| | |
| | | } |
| | | |
| | | @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); |
| | | } |