From baf741a2c65777b70d96b6c5d60204170dd92626 Mon Sep 17 00:00:00 2001
From: 海波 张 <2956280567@qq.com>
Date: 星期二, 03 六月 2025 17:31:05 +0800
Subject: [PATCH] 出库修改

---
 wms/TaskHelper.cs |  116 +++++++++++++++++++++++++++++++++++++++++++++++++++------
 1 files changed, 103 insertions(+), 13 deletions(-)

diff --git a/wms/TaskHelper.cs b/wms/TaskHelper.cs
index 5dddfea..77bc78b 100644
--- a/wms/TaskHelper.cs
+++ b/wms/TaskHelper.cs
@@ -58,6 +58,13 @@
         }
 
 
+        internal static WmsWork GetWmsWork(string no) {
+            var db = new SqlHelper<WmsWork>().GetInstance();
+            return db.Queryable<WmsWork>().Where(it => it.S_CODE == no).First();
+        }
+      
+
+
         internal static WMSTask GetTaskByCntrCode(string cntrCode)
         {
             var db = new SqlHelper<WMSTask>().GetInstance();
@@ -104,7 +111,7 @@
         internal static WMSTask GetTaskByStartLoc(string loc)
         {
             var db = new SqlHelper<WMSTask>().GetInstance();
-            var task = db.Queryable<WMSTask>().Where(a => a.S_START_LOC == loc && a.S_B_STATE != "瀹屾垚" && a.S_B_STATE != "鍙栨秷" && a.S_B_STATE != "澶辫触" && a.S_B_STATE != "宸插畬鎴�).OrderByDescending(b => b.T_CREATE).First();
+            var task = db.Queryable<WMSTask>().Where(a => a.S_START_LOC == loc && a.S_B_STATE != "瀹屾垚" && a.S_B_STATE != "鍙栨秷" && a.S_B_STATE != "澶辫触" && a.S_B_STATE != "宸插畬鎴� && a.S_B_STATE != "鏈墽琛�).OrderByDescending(b => b.T_CREATE).First();
             return task;
         }
         /// <summary>
@@ -115,7 +122,7 @@
         internal static WMSTask GetTaskByEndLoc(string loc)
         {
             var db = new SqlHelper<WMSTask>().GetInstance();
-            var task = db.Queryable<WMSTask>().Where(a => a.S_END_LOC == loc &&  a.S_B_STATE != "瀹屾垚" && a.S_B_STATE != "鍙栨秷" && a.S_B_STATE != "澶辫触" && a.S_B_STATE != "宸插畬鎴�).OrderByDescending(b => b.T_CREATE).First();
+            var task = db.Queryable<WMSTask>().Where(a => a.S_END_LOC == loc &&  a.S_B_STATE != "瀹屾垚" && a.S_B_STATE != "鍙栨秷" && a.S_B_STATE != "澶辫触" && a.S_B_STATE != "宸插畬鎴� && a.S_B_STATE != "鏈墽琛�).OrderByDescending(b => b.T_CREATE).First();
             return task;
         }
 
@@ -243,6 +250,8 @@
         {
             var tasks = new List<Task>();
 
+            
+
             // 浠诲姟1
             var task1 = new WMSTask()
             {
@@ -278,6 +287,10 @@
                 N_PRIORITY = operation.N_PRIORITY,
                 //宸ヨ绫诲瀷
                 TOOLSTYPE = operation.TOOLSTYPE,
+
+               
+
+
             };
 
             try
@@ -546,6 +559,7 @@
             var db = new SqlHelper<WmsTaskAction>().GetInstance();
             var action = new WmsTaskAction() {
                 S_ACTION = state.ToString(),
+                N_ACTION_CODE = state,
                 S_TASK_CODE = no,
                 S_EQ_CODE = forkliftNo,
                 S_EQ_TYPE = "agv",
@@ -590,6 +604,7 @@
             var action = new WmsTaskAction()
             {
                 S_ACTION = state.ToString(),
+                N_ACTION_CODE = int.Parse(state),
                 S_TASK_CODE = no,
                 S_EQ_CODE = forkliftNo,
                 S_EQ_TYPE = "wcs",
@@ -708,15 +723,15 @@
                 LocationHelper.LockLoc(task.S_END_LOC, "鍑哄簱閿�, 2);
             }
                 
-            if (task.S_TYPE.Contains("鍑哄簱")&&task.S_SCHEDULE_TYPE.Contains("agv") )
-            {
-                var location = db.Queryable<Location>().Where(a => a.S_CODE == task.S_END_LOC).First();
-                location.N_CURRENT_NUM = 0;
-                db.Updateable(location).UpdateColumns(it => new { it.N_CURRENT_NUM}).ExecuteCommand();
-                db.Deleteable<Container>().Where(it => it.S_CODE == task.S_CNTR_CODE).ExecuteCommand();
-                db.Deleteable<LocCntrRel>().Where(it => it.S_CNTR_CODE == task.S_CNTR_CODE).ExecuteCommand();
-                db.Deleteable<CntrItemRel>().Where(it => it.S_CNTR_CODE == task.S_CNTR_CODE).ExecuteCommand();
-            }
+            //if (task.S_TYPE.Contains("鍑哄簱")&&task.S_SCHEDULE_TYPE.Contains("agv") )
+            //{
+            //    var location = db.Queryable<Location>().Where(a => a.S_CODE == task.S_END_LOC).First();
+            //    location.N_CURRENT_NUM = 0;
+            //    db.Updateable(location).UpdateColumns(it => new { it.N_CURRENT_NUM}).ExecuteCommand();
+            //    db.Deleteable<Container>().Where(it => it.S_CODE == task.S_CNTR_CODE).ExecuteCommand();
+            //    db.Deleteable<LocCntrRel>().Where(it => it.S_CNTR_CODE == task.S_CNTR_CODE).ExecuteCommand();
+            //    db.Deleteable<CntrItemRel>().Where(it => it.S_CNTR_CODE == task.S_CNTR_CODE).ExecuteCommand();
+            //}
         }
 
 
@@ -846,6 +861,56 @@
 
         }
 
+        /// <summary>
+        /// 鏍规嵁浣滀笟缂栫爜鍜岃澶囩被鍨嬭幏鍙栧崟涓换鍔�+        /// </summary>
+        /// <param name="state"></param>
+        /// <returns></returns>
+        internal static WMSTask GetTaskByWork(string eq, string opCode)
+        {
+            try
+            {
+                var db = new SqlHelper<object>().GetInstance();
+                return db.Queryable<WMSTask>().Where(a =>  a.S_SCHEDULE_TYPE.Contains(eq) && a.S_OP_CODE.Contains(opCode)).First();
+            }
+            catch (Exception ex)
+            {
+                LogHelper.Error(ex.Message, ex);
+                return new WMSTask();
+            }
+
+        }
+
+        /// <summary>
+        /// 杩斿洖褰撳墠鎺ラ┏浣嶆墽琛屼腑浠诲姟鏁伴噺
+        /// </summary>
+        internal static int GetConnectionTask(string Connection)
+        {
+            var db = new SqlHelper<object>().GetInstance();
+
+
+            var ConnectionList = 0;
+            ConnectionList = db.Queryable<WMSTask>().Where(a => a.S_END_LOC.Contains(Connection) && a.S_TYPE.Contains("鍑哄簱") && a.S_B_STATE != "瀹屾垚" && a.S_B_STATE != "鍙栨秷" && a.S_B_STATE != "鏈墽琛�).ToList().Count();
+
+            return ConnectionList;
+        }
+
+
+        //internal static bool CreateAgvState(AgvState agvState)
+        //{
+        //    try
+        //    {
+        //        var db = new SqlHelper<object>().GetInstance();
+
+        //        return db.Insertable<AgvState>(agvState).ExecuteCommand() > 0;
+        //    }
+        //    catch (Exception ex)
+        //    {
+        //        LogHelper.Info($"娣诲姞Agv鍔ㄤ綔缂撳瓨寮傚父" + ex.Message, "NDC");
+        //        throw;
+        //    }
+        //}
+
 
         internal static bool CreateMesKtTask(MesKtTask cntr)
         {
@@ -857,12 +922,37 @@
             }
             catch (Exception ex)
             {
-                Console.WriteLine(ex.Message);
                 LogHelper.Info($"娣诲姞Mes绌烘墭缂撳瓨寮傚父" + ex.Message, "Mes浠诲姟涓嬪彂");
                 throw;
             }
         }
 
-       
+        internal static MesKtTask GetMesKtTask(string end)
+        {
+          
+                var db = new SqlHelper<object>().GetInstance();
+
+                return db.Queryable<MesKtTask>().Where(a => a.Location_To==end && a.Status=="N").First();
+        }
+
+        internal static bool ChangeMesKtTask(MesKtTask kt)
+        {
+
+            var db = new SqlHelper<object>().GetInstance();
+            kt.Status = "Y";
+            return db.Updateable(kt).UpdateColumns(it => new {
+                it.Status
+            }).ExecuteCommand()>0;
+
+            
+        }
+
+        internal static List<UnlimitedLoc> GetMesKtLoc()
+        {
+
+            var db = new SqlHelper<object>().GetInstance();
+
+            return db.Queryable<UnlimitedLoc>().ToList();
+        }
     }
 }

--
Gitblit v1.9.1