From b8a538a8a1e4045ab9d6ee58d4dbe5a641371894 Mon Sep 17 00:00:00 2001 From: litianxiang Date: Mon, 12 Jan 2026 13:59:06 +0800 Subject: [PATCH] =?UTF-8?q?fix=EF=BC=9A=E5=A2=9E=E9=87=8F=E6=9B=B4?= =?UTF-8?q?=E6=96=B0=E5=90=91=E9=87=8F=E9=97=AE=E9=A2=98=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/service/recommendation_system/incremental_listener.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/app/service/recommendation_system/incremental_listener.py b/app/service/recommendation_system/incremental_listener.py index 93ecf34..bc662ee 100644 --- a/app/service/recommendation_system/incremental_listener.py +++ b/app/service/recommendation_system/incremental_listener.py @@ -48,7 +48,7 @@ class IncrementalListener: if self.last_process_time is None: # 第一次运行，查询最近30分钟的数据 cursor.execute(f""" - SELECT id, account_id, path, category, style, data_time, is_system_sketch, sys_file_id + SELECT id, account_id, path, category, style, data_time FROM {TABLE_USER_PREFERENCE_LOG} WHERE data_time > DATE_SUB(NOW(), INTERVAL 30 MINUTE) ORDER BY data_time @@ -56,7 +56,7 @@ class IncrementalListener: else: # 基于上次处理时间查询 cursor.execute(f""" - SELECT id, account_id, path, category, style, data_time, is_system_sketch, sys_file_id + SELECT id, account_id, path, category, style, data_time FROM {TABLE_USER_PREFERENCE_LOG} WHERE data_time > %s ORDER BY data_time