From d7bf5fce0a442c858d02675a2c71a8af49937ae2 Mon Sep 17 00:00:00 2001
From: hao <1836460075@qq.com>
Date: 星期三, 04 六月 2025 17:20:54 +0800
Subject: [PATCH] 分布式调拨

---
 StandardInterface/MES.Service/service/WomcaaManager.cs |   13 +++++++++----
 1 files changed, 9 insertions(+), 4 deletions(-)

diff --git a/StandardInterface/MES.Service/service/WomcaaManager.cs b/StandardInterface/MES.Service/service/WomcaaManager.cs
index c59443d..f8df994 100644
--- a/StandardInterface/MES.Service/service/WomcaaManager.cs
+++ b/StandardInterface/MES.Service/service/WomcaaManager.cs
@@ -60,7 +60,7 @@
             .IgnoreColumns(true).ExecuteCommand() > 0;
 
         //鎵归噺鎻掑叆蹇界暐绌哄瓧娈�
-        var baOrUpdate = db.Insertable(mesWomcabs).PageSize(1)
+        var baOrUpdate = db.Insertable(mesWomcabs).PageSize(10)
             .IgnoreColumnsNull()
             .ExecuteCommand() > 0;
 
@@ -76,6 +76,7 @@
         var insertOrUpdate = db
             .Deleteable<Womcab>().In(decimals)
             .ExecuteCommand() > 0;
+
 
         if (update && insertOrUpdate) return true;
         throw new NotImplementedException("鏇存柊澶辫触");
@@ -200,7 +201,7 @@
             Typea = dto.TypeA, ///     鍗曟嵁鐘舵��
             RkOrg = dto.RK_ORG,           //鍏ュ簱缁勭粐
             Rcn=dto.RCN,                 //鏃ヤ骇鑳�
-
+            Cglineid=dto.CG_LINE_ID, //閲囪喘璁㈠崟琛宨d
 
             //娌冨皵鏂板
             // WR_F_SCDD_SCTZD = dto.F_SCDD_SCTZD
@@ -265,8 +266,12 @@
 
             var entity = Db.Queryable<Womcab>()
                 .Where(s => s.Erpid == womcab.Erpid).Single();
-            if (entity != null) womcab.Id = entity.Id;
-
+            if (entity != null)
+            {
+                // 鍒犻櫎宸叉湁鐨� Erpid 鐩稿叧鐨� Womcab 鏁版嵁
+              //  Db.Deleteable<Womcab>().Where(s => s.Erpid == womcab.Erpid).ExecuteCommand();
+                womcab.Id = entity.Id;
+            }
             womcabList.Add(womcab);
         }
 

--
Gitblit v1.9.3