From ad67399e14815baa028564c0edce3fec3c414914 Mon Sep 17 00:00:00 2001
From: Junjie <540245094@qq.com>
Date: 星期四, 13 六月 2024 09:01:39 +0800
Subject: [PATCH] #

---
 zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/controller/OpenController.java |   16 ++++++++++------
 1 files changed, 10 insertions(+), 6 deletions(-)

diff --git a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/controller/OpenController.java b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/controller/OpenController.java
index 3e9339b..4862e33 100644
--- a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/controller/OpenController.java
+++ b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/controller/OpenController.java
@@ -11,6 +11,7 @@
 import com.zy.asrs.wcs.core.entity.Task;
 import com.zy.asrs.wcs.core.entity.TaskCtg;
 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.LocService;
 import com.zy.asrs.wcs.core.service.TaskCtgService;
@@ -55,7 +56,7 @@
     public R createInTask(@RequestBody CreateInTaskParam param) {
         //鑾峰彇鍏ュ簱浠诲姟绫诲瀷
         TaskCtg taskCtg = taskCtgService.getOne(new LambdaQueryWrapper<TaskCtg>()
-                .eq(TaskCtg::getFlag, "IN")
+                .eq(TaskCtg::getFlag, String.valueOf(TaskCtgType.IN))
                 .eq(TaskCtg::getStatus, 1));
         if (taskCtg == null) {
             return R.error("浠诲姟绫诲瀷寮傚父");
@@ -106,7 +107,7 @@
     public R createOutTask(@RequestBody CreateOutTaskParam param) {
         //鑾峰彇鍑哄簱浠诲姟绫诲瀷
         TaskCtg taskCtg = taskCtgService.getOne(new LambdaQueryWrapper<TaskCtg>()
-                .eq(TaskCtg::getFlag, "OUT")
+                .eq(TaskCtg::getFlag, String.valueOf(TaskCtgType.OUT))
                 .eq(TaskCtg::getStatus, 1));
         if (taskCtg == null) {
             return R.error("浠诲姟绫诲瀷寮傚父");
@@ -157,7 +158,7 @@
     public R createManualTakeTask(@RequestBody CreateManualTakeTaskParam param) {
         //鑾峰彇鎵嬪姩浠诲姟绫诲瀷
         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("浠诲姟绫诲瀷寮傚父");
@@ -199,7 +200,7 @@
     public R createMoveTask(@RequestBody CreateMoveTaskParam param) {
         //鑾峰彇鍑哄簱浠诲姟绫诲瀷
         TaskCtg taskCtg = taskCtgService.getOne(new LambdaQueryWrapper<TaskCtg>()
-                .eq(TaskCtg::getFlag, "MOVE")
+                .eq(TaskCtg::getFlag, String.valueOf(TaskCtgType.MOVE))
                 .eq(TaskCtg::getStatus, 1));
         if (taskCtg == null) {
             return R.error("浠诲姟绫诲瀷寮傚父");
@@ -218,7 +219,10 @@
             return R.error("绌挎杞︿笉鍦ㄧ嚎");
         }
         ShuttleProtocol shuttleProtocol = shuttleThread.getStatus();
-        if (Utils.getLev(shuttleProtocol.getCurrentLocNo()) != Utils.getLev(param.getDestSite())) {
+        if (shuttleProtocol == null) {
+            return R.error("绌挎杞︿笉鍦ㄧ嚎");
+        }
+        if (Utils.getLev(shuttleProtocol.getCurrentLocNo()) != Utils.getLev(param.getDestLoc())) {
             return R.error("绌挎杞﹀拰鐩爣浣嶇疆涓嶅湪鍚屼竴妤煎眰");
         }
 
@@ -236,7 +240,7 @@
         task.setPriority(priority);
         task.setOriginSite(null);
         task.setOriginLoc(null);
-        task.setDestSite(param.getDestSite());
+        task.setDestSite(param.getDestLoc());
         task.setDestLoc(null);
         task.setIoTime(new Date());
         task.setStartTime(new Date());

--
Gitblit v1.9.1