全国一体化接口

boman-web-core/src/main/java/com/boman/web/core/controller/TaskController.java

@@ -104,6 +104,12 @@ public class TaskController {
         return taskService.zhenDate(startTime,endTime);
     }
 
+    @GetMapping("/test")
+    private String test() {
+        return taskService.test();
+    }
+
+
 
 
 

boman-web-core/src/main/java/com/boman/web/core/service/TaskService.java

@@ -34,6 +34,7 @@ import com.boman.web.core.service.czrk.CzrkServiceImpl;
 import com.boman.web.core.service.czrk.ICzrkJzdzService;
 import com.boman.web.core.service.ip.IpTimesService;
 import com.boman.web.core.service.toQianShan.ToQianshanPersonnerService;
+import com.boman.web.core.utils.AESUtil;
 import com.boman.web.core.utils.AuthUtils;
 import com.boman.web.core.utils.HttpClientUtils;
 import lombok.SneakyThrows;
@@ -49,7 +50,12 @@ import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.GetMapping;
 
 import javax.annotation.Resource;
+import java.io.BufferedReader;
 import java.io.IOException;
+import java.io.InputStreamReader;
+import java.io.Reader;
+import java.net.HttpURLConnection;
+import java.net.URL;
 import java.sql.Timestamp;
 import java.text.ParseException;
 import java.text.SimpleDateFormat;
@@ -1177,4 +1183,99 @@ public class TaskService {
         System.out.println("---------------插入来宜人员数据耗时" + (end - start) + "---------------");
     }
 
+    public String test() {
+        Long gjzwfwpt_rtime = new Date().getTime();
+        System.out.println("时间戳------"+gjzwfwpt_rtime);
+        String gjzwfwpt_rid = "TE3400003400000001@f6eae674bdc840d2b0474dd3d736faf1";
+        String gjzwfwpt_sid = "s_X01201000200000000_4817";
+
+        StringBuilder sb = new StringBuilder();
+        sb.append(gjzwfwpt_sid).append(gjzwfwpt_rid).append(String.valueOf(gjzwfwpt_rtime));
+
+        // System.out.println(sign(sid+rid+rtime,"90f27130802db6f63edb783831bf5aff"));
+        System.out.println("加密------"+AESUtil.sign(sb.toString(),"e72f935d839db74e407ca9fa13cc78b7"));
+
+        String gjzwfwpt_sign = AESUtil.sign(sb.toString(),"e72f935d839db74e407ca9fa13cc78b7");
+
+        JSONObject paramMap = new JSONObject();
+        paramMap.put("gjzwfwpt_rid",gjzwfwpt_rid);
+        paramMap.put("gjzwfwpt_sid",gjzwfwpt_sid);
+        paramMap.put("gjzwfwpt_rtime",String.valueOf(gjzwfwpt_rtime));
+        paramMap.put("gjzwfwpt_sign",gjzwfwpt_sign);
+        String http = "http://59.255.22.70:8443/authz/authSystem/getAppSecret";
+        try {
+            String data = HttpClientUtils.send(http, paramMap,"utf-8");
+            System.out.println("/authSystem/getAppSecret返回值------"+data);
+            JSONObject jsonObject = JSONObject.parseObject(data);
+            Map<String,Object> map = (Map<String, Object>) jsonObject.get("data");
+            System.out.println("secret------"+(String) map.get("secret"));
+            String my = AESUtil.AESDncode("e72f935d839db74e407ca9fa13cc78b7", (String) map.get("secret"));
+            System.out.println("解密------"+my);
+
+
+            //请求url
+            URL postUrl = new URL("http://59.255.22.70:8443/gateway/wsproxy");
+            //请求参数map
+            Map<String,String>  postParams = new HashMap<String,String>();
+            //组装参数
+            //公共请求参数
+            postParams.put("access_key", "e72f935d839db74e407ca9fa13cc78b7");
+            postParams.put("format","json");
+            postParams.put("request_id","");
+            postParams.put("sign", my);
+            postParams.put("timestamp",String.valueOf(gjzwfwpt_rtime));
+            postParams.put("version","1.0");
+            //请求查询条件参数
+            Map<String,String> params = new HashMap<String, String>();
+            params.put("cert_num_man", "340826199601121171");
+            params.put("name_man", "叶飞翔");
+            StringBuilder biz_content = new StringBuilder("{");
+            for(String key : params.keySet()){
+                String value = params.get(key);
+                biz_content.append("\""+key+"\""+":"+"\""+value+"\",");
+            }
+            biz_content.deleteCharAt(biz_content.length() - 1);
+            biz_content.append("}");
+            postParams.put("biz_content", biz_content.toString());
+            StringBuilder postData = new StringBuilder();
+            for (Map.Entry<String,String> param : postParams.entrySet()) {
+                if (postData.length() != 0){
+                    postData.append('&');
+                }
+                postData.append(param.getKey());
+                postData.append("=");
+                postData.append(param.getValue());
+            }
+            System.out.println("http://59.255.22.70:8443/gateway/wsproxy参数"+postData.toString());
+            byte[] postDataBytes = postData.toString().getBytes("UTF-8");
+            HttpURLConnection conn = (HttpURLConnection)postUrl.openConnection();
+            conn.setDoOutput(true);
+            conn.setDoInput(true);
+            conn.setUseCaches(false);
+            conn.setRequestMethod("POST");
+            conn.setRequestProperty("accept", "*/*");
+            conn.setRequestProperty("connection", "Keep-Alive");
+            conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
+            conn.setRequestProperty("Content-Type","application/x-www-form-urlencoded");
+            conn.setRequestProperty("Content-Length",String.valueOf(postDataBytes.length));
+            conn.connect();
+            conn.getOutputStream().write(postDataBytes);
+            Reader in = new BufferedReader(new InputStreamReader(conn.getInputStream(), "UTF-8"));
+            StringBuilder sb1 = new StringBuilder();
+            for (int c; (c = in.read()) >= 0;){
+                sb1.append((char)c);
+            }
+            //获取查询结果，结果示例见第5条，
+            String response = sb1.toString();
+
+            System.out.println("结果------"+response);
+            return response;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
+
+
+    }
+
 }

