奖励只发送一次

This commit is contained in:
tianfeng 2026-06-05 11:44:51 +08:00
parent 41dcfe0ac2
commit fec2546278

View File

@ -232,27 +232,14 @@ public class WeeklyRewardsSentManager {
// 4. 获取奖励配置并更新
List<ActivityConfigRewardsDTO> kingRewardList = activityConfigDTO.getButOneRewards();
// AR区和非AR区各查一次分别发奖励
String arRegionId = RegionConstants.AR_REGION_IDS.iterator().next();
List<RankingActivityRecord> arRecords = rankingActivityGateway.getRankingList(
List<RankingActivityRecord> records = rankingActivityGateway.getRankingList(
sysOrigin, rankingActivityType, cycleType, cycleKey, null,
isKingGames(activityConfigDTO) ? 10 : 3,
arRegionId
);
List<RankingActivityRecord> otherRecords = rankingActivityGateway.getRankingList(
sysOrigin, rankingActivityType, cycleType, cycleKey, null,
isKingGames(activityConfigDTO) ? 10 : 3,
RegionConstants.OTHER_REGION_PLACEHOLDER
null
);
// 发放活动奖励
if (isKingGames(activityConfigDTO)) {
sendCustomRankingActivityRewards(SysOriginPlatformEnum.ATYOU, activityId, arRecords, kingRewardList);
sendCustomRankingActivityRewards(SysOriginPlatformEnum.ATYOU, activityId, otherRecords, kingRewardList);
} else {
sendRankingActivityRewards(SysOriginPlatformEnum.ATYOU, activityId, arRecords, kingRewardList);
sendRankingActivityRewards(SysOriginPlatformEnum.ATYOU, activityId, otherRecords, kingRewardList);
}
sendRankingActivityRewards(SysOriginPlatformEnum.ATYOU, activityId, records, kingRewardList);
log.info("上周{}活动奖励发放完成, 活动ID: {}", activityConfigDTO.getRemark(), activityId);