package com.pashanhoo.zhj.service.impl;

import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.pashanhoo.common.HttpUtil;
import com.pashanhoo.zhj.entity.RegBusBdcqzsdjxxDo;
import com.pashanhoo.zhj.entity.SynZhjInfoDo;
import com.pashanhoo.zhj.mapper.RegBusBdcqzsdjxxMapper;
import com.pashanhoo.zhj.mapper.SynZhjInfoMapper;
import com.pashanhoo.zhj.service.ZhjDatasSynService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;

import java.io.*;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLEncoder;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * <p>
 * 案卷基本信息 服务实现类
 * </p>
 *
 * @author
 * @since 2021-11-05
 */
@Service
public class ZhjDatasSynServiceImpl extends ServiceImpl<RegBusBdcqzsdjxxMapper, RegBusBdcqzsdjxxDo> implements ZhjDatasSynService {

    private static Logger logger = LoggerFactory.getLogger(ZhjDatasSynServiceImpl.class);
    @Autowired
    private SynZhjInfoMapper synZhjInfoMapper;
    @Autowired
    private RegBusBdcqzsdjxxMapper regBusBdcqzsdjxxMapper;
    //智慧局内网ip
    private String zhjurl="http://172.16.56.10:7050";
    //认证令牌
    private  String appkey="3cd832c411238faa1df46d532a21bfcd";
    private String appSecret="ee7612083f63c2ce0d016c2aefd0a8d2";

    //查封信息认证令牌
    private  String cfappkey="efd3cca4d0734cc0b99f06fbba303efb";
    private String cfappSecret="255e3cbe16fe44c7ac9074aeff52c384";

    public void send_bdcYwInfo() {
       List<SynZhjInfoDo> selectAllListInfo=synZhjInfoMapper.selectAllInfo();
       if(selectAllListInfo!=null && selectAllListInfo.size()>0){
           final List<RegBusBdcqzsdjxxDo> zsdjInfoList=regBusBdcqzsdjxxMapper.getZsdjInfoList(selectAllListInfo);
           if(zsdjInfoList!=null && zsdjInfoList.size()>0){
               String url=zhjurl+"/dclp/hzapi/token?appKey="+appkey+"&appSecret="+appSecret;
               Map map1=doGetForNew(url);
               if(map1!=null && (Integer)map1.get("code")==200){
                   final Map map2= (Map) map1.get("data");
                   final String token= (String) map2.get("token");
                   //组装宗地基本信息
                   new Thread(new Runnable() {
                       @Override
                       public void run() {
                           System.out.println("===============当前线程是:"+Thread.currentThread().getName());
                           synZdInfo(zsdjInfoList,token);
                       }
                   }).start();

                    //组装户信息
                   new Thread(new Runnable() {
                       @Override
                       public void run() {
                           System.out.println("===============当前线程是:"+Thread.currentThread().getName());
                           synHInfo(zsdjInfoList,token);
                       }
                   }).start();

                   //组装权属状态
                   new Thread(new Runnable() {
                       @Override
                       public void run() {
                           System.out.println("===============当前线程是:"+Thread.currentThread().getName());
                           synQSZTInfo(zsdjInfoList,token);
                       }
                   }).start();
               }
               }
           }
       }

    /**
     *根据业务通过swagger接口手动推送宗地基本信息
     * @param ywh
     * @param
     */
    public void synZdInfoByywh(String ywh){
        List<RegBusBdcqzsdjxxDo> zsdjInfoList =regBusBdcqzsdjxxMapper.getZsdjInfoListByYwh(ywh);
        if(zsdjInfoList!=null && zsdjInfoList.size()>0){
            String url=zhjurl+"/dclp/hzapi/token?appKey="+appkey+"&appSecret="+appSecret;
            Map map1=doGetForNew(url);
            if(map1!=null && (Integer)map1.get("code")==200){
                Map map2= (Map) map1.get("data");
                String token= (String) map2.get("token");
                synZdInfo(zsdjInfoList,token);
            }
        }
    }

