diff --git a/fys-admin/src/main/java/com/fuyuanshen/global/queue/OnlineStatusTask.java b/fys-admin/src/main/java/com/fuyuanshen/global/queue/OnlineStatusTask.java index d552b17c..96930c5a 100644 --- a/fys-admin/src/main/java/com/fuyuanshen/global/queue/OnlineStatusTask.java +++ b/fys-admin/src/main/java/com/fuyuanshen/global/queue/OnlineStatusTask.java @@ -25,6 +25,7 @@ public class OnlineStatusTask { @Scheduled(cron = "0 */3 * * * ?") public void cronTask() { QueryWrapper queryWrapper = new QueryWrapper<>(); + queryWrapper.eq("online_status", 1); List devices = deviceMapper.selectList(queryWrapper); devices.forEach(item -> { String onlineStatusKey = GLOBAL_REDIS_KEY + DEVICE_KEY_PREFIX + item.getDeviceImei() + DeviceRedisKeyConstants.DEVICE_ONLINE_STATUS_KEY_PREFIX;