同步修改会话对象管理
This commit is contained in:
parent
0af3ef8c60
commit
416341cbd6
@ -186,7 +186,7 @@ func (this *SCompGateRoute) ReceiveMsg(ctx context.Context, args *pb.AgentMessag
|
|||||||
//RPC_NoticeUserClose 接收用户登录通知
|
//RPC_NoticeUserClose 接收用户登录通知
|
||||||
func (this *SCompGateRoute) NoticeUserLogin(ctx context.Context, args *pb.NoticeUserLoginReq, reply *pb.RPCMessageReply) error {
|
func (this *SCompGateRoute) NoticeUserLogin(ctx context.Context, args *pb.NoticeUserLoginReq, reply *pb.RPCMessageReply) error {
|
||||||
model := db.NewDBModel(comm.TableSession, db.Local())
|
model := db.NewDBModel(comm.TableSession, db.Local())
|
||||||
model.Change(args.UserId, map[string]interface{}{
|
model.AddList("online", args.UserId, map[string]interface{}{
|
||||||
"uid": args.UserId,
|
"uid": args.UserId,
|
||||||
"sessionId": args.UserSessionId,
|
"sessionId": args.UserSessionId,
|
||||||
"serviceTag": args.ServiceTag,
|
"serviceTag": args.ServiceTag,
|
||||||
|
Loading…
Reference in New Issue
Block a user