| | |
| | | List<Task> taskList = taskService.list(new LambdaQueryWrapper<Task>() |
| | | .in(Task::getUplinkSts, TaskUplinkStateType.PENDING.toString(), TaskUplinkStateType.FAILED.toString()) |
| | | .eq(Task::getTaskSts, TaskStsType.COMPLETE.val()) |
| | | .isNotNull(Task::getBusId).ne(Task::getPriority, 9999) |
| | | .isNotNull(Task::getBusId).ne(Task::getMemo, "TEST") |
| | | ); |
| | | if (Cools.isEmpty(taskList)) { return; } |
| | | for (Task task : taskList) { |
| | |
| | | |
| | | private void autoRun(AgvModel agvModel) { |
| | | |
| | | List<String> staPreNos = new ArrayList<>(); |
| | | String memo = "DEMO_STA_" + String.join("-", staPreNos); |
| | | String memo = "TEST" ; |
| | | String taskAssignModeArea = configService.getVal("TaskAssignModeArea", String.class); |
| | | if (Cools.isEmpty(taskAssignModeArea)) { |
| | | return; |
| | |
| | | for (Task task : taskList) { |
| | | task.setBusId(bus.getId()); |
| | | task.setTaskSts(TaskStsType.INIT.val()); |
| | | task.setMemo(memo); |
| | | if (!taskService.save(task)) { |
| | | throw new BusinessException("seqNum:" + task.getSeqNum() + " failed to save!"); |
| | | } |