package com.gk.hotwork.Service.ServiceImpl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
import com.baomidou.mybatisplus.extension.api.R;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.gk.hotwork.Domain.DepartmentInfo;
import com.gk.hotwork.Domain.Exception.BusinessException;
import com.gk.hotwork.Domain.RiskAnaUnit;
import com.gk.hotwork.Domain.RiskEvent;
import com.gk.hotwork.Domain.UserInfo;
import com.gk.hotwork.Domain.Utils.BeanUtils;
import com.gk.hotwork.Domain.Utils.StringUtils;
import com.gk.hotwork.Domain.Vo.RiskAnaUintExoprtVo;
import com.gk.hotwork.Domain.Vo.RiskEventExportVo;
import com.gk.hotwork.Mapper.RiskAnaUintMapper;
import com.gk.hotwork.Service.DepartmentService;
import com.gk.hotwork.Service.RiskAnaUnitService;
import com.gk.hotwork.Service.RiskEventService;
import com.gk.hotwork.Service.UserService;
import io.netty.util.internal.ObjectUtil;
import lombok.SneakyThrows;
import org.apache.commons.lang3.ObjectUtils;
import org.apache.poi.hssf.usermodel.*;
import org.apache.poi.ss.usermodel.HorizontalAlignment;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.File;
import java.io.FileOutputStream;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;

/**
* @author celin
* @date 2022/3/16 14:40
*/
@Service("riskAnaUnitService")
public class RiskAnaUnitServiceImpl extends ServiceImpl<RiskAnaUintMapper,RiskAnaUnit> implements RiskAnaUnitService {

    @Autowired
    private RiskAnaUintMapper riskAnaUintMapper;
    @Autowired
    private DepartmentService departmentService;
    @Autowired
    private RiskEventService riskEventService;
    @Autowired
    private UserService userService;

    /**
    * @Description: 分页查询
    * @date 2022/3/16 10:01
    */
    @Override
    public IPage<RiskAnaUnit> selectPage(Page<RiskAnaUnit> page, Map<String, Object> filter, UserInfo user) {
        return riskAnaUintMapper.selectPages(page,filter,user);
    }

    /**
    * @Description: 新增记录
    */
    @Override
    public void addOne(RiskAnaUnit riskAnaUnitVo,UserInfo userInfo) {
        Date date = new Date();
        //判空
        if (riskAnaUnitVo.getHazardDepId() == null) throw new BusinessException("部门id参数为空");
        if (riskAnaUnitVo.getHazardLiablePersonId() == null) throw new BusinessException("负责人id参数为空");
        DepartmentInfo department = departmentService.getById(riskAnaUnitVo.getHazardDepId());
        if (department == null) throw new BusinessException("部门不存在");
        UserInfo hazardLiablePerson = userService.getById(riskAnaUnitVo.getHazardLiablePersonId());
        if(hazardLiablePerson == null) throw new BusinessException("择负责人不存在");
        if(StringUtils.isBlank(riskAnaUnitVo.getRiskUnitName())) throw new BusinessException("请填写安全风险分析单元名称");
        if(StringUtils.isBlank(riskAnaUnitVo.getHazardCode())) throw new BusinessException("请填写危险源编码");
        //编号待定
        riskAnaUnitVo.setCreateTime(date);
        riskAnaUnitVo.setUpdateTime(date);
        riskAnaUnitVo.setCreateBy(userInfo.getRealname());
        riskAnaUnitVo.setUpdateBy(userInfo.getRealname());
        riskAnaUnitVo.setValidFlag(Boolean.TRUE);
        this.save(riskAnaUnitVo);
    }

    /**
    * @Description: 修改信息
    */

    @Override
    public void modOne(RiskAnaUnit riskAnaUnitVo, UserInfo user) {
        if (riskAnaUnitVo.getId() == null) throw new BusinessException("id参数为空");
        int count = this.count(new LambdaQueryWrapper<RiskAnaUnit>().eq(RiskAnaUnit::getId, riskAnaUnitVo.getId()));
        if (count < 1) throw new BusinessException("未找到相应实体");
        //判空
        if (riskAnaUnitVo.getHazardDepId() == null) throw new BusinessException("部门id参数为空");
        DepartmentInfo department = departmentService.getById(riskAnaUnitVo.getHazardDepId());
        if (department == null) throw new BusinessException("部门不存在");
        if (riskAnaUnitVo.getHazardLiablePersonId() == null) throw new BusinessException("负责人id参数为空");
        UserInfo hazardLiablePerson = userService.getById(riskAnaUnitVo.getHazardLiablePersonId());
        if(hazardLiablePerson == null) throw new BusinessException("择负责人不存在");
        if(StringUtils.isBlank(riskAnaUnitVo.getRiskUnitName())) throw new BusinessException("请填写安全风险分析单元名称");
        riskAnaUnitVo.setUpdateBy(user.getRealname());
        riskAnaUnitVo.setUpdateTime(new Date());
        this.updateById(riskAnaUnitVo);
    }


    /**
    * @Description: 删除
    */
    @Override
    public void delOne(Long id, UserInfo userInfo) {
        if (id == null) throw new BusinessException("id参数为空");
        RiskAnaUnit riskAnaUnit = this.getById(id);
        if (riskAnaUnit == null) throw new BusinessException("未找到相应实体");
        int count = riskEventService.count(new LambdaQueryWrapper<RiskEvent>()
                .eq(RiskEvent::getRiskUnitId, riskAnaUnit.getId())
                .eq(RiskEvent::getValidFlag, Boolean.TRUE));
        if (count > 0) throw new BusinessException("安全风险分析单元仍然绑定安全风险事件,无法删除");
        RiskAnaUnit delOne = new RiskAnaUnit();
        delOne.setId(id);
        delOne.setValidFlag(Boolean.FALSE);
        delOne.setUpdateBy(userInfo.getRealname());
        delOne.setUpdateTime(new Date());
        this.updateById(delOne);
    }

