From 64c076641c56b857fa78f6d9401f070591094569 Mon Sep 17 00:00:00 2001
From: 1 <1@123>
Date: 星期五, 27 二月 2026 15:18:59 +0800
Subject: [PATCH] lsh#wcs2.0交互下发

---
 rsf-open-api/src/main/java/com/vincent/rsf/openApi/controller/MissionTransferStationController.java |   48 ++++++++++++++++++++++++++++++++++++++++++------
 1 files changed, 42 insertions(+), 6 deletions(-)

diff --git a/rsf-open-api/src/main/java/com/vincent/rsf/openApi/controller/MissionTransferStationController.java b/rsf-open-api/src/main/java/com/vincent/rsf/openApi/controller/MissionTransferStationController.java
index 4e51c61..eff2d5f 100644
--- a/rsf-open-api/src/main/java/com/vincent/rsf/openApi/controller/MissionTransferStationController.java
+++ b/rsf-open-api/src/main/java/com/vincent/rsf/openApi/controller/MissionTransferStationController.java
@@ -1,9 +1,15 @@
 package com.vincent.rsf.openApi.controller;
 
+import com.vincent.rsf.framework.common.Cools;
+import com.vincent.rsf.framework.common.R;
 import com.vincent.rsf.openApi.entity.dto.CommonResponse;
+import com.vincent.rsf.openApi.entity.params.MissionTaskIssueParam;
+import com.vincent.rsf.openApi.enums.MissionSystemCodeEnum;
+import com.vincent.rsf.openApi.service.WmsWcsService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
@@ -15,13 +21,43 @@
 @RequestMapping("/mission")
 public class MissionTransferStationController {
 
+    @Autowired
+    private WmsWcsService wmsWcsService;
+
     @ApiOperation("浠诲姟鎬绘帶")
     @PostMapping("/task/master/control")
-    public CommonResponse missionMasterControl(@RequestBody Object objParams) {
-        System.out.println("111");
-        //鍒ゆ柇闇�瑕佷笅鍙戠郴缁�
-        //鍒ゆ柇涓嬪彂鏂瑰紡
-        //杩斿洖缁撴灉
-        return CommonResponse.ok();
+    public CommonResponse missionMasterControl(@RequestBody MissionTaskIssueParam param) {
+        try{
+            if (Cools.isEmpty(param)){
+                return CommonResponse.error("鍙傛暟涓虹┖锛侊紒锛�");
+            }
+            //鍒ゆ柇闇�瑕佷笅鍙戠郴缁�
+            if (param.getSystemCode().equals(MissionSystemCodeEnum.MISSION_SYSTEM_CODE_ENUM_HK_RCS_YZ_5.type)){
+                //杞捣搴蜂笅鍙戠▼搴�
+//                R r = wmsWcsService.issueTaskWcs(param);
+//                if (!r.get("code").equals(200)){
+//                    return CommonResponse.error(""+r.get("msg"));
+//                }
+            } else if (param.getSystemCode().equals(MissionSystemCodeEnum.MISSION_SYSTEM_CODE_ENUM_ZY_WCS_TWO.type)){
+                //杞瑆cs涓嬪彂绋嬪簭
+                R r = wmsWcsService.issueTaskWcs(param);
+                if (!r.get("code").equals(200)){
+                    return CommonResponse.error(""+r.get("msg"));
+                }
+            } else if (param.getSystemCode().equals(MissionSystemCodeEnum.MISSION_SYSTEM_CODE_ENUM_WEIGHING_YZ_5.type)){
+                //杞О閲�
+//                R r = wmsWcsService.issueTaskWcs(param);
+//                if (!r.get("code").equals(200)){
+//                    return CommonResponse.error(""+r.get("msg"));
+//                }
+            } else {
+                return CommonResponse.error("鏈煡绯荤粺绫诲瀷");
+            }
+            //鍒ゆ柇涓嬪彂鏂瑰紡
+            //杩斿洖缁撴灉
+            return CommonResponse.ok();
+        } catch (Exception e){
+            return CommonResponse.error(e.getMessage());
+        }
     }
 }

--
Gitblit v1.9.1