duyongjia
2025-01-09 daf541c51a7687b338e17b1543266bacee4ff2d3
ÏîÄ¿´úÂë/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/StackerCraneJob/CommonStackerCraneJob.cs
@@ -44,7 +44,7 @@
        {
            CommonStackerCrane commonStackerCrane = (CommonStackerCrane)context.JobDetail.JobDataMap.Get("JobParams");
            try
            {
            {
                //CommonStackerCrane commonStackerCrane = (CommonStackerCrane)context.JobDetail.JobDataMap.Get("JobParams");
                if (commonStackerCrane != null)
                {
@@ -59,31 +59,51 @@
                        if (commonStackerCrane.StackerCraneWorkStatusValue == StackerCraneWorkStatus.Standby)
                        {
                            WriteDebug(nameof(CommonStackerCraneJob), $"堆垛机开始执行,获取任务号");
                            Dt_Task? task = GetTask(commonStackerCrane);
                            if (task != null)
                            {
                                WriteDebug(nameof(CommonStackerCraneJob), $"堆垛机开始执行,任务号:{task.TaskNum}");
                                StackerCraneTaskCommand? stackerCraneTaskCommand = ConvertToStackerCraneTaskCommand(task);
                                int isIn = commonStackerCrane.Communicator.Read<byte>("DB106.12.0");
                                if(task.TaskType == (int)TaskOutboundTypeEnum.Outbound&&isIn==1)//如果在入库中,不允计下发出库任务
                                if((task.TaskType == (int)TaskOutboundTypeEnum.Outbound|| task.TaskType == (int)TaskOutboundTypeEnum.OutInventory) &&isIn==1)//如果在入库中,不允计下发出库任务
                                {
                                  return Task.CompletedTask;
                                    WriteDebug(nameof(CommonStackerCraneJob), $"出库校验,在入库中,不允计下发出库类型任务,任务号:{task.TaskNum}");
                                    return Task.CompletedTask;
                                }
                                if (stackerCraneTaskCommand != null)
                                {
                                    bool sendFlag = commonStackerCrane.SendCommand(stackerCraneTaskCommand);
                                    if (sendFlag)
                                    {
                                        if (task.TaskType == (int)TaskInboundTypeEnum.Inbound|| task.TaskType == (int)TaskInboundTypeEnum.InInventory)
                                        if (task.TaskType == (int)TaskInboundTypeEnum.Inbound|| task.TaskType == (int)TaskInboundTypeEnum.InInventory||task.TaskType==(int)TaskInboundTypeEnum.InPick)
                                        {
                                            _taskService.UpdateTaskStatus(task.TaskId, (int)TaskInStatusEnum.SC_InExecuting);
                                            _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"堆垛机入库执行中");
                                            WriteDebug(nameof(CommonStackerCraneJob), $"WCS堆垛机入库执行中,开始回写WMS任务状态,任务号:{task.TaskNum}");
                                            var response = HttpHelpers.Post<WebResponseContent>(url.Replace("PDA", "Task") + "UpdateTaskStatus?taskNum=" + task.TaskNum, "", "更新任务状态");
                                            if(response.Status==true)
                                            {
                                                WriteDebug(nameof(CommonStackerCraneJob), $"WCS堆垛机入库执行中,回写WMS任务状态成功,任务号:{task.TaskNum}");
                                            }
                                            else
                                            {
                                                WriteDebug(nameof(CommonStackerCraneJob), $"WCS堆垛机入库执行中,回写WMS任务状态失败,任务号:{task.TaskNum},失败原因{response.Message}");
                                            }
                                        }
                                        else if (task.TaskType == (int)TaskOutboundTypeEnum.Outbound|| task.TaskType == (int)TaskOutboundTypeEnum.OutInventory)
                                        {
                                            _taskService.UpdateTaskStatus(task.TaskId, (int)TaskOutStatusEnum.SC_OutExecuting);
                                            _taskExecuteDetailService.AddTaskExecuteDetail(task.TaskId, $"堆垛机出库执行中");
                                            var response = HttpHelpers.Post<WebResponseContent>(url.Replace("PDA", "Task") + "UpdateTaskStatus?taskNum=" + task.TaskNum, "", "更新任务状态");
                                            if (response.Status == true)
                                            {
                                                WriteDebug(nameof(CommonStackerCraneJob), $"WCS堆垛机入库执行中,回写WMS任务状态成功,任务号:{task.TaskNum}");
                                            }
                                            else
                                            {
                                                WriteDebug(nameof(CommonStackerCraneJob), $"WCS堆垛机入库执行中,回写WMS任务状态失败,任务号:{task.TaskNum},失败原因{response.Message}");
                                            }
                                        }
                                    }
                                }
@@ -94,30 +114,39 @@
            }
            catch (Exception ex)
            {
                Console.WriteLine(nameof(CommonStackerCraneJob) + ":" + ex.ToString());
                WriteDebug(nameof(CommonStackerCraneJob), $"堆垛机执行异常,{ex.Message}");
            }
            if (commonStackerCrane != null)
            try
            {
                //读取大堆垛机任务号和任务完成确认状态(因为封装的事件经常不触发,所以加个直接读的逻辑,以免出现堆垛机一直接处于等待wcs确认)
                byte IsOver = commonStackerCrane.Communicator.Read<byte>("DB106.22");
                int tasknum = commonStackerCrane.Communicator.Read<int>("DB106.18");
                //WriteDebug(nameof(CommonStackerCraneJob), $"大堆垛机SC01任务号堆垛机任务号:{tasknum}状态:{IsOver}");
                if (IsOver == 6)
                if (commonStackerCrane != null)
                {
                    if (commonStackerCrane.GetValue<StackerCraneDBName, short>(StackerCraneDBName.WorkType) != 5)
                    //读取大堆垛机任务号和任务完成确认状态(因为封装的事件经常不触发,所以加个直接读的逻辑,以免出现堆垛机一直接处于等待wcs确认)
                    byte IsOver = commonStackerCrane.Communicator.Read<byte>("DB106.22");
                    int tasknum = commonStackerCrane.Communicator.Read<int>("DB106.18");
                    //WriteDebug(nameof(CommonStackerCraneJob), $"大堆垛机SC01任务号堆垛机任务号:{tasknum}状态:{IsOver}");
                    if (IsOver == 6)
                    {
                        _taskService.StackCraneTaskCompleted(tasknum);
                        Console.Out.WriteLine("TaskCompleted" + tasknum);
                        bool issuccess = commonStackerCrane.SetValue(StackerCraneDBName.WorkType, 5);
                        if (issuccess)
                        if (commonStackerCrane.GetValue<StackerCraneDBName, short>(StackerCraneDBName.WorkType) != 5)
                        {
                            WriteDebug(nameof(CommonStackerCraneJob), $"堆垛机任务号:{tasknum},堆垛机回写5成功");
                            _taskService.StackCraneTaskCompleted(tasknum);
                            WriteDebug(nameof(CommonStackerCraneJob), $"堆垛机WCS任务执行完成,任务号:{tasknum}");
                            Console.Out.WriteLine("TaskCompleted" + tasknum);
                            bool issuccess = commonStackerCrane.SetValue(StackerCraneDBName.WorkType, 5);
                            if (issuccess)
                            {
                                WriteDebug(nameof(CommonStackerCraneJob), $"堆垛机任务号:{tasknum},堆垛机回写5成功");
                            }
                        }
                    }
                }
            }
            catch(Exception ex)
            {
                WriteDebug(nameof(CommonStackerCraneJob), $"堆垛机任务完成异常,{ex.Message}");
            }
            return Task.CompletedTask;
        }