From 7d1e2e5640def6b283f76555681b0a3e62b2a338 Mon Sep 17 00:00:00 2001 From: 16639036659 <577530412@qq.com> Date: 星期四, 13 六月 2024 08:56:24 +0800 Subject: [PATCH] 临时提交 --- src/main/java/com/ruoyi/project/tr/specialCheck/service/impl/SpecialCheckItemDangerLogServiceImpl.java | 72 +++++++++++++++++++++++++++++++++--- 1 files changed, 66 insertions(+), 6 deletions(-) diff --git a/src/main/java/com/ruoyi/project/tr/specialCheck/service/impl/SpecialCheckItemDangerLogServiceImpl.java b/src/main/java/com/ruoyi/project/tr/specialCheck/service/impl/SpecialCheckItemDangerLogServiceImpl.java index 20fa266..f8a4b92 100644 --- a/src/main/java/com/ruoyi/project/tr/specialCheck/service/impl/SpecialCheckItemDangerLogServiceImpl.java +++ b/src/main/java/com/ruoyi/project/tr/specialCheck/service/impl/SpecialCheckItemDangerLogServiceImpl.java @@ -2,17 +2,26 @@ import com.github.pagehelper.Page; import com.github.pagehelper.PageHelper; +import com.ruoyi.doublePrevention.entity.CJReport.PreventCJReportDangerInfo; import com.ruoyi.doublePrevention.enums.ErrorCodes; import com.ruoyi.doublePrevention.enums.ResultCodes; +import com.ruoyi.doublePrevention.repository.PreventCJReportDangerInfoRepository; +import com.ruoyi.doublePrevention.service.baseService.PreventCJReportDangerInfoService; import com.ruoyi.doublePrevention.vo.ResultVO; import com.ruoyi.project.system.user.domain.User; import com.ruoyi.project.tr.riskList.domain.RiskList; import com.ruoyi.project.tr.specialCheck.domin.BO.TbSpecialCheckItemDangerLogBO; import com.ruoyi.project.tr.specialCheck.domin.BO.TbSpecialCheckItemDangerLogUpdateBO; +import com.ruoyi.project.tr.specialCheck.domin.TbBaseCheckItem; +import com.ruoyi.project.tr.specialCheck.domin.TbBaseCheckScore; import com.ruoyi.project.tr.specialCheck.domin.TbSpecialCheckItemDangerLog; import com.ruoyi.project.tr.specialCheck.domin.TbSpecialCheckTaskLog; +import com.ruoyi.project.tr.specialCheck.mapper.TbBaseCheckItemMapper; +import com.ruoyi.project.tr.specialCheck.mapper.TbBaseCheckScoreMapper; +import com.ruoyi.project.tr.specialCheck.mapper.TbBaseCheckTaskMapper; import com.ruoyi.project.tr.specialCheck.mapper.TbSpecialCheckItemDangerLogMapper; import com.ruoyi.project.tr.specialCheck.service.SpecialCheckItemDangerLogService; +import com.ruoyi.project.tr.specialCheck.service.TbBaseCheckService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.util.ObjectUtils; @@ -28,6 +37,19 @@ @Autowired private TbSpecialCheckItemDangerLogMapper itemDangerLogMapper; + + @Autowired + private TbBaseCheckTaskMapper baseCheckTaskMapper; + + @Autowired + private TbBaseCheckItemMapper baseCheckItemMapper; + + @Autowired + private TbBaseCheckScoreMapper baseCheckScoreMapper; + + @Autowired + private PreventCJReportDangerInfoRepository preventCJReportDangerInfoRepository; + @Override @@ -61,21 +83,40 @@ ResultVO resultVO = new ResultVO<>(); resultVO.setCode(ErrorCodes.REQUEST_PARAM_ERROR.getCode()); - // 四类id,挨个查询,判断是否存在 + if (itemDangerLog.getTaskId() == null){ + resultVO.setMsg("任务不能为空"); + return resultVO; + } + TbBaseCheckTaskMapper baseCheckTaskByTaskId = baseCheckTaskMapper.getBaseCheckTaskByTaskId(itemDangerLog.getTaskId()); + if (ObjectUtils.isEmpty(baseCheckTaskByTaskId)){ + resultVO.setMsg("任务不存在"); + return resultVO; + } if (itemDangerLog.getCheckItemId() == null){ resultVO.setMsg("检查项不能为空"); return resultVO; } - if (itemDangerLog.getTaskId() == null){ - resultVO.setMsg("任务不能为空"); + TbBaseCheckItem baseCheckItemByItemId = baseCheckItemMapper.getBaseCheckItemByItemId(itemDangerLog.getCheckItemId()); + if (ObjectUtils.isEmpty(baseCheckItemByItemId)){ + resultVO.setMsg("检查项不存在"); return resultVO; } if (itemDangerLog.getCheckScoreId() == null){ resultVO.setMsg("评分不能为空"); return resultVO; } + TbBaseCheckScore baseCheckScoreByScoreId = baseCheckScoreMapper.getBaseCheckScoreByScoreId(itemDangerLog.getCheckScoreId()); + if (ObjectUtils.isEmpty(baseCheckScoreByScoreId)){ + resultVO.setMsg("评分标准不存在"); + return resultVO; + } if (itemDangerLog.getDangerId() == null){ resultVO.setMsg("关联隐患不能为空"); + return resultVO; + } + PreventCJReportDangerInfo dangerById = preventCJReportDangerInfoRepository.getDangerById(itemDangerLog.getDangerId()); + if (ObjectUtils.isEmpty(dangerById)){ + resultVO.setMsg("隐患不存在"); return resultVO; } if (itemDangerLog.getCheckDate() == null){ @@ -122,23 +163,42 @@ ResultVO resultVO = new ResultVO<>(); resultVO.setCode(ErrorCodes.REQUEST_PARAM_ERROR.getCode()); - // 四类id,挨个查询,判断是否存在 + if (updateBO.getTaskId() == null){ + resultVO.setMsg("任务不能为空"); + return resultVO; + } + TbBaseCheckTaskMapper baseCheckTaskByTaskId = baseCheckTaskMapper.getBaseCheckTaskByTaskId(updateBO.getTaskId()); + if (ObjectUtils.isEmpty(baseCheckTaskByTaskId)){ + resultVO.setMsg("任务不存在"); + return resultVO; + } if (updateBO.getCheckItemId() == null){ resultVO.setMsg("检查项不能为空"); return resultVO; } - if (updateBO.getTaskId() == null){ - resultVO.setMsg("任务不能为空"); + TbBaseCheckItem baseCheckItemByItemId = baseCheckItemMapper.getBaseCheckItemByItemId(updateBO.getCheckItemId()); + if (ObjectUtils.isEmpty(baseCheckItemByItemId)){ + resultVO.setMsg("检查项不存在"); return resultVO; } if (updateBO.getCheckScoreId() == null){ resultVO.setMsg("评分不能为空"); return resultVO; } + TbBaseCheckScore baseCheckScoreByScoreId = baseCheckScoreMapper.getBaseCheckScoreByScoreId(updateBO.getCheckScoreId()); + if (ObjectUtils.isEmpty(baseCheckScoreByScoreId)){ + resultVO.setMsg("评分标准不存在"); + return resultVO; + } if (updateBO.getDangerId() == null){ resultVO.setMsg("关联隐患不能为空"); return resultVO; } + PreventCJReportDangerInfo dangerById = preventCJReportDangerInfoRepository.getDangerById(updateBO.getDangerId()); + if (ObjectUtils.isEmpty(dangerById)){ + resultVO.setMsg("隐患不存在"); + return resultVO; + } if (updateBO.getCheckDate() == null){ resultVO.setMsg("检查时间不能为空"); return resultVO; -- Gitblit v1.9.2