From 8f8b6a47ce277cad0b640c328ab3962419e1c024 Mon Sep 17 00:00:00 2001
From: chen.lin <1442464845@qq.com>
Date: 星期五, 06 二月 2026 13:00:47 +0800
Subject: [PATCH] RCS完整流程
---
rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/TaskServiceImpl.java | 191 +++++++++++++++++++++++++++--------------------
1 files changed, 109 insertions(+), 82 deletions(-)
diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/TaskServiceImpl.java b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/TaskServiceImpl.java
index d653a6a..610b525 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/TaskServiceImpl.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/TaskServiceImpl.java
@@ -1516,26 +1516,23 @@
@Override
@Transactional(rollbackFor = Exception.class)
public void pubTaskToWcs(List<Task> tasks) {
- WcsTaskParams taskParams = new WcsTaskParams();
- List<TaskItemParam> items = new ArrayList<>();
+ /**浠诲姟涓嬪彂鎺ュ彛*/
+ String pubTakUrl = rcsApi.getHost() + ":" + rcsApi.getPort() + RcsConstant.pubTask;
- // 璁剧疆鎵规缂栧彿锛堜娇鐢ㄧ涓�涓换鍔＄殑barcode锛屽鏋滀负null鍒欎娇鐢ㄤ换鍔＄紪鐮侊級
- String batchNo = null;
- if (!tasks.isEmpty()) {
- Task firstTask = tasks.get(0);
- batchNo = StringUtils.isNotBlank(firstTask.getBarcode())
- ? firstTask.getBarcode()
- : firstTask.getTaskCode();
- }
- if (StringUtils.isBlank(batchNo)) {
- // 濡傛灉鎵规缂栧彿浠嶄负绌猴紝鐢熸垚涓�涓粯璁ゅ��
- batchNo = "BATCH_" + System.currentTimeMillis();
- }
-
- taskParams.setBatchNo(batchNo);
- log.info("璁剧疆鎵规缂栧彿锛歿}", batchNo);
-
- tasks.forEach(task -> {
+ for (Task task : tasks) {
+ WcsTaskParams taskParams = new WcsTaskParams();
+ List<TaskItemParam> items = new ArrayList<>();
+
+ // 璁剧疆鎵规缂栧彿锛堜娇鐢ㄥ綋鍓嶄换鍔＄殑浠诲姟缂栫爜锛�
+ String batchNo = task.getTaskCode();
+ if (StringUtils.isBlank(batchNo)) {
+ // 濡傛灉浠诲姟缂栧彿涓虹┖锛岀敓鎴愪竴涓粯璁ゅ��
+ batchNo = "BATCH_" + System.currentTimeMillis();
+ }
+ taskParams.setBatchNo(batchNo);
+ log.info("浠诲姟鎵规缂栧彿锛歿}", batchNo);
+
+ // 鏋勫缓褰撳墠浠诲姟鐨勫弬鏁�
TaskItemParam itemParam = new TaskItemParam();
//浠诲姟缂栫爜锛堝搴攕eqNum锛�
itemParam.setTaskNo(task.getTaskCode());
@@ -1597,58 +1594,91 @@
throw new CoolException("褰撳墠绔欑偣涓嶆槸F.鍦ㄥ簱鐘舵�侊紒锛�");
}
}
- if (station.getType().equals(StationTypeEnum.STATION_TYPE_NORMAL.type)) {
- if (!station.getUseStatus().equals(LocStsType.LOC_STS_TYPE_O.type)) {
+ // 绔欑偣闂寸Щ搴撻渶瑕佽幏鍙栫洰鏍囩珯鐐�
+ BasStation targetStation = basStationService.getOne(new LambdaQueryWrapper<BasStation>().eq(BasStation::getStationName, task.getTargSite()));
+ if (Objects.isNull(targetStation)) {
+ throw new CoolException("鐩爣绔欑偣涓嶅瓨鍦紒锛�");
+ }
+ if (targetStation.getType().equals(StationTypeEnum.STATION_TYPE_NORMAL.type)) {
+ if (!targetStation.getUseStatus().equals(LocStsType.LOC_STS_TYPE_O.type)) {
throw new CoolException("鐩爣绔欑偣涓嶆槸O.绌洪棽鐘舵�侊紒锛�");
}
}
}
items.add(itemParam);
- });
- taskParams.setTasks(items);
- /**浠诲姟涓嬪彂鎺ュ彛*/
- String pubTakUrl = rcsApi.getHost() + ":" + rcsApi.getPort() + RcsConstant.pubTask;
- /**RCS鍩虹閰嶇疆閾炬帴*/
- log.info("========== 寮�濮嬩笅鍙戜换鍔″埌RCS ==========");
- log.info("RCS璇锋眰鍦板潃锛歿}", pubTakUrl);
- log.info("鎵规缂栧彿锛歿}", batchNo);
- log.info("浠诲姟鏁伴噺锛歿}", tasks.size());
- log.info("浠诲姟鍒楄〃璇︽儏锛�");
- tasks.forEach(task -> {
- log.info(" - 浠诲姟缂栫爜锛歿}锛屼换鍔＄被鍨嬶細{}锛屾簮搴撲綅锛歿}锛岀洰鏍囧簱浣嶏細{}锛屾簮绔欑偣锛歿}锛岀洰鏍囩珯鐐癸細{}",
+ taskParams.setTasks(items);
+
+ // 璁板綍褰撳墠浠诲姟淇℃伅
+ log.info(" RCS- 浠诲姟缂栫爜锛歿}锛屼换鍔＄被鍨嬶細{}锛屾簮搴撲綅锛歿}锛岀洰鏍囧簱浣嶏細{}锛屾簮绔欑偣锛歿}锛岀洰鏍囩珯鐐癸細{}",
task.getTaskCode(), task.getTaskType(), task.getOrgLoc(),
task.getTargLoc(), task.getOrgSite(), task.getTargSite());
- });
- log.info("璇锋眰鍙傛暟锛歿}", JSONObject.toJSONString(taskParams));
- HttpHeaders headers = new HttpHeaders();
- headers.add("Content-Type", "application/json");
- headers.add("api-version", "v2.0");
- HttpEntity httpEntity = new HttpEntity(taskParams, headers);
- long startTime = System.currentTimeMillis();
- ResponseEntity<String> exchange = restTemplate.exchange(pubTakUrl, HttpMethod.POST, httpEntity, String.class);
- long endTime = System.currentTimeMillis();
- log.info("RCS鍝嶅簲鑰楁椂锛歿}ms", (endTime - startTime));
- log.info("RCS鍝嶅簲鐘舵�佺爜锛歿}", exchange.getStatusCode());
- log.info("RCS鍝嶅簲澶达細{}", exchange.getHeaders());
- log.info("RCS鍝嶅簲浣擄細{}", exchange.getBody());
- if (Objects.isNull(exchange.getBody())) {
- log.error("========== RCS浠诲姟涓嬪彂澶辫触 ==========");
- log.error("RCS鍝嶅簲浣撲负绌猴紝鏃犳硶瑙ｆ瀽鍝嶅簲缁撴灉");
- log.error("璇锋眰鍦板潃锛歿}", pubTakUrl);
- log.error("璇锋眰鍙傛暟锛歿}", JSONObject.toJSONString(taskParams));
- throw new CoolException("浠诲姟涓嬪彂澶辫触锛孯CS鍝嶅簲浣撲负绌猴紒锛�");
- } else {
+ log.info("RCS-璇锋眰鍙傛暟锛歿}", JSONObject.toJSONString(taskParams));
+
+ // 鍙戦�佸綋鍓嶄换鍔�
+ HttpHeaders headers = new HttpHeaders();
+ headers.add("Content-Type", "application/json");
+ headers.add("api-version", "v2.0");
+ HttpEntity httpEntity = new HttpEntity(taskParams, headers);
+
+ /**RCS鍩虹閰嶇疆閾炬帴*/
+ log.info("========== 寮�濮嬩笅鍙戜换鍔″埌RCS ==========");
+ log.info("璇锋眰RCS-鍦板潃锛歿}", pubTakUrl);
+ log.info("璇锋眰RCS-鍙傛暟锛歿}", JSONObject.toJSONString(taskParams));
+ long startTime = System.currentTimeMillis();
+ ResponseEntity<String> exchange = null;
try {
- ObjectMapper objectMapper = new ObjectMapper();
- objectMapper.coercionConfigDefaults()
- .setCoercion(CoercionInputShape.EmptyString, CoercionAction.AsEmpty);
- CommonResponse result = objectMapper.readValue(exchange.getBody(), CommonResponse.class);
- log.info("RCS鍝嶅簲瑙ｆ瀽缁撴灉 - code锛歿}锛宮sg锛歿}锛宒ata锛歿}",
- result.getCode(), result.getMsg(), result.getData());
- if (result.getCode() == 200) {
- log.info("RCS浠诲姟涓嬪彂鎴愬姛锛屽紑濮嬫洿鏂颁换鍔＄姸鎬�");
- tasks.forEach(task -> {
- log.info("鏇存柊浠诲姟鐘舵�� - 浠诲姟缂栫爜锛歿}锛屼换鍔＄被鍨嬶細{}", task.getTaskCode(), task.getTaskType());
+ exchange = restTemplate.exchange(pubTakUrl, HttpMethod.POST, httpEntity, String.class);
+ long endTime = System.currentTimeMillis();
+ log.info("RCS鍝嶅簲鑰楁椂锛歿}ms", (endTime - startTime));
+ log.info("RCS鍝嶅簲鐘舵�佺爜锛歿}", exchange.getStatusCode());
+ log.info("RCS鍝嶅簲澶达細{}", exchange.getHeaders());
+ log.info("RCS鍝嶅簲浣擄細{}", exchange.getBody());
+ } catch (org.springframework.web.client.ResourceAccessException e) {
+ long endTime = System.currentTimeMillis();
+ log.error("========== RCS浠诲姟涓嬪彂璧勬簮璁块棶寮傚父 ==========");
+ log.error("璇锋眰RCS-璧勬簮璁块棶寮傚父锛堝彲鑳藉寘鍚繛鎺ヨ秴鏃讹級锛岃�楁椂锛歿}ms锛屼换鍔＄紪鐮侊細{}", (endTime - startTime), task.getTaskCode(), e);
+ log.error("璇锋眰RCS-璇锋眰鍦板潃锛歿}", pubTakUrl);
+ log.error("璇锋眰RCS-璇锋眰鍙傛暟锛歿}", JSONObject.toJSONString(taskParams));
+ // 妫�鏌ユ槸鍚︽槸杩炴帴瓒呮椂寮傚父
+ Throwable cause = e.getCause();
+ String errorMsg = e.getMessage();
+ if (cause instanceof java.net.SocketTimeoutException ||
+ (cause instanceof java.net.ConnectException && cause.getMessage() != null && cause.getMessage().contains("timed out")) ||
+ (errorMsg != null && (errorMsg.contains("Connection timed out") || errorMsg.contains("timed out") || errorMsg.contains("timeout")))) {
+ throw new CoolException("RCS杩炴帴瓒呮椂锛屼换鍔′笅鍙戝け璐ワ紒浠诲姟缂栫爜锛�" + task.getTaskCode() + "锛岄敊璇俊鎭細" + errorMsg);
+ }
+ throw new CoolException("RCS璧勬簮璁块棶寮傚父锛屼换鍔′笅鍙戝け璐ワ紒浠诲姟缂栫爜锛�" + task.getTaskCode() + "锛岄敊璇俊鎭細" + errorMsg);
+ } catch (Exception e) {
+ long endTime = System.currentTimeMillis();
+ log.error("========== RCS浠诲姟涓嬪彂寮傚父 ==========");
+ log.error("璇锋眰RCS-寮傚父锛岃�楁椂锛歿}ms锛屼换鍔＄紪鐮侊細{}", (endTime - startTime), task.getTaskCode(), e);
+ log.error("璇锋眰RCS-鍦板潃锛歿}", pubTakUrl);
+ log.error("璇锋眰RCS-鍙傛暟锛歿}", JSONObject.toJSONString(taskParams));
+ String errorMsg = e.getMessage();
+ // 妫�鏌ユ槸鍚︽槸杩炴帴瓒呮椂鐩稿叧鐨勫紓甯�
+ if (errorMsg != null && (errorMsg.contains("Connection timed out") || errorMsg.contains("timed out") || errorMsg.contains("timeout"))) {
+ throw new CoolException("RCS杩炴帴瓒呮椂锛屼换鍔′笅鍙戝け璐ワ紒浠诲姟缂栫爜锛�" + task.getTaskCode() + "锛岄敊璇俊鎭細" + errorMsg);
+ }
+ throw new CoolException("RCS浠诲姟涓嬪彂寮傚父锛佷换鍔＄紪鐮侊細" + task.getTaskCode() + "锛岄敊璇俊鎭細" + errorMsg);
+ }
+
+ if (Objects.isNull(exchange) || Objects.isNull(exchange.getBody())) {
+ log.error("========== RCS浠诲姟涓嬪彂澶辫触 ==========");
+ log.error("璇锋眰RCS-RCS鍝嶅簲浣撲负绌猴紝鏃犳硶瑙ｆ瀽鍝嶅簲缁撴灉");
+ log.error("璇锋眰RCS-鍦板潃锛歿}", pubTakUrl);
+ log.error("璇锋眰RCS-鍙傛暟锛歿}", JSONObject.toJSONString(taskParams));
+ log.error("璇锋眰RCS-澶辫触鐨勪换鍔＄紪鐮侊細{}", task.getTaskCode());
+ throw new CoolException("浠诲姟涓嬪彂澶辫触锛孯CS鍝嶅簲浣撲负绌猴紒锛佷换鍔＄紪鐮侊細" + task.getTaskCode());
+ } else {
+ try {
+ ObjectMapper objectMapper = new ObjectMapper();
+ objectMapper.coercionConfigDefaults()
+ .setCoercion(CoercionInputShape.EmptyString, CoercionAction.AsEmpty);
+ CommonResponse result = objectMapper.readValue(exchange.getBody(), CommonResponse.class);
+ log.info("RCS鍝嶅簲瑙ｆ瀽缁撴灉 - code锛歿}锛宮sg锛歿}锛宒ata锛歿}",
+ result.getCode(), result.getMsg(), result.getData());
+ if (result.getCode() == 200) {
+ log.info("RCS浠诲姟涓嬪彂鎴愬姛锛屽紑濮嬫洿鏂颁换鍔＄姸鎬� - 浠诲姟缂栫爜锛歿}", task.getTaskCode());
if (task.getTaskType().equals(TaskType.TASK_TYPE_IN.type)
|| task.getTaskType().equals(TaskType.TASK_TYPE_PICK_IN.type)
|| task.getTaskType().equals(TaskType.TASK_TYPE_CHECK_IN.type)
@@ -1701,28 +1731,25 @@
}
}
}
- });
- log.info("========== RCS浠诲姟涓嬪彂瀹屾垚锛屽叡{}涓换鍔＄姸鎬佸凡鏇存柊 ==========", tasks.size());
- } else {
- log.error("========== RCS浠诲姟涓嬪彂澶辫触 ==========");
- log.error("RCS杩斿洖閿欒 - code锛歿}锛宮sg锛歿}锛宒ata锛歿}",
- result.getCode(), result.getMsg(), result.getData());
- log.error("澶辫触鐨勪换鍔″垪琛細");
- tasks.forEach(task -> {
- log.error(" - 浠诲姟缂栫爜锛歿}锛屼换鍔＄被鍨嬶細{}", task.getTaskCode(), task.getTaskType());
- });
-// throw new CoolException("浠诲姟涓嬪彂澶辫触锛侊紒");
+ } else {
+ log.error("========== RCS浠诲姟涓嬪彂澶辫触 ==========");
+ log.error("RCS杩斿洖閿欒 - code锛歿}锛宮sg锛歿}锛宒ata锛歿}",
+ result.getCode(), result.getMsg(), result.getData());
+ log.error("澶辫触鐨勪换鍔＄紪鐮侊細{}锛屼换鍔＄被鍨嬶細{}", task.getTaskCode(), task.getTaskType());
+ throw new CoolException("浠诲姟涓嬪彂澶辫触锛侊紒浠诲姟缂栫爜锛�" + task.getTaskCode());
+ }
+ } catch (JsonProcessingException e) {
+ log.error("========== RCS浠诲姟涓嬪彂寮傚父 ==========");
+ log.error("瑙ｆ瀽RCS鍝嶅簲澶辫触锛屽搷搴斾綋锛歿}锛屼换鍔＄紪鐮侊細{}", exchange.getBody(), task.getTaskCode(), e);
+ throw new CoolException("瑙ｆ瀽RCS鍝嶅簲澶辫触锛�" + e.getMessage() + "锛屼换鍔＄紪鐮侊細" + task.getTaskCode());
+ } catch (Exception e) {
+ log.error("========== RCS浠诲姟涓嬪彂寮傚父 ==========");
+ log.error("浠诲姟涓嬪彂杩囩▼涓彂鐢熷紓甯革紝浠诲姟缂栫爜锛歿}", task.getTaskCode(), e);
+ throw e;
}
- } catch (JsonProcessingException e) {
- log.error("========== RCS浠诲姟涓嬪彂寮傚父 ==========");
- log.error("瑙ｆ瀽RCS鍝嶅簲澶辫触锛屽搷搴斾綋锛歿}", exchange.getBody(), e);
- throw new CoolException("瑙ｆ瀽RCS鍝嶅簲澶辫触锛�" + e.getMessage());
- } catch (Exception e) {
- log.error("========== RCS浠诲姟涓嬪彂寮傚父 ==========");
- log.error("浠诲姟涓嬪彂杩囩▼涓彂鐢熷紓甯�", e);
- throw e;
}
}
+ log.info("========== RCS浠诲姟涓嬪彂瀹屾垚锛屽叡{}涓换鍔″凡澶勭悊 ==========", tasks.size());
}/**
--
Gitblit v1.9.1