quick fix timestamp

app/sheets.py

@@ -69,9 +69,8 @@ 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, đảm bảo so sánh kiểu dữ liệu an toàn."""
-        # --- THÊM LOG ĐỂ DEBUG ---
-        logger.info(f"[get_conversation_history] Bắt đầu lấy lịch sử cho user_id: '{user_id}' và page_id: '{page_id}'")
+        """Lấy lịch sử hội thoại từ sheet bằng vị trí cột cố định để đảm bảo độ tin cậy."""
+        logger.debug(f"[get_conversation_history] Bắt đầu lấy lịch sử cho user_id: '{user_id}' và page_id: '{page_id}'")
         try:
             if not self.service:
                 self.authenticate()
@@ -83,45 +82,47 @@ class SheetsClient:
             values = result.get('values', [])
             history = []
             
-            if not values or len(values) < 2:
-                logger.warning(f"[get_conversation_history] Không tìm thấy dữ liệu hoặc chỉ có header trong sheet. Tổng số dòng: {len(values)}")
-                return []
+            logger.debug(f"[get_conversation_history] Đã lấy được {len(values)} dòng từ sheet. Bắt đầu xử lý...")
             
-            logger.info(f"[get_conversation_history] Đã lấy được {len(values)} dòng từ sheet.")
-            header = values[0]
-            
-            for i, row in enumerate(values[1:], start=1):
-                row_data = dict(zip(header, row + [""] * (len(header) - len(row))))
-                
-                # --- THÊM LOG CHI TIẾT CHO TỪNG DÒNG ---
-                sheet_recipient_id = row_data.get('recipient_id', 'N/A')
-                sheet_page_id = row_data.get('page_id', 'N/A')
-                
-                logger.info(f"[get_conversation_history] Đang xử lý dòng {i+1}: recipient_id='{sheet_recipient_id}', page_id='{sheet_page_id}'")
-
-                is_recipient_match = str(sheet_recipient_id) == str(user_id)
-                is_page_match = str(sheet_page_id) == str(page_id)
-
-                if is_recipient_match and is_page_match:
-                    logger.info(f"[get_conversation_history] >>> TÌM THẤY DÒNG KHỚP tại dòng {i+1}!")
+            # Bỏ qua dòng header (values[0]) và lặp qua các dòng dữ liệu
+            for i, row in enumerate(values, start=1):
+                # Đảm bảo dòng có đủ 14 cột để tránh lỗi IndexError
+                if len(row) < 14:
+                    row.extend([""] * (14 - len(row)))
+
+                # ==================================================================
+                # >>>>> SỬA LỖI: ĐỌC DỮ LIỆU BẰNG VỊ TRÍ CỘT CỐ ĐỊNH <<<<<
+                # Vị trí cột được xác định dựa trên thứ tự trong hàm log_conversation
+                sheet_recipient_id = row[4] # Cột E
+                sheet_page_id = row[5]      # Cột F
+                # ==================================================================
+
+                if str(sheet_recipient_id) == str(user_id) and str(sheet_page_id) == str(page_id):
+                    logger.success(f"[get_conversation_history] >>> TÌM THẤY DÒNG KHỚP tại dòng {i}!")
                     try:
-                        timestamps_raw = json.loads(row_data.get('timestamp', '[]'))
+                        timestamps_raw = json.loads(row[12]) # Cột M
                         timestamps = _flatten_and_unique_timestamps(timestamps_raw)
                     except (json.JSONDecodeError, TypeError):
                         timestamps = []
                     
-                    row_data['timestamp'] = timestamps
-                    row_data['originalattachments'] = json.loads(row_data.get('originalattachments', '[]')) if row_data.get('originalattachments') else []
-                    row_data['isdone'] = str(row_data.get('isdone', 'false')).lower() == 'true'
-                    history.append(row_data)
-                else:
-                    # Log lý do không khớp
-                    if not is_recipient_match:
-                        logger.info(f"[get_conversation_history] Dòng {i+1} không khớp: recipient_id (sheet: '{sheet_recipient_id}', input: '{user_id}')")
-                    if not is_page_match:
-                         logger.info(f"[get_conversation_history] Dòng {i+1} không khớp: page_id (sheet: '{sheet_page_id}', input: '{page_id}')")
+                    history.append({
+                        'conversation_id': row[0],
+                        'originalcommand': row[1],
+                        'originalcontent': row[2],
+                        'originalattachments': json.loads(row[3]) if row[3] else [],
+                        'recipient_id': row[4],
+                        'page_id': row[5],
+                        'originaltext': row[6],
+                        'originalvehicle': row[7],
+                        'originalaction': row[8],
+                        'originalpurpose': row[9],
+                        'originalquestion': row[10],
+                        'systemresponse': row[11],
+                        'timestamp': timestamps,
+                        'isdone': str(row[13]).lower() == 'true'
+                    })
 
-            logger.info(f"[get_conversation_history] Hoàn tất xử lý. Tìm thấy {len(history)} bản ghi lịch sử.")
+            logger.debug(f"[get_conversation_history] Hoàn tất xử lý. Tìm thấy {len(history)} bản ghi lịch sử.")
             return history
         except Exception as e:
             logger.error(f"Error getting conversation history: {e}", exc_info=True)