Commit 17c64673 authored by 赵啸非's avatar 赵啸非

添加告警统计信息

parent c8505a23
...@@ -46,13 +46,14 @@ public class DeviceStatTaskImpl implements ITaskExcuteService { ...@@ -46,13 +46,14 @@ public class DeviceStatTaskImpl implements ITaskExcuteService {
while (true) { while (true) {
DeviceEntity deviceEntity = cacheService.lpop(RedisKey.KEY_DEVICE_ONLINE_QUEUE, DeviceEntity.class); DeviceEntity deviceEntity = cacheService.lpop(RedisKey.KEY_DEVICE_ONLINE_QUEUE, DeviceEntity.class);
if (ObjectUtils.isEmpty(deviceEntity)) { if (ObjectUtils.isEmpty(deviceEntity)) {
log.info("等待更新队列为空"); log.info("等待更新队列为空!");
break; break;
} else { } else {
waitDeviceInfos.add(deviceEntity); waitDeviceInfos.add(deviceEntity);
} }
} }
log.info("waitDeviceInfos size:{}", waitDeviceInfos.size());
if (!ObjectUtils.isEmpty(waitDeviceInfos)) { if (!ObjectUtils.isEmpty(waitDeviceInfos)) {
deviceService.update(waitDeviceInfos); deviceService.update(waitDeviceInfos);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment