moliparty/peko-java
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

临时去除移除房间列表数据

Browse Source
This commit is contained in:
hokli
2025-06-14 00:52:44 +08:00
parent dd3ae8712b
commit a53e51f719
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/homeV2/HomeRoomPoolService.java
View File

@@ -29,7 +29,7 @@ public class HomeRoomPoolService {
}
public void removeRoom(Integer partitionId, Long roomUid){
getPartitionMap(partitionId).fastRemove(roomUid);
// getPartitionMap(partitionId).fastRemove(roomUid);
log.info("[HomeRoomPool] removeRoom partitionId: {}, roomUid: {}", partitionId, roomUid);
}

4
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/homeV2/HomeV2Service.java
View File

@@ -292,7 +292,7 @@ public class HomeV2Service {
String[] uidArray = homeRoomSet.stream().map(Objects::toString).toArray(String[]::new);
List<String> cacheList = jedisService.hmread(RedisKey.room_mic_up.getKey(), uidArray);
if (CollectionUtils.isEmpty(cacheList)){
poolService.getPartitionMap(partitionId).clear();
// poolService.getPartitionMap(partitionId).clear();
return ;
}
@@ -305,7 +305,7 @@ public class HomeV2Service {
}
Long[] emptyRoomList = homeRoomSet.toArray(Long[]::new);
poolService.getPartitionMap(partitionId).fastRemove(emptyRoomList);
// poolService.getPartitionMap(partitionId).fastRemove(emptyRoomList);
}
}