From 05d231695c248634477f2d161cb7c59f06e3ca2d Mon Sep 17 00:00:00 2001
From: mac <mac@mac11MacBook-Pro.local>
Date: Fri, 31 Jul 2026 18:59:00 +0800
Subject: [PATCH 1/2] feat(frontend): add voice assistant flows

---
 .../components/AssistantChatSheet.test.tsx    |  77 ++++++
 .../components/AssistantDock.test.tsx         |  31 +++
 .../components/AssistantDraftCard.test.tsx    |  49 ++++
 .../components/TempoAssistantIcon.test.tsx    |  13 +
 .../components/VoiceHoldButton.test.tsx       |  71 +++++
 .../hooks/useAssistantSession.test.tsx        | 250 +++++++++++++++++
 .../components/AssistantChatSheet.styles.ts   |  95 +++++++
 .../components/AssistantChatSheet.tsx         | 133 +++++++++
 .../components/AssistantDock.styles.ts        |  20 ++
 .../assistant/components/AssistantDock.tsx    |  32 +++
 .../components/AssistantDraftCard.styles.ts   | 134 +++++++++
 .../components/AssistantDraftCard.tsx         |  93 +++++++
 .../components/TempoAssistantIcon.tsx         |  24 ++
 .../components/VoiceHoldButton.styles.ts      |  54 ++++
 .../assistant/components/VoiceHoldButton.tsx  | 177 ++++++++++++
 .../assistant/data/VoiceStreamPort.ts         | 154 +++++++++++
 .../assistant/hooks/useAssistantSession.ts    | 256 ++++++++++++++++++
 frontend/src/features/assistant/index.ts      |   5 +
 frontend/src/features/assistant/types.ts      |  31 +++
 19 files changed, 1699 insertions(+)
 create mode 100644 frontend/__tests__/features/assistant/components/AssistantChatSheet.test.tsx
 create mode 100644 frontend/__tests__/features/assistant/components/AssistantDock.test.tsx
 create mode 100644 frontend/__tests__/features/assistant/components/AssistantDraftCard.test.tsx
 create mode 100644 frontend/__tests__/features/assistant/components/TempoAssistantIcon.test.tsx
 create mode 100644 frontend/__tests__/features/assistant/components/VoiceHoldButton.test.tsx
 create mode 100644 frontend/__tests__/features/assistant/hooks/useAssistantSession.test.tsx
 create mode 100644 frontend/src/features/assistant/components/AssistantChatSheet.styles.ts
 create mode 100644 frontend/src/features/assistant/components/AssistantChatSheet.tsx
 create mode 100644 frontend/src/features/assistant/components/AssistantDock.styles.ts
 create mode 100644 frontend/src/features/assistant/components/AssistantDock.tsx
 create mode 100644 frontend/src/features/assistant/components/AssistantDraftCard.styles.ts
 create mode 100644 frontend/src/features/assistant/components/AssistantDraftCard.tsx
 create mode 100644 frontend/src/features/assistant/components/TempoAssistantIcon.tsx
 create mode 100644 frontend/src/features/assistant/components/VoiceHoldButton.styles.ts
 create mode 100644 frontend/src/features/assistant/components/VoiceHoldButton.tsx
 create mode 100644 frontend/src/features/assistant/data/VoiceStreamPort.ts
 create mode 100644 frontend/src/features/assistant/hooks/useAssistantSession.ts
 create mode 100644 frontend/src/features/assistant/index.ts
 create mode 100644 frontend/src/features/assistant/types.ts

diff --git a/frontend/__tests__/features/assistant/components/AssistantChatSheet.test.tsx b/frontend/__tests__/features/assistant/components/AssistantChatSheet.test.tsx
new file mode 100644
index 0000000..50ae6d7
--- /dev/null
+++ b/frontend/__tests__/features/assistant/components/AssistantChatSheet.test.tsx
@@ -0,0 +1,77 @@
+import { describe, expect, it, jest } from '@jest/globals';
+import { fireEvent, render, screen } from '@testing-library/react-native';
+
+import { AssistantChatSheet } from '@/features/assistant/components/AssistantChatSheet';
+
+describe('AssistantChatSheet', () => {
+  it('shows empty state and closes', () => {
+    const onClose = jest.fn();
+    render(
+      <AssistantChatSheet
+        messages={[]}
+        onAction={jest.fn()}
+        onClose={onClose}
+        onVoiceEnd={jest.fn()}
+        visible
+      />,
+    );
+    expect(screen.getByText('等你说第一句话')).toBeTruthy();
+    fireEvent.press(screen.getAllByLabelText('关闭语音助手')[0]!);
+    expect(onClose).toHaveBeenCalled();
+  });
+
+  it('renders user, draft and assistant messages', () => {
+    const onAction = jest.fn();
+    render(
+      <AssistantChatSheet
+        visible
+        onAction={onAction}
+        onClose={jest.fn()}
+        onVoiceEnd={jest.fn()}
+        messages={[
+          { id: 'u1', role: 'user', createdAt: 1, text: '明天下午开会' },
+          {
+            id: 'd1',
+            role: 'assistant',
+            createdAt: 2,
+            draft: { title: '开会', whenLabel: '明天 15:00', state: 'pending' },
+            actions: [{ id: 'ok', kind: 'confirm', label: '加入' }],
+          },
+          { id: 'a1', role: 'assistant', createdAt: 3, text: '已记下' },
+        ]}
+      />,
+    );
+    expect(screen.getByText('明天下午开会')).toBeTruthy();
+    expect(screen.getByText('开会')).toBeTruthy();
+    expect(screen.getByText('已记下')).toBeTruthy();
+    fireEvent.press(screen.getByLabelText('加入'));
+    expect(onAction).toHaveBeenCalledWith('d1', { id: 'ok', kind: 'confirm', label: '加入' });
+  });
+
+  it('hides when not visible', () => {
+    render(
+      <AssistantChatSheet
+        messages={[]}
+        onAction={jest.fn()}
+        onClose={jest.fn()}
+        onVoiceEnd={jest.fn()}
+        visible={false}
+      />,
+    );
+    expect(screen.queryByText('语音助手')).toBeNull();
+  });
+
+  it('shows a processing state after recording is released', () => {
+    render(
+      <AssistantChatSheet
+        isProcessing
+        messages={[]}
+        onAction={jest.fn()}
+        onClose={jest.fn()}
+        onVoiceEnd={jest.fn()}
+        visible
+      />,
+    );
+    expect(screen.getByText('正在整理录音…')).toBeTruthy();
+  });
+});
diff --git a/frontend/__tests__/features/assistant/components/AssistantDock.test.tsx b/frontend/__tests__/features/assistant/components/AssistantDock.test.tsx
new file mode 100644
index 0000000..553fe6c
--- /dev/null
+++ b/frontend/__tests__/features/assistant/components/AssistantDock.test.tsx
@@ -0,0 +1,31 @@
+import { describe, expect, it, jest } from '@jest/globals';
+import { fireEvent, render, screen } from '@testing-library/react-native';
+
+import { AssistantDock } from '@/features/assistant/components/AssistantDock';
+
+jest.mock('@/features/assistant/components/VoiceHoldButton', () => ({
+  VoiceHoldButton: ({ onPress }: { onPress?: () => void }) => {
+    const { Pressable, Text } = require('react-native');
+    return (
+      <Pressable accessibilityLabel="mock-open-assistant" onPress={onPress}>
+        <Text>voice-hold</Text>
+      </Pressable>
+    );
+  },
+}));
+
+describe('AssistantDock', () => {
+  it('hides when requested', () => {
+    const { queryByText } = render(
+      <AssistantDock hidden onOpen={jest.fn()} onVoiceEnd={jest.fn()} />,
+    );
+    expect(queryByText('voice-hold')).toBeNull();
+  });
+
+  it('shows the voice control when visible', () => {
+    const onOpen = jest.fn();
+    render(<AssistantDock onOpen={onOpen} onVoiceEnd={jest.fn()} />);
+    fireEvent.press(screen.getByLabelText('mock-open-assistant'));
+    expect(onOpen).toHaveBeenCalledTimes(1);
+  });
+});
diff --git a/frontend/__tests__/features/assistant/components/AssistantDraftCard.test.tsx b/frontend/__tests__/features/assistant/components/AssistantDraftCard.test.tsx
new file mode 100644
index 0000000..cac1725
--- /dev/null
+++ b/frontend/__tests__/features/assistant/components/AssistantDraftCard.test.tsx
@@ -0,0 +1,49 @@
+import { describe, expect, it, jest } from '@jest/globals';
+import { fireEvent, render, screen } from '@testing-library/react-native';
+
+import type { AssistantDraft } from '@/features/assistant/types';
+import { AssistantDraftCard } from '@/features/assistant/components/AssistantDraftCard';
+
+const draft = (overrides: Partial<AssistantDraft> = {}): AssistantDraft => ({
+  title: '下午评审',
+  whenLabel: '今天 15:00',
+  state: 'pending',
+  ...overrides,
+});
+
+describe('AssistantDraftCard', () => {
+  it('shows actions while pending', () => {
+    const onAction = jest.fn();
+    render(
+      <AssistantDraftCard
+        draft={draft({ metaLabel: '会议室 A' })}
+        actions={[
+          { id: 'ok', kind: 'confirm', label: '加入' },
+          { id: 'no', kind: 'dismiss', label: '忽略' },
+        ]}
+        onAction={onAction}
+      />,
+    );
+    expect(screen.getByText('待确认')).toBeTruthy();
+    expect(screen.getByText('会议室 A')).toBeTruthy();
+    fireEvent.press(screen.getByLabelText('加入'));
+    expect(onAction).toHaveBeenCalledWith({ id: 'ok', kind: 'confirm', label: '加入' });
+  });
+
+  it('hides actions after the draft is resolved', () => {
+    render(
+      <AssistantDraftCard
+        draft={draft({ state: 'added' })}
+        actions={[{ id: 'ok', kind: 'confirm', label: '加入' }]}
+        onAction={jest.fn()}
+      />,
+    );
+    expect(screen.getByText('已加入日程')).toBeTruthy();
+    expect(screen.queryByLabelText('加入')).toBeNull();
+  });
+
+  it('renders dismissed chip', () => {
+    render(<AssistantDraftCard draft={draft({ state: 'dismissed' })} onAction={jest.fn()} />);
+    expect(screen.getByText('已忽略')).toBeTruthy();
+  });
+});
diff --git a/frontend/__tests__/features/assistant/components/TempoAssistantIcon.test.tsx b/frontend/__tests__/features/assistant/components/TempoAssistantIcon.test.tsx
new file mode 100644
index 0000000..09d2059
--- /dev/null
+++ b/frontend/__tests__/features/assistant/components/TempoAssistantIcon.test.tsx
@@ -0,0 +1,13 @@
+import { describe, expect, it } from '@jest/globals';
+import { render } from '@testing-library/react-native';
+
+import { TempoAssistantIcon } from '@/features/assistant/components/TempoAssistantIcon';
+
+describe('TempoAssistantIcon', () => {
+  it('renders with default and custom props', () => {
+    const { rerender, toJSON } = render(<TempoAssistantIcon />);
+    expect(toJSON()).toBeTruthy();
+    rerender(<TempoAssistantIcon color="#15352B" size={30} />);
+    expect(toJSON()).toBeTruthy();
+  });
+});
diff --git a/frontend/__tests__/features/assistant/components/VoiceHoldButton.test.tsx b/frontend/__tests__/features/assistant/components/VoiceHoldButton.test.tsx
new file mode 100644
index 0000000..2da8f4f
--- /dev/null
+++ b/frontend/__tests__/features/assistant/components/VoiceHoldButton.test.tsx
@@ -0,0 +1,71 @@
+import { describe, expect, it, jest } from '@jest/globals';
+import { fireEvent, render, screen } from '@testing-library/react-native';
+import { Vibration } from 'react-native';
+
+import { VoiceHoldButton } from '@/features/assistant/components/VoiceHoldButton';
+
+describe('VoiceHoldButton', () => {
+  it('renders the hold-to-talk control', () => {
+    render(<VoiceHoldButton onVoiceEnd={jest.fn()} onVoiceStart={jest.fn()} />);
+  });
+
+  it('opens the assistant on a tap without starting or ending audio', () => {
+    const onPress = jest.fn();
+    const onVoiceStart = jest.fn();
+    const onVoiceEnd = jest.fn();
+    render(
+      <VoiceHoldButton onPress={onPress} onVoiceEnd={onVoiceEnd} onVoiceStart={onVoiceStart} />,
+    );
+
+    fireEvent.press(screen.getByLabelText('轻点打开语音助手，按住说话，上滑取消'));
+
+    expect(onPress).toHaveBeenCalledTimes(1);
+    expect(onVoiceStart).not.toHaveBeenCalled();
+    expect(onVoiceEnd).not.toHaveBeenCalled();
+  });
+
+  it('starts on long press and ends when released', () => {
+    const vibrate = jest.spyOn(Vibration, 'vibrate').mockImplementation(() => undefined);
+    const onPress = jest.fn();
+    const onVoiceStart = jest.fn();
+    const onVoiceEnd = jest.fn();
+    render(
+      <VoiceHoldButton onPress={onPress} onVoiceEnd={onVoiceEnd} onVoiceStart={onVoiceStart} />,
+    );
+    const button = screen.getByLabelText('轻点打开语音助手，按住说话，上滑取消');
+    const event = { nativeEvent: { pageY: 200 } };
+
+    fireEvent(button, 'pressIn', event);
+    fireEvent(button, 'longPress', event);
+    fireEvent(button, 'pressOut', event);
+
+    expect(onVoiceStart).toHaveBeenCalledTimes(1);
+    expect(onVoiceEnd).toHaveBeenCalledTimes(1);
+    expect(onPress).not.toHaveBeenCalled();
+    expect(vibrate).toHaveBeenCalledTimes(1);
+    vibrate.mockRestore();
+  });
+
+  it('cancels a long press moved upward before release', () => {
+    const vibrate = jest.spyOn(Vibration, 'vibrate').mockImplementation(() => undefined);
+    const onVoiceCancel = jest.fn();
+    render(
+      <VoiceHoldButton
+        onVoiceCancel={onVoiceCancel}
+        onVoiceEnd={jest.fn()}
+        onVoiceStart={jest.fn()}
+      />,
+    );
+    const button = screen.getByLabelText('按住说话，松开发送，上滑取消');
+
+    fireEvent(button, 'pressIn', { nativeEvent: { pageY: 200 } });
+    fireEvent(button, 'longPress', { nativeEvent: { pageY: 200 } });
+    fireEvent(button, 'touchMove', { nativeEvent: { pageY: 100 } });
+    fireEvent(button, 'touchMove', { nativeEvent: { pageY: 90 } });
+    fireEvent(button, 'pressOut', { nativeEvent: { pageY: 100 } });
+
+    expect(onVoiceCancel).toHaveBeenCalledTimes(1);
+    expect(vibrate).toHaveBeenCalledTimes(2);
+    vibrate.mockRestore();
+  });
+});
diff --git a/frontend/__tests__/features/assistant/hooks/useAssistantSession.test.tsx b/frontend/__tests__/features/assistant/hooks/useAssistantSession.test.tsx
new file mode 100644
index 0000000..361c4dd
--- /dev/null
+++ b/frontend/__tests__/features/assistant/hooks/useAssistantSession.test.tsx
@@ -0,0 +1,250 @@
+import { describe, expect, it, jest } from '@jest/globals';
+import { act, renderHook } from '@testing-library/react-native';
+
+import type { WsJsonMessage } from '@/contracts';
+import type { VoiceRecorder, VoiceTransport } from '@/features/assistant/data/VoiceStreamPort';
+import { useAssistantSession } from '@/features/assistant/hooks/useAssistantSession';
+
+function createVoiceTransport(options: {
+  missingFields?: string[];
+  ambiguousFields?: string[];
+  startGate?: Promise<void>;
+}): VoiceTransport {
+  const listeners = new Set<(message: WsJsonMessage | ArrayBuffer) => void>();
+  let resultRequestId = '';
+
+  return {
+    onMessage(listener) {
+      listeners.add(listener);
+      return () => listeners.delete(listener);
+    },
+    async request<T extends WsJsonMessage>(message: WsJsonMessage & { request_id: string }) {
+      if (message.type === 'voice.stream.start') {
+        await options.startGate;
+        resultRequestId = message.request_id;
+        return {
+          type: 'voice.stream.started',
+          request_id: message.request_id,
+          ok: true,
+          payload: { stream_id: 'stream_1', job_id: 'job_1' },
+        } as unknown as T;
+      }
+      if (message.type === 'voice.stream.end') {
+        const parseResult: WsJsonMessage = {
+          type: 'voice.parse.result',
+          request_id: resultRequestId,
+          job_id: 'job_1',
+          status: 'ready_for_confirmation',
+          draft: {
+            schedule_type: 'time',
+            title: '语音日程',
+            start_time: null,
+          },
+          missing_fields: options.missingFields ?? [],
+          ambiguous_fields: options.ambiguousFields ?? [],
+          needs_confirmation: true,
+        };
+        for (const listener of listeners) listener(parseResult);
+        return {
+          type: 'voice.stream.ended',
+          request_id: message.request_id,
+          ok: true,
+          payload: { stream_id: 'stream_1', job_id: 'job_1', status: 'processing' },
+        } as unknown as T;
+      }
+      return {
+        type: 'voice.stream.cancelled',
+        request_id: message.request_id,
+        ok: true,
+        payload: { stream_id: 'stream_1' },
+      } as unknown as T;
+    },
+    sendBinary() {},
+  };
+}
+
+const recorder: VoiceRecorder = {
+  async start(onChunk) {
+    onChunk(new ArrayBuffer(2));
+  },
+  async stop() {},
+  async cancel() {},
+};
+
+describe('useAssistantSession', () => {
+  it('keeps incomplete parse metadata and does not offer direct confirmation', async () => {
+    const onConfirmDraft = jest.fn(async () => undefined);
+    const { result } = renderHook(() =>
+      useAssistantSession({
+        client: createVoiceTransport({
+          missingFields: ['start_time'],
+          ambiguousFields: ['title'],
+        }),
+        onConfirmDraft,
+        recorder,
+      }),
+    );
+
+    await act(async () => {
+      await result.current.handleVoiceStart();
+    });
+    await act(async () => {
+      await result.current.handleVoiceEnd();
+    });
+
+    const message = result.current.messages[0];
+    expect(message?.draft?.clarificationLabel).toBe('需要补充：开始时间；需要确认：标题');
+    expect(message?.actions?.map((action) => action.kind)).toEqual(['dismiss']);
+    expect(onConfirmDraft).not.toHaveBeenCalled();
+  });
+
+  it('offers confirmation when the parsed draft is complete', async () => {
+    const onConfirmDraft = jest.fn(async () => undefined);
+    const { result } = renderHook(() =>
+      useAssistantSession({
+        client: createVoiceTransport({}),
+        onConfirmDraft,
+        recorder,
+      }),
+    );
+
+    await act(async () => {
+      await result.current.handleVoiceStart();
+    });
+    await act(async () => {
+      await result.current.handleVoiceEnd();
+    });
+
+    const message = result.current.messages[0];
+    const confirm = message?.actions?.find((action) => action.kind === 'confirm');
+    expect(confirm).toBeDefined();
+
+    await act(async () => {
+      await result.current.handleAction(message!.id, confirm!);
+    });
+    expect(onConfirmDraft).toHaveBeenCalledTimes(1);
+    expect(result.current.messages[0]?.draft?.state).toBe('added');
+  });
+
+  it('waits for an in-flight start when the user releases immediately', async () => {
+    let releaseStart: () => void = () => undefined;
+    const startGate = new Promise<void>((resolve) => {
+      releaseStart = resolve;
+    });
+    const { result } = renderHook(() =>
+      useAssistantSession({
+        client: createVoiceTransport({ startGate }),
+        onConfirmDraft: async () => undefined,
+        recorder,
+      }),
+    );
+
+    let starting!: Promise<void>;
+    let ending!: Promise<void>;
+    act(() => {
+      starting = result.current.handleVoiceStart();
+      ending = result.current.handleVoiceEnd();
+    });
+
+    await act(async () => {
+      releaseStart();
+      await Promise.all([starting, ending]);
+    });
+
+    expect(result.current.messages).toHaveLength(1);
+    expect(result.current.messages[0]?.draft?.title).toBe('语音日程');
+  });
+
+  it('reports processing while waiting for the final parse result', async () => {
+    let releaseEnd: () => void = () => undefined;
+    const listeners = new Set<(message: WsJsonMessage | ArrayBuffer) => void>();
+    let startRequestId = '';
+    const client: VoiceTransport = {
+      onMessage(listener) {
+        listeners.add(listener);
+        return () => listeners.delete(listener);
+      },
+      async request<T extends WsJsonMessage>(message: WsJsonMessage & { request_id: string }) {
+        if (message.type === 'voice.stream.start') {
+          startRequestId = message.request_id;
+          return {
+            type: 'voice.stream.started',
+            request_id: message.request_id,
+            ok: true,
+            payload: { stream_id: 'stream_1', job_id: 'job_1' },
+          } as unknown as T;
+        }
+        await new Promise<void>((resolve) => {
+          releaseEnd = resolve;
+        });
+        for (const listener of listeners) {
+          listener({
+            type: 'voice.parse.result',
+            request_id: startRequestId,
+            job_id: 'job_1',
+            status: 'ready_for_confirmation',
+            draft: { schedule_type: 'time', title: '语音日程', start_time: null },
+            missing_fields: [],
+            ambiguous_fields: [],
+            needs_confirmation: true,
+          });
+        }
+        return {
+          type: 'voice.stream.ended',
+          request_id: message.request_id,
+          ok: true,
+          payload: { stream_id: 'stream_1', job_id: 'job_1', status: 'processing' },
+        } as unknown as T;
+      },
+      sendBinary() {},
+    };
+    const { result } = renderHook(() =>
+      useAssistantSession({ client, onConfirmDraft: async () => undefined, recorder }),
+    );
+    await act(async () => {
+      await result.current.handleVoiceStart();
+    });
+
+    let ending!: Promise<void>;
+    act(() => {
+      ending = result.current.handleVoiceEnd();
+    });
+    await act(async () => {
+      await Promise.resolve();
+    });
+    expect(result.current.isProcessing).toBe(true);
+
+    await act(async () => {
+      releaseEnd();
+      await ending;
+    });
+    expect(result.current.isProcessing).toBe(false);
+  });
+
+  it('cancels without parsing when the recorder produced no audio', async () => {
+    const client = createVoiceTransport({});
+    const request = jest.spyOn(client, 'request');
+    const silentRecorder: VoiceRecorder = {
+      async start() {},
+      async stop() {},
+      async cancel() {},
+    };
+    const { result } = renderHook(() =>
+      useAssistantSession({
+        client,
+        onConfirmDraft: async () => undefined,
+        recorder: silentRecorder,
+      }),
+    );
+
+    await act(async () => {
+      await result.current.handleVoiceStart();
+      await result.current.handleVoiceEnd();
+    });
+
+    const requestTypes = request.mock.calls.map(([message]) => message.type);
+    expect(requestTypes).toEqual(['voice.stream.start', 'voice.stream.cancel']);
+    expect(result.current.messages).toHaveLength(0);
+    expect(result.current.isProcessing).toBe(false);
+  });
+});
diff --git a/frontend/src/features/assistant/components/AssistantChatSheet.styles.ts b/frontend/src/features/assistant/components/AssistantChatSheet.styles.ts
new file mode 100644
index 0000000..6b6fc6a
--- /dev/null
+++ b/frontend/src/features/assistant/components/AssistantChatSheet.styles.ts
@@ -0,0 +1,95 @@
+import { StyleSheet } from 'react-native';
+
+import { colors } from '@/shared/theme';
+
+export const assistantChatSheetStyles = StyleSheet.create({
+  sheet: {
+    maxHeight: '86%',
+    minHeight: 360,
+    overflow: 'hidden',
+    paddingBottom: 0,
+    paddingHorizontal: 0,
+  },
+  header: {
+    alignItems: 'center',
+    borderBottomColor: colors.line,
+    borderBottomWidth: 1,
+    flexDirection: 'row',
+    gap: 11,
+    marginBottom: 0,
+    paddingBottom: 13,
+    paddingHorizontal: 18,
+    paddingTop: 14,
+  },
+  mark: {
+    alignItems: 'center',
+    backgroundColor: colors.deep,
+    borderColor: colors.lime,
+    borderRadius: 13,
+    borderWidth: 1.5,
+    height: 36,
+    justifyContent: 'center',
+    width: 36,
+  },
+  headerCopy: { flex: 1, minWidth: 0 },
+  title: { color: colors.ink, fontSize: 16, fontWeight: '800' },
+  subtitle: { color: colors.sub, fontSize: 11, marginTop: 3 },
+  list: {
+    backgroundColor: colors.background,
+    flexGrow: 1,
+    flexShrink: 1,
+  },
+  listContent: {
+    gap: 10,
+    paddingBottom: 16,
+    paddingHorizontal: 16,
+    paddingTop: 14,
+  },
+  listContentEmpty: {
+    flexGrow: 1,
+    justifyContent: 'center',
+  },
+  empty: {
+    alignItems: 'center',
+    paddingHorizontal: 24,
+    paddingVertical: 28,
+  },
+  emptyTitle: { color: colors.deep, fontSize: 15, fontWeight: '800' },
+  emptyHint: {
+    color: colors.sub,
+    fontSize: 12,
+    lineHeight: 18,
+    marginTop: 8,
+    textAlign: 'center',
+  },
+  rowUser: { alignItems: 'flex-end' },
+  bubbleUser: {
+    backgroundColor: colors.deep,
+    borderRadius: 16,
+    borderBottomRightRadius: 4,
+    maxWidth: '82%',
+    paddingHorizontal: 14,
+    paddingVertical: 10,
+  },
+  bubbleUserText: { color: colors.surface, fontSize: 14, lineHeight: 20 },
+  rowAssistant: { alignItems: 'flex-start' },
+  bubbleAssistant: {
+    backgroundColor: colors.surface,
+    borderColor: colors.line,
+    borderRadius: 16,
+    borderBottomLeftRadius: 4,
+    borderWidth: 1,
+    maxWidth: '88%',
+    paddingHorizontal: 14,
+    paddingVertical: 10,
+  },
+  bubbleAssistantText: { color: colors.ink, fontSize: 14, lineHeight: 20 },
+  draftSlot: { width: '100%' },
+  composer: {
+    alignItems: 'center',
+    backgroundColor: colors.surface,
+    borderTopColor: colors.line,
+    borderTopWidth: 1,
+    paddingTop: 12,
+  },
+});
diff --git a/frontend/src/features/assistant/components/AssistantChatSheet.tsx b/frontend/src/features/assistant/components/AssistantChatSheet.tsx
new file mode 100644
index 0000000..e62c320
--- /dev/null
+++ b/frontend/src/features/assistant/components/AssistantChatSheet.tsx
@@ -0,0 +1,133 @@
+import { useEffect, useRef } from 'react';
+import { ScrollView, Text, View } from 'react-native';
+import { useSafeAreaInsets } from 'react-native-safe-area-context';
+
+import { BottomSheetFrame } from '@/shared/components/BottomSheetFrame';
+import { colors } from '@/shared/theme';
+
+import type { AssistantMessage, AssistantMessageAction } from '../types';
+import { assistantChatSheetStyles as styles } from './AssistantChatSheet.styles';
+import { AssistantDraftCard } from './AssistantDraftCard';
+import { TempoAssistantIcon } from './TempoAssistantIcon';
+import { VoiceHoldButton } from './VoiceHoldButton';
+
+export function AssistantChatSheet({
+  isProcessing = false,
+  messages,
+  onAction,
+  onClose,
+  onVoiceCancel,
+  onVoiceEnd,
+  onVoiceStart,
+  visible,
+}: {
+  isProcessing?: boolean;
+  messages: AssistantMessage[];
+  onAction: (messageId: string, action: AssistantMessageAction) => void;
+  onClose: () => void;
+  onVoiceCancel?: () => void;
+  onVoiceEnd: () => void;
+  onVoiceStart?: () => void;
+  visible: boolean;
+}) {
+  const listRef = useRef<ScrollView>(null);
+  const insets = useSafeAreaInsets();
+
+  useEffect(() => {
+    if (!visible) return;
+    const timer = setTimeout(() => listRef.current?.scrollToEnd({ animated: true }), 60);
+    return () => clearTimeout(timer);
+  }, [messages, visible]);
+
+  return (
+    <BottomSheetFrame
+      closeAccessibilityLabel="关闭语音助手"
+      header={
+        <>
+          <View style={styles.mark}>
+            <TempoAssistantIcon color={colors.lime} size={19} />
+          </View>
+          <View style={styles.headerCopy}>
+            <Text style={styles.title}>语音助手</Text>
+            <Text style={styles.subtitle}>说一句话，我整理成日程给你确认</Text>
+          </View>
+        </>
+      }
+      headerStyle={styles.header}
+      onClose={onClose}
+      sheetStyle={styles.sheet}
+      visible={visible}
+    >
+      <ScrollView
+        ref={listRef}
+        contentContainerStyle={[
+          styles.listContent,
+          messages.length === 0 && styles.listContentEmpty,
+        ]}
+        onContentSizeChange={() => listRef.current?.scrollToEnd({ animated: true })}
+        showsVerticalScrollIndicator={false}
+        style={styles.list}
+      >
+        {messages.length === 0 ? (
+          <View style={styles.empty}>
+            <Text accessibilityLiveRegion="polite" style={styles.emptyTitle}>
+              {isProcessing ? '正在整理录音…' : '等你说第一句话'}
+            </Text>
+            <Text style={styles.emptyHint}>
+              {isProcessing
+                ? '识别完成后会生成一张待确认的日程草稿'
+                : '松开手指后，识别到的内容会整理成日程草稿显示在这里'}
+            </Text>
+          </View>
+        ) : null}
+        {messages.map((item) => {
+          if (item.role === 'user') {
+            return (
+              <View key={item.id} style={styles.rowUser}>
+                <View style={styles.bubbleUser}>
+                  <Text style={styles.bubbleUserText}>{item.text}</Text>
+                </View>
+              </View>
+            );
+          }
+
+          if (item.draft) {
+            return (
+              <View key={item.id} style={styles.draftSlot}>
+                <AssistantDraftCard
+                  actions={item.actions}
+                  draft={item.draft}
+                  onAction={(action) => onAction(item.id, action)}
+                />
+              </View>
+            );
+          }
+
+          return (
+            <View key={item.id} style={styles.rowAssistant}>
+              <View style={styles.bubbleAssistant}>
+                <Text style={styles.bubbleAssistantText}>{item.text}</Text>
+              </View>
+            </View>
+          );
+        })}
+        {isProcessing && messages.length > 0 ? (
+          <View style={styles.rowAssistant}>
+            <View style={styles.bubbleAssistant}>
+              <Text accessibilityLiveRegion="polite" style={styles.bubbleAssistantText}>
+                正在整理录音…
+              </Text>
+            </View>
+          </View>
+        ) : null}
+      </ScrollView>
+      <View style={[styles.composer, { paddingBottom: Math.max(insets.bottom, 14) }]}>
+        <VoiceHoldButton
+          onVoiceCancel={onVoiceCancel}
+          onVoiceEnd={onVoiceEnd}
+          onVoiceStart={onVoiceStart}
+        />
+      </View>
+    </BottomSheetFrame>
+  );
+}
diff --git a/frontend/src/features/assistant/components/AssistantDock.styles.ts b/frontend/src/features/assistant/components/AssistantDock.styles.ts
new file mode 100644
index 0000000..76f3180
--- /dev/null
+++ b/frontend/src/features/assistant/components/AssistantDock.styles.ts
@@ -0,0 +1,20 @@
+import { StyleSheet } from 'react-native';
+
+import { colors } from '@/shared/theme';
+
+export const assistantDockStyles = StyleSheet.create({
+  dock: {
+    alignItems: 'center',
+    backgroundColor: 'rgba(244,245,241,0.97)',
+    borderTopColor: colors.line,
+    borderTopWidth: 1,
+    bottom: 0,
+    justifyContent: 'flex-end',
+    left: 0,
+    paddingBottom: 10,
+    paddingTop: 6,
+    position: 'absolute',
+    right: 0,
+    zIndex: 20,
+  },
+});
diff --git a/frontend/src/features/assistant/components/AssistantDock.tsx b/frontend/src/features/assistant/components/AssistantDock.tsx
new file mode 100644
index 0000000..0cf7342
--- /dev/null
+++ b/frontend/src/features/assistant/components/AssistantDock.tsx
@@ -0,0 +1,32 @@
+import { View } from 'react-native';
+
+import { assistantDockStyles as styles } from './AssistantDock.styles';
+import { VoiceHoldButton } from './VoiceHoldButton';
+
+/** 日程页底部语音入口；助手弹层打开时隐藏，改由弹层内的按钮说话。 */
+export function AssistantDock({
+  hidden = false,
+  onOpen,
+  onVoiceCancel,
+  onVoiceEnd,
+  onVoiceStart,
+}: {
+  hidden?: boolean;
+  onOpen: () => void;
+  onVoiceCancel?: () => void;
+  onVoiceEnd: () => void;
+  onVoiceStart?: () => void;
+}) {
+  if (hidden) return null;
+
+  return (
+    <View style={[styles.dock, { pointerEvents: 'box-none' }]}>
+      <VoiceHoldButton
+        onPress={onOpen}
+        onVoiceCancel={onVoiceCancel}
+        onVoiceEnd={onVoiceEnd}
+        onVoiceStart={onVoiceStart}
+      />
+    </View>
+  );
+}
diff --git a/frontend/src/features/assistant/components/AssistantDraftCard.styles.ts b/frontend/src/features/assistant/components/AssistantDraftCard.styles.ts
new file mode 100644
index 0000000..669346b
--- /dev/null
+++ b/frontend/src/features/assistant/components/AssistantDraftCard.styles.ts
@@ -0,0 +1,134 @@
+import { StyleSheet } from 'react-native';
+
+import { colors } from '@/shared/theme';
+
+export const assistantDraftCardStyles = StyleSheet.create({
+  card: {
+    backgroundColor: colors.surface,
+    borderColor: colors.line,
+    borderRadius: 16,
+    borderWidth: 1,
+    overflow: 'hidden',
+  },
+  cardResolved: {
+    backgroundColor: '#FBFCFA',
+  },
+  head: {
+    alignItems: 'flex-start',
+    flexDirection: 'row',
+    gap: 11,
+    paddingHorizontal: 13,
+    paddingTop: 13,
+  },
+  icon: {
+    alignItems: 'center',
+    backgroundColor: colors.limeSoft,
+    borderRadius: 10,
+    height: 34,
+    justifyContent: 'center',
+    width: 34,
+  },
+  iconResolved: {
+    backgroundColor: '#E7EDE8',
+  },
+  copy: {
+    flex: 1,
+    minWidth: 0,
+  },
+  titleRow: {
+    alignItems: 'flex-start',
+    flexDirection: 'row',
+    gap: 8,
+    justifyContent: 'space-between',
+  },
+  title: {
+    color: colors.ink,
+    flex: 1,
+    fontSize: 15,
+    fontWeight: '800',
+    lineHeight: 20,
+  },
+  when: {
+    color: colors.ink,
+    fontSize: 12,
+    fontWeight: '600',
+    lineHeight: 17,
+    marginTop: 5,
+  },
+  meta: {
+    color: colors.sub,
+    fontSize: 11,
+    lineHeight: 16,
+    marginTop: 3,
+  },
+  clarification: {
+    color: '#A16142',
+    fontSize: 11,
+    lineHeight: 16,
+    marginTop: 6,
+  },
+  chip: {
+    alignItems: 'center',
+    backgroundColor: colors.limeSoft,
+    borderRadius: 8,
+    flexDirection: 'row',
+    gap: 3,
+    paddingHorizontal: 7,
+    paddingVertical: 4,
+  },
+  chipAdded: {
+    backgroundColor: '#E4EEE6',
+  },
+  chipDismissed: {
+    backgroundColor: '#EEF0ED',
+  },
+  chipText: {
+    color: '#5C7045',
+    fontSize: 9,
+    fontWeight: '800',
+  },
+  chipTextAdded: {
+    color: '#63866E',
+  },
+  chipTextDismissed: {
+    color: colors.muted,
+  },
+  actions: {
+    borderTopColor: colors.line,
+    borderTopWidth: 1,
+    flexDirection: 'row',
+    gap: 8,
+    marginTop: 13,
+    paddingHorizontal: 13,
+    paddingVertical: 11,
+  },
+  action: {
+    alignItems: 'center',
+    borderRadius: 11,
+    flexDirection: 'row',
+    gap: 5,
+    height: 40,
+    justifyContent: 'center',
+  },
+  actionDismiss: {
+    backgroundColor: '#E9ECE8',
+    flex: 1,
+  },
+  actionDismissText: {
+    color: colors.ink,
+    fontSize: 12,
+    fontWeight: '700',
+  },
+  actionConfirm: {
+    backgroundColor: colors.lime,
+    flex: 1.4,
+  },
+  actionConfirmText: {
+    color: colors.deep,
+    fontSize: 12,
+    fontWeight: '800',
+  },
+  bottomPad: {
+    height: 13,
+  },
+});
diff --git a/frontend/src/features/assistant/components/AssistantDraftCard.tsx b/frontend/src/features/assistant/components/AssistantDraftCard.tsx
new file mode 100644
index 0000000..654b343
--- /dev/null
+++ b/frontend/src/features/assistant/components/AssistantDraftCard.tsx
@@ -0,0 +1,93 @@
+import { CalendarClock, Check, CheckCircle2 } from 'lucide-react-native';
+import { Pressable, Text, View } from 'react-native';
+
+import { colors } from '@/shared/theme';
+
+import type { AssistantDraft, AssistantMessageAction } from '../types';
+import { assistantDraftCardStyles as styles } from './AssistantDraftCard.styles';
+
+const CHIP_LABEL = {
+  pending: '待确认',
+  added: '已加入日程',
+  dismissed: '已忽略',
+} as const;
+
+/** 助手把语音解析成的日程草稿：先看清内容，再决定是否加入日程。 */
+export function AssistantDraftCard({
+  actions,
+  draft,
+  onAction,
+}: {
+  actions?: AssistantMessageAction[];
+  draft: AssistantDraft;
+  onAction: (action: AssistantMessageAction) => void;
+}) {
+  const state = draft.state ?? 'pending';
+  const resolved = state !== 'pending';
+  const showActions = state === 'pending' && actions && actions.length > 0;
+
+  return (
+    <View style={[styles.card, resolved && styles.cardResolved]}>
+      <View style={styles.head}>
+        <View style={[styles.icon, resolved && styles.iconResolved]}>
+          <CalendarClock color={resolved ? colors.sub : colors.deep} size={17} strokeWidth={2.1} />
+        </View>
+        <View style={styles.copy}>
+          <View style={styles.titleRow}>
+            <Text style={styles.title}>{draft.title}</Text>
+            <View
+              style={[
+                styles.chip,
+                state === 'added' && styles.chipAdded,
+                state === 'dismissed' && styles.chipDismissed,
+              ]}
+            >
+              {state === 'added' ? (
+                <CheckCircle2 color="#63866E" size={10} strokeWidth={2.4} />
+              ) : null}
+              <Text
+                style={[
+                  styles.chipText,
+                  state === 'added' && styles.chipTextAdded,
+                  state === 'dismissed' && styles.chipTextDismissed,
+                ]}
+              >
+                {CHIP_LABEL[state]}
+              </Text>
+            </View>
+          </View>
+          <Text style={styles.when}>{draft.whenLabel}</Text>
+          {draft.metaLabel ? <Text style={styles.meta}>{draft.metaLabel}</Text> : null}
+          {draft.clarificationLabel ? (
+            <Text accessibilityRole="text" style={styles.clarification}>
+              {draft.clarificationLabel}
+            </Text>
+          ) : null}
+        </View>
+      </View>
+      {showActions ? (
+        <View style={styles.actions}>
+          {actions.map((action) => {
+            const confirm = action.kind === 'confirm';
+            return (
+              <Pressable
+                key={action.id}
+                accessibilityLabel={action.label}
+                accessibilityRole="button"
+                onPress={() => onAction(action)}
+                style={[styles.action, confirm ? styles.actionConfirm : styles.actionDismiss]}
+              >
+                {confirm ? <Check color={colors.deep} size={14} strokeWidth={2.4} /> : null}
+                <Text style={confirm ? styles.actionConfirmText : styles.actionDismissText}>
+                  {action.label}
+                </Text>
+              </Pressable>
+            );
+          })}
+        </View>
+      ) : (
+        <View style={styles.bottomPad} />
+      )}
+    </View>
+  );
+}
diff --git a/frontend/src/features/assistant/components/TempoAssistantIcon.tsx b/frontend/src/features/assistant/components/TempoAssistantIcon.tsx
new file mode 100644
index 0000000..6006a6a
--- /dev/null
+++ b/frontend/src/features/assistant/components/TempoAssistantIcon.tsx
@@ -0,0 +1,24 @@
+import Svg, { Path } from 'react-native-svg';
+
+export function TempoAssistantIcon({
+  color = '#D9F65A',
+  size = 22,
+}: {
+  color?: string;
+  size?: number;
+}) {
+  return (
+    <Svg fill="none" height={size} viewBox="0 0 24 24" width={size}>
+      <Path
+        d="M12 3.5 13.8 9l5.2 1.7-5.2 1.7L12 18l-1.8-5.6L5 10.7 10.2 9 12 3.5Z"
+        stroke={color}
+        strokeLinejoin="round"
+        strokeWidth={1.65}
+      />
+      <Path
+        d="m18.3 15.6.65 1.95 1.95.65-1.95.65-.65 1.95-.65-1.95-1.95-.65 1.95-.65.65-1.95Z"
+        fill={color}
+      />
+    </Svg>
+  );
+}
diff --git a/frontend/src/features/assistant/components/VoiceHoldButton.styles.ts b/frontend/src/features/assistant/components/VoiceHoldButton.styles.ts
new file mode 100644
index 0000000..f4e1932
--- /dev/null
+++ b/frontend/src/features/assistant/components/VoiceHoldButton.styles.ts
@@ -0,0 +1,54 @@
+import { StyleSheet } from 'react-native';
+
+import { colors } from '@/shared/theme';
+
+export const voiceHoldButtonStyles = StyleSheet.create({
+  wrap: {
+    alignItems: 'center',
+    alignSelf: 'center',
+    gap: 7,
+  },
+  hintSlot: {
+    alignItems: 'center',
+    justifyContent: 'center',
+    minHeight: 15,
+  },
+  hint: {
+    color: colors.muted,
+    fontSize: 11,
+    fontWeight: '700',
+  },
+  hintCancel: {
+    color: colors.coral,
+  },
+  button: {
+    alignItems: 'center',
+    backgroundColor: colors.deep,
+    borderColor: 'transparent',
+    borderRadius: 16,
+    borderWidth: 1,
+    height: 52,
+    justifyContent: 'center',
+    width: 52,
+  },
+  buttonListening: {
+    borderColor: 'rgba(215,243,106,0.55)',
+    width: 96,
+  },
+  buttonCancel: {
+    backgroundColor: colors.peach,
+    borderColor: '#F1C6B6',
+    width: 76,
+  },
+  wave: {
+    alignItems: 'center',
+    flexDirection: 'row',
+    gap: 4,
+    height: 24,
+  },
+  waveBar: {
+    backgroundColor: colors.lime,
+    borderRadius: 999,
+    width: 3.5,
+  },
+});
diff --git a/frontend/src/features/assistant/components/VoiceHoldButton.tsx b/frontend/src/features/assistant/components/VoiceHoldButton.tsx
new file mode 100644
index 0000000..c80e211
--- /dev/null
+++ b/frontend/src/features/assistant/components/VoiceHoldButton.tsx
@@ -0,0 +1,177 @@
+import { useEffect, useRef, useState } from 'react';
+import {
+  Animated,
+  Easing,
+  Platform,
+  Pressable,
+  Text,
+  Vibration,
+  View,
+  type GestureResponderEvent,
+  type StyleProp,
+  type ViewStyle,
+} from 'react-native';
+
+import { colors } from '@/shared/theme';
+
+import { TempoAssistantIcon } from './TempoAssistantIcon';
+import { voiceHoldButtonStyles as styles } from './VoiceHoldButton.styles';
+
+const WAVE_BAR_HEIGHTS = [11, 18, 24, 16, 12] as const;
+const CANCEL_DISTANCE = 72;
+const HOLD_DELAY_MS = 320;
+const HAPTIC_DURATION_MS = 35;
+
+/** 轻点打开助手；按住说话、松开发送、上滑取消。 */
+export function VoiceHoldButton({
+  iconSize = 22,
+  onPress,
+  onVoiceCancel,
+  onVoiceEnd,
+  onVoiceStart,
+  style,
+}: {
+  iconSize?: number;
+  onPress?: () => void;
+  onVoiceCancel?: () => void;
+  onVoiceEnd: () => void;
+  onVoiceStart?: () => void;
+  style?: StyleProp<ViewStyle>;
+}) {
+  const [isListening, setIsListening] = useState(false);
+  const [willCancel, setWillCancel] = useState(false);
+  const [waveValues] = useState(() => WAVE_BAR_HEIGHTS.map(() => new Animated.Value(0.55)));
+  const recordingStartedRef = useRef(false);
+  const longPressTriggeredRef = useRef(false);
+  const cancelHapticFiredRef = useRef(false);
+  const willCancelRef = useRef(false);
+  const startYRef = useRef(0);
+
+  const handlePressIn = (event: GestureResponderEvent) => {
+    startYRef.current = event.nativeEvent.pageY;
+    recordingStartedRef.current = false;
+    longPressTriggeredRef.current = false;
+    cancelHapticFiredRef.current = false;
+    willCancelRef.current = false;
+    setWillCancel(false);
+  };
+
+  const handleLongPress = () => {
+    longPressTriggeredRef.current = true;
+    recordingStartedRef.current = true;
+    setIsListening(true);
+    Vibration.vibrate(HAPTIC_DURATION_MS);
+    onVoiceStart?.();
+  };
+
+  const handleTouchMove = (event: GestureResponderEvent) => {
+    if (!recordingStartedRef.current) return;
+    const shouldCancel = event.nativeEvent.pageY - startYRef.current < -CANCEL_DISTANCE;
+    if (shouldCancel && !cancelHapticFiredRef.current) {
+      cancelHapticFiredRef.current = true;
+      Vibration.vibrate(HAPTIC_DURATION_MS);
+    }
+    willCancelRef.current = shouldCancel;
+    setWillCancel(shouldCancel);
+  };
+
+  const handlePressOut = () => {
+    if (!recordingStartedRef.current) return;
+    const cancelled = willCancelRef.current;
+    recordingStartedRef.current = false;
+    willCancelRef.current = false;
+    setIsListening(false);
+    setWillCancel(false);
+    if (cancelled) onVoiceCancel?.();
+    else onVoiceEnd();
+  };
+
+  useEffect(() => {
+    if (!isListening) {
+      waveValues.forEach((value) => {
+        value.stopAnimation();
+        value.setValue(0.55);
+      });
+      return;
+    }
+
+    const animation = Animated.loop(
+      Animated.stagger(
+        60,
+        waveValues.map((value) =>
+          Animated.sequence([
+            Animated.timing(value, {
+              duration: 170,
+              easing: Easing.inOut(Easing.ease),
+              toValue: 1,
+              useNativeDriver: Platform.OS !== 'web',
+            }),
+            Animated.timing(value, {
+              duration: 170,
+              easing: Easing.inOut(Easing.ease),
+              toValue: 0.5,
+              useNativeDriver: Platform.OS !== 'web',
+            }),
+          ]),
+        ),
+      ),
+    );
+
+    animation.start();
+    return () => {
+      animation.stop();
+      waveValues.forEach((value) => value.setValue(0.55));
+    };
+  }, [isListening, waveValues]);
+
+  const hint = willCancel ? '松开手指取消发送' : isListening ? '松开发送 · 上滑取消' : '';
+
+  return (
+    <View style={[styles.wrap, style]}>
+      {hint ? (
+        <View style={styles.hintSlot}>
+          <Text style={[styles.hint, willCancel && styles.hintCancel]}>{hint}</Text>
+        </View>
+      ) : null}
+      <Pressable
+        accessibilityLabel={
+          onPress ? '轻点打开语音助手，按住说话，上滑取消' : '按住说话，松开发送，上滑取消'
+        }
+        accessibilityRole="button"
+        delayLongPress={HOLD_DELAY_MS}
+        onLongPress={handleLongPress}
+        onPress={() => {
+          if (!longPressTriggeredRef.current) onPress?.();
+        }}
+        onPressIn={handlePressIn}
+        onPressOut={handlePressOut}
+        onTouchMove={handleTouchMove}
+        style={[
+          styles.button,
+          isListening && !willCancel && styles.buttonListening,
+          willCancel && styles.buttonCancel,
+        ]}
+      >
+        {isListening && !willCancel ? (
+          <View style={styles.wave}>
+            {waveValues.map((value, index) => (
+              <Animated.View
+                key={`wave-${WAVE_BAR_HEIGHTS[index]}-${index}`}
+                style={[
+                  styles.waveBar,
+                  {
+                    height: WAVE_BAR_HEIGHTS[index],
+                    opacity: value,
+                    transform: [{ scaleY: value }],
+                  },
+                ]}
+              />
+            ))}
+          </View>
+        ) : (
+          <TempoAssistantIcon color={willCancel ? colors.coral : colors.lime} size={iconSize} />
+        )}
+      </Pressable>
+    </View>
+  );
+}
diff --git a/frontend/src/features/assistant/data/VoiceStreamPort.ts b/frontend/src/features/assistant/data/VoiceStreamPort.ts
new file mode 100644
index 0000000..47f963c
--- /dev/null
+++ b/frontend/src/features/assistant/data/VoiceStreamPort.ts
@@ -0,0 +1,154 @@
+import type {
+  VoiceParseReadyResult,
+  VoiceParseResultMessage,
+  VoiceStreamCancelCommand,
+  VoiceStreamCancelAck,
+  VoiceStreamEndCommand,
+  VoiceStreamStartCommand,
+  VoiceStreamStartResponse,
+  VoiceStreamEndResponse,
+  WsJsonMessage,
+} from '@/contracts';
+import { nextRequestId } from '@/shared/utils/requestId';
+
+export type VoiceParseOutcome = Pick<
+  VoiceParseReadyResult,
+  'draft' | 'missing_fields' | 'ambiguous_fields'
+>;
+
+export type VoiceStreamPort = {
+  start(): Promise<{ streamId: string; jobId: string; resultRequestId: string }>;
+  sendAudioChunk(data: ArrayBuffer): void;
+  end(streamId: string, jobId: string, resultRequestId: string): Promise<VoiceParseOutcome>;
+  cancel(streamId: string, jobId: string | null): Promise<void>;
+};
+
+/** Composition port; concrete microphone adapters live outside the feature. */
+export type VoiceRecorder = {
+  start(onChunk: (chunk: ArrayBuffer) => void): Promise<void>;
+  stop(): Promise<void>;
+  cancel(): Promise<void>;
+};
+
+/** assistant data 层所需的最小传输面；由 app 注入 WsClient。 */
+export type VoiceTransport = {
+  onMessage(listener: (message: WsJsonMessage | ArrayBuffer) => void): () => void;
+  request<T extends WsJsonMessage>(
+    message: WsJsonMessage & { request_id: string },
+    isMatch?: (response: WsJsonMessage) => boolean,
+  ): Promise<T>;
+  sendBinary(data: ArrayBuffer): void;
+};
+
+export class WsVoiceStreamPort implements VoiceStreamPort {
+  constructor(private readonly client: VoiceTransport) {}
+
+  async start(): Promise<{ streamId: string; jobId: string; resultRequestId: string }> {
+    const request: VoiceStreamStartCommand = {
+      type: 'voice.stream.start',
+      request_id: nextRequestId('req_voice_start'),
+      payload: {
+        audio_format: 'pcm_s16le',
+        sample_rate_hz: 16000,
+        channels: 1,
+      },
+    };
+    const response = await this.client.request<VoiceStreamStartResponse>(request, (message) => {
+      return (
+        message.request_id === request.request_id &&
+        (message.type === 'voice.stream.started' || message.type === 'voice.stream.error')
+      );
+    });
+    if (!response.ok) {
+      throw new Error(response.error.message);
+    }
+    return {
+      streamId: response.payload.stream_id,
+      jobId: response.payload.job_id,
+      resultRequestId: request.request_id,
+    };
+  }
+
+  sendAudioChunk(data: ArrayBuffer): void {
+    if (data.byteLength === 0 || data.byteLength % 2 !== 0) {
+      throw new Error('PCM 音频帧不能为空且必须按 16 位采样对齐');
+    }
+    this.client.sendBinary(data);
+  }
+
+  async end(streamId: string, jobId: string, resultRequestId: string): Promise<VoiceParseOutcome> {
+    const request: VoiceStreamEndCommand = {
+      type: 'voice.stream.end',
+      request_id: nextRequestId('req_voice_end'),
+      payload: { stream_id: streamId },
+    };
+
+    let cleanupParseListener = () => undefined;
+    const parseResult = new Promise<VoiceParseOutcome>((resolve, reject) => {
+      const timer = setTimeout(() => {
+        cleanupParseListener();
+        reject(new Error('voice.parse.result timed out'));
+      }, 20_000);
+      const unsubscribe = this.client.onMessage((message: WsJsonMessage | ArrayBuffer) => {
+        if (message instanceof ArrayBuffer) return;
+        if (message.type !== 'voice.parse.result') return;
+        const result = message as VoiceParseResultMessage;
+        // The MVP backend correlates the final parse result to voice.stream.start,
+        // while voice.stream.ended is correlated to this end request.
+        if (result.job_id !== jobId || result.request_id !== resultRequestId) return;
+        clearTimeout(timer);
+        cleanupParseListener();
+        if (result.status === 'failed') {
+          reject(new Error(result.error.message));
+          return;
+        }
+        resolve({
+          draft: result.draft,
+          missing_fields: result.missing_fields,
+          ambiguous_fields: result.ambiguous_fields,
+        });
+      });
+      cleanupParseListener = () => {
+        clearTimeout(timer);
+        unsubscribe();
+      };
+    });
+
+    let endResponse: VoiceStreamEndResponse;
+    try {
+      endResponse = await this.client.request<VoiceStreamEndResponse>(request, (message) => {
+        return (
+          message.request_id === request.request_id &&
+          (message.type === 'voice.stream.ended' || message.type === 'voice.stream.error')
+        );
+      });
+    } catch (error) {
+      cleanupParseListener();
+      throw error;
+    }
+    if (!endResponse.ok) {
+      cleanupParseListener();
+      throw new Error(endResponse.error.message);
+    }
+    return parseResult;
+  }
+
+  async cancel(streamId: string, jobId: string | null): Promise<void> {
+    const request: VoiceStreamCancelCommand = {
+      type: 'voice.stream.cancel',
+      request_id: nextRequestId('req_voice_cancel'),
+      payload: { stream_id: streamId, job_id: jobId },
+    };
+    const response = await this.client.request<VoiceStreamCancelAck>(request, (message) => {
+      return (
+        message.request_id === request.request_id &&
+        (message.type === 'voice.stream.cancelled' ||
+          message.type === 'voice.stream.error' ||
+          message.type === 'voice.stream.cancel')
+      );
+    });
+    if (!response.ok) {
+      throw new Error(response.error.message);
+    }
+  }
+}
diff --git a/frontend/src/features/assistant/hooks/useAssistantSession.ts b/frontend/src/features/assistant/hooks/useAssistantSession.ts
new file mode 100644
index 0000000..70ffe13
--- /dev/null
+++ b/frontend/src/features/assistant/hooks/useAssistantSession.ts
@@ -0,0 +1,256 @@
+import { useCallback, useEffect, useMemo, useRef, useState } from 'react';
+
+import type { VoiceParseDraft } from '@/contracts';
+
+import {
+  WsVoiceStreamPort,
+  type VoiceRecorder,
+  type VoiceParseOutcome,
+  type VoiceStreamPort,
+  type VoiceTransport,
+} from '../data/VoiceStreamPort';
+import type { AssistantMessage, AssistantMessageAction } from '../types';
+
+function formatWhenLabel(draft: VoiceParseDraft): string {
+  if (draft.start_time) {
+    const date = new Date(draft.start_time);
+    if (!Number.isNaN(date.getTime())) {
+      return `${date.getMonth() + 1}月${date.getDate()}日 ${String(date.getHours()).padStart(2, '0')}:${String(date.getMinutes()).padStart(2, '0')}`;
+    }
+  }
+  if (draft.location_name || draft.location_address) {
+    return draft.location_name ?? draft.location_address ?? '地点提醒';
+  }
+  return '待确认时间';
+}
+
+const FIELD_LABELS: Record<string, string> = {
+  title: '标题',
+  schedule_type: '提醒类型',
+  start_time: '开始时间',
+  end_time: '结束时间',
+  location_name: '地点名称',
+  location_address: '地点地址',
+};
+
+function formatFieldName(field: string): string {
+  return FIELD_LABELS[field] ?? field;
+}
+
+function formatClarificationLabel(result: VoiceParseOutcome): string | undefined {
+  const missing = result.missing_fields.map(formatFieldName);
+  const ambiguous = result.ambiguous_fields.map(formatFieldName);
+  const parts: string[] = [];
+  if (missing.length > 0) parts.push(`需要补充：${missing.join('、')}`);
+  if (ambiguous.length > 0) parts.push(`需要确认：${ambiguous.join('、')}`);
+  return parts.length > 0 ? parts.join('；') : undefined;
+}
+
+const unavailableRecorder: VoiceRecorder = {
+  async start() {
+    throw new Error('录音适配器未注入');
+  },
+  async stop() {},
+  async cancel() {},
+};
+
+type ActiveVoiceStream = {
+  streamId: string;
+  jobId: string;
+  resultRequestId: string;
+  port: VoiceStreamPort;
+  recorder: VoiceRecorder;
+  hasAudio: boolean;
+};
+
+async function cancelVoiceStream(stream: ActiveVoiceStream): Promise<void> {
+  await stream.recorder.cancel().catch(() => undefined);
+  await stream.port.cancel(stream.streamId, stream.jobId).catch(() => undefined);
+}
+
+/**
+ * 助手会话：只产出 VoiceParseDraft，不依赖 schedule model。
+ * AppShell 负责映射为 ScheduleDraft 并写入日程。
+ */
+export function useAssistantSession(options: {
+  client: VoiceTransport | null;
+  onConfirmDraft: (draft: VoiceParseDraft) => Promise<void>;
+  /** App/native hosts may inject an Expo Audio backed recorder. */
+  recorder?: VoiceRecorder;
+}) {
+  const voice = useMemo(
+    () => (options.client ? new WsVoiceStreamPort(options.client) : null),
+    [options.client],
+  );
+  const recorder = useMemo(() => options.recorder ?? unavailableRecorder, [options.recorder]);
+  const [messages, setMessages] = useState<AssistantMessage[]>([]);
+  const [isProcessing, setIsProcessing] = useState(false);
+  const activeStreamRef = useRef<ActiveVoiceStream | null>(null);
+  const startPromiseRef = useRef<Promise<ActiveVoiceStream> | null>(null);
+  const [pendingDrafts, setPendingDrafts] = useState<Record<string, VoiceParseOutcome>>({});
+
+  useEffect(() => {
+    return () => {
+      const cancel = (stream: ActiveVoiceStream) => {
+        if (activeStreamRef.current === stream) activeStreamRef.current = null;
+        void cancelVoiceStream(stream);
+      };
+      const starting = startPromiseRef.current;
+      if (starting) {
+        void starting.then(cancel).catch(() => undefined);
+        return;
+      }
+      const stream = activeStreamRef.current;
+      if (stream) cancel(stream);
+    };
+  }, []);
+
+  const handleVoiceStart = useCallback(async () => {
+    if (!voice) throw new Error('语音通道未就绪');
+    if (activeStreamRef.current || startPromiseRef.current) {
+      throw new Error('语音录音已经开始');
+    }
+
+    const startOperation = (async (): Promise<ActiveVoiceStream> => {
+      const started = await voice.start();
+      const stream: ActiveVoiceStream = { ...started, port: voice, recorder, hasAudio: false };
+      try {
+        await recorder.start((chunk) => {
+          voice.sendAudioChunk(chunk);
+          stream.hasAudio = true;
+        });
+      } catch (error) {
+        await voice.cancel(started.streamId, started.jobId).catch(() => undefined);
+        throw error;
+      }
+      activeStreamRef.current = stream;
+      return stream;
+    })();
+    startPromiseRef.current = startOperation;
+    try {
+      await startOperation;
+    } finally {
+      if (startPromiseRef.current === startOperation) {
+        startPromiseRef.current = null;
+      }
+    }
+  }, [recorder, voice]);
+
+  const handleVoiceEnd = useCallback(async () => {
+    const starting = startPromiseRef.current;
+    if (starting) {
+      try {
+        await starting;
+      } catch {
+        // handleVoiceStart owns reporting its startup failure.
+        return;
+      }
+    }
+    const stream = activeStreamRef.current;
+    if (!stream) return;
+    activeStreamRef.current = null;
+    setIsProcessing(true);
+    try {
+      try {
+        await stream.recorder.stop();
+      } catch (error) {
+        await stream.port.cancel(stream.streamId, stream.jobId).catch(() => undefined);
+        throw error;
+      }
+      if (!stream.hasAudio) {
+        await stream.port.cancel(stream.streamId, stream.jobId).catch(() => undefined);
+        return;
+      }
+      const parseResult = await stream.port.end(
+        stream.streamId,
+        stream.jobId,
+        stream.resultRequestId,
+      );
+      const messageId = `msg_${Date.now()}`;
+      const clarificationLabel = formatClarificationLabel(parseResult);
+      const canConfirm = !clarificationLabel;
+      setPendingDrafts((current) => ({ ...current, [messageId]: parseResult }));
+      setMessages((current) => [
+        ...current,
+        {
+          id: messageId,
+          role: 'assistant',
+          createdAt: Date.now(),
+          draft: {
+            title: parseResult.draft.title,
+            whenLabel: formatWhenLabel(parseResult.draft),
+            metaLabel: parseResult.draft.location_name ?? undefined,
+            clarificationLabel,
+            state: 'pending',
+          },
+          actions: canConfirm
+            ? [
+                { id: `${messageId}_confirm`, label: '确认添加', kind: 'confirm' },
+                { id: `${messageId}_dismiss`, label: '忽略', kind: 'dismiss' },
+              ]
+            : [{ id: `${messageId}_dismiss`, label: '忽略', kind: 'dismiss' }],
+        },
+      ]);
+    } finally {
+      setIsProcessing(false);
+    }
+  }, []);
+
+  const handleVoiceCancel = useCallback(() => {
+    setIsProcessing(false);
+    const cancel = (stream: ActiveVoiceStream) => {
+      if (activeStreamRef.current === stream) activeStreamRef.current = null;
+      return cancelVoiceStream(stream);
+    };
+
+    const starting = startPromiseRef.current;
+    if (starting) {
+      void starting.then(cancel).catch(() => undefined);
+      return;
+    }
+    const stream = activeStreamRef.current;
+    if (stream) void cancel(stream);
+  }, []);
+
+  const handleAction = useCallback(
+    async (messageId: string, action: AssistantMessageAction) => {
+      if (action.kind === 'confirm') {
+        const result = pendingDrafts[messageId];
+        if (!result) return;
+        if (result.missing_fields.length > 0 || result.ambiguous_fields.length > 0) {
+          throw new Error('语音草稿仍有待确认字段，不能直接加入日程');
+        }
+        await options.onConfirmDraft(result.draft);
+      }
+      setPendingDrafts((current) => {
+        const next = { ...current };
+        delete next[messageId];
+        return next;
+      });
+      setMessages((current) =>
+        current.map((item) =>
+          item.id === messageId && item.draft
+            ? {
+                ...item,
+                actions: undefined,
+                draft: {
+                  ...item.draft,
+                  state: action.kind === 'confirm' ? 'added' : 'dismissed',
+                },
+              }
+            : item,
+        ),
+      );
+    },
+    [options, pendingDrafts],
+  );
+
+  return {
+    messages,
+    isProcessing,
+    handleVoiceStart,
+    handleVoiceEnd,
+    handleVoiceCancel,
+    handleAction,
+  };
+}
diff --git a/frontend/src/features/assistant/index.ts b/frontend/src/features/assistant/index.ts
new file mode 100644
index 0000000..4418d06
--- /dev/null
+++ b/frontend/src/features/assistant/index.ts
@@ -0,0 +1,5 @@
+export { AssistantChatSheet } from './components/AssistantChatSheet';
+export { AssistantDock } from './components/AssistantDock';
+export { useAssistantSession } from './hooks/useAssistantSession';
+export type { VoiceRecorder } from './data/VoiceStreamPort';
+export type { AssistantMessage, AssistantMessageAction } from './types';
diff --git a/frontend/src/features/assistant/types.ts b/frontend/src/features/assistant/types.ts
new file mode 100644
index 0000000..8c3b99c
--- /dev/null
+++ b/frontend/src/features/assistant/types.ts
@@ -0,0 +1,31 @@
+export type AssistantRole = 'user' | 'assistant';
+
+export type AssistantMessageAction = {
+  id: string;
+  label: string;
+  kind: 'confirm' | 'dismiss';
+};
+
+/** 助手解析出的草稿状态：待确认 / 已加入日程 / 已忽略。 */
+export type AssistantDraftState = 'pending' | 'added' | 'dismissed';
+
+/** 语音被解析成的日程草稿，用卡片展示而不是塞进对话文字里。 */
+export type AssistantDraft = {
+  title: string;
+  whenLabel: string;
+  metaLabel?: string;
+  /** 解析字段不完整时只展示草稿，不允许直接写入日程。 */
+  clarificationLabel?: string;
+  state?: AssistantDraftState;
+};
+
+export type AssistantMessage = {
+  id: string;
+  role: AssistantRole;
+  createdAt: number;
+  /** 纯文本内容；带 draft 的助手消息可以只给卡片。 */
+  text?: string;
+  draft?: AssistantDraft;
+  /** 助手消息可附带确认操作；点过后清空。 */
+  actions?: AssistantMessageAction[];
+};

