Method ListComments

internal/service/comment.go:84–118

ListComments 列出评论的实现

(ctx context.Context, postId, minID, limit int64)

// ListComments 列出评论的实现
func (c *commentService) ListComments(ctx context.Context, postId, minID, limit int64) ([]domain.Comment, error) {
	// 获取评论列表
	comments, err := c.repo.ListComments(ctx, postId, minID, limit)
	if err != nil {
		return nil, fmt.Errorf("获取评论列表失败: %w", err)
	}

	// 初始化返回的评论列表
	domainComments := make([]domain.Comment, 0, len(comments))
	var eg errgroup.Group

	// 并发处理每个评论
	for i, comment := range comments {
		domainComments = append(domainComments, comment)

		i := i // 创建副本避免闭包问题
		commentId := comment.Id
		eg.Go(func() error {
			// 获取最新的三条子评论
			subComments, err := c.repo.GetMoreCommentsReply(ctx, commentId, 0, 3)
			if err != nil {
				return fmt.Errorf("获取子评论失败: %w", err)
			}

			domainComments[i].Children = subComments
			return nil
		})
	}

	if err := eg.Wait(); err != nil {
		return nil, err
	}

	return domainComments, nil
}

func (c *commentService) GetTopCommentsReply(ctx context.Context, postId int64) (domain.Comment, error) {
	return c.repo.GetTopCommentsReply(ctx, postId)