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 | 22 +++++++++++-----------
skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sg/service/impl/SgProjectInfoServiceImpl.java | 11 +++++++++--
2 files changed, 20 insertions(+), 13 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 95fb1c8..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() != 2) {
+ if (one == null || one.getStatus() != 2) {
throw new ServiceException("请先完成" + gxStepDO.getGxStepName() + "的审批！");
}
}
@@ -235,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()) {
diff --git a/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sg/service/impl/SgProjectInfoServiceImpl.java b/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sg/service/impl/SgProjectInfoServiceImpl.java
index 0ca5672..dbfa170 100644
--- a/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sg/service/impl/SgProjectInfoServiceImpl.java
+++ b/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sg/service/impl/SgProjectInfoServiceImpl.java
@@ -11,6 +11,7 @@
import cn.gistack.sm.sg.service.SgProjectInfoService;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
+import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.beans.factory.annotation.Autowired;
@@ -118,8 +119,14 @@
public Map<String, Long> projectCount(ProjectSearchDTO searchDTO) {
Map<String, Long> map = new HashMap<>();
LambdaQueryChainWrapper<SgProjectInfoDO> wrapper = new LambdaQueryChainWrapper<>(sgProjectInfoMapper);
- wrapper.like(SgProjectInfoDO::getProjectName,searchDTO.getProjectName());
- wrapper.eq(SgProjectInfoDO::getStatus,searchDTO.getStatus());
+ String projectName = searchDTO.getProjectName();
+ Integer status = searchDTO.getStatus();
+ if (StringUtils.isNotBlank(projectName)){
+ wrapper.like(SgProjectInfoDO::getProjectName,searchDTO.getProjectName());
+ }
+ if (status!=null){
+ wrapper.eq(SgProjectInfoDO::getStatus,searchDTO.getStatus());
+ }
List<SgProjectInfoDO> list = wrapper.list();
List<SgProjectInfoDO> pending = list.stream().filter(s -> s.getStatus() == 0).collect(Collectors.toList());
List<SgProjectInfoDO> progress = list.stream().filter(s -> s.getStatus() == 1).collect(Collectors.toList());
--
Gitblit v1.9.3