refactor message flow on purposes

app/message_processor.py

@@ -182,9 +182,78 @@ class MessageProcessor:
             if value not in (None, "", []) and conv.get(key) in (None, "", []):
                 conv[key] = value
         logger.info(f"[DEBUG] Message history update cuối cùng: {conv}")
-        # 5. Xử lý logic nghiệp vụ
-        response = await self.process_business_logic(conv, page_token)
-        logger.info(f"[DEBUG] Message history sau khi process: {conv}")
+
+        # 5. Rẽ nhánh xử lý theo mục đích (muc_dich)
+        # Lấy muc_dich từ history nếu có, hoặc từ message mới phân tích
+        muc_dich_to_use = None
+        if history and conv.get('originalpurpose'):
+            muc_dich_to_use = conv.get('originalpurpose')
+        else:
+            muc_dich_to_use = muc_dich
+        logger.info(f"[DEBUG] Định hướng mục đích xử lý: {muc_dich_to_use}")
+
+        response = None
+        if not command:
+            if muc_dich_to_use == "hỏi về mức phạt":
+                # Giữ nguyên luồng cũ cho hỏi về mức phạt
+                vehicle = conv.get('originalvehicle', '')
+                action = conv.get('originalaction', '')
+                keywords = [kw.strip() for kw in vehicle.split(',') if kw.strip()]
+                if keywords:
+                    if action:
+                        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)})")
+                        matches = self.channel.supabase.match_documents(
+                            embedding,
+                            vehicle_keywords=keywords,
+                            user_question=action
+                        )
+                        logger.info(f"[DEBUG] matches: {matches}")
+                        if matches:
+                            response = await self.format_search_results(message_text, matches, page_token, sender_id)
+                        else:
+                            response = "Xin lỗi, tôi không tìm thấy thông tin phù hợp."
+                    else:
+                        logger.info(f"[DEBUG] Không có hành vi vi phạm: {message_text}")
+                        response = "Xin lỗi, tôi không tìm thấy thông tin về hành vi vi phạm trong câu hỏi của bạn."
+                    conv['isdone'] = True
+                else:
+                    response = "Vui lòng cho biết loại phương tiện bạn cần tìm (xe máy, ô tô...)"
+                    conv['isdone'] = False
+            elif muc_dich_to_use == "hỏi về quy tắc giao thông":
+                # Dùng LLM để trả lời câu hỏi về quy tắc giao thông
+                answer = await self.channel.llm.generate_text(message_text)
+                response = answer.strip() if answer and answer.strip() else "[Đang phát triển] Tính năng trả lời về quy tắc giao thông sẽ sớm có mặt."
+                conv['isdone'] = True
+            elif muc_dich_to_use == "hỏi về báo hiệu đường bộ":
+                # Dùng LLM để trả lời câu hỏi về báo hiệu đường bộ
+                answer = await self.channel.llm.generate_text(message_text)
+                response = answer.strip() if answer and answer.strip() else "[Đang phát triển] Tính năng trả lời về báo hiệu đường bộ sẽ sớm có mặt."
+                conv['isdone'] = True
+            elif muc_dich_to_use == "hỏi về quy trình xử lý vi phạm giao thông":
+                # Dùng LLM để trả lời câu hỏi về quy trình xử lý vi phạm giao thông
+                answer = await self.channel.llm.generate_text(message_text)
+                response = answer.strip() if answer and answer.strip() else "[Đang phát triển] Tính năng trả lời về quy trình xử lý vi phạm giao thông sẽ sớm có mặt."
+                conv['isdone'] = True
+            else:
+                # Dùng LLM cho các mục đích khác
+                answer = await self.channel.llm.generate_text(message_text)
+                response = answer.strip() if answer and answer.strip() else "[Đang phát triển] Tính năng này sẽ sớm có mặt."
+                conv['isdone'] = True
+        else:
+            # Có command
+            if command == "xong":
+                post_url = await self.create_facebook_post(page_token, conv['recipient_id'], [conv])
+                if post_url:
+                    response = f"Bài viết đã được tạo thành công! Bạn có thể xem tại: {post_url}"
+                else:
+                    response = "Đã xảy ra lỗi khi tạo bài viết. Vui lòng thử lại sau."
+                conv['isdone'] = True
+            else:
+                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
+
         # 6. Gửi response và cập nhật final state
         # Replace all occurrences of '**' with '*' before sending
         response_to_send = format_for_facebook(response.replace('**', '*')) if isinstance(response, str) else response