From c6226bd92f6abe9270c3ffef247237bd3cad3e61 Mon Sep 17 00:00:00 2001 From: ioito Date: Tue, 1 Aug 2023 17:00:50 +0800 Subject: [PATCH] fix(notify): optimized event query --- pkg/notify/models/event.go | 14 ++++++++++++-- 1 file changed, 12 insertions(+), 2 deletions(-) diff --git a/pkg/notify/models/event.go b/pkg/notify/models/event.go index af278bebcb..0e94e7ca37 100644 --- a/pkg/notify/models/event.go +++ b/pkg/notify/models/event.go @@ -16,8 +16,11 @@ package models import ( "context" + "strconv" "time" + "yunion.io/x/pkg/errors" + "yunion.io/x/onecloud/pkg/cloudcommon/consts" "yunion.io/x/onecloud/pkg/cloudcommon/db" ) @@ -66,11 +69,18 @@ func (e *SEventManager) CreateEvent(ctx context.Context, event, topicId, message } func (e *SEventManager) GetEvent(id string) (*SEvent, error) { - model, err := e.FetchById(id) + event := &SEvent{} + event.SetModelManager(EventManager, event) + eventId, err := strconv.Atoi(id) + if err != nil { + return nil, errors.Wrapf(err, "Atoi(%s)", id) + } + event.Id = int64(eventId) + err = EventManager.GetSplitTable().Fetch(event) if err != nil { return nil, err } - return model.(*SEvent), nil + return event, nil } func (e *SEvent) GetRecordTime() time.Time {