Upload app.py

app.py

@@ -0,0 +1,183 @@
+from flask import Flask, request, abort
+from linebot.v3.webhook import WebhookParser, WebhookHandler
+from linebot.v3.webhooks import MessageEvent, TextMessageContent
+from linebot.v3.messaging import MessagingApi, Configuration, ApiClient
+from linebot.v3.messaging.models import (
+    TextMessage, ReplyMessageRequest,
+    FlexMessage, FlexBubble, FlexBox, FlexText, FlexButton, URIAction,
+    QuickReply, QuickReplyItem, LocationAction
+)
+from linebot.v3.exceptions import InvalidSignatureError
+
+import sqlite3
+import requests
+import os
+from dotenv import load_dotenv
+
+load_dotenv()
+
+app = Flask(__name__)
+
+CHANNEL_SECRET = os.getenv("CHANNEL_SECRET")
+CHANNEL_ACCESS_TOKEN = os.getenv("CHANNEL_ACCESS_TOKEN")
+GOOGLE_MAP_API_KEY = os.getenv("GOOGLE_MAP_API_KEY")
+
+configuration = Configuration(access_token=CHANNEL_ACCESS_TOKEN)
+parser = WebhookParser(CHANNEL_SECRET)
+handler = WebhookHandler(CHANNEL_SECRET)
+
+BASE_DIR = os.path.dirname(os.path.abspath(__file__))
+DB_PATH = os.path.join(BASE_DIR, "medicine.db")
+
+@app.route("/callback", methods=["POST"])
+def callback():
+    signature = request.headers.get("X-Line-Signature", "")
+    body = request.get_data(as_text=True)
+
+    try:
+        events = parser.parse(body, signature)
+    except InvalidSignatureError:
+        abort(400)
+    except Exception as e:
+        print("Webhook parse error:", e)
+        abort(400)
+
+    with ApiClient(configuration) as api_client:
+        messaging_api = MessagingApi(api_client)
+
+        for event in events:
+            if event.type == "message":
+                if event.message.type == "text":
+                    user_input = event.message.text.strip()
+                    print("📨 收到訊息：", user_input)
+
+                    if user_input == "查詢藥品":
+                        reply_text = "請輸入藥品名稱，例如：口服感冒藥"
+                        reply_request = ReplyMessageRequest(
+                            reply_token=event.reply_token,
+                            messages=[TextMessage(text=reply_text)]
+                        )
+                        messaging_api.reply_message(reply_message_request=reply_request)
+
+                    elif "查詢藥局" in user_input:
+                        quick_reply = QuickReply(
+                            items=[QuickReplyItem(action=LocationAction(label="傳送我的位置"))]
+                        )
+                        reply_request = ReplyMessageRequest(
+                            reply_token=event.reply_token,
+                            messages=[TextMessage(text="請點選下方按鈕傳送你的位置，我才能幫你找附近藥局喔～", quick_reply=quick_reply)]
+                        )
+                        messaging_api.reply_message(reply_message_request=reply_request)
+
+                    else:
+                        # 直接當作藥品名稱查詢
+                        medicine_name = user_input
+                        try:
+                            conn = sqlite3.connect(DB_PATH)
+                            cursor = conn.cursor()
+                            query = """
+                                SELECT DISTINCT 中文品名, 英文品名, 適應症
+                                FROM drugs
+                                WHERE 中文品名 LIKE ?
+                                LIMIT 3
+                            """
+                            cursor.execute(query, ('%' + medicine_name + '%',))
+                            rows = cursor.fetchall()
+                            conn.close()
+
+                            if not rows:
+                                reply_text = f"找不到與「{medicine_name}」相關的藥品。"
+                            else:
+                                reply_text = ""
+                                for row in rows:
+                                    reply_text += (
+                                        f"🔹 中文品名：{row[0]}\n"
+                                        f"📌 英文品名：{row[1]}\n"
+                                        f"📄 適應症：{row[2]}\n\n"
+                                    )
+                        except Exception as e:
+                            reply_text = f"⚠️ 查詢資料時發生錯誤：{str(e)}"
+
+                        reply_request = ReplyMessageRequest(
+                            reply_token=event.reply_token,
+                            messages=[TextMessage(text=reply_text.strip())]
+                        )
+                        messaging_api.reply_message(reply_message_request=reply_request)
+
+                elif event.message.type == "location":
+                    user_lat = event.message.latitude
+                    user_lng = event.message.longitude
+
+                    nearby_url = (
+                        f"https://maps.googleapis.com/maps/api/place/nearbysearch/json?"
+                        f"location={user_lat},{user_lng}&radius=1000&type=pharmacy&key={GOOGLE_MAP_API_KEY}"
+                    )
+                    nearby_res = requests.get(nearby_url).json()
+
+                    if not nearby_res.get('results'):
+                        reply_request = ReplyMessageRequest(
+                            reply_token=event.reply_token,
+                            messages=[TextMessage(text="附近找不到藥局")]
+                        )
+                        messaging_api.reply_message(reply_message_request=reply_request)
+                        continue
+
+                    place = nearby_res['results'][0]
+                    place_id = place['place_id']
+                    name = place.get('name', '藥局名稱未知')
+                    location = place['geometry']['location']
+                    dest_lat, dest_lng = location['lat'], location['lng']
+
+                    details_url = (
+                        f"https://maps.googleapis.com/maps/api/place/details/json?"
+                        f"place_id={place_id}&fields=name,formatted_phone_number&key={GOOGLE_MAP_API_KEY}"
+                    )
+                    details_res = requests.get(details_url).json()
+                    phone = details_res.get('result', {}).get('formatted_phone_number', '電話不詳')
+
+                    dist_url = (
+                        f"https://maps.googleapis.com/maps/api/distancematrix/json?"
+                        f"origins={user_lat},{user_lng}&destinations={dest_lat},{dest_lng}&key={GOOGLE_MAP_API_KEY}"
+                    )
+                    dist_res = requests.get(dist_url).json()
+                    distance = dist_res['rows'][0]['elements'][0]['distance']['text']
+
+                    map_url = f"https://www.google.com/maps/search/?api=1&query={dest_lat},{dest_lng}"
+
+                    bubble = FlexBubble(
+                        body=FlexBox(
+                            layout="vertical",
+                            contents=[
+                                FlexText(text=name, weight="bold", size="lg"),
+                                FlexText(text=f"電話：{phone}", size="sm", color="#555555"),
+                                FlexText(text=f"距離：{distance}", size="sm", color="#777777"),
+                            ],
+                        ),
+                        footer=FlexBox(
+                            layout="vertical",
+                            contents=[
+                                FlexButton(
+                                    style="link",
+                                    height="sm",
+                                    action=URIAction(label="地圖導航", uri=map_url),
+                                )
+                            ],
+                        ),
+                    )
+
+                    flex_message = FlexMessage(
+                        alt_text="附近藥局推薦",
+                        contents=bubble
+                    )
+
+                    reply_request = ReplyMessageRequest(
+                        reply_token=event.reply_token,
+                        messages=[flex_message]
+                    )
+                    messaging_api.reply_message(reply_message_request=reply_request)
+
+    return "OK"
+
+
+if __name__ == "__main__":
+    app.run(debug=True, port=8000)