From bc76e975aae3837eae625a2e3ffff7d02a5fc3f3 Mon Sep 17 00:00:00 2001
From: tangzy <tangzy123456>
Date: Mon, 13 Sep 2021 17:27:24 +0800
Subject: [PATCH] 1.山洪

---
 src/main/java/org/springblade/modules/mountainrain/controller/MountainrainController.java |  183 ++++++++++++++++++++++++++-------------------
 1 files changed, 104 insertions(+), 79 deletions(-)

diff --git a/src/main/java/org/springblade/modules/mountainrain/controller/MountainrainController.java b/src/main/java/org/springblade/modules/mountainrain/controller/MountainrainController.java
index d829e5e..0297cf2 100644
--- a/src/main/java/org/springblade/modules/mountainrain/controller/MountainrainController.java
+++ b/src/main/java/org/springblade/modules/mountainrain/controller/MountainrainController.java
@@ -41,6 +41,7 @@
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
 import springfox.documentation.annotations.ApiIgnore;
+
 import javax.validation.Valid;
 import java.math.BigDecimal;
 import java.text.SimpleDateFormat;
@@ -49,7 +50,7 @@
 import java.util.*;
 
 /**
- *  控制器
+ * 控制器
  *
  * @author BladeX
  * @since 2020-02-27
@@ -384,69 +385,68 @@
 	 */
 	@ApiLog("查询洪水预警")
 	@GetMapping("/ss")
