java-insagent-pc/src/main/java/com/ydtech/modules/ins/controller/InsCBITAPIController.java

package com.ydtech.modules.ins.controller;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.ObjectReader;
import com.ydtech.core.page.HttpResult;
import com.ydtech.modules.admin.model.SysCbitError;
import com.ydtech.modules.admin.model.SysCbitLog;
import com.ydtech.modules.admin.model.SysDept;
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.base.controller.BaseController;
import com.ydtech.modules.esm.model.EsmAgreement;
import com.ydtech.modules.esm.model.EsmAgreementProd;
import com.ydtech.modules.esm.model.EsmRetail;
import com.ydtech.modules.esm.service.EsmAgreementProdService;
import com.ydtech.modules.esm.service.EsmAgreementService;
import com.ydtech.modules.esm.service.EsmRetailService;
import com.ydtech.modules.esm.service.EsmUserInternalService;
import com.ydtech.modules.ins.model.InsOrder;
import com.ydtech.modules.ins.model.cbit.*;
import com.ydtech.modules.ins.model.vo.CarInfoVo;
import com.ydtech.modules.ins.model.vo.CarModelQryVo;
import com.ydtech.modules.ins.model.vo.CustomerInfoVo;
import com.ydtech.modules.ins.model.vo.KindInfoVo;
import com.ydtech.modules.ins.service.*;
import com.ydtech.utils.HttpsPostUtil;
import com.ydtech.utils.RSA.RSAUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.core.env.Environment;
import org.springframework.util.StringUtils;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.util.*;

/**
 * @author gws
 * @version 1.0.0
 * @description InsCBITController
 * @since 2021/11/7 9:22
 */
@RestController
@RequestMapping("/CBIT/API/insCBIT")
public class InsCBITAPIController extends BaseController {
    Logger logger = LoggerFactory.getLogger(InsCBITAPIController.class);
    @Autowired
    Environment environment;
    @Autowired
    SysCbitLogService sysCbitLogService;
    @Autowired
    SysCbitErrorService sysCbitErrorService;
    @Autowired
    InsCBITService insCBITService;
    @Autowired
    InsOrderService insOrderService;
    @Autowired
    SysUserService sysUserService;
    @Autowired
    InsTaskHistoryService insTaskHistoryService;
    @Autowired
    EsmAgreementProdService esmAgreementProdService;
    @Autowired
    EsmAgreementService esmAgreementService;
    @Autowired
    SysDeptService sysDeptService;
    @Autowired
    EsmRetailService esmRetailService;
    @Autowired
    EsmUserInternalService esmUserInternalService;

    //接口域名
    @Value("${cbit.url_pre}")
    String url_pre = "";
    //中介机构编码
    @Value("${cbit.franchiserId}")
    String franchiserId = "";
    //ip
    @Value("${cbit.ip}")
    String franchiserIp = "";
    //中介平台-加解密秘钥对  私钥+公钥
    @Value("${cbit.ZJPT_PUBLIC_KEY}")
    private String ZJPT_PUBLIC_KEY = "";
    //合作伙伴-加解密秘钥对  私钥+公钥
    @Value("${cbit.HZHB_PRIVATE_KEY}")
    private String HZHB_PRIVATE_KEY = "";
    @Value("${cbit.aly.url_pre}")
    String aly_url_pre = "";

    @Value("${cbit.franchiserChannelId_pingan}")
    String franchiserChannelId_pingan = "";
    @Value("${cbit.franchiserChannelCode_pingan}")
    String franchiserChannelCode_pingan = "";
    @Value("${cbit.carDealerCode_pingan}")
    String carDealerCode_pingan = "";
    @Value("${cbit.insurerBranchCode_pingan}")
    String insurerBranchCode_pingan = "";

    @Value("${cbit.franchiserChannelId_taiping}")
    String franchiserChannelId_taiping = "";
    @Value("${cbit.groupCode_taiping}")
    String groupCode_taiping = "";
    @Value("${cbit.insurerBranchCode_taiping}")
    String insurerBranchCode_taiping = "";

    @Value("${cbit.franchiserChannelId_taipingyang}")
    String franchiserChannelId_taipingyang = "";
    @Value("${cbit.insurerBranchCode_taipingyang}")
    String insurerBranchCode_taipingyang = "";

    /**
     * 3.2初始化参数获取接口
     * insurerId 保险公司id
     * insurerBranchCode 二级机构编码
     * franchiserChannelId 传中介网点代码
     */
    @PostMapping(value = "/initParamAPI")
    public InitResultData initParamAPI(@RequestBody String insurers) {
        CBITBaseparam req_baseparam = null;
        //平安
        if (insurers.contains("000017")) {
            req_baseparam = getPingAnBaseparam();
        }
        //太平洋
        if (insurers.contains("000014")) {
            req_baseparam = getTaiPingYangBaseparam();
        }
        //太平
        if (insurers.contains("000026")) {
            req_baseparam = getTaiPingBaseparam();
        }
        InitResultData initResultData = insCBITService.initParamAPI(req_baseparam);

        return initResultData;
    }

    /**
     * 车型查询接口
     */
    @PostMapping(value = "/queryModel")
    public HttpResult queryModel(@RequestBody CarModelQryVo carModelQryVo) {
        HttpResult httpResult = null;
        try {
            //车型查询默认使用太平洋
            String insurers = carModelQryVo.getInsurers();
            CBITBaseparam baseParam = null;
            //平安
            if (insurers.contains("000017")) {
                baseParam = getPingAnBaseparam();
            }
            //太平洋
            else if (insurers.contains("000014")) {
                baseParam = getTaiPingYangBaseparam();
            }
            //太平
            else if (insurers.contains("000026")) {
                baseParam = getTaiPingBaseparam();
            } else {
                baseParam = getTaiPingYangBaseparam();
            }
            HttpResult httpResult_orderno = insCBITService.geneOrder(baseParam);
            String orderno = "";
            if (httpResult_orderno.getCode() == 200) {
                orderno = (String) httpResult_orderno.getData();
            }
            baseParam.setOrderNo(orderno);
            carModelQryVo.setBaseParam(baseParam);
            carModelQryVo.setNewVehicleFlag("0");//是否新车，默认否
            httpResult = insCBITService.queryModel(carModelQryVo);

        } catch (Exception e) {
            e.printStackTrace();
            return HttpResult.error(e.getMessage());
        }
        return httpResult;
    }

    /**
     * 报价（需调用多个个接口：订单号生成、车辆确认、报价）
     *
     * @param quoteInfo
     * @return
     */
    @PostMapping("/quote")
    public HttpResult quote(@RequestBody CBITQuoteInfoVo quoteInfo) {
        List<QuoteRespData> quoteResults = new ArrayList<>();

        try {
            //必填校验
            checkEmpty(quoteInfo);
            String insurers = quoteInfo.getInsurers();
            //平安
            if (insurers.contains("000017")) {
                QuoteRespData pingAnQuote = quote_PingAn(quoteInfo);
                quoteResults.add(pingAnQuote);
            }
            //太平洋
            if (insurers.contains("000014")) {
                QuoteRespData taiPingYangQuote = quote_TaiPingYang(quoteInfo);
                quoteResults.add(taiPingYangQuote);
            }
            //太平
            if (insurers.contains("000026")) {
                QuoteRespData taiPingQuote = quote_TaiPing(quoteInfo);
                quoteResults.add(taiPingQuote);
            }

        } catch (Exception e) {
            e.printStackTrace();
            return HttpResult.error(e.getMessage());
        }
        return HttpResult.ok(quoteResults);
    }

