| | |
|---|
| | | 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; |
|---|
| | |
|---|
| | | 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().putAll(RedisConstants.AQI_DATA + cityCode, value); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
