package com.ruoyi.doublePrevention.service.baseService.impl;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.github.pagehelper.Page;
import com.github.pagehelper.PageHelper;
import com.ruoyi.common.exception.BusinessException;
import com.ruoyi.common.utils.BeanCopyUtils;
import com.ruoyi.doublePrevention.entity.PreventRiskDangerCheckLog;
import com.ruoyi.doublePrevention.entity.RiskAndPeopleInfo;
import com.ruoyi.doublePrevention.entity.dto.req.RiskAndPeopleInfoReqBO;
import com.ruoyi.doublePrevention.entity.dto.resp.RiskAndPeopleInfoDTO;
import com.ruoyi.doublePrevention.entity.dto.resp.RiskAndPeopleInfoRespDTO;
import com.ruoyi.doublePrevention.repository.RiskAndPeopleInfoRepository;
import com.ruoyi.doublePrevention.service.baseService.PreventRiskDangerCheckLogService;
import com.ruoyi.doublePrevention.service.baseService.RiskAndPeopleInfoService;
import com.ruoyi.doublePrevention.vo.ResultVO;
import com.ruoyi.project.tr.HiddenDangerCheckJob.domain.HiddenDangerCheckJobLog;
import com.ruoyi.project.tr.HiddenDangerCheckJob.service.IHiddenDangerCheckJobLogService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.ObjectUtils;
import org.springframework.web.bind.annotation.RequestBody;

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

@Service("RiskAndPeopleInfoService")
public class RiskAndPeopleInfoServiceImpl  extends ServiceImpl<RiskAndPeopleInfoRepository, RiskAndPeopleInfo> implements RiskAndPeopleInfoService {

    @Autowired
    private RiskAndPeopleInfoRepository repository;

    @Autowired
    private IHiddenDangerCheckJobLogService hiddenDangerCheckJobLogService;

    @Autowired
    private PreventRiskDangerCheckLogService preventRiskDangerCheckLogService;

