adjust parallel search and rerank

app/message_processor.py

@@ -147,7 +147,9 @@ class MessageProcessor:
 
         conv.update({
             'originalcommand': command, 'originalcontent': remaining_text, 'originalvehicle': ','.join(keywords),
-            'originalaction': ' '.join(tu_khoa_list), 'originalpurpose': muc_dich, 'originalquestion': cau_hoi or ""
+            # Sửa lỗi: Dùng separator ';;;' để nối các cụm từ khóa,
+            # tránh bị tách sai ở bước sau.
+            'originalaction': ';;;'.join(tu_khoa_list), 'originalpurpose': muc_dich, 'originalquestion': cau_hoi or ""
         })
 
         muc_dich_to_use = muc_dich or conv.get('originalpurpose')
@@ -384,7 +386,10 @@ class MessageProcessor:
         action_keywords_str = conv.get('originalaction', '')
         question = conv.get('originalquestion', '')
 
-        tu_khoa_list = action_keywords_str.split()
+        # Sửa lỗi: Tách các cụm từ khóa bằng separator ';;;' thay vì khoảng trắng.
+        # Điều này đảm bảo mỗi từ khóa là một cụm từ hoàn chỉnh.
+        # Lọc bỏ các chuỗi rỗng có thể xuất hiện nếu action_keywords_str rỗng.
+        tu_khoa_list = [kw.strip() for kw in action_keywords_str.split(';;;') if kw.strip()]
 
         if not tu_khoa_list and not question:
              return "Để tra cứu mức phạt, bạn vui lòng cung cấp hành vi vi phạm nhé."
@@ -402,7 +407,7 @@ class MessageProcessor:
             seen_ids = set()
             for reranked_list in list_of_reranked_results:
                 for match in reranked_list:
-                    match_id = match.get('id')
+                    match_id = match.get('doc_id')
                     if match_id and match_id not in seen_ids:
                         combined_matches.append(match)
                         seen_ids.add(match_id)