bbwy/BBWY.Server.Business/PurchaseOrder/PurchaseOrderBusiness.cs

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

namespace BBWY.Server.Business
{
    public class PurchaseOrderBusiness : BaseBusiness, IDenpendency
    {
        private IEnumerable<PlatformSDKBusiness> platformSDKBusinessList;
        private TaskSchedulerManager taskSchedulerManager;
        private OrderBusiness orderBusiness;
        private MDSBusiness mdsBusiness;
        private VenderBusiness venderBusiness;

        private IDictionary<Enums.Platform, string> deliverySelfDic;

        public PurchaseOrderBusiness(IFreeSql fsql,
                                     NLog.ILogger logger,
                                     IIdGenerator idGenerator,
                                     IEnumerable<PlatformSDKBusiness> platformSDKBusinessList,
                                     TaskSchedulerManager taskSchedulerManager,
                                     OrderBusiness orderBusiness,
                                     MDSBusiness mdsBusiness,
                                     VenderBusiness venderBusiness) : base(fsql, logger, idGenerator)
        {
            this.platformSDKBusinessList = platformSDKBusinessList;
            this.taskSchedulerManager = taskSchedulerManager;
            this.orderBusiness = orderBusiness;
            this.mdsBusiness = mdsBusiness;
            this.venderBusiness = venderBusiness;

            deliverySelfDic = new Dictionary<Enums.Platform, string>()
            {
                {Enums.Platform.京东 , "1274"} //厂家自送
            };
        }

        public void AddPurchaseOrder(AddPurchaseOrderRequest addPurchaseOrderRequest)
        {
            if (string.IsNullOrEmpty(addPurchaseOrderRequest.PurchaseOrderId) ||
                string.IsNullOrEmpty(addPurchaseOrderRequest.SkuId) ||
               string.IsNullOrEmpty(addPurchaseOrderRequest.ProductId))
                throw new BusinessException("缺少采购单必要信息");

            if (fsql.Select<PurchaseOrder>().Where(po => po.SkuId == addPurchaseOrderRequest.SkuId &&
                                                         po.PurchaseOrderId == addPurchaseOrderRequest.PurchaseOrderId &&
                                                         po.StorageType == addPurchaseOrderRequest.StorageType).Any())
                throw new BusinessException("同一个SkuId和同一种仓储类型中不能存在重复的采购单号");

            var purchaseOrder = addPurchaseOrderRequest.Map<PurchaseOrder>();
            purchaseOrder.Id = idGenerator.NewLong();
            purchaseOrder.CreateTime = DateTime.Now;
            fsql.Insert(purchaseOrder).ExecuteAffrows();
        }

        public void EditPurchaseOrder(EditPurchaseOrderRequest editPurchaseOrderRequest)
        {
            fsql.Update<PurchaseOrder>(editPurchaseOrderRequest.Id).Set(po => po.PurchaseQuantity, editPurchaseOrderRequest.PurchaseQuantity)
                                                                   .Set(po => po.RemainingQuantity, editPurchaseOrderRequest.RemainingQuantity)
                                                                   .Set(po => po.SingleSkuAmount, editPurchaseOrderRequest.SingleSkuAmount)
                                                                   .Set(po => po.SingleFreight, editPurchaseOrderRequest.SingleFreight)
                                                                   .Set(po => po.SingleFirstFreight, editPurchaseOrderRequest.SingleFirstFreight)
                                                                   .Set(po => po.SingleOperationAmount, editPurchaseOrderRequest.SingleOperationAmount)
                                                                   .Set(po => po.SingleConsumableAmount, editPurchaseOrderRequest.SingleConsumableAmount)
                                                                   .Set(po => po.SingleStorageAmount, editPurchaseOrderRequest.SingleStorageAmount)
                                                                   .Set(po => po.SingleDeliveryFreight, editPurchaseOrderRequest.SingleDeliveryFreight)
                                                                   .ExecuteAffrows();
        }

        public IList<PurchaseOrderResponse> GetList(QueryPurchaseOrderRequest queryPurchaseOrderRequest)
        {
            return fsql.Select<PurchaseOrder>().Where(po => po.ShopId == queryPurchaseOrderRequest.ShopId &&
                                                            queryPurchaseOrderRequest.SkuIdList.Contains(po.SkuId) &&
                                                            po.StorageType == queryPurchaseOrderRequest.StorageType)
                                               .ToList()
                                               .Map<IList<PurchaseOrderResponse>>();
        }

