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

giftGiveRunningWater logs插入注释

Browse Source
This commit is contained in:
tianfeng 2026-03-02 15:25:50 +08:00
parent bbaaacc3e3
commit bcabd67844
6 changed files with 12 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -65,7 +65,7 @@ public class DiamondCountStrategy implements GiftStrategy {
log.warn("【钻石统计】没有找到流水信息，忽律处理"); log.warn("【钻石统计】没有找到流水信息，忽律处理");
return; return;
} }
giftGiveRunningWaterService.addLog(runningWater.getId(), "开始：钻石统计策略"); // giftGiveRunningWaterService.addLog(runningWater.getId(), "开始：钻石统计策略");
GiftGiveRunningWater finalRunningWater = runningWater; GiftGiveRunningWater finalRunningWater = runningWater;
runningWater.getAcceptUsers().forEach(accept -> { runningWater.getAcceptUsers().forEach(accept -> {
@ -94,7 +94,7 @@ public class DiamondCountStrategy implements GiftStrategy {
}); });
giftGiveRunningWaterService.addLog(runningWater.getId(), "结束：钻石统计相关"); // giftGiveRunningWaterService.addLog(runningWater.getId(), "结束：钻石统计相关");
} }

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

@ -102,7 +102,7 @@ public class GiftAnchorCountStrategy implements GiftStrategy {
log.warn("【主播统计】没有找到流水信息，忽律处理"); log.warn("【主播统计】没有找到流水信息，忽律处理");
return; return;
} }
giftGiveRunningWaterService.addLog(runningWater.getId(), "开始：主播统计相关"); // giftGiveRunningWaterService.addLog(runningWater.getId(), "开始：主播统计相关");
GiftValue giftValue = runningWater.getGiftValue(); GiftValue giftValue = runningWater.getGiftValue();
@ -171,7 +171,7 @@ public class GiftAnchorCountStrategy implements GiftStrategy {
// teamSalaryMqMessage.sendSalaryCount(teamIds); // teamSalaryMqMessage.sendSalaryCount(teamIds);
//teamSalaryMqMessage.sendSalary(teamIds, false); //teamSalaryMqMessage.sendSalary(teamIds, false);
} }
giftGiveRunningWaterService.addLog(runningWater.getId(), "结束：主播统计相关"); // giftGiveRunningWaterService.addLog(runningWater.getId(), "结束：主播统计相关");
// CompletableFuture.runAsync(() -> { // CompletableFuture.runAsync(() -> {
// log.warn("异步同步钻石情况{}", teamIds); // log.warn("异步同步钻石情况{}", teamIds);

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

@ -164,7 +164,7 @@ public class GiftCountStrategy implements GiftStrategy {
|| !GiftCurrencyType.GOLD.eq(giftValue.getCurrencyType())) { || !GiftCurrencyType.GOLD.eq(giftValue.getCurrencyType())) {
return; return;
} }
giftGiveRunningWaterService.addLog(runningWater.getId(), "开始：礼物统计相关"); // giftGiveRunningWaterService.addLog(runningWater.getId(), "开始：礼物统计相关");
// 幸运礼物比例 // 幸运礼物比例
BigDecimal luckyGiftRatio = gameLuckyGiftCommon.getLuckyGiftShareRatio(runningWater.getSysOrigin()); BigDecimal luckyGiftRatio = gameLuckyGiftCommon.getLuckyGiftShareRatio(runningWater.getSysOrigin());
@ -207,7 +207,7 @@ public class GiftCountStrategy implements GiftStrategy {
// Spins 送礼物任务 // Spins 送礼物任务
handleSpinsGiftTask(runningWater); handleSpinsGiftTask(runningWater);
giftGiveRunningWaterService.addLog(runningWater.getId(), "结束：礼物统计相关"); // giftGiveRunningWaterService.addLog(runningWater.getId(), "结束：礼物统计相关");
} }
private void saveConfessionChance(GiftGiveRunningWater runningWater) { private void saveConfessionChance(GiftGiveRunningWater runningWater) {

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

@ -71,7 +71,7 @@ public class GiftPrizeAcceptStrategy implements GiftStrategy {
return; return;
} }
giftGiveRunningWaterService.addLog(runningWater.getId(), "开始：接收奖品策略"); // giftGiveRunningWaterService.addLog(runningWater.getId(), "开始：接收奖品策略");
runningWater.getAcceptUsers().forEach(accept -> { runningWater.getAcceptUsers().forEach(accept -> {
@ -112,8 +112,7 @@ public class GiftPrizeAcceptStrategy implements GiftStrategy {
} }
}); });
giftGiveRunningWaterService.addLog(runningWater.getId(), // giftGiveRunningWaterService.addLog(runningWater.getId(),"结束：接收奖品策略(礼物墙、积分/钻石发放)");
"结束：接收奖品策略(礼物墙、积分/钻石发放)");
} }
/** /**

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

@ -68,7 +68,7 @@ public class GiftRocketListener implements GiftStrategy {
return; return;
} }
giftGiveRunningWaterService.addLog(runningWater.getId(), "开始：火箭能量增加"); // giftGiveRunningWaterService.addLog(runningWater.getId(), "开始：火箭能量增加");
try { try {
// 3. 获取礼物信息 // 3. 获取礼物信息
@ -103,7 +103,7 @@ public class GiftRocketListener implements GiftStrategy {
} catch (Exception e) { } catch (Exception e) {
log.error("【火箭能量增加】处理异常: runningWaterId={}", runningWater.getId(), e); log.error("【火箭能量增加】处理异常: runningWaterId={}", runningWater.getId(), e);
} finally { } finally {
giftGiveRunningWaterService.addLog(runningWater.getId(), "结束：火箭能量增加"); // giftGiveRunningWaterService.addLog(runningWater.getId(), "结束：火箭能量增加");
} }
} }

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

@ -98,7 +98,7 @@ public class RankCountStrategy implements GiftStrategy {
if (!GiftCurrencyType.GOLD.eq(runningWater.getGiftValue().getCurrencyType())) { if (!GiftCurrencyType.GOLD.eq(runningWater.getGiftValue().getCurrencyType())) {
return; return;
} }
giftGiveRunningWaterService.addLog(runningWater.getId(), "开始：排行榜相关统计"); // giftGiveRunningWaterService.addLog(runningWater.getId(), "开始：排行榜相关统计");
GiftValue giftValue = runningWater.getGiftValue(); GiftValue giftValue = runningWater.getGiftValue();
@ -145,7 +145,7 @@ public class RankCountStrategy implements GiftStrategy {
// 首页排行榜 // 首页排行榜
homeRank(runningWater, giftRatio); homeRank(runningWater, giftRatio);
giftGiveRunningWaterService.addLog(runningWater.getId(), "结束：排行榜相关统计"); // giftGiveRunningWaterService.addLog(runningWater.getId(), "结束：排行榜相关统计");
} }
private BigDecimal getGiftRatio(GiftGiveRunningWater runningWater) { private BigDecimal getGiftRatio(GiftGiveRunningWater runningWater) {