From 650b5eb2ccafcb8277172df5631196879383c492 Mon Sep 17 00:00:00 2001 From: lvzb <35200379@qq.com> Date: Fri, 5 Jul 2024 14:23:57 +0800 Subject: [PATCH] =?UTF-8?q?Eos=E6=8E=A5=E5=8F=A3=E6=97=A5=E5=BF=97?= =?UTF-8?q?=E6=95=B4=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Incoming/EosIncomingBackgroundWorker.cs | 11 +++++++---- .../Outgoing/EosOutgoingBackgroundWorker.cs | 10 ++++++---- 2 files changed, 13 insertions(+), 8 deletions(-) diff --git a/be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.EosAgent/Incoming/EosIncomingBackgroundWorker.cs b/be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.EosAgent/Incoming/EosIncomingBackgroundWorker.cs index 3835ef772..81c8b0aad 100644 --- a/be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.EosAgent/Incoming/EosIncomingBackgroundWorker.cs +++ b/be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.EosAgent/Incoming/EosIncomingBackgroundWorker.cs @@ -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 _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(); @@ -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(); @@ -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}"); } } diff --git a/be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.EosAgent/Outgoing/EosOutgoingBackgroundWorker.cs b/be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.EosAgent/Outgoing/EosOutgoingBackgroundWorker.cs index 9ec0587a6..aa96e8145 100644 --- a/be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.EosAgent/Outgoing/EosOutgoingBackgroundWorker.cs +++ b/be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.EosAgent/Outgoing/EosOutgoingBackgroundWorker.cs @@ -10,7 +10,7 @@ namespace Win_in.Sfs.Wms.DataExchange.Fawtyg.EosAgent; public class EosOutgoingBackgroundWorker : AsyncPeriodicBackgroundWorkerBase { - private readonly string Outgoing = "EOS Outgoing"; + private readonly string Outgoing = "EOS 发送"; private readonly IOptions _options; @@ -28,10 +28,10 @@ public class EosOutgoingBackgroundWorker : AsyncPeriodicBackgroundWorkerBase [UnitOfWork] protected override async Task DoWorkAsync(PeriodicBackgroundWorkerContext workerContext) { - Logger.LogInformation($"Starting: Handling {Outgoing}"); + Logger.LogInformation($"开始: 处理 {Outgoing}"); if (!_options.Value.IncomingOptions.Active) { - Logger.LogInformation($"{Outgoing} is not active!"); + Logger.LogInformation($"{Outgoing} 已关闭没有执行!"); return; } @@ -40,14 +40,16 @@ public class EosOutgoingBackgroundWorker : AsyncPeriodicBackgroundWorkerBase var arriveNoteList = await arriveConvert.ConvertAsync().ConfigureAwait(false); var arriveWriter = workerContext.ServiceProvider.GetRequiredService(); await arriveWriter.WriteAsync(arriveNoteList).ConfigureAwait(false); + Logger.LogInformation($"处理采购上架单【{arriveNoteList.Count}】条数据"); Logger.LogInformation($"传出 采购退货单"); var returnConvert = workerContext.ServiceProvider.GetRequiredService(); var returnNoteList = await returnConvert.ConvertAsync().ConfigureAwait(false); var returnWriter = workerContext.ServiceProvider.GetRequiredService(); await returnWriter.WriteAsync(returnNoteList).ConfigureAwait(false); + Logger.LogInformation($"处理采购退货单【{returnNoteList.Count}】条数据"); - Logger.LogInformation($"Completed: Handling {Outgoing}"); + Logger.LogInformation($"提交: 处理 {Outgoing}"); } }