From cabc8e23b0b1eb4d256813e3941a4f214b32f4e4 Mon Sep 17 00:00:00 2001
From: Junjie <540245094@qq.com>
Date: 星期五, 01 八月 2025 17:20:23 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/core/task/TrafficApplyProcess.java | 15 +++++++++++++++
1 files changed, 15 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/zy/core/task/TrafficApplyProcess.java b/src/main/java/com/zy/core/task/TrafficApplyProcess.java
index 2935d3e..7b7e79d 100644
--- a/src/main/java/com/zy/core/task/TrafficApplyProcess.java
+++ b/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;
--
Gitblit v1.9.1