-
-
no-notice
-
- {{ $t('notify_no_notice') }}
-
-
+
+ {{
+ t('notification_bell_title', [unRead > 99 ? '99+' : unRead])
+ }}
+
+ {{ t('notification_record_mark_all_read') }}
+
+
+
+
-
-
-
- {{ $t('daas_notification_center_yonghucaozuo') }}
-
-
-
-
-
-
no-notice
-
- {{ $t('notify_view_more') }}
-
-
+
+ {{ record.taskName }} · {{ fmt(record.latestNotifyTime) }}
-
-
-
-
- {{
- $t('daas_notification_alarmnotification_gaojingtongzhi')
- }}
-
-
-
- -
-
-
-
-
-
- 【{{ item.title }}】
-
- {{ item.title }}
-
-
-
-
-
-
-
no-notice
-
- {{ $t('notify_no_notice') }}
-
-
+
+
+
+
+
no-notice
+
+ {{ t('notify_no_notice') }}
-
-
+
+
+
+ {{
+ t('notification_view_all_records')
+ }}
+
+
-
-
diff --git a/apps/daas/src/views/notification/NotificationRecordDrawer.vue b/apps/daas/src/views/notification/NotificationRecordDrawer.vue
new file mode 100644
index 0000000000..e3fb8cb32c
--- /dev/null
+++ b/apps/daas/src/views/notification/NotificationRecordDrawer.vue
@@ -0,0 +1,279 @@
+
+
+
+
+
+
+ {{ detail.title }}
+
+ {{
+ ALARM_LEVEL_MAP[detail.level]?.text || detail.level
+ }}
+
+ {{ t('notification_record_others') }}
+
+
+ {{
+ detail.unread
+ ? t('notification_record_unread')
+ : t('notification_record_read')
+ }}
+
+ {{ t('notification_record_read_at') }}：{{
+ fmt(detail.readAt)
+ }}
+ {{
+ t('notification_record_others_hint')
+ }}
+
+ {{
+ detail.unread
+ ? t('notification_record_mark_read')
+ : t('notification_record_mark_unread')
+ }}
+
+
+
+
+
+ {{ detail.taskName || '-' }}
+
+
+ {{
+ (detail.metric && alarmKeyMap[detail.metric]) ||
+ detail.metric ||
+ '-'
+ }}
+
+
+ {{ fmt(detail.firstOccurrenceTime) }}
+
+
+ {{ fmt(detail.lastOccurrenceTime) }}
+
+
+ {{ detail.occurrenceCount ?? '-' }}
+
+
+ {{ fmt(detail.latestNotifyTime) }}
+
+
+ {{ detail.alarmEventId || '-' }}
+
+
+
+
+ {{ t('alarm_event_go_task') }}
+
+
+ {{ t('notification_record_view_alarm') }}
+
+ {{
+ t('notification_record_alarm_missing')
+ }}
+
+
+
+
{{ t('notification_record_deliveries') }}
+
+
+
+
+
+ {{ fmt(batch.time) }}
+
+ ·
+ {{
+ t('notification_record_occurrence_snapshot', [
+ batch.occurrenceCountSnapshot,
+ ])
+ }}
+
+
+
+
+ {{
+ t(`delivery_channel_${row.channel.toLowerCase()}`)
+ }}
+
+
+ {{ row.address || '-' }}
+
+
+
+
+ {{ t(`delivery_recipient_${row.status.toLowerCase()}`) }}
+
+
+
+
+ {{ fmt(row.sentAt) }}
+
+
+
+ {{
+ row.failureMessage ||
+ (row.skipReason
+ ? t(`delivery_skip_${row.skipReason.toLowerCase()}`)
+ : '-')
+ }}
+
+
+
+
+ {{ t('notification_record_smtp_hint') }}
+
+
+
diff --git a/apps/daas/src/views/notification/NotificationRecords.vue b/apps/daas/src/views/notification/NotificationRecords.vue
new file mode 100644
index 0000000000..3194962c9e
--- /dev/null
+++ b/apps/daas/src/views/notification/NotificationRecords.vue
@@ -0,0 +1,383 @@
+
+
+
+
+
+
+ {{ $t('notification_record_mark_read') }}
+
+
+ {{ $t('notification_record_mark_unread') }}
+
+
+ {{ $t('notification_record_mark_all_read') }}
+
+
+ {{ $t('notify_setting') }}
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ {{
+ row.levelLabel
+ }}
+
+
+
+
+
+ {{ row.title }}
+
+
+ {{ $t('notification_record_legacy') }}
+
+
+ {{ $t('notification_record_alarm_missing') }}
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ {{
+ $t('public_button_details')
+ }}
+
+
+
+ {{
+ row.unread
+ ? $t('notification_record_mark_read')
+ : $t('notification_record_mark_unread')
+ }}
+
+
+
+
+
+
+
+
+
+
diff --git a/apps/daas/src/views/role/Role.vue b/apps/daas/src/views/role/Role.vue
index adb9862e12..1cfe5d9198 100644
--- a/apps/daas/src/views/role/Role.vue
+++ b/apps/daas/src/views/role/Role.vue
@@ -24,6 +24,8 @@ const MODULE_ICONS: Record
= {
v2_data_pipeline: 'migrate',
v2_advanced_features: 'vip-one',
'v2_data-server': 'apiServer_navbar',
+ 'v2_ops-center': 'warning',
+ 'v2_message-center': 'notice-system-notice',
'v2_system-management': 'setting',
}
@@ -428,6 +430,25 @@ const pageSort = [
},
],
},
+ {
+ name: 'v2_ops-center',
+ children: [
+ {
+ name: 'v2_alarm_event',
+ buttons: [
+ {
+ label: t('public_button_close'),
+ name: 'v2_alarm_event_ack_close',
+ checked: false,
+ },
+ ],
+ },
+ ],
+ },
+ {
+ name: 'v2_message-center',
+ children: [{ name: 'v2_notification_record' }],
+ },
{
name: 'v2_system-management',
children: [
@@ -458,6 +479,7 @@ const pageSort = [
],
},
{ name: 'v2_role_management' },
+ { name: 'v2_audit_log' },
],
},
]
diff --git a/apps/daas/src/views/setting/NotificationSetting.vue b/apps/daas/src/views/setting/NotificationSetting.vue
index 629073735b..4adff733de 100644
--- a/apps/daas/src/views/setting/NotificationSetting.vue
+++ b/apps/daas/src/views/setting/NotificationSetting.vue
@@ -70,6 +70,20 @@ export default {
type="info"
show-icon
/>
+
+ {{ $t('alarm_event_open_setting') }}
+
{{ notificationMAP[item.label] }}
- {{
- $t('notify_system_notice')
- }}
+
{{
@@ -162,9 +174,7 @@ export default {
-
{{ notificationMAP[item.label] }}
- {{
- $t('notify_system_notice')
- }}
+
@@ -177,9 +187,7 @@ export default {
-
{{ notificationMAP[item.label] }}
- {{
- $t('notify_system_notice')
- }}
+
diff --git a/packages/api/src/core/alarm.ts b/packages/api/src/core/alarm.ts
index 432006495e..7f8ad87b40 100644
--- a/packages/api/src/core/alarm.ts
+++ b/packages/api/src/core/alarm.ts
@@ -229,3 +229,106 @@ export function fetchAlarmReceiverPreview(taskId: string) {
{ params: { taskId } },
)
}
+
+/* ---------- 告警事件（TAP-13052） ---------- */
+
+export type AlarmObjectType =
+ | 'TASK'
+ | 'NODE'
+ | 'CONNECTION'
+ | 'AGENT'
+ | 'INSPECT'
+ | 'API_SERVER'
+
+export interface DeliveryChannelSummary {
+ total: number
+ success: number
+ failed: number
+ skipped: number
+}
+
+export interface DeliverySummary {
+ status: 'NONE' | 'SUCCESS' | 'PARTIAL_FAILED' | 'FAILED' | 'SKIPPED'
+ total: number
+ success: number
+ failed: number
+ skipped: number
+ channels: Notify[]
+ byChannel: Partial>
+ latestDeliveryTime?: string
+}
+
+export interface AlarmEvent {
+ id: string
+ level: string
+ status: 'ING' | 'RECOVER' | 'CLOESE'
+ metric: string
+ summary: string
+ objectType: AlarmObjectType
+ objectId?: string
+ objectName?: string
+ objectDeleted: boolean
+ taskId?: string
+ taskName?: string
+ syncType?: string
+ nodeId?: string
+ nodeName?: string
+ agentId?: string
+ connectionId?: string
+ inspectId?: string
+ serverId?: string
+ apiId?: string
+ currentValue?: number
+ threshold?: number
+ firstOccurrenceTime?: string
+ lastOccurrenceTime?: string
+ occurrenceCount?: number
+ recoveryTime?: string
+ closeTime?: string
+ closeBy?: string
+ /** 任务重新运行时由系统归档 */
+ archived?: boolean
+ lastNotifyTime?: string
+ deliverySummary?: DeliverySummary
+}
+
+export interface AlarmEventStats {
+ alarming: number
+ severe: number
+ todayNew: number
+ todayRecovered: number
+}
+
+/** 数组参数以逗号拼接，服务端按列表绑定 */
+export function joinListParams(params: Record = {}) {
+ const result: Record = {}
+ Object.entries(params).forEach(([key, value]) => {
+ if (value === undefined || value === null || value === '') return
+ if (Array.isArray(value)) {
+ if (value.length) result[key] = value.join(',')
+ return
+ }
+ result[key] = value
+ })
+ return result
+}
+
+export function listAlarmEvents(params: Record) {
+ return requestClient.get<{ total: number; items: AlarmEvent[] }>(
+ '/api/alarms',
+ { params: joinListParams(params) },
+ )
+}
+
+export function getAlarmEvent(id: string) {
+ return requestClient.get(`/api/alarms/${id}`)
+}
+
+export function getAlarmEventStats() {
+ return requestClient.get('/api/alarms/stats')
+}
+
+/** 关闭告警事件，需要告警关闭权限并写入操作审计 */
+export function closeAlarmEvents(ids: string[]) {
+ return requestClient.post('/api/alarms/close', ids)
+}
diff --git a/packages/api/src/core/notification.ts b/packages/api/src/core/notification.ts
index 3fd07df85a..25b5a1efbd 100644
--- a/packages/api/src/core/notification.ts
+++ b/packages/api/src/core/notification.ts
@@ -1,4 +1,5 @@
import { isPlainObj } from '@tap/shared'
+import { joinListParams, type DeliverySummary } from './alarm'
import {
requestClient,
type CountFetchResult,
@@ -84,3 +85,95 @@ export function updateNotification(where: any, attributes: any) {
attributes,
)
}
+
+/* ---------- 通知记录（TAP-13052） ---------- */
+
+const RECORD_URL = '/api/notifications'
+
+export interface NotificationRecord {
+ id: string
+ alarmEventId?: string
+ legacy: boolean
+ /** 关联告警事件已被清除（历史版本任务重新运行时删除） */
+ alarmEventMissing?: boolean
+ /** 记录中有发给当前用户的消息，才可标记已读/未读 */
+ readable: boolean
+ messageIds: string[]
+ title: string
+ level: string
+ metric?: string
+ alarmStatus?: string
+ objectType?: string
+ taskId?: string
+ taskName?: string
+ firstOccurrenceTime?: string
+ lastOccurrenceTime?: string
+ occurrenceCount?: number
+ notificationCount: number
+ unread: boolean
+ latestNotifyTime?: string
+ deliverySummary?: DeliverySummary
+}
+
+export interface NotificationRecipient {
+ channel: string
+ address?: string
+ status: 'SUCCESS' | 'FAILED' | 'SKIPPED'
+ sentAt?: string
+ failureMessage?: string
+ skipReason?: string
+}
+
+export interface NotificationBatch {
+ batchId: string
+ time?: string
+ occurrenceCountSnapshot?: number
+ recipients: NotificationRecipient[]
+}
+
+export interface NotificationRecordDetail extends NotificationRecord {
+ content: string
+ readAt?: string
+ batches: NotificationBatch[]
+}
+
+export function listNotificationRecords(params: Record) {
+ return requestClient.get<{ total: number; items: NotificationRecord[] }>(
+ RECORD_URL,
+ { params: joinListParams(params) },
+ )
+}
+
+export function getNotificationRecord(id: string) {
+ return requestClient.get(
+ `${RECORD_URL}/${encodeURIComponent(id)}`,
+ )
+}
+
+export function getUnreadNotificationCount() {
+ return requestClient.get(`${RECORD_URL}/unread-count`)
+}
+
+export function previewNotificationReadState(
+ params: Record,
+ read: boolean,
+) {
+ return requestClient.get<{
+ count: number
+ ids: string[]
+ truncated: boolean
+ }>(`${RECORD_URL}/read-state/preview`, {
+ params: { ...joinListParams(params), read },
+ })
+}
+
+export function updateNotificationReadState(ids: string[], read: boolean) {
+ return requestClient.patch(`${RECORD_URL}/read-state`, { ids, read })
+}
+
+export function updateOneNotificationReadState(id: string, read: boolean) {
+ return requestClient.patch(
+ `${RECORD_URL}/${encodeURIComponent(id)}/read-state`,
+ { read },
+ )
+}