    /**
     * 3.8核保接口
     *
     * @param
     * @return
     */
    @PostMapping("/submitAudit")
    public HttpResult submitAudit(@RequestBody CBITQuoteInfoVo quoteInfo) {
        HttpResult httpResult = new HttpResult();
        try {
            //必填校验
            checkEmpty_Audit(quoteInfo);
            String insurers = quoteInfo.getInsurers();
            String orderNo = quoteInfo.getOrderno();

            //平安
            if (insurers.contains("000017")) {
                httpResult = audit_PingAn(quoteInfo, orderNo);
            }
            //太平洋
            if (insurers.contains("000014")) {
                httpResult = audit_TaiPingYang(quoteInfo, orderNo);
            }
            //太平
            if (insurers.contains("000026")) {
                httpResult = audit_TaiPing(quoteInfo, orderNo);
            }
        } catch (Exception e) {
            e.printStackTrace();
            return HttpResult.error(e.getMessage());
        }
        return httpResult;
    }

    /**
     * 支付
     *
     * @return
     */
    @PostMapping("/pingAnPay")
    public HttpResult pingAnPay(@RequestBody String req_param) {
        HttpResult httpResult = null;
        try {
            String orderNo = JSON.parseObject(req_param).getString("orderno");
            CBITBaseparam pingAnbaseParam = getPingAnBaseparam();
            pingAnbaseParam.setOrderNo(orderNo);
            httpResult = insCBITService.pay_application(pingAnbaseParam);

        } catch (Exception e) {
            e.printStackTrace();
            return HttpResult.error(e.getMessage());
        }
        return httpResult;
    }

    /**
     * 支付
     *
     * @return
     */
    @PostMapping("/taiPingYangPay")
    public HttpResult taiPingYangPay(@RequestBody String req_param) {
        HttpResult httpResult = null;
        try {
            String orderNo = JSON.parseObject(req_param).getString("orderno");
            CBITBaseparam taiPingYangbaseParam = getTaiPingYangBaseparam();
            taiPingYangbaseParam.setOrderNo(orderNo);
            httpResult = insCBITService.pay_application(taiPingYangbaseParam);

        } catch (Exception e) {
            e.printStackTrace();
            return HttpResult.error(e.getMessage());
        }
        return httpResult;
    }

    /**
     * 支付--发短信
     *
     * @return
     */
    @PostMapping("/taiPingDuanXin")
    public HttpResult taiPingDuanXin(@RequestBody String req_param) {
        HttpResult httpResult = null;
        try {
            String orderNo = JSON.parseObject(req_param).getString("orderno");
            CBITBaseparam taiPingbaseParam = getTaiPingBaseparam();
            taiPingbaseParam.setOrderNo(orderNo);
            httpResult = insCBITService.pay_duanxin(taiPingbaseParam);


        } catch (Exception e) {
            e.printStackTrace();
            return HttpResult.error(e.getMessage());
        }
        return httpResult;
    }

    /**
     * 支付
     *
     * @return
     */
    @PostMapping("/taiPingPay")
    public HttpResult taiPingPay(@RequestBody Map<String, String> req_param) {
        HttpResult httpResult = null;
        try {
            String orderNo = req_param.get("orderno");
            String issueCode = req_param.get("issueCode");
            CBITBaseparam taiPingbaseParam = getTaiPingBaseparam();
            taiPingbaseParam.setOrderNo(orderNo);

            insCBITService.pay_duanxin_back(taiPingbaseParam, issueCode);

            httpResult = insCBITService.pay_duanxin_pay(taiPingbaseParam);

        } catch (Exception e) {
            e.printStackTrace();
            return HttpResult.error(e.getMessage());
        }
        return httpResult;
    }


    /**
     * 3.19支付信息回调接口
     *
     * @return
     */

    @PostMapping("/updatePayInfo")
    public HttpServletResponse updatePayInfo(HttpServletRequest request, HttpServletResponse http_resp, @RequestBody Map<String, String> reqMap) {
        ReqParamCBIT reqParam_cbit = null;
        String url = aly_url_pre + "/updatePayInfo";
        String req_desc = "支付信息回调接口";
        String reqGetContent = "";
        String resp_json = "";//阿里云返回
        try {
            String req_bizContent = reqMap.get("bizContent");
            String req_sign = request.getHeader("Signature");
            logger.info("bizContent-->" + req_bizContent);
            logger.info("Signature-->" + req_sign);
            reqGetContent = RSAUtils.checkSignAndDecrypt(req_bizContent, req_sign, ZJPT_PUBLIC_KEY, HZHB_PRIVATE_KEY, "UTF-8", true, true);
            logger.info("解密后的请求参数reqGetContent=" + reqGetContent);

            Map<String, String> reqGetContentMap = JSON.parseObject(reqGetContent, Map.class);
            String bizContent = JSON.toJSONString(reqGetContentMap.get("bizContent"));
            reqParam_cbit = JSON.parseObject(bizContent, ReqParamCBIT.class);
            String orderNo = reqParam_cbit.getOrderNo();
            String payResult = reqParam_cbit.getPayResult();
            //-------具体系统状态更新逻辑---------
            if ("1".equals(payResult)) {
                //2.调用aly接口
                String req_json = JSON.toJSONString(reqParam_cbit);
                logger.info(req_desc + "--请求url-->" + url);
                logger.info(req_desc + "--请求参数-->" + req_json);
                resp_json = HttpsPostUtil.sendCBITPost_self(url, req_json);
                logger.info(req_desc + "--返回结果-->" + resp_json);
                //4.处理接口返回数据
                ObjectMapper objectMapper = new ObjectMapper();
                ObjectReader reader = objectMapper.readerFor(HttpResult.class);
                HttpResult httpResult = new HttpResult();
                try {
                    httpResult = reader.readValue(resp_json);
                } catch (IOException e) {
                    throw new Exception("反序列化失败");
                }
                if (httpResult == null) {
                    throw new Exception("反序列化失败");
                }
                if (httpResult.getCode() != 200) {
                    throw new Exception("支付信息回调接口，服务器处理异常：" + httpResult.getMsg());
                }
            }
            //拼装返回信息
            geneResponse(http_resp, reqParam_cbit);
            // 插入接口日志表
            insertCbitLog(url, req_desc, reqParam_cbit.getBaseParam().getRequestNo(), reqGetContent, resp_json);
        } catch (Exception e) {
            //记录报错日志表
            e.printStackTrace();
            String api_url = "/CBIT/API/insCBIT/updatePayInfo";
            String errorinfo = e.getMessage();
            insertCbitError(reqParam_cbit, api_url, errorinfo);
            //拼装返回信息
            geneErrorResponse(http_resp, reqParam_cbit, errorinfo);
        }
        return http_resp;
    }

