| | |
| | | |
| | | // deprecate jam |
| | | if (this.isJamBeDeprecatedByAvo(segment.getId())) { |
| | | if (this.skipCurrSegment(segment)) { |
| | | return; |
| | | } |
| | | mainService.settleSegmentList(Utils.singletonList(segment), null); |
| | | return; |
| | | } |
| | | |
| | | // execute ----------------------------------------------- |
| | |
| | | .eq(Jam::getAvoSeg, avoSeg) |
| | | .eq(Jam::getState, JamStateType.DEPRECATED.toString()) |
| | | ); |
| | | } |
| | | |
| | | private boolean skipCurrSegment(Segment currSegment) { |
| | | currSegment.setState(SegmentStateType.FINISH.toString()); |
| | | currSegment.setUpdateTime(new Date()); |
| | | if (!segmentService.updateById(currSegment)) { |
| | | log.error("Segment [{}] failed to update !!!", currSegment.getTravelId() + " - " + currSegment.getSerial()); |
| | | return false; |
| | | } |
| | | segmentService.processNext(Utils.singletonList(currSegment)); |
| | | return true; |
| | | } |
| | | |
| | | } |