From b51fc02e94099f3419781cb59b3a6d8762bddaf3 Mon Sep 17 00:00:00 2001
From: shenyijian <1178253012@qq.com>
Date: Thu, 20 Jun 2024 16:28:48 +0800
Subject: [PATCH] 湖北水库:施工:根据设备查询审批ID、审批待办列表分页

---
 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sg/service/impl/SgProgressReportServiceImpl.java |   50 ++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 50 insertions(+), 0 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 f4e98eb..592c530 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
@@ -10,6 +10,7 @@
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 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.conditions.update.LambdaUpdateChainWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -69,6 +70,7 @@
 	public void add(SgProgressReportDO sgProgressReportDO) {
 		Date now = DateUtil.now();
 		sgProgressReportDO.setReportTime(now);
+		sgProgressReportDO.setCreateTime(now);
 		Long gxDeviceId = sgProgressReportDO.getGxDeviceId();
 		Long gxStepId = sgProgressReportDO.getGxStepId();
 		List<SgGxStepDO> list = sgGxStepMapper.selectByGxInfoId(gxDeviceId);
@@ -280,7 +282,9 @@
 	public Map<String, Long> countList(ProjectSearchDTO searchDTO) {
 		Long userId = AuthUtil.getUserId();
 		searchDTO.setUserId(userId);
+		searchDTO.setApprovalStatus(0);
 		Long pending = sgProgressReportMapper.countList(searchDTO);
+		searchDTO.setApprovalStatus(1);
 		Long over = sgProgressReportMapper.countList(searchDTO);
 		Map<String, Long> map = new HashMap<>();
 		map.put("pending",pending);
@@ -303,6 +307,52 @@
 		map.put("reject", (long) reject.size());
 		return map;
 	}
+
+	@Override
+	public boolean checkStep(Long gxDeviceId, Long gxStepId) {
+		List<SgGxStepDO> list = sgGxStepMapper.selectByGxInfoId(gxDeviceId);
+		SgGxStepDO sgGxStepDO = sgGxStepMapper.selectById(gxStepId);
+		QueryWrapper<SgProgressReportDO> wrapper = new QueryWrapper<>();
+		wrapper.eq("gx_step_id", gxStepId).eq("gx_device_id",gxDeviceId);
+		List<SgProgressReportDO> sgProgressReportDOS = sgProgressReportMapper.selectList(wrapper);
+		if ( sgProgressReportDOS!=null && sgProgressReportDOS.size()>0){
+			return false;
+		}
+		for (SgGxStepDO gxStepDO : list) {
+			if (Integer.parseInt(sgGxStepDO.getGxStepNum()) - Integer.parseInt(gxStepDO.getGxStepNum()) == 1) {
+				QueryWrapper<SgProgressReportDO> wrapper1 = new QueryWrapper<>();
+				wrapper1.eq("gx_step_id", gxStepDO.getId());
+				SgProgressReportDO one = sgProgressReportMapper.selectOne(wrapper1);
+				if (one == null || one.getStatus() != 2) {
+					return false;
+				}
+			}
+		}
+		return true;
+	}
+
+	@Override
+	public IPage<SgProgressReportVO> progressPage(IPage<SgProgressReportVO> page, ProjectSearchDTO searchDTO) {
+		Long userId = AuthUtil.getUserId();
+		searchDTO.setUserId(userId);
+		List<SgProgressReportVO> list = sgProgressReportMapper.queryList(page, searchDTO);
+		return page.setRecords(list);
+	}
+
+	@Override
+	public String getDeviceReport(Long gxDeviceId, Long gxStepId) {
+		QueryWrapper<SgProgressReportDO> wrapper = new QueryWrapper<>();
+		wrapper.eq("gx_device_id",gxDeviceId);
+		if (gxStepId!=null){
+			wrapper.eq("gx_step_id",gxStepId);
+		}
+		List<SgProgressReportDO> sgProgressReportDOS = sgProgressReportMapper.selectList(wrapper);
+		if (CollectionUtils.isNotEmpty(sgProgressReportDOS)){
+			sgProgressReportDOS.sort((u1, u2) -> u2.getCreateTime().compareTo(u1.getCreateTime()));
+		return sgProgressReportDOS.get(0).getId().toString();
+		}
+		return null;
+	}
 }
 
 

--
Gitblit v1.9.3