fix duplicate message

app/main.py

@@ -199,7 +199,7 @@ async def process_message(message_data: Dict[str, Any]):
         logger.error(f"No access token found for page {page_id}")
         return
 
-# Extract command and keywords
+    # Extract command and keywords
     command, remaining_text = extract_command(message_text)
     # Sử dụng LLM để phân tích message_text và extract keywords, mục đích, hành vi vi phạm
     llm_analysis = await llm_client.analyze(message_text)
@@ -223,12 +223,8 @@ async def process_message(message_data: Dict[str, Any]):
 
     logger.info(f"[DEBUG] Phương tiện: {keywords} - Hành vi: {hanh_vi_vi_pham} - Mục đích: {muc_dich}")
 
-    response = ""
-    log_needed = True
-    log_kwargs = {
-        'conversation_id': None,
-        'user_id': sender_id,
-        'page_id': page_id,
+    # 2. Chuẩn bị thông tin message hiện tại
+    current_message_info = {
         'message': message_text,
         'command': command,
         'content': remaining_text,
@@ -236,68 +232,78 @@ async def process_message(message_data: Dict[str, Any]):
         'vehicle': ','.join(keywords),
         'action': hanh_vi_vi_pham,
         'purpose': muc_dich,
-        'timestamp': timestamp,
-        'is_done': False
+        'timestamp': timestamp
     }
 
-    # 1. Nếu history rỗng (conversation mới)
-    if not history:
-        log_kwargs['conversation_id'] = None
-        if not command:
-            if keywords:
-                # Có thông tin phương tiện
-                if hanh_vi_vi_pham:
-                    embedding = await embedding_client.create_embedding(hanh_vi_vi_pham)
-                else:
-                    embedding = await embedding_client.create_embedding(message_text)
-                logger.info(f"[DEBUG] embedding: {embedding[:5]} ... (total {len(embedding)})")
-                matches = supabase_client.match_documents(embedding, vehicle_keywords=keywords)
-                logger.info(f"[DEBUG] matches: {matches}")
-                if matches:
-                    response = await format_search_results(matches)
-                else:
-                    response = "Xin lỗi, tôi không tìm thấy thông tin phù hợp."
-                log_kwargs['is_done'] = True
-            else:
-                # Không có thông tin phương tiện
-                response = "Vui lòng cho biết loại phương tiện bạn cần tìm (xe máy, ô tô...)"
-                log_kwargs['is_done'] = False
-        else:
-            # Có command
-            response = "Vui lòng cung cấp thêm thông tin và gõ lệnh \\xong khi hoàn tất."
-            log_kwargs['is_done'] = False
-        await facebook_client.send_message(page_token, sender_id, response)
-        await loop.run_in_executor(executor, lambda: sheets_client.log_conversation(**log_kwargs))
-        return
-
-    # 2. Nếu history có conversation (conversation cũ)
-    last_conv = history[-1] if history else None
-    last_command = last_conv['originalcommand'] if last_conv else ''
-    last_isdone = last_conv['isdone'] if last_conv else False
-
-    # --- Cập nhật log_kwargs theo lịch sử ---
-    log_kwargs_old = log_kwargs.copy()
-    log_kwargs_overwritten = {}
-    for key in log_kwargs.keys():
-        history_val = last_conv.get(key) if last_conv else None
-        current_val = log_kwargs[key]
-        if history_val not in [None, '', [], {}]:
-            if current_val not in [None, '', [], {}]:
-                log_kwargs_overwritten[key] = current_val  # Lưu giá trị cũ để xử lý sau
-            log_kwargs[key] = history_val  # Ưu tiên giá trị từ lịch sử
-    # --- END cập nhật log_kwargs ---
-
-    # Đảm bảo truyền đúng conversation_id khi update
+    # 3. Xử lý theo trường hợp
     if open_conv:
-        log_kwargs['conversation_id'] = open_conv['conversation_id']
+        # Có conversation đang mở → Update
+        logger.info(f"[UPDATE] Cập nhật conversation đang mở: {open_conv['conversation_id']}")
+        log_kwargs = {
+            'conversation_id': open_conv['conversation_id'],
+            'user_id': sender_id,
+            'page_id': page_id,
+            'is_done': False,
+            **current_message_info
+        }
+        # Merge thông tin: ưu tiên thông tin mới nếu có, giữ thông tin cũ nếu mới rỗng
+        for key, value in open_conv.items():
+            if key in log_kwargs and (not log_kwargs[key] or log_kwargs[key] in [None, '', [], {}]):
+                log_kwargs[key] = value
+        
+        # Xử lý logic nghiệp vụ dựa trên thông tin tổng hợp
+        response = await process_business_logic(log_kwargs, page_token)
+        
     else:
-        log_kwargs['conversation_id'] = None
+        # Không có conversation đang mở → Tạo mới
+        logger.info("[CREATE] Tạo conversation mới")
+        log_kwargs = {
+            'conversation_id': None,
+            'user_id': sender_id,
+            'page_id': page_id,
+            'is_done': False,
+            **current_message_info
+        }
+        
+        # Lưu conversation mới trước
+        await loop.run_in_executor(executor, lambda: sheets_client.log_conversation(**log_kwargs))
+        
+        # Lấy conversation_id vừa tạo
+        updated_history = await loop.run_in_executor(
+            executor, lambda: sheets_client.get_conversation_history(sender_id, page_id)
+        )
+        new_conv = next((row for row in updated_history if not row.get('isdone')), None)
+        if new_conv:
+            log_kwargs['conversation_id'] = new_conv['conversation_id']
+            logger.info(f"[CREATE] Đã tạo conversation mới: {new_conv['conversation_id']}")
+        
+        # Xử lý logic nghiệp vụ dựa trên thông tin hiện tại
+        response = await process_business_logic(log_kwargs, page_token)
+
+    # 4. Gửi response và cập nhật final state
+    await facebook_client.send_message(page_token, sender_id, response)
+    await loop.run_in_executor(executor, lambda: sheets_client.log_conversation(**log_kwargs))
+    return
 
-    if not last_command:
-        # Lịch sử không có command
+async def process_business_logic(log_kwargs: Dict[str, Any], page_token: str) -> str:
+    """
+    Xử lý logic nghiệp vụ dựa trên thông tin conversation.
+    """
+    command = log_kwargs.get('command', '')
+    vehicle = log_kwargs.get('vehicle', '')
+    action = log_kwargs.get('action', '')
+    message = log_kwargs.get('message', '')
+    
+    # Tách vehicle thành list keywords
+    keywords = [kw.strip() for kw in vehicle.split(',') if kw.strip()]
+    
+    if not command:
         if keywords:
             # Có thông tin phương tiện
-            embedding = await embedding_client.create_embedding(log_kwargs['action'])
+            if action:
+                embedding = await embedding_client.create_embedding(action)
+            else:
+                embedding = await embedding_client.create_embedding(message)
             logger.info(f"[DEBUG] embedding: {embedding[:5]} ... (total {len(embedding)})")
             matches = supabase_client.match_documents(embedding, vehicle_keywords=keywords)
             logger.info(f"[DEBUG] matches: {matches}")
@@ -306,35 +312,26 @@ async def process_message(message_data: Dict[str, Any]):
             else:
                 response = "Xin lỗi, tôi không tìm thấy thông tin phù hợp."
             log_kwargs['is_done'] = True
-            await facebook_client.send_message(page_token, sender_id, response)
-            await loop.run_in_executor(executor, lambda: sheets_client.log_conversation(**log_kwargs))
-            return
         else:
             # Không có thông tin phương tiện
             response = "Vui lòng cho biết loại phương tiện bạn cần tìm (xe máy, ô tô...)"
-            log_needed = False
-            await facebook_client.send_message(page_token, sender_id, response)
-            return
+            log_kwargs['is_done'] = False
     else:
-        # Lịch sử có command
+        # Có command
         if command == "xong":
             # Tạo bài viết mới trên page (placeholder)
             # TODO: Thay thế hàm này bằng logic thực tế
-            post_url = await create_facebook_post(page_token, sender_id, history)
+            post_url = await create_facebook_post(page_token, log_kwargs['user_id'], [log_kwargs])
             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."
             log_kwargs['is_done'] = True
-            await facebook_client.send_message(page_token, sender_id, response)
-            await loop.run_in_executor(executor, lambda: sheets_client.log_conversation(**log_kwargs))
-            return
         else:
             response = "Vui lòng cung cấp thêm thông tin và gõ lệnh \\xong khi hoàn tất."
             log_kwargs['is_done'] = False
-            await facebook_client.send_message(page_token, sender_id, response)
-            await loop.run_in_executor(executor, lambda: sheets_client.log_conversation(**log_kwargs))
-            return
+    
+    return response
 
 async def format_search_results(matches: List[Dict[str, Any]]) -> str:
     if not matches:

app/sheets.py

@@ -191,8 +191,8 @@ class SheetsClient:
                 if row_index is not None:
                     # Lấy dữ liệu dòng hiện tại
                     current_row = values[row_index]
-                    # Đảm bảo đủ 12 cột
-                    while len(current_row) < 12:
+                    # Đảm bảo đủ 13 cột (thêm processing)
+                    while len(current_row) < 13:
                         current_row.append("")
                     # Tạo dòng mới với giá trị mới nếu có, giữ nguyên nếu không
                     new_row = [