package com.ruoyi.project.tr.specialCheck.service.impl;
|
|
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;
|
|
import java.time.LocalDateTime;
|
import java.util.List;
|
import java.util.UUID;
|
|
import static com.ruoyi.common.utils.security.ShiroUtils.getSysUser;
|
|
@Service
|
public class SpecialCheckItemDangerLogServiceImpl implements SpecialCheckItemDangerLogService {
|
|
@Autowired
|
private TbSpecialCheckItemDangerLogMapper itemDangerLogMapper;
|
|
@Autowired
|
private TbBaseCheckTaskMapper baseCheckTaskMapper;
|
|
@Autowired
|
private TbBaseCheckItemMapper baseCheckItemMapper;
|
|
@Autowired
|
private TbBaseCheckScoreMapper baseCheckScoreMapper;
|
|
@Autowired
|
private PreventCJReportDangerInfoRepository preventCJReportDangerInfoRepository;
|
|
|
|
@Override
|
public ResultVO<List<TbSpecialCheckItemDangerLog>> selectSpecialCheckItemDangerLogPage(TbSpecialCheckItemDangerLogBO itemDangerLogBO) {
|
Integer pageIndex = itemDangerLogBO.getPageNum();
|
Integer pageSize = itemDangerLogBO.getPageSize();
|
if (pageIndex == 0 || pageSize == 0){
|
return new ResultVO<>(ErrorCodes.REQUEST_PARAM_ERROR.getCode(),"当前页码或当前页显示数不能为0");
|
}
|
|
Page<TbSpecialCheckItemDangerLog> page = PageHelper.startPage(pageIndex, pageSize);
|
itemDangerLogMapper.selectSpecialCheckItemDangerLogPage(itemDangerLogBO);
|
|
Long total = page.getTotal();
|
int count = total.intValue();
|
List<TbSpecialCheckItemDangerLog> pageResult = null;
|
|
ResultVO<List<TbSpecialCheckItemDangerLog>> resultVO = new ResultVO<>(ResultCodes.OK,pageResult);
|
|
resultVO.setData(page.getResult());
|
resultVO.setCount(count);
|
resultVO.setCount((int) page.getTotal());
|
resultVO.setPageNum(page.getPageNum());
|
resultVO.setPageSize(page.getPageSize());
|
return resultVO;
|
}
|
|
@Override
|
public ResultVO<TbSpecialCheckItemDangerLog> addSpecialItemDanger(TbSpecialCheckItemDangerLog itemDangerLog) {
|
User sysUser = getSysUser();
|
ResultVO resultVO = new ResultVO<>();
|
resultVO.setCode(ErrorCodes.REQUEST_PARAM_ERROR.getCode());
|
|
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;
|
}
|
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){
|
resultVO.setMsg("检查时间不能为空");
|
return resultVO;
|
}
|
if (itemDangerLog.getCheckType() == null){
|
resultVO.setMsg("检查类型不能为空");
|
return resultVO;
|
}
|
|
LocalDateTime dateTime = LocalDateTime.now();
|
String uuid = UUID.randomUUID().toString();
|
|
itemDangerLog.setId(uuid);
|
itemDangerLog.setCompanyCode("652310082");
|
itemDangerLog.setCreateDate(dateTime);
|
itemDangerLog.setUpdateDate(dateTime);
|
itemDangerLog.setCreateBy(sysUser.getUserName());
|
itemDangerLog.setUpdateBy(sysUser.getUserName());
|
itemDangerLog.setReportStatus((byte) 1);
|
itemDangerLog.setReportTime(null);
|
itemDangerLog.setDeleted((byte) 0);
|
// itemDangerLog.setDangerId(itemDangerLog.getDangerId());
|
// itemDangerLog.setDangerId(itemDangerLog.getTaskId());
|
// itemDangerLog.setCheckType(itemDangerLog.getCheckType());
|
// itemDangerLog.setCheckItemId(itemDangerLog.getCheckItemId());
|
// itemDangerLog.setCheckScoreId(itemDangerLog.getCheckScoreId());
|
// itemDangerLog.setCheckDate(itemDangerLog.getCheckDate());
|
// itemDangerLog.setCheckPay(itemDangerLog.getCheckPay());
|
// itemDangerLog.setHarmType(itemDangerLog.getHarmType());
|
itemDangerLog.setDangerName(dangerById.getDangerName());
|
itemDangerLog.setCheckName(baseCheckItemByItemId.getCheckName());
|
itemDangerLog.setCheckContent(baseCheckItemByItemId.getCheckContent());
|
itemDangerLog.setCheckWay(null);
|
itemDangerLog.setCheckBasis(baseCheckItemByItemId.getCheckBasis());
|
itemDangerLog.setApplicablePlace(baseCheckItemByItemId.getApplicablePlace());
|
itemDangerLog.setIsReject(baseCheckScoreByScoreId.getIsReject());
|
itemDangerLog.setDeductPoint(baseCheckScoreByScoreId.getDeductPoint());
|
itemDangerLog.setDeductIllustrate(baseCheckScoreByScoreId.getDeductIllustrate());
|
|
|
|
|
|
int saveResult = itemDangerLogMapper.save(itemDangerLog);
|
if (saveResult == 0){
|
resultVO.setCode(ResultCodes.SERVER_ADD_ERROR.getCode());
|
resultVO.setMsg(ResultCodes.SERVER_ADD_ERROR.getDesc());
|
return resultVO;
|
}
|
resultVO.setCode(ResultCodes.OK.getCode());
|
resultVO.setMsg("新增检查成功");
|
return resultVO;
|
}
|
|
@Override
|
public TbSpecialCheckItemDangerLog getSpecialCheckItemDangerLogByIndexId(Long indexId) {
|
return itemDangerLogMapper.getSpecialCheckItemDangerLogByIndexId(indexId);
|
}
|
|
@Override
|
public ResultVO<TbSpecialCheckItemDangerLog> updateSpecialCheckItemDangerLog(TbSpecialCheckItemDangerLogUpdateBO updateBO) {
|
User sysUser = getSysUser();
|
ResultVO resultVO = new ResultVO<>();
|
resultVO.setCode(ErrorCodes.REQUEST_PARAM_ERROR.getCode());
|
|
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;
|
}
|
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;
|
}
|
if (updateBO.getCheckType() == null){
|
resultVO.setMsg("检查类型不能为空");
|
return resultVO;
|
}
|
|
LocalDateTime dateTime = LocalDateTime.now();
|
|
updateBO.setUpdateDate(dateTime);
|
updateBO.setUpdateBy(sysUser.getUserName());
|
updateBO.setReportStatus((byte) 1);
|
|
updateBO.setDangerName(dangerById.getDangerName());
|
updateBO.setCheckName(baseCheckItemByItemId.getCheckName());
|
updateBO.setCheckContent(baseCheckItemByItemId.getCheckContent());
|
updateBO.setCheckWay(null);
|
updateBO.setCheckBasis(baseCheckItemByItemId.getCheckBasis());
|
updateBO.setApplicablePlace(baseCheckItemByItemId.getApplicablePlace());
|
updateBO.setIsReject(baseCheckScoreByScoreId.getIsReject());
|
updateBO.setDeductPoint(baseCheckScoreByScoreId.getDeductPoint());
|
updateBO.setDeductIllustrate(baseCheckScoreByScoreId.getDeductIllustrate());
|
|
int updateResult = itemDangerLogMapper.updateSpecialCheckItemDangerLogById(updateBO);
|
if (updateResult == 0){
|
resultVO.setCode(ResultCodes.SERVER_UPDATE_ERROR.getCode());
|
resultVO.setMsg(ResultCodes.SERVER_UPDATE_ERROR.getDesc());
|
return resultVO;
|
}
|
resultVO.setCode(ResultCodes.OK.getCode());
|
resultVO.setMsg("更新成功");
|
return resultVO;
|
}
|
|
@Override
|
public ResultVO<TbSpecialCheckItemDangerLog> deleteTbSpecialItemDangerTaskLog(TbSpecialCheckItemDangerLogUpdateBO updateBO) {
|
User sysUser = getSysUser();
|
ResultVO resultVO = new ResultVO<>();
|
resultVO.setCode(ErrorCodes.REQUEST_PARAM_ERROR.getCode());
|
|
if (updateBO.getIndexId() == null){
|
resultVO.setMsg("检查项为空");
|
return resultVO;
|
}
|
TbSpecialCheckItemDangerLog specialCheckItemDangerLogByIndexId = itemDangerLogMapper.getSpecialCheckItemDangerLogByIndexId(updateBO.getIndexId());
|
if (ObjectUtils.isEmpty(specialCheckItemDangerLogByIndexId)){
|
resultVO.setMsg("检查项不存在，删除失败");
|
return resultVO;
|
}
|
|
TbSpecialCheckItemDangerLog tbSpecialCheckItemDangerLog = new TbSpecialCheckItemDangerLog();
|
LocalDateTime dateTime = LocalDateTime.now();
|
|
tbSpecialCheckItemDangerLog.setIndexId(updateBO.getIndexId());
|
tbSpecialCheckItemDangerLog.setUpdateDate(dateTime);
|
tbSpecialCheckItemDangerLog.setUpdateBy(sysUser.getUserName());
|
tbSpecialCheckItemDangerLog.setReportStatus((byte) 1);
|
tbSpecialCheckItemDangerLog.setDeleted((byte) 1);
|
|
int deleteResult = itemDangerLogMapper.deleteTbSpecialCheckItemDangerLog(tbSpecialCheckItemDangerLog);
|
if (deleteResult == 0){
|
resultVO.setCode(ResultCodes.SERVER_DEL_ERROR.getCode());
|
resultVO.setMsg(ResultCodes.SERVER_DEL_ERROR.getDesc());
|
return resultVO;
|
}
|
resultVO.setCode(ResultCodes.OK.getCode());
|
resultVO.setMsg("删除成功");
|
return resultVO;
|
}
|
|
|
}
|
