CREATE TABLE invite_codes (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    code TEXT UNIQUE NOT NULL,        -- 8位随机码
    created_by INTEGER,               -- admin user_id
    max_uses INTEGER DEFAULT 1,       -- 默认一码一用
    used_count INTEGER DEFAULT 0,
    status TEXT DEFAULT 'active',     -- active/disabled/exhausted
    expires_at TEXT,                  -- 可选过期时间
    created_at TEXT DEFAULT (datetime('now'))
);

CREATE TABLE invite_usage (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    code_id INTEGER NOT NULL,
    user_id INTEGER NOT NULL,
    used_at TEXT DEFAULT (datetime('now')),
    FOREIGN KEY (code_id) REFERENCES invite_codes(id),
    FOREIGN KEY (user_id) REFERENCES users(id)
);

# 生成邀请码
python3 admin_cli.py gen-invite --count 5

# 查看邀请码状态
python3 admin_cli.py list-invites

# 禁用邀请码
python3 admin_cli.py disable-invite CODE123

# 查看用户
python3 admin_cli.py list-users

# 封禁用户
python3 admin_cli.py ban-user 42

-- 自动建表（每月1张）
CREATE TABLE IF NOT EXISTS agg_trades_202602 (
    agg_id INTEGER PRIMARY KEY,        -- Binance aggTradeId（天然唯一）
    symbol TEXT NOT NULL,               -- BTCUSDT / ETHUSDT
    price REAL NOT NULL,
    qty REAL NOT NULL,
    first_trade_id INTEGER,
    last_trade_id INTEGER,
    time_ms INTEGER NOT NULL,           -- 成交时间(毫秒)
    is_buyer_maker INTEGER NOT NULL     -- 0=主动买, 1=主动卖
);

CREATE INDEX IF NOT EXISTS idx_agg_trades_202602_time
    ON agg_trades_202602(symbol, time_ms);

CREATE TABLE agg_trades_meta (
    symbol TEXT PRIMARY KEY,
    last_agg_id INTEGER NOT NULL,       -- 最后写入的agg_id
    last_time_ms INTEGER NOT NULL,      -- 最后写入的时间
    updated_at TEXT DEFAULT (datetime('now'))
);

┌─────────────────────┐
│  WebSocket主链路     │ ← wss://fstream.binance.com/ws/btcusdt@aggTrade
│  (实时推送)          │ ← wss://fstream.binance.com/ws/ethusdt@aggTrade
└──────┬──────────────┘
       │ 攒200条 or 1秒
       ▼
┌─────────────────────┐
│  批量写入器          │ → INSERT OR IGNORE INTO agg_trades_YYYYMM
│  (去重+分表路由)     │ → UPDATE agg_trades_meta
└──────┬──────────────┘
       │
┌──────┴──────────────┐
│  补洞巡检（每分钟）  │ → 检查agg_id连续性
│                     │ → REST /fapi/v1/aggTrades?fromId=X 补缺
└─────────────────────┘

┌────────────────────────────────────────────┐
│ [BTC▼] [时间范围选择] [1m 5m 15m]          │ ← 全局控制栏
├────────────────────────────────────────────┤
│                                            │
│           K线图 (lightweight-charts)        │ ← 可框选时间段
│                                            │
├────────────────────────────────────────────┤
│                                            │
│     成交流热图 (ECharts heatmap)            │ ← 时间×价格×密度
│     绿=主动买  红=主动卖                     │
│                                            │
├──────────────────────┬─────────────────────┤
│ 时段摘要              │ 标注面板             │
│ 总成交量: 1,234 BTC  │ [上涨前兆] [下跌前兆] │
│ 买/卖比: 62%/38%     │ [震荡] [放量突破]     │
│ Delta: +427 BTC      │                     │
│ 最大单笔: 12.5 BTC   │ [保存标注]           │
│ 成交速率: 89笔/秒    │ [AI分析] [导出]      │
└──────────────────────┴─────────────────────┘

interface TimeRange {
  startMs: number;
  endMs: number;
  source: 'kline' | 'heatmap' | 'control' | 'manual';
}

CREATE TABLE annotations (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    user_id INTEGER NOT NULL,
    symbol TEXT NOT NULL,
    start_ms INTEGER NOT NULL,
    end_ms INTEGER NOT NULL,
    label TEXT NOT NULL,               -- 上涨前兆/下跌前兆/震荡/突破/假突破/洗盘...
    note TEXT,                         -- 用户备注
    confidence INTEGER DEFAULT 3,      -- 1-5 置信度
    version INTEGER DEFAULT 1,         -- 版本号（修改时递增）
    features_json TEXT,                -- 当时的特征快照（delta/速率/大单等）
    created_at TEXT DEFAULT (datetime('now')),
    updated_at TEXT,
    FOREIGN KEY (user_id) REFERENCES users(id)
);

原始成交数据（该时段）
    ↓ Python预处理（后端）
结构化摘要（~500字）：
  - 成交速率变化曲线（文字描述）
  - Delta累计走势
  - 大单列表（>平均5倍）
  - 价格关键点（高低点+突破位）
    ↓ AI分析
结论+建议（~200字）