活动：限时排行榜

game-server/app/services/redisService.ts

@@ -1,16 +1,20 @@
-import { COM_BTL_QUALITY, GUILD_ACTIVITY_TYPE } from './../consts';
+import { ACTIVITY_TYPE, COM_BTL_QUALITY, getRedisKeyByRankType, GUILD_ACTIVITY_TYPE } from './../consts';
 import * as Redis from 'redis';
 import {REDIS_KEY} from '../consts'
 import { GameModel } from "../db/Game";
-import { promisifyAll } from 'bluebird';
 import { pinus, ServerInfo } from 'pinus';
 import { GuildRankParam, GuildLeader, RankParam, LineupParam } from '../domain/rank';
 import { comBtlRanges } from '../pubUtils/data';
-import { setRankRedisFromDb } from './rankService';
+import { Rank, setRankRedisFromDb } from './rankService';
 import { ServerlistModel } from '../db/Serverlist';
 import moment = require('moment');
 import { getRedisSubChannel } from '../pubUtils/sdkUtil';
 import { getRandSingleEelm } from '../pubUtils/util';
+import { ActivityModel } from '../db/Activity';
+import { TimeLimitRankData } from '../domain/activityField/timeLimitRankField';
+import { ActivityTimeLimitRankModel } from '../db/ActivityTimeLimitRank';
+import { RoleType } from '../db/Role';
+import { GuildType } from '../db/Guild';
 
 /**
  * 在服务重新启动时，将信息存入redis
@@ -38,11 +42,14 @@ export async function initAllRank() {
     await delKeys(REDIS_KEY.HERO_RANK);
     await delKeys(REDIS_KEY.SHOW_LINEUP);
     // await delKeys(REDIS_KEY.PVP_RANK);
+    await delKeys(REDIS_KEY.GUILD_FUND);
+    await delKeys(REDIS_KEY.SUM_CE_SNAPSHOT);
 
     await setRankRedisFromDb(REDIS_KEY.PVP_RANK, {});
 
-    for(let {id} of serverList) {
+    for(let {id, activityGroupId} of serverList) {
         await initRank(id);
+        await initActivitiesRank(id, activityGroupId)
     }
 }
 
@@ -65,7 +72,27 @@ export async function initRank(serverId: number) {
     await setRankRedisFromDb(REDIS_KEY.MAIN_RANK, { serverId });
     await setRankRedisFromDb(REDIS_KEY.MAIN_ELITE_RANK, { serverId });
     await setRankRedisFromDb(REDIS_KEY.HERO_RANK, { serverId });
+}
 
+export async function initActivitiesRank(serverId: number, activityGroupId: number[]) {
+    let activities = await ActivityModel.findOpenActivityByType(activityGroupId, ACTIVITY_TYPE.TIME_LIMIT_RANK, new Date());
+    for(let activity of activities) {
+        let data = new TimeLimitRankData(activity, 0);
+        if(data.beginTime <= Date.now() && data.endTime >= Date.now()) {
+            let redisKey = getRedisKeyByRankType(data.rankType, true);
+
+            let ranks = await ActivityTimeLimitRankModel.getRank(serverId, data.activityId);
+            let r = new Rank(redisKey, { serverId, activityId: data.activityId });
+            r.setIsInit(true);
+            for (let rank of ranks) {
+                if(r.infoKey == REDIS_KEY.USER_INFO) {
+                    await r.setRankWithRoleInfo(rank.roleId, rank.score, rank.time||0, <RoleType>rank.role);
+                } else if(r.infoKey == REDIS_KEY.GUILD_INFO) {
+                    await r.setRankWithGuildInfo(rank.guildCode, rank.score, rank.time||0, <GuildType>rank.guild);
+                }
+            }
+        }
+    }    
 }
 
 /**
@@ -444,6 +471,10 @@ export function redisClient() {
     return client;
 }
 
+export async function hasKey(key: string) {
+    return await redisClient().existsAsync(key);
+}
+
 /**************** 数据库表end */