fix duplicate message
Browse files- app/sheets.py +5 -1
app/sheets.py
CHANGED
|
@@ -146,7 +146,7 @@ class SheetsClient:
|
|
| 146 |
range=SHEET_RANGE
|
| 147 |
).execute()
|
| 148 |
values = result.get('values', [])
|
| 149 |
-
|
| 150 |
ts = datetime.now().isoformat()
|
| 151 |
|
| 152 |
if not conversation_id:
|
|
@@ -227,14 +227,17 @@ class SheetsClient:
|
|
| 227 |
# Update existing conversation
|
| 228 |
header = values[0]
|
| 229 |
data_rows = values[1:]
|
|
|
|
| 230 |
row_index = None
|
| 231 |
for i, row in enumerate(data_rows):
|
| 232 |
if row[0] == conversation_id:
|
| 233 |
row_index = i
|
| 234 |
break
|
|
|
|
| 235 |
if row_index is not None:
|
| 236 |
sheet_row_number = row_index + 2 # +2 vì header ở dòng 1, data bắt đầu từ dòng 2
|
| 237 |
current_row = data_rows[row_index]
|
|
|
|
| 238 |
while len(current_row) < 13:
|
| 239 |
current_row.append("")
|
| 240 |
# Tạo dòng mới với giá trị mới nếu có, giữ nguyên nếu không
|
|
@@ -253,6 +256,7 @@ class SheetsClient:
|
|
| 253 |
str(is_done).lower() if is_done is not None else current_row[11]
|
| 254 |
]
|
| 255 |
update_range = f"{SHEET_RANGE.split('!')[0]}!A{sheet_row_number}"
|
|
|
|
| 256 |
body = {
|
| 257 |
'values': [new_row]
|
| 258 |
}
|
|
|
|
| 146 |
range=SHEET_RANGE
|
| 147 |
).execute()
|
| 148 |
values = result.get('values', [])
|
| 149 |
+
logger.info(f"[DEBUG] Gsheet values {values}")
|
| 150 |
ts = datetime.now().isoformat()
|
| 151 |
|
| 152 |
if not conversation_id:
|
|
|
|
| 227 |
# Update existing conversation
|
| 228 |
header = values[0]
|
| 229 |
data_rows = values[1:]
|
| 230 |
+
logger.info(f"[DEBUG] Gsheet data_rows {data_rows}")
|
| 231 |
row_index = None
|
| 232 |
for i, row in enumerate(data_rows):
|
| 233 |
if row[0] == conversation_id:
|
| 234 |
row_index = i
|
| 235 |
break
|
| 236 |
+
logger.info(f"[DEBUG] Gsheet row index {row_index}")
|
| 237 |
if row_index is not None:
|
| 238 |
sheet_row_number = row_index + 2 # +2 vì header ở dòng 1, data bắt đầu từ dòng 2
|
| 239 |
current_row = data_rows[row_index]
|
| 240 |
+
logger.info(f"[DEBUG] Gsheet current row {current_row}")
|
| 241 |
while len(current_row) < 13:
|
| 242 |
current_row.append("")
|
| 243 |
# Tạo dòng mới với giá trị mới nếu có, giữ nguyên nếu không
|
|
|
|
| 256 |
str(is_done).lower() if is_done is not None else current_row[11]
|
| 257 |
]
|
| 258 |
update_range = f"{SHEET_RANGE.split('!')[0]}!A{sheet_row_number}"
|
| 259 |
+
logger.info(f"[DEBUG] Gsheet update range {update_range}")
|
| 260 |
body = {
|
| 261 |
'values': [new_row]
|
| 262 |
}
|