| | |
| | | package com.moral.api.service.impl; |
| | | |
| | | import com.alibaba.excel.util.StringUtils; |
| | | import com.alibaba.fastjson.JSON; |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | |
| | | } |
| | | return result; |
| | | } |
| | | |
| | | |
| | | @Override |
| | | public List<Map<String, Object>> measuredCompareForecastOfO3_8H(Map<String, Object> params) { |
| | | String regionCode = params.get("regionCode").toString(); |
| | | String time = params.get("time").toString(); |
| | | Date endTime = DateUtils.getDate(time+" "+"23:00:00",DateUtils.yyyy_MM_dd_HH_mm_ss_EN); |
| | | Date startDate = DateUtils.getDate(time+" "+"00:00:00",DateUtils.yyyy_MM_dd_HH_mm_ss_EN); |
| | | Date startTime = DateUtils.addHours(startDate,-7); |
| | | //预测数据 |
| | | QueryWrapper<Forecast> forecastQueryWrapper = new QueryWrapper<>(); |
| | | forecastQueryWrapper.select("time", "value") |
| | | .eq("city_code", regionCode) |
| | | .between("time",startTime,endTime) |
| | | .orderByAsc("time"); |
| | | List<Map<String, Object>> forecastData = forecastMapper.selectMaps(forecastQueryWrapper); |
| | | //实测数据 |
| | | QueryWrapper<CityAqi> cityAqiQueryWrapper = new QueryWrapper<>(); |
| | | cityAqiQueryWrapper.select("time", "value") |
| | | .eq("city_code", regionCode) |
| | | .between("time",startTime,endTime).orderByAsc("time"); |
| | | List<Map<String, Object>> measuredData = cityAqiMapper.selectMaps(cityAqiQueryWrapper); |
| | | |
| | | List<Map<String, Object>> result = getO3_8H(forecastData,0,time); |
| | | result.addAll(getO3_8H(measuredData,1,time)); |
| | | return result; |
| | | } |
| | | |
| | | |
| | | @Override |
| | | public Map<String, Object> queryCityAqiByRegionCode(Integer regionCode) { |
| | |
| | | } |
| | | return s; |
| | | } |
| | | |
| | | public List<Map<String, Object>> getO3_8H(List<Map<String, Object>> data , int type,String day) { |
| | | List<Map<String, Object>> list = new ArrayList<>(); |
| | | for(int i = 0 ;i<=23;i++){ |
| | | Map<String, Object> map = new HashMap<>(); |
| | | if(type == 0){ |
| | | map.put("type","预测"); |
| | | }else { |
| | | map.put("type","实测"); |
| | | } |
| | | String times = day+" "+i; |
| | | Date endDate = DateUtils.getDate(times,DateUtils.yyyy_MM_dd_HH_EN); |
| | | Date startDate = DateUtils.addHours(DateUtils.getDate(day+" "+i,DateUtils.yyyy_MM_dd_HH_EN),-7); |
| | | List<Double> value = new ArrayList<>(); |
| | | for(Map<String, Object> m : data){ |
| | | Date time = (Date) m.get("time"); |
| | | if(DateUtils.isTimeBeforE(time,startDate) && DateUtils.isTimeBeforE(endDate,time)){ |
| | | Map<String, Object> sensorValue = JSONObject.parseObject((String) m.get("value"), Map.class); |
| | | Double o3 = Double.parseDouble(sensorValue.get("O3").toString()); |
| | | value.add(o3); |
| | | |
| | | } |
| | | } |
| | | if (value.size() < 6) { |
| | | continue; |
| | | } |
| | | double average = value.stream().mapToDouble(aDouble -> aDouble).summaryStatistics().getAverage(); |
| | | map.put("O3", new BigDecimal(average).setScale(3, BigDecimal.ROUND_HALF_UP).doubleValue()); |
| | | map.put("time",times); |
| | | list.add(map); |
| | | } |
| | | |
| | | return list; |
| | | |
| | | } |
| | | |
| | | } |