diff --git a/internal/rpc/office/office.go b/internal/rpc/office/office.go index 674dcf773..ab9da950a 100644 --- a/internal/rpc/office/office.go +++ b/internal/rpc/office/office.go @@ -453,7 +453,7 @@ func (s *officeServer) CommentOneWorkMoment(_ context.Context, req *pbOffice.Com if req.UserID != workMoment.UserID { msg.WorkMomentSendNotification(req.OperationID, workMoment.UserID, workMomentNotificationMsg) } - if req.ReplyUserID != "" { + if req.ReplyUserID != "" && req.ReplyUserID != req.UserID { msg.WorkMomentSendNotification(req.OperationID, req.ReplyUserID, workMomentNotificationMsg) } log.NewInfo(req.OperationID, utils.GetSelfFuncName(), "resp: ", resp.String()) diff --git a/internal/rpc/user/user.go b/internal/rpc/user/user.go index 23423bcd4..f3e688588 100644 --- a/internal/rpc/user/user.go +++ b/internal/rpc/user/user.go @@ -389,6 +389,10 @@ func (s *userServer) UpdateUserInfo(ctx context.Context, req *pbUser.UpdateUserI log.Info(req.OperationID, "UserInfoUpdatedNotification ", req.UserInfo.UserID, v.FriendUser.UserID) chat.UserInfoUpdatedNotification(req.OperationID, req.UserInfo.UserID, v.FriendUser.UserID) } + + etcdConn := getcdv3.GetConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.OpenImFriendName) + client := pbFriend.NewFriendClient(etcdConn) + chat.UserInfoUpdatedNotification(req.OperationID, req.UserInfo.UserID, req.OpUserID) log.Info(req.OperationID, "UserInfoUpdatedNotification ", req.UserInfo.UserID, req.OpUserID) return &pbUser.UpdateUserInfoResp{CommonResp: &pbUser.CommonResp{}}, nil