quick fix timestamp

app/sheets.py

@@ -170,18 +170,18 @@ class SheetsClient:
             values = data_result.get('values', [])
             
             # Định danh của sự kiện đang xử lý
-            recipient_id = str(kwargs.get('recipient_id'))
-            page_id = str(kwargs.get('page_id'))
-            # Timestamp của sự kiện webhook này là duy nhất
+            recipient_id = str(kwargs.get('recipient_id')).strip()
+            page_id = str(kwargs.get('page_id')).strip()
             ts_list = _flatten_and_unique_timestamps(kwargs.get('timestamp', []))
-            event_timestamp = str(ts_list[-1]) if ts_list else ''
+            event_timestamp = str(ts_list[-1]).strip() if ts_list else ''
             
+            logger.debug(f"UPSERT: Bắt đầu tìm kiếm với recipient_id='{recipient_id}', page_id='{page_id}', event_timestamp='{event_timestamp}'")
+
             # --- 3. Tìm kiếm bản ghi đã tồn tại ---
             found_row_index = -1
             found_row_data = {}
             start_row = _get_start_row_from_range(SHEET_RANGE)
 
-            # Lấy vị trí các cột cần thiết từ header
             try:
                 id_col_idx = header.index('conversation_id')
                 recipient_col_idx = header.index('recipient_id')
@@ -191,26 +191,38 @@ class SheetsClient:
                 logger.error(f"Thiếu cột bắt buộc trong header: {e}")
                 return None
 
-            # Ưu tiên tìm bằng conversation_id nếu có
-            target_conv_id = kwargs.get('conversation_id')
+            target_conv_id = str(kwargs.get('conversation_id') or '').strip()
             if target_conv_id:
+                logger.debug(f"UPSERT: Ưu tiên tìm bằng conversation_id='{target_conv_id}'")
                 for i, row in enumerate(values, start=start_row):
-                    if len(row) > id_col_idx and str(row[id_col_idx]).strip() == str(target_conv_id):
-                        found_row_index = i
-                        found_row_data = dict(zip(header, row))
-                        logger.success(f"Tìm thấy bằng conversation_id '{target_conv_id}' tại dòng {i}.")
-                        break
+                    if len(row) > id_col_idx:
+                        sheet_conv_id = str(row[id_col_idx]).strip()
+                        is_match = sheet_conv_id == target_conv_id
+                        logger.trace(f"Dòng {i}: So sánh ID: '{sheet_conv_id}' == '{target_conv_id}' -> {is_match}")
+                        if is_match:
+                            found_row_index = i
+                            found_row_data = dict(zip(header, row))
+                            logger.success(f"Tìm thấy bằng conversation_id tại dòng {i}.")
+                            break
             
-            # Nếu không tìm thấy bằng ID, tìm bằng bộ ba (user, page, timestamp)
             if found_row_index == -1:
+                logger.debug(f"UPSERT: Không tìm thấy bằng ID, chuyển sang tìm bằng (user, page, timestamp).")
                 for i, row in enumerate(values, start=start_row):
                     if len(row) <= max(recipient_col_idx, page_col_idx, timestamp_col_idx):
                         continue
+                    
+                    sheet_recipient_id = str(row[recipient_col_idx]).strip()
+                    sheet_page_id = str(row[page_col_idx]).strip()
+                    
+                    id_match = (sheet_recipient_id == recipient_id) and (sheet_page_id == page_id)
+                    logger.trace(f"Dòng {i}: So sánh (user, page): ('{sheet_recipient_id}' == '{recipient_id}') AND ('{sheet_page_id}' == '{page_id}') -> {id_match}")
 
-                    if str(row[recipient_col_idx]) == recipient_id and str(row[page_col_idx]) == page_id:
+                    if id_match:
                         try:
-                            sheet_timestamps = [str(ts) for ts in _flatten_and_unique_timestamps(json.loads(row[timestamp_col_idx]))]
-                            if event_timestamp and event_timestamp in sheet_timestamps:
+                            sheet_timestamps = [str(ts).strip() for ts in _flatten_and_unique_timestamps(json.loads(row[timestamp_col_idx]))]
+                            ts_match = event_timestamp and event_timestamp in sheet_timestamps
+                            logger.trace(f"Dòng {i}: So sánh timestamp: '{event_timestamp}' in {sheet_timestamps} -> {ts_match}")
+                            if ts_match:
                                 found_row_index = i
                                 found_row_data = dict(zip(header, row))
                                 logger.success(f"Tìm thấy bằng (user, page, timestamp) tại dòng {i}.")
@@ -225,7 +237,6 @@ class SheetsClient:
                 
                 updated_data = found_row_data.copy()
                 for key, value in kwargs.items():
-                    # Chỉ cập nhật nếu giá trị mới không rỗng hoặc là boolean (cho isdone)
                     if value is not None and value != '' or isinstance(value, bool):
                         updated_data[key] = value