java-insagent-pc/src/main/java/com/ydtech/modules/nai/controller/ChinaCoalInterface.java

package com.ydtech.modules.nai.controller;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.ydtech.core.page.HttpResult;
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.esm.model.*;
import com.ydtech.modules.esm.service.*;
import com.ydtech.modules.ins.model.*;
import com.ydtech.modules.ins.service.*;
import com.ydtech.modules.ins.model.vo.KindInfoVo;
import com.ydtech.modules.ins.model.vo.QuoteKindRespVo;
import com.ydtech.modules.ins.model.vo.QuoteRespVo;
import com.ydtech.modules.ins.model.vo.QuoteRiskRespVo;
import com.ydtech.modules.nai.httpvo.*;
import com.ydtech.utils.HttpsPostUtil;
import com.ydtech.utils.idgen.IdGenerate;
import io.swagger.annotations.Api;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.env.Environment;
import org.springframework.util.StringUtils;
import org.springframework.web.bind.annotation.*;

import javax.servlet.http.HttpServletRequest;
import java.math.BigDecimal;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;

/**
 * @ClassName ChinaCoalInterface
 * @Description: TODO
 * @Author
 * @Date 2021/5/25
 **/
@RestController
@RequestMapping("zm")
@Api(tags = "中煤API对接")
public class ChinaCoalInterface {
    private static final Logger logger = LoggerFactory.getLogger(ChinaCoalInterface.class);

    @Autowired
    private InsTaskImageService InsTaskImageService;

    @Autowired
    Environment environment;

    @Autowired
    RenbaoService renbaoService;
    @Autowired
    InsOrderService insOrderService;
    @Autowired
    SysUserService sysUserService;
    @Autowired
    SysDeptService sysDeptService;
    @Autowired
    EsmAgreementService esmAgreementService;
    @Autowired
    EsmAgreementProdService esmAgreementProdService;
    @Autowired
    EsmRetailService esmRetailService;
    @Autowired
    EsmUserInternalService esmUserInternalService;
    @Autowired
    InsOrderTaskService insOrderTaskService;
    @Autowired
    InsTaskHistoryService insTaskHistoryService;
    @Autowired
    private InsFileLogService insFileLogService;
    @Autowired
    InsFeeDetailService insFeeDetailService;
    @Autowired
    EsmAgreementProdfeeService esmAgreementProdfeeService;
    @Autowired
    InsDeptFeeService insDeptFeeService;
    @Autowired
    InsCommissionService insCommissionService;

    /**
     * 车型查询接口
     *
     * @param record
     * @param request
     * @return
     */
    @PostMapping(value = "/ModelsQuery")
    public HttpResult ModelsQuery(@RequestBody ModelsQueryHeadVO record, HttpServletRequest request) {
        List<SimpleStadarCarVO> list = null;
        //获取请求方法名称
        String file = request.getRequestURI();
        String method = file.substring(file.lastIndexOf("/") + 1);
        //获取请求地址
        String zmUrl = environment.getProperty("ZMUrl");
        String url = zmUrl + method + ".do";
        logger.info("请求地址为:" + url);
        record.setModelName(record.getModelName());
        HeadVO head = head(method);
        head.setToken(environment.getProperty("ZMToken"));
        record.setHead(head);
        String json = JSON.toJSONString(record);
        logger.info("请求参数为:" + json);
        String post = HttpsPostUtil.sendPost(url, json);
        if (!StringUtils.isEmpty(post)) {
            JSONObject jsonObject = null;
            jsonObject = JSONObject.parseObject(post);
            Map<String, Object> map = jsonObject;
            String simpleStadarCar = map.get("simpleStadarCar").toString();
            list = JSONObject.parseArray(simpleStadarCar, SimpleStadarCarVO.class);
            logger.info("======车型查询接口返回为===============" + list);

        }
        return HttpResult.ok(list);

    }

    /**
     * 续保查询接口
     *
     * @param record
     * @param request
     * @return
     */
    @PostMapping(value = "/RenewalQuery")
    public HttpResult RenewalQuery(@RequestBody RenewalQueryHeadVO record, HttpServletRequest request) {

        //获取请求方法名称
        String file = request.getRequestURI();
        String method = file.substring(file.lastIndexOf("/") + 1);
        logger.info("最后一个/后的数据为：" + method);
        //获取请求地址
        String zmUrl = environment.getProperty("ZMUrl");
        logger.info("获取自定义属性路径为：" + environment.getProperty("ZMUrl"));
        String url = zmUrl + method + ".do";
        record.setProvince("140000");
        HeadVO head = head(method);
        head.setToken(environment.getProperty("ZMToken"));
        record.setHead(head);
        String json = JSON.toJSONString(record);
        logger.info("请求参数为:" + json);
        String post = HttpsPostUtil.sendPost(url, json);

        logger.info("==========续保查询接口返回===========" + post);
        return HttpResult.ok(post);
    }

    /**
     * 报价
     *
     * @param record
     * @param request
     * @return
     */
    @PostMapping(value = "/QuotedPrice")
    public HttpResult QuotedPrice(@RequestBody OfferVO record, HttpServletRequest request) {
        //获取请求方法名称
        String s1 = JSONObject.toJSONString(record);
        logger.info("中煤报价接口QuotedPrice请求参数为" + s1);
        SimpleDateFormat sdfm = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
        HttpResult httpResult = new HttpResult();
        QuotedPriceHeadVO recordHeadVO = new QuotedPriceHeadVO();
        PolicyLocationVO policyLocationVO = new PolicyLocationVO();
        BusinessDataVO businessDataVO = new BusinessDataVO();
        SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        Date date = null;
        String file = request.getRequestURI();
        String method = file.substring(file.lastIndexOf("/") + 1);
        //获取请求地址
        String zmUrl = environment.getProperty("ZMUrl");

        String url = zmUrl + method + ".do";
        logger.info("请求地址为:" + url);
        policyLocationVO.setCity("140400");
        policyLocationVO.setDistrict("140431");
        policyLocationVO.setProvince("140000");
        //参数组装
        ZMCarInfoVO carInfo = record.getCarInfo();
        List<ZMRiskListVO> riskList = record.getRiskList();
        PolicyCarVO policyCar = new PolicyCarVO();
        SimpleStadarCarVO simpleStadarCarVO = new SimpleStadarCarVO();
        InsuredObjectVO insuredObjectVO = new InsuredObjectVO();
        ModelsQueryHeadVO records = new ModelsQueryHeadVO();
        HeadVO shead = head("ModelsQuery");

        records.setModelCode(carInfo.getLocalModelCode());
        records.setModelName(carInfo.getBrandName());
        records.setHead(shead);
        String json = JSON.toJSONString(records);
        logger.info("请求参数为:" + json);
        logger.info("车型查询接口请求地址" + url);

        String post = HttpsPostUtil.sendPost(url, json);
        logger.info("车型查询接口返回为" + post);
        String sumPremium = null;
        String bizPremium = null;
        String coverageList = null;
        String renewal;
        if (!StringUtils.isEmpty(post)) {
            JSONObject jsonObject = null;
            jsonObject = JSONObject.parseObject(post);
            Map<String, Object> map = jsonObject;
            String simpleStadarCar = map.get("simpleStadarCar").toString();
            List<SimpleStadarCarVO> s = JSONObject.parseArray(simpleStadarCar, SimpleStadarCarVO.class);
            for (int i = 0; i < s.size(); i++) {
                simpleStadarCarVO.setLocalModelCode(s.get(i).getLocalModelCode());
                simpleStadarCarVO.setModelCode(s.get(i).getModelCode());
                simpleStadarCarVO.setApprovedLoad(s.get(i).getApprovedLoad());
                simpleStadarCarVO.setApprovedPassengersCapacity(s.get(i).getApprovedPassengersCapacity());//参数转换
                simpleStadarCarVO.setDisplacement(s.get(i).getDisplacement());//类型转换
                simpleStadarCarVO.setOriginalPurchasePrice(s.get(i).getOriginalPurchasePrice());//类型
                simpleStadarCarVO.setEnergyTypes(s.get(i).getEnergyTypes());
                simpleStadarCarVO.setBrand(s.get(i).getBrand());
                simpleStadarCarVO.setBrandCode(s.get(i).getBrandCode()); //
                simpleStadarCarVO.setSeries(s.get(i).getSeries());
                simpleStadarCarVO.setSeriesCode(s.get(i).getSeriesCode());//
                simpleStadarCarVO.setPower(s.get(i).getPower());//车牌号
                simpleStadarCarVO.setUnladenMass(s.get(i).getUnladenMass());//类型转换
                simpleStadarCarVO.setGrossMass(s.get(i).getGrossMass());//
                simpleStadarCarVO.setTractionMass(s.get(i).getTractionMass());//
                simpleStadarCarVO.setPurchasePrice(s.get(i).getPurchasePrice());

            }
        }
        //policyCar组装
        policyCar.setEngine(carInfo.getEngineNo());
        policyCar.setNewCarSign(carInfo.getNoLicenseFlag());
        policyCar.setPlateNo(carInfo.getLicenseNo());
        policyCar.setVIN(carInfo.getVinNo());
        policyCar.setEcdemicVehicleFlag(false);
        if (!Integer.toString(carInfo.getTransferFlag()).equals("")) {
            int transferFlag = carInfo.getTransferFlag();
            if (transferFlag == 1) {
                policyCar.setChgOwnerFlag("01");
                String transferDate = format.format(carInfo.getTransferDate()) + " 00:00:00";
                policyCar.setTransferDate(transferDate);

            } else {
                policyCar.setChgOwnerFlag(Integer.toString(carInfo.getTransferFlag()));
            }
        } else {
            policyCar.setChgOwnerFlag(Integer.toString(carInfo.getTransferFlag()));
        }

        String a = format.format(carInfo.getRegisterDate()) + " 00:00:00";
        policyCar.setRegisterDate(a);
        String c = format.format(carInfo.getIssueDate()) + " 00:00:00";

        policyCar.setIssueDate(c);//carInfo.getIssueDate()时间类型
        policyCar.setPlateType(carInfo.getLicenseTypeCode());
        policyCar.setCarUseType(carInfo.getCarnature());
        policyCar.setPlateColorCode("01");
        policyCar.setCarCheckStatus("2");

        //simpleStadarCar组装
        insuredObjectVO.setPolicyCar(policyCar);
        List list = new ArrayList();

        insuredObjectVO.setSimpleStadarCar(simpleStadarCarVO);
        CustomerVO customerVO = new CustomerVO();
        ZMOwnerInfoVO zmOwnerInfoVO = record.getOwnerInfo();
        ZMInsuredPersonInfoVO insuredPersonInfo = record.getInsuredPersonInfo();
        ZMPolicyHolderInfoVO policyHolderInfo = record.getPolicyHolderInfo();
        Map<String, String> map = new HashMap<String, String>();
        Map<String, String> map1 = new HashMap<String, String>();

        Map<String, String> map2 = new HashMap<String, String>();
        int quantity = 0;
        if (zmOwnerInfoVO != null) {
            map.put("name", zmOwnerInfoVO.getName());
            map.put("identifyType", zmOwnerInfoVO.getIdentifyType());
            map.put("mobile", zmOwnerInfoVO.getMobile());
            map.put("identifyNumber", zmOwnerInfoVO.getIdentifyNumber());
            map.put("addr", zmOwnerInfoVO.getAddr());
            map.put("role", "3");
            map.put("invocieType", "026");
            list.add(map);
        }
        if (policyHolderInfo != null) {
            map1.put("name", policyHolderInfo.getName());
            map1.put("identifyType", policyHolderInfo.getIdentifyType());
            map1.put("mobile", policyHolderInfo.getMobile());
            map1.put("identifyNumber", policyHolderInfo.getIdentifyNumber());
            map1.put("addr", policyHolderInfo.getAddr());
            map1.put("role", "1");
            map1.put("invocieType", "026");

            map1.put("identifyValidDate", "2008/1/1 00:00:00");
            map1.put("identifyValidEndDate", "2038/12/31 23:59:59");
            list.add(map1);
        }
        if (insuredPersonInfo != null) {

            map2.put("name", insuredPersonInfo.getName());
            map2.put("identifyType", insuredPersonInfo.getIdentifyType());
            map2.put("mobile", insuredPersonInfo.getMobile());
            map2.put("identifyNumber", insuredPersonInfo.getIdentifyNumber());
            map2.put("addr", insuredPersonInfo.getAddr());
            map2.put("role", "2");
            map2.put("invocieType", "026");
            list.add(map2);
        }
        InsOrder insOrder = new InsOrder();
        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.getById(record.getUserId());
        if (user == null) {
            httpResult.setMsg("userId不存在");
            return httpResult;
        }
        //
        if (org.springframework.util.StringUtils.isEmpty(record.getCarInfo().getFrameNo())) {
            httpResult.setMsg("车架号不能为空");
            return httpResult;
        }
        // 关闭订单 不含当前报价号
        InsOrder 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)) {
                httpResult.setMsg("此车辆已提交核保，重新报价请先关闭订单，任务号:" + orderObj.getQuoteno());
                return httpResult;
            }
        }

        insOrder.setUsername(user.getName());
        insOrder.setDeptid(user.getDeptId());
        SysDept dept = sysDeptService.getById(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());

        Map map4 = new HashMap();
        List lists = new ArrayList();
        List listt = new ArrayList();
        List list2 = new ArrayList();
        List list6 = new ArrayList();
        String startDate0510 = null;
        String endDate0510 = null;
        String endDate0507 = null;
        String startDate0507 = null;
        double unitAmounts = 0;
        for (int i = 0; i < riskList.size(); i++) {
            ContractVO contractVOx = new ContractVO();
            if (riskList.get(i).getRiskCode().equals("0510")) {
                List<KindInfoVo> kindList = record.getKindList();
                for (int j = 0; j < kindList.size(); j++) {

                    KindInfoVo kindInfoVo = kindList.get(j);
                    String deductibleRate = kindInfoVo.getDeductibleRate();
                    BigDecimal setScale = null;
                    if (deductibleRate != null) {
                        BigDecimal b1 = new BigDecimal(Double.parseDouble(deductibleRate));
                        BigDecimal b2 = b1.divide(new BigDecimal(-1d));
                        setScale = b2.setScale(4, 4);
                    }

                    //第三者责任险
                    if (kindList.get(j).getKindCode().equals("B")) {
                        Map mapsv = new HashMap();
                        mapsv.put("amount", (int) kindList.get(j).getAmount());
                        mapsv.put("unitAmount", 0);
                        mapsv.put("deductibleRate", setScale);
                        mapsv.put("deductible", "0.0");
                        mapsv.put("relatedInd", "1");
                        mapsv.put("kindCode", "02");
                        mapsv.put("kindName", kindList.get(j).getKindName());
                        lists.add(mapsv);

                    }

                    //乘客责任险
                    if (kindList.get(j).getKindCode().equals("D4")) {
                        Map mapsq = new HashMap();
                        mapsq.put("amount", (int) kindList.get(j).getUnitAmount() * (simpleStadarCarVO.getApprovedPassengersCapacity() - 1));
                        unitAmounts = kindList.get(j).getUnitAmount();
                        mapsq.put("unitAmount", kindList.get(j).getUnitAmount());
                        mapsq.put("deductibleRate", setScale);
                        quantity = simpleStadarCarVO.getApprovedPassengersCapacity();
                        mapsq.put("quantity", simpleStadarCarVO.getApprovedPassengersCapacity() - 1);
                        mapsq.put("relatedInd", "1");
                        mapsq.put("kindCode", "044");
                        mapsq.put("kindName", kindList.get(j).getKindName());
                        lists.add(mapsq);

                    }

                    //机动车损失险
                    if (kindList.get(j).getKindCode().equals("A")) {
                        Map mapsa = new HashMap();
                        mapsa.put("amount", 0);
                        mapsa.put("unitAmount", 0);
                        mapsa.put("deductibleRate", setScale);
                        mapsa.put("deductible", "0.0");
                        mapsa.put("relatedInd", "1");
                        mapsa.put("kindCode", "01");
                        mapsa.put("kindName", kindList.get(j).getKindName());
                        lists.add(mapsa);
                    }

                    //司机责任险
                    if (kindList.get(j).getKindCode().equals("D3")) {
                        Map mapsd = new HashMap();
                        mapsd.put("amount", (int) kindList.get(j).getAmount());
                        mapsd.put("unitAmount", kindList.get(j).getAmount());
                        mapsd.put("deductibleRate", setScale);
                        mapsd.put("quantity", "1");
                        mapsd.put("deductible", "0.0");
                        mapsd.put("relatedInd", "1");
                        mapsd.put("kindCode", "041");
                        mapsd.put("kindName", kindList.get(j).getKindName());
                        lists.add(mapsd);
                    }

                    if (kindList.get(j).getKindCode().equals("MJ1")) {
                        Map mapsd = new HashMap();
                        mapsd.put("amount", (int) kindList.get(j).getAmount());
                        mapsd.put("unitAmount", kindList.get(j).getAmount());
                        mapsd.put("deductibleRate", setScale);
                        mapsd.put("quantity", "1");
                        mapsd.put("deductible", "0.0");
                        mapsd.put("relatedInd", "1");
                        //附加绝对免赔率特约条款（车损）
                        mapsd.put("kindCode", "501");
                        mapsd.put("kindName", kindList.get(j).getKindName());
                        mapsd.put("deductibleRate", setScale);
                        lists.add(mapsd);
                    }

                    if (kindList.get(j).getKindCode().equals("MJ2")) {
                        Map mapsd = new HashMap();
                        mapsd.put("amount", (int) kindList.get(j).getAmount());
                        mapsd.put("unitAmount", kindList.get(j).getAmount());
                        mapsd.put("deductibleRate", setScale);
                        mapsd.put("quantity", "1");
                        mapsd.put("deductible", "0.0");
                        mapsd.put("relatedInd", "1");
                        mapsd.put("kindCode", "502");
                        mapsd.put("kindName", kindList.get(j).getKindName());
                        mapsd.put("deductibleRate", setScale);
                        lists.add(mapsd);
                    }

                    if (kindList.get(j).getKindCode().equals("MJ3")) {
                        Map mapsd = new HashMap();
                        mapsd.put("amount", (int) kindList.get(j).getAmount());
                        mapsd.put("unitAmount", kindList.get(j).getAmount());
                        mapsd.put("deductibleRate", setScale);
                        mapsd.put("quantity", "1");
                        mapsd.put("deductible", "0.0");
                        mapsd.put("relatedInd", "1");
                        mapsd.put("kindCode", "5041");
                        mapsd.put("kindName", kindList.get(j).getKindName());
                        mapsd.put("deductibleRate", setScale);
                        lists.add(mapsd);
                    }

                    if (kindList.get(j).getKindCode().equals("MJ4")) {
                        Map mapsd = new HashMap();
                        mapsd.put("amount", (int) kindList.get(j).getAmount());
                        mapsd.put("unitAmount", kindList.get(j).getAmount());
                        mapsd.put("deductibleRate", setScale);
                        mapsd.put("quantity", "1");
                        mapsd.put("deductible", "0.0");
                        mapsd.put("relatedInd", "1");
                        mapsd.put("deductibleRate", setScale);
                        mapsd.put("kindCode", "5044");
                        mapsd.put("kindName", kindList.get(j).getKindName());
                        lists.add(mapsd);
                    }

                    if (kindList.get(j).getKindCode().equals("L")) {
                        Map mapsd = new HashMap();
                        mapsd.put("amount", (int) kindList.get(j).getAmount());
                        mapsd.put("unitAmount", kindList.get(j).getAmount());
                        mapsd.put("deductibleRate", setScale);
                        mapsd.put("quantity", "1");
                        mapsd.put("deductible", "0.0");
                        mapsd.put("relatedInd", "1");
                        mapsd.put("deductibleRate", setScale);
                        mapsd.put("kindCode", "21");
                        mapsd.put("kindName", kindList.get(j).getKindName());
                        lists.add(mapsd);
                    }

                    if (kindList.get(j).getKindCode().equals("BD")) {
                        Map mapsd = new HashMap();
                        mapsd.put("amount", (int) kindList.get(j).getAmount());
                        mapsd.put("unitAmount", kindList.get(j).getAmount());
                        mapsd.put("deductibleRate", setScale);
                        mapsd.put("quantity", "1");
                        mapsd.put("deductible", "0.0");
                        mapsd.put("relatedInd", "1");
                        mapsd.put("deductibleRate", setScale);
                        mapsd.put("kindCode", "49");
                        mapsd.put("kindName", kindList.get(j).getKindName());
                        lists.add(mapsd);
                    }

                }
                ContractMainVO me = new ContractMainVO();

                try {
                    String endDate = riskList.get(i).getEndDate() + ":00";
                    String sdate = "00:00";
                    String substring = endDate.substring(endDate.length() - 5);

                    if (sdate.equals(substring)) {
                        date = format.parse(riskList.get(i).getEndDate() + ":00");
                        date.setTime(date.getTime() - 1000 + +1000 * 60 * 60 * 24 * 1);

                    } else {
                        date = format.parse(riskList.get(i).getEndDate() + ":00");
                        map4.put("ReinsuranceFlag", "1");

                    }
                } catch (ParseException e) {
                    e.printStackTrace();
                }
                me.setExpiryDate(df.format(date));
                me.setRiskCode("0361");
                startDate0510 = riskList.get(i).getStartDate() + ":00".toString();
                endDate0510 = riskList.get(i).getEndDate() + ":00".toString();
                me.setValidDate(riskList.get(i).getStartDate() + ":00".toString());

                map4.put("expiryDate", df.format(date));
                map4.put("riskCode", "0361");
                map4.put("validDate", riskList.get(i).getStartDate() + ":00");
                list2.add(map4);

                contractVOx.setContractMain(me);
                contractVOx.setCoverage(lists);

            }

            if (riskList.get(i).getRiskCode().equals("0507")) {


                ContractMainVO me = new ContractMainVO();
                try {
                    date = format.parse(riskList.get(i).getEndDate() + ":00");
                } catch (ParseException e) {
                    e.printStackTrace();
                }
                startDate0507 = riskList.get(i).getStartDate() + ":00";
                endDate0507 = riskList.get(i).getEndDate() + ":00";
                date.setTime(date.getTime() - 1000 + 1000 * 60 * 60 * 24 * 1);
                me.setExpiryDate(df.format(date));
                me.setRiskCode("0330");
                String startDate = riskList.get(i).getStartDate() + ":00";
                String endDate = riskList.get(i).getEndDate() + ":00";
                me.setValidDate(riskList.get(i).getStartDate() + ":00");

                Map mapwe = new HashMap();
                mapwe.put("amount", 2000);
                mapwe.put("kindCode", "BZ");
                mapwe.put("kindName", "机动车交通事故责任强制险");
                listt.add(mapwe);


                contractVOx.setCoverage(listt);
                contractVOx.setContractMain(me);

            }
            list6.add(contractVOx);

        }

        customerVO.setMobile(insuredPersonInfo.getMobile());
        customerVO.setName(insuredPersonInfo.getName());
        customerVO.setInsuredType(026);
        customerVO.setRole("3");
        insOrder.setInsuredname(record.getPolicyHolderInfo().getName());
        HeadVO heads = head(method);
        businessDataVO.setCustomer(list);
        businessDataVO.setInsuredObject(insuredObjectVO);
        businessDataVO.setPolicyLocation(policyLocationVO);

        businessDataVO.setContract(list6);

        recordHeadVO.setHead(heads);
        recordHeadVO.setBusinessData(businessDataVO);
        String json1 = JSON.toJSONString(recordHeadVO);
        logger.info("报价接口请求参数为:" + json1);
        String posts = HttpsPostUtil.sendPost(url, json1);
        logger.info("报价接口返回参数为:" + posts);
        HeadMessage headMessage = null;
        String returnMessage = null;
        String returnCode = null;
        if (posts != null && !posts.equals("")) {
            headMessage = HttpsPostUtil.HeadMessage(posts);
            returnMessage = headMessage.getReturnMessage();
            returnCode = headMessage.getReturnCode();
        }

        Double Vehicle = null;

        //保存订单信息

        if (returnCode != null && returnCode.equals("0")) {


            List<ZMRiskListVO> risks = record.getRiskList();
            for (ZMRiskListVO 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());
                }
            }
