身份信息反馈接口

src/main/java/com/founder/controller/SfxxfwController.java

+package com.founder.controller;
+
+import com.founder.checkAuthorization.annotation.CheckAuthorization;
+import com.founder.checkAuthorization.config.AuthorizationInterceptor;
+import com.founder.common.IpADressLock;
+import com.founder.common.LogsUtil;
+import com.founder.dao.AuthorizationMapper;
+import com.founder.model.R;
+import com.founder.model.SfxxReqVo;
+import com.founder.service.SfxxService;
+import com.founder.service.SysGnsyrzOpenApiService;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.Map;
+
+@RestController
+@RequestMapping(value="/api/v1/430000-ythcj-hcfk",produces = "application/json; charset=utf-8")
+@Slf4j
+@CheckAuthorization
+public class SfxxfwController {
+
+    @Autowired
+    private AuthorizationMapper authorizationMapper;
+    @Autowired
+    private SfxxService sfxxService;
+    @Autowired
+    private SysGnsyrzOpenApiService sysGnsyrzOpenApiService;
+    @Autowired
+    private IpADressLock ipADressLock;
+
+    /**
+     * 获取身份信息反馈
+     * @param sfxxReqVo
+     * @return
+     */
+    @PostMapping("/sfxxfk")
+    public R getJjwfjl(HttpServletRequest request, @RequestBody SfxxReqVo sfxxReqVo){
+        if(sfxxReqVo == null || (StringUtils.isEmpty(sfxxReqVo.getBhcrsfzhm()) && StringUtils.isEmpty(sfxxReqVo.getXm()))){
+            return R.error("没有被查询人员的身份证号码或姓名，不能查询！");
+        }
+        Map<String, String> map = getFwidAndXtmc(request);
+        try {
+            Map<String, Object> mapResult = sfxxService.getSfxxfk(request, sfxxReqVo);
+            sysGnsyrzOpenApiService.insertGNSYRZOPENAPI("01",map.get("FWMC"), LogsUtil.getNotEmptyFiled(sfxxReqVo).toString(),
+                    "","","430000000000",map.get("XTMC"),"", ipADressLock.getAddressIp(request),"0", map.get("FWID"));
+            return R.ok().data(mapResult).message("身份信息反馈成功");
+        }catch (Exception e){
+            log.error("错误日志", e);
+            sysGnsyrzOpenApiService.insertGNSYRZOPENAPI("01",map.get("FWMC"), LogsUtil.getNotEmptyFiled(sfxxReqVo).toString(),
+                    "","","430000000000",map.get("XTMC"),"", ipADressLock.getAddressIp(request),"1", map.get("FWID"));
+            return R.error("身份信息反馈失败，请联系管理员");
+        }
+    }
+
+    private Map<String, String> getFwidAndXtmc(HttpServletRequest request) {
+        String appId = request.getHeader(AuthorizationInterceptor.appId);
+        String appSecret = request.getHeader(AuthorizationInterceptor.appSecret);
+        return authorizationMapper.getFwidAndXtmc(appId, appSecret);
+    }
+
+}

src/main/java/com/founder/model/SfxxReqVo.java

+package com.founder.model;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+public class SfxxReqVo implements Serializable {
+
+    private static final long serialVersionUID = 1180958860019149903L;
+    //核查请求任务id
+    private String hcqqrwid;
+    //核查人姓名
+    private String hcrxm;
+    //核查人身份号码
+    private String hcrsfhm;
+    //核查人警号
+    private String hdrjh;
+    //核查单位代码
+    private String hcdwdm;
+    //核查单位名称
+    private String hcdwmc;
+    //被核查人身份号码
+    private String bhcrsfzhm;
+    //被核查人姓名
+    private String xm;
+
+    @Override
+    public String toString() {
+        return "SfxxReqVo{" +
+                "hcqqrwid='" + hcqqrwid + '\'' +
+                ", hcrxm='" + hcrxm + '\'' +
+                ", hcrsfhm='" + hcrsfhm + '\'' +
+                ", hdrjh='" + hdrjh + '\'' +
+                ", hcdwdm='" + hcdwdm + '\'' +
+                ", hcdwmc='" + hcdwmc + '\'' +
+                ", bhcrsfzhm='" + bhcrsfzhm + '\'' +
+                ", xm='" + xm + '\'' +
+                '}';
+    }
+}

