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

去除部分冗余逻辑

Browse Source
This commit is contained in:
tianfeng 2025-12-18 17:24:28 +08:00
parent 7fff599f7a
commit 389317b691
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/listener/gift/strategy/GiftAnchorCountStrategy.java
View File

@ -156,10 +156,10 @@ public class GiftAnchorCountStrategy implements GiftStrategy {
teamIds.add(teamMember.getTeamId()); teamIds.add(teamMember.getTeamId());
// 团队内 -> 代理主播活动（永久活动） // 团队内 -> 代理主播活动（永久活动）
activityAgentAnchorCount(acceptAnchorUser.getTargetAmount().longValue(), // activityAgentAnchorCount(acceptAnchorUser.getTargetAmount().longValue(),
acceptAnchorUser.getAcceptUserId(), teamMember.getTeamId()); // acceptAnchorUser.getAcceptUserId(), teamMember.getTeamId());
// 代理活动(永久活动) // 代理活动(永久活动)
agentActivityCount(acceptAnchorUser, teamMember.getTeamId()); // agentActivityCount(acceptAnchorUser, teamMember.getTeamId());
} }
}); });
@ -168,7 +168,7 @@ public class GiftAnchorCountStrategy implements GiftStrategy {
log.warn("发送通知,更新代理工资数据，团队Ids：{}", teamIds); log.warn("发送通知,更新代理工资数据，团队Ids：{}", teamIds);
// 发送通知,更新代理工资数据 // 发送通知,更新代理工资数据
if (CollectionUtils.isNotEmpty(teamIds)) { if (CollectionUtils.isNotEmpty(teamIds)) {
teamSalaryMqMessage.sendSalaryCount(teamIds); // teamSalaryMqMessage.sendSalaryCount(teamIds);
//teamSalaryMqMessage.sendSalary(teamIds, false); //teamSalaryMqMessage.sendSalary(teamIds, false);
} }
giftGiveRunningWaterService.addLog(runningWater.getId(), "结束：主播统计相关"); giftGiveRunningWaterService.addLog(runningWater.getId(), "结束：主播统计相关");