From 5b9da592f9bc117c88244f469418d5a5b29e4266 Mon Sep 17 00:00:00 2001
From: 海波 张 <2956280567@qq.com>
Date: 星期三, 16 七月 2025 17:31:52 +0800
Subject: [PATCH] mes取消修改

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

diff --git a/wms/TaskHelper.cs b/wms/TaskHelper.cs
index 77bc78b..dda45de 100644
--- a/wms/TaskHelper.cs
+++ b/wms/TaskHelper.cs
@@ -1,6 +1,9 @@
-锘縰sing HH.WCS.ZhongCeJinTan.device;
+锘縰sing HH.WCS.ZhongCeJinTan.api;
+using HH.WCS.ZhongCeJinTan.core;
+using HH.WCS.ZhongCeJinTan.device;
 using HH.WCS.ZhongCeJinTan.dispatch;
 using HH.WCS.ZhongCeJinTan.util;
+using ICSharpCode.SharpZipLib.Zip;
 using Newtonsoft.Json;
 using SqlSugar;
 using System;
@@ -12,6 +15,8 @@
 using System.Xml.Linq;
 using static HH.WCS.ZhongCeJinTan.util.Settings;
 using static HH.WCS.ZhongCeJinTan.wms.WcsModel;
+
+
 
 namespace HH.WCS.ZhongCeJinTan.wms
 {
@@ -111,7 +116,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 != "宸插畬鎴� && 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 != "宸插畬鎴�).OrderByDescending(b => b.T_CREATE).First();
             return task;
         }
         /// <summary>
@@ -122,7 +127,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 != "宸插畬鎴� && 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 != "宸插畬鎴�).OrderByDescending(b => b.T_CREATE).First();
             return task;
         }
 
@@ -219,6 +224,7 @@
                     CreateOneTask(operation);
                     break;
                 case 7:
+                    //鍑哄簱涓ゆ浠诲姟
                     CreateOutTowTask(operation);
                     break;
                 case 9:
