SpringBoot中实现订单30分钟自动取消的项目实践

@Entity
public class Order {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;
    @Column(nullable = false)
    private LocalDateTime createTime;
    @Enumerated(EnumType.STRING)
    private OrderStatus status;
    @Column(nullable = false)
    private BigDecimal amount;
    // 其他属性和方法
}

@Service
public class OrderCancellationService {
    @Autowired
    private OrderRepository orderRepository;
    public void cancelOrdersAfterTimeout() {
        List<Order> pendingOrders = orderRepository.findByStatusAndCreateTimeBefore(
            OrderStatus.PENDING_PAYMENT, LocalDateTime.now().minusMinutes(30)
        );
        for (Order order : pendingOrders) {
            // 取消订单的逻辑，可以更新订单状态为已取消
            order.setStatus(OrderStatus.CANCELLED);
            orderRepository.save(order);
        }
    }
}

@Configuration
@EnableScheduling
public class ScheduledTasks {
    @Autowired
    private OrderCancellationService orderCancellationService;
    @Scheduled(fixedRate = 60000) // 每分钟执行一次
    public void cancelPendingOrders() {
        orderCancellationService.cancelOrdersAfterTimeout();
    }
}

@SpringBootTest
@RunWith(SpringRunner.class)
public class OrderCancellationServiceTests {
    @Autowired
    private OrderCancellationService orderCancellationService;
    @Autowired
    private OrderRepository orderRepository;
    @Test
    public void testCancelPendingOrders() {
        // 创建一个待支付订单，订单创建时间在30分钟之前
        Order order = new Order();
        order.setCreateTime(LocalDateTime.now().minusMinutes(31));
        order.setStatus(OrderStatus.PENDING_PAYMENT);
        order.setAmount(BigDecimal.TEN);
        orderRepository.save(order);
        // 执行自动取消任务
        orderCancellationService.cancelOrdersAfterTimeout();
        // 验证订单状态是否已取消
        Order cancelledOrder = orderRepository.findById(order.getId()).orElse(null);
        assertNotNull(cancelledOrder);
        assertEquals(OrderStatus.CANCELLED, cancelledOrder.getStatus());
    }
}