fix duplicate message

app/sheets.py

@@ -121,7 +121,7 @@ class SheetsClient:
         conversation_id: str,
         user_id: str,
         page_id: str,
-        message: str,
+        originaltext: str = "",
         command: str = "",
         content: str = "",
         attachments: Optional[List[str]] = None,
@@ -133,8 +133,7 @@ class SheetsClient:
     ) -> Optional[Dict[str, Any]]:
         """
         Ghi log hội thoại vào Google Sheets.
-        Input: user_id, page_id, message, command, content, attachments, vehicle, is_done
-        Output: Dict containing the conversation data if successful, None if error
+        Dùng originaltext cho cột message trong sheet và các logic liên quan.
         """
         try:
             if not self.service:
@@ -187,7 +186,7 @@ class SheetsClient:
                     json.dumps(attachments or []),
                     user_id,
                     page_id,
-                    message,
+                    originaltext,
                     vehicle,
                     action,
                     purpose,
@@ -207,7 +206,7 @@ class SheetsClient:
                     body=body
                 ).execute()
 
-                logger.info(f"Thêm mới conversation: {conversation_id} | Giá trị: {dict(zip(['conversation_id','command','content','attachments','user_id','page_id','message','vehicle','action','purpose','timestamp','is_done'], new_row))}")
+                logger.info(f"Thêm mới conversation: {conversation_id} | Giá trị: {dict(zip(['conversation_id','command','content','attachments','user_id','page_id','originaltext','vehicle','action','purpose','timestamp','is_done'], new_row))}")
 
                 # Return the conversation data directly
                 return {
@@ -217,7 +216,7 @@ class SheetsClient:
                     'originalattachments': attachments or [],
                     'recipient_id': user_id,
                     'page_id': page_id,
-                    'originaltext': message,
+                    'originaltext': originaltext,
                     'originalvehicle': vehicle,
                     'originalaction': action,
                     'originalpurpose': purpose,
@@ -254,7 +253,7 @@ class SheetsClient:
                         json.dumps(attachments) if attachments is not None else current_row[3],
                         user_id if user_id else current_row[4],
                         page_id if page_id else current_row[5],
-                        message if message else current_row[6],
+                        originaltext if originaltext else current_row[6],
                         vehicle if vehicle else current_row[7],
                         action if action else current_row[8],
                         purpose if purpose else current_row[9],
@@ -272,12 +271,11 @@ class SheetsClient:
                         valueInputOption='RAW',
                         body=body
                     ).execute()
-                    changed_cols = []
-                    col_names = ['conversation_id','command','content','attachments','user_id','page_id','message','vehicle','action','purpose','timestamp','is_done']
+                    changed_cols = ['conversation_id','command','content','attachments','user_id','page_id','originaltext','vehicle','action','purpose','timestamp','is_done']
                     for idx, (old, new) in enumerate(zip(current_row, new_row)):
                         if old != new:
-                            changed_cols.append(col_names[idx])
-                    logger.info(f"Cập nhật conversation: {conversation_id} tại dòng {sheet_row_number} | Cột cập nhật: {changed_cols} | Giá trị mới: {dict(zip(col_names, new_row))}")
+                            changed_cols.append(changed_cols[idx])
+                    logger.info(f"Cập nhật conversation: {conversation_id} tại dòng {sheet_row_number} | Cột cập nhật: {changed_cols} | Giá trị mới: {dict(zip(changed_cols, new_row))}")
 
                     # Return the updated conversation data
                     return {