    /**
     * 给智慧局推送宗地基本信息
     * @param zsdjInfoList
     * @param token
     */
    public void synZdInfo(List<RegBusBdcqzsdjxxDo> zsdjInfoList,String token)  {
        try{
            if(zsdjInfoList!=null && zsdjInfoList.size()>0){
                for (int i = 0; i < zsdjInfoList.size(); i++) {
                    RegBusBdcqzsdjxxDo busBdcqzsdjxxDo= zsdjInfoList.get(i);
                    List<Map> zdjglist = regBusBdcqzsdjxxMapper.getZdInfoByZddm(busBdcqzsdjxxDo);
                    if(zdjglist!=null && zdjglist.size()>0){
                        for (int j = 0; j < zdjglist.size(); j++) {
                            Map map=zdjglist.get(j);
                            StringBuilder params = new StringBuilder();
                            params.append("?").append("DJQDM=").append(map.get("DJQDM")).append("&")
                                    .append("DJQMC=").append(URLEncoder.encode((String) map.get("DJQMC"),"UTF-8")).append("&")
                                    .append("DJZQDM=").append(map.get("DJZQDM")).append("&")
                                    .append("DJZQMC=").append(URLEncoder.encode((String) map.get("DJZQMC"),"UTF-8")).append("&")
                                    .append("BDCDYH=").append(map.get("BDCDYH")).append("&")
                                    .append("ZL=").append(URLEncoder.encode((String) map.get("ZL"),"UTF-8")).append("&")
                                    .append("ZDMJ=").append(map.get("ZDMJ")).append("&")
                                    .append("YT=").append(URLEncoder.encode((String) map.get("YT"),"UTF-8"));
                            String url1=zhjurl+"/dclp/hzapi/ZDJGMS"+params.toString();
                            Integer code=doPostForNew(url1,"", token);
                            if(code==200){
                                synZhjInfoMapper.updatezdzt(busBdcqzsdjxxDo.getYwh());
                            }
                        }
                    }

                }
            }
        }catch (Exception ex){
            ex.printStackTrace();
        }

    }
    /**
     * 根据业务通过swagger接口手动推送户信息
     * @param ywh
     * @param
     */
    public void synHInfoByYwh(String ywh){
        List<RegBusBdcqzsdjxxDo> zsdjInfoList =regBusBdcqzsdjxxMapper.getZsdjInfoListByYwh(ywh);
        if(zsdjInfoList!=null && zsdjInfoList.size()>0){
            String url=zhjurl+"/dclp/hzapi/token?appKey="+appkey+"&appSecret="+appSecret;
            Map map1=doGetForNew(url);
            if(map1!=null && (Integer)map1.get("code")==200){
                Map map2= (Map) map1.get("data");
                String token= (String) map2.get("token");
                synHInfo(zsdjInfoList,token);
            }
        }
    }
    /**
     * 给智慧局推送户基本信息
     * @param zsdjInfoList
     * @param token
     */
    public void synHInfo(List<RegBusBdcqzsdjxxDo> zsdjInfoList,String token){
        try{
            if(zsdjInfoList!=null && zsdjInfoList.size()>0){
                for (int i = 0; i < zsdjInfoList.size(); i++) {
                    RegBusBdcqzsdjxxDo busBdcqzsdjxxDo= zsdjInfoList.get(i);
                    List<Map> hlist = regBusBdcqzsdjxxMapper.getHQSInfoByZddm(busBdcqzsdjxxDo);
                    if(hlist!=null && hlist.size()>0){
                        for (int j = 0; j < hlist.size(); j++) {
                            Map map=hlist.get(j);
                            StringBuilder params = new StringBuilder();
                            params.append("?").append("BDCDYH=").append(map.get("BDCDYH")).append("&")
                                    .append("ZRZH=").append(map.get("ZRZH")).append("&")
                                    .append("CH=").append(map.get("CH")).append("&")
                                    .append("ZL=").append(URLEncoder.encode((String) map.get("ZL"),"UTF-8")).append("&")
                                    .append("SJCS=").append(map.get("SJCS")).append("&")
                                    .append("SHBW=").append(URLEncoder.encode((String) map.get("SHBW"),"UTF-8")).append("&")
                                    .append("HX=").append(map.get("HX")).append("&")
                                    .append("HXJG=").append(map.get("HXJG")).append("&")
                                    .append("FWYT1=").append(map.get("FWYT1")).append("&")
                                    .append("SCJZMJ=").append(map.get("SCJZMJ")).append("&")
                                    .append("SCTNJZMJ=").append(map.get("SCTNJZMJ")).append("&")
                                    .append("SCDXBFJZMJ=").append(map.get("SCDXBFJZMJ")).append("&")
                                    .append("FTTDMJ=").append(map.get("FTTDMJ")).append("&")
                                    .append("FWLX=").append(map.get("FWLX")).append("&")
                                    .append("FWXZ=").append(map.get("FWXZ")).append("&")
                                    .append("QLLX=").append(map.get("QLLX")).append("&")
                                    .append("DJLX=").append(map.get("DJLX")).append("&")
                                    .append("SYQMJ=").append(map.get("SYQMJ")).append("&")
                                    .append("SYQQSSJ=").append(map.get("SYQQSSJ")).append("&")
                                    .append("SYQJSSJ=").append(map.get("SYQJSSJ")).append("&")
                                    .append("BDCQZH=").append(URLEncoder.encode((String) map.get("BDCQZH"),"UTF-8")).append("&")
                                    .append("QXDM=").append(map.get("QXDM")).append("&")
                                    .append("DJSJ=").append(map.get("DJSJ")).append("&")
                                    .append("QSZT=").append(map.get("QSZT")).append("&")
                                    .append("ZT=").append(map.get("ZT"));

                            String url1=zhjurl+"/dclp/hzapi/HQSJGMS"+params.toString();
                            Integer code=doPostForNew(url1,"", token);
                            if(code==200){
                                synZhjInfoMapper.updatezdzt(busBdcqzsdjxxDo.getYwh());
                            }
                        }
                    }
                }
            }
        }catch (Exception ex){
            ex.printStackTrace();
        }

    }

