From d56b8093dc9e3e75f8efe1a0f1aa6d821c9c3dfb Mon Sep 17 00:00:00 2001
From: Junjie <xjj@123>
Date: 星期二, 15 四月 2025 13:30:35 +0800
Subject: [PATCH] #

---
 zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/kernel/AnalyzeService.java |   71 ++++++++++++++++-------------------
 1 files changed, 32 insertions(+), 39 deletions(-)

diff --git a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/kernel/AnalyzeService.java b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/kernel/AnalyzeService.java
index 8cf74c0..b0204ad 100644
--- a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/kernel/AnalyzeService.java
+++ b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/kernel/AnalyzeService.java
@@ -119,11 +119,6 @@
                 return motionList;
             }
 
-            BasConveyorSta basConveyorStaDest = basConveyorStaService.selectBySiteNo(task.getDestSite());
-            if (basConveyorStaDest == null) {
-                return motionList;
-            }
-
             //妫�娴嬬┛姊溅鏄惁鏈変换鍔$粦瀹�
             boolean shuttleResult = Utils.checkShuttleHasBinding(shuttleDevice, task.getTaskNo());
             if (shuttleResult) {
@@ -158,9 +153,9 @@
                             dto.setLiftNo(transferLiftDevice.getId().intValue());
                             dto.setLev(Utils.getLev(task.getDestLoc()));
                             dto.setStaNo(Integer.parseInt(task.getDestSite()));
-                            dto.setDevpNo(basConveyorStaDest.getConveyorDeviceId().intValue());
-                            dto.setReleaseLift(1);//鎵ц瀹屾垚鍚庨噴鏀炬彁鍗囨満
-                        }))
+//                            dto.setReleaseLift(1);//鎵ц瀹屾垚鍚庨噴鏀炬彁鍗囨満
+                        })),
+                        MotionCtgType.LIFT_WITH_GOODS_IN
                 ));
 
                 // 绌挎杞﹁蛋琛岃嚦鎻愬崌鏈哄簱浣�
@@ -197,6 +192,7 @@
                             dto.setShuttleDevice(shuttleDevice);
                             dto.setLiftNo(transferLiftDevice.getId().intValue());
                             dto.setLocNo(standbyLocNoTo);
+                            dto.setReleaseLift(1);//鎵ц瀹屾垚鍚庨噴鏀炬彁鍗囨満
                         })),
                         MotionCtgType.SHUTTLE_TRANSPORT
                 ));
@@ -268,8 +264,6 @@
                 return motionList;
             }
 
-
-
             //妫�娴嬬┛姊溅鏄惁鏈変换鍔$粦瀹�
             boolean shuttleResult = Utils.checkShuttleHasBinding(shuttleDevice, task.getTaskNo());
             if (shuttleResult) {
@@ -289,22 +283,14 @@
             //绌挎杞﹁繘鎻愬崌鏈哄緟鏈轰綅搴撲綅鍙� 杈撻�佺嚎浣嶇疆
             String standbyLocNoTo = shuttleStandbyTo.getDeviceStandbyLoc();
 
-            //绌挎杞︽崲灞傛椂寰呮満浣嶇疆 浣跨敤琛ㄥ垪 memo鏁版嵁
-            String standbyLocNoMemo = shuttleStandbyTo.getMemo();
+            //绌挎杞﹀緟鏈轰綅缃� 浣跨敤琛ㄥ垪
+            String standbyLocNoList = shuttleStandbyTo.getStandbyLoc();
 
             //鑾峰彇鍑哄簱浠诲姟绫诲瀷
             TaskCtg taskCtg = taskCtgService.getOne(new LambdaQueryWrapper<TaskCtg>()
                     .eq(TaskCtg::getFlag, String.valueOf(TaskCtgType.OUT))
                     .eq(TaskCtg::getStatus, 1));
             if (taskCtg == null) {
-                return motionList;
-            }
-            //鑾峰彇杈撻�佺嚎璺緞
-            BasConveyorPath basConveyorPath = basConveyorPathService.getOne(new LambdaQueryWrapper<BasConveyorPath>()
-                    .eq(BasConveyorPath::getDeviceStn, task.getOriginSite())
-                    .eq(BasConveyorPath::getDeviceNo, liftProtocol.getLiftNo())
-                    .eq(BasConveyorPath::getTypeNo, taskCtg.getId()));
-            if (basConveyorPath == null) {
                 return motionList;
             }
 
@@ -374,15 +360,16 @@
                             dto.setLocNo(standbyLocNoTo);
                             dto.setStaNo(getStaByLev(Utils.getLev(task.getOriginLoc())));//杈撻�佺珯
                         })),
-                        MotionCtgType.SHUTTLE_TRANSPORT_TO_CONVEYOR
+                        MotionCtgType.SHUTTLE_TRANSPORT
                 ));
 
+                Integer liftLevLogic = liftDispatcher.getLiftLevOffset(transferLiftDevice.getId().intValue(), Utils.getLev(originLoc));
                 // 鎻愬崌鏈虹┖杞界Щ鍔ㄥ埌鍑哄簱灞�
                 motionList.addAll(kernelService.liftMove(
                         null
                         , MotionDto.build((dto -> {
                             dto.setLiftNo(transferLiftDevice.getId().intValue());
-                            dto.setLev(Utils.getLev(originLoc));
+                            dto.setLev(liftLevLogic);
                         }))
                 ));
 
