|
|
@ -11,7 +11,7 @@ namespace Win_in.Sfs.Wms.DataExchange.Fawtyg.EosAgent; |
|
|
|
|
|
|
|
public class EosIncomingBackgroundWorker : AsyncPeriodicBackgroundWorkerBase |
|
|
|
{ |
|
|
|
private readonly string Incoming = "EOS Incoming"; |
|
|
|
private readonly string Incoming = "EOS 接收"; |
|
|
|
|
|
|
|
private readonly IOptions<EosOptions> _options; |
|
|
|
|
|
|
@ -28,10 +28,10 @@ public class EosIncomingBackgroundWorker : AsyncPeriodicBackgroundWorkerBase |
|
|
|
[UnitOfWork] |
|
|
|
protected override async Task DoWorkAsync(PeriodicBackgroundWorkerContext workerContext) |
|
|
|
{ |
|
|
|
Logger.LogInformation($"Starting: Handling {Incoming}"); |
|
|
|
Logger.LogInformation($"开始: 处理 {Incoming}"); |
|
|
|
if (!_options.Value.IncomingOptions.Active) |
|
|
|
{ |
|
|
|
Logger.LogInformation($"{Incoming} is not active!"); |
|
|
|
Logger.LogInformation($"{Incoming} 已关闭没有执行!"); |
|
|
|
return; |
|
|
|
} |
|
|
|
|
|
|
@ -42,6 +42,7 @@ public class EosIncomingBackgroundWorker : AsyncPeriodicBackgroundWorkerBase |
|
|
|
var plansFromExternalList = await planReader.ReadAsync().ConfigureAwait(false); |
|
|
|
//转换Plan
|
|
|
|
await planConverter.ConvertAsync(plansFromExternalList).ConfigureAwait(false); |
|
|
|
Logger.LogInformation($"处理采购订单【{plansFromExternalList.Count}】条数据"); |
|
|
|
|
|
|
|
Logger.LogInformation($"读取 发货单"); |
|
|
|
var shipHandleService = workerContext.ServiceProvider.GetRequiredService<ShipReader>(); |
|
|
@ -50,6 +51,7 @@ public class EosIncomingBackgroundWorker : AsyncPeriodicBackgroundWorkerBase |
|
|
|
var shipsFromExternalList = await shipHandleService.ReadAsync().ConfigureAwait(false); |
|
|
|
//转换Ship
|
|
|
|
await shipConverter.ConvertAsync(shipsFromExternalList).ConfigureAwait(false); |
|
|
|
Logger.LogInformation($"处理发货单【{shipsFromExternalList.Count}】条数据"); |
|
|
|
|
|
|
|
Logger.LogInformation($"读取 产品"); |
|
|
|
var productHandleService = workerContext.ServiceProvider.GetRequiredService<ProductReader>(); |
|
|
@ -58,8 +60,9 @@ public class EosIncomingBackgroundWorker : AsyncPeriodicBackgroundWorkerBase |
|
|
|
var productsFromExternalList = await productHandleService.ReadAsync().ConfigureAwait(false); |
|
|
|
// 转换Product
|
|
|
|
await productConverter.ConvertAsync(productsFromExternalList).ConfigureAwait(false); |
|
|
|
Logger.LogInformation($"处理产品【{productsFromExternalList.Count}】条数据"); |
|
|
|
|
|
|
|
Logger.LogInformation($"Completed: Handling {Incoming}"); |
|
|
|
Logger.LogInformation($"提交: 处理 {Incoming}"); |
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|