From 7fdc76dde7cd00510347e3231c4f60a88b012107 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期四, 02 四月 2026 19:03:24 +0800
Subject: [PATCH] #预调度堆垛机2
---
src/main/java/com/zy/core/utils/CrnOperateProcessUtils.java | 186 ++++++++++++++++++++++++++++------------------
1 files changed, 113 insertions(+), 73 deletions(-)
diff --git a/src/main/java/com/zy/core/utils/CrnOperateProcessUtils.java b/src/main/java/com/zy/core/utils/CrnOperateProcessUtils.java
index 787f8c0..32caee7 100644
--- a/src/main/java/com/zy/core/utils/CrnOperateProcessUtils.java
+++ b/src/main/java/com/zy/core/utils/CrnOperateProcessUtils.java
@@ -101,80 +101,65 @@
//鍏ュ嚭搴� ===>> 鍫嗗灈鏈哄叆鍑哄簱浣滀笟涓嬪彂
private void crnIoExecuteNormal(BasCrnp currentCrn, Set<Integer> crnMoveBlockedCrnNos) {
- Map<Integer, BasCrnp> dispatchCrnMap = new HashMap<>();
- Map<Integer, CrnThread> dispatchThreadMap = new HashMap<>();
- Map<Integer, CrnProtocol> dispatchProtocolMap = new HashMap<>();
- for (BasCrnp basCrnp : java.util.Collections.singletonList(currentCrn)) {
- if (basCrnp == null || basCrnp.getCrnNo() == null || crnMoveBlockedCrnNos.contains(basCrnp.getCrnNo())) {
- continue;
- }
- CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, basCrnp.getCrnNo());
- if (crnThread == null) {
- continue;
- }
-
- CrnProtocol crnProtocol = crnThread.getStatus();
- if (crnProtocol == null) {
- continue;
- }
-
- long runningCount = wrkMastService.count(new QueryWrapper<WrkMast>()
- .eq("crn_no", basCrnp.getCrnNo())
- .in("wrk_sts", WrkStsType.INBOUND_RUN.sts, WrkStsType.OUTBOUND_RUN.sts, WrkStsType.LOC_MOVE_RUN.sts, WrkStsType.CRN_MOVE_RUN.sts));
- if (runningCount > 0) {
- continue;
- }
-
- // 鍙湁褰撳爢鍨涙満绌洪棽 骞朵笖 鏃犱换鍔℃椂鎵嶇户缁墽琛�
- if (crnProtocol.getMode() == CrnModeType.AUTO.id
- && crnProtocol.getTaskNo() == 0
- && crnProtocol.getStatus() == CrnStatusType.IDLE.id
- && crnProtocol.getLoaded() == 0
- && crnProtocol.getForkPos() == 0
- && crnProtocol.getAlarm() == 0
- ) {
- Object clearLock = redisUtil.get(RedisKeyType.CLEAR_CRN_TASK_LIMIT.key + basCrnp.getCrnNo());
- if (clearLock != null) {
- continue;
- }
- dispatchCrnMap.put(basCrnp.getCrnNo(), basCrnp);
- dispatchThreadMap.put(basCrnp.getCrnNo(), crnThread);
- dispatchProtocolMap.put(basCrnp.getCrnNo(), crnProtocol);
- }
- }
-
- if (dispatchCrnMap.isEmpty()) {
+ if (currentCrn == null || currentCrn.getCrnNo() == null || crnMoveBlockedCrnNos.contains(currentCrn.getCrnNo())) {
return;
}
+ Integer crnNo = currentCrn.getCrnNo();
+ CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, crnNo);
+ if (crnThread == null) {
+ return;
+ }
+
+ CrnProtocol crnProtocol = crnThread.getStatus();
+ if (crnProtocol == null) {
+ return;
+ }
+
+ long runningCount = wrkMastService.count(new QueryWrapper<WrkMast>()
+ .eq("crn_no", crnNo)
+ .in("wrk_sts", WrkStsType.INBOUND_RUN.sts, WrkStsType.OUTBOUND_RUN.sts, WrkStsType.LOC_MOVE_RUN.sts, WrkStsType.CRN_MOVE_RUN.sts));
+ if (runningCount > 0) {
+ return;
+ }
+
+ // 鍙湁褰撳爢鍨涙満绌洪棽 骞朵笖 鏃犱换鍔℃椂鎵嶇户缁墽琛�
+ if (crnProtocol.getMode() != CrnModeType.AUTO.id
+ || crnProtocol.getTaskNo() != 0
+ || crnProtocol.getStatus() != CrnStatusType.IDLE.id
+ || crnProtocol.getLoaded() != 0
+ || crnProtocol.getForkPos() != 0
+ || crnProtocol.getAlarm() != 0) {
+ return;
+ }
+
+ Object clearLock = redisUtil.get(RedisKeyType.CLEAR_CRN_TASK_LIMIT.key + crnNo);
+ if (clearLock != null) {
+ return;
+ }
+
+ String lastIo = resolveCrnLastIo(crnProtocol);
+
List<WrkMast> taskQueue = wrkMastService.list(new QueryWrapper<WrkMast>()
- .in("crn_no", new ArrayList<>(dispatchCrnMap.keySet()))
+ .eq("crn_no", crnNo)
.in("wrk_sts",
WrkStsType.INBOUND_STATION_RUN_COMPLETE.sts,
WrkStsType.NEW_OUTBOUND.sts,
WrkStsType.NEW_LOC_MOVE.sts));
- taskQueue.sort(Comparator
- .comparingInt(this::resolveBatchOutboundRank)
+ taskQueue.sort(Comparator.comparingInt((WrkMast wrkMast) -> resolveTaskTypeRank(wrkMast, lastIo))
+ .thenComparingInt(this::resolveBatchOutboundRank)
.thenComparingInt(this::resolveBatchSeqOrder)
.thenComparingDouble(this::resolveTaskIoPri)
.thenComparingLong(this::resolveTaskQueueTime)
.thenComparingInt(this::resolveTaskQueueNo));
for (WrkMast wrkMast : taskQueue) {
- if (wrkMast == null || wrkMast.getCrnNo() == null) {
- continue;
- }
-
- Integer crnNo = wrkMast.getCrnNo();
- BasCrnp basCrnp = dispatchCrnMap.get(crnNo);
- CrnThread crnThread = dispatchThreadMap.get(crnNo);
- CrnProtocol crnProtocol = dispatchProtocolMap.get(crnNo);
- if (basCrnp == null || crnThread == null || crnProtocol == null) {
+ if (wrkMast == null || wrkMast.getCrnNo() == null || !Objects.equals(wrkMast.getCrnNo(), crnNo)) {
continue;
}
if (wrkMast.getWrkSts() != null && wrkMast.getWrkSts() == WrkStsType.INBOUND_STATION_RUN_COMPLETE.sts) {
- boolean result = this.crnExecuteInPlanner(basCrnp, crnThread, wrkMast);
+ boolean result = this.crnExecuteInPlanner(currentCrn, crnThread, wrkMast);
if (result) {
crnProtocol.setLastIo("O");
return;
@@ -183,7 +168,7 @@
}
if (wrkMast.getWrkSts() != null && wrkMast.getWrkSts() == WrkStsType.NEW_OUTBOUND.sts) {
- boolean result = this.crnExecuteOutPlanner(basCrnp, crnThread, wrkMast);
+ boolean result = this.crnExecuteOutPlanner(currentCrn, crnThread, wrkMast);
if (result) {
crnProtocol.setLastIo("I");
return;
@@ -192,7 +177,7 @@
}
if (wrkMast.getWrkSts() != null && wrkMast.getWrkSts() == WrkStsType.NEW_LOC_MOVE.sts) {
- boolean transfer = this.crnExecuteMovePlanner(basCrnp, crnThread, wrkMast);
+ boolean transfer = this.crnExecuteMovePlanner(currentCrn, crnThread, wrkMast);
if (transfer) {
return;
}
@@ -202,6 +187,44 @@
private int resolveBatchOutboundRank(WrkMast wrkMast) {
return isBatchOutboundTask(wrkMast) ? 0 : 1;
+ }
+
+ private String resolveCrnLastIo(CrnProtocol crnProtocol) {
+ if (crnProtocol == null) {
+ return "I";
+ }
+ if (Cools.isEmpty(crnProtocol.getLastIo())) {
+ return "I";
+ }
+ return crnProtocol.getLastIo();
+ }
+
+ private int resolveTaskTypeRank(WrkMast wrkMast, String lastIo) {
+ if (wrkMast == null || wrkMast.getWrkSts() == null) {
+ return Integer.MAX_VALUE;
+ }
+
+ if (Objects.equals(wrkMast.getWrkSts(), WrkStsType.NEW_LOC_MOVE.sts)) {
+ return 0;
+ }
+
+ if (Objects.equals("O", lastIo)) {
+ if (Objects.equals(wrkMast.getWrkSts(), WrkStsType.INBOUND_STATION_RUN_COMPLETE.sts)) {
+ return 1;
+ }
+ if (Objects.equals(wrkMast.getWrkSts(), WrkStsType.NEW_OUTBOUND.sts)) {
+ return 2;
+ }
+ return 3;
+ }
+
+ if (Objects.equals(wrkMast.getWrkSts(), WrkStsType.NEW_OUTBOUND.sts)) {
+ return 1;
+ }
+ if (Objects.equals(wrkMast.getWrkSts(), WrkStsType.INBOUND_STATION_RUN_COMPLETE.sts)) {
+ return 2;
+ }
+ return 3;
}
private int resolveBatchSeqOrder(WrkMast wrkMast) {
@@ -362,7 +385,7 @@
return false;
}
- if (!allowBatchOutboundExecute(wrkMast)) {
+ if (!allowBatchOutboundExecute(wrkMast, true)) {
return false;
}
@@ -435,13 +458,19 @@
return false;
}
- private boolean allowBatchOutboundExecute(WrkMast wrkMast) {
+ public boolean canOutboundTaskExecuteInCurrentBatchWindow(WrkMast wrkMast) {
+ return allowBatchOutboundExecute(wrkMast, false);
+ }
+
+ private boolean allowBatchOutboundExecute(WrkMast wrkMast, boolean logBlockedReason) {
if (wrkMast == null || Cools.isEmpty(wrkMast.getBatch())) {
return true;
}
if (Cools.isEmpty(wrkMast.getBatchSeq())) {
- News.taskInfo(wrkMast.getWrkNo(), "鎵规:{} 缂哄皯鎵规搴忓彿锛屾殏涓嶅厑璁稿爢鍨涙満鍑哄簱", wrkMast.getBatch());
+ if (logBlockedReason) {
+ News.taskInfo(wrkMast.getWrkNo(), "鎵规:{} 缂哄皯鎵规搴忓彿锛屾殏涓嶅厑璁稿爢鍨涙満鍑哄簱", wrkMast.getBatch());
+ }
return false;
}
@@ -456,7 +485,9 @@
}
if (Cools.isEmpty(firstBatchWrkMast.getBatchSeq())) {
- News.taskInfo(wrkMast.getWrkNo(), "鎵规:{} 瀛樺湪鏈厤缃壒娆″簭鍙风殑浠诲姟锛屾殏涓嶅厑璁稿爢鍨涙満鍑哄簱", wrkMast.getBatch());
+ if (logBlockedReason) {
+ News.taskInfo(wrkMast.getWrkNo(), "鎵规:{} 瀛樺湪鏈厤缃壒娆″簭鍙风殑浠诲姟锛屾殏涓嶅厑璁稿爢鍨涙満鍑哄簱", wrkMast.getBatch());
+ }
return false;
}
@@ -464,7 +495,9 @@
boolean firstBatchTaskExecuted = firstBatchWrkMast.getWrkSts() != null
&& !firstBatchWrkMast.getWrkSts().equals(WrkStsType.NEW_OUTBOUND.sts);
if (!currentIsFirstBatchTask && !firstBatchTaskExecuted) {
- News.taskInfo(wrkMast.getWrkNo(), "鎵规:{} 棣栦釜搴忓彿浠诲姟:{} 灏氭湭鎵ц锛屽綋鍓嶄换鍔℃殏涓嶅厑璁稿嚭搴�", wrkMast.getBatch(), firstBatchWrkMast.getWrkNo());
+ if (logBlockedReason) {
+ News.taskInfo(wrkMast.getWrkNo(), "鎵规:{} 棣栦釜搴忓彿浠诲姟:{} 灏氭湭鎵ц锛屽綋鍓嶄换鍔℃殏涓嶅厑璁稿嚭搴�", wrkMast.getBatch(), firstBatchWrkMast.getWrkNo());
+ }
return false;
}
@@ -475,19 +508,24 @@
List<WrkMast> unfinishedBatchWrkMasts = listUnfinishedBatchWrkMasts(wrkMast.getBatch());
if (hasMissingBatchSeq(unfinishedBatchWrkMasts)) {
- News.taskInfo(wrkMast.getWrkNo(), "鎵规:{} 瀛樺湪鏈厤缃壒娆″簭鍙风殑鏈畬鎴愪换鍔★紝鏆備笉鍏佽鍫嗗灈鏈哄嚭搴�", wrkMast.getBatch());
+ if (logBlockedReason) {
+ News.taskInfo(wrkMast.getWrkNo(), "鎵规:{} 瀛樺湪鏈厤缃壒娆″簭鍙风殑鏈畬鎴愪换鍔★紝鏆備笉鍏佽鍫嗗灈鏈哄嚭搴�", wrkMast.getBatch());
+ }
return false;
}
if (!isWithinBatchExecuteWindow(wrkMast, unfinishedBatchWrkMasts, batchRunningLimit)) {
- Integer windowStartSeq = unfinishedBatchWrkMasts.get(0).getBatchSeq();
- Integer windowEndSeq = unfinishedBatchWrkMasts.get(Math.min(batchRunningLimit, unfinishedBatchWrkMasts.size()) - 1).getBatchSeq();
- News.taskInfo(wrkMast.getWrkNo(),
- "鎵规:{} 褰撳墠涓ユ牸鎵ц绐楀彛搴忓彿涓篬{}-{}]锛屽綋鍓嶅簭鍙�={}锛屾殏涓嶅厑璁稿爢鍨涙満鍑哄簱",
- wrkMast.getBatch(),
- windowStartSeq,
- windowEndSeq,
- wrkMast.getBatchSeq());
+ if (logBlockedReason) {
+ List<Integer> windowBatchSeqList = unfinishedBatchWrkMasts.stream()
+ .limit(Math.min(batchRunningLimit, unfinishedBatchWrkMasts.size()))
+ .map(WrkMast::getBatchSeq)
+ .collect(java.util.stream.Collectors.toList());
+ News.taskInfo(wrkMast.getWrkNo(),
+ "鎵规:{} 褰撳墠涓ユ牸鎵ц绐楀彛搴忓彿鍒楄〃涓簕}锛屽綋鍓嶅簭鍙�={}锛屾殏涓嶅厑璁稿爢鍨涙満鍑哄簱",
+ wrkMast.getBatch(),
+ windowBatchSeqList,
+ wrkMast.getBatchSeq());
+ }
return false;
}
@@ -499,7 +537,9 @@
WrkStsType.COMPLETE_OUTBOUND.sts,
WrkStsType.SETTLE_OUTBOUND.sts));
if (batchRunningCount >= batchRunningLimit) {
- News.taskInfo(wrkMast.getWrkNo(), "鎵规:{} 鎵ц涓换鍔℃暟杈惧埌涓婇檺锛屽綋鍓�={}锛屼笂闄�={}", wrkMast.getBatch(), batchRunningCount, batchRunningLimit);
+ if (logBlockedReason) {
+ News.taskInfo(wrkMast.getWrkNo(), "鎵规:{} 鎵ц涓换鍔℃暟杈惧埌涓婇檺锛屽綋鍓�={}锛屼笂闄�={}", wrkMast.getBatch(), batchRunningCount, batchRunningLimit);
+ }
return false;
}
--
Gitblit v1.9.1