| | |
| | | |
| | | //堆垛机任务执行完成,按 lane 串行提交 |
| | | crnOperateUtils.submitCrnIoExecuteFinishTasks(DISPATCH_INTERVAL_MS); |
| | | |
| | | // 检测入库任务是否已经到达目标站台 |
| | | stationOperateProcessUtils.submitInboundStationArrivalTasks(DISPATCH_INTERVAL_MS); |
| | | //执行输送站点入库任务,按 lane 串行提交 |
| | |
| | | continue; |
| | | } |
| | | MessageQueue.offer(SlaveType.Devp, basDevp.getDevpNo(), new Task(2, command)); |
| | | News.taskInfo(stationProtocol.getTaskNo(), "{}扫码异常,已退回至{}", backStation.getStationId()); |
| | | News.taskInfo(stationProtocol.getTaskNo(), "{}异常,已退回至{}", backStation.getStationId()); |
| | | redisUtil.set(RedisKeyType.GENERATE_STATION_BACK_LIMIT.key + stationProtocol.getTaskNo(), 10); |
| | | continue; |
| | | } |
| | | |
| | | if (!canSubmitGenerateStoreTask(basDevp, stationThread, stationObjModel, stationProtocol)) { |