diff --git a/game-server/app/servers/connector/handler/entryHandler.ts b/game-server/app/servers/connector/handler/entryHandler.ts index 43da45f6f..b92982622 100644 --- a/game-server/app/servers/connector/handler/entryHandler.ts +++ b/game-server/app/servers/connector/handler/entryHandler.ts @@ -201,7 +201,6 @@ export class EntryHandler { let channelService = this.app.get('channelService'); let channel = channelService.getChannel(roleId, true); channel.leave(roleId, sid); - // this.app.rpc.battle.battleRemote.kick.route(session)(roleId, this.app.get('serverId'), serverId); this.app.rpc.chat.chatRemote.kickWorldChannel.route(session, true)(roleId, sid, serverId); await leaveSysChannel(roleId, sid, serverId); await leaveWorldChannel(roleId, sid, serverId); diff --git a/game-server/app/services/redisService.ts b/game-server/app/services/redisService.ts index 06e80732a..871a68ae4 100644 --- a/game-server/app/services/redisService.ts +++ b/game-server/app/services/redisService.ts @@ -158,9 +158,7 @@ export async function setTeamSearchReq(roleId: string, sid: string, qualityArr: cmds.push(['sadd', getComTeamKey(quality, lvRange), getComTeamValue(roleId, sid)]); } }); - const multiClient = redisClient().multi(cmds) as Redis.Multi; - const newMulti = promisifyAll(multiClient) as Redis.Multi; - const res = await newMulti.execAsync(); + const res = await redisClient().multi(cmds).execAsync(); console.log('setTeamSearchReq: ', res); return res; } @@ -185,9 +183,7 @@ export async function rmRoleFromQueue(roleId: string, sid: string, qualityArr: A } } }; - const multiClient = redisClient().multi(cmds) as Redis.Multi; - const newMulti = promisifyAll(multiClient) as Redis.Multi; - await newMulti.execAsync(); + await redisClient().multi(cmds).execAsync(); } /** diff --git a/game-server/config/redis.ts b/game-server/config/redis.ts index 8b5d2de0a..f6222cdf3 100644 --- a/game-server/config/redis.ts +++ b/game-server/config/redis.ts @@ -87,6 +87,7 @@ export function connectRedis(redisArr: string, redisPw: string) { // 转 promise const client = promisifyAll(oldRedisClient) as Redis.RedisClient; + promisifyAll(Redis.Multi.prototype); client.set('hello', 'redis', Redis.print); return client;