From f80938e8a03d9343672b4fb3179836b019f6b9d8 Mon Sep 17 00:00:00 2001
From: 海波 张 <2956280567@qq.com>
Date: 星期六, 28 六月 2025 21:38:46 +0800
Subject: [PATCH] 0628

---
 core/TaskCore.cs |   66 +++++++++++++++++++++++---------
 1 files changed, 47 insertions(+), 19 deletions(-)

diff --git a/core/TaskCore.cs b/core/TaskCore.cs
index c4fd023..19cbf6f 100644
--- a/core/TaskCore.cs
+++ b/core/TaskCore.cs
@@ -11,6 +11,7 @@
 using System.Reflection;
 using System.Threading.Tasks;
 using System.Web.Services.Description;
+using Top.Api;
 using static HH.WCS.ZhongCeJinTan.api.ApiModel;
 using static HH.WCS.ZhongCeJinTan.util.Settings;
 
@@ -19,7 +20,6 @@
     internal class TaskCore
     {
         public static void OperateTaskStatus(AgvTaskState model) {
-
             var wmsTask = TaskHelper.GetTask(model.task_no);
             var db = new SqlHelper<object>().GetInstance();
 
@@ -33,7 +33,7 @@
                         switch (model.state)
                         {
                             case 1:
-                                TaskHelper.Begin(wmsTask,model.forklift_no);
+                                TaskHelper.Begin(wmsTask,model.forklift_no.ToString());
                                 //鑳庨潰浜や簰
                                 TaskHelper.TmSafety(wmsTask);
                                 break;
@@ -62,12 +62,25 @@
                                 }                        
                             break;
                             case 2:
-                                TaskHelper.End(wmsTask); 
+                            //绌烘墭鍑烘垨鑰呮弧鎵樺嚭浠诲姟瀹屾垚鍒ゆ柇鏄惁瑕佹彁楂樺叆搴撲紭鍏堢骇
+
+                            LogHelper.Info($"浠诲姟{wmsTask.S_CODE}瀹屾垚锛屽垽鏂叆搴撲紭鍏堢骇", "鍏ュ簱浼樺厛绾�);
+                            TaskProcess.inPri(wmsTask);
+                            TaskHelper.End(wmsTask); 
                             break;
                             case 7:
-                                //agv鎵ц閫氱煡
-                                WcsTask.WcsCallback(wmsTask, model.state, model.forklift_no);
 
+                                var wcsTask1 = TaskHelper.GetTaskByWorkNo(wmsTask.S_OP_CODE, "wcs");
+                                if (wcsTask1!=null)
+                                {
+                                    //agv鎵ц閫氱煡 wcs鍙栨秷
+                                    WcsTask.WcsCallback(wmsTask, model.state, model.forklift_no.ToString());
+                                    if (!TaskHelper.CheckActionRecordExist(wcsTask1.S_CODE, "6"))
+                                    {
+                                        TaskHelper.Fail(wcsTask1);
+                                        TaskProcess.OperateStatus(wcsTask1, 7);
+                                    }
+                                }
 
                                 TaskHelper.Fail(wmsTask);
                                 TaskProcess.OperateStatus(wmsTask, 7);
@@ -77,32 +90,47 @@
                                     ContainerHelper.delCntr(wmsTask.S_CNTR_CODE);
                                     ContainerHelper.delCntrItem(wmsTask.S_CNTR_CODE);
                                 }
-                                    //鍑哄簱鍙栨秷鍒ゆ柇鎺ラ┏浣嶆槸鍚︽湁璐э紝鏈夎揣闇�瑙g粦
-                                    if (!WcsTask.WcsCvstate(wmsTask))
-                                    {
-                                        LogHelper.Info($"Wcs绔嬪簱鎺ラ┏浣嶆棤璐э紝瑙g粦璐т綅:{wmsTask.S_START_LOC}", "绔嬪簱");
-                                        TaskProcess.OperateStatus(wmsTask, 4);
-                                        ContainerHelper.delCntr(wmsTask.S_CNTR_CODE);
-                                        ContainerHelper.delCntrItem(wmsTask.S_CNTR_CODE);
-                                    } 
-                                break;
+
+                                //鍑哄簱鍙栨秷鍒ゆ柇鎺ラ┏浣嶆槸鍚︽湁璐э紝鏈夎揣闇�瑙g粦
+                                if (!WcsTask.WcsCvstate(wmsTask))
+                                {
+                                    LogHelper.Info($"Wcs绔嬪簱鎺ラ┏浣嶆棤璐э紝瑙g粦璐т綅:{wmsTask.S_START_LOC}", "绔嬪簱");
+                                    TaskProcess.OperateStatus(wmsTask, 4);
+                                    ContainerHelper.delCntr(wmsTask.S_CNTR_CODE);
+                                    ContainerHelper.delCntrItem(wmsTask.S_CNTR_CODE);
+                                }
+                            break;
 
                         }
-                         TaskHelper.AddActionRecord(wmsTask.S_CODE, model.state, model.forklift_no, model.ext_data);
-                        
+                         TaskHelper.AddActionRecord(wmsTask.S_CODE, model.state, model.forklift_no.ToString());          
                 }
                 else
                 {
                     //瀹夊叏璇锋眰绛�-                    TaskProcess.OperateReq(model.task_no, model.state, model.forklift_no, model.ext_data);
+                    TaskProcess.OperateReq(model.task_no, model.state, model.forklift_no.ToString());
                 }
             }
-        
         }
-      
 
+        public static void addAgvActionState(AgvTaskState model)
+        {
+            var agvAction = new AgvActionState();
+            agvAction.state = model.state;
+            agvAction.task_no = model.task_no;
+            agvAction.forklift_no = model.forklift_no.ToString();
 
+            if (TaskHelper.CreateAgvActionState(agvAction))
+            {
+                LogHelper.Info("娣诲姞agv鍔ㄤ綔缂撳瓨鎴愬姛淇℃伅" + JsonConvert.SerializeObject(agvAction), "agv鍔ㄤ綔缂撳瓨");
+            }
+            else {
+                LogHelper.Info("娣诲姞agv鍔ㄤ綔缂撳瓨澶辫触淇℃伅" + JsonConvert.SerializeObject(agvAction), "agv鍔ㄤ綔缂撳瓨");
+            }
+        }
+            
+            
 
+            
 
 
         /// <summary>

--
Gitblit v1.9.1