From c3d37562d45e05b1830c965ce8d6febc9c40b39b Mon Sep 17 00:00:00 2001
From: cpT <1@123>
Date: 星期四, 29 一月 2026 10:47:27 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/core/utils/DualCrnOperateProcessUtils.java | 116 +++++++++++++++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 111 insertions(+), 5 deletions(-)
diff --git a/src/main/java/com/zy/core/utils/DualCrnOperateProcessUtils.java b/src/main/java/com/zy/core/utils/DualCrnOperateProcessUtils.java
index 409f546..f763f44 100644
--- a/src/main/java/com/zy/core/utils/DualCrnOperateProcessUtils.java
+++ b/src/main/java/com/zy/core/utils/DualCrnOperateProcessUtils.java
@@ -15,6 +15,7 @@
import com.zy.asrs.service.WrkMastService;
import com.zy.asrs.utils.NotifyUtils;
import com.zy.asrs.utils.Utils;
+import com.zy.common.entity.FindCrnNoResult;
import com.zy.common.model.StartupDto;
import com.zy.common.service.CommonService;
import com.zy.common.utils.RedisUtil;
@@ -248,11 +249,6 @@
}
Integer crnNo = basDualCrnp.getCrnNo();
- int station = calcStation(dualCrnProtocol, "in");
- if (station == 0) {
- News.info("鍙屽伐浣嶅爢鍨涙満:{} 鏃犲彲鐢ㄥ伐浣�", basDualCrnp.getCrnNo());
- return false;
- }
if (wrkMast.getWrkSts() != WrkStsType.INBOUND_DEVICE_RUN.sts) {
return false;
@@ -311,11 +307,55 @@
inStationObjModel = stationObjModel;
break;
}
+
+ StationObjModel dualCrnSlaveStationObjModel = stationObjModel.getDualCrnSlaveStation();
+ if (dualCrnSlaveStationObjModel == null) {
+ continue;
+ }
+
+ StationProtocol slaveStationProtocol = stationProtocolMap.get(dualCrnSlaveStationObjModel.getStationId());
+ if (slaveStationProtocol == null) {
+ continue;
+ }
+
+ if (!slaveStationProtocol.isAutoing()) {
+ continue;
+ }
+
+ if (!slaveStationProtocol.isLoading()) {
+ continue;
+ }
+
+ if (slaveStationProtocol.getTaskNo() <= 0) {
+ continue;
+ }
+
+ if (slaveStationProtocol.getTaskNo().equals(wrkMast.getWrkNo())) {
+ inStationObjModel = dualCrnSlaveStationObjModel;
+ break;
+ }
}
if (inStationObjModel == null) {
News.taskInfo(wrkMast.getWrkNo(), "鏈悳绱㈠埌鍙栬揣绔欑偣");
return false;
+ }
+
+ Integer station = inStationObjModel.getDualCrnExecuteStation();
+ if (station == 1) {
+ List<Integer> basList = basDualCrnp.getDisableStationOneBays$();
+ if (basList.contains(Utils.getBay(wrkMast.getLocNo()))) {
+ //绂佹鏀捐揣鍒楋紝鐢宠閲嶆柊鍒嗛厤
+ reassignTaskLocNo(wrkMast, inStationObjModel);
+ return false;
+ }
+ }else {
+ List<Integer> basList = basDualCrnp.getDisableStationTwoBays$();
+ if (basList.contains(Utils.getBay(wrkMast.getLocNo()))) {
+ //绂佹鏀捐揣鍒楋紝鐢宠閲嶆柊鍒嗛厤
+ reassignTaskLocNo(wrkMast, inStationObjModel);
+ return false;
+ }
}
String sourceLocNo = Utils.getLocNo(inStationObjModel.getDeviceRow(), inStationObjModel.getDeviceBay(), inStationObjModel.getDeviceLev());
@@ -757,4 +797,70 @@
return 0;
}
+ private boolean reassignTaskLocNo(WrkMast wrkMast, StationObjModel stationObjModel) {
+ StationThread stationThread = (StationThread) SlaveConnection.get(SlaveType.Devp, stationObjModel.getDeviceNo());
+ if (stationThread == null) {
+ return false;
+ }
+
+ Map<Integer, StationProtocol> stationProtocolMap = stationThread.getStatusMap();
+ StationProtocol stationProtocol = stationProtocolMap.get(stationObjModel.getStationId());
+ if (stationProtocol == null) {
+ return false;
+ }
+
+ String response = wmsOperateUtils.applyReassignTaskLocNo(wrkMast.getWrkNo(), stationObjModel.getStationId());
+ if (response == null) {
+ News.taskError(wrkMast.getWrkNo(), "璇锋眰WMS閲嶆柊鍒嗛厤鍏ュ簱搴撲綅鎺ュ彛澶辫触锛屾帴鍙ｆ湭鍝嶅簲锛侊紒锛乺esponse锛歿}", response);
+ return false;
+ }
+
+ JSONObject jsonObject = JSON.parseObject(response);
+ if (jsonObject.getInteger("code").equals(200)) {
+ StartupDto dto = jsonObject.getObject("data", StartupDto.class);
+
+ String sourceLocNo = wrkMast.getLocNo();
+ String locNo = dto.getLocNo();
+
+ LocMast sourceLocMast = locMastService.queryByLoc(sourceLocNo);
+ if (sourceLocMast == null) {
+ News.taskInfo(wrkMast.getWrkNo(), "搴撲綅鍙�:{} 婧愬簱浣嶄俊鎭笉瀛樺湪", sourceLocNo);
+ return false;
+ }
+
+ if (!sourceLocMast.getLocSts().equals("S")) {
+ News.taskInfo(wrkMast.getWrkNo(), "搴撲綅鍙�:{} 婧愬簱浣嶇姸鎬佷笉澶勪簬鍏ュ簱棰勭害", sourceLocNo);
+ return false;
+ }
+
+ LocMast locMast = locMastService.queryByLoc(locNo);
+ if (locMast == null) {
+ News.taskInfo(wrkMast.getWrkNo(), "搴撲綅鍙�:{} 鐩爣搴撲綅淇℃伅涓嶅瓨鍦�", locNo);
+ return false;
+ }
+
+ if (!locMast.getLocSts().equals("O")) {
+ News.taskInfo(wrkMast.getWrkNo(), "搴撲綅鍙�:{} 鐩爣搴撲綅鐘舵�佷笉澶勪簬绌哄簱浣�", locNo);
+ return false;
+ }
+ //鏇存柊婧愬簱浣�
+ sourceLocMast.setLocSts("O");
+ sourceLocMast.setModiTime(new Date());
+ locMastService.updateById(sourceLocMast);
+
+ //鏇存柊鐩爣搴撲綅
+ locMast.setLocSts("S");
+ locMast.setModiTime(new Date());
+ locMastService.updateById(locMast);
+
+ //鏇存柊宸ヤ綔妗ｆ暟鎹�
+ wrkMast.setLocNo(locNo);
+ wrkMastService.updateById(wrkMast);
+ return true;
+ } else {
+ News.error("璇锋眰WMS鏇存崲鍙屽伐浣嶅簱浣嶆帴鍙ｅけ璐ワ紒锛侊紒response锛歿}", response);
+ }
+ return false;
+ }
+
}
--
Gitblit v1.9.1