package com.gk.hotwork.Service.ServiceImpl;

import com.baomidou.mybatisplus.core.metadata.IPage;
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.RiskSource;
import com.gk.hotwork.Domain.UserInfo;
import com.gk.hotwork.Domain.Vo.RiskEventExportVo;
import com.gk.hotwork.Domain.Vo.RiskSourceSearchVo;
import com.gk.hotwork.Domain.Vo.RiskSourceVo;
import com.gk.hotwork.Domain.dto.RiskSourceDto;
import com.gk.hotwork.Domain.Utils.BeanUtils;
import com.gk.hotwork.Domain.Utils.StringUtils;
import com.gk.hotwork.Domain.dto.RiskSourceUpdateDto;
import com.gk.hotwork.Mapper.RiskSourceMapper;
import com.gk.hotwork.Service.DepartmentService;
import com.gk.hotwork.Service.RiskSourceService;
import com.gk.hotwork.Service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

@Service("RiskSourceService")
public class RiskSourceServiceImpl extends ServiceImpl<RiskSourceMapper, RiskSource> implements RiskSourceService {

    @Autowired
    private RiskSourceMapper riskSourceMapper;

    @Autowired
    private UserService userService;

    @Autowired
    private DepartmentService departmentService;

    @Override
    public IPage<RiskSource> findRiskSourceListByConditions(Page<RiskSource> page, RiskSourceSearchVo searchVo) {
        return riskSourceMapper.findRiskSourceListByConditionsAndPage(page,searchVo);
    }

    @Override
    public RiskSource findById(Long id) {
        return riskSourceMapper.selectById(id);
    }

    @Override
    public boolean updateById(RiskSourceUpdateDto riskSourceUpdateDto) {
        if(riskSourceUpdateDto.getId() == null || riskSourceUpdateDto.getId() <= 0){
            return false;
        }
        boolean updateResult = false;
        RiskSource riskSource = riskSourceMapper.selectById(riskSourceUpdateDto.getId());
        if(riskSource!=null && riskSource.getId() >0){
            //校验数据
            String checkResult = checkRiskSourceForUpdate(riskSource,riskSourceUpdateDto);
            if(checkResult.equals("Y")){
                riskSource.setEditTime(new Date());
                if(riskSourceMapper.updateById(riskSource) > 0){
                    updateResult = true;
                }
            }
        }
        return updateResult;
    }

    @Override
    public boolean insertOne(RiskSourceDto riskSourceDto) {
        RiskSource riskSource = new RiskSource();
        BeanUtils.copyProperties(riskSourceDto,riskSource);
        riskSource.setStatus((byte)1);
        riskSource.setCreateTime(new Date());
        riskSource.setEditTime(riskSource.getCreateTime());
        if(!checkRiskSourceForCreate(riskSource)){
            return false;
        }
        if(riskSourceMapper.insert(riskSource) > 0){
            return true;
        }else {
            return false;
        }
    }

    @Override
    public void delOne(Long id, UserInfo user) {
        if (id == null) throw new BusinessException("id参数为空");
        if (this.getById(id) == null) throw new BusinessException("找不到风险源");
        RiskSource riskSource = new RiskSource();
        riskSource.setId(id);
        riskSource.setStatus((byte)3);
        boolean success = this.updateById(riskSource);
        if (!success) throw new BusinessException("删除失败，请联系管理员");

    }



    private boolean checkRiskSourceForCreate(RiskSource riskSource){
        //检查用户是否存在
        boolean flag = true;
        if(riskSource == null){
            flag = false;
            return flag;
        }
        if(riskSource.getCreateUid() !=null && riskSource.getEditUid() !=null){
            UserInfo u1 = userService.getById(riskSource.getCreateUid());
            UserInfo u2 = userService.getById(riskSource.getEditUid());
            if(u1==null || u1.getId() <=0 || u2 == null || u2.getId() <= 0){
                flag = false;
            }else {
                riskSource.setEditUname(u2.getRealname());
            }
        }else {
            flag = false;
        }
        //检查部门是否存在
        if(riskSource.getDepId() != null){
            DepartmentInfo departmentInfo = departmentService.getById(riskSource.getDepId());
            if(departmentInfo == null || departmentInfo.getId() <= 0){
                flag = false;
            }else {
                riskSource.setDepName(departmentInfo.getDepartment());
            }
        }else {
            flag = false;
        }

        //检查状态值、类型值是否支持
        if(riskSource.getType() != null && riskSource.getType() != 1 && riskSource.getType() != 2){
            flag = false;
        }
        if(riskSource.getStatus() != 1 && riskSource.getStatus() != 2 && riskSource.getStatus() != 3){
            flag = false;
        }
        //检查风险等级是否支持
        if(riskSource.getLevel() != 1 && riskSource.getLevel() != 2 && riskSource.getLevel() != 3 && riskSource.getLevel() != 4){
            flag = false;
        }
        return flag;
    }

