暂时移除事件代码

This commit is contained in:
liwei1dao 2023-03-30 14:16:14 +08:00
parent f0877961f9
commit 67d28e43f2
2 changed files with 1 additions and 12 deletions

View File

@ -27,7 +27,7 @@ func (this *apiComp) ChanageChannel(session comm.IUserSession, req *pb.ChatChana
return return
} }
if ok { 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 code = pb.ErrorCode_DBError
return return
} }

View File

@ -1,13 +1,10 @@
package user package user
import ( import (
"context"
"go_dreamfactory/comm" "go_dreamfactory/comm"
"go_dreamfactory/lego/sys/event"
"go_dreamfactory/lego/sys/log" "go_dreamfactory/lego/sys/log"
"go_dreamfactory/pb" "go_dreamfactory/pb"
cfg "go_dreamfactory/sys/configure/structs" cfg "go_dreamfactory/sys/configure/structs"
"go_dreamfactory/sys/db"
"strings" "strings"
"google.golang.org/protobuf/proto" "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) 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 return
} }