bbwy/BBWY.Server.Business/Sync/JD/JDServiceOrderSyncBusiness.cs

using BBWY.Common.Http;
using BBWY.Common.Models;
using BBWY.Server.Model;
using BBWY.Server.Model.Dto;
using Microsoft.Extensions.Options;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System;
using System.Collections.Generic;
using System.Net.Http;
using System.Threading.Tasks;
using Yitter.IdGenerator;
using System.Linq;
using BBWY.Server.Model.Db;
using FreeSql;

namespace BBWY.Server.Business.Sync
{
    public class JDServiceOrderSyncBusiness : BaseSyncBusiness, IDenpendency
    {
        private IList<LogisticsCompanyRelationship> jd_kd100_logisticsCompanyDictionary;
        private IList<int> kuaiDi100PushStateList;

        public JDServiceOrderSyncBusiness(RestApiService restApiService, IOptions<GlobalConfig> options, NLogManager nLogManager, IFreeSql fsql, IIdGenerator idGenerator, TaskSchedulerManager taskSchedulerManager, VenderBusiness venderBusiness, YunDingBusiness yunDingBusiness) : base(restApiService, options, nLogManager, fsql, idGenerator, taskSchedulerManager, venderBusiness, yunDingBusiness)
        {
            /*
yuantong  圆通速递
yunda  韵达快递
zhongtong  中通快递
shentong  申通快递
jtexpress  极兔速递
youzhengguonei  邮政快递包裹
shunfeng  顺丰速运
ems  EMS
jd  京东物流
youzhengbk  邮政标准快递
fengwang  丰网速运
debangkuaidi  德邦快递
debangwuliu  德邦
zhongtongkuaiyun  中通快运
danniao  丹鸟
subida  速必达
lianhaowuliu  联昊通
yundakuaiyun  韵达快运
annengwuliu  安能快运
kuayue  跨越速运
jingdongkuaiyun  京东快运
huitongkuaidi  百世快递

             */
            kuaiDi100PushStateList = new List<int>()
            {
                0, //在途
                1, //揽收
                3, //签收
                5, //派件
            };

            jd_kd100_logisticsCompanyDictionary = new List<LogisticsCompanyRelationship>()
            {
                 new LogisticsCompanyRelationship(){ SourceName="圆通速递",TargetName="圆通速递",TargetCode="yuantong"},
                 new LogisticsCompanyRelationship(){ SourceName="圆通快递",TargetName="圆通速递",TargetCode="yuantong"},
                 new LogisticsCompanyRelationship(){ SourceName="韵达快递",TargetName="韵达快递",TargetCode="yunda"},
                 new LogisticsCompanyRelationship(){ SourceName="韵达快运",TargetName="韵达快运",TargetCode="yundakuaiyun"},
                 new LogisticsCompanyRelationship(){ SourceName="中通快递",TargetName="中通快递",TargetCode="zhongtong"},
                 new LogisticsCompanyRelationship(){ SourceName="中通速递",TargetName="中通快递",TargetCode="zhongtong"},
                 new LogisticsCompanyRelationship(){ SourceName="中通快运",TargetName="中通快运",TargetCode="zhongtongkuaiyun"},
                 new LogisticsCompanyRelationship(){ SourceName="极兔速递",TargetName="极兔速递",TargetCode="jtexpress"},
                 new LogisticsCompanyRelationship(){ SourceName="极兔快递",TargetName="极兔速递",TargetCode="jtexpress"},
                 new LogisticsCompanyRelationship(){ SourceName="邮政快递包裹",TargetName="邮政快递包裹",TargetCode="youzhengguonei"},
                 new LogisticsCompanyRelationship(){ SourceName="顺丰速运",TargetName="顺丰速运",TargetCode="shunfeng"},
                 new LogisticsCompanyRelationship(){ SourceName="顺丰快递",TargetName="顺丰速运",TargetCode="shunfeng"},
                 new LogisticsCompanyRelationship(){ SourceName="EMS",TargetName="EMS",TargetCode="ems"},
                 new LogisticsCompanyRelationship(){ SourceName="京东物流",TargetName="京东物流",TargetCode="jd"},
                 new LogisticsCompanyRelationship(){ SourceName="京东快递",TargetName="京东快运",TargetCode="jingdongkuaiyun"},
                 new LogisticsCompanyRelationship(){ SourceName="德邦快递",TargetName="德邦快递",TargetCode="debangkuaidi"},
                 new LogisticsCompanyRelationship(){ SourceName="德邦",TargetName="德邦",TargetCode="debangwuliu"},
                 new LogisticsCompanyRelationship(){ SourceName="丹鸟",TargetName="丹鸟",TargetCode="danniao"},
                 new LogisticsCompanyRelationship(){ SourceName="其他-丹鸟KD",TargetName="丹鸟",TargetCode="danniao"},
                 new LogisticsCompanyRelationship(){ SourceName="百世快递",TargetName="百世快递",TargetCode="huitongkuaidi"},
                 new LogisticsCompanyRelationship(){ SourceName="百世快运",TargetName="百世快递",TargetCode="huitongkuaidi"},
            };
        }

