package com.ruoyi.project.tr.riskEvaluationPlan.controller;

import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.common.utils.poi.ExcelUtil;
import com.ruoyi.common.utils.security.ShiroUtils;
import com.ruoyi.framework.aspectj.lang.annotation.Log;
import com.ruoyi.framework.aspectj.lang.enums.BusinessType;
import com.ruoyi.framework.web.controller.BaseController;
import com.ruoyi.framework.web.domain.AjaxResult;
import com.ruoyi.project.enumerate.TrEvaluationMethodDetailsEnum;
import com.ruoyi.project.enumerate.TrEvaluationMethodTypeEnum;
import com.ruoyi.project.enumerate.TrRiskTypeEnum;
import com.ruoyi.project.system.dept.domain.Dept;
import com.ruoyi.project.system.dept.service.IDeptService;
import com.ruoyi.project.system.user.domain.User;
import com.ruoyi.project.tr.criterionDetail.domain.CriterionDetail;
import com.ruoyi.project.tr.criterionDetail.domain.CriterionDetailDTO;
import com.ruoyi.project.tr.criterionDetail.service.ICriterionDetailService;
import com.ruoyi.project.tr.region.domain.Region;
import com.ruoyi.project.tr.region.service.IRegionService;
import com.ruoyi.project.tr.riskCheckPoint.domain.RiskCheckPoint;
import com.ruoyi.project.tr.riskCheckPoint.service.IRiskCheckPointService;
import com.ruoyi.project.tr.riskEvaluationPlan.domain.RiskEvaluationPlan;
import com.ruoyi.project.tr.riskEvaluationPlan.domain.dto.RiskEvaluationDTO;
import com.ruoyi.project.tr.riskEvaluationPlan.service.IRiskEvaluationPlanService;
import com.ruoyi.project.tr.riskList.domain.RiskList;
import com.ruoyi.project.tr.riskList.service.IRiskListService;
import com.ruoyi.project.tr.riskType.domain.RiskType;
import com.ruoyi.project.tr.riskType.service.IRiskTypeService;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.multipart.MultipartFile;

import java.math.BigDecimal;
import java.util.HashMap;
import java.util.List;

/**
 * 风险评价,统一使用方法控制器
 * 
 * @author wm
 * @date 2020-05-09
 */
@Controller
@RequestMapping("/tr/riskEvaluation")
public class RiskEvaluationController extends BaseController{

    @Autowired
    private IRiskListService riskListService;

    @Autowired
    private IRiskEvaluationPlanService riskEvaluationPlanService;

    @Autowired
    private IRiskCheckPointService riskCheckPointService;

    @Autowired
    private IRiskTypeService typeService;

    @Autowired
    private IRegionService regionService;

    @Autowired
    private IDeptService deptService;

