Merge pull request #6738 from Milesians/codex/fix-interval-multiplier-display

fix: 修正区间倍率展示并补齐模型广场 1h 缓存价格
This commit is contained in:
Wesley Liddick
2026-09-07 18:51:00 +08:00
committed by GitHub
13 changed files with 248 additions and 50 deletions
@@ -81,15 +81,19 @@ type userSupportedModelPricing struct {
// userPricingIntervalDTO 定价区间白名单(去掉内部 ID、SortOrder 等前端不渲染的字段)。
type userPricingIntervalDTO struct {
MinTokens int `json:"min_tokens"`
MaxTokens *int `json:"max_tokens"`
TierLabel string `json:"tier_label,omitempty"`
InputPrice *float64 `json:"input_price"`
OutputPrice *float64 `json:"output_price"`
CacheWritePrice *float64 `json:"cache_write_price"`
CacheWrite1hPrice *float64 `json:"cache_write_1h_price"`
CacheReadPrice *float64 `json:"cache_read_price"`
PerRequestPrice *float64 `json:"per_request_price"`
MinTokens int `json:"min_tokens"`
MaxTokens *int `json:"max_tokens"`
TierLabel string `json:"tier_label,omitempty"`
InputPrice *float64 `json:"input_price"`
OutputPrice *float64 `json:"output_price"`
CacheWritePrice *float64 `json:"cache_write_price"`
CacheWrite1hPrice *float64 `json:"cache_write_1h_price"`
CacheReadPrice *float64 `json:"cache_read_price"`
InputMultiplier *float64 `json:"input_multiplier"`
OutputMultiplier *float64 `json:"output_multiplier"`
CacheWriteMultiplier *float64 `json:"cache_write_multiplier"`
CacheReadMultiplier *float64 `json:"cache_read_multiplier"`
PerRequestPrice *float64 `json:"per_request_price"`
}
// userSupportedModel 用户可见的支持模型条目。
@@ -295,15 +299,19 @@ func toUserPricingIntervals(src []service.PricingInterval) []userPricingInterval
intervals := make([]userPricingIntervalDTO, 0, len(src))
for _, iv := range src {
intervals = append(intervals, userPricingIntervalDTO{
MinTokens: iv.MinTokens,
MaxTokens: iv.MaxTokens,
TierLabel: iv.TierLabel,
InputPrice: iv.InputPrice,
OutputPrice: iv.OutputPrice,
CacheWritePrice: iv.CacheWritePrice,
CacheWrite1hPrice: iv.CacheWrite1hPrice,
CacheReadPrice: iv.CacheReadPrice,
PerRequestPrice: iv.PerRequestPrice,
MinTokens: iv.MinTokens,
MaxTokens: iv.MaxTokens,
TierLabel: iv.TierLabel,
InputPrice: iv.InputPrice,
OutputPrice: iv.OutputPrice,
CacheWritePrice: iv.CacheWritePrice,
CacheWrite1hPrice: iv.CacheWrite1hPrice,
CacheReadPrice: iv.CacheReadPrice,
InputMultiplier: iv.InputMultiplier,
OutputMultiplier: iv.OutputMultiplier,
CacheWriteMultiplier: iv.CacheWriteMultiplier,
CacheReadMultiplier: iv.CacheReadMultiplier,
PerRequestPrice: iv.PerRequestPrice,
})
}
return intervals
@@ -113,10 +113,18 @@ func TestUserAvailableChannel_FieldWhitelist(t *testing.T) {
}
// pricing interval 白名单:不应暴露 id / sort_order。
inputMultiplier := 2.0
outputMultiplier := 1.5
cacheWriteMultiplier := 2.0
cacheReadMultiplier := 2.0
pricing := toUserPricing(&service.ChannelModelPricing{
BillingMode: service.BillingModeToken,
Intervals: []service.PricingInterval{
{ID: 7, MinTokens: 0, MaxTokens: nil, SortOrder: 3},
{
ID: 7, MinTokens: 0, MaxTokens: nil, SortOrder: 3,
InputMultiplier: &inputMultiplier, OutputMultiplier: &outputMultiplier,
CacheWriteMultiplier: &cacheWriteMultiplier, CacheReadMultiplier: &cacheReadMultiplier,
},
},
})
require.NotNil(t, pricing)
@@ -129,6 +137,14 @@ func TestUserAvailableChannel_FieldWhitelist(t *testing.T) {
_, exists := ivDecoded[key]
require.Falsef(t, exists, "user pricing interval must not expose %q", key)
}
for key, want := range map[string]float64{
"input_multiplier": inputMultiplier, "output_multiplier": outputMultiplier,
"cache_write_multiplier": cacheWriteMultiplier, "cache_read_multiplier": cacheReadMultiplier,
} {
got, exists := ivDecoded[key]
require.Truef(t, exists, "user pricing interval must expose %q", key)
require.InDelta(t, want, got.(float64), 1e-12)
}
}
func TestBuildPlatformSections_GroupsByPlatform(t *testing.T) {
@@ -19,13 +19,14 @@ const ContextPricingBasisWholeRequest ContextPricingBasis = "whole_request"
// ContextPricingTier (MinTokens, MaxTokens] 区间内的有效 per-token 单价(USD)。
// nil 表示该项无价/不计费;MaxTokens 为 nil 表示无上限。
type ContextPricingTier struct {
MinTokens int
MaxTokens *int
Label string
Input *float64
Output *float64
CacheWrite *float64
CacheRead *float64
MinTokens int
MaxTokens *int
Label string
Input *float64
Output *float64
CacheWrite *float64
CacheWrite1h *float64
CacheRead *float64
}
// TimePricingPeriod 分时倍率时段:配置时区当天 [StartTime, EndTime) 内整单费用乘 Multiplier。
@@ -289,6 +290,10 @@ func probeContextTier(seg contextSegment, resolved *ResolvedPricing, probe func(
return tier, err
}
// 输出价只随上下文所在档变化:固定上下文 c,对输出 token 数做差商(固定部分相减抵消)。
tier.CacheWrite1h, err = probeComponentPrice(func(n int) UsageTokens { return UsageTokens{CacheCreationTokens: n, CacheCreation1hTokens: n} }, c, delta, probe)
if err != nil {
return tier, err
}
tier.Output, err = probeComponentPrice(func(n int) UsageTokens { return UsageTokens{InputTokens: c, OutputTokens: n} }, 0, contextProbeDelta, probe)
if err != nil {
return tier, err
@@ -298,6 +303,7 @@ func probeContextTier(seg contextSegment, resolved *ResolvedPricing, probe func(
tier.Input = contextPricePtr(tier.Input, explicit.input)
tier.Output = contextPricePtr(tier.Output, explicit.output)
tier.CacheWrite = contextPricePtr(tier.CacheWrite, explicit.cacheWrite)
tier.CacheWrite1h = contextPricePtr(tier.CacheWrite1h, explicit.cacheWrite1h)
tier.CacheRead = contextPricePtr(tier.CacheRead, explicit.cacheRead)
return tier, nil
}
@@ -341,7 +347,7 @@ func roundContextPrice(v float64) float64 {
}
type explicitContextFields struct {
input, output, cacheWrite, cacheRead bool
input, output, cacheWrite, cacheWrite1h, cacheRead bool
}
// explicitContextPricingFields 判断各项是否被分组卡/渠道定价(含命中区间)显式配置。
@@ -355,11 +361,13 @@ func explicitContextPricingFields(resolved *ResolvedPricing, contextTokens int)
out.input = cp.InputPrice != nil
out.output = cp.OutputPrice != nil
out.cacheWrite = cp.CacheWritePrice != nil
out.cacheWrite1h = cp.CacheWrite1hPrice != nil || cp.CacheWritePrice != nil
out.cacheRead = cp.CacheReadPrice != nil
if iv := FindMatchingInterval(resolved.Intervals, contextTokens); iv != nil {
out.input = out.input || iv.InputPrice != nil
out.output = out.output || iv.OutputPrice != nil
out.cacheWrite = out.cacheWrite || iv.CacheWritePrice != nil
out.cacheWrite1h = out.cacheWrite1h || iv.CacheWrite1hPrice != nil || iv.CacheWritePrice != nil
out.cacheRead = out.cacheRead || iv.CacheReadPrice != nil
}
return out
@@ -393,7 +401,7 @@ func mergeEqualContextTiers(tiers []ContextPricingTier) []ContextPricingTier {
func sameContextPrices(a, b ContextPricingTier) bool {
return samePricePtr(a.Input, b.Input) && samePricePtr(a.Output, b.Output) &&
samePricePtr(a.CacheWrite, b.CacheWrite) && samePricePtr(a.CacheRead, b.CacheRead)
samePricePtr(a.CacheWrite, b.CacheWrite) && samePricePtr(a.CacheWrite1h, b.CacheWrite1h) && samePricePtr(a.CacheRead, b.CacheRead)
}
func samePricePtr(a, b *float64) bool {
@@ -385,6 +385,24 @@ func TestResolveContextPricingSchedule_NilResolver(t *testing.T) {
require.Nil(t, sched)
}
func TestPlazaSchedulePreservesCacheWrite1h(t *testing.T) {
cp := sonnetChannel(PricingInterval{MinTokens: 272000, CacheWriteMultiplier: testPtrFloat64(2)})
cp[0].CacheWritePrice = testPtrFloat64(12.5e-6)
cp[0].CacheWrite1hPrice = testPtrFloat64(20e-6)
group := enabledGroup(PlatformAnthropic)
bs, resolver := newScheduleTestEnv(t, scheduleScenario{channel: cp, groupPlatform: PlatformAnthropic})
sched, err := bs.ResolveContextPricingSchedule(context.Background(), resolver, ContextPricingScheduleInput{Model: "claude-sonnet-4", Group: group, Platform: PlatformAnthropic})
require.NoError(t, err)
display := plazaPricingFromSchedule(&cp[0], sched)
requirePrice(t, testPtrFloat64(20e-6), display.CacheWrite1hPrice, "base 1h")
require.Len(t, display.Intervals, 2)
requirePrice(t, testPtrFloat64(25e-6), display.Intervals[1].CacheWritePrice, "tier 5m")
requirePrice(t, testPtrFloat64(40e-6), display.Intervals[1].CacheWrite1hPrice, "tier 1h")
a := ContextPricingTier{CacheWrite1h: testPtrFloat64(1)}
b := ContextPricingTier{CacheWrite1h: testPtrFloat64(2)}
require.Len(t, mergeEqualContextTiers([]ContextPricingTier{a, b}), 2)
}
// --- 对账:阶梯表推算的费用必须等于真实计费函数 ---
type tokenKind int
@@ -269,6 +269,7 @@ func plazaPricingFromSchedule(raw *ChannelModelPricing, sched *ContextPricingSch
out.InputPrice = first.Input
out.OutputPrice = first.Output
out.CacheWritePrice = first.CacheWrite
out.CacheWrite1hPrice = first.CacheWrite1h
out.CacheReadPrice = first.CacheRead
if len(sched.Tiers) > 1 {
out.Intervals = plazaIntervalsFromTiers(sched.Tiers)
@@ -280,14 +281,15 @@ func plazaIntervalsFromTiers(tiers []ContextPricingTier) []PricingInterval {
intervals := make([]PricingInterval, 0, len(tiers))
for i, t := range tiers {
intervals = append(intervals, PricingInterval{
MinTokens: t.MinTokens,
MaxTokens: t.MaxTokens,
TierLabel: t.Label,
InputPrice: t.Input,
OutputPrice: t.Output,
CacheWritePrice: t.CacheWrite,
CacheReadPrice: t.CacheRead,
SortOrder: i,
MinTokens: t.MinTokens,
MaxTokens: t.MaxTokens,
TierLabel: t.Label,
InputPrice: t.Input,
OutputPrice: t.Output,
CacheWritePrice: t.CacheWrite,
CacheWrite1hPrice: t.CacheWrite1h,
CacheReadPrice: t.CacheRead,
SortOrder: i,
})
}
return intervals
+4
View File
@@ -31,6 +31,10 @@ export interface UserPricingInterval {
cache_write_price: number | null
cache_write_1h_price?: number | null
cache_read_price: number | null
input_multiplier?: number | null
output_multiplier?: number | null
cache_write_multiplier?: number | null
cache_read_multiplier?: number | null
per_request_price: number | null
}
+1 -1
View File
@@ -46,7 +46,7 @@ export interface PlazaTimePricing {
export interface PlazaModel {
name: string
platform: string
/** 实收口径的展示定价:多档时 intervals 为各档绝对单价(已由计费服务折算);均为标准时段价。 */
/** 实收口径的展示定价:档位可提供绝对单价或相对基础价倍率;均为标准时段价。 */
pricing: UserSupportedModelPricing | null
official_pricing: PlazaOfficialPricing | null
/** 仅多档模型返回。 */
@@ -153,7 +153,7 @@
<template v-if="iv.tier_label">{{ iv.tier_label }}</template>
<template v-else>{{ formatRange(iv.min_tokens, iv.max_tokens) }}</template>
</span>
<span>{{ formatInterval(iv, model.pricing.billing_mode) }}</span>
<span>{{ formatInterval(iv, model.pricing) }}</span>
</div>
</div>
</div>
@@ -168,16 +168,15 @@
import { computed, nextTick, onBeforeUnmount, ref } from 'vue'
import { useI18n } from 'vue-i18n'
import PricingRow from './PricingRow.vue'
import { formatScaled } from '@/utils/pricing'
import { formatScaled, resolveIntervalPrices } from '@/utils/pricing'
import {
BILLING_MODE_TOKEN,
BILLING_MODE_PER_REQUEST,
BILLING_MODE_IMAGE,
type BillingMode
BILLING_MODE_IMAGE
} from '@/constants/channel'
// 复用 api/channels.ts 的用户侧最小形态 DTO。
// admin 侧 ChannelModelPricing 字段更多,但结构上是用户 DTO 的超集,admin 视图传入可直接通过结构化子类型检查。
import type { UserPricingInterval, UserSupportedModel } from '@/api/channels'
import type { UserPricingInterval, UserSupportedModel, UserSupportedModelPricing } from '@/api/channels'
import PlatformIcon from '@/components/common/PlatformIcon.vue'
import type { GroupPlatform } from '@/types'
import { platformBadgeClass, platformBorderClass, platformBadgeLightClass } from '@/utils/platformColors'
@@ -246,12 +245,13 @@ function formatRange(min: number, max: number | null): string {
return `(${min}, ${maxLabel}]`
}
function formatInterval(iv: UserPricingInterval, mode: BillingMode): string {
if (mode === BILLING_MODE_PER_REQUEST || mode === BILLING_MODE_IMAGE) {
function formatInterval(iv: UserPricingInterval, pricing: UserSupportedModelPricing): string {
if (pricing.billing_mode === BILLING_MODE_PER_REQUEST || pricing.billing_mode === BILLING_MODE_IMAGE) {
return formatScaled(iv.per_request_price, 1)
}
const input = formatScaled(iv.input_price, perMillionScale)
const output = formatScaled(iv.output_price, perMillionScale)
const resolved = resolveIntervalPrices(iv, pricing)
const input = formatScaled(resolved.input_price, perMillionScale)
const output = formatScaled(resolved.output_price, perMillionScale)
return `${input} / ${output}`
}
@@ -0,0 +1,54 @@
import { nextTick } from 'vue'
import { describe, expect, it, vi } from 'vitest'
import { mount } from '@vue/test-utils'
import SupportedModelChip from '../SupportedModelChip.vue'
vi.mock('vue-i18n', async () => {
const actual = await vi.importActual<typeof import('vue-i18n')>('vue-i18n')
return {
...actual,
useI18n: () => ({ t: (key: string) => key })
}
})
describe('SupportedModelChip', () => {
it('仅配置区间倍率时按基础价展示 token 档位', async () => {
const wrapper = mount(SupportedModelChip, {
attachTo: document.body,
props: {
model: {
name: 'gpt-test',
platform: '',
pricing: {
billing_mode: 'token',
input_price: 10e-6,
output_price: 50e-6,
cache_write_price: null,
cache_read_price: null,
image_input_price: null,
image_output_price: null,
per_request_price: null,
intervals: [{
min_tokens: 272000,
max_tokens: null,
input_price: null,
output_price: null,
cache_write_price: null,
cache_read_price: null,
input_multiplier: 2,
output_multiplier: 1.5,
per_request_price: null
}]
}
},
showPlatform: false
}
})
await wrapper.find('[tabindex="0"]').trigger('mouseenter')
await nextTick()
expect(document.body.textContent).toContain('$20 / $75')
wrapper.unmount()
})
})
@@ -1,6 +1,6 @@
<template>
<div class="plaza-pricing-table overflow-x-auto" :style="accentStyle">
<table class="w-full min-w-[1000px] table-fixed border-collapse text-sm tabular-nums">
<table class="w-full min-w-[1000px] table-auto border-collapse text-sm tabular-nums">
<colgroup>
<col class="w-[25%]" />
<col class="w-[11%]" />
@@ -306,7 +306,7 @@
<script setup lang="ts">
import { computed } from 'vue'
import { useI18n } from 'vue-i18n'
import { formatScaled } from '@/utils/pricing'
import { formatScaled, resolveIntervalPrices } from '@/utils/pricing'
import { platformAccentColor, platformBadgeLightClass, platformLabel } from '@/utils/platformColors'
import {
BILLING_MODE_TOKEN,
@@ -485,7 +485,7 @@ function sortByContext(intervals: UserPricingInterval[]): UserPricingInterval[]
/** token 模式的阶梯定价(内联进输入/输出/缓存列)。 */
function tokenIntervals(m: PlazaModel): UserPricingInterval[] {
return sortByContext(m.pricing?.intervals ?? [])
return sortByContext(m.pricing?.intervals ?? []).map(iv => resolveIntervalPrices(iv, m.pricing!))
}
/** 官方阶梯(后端按目录规则合成,不受分组开关影响)。 */
@@ -495,7 +495,10 @@ function officialIntervals(m: PlazaModel): UserPricingInterval[] {
/** 任一档带缓存价才按档渲染缓存列;否则沿用平价的写入/读取两行。 */
function hasTierCachePricing(intervals: UserPricingInterval[]): boolean {
return intervals.some((iv) => iv.cache_write_price != null || iv.cache_write_1h_price != null || iv.cache_read_price != null)
return intervals.some((iv) =>
iv.cache_write_price != null || iv.cache_write_1h_price != null || iv.cache_read_price != null ||
iv.cache_write_multiplier != null || iv.cache_read_multiplier != null
)
}
/** 档位说明:整单按档计价,或(平台旧规则)仅超出部分按档计价。 */
@@ -294,6 +294,53 @@ describe('PlazaModelPricingTable', () => {
expect(text).toContain('$15.00')
})
it('仅配置区间倍率时按基础价格展示 input/output/cache 各档价格', () => {
const model = tokenModel({
pricing: {
billing_mode: 'token',
input_price: 10e-6,
output_price: 50e-6,
cache_write_price: 12.5e-6,
cache_write_1h_price: 12.5e-6,
cache_read_price: 2e-6,
image_input_price: null,
image_output_price: null,
per_request_price: null,
intervals: [{
min_tokens: 272000,
max_tokens: null,
tier_label: '>272K',
input_price: null,
output_price: null,
cache_write_price: null,
cache_write_1h_price: null,
cache_read_price: null,
input_multiplier: 2,
output_multiplier: 1.5,
cache_write_multiplier: 2,
cache_read_multiplier: 2,
per_request_price: null
}]
},
official_pricing: null
})
const text = mountTable([model], 1).text()
expect(text).toContain('$20.00')
expect(text).toContain('$75.00')
expect(text).toContain('$25.00')
expect(text).toContain('$4.00')
model.pricing!.intervals.unshift({
...model.pricing!.intervals[0], min_tokens: 0, max_tokens: 272000,
tier_label: '<=272K', cache_write_multiplier: null, cache_read_multiplier: null
})
const cells = mountTable([model], 1).findAll('tbody td')
expect(cells[3].text()).toContain('$12.50')
expect(cells[3].text()).toContain('$2.00')
expect(cells[3].text()).toContain('$25.00')
expect(cells[3].text()).toContain('$4.00')
})
it('生图独立倍率开启时,按图价格 × 独立倍率,不乘分组倍率;倍率列展示独立倍率', () => {
const model = tokenModel({
name: 'gpt-image-2',
@@ -0,0 +1,20 @@
import { describe, expect, it } from 'vitest'
import { resolveIntervalPrices } from '../pricing'
const base = { input_price: 10, output_price: 50, cache_write_price: 12.5, cache_write_1h_price: 30, cache_read_price: 2 }
const interval = { min_tokens: 272000, max_tokens: null, input_price: null, output_price: null, cache_write_price: null, cache_write_1h_price: null, cache_read_price: null, per_request_price: null }
describe('resolveIntervalPrices', () => {
it('inherits base prices without overrides', () => {
expect(resolveIntervalPrices(interval, base)).toMatchObject(base)
})
it('applies cache multiplier to both durations', () => {
expect(resolveIntervalPrices({ ...interval, cache_write_multiplier: 2 }, base)).toMatchObject({ cache_write_price: 25, cache_write_1h_price: 60 })
})
it('uses explicit cache write for both durations before multiplier', () => {
expect(resolveIntervalPrices({ ...interval, cache_write_price: 20, cache_write_multiplier: 2 }, base)).toMatchObject({ cache_write_price: 20, cache_write_1h_price: 20 })
})
it('preserves explicit zero and separate 1h override', () => {
expect(resolveIntervalPrices({ ...interval, cache_write_price: 0, cache_write_1h_price: 7, cache_write_multiplier: 2 }, base)).toMatchObject({ cache_write_price: 0, cache_write_1h_price: 7 })
})
})
+18
View File
@@ -22,3 +22,21 @@ export function formatScaled(value: number | null, scale: number, minFractionDig
}
return `$${s}`
}
import type { UserPricingInterval } from '@/api/channels'
type TokenPrices = Pick<UserPricingInterval, 'input_price' | 'output_price' | 'cache_write_price' | 'cache_write_1h_price' | 'cache_read_price'>
export function resolveIntervalPrices(iv: UserPricingInterval, base: TokenPrices): UserPricingInterval {
const price = (absolute: number | null | undefined, multiplier: number | null | undefined, fallback: number | null | undefined) =>
absolute ?? (fallback == null ? null : fallback * (multiplier ?? 1))
return {
...iv,
input_price: price(iv.input_price, iv.input_multiplier, base.input_price),
output_price: price(iv.output_price, iv.output_multiplier, base.output_price),
cache_write_price: price(iv.cache_write_price, iv.cache_write_multiplier, base.cache_write_price),
// Resolver uses an explicit cache-write price for both durations unless 1h is overridden.
cache_write_1h_price: iv.cache_write_1h_price ?? iv.cache_write_price ?? price(null, iv.cache_write_multiplier, base.cache_write_1h_price),
cache_read_price: price(iv.cache_read_price, iv.cache_read_multiplier, base.cache_read_price)
}
}