fix duplicate message

app/main.py

@@ -195,8 +195,11 @@ async def process_message(message_data: Dict[str, Any]):
     if history:
         # 1. Chặn duplicate message (trùng sender_id, page_id, timestamp)
         for row in history:
+            row_timestamps = row.get('timestamp', [])
+            if isinstance(row_timestamps, list) and len(row_timestamps) == 1 and isinstance(row_timestamps[0], list):
+                row_timestamps = row_timestamps[0]
             if (
-                str(timestamp) in row.get('timestamp', [])
+                str(timestamp) in [str(ts) for ts in row_timestamps]
                 and str(row.get('recipient_id')) == str(sender_id)
                 and str(row.get('page_id')) == str(page_id)
             ):
@@ -213,7 +216,7 @@ async def process_message(message_data: Dict[str, Any]):
                 'vehicle': row.get('originalvehicle'),
                 'action': row.get('originalaction'),
                 'purpose': row.get('originalpurpose'),
-                'timestamp': row.get('timestamp'),
+                'timestamp': row_timestamps,
                 'is_done': row.get('isdone')
             }
     else:
@@ -230,6 +233,8 @@ async def process_message(message_data: Dict[str, Any]):
                 conv[key] = value
         logger.info(f"[DEBUG] Message history sau update: {conv}")
     # Thêm timestamp mới nếu chưa có
+    if isinstance(conv['timestamp'], list) and len(conv['timestamp']) == 1 and isinstance(conv['timestamp'][0], list):
+        conv['timestamp'] = conv['timestamp'][0]
     if timestamp not in conv['timestamp']:
         conv['timestamp'].append(timestamp)
 

app/sheets.py

@@ -92,6 +92,8 @@ class SheetsClient:
             for row in values:
                 row = row + [""] * (12 - len(row))
                 timestamps = json.loads(row[10]) if row[10] else []
+                if isinstance(timestamps, list) and len(timestamps) == 1 and isinstance(timestamps[0], list):
+                    timestamps = timestamps[0]
                 if row[4] == user_id and row[5] == page_id and row[11].lower() == 'false':
                     history.append({
                         'conversation_id': row[0],
@@ -154,9 +156,11 @@ class SheetsClient:
                 for row in values:
                     if len(row) >= 11:
                         row_timestamps = json.loads(row[10]) if row[10] else []
+                        if isinstance(row_timestamps, list) and len(row_timestamps) == 1 and isinstance(row_timestamps[0], list):
+                            row_timestamps = row_timestamps[0]
                         row_user_id = row[4]
                         row_page_id = row[5]
-                        if (str(timestamp) in row_timestamps and str(row_user_id) == str(user_id) and str(row_page_id) == str(page_id)):
+                        if (str(timestamp) in [str(ts) for ts in row_timestamps] and str(row_user_id) == str(user_id) and str(row_page_id) == str(page_id)):
                             # Found duplicate, return existing conversation
                             logger.info(f"Found duplicate conversation for user {user_id}, page {page_id}, timestamp {timestamp}")
                             return {
@@ -239,6 +243,8 @@ class SheetsClient:
                         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
                     current_timestamps = json.loads(current_row[10]) if current_row[10] else []
+                    if isinstance(current_timestamps, list) and len(current_timestamps) == 1 and isinstance(current_timestamps[0], list):
+                        current_timestamps = current_timestamps[0]
                     if timestamp not in current_timestamps:
                         current_timestamps.append(timestamp)
                     new_row = [
@@ -255,7 +261,7 @@ class SheetsClient:
                         json.dumps(current_timestamps),
                         str(is_done).lower() if is_done is not None else current_row[11]
                     ]
-                    update_range = f"{SHEET_RANGE.split('!')[0]}!A{sheet_row_number}"
+                    update_range = f"{SHEET_RANGE.split('!')[0]}!A{row_index + 1}"
                     logger.info(f"[DEBUG] Gsheet update range {update_range}")
                     body = {
                         'values': [new_row]