update message flow

app/constants.py

@@ -128,35 +128,7 @@ VIETNAMESE_STOP_PHRASES = [
     # ... thêm các từ khác bạn muốn loại bỏ
 ]
 
-# Batch status messages for reranker Facebook notifications
-BATCH_STATUS_MESSAGES = [
-    "Mình đang sắp xếp lại để nội dung rõ ràng hơn",
-    "Thông tin mình đang hệ thống lại cho mạch lạc hơn",
-    "Mình đang tổ chức lại các ý chính cho dễ theo dõi",
-    "Hiện tại mình đang chỉnh sửa lại cấu trúc thông tin",
-    "Mình đang rà soát và sắp xếp lại nội dung đã có",
-    "Các phần thông tin đang được mình sắp lại theo thứ tự hợp lý",
-    "Mình đang gom các ý liên quan để thống nhất nội dung",
-    "Thông tin đang được mình sắp xếp lại để tránh trùng lặp",
-    "Mình đang điều chỉnh bố cục để nội dung liền mạch hơn",
-    "Mình đang tinh gọn lại thông tin cho súc tích và dễ hiểu"
-]
-
-# Summary status messages for Facebook notifications when summarizing/answering
-SUMMARY_STATUS_MESSAGES = [
-    "Mình đang tổng hợp lại để đưa ra câu trả lời rõ ràng nhất",
-    "Hiện tại mình đang rà lại các thông tin để chốt phương án",
-    "Mình đang đối chiếu dữ liệu để đưa ra kết luận cuối cùng",
-    "Mình đang gom lại toàn bộ nội dung để trả lời dứt khoát",
-    "Mình đang hoàn thiện phần tổng hợp để có câu trả lời chính xác",
-    "Thông tin đang được mình tổng hợp lại để phản hồi đầy đủ",
-    "Mình đang chuẩn bị câu trả lời cuối cùng dựa trên các dữ liệu đã có",
-    "Mình đang xử lý thông tin đầu vào để đưa ra phương án phù hợp nhất",
-    "Mình đang hoàn tất bước tổng hợp để có phản hồi cụ thể",
-    "Mình đang chốt lại các điểm chính để trả lời một cách trọn vẹn"
-]
-
-# Processing status messages for Facebook notifications when processing/searching
+# Processing status messages for Facebook notifications when processing
 PROCESSING_STATUS_MESSAGES = [
     "Okie, mình kiểm tra lại thông tin liền nha!",
     "Để mình rà lại chút, xong mình phản hồi ngay.",
@@ -177,6 +149,20 @@ PROCESSING_STATUS_MESSAGES = [
     "Tin nhắn đã đến, mình đang cân nhắc cách trả lời cho tinh tế hơn."
 ]
 
+# Processing status messages for Facebook notifications when starting searching
+START_SEARCHING_MESSAGES = [
+    "Mình đã phân tích sơ bộ và đang tra cứu thêm để làm rõ các điểm liên quan.",
+    "Dựa trên phân tích ban đầu, mình đang tiếp tục đào sâu để có thông tin đầy đủ.",
+    "Mình đã xác định được vài hướng chính và đang kiểm tra chi tiết từng phần.",
+    "Mình đã phác thảo sơ bộ nội dung và đang mở rộng tìm hiểu để củng cố câu trả lời.",
+    "Phần chính mình đã nắm được, hiện đang tra cứu thêm để hoàn thiện phản hồi.",
+    "Mình đang lần theo các manh mối đã phân tích để tìm câu trả lời phù hợp nhất.",
+    "Dựa trên những gì đã phân tích, mình đang tìm thêm nguồn để kiểm chứng.",
+    "Mình đã xác định các yếu tố chính và đang rà thêm thông tin để trả lời chắc chắn hơn.",
+    "Phân tích bước đầu đã rõ, giờ mình đang đối chiếu lại với dữ liệu liên quan.",
+    "Mình đang tiếp tục mở rộng từ kết quả phân tích ban đầu để đảm bảo phản hồi toàn diện."
+]
+
 # Found regulations status messages for Facebook notifications when regulations are found
 FOUND_REGULATIONS_MESSAGES = [
     "Mình có thấy một vài quy định liên quan, đang xác minh lại và sẽ phản hồi sớm.",
@@ -191,5 +177,33 @@ FOUND_REGULATIONS_MESSAGES = [
     "Thông tin đang được mình kiểm tra lại lần cuối, mình sẽ cập nhật sớm nhất nhé."
 ]
 
+# Batch status messages for reranker Facebook notifications
+BATCH_STATUS_MESSAGES = [
+    "Mình đang sắp xếp lại để nội dung rõ ràng hơn",
+    "Thông tin mình đang hệ thống lại cho mạch lạc hơn",
+    "Mình đang tổ chức lại các ý chính cho dễ theo dõi",
+    "Hiện tại mình đang chỉnh sửa lại cấu trúc thông tin",
+    "Mình đang rà soát và sắp xếp lại nội dung đã có",
+    "Các phần thông tin đang được mình sắp lại theo thứ tự hợp lý",
+    "Mình đang gom các ý liên quan để thống nhất nội dung",
+    "Thông tin đang được mình sắp xếp lại để tránh trùng lặp",
+    "Mình đang điều chỉnh bố cục để nội dung liền mạch hơn",
+    "Mình đang tinh gọn lại thông tin cho súc tích và dễ hiểu"
+]
+
+# Summary status messages for Facebook notifications when summarizing/answering
+SUMMARY_STATUS_MESSAGES = [
+    "Mình ��ang tổng hợp lại để đưa ra câu trả lời rõ ràng nhất",
+    "Hiện tại mình đang rà lại các thông tin để chốt phương án",
+    "Mình đang đối chiếu dữ liệu để đưa ra kết luận cuối cùng",
+    "Mình đang gom lại toàn bộ nội dung để trả lời dứt khoát",
+    "Mình đang hoàn thiện phần tổng hợp để có câu trả lời chính xác",
+    "Thông tin đang được mình tổng hợp lại để phản hồi đầy đủ",
+    "Mình đang chuẩn bị câu trả lời cuối cùng dựa trên các dữ liệu đã có",
+    "Mình đang xử lý thông tin đầu vào để đưa ra phương án phù hợp nhất",
+    "Mình đang hoàn tất bước tổng hợp để có phản hồi cụ thể",
+    "Mình đang chốt lại các điểm chính để trả lời một cách trọn vẹn"
+]
+
 SHEET_RANGE = 'chat!A2:N'
-VERSION_NUMBER = 123456799
+VERSION_NUMBER = 123456800

app/message_processor.py

@@ -3,7 +3,7 @@ import asyncio
 import traceback
 import json
 from loguru import logger
-from .constants import SUMMARY_STATUS_MESSAGES, PROCESSING_STATUS_MESSAGES, FOUND_REGULATIONS_MESSAGES, BATCH_STATUS_MESSAGES
+from .constants import START_SEARCHING_MESSAGES, SUMMARY_STATUS_MESSAGES, PROCESSING_STATUS_MESSAGES, FOUND_REGULATIONS_MESSAGES, BATCH_STATUS_MESSAGES
 from .utils import get_random_message
 from .facebook import FacebookClient
 from app.config import get_settings
@@ -146,6 +146,8 @@ class MessageProcessor:
         logger.info(f"[DEBUG] Định hướng mục đích xử lý: {muc_dich_to_use}")
         conversation_context = self.get_llm_history(history)
 
+        # Gửi tin nhắn trước khi tiến hành tìm kiếm
+        asyncio.create_task(self.facebook.send_message(message=get_random_message(START_SEARCHING_MESSAGES)))
         response = None
         handlers = {
             "hỏi về mức phạt": self.handle_muc_phat,
@@ -257,7 +259,7 @@ class MessageProcessor:
             if hpbsnoidung: full_result_text += f"\n- Hình phạt bổ sung: {hpbsnoidung}"
             bpkpnoidung = arr_to_str(match.get('bpkpnoidung'), sep="; ")
             if bpkpnoidung: full_result_text += f"\n- Biện pháp khắc phục: {bpkpnoidung}"
-            if match.get('impounding'): full_result_text += f"\n- Tạm giữ phương tiện: 07 ngày"
+            if match.get('cr_impounding'): full_result_text += f"\n- Tạm giữ phương tiện: 07 ngày"
         
         prompt = (
             "Bạn là một trợ lý pháp lý AI chuyên nghiệp. Nhiệm vụ của bạn là tổng hợp thông tin từ hai nguồn: **Lịch sử trò chuyện** và **Các đoạn luật liên quan** để đưa ra một câu trả lời duy nhất, liền mạch và tự nhiên cho người dùng.\n\n"