Merge remote-tracking branch 'origin/xiaohudou_20220427' into xiaohudou_20220427

config/src/main/resources/config/application-dev.yml

@@ -20,7 +20,7 @@ spring:
 #    password: 123456
 
 # 测试外网
-    url: jdbc:mysql://121.37.22.224:3306/wecloud_im_feature_cluster?serverTimezone=UTC&useUnicode=true&characterEncoding=utf8&useSSL=false&allowPublicKeyRetrieval=true
+    url: jdbc:mysql://124.71.83.11:3306/wecloud_im?serverTimezone=UTC&useUnicode=true&characterEncoding=utf8&useSSL=false&allowPublicKeyRetrieval=true
     username: root
     password: temple123456
 

core/src/main/java/com/wecloud/im/controller/ImConversationController.java

@@ -259,7 +259,7 @@ public class ImConversationController extends BaseController {
      */
     @PostMapping("/listConversation")
     @ApiOperation(value = "批量查找会话信息", notes = "会话")
-    public ApiResult<List<ConversationVo>> listConversation(ListConversationParam param) {
+    public ApiResult<List<ConversationVo>> listConversation(@RequestBody ListConversationParam param) {
         List<ConversationVo> conversationList = imConversationService.listConversation(param);
         return ApiResult.ok(conversationList);
     }

core/src/main/java/com/wecloud/im/param/ListConversationParam.java

@@ -26,7 +26,7 @@ public class ListConversationParam extends BaseEntity {
     private Integer chatType;
 
     @ApiModelProperty("会话id列表")
-    private List<Long> conversationIds;
+    private String conversationIds;
 
 
 

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

@@ -31,6 +31,7 @@ import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.metadata.OrderItem;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.chanjx.utils.StringUtils;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
 import com.wecloud.im.chatroom.cache.ChatRoomCacheManager;
@@ -1261,14 +1262,15 @@ public class ImConversationServiceImpl extends BaseServiceImpl<ImConversationMap
 
     @Override
     public List<ConversationVo> listConversation(ListConversationParam param) {
-        if (CollectionUtils.isEmpty(param.getConversationIds())) {
+        if (StringUtils.isBlank(param.getConversationIds())) {
             throw new BusinessException("会话id列表不可为空");
         }
+        List<Long> conversationIds = (List)JSON.parse(param.getConversationIds());
         List<ConversationVo> conversationVoList = Lists.newArrayList();
         List<ImConversation> conversations = imConversationMapper.selectList(
                 new QueryWrapper<ImConversation>().lambda()
                         .eq(ImConversation::getChatType, param.getChatType())
-                        .in(ImConversation::getId, param.getConversationIds())
+                        .in(ImConversation::getId, conversationIds)
                         .orderByDesc(ImConversation::getId)
         );
         if (CollectionUtils.isEmpty(conversations)) {