#

Junjie

2025-08-02 2c1e3b7b10c0d4afbf09a9151e132f1ee85b9c6f

 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;