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;

namespace BBWY.Server.Business.Sync
{
    public class JDServiceOrderSyncBusiness : BaseSyncBusiness, IDenpendency
    {
        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)
        {
        }

        public void SyncAllShopServiceOrder()
        {
            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.SyncAfterOrderTaskScheduler);
            }
        }

        private void SyncServiceOrder(ShopResponse shop, JArray jArray)
        {

        }

        private void SyncServiceOrder(ShopResponse shop, string orderId, DateTime? startTime = null, DateTime? endTime = null, bool isAuto = false)
        {
            /*
            审核阶段:
            待审核: 10001
            待用户反馈: 10002
            用户已反馈: 10012
            【待收货: 10005】
            【取消: 10011】
            审核关闭: 10004
            待用户确认: 10009
            【完成: 10010】
            处理阶段:
            已收货，待处理 : 10007
            原返取消，待处理:7060
            换新取消，待处理:7023
            线下换新取消，待处理:7090
            商家催收: 13000
            */
            try
            {
                var shopId = long.Parse(shop.ShopId);
                var relayAPIHost = GetPlatformRelayAPIHost(shop.PlatformId);
                var serviceStatusList = new List<int>() { 10005, 10011, 10010 };
                #region
                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,
                    OrderId = orderId,
                    VenderId = shop.VenderId
                };

                List<JToken> jtokenList = new List<JToken>();
                foreach (var serviceStatus in serviceStatusList)
                {
                    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}");
                    jtokenList.AddRange(serviceOrderListResponse.Data);
                }
                #endregion

                var serviceIdList = jtokenList.Select(j => j.Value<string>("serviceId")).ToList();
                var dbServiceOrderList = fsql.Select<ServiceOrder>().Where(s => 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>().Where(osku => osku.ShopId == shopId && apiOrderIdList.Contains(osku.OrderId)).ToList();

                foreach (var serviceOrderJToken in jtokenList)
                {
                    var serviceId = serviceOrderJToken.Value<string>("serviceId");
                    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;
                        dbServiceOrder = new ServiceOrder()
                        {
                            Id = idGenerator.NewLong(),
                            ServiceId = serviceId,
                            OrderId = serviceOrderId,
                            ShopId = shop.ShopId,
                            ProductId = dbOsku.ProductId,
                            SkuItemCount = dbOsku.ItemTotal,
                            Status = serviceOrderJToken.Value<int>("sserviceOrderJToken"),
                            CreateTime = DateTime.Now,
                            SkuId = skuId,
                            StatusUpdateTime = serviceOrderJToken.Value<DateTime>("updateTime"),
                            IsSubscribeKuaiDi100 = false,
                            WaybillNo = string.Empty,
                            ExpressName = string.Empty,
                            ApplyTime = serviceOrderJToken.Value<DateTime>("applyTime")
                        };
                    }
                }

                //SyncServiceOrder(shop, serviceOrderListResponse.Data);
            }
            catch (Exception ex)
            {
                var shopData = JsonConvert.SerializeObject(shop);
                nLogManager.Default().Error(ex, $"SyncServiceOrder ShopData:{shopData}");
            }
        }
    }
}