java-insagent-pc/src/main/java/com/ydtech/modules/ins/service/impl/InsAlltrustApiServiceImpl.java

package com.ydtech.modules.ins.service.impl;

import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.*;
import com.fasterxml.jackson.dataformat.xml.XmlMapper;
import com.ydtech.components.InsAlltrustRequestApiComponents;
import com.ydtech.constants.InsTaskHistoryEnum;
import com.ydtech.constants.enums.InsOrderStatus;
import com.ydtech.constants.enums.InsQuoteFlow;
import com.ydtech.constants.enums.dict.AttachInsureEnum;
import com.ydtech.constants.enums.dict.WhetherEnum;
import com.ydtech.core.page.HttpResult;
import com.ydtech.exception.SystemException;
import com.ydtech.modules.admin.model.SysUser;
import com.ydtech.modules.admin.service.SysDeptService;
import com.ydtech.modules.admin.service.SysUserService;
import com.ydtech.modules.esm.dao.EsmInsAttachInsureDetailsMapper;
import com.ydtech.modules.esm.dao.EsmInsAttachInsureMapper;
import com.ydtech.modules.esm.model.*;
import com.ydtech.modules.esm.service.*;
import com.ydtech.modules.ins.dao.InsAlltrustRegionMapper;
import com.ydtech.modules.ins.model.InsApiLog;
import com.ydtech.modules.ins.model.ya.CarModelDTO;
import com.ydtech.modules.ins.model.ya.CarModel_Req;
import com.ydtech.modules.ins.model.ya.YaQuoteInfoVo;
import com.ydtech.modules.ins.model.yc.*;
import com.ydtech.modules.ins.model.yc.accident.response.ResponseYwCvrg;
import com.ydtech.modules.ins.model.yc.audit.Audit;
import com.ydtech.modules.ins.model.yc.audit.response.AuditResponse;
import com.ydtech.modules.ins.model.yc.callbackAnOrder.CallbackAnOrder;
import com.ydtech.modules.ins.model.yc.imageUp.ImageUp;
import com.ydtech.modules.ins.model.yc.imageUp.response.ImageUpResponse;
import com.ydtech.modules.ins.model.yc.modelsQuery.ModelsQueryResponse;
import com.ydtech.modules.ins.model.yc.modelsQuery.ModelsQueryXml;
import com.ydtech.modules.ins.model.yc.accident.Accident;
import com.ydtech.modules.ins.model.yc.pay.Pay;
import com.ydtech.modules.ins.model.yc.pay.response.AccidentResponse;
import com.ydtech.modules.ins.model.yc.pay.response.PayResponse;
import com.ydtech.modules.ins.model.yc.policy.Policy;
import com.ydtech.modules.ins.model.yc.policy.response.PolicyResponse;
import com.ydtech.modules.ins.model.yc.ruote.*;
import com.ydtech.modules.ins.model.yc.ruote.response.RuoteResponse;
import com.ydtech.modules.ins.service.*;
import com.ydtech.modules.ins.vo.*;
import com.ydtech.modules.order.components.InsOrdersComponents;
import com.ydtech.modules.order.entity.InsAreaCompany;
import com.ydtech.modules.order.entity.InsOrders;
import com.ydtech.modules.order.entity.vo.*;
import com.ydtech.modules.order.service.InsAreaCompanyService;
import com.ydtech.modules.order.service.InsOrdersService;
import com.ydtech.utils.HttpXmlUtil;
import com.ydtech.utils.IDCardUtils;
import com.ydtech.utils.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.security.core.context.SecurityContextHolder;
import org.springframework.security.core.userdetails.UserDetails;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.io.IOException;
import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.time.LocalDateTime;
import java.util.*;
import java.util.concurrent.atomic.AtomicInteger;


@Service
public class InsAlltrustApiServiceImpl implements InsAlltrustApiService {


    private static final Logger log = LoggerFactory.getLogger("alltrust");

    @Autowired
    private InsAlltrustRequestApiComponents apiComponents;

    @Autowired
    private InsAlltrustRegionMapper insAlltrustRegionMapper;
    @Autowired
    private InsOrdersComponents insOrdersComponents;


    private AuthorityDataXml authorityDataXml = null;


    private ObjectMapper xmlMapper = null;


    @Autowired
    private YcBuildData ycBuildData;
    @Autowired
    private SysUserService sysUserService;
    @Autowired
    private SysDeptService sysDeptService;
    @Autowired
    private EsmRetailService esmRetailService;
    @Autowired
    private EsmAgreementService esmAgreementService;
    @Autowired
    private EsmAgreementProdService esmAgreementProdService;
    @Autowired
    private EsmUserInternalService esmUserInternalService;
    @Autowired
    private InsTaskHistoryService insTaskHistoryService;
    @Autowired
    private InsAreaCompanyService insAreaCompanyService;
    @Autowired
    private InsOrdersService insOrdersService;
    @Autowired
    private InsTaskImageService insTaskImageService;
    @Autowired
    private EsmInsAttachInsureMapper esmInsAttachInsureMapper;
    @Autowired
    private EsmInsAttachInsureDetailsMapper esmInsAttachInsureDetailsMapper;
    @Autowired
    private EsmInsCompanyService esmInsCompanyService;

    @Autowired
    InsApiLogService insApiLogService;


    /**
     * @description: 获取验证数据
     * @author: lig
     * @date: 2023年02月07日 0007
     */
    private AuthorityDataXml gainAuthorityDataXml() {
        if (null == authorityDataXml) {
            authorityDataXml = new AuthorityDataXml();
            authorityDataXml.setUserName(apiComponents.getUserName());
            authorityDataXml.setPassword(apiComponents.getPassword());
        }
        return authorityDataXml;
    }

    /**
     * 获取渠道
     */
    public Agent gainAgent() {
        return apiComponents.gainAgent();
//        if (null == agent) {
//            agent = new Agent();
//            agent.setAgentCode(agentCode);
//            agent.setConferCode(agentType);
//            agent.setAgentType(agentType);
//            agent.setAgentNme(agentNme);
//            agent.setQlftNo(qlftNo);
//            agent.setCustNature(custNature);
//            agent.setAgentProfId(agentCode);
//            agent.setSubCoNo(agentType);
//        }
//        return agent;
    }

