From ca7a4c0c2a348b8f0140617f5bde6f64b9a5dcf7 Mon Sep 17 00:00:00 2001 From: minecraft1024a Date: Wed, 24 Sep 2025 20:57:12 +0800 Subject: [PATCH] =?UTF-8?q?feat(chat):=20=E5=9C=A8=E4=BA=B2=E5=92=8C?= =?UTF-8?q?=E6=B5=81=E5=AF=B9=E8=AF=9D=E4=B8=AD=E8=A7=A6=E5=8F=91=E8=A1=A8?= =?UTF-8?q?=E8=BE=BE=E5=AD=A6=E4=B9=A0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 每次亲和流对话器处理消息时，都会异步触发一次表达学习任务。这有助于模型根据最近的对话内容，持续优化其表达方式。 --- .../built_in/affinity_flow_chatter/affinity_chatter.py | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/plugins/built_in/affinity_flow_chatter/affinity_chatter.py b/src/plugins/built_in/affinity_flow_chatter/affinity_chatter.py index 07e14f8a9..08f5f7098 100644 --- a/src/plugins/built_in/affinity_flow_chatter/affinity_chatter.py +++ b/src/plugins/built_in/affinity_flow_chatter/affinity_chatter.py @@ -3,6 +3,7 @@ 基于现有的AffinityFlowChatter重构为插件化组件 """ +import asyncio import time import traceback 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.chat.planner_actions.action_manager import ChatterActionManager from src.common.logger import get_logger +from src.chat.express.expression_learner import expression_learner_manager logger = get_logger("affinity_chatter") @@ -62,6 +64,10 @@ class AffinityChatter(BaseChatter): 处理结果字典 """ 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() # 使用增强版规划器处理消息