    @Autowired
    private ICriterionDetailService criterionDetailService;


//    /**
//     * 用于设备设施计划的导入
//     * @param file
//     * @return
//     * @throws Exception
//     */
//    @Log(title = "设备设施计划导入", businessType = BusinessType.IMPORT)
//    @PostMapping("/deviceImportData")
//    @ResponseBody
//    @Transactional
//    public AjaxResult deviceImportData(MultipartFile file) throws Exception {
//        User user = ShiroUtils.getSysUser();
//
//        //查询各个评分所用的准则明细
//        List<CriterionDetail> LS_L = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.LS_L.getCriterionId());
//        List<CriterionDetail> LS_S = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.LS_S.getCriterionId());
//
//        List<CriterionDetail> LEC_L = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.LEC_L.getCriterionId());
//        List<CriterionDetail> LEC_E = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.LEC_E.getCriterionId());
//        List<CriterionDetail> LEC_C = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.LEC_C.getCriterionId());
//
//        List<CriterionDetail> MES_M = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.MES_M.getCriterionId());
//        List<CriterionDetail> MES_E = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.MES_E.getCriterionId());
//        List<CriterionDetail> MES_S = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.MES_S.getCriterionId());
//
//        List<CriterionDetail> RS_R = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.RS_R.getCriterionId());
//        List<CriterionDetail> RS_S = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.RS_S.getCriterionId());
//
//
//
//        ExcelUtil<RiskEvaluationDTO> util = new ExcelUtil<RiskEvaluationDTO>(RiskEvaluationDTO.class);
//        List<RiskEvaluationDTO> deviceList = util.importExcel(file.getInputStream());
//
//        RiskList risk = new RiskList();
//
//        RiskEvaluationPlan plan = new RiskEvaluationPlan();
//        //首先添加设备
//        for (RiskEvaluationDTO riskEvaluationDTO :deviceList){
//
//            //如果不为空,就新增设备
//            if (StringUtils.isNotEmpty(riskEvaluationDTO.getRiskListName())) {
//                BeanUtils.copyProperties(riskEvaluationDTO, risk);
//                risk.setCompanyId(user.getCompanyId());
//                risk.setUserId(user.getUserId());
//                risk.setCreateBy(user.getUserName());
//                risk.setRiskType(TrRiskTypeEnum.DEVICE.getCode());
//                //根据名称,替换成对应ID
//
//                //设备设施类型
//                String riskType = riskEvaluationDTO.getRiskListDeviceType();
//                if (StringUtils.isNotEmpty(riskType)) {
//                    List<RiskType> riskTypeList = typeService.selectRiskTypeListByCompanyId(user.getCompanyId(), 1);
//                    for (RiskType r : riskTypeList) {
//                        if (riskType.equals(r.getRiskTypeName())) {
//                            risk.setRiskListDeviceType(r.getRiskTypeId());
//                            break;
//                        }
//                    }
//                    if (risk.getRiskListDeviceType()==null){
//                        return AjaxResult.error("{"+riskType+"},该[设备设施类型]未找到");
//                    }
//                } else {
//                    return AjaxResult.error("[设备设施类型]不能为空");
//                }
//
//                //区域/位置
//                String region = riskEvaluationDTO.getRegionName();
//                if (StringUtils.isNotEmpty(region)) {
//                    List<Region> regionList = regionService.selectRegionListByCompanyId(user.getCompanyId());
//                    for (Region r : regionList) {
//                        if (region.equals(r.getRegionName())) {
//                            risk.setRegionId(r.getRegionId());
//                            break;
//                        }
//                    }
//                    if (risk.getRegionId()==null){
//                        return AjaxResult.error("{"+region+"},该[区域/位置]未找到");
//                    }
//                } else {
//                    return AjaxResult.error("[区域/位置]不能为空");
//                }
//
//                //管辖部门/单位
//                String dept = riskEvaluationDTO.getDeptName();
//                if (StringUtils.isNotEmpty(dept)) {
//                    List<Dept> deptList = deptService.selectDeptListByCompanyId(user.getCompanyId());
//                    for (Dept d : deptList) {
//                        if (dept.equals(d.getDeptName())) {
//                            risk.setDeptId(d.getDeptId());
//                            break;
//                        }
//                    }
//                    if (risk.getDeptId()==null){
//                        return AjaxResult.error("{"+dept+"},该[管辖部门/单位]未找到");
//                    }
//                } else {
//                    return AjaxResult.error("[管辖部门/单位]不能为空");
//                }
//
//                //保存复制过的对象
//                int addNum = riskListService.insertRiskList(risk);
//                if (addNum<= 0){
//                    throw new Exception("设备导入失败!");
//                }
//            }
//
//            //新增设备后继续新增计划,评价计划是否存在
//            if (StringUtils.isNotEmpty(riskEvaluationDTO.getEvaluationPlanName())){
//                BeanUtils.copyProperties(riskEvaluationDTO,plan);
//                //保存复制过的对象
//                plan.setEvaluationRiskId(risk.getRiskListId());
//                plan.setCompanyId(user.getCompanyId());
//                plan.setPlanUserId(user.getUserId());
//                plan.setIdentifyUserId(user.getUserId());
//                plan.setPlanStatus(2);
//                plan.setStageStatus(4);
//                plan.setIdentifyStatus(2);
//                plan.setEvaluationType(1);
//                plan.setRiskIdentifyMethod(1);
//
//                int addNum = riskEvaluationPlanService.insertRiskEvaluationPlan(plan);
//                if (addNum<=0){
//                    throw new Exception("计划导入失败!");
//                }
//            }
//            System.out.println(plan);
//
//            //新增过计划后,增加检查点,
//            RiskCheckPoint checkPoint = new RiskCheckPoint();
//            BeanUtils.copyProperties(riskEvaluationDTO,checkPoint);
//            checkPoint.setPlanId(plan.getPlanId());
//            checkPoint.setEvaluationUserId(user.getUserId());
//            checkPoint.setReviewUserId(user.getUserId());
//            checkPoint.setEvaluationStatus(2);
//            checkPoint.setReviewStatus(2);
//            checkPoint.setCompanyId(user.getCompanyId());
//
//            //根据分数信息,和选择评分类型,查找用户选择的分级
//            if (TrEvaluationMethodTypeEnum.LS.getMethodId().equals(checkPoint.getEvaluationMethodType())){
//                checkPoint.setEvaluationNowLsL(getScoreId(LS_L,riskEvaluationDTO.getEvaluationNowLsL()));
//                checkPoint.setEvaluationNowLsS(getScoreId(LS_S,riskEvaluationDTO.getEvaluationNowLsS()));
//
//                checkPoint.setEvaluationAfterLsL(getScoreId(LS_L,riskEvaluationDTO.getEvaluationAfterLsL()));
//                checkPoint.setEvaluationAfterLsS(getScoreId(LS_S,riskEvaluationDTO.getEvaluationAfterLsS()));
//            }else if(TrEvaluationMethodTypeEnum.LEC.getMethodId().equals(checkPoint.getEvaluationMethodType())){
//                checkPoint.setEvaluationNowLecL(getScoreId(LEC_L,riskEvaluationDTO.getEvaluationNowLecL()));
//                checkPoint.setEvaluationNowLecE(getScoreId(LEC_E,riskEvaluationDTO.getEvaluationNowLecE()));
//                checkPoint.setEvaluationNowLecC(getScoreId(LEC_C,riskEvaluationDTO.getEvaluationNowLecC()));
//
//                checkPoint.setEvaluationAfterLecL(getScoreId(LEC_L,riskEvaluationDTO.getEvaluationAfterLecL()));
//                checkPoint.setEvaluationAfterLecE(getScoreId(LEC_E,riskEvaluationDTO.getEvaluationAfterLecE()));
//                checkPoint.setEvaluationAfterLecC(getScoreId(LEC_C,riskEvaluationDTO.getEvaluationAfterLecC()));
//            }else if(TrEvaluationMethodTypeEnum.MES.getMethodId().equals(checkPoint.getEvaluationMethodType())){
//                checkPoint.setEvaluationNowMesM(getScoreId(MES_M,riskEvaluationDTO.getEvaluationNowMesM()));
//                checkPoint.setEvaluationNowMesE(getScoreId(MES_E,riskEvaluationDTO.getEvaluationNowMesE()));
//                checkPoint.setEvaluationNowMesS(getScoreId(MES_S,riskEvaluationDTO.getEvaluationNowMesS()));
//
//                checkPoint.setEvaluationAfterMesM(getScoreId(MES_M,riskEvaluationDTO.getEvaluationAfterMesM()));
//                checkPoint.setEvaluationAfterMesE(getScoreId(MES_E,riskEvaluationDTO.getEvaluationAfterMesE()));
//                checkPoint.setEvaluationAfterMesS(getScoreId(MES_S,riskEvaluationDTO.getEvaluationAfterMesS()));
//            }else if(TrEvaluationMethodTypeEnum.RS.getMethodId().equals(checkPoint.getEvaluationMethodType())){
//                checkPoint.setEvaluationNowRsR(getScoreIdByRsR(RS_R,riskEvaluationDTO.getEvaluationNowRsR()));
//                checkPoint.setEvaluationNowRsS(getScoreIdByRsS(RS_S,riskEvaluationDTO.getEvaluationNowRsS()));
//
//                checkPoint.setEvaluationAfterRsR(getScoreIdByRsR(RS_R,riskEvaluationDTO.getEvaluationAfterRsR()));
//                checkPoint.setEvaluationAfterRsS(getScoreIdByRsS(RS_S,riskEvaluationDTO.getEvaluationAfterRsS()));
//            }
//
//            //计算分值
//            pingFen(checkPoint);
//
//            riskCheckPointService.insertRiskCheckPoint(checkPoint);
//        }
//
//        return AjaxResult.success("导入成功!");
//    }

