From bbfc00fbe443de9178a12599b360a3fe8a8415e7 Mon Sep 17 00:00:00 2001
From: HuangHai <10402852@qq.com>
Date: Wed, 26 Mar 2025 11:17:11 +0800
Subject: [PATCH] 'commit'

---
 .../Milvus/Utils/MilvusCollectionManager.py   |   2 +-
 .../MilvusCollectionManager.cpython-310.pyc   | Bin 4529 -> 4528 bytes
 AI/WxMini/Milvus/X1_create_collection.py      |   6 +-
 AI/WxMini/Milvus/X3_insert_data.py            |   4 +-
 AI/WxMini/Milvus/X4_select_all_data.py        |   6 +-
 AI/WxMini/Milvus/X5_search_near_data.py       |   2 +-
 AI/WxMini/Sql/t_chat_log.sql                  |   2 +-
 AI/WxMini/Start.py                            |  71 ++++++++++++++----
 AI/WxMini/Test/Math1.py                       |   4 +-
 AI/WxMini/Utils/MySQLUtil.py                  |  65 ++++++++++------
 .../__pycache__/MySQLUtil.cpython-310.pyc     | Bin 5967 -> 6553 bytes
 .../__pycache__/RedisUtil.cpython-310.pyc     | Bin 1880 -> 2085 bytes
 AI/WxMini/__pycache__/Start.cpython-310.pyc   | Bin 8251 -> 9093 bytes
 .../build/lib/nls/stream_input_tts.py         |   6 +-
 14 files changed, 116 insertions(+), 52 deletions(-)

diff --git a/AI/WxMini/Milvus/Utils/MilvusCollectionManager.py b/AI/WxMini/Milvus/Utils/MilvusCollectionManager.py
index 1d10aa19..39234eaa 100644
--- a/AI/WxMini/Milvus/Utils/MilvusCollectionManager.py
+++ b/AI/WxMini/Milvus/Utils/MilvusCollectionManager.py
@@ -71,7 +71,7 @@ class MilvusCollectionManager:
             # 使用 Milvus 的 query 方法查询指定 ID 的记录
             results = self.collection.query(
                 expr=f"id == {id}",  # 查询条件
-                output_fields=["id", "session_id", "user_input", "model_response", "timestamp"]  # 返回的字段
+                output_fields=["id", "person_id", "user_input", "model_response", "timestamp"]  # 返回的字段
             )
             if results:
                 return results[0]  # 返回第一条记录
