|
|
@@ -166,8 +166,8 @@ public class WithdrawApplyService {
|
|
|
@RedisLock(value = "'approveAll'", expire = 1, unit = TimeUnit.HOURS)
|
|
|
public void approveAll() throws ExecutionException, InterruptedException {
|
|
|
new ForkJoinPool(5).submit(() -> {
|
|
|
- withdrawApplyRepo.findByCreatedAtBetweenAndStatus(LocalDate.now().minusDays(1).atStartOfDay(),
|
|
|
- LocalDate.now().minusDays(1).atTime(LocalTime.MAX), WithdrawStatus.PENDING)
|
|
|
+ withdrawApplyRepo.findByCreatedAtBeforeAndStatus(LocalDate.now().minusDays(1).atStartOfDay(),
|
|
|
+ WithdrawStatus.PENDING)
|
|
|
.parallelStream().forEach(withdrawApply -> {
|
|
|
try {
|
|
|
finishWithdrawApply(withdrawApply.getId(), true, null);
|