duyongjia
2024-12-03 14aaca9a2e1da2849d602487a52094ee26bbe30a
´úÂë¹ÜÀí/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/StackerCraneJob/CommonStackerCraneJob.cs
@@ -53,15 +53,15 @@
        public Task Execute(IJobExecutionContext context)
        {
            //WriteDebug("大堆垛机运行日志", "开始时间" + DateTime.Now);
            Console.WriteLine("当前线程数"+ThreadPool.ThreadCount);
             WriteDebug("线程统计日志", "线程数" + ThreadPool.ThreadCount);
             //CommonStackerCrane commonStackerCrane = (CommonStackerCrane)context.JobDetail.JobDataMap.Get("JobParams");
             CommonStackerCrane commonStackerCrane = Storage.Devices.FirstOrDefault(x => x.DeviceCode == "SC01") as CommonStackerCrane;
            try
            {  
                if (commonStackerCrane != null)
                {
                   WriteDebug("大堆垛机运行日志", $"大堆垛机任务执行中...");
                   //WriteDebug("大堆垛机运行日志", $"大堆垛机任务执行中...");
                    //if (!commonStackerCrane.IsEventSubscribed)
                    //{
                    //    commonStackerCrane.StackerCraneTaskCompletedEventHandler += CommonStackerCrane_StackerCraneTaskCompletedEventHandler;//订阅任务完成事件
@@ -69,7 +69,7 @@
                    if (commonStackerCrane.StackerCraneAutoStatusValue == StackerCraneAutoStatus.Automatic && commonStackerCrane.StackerCraneStatusValue == StackerCraneStatus.Normal)
                    {
                        commonStackerCrane.CheckStackerCraneTaskCompleted();//防止任务完成事件监测超时,再手动触发一次
                       // commonStackerCrane.CheckStackerCraneTaskCompleted();//防止任务完成事件监测超时,再手动触发一次
                        
                        if (commonStackerCrane.StackerCraneWorkStatusValue == StackerCraneWorkStatus.Standby)
                        {
@@ -77,7 +77,7 @@
                            if (task != null)
                            {
                                
                                WriteDebug("大堆垛机运行日志", $"大堆垛机任务号{task.TaskNum}");
                                WriteDebug(nameof(CommonStackerCraneJob), $"大堆垛机任务号{task.TaskNum}");
                                StackerCraneTaskCommand? stackerCraneTaskCommand = ConvertToStackerCraneTaskCommand(task);
                                if (stackerCraneTaskCommand != null)
                                {
@@ -128,9 +128,7 @@
            }
            //Task.Run(delegate
            //{
            try
            {
                if (commonStackerCrane != null)
@@ -138,7 +136,7 @@
                    //读取大堆垛机任务号和任务完成确认状态(因为封装的事件经常不触发,所以加个直接读的逻辑,以免出现堆垛机一直接处于等待wcs确认)
                    byte IsOver = commonStackerCrane.Communicator.Read<byte>("DB106.22");
                    int tasknum = commonStackerCrane.Communicator.Read<int>("DB106.18");
                    //WriteDebug(nameof(CommonStackerCraneJob), $"读取大堆垛机SC01任务完成信号值:{IsOver} ä»»åŠ¡å·ï¼š{tasknum}");
                    WriteDebug(nameof(CommonStackerCraneJob), $"大堆垛机SC01任务号堆垛机任务号:{tasknum}状态:{IsOver}");
                    if (IsOver == 6)
                    {
                        if (commonStackerCrane.GetValue<StackerCraneDBName, short>(StackerCraneDBName.WorkType) != 5)
@@ -146,17 +144,38 @@
                            _taskService.StackCraneTaskCompleted(tasknum);
                            Console.Out.WriteLine("TaskCompleted" + tasknum);
                            bool issuccess = commonStackerCrane.SetValue(StackerCraneDBName.WorkType, 5);
                            if (issuccess)
                            if(issuccess)
                            {
                                WriteDebug(nameof(CommonStackerCraneJob), $"大堆垛机SC01任务号写入任务完成确认值5成功{tasknum}");
                                WriteDebug(nameof(CommonStackerCraneJob), $"大堆垛机SC01任务号堆垛机任务号:{tasknum},回写5成功");
                                //查询当前任务号,是不是出库(正常库位-->暂存位)
                                Dt_Task tasktemp = _taskService.QueryStackerCraneTaskByRelotion(tasknum);
                                if (tasktemp != null&&!string.IsNullOrEmpty(tasktemp.Remark.Trim()))
                                {
                                    //根据任务目标地址确定写入PLC位置 Depth
                                    Dt_LocationInfo location = _locationInfoRepository.QueryFirst(x => x.LocationCode == tasktemp.TargetAddress);
                                    if (commonStackerCrane != null && location != null)
                                    {
                                        bool issuccess2 = commonStackerCrane.Communicator.Write<short>("DB28." + location.Depth + ".0", 9);
                                        if (issuccess2)
                                        {
                                            ServiceLogger.WriteDebug("TaskService", $"原料出库后写入标识成功!");
                                        }
                                        else
                                        {
                                            ServiceLogger.WriteDebug("TaskService", $"原料出库后写入标识失败!");
                                        }
                                    }
                                }
                            }
                            else
                            {
                                WriteDebug(nameof(CommonStackerCraneJob), $"大堆垛机SC01任务号写入任务完成确认值5失败{tasknum}");
                                WriteDebug(nameof(CommonStackerCraneJob), $"大堆垛机SC01任务号堆垛机任务号:{tasknum},回写5失败");
                            }
                        }
                    }
                    //提升机交互
                    Dt_Task? task1001 = _taskService.QueryStackerCraneTaskByAGVRequest("SC01");
@@ -176,18 +195,6 @@
                        {
                            MESSendCMD sendcmd = new MESSendCMD { cmd = 2001, task_id = task1001.TaskNum, status = 6 };
                            MESResponse res = ApiInvoke.SendTaskCMD(sendcmd);
                            if (res != null && res.code != 0)
                            {
                                WriteDebug(nameof(CommonStackerCraneJob), $"允计AGV进入提升机,回传WMS失败!任务号{task1001.TaskNum}");
                            }
                            else
                            {
                                WriteDebug(nameof(CommonStackerCraneJob), $"允计AGV进入提升机,回传WMS成功!任务号{task1001.TaskNum}");
                            }
                        }
                        else
                        {
                            WriteDebug(nameof(CommonStackerCraneJob), $"未读取到提升机允计进入信号,暂不允计AGV进入提升机,任务号{task1001.TaskNum}");
                        }
                    }
                    Dt_Task? task3001 = _taskService.QueryStackerCraneTaskByAGVPutFinish("SC01");
@@ -208,10 +215,7 @@
                            {
                                commonStackerCrane.Communicator.Write<short>("DB1.0.0", 1);
                            }
                            else
                            {
                                WriteDebug(nameof(CommonStackerCraneJob), $"未写入提升信号,可能是已写入或者提升机未处理就绪状态,任务号:{task3001.TaskNum}");
                            }
                            //读取提升机信号,确定是否提升完成
                            IsFinish = commonStackerCrane.Communicator.Read<short>("DB2.2.0");
@@ -228,10 +232,7 @@
                            {
                                commonStackerCrane.Communicator.Write<short>("DB1.6.0", 1);
                            }
                            else
                            {
                                WriteDebug(nameof(CommonStackerCraneJob), $"未写入提升信号,可能是信号已写入或者提升机未处理就绪状态,任务号:{task3001.TaskNum}");
                            }
                            //读取提升机信号,确定是否提升完成
                            IsFinish = commonStackerCrane.Communicator.Read<short>("DB2.10.0");
                        }
@@ -247,10 +248,7 @@
                                WriteDebug(nameof(CommonStackerCraneJob), $"提升机提升完成,回传WMS失败!任务号{task3001.TaskNum}");
                            }
                        }
                        else
                        {
                            WriteDebug(nameof(CommonStackerCraneJob), $"提升机提升中...,任务号:{task3001.TaskNum}");
                        }
                    }
                    //小堆垛机出库完成任务
@@ -334,10 +332,8 @@
            }
            catch (Exception ex)
            {
                WriteError(nameof(CommonStackerCraneJob), "查询或写入PLC状态失败!", ex);
                WriteError(nameof(CommonStackerCraneJob), "执行异常!", ex);
            }
           // WriteDebug("大堆垛机运行日志", "结束时间" + DateTime.Now);
            //});
            return Task.CompletedTask;
        }