        public void SyncServiceOrder()
        {
            var shopList = venderBusiness.GetShopList(platform: Enums.Platform.京东);
            //SyncAfterOrder(shopList.FirstOrDefault(s => s.ShopName == "布莱特玩具专营店"), string.Empty, isAuto: true);
            foreach (var shop in shopList)
            {
                Task.Factory.StartNew(() => SyncServiceOrder(shop, string.Empty, isAuto: true),
                                            System.Threading.CancellationToken.None,
                                            TaskCreationOptions.LongRunning,
                                            taskSchedulerManager.SyncServiceOrderTaskScheduler);
            }
        }

        public void SyncServiceOrder(long shopId, string serviceId)
        {
            var shopList = venderBusiness.GetShopList(shopId);
            Task.Factory.StartNew(() => SyncServiceOrder(shopList[0], serviceId, isAuto: true),
                                           System.Threading.CancellationToken.None,
                                           TaskCreationOptions.LongRunning,
                                           taskSchedulerManager.SyncServiceOrderTaskScheduler);
        }

        private void SyncServiceOrder(ShopResponse shop, long shopId, IList<JToken> jtokenList, string relayAPIHost, string appKey, string appSecret, string token)
        {
            var serviceIdList = jtokenList.Select(j => j.Value<string>("serviceId")).ToList();
            var dbServiceOrderList = fsql.Select<ServiceOrder>().Where(s => s.ShopId == shop.ShopId && serviceIdList.Contains(s.ServiceId)).ToList();
            var dbServiceIdList = dbServiceOrderList.Select(s => s.ServiceId).ToList();
            var exceptServiceIdList = serviceIdList.Except(dbServiceIdList);

            var apiOrderIdList = jtokenList.Where(j => exceptServiceIdList.Contains(j.Value<string>("serviceId"))).Select(j => j.Value<string>("orderId")).ToList();
            var dbOrderSkuList = fsql.Select<OrderSku, Order>().InnerJoin((osku, o) => osku.OrderId == o.Id)
                                                               .Where((osku, o) => osku.ShopId == shopId && apiOrderIdList.Contains(osku.OrderId) && osku.Price != 0)
                                                               .ToList((osku, o) => new
                                                               {
                                                                   Id = osku.Id,
                                                                   ProductId = osku.ProductId,
                                                                   SkuId = osku.SkuId,
                                                                   OrderId = osku.OrderId,
                                                                   ItemTotal = osku.ItemTotal,
                                                                   StorageType = o.StorageType
                                                               });

            List<ServiceOrder> insertServiceOrderList = new List<ServiceOrder>();
            List<IUpdate<ServiceOrder>> updateServiceOrderList = new List<IUpdate<ServiceOrder>>();

            foreach (var serviceOrderJToken in jtokenList)
            {
                var serviceId = serviceOrderJToken.Value<string>("serviceId");
                var status = serviceOrderJToken.Value<int>("sserviceOrderJToken");
                var statusUpdateTime = serviceOrderJToken.Value<DateTime>("updateTime");
                var dbServiceOrder = dbServiceOrderList.FirstOrDefault(s => s.ServiceId == serviceId);
                if (dbServiceOrder == null)
                {
                    var serviceOrderId = serviceOrderJToken.Value<string>("orderId");
                    var skuId = serviceOrderJToken.Value<string>("skuId");
                    var dbOsku = dbOrderSkuList.FirstOrDefault(osku => osku.OrderId == serviceOrderId && osku.SkuId == skuId);
                    if (dbOsku == null)
                        continue;
                    var isNeedSubscribeKuaiDi100 = false;
                    var isTuiHuoCang = false;

                    #region 待收货服务单，检查是否需要订阅快递100
                    if (status == 10005)
                    {
                        if (dbOsku.StorageType == Enums.StorageType.代发)
                            isNeedSubscribeKuaiDi100 = true;
                        else
                        {
                            try
                            {
                                var serviceOrderDetailResult = restApiService.SendRequest(relayAPIHost, "api/PlatformSDK/GetServiceOrderDetail", new QueryServiceOrderDetailRequest()
                                {
                                    AppKey = appKey,
                                    AppSecret = appSecret,
                                    AppToken = token,
                                    OrderId = serviceOrderId,
                                    ServiceId = serviceId,
                                    Platform = Enums.Platform.京东,
                                    VenderId = shop.VenderId
                                }, GetYunDingRequestHeader(), HttpMethod.Post);

                                if (serviceOrderDetailResult.StatusCode != System.Net.HttpStatusCode.OK)
                                    throw new Exception($"获取服务单详情失败 {serviceOrderDetailResult.Content}");
                                var serviceOrderDetailResponse = JsonConvert.DeserializeObject<ApiResponse<JToken>>(serviceOrderDetailResult.Content);
                                if (!serviceOrderDetailResponse.Success)
                                    throw new Exception($"获取服务单详情失败 {serviceOrderDetailResponse.Msg}");

                                //检查退货城市是否为泉州
                                isNeedSubscribeKuaiDi100 = serviceOrderDetailResponse.Data["returnWareAddress"].Value<int>("cityCode") == 2812;
                                isTuiHuoCang = isNeedSubscribeKuaiDi100;
                            }
                            catch { }
                        }
                    }
                    #endregion

                    dbServiceOrder = new ServiceOrder()
                    {
                        Id = idGenerator.NewLong(),
                        ServiceId = serviceId,
                        OrderId = serviceOrderId,
                        ShopId = shop.ShopId,
                        ProductId = dbOsku.ProductId,
                        SkuItemCount = dbOsku.ItemTotal,
                        Status = status,
                        CreateTime = DateTime.Now,
                        SkuId = skuId,
                        StatusUpdateTime = statusUpdateTime,
                        IsSubscribeKuaiDi100 = false,
                        IsNeedSubscribeKuaiDi100 = isNeedSubscribeKuaiDi100,
                        ApplyTime = serviceOrderJToken.Value<DateTime>("applyTime"),
                    };
                    if (isTuiHuoCang)
                        dbServiceOrder.ReturnDirection = 0;
                    insertServiceOrderList.Add(dbServiceOrder);
                }
                else if (dbServiceOrder.Status != status)
                {
                    var update = fsql.Update<ServiceOrder>(dbServiceOrder.Id).Set(s => s.Status, status)
                                                                             .Set(s => s.StatusUpdateTime, statusUpdateTime);
                    updateServiceOrderList.Add(update);
                }
            }

            fsql.Transaction(() =>
            {
                if (insertServiceOrderList.Count() > 0)
                    fsql.Insert(insertServiceOrderList).ExecuteAffrows();
                if (updateServiceOrderList.Count() > 0)
                    foreach (var update in updateServiceOrderList)
                        update.ExecuteAffrows();
            });
        }

