package com.pashanhoo.qys.service.impl;

import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.pashanhoo.common.EciHttpUtil;
import com.pashanhoo.common.Result;
import com.pashanhoo.qys.entity.ElecLicenseInfoDo;
import com.pashanhoo.qys.mapper.ElecLicenseInfoMapper;
import com.pashanhoo.qys.service.EciService;
import com.pashanhoo.zhj.mapper.RegBusBdcqzsdjxxMapper;
import net.glxn.qrgen.core.image.ImageType;
import net.glxn.qrgen.javase.QRCode;
import org.apache.commons.codec.binary.Base64;
import org.apache.commons.lang3.StringUtils;
import org.ofdrw.converter.ImageMaker;
import org.ofdrw.reader.OFDReader;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

import javax.imageio.ImageIO;
import java.awt.image.BufferedImage;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.IOException;
import java.net.URLEncoder;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.text.SimpleDateFormat;
import java.util.*;


@Service
public class EciServiceImpl extends ServiceImpl<ElecLicenseInfoMapper, ElecLicenseInfoDo> implements EciService {

    private static Logger logger = LoggerFactory.getLogger(EciServiceImpl.class);
    @Value("${app.hostUrl}")
    private String hostUrl;

    @Value("${app.bdcdjzmlc}")
    private String bdcdjzmlc;

    @Value("${app.bdcqzslc}")
    private String bdcqzslc;

    @Autowired
    private RegBusBdcqzsdjxxMapper regBusBdcqzsdjxxMapper;
    @Autowired
    private ElecLicenseInfoMapper elecLicenseInfoMapper;
    @Autowired
    private EciHttpUtil eciHttpUtil;



    @Override
    public void accessCreateContract() {
        try{
            List<Map> list=assemblyInfo();
            if(list!=null && list.size()>0){
                for (int i = 0; i < list.size(); i++) {
                    //=========创建合同t==============
                    ElecLicenseInfoDo elecLicenseInfo=createContract(list.get(i));
                    if(null==elecLicenseInfo || !"0".equals(elecLicenseInfo.getErr_state())){
                        continue;
                    }
                    //=========合同详情==============
                    ElecLicenseInfoDo details=accessDetails(elecLicenseInfo);
                    if(null==details || !"0".equals(details.getErr_state())){
                        continue;
                    }
                    //=========证照下载==============
                    ElecLicenseInfoDo download=accessDownload(details);
                    if(null==download || !"0".equals(download.getErr_state())){
                        continue;
                    }
                    //=========ofd转换==============
                    ElecLicenseInfoDo ofdzh=convertElec(download);
                    if(null==ofdzh || !"0".equals(ofdzh.getErr_state())){
                        continue;
                    }
                    //修改电子证书标识
                    elecLicenseInfoMapper.updateEciInfo(ofdzh.getBizId());
                }
            }
        }catch (Exception ex){
            ex.printStackTrace();
        }
    }

    @Override
    public Result createContractForHandle(String zsbs, String qlrzjh, String bh) {
        List<Map> list=createInfoByHandle(zsbs,qlrzjh,bh);
        if(list!=null && list.size()>0){
            for (int i = 0; i < list.size(); i++) {
                createContract(list.get(i));
            }
        }
        return Result.ok();
    }

    @Override
    public Result accessDetailsForHandle(String biz_id) {
        ElecLicenseInfoDo elecLicenseInfoDo=this.getById(biz_id);
        if(elecLicenseInfoDo!=null){
            accessDetails(elecLicenseInfoDo);
        }
        return Result.ok();
    }

    @Override
    public Result accessDownloadForHandle(String biz_id) {
        ElecLicenseInfoDo elecLicenseInfoDo=this.getById(biz_id);
        if(elecLicenseInfoDo!=null){
            accessDownload(elecLicenseInfoDo);
        }
        return Result.ok();
    }

    @Override
    public Result convertElecForHandle(String biz_id) {
        ElecLicenseInfoDo elecLicenseInfoDo=this.getById(biz_id);
        if(elecLicenseInfoDo!=null){
            convertElec(elecLicenseInfoDo);
            elecLicenseInfoMapper.updateEciInfo(biz_id);
        }
        return Result.ok();
    }

