package com.gkhy.safePlatform.doublePrevention.service.impl;

import com.gkhy.safePlatform.account.rpc.apimodel.AccountAuthService;
import com.gkhy.safePlatform.account.rpc.apimodel.AccountDepartmentService;
import com.gkhy.safePlatform.account.rpc.apimodel.AccountUserService;
import com.gkhy.safePlatform.account.rpc.apimodel.model.resp.DepInfoRPCRespDTO;
import com.gkhy.safePlatform.account.rpc.apimodel.model.resp.UserInfoRPCRespDTO;
import com.gkhy.safePlatform.account.rpc.apimodel.model.resp.UserRPCRespDTO;
import com.gkhy.safePlatform.commons.co.ContextCacheUser;
import com.gkhy.safePlatform.commons.enums.E;
import com.gkhy.safePlatform.commons.exception.AusinessException;
import com.gkhy.safePlatform.commons.utils.BeanCopyUtils;
import com.gkhy.safePlatform.commons.utils.idService.SnowFlow;
import com.gkhy.safePlatform.commons.vo.ResultVO;
import com.gkhy.safePlatform.doublePrevention.entity.*;
import com.gkhy.safePlatform.doublePrevention.entity.dto.PreventRiskControlTemplateDO;
import com.gkhy.safePlatform.doublePrevention.enums.DeviceStatusEnum;
import com.gkhy.safePlatform.doublePrevention.enums.StatusEnum;
import com.gkhy.safePlatform.doublePrevention.enums.SyncEnum;
import com.gkhy.safePlatform.doublePrevention.service.FileHandlerService;
import com.gkhy.safePlatform.doublePrevention.service.baseService.*;
import com.gkhy.safePlatform.doublePrevention.utils.ExcelProperty;
import com.gkhy.safePlatform.doublePrevention.utils.FileOptUtils;
import org.apache.commons.lang3.ObjectUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.dubbo.config.annotation.DubboReference;
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
import org.apache.poi.ss.usermodel.FormulaEvaluator;
import org.apache.poi.ss.usermodel.Row;
import org.apache.poi.ss.usermodel.Sheet;
import org.apache.poi.ss.usermodel.Workbook;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.multipart.MultipartFile;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.UUID;
import java.util.regex.Pattern;

import static com.gkhy.safePlatform.doublePrevention.utils.Properties.filePath;

@Service
public class FileHandlerServiceImpl implements FileHandlerService {

    @DubboReference(check = false)
    private AccountAuthService accountAuthService;
    @DubboReference(check = false)
    private AccountUserService accountUserService;
    @DubboReference(check = false)
    private AccountDepartmentService accountDepartmentService;

    @Autowired
    private PreventDangerCheckTaskUnitService preventDangerCheckTaskUnitService;
    @Autowired
    private PreventRiskControlMeasureService preventRiskControlMeasureService;
    @Autowired
    private PreventDangerCheckWorkService preventDangerCheckWorkService;
    @Autowired
    private PreventDangerCheckTaskService preventDangerCheckTaskService;
    @Autowired
    private PreventDangerCheckContentService preventDangerCheckContentService;
    @Autowired
    private PreventReportConfigService preventReportConfigService;
    @Autowired
    private PreventProduceDeviceService preventProduceDeviceService;
    @Autowired
    private PreventRiskMapService preventRiskMapService;
    @Autowired
    private PreventRiskAnaUnitService preventRiskUnitService;
    @Autowired
    private PreventRiskEventService preventRiskEventService;
    @Autowired
    private PreventRiskControlTemplateService preventRiskControlTemplateService;


    private final Logger logger = LoggerFactory.getLogger(this.getClass());
    //正整数
    String pattern = "^[0-9]*[1-9][0-9]*$";

    Pattern pattern2 = Pattern.compile("^(([1-9]{1}\\d*)|([0]{1}))(\\.(\\d){0,2})?$");

    String[] deviceTitle = {"生产装置", "风险等级", "所属部门", "区域位置"};

    String[] riskUnitTitle = {"单元名称", "责任部门", "责任人", "安全风险分析对象编码", "生产装置"};

    String[] eventTitle = {"事件名称", "单元名称", "可能造成的后果"};

    String[] measureTitle = {"风险事件", "管控措施编号", "管控方式", "管控措施分类1", "管控措施分类2", "管控措施分类3", "管控措施描述", "隐患排查内容"};



