diff --git a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/complaintBox/service/impl/BusComplaintBoxServiceImpl.java b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/complaintBox/service/impl/BusComplaintBoxServiceImpl.java index e25ec5a8..f4a0df4a 100644 --- a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/complaintBox/service/impl/BusComplaintBoxServiceImpl.java +++ b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/complaintBox/service/impl/BusComplaintBoxServiceImpl.java @@ -333,6 +333,9 @@ public class BusComplaintBoxServiceImpl extends ServiceImpl lqw = new LambdaUpdateWrapper(); lqw.set(BusComplaintBox::getStatus, bo.getStatus()); lqw.eq(BusComplaintBox::getId, bo.getId()); - if ("5".equals(busComplaintBoxVo.getStatus())){ + if ("5".equals(bo.getStatus())){ BusComplaintBoxDisposeLogging logging = new BusComplaintBoxDisposeLogging(); logging.setComplaintId(bo.getId()); LoginUser loginUser = LoginHelper.getLoginUser(); @@ -351,6 +354,7 @@ public class BusComplaintBoxServiceImpl extends ServiceImpl list(SysUserBo user, PageQuery pageQuery) { + return userService.selectPageUserList(user, pageQuery); + } + + + +} diff --git a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/controller/HseSafetySgdcController.java b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/controller/HseSafetySgdcController.java index 45b6918f..4d19e993 100644 --- a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/controller/HseSafetySgdcController.java +++ b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/controller/HseSafetySgdcController.java @@ -15,6 +15,10 @@ import org.dromara.common.log.enums.BusinessType; import org.dromara.common.mybatis.core.page.PageQuery; import org.dromara.common.mybatis.core.page.TableDataInfo; import org.dromara.common.web.core.BaseController; +import org.dromara.contractor.domain.vo.contractor.SubContractorManagerVo; +import org.dromara.contractor.service.ISubContractorService; +import org.dromara.project.domain.vo.projectteam.BusProjectTeamForemanVo; +import org.dromara.project.service.IBusProjectTeamService; import org.dromara.safety.accident.domain.bo.HseSafetySgdcBo; import org.dromara.safety.accident.domain.vo.HseSafetySgdcVo; import org.dromara.safety.accident.domain.vo.SgsbCountVo; @@ -38,6 +42,32 @@ public class HseSafetySgdcController extends BaseController { private final IHseSafetySgdcService hseSafetySgdcService; + private final IBusProjectTeamService busProjectTeamService; + + private final ISubContractorService contractorService; + + + /** + * 根据项目id查询项目班组班组长信息列表 + */ + @SaCheckPermission("accident:safetySgdc:edit") + @GetMapping("/listForeman/{projectId}") + public R> listForeman(@NotNull(message = "项目id不能为空") + @PathVariable Long projectId) { + return R.ok(busProjectTeamService.queryForemanListByProjectId(projectId)); + } + + + /** + * 根据项目id查询分包方管理人员信息列表 + */ + @SaCheckPermission("accident:safetySgdc:edit") + @GetMapping("/listManager/{projectId}") + public R> listManager(@NotNull(message = "项目id不能为空") + @PathVariable Long projectId) { + return R.ok(contractorService.queryManagerListByProjectId(projectId)); + } + /** * 查询安全-事故调查列表 */ diff --git a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/controller/HseSafetySgzgbhController.java b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/controller/HseSafetySgzgbhController.java index 45917723..77e4aac8 100644 --- a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/controller/HseSafetySgzgbhController.java +++ b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/controller/HseSafetySgzgbhController.java @@ -44,7 +44,7 @@ public class HseSafetySgzgbhController extends BaseController { /** * 头部数据返回 */ - @SaCheckPermission("jxzgbh:yhzgbh:list") + @SaCheckPermission("accident:safetySgzgbh:list") @GetMapping("/getListHead") public R getListHead(HseSafetySgzgbhBo bo) { return R.ok(hseSafetySgzgbhService.getListHead(bo)); diff --git a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/domain/bo/HseSafetySgdcxqReq.java b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/domain/bo/HseSafetySgdcxqReq.java index c834da62..bc1bee4b 100644 --- a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/domain/bo/HseSafetySgdcxqReq.java +++ b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/domain/bo/HseSafetySgdcxqReq.java @@ -12,7 +12,7 @@ import java.io.Serializable; import java.util.Date; /** - * 安全-事故调查业务对象 hse_safety_sgdc + * 档案-事故调查信息 * * @author Lion Li * @date 2025-12-05 @@ -44,16 +44,19 @@ public class HseSafetySgdcxqReq implements Serializable { * 责任部门 */ private Long zrbm; + private String zrbmName; /** * 主要负责人 */ private Long zyfzr; + private String zyfzrName; /** * 次要负责人 */ private Long cyfzr; + private String cyfzrName; /** * 责任划分 diff --git a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/domain/bo/HseSafetySgssqkReq.java b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/domain/bo/HseSafetySgssqkReq.java index 17d0a9a6..272d3b6c 100644 --- a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/domain/bo/HseSafetySgssqkReq.java +++ b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/domain/bo/HseSafetySgssqkReq.java @@ -12,7 +12,7 @@ import java.io.Serializable; import java.util.Date; /** - * 安全-事故上报业务对象 hse_safety_sgsb + * 档案-损失情况信息 * * @author Lion Li * @date 2025-12-05 diff --git a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/domain/bo/HseSafetySgxqReq.java b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/domain/bo/HseSafetySgxqReq.java index 531ed2ed..1e8bef2d 100644 --- a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/domain/bo/HseSafetySgxqReq.java +++ b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/domain/bo/HseSafetySgxqReq.java @@ -12,7 +12,7 @@ import java.io.Serializable; import java.util.Date; /** - * 安全-事故上报业务对象 hse_safety_sgsb + * 档案-事故详情信息 * * @author Lion Li * @date 2025-12-05 diff --git a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/domain/bo/HseSafetySgzgfcxqReq.java b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/domain/bo/HseSafetySgzgfcxqReq.java index 19f43521..3a502ab9 100644 --- a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/domain/bo/HseSafetySgzgfcxqReq.java +++ b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/domain/bo/HseSafetySgzgfcxqReq.java @@ -18,7 +18,7 @@ import java.util.Date; import java.util.List; /** - * 安全-事故整改闭环业务对象 hse_safety_sgzgbh + * 档案-事故整改与复查信息 * * @author Lion Li * @date 2025-12-05 diff --git a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/domain/vo/HseSafetySgsbVo.java b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/domain/vo/HseSafetySgsbVo.java index d0a3d81f..ec53cc11 100644 --- a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/domain/vo/HseSafetySgsbVo.java +++ b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/domain/vo/HseSafetySgsbVo.java @@ -2,8 +2,12 @@ package org.dromara.safety.accident.domain.vo; import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; import com.alibaba.excel.annotation.ExcelProperty; +import com.baomidou.mybatisplus.annotation.FieldFill; +import com.baomidou.mybatisplus.annotation.TableField; import io.github.linpeilie.annotations.AutoMapper; import lombok.Data; +import org.dromara.common.translation.annotation.Translation; +import org.dromara.common.translation.constant.TransConstant; import org.dromara.safety.accident.domain.HseSafetySgsb; import java.io.Serial; @@ -38,6 +42,8 @@ public class HseSafetySgsbVo implements Serializable { */ @ExcelProperty(value = "关联项目") private Long projectId; + @Translation(type = TransConstant.PROJECT_ID_TO_NAME, mapper = "projectId") + private String projectName; /** * 事故编号 @@ -162,4 +168,9 @@ public class HseSafetySgsbVo implements Serializable { */ private String createByName; + /** + * 创建时间 + */ + private Date createTime; + } diff --git a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/domain/vo/SgsbCountVo.java b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/domain/vo/SgsbCountVo.java index e371bab5..055a756f 100644 --- a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/domain/vo/SgsbCountVo.java +++ b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/domain/vo/SgsbCountVo.java @@ -8,24 +8,24 @@ import java.math.BigDecimal; public class SgsbCountVo { /** - * 本月上报事故 + * 本月总上报事故 */ private Long bysbsg; - /** - * 待处理事故 - */ - private Long dclsg; - /** * 已闭环事故 */ private Long ybhsg; - /** - * 事故整改完成率 + * 待整改事故 */ - private BigDecimal sgzgwcl; + private Long dzgsg; + /** + * 已整改事故 + */ + private Long yzgsg; + + /** * 待调查事故 @@ -43,8 +43,8 @@ public class SgsbCountVo { private Long ywcdc; /** - * 待整改事故 + * 总调查事故 */ - private Long dzgsg; + private Long zdcsg; } diff --git a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/menu/SGStatusEnum.java b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/menu/SGStatusEnum.java index a0a10d8f..bd0f25bf 100644 --- a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/menu/SGStatusEnum.java +++ b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/menu/SGStatusEnum.java @@ -66,7 +66,19 @@ public enum SGStatusEnum { /** * 未闭环 */ - OPEN_LOOP("1", "未闭环"); + OPEN_LOOP("1", "未闭环"), + + + //事故调查保存状态 + /** + * 草稿 + */ + DRAFT("0", "草稿"), + /** + * 提交 + */ + SUBMIT("1", "提交"); + private final String code; diff --git a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/service/impl/HseSafetySgdcServiceImpl.java b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/service/impl/HseSafetySgdcServiceImpl.java index 96532344..121f44ac 100644 --- a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/service/impl/HseSafetySgdcServiceImpl.java +++ b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/service/impl/HseSafetySgdcServiceImpl.java @@ -313,6 +313,8 @@ public class HseSafetySgdcServiceImpl extends ServiceImpl sbList = baseMapper.getSgsbListByProjectId(projectId); + if (sbList != null && !sbList.isEmpty()){ + zdcsg = sbList.size(); + } for (HseSafetySgsb sgsb : sbList) { //待调查事故 上报后 审核后 待调查 if (sgsb.getSgzt().equals(SGStatusEnum.UNDER_INVESTIGATION.getCode())){ - ddcsg++; - }else if (sgsb.getSgzt().equals(SGStatusEnum.SG_TO_BE_RECTIFIED.getCode())){ - //调查中事故 待调查 填写完数据提交后 待整改 - dczsg++; - }else if (sgsb.getSgzt().equals(SGStatusEnum.SG_HAS_BEEN_RECTIFIED.getCode())){ - //已完成调查 待整改 -> 已整改 - ywcdc++; - } - //待整改事项 查看整改表关联此调查的数据 整改状态为待整改 - LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); - queryWrapper.eq(HseSafetySgdc::getSgId,sgsb.getId()); - List sgdcs = list(queryWrapper); - for (HseSafetySgdc sgdc : sgdcs) { - //寻找对应整改数据 - LambdaQueryWrapper zgqwr = new LambdaQueryWrapper<>(); - zgqwr.eq(HseSafetySgzgbh::getDcId,sgdc.getId()); - List zgs = zgbhService.list(zgqwr); - for (HseSafetySgzgbh zg : zgs) { - //寻找待整改 - if (zg.getZgStatus().equals(SGStatusEnum.TO_BE_RECTIFIED.getCode())){ - dzgsg++; + HseSafetySgdcVo sgdcVo = baseMapper.selectVoOne(new LambdaQueryWrapper().eq(HseSafetySgdc::getSgId, sgsb.getId())); + if (sgdcVo != null){ + //待调查事故 已生成调查事件但还未调查 + if (sgdcVo.getBczt() == null){ + ddcsg++; + continue; + } + //调查中事故 已调查但提交状态为草稿 + if (SGStatusEnum.DRAFT.getCode().equals(sgdcVo.getBczt())){ + dczsg++; } } + + }else if (sgsb.getSgzt().equals(SGStatusEnum.SG_TO_BE_RECTIFIED.getCode())){ + //待整改 + ywcdc++; } + } countVo.setDdcsg(ddcsg); countVo.setDczsg(dczsg); countVo.setYwcdc(ywcdc); - countVo.setDzgsg(dzgsg); + countVo.setZdcsg(zdcsg); return countVo; } diff --git a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/service/impl/HseSafetySgsbServiceImpl.java b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/service/impl/HseSafetySgsbServiceImpl.java index 9c807f0d..096cfcdc 100644 --- a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/service/impl/HseSafetySgsbServiceImpl.java +++ b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/service/impl/HseSafetySgsbServiceImpl.java @@ -16,6 +16,7 @@ import org.dromara.safety.accident.domain.HseSafetySgzgbh; import org.dromara.safety.accident.domain.bo.HseSafetySgdcBo; import org.dromara.safety.accident.domain.bo.HseSafetySgsbBo; import org.dromara.safety.accident.domain.vo.HseSafetySgsbVo; +import org.dromara.safety.accident.domain.vo.HseSafetySgzgbhHeadVo; import org.dromara.safety.accident.domain.vo.SgsbCountVo; import org.dromara.safety.accident.mapper.HseSafetySgsbMapper; import org.dromara.safety.accident.menu.SGStatusEnum; @@ -186,68 +187,79 @@ public class HseSafetySgsbServiceImpl extends ServiceImpl lambdaQueryWrapper = new LambdaQueryWrapper<>(); - lambdaQueryWrapper.eq(HseSafetySgsb::getProjectId, projectId); - List list = this.list(lambdaQueryWrapper); - //获取整改对应列表 - List zgxxes = baseMapper.getSgzgList(); - //获取调查列表 - List dcList = sgdcService.list(); - //初始化统计信息 - SgsbCountVo sgsbCountVo = new SgsbCountVo(); - sgsbCountVo.setSgzgwcl(BigDecimal.ZERO); - long sbsg = 0; - long dclsg = 0; - long ybhsg = 0; - long zgwc = 0; - //获取时间 - Date firstDay = getFirstDayOfMonth(); - Date lastDay = getLastDayOfMonth(); - for (HseSafetySgsb hseSafetySgsb : list) { - //本月上报事故 - if (hseSafetySgsb.getCreateTime().after(firstDay) && hseSafetySgsb.getCreateTime().before(lastDay)){ - sbsg++; - //本月完成数量 - for (HseSafetySgdc safetySgdc : dcList) { - if (hseSafetySgsb.getId() == safetySgdc.getSgId()){ - //事故找到 调查 调查寻找整改 - for (HseSafetySgzgbh zgxx : zgxxes) { - if (zgxx.getSgId() == safetySgdc.getId()){ - //如果调查找到了整改 则查看状态 - if (zgxx.getIsFinish().equals("1") || zgxx.getIsFinish().equals("3")){ - zgwc++; - break; - } - } - } - break; - } - } - } - //待处理事故 新增后为已上报 审核通过后向调查新增 状态为草稿 原数据状态改为待调查 - if (hseSafetySgsb.getSgzt().equals(SGStatusEnum.REPORTED.getCode())){ - dclsg++; - } - //已闭环事故 - if (hseSafetySgsb.getSgzt().equals(SGStatusEnum.CLOSED_LOOP_OPERATION.getCode())){ - ybhsg++; - } + SgsbCountVo sgzgbhHeadVo = new SgsbCountVo(); + List sgzgbhs = this.getBaseMapper().selectList(new LambdaQueryWrapper().eq(HseSafetySgsb::getProjectId, projectId).le(HseSafetySgsb::getCreateTime, LocalDate.now().plusDays(1)).ge(HseSafetySgsb::getCreateTime, LocalDate.now().minusDays(29))); + if (sgzgbhs != null && !sgzgbhs.isEmpty()) { + sgzgbhHeadVo.setBysbsg((long) sgzgbhs.size()); + sgzgbhHeadVo.setDdcsg(sgzgbhs.stream().filter(jxYhzgbh -> SGStatusEnum.UNDER_INVESTIGATION.getCode().equals(jxYhzgbh.getSgzt())).count()); + sgzgbhHeadVo.setDzgsg(sgzgbhs.stream().filter(jxYhzgbh -> SGStatusEnum.SG_TO_BE_RECTIFIED.getCode().equals(jxYhzgbh.getSgzt())).count()); + sgzgbhHeadVo.setYzgsg(sgzgbhs.stream().filter(jxYhzgbh -> SGStatusEnum.SG_HAS_BEEN_RECTIFIED.getCode().equals(jxYhzgbh.getSgzt())).count()); + sgzgbhHeadVo.setYbhsg(sgzgbhs.stream().filter(jxYhzgbh -> SGStatusEnum.SG_CLOSED_LOOP_OPERATION.getCode().equals(jxYhzgbh.getSgzt())).count()); } - sgsbCountVo.setBysbsg(sbsg); - sgsbCountVo.setDclsg(dclsg); - sgsbCountVo.setYbhsg(ybhsg); - - BigDecimal wcl; - if (sbsg == 0){ - wcl = BigDecimal.ZERO; - }else { - wcl = new BigDecimal(zgwc).divide(new BigDecimal(sbsg), 2, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); - } - sgsbCountVo.setSgzgwcl(wcl); - - return sgsbCountVo; + return sgzgbhHeadVo; +// //获取对应列表 +// LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>(); +// lambdaQueryWrapper.eq(HseSafetySgsb::getProjectId, projectId); +// List list = this.list(lambdaQueryWrapper); +// //获取整改对应列表 +// List zgxxes = baseMapper.getSgzgList(); +// //获取调查列表 +// List dcList = sgdcService.list(); +// //初始化统计信息 +// SgsbCountVo sgsbCountVo = new SgsbCountVo(); +// sgsbCountVo.setSgzgwcl(BigDecimal.ZERO); +// +// long sbsg = 0; +// long dclsg = 0; +// long ybhsg = 0; +// long zgwc = 0; +// //获取时间 +// Date firstDay = getFirstDayOfMonth(); +// Date lastDay = getLastDayOfMonth(); +// for (HseSafetySgsb hseSafetySgsb : list) { +// //本月上报事故 +// if (hseSafetySgsb.getCreateTime().after(firstDay) && hseSafetySgsb.getCreateTime().before(lastDay)){ +// sbsg++; +// //本月完成数量 +// for (HseSafetySgdc safetySgdc : dcList) { +// if (hseSafetySgsb.getId() == safetySgdc.getSgId()){ +// //事故找到 调查 调查寻找整改 +// for (HseSafetySgzgbh zgxx : zgxxes) { +// if (zgxx.getSgId() == safetySgdc.getId()){ +// //如果调查找到了整改 则查看状态 +// if (zgxx.getIsFinish().equals("1") || zgxx.getIsFinish().equals("3")){ +// zgwc++; +// break; +// } +// } +// } +// break; +// } +// } +// } +// //待处理事故 新增后为已上报 审核通过后向调查新增 状态为草稿 原数据状态改为待调查 +// if (hseSafetySgsb.getSgzt().equals(SGStatusEnum.REPORTED.getCode())){ +// dclsg++; +// } +// //已闭环事故 +// if (hseSafetySgsb.getSgzt().equals(SGStatusEnum.CLOSED_LOOP_OPERATION.getCode())){ +// ybhsg++; +// } +// } +// sgsbCountVo.setBysbsg(sbsg); +// sgsbCountVo.setDclsg(dclsg); +// sgsbCountVo.setYbhsg(ybhsg); +// +// BigDecimal wcl; +// if (sbsg == 0){ +// wcl = BigDecimal.ZERO; +// }else { +// wcl = new BigDecimal(zgwc).divide(new BigDecimal(sbsg), 2, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); +// } +// sgsbCountVo.setSgzgwcl(wcl); +// +// return sgsbCountVo; } /** diff --git a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/service/impl/HseSafetySgzgbhServiceImpl.java b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/service/impl/HseSafetySgzgbhServiceImpl.java index 73dba277..3a0f5ab5 100644 --- a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/service/impl/HseSafetySgzgbhServiceImpl.java +++ b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/accident/service/impl/HseSafetySgzgbhServiceImpl.java @@ -5,6 +5,7 @@ import cn.hutool.json.JSONUtil; import com.baomidou.mybatisplus.core.toolkit.BeanUtils; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import jakarta.annotation.Resource; +import org.dromara.common.core.domain.model.LoginUser; import org.dromara.common.core.exception.ServiceException; import org.dromara.common.core.utils.MapstructUtils; import org.dromara.common.core.utils.StringUtils; @@ -14,6 +15,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import lombok.RequiredArgsConstructor; +import org.dromara.common.satoken.utils.LoginHelper; import org.dromara.common.utils.BatchNumberGenerator; import org.dromara.mechanical.jxzgbh.domain.JxYhzgbh; import org.dromara.mechanical.jxzgbh.domain.vo.JxZgxxHeadVo; @@ -26,6 +28,10 @@ import org.dromara.safety.accident.domain.bo.*; import org.dromara.safety.accident.domain.vo.*; import org.dromara.safety.accident.menu.SGStatusEnum; import org.dromara.safety.accident.service.*; +import org.dromara.system.domain.vo.SysDeptVo; +import org.dromara.system.domain.vo.SysUserVo; +import org.dromara.system.service.ISysDeptService; +import org.dromara.system.service.ISysUserService; import org.springframework.context.annotation.Lazy; import org.springframework.stereotype.Service; import org.dromara.safety.accident.domain.HseSafetySgzgbh; @@ -65,6 +71,12 @@ public class HseSafetySgzgbhServiceImpl extends ServiceImpl zgxxVos =zgxxService.getZGBGInfoVoByIdList(vo.getId()); - if(!zgxxVos.isEmpty()){ + if (null != vo) { + List zgxxVos = zgxxService.getZGBGInfoVoByIdList(vo.getId()); + if (!zgxxVos.isEmpty()) { vo.setZgxxVos(zgxxVos); } } @@ -167,7 +179,7 @@ public class HseSafetySgzgbhServiceImpl extends ServiceImpl ids, Boolean isValid) { - if(isValid){ + if (isValid) { //TODO 做一些业务上的校验,判断是否需要校验 } return baseMapper.deleteByIds(ids) > 0; @@ -196,17 +208,24 @@ public class HseSafetySgzgbhServiceImpl extends ServiceImpl().eq(HseSafetyZgxx::getMasterId, sgzgbh.getId()).orderByDesc(HseSafetyZgxx::getCreateTime).last("limit 1")); - if (zgxx == null){ + if (zgxx == null) { throw new ServiceException("找不到整改信息"); } bo.setZgId(zgxx.getId()); Boolean b = fcxxService.insertByBo(bo); //修改主数据整改状态合复查状态 sgzgbh.setFcStatus(bo.getReviewState()); - if (SGStatusEnum.PASS.getCode().equals(bo.getReviewState())){ + if (SGStatusEnum.PASS.getCode().equals(bo.getReviewState())) { sgzgbh.setReviewStatus(SGStatusEnum.CLOSED_LOOP_OPERATION.getCode()); hseSafetySgsb.setSgzt(SGStatusEnum.SG_CLOSED_LOOP_OPERATION.getCode()); //复查通过则生成档案信息数据 @@ -258,7 +285,7 @@ public class HseSafetySgzgbhServiceImpl extends ServiceImpl reqs = new ArrayList<>(); - if (vo.getZgxxVos() != null){ + if (vo.getZgxxVos() != null) { vo.getZgxxVos().forEach(v -> { HseSafetySgzgfcxqReq req = new HseSafetySgzgfcxqReq(); req.setAbarbeitungMeasure(v.getAbarbeitungMeasure()); @@ -294,7 +332,7 @@ public class HseSafetySgzgbhServiceImpl extends ServiceImpl sgzgbhs = this.getBaseMapper().selectList(new LambdaQueryWrapper().eq(HseSafetySgzgbh::getProjectId,bo.getProjectId()).le(HseSafetySgzgbh::getCreateTime, LocalDate.now().plusDays(1)).ge(HseSafetySgzgbh::getCreateTime, LocalDate.now().minusDays(29))); - if ( sgzgbhs != null && !sgzgbhs.isEmpty()) { + List sgzgbhs = this.getBaseMapper().selectList(new LambdaQueryWrapper().eq(HseSafetySgzgbh::getProjectId, bo.getProjectId()).le(HseSafetySgzgbh::getCreateTime, LocalDate.now().plusDays(1)).ge(HseSafetySgzgbh::getCreateTime, LocalDate.now().minusDays(29))); + if (sgzgbhs != null && !sgzgbhs.isEmpty()) { sgzgbhHeadVo.setZs((long) sgzgbhs.size()); sgzgbhHeadVo.setDzg(sgzgbhs.stream().filter(jxYhzgbh -> jxYhzgbh.getZgStatus().equals(SGStatusEnum.TO_BE_RECTIFIED.getCode())).count()); sgzgbhHeadVo.setDys(sgzgbhs.stream().filter(jxYhzgbh -> SGStatusEnum.HAS_BEEN_RECTIFIED.getCode().equals(jxYhzgbh.getZgStatus()) && SGStatusEnum.OPEN_LOOP.getCode().equals(jxYhzgbh.getReviewStatus())).count()); @@ -335,11 +373,11 @@ public class HseSafetySgzgbhServiceImpl extends ServiceImpl().eq(HseSafetyZgxx::getMasterId, bo.getId()).orderByDesc(HseSafetyZgxx::getCreateTime).last("limit 1")); - if (zgxx == null){ + if (zgxx == null) { throw new ServiceException("找不到整改信息"); } HseSafetyFcxx fcxx = fcxxService.getBaseMapper().selectOne(new LambdaQueryWrapper().eq(HseSafetyFcxx::getZgId, zgxx.getId()).orderByDesc(HseSafetyFcxx::getCreateTime).last("limit 1")); - if (fcxx == null){ + if (fcxx == null) { throw new ServiceException("找不到复查信息"); } return fcxx.getNotPassCause(); diff --git a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/enums/AqEnums.java b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/enums/AqEnums.java index 6d4dceff..dba42a50 100644 --- a/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/enums/AqEnums.java +++ b/xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/safety/enums/AqEnums.java @@ -3,7 +3,7 @@ package org.dromara.safety.enums; public enum AqEnums { AQJDZT_S("是否交底", "1"), - AQJDZT_F("是否交底", "2"), + AQJDZT_F("是否交底", "0"), AQWXJX_S("是否存在危险迹象", "1"), AQWXJX_F("是否存在危险迹象", "0");