From c0384b1730dcea830e387ea251d78f3512769e80 Mon Sep 17 00:00:00 2001
From: yxm <zhp1521624>
Date: Sat, 13 Jul 2024 11:39:40 +0800
Subject: [PATCH] 项目进度上报点击图标上报逻辑优化v0.2

---
 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sg/service/impl/SgProgressReportServiceImpl.java |   73 ++++++++++++++++++++++++++++++++++++
 1 files changed, 73 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 e817bb1..71d560e 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
@@ -4,6 +4,7 @@
 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.SgReportVO;
 import cn.gistack.sm.sg.VO.SgStepReportVO;
 import cn.gistack.sm.sg.mapper.*;
 import cn.gistack.sm.sg.service.SgProgressReportService;
@@ -83,6 +84,19 @@
 		if(sgProgressReportDO.getStatus()==4){
 			sgProgressReportMapper.insert(sgProgressReportDO);
 			return;
+		}
+		QueryWrapper<SgProgressReportDO> wrappers = new QueryWrapper<>();
+		wrappers.eq("profram_id", sgProgressReportDO.getProframId()).ne("status", 4).eq("gx_step_name", "施工准备");
+		List<SgProgressReportDO> sgProgressReportDOS1 = sgProgressReportMapper.selectList(wrappers);
+
+		if (sgProgressReportDOS1!= null && sgProgressReportDOS1.size() > 0) {
+			for (SgProgressReportDO sgProgressReportDO1 : sgProgressReportDOS1) {
+				if (sgProgressReportDO1.getStatus()!= 2) {
+					throw new ServiceException("请先完成施工准备的审批!");
+				}
+			}
+		} else if (sgProgressReportDOS1 == null || (!sgProgressReportDO.getGxStepName().equals("施工准备"))) {
+			throw new ServiceException("请先发起施工准备的审批!");
 		}
 		Long gxDeviceId = sgProgressReportDO.getGxDeviceId();
 		Long gxStepId = sgProgressReportDO.getGxStepId();
@@ -412,6 +426,65 @@
 		}
 		return null;
 	}
+
+	@Override
+	public SgReportVO getDeviceReportcopy(Long deviceId, Long stepId) {
+		SgReportVO sgReportVO = new SgReportVO();
+		QueryWrapper<SgProgressReportDO> wrapper = new QueryWrapper<>();
+		wrapper.eq("gx_device_id", deviceId).ne("status", 4);
+
+		if (stepId!= null) {
+			wrapper.eq("gx_step_id", stepId);
+		}
+
+		List<SgProgressReportDO> sgProgressReportDOS = sgProgressReportMapper.selectList(wrapper);
+
+		// 先检查列表是否为空,进行后续操作
+		if (CollectionUtils.isNotEmpty(sgProgressReportDOS)) {
+			sgProgressReportDOS.sort((u1, u2) -> u2.getCreateTime().compareTo(u1.getCreateTime()));
+			SgProgressReportDO firstReport = sgProgressReportDOS.get(0);
+
+			if (firstReport.getReportUser().equals(AuthUtil.getUserId()) && firstReport.getStatus().equals(3)) {
+				sgReportVO.setGxDeviceId(deviceId);
+				sgReportVO.setGxStepId(stepId);
+				sgReportVO.setId(firstReport.getId());
+				sgReportVO.setProframId(firstReport.getProframId());
+				return sgReportVO;
+			} else {
+				sgReportVO.setGxDeviceId(deviceId);
+				sgReportVO.setGxStepId(stepId);
+				sgReportVO.setId(firstReport.getId());
+				sgReportVO.setProframId(firstReport.getProframId());
+				return sgReportVO;
+			}
+		} else {
+
+
+			QueryWrapper<SgProgressReportDO> wrappers = new QueryWrapper<>();
+			wrappers.eq("gx_device_id", deviceId).ne("status", 4).orderByDesc("create_time");
+
+			sgProgressReportDOS = sgProgressReportMapper.selectList(wrappers);
+
+
+			if (CollectionUtils.isNotEmpty(sgProgressReportDOS)) {
+				sgProgressReportDOS.sort((u1, u2) -> u2.getCreateTime().compareTo(u1.getCreateTime()));
+				SgProgressReportDO firstReport = sgProgressReportDOS.get(0);
+
+				if (firstReport.getReportUser().equals(AuthUtil.getUserId()) && firstReport.getStatus().equals(2)) {
+					sgReportVO.setGxDeviceId(deviceId);
+					sgReportVO.setGxStepId(stepId);
+					sgReportVO.setProframId(firstReport.getProframId());
+				} else {
+					throw new ServiceException("请完成上一步工序!");
+				}
+			}
+		}
+		sgReportVO.setGxDeviceId(deviceId);
+		sgReportVO.setGxStepId(stepId);
+		sgReportVO.setProframId(sgProgressReportMapper.selectProframId(deviceId));
+
+		return sgReportVO;
+	}
 }
 
 

--
Gitblit v1.9.3