        public void DeletePurchaseOrder(long id)
        {
            fsql.Delete<PurchaseOrder>(id).ExecuteAffrows();
        }

        public PreviewOrderResponse PreviewPurchaseOrder(PreviewOrderReuqest previewOrderReuqest)
        {
            if (previewOrderReuqest.Platform != Model.Enums.Platform.阿里巴巴)
                throw new NotImplementedException();
            return platformSDKBusinessList.FirstOrDefault(p => p.Platform == previewOrderReuqest.Platform).PreviewOrder(previewOrderReuqest);
        }

        public void FastCreateOrder(CreateOnlinePurchaseOrderRequest createOnlinePurchaseOrderRequest)
        {
            if (createOnlinePurchaseOrderRequest.Platform != Enums.Platform.阿里巴巴)
                throw new NotImplementedException();
            var dbOrder = fsql.Select<Order>(createOnlinePurchaseOrderRequest.OrderId).ToOne();
            if (dbOrder == null)
                throw new BusinessException("订单不存在");
            //if (dbOrder.OrderState != Model.Enums.OrderState.等待采购)
            //    throw new BusinessException("只能为等待采购的订单进行采购");
            var orderSku = fsql.Select<OrderSku>().Where(osku => osku.OrderId == createOnlinePurchaseOrderRequest.OrderId).ToOne();
            if (orderSku == null)
                throw new BusinessException("订单Sku不存在");

            var createOrderResponse = platformSDKBusinessList.FirstOrDefault(p => p.Platform == createOnlinePurchaseOrderRequest.Platform)
                                                             .FastCreateOrder(createOnlinePurchaseOrderRequest);

            IInsert<PurchaseOrder> insertPurchaseOrder = null;
            IInsert<OrderCostDetail> insertOrderCostDetail = null;
            IInsert<OrderCost> insertOrderCost = null;
            IInsert<OrderDropShipping> insertOrderDropShipping = null;

            #region 采购单
            var purchaseOrder = new PurchaseOrder()
            {
                Id = idGenerator.NewLong(),
                CreateTime = DateTime.Now,
                ProductId = orderSku.ProductId,
                SkuId = orderSku.SkuId,
                PurchaseMethod = Enums.PurchaseMethod.线上采购,
                PurchaseOrderId = createOrderResponse.PurchaseOrderId,
                PurchasePlatform = createOnlinePurchaseOrderRequest.Platform,
                PurchaseQuantity = orderSku.ItemTotal.Value,
                RemainingQuantity = 0,
                ShopId = createOnlinePurchaseOrderRequest.ShopId,
                SingleConsumableAmount = 0,
                SingleDeliveryFreight = 0,
                SingleFirstFreight = 0,
                SingleStorageAmount = 0,
                SingleOperationAmount = 0,
                SingleSkuAmount = createOrderResponse.ProductAmount / orderSku.ItemTotal.Value,
                SingleFreight = createOrderResponse.FreightAmount / orderSku.ItemTotal.Value,
                StorageType = Enums.StorageType.代发
            };
            insertPurchaseOrder = fsql.Insert(purchaseOrder);
            #endregion

            #region 成本明细
            var orderCostDetail = new OrderCostDetail()
            {
                Id = idGenerator.NewLong(),
                ConsumableAmount = 0,
                CreateTime = DateTime.Now,
                DeductionQuantity = orderSku.ItemTotal.Value,
                DeliveryExpressFreight = 0,
                FirstFreight = 0,
                OperationAmount = 0,
                OrderId = createOnlinePurchaseOrderRequest.OrderId,
                ProductId = orderSku.ProductId,
                PurchaseFreight = createOrderResponse.FreightAmount,
                PurchaseOrderPKId = purchaseOrder.Id,
                SkuAmount = createOrderResponse.ProductAmount,
                SkuId = orderSku.SkuId,
                StorageAmount = 0,
                UnitCost = purchaseOrder.UnitCost,
                TotalCost = createOrderResponse.TotalAmount //purchaseOrder.UnitCost * orderSku.ItemTotal.Value
            };
            insertOrderCostDetail = fsql.Insert(orderCostDetail);
            #endregion

            #region 订单成本
            var orderCost = new OrderCost()
            {
                OrderId = orderSku.OrderId,
                CreateTime = DateTime.Now,
                DeliveryExpressFreight = 0,
                IsManualEdited = false,
                PlatformCommissionRatio = 0.05M,
                PreferentialAmount = dbOrder.PreferentialAmount,
                SDCommissionAmount = 0,
                PurchaseAmount = createOrderResponse.TotalAmount
            };
            orderCost.PlatformCommissionAmount = dbOrder.OrderSellerPrice * orderCost.PlatformCommissionRatio;
            orderCost.Profit = dbOrder.OrderSellerPrice +
                               dbOrder.FreightPrice -
                               orderCost.PurchaseAmount -
                               orderCost.DeliveryExpressFreight -
                               orderCost.PlatformCommissionAmount;
            insertOrderCost = fsql.Insert(orderCost);
            #endregion

            #region 采购信息
            var orderDropShipping = new OrderDropShipping()
            {
                OrderId = createOnlinePurchaseOrderRequest.OrderId,
                PurchaseAccountId = createOnlinePurchaseOrderRequest.PurchaseAccountId,
                BuyerAccount = createOnlinePurchaseOrderRequest.BuyerAccount,
                SellerAccount = createOnlinePurchaseOrderRequest.SellerAccount,
                CreateTime = DateTime.Now,
                DeliveryFreight = 0,
                PurchaseAmount = createOrderResponse.TotalAmount,
                PurchaseOrderId = createOrderResponse.PurchaseOrderId,
                PurchasePlatform = createOnlinePurchaseOrderRequest.Platform
            };
            insertOrderDropShipping = fsql.Insert(orderDropShipping);
            #endregion

            fsql.Transaction(() =>
            {
                insertPurchaseOrder.ExecuteAffrows();
                insertOrderCostDetail.ExecuteAffrows();
                insertOrderCost.ExecuteAffrows();
                insertOrderDropShipping.ExecuteAffrows();
                fsql.Update<Order>(createOnlinePurchaseOrderRequest.OrderId).SetIf(dbOrder.OrderState == Enums.OrderState.等待采购, o => o.OrderState, Model.Enums.OrderState.待出库)
                                                                            .Set(o => o.StorageType, Model.Enums.StorageType.代发)
                                                                            .ExecuteAffrows();
            });
        }

