From f7befcab74dac75f8bf0af9c732375311ceb4b76 Mon Sep 17 00:00:00 2001 From: "mingliang.tang" <1448969505@qq.com> Date: Tue, 8 Aug 2023 23:14:41 +0800 Subject: [PATCH] =?UTF-8?q?MES=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../IncomingToWmsWorker.cs | 30 +++++++++---------- 1 file changed, 14 insertions(+), 16 deletions(-) diff --git a/be/DataExchange/src/Win_in.Sfs.Wms.DataExchange.Agent/IncomingToWmsWorker.cs b/be/DataExchange/src/Win_in.Sfs.Wms.DataExchange.Agent/IncomingToWmsWorker.cs index 2a2dcb714..347421104 100644 --- a/be/DataExchange/src/Win_in.Sfs.Wms.DataExchange.Agent/IncomingToWmsWorker.cs +++ b/be/DataExchange/src/Win_in.Sfs.Wms.DataExchange.Agent/IncomingToWmsWorker.cs @@ -66,8 +66,9 @@ public class IncomingToWmsWorker : AsyncPeriodicBackgroundWorkerBase foreach (var incomingToWms in incomingToWmsList) { try - { - await AddOrUpdateWmsAsync(workerContext, incomingToWms).ConfigureAwait(false); + { + await AddOrUpdateWmsAsync(workerContext, incomingToWms).ConfigureAwait(false); + } catch (Exception e) { @@ -168,8 +169,8 @@ public class IncomingToWmsWorker : AsyncPeriodicBackgroundWorkerBase private async Task SendProductReceipt(PeriodicBackgroundWorkerContext workerContext, IncomingToWms incomingToWms) { // 定义请求的 URL - string apiUrl = "http://dev.ccwin-in.com:60085/api/wms/store/product-receipt-note"; - string authUrl = "http://dev.ccwin-in.com:60083"; + string apiUrl = "http://10.164.113.31:60085/api/wms/store/product-receipt-note"; + var productReceiptJson = JsonSerializer.Deserialize(incomingToWms.DataContent); try { @@ -195,20 +196,17 @@ public class IncomingToWmsWorker : AsyncPeriodicBackgroundWorkerBase // 处理请求异常 // 可以记录日志或者抛出异常 Console.WriteLine(ex.Message); - incomingToWms.SetError(EnumExchangeDataErrorCode.Exception, ex.Message); + //incomingToWms.SetError(EnumExchangeDataErrorCode.Exception, ex.Message); } - finally - { - //Resolve dependencies - var incomingToWmsManager = workerContext.ServiceProvider.GetRequiredService(); - //Do the work - var incomingToWmsList = await incomingToWmsManager.GetToBeProcessedListAsync().ConfigureAwait(false); - //归档并删除 - await incomingToWmsManager.ArchiveAutoSaveAsync(incomingToWms).ConfigureAwait(false); + //finally + //{ + // //Resolve dependencies + // var incomingToWmsManager = workerContext.ServiceProvider.GetRequiredService(); + + // //归档并删除 + // await incomingToWmsManager.ArchiveAutoSaveAsync(incomingToWms).ConfigureAwait(false); - } - - // await incomingToWms.HandleProductReceiptsAsync(workerContext).ConfigureAwait(false); + //} } }