增加createImConversationForSdk接口

core/src/main/java/com/wecloud/im/service/ImConversationService.java

 package com.wecloud.im.service;
 
-import io.geekidea.springbootplus.framework.common.api.ApiResult;
-import io.geekidea.springbootplus.framework.common.service.BaseService;
-import io.geekidea.springbootplus.framework.core.pagination.Paging;
-
-import java.util.List;
-
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.wecloud.im.entity.ImConversation;
-import com.wecloud.im.param.ChatRoomMemberPageParam;
-import com.wecloud.im.param.DisbandConversationParam;
-import com.wecloud.im.param.ExitChatRoomParam;
-import com.wecloud.im.param.GroupChatSettingParam;
-import com.wecloud.im.param.ImConversationPageParam;
-import com.wecloud.im.param.ImConversationQueryParam;
-import com.wecloud.im.param.ImConversationQueryVo;
-import com.wecloud.im.param.IntoChatRoomParam;
-import com.wecloud.im.param.ListConversationParam;
-import com.wecloud.im.param.MutedGroupMemberParam;
-import com.wecloud.im.param.MutedGroupParam;
-import com.wecloud.im.param.SetAdminsParam;
-import com.wecloud.im.param.TransferOwnerParam;
-import com.wecloud.im.param.add.ImClientLeaveConversation;
-import com.wecloud.im.param.add.ImClientToConversation;
-import com.wecloud.im.param.add.ImConversationAttrUpdate;
-import com.wecloud.im.param.add.ImConversationCreate;
-import com.wecloud.im.param.add.ImConversationDisplayUpdate;
-import com.wecloud.im.param.add.ImConversationNameUpdate;
+import com.wecloud.im.param.*;
+import com.wecloud.im.param.add.*;
 import com.wecloud.im.vo.ChatRoomMemberVo;
 import com.wecloud.im.vo.ConversationVo;
 import com.wecloud.im.vo.ImConversationCreateVo;
+import io.geekidea.springbootplus.framework.common.api.ApiResult;
+import io.geekidea.springbootplus.framework.common.service.BaseService;
+import io.geekidea.springbootplus.framework.core.pagination.Paging;
+
+import java.util.Collection;
+import java.util.List;
 
 /**
  * 会话表 服务类
@@ -57,6 +40,14 @@ public interface ImConversationService extends BaseService<ImConversation> {
      */
     ImConversationCreateVo createImConversation(ImConversationCreate imConversationCreate);
 
+    /**
+     * 创建会话 sdk用
+     *
+     * @param imConversationCreate
+     * @return
+     */
+    ImConversation createImConversationForSdk(ImConversationCreate imConversationCreate);
+
 
     /**
      * 将用户添加进会话
@@ -247,14 +238,13 @@ public interface ImConversationService extends BaseService<ImConversation> {
     List<ConversationVo> listConversation(ListConversationParam param);
 
     /**
-     *
-     * @Author luozh
-     * @Date 2022年05月06日 07:18:34
      * @param senderClientId
      * @param receiverClientIds
+     * @Author luozh
+     * @Date 2022年05月06日 07:18:34
      * @Return
      */
-    List<ImConversation> getConversationBySenderAndReceivers(Long senderImClientId, List<Long> receiverImClientIds);
+    List<ImConversation> getConversationBySenderAndReceivers(Long senderImClientId, Collection<Long> receiverImClientIds);
 
 
 }

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

 package com.wecloud.im.service.impl;
 
-import io.geekidea.springbootplus.framework.common.api.ApiCode;
-import io.geekidea.springbootplus.framework.common.api.ApiResult;
-import io.geekidea.springbootplus.framework.common.enums.BaseEnum;
-import io.geekidea.springbootplus.framework.common.exception.BusinessException;
-import io.geekidea.springbootplus.framework.common.service.impl.BaseServiceImpl;
-import io.geekidea.springbootplus.framework.core.pagination.PageInfo;
-import io.geekidea.springbootplus.framework.core.pagination.Paging;
-import lombok.extern.slf4j.Slf4j;
-
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.stream.Collectors;
-
-import org.apache.commons.collections4.CollectionUtils;
-import org.springframework.beans.BeanUtils;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.cache.annotation.CacheConfig;
-import org.springframework.cache.annotation.CacheEvict;
-import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
-
 import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
@@ -33,48 +9,16 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
 import com.wecloud.im.chatroom.cache.ChatRoomCacheManager;
-import com.wecloud.im.entity.ImApplication;
-import com.wecloud.im.entity.ImClient;
-import com.wecloud.im.entity.ImConversation;
-import com.wecloud.im.entity.ImConversationMembers;
-import com.wecloud.im.entity.ImMessage;
-import com.wecloud.im.entity.ImMessageOnlineSend;
+import com.wecloud.im.entity.*;
 import com.wecloud.im.mapper.ImConversationMapper;
