Browse Source

插入快递单过滤重复

qianyi
shanji 2 years ago
parent
commit
7dccb37867
  1. 18
      BBWY.Server.Business/Sync/JD/JDServiceOrderSyncBusiness.cs
  2. 2
      BBWY.Server.Business/Sync/OrderSyncBusiness.cs

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

@ -410,7 +410,7 @@ huitongkuaidi 百世快递
.SetIf(isUpdateSubscribe, s => s.IsSubscribeKuaiDi100, true);
updateSerivceOrderList.Add(update);
if (isUpdateDelivery)
if (isUpdateDelivery && insertExpressOrderList.Count(e => e.WayBillNo == serviceOrder.WayBillNo) == 0)
{
insertExpressOrderList.Add(new ExpressOrder()
{
@ -426,6 +426,22 @@ huitongkuaidi 百世快递
}
}
if (insertExpressOrderList.Count() > 0)
{
var insertExpressOrderWayBillNoList = insertExpressOrderList.Select(e => e.WayBillNo).ToList();
var dbWayBillNoList = fsql.Select<ExpressOrder>().Where(e => insertExpressOrderWayBillNoList.Contains(e.WayBillNo)).ToList(e => e.WayBillNo);
if (dbWayBillNoList.Count() > 0)
{
for (var i = 0; i < insertExpressOrderList.Count(); i++)
{
if (dbWayBillNoList.Any(w => w == insertExpressOrderList[i].WayBillNo))
{
insertExpressOrderList.Remove(insertExpressOrderList[i]);
i--;
}
}
}
}
fsql.Transaction(() =>
{

2
BBWY.Server.Business/Sync/OrderSyncBusiness.cs

@ -735,7 +735,7 @@ namespace BBWY.Server.Business
var shopList = venderBusiness.GetShopList(platform: Enums.Platform.);
foreach (var shop in shopList)
{
Task.Factory.StartNew(() => SyncOrder(shop, string.Empty, isAuto: true), System.Threading.CancellationToken.None, TaskCreationOptions.LongRunning, taskSchedulerManager.SyncOrderTaskScheduler);
Task.Factory.StartNew(() => SyncOrder(shop, string.Empty, isAuto: true), CancellationToken.None, TaskCreationOptions.LongRunning, taskSchedulerManager.SyncOrderTaskScheduler);
}
}

Loading…
Cancel
Save