From bea24bbaa7f9863355e4c144823feec41c7374aa Mon Sep 17 00:00:00 2001
From: ForwithyNew <2008nmj@sina.com>
Date: Tue, 11 Jun 2024 11:48:38 +0800
Subject: [PATCH] =?UTF-8?q?/getHistoryStats=E6=8E=A5=E5=8F=A3=EF=BC=9A?=
 =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E7=AD=9B=E9=80=89=E6=9D=A1=E4=BB=B6(?=
 =?UTF-8?q?=E6=9A=B4=E9=9B=A8=E5=92=8C=E9=9B=B7=E9=9B=A8=E5=A4=A7=E9=A3=8E?=
 =?UTF-8?q?=EF=BC=8C=E7=BA=A2=E8=89=B2=E5=92=8C=E6=A9=99=E8=89=B2=EF=BC=8C?=
 =?UTF-8?q?=E8=B5=B7=E5=A7=8B=E6=97=B6=E9=97=B4)=E3=80=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/whdc/controller/QXWarnController.java     | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/src/main/java/com/whdc/controller/QXWarnController.java b/src/main/java/com/whdc/controller/QXWarnController.java
index b3f670d..bb82e3b 100644
--- a/src/main/java/com/whdc/controller/QXWarnController.java
+++ b/src/main/java/com/whdc/controller/QXWarnController.java
@@ -28,6 +28,8 @@ import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.time.LocalDate;
+import java.time.format.DateTimeFormatter;
 import java.util.*;
 import java.util.stream.Collectors;
 
@@ -715,14 +717,22 @@ public class QXWarnController {
         return zerofill(year)+"-"+zerofill(month)+"-"+zerofill(day)+" "+
                 "00"+":"+"00"+":"+"00";
     }
+    //统计函数
     private int getCount2(List<WarningData> data){
         int sum = 0;
+        DateTimeFormatter format = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
         List<WarningData.Warning> warnList = Lists.newArrayList();//汇总
         for (WarningData datum : data) {
             for (WarningData.TypeList typeList : datum.getTypeList()) {
                 warnList.addAll(typeList.getWarnList());
             }
         }
+        warnList = warnList.stream().filter(o -> {
+            LocalDate date = LocalDate.parse(o.getPublishTime(), format);
+            return date.isAfter(LocalDate.parse("2024-04-28 08:00:00", format));
+        }).collect(Collectors.toList());
+        warnList = warnList.stream().filter(o -> "暴雨".equals(o.getWarnSignalType())||"雷雨大风".equals(o.getWarnSignalType())).collect(Collectors.toList());
+        warnList = warnList.stream().filter(o -> "红色".equals(o.getWarnSignalLevel())||"橙色".equals(o.getWarnSignalLevel())).collect(Collectors.toList());
         return warnList.size();
     }
 }