        private void SyncServiceOrder(ShopResponse shop, string serviceId, DateTime? startTime = null, DateTime? endTime = null, bool isAuto = false)
        {
            /*
            审核阶段:
            待审核: 10001
            待用户反馈: 10002
            用户已反馈: 10012
            【待收货: 10005】
            【取消: 10011】
            审核关闭: 10004
            待用户确认: 10009
            【完成: 10010】
            处理阶段:
            已收货，待处理 : 10007
            原返取消，待处理:7060
            换新取消，待处理:7023
            线下换新取消，待处理:7090
            商家催收: 13000
            */

            var loggerName = $"新服务单同步-{shop.ShopName}";
            try
            {
                var shopId = long.Parse(shop.ShopId);
                var relayAPIHost = GetPlatformRelayAPIHost(shop.PlatformId);
                var serviceStatusList = new List<int>() { 10005, 10011, 10010 };

                var request = new QueryServiceOrderRequest()
                {
                    UpdateTimeBegin = startTime ?? DateTime.Now.Date.AddHours(-1),
                    UpdateTimeEnd = endTime ?? DateTime.Now,
                    AppKey = shop.AppKey,
                    AppSecret = shop.AppSecret,
                    AppToken = shop.AppToken,
                    PageIndex = 1,
                    PageSize = 50,
                    Platform = shop.PlatformId,
                    SaveResponseLog = true,
                    ServiceId = serviceId,
                    VenderId = shop.VenderId
                };

                List<JToken> jtokenList = new List<JToken>();
                foreach (var serviceStatus in serviceStatusList)
                {
                    if (string.IsNullOrEmpty(serviceId))
                        request.ServiceStatus = serviceStatus;
                    var serviceOrderListApiResult = restApiService.SendRequest(relayAPIHost, "api/PlatformSDK/GetServiceOrderList", request, GetYunDingRequestHeader(), HttpMethod.Post);
                    if (serviceOrderListApiResult.StatusCode != System.Net.HttpStatusCode.OK)
                        throw new Exception($"获取服务单失败 {serviceOrderListApiResult.Content}");
                    var serviceOrderListResponse = JsonConvert.DeserializeObject<ApiResponse<JArray>>(serviceOrderListApiResult.Content);
                    if (!serviceOrderListResponse.Success)
                        throw new Exception($"获取服务单失败 {serviceOrderListResponse.Msg}");
                    if (serviceOrderListResponse.Data != null && serviceOrderListResponse.Data.Count() > 0)
                        jtokenList.AddRange(serviceOrderListResponse.Data);
                    if (!string.IsNullOrEmpty(serviceId))
                        break;
                }

                SyncServiceOrder(shop, shopId, jtokenList, relayAPIHost, request.AppKey, request.AppSecret, request.AppToken);
            }
            catch (Exception ex)
            {
                nLogManager.GetLogger(loggerName).Error(ex, $"SyncServiceOrder ShopName:{shop.ShopName} ShopId:{shop.ShopId}");
            }
        }

