blame | history | patch | commit | commitdiff | ignore whitespace
kaiyu
2021-07-28 11d10fc9ca90ec29159738c1eac5e2d9203d8bb6 
 screen-job/src/main/java/com/moral/api/service/impl/HistoryAqiServiceImpl.java


@@ -1,17 +1,19 @@


package com.moral.api.service.impl;




import com.alibaba.fastjson.JSON;


import com.alibaba.fastjson.JSONObject;


import com.moral.api.entity.CityAqiConfig;


import com.moral.api.entity.HistoryAqi;


import com.moral.api.mapper.HistoryAqiMapper;


import com.moral.api.service.CityAqiConfigService;


import com.moral.api.service.HistoryAqiService;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import com.moral.constant.RedisConstants;




import lombok.extern.slf4j.Slf4j;


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


import org.springframework.data.redis.core.RedisTemplate;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.util.ObjectUtils;


import org.springframework.web.client.RestTemplate;




@@ -42,6 +44,7 @@


    private RedisTemplate redisTemplate;




    @Override


    @Transactional


    public void insertHistoryAqi() {


        RestTemplate restTemplate = new RestTemplate();


        //获取aqi城市配置


@@ -67,11 +70,11 @@


            value.put("O3", data.get("o3C"));


            value.put("AQI", data.get("value"));


            //数据


            historyAqi.setValue(JSON.toJSONString(value));


            historyAqi.setValue(JSONObject.toJSONString(value));


            //数据存入数据库


            historyAqiMapper.insert(historyAqi);


            //存入redis


            redisTemplate.opsForHash().putAll("aqi_" + cityCode, value);


            redisTemplate.opsForHash().put(RedisConstants.AQI_DATA, cityCode, value);


        }


    }


}