|
|
@@ -203,7 +203,8 @@ public class KxsCampServiceImpl extends ServiceImpl<KxsCampMapper, KxsCamp> impl
|
|
|
public void prizePoolIsRefreshed() {
|
|
|
//查询正在进行中的活动
|
|
|
LocalDateTime now = LocalDateTime.now();
|
|
|
- List<KxsCamp> list = baseMapper.selectList(Wrappers.<KxsCamp>lambdaQuery().ge(KxsCamp::getStartTime, now).le(KxsCamp::getEndTime, now));
|
|
|
+ //定时任务执行中时，查询当前正在进行的活动，由于定时任务执行时间偏差，当前时间减1一分钟判断
|
|
|
+ List<KxsCamp> list = baseMapper.selectList(Wrappers.<KxsCamp>lambdaQuery().le(KxsCamp::getStartTime, now).ge(KxsCamp::getEndTime, now.minusMinutes(1)));
|
|
|
//查询活动参与的创客
|
|
|
for (KxsCamp kxsCamp : list) {
|
|
|
//初始化奖金池
|
mac