From e13504017faae657acf2947dcabce5b4a1253b1a Mon Sep 17 00:00:00 2001
From: lvzb <35200379@qq.com>
Date: Mon, 1 Apr 2024 17:15:06 +0800
Subject: [PATCH] =?UTF-8?q?=E5=9B=9E=E5=86=B2=E5=92=8C=E7=BC=B4=E5=BA=93?=
 =?UTF-8?q?=E6=8E=A5=E5=8F=A3=E8=B0=83=E7=94=A8=E5=BD=A2=E5=BC=8F=E4=BF=AE?=
 =?UTF-8?q?=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../IncomingToWmsExtensions.cs                             | 6 ++++--
 .../IncomingToWmsWorker.cs                                 | 7 ++++---
 2 files changed, 8 insertions(+), 5 deletions(-)

diff --git a/be/DataExchange/src/Win_in.Sfs.Wms.DataExchange.Agent/IncomingToWmsExtensions.cs b/be/DataExchange/src/Win_in.Sfs.Wms.DataExchange.Agent/IncomingToWmsExtensions.cs
index f68a7724f..3ce74a40e 100644
--- a/be/DataExchange/src/Win_in.Sfs.Wms.DataExchange.Agent/IncomingToWmsExtensions.cs
+++ b/be/DataExchange/src/Win_in.Sfs.Wms.DataExchange.Agent/IncomingToWmsExtensions.cs
@@ -11,6 +11,7 @@ using Win_in.Sfs.Auth.Users.Inputs;
 using Win_in.Sfs.Basedata.Application.Contracts;
 using Win_in.Sfs.Label.Application.Contracts;
 using Win_in.Sfs.Wms.DataExchange.Domain;
+using Win_in.Sfs.Wms.DataExchange.Wms;
 using Win_in.Sfs.Wms.Inventory.Application.Contracts;
 using Win_in.Sfs.Wms.Store.Application.Contracts;
 
@@ -150,8 +151,9 @@ public static class IncomingToWmsExtensions
     {
         var productReceipt = JsonSerializer.Deserialize<ProductReceiptNoteEditInput>(incomingConverted.DataContent);
         var productReceiptAppService = workerContext.ServiceProvider.GetRequiredService<IProductReceiptNoteAppService>();
-        
-        await productReceiptAppService.CreateAsync(productReceipt).ConfigureAwait(false);
+        List<ProductReceiptNoteEditInput> list = new List<ProductReceiptNoteEditInput>();
+        list.Add(productReceipt);
+        await productReceiptAppService.CreateManyAsync(list).ConfigureAwait(false);
     }
 
     public static async Task HandleMaterialRequestsAsync(this IncomingToWms incomingConverted, PeriodicBackgroundWorkerContext workerContext)
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 b9e81463a..f64b30ff2 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
@@ -157,7 +157,8 @@ public class IncomingToWmsWorker : AsyncPeriodicBackgroundWorkerBase
                 await incomingToWms.HandleAsnsAsync(workerContext).ConfigureAwait(false);
                 break;
             case EnumIncomingDataType.ProductReceipt:
-                await SendProductReceipt(workerContext, incomingToWms).ConfigureAwait(false);
+                //  await SendProductReceipt(workerContext, incomingToWms).ConfigureAwait(false);
+                await incomingToWms.HandleProductReceiptsAsync(workerContext).ConfigureAwait(false);
                 break;
             case EnumIncomingDataType.MaterialRequest:
                 await incomingToWms.HandleMaterialRequestsAsync(workerContext).ConfigureAwait(false);
@@ -172,8 +173,8 @@ public class IncomingToWmsWorker : AsyncPeriodicBackgroundWorkerBase
                 await incomingToWms.HandleInventoryLabelsAsync(workerContext).ConfigureAwait(false);
                 break;
             case EnumIncomingDataType.BackFlush:
-                 // await incomingToWms.HandleBackFlushsAsync(workerContext).ConfigureAwait(false);
-                await SendBackFlush(workerContext, incomingToWms).ConfigureAwait(false);
+                  await incomingToWms.HandleBackFlushsAsync(workerContext).ConfigureAwait(false);
+               // await SendBackFlush(workerContext, incomingToWms).ConfigureAwait(false);
                 break;
             case EnumIncomingDataType.None:
             default: