blame | history | patch | commit | commitdiff | ignore whitespace
jinpengyong
2021-10-27 f7b23ea4d8c720c691fe2552a1250dd22792ca66 
 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);


        }


    }