排行榜20位优化
parent
91dd46a809
commit
d8160bdfb0
|
@ -16,6 +16,7 @@ public class RankHandler extends BaseHandler<PlayerInfoProto.RankRequest> {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void processWithProto(ISession iSession, PlayerInfoProto.RankRequest proto) throws Exception {
|
public void processWithProto(ISession iSession, PlayerInfoProto.RankRequest proto) throws Exception {
|
||||||
RankLogic.getInstance().getRank(iSession,proto.getType(),proto.getActiviteId(),MessageTypeProto.MessageType.GET_ONE_RANK_RESPONSE);
|
RankLogic.getInstance().getRank(iSession,proto.getType(),proto.getActiviteId(),
|
||||||
|
proto.getIndex(),MessageTypeProto.MessageType.GET_ONE_RANK_RESPONSE);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -47,7 +47,7 @@ public class RankLogic {
|
||||||
public static class Instance {
|
public static class Instance {
|
||||||
public final static RankLogic instance = new RankLogic();
|
public final static RankLogic instance = new RankLogic();
|
||||||
}
|
}
|
||||||
public void getRank(ISession session, int type, int activityId,MessageTypeProto.MessageType messageType) throws Exception {
|
public void getRank(ISession session, int type, int activityId,int index,MessageTypeProto.MessageType messageType) throws Exception {
|
||||||
LOGGER.info("获取排行榜信息type={},activityId={}",type,activityId);
|
LOGGER.info("获取排行榜信息type={},activityId={}",type,activityId);
|
||||||
int page = 1;
|
int page = 1;
|
||||||
String rkey = "";
|
String rkey = "";
|
||||||
|
@ -73,7 +73,7 @@ public class RankLogic {
|
||||||
}
|
}
|
||||||
|
|
||||||
}else{
|
}else{
|
||||||
rankResponse = rank.getRank(session.getUid(),rkey,1, -1);
|
rankResponse = rank.getRank(session.getUid(),rkey,index/20+1, 20);
|
||||||
}
|
}
|
||||||
ReportUtil.onReportEvent(UserManager.getUser(session.getUid()), ReportEventEnum.CHECK_RANKING.getType(),String.valueOf(type));
|
ReportUtil.onReportEvent(UserManager.getUser(session.getUid()), ReportEventEnum.CHECK_RANKING.getType(),String.valueOf(type));
|
||||||
MessageUtil.sendMessage(session,1,messageType.getNumber(),rankResponse,true);
|
MessageUtil.sendMessage(session,1,messageType.getNumber(),rankResponse,true);
|
||||||
|
|
|
@ -47,8 +47,8 @@ public abstract class AbstractRank implements IRank {
|
||||||
}
|
}
|
||||||
int start = (page - 1) * rankEndLine, end = page * rankEndLine - 1;
|
int start = (page - 1) * rankEndLine, end = page * rankEndLine - 1;
|
||||||
Set<ZSetOperations.TypedTuple<String>> zsetreverseRangeWithScores = getRankByKey(rkey,start,end);
|
Set<ZSetOperations.TypedTuple<String>> zsetreverseRangeWithScores = getRankByKey(rkey,start,end);
|
||||||
if(start==0){
|
if(start%rankEndLine == 0){
|
||||||
start=1;
|
start++;
|
||||||
}
|
}
|
||||||
PlayerInfoProto.RankResponse.Builder allUserResponse = getAllUserResponse(zsetreverseRangeWithScores,start);
|
PlayerInfoProto.RankResponse.Builder allUserResponse = getAllUserResponse(zsetreverseRangeWithScores,start);
|
||||||
//当前用户信息
|
//当前用户信息
|
||||||
|
|
Loading…
Reference in New Issue