jinglun-cloud
17 小时以前 1ef1063281497f32fcfa4f14b07d99399c0bb765
src/main/java/com/zy/core/utils/station/StationDispatchRuntimeStateSupport.java
@@ -137,11 +137,19 @@
        return tryAcquireLock(RedisKeyType.STATION_OUT_ORDER_DISPATCH_LIMIT_.key + wrkNo + "_" + stationId, seconds);
    }
    public boolean tryAcquireRunBlockDirectReassignLock(Integer wrkNo, Integer stationId, int seconds) {
    public boolean hasRunBlockDirectReassignLimit(Integer wrkNo, Integer stationId) {
        if (wrkNo == null || wrkNo <= 0 || stationId == null) {
            return true;
            return false;
        }
        return tryAcquireLock(RedisKeyType.STATION_RUN_BLOCK_DIRECT_REASSIGN_LIMIT_.key + wrkNo + "_" + stationId, seconds);
        return redisUtil != null
                && redisUtil.get(RedisKeyType.STATION_RUN_BLOCK_DIRECT_REASSIGN_LIMIT_.key + wrkNo + "_" + stationId) != null;
    }
    public void recordRunBlockDirectReassignLimit(Integer wrkNo, Integer stationId, int seconds) {
        if (wrkNo == null || wrkNo <= 0 || stationId == null || redisUtil == null || seconds <= 0) {
            return;
        }
        redisUtil.set(RedisKeyType.STATION_RUN_BLOCK_DIRECT_REASSIGN_LIMIT_.key + wrkNo + "_" + stationId, "lock", seconds);
    }
    public void signalSegmentReset(Integer taskNo, long waitMs) {