修复NPE

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

@@ -697,19 +697,24 @@ public class ImMessageServiceImpl extends BaseServiceImpl<ImMessageMapper, ImMes
 
 
             // 发送消息
             // 发送消息
             for (ImConversationMembers members : membersList) {
             for (ImConversationMembers members : membersList) {
+                try {
                     if (members.getClientId().equals(senderClientId) && !param.getIncludeSender()) {
                     if (members.getClientId().equals(senderClientId) && !param.getIncludeSender()) {
                         // 是否是发送者 且includeSender不为true
                         // 是否是发送者 且includeSender不为true
                         continue;
                         continue;
                     }
                     }
-                // 入库 保存收件箱
-                saveImInbox(application, conversation.getId(), imMessageOnlineSend.getMsgId(),
-                        members, SnowflakeUtil.getId());
-
-                // 在线用户直接发消息
-                sendMsgForOnline(members.getFkClientId(), imMessageOnlineSend);
+                } catch (Exception e) {
+                    log.info("");
+                }
 
 
-                // 离线消息推送
-                pushMsgToOfflineMembers(application, members, param.getPushContent(), param.getPushExt());
+//                // 入库 保存收件箱
+//                saveImInbox(application, conversation.getId(), imMessageOnlineSend.getMsgId(),
+//                        members, SnowflakeUtil.getId());
+//
+//                // 在线用户直接发消息
+//                sendMsgForOnline(members.getFkClientId(), imMessageOnlineSend);
+//
+//                // 离线消息推送
+//                pushMsgToOfflineMembers(application, members, param.getPushContent(), param.getPushExt());
             }
             }
 
 
         });
         });
@@ -832,9 +837,9 @@ public class ImMessageServiceImpl extends BaseServiceImpl<ImMessageMapper, ImMes
             receiverMember.setFkConversationId(conversation.getId());
             receiverMember.setFkConversationId(conversation.getId());
 
 
             ImConversationMembers creatorMember = new ImConversationMembers();
             ImConversationMembers creatorMember = new ImConversationMembers();
-            receiverMember.setClientId(sender.getClientId());
-            receiverMember.setFkClientId(sender.getId());
-            receiverMember.setFkConversationId(conversation.getId());
+            creatorMember.setClientId(sender.getClientId());
+            creatorMember.setFkClientId(sender.getId());
+            creatorMember.setFkConversationId(conversation.getId());
 
 
             List<ImConversationMembers> conversationMembers = new ArrayList<>();
             List<ImConversationMembers> conversationMembers = new ArrayList<>();
             conversationMembers.add(receiverMember);
             conversationMembers.add(receiverMember);