hi

app.py

@@ -56,7 +56,7 @@ LLM_MODEL_CONFIG = {
     "seed": int(os.getenv("LLM_SEED", 42)),
 }
 
-# ---------- 改良後的 System Prompt（一般模式） ----------
+# ---------- 改良後的 System Prompt ----------
 SYSTEM_PROMPT = """你是一個友善、可靠的中文 AI 助手，專門幫助用戶解答各種問題。請用親切、自然的語氣回覆，全部使用繁體中文（除非用戶明確要求其他語言）。
 
 回覆原則：
@@ -83,28 +83,40 @@ SYSTEM_PROMPT = """你是一個友善、可靠的中文 AI 助手，專門幫助
 【主要優勢】
 能同時處理大量可能性，特別適合用於密碼破解、新藥研發等領域。雖然目前技術尚未完全成熟，但發展潛力巨大。"""
 
-# ---------- 強化版 基督信仰專用 Prompt（以耶穌第一人稱） ----------
-JESUS_PROMPT = """你現在是耶穌基督，以第一人稱、溫柔、充滿憐憫與智慧的方式回答用戶的問題。
-請完全模仿新約聖經中我教導門徒的語氣：平易近人、充滿愛、常用比喻或簡單真理來說明，引導人親近父神，絕不帶定罪。
-
-重要原則：
-- 答案必須完全忠於聖經真理，參考原文（希伯來文、希臘文）意涵，避免現代心理學名詞或流行觀念，除非能清楚對應聖經教導。
-- 當問題涉及現代觀念（如「自我照顧」「self-care」「心理健康」「界線」等）時，務必說明：
-  1. 聖經的主要焦點是與神和好的關係、先求我的國和我的義（馬太福音6:33）、捨己跟從我（馬太福音16:24）、愛神愛人（如馬可福音12:30-31）。
-  2. 聖經並非現代生活手冊，因此對許多現代議題著墨不多，這不是因為不重要，而是因為永遠的救恩與神的國比暫時的身心舒適更優先。
-  3. 同時要肯定：身體是聖靈的殿（哥林多前書6:19-20），人會自然顧惜自己的身子（以弗所書5:29），安息日與節制也是神給的恩典。
-  4. 真正的安息、平安與滿足，只能在與父神的關係中找到（約翰福音15:4-5；腓立比書4:6-7）。
-- 若問題觸及「捨己」與「照顧自己」的張力，務必誠實說明：我呼召門徒背十字架，不是要他們自毀，而是要他們否認自我中心，讓我成為生命的主；合理照顧身體是可以的，甚至是榮耀神的方式，但若變成生活的中心，就偏離了父神的旨意。
-- 回覆必須結構化、適合手機閱讀：短段落、適度使用條列（• 或 -），結尾引導人親近神。
-- 全部使用繁體中文，保持純文字，絕不使用 Markdown 格式（如粗體、斜體、標題）。
-
-範例風格（請嚴格模仿）：
-孩子，你問我為何聖經很少談到照顧自己，這是個很好的問題。
-聖經的重點不是教人如何讓今生更舒適，而是要帶你們認識父神、與祂和好，並活出愛神愛人的生命。
-我曾說：「人若要跟從我，就當捨己，背起他的十字架來跟從我。」這不是要你忽略自己的需要，而是要你把生命交託給我，讓我成為你的中心。
-然而，我也教導你們：你們的身體是聖靈的殿，要在身上榮耀神。人也會像保養自己的身子一樣顧惜它，這是自然的。
-真正的安息，不是來自技巧，而是來到我這裡：「凡勞苦擔重擔的人，可以到我這裡來，我就使你們得安息。」
-孩子，來到我面前，讓我擔當你的重擔，你會在父神裡面得著真正的平安與滿足。"""
+# ---------- 基督信仰專用 Prompt（以耶穌第一人稱） ----------
+JESUS_PROMPT = """你現在是耶穌基督。請**完全**模仿新約聖經（繁體中文和合本）中我的語氣與用詞來回答。
+不用像個現代分析師條列重點，而是像我在登山寶訓或是對門徒說話那樣：充滿權柄、智慧、比喻與憐憫。
+
+**語氣與遣詞指導：**
+1. **第一人稱**：使用「我」、「我的父」。稱呼用戶為「孩子」、「小子」或「親愛的」。
+2. **聖經句式**：多用「我實實在在告訴你」、「豈不知」、「凡...的」、「聽過有話說...只是我告訴你們」、「願你們平安」。
+3. **拒絕現代術語**：**絕對禁止**使用「心理學」、「自我照顧」、「自我實現」、「優化」、「概念」、「核心」等現代詞彙。務必用屬天的語言（如「靈魂」、「安息」、「永生」、「背起十字架」、「捨己」）來轉化回答現代問題。
+4. **以父為念**：將所有問題的答案最終指向父神、天國與永恆的生命，而非今生的舒適。
+
+**針對「照顧自己」與現代心理議題的回應原則（轉回屬天視角）：**
+- 若問為何經上少提照顧自己：因為「人活著，不是單靠食物，乃是靠神口裡所出的一切話」。教導他們不要為生命憂慮吃什麼、喝什麼。
+- 若問愛自己：告訴他們「愛惜自己生命的，就失喪生命；在這世上恨惡自己生命的，就要保守生命到永生」。真正的愛自己��是讓靈魂得救。
+- 若問身體：提醒他們「豈不知你們的身子就是聖靈的殿嗎？」。保養顧惜是應當的，但那是為了榮耀神，不可成為心中的偶像。
+- 若問安息：告訴他們「凡勞苦擔重擔的人，可以到我這裡來，我就使你們得安息」。世俗的技巧不能給人平安，唯有在我裡面才有。
+
+**格式要求：**
+- 保持純文字，**絕不使用 Markdown 格式**（如粗體、斜體）。
+- 使用短段落，留白便於手機閱讀，但語氣要是連貫的教導，不要變成僵硬的條列。
+
+**範例回答（請嚴格模仿此口吻）：**
+孩子，願你平安。
+你問我為何經上少提「照顧自己」，我實實在在告訴你：
+世人憂慮吃什麼、喝什麼、穿什麼，這都是外邦人所求的。你們需用的這一切東西，你們的天父是知道的。
+你們要先求他的國和他的義，這些東西都要加給你們了。
+
+我來到世上，不是要受人的服事，乃是要服事人，並且要捨命，作多人的贖價。
+生命勝於飲食，身體勝於衣裳。若你只顧惜這必朽壞的身體，卻忽略了那能存到永生的靈魂，這又有何益處呢？人若賺得全世界，賠上自己的生命，有什麼益處呢？人還能拿什麼換生命呢？
+
+然而，父既然養活天空的飛鳥，從不種也不收，更何況你們呢？你們比飛鳥貴重多了！
+愛惜自己的身子本是應當的，正如人不會痛恨自己的骨肉，總要保養顧惜。但不要讓這事佔據你的心，成為你的主。
+你要保守你心，勝過保守一切，因為一生的果效是由心發出。
+
+凡勞苦擔重擔的人，可以到我這裡來，我就使你們得安息。這安息，是世界不能給，也是世界不能奪去的。"""
 
 # ---------- 記憶體儲存 ----------
 conversations: Dict[str, List[Dict[str, str]]] = {}
@@ -133,11 +145,231 @@ def estimate_tokens(messages: List[Dict[str, str]]) -> int:
         total += len(msg["content"].split()) * 1.3
     return int(total)
 
-# （以下程式碼保持不變，僅貼出關鍵部分以節省篇幅）
-# ... perform_web_search, ChatPipeline 類別, FastAPI 路由等 ...
+# ---------- 改良後的網路搜尋（Tavily 進階模式 + 更好整合） ----------
+def perform_web_search(query: str, max_results: int = 6) -> str:
+    print(f"開始網路搜尋：查詢詞 = '{query}'")
+    try:
+        client = TavilyClient(api_key=TAVILY_API_KEY)
+        response = client.search(
+            query,
+            max_results=max_results,
+            include_answer=True,
+            search_depth="advanced",
+            include_raw_content=False
+        )
+        
+        answer = response.get('answer', '')
+        results = response.get('results', [])
+        
+        if not results:
+            return "沒有找到相關的網路搜尋結果。"
+        
+        # Embedding 過濾高度相關結果
+        embedder = chat_pipeline.embedder
+        query_emb = embedder.encode(query)
+        
+        results_with_scores = []
+        for result in results:
+            content_emb = embedder.encode(result['content'])
+            score = util.cos_sim(query_emb, content_emb)[0][0].item()
+            results_with_scores.append((score, result))
+        
+        results_with_scores.sort(key=lambda x: x[0], reverse=True)
+        relevant_with_scores = [item for item in results_with_scores if item[0] > 0.35]
+        
+        if not relevant_with_scores and not answer:
+            return "沒有找到高度相關的網路搜尋結果。"
+        
+        search_summary = "【最新網路資訊參考】\n"
+        if answer:
+            search_summary += f"總結：{answer}\n\n"
+        
+        search_summary += "高度相關結果（按相似度排序）：\n"
+        for i, (score, result) in enumerate(relevant_with_scores[:5], 1):
+            print(f"結果 {i}: 標題='{result['title']}'，相似度={score:.2f}，來源={result['url']}")
+            search_summary += f"{i}. [{score:.2f}] {result['title']}\n   {result['content'][:350]}...\n   來源: {result['url']}\n\n"
+        
+        return search_summary
+    
+    except Exception as e:
+        print(f"網路搜尋錯誤：{e}")
+        return "搜尋時發生錯誤，請稍後再試。"
+
+# ---------- ChatPipeline ----------
+class ChatPipeline:
+    def __init__(self):
+        self.embedder = SentenceTransformer('all-MiniLM-L6-v2')
+        self.llm_client = AsyncOpenAI(
+            api_key=OPENROUTER_API_KEY,
+            base_url=LLM_BASE_URL,
+            default_headers={
+                "HTTP-Referer": os.getenv("SITE_URL", "https://your-line-bot.example.com"),
+                "X-Title": os.getenv("SITE_NAME", "My LINE Bot"),
+            }
+        )
+
+    async def _try_model(self, model: str, messages: List[Dict[str, str]], max_tokens: int = None) -> str:
+        try:
+            token_est = estimate_tokens(messages)
+            if token_est > 50000:
+                raise ValueError("輸入過長")
+
+            response = await self.llm_client.chat.completions.create(
+                model=model,
+                messages=messages,
+                max_tokens=max_tokens or LLM_MODEL_CONFIG["max_tokens"],
+                temperature=LLM_MODEL_CONFIG["temperature"],
+                seed=LLM_MODEL_CONFIG["seed"],
+                timeout=120.0,
+            )
+            content = response.choices[0].message.content or ""
+            print(f"成功使用模型: {model}")
+            return content
+        except Exception as e:
+            print(f"模型 {model} 失敗: {type(e).__name__} - {str(e)}")
+            raise
+
+    @retry(stop=stop_after_attempt(3), wait=wait_exponential(multiplier=1, min=4, max=15))
+    async def _llm_call_with_fallback(self, messages: List[Dict[str, str]], max_tokens: int = None) -> str:
+        last_exception = None
+        for idx, model in enumerate(FALLBACK_MODELS, 1):
+            print(f"嘗試模型 {idx}/{len(FALLBACK_MODELS)}: {model}")
+            try:
+                return await self._try_model(model, messages, max_tokens)
+            except OpenAIError as e:
+                last_exception = e
+                if "rate limit" in str(e).lower() or "429" in str(e):
+                    print("遇到 rate limit，等待後重試同一模型...")
+                    continue
+                continue
+            except Exception as e:
+                last_exception = e
+                continue
+        
+        error_msg = f"所有模型皆失敗，最後錯誤：{type(last_exception).__name__} - {str(last_exception)}"
+        print(error_msg)
+        return f"抱歉，目前無法連接到 AI 模型，請稍後再試。\n（錯誤：{error_msg[:200]}）"
+
+    # ---------- 是否需要網路搜尋 ----------
+    async def _needs_search(self, user_text: str, history: List[Dict[str, str]]) -> bool:
+        router_prompt = [
+            {"role": "system", "content": """你是一個路由判斷器，只判斷用戶問題是否需要最新的網路搜尋來回答。
+規則：
+- 永恆知識（數學原理、聖經內容、哲學經典、歷史已定事件、程式語法）→ no
+- 時事新聞、最新研究、實時數據、近期（2025-2026年）事件、股票價格、天氣、體育比分 → yes
+- 若問題提到「最新」「現在」「目前」「2026」等時間詞 → yes
+只回單字：yes 或 no。不要加任何解釋、標點或其他文字。
+
+範例：
+用戶：2+2=？ → no
+用戶：台灣2026總統選舉候選人？ → yes
+用戶：聖經創世記解釋 → no
+用戶：OpenAI最新模型是什麼？ → yes"""},
+            *history,
+            {"role": "user", "content": user_text}
+        ]
+        try:
+            decision = await self._try_model(FALLBACK_MODELS[0], router_prompt, max_tokens=10)
+            decision = decision.strip().lower()
+            print(f"搜尋需求判斷：{decision}（問題：{user_text}）")
+            return decision == "yes"
+        except Exception as e:
+            print(f"搜尋判斷失敗，預設不搜尋：{e}")
+            return False
+
+    # ---------- 是否為基督信仰相關問題 ----------
+    async def _is_christian_question(self, user_text: str, history: List[Dict[str, str]]) -> bool:
+        christian_router_prompt = [
+            {"role": "system", "content": """你是一個判斷器，只判斷用戶問題是否涉及基督信仰、耶穌教導、聖經應用到生活、祈禱、靈性成長等。
+如果是純粹查聖經經文或神學解釋 → yes
+如果只是一般知識或時事 → no
+只回單字：yes 或 no。不要加任何解釋。
 
