性能优化

core/src/main/java/com/wecloud/im/action/NormalChatAction.java

@@ -138,7 +138,7 @@ public class NormalChatAction {
         Map<Long, ImConversationMembers> memberMap = membersList.stream().collect(Collectors.toMap(ImConversationMembers::getFkClientId, member -> member));
         Map<Long, ImConversationMembers> memberMap = membersList.stream().collect(Collectors.toMap(ImConversationMembers::getFkClientId, member -> member));
 
 
         // 判断为单聊
         // 判断为单聊
-        if (membersList.size() == 2) {
+        if (ChatTypeEnum.SINGLE.getCode().equals(conversation.getChatType())) {
             // 判断是否被拉黑逻辑
             // 判断是否被拉黑逻辑
             if (black(reqId, imClientSender, membersList, request.getSenderChannel())) {
             if (black(reqId, imClientSender, membersList, request.getSenderChannel())) {
                 return;
                 return;
@@ -149,23 +149,24 @@ public class NormalChatAction {
             }
             }
         }
         }
 
 
-        if (beKickOut(reqId, imClientSender, membersList, request.getSenderChannel())) {
-            return;
-        }
-        if (muted(conversation, reqId, imClientSender, membersList, memberMap, request.getSenderChannel())) {
-            return;
-        }
-        if (baned(conversation, reqId, imClientSender, membersList, request.getSenderChannel())) {
-            return;
+        if (ChatTypeEnum.NORMAL_GROUP.getCode().equals(conversation.getChatType())) {
+            if (beKickOut(reqId, imClientSender, membersList, request.getSenderChannel())) {
+                return;
+            }
+            if (muted(conversation, reqId, imClientSender, membersList, memberMap, request.getSenderChannel())) {
+                return;
+            }
+            if (baned(conversation, reqId, imClientSender, membersList, request.getSenderChannel())) {
+                return;
+            }
         }
         }
-
         // 消息内容校验
         // 消息内容校验
         if (!checkMsg(imClientSender, conversation, reqId, data, request.getSenderChannel(), memberMap)) {
         if (!checkMsg(imClientSender, conversation, reqId, data, request.getSenderChannel(), memberMap)) {
             return;
             return;
         }
         }
         ImMessageOnlineSend imMessageOnlineSend = assembleImMessageOnlineSend(data, imClientSender, imApplication.getId());
         ImMessageOnlineSend imMessageOnlineSend = assembleImMessageOnlineSend(data, imClientSender, imApplication.getId());
 
 
-        // 再给所有人发 todo 需要改成批量
+        // 再给所有人发
         for (ImConversationMembers member : membersList) {
         for (ImConversationMembers member : membersList) {
             if (member.getFkClientId().equals(imClientSender.getId())) {
             if (member.getFkClientId().equals(imClientSender.getId())) {
                 // 不给自己发
                 // 不给自己发