    private ObjectMapper gainXmlMapper() {
        if (null == xmlMapper) {
            xmlMapper = new XmlMapper();
            xmlMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
            xmlMapper.configure(SerializationFeature.WRAP_ROOT_VALUE, false);
            xmlMapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);
            xmlMapper.setPropertyNamingStrategy(PropertyNamingStrategy.UPPER_CAMEL_CASE);
            xmlMapper.enable(MapperFeature.USE_STD_BEAN_NAMING);
            xmlMapper.configure(MapperFeature.ACCEPT_CASE_INSENSITIVE_PROPERTIES, true);
        }
        return xmlMapper;
    }


    //
    //==============================API 方式
    //

    /**
     * 1 车型查询接口
     */
    @Override
    public HttpResult modelsQueryApi(CarModel_Req carModelReq) {

//        if (org.springframework.util.StringUtils.isEmpty(carModelReq.getFrameNo()) || org.springframework.util.StringUtils.isEmpty(carModelReq.getEnrollDate()) || org.springframework.util.StringUtils.isEmpty(carModelReq.getModelName())) {
//            return HttpResult.error("frameNo, enrollDate, modelName 这些参数不能为空！");
//        }

        ModelsQueryXml m = buildModelsQueryParam(carModelReq);
        ObjectMapper xmlMapper = this.gainXmlMapper();

        log.info("===永诚--车型查询接口请求开始===");
        InsApiLog apiLog = httpPost(xmlMapper, m, YcBuildData.API_MODEL);
        String responseData = apiLog.getResponseData();
        log.info("===永诚--车型查询接口请求结束===");
        try {
            String cleanStr = YcBuildData.cleanResponseStr(responseData);
            ModelsQueryResponse rd = xmlMapper.readValue(cleanStr, ModelsQueryResponse.class);
            if (rd.getReturnCode().equals("E0001")) {
                return HttpResult.ok(rd.getMsg());
            }
            return HttpResult.ok(buildCarModel(rd));
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
    }


    /**
     * 2 报价
     */
    @Override
    public HttpResult quoteApi(BaseQuoteVo<AccidentalDrivingVo> quoteVo) {
//    public HttpResult quoteApi(BaseQuoteInfoVo yaQuoteInfoVo) {
        BaseQuoteInfoVo yaQuoteInfoVo = insOrdersComponents.getQuoteInfo(quoteVo.getOrderNo());
        HttpResult httpResult = new HttpResult();
        ObjectMapper xmlMapper = this.gainXmlMapper();

        InsAreaCompany iac = null;

        InsOrders order = insOrdersService.getById(yaQuoteInfoVo.getOrderNo());

        AccidentalDrivingVo adVo = quoteVo.getAccidentalDrivingVo();


        //1.1必填校验
        checkEmpty(yaQuoteInfoVo);

        //组装参数
        Ruote m = Ruote.buildQuoteParam(yaQuoteInfoVo, gainAuthorityDataXml(), apiComponents.gainAgent(), apiComponents, adVo);
        //构造地区
        buildRegion(m);

        //6 接口请求
        log.debug("=========永诚API方式 - xml请求 - 报价开始======");
        InsApiLog apiLog = httpPost(xmlMapper, m, YcBuildData.API_QUOTE);
        log.debug("=========永诚API方式 - xml请求 - 报价结束！======");
        verifyRequest(apiLog, iac, InsQuoteFlow.Q_S_0);

        String responseData = apiLog.getResponseData();

        try {
            String cleanStr = YcBuildData.cleanResponseStr(responseData);
            RuoteResponse rd = xmlMapper.readValue(cleanStr, RuoteResponse.class);

            if (!rd.getHead().getErrorCode().equals("000000")) {
                throw new SystemException(rd.getHead().getErrorMessage());
            }
            QuoteRespVo quoteRespVo = YcBuildData.buildQuoteRespVo(order, rd, yaQuoteInfoVo);
            //8 生成订单
            iac = response_order(order, quoteRespVo, m, rd,quoteVo);
//            updateApiLog(apiLog, iac);
            quoteRespVo.setCompanyId(iac.getId());


            httpResult.setData(quoteRespVo);
            httpResult.setMsg("成功");

        } catch (IOException e) {
            throw new RuntimeException(e);
        }
        return httpResult;

    }


    /**
     * 3 核保
     *
     * @param quoteOrderNo
     */
    @Override
    @Transactional
    public HttpResult auditApi(String quoteOrderNo) {

        ObjectMapper xmlMapper = this.gainXmlMapper();
        String msg = "提交成功";
        HttpResult h = HttpResult.ok(msg);
        try {
            //子订单
            InsAreaCompany iac = insAreaCompanyService.getById(quoteOrderNo);
            if (iac == null) {
                return HttpResult.error("订单不存在");
            }
            InsOrders order = insOrdersService.getById(iac.getOrderno());

//            if (InsOrderStatus.S_5.getCode().equals(iac.getOrderstatus()) || InsOrderStatus.S_4.getCode().equals(iac.getOrderstatus())) {
//                return HttpResult.ok(InsOrderStatus.matchKey(iac.getOrderstatus()).getDesc());
//            }


            //车主
            CustomerInfoVo ownerInfo = JSONObject.parseObject(order.getOwnerinfo().toJSONString(), CustomerInfoVo.class);
            //被保人
            CustomerInfoVo insureInfo = JSONObject.parseObject(order.getInsureinfo().toJSONString(), CustomerInfoVo.class);
            //投保人
            CustomerInfoVo applyInfo = JSONObject.parseObject(order.getApplyinfo().toJSONString(), CustomerInfoVo.class);


            //组装参数
            Audit m = Audit.buildAuditParam(ownerInfo, insureInfo, applyInfo, this.gainAuthorityDataXml(), iac, apiComponents);

            //处理地区
            Map<String, String> insureMap = gainRegionCode(insureInfo.getAddr());
            if (null != insureMap && insureMap.size() > 0) {
                m.getRequestLabel().getCondition().getCustomer().setCProvince(insureMap.get("provinceCode"));
                m.getRequestLabel().getCondition().getCustomer().setCCity(insureMap.get("cityCode"));
                m.getRequestLabel().getCondition().getCustomer().setCCounty(insureMap.get("areaCode"));
            } else {
                throw new SystemException("永诚 - 被保人地区获取失败，请联系管理员");
            }


            log.debug("=========永诚API方式 - xml请求 - 核保开始======");
            //接口请求
            InsApiLog apiLog = httpPost(xmlMapper, m, YcBuildData.API_AUDIT);
            log.debug("=========永诚API方式 - xml请求 - 核保结束！======");
            verifyRequest(apiLog, iac, InsQuoteFlow.Q_S_1);
            String responseData = apiLog.getResponseData();

            String cleanStr = YcBuildData.cleanResponseStr(responseData);
            AuditResponse rd = xmlMapper.readValue(cleanStr, AuditResponse.class);

            if (rd.getResponseHead().getReturnCode().equals("0000")) {
//            if (rd.getResponseHead().getReturnCode().equals("E0000")) {
                String statusJq = StringUtils.toString(rd.getStatusJq(), "");
                String statusSy = StringUtils.toString(rd.getStatusSY(), "");
                if (statusJq.equals("0") || statusSy.equals("0")) {
                    iac.setOrderstatus(InsOrderStatus.S_1.getCode());
                } else if (statusJq.equals("3") || statusSy.equals("3")) {
                    iac.setOrderstatus(InsOrderStatus.S_4.getCode());
                } else {
                    iac.setOrderstatus(InsOrderStatus.S_2.getCode());
                }
                if(StringUtils.toInt(order.getOrderstatus()) < StringUtils.toInt(iac.getOrderstatus())){
                    order.setOrderstatus(iac.getOrderstatus());
                }
            } else {
                msg = rd.getResponseHead().getReturnMessage();
                return HttpResult.error("核保失败" + msg);
            }

            iac.setAuditid(order.getUserid());

            iac.setInsOrderNo(rd.getOrderCode());
            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

            iac.setAudittime(LocalDateTime.now());

            iac.setJqapplyno(StringUtils.toString(rd.getPolicyAppNoJQ(), ""));
            iac.setSyapplyno(StringUtils.toString(rd.getPolicyAppNoSY(), ""));
            iac.setJqappoint(""); //交强特别约定
            iac.setSyappoint(""); //商业特别约定

            if (InsOrderStatus.S_2.getCode().equals(InsOrderStatus.matchKey(iac.getOrderstatus()).getCode())) {
                //获取缴费地址
                getPayUrlApi(iac);
            }else {
                h = HttpResult.error(msg + "状态：" + InsOrderStatus.matchKey(iac.getOrderstatus()).getDesc());
            }
            insAreaCompanyService.updateById(iac);
            insOrdersService.updateByOrderStatus(order.getOrderno(),order.getOrderstatus());

//            if (InsOrderStatus.S_2.getCode().equals(InsOrderStatus.matchKey(iac.getOrderstatus()).getCode())) {
//                return HttpResult.ok(msg);
//            } else {
//                return HttpResult.error(msg + "状态：" + InsOrderStatus.matchKey(iac.getOrderstatus()).getDesc());
//            }

//            //插入轨迹表
//            insTaskHistoryService.insertByOrderStatus(order);

        } catch (SystemException e) {
            return HttpResult.error(e.getMessage());
        } catch (Exception e) {
//            e.printStackTrace();
            log.error("===永诚API方式--核保报错(订单号-{})：{}", quoteOrderNo, e.getMessage());
            return HttpResult.error("系统错误，请联系管理员");
        }
        return h;
    }


    /**
     * 4 影像上传
     */
    @Override
    public HttpResult UploadImageApi(String quoteOrderNo) {

        HttpResult resutl = HttpResult.ok();
        InsAreaCompany iac = insAreaCompanyService.getByIdIsExist(quoteOrderNo);
        InsOrders order = insOrdersService.getById(iac.getOrderno());
        List<InsTaskImage> insTaskImages = insTaskImageService.selectByTaskId(order.getQuoteno());

//        InsAreaCompany iac = insAreaCompanyService.getById(quoteOrderNo);
//        InsOrders order = insOrdersService.getById(iac.getOrderno());

        insTaskImages.stream().forEach(a -> {
            InsApiLog apiLog = null;
            //组装参数
            log.debug("=========永诚API方式 - xml请求 - 影像上传开始======");
            //接口请求
            ImageUp iUp = ImageUp.buildImageUpParam(order, gainAuthorityDataXml(), a.getImage(), a.getImgtype(), apiComponents);
            log.debug("=========永诚API方式 - xml请求 - 影像上传结束！======");
            ObjectMapper xmlMapper = gainXmlMapper();
            //接口请求
            apiLog = httpPost(xmlMapper, iUp, YcBuildData.API_UPLOAD);
            verifyRequest(apiLog, iac, InsQuoteFlow.Q_S_2);
            try {
                String responseData = apiLog.getResponseData();
                String cleanStr = YcBuildData.cleanResponseStr(responseData);
                log.error("===永诚API方式--上传影像清洗返回参数：" + cleanStr);
                ImageUpResponse iur = xmlMapper.readValue(cleanStr, ImageUpResponse.class);
            } catch (IOException e) {
                e.printStackTrace();
                log.error("===永诚API方式--上传影像报错：" + e.getMessage());
                throw new SystemException("系统错误，请联系管理员");
            }

        });


        return HttpResult.ok();
    }


    /**
     * 5 支付
     */
    @Override
    public InsAreaCompany getPayUrlApi(InsAreaCompany iac) {

        try {
            //组装参数
            Pay pay = Pay.buildPayParam(iac, gainAuthorityDataXml(), apiComponents.getPayCallBack());

            ObjectMapper xmlMapper = gainXmlMapper();
            //接口请求
            log.debug("=========永诚API方式 - xml请求 - 获取缴费链接开始======");
            InsApiLog apiLog = httpPost(xmlMapper, pay, YcBuildData.API_PAY);
            log.debug("=========永诚API方式 - xml请求 - 获取缴费链接结束！======");
            verifyRequest(apiLog, iac, InsQuoteFlow.Q_S_3);
            String responseData = apiLog.getResponseData();


            String cleanStr = YcBuildData.cleanResponseStr(responseData);
            PayResponse payResp = xmlMapper.readValue(cleanStr, PayResponse.class);

            if (payResp.getReturnCode().equals("E0000")) {
                iac.setPaymentLink(payResp.getPayTransUrl());
//                insAreaCompanyService.updateById(iac);
            } else {
                log.error("永诚API方式 - 获取支付连接失败：" + payResp.getReturnMessage());
            }

        } catch (Exception e) {
            e.printStackTrace();
            throw new SystemException("获取支付连接失败");
        }
        return iac;
    }
//    /**
//     * 5 支付
//     */
//    @Override
//    public HttpResult getPayUrlApi(String quoteOrderNo) {
//        HttpResult httpResult = new HttpResult();
//
//        try {
//            InsAreaCompany iac = insAreaCompanyService.getById(quoteOrderNo);
//            InsOrders order = insOrdersService.getById(iac.getOrderno());
////            InsOrders order = insOrderService.selectByPk(orderno);
//            if (iac == null) {
//                return HttpResult.error("报价订单不存在");
//            }
//            //组装参数
//            Pay pay = Pay.buildPayParam(iac, gainAuthorityDataXml(), apiComponents.getPayCallBack());
//
//            ObjectMapper xmlMapper = gainXmlMapper();
//            //接口请求
//            log.debug("=========永诚API方式 - xml请求 - 获取缴费链接开始======");
//            InsApiLog apiLog = httpPost(xmlMapper, pay, YcBuildData.API_PAY);
//            log.debug("=========永诚API方式 - xml请求 - 获取缴费链接结束！======");
//            verifyRequest(apiLog, iac, InsQuoteFlow.Q_S_3);
//            String responseData = apiLog.getResponseData();
//
//
//            String cleanStr = YcBuildData.cleanResponseStr(responseData);
//            PayResponse payResp = xmlMapper.readValue(cleanStr, PayResponse.class);
//
//            if (payResp.getReturnCode().equals("E0000")) {
//                iac.setPaymentLink(payResp.getPayTransUrl());
//                insAreaCompanyService.updateById(iac);
//                httpResult.setMsg(payResp.getPayTransUrl());
//            } else {
//                httpResult.setMsg(payResp.getReturnMessage());
//            }
//
//        } catch (SystemException e) {
//            return HttpResult.error(e.getMessage());
//        } catch (Exception e) {
//            e.printStackTrace();
//            return HttpResult.error("系统错误，请联系管理员");
//        }
//        return httpResult;
//    }

    /**
     * 补传回调
     */
    @Override
    public HttpResult callbackAnOrder(String quoteOrderNo) {
        HttpResult httpResult = new HttpResult();

        try {
            InsAreaCompany iac = insAreaCompanyService.getById(quoteOrderNo);
            InsOrders order = insOrdersService.getById(iac.getOrderno());
            if (iac == null) {
                return HttpResult.error("报价订单不存在");
            }
            //0 支付回调 1核保回调 5直接返回字符串信息
            String type = "0";
            if(iac.getOrderstatus().equals(InsOrderStatus.S_1.getCode())) type = "1";
            //组装参数
            CallbackAnOrder o = CallbackAnOrder.buildCallbackAnOrderParam(iac, gainAuthorityDataXml(), type);

            ObjectMapper xmlMapper = gainXmlMapper();
            //接口请求
            log.debug("=========永诚API方式 - xml请求 - 补传回调开始======");
            InsApiLog apiLog = httpPost(xmlMapper, o, YcBuildData.API_ORDER_QUERY);
            log.debug("=========永诚API方式 - xml请求 - 补传回调结束！======");
            verifyRequest(apiLog, iac, InsQuoteFlow.Q_S_5);
            String responseData = apiLog.getResponseData();


            String cleanStr = YcBuildData.cleanResponseStr(responseData);
//            CallbackAnOrderResponse callbackAnOrderResponse = xmlMapper.readValue(cleanStr, CallbackAnOrderResponse.class);

            if (cleanStr.equals("0000")) {
                httpResult.setMsg("操作成功");
            } else {
                httpResult.setMsg(cleanStr);
//                httpResult.setMsg(callbackAnOrderResponse.getMessage());
            }

        } catch (SystemException e) {
            return HttpResult.error(e.getMessage());
        } catch (Exception e) {
            e.printStackTrace();
            return HttpResult.error("系统错误，请联系管理员");
        }
        return httpResult;
    }

    /**
     * 6 电子保单
     */
    @Override
    public HttpResult getPolicyPrintApi(PolicyPrintVo policyPrintVo) {
        HttpResult httpResult = new HttpResult();
        try {
            InsAreaCompany iac = insAreaCompanyService.getById(policyPrintVo.getCompanyId());
//            InsOrder order = insOrderService.selectByPk(orderno);
            if (iac == null) {
                return HttpResult.error("报价订单不存在");
            }
            String policyNo = policyPrintVo.getRiskCode().equals("0507") ? iac.getJqpolicyno() : iac.getSypolicyno();


            //组装参数
            Policy p = Policy.buildPolicyParam(policyNo, gainAuthorityDataXml());

            ObjectMapper xmlMapper = gainXmlMapper();
            //接口请求
            log.debug("=========永诚API方式 - xml请求 - 获取保单开始======");
            InsApiLog apiLog = httpPost(xmlMapper, p, YcBuildData.API_GUARANTEE_SLIP);
            log.debug("=========永诚API方式 - xml请求 - 获取保单结束！======");
            verifyRequest(apiLog, iac, InsQuoteFlow.Q_S_4);
            String responseData = apiLog.getResponseData();

            String cleanStr = YcBuildData.cleanResponseStr(responseData);
            PolicyResponse pResp = xmlMapper.readValue(cleanStr, PolicyResponse.class);

            if (pResp.getHead().getResponseCompleteMessageStatus().getMessageStatusCode().equals("E0000")) {
                Map m = new HashMap();
                if(policyPrintVo.getType().equals("1")){
                    m.put("jqFlagUrl", pResp.getPolicyBZUrl());
                    m.put("jqUrl", "");
                    m.put("syUrl", "");
                }
                if(policyPrintVo.getType().equals("2")){
                    m.put("jqFlagUrl", pResp.getPolicyBZUrl());
                    m.put("jqUrl", pResp.getJqpolicyUrl());
                    m.put("syUrl", pResp.getSypolicyUrl());

                }
//                httpResult.setData(m);
//                httpResult.setMsg(pResp.getHead().getResponseCompleteMessageStatus().getMessageStatusDescription());
                return HttpResult.ok(pResp.getHead().getResponseCompleteMessageStatus().getMessageStatusDescription(),m);

            } else {
                return HttpResult.error(pResp.getHead().getResponseCompleteMessageStatus().getMessageStatusDescription());
            }

        } catch (Exception e) {
            e.printStackTrace();
            return HttpResult.error("系统错误，请联系管理员");
        }
    }


    /**
     * 驾意外险
     */
    @Override
    public HttpResult gainAccidentList(AccidentalDrivingQueryVo accidentalDrivingVo) {
        HttpResult httpResult = new HttpResult();

        try {
//            InsAreaCompany iac = insAreaCompanyService.getById(quoteOrderNo);
//            InsOrders order = insOrdersService.getById(iac.getOrderno());
//            if (iac == null) {
//                return HttpResult.error("报价订单不存在");
//            }
            //组装参数
            Accident accident = Accident.buildPayParam(accidentalDrivingVo, gainAuthorityDataXml(), apiComponents, null);

            ObjectMapper xmlMapper = gainXmlMapper();
            //接口请求
            log.debug("=========永诚API方式 - xml请求 - 获取意健险方案及险种查询开始======");
            InsApiLog apiLog = httpPost(xmlMapper, accident, YcBuildData.API_ACCIDENT);
            log.debug("=========永诚API方式 - xml请求 - 获取意健险方案及险种查询结束！======");
//            verifyRequest(apiLog, iac,InsQuoteFlow.);
            String responseData = apiLog.getResponseData();


            String cleanStr = YcBuildData.cleanResponseStr(responseData);
            AccidentResponse accidentResp = xmlMapper.readValue(cleanStr, AccidentResponse.class);


            if (accidentResp.getHead().getResponseCompleteMessageStatus().getMessageStatusCode().equals("E0000")) {
                //清空旧的存入表
                LambdaQueryWrapper<EsmInsAttachInsure> lqw = new LambdaQueryWrapper<EsmInsAttachInsure>();
                lqw.eq(EsmInsAttachInsure::getCompanyId, accidentalDrivingVo.getCompanyCode());
                lqw.eq(EsmInsAttachInsure::getSeating, accidentalDrivingVo.getSeatNum());
                esmInsAttachInsureMapper.delete(lqw);

                List<ResponseYwCvrg.CvrgList> cList = accidentResp.getResponseYwCvrg().getCvrgList();

                List<EsmInsAttachInsure> eiaiList = new ArrayList<>();
                cList.stream().forEach(a -> {
                    EsmInsAttachInsure ati = new EsmInsAttachInsure();
                    ati.setCode(a.getCInsuranceTypeCode());
                    ati.setName(a.getCInsuranceType());
                    ati.setSeating(accidentalDrivingVo.getSeatNum() + "");
                    ati.setCompanyId(accidentalDrivingVo.getCompanyCode());
                    ati.setType(AttachInsureEnum.AI001.getCode());
                    ati.setEnable(WhetherEnum.YES.getCode());
                    ati.setRestrictNum(StringUtils.toInt(a.getNPurchaseLimitsNum()));

                    esmInsAttachInsureMapper.insert(ati);
                    eiaiList.add(ati);
                });


                httpResult.setData(eiaiList);
//                httpResult.setData(accidentResp.getResponseYwCvrg().getCvrgList());
                httpResult.setMsg(accidentResp.getHead().getResponseCompleteMessageStatus().getMessageStatusDescription());
            } else {
                httpResult.setMsg(accidentResp.getHead().getResponseCompleteMessageStatus().getMessageStatusDescription());
            }

        } catch (SystemException e) {
            return HttpResult.error(e.getMessage());
        } catch (Exception e) {
            e.printStackTrace();
            return HttpResult.error("系统错误，请联系管理员");
        }
        return httpResult;
    }


    /**
     * 驾意外险  同步
     */
    @Override
    public HttpResult syncAccidentInsure(AccidentalDrivingQueryVo accidentalDrivingVo) {


        AccidentResponse ar = gainAccidentInsure(accidentalDrivingVo, null);
//        List<EsmInsAttachInsure> eiaiList = new ArrayList<>();

        if (ar.getHead().getResponseCompleteMessageStatus().getMessageStatusCode().equals("E0000")) {
            //清空旧的存入表
            LambdaQueryWrapper<EsmInsAttachInsure> lqw = new LambdaQueryWrapper<EsmInsAttachInsure>();
            lqw.eq(EsmInsAttachInsure::getCompanyId, accidentalDrivingVo.getCompanyCode());
            lqw.eq(EsmInsAttachInsure::getSeating, accidentalDrivingVo.getSeatNum());
            lqw.select(EsmInsAttachInsure::getId);
            List<EsmInsAttachInsure> eiaiList = esmInsAttachInsureMapper.selectList(lqw);

            //删除已经存在的数据
            if (null != eiaiList && eiaiList.size() > 0) {

                List<String> ids = new ArrayList<>();
                eiaiList.stream().forEach(i -> {
                    ids.add(i.getId());
                });
                LambdaQueryWrapper<EsmInsAttachInsureDetails> lqwDetails = new LambdaQueryWrapper<>();
                lqwDetails.in(EsmInsAttachInsureDetails::getAttachInsureId, ids);
                //详情删除
                esmInsAttachInsureDetailsMapper.delete(lqwDetails);

                //            esmInsAttachInsureMapper.delete(lqw);
                esmInsAttachInsureMapper.deleteBatchIds(ids);
            }

            List<ResponseYwCvrg.CvrgList> cList = ar.getResponseYwCvrg().getCvrgList();


            cList.stream().forEach(a -> {
                EsmInsAttachInsure ati = new EsmInsAttachInsure();
                ati.setCode(a.getCInsuranceTypeCode());
                ati.setName(a.getCInsuranceType());
                ati.setSeating(accidentalDrivingVo.getSeatNum() + "");
                ati.setCompanyId(accidentalDrivingVo.getCompanyCode());
                ati.setType(AttachInsureEnum.AI001.getCode());
                ati.setEnable(WhetherEnum.YES.getCode());
                ati.setRestrictNum(StringUtils.toInt(a.getNPurchaseLimitsNum()));

                esmInsAttachInsureMapper.insert(ati);


                //具体方案信息
                AccidentResponse arCode = gainAccidentInsure(accidentalDrivingVo, a.getCInsuranceTypeCode());
                if (arCode.getHead().getResponseCompleteMessageStatus().getMessageStatusCode().equals("E0000")) {

                    AtomicInteger total = new AtomicInteger(0);
                    List<ResponseYwCvrg.CvrgList> cListDetails = arCode.getResponseYwCvrg().getCvrgList();
                    cListDetails.stream().forEach(d -> {

                        EsmInsAttachInsureDetails atiDetails = new EsmInsAttachInsureDetails();
                        atiDetails.setAttachInsureId(ati.getId());
                        atiDetails.setName(d.getCInsuranceLiability());
                        atiDetails.setCarSum(d.getNInsuranceAmountCar());
                        atiDetails.setSeatSum(d.getNInsuranceAmountSeat());
                        atiDetails.setPremium(d.getNLiabilityPremium());
                        total.addAndGet(StringUtils.toInt(d.getNLiabilityPremium()));
                        esmInsAttachInsureDetailsMapper.insert(atiDetails);
                    });

                    ati.setPremium(total.get() + "");
                    esmInsAttachInsureMapper.updateById(ati);

                }


//                eiaiList.add(ati);
            });
        }


        return HttpResult.ok("同步成功");
    }


    /**
     * 驾意外险
     */
    @Override
    public AccidentResponse gainAccidentInsure(AccidentalDrivingQueryVo accidentalDrivingVo, String schemeNo) {
        HttpResult httpResult = new HttpResult();

        //组装参数
        Accident accident = Accident.buildPayParam(accidentalDrivingVo, gainAuthorityDataXml(), apiComponents, schemeNo);

        ObjectMapper xmlMapper = gainXmlMapper();
        //接口请求
        log.debug("=========永诚API方式 - xml请求 - 获取意健险方案及险种查询开始======");
        InsApiLog apiLog = httpPost(xmlMapper, accident, YcBuildData.API_ACCIDENT);
        log.debug("=========永诚API方式 - xml请求 - 获取意健险方案及险种查询结束！======");
//            verifyRequest(apiLog, iac,InsQuoteFlow.);
        String responseData = apiLog.getResponseData();


        String cleanStr = YcBuildData.cleanResponseStr(responseData);
        AccidentResponse accidentResp = null;
        try {
            accidentResp = xmlMapper.readValue(cleanStr, AccidentResponse.class);
        } catch (JsonProcessingException e) {
            log.error("转换错误 方法：gainAccidentInsure  类：AccidentResponse");
            throw new RuntimeException(e);
        }
        return accidentResp;


//            if (accidentResp.getHead().getResponseCompleteMessageStatus().getMessageStatusCode().equals("E0000")) {
//                //清空旧的存入表
//                LambdaQueryWrapper<EsmInsAttachInsure> lqw = new LambdaQueryWrapper<EsmInsAttachInsure>();
//                lqw.eq(EsmInsAttachInsure::getCompanyId,accidentalDrivingVo.getCompanyCode());
//                lqw.eq(EsmInsAttachInsure::getSeating,accidentalDrivingVo.getSeatNum());
//                esmInsAttachInsureMapper.delete(lqw);
//
//                List<ResponseYwCvrg.CvrgList> cList = accidentResp.getResponseYwCvrg().getCvrgList();
//
//                List<EsmInsAttachInsure> eiaiList = new ArrayList<>();
//                cList.stream().forEach(a ->{
//                    EsmInsAttachInsure ati = new EsmInsAttachInsure();
//                    ati.setCode(a.getCInsuranceTypeCode());
//                    ati.setName(a.getCInsuranceType());
//                    ati.setSeating(accidentalDrivingVo.getSeatNum() + "");
//                    ati.setCompanyId(accidentalDrivingVo.getCompanyCode());
//                    ati.setType(AttachInsureEnum.AI001.getCode());
//                    ati.setEnable(WhetherEnum.YES.getCode());
//                    ati.setRestrictNum(StringUtils.toInt(a.getNPurchaseLimitsNum()));
//
//                    esmInsAttachInsureMapper.insert(ati);
//                    eiaiList.add(ati);
//                });
//
//
//
//
//                httpResult.setData(eiaiList);
////                httpResult.setData(accidentResp.getResponseYwCvrg().getCvrgList());
//                httpResult.setMsg(accidentResp.getHead().getResponseCompleteMessageStatus().getMessageStatusDescription());
//            } else {
//                httpResult.setMsg(accidentResp.getHead().getResponseCompleteMessageStatus().getMessageStatusDescription());
//            }

    }


    @Override
    @Transactional
    public HttpResult callBackApi(CallBackRequest param) {

//        if (StringUtils.isNotEmpty(param.getType())) return HttpResult.error("字段：type（回调类型）  参数为空");

        //成功
        if (param.getResult().equals("0")) {
            LambdaQueryWrapper<InsAreaCompany> lqw = new LambdaQueryWrapper();
            //交强投保单号查询
            lqw.eq(StringUtils.isNotEmpty(param.getCiPolicyAppNo()), InsAreaCompany::getJqapplyno, param.getCiPolicyAppNo());
            //商业投保单号查询
            lqw.eq(StringUtils.isNotEmpty(param.getBizPolicyAppNo()), InsAreaCompany::getSyapplyno, param.getBizPolicyAppNo());
            InsAreaCompany iac = insAreaCompanyService.getOne(lqw);


            if (null != iac) {
                if (StringUtils.isNotEmpty(param.getBizPolicyNo())) iac.setSypolicyno(param.getBizPolicyNo());
                if (StringUtils.isNotEmpty(param.getCiPolicyNo())) iac.setJqpolicyno(param.getCiPolicyNo());

                iac = buildCallBack(iac,param);

                InsOrders order = insOrdersService.getById(iac.getOrderno());
                if(StringUtils.toInt(order.getOrderstatus()) < StringUtils.toInt(iac.getOrderstatus())){
                    order.setOrderstatus(iac.getOrderstatus());
                }

                insAreaCompanyService.updateById(iac);
                insOrdersService.updateByOrderStatus(order.getOrderno(),order.getOrderstatus());



                //支付后 手工确认意外险
            } else {
                log.info(String.format("永诚API方式 - 回调 - 信息，订单不存在，交强保单号：{} ，商业保单号：{}", param.getCiPolicyNo(), param.getBizPolicyNo()));
            }

        } else {
            //失败原因
            param.getMessage();
            log.info(String.format("永诚API方式 - 回调 - 失败，交强保单号：{} ，商业保单号：{}，类型：{}", param.getCiPolicyNo(), param.getBizPolicyNo(), param.getType()));
        }
        return HttpResult.ok(param);
    }


    /**
     * @description:构造车型查询参数
     * @author: lig
     * @date: 2023年02月08日 0008
     */
    private ModelsQueryXml buildModelsQueryParam(CarModel_Req carModelReq) {

        ModelsQueryXml m = new ModelsQueryXml();
        ModelsQueryXml.RequestLabel requestLabel = new ModelsQueryXml.RequestLabel();
        requestLabel.setSearchKeyword(carModelReq.getFrameNo().substring(0, 8));
        requestLabel.setVid(carModelReq.getFrameNo());
        requestLabel.setEngineNo(carModelReq.getEngineNo());
        requestLabel.setDptCde("1425");
        requestLabel.setProno("");
        requestLabel.setMotorTypeCode("11");
        requestLabel.setCFstRegYm(carModelReq.getEnrollDate());
        requestLabel.setAuthorityData(this.gainAuthorityDataXml());


        m.setRequestLabel(requestLabel);


        return m;
    }


    /**
     * @description: 构造返回内容，参考永安
     * @author: lig
     * @date: 2023年02月07日 0007
     */
    private List<CarModelDTO> buildCarModel(ModelsQueryResponse modelsQueryResponse) {

        List<ModelsQueryResponse.VehicleInfo> vList = modelsQueryResponse.getVehicleInfoList();
        List<CarModelDTO> carModelList = new ArrayList<>();

        vList.stream().forEach(a -> {
            CarModelDTO dto = new CarModelDTO();
            BeanUtils.copyProperties(a, dto);
            carModelList.add(dto);
        });
        return carModelList;
    }


    private <T> InsApiLog httpPost(ObjectMapper mapper, T requestData, String apiName) {

        String xmlString = "<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:tns=\"http://newWS.front.app.echannel.ebiz.alltrust.com/\">";
        xmlString += "<soapenv:Body>";
        try {
            mapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);
            xmlString += mapper.writeValueAsString(requestData);

            xmlString += "</soapenv:Body>\n" +
                    "</soapenv:Envelope>";

        } catch (JsonProcessingException e) {
            throw new RuntimeException("永诚API方式-xml转换失败");
        }
        InsApiLog iplog = HttpXmlUtil.sendXmlPost(apiComponents.getUrl() + apiName, xmlString);
        log.info("永诚API方式 - xml请求 - 参数：" + iplog.getRequestData());
        log.info("永诚API方式 - xml请求 ------------分割线----------------");
        log.info("永诚API方式 - xml请求 - 响应：" + iplog.getResponseData());
        return iplog;
    }


    /**
     * @description: 拷贝永安方法，可以封装
     * @author: lig
     * @date: 2023年02月08日 0008
     */
    private void checkEmpty(YaQuoteInfoVo yaQuoteInfoVo) {

        if (yaQuoteInfoVo.getCarInfo() == null) {
            throw new SystemException("carInfo不能为空！");
        }
        if (yaQuoteInfoVo.getPolicyHolderInfo() == null || yaQuoteInfoVo.getInsuredPersonInfo() == null) {
            throw new SystemException("policyHolderInfo/insuredPersonInfo 不能为空！");
        }
        if (yaQuoteInfoVo.getRiskList() == null || yaQuoteInfoVo.getRiskList().size() == 0) {
            throw new SystemException("riskList 不能为空！");
        } else {
            for (RiskInfoVo riskInfoVo : yaQuoteInfoVo.getRiskList()) {
                if (riskInfoVo.getStartDate() == null || riskInfoVo.getEndDate() == null) {
                    throw new SystemException("riskList.startDate / riskList.endDate不能为空！");
                }
            }
        }

    }