    /**
     * 给智慧局推送权属状态基本信息
     * @param ywh
     * @param
     */
    public void synQSZTInfoByYwh(String ywh){
        List<RegBusBdcqzsdjxxDo> zsdjInfoList =regBusBdcqzsdjxxMapper.getZsdjInfoListByYwh(ywh);
        if(zsdjInfoList!=null && zsdjInfoList.size()>0){
            String url=zhjurl+"/dclp/hzapi/token?appKey="+appkey+"&appSecret="+appSecret;
            Map map1=doGetForNew(url);
            if(map1!=null && (Integer)map1.get("code")==200){
                Map map2= (Map) map1.get("data");
                String token= (String) map2.get("token");
                synQSZTInfo(zsdjInfoList,token);
            }
        }
    }



    /**
     * 给智慧局推送权属状态基本信息
     * @param zsdjInfoList
     * @param token
     */
    public void synQSZTInfo(List<RegBusBdcqzsdjxxDo> zsdjInfoList,String token){
        if(zsdjInfoList!=null && zsdjInfoList.size()>0){
            for (int i = 0; i < zsdjInfoList.size(); i++) {
                RegBusBdcqzsdjxxDo busBdcqzsdjxxDo= zsdjInfoList.get(i);
                List<Map> qsztList = regBusBdcqzsdjxxMapper.getQSZTInfoByZddm(busBdcqzsdjxxDo);
                if(qsztList!=null && qsztList.size()>0){
                    for (int j = 0; j < qsztList.size(); j++) {
                        Map map=qsztList.get(j);
                        StringBuilder params = new StringBuilder();
                        params.append("?").append("BDCDYH=").append(map.get("BDCDYH")).append("&")
                                .append("DYQSZT=").append(map.get("DYQSZT")).append("&")
                                .append("YYQSZT=").append(map.get("YYQSZT")).append("&")
                                .append("CFQSZT=").append(map.get("CFQSZT")).append("&")
                                .append("YGQSZT=").append(map.get("YGQSZT"));
                        String url1=zhjurl+"/dclp/hzapi/QSZT"+params.toString();
                        Integer code=doPostForNew(url1,"", token);
                        if(code==200){
                            synZhjInfoMapper.updatezdzt(busBdcqzsdjxxDo.getYwh());
                        }
                    }
                }
            }
        }
    }

