From 779283e0fff0277d8718cc390684c9bb2715b7c1 Mon Sep 17 00:00:00 2001
From: Junjie <DELL@qq.com>
Date: 星期三, 14 一月 2026 15:49:59 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/core/thread/impl/ZyStationV3Thread.java | 14 +++++++++++++-
1 files changed, 13 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/impl/ZyStationV3Thread.java b/src/main/java/com/zy/core/thread/impl/ZyStationV3Thread.java
index 1bf599d..7f518aa 100644
--- a/src/main/java/com/zy/core/thread/impl/ZyStationV3Thread.java
+++ b/src/main/java/com/zy/core/thread/impl/ZyStationV3Thread.java
@@ -282,6 +282,18 @@
}
private void executeMoveWithSeg(StationCommand original) {
+ int stationCommandSendLength = 20;
+ Object systemConfigMapObj = redisUtil.get(RedisKeyType.SYSTEM_CONFIG_MAP.key);
+ if (systemConfigMapObj != null) {
+ try {
+ HashMap<String, String> systemConfigMap = (HashMap<String, String>) systemConfigMapObj;
+ String stationCommandSendLengthStr = systemConfigMap.get("stationCommandSendLength");
+ if(stationCommandSendLengthStr != null){
+ stationCommandSendLength = Integer.parseInt(stationCommandSendLengthStr);
+ }
+ } catch (Exception ignore) {}
+ }
+
if(original.getCommandType() == StationCommandType.MOVE){
List<Integer> path = original.getNavigatePath();
if (path == null || path.isEmpty()) {
@@ -296,7 +308,7 @@
List<Integer> segmentEndIndices = new ArrayList<>();
int idx = 0;
while (idx < total) {
- int end = Math.min(idx + 3, total) - 1;
+ int end = Math.min(idx + stationCommandSendLength, total) - 1;
segmentTargets.add(path.get(end));
segmentEndIndices.add(end);
idx = end + 1;
--
Gitblit v1.9.1