        public void NewFastCreateOrder(CreateOnlinePurchaseOrderRequest createOnlinePurchaseOrderRequest)
        {
            if (createOnlinePurchaseOrderRequest.Platform != Enums.Platform.阿里巴巴)
                throw new NotImplementedException();
            var dbOrder = fsql.Select<Order>(createOnlinePurchaseOrderRequest.OrderId).ToOne();
            if (dbOrder == null)
                throw new BusinessException("订单不存在");
            if (dbOrder.OrderState != Model.Enums.OrderState.等待采购)
                throw new BusinessException("只能为等待采购的订单进行采购");

            var orderSkus = fsql.Select<OrderSku>().Where(osku => osku.OrderId == createOnlinePurchaseOrderRequest.OrderId).ToList();

            var createOrderResponse = platformSDKBusinessList.FirstOrDefault(p => p.Platform == createOnlinePurchaseOrderRequest.Platform)
                                                             .FastCreateOrder(createOnlinePurchaseOrderRequest);


            var purchaseOrderSimpleInfo = platformSDKBusinessList.FirstOrDefault(p => p.Platform == createOnlinePurchaseOrderRequest.Platform).GetOrderSimpleInfo(new GetOrderInfoRequest()
            {
                AppKey = createOnlinePurchaseOrderRequest.AppKey,
                AppSecret = createOnlinePurchaseOrderRequest.AppSecret,
                AppToken = createOnlinePurchaseOrderRequest.AppToken,
                OrderId = createOrderResponse.PurchaseOrderId,
                Platform = createOnlinePurchaseOrderRequest.Platform
            });

            List<PurchaseOrder> insertPurchaseOrders = new List<PurchaseOrder>();
            List<OrderCostDetail> insertOrderCostDetails = new List<OrderCostDetail>();
            List<PurchaseOrderDetail> insertPurchaseOrderDetails = new List<PurchaseOrderDetail>();

            IInsert<OrderCost> insertOrderCost = null;
            IInsert<OrderDropShipping> insertOrderDropShipping = null;
            foreach (var orderSku in orderSkus)
            {
                #region 计算当前sku的采购成本和采购运费
                var currentOrderSkuProductAmount = 0M; //采购成本
                var currentOrderSkuCargoParamList = createOnlinePurchaseOrderRequest.CargoParamList.Where(p => p.BelongSkuId == orderSku.SkuId); //找当前skuId的采购skuId
                currentOrderSkuProductAmount = purchaseOrderSimpleInfo.ItemList.Where(p => currentOrderSkuCargoParamList.Any(p1 => p1.SkuId == p.SkuId))
                                                                               ?.Sum(p => p.ProductAmount) ?? 0M;

                var currentOrderSkuFreightAmount = purchaseOrderSimpleInfo.FreightAmount / orderSkus.Count(); //采购运费(按sku数均分)
                #endregion

                #region 采购单
                var purchaseOrder = new PurchaseOrder()
                {
                    Id = idGenerator.NewLong(),
                    CreateTime = DateTime.Now,
                    ProductId = orderSku.ProductId,
                    SkuId = orderSku.SkuId,
                    PurchaseMethod = Enums.PurchaseMethod.线上采购,
                    PurchaseOrderId = createOrderResponse.PurchaseOrderId,
                    PurchasePlatform = createOnlinePurchaseOrderRequest.Platform,
                    PurchaseQuantity = orderSku.ItemTotal.Value,
                    RemainingQuantity = 0,
                    ShopId = createOnlinePurchaseOrderRequest.ShopId,
                    SingleConsumableAmount = 0,
                    SingleDeliveryFreight = 0,
                    SingleFirstFreight = 0,
                    SingleStorageAmount = 0,
                    SingleOperationAmount = 0,
                    SingleSkuAmount = currentOrderSkuProductAmount / orderSku.ItemTotal.Value,
                    SingleFreight = currentOrderSkuFreightAmount / orderSku.ItemTotal.Value,
                    StorageType = Enums.StorageType.代发
                };
                insertPurchaseOrders.Add(purchaseOrder);
                #endregion

                #region 成本明细
                var orderCostDetail = new OrderCostDetail()
                {
                    Id = idGenerator.NewLong(),
                    ConsumableAmount = 0,
                    CreateTime = DateTime.Now,
                    DeductionQuantity = orderSku.ItemTotal.Value,
                    DeliveryExpressFreight = 0,
                    FirstFreight = 0,
                    OperationAmount = 0,
                    OrderId = createOnlinePurchaseOrderRequest.OrderId,
                    ProductId = orderSku.ProductId,
                    PurchaseFreight = currentOrderSkuFreightAmount,
                    PurchaseOrderPKId = purchaseOrder.Id,
                    SkuAmount = currentOrderSkuProductAmount,
                    SkuId = orderSku.SkuId,
                    StorageAmount = 0,
                    UnitCost = purchaseOrder.UnitCost,
                    TotalCost = currentOrderSkuProductAmount + currentOrderSkuFreightAmount//purchaseOrder.UnitCost * orderSku.ItemTotal.Value
                };
                insertOrderCostDetail = fsql.Insert(orderCostDetail);
                #endregion
            }

            #region 订单成本
            var orderCost = new OrderCost()
            {
                OrderId = createOnlinePurchaseOrderRequest.OrderId,
                CreateTime = DateTime.Now,
                DeliveryExpressFreight = 0,
                IsManualEdited = false,
                PlatformCommissionRatio = 0.05M,
                PreferentialAmount = dbOrder.PreferentialAmount,
                SDCommissionAmount = 0,
                PurchaseAmount = createOrderResponse.TotalAmount
            };
            orderCost.PlatformCommissionAmount = dbOrder.OrderSellerPrice * orderCost.PlatformCommissionRatio;
            orderCost.Profit = dbOrder.OrderSellerPrice +
                               dbOrder.FreightPrice -
                               orderCost.PurchaseAmount -
                               orderCost.DeliveryExpressFreight -
                               orderCost.PlatformCommissionAmount;
            insertOrderCost = fsql.Insert(orderCost);
            #endregion

            #region 采购信息
            var orderDropShipping = new OrderDropShipping()
            {
                OrderId = createOnlinePurchaseOrderRequest.OrderId,
                PurchaseAccountId = createOnlinePurchaseOrderRequest.PurchaseAccountId,
                BuyerAccount = createOnlinePurchaseOrderRequest.BuyerAccount,
                SellerAccount = createOnlinePurchaseOrderRequest.SellerAccount,
                CreateTime = DateTime.Now,
                DeliveryFreight = 0,
                PurchaseAmount = createOrderResponse.TotalAmount,
                PurchaseOrderId = createOrderResponse.PurchaseOrderId,
                PurchasePlatform = createOnlinePurchaseOrderRequest.Platform
            };
            insertOrderDropShipping = fsql.Insert(orderDropShipping);
            #endregion

            fsql.Transaction(() =>
            {
                insertPurchaseOrder.ExecuteAffrows();
                insertOrderCostDetail.ExecuteAffrows();
                insertOrderCost.ExecuteAffrows();
                insertOrderDropShipping.ExecuteAffrows();
                fsql.Update<Order>(createOnlinePurchaseOrderRequest.OrderId).SetIf(dbOrder.OrderState == Enums.OrderState.等待采购, o => o.OrderState, Model.Enums.OrderState.待出库)
                                                                            .Set(o => o.StorageType, Model.Enums.StorageType.代发)
                                                                            .ExecuteAffrows();
            });
        }

