From 2c1e3b7b10c0d4afbf09a9151e132f1ee85b9c6f Mon Sep 17 00:00:00 2001
From: Junjie <540245094@qq.com>
Date: 星期六, 02 八月 2025 11:15:25 +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