        public void SubscribeKuaiDi100()
        {
            var shopList = venderBusiness.GetShopList(platform: Enums.Platform.京东);
            foreach (var shop in shopList)
            {
                Task.Factory.StartNew(() => SubscribeKuaiDi100(shop),
                                            System.Threading.CancellationToken.None,
                                            TaskCreationOptions.LongRunning,
                                            taskSchedulerManager.SyncServiceOrderTaskScheduler);
            }
        }

        public void SubscribeKuaiDi100(long shopId)
        {
            var shop = venderBusiness.GetShopList(shopId).FirstOrDefault();
            Task.Factory.StartNew(() => SubscribeKuaiDi100(shop),
                                        System.Threading.CancellationToken.None,
                                        TaskCreationOptions.LongRunning,
                                        taskSchedulerManager.SyncServiceOrderTaskScheduler);

        }

        private void SubscribeKuaiDi100(ShopResponse shop)
        {
            var loggerName = $"订阅快递100-{shop.ShopName}";
            try
            {
                var relayAPIHost = GetPlatformRelayAPIHost(shop.PlatformId);
                var serviceOrderList = fsql.Select<ServiceOrder>().Where(s => s.ShopId == shop.Id &&
                                                                                                 s.IsNeedSubscribeKuaiDi100 == true &&
                                                                                                 s.IsSubscribeKuaiDi100 == false)
                                                                  .OrderByDescending(s => s.StatusUpdateTime)
                                                                  .Page(1, 50)
                                                                  .ToList();
                List<IUpdate<ServiceOrder>> updateSerivceOrderList = new List<IUpdate<ServiceOrder>>();
                List<ExpressOrder> insertExpressOrderList = new List<ExpressOrder>();

                foreach (var serviceOrder in serviceOrderList)
                {
                    bool isUpdateDelivery = false, isUpdateSubscribe = false;
                    if (string.IsNullOrEmpty(serviceOrder.WayBillNo) || string.IsNullOrEmpty(serviceOrder.ExpressName))
                    {

                        try
                        {
                            #region 查询服务单运单详情
                            var serviceOrderDeliveryResult = restApiService.SendRequest(relayAPIHost, "api/PlatformSDK/GetServiceOrderDeliveryDetail", new QueryServiceOrderDetailRequest()
                            {
                                AppKey = shop.AppKey,
                                AppSecret = shop.AppSecret,
                                AppToken = shop.AppToken,
                                OrderId = serviceOrder.OrderId,
                                ServiceId = serviceOrder.ServiceId,
                                Platform = Enums.Platform.京东,
                                VenderId = shop.VenderId
                            }, GetYunDingRequestHeader(), HttpMethod.Post);

                            if (serviceOrderDeliveryResult.StatusCode != System.Net.HttpStatusCode.OK)
                                throw new Exception($"获取服务单运单详情失败 {serviceOrderDeliveryResult.Content}");
                            var serviceOrderDeliveryResponse = JsonConvert.DeserializeObject<ApiResponse<JToken>>(serviceOrderDeliveryResult.Content);
                            if (!serviceOrderDeliveryResponse.Success)
                                throw new Exception($"获取服务单运单详情失败 {serviceOrderDeliveryResponse.Msg}");

                            if (serviceOrderDeliveryResponse.Data != null)
                            {
                                serviceOrder.WayBillNo = serviceOrderDeliveryResponse.Data.Value<string>("expressCode");
                                serviceOrder.ExpressName = serviceOrderDeliveryResponse.Data.Value<string>("expressCompany");

                                isUpdateDelivery = !string.IsNullOrEmpty(serviceOrder.WayBillNo) && !string.IsNullOrEmpty(serviceOrder.ExpressName);
                            }
                            #endregion
                        }
                        catch (Exception ex)
                        {
                            nLogManager.GetLogger(loggerName).Error(ex, $"SubscribeKuaiDi100 ShopName:{shop.ShopName} ShopId:{shop.ShopId} ServiceId:{serviceOrder.ServiceId}");
                        }
                    }

                    if (!string.IsNullOrEmpty(serviceOrder.WayBillNo) && !string.IsNullOrEmpty(serviceOrder.ExpressName))
                    {
                        #region 订阅快递100
                        try
                        {
                            var kuaidi100CompanyCode = ConvertToKuaiDi100CompanyCode(serviceOrder.ExpressName);
                            var paramStr = JsonConvert.SerializeObject(new
                            {
                                company = kuaidi100CompanyCode,
                                number = serviceOrder.WayBillNo,
                                key = "SdcRPzxo8802",
                                parameters = new
                                {
                                    callbackurl = "https://bbwy.qiyue666.com/api/ServiceOrderSync/ReceiveKuaiDi100Push",
                                    salt = Guid.NewGuid(),
                                    resultv2 = "4"
                                }
                            });
                            var subscribeResult = restApiService.SendRequest("https://poll.kuaidi100.com", "poll", $"schema=json&param={paramStr}", null, HttpMethod.Post, RestApiService.ContentType_Form);
                            if (subscribeResult.StatusCode != System.Net.HttpStatusCode.OK)
                                throw new Exception($"订阅快递100失败 {subscribeResult.Content}");
                            var subscribeResponse = JsonConvert.DeserializeObject<KuaiDi100Response>(subscribeResult.Content);
                            if (!subscribeResponse.result)
                                throw new Exception($"订阅快递100失败 {subscribeResponse.message}");

                            isUpdateSubscribe = true;
                        }
                        catch (Exception ex)
                        {
                            nLogManager.GetLogger(loggerName).Error(ex, $"SubscribeKuaiDi100 ShopName:{shop.ShopName} ShopId:{shop.ShopId} ServiceId:{serviceOrder.ServiceId}");
                        }
                        #endregion
                    }

                    if (isUpdateSubscribe || isUpdateDelivery)
                    {
                        var update = fsql.Update<ServiceOrder>(serviceOrder.Id)
                                         .SetIf(isUpdateDelivery, e => e.WayBillNo, serviceOrder.WayBillNo)
                                         .SetIf(isUpdateDelivery, e => e.ExpressName, serviceOrder.ExpressName)
                                         .SetIf(isUpdateSubscribe, s => s.IsSubscribeKuaiDi100, true);
                        updateSerivceOrderList.Add(update);

                        if (isUpdateDelivery)
                        {
                            insertExpressOrderList.Add(new ExpressOrder()
                            {
                                Id = idGenerator.NewLong(),
                                CreateTime = DateTime.Now,
                                ExpressName = serviceOrder.ExpressName,
                                WayBillNo = serviceOrder.WayBillNo,
                                OrderId = serviceOrder.OrderId,
                                PackageType = 1,
                                UpdateTime = DateTime.Now
                            });
                        }
                    }
                }


                fsql.Transaction(() =>
                {
                    if (insertExpressOrderList.Count() > 0)
                        fsql.Insert(insertExpressOrderList).ExecuteAffrows();
                    if (updateSerivceOrderList.Count() > 0)
                        foreach (var update in updateSerivceOrderList)
                            update.ExecuteAffrows();
                });
            }
            catch (Exception ex)
            {
                nLogManager.GetLogger(loggerName).Error(ex, $"SubscribeKuaiDi100 ShopName:{shop.ShopName} ShopId:{shop.ShopId}");
            }
        }