From 90fa3fe7ad00cd621f60e1f8e75b12a0a465f773 Mon Sep 17 00:00:00 2001
From: mac <mac@mac11MacBook-Pro.local>
Date: Fri, 31 Jul 2026 19:36:05 +0800
Subject: [PATCH 2/2] fix(frontend): address voice assistant review

---
 .../assistant/data/VoiceStreamPort.test.ts    | 21 +++++
 .../application/ScheduleService.test.ts       | 40 +++++++++
 .../MapPicker/baidu/baiduMapWebView.test.ts   | 12 +++
 frontend/src/dev/fakes/FakeWsServer.ts        | 25 +++++-
 .../assistant/hooks/useAssistantSession.ts    | 14 +--
 .../schedule/application/ScheduleService.ts   | 90 +++++++++++++------
 .../MapPicker/baidu/baiduMapWebView.ts        | 13 ++-
 7 files changed, 172 insertions(+), 43 deletions(-)
 create mode 100644 frontend/__tests__/features/assistant/data/VoiceStreamPort.test.ts

diff --git a/frontend/__tests__/features/assistant/data/VoiceStreamPort.test.ts b/frontend/__tests__/features/assistant/data/VoiceStreamPort.test.ts
new file mode 100644
index 0000000..31a51a5
--- /dev/null
+++ b/frontend/__tests__/features/assistant/data/VoiceStreamPort.test.ts
@@ -0,0 +1,21 @@
+import { describe, expect, it } from '@jest/globals';
+
+import { FakeWsServer } from '@/dev/fakes/FakeWsServer';
+import { WsVoiceStreamPort } from '@/features/assistant/data/VoiceStreamPort';
+import { WsClient } from '@/infrastructure/ws/WsClient';
+
+describe('WsVoiceStreamPort with FakeWsServer', () => {
+  it('correlates the final parse result to the start request', async () => {
+    const server = new FakeWsServer();
+    const client = new WsClient({ fakeHandler: server.handleMessage });
+    server.attach(client);
+    await client.connect();
+    const voice = new WsVoiceStreamPort(client);
+
+    const started = await voice.start();
+    const result = await voice.end(started.streamId, started.jobId, started.resultRequestId);
+
+    expect(result.draft.title).toBe('语音创建的日程');
+    client.close();
+  });
+});
diff --git a/frontend/__tests__/features/schedule/application/ScheduleService.test.ts b/frontend/__tests__/features/schedule/application/ScheduleService.test.ts
index aea4b9c..be3def7 100644
--- a/frontend/__tests__/features/schedule/application/ScheduleService.test.ts
+++ b/frontend/__tests__/features/schedule/application/ScheduleService.test.ts
@@ -145,6 +145,18 @@ describe('ScheduleService', () => {
     expect(saved.system_schedule_ref_id).toBe('alarm_99');
   });
 