    /**
     * 生产装置-导入
     */
    @Transactional(propagation= Propagation.REQUIRED,timeout = 500)
    @Override
    public ResultVO<PreventProduceDevice> deviceImport(ContextCacheUser currentUser, MultipartFile file) {

        ResultVO resultVO = new ResultVO<>();
        resultVO.setCode("200");
        resultVO.setMsg("生产设施设备导入成功");

        if (file == null){
            throw new AusinessException(E.DATA_PARAM_NULL, "找不到上传文件");
        }
        if (file.getSize() == 0){
            throw new AusinessException(E.DATA_PARAM_NULL, "文件内容为空");
        }
        if (!FileOptUtils.isDirExists(filePath)) {
            throw new AusinessException(E.DATA_PARAM_NULL, "发生错误或不为目录");
        }
        String fileSave = filePath + currentUser.getRealName() + "_"  + ".xlsx";
        int sum = 0;
        //获取list
        List<PreventProduceDevice> deviceLists = new ArrayList<>();

        try {
            file.transferTo(new File(fileSave));
            String name = file.getOriginalFilename();
            Boolean isExcel2007 = name.substring(name.lastIndexOf(".") + 1).endsWith("xlsx") ? true : false;
            InputStream in = new FileInputStream(fileSave);

            Workbook workbook = null;
            if (isExcel2007) {
                workbook = new XSSFWorkbook(in);
            } else {
                workbook = new HSSFWorkbook(in);
            }
            FormulaEvaluator evaluator = workbook.getCreationHelper().createFormulaEvaluator();
            Sheet sheet = workbook.getSheetAt(0);
            if (sheet == null) {
                throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "excel 第1页不能为空");
            }
            Row row = sheet.getRow(0);
            // 标题总列数
            int colNum = row.getPhysicalNumberOfCells();
            String[] title = new String[colNum];

            if (colNum != deviceTitle.length) {
                throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "上传文件的列的个数错误");
            }
            for (int i = 0; i < colNum; i++) {

                title[i] = row.getCell(i).getStringCellValue();
                if (StringUtils.isNotBlank(title[i])) {
                    title[i] = title[i].trim();
                }
                if (!title[i].equals((deviceTitle[i]))) {
                    throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "上传文件的第" + (i + 1) + "列的标题为" + title[i] + "不为" + deviceTitle[i]);
                }
            }
            //遍历封装数据
            for (int irow = 1; irow <= sheet.getLastRowNum(); irow++) {
                int realRow = irow + 1;
                PreventProduceDevice device = new PreventProduceDevice();
                Object value = null;
                row = sheet.getRow(irow);

                //字段1-生产装置
                value = ExcelProperty.getCellValue(row.getCell(0), evaluator);
                if (null == value || StringUtils.isBlank(value.toString())) {
                    throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + (realRow + 1) + "行,生产装置不能为空.<br/>");
                } else {
                    //无重名，设置属性
                    PreventProduceDevice deviceByName = preventProduceDeviceService.getDeviceByName(value.toString().trim());
                    if (ObjectUtils.isEmpty(deviceByName)){
                        device.setProduceDeviceName(value.toString().trim());
                    }else {
                        throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + (realRow + 1) + "行,生产装置名称已被使用，请在生产装置名称后添加编号或所属部门.<br/>");
                    }
                }

                //字段2-风险等级
                //String level1="";
                value = ExcelProperty.getCellValue(row.getCell(1), evaluator);
                if (null == value || StringUtils.isBlank(value.toString())) {
                    throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + (realRow + 1) + "行,风险等级不能为空.<br/>");
                }
                /*1-低风险，2-一般风险，3-较大风险，4-重大风险*/
                if(value.toString().trim().equals("低风险")){
                    device.setRiskLevel((byte) 1);
                } else if(value.toString().trim().equals("一般风险")){
                    device.setRiskLevel((byte) 2);
                } else if(value.toString().trim().equals("较大风险")){
                    device.setRiskLevel((byte) 3);
                } else if(value.toString().trim().equals("重大风险")){
                    device.setRiskLevel((byte) 4);
                } else {
                    throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + (realRow + 1) + "行,风险等级不符合规范.<br/>");
                }

                //参数属性3-所属部门
                value = ExcelProperty.getCellValue(row.getCell(2), evaluator);
                if (null == value || StringUtils.isBlank(value.toString())) {
                    throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + (realRow + 1) + "行,所属部门不能为空.<br/>");
                } else {
                    //校验部门是否存在
                    ResultVO<DepInfoRPCRespDTO> depInfo = accountDepartmentService.getDepartmentInfoByDepName(value.toString().trim());
                    DepInfoRPCRespDTO dep = (DepInfoRPCRespDTO)depInfo.getData();
                    if (ObjectUtils.isEmpty(dep)){
                        throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + (realRow + 1) + "行,部门名称有误，或未录入系统.<br/>");
                    }else {
                        device.setDepName(value.toString().trim());
                        device.setDepId(dep.getDepId());
                    }
                }

                //参数属性4-区域位置
                value = ExcelProperty.getCellValue(row.getCell(3), evaluator);
                if (null == value || StringUtils.isBlank(value.toString())) {
                    throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + (realRow + 1) + "行的区域位置不能为空.<br/>");
                } else {
                    device.setLocation(value.toString().trim());
                }
                //获取填充信息
                Date date = new Date();
                SnowFlow snowFlow = new SnowFlow();//雪花算法生成器
                String uuid = UUID.randomUUID().toString();
                //封装参数
                device.setId( snowFlow.nextId());
                device.setUuid(uuid);
                device.setStatus(DeviceStatusEnum.DEVICE_USE.getCode());
                device.setEnterpriseId((long) 1);
                device.setEnterpriseUuid("111");
                device.setDepUuid(null);
                device.setCreateByUserName(currentUser.getRealName());
                device.setGmtCreate(date);
                device.setLastEditUserName(currentUser.getRealName());
                device.setGmtModitify(date);
                device.setDeleteStatus(StatusEnum.DELETE_STATUS_USE.getCode());
                deviceLists.add(device);
            }
        } catch (IOException e) {
            throw new RuntimeException("读取上传文件发生错误{}"+e);
        }

        for (PreventProduceDevice device : deviceLists) {
            //插入
            int result = preventProduceDeviceService.saveDevice(device);
            sum = sum + result;
        }
        resultVO.setCount(sum);

        return resultVO;
    }


    /**
     * 风险分析单元-导入
     */
    @Transactional(propagation= Propagation.REQUIRED,timeout = 500)
    @Override
    public ResultVO<PreventRiskAnaUnit> riskUnitImport(ContextCacheUser currentUser, MultipartFile file) {

        ResultVO resultVO = new ResultVO<>();
        resultVO.setCode("200");
        resultVO.setMsg(" 风险分析单元数据导入成功");

        if (file == null){
            throw new AusinessException(E.DATA_PARAM_NULL, "找不到上传文件");
        }
        if (file.getSize() == 0){
            throw new AusinessException(E.DATA_PARAM_NULL, "文件内容为空");
        }
        if (!FileOptUtils.isDirExists(filePath)) {
            throw new AusinessException(E.DATA_PARAM_NULL, "发生错误或不为目录");
        }
        String fileSave = filePath + currentUser.getRealName() + "_"  + ".xlsx";
        int sum = 0;
        //获取list
        List<PreventRiskAnaUnit> riskUnitLists = new ArrayList<>();

        try {
            file.transferTo(new File(fileSave));
            String name = file.getOriginalFilename();
            Boolean isExcel2007 = name.substring(name.lastIndexOf(".") + 1).endsWith("xlsx") ? true : false;
            InputStream in = new FileInputStream(fileSave);

            Workbook workbook = null;
            if (isExcel2007) {
                workbook = new XSSFWorkbook(in);
            } else {
                workbook = new HSSFWorkbook(in);
            }

            FormulaEvaluator evaluator = workbook.getCreationHelper().createFormulaEvaluator();
            Sheet sheet = workbook.getSheetAt(0);
            if (sheet == null) {
                throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "excel 第1页不能为空");
            }
            Row row = sheet.getRow(0);
            // 标题总列数
            int colNum = row.getPhysicalNumberOfCells();
            String[] title = new String[colNum];

            if (colNum != riskUnitTitle.length) {
                throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "上传文件的列的个数错误");
            }
            for (int i = 0; i < colNum; i++) {

                title[i] = row.getCell(i).getStringCellValue();
                if (StringUtils.isNotBlank(title[i])) {
                    title[i] = title[i].trim();
                }
                if (!title[i].equals((riskUnitTitle[i]))) {
                    throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "上传文件的第" + (i + 1) + "列的标题为：" + title[i] + "，不为：" + riskUnitTitle[i]);
                }
            }
            //遍历封装数据
            for (int irow = 1; irow <= sheet.getLastRowNum(); irow++) {
                int realRow = irow + 1;
                PreventRiskAnaUnit riskAnaUnit = new PreventRiskAnaUnit();
                Object value = null;
                Object value1 = null;
                row = sheet.getRow(irow);

                //字段1-安全风险分析单元
                value = ExcelProperty.getCellValue(row.getCell(0), evaluator);
                if (null == value || StringUtils.isBlank(value.toString())) {
                    throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + realRow + "行,安全风险分析单元名称不能为空.<br/>");
                } else {
                    PreventRiskAnaUnit riskUnitByName = preventRiskUnitService.getRiskUnitByName(value.toString().trim());
                    //无重名，设置属性
                    if (ObjectUtils.isEmpty(riskUnitByName)){
                        riskAnaUnit.setRiskUnitName(value.toString().trim());
                    }else {
                        throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + realRow + "行,安全风险分析单元名称已被使用，请在安全风险分析单元名称后添加编号或所属部门.<br/>");
                    }
                }

                //字段2-责任部门
                value1 = ExcelProperty.getCellValue(row.getCell(1), evaluator);
                if (null == value1 || StringUtils.isBlank(value1.toString())) {
                    throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + realRow + "行,责任部门不能为空.<br/>");
                } else {
                    //校验部门是否存在
                    ResultVO<DepInfoRPCRespDTO> depInfo = accountDepartmentService.getDepartmentInfoByDepName(value1.toString().trim());
                    DepInfoRPCRespDTO dep = (DepInfoRPCRespDTO)depInfo.getData();
                    if (ObjectUtils.isEmpty(dep)){
                        throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + realRow + "行,责任部门名称有误，或未录入系统.<br/>");
                    }else {
                        riskAnaUnit.setLiableDep(value1.toString().trim());
                        riskAnaUnit.setLiableDepId(dep.getDepId());
                        riskAnaUnit.setLiableDepUuid(null);
                    }
                }

                //字段3-责任人
                value = ExcelProperty.getCellValue(row.getCell(2), evaluator);
                if (null == value || StringUtils.isBlank(value.toString())) {
                    throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + realRow + "行的责任人不能为空.<br/>");
                } else {
                    //校验部门是否存在
                    ResultVO<DepInfoRPCRespDTO> depInfo = accountDepartmentService.getDepartmentInfoByDepName(value1.toString().trim());
                    DepInfoRPCRespDTO dep = (DepInfoRPCRespDTO)depInfo.getData();
                    //获取责任人信息
                    UserInfoRPCRespDTO liablePerson = null;
                    ResultVO<List<UserInfoRPCRespDTO>> listResultVO = accountUserService.listUserInfoByRealName(value.toString().trim());
                    List<UserInfoRPCRespDTO> personList = (List<UserInfoRPCRespDTO>)listResultVO.getData();
                    for (UserInfoRPCRespDTO userInfo : personList) {
                        if (userInfo.getDepId().equals(dep.getDepId())){
                            liablePerson = BeanCopyUtils.copyBean(userInfo, UserInfoRPCRespDTO.class);
                        }
                    }
                    if (ObjectUtils.isEmpty(liablePerson)){
                        throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + realRow + "行的责任人名称有误，或未录入系统.<br/>");
                    } else {
                        riskAnaUnit.setLiablePerson(liablePerson.getRealName());
                        //获取责任人信息
                        riskAnaUnit.setLiablePersonId(liablePerson.getUid());
                        riskAnaUnit.setLiablePersonUuid(liablePerson.getUuid());
                    }
                }

                //参数属性4-安全风险分析对象编码
                value = ExcelProperty.getCellValue(row.getCell(3), evaluator);
                if (null == value || StringUtils.isBlank(value.toString())) {
                    throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + realRow + "行,安全风险分析对象编码不能为空.<br/>");
                } else {
                    //查询是否有重复编码
                    PreventRiskAnaUnit riskUnitByCode = preventRiskUnitService.getRiskUnitByCode(value.toString().trim());
                    if (ObjectUtils.isEmpty(riskUnitByCode)){
                        riskAnaUnit.setRiskCode(value.toString().trim());
                    }else {
                        throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + realRow + "行,安全风险分析对象编码已经被使用.<br/>");
                    }
                }

                //参数属性5-所属生产装置
                value = ExcelProperty.getCellValue(row.getCell(4), evaluator);
                if (null == value || StringUtils.isBlank(value.toString())) {
                    throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + realRow + "行,生产装置不能为空.<br/>");
                } else {
                    //todo 此处，风险分析单元与设备是否需要同部门
                    PreventProduceDevice deviceByName = preventProduceDeviceService.getDeviceByName(value.toString().trim());
                    if (ObjectUtils.isEmpty(deviceByName)){
                        throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + realRow + "行,生产装置不存在或未录入系统.<br/>");
                    }else {
                        riskAnaUnit.setProduceDeviceId(deviceByName.getId());
                        riskAnaUnit.setProduceDeviceUuid(deviceByName.getUuid());
                    }
                }

                //获取填充信息
                Date date = new Date();
                SnowFlow snowFlow = new SnowFlow();//雪花算法生成器
                String uuid = UUID.randomUUID().toString();
                //封装参数
                riskAnaUnit.setId(snowFlow.nextId());
                riskAnaUnit.setUuid(uuid);
                riskAnaUnit.setDeleteStatus(StatusEnum.DELETE_STATUS_USE.getCode());
                riskAnaUnit.setEnterpriseId((long) 1);
                riskAnaUnit.setEnterpriseUuid("111");
                riskAnaUnit.setGmtModitify(date);
                riskAnaUnit.setGmtCreate(date);
                riskAnaUnit.setCreateByUserName(currentUser.getRealName());
                riskAnaUnit.setLastEditUserName(currentUser.getRealName());
                //读取上报主配置，设置上报属性
                PreventReportConfig reportConfigById = preventReportConfigService.getReportConfigById(SyncEnum.REPORT_CONFIG_RISK_ANA_UNIT.getCode());
                //设置上报时间为空
                riskAnaUnit.setReportTime(null);
                //设置本条数据上报更新时间
                riskAnaUnit.setUpdateReportDataTime(date);
                //读取上报主配置，进行任务记录上报配置,如果开启上报功能，且设置为自动上报,开启上报相关配置
                if (reportConfigById.getReportState() == SyncEnum.REPORT_ON.getCode()
                        && reportConfigById.getReportType() == SyncEnum.REPORT_HAND_EXEC_CONFIG.getCode()){
                    //设置上报状态为-等待上报
                    riskAnaUnit.setReportStatus(SyncEnum.SYNC_WAIT_EXEC.getCode());
                    //设置本条数据上报开关为-开启
                    riskAnaUnit.setReportSwitch(SyncEnum.REPORT_ON.getCode());
                    //其他情况默认不开启上报数据，如果是手动上报，可对单条数据进行操作
                }else {
                    //设置上报状态为-不上报
                    riskAnaUnit.setReportStatus(SyncEnum.SYNC_NOT_EXEC.getCode());
                    //设置本条数据上报开关为-关闭
                    riskAnaUnit.setReportSwitch(SyncEnum.REPORT_OFF.getCode());
                }
                //封装数据
                riskUnitLists.add(riskAnaUnit);
            }
        } catch (IOException e) {
            throw new RuntimeException("读取上传文件发生错误{}"+e);
        }

        //插入
        for (PreventRiskAnaUnit riskUnit : riskUnitLists) {
            int result = preventRiskUnitService.saveRiskAnaUnit(riskUnit);
            sum = sum + result;
        }
        resultVO.setCount(sum);

        return resultVO;
    }

    /**
     * 安全风险事件-导入
     */
    @Transactional(propagation= Propagation.REQUIRED,timeout = 500)
    @Override
    public ResultVO<PreventRiskEvent> eventImport(ContextCacheUser currentUser, MultipartFile file) {

        ResultVO resultVO = new ResultVO<>();
        resultVO.setCode("200");
        resultVO.setMsg(" 安全风险事件数据导入成功");

        if (file == null){
            throw new AusinessException(E.DATA_PARAM_NULL, "找不到上传文件");
        }
        if (file.getSize() == 0){
            throw new AusinessException(E.DATA_PARAM_NULL, "文件内容为空");
        }
        if (!FileOptUtils.isDirExists(filePath)) {
            throw new AusinessException(E.DATA_PARAM_NULL, "发生错误或不为目录");
        }
        String fileSave = filePath + currentUser.getRealName() + "_"  + ".xlsx";
        int sum = 0;
        //获取list
        List<PreventRiskEvent> eventList = new ArrayList<>();

        try {
            file.transferTo(new File(fileSave));
            String name = file.getOriginalFilename();
            Boolean isExcel2007 = name.substring(name.lastIndexOf(".") + 1).endsWith("xlsx") ? true : false;
            InputStream in = new FileInputStream(fileSave);

            Workbook workbook = null;
            if (isExcel2007) {
                workbook = new XSSFWorkbook(in);
            } else {
                workbook = new HSSFWorkbook(in);
            }

            FormulaEvaluator evaluator = workbook.getCreationHelper().createFormulaEvaluator();
            Sheet sheet = workbook.getSheetAt(0);
            if (sheet == null) {
                throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "excel 第1页不能为空");
            }
            Row row = sheet.getRow(0);
            // 标题总列数
            int colNum = row.getPhysicalNumberOfCells();
            String[] title = new String[colNum];

            if (colNum != eventTitle.length) {
                throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "上传文件的列的个数错误");
            }
            for (int i = 0; i < colNum; i++) {

                title[i] = row.getCell(i).getStringCellValue();
                if (StringUtils.isNotBlank(title[i])) {
                    title[i] = title[i].trim();
                }
                if (!title[i].equals((eventTitle[i]))) {
                    throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "上传文件的第" + (i + 1) + "列的标题为" + title[i] + "不为" + eventTitle[i]);
                }
            }
            //遍历封装数据
            for (int irow = 1; irow <= sheet.getLastRowNum(); irow++) {
                int realRow = irow + 1;
                PreventRiskEvent event = new PreventRiskEvent();
                Object value = null;
                row = sheet.getRow(irow);

                //字段1-风险事件名称
                value = ExcelProperty.getCellValue(row.getCell(0), evaluator);
                if (null == value || StringUtils.isBlank(value.toString())) {
                    throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + realRow + "行,风险事件名称不能为空.<br/>");
                } else {
                    //通过部门名称查部门
                    PreventRiskEvent riskEventByName = preventRiskEventService.getRiskEventByName(value.toString().trim());
                    if (ObjectUtils.isEmpty(riskEventByName)){
                        event.setRiskEventName(value.toString().trim());
                    }else {
                        throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + realRow + "行,风险事件名称已经被使用，请为新事件添加编号、部门、设施.<br/>");
                    }
                }

                //字段2-安全风险分析单元
                value = ExcelProperty.getCellValue(row.getCell(1), evaluator);
                if (null == value || StringUtils.isBlank(value.toString())) {
                    throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + realRow + "行,安全风险分析单元名称不能为空.<br/>");
                } else {
                    PreventRiskAnaUnit riskUnitByName = preventRiskUnitService.getRiskUnitByName(value.toString().trim());
                    if (ObjectUtils.isEmpty(riskUnitByName)){
                        throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + realRow + "行,安全风险分析单元不存在或未录入系统.<br/>");
                    }else {
                        event.setRiskUnitId(riskUnitByName.getId());
                        event.setRiskUnitUuid(riskUnitByName.getUuid());
                    }
                }
                //字段3-可能造成的后果
                value = ExcelProperty.getCellValue(row.getCell(2), evaluator);
                if (null == value || StringUtils.isBlank(value.toString())) {
                    event.setEventResult(null);
                } else {
                    event.setEventResult(value.toString().trim());
                }

                //获取填充信息
                Date date = new Date();
                SnowFlow snowFlow = new SnowFlow();//雪花算法生成器
                String uuid = UUID.randomUUID().toString();
                //封装参数
                event.setId(snowFlow.nextId());
                event.setUuid(uuid);
                event.setDeleteStatus(StatusEnum.DELETE_STATUS_USE.getCode());
                event.setEnterpriseId((long) 1);
                event.setEnterpriseUuid("111");
                event.setGmtModitify(date);
                event.setGmtCreate(date);
                event.setCreateByUserName(currentUser.getRealName());
                event.setLastEditUserName(currentUser.getRealName());
                //读取上报主配置，设置属性
                PreventReportConfig reportConfigById = preventReportConfigService.getReportConfigById(SyncEnum.REPORT_CONFIG_RISK_EVENT.getCode());
                //设置上报时间为空
                event.setReportTime(null);
                //设置本条数据上报更新时间
                event.setUpdateReportDataTime(date);
                //读取上报主配置，进行任务记录上报配置,如果开启上报功能，且设置为自动上报,开启上报相关配置
                if (reportConfigById.getReportState() == SyncEnum.REPORT_ON.getCode()
                        && reportConfigById.getReportType() == SyncEnum.REPORT_HAND_EXEC_CONFIG.getCode()){
                    //设置上报状态为-等待上报
                    event.setReportStatus(SyncEnum.SYNC_WAIT_EXEC.getCode());
                    //设置本条数据上报开关为-开启
                    event.setReportSwitch(SyncEnum.REPORT_ON.getCode());
                    //其他情况默认不开启上报数据，如果是手动上报，可对单条数据进行操作
                }else {
                    //设置上报状态为-不上报
                    event.setReportStatus(SyncEnum.SYNC_NOT_EXEC.getCode());
                    //设置本条数据上报开关为-关闭
                    event.setReportSwitch(SyncEnum.REPORT_OFF.getCode());
                }

                eventList.add(event);
            }
        } catch (IOException e) {
            throw new RuntimeException("读取上传文件发生错误{}"+e);
        }

        //插入
        for (PreventRiskEvent event : eventList) {
            int result = preventRiskEventService.saveRiskEvent(event);
            sum = sum + result;
        }
        resultVO.setCount(sum);

        return resultVO;
    }



    /**
     * 管控措施-导入
     */
    @Transactional(propagation= Propagation.REQUIRED,timeout = 500)
    @Override
    public ResultVO<PreventRiskControlMeasure> measureImport(ContextCacheUser currentUser, MultipartFile file) {

        ResultVO resultVO = new ResultVO<>();
        resultVO.setCode("200");
        resultVO.setMsg(" 安全风险管控措施导入成功");

        if (file == null){
            throw new AusinessException(E.DATA_PARAM_NULL, "找不到上传文件");
        }
        if (file.getSize() == 0){
            throw new AusinessException(E.DATA_PARAM_NULL, "文件内容为空");
        }
        if (!FileOptUtils.isDirExists(filePath)) {
            throw new AusinessException(E.DATA_PARAM_NULL, "发生错误或不为目录");
        }
        String fileSave = filePath + currentUser.getRealName() + "_"  + ".xlsx";
        int sum = 0;
        //获取list
        List<PreventRiskControlMeasure> measureList = new ArrayList<>();
        List<PreventDangerCheckContent> checkContentList = new ArrayList<>();

        try {
            file.transferTo(new File(fileSave));
            String name = file.getOriginalFilename();
            Boolean isExcel2007 = name.substring(name.lastIndexOf(".") + 1).endsWith("xlsx") ? true : false;
            InputStream in = new FileInputStream(fileSave);

            Workbook workbook = null;
            if (isExcel2007) {
                workbook = new XSSFWorkbook(in);
            } else {
                workbook = new HSSFWorkbook(in);
            }

            FormulaEvaluator evaluator = workbook.getCreationHelper().createFormulaEvaluator();
            Sheet sheet = workbook.getSheetAt(0);
            if (sheet == null) {
                throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "excel 第1页不能为空");
            }
            Row row = sheet.getRow(0);
            // 标题总列数
            int colNum = row.getPhysicalNumberOfCells();
            String[] title = new String[colNum];

            if (colNum != measureTitle.length) {
                throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "上传文件的列的个数错误");
            }
            for (int i = 0; i < colNum; i++) {

                title[i] = row.getCell(i).getStringCellValue();
                if (StringUtils.isNotBlank(title[i])) {
                    title[i] = title[i].trim();
                }
                if (!title[i].equals((measureTitle[i]))) {
                    throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "上传文件的第" + (i+1) + "列的标题为" + title[i] + "不为" + measureTitle[i]);
                }
            }
            //遍历封装数据
            for (int irow = 1; irow <= sheet.getLastRowNum(); irow++) {
                int realRow = irow + 1;
                PreventRiskControlMeasure measure = new PreventRiskControlMeasure();
                PreventDangerCheckContent checkContent = new PreventDangerCheckContent();
                Object value = null;
                Object value1 = null;
                row = sheet.getRow(irow);

                //字段1-风险事件名称 封装eventId 与 eventUuid
                value = ExcelProperty.getCellValue(row.getCell(0), evaluator);
                if (null == value || StringUtils.isBlank(value.toString())) {
                    throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + realRow + "行,风险事件名称不能为空.<br/>");
                } else {
                    //通过名称查事件
                    PreventRiskEvent riskEventByName = preventRiskEventService.getRiskEventByName(value.toString().trim());
                    if (ObjectUtils.isEmpty(riskEventByName)){
                        throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + realRow + "行,风险事件不存在或未录入系统.<br/>");
                    }else {
                        measure.setRiskEventId(riskEventByName.getId());
                        measure.setRiskEventUuid(riskEventByName.getUuid());
                    }
                }

                //字段2-管控措施编号
                value = ExcelProperty.getCellValue(row.getCell(1), evaluator);
                if (null == value || StringUtils.isBlank(value.toString())) {
                    throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + realRow + "行,管控措施编号不能为空.<br/>");
                } else {
                    PreventRiskControlMeasure controlMeasureByCode = preventRiskControlMeasureService.getControlMeasureByCode(value.toString().trim());
                    if (ObjectUtils.isEmpty(controlMeasureByCode)){
                        measure.setControlMeasureCode(value.toString().trim());
                    }else {
                        throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + realRow + "行,管控措施编号已经被使用.<br/>");
                    }
                }

                //字段3-管控方式
                value = ExcelProperty.getCellValue(row.getCell(2), evaluator);
                if (null == value || StringUtils.isBlank(value.toString())) {
                    throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + realRow + "行,管控方式不能为空.<br/>");
                } else {
                    if (value.toString().trim().equals("自动化监控")){
                        measure.setControlType((byte) 1);
                    }else if (value.toString().trim().equals("隐患排查")){
                        measure.setControlType((byte) 2);
                    }else {
                        throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + realRow + "行,管控方式不符合要求.<br/>");
                    }
                }


                //字段4、5-管控措施分类1、管控措施分类2
                value = ExcelProperty.getCellValue(row.getCell(3), evaluator);
                value1 = ExcelProperty.getCellValue(row.getCell(4), evaluator);
                if (null == value || StringUtils.isBlank(value.toString())) {
                    throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + realRow + "行,管控措施分类1不能为空.<br/>");
                } else if (null == value1 || StringUtils.isBlank(value.toString())){
                    throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + realRow + "行,管控措施分类2不能为空.<br/>");
                }else {
                    //todo 需要检查此方法返回值是否正确
                    PreventRiskControlTemplateDO classify1AndClassify2 = preventRiskControlTemplateService.getByClassify1AndClassify2(value.toString().trim(), value1.toString().trim());
                    if (ObjectUtils.isEmpty(classify1AndClassify2)){
                        throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + realRow + "行,管控措施分类1与管控措施分类2不符合规范或者不是父子层级.<br/>");
                    }else {
                        measure.setClassify1(classify1AndClassify2.getClassify1Id());
                        measure.setClassify2(classify1AndClassify2.getClassify2Id());
                    }
                }

                //字段6-管控措施分类3
                value = ExcelProperty.getCellValue(row.getCell(5), evaluator);
                if (null == value || StringUtils.isBlank(value.toString())) {
                    measure.setClassify3(null);
                } else {
                    measure.setClassify3(value.toString().trim());
                }

                //字段7-管控措施描述
                value = ExcelProperty.getCellValue(row.getCell(6), evaluator);
                if (null == value || StringUtils.isBlank(value.toString())) {
                    measure.setMeasureDesc(null);
                } else {
                    measure.setMeasureDesc(value.toString().trim());
                }

                //字段7-隐患排查内容
                value = ExcelProperty.getCellValue(row.getCell(7), evaluator);
                if (null == value || StringUtils.isBlank(value.toString())) {
                    throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "文件不符合要求,第" + realRow  + "行,隐患排查内容不能为空.<br/>");
                } else {
                    checkContent.setCheckContent(value.toString().trim());
                }

                //获取填充信息
                Date date = new Date();
                SnowFlow snowFlow = new SnowFlow();//雪花算法生成器
                String uuid = UUID.randomUUID().toString();
                long measureId = snowFlow.nextId();
                //封装管控措施参数
                measure.setId(measureId);
                measure.setUuid(uuid);
                measure.setEnterpriseId((long) 1);
                measure.setEnterpriseUuid("123");
                measure.setDeleteStatus(StatusEnum.DELETE_STATUS_USE.getCode());
                measure.setGmtModitify(date);
                measure.setGmtCreate(date);
                measure.setCreateByUserName(currentUser.getRealName());
                measure.setLastEditUserName(currentUser.getRealName());
                measure.setCheckTaskUnitId(null);
                measure.setCheckTaskUnitUuid(null);
                measure.setCheckWorkId(null);
                measure.setCheckWorkUuid(null);
                measure.setCheckTaskId(null);
                measure.setCheckTaskUuid(null);

                //封装隐患检查内容的参数
                checkContent.setControlMeasureId(measureId);
                checkContent.setControlMeasureUuid(uuid);

                PreventReportConfig reportConfigById = preventReportConfigService.getReportConfigById(SyncEnum.REPORT_CONFIG_RISK_MEASURE.getCode());
                //设置上报时间为空
                measure.setReportTime(null);
                //设置本条数据上报更新时间
                measure.setUpdateReportDataTime(date);
                //读取上报主配置，进行任务记录上报配置,如果开启上报功能，且设置为自动上报,开启上报相关配置
                if (reportConfigById.getReportState() == SyncEnum.REPORT_ON.getCode()
                        && reportConfigById.getReportType() == SyncEnum.REPORT_HAND_EXEC_CONFIG.getCode()){
                    //设置上报状态为-等待上报
                    measure.setReportStatus(SyncEnum.SYNC_WAIT_EXEC.getCode());
                    //设置本条数据上报开关为-开启
                    measure.setReportSwitch(SyncEnum.REPORT_ON.getCode());
                    //其他情况默认不开启上报数据，如果是手动上报，可对单条数据进行操作
                }else {
                    //设置上报状态为-不上报
                    measure.setReportStatus(SyncEnum.SYNC_NOT_EXEC.getCode());
                    //设置本条数据上报开关为-关闭
                    measure.setReportSwitch(SyncEnum.REPORT_OFF.getCode());
                }

                measureList.add(measure);
                checkContentList.add(checkContent);
            }
        } catch (IOException e) {
            throw new RuntimeException("读取上传文件发生错误{}"+e);
        }

        //插入
        for (PreventRiskControlMeasure measure : measureList) {
            int result = preventRiskControlMeasureService.saveRiskControlMeasure(measure);
            sum = sum + result;
        }
        //保存排查内容
        for (PreventDangerCheckContent checkContent : checkContentList) {
            int result = preventDangerCheckContentService.saveDangerCheckContent(checkContent);
        }
        resultVO.setCount(sum);

        return resultVO;
    }
}