| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public Sensor getSensorByCode(String code) { |
|---|
| | | if (code == null) |
|---|
| | | return null; |
|---|
| | | //从缓存中读取 |
|---|
| | | Sensor sensor = (Sensor) redisTemplate.opsForHash().get(RedisConstants.SENSOR_KEY, code); |
|---|
| | | //如果缓存为空则从数据库读取 |
|---|
| | | if (sensor == null) { |
|---|
| | | QueryWrapper<Sensor> wrapper = new QueryWrapper<>(); |
|---|
| | | sensor = new Sensor(); |
|---|
| | | sensor.setCode(code); |
|---|
| | | sensor.setIsDelete(Constants.NOT_DELETE); |
|---|
| | | wrapper.setEntity(sensor); |
|---|
| | | sensor = sensorMapper.selectOne(wrapper); |
|---|
| | | } |
|---|
| | | return sensor; |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void refreshCache(){ |
|---|
| | | Map<String, Sensor> sensors = getAllSensorFromDB(); |
|---|
| | | refreshCache(sensors); |
|---|
