forked from dyf/fys-Multi-tenant
在线状态任务2
This commit is contained in:
@ -25,6 +25,7 @@ public class OnlineStatusTask {
|
|||||||
@Scheduled(cron = "0 */3 * * * ?")
|
@Scheduled(cron = "0 */3 * * * ?")
|
||||||
public void cronTask() {
|
public void cronTask() {
|
||||||
QueryWrapper<Device> queryWrapper = new QueryWrapper<>();
|
QueryWrapper<Device> queryWrapper = new QueryWrapper<>();
|
||||||
|
queryWrapper.eq("online_status", 1);
|
||||||
List<Device> devices = deviceMapper.selectList(queryWrapper);
|
List<Device> devices = deviceMapper.selectList(queryWrapper);
|
||||||
devices.forEach(item -> {
|
devices.forEach(item -> {
|
||||||
String onlineStatusKey = GLOBAL_REDIS_KEY + DEVICE_KEY_PREFIX + item.getDeviceImei() + DeviceRedisKeyConstants.DEVICE_ONLINE_STATUS_KEY_PREFIX;
|
String onlineStatusKey = GLOBAL_REDIS_KEY + DEVICE_KEY_PREFIX + item.getDeviceImei() + DeviceRedisKeyConstants.DEVICE_ONLINE_STATUS_KEY_PREFIX;
|
||||||
|
|||||||
Reference in New Issue
Block a user