From 03c3ae747f82ad22c761c79e7b1c0e0031c57d41 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期一, 06 四月 2026 20:28:35 +0800
Subject: [PATCH] #出库站点命令下发
---
src/main/java/com/zy/core/utils/station/StationRegularDispatchProcessor.java | 14 +++++++++++++-
1 files changed, 13 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/zy/core/utils/station/StationRegularDispatchProcessor.java b/src/main/java/com/zy/core/utils/station/StationRegularDispatchProcessor.java
index 833d97a..643b495 100644
--- a/src/main/java/com/zy/core/utils/station/StationRegularDispatchProcessor.java
+++ b/src/main/java/com/zy/core/utils/station/StationRegularDispatchProcessor.java
@@ -116,6 +116,7 @@
wrkAnalysisService.markOutboundStationComplete(wrkMast, now);
notifyUtils.notify(String.valueOf(SlaveType.Devp), stationObjModel.getDeviceNo(), String.valueOf(wrkMast.getWrkNo()), wrkMast.getWmsWrkNo(), NotifyMsgType.STATION_OUT_TASK_RUN_COMPLETE, null);
redisUtil.set(RedisKeyType.STATION_OUT_EXECUTE_COMPLETE_LIMIT.key + wrkMast.getWrkNo(), "lock", 60);
+ clearOutboundDispatchCache(wrkMast);
attemptClearTaskPath(stationThread, wrkNo);
} catch (Exception e) {
e.printStackTrace();
@@ -169,10 +170,19 @@
wrkMast.setWrkSts(WrkStsType.COMPLETE_OUTBOUND.sts);
wrkMast.setIoTime(new Date());
wrkMastService.updateById(wrkMast);
+ clearOutboundDispatchCache(wrkMast);
}
} catch (Exception e) {
e.printStackTrace();
}
+ }
+
+ private void clearOutboundDispatchCache(WrkMast wrkMast) {
+ if (wrkMast == null || wrkMast.getWrkNo() == null) {
+ return;
+ }
+ redisUtil.del(RedisKeyType.CRN_OUT_TASK_COMPLETE_STATION_INFO.key + wrkMast.getWrkNo());
+ redisUtil.del(RedisKeyType.DUAL_CRN_OUT_TASK_STATION_INFO.key + wrkMast.getWrkNo());
}
public void attemptClearTaskPath(StationThread stationThread, Integer taskNo) {
@@ -222,7 +232,9 @@
if (!stationProtocol.isAutoing()
|| !stationProtocol.isLoading()
- || stationProtocol.getTaskNo() <= 0) {
+ || stationProtocol.getTaskNo() <= 0
+ || !stationProtocol.isInEnable()
+ ) {
return;
}
--
Gitblit v1.9.1