接入台北松山 RCSS CWA 10分钟实时温度；HKO 显示结算温度

台北通过现有 CWA 开放数据 API（站号 466920）接入高频推送。
香港/流浮山消息新增"结算温度"行，显示向下取整后的结算值。

Tested: pytest 176 passed, ruff check 通过

src/analysis/market_alert_engine.py

@@ -813,7 +813,7 @@ def _build_advice_cn(
     return "，".join(parts) + "。"
 
 
-_AIRPORT_ICAO_MAP = {"seoul": "RKSI", "busan": "RKPK", "tokyo": "RJTT", "ankara": "17128", "helsinki": "EFHK", "amsterdam": "EHAM", "istanbul": "17058", "paris": "LFPB", "hong kong": "HKO", "lau fau shan": "LFS"}
+_AIRPORT_ICAO_MAP = {"seoul": "RKSI", "busan": "RKPK", "tokyo": "RJTT", "ankara": "17128", "helsinki": "EFHK", "amsterdam": "EHAM", "istanbul": "17058", "paris": "LFPB", "hong kong": "HKO", "lau fau shan": "LFS", "taipei": "466920"}
 
 
 def _calc_airport_rapid_temp_change(

src/bot/runtime_coordinator.py

@@ -190,7 +190,7 @@ class StartupCoordinator:
         details = {
             "mode": "airport-periodic",
             "interval_sec": interval,
-            "cities": ["seoul", "busan", "tokyo", "ankara", "helsinki", "amsterdam", "istanbul", "paris", "hong kong", "lau fau shan"],
+            "cities": ["seoul", "busan", "tokyo", "ankara", "helsinki", "amsterdam", "istanbul", "paris", "hong kong", "lau fau shan", "taipei"],
             "chat_targets": len(chat_ids),
             "window": "DEB proximity ≤3°C",
         }

src/data_collection/settlement_sources.py

@@ -365,6 +365,18 @@ class SettlementSourceMixin:
                 "unit": "celsius",
             }
             self._set_settlement_cache(cache_key, payload)
+            # Write to airport obs log for high-freq monitoring
+            try:
+                from src.database.db_manager import DBManager
+                DBManager().append_airport_obs(
+                    icao="466920",
+                    city="taipei",
+                    temp_c=payload["current"]["temp"],
+                    wind_kt=payload["current"].get("wind_speed_kt"),
+                    obs_time=str(obs_time_raw or "").strip() or datetime.now().isoformat(),
+                )
+            except Exception:
+                logger.exception("airport_obs_log append failed for cwa")
             return payload
         except Exception as exc:
             logger.warning(f"CWA settlement fetch failed: {exc}")

src/utils/telegram_push.py

@@ -690,8 +690,8 @@ def start_trade_alert_push_loop(bot: Any, config: Dict[str, Any]) -> Optional[th
 
 # ── high-freq airport push loop ──
 
-HIGH_FREQ_AIRPORT_CITIES = {"seoul", "busan", "tokyo", "ankara", "helsinki", "amsterdam", "istanbul", "paris", "hong kong", "lau fau shan"}
-HIGH_FREQ_AIRPORT_ICAO = {"seoul": "RKSI", "busan": "RKPK", "tokyo": "RJTT", "ankara": "17128", "helsinki": "EFHK", "amsterdam": "EHAM", "istanbul": "17058", "paris": "LFPB", "hong kong": "HKO", "lau fau shan": "LFS"}
+HIGH_FREQ_AIRPORT_CITIES = {"seoul", "busan", "tokyo", "ankara", "helsinki", "amsterdam", "istanbul", "paris", "hong kong", "lau fau shan", "taipei"}
+HIGH_FREQ_AIRPORT_ICAO = {"seoul": "RKSI", "busan": "RKPK", "tokyo": "RJTT", "ankara": "17128", "helsinki": "EFHK", "amsterdam": "EHAM", "istanbul": "17058", "paris": "LFPB", "hong kong": "HKO", "lau fau shan": "LFS", "taipei": "466920"}
 
 _AIRPORT_PUSH_STATE_PATH = os.path.join(
     os.path.dirname(os.path.dirname(os.path.dirname(os.path.abspath(__file__)))),
@@ -752,7 +752,8 @@ def _build_airport_status_message(
     _AIRPORT_EN = {"seoul": "Incheon", "busan": "Gimhae", "tokyo": "Haneda",
                    "ankara": "Esenboğa", "helsinki": "Vantaa", "amsterdam": "Schiphol",
                    "istanbul": "Airport", "paris": "Le Bourget",
-                   "hong kong": "Observatory", "lau fau shan": "Lau Fau Shan"}
+                   "hong kong": "Observatory", "lau fau shan": "Lau Fau Shan",
+                   "taipei": "Songshan"}
     en_name = city.title()
     ap_name = _AIRPORT_EN.get(city, "")
     time_suffix = f" {local_time}" if local_time else ""
@@ -799,6 +800,12 @@ def _build_airport_status_message(
     if not runway_shown and station_temp is not None:
         label = "AROME预报" if city == "paris" else "当前实测"
         lines.append(f"{label}：{station_temp:.1f}°C")
+        # Show settlement (rounded-down) temp for HKO floor-rounding cities
+        if city in ("hong kong", "lau fau shan") and station_temp is not None:
+            from src.analysis.settlement_rounding import apply_city_settlement
+            settled = apply_city_settlement(city, station_temp)
+            if settled is not None:
+                lines.append(f"结算温度：{settled}°C")
     if deb_pred is not None:
         lines.append(f"今日DEB预报最高：{deb_pred:.1f}°C")
     if max_so_far is not None:
@@ -832,6 +839,7 @@ _AIRPORT_PUSH_INTERVAL = {
     "paris": 900,        # AROME HD 15-min model
     "hong kong": 60,     # HKO 1-min
     "lau fau shan": 60,  # HKO 1-min
+    "taipei": 600,       # CWA ~10-min
 }
 _DEB_PROXIMITY_THRESHOLD_C = 3.0