-	public R selectcInfos(int type,String time,String dateEnds1,String dateEnds3,String dateEnds6,String dateEnds24,int k,String timei) {
-		if (type == 0 && k==13) {
+	public R selectcInfos(int type, String time, String dateEnds1, String dateEnds3, String dateEnds6, String dateEnds24, int k, String timei) {
+		if (type == 0 && k == 13) {
 			//当前时间
 			String times = time;
 
 			String dateEnd1 = dateEnds1;
 
-			String timess=timei;
+			String timess = timei;
 
 			//三个小时前的时间
-			String dateEnd3 =dateEnds3;
+			String dateEnd3 = dateEnds3;
 
 			//六个小时前的时间
-			String dateEnd6 =dateEnds6;
+			String dateEnd6 = dateEnds6;
 
 			//二十四个小时前的时间
-			String dateEnd24 =dateEnds24;
+			String dateEnd24 = dateEnds24;
 
 			//对应雨量站
-			long startTime=System.currentTimeMillis();
-			List<MountainrainsCVO> mountainrainsCVOS = mountainrainService.selectcInfos(times, dateEnd24, dateEnd1, dateEnd3, dateEnd6,timess);
+			long startTime = System.currentTimeMillis();
+			List<MountainrainsCVO> mountainrainsCVOS = mountainrainService.selectcInfos(times, dateEnd24, dateEnd1, dateEnd3, dateEnd6, timess);
 			List<Map<String, Object>> lists = new ArrayList<>();
 			for (int i = 0; i < mountainrainsCVOS.size(); i++) {
-				if (mountainrainsCVOS.get(i).getCenconding()==null){
+				if (mountainrainsCVOS.get(i).getCenconding() == null) {
 					continue;
 				}
 				Map<String, Object> map = new HashMap<String, Object>();
-					int Max =mountainrainService .Max(mountainrainsCVOS.get(i).getDrp1(), mountainrainsCVOS.get(i).getDrp3(),
-						mountainrainsCVOS.get(i).getGohour(), mountainrainsCVOS.get(i).getGthour());
-					map.put("List", mountainrainsCVOS.get(i));
-					map.put("Max", Max);
-					lists.add(map);
+				int Max = mountainrainService.Max(mountainrainsCVOS.get(i).getDrp1(), mountainrainsCVOS.get(i).getDrp3(),
+					mountainrainsCVOS.get(i).getGohour(), mountainrainsCVOS.get(i).getGthour());
+				map.put("List", mountainrainsCVOS.get(i));
+				map.put("Max", Max);
+				lists.add(map);
 			}
 			return R.data(lists);
 
-		}
-		else {
+		} else {
 			//当前时间
 			String times = time;
 
 			String dateEnd1 = dateEnds1;
 
-			String timess=timei;
+			String timess = timei;
 
 			//三个小时前的时间
-			String dateEnd3 =dateEnds3;
+			String dateEnd3 = dateEnds3;
 
 			//六个小时前的时间
-			String dateEnd6 =dateEnds6;
+			String dateEnd6 = dateEnds6;
 
 			//二十四个小时前的时间
-			String dateEnd24 =dateEnds24;
+			String dateEnd24 = dateEnds24;
 
 			//对应雨量站
-			List<MountainrainsCVO> mountainrainsCVOS = mountainrainService.selectcInfo(times, dateEnd24, dateEnd1, dateEnd3, dateEnd6,timess);
+			List<MountainrainsCVO> mountainrainsCVOS = mountainrainService.selectcInfo(times, dateEnd24, dateEnd1, dateEnd3, dateEnd6, timess);
 			List<Map<String, Object>> lists = new ArrayList<>();
 			for (int i = 0; i < mountainrainsCVOS.size(); i++) {
 				Map<String, Object> map = new HashMap<String, Object>();
-					int Max = mountainrainService.Max(mountainrainsCVOS.get(i).getDrp1(), mountainrainsCVOS.get(i).getDrp3(),
-						mountainrainsCVOS.get(i).getGohour(), mountainrainsCVOS.get(i).getGthour());
-					map.put("List", mountainrainsCVOS.get(i));
-					map.put("Max", Max);
-					lists.add(map);
+				int Max = mountainrainService.Max(mountainrainsCVOS.get(i).getDrp1(), mountainrainsCVOS.get(i).getDrp3(),
+					mountainrainsCVOS.get(i).getGohour(), mountainrainsCVOS.get(i).getGthour());
+				map.put("List", mountainrainsCVOS.get(i));
+				map.put("Max", Max);
+				lists.add(map);
 
 			}
 			return R.data(lists);
@@ -460,19 +460,19 @@
 	 */
 	@ApiLog("查询洪水预警")
 	@GetMapping("/sss")
-	public R selectcInfoss(int type,String time,String dateEnds1,String dateEnds2,String dateEnds3,int k) {
+	public R selectcInfoss(int type, String time, String dateEnds1, String dateEnds2, String dateEnds3) {
 		//第二种方式预警
-		if (type == 0 && k==13) {
+		if (type == 0) {
 			//当前时间
 			String times = time;
 
 			String dateEnd1 = dateEnds1;
 
 			//2个小时前的时间
-			String dateEnd2 =dateEnds2;
+			String dateEnd2 = dateEnds2;
 
 			//3个小时前的时间
-			String dateEnd3 =dateEnds3;
+			String dateEnd3 = dateEnds3;
 
 			//对应雨量站
 			String s = mountainrainService.selectCode();
@@ -482,22 +482,21 @@
 				strArrays += "'" + split[i] + "',";
 			}
 			String code = strArrays.substring(0, strArrays.length() - 1);
-			List<MountainrainsCVO> mountainrainsCVOS = mountainrainService.Mountains(times, dateEnd1, dateEnd2, dateEnd3,code);
+			List<MountainrainsCVO> mountainrainsCVOS = mountainrainService.Mountains(times, dateEnd1, dateEnd2, dateEnd3, code);
 			List<Map<String, Object>> lists = new ArrayList<>();
 			for (int i = 0; i < mountainrainsCVOS.size(); i++) {
-				if (mountainrainsCVOS.get(i).getCenconding()==null){
+				if (mountainrainsCVOS.get(i).getCenconding() == null) {
 					continue;
 				}
 				Map<String, Object> map = new HashMap<String, Object>();
-				if (mountainrainsCVOS.get(i).getSoilval()>30){
-					int Max =mountainrainService .Max(mountainrainsCVOS.get(i).getDrp1(), mountainrainsCVOS.get(i).getDrp3(),
+				if (mountainrainsCVOS.get(i).getSoilval() > 30) {
+					int Max = mountainrainService.Max(mountainrainsCVOS.get(i).getDrp1(), mountainrainsCVOS.get(i).getDrp3(),
 						mountainrainsCVOS.get(i).getGohours(), mountainrainsCVOS.get(i).getGthours());
 					map.put("List", mountainrainsCVOS.get(i));
 					map.put("Max", Max);
 					lists.add(map);
-				}
-				else {
-					int Max =mountainrainService .Max(mountainrainsCVOS.get(i).getDrp1(), mountainrainsCVOS.get(i).getDrp3(),
+				} else {
+					int Max = mountainrainService.Max(mountainrainsCVOS.get(i).getDrp1(), mountainrainsCVOS.get(i).getDrp3(),
 						mountainrainsCVOS.get(i).getGohour(), mountainrainsCVOS.get(i).getGthour());
 					map.put("List", mountainrainsCVOS.get(i));
 					map.put("Max", Max);
@@ -517,10 +516,10 @@
 			String dateEnd1 = dateEnds1;
 
 			//两个小时前的时间
-			String dateEnd2 =dateEnds2;
+			String dateEnd2 = dateEnds2;
 
 			//三个小时前的时间
-			String dateEnd3 =dateEnds3;
+			String dateEnd3 = dateEnds3;
 
 			String s = regionWeightService.selectCode();
 			String[] split = s.split(",");
@@ -530,73 +529,99 @@
 			}
 			String code = strArrays.substring(0, strArrays.length() - 1);
 			List<Map<String, Integer>> list = mountainrainService.selecMone(times, dateEnd1, dateEnd2, dateEnd3, code);
-		    List list1= new ArrayList();
-		    List list2= new ArrayList();
-		    List list3= new ArrayList();
-			for (int i=0;i<list.size();i++){
-				if (list.get(i).get("drp1")>=30){
-						list1.add(list.get(i));
+			List<Map<String, Object>> lists = new ArrayList<>();
+			Map<String, Object> map = new HashMap<String, Object>();
+			for (int i = 0; i < list.size(); i++) {
+				if (list.get(i).get("drp1") >= 30) {
+					map.put("List", list.get(i));
+					map.put("Max", 1);
 				}
-				if (list.get(i).get("drp2")>=50) {
-					list2.add(list.get(i));
+				if (list.get(i).get("drp2") >= 50) {
+					map.put("List", list.get(i));
+					map.put("Max", 2);
 				}
-				if (list.get(i).get("drp3")>=80) {
-					list3.add(list.get(i));
+				if (list.get(i).get("drp3") >= 80) {
+					map.put("List", list.get(i));
+					map.put("Max", 3);
 				}
 
 			}
-			Map map = new HashMap();
-			map.put("list1",list1);
-			map.put("list2",list2);
-			map.put("list2",list3);
-			return R.data(map);
+			lists.add(map);
+			return R.data(lists);
 		}
 
 	}
 
 	/**
 	 * 土壤湿度计算
+	 *
 	 * @return
 	 */
-	@Scheduled(cron = "0 0 8 * * ?")
+	//@Scheduled(cron = "0 0 8 * * ?")
 	@GetMapping("/soleval")
 	public R soleval() {
-		SimpleDateFormat sdf = new SimpleDateFormat( "yyyy-MM-dd 08:00:00" );
-		Date today = new Date();
-		String endDate = sdf .format( today ); //当前日期
-		//获取三十天前日期
-		Calendar theCa = Calendar. getInstance ();
-		theCa .setTime( today );
-		theCa .add( theCa . DATE , -30); //最后一个数字30可改,30天的意思
-		Date start = theCa .getTime();
-		String startDate = sdf .format( start ); //三十天之前日期
+		mountainrainService.soildel();
+		int intervals = 31;
+		ArrayList passDaysList = new ArrayList<>();
+		for (int i = 0; i < intervals; i++) {
+			passDaysList.add(getDays(i, false));
+		}
+		Collections.sort(passDaysList);
 		String s = mountainrainService.selectCode();
+		//String s = "62310356,62310305";
 		String[] split = s.split(",");
 		String strArrays = "";
-		Integer num=60;
 		for (int i = 0; i < split.length; i++) {
 			strArrays += "'" + split[i] + "',";
 		}
 		String code = strArrays.substring(0, strArrays.length() - 1);
-		mountainrainService.soildel();
-		List<Map<String, Object>> list = mountainrainService.selectMtwo(startDate, endDate, code);
-		for (int i=0;i<list.size();i++){ ;
-			BigDecimal w = (BigDecimal) list.get(i).get("drp");
-			double drp = w.doubleValue();
-			String stcd = list.get(i).get("STCD").toString();
-			//计算湿度
-			double v = (num + drp) * 0.85;
-			if (v>60){
-				mountainrainService.soleInster(stcd,"60");
+		for (int i = 0; i < split.length; i++) {
+			Integer num = 30;
+			double v1 = 0;
+			String stcd = null;
+		for (int j = 0; j < passDaysList.size() - 1; j++) {
+			List<Map<String, Object>> map = mountainrainService.selectMtwo(passDaysList.get(j).toString(), passDaysList.get(j + 1).toString(), code);
+			if (map.size()==0){
+				continue;
 			}
-			else {
-				String a= String.valueOf(v);
-				mountainrainService.soleInster(stcd,a);
+			BigDecimal w = (BigDecimal) map.get(i).get("drp");
+			double drp = w.doubleValue();
+			stcd = map.get(i).get("STCD").toString();
+			//计算湿度
+			if (i == 0) {
+				v1 = formatDouble1((num + drp) * 0.85);
+			} else {
+				v1 += drp;
+				v1 = formatDouble1(v1 * 0.85);
 			}
 		}
+			if (v1 > 60) {
+				mountainrainService.soleInster(stcd, "60");
+			} else {
+				String a = String.valueOf(v1);
+				mountainrainService.soleInster(stcd, a);
+			}
+		}
+
 		return R.success("成功");
 	}
 
+	public static double formatDouble1(double d) {
+		return (double) Math.round(d * 10) / 10;
+	}
+
+	private static String getDays(int i, boolean b) {
+		Calendar calendar = Calendar.getInstance();
+		if (b) {
+			calendar.set(Calendar.DAY_OF_YEAR, calendar.get(Calendar.DAY_OF_YEAR) + i);
+		} else {
+			calendar.set(Calendar.DAY_OF_YEAR, calendar.get(Calendar.DAY_OF_YEAR) - i);
+		}
+		Date today = calendar.getTime();
+		SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd 08:00:00");
+		String result = format.format(today);
+		return result;
+	}
 
 }
 

--
Gitblit v1.9.3