@@ -303,12 +309,14 @@
                 {
                     LocationHelper.LockLoc(operation.S_START_LOC, "鍑哄簱閿�, 2);
                     LocationHelper.LockLoc(operation.S_END_LOC, "鍏ュ簱閿�, 1);
-                    LogHelper.Info($"浠诲姟{task1.S_OP_CODE}鍒涘缓鎴愬姛", "浠诲姟");
+                    LogHelper.Info($"浠诲姟{task1.S_CODE}鍒涘缓鎴愬姛", "浠诲姟");
                     var db = new SqlHelper<object>().GetInstance();
                     db.Updateable(operation).UpdateColumns(it => new { it.N_B_STATE, it.S_B_STATE }).ExecuteCommand();
+
+                    TaskHelper.opMesTask(task1, 0);
                 }
                 else {
-                    LogHelper.Info($"浠诲姟{task1.S_OP_CODE}鍒涘缓澶辫触", "浠诲姟");
+                    LogHelper.Info($"浠诲姟{task1.S_CODE}鍒涘缓澶辫触", "浠诲姟");
                 }
 
             }
@@ -412,12 +420,14 @@
 
                 if (CreateTask(task1) && CreateTask(task2))
                 {
-                    LocationHelper.LockLoc(operation.S_START_LOC, "鍑哄簱閿�, 2);
-                    LocationHelper.LockLoc(operation.S_END_LOC, "鍏ュ簱閿�, 1);
-                    LocationHelper.LockLoc(operation.CONNECTION, "鍏朵粬閿�, 3);
+                    //LocationHelper.LockLoc(operation.S_START_LOC, "鍑哄簱閿�, 2);
+                    //LocationHelper.LockLoc(operation.S_END_LOC, "鍏ュ簱閿�, 1);
+                    //LocationHelper.LockLoc(operation.CONNECTION, "鍏朵粬閿�, 3);
                     LogHelper.Info($"浠诲姟{task1.S_CODE},{task2.S_CODE}鍒涘缓鎴愬姛", "浠诲姟");
                     var db = new SqlHelper<object>().GetInstance();
                     db.Updateable(operation).UpdateColumns(it => new { it.N_B_STATE, it.S_B_STATE }).ExecuteCommand();
+                    LogHelper.Info($"鍥炴姤{task1.S_OP_CODE}", "鍥炴姤Mes浠诲姟");
+                    TaskHelper.opMesTask(task1, 0);
                 }
                 else
                 {
@@ -437,107 +447,117 @@
 
             var ConnectionLoc = LocationHelper.GetLocOne(operation.CONNECTION);
 
-
-            // 浠诲姟1
-            var task1 = new WMSTask()
+            var count = LocationHelper.GetConnectionTaskCount(operation.CONNECTION);
+            LogHelper.Info($"CreateOneTask 浣滀笟:{operation.S_CODE},鎺ラ┏浣�{operation.CONNECTION}锛屼换鍔℃暟閲忥細{count}", "浠诲姟");
+            if (count<=2)
             {
-                // 浣滀笟缂栫爜
-                S_OP_CODE = operation.S_CODE,
-                // 浠诲姟鍙�-                S_CODE = operation.S_CODE + "_1",
-                // 浠诲姟绫诲瀷
-                N_TYPE = operation.N_TYPE,
-                // 浠诲姟绫诲瀷
-                S_TYPE = operation.S_TYPE,
-                // 璧风偣璐т綅
-                S_START_LOC = operation.S_START_LOC,
-                // 璧风偣搴撳尯
-                S_START_AREA = operation.S_START_AREA,
-                // 缁堢偣璐т綅
-                S_END_LOC = operation.CONNECTION,
-                // 缁堢偣搴撳尯
-                S_END_AREA = ConnectionLoc.S_AREA_CODE,
-                // 璁惧绫诲瀷
-                N_SCHEDULE_TYPE = 2,
-                // 璁惧绫诲瀷
-                S_SCHEDULE_TYPE = "wcs",
-                // 瀹瑰櫒缂栫爜
-                S_CNTR_CODE = operation.S_CNTR_CODE,
-                //浠诲姟鐘舵�
-                S_B_STATE = "鏈墽琛�,
-                // 浼樺厛绾�-                N_PRIORITY = operation.N_PRIORITY,
-                //宸ヨ绫诲瀷
-                TOOLSTYPE = operation.TOOLSTYPE,
-                //璧风偣搴撳尯鍚嶇О
-                S_START_AREA_NAME = operation.S_START_AREA_NAME,
-                //缁堢偣搴撳尯鍚嶇О
-                S_END_AREA_NAME = operation.CONNECTION_AREA,
-            };
 
-            // 浠诲姟2
-            var task2 = new WMSTask()
-            {
-                // 浣滀笟缂栫爜
-                S_OP_CODE = operation.S_CODE,
-                // 浠诲姟鍙�-                S_CODE = operation.S_CODE + "_2",
-                // 浠诲姟绫诲瀷
-                N_TYPE = operation.N_TYPE,
-                // 浠诲姟绫诲瀷
-                S_TYPE = operation.S_TYPE,
-                // 璧风偣璐т綅
-                S_START_LOC = operation.CONNECTION,
-                // 璧风偣搴撳尯
-                S_START_AREA = ConnectionLoc.S_AREA_CODE,
-                // 缁堢偣璐т綅
-                S_END_LOC = operation.S_END_LOC,
-                // 缁堢偣搴撳尯
-                S_END_AREA = operation.S_END_AREA,
-                // 璁惧绫诲瀷
-                N_SCHEDULE_TYPE = 3,
-                // 璁惧绫诲瀷
-                S_SCHEDULE_TYPE = "agv",
-                // 瀹瑰櫒缂栫爜
-                S_CNTR_CODE = operation.S_CNTR_CODE,
-                //浠诲姟鐘舵�
-                S_B_STATE = "鏈墽琛�,
-                // 浼樺厛绾�-                N_PRIORITY = operation.N_PRIORITY,
-                //宸ヨ绫诲瀷
-                TOOLSTYPE = operation.TOOLSTYPE,
-                //璧风偣搴撳尯鍚嶇О
-                S_START_AREA_NAME = operation.CONNECTION_AREA,
-                //缁堢偣搴撳尯鍚嶇О
-                S_END_AREA_NAME = operation.S_END_AREA_NAME,
-            };
-
-            try
-            {
-                // 淇敼浣滀笟鐘舵�涓烘墽琛屼腑
-                operation.N_B_STATE = 1;
-                operation.S_B_STATE = "鎵ц";
-
-                if (CreateTask(task1) && CreateTask(task2))
+                // 浠诲姟1
+                var task1 = new WMSTask()
                 {
-                    LocationHelper.LockLoc(operation.S_START_LOC, "鍑哄簱閿�, 2);
-                    LocationHelper.LockLoc(operation.S_END_LOC, "鍏ュ簱閿�, 1);
-                    LocationHelper.LockLoc(operation.CONNECTION, "鍏ュ簱閿�, 1);
-                    LogHelper.Info($"浠诲姟{task1.S_CODE},{task2.S_CODE}鍒涘缓鎴愬姛", "浠诲姟");
-                    var db = new SqlHelper<object>().GetInstance();
-                    db.Updateable(operation).UpdateColumns(it => new { it.N_B_STATE, it.S_B_STATE }).ExecuteCommand();
-                }
-                else
-                {
-                    LogHelper.Info($"浠诲姟{task1.S_CODE},{task2.S_CODE}鍒涘缓澶辫触", "浠诲姟");
-                }
+                    // 浣滀笟缂栫爜
+                    S_OP_CODE = operation.S_CODE,
+                    // 浠诲姟鍙�+                    S_CODE = operation.S_CODE + "_1",
+                    // 浠诲姟绫诲瀷
+                    N_TYPE = operation.N_TYPE,
+                    // 浠诲姟绫诲瀷
+                    S_TYPE = operation.S_TYPE,
+                    // 璧风偣璐т綅
+                    S_START_LOC = operation.S_START_LOC,
+                    // 璧风偣搴撳尯
+                    S_START_AREA = operation.S_START_AREA,
+                    // 缁堢偣璐т綅
+                    S_END_LOC = operation.CONNECTION,
+                    // 缁堢偣搴撳尯
+                    S_END_AREA = ConnectionLoc.S_AREA_CODE,
+                    // 璁惧绫诲瀷
+                    N_SCHEDULE_TYPE = 2,
+                    // 璁惧绫诲瀷
+                    S_SCHEDULE_TYPE = "wcs",
+                    // 瀹瑰櫒缂栫爜
+                    S_CNTR_CODE = operation.S_CNTR_CODE,
+                    //浠诲姟鐘舵�
+                    S_B_STATE = "鏈墽琛�,
+                    // 浼樺厛绾�+                    N_PRIORITY = operation.N_PRIORITY,
+                    //宸ヨ绫诲瀷
+                    TOOLSTYPE = operation.TOOLSTYPE,
+                    //璧风偣搴撳尯鍚嶇О
+                    S_START_AREA_NAME = operation.S_START_AREA_NAME,
+                    //缁堢偣搴撳尯鍚嶇О
+                    S_END_AREA_NAME = operation.CONNECTION_AREA,
+                };
 
+                // 浠诲姟2
+                var task2 = new WMSTask()
+                {
+                    // 浣滀笟缂栫爜
+                    S_OP_CODE = operation.S_CODE,
+                    // 浠诲姟鍙�+                    S_CODE = operation.S_CODE + "_2",
+                    // 浠诲姟绫诲瀷
+                    N_TYPE = operation.N_TYPE,
+                    // 浠诲姟绫诲瀷
+                    S_TYPE = operation.S_TYPE,
+                    // 璧风偣璐т綅
+                    S_START_LOC = operation.CONNECTION,
+                    // 璧风偣搴撳尯
+                    S_START_AREA = ConnectionLoc.S_AREA_CODE,
+                    // 缁堢偣璐т綅
+                    S_END_LOC = operation.S_END_LOC,
+                    // 缁堢偣搴撳尯
+                    S_END_AREA = operation.S_END_AREA,
+                    // 璁惧绫诲瀷
+                    N_SCHEDULE_TYPE = 3,
+                    // 璁惧绫诲瀷
+                    S_SCHEDULE_TYPE = "agv",
+                    // 瀹瑰櫒缂栫爜
+                    S_CNTR_CODE = operation.S_CNTR_CODE,
+                    //浠诲姟鐘舵�
+                    S_B_STATE = "鏈墽琛�,
+                    // 浼樺厛绾�+                    N_PRIORITY = operation.N_PRIORITY,
+                    //宸ヨ绫诲瀷
+                    TOOLSTYPE = operation.TOOLSTYPE,
+                    //璧风偣搴撳尯鍚嶇О
+                    S_START_AREA_NAME = operation.CONNECTION_AREA,
+                    //缁堢偣搴撳尯鍚嶇О
+                    S_END_AREA_NAME = operation.S_END_AREA_NAME,
+                };
+
+                try
+                {
+                    // 淇敼浣滀笟鐘舵�涓烘墽琛屼腑
+                    operation.N_B_STATE = 1;
+                    operation.S_B_STATE = "鎵ц";
+
+                    if (CreateTask(task1) && CreateTask(task2))
+                    {
+                        //LocationHelper.LockLoc(operation.S_START_LOC, "鍑哄簱閿�, 2);
+                        //LocationHelper.LockLoc(operation.S_END_LOC, "鍏ュ簱閿�, 1);
+                        //LocationHelper.LockLoc(operation.CONNECTION, "鍏ュ簱閿�, 1);
+                        LogHelper.Info($"浠诲姟{task1.S_CODE},{task2.S_CODE}鍒涘缓鎴愬姛", "浠诲姟");
+                        var db = new SqlHelper<object>().GetInstance();
+                        db.Updateable(operation).UpdateColumns(it => new { it.N_B_STATE, it.S_B_STATE }).ExecuteCommand();
+
+                        TaskHelper.opMesTask(task2, 0);
+                    }
+                    else
+                    {
+                        LogHelper.Info($"浠诲姟{task1.S_CODE},{task2.S_CODE}鍒涘缓澶辫触", "浠诲姟");
+                    }
+
+                }
+                catch (Exception e)
+                {
+                    LogHelper.Info("CreateOneTask寮傚父淇℃伅" + e.Message, "浠诲姟");
+                    throw;
+                }
             }
-            catch (Exception e)
-            {
-                LogHelper.Info("CreateOneTask寮傚父淇℃伅" + e.Message, "浠诲姟");
-                throw;
-            }
+
+
+
         }
 
 
@@ -567,7 +587,95 @@
             };
             return db.Insertable(action).ExecuteCommand() > 0;
         }
-        internal static WmsTaskAction GetActionRecord(string taskNo,string action)
+
+        internal static bool opMesTask(WMSTask task, int state)
+        {
+
+            HttpHelper apiHelper = new HttpHelper();
+            string baseUrl = Settings.MesApiAddres;
+            try
+            {
+                var cntrItem = ContainerHelper.GetCntrItem(task.S_CNTR_CODE);
+                if (cntrItem == null)
+                {
+                    LogHelper.Info($"浠诲姟{task.S_CODE}娌℃煡鍒板鍣ㄧ墿鏂檣task.S_CNTR_CODE}", "鍥炴姤Mes浠诲姟");
+                    return false;
+                }
+
+                var work = TaskHelper.GetWmsWork(task.S_OP_CODE);
+
+                if (work == null) {
+                    LogHelper.Info($"浠诲姟{task.S_CODE}娌℃煡鍒颁綔涓歿task.S_OP_CODE}", "鍥炴姤Mes浠诲姟");
+                    return false;
+                }
+                var endArea = "";
+
+                if (LocationHelper.GetErroArea(task.S_END_AREA))
+                {
+                    if (task.S_TYPE.Contains("鍑哄簱"))
+                    {
+                        endArea = task.S_END_LOC;
+                    }
+                    else {
+                        endArea = task.S_END_AREA;
+                    }
+
+                    
+                }
+                else {
+                    if (task.S_TYPE.Contains("鍑哄簱"))
+                    {
+                        endArea = task.S_END_LOC;
+                    }
+                    else {
+                        endArea = work.S_END_AREA;
+                    }
+                }
+
+
+
+
+                var interact = new
+                {
+                    taskNo = task.S_OP_CODE,//浠诲姟鍙�+                    updater = "WMS",// 鎿嶄綔浜�濡俉MS/MES绛�+                    endStock = endArea,//缁堢偣
+                    taskStatus = state,//0锛氬垵濮嬬姸鎬侊紝1锛氳繘琛屼腑锛�锛氬畬鎴愶紝3锛氫换鍔″彇娑�+                    updateTime = DateTime.Now.ToString(),//鎿嶄綔鏃堕棿
+                    TurnCardNum  = cntrItem.TurnCardNum,//鍛ㄨ浆鍗″彿
+                    TOOLS_NO = task.S_CNTR_CODE//宸ヨ缂栧彿
+                    
+                };
+                LogHelper.Info("Mes鏇存柊浠诲姟鐘舵� 鍦板潃淇℃伅:" + baseUrl + "updateTask", "鍥炴姤Mes浠诲姟");
+                LogHelper.Info("Mes鏇存柊浠诲姟鐘舵� 鍙傛暟淇℃伅:" + JsonConvert.SerializeObject(interact), "鍥炴姤Mes浠诲姟");
+                var result = apiHelper.Post(baseUrl + "updateTask", JsonConvert.SerializeObject(interact));
+                LogHelper.Info("Mes鏇存柊浠诲姟鐘舵� 杩斿洖淇℃伅:" + JsonConvert.SerializeObject(result), "鍥炴姤Mes浠诲姟");
+                if (!string.IsNullOrEmpty(result))
+                {
+                    var res = JsonConvert.DeserializeObject<MesTaskReturn>(result);
+                    if (res.success && res.code == "0")
+                    {
+                        return true;
+                    }
+                    else
+                    {
+                        return false;
+                    }
+                }
+                else
+                {
+                    LogHelper.Info("Mes鏇存柊浠诲姟鐘舵� 杩斿洖淇℃伅涓虹┖", "鍥炴姤Mes浠诲姟");
+                    return false;
+                }
+            }
+            catch (Exception ex)
+            {
+                LogHelper.Info("Mes鏇存柊浠诲姟鐘舵�寮傚父"+ex.Message, "鍥炴姤Mes浠诲姟");
+                return false;
+            }
+
+        }
+            internal static WmsTaskAction GetActionRecord(string taskNo,string action)
         {
             var db = new SqlHelper<WmsTaskAction>().GetInstance();
 
@@ -722,16 +830,32 @@
             if (task.S_TYPE.Contains("鍑哄簱") && task.S_SCHEDULE_TYPE.Contains("wcs")) {
                 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_SCHEDULE_TYPE.Contains("agv"))
+            {
+
+                if (LocationHelper.GetErroArea(task.S_END_AREA))
+                {
+                    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();
+                }
+                else
+                {
+                    TaskHelper.opMesTask(task, 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();
+            }
         }
 
 
@@ -751,6 +875,14 @@
 
         internal static bool CreateTask(WMSTask wmsTask) {
             var db = new SqlHelper<WMSTask>().GetInstance();
+
+             var task = db.Queryable<WMSTask>().Where(a => a.S_CODE == wmsTask.S_CODE).First();
+
+            if (task!=null)
+            {
+                return false;
+            }
+
             return db.Insertable(wmsTask).ExecuteCommand() > 0;
 
         }
@@ -861,6 +993,29 @@
 
         }
 
+
+        /// <summary>
+        /// 鏍规嵁浠诲姟鐘舵�鍜岃捣鐐瑰拰绫诲瀷鏌ユ壘浠诲姟
+        /// </summary>
+        /// <param name="state"></param>
+        /// <returns></returns>
+        internal static WMSTask GetTaskByType(string start,string type,string state)
+        {
+            try
+            {
+                var db = new SqlHelper<object>().GetInstance();
+                return db.Queryable<WMSTask>().Where(a => a.S_B_STATE.Trim() == state && a.S_TYPE.Contains(type) && a.S_START_LOC.Contains(start)).First();
+            }
+            catch (Exception ex)
+            {
+                LogHelper.Error(ex.Message, ex);
+                return new WMSTask();
+            }
+
+        }
+
+
+
         /// <summary>
         /// 鏍规嵁浣滀笟缂栫爜鍜岃澶囩被鍨嬭幏鍙栧崟涓换鍔�         /// </summary>
@@ -952,7 +1107,68 @@
 
             var db = new SqlHelper<object>().GetInstance();
 
-            return db.Queryable<UnlimitedLoc>().ToList();
+            return db.Queryable<UnlimitedLoc>().Where(a=>a.Enable=="Y").ToList();
         }
+
+
+        /// <summary>
+        /// 鑾峰彇鍏ュ簱浼樺厛绾ц〃
+        /// </summary>
+        /// <returns></returns>
+        internal static List<InPri> GetInPri()
+        {
+
+            var db = new SqlHelper<object>().GetInstance();
+
+            return db.Queryable<InPri>().Where(a=>a.Enable=="Y") .ToList();
+        }
+        /// <summary>
+        /// 鑾峰彇鍑哄簱鎻愰珮浼樺厛绾ц〃
+        /// </summary>
+        /// <returns></returns>
+        internal static OutMinutePriority GetOutMinutePriority()
+        {
+
+            var db = new SqlHelper<object>().GetInstance();
+
+            return db.Queryable<OutMinutePriority>().Where(a => a.Enable == "Y").First();
+        }
+
+        
+
+
+        /// <summary>
+        /// 娣诲姞agv鍔ㄤ綔缂撳瓨
+        /// </summary>
+        /// <param name="agv"></param>
+        /// <returns></returns>
+        internal static bool CreateAgvActionState(AgvActionState agv)
+        {
+            try
+            {
+                var db = new SqlHelper<object>().GetInstance();
+                return db.Insertable<AgvActionState>(agv).ExecuteCommand() > 0;
+            }
+            catch (Exception ex)
+            {
+                Console.WriteLine(ex.Message);
+                throw;
+            }
+        }
+
+
+        /// <summary>
+        /// 鑾峰彇agv鍔ㄤ綔
+        /// </summary>
+        /// <returns></returns>
+        internal static List<AgvActionState> GetAgvActionState( string taskNo)
+        {
+
+            var db = new SqlHelper<object>().GetInstance();
+
+            return db.Queryable<AgvActionState>().Where(a => a.task_no==taskNo).ToList();
+        }
+
+
     }
 }

--
Gitblit v1.9.1