新增开奖定时任务 ,修改聚宝盆开奖规则

master
袁野 1 month ago
parent cd6afe3404
commit e1602d076c
  1. 7
      service/src/main/java/com/hfkj/service/partner/Impl/PartnerServiceImpl.java

@ -66,6 +66,7 @@ public class PartnerServiceImpl implements PartnerService {
throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "当前时间不允许投入!");
}
Long userId = jsonObject.getLong("userId");
BsUser user = bsUserService.getUser(userId);
BigDecimal goldCoin = jsonObject.getBigDecimal("goldCoin");
// 锁编号
String lockKey = LOCK_KEY + userId;
@ -90,6 +91,7 @@ public class PartnerServiceImpl implements PartnerService {
// 插入投入记录
BsPartnerPoolPre partnerPoolPre = new BsPartnerPoolPre();
partnerPoolPre.setUserId(userId);
partnerPoolPre.setUserName(user.getName());
partnerPoolPre.setCampaignNo(newRank(jsonObject.getInteger("level")));
partnerPoolPre.setLotteryNo(lotteryNo);
partnerPoolPre.setLevel(jsonObject.getInteger("level"));
@ -209,6 +211,7 @@ public class PartnerServiceImpl implements PartnerService {
}
// 配置参数
pool.setUserId(partnerPoolPre.getUserId());
pool.setUserName(partnerPoolPre.getUserName());
pool.setGoldCoin(partnerPoolPre.getGoldCoin());
pools.add(pool);
// 竞选成功预展 位置
@ -245,6 +248,7 @@ public class PartnerServiceImpl implements PartnerService {
}
// 配置参数
pool.setUserId(partnerPoolPre.getUserId());
pool.setUserName(partnerPoolPre.getUserName());
pool.setGoldCoin(partnerPoolPre.getGoldCoin());
pools.add(pool);
partnerPoolsL2 = partnerPoolsL2.stream()
@ -281,6 +285,7 @@ public class PartnerServiceImpl implements PartnerService {
}
// 配置参数
pool.setUserId(partnerPoolPre.getUserId());
pool.setUserName(partnerPoolPre.getUserName());
pool.setGoldCoin(partnerPoolPre.getGoldCoin());
pools.add(pool);
partnerPoolsL3 = partnerPoolsL3.stream()
@ -316,6 +321,7 @@ public class PartnerServiceImpl implements PartnerService {
}
// 配置参数
pool.setUserId(partnerPoolPre.getUserId());
pool.setUserName(partnerPoolPre.getUserName());
pool.setGoldCoin(partnerPoolPre.getGoldCoin());
pools.add(pool);
partnerPoolsL4 = partnerPoolsL4.stream()
@ -351,6 +357,7 @@ public class PartnerServiceImpl implements PartnerService {
}
// 配置参数
pool.setUserId(partnerPoolPre.getUserId());
pool.setUserName(partnerPoolPre.getUserName());
pool.setGoldCoin(partnerPoolPre.getGoldCoin());
pools.add(pool);
partnerPoolsL5 = partnerPoolsL5.stream()

Loading…
Cancel
Save