|
|
@@ -36,13 +36,13 @@ public class OrderCancelService {
|
|
|
@PostConstruct
|
|
|
public void init() {
|
|
|
orderCancelInterval = sysConfigRepo.findByName("order_cancel_interval")
|
|
|
- .map(SysConfig::getValue).map(Integer::parseInt).orElse(orderCancelInterval);
|
|
|
+ .map(SysConfig::getValue).map(Integer::parseInt).orElse(210);
|
|
|
}
|
|
|
|
|
|
@Scheduled(fixedRate = 30000)
|
|
|
public void batchCancel() {
|
|
|
List<Order> orders = orderRepo.findByStatusAndCreatedAtBeforeAndDelFalse(OrderStatus.NOT_PAID,
|
|
|
- LocalDateTime.now().minusSeconds(600));
|
|
|
+ LocalDateTime.now().minusSeconds(orderCancelInterval));
|
|
|
orders.parallelStream().forEach(o -> {
|
|
|
try {
|
|
|
Order order = orderRepo.findById(o.getId()).orElseThrow(new BusinessException("订单不存在"));
|