RecalculateTaskQuota 通用的异步差额结算。 actualQuota 是任务完成后的实际应扣额度，与预扣额度 (task.Quota) 做差额结算。 reason 用于日志记录（例如 "token重算" 或 "adaptor调整"）。 clamps 可选：若计算 actualQuo

func (info *RelayInfo) SetPromptTokens(promptTokens int) { info.promptTokens = promptTokens }

SetToolPriceForTest injects a tool price and rebuilds the lookup index. Tests only.

T translates a message key using the language from gin context

--------------------------------------------------------------------------- BuildTieredTokenParams: token normalization and ratio parity tests -------

GetResultURL 获取任务结果 URL（视频地址等） 新数据存在 PrivateData.ResultURL 中；旧数据回退到 FailReason（历史兼容）

GetSSRFProtectedHTTPClient 返回带拨号时 SSRF 校验的客户端。 ssrfProtectedHTTPClient 由 InitHttpClient 在启动时初始化，运行期只读。

GetUserSessionCached validates cached state first and falls back to the database on a miss or Redis read failure. A deny tombstone never falls back.

LoadFromJsonStringWithCallback loads a JSON string into the RWMap and calls the callback on success.

Update subscription used amount by delta (positive consume more, negative refund).

attachQuotaSaturation records the request's quota clamp (if any) onto the consume log's other.admin_info and emits a request-correlated backend audit

setupLogin creates a server-controlled login Session and returns the shared authentication bundle used by every login method.

AdvanceCurrentSessionToUserVersion is used when the security mutation and AuthVersion increment were committed in the same transaction (for example, a

ClaimExternalIdentityWithTx atomically claims a provider subject for one user. Repeating the exact mapping is idempotent; every competing subject or u

Complete a subscription order (idempotent). Creates a UserSubscription snapshot from the plan. expectedPaymentProvider guards against cross-gateway ca

ConsumeAuthFlow atomically validates and consumes a flow. Optional match fields are enforced when non-zero so tokens cannot cross purposes or users.