From 3b41ed73cd464ae2bad44598e6f0b522fc50e886 Mon Sep 17 00:00:00 2001
From: cl <1442464845@qq.com>
Date: 星期二, 17 三月 2026 12:53:42 +0800
Subject: [PATCH] 海康发送模拟
---
rsf-open-api/src/main/java/com/vincent/rsf/openApi/controller/MissionTransferStationController.java | 50 +++++++++++++++++++++++++++++++++++++++++++++-----
1 files changed, 45 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 eff2d5f..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,19 +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("浠诲姟涓浆绔�")
@@ -24,6 +32,13 @@
@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 MissionTaskIssueParam param) {
@@ -33,11 +48,35 @@
}
//鍒ゆ柇闇�瑕佷笅鍙戠郴缁�
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"));
-// }
+ 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);
@@ -60,4 +99,5 @@
return CommonResponse.error(e.getMessage());
}
}
+
}
--
Gitblit v1.9.1