From 2ad73d412385d20f1db975f24972fc11751ed040 Mon Sep 17 00:00:00 2001
From: lty <876263681@qq.com>
Date: 星期三, 18 六月 2025 14:42:28 +0800
Subject: [PATCH] #推送超时改为15秒
---
src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java | 20 +++++++++++++++++---
1 files changed, 17 insertions(+), 3 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..d285f24 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;
/**
@@ -2109,13 +2110,25 @@
.setPath(MesConstant.GWCS_FPKW_URL)
.setHeaders(headers)
.setJson(body)
+ .setTimeout(15, TimeUnit.SECONDS) // 璁剧疆杩炴帴 + 璇诲彇瓒呮椂涓�15绉�
.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 == 0) {
+ 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