+  it('keeps a confirmed save in cache when alarm sync fails', async () => {
+    syncForSchedule.mockRejectedValueOnce(new Error('permission denied'));
+
+    await expect(service.saveDraft(makeDraft({ title: '已保存会议' }))).rejects.toThrow(
+      '日程已保存到服务端，但系统提醒同步失败：permission denied',
+    );
+
+    expect(service.getItems()).toEqual([
+      expect.objectContaining({ id: 'schedule_auto', title: '已保存会议', status: 'scheduled' }),
+    ]);
+  });
+
   it('toggles done through updateStatus and re-arms on undo', async () => {
     syncForSchedule.mockResolvedValue('alarm_old');
     await service.saveDraft(
@@ -176,6 +188,34 @@ describe('ScheduleService', () => {
     expect(service.getItems()[0]?.system_schedule_ref_id).toBeNull();
   });
 
+  it('keeps a confirmed status update when alarm cancellation fails', async () => {
+    const schedule = makeSchedule({ id: 'toggle-failed', system_schedule_ref_id: 'alarm-1' });
+    cache.replaceAll([schedule]);
+    cancel.mockRejectedValueOnce(new Error('native alarm unavailable'));
+
+    await expect(service.toggleDone(schedule)).rejects.toThrow(
+      '日程状态已在服务端更新，但系统提醒同步失败',
+    );
+
+    expect(service.getItems()[0]).toEqual(
+      expect.objectContaining({ status: 'done', system_schedule_ref_id: 'alarm-1' }),
+    );
+  });
+
+  it('keeps a confirmed deletion when alarm cancellation fails', async () => {
+    const schedule = makeSchedule({ id: 'delete-failed', system_schedule_ref_id: 'alarm-2' });
+    cache.replaceAll([schedule]);
+    cancel.mockRejectedValueOnce(new Error('native alarm unavailable'));
+
+    await expect(service.deleteSchedule(schedule)).rejects.toThrow(
+      '日程已在服务端删除，但系统提醒取消失败',
+    );
+
+    expect(service.getItems()[0]).toEqual(
+      expect.objectContaining({ status: 'deleted', system_schedule_ref_id: 'alarm-2' }),
+    );
+  });
+
   it('keeps the alarm reference returned by the platform adapter', async () => {
     cancel.mockResolvedValue('remote_alarm');
     cache.replaceAll([makeSchedule({ id: 'remote', system_schedule_ref_id: 'local_alarm' })]);
diff --git a/frontend/__tests__/features/schedule/location/MapPicker/baidu/baiduMapWebView.test.ts b/frontend/__tests__/features/schedule/location/MapPicker/baidu/baiduMapWebView.test.ts
index e52aeda..fdb0007 100644
--- a/frontend/__tests__/features/schedule/location/MapPicker/baidu/baiduMapWebView.test.ts
+++ b/frontend/__tests__/features/schedule/location/MapPicker/baidu/baiduMapWebView.test.ts
@@ -22,4 +22,16 @@ describe('buildBaiduMapDocument', () => {
     expect(html).toContain('121.2');
     expect(html).toContain('办公室');
   });
+
+  it('escapes initial location data for the inline script context', () => {
+    const html = buildBaiduMapDocument('ak', {
+      address: '</script><script>window.pwned = "&"</script>',
+      latitude: 31.1,
+      longitude: 121.2,
+    });
+
+    expect(html).not.toContain('</script><script>window.pwned');
+    expect(html).toContain('\\u003c/script\\u003e\\u003cscript\\u003e');
+    expect(html).toContain('\\u0026');
+  });
 });
diff --git a/frontend/src/dev/fakes/FakeWsServer.ts b/frontend/src/dev/fakes/FakeWsServer.ts
index 136323e..4ee44f5 100644
--- a/frontend/src/dev/fakes/FakeWsServer.ts
+++ b/frontend/src/dev/fakes/FakeWsServer.ts
@@ -35,6 +35,7 @@ type FakeWsServerOptions = {
  */
 export class FakeWsServer {
   private readonly schedules = new Map<string, Schedule>();
+  private readonly voiceStreams = new Map<string, { jobId: string; startRequestId: string }>();
   private readonly userId: string;
   private client: WsClient | null = null;
   private voiceJobCounter = 0;
@@ -216,6 +217,7 @@ export class FakeWsServer {
     this.voiceJobCounter += 1;
     const streamId = `stream_${this.voiceJobCounter}`;
     const jobId = `job_${this.voiceJobCounter}`;
+    this.voiceStreams.set(streamId, { jobId, startRequestId: message.request_id });
     const response: VoiceStreamStartResponse = {
       type: 'voice.stream.started',
       request_id: message.request_id,
@@ -226,14 +228,28 @@ export class FakeWsServer {
   }
 
   private handleVoiceEnd(message: VoiceStreamEndCommand): void {
-    const jobId = `job_${this.voiceJobCounter || 1}`;
+    const stream = this.voiceStreams.get(message.payload.stream_id);
+    if (!stream) {
+      this.reply({
+        type: 'voice.stream.error',
+        request_id: message.request_id,
+        ok: false,
+        error: {
+          code: 'stream_not_found',
+          message: '语音流不存在或已结束',
+          details: null,
+        },
+      });
+      return;
+    }
+    this.voiceStreams.delete(message.payload.stream_id);
     const response: VoiceStreamEndResponse = {
       type: 'voice.stream.ended',
       request_id: message.request_id,
       ok: true,
       payload: {
         stream_id: message.payload.stream_id,
-        job_id: jobId,
+        job_id: stream.jobId,
         status: 'processing',
       },
     };
@@ -241,8 +257,8 @@ export class FakeWsServer {
 
     const parseResult: VoiceParseResultMessage = {
       type: 'voice.parse.result',
-      request_id: message.request_id,
-      job_id: jobId,
+      request_id: stream.startRequestId,
+      job_id: stream.jobId,
       status: 'ready_for_confirmation',
       draft: {
         schedule_type: 'time',
@@ -260,6 +276,7 @@ export class FakeWsServer {
   }
 
   private handleVoiceCancel(message: VoiceStreamCancelCommand): void {
+    this.voiceStreams.delete(message.payload.stream_id);
     this.reply({
       type: 'voice.stream.cancelled',
       request_id: message.request_id,
diff --git a/frontend/src/features/assistant/hooks/useAssistantSession.ts b/frontend/src/features/assistant/hooks/useAssistantSession.ts
index 70ffe13..d950120 100644
--- a/frontend/src/features/assistant/hooks/useAssistantSession.ts
+++ b/frontend/src/features/assistant/hooks/useAssistantSession.ts
@@ -46,14 +46,6 @@ function formatClarificationLabel(result: VoiceParseOutcome): string | undefined
   return parts.length > 0 ? parts.join('；') : undefined;
 }
 
-const unavailableRecorder: VoiceRecorder = {
-  async start() {
-    throw new Error('录音适配器未注入');
-  },
-  async stop() {},
-  async cancel() {},
-};
-
 type ActiveVoiceStream = {
   streamId: string;
   jobId: string;
@@ -75,14 +67,14 @@ async function cancelVoiceStream(stream: ActiveVoiceStream): Promise<void> {
 export function useAssistantSession(options: {
   client: VoiceTransport | null;
   onConfirmDraft: (draft: VoiceParseDraft) => Promise<void>;
-  /** App/native hosts may inject an Expo Audio backed recorder. */
-  recorder?: VoiceRecorder;
+  /** The app host must inject a production PCM recorder for its platform. */
+  recorder: VoiceRecorder;
 }) {
   const voice = useMemo(
     () => (options.client ? new WsVoiceStreamPort(options.client) : null),
     [options.client],
   );
-  const recorder = useMemo(() => options.recorder ?? unavailableRecorder, [options.recorder]);
+  const recorder = options.recorder;
   const [messages, setMessages] = useState<AssistantMessage[]>([]);
   const [isProcessing, setIsProcessing] = useState(false);
   const activeStreamRef = useRef<ActiveVoiceStream | null>(null);
diff --git a/frontend/src/features/schedule/application/ScheduleService.ts b/frontend/src/features/schedule/application/ScheduleService.ts
index 67eb74f..91a7b27 100644
--- a/frontend/src/features/schedule/application/ScheduleService.ts
+++ b/frontend/src/features/schedule/application/ScheduleService.ts
@@ -17,6 +17,17 @@ export type ScheduleServiceDeps = {
   notifyConflicts?: ScheduleConflictNotifier;
 };
 
+export class ScheduleAlarmSyncError extends Error {
+  readonly alarmCause: unknown;
+
+  constructor(message: string, cause: unknown) {
+    const detail = cause instanceof Error ? `：${cause.message}` : '';
+    super(`${message}${detail}`);
+    this.name = 'ScheduleAlarmSyncError';
+    this.alarmCause = cause;
+  }
+}
+
 export class ScheduleService {
   private readonly alarm: AlarmPort;
   private pushUnsubscribe: (() => void) | null = null;
@@ -87,26 +98,33 @@ export class ScheduleService {
 
     const scheduleId = response.payload.schedule_id;
 
-    const offsetMinutes = draft.time_remind_offset_minutes ?? 0;
-    const syncedSystemScheduleRefId = await this.alarm.syncForSchedule({
-      scheduleType: draft.schedule_type,
-      title: draft.title,
-      startTime: draft.start_time ?? null,
-      offsetMinutes,
-      previousAlarmId: existing?.system_schedule_ref_id ?? null,
-      shouldArm: response.payload.status === 'scheduled',
-    });
-
-    const entity = scheduleFromUpsertPayload({
+    const confirmedEntity = scheduleFromUpsertPayload({
       draft: { ...draft, schedule_id: scheduleId },
       scheduleId,
       userId,
       status: response.payload.status,
       geofenceArmed: response.payload.geofence_armed,
       existing,
-      systemScheduleRefId: syncedSystemScheduleRefId,
+      systemScheduleRefId: existing?.system_schedule_ref_id ?? null,
     });
+    this.deps.cache.upsert(confirmedEntity);
+
+    const offsetMinutes = draft.time_remind_offset_minutes ?? 0;
+    let syncedSystemScheduleRefId: string | null;
+    try {
+      syncedSystemScheduleRefId = await this.alarm.syncForSchedule({
+        scheduleType: draft.schedule_type,
+        title: draft.title,
+        startTime: draft.start_time ?? null,
+        offsetMinutes,
+        previousAlarmId: existing?.system_schedule_ref_id ?? null,
+        shouldArm: response.payload.status === 'scheduled',
+      });
+    } catch (error) {
+      throw new ScheduleAlarmSyncError('日程已保存到服务端，但系统提醒同步失败', error);
+    }
 
+    const entity = { ...confirmedEntity, system_schedule_ref_id: syncedSystemScheduleRefId };
     this.deps.cache.upsert(entity);
     return entity;
   }
@@ -120,21 +138,34 @@ export class ScheduleService {
       throw new Error(response.error.message);
     }
 
+    const confirmedEntity = withStatus(
+      schedule,
+      response.payload.status,
+      schedule.system_schedule_ref_id,
+    );
+    this.deps.cache.upsert(confirmedEntity);
+
     let systemScheduleRefId = schedule.system_schedule_ref_id;
-    if (nextStatus === 'done') {
-      systemScheduleRefId = await this.alarm.cancel(systemScheduleRefId);
-    } else {
-      systemScheduleRefId = await this.alarm.syncForSchedule({
-        scheduleType: schedule.schedule_type,
-        title: schedule.title,
-        startTime: schedule.start_time,
-        offsetMinutes: schedule.time_remind_offset_minutes,
-        previousAlarmId: schedule.system_schedule_ref_id,
-        shouldArm: true,
-      });
+    try {
+      if (nextStatus === 'done') {
+        systemScheduleRefId = await this.alarm.cancel(systemScheduleRefId);
+      } else {
+        systemScheduleRefId = await this.alarm.syncForSchedule({
+          scheduleType: schedule.schedule_type,
+          title: schedule.title,
+          startTime: schedule.start_time,
+          offsetMinutes: schedule.time_remind_offset_minutes,
+          previousAlarmId: schedule.system_schedule_ref_id,
+          shouldArm: true,
+        });
+      }
+    } catch (error) {
+      throw new ScheduleAlarmSyncError('日程状态已在服务端更新，但系统提醒同步失败', error);
     }
 
-    this.deps.cache.upsert(withStatus(schedule, response.payload.status, systemScheduleRefId));
+    this.deps.cache.upsert(
+      withStatus(confirmedEntity, response.payload.status, systemScheduleRefId),
+    );
   }
 
   async deleteSchedule(schedule: Schedule): Promise<void> {
@@ -143,7 +174,14 @@ export class ScheduleService {
     if (!response.ok) {
       throw new Error(response.error.message);
     }
-    const systemScheduleRefId = await this.alarm.cancel(schedule.system_schedule_ref_id);
-    this.deps.cache.upsert(markDeleted(schedule, systemScheduleRefId));
+    const confirmedEntity = markDeleted(schedule, schedule.system_schedule_ref_id);
+    this.deps.cache.upsert(confirmedEntity);
+    let systemScheduleRefId: string | null;
+    try {
+      systemScheduleRefId = await this.alarm.cancel(schedule.system_schedule_ref_id);
+    } catch (error) {
+      throw new ScheduleAlarmSyncError('日程已在服务端删除，但系统提醒取消失败', error);
+    }
+    this.deps.cache.upsert(markDeleted(confirmedEntity, systemScheduleRefId));
   }
 }
diff --git a/frontend/src/features/schedule/location/MapPicker/baidu/baiduMapWebView.ts b/frontend/src/features/schedule/location/MapPicker/baidu/baiduMapWebView.ts
index 0fe20a2..140c259 100644
--- a/frontend/src/features/schedule/location/MapPicker/baidu/baiduMapWebView.ts
+++ b/frontend/src/features/schedule/location/MapPicker/baidu/baiduMapWebView.ts
@@ -9,14 +9,23 @@ export type BaiduMapBridgeMessage =
   | { results: MapLocation[]; type: 'search-results' }
   | { type: 'search-error' };
 
+function serializeForInlineScript(value: unknown) {
+  return JSON.stringify(value)
+    .replace(/</g, '\\u003c')
+    .replace(/>/g, '\\u003e')
+    .replace(/&/g, '\\u0026')
+    .replace(/\u2028/g, '\\u2028')
+    .replace(/\u2029/g, '\\u2029');
+}
+
 export function buildBaiduMapDocument(ak: string, initialLocation: MapLocation | null) {
   const center = initialLocation ?? {
     address: '上海市 · 默认地图中心',
     latitude: 31.236305,
     longitude: 121.480237,
   };
-  const initialJson = JSON.stringify(initialLocation);
-  const centerJson = JSON.stringify(center);
+  const initialJson = serializeForInlineScript(initialLocation);
+  const centerJson = serializeForInlineScript(center);
 
   return `<!doctype html>
 <html lang="zh-CN">