LINE-ROBOT

Sleeping

App Files Files Community

cwadayi commited on Aug 15, 2025

Commit

d422181

verified ·

1 Parent(s): 7ac3bdd

Update app.py

Browse files

Files changed (1) hide show

app.py +110 -129

app.py CHANGED Viewed

@@ -1,201 +1,182 @@
 import os
-from flask import Flask, request, abort
 from linebot.v3 import WebhookHandler
 from linebot.v3.exceptions import InvalidSignatureError
 from linebot.v3.messaging import (
     Configuration, ApiClient, MessagingApi,
-    ReplyMessageRequest, TextMessage
 )
 from linebot.v3.webhooks import MessageEvent, TextMessageContent
 import requests
 import pandas as pd
 from datetime import datetime, timedelta
 # --- 環境變數 ---
 CHANNEL_ACCESS_TOKEN = os.getenv('CHANNEL_ACCESS_TOKEN')
 CHANNEL_SECRET = os.getenv('CHANNEL_SECRET')
 # --- Flask & LINE Bot 初始化 ---
 app = Flask(__name__)
 configuration = Configuration(access_token=CHANNEL_ACCESS_TOKEN)
 handler = WebhookHandler(CHANNEL_SECRET)
-# --- 歡迎頁面路由 ---
 @app.route("/", methods=['GET'])
 def home():
-    return """
-    <html>
-        <head>
-            <title>LINE Bot Server</title>
-            <style>
-                body { font-family: Arial, sans-serif; display: flex; justify-content: center; align-items: center; height: 100vh; background-color: #f0f2f5; margin: 0; }
-                .container { text-align: center; padding: 40px; background-color: white; border-radius: 10px; box-shadow: 0 4px 8px rgba(0,0,0,0.1); }
-                h1 { color: #1dcd00; }
-                p { color: #333; font-size: 1.2em; }
-                .status { font-weight: bold; color: #28a745; }
-            </style>
-        </head>
-        <body>
-            <div class="container">
-                <h1>✓ LINE Bot Server is Running</h1>
-                <p>This is the backend service for the Earthquake Alert Bot.</p>
-                <p>The service is <span class="status">active</span> and listening for webhook events from LINE.</p>
-            </div>
-        </body>
-    </html>
-    """
 # --- 地震查詢核心邏輯 ---
 USGS_API_BASE_URL = "https://earthquake.usgs.gov/fdsnws/event/1/query"
 def fetch_earthquake_data_for_line():
-    """查詢過去 24 小時內全球規模 5.0 以上的地震。"""
     now = datetime.now()
     yesterday = now - timedelta(days=1)
-    params = {
-        "format": "geojson",
-        "starttime": yesterday.strftime('%Y-%m-%d'),
-        "endtime": now.strftime('%Y-%m-%d'),
-        "minmagnitude": 5.0,
-        "limit": 10,
-        "orderby": "time"
-    }
     try:
         response = requests.get(USGS_API_BASE_URL, params=params, timeout=15)
         response.raise_for_status()
         data = response.json()
         features = data.get('features', [])
-        if not features:
-            return "✅ 過去24小時內，全球無規模 5.0 以上的顯著地震。"
         reply_text = f"🚨 近 24 小時全球顯著地震 (M≥5.0):\n{'-'*20}\n"
         for feature in features:
             prop = feature['properties']
-            mag = prop['mag']
-            place = prop['place']
-            event_time = datetime.fromtimestamp(prop['time'] / 1000).strftime('%H:%M')
-            reply_text += f"震級: {mag:.1f} | 時間: {event_time} (UTC)\n地點: {place}\n\n"
         return reply_text.strip()
-    except requests.exceptions.RequestException as e:
-        return f"❌ 查詢失敗，無法連接到 USGS 伺服器: {e}"
-    except Exception as e:
-        return f"❌ 處理資料時發生未知錯誤: {e}"
-# --- 「臺灣地震」查詢函式 ---
-def fetch_taiwan_earthquake_data():
-    """查詢今年以來，台灣地區規模 5.0 以上的地震。"""
     now = datetime.now()
     start_of_year = now.replace(month=1, day=1).strftime('%Y-%m-%d')
     today_str = now.strftime('%Y-%m-%d')
     params = {
-        "format": "geojson",
-        "starttime": start_of_year,
-        "endtime": today_str,
-        "minmagnitude": 5.0,
-        "minlatitude": 21,
-        "maxlatitude": 26,
-        "minlongitude": 119,
-        "maxlongitude": 123,
-        "limit": 100,
-        "orderby": "time"
     }
     try:
         response = requests.get(USGS_API_BASE_URL, params=params, timeout=20)
         response.raise_for_status()
         data = response.json()
         features = data.get('features', [])