    /**
     * 用于设备设施计划的导入
     * @param file
     * @return
     * @throws Exception
     */
    @Log(title = "设备设施计划导入", businessType = BusinessType.IMPORT)
    @PostMapping("/deviceImportData")
    @ResponseBody
    @Transactional
    public AjaxResult deviceImportData(MultipartFile file) throws Exception {
        User user = ShiroUtils.getSysUser();

        ExcelUtil<RiskEvaluationDTO> util = new ExcelUtil<RiskEvaluationDTO>(RiskEvaluationDTO.class);
        List<RiskEvaluationDTO> deviceList = util.importExcel(file.getInputStream());

        RiskList risk = new RiskList();
        int tag = 0;

        RiskEvaluationPlan plan = new RiskEvaluationPlan();
        //首先添加设备
        for (RiskEvaluationDTO riskEvaluationDTO :deviceList){

            //如果不为空,就新增设备
            if (StringUtils.isNotEmpty(riskEvaluationDTO.getRiskListName())) {
                BeanUtils.copyProperties(riskEvaluationDTO, risk);
                risk.setCompanyId(user.getCompanyId());
                risk.setUserId(user.getUserId());
                risk.setCreateBy(user.getUserName());
                risk.setRiskType(TrRiskTypeEnum.DEVICE.getCode());
                //根据名称,替换成对应ID

                //设备设施类型
                String riskType = riskEvaluationDTO.getRiskListDeviceType();
                if (StringUtils.isNotEmpty(riskType)) {
                    List<RiskType> riskTypeList = typeService.selectRiskTypeListByCompanyId(user.getCompanyId(), 1);
                    for (RiskType r : riskTypeList) {
                        if (riskType.equals(r.getRiskTypeName())) {
                            risk.setRiskListDeviceType(r.getRiskTypeId());
                            break;
                        }
                    }
                    if (risk.getRiskListDeviceType()==null){
                        return AjaxResult.error("{"+riskType+"},该[设备设施类型]未找到");
                    }
                } else {
                    return AjaxResult.error("[设备设施类型]不能为空");
                }

                //区域/位置
                String region = riskEvaluationDTO.getRegionName();
                if (StringUtils.isNotEmpty(region)) {
                    List<Region> regionList = regionService.selectRegionListByCompanyId(user.getCompanyId());
                    for (Region r : regionList) {
                        if (region.equals(r.getRegionName())) {
                            risk.setRegionId(r.getRegionId());
                            break;
                        }
                    }
                    if (risk.getRegionId()==null){
                        return AjaxResult.error("{"+region+"},该[区域/位置]未找到");
                    }
                } else {
                    return AjaxResult.error("[区域/位置]不能为空");
                }

                //管辖部门/单位
                String dept = riskEvaluationDTO.getDeptName();
                if (StringUtils.isNotEmpty(dept)) {
                    List<Dept> deptList = deptService.selectDeptListByCompanyId(user.getCompanyId());
                    for (Dept d : deptList) {
                        if (dept.equals(d.getDeptName())) {
                            risk.setDeptId(d.getDeptId());
                            break;
                        }
                    }
                    if (risk.getDeptId()==null){
                        return AjaxResult.error("{"+dept+"},该[管辖部门/单位]未找到");
                    }
                } else {
                    return AjaxResult.error("[管辖部门/单位]不能为空");
                }

                //保存复制过的对象
                int addNum = riskListService.insertRiskList(risk);
                if (addNum > 0){
                    tag = 1;
                }
            }
        }
        if (tag == 0){
            return AjaxResult.success("导入失败!");
        }
        return AjaxResult.success("导入成功!");
    }


