From 53e8b3ad59b48abf57321fd77c1924f4fe837b60 Mon Sep 17 00:00:00 2001
From: shenyijian <1178253012@qq.com>
Date: Tue, 18 Jun 2024 18:28:13 +0800
Subject: [PATCH] 湖北水库:施工:设备所有审批通过状态通过

---
 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sg/service/impl/SgProgressReportServiceImpl.java |   24 +++++++++++++-----------
 1 files changed, 13 insertions(+), 11 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 4be3fdf..f4e98eb 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
@@ -84,7 +84,7 @@
 				QueryWrapper<SgProgressReportDO> wrapper1 = new QueryWrapper<>();
 				wrapper1.eq("gx_step_id", gxStepDO.getId());
 				SgProgressReportDO one = sgProgressReportMapper.selectOne(wrapper1);
-				if (one != null && one.getStatus() != 3) {
+				if (one == null || one.getStatus() != 2) {
 					throw new ServiceException("请先完成" + gxStepDO.getGxStepName() + "的审批!");
 				}
 			}
@@ -131,6 +131,8 @@
 	@Override
 	public SgProgressReportVO detail(String id) {
 		SgProgressReportVO sgProgressReportVO = sgProgressReportMapper.queryById(id);
+		SgDeviceDO sgDeviceDO = sgDeviceMapper.selectById(sgProgressReportVO.getGxDeviceId());
+		sgProgressReportVO.setDeviceName(sgDeviceDO.getDeviceName());
 		List<SgReportUserDO> list = new LambdaQueryChainWrapper<>(sgReportUserMapper).eq(SgReportUserDO::getReportId, id).orderByAsc(SgReportUserDO::getApprovalTime).list();
 		List<Long> ids = list.stream().map(s -> s.getUserId()).collect(Collectors.toList());
 		List<Map<String,Object>> users = sgProgressReportMapper.getUserByIds(ids);
@@ -233,20 +235,20 @@
 						List<SgDeviceGxStepDO> sgDeviceGxStepDOs = sgGxStepMapper.getDeviceGXList(sgDeviceDO.getId());
 
 						if (sgDeviceGxStepDOs != null) {
-							int countStatus = 0;
-							for (SgDeviceGxStepDO sgDeviceGxStepDO : sgDeviceGxStepDOs) {
-								countStatus = +sgDeviceGxStepDO.getStatus();
-
-							}
-							int size = sgDeviceGxStepDOs.size();
-							if (countStatus != 0 && (size * 2) / countStatus == 1) {
+//							int countStatus = 0;
+//							for (SgDeviceGxStepDO sgDeviceGxStepDO : sgDeviceGxStepDOs) {
+//								countStatus = +sgDeviceGxStepDO.getStatus();
+//
+//							}
+//							int size = sgDeviceGxStepDOs.size(); //4
+							boolean allStatusesAreTwo = sgDeviceGxStepDOs.stream()
+								.allMatch(s -> s.getStatus() == 2);
+								if (allStatusesAreTwo) {
 								//如果设备下全部工序审核完成
 								sgDeviceDO.setStatus(2);
 								sgDeviceMapper.updateById(sgDeviceDO);
 								deviceFinishCount++;
-							}
-
-
+								}
 						}
 					}
 					if (deviceFinishCount == sgDeviceDOS.size()) {

--
Gitblit v1.9.3