fix duplicate message

app/main.py

@@ -178,7 +178,7 @@ async def process_message(message_data: Dict[str, Any]):
         'conversation_id': None,
         'user_id': sender_id,
         'page_id': page_id,
-        'message': message_text,
+        'originaltext': message_text,
         'command': '',
         'content': '',
         'attachments': attachments,
@@ -186,7 +186,7 @@ async def process_message(message_data: Dict[str, Any]):
         'action': '',
         'purpose': '',
         'timestamp': [timestamp],
-        'is_done': False
+        'isdone': False
     }
 
     logger.info(f"[DEBUG] Message cơ bản: {log_kwargs}")
@@ -209,7 +209,7 @@ async def process_message(message_data: Dict[str, Any]):
                 'conversation_id': row.get('conversation_id'),
                 'user_id': row.get('recipient_id'),
                 'page_id': row.get('page_id'),
-                'message': row.get('originaltext'),
+                'originaltext': row.get('originaltext'),
                 'command': row.get('originalcommand'),
                 'content': row.get('originalcontent'),
                 'attachments': row.get('originalattachments'),
@@ -217,7 +217,7 @@ async def process_message(message_data: Dict[str, Any]):
                 'action': row.get('originalaction'),
                 'purpose': row.get('originalpurpose'),
                 'timestamp': row_timestamps,
-                'is_done': row.get('isdone')
+                'isdone': row.get('isdone')
             }
     else:
         # 2. Ghi conversation mới NGAY LẬP TỨC với thông tin cơ bản
@@ -279,7 +279,7 @@ async def process_message(message_data: Dict[str, Any]):
         'conversation_id': conv['conversation_id'],
         'user_id': sender_id,
         'page_id': page_id,
-        'message': message_text,
+        'originaltext': message_text,
         'command': command,
         'content': remaining_text,
         'attachments': attachments,
@@ -287,7 +287,7 @@ async def process_message(message_data: Dict[str, Any]):
         'action': hanh_vi_vi_pham,
         'purpose': muc_dich,
         'timestamp': conv['timestamp'],
-        'is_done': False
+        'isdone': False
     }
 
     for key, value in update_kwargs.items():
@@ -309,7 +309,7 @@ async def process_business_logic(log_kwargs: Dict[str, Any], page_token: str) ->
     command = log_kwargs.get('command', '')
     vehicle = log_kwargs.get('vehicle', '')
     action = log_kwargs.get('action', '')
-    message = log_kwargs.get('message', '')
+    message = log_kwargs.get('originaltext', '')
     
     # Tách vehicle thành list keywords
     keywords = [kw.strip() for kw in vehicle.split(',') if kw.strip()]
@@ -330,11 +330,11 @@ async def process_business_logic(log_kwargs: Dict[str, Any], page_token: str) ->
                 response = await format_search_results(message, 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
+            log_kwargs['isdone'] = 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
+            log_kwargs['isdone'] = False
     else:
         # Có command
         if command == "xong":
@@ -345,10 +345,10 @@ async def process_business_logic(log_kwargs: Dict[str, Any], page_token: str) ->
                 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
+            log_kwargs['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."
-            log_kwargs['is_done'] = False
+            log_kwargs['isdone'] = False
     
     return response