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

This commit is contained in:
summer 2025-10-21 18:30:28 +08:00
parent e61a293616
commit 366e9c16e0
2 changed files with 17 additions and 8 deletions

View File

@ -132,14 +132,14 @@ func (h *handler) LatestMessageByAppId() core.HandlerFunc {
} }
// 自动标记该appid下的所有消息为已读管理端访问时 // 自动标记该appid下的所有消息为已读管理端访问时
_, err := h.writeDB.AppMessageLog.WithContext(ctx.RequestContext()). //_, err := h.writeDB.AppMessageLog.WithContext(ctx.RequestContext()).
Where(h.writeDB.AppMessageLog.AppID.Eq(req.AppID)). // Where(h.writeDB.AppMessageLog.AppID.Eq(req.AppID)).
Where(h.writeDB.AppMessageLog.IsRead.Eq(0)). // Where(h.writeDB.AppMessageLog.IsRead.Eq(0)).
Update(h.writeDB.AppMessageLog.IsRead, 1) // Update(h.writeDB.AppMessageLog.IsRead, 1)
if err != nil { //if err != nil {
// 记录错误但不影响查询结果 // // 记录错误但不影响查询结果
// TODO: 可以添加日志记录 // // TODO: 可以添加日志记录
} //}
res.Page = req.Page res.Page = req.Page
res.PageSize = req.PageSize res.PageSize = req.PageSize

View File

@ -110,6 +110,15 @@ func (h *handler) AppMessagePageList() core.HandlerFunc {
return return
} }
_, err = h.writeDB.AppMessageLog.WithContext(ctx.RequestContext()).
Where(h.writeDB.AppMessageLog.AppID.Eq(req.AppID)).
Where(h.writeDB.AppMessageLog.SenderID.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.Page = req.Page
res.PageSize = req.PageSize res.PageSize = req.PageSize
res.Total = count res.Total = count