boman-web-core/src/main/java/com/boman/web/core/utils/AESUtil.java

@@ -279,7 +279,7 @@ public class AESUtil {
     }
 
 
-    public static void main(String[] args) {
+    /*public static void main(String[] args) {
 
 
         Map<String,String> params = new HashMap<String, String>();
@@ -312,7 +312,7 @@ public class AESUtil {
 
         String gjzwfwpt_sign = sign(sb.toString(),"e72f935d839db74e407ca9fa13cc78b7");
 
-        /*Map<String, String> paramMap = new HashMap<>();
+        *//*Map<String, String> paramMap = new HashMap<>();
         paramMap.put("gjzwfwpt_rid",gjzwfwpt_rid);
         paramMap.put("gjzwfwpt_sid",gjzwfwpt_sid);
         paramMap.put("gjzwfwpt_rtime",String.valueOf(gjzwfwpt_rtime));
@@ -323,12 +323,12 @@ public class AESUtil {
             System.out.println(data);
         } catch (IOException e) {
             e.printStackTrace();
-        }*/
+        }*//*
 
-        String my = AESDncode("e72f935d839db74e407ca9fa13cc78b7","ViSzYpGs9lJsLMAYv9BMRH+NKd1DQDX1Jnzsgbhx+mPxuEmwTjHl2i4P77mtrnYZ");
+        String my = AESDncode("e72f935d839db74e407ca9fa13cc78b7","3fyzKj9ZNa8jMNSmfma0a6iuxWlTwCcyFDWSmZqapfXxuEmwTjHl2i4P77mtrnYZ");
         System.out.println(my);
 
-    }
+    }*/
 
 
 

boman-web-core/src/main/java/com/boman/web/core/utils/HttpClientUtils.java

@@ -1,18 +1,24 @@
 package com.boman.web.core.utils;
 
+import com.alibaba.fastjson.JSONObject;
+import org.apache.http.HttpEntity;
 import org.apache.http.NameValuePair;
 import org.apache.http.client.config.RequestConfig;
 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.HttpClients;
+import org.apache.http.message.BasicHeader;
 import org.apache.http.message.BasicNameValuePair;
+import org.apache.http.protocol.HTTP;
 import org.apache.http.util.EntityUtils;
 
 import java.io.IOException;
 import java.net.URLEncoder;
+import java.text.ParseException;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
@@ -123,4 +129,44 @@ public class HttpClientUtils {
                 .setConnectionRequestTimeout(TIMEOUT_MSEC)
                 .setSocketTimeout(TIMEOUT_MSEC).build();
     }
+
+    public static String send(String url, JSONObject json, String encoding) throws ParseException, IOException {
+        String body = "";
+
+        //创建httpclient对象
+        CloseableHttpClient client = HttpClients.createDefault();
+        //创建post方式请求对象
+        HttpPost httpPost = new HttpPost(url);
+
+        //装填参数
+        System.out.println("send参数："+json.toString());
+        StringEntity s = new StringEntity(json.toString(), "utf-8");
+        System.out.println("send参数string："+json.toString());
+        s.setContentEncoding(new BasicHeader(HTTP.CONTENT_TYPE,
+                "application/json"));
+        //设置参数到请求对象中
+        httpPost.setEntity(s);
+        System.out.println("请求地址："+url);
+//        System.out.println("请求参数："+nvps.toString());
+
+        //设置header信息
+        //指定报文头【Content-type】、【User-Agent】
+//        httpPost.setHeader("Content-type", "application/x-www-form-urlencoded");
+        httpPost.setHeader("Content-type", "application/json");
+        httpPost.setHeader("User-Agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
+
+        //执行请求操作，并拿到结果（同步阻塞）
+        CloseableHttpResponse response = client.execute(httpPost);
+        //获取结果实体
+        HttpEntity entity = response.getEntity();
+        if (entity != null) {
+            //按指定编码转换结果实体为String类型
+            body = EntityUtils.toString(entity, encoding);
+        }
+        EntityUtils.consume(entity);
+        //释放链接
+        response.close();
+        return body;
+    }
+
 }