using Newtonsoft.Json.Linq;
using Newtonsoft.Json;
using Rhea.Common;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Tiger.IBusiness;
using Tiger.Model;
using Tiger.Model.Minsun;
using System.Diagnostics;
using SqlSugar;
using Org.BouncyCastle.Ocsp;

namespace Tiger.Business.WMS
{
    public class SrmToWms : ISrmToWms
    {
        public static object SrmLock { get; } = new object();

        /// <summary>
        /// SRM推送到WMS
        /// </summary>
        /// <param name="dlvys"></param>
        /// <returns></returns>
        public ApiAction SrmDlvys(List<iSrmDlvy> dlvys)
        {
            var action = new ApiAction();
            DbClient db = Biz.Db;
            DateTime runStart = DateTime.Now;
            var companyId = "";
            try
            {
                if (dlvys != null && dlvys.Count > 0)
                {
                    var dlvyList = new List<WMS_SRMRcece>();
                    var asnList = new List<WMS_SRM_ASN>();
                    var dlvyDtlList = new List<WMS_SRM_ASN_LINES>();
                    var dlvySnList = new List<WMS_SRMSNList>();
                    var deliveryNoList = new List<string>();
                    var snDic = new Dictionary<string, List<WMS_SRMSNList>>();
                    List<iSrmDlvy> srmDlvys = new List<iSrmDlvy>();

                    //Work.DoAsync(() =>
                    //{
                    action = SaveSrmDlvyData(dlvys.Clone()); //异步推到新数据库
                    //});

                    return action;
                    foreach (var group in dlvys.Select(q => q.company).Distinct())
                    {
                        switch (group)
                        {
                            case "XCSJ":
                                db = Biz.DataSource["Main"].Client;
                                break;

                            case "DGXC":
                                db = Biz.DataSource["DGXC"].Client;
                                break;

                            case "AHXC":
                                db = Biz.DataSource["AHXC"].Client;
                                break;
                        }
                        companyId = group;
                        srmDlvys = dlvys.Where(x => x.company == group).ToList();
                        foreach (var dlvy in srmDlvys)
                        {
                            if (dlvy.documentStatus != "0")
                            {
                                Logger.Scheduler.Info($"QqtSRM({dlvy.company})开始推送到WMS...");
                                var DeliveryNo = dlvy.documnetNumber;
                                //送货单加入列表供保存时用
                                deliveryNoList.Add(DeliveryNo);
                                var snList = db.Queryable<WMS_SRMSNList>().Where(q => q.DeliveryNo == DeliveryNo).ToList();
                                WMS_SRMRcece srmRcece = db.Queryable<WMS_SRMRcece>().Where(q => q.DeliveryNo == DeliveryNo).Single() ?? new();

                                srmRcece.DeliveryNo = DeliveryNo;
                                srmRcece.Status = dlvy.documentStatus;
                                srmRcece.InnerVendorCode = dlvy.supplierCode;
                                //srmRcece.DeliveryType = dlvy["deliveryType"]?.ToInt32() ?? 0;
                                //srmRcece.LogisticsStatus = dlvy["logisticsStatus"]?.ToString();
                                //srmRcece.PurchaseType = dlvy["purchaseType"]?.ToInt32() ?? 0;
                                //srmRcece.LastOperateTime = dlvy["lastOperateTime"]?.ToString();
                                srmRcece.CreationTime = DateTime.Now;
                                srmRcece.LastModificationTime = DateTime.Now;
                                srmRcece.FLAW = "Y";
                                srmRcece.FLAT = "N";
                                srmRcece.FLAN = "N";
                                dlvyList.Add(srmRcece);

                                WMS_SRM_ASN asn = db.Queryable<WMS_SRM_ASN>().Where(q => q.DeliveryNo == DeliveryNo).Single() ?? new();

                                asn.DeliveryNo = DeliveryNo;
                                asn.status = (Convert.ToInt32(dlvy.documentStatus));
                                asn.innerVendorCode = dlvy.supplierCode;
                                asn.innerVendorName = dlvy.supplierName;
                                //asn.deliveryType = dlvy["deliveryType"]?.ToInt32() ?? 0;
                                //asn.logisticsStatus = dlvy["logisticsStatus"]?.ToInt32() ?? 0;
                                asn.deliveryDate = iSRM.FromUnixTime(Convert.ToInt64(dlvy.deliveryDate));
                                asn.planArrivedDate = iSRM.FromUnixTime(Convert.ToInt64(dlvy.bookDeliveryDate));
                                asn.CreationTime = DateTime.Now;
                                asn.LastModificationTime = DateTime.Now;
                                //asn.updateTime = FromUnixTime(dlvy["updateTime"]?.ToInt64());
                                //asn.grossWeight = dlvy["grossWeight"]?.ToDecimal() ?? 0;
                                //asn.netWeight = dlvy["netWeight"]?.ToDecimal() ?? 0;
                                //asn.totalPackingQty = dlvy["totalPackingQty"]?.ToDecimal() ?? 0;
                                //asn.cargoDeliveryTime = FromUnixTime(dlvy["cargoDeliveryTime"]?.ToInt64());
                                asn.CreationTime = DateTime.Now;
                                asnList.Add(asn);

                                //循环单身列表
                                foreach (var item in dlvy.bookDeliveryItems)
                                {
                                    WMS_SRM_ASN_LINES dtl = new()
                                    {
                                        DeliveryNo = DeliveryNo,
                                        lineNo = Convert.ToInt32(item.orderItemNumber), //pmdt002 项次
                                        poErpNo = item.orderNumber,
                                        poLineNo = item.lotNum, //分批序 pmdt004
                                        purchaseType = Convert.ToInt32(item.purchaseType),
                                        productCode = item.materialNumber,
                                        //productName = item.productName,
                                        //productScale = item.productScale,
                                        deliveryQty = Convert.ToDecimal(item.deliveryQuantity),
                                        //deliveryUnitCode = item.deliveryUnitCode,
                                        deliveryUnitName = item.purchaseUnit,
                                        //deliveryValuationQty = Convert.ToInt32(item.deliveryValuationQty),
                                        //price = item.price"]?.ToDouble() ?? double.MinValue,
                                        //taxPrice = item.taxPrice"]?.ToDouble() ?? double.MinValue,
                                        status = Convert.ToInt32(item.itemStatus),
                                        extendN01 = item.itemNumber, //pmdtseq
                                        //receiveStatus = Convert.ToInt32(item.receiveStatus),
                                        //buyerName = item.buyerName,
                                        //expectedDate = FromUnixTime(Convert.ToInt64(item.expectedDate)),
                                        //answerDate = FromUnixTime(Convert.ToInt64(item.answerDate)),
                                        //currencyCode = item.currencyCode,
                                        //currencyName = item.currencyName,
                                        //sendVerifyStatus = Convert.ToInt32(item.sendVerifyStatus),
                                        //resultFlag = item.resultFlag,
                                        //remark = item.remark,
                                        //brandName = item.brandName,
                                    };
                                    dlvyDtlList.Add(dtl);
                                }

                                //循环条码列表
                                foreach (var item in dlvy.barcodeDetailDatas)
                                {
                                    var sn = item.packetBarcodeNumber;
                                    WMS_SRMSNList dlvySn = snList.Where(q => q.SmallBarcode == sn).SingleOrDefault() ?? new();

                                    dlvySn.DeliveryNo = DeliveryNo;
                                    //dlvySn.BILLCODE = item.poErpNo;
                                    //dlvySn.BILLLINE = item.poLineNo;
                                    dlvySn.MATERIALCODE = item.materialNumber;
                                    dlvySn.SOURCETYPE = "SRM";
                                    //dlvySn.ITEM_NAME = item.productName;
                                    //dlvySn.SPECIFICATION = item.productScale;
                                    dlvySn.IncludeQty = Convert.ToDecimal(item.materialQuantity);
                                    dlvySn.SmallBarcode = item.packetBarcodeNumber;
                                    dlvySn.BigBarcode = item.mediumBarcodeNumber;
                                    dlvySn.OuterBarcode = item.cartonBarcodeNumber;
                                    dlvySn.CreationTime = DateTime.Now;
                                    dlvySn.production_date = DateTime.Now;
                                    dlvySn.LastModificationTime = DateTime.Now;
                                    snList.RemoveAll(q => q.SmallBarcode == sn);
                                    dlvySnList.Add(dlvySn);
                                }
                                //将sn列表加入字典
                                if (!snDic.ContainsKey(DeliveryNo))
                                {
                                    snDic.Add(DeliveryNo, snList);
                                }
                                Logger.Scheduler.Info($"QqtSRM({dlvy.company}) Get Delivery[{DeliveryNo}] Details[{dlvyDtlList.Count}] SN[{dlvySnList.Count}] successful");
                            }
                            else
                            {
                                action.IsSuccessed = false;
                                action.Message = $"SRM推送送货单状态[{dlvy.documentStatus}]不对";
                                return action;
                            }
                        }

                        //保存到数据库
                        var dbTran = db.UseTran(() =>
                        {
                            db.Storageable(dlvyList, "system").ExecuteCommand();
                            db.Storageable(asnList, "system").ExecuteCommand();
                            if (dlvyDtlList.Any())
                            {
                                foreach (var d in deliveryNoList)
                                {
                                    db.Deleteable<WMS_SRM_ASN_LINES>().Where(q => q.DeliveryNo == d).ExecuteCommand();
                                }
                                db.Storageable(dlvyDtlList, "system").ExecuteCommand();
                            }
                            if (dlvySnList.Any())
                            {
                                var i = 0;
                                while (dlvySnList.Count > i)
                                {
                                    var temp = dlvySnList.Skip(i).Take(500).ToList();
                                    db.Storageable(temp, "system").ExecuteCommand();
                                    i += temp.Count;
                                }
                            }
                            //循环字典内的sn列表有存在的删除
                            if (snDic.Any())
                            {
                                foreach (var item in snDic.Keys)
                                {
                                    if (snDic[item].Any())
                                    {
                                        var i = 0;
                                        while (snDic[item].Count > i)
                                        {
                                            var temp = snDic[item].Skip(i).Take(500).ToList();
                                            db.Deleteable(temp).ExecuteCommand();
                                            i += temp.Count;
                                        }
                                    }
                                }
                            }
                        });
                        if (!dbTran.IsSuccess)
                        {
                            throw dbTran.ErrorException;
                        }
                    }
                }
                DateTime endTime = DateTime.Now;
                Logger.Scheduler.Info($"QqtSRM({companyId}) 推送送货单完成，耗时:[{(endTime - runStart).TotalMilliseconds}]");
                action.Message = $"SRM推送送货单到WMS成功";
            }
            catch (Exception ex)
            {
                Logger.Scheduler.Info($"QqtSRM({companyId}) 推送送货单异常，耗时:[{(DateTime.Now - runStart).TotalMilliseconds}]");
                return action.GetResponse().CatchExceptionWithLog(ex, $"SRM To WMS 推送异常");
            }
            return action;
        }

