bug fix

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

@@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.metadata.OrderItem;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.google.common.collect.Lists;
+import com.google.common.collect.Maps;
 import com.wecloud.im.entity.ImApplication;
 import com.wecloud.im.entity.ImClient;
 import com.wecloud.im.entity.ImConversation;
@@ -228,28 +229,29 @@ public class ImConversationServiceImpl extends BaseServiceImpl<ImConversationMap
             imConversationMembers2.setFkClientId(client2.getId());
             imConversationMembers2.setRole(GroupRoleEnum.NORMAL.getCode());
             imConversationMembersService.save(imConversationMembers2);
-            // 给被拉入群的成员下发事件消息
-            ImMessage imMessage = new ImMessage();
-            Map<String, Object> content = new HashMap<>();
-            content.put("operator", createClient.getClientId()); //操作的client ID
-            content.put("passivityOperator", client2.getClientId()); //被操作的client ID
-            imMessage.setContent(JsonUtils.encodeJson(content));
-
-            //  保存消息至消息表
-            imMessage.setId(SnowflakeUtil.getId());
-            imMessage.setMsgType(MsgTypeEnum.CLIENT_JOIN_NEW_CONVERSATION.getUriCode());
-            imMessage.setCreateTime(new Date());
-            imMessage.setFkAppid(imApplication.getId());
-            imMessage.setSender(createClient.getId());
-            imMessage.setWithdraw(false);
-            imMessage.setEvent(true);
-            imMessage.setSystemFlag(false);
-            imMessage.setSendStatus(2);
-            imMessage.setFkConversationId(imConversation.getId());
-            imMessageService.save(imMessage);
-            sendEventMsgToMember(imApplication, client2.getId(), imMessage, createClient, client2);
+            if (imConversationCreate.getClientIds().size() > 1) {
+                // 给被拉入群的成员下发事件消息 -- 单聊则不下发
+                ImMessage imMessage = new ImMessage();
+                Map<String, Object> content = Maps.newHashMap();
+                content.put("operator", createClient.getClientId()); //操作的client ID
+                content.put("passivityOperator", client2.getClientId()); //被操作的client ID
+                imMessage.setContent(JsonUtils.encodeJson(content));
+
+                //  保存消息至消息表
+                imMessage.setId(SnowflakeUtil.getId());
+                imMessage.setMsgType(MsgTypeEnum.CLIENT_JOIN_NEW_CONVERSATION.getUriCode());
+                imMessage.setCreateTime(new Date());
+                imMessage.setFkAppid(imApplication.getId());
+                imMessage.setSender(createClient.getId());
+                imMessage.setWithdraw(false);
+                imMessage.setEvent(true);
+                imMessage.setSystemFlag(false);
+                imMessage.setSendStatus(2);
+                imMessage.setFkConversationId(imConversation.getId());
+                imMessageService.save(imMessage);
+                sendEventMsgToMember(imApplication, client2.getId(), imMessage, createClient, client2);
+            }
         }
-
         ImConversationCreateVo imConversationCreateVo = new ImConversationCreateVo();
         imConversationCreateVo.setId(imConversationId);