| | |
| | | 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; |
| | |
| | | import com.moral.api.pojo.dto.cityAQI.ConcentrationAndPercent; |
| | | import com.moral.api.pojo.form.aqi.AirQualityComparisonForm; |
| | | import com.moral.api.pojo.vo.cityAQI.AirQualityComparisonVO; |
| | | import com.moral.api.pojo.vo.cityAQI.CityAreaRangeVO; |
| | | import com.moral.api.service.*; |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | | import com.moral.constant.Constants; |
| | |
| | | private HistoryHourlyService historyHourlyService; |
| | | |
| | | @Autowired |
| | | SpecialCitiesProperties citiesProperties; |
| | | |
| | | @Autowired |
| | | private SysAreaMapper sysAreaMapper; |
| | | |
| | | @Override |
| | |
| | | } |
| | | 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) { |
| | |
| | | } |
| | | }); |
| | | |
| | | //今日累计O3_8H计算,取每小时O3_8H最大值 |
| | | //今日累计O3_8H计算,取每小时O3——8H最大值 |
| | | if (!ObjectUtils.isEmpty(doubles)) { |
| | | dataMap.put("O3_8H", Collections.max(doubles)); |
| | | } |
| | |
| | | /** |
| | | * @Description: 从数据库查询数据 |
| | | * @Param: [regionCode] |
| | | * @return: java.util.Map<java.lang.String, java.lang.Object> |
| | | * @return: java.util.Map<java.lang.String , java.lang.Object> |
| | | * @Author: 陈凯裕 |
| | | * @Date: 2021/10/28 |
| | | */ |
| | |
| | | */ |
| | | private ConcentrationAndPercent contrastParam(Double data, Double comparisonData, String sensor) { |
| | | double percentD = MathUtils.division(data - comparisonData, comparisonData, 4); |
| | | String percent = MathUtils.mul(percentD, 100d) + "%"; |
| | | String percent = MathUtils.mul(percentD,100d) + "%"; |
| | | ConcentrationAndPercent concentrationAndPercent = new ConcentrationAndPercent(); |
| | | concentrationAndPercent.setPercent(percent); |
| | | if (sensor.equals("CO")) {//CO小数点保留一位 |
| | | Double CO = AmendUtils.sciCal(data, 1); |
| | | concentrationAndPercent.setConcentration(CO.toString()); |
| | | } else if (sensor.equals("compositeIndex")) { |
| | | }else if (sensor.equals("compositeIndex")){ |
| | | concentrationAndPercent.setConcentration(data.toString()); |
| | | } else { |
| | | }else{ |
| | | Double sensorD = AmendUtils.sciCal(data, 0); |
| | | Integer sensorI = new Double(sensorD).intValue(); |
| | | concentrationAndPercent.setConcentration(sensorI.toString()); |
| | |
| | | /** |
| | | * @Description: 根据时间类型查询对应的6参以及综合指数,自定义时间类型用日数据做均值处理 |
| | | * @Param: [comparisonType, startDate, endDate, regionCode] |
| | | * @return: java.util.Map<java.lang.String, java.lang.Object> |
| | | * @return: java.util.Map<java.lang.String , java.lang.Object> |
| | | * @Author: 陈凯裕 |
| | | * @Date: 2022/1/17 |
| | | */ |
| | |
| | | private List<SysArea> getSysAreasByRegionType(String regionType, Integer regionCode) { |
| | | List<SysArea> areas; |
| | | if (regionType.equals(Constants.TWENTY_EIGHT_CITIES)) { |
| | | SpecialCitiesProperties properties = new SpecialCitiesProperties(); |
| | | areas = properties.getTwentyEightCities(); |
| | | areas = citiesProperties.getTwentyEightCities(); |
| | | } else { |
| | | areas = sysAreaService.getChildren(regionCode); |
| | | } |
| | |
| | | /** |
| | | * @Description: 计算6参平均值 |
| | | * @Param: [cityAqiList] |
| | | * @return: java.util.Map<java.lang.String, java.lang.Double> |
| | | * @return: java.util.Map<java.lang.String , java.lang.Double> |
| | | * 返回值key为sensorCode,value为值 |
| | | * @Author: 陈凯裕 |
| | | * @Date: 2021/11/2 |
| | |
| | | } |
| | | 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; |
| | | |
| | | } |
| | | |
| | | } |