【新增】快递物流查询接口新增v2版本,实现v1与v2版本切换使用。

This commit is contained in:
jianweie code
2023-12-29 21:35:34 +08:00
parent d722161e65
commit 892c9eb284
8 changed files with 663 additions and 131 deletions

View File

@@ -21,6 +21,7 @@ using CoreCms.Net.Model.ViewModels.UI;
using CoreCms.Net.Utility.Helper;
using Flurl.Http;
using Newtonsoft.Json;
using SqlSugar.Extensions;
namespace CoreCms.Net.Services
@@ -72,6 +73,7 @@ namespace CoreCms.Net.Services
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);
@@ -82,69 +84,123 @@ namespace CoreCms.Net.Services
var signStr = "maxSize" + maxSize + "showapi_appid" + showApiAppid + "showapi_timestamp" + showApiTimesTamp + showApiSecret;
var md5Sign = CommonHelper.Md5For32(signStr).ToLower();
var 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<ShowApiGetExpressCompanyListResult>();
if (result.showapi_res_code == 0)
string url;
if (showApiLogisticsVersion == 1)
{
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)
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)
{
var list = new List<CoreCmsLogistics>();
var systemLogistics = SystemSettingDictionary.GetSystemLogistics();
systemLogistics.ForEach(p =>
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 logistics = new CoreCmsLogistics();
logistics.logiCode = p.sKey;
logistics.logiName = p.sDescription;
logistics.imgUrl = "";
logistics.phone = shopMobile;
logistics.url = "";
logistics.sort = -1;
logistics.isDelete = false;
var list = new List<CoreCmsLogistics>();
list.Add(logistics);
});
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;
var count = 0;
result.showapi_res_body.expressList.ForEach(p =>
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
{
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 ? "数据刷新成功" : "数据刷新失败";
jm.msg = "接口获取数据失败";
}
}
else
{
jm.msg = "接口获取数据失败";
jm.msg = result.showapi_res_error;
}
}
else
{
jm.msg = result.showapi_res_error;
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;
}
@@ -177,8 +233,8 @@ namespace CoreCms.Net.Services
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);
@@ -187,70 +243,165 @@ namespace CoreCms.Net.Services
var signStr = "com" + com + "nu" + number + "phone" + phone + "showapi_appid" + showApiAppid + "showapi_timestamp" + showApiTimesTamp + showApiSecret;
var md5Sign = CommonHelper.Md5For32(signStr).ToLower();
var 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<ShowApiGetExpressPollResult>();
if (result.showapi_res_code != 0)
string url;
if (showApiLogisticsVersion == 1)
{
jm.status = false;
jm.msg = result.showapi_res_error;
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
{
switch (result.showapi_res_body.ret_code)
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)
{
case 0:
jm.status = true;
jm.msg = "查询成功";
jm.data = result.showapi_res_body;
break;
case 1:
jm.status = false;
jm.msg = "输入参数错误";
jm.data = result.showapi_res_body;
break;
case 2:
jm.status = false;
jm.msg = "查不到物流信息";
jm.data = result.showapi_res_body;
break;
case 3:
jm.status = false;
jm.msg = "单号不符合规则";
jm.data = result.showapi_res_body;
break;
case 4:
jm.status = false;
jm.msg = "快递公司编码不符合规则";
jm.data = result.showapi_res_body;
break;
case 5:
jm.status = false;
jm.msg = "快递查询渠道异常";
jm.data = result.showapi_res_body;
break;
case 6:
jm.status = false;
jm.msg = " auto时未查到单号对应的快递公司,请指定快递公司编码";
jm.data = result.showapi_res_body;
break;
case 7:
jm.status = false;
jm.msg = "单号与手机号不匹配";
jm.data = result.showapi_res_body;
break;
default:
jm.status = false;
jm.msg = "接口调用失败";
jm.data = result.showapi_res_body;
break;
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;
}
}
}