From ec3db382f74ce0dfaf8e7b96ad3d52ed772781b3 Mon Sep 17 00:00:00 2001
From: Administrator <335182714>
Date: 星期四, 19 六月 2025 13:21:43 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java | 22 ++++++++++++++++++----
1 files changed, 18 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
index af0164b..7f2c52e 100644
--- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
@@ -35,6 +35,7 @@
import javax.annotation.Resource;
import java.util.*;
+import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
/**
@@ -2087,7 +2088,7 @@
public boolean pushStaNoToGwcs(Integer palletizingNo, Integer staNo, Integer workNo, String barcode, String message) {
int maxRetry = 3; // 鏈�澶氶噸璇� 3 娆�
- long retryDelay = 3000; // 閲嶈瘯闂撮殧 3 绉�
+ long retryDelay = 10000; // 閲嶈瘯闂撮殧 10 绉�
boolean finalSuccess = false;
Map<String, Object> headers = getHeaders();
@@ -2109,13 +2110,25 @@
.setPath(MesConstant.GWCS_FPKW_URL)
.setHeaders(headers)
.setJson(body)
+ .setTimeout(30, TimeUnit.SECONDS) // 璁剧疆杩炴帴 + 璇诲彇瓒呮椂涓�30绉�
.build()
.doPost();
+
if (!Cools.isEmpty(response)) {
- success = true;
- finalSuccess = true;
- log.info("{} 鎴愬姛锛屽搷搴旓細{}", attemptMsg, response);
+ try {
+ JSONObject resJson = JSON.parseObject(response);
+ int code = resJson.getIntValue("code"); // 瑙嗗叿浣撴帴鍙ｈ�屽畾
+ if (code == 200) {
+ success = true;
+ finalSuccess = true;
+ log.info("{} 鎴愬姛锛屽搷搴旓細{}", attemptMsg, response);
+ } else {
+ log.warn("{} 鍝嶅簲澶辫触锛岃繑鍥瀋ode={}锛屽畬鏁村搷搴旓細{}", attemptMsg, code, response);
+ }
+ } catch (Exception parseEx) {
+ log.warn("{} 鍝嶅簲瑙ｆ瀽澶辫触锛屽唴瀹癸細{}", attemptMsg, response);
+ }
} else {
log.warn("{} 澶辫触锛屽搷搴斾负绌�", attemptMsg);
}
@@ -2155,6 +2168,7 @@
}
+
Map<String, Object> getHeaders(){
Map<String,Object> headers = new HashMap<>();
headers.put("digi-type","sync ");
--
Gitblit v1.9.1