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-11-13 21:52:46 +08:00
parent 66e27e0429
commit 91b876367e
1 changed files with 12 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/rocket/RocketRewardClaimCmdExe.java
View File

@ -155,20 +155,23 @@ public class RocketRewardClaimCmdExe {
// 6. 随机选择一个奖励 // 6. 随机选择一个奖励
PropsActivityRewardConfigInfoDTO selectedReward = rewardList.get(random.nextInt(rewardList.size())); PropsActivityRewardConfigInfoDTO selectedReward = rewardList.get(random.nextInt(rewardList.size()));
// 7. 发放奖励（先发放） // 7. 递增领取人数（发放成功后再递增）
String walletBizNo = RocketRewardLog.buildBizNo(roomId.toString(), userId);
grantReward(userId, selectedReward, walletBizNo);
// 8. 保存领取记录
saveRewardLog(roomId, userId, latestHistory, selectedReward, walletBizNo);
// 9. 递增领取人数（发放成功后再递增）
try { try {
rocketHistoryGateway.incrementClaimCount(historyId); boolean success = rocketHistoryGateway.tryIncrementClaimCount(historyId, rewardQuantity);
if (!success) {
return null;
}
} catch (Exception e) { } catch (Exception e) {
log.error("递增领取人数失败: historyId={}", historyId, e); log.error("递增领取人数失败: historyId={}", historyId, e);
} }
// 8. 发放奖励（先发放）
String walletBizNo = RocketRewardLog.buildBizNo(roomId.toString(), userId);
grantReward(userId, selectedReward, walletBizNo);
// 9. 保存领取记录
saveRewardLog(roomId, userId, latestHistory, selectedReward, walletBizNo);
// 10. 构建返回结果 // 10. 构建返回结果
RocketRewardCO rewardCO = new RocketRewardCO(); RocketRewardCO rewardCO = new RocketRewardCO();
rewardCO.setRewardType(selectedReward.getType()); rewardCO.setRewardType(selectedReward.getType());