写在前面#

1
CREATE TABLE ai_models (
2
    id INT PRIMARY KEY AUTO_INCREMENT,
3
    name VARCHAR(50) NOT NULL COMMENT '模型名称',
4
    provider VARCHAR(30) NOT NULL COMMENT '供应商: openai/deepseek/qwen/glm',
5
    model_name VARCHAR(50) NOT NULL COMMENT 'API 模型标识',
6
    base_url VARCHAR(200) NOT NULL COMMENT 'API 地址',
7
    api_key TEXT NOT NULL COMMENT 'API Key（加密存储）',
8
    rpm_limit INT DEFAULT 500 COMMENT 'RPM 限制',
9
    tpm_limit INT DEFAULT 100000 COMMENT 'TPM 限制',
10
    input_price DECIMAL(10,6) COMMENT '输入价格 $/1K tokens',
11
    output_price DECIMAL(10,6) COMMENT '输出价格 $/1K tokens',
12
    status TINYINT DEFAULT 1,
13
    created_at DATETIME
14
);

1
class AiChatService
2
{
3
    public function chat(array $messages, AiModels $model): ChatResult
4
    {
5
        $client = new Client([
6
            'base_uri' => $model->base_url,
7
            'timeout' => 120,
8
        ]);
9

10
        // 所有供应商都兼容 OpenAI 格式
11
        $response = $client->post('/v1/chat/completions', [
12
            'headers' => [
13
                'Authorization' => 'Bearer ' . decrypt($model->api_key),
14
                'Content-Type' => 'application/json',
15
            ],
16
            'json' => [
17
                'model' => $model->model_name,
18
                'messages' => $messages,
19
                'temperature' => $model->temperature ?? 0.7,
20
                'max_tokens' => $model->max_tokens ?? 4096,
21
            ],
22
        ]);
23

24
        return ChatResult::fromResponse(json_decode($response->getBody(), true));
25
    }
26
}

1
public function checkBudget(int $keyId): bool
2
{
3
    $key = $this->getKey($keyId);
4
    $todayUsage = $this->getTodayUsage($keyId);
5

6
    // 计算今日花费
7
    $cost = ($todayUsage['input_tokens'] / 1000) * $key->input_price
8
          + ($todayUsage['output_tokens'] / 1000) * $key->output_price;
9

10
    if ($cost >= $key->daily_budget) {
11
        Log::warning("Key {$keyId} 已达日预算上限: \${$cost}");
12
        return false;
13
    }
14

15
    // 80% 预警
16
    if ($cost >= $key->daily_budget * 0.8) {
17
        $this->sendBudgetAlert($keyId, $cost, $key->daily_budget);
18
    }
19

20
    return true;
21
}

1
┌─────────────────────────────────────────────────┐
2
│  AI 调用监控面板                                  │
3
├─────────────────────────────────────────────────┤
4
│  今日调用次数：347                                │
5
│  成功率：98.6%                                   │
6
│  平均响应时间：3.2s                               │
7
│  今日 Token 消耗：1,247,832                      │
8
│  今日费用：$4.73                                  │
9
├─────────────────────────────────────────────────┤
10
│  按场景统计：                                     │
11
│  chat:          218 次  $2.89  avg 2.8s          │
12
│  goods_script:  129 次  $1.84  avg 3.9s          │
13
├─────────────────────────────────────────────────┤
14
│  按模型统计：                                     │
15
│  deepseek-v4:   201 次  $0.42  avg 2.1s          │
16
│  gpt-5.3:        89 次  $3.15  avg 4.7s          │
17
│  qwen-3.5:       57 次  $1.16  avg 3.4s          │
18
└─────────────────────────────────────────────────┘

1
class AiRetryHandler
2
{
3
    private const RETRYABLE_CODES = [429, 500, 502, 503, 504];
4
    private const MAX_RETRIES = 3;
5

6
    public function callWithRetry(callable $fn): mixed
7
    {
8
        $lastException = null;
9

10
        for ($attempt = 0; $attempt <= self::MAX_RETRIES; $attempt++) {
11
            try {
12
                return $fn();
13
            } catch (AiApiException $e) {
14
                $lastException = $e;
15

16
                if (!in_array($e->getCode(), self::RETRYABLE_CODES)) {
17
                    throw $e; // 不可重试的错误直接抛出
18
                }
19

20
                if ($attempt === self::MAX_RETRIES) {
21
                    throw $e; // 重试次数用完
22
                }
23

24
                // 指数退避：1s, 2s, 4s
25
                $delay = pow(2, $attempt);
26

27
                // 429 特殊处理：读取 Retry-After 头
28
                if ($e->getCode() === 429 && $e->retryAfter) {
29
                    $delay = max($delay, $e->retryAfter);
30
                }
31

32
                Log::info("AI 调用重试 #{$attempt}, 等待 {$delay}s", [
33
                    'error' => $e->getMessage(),
34
                ]);
35

36
                sleep($delay);
37
            }
38
        }
39

40
        throw $lastException;
41
    }
42
}

1
public function chatWithFallback(array $messages, string $scene): ChatResult
2
{
3
    // 获取场景对应的智能体（可能有多个，按优先级排序）
4
    $agents = $this->dep(AiAgentsDep::class)->getActiveByScene($scene);
5

6
    foreach ($agents as $agent) {
7
        $model = AiModels::find($agent->model_id);
8

9
        try {
10
            return $this->retryHandler->callWithRetry(
11
                fn() => $this->aiChatService->chat($messages, $model)
12
            );
13
        } catch (AiApiException $e) {
14
            Log::warning("模型 {$model->name} 不可用，尝试降级", [
15
                'error' => $e->getMessage(),
16
            ]);
17
            continue; // 尝试下一个模型
18
        }
19
    }
20

21
    throw new BusinessException('所有 AI 模型均不可用，请稍后再试');
22
}