    public  Map doGetForNew(String url) {
        logger.info("http request url:" + url);
        BufferedReader in = null;
        String result = "";
        Map jsonObject=new HashMap();
        try{
            URL url1=new URL(url);
            HttpURLConnection conn= (HttpURLConnection) url1.openConnection();
            conn.setRequestMethod("GET");
            conn.setRequestProperty("accept","*/*");
            conn.setRequestProperty("connection","Keep-Alive");
            conn.setRequestProperty("Charset", "utf-8");
            conn.setDoInput(true);
            conn.setDoOutput(false);
            //x-qys-signature生成方式：Md5(AppToken + AppSecret + timestamp)，获取32位小写值
            conn.connect();
            in = new BufferedReader(new InputStreamReader(conn.getInputStream(),"UTF-8"));
            String line;
            while ((line = in.readLine()) != null) {
                result += line;
            }
            jsonObject=JSONObject.parseObject(result,Map.class);
            logger.info("http request back:" + jsonObject);
        }catch (Exception ex){
            logger.info("发送 POST 请求出现异常！" + ex);
            ex.printStackTrace();
        }finally {
            try {
                if (in != null) {
                    in.close();
                }
            } catch (IOException ex) {
                ex.printStackTrace();
            }
        }
        return jsonObject;
    }


    public  Integer doPostForNew(String url, String params,String token) {
        logger.info("http request url:" + url);
        logger.info("http request params:" + params);
        PrintWriter out = null;
        BufferedReader in = null;
        String result = "";
        Map jsonObject=new HashMap();
        Integer code=200;
        try{
            URL url1=new URL(url);
            HttpURLConnection conn= (HttpURLConnection) url1.openConnection();
            conn.setRequestMethod("POST");
            conn.setRequestProperty("accept","*/*");
            conn.setRequestProperty("connection","Keep-Alive");
            conn.setDoInput(true);
            conn.setDoOutput(true);
            conn.setRequestProperty("Content-Type", "application/json;charset=utf-8");
            conn.setRequestProperty("X-Access-Token", token);
            out=new PrintWriter(new OutputStreamWriter(conn.getOutputStream(),"utf-8"));
            out.print(params);
            out.flush();
            in = new BufferedReader(new InputStreamReader(conn.getInputStream(),"UTF-8"));
            String line;
            while ((line = in.readLine()) != null) {
                result += line;
            }
            jsonObject=JSONObject.parseObject(result,Map.class);
            logger.info("http request back:" + jsonObject);
            code= (Integer) jsonObject.get("code");
        }catch (Exception ex){
            logger.info("发送 POST 请求出现异常！" + ex);
            ex.printStackTrace();
            code=-1;
        }finally {
            try {
                if (out != null) {
                    out.close();
                }
                if (in != null) {
                    in.close();
                }
            } catch (IOException ex) {
                ex.printStackTrace();
            }
        }
        return code;
    }
    @Override
    public void synQYBDCXX(String token) {
            List<Map> list=synZhjInfoMapper.getQyBdcxx();
            if(list!=null  && list.size()>0) {
                for (int j = 0; j < list.size(); j++) {
                    try {
                        Map map = list.get(j);
                        StringBuilder params = new StringBuilder();
                        params.append("?");

                        String qlrmc="";
                        if(map.get("QLRMC")!=null){
                            qlrmc=URLEncoder.encode((String) map.get("QLRMC"), "UTF-8");
                        }
                        params.append("QLRMC=").append(qlrmc).append("&");

                        String  qlrzjh="";
                        if(map.get("QLRZJH")!=null){
                            qlrzjh=(String)map.get("QLRZJH");
                        }
                        params.append("QLRZJH=").append(qlrzjh).append("&");

                        String bdcqzsh="";
                        if(map.get("BDCQZSH")!=null){
                            bdcqzsh=URLEncoder.encode((String) map.get("BDCQZSH"), "UTF-8");
                        }
                        params.append("BDCQZSH=").append(bdcqzsh).append("&");

                        String bdcdyh="";
                        if(map.get("BDCDYH")!=null){
                            bdcdyh= (String) map.get("BDCDYH");
                        }
                        params.append("BDCDYH=").append(bdcdyh).append("&");

                        String djsj="";
                        if(map.get("DJSJ")!=null){
                            djsj= (String) map.get("DJSJ");
                        }
                        params.append("DJSJ=").append(djsj).append("&");

                        String yt="";
                        if(map.get("YT")!=null){
                            yt=URLEncoder.encode((String) map.get("YT"), "UTF-8");
                        }
                        params.append("YT=").append(yt).append("&");

                        String zl="";
                        if(map.get("ZL")!=null){
                            zl=URLEncoder.encode((String) map.get("ZL"), "UTF-8");
                        }
                        params.append("ZL=").append(zl).append("&");

                        String mj="";
                        if(map.get("MJ")!=null){
                            mj= (String) map.get("MJ");
                        }
                        params.append("MJ=").append(mj).append("&");

                        String syqx="";
                        if(map.get("SYQX")!=null){
                            syqx=URLEncoder.encode((String) map.get("SYQX"), "UTF-8");
                        }
                        params.append("SYQX=").append(syqx).append("&");

                        String djjg="";
                        if(map.get("DJJG")!=null){
                            djjg=URLEncoder.encode((String) map.get("DJJG"), "UTF-8");
                        }
                        params.append("DJJG=").append(djjg);

                        String url1 = zhjurl + "/dclp/hzapi/QYBDCXX" + params.toString();
                        doPostForNew(url1, "", token);
                    } catch (Exception ex) {
                        ex.printStackTrace();
                    }
                }
            }
    }

