From c52347661341a61cb2de2db1b9dee7c0f69dd309 Mon Sep 17 00:00:00 2001
From: HuangHai <10402852@qq.com>
Date: Tue, 25 Mar 2025 14:56:45 +0800
Subject: [PATCH] 'commit'

---
 AI/WxMini/Utils/MySQLUtil.py | 14 ++++++++++----
 1 file changed, 10 insertions(+), 4 deletions(-)

diff --git a/AI/WxMini/Utils/MySQLUtil.py b/AI/WxMini/Utils/MySQLUtil.py
index 70911e0a..6c3b311b 100644
--- a/AI/WxMini/Utils/MySQLUtil.py
+++ b/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 = [