补充session group字段

This commit is contained in:
liwei1dao 2024-01-15 17:50:32 +08:00
parent 8f4009f1be
commit 108731254b

View File

@ -52,6 +52,7 @@ type Agent struct {
uId string uId string
wId string wId string
cwid string cwid string
group int32
writeChan chan [][]byte writeChan chan [][]byte
closeSignal chan bool closeSignal chan bool
state int32 //状态 0 关闭 1 运行 2 关闭中 state int32 //状态 0 关闭 1 运行 2 关闭中
@ -420,6 +421,7 @@ func (this *Agent) messageDistribution(msg *pb.UserMessage) (err error) {
req.Ip = this.IP() req.Ip = this.IP()
req.UserSessionId = this.sessionId req.UserSessionId = this.sessionId
req.UserId = this.uId req.UserId = this.uId
req.Group = this.group
req.ServiceTag = this.gateway.Service().GetTag() req.ServiceTag = this.gateway.Service().GetTag()
req.GatewayServiceId = this.gateway.Service().GetId() req.GatewayServiceId = this.gateway.Service().GetId()
req.MainType = msg.MainType req.MainType = msg.MainType
@ -525,6 +527,7 @@ func (this *Agent) messageDistribution(msg *pb.UserMessage) (err error) {
loginresp = resp.(*pb.UserLoginResp) loginresp = resp.(*pb.UserLoginResp)
this.uId = loginresp.Data.Uid this.uId = loginresp.Data.Uid
this.wId = reply.ServiceId this.wId = reply.ServiceId
this.group = loginresp.Data.Group
this.gateway.LoginNotice(this) this.gateway.LoginNotice(this)
} }
} }