From 12d9f4e03c0331efc9a656356e78b9f314639707 Mon Sep 17 00:00:00 2001
From: 1 <1@123>
Date: 星期三, 18 三月 2026 17:07:57 +0800
Subject: [PATCH] lsh#
---
rsf-open-api/src/main/java/com/vincent/rsf/openApi/controller/MissionTransferStationController.java | 87 +++++++++++++++++++++++++++++++++++++++++--
1 files changed, 82 insertions(+), 5 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 ffb17c2..1d0dd98 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,13 +1,27 @@
package com.vincent.rsf.openApi.controller;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+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.entity.params.RCSTaskSubmitRequest;
+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.beans.factory.annotation.Value;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.client.RestTemplate;
@RestController
@Api("浠诲姟涓浆绔�")
@@ -15,12 +29,75 @@
@RequestMapping("/mission")
public class MissionTransferStationController {
+ @Autowired
+ private WmsWcsService wmsWcsService;
+
+ private final RestTemplate restTemplate = new RestTemplate();
+
+ @Value("${platform.hk.host}")
+ private String hkHost;
+ @Value("${platform.hk.port}")
+ private String hkPort;
+
@ApiOperation("浠诲姟鎬绘帶")
@PostMapping("/task/master/control")
- public CommonResponse missionMasterControl(@RequestBody Object objParams) {
- //鍒ゆ柇闇�瑕佷笅鍙戠郴缁�
- //鍒ゆ柇涓嬪彂鏂瑰紡
- //杩斿洖缁撴灉
- 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)){
+ HttpHeaders headers = new HttpHeaders();
+ headers.setContentType(MediaType.APPLICATION_JSON);
+ String url = hkHost + ":" + hkPort + "/rcs/rtas/api/robot/controller/task/submit";
+ RCSTaskSubmitRequest body = new RCSTaskSubmitRequest(param);
+ String reqJson = body.toJSONObject();
+ try {
+ HttpEntity<RCSTaskSubmitRequest> entity = new HttpEntity<>(body, headers);
+ String resp = restTemplate.postForObject(url, entity, String.class);
+ JSONObject respJson = (resp != null && !resp.isEmpty()) ? JSON.parseObject(resp) : null;
+ log.info("url:{}, 璇锋眰鍙傛暟:{}, 杩斿洖:{}", url, reqJson, respJson);
+ /* 娴峰悍杩斿洖渚嬪瓙:
+ {
+
+ "code": "SUCCESS",
+ "message": "鎴愬姛",
+ "data": {
+ "robotTaskCode": "13123123123",
+ "extra": null
+ }
+ }*/
+ if (respJson != null && "SUCCESS".equals(respJson.getString("code"))){
+ return CommonResponse.ok(respJson.getJSONObject("data"));
+ }
+ String msg = respJson != null ? respJson.getString("message") : "RCS杩斿洖寮傚父";
+ return CommonResponse.error(msg != null ? msg : "RCS杩斿洖寮傚父");
+ } catch (Exception e) {
+ log.error("RCS浠诲姟涓嬪彂璇锋眰寮傚父, url:{}, {}", url, e.getMessage(), e);
+ return CommonResponse.error("RCS鏈嶅姟璁块棶寮傚父: " + e.getMessage());
+ }
+ } 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