| | |
| | | //按照时间进行排序 |
| | | cityAqis.sort(Comparator.comparing(CityAqi::getTime)); |
| | | } |
| | | //封装返回数据,map的key为HH:mm格式的时间,value为aqi的数值 |
| | | //封装返回数据,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(), "HH:mm"); |
| | | String key = DateUtils.dateToDateString(aqi.getTime(), "yyyy-MM-dd HH:mm"); |
| | | String allDataJson = aqi.getValue(); |
| | | if (allDataJson == null) { |
| | | result.put(key, ""); |
| | |
| | | @Override |
| | | public List<Map<String, Object>> rankingDetails(Map<String, Object> params) { |
| | | List<Map<String, Object>> result = new ArrayList<>(); |
| | | int orgId = Integer.parseInt(params.get("organizationId").toString()); |
| | | int regionCode = Integer.parseInt(params.get("regionCode").toString()); |
| | | String type = params.get("type").toString(); |
| | | String time = null; |
| | | if (!ObjectUtils.isEmpty(params.get("time"))) { |
| | |
| | | } |
| | | String cityType = params.get("cityType").toString(); |
| | | |
| | | //获取省,市code |
| | | Organization organization = organizationService.getById(orgId); |
| | | Integer curProvinceCode = organization.getProvinceCode(); |
| | | Integer curCityCode = organization.getCityCode(); |
| | | String s = String.valueOf(regionCode); |
| | | //获取当前省,市code |
| | | Integer curProvinceCode = Integer.parseInt(s.substring(0, 2) + "0000"); |
| | | Integer curCityCode = Integer.parseInt(s.substring(0, 4) + "00"); |
| | | |
| | | QueryWrapper<SysArea> areaWrapper = new QueryWrapper<>(); |
| | | if ("province".equals(cityType)) { |
| | |
| | | List<String> primaryPollutantNames = aqi.getPrimaryPollutantNames(); |
| | | String primaryPollutant = ""; |
| | | if (!ObjectUtils.isEmpty(primaryPollutantNames)) { |
| | | primaryPollutant = primaryPollutantNames.toString().replace("[", "").replace("]", ""); |
| | | primaryPollutant = primaryPollutantNames.stream().map(String::valueOf).collect(Collectors.joining(",")); |
| | | } |
| | | dataMap.put("primaryPollutant", primaryPollutant); |
| | | |
| | |
| | | List<String> primaryPollutantNames = (List<String>) value.get("primaryPollutant"); |
| | | String primaryPollutant = ""; |
| | | if (!ObjectUtils.isEmpty(primaryPollutantNames)) { |
| | | primaryPollutant = primaryPollutantNames.toString().replace("[", "").replace("]", ""); |
| | | primaryPollutant = primaryPollutantNames.stream().map(String::valueOf).collect(Collectors.joining(",")); |
| | | } |
| | | value.put("primaryPollutant", primaryPollutant); |
| | | value.remove("pubtime"); |
| | |
| | | List<String> primaryPollutantNames = (List<String>) value.get("primaryPollutant"); |
| | | String primaryPollutant = ""; |
| | | if (!ObjectUtils.isEmpty(primaryPollutantNames)) { |
| | | primaryPollutant = primaryPollutantNames.toString().replace("[", "").replace("]", ""); |
| | | primaryPollutant = primaryPollutantNames.stream().map(String::valueOf).collect(Collectors.joining(",")); |
| | | } |
| | | value.put("primaryPollutant", primaryPollutant); |
| | | //城市名 |
| | |
| | | } |
| | | |
| | | @Override |
| | | public Map<String, Object> provincialRanking(Integer organizationId) { |
| | | public Map<String, Object> provincialRanking(Integer regionCode) { |
| | | //结果集 |
| | | Map<String, Object> result = new HashMap<>(); |
| | | |
| | |
| | | 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 s = String.valueOf(regionCode); |
| | | //获取省,市code |
| | | Organization organization = organizationService.getById(organizationId); |
| | | Integer provinceCode = organization.getProvinceCode(); |
| | | Integer cityCode = organization.getCityCode(); |
| | | Integer provinceCode = Integer.parseInt(s.substring(0, 2) + "0000"); |
| | | Integer cityCode = Integer.parseInt(s.substring(0, 4) + "00"); |
| | | //获取省内所有city_code |
| | | QueryWrapper<SysArea> wrapper = new QueryWrapper<>(); |
| | | wrapper.select("area_code").eq("parent_code", provinceCode); |
| | |
| | | } |
| | | return result; |
| | | } |
| | | |
| | | |
| | | } |