导入保单查询保单状态

src/main/java/cn/timer/api/utils/HttpUtils.java

 package cn.timer.api.utils;
 
 import java.io.*;
-import java.net.ConnectException;
-import java.net.SocketTimeoutException;
-import java.net.URL;
-import java.net.URLConnection;
+import java.net.*;
 import java.nio.charset.StandardCharsets;
 import java.security.cert.X509Certificate;
 import java.util.Map;
@@ -16,6 +13,12 @@ import javax.net.ssl.TrustManager;
 import javax.net.ssl.X509TrustManager;
 
 import com.alibaba.fastjson.JSONObject;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.client.utils.URIBuilder;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.util.EntityUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -37,59 +40,44 @@ public class HttpUtils
      * @param param 请求参数，请求参数应该是 name1=value1&name2=value2 的形式。
      * @return 所代表远程资源的响应结果
      */
-    public static String sendGet(String url, String param)
-    {
-        StringBuilder result = new StringBuilder();
-        BufferedReader in = null;
-        try
-        {
-            String urlNameString = url + "?" + param;
-            log.info("sendGet - {}", urlNameString);
-            URL realUrl = new URL(urlNameString);
-           HttpsURLConnection connection = (HttpsURLConnection)realUrl.openConnection();
-            connection.setRequestProperty("accept", "*/*");
-            connection.setRequestProperty("connection", "Keep-Alive");
-            connection.setRequestProperty("User-Agent", "Mozilla/5.0 (Windows NT 6.1; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/61.0.3163.100 Safari/537.36)");
-            connection.connect();
-            in = new BufferedReader(new InputStreamReader(connection.getInputStream()));
-            String line;
-            while ((line = in.readLine()) != null)
-            {
-                result.append(line);
-            }
-            log.info("recv - {}", result);
-        }
-        catch (ConnectException e)
-        {
-            log.error("调用HttpUtils.sendGet ConnectException, url=" + url + ",param=" + param, e);
-        }
-        catch (SocketTimeoutException e)
-        {
-            log.error("调用HttpUtils.sendGet SocketTimeoutException, url=" + url + ",param=" + param, e);
+    public static String sendGet(String url, Map<String, String> param)
+    { // 创建Httpclient对象
+        CloseableHttpClient httpclient = HttpClients.createDefault();
+
+        String resultString = "";
+        CloseableHttpResponse response = null;
+        try {
+            // 创建uri
+            URIBuilder builder = new URIBuilder(url);
+            if (param != null) {
+                for (String key : param.keySet()) {
+                    builder.addParameter(key, param.get(key));
                 }
-        catch (IOException e)
-        {
-            log.error("调用HttpUtils.sendGet IOException, url=" + url + ",param=" + param, e);
             }
-        catch (Exception e)
-        {
-            log.error("调用HttpsUtil.sendGet Exception, url=" + url + ",param=" + param, e);
-        }
-        finally
-        {
-            try
-            {
-                if (in != null)
-                {
-                    in.close();
+            URI uri = builder.build();
+
+            // 创建http GET请求
+            HttpGet httpGet = new HttpGet(uri);
+
+            // 执行请求
+            response = httpclient.execute(httpGet);
+            // 判断返回状态是否为200
+            if (response.getStatusLine().getStatusCode() == 200) {
+                resultString = EntityUtils.toString(response.getEntity(), "UTF-8");
             }
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            try {
+                if (response != null) {
+                    response.close();
                 }
-            catch (Exception ex)
-            {
-                log.error("调用in.close Exception, url=" + url + ",param=" + param, ex);
+                httpclient.close();
+            } catch (IOException e) {
+                e.printStackTrace();
             }
         }
-        return result.toString();
+        return resultString;
     }
 
     /**

src/main/resources/application-dev.yml

@@ -244,6 +244,9 @@ insure:
     secret: 'acb329868c31d5b3ba03de40dac13dd9'
     uploadUrl:  'http://sandbox.portal.unistar-ins.com/service/Home/Index/fileUpload'
     insuredUrl: 'http://sandbox.portal.unistar-ins.com/mall/Home/Index/createQuotePolicy'
+    #查询保单信息
+    policyDetail: 'http://sandbox.portal.unistar-ins.com/issuing/Home/Index/policy'
+
     #保全
     appidq: '1000115041006006938'
     secretq:  '6ba1bf4aa0bd14368c95ff0b9934a17b'
@@ -252,3 +255,19 @@ insure:
 
 # base_api_url
 BASE_API_URL: 'http://test-8timer-api.youlingrc.com'
+
+#sftp 配置
+sftp:
+  client:
+    protocol: 'sftp'
+    host: '120.78.162.177'
+    port: '22'
+    username: 'root'
+    password: 'fksdlfjs(*&&%HGgjfkdjsfhksh9781283KFHFFGHghhndbv##2@'
+    root: '/home'
+    sessionStrictHostKeyChecking: 'no'
+    sessionConnectTimeout: '15000'
+    channelConnectedTimeout: '15000'
+    serverUrl: 'https://test-img.8timer.cn'
+    targetPath: '/disk'
+    reservedName: false

src/main/resources/application-test.yml

@@ -244,6 +244,9 @@ insure:
   secret: 'acb329868c31d5b3ba03de40dac13dd9'
   uploadUrl:  'http://sandbox.portal.unistar-ins.com/service/Home/Index/fileUpload'
   insuredUrl: 'http://sandbox.portal.unistar-ins.com/mall/Home/Index/createQuotePolicy'
+  #查询保单信息
+  policyDetail: 'http://sandbox.portal.unistar-ins.com/issuing/Home/Index/policy'
+
   #保全
   appidq: '1000115041006006938'
   secretq:  '6ba1bf4aa0bd14368c95ff0b9934a17b'