Create pws_service.py

pws_service.py

@@ -1,7 +1,7 @@
 # pws_service.py (Robust Version)
 import requests
 import json
-from config import PWS_API_URL
+from config import PWS_API_URL, CWA_PWS_EARTHQUAKE_API
 
 def fetch_latest_pws_info() -> str:
     """
@@ -51,4 +51,20 @@ def fetch_latest_pws_info() -> str:
     except requests.exceptions.RequestException as e:
         return f"❌ PWS 查詢失敗：網路連線錯誤。\n錯誤訊息：{e}"
     except Exception as e:
-        return f"❌ PWS 查詢失敗：發生未預期的錯誤。\n錯誤訊息：{e}"
+        return f"❌ PWS 查詢失敗：發生未預期的錯誤。\n錯誤訊息：{e}"
+
+def fetch_cwa_pws_earthquake_info() -> str:
+    """從指定的 API 端點擷取最新的 CWA PWS 地震訊息。"""
+    try:
+        response = requests.get(CWA_PWS_EARTHQUAKE_API, timeout=15)
+        response.raise_for_status()  # 如果請求失敗 (e.g., 404, 500)，則引發例外
+        
+        # 假設 API 直接回傳格式化好的純文字
+        return response.text
+
+    except requests.exceptions.Timeout:
+        return "❌ PWS 地震訊息查詢失敗：連線超時。"
+    except requests.exceptions.RequestException as e:
+        return f"❌ PWS 地震訊息查詢失敗：網路連線錯誤。\n錯誤訊息：{e}"
+    except Exception as e:
+        return f"❌ PWS 地震訊息查詢失敗：發生未預期的錯誤。\n錯誤訊息：{e}"