    /**
     * 3.20保单结果回调接口
     *
     * @return
     */
    @PostMapping("/updatePolicyStatus")
    public HttpServletResponse updatePolicyStatus(HttpServletRequest request, HttpServletResponse http_resp, @RequestBody Map<String, String> reqMap) {
        ReqParamCBIT reqParam_cbit = null;
        String url = aly_url_pre + "/updatePolicyStatus";

        try {
            String req_bizContent = reqMap.get("bizContent");
            String req_sign = request.getHeader("Signature");
            logger.info("bizContent-->" + req_bizContent);
            logger.info("Signature-->" + req_sign);

            String reqGetContent = RSAUtils.checkSignAndDecrypt(req_bizContent, req_sign, ZJPT_PUBLIC_KEY, HZHB_PRIVATE_KEY, "UTF-8", true, true);
            logger.info("解密后的请求参数reqGetContent=" + reqGetContent);

            Map<String, String> reqGetContentMap = JSON.parseObject(reqGetContent, Map.class);
            String bizContent = JSON.toJSONString(reqGetContentMap.get("bizContent"));

            reqParam_cbit = JSON.parseObject(bizContent, ReqParamCBIT.class);
            //-------具体系统状态更新逻辑---------
            //2.调用aly接口
            String req_desc = "保单结果回调接口";
            String req_json = JSON.toJSONString(reqParam_cbit);
            logger.info(req_desc + "--请求url-->" + url);
            logger.info(req_desc + "--请求参数-->" + req_json);
            String resp_json = HttpsPostUtil.sendCBITPost_self(url, req_json);
            logger.info(req_desc + "--返回结果-->" + resp_json);
            //4.处理接口返回数据
            ObjectMapper objectMapper = new ObjectMapper();
            ObjectReader reader = objectMapper.readerFor(HttpResult.class);
            HttpResult httpResult = new HttpResult();
            try {
                httpResult = reader.readValue(resp_json);
            } catch (IOException e) {
                throw new Exception("反序列化失败");
            }
            if (httpResult == null) {
                throw new Exception("反序列化失败");
            }
            if (httpResult.getCode() != 200) {
                throw new Exception("保单结果回调接口，服务器处理异常：" + httpResult.getMsg());
            }

            //拼装返回信息
            geneResponse(http_resp, reqParam_cbit);
            // 插入接口日志表
            insertCbitLog(url, req_desc, reqParam_cbit.getBaseParam().getRequestNo(), reqGetContent, resp_json);

        } catch (Exception e) {
            //记录报错日志表
            e.printStackTrace();
            String api_url = "/CBIT/API/insCBIT/updatePolicyStatus";
            String errorinfo = e.getMessage();
            insertCbitError(reqParam_cbit, api_url, errorinfo);
            //拼装返回信息
            geneErrorResponse(http_resp, reqParam_cbit, errorinfo);
        }
        return http_resp;
    }

    /**
     * 3.21人工审核信息回调接口
     *
     * @return
     */

    @PostMapping("/updateAudit")
    public HttpServletResponse updateAudit(HttpServletRequest request, HttpServletResponse http_resp, @RequestBody Map<String, String> reqMap) {
        ReqParamCBIT reqParam_cbit = null;
        String url = aly_url_pre + "/updateAudit";
        try {
            String req_bizContent = reqMap.get("bizContent");
            String req_sign = request.getHeader("Signature");
            logger.info("bizContent-->" + req_bizContent);
            logger.info("Signature-->" + req_sign);
            String reqGetContent = RSAUtils.checkSignAndDecrypt(req_bizContent, req_sign, ZJPT_PUBLIC_KEY, HZHB_PRIVATE_KEY, "UTF-8", true, true);
            System.out.println("解密后的请求参数reqGetContent=" + reqGetContent);

            Map<String, String> reqGetContentMap = JSON.parseObject(reqGetContent, Map.class);
            String bizContent = JSON.toJSONString(reqGetContentMap.get("bizContent"));

            reqParam_cbit = JSON.parseObject(bizContent, ReqParamCBIT.class);

            //2.调用aly接口
            String req_desc = "人工审核信息回调接口";
            String req_json = JSON.toJSONString(reqParam_cbit);
            logger.info(req_desc + "--请求url-->" + url);
            logger.info(req_desc + "--请求参数-->" + req_json);
            String resp_json = HttpsPostUtil.sendCBITPost_self(url, req_json);
            logger.info(req_desc + "--返回结果-->" + resp_json);
            //4.处理接口返回数据
            ObjectMapper objectMapper = new ObjectMapper();
            ObjectReader reader = objectMapper.readerFor(HttpResult.class);
            HttpResult httpResult = new HttpResult();
            try {
                httpResult = reader.readValue(resp_json);
            } catch (IOException e) {
                throw new Exception("反序列化失败");
            }
            if (httpResult == null) {
                throw new Exception("反序列化失败");
            }
            if (httpResult.getCode() != 200) {
                throw new Exception("人工审核信息回调，服务器处理异常：" + httpResult.getMsg());
            }

            //拼装返回信息
            geneResponse(http_resp, reqParam_cbit);
            // 插入接口日志表
            insertCbitLog(url, req_desc, reqParam_cbit.getBaseParam().getRequestNo(), reqGetContent, resp_json);

        } catch (Exception e) {
            //记录报错日志表
            e.printStackTrace();
            String api_url = "/CBIT/API/insCBIT/updateAudit";
            String errorinfo = e.getMessage();
            insertCbitError(reqParam_cbit, api_url, errorinfo);
            //拼装返回信息
            geneErrorResponse(http_resp, reqParam_cbit, errorinfo);
        }
        return http_resp;
    }


    private HttpResult audit_PingAn(CBITQuoteInfoVo quoteInfo, String orderNo) throws Exception {
        HttpResult httpResult;

        //查询订单
//        InsOrder order = insOrderService.selectZMByPk(orderNo);
        InsOrder order = quoteInfo.getInsOrder();
        if (order != null) {
            //1.调核保接口
            CBITReqParam reqParam_in = new CBITReqParam();
            CBITBaseparam pingAnbaseParam = getPingAnBaseparam();
            pingAnbaseParam.setOrderNo(orderNo);
            reqParam_in.setBaseParam(pingAnbaseParam);
            VehicleModel_QueRen vehicleModel_QueRen = JSON.parseObject(JSON.toJSONString(order.getCarinfo()), VehicleModel_QueRen.class);
            quoteInfo.setVehicleModel_QueRen(vehicleModel_QueRen);//险别加工时要用
            quoteInfo.setRiskList(JSON.parseArray(JSON.toJSONString(order.getRiskinfo()), CBITRiskInfoVo.class));
            quoteInfo.setKindList(JSON.parseArray(JSON.toJSONString(order.getKindinfo()), KindInfoVo.class));
            httpResult = insCBITService.submitAudit(reqParam_in, quoteInfo);

           /* if (httpResult.getCode()==200) {
                AuditRespData auditRespData=(AuditRespData)httpResult.getData();
                Policy 	businessPolicy =auditRespData.getBusinessPolicy();
                Policy 	trafficPolicy =auditRespData.getTrafficPolicy();
                order.setOrderstatus("5");
                SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                order.setSubmittime(sdf.format(new Date()));
                order.setJqappoint(JSON.toJSONString(trafficPolicy.getSpecialTermItems())); //交强特别约定
                order.setSyappoint(JSON.toJSONString(businessPolicy.getSpecialTermItems())); //商业特别约定

                insOrderService.update(order);

                //插入轨迹表
                *//*InsTaskHistory history = new InsTaskHistory();
                history.setId(String.valueOf(new Date().getTime()));
                history.setCompany(order.getInscompany());
                history.setTaskid(order.getOrderno());
                history.setOperatorid(order.getUserid());
                history.setOperator(order.getUsername());
                history.setCreatetime(sdf.format(new Date()));
                history.setStatus("1");
                history.setRemark("提交核保");
                insTaskHistoryService.insert(history);*//*
            }*/

        } else {
            return HttpResult.error("订单号有误！");
        }
        return httpResult;
    }

