战力排行榜逻辑优化

back_recharge
duhui 2022-11-15 15:46:40 +08:00
parent 445da5f7c0
commit 16749cae35
6 changed files with 2 additions and 23 deletions

View File

@ -14,11 +14,9 @@ import com.ljsd.jieling.logic.activity.eventhandler.UserForceUpEventHandler;
import com.ljsd.jieling.logic.dao.UserManager; import com.ljsd.jieling.logic.dao.UserManager;
import com.ljsd.jieling.logic.dao.root.User; import com.ljsd.jieling.logic.dao.root.User;
import com.ljsd.jieling.network.session.ISession; import com.ljsd.jieling.network.session.ISession;
import com.ljsd.jieling.thrift.idl.InvalidOperException;
import com.ljsd.jieling.thrift.idl.RPCRequestGMIFace; import com.ljsd.jieling.thrift.idl.RPCRequestGMIFace;
import com.ljsd.jieling.thrift.idl.Result; import com.ljsd.jieling.thrift.idl.Result;
import com.ljsd.jieling.util.InnerMessageUtil; import com.ljsd.jieling.util.InnerMessageUtil;
import org.apache.thrift.TException;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.data.redis.core.ZSetOperations; import org.springframework.data.redis.core.ZSetOperations;

View File

@ -14,13 +14,6 @@ public class UserForceChangeHandler extends BaseHandler<PlayerInfoProto.UserForc
return MessageTypeProto.MessageType.USER_FORCE_CHANGE_REQUEST; return MessageTypeProto.MessageType.USER_FORCE_CHANGE_REQUEST;
} }
// @Override
// public void process(ISession iSession, PacketNetData netData) throws Exception {
// byte[] bytes = netData.parseClientProtoNetData();
// PlayerInfoProto.UserForceChangeRequest userForceChangeRequest = PlayerInfoProto.UserForceChangeRequest.parseFrom(bytes);
//
// }
@Override @Override
public void processWithProto(ISession iSession, PlayerInfoProto.UserForceChangeRequest userForceChangeRequest) throws Exception { public void processWithProto(ISession iSession, PlayerInfoProto.UserForceChangeRequest userForceChangeRequest) throws Exception {
PlayerLogic.getInstance().userforceChange(iSession,userForceChangeRequest.getTeamId()); PlayerLogic.getInstance().userforceChange(iSession,userForceChangeRequest.getTeamId());

View File

@ -1,16 +1,10 @@
package com.ljsd.jieling.kefu; package com.ljsd.jieling.kefu;
import com.ljsd.jieling.logic.activity.event.Poster;
import com.ljsd.jieling.logic.activity.event.UserForceChangeEvent;
import com.ljsd.jieling.logic.dao.root.User;
public class Cmd_mainfightrank extends GmRoleAbstract{ public class Cmd_mainfightrank extends GmRoleAbstract{
@Override @Override
public boolean exec(String[] args) throws Exception { public boolean exec(String[] args) throws Exception {
User user = getUser();
Poster.getPoster().dispatchEvent(new UserForceChangeEvent(user.getId(),user.getPlayerInfoManager().getMaxForce()));
return true; return true;
} }
} }

View File

@ -34,13 +34,11 @@ class ForceRankActivity extends AbstractActivity {
@Override @Override
public void onEvent(IEvent event) throws Exception { public void onEvent(IEvent event) throws Exception {
if(!(event instanceof UserForceChangeEvent)){ if(!(event instanceof UserForceChangeEvent)){
return; return;
} }
UserForceChangeEvent forceChangeEvent = (UserForceChangeEvent) event; UserForceChangeEvent forceChangeEvent = (UserForceChangeEvent) event;
RankContext.getRankEnum(RankEnum.FORCE_RANK.getType()).addRank(forceChangeEvent.getUid(),String.valueOf(id),forceChangeEvent.getForce()); RankContext.getRankEnum(RankEnum.FORCE_RANK.getType()).addRank(forceChangeEvent.getUid(),String.valueOf(id),forceChangeEvent.getForce());
} }
@Override @Override

View File

@ -17,10 +17,10 @@ public class UserForceUpEventHandler implements IEventHandler {
if(!(event instanceof UserForceChangeEvent)) if(!(event instanceof UserForceChangeEvent))
return; return;
UserForceChangeEvent forceChangeEvent = (UserForceChangeEvent)event; UserForceChangeEvent forceChangeEvent = (UserForceChangeEvent)event;
double scoreById = RankContext.getRankEnum(RankEnum.MAIN_LEVEL_RANK.getType()).getScoreById(forceChangeEvent.getUid(), ""); double scoreById = RankContext.getRankEnum(RankEnum.FORCE_RANK.getType()).getScoreById(forceChangeEvent.getUid(), "");
if(scoreById<=0){ if(scoreById<=0){
return; return;
} }
RankContext.getRankEnum(RankEnum.MAIN_LEVEL_RANK.getType()).addRank(forceChangeEvent.getUid(),"",Double.valueOf(scoreById).intValue(),forceChangeEvent.getForce()); RankContext.getRankEnum(RankEnum.FORCE_RANK.getType()).addRank(forceChangeEvent.getUid(),"",Double.valueOf(scoreById).intValue(),forceChangeEvent.getForce());
} }
} }

View File

@ -73,7 +73,6 @@ public class PlayerLogic {
private static final Logger LOGGER = LoggerFactory.getLogger(PlayerLogic.class); private static final Logger LOGGER = LoggerFactory.getLogger(PlayerLogic.class);
private PlayerLogic(){ private PlayerLogic(){
Poster.getPoster().listenEvent(new UserForceUpEventHandler(), UserForceChangeEvent.class); Poster.getPoster().listenEvent(new UserForceUpEventHandler(), UserForceChangeEvent.class);
} }
public static PlayerLogic getInstance(){ public static PlayerLogic getInstance(){
@ -339,9 +338,6 @@ public class PlayerLogic {
MessageUtil.sendIndicationMessage(session, 1, MessageTypeProto.MessageType.VIP_LEVEL_STATE_RESPONSE.getNumber(), vipLevelStateResponse.build(), true); MessageUtil.sendIndicationMessage(session, 1, MessageTypeProto.MessageType.VIP_LEVEL_STATE_RESPONSE.getNumber(), vipLevelStateResponse.build(), true);
} }
public void userforceChange(ISession iSession, int teamId) throws Exception { public void userforceChange(ISession iSession, int teamId) throws Exception {
int uid = iSession.getUid(); int uid = iSession.getUid();
User user = UserManager.getUser(uid); User user = UserManager.getUser(uid);