fix: correct profit cost aggregation

Author: lettimepassby

README.md

@@ -17,7 +17,7 @@
 - **余额预测**：余额历史（30 天）+ 实时速率分层估计（近 3 小时优先）预计耗尽时间；点击站点查看趋势图（历史折线 + 耗尽投影）
 - **通知告警**：余额偏低 / 耗尽 / 查询失败（**可配连续失败阈值与失败快速重试**）/ 恢复正常 / 预计即将耗尽（阈值可按天或小时），状态迁移触发、自动去重、可配重复提醒；可将单站标记为**不再续费**，低余额仅提醒一次；支持 10 种渠道：Telegram、钉钉（加签）、企业微信、飞书（签名）、Bark、ntfy、Server酱、Resend 邮件、SMTP 邮件（零依赖客户端）、自定义 Webhook，每渠道可单独测试
 - **我的站点（下游分析）**：自营 new-api 站点的分时段 / 分模型 / **分用户**用量与消费，**未来 7 天消费预测**（组合模型 + conformal 区间，历史满两周自动启用周末模式识别）
-- **利润分析**：下游收入（普通用户消费 × 售价汇率）− 上游期内成本（用量 × 充值汇率；固定成本按天摊销）；**管理员 / root 转售 Key 可标记计入收入**；未匹配渠道单独列出
+- **利润分析**：下游收入（普通用户消费 × 售价汇率）− 上游期内成本（用量 × 充值汇率；固定成本按天摊销）；用量接口返回空数据但余额确有下降时自动回退历史推算；支持成本渠道匹配别名（容器域名 / 内网 IP）和 **Sub2API 成本汇总站模式**（New API 只接一个负载均衡入口时采用其 `actual_cost`，后层上游不重复计费）；**管理员 / root 转售 Key 可标记计入收入**；未匹配渠道与缺省汇率会明确标记利润不完整
 - **每日日报**：每天定时（默认北京时间，可用 `REPORT_TIME_ZONE` 覆盖）汇总昨日经营——消费环比、收入/成本/利润、Top 模型与用户、上游余额与耗尽预警、未来 7 天预测——推送到通知渠道（邮件全文，IM 截断）；支持预览与立即发送
 - **人民币折算**：每站可配充值汇率（站点 $1 折合 ¥ 多少）；金额主显人民币，站点原始余额次要展示；余额告警阈值仍按站点余额判断
 - **PWA**：可添加到手机主屏幕独立运行（品牌图标 + 离线壳缓存；静态资源网络优先，API 不缓存）

app/(dashboard)/my/page.tsx

