sql优化
This commit is contained in:
@ -31,7 +31,7 @@ public class OrderOverdueTask {
|
|||||||
* lockAtMostFor:锁最多持有时间,防止节点宕机导致锁无法释放
|
* lockAtMostFor:锁最多持有时间,防止节点宕机导致锁无法释放
|
||||||
* lockAtLeastFor:锁最少持有时间,防止任务执行过快导致频繁执行
|
* lockAtLeastFor:锁最少持有时间,防止任务执行过快导致频繁执行
|
||||||
*/
|
*/
|
||||||
@Scheduled(cron = "0 */30 * * * ?")
|
@Scheduled(cron = "0 */1 * * * ?")
|
||||||
@SchedulerLock(name = "checkOverdueOrders", lockAtMostFor = "9m", lockAtLeastFor = "1m")
|
@SchedulerLock(name = "checkOverdueOrders", lockAtMostFor = "9m", lockAtLeastFor = "1m")
|
||||||
public void checkOverdueOrders() {
|
public void checkOverdueOrders() {
|
||||||
log.info("开始执行逾期订单检查任务");
|
log.info("开始执行逾期订单检查任务");
|
||||||
@ -52,6 +52,7 @@ public class OrderOverdueTask {
|
|||||||
LambdaQueryWrapper<OrderMainPO> queryWrapper = new LambdaQueryWrapper<>();
|
LambdaQueryWrapper<OrderMainPO> queryWrapper = new LambdaQueryWrapper<>();
|
||||||
queryWrapper.in(OrderMainPO::getOrderStatus,
|
queryWrapper.in(OrderMainPO::getOrderStatus,
|
||||||
Collections.singletonList(OrderStatusEnum.RENT_ING.getCode()))
|
Collections.singletonList(OrderStatusEnum.RENT_ING.getCode()))
|
||||||
|
.isNotNull(OrderMainPO::getEndRentTime)
|
||||||
.lt(OrderMainPO::getEndRentTime, LocalDateTime.now());
|
.lt(OrderMainPO::getEndRentTime, LocalDateTime.now());
|
||||||
|
|
||||||
List<OrderMainPO> overdueOrders = orderMainRepo.list(queryWrapper);
|
List<OrderMainPO> overdueOrders = orderMainRepo.list(queryWrapper);
|
||||||
|
|||||||
Reference in New Issue
Block a user