/getHistoryStats接口:添加筛选条件(暴雨和雷雨大风,红色和橙色,起始时间)。

master
ForwithyNew 2024-06-11 11:48:38 +08:00
parent 5de5e8429e
commit bea24bbaa7
1 changed files with 10 additions and 0 deletions

View File

@ -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();
}
}