/***********************************************************************
|
* Project: baifenBinfa
|
* ProjectName: 百分兵法管理系统
|
* Web: http://chuanyin.com
|
* Author:
|
* Email:
|
* CreateTime: 202403/02
|
* Description: 暂无
|
***********************************************************************/
|
|
using System;
|
using System.Collections.Generic;
|
using System.Threading.Tasks;
|
using CoreCms.Net.Configuration;
|
using CoreCms.Net.IRepository;
|
using CoreCms.Net.IRepository.UnitOfWork;
|
using CoreCms.Net.IServices;
|
using CoreCms.Net.Model.Entities;
|
using CoreCms.Net.Model.ViewModels.Api;
|
using CoreCms.Net.Model.ViewModels.UI;
|
using CoreCms.Net.Utility.Helper;
|
using Flurl.Http;
|
using Newtonsoft.Json;
|
using SqlSugar.Extensions;
|
|
|
namespace CoreCms.Net.Services
|
{
|
/// <summary>
|
/// 物流公司表 接口实现
|
/// </summary>
|
public class CoreCmsLogisticsServices : BaseServices<CoreCmsLogistics>, ICoreCmsLogisticsServices
|
{
|
private readonly ICoreCmsLogisticsRepository _dal;
|
private readonly ICoreCmsSettingServices _settingServices;
|
private readonly IUnitOfWork _unitOfWork;
|
|
|
|
public CoreCmsLogisticsServices(IUnitOfWork unitOfWork, ICoreCmsLogisticsRepository dal, ICoreCmsSettingServices settingServices)
|
{
|
this._dal = dal;
|
_settingServices = settingServices;
|
base.BaseDal = dal;
|
_unitOfWork = unitOfWork;
|
}
|
|
|
|
/// <summary>
|
/// 根据物流编码取物流名称等信息
|
/// </summary>
|
/// <param name="logiCode">物流编码</param>
|
/// <returns></returns>
|
public async Task<WebApiCallBack> GetLogiInfo(string logiCode)
|
{
|
var jm = new WebApiCallBack();
|
|
var model = await _dal.QueryByClauseAsync(p => p.logiCode == logiCode);
|
jm.status = model != null;
|
jm.data = model;
|
jm.msg = jm.status ? GlobalConstVars.GetDataSuccess : GlobalConstVars.GetDataFailure;
|
|
return jm;
|
}
|
|
|
/// <summary>
|
/// 通过接口更新所有快递公司信息
|
/// </summary>
|
public async Task<AdminUiCallBack> DoUpdateCompany()
|
{
|
var jm = new AdminUiCallBack();
|
|
var allConfigs = await _settingServices.GetConfigDictionaries();
|
var showApiLogisticsVersion = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.ShowApiLogisticsVersion).ObjToInt(1);
|
var showApiAppid = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.ShowApiAppid);
|
var showApiSecret = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.ShowApiSecret);
|
var shopMobile = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.ShopMobile);
|
|
var showApiTimesTamp = DateTime.Now.ToString("yyyyMMddHHmmss");
|
|
var maxSize = 1500;
|
var signStr = "maxSize" + maxSize + "showapi_appid" + showApiAppid + "showapi_timestamp" + showApiTimesTamp + showApiSecret;
|
var md5Sign = CommonHelper.Md5For32(signStr).ToLower();
|
|
string url;
|
if (showApiLogisticsVersion == 1)
|
{
|
url = "https://route.showapi.com/64-20?expName=&maxSize=1500&page=&showapi_appid=" + showApiAppid + "&showapi_timestamp=" + showApiTimesTamp + "&showapi_sign=" + md5Sign;
|
|
var result = await url.PostAsync().ReceiveJson<ShowApiGetExpressCompanyListResultV1>();
|
|
if (result.showapi_res_code == 0)
|
{
|
if (result.showapi_res_body != null && result.showapi_res_body.ret_code == 0 && result.showapi_res_body.expressList != null && result.showapi_res_body.expressList.Count > 0)
|
{
|
var list = new List<CoreCmsLogistics>();
|
|
var systemLogistics = SystemSettingDictionary.GetSystemLogistics();
|
systemLogistics.ForEach(p =>
|
{
|
var logistics = new CoreCmsLogistics();
|
logistics.logiCode = p.sKey;
|
logistics.logiName = p.sDescription;
|
logistics.imgUrl = "";
|
logistics.phone = shopMobile;
|
logistics.url = "";
|
logistics.sort = -1;
|
logistics.isDelete = false;
|
|
list.Add(logistics);
|
});
|
|
var count = 0;
|
result.showapi_res_body.expressList.ForEach(p =>
|
{
|
var logistics = new CoreCmsLogistics();
|
logistics.logiCode = p.simpleName;
|
logistics.logiName = p.expName;
|
logistics.imgUrl = p.imgUrl;
|
logistics.phone = p.phone;
|
logistics.url = p.url;
|
logistics.sort = count * 5;
|
logistics.isDelete = false;
|
|
list.Add(logistics);
|
count++;
|
});
|
await _dal.DeleteAsync(p => p.id > 0);
|
var bl = await _dal.InsertAsync(list) > 0;
|
jm.code = bl ? 0 : 1;
|
jm.msg = bl ? "数据刷新成功" : "数据刷新失败";
|
}
|
else
|
{
|
jm.msg = "接口获取数据失败";
|
}
|
}
|
else
|
{
|
jm.msg = result.showapi_res_error;
|
}
|
}
|
else
|
{
|
url = "https://route.showapi.com/2650-5?expName=&maxSize=1500&page=&showapi_appid=" + showApiAppid + "&showapi_timestamp=" + showApiTimesTamp + "&showapi_sign=" + md5Sign;
|
|
var result = await url.PostAsync().ReceiveJson<ShowApiGetExpressCompanyListResultV2>();
|
|
if (result.showapi_res_code == 0)
|
{
|
if (result.showapi_res_body != null && result.showapi_res_body.ret_code == 0 && result.showapi_res_body.express_list != null && result.showapi_res_body.express_list.Count > 0)
|
{
|
var list = new List<CoreCmsLogistics>();
|
|
var systemLogistics = SystemSettingDictionary.GetSystemLogistics();
|
systemLogistics.ForEach(p =>
|
{
|
var logistics = new CoreCmsLogistics();
|
logistics.logiCode = p.sKey;
|
logistics.logiName = p.sDescription;
|
logistics.imgUrl = "";
|
logistics.phone = shopMobile;
|
logistics.url = "";
|
logistics.sort = -1;
|
logistics.isDelete = false;
|
|
list.Add(logistics);
|
});
|
|
var count = 0;
|
result.showapi_res_body.express_list.ForEach(p =>
|
{
|
var logistics = new CoreCmsLogistics();
|
logistics.logiCode = p.com;
|
logistics.logiName = p.exp_name;
|
logistics.imgUrl = p.img_url;
|
logistics.phone = p.phone;
|
logistics.url = p.url;
|
logistics.sort = count * 5;
|
logistics.isDelete = false;
|
|
list.Add(logistics);
|
count++;
|
});
|
await _dal.DeleteAsync(p => p.id > 0);
|
var bl = await _dal.InsertAsync(list) > 0;
|
jm.code = bl ? 0 : 1;
|
jm.msg = bl ? "数据刷新成功" : "数据刷新失败";
|
}
|
else
|
{
|
jm.msg = "接口获取数据失败";
|
}
|
}
|
else
|
{
|
jm.msg = result.showapi_res_error;
|
}
|
}
|
|
|
return jm;
|
}
|
|
|
/// <summary>
|
/// 通过接口获取快递信息
|
/// </summary>
|
/// <param name="com">来源</param>
|
/// <param name="number">编号</param>
|
/// <param name="phone">手机号码</param>
|
/// <returns></returns>
|
public async Task<WebApiCallBack> ExpressPoll(string com, string number, string phone)
|
{
|
var jm = new WebApiCallBack();
|
|
|
if (string.IsNullOrEmpty(com))
|
{
|
jm.msg = "请提交来源";
|
return jm;
|
}
|
else if (string.IsNullOrEmpty(number))
|
{
|
jm.msg = "请提交编号";
|
return jm;
|
}
|
else if (string.IsNullOrEmpty(phone))
|
{
|
jm.msg = "请提交手机号码";
|
return jm;
|
}
|
|
var allConfigs = await _settingServices.GetConfigDictionaries();
|
var showApiLogisticsVersion = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.ShowApiLogisticsVersion).ObjToInt(1);
|
var showApiAppid = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.ShowApiAppid);
|
var showApiSecret = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.ShowApiSecret);
|
|
var showApiTimesTamp = DateTime.Now.ToString("yyyyMMddHHmmss");
|
|
var signStr = "com" + com + "nu" + number + "phone" + phone + "showapi_appid" + showApiAppid + "showapi_timestamp" + showApiTimesTamp + showApiSecret;
|
var md5Sign = CommonHelper.Md5For32(signStr).ToLower();
|
|
string url;
|
if (showApiLogisticsVersion == 1)
|
{
|
url = "https://route.showapi.com/64-19?com=" + com + "&nu=" + number + "&phone=" + phone + "&showapi_appid=" + showApiAppid + "&showapi_timestamp=" + showApiTimesTamp + "&showapi_sign=" + md5Sign;
|
var result = await url.PostAsync().ReceiveJson<ShowApiGetExpressPollResultV1>();
|
if (result.showapi_res_code != 0)
|
{
|
jm.status = false;
|
jm.msg = result.showapi_res_error;
|
}
|
else
|
{
|
jm = GetLogiInfo(1, result.showapi_res_code, result.showapi_res_body);
|
}
|
}
|
else
|
{
|
url = "https://route.showapi.com/2650-3?com=" + com + "&nu=" + number + "&phone=" + phone + "&showapi_appid=" + showApiAppid + "&showapi_timestamp=" + showApiTimesTamp + "&showapi_sign=" + md5Sign;
|
var result = await url.PostAsync().ReceiveJson<ShowApiGetExpressPollResultV2>();
|
if (result.showapi_res_code != 0)
|
{
|
jm.status = false;
|
jm.msg = result.showapi_res_error;
|
}
|
else
|
{
|
jm = GetLogiInfo(1, result.showapi_res_code, result.showapi_res_body);
|
}
|
}
|
return jm;
|
}
|
|
//根据状态反馈提示信息
|
private WebApiCallBack GetLogiInfo(int version, int retCode, object showapiResBody)
|
{
|
var jm = new WebApiCallBack();
|
|
if (retCode == 0)
|
{
|
jm.status = true;
|
jm.msg = "查询成功";
|
jm.data = showapiResBody;
|
}
|
else if (retCode == 1)
|
{
|
jm.status = false;
|
jm.msg = "输入参数错误";
|
jm.data = showapiResBody;
|
}
|
else if (retCode == 2)
|
{
|
jm.status = false;
|
jm.msg = "查不到物流信息";
|
jm.data = showapiResBody;
|
}
|
else if (retCode == 3)
|
{
|
jm.status = false;
|
jm.msg = "单号不符合规则";
|
jm.data = showapiResBody;
|
}
|
else if (retCode == 4)
|
{
|
jm.status = false;
|
jm.msg = "快递公司编码不符合规则";
|
jm.data = showapiResBody;
|
}
|
else if (retCode == 5)
|
{
|
jm.status = false;
|
jm.msg = "快递查询渠道异常";
|
jm.data = showapiResBody;
|
}
|
else if (retCode == 6)
|
{
|
jm.status = false;
|
jm.msg = " auto时未查到单号对应的快递公司,请指定快递公司编码";
|
jm.data = showapiResBody;
|
}
|
else if (retCode == 7)
|
{
|
jm.status = false;
|
jm.msg = "单号与手机号不匹配";
|
jm.data = showapiResBody;
|
}
|
else if (version == 2)
|
{
|
jm.status = true;
|
|
switch (retCode)
|
{
|
//101 揽件
|
//102 在途中
|
//103 派送中
|
//104 已签收(完结状态)
|
//105 用户拒签
|
//106 疑难件
|
//107 无效单(完结状态)
|
//108 超时单
|
//109 签收失败
|
//110 退回
|
//111 转投
|
//112 待签
|
//113 邮件回收
|
case 101:
|
jm.msg = "揽件";
|
break;
|
case 102:
|
jm.msg = "在途中";
|
break;
|
case 103:
|
jm.msg = "派送中";
|
break;
|
case 104:
|
jm.msg = "已签收(完结状态)";
|
break;
|
case 105:
|
jm.msg = "用户拒签";
|
break;
|
case 106:
|
jm.msg = "疑难件";
|
break;
|
case 107:
|
jm.msg = "无效单(完结状态)";
|
break;
|
case 108:
|
jm.msg = "超时单";
|
break;
|
case 109:
|
jm.msg = "签收失败";
|
break;
|
case 110:
|
jm.msg = "退回";
|
break;
|
case 111:
|
jm.msg = "转投";
|
break;
|
case 112:
|
jm.msg = "待签";
|
break;
|
case 113:
|
jm.msg = "邮件回收";
|
break;
|
default:
|
jm.status = false;
|
jm.msg = "未知状态";
|
break;
|
}
|
jm.data = showapiResBody;
|
}
|
else
|
{
|
jm.status = false;
|
jm.msg = "接口调用失败";
|
jm.data = showapiResBody;
|
}
|
|
return jm;
|
}
|
|
}
|
}
|
