diff --git a/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/job/BalanceDeductionJob.java b/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/job/BalanceDeductionJob.java index c5040e39..b5242940 100644 --- a/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/job/BalanceDeductionJob.java +++ b/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/job/BalanceDeductionJob.java @@ -87,7 +87,7 @@ public class BalanceDeductionJob implements JobHandler { List ids = abnormal.stream().map(DiningPlatesDO::getId).collect(Collectors.toList()); List orderIds = abnormal.stream().map(DiningPlatesDO::getOrderId).collect(Collectors.toList()); //获取异常用户订单 - List toPay = orderService.getToPayByOrder(orderIds); + List toPay = orderService.getToPayByOrderAbnormal(orderIds); toPay.forEach(dishOrderDO -> { deductionService.abnormalOrderHandle(dishOrderDO); }); diff --git a/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/service/order/OrderService.java b/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/service/order/OrderService.java index 9cf2b022..1661b19c 100644 --- a/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/service/order/OrderService.java +++ b/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/service/order/OrderService.java @@ -86,7 +86,7 @@ public interface OrderService { * 获取用户的异常订单 * @return */ - List getToPayByOrder(List orderIds); + List getToPayByOrderAbnormal(List orderIds); /** * 更改用户的支付状态 diff --git a/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/service/order/OrderServiceImpl.java b/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/service/order/OrderServiceImpl.java index ea06f7c0..e3221aab 100644 --- a/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/service/order/OrderServiceImpl.java +++ b/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/service/order/OrderServiceImpl.java @@ -332,6 +332,14 @@ public class OrderServiceImpl implements OrderService { @Override public List getToPayByOrder(List orderIds) { + List dishOrderDOS = dishOrderMapper.selectList(Wrappers.lambdaQuery() + .in(DishOrderDO::getId, orderIds) + .eq(DishOrderDO::getOrderStatus, DishOrderDO.INCOMPLETE)); + return dishOrderDOS; + } + + @Override + public List getToPayByOrderAbnormal(List orderIds) { List dishOrderDOS = dishOrderMapper.selectList(Wrappers.lambdaQuery() .in(DishOrderDO::getId, orderIds) .eq(DishOrderDO::getOrderStatus, DishOrderDO.ABNORMAL));