    private HttpResult audit_TaiPingYang(CBITQuoteInfoVo quoteInfo, String orderNo) throws Exception {
        HttpResult httpResult;

        //查询订单
//        InsOrder order = insOrderService.selectZMByPk(orderNo);
        InsOrder order = quoteInfo.getInsOrder();
        if (order != null) {
            //1.调核保接口
            CBITReqParam reqParam_in = new CBITReqParam();
            CBITBaseparam taiPingYangbaseParam = getTaiPingYangBaseparam();
            taiPingYangbaseParam.setOrderNo(orderNo);
            reqParam_in.setBaseParam(taiPingYangbaseParam);
            VehicleModel_QueRen vehicleModel_QueRen = JSON.parseObject(JSON.toJSONString(order.getCarinfo()), VehicleModel_QueRen.class);
            quoteInfo.setVehicleModel_QueRen(vehicleModel_QueRen);//险别加工时要用
            quoteInfo.setRiskList(JSON.parseArray(JSON.toJSONString(order.getRiskinfo()), CBITRiskInfoVo.class));
            quoteInfo.setKindList(JSON.parseArray(JSON.toJSONString(order.getKindinfo()), KindInfoVo.class));
            httpResult = insCBITService.submitAudit(reqParam_in, quoteInfo);

           /* if (httpResult.getCode()==200) {
                AuditRespData auditRespData=(AuditRespData)httpResult.getData();
                Policy 	businessPolicy =auditRespData.getBusinessPolicy();
                Policy 	trafficPolicy =auditRespData.getTrafficPolicy();
                order.setOrderstatus("5");
                SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                order.setSubmittime(sdf.format(new Date()));
                order.setJqappoint(JSON.toJSONString(trafficPolicy.getSpecialTermItems())); //交强特别约定
                order.setSyappoint(JSON.toJSONString(businessPolicy.getSpecialTermItems())); //商业特别约定

                insOrderService.update(order);

                //插入轨迹表
                *//*InsTaskHistory history = new InsTaskHistory();
                history.setId(String.valueOf(new Date().getTime()));
                history.setCompany(order.getInscompany());
                history.setTaskid(order.getOrderno());
                history.setOperatorid(order.getUserid());
                history.setOperator(order.getUsername());
                history.setCreatetime(sdf.format(new Date()));
                history.setStatus("1");
                history.setRemark("提交核保");
                insTaskHistoryService.insert(history);*//*
            }*/

        } else {
            return HttpResult.error("订单号有误！");
        }
        return httpResult;
    }

    private HttpResult audit_TaiPing(CBITQuoteInfoVo quoteInfo, String orderNo) throws Exception {
        HttpResult httpResult;

        //查询订单
//        InsOrder order = insOrderService.selectZMByPk(orderNo);
        InsOrder order = quoteInfo.getInsOrder();
        if (order != null) {
            //1.调核保接口
            CBITReqParam reqParam_in = new CBITReqParam();
            CBITBaseparam taiPingbaseParam = getTaiPingBaseparam();
            taiPingbaseParam.setOrderNo(orderNo);
            reqParam_in.setBaseParam(taiPingbaseParam);
            VehicleModel_QueRen vehicleModel_QueRen = JSON.parseObject(JSON.toJSONString(order.getCarinfo()), VehicleModel_QueRen.class);
            quoteInfo.setVehicleModel_QueRen(vehicleModel_QueRen);//险别加工时要用
            quoteInfo.setRiskList(JSON.parseArray(JSON.toJSONString(order.getRiskinfo()), CBITRiskInfoVo.class));
            quoteInfo.setKindList(JSON.parseArray(JSON.toJSONString(order.getKindinfo()), KindInfoVo.class));
            httpResult = insCBITService.submitAudit(reqParam_in, quoteInfo);

           /* if (httpResult.getCode()==200) {
                AuditRespData auditRespData=(AuditRespData)httpResult.getData();
                Policy 	businessPolicy =auditRespData.getBusinessPolicy();
                Policy 	trafficPolicy =auditRespData.getTrafficPolicy();
                order.setOrderstatus("5");
                SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                order.setSubmittime(sdf.format(new Date()));
                order.setJqappoint(JSON.toJSONString(trafficPolicy.getSpecialTermItems())); //交强特别约定
                order.setSyappoint(JSON.toJSONString(businessPolicy.getSpecialTermItems())); //商业特别约定

                insOrderService.update(order);

                //插入轨迹表
                *//*InsTaskHistory history = new InsTaskHistory();
                history.setId(String.valueOf(new Date().getTime()));
                history.setCompany(order.getInscompany());
                history.setTaskid(order.getOrderno());
                history.setOperatorid(order.getUserid());
                history.setOperator(order.getUsername());
                history.setCreatetime(sdf.format(new Date()));
                history.setStatus("1");
                history.setRemark("提交核保");
                insTaskHistoryService.insert(history);*//*
            }*/

        } else {
            return HttpResult.error("订单号有误！");
        }
        return httpResult;
    }

    private void checkEmpty(@RequestBody CBITQuoteInfoVo quoteInfo) throws Exception {
        if (StringUtils.isEmpty(quoteInfo.getInsurers())) {
            throw new Exception("insurers不能为空！");
        }
        if (quoteInfo.getCarInfo() == null || quoteInfo.getVehicleModel() == null) {
            throw new Exception("carInfo/vehicleModel不能为空！");
        }
        if (quoteInfo.getOwnerInfo() == null || quoteInfo.getPolicyHolderInfo() == null || quoteInfo.getInsuredPersonInfo() == null) {
            throw new Exception("ownerInfo/policyHolderInfo/insuredPersonInfo 不能为空！");
        }
        if (quoteInfo.getRiskList() == null || quoteInfo.getRiskList().size() == 0) {
            throw new Exception("riskList 不能为空！");
        } else {
            for (CBITRiskInfoVo cBITRiskInfoVo : quoteInfo.getRiskList()) {
                if (cBITRiskInfoVo.getStartDate() == null) {
                    throw new Exception("riskList.startDate 不能为空！");
                }
            }
        }

    }

    private void checkEmpty_Audit(@RequestBody CBITQuoteInfoVo quoteInfo) throws Exception {
        if (StringUtils.isEmpty(quoteInfo.getInsurers())) {
            throw new Exception("insurers不能为空！");
        }
        if (StringUtils.isEmpty(quoteInfo.getOrderno())) {
            throw new Exception("orderno不能为空！");
        }
        /*if(quoteInfo.getCarInfo()==null||quoteInfo.getVehicleModel()==null){
            throw new Exception("carInfo/vehicleModel不能为空！");
        }
        if(quoteInfo.getRiskList()==null||quoteInfo.getRiskList().size()==0){
            throw new Exception("riskList 不能为空！");
        }*/

    }

