湖南常口提交(湖南)

service/publicapi/src/main/java/com/founder/publicapi/controller/SkInterface/RyxxQgInterface.java

 package com.founder.publicapi.controller.SkInterface;
 
+import com.alibaba.fastjson.JSONObject;
 import com.founder.commonutils.model.newPublicEntity.MapRestResult;
 import com.founder.commonutils.model.newPublicEntity.SkRegionalsPerson;
+import com.founder.commonutils.model.newPublicEntity.TbStRy;
 import com.founder.commonutils.util.HttpUtil;
 import com.founder.publicapi.mapper.mysqlMapper.SysDictitemMapper;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
+import org.apache.commons.lang.StringUtils;
 import org.dom4j.Document;
 import org.dom4j.DocumentHelper;
 import org.dom4j.Element;
@@ -13,9 +16,9 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.web.bind.annotation.PostMapping;
 
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
+import java.text.DateFormat;
+import java.text.SimpleDateFormat;
+import java.util.*;
 
 /**
  * 全国人员常口接口
@@ -34,19 +37,70 @@ public class RyxxQgInterface {
         SkRegionalsPerson ryxx=new SkRegionalsPerson();
         String esbServiceReturn="";
         //String url="http://10.100.17.115:8080/NmgEsbQueryService/QueryLocalPersonForOther?conditions=sfzh="+"'"+zjhm+"'";
-        String url=getConn()+"'"+zjhm+"'";
-        HttpUtil hu=new HttpUtil();
+//        String url=getConn()+"'"+zjhm+"'";
+//        HttpUtil hu=new HttpUtil();
+//        try {
+//            esbServiceReturn=hu.doGet(url);
+//        } catch (Exception e) {
+//            return MapRestResult.error("失败"+e);
+//        }
+        Map<String,String> map=new HashMap();
+        map.put("zjhm",zjhm);
+        String resultStr="";
         try {
-            esbServiceReturn=hu.doGet(url);
+            System.out.println("常口调用开始==============="+zjhm);
+            resultStr=HttpUtil.doPost("http://65.26.2.184:1005/getRyxxByQgck",map);
+            if(StringUtils.isNotBlank(resultStr)){
+                System.out.println("常口调用成功==============="+zjhm);
+                JSONObject jsonObject=JSONObject.parseObject(resultStr);
+                if(jsonObject!=null&&jsonObject.containsKey("data")){
+                    JSONObject jsonObject1=jsonObject.getJSONObject("data");
+                    if(jsonObject1!=null&&jsonObject1.containsKey("ryxx")){
+                        TbStRy tbStRy=jsonObject1.getObject("ryxx", TbStRy.class);
+                        if(tbStRy!=null){
+                            ryxx=getQgxx(tbStRy);
+                        }
+                    }
+                }
+            }
         } catch (Exception e) {
-            return MapRestResult.error("失败"+e);
+            e.printStackTrace();
         }
-        ryxx=getryJbxxxmls(esbServiceReturn);
+        //ryxx=getryJbxxxmls(esbServiceReturn);
         listSkRegionalsPerson.add(ryxx);
         return MapRestResult.build(200, "OK",listSkRegionalsPerson.size(),listSkRegionalsPerson);
 
     }
 
+    private SkRegionalsPerson getQgxx(TbStRy tbStRy) {
+        SkRegionalsPerson qgRyJbXx= null;
+        try {
+            qgRyJbXx = new SkRegionalsPerson();
+            qgRyJbXx.setXm(tbStRy.getXm());
+            qgRyJbXx.setXb(tbStRy.getXbdmStr());
+            qgRyJbXx.setMz(tbStRy.getMzdmStr());
+            qgRyJbXx.setSfzhm(tbStRy.getZjhm());
+            qgRyJbXx.setHjdqhdz(tbStRy.getHjdzXzqhdmStr());
+            qgRyJbXx.setCsdzmc(tbStRy.getCsdDzmc());
+            qgRyJbXx.setImg("data:image/jpg;base64,"+tbStRy.getEdzzplj());
+            qgRyJbXx.setXzzdzmc(tbStRy.getXzzDzmc());
+            Date csrq=tbStRy.getCsrqQsrq();
+            String csrqQsrq = null;
+            if(csrq != null) {
+                DateFormat fmt = new SimpleDateFormat("yyyyMMdd");
+                try {
+                    csrqQsrq=fmt.format(csrq);
+                    qgRyJbXx.setCsrq(csrqQsrq);
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return qgRyJbXx;
+    }
+
     public  SkRegionalsPerson getQgckAllxx(String zjhm){
         List<SkRegionalsPerson> listSkRegionalsPerson = new ArrayList<>();
         SkRegionalsPerson ryxx=new SkRegionalsPerson();