hy/aslan-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

古尔邦节排行榜处理

Browse Source 
(cherry picked from commit 8d3c56838ce080d526cd0e20cddbe7ae4532b1ea)
This commit is contained in:
tianfeng 2026-05-25 14:26:25 +08:00
parent 905e001d08
commit b83ae626ef
1 changed files with 18 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/activity/query/RankingListQryExe.java
View File

@ -66,12 +66,7 @@ public class RankingListQryExe {
} }
// 查询排行榜列表 // 查询排行榜列表
String regionId = cmd.getRegionId() != null ? cmd.getRegionId() String regionId = resolveRegionId(cmd, activityType);
: (cmd.getReqUserId() != null ? userRegionGateway.getRegionId(cmd.getReqUserId()) : null);
// 邀请活动特殊处理
if (activityType == RankingActivityType.INVITE) {
regionId = "OTHER";
}
List<RankingActivityRecord> records = rankingActivityGateway.getRankingList( List<RankingActivityRecord> records = rankingActivityGateway.getRankingList(
cmd.getReqSysOrigin().getOrigin(), cmd.getReqSysOrigin().getOrigin(),
@ -152,7 +147,23 @@ public class RankingListQryExe {
return result; return result;
} }
private Set<Long> getUserIds(List<RankingActivityRecord> records) { /**
* 解析 regionId：不分区类型返回 null，邀请活动固定 OTHER，其余按用户地区
*/
private String resolveRegionId(RankingListQueryCmd cmd, RankingActivityType activityType) {
if (activityType.isNoPartition()) {
return null;
}
if (activityType == RankingActivityType.INVITE) {
return "OTHER";
}
if (cmd.getRegionId() != null) {
return cmd.getRegionId();
}
return cmd.getReqUserId() != null ? userRegionGateway.getRegionId(cmd.getReqUserId()) : null;
}
private Set<Long> getUserIds(List<RankingActivityRecord> records) {
return records.stream().map(RankingActivityRecord::getUserId).collect(Collectors.toSet()); return records.stream().map(RankingActivityRecord::getUserId).collect(Collectors.toSet());
} }