wishpal_ironfan
/
service
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

by Robin at 20241203

This commit is contained in:
Robin 2024-12-03 17:25:40 +08:00
parent 0c6545087b
commit 1c3f6940dc
3 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
app/mix/dao/mongo.go
View File

@ -6622,7 +6622,7 @@ func (m *Mongo) ReadNotifReceiveByIds(ctx *gin.Context, req *notificationproto.A
return result, err
}
func (m *Mongo) ReadAllNotifReceive(ctx *gin.Context, nType int64) (*qmgo.UpdateResult, error) {
func (m *Mongo) ReadAllNotifReceive(ctx *gin.Context, mid, nType int64) (*qmgo.UpdateResult, error) {
col := m.getColNotifReceive()
update := qmgo.M{
"$set": qmgo.M{
@ -6630,6 +6630,7 @@ func (m *Mongo) ReadAllNotifReceive(ctx *gin.Context, nType int64) (*qmgo.Update
},
}
filter := qmgo.M{
"obj_mid": mid,
"is_read": consts.NotifReceive_NotRead,
"n_type": nType,
}

2
app/mix/service/apiservice.go
View File

@ -4706,7 +4706,7 @@ func (s *Service) ApiReadAllNotification(ctx *gin.Context, req *notificationprot
for _, nType := range req.NTypes {
// 标记已读
result, err := _DefaultNotifReceive.OpReadAll(ctx, nType)
result, err := _DefaultNotifReceive.OpReadAll(ctx, req.BaseRequest.Mid, nType)
if err != nil {
logger.Error("_DefaultNotifReceive OpReadAll fail, req: %v, err: %v", util.ToJson(req), err)
ec = errcode.ErrCodeNotificationSrvFail

4
app/mix/service/logic/notif_receive.go
View File

@ -54,8 +54,8 @@ func (p *NotifReceive) OpReadByIds(ctx *gin.Context, req *notificationproto.ApiR
return result, nil
}
func (p *NotifReceive) OpReadAll(ctx *gin.Context, nType int64) (*qmgo.UpdateResult, error) {
result, err := p.store.ReadAllNotifReceive(ctx, nType)
func (p *NotifReceive) OpReadAll(ctx *gin.Context, mid, nType int64) (*qmgo.UpdateResult, error) {
result, err := p.store.ReadAllNotifReceive(ctx, mid, nType)
if err != nil {
logger.Error("ReadAllNotifReceive fail, err: %v", err)
return nil, err