    /**
     *插入电子证照表记录
     * @param tjcs
     * @param documentParam
     * @param backjson
     * @param jbxxmap
     */
    public ElecLicenseInfoDo insertEciInfo(String tjcs,String documentParam, Map backjson,Map jbxxmap){
        ElecLicenseInfoDo elecLicenseInfoDo=new ElecLicenseInfoDo();
        elecLicenseInfoDo.setTjcs(tjcs);
        elecLicenseInfoDo.setDocumentParam(documentParam);
        elecLicenseInfoDo.setZsbh((String) jbxxmap.get("BH"));
        elecLicenseInfoDo.setQlrmc((String) jbxxmap.get("QLRMC"));
        elecLicenseInfoDo.setZjh((String) jbxxmap.get("ZJH"));
        if(backjson.isEmpty()){
            elecLicenseInfoDo.setErr_state("1");
        }else{
            if ((Integer)backjson.get("code")==0) {
                Long contractId = Long.valueOf((String) backjson.get("contractId"));
                //合同ID入库
                elecLicenseInfoDo.setContractId(contractId);
                elecLicenseInfoDo.setErr_state("0");
                regBusBdcqzsdjxxMapper.updateBdcqzsjbxxInfo((String) jbxxmap.get("ID"));
            }else{
                elecLicenseInfoDo.setErr_state("1");
            }
        }
        elecLicenseInfoDo.setYwh((String) jbxxmap.get("YWH"));
        if(((String)jbxxmap.get("BDCQZH")).contains("证明")){
            elecLicenseInfoDo.setHtlx("1");
        }else{
            elecLicenseInfoDo.setHtlx("2");
        }
        elecLicenseInfoDo.setZsbs((String) jbxxmap.get("ID"));
        elecLicenseInfoDo.setEwmimage(getImage((String) jbxxmap.get("ID"),(String) jbxxmap.get("QLRMC"),(String) jbxxmap.get("ZJH")));
        //返回结果入库
        elecLicenseInfoDo.setFhjg(JSON.toJSONString(backjson));
        //未下载
        elecLicenseInfoDo.setSfxz("2");
        //未转换
        elecLicenseInfoDo.setSfzh("2");
        this.save(elecLicenseInfoDo);
        return elecLicenseInfoDo;
    }
    /**
     *修改电子证照表记录
     * @param tjcs
     * @param documentParam
     * @param backjson
     * @param
     */
    public ElecLicenseInfoDo updateEciInfo(String tjcs,String documentParam, Map backjson,ElecLicenseInfoDo elecLicenseInfoDo){
        elecLicenseInfoDo.setTjcs(tjcs);
        elecLicenseInfoDo.setDocumentParam(documentParam);
        if(backjson.isEmpty()){
            elecLicenseInfoDo.setErr_state("1");
        }else{
            if ((Integer)backjson.get("code")==0) {
                Long contractId = Long.valueOf((String) backjson.get("contractId"));
                //合同ID入库
                elecLicenseInfoDo.setContractId(contractId);
                elecLicenseInfoDo.setErr_state("0");
                regBusBdcqzsdjxxMapper.updateBdcqzsjbxxInfo(elecLicenseInfoDo.getZsbs());
            }else{
                elecLicenseInfoDo.setErr_state("1");
            }
        }
        //返回结果入库
        elecLicenseInfoDo.setFhjg(JSON.toJSONString(backjson));
        //未下载
        elecLicenseInfoDo.setSfxz("2");
        //未转换
        elecLicenseInfoDo.setSfzh("2");
        this.updateById(elecLicenseInfoDo);
        return elecLicenseInfoDo;
    }
    /**
     * 生成文件流
     * @param jbxxId
     * @return
     */
    public byte[] getImage(String jbxxId,String qlr,String zjh){
        byte[] data=null;
        try{
            String imageurl="https://www.hzbdcdj.com/api?scene="+jbxxId+"&qlr="+ URLEncoder.encode(qlr,"UTF-8")+"&zjh="+zjh;
            logger.info("55555555============"+imageurl);
            ByteArrayOutputStream out= QRCode.from(imageurl).to(ImageType.PNG).stream();
            data = out.toByteArray();
        }catch (Exception ex){
            ex.printStackTrace();
        }
        return data;
    }

