fix duplicate message

app/facebook.py

@@ -54,6 +54,8 @@ class FacebookClient:
         Input: page_access_token (str), recipient_id (str), message (str)
         Output: dict (response từ Facebook API)
         """
+
+        logger.debug(f"Đang gửi tin nhắn đến Facebook Messenger....\n\t{message}")
         url = f"https://graph.facebook.com/v18.0/me/messages?access_token={page_access_token}"
         
         payload = {
@@ -62,7 +64,6 @@ class FacebookClient:
         }
 
         try:
-            logger.debug(f"Đang gửi tin nhắn đến Facebook Messenger....\n\t{message}")
             response = await self._client.post(url, json=payload)
             response.raise_for_status()
             return response.json()

app/main.py

@@ -286,7 +286,9 @@ async def process_message(message_data: Dict[str, Any]):
         hanh_vi_vi_pham = hanh_vi_vi_pham.strip()
 
     logger.info(f"[DEBUG] Phương tiện: {keywords} - Hành vi: {hanh_vi_vi_pham} - Mục đích: {muc_dich}")
-
+    
+    await facebook_client.send_message(page_token, sender_id, "Mình đang phân tích câu hỏi của bạn. Sắp xong rồi\nCảm ơn sự kiên nhẫn của bạn!")
+    
     # 4. Update lại conversation với thông tin đầy đủ
     update_kwargs = {
         'conversation_id': conv['conversation_id'],
@@ -310,10 +312,10 @@ async def process_message(message_data: Dict[str, Any]):
     # 5. Xử lý logic nghiệp vụ
     response = await process_business_logic(conv, page_token)
     logger.info(f"[DEBUG] Message history sau khi process: {conv}")
-    
+
     # 6. Gửi response và cập nhật final state
     await facebook_client.send_message(page_token, sender_id, response)
-    await loop.run_in_executor(executor, lambda: sheets_client.log_conversation(**update_kwargs))
+    await loop.run_in_executor(executor, lambda: sheets_client.log_conversation(**conv))
     return
 
 async def process_business_logic(log_kwargs: Dict[str, Any], page_token: str) -> str:
@@ -423,9 +425,9 @@ async def format_search_results(question: str, matches: List[Dict[str, Any]]) ->
     prompt = (
         "Bạn là một trợ lý AI có kiến thức pháp luật, hãy trả lời câu hỏi dựa trên các đoạn luật sau. "
         "Chỉ sử dụng thông tin có trong các đoạn, không tự đoán.\n"
-        f"Các đoạn luật liên quan:\n{full_result_text}"
-        "\nHãy trả lời ngắn gọn, dễ hiểu, trích dẫn rõ ràng thông tin từ các đoạn luật nếu cần."
-        f"\nCâu hỏi của người dùng: {question}\n"
+        f"\nCác đoạn luật liên quan:\n{full_result_text}"
+        "\n\nHãy trả lời ngắn gọn, dễ hiểu, trích dẫn rõ ràng thông tin từ các đoạn luật nếu cần."
+        f"\n\nCâu hỏi của người dùng: {question}\n"
     )
 
     logger.info(f"[DEBUG] prompt:\n {prompt}")
@@ -435,6 +437,8 @@ async def format_search_results(question: str, matches: List[Dict[str, Any]]) ->
         answer = await llm_client.generate_text(prompt)
         if answer and answer.strip():
             return answer.strip()
+        else:
+            logger.error(f"LLM không trả về câu trả lời phù hợp: \n\tanswer: {answer}")
     except Exception as e:
         logger.error(f"LLM không sẵn sàng: {e}\n{traceback.format_exc()}")
     # Fallback: trả về tổng hợp các đoạn luật như cũ