| | |
|---|
| | | |
|---|
| | | //执行堆垛机任务，按 lane 串行提交 |
|---|
| | | crnOperateUtils.submitCrnIoTasks(DISPATCH_INTERVAL_MS); |
|---|
| | | |
|---|
| | | //堆垛机任务执行完成，按 lane 串行提交 |
|---|
| | | crnOperateUtils.submitCrnIoExecuteFinishTasks(DISPATCH_INTERVAL_MS); |
|---|
| | | |
|---|
| | | // 检测入库任务是否已经到达目标站台 |
|---|
| | | stationOperateProcessUtils.submitInboundStationArrivalTasks(DISPATCH_INTERVAL_MS); |
|---|
| | | //执行输送站点入库任务，按 lane 串行提交 |
|---|
| | | stationOperateProcessUtils.submitStationInTasks(DISPATCH_INTERVAL_MS); |
|---|
| | | |
|---|
| | | //执行输送站点出库任务，按 lane 串行提交 |
|---|
| | | stationOperateProcessUtils.submitCrnStationOutTasks(DISPATCH_INTERVAL_MS); |
|---|
| | | // 检测出库任务是否已经到达目标站台 |
|---|
| | | stationOperateProcessUtils.submitStationOutExecuteFinishTasks(DISPATCH_INTERVAL_MS); |
|---|
| | | // 检测站台运行完成后的任务转完成 |
|---|
| | | stationOperateProcessUtils.submitCheckTaskToCompleteTasks(DISPATCH_INTERVAL_MS); |
|---|
| | | |
|---|
| | | //检测输送站点是否运行堵塞，按 lane 串行提交 |
|---|
| | | stationOperateProcessUtils.submitCheckStationRunBlockTasks(DISPATCH_INTERVAL_MS); |
|---|
| | | //检测输送站点任务停留超时后重新计算路径，按 lane 串行提交 |
|---|
| | | stationOperateProcessUtils.submitCheckStationIdleRecoverTasks(DISPATCH_INTERVAL_MS); |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | |
|---|
| | | 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)) { |
|---|
