Update services/usgs_service.py

services/usgs_service.py

@@ -1,4 +1,5 @@
 # usgs_service.py
+
 import requests
 import pandas as pd
 from datetime import datetime, timedelta, timezone
@@ -76,4 +77,39 @@ def fetch_taiwan_df_this_year(min_mag: float = 5.0) -> pd.DataFrame | str:
             })
         return pd.DataFrame(rows)
     except Exception as e:
-        return f"❌ 查詢失敗: {e}"
+        return f"❌ 查詢失敗: {e}"
+
+# --- ✨ 以下是新增的函式 ---
+def fetch_usgs_earthquakes_by_date(start_time_str: str, end_time_str: str, min_mag: float, limit: int = 20) -> str:
+    """根據指定的日期範圍和最小規模，從 USGS API 查詢全球地震。"""
+    params = {
+        "format": "geojson",
+        "starttime": start_time_str,
+        "endtime": end_time_str,
+        "minmagnitude": float(min_mag),
+        "limit": int(limit),
+        "orderby": "time-asc", # 按時間正序排列
+    }
+    try:
+        r = requests.get(USGS_API_BASE_URL, params=params, timeout=20)
+        r.raise_for_status()
+        features = r.json().get("features", [])
+        if not features:
+            return f"✅ 在 {start_time_str} 至 {end_time_str} 期間，全球無規模 {min_mag} 以上的地震紀錄。"
+        
+        lines = [f"🔎 {start_time_str} 至 {end_time_str} 全球地震 (M≥{min_mag}):", "-" * 20]
+        for f in features:
+            p = f["properties"]
+            t_utc = datetime.fromtimestamp(p["time"] / 1000, tz=timezone.utc)
+            lines.append(
+                f"規模: {p['mag']:.1f} | 時間: {t_utc.strftime('%Y-%m-%d %H:%M')} (UTC)\n"
+                f"地點: {p.get('place', 'N/A')}\n"
+                f"報告: {p.get('url', '無')}"
+            )
+        
+        if len(features) >= limit:
+            lines.append(f"\n（注意：結果已達上限 {limit} 筆，可能還有更多地震未顯示）")
+
+        return "\n\n".join(lines)
+    except Exception as e:
+        return f"❌ 查詢失敗：{e}"