From d62c5c0eb2e28b7bf27d23de84a609b5a2e415e4 Mon Sep 17 00:00:00 2001
From: Junjie <xjj@123>
Date: 星期四, 17 十月 2024 18:48:00 +0800
Subject: [PATCH] #

---
 zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/controller/BasShuttleController.java |   24 +++++++++++++++++++++---
 1 files changed, 21 insertions(+), 3 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 d248998..62f5e5e 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
@@ -17,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;
@@ -142,7 +143,7 @@
 
         //鑾峰彇鎵嬪姩浠诲姟绫诲瀷
         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();
@@ -175,6 +176,23 @@
 
             shuttleThread.reset(null);
             return R.ok();
+        } else if (param.getShuttleTaskMode().equals("requestWaiting")) {
+            //鐢宠纭
+            Device device = deviceService.getOne(new LambdaQueryWrapper<Device>()
+                    .eq(Device::getDeviceType, DeviceCtgType.SHUTTLE.val())
+                    .eq(Device::getStatus, 1)
+                    .eq(Device::getDeviceNo, shuttleNo));
+            if (device == null) {
+                return R.error("璁惧涓嶅瓨鍦�");
+            }
+
+            ShuttleThread shuttleThread = (ShuttleThread) SlaveConnection.get(SlaveType.Shuttle, device.getId().intValue());
+            if (shuttleThread == null) {
+                return R.error("璁惧绂荤嚎");
+            }
+
+            shuttleThread.requestWaiting();
+            return R.ok();
         }
 
         Task task = new Task();
@@ -185,12 +203,12 @@
         task.setPriority(10);
         task.setOriginSite(null);
         task.setOriginLoc(sourceLoc);
-        task.setDestSite(targetSite);
+        task.setDestSite(null);
         task.setDestLoc(targetLoc);
         task.setIoTime(new Date());
         task.setStartTime(new Date());
         task.setStatus(1);
-        task.setMemo("manual");
+        task.setMemo(targetSite);
         task.setShuttleNo(param.getShuttleNo());
 
         if (param.getShuttleTaskMode().equals("takeMove")) {

--
Gitblit v1.9.1