From c1ed5a7f04fcc6459da611140a43870428092499 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期五, 10 四月 2026 23:42:17 +0800
Subject: [PATCH] #入库异常
---
src/main/java/com/zy/core/plugin/GslProcess.java | 65 ++++++++++++++++++++++++++------
1 files changed, 52 insertions(+), 13 deletions(-)
diff --git a/src/main/java/com/zy/core/plugin/GslProcess.java b/src/main/java/com/zy/core/plugin/GslProcess.java
index 8808f1a..261b8ce 100644
--- a/src/main/java/com/zy/core/plugin/GslProcess.java
+++ b/src/main/java/com/zy/core/plugin/GslProcess.java
@@ -134,7 +134,25 @@
continue;//涓嶅睘浜庡叆搴撴ā寮�
}
- StationCommand command = stationThread.getCommand(StationCommandType.MOVE, commonService.getWorkNo(WrkIoType.ENABLE_IN.id), stationId, entity.getBarcodeStation().getStationId(), 0);
+ //鍚姩鍏ュ簱锛屽垹闄ゆ潯鐮佺珯閫�鍥為檺鍒�
+ Integer backStationId = entity.getBarcodeStation().getStationId();
+ String lockKey = RedisKeyType.GENERATE_STATION_BACK_LIMIT.key + backStationId;
+ if (redisUtil.hasKey(lockKey)) {
+ StationProtocol backStationProtocol = stationMap.get(backStationId);
+ if (backStationProtocol == null) {
+ continue;
+ }
+
+ if (backStationProtocol.isAutoing()
+ && !backStationProtocol.isLoading()
+ && stationProtocol.getTaskNo() == 0
+ ) {
+ //鏉＄爜绔欒嚜鍔ㄣ�佹棤鐗┿�佸伐浣滃彿0銆傚垹闄ゆ潯鐮佺珯閫�鍥為檺鍒�
+ redisUtil.del(lockKey);
+ }
+ }
+
+ StationCommand command = stationThread.getCommand(StationCommandType.MOVE, commonService.getWorkNo(WrkIoType.ENABLE_IN.id), stationId, backStationId, 0);
stationCommandDispatcher.dispatch(basDevp.getDevpNo(), command, "gsl-process", "enable-in");
if (entity.getBarcodeStation() != null && entity.getBarcodeStation().getStationId() != null) {
Utils.precomputeInTaskEnableRow(entity.getBarcodeStation().getStationId());
@@ -171,23 +189,44 @@
if (!handleErrorStationBack(basDevp, stationThread, stationObjModel, stationMap.get(stationId))) {
continue;
}
- if (!canRequestStoreIn(stationMap.get(stationId))) {
+
+ StationProtocol stationProtocol = stationMap.get(stationId);
+ if (stationProtocol == null) {
continue;
}
+
+ if (!stationProtocol.isAutoing()) {
+ continue;
+ }
+
+ if (!stationProtocol.isLoading()) {
+ continue;
+ }
+
+ if (!stationProtocol.isInEnable()) {
+ continue;
+ }
+
+ if (stationProtocol.getTaskNo() == 0) {
+ continue;
+ }
+
+ if (Cools.isEmpty(stationProtocol.getBarcode())) {
+ continue;
+ }
+
+ if (stationProtocol.getError() > 0) {
+ continue;
+ }
+
+ if (stationProtocol.isInBarcodeError()) {
+ continue;
+ }
+
storeInTaskGenerationService.submitGenerateStoreTask(this, basDevp, stationObjModel, DISPATCH_INTERVAL_MS,
() -> storeInTaskGenerationService.generate(this, basDevp, stationObjModel));
}
}
- }
-
- private boolean canRequestStoreIn(StationProtocol stationProtocol) {
- return stationProtocol != null
- && stationProtocol.getError() <= 0
- && stationProtocol.isAutoing()
- && stationProtocol.isLoading()
- && stationProtocol.isInEnable()
- && stationProtocol.getTaskNo() > 0
- && !Cools.isEmpty(stationProtocol.getBarcode());
}
private boolean handleErrorStationBack(BasDevp basDevp,
@@ -262,7 +301,7 @@
}
stationCommandDispatcher.dispatch(basDevp.getDevpNo(), command, "gsl-process", "station-back");
News.info("{}鎵爜绔欏紓甯革紝宸查��鍥炶嚦{},鏉＄爜绔欑姸鎬侊細{}", stationProtocol.getTaskNo(), backStation.getStationId(), JSON.toJSONString(stationProtocol));
- redisUtil.set(lockKey, "lock", 15);
+ redisUtil.set(lockKey, "lock", 60 * 10);
return false;
}
--
Gitblit v1.9.1