    @Override
    public void qymxFcDyxx(String token) {
            List<Map> list=synZhjInfoMapper.getQymxfcdyxx();
            if(list!=null  && list.size()>0){
                for (int j = 0; j < list.size(); j++) {
                    try{
                        Map map=list.get(j);
                        StringBuilder params = new StringBuilder();
                        params.append("?");

                        String dyqr="";
                        if(map.get("DYQR")!=null){
                            dyqr= URLEncoder.encode((String)map.get("DYQR"),"UTF-8");
                        }
                        params.append("DYQR=").append(dyqr).append("&");

                        String dyqrzjh="";
                        if(map.get("DYQRZJH")!=null){
                            dyqrzjh= (String) map.get("DYQRZJH");
                        }
                        params.append("DYQRZJH=").append(dyqrzjh).append("&");

                        String bdcdjzmh="";
                        if(map.get("BDCDJZMH")!=null){
                            bdcdjzmh=URLEncoder.encode((String)map.get("BDCDJZMH"),"UTF-8");
                        }
                        params.append("BDCDJZMH=").append(bdcdjzmh).append("&");

                        String bdcdyh="";
                        if(map.get("BDCDYH")!=null){
                            bdcdyh= (String) map.get("BDCDYH");
                        }
                        params.append("BDCDYH=").append(bdcdyh).append("&");

                        String qllx="";
                        if(map.get("QLLX")!=null){
                            qllx=URLEncoder.encode((String)map.get("QLLX"),"UTF-8");
                        }
                        params.append("QLLX=").append(qllx).append("&");

                        String dyr="";
                        if(map.get("DYR")!=null){
                            dyr=URLEncoder.encode((String)map.get("DYR"),"UTF-8");
                        }
                        params.append("DYR=").append(dyr).append("&");

                        String dydjsj="";
                        if(map.get("DYDJSJ")!=null){
                            dydjsj= (String) map.get("DYDJSJ");
                        }
                        params.append("DYDJSJ=").append(dydjsj);

                        String url1=zhjurl+"/dclp/hzapi/QYMXFCDYXX"+params.toString();
                        doPostForNew(url1,"", token);
                    }catch (Exception ex){
                        ex.printStackTrace();
                    }
                }
            }
    }

