From 6883e31331af4633d1b7d74ea7deb5f972afa05d Mon Sep 17 00:00:00 2001
From: skyouc
Date: 星期五, 23 五月 2025 20:02:19 +0800
Subject: [PATCH] 新增移库功能

---
 rsf-server/src/main/java/com/vincent/rsf/server/api/controller/WcsController.java |   41 +++++++++++++++++++++++++++++++++++++++--
 1 files changed, 39 insertions(+), 2 deletions(-)

diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/api/controller/WcsController.java b/rsf-server/src/main/java/com/vincent/rsf/server/api/controller/WcsController.java
index 53139af..f6b67dc 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/api/controller/WcsController.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/api/controller/WcsController.java
@@ -4,10 +4,11 @@
 import com.vincent.rsf.framework.common.R;
 import com.vincent.rsf.server.api.entity.dto.InTaskMsgDto;
 import com.vincent.rsf.server.api.controller.params.TaskInParam;
-import com.vincent.rsf.server.api.entity.enums.TaskType;
+import com.vincent.rsf.server.manager.enums.TaskType;
 import com.vincent.rsf.server.api.service.WcsService;
 import com.vincent.rsf.server.system.controller.BaseController;
 import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
@@ -22,7 +23,7 @@
     @Autowired
     private WcsService wcsService;
 
-//    @ApiOperation(value = "wcs鐢熸垚鍏ュ簱浠诲姟鎺ュ彛")
+    @ApiOperation(value = "wcs鐢熸垚鍏ュ簱浠诲姟鎺ュ彛")
     @PostMapping("/create/in/task")
     public R createInTask(@RequestBody TaskInParam param) {
         if (Cools.isEmpty(param.getIoType())) {
@@ -43,5 +44,41 @@
 
     }
 
+    @ApiOperation(value = "agv鍙栬揣瀹屾垚鎺ュ彛")
+    @PostMapping("/agv/pickUp/complete")
+    public R AgvTaskPickUpComplete(@RequestBody TaskInParam param) {
+        if (Cools.isEmpty(param.getIoType())) {
+            return R.error("鍏ュ嚭搴撶被鍨嬩笉鑳戒负绌�");
+        }
+        if (Cools.isEmpty(param.getSourceStaNo())) {
+            return R.error("婧愮珯缂栧彿涓嶈兘涓虹┖");
+        }
+        if (Cools.isEmpty(param.getBarcode())) {
+            return R.error("鏉$爜涓嶈兘涓虹┖");
+        }
+        if (!param.getIoType().equals(TaskType.TASK_TYPE_IN.type)) {
+            return R.error("鍏ュ簱绫诲瀷鏈夎");
+        }
+        wcsService.agvTaskPickUpComplete(param);
 
+        return R.ok();
+
+    }
+
+    /**
+     * 鎺ユ敹WCS璋冨害锛屽洖浼犳墽琛岀姸鎬�
+     *  //TODO 1. 鎷f枡鍑哄簱锛屽啀鍏ュ簱鎵ц锛屼慨鏀圭姸鎬佷负199.浠诲姟瀹屾垚  骞惰褰曞叆搴撶珯鐐癸紙婧愮珯鐐癸級锛屾坊鍔犱换鍔″彿鍙傛暟
+     *
+     * @param param
+     * @return
+     */
+    @ApiOperation("鎺ユ敹WCS璋冨害锛屽洖浼犳墽琛岀姸鎬�")
+    @PostMapping("/exce/status")
+    public R receiveTask(@RequestBody TaskInParam param) {
+        if (Cools.isEmpty(param)) {
+            return R.error("鍙傛暟涓嶈兘涓虹┖锛侊紒");
+        }
+
+        return R.ok();
+    }
 }

--
Gitblit v1.9.1