From 7d149dff1368a45cf6a10856752de6e9f204f135 Mon Sep 17 00:00:00 2001
From: chen.lin <1442464845@qq.com>
Date: 星期二, 10 二月 2026 14:49:32 +0800
Subject: [PATCH] http请求泛型处理
---
rsf-open-api/src/main/java/com/vincent/rsf/openApi/service/impl/WmsRcsServiceImpl.java | 20 +++++++++++++++-----
1 files changed, 15 insertions(+), 5 deletions(-)
diff --git a/rsf-open-api/src/main/java/com/vincent/rsf/openApi/service/impl/WmsRcsServiceImpl.java b/rsf-open-api/src/main/java/com/vincent/rsf/openApi/service/impl/WmsRcsServiceImpl.java
index ed3f4f3..1a0bb6e 100644
--- a/rsf-open-api/src/main/java/com/vincent/rsf/openApi/service/impl/WmsRcsServiceImpl.java
+++ b/rsf-open-api/src/main/java/com/vincent/rsf/openApi/service/impl/WmsRcsServiceImpl.java
@@ -50,7 +50,17 @@
@Autowired
private RestTemplate restTemplate;
-
+ /**
+ * 鑾峰彇 WMS 鍩虹 URL锛坔ost:port锛夛紝鏈厤缃椂鎶涘嚭寮傚父锛岄伩鍏嶄骇鐢� null:null 瀵艰嚧 URISyntaxException銆�
+ */
+ private String getWmsBaseUrl() {
+ if (wmsApi == null || wmsApi.getHost() == null || wmsApi.getHost().isEmpty()
+ || wmsApi.getPort() == null || wmsApi.getPort().isEmpty()) {
+ log.error("WMS鍦板潃鏈厤缃�傝鍦ㄩ厤缃枃浠朵腑璁剧疆 platform.wms.host 涓� platform.wms.port");
+ throw new CoolException("WMS鍥炶皟鍦板潃鏈厤缃紝璇烽厤缃� platform.wms.host 鍜� platform.wms.port");
+ }
+ return wmsApi.getHost() + ":" + wmsApi.getPort();
+ }
/**
* @author Ryan
@@ -213,7 +223,7 @@
log.warn("RCS鍥炶皟浜嬩欢鍙傛暟eventType涓虹┖锛佸畬鏁村弬鏁帮細{}", JSONObject.toJSONString(params));
}
- String callUrl = wmsApi.getHost() + ":" + wmsApi.getPort() + WmsConstant.callBack;
+ String callUrl = getWmsBaseUrl() + WmsConstant.callBack;
/**WMS鍩虹閰嶇疆閾炬帴*/
log.info("浠诲姟鎵ц鐘舵�佷笂鎶ワ紝璇锋眰鍦板潃锛� {}锛� 璇锋眰鍙傛暟锛� {}", callUrl , JSONObject.toJSONString(params));
HttpHeaders headers = new HttpHeaders();
@@ -364,8 +374,8 @@
exMsgParams.put("robotCode", null);
exMsgParams.put("zpallet", null);
- // 灏嗕换鍔′笂鎶ュ洖璋冭浆鍙戝埌WMS绯荤粺
- String callUrl = wmsApi.getHost() + ":" + wmsApi.getPort() + WmsConstant.callBack;
+ // 灏嗕换鍔′笂鎶ュ洖璋冭浆鍙戝埌WMS绯荤粺锛堥渶閰嶇疆 platform.wms.host 涓� platform.wms.port锛�
+ String callUrl = getWmsBaseUrl() + WmsConstant.callBack;
log.info("RCS鍥炶皟-WMS-SERVER浠诲姟涓婃姤-锛岃姹傚湴鍧�锛� {}锛� 杞崲鍚庡弬鏁帮細 {}", callUrl, exMsgParams.toJSONString());
HttpHeaders headers = new HttpHeaders();
headers.add("Content-Type", "application/json");
@@ -419,7 +429,7 @@
log.info("鏂欑鐮侊細{}锛屽叆搴撶珯鐐癸細{}锛屽叆搴撶被鍨嬶細{}", params.getBarcode(), params.getStaNo(), params.getType());
// 璋冪敤WMS server鍐呴儴鎺ュ彛杩涜搴撲綅鍒嗛厤
- String wmsUrl = wmsApi.getHost() + ":" + wmsApi.getPort() + "/rsf-server/wcs/allocate/location";
+ String wmsUrl = getWmsBaseUrl() + "/rsf-server/wcs/allocate/location";
log.info("WMS璇锋眰鍦板潃锛歿}", wmsUrl);
// 鏋勫缓璇锋眰鍙傛暟
--
Gitblit v1.9.1