        private string ConvertToKuaiDi100CompanyCode(string sourceExpressName)
        {
            var result = jd_kd100_logisticsCompanyDictionary.FirstOrDefault(l => l.SourceName == sourceExpressName);
            if (result == null)
                throw new Exception($"匹配快递100公司失败,原快递名称 {sourceExpressName}");
            return result.TargetCode;
        }



        public void ReceiveKuaiDi100Push(string param)
        {
            JObject jobject = JObject.Parse(param);
            var waybillNo = jobject["lastResult"].Value<string>("nu");
            var state = jobject["lastResult"].Value<int>("state");
            if (!kuaiDi100PushStateList.Contains(state))
                return;

            var serviceOrderList = fsql.Select<ServiceOrder>().Where(s => s.WayBillNo == waybillNo).ToList();
            if (serviceOrderList.Count() == 0)
                throw new Exception($"快递单号{waybillNo} 未找到对应的服务单");

            var expressOrder = fsql.Select<ExpressOrder>().Where(e => e.WayBillNo == waybillNo).ToOne();
            if (expressOrder == null)
                throw new Exception($"快递单号{waybillNo} 未找到对应的快递单");

            if (expressOrder.TransportStatus == 1)  //已入库
                return;

            IUpdate<ExpressOrder> updateExpressOrder = null;
            List<IUpdate<ServiceOrder>> updateServiceOrderList = new List<IUpdate<ServiceOrder>>();

            /*
               0, //在途
               1, //揽收
               3, //签收
               5, //派件
            */

            var isUpdate = false;
            var newStatus = 0;
            DateTime? signTime = null;

            if (state == 0 || state == 1)
            {
                //在途 //揽收
                if (expressOrder.TransportStatus != 3)
                {
                    isUpdate = true;
                    newStatus = 3;
                }
            }
            else if (state == 3)
            {
                if (expressOrder.TransportStatus != 0)
                {
                    isUpdate = true;
                    newStatus = 0;

                    var data = jobject["lastResult"]["data"].Children().FirstOrDefault(d => d.Value<int>("statusCode") == 3);
                    if (data != null)
                        signTime = DateTime.Parse(data.Value<string>("ftime"));
                }
            }
            else if (state == 5)
            {
                if (expressOrder.TransportStatus != 2)
                {
                    isUpdate = true;
                    newStatus = 2;
                }
            }

            if (isUpdate)
            {
                fsql.Transaction(() =>
                {
                    fsql.Update<ExpressOrder>(expressOrder.Id).Set(e => e.TransportStatus, newStatus)
                                                              .SetIf(state == 3, e => e.SignTime, signTime)
                                                              .ExecuteAffrows();   //签收

                    foreach (var serviceOrder in serviceOrderList)
                    {
                        if (serviceOrder.TransportDetails == 1)
                            continue;
                        fsql.Update<ServiceOrder>(serviceOrder.Id).Set(s => s.TransportDetails, newStatus)
                                                                  .ExecuteAffrows();
                    }
                });
            }
        }
    }
}