    private QuoteRespData quote_TaiPingYang(CBITQuoteInfoVo quoteInfo) throws Exception {
        //1.太平洋-订单号生成
        CBITBaseparam taiPingYangbaseParam = getTaiPingYangBaseparam();
        HttpResult httpResult_orderno = insCBITService.geneOrder(taiPingYangbaseParam);
        String orderno = "";
        if (httpResult_orderno.getCode() == 200) {
            orderno = (String) httpResult_orderno.getData();
        } else {
            throw new Exception("订单号生成出错，错误信息：" + httpResult_orderno.getMsg());
        }
        taiPingYangbaseParam.setOrderNo(orderno);
        //2.太平洋--车型查询
        CarInfoVo carInfo = quoteInfo.getCarInfo();
        CarModelQryVo carModelQryVo = new CarModelQryVo();
        carModelQryVo.setBaseParam(taiPingYangbaseParam);
        carModelQryVo.setModelCName(carInfo.getModelcname());
        carModelQryVo.setEngineNo(carInfo.getEngineNo());
        carModelQryVo.setVin(carInfo.getVinNo());
        carModelQryVo.setNewVehicleFlag("0");//是否新车，默认否
        HttpResult httpResult_query = insCBITService.queryModel(carModelQryVo);
        if (httpResult_query.getCode() != 200) {
            throw new Exception("太平洋--车型查询出错，错误信息：" + httpResult_query.getMsg());
        }
        //3.太平洋--车辆确认
        CBITReqParam taiPingYangreqParam_in = new CBITReqParam();
        taiPingYangreqParam_in.setBaseParam(taiPingYangbaseParam);

        //3.1车主信息
        CustomerInfoVo ownerInfo = quoteInfo.getOwnerInfo();
        CarOwner carOwner = getCarOwner(ownerInfo);
        carOwner.setCertiStartDate("2020-1-1");
        carOwner.setCertiEndDate("2030-1-1");
        //3.2投保人信息
        CustomerInfoVo policyHolderInfo = quoteInfo.getPolicyHolderInfo();
        Holder holder = getHolder(policyHolderInfo);
        holder.setCertiStartDate("2020-1-1");
        holder.setCertiEndDate("2030-1-1");
        holder.setElecApplicationFlag("0");
        //3.3被保人信息
        CustomerInfoVo insuredPersonInfo = quoteInfo.getInsuredPersonInfo();
        Insureder insureder = getInsureder(insuredPersonInfo);
        insureder.setCertiStartDate("2020-1-1");
        insureder.setCertiEndDate("2030-1-1");
        //3.4车辆信息
        VehicleModel vehicleModel = quoteInfo.getVehicleModel();
        SimpleDateFormat sdfm = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        Vehicle vehicle = getVehicle(carInfo, vehicleModel, sdfm.parse(quoteInfo.getRiskList().get(0).getStartDate()), "000017");

        taiPingYangreqParam_in.setCarOwner(carOwner);
        taiPingYangreqParam_in.setHolder(holder);
        taiPingYangreqParam_in.setInsureder(insureder);
        taiPingYangreqParam_in.setVehicle(vehicle);
        HttpResult httpResult_confirm = insCBITService.confirmVehicle(taiPingYangreqParam_in);
        if (httpResult_confirm.getCode() != 200) {
            throw new Exception("车型确认出错，错误信息：" + httpResult_confirm.getMsg());
        }
        ConfirmVehicleResqData confirmVehicleResqData = (ConfirmVehicleResqData) httpResult_confirm.getData();
        if (confirmVehicleResqData.getVehicleModels() == null || confirmVehicleResqData.getVehicleModels().size() == 0) {
            throw new Exception("车型确认保信返回车型列表为空！");
        }
        quoteInfo.setVehicleModel_QueRen(confirmVehicleResqData.getVehicleModels().get(0));
        //4.太平洋--报价
        quoteInfo.setBaseParam(taiPingYangbaseParam);
        QuoteRespData quoteRespData = insCBITService.quote(quoteInfo);
        quoteRespData.setOrderno(orderno);
        //5.插入ins_order表
        /*InsOrder insOrder=geneInsOrder(quoteInfo,quoteRespData,"太平洋-000014",confirmVehicleResqData.getVehicleModels().get(0));
        quoteRespData.setInsOrder(insOrder);*/
        quoteRespData.setQuoteInfo(quoteInfo);
        return quoteRespData;
    }

    private QuoteRespData quote_TaiPing(CBITQuoteInfoVo quoteInfo) throws Exception {
        //1.太平-订单号生成
        CBITBaseparam taiPingbaseParam = getTaiPingBaseparam();
        HttpResult httpResult_orderno = insCBITService.geneOrder(taiPingbaseParam);
        String orderno = "";
        if (httpResult_orderno.getCode() == 200) {
            orderno = (String) httpResult_orderno.getData();
        } else {
            throw new Exception("订单号生成出错，错误信息：" + httpResult_orderno.getMsg());
        }
        taiPingbaseParam.setOrderNo(orderno);
        //2.太平--车型查询
        CarInfoVo carInfo = quoteInfo.getCarInfo();
        CarModelQryVo carModelQryVo = new CarModelQryVo();
        carModelQryVo.setBaseParam(taiPingbaseParam);
        carModelQryVo.setModelCName(carInfo.getModelcname());
        carModelQryVo.setEngineNo(carInfo.getEngineNo());
        carModelQryVo.setVin(carInfo.getVinNo());
        carModelQryVo.setNewVehicleFlag("0");//是否新车，默认否
        HttpResult httpResult_query = insCBITService.queryModel(carModelQryVo);
        if (httpResult_query.getCode() != 200) {
            throw new Exception("太平--车型查询出错，错误信息：" + httpResult_query.getMsg());
        }
        //3.太平--车辆确认
        CBITReqParam taiPingreqParam_in = new CBITReqParam();
        taiPingreqParam_in.setBaseParam(taiPingbaseParam);

        //3.1车主信息
        CustomerInfoVo ownerInfo = quoteInfo.getOwnerInfo();
        CarOwner carOwner = getCarOwner(ownerInfo);
        carOwner.setCertiStartDate("2020-1-1");
        carOwner.setCertiEndDate("2030-1-1");
        //3.2投保人信息
        CustomerInfoVo policyHolderInfo = quoteInfo.getPolicyHolderInfo();
        Holder holder = getHolder(policyHolderInfo);
        holder.setCertiStartDate("2020-1-1");
        holder.setCertiEndDate("2030-1-1");
        holder.setElecApplicationFlag("0");
        //3.3被保人信息
        CustomerInfoVo insuredPersonInfo = quoteInfo.getInsuredPersonInfo();
        Insureder insureder = getInsureder(insuredPersonInfo);
        insureder.setCertiStartDate("2020-1-1");
        insureder.setCertiEndDate("2030-1-1");
        //3.4车辆信息
        VehicleModel vehicleModel = quoteInfo.getVehicleModel();
        SimpleDateFormat sdfm = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        Vehicle vehicle = getVehicle(carInfo, vehicleModel, sdfm.parse(quoteInfo.getRiskList().get(0).getStartDate()), "000017");

        taiPingreqParam_in.setCarOwner(carOwner);
        taiPingreqParam_in.setHolder(holder);
        taiPingreqParam_in.setInsureder(insureder);
        taiPingreqParam_in.setVehicle(vehicle);
        HttpResult httpResult_confirm = insCBITService.confirmVehicle(taiPingreqParam_in);
        if (httpResult_confirm.getCode() != 200) {
            throw new Exception("车型确认出错，错误信息：" + httpResult_confirm.getMsg());
        }
        ConfirmVehicleResqData confirmVehicleResqData = (ConfirmVehicleResqData) httpResult_confirm.getData();
        if (confirmVehicleResqData.getVehicleModels() == null || confirmVehicleResqData.getVehicleModels().size() == 0) {
            throw new Exception("车型确认保信返回车型列表为空！");
        }
        quoteInfo.setVehicleModel_QueRen(confirmVehicleResqData.getVehicleModels().get(0));
        //3.太平--报价
        quoteInfo.setBaseParam(taiPingbaseParam);
        QuoteRespData quoteRespData = insCBITService.quote(quoteInfo);
        quoteRespData.setOrderno(orderno);
        //4.插入ins_order表
        /*InsOrder insOrder=geneInsOrder(quoteInfo,quoteRespData,"太平-000026",confirmVehicleResqData.getVehicleModels().get(0));
        quoteRespData.setInsOrder(insOrder);*/
        quoteRespData.setQuoteInfo(quoteInfo);
        return quoteRespData;
    }

