From a27162cb82ef0cabf9b43cbfd1f3eb8c177d1e14 Mon Sep 17 00:00:00 2001
From: heheng <heheng@123456>
Date: 星期一, 13 一月 2025 15:22:44 +0800
Subject: [PATCH] 修改问题

---
 src/main/java/com/gkhy/labRiskManage/domain/riskReport/service/impl/ReportRiskAssessInfoServiceImpl.java |   37 +++++++++++++++++++++++++++++++++++++
 1 files changed, 37 insertions(+), 0 deletions(-)

diff --git a/src/main/java/com/gkhy/labRiskManage/domain/riskReport/service/impl/ReportRiskAssessInfoServiceImpl.java b/src/main/java/com/gkhy/labRiskManage/domain/riskReport/service/impl/ReportRiskAssessInfoServiceImpl.java
index 235f60e..aedee64 100644
--- a/src/main/java/com/gkhy/labRiskManage/domain/riskReport/service/impl/ReportRiskAssessInfoServiceImpl.java
+++ b/src/main/java/com/gkhy/labRiskManage/domain/riskReport/service/impl/ReportRiskAssessInfoServiceImpl.java
@@ -1,5 +1,7 @@
 package com.gkhy.labRiskManage.domain.riskReport.service.impl;
 
+import com.gkhy.labRiskManage.api.controller.basic.dto.respDto.OldRiskAssessResDTO;
+import com.gkhy.labRiskManage.api.controller.experiment.dto.req.ExperimentAndPersonInsertReqBO;
 import com.gkhy.labRiskManage.api.controller.riskReport.dto.repDto.ReportReqBO;
 import com.gkhy.labRiskManage.api.controller.riskReport.dto.respDto.ReportExperimentSiteQueryRespDTO;
 import com.gkhy.labRiskManage.api.controller.riskReport.dto.respDto.ReportPersonQueryRespDTO;
@@ -19,10 +21,12 @@
 import com.gkhy.labRiskManage.domain.account.model.dto.UserInfoDomainDTO;
 import com.gkhy.labRiskManage.domain.account.service.UserDomainService;
 import com.gkhy.labRiskManage.domain.basic.entity.BasicRiskUnitType;
+import com.gkhy.labRiskManage.domain.basic.entity.OldRiskAssess;
 import com.gkhy.labRiskManage.domain.basic.model.dto.SiteQueryDTO;
 import com.gkhy.labRiskManage.domain.basic.service.BasicExperimentPersonService;
 import com.gkhy.labRiskManage.domain.basic.service.BasicExperimentSiteService;
 import com.gkhy.labRiskManage.domain.basic.service.BasicRiskUnitTypeService;
+import com.gkhy.labRiskManage.domain.basic.service.OldRiskAssessService;
 import com.gkhy.labRiskManage.domain.experiment.entity.ExperimentAndSite;
 import com.gkhy.labRiskManage.domain.experiment.entity.ExperimentAssessLog;
 import com.gkhy.labRiskManage.domain.experiment.entity.ExperimentInfo;
@@ -30,6 +34,7 @@
 import com.gkhy.labRiskManage.domain.experiment.enums.ExperimentRectifyStatusEnum;
 import com.gkhy.labRiskManage.domain.experiment.model.dto.ExperimentInfoDTO;
 import com.gkhy.labRiskManage.domain.experiment.service.ExperimentAndSiteService;
+import com.gkhy.labRiskManage.domain.experiment.service.ExperimentAndTypeService;
 import com.gkhy.labRiskManage.domain.experiment.service.ExperimentAssessLogService;
 import com.gkhy.labRiskManage.domain.experiment.service.ExperimentInfoService;
 import com.gkhy.labRiskManage.domain.riskReport.entity.*;
@@ -48,6 +53,7 @@
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.ObjectUtils;
+import org.springframework.util.StringUtils;
 
 import javax.persistence.criteria.CriteriaBuilder;
 import javax.persistence.criteria.CriteriaQuery;
