From 65045c93d95fcd02d37835b1e2ceec85e9568044 Mon Sep 17 00:00:00 2001 From: xuexinpeng Date: Fri, 10 Sep 2021 22:50:10 +0800 Subject: [PATCH] =?UTF-8?q?=E7=8E=89=E8=99=9A=E8=AE=BA=E9=81=93=E4=BA=8C?= =?UTF-8?q?=E7=89=88?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../handler/player/GetPlayerOneTeamInfo.java | 32 ++++++------------- .../crossService/CrossServiceLogic.java | 3 ++ .../logic/arena/CrossYuxulundaoLogic.java | 2 +- .../jieling/logic/player/PlayerLogic.java | 12 ++++++- .../ljsd/jieling/thread/task/MinuteTask.java | 2 +- 5 files changed, 25 insertions(+), 26 deletions(-) diff --git a/serverlogic/src/main/java/com/ljsd/jieling/handler/player/GetPlayerOneTeamInfo.java b/serverlogic/src/main/java/com/ljsd/jieling/handler/player/GetPlayerOneTeamInfo.java index 3ac5a78a8..65c162123 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/handler/player/GetPlayerOneTeamInfo.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/handler/player/GetPlayerOneTeamInfo.java @@ -14,8 +14,6 @@ import org.springframework.stereotype.Component; import rpc.protocols.MessageTypeProto; import rpc.protocols.PlayerInfoProto; -import java.util.List; - @Component public class GetPlayerOneTeamInfo extends BaseHandler { @Override @@ -27,40 +25,28 @@ public class GetPlayerOneTeamInfo extends BaseHandler arenaRank = RedisUtil.getInstence().getReverseZset(rkey, 0, 1); + Set arenaRank = RedisUtil.getInstence().getReverseZset(rkey, 0, -1); List arenaRankfilt = arenaRank.stream().mapToInt(n -> Integer.parseInt(n)).filter(n -> n > 1000).boxed().collect(Collectors.toList()); for (int i = 0; i < arenaRankfilt.size(); i++) { SMServerRankReward config = SMServerRankReward.getIdByScore(i + 1); 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 0916df0a5..9fd3b9ce8 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 @@ -16,6 +16,7 @@ import com.ljsd.jieling.globals.Global; import com.ljsd.jieling.jbean.ActivityMission; import com.ljsd.jieling.ktbeans.ReportEventEnum; import com.ljsd.jieling.ktbeans.ReportUtil; +import com.ljsd.jieling.logic.GlobleSystemLogic; import com.ljsd.jieling.logic.activity.ActivityLogic; import com.ljsd.jieling.logic.activity.ActivityType; import com.ljsd.jieling.logic.activity.crossService.CrossServiceLogic; @@ -687,10 +688,19 @@ public class PlayerLogic { } public CommonProto.TeamOneInfo.Builder getYuxuRobotTeamInfo(SArenaRobotConfig sArenaRobotConfig,List crossTeamId){ + int crossGroup = GlobleSystemLogic.getInstence().getCrossGroup(); + if (crossGroup == -1) { + return CommonProto.TeamOneInfo.newBuilder(); + } + //TODO + Map groupValues = RedisUtil.getInstence().getMapValues(RedisKey.SERVER_SPLIT_INFO, "", Integer.class, Integer.class); + List groupList = groupValues.entrySet().stream().filter(n -> n.getValue() == crossGroup).map(keyVal -> keyVal.getKey()).collect(Collectors.toList()); + int server = new Random().nextInt(groupList.size()); + CommonProto.TeamOneInfo.Builder oneInfo = CommonProto.TeamOneInfo.newBuilder() .setLevel(sArenaRobotConfig.getRobotLevel()) .setName(sArenaRobotConfig.getRobotName()) - .setUid(sArenaRobotConfig.getId()).setCrossTeamScore(sArenaRobotConfig.getMsScroe()).setServerName("S10"); + .setUid(sArenaRobotConfig.getId()).setCrossTeamScore(sArenaRobotConfig.getMsScroe()).setServerName(String.valueOf(groupList.get(server))); //CommonProto.TeamOneTeamInfo.Builder teamInfo = CommonProto.TeamOneTeamInfo.newBuilder(); if(sArenaRobotConfig.getDifferDemonsId()!=null){ diff --git a/serverlogic/src/main/java/com/ljsd/jieling/thread/task/MinuteTask.java b/serverlogic/src/main/java/com/ljsd/jieling/thread/task/MinuteTask.java index ab343e712..059606eed 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/thread/task/MinuteTask.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/thread/task/MinuteTask.java @@ -285,7 +285,7 @@ public class MinuteTask extends Thread { int hour = calendar.get(Calendar.HOUR_OF_DAY); int minute = calendar.get(Calendar.MINUTE); int w = calendar.get(Calendar.DAY_OF_WEEK) - 1; - if(w == 1 &&hour == 23 && minute ==50){ + if(w == 0 &&hour == 23 && minute ==50){ LOGGER.info("everySundaySpecialClockTask yuxulundao send reward start ..."); //玉虚论道23.50分执行 CrossYuxulundaoLogic.getInstance().sendReward();