Update planner.py

src/chat/focus_chat/planners/planner.py

@@ -24,36 +24,41 @@ install(extra_lines=3)
 def init_prompt():
     Prompt(
         """
-你的自我认知是：
+Your self-awareness is:
 {self_info_block}
 
 {extra_info_block}
 
-你需要基于以下信息决定如何参与对话
+
-这些信息可能会有冲突，请你整合这些信息，并选择一个最合适的action：
+You need to decide how to participate in the conversation based on the following information
+These information may conflict, please integrate these information, and choose the most suitable action:
+
 {chat_content_block}
 
 {mind_info_block}
 {cycle_info_block}
 
-请综合分析聊天内容和你看到的新消息，参考聊天规划，选择合适的action:
+IMPORTANT: The following tool call information has the highest priority and should be heavily weighted in your decision-making:
+{structured_info_block}
+
+Please analyze the conversation content and new messages you see, refer to the conversation plan, and choose the appropriate action:
 
 {action_options_text}
 
-你必须从上面列出的可用action中选择一个，并说明原因。
+You must choose one from the available actions above and explain why.
-你的决策必须以严格的 JSON 格式输出，且仅包含 JSON 内容，不要有任何其他文字或解释。
+Your decision must be output in strict JSON format, and only contain JSON content, no other text or explanation.
 
-请你以下面格式输出你选择的action：
+Please output your decision JSON in the following format:
 {{
     "action": "action_name",
-    "reasoning": "你的决策理由",
+    "reasoning": "Your decision reason",
-    "参数1": "参数1的值",
+    "parameter1": "parameter1 value",
-    "参数2": "参数2的值",
+    "parameter2": "parameter2 value",
-    "参数3": "参数3的值",
+    "parameter3": "parameter3 value",
     ...
 }}
 
-请输出你的决策 JSON：""",
+Please output your decision JSON: """,
         "planner_prompt",
     )
 
@@ -97,6 +102,7 @@ class ActionPlanner:
         try:
             # 获取观察信息
             extra_info: list[str] = []
+            _structured_info_list = []
 
             # 首先处理动作变更
             for info in all_plan_info:
@@ -136,6 +142,12 @@ class ActionPlanner:
                     self_info = info.get_processed_info()
                 elif isinstance(info, StructuredInfo):
                     _structured_info = info.get_data()
+                    # 收集工具调用的结构化信息
+                    if _structured_info and isinstance(_structured_info, dict):
+                        # StructuredInfo 的数据结构是 {tool_type: tool_content}
+                        for tool_type, tool_content in _structured_info.items():
+                            if tool_content:  # 确保内容不为空
+                                _structured_info_list.append(f"{tool_type}: {str(tool_content)}")
                 elif not isinstance(info, ActionInfo):  # 跳过已处理的ActionInfo
                     extra_info.append(info.get_processed_info())
 
@@ -154,13 +166,20 @@ class ActionPlanner:
                 }
 
             # --- 构建提示词 (调用修改后的 PromptBuilder 方法) ---
+            # 构建工具信息块
+            structured_info_block_str = "\n".join(_structured_info_list)
+            if structured_info_block_str:
+                structured_info_block_str = f"The following is basic information returned by tool calls. Please use this information as the basis for subsequent decision-making and actions:\n{structured_info_block_str}"
+            else:
+                structured_info_block_str = "No tool information available for reference."
+
             prompt = await self.build_planner_prompt(
                 self_info_block=self_info,
                 is_group_chat=is_group_chat,  # <-- Pass HFC state
                 chat_target_info=None,
                 observed_messages_str=observed_messages_str,  # <-- Pass local variable
                 current_mind=current_mind,  # <-- Pass argument
-                # structured_info=structured_info,  # <-- Pass SubMind info
+                structured_info_block=structured_info_block_str,
                 current_available_actions=current_available_actions,  # <-- Pass determined actions
                 cycle_info=cycle_info,  # <-- Pass cycle info
                 extra_info=extra_info,
@@ -249,6 +268,7 @@ class ActionPlanner:
         chat_target_info: Optional[dict],  # Now passed as argument
         observed_messages_str: str,
         current_mind: Optional[str],
+        structured_info_block: str,
         current_available_actions: Dict[str, ActionInfo],
         cycle_info: Optional[str],
         extra_info: list[str],
@@ -305,8 +325,11 @@ class ActionPlanner:
 
                 action_options_block += using_action_prompt
 
-            extra_info_block = "\n".join(extra_info)
+            extra_info_block = "\n".join(extra_info)  # 将局部变量名从 extra_info_block_str 改为 extra_info_block
-            extra_info_block = f"以下是一些额外的信息，现在请你阅读以下内容，进行决策\n{extra_info_block}\n以上是一些额外的信息，现在请你阅读以下内容，进行决策"
+            if extra_info_block: # 使用新的变量名进行检查
+                extra_info_block = f"The following is some additional information. Please read the following content to make a decision:\n{extra_info_block}\nEnd of additional information." # 使用新的变量名进行格式化
+            else:
+                extra_info_block = "No additional information available." # 使用新的变量名进行赋值
 
             planner_prompt_template = await global_prompt_manager.get_prompt_async("planner_prompt")
             prompt = planner_prompt_template.format(
@@ -316,9 +339,10 @@ class ActionPlanner:
                 chat_context_description=chat_context_description,
                 chat_content_block=chat_content_block,
                 mind_info_block=mind_info_block,
+                structured_info_block=structured_info_block,
                 cycle_info_block=cycle_info,
                 action_options_text=action_options_block,
-                extra_info_block=extra_info_block,
+                extra_info_block=extra_info_block,  # 确保这里传递的是修改后的变量名
             )
             return prompt