Fix fusion summary LLM trace payloads

Refs #973

Author: JAVA-LW

api/apps/api-server/src/routes/applications/application_runtime/runtime_debug_artifacts/visible_internal_llm_route_traces.rs

@@ -397,7 +397,7 @@ fn branch_trace_from_event(
         status: status.to_string(),
         route_model,
         provider_route,
-        input_payload: value_field(event_object, &["input_payload"]),
+        input_payload: branch_input_payload(event_object),
         output_payload,
         output,
         output_summary,
@@ -412,6 +412,66 @@ fn branch_trace_from_event(
     Some(branch_trace)
 }
 
+fn branch_input_payload(event_object: &Map<String, Value>) -> Option<Value> {
+    value_field(event_object, &["input_payload"])
+        .or_else(|| historical_llm_input_payload_from_debug_context(event_object))
+}
+
+fn historical_llm_input_payload_from_debug_context(
+    event_object: &Map<String, Value>,
+) -> Option<Value> {
+    if string_field(event_object, &["node_type"]).as_deref() != Some("llm") {
+        return None;
+    }
+
+    let llm_context = event_object
+        .get("debug_payload")?
+        .get("llm_context")?
+        .as_object()?;
+    let mut prompt_messages = Vec::new();
+
+    prompt_messages.extend(
+        llm_context
+            .get("provider_messages")?
+            .as_array()?
+            .iter()
+            .filter_map(|message| {
+                message
+                    .as_object()
+                    .map(|object| Value::Object(object.clone()))
+            }),
+    );
+
+    if let Some(effective_system) = llm_context
+        .get("effective_system")
+        .and_then(Value::as_str)
+        .map(str::trim)
+        .filter(|value| !value.is_empty())
+        .filter(|_| {
+            !prompt_messages
+                .iter()
+                .filter_map(Value::as_object)
+                .any(|message| string_field(message, &["role"]).as_deref() == Some("system"))
+        })
+    {
+        prompt_messages.insert(
+            0,
+            json!({
+                "role": "system",
+                "content": effective_system,
+            }),
+        );
+    }
+
+    if prompt_messages.is_empty() {
+        return None;
+    }
+
+    Some(json!({
+        "prompt_messages": prompt_messages,
+    }))
+}
+
 fn apply_branch_node_run_payload(
     branch_trace: &mut VisibleInternalLlmToolBranchTraceFacts,
     node_run: &VisibleInternalLlmToolBranchNodeRunPayload,
@@ -1347,4 +1407,87 @@ mod tests {
             json!("artifact-panel-b")
         );
     }
+
+    #[test]
+    fn fusion_trace_projects_historical_summary_llm_detail_from_debug_context() {
+        let debug_payload = json!({
+            "visible_internal_llm_tool_events": [
+                {
+                    "event_type": "visible_internal_llm_tool_started",
+                    "main_node_id": "node-main-llm",
+                    "target_node_id": "node-panel-a",
+                    "tool_name": "fusion_review",
+                    "tool_call_id": "call_fusion",
+                    "tool_mode": "fusion",
+                    "execution_mode": "bounded_parallel_panel"
+                },
+                {
+                    "event_type": "visible_internal_llm_tool_completed",
+                    "main_node_id": "node-main-llm",
+                    "target_node_id": "node-panel-a",
+                    "tool_name": "fusion_review",
+                    "tool_call_id": "call_fusion",
+                    "tool_mode": "fusion",
+                    "execution_mode": "bounded_parallel_panel",
+                    "node_id": "node-judge",
+                    "node_alias": "LLM5",
+                    "node_type": "llm",
+                    "provider_route": {
+                        "model": "gpt-5.4-mini",
+                        "provider_code": "fixture_provider"
+                    },
+                    "metrics_payload": {
+                        "usage": {
+                            "input_tokens": 5513,
+                            "output_tokens": 2455,
+                            "total_tokens": 7968
+                        }
+                    },
+                    "debug_payload": {
+                        "llm_context": {
+                            "effective_system": "You are the fusion judge.",
+                            "provider_messages": [
+                                {
+                                    "role": "user",
+                                    "content": "Merge panel answers."
+                                }
+                            ]
+                        },
+                        "assistant_message": {
+                            "role": "assistant",
+                            "content": "judge merged answer"
+                        }
+                    },
+                    "content": "judge merged answer"
+                }
+            ]
+        });
+
+        let traces = collect_visible_internal_llm_tool_route_traces(&debug_payload);
+
+        assert_eq!(traces.len(), 1);
+        let detail = traces[0].detail_payload();
+        let branch_trace = &detail["branch_traces"][0];
+        assert_eq!(branch_trace["node_alias"], json!("LLM5"));
+        assert_eq!(
+            branch_trace["input_payload"]["prompt_messages"][0]["role"],
+            json!("system")
+        );
+        assert_eq!(
+            branch_trace["input_payload"]["prompt_messages"][0]["content"],
+            json!("You are the fusion judge.")
+        );
+        assert_eq!(
+            branch_trace["input_payload"]["prompt_messages"][1]["content"],
+            json!("Merge panel answers.")
+        );
+        assert_eq!(
+            branch_trace["output_payload"]["text"],
+            json!("judge merged answer")
+        );
+        assert_eq!(
+            branch_trace["metrics_payload"]["usage"]["total_tokens"],
+            json!(7968)
+        );
+    }
 }

