修复bug:返回已存在的一对一会话id

common/src/main/java/com/wecloud/im/mapper/ImConversationMapper.java

@@ -77,7 +77,7 @@ public interface ImConversationMapper extends BaseMapper<ImConversation> {
 
 
 
 
     /**
     /**
-     * 查询已经存在的会话信息
+     * 查询已经存在的一对一会话信息
      *
      *
      * @param clientId1
      * @param clientId1
      * @param clientId2
      * @param clientId2

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

@@ -135,7 +135,7 @@ public class ImConversationServiceImpl extends BaseServiceImpl<ImConversationMap
                 if (repetitionConversation != 0) {
                 if (repetitionConversation != 0) {
 
 
                     log.info("repetitionConversation != 0");
                     log.info("repetitionConversation != 0");
-                    // 返回已存在的会话id
+                    // 返回已存在的一对一会话id
                     ImConversation repetitionConversationInfo = imConversationMapper.getRepetitionConversationInfo(createClient.getId(), client2.getId());
                     ImConversation repetitionConversationInfo = imConversationMapper.getRepetitionConversationInfo(createClient.getId(), client2.getId());
                     ImConversationCreateVo imConversationCreateVo = new ImConversationCreateVo();
                     ImConversationCreateVo imConversationCreateVo = new ImConversationCreateVo();
                     imConversationCreateVo.setId(repetitionConversationInfo.getId());
                     imConversationCreateVo.setId(repetitionConversationInfo.getId());

common/src/main/resources/mapper/ImConversationMapper.xml

@@ -92,14 +92,19 @@
 
 
 
 
     <select id="getRepetitionConversationInfo" resultType="com.wecloud.im.entity.ImConversation">
     <select id="getRepetitionConversationInfo" resultType="com.wecloud.im.entity.ImConversation">
-        SELECT im_conversation.*
+
+        SELECT im_conversation.*,
+               (SELECT COUNT(im2.id)
+                FROM im_conversation_members AS im2
+                WHERE im2.fk_conversation_id = im_conversation_members.fk_conversation_id) AS members_count
         FROM im_conversation_members
         FROM im_conversation_members
                  INNER JOIN (SELECT *
                  INNER JOIN (SELECT *
                              FROM im_conversation_members
                              FROM im_conversation_members
                              WHERE im_conversation_members.fk_client_id = #{clientId2}) AS im_conversation_members2
                              WHERE im_conversation_members.fk_client_id = #{clientId2}) AS im_conversation_members2
                             ON im_conversation_members.fk_conversation_id = im_conversation_members2.fk_conversation_id
                             ON im_conversation_members.fk_conversation_id = im_conversation_members2.fk_conversation_id
                  INNER JOIN im_conversation ON im_conversation.id = im_conversation_members.fk_conversation_id
                  INNER JOIN im_conversation ON im_conversation.id = im_conversation_members.fk_conversation_id
-        WHERE im_conversation_members.fk_client_id = #{clientId1} LIMIT  1
+        WHERE im_conversation_members.fk_client_id = #{clientId1}
+        HAVING members_count = 2 LIMIT 1
     </select>
     </select>
 
 
 </mapper>
 </mapper>