@@ -56,6 +62,7 @@
 import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.stream.Collectors;
 
 
 /**
@@ -103,6 +110,12 @@
     private RiskAssessPlanEvaluateMesService mesService;
     @Autowired
     private RiskAssessPlanEvaluateRsService rsService;
+
+    @Autowired
+    private ExperimentAndTypeService experimentAndTypeService;
+    
+    @Autowired
+    private OldRiskAssessService oldRiskAssessService;
 
 
     /**
@@ -191,6 +204,8 @@
         List<ReportAppQueryDTO> reportAppQueryDTOS = BeanCopyUtils.copyBeanList(reportQueryDTOS, ReportAppQueryDTO.class);
 
         List<UserInfoDomainDTO> userList = userDomainService.getUserList();
+
+
         for (ReportAppQueryDTO reportQueryDTO : reportAppQueryDTOS) {
             //获取审批人员
             List<ReportPersonQueryRespDTO> personByReportId = reportPersonService.listPersonByReportId(reportQueryDTO.getId());
@@ -205,6 +220,10 @@
             //获取评估计划
             List<AssessPlanQueryDTO> assessPlanByExperimentId = assessPlanService.getAssessPlanByExperimentId(reportQueryDTO.getExperimentId());
             reportQueryDTO.setEvaluateTime(experimentById.getCreateTime());
+            if (!ObjectUtils.isEmpty(experimentById.getProcess())){
+                reportQueryDTO.setProcess(experimentById.getProcess());
+            }
+
 
             if (!ObjectUtils.isEmpty(assessPlanByExperimentId)){
                 for (AssessPlanQueryDTO assessPlan : assessPlanByExperimentId) {
@@ -225,6 +244,16 @@
             }
             if (!ObjectUtils.isEmpty(siteByReportId)){
                 reportQueryDTO.setExperimentSite(BeanCopyUtils.copyBeanList(siteByReportId, ReportExperimentSiteQueryRespDTO.class));
+                if (queryBO.getExperimentId() != null){
+                    List<ReportExperimentSiteQueryRespDTO> experimentSite = reportQueryDTO.getExperimentSite();
+                    List<String> collect = experimentSite.stream().map(ReportExperimentSiteQueryRespDTO::getSiteName).collect(Collectors.toList());
+                    List<OldRiskAssessResDTO> oldRiskAssessListByRegion = oldRiskAssessService.getOldRiskAssessListByRegion(collect);
+                    if (!ObjectUtils.isEmpty(oldRiskAssessListByRegion)){
+
+                        reportQueryDTO.setOldRiskAssess(oldRiskAssessListByRegion);
+                    }
+                    reportQueryDTO.setExperimentAndType(experimentAndTypeService.getByExperimentId(reportQueryDTO.getExperimentId()));
+                }
             }
             reportQueryDTO.setExperimentCode(experimentById.getExperimentCode());
 
@@ -236,6 +265,9 @@
                     reportQueryDTO.setUpdateByUserName(userInfo.getRealName());
                 }
             }
+
+
+
         }
 
         searchResult.setData(reportAppQueryDTOS);
@@ -243,6 +275,7 @@
         return searchResult;
     }
 
+    
     /**
      * 风险评估报告 - 生成报告信息
      */
@@ -557,6 +590,9 @@
         reportById.setAssessPerson(reportUpdateBO.getAssessPerson());
         reportById.setAssessLevel(reportUpdateBO.getAssessLevel());
         reportById.setDescription(reportUpdateBO.getDescription());
+        if(!ObjectUtils.isEmpty(reportUpdateBO.getSafeRiskAnalysis())){
+            reportById.setSafeRiskAnalysis(reportUpdateBO.getSafeRiskAnalysis());
+        }
         reportById.setUpdateTime(LocalDateTime.now());
         reportById.setUpdateByUserId(currentUserId);
 
@@ -724,6 +760,7 @@
      * 风险评估报告 - 报告审核 - 新 - 单次审核
      */
     @Override
+    @Transactional
     public int reportNew(Long currentUserId, ReportReqBO reportReqBO) {
 
         if (currentUserId < 0){

--
Gitblit v1.9.2