LINE-ROBOT

Sleeping

App Files Files Community

cwadayi commited on Aug 15, 2025

Commit

3387e96

verified ·

1 Parent(s): d422181

Update app.py

Browse files

Files changed (1) hide show

app.py +44 -50

app.py CHANGED Viewed

@@ -17,13 +17,12 @@ 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')
@@ -33,20 +32,21 @@ 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"}
@@ -64,7 +64,6 @@ def fetch_earthquake_data_for_line():
     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')
@@ -84,33 +83,18 @@ def fetch_taiwan_earthquake_data_df():
         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 路由 ---
@@ -124,7 +108,7 @@ def callback():
         abort(400)
     return 'OK'
-# --- LINE 訊息處理 (有修改) ---
 @handler.add(MessageEvent, message=TextMessageContent)
 def handle_message(event):
     user_message = event.message.text.strip().lower()
@@ -132,48 +116,58 @@ def handle_message(event):
     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

 # --- 環境變數 ---
 CHANNEL_ACCESS_TOKEN = os.getenv('CHANNEL_ACCESS_TOKEN')
 CHANNEL_SECRET = os.getenv('CHANNEL_SECRET')
+# --- ✨✨✨ 修改點：讀取新的 Secret 名稱 ✨✨✨ ---
+HF_SPACE_URL = os.getenv('SPACEURL')
 # --- Flask & LINE Bot 初始化 ---
 app = Flask(__name__)
 if not os.path.exists('static'):
     os.makedirs('static')
 # --- 歡迎頁面 & 靜態圖片服務路由 ---
 @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>
+    """
 @app.route('/static/<path:filename>')
 def serve_static(filename):
     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"}
     except Exception as e: return f"❌ 查詢失敗: {e}"
 def fetch_taiwan_earthquake_data_df():
     now = datetime.now()
     start_of_year = now.replace(month=1, day=1).strftime('%Y-%m-%d')
     today_str = now.strftime('%Y-%m-%d')
         return pd.DataFrame(earthquake_list)
     except Exception as e: return f"❌ 查詢失敗: {e}"
+# --- 繪圖函式 ---
 def create_and_save_map(df):
     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)
+    fig.write_image(filepath, scale=2)
     return filename
 # --- Flask Webhook 路由 ---
         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:
+            line_bot_api.reply_message_with_http_info(ReplyMessageRequest(
                 reply_token=event.reply_token, messages=[TextMessage(text="🗺️ 收到指令！正在繪製地震分佈圖，請稍候...")]
             ))
             result = fetch_taiwan_earthquake_data_df()
             if isinstance(result, pd.DataFrame):
                 filename = create_and_save_map(result)
                 image_url = f"{HF_SPACE_URL}/static/{filename}"
                 line_bot_api.push_message(body={'to': event.source.user_id, 'messages': [
                     ImageSendMessage(original_content_url=image_url, preview_image_url=image_url)
                 ]})
             else:
                 line_bot_api.push_message(body={'to': event.source.user_id, 'messages': [TextMessage(text=result)]})
             return
         reply_text = ""
         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:
             result = fetch_taiwan_earthquake_data_df()
             if isinstance(result, pd.DataFrame):
+                count = len(result)
+                reply_text = f"🇹🇼 今年 ({datetime.now().year}年) 台灣區域顯著地震 (M≥5.0)，共 {count} 筆:\n{'-'*20}\n"
+                for index, row in result.iterrows():
+                    time_str = row['time'].strftime('%Y-%m-%d %H:%M')
+                    reply_text += f"震級: {row['magnitude']:.1f} | 時間: {time_str} (UTC)\n地點: {row['place']}\n\n"
+                    if len(reply_text) > 4500:
+                        reply_text += "... (資料過多，僅顯示部分)"
+                        break
             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 = "👋 你好！我是地震查詢機器人。\n\n輸入 /help 查看所有指令。"
         else:
             return