From 205cb40876114827a2134c29fde159e063e81454 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期六, 21 三月 2026 09:54:42 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/core/thread/impl/v5/StationV5SegmentExecutor.java | 11 +++++++++++
1 files changed, 11 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/impl/v5/StationV5SegmentExecutor.java b/src/main/java/com/zy/core/thread/impl/v5/StationV5SegmentExecutor.java
index 96320de..7e749fb 100644
--- a/src/main/java/com/zy/core/thread/impl/v5/StationV5SegmentExecutor.java
+++ b/src/main/java/com/zy/core/thread/impl/v5/StationV5SegmentExecutor.java
@@ -167,6 +167,9 @@
private boolean sendSegmentWithRetry(StationCommand command) {
while (true) {
+ if (isTaskMoveReset(command == null ? null : command.getTaskNo())) {
+ return false;
+ }
CommandResponse commandResponse = commandSender.apply(command);
if (commandResponse == null) {
sleepQuietly(200L);
@@ -179,6 +182,14 @@
}
}
+ private boolean isTaskMoveReset(Integer taskNo) {
+ if (taskNo == null || redisUtil == null) {
+ return false;
+ }
+ Object cancel = redisUtil.get(RedisKeyType.DEVICE_STATION_MOVE_RESET.key + taskNo);
+ return cancel != null;
+ }
+
private double loadSegmentAdvanceRatio() {
try {
ConfigService configService = SpringUtils.getBean(ConfigService.class);
--
Gitblit v1.9.1