From f8962beca656a05f4456c0f7eae5498da9e3d933 Mon Sep 17 00:00:00 2001
From: Gordon <1432970085@qq.com>
Date: Tue, 7 Jun 2022 16:05:59 +0800
Subject: [PATCH] kick

---
 internal/msg_gateway/gate/rpc_server.go | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/internal/msg_gateway/gate/rpc_server.go b/internal/msg_gateway/gate/rpc_server.go
index 94195449a..3ac358ec9 100644
--- a/internal/msg_gateway/gate/rpc_server.go
+++ b/internal/msg_gateway/gate/rpc_server.go
@@ -189,7 +189,14 @@ func (r *RPCServer) OnlineBatchPushOneMsg(_ context.Context, req *pbRelay.Online
 	}, nil
 }
 func (r *RPCServer) KickUserOffline(_ context.Context, req *pbRelay.KickUserOfflineReq) (*pbRelay.KickUserOfflineResp, error) {
-	panic("implement me")
+	for _, v := range req.KickUserIDList {
+		oldConnMap := ws.getUserAllCons(v)
+		if conn, ok := oldConnMap[int(req.PlatformID)]; ok { // user->map[platform->conn]
+			ws.sendKickMsg(conn, &UserConn{})
+		}
+	}
+	return nil, nil
+
 }
 func sendMsgToUser(conn *UserConn, bMsg []byte, in *pbRelay.OnlinePushMsgReq, RecvPlatForm int, RecvID string) (ResultCode int64) {
 	err := ws.writeMsg(conn, websocket.BinaryMessage, bMsg)