| | |
|---|
| | | //获取所有城市aqi小时数据 |
|---|
| | | QueryWrapper<CityAqi> wrapper = new QueryWrapper<>(); |
|---|
| | | wrapper.select("city_code", "time", "value") |
|---|
| | | .ge("time", DateUtils.dateToDateString(start)) |
|---|
| | | .lt("time", DateUtils.dateToDateString(end)); |
|---|
| | | .ge("time", start) |
|---|
| | | .lt("time", end); |
|---|
| | | List<Map<String, Object>> dailyData = cityAqiService.listMaps(wrapper); |
|---|
| | | |
|---|
| | | if (dailyData.size() == 0) { |
|---|
| | |
|---|
| | | .collect(Collectors.groupingBy(o -> o.get("city_code").toString())); |
|---|
| | | |
|---|
| | | List<CityAqiDaily> cityAqiDailies = new ArrayList<>(); |
|---|
| | | CityAqiDaily cityAqiDaily = new CityAqiDaily(); |
|---|
| | | |
|---|
| | | data.forEach((cityCode, value) -> { |
|---|
| | | CityAqiDaily cityAqiDaily = new CityAqiDaily(); |
|---|
| | | Map<String, Object> jsonMap = new HashMap<>(); |
|---|
| | | cityAqiDaily.setCityCode(Integer.parseInt(cityCode)); |
|---|
| | | cityAqiDaily.setTime(start); |
|---|