    @Log(title = "作业活动计划导入", businessType = BusinessType.IMPORT)
    @PostMapping("/workImportData")
    @ResponseBody
    @Transactional
    public AjaxResult workImportData(MultipartFile file) throws Exception {
        User user = ShiroUtils.getSysUser();

        List<CriterionDetail> LS_L = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.LS_L.getCriterionId());
        List<CriterionDetail> LS_S = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.LS_S.getCriterionId());

        List<CriterionDetail> LEC_L = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.LEC_L.getCriterionId());
        List<CriterionDetail> LEC_E = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.LEC_E.getCriterionId());
        List<CriterionDetail> LEC_C = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.LEC_C.getCriterionId());

        List<CriterionDetail> MES_M = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.MES_M.getCriterionId());
        List<CriterionDetail> MES_E = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.MES_E.getCriterionId());
        List<CriterionDetail> MES_S = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.MES_S.getCriterionId());

        ExcelUtil<RiskEvaluationDTO> util = new ExcelUtil<RiskEvaluationDTO>(RiskEvaluationDTO.class);
        List<RiskEvaluationDTO> deviceList = util.importExcel(file.getInputStream());

        RiskList risk = new RiskList();

        RiskEvaluationPlan plan = new RiskEvaluationPlan();
        //首先添加设备
        for (RiskEvaluationDTO riskEvaluationDTO :deviceList){

            //如果不为空,就新增设备
            if (StringUtils.isNotEmpty(riskEvaluationDTO.getRiskListName())) {
                BeanUtils.copyProperties(riskEvaluationDTO, risk);
                risk.setCompanyId(user.getCompanyId());
                risk.setUserId(user.getUserId());
                risk.setCreateBy(user.getUserName());
                risk.setRiskType(TrRiskTypeEnum.WORK.getCode());
                //根据名称,替换成对应ID

                //作业活动类型
                String workType = riskEvaluationDTO.getRiskListWorkType();
                if (StringUtils.isNotEmpty(workType)) {
                    List<RiskType> riskTypeList = typeService.selectRiskTypeListByCompanyId(user.getCompanyId(), 2);
                    for (RiskType r : riskTypeList) {
                        if (workType.equals(r.getRiskTypeName())) {
                            risk.setRiskListWorkType(r.getRiskTypeId());
                            break;
                        }
                    }
                    if (risk.getRiskListWorkType()==null){
                        return AjaxResult.error("{"+workType+"},该[作业活动类型]未找到");
                    }
                } else {
                    return AjaxResult.error("[作业活动类型]不能为空");
                }

                //作业频率
                String workFrequency = riskEvaluationDTO.getRiskListWorkFrequency();
                if (StringUtils.isNotEmpty(workFrequency)) {
                    List<RiskType> riskTypeList = typeService.selectRiskTypeListByCompanyId(user.getCompanyId(), 4);
                    for (RiskType r : riskTypeList) {
                        if (workFrequency.equals(r.getRiskTypeName())) {
                            risk.setRiskListWorkFrequency(r.getRiskTypeId());
                            break;
                        }
                    }
                    if (risk.getRiskListWorkFrequency()==null){
                        return AjaxResult.error("{"+workFrequency+"},该[作业频率]未找到");
                    }
                } else {
                    return AjaxResult.error("[作业频率]不能为空");
                }

                //区域/位置
                String region = riskEvaluationDTO.getRegionName();
                if (StringUtils.isNotEmpty(region)) {
                    List<Region> regionList = regionService.selectRegionListByCompanyId(user.getCompanyId());
                    for (Region r : regionList) {
                        if (region.equals(r.getRegionName())) {
                            risk.setRegionId(r.getRegionId());
                            break;
                        }
                    }
                    if (risk.getRegionId()==null){
                        return AjaxResult.error("{"+region+"},该[区域/位置]未找到");
                    }
                } else {
                    return AjaxResult.error("[区域/位置]不能为空");
                }

                //管辖部门/单位
                String dept = riskEvaluationDTO.getDeptName();
                if (StringUtils.isNotEmpty(dept)) {
                    List<Dept> deptList = deptService.selectDeptListByCompanyId(user.getCompanyId());
                    for (Dept d : deptList) {
                        if (dept.equals(d.getDeptName())) {
                            risk.setDeptId(d.getDeptId());
                            break;
                        }
                    }
                    if (risk.getDeptId()==null){
                        return AjaxResult.error("{"+dept+"},该[管辖部门/单位]未找到");
                    }
                } else {
                    return AjaxResult.error("[管辖部门/单位]不能为空");
                }

                //保存复制过的对象
                int addNum = riskListService.insertRiskList(risk);
                if (addNum<= 0){
                    throw new Exception("设备导入失败!");
                }
            }

            //新增设备后继续新增计划,评价计划是否存在
            if (StringUtils.isNotEmpty(riskEvaluationDTO.getEvaluationPlanName())){
                BeanUtils.copyProperties(riskEvaluationDTO,plan);
                //保存复制过的对象
                plan.setEvaluationRiskId(risk.getRiskListId());
                plan.setCompanyId(user.getCompanyId());
                plan.setPlanUserId(user.getUserId());
                plan.setIdentifyUserId(user.getUserId());
                plan.setPlanStatus(2);
                plan.setStageStatus(4);
                plan.setIdentifyStatus(2);
                plan.setEvaluationType(2);
                plan.setRiskIdentifyMethod(2);

                int addNum = riskEvaluationPlanService.insertRiskEvaluationPlan(plan);
                if (addNum<=0){
                    throw new Exception("计划导入失败!");
                }
            }
            System.out.println(plan);

            //新增过计划后,增加检查点,
            RiskCheckPoint checkPoint = new RiskCheckPoint();
            BeanUtils.copyProperties(riskEvaluationDTO,checkPoint);
            checkPoint.setPlanId(plan.getPlanId());
            checkPoint.setEvaluationUserId(user.getUserId());
            checkPoint.setReviewUserId(user.getUserId());
            checkPoint.setEvaluationStatus(2);
            checkPoint.setReviewStatus(2);
            checkPoint.setCompanyId(user.getCompanyId());

            //根据分数信息,和选择评分类型,查找用户选择的分级
            if (TrEvaluationMethodTypeEnum.LS.getMethodId().equals(checkPoint.getEvaluationMethodType())){
                checkPoint.setEvaluationNowLsL(getScoreId(LS_L,riskEvaluationDTO.getEvaluationNowLsL()));
                checkPoint.setEvaluationNowLsS(getScoreId(LS_S,riskEvaluationDTO.getEvaluationNowLsS()));

                checkPoint.setEvaluationAfterLsL(getScoreId(LS_L,riskEvaluationDTO.getEvaluationAfterLsL()));
                checkPoint.setEvaluationAfterLsS(getScoreId(LS_S,riskEvaluationDTO.getEvaluationAfterLsS()));
            }else if(TrEvaluationMethodTypeEnum.LEC.getMethodId().equals(checkPoint.getEvaluationMethodType())){
                checkPoint.setEvaluationNowLecL(getScoreId(LEC_L,riskEvaluationDTO.getEvaluationNowLecL()));
                checkPoint.setEvaluationNowLecE(getScoreId(LEC_E,riskEvaluationDTO.getEvaluationNowLecE()));
                checkPoint.setEvaluationNowLecC(getScoreId(LEC_C,riskEvaluationDTO.getEvaluationNowLecC()));

                checkPoint.setEvaluationAfterLecL(getScoreId(LEC_L,riskEvaluationDTO.getEvaluationAfterLecL()));
                checkPoint.setEvaluationAfterLecE(getScoreId(LEC_E,riskEvaluationDTO.getEvaluationAfterLecE()));
                checkPoint.setEvaluationAfterLecC(getScoreId(LEC_C,riskEvaluationDTO.getEvaluationAfterLecC()));
            }else if(TrEvaluationMethodTypeEnum.MES.getMethodId().equals(checkPoint.getEvaluationMethodType())){
                checkPoint.setEvaluationNowMesM(getScoreId(MES_M,riskEvaluationDTO.getEvaluationNowMesM()));
                checkPoint.setEvaluationNowMesE(getScoreId(MES_E,riskEvaluationDTO.getEvaluationNowMesE()));
                checkPoint.setEvaluationNowMesS(getScoreId(MES_S,riskEvaluationDTO.getEvaluationNowMesS()));

                checkPoint.setEvaluationAfterMesM(getScoreId(MES_M,riskEvaluationDTO.getEvaluationAfterMesM()));
                checkPoint.setEvaluationAfterMesE(getScoreId(MES_E,riskEvaluationDTO.getEvaluationAfterMesE()));
                checkPoint.setEvaluationAfterMesS(getScoreId(MES_S,riskEvaluationDTO.getEvaluationAfterMesS()));
            }

            pingFen(checkPoint);

            riskCheckPointService.insertRiskCheckPoint(checkPoint);
        }

        return AjaxResult.success("导入成功!");
    }


    @Log(title = "工艺节点计划导入", businessType = BusinessType.IMPORT)
    @PostMapping("/craftsImportData")
    @ResponseBody
    @Transactional
    public AjaxResult craftsImportData(MultipartFile file) throws Exception {
        User user = ShiroUtils.getSysUser();

        List<CriterionDetail> LS_L = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.LS_L.getCriterionId());
        List<CriterionDetail> LS_S = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.LS_S.getCriterionId());

        List<CriterionDetail> LEC_L = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.LEC_L.getCriterionId());
        List<CriterionDetail> LEC_E = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.LEC_E.getCriterionId());
        List<CriterionDetail> LEC_C = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.LEC_C.getCriterionId());

        List<CriterionDetail> MES_M = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.MES_M.getCriterionId());
        List<CriterionDetail> MES_E = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.MES_E.getCriterionId());
        List<CriterionDetail> MES_S = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.MES_S.getCriterionId());

        ExcelUtil<RiskEvaluationDTO> util = new ExcelUtil<RiskEvaluationDTO>(RiskEvaluationDTO.class);
        List<RiskEvaluationDTO> deviceList = util.importExcel(file.getInputStream());

        RiskList risk = new RiskList();

        RiskEvaluationPlan plan = new RiskEvaluationPlan();
        //首先添加工艺节点
        for (RiskEvaluationDTO riskEvaluationDTO :deviceList){

            //如果不为空,就新增设备
            if (StringUtils.isNotEmpty(riskEvaluationDTO.getRiskListName())) {
                BeanUtils.copyProperties(riskEvaluationDTO, risk);
                risk.setCompanyId(user.getCompanyId());
                risk.setUserId(user.getUserId());
                risk.setCreateBy(user.getUserName());
                risk.setRiskType(TrRiskTypeEnum.CRAFTS.getCode());
                //根据名称,替换成对应ID

                //工艺节点类型
                String craftsType = riskEvaluationDTO.getRiskListCraftsType();
                if (StringUtils.isNotEmpty(craftsType)) {
                    List<RiskType> riskTypeList = typeService.selectRiskTypeListByCompanyId(user.getCompanyId(), 3);
                    for (RiskType r : riskTypeList) {
                        if (craftsType.equals(r.getRiskTypeName())) {
                            risk.setRiskListCraftsType(r.getRiskTypeId());
                            break;
                        }
                    }
                    if (risk.getRiskListCraftsType()==null){
                        return AjaxResult.error("{"+craftsType+"},该[工艺节点类型]未找到");
                    }
                } else {
                    return AjaxResult.error("[工艺节点类型]不能为空");
                }

                //区域/位置
                String region = riskEvaluationDTO.getRegionName();
                if (StringUtils.isNotEmpty(region)) {
                    List<Region> regionList = regionService.selectRegionListByCompanyId(user.getCompanyId());
                    for (Region r : regionList) {
                        if (region.equals(r.getRegionName())) {
                            risk.setRegionId(r.getRegionId());
                            break;
                        }
                    }
                    if (risk.getRegionId()==null){
                        return AjaxResult.error("{"+region+"},该[区域/位置]未找到");
                    }
                } else {
                    return AjaxResult.error("[区域/位置]不能为空");
                }

                //管辖部门/单位
                String dept = riskEvaluationDTO.getDeptName();
                if (StringUtils.isNotEmpty(dept)) {
                    List<Dept> deptList = deptService.selectDeptListByCompanyId(user.getCompanyId());
                    for (Dept d : deptList) {
                        if (dept.equals(d.getDeptName())) {
                            risk.setDeptId(d.getDeptId());
                            break;
                        }
                    }
                    if (risk.getDeptId()==null){
                        return AjaxResult.error("{"+dept+"},该[管辖部门/单位]未找到");
                    }
                } else {
                    return AjaxResult.error("[管辖部门/单位]不能为空");
                }

                //保存复制过的对象
                int addNum = riskListService.insertRiskList(risk);
                if (addNum<= 0){
                    throw new Exception("设备导入失败!");
                }
            }

            //新增设备后继续新增计划,评价计划是否存在
            if (StringUtils.isNotEmpty(riskEvaluationDTO.getEvaluationPlanName())){
                BeanUtils.copyProperties(riskEvaluationDTO,plan);
                //保存复制过的对象
                plan.setEvaluationRiskId(risk.getRiskListId());
                plan.setCompanyId(user.getCompanyId());
                plan.setPlanUserId(user.getUserId());
                plan.setIdentifyUserId(user.getUserId());
                plan.setPlanStatus(2);
                plan.setStageStatus(4);
                plan.setIdentifyStatus(2);
                plan.setEvaluationType(3);
                plan.setRiskIdentifyMethod(3);

                int addNum = riskEvaluationPlanService.insertRiskEvaluationPlan(plan);
                if (addNum<=0){
                    throw new Exception("计划导入失败!");
                }
            }
            System.out.println(plan);

            //新增过计划后,增加检查点,
            RiskCheckPoint checkPoint = new RiskCheckPoint();
            BeanUtils.copyProperties(riskEvaluationDTO,checkPoint);
            checkPoint.setPlanId(plan.getPlanId());
            checkPoint.setEvaluationUserId(user.getUserId());
            checkPoint.setReviewUserId(user.getUserId());
            checkPoint.setEvaluationStatus(2);
            checkPoint.setReviewStatus(2);
            checkPoint.setCompanyId(user.getCompanyId());

            //根据分数信息,和选择评分类型,查找用户选择的分级
            if (TrEvaluationMethodTypeEnum.LS.getMethodId().equals(checkPoint.getEvaluationMethodType())){
                checkPoint.setEvaluationNowLsL(getScoreId(LS_L,riskEvaluationDTO.getEvaluationNowLsL()));
                checkPoint.setEvaluationNowLsS(getScoreId(LS_S,riskEvaluationDTO.getEvaluationNowLsS()));

                checkPoint.setEvaluationAfterLsL(getScoreId(LS_L,riskEvaluationDTO.getEvaluationAfterLsL()));
                checkPoint.setEvaluationAfterLsS(getScoreId(LS_S,riskEvaluationDTO.getEvaluationAfterLsS()));
            }else if(TrEvaluationMethodTypeEnum.LEC.getMethodId().equals(checkPoint.getEvaluationMethodType())){
                checkPoint.setEvaluationNowLecL(getScoreId(LEC_L,riskEvaluationDTO.getEvaluationNowLecL()));
                checkPoint.setEvaluationNowLecE(getScoreId(LEC_E,riskEvaluationDTO.getEvaluationNowLecE()));
                checkPoint.setEvaluationNowLecC(getScoreId(LEC_C,riskEvaluationDTO.getEvaluationNowLecC()));

                checkPoint.setEvaluationAfterLecL(getScoreId(LEC_L,riskEvaluationDTO.getEvaluationAfterLecL()));
                checkPoint.setEvaluationAfterLecE(getScoreId(LEC_E,riskEvaluationDTO.getEvaluationAfterLecE()));
                checkPoint.setEvaluationAfterLecC(getScoreId(LEC_C,riskEvaluationDTO.getEvaluationAfterLecC()));
            }else if(TrEvaluationMethodTypeEnum.MES.getMethodId().equals(checkPoint.getEvaluationMethodType())){
                checkPoint.setEvaluationNowMesM(getScoreId(MES_M,riskEvaluationDTO.getEvaluationNowMesM()));
                checkPoint.setEvaluationNowMesE(getScoreId(MES_E,riskEvaluationDTO.getEvaluationNowMesE()));
                checkPoint.setEvaluationNowMesS(getScoreId(MES_S,riskEvaluationDTO.getEvaluationNowMesS()));

                checkPoint.setEvaluationAfterMesM(getScoreId(MES_M,riskEvaluationDTO.getEvaluationAfterMesM()));
                checkPoint.setEvaluationAfterMesE(getScoreId(MES_E,riskEvaluationDTO.getEvaluationAfterMesE()));
                checkPoint.setEvaluationAfterMesS(getScoreId(MES_S,riskEvaluationDTO.getEvaluationAfterMesS()));
            }

            pingFen(checkPoint);

            riskCheckPointService.insertRiskCheckPoint(checkPoint);
        }

        return AjaxResult.success("导入成功!");
    }


    /**
     * 用于区域计划的导入
     * @param file
     * @return
     * @throws Exception
     */
    @Log(title = "设备设施计划导入", businessType = BusinessType.IMPORT)
    @PostMapping("/roomImportData")
    @ResponseBody
    @Transactional
    public AjaxResult roomImportData(MultipartFile file) throws Exception {
        User user = ShiroUtils.getSysUser();

        //查询各个评分所用的准则明细
        List<CriterionDetail> LS_L = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.LS_L.getCriterionId());
        List<CriterionDetail> LS_S = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.LS_S.getCriterionId());

        List<CriterionDetail> LEC_L = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.LEC_L.getCriterionId());
        List<CriterionDetail> LEC_E = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.LEC_E.getCriterionId());
        List<CriterionDetail> LEC_C = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.LEC_C.getCriterionId());

        List<CriterionDetail> MES_M = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.MES_M.getCriterionId());
        List<CriterionDetail> MES_E = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.MES_E.getCriterionId());
        List<CriterionDetail> MES_S = criterionDetailService.selectCriterionDetailListByCriterionId(TrEvaluationMethodDetailsEnum.MES_S.getCriterionId());

        ExcelUtil<RiskEvaluationDTO> util = new ExcelUtil<RiskEvaluationDTO>(RiskEvaluationDTO.class);
        List<RiskEvaluationDTO> deviceList = util.importExcel(file.getInputStream());

        RiskList risk = new RiskList();

        RiskEvaluationPlan plan = new RiskEvaluationPlan();
        //首先添加设备
        for (RiskEvaluationDTO riskEvaluationDTO :deviceList){

            //如果不为空,就新增设备
            if (StringUtils.isNotEmpty(riskEvaluationDTO.getRiskListName())) {
                BeanUtils.copyProperties(riskEvaluationDTO, risk);
                risk.setCompanyId(user.getCompanyId());
                risk.setUserId(user.getUserId());
                risk.setCreateBy(user.getUserName());
                risk.setRiskType(TrRiskTypeEnum.ROOM.getCode());
                //根据名称,替换成对应ID

                //设备设施类型
                String riskType = riskEvaluationDTO.getRiskListDeviceType();
                if (StringUtils.isNotEmpty(riskType)) {
                    List<RiskType> riskTypeList = typeService.selectRiskTypeListByCompanyId(user.getCompanyId(), 1);
                    for (RiskType r : riskTypeList) {
                        if (riskType.equals(r.getRiskTypeName())) {
                            risk.setRiskListDeviceType(r.getRiskTypeId());
                            break;
                        }
                    }
                    if (risk.getRiskListDeviceType()==null){
                        return AjaxResult.error("{"+riskType+"},该[设备设施类型]未找到");
                    }
                } else {
                    return AjaxResult.error("[设备设施类型]不能为空");
                }

                //区域/位置
                String region = riskEvaluationDTO.getRegionName();
                if (StringUtils.isNotEmpty(region)) {
                    List<Region> regionList = regionService.selectRegionListByCompanyId(user.getCompanyId());
                    for (Region r : regionList) {
                        if (region.equals(r.getRegionName())) {
                            risk.setRegionId(r.getRegionId());
                            break;
                        }
                    }
                    if (risk.getRegionId()==null){
                        return AjaxResult.error("{"+region+"},该[区域/位置]未找到");
                    }
                } else {
                    return AjaxResult.error("[区域/位置]不能为空");
                }

                //管辖部门/单位
                String dept = riskEvaluationDTO.getDeptName();
                if (StringUtils.isNotEmpty(dept)) {
                    List<Dept> deptList = deptService.selectDeptListByCompanyId(user.getCompanyId());
                    for (Dept d : deptList) {
                        if (dept.equals(d.getDeptName())) {
                            risk.setDeptId(d.getDeptId());
                            break;
                        }
                    }
                    if (risk.getDeptId()==null){
                        return AjaxResult.error("{"+dept+"},该[管辖部门/单位]未找到");
                    }
                } else {
                    return AjaxResult.error("[管辖部门/单位]不能为空");
                }

                //保存复制过的对象
                int addNum = riskListService.insertRiskList(risk);
                if (addNum<= 0){
                    throw new Exception("设备导入失败!");
                }
            }

            //新增设备后继续新增计划,评价计划是否存在
            if (StringUtils.isNotEmpty(riskEvaluationDTO.getEvaluationPlanName())){
                BeanUtils.copyProperties(riskEvaluationDTO,plan);
                //保存复制过的对象
                plan.setEvaluationRiskId(risk.getRiskListId());
                plan.setCompanyId(user.getCompanyId());
                plan.setPlanUserId(user.getUserId());
                plan.setIdentifyUserId(user.getUserId());
                plan.setPlanStatus(2);
                plan.setStageStatus(4);
                plan.setIdentifyStatus(2);
                plan.setEvaluationType(1);
                plan.setRiskIdentifyMethod(1);

                int addNum = riskEvaluationPlanService.insertRiskEvaluationPlan(plan);
                if (addNum<=0){
                    throw new Exception("计划导入失败!");
                }
            }
            System.out.println(plan);

            //新增过计划后,增加检查点,
            RiskCheckPoint checkPoint = new RiskCheckPoint();
            BeanUtils.copyProperties(riskEvaluationDTO,checkPoint);
            checkPoint.setPlanId(plan.getPlanId());
            checkPoint.setEvaluationUserId(user.getUserId());
            checkPoint.setReviewUserId(user.getUserId());
            checkPoint.setEvaluationStatus(2);
            checkPoint.setReviewStatus(2);
            checkPoint.setCompanyId(user.getCompanyId());

            //根据分数信息,和选择评分类型,查找用户选择的分级
            if (TrEvaluationMethodTypeEnum.LS.getMethodId().equals(checkPoint.getEvaluationMethodType())){
                checkPoint.setEvaluationNowLsL(getScoreId(LS_L,riskEvaluationDTO.getEvaluationNowLsL()));
                checkPoint.setEvaluationNowLsS(getScoreId(LS_S,riskEvaluationDTO.getEvaluationNowLsS()));

                checkPoint.setEvaluationAfterLsL(getScoreId(LS_L,riskEvaluationDTO.getEvaluationAfterLsL()));
                checkPoint.setEvaluationAfterLsS(getScoreId(LS_S,riskEvaluationDTO.getEvaluationAfterLsS()));
            }else if(TrEvaluationMethodTypeEnum.LEC.getMethodId().equals(checkPoint.getEvaluationMethodType())){
                checkPoint.setEvaluationNowLecL(getScoreId(LEC_L,riskEvaluationDTO.getEvaluationNowLecL()));
                checkPoint.setEvaluationNowLecE(getScoreId(LEC_E,riskEvaluationDTO.getEvaluationNowLecE()));
                checkPoint.setEvaluationNowLecC(getScoreId(LEC_C,riskEvaluationDTO.getEvaluationNowLecC()));

                checkPoint.setEvaluationAfterLecL(getScoreId(LEC_L,riskEvaluationDTO.getEvaluationAfterLecL()));
                checkPoint.setEvaluationAfterLecE(getScoreId(LEC_E,riskEvaluationDTO.getEvaluationAfterLecE()));
                checkPoint.setEvaluationAfterLecC(getScoreId(LEC_C,riskEvaluationDTO.getEvaluationAfterLecC()));
            }else if(TrEvaluationMethodTypeEnum.MES.getMethodId().equals(checkPoint.getEvaluationMethodType())){
                checkPoint.setEvaluationNowMesM(getScoreId(MES_M,riskEvaluationDTO.getEvaluationNowMesM()));
                checkPoint.setEvaluationNowMesE(getScoreId(MES_E,riskEvaluationDTO.getEvaluationNowMesE()));
                checkPoint.setEvaluationNowMesS(getScoreId(MES_S,riskEvaluationDTO.getEvaluationNowMesS()));

                checkPoint.setEvaluationAfterMesM(getScoreId(MES_M,riskEvaluationDTO.getEvaluationAfterMesM()));
                checkPoint.setEvaluationAfterMesE(getScoreId(MES_E,riskEvaluationDTO.getEvaluationAfterMesE()));
                checkPoint.setEvaluationAfterMesS(getScoreId(MES_S,riskEvaluationDTO.getEvaluationAfterMesS()));
            }

            //计算分值
            pingFen(checkPoint);

            riskCheckPointService.insertRiskCheckPoint(checkPoint);
        }

        return AjaxResult.success("导入成功!");
    }





    /**
     * 根据分数,获取到该分数的
     * @param list
     * @param score
     * @return
     */
    private Long getScoreId(List<CriterionDetail> list,BigDecimal score){
        for (CriterionDetail detail : list){
            if (score.compareTo(detail.getDetailScore())==0){
                return detail.getDetailId();
            }
        }
        return 0L;
    }


    /**
     *
     * @param list
     * @param score
     * @return
     */
    private Long getScoreIdByRsR(List<CriterionDetail> list,String score){
        for (CriterionDetail detail : list){
            if (score.equals(detail.getRsRKenengxing())){
                return detail.getDetailId();
            }
        }
        return 0L;
    }

    private Long getScoreIdByRsS(List<CriterionDetail> list,String score){
        for (CriterionDetail detail : list){
            if (score.equals(detail.getRsSDengji())){
                return detail.getDetailId();
            }
        }
        return 0L;
    }




    /**
     * 分数计算方法
     * @param riskCheckPoint
     */
    private void pingFen(RiskCheckPoint riskCheckPoint){

        //计算之前评分
        CriterionDetailDTO now = new CriterionDetailDTO();
        now.setEvaluationMethodType(riskCheckPoint.getEvaluationMethodType());
        now.setLS_L(riskCheckPoint.getEvaluationNowLsL());
        now.setLS_S(riskCheckPoint.getEvaluationNowLsS());
        now.setLEC_L(riskCheckPoint.getEvaluationNowLecL());
        now.setLEC_E(riskCheckPoint.getEvaluationNowLecE());
        now.setLEC_C(riskCheckPoint.getEvaluationNowLecC());
        now.setMES_M(riskCheckPoint.getEvaluationNowMesM());
        now.setMES_E(riskCheckPoint.getEvaluationNowMesE());
        now.setMES_S(riskCheckPoint.getEvaluationNowMesS());
        now.setRS_R(riskCheckPoint.getEvaluationNowRsR());
        now.setRS_S(riskCheckPoint.getEvaluationNowRsS());

        HashMap<String ,String> nowMap = criterionDetailService.calculation(now);

        riskCheckPoint.setEvaluationNowFengxianzhi(nowMap.get("Fengxianzhi"));
        riskCheckPoint.setEvaluationNowJibie(nowMap.get("Jibie"));
        riskCheckPoint.setEvaluationNowFengxianJibie(nowMap.get("FengxianJibie"));
        riskCheckPoint.setEvaluationNowFengxianse(nowMap.get("Fengxianse"));
        riskCheckPoint.setEvaluationNowGuankongCengji(nowMap.get("GuankongCengji"));


        //计算建议后评分
        CriterionDetailDTO after = new CriterionDetailDTO();
        after.setEvaluationMethodType(riskCheckPoint.getEvaluationMethodType());
        after.setLS_L(riskCheckPoint.getEvaluationAfterLsL());
        after.setLS_S(riskCheckPoint.getEvaluationAfterLsS());
        after.setLEC_L(riskCheckPoint.getEvaluationAfterLecL());
        after.setLEC_E(riskCheckPoint.getEvaluationAfterLecE());
        after.setLEC_C(riskCheckPoint.getEvaluationAfterLecC());
        after.setMES_M(riskCheckPoint.getEvaluationAfterMesM());
        after.setMES_E(riskCheckPoint.getEvaluationAfterMesE());
        after.setMES_S(riskCheckPoint.getEvaluationAfterMesS());
        after.setRS_R(riskCheckPoint.getEvaluationAfterRsR());
        after.setRS_S(riskCheckPoint.getEvaluationAfterRsS());

        HashMap<String ,String> afterMap = criterionDetailService.calculation(after);

        riskCheckPoint.setEvaluationAfterFengxianzhi(afterMap.get("Fengxianzhi"));
        riskCheckPoint.setEvaluationAfterJibie(afterMap.get("Jibie"));
        riskCheckPoint.setEvaluationAfterFengxianJibie(afterMap.get("FengxianJibie"));
        riskCheckPoint.setEvaluationAfterFengxianse(afterMap.get("Fengxianse"));
        riskCheckPoint.setEvaluationAfterGuankongCengji(afterMap.get("GuankongCengji"));

    }




}