diff --git a/modules/chat/api_chanagechannel.go b/modules/chat/api_chanagechannel.go index 3b7f2620e..045d686b0 100644 --- a/modules/chat/api_chanagechannel.go +++ b/modules/chat/api_chanagechannel.go @@ -27,7 +27,7 @@ func (this *apiComp) ChanageChannel(session comm.IUserSession, req *pb.ChatChana return } if ok { - if err = this.module.modelChat.removeCrossChannelMember(session); err != nil { + if err = this.module.modelChat.removeCrossChannelMember(session.GetUserId()); err != nil { code = pb.ErrorCode_DBError return } diff --git a/modules/user/api_create.go b/modules/user/api_create.go index 3af207025..2a43592e1 100644 --- a/modules/user/api_create.go +++ b/modules/user/api_create.go @@ -1,13 +1,10 @@ package user import ( - "context" "go_dreamfactory/comm" - "go_dreamfactory/lego/sys/event" "go_dreamfactory/lego/sys/log" "go_dreamfactory/pb" cfg "go_dreamfactory/sys/configure/structs" - "go_dreamfactory/sys/db" "strings" "google.golang.org/protobuf/proto" @@ -130,13 +127,5 @@ func (this *apiComp) Create(session comm.IUserSession, req *pb.UserCreateReq) (c } this.mail.SendMailByCid(session, comm.Welcomemail, nil) - event.TriggerEvent(comm.EventCreateUser, session.GetUserId()) - this.module.service.AcrossClusterRpcGo(context.Background(), db.CrossTag(), comm.Service_Worker, string(comm.Rpc_GatewayNoticeUserCreate), &pb.NoticeUserCreateReq{ - Ip: session.GetIP(), - UserId: session.GetUserId(), - ServiceTag: session.GetServiecTag(), - GatewayServiceId: session.GetGatewayServiceId(), - UserSessionId: session.GetSessionId(), - }, nil) return }