Method SetPub

internal/repository/cache/post.go:403–435

SetPub 设置已发布帖子缓存

(ctx context.Context, key string, post domain.Post)

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

	// 获取分布式锁
	lockKey := c.lockKey("pub:" + key)
	success, err := c.acquireLock(ctx, lockKey, 5*time.Second)
	if err != nil {
		return fmt.Errorf("获取分布式锁失败: %v", err)
	}
	if !success {
		return fmt.Errorf("获取分布式锁失败: 锁已被占用")
	}
	defer c.releaseLock(ctx, lockKey)

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

	// 使用随机过期时间
	randomExpiration := c.expiration + time.Duration(rand.Int63n(300))*time.Second
	err = c.client.Set(ctx, c.pubKey(key), data, randomExpiration).Err()
	if err != nil {
		return fmt.Errorf("设置缓存失败: %v", err)
	}

	// 删除空对象标记(如果存在)
	_ = c.client.Del(ctx, c.emptyKey(key))

	return nil
}

// DelPub 删除已发布帖子缓存
func (c *postCache) DelPub(ctx context.Context, key string) error {