diff --git a/fys-admin/src/main/java/com/fuyuanshen/global/mqtt/rule/bjq/BjqModeRule.java b/fys-admin/src/main/java/com/fuyuanshen/global/mqtt/rule/bjq/BjqModeRule.java index 56bb514f6..6b58b0535 100644 --- a/fys-admin/src/main/java/com/fuyuanshen/global/mqtt/rule/bjq/BjqModeRule.java +++ b/fys-admin/src/main/java/com/fuyuanshen/global/mqtt/rule/bjq/BjqModeRule.java @@ -63,6 +63,12 @@ public class BjqModeRule implements MqttMessageRule { updateWrapper.set("online_status", 2); deviceService.update(updateWrapper); RedisUtils.deleteObject(sendMessageIng); + + // 解除告警 + String deviceRedisKey = GlobalConstants.GLOBAL_REDIS_KEY + DeviceRedisKeyConstants.DEVICE_KEY_PREFIX + context.getDeviceImei() + DEVICE_ALARM_KEY_PREFIX; + if(RedisUtils.getCacheObject(deviceRedisKey) != null){ + RedisUtils.deleteObject(deviceRedisKey); + } } } // 发送设备状态和位置信息到Redis