Flow Maps

业务流与数据流全景

业务闭环 × 数据管道 · 2026-09-17 版 · 变更日志 · 定时任务 · 功能底账
平台/外部 采集与数据层 业务决策 执行/外发(有护栏) 质量与监控

一、业务流(公司经营闭环)

flowchart TB
  subgraph L1["① 数据接入"]
    A1["平台 API 凭据接入
/settings·SP-API·Ads·Noon"] A2["手动报表/文件上传
onno广告·规格书·回流CSV"] end subgraph L2["② 经营分析"] B1["工作台 KPI+看板"] B2["今日实时页"] B3["财务 P&L/回款"] B4["广告六tab·出价建议"] B5["库存补货预警"] B6["选品 ABA/Keepa/雷达"] end subgraph L3["③ 决策"] C1["广告: 规则建议→人工审"] C2["补货: 预警→PO采购"] C3["选品: 决策台人工终裁"] C4["推广: KOL外联/投稿/投放审批"] end subgraph L4["④ 执行(带护栏)"] D1["广告动作执行
幂等键+审计+上限"] D2["PO→确认→供应商邮件→
在途→收货GRN"] D3["Listing 11步闭环
规格书→AI解析/映射/生成→
人工审核→SP-API直推→ASIN回写"] D4["A+内容·模板"] end subgraph L5["⑤ 履约与回款"] E1["物流轨迹14段+运费计算"] E2["结算/回款对账"] end Q["质量与监控回路
四道门+六层断言+功能底账
断更/费用覆盖/漂移报警→自动补抓"] A1-->L2; A2-->L2 L2-->L3; L3-->L4; D2-->E1; D3-->E2; D1-->B4 E1-.->B3; E2-.->B3; B6-.->C3 Q-. 保障全链 .->L2

二、数据流(技术管道)

flowchart LR
  P1["Amazon SP-API
Ads API·Noon API"] P2["Keepa·ABA·Dell大词库
KOL库·飞书文档"] M["mars 统一采集器
12任务·出口IP守卫
/opt/collection"] SRC["mercury/venus 源库
(222)"] ING["SaaS ingest222
04:30全量+对账删除
2h增量(含Noon订单)"] DB[("saas_registry
96表·RLS租户隔离")] API["FastAPI
口径层metrics唯一实现"] WEB["Next.js 页面
KPI/81图墙/表格"] U["用户·多租户"] ALM["监控报警
pipe_stale·fee_coverage
·source_drift"] BF["补抓回路
45d深窗(周日)
报警定向重拉"] P1-->M; M-->SRC; P2-->M SRC-->ING-->DB-->API-->WEB-->U DB-->ALM; ALM-->BF; BF-->SRC classDef ext fill:#eef0fe,stroke:#6366f1,color:#312e81 classDef dat fill:#e6f6f3,stroke:#0e9384,color:#134e4a classDef biz fill:#fdf3e7,stroke:#b45309,color:#7c2d12 classDef qa fill:#f5f0ff,stroke:#7c3aed,color:#4c1d95 class P1,P2 ext; class M,SRC,ING,DB,API,WEB dat; class ALM,BF qa

三、关键口径锚点(数据的"宪法")

一个口径一份实现:业务聚合只在 metrics.py 定义,端点只准调用。
并集铁律:Noon 广告 = pl_monthly(zipforce 月度) ∪ noon_ads_daily(onno 日级);AMZ 广告 = ads_sku_daily ∪ amazon_ads_daily(onno)。
回款:AMZ=amazon_settlement_monthly;Noon=noon_statement(月份归一去重)。
费用:一律走 order_fees 真源;覆盖率不足自动挂脚注。
禁止:显示裸 0 必须带解释;跨平台口径不同显示"—";机器永不 QUALIFIED。

本页由部署会话维护;流程或口径变更须同步更新。