| | |
|---|
| | | package com.moral.api.service.impl; |
|---|
| | | |
|---|
| | | import com.alibaba.fastjson.JSON; |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|---|
| | | import com.moral.api.entity.GovMonitorPoint; |
|---|
| | | import com.moral.api.mapper.GovMonitorPointMapper; |
|---|
| | |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | | |
|---|
| | | import java.util.List; |
|---|
| | | import java.util.Map; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * <p> |
|---|
| | |
|---|
| | | RedisTemplate redisTemplate; |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public List<GovMonitorPoint> queryGovMonitorPointAndDataByRegionCode(Integer regionCode) { |
|---|
| | | public List<GovMonitorPoint> queryGovMonitorPointAndDataByRegionCode(Integer regionCode,String sensorCode) { |
|---|
| | | String regionCodeStr = RegionCodeUtils.regionCodeConvertToName(regionCode); |
|---|
| | | QueryWrapper<GovMonitorPoint> wrapper = new QueryWrapper<>(); |
|---|
| | | wrapper.eq(regionCodeStr,regionCode); |
|---|
| | |
|---|
| | | List<GovMonitorPoint> govMonitorPoints = govMonitorPointMapper.selectList(wrapper); |
|---|
| | | for (GovMonitorPoint govMonitorPoint : govMonitorPoints) { |
|---|
| | | Object data = redisTemplate.opsForHash().get(RedisConstants.AQI_DATA, govMonitorPoint.getGuid()); |
|---|
| | | if(data!=null) |
|---|
| | | govMonitorPoint.setData(String.valueOf(data)); |
|---|
| | | Map<String,Object> dataMap = (Map<String, Object>) data; |
|---|
| | | if(data!=null&&dataMap.get(sensorCode)!=null) |
|---|
| | | govMonitorPoint.setData(String.valueOf(dataMap.get(sensorCode))); |
|---|
| | | } |
|---|
| | | return govMonitorPoints; |
|---|
| | | } |
|---|