diff --git a/AI/WxMini/Milvus/Utils/__pycache__/MilvusCollectionManager.cpython-310.pyc b/AI/WxMini/Milvus/Utils/__pycache__/MilvusCollectionManager.cpython-310.pyc
index 22ad788fc6da1eae1ab6a213c10369c44cc8103f..b7382af3526516e81848f119f5b38c8e8ca7bfd4 100644
GIT binary patch
delta 33
ncmdm}yg`{apO=@50SKzHAE&2m<eksO%2|+FRJ?f;*MBwuo(u|p

delta 34
ocmdm>yiu7qpO=@50SJ;<9;T;m<eksO##NkJT%5UiBiDa60G_G}YybcN

diff --git a/AI/WxMini/Milvus/X1_create_collection.py b/AI/WxMini/Milvus/X1_create_collection.py
index 9c513aa5..0318dea3 100644
--- a/AI/WxMini/Milvus/X1_create_collection.py
+++ b/AI/WxMini/Milvus/X1_create_collection.py
@@ -1,3 +1,5 @@
+import asyncio
+
 from pymilvus import FieldSchema, DataType, utility
 
 from WxMini.Milvus.Utils.MilvusCollectionManager import MilvusCollectionManager
@@ -23,13 +25,13 @@ if utility.has_collection(collection_name):
 # 5. 定义集合的字段和模式
 fields = [
     FieldSchema(name="id", dtype=DataType.INT64, is_primary=True, auto_id=True),  # 主键字段，自动生成 ID
-    FieldSchema(name="session_id", dtype=DataType.VARCHAR, max_length=64),  # 会话 ID
+    FieldSchema(name="person_id", dtype=DataType.VARCHAR, max_length=64),  # 会话 ID
     FieldSchema(name="user_input", dtype=DataType.VARCHAR, max_length=2048),  # 用户问题
     FieldSchema(name="model_response", dtype=DataType.VARCHAR, max_length=2048),  # 大模型反馈结果
     FieldSchema(name="timestamp", dtype=DataType.VARCHAR, max_length=32),  # 时间
     FieldSchema(name="embedding", dtype=DataType.FLOAT_VECTOR, dim=MS_DIMENSION)  # 向量字段，维度为 200
 ]
-schema_description = "Chat records collection with session ID, user input, model response, and timestamp"
+schema_description = "Chat records collection with person_id , user input, model response, and timestamp"
 
 # 6. 创建集合
 print(f"正在创建集合 '{collection_name}'...")
diff --git a/AI/WxMini/Milvus/X3_insert_data.py b/AI/WxMini/Milvus/X3_insert_data.py
index b5e614f6..c8b68618 100644
--- a/AI/WxMini/Milvus/X3_insert_data.py
+++ b/AI/WxMini/Milvus/X3_insert_data.py
@@ -66,14 +66,14 @@ print(f"大模型回复: {model_response}")
 
 # 7. 获取当前时间和会话 ID
 timestamp = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())  # 当前时间
-session_id = "F9D1C319-215D-3B4E-FAA0-0E024AC12D3C"  # 会话 ID（可以根据需要动态生成）
+person_id = "F9D1C319-215D-3B4E-FAA0-0E024AC12D3C"  # 会话 ID（可以根据需要动态生成）
 
 # 8. 将用户问题转换为嵌入向量
 user_embedding = text_to_embedding(user_input)
 
 # 9. 插入数据，确保字段顺序与集合定义一致
 entities = [
-    [session_id],  # session_id
+    [person_id],  # person_id
     [user_input],  # user_input
     [model_response],  # model_response
     [timestamp],  # timestamp
diff --git a/AI/WxMini/Milvus/X4_select_all_data.py b/AI/WxMini/Milvus/X4_select_all_data.py
index 290c89ec..0a8395ba 100644
--- a/AI/WxMini/Milvus/X4_select_all_data.py
+++ b/AI/WxMini/Milvus/X4_select_all_data.py
@@ -21,7 +21,7 @@ try:
     # 使用 Milvus 的 query 方法查询所有数据
     results = collection_manager.collection.query(
         expr="",  # 空表达式表示查询所有数据
-        output_fields=["id", "session_id", "user_input", "model_response", "timestamp", "embedding"],  # 指定返回的字段
+        output_fields=["id", "person_id", "user_input", "model_response", "timestamp", "embedding"],  # 指定返回的字段
         limit=1000  # 设置最大返回记录数
     )
     print("查询结果：")
@@ -29,14 +29,14 @@ try:
         for result in results:
             try:
                 # 获取字段值
-                session_id = result["session_id"]
+                person_id = result["person_id"]
                 user_input = result["user_input"]
                 model_response = result["model_response"]
                 timestamp = result["timestamp"]
                 embedding = result["embedding"]
                 # 打印结果
                 print(f"ID: {result['id']}")
-                print(f"会话 ID: {session_id}")
+                print(f"会话 ID: {person_id}")
                 print(f"用户问题: {user_input}")
                 print(f"大模型回复: {model_response}")
                 print(f"时间: {timestamp}")
diff --git a/AI/WxMini/Milvus/X5_search_near_data.py b/AI/WxMini/Milvus/X5_search_near_data.py
index 39ca8bd7..f75dc867 100644
--- a/AI/WxMini/Milvus/X5_search_near_data.py
+++ b/AI/WxMini/Milvus/X5_search_near_data.py
@@ -62,7 +62,7 @@ if results:
                 # 查询非向量字段
                 record = collection_manager.query_by_id(hit.id)
                 print(f"ID: {hit.id}")
-                print(f"会话 ID: {record['session_id']}")
+                print(f"会话 ID: {record['person_id']}")
                 print(f"用户问题: {record['user_input']}")
                 print(f"大模型回复: {record['model_response']}")
                 print(f"时间: {record['timestamp']}")
diff --git a/AI/WxMini/Sql/t_chat_log.sql b/AI/WxMini/Sql/t_chat_log.sql
index cbb24698..17b9e98c 100644
--- a/AI/WxMini/Sql/t_chat_log.sql
+++ b/AI/WxMini/Sql/t_chat_log.sql
@@ -23,7 +23,7 @@ SET FOREIGN_KEY_CHECKS = 0;
 DROP TABLE IF EXISTS `t_chat_log`;
 CREATE TABLE `t_chat_log`  (
   `id` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键',
-  `session_id` char(36) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT '用户人员编号',
+  `person_id` char(36) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT '用户人员编号',
   `user_input` varchar(2000) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT '用户提出的问题',
   `model_response` varchar(2000) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT '大模型的反馈',
   `audio_url` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '生成的语音文件路径',
diff --git a/AI/WxMini/Start.py b/AI/WxMini/Start.py
index e770c91b..76c9dafd 100644
--- a/AI/WxMini/Start.py
+++ b/AI/WxMini/Start.py
@@ -13,7 +13,7 @@ from WxMini.Milvus.Utils.MilvusConnectionPool import *
 from WxMini.Utils.OssUtil import upload_mp3_to_oss_from_memory
 from WxMini.Utils.TtsUtil import TTS
 from WxMini.Utils.MySQLUtil import init_mysql_pool, save_chat_to_mysql, get_chat_log_by_session, update_risk, \
-    get_risk_chat_log_page, get_last_chat_log_id
+    get_risk_chat_log_page, get_last_chat_log_id, get_user_by_login_name
 from WxMini.Utils.EmbeddingUtil import text_to_embedding
 
 # 配置日志
@@ -46,9 +46,9 @@ async def lifespan(app: FastAPI):
 
 
 # 会话结束后，调用检查方法，判断是不是有需要介入的问题出现
-async def on_session_end(session_id):
+async def on_session_end(person_id):
     # 获取最后一条聊天记录
-    last_id = await get_last_chat_log_id(app.state.mysql_pool, session_id)
+    last_id = await get_last_chat_log_id(app.state.mysql_pool, person_id)
     if last_id:
         # 查询最后一条记录的详细信息
         async with app.state.mysql_pool.acquire() as conn:
@@ -90,10 +90,10 @@ async def on_session_end(session_id):
         analysis_result = response.choices[0].message.content.strip()
         if analysis_result.startswith("NO"):
             # 异步执行 update_risk
-            asyncio.create_task(update_risk(app.state.mysql_pool, session_id, analysis_result))
-            logger.info(f"已异步更新 session_id={session_id} 的风险状态。")
+            asyncio.create_task(update_risk(app.state.mysql_pool, person_id, analysis_result))
+            logger.info(f"已异步更新 person_id={person_id} 的风险状态。")
         else:
-            logger.info(f"AI大模型没有发现任何心理健康问题，用户会话 {session_id} 没有风险。")
+            logger.info(f"AI大模型没有发现任何心理健康问题，用户会话 {person_id} 没有风险。")
 
 
 # 初始化 FastAPI 应用
@@ -106,11 +106,12 @@ client = AsyncOpenAI(
 )
 
 
+
 @app.post("/aichat/reply")
-async def reply(session_id: str = Form(...), prompt: str = Form(...)):
+async def reply(person_id: str = Form(...), prompt: str = Form(...)):
     """
     接收用户输入的 prompt，调用大模型并返回结果
-    :param session_id: 用户会话 ID
+    :param person_id: 用户会话 ID
     :param prompt: 用户输入的 prompt
     :return: 大模型的回复
     """
@@ -132,7 +133,7 @@ async def reply(session_id: str = Form(...), prompt: str = Form(...)):
             collection_manager.search,
             data=current_embedding,  # 输入向量
             search_params=search_params,  # 搜索参数
-            expr=f"session_id == '{session_id}'",  # 按 session_id 过滤
+            expr=f"person_id == '{person_id}'",  # 按 person_id 过滤
             limit=5  # 返回 5 条结果
         )
         end_time = time.time()
@@ -182,7 +183,7 @@ async def reply(session_id: str = Form(...), prompt: str = Form(...)):
             # 记录用户输入和大模型反馈到向量数据库
             timestamp = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
             entities = [
-                [session_id],  # session_id
+                [person_id],  # person_id
                 [prompt[:500]],  # user_input，截断到 500 字符
                 [result[:500]],  # model_response，截断到 500 字符
                 [timestamp],  # timestamp
@@ -214,11 +215,11 @@ async def reply(session_id: str = Form(...), prompt: str = Form(...)):
             url = OSS_PREFIX + tts_file
 
             # 记录聊天数据到 MySQL
-            await save_chat_to_mysql(app.state.mysql_pool, session_id, prompt, result, url, duration)
+            await save_chat_to_mysql(app.state.mysql_pool, person_id, prompt, result, url, duration)
             logger.info("用户输入和大模型反馈已记录到 MySQL 数据库。")
 
             # 调用会话检查机制
-            await on_session_end(session_id)
+            await on_session_end(person_id)
 
             # 返回数据
             return {
@@ -241,22 +242,62 @@ async def reply(session_id: str = Form(...), prompt: str = Form(...)):
 # 获取聊天记录
 from fastapi import Query
 
+# 登录接口
+@app.post("/aichat/login")
+async def login(
+    login_name: str = Form(..., description="用户名"),
+    password: str = Form(..., description="密码")
+):
+    """
+    用户登录接口
+    :param login_name: 用户名
+    :param password: 密码
+    :return: 登录结果
+    """
+    if not login_name or not password:
+        raise HTTPException(status_code=400, detail="用户名和密码不能为空")
+
+    # 调用 get_user_by_login_name 方法
+    user = await get_user_by_login_name(app.state.mysql_pool, login_name)
+    if not user:
+        raise HTTPException(status_code=404, detail="用户不存在")
+    if user['password'] != password:
+        raise HTTPException(status_code=401, detail="密码错误")
+
+    # 返回带字段名称的数据
+    return {
+        "code": 200,
+        "message": "登录成功",
+        "data": {
+            "person_id": user["person_id"],
+            "login_name": user["login_name"],
+            "identity_id": user["identity_id"],
+            "person_name": user["person_name"],
+            "xb_name": user["xb_name"],
+            "city_name": user["city_name"],
+            "area_name": user["area_name"],
+            "school_name": user["school_name"],
+            "grade_name": user["grade_name"],
+            "class_name": user["class_name"]
+        }
+    }
+
 # 获取聊天记录
 @app.get("/aichat/get_chat_log")
 async def get_chat_log(
-        session_id: str,
+        person_id: str,
         page: int = Query(default=1, ge=1, description="当前页码（默认值为 1，但会动态计算为最后一页）"),
         page_size: int = Query(default=10, ge=1, le=100, description="每页记录数")
 ):
     """
     获取指定会话的聊天记录，默认返回最新的记录（最后一页）
-    :param session_id: 用户会话 ID
+    :param person_id: 用户会话 ID
     :param page: 当前页码（默认值为 1，但会动态计算为最后一页）
     :param page_size: 每页记录数
     :return: 分页数据
     """
     # 调用 get_chat_log_by_session 方法
-    result = await get_chat_log_by_session(app.state.mysql_pool, session_id, page, page_size)
+    result = await get_chat_log_by_session(app.state.mysql_pool, person_id, page, page_size)
     return result
 
 @app.get("/aichat/get_risk_page")
diff --git a/AI/WxMini/Test/Math1.py b/AI/WxMini/Test/Math1.py
index e6ad4749..85b9574c 100644
--- a/AI/WxMini/Test/Math1.py
+++ b/AI/WxMini/Test/Math1.py
@@ -14,10 +14,10 @@ prompt = "You are a helpful and harmless assistant. You are Qwen developed by Al
 #img_url = 'https://qianwen-res.oss-cn-beijing.aliyuncs.com/QVQ/demo.png'
 # 答案=46
 
-img_url='https://hzkc.oss-cn-beijing.aliyuncs.com/Temp/simple_math.jpeg'
+#img_url='https://hzkc.oss-cn-beijing.aliyuncs.com/Temp/simple_math.jpeg'
 # 答案应该是80度
 
-# img_url='https://hzkc.oss-cn-beijing.aliyuncs.com/Temp/hard_math.jpeg'
+img_url='https://hzkc.oss-cn-beijing.aliyuncs.com/Temp/hard_math.jpeg'
 
 response = client.chat.completions.create(
     #model="Qwen/QVQ-72B-Preview",
diff --git a/AI/WxMini/Utils/MySQLUtil.py b/AI/WxMini/Utils/MySQLUtil.py
index 4105a265..50647a2c 100644
--- a/AI/WxMini/Utils/MySQLUtil.py
+++ b/AI/WxMini/Utils/MySQLUtil.py
@@ -1,4 +1,6 @@
 import logging
+from typing import Optional, Dict
+
 from aiomysql import create_pool
 from WxMini.Milvus.Config.MulvusConfig import *
 
@@ -24,12 +26,12 @@ async def init_mysql_pool():
 
 
 # 保存聊天记录到 MySQL
-async def save_chat_to_mysql(mysql_pool, session_id, prompt, result, audio_url, duration):
+async def save_chat_to_mysql(mysql_pool, person_id, prompt, result, audio_url, duration):
     async with mysql_pool.acquire() as conn:
         async with conn.cursor() as cur:
             await cur.execute(
-                "INSERT INTO t_chat_log (session_id, user_input, model_response,audio_url,duration,create_time) VALUES (%s, %s, %s, %s, %s,NOW())",
-                (session_id, prompt, result, audio_url, duration)
+                "INSERT INTO t_chat_log (person_id, user_input, model_response,audio_url,duration,create_time) VALUES (%s, %s, %s, %s, %s,NOW())",
+                (person_id, prompt, result, audio_url, duration)
             )
             await conn.commit()
 
@@ -46,11 +48,11 @@ async def truncate_chat_log(mysql_pool):
 from aiomysql import DictCursor
 
 # 分页查询聊天记录
-async def get_chat_log_by_session(mysql_pool, session_id, page=1, page_size=10):
+async def get_chat_log_by_session(mysql_pool, person_id, page=1, page_size=10):
     """
-    根据 session_id 查询聊天记录，并按 id 降序分页
+    根据 person_id 查询聊天记录，并按 id 降序分页
     :param mysql_pool: MySQL 连接池
-    :param session_id: 用户会话 ID
+    :param person_id: 用户会话 ID
     :param page: 当前页码（默认值为 1，但会动态计算为最后一页）
     :param page_size: 每页记录数
     :return: 分页数据
@@ -62,8 +64,8 @@ async def get_chat_log_by_session(mysql_pool, session_id, page=1, page_size=10):
         async with conn.cursor(DictCursor) as cur:  # 使用 DictCursor
             # 查询总记录数
             await cur.execute(
-                "SELECT COUNT(*) FROM t_chat_log WHERE session_id = %s",
-                (session_id,)
+                "SELECT COUNT(*) FROM t_chat_log WHERE person_id = %s",
+                (person_id,)
             )
             total = (await cur.fetchone())['COUNT(*)']
 
@@ -75,9 +77,9 @@ async def get_chat_log_by_session(mysql_pool, session_id, page=1, page_size=10):
 
             # 查询分页数据，按 id 降序排列
             await cur.execute(
-                "SELECT id, session_id, user_input, model_response, audio_url, duration, create_time "
-                "FROM t_chat_log WHERE session_id = %s ORDER BY id DESC LIMIT %s OFFSET %s",
-                (session_id, page_size, offset)
+                "SELECT id, person_id, user_input, model_response, audio_url, duration, create_time "
+                "FROM t_chat_log WHERE person_id = %s ORDER BY id DESC LIMIT %s OFFSET %s",
+                (person_id, page_size, offset)
             )
             records = await cur.fetchall()
 
@@ -88,7 +90,7 @@ async def get_chat_log_by_session(mysql_pool, session_id, page=1, page_size=10):
             result = [
                 {
                     "id": record['id'],
-                    "session_id": record['session_id'],
+                    "person_id": record['person_id'],
                     "user_input": record['user_input'],
                     "model_response": record['model_response'],
                     "audio_url": record['audio_url'],
@@ -108,7 +110,7 @@ async def get_chat_log_by_session(mysql_pool, session_id, page=1, page_size=10):
 
 
 # 获取指定会话的最后一条记录的 id
-async def get_last_chat_log_id(mysql_pool, session_id):
+async def get_last_chat_log_id(mysql_pool, person_id):
     """
     获取指定会话的最后一条记录的 id
     :param mysql_pool: MySQL 连接池
@@ -118,19 +120,19 @@ async def get_last_chat_log_id(mysql_pool, session_id):
     async with mysql_pool.acquire() as conn:
         async with conn.cursor() as cur:
             await cur.execute(
-                "SELECT id FROM t_chat_log WHERE session_id = %s ORDER BY id DESC LIMIT 1",
-                (session_id,)
+                "SELECT id FROM t_chat_log WHERE person_id = %s ORDER BY id DESC LIMIT 1",
+                (person_id,)
             )
             result = await cur.fetchone()
             return result[0] if result else None
 
 
 # 更新为危险的记录
-async def update_risk(mysql_pool, session_id, risk_memo):
+async def update_risk(mysql_pool, person_id, risk_memo):
     async with mysql_pool.acquire() as conn:
         async with conn.cursor() as cur:
             # 1. 获取此人员的最后一条记录 id
-            last_id = await get_last_chat_log_id(mysql_pool, session_id)
+            last_id = await get_last_chat_log_id(mysql_pool, person_id)
 
             if last_id:
                 # 2. 更新 risk_flag 和 risk_memo
@@ -139,9 +141,9 @@ async def update_risk(mysql_pool, session_id, risk_memo):
                     (risk_memo.replace('\n', '').replace("NO", ""), last_id)
                 )
                 await conn.commit()
-                logger.info(f"已更新 session_id={session_id} 的最后一条记录 (id={last_id}) 的 risk_flag 和 risk_memo。")
+                logger.info(f"已更新 person_id={person_id} 的最后一条记录 (id={last_id}) 的 risk_flag 和 risk_memo。")
             else:
-                logger.warning(f"未找到 session_id={session_id} 的记录。")
+                logger.warning(f"未找到 person_id={person_id} 的记录。")
 
 
 # 查询有风险的聊天记录
@@ -166,7 +168,7 @@ async def get_risk_chat_log_page(mysql_pool, risk_flag, page=1, page_size=10):
 
             # 查询分页数据
             query = (
-                "SELECT id, session_id, user_input, model_response, audio_url, duration, create_time, risk_memo "
+                "SELECT id, person_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"
             )
             params = (risk_flag, page_size, offset)
@@ -180,7 +182,7 @@ async def get_risk_chat_log_page(mysql_pool, risk_flag, page=1, page_size=10):
             result = [
                 {
                     "id": record[0],
-                    "session_id": record[1],
+                    "person_id": record[1],
                     "user_input": record[2],
                     "model_response": record[3],
                     "audio_url": record[4],
@@ -196,4 +198,23 @@ async def get_risk_chat_log_page(mysql_pool, risk_flag, page=1, page_size=10):
                 "total": total,
                 "page": page,
                 "page_size": page_size
-            }
\ No newline at end of file
+            }
+# 查询用户信息
+async def get_user_by_login_name(mysql_pool, login_name: str) -> Optional[Dict]:
+    """
+    根据用户名查询用户信息
+    :param pool: MySQL 连接池
+    :param login_name: 用户名
+    :return: 用户信息（字典形式）
+    """
+    async with mysql_pool.acquire() as conn:
+        async with conn.cursor() as cursor:
+            sql = "SELECT * FROM t_base_person WHERE login_name = %s"
+            await cursor.execute(sql, (login_name,))
+            row = await cursor.fetchone()
+            if not row:
+                return None
+
+            # 将元组转换为字典
+            columns = [column[0] for column in cursor.description]
+            return dict(zip(columns, row))
\ No newline at end of file
diff --git a/AI/WxMini/Utils/__pycache__/MySQLUtil.cpython-310.pyc b/AI/WxMini/Utils/__pycache__/MySQLUtil.cpython-310.pyc
index bef1a1937aff4f6df597e10cfd2bfc9b7a169510..4fb6dc199fe526815846a39954b9519bcbcb5240 100644
GIT binary patch
delta 1486
zcma)+Z%iCT6u|e*?%wU~aR==E<6pgPDU>Uf7AgKgtm1)fO$7sORnqi&unQ$Q?&#cI
z6?zvSL9NCnl4)vfO}uNW!G54tnp7!T6a8Xh(pbOf`BCml6BA90elb{Qb}3N(;%xS}
zZ{EC_dGp@Bx!Le;lQZUU$Q*6sBR>!R@xZjR3NB994+J@_I0C~;uL7J_rIl*R6!f|@
zm*$@0dfl2w^U|+}j`*}PI^xyJb>9HeDzwTep|?zf9xkxq%6ut;aq=xH6Gn6#CnM4(
zV&@a0jrHbU<$nif0CIBsP=6wr#PJv=uZVuwLC%V5WhyPCgbYgXS=h<#<utU1J9j88
zro@auz7t&_lDxRlA(n9|-p!>YL+`ivT$b#Lb=sD)Wvp2aIMQb6f)ixgQeQXyG62;8
z_Y!?IM4gnA0pK`UrLB<ptZ-^pHC)YGYDl^Ar0I93^^w{;*Uv7^Ud&G{EPgt#HvYQs
z*5c={EiRnPzd2Kwm|U98-kyDjj*uDaao9=xQf&iUCKe41Y3dVdO?*rWb{**4U$-@Y
zEi~3+=X*N#bp-dTL)tcT!x5?1-0Y_0BZnMz@|zSTXKbxx(&nkgo9P_vW2j-MWvF1N
zWY|JMZrPgQMIy<gx|EX-h9gP61LGLR3bSxAY+`Uz<fH*T(SI}+)mNl&B$BgY{Wx`5
z57@Dn85+AaGU*|PDuxXVI~bbC4|3aHHXPqYfhGi-1PXG4fDi~E|E&lmd=W432qYvg
zJ4K1N@JP1&iJS<`NBGPAqxWtZG~C54bDI4+z;2>C)b&v)b$ukPI{@<?H<JlR5MtzO
zM>Vw0Eje^hm_C2)lfwC{g)<+U;XG2j&rlcMyHt4Ni~PwI^^M{hXeIgL7)+7_C0n3<
zE?sg7m3;W$Yy`;(*DvI#t-J@<(dF-0DFV{}NCbYGc^P1+XK=2fgh>q)SIPJ8uGa0W
zYXoyO%5;OZbeX4RMt%mBA}4BkUvdyXOb&az4Xe}eqs-v`4CTaQNga>oEF)nY9**P3
z$OX@KI8APO+75TIrQ}F#a3~szhKKcjL>2d%NCkEud_~{*JjEoWxD1!&j4}jThP%@!
zg)*>CQ<vs7L<^SBpp-za*el3S_9l3W6c^P$d+@%JWA_4|e4XvFR&uvb&lFBx%fEf9
z@csu&moJ#z#T(he<YmLE#W;gX>Z}{b*Su~~SLc~lSWhHz^qzX%{LZn)l>~29pXu&;
zPECaR!f`!hmZ<u|o{sJgb!}mzVDaPB$AD<o!t+!%<9mcvQjU)wi~K9GIq#sJ2qoh>
z4)u+O))xDQ+Q(Tc(S%}EXlb~i2;9pnKYlkI2q5E1z|~AHCl7kR^c$7hLi@Otp`F1<
e8Xr$!+)b9fwXltB_Ei@ZNir|(k`&pcH2(uch>h0(

delta 1090
zcmZ9K{cBrQ7{~8(?n`cNmNdyt?$VdJyJfda?AnfPRaVn#?J`>IT4;-7{lOA<(iiC(
zJ!#d+4VE$HlvUUskWTC9KsFgtrV;k0!+$^o5tRI<n9$)569fknt>+}Au%5&Hoaa90
zd(QLlJm>PkAKC&rzu%DfczEWw$<LcE2Abf5i!Bq$7!A_USr`k`Fg4FgV<wHzC|@JA
zo?3J}--%Kfk&+Ex{uCllE%XnLq=!fC{=v~9dv5&XRAz2`CO2s(^4WZT8kh9lxJRDT
zjOuUkQ~58zE9y=-fcI6qwNOx8WrbXo4oUqIC4JJzuM|{QU6HBm!US9;H7`iqr=VZk
z6({o&>vTN@;u5OHBv+0|1-*JgbHSBeeL}`{)glEiX0;)3@#jzrT*6;9GnxQNGHgC7
zD|af3t9C6x-Q&pR#rJT(Cxw4(+l3cAjq&oeGnFgLzu&%V59VgG55KukK7aYay`{C)
z&(>}g*S`IteEueW?|BnC&}TNcRPV{nj!#p&%XadNhmn}Z@y_x{dLZ39YERRB8_|~Z
zu^n6V_R#Q=^sxQn2`;mHu+IAyE=J<f$06rLt8=Q=p|;c4=^X2HMv@*p=S|^bZwDO5
z{l@9zTFH1hGc%t}GnQj4EaI915ss2Rk)1m^#q-~=GBYztAG5^%c7YCoX9SuAb_g62
zcoqY`o|oFWnSX(UEGS+b!Xyj|A)tWqUswssx~#x9S&<3o#P~O$YBDjjze#{VZ7Tmn
zezDeL(6-LHic7wG0DU;>x7AwF-}WcWq_QPrb{LEPUYNy4{y20O8v|J|qdbA~t*<Jd
zd|mnI=0*)K)eThrmE{|i_wVywZ214IbD$foU=9}WTyQTOEv^P{kkIw5O(;&8?eH#(
z^Q+k&0Y{)&V6Q-e<AH}Gsk5YTRLk|Wuv!Ef1R4eQ2^<k<6%Zw3flUO3b%3MDzkG~C
zlZa1yqye93MN_GRLQ$>xW;1xqC;P|_3(-yio1>)C?5p#WtP?+sT5X%h*mFYgWFt%J
z8}nIqx}?3HVVP5Tmck#S?SM$Eo`wM~Pm)2lySi3iYt6Qh#=Z-7iQBpbjtUH5Z+$Z)
Q@U{B5Zg}<Q^>D!aA3<&t7XSbN

diff --git a/AI/WxMini/Utils/__pycache__/RedisUtil.cpython-310.pyc b/AI/WxMini/Utils/__pycache__/RedisUtil.cpython-310.pyc
index 507cb7b34370ec0b6bce69bbf82db79088a62752..4a9271476eb9408bf513491e949d2891c5567144 100644
GIT binary patch
delta 469
zcmX|+O-lkn7{})sR~>iVRZK%e#9j!NqHZ0!1a<4s#f8YrChQVrDU2(kXa;tWAV};I
z5gF(QFoV8BpCG)3QP8n_J(J|X{N~|5zh_=vwO&xmtEx<Jl(*jwHhnEE4*RX8ji{wq
z{&SL6Y`>*uDPOUD4Fbeg`qv#=r|65OEu4ikq7rh*5jfO>OQ?}5>9{QV06-kcay4+>
zB^F5$i8$`^GLRZ36%F^KD%_GgIyUyuslh1-b6l06M0EEKXLtkmA&N1CVboJeBcHW%
z$<g!Ud-G~^aX)HyK5x2z+v7567!#@6|9I-HCv^{3#6f-m6*2T!_Ob2QJRp)FLZ^I6
z)M0_h1k+dzRg_J~DVR<^fp<qSD~KKnekxN9G>8K`qdz=0Sa9_K=GrgPEW`(2(ju&`
z30o7k#L%3$35<r!G*2>zIn&gEdoj?}Hun^x;;%d|@NeZZC$?#}Bi{KL@gznVge2L;
O0!(IMrg&tTO5eXM&}Ya1

delta 259
zcmZ1~aD$I8pO=@50SIc@9;QELpU5Y}STs@FUMrP5g*%(6$UKE7iYJvLm8Y4Jks+0{
znIVcdmAA+!l`jQIH!}gnxHdK|VA|}*GL?~0a`F>aMMkO3Y;0<bjJlI`*~L9%fF|GK
zh>y=r%*>0Aj}orTFD;5MDJhOG$<I#Bi_b_cN-Y%!s(I13{b~QSryU!f&uUQ!2?<sR
z0m)lwG8VA|Wi|OHN3)meNdcKfFcb3<b5rBvi#S0R@E4_)6lJECrKUj4E#e1?PJY3z
ktN>EY!N9>N#KOhQA;2NR!Og<N!N|tU!pOzQ#mw>*0QV|GZU6uP

diff --git a/AI/WxMini/__pycache__/Start.cpython-310.pyc b/AI/WxMini/__pycache__/Start.cpython-310.pyc
index 58368920199a2cc99927df3142bb86698aa6431c..d4d62029c95ea43ed79a9b2cd159fa401a938503 100644
GIT binary patch
delta 2520
zcma)7T~J%c6~4RrMG``QB@hNl#(=q)|HO76ZsT_PljI?BO=r?kn`%_;LWG5+SzU$V
ziV6oewNop>xprb3OrXK3GaVaGX=^veFYR>PX<s|jncJ7n6bX3f@YFsvcF$R1o6?u+
z&i%A|_Izj0-|oG4>_=aBrz$HQ3jAJ9|9wO|biv(7d+CMFrTkc9xREGKVU9%8SRfoA
z3MZpMctgy|Tm_2rg?+qvk%ag27T(I+_yJZ~FooN>8t&j#yknY#4{{50bK5XwRm^k7
z43bV(&1%jl;Vy3DovgM%!rk1(d)OZ4Ezoc;?_TI*zD2_Gc2+k{xJ01W^M2;%{ljL~
z!1kW8fT3r=wZ?>X%n^2gD@bbs8tAhC3l^vxg>VGyeZX#(?ES1ovY!RUA=U~E2Wx}p
z0BbLpV64KpgB@g@`GR?S+b({Xb@Ri+R@TFMCHaUX_dOx^Z<Eo`GrJ9e9TR&NY&^Ad
zh#i)8p5x8z$Voawgb#utiGlC{9~d2E&#?hkI|#;}FPNbOWJtd1QN5AQ5u5%SI#F-<
zMz|KqX1IuaZz7UNjl`3YWOR(L^qU?LyC3TLsUlkR0m})}wsPKbjO;V{l~MO-mH2(m
zHd@KHXA7Q1WzwFrFH|$P{ts)guPUd^D$H}uv`Db{LyG2I@Udzst$8ZN6@1lN{R_6^
zenDWvEVhxOI6J?7^WxU()lHPG+_gO-O$L4C)ocSyi+6reTz#u_^LlCam!%JGhtgbR
zbfY5gM2AHXA*3_MTy-N3n*h`bqe5!cIES1qD3#Evr=6n^*<YR9<k8x5HFe6QPgAvy
z(SxI%`td4%z6%4;x^l`ic}ZavFDejDcg~ly<t+6|&YN?yo;k~F%4>>77rJv4wINs^
z3$k7oD$uuxS<xzI$ixGpOuC42%Bv|0Zq}!Ta;|AIt6Y-|slP*3X0nP&m+yzJaWcNc
z__(6>XYc3_tG;2D@%+iZUmy46Ep9pcw<pqNIAl5F$#hoBx*$|Xap`BJ8;iyHpA3c!
z_gISYL`3jRI+e`ul{c%sCjHlYmYaLTlVpi~z%ty}8L?C{$zxhPl@zu5kG-v=LBHw!
zTa)2<b!aGZ{KQwk_R_aRC8l#{=I4EX2@Ru=A?(ODnzaa?PD~{AOLY(OGayiju)^Od
zYme-{Yz0i#FWxAfy;GbisKjtGo{5Qg8hyy3W^wuL^@Y=h<7u-R_H;Cp8BYloqoDBk
zXM%wn-rvESnFlyca*D9zNXDtbNnkY3Ojsd}XcX#8p}yu9l}VbTnZ2N3Vb=0`jxw8H
z$&r&LaRB6YR#BES2Xn%j3)U#Bl!$tixg}Of^hm6hSR=7k;vT>}WnRC+d~;4#H)n!V
zP@m0!n~o6t$|+dCa<6#*Qt936#rHmz;=y!OM8`r;V;|hsgk<ehc$|>IP&r-YHNmy4
zNCHKgUC-asOY?JbDLw<oEE|B`pX9#y{`oR@?QUUX`u^J8&(=TvOhiECmH0)}u6m*k
z8pWHJi*q-G4zl<KT*b~S^EWSE*;roQ`~wK2bUUcCGx_2>ABiy#i}w*a01PwUK8AIK
zCm9!pITqI@3_FWwG!c(!hBXs=Bb7=RmJtzU+_1zFP<Yk3!w5PcEs0Aw`T*fWgv$t5
z5UwK30_0T_>;UIM97WL(fNByJ9M>R($^z+}wA+c&-Tf?U@h@1(bOX>SyVFHHCNpu#
zhngv|QY-o2$NW#T^>cAef4$zH7YBfv{R%+wzFs_6*j)S-^!V25+0A>GH*PHzr&b~T
zp}wuv^K19tUR%9deCI}K>h#8~#r0bs!b)jwsyOrR+TAJOZLOYzuxyMEN3#jdpd(yd
z0K1!btBP;qHdwdP@_V4WaqBj=*Coeo)hzIYh>vu$|2w2kkNWxJ`{hX6|L27MbN^ob
zSi_f3?6?ZRBv}3uTK*}*#|Y;Tc4g5eFPk@_8h(R<&_5YG>U65!Z6;!A<<AWdNdCLX
z!~Rn%ga^m}y^%<wOkQFs9E~GjF;$DWj^kY(oJH9#H!9H$5zm~Aq@yFe7yZCapi|UU
zuQxQg$tSwnq^dro)&UqcxOGm#*GGL`yddY`K72z*L>yJVzw(17l~7TmF9t%SR{w3F
zlQimE0r-sSy}^1fo;QIXG|`6eGJ;=!Js9|=bRMrqaSgyQfnVYjPL~iqL76T4W;~V>
zNy8+v$sK{nkXlj0eiSbIY=VCg;!rYE`X7UPNsC?z2K=^WqU2o`yU9Tv#QcyF`iN53
TLwmdK47J-Gd+fwV&7c1VwI<;Y

delta 1655
zcma)6ZERCj7(VCr>(aGdSJtj$ZFkphu*=r&19VDIM+gxNY|13W22y9wp=;N*%enW0
zBbN*r7>pK24oq-^bY?0fBE)JSGJYDuUlT*pAI2Cvw#0-#=s$wz+)bGLvdww=p7%b_
z)Ayt4sn>7!y7Eq^9kAEr#P6wW=UG=k_!FLOpBsk&0c6hxMuPDm1Q=#Q>@=b(<R}RI
zUX*atER2V71UKUrydF6VruYWj8kcc3mM36*BeozHwjB~sHFBRcvrHSRL7tN!-i~d!
z4XrJ}coaKu4AmlUL5O$YXt5LdW+4_)-Ng9v2V`<T?n3pr>yR0(Lk%Y_%&41DH=zKd
z+7U!S6he&!6N@DlH=!_!6wE8SX1p1-;LV4uXg%6sXkRe2t%f$p`0|RD#~Yvd^gT5)
zp*Cjn%%~kj4Wk!v6N(KB<Pn<_%=W~4a8KqX)PXut7qjXvnArs3fN|ta^j%>FTIpk9
ztaQfo1d4t(@vDGD=y}Ut*iu@w^ui`rJ;=B+)#NALmT{t$ThToWj)}ThtU=Xum#wkO
zt%GTRYA%^(Az#q|P`yPT@)+5*&$9dpKXNU-XnV7*Y}XV_66xHirfPiO_R93-2iML$
zod3M+8p$J^O%SY%=5q=z3E~qNA&`;ELSMhuz=F!n?<(^r7Os7{F#Y|))D20&ijt-w
z`*;;^goHRW(ku2E4`-7A19?r^zD(O!HBc4dX#<*RsVc)-4mq%C97T0c9XRGwTU9x;
zG1I049qKOKr+X)?y8v3V6F{JXB1AFXt=g`G3HWawbugYyxA=kX)m^A_#<Cym2dYqv
z>H=r8$@owsTZU8+PCzqIos)3vE(FIM5FGU~R~PbjtCH@RfYacTAu$Bqw9XxLu9zGF
z@+R#T-R6GFvfRv+`wMIJa`;M3qJgYujcE=B_R8GX3s+_<mp|Sjkqs<Sx>w^hwH=j*
zRCQF@($O)NRbzQYi6(Q=p}}10=ulpZ4QA70S}v)?lKGJi`fKg=aEv^iAd#3$*_Fa-
zBAL(Sa8ga@bHqchds|>V{l)uR4RJCCS-pavefK5Alkag@HFa)fA$T-9HbU>!-Gv2u
zrlEf865q16jX~uOt$b8in*HHH@q>r+rz>BbShzg%$E_cwzI+Zpod2Y9`r^{<3ya^*
zE#53G-ub3-`UYKS2-TLW5LS{TJ<4la;y*0%4s{3CSwH3BB<&0wfL>Y%;Fa<H9q5Vt
zAMb(S!M&^cVrH_L@H)vk4(B<1$l<vb9mceV2GvA1pL)ayij{$I-0w0&GF1{ncj5Q}
zt~<y;UPIhG{_hu&EYBHR7~zq|!NNeckk5GhTm`3i?zu9YybO|7h7+TMDQsa=Ry>R*
z92XpZx>It&3v|CE%U&+^F(})P<jF85iu^Kp&A7AjQ|Vlaq&Vep>8d0{dcP?MJ@l`p
zcGy6};og|UnVvlZiS7NnckkH#_OAZEMBlbOJ4ld=>N&J<c!PtVPKHCnMl%I=FPm72
z<bD2Rio*q-vuTIZ$vnxGO+?GB>dEM?nKQ(#?9W2W;#c_(N69e|fe88A0sVpliu|zH
b0VNuWglyI@1mmKO?u)dFVyy^$g8A`36h_M9

diff --git a/AI/WxMini/alibabacloud-nls-python-sdk-dev/build/lib/nls/stream_input_tts.py b/AI/WxMini/alibabacloud-nls-python-sdk-dev/build/lib/nls/stream_input_tts.py
index bf63d48b..3ec09e49 100644
--- a/AI/WxMini/alibabacloud-nls-python-sdk-dev/build/lib/nls/stream_input_tts.py
+++ b/AI/WxMini/alibabacloud-nls-python-sdk-dev/build/lib/nls/stream_input_tts.py
@@ -32,10 +32,10 @@ __all__ = ["NlsStreamInputTtsSynthesizer"]
 
 
 class NlsStreamInputTtsRequest:
-    def __init__(self, task_id, session_id, appkey):
+    def __init__(self, task_id, person_id, appkey):
         self.task_id = task_id
         self.appkey = appkey
-        self.session_id = session_id
+        self.person_id = person_id
 
     def getStartCMD(self, voice, format, sample_rate, volumn, speech_rate, pitch_rate, ex):
         self.voice = voice
@@ -53,7 +53,7 @@ class NlsStreamInputTtsRequest:
                 "appkey": self.appkey,
             },
             "payload": {
-                "session_id": self.session_id,
+                "session_id": self.person_id,
                 "voice": self.voice,
                 "format": self.format,
                 "sample_rate": self.sample_rate,