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: