From 55e1fa803b11e647a9072502456340e859705c76 Mon Sep 17 00:00:00 2001
From: Zhang-Hong-Lin <a3219986988@163.com>
Date: 星期五, 07 三月 2025 10:20:20 +0800
Subject: [PATCH] 1

---
 项目代码/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/OHT/OHTJob.cs |   69 +++++++++++++++++++++++++++++-----
 1 files changed, 59 insertions(+), 10 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 6c11c06..e2590a8 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;
@@ -45,7 +45,6 @@
         }
         public Task Execute(IJobExecutionContext context)
         {
-           
             bool flag = context.JobDetail.JobDataMap.TryGetValue("JobParams", out object? value);
             if (flag && value != null)
             {
@@ -96,6 +95,14 @@
                                 }
                             }
                         }
+                        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;
                     }
                     else if (oHTReadData.R_RunState == (int)RunStateEnum.PutCompleted && oHTReadData.R_TaskState == (int)TaskStateEnum.TaskComplete)
@@ -108,10 +115,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 && oHTReadData.R_AlarmCode == (int)AlarmCodeEnum.Normal)
+                    if (oHTReadData.R_RunMode == (int)RunModeEnum.Automatic)
                     {
                         if (oHTReadData.R_RunState == (int)RunStateEnum.Standby)
                         {
@@ -121,6 +138,8 @@
                                 OHTTaskCommand? oHTTaskCommand = ConvertToOHTTaskCommand(task);
                                 if (oHTTaskCommand != null)
                                 {
+                                    //缁欏ぉ杞︿笅鍙戜换鍔′箣鍓嶅皢姝ゅ�煎啓0
+                                    device.SetValue(DeviceDBName.W_ConfirmSignal, 0);
                                     //todo锛氬啓鍏ヤ换鍔″懡浠�
                                     device.SetValue(DeviceDBName.W_Task_Type, oHTTaskCommand.W_Task_Type);
                                     device.SetValue(DeviceDBName.W_Pick_Line, oHTTaskCommand.W_Pick_Line);
@@ -150,7 +169,7 @@
                 }
                 catch (Exception ex)
                 {
-                    _ErrormsginfoService.UpdateErrorMsg(ex.Message,1);
+                    _ErrormsginfoService.UpdateErrorMsg(ex.Message, 1);
                 }
             }
             return Task.CompletedTask;
@@ -167,7 +186,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("-");
@@ -176,7 +195,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
                 {
@@ -184,7 +203,7 @@
                     _taskService.UpdateTaskExceptionMessage(task.TaskNum, $"浠诲姟婧愬湴鍧�閰嶇疆閿欒锛�");
                     return null;
                 }
-                oHtTaskCommand.W_CheckValue = task.TaskType + Convert.ToInt16(SourceCodes[0]) + Convert.ToInt16(SourceCodes[1]);
+                oHtTaskCommand.W_CheckValue = 2 + Convert.ToInt16(SourceCodes[0]) + Convert.ToInt16(SourceCodes[1]);
             }
             else if (task.TaskState == (int)TaskInStatusEnum.Line_Ingrab || task.TaskState == (int)TaskOutStatusEnum.SC_OutExecuting)
             {
@@ -203,7 +222,26 @@
                     _taskService.UpdateTaskExceptionMessage(task.TaskNum, $"浠诲姟婧愬湴鍧�閰嶇疆閿欒锛�");
                     return null;
                 }
-                oHtTaskCommand.W_CheckValue = task.TaskType + Convert.ToInt16(SourceCodes[0]) + Convert.ToInt16(SourceCodes[1]);
+                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)
@@ -224,8 +262,8 @@
                 oHtTaskCommand.W_Catch_2 = 1;
                 oHtTaskCommand.W_CheckValue += 2;
             }
-            oHtTaskCommand.W_TaskNumber = task.TaskNum;
-            oHtTaskCommand.W_CheckValue += task.TaskNum;
+            oHtTaskCommand.W_TaskNumber = task.TaskId;
+            oHtTaskCommand.W_CheckValue += task.TaskId;
             return oHtTaskCommand;
         }
 
@@ -249,6 +287,17 @@
                     InorOut = "In";
                 }
             }
+            else
+            {
+                if (workType.Equals("In"))
+                {
+                    InorOut = "Out";
+                }
+                else
+                {
+                    InorOut = "In";
+                }
+            }
             return task;
         }
     }

--
Gitblit v1.9.3