//        insOrder.setJqstartdate("");
//        insOrder.setJqenddate("");
//        insOrder.setSystartdate("");
//        insOrder.setSyenddate("");

//        ZG01001	单交强
//        ZG01002	单三者
//        ZG01003	单商业
//        ZG01004	交强+三者  交强+三者  （交强的费用）
//        ZG01005	交强+三者  交强+三者（三者的费用）
//        ZG01006	交强+商业  交强+商业（交强的费用）
//        ZG01007	交强+商业  交强+商业（商业的费用）
            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[]{"000019%", "%" + user.getDeptId() + "%"});
            if (agreements.size() == 0) {
                httpResult.setMsg("不存在有效协议或机构" + user.getDeptId() + "未授权");
                return httpResult;
            }
            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())));

            insOrder.setInscompany("中煤财险");
            insOrder.setCreatetime(sdfm.format(new Date()));

            List<QuoteKindRespVo> quoteKindRespVos = new ArrayList<>();
            QuoteRespVo quoteRespVo = new QuoteRespVo();
            QuoteRiskRespVo riskLists = new QuoteRiskRespVo();
            QuoteKindRespVo kindList = new QuoteKindRespVo();

            JSONObject jsonObject = JSONObject.parseObject(posts);
            Map<String, Object> maps = jsonObject;
            String payTax = null;
            String sumPayTax = null;
            String taxinfo = null;
            Object s = maps.get("taxinfo");
            if (s != null) {
                taxinfo = maps.get("taxinfo").toString();
            }
            if (taxinfo != null) {
                jsonObject = JSONObject.parseObject(taxinfo);
                Map<String, Object> mapssx = jsonObject;
                sumPayTax = mapssx.get("sumPayTax").toString();
                if (!StringUtils.isEmpty(mapssx.get("payTax").toString())) {
                    payTax = mapssx.get("payTax").toString();
                }
            }


            Object t = maps.get("bizPremium");
            if (t != null) {
                bizPremium = maps.get("bizPremium").toString();
            }

            if (bizPremium != null) {
                jsonObject = JSONObject.parseObject(bizPremium);
                Map<String, Object> mapsss = jsonObject;
                sumPremium = mapsss.get("sumPremium").toString();
                jsonObject = JSONObject.parseObject(bizPremium);
                Map<String, Object> mapssss = jsonObject;
                coverageList = mapssss.get("coverageList").toString();
//                renewal = mapssss.get("isRenewal").toString();
                riskLists.setPremium(Double.parseDouble(sumPremium));
            }


            String forcePrimium = null;
            Object z = maps.get("forcePrimium");
            String premium = null;
            String amount = null;
            if (z != null) {
                forcePrimium = maps.get("forcePrimium").toString();

                jsonObject = JSONObject.parseObject(forcePrimium);

                Map<String, Object> mapsx = jsonObject;

                premium = mapsx.get("premium").toString();
                Vehicle = Double.parseDouble(premium);
                amount = mapsx.get("amount").toString();
            }
            List listz = new ArrayList();

            JSONArray jsonArraysss;

            quoteKindRespVos.add(kindList);
            if (sumPayTax != null) {
                quoteRespVo.setTaxAmount(Double.parseDouble(sumPayTax));
            }
            if (premium != null) {
                kindList.setCoveragePremium(Double.parseDouble(premium));
            }
            quoteRespVo.setKindList(quoteKindRespVos);

            List<QuoteRiskRespVo> riskList1 = new ArrayList<>();
            QuoteRiskRespVo risk = new QuoteRiskRespVo();

            if (forcePrimium != null) {
                risk.setRiskCode("0507");
                risk.setRiskName("机动车交通事故责任强制保险");

                risk.setPremium(Double.parseDouble(premium));
                Double premium2 = Double.parseDouble(premium);
                risk.setAmount(Double.parseDouble(amount));
                risk.setStartDate(startDate0507);
                risk.setEndDate(endDate0507);
                riskList1.add(risk);
            }
            double syPremium = 0;
            if (bizPremium != null && !bizPremium.equals("")) {
                risk = new QuoteRiskRespVo();
                risk.setRiskCode("0510");
                risk.setRiskName("机动车商业保险");

                BigDecimal bd = new BigDecimal(sumPremium);
                bd = bd.setScale(2, BigDecimal.ROUND_HALF_UP);
                syPremium = bd.doubleValue();
                risk.setPremium(syPremium);
                risk.setStartDate(startDate0510);
                risk.setEndDate(endDate0510);
                riskList1.add(risk);
            }

            List<QuoteKindRespVo> kindList1 = new ArrayList<>();
            if (JSONObject.parseArray(coverageList) != null) {
                jsonArraysss = JSONObject.parseArray(coverageList);

                for (int i = 0; i < jsonArraysss.size(); i++) {
                    JSONObject object = jsonArraysss.getJSONObject(i);
                    listz.add(premium);


                }
                for (int i = 0; i < jsonArraysss.size(); i++) {
                    JSONObject obj = jsonArraysss.getJSONObject(i);
                    String kindcode = obj.getString("kindCode");
                    QuoteKindRespVo kind = null;
                    if ("01".equals(obj.getString("kindCode"))) {
                        kind = new QuoteKindRespVo();
                        kind.setKindCode("A");
                        kind.setKindName("车辆损失保险");
                        kind.setAmount(obj.getDouble("amount"));
                        kind.setCoveragePremium(obj.getDouble("premium"));
                        kindList1.add(kind);
                    }
                    if ("02".equals(obj.getString("kindCode"))) {
                        kind = new QuoteKindRespVo();
                        kind.setKindCode("B");
                        kind.setKindName("第三者责任险");
                        kind.setAmount(obj.getDouble("amount"));
                        kind.setCoveragePremium(obj.getDouble("premium"));
                        kindList1.add(kind);
                    }
                    if ("041".equals(obj.getString("kindCode"))) {
                        kind = new QuoteKindRespVo();
                        kind.setKindCode("D3");
                        kind.setKindName("司机责任险");
                        kind.setAmount(obj.getDouble("amount"));
                        kind.setCoveragePremium(obj.getDouble("premium"));
                        kind.setUnitAmount(obj.getDouble("amount"));
                        kindList1.add(kind);
                    }
                    if ("044".equals(obj.getString("kindCode"))) {
                        kind = new QuoteKindRespVo();
                        kind.setKindCode("D4");
                        kind.setKindName("乘客责任险");
                        kind.setUnitAmount(unitAmounts);
                        kind.setAmount(obj.getDouble("amount"));
                        kind.setCoveragePremium(obj.getDouble("premium"));
                        kind.setQuantity(String.valueOf(quantity - 1));
                        // kind.setUnitAmount(obj.getDouble("unitAmount"));
                        kindList1.add(kind);
                    }
                    if ("501".equals(obj.getString("kindCode"))) {
                        kind = new QuoteKindRespVo();
                        kind.setKindCode("MJ1");
                        kind.setKindName("绝对免赔率特约险(车损)");
                        kind.setAmount(obj.getDouble("amount"));
                        kind.setCoveragePremium(obj.getDouble("premium"));
                        kindList1.add(kind);
                    }
                    if ("502".equals(obj.getString("kindCode"))) {
                        kind = new QuoteKindRespVo();
                        kind.setKindCode("MJ2");
                        kind.setKindName("绝对免赔率特约险(三者)");
                        kind.setAmount(obj.getDouble("amount"));
                        kind.setCoveragePremium(obj.getDouble("premium"));
                        kindList1.add(kind);
                    }
                    if ("5041".equals(obj.getString("kindCode"))) {
                        kind = new QuoteKindRespVo();
                        kind.setKindCode("MJ3");
                        kind.setKindName("绝对免赔率特约险(司机)");
                        kind.setAmount(obj.getDouble("amount"));
                        kind.setCoveragePremium(obj.getDouble("premium"));
                        kindList1.add(kind);
                    }
                    if ("5044".equals(obj.getString("kindCode"))) {
                        kind = new QuoteKindRespVo();
                        kind.setKindCode("MJ4");
                        kind.setKindName("绝对免赔率特约险(乘客)");
                        kind.setAmount(obj.getDouble("amount"));
                        kind.setCoveragePremium(obj.getDouble("premium"));
                        kindList1.add(kind);
                    }
                    if ("21".equals(obj.getString("kindCode"))) {
                        kind = new QuoteKindRespVo();
                        kind.setKindCode("L");
                        kind.setKindName("车身划痕损失险");
                        kind.setAmount(obj.getDouble("amount"));
                        kind.setCoveragePremium(obj.getDouble("premium"));
                        kindList1.add(kind);
                    }
                    if ("49".equals(obj.getString("kindCode"))) {
                        kind = new QuoteKindRespVo();
                        kind.setKindCode("BD");
                        kind.setKindName("法定节假日限额翻倍险");
                        kind.setAmount(obj.getDouble("amount"));
                        kind.setCoveragePremium(obj.getDouble("premium"));
                        kindList1.add(kind);
                    }
                }
            }


            //贴过来的
            if (premium != null) {
                BigDecimal sumPremium2 = new BigDecimal(premium);
                sumPremium2 = sumPremium2.setScale(2, BigDecimal.ROUND_HALF_UP);
                BigDecimal jqpremium = new BigDecimal(sumPremium2.doubleValue() + Double.parseDouble(payTax));
                jqpremium = jqpremium.setScale(2, BigDecimal.ROUND_HALF_UP);
                quoteRespVo.setCiSumPermium(jqpremium.doubleValue());  //交强险和车船税合计

            }

            if (premium != null && !premium.equals("") && sumPremium != null && !sumPremium.equals("") && sumPayTax != null && !sumPayTax.equals("")) {
                BigDecimal jqpremium = new BigDecimal(Double.parseDouble(premium) + Double.parseDouble(sumPremium) + Double.parseDouble(sumPayTax));
                jqpremium = jqpremium.setScale(2, BigDecimal.ROUND_HALF_UP);
                quoteRespVo.setSumPermium(jqpremium.doubleValue());  //交强+商业+车船总和
            } else if (premium != null && !premium.equals("") && sumPremium != null && !sumPremium.equals("")) {
                BigDecimal jqpremium = new BigDecimal(Double.parseDouble(premium) + Double.parseDouble(sumPremium));
                jqpremium = jqpremium.setScale(2, BigDecimal.ROUND_HALF_UP);
                quoteRespVo.setSumPermium(jqpremium.doubleValue());//交强+商业+车船总和

            } else if (premium != null && !premium.equals("") && sumPayTax != null && !sumPayTax.equals("")) {
                BigDecimal jqpremium = new BigDecimal(Double.parseDouble(premium) + Double.parseDouble(sumPayTax));
                jqpremium = jqpremium.setScale(2, BigDecimal.ROUND_HALF_UP);
                quoteRespVo.setSumPermium(jqpremium.doubleValue());//交强+商业+车船总和

            } else if (sumPremium != null && !sumPremium.equals("")) {
                BigDecimal jqpremium = new BigDecimal(Double.parseDouble(sumPremium));
                jqpremium = jqpremium.setScale(2, BigDecimal.ROUND_HALF_UP);

                quoteRespVo.setSumPermium(jqpremium.doubleValue());
            }
            quoteRespVo.setTotalAdjustRate(1);
            if (payTax != null) {
                quoteRespVo.setTaxAmount(Double.parseDouble(payTax));

            }
            quoteRespVo.setILogPreUdwMess("0");//评分
            quoteRespVo.setOrderno(orderno); //订单号
            quoteRespVo.setRiskList(riskList1);
            quoteRespVo.setKindList(kindList1);

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

            //报价成功更新险种信息
            insOrder.setRiskinfo(JSONObject.parseArray(JSONObject.toJSONString(riskList1)));
            insOrder.setKindinfo(JSONObject.parseArray(JSONObject.toJSONString(kindList1)));
            if (Vehicle != null) {
                BigDecimal Vehiclemium = new BigDecimal(Vehicle);
                Vehiclemium = Vehiclemium.setScale(2, BigDecimal.ROUND_HALF_UP);
                insOrder.setJqpremium(Vehiclemium.doubleValue());
            }
            if (premium != null) {
                syPremium = syPremium - Double.parseDouble(premium);
                BigDecimal bd = new BigDecimal(syPremium);
                bd = bd.setScale(2, BigDecimal.ROUND_HALF_UP);
                syPremium = bd.doubleValue();
                insOrder.setSypremium(syPremium);
            }

            if (sumPayTax != null) {
                insOrder.setTaxamount(Double.parseDouble(sumPayTax));
            }
            BigDecimal bd = new BigDecimal(quoteRespVo.getSumPermium());
            bd = bd.setScale(2, BigDecimal.ROUND_HALF_UP);
            insOrder.setSumpremium(bd.doubleValue());
            //报价状态 0失败 1成功

            httpResult.setCode(200);
            httpResult.setMsg(returnMessage);

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

            insOrder.setSypremium(bd1.doubleValue());
            insOrder.setQuotestatus("1");
            insOrder.setReqtxt(JSONObject.parseObject(json1));
            insOrder.setReptxt(JSONObject.parseObject(posts));
            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);
        } else {
            httpResult.setCode(200);
            httpResult.setMsg(returnMessage);
            insOrder.setQuotestatus("0");  //报价状态 0失败 1成功
        }
        return httpResult;


    }

    /**
     * 提交核保
     *
     * @param request
     * @return
     */