api/crates/orchestration-runtime/src/_tests/execution_engine_tests/human_and_tool_resume/visible_internal_llm_tools.rs

@@ -524,6 +524,26 @@ async fn fusion_visible_internal_llm_tool_executes_panel_llms_in_bounded_paralle
             "panel LLM event should preserve node-run-like output payload"
         );
     }
+    let judge_event = route_events
+        .iter()
+        .find(|event| {
+            event["event_type"] == json!("visible_internal_llm_tool_completed")
+                && event["node_id"] == json!("node-judge")
+        })
+        .expect("fusion summary LLM completed event should exist");
+    assert_eq!(judge_event["node_type"], json!("llm"));
+    assert!(
+        judge_event["input_payload"]["prompt_messages"].is_array(),
+        "fusion summary LLM event should preserve node-run-like input payload"
+    );
+    assert_eq!(
+        judge_event["output_payload"]["text"],
+        json!("judge-result ")
+    );
+    assert_eq!(
+        judge_event["metrics_payload"]["usage"]["total_tokens"],
+        json!(24)
+    );
 
     let captured = invoker
         .captured_inputs

api/crates/orchestration-runtime/src/execution_engine/visible_internal_llm_tools.rs

@@ -740,6 +740,8 @@ where
                     "node_id": node.node_id,
                     "node_alias": node.alias,
                     "node_type": node.node_type,
+                    "input_payload": node_output.input_payload.clone(),
+                    "output_payload": node_output.output_payload.clone(),
                     "provider_route": node_output.output_payload
                         .get("provider_route")
                         .cloned()

web/app/src/features/agent-flow/_tests/debug-console/debug-conversation-log-panel.test.tsx

@@ -434,6 +434,88 @@ const fusionSummaryOnlyAssistantMessage: AgentFlowDebugMessage = {
   ]
 };
 
+const fusionHistoricalBranchDetailAssistantMessage: AgentFlowDebugMessage = {
+  ...assistantMessage,
+  traceSummary: [
+    {
+      ...assistantMessage.traceSummary[1],
+      nodeId: 'node-main-llm',
+      nodeRunId: 'node-run-main-llm',
+      nodeAlias: 'LLM',
+      debugPayload: {
+        llm_rounds: [
+          {
+            round_index: 0,
+            assistant: {
+              role: 'assistant',
+              tool_calls: [
+                {
+                  id: 'call_fusion',
+                  name: 'fusion_review'
+                }
+              ]
+            }
+          }
+        ],
+        visible_internal_llm_tool_trace: [
+          {
+            kind: 'visible_internal_llm_tool_trace',
+            preview_kind: 'visible_internal_llm_tool_trace',
+            route_kind: 'fusion',
+            tool_call_id: 'call_fusion',
+            tool_name: 'fusion_review',
+            status: 'succeeded',
+            branch_count: 1,
+            branch_traces: [
+              {
+                node_id: 'node-judge',
+                node_alias: 'LLM5',
+                node_type: 'llm',
+                status: 'succeeded',
+                route_model: 'gpt-5.4-mini',
+                input_payload: {
+                  prompt_messages: [
+                    {
+                      role: 'system',
+                      content: 'You are the fusion judge.'
+                    },
+                    {
+                      role: 'user',
+                      content: 'Merge panel answers.'
+                    }
+                  ]
+                },
+                output_payload: {
+                  text: 'judge merged answer'
+                },
+                metrics_payload: {
+                  usage: {
+                    input_tokens: 5513,
+                    output_tokens: 2455,
+                    total_tokens: 7968
+                  }
+                },
+                debug_payload: {
+                  assistant_message: {
+                    role: 'assistant',
+                    content: 'judge merged answer'
+                  }
+                },
+                output_summary: {
+                  kind: 'text',
+                  preview: 'judge merged answer',
+                  char_count: 19,
+                  truncated: false
+                }
+              }
+            ]
+          }
+        ]
+      }
+    }
+  ]
+};
+
 const answerSnapshotAssistantMessage: AgentFlowDebugMessage = {
   ...assistantMessage,
   status: 'waiting_callback',
@@ -716,6 +798,53 @@ describe('debug conversation log panel', () => {
     ).not.toBeInTheDocument();
   }, 10_000);
 
