From 6513c35280f2283ff53b36bdc0c9d83aba475f8d Mon Sep 17 00:00:00 2001
From: Zhang-Hong-Lin <a3219986988@163.com>
Date: 星期五, 07 三月 2025 19:54:24 +0800
Subject: [PATCH] Merge branch 'master' of http://115.159.85.185:8098/r/ZhuZhouYouRuiKe/YangJiPingKu

---
 项目代码/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/OHT/OHTJob.cs |   57 ++++++++++++++++++++++++++++++++++++++++++++++++++-------
 1 files changed, 50 insertions(+), 7 deletions(-)

diff --git "a/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/OHT/OHTJob.cs" "b/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/OHT/OHTJob.cs"
index f71d2ff..a1027df 100644
--- "a/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/OHT/OHTJob.cs"
+++ "b/\351\241\271\347\233\256\344\273\243\347\240\201/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/OHT/OHTJob.cs"
@@ -37,7 +37,7 @@
         private readonly ITaskService _taskService;
         private readonly Idt_ErrormsginfoService _ErrormsginfoService;
         WebSocketServer _webSocketServer;
-        public OHTJob(ITaskService taskService, WebSocketServer webSocketServer,Idt_ErrormsginfoService errormsginfoService)
+        public OHTJob(ITaskService taskService, WebSocketServer webSocketServer, Idt_ErrormsginfoService errormsginfoService)
         {
             _taskService = taskService;//娉ㄥ叆
             _webSocketServer = webSocketServer;
@@ -71,11 +71,13 @@
                         {
                             throw new Exception(string.Format("澶╄溅鍙栬揣瀹屾垚浠诲姟鏈煡璇㈠埌浠诲姟鍙穥0}", oHTReadData.R_TaskNumber));
                         }
+                        //鍏ュ簱
                         if (nawtask.TaskType == (int)TaskInboundTypeEnum.Inbound)
                         {
-                            //濡傛灉浠诲姟鐨勭姸鎬佹槸澶╄溅鍏ュ簱鍙栬揣鎵ц涓�
+                            //濡傛灉浠诲姟鐨勭姸鎬佹槸鍚︽槸澶╄溅鍏ュ簱鍙栬揣鎵ц涓�
                             if (nawtask.TaskState == (int)TaskInStatusEnum.Line_InGrabExecuting)
                             {
+                                //淇敼鐘舵��
                                 WebResponseContent result = _taskService.UpdateTaskStatusToLine_Ingrab(nawtask);
                                 if (result.Status)
                                 {
@@ -83,16 +85,28 @@
                                 }
                             }
                         }
+                        //鍑哄簱
                         else if (nawtask.TaskType == (int)TaskOutboundTypeEnum.Outbound)
                         {
-                            //濡傛灉浠诲姟鐘舵�佹槸澶╄溅鍑哄簱鍙栬揣鎵ц涓�
+                            //濡傛灉浠诲姟鐘舵�佹槸鍚︽槸澶╄溅鍑哄簱鍙栬揣鎵ц涓�
                             if (nawtask.TaskState == (int)TaskOutStatusEnum.Line_OutGrabExecuting)
                             {
+                                //淇敼鐘舵��
                                 WebResponseContent result = _taskService.UpdateTaskStatusToLine_Outgrab(nawtask);
                                 if (result.Status)
                                 {
                                     device.SetValue(DeviceDBName.W_ConfirmSignal, 3);
                                 }
+                            }
+                        }
+                        //鐩存帴鍑哄簱
+                        else if (nawtask.TaskType == (int)TaskOutboundTypeEnum.OutInventory)
+                        {
+                            //淇敼鐘舵��
+                            WebResponseContent result = _taskService.UpdateTaskStatusToLine_Outgrab(nawtask);
+                            if (result.Status)
+                            {
+                                device.SetValue(DeviceDBName.W_ConfirmSignal, 3);
                             }
                         }
                         return Task.CompletedTask;
@@ -107,10 +121,20 @@
                         }
                         return Task.CompletedTask;
                     }
+                    else if (oHTReadData.R_RunState == (int)RunStateEnum.MoveCompleted && oHTReadData.R_TaskState == (int)TaskStateEnum.TaskComplete)
+                    {
+                        //澶╄溅绉诲姩瀹屾垚
+                        WebResponseContent result = _taskService.StackCraneTaskCompleted(oHTReadData.R_TaskNumber, oHTReadData.weight);
+                        if (result.Status)
+                        {
+                            device.SetValue(DeviceDBName.W_ConfirmSignal, 3);
+                        }
+                        return Task.CompletedTask;
+                    }
                     #endregion
 
                     #region 澶╄溅鍙戦�佷换鍔¢�昏緫
-                    if (oHTReadData.R_RunMode == (int)RunModeEnum.Automatic )
+                    if (oHTReadData.R_RunMode == (int)RunModeEnum.Automatic)
                     {
                         if (oHTReadData.R_RunState == (int)RunStateEnum.Standby)
                         {
@@ -151,7 +175,7 @@
                 }
                 catch (Exception ex)
                 {
-                    _ErrormsginfoService.UpdateErrorMsg(ex.Message,1);
+                    _ErrormsginfoService.UpdateErrorMsg(ex.Message, 1);
                 }
             }
             return Task.CompletedTask;
@@ -168,7 +192,7 @@
         {
             OHTTaskCommand oHtTaskCommand = new OHTTaskCommand();
 
-            if (task.TaskState==(int)TaskInStatusEnum.InNew || task.TaskState == (int)TaskOutStatusEnum.OutNew)
+            if (task.TaskState == (int)TaskInStatusEnum.InNew || task.TaskState == (int)TaskOutStatusEnum.OutNew)
             {
                 oHtTaskCommand.W_Task_Type = 2;
                 string[] SourceCodes = task.SourceAddress.Split("-");
@@ -177,7 +201,7 @@
                     oHtTaskCommand.W_Pick_Line = Convert.ToInt16(SourceCodes[0]);
                     oHtTaskCommand.W_Pick_Column = Convert.ToInt16(SourceCodes[1]);
                     oHtTaskCommand.W_Put_Line = 0;
-                    oHtTaskCommand.W_Put_Column = 0;
+                    oHtTaskCommand.W_Put_Column = 0; 
                 }
                 else
                 {
@@ -206,6 +230,25 @@
                 }
                 oHtTaskCommand.W_CheckValue = 3 + Convert.ToInt16(SourceCodes[0]) + Convert.ToInt16(SourceCodes[1]);
             }
+            else if(task.TaskState == (int)TaskMoveStatusEnum.OutNewMove )
+            {
+                oHtTaskCommand.W_Task_Type = 4;
+                string[] SourceCodes = task.TargetAddress.Split("-");
+                if (SourceCodes.Length == 3)
+                {
+                    oHtTaskCommand.W_Pick_Line = 0;
+                    oHtTaskCommand.W_Pick_Column = 0;
+                    oHtTaskCommand.W_Put_Line = Convert.ToInt16(SourceCodes[0]);
+                    oHtTaskCommand.W_Put_Column = Convert.ToInt16(SourceCodes[1]);
+                }
+                else
+                {
+                    //鏁版嵁閰嶇疆閿欒
+                    _taskService.UpdateTaskExceptionMessage(task.TaskNum, $"浠诲姟婧愬湴鍧�閰嶇疆閿欒锛�");
+                    return null;
+                }
+                oHtTaskCommand.W_CheckValue = 4 + Convert.ToInt16(SourceCodes[0]) + Convert.ToInt16(SourceCodes[1]);
+            }
             
             if (task.WMSId==1)
             {

--
Gitblit v1.9.3