city_aqi数据存入redis

jinpengyong

2021-10-27 f7b23ea4d8c720c691fe2552a1250dd22792ca66

city_aqi数据存入redis

 screen-common/src/main/java/com/moral/constant/RedisConstants.java

@@ -88,5 +88,10 @@
     * */
    public static final String GOV_MONITOR_POINT = "gov_monitor_point";

    /*
     * redis中城市aqi数据key
     * */
    public static final String CITY_AQI = "city_aqi";


}

 screen-job/src/main/java/com/moral/api/service/impl/CityAqiServiceImpl.java

@@ -9,10 +9,12 @@
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.moral.api.service.CityConfigService;
import com.moral.constant.Constants;
import com.moral.constant.RedisConstants;
import com.moral.util.DateUtils;

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

import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.util.ObjectUtils;
import org.springframework.web.client.RestTemplate;
@@ -42,6 +44,9 @@
    @Autowired
    private RestTemplate restTemplate;

    @Autowired
    private RedisTemplate redisTemplate;

    @Override
    public void insertCityAqi() {
        //获取城市配置
@@ -70,13 +75,15 @@
            aqi.put("so2", aqi.remove("so2C"));
            aqi.put("no2", aqi.remove("no2C"));
            aqi.put("co", aqi.remove("coC"));
            aqi.put("o3", aqi.remove("o3c"));
            aqi.put("o3", aqi.remove("o3C"));
            aqi.put("aqi", aqi.remove("value"));
            CityAqi cityAqi = new CityAqi();
            cityAqi.setCityCode(cityCode);
            cityAqi.setTime(time);
            cityAqi.setValue(JSONObject.toJSONString(aqi));
            cityAqiMapper.insert(cityAqi);
            //存入redis
            redisTemplate.opsForHash().put(RedisConstants.CITY_AQI, cityCode, aqi);
        }
    }