    private String checkRiskSourceForUpdate(RiskSource riskSource,RiskSourceUpdateDto updateDto){
        boolean checkResult = true;
        boolean editFlag = false;
        if(riskSource == null || riskSource.getId() <= 0 || updateDto == null || updateDto.getId() <= 0){
            return "风险源不存在";
        }
        //检查部门
        if(updateDto.getDepId() != null && updateDto.getDepId() != riskSource.getDepId()){
            DepartmentInfo departmentInfo = departmentService.getById(riskSource.getDepId());
            if(departmentInfo == null){
                return "部门不存在";
            }else {
                riskSource.setDepId(departmentInfo.getId());
                riskSource.setDepName(departmentInfo.getDepartment());
                editFlag = true;
            }
        }
        //检查类型变更
        if(updateDto.getType() != null && updateDto.getType() != riskSource.getType()){
            if(updateDto.getType().byteValue() == 1 || updateDto.getType().byteValue() == 2){
                riskSource.setType(updateDto.getType());
                editFlag = true;
            }else {
                return "类型不支持";
            }
        }
        //风险等级
        if(updateDto.getLevel() != null && updateDto.getLevel() != riskSource.getLevel()){
            if(updateDto.getLevel().byteValue() == 1 || updateDto.getLevel().byteValue() == 2
                    || updateDto.getLevel().byteValue() == 3 || updateDto.getLevel().byteValue() == 4){
                riskSource.setLevel(updateDto.getLevel());
                editFlag = true;
            }else {
                return "风险等级不支持";
            }
        }
        //名称变动
        if(updateDto.getName() != null && !updateDto.getName().equals(riskSource.getName())){
            if(updateDto.getName().length() > 15){
                return "风险名称超过15个字符";
            }else {
                riskSource.setName(updateDto.getName());
                editFlag = true;
            }
        }
        //位置变动
        if(updateDto.getLocation() != null && !updateDto.getLocation().equals(riskSource.getLocation())){
            if(updateDto.getLocation().length() > 30){
                return "位置描述超过30个字符";
            }else {
                riskSource.setLocation(updateDto.getLocation());
                editFlag = true;
            }
        }
        //风险描述变动
        if(updateDto.getAccidentDesc() != null && !updateDto.getAccidentDesc().equals(riskSource.getAccidentDesc())){
            if(updateDto.getAccidentDesc().length() > 50){
                return "事故秒数超过50个字符";
            }else {
                riskSource.setAccidentDesc(updateDto.getAccidentDesc());
                editFlag = true;
            }
        }
        if(editFlag == true){
            UserInfo userInfo = userService.getById(updateDto.getEditUid());
            if(userInfo!=null && userInfo.getId()>0){
                riskSource.setEditUid(userInfo.getId());
                riskSource.setEditUname(userInfo.getRealname());
                return "Y";
            }else {
                return "N";
            }
        }else {
            return "N";
        }
    }

    /** 生产装置导出 */
    @Override
    public List<RiskSourceVo> getRiskSourceExport(HttpServletRequest request, HttpServletResponse response) {

        List<RiskSource> risklist = riskSourceMapper.getRiskSourceList();
        List<RiskSourceVo> list = new ArrayList<>();

        for (RiskSource riskSource : risklist) {
            RiskSourceVo copy = BeanUtils.copy(riskSource, RiskSourceVo.class);
            list.add(copy);
        }
        return list;
    }
}