From b7c3fc85eba070a5c6625bc680ae9993d5553fae Mon Sep 17 00:00:00 2001
From: guoshilong <123456>
Date: Tue, 12 Mar 2024 16:25:56 +0800
Subject: [PATCH] hst预测定时器启用多线程请求
---
skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/service/impl/HsybServiceImpl.java | 62 +++++++++++++++++++++++++-----
1 files changed, 51 insertions(+), 11 deletions(-)
diff --git a/skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/service/impl/HsybServiceImpl.java b/skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/service/impl/HsybServiceImpl.java
index 52bd26d..e626338 100644
--- a/skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/service/impl/HsybServiceImpl.java
+++ b/skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/service/impl/HsybServiceImpl.java
@@ -9,15 +9,25 @@
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.parser.Feature;
import lombok.AllArgsConstructor;
+import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
+import org.apache.http.conn.ssl.NoopHostnameVerifier;
+import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
import org.springblade.core.tool.utils.DateUtil;
import org.springblade.core.tool.utils.StringUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.*;
+import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
import org.springframework.stereotype.Service;
import org.springframework.util.MultiValueMap;
import org.springframework.web.client.RestTemplate;
+import javax.net.ssl.SSLContext;
+import javax.net.ssl.TrustManager;
+import javax.net.ssl.TrustManagerFactory;
+import java.security.KeyStore;
import java.time.LocalDate;
import java.time.format.DateTimeFormatter;
import java.util.*;
@@ -74,16 +84,19 @@
HsybGetFuturePo hsybGetFuturePo = sendRequestToHsyb(GET_NEW_FUTURE, urlParams);
- //程序转为hashmap,手动转换类型
- List<NewSwFuturePo> data = JSON.parseArray(JSON.toJSONString(hsybGetFuturePo.getData()), NewSwFuturePo.class);
- List<NewSwFuturePo> filterData = filterPredict(data);
+ if (hsybGetFuturePo.getData() !=null){
+ //程序转为hashmap,手动转换类型
+ List<NewSwFuturePo> data = JSON.parseArray(JSON.toJSONString(hsybGetFuturePo.getData()), NewSwFuturePo.class);
+ List<NewSwFuturePo> filterData = filterPredict(data);
- log.info(StringUtil.format("过滤后的预测水位数据：{}", JSON.toJSONString(filterData)));
- return filterData;
-// }else{
-// //拿不到预测水位
-// return null;
-// }
+ log.info(StringUtil.format("过滤后的预测水位数据：{}", JSON.toJSONString(filterData)));
+ return filterData;
+ }else {
+ //因为会有data为null的数据，所以返回空数组
+ List<NewSwFuturePo> list = new ArrayList<>();
+ return list;
+ }
+
}
public Boolean isResHasModel(String resId){
@@ -189,6 +202,7 @@
return null;
}
+ @SneakyThrows
public HsybGetFuturePo sendRequestToHsyb(String url, String urlParam) {
// 获取环境
String activeProfile = SpringContextUtil.getActiveProfile();
@@ -203,14 +217,40 @@
}
url = url + urlParam;
log.info("洪水预报请求地址：{}", url);
+
+ // 创建一个信任所有证书的 TrustManager
+ TrustManagerFactory trustManagerFactory = TrustManagerFactory.getInstance(TrustManagerFactory.getDefaultAlgorithm());
+ trustManagerFactory.init((KeyStore) null);
+ TrustManager[] trustManagers = trustManagerFactory.getTrustManagers();
+
+ // 创建一个不验证主机名的 SSLContext
+ SSLContext sslContext = SSLContext.getInstance("TLS");
+ sslContext.init(null, trustManagers, new java.security.SecureRandom());
+
+ // 创建一个不验证主机名的 SSLConnectionSocketFactory
+ SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(sslContext, NoopHostnameVerifier.INSTANCE);
+
+ // 创建 HttpClient
+ CloseableHttpClient httpClient = HttpClients.custom()
+ .setSSLSocketFactory(sslsf)
+ .build();
+
+ // 创建 HttpComponentsClientHttpRequestFactory 并设置 HttpClient
+ HttpComponentsClientHttpRequestFactory requestFactory = new HttpComponentsClientHttpRequestFactory();
+ requestFactory.setHttpClient(httpClient);
+
+ // 创建 RestTemplate 并设置请求工厂
+ RestTemplate restTemplate = new RestTemplate(requestFactory);
+
//设置请求头
HttpHeaders headers = new HttpHeaders();
headers.add("Authorization", AUTHORIZATION);
//封装请求头
- HttpEntity<MultiValueMap<String, Object>> formEntity = new HttpEntity<MultiValueMap<String, Object>>(headers);
+ HttpEntity<MultiValueMap<String, Object>> formEntity = new HttpEntity<>(headers);
try {
ResponseEntity<HsybGetFuturePo> exchange = restTemplate.exchange(url, HttpMethod.GET, formEntity, HsybGetFuturePo.class);
+ log.info("请求结果："+ exchange.getBody().toString());
return exchange.getBody();
} catch (Exception e) {
e.printStackTrace();
@@ -313,7 +353,7 @@
* "resId": "42092250024"
* },
*/
- if (list.size() == 0) {
+ if (null == list || list.size() == 0) {
return null;
}
--
Gitblit v1.9.3