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/entity/params/RCSTaskSubmitRequest.java | 69 +++++++++++++++++++++++
rsf-open-api/src/main/java/com/vincent/rsf/openApi/entity/params/RCSTargetRouteItem.java | 51 +++++++++++++++++
rsf-open-api/src/main/java/com/vincent/rsf/openApi/controller/MissionTransferStationController.java | 50 +++++++++++++++-
rsf-open-api/src/main/resources/application-dev.yml | 4
4 files changed, 167 insertions(+), 7 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());
}
}
+
}
diff --git a/rsf-open-api/src/main/java/com/vincent/rsf/openApi/entity/params/RCSTargetRouteItem.java b/rsf-open-api/src/main/java/com/vincent/rsf/openApi/entity/params/RCSTargetRouteItem.java
new file mode 100644
index 0000000..df90f48
--- /dev/null
+++ b/rsf-open-api/src/main/java/com/vincent/rsf/openApi/entity/params/RCSTargetRouteItem.java
@@ -0,0 +1,51 @@
+package com.vincent.rsf.openApi.entity.params;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+import java.util.List;
+
+@Schema(description = "鐩爣璺緞鐐癸紙targetRoute 鍗曟潯锛�")
+@Data
+public class RCSTargetRouteItem {
+
+ @Schema(description = "椤哄簭鍙�", example = "0")
+ private Integer seq;
+
+ @Schema(description = "鐐逛綅绫诲瀷棰勫埗鏋氫妇鍊硷細\n" +
+ "ZONE 鐩爣鎵�澶勫尯鍩熺紪鍙穃n" +
+ "SITE 绔欑偣鍒悕\n" +
+ "STORAGE 浠撲綅鍒悕\n" +
+ "MAT_LABEL 鐗╂枡鏍囩\n" +
+ "CARRIER 杞藉叿缂栧彿\n" +
+ "STACK 宸烽亾缂栧彿\n" +
+ "STACK_LABEL 宸烽亾鐗瑰緛鍊糪n" +
+ "CHANNEL 閫氶亾缂栧彿\n" +
+ "EQPT 澶栭儴璁惧\n" +
+ "PTL_WALL CTU 缂撳瓨鏋禱n" +
+ "CARRIER_TYPE 杞藉叿绫诲瀷\n" +
+ "BIN_TYPE 浠撲綅绫诲瀷\n" +
+ "AREA_STATION 鍖哄煙宸ヤ綔鍙癨n" +
+ "PILE_COUNT 涓�娆℃惉鍑犱釜\n" +
+ "MIX_CONDITION 鏉′欢缁勫悎 DEGREE 鐑害\n" +
+ "MULTI_BIN_GROUP 澶氭繁浣嶇粍鍙�", example = "ZONE", allowableValues = {"ZONE", "SITE"})
+ private String type;
+
+ @Schema(description = "鐐逛綅缂栫爜", example = "A1")
+ private String code;
+
+ @Schema(description = "鎿嶄綔绫诲瀷\n" +
+ "COLLECT 鍙栬揣\n" +
+ "DELIVERY 閫佽揣\n" +
+ "ROTATE 鏃嬭浆", example = "COLLECT", allowableValues = {"COLLECT", "DELIVERY"})
+ private String operation;
+
+ @Schema(description = "鏈哄櫒浜虹被鍨�")
+ private String robotType;
+
+ @Schema(description = "鎸囧畾鏈哄櫒浜虹紪鐮佸垪琛�")
+ private List<String> robotCode;
+
+ @Schema(description = "鎵╁睍淇℃伅")
+ private Object extra;
+}
diff --git a/rsf-open-api/src/main/java/com/vincent/rsf/openApi/entity/params/RCSTaskSubmitRequest.java b/rsf-open-api/src/main/java/com/vincent/rsf/openApi/entity/params/RCSTaskSubmitRequest.java
new file mode 100644
index 0000000..012aef4
--- /dev/null
+++ b/rsf-open-api/src/main/java/com/vincent/rsf/openApi/entity/params/RCSTaskSubmitRequest.java
@@ -0,0 +1,69 @@
+package com.vincent.rsf.openApi.entity.params;
+
+import com.alibaba.fastjson.JSON;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@Schema(description = "浠诲姟涓嬪彂璇锋眰锛�2.1.2 鍥芥爣锛�")
+@Data
+public class RCSTaskSubmitRequest {
+ @Schema(description = "浠诲姟绫诲瀷", example = "TRANSPORT")
+ private String taskType;
+
+ @Schema(description = "鐩爣璺緞鐐瑰垪琛�")
+ private List<RCSTargetRouteItem> targetRoute = new ArrayList<RCSTargetRouteItem>();
+
+ @Schema(description = "鍒濆浼樺厛绾�")
+ private Integer initPriority;
+
+ @Schema(description = "鎴鏃堕棿")
+ private String deadline;
+
+ @Schema(description = "鏈哄櫒浜虹被鍨�")
+ private String robotType;
+
+ @Schema(description = "鎸囧畾鏈哄櫒浜虹紪鐮佸垪琛�")
+ private List<String> robotCode;
+
+ @Schema(description = "鏄惁鍙腑鏂�")
+ private Integer interrupt;
+
+ @Schema(description = "鏈哄櫒浜轰换鍔＄紪鐮�", example = "tt13123123123")
+ private String robotTaskCode;
+
+ @Schema(description = "缁勭紪鐮�")
+ private String groupCode;
+
+ @Schema(description = "鎵╁睍淇℃伅锛堝 carrierInfo 绛夛級")
+ private Object extra;
+
+ public RCSTaskSubmitRequest() {
+
+ }
+
+ public RCSTaskSubmitRequest(MissionTaskIssueParam param) {
+ setTaskType("TRANSPORT");
+ setRobotTaskCode(param.getTaskNo());
+ /*鎵ц姝ラ*/
+ getTargetRoute().add(new RCSTargetRouteItem() {{
+ setSeq(0);//椤哄簭鍙�
+ setType("ZONE");
+ setCode("A1");
+ setOperation("COLLECT");
+ }});
+ getTargetRoute().add(new RCSTargetRouteItem() {{
+ setSeq(1);
+ setType("ZONE");
+ setCode("S001");
+ setOperation("DELIVERY");
+ }});
+
+ }
+ public String toJSONObject() {
+ return JSON.toJSONString(this);
+ }
+
+}
diff --git a/rsf-open-api/src/main/resources/application-dev.yml b/rsf-open-api/src/main/resources/application-dev.yml
index 4cee35b..ad49eca 100644
--- a/rsf-open-api/src/main/resources/application-dev.yml
+++ b/rsf-open-api/src/main/resources/application-dev.yml
@@ -73,9 +73,9 @@
#WCS閾炬帴
hk:
#閾炬帴
- host: http://127.0.0.1
+ host: http://192.168.4.197
#绔彛
- port: 9090
+ port: 9189
wms:
#閾炬帴
host: http://127.0.0.1
--
Gitblit v1.9.1