diff --git a/accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/room/GuildMemberRoomMicRecordService.java b/accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/room/GuildMemberRoomMicRecordService.java index 14bedae64..2af6499b2 100644 --- a/accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/room/GuildMemberRoomMicRecordService.java +++ b/accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/room/GuildMemberRoomMicRecordService.java @@ -342,7 +342,7 @@ public class GuildMemberRoomMicRecordService extends ServiceImpl micUids = playRoomVo.getMicUsers().stream().map(MicUserVo::getUid).collect(Collectors.toSet()); if (!micUids.contains(uid)) { micRecordMap.remove(uid); - return; + continue; } RLock lock = redissonClient.getLock(RedisKey.guild_member_room_mic_record_lock.getKey(uid.toString(), roomId.toString(), pos.toString())); @@ -367,19 +367,19 @@ public class GuildMemberRoomMicRecordService extends ServiceImpl micSet = redissonClient.getSet(RedisKey.guild_member_room_mic_record.getKey(uid.toString(), roomId.toString(), pos.toString())); Optional lastUpMic = micSet.stream().filter(inTime -> timeInMillis.compareTo(inTime) > 0).max(Comparator.comparingLong(Long::longValue)); if (lastUpMic.isEmpty()) { log.error("[statMicRecordTask] 获取上麦时间异常 uid {} roomUid {} roomId {} pos {} timeInMillis {}", uid, roomId, pos, timeInMillis); micRecordMap.remove(uid); - return; + continue; } Long maxUpTime = lastUpMic.get(); if (maxUpTime == null) { micRecordMap.remove(uid); - return; + continue; } Integer partitionId = guildMember.getPartitionId();