| | |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void insertCityAqiDaily() { |
|---|
| | | List<String> sensors = Arrays.asList("PM2_5", "PM10", "SO2", "NO2", "CO", "O3", "AQI"); |
|---|
| | | //需要均值计算的因子 |
|---|
| | | List<String> sensors = Arrays.asList("PM2_5", "PM10", "SO2", "NO2", "CO"); |
|---|
| | | String format = DateUtils.yyyy_MM_dd_EN; |
|---|
| | | Date now = new Date(); |
|---|
| | | //开始时间，昨日 |
|---|
| | |
|---|
| | | //移除第一天数据（0点的），O3滑动值第一条数据是从1点-8点 |
|---|
| | | value.removeIf(map -> ((Date) map.get("time")).getTime() == start.getTime()); |
|---|
| | | |
|---|
| | | //臭氧日均值计算，滑动值算法 |
|---|
| | | //O3日均值单独计算，滑动值算法 |
|---|
| | | Double o3OfDay = AmendUtils.o3OfDay(value); |
|---|
| | | if (o3OfDay != null) { |
|---|
| | | jsonMap.put("O3", o3OfDay); |
|---|
| | |
|---|
| | | sensors.forEach(sensor -> { |
|---|
| | | OptionalDouble optionalDouble = tempValue.parallelStream().flatMapToDouble(v -> { |
|---|
| | | Map<String, Object> dataValue = JSONObject.parseObject((String) v.get("value"), Map.class); |
|---|
| | | //臭氧单独计算 |
|---|
| | | if ("O3".equals(sensor)) { |
|---|
| | | return null; |
|---|
| | | } |
|---|
| | | |
|---|
| | | //aqi单独计算 |
|---|
| | | if ("AQI".equals(sensor)) { |
|---|
| | | return null; |
|---|
| | | } |
|---|
| | | |
|---|
| | | Object sensorValue = dataValue.get(sensor); |
|---|
| | | if (ObjectUtils.isEmpty(sensorValue)) { |
|---|
| | | return null; |
|---|
