weather_service.py

weather_service.py

@@ -1,85 +0,0 @@
-# weather_service.py
-import requests
-from config import CWA_API_KEY, DATASET_IDS
-
-CWA_API_BASE_URL = "https://opendata.cwa.gov.tw/api/v1/rest/datastore/"
-
-def _make_cwa_api_request(data_id, params=None):
-    """一個通用的 CWA API 請求函式"""
-    if not CWA_API_KEY:
-        raise ValueError("錯誤：尚未設定 CWA_API_KEY Secret。")
-    
-    api_url = f"{CWA_API_BASE_URL}{data_id}"
-    base_params = {"Authorization": CWA_API_KEY, "format": "JSON"}
-    if params:
-        base_params.update(params)
-    
-    response = requests.get(api_url, params=base_params, timeout=10)
-    response.raise_for_status() # 如果請求失敗 (e.g., 401, 404, 500), 會在此拋出錯誤
-    
-    data = response.json()
-    if not data.get('success'):
-        raise ValueError("API 回應不成功或資料格式有誤。")
-    
-    return data.get('records', {})
-
-def _parse_forecast_data(records, location):
-    """解析 F-C0032-001 的預報資料並格式化為文字"""
-    location_records = records.get('location', [])
-    if not location_records:
-        return f"找不到「{location}」的預報資訊。\n請確認是否為台灣的縣市名稱 (例如: 臺北市, 花蓮縣)。"
-
-    weather_elements = location_records[0].get('weatherElement', [])
-    
-    # 用字典來重組資料，以時間為主鍵
-    forecasts = {}
-    for element in weather_elements:
-        element_name = element['elementName']
-        for time_period in element['time']:
-            time_key = f"{time_period['startTime']} ~ {time_period['endTime']}"
-            if time_key not in forecasts:
-                forecasts[time_key] = {}
-            
-            value = time_period['parameter']['parameterName']
-            unit = time_period['parameter'].get('parameterUnit', '')
-            forecasts[time_key][element_name] = f"{value}{unit}"
-
-    # 格式化輸出
-    result = f"📍 {location} 未來 36 小時天氣預報：\n"
-    for time_period, values in sorted(forecasts.items()):
-        # 將時間字串格式化得更易讀
-        start_time_str = time_period.split(' ~ ')[0]
-        start_dt = datetime.fromisoformat(start_time_str)
-        period_name = f"{start_dt.strftime('%m/%d %H:%M')}"
-
-        result += (
-            f"\n➢ 時段：{period_name} 開始\n"
-            f"  天氣：{values.get('Wx', 'N/A')}\n"
-            f"  氣溫：{values.get('MinT', '?')}°C - {values.get('MaxT', '?')}°C\n"
-            f"  降雨機率：{values.get('PoP', '?')}%"
-        )
-    return result
-
-def fetch_forecast_by_location(location_name: str) -> str:
-    """
-    主要的天氣預報查詢函式，由 command_handler 呼叫。
-    它會處理地點名稱的 '台'/'臺' 轉換，並呼叫輔助函式。
-    """
-    try:
-        # 進行地點名稱的簡易處理，提高 API 成功率
-        processed_location = location_name.replace("台", "臺")
-        if not (processed_location.endswith("市") or processed_location.endswith("縣")):
-            # 根據 Gradio 程式碼的縣市列表，大部分地點都是縣
-            if processed_location in ["臺北", "新北", "基隆", "桃園", "新竹", "臺中", "嘉義", "臺南", "高雄"]:
-                 processed_location += "市"
-            else:
-                 processed_location += "縣"
-
-        records = _make_cwa_api_request(
-            DATASET_IDS["天氣預報"], 
-            {"locationName": processed_location}
-        )
-        return _parse_forecast_data(records, processed_location)
-    except Exception as e:
-        return f"❌ 天氣預報查詢失敗：{e}"
-