Method GetPublishPostById

internal/service/post.go:134–177

GetPublishPostById 获取已发布的帖子详细信息

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

// GetPublishPostById 获取已发布的帖子详细信息
func (p *postService) GetPublishPostById(ctx context.Context, postId uint, uid int64) (domain.Post, error) {
	dp, err := p.repo.GetPublishPostById(ctx, postId)
	if err != nil {
		p.l.Error("获取已发布帖子失败", zap.Error(err))
		return domain.Post{}, fmt.Errorf("获取已发布帖子失败: %w", err)
	}

	// 设置超时上下文
	ctx, cancel := context.WithTimeout(ctx, time.Second*5)
	defer cancel()

	// 异步处理阅读事件
	asyncReadEvent := general.WithAsyncCancel(ctx, cancel, func() error {
		if er := p.producer.ProduceReadEvent(post.ReadEvent{
			PostId:  postId,
			Uid:     uid,
			Title:   dp.Title,
			Content: dp.Content,
		}); er != nil {
			p.l.Error("生成阅读事件失败", zap.Error(er))
			return fmt.Errorf("生成阅读事件失败: %w", er)
		}
		return nil
	})
	asyncReadEvent()

	inc, err := p.incRepo.Get(ctx, postId)
	if err != nil && err != gorm.ErrRecordNotFound {
		p.l.Error("获取互动数据失败", zap.Error(err))
		return domain.Post{}, fmt.Errorf("获取互动数据失败: %w", err)
	} else if err == gorm.ErrRecordNotFound {
		inc = domain.Interactive{
			LikeCount:    0,
			ReadCount:    0,
			CollectCount: 0,
		}
	}

	dp.LikeCount = inc.LikeCount
	dp.ReadCount = inc.ReadCount
	dp.CollectCount = inc.CollectCount

	return dp, nil
}

// ListPosts 列出帖子
func (p *postService) ListPosts(ctx context.Context, pagination domain.Pagination) ([]domain.Post, error) {