This commit is contained in:
zt
2025-02-26 14:44:44 +08:00
parent e7ce2668a3
commit 2fc4303db9
3 changed files with 10 additions and 2 deletions

View File

@ -87,7 +87,7 @@ public class BalanceDeductionJob implements JobHandler {
List<Long> ids = abnormal.stream().map(DiningPlatesDO::getId).collect(Collectors.toList()); List<Long> ids = abnormal.stream().map(DiningPlatesDO::getId).collect(Collectors.toList());
List<Long> orderIds = abnormal.stream().map(DiningPlatesDO::getOrderId).collect(Collectors.toList()); List<Long> orderIds = abnormal.stream().map(DiningPlatesDO::getOrderId).collect(Collectors.toList());
//获取异常用户订单 //获取异常用户订单
List<DishOrderDO> toPay = orderService.getToPayByOrder(orderIds); List<DishOrderDO> toPay = orderService.getToPayByOrderAbnormal(orderIds);
toPay.forEach(dishOrderDO -> { toPay.forEach(dishOrderDO -> {
deductionService.abnormalOrderHandle(dishOrderDO); deductionService.abnormalOrderHandle(dishOrderDO);
}); });

View File

@ -86,7 +86,7 @@ public interface OrderService {
* 获取用户的异常订单 * 获取用户的异常订单
* @return * @return
*/ */
List<DishOrderDO> getToPayByOrder(List<Long> orderIds); List<DishOrderDO> getToPayByOrderAbnormal(List<Long> orderIds);
/** /**
* 更改用户的支付状态 * 更改用户的支付状态

View File

@ -332,6 +332,14 @@ public class OrderServiceImpl implements OrderService {
@Override @Override
public List<DishOrderDO> getToPayByOrder(List<Long> orderIds) { public List<DishOrderDO> getToPayByOrder(List<Long> orderIds) {
List<DishOrderDO> dishOrderDOS = dishOrderMapper.selectList(Wrappers.<DishOrderDO>lambdaQuery()
.in(DishOrderDO::getId, orderIds)
.eq(DishOrderDO::getOrderStatus, DishOrderDO.INCOMPLETE));
return dishOrderDOS;
}
@Override
public List<DishOrderDO> getToPayByOrderAbnormal(List<Long> orderIds) {
List<DishOrderDO> dishOrderDOS = dishOrderMapper.selectList(Wrappers.<DishOrderDO>lambdaQuery() List<DishOrderDO> dishOrderDOS = dishOrderMapper.selectList(Wrappers.<DishOrderDO>lambdaQuery()
.in(DishOrderDO::getId, orderIds) .in(DishOrderDO::getId, orderIds)
.eq(DishOrderDO::getOrderStatus, DishOrderDO.ABNORMAL)); .eq(DishOrderDO::getOrderStatus, DishOrderDO.ABNORMAL));