代码调试

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

@@ -171,7 +171,7 @@ public class NormalChatAction {
         ImMessageOnlineSend imMessageOnlineSend = assembleImMessageOnlineSend(data, imClientSender, imApplication.getId());
 
         // 入库 保存收件箱
-        batchSaveInbox(imApplication, conversation, imMessageOnlineSend.getMsgId(), membersList);
+        batchSaveInbox(imApplication, imClientSender, conversation, imMessageOnlineSend.getMsgId(), membersList);
         // 入库成功后 判断是否是临时会话 如果是，双方会话display状态是否是1(显示)，如果不是，需要修改为是
         if (ChatTypeEnum.TEMP.getCode().equals(conversation.getChatType())) {
             // 木有只有私聊一种临时会话类型
@@ -301,10 +301,13 @@ public class NormalChatAction {
      * @param messageId
      * @param membersList
      */
-    private void batchSaveInbox(ImApplication imApplication, ImConversationQueryVo conversation, long messageId,
+    private void batchSaveInbox(ImApplication imApplication, ImClient clientSender, ImConversationQueryVo conversation, long messageId,
                                 List<ImConversationMembers> membersList) {
         List<ImInbox> inboxes = Lists.newArrayList();
         for (ImConversationMembers member : membersList) {
+            if (clientSender.getClientId().equals(member.getClientId())) {
+                continue;
+            }
             ImInbox imInbox = new ImInbox();
             imInbox.setId(SnowflakeUtil.getId());
             imInbox.setCreateTime(new Date());
@@ -316,8 +319,10 @@ public class NormalChatAction {
             imInbox.setFkConversationId(conversation.getId());
             inboxes.add(imInbox);
         }
+        if (CollectionUtils.isNotEmpty(inboxes)) {
             imInboxService.saveBatch(inboxes);
         }
+    }
 
     /**
      * 判断是否被拉黑