From 135a322f44708b1187d37ea4b6859b5d82113e89 Mon Sep 17 00:00:00 2001 From: kongzy <kongzy> Date: 星期三, 14 八月 2024 11:00:30 +0800 Subject: [PATCH] update gitignore --- src/main/java/com/ruoyi/doublePrevention/service/baseService/impl/RiskAndPeopleInfoServiceImpl.java | 328 +++++++++++++++++++++++++++--------------------------- 1 files changed, 164 insertions(+), 164 deletions(-) diff --git a/src/main/java/com/ruoyi/doublePrevention/service/baseService/impl/RiskAndPeopleInfoServiceImpl.java b/src/main/java/com/ruoyi/doublePrevention/service/baseService/impl/RiskAndPeopleInfoServiceImpl.java index 66babe9..8431dd7 100644 --- a/src/main/java/com/ruoyi/doublePrevention/service/baseService/impl/RiskAndPeopleInfoServiceImpl.java +++ b/src/main/java/com/ruoyi/doublePrevention/service/baseService/impl/RiskAndPeopleInfoServiceImpl.java @@ -1,164 +1,164 @@ -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); - } -} +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); + } +} -- Gitblit v1.9.2