        #region CallBack

        #region 1688CallBack
        public void CallbackFrom1688(string jsonStr)
        {
            logger.Info(jsonStr);
            var jObject = JObject.Parse(jsonStr);
            var type = jObject.Value<string>("type").ToUpper();
            switch (type)
            {
                case "ORDER_BUYER_VIEW_PART_PART_SENDGOODS":  //部分发货
                case "ORDER_BUYER_VIEW_ANNOUNCE_SENDGOODS":   //发货
                    DeliveryCallbackFrom1688(jObject);
                    break;
                case "ORDER_BUYER_VIEW_ORDER_PRICE_MODIFY":
                    OrderPriceModificationCallbackFrom1688(jObject); //订单改价
                    break;
                default:
                    break;
            }
        }

        /// <summary>
        /// 1688发货回调
        /// </summary>
        /// <param name="jObject"></param>
        private void DeliveryCallbackFrom1688(JObject jObject)
        {
            var purchaseOrderId = jObject["data"].Value<string>("orderId");
            Task.Factory.StartNew(() => DeliveryCallback(purchaseOrderId, Enums.Platform.阿里巴巴), CancellationToken.None, TaskCreationOptions.LongRunning, taskSchedulerManager.PurchaseOrderCallbackTaskScheduler);
        }

        /// <summary>
        /// 1688订单改价回调
        /// </summary>
        /// <param name="jObject"></param>
        private void OrderPriceModificationCallbackFrom1688(JObject jObject)
        {
            //var purchaseOrderId = jObject["data"].Value<string>("orderId");
            //Task.Factory.StartNew(() => OrderPriceModificationCallback(purchaseOrderId, Enums.Platform.阿里巴巴), CancellationToken.None, TaskCreationOptions.LongRunning, taskSchedulerManager.PurchaseOrderCallbackTaskScheduler);
        }
        #endregion

