日志

core/src/main/java/com/wecloud/im/param/PrivateChatStatusMessageParam.java

@@ -25,7 +25,7 @@ public class PrivateChatStatusMessageParam {
     private String fromUserId;
 
     /**
-     * 接收群id
+     * 接收用户id
      */
     @NotEmpty(message = "接收用户id不能为空")
     @ApiModelProperty("接收用户id")

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

@@ -945,11 +945,10 @@ public class ImMessageServiceImpl extends BaseServiceImpl<ImMessageMapper, ImMes
         // 获取收件人信息
         List<ImClient> receiverList = imClientService.list(Wrappers.<ImClient>lambdaQuery().eq(ImClient::getFkAppid,
                 appId).in(ImClient::getClientId, toUserIdList));
-        Map<Long, ImClient> clientMapById = receiverList.stream().collect(Collectors.toMap(ImClient::getId, Function.identity()));
         if (receiverList.isEmpty()) {
             throw new BusinessException("收件人列表为空");
         }
-
+        Map<Long, ImClient> clientMapById = receiverList.stream().collect(Collectors.toMap(ImClient::getId, Function.identity()));
 
         // 查找conversation列表
         Long senderImClientId = sender.getId();
@@ -957,6 +956,8 @@ public class ImMessageServiceImpl extends BaseServiceImpl<ImMessageMapper, ImMes
         List<ImConversation> conversationList =
                 imConversationService.getConversationBySenderAndReceivers(senderImClientId, receiverImClientIds);
 
+        log.info("单人消息获取会话入参 {} {} 会话数量 {}", senderImClientId, JSON.toJSONString(receiverImClientIds), conversationList.size());
+
         // 根据收件人imClientId对会话/会话成员进行分组
         Set<Long> notExistConversationReceiverClientIds = new HashSet<>(receiverImClientIds);