1
  /**
2
     * 获取聊天频道话题评论列表
3
     *
4
     * @param channelId   频道id
5
     * @param userId      用户id
6
     * @param pageCurrent 当前页
7
     * @param pageSize    每页条数
8
     * @return {@link List < InstantChatChannelCommentVo >} 聊天频道话题评论列表
9
     * @throws Exception 异常
10
     * @author shenhuanjie
11
     * @version v2.3.0
12
     * @since 2024/2/21 14:42
13
     */
14
    @Override
15
    public List<InstantChatChannelCommentVo> getInstantChatChannelCommentList(String channelId, String userId, Integer pageCurrent, Integer pageSize) throws InvocationTargetException, IllegalAccessException {
16
        if (StringUtils.isEmpty(channelId)) {
17
            throw new IllegalArgumentException("频道id不能为空");
18
        }
19
        PlatInstantChatChannelEntity channel = platInstantChatChannelService.getInstantChatChannelDetail(channelId);
20
        if (channel == null) {
21
            throw new RuntimeException("频道不存在");
22
        }
23
        // 校验频道类型
24
        String channelType = channel.getChannelType();
25
        if (StringUtils.isEmpty(channelType)) {
26
            throw new RuntimeException("频道类型不能为空");
27
        }
28
        if (!channelType.equals(InstantChatChannelTypeEnum.COMMENT_CHANNEL.getCode())) {
29
            throw new RuntimeException("该频道不支持评论");
30
        }
31
        // 获取频道评论列表
32
        List<PlatInstantChatChannelCommentEntity> commentList = this.getInstantsChatChannelCommentList(channelId, pageCurrent, pageSize);
33
        // 频道评论列表 IDS 集合
34
        List<String> commentIds = commentList.stream().map(PlatInstantChatChannelCommentEntity::getId).collect(Collectors.toList());
35
        // 获取频道评论回复列表
36
        List<PlatInstantChatChannelCommentEntity> replyList = this.getInstantsChatChannelCommentReplyList(commentIds);
37

38
        Map<String, InstantChatChannelCommentVo> commentTreeMap = new TreeMap<>();
39

40
        for (PlatInstantChatChannelCommentEntity comment : commentList) {
41
            InstantChatChannelCommentVo vo = new InstantChatChannelCommentVo();
42
            BeanUtils.copyProperties(vo, comment);
43
            commentTreeMap.put(comment.getId(), vo);
44
        }
45

46
        for (PlatInstantChatChannelCommentEntity reply : replyList) {
47
            String parentId = reply.getParentId();
48
            if (StringUtils.isEmpty(parentId)) {
49
                continue;
50
            }
51
            if (!commentTreeMap.containsKey(parentId)) {
52
                continue;
53
            }
54
            List<InstantChatChannelCommentVo> parentReplyList = commentTreeMap.get(parentId).getReplyList();
55
            if (parentReplyList == null) {
56
                parentReplyList = new ArrayList<>();
57
                commentTreeMap.get(parentId).setReplyList(parentReplyList);
58
            }
59
            InstantChatChannelCommentVo vo = new InstantChatChannelCommentVo();
60
            BeanUtils.copyProperties(vo, reply);
61
            commentTreeMap.get(parentId).getReplyList().add(vo);
62
        }
63
        List<InstantChatChannelCommentVo> commentVos = new ArrayList<>(commentTreeMap.values());
64
        // 按照评论时间倒序排序
65
        commentVos.sort(Comparator.comparing(InstantChatChannelCommentVo::getCreateTime).reversed());
66
        return commentVos;
67
    }