//    /**
//     * 生成订单  拷贝永安
//     *
//     * @author: lig
//     * @date: 2023年02月16日 0016
//     */
//    protected InsOrders gene_order(YaQuoteInfoVo record) {
//        InsOrders insOrder = new InsOrders();
//        String orderno = IdGenerate.nextId();
//        insOrder.setOrderno(orderno);
//        insOrder.setQuoteno(String.valueOf(record.getQuoteno()));
//        insOrder.setOrderstatus("0");  //0报价 1待核保 2已核保待缴费 3核保退回 4核保不通过
//        insOrder.setFrameno(record.getCarInfo().getFrameNo());
//        insOrder.setLicenseno(record.getCarInfo().getLicenseNo());
//
//        insOrder.setCarinfo(JSONObject.parseObject(JSONObject.toJSONString(record.getCarInfo())));
//        SysUser user = sysUserService.selectByPk(record.getUserId());
//        if (user == null) {
//            throw new SystemException("userId不存在");
//        }
//        if (org.springframework.util.StringUtils.isEmpty(record.getCarInfo().getFrameNo())) {
//            throw new SystemException("车架号不能为空");
//        }
//        // 关闭订单 不含当前报价号
//        InsOrders orderObj = insOrderService.queryQuoteno(new Object[]{record.getUserId(), record.getCarInfo().getFrameNo(), record.getQuoteno()});
//        if (orderObj != null) {
//            List<InsOrder> listo = insOrderService.selectList(" where quoteno=?", new Object[]{orderObj.getQuoteno()});
//            String status = "0";
//            for (InsOrder order : listo) {
//                if (!"0".equals(order.getOrderstatus())) {
//                    status = order.getOrderstatus();
//                }
//            }
//            //0报价中 1待核保 2已核保 3核保退回 4核保不通过 5已核保待缴费 6已缴费 7已承保 99已关闭
//            if ("0".equals(status)) {//关闭订单
//                insOrderService.closeOrder(orderObj.getOrderno(), "99");
//            } else if (!"99".equals(status)) {
//                throw new SystemException("此车辆已提交核保，重新报价请先关闭订单，任务号:" + orderObj.getQuoteno());
//            }
//        }
//        insOrder.setUserid(user.getId());
//        insOrder.setUsername(user.getName());
//        insOrder.setDeptid(user.getDeptId());
//        SysDept dept = sysDeptService.selectByPk(user.getDeptId());
//        insOrder.setDeptname(dept == null ? "" : dept.getName());
//
//        double retailRate = countRetail(user.getDeptId(), user.getId());
//
//        insOrder.setOwnerinfo(JSONObject.parseObject(JSONObject.toJSONString(record.getOwnerInfo())));
//        insOrder.setApplyinfo(JSONObject.parseObject(JSONObject.toJSONString(record.getPolicyHolderInfo())));
//        insOrder.setInsureinfo(JSONObject.parseObject(JSONObject.toJSONString(record.getInsuredPersonInfo())));
//
//        insOrder.setInsuredname(record.getPolicyHolderInfo().getName());
//
//
//        List<RiskInfoVo> risks = record.getRiskList();
//        for (RiskInfoVo risk : risks) {
//            if ("0507".equals(risk.getRiskCode())) {//交强
//                insOrder.setJqstartdate(risk.getStartDate());
//                insOrder.setJqenddate(risk.getEndDate());
//            }
//            if ("0510".equals(risk.getRiskCode())) {//商业
//                insOrder.setSystartdate(risk.getStartDate());
//                insOrder.setSyenddate(risk.getEndDate());
//            }
//        }
//
//        List<KindInfoVo> kinds = record.getKindList();
//        String productId = "";
//        String productname = "";
//
//        List<EsmAgreement> agreements = esmAgreementService.selectList(" where t.agreestatus='1' and t.insure1 like ? " + "and exists (select 1 from esm_agreement_prod t2 where t.id=t2.agreeid and t2.authcomcode like ?)", new Object[]{"000006140400%", "%" + user.getDeptId() + "%"});
//        if (agreements.size() == 0) {
//            throw new SystemException("不存在有效协议或机构" + user.getDeptId() + "未授权");
//        }
//        String agreeid = agreements.get(0).getId();
//        insOrder.setAgreeid(agreeid);
//        //匹配协议，获取费用
//        StringBuffer whereStr = new StringBuffer();
//        List params = new ArrayList();// where t.agreeid=? and t.productid in ()
//        whereStr.append("where t.agreeid=? ");
//        params.add(agreeid);
//        if (risks.size() == 1 && "0507".equals(risks.get(0).getRiskCode())) {
//            productId = "ZG01001";
//            productname = "单交强";
//            whereStr.append(" and t.productid=?");
//            params.add(productId);
//        } else if (risks.size() == 1 && kinds.size() == 1 && "B".equals(kinds.get(0).getKindCode())) {
//            productId = "ZG01002";
//            productname = "单三者";
//            whereStr.append(" and t.productid=?");
//            params.add(productId);
//        } else if (risks.size() == 1) {
//            productId = "ZG01003";
//            productname = "单商业";
//            whereStr.append(" and t.productid=?");
//            params.add(productId);
//        } else if (risks.size() == 2 && kinds.size() == 1 && "B".equals(kinds.get(0).getKindCode())) {
//            productId = "ZG01004";
//            productname = "交强+三者";
//            whereStr.append(" and t.productid in (?,?)");
//            params.add("ZG01004");
//            params.add("ZG01005");
//        } else {
//            productId = "ZG01006";
//            productname = "交强+商业";
//            whereStr.append(" and t.productid in (?,?)");
//            params.add("ZG01006");
//            params.add("ZG01007");
//        }
//
//        insOrder.setProductid(productId);
//        insOrder.setProduct(productname);
//        List<EsmAgreementProd> agreementProds = esmAgreementProdService.selectList(whereStr.toString(), params.toArray());
//        for (EsmAgreementProd prod : agreementProds) {
//            if ("ZG01001".equals(prod.getProductid()) || "ZG01004".equals(prod.getProductid()) || "ZG01006".equals(prod.getProductid())) {
//
//                insOrder.setFeerate(prod.getProductrate()); //交强手续费比例
//                insOrder.setJqdiscountrate(prod.getFeerate() - retailRate); //交强优惠比例=业务员绩效-分销费用
//            } else {
//                insOrder.setDisrate(prod.getProductrate()); //商业手续费比例
//                insOrder.setSydiscountrate(prod.getFeerate() - retailRate); //商业优惠比例=业务员绩效-分销费用
//
//            }
//            insOrder.setProductid(prod.getId());
//        }
//
//        insOrder.setRiskinfo(JSONObject.parseArray(JSONObject.toJSONString(record.getRiskList())));
//        insOrder.setKindinfo(JSONObject.parseArray(JSONObject.toJSONString(record.getKindList())));
//        SimpleDateFormat sdfm = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
//
//        insOrder.setInscompany("永安财险");
//        insOrder.setCreatetime(sdfm.format(new Date()));
//
//        return insOrder;
//
//    }


    /**
     * 分销费用统计   拷贝永安
     *
     * @param deptid
     * @param userid
     * @return
     */
    public double countRetail(String deptid, String userid) {
        double retailRate = 0;

        //1、根据机构匹配分销规则，获取分销比例
        List<EsmRetail> list = esmRetailService.selectList(" where deptid = ? and status=?", new Object[]{deptid, "1"});
        //2、根据userid查询三级推荐人
        List<SysUser> users = esmUserInternalService.getSuperior(userid);

        if (list != null && list.size() > 0 && users.size() > 0 && !"0".equals(list.get(0).getRetailtype())) {
            EsmRetail retail = list.get(0);
            List<Double> rateList = new ArrayList<Double>();
            rateList.add(retail.getDisrate1());
            rateList.add(retail.getDisrate2());
            rateList.add(retail.getDisrate3());

            if ("1".equals(retail.getRetailtype())) {//一级分销
                retailRate += rateList.get(0);
            } else if ("2".equals(retail.getRetailtype())) {//二级分销
                int num = users.size() > 2 ? 2 : users.size();
                for (int i = 0; i < num; i++) {
                    retailRate += rateList.get(i);
                }

            } else {//三级分销
                int num = users.size() > 2 ? 3 : users.size();
                for (int i = 0; i < num; i++) {
                    retailRate += rateList.get(i);
                }

            }

        }

        return retailRate;
    }


    /**
     * 新订单 - 子订单
     *
     * @author: lig
     * @date: 2023年02月16日 0016
     */
    private InsAreaCompany response_order(InsOrders insOrder, QuoteRespVo quoteRespVo, Ruote requestData, RuoteResponse responseData,BaseQuoteVo<AccidentalDrivingVo> quoteVo) {


        //交强保费 含税
        double jqPremium = StringUtils.toDouble(responseData.getBase().getNBefTaxPrmJQ()) + StringUtils.toDouble(responseData.getBase().getNAppTaxAmtJQ());
        //商业保费 含税
        double syPremium = StringUtils.toDouble(responseData.getBase().getNBefTaxPrmSY()) + StringUtils.toDouble(responseData.getBase().getNAppTaxAmtSY());
        //保险公司订单号
        String insOrderNo = responseData.getBase().getCresvTxt6();

        //查询码交强
        String queryCodeJq = responseData.getVhl().getCQryCdeJQ();
        //查询码商业
        String queryCodeSy = responseData.getVhl().getCQryCdeSY();

        EsmInsCompany eic = esmInsCompanyService.getById(quoteVo.getCompanyId());


        boolean jq_falg = jqPremium > 0 ? true : false;
        //保存订单信息
        InsAreaCompany insAreaCompany = new InsAreaCompany();
        insAreaCompany.setOrderno(insOrder.getOrderno());
        insAreaCompany.setReptxt(JSONObject.parseObject(JSONObject.toJSONString(responseData)));
        insAreaCompany.setJqpremium(BigDecimal.valueOf(jq_falg ? jqPremium : 0));
        insAreaCompany.setSypremium(BigDecimal.valueOf(syPremium));
        insAreaCompany.setTaxamount(BigDecimal.valueOf(jq_falg ? quoteRespVo.getTaxAmount() : 0));
        insAreaCompany.setSumpremium(BigDecimal.valueOf(quoteRespVo.getSumPermium()));
//        insAreaCompany.setSumpremium(BigDecimal.valueOf(add(quoteRespVo.getSumPermium(), insOrder.getTaxamount())));
        insAreaCompany.setOrderstatus(InsTaskHistoryEnum.WAITING_NUCLEAR_INSURANCE.getState() + "");
        insAreaCompany.setRiskinfo(JSONObject.parseArray(JSONObject.toJSONString(quoteRespVo.getRiskList())));
        insAreaCompany.setKindinfo(JSONObject.parseArray(JSONObject.toJSONString(quoteRespVo.getKindList())));
        insAreaCompany.setCreatetime(LocalDateTime.now());
        insAreaCompany.setInsOrderNo(insOrderNo);
        insAreaCompany.setJqapplyno(queryCodeJq);
        insAreaCompany.setSyapplyno(queryCodeSy);
        insAreaCompany.setCompanyId(eic.getId());
        insAreaCompany.setInscompany(eic.getNamesimple());
        insAreaCompanyService.save(insAreaCompany);
        return insAreaCompany;


//        //插入轨迹表
//        InsTaskHistory history = new InsTaskHistory();
//        history.setId(String.valueOf(new Date().getTime()));
//        history.setCompany(insOrder.getInscompany());
//        history.setTaskid(insOrder.getOrderno());
//        history.setOperatorid(insOrder.getUserid());
//        history.setOperator(insOrder.getUsername());
//        SimpleDateFormat sdfm = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
//        history.setCreatetime(sdfm.format(new Date()));
//        history.setOperator(insOrder.getUsername());
//        history.setStatus("0");
//        history.setRemark("报价中");
//        insTaskHistoryService.insert(history);

    }


    public static double add(double v1, double v2) {

        BigDecimal b1 = new BigDecimal(Double.toString(v1));

        BigDecimal b2 = new BigDecimal(Double.toString(v2));

        return b1.add(b2).doubleValue();

    }


    public static String getUserName() {
        String userName = null;
        Object principal = SecurityContextHolder.getContext().getAuthentication().getPrincipal();

        if (principal instanceof UserDetails) {
            userName = ((UserDetails) principal).getUsername();
        } else {
            userName = principal.toString();
        }
        return userName;
    }

    /**
     * 验证远程请求
     *
     * @author: lig
     * @date: 2023年02月22日 0022
     */
    private void verifyRequest(InsApiLog apiLog, InsAreaCompany insAreaCompany, InsQuoteFlow iqf) {
        //增加api日志
        insApiLogService.insertAsync(new InsApiLog(insAreaCompany, apiLog, iqf));
        if (StringUtils.isNotEmpty(apiLog.getExceptionMsg())) {
            throw new SystemException("远程接口调用异常");
//            throw new RuntimeException("远程接口调用异常");
        }

    }