    /**
     * 根据基本信息id生成二维码图片加密字符串
     * @param jbxxId
     * @return
     */
    public String getBase64ewm(String jbxxId,String qlr,String zjh){
        byte[] data=getImage(jbxxId,qlr,zjh);
        String base64ewm =Base64.encodeBase64String(data);
        return base64ewm;
    }


    /**
     * 创建合同
     * @param map
     */
    public ElecLicenseInfoDo createContract(Map map){
        String url=hostUrl + "/contract/createbycategory";
        ElecLicenseInfoDo elecLicenseInfo=null;
        try{
                String ywh = (String) map.get("YWH");
                Map jsonMap = new HashMap();
                jsonMap.put("sn", ywh);
                jsonMap.put("send", "true");
                jsonMap.put("creatorName", "");
                jsonMap.put("creatorContact", "");
                jsonMap.put("tenantName", "汉中市不动产登记交易服务中心");
                String zsbh= (String) map.get("BH");//去掉汉字的证书编号，数字组合


                Map<String, String> documentMap = new HashMap<String, String>();
                String bdcqzh = (String) map.get("BDCQZH");
                if (bdcqzh.contains("证明")) {
                    jsonMap.put("subject", "不动产登记证明");
                    jsonMap.put("categoryId", bdcdjzmlc);
                    List<String> ywrmcList=elecLicenseInfoMapper.getYwrMcByCOnditon(ywh,(String) map.get("BDCDYH"));
                    documentMap.put("bdczmh", zsbh);
                    documentMap.put("zmqlhsx",getzmsx((String) map.get("DJLX"),(String) map.get("BDCDYH")));
                    documentMap.put("ywr", StringUtils.join(ywrmcList.toArray(), ","));
                    documentMap.put("qt", map.get("QT")==null ? "无": (String) map.get("QT"));
                } else {
                    jsonMap.put("subject", "不动产登记证书");
                    jsonMap.put("categoryId", bdcqzslc);

                    documentMap.put("bdcqzh",zsbh);
                    documentMap.put("gyqk", map.get("GYQK")==null ? "": (String) map.get("GYQK"));
                    documentMap.put("qllx", map.get("QLLX")==null ? "": (String) map.get("QLLX"));
                    documentMap.put("qlxz", map.get("QLXZ")==null ? "": (String) map.get("QLXZ"));
                    documentMap.put("yt", map.get("YT")==null ? "": (String) map.get("YT"));
                    documentMap.put("mj", map.get("MJ")==null ? "": (String) map.get("MJ"));
                    documentMap.put("syqx", map.get("SYQX")==null ? "": (String) map.get("SYQX"));
                    documentMap.put("qlqtzk", map.get("QLQTZK")==null ? "": (String) map.get("QLQTZK"));
                }

                List list2 = new ArrayList();
                Map map2 = new HashMap();
                map2.put("type", "CORPORATE");
                map2.put("name", "汉中市不动产登记交易服务中心");
                map2.put("serialNo", "1");
                list2.add(map2);

                List list1 = new ArrayList();
                Map map1 = new HashMap();
                map1.put("tenantType", "CORPORATE");
                map1.put("tenantName", "汉中市不动产登记交易服务中心");
                map1.put("serialNo", "1");
                map1.put("actions", list2);
                list1.add(map1);

                jsonMap.put("signatories", list1);

                documentMap.put("djsj", map.get("Y")==null ? "":(String) map.get("Y"));
                documentMap.put("y", map.get("Y")==null ? "":(String) map.get("Y"));
                documentMap.put("m", map.get("M")==null ? "":(String) map.get("M"));
                documentMap.put("d", map.get("D")==null ? "":(String) map.get("D"));
                documentMap.put("qlr", map.get("QLRMC")==null ? "":(String) map.get("QLRMC"));
                documentMap.put("zl", map.get("ZL")==null ? "":(String) map.get("ZL"));
                documentMap.put("bdcdyh", map.get("BDCDYH")==null ? "":(String) map.get("BDCDYH"));
                documentMap.put("fj", "业务号："+ywh);
                documentMap.put("qx", "汉台区");

                String base64ewm =getBase64ewm((String) map.get("ID"),(String) map.get("QLRMC"),(String) map.get("ZJH"));

                Map ewmMap = new HashMap();
                ewmMap.put("fileName", map.get("ID")+".png");
                ewmMap.put("value", "data:image/png;base64,"+base64ewm);
                documentMap.put("ewm", JSON.toJSONString(ewmMap));

                List<Map> arryList = new ArrayList<Map>();
                for (Map.Entry<String, String> entry : documentMap.entrySet()) {
                    convert(arryList, entry.getKey(), entry.getValue());
                }

                jsonMap.put("documentParams", arryList);
                String inparam=JSON.toJSONString(jsonMap);

                Map jsonObject =eciHttpUtil.doPostForNew(url, inparam);
                elecLicenseInfo =new ElecLicenseInfoDo();
                elecLicenseInfo.setYwh((String) map.get("YWH"));
                elecLicenseInfo.setZsbs((String) map.get("ID"));
                elecLicenseInfo.setZsbh(zsbh);
                elecLicenseInfo.setZjh((String) map.get("ZJH"));
                elecLicenseInfo =elecLicenseInfoMapper.getElecLicenseInfo(elecLicenseInfo);
                if(elecLicenseInfo==null){
                    //电子证照表记录
                    elecLicenseInfo=insertEciInfo(inparam,JSON.toJSONString(documentMap),jsonObject,map);
                }else{
                    elecLicenseInfo=updateEciInfo(inparam,JSON.toJSONString(documentMap),jsonObject,elecLicenseInfo);
                }
        }catch (Exception ex){
            ex.printStackTrace();
        }
        return elecLicenseInfo;
    }


