|
|
@@ -135,7 +135,7 @@ public class MeetingDeviceServiceImpl extends AbstractCrudService<MeetingDeviceM
|
|
|
.filter(Objects::nonNull)
|
|
|
.collect(Collectors.toList());
|
|
|
|
|
|
- // 2. 批量查询心跳信息并构建Map(Java 8 兼容版)
|
|
|
+ // 2. 批量查询心跳信息并构建Map
|
|
|
Map<String, LocalDateTime> deviceHeartbeatMap;
|
|
|
if (CollectionUtils.isEmpty(validDeviceCodes)) {
|
|
|
deviceHeartbeatMap = Collections.emptyMap();
|
|
|
@@ -146,11 +146,11 @@ public class MeetingDeviceServiceImpl extends AbstractCrudService<MeetingDeviceM
|
|
|
.collect(Collectors.toMap(
|
|
|
MeetingDeviceHeartbeat::getDeviceCode,
|
|
|
MeetingDeviceHeartbeat::getCreateTime,
|
|
|
- (existing, replacement) -> existing // 解决重复key问题
|
|
|
+ (existing, replacement) -> existing
|
|
|
));
|
|
|
}
|
|
|
|
|
|
- // 3. 设备状态赋值(逻辑不变)
|
|
|
+ // 3. 设备状态赋值
|
|
|
page.getRecords().forEach(meetingDevice -> {
|
|
|
String deviceCode1 = meetingDevice.getDeviceCode();
|
|
|
boolean isHeartbeatValid = Objects.nonNull(deviceCode1)
|
|
|
@@ -159,7 +159,7 @@ public class MeetingDeviceServiceImpl extends AbstractCrudService<MeetingDeviceM
|
|
|
meetingDevice.setDeviceStatus(isHeartbeatValid ? 1 : 0);
|
|
|
});
|
|
|
|
|
|
- // 4. 通用映射关联数据(逻辑不变)
|
|
|
+ // 4. 通用映射关联数据
|
|
|
mapAssociatedData(page.getRecords(),
|
|
|
MeetingDevice::getRoomId,
|
|
|
buildIdMap(meetingRoomsList, MeetingRoom::getRoomId),
|