| | |
| | | bus.setBusSts(BusStsType.PROGRESS.val()); |
| | | bus.setUpdateTime(now); |
| | | if (!busService.updateById(bus)) { |
| | | log.error("Bus [{}] 更新失败 !!!", bus.getUuid()); |
| | | log.error("Bus [{}] failed to Update !!!", bus.getUuid()); |
| | | } |
| | | return; |
| | | } |
| | |
| | | for (Task task : taskList) { |
| | | Agv agv = missionAssignService.execute(task, taskAllot, taskIds); |
| | | if (null == agv) { |
| | | log.warn("{}任务异常,无法检索空闲Agv...", task.getSeqNum()); |
| | | log.warn("Task[{}] has an issue, because it failed to checkout agv which is idle...", task.getSeqNum()); |
| | | continue; |
| | | } |
| | | |
| | |
| | | task.setIoTime(now); |
| | | task.setUpdateTime(now); |
| | | if (!taskService.updateById(task)) { |
| | | throw new BusinessException(task.getSeqNum() + "任务更新失败"); |
| | | throw new BusinessException("seqNum: " + task.getSeqNum() + " failed to update"); |
| | | } |
| | | |
| | | if (taskAllot.containsKey(agv.getUuid())) { |