blame | history | patch | commit | commitdiff | ignore whitespace
jinpengyong
2024-06-19 32cc13189371ee1e367897a64fbc22f90b53add8 
 screen-api/src/main/java/com/moral/api/service/impl/CityAqiServiceImpl.java


@@ -1,19 +1,19 @@


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.baomidou.mybatisplus.extension.plugins.pagination.Page;


import com.moral.api.config.properties.SpecialCitiesProperties;


import com.moral.api.dto.CityAqiDailyListDTO;


import com.moral.api.entity.*;


import com.moral.api.mapper.CityAqiMapper;


import com.moral.api.mapper.DeviceMapper;


import com.moral.api.mapper.ForecastMapper;


import com.moral.api.mapper.SysAreaMapper;


import com.moral.api.mapper.*;


import com.moral.api.pojo.dto.cityAQI.CityPollutionLevel;


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;


@@ -26,6 +26,7 @@




import com.moral.util.MathUtils;




import org.apache.commons.collections4.CollectionUtils;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.data.redis.core.RedisTemplate;


import org.springframework.stereotype.Service;


@@ -50,6 +51,8 @@




    @Autowired


    private CityAqiMapper cityAqiMapper;


    @Autowired


    private CityAqiDailyMapper cityAqiDailyMapper;




    @Autowired


    private ForecastMapper forecastMapper;


@@ -83,6 +86,9 @@




    @Autowired


    private HistoryHourlyService historyHourlyService;




    @Autowired


    SpecialCitiesProperties citiesProperties;




    @Autowired


    private SysAreaMapper sysAreaMapper;


@@ -143,6 +149,34 @@


        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) {


        Map<String, Object> value = (Map<String, Object>) redisTemplate.opsForHash().get(RedisConstants.CITY_AQI, String.valueOf(regionCode));


@@ -175,7 +209,7 @@


    @Override


    public Map<String, Object> query24HoursAqiByRegionCode(Integer regionCode) {


        //查询最新一条数据，用于获取最新的时间


        QueryWrapper<CityAqi> lastDataWrapper = new QueryWrapper<>();


        /*QueryWrapper<CityAqi> lastDataWrapper = new QueryWrapper<>();


        lastDataWrapper.eq("city_code", regionCode);


        lastDataWrapper.orderByDesc("time");


        lastDataWrapper.last(true, "limit 1");


@@ -188,39 +222,33 @@


        //查询数据


        QueryWrapper<CityAqi> wrapper = new QueryWrapper<>();


        wrapper.between("time", startDate, endDate);


        wrapper.eq("city_code", regionCode);


        List<CityAqi> cityAqis = cityAqiMapper.selectList(wrapper);


        wrapper.eq("city_code", regionCode);*/


        List<CityAqi> cityAqis = cityAqiMapper.listCity(regionCode);


        //如果数据不足24小时则补全


        if (cityAqis.size() != 24) {


            Map<Date, CityAqi> dateCityAqiMap = new HashMap<>();


            cityAqis.forEach(value -> dateCityAqiMap.put(value.getTime(), value));


        if(CollectionUtils.isEmpty(cityAqis)){


            return new HashMap<>();


        }


        Date startDate = cityAqis.get(0).getTime();


        if(cityAqis.size()<24){


            for (int i = 0; i < 24; i++) {


                Date date = DateUtils.addHours(startDate, i);


                CityAqi cityAqi1 = dateCityAqiMap.get(date);


                if (cityAqi1 == null) {


                Date dateTime = DateUtils.addHours(startDate, i);


                if(cityAqis.size()-1 <i){


                    CityAqi newCityAqi = new CityAqi();


                    newCityAqi.setTime(date);


                    newCityAqi.setTime(dateTime);


                    newCityAqi.setValue("0");


                    cityAqis.add(newCityAqi);


                    continue;


                }


            }


            //按照时间进行排序


            cityAqis.sort(Comparator.comparing(CityAqi::getTime));


        }


            //按照时间进行排序


        cityAqis.sort(Comparator.comparing(CityAqi::getTime));




        //封装返回数据,map的key为yyyy-MM-dd HH:mm格式的时间，value为aqi的数值


        Map<String, Object> result = new LinkedHashMap<>();


        for (CityAqi aqi : cityAqis) {


            String key = DateUtils.dateToDateString(aqi.getTime(), "yyyy-MM-dd HH:mm");


            String allDataJson = aqi.getValue();


            if (allDataJson == null) {


                result.put(key, "");


                continue;


            }


            Map<String, Object> allDataMap = JSON.parseObject(allDataJson, Map.class);


            Object aqiData = allDataMap.get("AQI");


            if (aqiData == null)


                result.put(key, "");


            else


                result.put(key, aqiData);


            result.put(key,aqi.getValue());


        }


        return result;


    }


@@ -372,7 +400,7 @@


                }


            });




            //今日累计O3_8H计算,取每小时O3_8H最大值


            //今日累计O3_8H计算,取每小时O3——8H最大值


            if (!ObjectUtils.isEmpty(doubles)) {


                dataMap.put("O3_8H", Collections.max(doubles));


            }


