解决聊天室定向消息问题

2024-11-20 12:47:11 +08:00
parent 3d98d17b0d
commit 8635153e59
1 changed files with 4 additions and 1 deletions
@@ -733,7 +733,7 @@ public class MemoryMessagesStore implements IMessagesStore {
            }
            pullType = ProtoConstants.PullType.Pull_Normal;
        } else if (type == ProtoConstants.ConversationType.ConversationType_ChatRoom) {
-            boolean isDirect = !StringUtil.isNullOrEmpty(message.getToUser());
+            boolean isDirect = !StringUtil.isNullOrEmpty(message.getToUser()) || !message.getToList().isEmpty();
            Collection<UserClientEntry> entries = getChatroomMembers(message.getConversation().getTarget());
            for (UserClientEntry entry : entries) {
                if (isDirect) {
@@ -741,6 +741,9 @@ public class MemoryMessagesStore implements IMessagesStore {
                        notifyReceivers.add(message.getToUser());
                        break;
                    }
+                    if (message.getToList().contains(entry.userId)) {
+                        notifyReceivers.add(entry.userId);
+                    }
                } else {
                    notifyReceivers.add(entry.userId);
                }