    private QuoteRespData quote_PingAn(CBITQuoteInfoVo quoteInfo) throws Exception {
        //1.平安--订单号生成
        CBITBaseparam pingAnbaseParam = getPingAnBaseparam();
        HttpResult httpResult_orderno = insCBITService.geneOrder(pingAnbaseParam);
        String orderno = "";
        if (httpResult_orderno.getCode() == 200) {
            orderno = (String) httpResult_orderno.getData();
        } else {
            throw new Exception("订单号生成出错，错误信息：" + httpResult_orderno.getMsg());
        }
        pingAnbaseParam.setOrderNo(orderno);
        //2.平安--车辆确认
        CBITReqParam pingAnreqParam_in = new CBITReqParam();
        pingAnreqParam_in.setBaseParam(pingAnbaseParam);

        //2.1车主信息
        CustomerInfoVo ownerInfo = quoteInfo.getOwnerInfo();
        CarOwner carOwner = getCarOwner(ownerInfo);
        carOwner.setCertiStartDate("2020-1-1");
        carOwner.setCertiEndDate("2030-1-1");
        //2.2投保人信息
        CustomerInfoVo policyHolderInfo = quoteInfo.getPolicyHolderInfo();
        Holder holder = getHolder(policyHolderInfo);
        holder.setCertiStartDate("2020-1-1");
        holder.setCertiEndDate("2030-1-1");
        holder.setElecApplicationFlag("0");
        //2.3被保人信息
        CustomerInfoVo insuredPersonInfo = quoteInfo.getInsuredPersonInfo();
        Insureder insureder = getInsureder(insuredPersonInfo);
        insureder.setCertiStartDate("2020-1-1");
        insureder.setCertiEndDate("2030-1-1");
        //2.4车辆信息
        CarInfoVo carInfo = quoteInfo.getCarInfo();
        VehicleModel vehicleModel = quoteInfo.getVehicleModel();
        SimpleDateFormat sdfm = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        Vehicle vehicle = getVehicle(carInfo, vehicleModel, sdfm.parse(quoteInfo.getRiskList().get(0).getStartDate()), "000017");

        pingAnreqParam_in.setCarOwner(carOwner);
        pingAnreqParam_in.setHolder(holder);
        pingAnreqParam_in.setInsureder(insureder);
        pingAnreqParam_in.setVehicle(vehicle);
        HttpResult httpResult_confirm = insCBITService.confirmVehicle(pingAnreqParam_in);
        if (httpResult_confirm.getCode() != 200) {
            throw new Exception("车型确认出错，错误信息：" + httpResult_confirm.getMsg());
        }
        ConfirmVehicleResqData confirmVehicleResqData = (ConfirmVehicleResqData) httpResult_confirm.getData();
        if (confirmVehicleResqData.getVehicleModels() == null || confirmVehicleResqData.getVehicleModels().size() == 0) {
            throw new Exception("车型确认保信返回车型列表为空！");
        }
        quoteInfo.setVehicleModel_QueRen(confirmVehicleResqData.getVehicleModels().get(0));
        //3.平安--报价
        quoteInfo.setBaseParam(pingAnbaseParam);
        QuoteRespData quoteRespData = insCBITService.quote(quoteInfo);
        quoteRespData.setOrderno(orderno);
        //4.插入ins_order表
        /*InsOrder insOrder=geneInsOrder(quoteInfo,quoteRespData,"平安-000017",confirmVehicleResqData.getVehicleModels().get(0));
        quoteRespData.setInsOrder(insOrder);*/
        quoteRespData.setQuoteInfo(quoteInfo);
        return quoteRespData;
    }

    //报价生成ins_order
    private InsOrder geneInsOrder(CBITQuoteInfoVo quoteInfo, QuoteRespData quoteRespData, String insures, VehicleModel_QueRen vehicleModel_QueRen) throws Exception {
        InsOrder insOrder = new InsOrder();
        String orderno = quoteRespData.getOrderno();
        insOrder.setOrderno(orderno);
        insOrder.setQuoteno(String.valueOf(quoteInfo.getQuoteno()));
        insOrder.setOrderstatus("0");  //0报价 1待核保 2已核保待缴费 3核保退回 4核保不通过
        insOrder.setFrameNo(quoteInfo.getCarInfo().getFrameNo());
        insOrder.setLicenseNo(quoteInfo.getCarInfo().getLicenseNo());

        insOrder.setCarinfo(JSONObject.parseObject(JSONObject.toJSONString(vehicleModel_QueRen)));
        SysUser user = sysUserService.getById(quoteInfo.getUserId());
        if (user == null) {
            throw new Exception("userId不存在");
        }
        //
        if (StringUtils.isEmpty(quoteInfo.getCarInfo().getFrameNo())) {
            throw new Exception("车架号不能为空");
        }
        InsOrder orderObj = insOrderService.queryQuoteno(new Object[]{quoteInfo.getUserId(), quoteInfo.getCarInfo().getFrameNo(), quoteInfo.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 Exception("此车辆已提交核保，重新报价请先关闭订单，任务号:" + orderObj.getQuoteno());
            }
        }


        insOrder.setUsername(user.getName());
        insOrder.setDeptid(user.getDeptId());
        SysDept dept = sysDeptService.getById(user.getDeptId());
        insOrder.setDeptname(dept == null ? "" : dept.getName());


        insOrder.setOwnerinfo(JSONObject.parseObject(JSONObject.toJSONString(quoteInfo.getOwnerInfo())));
        insOrder.setApplyinfo(JSONObject.parseObject(JSONObject.toJSONString(quoteInfo.getPolicyHolderInfo())));
        insOrder.setInsureinfo(JSONObject.parseObject(JSONObject.toJSONString(quoteInfo.getInsuredPersonInfo())));

        insOrder.setInsuredname(quoteInfo.getPolicyHolderInfo().getName());
        List<CBITRiskInfoVo> risks = quoteInfo.getRiskList();
        for (CBITRiskInfoVo 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 = quoteInfo.getKindList();
        String productId = "";
        String productname = "";
        //平安：000004
        //太平：000005
        //太平洋：000007
        String ins_zgdd = "";
        if (insures.contains("000017")) {
            ins_zgdd = "000004";
        } else if (insures.contains("000026")) {
            ins_zgdd = "000005";
        } else if (insures.contains("000014")) {
            ins_zgdd = "000007";
        }


        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[]{ins_zgdd + "%", "%" + user.getDeptId() + "%"});
        if (agreements.size() == 0) {
            throw new Exception("不存在有效协议或机构" + 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");
        }

        double retailRate = countRetail(user.getDeptId(), user.getId());
        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(quoteInfo.getRiskList())));
        insOrder.setKindinfo(JSONObject.parseArray(JSONObject.toJSONString(quoteInfo.getKindList())));

