From 1dd5d8f8a616f5cf3caa7828d46989c7d3dcafc4 Mon Sep 17 00:00:00 2001
From: xieb <vip_xiaobin810@163.com>
Date: Thu, 19 Oct 2023 15:01:43 +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/AttStBaseServiceImpl.java | 44 ++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 44 insertions(+), 0 deletions(-)
diff --git a/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/service/impl/AttStBaseServiceImpl.java b/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/service/impl/AttStBaseServiceImpl.java
index cc87734..345589a 100644
--- a/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/service/impl/AttStBaseServiceImpl.java
+++ b/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/sjztmd/service/impl/AttStBaseServiceImpl.java
@@ -6,10 +6,54 @@
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springblade.core.mp.base.BaseServiceImpl;
+import org.springblade.core.mp.support.Condition;
+import org.springblade.core.tool.utils.StringUtil;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springblade.core.tool.utils.ObjectUtil;
+
+import java.util.List;
@Service
@DS("zt")
public class AttStBaseServiceImpl extends ServiceImpl<AttStBaseMapper, AttStBase> implements IAttStBaseService {
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public boolean updateById(AttStBase entity) {
+ AttStBase base = new AttStBase();
+ if (ObjectUtil.isNotEmpty(entity.getIsMainRain())&&entity.getIsMainRain().equals(1)){
+ //设置雨情站为主站
+ //获取该水库下的所有雨情站
+ base.setResGuid(entity.getResGuid());
+ base.setIsPptn(1);
+ List<AttStBase> list = list(Condition.getQueryWrapper(base));
+ //设置所有雨量站为辅站
+ list.forEach(e->{
+ e.setIsMainRain(0);
+ });
+ updateBatchById(list);
+ //设置该站为主站
+ }else if (ObjectUtil.isNotEmpty(entity.getIsMainRsvr())&&entity.getIsMainRsvr().equals(1)){
+ //设置水情站为主站
+ //获取该水库下的所有水情站
+ base.setResGuid(entity.getResGuid());
+ base.setIsRsvr(1);
+ List<AttStBase> list = list(Condition.getQueryWrapper(base));
+ //设置所有水情站为辅站
+ list.forEach(e->{
+ e.setIsMainRsvr(0);
+ });
+ updateBatchById(list);
+ //设置该站为主站
+ }
+ return super.updateById(entity);
+ }
+
+ @Override
+ public List<AttStBase> selectAttStBaseRadius(AttStBase attStBase) {
+ if (StringUtil.isBlank(attStBase.getStationLongitude()) || StringUtil.isBlank(attStBase.getStationLatitude()) || StringUtil.isBlank(attStBase.getRadius()))
+ return null;
+ return baseMapper.selectAttStBaseRadius(attStBase);
+ }
}
--
Gitblit v1.9.3