From f86afcf9c1b71503fc95302a5cbec1417e63f520 Mon Sep 17 00:00:00 2001 From: summer <> Date: Thu, 30 Oct 2025 17:06:49 +0800 Subject: [PATCH] =?UTF-8?q?feat(1.0):=E8=B0=83=E6=95=B4=E5=B7=B2=E8=AF=BB?= =?UTF-8?q?=E7=9A=84=E8=8A=82=E7=82=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/api/app/app_message_list.go | 18 ++++++++++-------- 1 file changed, 10 insertions(+), 8 deletions(-) diff --git a/internal/api/app/app_message_list.go b/internal/api/app/app_message_list.go index 01359f3..4cbff8a 100644 --- a/internal/api/app/app_message_list.go +++ b/internal/api/app/app_message_list.go @@ -110,14 +110,16 @@ func (h *handler) AppMessagePageList() core.HandlerFunc { return } - _, err = h.writeDB.AppMessageLog.WithContext(ctx.RequestContext()). - Where(h.writeDB.AppMessageLog.AppID.Eq(req.AppID)). - Where(h.writeDB.AppMessageLog.SenderID.Eq(req.UserID)).Or(h.readDB.AppMessageLog.ReceiverID.Eq(req.UserID)). - Where(h.writeDB.AppMessageLog.IsRead.Eq(0)). - Update(h.writeDB.AppMessageLog.IsRead, 1) - if err != nil { - h.logger.Error(fmt.Sprintf("[AppMessagePageList] update app message log error: %s", err.Error())) - } + go func() { + _, err = h.writeDB.AppMessageLog. + Where(h.writeDB.AppMessageLog.AppID.Eq(req.AppID)). + Where(h.writeDB.AppMessageLog.SenderID.Eq(req.UserID)).Or(h.readDB.AppMessageLog.ReceiverID.Eq(req.UserID)). + Where(h.writeDB.AppMessageLog.IsRead.Eq(0)). + Update(h.writeDB.AppMessageLog.IsRead, 1) + if err != nil { + h.logger.Error(fmt.Sprintf("[AppMessagePageList] update app message log error: %s", err.Error())) + } + }() res.Page = req.Page res.PageSize = req.PageSize