南科院预测模型

xieb

2024-03-08 1786e7a0c6f39150720f50dc3303b871df299103

南科院预测模型

 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.*;
@@ -189,6 +199,7 @@
        return null;
    }

    @SneakyThrows
    public HsybGetFuturePo sendRequestToHsyb(String url, String urlParam) {
        // 获取环境
        String activeProfile = SpringContextUtil.getActiveProfile();
@@ -203,11 +214,36 @@
        }
        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);
@@ -313,7 +349,7 @@
         *             "resId": "42092250024"
         *         },
         */
        if (list.size() == 0) {
        if (null == list || list.size() == 0) {
            return null;
        }