hy/aslan-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

发现页接口优化

Browse Source
This commit is contained in:
tianfeng 2025-09-15 19:21:45 +08:00
parent 2826529aca
commit 5d3724416b
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/room/query/RoomVoiceDiscoverQryExe.java
View File

@ -66,9 +66,10 @@ public class RoomVoiceDiscoverQryExe {
List<ActiveVoiceRoom> activeVoiceRooms = activeVoiceRoomService.listDiscover(cmd.requireReqSysOrigin(), cmd.isAllRegion(), region, 50); List<ActiveVoiceRoom> activeVoiceRooms = activeVoiceRoomService.listDiscover(cmd.requireReqSysOrigin(), cmd.isAllRegion(), region, 50);
log.info("activeVoiceRooms:{}", JSON.toJSONString(activeVoiceRooms)); log.info("activeVoiceRooms:{}", JSON.toJSONString(activeVoiceRooms));
// 处理没有人的房间，有缓存不会大量创建线程 // 处理没有人的房间，有缓存不会大量创建线程
new Thread(() -> formatRoomList(activeVoiceRooms)).start(); List<Long> longs = formatRoomList(activeVoiceRooms);
List<ActiveVoiceRoom> list = activeVoiceRooms.stream().filter(e -> !longs.contains(e.getId())).toList();
List<RoomVoiceProfileCO> roomList = roomVoiceProfileCommon.toListRoomVoiceProfileCO(activeVoiceRooms); List<RoomVoiceProfileCO> roomList = roomVoiceProfileCommon.toListRoomVoiceProfileCO(list);
if (CollectionUtils.isEmpty(roomList)) { if (CollectionUtils.isEmpty(roomList)) {
//roomList = getHomeData(cmd,latestMobileDeviceService.getLatestLanguage(cmd.requiredReqUserId())); //roomList = getHomeData(cmd,latestMobileDeviceService.getLatestLanguage(cmd.requiredReqUserId()));
@ -96,7 +97,7 @@ public class RoomVoiceDiscoverQryExe {
* @param roomList * @param roomList
* @return * @return
*/ */
private void formatRoomList(List<ActiveVoiceRoom> roomList) { private List<Long> formatRoomList(List<ActiveVoiceRoom> roomList) {
List<Long> notUserRooms = new ArrayList<>(); List<Long> notUserRooms = new ArrayList<>();
//只显示有人活跃用户，获取在线人数大于0的房间 //只显示有人活跃用户，获取在线人数大于0的房间
roomList.forEach(item -> { roomList.forEach(item -> {
@ -109,7 +110,9 @@ public class RoomVoiceDiscoverQryExe {
}); });
if (!notUserRooms.isEmpty()) { if (!notUserRooms.isEmpty()) {
activeVoiceRoomService.removeByIds(notUserRooms); activeVoiceRoomService.removeByIds(notUserRooms);
return notUserRooms;
} }
return CollectionUtils.newArrayList();
} }
public static void main(String[] args) { public static void main(String[] args) {