Method GetPub

internal/repository/cache/post.go:375–400

GetPub 获取已发布帖子缓存

(ctx context.Context, key string)

// GetPub 获取已发布帖子缓存
func (c *postCache) GetPub(ctx context.Context, key string) (domain.Post, error) {
	if key == "" {
		return domain.Post{}, fmt.Errorf("无效的帖子ID: %s", key)
	}

	// 先检查是否是空对象
	isEmpty, err := c.IsEmpty(ctx, key)
	if err == nil && isEmpty {
		return domain.Post{}, fmt.Errorf("帖子不存在 %s", key)
	}

	data, err := c.client.Get(ctx, c.pubKey(key)).Bytes()
	if err != nil {
		if err == redis.Nil {
			return domain.Post{}, fmt.Errorf("缓存中未找到已发布帖子: %s", key)
		}
		return domain.Post{}, fmt.Errorf("从缓存获取已发布帖子失败: %v", err)
	}

	var post domain.Post
	if err = json.Unmarshal(data, &post); err != nil {
		return domain.Post{}, fmt.Errorf("反序列化已发布帖子数据失败: %v", err)
	}

	return post, nil
}

// SetPub 设置已发布帖子缓存
func (c *postCache) SetPub(ctx context.Context, key string, post domain.Post) error {