| | |
| | | } |
| | | |
| | | @Override |
| | | public List<Task> findRunningTasksByAgv(Long agvId) { |
| | | public List<Task> findTransportTasksByAgv(Long agvId) { |
| | | if (null == agvId) { |
| | | return new ArrayList<>(); |
| | | } |
| | |
| | | } |
| | | |
| | | @Override |
| | | public Task findLatestTask(Long agvId) { |
| | | public Task findLatestTask(Long agvId, TaskStsType taskSts) { |
| | | LambdaQueryWrapper<Task> wrapper = new LambdaQueryWrapper<Task>() |
| | | .orderByDesc(Task::getCreateTime) |
| | | .last("limit 0, 1"); |
| | | if (null != agvId) { |
| | | wrapper.eq(Task::getAgvId, agvId); |
| | | } |
| | | if (null != taskSts) { |
| | | wrapper.eq(Task::getTaskSts, taskSts.val()); |
| | | } |
| | | return this.list(wrapper).stream().findFirst().orElse(null); |
| | | } |
| | | |