From c18f8a5adb162791ef63f92ec457c8a34844e822 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期五, 10 四月 2026 21:52:49 +0800
Subject: [PATCH] #入库异常
---
src/main/java/com/zy/core/plugin/GslProcess.java | 9 +++------
1 files changed, 3 insertions(+), 6 deletions(-)
diff --git a/src/main/java/com/zy/core/plugin/GslProcess.java b/src/main/java/com/zy/core/plugin/GslProcess.java
index e5e2034..8808f1a 100644
--- a/src/main/java/com/zy/core/plugin/GslProcess.java
+++ b/src/main/java/com/zy/core/plugin/GslProcess.java
@@ -246,10 +246,7 @@
return false;
}
- Integer lockTaskNo = stationProtocol.getTaskNo();
- String lockKey = (lockTaskNo != null && lockTaskNo > 0)
- ? RedisKeyType.GENERATE_STATION_BACK_LIMIT.key + lockTaskNo
- : RedisKeyType.GENERATE_STATION_BACK_LIMIT.key + "station_" + stationProtocol.getStationId();
+ String lockKey = RedisKeyType.GENERATE_STATION_BACK_LIMIT.key + stationProtocol.getStationId();
Object lock = redisUtil.get(lockKey);
if (lock != null) {
return false;
@@ -264,8 +261,8 @@
return false;
}
stationCommandDispatcher.dispatch(basDevp.getDevpNo(), command, "gsl-process", "station-back");
- News.taskInfo(stationProtocol.getTaskNo(), "鎵爜寮傚父锛屽凡閫�鍥炶嚦{}", backStation.getStationId());
- redisUtil.set(lockKey, "lock", 10);
+ News.info("{}鎵爜绔欏紓甯革紝宸查��鍥炶嚦{},鏉＄爜绔欑姸鎬侊細{}", stationProtocol.getTaskNo(), backStation.getStationId(), JSON.toJSONString(stationProtocol));
+ redisUtil.set(lockKey, "lock", 15);
return false;
}
--
Gitblit v1.9.1