From 9a1fc806b7cd4e4e11778f9d3bf51987f8b7908b Mon Sep 17 00:00:00 2001
From: guoshilong <123456>
Date: Thu, 22 Feb 2024 11:59:04 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/jtdev' into jtdev

---
 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/service/impl/AttResFlseLimServiceImpl.java |   90 +++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 79 insertions(+), 11 deletions(-)

diff --git a/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/service/impl/AttResFlseLimServiceImpl.java b/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/service/impl/AttResFlseLimServiceImpl.java
index 7b7edd4..457472f 100644
--- a/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/service/impl/AttResFlseLimServiceImpl.java
+++ b/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/service/impl/AttResFlseLimServiceImpl.java
@@ -1,15 +1,18 @@
 package cn.gistack.sm.sjztmd.service.impl;
 
 
+import cn.gistack.sm.sjztmd.entity.AttResDangerManageSpecial;
 import cn.gistack.sm.sjztmd.entity.AttResFlseLim;
 import cn.gistack.sm.sjztmd.entity.AttResStagChar;
 import cn.gistack.sm.sjztmd.entity.AttResWaterBlock;
 import cn.gistack.sm.sjztmd.mapper.AttResFlseLimMapper;
+import cn.gistack.sm.sjztmd.service.IAttResDangerManageSpecialService;
 import cn.gistack.sm.sjztmd.service.IAttResFlseLimService;
 import cn.gistack.sm.sjztmd.service.IAttResStagCharService;
 import cn.gistack.sm.sjztmd.service.IAttResWaterBlockService;
 import cn.gistack.sm.sjztmd.vo.EditResInfoVO;
 import cn.gistack.system.user.feign.IUserClient;
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.dynamic.datasource.annotation.DS;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.baomidou.mybatisplus.extension.toolkit.SqlHelper;
@@ -19,6 +22,8 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
+
+import java.util.Date;
 
 /**
  * @PROJECT_NAME: skjcmanager
@@ -37,6 +42,9 @@
 	private IAttResWaterBlockService attResWaterBlockService;
 
 	@Autowired
+	private IAttResDangerManageSpecialService attResDangerManageSpecialService;
+
+	@Autowired
 	private IUserClient userClient;
 
 	@Override
@@ -45,26 +53,78 @@
 		editResInfoVO.setUpdateTime(DateUtil.now());
 
 		// 修改汛期水位
-		if (null != editResInfoVO.getXqswObjQ()) {
+		if (null != editResInfoVO.getXqswObjQ() && StringUtil.isNotBlank(String.valueOf(editResInfoVO.getXqswObjQ().getTbFlseLimStag()))) {
 			AttResFlseLim attResFlseLimQ = editResInfoVO.getXqswObjQ();
 			attResFlseLimQ.setResGuid(editResInfoVO.getResGuid());
 			attResFlseLimQ.setUpdateTime(DateUtil.now());
-			attResFlseLimQ.setUpdateBy(AuthUtil.getUserName() + "-" + userClient.userInfoById(AuthUtil.getUserId()).getData().getPhone());
-			baseMapper.updateAttResFlseLimByGuid(attResFlseLimQ,"前汛期");
+
+			JSONObject paramJson = new JSONObject();
+			paramJson.put("time", DateUtil.format(new Date(),"yyyy-MM-dd"));
+			String editPar = "tb_flse_lim_stag:修改值为" + editResInfoVO.getXqswObjQ().getTbFlseLimStag();
+			if (StringUtil.isNotBlank(editResInfoVO.getXqswObjQ().getTbFloodSeasonStart()))
+				editPar += ",tb_flood_season_start:修改值为" + editResInfoVO.getXqswObjQ().getTbFloodSeasonStart();
+			if (StringUtil.isNotBlank(editResInfoVO.getXqswObjQ().getTbFloodSeasonEnd()))
+				editPar += ",tb_flood_season_end:修改值为" + editResInfoVO.getXqswObjQ().getTbFloodSeasonEnd();
+			paramJson.put("editPar", editPar);
+			paramJson.put("ly", "ywxt");
+			paramJson.put("user_id", AuthUtil.getUserId());
+			paramJson.put("user_name", AuthUtil.getUserName());
+			paramJson.put("phone", userClient.userInfoById(AuthUtil.getUserId()).getData().getPhone());
+			attResFlseLimQ.setUpdateBy(paramJson.toJSONString());
+
+			Integer ret = baseMapper.updateAttResFlseLimByGuid(attResFlseLimQ,"前汛期");
+			if (ret == 0) {
+				baseMapper.addAttResFlseLim(attResFlseLimQ,"前汛期");
+			}
 		}
-		if (null != editResInfoVO.getXqswObjZ()) {
+		if (null != editResInfoVO.getXqswObjZ()  && StringUtil.isNotBlank(String.valueOf(editResInfoVO.getXqswObjZ().getTbFlseLimStag()))) {
 			AttResFlseLim attResFlseLimZ = editResInfoVO.getXqswObjZ();
 			attResFlseLimZ.setResGuid(editResInfoVO.getResGuid());
 			attResFlseLimZ.setUpdateTime(DateUtil.now());
-			attResFlseLimZ.setUpdateBy(AuthUtil.getUserName() + "-" + userClient.userInfoById(AuthUtil.getUserId()).getData().getPhone());
-			baseMapper.updateAttResFlseLimByGuid(attResFlseLimZ,"中汛期");
+
+			JSONObject paramJson = new JSONObject();
+			paramJson.put("time", DateUtil.format(new Date(),"yyyy-MM-dd"));
+			String editPar = "tb_flse_lim_stag:修改值为" + editResInfoVO.getXqswObjZ().getTbFlseLimStag();
+			if (StringUtil.isNotBlank(editResInfoVO.getXqswObjQ().getTbFloodSeasonStart()))
+				editPar += ",tb_flood_season_start:修改值为" + editResInfoVO.getXqswObjQ().getTbFloodSeasonStart();
+			if (StringUtil.isNotBlank(editResInfoVO.getXqswObjQ().getTbFloodSeasonEnd()))
+				editPar += ",tb_flood_season_end:修改值为" + editResInfoVO.getXqswObjQ().getTbFloodSeasonEnd();
+			paramJson.put("editPar", editPar);
+			paramJson.put("ly", "ywxt");
+			paramJson.put("user_id", AuthUtil.getUserId());
+			paramJson.put("user_name", AuthUtil.getUserName());
+			paramJson.put("phone", userClient.userInfoById(AuthUtil.getUserId()).getData().getPhone());
+			attResFlseLimZ.setUpdateBy(paramJson.toJSONString());
+
+			Integer ret = baseMapper.updateAttResFlseLimByGuid(attResFlseLimZ,"中汛期");
+
+			if (ret == 0) {
+				baseMapper.addAttResFlseLim(attResFlseLimZ,"中汛期");
+			}
 		}
-		if (null != editResInfoVO.getXqswObjH()) {
+		if (null != editResInfoVO.getXqswObjH() && StringUtil.isNotBlank(String.valueOf(editResInfoVO.getXqswObjH().getTbFlseLimStag()))) {
 			AttResFlseLim attResFlseLimH = editResInfoVO.getXqswObjH();
 			attResFlseLimH.setResGuid(editResInfoVO.getResGuid());
 			attResFlseLimH.setUpdateTime(DateUtil.now());
-			attResFlseLimH.setUpdateBy(AuthUtil.getUserName() + "-" + userClient.userInfoById(AuthUtil.getUserId()).getData().getPhone());
-			baseMapper.updateAttResFlseLimByGuid(attResFlseLimH,"后汛期");
+
+			JSONObject paramJson = new JSONObject();
+			paramJson.put("time", DateUtil.format(new Date(),"yyyy-MM-dd"));
+			String editPar = "tb_flse_lim_stag:修改值为" + editResInfoVO.getXqswObjH().getTbFlseLimStag();
+			if (StringUtil.isNotBlank(editResInfoVO.getXqswObjQ().getTbFloodSeasonStart()))
+				editPar += ",tb_flood_season_start:修改值为" + editResInfoVO.getXqswObjQ().getTbFloodSeasonStart();
+			if (StringUtil.isNotBlank(editResInfoVO.getXqswObjQ().getTbFloodSeasonEnd()))
+				editPar += ",tb_flood_season_end:修改值为" + editResInfoVO.getXqswObjQ().getTbFloodSeasonEnd();
+			paramJson.put("editPar", editPar);
+			paramJson.put("ly", "ywxt");
+			paramJson.put("user_id", AuthUtil.getUserId());
+			paramJson.put("user_name", AuthUtil.getUserName());
+			paramJson.put("phone", userClient.userInfoById(AuthUtil.getUserId()).getData().getPhone());
+			attResFlseLimH.setUpdateBy(paramJson.toJSONString());
+
+			Integer ret = baseMapper.updateAttResFlseLimByGuid(attResFlseLimH,"后汛期");
+			if (ret == 0) {
+				baseMapper.addAttResFlseLim(attResFlseLimH,"后汛期");
+			}
 		}
 
 		// 修改水位特征参数
@@ -88,13 +148,21 @@
 			attResStagChar.setWatShedArea(editResInfoVO.getWatShedArea());
 
 		// 修改坝顶高程
-		if (StringUtil.isNotBlank(editResInfoVO.getTopDamTopElevation())) {
+		if (StringUtil.isNotBlank(editResInfoVO.getTbDamTopElevation())) {
 			AttResWaterBlock resWaterBlock = new AttResWaterBlock();
 			resWaterBlock.setResGuid(editResInfoVO.getResGuid());
-			resWaterBlock.setTopDamTopElevation(editResInfoVO.getTopDamTopElevation());
+			resWaterBlock.setTbDamTopElevation(editResInfoVO.getTbDamTopElevation());
 			attResWaterBlockService.updateAttResWaterBlockByResId(resWaterBlock);
 		}
 
+		// 修改控制运行水位
+		if (StringUtil.isNotBlank(editResInfoVO.getTbControlZ())) {
+			AttResDangerManageSpecial attResDangerManageSpecial = new AttResDangerManageSpecial();
+			attResDangerManageSpecial.setResGuid(editResInfoVO.getResGuid());
+			attResDangerManageSpecial.setTbControlZ(editResInfoVO.getTbControlZ());
+			attResDangerManageSpecialService.updateAttResDangerManageSpecialByResId(attResDangerManageSpecial);
+		}
+
 		return attResStagCharService.customizeUpdateByGuid(attResStagChar);
 	}
 }

--
Gitblit v1.9.3