From 4e3503ad797d70b4c48a9cd2a13fa41273d6e1ce Mon Sep 17 00:00:00 2001
From: cnf <3200815559@qq.com>
Date: 星期五, 13 六月 2025 10:32:16 +0800
Subject: [PATCH] RUKU

---
 MES.Service/service/WomcaaManager.cs |   34 +++++++++++++++++++++++++++-------
 1 files changed, 27 insertions(+), 7 deletions(-)

diff --git a/MES.Service/service/WomcaaManager.cs b/MES.Service/service/WomcaaManager.cs
index 121bb55..a697391 100644
--- a/MES.Service/service/WomcaaManager.cs
+++ b/MES.Service/service/WomcaaManager.cs
@@ -1,9 +1,7 @@
-锘縰sing Dm;
-using MES.Service.DB;
+锘縰sing MES.Service.DB;
 using MES.Service.Dto.webApi;
 using MES.Service.Modes;
 using SqlSugar;
-using System.Net.NetworkInformation;
 
 namespace MES.Service.service;
 
@@ -58,6 +56,7 @@
         }
         var orUpdate = base.Insert(mesWomcaa);
         var baOrUpdate = _womcabManager.InsertRange(mesWomcabs);
+        db.Ado.CommitTran();
         if (orUpdate && baOrUpdate) {
             //瀹氫箟杈撳叆鍙傛暟
             var inputParam1 = new SugarParameter("P_WORK_NO", mesWomcaa.Caa001);
@@ -72,11 +71,11 @@
             if (result == 1)
             {
                 //瀛樺偍杩囩▼澶辫触鍒欎簨鍔¤繘琛屽洖婊�
-                db.Ado.RollbackTran();
+                //db.Ado.RollbackTran();
                 throw new Exception(message);
             }
             // 鎻愪氦浜嬪姟
-            db.Ado.CommitTran();
+            //db.Ado.CommitTran();
             return true;
         }
         throw new NotImplementedException("鎻掑叆鎴栨洿鏂板け璐�");
@@ -92,8 +91,29 @@
         }
         var orUpdate = base.Insert(mesWomcaa);
         var baOrUpdate = _womcabManager.InsertRange(mesWomcabs);
-
-        if (orUpdate && baOrUpdate) return true;
+        db.Ado.CommitTran();
+        if (orUpdate && baOrUpdate)
+        {
+            //瀹氫箟杈撳叆鍙傛暟
+            var inputParam1 = new SugarParameter("P_WORK_NO", mesWomcaa.Caa001);
+            // 瀹氫箟杈撳嚭鍙傛暟
+            var outParam1 = new SugarParameter("c_Result", null, true);
+            var outParam2 = new SugarParameter("C_MSG", null, true);
+            // 浣跨敤 SqlSugar 鎵ц瀛樺偍杩囩▼
+            Db.Ado.ExecuteCommand("BEGIN PRC_UPDATE_DAA(:P_WORK_NO,:c_Result,:C_MSG); END;", inputParam1, outParam1, outParam2);
+            // 鑾峰彇杈撳嚭鍙傛暟鐨勫��
+            int result = int.Parse((string)outParam1.Value);
+            string message = outParam2.Value == DBNull.Value ? string.Empty : (string)outParam2.Value;
+            if (result == 1)
+            {
+                //瀛樺偍杩囩▼澶辫触鍒欎簨鍔¤繘琛屽洖婊�
+                //db.Ado.RollbackTran();
+                throw new Exception(message);
+            }
+            // 鎻愪氦浜嬪姟
+            //db.Ado.CommitTran();
+            return true;
+        }
         throw new NotImplementedException("鎻掑叆鎴栨洿鏂板け璐�");
     }
 

--
Gitblit v1.9.3