    public void convert(List arryList,String name,String  value){
        Map map=new HashMap();
        map.put("name",name);
        map.put("value",value);
        arryList.add(map);
    }

    public ElecLicenseInfoDo accessDetails(ElecLicenseInfoDo waitForDetail) {
        ElecLicenseInfoDo elecLicenseInfoDo=null;
        try {
                Long contractId = waitForDetail.getContractId();
                String url = hostUrl+ "/contract/detail?contractId=" + contractId;
                logger.info("请求合同详情接口url:" + url);

                 Map jsonObject = eciHttpUtil.doGetForNew(url);

                if(jsonObject.isEmpty()){
                    waitForDetail.setErr_state("2");
                }else{
                    Integer code = (Integer) jsonObject.get("code");
                    logger.info("合同详情接口请求结果:" + jsonObject);
                    if (code==0) {
                        Map obj1= (Map) jsonObject.get("contract");
                        List list= (List) obj1.get("documents");
                        Map map= (Map) list.get(0);
                        waitForDetail.setErr_state("0");
                        waitForDetail.setDocumentId((String) map.get("id"));
                    }else{
                        waitForDetail.setErr_state("2");
                    }
                }
                //文档ID入库
                this.updateById(waitForDetail);

                elecLicenseInfoDo=waitForDetail;

        } catch (Exception e) {
            e.printStackTrace();
        }
        return elecLicenseInfoDo;
    }
    /**
     * 下载合同方法
     * @return
     */
    public ElecLicenseInfoDo accessDownload(ElecLicenseInfoDo waitForDownload) {
        ElecLicenseInfoDo downloadInfo=null;
        try{
            String documentId = waitForDownload.getDocumentId();
            String bh=waitForDownload.getZsbh();
            String ofdPath = eciHttpUtil.download(documentId,bh);
            if (StringUtils.isNotBlank(ofdPath)) {
                //入库ofd文件地址
                waitForDownload.setSfxz("1");
                waitForDownload.setOfdWjdz(ofdPath);
                waitForDownload.setErr_state("0");
            }else{
                waitForDownload.setErr_state("3");
            }
            this.updateById(waitForDownload);
            downloadInfo=waitForDownload;
        }catch (Exception ex){
            ex.printStackTrace();
        }
        return downloadInfo;
    }

