| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public List<Task> findTasksByLaneHash(String laneHash) { |
|---|
| | | public List<Task> findRunningTasksByLaneHash(String laneHash) { |
|---|
| | | if (Cools.isEmpty(laneHash)) { |
|---|
| | | return new ArrayList<>(); |
|---|
| | | } |
|---|
| | | return this.list(new LambdaQueryWrapper<Task>().eq(Task::getOriLaneHash, laneHash).or().eq(Task::getDestLaneHash, laneHash)); |
|---|
| | | return this.list(new LambdaQueryWrapper<Task>() |
|---|
| | | .in(Task::getTaskSts, TaskStsType.WAITING.val(), TaskStsType.ASSIGN.val(), TaskStsType.PROGRESS.val()) |
|---|
| | | .and(i -> { |
|---|
| | | i.eq(Task::getOriLaneHash, laneHash).or().eq(Task::getDestLaneHash, laneHash); |
|---|
| | | }) |
|---|
| | | |
|---|
| | | ); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Transactional |
|---|
