diff --git a/controllers/event_controller.go b/controllers/event_controller.go index 93b2799f8..f41121624 100644 --- a/controllers/event_controller.go +++ b/controllers/event_controller.go @@ -180,8 +180,15 @@ func handleMessages() { // @router /GetImMessageRecord [get] func (c *EventController) GetImMessageRecord() { c.callGetImMessageRecord(func(params *tEventGetImMessageRecordParams) (retVal interface{}, errCode string, err error) { - retVal, err = dao.GetImMessageRecord(dao.GetDB(), params.GroupID, "", 0, -1, utils.Str2Time(params.FromTime), utils.Str2Time(params.ToTime), params.Offset, params.PageSize) + var db = dao.GetDB() + retVal, err = dao.GetImMessageRecord(db, params.GroupID, "", 0, -1, utils.Str2Time(params.FromTime), utils.Str2Time(params.ToTime), params.Offset, params.PageSize) //清除此用户组所有的未读标记 + if messageGroupReads, err := dao.GetMessageGroupRead(db, params.Ctx.GetUserID(), params.GroupID); err == nil { + for _, v := range messageGroupReads { + v.UnReadCount = 0 + dao.UpdateEntity(db, v, "UnReadCount") + } + } return retVal, "", err }) }