|
@ -43,6 +43,22 @@ namespace BBWYB.Server.Business.Sync |
|
|
Task.Factory.StartNew(() => Sync(shop, orderId, startTime, endTime, AdapterEnums.SortTimeField.Modify, AdapterEnums.SortType.Desc), CancellationToken.None, TaskCreationOptions.LongRunning, taskSchedulerManager.SyncOrderTaskScheduler); |
|
|
Task.Factory.StartNew(() => Sync(shop, orderId, startTime, endTime, AdapterEnums.SortTimeField.Modify, AdapterEnums.SortType.Desc), CancellationToken.None, TaskCreationOptions.LongRunning, taskSchedulerManager.SyncOrderTaskScheduler); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
public void ManualOrderSync(long shopId, DateTime startTime, DateTime endTime) |
|
|
|
|
|
{ |
|
|
|
|
|
var shop = venderBusiness.GetShopList(shopId, platform: Enums.Platform.拳探).FirstOrDefault(); |
|
|
|
|
|
if (shop == null) |
|
|
|
|
|
throw new BusinessException($"未找到店铺Id {shopId}"); |
|
|
|
|
|
while (true) |
|
|
|
|
|
{ |
|
|
|
|
|
var s = startTime; |
|
|
|
|
|
var e = s.AddHours(3); |
|
|
|
|
|
Sync(shop, string.Empty, s, e, AdapterEnums.SortTimeField.Modify, AdapterEnums.SortType.Desc); |
|
|
|
|
|
if (e >= endTime) |
|
|
|
|
|
break; |
|
|
|
|
|
startTime = startTime.AddHours(3); |
|
|
|
|
|
} |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
private void Sync(ShopResponse shop, |
|
|
private void Sync(ShopResponse shop, |
|
|
string orderId, |
|
|
string orderId, |
|
|
DateTime? startTime, |
|
|
DateTime? startTime, |
|
|