Method ListPublishPosts

internal/repository/post.go:197–238

ListPublishPosts 获取已发布的帖子列表

(ctx context.Context, pagination domain.Pagination, biz ...int)

// ListPublishPosts 获取已发布的帖子列表
func (p *postRepository) ListPublishPosts(ctx context.Context, pagination domain.Pagination, biz ...int) ([]domain.Post, error) {
	// 先从缓存中获取
	posts, err := p.cache.GetPubList(ctx, pagination.Page, int(*pagination.Size))
	if err == nil && len(posts) > 0 {
		return posts, nil
	}

	// 缓存未命中,从数据库获取
	pub, err := p.dao.ListPub(ctx, pagination)
	if err != nil {
		p.l.Error("从数据库获取已发布帖子列表失败", zap.Error(err))
		return nil, fmt.Errorf("从数据库获取已发布帖子列表失败: %w", err)
	}

	if len(pub) == 0 && len(biz) == 0 {
		p.l.Info("没有找到已发布的帖子")
		// 缓存空对象
		if err := p.cache.SetEmpty(ctx, fmt.Sprint(pagination.Page)); err != nil {
			p.l.Error("设置空对象缓存失败", zap.Error(err))
		}
		return []domain.Post{}, nil
	}

	result := change.FromDomainSlicePubPostList(pub)

	go func() {
		// 如果是前三页
		if pagination.Page <= 3 {
			if err := p.cache.PreHeat(ctx, result); err != nil {
				p.l.Error("预热已发布帖子列表缓存失败", zap.Error(err))
			}
		} else {
			if err := p.cache.SetPubList(ctx, pagination.Page, int(*pagination.Size), result); err != nil {
				p.l.Error("缓存已发布帖子列表失败",
					zap.Error(err),
					zap.Int("page", pagination.Page))
			}
		}
	}()

	return result, nil
}

// Delete 删除帖子
func (p *postRepository) Delete(ctx context.Context, postId uint, uid int64) error {