消息推送

## 供应商熔断告警

> 供应商 **Anthropic 官方** (ID: 1) 已触发熔断保护

**详细信息**
失败次数: 5 次
预计恢复: 2025-01-15 14:30:00
最后错误: `rate_limit_exceeded: You have exceeded your rate limit`

---
2025-01-15 14:00:00 · 熔断器将在预计时间后自动恢复

## 今日用户消费排行榜

> 统计日期: **2025-01-14**

**排名情况**

🥇 **张三** (ID: 1)
消费 $12.3456 · 请求 1,234 次 · Token 2.45M

🥈 **李四** (ID: 2)
消费 $8.7654 · 请求 987 次 · Token 1.87M

🥉 **王五** (ID: 3)
消费 $5.4321 · 请求 654 次 · Token 1.23M

---
**今日总览**
总请求 5,678 次 · 总消费 $45.6789

2025-01-15 09:00:00

## 成本预警提醒

> 用户 **张三** 的消费已达到预警阈值

**消费详情**
当前消费: $8.5000
配额限制: $10.0000
使用比例: **85.0%** 🟡
剩余额度: $1.5000
统计周期: 本周

---
2025-01-15 10:30:00 · 请注意控制消费

POST <webhook_url>
Content-Type: application/json

{
  "msgtype": "markdown",
  "markdown": {
    "content": "消息内容（Markdown 格式）"
  }
}

https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx

// worker.js - Telegram 适配器
export default {
  async fetch(request, env) {
    try {
      // 验证请求方法
      if (request.method !== 'POST') {
        return jsonResponse({ errcode: 405, errmsg: 'Method not allowed' }, 200);
      }

      // 从 URL 参数验证密钥
      const url = new URL(request.url);
      const secret = url.searchParams.get('secret');

      if (secret !== env.WEBHOOK_SECRET) {
        return jsonResponse({ errcode: 401, errmsg: 'Unauthorized' }, 200);
      }

      // 解析请求体（企业微信格式）
      const body = await request.json();
      const content = body.markdown?.content || body.text;

      if (!content) {
        return jsonResponse({ errcode: 400, errmsg: 'Missing content' }, 200);
      }

      // 发送到 Telegram
      const telegramResponse = await fetch(
        `https://api.telegram.org/bot${env.BOT_TOKEN}/sendMessage`,
        {
          method: 'POST',
          headers: { 'Content-Type': 'application/json' },
          body: JSON.stringify({
            chat_id: env.CHAT_ID,
            text: content,
            parse_mode: 'Markdown',
            disable_web_page_preview: true
          })
        }
      );

      const result = await telegramResponse.json();

      if (result.ok) {
        // ✅ Telegram 成功 - 返回成功响应（不会重试）
        console.log('✅ Message sent successfully');
        return jsonResponse({ errcode: 0, errmsg: 'ok' }, 200);
      } else {
        // ❌ Telegram 失败 - 返回错误响应（触发 CCH 重试）
        console.error('❌ Telegram API error:', result.description);
        return jsonResponse({
          errcode: result.error_code || 1,
          errmsg: `Telegram error: ${result.description || 'Unknown error'}`
        }, 200);
      }

    } catch (error) {
      // ❌ Worker 异常 - 返回错误响应（触发 CCH 重试）
      console.error('❌ Worker error:', error);
      return jsonResponse({
        errcode: 500,
        errmsg: error.message || 'Internal error'
      }, 200);
    }
  }
};

// 辅助函数：返回 JSON 响应
function jsonResponse(data, status = 200) {
  return new Response(JSON.stringify(data), {
    status: status,
    headers: { 'Content-Type': 'application/json' }
  });
}

https://your-worker.your-subdomain.workers.dev?secret=your_webhook_secret

// 通用适配器模板
export default {
  async fetch(request, env) {
    if (request.method !== 'POST') {
      return jsonResponse({ errcode: 405, errmsg: 'Method not allowed' });
    }

    try {
      // 1. 验证请求（可选但推荐）
      const url = new URL(request.url);
      if (url.searchParams.get('secret') !== env.SECRET) {
        return jsonResponse({ errcode: 401, errmsg: 'Unauthorized' });
      }

      // 2. 解析 CCH 发送的消息
      const body = await request.json();
      const content = body.markdown?.content || body.text;

      // 3. 转换为目标平台格式并发送
      // ... 根据目标平台 API 实现 ...

      // 4. 返回结果
      return jsonResponse({ errcode: 0, errmsg: 'ok' });

    } catch (error) {
      return jsonResponse({ errcode: 500, errmsg: error.message });
    }
  }
};

function jsonResponse(data) {
  return new Response(JSON.stringify(data), {
    headers: { 'Content-Type': 'application/json' }
  });
}

**测试消息**

企业微信机器人连接成功！