diff --git a/apps/miniprogram/src/pages/messages/index.tsx b/apps/miniprogram/src/pages/messages/index.tsx
index adb5126..6253c76 100644
--- a/apps/miniprogram/src/pages/messages/index.tsx
+++ b/apps/miniprogram/src/pages/messages/index.tsx
@@ -2,6 +2,7 @@ import { useState } from 'react';
 import { View, Text } from '@tarojs/components';
 import Taro, { useDidShow } from '@tarojs/taro';
 import { listConsultations, ConsultationSession } from '../../services/consultation';
+import { notificationService } from '../../services/notification';
 import Loading from '../../components/Loading';
 import './index.scss';
 
@@ -32,9 +33,8 @@ export default function Messages() {
         const res = await listConsultations({ page: 1, page_size: 20 });
         setSessions(res.data || []);
       } else {
-        // 通知目前从咨询中提取状态变化作为示例
-        // 后续可对接独立通知 API
-        setNotifications([]);
+        const res = await notificationService.list<{ data: unknown[] }>({ page: 1, page_size: 20 });
+        setNotifications((res as { data?: unknown[] })?.data || []);
       }
     } catch {
       if (tab === 'consultation') setSessions([]);
diff --git a/apps/miniprogram/src/services/notification.ts b/apps/miniprogram/src/services/notification.ts
new file mode 100644
index 0000000..50cb0e9
--- /dev/null
+++ b/apps/miniprogram/src/services/notification.ts
@@ -0,0 +1,12 @@
+import { api } from './request';
+
+export const notificationService = {
+  list: (params?: { page?: number; page_size?: number }) =>
+    api.get('/messages', params as Record<string, string | number | undefined>),
+  markRead: (id: string) =>
+    api.put(`/messages/${id}/read`),
+  markAllRead: () =>
+    api.put('/messages/read-all'),
+  getUnreadCount: () =>
+    api.get('/messages/unread-count'),
+};