@@ -634,7 +662,7 @@


    /**


     * @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


     */


@@ -659,13 +687,34 @@


        Date now = new Date();


        //昨日


        Date yesterday = DateUtils.dataToTimeStampTime(DateUtils.getDateOfDay(now, -1), DateUtils.yyyy_MM_dd_EN);


        String dateString = DateUtils.dateToDateString(yesterday, DateUtils.yyyy_MM_dd_HH_mm_ss_EN);


        String dateString = DateUtils.dateToDateString(yesterday, DateUtils.yyyy_MM_dd_EN);




        String s = String.valueOf(regionCode);


        //获取省,市code


        Integer provinceCode = Integer.parseInt(s.substring(0, 2) + "0000");


        Integer cityCode = Integer.parseInt(s.substring(0, 4) + "00");


        //获取省内所有city_code


        Map<String,Object> params = new HashMap<>();


        params.put("cityCode",provinceCode);


        params.put("start",dateString);


        params.put("end",dateString);


        params.put("type",1);


        List<CityAqiDailyListDTO> dayList = cityAqiDailyMapper.CityAqiDailyMap(params);


        String start = DateUtils.dateToDateString(DateUtils.addMonths(DateUtils.getFirstDayOfLastMonth(), 1));


        params.put("start",start);


        params.put("type",2);


        List<CityAqiDailyListDTO> monList = cityAqiDailyMapper.CityAqiDailyMap(params);


        start =DateUtils.dateToDateString(now, DateUtils.yyyy);


        params.put("start",start);


        params.put("end",start);


        params.put("type",3);


        List<CityAqiDailyListDTO> yearList = cityAqiDailyMapper.CityAqiDailyMap(params);


        int indexDay = dayList.stream().map(CityAqiDailyListDTO::getCityCode).collect(Collectors.toList()).indexOf(cityCode.toString());


        int indexMon = monList.stream().map(CityAqiDailyListDTO::getCityCode).collect(Collectors.toList()).indexOf(cityCode.toString());


        int indexYear = yearList.stream().map(CityAqiDailyListDTO::getCityCode).collect(Collectors.toList()).indexOf(cityCode.toString());


        result.put("day",mapResult(dayList,indexDay));


        result.put("month",mapResult(monList,indexMon));


        result.put("year",mapResult(yearList,indexYear));


       /* //获取省内所有city_code


        QueryWrapper<SysArea> wrapper = new QueryWrapper<>();


        wrapper.select("area_code").eq("parent_code", provinceCode);


        List<Object> cityCodes = sysAreaService.listObjs(wrapper);


@@ -753,11 +802,19 @@


            yearMap.put("size", null);


        }


        yearMap.put("compositeIndex", yearMap.remove("value"));


        result.put("year", yearMap);


        result.put("year", yearMap);*/




        //时间，昨日


        result.put("time", DateUtils.dateToDateString(yesterday, DateUtils.yyyy_MM_dd_EN));


        return result;


    }




    private Map<String,Object> mapResult(List<CityAqiDailyListDTO> list, int length){


        Map<String,Object> map = new HashMap<>();


        map.put("AQI",CollectionUtils.isNotEmpty(list)&&length>0&&Objects.nonNull(list.get(length-1))?list.get(length-1).getAqi():0);


        map.put("rank",CollectionUtils.isNotEmpty(list)&&length>0?length:0);


        map.put("size",CollectionUtils.isNotEmpty(list)&&length>0?list.size():0);


        return map;


    }




    @Override


@@ -1191,15 +1248,15 @@


     */


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


@@ -1225,7 +1282,7 @@


    /**


     * @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


     */


@@ -1309,8 +1366,7 @@


    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);


        }


@@ -1320,7 +1376,7 @@


    /**


     * @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


@@ -1383,4 +1439,42 @@


        }


        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) {


                map.put("time",times);


                list.add(map);


                continue;


            }


            double average = value.stream().mapToDouble(aDouble -> aDouble).summaryStatistics().getAverage();


            map.put("O3", new BigDecimal(average).setScale(0, BigDecimal.ROUND_HALF_UP).doubleValue());


            map.put("time",times);


            list.add(map);


        }




        return list;




    }




}