-import com.wecloud.im.param.ChatRoomMemberPageParam;
-import com.wecloud.im.param.DisbandConversationParam;
-import com.wecloud.im.param.ExitChatRoomParam;
-import com.wecloud.im.param.GroupChatSettingParam;
-import com.wecloud.im.param.ImClientSimpleDto;
-import com.wecloud.im.param.ImConversationPageParam;
-import com.wecloud.im.param.ImConversationQueryParam;
-import com.wecloud.im.param.ImConversationQueryVo;
-import com.wecloud.im.param.IntoChatRoomParam;
-import com.wecloud.im.param.ListConversationMembersParam;
-import com.wecloud.im.param.ListConversationParam;
-import com.wecloud.im.param.MutedGroupMemberParam;
-import com.wecloud.im.param.MutedGroupParam;
-import com.wecloud.im.param.SetAdminsParam;
-import com.wecloud.im.param.TransferOwnerParam;
-import com.wecloud.im.param.add.ImClientLeaveConversation;
-import com.wecloud.im.param.add.ImClientToConversation;
-import com.wecloud.im.param.add.ImConversationAttrUpdate;
-import com.wecloud.im.param.add.ImConversationCreate;
-import com.wecloud.im.param.add.ImConversationDisplayUpdate;
-import com.wecloud.im.param.add.ImConversationNameUpdate;
+import com.wecloud.im.param.*;
+import com.wecloud.im.param.add.*;
 import com.wecloud.im.sdk.enums.ChatTypeEnum;
 import com.wecloud.im.sdk.enums.GroupChatSettingTypeEnum;
 import com.wecloud.im.sdk.enums.GroupRoleEnum;
 import com.wecloud.im.sdk.enums.MutedEnum;
-import com.wecloud.im.service.ContextService;
-import com.wecloud.im.service.ImClientService;
-import com.wecloud.im.service.ImConversationMembersService;
-import com.wecloud.im.service.ImConversationService;
-import com.wecloud.im.service.ImMessageService;
-import com.wecloud.im.vo.ChatRoomMemberVo;
-import com.wecloud.im.vo.ConversationMemberVo;
-import com.wecloud.im.vo.ConversationVo;
-import com.wecloud.im.vo.ImConversationCreateVo;
-import com.wecloud.im.vo.OfflineMsgDto;
+import com.wecloud.im.service.*;
+import com.wecloud.im.vo.*;
 import com.wecloud.im.ws.enums.MsgTypeEnum;
 import com.wecloud.im.ws.enums.WsResponseCmdEnum;
 import com.wecloud.im.ws.model.WsResponse;
@@ -82,15 +26,26 @@ import com.wecloud.im.ws.sender.ChannelSender;
 import com.wecloud.im.ws.utils.RedisUtils;
 import com.wecloud.utils.JsonUtils;
 import com.wecloud.utils.SnowflakeUtil;
+import io.geekidea.springbootplus.framework.common.api.ApiCode;
+import io.geekidea.springbootplus.framework.common.api.ApiResult;
+import io.geekidea.springbootplus.framework.common.enums.BaseEnum;
+import io.geekidea.springbootplus.framework.common.exception.BusinessException;
+import io.geekidea.springbootplus.framework.common.service.impl.BaseServiceImpl;
+import io.geekidea.springbootplus.framework.core.pagination.PageInfo;
+import io.geekidea.springbootplus.framework.core.pagination.Paging;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections4.CollectionUtils;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.cache.annotation.CacheConfig;
+import org.springframework.cache.annotation.CacheEvict;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
-import static com.wecloud.im.ws.enums.MsgTypeEnum.CONVERSATION_FORBID_ADD_FRIEND;
-import static com.wecloud.im.ws.enums.MsgTypeEnum.CONVERSATION_FORBID_ADD_FRIEND_CANCEL;
-import static com.wecloud.im.ws.enums.MsgTypeEnum.CONVERSATION_FORBID_SEND_LINK;
-import static com.wecloud.im.ws.enums.MsgTypeEnum.CONVERSATION_FORBID_SEND_LINK_CANCEL;
-import static com.wecloud.im.ws.enums.MsgTypeEnum.CONVERSATION_FORBID_SEND_PIC;
-import static com.wecloud.im.ws.enums.MsgTypeEnum.CONVERSATION_FORBID_SEND_PIC_CANCEL;
-import static com.wecloud.im.ws.enums.MsgTypeEnum.CONVERSATION_FORBID_SEND_RED_PACKETS;
-import static com.wecloud.im.ws.enums.MsgTypeEnum.CONVERSATION_FORBID_SEND_RED_PACKETS_CANCEL;
+import java.util.*;
+import java.util.stream.Collectors;
+
+import static com.wecloud.im.ws.enums.MsgTypeEnum.*;
 
 /**
  * 会话表 服务实现类
@@ -290,6 +245,11 @@ public class ImConversationServiceImpl extends BaseServiceImpl<ImConversationMap
     }
 
     @Override
+    public ImConversation createImConversationForSdk(ImConversationCreate imConversationCreate) {
+        return null;
+    }
+
+    @Override
     @Transactional(rollbackFor = Exception.class)
     public Boolean addClientToConversation(ImClientToConversation imClientToConversation) {
 
@@ -1151,7 +1111,7 @@ public class ImConversationServiceImpl extends BaseServiceImpl<ImConversationMap
     }
 
     @Override
-    public List<ImConversation> getConversationBySenderAndReceivers(Long senderImClientId, List<Long> receiverImClientIds) {
+    public List<ImConversation> getConversationBySenderAndReceivers(Long senderImClientId, Collection<Long> receiverImClientIds) {
         return baseMapper.getConversationBySenderAndReceivers(senderImClientId, receiverImClientIds);
     }