From acb0438796e0de2204fbf499d41ae1725bae7b8c Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期二, 14 四月 2026 12:28:20 +0800
Subject: [PATCH] #命令下发队列日志
---
src/main/java/com/zy/core/move/StationMoveCoordinator.java | 11 +++++++++++
1 files changed, 11 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/zy/core/move/StationMoveCoordinator.java b/src/main/java/com/zy/core/move/StationMoveCoordinator.java
index 2e6c0c3..075ea36 100644
--- a/src/main/java/com/zy/core/move/StationMoveCoordinator.java
+++ b/src/main/java/com/zy/core/move/StationMoveCoordinator.java
@@ -5,6 +5,7 @@
import com.zy.common.utils.RedisUtil;
import com.zy.core.enums.RedisKeyType;
import com.zy.core.model.command.StationCommand;
+import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@@ -20,6 +21,7 @@
import java.util.Objects;
import java.util.function.Supplier;
+@Slf4j
@Component
public class StationMoveCoordinator {
@@ -79,6 +81,7 @@
if (session == null || !session.isActive()) {
return;
}
+ log.info("markCancelPending, taskNo={}, routeVersion={}, cancelReason={}", taskNo, session.getRouteVersion(), cancelReason);
session.setStatus(StationMoveSession.STATUS_CANCEL_PENDING);
session.setCancelReason(cancelReason);
saveSession(session);
@@ -174,6 +177,10 @@
command.setRouteVersion(session.getRouteVersion());
saveSession(session);
+ log.info("recordDispatch done, taskNo={}, routeVersion={}, reuse={}, prevRouteVersion={}, dispatchStationId={}, triggerName={}",
+ taskNo, session.getRouteVersion(), reuseCurrent,
+ current == null ? null : current.getRouteVersion(),
+ dispatchStationId, triggerName);
if (circleRoute) {
saveLegacyCircleCommand(taskNo, command);
@@ -190,6 +197,7 @@
clearLegacyCircleCommand(taskNo);
return null;
}
+ log.info("cancelSession, taskNo={}, routeVersion={}, cancelReason=reroute_cancelled", taskNo, session.getRouteVersion());
session.setStatus(StationMoveSession.STATUS_CANCELLED);
session.setCancelReason("reroute_cancelled");
saveSession(session);
@@ -241,8 +249,11 @@
}
StationMoveSession session = sessionRegistry.load(taskNo);
if (session == null || !Objects.equals(session.getRouteVersion(), routeVersion)) {
+ log.warn("updateTerminal skipped: session mismatch, taskNo={}, cmdRouteVersion={}, sessionRouteVersion={}, targetStatus={}, cancelReason={}",
+ taskNo, routeVersion, session == null ? null : session.getRouteVersion(), status, cancelReason);
return;
}
+ log.info("updateTerminal, taskNo={}, routeVersion={}, status={}, cancelReason={}", taskNo, routeVersion, status, cancelReason);
session.setCurrentStationId(currentStationId);
session.setStatus(status);
session.setCancelReason(cancelReason);
--
Gitblit v1.9.1