From e4675cf7238b53bca8dedfd504f75551b6c01fce Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期二, 31 三月 2026 22:48:30 +0800
Subject: [PATCH] #入库预调度
---
src/main/java/com/zy/asrs/task/InboundCrnMoveDispatchScheduler.java | 185 +++++++++++++++++++++++++++++++++++++
src/main/java/com/zy/asrs/task/WrkAnalysisStationArrivalScanner.java | 92 ------------------
2 files changed, 186 insertions(+), 91 deletions(-)
diff --git a/src/main/java/com/zy/asrs/task/InboundCrnMoveDispatchScheduler.java b/src/main/java/com/zy/asrs/task/InboundCrnMoveDispatchScheduler.java
new file mode 100644
index 0000000..f2e7139
--- /dev/null
+++ b/src/main/java/com/zy/asrs/task/InboundCrnMoveDispatchScheduler.java
@@ -0,0 +1,185 @@
+package com.zy.asrs.task;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.core.common.Cools;
+import com.zy.asrs.entity.BasCrnp;
+import com.zy.asrs.entity.BasStation;
+import com.zy.asrs.entity.WrkMast;
+import com.zy.asrs.service.BasCrnpService;
+import com.zy.asrs.service.BasStationService;
+import com.zy.asrs.service.WrkMastService;
+import com.zy.asrs.utils.Utils;
+import com.zy.common.entity.FindCrnNoResult;
+import com.zy.common.service.CommonService;
+import com.zy.core.News;
+import com.zy.core.cache.SlaveConnection;
+import com.zy.core.enums.SlaveType;
+import com.zy.core.enums.WrkIoType;
+import com.zy.core.enums.WrkStsType;
+import com.zy.core.model.StationObjModel;
+import com.zy.core.model.protocol.StationProtocol;
+import com.zy.core.move.StationMoveCoordinator;
+import com.zy.core.move.StationMoveSession;
+import com.zy.core.thread.StationThread;
+import com.zy.core.utils.CrnOperateProcessUtils;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+
+@Component
+public class InboundCrnMoveDispatchScheduler {
+
+ private final WrkMastService wrkMastService;
+ private final BasStationService basStationService;
+ private final CommonService commonService;
+ private final BasCrnpService basCrnpService;
+ private final CrnOperateProcessUtils crnOperateProcessUtils;
+ private final StationMoveCoordinator stationMoveCoordinator;
+
+ public InboundCrnMoveDispatchScheduler(WrkMastService wrkMastService,
+ BasStationService basStationService,
+ CommonService commonService,
+ BasCrnpService basCrnpService,
+ CrnOperateProcessUtils crnOperateProcessUtils,
+ StationMoveCoordinator stationMoveCoordinator) {
+ this.wrkMastService = wrkMastService;
+ this.basStationService = basStationService;
+ this.commonService = commonService;
+ this.basCrnpService = basCrnpService;
+ this.crnOperateProcessUtils = crnOperateProcessUtils;
+ this.stationMoveCoordinator = stationMoveCoordinator;
+ }
+
+ @Scheduled(fixedDelay = 1000L)
+ public void dispatchInboundCrnMove() {
+ List<WrkMast> wrkMasts = wrkMastService.list(new QueryWrapper<WrkMast>()
+ .eq("io_type", WrkIoType.IN.id)
+ .eq("wrk_sts", WrkStsType.INBOUND_STATION_RUN.sts)
+ .isNotNull("sta_no"));
+ for (WrkMast wrkMast : wrkMasts) {
+ if (wrkMast == null || wrkMast.getWrkNo() == null || wrkMast.getStaNo() == null || Cools.isEmpty(wrkMast.getLocNo())) {
+ continue;
+ }
+
+ BasStation basStation = basStationService.getOne(new QueryWrapper<BasStation>()
+ .eq("station_id", wrkMast.getStaNo())
+ .last("limit 1"));
+ if (basStation == null || basStation.getDeviceNo() == null) {
+ continue;
+ }
+
+ StationThread stationThread = (StationThread) SlaveConnection.get(SlaveType.Devp, basStation.getDeviceNo());
+ if (stationThread == null) {
+ continue;
+ }
+
+ Map<Integer, StationProtocol> statusMap = stationThread.getStatusMap();
+ StationProtocol stationProtocol = statusMap == null ? null : statusMap.get(basStation.getStationId());
+ tryDispatchInboundCrnMove(wrkMast, stationProtocol);
+ }
+ }
+
+ private void tryDispatchInboundCrnMove(WrkMast wrkMast, StationProtocol targetStationProtocol) {
+ if (targetStationProtocol != null
+ && targetStationProtocol.isLoading()
+ && targetStationProtocol.getTaskNo() > 0
+ && targetStationProtocol.isInEnable()) {
+ return;
+ }
+
+ FindCrnNoResult findCrnNoResult = commonService.findCrnNoByLocNo(wrkMast.getLocNo());
+ if (findCrnNoResult == null || !Objects.equals(findCrnNoResult.getCrnType(), SlaveType.Crn) || findCrnNoResult.getCrnNo() == null) {
+ return;
+ }
+ Integer crnNo = findCrnNoResult.getCrnNo();
+
+ BasCrnp basCrnp = basCrnpService.getOne(new QueryWrapper<BasCrnp>()
+ .eq("crn_no", crnNo)
+ .last("limit 1"));
+ if (basCrnp == null) {
+ return;
+ }
+
+ String inboundPickupLocNo = resolveInboundPickupLocNo(basCrnp, wrkMast.getStaNo());
+ if (Cools.isEmpty(inboundPickupLocNo)) {
+ return;
+ }
+
+ // 鍚屽爢鍨涙満娌℃湁鏈畬鎴愬嚭搴撲换鍔℃椂锛屼紭鍏堢洿鎺ュ埌褰撳墠鍏ュ簱浠诲姟鍙栬揣浣嶇瓑寰呫��
+ if (!hasPendingOutboundTask(crnNo)) {
+ boolean dispatched = crnOperateProcessUtils.dispatchCrnMove(crnNo, inboundPickupLocNo);
+ if (dispatched) {
+ News.info("妫�娴嬪埌浠呮湁鍏ュ簱浠诲姟锛屽凡瑙﹀彂鍫嗗灈鏈虹洿鎺ョЩ鍔ㄥ埌鍏ュ簱浠诲姟鍙栬揣浣嶇瓑寰咃紝宸ヤ綔鍙�={}锛屽爢鍨涙満鍙�={}锛屽彇璐т綅={}",
+ wrkMast.getWrkNo(), crnNo, inboundPickupLocNo);
+ }
+ return;
+ }
+
+ StationMoveSession session = stationMoveCoordinator == null ? null : stationMoveCoordinator.loadSession(wrkMast.getWrkNo());
+ if (!isInboundCrnMoveDispatchWindow(wrkMast, session)) {
+ return;
+ }
+
+ boolean dispatched = crnOperateProcessUtils.dispatchCrnMove(crnNo, inboundPickupLocNo);
+ if (dispatched) {
+ News.info("鍏ュ簱浠诲姟鍗冲皢鍒拌揪鍙栬揣浣嶏紝宸茶Е鍙戝爢鍨涙満棰勭Щ杞︼紝宸ヤ綔鍙�={}锛屽爢鍨涙満鍙�={}锛屽彇璐т綅={}",
+ wrkMast.getWrkNo(), crnNo, inboundPickupLocNo);
+ }
+ }
+
+ private String resolveInboundPickupLocNo(BasCrnp basCrnp, Integer targetStationId) {
+ if (basCrnp == null || targetStationId == null) {
+ return null;
+ }
+ for (StationObjModel stationObjModel : basCrnp.getInStationList$()) {
+ if (stationObjModel == null || !Objects.equals(stationObjModel.getStationId(), targetStationId)) {
+ continue;
+ }
+ if (stationObjModel.getDeviceRow() == null || stationObjModel.getDeviceBay() == null || stationObjModel.getDeviceLev() == null) {
+ continue;
+ }
+ return Utils.getLocNo(stationObjModel.getDeviceRow(), stationObjModel.getDeviceBay(), stationObjModel.getDeviceLev());
+ }
+ return null;
+ }
+
+ private boolean hasPendingOutboundTask(Integer crnNo) {
+ if (crnNo == null) {
+ return false;
+ }
+ return wrkMastService.count(new QueryWrapper<WrkMast>()
+ .eq("crn_no", crnNo)
+ .eq("io_type", WrkIoType.OUT.id)
+ .in("wrk_sts",
+ WrkStsType.NEW_OUTBOUND.sts,
+ WrkStsType.OUTBOUND_RUN.sts,
+ WrkStsType.OUTBOUND_RUN_COMPLETE.sts,
+ WrkStsType.STATION_RUN.sts,
+ WrkStsType.STATION_RUN_COMPLETE.sts,
+ WrkStsType.OUTBOUND_MANUAL.sts)) > 0;
+ }
+
+ private boolean isInboundCrnMoveDispatchWindow(WrkMast wrkMast, StationMoveSession session) {
+ if (wrkMast == null || session == null || !session.isActive() || wrkMast.getStaNo() == null) {
+ return false;
+ }
+ List<Integer> fullPathStationIds = session.getFullPathStationIds();
+ Integer currentStationId = session.getCurrentStationId();
+ if (fullPathStationIds == null || fullPathStationIds.isEmpty() || currentStationId == null) {
+ return false;
+ }
+ int currentIndex = fullPathStationIds.lastIndexOf(currentStationId);
+ if (currentIndex < 0 || currentIndex >= fullPathStationIds.size() - 1) {
+ return false;
+ }
+ int remainingStationCount = fullPathStationIds.size() - currentIndex - 1;
+ if (remainingStationCount != 1) {
+ return false;
+ }
+ Integer nextStationId = fullPathStationIds.get(currentIndex + 1);
+ return Objects.equals(nextStationId, wrkMast.getStaNo());
+ }
+}
diff --git a/src/main/java/com/zy/asrs/task/WrkAnalysisStationArrivalScanner.java b/src/main/java/com/zy/asrs/task/WrkAnalysisStationArrivalScanner.java
index f299636..cf33ff0 100644
--- a/src/main/java/com/zy/asrs/task/WrkAnalysisStationArrivalScanner.java
+++ b/src/main/java/com/zy/asrs/task/WrkAnalysisStationArrivalScanner.java
@@ -1,27 +1,17 @@
package com.zy.asrs.task;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
-import com.core.common.Cools;
-import com.zy.asrs.entity.BasCrnp;
import com.zy.asrs.entity.BasStation;
import com.zy.asrs.entity.WrkMast;
-import com.zy.asrs.service.BasCrnpService;
import com.zy.asrs.service.BasStationService;
import com.zy.asrs.service.WrkAnalysisService;
import com.zy.asrs.service.WrkMastService;
-import com.zy.asrs.utils.Utils;
-import com.zy.common.entity.FindCrnNoResult;
-import com.zy.common.service.CommonService;
import com.zy.core.News;
import com.zy.core.cache.SlaveConnection;
import com.zy.core.enums.SlaveType;
import com.zy.core.enums.WrkStsType;
-import com.zy.core.model.StationObjModel;
-import com.zy.core.move.StationMoveCoordinator;
-import com.zy.core.move.StationMoveSession;
import com.zy.core.model.protocol.StationProtocol;
import com.zy.core.thread.StationThread;
-import com.zy.core.utils.CrnOperateProcessUtils;
import com.zy.core.utils.StationOperateProcessUtils;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
@@ -29,7 +19,6 @@
import java.util.Date;
import java.util.List;
import java.util.Map;
-import java.util.Objects;
@Component
public class WrkAnalysisStationArrivalScanner {
@@ -38,27 +27,15 @@
private final BasStationService basStationService;
private final WrkAnalysisService wrkAnalysisService;
private final StationOperateProcessUtils stationOperateProcessUtils;
- private final StationMoveCoordinator stationMoveCoordinator;
- private final CommonService commonService;
- private final BasCrnpService basCrnpService;
- private final CrnOperateProcessUtils crnOperateProcessUtils;
public WrkAnalysisStationArrivalScanner(WrkMastService wrkMastService,
BasStationService basStationService,
WrkAnalysisService wrkAnalysisService,
- StationOperateProcessUtils stationOperateProcessUtils,
- StationMoveCoordinator stationMoveCoordinator,
- CommonService commonService,
- BasCrnpService basCrnpService,
- CrnOperateProcessUtils crnOperateProcessUtils) {
+ StationOperateProcessUtils stationOperateProcessUtils) {
this.wrkMastService = wrkMastService;
this.basStationService = basStationService;
this.wrkAnalysisService = wrkAnalysisService;
this.stationOperateProcessUtils = stationOperateProcessUtils;
- this.stationMoveCoordinator = stationMoveCoordinator;
- this.commonService = commonService;
- this.basCrnpService = basCrnpService;
- this.crnOperateProcessUtils = crnOperateProcessUtils;
}
@Scheduled(fixedDelay = 1000L)
@@ -89,7 +66,6 @@
}
Map<Integer, StationProtocol> statusMap = stationThread.getStatusMap();
StationProtocol stationProtocol = statusMap == null ? null : statusMap.get(basStation.getStationId());
- tryDispatchInboundCrnMove(wrkMast, stationProtocol);
boolean arrived = stationProtocol != null
&& wrkMast.getWrkNo().equals(stationProtocol.getTaskNo())
&& stationProtocol.isLoading();
@@ -101,71 +77,5 @@
News.info("鍏ュ簱绔欑偣鍒拌揪鎵弿鍛戒腑锛屽伐浣滃彿={}锛岀洰鏍囩珯={}", wrkMast.getWrkNo(), wrkMast.getStaNo());
}
}
- }
-
- private void tryDispatchInboundCrnMove(WrkMast wrkMast, StationProtocol targetStationProtocol) {
- if (wrkMast == null || wrkMast.getWrkNo() == null || wrkMast.getStaNo() == null || Cools.isEmpty(wrkMast.getLocNo())) {
- return;
- }
- if (targetStationProtocol != null
- && targetStationProtocol.isLoading()
- && targetStationProtocol.getTaskNo() > 0
- && targetStationProtocol.isInEnable()) {
- return;
- }
-
- StationMoveSession session = stationMoveCoordinator == null ? null : stationMoveCoordinator.loadSession(wrkMast.getWrkNo());
- if (!isInboundCrnMoveDispatchWindow(wrkMast, session)) {
- return;
- }
-
- FindCrnNoResult findCrnNoResult = commonService.findCrnNoByLocNo(wrkMast.getLocNo());
- if (findCrnNoResult == null || !Objects.equals(findCrnNoResult.getCrnType(), SlaveType.Crn) || findCrnNoResult.getCrnNo() == null) {
- return;
- }
-
- BasCrnp basCrnp = basCrnpService.getOne(new QueryWrapper<BasCrnp>()
- .eq("crn_no", findCrnNoResult.getCrnNo())
- .last("limit 1"));
- if (basCrnp == null) {
- return;
- }
-
- for (StationObjModel stationObjModel : basCrnp.getInStationList$()) {
- if (stationObjModel == null || !Objects.equals(stationObjModel.getStationId(), wrkMast.getStaNo())) {
- continue;
- }
- if (stationObjModel.getDeviceRow() == null || stationObjModel.getDeviceBay() == null || stationObjModel.getDeviceLev() == null) {
- continue;
- }
- String inletLocNo = Utils.getLocNo(stationObjModel.getDeviceRow(), stationObjModel.getDeviceBay(), stationObjModel.getDeviceLev());
- boolean dispatched = crnOperateProcessUtils.dispatchCrnMove(findCrnNoResult.getCrnNo(), inletLocNo);
- if (dispatched) {
- News.info("鍏ュ簱浠诲姟鍗冲皢鍒拌揪鍏ュ簱鍙ｏ紝宸茶Е鍙戝爢鍨涙満棰勭Щ杞︼紝宸ヤ綔鍙�={}锛屽爢鍨涙満鍙�={}锛屽叆搴撳彛浣嶇疆={}",
- wrkMast.getWrkNo(), findCrnNoResult.getCrnNo(), inletLocNo);
- }
- return;
- }
- }
-
- private boolean isInboundCrnMoveDispatchWindow(WrkMast wrkMast, StationMoveSession session) {
- if (wrkMast == null || session == null || !session.isActive() || wrkMast.getStaNo() == null) {
- return false;
- }
- List<Integer> fullPathStationIds = session.getFullPathStationIds();
- Integer currentStationId = session.getCurrentStationId();
- if (fullPathStationIds == null || fullPathStationIds.isEmpty() || currentStationId == null) {
- return false;
- }
- int currentIndex = fullPathStationIds.lastIndexOf(currentStationId);
- if (currentIndex < 0 || currentIndex >= fullPathStationIds.size() - 1) {
- return false;
- }
- int remainingStationCount = fullPathStationIds.size() - currentIndex - 1;
- if (remainingStationCount != 1) {
- return false;
- }
- Integer nextStationId = fullPathStationIds.get(currentIndex + 1);
- return Objects.equals(nextStationId, wrkMast.getStaNo());
}
}
--
Gitblit v1.9.1