From c56c490b60b25752c89b372f116ec6ca589cdcde Mon Sep 17 00:00:00 2001
From: AmandaloveYang <2569718930@qq.com>
Date: Mon, 11 May 2026 18:34:39 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E6=9C=BA=E5=9C=BA=E9=AB=98?=
 =?UTF-8?q?=E9=A2=91=E6=95=B0=E6=8D=AE=E6=8E=A5=E5=85=A5=E5=B8=82=E5=9C=BA?=
 =?UTF-8?q?=E7=9B=91=E6=8E=A7=E9=A2=91=E9=81=93=E6=96=B9=E6=A1=88=E6=96=87?=
 =?UTF-8?q?=E6=A1=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>
---
 docs/AIRPORT_MARKET_MONITOR_ZH.md | 146 ++++++++++++++++++++++++++++++
 1 file changed, 146 insertions(+)
 create mode 100644 docs/AIRPORT_MARKET_MONITOR_ZH.md

diff --git a/docs/AIRPORT_MARKET_MONITOR_ZH.md b/docs/AIRPORT_MARKET_MONITOR_ZH.md
new file mode 100644
index 00000000..0e92f649
--- /dev/null
+++ b/docs/AIRPORT_MARKET_MONITOR_ZH.md
@@ -0,0 +1,146 @@
+# 机场高频数据接入 Telegram 市场监控频道方案
+
+## 背景
+
+### 现有数据
+
+| 城市 | 机场 | ICAO | 数据源 | 刷新频率 | 缓存 TTL | 数据字段 |
+|------|------|------|--------|---------|----------|---------|
+| 首尔 | 仁川国际 | RKSI | AMOS (`global.amo.go.kr`) | 1 分钟 | 60s | 温度/露点/风速/气压/能见度/RVR/跑道对温度/METAR/TAF |
+| 釜山 | 金海国际 | RKPK | AMOS (`global.amo.go.kr`) | 1 分钟 | 60s | 同上 |
+| 东京 | 羽田 | RJTT | JMA AMeDAS (`jma.go.jp`) | 10 分钟 | 120s | 10 分钟温度观测（当前仅提取 temp） |
+
+### 现有 Telegram 推送系统
+
+- **循环**: `start_trade_alert_push_loop`，默认每 30 分钟跑一轮
+- **覆盖城市**: `TELEGRAM_ALERT_CITIES`（默认全部 51 城）
+- **4 条规则**: Ankara Center DEB 命中、动量突变(30min 斜率 > 0.8°C)、预报突破、暖平流
+- **门禁**: 严重度/触发数/市场可交易性/冷却期 多层过滤
+- **消息**: 中英双语，包含触发类型、实况温度、市场概率分布、AI 建议
+
+### 问题
+
+高频机场数据已就绪，但现有推送系统没有针对性利用。首尔/釜山 1 分钟级 AMOS 和东京 10 分钟级 JMA 可以做更快、更灵敏的市场信号检测。
+
+---
+
+## 方案设计
+
+### 核心思路
+
+**增强现有系统，不新建**。对高频机场城市使用更低的推送间隔和更灵敏的规则参数。
+
+### 1. 高频机场城市快速通道
+
+在现有 30 分钟主循环之外，为 `{seoul, busan, tokyo}` 单独跑一个 10 分钟间隔的子循环，只检查动量突变和预报突破两条最关键的规则，使用更低的触发阈值。
+
+**配置（写死在代码中）**:
+```python
+HIGH_FREQ_AIRPORT_CITIES = {"seoul", "busan", "tokyo"}
+HIGH_FREQ_PUSH_INTERVAL_SEC = 600        # 10 分钟
+HIGH_FREQ_MOMENTUM_THRESHOLD_C = 0.5     # 比默认 0.8°C 更灵敏
+```
+
+**逻辑**:
+- 主循环 30 分钟照常跑全部城市（不变）
+- 每 10 分钟额外跑一轮高频城市子集
+- 高频轮次跳过 Ankara DEB 和 Advection 规则
+- 高频告警有独立冷却期（如 2 小时，比默认 6 小时更短）
+
+### 2. 机场观测积累与趋势检测
+
+**问题**: 当前 AMOS/JMA 每次只返回最新一条观测，无法计算温度斜率做动量检测。
+
+**新增数据库表**: `airport_obs_log`
+```sql
+CREATE TABLE IF NOT EXISTS airport_obs_log (
+    id INTEGER PRIMARY KEY AUTOINCREMENT,
+    icao TEXT NOT NULL,
+    city TEXT NOT NULL,
+    temp_c REAL,
+    wind_kt REAL,
+    pressure_hpa REAL,
+    obs_time TEXT NOT NULL,
+    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+);
+CREATE INDEX IF NOT EXISTS idx_airport_obs_log_icao_time
+    ON airport_obs_log(icao, created_at DESC);
+```
+
+**写入**: 在 AMOS/JMA 成功获取数据后自动调用 `append_airport_obs()` 写入。自动清理 2 小时前的旧数据。
+
+**读取**: `get_airport_obs_recent(icao, minutes=30)` 返回最近 N 分钟观测列表，用于计算温度变化斜率。
+
+### 3. 温度突变即时告警
+
+基于积累的观测日志，新增告警规则 `airport_rapid_temp_change`。
+
+| 参数 | 值 | 说明 |
+|------|-----|------|
+| 滑动窗口 | 20 分钟 | 取最近 20 分钟内的观测 |
+| 最少样本 | 3 条 | 确保有足够数据点 |
+| 触发阈值 | > 0.3°C/10min | 约 1.8°C/小时 |
+| 额外条件 | 温度变化方向与市场桶一致 | 避免无关告警 |
+
+**告警消息示例**:
+```
+🚨 首尔/仁川 温度急变
+
+跑道中位数 15.2→16.8°C (+1.6°C / 15min)
+风 180°→210° 暖平流增强
+市场桶 17°C 概率 62% → 当前边缘 +8.2%
+```
+
+### 4. 机场实况快照摘要
+
+每隔 30 分钟，向市场监控频道推送三座机场的当前实况摘要。
+
+**推送时段**: 仅各城市当地 08:00-20:00（避免半夜噪音）
+
+**消息格式**:
+```
+🛫 机场实况快照 14:30 CST
+
+🇰🇷 首尔/仁川 RKSI
+跑道 15L/33R: 14.6°C | 15R/33L: 15.2°C
+风 220° 14kt | QNH 1015.2 hPa | 能见度 ≥10km
+METAR 14:00Z | 跑道中位数 14.9°C
+
+🇰🇷 釜山/金海 RKPK
+跑道 18L/36R: 13.8°C | 风 180° 8kt
+METAR 14:00Z
+
+🇯🇵 东京/羽田 RJTT
+JMA AMeDAS 10-min: 12.4°C (14:20 JST)
+```
+
+---
+
+## 改动文件清单
+
+| 优先级 | 文件 | 改动 |
+|--------|------|------|
+| 1 | `src/database/db_manager.py` | 新增 `airport_obs_log` 表、`append_airport_obs()`、`get_airport_obs_recent()` |
+| 2 | `src/data_collection/amos_station_sources.py` | 成功获取后调用 `append_airport_obs()` 写日志 |
+| 3 | `src/data_collection/jma_amedas_sources.py` | 成功获取后调用 `append_airport_obs()` 写日志，可选扩展提取更多字段（风速/气压） |
+| 4 | `src/analysis/market_alert_engine.py` | 新增 `airport_rapid_temp_change` 规则 |
+| 5 | `src/utils/telegram_push.py` | 高频快速通道子循环、机场快照推送、温度急变告警集成 |
+
+---
+
+## 实施顺序
+
+1. **Phase 1 — DB 层**: `airport_obs_log` 表 + 读写方法
+2. **Phase 2 — 采集层**: AMOS/JMA 成功后自动写日志，部署观察 1-2 天确认数据积累正常
+3. **Phase 3 — 告警引擎**: `airport_rapid_temp_change` 规则 + 单元测试
+4. **Phase 4 — 推送层**: 高频快速通道 + 机场快照，先在测试频道验证消息格式
+5. **Phase 5 — 上线**: 切换到正式市场监控频道，观察 3-7 天调整阈值
+
+---
+
+## 风险与注意事项
+
+- **AMOS/JMA 站点可用性**: `global.amo.go.kr` 和 `jma.go.jp` 可能偶发性不可用，需容错处理
+- **告警频率控制**: 高频循环可能产生过多告警，需要严格的冷却期和去重机制
+- **数据库体积**: `airport_obs_log` 每 1-10 分钟写入 3 条记录，2 小时约 36-360 条，自动清理后体积可控
+- **东京 JMA 数据完整性**: 当前只提取 temp，风速/气压需要额外解析（JMA JSON 中有 `wind` 和 `pressure` 数组但未使用）