独立用量统计页：分站点 / 分模型 / 分时段的 Token 消耗 (v1.2.0 预备)

- providers 新增 queryStationUsage：Sub2API 走 /usage/dashboard/snapshot-v2
 （老版本回退 trend + models 双接口，密码模式复用令牌缓存并自动续期）；
  New API 走 /api/data/self 数据看板接口，quota 按 500000=$1 换算
- GET /api/usage?range=today|7d|30d：并行查询全部站点，按范围缓存 60 秒，
  单站失败不影响整体（错误逐站展示）
- 新导航「用量统计」：范围/站点筛选，总 Tokens / 实际消耗 / 请求数 / 数据来源统计卡，
  按小时/天的消耗趋势柱状图 + 分模型条形图（超 10 项折叠为其他）+ 模型明细表
- Docker 镜像加 tzdata，compose 提供 TZ=Asia/Shanghai（今日边界按该时区）；
  Watchtower 检查间隔缩短到 60 秒

Author: lettimepassby

Dockerfile

@@ -6,6 +6,9 @@ ENV NODE_ENV=production \
     HOST=0.0.0.0 \
     PORT=8787
 
+# 支持 TZ 环境变量（「今日」统计边界按此时区计算）
+RUN apk add --no-cache tzdata
+
 COPY package.json package-lock.json ./
 RUN npm ci --omit=dev
 

README.md

@@ -9,6 +9,10 @@
 
 - **总览面板**：总剩余余额、**今日总消耗**、日均消耗（估算）、低余额 / 耗尽、查询异常统计；**总余额趋势图**（全站合计、24 小时～30 天切换、悬停查看分站明细）与**日均消耗对比图**；每站余额、今日消耗、用量进度条、状态标签、查询延迟
 - **今日消耗与站点一致**：Sub2API 站点直接读取站点用户仪表盘同款接口（`/api/v1/usage/dashboard/stats` 的 `today_actual_cost`，即今日实际扣费），与站点页面显示的数值完全一致；其他类型按余额历史推算并以 ≈ 标注
+- **用量统计页**：分站点、分模型、分时段的 Token 消耗——今天（按小时）/ 近 7 天 / 近 30 天，
+  含消耗趋势柱状图、分模型条形图与明细表（请求数 / 输入输出 / 总 Tokens / 实际消耗）。
+  数据源：Sub2API 用 `/usage/dashboard/snapshot-v2`（老版本自动回退 trend + models 接口），
+  New API 用 `/api/data/self`（需站点开启数据看板）；sk 密钥模式无用量明细接口
 - **Sub2API 账号密码模式**：只填邮箱 + 密码，面板自动登录换取令牌；令牌过期时自动用 refresh_token 刷新（支持轮换），刷新失败自动用密码重新登录——**全程无需人工干预**
 - **余额预测**：记录余额历史（30 天），线性回归估算日均消耗与预计耗尽时间；点击任意站点查看趋势图（历史折线 + 虚线耗尽投影 + 悬停查看）；识别充值，只按最近一段消耗回归
 - **通知告警**：余额偏低 / 耗尽 / 查询失败 / 恢复正常 / 预计即将耗尽（**阈值可按天或小时设置**），状态迁移触发、自动去重、可配重复提醒间隔；支持 10 种渠道：

deploy/docker-compose.yml

@@ -9,6 +9,8 @@ services:
       - "8787:8787"
     environment:
       - HOST=0.0.0.0
+      # 「今日消耗 / 用量统计」的日期边界按此时区计算
+      - TZ=Asia/Shanghai
     volumes:
       - ./data:/app/data
 
@@ -24,5 +26,5 @@ services:
     environment:
       # 新版 Docker 守护进程要求 API >= 1.40，watchtower 默认协商值过老
       - DOCKER_API_VERSION=1.44
-    # 每 5 分钟检查一次 relay-monitor 的新镜像，更新后清理旧镜像
-    command: --cleanup --interval 300 relay-monitor
+    # 每分钟检查一次 relay-monitor 的新镜像，更新后清理旧镜像
+    command: --cleanup --interval 60 relay-monitor

lib/providers.js

@@ -282,6 +282,151 @@ async function querySub2Api(station) {
   return { ...parseSub2ApiMe(data), todayUsed, todayRequests, todayTokens, tokensChanged };
 }
 