src/main/java/com/founder/service/SfxxService.java

+package com.founder.service;
+
+import com.founder.model.SfxxReqVo;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.Map;
+
+public interface SfxxService {
+
+    Map<String, Object> getSfxxfk(HttpServletRequest request, SfxxReqVo sfxxReqVo) throws Exception;
+
+}

src/main/java/com/founder/service/impl/SfxxServiceImpl.java

+package com.founder.service.impl;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.founder.model.SfxxReqVo;
+import com.founder.service.SfxxService;
+import com.founder.util.EsUtils;
+import com.founder.util.HttpClient;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Service;
+
+import javax.servlet.http.HttpServletRequest;
+import java.net.URLEncoder;
+import java.util.HashMap;
+import java.util.Map;
+
+@Service
+public class SfxxServiceImpl implements SfxxService {
+    @Override
+    public Map<String, Object> getSfxxfk(HttpServletRequest request, SfxxReqVo sfxxReqVo) throws Exception {
+        Map<String, Object> resultMap = new HashMap<>(); //返回值
+        String bodyJson="{\n" +
+                "    \"hcqqrwid\": null,\n" +
+                "    \"hcrxm\": null,\n" +
+                "    \"hcrsfhm\": null,\n" +
+                "    \"hdrjh\": null,\n" +
+                "    \"hcdwdm\": null,\n" +
+                "    \"hcdwmc\": null,\n" +
+                "    \"bhcrsfzhm\": "+ sfxxReqVo.getBhcrsfzhm() +",\n" +
+                "    \"xm\": "+ sfxxReqVo.getXm() +"}";
+        Map<String, String> header = initHttpXmlHeads();
+        String resultToken = "";
+        resultToken = HttpClient.doPostJson("http://10.142.16.96:9061/zyApi/getSfxx", header, bodyJson);
+        String qkry = "0";
+        String ztry = "0";
+        String zdry = "0";
+        if (StringUtils.isNotEmpty(resultToken)){
+            Map map = JSON.parseObject(resultToken, HashMap.class);  //解析整体为map
+            System.out.println(map);
+            Object dataObj = map.get("data");  //解析出data
+            if(StringUtils.isNotEmpty(dataObj.toString())){
+                Map dataMap = JSON.parseObject(dataObj.toString(), HashMap.class);   //解析出data
+                qkry = dataMap.get("qkry").toString();
+                ztry = dataMap.get("ztry").toString();
+                zdry = dataMap.get("zdry").toString();
+            }
+        }
+        resultMap.put("code","200");
+        resultMap.put("msg","身份信息反馈查询成功");
+        resultMap.put("qkry", qkry + "");
+        resultMap.put("ztry", ztry + "");
+        resultMap.put("zdry", zdry + "");
+        resultMap.put("xdry", judgeXdry(request, sfxxReqVo));
+        return resultMap;
+    }
+
+    private String judgeXdry(HttpServletRequest request, SfxxReqVo sfxxReqVo){
+        String xdry = "";
+        try {
+            String sql = "SELECT * FROM " +
+                    "case_type01 where _type= " +
+                    "'dxfqzgljdjds'";
+            if (StringUtils.isNotEmpty(sfxxReqVo.getBhcrsfzhm())){
+                sql += "and ZJHM = '" + sfxxReqVo.getBhcrsfzhm() + "' ";
+            }
+            if (StringUtils.isNotEmpty(sfxxReqVo.getXm())){
+                sql += "and XM = '" + sfxxReqVo.getXm() + "' ";
+            }
+            System.out.println("sql"+sql);
+            String map = EsUtils.newQueryEss(request, sql);
+            JSONObject jsonObject = JSONObject.parseObject(map);
+            System.out.println("============="+map);
+            JSONArray data = jsonObject.getJSONArray("data");
+            if (data != null && data.size() > 0) {
+                xdry = "1";
+            }else {
+                xdry = "0";
+            }
+        } catch (Exception e) {
+            xdry = "0";
+            e.printStackTrace();
+        }
+        return xdry;
+    }
+
+    private HashMap<String, String> initHttpXmlHeads() {
+        HashMap<String, String> headParams = new HashMap<String, String>();
+        headParams.put("Content-Type", "application/json;charset=UTF-8");
+//        headParams.put("founder.appId",)
+        return headParams;
+    }
+}