coreshoppro/CoreCms.Net.RedisMQ/WeChatPayShippingSubscribe.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using CoreCms.Net.Caching.AccressToken;
using CoreCms.Net.Configuration;
using CoreCms.Net.IServices;
using CoreCms.Net.Loging;
using CoreCms.Net.Utility.Extensions;
using CoreCms.Net.Utility.Helper;
using CoreCms.Net.WeChat.Service.HttpClients;
using InitQ.Abstractions;
using InitQ.Attributes;
using Newtonsoft.Json;
using SKIT.FlurlHttpClient.Wechat.Api;
using SKIT.FlurlHttpClient.Wechat.Api.Models;

namespace CoreCms.Net.RedisMQ
{
    /// <summary>
    /// 微信支付成功后推送到接口进行发货处理
    /// </summary>
    public class WeChatPayShippingSubscribe : IRedisSubscribe
    {
        private readonly IWeChatApiHttpClientFactory _weChatApiHttpClientFactory;
        private readonly ICoreCmsServicesServices _servicesServices;
        private readonly ICoreCmsBillPaymentsServices _billPaymentsServices;
        private readonly ICoreCmsBillDeliveryServices _billDeliveryServices;
        private readonly ICoreCmsOrderItemServices _orderItemServices;
        private readonly ICoreCmsUserServices _userServices;
        private readonly ICoreCmsUserWeChatInfoServices _weChatInfoServices;
        private readonly ICoreCmsOrderServices _orderServices;
        private readonly ICoreCmsSettingServices _settingServices;



        public WeChatPayShippingSubscribe(ICoreCmsBillPaymentsServices billPaymentsServices, IWeChatApiHttpClientFactory weChatApiHttpClientFactory, ICoreCmsServicesServices servicesServices, ICoreCmsBillDeliveryServices billDeliveryServices, ICoreCmsOrderItemServices orderItemServices, ICoreCmsUserServices userServices, ICoreCmsUserWeChatInfoServices weChatInfoServices, ICoreCmsOrderServices orderServices, ICoreCmsSettingServices settingServices)
        {
            _billPaymentsServices = billPaymentsServices;
            _weChatApiHttpClientFactory = weChatApiHttpClientFactory;
            _servicesServices = servicesServices;
            _billDeliveryServices = billDeliveryServices;
            _orderItemServices = orderItemServices;
            _userServices = userServices;
            _weChatInfoServices = weChatInfoServices;
            _orderServices = orderServices;
            _settingServices = settingServices;
        }

