质检给市平台推送数据的接口，并且把该表的关键字字段改为非关键字

src/main/java/com/chinaitop/depot/utils/HttpUtil.java

@@ -0,0 +1,245 @@
+package com.chinaitop.depot.utils;
+
+import org.apache.http.*;
+import org.apache.http.client.HttpClient;
+import org.apache.http.client.entity.UrlEncodedFormEntity;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.DefaultHttpClient;
+import org.apache.http.impl.client.HttpClientBuilder;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.message.BasicNameValuePair;
+import org.apache.http.protocol.HTTP;
+import org.apache.http.util.EntityUtils;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.converter.HttpMessageConverter;
+import org.springframework.http.converter.StringHttpMessageConverter;
+import org.springframework.web.client.RestTemplate;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.net.URI;
+import java.nio.charset.StandardCharsets;
+import java.util.ArrayList;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author qingsong.han
+ * @description: http工具类
+ * @create 2020-04-19 12:48
+ */
+public class HttpUtil {
+
+    /**
+     * 使用apache的HttpClient发送http
+     *
+     * @param wsdlURL
+     *            请求URL
+     * @param contentType
+     *            如:application/json;charset=utf8
+     * @param content
+     *            数据内容
+     * @DATE 2018年9月22日 下午10:29:17
+     */
+    public static String doHttpPostByHttpClient(final String wsdlURL, final String contentType, final String content) throws IOException {
+        // 获得Http客户端(可以理解为:你得先有一个浏览器;注意:实际上HttpClient与浏览器是不一样的)
+        CloseableHttpClient httpClient = HttpClientBuilder.create().build();
+        // 创建Post请求
+//        HttpPost httpPost = new HttpPost(wsdlURL);
+        HttpGet httpGet = new HttpGet(wsdlURL);
+        /*StringEntity entity = new StringEntity(content, "UTF-8");
+        // 将数据放入entity中
+        httpPost.setEntity(entity);
+        httpPost.setHeader("Content-Type", contentType);*/
+        // 响应模型
+        CloseableHttpResponse response = null;
+        String result = "";
+        try {
+            // 由客户端执行(发送)Post请求
+//            response = httpClient.execute(httpPost);
+            response = httpClient.execute(httpGet);
+            // 从响应模型中获取响应实体
+            // 注意:和doHttpPostByRestTemplate方法用的不是同一个HttpEntity
+            HttpEntity responseEntity = response.getEntity();
+            System.out.println("响应ContentType为:" + responseEntity.getContentType());
+            System.out.println("响应状态为:" + response.getStatusLine());
+            if (responseEntity != null) {
+                result = EntityUtils.toString(responseEntity);
+                System.out.println("响应内容为:" + result);
+            }
+        } finally {
+            // 释放资源
+            if (httpClient != null) {
+                httpClient.close();
+            }
+            if (response != null) {
+                response.close();
+            }
+        }
+        return result;
+    }
+
+    /**
+     * 使用springframework的RestTemplate发送http
+     *
+     * @param wsdlURL
+     *            请求URL
+     * @param contentType
+     *            如:application/json;charset=utf8
+     * @param content
+     *            数据内容
+     * @DATE 2018年9月22日 下午10:30:48
+     */
+    public static String doHttpPostByRestTemplate(final String wsdlURL, final String contentType, final String content) {
+        // http使用无参构造;https需要使用有参构造
+        RestTemplate restTemplate = new RestTemplate();
+        // 解决中文乱码
+        List<HttpMessageConverter<?>> converterList = restTemplate.getMessageConverters();
+        converterList.remove(1);
+        HttpMessageConverter<?> converter = new StringHttpMessageConverter(StandardCharsets.UTF_8);
+        converterList.add(1, converter);
+        restTemplate.setMessageConverters(converterList);
+        // 设置Content-Type
+        HttpHeaders headers = new HttpHeaders();
+        headers.remove("Content-Type");
+        headers.add("Content-Type", contentType);
+        // 数据信息封装
+        // 注意:和doHttpPostByHttpClient方法用的不是同一个HttpEntity
+        org.springframework.http.HttpEntity<String> formEntity = new org.springframework.http.HttpEntity<String>(
+                content, headers);
+        String result = restTemplate.postForObject(wsdlURL, formEntity, String.class);
+        return result;
+    }
+
+    /**
+     * post请求(用于key-value格式的参数)
+     * @param url
+     * @param params
+     * @return
+     */
+    public static String doPost(String url, Map params){
+
+        BufferedReader in = null;
+        try {
+            // 定义HttpClient
+            HttpClient client = new DefaultHttpClient();
+            // 实例化HTTP方法
+            HttpPost request = new HttpPost();
+            request.setURI(new URI(url));
+            //设置参数
+            List<NameValuePair> nvps = new ArrayList<NameValuePair>();
+            for (Iterator iter = params.keySet().iterator(); iter.hasNext();) {
+                String name = (String) iter.next();
+                String value = String.valueOf(params.get(name));
+                nvps.add(new BasicNameValuePair(name, value));
+
+                //System.out.println(name +"-"+value);
+            }
+            request.setEntity(new UrlEncodedFormEntity(nvps, HTTP.UTF_8));
+
+            HttpResponse response = client.execute(request);
+            int code = response.getStatusLine().getStatusCode();
+            if(code == 200){	//请求成功
+                in = new BufferedReader(new InputStreamReader(response.getEntity()
+                        .getContent(),"utf-8"));
+                StringBuffer sb = new StringBuffer("");
+                String line = "";
+                String NL = System.getProperty("line.separator");
+                while ((line = in.readLine()) != null) {
+                    sb.append(line + NL);
+                }
+
+                in.close();
+
+                return sb.toString();
+            }
+            else{	//
+                System.out.println("状态码：" + code);
+                return null;
+            }
+        }
+        catch(Exception e){
+            e.printStackTrace();
+
+            return null;
+        }
+    }
+
+    /**
+     * get请求
+     * @return
+     */
+    public static String doGet(String url) {
+        try {
+            HttpClient client = new DefaultHttpClient();
+            //发送get请求
+            HttpGet request = new HttpGet(url);
+            HttpResponse response = client.execute(request);
+
+            /**请求发送成功，并得到响应**/
+            if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) {
+                /**读取服务器返回过来的json字符串数据**/
+                String strResult = EntityUtils.toString(response.getEntity());
+
+                return strResult;
+            }
+        }
+        catch (IOException e) {
+            e.printStackTrace();
+        }
+
+        return null;
+    }
+
+    /**
+     * post请求（用于请求json格式的参数）
+     * @param url
+     * @param params
+     * @return
+     */
+    public static String doPost(String url, String params) throws Exception {
+
+        CloseableHttpClient httpclient = HttpClients.createDefault();
+        HttpPost httpPost = new HttpPost(url);// 创建httpPost
+        httpPost.setHeader("Accept", "application/json");
+//        httpPost.setHeader("Content-Type", "application/x-www-form-urlencoded");
+        httpPost.setHeader("Content-Type", "application/json");
+        String charSet = "UTF-8";
+        StringEntity entity = new StringEntity(params, charSet);
+        httpPost.setEntity(entity);
+        CloseableHttpResponse response = null;
+
+        try {
+
+            response = httpclient.execute(httpPost);
+            StatusLine status = response.getStatusLine();
+            int state = status.getStatusCode();
+            if (state == HttpStatus.SC_OK) {
+                HttpEntity responseEntity = response.getEntity();
+                String jsonString = EntityUtils.toString(responseEntity);
+                return jsonString;
+            }
+        }
+        finally {
+            if (response != null) {
+                try {
+                    response.close();
+                } catch (IOException e) {
+                    e.printStackTrace();
+                }
+            }
+            try {
+                httpclient.close();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+        return null;
+    }
+}