        insOrder.setInscompany(insures);
        SimpleDateFormat sdfm = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        insOrder.setCreatetime(sdfm.format(new Date()));

        TrafficPolicy_resp trafficPolicy = quoteRespData.getTrafficPolicy();
        BusinessPolicy_resp businessPolicy = quoteRespData.getBusinessPolicy();
        BigDecimal vehicleTax = new BigDecimal(0);
        if (trafficPolicy != null) {//交强保费
            BigDecimal Vehiclemium = trafficPolicy.getPremium();
            vehicleTax = trafficPolicy.getVehicleTax().getTotalAmount();
            Vehiclemium = Vehiclemium.setScale(2, BigDecimal.ROUND_HALF_UP);
            insOrder.setJqpremium(Vehiclemium.doubleValue());
            insOrder.setTaxamount(vehicleTax.doubleValue());
        }
        if (businessPolicy != null) {//商业保费
            BigDecimal bd = businessPolicy.getPremium();
            bd = bd.setScale(2, BigDecimal.ROUND_HALF_UP);
            double syPremium = bd.doubleValue();
            insOrder.setSypremium(syPremium);
        }

        BigDecimal bd = quoteRespData.getPremium();
        bd = bd.setScale(2, BigDecimal.ROUND_HALF_UP);
        insOrder.setSumpremium(bd.doubleValue());
        //报价状态 0失败 1成功

        BigDecimal bds = new BigDecimal(insOrder.getSypremium());
        BigDecimal bd1 = bds.setScale(2, BigDecimal.ROUND_HALF_UP);

        insOrder.setSypremium(bd1.doubleValue());
        insOrder.setQuotestatus("1");

        insOrder.setUserid(user.getId());
        logger.info("用户id====" + insOrder.getUserid());
//        insOrderService.insert(insOrder);