        /// <summary>
        /// QqtSRM数据推送到WMS
        /// </summary>
        /// <param name="dlvys"></param>
        /// <returns></returns>
        public ApiAction SrmDlvysToWms(List<iSrmDlvy> dlvys)
        {
            var action = new ApiAction();
            DbClient db = Biz.Db;
            DateTime runStart = DateTime.Now;
            try
            {
                Logger.Scheduler.Info($"QqtSRM开始推送送货单[{string.Join(",", dlvys.Select(x => x.documnetNumber))}]到新WMS...");
                var dlvyList = new List<BIZ_SRM_DLVY>();
                var dlvyDtlList = new List<BIZ_SRM_DLVY_DTL>();
                var dlvySnList = new List<BIZ_SRM_DLVY_SN>();
                var deliveryNoList = new List<string>();
                var snDic = new Dictionary<string, List<BIZ_SRM_DLVY_SN>>();
                //var pkgs = new List<WMS_ITEM_PKG>();
                //var items = new List<WMS_ITEM>();
                //var hiss = new List<WMS_ITEM_HIS>();
                foreach (var dlvy in dlvys)
                {
                    if (dlvy.documentStatus != "0")
                    {
                        //Debug.WriteLine($"Begin1:{DateTime.Now}");
                        Logger.Scheduler.Info($"New QqtSRM({dlvy.company})开始推送数据...");
                        var DeliveryNo = dlvy.documnetNumber;
                        //送货单加入列表供保存时用
                        deliveryNoList.Add(DeliveryNo);
                        var snList = db.Queryable<BIZ_SRM_DLVY_SN>().Where(q => q.DELIVERY_NO == DeliveryNo).ToList();
                        BIZ_SRM_DLVY _dlvy = db.Queryable<BIZ_SRM_DLVY>().Where(q => q.DELIVERY_NO == DeliveryNo).Single() ?? new()
                        {
                            DELIVERY_NO = DeliveryNo,
                            STATUS = Convert.ToInt32(dlvy.documentStatus),
                            SUPP_CODE = dlvy.supplierCode,
                            HANDLED = 0,
                            SUPP_NAME = dlvy.supplierName,
                            DELIVERY_DATE = iSRM.FromUnixTime(Convert.ToInt64(dlvy.deliveryDate)),
                            PLANARRIVED_DATE = iSRM.FromUnixTime(Convert.ToInt64(dlvy.bookDeliveryDate)),
                            AUTH_ORG = dlvy.company,
                        };
                        dlvyList.Add(_dlvy);

                        //循环单身列表
                        var PoNo = dlvy.bookDeliveryItems[0].orderNumber;
                        var dtls = db.Queryable<BIZ_SRM_DLVY_DTL>().Where(q => q.DELIVERY_NO == DeliveryNo).ToList();
                        foreach (var item in dlvy.bookDeliveryItems)
                        {
                            BIZ_SRM_DLVY_DTL dtl = dtls.Where(x => x.ITEM_CODE == item.materialNumber && x.PO_LINE_NO == Convert.ToInt32(item.itemNumber)).FirstOrDefault() ?? new();
                            dtl.DELIVERY_NO = DeliveryNo;
                            dtl.LINE_NO = Convert.ToInt32(item.orderItemNumber); //pmdt002 项次
                            dtl.ERP_PO_NO = item.orderNumber;
                            dtl.BATCH_NUMBER = item.lotNum; //分批序 pmdt004
                            dtl.PO_TYPE = Convert.ToInt32(item.purchaseType);
                            dtl.ITEM_CODE = item.materialNumber;
                            //productName = item.productName,
                            //productScale = item.productScale,
                            dtl.QTY = Convert.ToDecimal(item.deliveryQuantity);
                            dtl.UNIT = item.purchaseUnit;
                            dtl.PRICE = Convert.ToDouble(item.price);
                            dtl.TAX_PRICE = Convert.ToDouble(item.taxPrice);
                            dtl.STATUS = Convert.ToInt32(item.itemStatus);
                            dtl.PO_LINE_NO = Convert.ToInt32(item.itemNumber); //pmdtseq
                            dtl.BUYER = item.buyerName;
                            //receiveStatus = Convert.ToInt32(item.receiveStatus),
                            //expectedDate = FromUnixTime(Convert.ToInt64(item.expectedDate)),
                            //answerDate = FromUnixTime(Convert.ToInt64(item.answerDate)),
                            //currencyCode = item.currencyCode,
                            //currencyName = item.currencyName,
                            //sendVerifyStatus = Convert.ToInt32(item.sendVerifyStatus),
                            //resultFlag = item.resultFlag,
                            //remark = item.remark,
                            //brandName = item.brandName,
                            dtl.AUTH_ORG = dlvy.company;
                            dlvyDtlList.Add(dtl);
                            Logger.Scheduler.Info($"新SRM单身：[{DeliveryNo} - {item.materialNumber}]");
                        }

                        //循环条码列表
                        foreach (var item in dlvy.barcodeDetailDatas.OrderBy(x => x.materialNumber))
                        {
                            var sn = item.packetBarcodeNumber;
                            BIZ_SRM_DLVY_SN dlvySn = snList.Where(q => q.SMALL_BARCODE == sn).SingleOrDefault() ?? new();

                            dlvySn.DELIVERY_NO = DeliveryNo;
                            //dlvySn.PO_LINE_NO = lineno;
                            dlvySn.ITEM_CODE = item.materialNumber;
                            dlvySn.QTY = Convert.ToDecimal(item.materialQuantity);
                            dlvySn.SMALL_BARCODE = sn;
                            dlvySn.SMALL_SN = sn;
                            dlvySn.BIG_BARCODE = item.mediumBarcodeNumber;
                            dlvySn.BIG_SN = item.mediumBarcodeNumber;
                            dlvySn.OUTER_BARCODE = item.cartonBarcodeNumber;
                            dlvySn.OUTER_SN = item.cartonBarcodeNumber;
                            dlvySn.AUTH_ORG = dlvy.company;
                            dlvySn.PO_ERP_NO = PoNo;
                            dlvySn.IMPORTED = 1;
                            dlvySn.IMPORTED_DATE = DateTime.Now;

                            //dlvySn.PROD_DATE = DateTime.Now;
                            snList.RemoveAll(q => q.SMALL_BARCODE == sn);
                            dlvySnList.Add(dlvySn);
                            Debug.WriteLine(dlvySnList.Count);

                            ////OUTER_SN
                            //if (!dlvySn.OUTER_SN.IsNullOrEmpty() && !pkgs.Any(q => q.SN == dlvySn.OUTER_SN))
                            //{
                            //    //var pkg = db.Queryable<WMS_ITEM_PKG>().Where(x => x.SN == dlvySn.OUTER_SN).First() ?? new() {
                            //    //};
                            //    pkgs.Add(new WMS_ITEM_PKG()
                            //    {
                            //        AUTH_ORG = dlvy.company,
                            //        SN = dlvySn.OUTER_SN,
                            //        PKG_TYPE = dlvySn.OUTER_SN.StartsWith("P") ? WMS_ITEM_PKG.PKG_TYPEs.Pallet.GetValue() : (dlvySn.OUTER_SN.StartsWith("C") ? WMS_ITEM_PKG.PKG_TYPEs.Carton.GetValue() : WMS_ITEM_PKG.PKG_TYPEs.OnePiece.GetValue()),
                            //        ITEM_CODE = dlvySn.ITEM_CODE,
                            //        QTY = dlvy.barcodeDetailDatas.Where(q => q.cartonBarcodeNumber == dlvySn.OUTER_SN).Sum(q => Convert.ToDecimal(q.materialQuantity)),
                            //        TRANS_CODE = nameof(BIZ_SRM_DLVY),
                            //        TRANS_NO = dlvySn.DELIVERY_NO,
                            //        SUPP_CODE = dlvySn.SUPP_CODE,
                            //    });
                            //}
                            ////BIG_SN
                            //if (!dlvySn.BIG_SN.IsNullOrEmpty() && !pkgs.Any(q => q.SN == dlvySn.BIG_SN))
                            //{
                            //    pkgs.Add(new WMS_ITEM_PKG()
                            //    {
                            //        AUTH_ORG = dlvy.company,
                            //        SN = dlvySn.BIG_SN,
                            //        PARENT_SN = dlvySn.OUTER_SN,
                            //        PKG_TYPE = dlvySn.BIG_SN.StartsWith("P") ? WMS_ITEM_PKG.PKG_TYPEs.Pallet.GetValue() : (dlvySn.BIG_SN.StartsWith("C") ? WMS_ITEM_PKG.PKG_TYPEs.Carton.GetValue() : WMS_ITEM_PKG.PKG_TYPEs.OnePiece.GetValue()),
                            //        ITEM_CODE = dlvySn.ITEM_CODE,
                            //        QTY = dlvy.barcodeDetailDatas.Where(q => q.mediumBarcodeNumber == dlvySn.BIG_SN).Sum(q => Convert.ToDecimal(q.materialQuantity)),
                            //        TRANS_CODE = nameof(BIZ_SRM_DLVY),
                            //        TRANS_NO = dlvySn.DELIVERY_NO,
                            //        SUPP_CODE = dlvySn.SUPP_CODE,
                            //    });
                            //}
                            ////SMALL_SN
                            //if (!dlvySn.SMALL_SN.IsNullOrEmpty() && !pkgs.Any(q => q.SN == dlvySn.SMALL_SN))
                            //{
                            //    pkgs.Add(new WMS_ITEM_PKG()
                            //    {
                            //        AUTH_ORG = dlvy.company,
                            //        SN = dlvySn.SMALL_SN,
                            //        PARENT_SN = dlvySn.BIG_SN,
                            //        PKG_TYPE = dlvySn.SMALL_SN.StartsWith("P") ? WMS_ITEM_PKG.PKG_TYPEs.Pallet.GetValue() : (dlvySn.SMALL_SN.StartsWith("C") ? WMS_ITEM_PKG.PKG_TYPEs.Carton.GetValue() : WMS_ITEM_PKG.PKG_TYPEs.OnePiece.GetValue()),
                            //        ITEM_CODE = dlvySn.ITEM_CODE,
                            //        QTY = dlvySn.QTY,
                            //        TRANS_CODE = nameof(BIZ_SRM_DLVY),
                            //        TRANS_NO = dlvySn.DELIVERY_NO,
                            //        SUPP_CODE = dlvySn.SUPP_CODE,
                            //    });
                            //    var newItem = new WMS_ITEM()
                            //    {
                            //        AUTH_ORG = dlvy.company,
                            //        SN = dlvySn.SMALL_SN,
                            //        ITEM_CODE = dlvySn.ITEM_CODE,
                            //        STATUS = WMS_ITEM.STATUSs.Incoming.GetValue(),
                            //        QTY = dlvySn.QTY,
                            //        PROD_DATE = dlvySn.PROD_DATE,
                            //        TRANS_CODE = nameof(BIZ_SRM_DLVY),
                            //        TRANS_LINE = dlvySn.PO_LINE_NO.ToString(),
                            //        TRANS_NO = dlvySn.DELIVERY_NO,
                            //        SUPP_CODE = dlvy.supplierCode,
                            //        CARTON_NO = dlvySn.BIG_SN.StartsWith("C") ? dlvySn.BIG_SN : null,
                            //        PALLET_NO = dlvySn.OUTER_SN.StartsWith("P") ? dlvySn.OUTER_SN : null,
                            //        IS_LOCKED = "N",
                            //        SOURCE_CODE = nameof(BIZ_ERP_PO),
                            //        SOURCE_LINE = dlvySn.PO_LINE_NO.ToString(),
                            //        SOURCE_ORDER = PoNo,
                            //        CREATE_USER = "SRM",
                            //        UPDATE_USER = "SRM",
                            //    };
                            //    items.Add(newItem);
                            //    hiss.Add(new WMS_ITEM_HIS(newItem, $"从供应商送货单获取条码[{dlvySn.SMALL_SN}]数据"));
                            //}
                        }
                        //将sn列表加入字典
                        if (!snDic.ContainsKey(DeliveryNo))
                        {
                            snDic.Add(DeliveryNo, snList);
                        }
                        Logger.Scheduler.Info($"New QqtSRM({dlvy.company}) Get Delivery[{DeliveryNo}] Details[{dlvyDtlList.Count}] SN[{dlvySnList.Count}] successful");

                        //Debug.WriteLine($"End1:{DateTime.Now}");
                    }
                    else
                    {
                        Logger.Scheduler.Error($"SRM推送送货单状态[{dlvy.documentStatus}]不对");

                        //action.IsSuccessed = false;
                        //action.Message = $"SRM推送送货单状态[{dlvy.documentStatus}]不对";
                        //return action;
                    }
                }

                DbClient _db = Biz.DataSource["WMS57"].Client;
                //保存到数据库
                var dbTran = _db.UseTran(() =>
                {
                    //DateTime startTime = DateTime.Now;
                    //Debug.WriteLine($"Begin:{startTime}");
                    _db.Utilities.PageEach(dlvyList, 1000, pageList =>
                    {
                        var y = _db.Storageable(pageList, "SRM")
                                .WhereColumns(t => new { t.DELIVERY_NO, t.GHOST_ROW })
                                .ToStorage();
                        y.BulkCopy();
                        y.BulkUpdate();
                    });
                    if (dlvyDtlList.Any())
                    {
                        //foreach (var d in deliveryNoList)
                        {
                            // _db.Deleteable<BIZ_SRM_DLVY_DTL>().Where(q => deliveryNoList.Contains(q.DELIVERY_NO)).ExecuteCommand();
                        }
                        _db.Utilities.PageEach(dlvyDtlList, 1000, pageList =>
                        {
                            var y = _db.Storageable(pageList, "SRM")
                                    .WhereColumns(t => new { t.DELIVERY_NO, t.ITEM_CODE, t.LINE_NO, t.GHOST_ROW })
                                    .ToStorage();
                            y.BulkCopy();
                            y.BulkUpdate();
                        });
                    }
                    if (dlvySnList.Any())
                    {
                        _db.Utilities.PageEach(dlvySnList, 1000, pageList =>
                        {
                            var y = _db.Storageable(pageList, "SRM")
                                    .WhereColumns(t => new { t.SMALL_SN, t.GHOST_ROW })
                                    .ToStorage();
                            y.BulkCopy();
                            y.BulkUpdate();
                        });
                        //var i = 0;
                        //while (dlvySnList.Count > i)
                        //{
                        //    var temp = dlvySnList.Skip(i).Take(500).ToList();
                        //    _db.Storageable(temp, "SRM").ExecuteCommand();
                        //    i += temp.Count;
                        //    Debug.WriteLine(i);
                        //}
                    }
                    //循环字典内的sn列表有存在的删除
                    if (snDic.Any())
                    {
                        foreach (var item in snDic.Keys)
                        {
                            if (snDic[item].Any())
                            {
                                var i = 0;
                                while (snDic[item].Count > i)
                                {
                                    var temp = snDic[item].Skip(i).Take(500).ToList();
                                    _db.Deleteable(temp).ExecuteCommand();
                                    i += temp.Count;
                                }
                            }
                        }
                    }
                    //_db.Utilities.PageEach(pkgs, 1000, pageList =>
                    //{
                    //    var x = _db.Storageable(pageList, "SRM")
                    //       .WhereColumns(t => new { t.SN, t.GHOST_ROW })
                    //       .ToStorage();
                    //    x.BulkCopy();
                    //    x.BulkUpdate(); //.IgnoreColumns(x => x.ID);
                    //});

                    //_db.Utilities.PageEach(items, 1000, pageList =>
                    //{
                    //    var y = _db.Storageable(pageList, "SRM")
                    //           .WhereColumns(t => new { t.SN, t.GHOST_ROW })
                    //           .ToStorage();
                    //    y.BulkCopy();
                    //    y.BulkUpdate();
                    //});
                    //_db.Fastest<WMS_ITEM_HIS>().BulkCopy(hiss);//插入
                    ////_db.Insertable(hiss, "SRM").ExecuteCommand();
                    //Debug.WriteLine($"End:{DateTime.Now}，耗时:[{(DateTime.Now - startTime).TotalSeconds}]");
                });
                if (!dbTran.IsSuccess)
                {
                    //throw dbTran.ErrorException;
                    Logger.Scheduler.Error($"QqtSRM推送新送货单异常，错误:[{dbTran.ErrorException.Message}]");
                }
                foreach (var dlvy in dlvys)
                {
                    if (dlvy.documentStatus != "0")
                    {
                        try
                        {
                            var bTime = DateTime.Now;
                            Biz.Db.Ado.UseStoredProcedure().ExecuteCommand("pkg_ImportItemFromSRM", new SugarParameter("dlvyNo", dlvy.documnetNumber));
                            Logger.Scheduler.Info($"New QqtSRM 保存送货单[{dlvy.documnetNumber}]条码导入WMS_ITEM完成，耗时:[{(DateTime.Now - bTime).TotalMilliseconds}]毫秒");
                        }
                        catch (System.Exception ex)
                        {
                            Logger.Scheduler.Error($"New QqtSRM 保存送货单[{dlvy.documnetNumber}]条码导入WMS_ITEM异常：[{ex.Message}]");
                        }
                    }
                }
                DateTime endTime = DateTime.Now;
                Logger.Scheduler.Info($"New QqtSRM 推送送货单[{string.Join(",", dlvys.Select(x => x.documnetNumber))}]完成，耗时:[{(endTime - runStart).TotalMilliseconds}]");
            }
            catch (Exception ex)
            {
                Logger.Scheduler.Error($"QqtSRM推送新送货单异常，错误:[{ex.Message}]");
            }
            return action;
        }

