From e29a9f245ff4e57a40bbab1c0acc3cbc31d3ac2b Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期一, 21 四月 2025 11:13:13 +0800
Subject: [PATCH] #出库找待机位优化

---
 zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/controller/BasShuttleController.java |   48 +++++++++++++++++++++++++++++++++++-------------
 1 files changed, 35 insertions(+), 13 deletions(-)

diff --git a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/controller/BasShuttleController.java b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/controller/BasShuttleController.java
index 8255384..0433698 100644
--- a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/controller/BasShuttleController.java
+++ b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/controller/BasShuttleController.java
@@ -2,7 +2,6 @@
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
-import com.zy.asrs.framework.common.BaseRes;
 import com.zy.asrs.framework.common.Cools;
 import com.zy.asrs.framework.common.R;
 import com.zy.asrs.framework.common.SnowflakeIdWorker;
@@ -18,6 +17,7 @@
 import com.zy.asrs.wcs.core.entity.TaskCtg;
 import com.zy.asrs.wcs.core.kernel.AnalyzeService;
 import com.zy.asrs.wcs.core.model.enums.DeviceCtgType;
+import com.zy.asrs.wcs.core.model.enums.TaskCtgType;
 import com.zy.asrs.wcs.core.model.enums.TaskStsType;
 import com.zy.asrs.wcs.core.service.BasShuttleService;
 import com.zy.asrs.wcs.core.service.MotionService;
@@ -27,7 +27,6 @@
 import com.zy.asrs.wcs.rcs.News;
 import com.zy.asrs.wcs.rcs.cache.SlaveConnection;
 import com.zy.asrs.wcs.rcs.entity.Device;
-import com.zy.asrs.wcs.rcs.entity.DeviceType;
 import com.zy.asrs.wcs.rcs.model.enums.SlaveType;
 import com.zy.asrs.wcs.rcs.model.protocol.ShuttleProtocol;
 import com.zy.asrs.wcs.rcs.service.DeviceService;
@@ -142,9 +141,9 @@
 
         Integer shuttleNo = param.getShuttleNo();
 
-        //鑾峰彇杩佺Щ浠诲姟绫诲瀷
+        //鑾峰彇鎵嬪姩浠诲姟绫诲瀷
         TaskCtg taskCtg = taskCtgService.getOne(new LambdaQueryWrapper<TaskCtg>()
-                .eq(TaskCtg::getFlag, "MANUAL")
+                .eq(TaskCtg::getFlag, String.valueOf(TaskCtgType.MANUAL))
                 .eq(TaskCtg::getStatus, 1));
         if (taskCtg == null) {
             return R.error();
@@ -194,6 +193,10 @@
         task.setStatus(1);
         task.setMemo("manual");
         task.setShuttleNo(param.getShuttleNo());
+
+        if (param.getShuttleTaskMode().equals("takeMove")) {
+            task.setRecordLoc("Y");//璁板綍搴撳瓨淇℃伅
+        }
         boolean result = taskService.save(task);
         if (!result) {
             return R.error();
@@ -220,7 +223,6 @@
     //璺戝簱绯荤粺
     @PreAuthorize("hasAuthority('core:basShuttle:operator')")
     @PostMapping("/basShuttle/moveLoc")
-    @Transactional
     public synchronized R shuttleMoveLoc(@RequestBody ShuttleMoveLocParam param) {
         Device device = deviceService.getOne(new LambdaQueryWrapper<Device>()
                 .eq(Device::getDeviceType, DeviceCtgType.SHUTTLE.val())
@@ -245,14 +247,34 @@
             return R.error("灏忚溅蹇欑涓�");
         }
 
-        shuttleProtocol.setMoveLoc(true);//寮�鍚窇搴�
-        shuttleProtocol.setMoveType(param.getMoveType());
-        shuttleProtocol.setXStart(param.getStartX());
-        shuttleProtocol.setXTarget(param.getTargetX());
-        shuttleProtocol.setXCurrent(param.getStartX());
-        shuttleProtocol.setYStart(param.getStartY());
-        shuttleProtocol.setYTarget(param.getTargetY());
-        shuttleProtocol.setYCurrent(param.getStartY());
+        shuttleThread.enableMoveLoc(param, true);
+        return R.ok();
+    }
+
+    //璺戝簱绯荤粺鍏抽棴
+    @PreAuthorize("hasAuthority('core:basShuttle:operator')")
+    @PostMapping("/basShuttle/moveLocClose")
+    public synchronized R shuttleMoveLocClose(@RequestBody ShuttleMoveLocParam param) {
+        Device device = deviceService.getOne(new LambdaQueryWrapper<Device>()
+                .eq(Device::getDeviceType, DeviceCtgType.SHUTTLE.val())
+                .eq(Device::getStatus, 1)
+                .eq(Device::getHostId, getHostId())
+                .eq(Device::getDeviceNo, param.getShuttleNo()));
+        if (device == null) {
+            return R.error();
+        }
+
+        ShuttleThread shuttleThread = (ShuttleThread) SlaveConnection.get(SlaveType.Shuttle, device.getId().intValue());
+        if (shuttleThread == null) {
+            return R.error();
+        }
+
+        ShuttleProtocol shuttleProtocol = shuttleThread.getStatus();
+        if (shuttleProtocol == null) {
+            return R.error();
+        }
+
+        shuttleThread.enableMoveLoc(null, false);
         return R.ok();
     }
 

--
Gitblit v1.9.1