From cff4ebaee427c1680a966c4c3ab2b274e6cfe9ac Mon Sep 17 00:00:00 2001 From: shanj <18996038927@163.com> Date: Wed, 28 Jun 2023 22:14:23 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BF=AB=E9=80=92=E5=8D=95=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../DataRepair/DataRepairBusiness.cs | 27 +++++++++++++++++-- 1 file changed, 25 insertions(+), 2 deletions(-) diff --git a/BBWYB.Server.Business/DataRepair/DataRepairBusiness.cs b/BBWYB.Server.Business/DataRepair/DataRepairBusiness.cs index b2a827f..205657e 100644 --- a/BBWYB.Server.Business/DataRepair/DataRepairBusiness.cs +++ b/BBWYB.Server.Business/DataRepair/DataRepairBusiness.cs @@ -16,10 +16,33 @@ namespace BBWYB.Server.Business public void RepairPurchaseExpressOrder() { - + var purchaseExpressOrderList = fsql.Select().Where(peo => !string.IsNullOrEmpty(peo.PurchaseOrderId)).ToList(); + var wayBillNos = purchaseExpressOrderList.Select(peo => peo.WaybillNo).ToList(); + var relationList = fsql.Select().Where(eori => wayBillNos.Contains(eori.WayBillNo)).ToList(); + + List insertExpressOrderRelationInfoList = new List(); + foreach (var peo in purchaseExpressOrderList) + { + var relation = relationList.FirstOrDefault(r => r.WayBillNo == peo.WaybillNo && r.PurchaseOrderId == peo.PurchaseOrderId); + if (relation != null) + continue; + insertExpressOrderRelationInfoList.Add(new ExpressOrderRelationInfo() + { + Id = idGenerator.NewLong(), + CreateTime = DateTime.Now, + OrderId = peo.OrderId, + PurchaseOrderId = peo.PurchaseOrderId, + ShopId = peo.ShopId, + WayBillNo = peo.WaybillNo + }); + } + fsql.Transaction(() => + { + fsql.Insert(insertExpressOrderRelationInfoList).ExecuteAffrows(); + }); } - public void SubscribeKD100(string waybillNo,string targetCompanyCode) + public void SubscribeKD100(string waybillNo, string targetCompanyCode) { kuaiDi100Manager.SubscribeKuaiDi100(waybillNo, targetCompanyCode, "http://bbwyb.qiyue666.com/api/purchaseorder/kuaidi100publish"); }