缴库接口修改

be/DataExchange/src/Win_in.Sfs.Wms.DataExchange.Agent/AgentModule.cs

@@ -49,15 +49,15 @@ public class AgentModule : AbpModule
         PreConfigure<AbpHttpClientBuilderOptions>(options =>
         {
             //Polly 重试3次
-            options.ProxyClientBuildActions.Add((remoteServiceName, clientBuilder) =>
-            {
-                clientBuilder.AddTransientHttpErrorPolicy(policyBuilder =>
-                    policyBuilder.WaitAndRetryAsync(
-                        3,
-                        i => TimeSpan.FromSeconds(Math.Pow(2, i))
-                    )
-                );
-            });
+            //options.ProxyClientBuildActions.Add((remoteServiceName, clientBuilder) =>
+            //{
+            //    clientBuilder.AddTransientHttpErrorPolicy(policyBuilder =>
+            //        policyBuilder.WaitAndRetryAsync(
+            //            3,
+            //            i => TimeSpan.FromSeconds(Math.Pow(2, i))
+            //        )
+            //    );
+            //});
 
             //默认添加Authorization Header: Bearer Token
             options.ProxyClientActions.Add((a, s, h) =>

be/DataExchange/src/Win_in.Sfs.Wms.DataExchange.Agent/IncomingToWmsWorker.cs

@@ -62,7 +62,7 @@ public class IncomingToWmsWorker : AsyncPeriodicBackgroundWorkerBase
     }
 
     private async Task HandleIncomingDataAsync(PeriodicBackgroundWorkerContext workerContext)
-   {
+    {
         //Resolve dependencies
         var incomingToWmsManager = workerContext.ServiceProvider.GetRequiredService<IIncomingToWmsManager>();
         //Do the work
@@ -71,9 +71,9 @@ public class IncomingToWmsWorker : AsyncPeriodicBackgroundWorkerBase
         foreach (var incomingToWms in incomingToWmsList)
         {
             try
-            {              
-                    await AddOrUpdateWmsAsync(workerContext, incomingToWms).ConfigureAwait(false);               
-              
+            {
+                await AddOrUpdateWmsAsync(workerContext, incomingToWms).ConfigureAwait(false);
+
             }
             catch (AbpValidationException ex)
             {
@@ -172,23 +172,23 @@ public class IncomingToWmsWorker : AsyncPeriodicBackgroundWorkerBase
                 await incomingToWms.HandleInventoryLabelsAsync(workerContext).ConfigureAwait(false);
                 break;
             case EnumIncomingDataType.BackFlush:
-                 // await incomingToWms.HandleBackFlushsAsync(workerContext).ConfigureAwait(false);
+                // await incomingToWms.HandleBackFlushsAsync(workerContext).ConfigureAwait(false);
                 await SendBackFlush(workerContext, incomingToWms).ConfigureAwait(false);
                 break;
             case EnumIncomingDataType.None:
             default:
                 throw new ArgumentOutOfRangeException();
         }
-       if( incomingToWms.Status != EnumExchangeDataStatus.Error)
+        if (incomingToWms.Status != EnumExchangeDataStatus.Error)
         {
             incomingToWms.SetSuccess();
-        } 
+        }
     }
     private async Task SendBackFlush(PeriodicBackgroundWorkerContext workerContext, IncomingToWms incomingToWms)
     { // 定义请求的 URL
       //  string apiUrl = "http://10.164.113.31:60085/api/wms/store/product-receipt-note";
 
-        string apiUrl = _options.Value.IncomingOptions.apiUrl+ "api/wms/store/backFlush-note/create-many";
+        string apiUrl = _options.Value.IncomingOptions.apiUrl + "api/wms/store/backFlush-note/create-many";
 
         if (!string.IsNullOrEmpty(_options.Value.IncomingOptions.apiUrl))
         {
@@ -237,6 +237,8 @@ public class IncomingToWmsWorker : AsyncPeriodicBackgroundWorkerBase
         if (!string.IsNullOrEmpty(_options.Value.IncomingOptions.apiUrl))
         {
             var productReceiptJson = JsonSerializer.Deserialize<ProductReceiptNoteEditInput>(incomingToWms.DataContent);
+            var memos = productReceiptJson.Details.Select(r => r.Remark).ToList();
+            string memostr = String.Join(", ", memos);
             productReceiptJson.Worker = "Mes";
             try
             {
@@ -256,6 +258,7 @@ public class IncomingToWmsWorker : AsyncPeriodicBackgroundWorkerBase
 
                 // 读取响应内容并返回
                 string responseBody = await response.Content.ReadAsStringAsync().ConfigureAwait(false);
+                Logger.LogInformation("标签" + memostr);
             }
             catch (HttpRequestException ex)
             {
@@ -274,10 +277,10 @@ public class IncomingToWmsWorker : AsyncPeriodicBackgroundWorkerBase
         //{
         //    //Resolve dependencies
         //    var incomingToWmsManager = workerContext.ServiceProvider.GetRequiredService<IIncomingToWmsManager>();
-                   
+
         //    //归档并删除
         //    await incomingToWmsManager.ArchiveAutoSaveAsync(incomingToWms).ConfigureAwait(false);
-             
+
         //}    
 
     }

be/DataExchange/src/Win_in.Sfs.Wms.DataExchange.Agent/appsettings.json

@@ -42,14 +42,14 @@
     "IncomingOptions": {
       "Active": true,
       "PeriodSeconds": 10,
-      "RetryTimes": 3,
+      "RetryTimes": 1,
       "BatchSize": 100,
       "apiUrl": "http://10.164.113.31:60085/"
     },
     "OutgoingOptions": {
       "Active": false,
       "PeriodSeconds": 10,
-      "RetryTimes": 3,
+      "RetryTimes": 1,
       "BatchSize": 100,
       "BaseUrl": "https://localhost:7034/test",
       "Username": "username",