Method refreshPubCache

internal/job/refresh_cache.go:69–82

刷新发布的帖子缓存

(ctx context.Context, key, postId string, logger *zap.Logger)

// 刷新发布的帖子缓存
func (r *RefreshCacheTask) refreshPubCache(ctx context.Context, key, postId string, logger *zap.Logger) error {
	if err := r.cache.DelPubList(ctx, key); err != nil {
		logger.Error("删除发布帖子列表缓存失败", zap.Error(err))
		return fmt.Errorf("删除发布帖子列表缓存失败: %w", err)
	}

	if err := r.cache.DelPub(ctx, postId); err != nil {
		logger.Error("删除发布帖子缓存失败", zap.Error(err))
		return fmt.Errorf("删除发布帖子缓存失败: %w", err)
	}

	logger.Info("删除发布帖子缓存成功")
	return nil
}

// 刷新普通帖子缓存
func (r *RefreshCacheTask) refreshNormalCache(ctx context.Context, key, postId string, logger *zap.Logger) error {