//    /**
//     * 验证远程请求
//     *
//     * @author: lig
//     * @date: 2023年02月22日 0022
//     */
//    private void verifyRequest(InsApiLog apiLog, InsAreaCompany insAreaCompany) {
//        //增加api日志
//        insApiLogService.insertAsync(new InsApiLog(insAreaCompany, apiLog));
//        if (StringUtils.isNotEmpty(apiLog.getExceptionMsg())) {
//            throw new RuntimeException("远程接口调用异常");
//        }
//
//    }

    /**
     * 更新api log
     *
     * @author: lig
     * @date: 2023-03-21
     */
    private void updateApiLog(InsApiLog apiLog, InsAreaCompany iac) {
        if (null != apiLog && null != iac) {
            apiLog.setOrderNo(StringUtils.toString(iac.getId()));
//            apiLog.setOrderStatus(iac.getOrderstatus());
            insApiLogService.UpdateAsync(apiLog);
        }

    }


    @Override
    public Map<String, String> gainRegionCode(String address) {

        log.debug("*********永诚API方式 - 身份证地址解析 参数：" + address);
        Map<String, String> m = IDCardUtils.addressResolution(address);
        String city = m.get("city");
        String district = m.get("district");
//        if(StringUtils.isNullOrEmpty(district)){
//            //第二级赋值到第三级
//            district = city;
//        }

        List<InsAlltrustRegion> areaList = new ArrayList<>();
        if (StringUtils.isNotEmpty(district)) {
            //查询地区
            LambdaQueryWrapper<InsAlltrustRegion> lqw = new LambdaQueryWrapper<>();
            lqw.eq(InsAlltrustRegion::getArea, district);
            areaList = insAlltrustRegionMapper.selectList(lqw);
        }


        //如果地区查不到 用城市当地区查
        if (null == areaList || areaList.size() < 1) {
            LambdaQueryWrapper<InsAlltrustRegion> cityLqw = new LambdaQueryWrapper<>();
            cityLqw.eq(InsAlltrustRegion::getArea, city);
            areaList = insAlltrustRegionMapper.selectList(cityLqw);
        }
        if (null != areaList && areaList.size() > 0) {
            Map rMap = new HashMap();
            rMap.put("provinceCode", areaList.get(0).getProvinceCode());
            rMap.put("cityCode", areaList.get(0).getCityCode());
            rMap.put("areaCode", areaList.get(0).getAreaCode());
            return rMap;
        }
        return null;
    }


    private void buildRegion(Ruote m) {
        //车主
        Vhlowner owner = m.getRequestLabel().getCondition().getVhlowner();
        //被保人
        Insured i = m.getRequestLabel().getCondition().getInsured();
        //投保人
        Applicant a = m.getRequestLabel().getCondition().getApplicant();


        String provinceCode = "provinceCode";
        String cityCode = "cityCode";
        String areaCode = "areaCode";
//        owner.getCAreaCde()

        Map<String, String> ownerMap = gainRegionCode(owner.getCWaddress());
        if (null != ownerMap && ownerMap.size() > 0) {
            owner.setCProvince(ownerMap.get(provinceCode));
            owner.setCCity(ownerMap.get(cityCode));
            owner.setCCounty(ownerMap.get(areaCode));
            //清空格式化 自建数据
            owner.setCWaddress(null);
        } else {
            throw new SystemException("永诚 - 车主地区获取失败，请联系管理员");
        }

        Map<String, String> iMap = gainRegionCode(i.getCClntAddr());
        if (null != iMap && iMap.size() > 0) {
            i.setCProvince(iMap.get(provinceCode));
            i.setCCity(iMap.get(cityCode));
            i.setCCounty(iMap.get(areaCode));
        } else {
            throw new SystemException("永诚 - 被保人地区获取失败，请联系管理员");
        }

        Map<String, String> aMap = gainRegionCode(a.getCClntAddr());
        if (null != aMap && aMap.size() > 0) {
            a.setCProvince(aMap.get(provinceCode));
            a.setCCity(aMap.get(cityCode));
            a.setCCounty(aMap.get(areaCode));
        } else {
            throw new SystemException("永诚 - 投保人地区获取失败，请联系管理员");
        }
    }

    /**
     *  构造回调
     *  依赖 buildCallBack
     *
     * @author: lig
     * @date: 2023-05-06
     */
    private InsAreaCompany buildCallBack(InsAreaCompany iac,CallBackRequest param){
        //正常回调 与 补传回调
        if(StringUtils.isNotEmpty(param.getStatus())){
            iac = buildCallBackStatus(iac, param.getStatus());
        }else {
            if(StringUtils.isNotEmpty(param.getJqstatus())){
                iac = buildCallBackStatus(iac, param.getJqstatus());
            }
            if(StringUtils.isNotEmpty(param.getSystatus())){
                iac = buildCallBackStatus(iac, param.getSystatus());
            }

        }
        return iac;
    }

    /**
     *  构造回调状态
     *
     *
     * @author: lig
     * @date: 2023-05-06
     */
    private InsAreaCompany buildCallBackStatus(InsAreaCompany iac,String status){
        if (status.equals("9")) {
            iac.setOrderstatus(InsOrderStatus.S_2.getCode());
            //更新支付连接
            log.debug("准备进入获取支付连接######################");
            iac = getPayUrlApi(iac);
            log.debug("结束 - 准备进入获取支付连接######################");
        }
        if (status.equals("3")) {
            iac.setOrderstatus(InsOrderStatus.S_4.getCode());
        }
        if (status.equals("1")) {
            iac.setOrderstatus(InsOrderStatus.S_3.getCode());
        }
        return iac;
    }


}