| | |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | |
| | | import java.util.ArrayList; |
| | | import java.util.Comparator; |
| | | import java.util.Date; |
| | | import java.util.List; |
| | |
| | | |
| | | @Override |
| | | public void processNext(List<Segment> segmentList) { |
| | | Date now = new Date(); |
| | | |
| | | segmentList.stream().max(Comparator.comparingInt(Segment::getSerial)).ifPresent(segment -> { |
| | | Segment nextSegment = this.getNextStepOfInit(segment.getTravelId(), segment.getSerial()); |
| | |
| | | if (null != nextSegment) { |
| | | |
| | | nextSegment.setState(SegmentStateType.WAITING.toString()); |
| | | nextSegment.setUpdateTime(now); |
| | | nextSegment.setUpdateTime(new Date()); |
| | | if (!this.updateById(nextSegment)) { |
| | | log.error("Segment [{}] failed to update !!!", nextSegment.getGroupId() + " - " + nextSegment.getSerial()); |
| | | } |
| | |
| | | .eq(Segment::getTravelId, travelId) |
| | | .eq(Segment::getSerial, serial + 1) |
| | | .eq(Segment::getState, SegmentStateType.INIT.toString()) |
| | | ); |
| | | } |
| | | |
| | | @Override |
| | | public Segment getPreviousStepOfFinish(Long travelId, Integer serial, String memo) { |
| | | return this.getOne(new LambdaQueryWrapper<Segment>() |
| | | .eq(Segment::getTravelId, travelId) |
| | | .eq(Segment::getSerial, serial - 1) |
| | | // .eq(Segment::getState, SegmentStateType.FINISH.toString()) |
| | | .eq(Segment::getMemo, memo) |
| | | ); |
| | | } |
| | | |
| | |
| | | return this.baseMapper.getGroupNo(state.toString(), agvId, groupNo); |
| | | } |
| | | |
| | | @Override |
| | | public List<Segment> getRunningByEndCode(Long codeId) { |
| | | if (null == codeId) { |
| | | return new ArrayList<>(); |
| | | } |
| | | return this.list(new LambdaQueryWrapper<Segment>() |
| | | .eq(Segment::getEndNode, codeId) |
| | | .in(Segment::getState, SegmentStateType.WAITING.toString(), SegmentStateType.RUNNING.toString()) |
| | | ); |
| | | } |
| | | |
| | | } |