@@ -418,8 +405,8 @@
                         MotionDto.build((dto -> {
                             dto.setShuttleNo(shuttleDevice.getId().intValue());
                             dto.setShuttleDevice(shuttleDevice);
-                            dto.setLocNo(standbyLocNoTo);
-                            dto.setSync(0);//寮傛鎵ц
+                            dto.setLocNo(standbyLocNoList);
+//                            dto.setSync(0);//寮傛鎵ц
                             dto.setReleaseShuttle(1);//鎵ц瀹屾垚鍚庨噴鏀惧皬杞�
                         })),
                         MotionCtgType.SHUTTLE_MOVE_STANDBY
@@ -435,9 +422,9 @@
                         , MotionDto.build((dto -> {
                             dto.setLiftNo(transferLiftDevice.getId().intValue());
                             dto.setStaNo(Integer.parseInt(task.getDestSite()));//鍑哄簱绔欑偣
-                            dto.setDevpNo(basConveyorStaOrigin.getConveyorDeviceId().intValue());
                             dto.setReleaseLift(1);//鎵ц瀹屾垚鍚庨噴鏀炬彁鍗囨満
-                        }))
+                        })),
+                        MotionCtgType.LIFT_WITH_GOODS_OUT
                 ));
 
             }
@@ -499,14 +486,7 @@
                 return motionList;
             }
 
-
-
             String shuttleLocNo = shuttleProtocol.getCurrentLocNo();
-
-            BasConveyorSta basConveyorStaDest = basConveyorStaService.selectBySiteNo(task.getDestSite());
-            if (basConveyorStaDest == null) {
-                return motionList;
-            }
 
             //妫�娴嬬┛姊溅鏄惁鏈変换鍔$粦瀹�
             boolean shuttleResult = Utils.checkShuttleHasBinding(shuttleDevice, task.getTaskNo());
@@ -607,6 +587,14 @@
                 return motionList;//鏈垎鏋愭垚鍔�
             }
 
+            //鑾峰彇灏忚溅寰呮満搴撲綅 ==> 杩涙彁鍗囨満
+            ShuttleStandby shuttleStandbyTo = shuttleStandbyService.getOne(new LambdaQueryWrapper<ShuttleStandby>()
+                    .eq(ShuttleStandby::getDeviceLev, Utils.getLev(shuttleLocNo))
+                    .eq(ShuttleStandby::getStatus, 1));
+
+            //绌挎杞﹀緟鏈轰綅缃� 浣跨敤琛ㄥ垪
+            String standbyLocNoList = shuttleStandbyTo.getStandbyLoc();
+
             String standbyLocNo;
             if (originSite == 1015) {
                 standbyLocNo = "1200101";
@@ -696,8 +684,8 @@
                         MotionDto.build((dto -> {
                             dto.setShuttleNo(shuttleDevice.getId().intValue());
                             dto.setShuttleDevice(shuttleDevice);
-                            dto.setLocNo(standbyLocNo);
-                            dto.setSync(0);//寮傛鎵ц
+                            dto.setLocNo(standbyLocNoList);
+//                            dto.setSync(0);//寮傛鎵ц
                             dto.setReleaseShuttle(1);//鎵ц瀹屾垚鍚庨噴鏀惧皬杞�
                         })),
                         MotionCtgType.SHUTTLE_MOVE_STANDBY
@@ -1223,12 +1211,13 @@
         if (destSite.equals("move")) {
             //鎻愬崌鏈哄崌闄嶆ゼ灞�
 
+            Integer liftLevLogic = liftDispatcher.getLiftLevOffset(device.getId().intValue(), Integer.parseInt(task.getDestLoc()));
             // 鎻愬崌鏈虹┖杞界Щ鍔ㄥ埌绌挎杞﹀眰
             motionList.addAll(kernelService.liftMove(
                     null
                     , MotionDto.build((dto -> {
                         dto.setLiftNo(device.getId().intValue());
-                        dto.setLev(Integer.parseInt(task.getDestLoc()));
+                        dto.setLev(liftLevLogic);
                     }))
             ));
 
@@ -1240,19 +1229,23 @@
                 return motionList;
             }
 
+            Integer originLev = liftDispatcher.getLiftLevOffset(device.getId().intValue(), Utils.getLev(basConveyorStaOrigin.getLocNo()));
+            Integer targetLev = liftDispatcher.getLiftLevOffset(device.getId().intValue(), Utils.getLev(basConveyorStaDest.getLocNo()));
+
             // 鎻愬崌鏈虹Щ鍔ㄦ墭鐩�
             motionList.addAll(kernelService.liftMoveGoods(
                     MotionDto.build((dto -> {
                         dto.setLiftNo(device.getId().intValue());
-                        dto.setLev(Utils.getLev(basConveyorStaOrigin.getLocNo()));
+                        dto.setLev(originLev);
                         dto.setStaNo(Integer.parseInt(task.getOriginSite()));
                     }))
                     , MotionDto.build((dto -> {
                         dto.setLiftNo(device.getId().intValue());
-                        dto.setLev(Utils.getLev(basConveyorStaDest.getLocNo()));
+                        dto.setLev(targetLev);
                         dto.setDevpNo(basConveyorStaDest.getConveyorDeviceId().intValue());
                         dto.setStaNo(Integer.parseInt(task.getDestSite()));
-                    }))
+                    })),
+                    MotionCtgType.LIFT_WITH_GOODS
             ));
 
         } else if (destSite.equals("lock")) {

--
Gitblit v1.9.1