| | |
| | | try { |
| | | Date now = new Date(); |
| | | |
| | | // deprecate jam |
| | | if (this.isExpiredJamByAvo(segment.getId())) { |
| | | mainService.settleSegmentList(Utils.singletonList(segment), null); |
| | | return; |
| | | } |
| | | |
| | | // temporary ----------------- |
| | | Integer algoExtensionTime = configService.getVal("algoExtensionTime", Integer.class); |
| | | if (null != algoExtensionTime && algoExtensionTime > 0) { |
| | |
| | | .eq(Jam::getCycleCode, endNode) |
| | | .eq(Jam::getState, JamStateType.RUNNING.toString()) |
| | | ) > 0) { |
| | | return; |
| | | } |
| | | |
| | | // deprecate jam |
| | | if (this.isExpiredJamByAvo(segment.getId())) { |
| | | mainService.settleSegmentList(Utils.singletonList(segment), null); |
| | | return; |
| | | } |
| | | |