feat(chat): 在亲和流对话中触发表达学习

每次亲和流对话器处理消息时,都会异步触发一次表达学习任务。这有助于模型根据最近的对话内容,持续优化其表达方式。
This commit is contained in:
minecraft1024a
2025-09-24 20:57:12 +08:00
committed by Windpicker-owo
parent b91d1e6bf5
commit ca7a4c0c2a

View File

@@ -3,6 +3,7 @@
基于现有的AffinityFlowChatter重构为插件化组件 基于现有的AffinityFlowChatter重构为插件化组件
""" """
import asyncio
import time import time
import traceback import traceback
from datetime import datetime from datetime import datetime
@@ -14,6 +15,7 @@ from src.common.data_models.message_manager_data_model import StreamContext
from src.plugins.built_in.affinity_flow_chatter.planner import ChatterActionPlanner from src.plugins.built_in.affinity_flow_chatter.planner import ChatterActionPlanner
from src.chat.planner_actions.action_manager import ChatterActionManager from src.chat.planner_actions.action_manager import ChatterActionManager
from src.common.logger import get_logger from src.common.logger import get_logger
from src.chat.express.expression_learner import expression_learner_manager
logger = get_logger("affinity_chatter") logger = get_logger("affinity_chatter")
@@ -62,6 +64,10 @@ class AffinityChatter(BaseChatter):
处理结果字典 处理结果字典
""" """
try: try:
# 触发表达学习
learner = expression_learner_manager.get_expression_learner(self.stream_id)
asyncio.create_task(learner.trigger_learning_for_chat())
unread_messages = context.get_unread_messages() unread_messages = context.get_unread_messages()
# 使用增强版规划器处理消息 # 使用增强版规划器处理消息