//    @GetMapping(value = "/Submit")
    public HttpResult Submit(@RequestParam String orderno, @RequestParam String jqappoint, @RequestParam String syappoint, HttpServletRequest request) {
        SubmitHeadVO record = new SubmitHeadVO();
        DeliveryInfoVO deliveryInfo = new DeliveryInfoVO();
        //查询订单
        InsOrder order = insOrderService.selectZMByPk(orderno);
        if (order != null) {

            //获取请求方法名称
            String file = request.getRequestURI();
            String method = file.substring(file.lastIndexOf("/") + 1);
            //获取请求地址
            String zmUrl = environment.getProperty("ZMUrl");
            String url = zmUrl + method + ".do";
            record.setOrderNo("140000");
            JSONObject reptxt = order.getReptxt();
            Map<String, Object> reptxtmap = reptxt;
            JSONObject reqtxt = order.getReqtxt();
            Map<String, Object> reqtxtmap = reqtxt;
//            Object ownerInfo = order.getOwnerinfo();
            JSONObject ownerInfoObject = order.getOwnerinfo();

            Object orderNo = reptxtmap.get("orderNo");
            Object vin = reptxtmap.get("vin");

            record.setOrderNo(orderNo.toString());
            record.setVIN(vin.toString());
            deliveryInfo.setName(ownerInfoObject.get("name").toString());
            deliveryInfo.setMobile(ownerInfoObject.get("mobile").toString());
            deliveryInfo.setProvince("140000");
            deliveryInfo.setCity("140400");
            deliveryInfo.setDistrict("140431");
            deliveryInfo.setDetail(ownerInfoObject.get("addr").toString());
            record.setPageUrl("http://www.baidu.com");
            record.setCallbackUrl(environment.getProperty("CallbackUrl"));
            record.setPassMsgUrl(environment.getProperty("RGCallbackUrl"));

            record.setBusSrePcMAC("12-E1-AD-45-A2-65");
            record.setBusSrePcIP("47.92.254.66");

            //参数组装
            HeadVO head = head(method);
            head.setToken(environment.getProperty("ZMToken"));
            record.setHead(head);
            record.setDeliveryInfo(deliveryInfo);
            String json = JSON.toJSONString(record);
            logger.info("核保接口请求参数为:" + json);
            String post = HttpsPostUtil.sendPost(url, json);
            logger.info("核保接口返回参数为:" + post);
            HeadMessage headMessage = HttpsPostUtil.HeadMessage(post);
            String returnMessage = headMessage.getReturnMessage();
            String returnCode = headMessage.getReturnCode();

            if (returnCode != null) {

                order.setOrderstatus("1");
                SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                order.setSubmittime(sdf.format(new Date()));
                order.setJqappoint(jqappoint); //交强特别约定
                order.setSyappoint(syappoint); //商业特别约定

                order.setJqapplyno(JSONObject.parseObject(post).getString("proposalNo")); //主投保单号
                //匹配任务接收人
                String licenseno = order.getLicenseNo().substring(0, 2);
                List<InsOrderTask> list = insOrderTaskService.selectList(" where t.status='1' and t.insname=? and t.licenseno=? and t.orderstatus=?", new Object[]{order.getInscompany(), licenseno, "1"});
                if (list.size() > 0) {
                    order.setAuditid(list.get(0).getAuditid());
                    order.setAuditname(list.get(0).getAuditname());
                }

                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);

                return HttpResult.ok(returnMessage);
            } else {
                return HttpResult.error(returnMessage);
            }
        }

        return HttpResult.ok("提交成功");

    }

    /**
     * 缴费查询接口
     *
     * @param record
     * @param request
     * @return
     */
    @PostMapping(value = "/OrderStatus")
    public HttpResult OrderStatus(@RequestBody OrderStatusHeadVO record, HttpServletRequest request) {
        String file = request.getRequestURI();
        String method = file.substring(file.lastIndexOf("/") + 1);
        String zmUrl = environment.getProperty("ZMUrl");
        String url = zmUrl + method + ".do";
        InsOrder order = insOrderService.selectZMByPk(record.getOrderNo());
        JSONObject reptxt = order.getReptxt();
        Map<String, Object> reptxtmap = reptxt;
        Object orderNo = reptxtmap.get("orderNo");
        record.setOrderNo(orderNo.toString());
        HeadVO head = head(method);
        head.setToken(environment.getProperty("ZMToken"));
        record.setHead(head);
        String json = JSON.toJSONString(record);
        String post = HttpsPostUtil.sendPost(url, json);

        return HttpResult.ok(post);

    }

    /**
     * 核保状态查询
     *
     * @param record
     * @param request
     * @return
     */
    @PostMapping(value = "/SubmitStatusQuery")
    public HttpResult SubmitStatusQuery(@RequestBody SubmitStatusQueryHeadVO record, HttpServletRequest request) {
        String file = request.getRequestURI();
        String method = file.substring(file.lastIndexOf("/") + 1);

        String zmUrl = environment.getProperty("ZMUrl");

        String url = zmUrl + "SubmitStatus" + ".do";

//        InsOrder order = insOrderService.selectZMByPk(record.getOrderNo());
//        JSONObject reptxt = order.getReptxt();
//        Map<String, Object> reptxtmap = reptxt;
//        Object orderNo = reptxtmap.get("orderNo");
//        record.setOrderNo(orderNo.toString());

        PayinfoVO payinfo = insOrderService.selectPayinfo(" where orderno=?", new Object[]{record.getOrderNo()});

        record.setProposalNo(payinfo.getPolicyNo()); //主投保单号
        HeadVO head = head(method);
        head.setToken(environment.getProperty("ZMToken"));
        record.setHead(head);
        String json = JSON.toJSONString(record);
        logger.info("核保状态查询请求参数为:" + json);
        String post = HttpsPostUtil.sendPost(url, json);
        logger.info("核保状态查询返回结果为:" + post);

        JSONObject obj = JSONObject.parseObject(post);
        payinfo.setReptxt(obj);
        insOrderService.updatePayinfo(payinfo);
        return HttpResult.ok(obj.getString("underWriteInd"), obj.getString("payUrl"));

    }

    /**
     * 电子保单下载
     *
     * @param dirId
     * @param request
     * @return
     */
    @GetMapping(value = "/InsurancePolicyPrint")
    public HttpResult InsurancePolicyPrint(@RequestParam("dirId") String dirId, HttpServletRequest request) {
        InsurancePolicyPrintHeadVO record = new InsurancePolicyPrintHeadVO();
        String file = request.getRequestURI();
        String method = file.substring(file.lastIndexOf("/") + 1);

        String zmUrl = environment.getProperty("ZMUrl");

        String url = zmUrl + method + ".do";

        InsOrder order = insOrderService.selectZMByPk(dirId);
        JSONObject reptxt = order.getReptxt();
        JSONObject reqtxt = order.getReqtxt();
        Map<String, Object> reptxtmap = reptxt;

        Object forcePrimium = reptxtmap.get("forcePrimium");
        String kindName = null;
        JSONObject jsonObject = JSONObject.parseObject(forcePrimium.toString());
        if (jsonObject != null) {
            kindName = jsonObject.get("kindName").toString();
        }
        record.setPolicyNo(reptxtmap.get("orderNo").toString());
        HeadVO head = head(method);
        head.setToken(environment.getProperty("ZMToken"));
        record.setHead(head);
        String json = JSON.toJSONString(record);
        String post = HttpsPostUtil.sendPost(url, json);
        return HttpResult.ok(post);

    }

    /**
     * 影像上传
     *
     * @param record
     * @param request
     * @return
     */
    @PostMapping(value = "/UploadImage")
    public HttpResult UploadImage(@RequestBody InsTaskImage record, HttpServletRequest request) {
        Integer result = 0;
        String msg = "保存成功";
        NodeBeanlistVO nodeBean = new NodeBeanlistVO();
        List<NodeBeanlistVO> nodeBeanList = new ArrayList();
        UploadImageHeadVO uploadHead = new UploadImageHeadVO();
        ImageBeanListVO imgVO = new ImageBeanListVO();
        List<ImageBeanListVO> imageBeanList = new ArrayList<>();

        List list = new ArrayList();
        if (record.getTaskid() == null || record.getTaskid().equalsIgnoreCase("")) {
            return HttpResult.ok("任务号taskid不能为空", result);
        }
        if (record.getImgtype() == null || record.getImgtype().equalsIgnoreCase("")) {
            return HttpResult.ok("图片类型imgtype不能为空", result);
        }

        if (record.getImgList() == null || record.getImgList().size() == 0) {
            return HttpResult.ok("图片列表imgList不能为空", result);
        }

        InsTaskImageService.delete(record.getTaskid(), record.getImgtype());

        for (String image : record.getImgList()) {
            List imgList = new ArrayList();

            record.setId(IdGenerate.nextId());
            nodeBean.setId(record.getId());
            record.setCreator(getUserName());
            imgVO.setFileName(record.getCreator());

            record.setCreatetime(new Date());
            record.setImage(image);
            imgVO.setImage(record.getImage());
            if (record.getImgtype() != null && record.getImgtype().equals("C01")) {
                nodeBean.setId("UW_0305");
            } else if (record.getImgtype() != null && record.getImgtype().equals("C03")) {
                nodeBean.setId("UW_0302");
            } else if (record.getImgtype() != null && record.getImgtype().equals("C05")) {
                nodeBean.setId("UW_0301");
            }
            imgList.add(imgVO);
            nodeBean.setImageBeanList(imgList);
            //imageBeanList.add(imgVO);

            nodeBeanList.add(nodeBean);
            //  list.add(imageBeanList);

            InsTaskImageService.insert(record);

        }

        String file = request.getRequestURI();
        String method = file.substring(file.lastIndexOf("/") + 1);
        String zmUrl = environment.getProperty("ZMIMGUrl");
        String url = zmUrl + method + ".do";
        PayinfoVO payinfo = insOrderService.selectPayinfo(" where orderno=?", new Object[]{record.getTaskid()});

        if (payinfo == null) {
            return HttpResult.error("请先提交核保！");
        }
        HeadVO heads = head(method);
        heads.setToken(environment.getProperty("ZMToken"));
        uploadHead.setHead(heads);
        uploadHead.setNodeBeanlist(nodeBeanList);
        uploadHead.setContractNo(payinfo.getPolicyNo());
        String jsons = JSON.toJSONString(uploadHead);
        String posts = HttpsPostUtil.sendPost(url, jsons);

        return HttpResult.ok(posts);

    }

    /**
     * 校验发短信接口
     *
     * @param record
     * @param request
     * @return
     */
    @PostMapping(value = "/CheckSMScode")
    public HttpResult CheckSMScode(@RequestBody CheckSMScodeHeadVO record, HttpServletRequest request) {
        String file = request.getRequestURI();
        String method = file.substring(file.lastIndexOf("/") + 1);
        String zmUrl = environment.getProperty("ZMSMSUrl");
        String url = zmUrl + method + ".do";

        //参数组装


        HeadVO head = head(method);
        head.setToken(environment.getProperty("ZMToken"));
        record.setHead(head);
        String json = JSON.toJSONString(record);
        String post = HttpsPostUtil.sendPost(url, json);

        return HttpResult.ok(post);

    }

    /**
     * 验证校验码正确
     *
     * @param record
     * @param request
     * @return
     */
    @PostMapping(value = "/ValidSMScode")
    public HttpResult ValidSMScode(@RequestBody ValidSMScodeHeadVO record, HttpServletRequest request) {
        String file = request.getRequestURI();
        String method = file.substring(file.lastIndexOf("/") + 1);

        String zmUrl = environment.getProperty("ZMSMSUrl");

        String url = zmUrl + method + ".do";


        //参数组装


        HeadVO head = head(method);
        head.setToken(environment.getProperty("ZMToken"));
        record.setHead(head);
        String json = JSON.toJSONString(record);
        String post = HttpsPostUtil.sendPost(url, json);


        return HttpResult.ok(post);

    }


    /**
     * 分销费用统计
     *
     * @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;
    }

    public String getUserName() {

        return "";
//        String userName = null;
//        Object principal = SecurityContextHolder.getContext().getAuthentication().getPrincipal();
//
//        if (principal instanceof UserDetails) {
//            userName = ((UserDetails) principal).getUsername();
//        } else {
//            userName = principal.toString();
//        }
//        return userName;
    }

    /**
     * 承保回调
     *
     * @param record
     * @param request
     * @return
     */
    @PostMapping(value = "/Underwriting")
    public HeadMessage Underwriting(@RequestBody UnderwritingVO record, HttpServletRequest request) {
        logger.info("回调Underwriting接口" + record.toString());
        String studentJson = JSON.toJSONString(record);//将对象转json
        logger.info("回调Underwriting接口" + studentJson);
        JSONObject jsonObject = JSONObject.parseObject(studentJson);
        Map map = jsonObject;
        StringBuffer whereStr = new StringBuffer(" where 1=1");
        ArrayList array = new ArrayList();

        if (map.get("bizProposalNo") != null && !map.get("bizProposalNo").equals("")) {
            String bizPolicyNo = map.get("bizPolicyNo").toString();

            String bizProposalNo = map.get("bizProposalNo").toString();//商业险投保单号
            whereStr.append(" and syapplyno=?");
            array.add(bizProposalNo);
        } else {
            String forceProposalNo = map.get("forceProposalNo").toString();//交强险投保单号
            String forcePolicyNo = map.get("forcePolicyNo").toString();

            whereStr.append(" and  jqapplyno=?");
            array.add(forceProposalNo);
        }


        String proposalNo = map.get("proposalNo").toString();
        HeadVO heads = record.getHead();
        String status = map.get("status").toString();

        HeadMessage headmess = new HeadMessage();
        if (status != null && !status.equals("")) {

            InsOrder order = insOrderService.selectSyapplyno(whereStr.toString(), array.toArray());
            logger.info("通过保单号查询" + proposalNo);
            if (order != null && !order.equals("")) {

                if (record.getBizPolicyNo() != null) {
                    order.setSypolicyno(record.getBizPolicyNo());
                }
                if (record.getForcePolicyNo() != null) {
                    order.setJqpolicyno(record.getForcePolicyNo());
                }
                if (record.getBizProposalNo() != null) {
                    order.setSyapplyno(record.getBizProposalNo());
                }
                if (record.getForceProposalNo() != null) {
                    order.setJqapplyno(record.getForceProposalNo());
                }
                String orders = JSON.toJSONString(order);//将对象转json
                logger.info("修改参数" + orders);
                order.setOrderstatus("6");
                SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                order.setPaytime(sdf.format(new Date()));
                //  saveFeeDetail(order);
                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.getAuditid());
                history.setOperator(order.getAuditname());
                history.setCreatetime(sdf.format(new Date()));
                history.setStatus("6");
                history.setRemark("已缴费待配送");
                insTaskHistoryService.insert(history);
            }
        } else {
            headmess.setReturnMessage("-1");
            HttpResult.error("失败");
        }

        headmess.setReturnMessage("0");

        return headmess;
    }

    /**
     * 人工核保承保回调
     *
     * @param record
     * @param request
     * @return
     */
    @PostMapping(value = "/ArtificialUnderwriting")
    public HeadMessage ArtificialUnderwriting(@RequestBody ArtificialVO record, HttpServletRequest request) {
        HeadMessage headmess = new HeadMessage();
        String rep = JSON.toJSONString(record);//将对象转json
        logger.info("人工核保回调接入参" + rep);
        JSONObject reptext = JSONObject.parseObject(rep);
        StringBuffer whereStr = new StringBuffer(" where 1=1");
        ArrayList array = new ArrayList();
        //插入轨迹表
        InsTaskHistory history = new InsTaskHistory();
        if (record.getContractNo() != null && !record.getContractNo().equals("")) {
            String contractNo = record.getContractNo();
            whereStr.append(" and  policyNo=? ");
            array.add(contractNo);
        }
        PayinfoVO payinfo = insOrderService.selectPayinfo(whereStr.toString(), array.toArray());
        logger.info("人工核保回调接查询到的信息" + JSON.toJSONString(payinfo));


        if (payinfo != null && !payinfo.equals("")) {
            InsOrder order = insOrderService.selectByPk(payinfo.getOrderno());
            JSONObject reptxt = payinfo.getReptxt();

            Map<String, Object> reptxtmap = reptxt;
            reptxtmap.put("payUrl", record.getPayUrl());
            payinfo.setReptxt(JSONObject.parseObject(reptxtmap.toString()));

        } else {
            headmess.setReturnMessage("FAILD");
            return headmess;
        }

        String statusCode = record.getStatusCode();


        if (statusCode != null && !statusCode.equals("")) {
            InsOrder order = insOrderService.selectSyapplyno(" where orderno=? ", new Object[]{payinfo.getOrderno()});

            logger.info("人工核保订单号查询" + order.getOrderno());
            if (record.getStatusCode() != null && record.getStatusCode().equals("1")) {
                insOrderService.updatePayinfo(payinfo);

                if (record.getProposalNoS() != null) {
                    order.setSypolicyno(record.getProposalNoS());
                }
                if (record.getProposalNoJ() != null) {
                    order.setJqpolicyno(record.getProposalNoJ());
                }
                order.setOrderstatus("5");
                history.setStatus("5");
                history.setRemark("已核保待缴费");
            } else if (record.getStatusCode() != null && record.getStatusCode().equals("2")) {
                order.setOrderstatus("1");
                history.setStatus("1");
                history.setRemark("待核保");
            } else if (record.getStatusCode() != null && record.getStatusCode().equals("4")) {
                order.setOrderstatus("99");
                history.setStatus("99");
                history.setRemark("拒保");
            }

            String orders = JSON.toJSONString(order);//将对象转json
            logger.info("修改参数" + orders);

            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            order.setPaytime(sdf.format(new Date()));
            insOrderService.update(order);

            history.setId(String.valueOf(new Date().getTime()));
            history.setCompany(order.getInscompany());
            history.setTaskid(order.getOrderno());
            history.setOperatorid(order.getAuditid());
            history.setOperator(order.getAuditname());
            history.setCreatetime(sdf.format(new Date()));


            insTaskHistoryService.insert(history);


        } else {
            headmess.setReturnMessage("-1");
            HttpResult.error("失败");
        }

        headmess.setReturnMessage("OK");

        return headmess;
    }

    public HeadVO head(String methodName) {

        HeadVO headVO = new HeadVO();
        headVO.setTransCode(methodName);
        headVO.setTransType("Req");

        //测试
//        headVO.setToken("THIRDSCOuloft2020052818346904zmYBSX");
        //生产
        headVO.setToken(environment.getProperty("ZMToken"));
        headVO.setSource("326");

        return headVO;
    }

}