From 1d6c5111cf4aafc076aa3f8ddf488f6cc3cf6cb1 Mon Sep 17 00:00:00 2001
From: Junjie <xjj@123>
Date: 星期四, 13 二月 2025 16:56:11 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/controller/OpenController.java |   47 +++++++++++++++++++++++++++++++++++++++++------
 1 files changed, 41 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/OpenController.java b/src/main/java/com/zy/asrs/controller/OpenController.java
index da84136..f79b1d1 100644
--- a/src/main/java/com/zy/asrs/controller/OpenController.java
+++ b/src/main/java/com/zy/asrs/controller/OpenController.java
@@ -3,9 +3,7 @@
 import com.core.common.R;
 import com.zy.asrs.domain.NotifyDto;
 import com.zy.asrs.domain.enums.NotifyMsgType;
-import com.zy.asrs.domain.param.CancelTaskParam;
-import com.zy.asrs.domain.param.CompleteTaskParam;
-import com.zy.asrs.domain.param.CreateMoveTaskParam;
+import com.zy.asrs.domain.param.*;
 import com.zy.asrs.utils.NotifyUtils;
 import com.zy.common.service.CommonService;
 import com.zy.core.dispatcher.ShuttleDispatchUtils;
@@ -13,8 +11,6 @@
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
-
-import java.util.List;
 
 @Slf4j
 @RestController
@@ -38,6 +34,45 @@
             return R.ok();
         }
         return R.error("鐢熸垚澶辫触");
+    }
+
+    //绉诲簱浠诲姟
+    @PostMapping("/createLocMoveTask")
+    public R createLocMoveTask(@RequestBody CreateLocMoveTaskParam param) {
+        if (param == null) {
+            return R.error("鍙傛暟涓嶈兘涓虹┖");
+        }
+        boolean result = commonService.createLocMoveTask(param);
+        if (result) {
+            return R.ok();
+        }
+        return R.error("鐢熸垚绉诲簱浠诲姟澶辫触");
+    }
+
+    //鍏ュ簱浠诲姟
+    @PostMapping("/createInTask")
+    public R createInTask(@RequestBody CreateInTaskParam param) {
+        if (param == null) {
+            return R.error("鍙傛暟涓嶈兘涓虹┖");
+        }
+        boolean result = commonService.createInTask(param);
+        if (result) {
+            return R.ok();
+        }
+        return R.error("鐢熸垚鍏ュ簱浠诲姟澶辫触");
+    }
+
+    //鍑哄簱浠诲姟
+    @PostMapping("/createOutTask")
+    public R createOutTask(@RequestBody CreateOutTaskParam param) {
+        if (param == null) {
+            return R.error("鍙傛暟涓嶈兘涓虹┖");
+        }
+        boolean result = commonService.createOutTask(param);
+        if (result) {
+            return R.ok();
+        }
+        return R.error("鐢熸垚鍑哄簱浠诲姟澶辫触");
     }
 
     @PostMapping("/completeTask")
@@ -66,7 +101,7 @@
 
     @GetMapping("/test")
     public R test() {
-        notifyUtils.notify(String.valueOf(SlaveType.Shuttle), 1, "9999", NotifyMsgType.SHUTTLE_MOVING);
+        notifyUtils.notify("task", 1, "9999", NotifyMsgType.SHUTTLE_MOVING, "data");
         notifyUtils.notify(String.valueOf(SlaveType.Shuttle), 2, "9999", NotifyMsgType.SHUTTLE_MOVE_COMPLETE);
         return R.ok();
     }

--
Gitblit v1.9.1