    @Override
    public ResultVO<RiskAndPeopleInfoRespDTO> listRiskAndPeoplePage(RiskAndPeopleInfoReqBO reqBO) {

        ResultVO resultVO = new ResultVO<>();

        RiskAndPeopleInfoRespDTO respDTO = new RiskAndPeopleInfoRespDTO();

        if (ObjectUtils.isEmpty(reqBO.getPageSize())){
            throw new BusinessException("分页信息不能为空");
        }
        if (ObjectUtils.isEmpty(reqBO.getPageNum())){
            throw new BusinessException("分页信息不能为空");
        }

        Integer pageIndex = reqBO.getPageNum();
        Integer pageSize = reqBO.getPageSize();

        Page<RiskAndPeopleInfo> page = PageHelper.startPage(pageIndex, pageSize);
        List<RiskAndPeopleInfo> riskOldInfo = repository.listRiskAndPeoplePage(reqBO);

        List<HiddenDangerCheckJobLog> allCheckJobLogList = new ArrayList<>();
        List<HiddenDangerCheckJobLog>  completeCheckJobLogList = new ArrayList<>();
        List<HiddenDangerCheckJobLog> allCheckJobLogListOfHandle = new ArrayList<>();
        List<HiddenDangerCheckJobLog> completeCheckJobLogListOfHandle = new ArrayList<>();
        List<HiddenDangerCheckJobLog> allCheckJobLogListOfTechnology = new ArrayList<>();
        List<HiddenDangerCheckJobLog> completeCheckJobLogListOfTechnology = new ArrayList<>();
        List<HiddenDangerCheckJobLog> allCheckJobLogListOfMain = new ArrayList<>();
        List<HiddenDangerCheckJobLog> completeCheckJobLogListOfMain = new ArrayList<>();

        for (RiskAndPeopleInfo riskAndPeopleInfo : riskOldInfo) {
            //操作人的id，依此为依据，查询所有的任务记录 check_user_id
            List<HiddenDangerCheckJobLog> jobLogOfHandle = hiddenDangerCheckJobLogService.getJobLogByCheckUserId(riskAndPeopleInfo.getHandleLiabilityPersonId());
            if (jobLogOfHandle.size() > 0){
                for (HiddenDangerCheckJobLog jobLog : jobLogOfHandle) {
                    PreventRiskDangerCheckLog preventRiskDangerCheckLog = preventRiskDangerCheckLogService.getByDangerCheckByJobId(jobLog.getJobId());
                    if (preventRiskDangerCheckLog.getCheckStatus() != 3){
                        completeCheckJobLogListOfHandle.add(jobLog);
                        completeCheckJobLogList.add(jobLog);
                    }
                    allCheckJobLogListOfHandle.add(jobLog);
                    allCheckJobLogList.add(jobLog);
                }
            }

            //技术负责人的id，依此为依据，查询所有的任务记录 check_user_id
            List<HiddenDangerCheckJobLog> jobLogListsOfTechnology = hiddenDangerCheckJobLogService.getJobLogByCheckUserId(riskAndPeopleInfo.getTechnologyLiabilityPersonId());
            if (jobLogListsOfTechnology.size() > 0){
                for (HiddenDangerCheckJobLog jobLog : jobLogListsOfTechnology) {
                    PreventRiskDangerCheckLog preventRiskDangerCheckLog = preventRiskDangerCheckLogService.getByDangerCheckByJobId(jobLog.getJobId());
                    if (preventRiskDangerCheckLog.getCheckStatus() != 3){
                        completeCheckJobLogListOfTechnology.add(jobLog);
                        completeCheckJobLogList.add(jobLog);
                    }
                    allCheckJobLogListOfTechnology.add(jobLog);
                    allCheckJobLogList.add(jobLog);
                }
            }

            //主要负责人的id，依此为依据，查询所有的任务记录 check_user_id
            List<HiddenDangerCheckJobLog> jobLogListsOfMain = hiddenDangerCheckJobLogService.getJobLogByCheckUserId(riskAndPeopleInfo.getMainLiabilityPersonId());
            if (jobLogListsOfMain.size() > 0){
                for (HiddenDangerCheckJobLog jobLog : jobLogListsOfMain) {
                    PreventRiskDangerCheckLog preventRiskDangerCheckLog = preventRiskDangerCheckLogService.getByDangerCheckByJobId(jobLog.getJobId());
                    if (preventRiskDangerCheckLog.getCheckStatus() != 3){
                        completeCheckJobLogListOfMain.add(jobLog);
                        completeCheckJobLogList.add(jobLog);
                    }
                    allCheckJobLogListOfMain.add(jobLog);
                    allCheckJobLogList.add(jobLog);
                }
            }
        }

        List<RiskAndPeopleInfoDTO> riskAndPeopleList = BeanCopyUtils.copyBeanList(riskOldInfo, RiskAndPeopleInfoDTO.class);

        int completeRatio = 0;
        if (allCheckJobLogList.size() > 0){
            completeRatio = completeCheckJobLogList.size() / allCheckJobLogList.size();
        }

        int completeRatioOfHandle = 0;
        if (allCheckJobLogListOfHandle.size() > 0){
            completeRatioOfHandle = completeCheckJobLogListOfHandle.size() / allCheckJobLogListOfHandle.size();
        }

        int completeRatioOfTechnology = 0;
        if (allCheckJobLogListOfTechnology.size() > 0){
            completeRatioOfTechnology = completeCheckJobLogListOfTechnology.size() / allCheckJobLogListOfTechnology.size();
        }

        int completeRatioOfMain = 0;
        if (allCheckJobLogListOfMain.size() > 0){
            completeRatioOfMain = completeCheckJobLogListOfMain.size() / allCheckJobLogListOfMain.size();
        }
        respDTO.setRiskAndPeopleInfoDTO(riskAndPeopleList);
        respDTO.setCount(allCheckJobLogList.size());
        respDTO.setComplete(completeCheckJobLogList.size());
        respDTO.setCompleteRatio(BigDecimal.valueOf(completeRatio));

        respDTO.setCountOfHandle(allCheckJobLogListOfHandle.size());
        respDTO.setCompleteOfHandle(completeCheckJobLogListOfHandle.size());
        respDTO.setCompleteRatioOfHandle(BigDecimal.valueOf(completeRatioOfHandle));

        respDTO.setCountOfTechnology(allCheckJobLogListOfTechnology.size());
        respDTO.setCompleteOfTechnology(completeCheckJobLogListOfTechnology.size());
        respDTO.setCompleteRatioOfTechnology(BigDecimal.valueOf(completeRatioOfTechnology));

        respDTO.setCountOfMain(allCheckJobLogListOfMain.size());
        respDTO.setCompleteOfMain(completeCheckJobLogListOfMain.size());
        respDTO.setCompleteRatioOfMain(BigDecimal.valueOf(completeRatioOfMain));

        resultVO.setPageSize(pageSize);
        resultVO.setPageNum(pageIndex);
        resultVO.setCount((int) page.getTotal());
        resultVO.setData(respDTO);

        return resultVO;
    }


    @Override
    public RiskAndPeopleInfo selectRiskAndPeopleInfoById(Long id) {
        return repository.selectRiskAndPeopleInfoById(id);
    }
}