fix duplicate message

app/main.py

@@ -185,17 +185,18 @@ async def process_message(message_data: Dict[str, Any]):
         'vehicle': '',
         'action': '',
         'purpose': '',
-        'timestamp': timestamp,
+        'timestamp': [timestamp],
         'is_done': False
     }
 
+    logger.info(f"[DEBUG] Message cơ bản: {log_kwargs}")
     conv = None
 
     if history:
         # 1. Chặn duplicate message (trùng sender_id, page_id, timestamp)
         for row in history:
             if (
-                str(row.get('timestamp')) == str(timestamp)
+                str(timestamp) in row.get('timestamp', [])
                 and str(row.get('recipient_id')) == str(sender_id)
                 and str(row.get('page_id')) == str(page_id)
             ):
@@ -223,9 +224,14 @@ async def process_message(message_data: Dict[str, Any]):
         logger.error("Không thể tạo conversation mới!")
         return
     else:
+        logger.info(f"[DEBUG] Message history: {conv}")
         for key, value in log_kwargs.items():
             if value not in (None, "", []) and conv.get(key) in (None, "", []):
                 conv[key] = value
+        logger.info(f"[DEBUG] Message history sau update: {conv}")
+    # Thêm timestamp mới nếu chưa có
+    if timestamp not in conv['timestamp']:
+        conv['timestamp'].append(timestamp)
 
     # Get page access token (sync)
     page_token = supabase_client.get_page_token(page_id)
@@ -275,14 +281,14 @@ async def process_message(message_data: Dict[str, Any]):
         'vehicle': ','.join(keywords),
         'action': hanh_vi_vi_pham,
         'purpose': muc_dich,
-        'timestamp': timestamp,
+        'timestamp': conv['timestamp'],
         'is_done': False
     }
 
     for key, value in update_kwargs.items():
         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 process_business_logic(conv, page_token)
 
@@ -354,7 +360,7 @@ async def format_search_results(question: str, matches: List[Dict[str, Any]]) ->
             top = match
 
         # Chuẩn bị context cho LLM: liệt kê tất cả các item với chú thích rõ ràng
-        full_result_text += f"Đoạn {i}:\n"
+        full_result_text += f"\nĐoạn {i}:\n"
          # Thực hiện hành vi
         tieude = (top.get('tieude') or '').strip()
         noidung = (top.get('noidung') or '').strip()
@@ -400,7 +406,7 @@ async def format_search_results(question: str, matches: List[Dict[str, Any]]) ->
         "Chỉ sử dụng thông tin có trong các đoạn, không tự đoán.\n"
         f"Các đoạn luật liên quan:\n{full_result_text}"
         "\nHãy trả lời ngắn gọn, dễ hiểu, trích dẫn rõ ràng thông tin từ các đoạn luật nếu cần."
-        f"Câu hỏi của người dùng: {question}\n"
+        f"\nCâu hỏi của người dùng: {question}\n"
     )
 
     logger.info(f"[DEBUG] prompt:\n {prompt}")

app/sheets.py

@@ -90,8 +90,8 @@ class SheetsClient:
             history = []
 
             for row in values:
-                # Bổ sung cột rỗng cho đủ 12 cột
                 row = row + [""] * (12 - len(row))
+                timestamps = json.loads(row[10]) if row[10] else []
                 if row[4] == user_id and row[5] == page_id and row[11].lower() == 'false':
                     history.append({
                         'conversation_id': row[0],
@@ -104,7 +104,7 @@ class SheetsClient:
                         'originalvehicle': row[7],
                         'originalaction': row[8],
                         'originalpurpose': row[9],
-                        'timestamp': row[10],
+                        'timestamp': timestamps,
                         'isdone': row[11].lower() == 'true'
                     })
 
@@ -152,14 +152,11 @@ class SheetsClient:
             if not conversation_id:
                 # Check for duplicates before creating new conversation
                 for row in values:
-                    # Ensure row has enough columns
                     if len(row) >= 11:
-                        row_timestamp = row[10]
+                        row_timestamps = json.loads(row[10]) if row[10] else []
                         row_user_id = row[4]
                         row_page_id = row[5]
-                        if (str(row_timestamp) == str(timestamp) and 
-                            str(row_user_id) == str(user_id) and 
-                            str(row_page_id) == str(page_id)):
+                        if (str(timestamp) 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 {
@@ -173,7 +170,7 @@ class SheetsClient:
                                 'originalvehicle': row[7],
                                 'originalaction': row[8],
                                 'originalpurpose': row[9],
-                                'timestamp': row[10],
+                                'timestamp': row_timestamps,
                                 'isdone': row[11].lower() == 'true' if len(row) > 11 else False
                             }
 
@@ -190,7 +187,7 @@ class SheetsClient:
                     vehicle,
                     action,
                     purpose,
-                    timestamp,
+                    json.dumps([timestamp]),
                     str(is_done).lower()
                 ]
 
@@ -220,7 +217,7 @@ class SheetsClient:
                     'originalvehicle': vehicle,
                     'originalaction': action,
                     'originalpurpose': purpose,
-                    'timestamp': timestamp,
+                    'timestamp': [timestamp],
                     'isdone': is_done
                 }
             else:
@@ -241,6 +238,9 @@ class SheetsClient:
                     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
+                    current_timestamps = json.loads(current_row[10]) if current_row[10] else []
+                    if timestamp not in current_timestamps:
+                        current_timestamps.append(timestamp)
                     new_row = [
                         conversation_id,
                         command if command else current_row[1],
@@ -252,7 +252,7 @@ class SheetsClient:
                         vehicle if vehicle else current_row[7],
                         action if action else current_row[8],
                         purpose if purpose else current_row[9],
-                        timestamp if timestamp else current_row[10],
+                        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}"
@@ -285,7 +285,7 @@ class SheetsClient:
                         'originalvehicle': new_row[7],
                         'originalaction': new_row[8],
                         'originalpurpose': new_row[9],
-                        'timestamp': new_row[10],
+                        'timestamp': json.loads(new_row[10]),
                         'isdone': new_row[11].lower() == 'true'
                     }