|
@ -51,13 +51,13 @@ public class EosIncomingBackgroundWorker : AsyncPeriodicBackgroundWorkerBase |
|
|
//转换Ship
|
|
|
//转换Ship
|
|
|
await shipConverter.ConvertAsync(shipsFromExternalList).ConfigureAwait(false); |
|
|
await shipConverter.ConvertAsync(shipsFromExternalList).ConfigureAwait(false); |
|
|
|
|
|
|
|
|
//Logger.LogInformation($"读取 产品");
|
|
|
Logger.LogInformation($"读取 产品"); |
|
|
//var productHandleService = workerContext.ServiceProvider.GetRequiredService<ProductReader>();
|
|
|
var productHandleService = workerContext.ServiceProvider.GetRequiredService<ProductReader>(); |
|
|
//var productConverter = workerContext.ServiceProvider.GetRequiredService<ProductConverter>();
|
|
|
var productConverter = workerContext.ServiceProvider.GetRequiredService<ProductConverter>(); |
|
|
////读取并保持Product
|
|
|
//读取并保持Product
|
|
|
//var productsFromExternalList = await productHandleService.ReadAsync().ConfigureAwait(false);
|
|
|
var productsFromExternalList = await productHandleService.ReadAsync().ConfigureAwait(false); |
|
|
//// 转换Product
|
|
|
// 转换Product
|
|
|
//await productConverter.ConvertAsync(productsFromExternalList).ConfigureAwait(false);
|
|
|
await productConverter.ConvertAsync(productsFromExternalList).ConfigureAwait(false); |
|
|
|
|
|
|
|
|
Logger.LogInformation($"Completed: Handling {Incoming}"); |
|
|
Logger.LogInformation($"Completed: Handling {Incoming}"); |
|
|
} |
|
|
} |
|
|