    @Override
    public void synQyInfo() {
        String url=zhjurl+"/dclp/hzapi/token?appKey="+appkey+"&appSecret="+appSecret;
        Map map1=doGetForNew(url);
        if(map1!=null && (Integer)map1.get("code")==200){
            final Map map2= (Map) map1.get("data");
            final String token= (String) map2.get("token");
            //组装中小微企业基本信息
            new Thread(new Runnable() {
                @Override
                public void run() {
                    System.out.println("===============当前线程是:"+Thread.currentThread().getName());
                    synQYBDCXX(token);
                }
            }).start();

           //组装中小微企业抵押信息
            new Thread(new Runnable() {
                @Override
                public void run() {
                    System.out.println("===============当前线程是:"+Thread.currentThread().getName());
                    qymxFcDyxx(token);
                }
            }).start();

        }
    }



/*推送查封信息*/
    @Override
    public void synYcfInfo() {
            //预查封推送执行
            new Thread(new Runnable() {
                @Override
                public void run() {
                    System.out.println("===============当前线程是:"+Thread.currentThread().getName());
                    synYcfBDCXX();
                }
            }).start();

    }



    /*推送查封信息*/
    @Override
    public void synCfInfo() {
            //组装中小微企业基本信息
            new Thread(new Runnable() {
                @Override
                public void run() {
                    System.out.println("===============当前线程是:"+Thread.currentThread().getName());
                    getCFBdcxx();
                }
            }).start();

    }


//907   房屋预查封   905  房屋查封登记

    public void synYcfBDCXX() {
        List<Map> list=synZhjInfoMapper.getYCFBdcxx();
        if(list!=null  && list.size()>0) {
            for (int j = 0; j < list.size(); j++) {
                try {

                    String url=zhjurl+"/dclp/hzapi/token?appKey="+cfappkey+"&appSecret="+cfappSecret;
                    Map map1=doGetForNew(url);
                    if(map1!=null && (Integer)map1.get("code")==200) {
                        final Map map2 = (Map) map1.get("data");
                        final String token = (String) map2.get("token");
                        Map<String, String> map = list.get(j);
                        if (((String) map.get("ISCHAFENG"))!=null) {
                            if (Integer.valueOf((String) map.get("ISCHAFENG")) >= 100) {
                                map.put("ISCHAFENG", "1");
                            }
                        }
                        Map<String, String> headers = new HashMap<>();
                        headers.put("X-Access-Token", token);

                        String url1 = zhjurl + "/dclp/hzapi/YCFXX";
                        HttpUtil.getReturnResByUrl(url1, map, headers, "utf-8");
                    }
                } catch (Exception ex) {
                    ex.printStackTrace();
                }
            }
        }
    }




    public void getCFBdcxx() {
        List<Map> list=synZhjInfoMapper.getCFBdcxx();
        if(list!=null  && list.size()>0) {
            for (int j = 0; j < list.size(); j++) {
                try {
                    String url=zhjurl+"/dclp/hzapi/token?appKey="+cfappkey+"&appSecret="+cfappSecret;
                    Map map1=doGetForNew(url);
                    if(map1!=null && (Integer)map1.get("code")==200) {
                        final Map map2 = (Map) map1.get("data");
                        final String token = (String) map2.get("token");
                        Map<String, String> map = list.get(j);
                        if (((String) map.get("ISCHAFENG")) != null) {
                            if (Integer.valueOf((String) map.get("ISCHAFENG")) >= 100) {
                                map.put("ISCHAFENG", "1");
                            }
                        }
                        Map<String, String> headers = new HashMap<>();
                        headers.put("X-Access-Token", token);


                        String url1 = zhjurl + "/dclp/hzapi/CFXX";
                        HttpUtil.getReturnResByUrl(url1, map, headers, "utf-8");
                    }
                } catch (Exception ex) {
                    ex.printStackTrace();
                }
            }
        }
    }
}