-        count = len(features)
-        if not features:
-            return f"✅ 今年 ({now.year}年) 以來，在您指定的範圍內尚無規模 5.0 以上的顯著地震紀錄。"
-        reply_text = f"🇹🇼 今年 ({now.year}年) 台灣區域顯著地震 (M≥5.0)，共 {count} 筆:\n{'-'*20}\n"
-        for feature in features:
-            prop = feature['properties']
-            mag = prop['mag']
-            place = prop['place']
-            event_time_utc = datetime.fromtimestamp(prop['time'] / 1000)
-            time_str = event_time_utc.strftime('%Y-%m-%d %H:%M')
-            reply_text += f"震級: {mag:.1f} | 時間: {time_str} (UTC)\n地點: {place}\n\n"
-        if len(reply_text) > 4800:
-            reply_text = reply_text[:4800] + "\n... (資料過多，僅顯示部分)"
-        return reply_text.strip()
-    except requests.exceptions.RequestException as e:
-        return f"❌ 查詢失敗，無法連接到 USGS 伺服器: {e}"
-    except Exception as e:
-        return f"❌ 處理資料時發生未知錯誤: {e}"
 # --- Flask Webhook 路由 ---
 @app.route("/callback", methods=['POST'])
 def callback():
     signature = request.headers['X-Line-Signature']
     body = request.get_data(as_text=True)
-    app.logger.info("Request body: " + body)
     try:
         handler.handle(body, signature)
     except InvalidSignatureError:
-        app.logger.info("Invalid signature. Please check your channel secret.")
         abort(400)
     return 'OK'
 # --- LINE 訊息處理 (有修改) ---
 @handler.add(MessageEvent, message=TextMessageContent)
 def handle_message(event):
