#

Junjie

8 天以前 cabc8e23b0b1eb4d256813e3941a4f214b32f4e4

 src/main/java/com/zy/core/task/TrafficApplyProcess.java

@@ -88,6 +88,21 @@
        }
    }

    @Scheduled(cron = "0/3 * * * * ? ")
    public void processCancel() {
        TrafficControlThread trafficControlThread = (TrafficControlThread) SlaveConnection.get(SlaveType.TrafficControl, 1);
        if (trafficControlThread == null) {
            return;
        }
        Set<String> keys = redisUtil.searchKeys(RedisKeyType.TRAFFIC_CONTROL_CANCEL_LIST.key);

        for (String key : keys) {
            TrafficControlDataModel param = (TrafficControlDataModel) redisUtil.get(key);
            redisUtil.del(key);
            boolean apply = trafficControlThread.cancelTrafficControl(param.getShuttleNo(), param.getTaskNo());
        }
    }

    class ApplyKey{
        @Getter
        String key;