quick fix timestamp

app/sheets.py

@@ -69,7 +69,7 @@ class SheetsClient:
 
     @timing_decorator_sync
     def get_conversation_history(self, user_id: str, page_id: str) -> List[Dict[str, Any]]:
-        """Lấy lịch sử hội thoại từ sheet."""
+        """Lấy lịch sử hội thoại từ sheet, đảm bảo so sánh kiểu dữ liệu an toàn."""
         try:
             if not self.service:
                 self.authenticate()
@@ -80,15 +80,21 @@ class SheetsClient:
             ).execute()
             values = result.get('values', [])
             history = []
-            if not values or len(values) < 2: # Cần có header và ít nhất 1 dòng dữ liệu
+            
+            # Nếu không có dữ liệu hoặc chỉ có header, trả về rỗng
+            if not values or len(values) < 2:
                 return []
             
             header = values[0]
             for row in values[1:]:
-                # Zip header với row để tạo dict, an toàn hơn
                 row_data = dict(zip(header, row + [""] * (len(header) - len(row))))
                 
-                if row_data.get('recipient_id') == user_id and row_data.get('page_id') == page_id:
+                # ==================================================================
+                # >>>>> SỬA LỖI SO SÁNH KIỂU DỮ LIỆU TẠI ĐÂY <<<<<
+                # Ép kiểu cả hai vế về string để đảm bảo so sánh chính xác
+                if str(row_data.get('recipient_id')) == str(user_id) and \
+                   str(row_data.get('page_id')) == str(page_id):
+                # ==================================================================
                     try:
                         timestamps_raw = json.loads(row_data.get('timestamp', '[]'))
                         timestamps = _flatten_and_unique_timestamps(timestamps_raw)
@@ -133,20 +139,14 @@ class SheetsClient:
             ).execute()
             values = result.get('values', [])
 
-            # ==================================================================
-            # >>>>> SỬA LỖI LỒNG TIMESTAMP TẠI ĐÂY <<<<<
-            # Bước 1: Xử lý `timestamp` đầu vào để nó LUÔN LUÔN là một danh sách phẳng.
             processed_timestamps = _flatten_and_unique_timestamps(timestamp or [])
             
-            # Bước 2: Lấy timestamp mới nhất để kiểm tra trùng lặp. Nếu list rỗng thì tạo mới.
             if not processed_timestamps:
                 current_ts_for_check = datetime.now().isoformat()
                 processed_timestamps.append(current_ts_for_check)
             else:
                 current_ts_for_check = processed_timestamps[-1]
-            # ==================================================================
 
-            # Logic kiểm tra trùng lặp của bạn được giữ nguyên
             for row in values:
                 row = row + [""] * 14
                 try:
@@ -180,7 +180,6 @@ class SheetsClient:
                         'isdone': row[13].lower() == 'true' if len(row) > 13 else False
                     }
 
-            # Logic tạo dòng mới và append vào sheet được giữ nguyên
             if not conversation_id:
                 conversation_id = generate_conversation_id(recipient_id, page_id, current_ts_for_check)
             
@@ -197,7 +196,7 @@ class SheetsClient:
                 originalpurpose,
                 originalquestion,
                 systemresponse,
-                json.dumps(processed_timestamps), # <<<< SỬ DỤNG BIẾN ĐÃ ĐƯỢC XỬ LÝ
+                json.dumps(processed_timestamps),
                 str(isdone).lower()
             ]
 
@@ -224,7 +223,7 @@ class SheetsClient:
                 'originalpurpose': originalpurpose,
                 'originalquestion': originalquestion,
                 'systemresponse': systemresponse,
-                'timestamp': processed_timestamps, # <<<< TRẢ VỀ DANH SÁCH ĐÃ ĐƯỢC XỬ LÝ
+                'timestamp': processed_timestamps,
                 'isdone': isdone
             }
         except Exception as e: