| | |
| | | Map<String, Object> value = (Map<String, Object>) redisTemplate.opsForHash().get(RedisConstants.CITY_AQI, String.valueOf(regionCode)); |
| | | if (value == null) |
| | | value = queryCityAqiByRegionCodeFromDB(regionCode); |
| | | //如果地区码是县级市则转换到市级在进行查询 |
| | | if (value == null) { |
| | | String regionCodeStr = String.valueOf(regionCode); |
| | | String end = regionCodeStr.substring(regionCodeStr.length() - 2, regionCodeStr.length()); |
| | | if (!end.equals(00)) { |
| | | regionCodeStr = regionCodeStr.substring(0, regionCodeStr.length() - 2); |
| | | regionCodeStr += "00"; |
| | | regionCode = Integer.parseInt(regionCodeStr); |
| | | value = (Map<String, Object>) redisTemplate.opsForHash().get(RedisConstants.CITY_AQI, String.valueOf(regionCode)); |
| | | if (value == null) |
| | | value = queryCityAqiByRegionCodeFromDB(regionCode); |
| | | }else{ |
| | | return null; |
| | | } |
| | | } |
| | | //根据AQI计算污染等级 |
| | | if (value == null || value.get("AQI") == null) |
| | | return null; |