java-insagent-pc/src/main/java/com/ydtech/modules/ins/service/impl/InsYongchengApiServiceImpl.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.YongchengRequestApiComponents;
import com.ydtech.constants.InsTaskHistoryEnum;
import com.ydtech.constants.enums.InsOrderStatus;
import com.ydtech.constants.enums.InsQuoteFlow;
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.model.EsmRetail;
import com.ydtech.modules.esm.model.InsTaskImage;
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.audit.Audit;
import com.ydtech.modules.ins.model.yc.audit.response.AuditResponse;
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.order.CallbackAnOrder;
import com.ydtech.modules.ins.model.yc.order.response.CallbackAnOrderResponse;
import com.ydtech.modules.ins.model.yc.pay.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.Agent;
import com.ydtech.modules.ins.model.yc.ruote.Applicant;
import com.ydtech.modules.ins.model.yc.ruote.Insured;
import com.ydtech.modules.ins.model.yc.ruote.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.entity.InsAreaCompany;
import com.ydtech.modules.order.entity.InsOrders;
import com.ydtech.modules.order.entity.vo.BaseQuoteInfoVo;
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 lombok.extern.slf4j.Slf4j;
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.*;


@Service
public class InsYongchengApiServiceImpl implements InsYongchengApiService {


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

    @Autowired
    private YongchengRequestApiComponents apiComponents;

    @Autowired
    private InsAlltrustRegionMapper insAlltrustRegionMapper;


    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
    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);
        }
        return xmlMapper;
    }


//    private final YongchengRequestComponents yongchengRequestComponents;
//
//    private final OrderComponents orderComponents;
//
//    private final StringRedisTemplate redisTemplate;
//
//    private final InsOrderService insOrderService;
//
//    private final InsTaskHistoryComponents insTaskHistoryComponents;
//
//    private final InsTaskImageService insTaskImageService;

//    public InsYongchengApiServiceImpl(YongchengRequestComponents yongchengRequestComponents, OrderComponents orderComponents, StringRedisTemplate redisTemplate, InsOrderService insOrderService, InsTaskHistoryComponents insTaskHistoryComponents, InsTaskImageService insTaskImageService) {
//        this.yongchengRequestComponents = yongchengRequestComponents;
//        this.orderComponents = orderComponents;
//        this.redisTemplate = redisTemplate;
//        this.insOrderService = insOrderService;
//        this.insTaskHistoryComponents = insTaskHistoryComponents;
//        this.insTaskImageService = insTaskImageService;
//    }

//    public double parseDouble(String s) {
//        if (StringUtils.isNullOrEmpty(s)) {
//            return 0;
//        }
//        return Double.parseDouble(s);
//    }


    //
    //==============================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);
            return HttpResult.ok(buildCarModel(rd));
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
    }


    /**
     * 2 报价
     */
    @Override
    public HttpResult quoteApi(BaseQuoteInfoVo yaQuoteInfoVo) {
        HttpResult httpResult = new HttpResult();
        ObjectMapper xmlMapper = this.gainXmlMapper();

        InsAreaCompany iac = null;

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


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

        //组装参数
        Ruote m = Ruote.buildQuoteParam(yaQuoteInfoVo, gainAuthorityDataXml(), apiComponents.gainAgent());
        //构造地区
        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);
//            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 = "提交成功";
        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());
//            }

            //组装参数
            Audit m = Audit.buildAuditParam(order, this.gainAuthorityDataXml(), iac);
            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());
                }
            } else {
                msg = rd.getResponseHead().getReturnMessage();
                return HttpResult.ok("核保失败" + 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(""); //商业特别约定

            insAreaCompanyService.updateById(iac);
            return HttpResult.ok(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 HttpResult.ok(msg);
    }


    /**
     * 4 影像上传
     */
    @Override
    public HttpResult UploadImageApi(List<InsTaskImage> taskImageList, String quoteOrderNo) {


        HttpResult resutl = HttpResult.ok();
        InsAreaCompany iac = insAreaCompanyService.getById(quoteOrderNo);
        InsOrders order = insOrdersService.getById(iac.getOrderno());

        taskImageList.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 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("报价订单不存在");
            }
            //组装参数
            CallbackAnOrder o = CallbackAnOrder.buildCallbackAnOrderParam(iac, gainAuthorityDataXml());

            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(String orderNo,String type) {
        HttpResult httpResult = new HttpResult();
        try {
            InsAreaCompany iac = insAreaCompanyService.getById(orderNo);
//            InsOrder order = insOrderService.selectByPk(orderno);
            if (iac == null) {
                return HttpResult.error("报价订单不存在");
            }
            String policyNo = type.equals("1")?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();
                m.put("url",StringUtils.isNotEmpty(pResp.getJqpolicyUrl())?pResp.getJqpolicyUrl():pResp.getSypolicyUrl());
//                m.put("syPolicyUrl", pResp.getSypolicyUrl());
//                m.put("jqPolicyUrl", pResp.getJqpolicyUrl());
//                m.put("policyBZUrl", pResp.getPolicyBZUrl());
                httpResult.setData(m);
                httpResult.setMsg(pResp.getHead().getResponseCompleteMessageStatus().getMessageStatusDescription());

            } else {
                httpResult.setMsg(pResp.getHead().getResponseCompleteMessageStatus().getMessageStatusDescription());
            }

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



    /**
     *  意外险
     */
    @Override
    public HttpResult gainAccidentList(String quoteOrderNo) {
        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(order, gainAuthorityDataXml(), apiComponents);

            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")) {
                httpResult.setData(accidentResp.getResponseYwCvrg());
                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 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.getCiPolicyNo())) iac.setJqpolicyno(param.getCiPolicyNo());
                if(StringUtils.isNotEmpty(param.getBizPolicyNo())) iac.setSypolicyno(param.getBizPolicyNo());
//                if(param.getType().equals("0")) iac.setOrderstatus(InsOrderStatus.S_3.getCode());
//                if(param.getType().equals("1")) iac.setOrderstatus(InsOrderStatus.S_7.getCode());
                iac.setOrderstatus(InsOrderStatus.S_3.getCode());
                insAreaCompanyService.updateById(iac);

                //支付后 手工确认意外险
            }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) {


        //交强保费 含税
        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();


        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.setInscompany("永诚API");
        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 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;
        }

        if(StringUtils.isNullOrEmpty(district)){
            return null;
        }

        //查询
        LambdaQueryWrapper<InsAlltrustRegion> lqw = new LambdaQueryWrapper<>();
        lqw.eq(InsAlltrustRegion::getArea,district);
        List<InsAlltrustRegion> list = insAlltrustRegionMapper.selectList(lqw);
        if(null != list && list.size() > 0){
            Map rMap = new HashMap();
            rMap.put("provinceCode",list.get(0).getProvinceCode());
            rMap.put("cityCode",list.get(0).getCityCode());
            rMap.put("areaCode",list.get(0).getAreaCode());
            return rMap;
        }
        return null;
    }


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

        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("永诚 - 地区获取失败，请联系管理员");
        }
    }


}