From f8c80586bfc419db594673b8ea0524a246d596ca Mon Sep 17 00:00:00 2001
From: shenyijian <1178253012@qq.com>
Date: Fri, 13 Sep 2024 21:44:02 +0800
Subject: [PATCH] 湖北水库:审核流修改

---
 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sg/service/impl/SgProgressReportServiceImpl.java |   28 ++++++++++++++++------------
 1 files changed, 16 insertions(+), 12 deletions(-)

diff --git a/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sg/service/impl/SgProgressReportServiceImpl.java b/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sg/service/impl/SgProgressReportServiceImpl.java
index 0aabb1c..29f564b 100644
--- a/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sg/service/impl/SgProgressReportServiceImpl.java
+++ b/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sg/service/impl/SgProgressReportServiceImpl.java
@@ -3,10 +3,7 @@
 import cn.gistack.sm.sg.DO.*;
 import cn.gistack.sm.sg.DTO.ApprovalDTO;
 import cn.gistack.sm.sg.DTO.ProjectSearchDTO;
-import cn.gistack.sm.sg.VO.SgProgressReportVO;
-import cn.gistack.sm.sg.VO.SgProjectInfoVO;
-import cn.gistack.sm.sg.VO.SgReportVO;
-import cn.gistack.sm.sg.VO.SgStepReportVO;
+import cn.gistack.sm.sg.VO.*;
 import cn.gistack.sm.sg.mapper.*;
 import cn.gistack.sm.sg.service.SgProgressReportService;
 import cn.gistack.sm.sg.service.SgProjectInfoService;
@@ -223,10 +220,10 @@
 			} catch (InterruptedException e) {
 				throw new RuntimeException(e);
 			}
-//			if (sgGxConfigDO.getSgOrder() == 1) {
-//				sgProgressReportDO.setAuditPerson(String.valueOf(sgGxConfigDO.getUser()));
-//				sgProgressReportMapper.updateById(sgProgressReportDO);
-//			}
+			if (sgGxConfigDO.getSgOrder() == 1) {
+				sgProgressReportDO.setAuditPerson(String.valueOf(sgGxConfigDO.getRoleId()));
+				sgProgressReportMapper.updateById(sgProgressReportDO);
+			}
 		}
 
 		//加个项目及设备的状态判断 方便统计计算
@@ -303,7 +300,7 @@
 		if (isReject==1){
 			sgReportUserDO = sgReportUserDOS.get(0);
 		}else {
-			sgReportUserDO = sgReportUserDOS.stream().filter(s -> s.getUserId().equals(Long.parseLong(sgProgressReportDO.getAuditPerson()))).findFirst().get();
+			sgReportUserDO = sgReportUserDOS.stream().filter(s -> s.getRoleId().equals(Long.parseLong(sgProgressReportDO.getAuditPerson()))).findFirst().get();
 		}
 		Date date = new Date();
 		LambdaUpdateChainWrapper<SgProgressReportDO> updateChainWrapper = new LambdaUpdateChainWrapper<>(sgProgressReportMapper).eq(SgProgressReportDO::getId, id);
@@ -311,12 +308,12 @@
 			.eq(SgReportUserDO::getId, sgReportUserDO.getId()).set(SgReportUserDO::getApprovalContent,approvalDTO.getApprovalContent()).set(SgReportUserDO::getApprovalTime,date);
 		if (approvalDTO.getStatus()==1){
 			Integer approvalOrder = sgReportUserDO.getApprovalOrder();
-			userUpdate.set(SgReportUserDO::getApprovalStatus,1).update();
+			userUpdate.set(SgReportUserDO::getApprovalStatus,1).set(SgReportUserDO::getUserId,userId).update();
 		Optional<SgReportUserDO> next = sgReportUserDOS.stream().filter(s -> s.getApprovalOrder() == approvalOrder + 1).findFirst();
 		//如果存在下一个审批人,则继续审批
 		if (next.isPresent()){
 			SgReportUserDO nextUser = next.get();
-			updateChainWrapper.set(SgProgressReportDO::getStatus,1).set(SgProgressReportDO::getAuditPerson,nextUser.getUserId()).update();
+			updateChainWrapper.set(SgProgressReportDO::getStatus,1).set(SgProgressReportDO::getAuditPerson,nextUser.getRoleId()).update();
 		}else {
 			updateChainWrapper.set(SgProgressReportDO::getStatus,2).set(SgProgressReportDO::getAuditPerson,null).update();
 			Long proframId = sgProgressReportMapper.selectById(approvalDTO.getId()).getProframId();
@@ -435,7 +432,14 @@
 						sgProjectInfoMapper.updateById(project);
 					}
 				}
-
+				Map<String, SgOperatingRateVO> deviceTypes = sgProjectInfoService.getDeviceTypes(Arrays.asList(projectId.toString()));
+				SgOperatingRateVO vo = deviceTypes.get(projectId.toString());
+				if (Objects.nonNull(vo)){
+					project.setSurfaceProgress(vo.getSurfaceProgress());
+					project.setVideoProgress(vo.getVideoProgress());
+					project.setTransProgress(vo.getTransProgress());
+					project.setSeepageProgress(vo.getSeepageProgress());
+				}
 			}
 		}
 

--
Gitblit v1.9.3