From 28a7882999b21324caf6bade1dcca8c5bd0aba47 Mon Sep 17 00:00:00 2001 From: duhui Date: Mon, 13 Sep 2021 00:29:30 +0800 Subject: [PATCH 1/6] =?UTF-8?q?=E8=B7=A8=E6=9C=8Dbug=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ljsd/jieling/logic/GlobleSystemLogic.java | 4 ++ .../ljsd/jieling/logic/mail/MailLogic.java | 5 +- .../jieling/logic/rank/CrossRankManager.java | 54 ++++++++++--------- .../logic/rank/rankImpl/CrossArenaRank.java | 1 + 4 files changed, 36 insertions(+), 28 deletions(-) diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/GlobleSystemLogic.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/GlobleSystemLogic.java index 80c6945c2..715fed8d9 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/GlobleSystemLogic.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/GlobleSystemLogic.java @@ -208,12 +208,15 @@ public class GlobleSystemLogic implements IEventHandler { } public void doSplit(){ + LOGGER.info("跨服分组验证处理"); if(!GameApplication.serverProperties.isArenaCross()){ + LOGGER.error("跨服分组,测试服不做分组"); return; } RedisUtil redisUtil = RedisUtil.getInstence(); Object matched = redisUtil.get(RedisKey.MATCHED_SPLIT_KEY); if(matched!=null){ + LOGGER.error("跨服分组,获取key:【MATCHED_SPLIT_KEY】失败, info:{}",matched.toString()); return; } SMServerArenaSetting setting = STableManager.getConfig(SMServerArenaSetting.class).get(1); @@ -221,6 +224,7 @@ public class GlobleSystemLogic implements IEventHandler { boolean lock = redisUtil.lock("SERVER_SPLIT_REDIS_LOCK", TimeUtils.ONE_MINUTE * 2); if(!lock){ //没有拿到锁直接返回 + LOGGER.error("跨服分组,未获取到锁"); return; } //这里为所有服务器的世界等级 diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/mail/MailLogic.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/mail/MailLogic.java index 92f4ccb65..058804cc2 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/mail/MailLogic.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/mail/MailLogic.java @@ -434,9 +434,10 @@ public class MailLogic { public void sendCrossServerIndication(){ int crossGroup = GlobleSystemLogic.getInstence().getCrossGroup(); int result = crossGroup == -1 ? 0 : 1; - PlayerInfoProto.IsCrossResponse build = PlayerInfoProto.IsCrossResponse.newBuilder().setIsCross(result).build(); + PlayerInfoProto.IsCrossIndication build = PlayerInfoProto.IsCrossIndication.newBuilder().setIsCross(result).build(); for(ISession session:OnlineUserManager.sessionMap.values()){ - MessageUtil.sendIndicationMessage(session.getUid(),build); + LOGGER.info("=====================开始跨服,推送数据到玩家信息:{},分组id:{}",session.getUid(),crossGroup); + MessageUtil.sendIndicationMessage(session,1,MessageTypeProto.MessageType.IsCrossIndication_VALUE,build,true); } } diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/CrossRankManager.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/CrossRankManager.java index 3796716ab..ab01fa4aa 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/CrossRankManager.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/CrossRankManager.java @@ -47,38 +47,40 @@ public class CrossRankManager { * 跨服排行处理 */ public void crossRankHandle(boolean choice){ - if (choice || !isTime()){ - // 不是处理数据的服务器 - return; - } - for (RankEnum value : RankEnum.values()) { - int type = value.getType(); - boolean rank2 = RankContext.isCrossRank2(type); - if (rank2){ - //跨服 - if(RankContext.isCrossRank(type)){ - // 获取分组id,是否跨服 - int crossGroup = GlobleSystemLogic.getInstence().getCrossGroup(); - if(crossGroup != -1){ - AbstractRank rank = RankContext.getRankEnum(type); - String key = RedisUtil.getInstence().getKey(rank.getCrossRedisKey(),"",false); - Map cacheMap = RedisUtil.getInstence().getMapValues(RedisKey.FAMILY_INFO, "", Integer.class, GuildCache.class); - Set> range = RedisUtil.getInstence().getZsetreverseRangeWithScores(rank.getRedisKey(), "", 0, 100, true); - for (ZSetOperations.TypedTuple tuple : range) { - if (tuple.getValue().length() == 8){ - rank.crossUserCache(Integer.parseInt(tuple.getValue())); - }else { - GuildCache cache = cacheMap.get(Integer.valueOf(tuple.getValue())); - if (cache != null){ - rank.crossUserCache(cache.getLeaderUId()); + // 时间验证 + if (choice || isTime()){ + // 全部排行遍历 + for (RankEnum value : RankEnum.values()) { + int type = value.getType(); + boolean rank2 = RankContext.isCrossRank2(type); + if (rank2){ + //跨服 + if(RankContext.isCrossRank(type)){ + // 获取分组id,是否跨服 + int crossGroup = GlobleSystemLogic.getInstence().getCrossGroup(); + if(crossGroup != -1){ + AbstractRank rank = RankContext.getRankEnum(type); + String key = RedisUtil.getInstence().getKey(rank.getCrossRedisKey(),"",false); + Map cacheMap = RedisUtil.getInstence().getMapValues(RedisKey.FAMILY_INFO, "", Integer.class, GuildCache.class); + Set> range = RedisUtil.getInstence().getZsetreverseRangeWithScores(rank.getRedisKey(), "", 0, 100, true); + for (ZSetOperations.TypedTuple tuple : range) { + if (tuple.getValue().length() == 8){ + rank.crossUserCache(Integer.parseInt(tuple.getValue())); + }else { + GuildCache cache = cacheMap.get(Integer.valueOf(tuple.getValue())); + if (cache != null){ + rank.crossUserCache(cache.getLeaderUId()); + } } + RedisUtil.getInstence().zsetAddOne(key,tuple.getValue(),tuple.getScore()); } - RedisUtil.getInstence().zsetAddOne(key,tuple.getValue(),tuple.getScore()); + LOGGER.info("=====================跨服排行榜处理========,key:{}",key); } - LOGGER.info("=====================跨服排行榜处理========,key:{}",key); } } } + // 更新时间 + isTime(); } } diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/CrossArenaRank.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/CrossArenaRank.java index 71dcdc68d..625209228 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/CrossArenaRank.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/CrossArenaRank.java @@ -108,6 +108,7 @@ public class CrossArenaRank extends AbstractRank { @Override public PlayerInfoProto.RankResponse getCrossRank(int uid, String rkey, int page, int rankEndLine) throws Exception { + rkey = Integer.toString(GlobleSystemLogic.getInstence().getCrossGroup()); return getRank(uid,rkey,page,rankEndLine); } } From fdf2e28b6fc87d0bddb4490fd7e2122037aee818 Mon Sep 17 00:00:00 2001 From: duhui Date: Mon, 2 Aug 2021 11:18:03 +0800 Subject: [PATCH 2/6] =?UTF-8?q?=E8=B7=A8=E6=9C=8D=E6=8E=92=E8=A1=8C?= =?UTF-8?q?=E6=88=98=E5=8A=9B=E6=98=BE=E7=A4=BA=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/ljsd/jieling/logic/player/PlayerLogic.java | 1 + 1 file changed, 1 insertion(+) diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/player/PlayerLogic.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/player/PlayerLogic.java index b9d4101c3..7a60d3328 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/player/PlayerLogic.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/player/PlayerLogic.java @@ -771,6 +771,7 @@ public class PlayerLogic { } CommonProto.Hero.Builder heroBuilder = CommonProto.Hero.newBuilder().setLevel(hero.getLevel()).setEspecialEquipLevel(hero.getEspecialEquipLevel()).setStar(hero.getStar()).setId(hero.getId()).setHeroId(hero.getTemplateId()).setBreakId(hero.getBreakId()).setStarBreakId(hero.getStarBreakId()); PlayerInfoProto.ViewHeroInfoResponse.Builder builder = PlayerInfoProto.ViewHeroInfoResponse.newBuilder(); + Map heroNotBufferAttribute = hero.getAttributeMapByTeam().getOrDefault(teamId,new HashMap<>()); for(Map.Entry item : heroNotBufferAttribute.entrySet()){ builder.addSpecialEffects(CommonProto.SpecialEffects.newBuilder().setPropertyId(item.getKey()).setPropertyValue(item.getValue().intValue()).build()); From 4f8f6cd44d23c082da624578fcd49ce566f1d90c Mon Sep 17 00:00:00 2001 From: duhui Date: Mon, 2 Aug 2021 11:18:54 +0800 Subject: [PATCH 3/6] =?UTF-8?q?=E8=B7=A8=E6=9C=8D=E6=88=98=E5=8A=9B?= =?UTF-8?q?=E8=A1=A5=E5=85=85=E6=8F=90=E4=BA=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../jieling/logic/activity/crossService/CrossServiceLogic.java | 2 +- .../main/java/com/ljsd/jieling/logic/rank/CrossRankManager.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/activity/crossService/CrossServiceLogic.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/activity/crossService/CrossServiceLogic.java index 1ae2e81b2..4771cc7ed 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/activity/crossService/CrossServiceLogic.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/activity/crossService/CrossServiceLogic.java @@ -214,7 +214,7 @@ public class CrossServiceLogic { if (collect.isEmpty()){ continue; } - Map attribute = HeroLogic.getInstance().calHeroNotBufferAttribute(user, hero, false, teamId); + Map attribute = HeroLogic.getInstance().calHeroNotBufferAttribute(user, hero, true, teamId); arenaOfHero.putAttributeMapByTeam(teamId,attribute); } return arenaOfHero; diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/CrossRankManager.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/CrossRankManager.java index ab01fa4aa..452a9e5db 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/CrossRankManager.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/CrossRankManager.java @@ -68,7 +68,7 @@ public class CrossRankManager { rank.crossUserCache(Integer.parseInt(tuple.getValue())); }else { GuildCache cache = cacheMap.get(Integer.valueOf(tuple.getValue())); - if (cache != null){ + if (cache != null && cache.getLeaderUId() != 0){ rank.crossUserCache(cache.getLeaderUId()); } } From cc0574a4a63516b139d7505d74b308f07c59b854 Mon Sep 17 00:00:00 2001 From: duhui Date: Mon, 2 Aug 2021 13:34:35 +0800 Subject: [PATCH 4/6] =?UTF-8?q?=E8=B7=A8=E6=9C=8D=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/ljsd/jieling/logic/arena/ArenaLogic.java | 7 +++++-- .../java/com/ljsd/jieling/logic/family/GuildLogic.java | 4 +++- .../src/main/java/com/ljsd/jieling/util/CBean2Proto.java | 4 +++- 3 files changed, 11 insertions(+), 4 deletions(-) diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/arena/ArenaLogic.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/arena/ArenaLogic.java index eb9d191e3..2f1f2373e 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/arena/ArenaLogic.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/arena/ArenaLogic.java @@ -23,6 +23,7 @@ import com.ljsd.jieling.logic.activity.event.Poster; import com.ljsd.jieling.logic.dao.*; import com.ljsd.jieling.logic.dao.gm.ArenaOfUser; import com.ljsd.jieling.logic.dao.root.User; +import com.ljsd.jieling.logic.family.CrossDeathPathLogic; import com.ljsd.jieling.logic.fight.*; import com.ljsd.jieling.logic.fight.result.FightResult; import com.ljsd.jieling.logic.hero.HeroLogic; @@ -969,11 +970,12 @@ public class ArenaLogic { Object get = RedisUtil.getInstence().hget(RedisKey.ARENA_PROUD_COUNT, String.valueOf(enemy.getId())); int proudTime = get==null?1:Integer.parseInt((String)get); int enemyId = enemy.getId(); + String serverName = CrossDeathPathLogic.getInstance().getServerNameByDeathPath(enemy.getPlayerManager().getServerId()); CommonProto.ArenaPersonInfo personInfoBuild = CommonProto.ArenaPersonInfo.newBuilder() .setUid(enemyId) .setLevel(enemy.getPlayerManager().getLevel()) .setName(enemy.getPlayerManager().getName()) - .setServername(enemy.getPlayerManager().getServerName()) + .setServername(serverName) .setTotalForce(enemy.getHeroManager().getTotalForce()) .setUserTitle(enemy.getPlayerManager().getUserTitle()) .setUserMount(enemy.getPlayerManager().getUserMount()) @@ -993,13 +995,14 @@ public class ArenaLogic { int enemyId = enemy.getEnemyId(); SArenaRobotConfig sArenaRobotConfig = SArenaRobotConfig.getsArenaRobotConfigById(enemyId); CommonProto.Team teamBuild = CommonProto.Team.newBuilder().addAllHeroTid(sArenaRobotConfig.getHeroList()).build(); + String serverName = CrossDeathPathLogic.getInstance().getServerNameByDeathPath(enemy.getServerID()); CommonProto.ArenaPersonInfo personInfoBuild = CommonProto.ArenaPersonInfo.newBuilder() .setUid(enemy.getEnemyId_UUid()) .setLevel(sArenaRobotConfig.getRobotLevel()) .setName(enemy.getRandomName()==null?"":enemy.getRandomName()) .setScore(sArenaRobotConfig.getRobotScore()) .setTotalForce(sArenaRobotConfig.getTotalForce()) - .setServername(CrossServiceLogic.getInstance().findServerName(enemy.getServerID())) + .setServername(serverName) .setUserSkin(80012) .setGender(enemy.isGender()?1:0) .setRank(rank) diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/family/GuildLogic.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/family/GuildLogic.java index a2e503b4c..2ec675de4 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/family/GuildLogic.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/family/GuildLogic.java @@ -823,7 +823,7 @@ public class GuildLogic { throw new ErrorCodeException(ErrorCode.FAMILY_IN_SENSITIVE); }else{ if(type==1){ - if(content.length()<0||content.length()>32){ + if(content.length() > 32){ throw new ErrorCodeException(ErrorCode.ANNOUNCE_SIZE); } guildInfo.setAnnounce(content); @@ -835,6 +835,8 @@ public class GuildLogic { throw new ErrorCodeException(ErrorCode.ITEM_NOT_ENOUGH); } guildInfo.setName(content); + // 缓存同步 + RedisUtil.getInstence().putMapEntry(RedisKey.FAMILY_INFO,"",String.valueOf(guildInfo.getId()),GuildCache.create(guildInfo)); } MessageUtil.sendMessage(session,resultCode,msgId,response,true); } diff --git a/serverlogic/src/main/java/com/ljsd/jieling/util/CBean2Proto.java b/serverlogic/src/main/java/com/ljsd/jieling/util/CBean2Proto.java index 512df7354..4c16deb27 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/util/CBean2Proto.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/util/CBean2Proto.java @@ -14,6 +14,7 @@ import com.ljsd.jieling.logic.dao.*; import com.ljsd.jieling.logic.dao.gm.ArenaOfHero; import com.ljsd.jieling.logic.dao.root.GuildInfo; import com.ljsd.jieling.logic.dao.root.User; +import com.ljsd.jieling.logic.family.CrossDeathPathLogic; import com.ljsd.jieling.logic.fight.CombatLogic; import com.ljsd.jieling.logic.hero.HeroLogic; import com.ljsd.jieling.logic.store.newRechargeInfo.NewRechargeInfo; @@ -550,7 +551,8 @@ public class CBean2Proto { chatInfo.setMessageId(messageId); chatInfo.setUserTitle(playerInfoManager.getUserTitle()); chatInfo.setPracticeLevel(user.getHeroManager().getPracticeLevel()); - chatInfo.setServerName(CrossServiceLogic.getInstance().findServerName(GameApplication.serverId)); + String serverName = CrossDeathPathLogic.getInstance().getServerNameByDeathPath(GameApplication.serverId); + chatInfo.setServerName(serverName); return chatInfo.build(); } From cde4df5928e3c36d2827f9acf1ad71991b02c4b8 Mon Sep 17 00:00:00 2001 From: lvxinran Date: Sat, 7 Aug 2021 14:03:30 +0800 Subject: [PATCH 5/6] =?UTF-8?q?=E7=BD=97=E6=B5=AE=E6=8E=92=E8=A1=8C?= =?UTF-8?q?=E7=AD=89=E7=BA=A7=E4=B8=8D=E4=B8=80=E8=87=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/ljsd/jieling/logic/arena/ArenaLogic.java | 2 +- .../java/com/ljsd/jieling/logic/dao/CrossArenaEnemy.java | 8 +++++++- .../ljsd/jieling/logic/rank/rankImpl/CrossArenaRank.java | 2 +- 3 files changed, 9 insertions(+), 3 deletions(-) diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/arena/ArenaLogic.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/arena/ArenaLogic.java index eb9d191e3..78501edae 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/arena/ArenaLogic.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/arena/ArenaLogic.java @@ -860,7 +860,7 @@ public class ArenaLogic { int server = random.nextInt(groupList.size()); rank.addRank(robotIndex,String.valueOf(crossGroup),robotNum-robotIndex); SArenaRobotConfig config = SArenaRobotConfig.getsArenaRobotConfigById(robotIds.get(robotIndex)); - robotInfo.put(String.valueOf(robotIndex),new CrossArenaEnemy(robotIds.get(robotIndex),robotIndex,groupList.get(server),0,0,random.nextBoolean(),PlayerLogic.getInstance().getRandomName2WithOutVerify(),config.getTotalForce())); + robotInfo.put(String.valueOf(robotIndex),new CrossArenaEnemy(robotIds.get(robotIndex),robotIndex,groupList.get(server),0,0,random.nextBoolean(),PlayerLogic.getInstance().getRandomName2WithOutVerify(),config.getTotalForce(),config.getRoleLv())); } LOGGER.info("跨服信息初始化结束"); diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/dao/CrossArenaEnemy.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/dao/CrossArenaEnemy.java index 8525c3903..3a8bacf23 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/dao/CrossArenaEnemy.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/dao/CrossArenaEnemy.java @@ -17,6 +17,7 @@ public class CrossArenaEnemy { private boolean gender; private String randomName; private int totalForce; + private int level; public CrossArenaEnemy(int enemyId, int enemyId_UUid, int serverID, int enemyType, int enemyStatus, int rank) { this.enemyId = enemyId; @@ -27,12 +28,13 @@ public class CrossArenaEnemy { this.rank = rank; } - public CrossArenaEnemy(int enemyId,int enemyId_UUid, int serverID, int enemyType, int enemyStatus,boolean gender,String randomName,int totalForce) { + public CrossArenaEnemy(int enemyId,int enemyId_UUid, int serverID, int enemyType, int enemyStatus,boolean gender,String randomName,int totalForce,int level) { this(enemyId,enemyId_UUid,serverID,enemyType,enemyStatus); this.gender=gender; this.randomName = randomName; this.totalForce = totalForce; + this.level = level; } public CrossArenaEnemy(int enemyId,int enemyId_UUid, int serverID, int enemyType, int enemyStatus) { this.enemyId = enemyId; @@ -91,4 +93,8 @@ public class CrossArenaEnemy { public int getTotalForce() { return totalForce; } + + public int getLevel() { + return level; + } } diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/CrossArenaRank.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/CrossArenaRank.java index 625209228..8d2ddb34e 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/CrossArenaRank.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/CrossArenaRank.java @@ -62,7 +62,7 @@ public class CrossArenaRank extends AbstractRank { CommonProto.UserRank.Builder everyRank = CommonProto.UserRank.newBuilder() .setUid(mapEntry.getEnemyId_UUid()) .setUserName(mapEntry.getRandomName()) - .setLevel(100) + .setLevel(mapEntry.getLevel()==0?100:mapEntry.getLevel()) .setUserSkin(80012) .setRankInfo(everyRankInfo) .setServerName(CrossServiceLogic.getInstance().findServerName(mapEntry.getServerID())) From ea93c562cc17c376140990835f742aca4f575ada Mon Sep 17 00:00:00 2001 From: duhui Date: Mon, 2 Aug 2021 14:37:52 +0800 Subject: [PATCH 6/6] =?UTF-8?q?=E8=B7=A8=E6=9C=8D=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/ljsd/jieling/logic/rank/rankImpl/MainLevelRank.java | 3 ++- .../logic/rank/rankImpl/ShanHeSheJiTuChapterRank.java | 4 +++- .../jieling/logic/rank/rankImpl/ShanHeSheJiTuStarRank.java | 4 +++- .../java/com/ljsd/jieling/thread/task/DataReportTask.java | 5 ----- 4 files changed, 8 insertions(+), 8 deletions(-) diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/MainLevelRank.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/MainLevelRank.java index 75ea91f51..57bd21024 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/MainLevelRank.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/MainLevelRank.java @@ -3,6 +3,7 @@ package com.ljsd.jieling.logic.rank.rankImpl; import rpc.protocols.CommonProto; import rpc.protocols.PlayerInfoProto; import org.springframework.data.redis.core.ZSetOperations; +import util.TimeUtils; import java.util.*; @@ -60,6 +61,6 @@ public class MainLevelRank extends AbstractRank { @Override public double getScore(double... data) { - return data[0]+ data[1]/Math.pow(10,8); + return data[0]+ TimeUtils.getDoubleTime(); } } diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/ShanHeSheJiTuChapterRank.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/ShanHeSheJiTuChapterRank.java index 237eee752..72121a957 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/ShanHeSheJiTuChapterRank.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/ShanHeSheJiTuChapterRank.java @@ -1,5 +1,7 @@ package com.ljsd.jieling.logic.rank.rankImpl; +import util.TimeUtils; + public class ShanHeSheJiTuChapterRank extends AbstractRank{ public ShanHeSheJiTuChapterRank(int type, String redisKey) { @@ -12,7 +14,7 @@ public class ShanHeSheJiTuChapterRank extends AbstractRank{ @Override public double getScore(double... data) { - return data[0]; + return data[0]+ TimeUtils.getDoubleTime(); } } diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/ShanHeSheJiTuStarRank.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/ShanHeSheJiTuStarRank.java index 6ac26ad0d..3c47b85d3 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/ShanHeSheJiTuStarRank.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/ShanHeSheJiTuStarRank.java @@ -1,5 +1,7 @@ package com.ljsd.jieling.logic.rank.rankImpl; +import util.TimeUtils; + public class ShanHeSheJiTuStarRank extends AbstractRank{ public ShanHeSheJiTuStarRank(int type, String redisKey) { @@ -12,7 +14,7 @@ public class ShanHeSheJiTuStarRank extends AbstractRank{ @Override public double getScore(double... data) { - return data[0]; + return data[0]+ TimeUtils.getDoubleTime(); } } diff --git a/serverlogic/src/main/java/com/ljsd/jieling/thread/task/DataReportTask.java b/serverlogic/src/main/java/com/ljsd/jieling/thread/task/DataReportTask.java index e4705a520..2f1358e8c 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/thread/task/DataReportTask.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/thread/task/DataReportTask.java @@ -1,13 +1,8 @@ package com.ljsd.jieling.thread.task; -import com.ljsd.GameApplication; -import com.ljsd.jieling.config.reportData.DataMessageUtils; import com.ljsd.jieling.ktbeans.ReportUserEvent; import com.ljsd.jieling.ktbeans.ReportUtil; import org.springframework.stereotype.Component; - -import java.util.concurrent.ExecutorService; -import java.util.concurrent.Executors; @Component public class DataReportTask extends Thread {