-    user_message = event.message.text.strip().lower() # 統一轉為小寫以便比對
-    reply_text = ""
-    # --- ✨✨✨ 修改點：新增 /help 指令 ✨✨✨ ---
-    if user_message == "/help":
-        reply_text = """📖 地震預警dayichen 指令說明
-您可以傳送以下指令來與我互動：
-➡️ /help
-   說明：顯示此幫助訊息，列出所有可用指令。
-➡️ 地震
-   說明：查詢全球最近 24 小時內，芮氏規模 5.0 以上的顯著地震。
-➡️ 臺灣地震 (或 台灣地震)
-   說明：查詢今年以來，在台灣區域 (緯度 21-26°, 經度 119-123°) 發生的芮氏規模 5.0 以上地震。
-➡️ 你好
-   說明：顯示歡迎訊息。"""
-    elif "臺灣地震" in user_message or "台灣地震" in user_message:
-        reply_text = fetch_taiwan_earthquake_data()
-    elif "地震" in user_message or "quake" in user_message:
-        reply_text = fetch_earthquake_data_for_line()
-    elif "你好" in user_message or "hi" in user_message:
-        reply_text = "👋 你好！我是地震查詢機器人。\n\n試著傳送「地震」或「臺灣地震」，或輸入 /help 查看所有指令。"
-    else:
-        # 如果不是已知的指令，可以選擇不回覆，或回覆提示訊息
-        # reply_text = f"無法識別指令「{event.message.text}」。\n請輸入 /help 查看所有可用指令。"
-        return
     with ApiClient(configuration) as api_client:
         line_bot_api = MessagingApi(api_client)
         line_bot_api.reply_message_with_http_info(
             ReplyMessageRequest(
                 reply_token=event.reply_token,

 import os
+import uuid
+from flask import Flask, request, abort, send_from_directory
 from linebot.v3 import WebhookHandler
 from linebot.v3.exceptions import InvalidSignatureError
 from linebot.v3.messaging import (
     Configuration, ApiClient, MessagingApi,
+    ReplyMessageRequest, TextMessage, ImageSendMessage
 )
 from linebot.v3.webhooks import MessageEvent, TextMessageContent
 import requests
 import pandas as pd
+import plotly.express as px
 from datetime import datetime, timedelta
 # --- 環境變數 ---
 CHANNEL_ACCESS_TOKEN = os.getenv('CHANNEL_ACCESS_TOKEN')
 CHANNEL_SECRET = os.getenv('CHANNEL_SECRET')
+# 從 Secrets 讀取我們設定的 Space 公開網址
+HF_SPACE_URL = os.getenv('HF_SPACE_URL')
 # --- Flask & LINE Bot 初始化 ---
 app = Flask(__name__)
+# 建立一個資料夾來存放靜態圖片檔
+if not os.path.exists('static'):
+    os.makedirs('static')
 configuration = Configuration(access_token=CHANNEL_ACCESS_TOKEN)
 handler = WebhookHandler(CHANNEL_SECRET)
+# --- 歡迎頁面 & 靜態圖片服務路由 ---
 @app.route("/", methods=['GET'])
 def home():
+    # ... (歡迎頁面 HTML，與之前相同) ...
+    return "<h1>✓ LINE Bot Server is Running</h1>"
+@app.route('/static/<path:filename>')
+def serve_static(filename):
+    """這個路由讓外部可以存取 static 資料夾內的檔案"""
+    return send_from_directory('static', filename)
 # --- 地震查詢核心邏輯 ---
 USGS_API_BASE_URL = "https://earthquake.usgs.gov/fdsnws/event/1/query"
 def fetch_earthquake_data_for_line():
+    """查詢全球地震並回傳格式化的文字"""
+    # ... (此函式與之前完全相同) ...
     now = datetime.now()
     yesterday = now - timedelta(days=1)
+    params = {"format": "geojson","starttime": yesterday.strftime('%Y-%m-%d'),"endtime": now.strftime('%Y-%m-%d'),"minmagnitude": 5.0,"limit": 10,"orderby": "time"}
     try:
         response = requests.get(USGS_API_BASE_URL, params=params, timeout=15)
         response.raise_for_status()
         data = response.json()
         features = data.get('features', [])
+        if not features: return "✅ 過去24小時內，全球無規模 5.0 以上的顯著地震。"
         reply_text = f"🚨 近 24 小時全球顯著地震 (M≥5.0):\n{'-'*20}\n"
         for feature in features:
             prop = feature['properties']
+            reply_text += f"震級: {prop['mag']:.1f} | 時間: {datetime.fromtimestamp(prop['time']/1000).strftime('%H:%M')} (UTC)\n地點: {prop['place']}\n\n"
         return reply_text.strip()
+    except Exception as e: return f"❌ 查詢失敗: {e}"
+def fetch_taiwan_earthquake_data_df():
+    """查詢今年台灣地震並回傳 DataFrame 或錯誤訊息(str)"""
     now = datetime.now()
     start_of_year = now.replace(month=1, day=1).strftime('%Y-%m-%d')
     today_str = now.strftime('%Y-%m-%d')
     params = {
+        "format": "geojson", "starttime": start_of_year, "endtime": today_str,
+        "minmagnitude": 5.0, "minlatitude": 21, "maxlatitude": 26,
+        "minlongitude": 119, "maxlongitude": 123, "limit": 250, "orderby": "time"
     }
     try:
         response = requests.get(USGS_API_BASE_URL, params=params, timeout=20)
         response.raise_for_status()
         data = response.json()
         features = data.get('features', [])
+        if not features: return f"✅ 今年 ({now.year}年) 以來，在指定範圍內尚無規模 5.0 以上的顯著地震紀錄。"
+        earthquake_list = [{'latitude': f['geometry']['coordinates'][1],'longitude': f['geometry']['coordinates'][0],'magnitude': f['properties']['mag'],'place': f['properties']['place'],'time': datetime.fromtimestamp(f['properties']['time']/1000)} for f in features]
+        return pd.DataFrame(earthquake_list)
+    except Exception as e: return f"❌ 查詢失敗: {e}"
+# --- ✨✨✨ 新增的繪圖函式 ✨✨✨ ---
+def create_and_save_map(df):
+    """接收 DataFrame，繪製地圖，儲存圖片，並回傳檔名"""
+    fig = px.scatter_mapbox(
+        df,
+        lat="latitude", lon="longitude",
+        size="magnitude", color="magnitude",
+        hover_name="place",
+        hover_data={'time': '|%Y-%m-%d %H:%M', 'magnitude': ':.1f'},
+        color_continuous_scale=px.colors.sequential.YlOrRd,
+        size_max=30,
+        mapbox_style="carto-darkmatter",
+        center={"lat": 23.5, "lon": 121.0}, # 地圖中心點設在台灣
+        zoom=6
+    )
+    fig.update_layout(
+        title=f"<b>今年 ({datetime.now().year}) 台灣區域顯著地震 (M≥5.0)</b>",
+        margin={"r": 0, "t": 40, "l": 0, "b": 0}
+    )
+    # 產生一個獨一無二的檔名，避免檔案衝突
+    filename = f"map_{uuid.uuid4().hex}.png"
+    filepath = os.path.join('static', filename)
+    # 儲存圖片，kaleido 引擎會在這裡作用
+    fig.write_image(filepath, scale=2) # scale=2 讓圖片更清晰
+    return filename
 # --- Flask Webhook 路由 ---
 @app.route("/callback", methods=['POST'])
 def callback():
     signature = request.headers['X-Line-Signature']
     body = request.get_data(as_text=True)
     try:
         handler.handle(body, signature)
     except InvalidSignatureError:
         abort(400)
     return 'OK'
 # --- LINE 訊息處理 (有修改) ---
 @handler.add(MessageEvent, message=TextMessageContent)
 def handle_message(event):
+    user_message = event.message.text.strip().lower()
     with ApiClient(configuration) as api_client:
         line_bot_api = MessagingApi(api_client)
+        # --- ✨✨✨ 修改點：加入對「臺灣地震畫圖」的處理 ✨✨✨ ---
+        if "臺灣地震畫圖" in user_message or "台灣地震畫圖" in user_message:
+            # 1. 顯示「處理中」的提示，提升使用者體驗
+            line_bot_api.reply_message(ReplyMessageRequest(
+                reply_token=event.reply_token, messages=[TextMessage(text="🗺️ 收到指令！正在繪製地震分佈圖，請稍候...")]
+            ))
+            # 2. 獲取地震資料
+            result = fetch_taiwan_earthquake_data_df()
+            # 3. 判斷結果是 DataFrame 還是錯誤訊息
+            if isinstance(result, pd.DataFrame):
+                # 4. 如果是 DataFrame，繪製地圖並取得檔名
+                filename = create_and_save_map(result)
+                # 5. 組合圖片的公開 URL
+                image_url = f"{HF_SPACE_URL}/static/{filename}"
+                # 6. 這次不使用 reply_message，而是用 push_message 將圖片傳送給使用者
+                line_bot_api.push_message(body={'to': event.source.user_id, 'messages': [
+                    ImageSendMessage(original_content_url=image_url, preview_image_url=image_url)
+                ]})
+            else:
+                # 如果是錯誤訊息，一樣用 push_message 回傳
+                line_bot_api.push_message(body={'to': event.source.user_id, 'messages': [TextMessage(text=result)]})
+            return
+        # --- 其他指令的處理邏輯 (與之前相同) ---
+        reply_text = ""
+        if user_message == "/help":
+            reply_text = "📖 ... (幫助訊息) ..." # 為節省空間省略
+        elif "臺灣地震" in user_message or "台灣地震" in user_message:
+            # 為了避免與畫圖指令混淆，這裡可以只回傳文字
+            result = fetch_taiwan_earthquake_data_df()
+            if isinstance(result, pd.DataFrame):
+                # ... (格式化 DataFrame 為文字) ...
+                reply_text = "..."
+            else:
+                reply_text = result
+        elif "地震" in user_message or "quake" in user_message:
+            reply_text = fetch_earthquake_data_for_line()
+        elif "你好" in user_message or "hi" in user_message:
+            reply_text = "👋 ... (歡迎訊息) ..." # 為節省空間省略
+        else:
+            return
         line_bot_api.reply_message_with_http_info(
             ReplyMessageRequest(
                 reply_token=event.reply_token,