重启服务器时清空redis中的寻宝匹配记录
This commit is contained in:
@@ -54,6 +54,7 @@ mongoose.connect(mongoAddr, { useNewUrlParser: true, useUnifiedTopology: true, u
|
|||||||
});
|
});
|
||||||
|
|
||||||
redisService.initAllRank();
|
redisService.initAllRank();
|
||||||
|
redisService.clearComBtlQueue();
|
||||||
/**
|
/**
|
||||||
* Init app for client.
|
* Init app for client.
|
||||||
*/
|
*/
|
||||||
|
|||||||
@@ -13,6 +13,7 @@ declare module 'redis' {
|
|||||||
sremAsync(...args: any[]): Promise<any>;
|
sremAsync(...args: any[]): Promise<any>;
|
||||||
sismemberAsync(...args: any[]): Promise<any>;
|
sismemberAsync(...args: any[]): Promise<any>;
|
||||||
srandmemberAsync(...args: any[]): Promise<any>;
|
srandmemberAsync(...args: any[]): Promise<any>;
|
||||||
|
delAsync(...args: any[]): Promise<any>;
|
||||||
}
|
}
|
||||||
export interface Multi extends Commands<Multi> {
|
export interface Multi extends Commands<Multi> {
|
||||||
execAsync(...args: any[]): Promise<any>;
|
execAsync(...args: any[]): Promise<any>;
|
||||||
@@ -154,7 +155,6 @@ export async function setTeamSearchReq(roleId: string, sid: string, qualityArr:
|
|||||||
}
|
}
|
||||||
|
|
||||||
// 取出 0 - 2 个某品质的匹配中玩家,并在其它品质中删除此玩家信息
|
// 取出 0 - 2 个某品质的匹配中玩家,并在其它品质中删除此玩家信息
|
||||||
|
|
||||||
export async function rmRoleFromQueue(roleId: string, sid: string, qualityArr: Array<number>) {
|
export async function rmRoleFromQueue(roleId: string, sid: string, qualityArr: Array<number>) {
|
||||||
let cmds = [];
|
let cmds = [];
|
||||||
for (let q of qualityArr) {
|
for (let q of qualityArr) {
|
||||||
@@ -199,6 +199,12 @@ export async function checkRoleInQueue(roleId: string, sid: string, qualityArr:
|
|||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
export async function clearComBtlQueue() {
|
||||||
|
for (let q of GOOD_QUALITY) {
|
||||||
|
client.delAsync(`${REDIS_KEY.COM_TEAM_SEARCH_PRE}${q}`);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
/**************** 寻宝相关 end */
|
/**************** 寻宝相关 end */
|
||||||
|
|
||||||
////// redis方法
|
////// redis方法
|
||||||
|
|||||||
Reference in New Issue
Block a user