diff --git a/internal/rpc/group/group.go b/internal/rpc/group/group.go index 3ddd9cc22..778316e5c 100644 --- a/internal/rpc/group/group.go +++ b/internal/rpc/group/group.go @@ -1207,9 +1207,10 @@ func (s *groupServer) SetGroupInfoEx(ctx context.Context, req *pbgroup.SetGroupI log.ZWarn(ctx, "GetGroupMemberIDs is failed.", err) return nil, err } - + // use temp admin permission to force success. + adminCtx := mcontext.WithOpUserIDContext(ctx, s.config.Share.IMAdminUserID[0]) conversation.GroupAtType = &wrapperspb.Int32Value{Value: constant.GroupNotification} - if err := s.conversationClient.SetConversations(ctx, resp.UserIDs, conversation); err != nil { + if err := s.conversationClient.SetConversations(adminCtx, resp.UserIDs, conversation); err != nil { log.ZWarn(ctx, "SetConversations", err, "UserIDs", resp.UserIDs, "conversation", conversation) } diff --git a/internal/rpc/msg/send.go b/internal/rpc/msg/send.go index c93f18148..f9e7428dd 100644 --- a/internal/rpc/msg/send.go +++ b/internal/rpc/msg/send.go @@ -87,8 +87,9 @@ func (m *msgServer) setConversationAtInfo(nctx context.Context, msg *sdkws.MsgDa } }() + // template admin permission for next operation ctx := mcontext.NewCtx("@@@" + mcontext.GetOperationID(nctx)) - + ctx = mcontext.WithOpUserIDContext(ctx, m.config.Share.IMAdminUserID[0]) var atUserID []string conversation := &pbconversation.ConversationReq{