        /// <summary>
        /// 异步推送到新数据库
        /// </summary>
        /// <returns></returns>
        private ApiAction SaveSrmDlvyData(List<iSrmDlvy> dlvys)
        {
            lock (SrmLock)
            {
                var action = new ApiAction();
                DbClient db = Biz.DataSource["WMS57"].Client;
                DateTime runStart = DateTime.Now;
                try
                {
                    Logger.Scheduler.Info($"QqtSRM开始推送送货单[{string.Join(",", dlvys.Select(x => x.documnetNumber))}]到新WMS...");
                    var dlvyList = new List<BIZ_SRM_DLVY>();
                    var dlvyDtlList = new List<BIZ_SRM_DLVY_DTL>();
                    var dlvySnList = new List<BIZ_SRM_DLVY_SN>();
                    var deliveryNoList = new List<string>();
                    var snDic = new Dictionary<string, List<BIZ_SRM_DLVY_SN>>();
                    //var pkgs = new List<WMS_ITEM_PKG>();
                    //var items = new List<WMS_ITEM>();
                    //var hiss = new List<WMS_ITEM_HIS>();
                    foreach (var dlvy in dlvys)
                    {
                        if (dlvy.documentStatus != "0")
                        {
                            //Debug.WriteLine($"Begin1:{DateTime.Now}");
                            Logger.Scheduler.Info($"New QqtSRM({dlvy.company})开始推送数据...");
                            var DeliveryNo = dlvy.documnetNumber;
                            //送货单加入列表供保存时用
                            deliveryNoList.Add(DeliveryNo);
                            var snList = db.Queryable<BIZ_SRM_DLVY_SN>().Where(q => q.DELIVERY_NO == DeliveryNo).ToList();
                            var statusitem = dlvys.Count(i => i.bookDeliveryItems.Any(a => a.itemStatus != "4"));
                            BIZ_SRM_DLVY _dlvy = db.Queryable<BIZ_SRM_DLVY>().Where(q => q.DELIVERY_NO == DeliveryNo).Single() ?? new()
                            {
                                DELIVERY_NO = DeliveryNo,
                                STATUS = Convert.ToInt32(dlvy.documentStatus),
                                SUPP_CODE = dlvy.supplierCode,
                                HANDLED = 0,
                                SUPP_NAME = dlvy.supplierName,
                                DELIVERY_DATE = iSRM.FromUnixTime(Convert.ToInt64(dlvy.deliveryDate)),
                                PLANARRIVED_DATE = iSRM.FromUnixTime(Convert.ToInt64(dlvy.bookDeliveryDate)),
                                AUTH_ORG = dlvy.company,
                            };
                            if (statusitem == 0)
                            {
                                _dlvy.STATUS = 4;
                            }
                            dlvyList.Add(_dlvy);

                            //循环单身列表
                            var PoNo = dlvy.bookDeliveryItems[0].orderNumber;
                            var dtls = db.Queryable<BIZ_SRM_DLVY_DTL>().Where(q => q.DELIVERY_NO == DeliveryNo).ToList();
                            foreach (var item in dlvy.bookDeliveryItems)
                            {
                                BIZ_SRM_DLVY_DTL dtl = dtls.Where(x => x.ITEM_CODE == item.materialNumber && x.PO_LINE_NO == Convert.ToInt32(item.itemNumber)).FirstOrDefault() ?? new();
                                dtl.DELIVERY_NO = DeliveryNo;
                                dtl.LINE_NO = Convert.ToInt32(item.orderItemNumber); //pmdt002 项次
                                dtl.ERP_PO_NO = item.orderNumber;
                                dtl.BATCH_NUMBER = item.lotNum; //分批序 pmdt004
                                dtl.PO_TYPE = Convert.ToInt32(item.purchaseType);
                                dtl.ITEM_CODE = item.materialNumber;
                                //productName = item.productName,
                                //productScale = item.productScale,
                                dtl.QTY = Convert.ToDecimal(item.deliveryQuantity);
                                dtl.UNIT = item.purchaseUnit;
                                dtl.PRICE = Convert.ToDouble(item.price);
                                dtl.TAX_PRICE = Convert.ToDouble(item.taxPrice);
                                dtl.STATUS = Convert.ToInt32(item.itemStatus);
                                dtl.PO_LINE_NO = Convert.ToInt32(item.itemNumber); //pmdtseq
                                dtl.BUYER = item.buyerName;
                                //receiveStatus = Convert.ToInt32(item.receiveStatus),
                                //expectedDate = FromUnixTime(Convert.ToInt64(item.expectedDate)),
                                //answerDate = FromUnixTime(Convert.ToInt64(item.answerDate)),
                                //currencyCode = item.currencyCode,
                                //currencyName = item.currencyName,
                                //sendVerifyStatus = Convert.ToInt32(item.sendVerifyStatus),
                                //resultFlag = item.resultFlag,
                                //remark = item.remark,
                                //brandName = item.brandName,
                                dtl.AUTH_ORG = dlvy.company;
                                dlvyDtlList.Add(dtl);
                                Logger.Scheduler.Info($"新SRM单身：[{DeliveryNo} - {item.materialNumber}]");
                            }

                            //循环条码列表
                            foreach (var item in dlvy.barcodeDetailDatas.OrderBy(x => x.materialNumber))
                            {
                                var sn = item.packetBarcodeNumber;
                                BIZ_SRM_DLVY_SN dlvySn = snList.Where(q => q.SMALL_BARCODE == sn).SingleOrDefault() ?? new();

                                dlvySn.DELIVERY_NO = DeliveryNo;
                                //dlvySn.PO_LINE_NO = lineno;
                                dlvySn.ITEM_CODE = item.materialNumber;
                                dlvySn.QTY = Convert.ToDecimal(item.materialQuantity);
                                dlvySn.SMALL_BARCODE = sn;
                                dlvySn.SMALL_SN = sn;
                                dlvySn.BIG_BARCODE = item.mediumBarcodeNumber;
                                dlvySn.BIG_SN = item.mediumBarcodeNumber;
                                dlvySn.OUTER_BARCODE = item.cartonBarcodeNumber;
                                dlvySn.OUTER_SN = item.cartonBarcodeNumber;
                                dlvySn.AUTH_ORG = dlvy.company;
                                dlvySn.PO_ERP_NO = PoNo;
                                dlvySn.IMPORTED = 1;
                                dlvySn.IMPORTED_DATE = DateTime.Now;

                                //dlvySn.PROD_DATE = DateTime.Now;
                                snList.RemoveAll(q => q.SMALL_BARCODE == sn);
                                dlvySnList.Add(dlvySn);
                                Debug.WriteLine(dlvySnList.Count);

                                #region MyRegion

                                ////OUTER_SN
                                //if (!dlvySn.OUTER_SN.IsNullOrEmpty() && !pkgs.Any(q => q.SN == dlvySn.OUTER_SN))
                                //{
                                //    //var pkg = db.Queryable<WMS_ITEM_PKG>().Where(x => x.SN == dlvySn.OUTER_SN).First() ?? new() {
                                //    //};
                                //    pkgs.Add(new WMS_ITEM_PKG()
                                //    {
                                //        AUTH_ORG = dlvy.company,
                                //        SN = dlvySn.OUTER_SN,
                                //        PKG_TYPE = dlvySn.OUTER_SN.StartsWith("P") ? WMS_ITEM_PKG.PKG_TYPEs.Pallet.GetValue() : (dlvySn.OUTER_SN.StartsWith("C") ? WMS_ITEM_PKG.PKG_TYPEs.Carton.GetValue() : WMS_ITEM_PKG.PKG_TYPEs.OnePiece.GetValue()),
                                //        ITEM_CODE = dlvySn.ITEM_CODE,
                                //        QTY = dlvy.barcodeDetailDatas.Where(q => q.cartonBarcodeNumber == dlvySn.OUTER_SN).Sum(q => Convert.ToDecimal(q.materialQuantity)),
                                //        TRANS_CODE = nameof(BIZ_SRM_DLVY),
                                //        TRANS_NO = dlvySn.DELIVERY_NO,
                                //        SUPP_CODE = dlvySn.SUPP_CODE,
                                //    });
                                //}
                                ////BIG_SN
                                //if (!dlvySn.BIG_SN.IsNullOrEmpty() && !pkgs.Any(q => q.SN == dlvySn.BIG_SN))
                                //{
                                //    pkgs.Add(new WMS_ITEM_PKG()
                                //    {
                                //        AUTH_ORG = dlvy.company,
                                //        SN = dlvySn.BIG_SN,
                                //        PARENT_SN = dlvySn.OUTER_SN,
                                //        PKG_TYPE = dlvySn.BIG_SN.StartsWith("P") ? WMS_ITEM_PKG.PKG_TYPEs.Pallet.GetValue() : (dlvySn.BIG_SN.StartsWith("C") ? WMS_ITEM_PKG.PKG_TYPEs.Carton.GetValue() : WMS_ITEM_PKG.PKG_TYPEs.OnePiece.GetValue()),
                                //        ITEM_CODE = dlvySn.ITEM_CODE,
                                //        QTY = dlvy.barcodeDetailDatas.Where(q => q.mediumBarcodeNumber == dlvySn.BIG_SN).Sum(q => Convert.ToDecimal(q.materialQuantity)),
                                //        TRANS_CODE = nameof(BIZ_SRM_DLVY),
                                //        TRANS_NO = dlvySn.DELIVERY_NO,
                                //        SUPP_CODE = dlvySn.SUPP_CODE,
                                //    });
                                //}
                                ////SMALL_SN
                                //if (!dlvySn.SMALL_SN.IsNullOrEmpty() && !pkgs.Any(q => q.SN == dlvySn.SMALL_SN))
                                //{
                                //    pkgs.Add(new WMS_ITEM_PKG()
                                //    {
                                //        AUTH_ORG = dlvy.company,
                                //        SN = dlvySn.SMALL_SN,
                                //        PARENT_SN = dlvySn.BIG_SN,
                                //        PKG_TYPE = dlvySn.SMALL_SN.StartsWith("P") ? WMS_ITEM_PKG.PKG_TYPEs.Pallet.GetValue() : (dlvySn.SMALL_SN.StartsWith("C") ? WMS_ITEM_PKG.PKG_TYPEs.Carton.GetValue() : WMS_ITEM_PKG.PKG_TYPEs.OnePiece.GetValue()),
                                //        ITEM_CODE = dlvySn.ITEM_CODE,
                                //        QTY = dlvySn.QTY,
                                //        TRANS_CODE = nameof(BIZ_SRM_DLVY),
                                //        TRANS_NO = dlvySn.DELIVERY_NO,
                                //        SUPP_CODE = dlvySn.SUPP_CODE,
                                //    });
                                //    var newItem = new WMS_ITEM()
                                //    {
                                //        AUTH_ORG = dlvy.company,
                                //        SN = dlvySn.SMALL_SN,
                                //        ITEM_CODE = dlvySn.ITEM_CODE,
                                //        STATUS = WMS_ITEM.STATUSs.Incoming.GetValue(),
                                //        QTY = dlvySn.QTY,
                                //        PROD_DATE = dlvySn.PROD_DATE,
                                //        FIRST_IN_DATE = DateTime.Now,
                                //        TRANS_CODE = nameof(BIZ_SRM_DLVY),
                                //        TRANS_LINE = dlvySn.PO_LINE_NO.ToString(),
                                //        TRANS_NO = dlvySn.DELIVERY_NO,
                                //        SUPP_CODE = dlvy.supplierCode,
                                //        CARTON_NO = dlvySn.BIG_SN.StartsWith("C") ? dlvySn.BIG_SN : null,
                                //        PALLET_NO = dlvySn.OUTER_SN.StartsWith("P") ? dlvySn.OUTER_SN : null,
                                //        IS_LOCKED = "N",
                                //        SOURCE_CODE = nameof(BIZ_ERP_PO),
                                //        SOURCE_LINE = dlvySn.PO_LINE_NO.ToString(),
                                //        SOURCE_ORDER = PoNo,
                                //        CREATE_USER = "SRM",
                                //        UPDATE_USER = "SRM",
                                //    };
                                //    items.Add(newItem);
                                //    hiss.Add(new WMS_ITEM_HIS(newItem, $"从供应商送货单获取条码[{dlvySn.SMALL_SN}]数据"));
                                //}

                                #endregion MyRegion
                            }
                            //将sn列表加入字典
                            if (!snDic.ContainsKey(DeliveryNo))
                            {
                                snDic.Add(DeliveryNo, snList);
                            }
                            Logger.Scheduler.Info($"New QqtSRM({dlvy.company}) Get Delivery[{DeliveryNo}] Details[{dlvyDtlList.Count}] SN[{dlvySnList.Count}] successful");

                            //Debug.WriteLine($"End1:{DateTime.Now}");
                        }
                        else
                        {
                            Logger.Scheduler.Error($"SRM推送送货单状态[{dlvy.documentStatus}]不对");

                            action.IsSuccessed = false;
                            action.LocaleMsg = Biz.L($"SRM推送送货单状态[{dlvy.documentStatus}]不对");
                            //return action;
                        }
                    }

                    DbClient _db = Biz.DataSource["WMS57"].Client;
                    //保存到数据库
                    var dbTran = _db.UseTran(() =>
                    {
                        //DateTime startTime = DateTime.Now;
                        //Debug.WriteLine($"Begin:{startTime}");

                        if (dlvyList.Count > 150)
                        {
                            _db.Utilities.PageEach(dlvyList, 1000, pageList =>
                            {
                                var y = _db.Storageable(pageList, "SRM")
                                       .WhereColumns(t => new { t.DELIVERY_NO, t.GHOST_ROW })
                                       .ToStorage();
                                y.BulkCopy();
                                y.BulkUpdate();
                            });
                        }
                        else
                        {
                            var d = _db.Storageable(dlvyList, "SRM")
                                       .WhereColumns(t => new { t.DELIVERY_NO, t.GHOST_ROW })
                                       .ToStorage();
                            d.AsInsertable.ExecuteCommand();
                            d.AsUpdateable.IgnoreColumns(x => x.ID).ExecuteCommand();
                        }
                        if (dlvyDtlList.Any())
                        {
                            //foreach (var d in deliveryNoList)
                            {
                                //_db.Deleteable<BIZ_SRM_DLVY_DTL>().Where(q => deliveryNoList.Contains(q.DELIVERY_NO)).ExecuteCommand();
                            }
                            if (dlvyDtlList.Count > 150)
                            {
                                _db.Utilities.PageEach(dlvyDtlList, 1000, pageList =>
                                {
                                    var y = _db.Storageable(pageList, "SRM")
                                           .WhereColumns(t => new { t.DELIVERY_NO, t.ITEM_CODE, t.PO_LINE_NO, t.GHOST_ROW })
                                           .ToStorage();
                                    y.BulkCopy();
                                    y.BulkUpdate();
                                });
                            }
                            else
                            {
                                var l = _db.Storageable(dlvyDtlList, "SRM")
                                       .WhereColumns(t => new { t.DELIVERY_NO, t.ITEM_CODE, t.PO_LINE_NO, t.GHOST_ROW })
                                       .ToStorage();
                                l.AsInsertable.ExecuteCommand();
                                l.AsUpdateable.IgnoreColumns(x => x.ID).ExecuteCommand();
                            }
                        }
                        if (dlvySnList.Any())
                        {
                            if (dlvySnList.Count > 150)
                            {
                                _db.Utilities.PageEach(dlvySnList, 1000, pageList =>
                                {
                                    var y = _db.Storageable(pageList, "SRM")
                                           .WhereColumns(t => new { t.SMALL_SN, t.GHOST_ROW })
                                           .ToStorage();
                                    y.BulkCopy();
                                    y.BulkUpdate();
                                });
                            }
                            else
                            {
                                var s = _db.Storageable(dlvySnList, "SRM")
                                       .WhereColumns(t => new { t.SMALL_SN, t.GHOST_ROW })
                                       .ToStorage();
                                s.AsInsertable.ExecuteCommand();
                                s.AsUpdateable.IgnoreColumns(x => x.ID).ExecuteCommand();
                            }
                        }
                        //循环字典内的sn列表有存在的删除
                        if (snDic.Any())
                        {
                            foreach (var item in snDic.Keys)
                            {
                                if (snDic[item].Any())
                                {
                                    var i = 0;
                                    while (snDic[item].Count > i)
                                    {
                                        var temp = snDic[item].Skip(i).Take(500).ToList();
                                        _db.Deleteable(temp).ExecuteCommand();
                                        i += temp.Count;
                                    }
                                }
                            }
                        }

                        //if (pkgs.Count > 150)
                        //{
                        //    _db.Utilities.PageEach(pkgs, 1000, pageList =>
                        //    {
                        //        var x = _db.Storageable(pageList, "SRM")
                        //           .WhereColumns(t => new { t.SN, t.GHOST_ROW })
                        //           .ToStorage();
                        //        x.BulkCopy();
                        //        x.BulkUpdate(); //.IgnoreColumns(x => x.ID);
                        //    });
                        //}
                        //else
                        //{
                        //    var x = _db.Storageable(pkgs, "SRM")
                        //          .WhereColumns(t => new { t.SN, t.GHOST_ROW })
                        //          .ToStorage();
                        //    x.AsInsertable.ExecuteCommand();
                        //    x.AsUpdateable.IgnoreColumns(x => x.ID).ExecuteCommand();
                        //}

                        //if (items.Count > 150)
                        //{
                        //    _db.Utilities.PageEach(items, 1000, pageList =>
                        //    {
                        //        var y = _db.Storageable(pageList, "SRM")
                        //               .WhereColumns(t => new { t.SN, t.GHOST_ROW })
                        //               .ToStorage();
                        //        y.BulkCopy();
                        //        y.BulkUpdate();
                        //    });
                        //}
                        //else
                        //{
                        //    var y = _db.Storageable(items, "SRM")
                        //           .WhereColumns(t => new { t.SN, t.GHOST_ROW })
                        //           .ToStorage();
                        //    y.AsInsertable.ExecuteCommand();
                        //    y.AsUpdateable.IgnoreColumns(x => x.ID).ExecuteCommand();
                        //}
                        //if (hiss.Count > 150)
                        //{
                        //    _db.Fastest<WMS_ITEM_HIS>().BulkCopy(hiss);//插入
                        //}
                        //else
                        //{
                        //    _db.Insertable(hiss, "SRM").ExecuteCommand();
                        //}

                        //Debug.WriteLine($"End:{DateTime.Now}，耗时:[{(DateTime.Now - startTime).TotalSeconds}]");
                    });
                    if (!dbTran.IsSuccess)
                    {
                        //throw dbTran.ErrorException;
                        Logger.Scheduler.Error($"QqtSRM推送新送货单异常，错误:[{dbTran.ErrorException.Message}]");
                        action.LocaleMsg = Biz.L($"QqtSRM推送新送货单异常，错误:[{dbTran.ErrorException.Message}]");
                    }
                    DbClient adoDb = Biz.DataSource["WMS57"].Client;
                    foreach (var dlvy in dlvys)
                    {
                        if (dlvy.documentStatus != "0")
                        {
                            try
                            {
                                var bTime = DateTime.Now;
                                adoDb.Ado.UseStoredProcedure().ExecuteCommand("pkg_ImportItemFromSRM", new SugarParameter("dlvyNo", dlvy.documnetNumber));
                                Logger.Scheduler.Info($"New QqtSRM 保存送货单[{dlvy.documnetNumber}]条码导入WMS_ITEM完成，耗时:[{(DateTime.Now - bTime).TotalMilliseconds}]毫秒");
                            }
                            catch (System.Exception ex)
                            {
                                Logger.Scheduler.Error($"New QqtSRM 保存送货单[{dlvy.documnetNumber}]条码导入WMS_ITEM异常：[{ex.Message}]");
                            }
                        }
                    }
                    DateTime endTime = DateTime.Now;
                    Logger.Scheduler.Info($"New QqtSRM 推送送货单[{string.Join(",", dlvys.Select(x => x.documnetNumber))}]完成，耗时:[{(endTime - runStart).TotalMilliseconds}]");
                    action.LocaleMsg = Biz.L($"New QqtSRM 推送送货单[{string.Join(",", dlvys.Select(x => x.documnetNumber))}]完成，耗时:[{(endTime - runStart).TotalMilliseconds}]");
                }
                catch (Exception ex)
                {
                    Logger.Scheduler.Error($"QqtSRM推送新送货单异常，错误:[{ex.Message}]");
                    action.IsSuccessed = false;
                    action.LocaleMsg = Biz.L($"QqtSRM推送新送货单异常，错误:[{ex.Message}]");
                }
                return action;
            }
        }
    }
}