From b33a7413858eed856e2ccddc60fd5855ba3f93cd Mon Sep 17 00:00:00 2001 From: "2569718930@qq.com" <2569718930@qq.com> Date: Wed, 18 Mar 2026 21:01:31 +0800 Subject: [PATCH] Switch Ankara MGM station selection to 17128 airport --- src/analysis/market_alert_engine.py | 7 +++---- src/data_collection/weather_sources.py | 4 ++-- 2 files changed, 5 insertions(+), 6 deletions(-) diff --git a/src/analysis/market_alert_engine.py b/src/analysis/market_alert_engine.py index cde92c17..b0a8db29 100644 --- a/src/analysis/market_alert_engine.py +++ b/src/analysis/market_alert_engine.py @@ -203,7 +203,7 @@ def _pick_leading_station(city: str, nearby: List[Dict[str, Any]]) -> Optional[D for row in nearby: name = str(row.get("name") or "").lower() sid = str(row.get("istNo") or "").strip() - if sid == "17130" or "center" in name or "bölge" in name or "etimesgut" in name: + if sid == "17128" or "airport" in name or "17128" in name: priority_rows.append(row) if priority_rows: return max(priority_rows, key=_temp) @@ -218,9 +218,9 @@ def _pick_ankara_center_station(nearby: List[Dict[str, Any]]) -> Optional[Dict[s for row in nearby: name = str(row.get("name") or "").strip().lower() sid = str(row.get("istNo") or "").strip() - if sid == "17130": + if sid == "17128": return row - if name in {"ankara (bölge/center)", "ankara (bolge/center)"}: + if name in {"airport (mgm/17128)", "ankara airport", "ankara esenboğa airport"}: return row return None @@ -1360,4 +1360,3 @@ def build_trading_alerts( "telegram": telegram, } - diff --git a/src/data_collection/weather_sources.py b/src/data_collection/weather_sources.py index c85ab921..c4538433 100644 --- a/src/data_collection/weather_sources.py +++ b/src/data_collection/weather_sources.py @@ -2118,7 +2118,7 @@ class WeatherDataCollector: # Turkish cities: keep MGM model fallback alive when Open-Meteo is rate-limited. turkish_provinces = { - "ankara": ("17130", "Ankara"), # MGM center station + "ankara": ("17128", "Ankara"), # MGM airport station "istanbul": ("17060", "Istanbul"), } @@ -2147,7 +2147,7 @@ class WeatherDataCollector: # 对土耳其城市，额外获取 MGM 官方数据与周边测站 turkish_provinces = { - "ankara": ("17130", "Ankara"), # use one MGM station consistently + "ankara": ("17128", "Ankara"), # use airport station consistently "istanbul": ("17060", "Istanbul"), } if city_lower in turkish_provinces: