| | |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | | import org.springframework.util.ObjectUtils; |
|---|
| | | |
|---|
| | | import java.util.ArrayList; |
|---|
| | | import java.util.Arrays; |
|---|
| | | import java.util.Date; |
|---|
| | | import java.util.HashMap; |
|---|
| | |
|---|
| | | QueryWrapper<CityAqi> wrapper = new QueryWrapper<>(); |
|---|
| | | wrapper.select("city_code", "time", "value") |
|---|
| | | .ge("time", DateUtils.dateToDateString(start)) |
|---|
| | | .lt("time", DateUtils.dateToDateString(end)); |
|---|
| | | .le("time", DateUtils.dateToDateString(end)); |
|---|
| | | List<Map<String, Object>> dailyData = cityAqiService.listMaps(wrapper); |
|---|
| | | |
|---|
| | | if (dailyData.size() == 0) { |
|---|
| | |
|---|
| | | cityAqiDaily.setCityCode(Integer.parseInt(cityCode)); |
|---|
| | | cityAqiDaily.setTime(start); |
|---|
| | | |
|---|
| | | //臭氧采用滑动值算法 |
|---|
| | | //中间变量，用于计算除臭氧外其它因子 |
|---|
| | | List<Map<String, Object>> tempValue = new ArrayList<>(value); |
|---|
| | | |
|---|
| | | //移除第一天数据（0点的），O3滑动值第一条数据是从1点-8点 |
|---|
| | | value.removeIf(map -> ((Date) map.get("time")).getTime() == start.getTime()); |
|---|
| | | |
|---|
| | | Double o3OfDay = AmendUtils.o3OfDay(value); |
|---|
| | | if (o3OfDay != null) { |
|---|
| | | jsonMap.put("o3", o3OfDay); |
|---|
| | | } |
|---|
| | | //除臭氧外其他因子均值计算 |
|---|
| | | tempValue.removeIf(o -> ((Date) o.get("time")).getTime() == end.getTime()); |
|---|
| | | |
|---|
| | | sensors.forEach(sensor -> { |
|---|
| | | OptionalDouble optionalDouble = value.parallelStream().flatMapToDouble(v -> { |
|---|
| | | OptionalDouble optionalDouble = tempValue.parallelStream().flatMapToDouble(v -> { |
|---|
| | | Map<String, Object> dataValue = JSONObject.parseObject((String) v.get("value"), Map.class); |
|---|
| | | //臭氧单独计算 |
|---|
| | | if ("o3".equals(sensor)) { |
|---|
