修复设备关闭无法清除缓存的问题
This commit is contained in:
parent
3ee762f5bb
commit
8e0428e0b2
@ -29,6 +29,9 @@ public class DeviceRepository {
|
|||||||
DeviceEntity device = deviceMapper.getByDeviceId(deviceId);
|
DeviceEntity device = deviceMapper.getByDeviceId(deviceId);
|
||||||
if (null != device) {
|
if (null != device) {
|
||||||
redisTemplate.opsForValue().set(String.format(DEVICE_CACHE_KEY, deviceId), JSONObject.toJSONString(device));
|
redisTemplate.opsForValue().set(String.format(DEVICE_CACHE_KEY, deviceId), JSONObject.toJSONString(device));
|
||||||
|
if (!Integer.valueOf(1).equals(device.getStatus())) {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
return device;
|
return device;
|
||||||
}
|
}
|
||||||
@ -43,6 +46,9 @@ public class DeviceRepository {
|
|||||||
}
|
}
|
||||||
if (null != device) {
|
if (null != device) {
|
||||||
redisTemplate.opsForValue().set(String.format(DEVICE_CACHE_KEY, deviceNo), JSONObject.toJSONString(device));
|
redisTemplate.opsForValue().set(String.format(DEVICE_CACHE_KEY, deviceNo), JSONObject.toJSONString(device));
|
||||||
|
if (!Integer.valueOf(1).equals(device.getStatus())) {
|
||||||
|
return null;
|
||||||
|
}
|
||||||
} else {
|
} else {
|
||||||
redisTemplate.opsForValue().set(String.format(DEVICE_CACHE_KEY, deviceNo), "null", 60L, TimeUnit.SECONDS);
|
redisTemplate.opsForValue().set(String.format(DEVICE_CACHE_KEY, deviceNo), "null", 60L, TimeUnit.SECONDS);
|
||||||
}
|
}
|
||||||
|
@ -72,7 +72,10 @@ public class DeviceServiceImpl implements DeviceService {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public ApiResponse updateStatus(Long id) {
|
public ApiResponse updateStatus(Long id) {
|
||||||
return ApiResponse.success(deviceMapper.updateStatus(id));
|
deviceRepository.clearDeviceCache(id);
|
||||||
|
deviceMapper.updateStatus(id);
|
||||||
|
deviceRepository.clearDeviceCache(id);
|
||||||
|
return ApiResponse.success(1);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
Loading…
x
Reference in New Issue
Block a user