| | |
| | | } |
| | | |
| | | @Override |
| | | public Task selectBySeqNum(String seqNum) { |
| | | return this.list(new LambdaQueryWrapper<Task>().eq(Task::getSeqNum, seqNum)).get(0); |
| | | } |
| | | |
| | | |
| | | @Override |
| | | public List<Task> selectBySts(TaskStsType taskStsType) { |
| | | LambdaQueryWrapper<Task> wrapper = new LambdaQueryWrapper<>(); |
| | | wrapper.eq(Task::getTaskSts, taskStsType.val()); |
| | |
| | | } |
| | | |
| | | @Override |
| | | @Transactional |
| | | public Boolean cancelCheckTaskSts(Long taskId, Long userId) { |
| | | Task task = this.getById(taskId); |
| | | if (null == task) { |
| | | return Boolean.FALSE; |
| | | } |
| | | if ( task.getTaskSts() >= TaskStsType.ASSIGN.val()){ |
| | | throw new BusinessException("任务已分配或执行,不能取消"); |
| | | } |
| | | |
| | | this.maintainLocSts(task, Boolean.FALSE); |
| | | |
| | | task.setTaskSts(TaskStsType.CANCEL.val()); |
| | | task.setUpdateTime(new Date()); |
| | | task.setUpdateBy(userId); |
| | | if (!this.updateById(task)) { |
| | | throw new CoolException(BaseRes.ERROR); |
| | | } |
| | | busService.checkoutComplete(task.getBusId()); |
| | | return Boolean.TRUE; |
| | | } |
| | | |
| | | @Override |
| | | public Lane checkoutOriginLane(Task task) { |
| | | Long codeId = null; |
| | | TaskTypeType typeType = TaskTypeType.get(task.getTaskTypeEl()); |