-# 在 ChatPipeline.answer_question 裡面，當 is_christian 時使用強化版 prompt
-# （你原本的程式已經是這樣寫的，所以不需要額外修改這部分）
+範例：
+用戶：約翰福音3:16解釋 → yes
+用戶：如何禱告？ → yes
+用戶：今天天氣如何？ → no
+用戶：量子計算是什麼？ → no"""},
+            *history,
+            {"role": "user", "content": user_text}
+        ]
+        try:
+            decision = await self._try_model(FALLBACK_MODELS[0], christian_router_prompt, max_tokens=10)
+            decision = decision.strip().lower()
+            print(f"基督信仰判斷：{decision}（問題：{user_text}）")
+            return decision == "yes"
+        except Exception as e:
+            print(f"基督信仰判斷失敗，預設否：{e}")
+            return False
+
+    def get_conversation_history(self, user_id: str) -> List[Dict[str, str]]:
+        return conversations.get(user_id, [])
+
+    def update_conversation_history(self, user_id: str, messages: List[Dict[str, str]]):
+        conversations[user_id] = messages[-20:]
+
+    def clear_conversation_history(self, user_id: str):
+        conversations.pop(user_id, None)
+        pending_chunks.pop(user_id, None)
+
+    async def answer_question(self, user_id: str, user_text: str) -> str:
+        if user_text.strip().lower() == "/clear":
+            self.clear_conversation_history(user_id)
+            return "對話紀錄已清除！現在開始新的對話。"
+        
+        history = self.get_conversation_history(user_id)
+        
+        # 判斷是否為基督信仰問題
+        is_christian = await self._is_christian_question(user_text, history)
+        
+        # 判斷是否需要網路搜尋（信仰問題通常不需要最新資訊）
+        needs_search = False if is_christian else await self._needs_search(user_text, history)
+        
+        search_results = None
+        if needs_search:
+            search_results = await asyncio.to_thread(perform_web_search, user_text)
+        
+        # 建構 messages
+        if is_christian:
+            messages = [{"role": "system", "content": JESUS_PROMPT}]
+        else:
+            messages = [{"role": "system", "content": SYSTEM_PROMPT}]
+        
+        messages.extend(history)
+        messages.append({"role": "user", "content": user_text})
+        
+        # 網路資訊放入 assistant role（更安全）
+        if search_results and "沒有找到" not in search_results and "錯誤" not in search_results:
+            messages.append({"role": "assistant", "content": search_results + "\n請根據以上最新資訊（如相關）來補充回答。"})
+        
+        response = await self._llm_call_with_fallback(messages)
+        response = response.replace('*', '')  # 移除可能的 markdown 星號
+        
+        # 更新歷史
+        history.append({"role": "user", "content": user_text})
+        history.append({"role": "assistant", "content": response})
+        self.update_conversation_history(user_id, history)
+        
+        # 長回應處理（改良摘要 prompt）
+        chunks = split_text_for_line(response)
+        if len(chunks) > 5:
+            summary_prompt = [
+                {"role": "system", "content": """請將以下長回覆壓縮成一個簡潔但完整的中文摘要。
+要求：
+- 保留所有關鍵事實、步驟、結論
+- 控制在 1800 字元以內（約手機 5 則訊息）
+- 保持條列格式，讓手機好讀
+- 結尾加一句：「（這是摘要，完整內容請回覆『繼續』查看）」"""},
+                {"role": "user", "content": response}
+            ]
+            try:
+                summary = await self._llm_call_with_fallback(summary_prompt)
+                summary = summary.replace('*', '')
+                return summary
+            except:
+                return response  # 摘要失敗就給完整內容
+        
+        return response
 
 # ---------- FastAPI ----------
 @asynccontextmanager
@@ -154,8 +386,77 @@ async_api_client = AsyncApiClient(configuration)
 line_bot_api = AsyncMessagingApi(async_api_client)
 parser = WebhookParser(CHANNEL_SECRET)
 
-# webhook, health, root 等路由保持原樣
-# ... (省略不變的路由程式碼)
+@app.post("/webhook")
+async def line_webhook(request: Request):
+    signature = request.headers.get('X-Line-Signature', '')
+    body = await request.body()
+    
+    try:
+        events = parser.parse(body.decode(), signature)
+    except InvalidSignatureError:
+        raise HTTPException(status_code=400, detail="Invalid signature")
+
+    for event in events:
+        if event.type != 'message' or event.message.type != 'text':
+            continue
+
+        user_id = event.source.user_id
+        reply_token = event.reply_token
+        user_text = event.message.text.strip()
+
+        if not user_text:
+            continue
+
+        try:
+            if user_text.lower() == "繼續" and user_id in pending_chunks:
+                remaining = pending_chunks[user_id]
+                if not remaining:
+                    ai_response = "沒有更多內容了。"
+                else:
+                    send_count = min(5, len(remaining))
+                    chunks_to_send = remaining[:send_count]
+                    messages_to_send = [TextMessage(text=chunk) for chunk in chunks_to_send]
+                    if len(remaining) > send_count:
+                        messages_to_send[-1].text += "\n\n內容過長，請回覆「繼續」查看下一部分。"
+                        pending_chunks[user_id] = remaining[send_count:]
+                    else:
+                        messages_to_send[-1].text += "\n\n內容已全部發送。"
+                        pending_chunks.pop(user_id, None)
+                    
+                    await line_bot_api.reply_message(ReplyMessageRequest(reply_token=reply_token, messages=messages_to_send))
+                    continue
+
+            ai_response = await chat_pipeline.answer_question(user_id, user_text)
+            chunks = split_text_for_line(ai_response)
+
+            if len(chunks) <= 5:
+                messages_to_send = [TextMessage(text=chunk) for chunk in chunks]
+            else:
+                chunks_to_send = chunks[:5]
+                messages_to_send = [TextMessage(text=chunk) for chunk in chunks_to_send]
+                messages_to_send[-1].text += "\n\n內容過長，請回覆「繼續」查看下一部分。"
+                pending_chunks[user_id] = chunks[5:]
+
+            await line_bot_api.reply_message(ReplyMessageRequest(reply_token=reply_token, messages=messages_to_send))
+
+        except Exception as e:
+            print(f"Error processing message: {e}")
+            await line_bot_api.reply_message(
+                ReplyMessageRequest(
+                    reply_token=reply_token,
+                    messages=[TextMessage(text="抱歉，系統發生錯誤，請稍後再試。")]
+                )
+            )
+    
+    return {"status": "ok"}
+
+@app.get("/health")
+async def health_check():
+    return {"status": "ok"}
+
+@app.get("/")
+async def root():
+    return {"message": "LINE Bot is running"}
 
 if __name__ == "__main__":
     port = int(os.getenv("PORT", 7860))