feat(1.0):调整已读的节点

This commit is contained in:
summer 2025-10-30 17:06:49 +08:00
parent 3e78590fff
commit 2213817a5a

View File

@ -110,14 +110,16 @@ func (h *handler) AppMessagePageList() core.HandlerFunc {
return return
} }
_, err = h.writeDB.AppMessageLog.WithContext(ctx.RequestContext()). go func() {
Where(h.writeDB.AppMessageLog.AppID.Eq(req.AppID)). _, err = h.writeDB.AppMessageLog.
Where(h.writeDB.AppMessageLog.SenderID.Eq(req.UserID)).Or(h.readDB.AppMessageLog.ReceiverID.Eq(req.UserID)). Where(h.writeDB.AppMessageLog.AppID.Eq(req.AppID)).
Where(h.writeDB.AppMessageLog.IsRead.Eq(0)). Where(h.writeDB.AppMessageLog.SenderID.Eq(req.UserID)).Or(h.readDB.AppMessageLog.ReceiverID.Eq(req.UserID)).
Update(h.writeDB.AppMessageLog.IsRead, 1) Where(h.writeDB.AppMessageLog.IsRead.Eq(0)).
if err != nil { Update(h.writeDB.AppMessageLog.IsRead, 1)
h.logger.Error(fmt.Sprintf("[AppMessagePageList] update app message log error: %s", err.Error())) if err != nil {
} h.logger.Error(fmt.Sprintf("[AppMessagePageList] update app message log error: %s", err.Error()))
}
}()
res.Page = req.Page res.Page = req.Page
res.PageSize = req.PageSize res.PageSize = req.PageSize