@@ -417,6 +417,15 @@ export default function MyStationPage() {
       ) : null}
       {p && !p.error ? (
         <>
+          {p.warnings?.length ? (
+            <Alert
+              style={{ marginTop: 14 }}
+              type={p.complete ? "info" : "warning"}
+              showIcon
+              message={!p.complete ? "利润数据尚不完整" : p.estimated ? "成本中包含估算值" : "利润口径提示"}
+              description={p.warnings.join("；")}
+            />
+          ) : null}
           <SectionHead
             title="利润分析"
             sub={`收入 = 普通用户消费 × 售价汇率（不含管理员/root，除非该 Key 已标为转售）· 成本按各上游口径（窗口 ${p.windowDays} 天）`}
@@ -560,7 +569,7 @@ export default function MyStationPage() {
                     name={
                       <>
                         {c.name} <Tag>{MODE_LABEL[c.mode] || c.mode}</Tag>
-                        {c.note ? <Tag color={c.note === "已到期" ? "warning" : undefined}>{c.note}</Tag> : null}
+                        {c.note ? <Tag color={c.mode === "history" || c.note === "已到期" ? "warning" : undefined}>{c.note}</Tag> : null}
                       </>
                     }
                     meta={`渠道：${c.channels.join("、")}`}

app/(dashboard)/stations/page.tsx

@@ -252,6 +252,7 @@ function StationRow(props: {
         <div style={{ fontWeight: 600 }}>
           {s.name}
           {s.isOwn ? <Tag color="blue" style={{ marginInlineStart: 6 }}>我的站</Tag> : null}
+          {s.costGateway ? <Tag color="cyan" style={{ marginInlineStart: 6 }}>成本汇总站</Tag> : null}
           {s.noRenewal ? <Tag color="orange" style={{ marginInlineStart: 6 }}>不再续费</Tag> : null}
           {s.demo ? <Tag style={{ marginInlineStart: 6 }}>演示</Tag> : null}
           {statusPill(st)}
@@ -394,6 +395,8 @@ export default function StationsPage() {
       password: "",
       lowBalanceUsd: station?.lowBalanceUsd ?? "",
       cnyPerUsd: station?.cnyPerUsd ?? "",
+      costAliasesText: Array.isArray(station?.costAliases) ? station.costAliases.join("\n") : "",
+      costGateway: !!station?.costGateway,
       isOwn: !!station?.isOwn,
       noRenewal: !!station?.noRenewal,
     });
@@ -417,6 +420,11 @@ export default function StationsPage() {
       email: String(v.email || "").trim(),
       lowBalanceUsd: String(v.lowBalanceUsd ?? "").trim(),
       cnyPerUsd: String(v.cnyPerUsd ?? "").trim(),
+      costAliases: String(v.costAliasesText || "")
+        .split(/[\n,]/)
+        .map((x) => x.trim())
+        .filter(Boolean),
+      costGateway: String(v.type || "").startsWith("sub2api") && !!v.costGateway,
       // 金额/天数保持字符串提交（同 v1 collectPurchases），全空行剔除
       fixedPurchases: purchases
         .map((p) => ({
@@ -579,6 +587,26 @@ export default function StationsPage() {
               <Input placeholder="如 2 表示 $1 = ¥2，留空按 1:1" />
             </Form.Item>
           )}
+          {String(formType || "").startsWith("sub2api") && (
+            <Form.Item
+              name="costGateway"
+              valuePropName="checked"
+              style={{ marginBottom: 12 }}
+              extra="适用于 New API 只连接这一个 Sub2API 负载均衡入口的架构。利润只采用本站 actual_cost 作为全部用量成本，其后的监控上游不会重复计入。全局只能设置一个。"
+            >
+              <Checkbox>这是成本汇总站</Checkbox>
+            </Form.Item>
+          )}
+          {!isFixed && (
+            <Form.Item
+              label="成本渠道匹配别名"
+              name="costAliasesText"
+              style={{ marginBottom: 12 }}
+              extra="当自有站渠道使用容器域名、内网 IP 或代理地址时，每行填写一个渠道地址；利润计算会将它们归属到此上游。"
+            >
+              <Input.TextArea autoSize={{ minRows: 2, maxRows: 4 }} placeholder={"例如：sub2api-internal\n10.0.0.8:8080"} />
+            </Form.Item>
+          )}
           {!isFixed && (
             <Form.Item
               name="noRenewal"

app/api/stations/[id]/route.js

@@ -10,12 +10,18 @@ export const PUT = withAuth(async (request, rt, params) => {
     return json({ error: "无效的中转站类型" }, 400);
   const s = await rt.store.update(params.id, b);
   if (!s) return json({ error: "未找到该中转站" }, 404);
+  rt._ownCache?.clear();
+  delete rt._ownChannelsCache;
+  delete rt._ownUsersCache;
   refreshStation(rt, s).catch(() => {});
   return json({ station: redact(rt, s) });
 });
 
 export const DELETE = withAuth(async (request, rt, params) => {
   const ok = await rt.store.remove(params.id);
+  rt._ownCache?.clear();
+  delete rt._ownChannelsCache;
+  delete rt._ownUsersCache;
   rt.history.remove(params.id);
   return json({ ok });
 });

app/api/stations/route.js

@@ -14,6 +14,9 @@ export const POST = withAuth(async (request, rt) => {
     return json({ error: "无效的中转站类型" }, 400);
   if (!b.baseUrl && b.type !== "fixed") return json({ error: "请填写站点地址" }, 400);
   const s = await rt.store.add(b);
+  rt._ownCache?.clear();
+  delete rt._ownChannelsCache;
+  delete rt._ownUsersCache;
   refreshStation(rt, s).catch(() => {});
   return json({ station: redact(rt, s) });
 });

db/store.js

@@ -22,6 +22,12 @@ function numOrNull(v) {
   return Number.isFinite(n) ? n : null;
 }
 
+// 成本渠道匹配别名：用于渠道配置采用容器域名/IP、与监控地址不一致的场景。
+function sanitizeCostAliases(input) {
+  const rows = Array.isArray(input) ? input : String(input || "").split(/[\n,]/);
+  return [...new Set(rows.map((v) => String(v || "").trim()).filter(Boolean))];
+}
+
 // 固定成本付费记录：[{amount(¥), days, startDate|null}]，无效行直接丢弃
 function sanitizePurchases(input) {
   if (!Array.isArray(input)) return null;
@@ -92,6 +98,8 @@ export class Store {
     for (const s of this.data.stations) {
       // v2.1：旧站点没有续费计划字段，默认保持原有的正常重复提醒策略。
       s.noRenewal = !!s.noRenewal;
+      s.costAliases = sanitizeCostAliases(s.costAliases);
+      s.costGateway = ["sub2api", "sub2api-password"].includes(s.type) && !!s.costGateway;
       if (!Array.isArray(s.fixedPurchases)) {
         s.fixedPurchases = [];
         const amount = s.fixedCostCny ?? s.fixedMonthlyCny;
@@ -280,6 +288,10 @@ export class Store {
       lowBalanceUsd: numOrNull(input.lowBalanceUsd),
       // 充值折算汇率：站点 $1 折合人民币（¥）；null 按 1:1 展示
       cnyPerUsd: numOrNull(input.cnyPerUsd),
+      // 自有站渠道可能使用容器域名、内网 IP 等地址；别名参与利润成本归属匹配。
+      costAliases: sanitizeCostAliases(input.costAliases),
+      // 成本汇总站：其 actual_cost 已覆盖后面的负载均衡上游，利润中只计这一层。
+      costGateway: ["sub2api", "sub2api-password"].includes(input.type) && !!input.costGateway,
       // 我自己的中转站：启用「我的站点」下游用量分析（需管理员令牌）
       isOwn: !!input.isOwn,
       // 不再续费：余额低于阈值时仅提醒一次，不再发送耗尽/ETA/持续余额提醒
@@ -294,6 +306,9 @@ export class Store {
       alertState: null, // 告警去重状态（含不再续费站点的一次性低余额提醒时间）
       balance: null, // 最近一次查询结果
     };
+    if (station.costGateway) {
+      for (const s of this.data.stations) s.costGateway = false;
+    }
     this.data.stations.push(station);
     await this.save();
     return station;
@@ -311,6 +326,13 @@ export class Store {
     if ("password" in patch) s.password = String(patch.password ?? "");
     if ("lowBalanceUsd" in patch) s.lowBalanceUsd = numOrNull(patch.lowBalanceUsd);
     if ("cnyPerUsd" in patch) s.cnyPerUsd = numOrNull(patch.cnyPerUsd);
+    if ("costAliases" in patch) s.costAliases = sanitizeCostAliases(patch.costAliases);
+    if ("costGateway" in patch || !["sub2api", "sub2api-password"].includes(s.type)) {
+      s.costGateway = ["sub2api", "sub2api-password"].includes(s.type) && !!patch.costGateway;
+      if (s.costGateway) {
+        for (const other of this.data.stations) if (other.id !== s.id) other.costGateway = false;
+      }
+    }
     if ("isOwn" in patch) s.isOwn = !!patch.isOwn;
     if ("noRenewal" in patch || s.type === "fixed") {
       const noRenewal = s.type !== "fixed" && !!patch.noRenewal;

db/store.test.js

@@ -49,3 +49,29 @@ test("重新标记不再续费会重置单次提醒资格", async () => {
   await store.update("station-1", { type: "fixed", noRenewal: true });
   assert.equal(store.get("station-1").noRenewal, false);
 });
+
+test("成本渠道匹配别名会清理空值并去重", async () => {
+  const store = new Store(fakePool());
+  const added = await store.add({
+    name: "上游",
+    type: "newapi",
+    baseUrl: "https://public.example.com",
+    costAliases: [" internal-host ", "", "internal-host", "10.0.0.8:8080"],
+  });
+  assert.deepEqual(added.costAliases, ["internal-host", "10.0.0.8:8080"]);
+
+  await store.update(added.id, { costAliases: "alias-a, alias-b\nalias-a" });
+  assert.deepEqual(store.get(added.id).costAliases, ["alias-a", "alias-b"]);
+});
+
+test("全局只保留一个 Sub2API 成本汇总站", async () => {
+  const store = new Store(fakePool());
+  const first = await store.add({ name: "网关 A", type: "sub2api", baseUrl: "https://a.example.com", costGateway: true });
+  const second = await store.add({ name: "网关 B", type: "sub2api-password", baseUrl: "https://b.example.com", costGateway: true });
+  assert.equal(store.get(first.id).costGateway, false);
+  assert.equal(store.get(second.id).costGateway, true);
+
+  await store.update(first.id, { costGateway: true });
+  assert.equal(store.get(first.id).costGateway, true);
+  assert.equal(store.get(second.id).costGateway, false);
+});

package.json

@@ -9,7 +9,7 @@
     "dev": "next dev",
     "build": "next build",
     "start": "next start",
-    "test": "node --test lib/alerts.test.js db/store.test.js",
+    "test": "node --test lib/alerts.test.js db/store.test.js server/own-helpers.test.js",
     "db:migrate": "node db/migrate.js"
   },
   "dependencies": {