| | |
| | | stationProtocol.getTaskNo(), |
| | | currentTaskBufferCommandCount); |
| | | } |
| | | if (!stationDispatchRuntimeStateSupport.tryAcquireRunBlockDirectReassignLock( |
| | | if (stationDispatchRuntimeStateSupport.hasRunBlockDirectReassignLimit( |
| | | wrkMast.getWrkNo(), |
| | | stationProtocol.getStationId(), |
| | | RUN_BLOCK_DIRECT_REASSIGN_LIMIT_SECONDS)) { |
| | | stationProtocol.getStationId())) { |
| | | News.info("输送站点运行堵塞重分配已跳过,15分钟内不允许重复申请。站点号={},工作号={}", |
| | | stationProtocol.getStationId(), |
| | | wrkMast.getWrkNo()); |
| | |
| | | if (!wrkMastService.updateById(wrkMast)) { |
| | | return; |
| | | } |
| | | stationDispatchRuntimeStateSupport.recordRunBlockDirectReassignLimit( |
| | | wrkMast.getWrkNo(), |
| | | stationProtocol.getStationId(), |
| | | RUN_BLOCK_DIRECT_REASSIGN_LIMIT_SECONDS); |
| | | stationDispatchRuntimeStateSupport.signalSegmentReset(wrkMast.getWrkNo(), STATION_MOVE_RESET_WAIT_MS); |
| | | boolean offered = offerDevpCommandWithDedup(basDevp.getDevpNo(), command, "checkStationRunBlock_direct"); |
| | | if (!offered) { |