From efe4e8e1cdd3a01a8d2873d16c7a4d101956ae58 Mon Sep 17 00:00:00 2001
From: guoshilong <123456>
Date: Tue, 07 Nov 2023 18:03:46 +0800
Subject: [PATCH] 监测预警饼图接口

---
 skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/damSecurity/service/impl/DamSecurityServiceImpl.java |  112 +++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 111 insertions(+), 1 deletions(-)

diff --git a/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/damSecurity/service/impl/DamSecurityServiceImpl.java b/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/damSecurity/service/impl/DamSecurityServiceImpl.java
index baf182a..ddd2690 100644
--- a/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/damSecurity/service/impl/DamSecurityServiceImpl.java
+++ b/skjcmanager/skjcmanager-service/skjcmanager-sm/src/main/java/cn/gistack/sm/damSecurity/service/impl/DamSecurityServiceImpl.java
@@ -1,11 +1,19 @@
 package cn.gistack.sm.damSecurity.service.impl;
 
+import cn.gistack.nky.vo.AlarmGetVO;
 import cn.gistack.sm.damSecurity.mapper.DamSecurityMapper;
 import cn.gistack.sm.damSecurity.service.IDamSecurityService;
-import cn.gistack.sm.damSecurity.vo.DamSecurityStatistics;
+import cn.gistack.sm.damSecurity.vo.*;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import org.springblade.core.tool.utils.ObjectUtil;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.io.UnsupportedEncodingException;
+import java.net.URLDecoder;
+import java.nio.charset.StandardCharsets;
+import java.util.ArrayList;
+import java.util.HashMap;
 import java.util.List;
 
 @Service
@@ -23,4 +31,106 @@
 	public List<DamSecurityStatistics> listRegionCount(DamSecurityStatistics damSecurityStatistics) {
 		return damSecurityMapper.listRegionCount(damSecurityStatistics);
 	}
+
+	@Override
+	public List<DamStationStatistics> tableResCount(DamStationStatistics damStationStatistics) {
+		return damSecurityMapper.tableResCount(damStationStatistics);
+	}
+
+	@Override
+	public IPage<DamStationStatistics> tableResCountPage(DamStationStatistics damStationStatistics, IPage<DamStationStatistics> page) {
+		return page.setRecords(damSecurityMapper.tableResCountPage(damStationStatistics,page));
+	}
+
+	@Override
+	public List<DamStationStatistics> alarmResCount(DamStationStatistics damStationStatistics,String basCode) {
+		return damSecurityMapper.alarmResCount(damStationStatistics,basCode);
+	}
+
+	@Override
+	public List<DamStatisticsRes> damResInfoCount(String adCode) {
+
+		List<DamStatisticsRes> list = damSecurityMapper.damResInfoCount(adCode);
+
+//		list.forEach(damStatisticsRes -> {
+//			List<DamStationStatistics> errorList = damSecurityMapper.getResErrorList(damStatisticsRes,adCode);
+//			damStatisticsRes.setErrorList(errorList);
+//		});
+//
+//		list.forEach(damStatisticsRes -> {
+//			List<DamStationStatistics> normalList = new ArrayList<>();
+//			if (damStatisticsRes.getType().equals("1")){
+//				//渗压
+//				normalList = damSecurityMapper.getResSyNormalList(adCode);
+//			}else if (damStatisticsRes.getType().equals("2")){
+//				//渗流
+//				normalList = damSecurityMapper.getResSlNormalList(adCode);
+//			}else if (damStatisticsRes.getType().equals("3")){
+//				//位移
+//				 normalList = damSecurityMapper.getResWyNormalList(adCode);
+//			}
+//			damStatisticsRes.setNormalList(normalList);
+//		});
+
+		return list;
+	}
+
+	@Override
+	public List<DamStationStatistics> damResInfoCountMap(HashMap<String,String>  obj) {
+		String type = obj.get("type");
+		String adCode = obj.get("adCode");
+		String status = obj.get("status");
+
+
+		List<DamStationStatistics> list = new ArrayList<>();
+		if (type.equals("sy")){
+			list = damSecurityMapper.getSyList(adCode,status);
+		}else if (type.equals("sl")){
+			list = damSecurityMapper.getSlList(adCode,status);
+		}else if (type.equals("wy")){
+			list = damSecurityMapper.getWyList(adCode,status);
+		}else {
+			return null;
+		}
+
+		return list;
+	}
+
+	@Override
+	public List<DamMonitor> listRegionCountMonitor(DamMonitor damMonitor) {
+
+		List<DamMonitor> regionList = getRegionList(damMonitor);
+		regionList.forEach(region ->{
+			damMonitor.setAdCode(region.getAdCode());
+			List<LevelPo> levelPoList = damSecurityMapper.getLevelList(damMonitor);
+			region.setLevelList(levelPoList);
+		});
+		return regionList;
+	}
+
+	@Override
+	public IPage<AlarmGetVO> pageMonitor(AlarmGetVO alarmGet, IPage<AlarmGetVO> page) {
+
+		//位移
+		if (alarmGet.getType().equals("3")){
+			List<AlarmGetVO> list =  damSecurityMapper.pageMonitorWy(page,alarmGet);
+			return page.setRecords(list);
+		}else{
+			List<AlarmGetVO> list =  damSecurityMapper.pageMonitor(page,alarmGet);
+			return page.setRecords(list);
+		}
+
+	}
+
+	@Override
+	public List<LevelPo> levelMonitorPie(DamMonitor damMonitor) {
+		List<LevelPo> levelPoList = damSecurityMapper.getLevelList(damMonitor);
+		return levelPoList;
+	}
+
+
+	public List<DamMonitor> getRegionList(DamMonitor damMonitor){
+		return damSecurityMapper.getRegionList(damMonitor);
+	}
+
 }

--
Gitblit v1.9.3