From e1147aff9e7fe5999e0e0bd76c83e7964926f3b2 Mon Sep 17 00:00:00 2001 From: Gordon <1432970085@qq.com> Date: Mon, 16 Jan 2023 13:26:14 +0800 Subject: [PATCH] user update --- internal/rpc/user/user.go | 22 +++++++++++----------- 1 file changed, 11 insertions(+), 11 deletions(-) diff --git a/internal/rpc/user/user.go b/internal/rpc/user/user.go index d89707c08..6dc493ccc 100644 --- a/internal/rpc/user/user.go +++ b/internal/rpc/user/user.go @@ -264,17 +264,17 @@ func (s *userServer) SetConversation(ctx context.Context, req *pbUser.SetConvers resp.CommonResp = &pbUser.CommonResp{ErrCode: constant.ErrDB.ErrCode, ErrMsg: errMsg} return resp, nil } - if req.Conversation.ConversationType == constant.SuperGroupChatType { - if req.Conversation.RecvMsgOpt == constant.ReceiveNotNotifyMessage { - if err = db.DB.SetSuperGroupUserNotRecvOfflineMsgOpt(req.Conversation.GroupID, v); err != nil { - log.NewError(req.OperationID, utils.GetSelfFuncName(), "cache failed, rpc return", err.Error(), req.Conversation.GroupID, v) - } - } else { - if err = db.DB.ReduceSuperGroupUserNotRecvOfflineMsgOpt(req.Conversation.GroupID, v); err != nil { - log.NewError(req.OperationID, utils.GetSelfFuncName(), "cache failed, rpc return", err.Error(), req.Conversation.GroupID, v) - } - } - } + //if req.Conversation.ConversationType == constant.SuperGroupChatType { + // if req.Conversation.RecvMsgOpt == constant.ReceiveNotNotifyMessage { + // if err = db.DB.SetSuperGroupUserNotRecvOfflineMsgOpt(req.Conversation.GroupID, v); err != nil { + // log.NewError(req.OperationID, utils.GetSelfFuncName(), "cache failed, rpc return", err.Error(), req.Conversation.GroupID, v) + // } + // } else { + // if err = db.DB.ReduceSuperGroupUserNotRecvOfflineMsgOpt(req.Conversation.GroupID, v); err != nil { + // log.NewError(req.OperationID, utils.GetSelfFuncName(), "cache failed, rpc return", err.Error(), req.Conversation.GroupID, v) + // } + // } + //} } var conversation db.Conversation