Merge branch 'main' of hf-trada:spaces/TradaAI/Chatopus

app/constants.py

@@ -192,4 +192,4 @@ FOUND_REGULATIONS_MESSAGES = [
 ]
 
 SHEET_RANGE = 'chat!A2:N'
-VERSION_NUMBER = 123456793
+VERSION_NUMBER = 123456794

app/message_processor.py

@@ -62,14 +62,14 @@ class MessageProcessor:
             'originalpurpose': '', 'originalquestion': '', 'systemresponse': '',
             'timestamp': [timestamp], 'isdone': False
         }
-        
+
         logger.info(f"[DEBUG] Message cơ bản: {log_kwargs}")
         conv = await loop.run_in_executor(None, lambda: sheets_client.log_conversation(**log_kwargs))
         if not conv:
             logger.error("Không thể tạo conversation mới!")
             return
         logger.info(f"[DEBUG] Message history sau lần ghi đầu: {conv}")
-        
+                
         conv['timestamp'] = self.flatten_timestamp(conv['timestamp'])
         if timestamp not in conv['timestamp']:
             conv['timestamp'].append(timestamp)
@@ -84,7 +84,6 @@ class MessageProcessor:
             return
         
         try:
-            # TỐI ƯU 1: Gửi tin nhắn trạng thái và không cần chờ đợi
             asyncio.create_task(self.facebook.send_message(message=get_random_message(PROCESSING_STATUS_MESSAGES)))
         except Exception as e:
             if "expired" in str(e).lower():
@@ -153,19 +152,16 @@ class MessageProcessor:
                 response = "Vui lòng cung cấp thêm thông tin và gõ lệnh \\xong khi hoàn tất."
                 conv['isdone'] = False
 
-        # TỐI ƯU 2: Gửi câu trả lời cuối cùng và không cần chờ
         asyncio.create_task(self.facebook.send_message(message=response))
         
         conv['systemresponse'] = response
         
         logger.info(f"Chuẩn bị ghi/cập nhật dữ liệu cuối cùng vào sheet: {conv}")
-        # TỐI ƯU 3: Ghi log cuối cùng và không cần chờ, cho phép webhook trả về ngay
-        asyncio.create_task(
-            loop.run_in_executor(None, lambda: sheets_client.log_conversation(**conv))
-        )
+        
+        loop.run_in_executor(None, lambda: sheets_client.log_conversation(**conv))
+        
         return
     
-    # ... (các hàm get_latest_timestamp, get_llm_history, flatten_timestamp, normalize_vehicle_keyword không đổi) ...
     def get_latest_timestamp(self,ts_value):
         if isinstance(ts_value, (int, float)): return int(ts_value)
         if isinstance(ts_value, str):
@@ -217,7 +213,6 @@ class MessageProcessor:
         if not matches:
             return "Không tìm thấy kết quả phù hợp."
 
-        # TỐI ƯU: Gửi tin nhắn trạng thái và không chờ
         asyncio.create_task(self.facebook.send_message(message=get_random_message(FOUND_REGULATIONS_MESSAGES)))
 
         try:
@@ -254,7 +249,6 @@ class MessageProcessor:
             "### Trả lời:"
         )
         
-        # TỐI ƯU: Gửi tin nhắn trạng thái và không chờ
         asyncio.create_task(self.facebook.send_message(message=f"{get_random_message(SUMMARY_STATUS_MESSAGES)}"))
         
         try:
@@ -267,7 +261,7 @@ class MessageProcessor:
         except Exception as e:
             logger.error(f"LLM không sẵn sàng: {e}\n{traceback.format_exc()}")
         
-        return "Dựa trên thông tin bạn cung cấp..." # Fallback
+        return "Dựa trên thông tin bạn cung cấp, tôi đã tìm thấy một số quy định liên quan. Tuy nhiên, tôi đang gặp chút khó khăn trong việc tóm tắt. Bạn vui lòng tham khảo nội dung chi tiết trong các văn bản luật nhé."
 
     async def create_facebook_post(self, page_token: str, sender_id: str, history: List[Dict[str, Any]]) -> str:
         logger.info(f"[MOCK] Creating Facebook post for sender_id={sender_id} with history={history}")
@@ -290,7 +284,6 @@ class MessageProcessor:
             loop = asyncio.get_event_loop()
             match_count = get_settings().match_count
             
-            # TỐI ƯU 4: Chạy tác vụ I/O đồng bộ trong executor để không chặn event loop
             matches = await loop.run_in_executor(
                 None,
                 lambda: self.channel.supabase.match_documents(
@@ -353,7 +346,6 @@ class MessageProcessor:
             'Với các thông tin sau: "Bạn có tên là WeThoong AI, là trợ lý giao thông thông minh. Bạn được anh Viet Cat tạo ra và facebook cá nhân của anh ấy là https://facebook.com/vietcat". '
             'Không được trả lời bạn là AI của Google, OpenAI, hay bất kỳ hãng nào khác. '
             'Hãy trả lời thông minh, hài hước, ngắn gọn cho câu hỏi sau:\n'
-            # --- SỬA LỖI CÚ PHÁP TẠI ĐÂY ---
             f'Câu hỏi:\n"{conv["originaltext"]}"'
         )
         try: