Method Get

internal/repository/cache/post.go:58–83

Get 获取帖子缓存

(ctx context.Context, key string)

// Get 获取帖子缓存
func (c *postCache) Get(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.key(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
}

// Set 设置帖子缓存,使用随机过期时间防止缓存雪崩
func (c *postCache) Set(ctx context.Context, key string, post domain.Post) error {