+  test('shows fusion branch LLM tokens from metrics payload and reuses node detail sections', () => {
+    renderConsole({
+      messages: [
+        {
+          id: 'user-1',
+          role: 'user',
+          status: 'completed',
+          runId: 'run-1',
+          content: '做 fusion 评审',
+          rawOutput: null,
+          traceSummary: []
+        },
+        fusionHistoricalBranchDetailAssistantMessage
+      ]
+    });
+
+    fireEvent.click(screen.getByRole('button', { name: '查看对话日志' }));
+    const panel = screen.getByRole('complementary', { name: '对话日志' });
+    fireEvent.click(within(panel).getByRole('tab', { name: '追踪' }));
+    fireEvent.click(within(panel).getByRole('button', { name: /LLM/ }));
+    fireEvent.click(
+      within(panel).getByRole('button', { name: /工具.*1 次工具回调/ })
+    );
+    fireEvent.click(
+      within(panel).getByRole('button', { name: /fusion_review/ })
+    );
+
+    const branchNode = within(panel).getByTestId('debug-llm-route-branch-node');
+    const branchButton = within(branchNode).getByRole('button', {
+      name: /LLM5/
+    });
+    expect(branchButton).toHaveTextContent('7.96 K tokens');
+    expect(branchButton).not.toHaveTextContent('执行成功');
+
+    fireEvent.click(branchButton);
+
+    expect(within(branchNode).getByLabelText('输入 JSON')).toHaveTextContent(
+      'Merge panel answers.'
+    );
+    expect(
+      within(branchNode).getByLabelText('数据处理 JSON')
+    ).toHaveTextContent('assistant_message');
+    expect(within(branchNode).getByLabelText('输出 JSON')).toHaveTextContent(
+      'judge merged answer'
+    );
+  }, 10_000);
+
   test('collapses repeated LLM node runs into one trace row', () => {
     renderConsole({
       messages: [

web/app/src/features/agent-flow/components/debug-console/conversation/DebugWorkflowNodeRow.tsx

@@ -30,27 +30,37 @@ function statusTone(status: string) {
   }
 }
 
-function readOutputTotalTokens(outputPayload: unknown) {
-  if (
-    !outputPayload ||
-    typeof outputPayload !== 'object' ||
-    Array.isArray(outputPayload)
-  ) {
+function readRecord(value: unknown): Record<string, unknown> | null {
+  if (!value || typeof value !== 'object' || Array.isArray(value)) {
     return null;
   }
 
-  const usage = (outputPayload as Record<string, unknown>).usage;
+  return value as Record<string, unknown>;
+}
+
+function readTotalTokens(payload: unknown) {
+  const record = readRecord(payload);
+  if (!record) {
+    return null;
+  }
+
+  const directTotalTokens = record.total_tokens;
+  if (typeof directTotalTokens === 'number') {
+    return directTotalTokens;
+  }
 
-  if (!usage || typeof usage !== 'object' || Array.isArray(usage)) {
+  const usage = readRecord(record.usage);
+  if (!usage) {
     return null;
   }
 
-  const totalTokens = (usage as Record<string, unknown>).total_tokens;
+  const totalTokens = usage.total_tokens;
   return typeof totalTokens === 'number' ? totalTokens : null;
 }
 
 function metricText(item: AgentFlowTraceItem) {
-  const tokens = readOutputTotalTokens(item.outputPayload);
+  const tokens =
+    readTotalTokens(item.metricsPayload) ?? readTotalTokens(item.outputPayload);
   const durationMs = item.durationMs;
   const toolCount =
     item.nodeType === 'llm'