战力冲刺

xuexinpeng 2022-02-22 21:02:47 +08:00
parent 1368922c6d
commit 900412365d
3 changed files with 9 additions and 6 deletions

View File

@ -223,6 +223,7 @@ public class ActivityLogic implements IEventHandler{
} }
} }
abstractActivity.onActivityPreEnd(); abstractActivity.onActivityPreEnd();
continue;
} }
if (null == abstractActivity) { if (null == abstractActivity) {

View File

@ -42,9 +42,7 @@ public class PowerRiceActivity extends AbstractActivity{
//取出实时排行榜数据 存到另一个redis字段中 //取出实时排行榜数据 存到另一个redis字段中
Set<ZSetOperations.TypedTuple<String>> rankInfos = rank.getRankByKey("", 0,-1); Set<ZSetOperations.TypedTuple<String>> rankInfos = rank.getRankByKey("", 0,-1);
for(ZSetOperations.TypedTuple<String> rankInfo:rankInfos){ for(ZSetOperations.TypedTuple<String> rankInfo:rankInfos){
if(powerRank.getScoreById(Integer.parseInt(rankInfo.getValue()),"") == 0){ powerRank.addRank(Integer.parseInt(rankInfo.getValue()),"",rankInfo.getScore());
powerRank.addRank(Integer.parseInt(rankInfo.getValue()),"",rankInfo.getScore());
}
} }
} }
@ -67,7 +65,8 @@ public class PowerRiceActivity extends AbstractActivity{
*/ */
@Override @Override
public void onActivityEnd() throws Exception { public void onActivityEnd() throws Exception {
AbstractRank powerRank = RankContext.getRankEnum(RankEnum.POWER_RICE_RANK.getType());
powerRank.removeRank("");
} }
@Override @Override
@ -92,8 +91,6 @@ public class PowerRiceActivity extends AbstractActivity{
index++; index++;
} }
GlobalSystemControl globalSystemControl = GlobalSystemControl.getGlobalSystemControl(); GlobalSystemControl globalSystemControl = GlobalSystemControl.getGlobalSystemControl();
//HashMap<Integer, Integer> activityPreMap = globalSystemControl.getActivityPreEnd();
//activityPreMap.put(id,TimeUtils.nowInt());
globalSystemControl.addActivityPreEnd(id,TimeUtils.now()); globalSystemControl.addActivityPreEnd(id,TimeUtils.now());
GlobalSystemControl.save(globalSystemControl); GlobalSystemControl.save(globalSystemControl);
} }

View File

@ -386,4 +386,9 @@ public abstract class AbstractRank implements IRank {
} }
} }
public void removeRank(String rkey){
String key = RedisUtil.getInstence().getKey(redisKey, rkey);
RedisUtil.getInstence().del(key);
}
} }