        /// <summary>
        /// 采购平台发货回调
        /// </summary>
        /// <param name="purchaseOrderId"></param>
        /// <param name="callbackPlatform"></param>
        private void DeliveryCallback(string purchaseOrderId, Enums.Platform callbackPlatform)
        {
            string currentProgress = string.Empty;
            try
            {
                #region 查询代发信息
                currentProgress = "查询代发信息";
                var orderDropshipping = fsql.Select<OrderDropShipping>().Where(o => o.PurchaseOrderId == purchaseOrderId).ToOne();
                if (orderDropshipping == null)
                    throw new Exception("未查询到代发信息");
                #endregion

                #region 查询采购账号
                currentProgress = "查询采购账号";
                var purchaseAccount = fsql.Select<PurchaseAccount>().WhereIf(orderDropshipping.PurchaseAccountId != 0, pa => pa.Id == orderDropshipping.PurchaseAccountId)
                                                                    .WhereIf(orderDropshipping.PurchaseAccountId == 0, pa => pa.AccountName == orderDropshipping.BuyerAccount)
                                                                    .Where(pa => pa.PurchasePlatformId == callbackPlatform).ToOne();
                if (purchaseAccount == null)
                    throw new Exception($"未查询到采购账号{orderDropshipping.BuyerAccount}");
                #endregion

                #region 获取采购单的物流信息
                currentProgress = "获取采购单的物流信息";
                var wayBillNoResponse = platformSDKBusinessList.FirstOrDefault(p => p.Platform == callbackPlatform).GetWayBillNoByOrderId(new QueryOrderWayBillNoRequest()
                {
                    AppKey = purchaseAccount.AppKey,
                    AppSecret = purchaseAccount.AppSecret,
                    AppToken = purchaseAccount.AppToken,
                    OrderId = purchaseOrderId,
                    Platform = callbackPlatform
                });
                #endregion

                #region 查询采购账号的归属店铺
                currentProgress = "查询采购账号归属店铺";
                var shop = mdsBusiness.GetShopInfoByShopId(purchaseAccount.ShopId.Value);
                #endregion

                #region 获取目标平台的物流公司列表
                currentProgress = "获取店铺平台物流公司列表";
                var logisticsCompanyList = venderBusiness.GetLogisticsList(new PlatformRequest()
                {
                    AppKey = shop.AppKey,
                    AppSecret = shop.AppSecret,
                    AppToken = shop.AppToken,
                    Platform = shop.Platform
                });
                #endregion

                #region 物流公司翻译
                currentProgress = "将采购单的物流公司翻译为店铺平台的物流公司";
                var logisticsCompanyId = ConvertLogisticsCompanyId(wayBillNoResponse.LogisticsCompanyName, logisticsCompanyList, shop.Platform);
                #endregion

                #region 店铺平台订单出库
                currentProgress = "店铺平台订单出库";
                orderBusiness.OutStock(new OutStockRequest()
                {
                    AppKey = shop.AppKey,
                    AppSecret = shop.AppSecret,
                    AppToken = shop.AppToken,
                    OrderId = orderDropshipping.OrderId,
                    Platform = shop.Platform,
                    WayBillNo = wayBillNoResponse.WayBillNo,
                    LogisticsId = logisticsCompanyId   //物流公司Id
                });
                #endregion
            }
            catch (Exception ex)
            {
                logger.Error(ex, $"DeliveryCallback 回调平台{callbackPlatform},采购单号{purchaseOrderId},执行进度[{currentProgress}]");
            }
        }

