| | |
| | | .eq(Segment::getSerial, serial - 1) |
| | | .eq(Segment::getState, SegmentStateType.FINISH.toString()) |
| | | .orderByDesc(Segment::getId) |
| | | .last("limit 1") |
| | | ); |
| | | } |
| | | |
| | |
| | | } |
| | | |
| | | @Override |
| | | public Segment getCurrWaitingSeg(Long travelId, Long agvId) { |
| | | List<Segment> segments = this.list(new LambdaQueryWrapper<Segment>() |
| | | .eq(Segment::getTravelId, travelId) |
| | | .eq(Segment::getAgvId, agvId) |
| | | .eq(Segment::getState, SegmentStateType.WAITING.toString()) |
| | | .orderByDesc(Segment::getId) |
| | | ); |
| | | if (Cools.isEmpty(segments)) { |
| | | } |
| | | return segments.stream().findFirst().orElse(null); |
| | | } |
| | | |
| | | @Override |
| | | public Segment getCurrRunningSeg(Long agvId, Long codeId) { |
| | | List<Segment> segments = this.list(new LambdaQueryWrapper<Segment>() |
| | | .eq(Segment::getAgvId, agvId) |
| | |
| | | .eq(Segment::getEndNode, codeId) |
| | | .orderByDesc(Segment::getId) |
| | | ); |
| | | |
| | | if (Cools.isEmpty(segments)) { |
| | | |
| | | } |
| | | return segments.stream().findFirst().orElse(null); |
| | | } |
| | |
| | | return this.baseMapper.selectUsedBackpacks(agvId, travelId); |
| | | } |
| | | |
| | | @Override |
| | | @Override //todo |
| | | public Segment getRollerWaiting(Long agvId, Long codeId, TaskPosDto.PosType posType) { |
| | | List<Segment> segments = this.list(new LambdaQueryWrapper<Segment>() |
| | | .eq(Segment::getAgvId, agvId) |