From ffbcb17a9ce705b443c3a450e3e3d56f13ee712f Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期二, 23 九月 2025 13:13:56 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/shuttle_rcs_dev' into shuttle_rcs_dev
---
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