diff --git a/client/src/i18n/locales/en-US.ts b/client/src/i18n/locales/en-US.ts
index 58765e8..7489d0b 100644
--- a/client/src/i18n/locales/en-US.ts
+++ b/client/src/i18n/locales/en-US.ts
@@ -415,6 +415,13 @@ export default {
     backendStatus: 'Backend status',
     backendMessage: 'Backend message',
     waitingSuperAgent: 'Parsing the email and waiting for SuperAgent',
+    systemStages: 'System stages',
+    superAgentTrace: 'SuperAgent Trace',
+    traceToolName: 'Tool',
+    traceInputSummary: 'Input summary',
+    traceOutputSummary: 'Output summary',
+    traceStatus: 'Status',
+    traceTime: 'Time',
     sourceTrace: 'SourceMessage trace',
     sourceMessageId: 'SourceMessage ID',
     sourceProvider: 'Source provider',
diff --git a/client/src/i18n/locales/th-TH.ts b/client/src/i18n/locales/th-TH.ts
index 88f429b..b2c895c 100644
--- a/client/src/i18n/locales/th-TH.ts
+++ b/client/src/i18n/locales/th-TH.ts
@@ -415,6 +415,13 @@ export default {
     backendStatus: 'สถานะจากระบบหลังบ้าน',
     backendMessage: 'ข้อความจากระบบหลังบ้าน',
     waitingSuperAgent: 'กำลังแยกอีเมลและรอ SuperAgent ตอบกลับ',
+    systemStages: 'ขั้นตอนของระบบ',
+    superAgentTrace: 'SuperAgent Trace',
+    traceToolName: 'เครื่องมือ',
+    traceInputSummary: 'สรุป input',
+    traceOutputSummary: 'สรุป output',
+    traceStatus: 'สถานะ',
+    traceTime: 'เวลา',
     sourceTrace: 'การติดตาม SourceMessage',
     sourceMessageId: 'SourceMessage ID',
     sourceProvider: 'Source provider',
diff --git a/client/src/i18n/locales/zh-CN.ts b/client/src/i18n/locales/zh-CN.ts
index 79cc5f7..fb57cc0 100644
--- a/client/src/i18n/locales/zh-CN.ts
+++ b/client/src/i18n/locales/zh-CN.ts
@@ -415,6 +415,13 @@ export default {
     backendStatus: '后端状态',
     backendMessage: '后端消息',
     waitingSuperAgent: '正在解析邮件并等待 SuperAgent 返回',
+    systemStages: '本系统处理阶段',
+    superAgentTrace: 'SuperAgent Trace',
+    traceToolName: '工具',
+    traceInputSummary: '入参摘要',
+    traceOutputSummary: '出参摘要',
+    traceStatus: '状态',
+    traceTime: '时间',
     sourceTrace: 'SourceMessage 追溯',
     sourceMessageId: 'SourceMessage ID',
     sourceProvider: '来源 Provider',
diff --git a/client/src/services/debugEmlService.ts b/client/src/services/debugEmlService.ts
index 11a216e..befbc2f 100644
--- a/client/src/services/debugEmlService.ts
+++ b/client/src/services/debugEmlService.ts
@@ -1,7 +1,10 @@
 import type {
   DebugEmlErrorCode,
   DebugEmlErrorResponse,
+  DebugEmlStageEvent,
+  DebugEmlStreamHandlers,
   DebugEmlSuperAgentRunResult,
+  DebugEmlSuperAgentTraceEvent,
   DebugEmlUploadInput,
 } from '@/types/debugEml'
 import { getStoredAccessToken } from '@/services/authSession'
@@ -9,6 +12,11 @@ import { isAuthSessionInvalidPayload, notifyUnauthorized } from '@/services/http
 
 const apiBaseUrl = import.meta.env.VITE_API_BASE_URL ?? ''
 const debugEmlEndpoint = '/api/system/debug/eml-superagent-runs'
+const debugEmlStreamEndpoint = `${debugEmlEndpoint}/stream`
+const jsonSecretPattern =
+  /("(?:api[_-]?key|token|secret|password|cookie|authorization)"\s*:\s*")[^"]*(")/gi
+const headerSecretPattern = /((?:authorization|cookie)\s*:\s*)[^\s,;]+/gi
+const textSecretPattern = /((?:api[_-]?key|token|secret|password)\s*[=:]\s*)[^\s,;}]+/gi
 
 export class DebugEmlUploadError extends Error {
   readonly status: number
@@ -61,9 +69,91 @@ export async function uploadDebugEmlSuperAgentRun(
   return normalizeDebugEmlResult(payload)
 }
 
-function buildUploadHeaders(debugUploadKey: string): Record<string, string> {
+export async function uploadDebugEmlSuperAgentRunStream(
+  input: DebugEmlUploadInput,
+  handlers: DebugEmlStreamHandlers = {},
+): Promise<DebugEmlSuperAgentRunResult> {
+  const response = await fetch(`${apiBaseUrl}${debugEmlStreamEndpoint}`, {
+    method: 'POST',
+    headers: buildUploadHeaders(input.debugUploadKey, 'text/event-stream'),
+    body: buildUploadForm(input),
+  })
+
+  if (!response.ok) {
+    const payload = await readResponsePayload(response)
+    if (isAuthSessionInvalidPayload(payload)) {
+      notifyUnauthorized()
+    }
+    const errorPayload = isDebugEmlErrorResponse(payload) ? payload : {}
+    throw new DebugEmlUploadError(
+      errorPayload.message || `Request failed with status ${response.status}`,
+      response.status,
+      errorPayload.error_code || 'DEBUG_EML_RUN_FAILED',
+      payload,
+    )
+  }
+
+  if (!response.body) {
+    throw new DebugEmlUploadError('Debug EML SSE 响应为空。', response.status, 'DEBUG_EML_RUN_FAILED', null)
+  }
+
+  let finalResult: DebugEmlSuperAgentRunResult | null = null
+  let streamError: DebugEmlUploadError | null = null
+  await readSseStream(response.body, (event) => {
+    const payload = parseSsePayload(event.data)
+    if (event.event === 'debug_stage') {
+      handlers.onStage?.(normalizeStageEvent(payload))
+      return
+    }
+    if (event.event === 'superagent_trace') {
+      handlers.onTrace?.(normalizeTraceEvent(payload))
+      return
+    }
+    if (event.event === 'superagent_result') {
+      finalResult = normalizeDebugEmlResult(payload)
+      handlers.onResult?.(finalResult)
+      return
+    }
+    if (event.event === 'debug_error') {
+      const errorPayload = isDebugEmlErrorResponse(payload) ? payload : {}
+      streamError = new DebugEmlUploadError(
+        errorPayload.message || 'Debug EML 调试失败。',
+        response.status,
+        errorPayload.error_code || 'DEBUG_EML_RUN_FAILED',
+        payload,
+      )
+    }
+  })
+
+  if (streamError) {
+    throw streamError
+  }
+  if (!finalResult) {
+    throw new DebugEmlUploadError('Debug EML SSE 未收到最终结果。', response.status, 'DEBUG_EML_RUN_FAILED', null)
+  }
+  return finalResult
+}
+
+function buildUploadForm(input: DebugEmlUploadInput): FormData {
+  const form = new FormData()
+  form.append('file', input.file)
+  const hotelId = input.hotelId?.trim()
+  if (hotelId) {
+    form.append('hotel_id', hotelId)
+  }
+  const runLabel = input.runLabel?.trim()
+  if (runLabel) {
+    form.append('run_label', runLabel)
+  }
+  return form
+}
+
+function buildUploadHeaders(
+  debugUploadKey: string,
+  accept: 'application/json' | 'text/event-stream' = 'application/json',
+): Record<string, string> {
   const headers: Record<string, string> = {
-    Accept: 'application/json',
+    Accept: accept,
     'X-TH-Hotel-Debug-Upload-Key': debugUploadKey.trim(),
   }
   const token = getStoredAccessToken()
@@ -104,11 +194,109 @@ function normalizeDebugEmlResult(payload: unknown): DebugEmlSuperAgentRunResult
     superagent_run_id: nullableStringValue(result.superagent_run_id),
     superagent_raw_answer: nullableStringValue(result.superagent_raw_answer),
     superagent_parsed_json: result.superagent_parsed_json ?? null,
+    superagent_trace_events: Array.isArray(result.superagent_trace_events)
+      ? result.superagent_trace_events.map(normalizeTraceEvent)
+      : [],
     warnings: Array.isArray(result.warnings) ? result.warnings.filter(isString) : [],
     status: nullableStringValue(result.status),
   }
 }
 
+async function readSseStream(
+  body: ReadableStream<Uint8Array>,
+  onEvent: (event: { event: string; data: string }) => void,
+): Promise<void> {
+  const reader = body.getReader()
+  const decoder = new TextDecoder()
+  let buffer = ''
+  while (true) {
+    const { value, done } = await reader.read()
+    if (done) {
+      break
+    }
+    buffer += decoder.decode(value, { stream: true })
+    buffer = consumeSseBuffer(buffer, onEvent)
+  }
+  buffer += decoder.decode()
+  consumeSseBuffer(`${buffer}\n\n`, onEvent)
+}
+
+function consumeSseBuffer(
+  buffer: string,
+  onEvent: (event: { event: string; data: string }) => void,
+): string {
+  let remaining = buffer
+  while (true) {
+    const separatorIndex = remaining.search(/\r?\n\r?\n/)
+    if (separatorIndex < 0) {
+      return remaining
+    }
+    const block = remaining.slice(0, separatorIndex)
+    remaining = remaining.slice(separatorIndex + (remaining[separatorIndex] === '\r' ? 4 : 2))
+    const event = parseSseBlock(block)
+    if (event) {
+      onEvent(event)
+    }
+  }
+}
+
+function parseSseBlock(block: string): { event: string; data: string } | null {
+  let event = 'message'
+  const dataLines: string[] = []
+  for (const line of block.split(/\r?\n/)) {
+    if (line.startsWith('event:')) {
+      event = line.slice('event:'.length).trim()
+      continue
+    }
+    if (line.startsWith('data:')) {
+      dataLines.push(line.slice('data:'.length).trim())
+    }
+  }
+  if (!dataLines.length && event !== 'done') {
+    return null
+  }
+  return {
+    event,
+    data: dataLines.join('\n'),
+  }
+}
+
+function parseSsePayload(data: string): unknown {
+  if (!data.trim()) {
+    return {}
+  }
+  try {
+    return JSON.parse(data)
+  } catch {
+    return data
+  }
+}
+
+function normalizeStageEvent(value: unknown): DebugEmlStageEvent {
+  const stage = isRecord(value) ? value : {}
+  return {
+    debug_run_id: nullableStringValue(stage.debug_run_id),
+    status: nullableStringValue(stage.status),
+    safe_summary: nullableStringValue(stage.safe_summary),
+  }
+}
+
+function normalizeTraceEvent(value: unknown): DebugEmlSuperAgentTraceEvent {
+  const trace = isRecord(value) ? value : {}
+  return {
+    event: nullableMaskedStringValue(trace.event),
+    run_id: nullableMaskedStringValue(trace.run_id),
+    message_id: nullableMaskedStringValue(trace.message_id),
+    tool_call_id: nullableMaskedStringValue(trace.tool_call_id),
+    tool_name: nullableMaskedStringValue(trace.tool_name),
+    text: nullableMaskedStringValue(trace.text),
+    input_summary: nullableMaskedStringValue(trace.input_summary),
+    output_summary: nullableMaskedStringValue(trace.output_summary),
+    status: nullableMaskedStringValue(trace.status),
+    ts: nullableMaskedStringValue(trace.ts),
+  }
+}
+
 function normalizeUploadedMedia(value: unknown): DebugEmlSuperAgentRunResult['uploaded_media'][number] {
   const media = isRecord(value) ? value : {}
   return {
@@ -141,3 +329,13 @@ function nullableStringValue(value: unknown): string | null {
 function stringValue(value: unknown): string {
   return typeof value === 'string' ? value : ''
 }
+
+function nullableMaskedStringValue(value: unknown): string | null {
+  if (typeof value !== 'string') {
+    return null
+  }
+  return value
+    .replace(jsonSecretPattern, '$1***$2')
+    .replace(headerSecretPattern, '$1***')
+    .replace(textSecretPattern, '$1***')
+}
diff --git a/client/src/tests/debugEmlService.spec.ts b/client/src/tests/debugEmlService.spec.ts
index cad0f78..bfb79e8 100644
--- a/client/src/tests/debugEmlService.spec.ts
+++ b/client/src/tests/debugEmlService.spec.ts
@@ -1,6 +1,10 @@
 import { beforeEach, describe, expect, it, vi } from 'vitest'
 
-import { DebugEmlUploadError, uploadDebugEmlSuperAgentRun } from '@/services/debugEmlService'
+import {
+  DebugEmlUploadError,
+  uploadDebugEmlSuperAgentRun,
+  uploadDebugEmlSuperAgentRunStream,
+} from '@/services/debugEmlService'
 import { setUnauthorizedHandler } from '@/services/httpClient'
 
 const jsonHeaders = {
@@ -19,6 +23,24 @@ function mockJsonResponse(payload: unknown, status = 201): Response {
   } as Response
 }
 
+function mockSseResponse(chunks: string[], status = 200): Response {
+  const encoder = new TextEncoder()
+  const stream = new ReadableStream<Uint8Array>({
+    start(controller) {
+      for (const chunk of chunks) {
+        controller.enqueue(encoder.encode(chunk))
+      }
+      controller.close()
+    },
+  })
+  return new Response(stream, {
+    status,
+    headers: {
+      'Content-Type': 'text/event-stream',
+    },
+  })
+}
+
 describe('debugEmlService', () => {
   beforeEach(() => {
     vi.restoreAllMocks()
@@ -155,4 +177,100 @@ describe('debugEmlService', () => {
 
     expect(unauthorizedHandler).toHaveBeenCalledOnce()
   })
+
+  it('streams debug stages, public SuperAgent trace, and final result from backend SSE', async () => {
+    const fetchMock = vi.spyOn(globalThis, 'fetch').mockResolvedValue(
+      mockSseResponse([
+        'event: debug_stage\n',
+        'data: {"debug_run_id":"90003","status":"PARSING_EML","safe_summary":"阶段：解析 EML 邮件。"}\n\n',
+        'event: superagent_trace\n',
+        'data: {"event":"reasoning.summary","run_id":"run-stream-1","text":"正在分析 Debug 邮件。","ts":"2026-07-11T10:00:01Z"}\n\n',
+        'event: superagent_trace\n',
+        'data: {"event":"tool.call.started","run_id":"run-stream-1","tool_name":"th_hotel_query_case_context","input_summary":"{\\"group_code\\":\\"G001\\"}"}\n\n',
+        'event: superagent_result\n',
+        'data: {"debug_run_id":"90003","source_message_id":"30003","uploaded_media":[],"superagent_session_id":"session-stream-1","superagent_run_id":"run-stream-1","superagent_raw_answer":"{\\"route_code\\":\\"S10\\"}","superagent_parsed_json":{"route_code":"S10"},"superagent_trace_events":[{"event":"reasoning.summary","text":"正在分析 Debug 邮件。"}],"warnings":[],"status":"SUPERAGENT_SUCCEEDED"}\n\n',
+        'event: done\n',
+        'data: {"status":"done"}\n\n',
+      ]),
+    )
+    const stages: unknown[] = []
+    const traces: unknown[] = []
+    const file = new File(['From: guest@example.test'], 'booking.eml', { type: 'message/rfc822' })
+
+    const result = await uploadDebugEmlSuperAgentRunStream(
+      {
+        hotelId: 'HOTEL-TEST',
+        debugUploadKey: 'manual-debug-key',
+        runLabel: 'stream-smoke',
+        file,
+      },
+      {
+        onStage: (stage) => stages.push(stage),
+        onTrace: (trace) => traces.push(trace),
+      },
+    )
+
+    expect(fetchMock).toHaveBeenCalledTimes(1)
+    const [url, init] = fetchMock.mock.calls[0]!
+    expect(url).toBe('/api/system/debug/eml-superagent-runs/stream')
+    expect(init).toMatchObject({
+      method: 'POST',
+      headers: {
+        Accept: 'text/event-stream',
+        'X-TH-Hotel-Debug-Upload-Key': 'manual-debug-key',
+      },
+    })
+    expect(stages).toMatchObject([
+      {
+        debug_run_id: '90003',
+        status: 'PARSING_EML',
+        safe_summary: '阶段：解析 EML 邮件。',
+      },
+    ])
+    expect(traces).toMatchObject([
+      {
+        event: 'reasoning.summary',
+        run_id: 'run-stream-1',
+        text: '正在分析 Debug 邮件。',
+      },
+      {
+        event: 'tool.call.started',
+        tool_name: 'th_hotel_query_case_context',
+        input_summary: '{"group_code":"G001"}',
+      },
+    ])
+    expect(result.superagent_run_id).toBe('run-stream-1')
+    expect(result.superagent_parsed_json).toEqual({ route_code: 'S10' })
+    expect(result.superagent_trace_events).toMatchObject([
+      {
+        event: 'reasoning.summary',
+        text: '正在分析 Debug 邮件。',
+      },
+    ])
+  })
+
+  it('throws a typed error when the backend SSE stream emits debug_error', async () => {
+    vi.spyOn(globalThis, 'fetch').mockResolvedValue(
+      mockSseResponse([
+        'event: debug_stage\n',
+        'data: {"debug_run_id":"90004","status":"CALLING_SUPERAGENT","safe_summary":"阶段：调用 SuperAgent Open API。"}\n\n',
+        'event: debug_error\n',
+        'data: {"debug_run_id":"90004","error_code":"SUPERAGENT_OPEN_API_FAILED","message":"SuperAgent 调用失败。","status":"SUPERAGENT_FAILED"}\n\n',
+        'event: done\n',
+        'data: {"status":"done"}\n\n',
+      ]),
+    )
+    const file = new File(['From: guest@example.test'], 'booking.eml', { type: 'message/rfc822' })
+
+    await expect(
+      uploadDebugEmlSuperAgentRunStream({
+        hotelId: 'HOTEL-TEST',
+        debugUploadKey: 'manual-debug-key',
+        file,
+      }),
+    ).rejects.toMatchObject({
+      errorCode: 'SUPERAGENT_OPEN_API_FAILED',
+      message: 'SuperAgent 调用失败。',
+    } satisfies Partial<DebugEmlUploadError>)
+  })
 })
diff --git a/client/src/tests/debugEmlView.spec.ts b/client/src/tests/debugEmlView.spec.ts
index 44a2a2d..9ce4f4e 100644
--- a/client/src/tests/debugEmlView.spec.ts
+++ b/client/src/tests/debugEmlView.spec.ts
@@ -11,6 +11,7 @@ vi.mock('@/services/debugEmlService', async (importOriginal) => {
   return {
     ...actual,
     uploadDebugEmlSuperAgentRun: vi.fn(),
+    uploadDebugEmlSuperAgentRunStream: vi.fn(),
   }
 })
 
@@ -66,6 +67,20 @@ function createResult() {
     superagent_run_id: 'run-1',
     superagent_raw_answer: '{"ok":true}',
     superagent_parsed_json: { ok: true },
+    superagent_trace_events: [
+      {
+        event: 'reasoning.summary',
+        run_id: 'run-1',
+        message_id: null,
+        tool_call_id: null,
+        tool_name: null,
+        text: '正在分析 Debug 邮件。',
+        input_summary: null,
+        output_summary: null,
+        status: null,
+        ts: '2026-07-11T10:00:01Z',
+      },
+    ],
     warnings: ['SuperAgent 返回非 JSON 时会展示原始回答'],
     status: 'SUPERAGENT_SUCCEEDED',
   }
@@ -85,10 +100,47 @@ async function chooseFile(wrapper: ReturnType<typeof mountView>) {
 describe('DebugEmlSuperAgentRunView', () => {
   beforeEach(() => {
     vi.mocked(service.uploadDebugEmlSuperAgentRun).mockReset()
+    vi.mocked(service.uploadDebugEmlSuperAgentRunStream).mockReset()
   })
 
-  it('submits the selected eml file and renders sanitized debug result', async () => {
-    vi.mocked(service.uploadDebugEmlSuperAgentRun).mockResolvedValue(createResult())
+  it('streams the selected eml file and renders stages, trace, and sanitized debug result', async () => {
+    vi.mocked(service.uploadDebugEmlSuperAgentRunStream).mockImplementation(async (_input, handlers) => {
+      handlers?.onStage?.({
+        debug_run_id: '90001',
+        status: 'PARSING_EML',
+        safe_summary: '阶段：解析 EML 邮件。',
+      })
+      handlers?.onStage?.({
+        debug_run_id: '90001',
+        status: 'CALLING_SUPERAGENT',
+        safe_summary: '阶段：调用 SuperAgent Open API，source_message_id=30001。',
+      })
+      handlers?.onTrace?.({
+        event: 'reasoning.summary',
+        run_id: 'run-1',
+        message_id: null,
+        tool_call_id: null,
+        tool_name: null,
+        text: '正在分析 Debug 邮件。',
+        input_summary: null,
+        output_summary: null,
+        status: null,
+        ts: '2026-07-11T10:00:01Z',
+      })
+      handlers?.onTrace?.({
+        event: 'tool.call.started',
+        run_id: 'run-1',
+        message_id: 'ai-1',
+        tool_call_id: 'tool-1',
+        tool_name: 'th_hotel_query_case_context',
+        text: null,
+        input_summary: '{"group_code":"G001"}',
+        output_summary: null,
+        status: null,
+        ts: '2026-07-11T10:00:02Z',
+      })
+      return createResult()
+    })
     const wrapper = mountView()
 
     await wrapper.find('input[name="hotel_id"]').setValue('HOTEL-TEST')
@@ -98,12 +150,24 @@ describe('DebugEmlSuperAgentRunView', () => {
     await wrapper.find('form').trigger('submit')
     await flushPromises()
 
-    expect(service.uploadDebugEmlSuperAgentRun).toHaveBeenCalledWith({
-      hotelId: 'HOTEL-TEST',
-      debugUploadKey: 'manual-debug-key',
-      runLabel: 'frontend-smoke',
-      file,
-    })
+    expect(service.uploadDebugEmlSuperAgentRunStream).toHaveBeenCalledWith(
+      {
+        hotelId: 'HOTEL-TEST',
+        debugUploadKey: 'manual-debug-key',
+        runLabel: 'frontend-smoke',
+        file,
+      },
+      expect.objectContaining({
+        onStage: expect.any(Function),
+        onTrace: expect.any(Function),
+      }),
+    )
+    expect(wrapper.text()).toContain('PARSING_EML')
+    expect(wrapper.text()).toContain('CALLING_SUPERAGENT')
+    expect(wrapper.text()).toContain('阶段：解析 EML 邮件。')
+    expect(wrapper.text()).toContain('reasoning.summary')
+    expect(wrapper.text()).toContain('正在分析 Debug 邮件。')
+    expect(wrapper.text()).toContain('th_hotel_query_case_context')
     expect(wrapper.text()).toContain('90001')
     expect(wrapper.text()).toContain('30001')
     expect(wrapper.text()).toContain('DEBUG_EML_UPLOAD')
@@ -116,7 +180,7 @@ describe('DebugEmlSuperAgentRunView', () => {
   })
 
   it('does not render raw html with oss urls by default', async () => {
-    vi.mocked(service.uploadDebugEmlSuperAgentRun).mockResolvedValue(createResult())
+    vi.mocked(service.uploadDebugEmlSuperAgentRunStream).mockResolvedValue(createResult())
     const wrapper = mountView()
 
     await wrapper.find('input[name="hotel_id"]').setValue('HOTEL-TEST')
@@ -130,7 +194,7 @@ describe('DebugEmlSuperAgentRunView', () => {
   })
 
   it('shows mapped error_code messages without exposing the debug key', async () => {
-    vi.mocked(service.uploadDebugEmlSuperAgentRun).mockRejectedValue(
+    vi.mocked(service.uploadDebugEmlSuperAgentRunStream).mockRejectedValue(
       new DebugEmlUploadError('Debug 上传访问口令缺失或错误。', 401, 'DEBUG_UPLOAD_KEY_INVALID', {
         error_code: 'DEBUG_UPLOAD_KEY_INVALID',
       }),
diff --git a/client/src/types/debugEml.ts b/client/src/types/debugEml.ts
index 75cfa9d..92e4ecb 100644
--- a/client/src/types/debugEml.ts
+++ b/client/src/types/debugEml.ts
@@ -35,10 +35,30 @@ export interface DebugEmlSuperAgentRunResult {
   superagent_run_id: string | null
   superagent_raw_answer: string | null
   superagent_parsed_json: unknown | null
+  superagent_trace_events: DebugEmlSuperAgentTraceEvent[]
   warnings: string[]
   status: string | null
 }
 
+export interface DebugEmlSuperAgentTraceEvent {
+  event: string | null
+  run_id: string | null
+  message_id: string | null
+  tool_call_id: string | null
+  tool_name: string | null
+  text: string | null
+  input_summary: string | null
+  output_summary: string | null
+  status: string | null
+  ts: string | null
+}
+
+export interface DebugEmlStageEvent {
+  debug_run_id: string | null
+  status: string | null
+  safe_summary: string | null
+}
+
 export interface DebugEmlUploadedMediaResult {
   media_type: string | null
   file_name: string | null
@@ -53,3 +73,9 @@ export interface DebugEmlErrorResponse {
   error_code?: DebugEmlErrorCode
   message?: string
 }
+
+export interface DebugEmlStreamHandlers {
+  onStage?: (stage: DebugEmlStageEvent) => void
+  onTrace?: (trace: DebugEmlSuperAgentTraceEvent) => void
+  onResult?: (result: DebugEmlSuperAgentRunResult) => void
+}
diff --git a/client/src/views/debug/DebugEmlSuperAgentRunView.vue b/client/src/views/debug/DebugEmlSuperAgentRunView.vue
index 2a97036..2d32d37 100644
--- a/client/src/views/debug/DebugEmlSuperAgentRunView.vue
+++ b/client/src/views/debug/DebugEmlSuperAgentRunView.vue
@@ -14,13 +14,13 @@
         <div>
           <dt>{{ t('debugEml.debugRunId') }}</dt>
           <dd class="th-code">
-            {{ result?.debug_run_id ?? '-' }}
+            {{ currentDebugRunId ?? '-' }}
           </dd>
         </div>
         <div>
           <dt>{{ t('debugEml.backendStatus') }}</dt>
           <dd class="th-code">
-            {{ result?.status ?? '-' }}
+            {{ currentBackendStatus ?? '-' }}
           </dd>
         </div>
       </dl>
@@ -127,13 +127,13 @@
             <div>
               <dt>{{ t('debugEml.debugRunId') }}</dt>
               <dd class="th-code">
-                {{ result?.debug_run_id ?? '-' }}
+                {{ currentDebugRunId ?? '-' }}
               </dd>
             </div>
             <div>
               <dt>{{ t('debugEml.backendStatus') }}</dt>
               <dd class="th-code">
-                {{ result?.status ?? '-' }}
+                {{ currentBackendStatus ?? '-' }}
               </dd>
             </div>
           </dl>
@@ -157,6 +157,95 @@
       </aside>
 
       <main class="debug-eml-results">
+        <section
+          v-if="stageEvents.length || busy"
+          class="debug-eml-card debug-eml-stream-section"
+        >
+          <div class="th-section-header">
+            <h2 class="th-section-title">
+              <i
+                class="pi pi-list-check"
+                aria-hidden="true"
+              />
+              {{ t('debugEml.systemStages') }}
+            </h2>
+          </div>
+          <ol
+            v-if="stageEvents.length"
+            class="debug-eml-event-list debug-eml-event-list--stages"
+          >
+            <li
+              v-for="(stage, index) in stageEvents"
+              :key="`${stage.status ?? 'stage'}-${index}`"
+            >
+              <strong>{{ stage.status ?? '-' }}</strong>
+              <span>{{ stage.safe_summary ?? '-' }}</span>
+              <small class="th-code">{{ stage.debug_run_id ?? '-' }}</small>
+            </li>
+          </ol>
+          <div
+            v-else
+            class="empty-state empty-state--compact"
+          >
+            {{ t('debugEml.waitingSuperAgent') }}
+          </div>
+        </section>
+
+        <section
+          v-if="visibleTraceEvents.length || busy"
+          class="debug-eml-card debug-eml-stream-section"
+        >
+          <div class="th-section-header">
+            <h2 class="th-section-title">
+              <i
+                class="pi pi-wave-pulse"
+                aria-hidden="true"
+              />
+              {{ t('debugEml.superAgentTrace') }}
+            </h2>
+          </div>
+          <ol
+            v-if="visibleTraceEvents.length"
+            class="debug-eml-event-list debug-eml-event-list--trace"
+          >
+            <li
+              v-for="(trace, index) in visibleTraceEvents"
+              :key="`${trace.event ?? 'trace'}-${trace.tool_call_id ?? index}`"
+            >
+              <strong>{{ trace.event ?? '-' }}</strong>
+              <span v-if="trace.text">{{ trace.text }}</span>
+              <dl class="debug-eml-trace-fields">
+                <div v-if="trace.tool_name">
+                  <dt>{{ t('debugEml.traceToolName') }}</dt>
+                  <dd class="th-code">{{ trace.tool_name }}</dd>
+                </div>
+                <div v-if="trace.input_summary">
+                  <dt>{{ t('debugEml.traceInputSummary') }}</dt>
+                  <dd class="th-code">{{ trace.input_summary }}</dd>
+                </div>
+                <div v-if="trace.output_summary">
+                  <dt>{{ t('debugEml.traceOutputSummary') }}</dt>
+                  <dd class="th-code">{{ trace.output_summary }}</dd>
+                </div>
+                <div v-if="trace.status">
+                  <dt>{{ t('debugEml.traceStatus') }}</dt>
+                  <dd class="th-code">{{ trace.status }}</dd>
+                </div>
+                <div v-if="trace.ts">
+                  <dt>{{ t('debugEml.traceTime') }}</dt>
+                  <dd class="th-code">{{ trace.ts }}</dd>
+                </div>
+              </dl>
+            </li>
+          </ol>
+          <div
+            v-else
+            class="empty-state empty-state--compact"
+          >
+            {{ t('common.noData') }}
+          </div>
+        </section>
+
         <template v-if="result">
           <section class="debug-eml-card">
             <div class="th-section-header">
@@ -341,8 +430,13 @@ import { computed, ref } from 'vue'
 import { useI18n } from 'vue-i18n'
 
 import { reservationHotelId } from '@/config/reservationConfig'
-import { DebugEmlUploadError, uploadDebugEmlSuperAgentRun } from '@/services/debugEmlService'
-import type { DebugEmlErrorCode, DebugEmlSuperAgentRunResult } from '@/types/debugEml'
+import { DebugEmlUploadError, uploadDebugEmlSuperAgentRunStream } from '@/services/debugEmlService'
+import type {
+  DebugEmlErrorCode,
+  DebugEmlStageEvent,
+  DebugEmlSuperAgentRunResult,
+  DebugEmlSuperAgentTraceEvent,
+} from '@/types/debugEml'
 
 type DebugEmlStatus = 'idle' | 'uploading' | 'succeeded' | 'failed'
 
@@ -354,6 +448,8 @@ const runLabel = ref('')
 const selectedFile = ref<File | null>(null)
 const status = ref<DebugEmlStatus>('idle')
 const result = ref<DebugEmlSuperAgentRunResult | null>(null)
+const stageEvents = ref<DebugEmlStageEvent[]>([])
+const traceEvents = ref<DebugEmlSuperAgentTraceEvent[]>([])
 const errorCode = ref<DebugEmlErrorCode | ''>('')
 const errorMessage = ref('')
 
@@ -362,6 +458,16 @@ const submitDisabled = computed(
   () => busy.value || !debugUploadKey.value.trim() || !selectedFile.value,
 )
 const statusLabel = computed(() => t(`debugEml.statuses.${status.value}`))
+const latestStageEvent = computed(() => stageEvents.value[stageEvents.value.length - 1] ?? null)
+const currentDebugRunId = computed(
+  () => result.value?.debug_run_id || latestStageEvent.value?.debug_run_id || null,
+)
+const currentBackendStatus = computed(
+  () => result.value?.status || latestStageEvent.value?.status || null,
+)
+const visibleTraceEvents = computed(() =>
+  traceEvents.value.length ? traceEvents.value : result.value?.superagent_trace_events ?? [],
+)
 const errorDisplayMessage = computed(() => {
   if (!errorCode.value) {
     return ''
@@ -394,14 +500,33 @@ async function submitUpload(): Promise<void> {
   errorCode.value = ''
   errorMessage.value = ''
   result.value = null
+  stageEvents.value = []
+  traceEvents.value = []
 
   try {
-    result.value = await uploadDebugEmlSuperAgentRun({
-      hotelId: hotelId.value,
-      debugUploadKey: debugUploadKey.value.trim(),
-      runLabel: runLabel.value,
-      file: selectedFile.value,
-    })
+    const finalResult = await uploadDebugEmlSuperAgentRunStream(
+      {
+        hotelId: hotelId.value,
+        debugUploadKey: debugUploadKey.value.trim(),
+        runLabel: runLabel.value,
+        file: selectedFile.value,
+      },
+      {
+        onStage: (stage) => {
+          stageEvents.value = [...stageEvents.value, stage]
+        },
+        onTrace: (trace) => {
+          traceEvents.value = [...traceEvents.value, trace]
+        },
+        onResult: (streamResult) => {
+          result.value = streamResult
+        },
+      },
+    )
+    result.value = finalResult
+    if (!traceEvents.value.length && finalResult.superagent_trace_events.length) {
+      traceEvents.value = finalResult.superagent_trace_events
+    }
     status.value = 'succeeded'
   } catch (error) {
     status.value = 'failed'
@@ -680,6 +805,11 @@ function formatMediaSize(sizeBytes: number | null): string {
   color: var(--th-color-slate-900);
 }
 
+.empty-state--compact {
+  min-height: 84px;
+  padding: 16px;
+}
+
 .empty-state--error {
   place-items: start;
   color: var(--th-color-danger);
@@ -732,6 +862,78 @@ function formatMediaSize(sizeBytes: number | null): string {
   font-weight: 800;
 }
 
+.debug-eml-stream-section {
+  gap: 14px;
+}
+
+.debug-eml-event-list {
+  display: grid;
+  gap: 10px;
+  margin: 0;
+  padding: 0;
+  list-style: none;
+}
+
+.debug-eml-event-list li {
+  min-width: 0;
+  display: grid;
+  gap: 8px;
+  border: 1px solid rgba(148, 163, 184, 0.25);
+  border-radius: 10px;
+  background: var(--th-color-slate-50);
+  padding: 12px;
+}
+
+.debug-eml-event-list strong {
+  color: var(--th-color-slate-900);
+  font-size: 13px;
+  overflow-wrap: anywhere;
+}
+
+.debug-eml-event-list span,
+.debug-eml-event-list small {
+  color: var(--th-color-slate-600);
+  font-size: 12px;
+  line-height: 1.55;
+  overflow-wrap: anywhere;
+}
+
+.debug-eml-event-list--stages li {
+  grid-template-columns: minmax(150px, 210px) minmax(0, 1fr) minmax(100px, 160px);
+  align-items: start;
+}
+
+.debug-eml-event-list--trace li {
+  background: linear-gradient(180deg, var(--th-color-white), var(--th-color-slate-50));
+}
+
+.debug-eml-trace-fields {
+  display: grid;
+  grid-template-columns: repeat(2, minmax(0, 1fr));
+  gap: 8px;
+  margin: 0;
+}
+
+.debug-eml-trace-fields div {
+  min-width: 0;
+  border-radius: 8px;
+  background: rgb(255 255 255 / 76%);
+  padding: 8px;
+}
+
+.debug-eml-trace-fields dt {
+  color: var(--th-color-slate-500);
+  font-size: 11px;
+  font-weight: 700;
+}
+
+.debug-eml-trace-fields dd {
+  margin: 4px 0 0;
+  color: var(--th-color-slate-900);
+  font-size: 12px;
+  overflow-wrap: anywhere;
+}
+
 .debug-eml-html-preview {
   max-height: 520px;
   overflow: auto;
@@ -886,6 +1088,8 @@ pre {
   .debug-eml-kv,
   .debug-eml-kv--grid,
   .debug-eml-two-column,
+  .debug-eml-event-list--stages li,
+  .debug-eml-trace-fields,
   .debug-eml-media-list li {
     grid-template-columns: 1fr;
   }
diff --git a/server/src/main/java/cn/nianxx/thhotel/integrations/ai/superagent/common/result/SuperAgentOpenApiResult.java b/server/src/main/java/cn/nianxx/thhotel/integrations/ai/superagent/common/result/SuperAgentOpenApiResult.java
index ba83655..8e24609 100644
--- a/server/src/main/java/cn/nianxx/thhotel/integrations/ai/superagent/common/result/SuperAgentOpenApiResult.java
+++ b/server/src/main/java/cn/nianxx/thhotel/integrations/ai/superagent/common/result/SuperAgentOpenApiResult.java
@@ -1,5 +1,6 @@
 package cn.nianxx.thhotel.integrations.ai.superagent.common.result;
 
+import com.fasterxml.jackson.annotation.JsonProperty;
 import java.util.List;
 
 /**
@@ -15,6 +16,7 @@ import java.util.List;
  * @param outputTokens 输出 token 数
  * @param totalTokens 总 token 数
  * @param eventTypes SSE 事件类型列表
+ * @param traceEvents SuperAgent 公开 Trace 事件列表，只包含可展示摘要字段
  */
 public record SuperAgentOpenApiResult(
         String sessionId,
@@ -26,6 +28,44 @@ public record SuperAgentOpenApiResult(
         Integer inputTokens,
         Integer outputTokens,
         Integer totalTokens,
-        List<String> eventTypes
+        List<String> eventTypes,
+        @JsonProperty("trace_events")
+        List<SuperAgentOpenApiTraceEvent> traceEvents
 ) {
+
+    /**
+     * 兼容未启用 Trace 的历史调用方。
+     */
+    public SuperAgentOpenApiResult(
+            String sessionId,
+            String runId,
+            String profileId,
+            String profileVersionId,
+            String modelName,
+            String rawAnswer,
+            Integer inputTokens,
+            Integer outputTokens,
+            Integer totalTokens,
+            List<String> eventTypes) {
+        this(
+                sessionId,
+                runId,
+                profileId,
+                profileVersionId,
+                modelName,
+                rawAnswer,
+                inputTokens,
+                outputTokens,
+                totalTokens,
+                eventTypes,
+                List.of());
+    }
+
+    /**
+     * 复制集合，避免结果对象被调用方后续修改。
+     */
+    public SuperAgentOpenApiResult {
+        eventTypes = eventTypes == null ? List.of() : List.copyOf(eventTypes);
+        traceEvents = traceEvents == null ? List.of() : List.copyOf(traceEvents);
+    }
 }
diff --git a/server/src/main/java/cn/nianxx/thhotel/integrations/ai/superagent/common/result/SuperAgentOpenApiTraceEvent.java b/server/src/main/java/cn/nianxx/thhotel/integrations/ai/superagent/common/result/SuperAgentOpenApiTraceEvent.java
new file mode 100644
index 0000000..165d109
--- /dev/null
+++ b/server/src/main/java/cn/nianxx/thhotel/integrations/ai/superagent/common/result/SuperAgentOpenApiTraceEvent.java
@@ -0,0 +1,37 @@
+package cn.nianxx.thhotel.integrations.ai.superagent.common.result;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+/**
+ * SuperAgent Open API 公开 Trace 事件。只保留对外策略允许的摘要字段，不保存原始工具入参、Secret 或 Cookie。
+ *
+ * @param event SuperAgent 公开 trace 事件类型
+ * @param runId SuperAgent run ID
+ * @param messageId AI message ID
+ * @param toolCallId 工具调用 ID
+ * @param toolName 工具名称
+ * @param text 公开推理或进度摘要
+ * @param inputSummary 工具入参摘要
+ * @param outputSummary 工具输出摘要
+ * @param status 运行或任务状态
+ * @param ts SuperAgent 事件时间戳
+ */
+public record SuperAgentOpenApiTraceEvent(
+        String event,
+        @JsonProperty("run_id")
+        String runId,
+        @JsonProperty("message_id")
+        String messageId,
+        @JsonProperty("tool_call_id")
+        String toolCallId,
+        @JsonProperty("tool_name")
+        String toolName,
+        String text,
+        @JsonProperty("input_summary")
+        String inputSummary,
+        @JsonProperty("output_summary")
+        String outputSummary,
+        String status,
+        String ts
+) {
+}
diff --git a/server/src/main/java/cn/nianxx/thhotel/integrations/ai/superagent/service/SuperAgentOpenApiClient.java b/server/src/main/java/cn/nianxx/thhotel/integrations/ai/superagent/service/SuperAgentOpenApiClient.java
index 24c2da0..832b622 100644
--- a/server/src/main/java/cn/nianxx/thhotel/integrations/ai/superagent/service/SuperAgentOpenApiClient.java
+++ b/server/src/main/java/cn/nianxx/thhotel/integrations/ai/superagent/service/SuperAgentOpenApiClient.java
@@ -2,6 +2,8 @@ package cn.nianxx.thhotel.integrations.ai.superagent.service;
 
 import cn.nianxx.thhotel.integrations.ai.superagent.common.request.SuperAgentMailDebugRequest;
 import cn.nianxx.thhotel.integrations.ai.superagent.common.result.SuperAgentOpenApiResult;
+import cn.nianxx.thhotel.integrations.ai.superagent.common.result.SuperAgentOpenApiTraceEvent;
+import java.util.function.Consumer;
 
 /**
  * SuperAgent Open API 客户端端口。业务层只依赖该接口，不直接拼 HTTP 或解析 SSE。
@@ -11,5 +13,15 @@ public interface SuperAgentOpenApiClient {
     /**
      * 创建 SuperAgent session 并发送邮件 Debug 消息，返回最终 AI 回答。
      */
-    SuperAgentOpenApiResult invokeMailDebug(SuperAgentMailDebugRequest request);
+    default SuperAgentOpenApiResult invokeMailDebug(SuperAgentMailDebugRequest request) {
+        return invokeMailDebug(request, traceEvent -> {
+        });
+    }
+
+    /**
+     * 创建 SuperAgent session 并发送邮件 Debug 消息，边解析边回调公开 Trace 事件。
+     */
+    SuperAgentOpenApiResult invokeMailDebug(
+            SuperAgentMailDebugRequest request,
+            Consumer<SuperAgentOpenApiTraceEvent> traceConsumer);
 }
diff --git a/server/src/main/java/cn/nianxx/thhotel/integrations/ai/superagent/service/impl/SuperAgentOpenApiClientImpl.java b/server/src/main/java/cn/nianxx/thhotel/integrations/ai/superagent/service/impl/SuperAgentOpenApiClientImpl.java
index 5cc89cd..7ebdcd4 100644
--- a/server/src/main/java/cn/nianxx/thhotel/integrations/ai/superagent/service/impl/SuperAgentOpenApiClientImpl.java
+++ b/server/src/main/java/cn/nianxx/thhotel/integrations/ai/superagent/service/impl/SuperAgentOpenApiClientImpl.java
@@ -2,16 +2,22 @@ package cn.nianxx.thhotel.integrations.ai.superagent.service.impl;
 
 import cn.nianxx.thhotel.integrations.ai.superagent.common.request.SuperAgentMailDebugRequest;
 import cn.nianxx.thhotel.integrations.ai.superagent.common.result.SuperAgentOpenApiResult;
+import cn.nianxx.thhotel.integrations.ai.superagent.common.result.SuperAgentOpenApiTraceEvent;
 import cn.nianxx.thhotel.integrations.ai.superagent.service.SuperAgentOpenApiClient;
 import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.ObjectMapper;
+import java.io.InputStreamReader;
+import java.nio.charset.StandardCharsets;
 import java.util.LinkedHashMap;
 import java.util.Map;
 import java.util.UUID;
+import java.util.function.Consumer;
 import org.springframework.http.client.SimpleClientHttpRequestFactory;
 import org.springframework.http.MediaType;
 import org.springframework.stereotype.Service;
+import org.springframework.util.StreamUtils;
 import org.springframework.web.client.RestClient;
+import org.springframework.web.client.RestClientResponseException;
 
 /**
  * SuperAgent Open API HTTP 客户端实现。负责创建 session、发送 SSE 消息和解析最终回答。
@@ -39,7 +45,9 @@ public class SuperAgentOpenApiClientImpl implements SuperAgentOpenApiClient {
      * 调用 SuperAgent Open API 邮件 Debug 流程；配置缺失时直接失败，避免静默跳过真实调用。
      */
     @Override
-    public SuperAgentOpenApiResult invokeMailDebug(SuperAgentMailDebugRequest request) {
+    public SuperAgentOpenApiResult invokeMailDebug(
+            SuperAgentMailDebugRequest request,
+            Consumer<SuperAgentOpenApiTraceEvent> traceConsumer) {
         validateProperties();
         try {
             RestClient restClient = RestClient.builder()
@@ -47,8 +55,7 @@ public class SuperAgentOpenApiClientImpl implements SuperAgentOpenApiClient {
                     .requestFactory(requestFactory())
                     .build();
             String sessionId = createSession(restClient, request);
-            String sseBody = sendMessage(restClient, sessionId, request);
-            return sseParser.parse(sessionId, sseBody);
+            return sendMessage(restClient, sessionId, request, traceConsumer);
         } catch (SuperAgentOpenApiException exception) {
             throw exception;
         } catch (Exception exception) {
@@ -86,24 +93,46 @@ public class SuperAgentOpenApiClientImpl implements SuperAgentOpenApiClient {
     }
 
     /**
-     * 发送 Debug 邮件消息并读取 SSE 文本响应。
+     * 发送 Debug 邮件消息并流式解析 SSE 文本响应。
      */
-    private String sendMessage(RestClient restClient, String sessionId, SuperAgentMailDebugRequest request) {
+    private SuperAgentOpenApiResult sendMessage(
+            RestClient restClient,
+            String sessionId,
+            SuperAgentMailDebugRequest request,
+            Consumer<SuperAgentOpenApiTraceEvent> traceConsumer) {
         String csrfToken = UUID.randomUUID().toString();
         Map<String, Object> body = new LinkedHashMap<>();
         body.put("message", request.message());
         body.put("idempotency_key", request.idempotencyKey() + "-message");
         body.put("metadata", request.metadata());
         return restClient.post()
-                .uri("/api/open/agent-sessions/{sessionId}/messages/stream", sessionId)
+                .uri(uriBuilder -> uriBuilder
+                        .path("/api/open/agent-sessions/{sessionId}/messages/stream")
+                        .queryParam("include_trace", "true")
+                        .build(sessionId))
                 .contentType(MediaType.APPLICATION_JSON)
                 .accept(MediaType.TEXT_EVENT_STREAM)
                 .header("Authorization", "Bearer " + properties.getApiKey())
                 .header("X-CSRF-Token", csrfToken)
                 .header("Cookie", "csrf_token=" + csrfToken)
                 .body(body)
-                .retrieve()
-                .body(String.class);
+                .exchange((clientRequest, clientResponse) -> {
+                    if (!clientResponse.getStatusCode().is2xxSuccessful()) {
+                        byte[] responseBody = StreamUtils.copyToByteArray(clientResponse.getBody());
+                        throw new RestClientResponseException(
+                                "SuperAgent Open API HTTP 调用失败。",
+                                clientResponse.getStatusCode(),
+                                clientResponse.getStatusText(),
+                                clientResponse.getHeaders(),
+                                responseBody,
+                                StandardCharsets.UTF_8);
+                    }
+                    try (InputStreamReader reader = new InputStreamReader(
+                            clientResponse.getBody(),
+                            StandardCharsets.UTF_8)) {
+                        return sseParser.parse(sessionId, reader, traceConsumer);
+                    }
+                });
     }
 
     /**
diff --git a/server/src/main/java/cn/nianxx/thhotel/integrations/ai/superagent/service/impl/SuperAgentOpenApiSseParser.java b/server/src/main/java/cn/nianxx/thhotel/integrations/ai/superagent/service/impl/SuperAgentOpenApiSseParser.java
index edcd91e..d148c87 100644
--- a/server/src/main/java/cn/nianxx/thhotel/integrations/ai/superagent/service/impl/SuperAgentOpenApiSseParser.java
+++ b/server/src/main/java/cn/nianxx/thhotel/integrations/ai/superagent/service/impl/SuperAgentOpenApiSseParser.java
@@ -1,12 +1,19 @@
 package cn.nianxx.thhotel.integrations.ai.superagent.service.impl;
 
 import cn.nianxx.thhotel.integrations.ai.superagent.common.result.SuperAgentOpenApiResult;
+import cn.nianxx.thhotel.integrations.ai.superagent.common.result.SuperAgentOpenApiTraceEvent;
 import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.ObjectMapper;
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.Reader;
+import java.io.StringReader;
 import java.util.ArrayList;
 import java.util.LinkedHashSet;
 import java.util.List;
 import java.util.Set;
+import java.util.function.Consumer;
+import java.util.regex.Pattern;
 import org.springframework.stereotype.Component;
 
 /**
@@ -15,6 +22,13 @@ import org.springframework.stereotype.Component;
 @Component
 public class SuperAgentOpenApiSseParser {
 
+    private static final Pattern JSON_SECRET_PATTERN = Pattern.compile(
+            "(?i)(\"(?:api[_-]?key|token|secret|password|cookie|authorization)\"\\s*:\\s*\")[^\"]*(\")");
+    private static final Pattern HEADER_SECRET_PATTERN = Pattern.compile(
+            "(?i)((?:authorization|cookie)\\s*:\\s*)[^\\s,;]+");
+    private static final Pattern TEXT_SECRET_PATTERN = Pattern.compile(
+            "(?i)((?:api[_-]?key|token|secret|password)\\s*[=:]\\s*)[^\\s,;}]+");
+
     private final ObjectMapper objectMapper;
 
     /**
@@ -35,18 +49,50 @@ public class SuperAgentOpenApiSseParser {
      * 解析 SSE 文本，返回最终 AI 回答和调用元数据。
      */
     public SuperAgentOpenApiResult parse(String sessionId, String sseBody) {
+        return parse(sessionId, sseBody, traceEvent -> {
+        });
+    }
+
+    /**
+     * 解析 SSE 文本，边解析边回调 SuperAgent 公开 Trace 事件。
+     */
+    public SuperAgentOpenApiResult parse(
+            String sessionId,
+            String sseBody,
+            Consumer<SuperAgentOpenApiTraceEvent> traceConsumer) {
         if (sseBody == null || sseBody.isBlank()) {
             throw new SuperAgentOpenApiException("SuperAgent SSE 响应为空。");
         }
+        return parse(sessionId, new StringReader(sseBody), traceConsumer);
+    }
+
+    /**
+     * 从 Reader 流式解析 SSE，适用于 Open API 长连接响应。
+     */
+    public SuperAgentOpenApiResult parse(
+            String sessionId,
+            Reader reader,
+            Consumer<SuperAgentOpenApiTraceEvent> traceConsumer) {
+        if (reader == null) {
+            throw new SuperAgentOpenApiException("SuperAgent SSE 响应为空。");
+        }
         Set<String> eventTypes = new LinkedHashSet<>();
         ParsedState state = new ParsedState();
-        for (SseEvent event : splitEvents(sseBody)) {
-            eventTypes.add(event.eventType());
-            consumeEvent(event, state);
-            if (state.endSeen) {
-                break;
-            }
+        try {
+            parseLines(reader, event -> {
+                eventTypes.add(event.eventType());
+                consumeEvent(event, state, safeTraceConsumer(traceConsumer));
+            }, state);
+        } catch (IOException exception) {
+            throw new SuperAgentOpenApiException("SuperAgent SSE 读取失败。", exception);
         }
+        return buildResult(sessionId, eventTypes, state);
+    }
+
+    /**
+     * 汇总解析状态并生成结果对象。
+     */
+    private SuperAgentOpenApiResult buildResult(String sessionId, Set<String> eventTypes, ParsedState state) {
         if (!state.endSeen) {
             throw new SuperAgentOpenApiException("SuperAgent SSE 未收到结束事件。");
         }
@@ -70,13 +116,17 @@ public class SuperAgentOpenApiSseParser {
                 state.inputTokens,
                 state.outputTokens,
                 state.totalTokens,
-                List.copyOf(eventTypes));
+                List.copyOf(eventTypes),
+                List.copyOf(state.traceEvents));
     }
 
     /**
      * 消费单个 SSE 事件。
      */
-    private void consumeEvent(SseEvent event, ParsedState state) {
+    private void consumeEvent(
+            SseEvent event,
+            ParsedState state,
+            Consumer<SuperAgentOpenApiTraceEvent> traceConsumer) {
         try {
             if ("end".equals(event.eventType())) {
                 state.endSeen = true;
@@ -94,6 +144,9 @@ public class SuperAgentOpenApiSseParser {
             if ("values".equals(event.eventType())) {
                 consumeValuesEvent(data, state);
             }
+            if ("trace".equals(event.eventType())) {
+                consumeTraceEvent(data, state, traceConsumer);
+            }
         } catch (Exception exception) {
             throw new SuperAgentOpenApiException("SuperAgent SSE JSON 解析失败。", exception);
         }
@@ -159,31 +212,96 @@ public class SuperAgentOpenApiSseParser {
     }
 
     /**
-     * 拆分 SSE 事件块，支持多行 data。
+     * 消费公开 Trace 事件，只提取可展示摘要字段。
      */
-    private List<SseEvent> splitEvents(String sseBody) {
-        String[] blocks = sseBody.split("\\R\\s*\\R");
-        List<SseEvent> events = new ArrayList<>();
-        for (String block : blocks) {
-            String eventType = "message";
-            StringBuilder data = new StringBuilder();
-            for (String line : block.split("\\R")) {
-                if (line.startsWith("event:")) {
-                    eventType = line.substring("event:".length()).trim();
-                    continue;
-                }
-                if (line.startsWith("data:")) {
-                    if (!data.isEmpty()) {
-                        data.append('\n');
-                    }
-                    data.append(line.substring("data:".length()).trim());
-                }
+    private void consumeTraceEvent(
+            JsonNode data,
+            ParsedState state,
+            Consumer<SuperAgentOpenApiTraceEvent> traceConsumer) {
+        JsonNode trace = data.path("data").isObject() && data.path("event").isMissingNode()
+                ? data.path("data")
+                : data;
+        JsonNode toolCalls = trace.path("tool_calls");
+        if (toolCalls.isArray() && !toolCalls.isEmpty()) {
+            for (JsonNode toolCall : toolCalls) {
+                emitTraceEvent(traceEvent(trace, toolCall), state, traceConsumer);
             }
-            if (!data.isEmpty() || "end".equals(eventType)) {
-                events.add(new SseEvent(eventType, data.toString()));
+            return;
+        }
+        emitTraceEvent(traceEvent(trace, trace), state, traceConsumer);
+    }
+
+    /**
+     * 构造公开 Trace 事件对象。
+     */
+    private SuperAgentOpenApiTraceEvent traceEvent(JsonNode trace, JsonNode detail) {
+        return new SuperAgentOpenApiTraceEvent(
+                safeTraceText(text(trace, "event", null)),
+                safeTraceText(text(trace, "run_id", null)),
+                safeTraceText(text(trace, "message_id", null)),
+                safeTraceText(text(detail, "tool_call_id", text(trace, "tool_call_id", null))),
+                safeTraceText(text(detail, "name", text(trace, "name", null))),
+                safeTraceText(text(trace, "text", null)),
+                safeTraceText(summary(detail.path("input"), summary(trace.path("input"), null))),
+                safeTraceText(summary(detail.path("output"), summary(trace.path("output"), null))),
+                safeTraceText(text(trace, "status", null)),
+                safeTraceText(text(trace, "ts", null)));
+    }
+
+    /**
+     * 保存并回调 Trace 事件。
+     */
+    private void emitTraceEvent(
+            SuperAgentOpenApiTraceEvent traceEvent,
+            ParsedState state,
+            Consumer<SuperAgentOpenApiTraceEvent> traceConsumer) {
+        if (traceEvent.event() == null || traceEvent.event().isBlank()) {
+            return;
+        }
+        state.traceEvents.add(traceEvent);
+        traceConsumer.accept(traceEvent);
+    }
+
+    /**
+     * 流式拆分 SSE 事件块，支持多行 data。
+     */
+    private void parseLines(Reader reader, Consumer<SseEvent> consumer, ParsedState state) throws IOException {
+        BufferedReader bufferedReader = reader instanceof BufferedReader existingReader
+                ? existingReader
+                : new BufferedReader(reader);
+        SseEventBuilder builder = new SseEventBuilder();
+        String line;
+        while ((line = bufferedReader.readLine()) != null) {
+            if (line.isBlank()) {
+                flushEvent(builder, consumer);
+                if (state.endSeen) {
+                    return;
+                }
+                continue;
+            }
+            if (line.startsWith(":")) {
+                continue;
+            }
+            if (line.startsWith("event:")) {
+                builder.eventType(line.substring("event:".length()).trim());
+                continue;
+            }
+            if (line.startsWith("data:")) {
+                builder.appendData(line.substring("data:".length()).trim());
             }
         }
-        return events;
+        flushEvent(builder, consumer);
+    }
+
+    /**
+     * 输出当前累积事件并重置 builder。
+     */
+    private void flushEvent(SseEventBuilder builder, Consumer<SseEvent> consumer) {
+        SseEvent event = builder.build();
+        if (event != null) {
+            consumer.accept(event);
+        }
+        builder.reset();
     }
 
     /**
@@ -205,6 +323,42 @@ public class SuperAgentOpenApiSseParser {
         return value.asInt();
     }
 
+    /**
+     * 读取公开 summary 字段。
+     */
+    private String summary(JsonNode node, String fallback) {
+        if (node == null || node.isMissingNode() || node.isNull()) {
+            return fallback;
+        }
+        String value = text(node, "summary", null);
+        if (value != null) {
+            return value;
+        }
+        return node.isTextual() ? node.asText() : fallback;
+    }
+
+    /**
+     * Trace 展示字段做短文本脱敏与截断。
+     */
+    private String safeTraceText(String value) {
+        if (value == null || value.isBlank()) {
+            return null;
+        }
+        String sanitized = JSON_SECRET_PATTERN.matcher(value).replaceAll("$1***$2");
+        sanitized = HEADER_SECRET_PATTERN.matcher(sanitized).replaceAll("$1***");
+        sanitized = TEXT_SECRET_PATTERN.matcher(sanitized).replaceAll("$1***");
+        return sanitized.length() > 2048 ? sanitized.substring(0, 2048) : sanitized;
+    }
+
+    /**
+     * Trace 消费者为空时使用 no-op。
+     */
+    private Consumer<SuperAgentOpenApiTraceEvent> safeTraceConsumer(
+            Consumer<SuperAgentOpenApiTraceEvent> traceConsumer) {
+        return traceConsumer == null ? traceEvent -> {
+        } : traceConsumer;
+    }
+
     /**
      * 读取 AI content，兼容字符串、文本片段数组和简单文本对象。
      */
@@ -252,6 +406,37 @@ public class SuperAgentOpenApiSseParser {
     private record SseEvent(String eventType, String data) {
     }
 
+    /**
+     * SSE 事件累积器。
+     */
+    private static final class SseEventBuilder {
+        private String eventType = "message";
+        private final StringBuilder data = new StringBuilder();
+
+        private void eventType(String eventType) {
+            this.eventType = eventType == null || eventType.isBlank() ? "message" : eventType;
+        }
+
+        private void appendData(String value) {
+            if (!data.isEmpty()) {
+                data.append('\n');
+            }
+            data.append(value);
+        }
+
+        private SseEvent build() {
+            if (data.isEmpty() && !"end".equals(eventType)) {
+                return null;
+            }
+            return new SseEvent(eventType, data.toString());
+        }
+
+        private void reset() {
+            eventType = "message";
+            data.setLength(0);
+        }
+    }
+
     /**
      * SSE 解析过程中的可变状态。
      */
@@ -270,5 +455,6 @@ public class SuperAgentOpenApiSseParser {
         private Integer fallbackInputTokens;
         private Integer fallbackOutputTokens;
         private Integer fallbackTotalTokens;
+        private final List<SuperAgentOpenApiTraceEvent> traceEvents = new ArrayList<>();
     }
 }
diff --git a/server/src/main/java/cn/nianxx/thhotel/platform/debug/common/result/DebugEmlSuperAgentRunResult.java b/server/src/main/java/cn/nianxx/thhotel/platform/debug/common/result/DebugEmlSuperAgentRunResult.java
index 874c014..ef5b28e 100644
--- a/server/src/main/java/cn/nianxx/thhotel/platform/debug/common/result/DebugEmlSuperAgentRunResult.java
+++ b/server/src/main/java/cn/nianxx/thhotel/platform/debug/common/result/DebugEmlSuperAgentRunResult.java
@@ -1,5 +1,6 @@
 package cn.nianxx.thhotel.platform.debug.common.result;
 
+import cn.nianxx.thhotel.integrations.ai.superagent.common.result.SuperAgentOpenApiTraceEvent;
 import com.fasterxml.jackson.annotation.JsonProperty;
 import com.fasterxml.jackson.databind.JsonNode;
 import java.util.List;
@@ -25,6 +26,7 @@ import java.util.Map;
  * @param superagentRunId SuperAgent run ID
  * @param superagentRawAnswer SuperAgent 原始最终回答
  * @param superagentParsedJson 后端解析出的 JSON
+ * @param superagentTraceEvents SuperAgent 公开 Trace 事件列表
  * @param warnings 可展示的安全警告
  * @param status Debug 运行状态
  */
@@ -63,6 +65,8 @@ public record DebugEmlSuperAgentRunResult(
         String superagentRawAnswer,
         @JsonProperty("superagent_parsed_json")
         JsonNode superagentParsedJson,
+        @JsonProperty("superagent_trace_events")
+        List<SuperAgentOpenApiTraceEvent> superagentTraceEvents,
         List<String> warnings,
         String status
 ) {
diff --git a/server/src/main/java/cn/nianxx/thhotel/platform/debug/control/DebugEmlSuperAgentController.java b/server/src/main/java/cn/nianxx/thhotel/platform/debug/control/DebugEmlSuperAgentController.java
index ae168c7..adcc625 100644
--- a/server/src/main/java/cn/nianxx/thhotel/platform/debug/control/DebugEmlSuperAgentController.java
+++ b/server/src/main/java/cn/nianxx/thhotel/platform/debug/control/DebugEmlSuperAgentController.java
@@ -3,6 +3,7 @@ package cn.nianxx.thhotel.platform.debug.control;
 import cn.nianxx.thhotel.platform.debug.common.result.DebugEmlSuperAgentRunResult;
 import cn.nianxx.thhotel.platform.debug.service.DebugEmlSuperAgentRunService;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.http.HttpHeaders;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.MediaType;
 import org.springframework.http.ResponseEntity;
@@ -12,6 +13,7 @@ import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 import org.springframework.web.multipart.MultipartFile;
+import org.springframework.web.servlet.mvc.method.annotation.StreamingResponseBody;
 
 /**
  * Debug EML 上传 Controller。该入口只用于受控调试，不创建业务订单或任务。
@@ -41,4 +43,23 @@ public class DebugEmlSuperAgentController {
             @RequestParam(name = "run_label", required = false) String runLabel) {
         return ResponseEntity.status(HttpStatus.CREATED).body(runService.uploadAndRun(accessKey, file, hotelId, runLabel));
     }
+
+    /**
+     * 上传单封 .eml 邮件并以 SSE 实时返回本系统阶段、SuperAgent 公开 Trace 和最终回答。
+     */
+    @PostMapping(path = "/stream", consumes = MediaType.MULTIPART_FORM_DATA_VALUE, produces = MediaType.TEXT_EVENT_STREAM_VALUE)
+    public ResponseEntity<StreamingResponseBody> uploadStream(
+            @RequestHeader(name = "X-TH-Hotel-Debug-Upload-Key", required = false) String accessKey,
+            @RequestParam("file") MultipartFile file,
+            @RequestParam(name = "hotel_id", required = false) String hotelId,
+            @RequestParam(name = "run_label", required = false) String runLabel) {
+        runService.validateUploadAccessKey(accessKey);
+        StreamingResponseBody responseBody = outputStream ->
+                runService.uploadAndRunStream(accessKey, file, hotelId, runLabel, outputStream);
+        return ResponseEntity.ok()
+                .header(HttpHeaders.CACHE_CONTROL, "no-cache")
+                .header("X-Accel-Buffering", "no")
+                .contentType(MediaType.TEXT_EVENT_STREAM)
+                .body(responseBody);
+    }
 }
diff --git a/server/src/main/java/cn/nianxx/thhotel/platform/debug/service/DebugEmlSuperAgentRunService.java b/server/src/main/java/cn/nianxx/thhotel/platform/debug/service/DebugEmlSuperAgentRunService.java
index f073ac2..3bf44b9 100644
--- a/server/src/main/java/cn/nianxx/thhotel/platform/debug/service/DebugEmlSuperAgentRunService.java
+++ b/server/src/main/java/cn/nianxx/thhotel/platform/debug/service/DebugEmlSuperAgentRunService.java
@@ -1,6 +1,7 @@
 package cn.nianxx.thhotel.platform.debug.service;
 
 import cn.nianxx.thhotel.platform.debug.common.result.DebugEmlSuperAgentRunResult;
+import java.io.OutputStream;
 import org.springframework.web.multipart.MultipartFile;
 
 /**
@@ -8,6 +9,11 @@ import org.springframework.web.multipart.MultipartFile;
  */
 public interface DebugEmlSuperAgentRunService {
 
+    /**
+     * 校验 Debug EML 上传访问口令。流式入口需要在响应开始前完成校验，才能保留标准 HTTP 401。
+     */
+    void validateUploadAccessKey(String accessKey);
+
     /**
      * 上传并处理单封 EML，写入 SourceMessage 后调用 SuperAgent Open API。
      */
@@ -16,4 +22,14 @@ public interface DebugEmlSuperAgentRunService {
             MultipartFile file,
             String hotelId,
             String runLabel);
+
+    /**
+     * 上传并处理单封 EML，按 text/event-stream 实时写出内部阶段、SuperAgent Trace 和最终结果。
+     */
+    void uploadAndRunStream(
+            String accessKey,
+            MultipartFile file,
+            String hotelId,
+            String runLabel,
+            OutputStream outputStream);
 }
diff --git a/server/src/main/java/cn/nianxx/thhotel/platform/debug/service/impl/DebugEmlSuperAgentRunServiceImpl.java b/server/src/main/java/cn/nianxx/thhotel/platform/debug/service/impl/DebugEmlSuperAgentRunServiceImpl.java
index 8c2aa65..aedb4c1 100644
--- a/server/src/main/java/cn/nianxx/thhotel/platform/debug/service/impl/DebugEmlSuperAgentRunServiceImpl.java
+++ b/server/src/main/java/cn/nianxx/thhotel/platform/debug/service/impl/DebugEmlSuperAgentRunServiceImpl.java
@@ -2,6 +2,7 @@ package cn.nianxx.thhotel.platform.debug.service.impl;
 
 import cn.nianxx.thhotel.integrations.ai.superagent.common.request.SuperAgentMailDebugRequest;
 import cn.nianxx.thhotel.integrations.ai.superagent.common.result.SuperAgentOpenApiResult;
+import cn.nianxx.thhotel.integrations.ai.superagent.common.result.SuperAgentOpenApiTraceEvent;
 import cn.nianxx.thhotel.integrations.ai.superagent.service.SuperAgentOpenApiClient;
 import cn.nianxx.thhotel.integrations.ai.superagent.service.impl.SuperAgentOpenApiException;
 import cn.nianxx.thhotel.integrations.storage.aliyunoss.common.request.ObjectStoragePutRequest;
@@ -34,6 +35,8 @@ import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.databind.node.ObjectNode;
+import java.io.IOException;
+import java.io.OutputStream;
 import java.net.SocketTimeoutException;
 import java.net.URLDecoder;
 import java.nio.charset.StandardCharsets;
@@ -48,6 +51,7 @@ import java.util.LinkedHashMap;
 import java.util.List;
 import java.util.Locale;
 import java.util.Map;
+import java.util.function.Consumer;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 import org.springframework.http.HttpStatus;
@@ -106,6 +110,14 @@ public class DebugEmlSuperAgentRunServiceImpl implements DebugEmlSuperAgentRunSe
         this.hotelContextService = hotelContextService;
     }
 
+    /**
+     * 校验 Debug EML 上传访问口令。供 Controller 在流式响应开始前复用，避免错误被写成 SSE 事件后丢失 HTTP 状态。
+     */
+    @Override
+    public void validateUploadAccessKey(String accessKey) {
+        validateAccessKey(accessKey);
+    }
+
     /**
      * 处理单封 Debug EML 上传；第一版只展示 SuperAgent 结果，不创建订单或任务。
      */
@@ -131,7 +143,7 @@ public class DebugEmlSuperAgentRunServiceImpl implements DebugEmlSuperAgentRunSe
                 DebugEmlSuperAgentRunStatus.CREATED.name(),
                 now));
         try {
-            return doUploadAndRun(runId, normalizedHotelId, trimToNull(runLabel), safeFileName, emlBytes, now);
+            return doUploadAndRun(runId, normalizedHotelId, trimToNull(runLabel), safeFileName, emlBytes, now, null);
         } catch (DebugEmlSuperAgentException exception) {
             markFailed(runId, exception.getMessage(), statusForException(exception), nowUtc());
             throw exception;
@@ -166,6 +178,80 @@ public class DebugEmlSuperAgentRunServiceImpl implements DebugEmlSuperAgentRunSe
         }
     }
 
+    /**
+     * 处理单封 Debug EML 上传，并实时输出安全的调试 SSE 事件。
+     */
+    @Override
+    public void uploadAndRunStream(
+            String accessKey,
+            MultipartFile file,
+            String hotelId,
+            String runLabel,
+            OutputStream outputStream) {
+        OutputStreamDebugEmlStreamSink streamSink = new OutputStreamDebugEmlStreamSink(outputStream, objectMapper);
+        Long runId = null;
+        try {
+            validateAccessKey(accessKey);
+            String normalizedHotelId = normalizeHotelId(hotelId);
+            validateFile(file);
+            byte[] emlBytes = readFileBytes(file);
+            String safeFileName = safeFileName(file.getOriginalFilename(), "debug-email.eml");
+            if (!safeFileName.toLowerCase(Locale.ROOT).endsWith(".eml")) {
+                throw new DebugEmlSuperAgentException(HttpStatus.BAD_REQUEST, "INVALID_FILE_TYPE", "只支持上传 .eml 邮件文件。");
+            }
+
+            LocalDateTime now = nowUtc();
+            runId = runRepository.insert(new DebugEmlSuperAgentRunDraft(
+                    normalizedHotelId,
+                    trimToNull(runLabel),
+                    DebugEmlSuperAgentRunStatus.CREATED.name(),
+                    now));
+            DebugEmlSuperAgentRunResult result = doUploadAndRun(
+                    runId,
+                    normalizedHotelId,
+                    trimToNull(runLabel),
+                    safeFileName,
+                    emlBytes,
+                    now,
+                    streamSink);
+            streamSink.result(result);
+            streamSink.done();
+        } catch (DebugEmlSuperAgentException exception) {
+            if (runId != null) {
+                markFailed(runId, exception.getMessage(), statusForException(exception), nowUtc());
+            }
+            streamSink.error(runId, exception.getErrorCode(), exception.getMessage(), statusForException(exception).name());
+        } catch (EmlMessageParseException exception) {
+            if (runId != null) {
+                markFailed(runId, "EML 邮件解析失败。", DebugEmlSuperAgentRunStatus.FAILED, nowUtc());
+            }
+            streamSink.error(runId, "EML_PARSE_FAILED", "EML 邮件解析失败。", DebugEmlSuperAgentRunStatus.FAILED.name());
+        } catch (ObjectStorageException exception) {
+            if (runId != null) {
+                markFailed(runId, "OSS 上传失败。", DebugEmlSuperAgentRunStatus.FAILED, nowUtc());
+            }
+            streamSink.error(runId, "OSS_UPLOAD_FAILED", "OSS 上传失败。", DebugEmlSuperAgentRunStatus.FAILED.name());
+        } catch (SuperAgentOpenApiException exception) {
+            if (runId != null) {
+                markFailed(runId, superAgentFailureSummary(exception), DebugEmlSuperAgentRunStatus.SUPERAGENT_FAILED, nowUtc());
+            }
+            streamSink.error(
+                    runId,
+                    "SUPERAGENT_OPEN_API_FAILED",
+                    "SuperAgent 调用失败。",
+                    DebugEmlSuperAgentRunStatus.SUPERAGENT_FAILED.name());
+        } catch (Exception exception) {
+            if (runId != null) {
+                markFailed(runId, "Debug EML 上传处理失败。", DebugEmlSuperAgentRunStatus.FAILED, nowUtc());
+            }
+            streamSink.error(
+                    runId,
+                    "DEBUG_EML_RUN_FAILED",
+                    "Debug EML 上传处理失败。",
+                    DebugEmlSuperAgentRunStatus.FAILED.name());
+        }
+    }
+
     /**
      * 解析 Debug 上传酒店上下文。第一版可不传 hotel_id，由单酒店系统上下文兜底。
      */
@@ -250,12 +336,14 @@ public class DebugEmlSuperAgentRunServiceImpl implements DebugEmlSuperAgentRunSe
             String runLabel,
             String safeFileName,
             byte[] emlBytes,
-            LocalDateTime createdAt) throws Exception {
+            LocalDateTime createdAt,
+            DebugEmlSuperAgentStreamSink streamSink) throws Exception {
         String sha256 = sha256(emlBytes);
         markStage(
                 runId,
                 DebugEmlSuperAgentRunStatus.PARSING_EML,
-                "阶段：解析 EML 邮件，文件名：" + safeFileName + "，大小：" + emlBytes.length + " bytes。");
+                "阶段：解析 EML 邮件，文件名：" + safeFileName + "，大小：" + emlBytes.length + " bytes。",
+                streamSink);
         ParsedEmlMessage parsed = parseService.parse(emlBytes, safeFileName);
         String originalMessageId = parsed.messageId();
         String originalConversationId = parsed.conversationId();
@@ -267,7 +355,8 @@ public class DebugEmlSuperAgentRunServiceImpl implements DebugEmlSuperAgentRunSe
         markStage(
                 runId,
                 DebugEmlSuperAgentRunStatus.UPLOADING_ORIGINAL_EML,
-                "阶段：上传原始 EML 到 OSS，文件名：" + safeFileName + "，大小：" + emlBytes.length + " bytes。");
+                "阶段：上传原始 EML 到 OSS，文件名：" + safeFileName + "，大小：" + emlBytes.length + " bytes。",
+                streamSink);
         uploadedMedia.add(uploadOriginalEml(runId, safeFileName, emlBytes, createdAt));
         int inlineIndex = 1;
         int attachmentIndex = 1;
@@ -276,13 +365,15 @@ public class DebugEmlSuperAgentRunServiceImpl implements DebugEmlSuperAgentRunSe
                 markStage(
                         runId,
                         DebugEmlSuperAgentRunStatus.UPLOADING_MEDIA,
-                        mediaUploadStageSummary(mediaItem, "inline", inlineIndex));
+                        mediaUploadStageSummary(mediaItem, "inline", inlineIndex),
+                        streamSink);
                 uploadedMedia.add(uploadParsedMedia(runId, createdAt, mediaItem, "inline", inlineIndex++));
             } else {
                 markStage(
                         runId,
                         DebugEmlSuperAgentRunStatus.UPLOADING_MEDIA,
-                        mediaUploadStageSummary(mediaItem, "attachments", attachmentIndex));
+                        mediaUploadStageSummary(mediaItem, "attachments", attachmentIndex),
+                        streamSink);
                 uploadedMedia.add(uploadParsedMedia(runId, createdAt, mediaItem, "attachments", attachmentIndex++));
             }
         }
@@ -290,7 +381,8 @@ public class DebugEmlSuperAgentRunServiceImpl implements DebugEmlSuperAgentRunSe
         markStage(
                 runId,
                 DebugEmlSuperAgentRunStatus.BUILDING_SOURCE_MESSAGE,
-                "阶段：构造 SourceMessage payload。");
+                "阶段：构造 SourceMessage payload。",
+                streamSink);
         String htmlWithOssUrls = replaceCidReferences(parsed.htmlBody(), uploadedMedia, warnings);
         String htmlBodySanitized = htmlSanitizerService.sanitizeHtml(htmlWithOssUrls);
         String htmlRenderMode = htmlSanitizerService.htmlRenderMode(htmlWithOssUrls);
@@ -308,7 +400,8 @@ public class DebugEmlSuperAgentRunServiceImpl implements DebugEmlSuperAgentRunSe
         markStage(
                 runId,
                 DebugEmlSuperAgentRunStatus.CAPTURING_SOURCE_MESSAGE,
-                "阶段：写入 SourceMessage Inbox。");
+                "阶段：写入 SourceMessage Inbox。",
+                streamSink);
         SourceMessageCaptureResult captureResult = sourceMessageCaptureService.capture(new CaptureSourceMessageCommand(
                 hotelId,
                 SOURCE_PROVIDER,
@@ -338,15 +431,29 @@ public class DebugEmlSuperAgentRunServiceImpl implements DebugEmlSuperAgentRunSe
         markStage(
                 runId,
                 DebugEmlSuperAgentRunStatus.CALLING_SUPERAGENT,
-                "阶段：调用 SuperAgent Open API，source_message_id=" + captureResult.inboxId() + "。");
-        SuperAgentOpenApiResult superAgentResult = superAgentOpenApiClient.invokeMailDebug(new SuperAgentMailDebugRequest(
+                "阶段：调用 SuperAgent Open API，source_message_id=" + captureResult.inboxId() + "。",
+                streamSink);
+        SuperAgentMailDebugRequest superAgentRequest = new SuperAgentMailDebugRequest(
                 buildSuperAgentMessage(payloadJson),
                 "debug-eml-" + runId,
                 Map.of(
                         "source", "th-hotel-debug-eml-upload",
                         "debug_run_id", runId.toString(),
                         "source_message_id", captureResult.inboxId().toString(),
-                        "hotel_id", hotelId)));
+                        "hotel_id", hotelId));
+        List<SuperAgentOpenApiTraceEvent> streamedTraceEvents = new ArrayList<>();
+        Consumer<SuperAgentOpenApiTraceEvent> traceConsumer = traceEvent -> {
+            streamedTraceEvents.add(traceEvent);
+            if (streamSink != null) {
+                streamSink.trace(traceEvent);
+            }
+        };
+        SuperAgentOpenApiResult superAgentResult = streamSink == null
+                ? superAgentOpenApiClient.invokeMailDebug(superAgentRequest)
+                : superAgentOpenApiClient.invokeMailDebug(superAgentRequest, traceConsumer);
+        List<SuperAgentOpenApiTraceEvent> traceEvents = streamedTraceEvents.isEmpty()
+                ? superAgentResult.traceEvents()
+                : List.copyOf(streamedTraceEvents);
         JsonNode parsedJson = parseSuperAgentJson(superAgentResult.rawAnswer(), warnings);
         String parsedJsonText = parsedJson == null ? null : objectMapper.writeValueAsString(parsedJson);
         DebugEmlSuperAgentRunStatus status = DebugEmlSuperAgentRunStatus.SUPERAGENT_SUCCEEDED;
@@ -391,6 +498,7 @@ public class DebugEmlSuperAgentRunServiceImpl implements DebugEmlSuperAgentRunSe
                 superAgentResult.runId(),
                 superAgentResult.rawAnswer(),
                 parsedJson,
+                traceEvents,
                 List.copyOf(warnings),
                 status.name());
     }
@@ -693,14 +801,29 @@ public class DebugEmlSuperAgentRunServiceImpl implements DebugEmlSuperAgentRunSe
             Long runId,
             DebugEmlSuperAgentRunStatus status,
             String safeSummary) {
+        markStage(runId, status, safeSummary, null);
+    }
+
+    /**
+     * 标记 Debug 运行中的当前阶段，并在流式调试入口实时输出阶段事件。
+     */
+    private void markStage(
+            Long runId,
+            DebugEmlSuperAgentRunStatus status,
+            String safeSummary,
+            DebugEmlSuperAgentStreamSink streamSink) {
         if (runId == null) {
             return;
         }
+        String truncatedSummary = truncate(safeSummary, 512);
         runRepository.updateStatus(new DebugEmlSuperAgentRunStatusUpdate(
                 runId,
                 status.name(),
-                truncate(safeSummary, 512),
+                truncatedSummary,
                 nowUtc()));
+        if (streamSink != null) {
+            streamSink.stage(runId, status, truncatedSummary);
+        }
     }
 
     /**
@@ -912,6 +1035,106 @@ public class DebugEmlSuperAgentRunServiceImpl implements DebugEmlSuperAgentRunSe
         return LocalDateTime.now(ZoneOffset.UTC);
     }
 
+    /**
+     * Debug EML 流式事件输出端口，避免主流程依赖 HTTP 细节。
+     */
+    private interface DebugEmlSuperAgentStreamSink {
+
+        /**
+         * 输出本系统处理阶段。
+         */
+        void stage(Long runId, DebugEmlSuperAgentRunStatus status, String safeSummary);
+
+        /**
+         * 输出 SuperAgent 公开 Trace 事件。
+         */
+        void trace(SuperAgentOpenApiTraceEvent traceEvent);
+
+        /**
+         * 输出最终 Debug 结果。
+         */
+        void result(DebugEmlSuperAgentRunResult result);
+
+        /**
+         * 输出安全错误事件。
+         */
+        void error(Long runId, String errorCode, String message, String status);
+
+        /**
+         * 输出流结束事件。
+         */
+        void done();
+    }
+
+    /**
+     * 将 Debug EML 事件写成 text/event-stream。
+     */
+    private static final class OutputStreamDebugEmlStreamSink implements DebugEmlSuperAgentStreamSink {
+
+        private final OutputStream outputStream;
+        private final ObjectMapper objectMapper;
+        private boolean active = true;
+
+        private OutputStreamDebugEmlStreamSink(OutputStream outputStream, ObjectMapper objectMapper) {
+            this.outputStream = outputStream;
+            this.objectMapper = objectMapper;
+        }
+
+        @Override
+        public void stage(Long runId, DebugEmlSuperAgentRunStatus status, String safeSummary) {
+            Map<String, Object> data = new LinkedHashMap<>();
+            data.put("debug_run_id", runId == null ? null : runId.toString());
+            data.put("status", status.name());
+            data.put("safe_summary", safeSummary);
+            send("debug_stage", data);
+        }
+
+        @Override
+        public void trace(SuperAgentOpenApiTraceEvent traceEvent) {
+            send("superagent_trace", traceEvent);
+        }
+
+        @Override
+        public void result(DebugEmlSuperAgentRunResult result) {
+            send("superagent_result", result);
+        }
+
+        @Override
+        public void error(Long runId, String errorCode, String message, String status) {
+            Map<String, Object> data = new LinkedHashMap<>();
+            data.put("debug_run_id", runId == null ? null : runId.toString());
+            data.put("error_code", errorCode);
+            data.put("message", message);
+            data.put("status", status);
+            send("debug_error", data);
+            done();
+        }
+
+        @Override
+        public void done() {
+            send("done", Map.of("status", "done"));
+        }
+
+        /**
+         * 写出一个 SSE 事件块并立即 flush。写失败通常表示客户端断开，只关闭流输出，不影响后续业务落库。
+         */
+        private void send(String eventName, Object data) {
+            if (!active) {
+                return;
+            }
+            try {
+                String eventBlock = "event: " + eventName
+                        + "\n"
+                        + "data: " + objectMapper.writeValueAsString(data)
+                        + "\n\n";
+                outputStream.write(eventBlock.getBytes(StandardCharsets.UTF_8));
+                outputStream.flush();
+            } catch (IOException exception) {
+                active = false;
+            }
+        }
+    }
+
     /**
      * 上传媒体内部组合对象。
      */
diff --git a/server/src/test/java/cn/nianxx/thhotel/integrations/ai/superagent/service/impl/SuperAgentOpenApiClientImplTest.java b/server/src/test/java/cn/nianxx/thhotel/integrations/ai/superagent/service/impl/SuperAgentOpenApiClientImplTest.java
new file mode 100644
index 0000000..bb96f19
--- /dev/null
+++ b/server/src/test/java/cn/nianxx/thhotel/integrations/ai/superagent/service/impl/SuperAgentOpenApiClientImplTest.java
@@ -0,0 +1,88 @@
+package cn.nianxx.thhotel.integrations.ai.superagent.service.impl;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+import cn.nianxx.thhotel.integrations.ai.superagent.common.request.SuperAgentMailDebugRequest;
+import cn.nianxx.thhotel.integrations.ai.superagent.common.result.SuperAgentOpenApiResult;
+import cn.nianxx.thhotel.integrations.ai.superagent.common.result.SuperAgentOpenApiTraceEvent;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.sun.net.httpserver.HttpServer;
+import java.io.OutputStream;
+import java.net.InetAddress;
+import java.net.InetSocketAddress;
+import java.nio.charset.StandardCharsets;
+import java.time.Duration;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.atomic.AtomicReference;
+import org.junit.jupiter.api.Test;
+
+class SuperAgentOpenApiClientImplTest {
+
+    @Test
+    void shouldRequestStreamingMessagesWithIncludeTraceAndEmitPublicTraceEvents() throws Exception {
+        HttpServer server = HttpServer.create(new InetSocketAddress(InetAddress.getLoopbackAddress(), 0), 0);
+        AtomicReference<String> streamQuery = new AtomicReference<>();
+        server.createContext("/api/open/agent-sessions", exchange -> {
+            byte[] response = "{\"session_id\":\"session-http-001\"}".getBytes(StandardCharsets.UTF_8);
+            exchange.getResponseHeaders().add("Content-Type", "application/json");
+            exchange.sendResponseHeaders(200, response.length);
+            try (OutputStream outputStream = exchange.getResponseBody()) {
+                outputStream.write(response);
+            }
+        });
+        server.createContext("/api/open/agent-sessions/session-http-001/messages/stream", exchange -> {
+            streamQuery.set(exchange.getRequestURI().getRawQuery());
+            byte[] response = """
+                    event: metadata
+                    data: {"run_id":"run-http-001","resolved_profile_id":"profile-http","resolved_profile_version_id":"version-http"}
+
+                    event: trace
+                    data: {"event":"reasoning.summary","run_id":"run-http-001","text":"正在分析 Debug 邮件。","ts":"2026-07-11T10:00:01Z"}
+
+                    event: values
+                    data: {"messages":[{"type":"ai","content":"{\\"route_code\\":\\"S10\\"}","response_metadata":{"finish_reason":"stop","model_name":"debug-model"},"usage_metadata":{"input_tokens":9,"output_tokens":4,"total_tokens":13}}]}
+
+                    event: end
+                    data: {}
+
+                    """.getBytes(StandardCharsets.UTF_8);
+            exchange.getResponseHeaders().add("Content-Type", "text/event-stream");
+            exchange.sendResponseHeaders(200, response.length);
+            try (OutputStream outputStream = exchange.getResponseBody()) {
+                outputStream.write(response);
+            }
+        });
+        server.start();
+        try {
+            SuperAgentOpenApiProperties properties = new SuperAgentOpenApiProperties();
+            properties.setEnabled(true);
+            properties.setBaseUrl("http://127.0.0.1:" + server.getAddress().getPort());
+            properties.setApiKey("df_open_test");
+            properties.setExternalSubjectId("debug-subject");
+            properties.setConnectTimeout(Duration.ofSeconds(5));
+            properties.setReadTimeout(Duration.ofSeconds(5));
+            SuperAgentOpenApiClientImpl client = new SuperAgentOpenApiClientImpl(
+                    properties,
+                    new SuperAgentOpenApiSseParser(new ObjectMapper()),
+                    new ObjectMapper());
+            List<SuperAgentOpenApiTraceEvent> traceEvents = new ArrayList<>();
+
+            SuperAgentOpenApiResult result = client.invokeMailDebug(new SuperAgentMailDebugRequest(
+                    "debug message",
+                    "debug-idempotency",
+                    Map.of("source", "unit-test")), traceEvents::add);
+
+            assertThat(streamQuery.get()).isEqualTo("include_trace=true");
+            assertThat(result.sessionId()).isEqualTo("session-http-001");
+            assertThat(result.runId()).isEqualTo("run-http-001");
+            assertThat(result.traceEvents()).hasSize(1);
+            assertThat(traceEvents).hasSize(1);
+            assertThat(traceEvents.get(0).event()).isEqualTo("reasoning.summary");
+            assertThat(traceEvents.get(0).text()).isEqualTo("正在分析 Debug 邮件。");
+        } finally {
+            server.stop(0);
+        }
+    }
+}
diff --git a/server/src/test/java/cn/nianxx/thhotel/integrations/ai/superagent/service/impl/SuperAgentOpenApiSseParserTest.java b/server/src/test/java/cn/nianxx/thhotel/integrations/ai/superagent/service/impl/SuperAgentOpenApiSseParserTest.java
index 1403839..d833e1e 100644
--- a/server/src/test/java/cn/nianxx/thhotel/integrations/ai/superagent/service/impl/SuperAgentOpenApiSseParserTest.java
+++ b/server/src/test/java/cn/nianxx/thhotel/integrations/ai/superagent/service/impl/SuperAgentOpenApiSseParserTest.java
@@ -4,6 +4,9 @@ import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.Assertions.assertThatThrownBy;
 
 import cn.nianxx.thhotel.integrations.ai.superagent.common.result.SuperAgentOpenApiResult;
+import cn.nianxx.thhotel.integrations.ai.superagent.common.result.SuperAgentOpenApiTraceEvent;
+import java.util.ArrayList;
+import java.util.List;
 import org.junit.jupiter.api.Test;
 
 class SuperAgentOpenApiSseParserTest {
@@ -164,4 +167,41 @@ class SuperAgentOpenApiSseParserTest {
 
         assertThat(result.rawAnswer()).isEqualTo("{\"ai_task_results\":[{\"task_type\":\"Cancel Booking\"}]}");
     }
+
+    @Test
+    void shouldCollectPublicTraceEventsAndKeepFinalAnswer() {
+        String sse = """
+                event: metadata
+                data: {"run_id":"run-debug-trace","resolved_profile_id":"profile-debug"}
+
+                event: trace
+                data: {"event":"reasoning.summary","run_id":"run-debug-trace","text":"正在分析邮件和附件。","ts":"2026-07-11T10:00:01Z"}
+
+                event: trace
+                data: {"event":"tool.call.started","run_id":"run-debug-trace","message_id":"ai-1","tool_calls":[{"tool_call_id":"tool-1","name":"th_hotel_query_case_context","input":{"summary":"{\\"group_code\\":\\"G001\\"}"}}],"ts":"2026-07-11T10:00:02Z"}
+
+                event: trace
+                data: {"event":"tool.call.completed","run_id":"run-debug-trace","tool_call_id":"tool-1","name":"th_hotel_query_case_context","output":{"summary":"matched 1 case"},"ts":"2026-07-11T10:00:03Z"}
+
+                event: values
+                data: {"messages":[{"type":"ai","content":"{\\"route_code\\":\\"S10\\"}","response_metadata":{"finish_reason":"stop","model_name":"debug-model"},"usage_metadata":{"input_tokens":31,"output_tokens":5,"total_tokens":36}}]}
+
+                event: end
+                data: {}
+
+                """;
+        List<SuperAgentOpenApiTraceEvent> emittedTraceEvents = new ArrayList<>();
+
+        SuperAgentOpenApiResult result = parser.parse("session-debug-trace", sse, emittedTraceEvents::add);
+
+        assertThat(result.rawAnswer()).isEqualTo("{\"route_code\":\"S10\"}");
+        assertThat(result.eventTypes()).containsExactly("metadata", "trace", "values", "end");
+        assertThat(result.traceEvents()).hasSize(3);
+        assertThat(emittedTraceEvents).hasSize(3);
+        assertThat(result.traceEvents().get(0).event()).isEqualTo("reasoning.summary");
+        assertThat(result.traceEvents().get(0).text()).isEqualTo("正在分析邮件和附件。");
+        assertThat(result.traceEvents().get(1).toolName()).isEqualTo("th_hotel_query_case_context");
+        assertThat(result.traceEvents().get(1).inputSummary()).isEqualTo("{\"group_code\":\"G001\"}");
+        assertThat(result.traceEvents().get(2).outputSummary()).isEqualTo("matched 1 case");
+    }
 }
diff --git a/server/src/test/java/cn/nianxx/thhotel/platform/debug/control/DebugEmlSuperAgentControllerTest.java b/server/src/test/java/cn/nianxx/thhotel/platform/debug/control/DebugEmlSuperAgentControllerTest.java
index cbeaeca..4ebb6aa 100644
--- a/server/src/test/java/cn/nianxx/thhotel/platform/debug/control/DebugEmlSuperAgentControllerTest.java
+++ b/server/src/test/java/cn/nianxx/thhotel/platform/debug/control/DebugEmlSuperAgentControllerTest.java
@@ -7,20 +7,27 @@ import static org.hamcrest.Matchers.not;
 import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.Mockito.reset;
 import static org.mockito.Mockito.when;
+import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.asyncDispatch;
 import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.multipart;
 import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.content;
 import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.jsonPath;
+import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.request;
 import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.status;
 
 import cn.nianxx.thhotel.ThHotelApplication;
 import cn.nianxx.thhotel.integrations.ai.superagent.common.result.SuperAgentOpenApiResult;
+import cn.nianxx.thhotel.integrations.ai.superagent.common.result.SuperAgentOpenApiTraceEvent;
 import cn.nianxx.thhotel.integrations.ai.superagent.service.SuperAgentOpenApiClient;
 import cn.nianxx.thhotel.integrations.ai.superagent.service.impl.SuperAgentOpenApiException;
 import cn.nianxx.thhotel.integrations.storage.aliyunoss.common.request.ObjectStoragePutRequest;
 import cn.nianxx.thhotel.integrations.storage.aliyunoss.common.result.ObjectStoragePutResult;
 import cn.nianxx.thhotel.integrations.storage.aliyunoss.service.ObjectStorageService;
+import cn.nianxx.thhotel.platform.debug.service.DebugEmlSuperAgentRunService;
+import java.io.IOException;
+import java.io.OutputStream;
 import java.nio.charset.StandardCharsets;
 import java.util.List;
+import java.util.function.Consumer;
 import java.util.concurrent.atomic.AtomicInteger;
 import org.junit.jupiter.api.Test;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -32,6 +39,7 @@ import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.mock.web.MockMultipartFile;
 import org.springframework.test.context.ActiveProfiles;
 import org.springframework.test.web.servlet.MockMvc;
+import org.springframework.test.web.servlet.MvcResult;
 import org.springframework.web.client.RestClientResponseException;
 
 @SpringBootTest(
@@ -56,6 +64,9 @@ class DebugEmlSuperAgentControllerTest {
     @Autowired
     private JdbcTemplate jdbcTemplate;
 
+    @Autowired
+    private DebugEmlSuperAgentRunService runService;
+
     @MockBean
     private ObjectStorageService objectStorageService;
 
@@ -71,6 +82,17 @@ class DebugEmlSuperAgentControllerTest {
                 .andExpect(content().string(not(containsString("test-debug-upload-key"))));
     }
 
+    @Test
+    void shouldRejectStreamUploadWhenDebugKeyMissingBeforeStartingSse() throws Exception {
+        mockMvc.perform(multipart(ENDPOINT + "/stream")
+                        .file(emlFile())
+                        .param("hotel_id", "HOTEL-TEST"))
+                .andExpect(status().isUnauthorized())
+                .andExpect(content().contentTypeCompatibleWith(MediaType.APPLICATION_JSON))
+                .andExpect(jsonPath("$.error_code").value("DEBUG_UPLOAD_KEY_INVALID"))
+                .andExpect(content().string(not(containsString("test-debug-upload-key"))));
+    }
+
     @Test
     void shouldUploadEmlToOssCaptureSourceMessageAndReturnSuperAgentResult() throws Exception {
         when(objectStorageService.putObject(any())).thenAnswer(invocation -> {
@@ -158,6 +180,139 @@ class DebugEmlSuperAgentControllerTest {
         org.assertj.core.api.Assertions.assertThat(debugRunCount).isEqualTo(1L);
     }
 
+    @Test
+    void shouldStreamDebugStagesSuperAgentTraceAndFinalResult() throws Exception {
+        when(objectStorageService.putObject(any())).thenAnswer(invocation -> {
+            ObjectStoragePutRequest request = invocation.getArgument(0);
+            return new ObjectStoragePutResult(
+                    request.objectKey(),
+                    "https://oss.example.test/" + request.objectKey(),
+                    request.contentType(),
+                    request.sizeBytes());
+        });
+        when(superAgentOpenApiClient.invokeMailDebug(any(), any())).thenAnswer(invocation -> {
+            @SuppressWarnings("unchecked")
+            Consumer<SuperAgentOpenApiTraceEvent> traceConsumer = invocation.getArgument(1);
+            traceConsumer.accept(new SuperAgentOpenApiTraceEvent(
+                    "reasoning.summary",
+                    "run-stream-001",
+                    null,
+                    null,
+                    null,
+                    "正在分析 Debug 邮件。",
+                    null,
+                    null,
+                    null,
+                    "2026-07-11T10:00:01Z"));
+            traceConsumer.accept(new SuperAgentOpenApiTraceEvent(
+                    "tool.call.started",
+                    "run-stream-001",
+                    "ai-1",
+                    "tool-1",
+                    "th_hotel_query_case_context",
+                    null,
+                    "{\"group_code\":\"G001\"}",
+                    null,
+                    null,
+                    "2026-07-11T10:00:02Z"));
+            return new SuperAgentOpenApiResult(
+                    "session-stream-001",
+                    "run-stream-001",
+                    "profile-debug",
+                    "profile-version-debug",
+                    "debug-model",
+                    "{\"route_code\":\"S10\"}",
+                    11,
+                    7,
+                    18,
+                    List.of("metadata", "trace", "values", "end"),
+                    List.of());
+        });
+
+        MvcResult mvcResult = mockMvc.perform(multipart(ENDPOINT + "/stream")
+                        .file(emlFile())
+                        .param("hotel_id", "HOTEL-TEST")
+                        .param("run_label", "stream-debug-upload")
+                        .header("X-TH-Hotel-Debug-Upload-Key", "test-debug-upload-key"))
+                .andExpect(request().asyncStarted())
+                .andReturn();
+
+        mockMvc.perform(asyncDispatch(mvcResult))
+                .andExpect(status().isOk())
+                .andExpect(content().contentTypeCompatibleWith(MediaType.TEXT_EVENT_STREAM))
+                .andExpect(content().string(containsString("event: debug_stage")))
+                .andExpect(content().string(containsString("\"status\":\"PARSING_EML\"")))
+                .andExpect(content().string(containsString("\"status\":\"CALLING_SUPERAGENT\"")))
+                .andExpect(content().string(containsString("event: superagent_trace")))
+                .andExpect(content().string(containsString("\"event\":\"reasoning.summary\"")))
+                .andExpect(content().string(containsString("\"event\":\"tool.call.started\"")))
+                .andExpect(content().string(containsString("\"tool_name\":\"th_hotel_query_case_context\"")))
+                .andExpect(content().string(containsString("event: superagent_result")))
+                .andExpect(content().string(containsString("\"superagent_run_id\":\"run-stream-001\"")))
+                .andExpect(content().string(containsString("\"superagent_parsed_json\":{\"route_code\":\"S10\"}")))
+                .andExpect(content().string(containsString("event: done")))
+                .andExpect(content().string(not(containsString("test-debug-upload-key"))));
+    }
+
+    @Test
+    void shouldKeepBusinessRunStatusWhenSseClientDisconnects() {
+        when(objectStorageService.putObject(any())).thenAnswer(invocation -> {
+            ObjectStoragePutRequest request = invocation.getArgument(0);
+            return new ObjectStoragePutResult(
+                    request.objectKey(),
+                    "https://oss.example.test/" + request.objectKey(),
+                    request.contentType(),
+                    request.sizeBytes());
+        });
+        when(superAgentOpenApiClient.invokeMailDebug(any(), any())).thenAnswer(invocation -> {
+            @SuppressWarnings("unchecked")
+            Consumer<SuperAgentOpenApiTraceEvent> traceConsumer = invocation.getArgument(1);
+            traceConsumer.accept(new SuperAgentOpenApiTraceEvent(
+                    "reasoning.summary",
+                    "run-stream-disconnect",
+                    null,
+                    null,
+                    null,
+                    "正在分析 Debug 邮件。",
+                    null,
+                    null,
+                    null,
+                    "2026-07-11T10:00:01Z"));
+            return new SuperAgentOpenApiResult(
+                    "session-stream-disconnect",
+                    "run-stream-disconnect",
+                    "profile-debug",
+                    "profile-version-debug",
+                    "debug-model",
+                    "{\"route_code\":\"S10\"}",
+                    11,
+                    7,
+                    18,
+                    List.of("metadata", "trace", "values", "end"),
+                    List.of());
+        });
+
+        org.assertj.core.api.Assertions.assertThatCode(() -> runService.uploadAndRunStream(
+                        "test-debug-upload-key",
+                        emlFile(),
+                        "HOTEL-TEST",
+                        "stream-client-disconnected",
+                        new FailingOutputStream()))
+                .doesNotThrowAnyException();
+
+        Long debugRunCount = jdbcTemplate.queryForObject("""
+                SELECT COUNT(*)
+                FROM platform_debug_eml_superagent_run
+                WHERE hotel_id = 'HOTEL-TEST'
+                  AND run_status = 'SUPERAGENT_SUCCEEDED'
+                  AND superagent_session_id = 'session-stream-disconnect'
+                  AND superagent_run_id = 'run-stream-disconnect'
+                  AND run_label = 'stream-client-disconnected'
+                  AND safe_error_summary IS NULL
+                """, Long.class);
+        org.assertj.core.api.Assertions.assertThat(debugRunCount).isEqualTo(1L);
+    }
+
     @Test
     void shouldRecordPhaseBeforeUploadingOriginalEmlToOss() throws Exception {
         AtomicInteger uploadIndex = new AtomicInteger();
@@ -408,6 +563,19 @@ class DebugEmlSuperAgentControllerTest {
                 unsafeHtmlEmlBytes());
     }
 
+    private static final class FailingOutputStream extends OutputStream {
+
+        @Override
+        public void write(int b) throws IOException {
+            throw new IOException("client disconnected");
+        }
+
+        @Override
+        public void write(byte[] b, int off, int len) throws IOException {
+            throw new IOException("client disconnected");
+        }
+    }
+
     private byte[] emlBytes() {
         return """
                 From: Guest <guest@example.test>