gardel/Mofox-Core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(proactive_thinking): 优化主动思考功能，实现场景化响应

Browse Source 
本次更新针对主动思考（Proactive Thinking）功能进行了多项重要优化，旨在提升其智能化、灵活性和稳定性。

主要变更：

1.  **新增聊天场景区分**:
    *   在 `proactive_thinking_executor.py` 中增加了对群聊（group）和私聊（private）场景的判断逻辑。
    *   为两种场景分别创建了独立的、更具针对性的决策和回复提示词模板（`_group` 和 `_private` 后缀），使主动发言更贴合不同聊天氛围。

2.  **上下文长度配置化**:
    *   移除了原先在代码中硬编码的上下文长度（`limit=40`）。
    *   现在，功能会直接读取 `bot_config.toml` 中 `[chat]` 部分的 `max_context_size` 配置，实现了与全局配置的统一，增强了灵活性。

3.  **优化触发机制，减少跳过**:
    *   针对群聊等繁忙场景下，因 `chatter` 正在处理消息而导致主动思考被频繁跳过的问题，增加了一个短暂的等待和重试机制。
    *   现在，当检测到 `chatter` 忙碌时，会等待3秒后再次检查，提高了主动思考的成功触发率。

此次修改使得主动思考功能更加智能、可配置，并能更好地适应复杂的聊天环境。
```
This commit is contained in:
tt-P607
2025-11-23 10:53:06 +08:00
parent 19fefeb284
commit 9d1ebba373
1 changed files with 175 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

203
src/plugins/built_in/affinity_flow_chatter/proactive/proactive_thinking_executor.py
View File

@@ -25,18 +25,143 @@ logger = get_logger("proactive_thinking_executor")
# == Prompt Templates
# ==================================================================================================
# 决策 Prompt
decision_prompt_template = Prompt(
# --- 群聊场景 ---
decision_prompt_template_group = Prompt(
"""{time_block}
你的人设是：
{bot_personality}
你正在考虑是否要在与 "{stream_name}" 的对话中主动说些什么。
你正在考虑是否要在 **群聊 "{stream_name}"** 中主动说些什么。
【你当前的心情】
{current_mood}
【聊天环境信息】
【群聊环境信息】
- 整体印象: {stream_impression}
- 聊天风格: {chat_style}
- 常见话题: {topic_keywords}
- 你的兴趣程度: {interest_score:.2f}/1.0
{last_decision_text}
【最近的聊天记录】
{recent_chat_history}
请根据以上信息，决定你现在应该做什么：
**选项1：什么都不做 (do_nothing)**
- 适用场景：群里气氛不适合你说话、最近对话很活跃、没什么特别想说的、或者此时说话会显得突兀。
- 心情影响：如果心情不好（如生气、难过），可能更倾向于保持沉默。
**选项2：简单冒个泡 (simple_bubble)**
- 适用场景：群里有些冷清，你想缓和气氛或开启新的互动。
- 方式：说一句轻松随意的话，旨在建立或维持连接。
- 心情影响：心情会影响你冒泡的方式和内容。
**选项3：发起一次有目的的互动 (throw_topic)**
- 适用场景：你想延续对话、表达关心、或深入讨论某个具体话题。
- **【互动类型1：延续约定或提醒】(最高优先级)**：检查最近的聊天记录，是否存在可以延续的互动。例如，如果昨晚的最后一条消息是“晚安”，现在是早上，一个“早安”的回应是绝佳的选择。如果之前提到过某个约定（如“待会聊”），现在可以主动跟进。
- **【互动类型2：展现真诚的关心】(次高优先级)**：如果不存在可延续的约定，请仔细阅读聊天记录，寻找**群友**提及的个人状况（如天气、出行、身体、情绪、工作学习等），并主动表达关心。
- **【互动类型3：开启新话题】**：当以上两点都不适用时，可以考虑开启一个你感兴趣的新话题。
- 心情影响：心情会影响你想发起互动的方式和内容。
请以JSON格式回复你的决策：
{{
"action": "do_nothing" | "simple_bubble" | "throw_topic",
"reasoning": "你的决策理由（请结合你的心情、群聊环境和对话历史进行分析）",
"topic": "(仅当action=throw_topic时填写)你的互动意图（如：回应晚安并说早安、关心大家的考试情况、讨论新游戏）"
}}
注意：
1. 兴趣度较低(<0.4)时或者最近聊天很活跃（不到1小时），倾向于 `do_nothing` 或 `simple_bubble`。
2. 你的心情会影响你的行动倾向和表达方式。
3. 参考上次决策，避免重复，并可根据上次的互动效果调整策略。
4. 只有在真的有感而发时才选择 `throw_topic`。
5. 保持你的人设，确保行为一致性。
""",
name="proactive_thinking_decision_group",
)
simple_bubble_reply_prompt_template_group = Prompt(
"""{time_block}
你的人设是：
{bot_personality}
距离上次对话已经有一段时间了，你决定在群里主动说些什么，轻松地开启新的互动。
【你当前的心情】
{current_mood}
【群聊环境】
- 整体印象: {stream_impression}
- 聊天风格: {chat_style}
【最近的聊天记录】
{recent_chat_history}
{expression_habits}
请生成一条简短的消息，用于**在群聊中冒泡**。
【要求】
1. 风格简短随意（5-20字）
2. 不要提出明确的话题或问题，可以是问候、表达心情或一句随口的话。
3. 符合你的人设和当前聊天风格。
4. **你的心情应该影响消息的内容和语气**。
5. 如果有表达方式参考，在合适时自然使用。
6. 合理参考历史记录。
直接输出消息内容，不要解释：""",
name="proactive_thinking_simple_bubble_group",
)
throw_topic_reply_prompt_template_group = Prompt(
"""{time_block}
你的人设是：
{bot_personality}
你决定在 **群聊 "{stream_name}"** 中主动发起一次互动。
【你当前的心情】
{current_mood}
【群聊环境】
- 整体印象: {stream_impression}
- 聊天风格: {chat_style}
- 常见话题: {topic_keywords}
【最近的聊天记录】
{recent_chat_history}
【你的互动意图】
{topic}
{expression_habits}
【构思指南】
请根据你的互动意图，并参考最近的聊天记录，生成一条有温度的、**适合在群聊中说**的消息。
- 如果意图是**延续约定**（如回应“晚安”），请直接生成对应的问候。
- 如果意图是**表达关心**（如跟进群友提到的事），请生成自然、真诚的关心话语。
- 如果意图是**开启新话题**，请**确保新话题与最近的聊天内容有关联**，自然地引入话题，避免过于跳脱。
请根据这个意图，生成一条消息，要求：
1. 要与最近的聊天记录相关，自然地引入话题或表达关心。
2. 长度适中（20-40字）。
3. 结合最近的聊天记录确保对话连贯，不要显得突兀。
4. 符合你的人设和当前聊天风格。
5. **你的心情会影响你的表达方式**。
6. 如果有表达方式参考，在合适时自然使用。
直接输出消息内容，不要解释：""",
name="proactive_thinking_throw_topic_group",
)
# --- 私聊场景 ---
decision_prompt_template_private = Prompt(
"""{time_block}
你的人设是：
{bot_personality}
你正在考虑是否要主动与 **"{stream_name}"** 说些什么。
【你当前的心情】
{current_mood}
【与对方的聊天信息】
- 整体印象: {stream_impression}
- 聊天风格: {chat_style}
- 常见话题: {topic_keywords}
@@ -52,22 +177,22 @@ decision_prompt_template = Prompt(
- 适用场景：气氛不适合说话、最近对话很活跃、没什么特别想说的、或者此时说话会显得突兀。
- 心情影响：如果心情不好（如生气、难过），可能更倾向于保持沉默。
**选项2：简单冒个泡 (simple_bubble)**
- 适用场景：对话有些冷清，你想缓和气氛或开启新的互动。
**选项2：简单问候一下 (simple_bubble)**
- 适用场景：对话有些冷清，你想开启新的互动。
- 方式：说一句轻松随意的话，旨在建立或维持连接。
- 心情影响：心情会影响你冒泡的方式和内容。
- 心情影响：心情会影响你问候的方式和内容。
**选项3：发起一次有目的的互动 (throw_topic)**
- 适用场景：你想延续对话、表达关心、或深入讨论某个具体话题。
- **【互动类型1：延续约定或提醒】(最高优先级)**：检查最近的聊天记录，是否存在可以延续的互动。例如，如果昨晚的最后一条消息是“晚安”，现在是早上，一个“早安”的回应是绝佳的选择。如果之前提到过某个约定（如“待会聊”），现在可以主动跟进。
- **【互动类型2：展现真诚的关心】(次高优先级)**：如果不存在可延续的约定，请仔细阅读聊天记录，寻找对方提及的个人状况（如天气、出行、身体、情绪、工作学习等），并主动表达关心。
- **【互动类型2：展现真诚的关心】(次高优先级)**：如果不存在可延续的约定，请仔细阅读聊天记录，寻找**对方**提及的个人状况（如天气、出行、身体、情绪、工作学习等），并主动表达关心。
- **【互动类型3：开启新话题】**：当以上两点都不适用时，可以考虑开启一个你感兴趣的新话题。
- 心情影响：心情会影响你想发起互动的方式和内容。
请以JSON格式回复你的决策：
{{
"action": "do_nothing" | "simple_bubble" | "throw_topic",
"reasoning": "你的决策理由（请结合你的心情、聊天环境和对话历史进行分析）",
"reasoning": "你的决策理由（请结合你的心情、与对方的聊天情况和对话历史进行分析）",
"topic": "(仅当action=throw_topic时填写)你的互动意图（如：回应晚安并说早安、关心对方的考试情况、讨论新游戏）"
}}
@@ -78,28 +203,27 @@ decision_prompt_template = Prompt(
4. 只有在真的有感而发时才选择 `throw_topic`。
5. 保持你的人设，确保行为一致性。
""",
name="proactive_thinking_decision",
name="proactive_thinking_decision_private",
)
# 冒泡回复 Prompt
simple_bubble_reply_prompt_template = Prompt(
simple_bubble_reply_prompt_template_private = Prompt(
"""{time_block}
你的人设是：
{bot_personality}
距离上次对话已经有一段时间了，你决定主动说些什么，轻松地开启新的互动。
距离上次和 **"{stream_name}"** 对话已经有一段时间了，你决定主动说些什么，轻松地开启新的互动。
【你当前的心情】
{current_mood}
【聊天环境】
【与对方的聊天环境】
- 整体印象: {stream_impression}
- 聊天风格: {chat_style}
【最近的聊天记录】
{recent_chat_history}
{expression_habits}
请生成一条简短的消息，用于水群。
请生成一条简短的消息，用于**私聊中轻松地打个招呼**。
【要求】
1. 风格简短随意（5-20字）
2. 不要提出明确的话题或问题，可以是问候、表达心情或一句随口的话。
@@ -108,21 +232,20 @@ simple_bubble_reply_prompt_template = Prompt(
5. 如果有表达方式参考，在合适时自然使用。
6. 合理参考历史记录。
直接输出消息内容，不要解释：""",
name="proactive_thinking_simple_bubble",
name="proactive_thinking_simple_bubble_private",
)
# 抛出话题回复 Prompt
throw_topic_reply_prompt_template = Prompt(
throw_topic_reply_prompt_template_private = Prompt(
"""{time_block}
你的人设是：
{bot_personality}
你决定在与 "{stream_name}" 的对话中主动发起一次互动。
你决定在与 **"{stream_name}"** 的私聊中主动发起一次互动。
【你当前的心情】
{current_mood}
【聊天环境】
【与对方的聊天环境】
- 整体印象: {stream_impression}
- 聊天风格: {chat_style}
- 常见话题: {topic_keywords}
@@ -134,9 +257,9 @@ throw_topic_reply_prompt_template = Prompt(
{topic}
{expression_habits}
【构思指南】
请根据你的互动意图，并参考最近的聊天记录，生成一条有温度的消息。
请根据你的互动意图，并参考最近的聊天记录，生成一条有温度的、**适合在私聊中说**的消息。
- 如果意图是**延续约定**（如回应“晚安”），请直接生成对应的问候。
- 如果意图是**表达关心**（如跟进对方提到的事），请生成自然、真诚的关心话语。
- 如果意ت意图是**表达关心**（如跟进对方提到的事），请生成自然、真诚的关心话语。
- 如果意图是**开启新话题**，请**确保新话题与最近的聊天内容有关联**，自然地引入话题，避免过于跳脱。
请根据这个意图，生成一条消息，要求：
@@ -148,7 +271,7 @@ throw_topic_reply_prompt_template = Prompt(
6. 如果有表达方式参考，在合适时自然使用。
直接输出消息内容，不要解释：""",
name="proactive_thinking_throw_topic",
name="proactive_thinking_throw_topic_private",
)
@@ -194,7 +317,7 @@ class ProactiveThinkingPlanner:
# 2. 获取最近的聊天记录
recent_messages = await message_api.get_recent_messages(
chat_id=stream_id,
limit=40,
limit=global_config.chat.max_context_size,
limit_mode="latest",
hours=24
)
@@ -237,9 +360,13 @@ class ProactiveThinkingPlanner:
logger.warning(f"获取上次决策失败: {e}")
# 6. 构建上下文
# 7. 判断聊天类型
chat_type = "group" if "group" in stream_id else "private"
context = {
"stream_id": stream_id,
"stream_name": stream_data.get("stream_name", "未知"),
"chat_type": chat_type,
"stream_impression": stream_data.get("stream_impression_text", "暂无印象"),
"chat_style": stream_data.get("stream_chat_style", "未知"),
"topic_keywords": stream_data.get("stream_topic_keywords", ""),
@@ -318,6 +445,13 @@ class ProactiveThinkingPlanner:
if last_topic:
last_decision_text += f"\n- 话题: {last_topic}"
# 根据聊天类型选择不同的决策Prompt
chat_type = context.get("chat_type", "group")
if chat_type == "private":
decision_prompt_template = decision_prompt_template_private
else:
decision_prompt_template = decision_prompt_template_group
decision_prompt = decision_prompt_template.format(
time_block=context["time_block"],
bot_personality=context["bot_personality"],
@@ -378,10 +512,20 @@ class ProactiveThinkingPlanner:
stream_id=context.get("stream_id", ""), chat_history=context.get("recent_chat_history", "")
)
# 根据聊天类型选择不同的回复Prompt
chat_type = context.get("chat_type", "group")
if chat_type == "private":
simple_template = simple_bubble_reply_prompt_template_private
throw_template = throw_topic_reply_prompt_template_private
else:
simple_template = simple_bubble_reply_prompt_template_group
throw_template = throw_topic_reply_prompt_template_group
if action == "simple_bubble":
reply_prompt = simple_bubble_reply_prompt_template.format(
reply_prompt = simple_template.format(
time_block=context["time_block"],
bot_personality=context["bot_personality"],
stream_name=context["stream_name"],
current_mood=context.get("current_mood", "感觉很平静"),
stream_impression=context["stream_impression"],
chat_style=context["chat_style"],
@@ -389,7 +533,7 @@ class ProactiveThinkingPlanner:
expression_habits=expression_habits,
)
else: # throw_topic
reply_prompt = throw_topic_reply_prompt_template.format(
reply_prompt = throw_template.format(
time_block=context["time_block"],
bot_personality=context["bot_personality"],
stream_name=context["stream_name"],
@@ -565,8 +709,11 @@ async def execute_proactive_thinking(stream_id: str):
chat_stream = await chat_manager.get_stream(stream_id)
if chat_stream and chat_stream.context_manager.context.is_chatter_processing:
logger.warning(f"⚠️ 主动思考跳过：聊天流 {stream_id} 的 chatter 正在处理消息")
return
logger.warning(f"⚠️ 主动思考等待：聊天流 {stream_id} 的 chatter 正在处理消息，等待3秒后重试...")
await asyncio.sleep(3)
if chat_stream.context_manager.context.is_chatter_processing:
logger.warning(f"⚠️ 主动思考跳过：聊天流 {stream_id} 的 chatter 仍在处理消息")
return
except Exception as e:
logger.warning(f"检查 chatter 处理状态时出错: {e}，继续执行")