    public ElecLicenseInfoDo convertElec(ElecLicenseInfoDo waitForConvert) {
        //转换后文件输出路径
        ElecLicenseInfoDo convert=null;
        try {
            String ofdPath = waitForConvert.getOfdWjdz();
            String id=waitForConvert.getDocumentId();
            String bh=waitForConvert.getZsbh();
            SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy");
            String dateDir = simpleDateFormat.format(new Date());
            String url=ofdToImg(ofdPath,"D:\\ECI\\"+ dateDir+bh+"\\",id);
            if(StringUtils.isNotBlank(url)){
                waitForConvert.setSfzh("1");
                waitForConvert.setJpgWjdz(url);
                waitForConvert.setErr_state("0");
            }else{
                waitForConvert.setErr_state("4");
            }
            this.updateById(waitForConvert);
            convert=waitForConvert;

        } catch (Exception  e) {
            e.printStackTrace();
        }
        return convert;
    }

    /**
     * 将ofd转换为图片
     * @param
     * @param imgPath 目标文件路径
     */
    public  String ofdToImg(String ofdPath, String imgPath,String id) {
        File savePath = new File(imgPath);
        if (!savePath.exists()) {
            savePath.mkdirs();
        }
        // 1. 文件输入路径
        Path src = Paths.get(ofdPath);
        // 2. 加载指定目录字体(非必须)
        // FontLoader.getInstance().scanFontDir(new File("src/test/resources/fonts"));
        // 3. 创建转换转换对象，设置 每毫米像素数量(Pixels per millimeter)
        try(OFDReader reader = new OFDReader(src);) {
            ImageMaker imageMaker = new ImageMaker(reader, 15);
            for (int i = 0; i < imageMaker.pageSize(); i++) {
                // 4. 指定页码转换图片
                BufferedImage image = imageMaker.makePage(i);
                Path dist = Paths.get( imgPath+ id + ".jpg");
                // 5. 存储为指定格式图片
                ImageIO.write(image, "JPG", dist.toFile());
                return  imgPath + id + ".jpg";
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
        return "";
    }

    /**
     *根据缮证类型决定生成对应的权利相关信息
     */
    public List<Map> assemblyInfo(){
        List<Map>  oldlist=regBusBdcqzsdjxxMapper.getBdcqzsjbxxInfo();
        List<Map> list=new ArrayList<Map>();
        if(oldlist!=null && oldlist.size()>0){
            for (int i = 0; i < oldlist.size(); i++) {
                Map map=oldlist.get(i);
                String bh= (String)map.get("BH");
                String zsbh[]=bh.split(",");
                if(zsbh!=null && zsbh.length>0){
                    String qlqtzk=(String)map.get("QLQTZK");
                    Map qrlInfoMap=regBusBdcqzsdjxxMapper.getQlrInfoByYwh((String) map.get("YWH"));
                    if(qrlInfoMap!=null){
                        String allQlrmc=(String)qrlInfoMap.get("QLRMC");
                        String allZjh=(String)qrlInfoMap.get("ZJH");
                        if(StringUtils.isNotBlank(allQlrmc)){
                            for (int k = 0; k < zsbh.length; k++) {
                                String qlr[]=allQlrmc.split(",");
                                String zjh[]=allZjh.split(",");
                                Map hashMap=new HashMap(map);
                                hashMap.put("QLRMC",qlr[k]);
                                hashMap.put("BH",zsbh[k]);
                                hashMap.put("ZJH",zjh[k]);
                                List list1= Arrays.asList(qlr);
                                List arrList = new ArrayList(list1);
                                arrList.remove(qlr[k]);
                                String gyr=StringUtils.join(arrList.toArray(),",");
                                if(StringUtils.isNotBlank(qlqtzk)){
                                    qlqtzk=qlqtzk.substring(0, qlqtzk.length() - 1);
                                    if(arrList!=null && arrList.size()>0){
                                        hashMap.put("QLQTZK",qlqtzk+hashMap.get("GYQK")+";共有人："+gyr);
                                    }else{
                                        hashMap.put("QLQTZK",qlqtzk+hashMap.get("GYQK"));
                                    }

                                }
                                list.add(hashMap);
                            }
                        }
                    }
                }
            }
        }
        return list;
    }

    /**
     * 手动版创建合同组件信息
     * @return
     */
    public List<Map> createInfoByHandle(String zsbs,String qlrzjh,String bh){
        List<Map> list=new ArrayList<Map>();
        Map map=regBusBdcqzsdjxxMapper.getBdcqzsJbxxById(zsbs);
        if(map!=null){
            Map qrlInfoMap=regBusBdcqzsdjxxMapper.getQlrInfoByYwh((String) map.get("YWH"));
            String allQlrmc=(String)qrlInfoMap.get("QLRMC");
            if(StringUtils.isNotBlank(allQlrmc)){
                String allZjh=(String)qrlInfoMap.get("ZJH");
                if(StringUtils.isNotBlank(allZjh)){
                    String zjh[]=allZjh.split(",");
                    String qlqtzk=(String)map.get("QLQTZK");
                    for (int k = 0; k < zjh.length; k++) {
                        if(StringUtils.equals(qlrzjh,zjh[k])){
                            String qlr[]=allQlrmc.split(",");
                            Map hashMap=new HashMap(map);
                            hashMap.put("QLRMC",qlr[k]);
                            hashMap.put("BH",bh);
                            hashMap.put("ZJH",qlrzjh);
                            List list1= Arrays.asList(qlr);
                            List arrList = new ArrayList(list1);
                            arrList.remove(qlr[k]);
                            String gyr=StringUtils.join(arrList.toArray(),",");
                            if(StringUtils.isNotBlank(qlqtzk)){
                                qlqtzk=qlqtzk.substring(0, qlqtzk.length() - 1);
                                hashMap.put("QLQTZK",qlqtzk+hashMap.get("GYQK")+";共有人："+gyr);
                            }
                            list.add(hashMap);
                        }
                    }
                }
            }
        }
        return list;
    }



    public String getzmsx(String djxl,String bdcdyh){
        //证明权利或事项
        if(djxl.equals("214") || djxl.equals("215")
                || djxl.equals("213") || djxl.equals("209")
                || djxl.equals("315") || djxl.equals("605")
                || djxl.equals("430") || djxl.equals("316")
                || djxl.equals("606") || djxl.equals("431")
                || djxl.equals("427") || djxl.equals("428")
                || djxl.equals("317") || djxl.equals("318")
                || djxl.equals("608") || djxl.equals("433")
                || djxl.equals("422") || djxl.equals("217")){
                        if(djxl.equals("213") || djxl.equals("316")
                                || djxl.equals("606") || djxl.equals("431")
                                || djxl.equals("427") || djxl.equals("428")){
                            return  "在建工程抵押权";
                        }else {
                            return "抵押权";
                        }
        }else {
            //预抵押变更事项可以修改期房和现房的预抵押所以应取上一笔的预抵押信息，获取上一笔抵押登记小类
            if (djxl.equals("818") || djxl.equals("607")
                    || djxl.equals("432")){
                Map rightsInfo= regBusBdcqzsdjxxMapper.getRightsInfo(bdcdyh);
                if(rightsInfo!=null){
                    return regBusBdcqzsdjxxMapper.getInfoByValue((String) rightsInfo.get("REMARKS"),"reg_bus_djxl");
                }
            }else {
                if(djxl.equals("609") || djxl.equals("812") || djxl.equals("809") || djxl.equals("810") || djxl.equals("811")){
                    return regBusBdcqzsdjxxMapper.getInfoByValue("803","reg_bus_djxl");
                }else{
                    return regBusBdcqzsdjxxMapper.getInfoByValue(djxl,"reg_bus_djxl");
                }
            }
        }
        return "";
    }


}