runSystemTaskClaimPass tries to claim one pending task per registered type and dispatches each claimed task in its own goroutine so a long-running han

runSystemTaskScheduler creates a new task row for each enabled scheduled handler whose interval has elapsed since its last run and that has no active

saturateQuota converts an already-rounded quota value to int, clamping to the int32 range. Whenever clamping (what would otherwise be an integer wrapa

* var syncModels = []string{ "z-image", "qwen-image", "wan2.6", } */

taskBillingOther 从 task 的 BillingContext 构建日志 Other 字段。

taskModelName 从 BillingContext 或 Properties 中获取模型名称。

withNormalizedEmailLock serializes concurrent writers that target the same normalized email inside tx, so a "check then write" sequence cannot be race

Admin bind (no payment). Creates a UserSubscription from a plan.

BodyStorageCleanup 请求体存储清理中间件 在请求处理完成后自动清理磁盘/内存缓存

BuildParamOverrideContext 提供 ApplyParamOverride 可用的上下文信息。 目前内置以下字段： - upstream_model/model：始终为通道映射后的上游模型名。 - original_model：请求最初指定的模型名。 - request_path

BuildProxyURL constructs the video proxy URL using the public task ID. e.g., "https://your-server.com/v1/videos/task_xxxx/content"

CacheGetRandomSatisfiedChannel tries to get a random channel that satisfies the requirements. 尝试获取一个满足要求的随机渠道。 For "auto" tokenGroup with cross-group

CheckClusterNameAvailability checks if a cluster name is available

CheckUserExistOrDeleted check if user exist or deleted, if not exist, return false, nil, if deleted or exist, return true, nil

CleanupOldDiskCacheFiles 清理旧的缓存文件 maxAge: 文件最大存活时间 注意：此函数只删除文件，不更新统计（因为无法知道每个文件的原始大小）

CreateBackupCodes 创建备用码

CreateWaffoPancakeCheckoutSession creates an Authenticated-mode checkout session: the order is bound to BuyerIdentity (stable per user) so it stays at

return image.Config, format, clean base64 string, error