From 1319cb7072623dff12369a889af766db2d166def Mon Sep 17 00:00:00 2001
From: lss <2538410689@qq.com>
Date: 星期一, 28 七月 2025 17:58:47 +0800
Subject: [PATCH] 叠盘机优化

---
 HH.WCS.Mobox3/HH.WCS.Mobox3.JiaTong/wms/WCSHelper.cs |   55 ++++++++++++++++++++++++++++++++++++++++++-------------
 1 files changed, 42 insertions(+), 13 deletions(-)

diff --git a/HH.WCS.Mobox3/HH.WCS.Mobox3.JiaTong/wms/WCSHelper.cs b/HH.WCS.Mobox3/HH.WCS.Mobox3.JiaTong/wms/WCSHelper.cs
index aa6c5da..900a982 100644
--- a/HH.WCS.Mobox3/HH.WCS.Mobox3.JiaTong/wms/WCSHelper.cs
+++ b/HH.WCS.Mobox3/HH.WCS.Mobox3.JiaTong/wms/WCSHelper.cs
@@ -20,7 +20,9 @@
         {
             var res = false;
             var db = new SqlHelper<WCSTask>().GetInstance();
+           
             task.S_B_STATE = status;
+
             db.Updateable(task).UpdateColumns(it => new { it.S_B_STATE }).ExecuteCommand();
             return res;
         }
@@ -169,18 +171,23 @@
             }
             return res;
         }
+        public static object _add;
         internal static bool AddActionRecord(string no, int state, string forkliftNo, string extData)
         {
-            var db = new SqlHelper<TaskAction>().GetInstance();
-            var action = new TaskAction()
-            {
-                N_ACTION_CODE = state,
-                S_TASK_CODE = no,
-                S_EQ_CODE = forkliftNo,
-                S_EQ_TYPE = "agv",
-                S_DATA = extData
-            };
-            return db.Insertable(action).ExecuteCommand() > 0;
+           
+                var db = new SqlHelper<TaskAction>().GetInstance();
+
+                var action = new TaskAction()
+                {
+                    N_ACTION_CODE = state,
+                    S_TASK_CODE = no,
+                    S_EQ_CODE = forkliftNo,
+                    S_EQ_TYPE = "agv",
+                    S_DATA = extData
+                };
+                return db.Insertable(action).ExecuteCommand() > 0;
+            
+          
         }
         internal static bool CheckActionRecordExist(string no, int code)
         {
@@ -198,8 +205,23 @@
                     task.S_B_STATE = WCSTask.GetStateStr(task.N_B_STATE);
                     task.T_START_TIME = DateTime.Now;
                     task.S_WORKSHOP_NO = agvno;
-                    db.Updateable(task).UpdateColumns(it => new { it.N_B_STATE, it.S_B_STATE, it.T_START_TIME, it.S_WORKSHOP_NO }).ExecuteCommand();
+                    db.Updateable(task).UpdateColumns(it => new { it.N_B_STATE, it.S_B_STATE, it.S_WORKSHOP_NO }).ExecuteCommand();
                 }
+
+            }
+        }
+
+        internal static void UpdateAgvNo(WCSTask task, string agvno)
+        {
+            var db = new SqlHelper<WCSTask>().GetInstance();
+            if (task != null)
+            {
+
+     
+                task.T_START_TIME = DateTime.Now;
+                task.S_WORKSHOP_NO = agvno;
+                db.Updateable(task).UpdateColumns(it => new { it.T_START_TIME, it.S_WORKSHOP_NO }).ExecuteCommand();
+
 
             }
         }
@@ -232,9 +254,10 @@
             try
             {
                 bool res = false;
+                LogHelper.Info($"浠诲姟锛歿TN_Task.S_CODE}寮�鍒涘缓");
                 db.BeginTran();
                 res = db.Insertable(TN_Task).ExecuteCommand() > 0;
-                if (res) 
+                if (res)
                 {
                     var Startmodel = db.Queryable<Location>().Where(a => a.S_CODE.Trim() == TN_Task.S_START_LOC).First();
                     var Endmodel = db.Queryable<Location>().Where(a => a.S_CODE.Trim() == TN_Task.S_END_LOC).First();
@@ -243,6 +266,12 @@
                         Startmodel.N_LOCK_STATE = 2;
                         Startmodel.S_LOCK_STATE = Location.GetLockStateStr(2);
                         res = db.Updateable(Startmodel).UpdateColumns(it => new { it.N_LOCK_STATE, it.S_LOCK_STATE }).ExecuteCommand() > 0;
+                    }
+                    else
+                    {
+                        LogHelper.Info($"浠诲姟:{TN_Task.S_CODE}鐢熸垚澶辫触,璧风偣璐т綅涓嶅彲鐢�);
+                        db.RollbackTran();
+                        return false;
                     }
                     if (Endmodel != null && Endmodel.S_LOCK_STATE.Trim() == "鏃�)
                     {
@@ -266,7 +295,7 @@
                     LogHelper.Info($"浠诲姟:{TN_Task.S_CODE}鐢熸垚澶辫触");
                     db.RollbackTran();
                 }
-                return res;   
+                return res;
             }
             catch (Exception ex)
             {

--
Gitblit v1.9.1