'commit'

AI/WxMini/Utils/MySQLUtil.py

@@ -124,6 +124,7 @@ async def get_risk_chat_log_page(mysql_pool, risk_flag, page=1, page_size=10):
     """
     查询有风险的聊天记录，并按 id 降序分页
     :param mysql_pool: MySQL 连接池
+    :param risk_flag: 风险标志
     :param page: 当前页码
     :param page_size: 每页记录数
     :return: 分页数据
@@ -133,17 +134,22 @@ async def get_risk_chat_log_page(mysql_pool, risk_flag, page=1, page_size=10):
         async with conn.cursor() as cur:
             # 查询总记录数
             await cur.execute(
-                "SELECT COUNT(*) FROM t_chat_log WHERE risk_flag = %s", (risk_flag)
+                "SELECT COUNT(*) FROM t_chat_log WHERE risk_flag = %s", (risk_flag,)
             )
             total = (await cur.fetchone())[0]
+            print(f"总记录数: {total}")
 
             # 查询分页数据
-            await cur.execute(
+            query = (
                 "SELECT id, session_id, user_input, model_response, audio_url, duration, create_time, risk_memo "
-                "FROM t_chat_log WHERE risk_flag = %s ORDER BY id DESC LIMIT %s OFFSET %s",
-                (risk_flag, page_size, offset)
+                "FROM t_chat_log WHERE risk_flag = %s ORDER BY id DESC LIMIT %s OFFSET %s"
             )
+            params = (risk_flag, page_size, offset)
+            print(f"执行查询: {query % params}")  # 打印 SQL 查询
+
+            await cur.execute(query, params)
             records = await cur.fetchall()
+            print(f"查询结果: {records}")  # 打印查询结果
 
             # 将查询结果转换为字典列表
             result = [