修复报错

core/src/main/java/com/wecloud/im/service/impl/ImMessageServiceImpl.java

@@ -789,7 +789,7 @@ public class ImMessageServiceImpl extends BaseServiceImpl<ImMessageMapper, ImMes
         List<ImConversation> conversationList =
         List<ImConversation> conversationList =
                 imConversationService.getConversationBySenderAndReceivers(senderImClientId, receiverImClientIds);
                 imConversationService.getConversationBySenderAndReceivers(senderImClientId, receiverImClientIds);
         conversationMapGroupById.putAll(conversationList.stream().collect(Collectors.toMap(ImConversation::getId,
         conversationMapGroupById.putAll(conversationList.stream().collect(Collectors.toMap(ImConversation::getId,
-                Function.identity())));
+                Function.identity(), (v1, v2) -> v1)));
 
 
         // 查找会话成员
         // 查找会话成员
         List<Long> conversationIdList = conversationList.stream().map(ImConversation::getId).collect(Collectors.toList());
         List<Long> conversationIdList = conversationList.stream().map(ImConversation::getId).collect(Collectors.toList());
@@ -797,7 +797,7 @@ public class ImMessageServiceImpl extends BaseServiceImpl<ImMessageMapper, ImMes
                 imConversationMembersService.list(Wrappers.<ImConversationMembers>lambdaQuery().in(ImConversationMembers::getFkConversationId, conversationIdList));
                 imConversationMembersService.list(Wrappers.<ImConversationMembers>lambdaQuery().in(ImConversationMembers::getFkConversationId, conversationIdList));
         conMembersMapGroupByConId.putAll(conversationMembersList.stream().collect(Collectors.groupingBy(ImConversationMembers::getFkConversationId)));
         conMembersMapGroupByConId.putAll(conversationMembersList.stream().collect(Collectors.groupingBy(ImConversationMembers::getFkConversationId)));
 
 
-        if (conversationList.size() == receiverList.size()) {
+        if (conversationMapGroupById.size() == receiverList.size()) {
             // 如果会话数量和收件人数量一致，后面的逻辑就不需要走了
             // 如果会话数量和收件人数量一致，后面的逻辑就不需要走了
             return;
             return;
         }
         }