using System;
|
using System.Collections.Generic;
|
using CoreCms.Net.Configuration;
|
using Microsoft.AspNetCore.Authorization;
|
using Microsoft.AspNetCore.Mvc;
|
using System.ComponentModel;
|
using System.Linq;
|
using System.Threading.Tasks;
|
using CoreCms.Net.Model.Entities;
|
using CoreCms.Net.Model.ViewModels.UI;
|
using CoreCms.Net.Utility.Extensions;
|
using CoreCms.Net.Utility.Helper;
|
using SqlSugar;
|
using CoreCms.Net.Caching.AccressToken;
|
using CoreCms.Net.DTO.WeChatShipping;
|
using CoreCms.Net.IServices;
|
using CoreCms.Net.WeChat.Service.HttpClients;
|
using CoreCms.Net.WeChat.Service.Enums;
|
using SKIT.FlurlHttpClient.Wechat.Api.Models;
|
using SKIT.FlurlHttpClient.Wechat.Api;
|
using CoreCms.Net.Model.FromBody;
|
using CoreCms.Net.Web.Admin.Infrastructure;
|
|
namespace CoreCms.Net.Web.Admin.Controllers.WeChatShipping
|
{
|
|
/// <summary>
|
/// 微信发货信息订单管理
|
///</summary>
|
[Description("微信发货信息订单管理")]
|
[Route("api/[controller]/[action]")]
|
[ApiController]
|
[RequiredErrorForAdmin]
|
[Authorize(Permissions.Name)]
|
public class WeChatShippingOrderController : ControllerBase
|
{
|
|
private readonly IWeChatApiHttpClientFactory _weChatApiHttpClientFactory;
|
private readonly ICoreCmsBillPaymentsServices _billPaymentsServices;
|
private readonly ICoreCmsOrderServices _orderServices;
|
private readonly ICoreCmsOrderItemServices _orderItemServices;
|
private readonly ICoreCmsServicesServices _servicesServices;
|
private readonly IWeChatShippingDeliveryServices _weChatShippingDeliveryServices;
|
private readonly ICoreCmsBillDeliveryServices _billDeliveryServices;
|
|
|
/// <summary>
|
/// 构造函数
|
/// </summary>
|
public WeChatShippingOrderController(IWeChatApiHttpClientFactory weChatApiHttpClientFactory, ICoreCmsBillPaymentsServices billPaymentsServices, ICoreCmsOrderServices orderServices, ICoreCmsOrderItemServices orderItemServices, ICoreCmsServicesServices servicesServices, IWeChatShippingDeliveryServices weChatShippingDeliveryServices, ICoreCmsBillDeliveryServices billDeliveryServices)
|
{
|
_weChatApiHttpClientFactory = weChatApiHttpClientFactory;
|
_billPaymentsServices = billPaymentsServices;
|
_orderServices = orderServices;
|
_orderItemServices = orderItemServices;
|
_servicesServices = servicesServices;
|
_weChatShippingDeliveryServices = weChatShippingDeliveryServices;
|
_billDeliveryServices = billDeliveryServices;
|
}
|
|
|
#region 获取列表============================================================
|
|
// POST: Api/CoreCmsBillReship/GetPageList
|
/// <summary>
|
/// 获取列表
|
/// </summary>
|
/// <returns></returns>
|
[HttpPost]
|
[Description("获取列表")]
|
public async Task<AdminUiCallBack> GetPageList()
|
{
|
var jm = new AdminUiCallBack();
|
var pageCurrent = Request.Form["page"].FirstOrDefault().ObjectToInt(1);
|
var pageSize = Request.Form["limit"].FirstOrDefault().ObjectToInt(20);
|
|
var last_index = Request.Form["last_index"].FirstOrDefault();
|
|
//获取排序字段
|
|
//设置排序方式
|
var orderDirection = Request.Form["orderDirection"].FirstOrDefault();
|
var orderBy = orderDirection switch
|
{
|
"asc" => OrderByType.Asc,
|
"desc" => OrderByType.Desc,
|
_ => OrderByType.Desc
|
};
|
//查询筛选
|
|
|
//构建请求
|
var client = _weChatApiHttpClientFactory.CreateWxOpenClient();
|
var accessToken = WeChatCacheAccessTokenHelper.GetWxOpenAccessToken();
|
var request = new WxaSecOrderGetOrderListRequest()
|
{
|
AccessToken = accessToken
|
};
|
|
//构建查询
|
var status = Request.Form["status"].FirstOrDefault().ObjectToInt(0);
|
if (status > 0)
|
{
|
request.OrderState = status;
|
}
|
|
if (pageCurrent > 1)
|
{
|
request.Limit = pageCurrent;
|
}
|
|
if (!string.IsNullOrEmpty(last_index))
|
{
|
request.Offset = last_index;
|
}
|
|
if (pageSize > 0)
|
{
|
request.Limit = pageSize;
|
}
|
|
var response = await client.ExecuteWxaSecOrderGetOrderListAsync(request, HttpContext.RequestAborted);
|
if (response.ErrorCode == (int)WeChatReturnCode.ReturnCode.请求成功)
|
{
|
|
//返回数据
|
jm.data = response.OrderList;
|
jm.otherData = response;
|
jm.code = 0;
|
jm.count = 10000;
|
jm.msg = "数据调用成功!";
|
}
|
else
|
{
|
jm.code = 1;
|
jm.msg = response.ErrorMessage;
|
}
|
|
//获取数据
|
|
return jm;
|
}
|
|
#endregion
|
|
#region 首页数据============================================================
|
|
// POST: Api/CoreCmsBillReship/GetIndex
|
/// <summary>
|
/// 首页数据
|
/// </summary>
|
/// <returns></returns>
|
[HttpPost]
|
[Description("首页数据")]
|
public AdminUiCallBack GetIndex()
|
{
|
//返回数据
|
var jm = new AdminUiCallBack { code = 0 };
|
|
var status = EnumHelper.EnumToList<GlobalEnumVars.WeChatShippingOrderStatus>();
|
var logisticsType = EnumHelper.EnumToList<GlobalEnumVars.WeChatShippingLogisticsType>();
|
|
jm.data = new
|
{
|
status,
|
logisticsType
|
};
|
|
|
return jm;
|
}
|
|
#endregion
|
|
#region 创建发货单============================================================
|
/// <summary>
|
/// 创建发货单
|
/// </summary>
|
/// <returns></returns>
|
[HttpPost]
|
[Description("创建数据")]
|
public async Task<AdminUiCallBack> GetCreate([FromBody] FMStringId entity)
|
{
|
//返回数据
|
var jm = new AdminUiCallBack { code = 0 };
|
|
var paymentOrder = await _billPaymentsServices.QueryByClauseAsync(p => p.paymentId == entity.id);
|
if (paymentOrder == null)
|
{
|
jm.msg = "支付单获取失败";
|
return jm;
|
}
|
|
var billDeliveryList = new List<CoreCmsBillDelivery>();
|
|
var orderTitle = string.Empty;
|
var logisticsTypeValue = 0;
|
if (paymentOrder.type == (int)GlobalEnumVars.BillPaymentsType.Recharge)
|
{
|
orderTitle = "用户充值" + paymentOrder.money + "元";
|
logisticsTypeValue = (int)GlobalEnumVars.WeChatShippingLogisticsType.虚拟商品;
|
}
|
else if (paymentOrder.type == (int)GlobalEnumVars.BillPaymentsType.FormOrder)
|
{
|
orderTitle = "表单订单";
|
logisticsTypeValue = (int)GlobalEnumVars.WeChatShippingLogisticsType.虚拟商品;
|
}
|
else if (paymentOrder.type == (int)GlobalEnumVars.BillPaymentsType.FormPay)
|
{
|
orderTitle = "表单付款码支付";
|
logisticsTypeValue = (int)GlobalEnumVars.WeChatShippingLogisticsType.虚拟商品;
|
}
|
else if (paymentOrder.type == (int)GlobalEnumVars.BillPaymentsType.ServiceOrder)
|
{
|
var id = Convert.ToInt32(paymentOrder.sourceId);
|
var serviceModel = await _servicesServices.QueryByClauseAsync(p => p.id == id);
|
if (serviceModel == null)
|
{
|
jm.msg = "服务项目获取失败";
|
return jm;
|
}
|
|
orderTitle = serviceModel.title;
|
logisticsTypeValue = (int)GlobalEnumVars.WeChatShippingLogisticsType.虚拟商品;
|
}
|
else if (paymentOrder.type == (int)GlobalEnumVars.BillPaymentsType.Common
|
|| paymentOrder.type == (int)GlobalEnumVars.BillPaymentsType.PinTuan
|
|| paymentOrder.type == (int)GlobalEnumVars.BillPaymentsType.Group
|
|| paymentOrder.type == (int)GlobalEnumVars.BillPaymentsType.Seckill
|
|| paymentOrder.type == (int)GlobalEnumVars.BillPaymentsType.Solitaire
|
)
|
{
|
|
billDeliveryList = await _billDeliveryServices.QueryListByClauseAsync(p => p.orderId == paymentOrder.sourceId);
|
//获取订单
|
var order = await _orderServices.QueryByClauseAsync(p => p.orderId == paymentOrder.sourceId);
|
if (order == null)
|
{
|
jm.msg = "关联订单获取失败";
|
return jm;
|
}
|
|
logisticsTypeValue = order.receiptType switch
|
{
|
//设置物流的发货模式
|
(int)GlobalEnumVars.OrderReceiptType.SelfDelivery => (int)GlobalEnumVars.WeChatShippingLogisticsType.用户自提,
|
(int)GlobalEnumVars.OrderReceiptType.IntraCityService => (int)GlobalEnumVars.WeChatShippingLogisticsType.同城配送,
|
(int)GlobalEnumVars.OrderReceiptType.Logistics => (int)GlobalEnumVars.WeChatShippingLogisticsType.物流配送,
|
_ => logisticsTypeValue
|
};
|
var orderItems = await _orderItemServices.QueryListByClauseAsync(p => p.orderId == paymentOrder.sourceId);
|
if (!orderItems.Any())
|
{
|
jm.msg = "订单详情获取失败";
|
return jm;
|
}
|
else
|
{
|
if (orderItems.Count == 1)
|
{
|
orderTitle = orderItems.FirstOrDefault()?.name;
|
}
|
else
|
{
|
orderItems.ForEach(p => { orderTitle += p.name + ";"; });
|
}
|
}
|
|
}
|
else if (paymentOrder.type == (int)GlobalEnumVars.BillPaymentsType.Bargain)
|
{
|
orderTitle = "砍价活动";
|
logisticsTypeValue = (int)GlobalEnumVars.WeChatShippingLogisticsType.物流配送;
|
}
|
else if (paymentOrder.type == (int)GlobalEnumVars.BillPaymentsType.Giveaway)
|
{
|
orderTitle = "购物赠品";
|
logisticsTypeValue = (int)GlobalEnumVars.WeChatShippingLogisticsType.虚拟商品;
|
}
|
else
|
{
|
jm.msg = "订单类型获取失败";
|
return jm;
|
}
|
|
var status = EnumHelper.EnumToList<GlobalEnumVars.WeChatShippingOrderStatus>();
|
var logisticsType = EnumHelper.EnumToList<GlobalEnumVars.WeChatShippingLogisticsType>();
|
|
|
//构建请求
|
var client = _weChatApiHttpClientFactory.CreateWxOpenClient();
|
var accessToken = WeChatCacheAccessTokenHelper.GetWxOpenAccessToken();
|
var request = new WxaSecOrderGetOrderRequest
|
{
|
AccessToken = accessToken,
|
TransactionId = entity.data.ToString(),
|
OutTradeNumber = entity.id
|
};
|
|
var deliveryCompany = await _weChatShippingDeliveryServices.GetCaChe();
|
|
|
var response = await client.ExecuteWxaSecOrderGetOrderAsync(request, HttpContext.RequestAborted);
|
if (response.IsSuccessful())
|
{
|
jm.code = 0;
|
jm.data = new
|
{
|
response.Order,
|
status,
|
logisticsType,
|
orderTitle,
|
deliveryCompany,
|
billDeliveryList,
|
paymentOrder,
|
logisticsTypeValue
|
};
|
}
|
else
|
{
|
jm.code = 1;
|
jm.msg = response.ErrorMessage;
|
}
|
return jm;
|
}
|
#endregion
|
|
#region 创建提交============================================================
|
// POST: Api/CoreCmsAgent/DoCreate
|
/// <summary>
|
/// 创建提交
|
/// </summary>
|
/// <param name="entity"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[Description("创建提交")]
|
public async Task<AdminUiCallBack> DoCreate([FromBody] OrderShippingCreatePost entity)
|
{
|
var jm = new AdminUiCallBack();
|
|
var shippingList = new List<WxaSecOrderUploadShippingInfoRequest.Types.Shipping>();
|
|
if (entity.logistics_type == (int)GlobalEnumVars.WeChatShippingLogisticsType.物流配送)
|
{
|
if (entity.shipping_list == null || !entity.shipping_list.Any())
|
{
|
jm.msg = "物流配送请完善快递信息";
|
return jm;
|
}
|
|
foreach (var item in entity.shipping_list)
|
{
|
if (string.IsNullOrEmpty(item.express_company) && string.IsNullOrEmpty(item.tracking_no))
|
{
|
jm.msg = "请填写完整的快递信息";
|
return jm;
|
}
|
var shipping = new WxaSecOrderUploadShippingInfoRequest.Types.Shipping
|
{
|
ItemDescription = entity.item_desc,
|
ExpressCompany = item.express_company,
|
TrackingNumber = item.tracking_no
|
};
|
shippingList.Add(shipping);
|
}
|
}
|
else if (entity.logistics_type == (int)GlobalEnumVars.WeChatShippingLogisticsType.同城配送)
|
{
|
var shipping = new WxaSecOrderUploadShippingInfoRequest.Types.Shipping
|
{
|
ItemDescription = entity.item_desc,
|
ExpressCompany = entity.cityDistributionName,
|
TrackingNumber = entity.cityDistributionNumber
|
};
|
shippingList.Add(shipping);
|
}
|
else if (entity.logistics_type == (int)GlobalEnumVars.WeChatShippingLogisticsType.用户自提 || entity.logistics_type == (int)GlobalEnumVars.WeChatShippingLogisticsType.虚拟商品)
|
{
|
var shipping = new WxaSecOrderUploadShippingInfoRequest.Types.Shipping
|
{
|
ItemDescription = entity.item_desc
|
};
|
shippingList.Add(shipping);
|
}
|
else
|
{
|
jm.msg = "请提交合理的物流模式";
|
return jm;
|
}
|
|
var request = new WxaSecOrderUploadShippingInfoRequest
|
{
|
OrderKey = new WxaSecOrderUploadCombinedShippingInfoRequest.Types.OrderKey()
|
{
|
OrderNumberType = 2,
|
TransactionId = entity.transaction_id,
|
MerchantId = entity.merchant_id,
|
OutTradeNumber = entity.merchant_trade_no
|
},
|
LogisticsType = entity.logistics_type,
|
IsFinishAll = entity.is_all_delivered,
|
ShippingList = shippingList,
|
Payer = new WxaSecOrderUploadCombinedShippingInfoRequest.Types.Payer() { OpenId = entity.openid }
|
};
|
|
if (request.LogisticsType == (int)GlobalEnumVars.WeChatShippingLogisticsType.物流配送 && request.IsFinishAll == true)
|
{
|
if (shippingList.Count == 1)
|
{
|
request.DeliveryMode = (int)GlobalEnumVars.WeChatShippingDeliveryMode.UNIFIED_DELIVERY;
|
}
|
else
|
{
|
request.DeliveryMode = (int)GlobalEnumVars.WeChatShippingDeliveryMode.SPLIT_DELIVERY;
|
}
|
}
|
else if (request.LogisticsType == (int)GlobalEnumVars.WeChatShippingLogisticsType.物流配送 && request.IsFinishAll == false)
|
{
|
request.DeliveryMode = (int)GlobalEnumVars.WeChatShippingDeliveryMode.SPLIT_DELIVERY;
|
}
|
else
|
{
|
request.DeliveryMode = (int)GlobalEnumVars.WeChatShippingDeliveryMode.UNIFIED_DELIVERY;
|
}
|
|
|
|
//构建请求
|
var client = _weChatApiHttpClientFactory.CreateWxOpenClient();
|
|
request.AccessToken = WeChatCacheAccessTokenHelper.GetWxOpenAccessToken();
|
|
var response = await client.ExecuteWxaSecOrderUploadShippingInfoAsync(request, HttpContext.RequestAborted);
|
|
if (response.IsSuccessful())
|
{
|
jm.code = 0;
|
jm.data = new
|
{
|
response
|
};
|
jm.msg = "提交成功";
|
}
|
else
|
{
|
jm.code = 1;
|
jm.msg = response.ErrorMessage;
|
}
|
|
return jm;
|
}
|
#endregion
|
|
#region 重新发货============================================================
|
/// <summary>
|
/// 重新发货
|
/// </summary>
|
/// <returns></returns>
|
[HttpPost]
|
[Description("创建数据")]
|
public async Task<AdminUiCallBack> GetUpdate([FromBody] FMStringId entity)
|
{
|
//返回数据
|
var jm = new AdminUiCallBack { code = 0 };
|
|
var paymentOrder = await _billPaymentsServices.QueryByClauseAsync(p => p.paymentId == entity.id);
|
if (paymentOrder == null)
|
{
|
jm.msg = "支付单获取失败";
|
return jm;
|
}
|
|
var status = EnumHelper.EnumToList<GlobalEnumVars.WeChatShippingOrderStatus>();
|
var logisticsType = EnumHelper.EnumToList<GlobalEnumVars.WeChatShippingLogisticsType>();
|
|
|
//构建请求
|
var client = _weChatApiHttpClientFactory.CreateWxOpenClient();
|
var accessToken = WeChatCacheAccessTokenHelper.GetWxOpenAccessToken();
|
var request = new WxaSecOrderGetOrderRequest
|
{
|
AccessToken = accessToken,
|
TransactionId = entity.data.ToString(),
|
OutTradeNumber = entity.id
|
};
|
|
var deliveryCompany = await _weChatShippingDeliveryServices.GetCaChe();
|
|
|
var response = await client.ExecuteWxaSecOrderGetOrderAsync(request, HttpContext.RequestAborted);
|
if (response.IsSuccessful())
|
{
|
jm.code = 0;
|
jm.data = new
|
{
|
response.Order,
|
status,
|
logisticsType,
|
deliveryCompany
|
};
|
}
|
else
|
{
|
jm.code = 1;
|
jm.msg = response.ErrorMessage;
|
}
|
return jm;
|
}
|
#endregion
|
|
#region 重新发货提交============================================================
|
/// <summary>
|
/// 重新发货提交
|
/// </summary>
|
/// <param name="entity"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[Description("创建提交")]
|
public AdminUiCallBack DoUpdate([FromBody] Object entity)
|
{
|
var jm = new AdminUiCallBack();
|
|
return jm;
|
}
|
#endregion
|
|
#region 预览数据============================================================
|
// POST: Api/CoreCmsAgent/GetDetails/10
|
/// <summary>
|
/// 预览数据
|
/// </summary>
|
/// <param name="entity"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[Description("预览数据")]
|
public async Task<AdminUiCallBack> GetDetails([FromBody] FMStringId entity)
|
{
|
//返回数据
|
var jm = new AdminUiCallBack { code = 0 };
|
|
var paymentOrder = await _billPaymentsServices.QueryByClauseAsync(p => p.paymentId == entity.id);
|
if (paymentOrder == null)
|
{
|
jm.msg = "支付单获取失败";
|
return jm;
|
}
|
|
var orderTitle = string.Empty;
|
|
if (paymentOrder.type == (int)GlobalEnumVars.BillPaymentsType.Recharge)
|
{
|
orderTitle = "用户充值" + paymentOrder.money + "元";
|
}
|
else if (paymentOrder.type == (int)GlobalEnumVars.BillPaymentsType.FormOrder)
|
{
|
orderTitle = "表单订单";
|
}
|
else if (paymentOrder.type == (int)GlobalEnumVars.BillPaymentsType.FormPay)
|
{
|
orderTitle = "表单付款码支付";
|
}
|
else if (paymentOrder.type == (int)GlobalEnumVars.BillPaymentsType.ServiceOrder)
|
{
|
var id = Convert.ToInt32(paymentOrder.sourceId);
|
var serviceModel = await _servicesServices.QueryByClauseAsync(p => p.id == id);
|
if (serviceModel == null)
|
{
|
jm.msg = "服务项目获取失败";
|
return jm;
|
}
|
|
orderTitle = serviceModel.title;
|
}
|
else if (paymentOrder.type == (int)GlobalEnumVars.BillPaymentsType.Common
|
|| paymentOrder.type == (int)GlobalEnumVars.BillPaymentsType.PinTuan
|
|| paymentOrder.type == (int)GlobalEnumVars.BillPaymentsType.Group
|
|| paymentOrder.type == (int)GlobalEnumVars.BillPaymentsType.Seckill
|
|| paymentOrder.type == (int)GlobalEnumVars.BillPaymentsType.Solitaire
|
)
|
{
|
var orderItems = await _orderItemServices.QueryListByClauseAsync(p => p.orderId == paymentOrder.sourceId);
|
if (!orderItems.Any())
|
{
|
jm.msg = "订单详情获取失败";
|
return jm;
|
}
|
else
|
{
|
if (orderItems.Count == 1)
|
{
|
orderTitle = orderItems.FirstOrDefault()?.name;
|
}
|
else
|
{
|
orderItems.ForEach(p => { orderTitle += p.name + ";"; });
|
}
|
}
|
}
|
else if (paymentOrder.type == (int)GlobalEnumVars.BillPaymentsType.Bargain)
|
{
|
orderTitle = "砍价活动";
|
}
|
else if (paymentOrder.type == (int)GlobalEnumVars.BillPaymentsType.Giveaway)
|
{
|
orderTitle = "购物赠品";
|
}
|
else
|
{
|
jm.msg = "订单类型获取失败";
|
return jm;
|
}
|
|
var status = EnumHelper.EnumToList<GlobalEnumVars.WeChatShippingOrderStatus>();
|
var logisticsType = EnumHelper.EnumToList<GlobalEnumVars.WeChatShippingLogisticsType>();
|
|
|
//构建请求
|
var client = _weChatApiHttpClientFactory.CreateWxOpenClient();
|
var accessToken = WeChatCacheAccessTokenHelper.GetWxOpenAccessToken();
|
var request = new WxaSecOrderGetOrderRequest
|
{
|
AccessToken = accessToken,
|
TransactionId = entity.data.ToString(),
|
OutTradeNumber = entity.id
|
};
|
|
var deliveryCompany = await _weChatShippingDeliveryServices.GetCaChe();
|
|
|
var response = await client.ExecuteWxaSecOrderGetOrderAsync(request, HttpContext.RequestAborted);
|
if (response.IsSuccessful())
|
{
|
jm.code = 0;
|
jm.data = new
|
{
|
response.Order,
|
status,
|
logisticsType,
|
orderTitle,
|
deliveryCompany
|
};
|
}
|
else
|
{
|
jm.code = 1;
|
jm.msg = response.ErrorMessage;
|
}
|
return jm;
|
}
|
#endregion
|
|
}
|
}
|
