From 1dd8491440cf584a0589ca881cc4544aba7e40cf Mon Sep 17 00:00:00 2001 From: douxu Date: Fri, 8 May 2026 16:19:12 +0800 Subject: [PATCH] refactor: replace EventStatusPersisted with IsPersisted field on EventRecord - add IsPersisted bool to EventRecord for explicit persistence tracking by eventRT consumer - remove EventStatusPersisted constant, decoupling DB persistence from event lifecycle status - update event status comments for accuracy and CIM-agnostic language --- constants/event.go | 10 ++++------ mq/event/event.go | 2 ++ 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/constants/event.go b/constants/event.go index e4ea62e..11dbf29 100644 --- a/constants/event.go +++ b/constants/event.go @@ -52,15 +52,13 @@ const ( const ( // EventStatusHappended define status for event record when event just happened, no data attached yet EventStatusHappended = iota - // EventStatusDataAttached define status for event record when event just happened, data attached already + // EventStatusDataAttached define status for event record when event data attached, ready to be sent EventStatusDataAttached - // EventStatusReported define status for event record when event reported to CIM, no matter it's successful or failed + // EventStatusReported define status for event record when event reported to downstream, no matter it's successful or failed EventStatusReported - // EventStatusConfirmed define status for event record when event confirmed by CIM, no matter it's successful or failed + // EventStatusConfirmed define status for event record when event confirmed by operator or CIM EventStatusConfirmed - // EventStatusPersisted define status for event record when event persisted in database, no matter it's successful or failed - EventStatusPersisted - // EventStatusClosed define status for event record when event closed, no matter it's successful or failed + // EventStatusClosed define status for event record when event closed due to condition recovery or manual close EventStatusClosed ) diff --git a/mq/event/event.go b/mq/event/event.go index 6740251..951242e 100644 --- a/mq/event/event.go +++ b/mq/event/event.go @@ -13,6 +13,8 @@ type EventRecord struct { Priority int `json:"priority"` // 事件状态 Status int `json:"status"` + // 是否已持久化到数据库，由 eventRT 消费并落库后置为 true + IsPersisted bool `json:"is_persisted"` // 可选模板参数 Category string `json:"category,omitempty"` // 毫秒级时间戳 (Unix epoch)