| | |
| | | return false; |
| | | } |
| | | |
| | | if (isOutboundStationTaskLimitReached()) { |
| | | if (isConveyorStationTaskLimitReached()) { |
| | | return false; |
| | | } |
| | | |
| | |
| | | return false; |
| | | } |
| | | |
| | | private boolean isOutboundStationTaskLimitReached() { |
| | | int stationMaxTaskCount = getSystemConfigInt("stationMaxTaskCountLimit", 30); |
| | | if (stationMaxTaskCount <= 0) { |
| | | private boolean isConveyorStationTaskLimitReached() { |
| | | int conveyorStationTaskLimit = getSystemConfigInt("conveyorStationTaskLimit", 30); |
| | | if (conveyorStationTaskLimit <= 0) { |
| | | return false; |
| | | } |
| | | |
| | | int currentStationTaskCount = stationOperateProcessUtils.getCurrentStationTaskCount(); |
| | | if (currentStationTaskCount >= stationMaxTaskCount) { |
| | | News.warn("输送站点任务数量达到上限,已停止任务下发。当前任务数={},上限={}", currentStationTaskCount, stationMaxTaskCount); |
| | | if (currentStationTaskCount >= conveyorStationTaskLimit) { |
| | | News.warn("输送站点任务数量达到上限,已停止任务下发。当前任务数={},上限={}", |
| | | currentStationTaskCount, |
| | | conveyorStationTaskLimit); |
| | | return true; |
| | | } |
| | | return false; |