+// ---- 用量明细（分模型 / 分时间）--------------------------------------------
+
+function localDateStr(ms) {
+  const d = new Date(ms);
+  return `${d.getFullYear()}-${String(d.getMonth() + 1).padStart(2, "0")}-${String(d.getDate()).padStart(2, "0")}`;
+}
+
+// 尝试把提供商返回的时间标签解析成时间戳；解析失败返回 null，前端按原始标签展示
+function parseDateLabel(s) {
+  if (!s) return null;
+  let t = Date.parse(s);
+  if (Number.isNaN(t)) t = Date.parse(String(s).replace(" ", "T"));
+  return Number.isNaN(t) ? null : t;
+}
+
+// 取可用的 Sub2API bearer；密码模式沿用 s2Tokens 缓存并自动登录/刷新
+async function sub2apiBearer(station, base, force = false) {
+  const passwordMode = station.type === "sub2api-password" || station.authMode === "password";
+  if (!passwordMode) {
+    const t = String(station.accessToken || station.apiKey || "").trim();
+    if (!t) throw new Error("缺少登录令牌 (Sub2API JWT)");
+    return t;
+  }
+  const tokens = (station.s2Tokens ||= {});
+  if (!force && tokens.accessToken && tokens.expiresAt &&
+      tokens.expiresAt - Date.now() > TOKEN_REFRESH_BUFFER_MS) {
+    return tokens.accessToken;
+  }
+  if (force) tokens.accessToken = "";
+  if (!(await sub2apiRefresh(base, tokens))) await sub2apiLogin(base, station, tokens);
+  return tokens.accessToken;
+}
+
+function normSub2Models(models) {
+  return (models || []).map((m) => ({
+    model: m.model || "unknown",
+    tokens: num(m.total_tokens),
+    cost: num(m.actual_cost ?? m.cost),
+    requests: num(m.requests),
+    inputTokens: num(m.input_tokens),
+    outputTokens: num(m.output_tokens),
+  })).sort((a, b) => b.tokens - a.tokens);
+}
+
+function normSub2Trend(trend) {
+  return (trend || []).map((p) => ({
+    t: parseDateLabel(p.date),
+    label: String(p.date ?? ""),
+    tokens: num(p.total_tokens),
+    cost: num(p.actual_cost ?? p.cost),
+    requests: num(p.requests),
+  }));
+}
+
+async function sub2apiUsage(station, { startMs, endMs, granularity, tz }) {
+  const base = trimBase(station.baseUrl);
+  if (!base) throw new Error("缺少站点地址");
+  const params = {
+    start_date: localDateStr(startMs),
+    end_date: localDateStr(endMs),
+    granularity,
+    timezone: tz,
+  };
+  const get = async (path, extra) => {
+    let bearer = await sub2apiBearer(station, base);
+    let r = await request(`${base}${path}?${new URLSearchParams({ ...params, ...extra })}`, {
+      headers: { Authorization: `Bearer ${bearer}` },
+    });
+    if (r.status === 401 && station.type === "sub2api-password") {
+      bearer = await sub2apiBearer(station, base, true);
+      r = await request(`${base}${path}?${new URLSearchParams({ ...params, ...extra })}`, {
+        headers: { Authorization: `Bearer ${bearer}` },
+      });
+    }
+    return r;
+  };
+
+  // 首选 snapshot-v2 一次拿全；老版本站点回退到 trend + models 两个接口
+  const snap = await get("/api/v1/usage/dashboard/snapshot-v2", {
+    include_trend: "true", include_model_stats: "true",
+  });
+  if (snap.status < 300 && snap.body?.code === 0 && snap.body.data) {
+    const d = snap.body.data;
+    return { models: normSub2Models(d.models), trend: normSub2Trend(d.trend) };
+  }
+  const [tr, mo] = await Promise.all([
+    get("/api/v1/usage/dashboard/trend"),
+    get("/api/v1/usage/dashboard/models"),
+  ]);
+  if (tr.status >= 300 && mo.status >= 300) throw new Error(httpErrorMessage(tr));
+  return {
+    models: mo.status < 300 && mo.body?.code === 0 ? normSub2Models(mo.body.data?.models) : [],
+    trend: tr.status < 300 && tr.body?.code === 0 ? normSub2Trend(tr.body.data?.trend) : [],
+  };
+}
+
+async function newApiUsage(station, { startMs, endMs }) {
+  const base = trimBase(station.baseUrl);
+  const token = String(station.accessToken || "").trim();
+  if (!base || !token) throw new Error("缺少站点地址或访问令牌");
+  const headers = { Authorization: token };
+  const userId = String(station.userId || "").trim();
+  if (userId) headers["New-Api-User"] = userId;
+
+  const qs = `start_timestamp=${Math.floor(startMs / 1000)}&end_timestamp=${Math.ceil(endMs / 1000)}`;
+  const r = await request(`${base}/api/data/self?${qs}`, { headers });
+  if (r.status >= 300) throw new Error(httpErrorMessage(r));
+  if (r.body?.success === false) throw new Error(r.body?.message || "站点未开启数据看板");
+  const rows = Array.isArray(r.body?.data) ? r.body.data : null;
+  if (!rows) throw new Error("站点未开启数据看板（DataExportEnabled）");
+
+  const models = new Map(), trend = new Map();
+  for (const row of rows) {
+    const tokens = num(row.token_used);
+    const cost = num(row.quota) / QUOTA_PER_UNIT;
+    const reqs = num(row.count);
+    const name = row.model_name || "unknown";
+    const m = models.get(name) || { model: name, tokens: 0, cost: 0, requests: 0, inputTokens: null, outputTokens: null };
+    m.tokens += tokens; m.cost += cost; m.requests += reqs;
+    models.set(name, m);
+    const t = num(row.created_at) * 1000;
+    const tr = trend.get(t) || { t, label: "", tokens: 0, cost: 0, requests: 0 };
+    tr.tokens += tokens; tr.cost += cost; tr.requests += reqs;
+    trend.set(t, tr);
+  }
+  return {
+    models: [...models.values()].sort((a, b) => b.tokens - a.tokens),
+    trend: [...trend.values()].sort((a, b) => a.t - b.t),
+  };
+}
+
+/**
+ * 查询站点的用量明细（分模型 + 分时间），返回 {models, trend}。
+ * 与余额查询不同，出错直接 throw，由调用方汇总每个站点的错误。
+ */
+export async function queryStationUsage(station, opts) {
+  switch (station.type) {
+    case "newapi": return newApiUsage(station, opts);
+    case "newapi-key": throw new Error("sk 密钥模式没有用量明细接口");
+    case "sub2api":
+    case "sub2api-password": return sub2apiUsage(station, opts);
+    default: throw new Error(`未知的中转站类型：${station.type}`);
+  }
+}
+
 const HANDLERS = {
   newapi: queryNewApi,
   "newapi-key": queryNewApiKey,