czg_team/video_server
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

bug fix

Browse Source
This commit is contained in:
GYJ
2024-12-28 19:19:52 +08:00
parent acccb9b7df
commit fde0d80a16
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/com/sqx/modules/job/task/SupplyAgainSignRewardTask.java
View File

@@ -54,7 +54,9 @@ public class SupplyAgainSignRewardTask implements ITask {
log.error("没有邀请的用户 用户 ID {}", userId); log.error("没有邀请的用户 用户 ID {}", userId);
} }
Double inviteAmount = 0.0;
String amount = commonRepository.findOne(912).getValue(); String amount = commonRepository.findOne(912).getValue();
double doubleAmount = Double.parseDouble(amount);
for (Long inviteeUserId : userIdList) { for (Long inviteeUserId : userIdList) {
QueryWrapper<UserMoneyDetails> queryWrapper = new QueryWrapper<>(); QueryWrapper<UserMoneyDetails> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("classify", 6); queryWrapper.eq("classify", 6);
@@ -79,10 +81,14 @@ public class SupplyAgainSignRewardTask implements ITask {
userMoneyDetails.setMoneyType(1); userMoneyDetails.setMoneyType(1);
userMoneyDetailsService.save(userMoneyDetails); userMoneyDetailsService.save(userMoneyDetails);
//存入余额 钱 //存入余额 钱
userMoneyService.updateAmount(1, inviteeUserId, Double.parseDouble(amount)); inviteAmount += doubleAmount;
log.info("发放过奖励, 用户 ID {}， 邀请 ID {}", userId, inviteeUserId); log.info("发放过奖励, 用户 ID {}， 邀请 ID {}", userId, inviteeUserId);
} }
if (inviteAmount > 0) {
userMoneyService.updateAmount(1, userId, inviteAmount);
}
log.info("补发奖励结束"); log.info("补发奖励结束");
} }
} }