Method Delete

internal/repository/post.go:241–265

Delete 删除帖子

(ctx context.Context, postId uint, uid int64)

// Delete 删除帖子
func (p *postRepository) Delete(ctx context.Context, postId uint, uid int64) error {
	// 获取帖子
	post, err := p.GetPostById(ctx, postId, uid)
	if err != nil {
		return fmt.Errorf("获取帖子失败: %w", err)
	}

	if post.ID == 0 {
		return fmt.Errorf("帖子不存在")
	}

	// 删除帖子
	if err := p.dao.Delete(ctx, postId, uid); err != nil {
		p.l.Error("删除帖子失败", zap.Error(err), zap.Uint("post_id", postId))
		return fmt.Errorf("删除帖子失败: %w", err)
	}

	if post.Status == domain.Published {
		p.refreshCache(job.RefreshTypeAll, "*", postId)
	}

	p.refreshCache(job.RefreshTypeNormal, "*", postId)

	return nil
}

// GetPost 获取帖子
func (p *postRepository) GetPost(ctx context.Context, postId uint) (domain.Post, error) {