        /// <summary>
        /// 物流公司翻译, 将发货平台的物流公司翻译为店铺平台的物流公司
        /// </summary>
        /// <param name="sourceLogisticsCompanyName"></param>
        /// <param name="targetLogisticsList"></param>
        /// <param name="tagetLogisticsPlatform"></param>
        /// <returns></returns>
        private string ConvertLogisticsCompanyId(string sourceLogisticsCompanyName, IList<LogisticsResponse> targetLogisticsList, Enums.Platform tagetLogisticsPlatform)
        {
            var match = Regex.Match(sourceLogisticsCompanyName, "(中通|圆通|申通|顺丰|韵达|邮政快递包裹|平邮|EMS|德邦|百世|天天|优速)");
            if (match.Success)
            {
                var sname = match.Groups[1].Value;
                var targetLogistics = targetLogisticsList.FirstOrDefault(t => t.Name.Contains(sname));
                if (targetLogistics != null)
                    return targetLogistics.Id;
            }
            return deliverySelfDic[tagetLogisticsPlatform];
        }

        /// <summary>
        /// 采购平台改价回调
        /// </summary>
        /// <param name="purchaseOrderId"></param>
        /// <param name="callbackPlatform"></param>
        private void OrderPriceModificationCallback(string purchaseOrderId, Enums.Platform callbackPlatform)
        {
            string currentProgress = string.Empty;

            try
            {
                #region 查询代发信息
                currentProgress = "查询代发信息";
                var orderDropshipping = fsql.Select<OrderDropShipping>().Where(o => o.PurchaseOrderId == purchaseOrderId).ToOne();
                if (orderDropshipping == null)
                    throw new Exception("未查询到代发信息");
                #endregion

                #region 查询采购账号
                currentProgress = "查询采购账号";
                var purchaseAccount = fsql.Select<PurchaseAccount>().WhereIf(orderDropshipping.PurchaseAccountId != 0, pa => pa.Id == orderDropshipping.PurchaseAccountId)
                                                                    .WhereIf(orderDropshipping.PurchaseAccountId == 0, pa => pa.AccountName == orderDropshipping.BuyerAccount)
                                                                    .Where(pa => pa.PurchasePlatformId == callbackPlatform).ToOne();
                if (purchaseAccount == null)
                    throw new Exception($"未查询到采购账号{orderDropshipping.BuyerAccount}");
                #endregion

                #region 查询订单Sku
                currentProgress = "查询订单Sku";
                var orderSkuList = fsql.Select<OrderSku>().Where(osku => osku.OrderId == orderDropshipping.OrderId).ToList();
                if (orderSkuList == null || orderSkuList.Count() == 0)
                    throw new BusinessException("订单Sku不存在");
                #endregion

                #region 查询订单
                currentProgress = "查询订单";
                var dbOrder = fsql.Select<Order>(orderDropshipping.OrderId).ToOne();
                if (dbOrder == null)
                    throw new BusinessException("订单不存在");
                #endregion

                #region 查询采购单
                currentProgress = "查询采购单";
                var purchaseOrderList = fsql.Select<PurchaseOrder>().Where(po => po.PurchaseOrderId == purchaseOrderId &&
                                                                                 po.PurchaseMethod == Enums.PurchaseMethod.线上采购).ToList();
                if (purchaseOrderList == null || purchaseOrderList.Count() == 0)
                    throw new BusinessException("采购单不存在");
                #endregion

                #region 查询成本明细
                currentProgress = "查询成本明细";
                var orderCostDetailList = fsql.Select<OrderCostDetail>().Where(ocd => ocd.OrderId == orderDropshipping.OrderId).ToList();
                if (orderCostDetailList == null || orderCostDetailList.Count() == 0)
                    throw new BusinessException("订单成本明细不存在");
                #endregion

                #region 查询订单成本
                currentProgress = "查询订单成本";
                var orderCost = fsql.Select<OrderCost>(orderDropshipping.OrderId).ToOne();
                if (orderCost == null)
                    throw new BusinessException("订单成本不存在");
                #endregion

                #region 查询改价后的订单金额
                currentProgress = "查询改价后的订单金额";
                var purchaseOrderSimpleInfo = platformSDKBusinessList.FirstOrDefault(p => p.Platform == callbackPlatform).GetOrderSimpleInfo(new GetOrderInfoRequest()
                {
                    AppKey = purchaseAccount.AppKey,
                    AppSecret = purchaseAccount.AppSecret,
                    AppToken = purchaseAccount.AppToken,
                    OrderId = purchaseOrderId,
                    Platform = callbackPlatform
                });
                #endregion

                foreach (var orderSku in orderSkuList)
                {
                    var purchaseOrder = purchaseOrderList.FirstOrDefault(po => po.SkuId == orderSku.SkuId);

                }

                fsql.Transaction(() =>
                {
                    //fsql.Update<PurchaseOrder>(purchaseOrderId).Set(po => po.SingleSkuAmount, orderAmountResponse.ProductAmount / orderSku.ItemTotal.Value)
                    //                                           .Set(po => po.SingleFreight, orderAmountResponse.FreightAmount / orderSku.ItemTotal.Value)
                    //                                           .ExecuteAffrows();
                    //fsql.Update<OrderCostDetail>().Where(ocd=>)

                });
            }
            catch (Exception ex)
            {
                logger.Error(ex, $"OrderPriceModificationCallback 回调平台{callbackPlatform},采购单号{purchaseOrderId},执行进度[{currentProgress}]");
            }
        }
        #endregion
    }
}