update message flow

app/config.py

@@ -38,8 +38,8 @@ class Settings(BaseSettings):
     log_level: str = os.getenv("LOG_LEVEL", "DEBUG") or "DEBUG"
 
     # Search Configuration
-    match_count: int = int(os.getenv("MATCH_COUNT", "15")) or 15
-    max_docs_to_rerank: int = int(os.getenv("MAX_DOCS_TO_RERANK", "15")) or 15
+    match_count: int = int(os.getenv("MATCH_COUNT", "20")) or 20
+    max_docs_to_rerank: int = int(os.getenv("MAX_DOCS_TO_RERANK", "20")) or 20
 
     # Gemini Configuration
     # Hỗ trợ nhiều API key và model cho Gemini

app/message_processor.py

@@ -395,8 +395,12 @@ class MessageProcessor:
             logger.info(f"[DEBUG] tạo embedding: {action}")
             embedding = await self.channel.embedder.create_embedding(action)
             logger.info(f"[DEBUG] embedding: {embedding[:5]} ... (total {len(embedding)})")
+            # Lấy match_count từ config
+            from app.config import get_settings
+            match_count = get_settings().match_count
             matches = self.channel.supabase.match_documents(
                 embedding,
+                match_count=match_count,
                 # vehicle_keywords=keywords,
                 user_question=action
             )

app/reranker.py

@@ -101,9 +101,10 @@ class Reranker:
         # Không giới hạn content length, giữ nguyên nội dung luật
         docs_content = []
         for i, doc in enumerate(docs):
-            tieude = (doc.get('tieude') or '').strip()
-            noidung = (doc.get('noidung') or '').strip()
-            content = f"{tieude} {noidung}".strip()
+            # tieude = (doc.get('tieude') or '').strip()
+            # noidung = (doc.get('noidung') or '').strip()
+            # content = f"{tieude} {noidung}".strip()
+            content = (doc.get('fullcontent') or '').strip()
             docs_content.append(f"{i+1}. {content}")
         
         batch_prompt = (