[瑞成接口、鸿程接口] <feat> 接口接入；处理数据

 - 六十六.浙江省企业基本信息查询：处理股东信息字符串
 - 鸿程新接口接入

src/main/java/com/mth/requestsecret/controller/HongChengController.java

@@ -66,6 +66,130 @@ public class HongChengController {
         // 姓名，证件号
         paramMap.put("querymanList", Lists.newArrayList(user));
 
-        return restTemplateService.hongChengSendRequest(paramMap, apiMethod);
+        return restTemplateService.hongChengSendRequest(paramMap, apiMethod, "不动产权属查询");
     }
+
+    /**
+     * 低保边缘在册家庭信息查询
+     *
+     * @param user
+     * @return
+     */
+    @PostMapping("/edgeBasicLivingAllowance")
+    public ResponseEntity edgeBasicLivingAllowance(HongChengUser user) throws UnsupportedEncodingException {
+        // api签名
+        String apiMethod = "30501500813/20210511146922115787328422";
+        // api参数
+        Map<String, Object> paramMap = new HashMap<>();
+
+        // 姓名
+        paramMap.put("mhz", user.getName());
+        // 身份证号
+        paramMap.put("mhzsfz", user.getZjh());
+
+        return restTemplateService.hongChengSendRequest(paramMap, apiMethod, "低保边缘在册家庭信息查询");
+    }
+
+    /**
+     * 低保在册家庭信息查询
+     *
+     * @param user
+     * @return
+     */
+    @PostMapping("/basicLivingAllowance")
+    public ResponseEntity basicLivingAllowance(HongChengUser user) throws UnsupportedEncodingException {
+        // api签名
+        String apiMethod = "30501500811/20210511106906969438949677";
+        // api参数
+        Map<String, Object> paramMap = new HashMap<>();
+
+        // 姓名
+        paramMap.put("mhz", user.getName());
+        // 身份证号
+        paramMap.put("mhzsfz", user.getZjh());
+
+        return restTemplateService.hongChengSendRequest(paramMap, apiMethod, "低保在册家庭信息查询");
+    }
+
+    /**
+     * 特困在册家庭信息查询
+     *
+     * @param user
+     * @return
+     */
+    @PostMapping("/extremelyPoor")
+    public ResponseEntity extremelyPoor(HongChengUser user) throws UnsupportedEncodingException {
+        // api签名
+        String apiMethod = "30501500814/20210511166929001099754693";
+        // api参数
+        Map<String, Object> paramMap = new HashMap<>();
+
+        // 姓名
+        paramMap.put("mhz", user.getName());
+        // 身份证号
+        paramMap.put("mhzsfz", user.getZjh());
+
+        return restTemplateService.hongChengSendRequest(paramMap, apiMethod, "特困在册家庭信息查询");
+    }
+
+    /**
+     * 浙江出入境口岸查询
+     *
+     * @param user
+     * @return
+     */
+    @PostMapping("/entryAndExit")
+    public ResponseEntity entryAndExit(HongChengUser user) throws UnsupportedEncodingException {
+        // api签名
+        String apiMethod = "30681300812/20210511146921555575237961";
+        // api参数
+        Map<String, Object> paramMap = new HashMap<>();
+
+        // 身份证号
+        paramMap.put("sfzh", user.getZjh());
+
+        return restTemplateService.hongChengSendRequest(paramMap, apiMethod, "浙江出入境口岸查询");
+    }
+
+    /**
+     * 浙江省机动车违法记录查询
+     *
+     * @param hpzl
+     * @param hphm
+     * @return
+     */
+    @PostMapping("/motorVehicleIllegalRecord")
+    public ResponseEntity motorVehicleIllegalRecord(String hpzl, String hphm) throws UnsupportedEncodingException {
+        // api签名
+        String apiMethod = "30210900816/20210511176931335940936366";
+        // api参数
+        Map<String, Object> paramMap = new HashMap<>();
+
+        // 号牌种类
+        paramMap.put("hpzl", hpzl);
+        // 号牌号码
+        paramMap.put("hphm", hphm);
+
+        return restTemplateService.hongChengSendRequest(paramMap, apiMethod, "浙江省机动车违法记录查询");
+    }
+
+    /**
+     * 浙江省死亡信息查询
+     *
+     * @param swrq
+     * @return
+     */
+    @PostMapping("/deathMessage")
+    public ResponseEntity deathMessage(String swrq) throws UnsupportedEncodingException {
+        // api签名
+        String apiMethod = "30682000808/20210506106476298582165626";
+        // api参数
+        Map<String, Object> paramMap = new HashMap<>();
+
+        // 死亡日期（格式：20201221）
+        paramMap.put("SWRQ", swrq);
+
+        return restTemplateService.hongChengSendRequest(paramMap, apiMethod, "浙江省死亡信息查询");
+    }
+
 }

src/main/java/com/mth/requestsecret/controller/RequestController.java

 package com.mth.requestsecret.controller;
 
+import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
+import com.google.common.base.Splitter;
 import com.mth.requestsecret.service.RestTemplateService;
 import com.mth.requestsecret.vo.shuguanjuvo.*;
 import lombok.extern.slf4j.Slf4j;
@@ -16,6 +18,9 @@ import org.springframework.util.MultiValueMap;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.util.List;
+import java.util.Optional;
+
 
 /**
  * 纪委智慧监督平台接口
@@ -1155,12 +1160,12 @@ public class RequestController {
     }
 
     /**
-     * 六十六.浙江省企业基本信息查询
+     * 六十六.浙江省企业基本信息查询_备份
      *
      * @param param
      * @return
      */
-    @PostMapping("/enterpriseInfo")
+    @PostMapping("/enterpriseInfo_back")
     public ResponseEntity<String> enterpriseInfo(SixtySixParamVO param) {
         // api签名
         String apiMethod = "enterpriseInfo.action";
@@ -1174,6 +1179,47 @@ public class RequestController {
         return restTemplateService.commonSendRequest(paramMap, apiMethod);
     }
 
+    /**
+     * 六十六.浙江省企业基本信息查询
+     *
+     * @param param
+     * @return
+     */
+    @PostMapping("/enterpriseInfo")
+    public ResponseEntity<String> enterpriseInfo1(SixtySixParamVO param) {
+        // api签名
+        String apiMethod = "enterpriseInfo.action";
+        // api参数
+        MultiValueMap<String, Object> paramMap = new LinkedMultiValueMap<>();
+        paramMap.add("uniscId", param.getUniscId());
+        paramMap.add("companyName", param.getOrgName());
+        paramMap.add("registerNo", param.getRegisterNo());
+        paramMap.add("entType", param.getEntType());
+        paramMap.add("additional", param.getAdditional());
+        ResponseEntity<String> response = restTemplateService.commonSendRequest(paramMap, apiMethod);
+
+        // body中新增响应键值对：处理 shareholderInfo 股东信息字符串为标准数据
+        JSONObject jsonResponse = JSONObject.parseObject(response.getBody());
+        String shareholderInfo = Optional.ofNullable(jsonResponse)
+                .map(item -> item.getJSONArray("datas"))
+                .map(item -> item.get(0))
+                .map(item -> ((JSONObject) item).getString("shareholderInfo"))
+                .orElse(null);
+        if (shareholderInfo == null) {
+            return response;
+        }
+        List<String> shareholderInfoList = Splitter.on(";").trimResults().omitEmptyStrings().splitToList(shareholderInfo);
+        JSONArray shareholderInfoJsonArray = new JSONArray();
+        shareholderInfoList.stream()
+                .map(item -> "{" + item.replace("=", ":") + "}")
+                .forEach(item -> {
+                    JSONObject jsonObject = JSONObject.parseObject(item);
+                    shareholderInfoJsonArray.add(jsonObject);
+                });
+        ((JSONObject) jsonResponse.getJSONArray("datas").get(0)).put("shareholderInfoList", shareholderInfoJsonArray);
+        return new ResponseEntity<>(jsonResponse.toJSONString(), HttpStatus.OK);
+    }
+
     /**
      * 六十七. 浙江杭州教育局学籍信息查询
      *

src/main/java/com/mth/requestsecret/service/RestTemplateService.java

@@ -387,8 +387,9 @@ public class RestTemplateService {
      * 鸿程 浙江杭州规划和自然资源局不动产权属查询
      * @param paramMap
      * @param apiMethod
+     * @param apiDesc
      */
-    public ResponseEntity hongChengSendRequest(Map<String, Object> paramMap, String apiMethod) throws UnsupportedEncodingException {
+    public ResponseEntity hongChengSendRequest(Map<String, Object> paramMap, String apiMethod, String apiDesc) throws UnsupportedEncodingException {
 
         String url = hongchengAddress + apiMethod;
 
@@ -409,7 +410,7 @@ public class RestTemplateService {
         body.add("sign", sign);
         HttpEntity httpEntity = new HttpEntity<>(body, headers);
 
-        log.info("不动产权属查询api：{}", apiMethod);
+        log.info("api描述：{}", apiDesc);
         log.info("api url：{}", url);
         log.info("原参数：{}", paramMap);
         log.info("加密参数encryptParam：{}", encryptParam);