        /// <summary>
        /// 微信支付成功后推送到接口进行发货处理
        /// </summary>
        /// <param name="msg"></param>
        /// <returns></returns>
        [Subscribe(RedisMessageQueueKey.WeChatPayShipping)]
        private async Task WeChatPayNotice(string msg)
        {
            try
            {
                var paymentOrder = await _billPaymentsServices.QueryByClauseAsync(p => p.paymentId == msg);
                if (paymentOrder == null)
                {
                    NLogUtil.WriteAll(NLog.LogLevel.Info, LogType.RedisMessageQueue, "微信发货信息处理", msg + "：支付单不存在");
                    return;
                }
                else
                {
                    if (paymentOrder.paymentCode != GlobalEnumVars.PaymentsTypes.wechatpay.ToString())
                    {
                        NLogUtil.WriteAll(NLog.LogLevel.Info, LogType.RedisMessageQueue, "微信发货信息处理", msg + "：非微信支付方式不予处理");
                        return;
                    }




                    var client = _weChatApiHttpClientFactory.CreateWxOpenClient();
                    var accessToken = WeChatCacheAccessTokenHelper.GetWxOpenAccessToken();

                    var isTradeManagedRequest = new WxaSecOrderIsTradeManagedRequest()
                    {
                        AccessToken = accessToken
                    };
                    //商品名称
                    var orderTitle = string.Empty;
                    //检索是否开启了微信发货信息功能，才会进行后面的发货操作
                    var responseIsTradeManagedResponse = await client.ExecuteWxaSecOrderIsTradeManagedAsync(isTradeManagedRequest);
                    if (responseIsTradeManagedResponse.IsSuccessful() && responseIsTradeManagedResponse.IsTradeManaged)
                    {
                        //判断不同支付单类型下如何获取商品标题，目前只是简单标题，非商品订单如果需要详细到具体明细，建议扩展获取其他关联信息。
                        switch (paymentOrder.type)
                        {
                            case (int)GlobalEnumVars.BillPaymentsType.Recharge:
                                orderTitle = "用户充值" + paymentOrder.money + "元";
                                break;
                            case (int)GlobalEnumVars.BillPaymentsType.FormOrder:
                                orderTitle = "表单订单";
                                break;
                            case (int)GlobalEnumVars.BillPaymentsType.FormPay:
                                orderTitle = "表单付款码支付";
                                break;
                            case (int)GlobalEnumVars.BillPaymentsType.ServiceOrder:
                                {
                                    var id = Convert.ToInt32(paymentOrder.sourceId);
                                    var serviceModel = await _servicesServices.QueryByClauseAsync(p => p.id == id);
                                    if (serviceModel == null)
                                    {
                                        NLogUtil.WriteAll(NLog.LogLevel.Error, LogType.RedisMessageQueue, "微信发货信息处理", msg + "：服务项目获取失败");
                                        return;
                                    }
                                    orderTitle = serviceModel.title;
                                    break;
                                }
                            case (int)GlobalEnumVars.BillPaymentsType.Common:
                            case (int)GlobalEnumVars.BillPaymentsType.PinTuan:
                            case (int)GlobalEnumVars.BillPaymentsType.Group:
                            case (int)GlobalEnumVars.BillPaymentsType.Seckill:
                            case (int)GlobalEnumVars.BillPaymentsType.Solitaire:
                                {
                                    var orderItems = await _orderItemServices.QueryListByClauseAsync(p => p.orderId == paymentOrder.sourceId);
                                    if (!orderItems.Any())
                                    {
                                        NLogUtil.WriteAll(NLog.LogLevel.Error, LogType.RedisMessageQueue, "微信发货信息处理", msg + "：订单详情获取失败");
                                        return;
                                    }

                                    if (orderItems.Count == 1)
                                    {
                                        orderTitle = orderItems.FirstOrDefault()?.name;
                                    }
                                    else
                                    {
                                        orderItems.ForEach(p => { orderTitle += p.name + ";"; });
                                    }

                                    break;
                                }
                            case (int)GlobalEnumVars.BillPaymentsType.Bargain:
                                orderTitle = "砍价活动";
                                break;
                            case (int)GlobalEnumVars.BillPaymentsType.Giveaway:
                                orderTitle = "购物赠品";
                                break;
                            default:
                                NLogUtil.WriteAll(NLog.LogLevel.Error, LogType.RedisMessageQueue, "微信发货信息处理", msg + "：订单类型获取失败");
                                return;
                        }


                        //构建请求
                        var request = new WxaSecOrderUploadShippingInfoRequest
                        {
                            AccessToken = accessToken,
                            OrderKey = new WxaSecOrderUploadCombinedShippingInfoRequest.Types.OrderKey()
                            {
                                OrderNumberType = 2,
                                TransactionId = paymentOrder.tradeNo,
                            },
                            IsFinishAll = true
                        };


                        //组装参数

                        //获取openid
                        var user = await _userServices.QueryByClauseAsync(p => p.id == paymentOrder.userId);
                        if (user == null)
                        {
                            NLogUtil.WriteAll(NLog.LogLevel.Error, LogType.RedisMessageQueue, "微信发货信息处理", msg + "：用户信息获取失败");
                            return;
                        }

                        var weChatUserInfo = await _weChatInfoServices.QueryByClauseAsync(p => p.userId == user.id && p.type == (int)GlobalEnumVars.UserAccountTypes.微信小程序);
                        if (weChatUserInfo == null)
                        {
                            NLogUtil.WriteAll(NLog.LogLevel.Error, LogType.RedisMessageQueue, "微信发货信息处理", msg + "：用户信息openId获取失败");
                            return;
                        }

                        request.Payer = new WxaSecOrderUploadCombinedShippingInfoRequest.Types.Payer() { OpenId = weChatUserInfo.openid };

                        //设置发货信息
                        //如果是商品模式是，则去走快递或者自提及同城配送。
                        //两种情况：1支付单支付成功后，自动调用此模式处理充值，服务商品，用户自提的订单，2、如果是后台手动发货，处理发货的订单业务。
                        var shippingList = new List<WxaSecOrderUploadShippingInfoRequest.Types.Shipping>();

                        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 order = await _orderServices.QueryByClauseAsync(p => p.orderId == paymentOrder.sourceId);
                            if (order == null)
                            {
                                NLogUtil.WriteAll(NLog.LogLevel.Error, LogType.RedisMessageQueue, "微信发货信息处理", msg + "：订单获取失败");
                                return;
                            }

                            request.LogisticsType = order.receiptType switch
                            {
                                //设置物流的发货模式
                                (int)GlobalEnumVars.OrderReceiptType.SelfDelivery => (int)GlobalEnumVars.WeChatShippingLogisticsType.用户自提,
                                (int)GlobalEnumVars.OrderReceiptType.IntraCityService => (int)GlobalEnumVars.WeChatShippingLogisticsType.同城配送,
                                (int)GlobalEnumVars.OrderReceiptType.Logistics => (int)GlobalEnumVars.WeChatShippingLogisticsType.物流配送,
                                _ => request.LogisticsType
                            };

                            //判断订单是否发货
                            if (order.shipStatus is (int)GlobalEnumVars.OrderShipStatus.PartialYes or (int)GlobalEnumVars.OrderShipStatus.Yes)
                            {
                                //获取订单的发货信息
                                var orderBillDeliveries = await _billDeliveryServices.QueryListByClauseAsync(p => p.orderId == paymentOrder.sourceId);
                                if (orderBillDeliveries == null || !orderBillDeliveries.Any())
                                {
                                    NLogUtil.WriteAll(NLog.LogLevel.Error, LogType.RedisMessageQueue, "微信发货信息处理", msg + "：未获取到发货信息，自动发货停止操作");
                                    return;
                                }
                                shippingList.AddRange(orderBillDeliveries.Select(item => new WxaSecOrderUploadShippingInfoRequest.Types.Shipping { ItemDescription = orderTitle, ExpressCompany = item.thirdPartylogiCode, TrackingNumber = item.logiNo }));

                                request.DeliveryMode = orderBillDeliveries.Count > 1
                                    ? (int)GlobalEnumVars.WeChatShippingDeliveryMode.SPLIT_DELIVERY
                                    : (int)GlobalEnumVars.WeChatShippingDeliveryMode.UNIFIED_DELIVERY;
                            }
                            else
                            {
                                //判断是否门店订单自动发货
                                var allConfigs = await _settingServices.GetConfigDictionaries();
                                var storeOrderAutomaticDelivery = CommonHelper.GetConfigDictionary(allConfigs, SystemSettingConstVars.StoreOrderAutomaticDelivery).ObjectToInt(1);
                                if (storeOrderAutomaticDelivery == 1 || order.receiptType == (int)GlobalEnumVars.OrderReceiptType.SelfDelivery)
                                {
                                    shippingList.Add(new WxaSecOrderUploadShippingInfoRequest.Types.Shipping() { ItemDescription = orderTitle, ExpressCompany = "", TrackingNumber = "" });
                                }
                                else
                                {
                                    NLogUtil.WriteAll(NLog.LogLevel.Error, LogType.RedisMessageQueue, "微信发货信息处理", msg + "：未获取到发货信息，自动发货停止操作");
                                    return;
                                }
                            }
                        }
                        else
                        {
                            //非商品模式，直接走虚拟发货。
                            request.LogisticsType = (int)GlobalEnumVars.WeChatShippingLogisticsType.虚拟商品;
                            request.DeliveryMode = (int)GlobalEnumVars.WeChatShippingDeliveryMode.UNIFIED_DELIVERY;
                            shippingList.Add(new WxaSecOrderUploadShippingInfoRequest.Types.Shipping() { ItemDescription = orderTitle, ExpressCompany = "", TrackingNumber = "" });
                        }

                        request.ShippingList = shippingList;

                        var response = await client.ExecuteWxaSecOrderUploadShippingInfoAsync(request);
                        if (response.IsSuccessful())
                        {
                            NLogUtil.WriteAll(NLog.LogLevel.Info, LogType.RedisMessageQueue, "微信发货信息处理", msg + ":发货提交成功");
                        }
                        else
                        {
                            NLogUtil.WriteAll(NLog.LogLevel.Error, LogType.RedisMessageQueue, "微信发货信息处理-推送接口", JsonConvert.SerializeObject(response));

                        }
                    }
                    else
                    {
                        NLogUtil.WriteAll(NLog.LogLevel.Error, LogType.RedisMessageQueue, "微信发货信息处理-获取是否需要推送", JsonConvert.SerializeObject(responseIsTradeManagedResponse));
                    }
                }
            }
            catch (Exception ex)
            {
                NLogUtil.WriteAll(NLog.LogLevel.Error, LogType.RedisMessageQueue, "微信发货信息处理", msg, ex);
                throw;
            }
            await Task.CompletedTask;
        }

    }
}