diff --git a/internal/api/app/app_latest_messages.go b/internal/api/app/app_latest_messages.go index 91fb2fd..3afe765 100644 --- a/internal/api/app/app_latest_messages.go +++ b/internal/api/app/app_latest_messages.go @@ -132,14 +132,14 @@ func (h *handler) LatestMessageByAppId() core.HandlerFunc { } // 自动标记该appid下的所有消息为已读(管理端访问时) - _, err := h.writeDB.AppMessageLog.WithContext(ctx.RequestContext()). - Where(h.writeDB.AppMessageLog.AppID.Eq(req.AppID)). - Where(h.writeDB.AppMessageLog.IsRead.Eq(0)). - Update(h.writeDB.AppMessageLog.IsRead, 1) - if err != nil { - // 记录错误但不影响查询结果 - // TODO: 可以添加日志记录 - } + //_, err := h.writeDB.AppMessageLog.WithContext(ctx.RequestContext()). + // Where(h.writeDB.AppMessageLog.AppID.Eq(req.AppID)). + // Where(h.writeDB.AppMessageLog.IsRead.Eq(0)). + // Update(h.writeDB.AppMessageLog.IsRead, 1) + //if err != nil { + // // 记录错误但不影响查询结果 + // // TODO: 可以添加日志记录 + //} res.Page = req.Page res.PageSize = req.PageSize diff --git a/internal/api/app/app_message_list.go b/internal/api/app/app_message_list.go index 26a2669..6a283b4 100644 --- a/internal/api/app/app_message_list.go +++ b/internal/api/app/app_message_list.go @@ -110,6 +110,15 @@ 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)). + 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 res.Total = count