1

huanghongfeng

昨天 9b2a125b8e539859774176979fc4956c379f05cc

 ÏîÄ¿´úÂë/WCS/WIDESEAWCS_Server/WIDESEAWCS_Tasks/StackerCraneJob/CommonStackerCraneJob.cs

@@ -60,6 +60,7 @@
        {
            try
            {

                SpeStackerCrane speStackerCrane = (SpeStackerCrane)context.JobDetail.JobDataMap.Get("JobParams");
                if (speStackerCrane != null)
                {
@@ -89,7 +90,7 @@
                                        speStackerCrane.LastTaskType = task.TaskType;
                                        task.Dispatchertime = DateTime.Now;
                                        task.ExceptionMessage = "";
                                        _taskService.UpdateTask(task, TaskStatusEnum.SC_Executing);
                                        WebResponseContent webResponseContent = _taskService.UpdateTaskStatusToNext(task.TaskNum);
                                        //延时1s
                                        Thread.Sleep(1000);
                                    }
@@ -123,7 +124,7 @@
                }
            }
        }
        

        /// <summary>
        /// èŽ·å–任务
        /// </summary>
@@ -140,9 +141,14 @@
            }

            task = _taskService.QueryStackerCraneInTask(commonStackerCrane.DeviceCode);         //获取入库任务
            if(task != null)
            if (task != null)
            {
                return task;    //如果有任务则直接下发给堆垛机
                if(task.Roadway=="SC02") return task;    //如果有任务则直接下发给堆垛机
                if(task.Depth==1) return task;
                //2深位进行判断是否要移库

                Dt_Task dt_Task = _taskService.RequestWMSTaskMovelibrary(task);
                if (dt_Task != null) return dt_Task;
            }
            else
            {
@@ -152,11 +158,11 @@
                {
                    if (OutTaskStationIsOccupied(item) != null)
                    {
                        if(item.Roadway== "SC01")
                        if (item.Roadway == "SC01")
                        {
                            if (item.Depth == 1) return item;
                            //调取WMS接口进行判断是否需要进行移库
                            Dt_Task dt_Task= OutTaskMovelibrary(item);
                            Dt_Task dt_Task = OutTaskMovelibrary(item);
                            if (dt_Task != null) return dt_Task;

                        }
@@ -187,7 +193,7 @@
            string SourceAddress = string.Join("-", targetCodes); //组装浅库位地址
            Dt_Task? tasks = _taskService.QueryStationIsOccupiedOutTasks(task.Roadway, SourceAddress); //找浅库位是否有任务
            if (tasks != null) return tasks;
        //向wms申请判断浅库位是否有货，是否需要进行移库
            //向wms申请判断浅库位是否有货，是否需要进行移库
            Dt_Task? taskst = _taskService.RequestWMSTaskMovelibrary(task);
            if (taskst != null) return taskst;
            return null;
@@ -203,26 +209,27 @@
        /// <returns>如果未被占用，返回传入的任务信息，否则，返回null</returns>
        private Dt_Task? OutTaskStationIsOccupied([NotNull] Dt_Task task)
        {
            Dt_Router? router = _routerService.QueryNextRoutes(task.Roadway, task.NextAddress).FirstOrDefault();
            if (router != null)
            try
            {
                IDevice? device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == router.ChildPosiDeviceCode);
                IDevice? device = Storage.Devices.FirstOrDefault(x => x.DeviceCode == "CL01");
                if (device != null)
                {
                    CommonConveyorLine conveyorLine = (CommonConveyorLine)device;
                    if (conveyorLine.IsOccupied(router.ChildPosi))//出库站台未被占用
                    OtherDevice conveyorLine = (OtherDevice)device;
                    DeviceProDTO? deviceProDTO = conveyorLine.DeviceProDTOs.FirstOrDefault(x => x.DeviceChildCode == task.NextAddress && x.DeviceProParamName == "IsOccupied");    //根据堆垛机地址，地址名称找协议
                    if (deviceProDTO != null)
                    {
                        return task;
                        bool B_Event_Test = conveyorLine.Communicator.Read<bool>(deviceProDTO.DeviceProAddress);        //判断输送线是否允许放货信号
                        if (!B_Event_Test)
                        {
                            return task;
                        }
                    }
                }
                else
                {
                    _taskService.UpdateTaskExceptionMessage(task.TaskNum, $"未找到出库站台【{router.ChildPosiDeviceCode}】对应的通讯对象，无法判断出库站台是否被占用");
                }
            }
            else
            catch (Exception ex)
            {
                _taskService.UpdateTaskExceptionMessage(task.TaskNum, $"未找到站台【{task.NextAddress}】信息，无法校验站台");

                throw;
            }
            return null;
        }
@@ -241,10 +248,10 @@
            stackerCraneTaskCommand.TaskNum = task.TaskNum;
            stackerCraneTaskCommand.WorkType = 1;
            stackerCraneTaskCommand.TrayType = 1;
            if (task.TaskType==(int)TaskInboundTypeEnum.Inbound)//判断是否是入库任务
            if (task.TaskType == (int)TaskInboundTypeEnum.Inbound)//判断是否是入库任务
            {

                Dt_StationManger dt_StationManger=_stationMangerRepository.QueryFirst(x=>x.StationCode==task.SourceAddress);
                Dt_StationManger dt_StationManger = _stationMangerRepository.QueryFirst(x => x.StationCode == task.SourceAddress);


                string[] startCodes = dt_StationManger.StackerCraneStationCode.Split("-");