moliparty/peko-java
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

旧红包定时任务

Browse Source
This commit is contained in:
hokli
2025-03-03 14:12:12 +08:00
parent 86874337e5
commit d737716af8
1 changed files with 18 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
accompany-scheduler/accompany-scheduler-service/src/main/java/com/accompany/scheduler/task/redenvelope/RedEnvelopeBackTask.java
View File

@@ -28,23 +28,23 @@ public class RedEnvelopeBackTask extends BaseTask {
private RedEnvelopeStrategyContext redEnvelopeStrategyContext;
@Autowired
private JedisLockService jedisLockService;
@Scheduled(cron = "0 0/1 * * * ?")
@Transactional
public void sendWeekStarAward(){
String lockVal = jedisLockService.lock(RedisKey.lock_red_envelope_task.getKey());
if(StringUtils.isEmpty(lockVal)){
return;
}
try {
log.info("进入过期红包退还定时任务: {}", new Date());
List<Long> redEnvelopeIds = redEnvelopeService.listTimeOutAndNotBackRedEnvelope();
log.info("过期红包id有: {}", redEnvelopeIds);
redEnvelopeIds.forEach(it -> redEnvelopeService.back(it));
log.info("过期红包退还定时任务执行完毕");
} finally {
jedisLockService.unlock(RedisKey.lock_red_envelope_task.getKey(), lockVal);
}
}
//
// @Scheduled(cron = "0 0/1 * * * ?")
// @Transactional
// public void sendWeekStarAward(){
// String lockVal = jedisLockService.lock(RedisKey.lock_red_envelope_task.getKey());
// if(StringUtils.isEmpty(lockVal)){
// return;
// }
// try {
// log.info("进入过期红包退还定时任务: {}", new Date());
// List<Long> redEnvelopeIds = redEnvelopeService.listTimeOutAndNotBackRedEnvelope();
// log.info("过期红包id有: {}", redEnvelopeIds);
// redEnvelopeIds.forEach(it -> redEnvelopeService.back(it));
// log.info("过期红包退还定时任务执行完毕");
// } finally {
// jedisLockService.unlock(RedisKey.lock_red_envelope_task.getKey(), lockVal);
// }
// }
}