    @Override
    public List<Map> selectDepartmentAnalysis() {
        return riskAnaUintMapper.selectDepartmentAnalysis();
    }

    @SneakyThrows
    @Override
    public List<RiskAnaUintExoprtVo> getInfo(HttpServletRequest request, HttpServletResponse response) {

        List<RiskAnaUnit> riskAnaUnitlist = riskAnaUintMapper.getInfo();
        List<RiskAnaUintExoprtVo> list = new ArrayList<>();

        for (RiskAnaUnit riskAnaUnit : riskAnaUnitlist) {
            RiskAnaUintExoprtVo copy = BeanUtils.copy(riskAnaUnit, RiskAnaUintExoprtVo.class);
            list.add(copy);
        }

        return list;

    /*    //第一步创建一个webbook,对应一个Excel文件
        HSSFWorkbook wb=new HSSFWorkbook();
        //第二步,在webbook中添加一个sheet,对应Excel文件中的sheet
        HSSFSheet sheet=wb.createSheet("管控措施");
        //第三步，在sheet中添加表头第0行
        HSSFRow row = sheet.createRow(0);
        //第四步，创建单元格，并设置表头居中
        HSSFCellStyle style = wb.createCellStyle();
        style.setAlignment(HorizontalAlignment.CENTER);//居中格式

        HSSFCell cell = row.createCell(0);
        cell.setCellValue("安全风险对象编码");
        cell.setCellStyle(style);

        cell=row.createCell((short)1);
        cell.setCellValue("安全风险单元名称");
        cell.setCellStyle(style);

        cell=row.createCell((short)2);
        cell.setCellValue("责任人");
        cell.setCellStyle(style);

        cell=row.createCell((short)3);
        cell.setCellValue("责任部门");
        cell.setCellStyle(style);

        for (int i = 0; i < list.size(); i++) {
            //创建单元格，并赋值
            row=sheet.createRow(i+1);
            RiskAnaUnit riskAnaUnit = list.get(i);

            row.createCell((short) 0).setCellValue(riskAnaUnit.getHazardCode());
            row.createCell((short)1).setCellValue(riskAnaUnit.getRiskUnitName());
            row.createCell((short)2).setCellValue(riskAnaUnit.getHazardLiablePerson());
            row.createCell((short)3).setCellValue(riskAnaUnit.getHazardDep());

        }
        //第六步，下载Excel
        FileOutputStream fileOutputStream = new FileOutputStream(new File("D:\\安全风险分析单元.xls"));
        wb.write(fileOutputStream);*/

    }

    @Override
    public RiskAnaUnit getInfoByRiskUnitName(String riskUnitName) {
        //riskAnaUintMapper.getInfoByRiskUnitName(riskUnitName);
        return riskAnaUintMapper.getInfoByRiskUnitName(riskUnitName);
    }
    @Transactional
    @Override
    public void importRiskAnaUnit(List<RiskAnaUintExoprtVo> param, UserInfo user) {

        if (CollectionUtils.isEmpty(param)){
            throw new BusinessException("文件不能为空");
        }

        for (RiskAnaUintExoprtVo riskAnaUintVo : param) {
            /**传入字段
             * 风险源编码hazardCode 风险单元名称riskUnitName 责任人hazardLiablePerson 责任部门hazardDep
             * 补充字段
             * 创建时间，修改时间，创建人，修改人，有效状态，责任人id，责任部门id
             * */
           DepartmentInfo departmentInfo = departmentService.getInfoByName(riskAnaUintVo.getHazardDep());
           if (departmentInfo.getDepartment() == null) throw new BusinessException("部门不存在");

           UserInfo userInfo = userService.getByRealName(riskAnaUintVo.getHazardLiablePerson(), departmentInfo.getDepartment());
           if (ObjectUtils.isEmpty(userInfo)) throw new BusinessException("负责人不存在");

           if (riskAnaUintVo.getHazardCode() == null && riskAnaUintVo.getRiskUnitName() == null){
               throw new BusinessException("生产装置编码与风险单元名称不能为空");
           }
           RiskAnaUnit riskAnaUnit = new RiskAnaUnit();

            riskAnaUnit.setHazardCode(riskAnaUintVo.getHazardCode());
            riskAnaUnit.setRiskUnitName(riskAnaUintVo.getRiskUnitName());
            riskAnaUnit.setHazardLiablePerson(riskAnaUintVo.getHazardLiablePerson());
            riskAnaUnit.setHazardDep(riskAnaUintVo.getHazardDep());

           riskAnaUnit.setHazardDepId(departmentInfo.getId());
           riskAnaUnit.setHazardLiablePersonId(userInfo.getId());
           riskAnaUnit.setCreateTime(new Date());
           riskAnaUnit.setUpdateTime(new Date());
           riskAnaUnit.setCreateBy(user.getRealname());
           riskAnaUnit.setUpdateBy(user.getRealname());
           riskAnaUnit.setValidFlag(Boolean.TRUE);
           this.save(riskAnaUnit);
        }
    }

}