        //插入轨迹表
        /*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());
        history.setCreatetime(sdfm.format(new Date()));
        history.setOperator(insOrder.getUsername());
        history.setStatus("0");
        history.setRemark("报价中");
        insTaskHistoryService.insert(history);
*/
        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;
    }

    private Vehicle getVehicle(CarInfoVo carInfo, VehicleModel vehicleModel, Date startdate, String insures) {
        Vehicle vehicle = new Vehicle();//车辆信息
        vehicle.setNewVehicleFlag("0");//是否新车
        vehicle.setCurrentValue(new BigDecimal(vehicleModel.getPurchasePrice()));
        vehicle.setCarVin(carInfo.getVinNo());
        vehicle.setVehicleModelCode(vehicleModel.getMoldCharacterCode());
        vehicle.setEngineNo(carInfo.getEngineNo());
        vehicle.setPlateNo(carInfo.getLicenseNo());
        vehicle.setRegisterDate(carInfo.getRegisterDate());
        vehicle.setPurchasePrice(new BigDecimal(vehicleModel.getPurchasePrice()));
        vehicle.setMoldName(vehicleModel.getMoldName());
        vehicle.setPlateColor("01");//01	蓝
        vehicle.setSeatCount(vehicleModel.getSeatCount());
        vehicle.setOriginalSeatCount(vehicleModel.getSeatCount());
        vehicle.setTonNumber("0");
        vehicle.setEmptyWeight(vehicleModel.getEmptyWeight());
        vehicle.setFuelType(vehicleModel.getFuelType());
        vehicle.setExhaustMeasure(new BigDecimal(vehicleModel.getEngineCapacity()));
        vehicle.setVehicleAlias(vehicleModel.getVehicleAlias());
        vehicle.setVehicleKind("11");//11	客车
        vehicle.setLicenseType("02");//02	小型汽车号牌
        /**需按保司进行判断
         * 国寿财：210	非营业个人
         * 太平：253	家庭自用 "000026"
         * 人保：210	非营业个人
         * 平安：200	非营业 "000017"
         * 阳光：210	非营业个人
         * 中华：253	家庭自用 "000012"
         * 天安：253	家庭自用 "000022"
         * 大地：253	家庭自用 "000010"
         * 太保：253	家庭自用 "000014"
         */
        String usageDetail = "210";//210	非营业个人

        String usage253 = "000026,000012,000022,000010,000014,000017";
        if (usage253.contains(insures)) {
            usageDetail = "253";
        }

        vehicle.setVehicleUsageDetail(usageDetail);//210	非营业个人
        vehicle.setVehicleAffNature("1");//1	个人
        vehicle.setVehicleTypeOfDrivingPermit("K33");//K33	小型轿车
        vehicle.setSecondHandVehicleFlag("0");//是否二手车
        vehicle.setVehicleUsage("200");//200	非营业
        vehicle.setVehicleQuery(vehicleModel.getMoldName());
        if (carInfo.isTransferFlag() == true) {
            vehicle.setIsTransfer("1");//是否过户
            vehicle.setTransferDate(carInfo.getTransferDate());
        } else {
            vehicle.setIsTransfer("0");
        }
        vehicle.setCertificationDate(carInfo.getIssueDate());
        SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        vehicle.setEffectDate(df.format(startdate));
        return vehicle;
    }

    private Insureder getInsureder(CustomerInfoVo insuredPersonInfo) {
        Insureder insureder = new Insureder();//被保人信息
        insureder.setInsuredName(insuredPersonInfo.getName());
        insureder.setCertType("111");//默认身份证
        insureder.setCertiType("0");//证件是否长期
        insureder.setCertNo(insuredPersonInfo.getIdentifyNumber());
        insureder.setCustomerType("2");
        insureder.setPhoneNumber(insuredPersonInfo.getMobile());
        insureder.setCertiStartDate("");
        insureder.setCertiEndDate("");
        insureder.setNation("");
        insureder.setIssuer("");
        insureder.setAddress(insuredPersonInfo.getAddr());
        return insureder;
    }

    private Holder getHolder(CustomerInfoVo policyHolderInfo) {
        Holder holder = new Holder();//投保人信息
        holder.setHolderName(policyHolderInfo.getName());
        holder.setInvoiceType("1");
        holder.setBizFormatType("1");
        holder.setForceFormatType("1");
        holder.setCertType("111");//默认身份证
        holder.setCertiType("0");//证件是否长期
        holder.setCertNo(policyHolderInfo.getIdentifyNumber());
        holder.setCustomerType("2");
        holder.setPhoneNumber(policyHolderInfo.getMobile());
        holder.setCertiStartDate("");
        holder.setCertiEndDate("");
        holder.setNation("");
        holder.setIssuer("");
        holder.setAddress(policyHolderInfo.getAddr());

        return holder;
    }

    private CarOwner getCarOwner(CustomerInfoVo ownerInfo) {
        CarOwner carOwner = new CarOwner();//车主信息
        carOwner.setOwnerName(ownerInfo.getName());
        carOwner.setCertType("111");//默认身份证
        carOwner.setCertiType("0");//证件是否长期
        carOwner.setCertNo(ownerInfo.getIdentifyNumber());
        carOwner.setCustomerType("2");
        carOwner.setPhoneNumber(ownerInfo.getMobile());
        carOwner.setCertiStartDate("");
        carOwner.setCertiEndDate("");
        carOwner.setNation("");
        carOwner.setIssuer("");
        carOwner.setAddress(ownerInfo.getAddr());
        return carOwner;
    }

    private CBITBaseparam getTaiPingBaseparam() {
        CBITBaseparam baseParam = new CBITBaseparam();
        baseParam.setInsurerId("000026");
        baseParam.setInsurerBranchCode(insurerBranchCode_taiping);
        FranchiserChannel franchiserChannel = new FranchiserChannel();
        franchiserChannel.setFranchiserChannelId(franchiserChannelId_taiping);
//        franchiserChannel.setFranchiserChannelCode(franchiserChannelId_taiping);
        franchiserChannel.setGroupCode(groupCode_taiping);
        baseParam.setFranchiserChannel(franchiserChannel);
        return baseParam;
    }

    private CBITBaseparam getTaiPingYangBaseparam() {
        CBITBaseparam baseParam = new CBITBaseparam();
        baseParam.setInsurerId("000014");
        baseParam.setInsurerBranchCode(insurerBranchCode_taipingyang);
        FranchiserChannel franchiserChannel = new FranchiserChannel();
        franchiserChannel.setFranchiserChannelId(franchiserChannelId_taipingyang);
//        franchiserChannel.setFranchiserChannelCode(franchiserChannelCode_taipingyang);
        baseParam.setFranchiserChannel(franchiserChannel);
        return baseParam;
    }

    private CBITBaseparam getPingAnBaseparam() {
        CBITBaseparam baseParam = new CBITBaseparam();
        baseParam.setInsurerId("000017");
        baseParam.setInsurerBranchCode(insurerBranchCode_pingan);
        FranchiserChannel franchiserChannel = new FranchiserChannel();
        franchiserChannel.setFranchiserChannelId(franchiserChannelId_pingan);
        franchiserChannel.setCarDealerCode(carDealerCode_pingan);
        franchiserChannel.setFranchiserChannelCode(franchiserChannelCode_pingan);
        baseParam.setFranchiserChannel(franchiserChannel);
        return baseParam;
    }


    private void geneResponse(HttpServletResponse http_resp, ReqParamCBIT reqParam_cbit) throws Exception {
        CBITBaseparam baseParam = new CBITBaseparam();
        baseParam.setRequestNo(reqParam_cbit.getBaseParam().getRequestNo());
        baseParam.setFranchiserId(franchiserId);
        ResponseCBIT resp = new ResponseCBIT("Z00001", "处理成功", baseParam);
        String resp_str = JSON.toJSONString(resp);
        System.out.println("加密前返回参数resp_bizContent=" + resp_str);
        Map<String, String> encry = RSAUtils.encryptAndSign(resp_str, ZJPT_PUBLIC_KEY, HZHB_PRIVATE_KEY, "UTF-8", true, true);
        String resp_bizContent = encry.get("CONTENT");//密文
        System.out.println("加密后返回参数resp_bizContent=" + resp_bizContent);
        String resp_sign = encry.get("SIGNATURE");//签名，放在请求头中
        System.out.println("最终返回头中的签名resp_sign=" + resp_sign);

        Map<String, String> resp_Map = new HashMap<>();
        resp_Map.put("bizContent", resp_bizContent);
        String resp_Content = JSON.toJSONString(resp_Map);

        http_resp.setContentType("application/json;charset=utf-8");
        http_resp.addHeader("Accept", "application/json;charset=utf-8");
        http_resp.addHeader("Signature", resp_sign);
        http_resp.addHeader("PartnerCode", "p_taiyuantianqin");
        ServletOutputStream out = http_resp.getOutputStream();
        out.write(resp_Content.getBytes("UTF-8"));
        out.close();
    }

    private void geneErrorResponse(HttpServletResponse http_resp, ReqParamCBIT reqParam_cbit, String errorinfo) {
        try {
            CBITBaseparam baseParam = new CBITBaseparam();
            baseParam.setRequestNo(reqParam_cbit.getBaseParam().getRequestNo());
            ResponseCBIT resp = new ResponseCBIT("Z00004", errorinfo, baseParam);//Z00004	处理失败

            String resp_str = JSON.toJSONString(resp);
            System.out.println("加密前返回参数resp_bizContent=" + resp_str);
            Map<String, String> encry = RSAUtils.encryptAndSign(resp_str, ZJPT_PUBLIC_KEY, HZHB_PRIVATE_KEY, "UTF-8", true, true);
            String resp_bizContent = encry.get("CONTENT");//密文
            System.out.println("加密后返回参数resp_bizContent=" + resp_bizContent);
            String resp_sign = encry.get("SIGNATURE");//签名，放在请求头中
            System.out.println("最终返回头中的签名resp_sign=" + resp_sign);

            Map<String, String> resp_Map = new HashMap<>();
            resp_Map.put("bizContent", resp_bizContent);
            String resp_Content = JSON.toJSONString(resp_Map);

            http_resp.setContentType("application/json;charset=utf-8");
            http_resp.addHeader("Accept", "application/json;charset=utf-8");
            http_resp.addHeader("Signature", resp_sign);
            http_resp.addHeader("PartnerCode", "p_taiyuantianqin");
            ServletOutputStream out = http_resp.getOutputStream();
            out.write(resp_Content.getBytes("UTF-8"));
            out.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    @PostMapping(value = "/testCBIT")
    public void testjson() {
        HttpResult httpResult = null;
        System.out.println("--------------/testCBIT");
        String resp_json = environment.getProperty("resp_json");
        System.out.println("resp_json---" + resp_json);
        ObjectMapper objectMapper = new ObjectMapper();
        ObjectReader reader = objectMapper.readerFor(HttpResult.class);
        try {
            httpResult = reader.readValue(resp_json);
        } catch (IOException e) {
            httpResult = null;
            logger.error("反序列化失败", e);
        }
        if (httpResult == null) {
            logger.error("反序列化失败");
        }
        if (httpResult.getCode() != 200) {
            logger.error("返回错误，错误信息：" + httpResult.getMsg());
        } else {
            AuditRespData auditRespData = JSON.parseObject(JSON.toJSONString(httpResult.getData()), AuditRespData.class);
            System.out.println("111111111111111111");
        }
    }

    private void insertCbitError(@RequestBody ReqParamCBIT reqParam_cbit, String api_url, String errorinfo) {
        SysCbitError sysCbitError = new SysCbitError();
        sysCbitError.setReqno(reqParam_cbit.getBaseParam().getRequestNo());
        sysCbitError.setRequrl(api_url);
        sysCbitError.setReqparam(JSON.toJSONString(reqParam_cbit));
        sysCbitError.setErrorinfo(errorinfo);
        sysCbitErrorService.insert(sysCbitError);
    }

    private void insertCbitLog(String url, String req_desc, String reqno, String req_json, String resp_json) {
        SysCbitLog cbitLog = new SysCbitLog();
        cbitLog.setReqNo(reqno);
        cbitLog.setUsercode("");
//        cbitLog.setUsercode(SecurityUtils.getUsername());
        cbitLog.setReqUrl(url);
        cbitLog.setDescription(req_desc);
        cbitLog.setReqParam(req_json);
        cbitLog.setResponse(resp_json);
        cbitLog.setCreatetime(new Date());
        sysCbitLogService.insert(cbitLog);
    }
}