diff --git a/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java b/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java index fba7c622..c360f66f 100644 --- a/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java +++ b/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java @@ -111,7 +111,9 @@ public class TempOrdersTask { // .lt(Orders::getCreateTime, DateUtil.offsetMinute(DateUtil.date(), -15))); List payDetailsList = payDetailsDao.selectList(new LambdaQueryWrapper() .eq(PayDetails::getState, 0) - .lt(PayDetails::getCreateTime, DateUtil.offsetMinute(DateUtil.date(), -15))); + .lt(PayDetails::getCreateTime, DateUtil.offsetMinute(DateUtil.date(), -15)) + .last(" order by create_time asc limit 1800") + ); if (CollUtil.isEmpty(payDetailsList)) { return; } diff --git a/src/main/java/com/sqx/modules/pay/controller/app/WuyouController.java b/src/main/java/com/sqx/modules/pay/controller/app/WuyouController.java index 413f1367..bbd3582a 100644 --- a/src/main/java/com/sqx/modules/pay/controller/app/WuyouController.java +++ b/src/main/java/com/sqx/modules/pay/controller/app/WuyouController.java @@ -123,6 +123,13 @@ public class WuyouController { payType); if (baseResp.getCode() == null) { if (baseResp.getErrorMsg().contains("通道拥挤")) { + order.setStatus(3); + ordersService.update(order, new LambdaQueryWrapper() + .eq(Orders::getOrdersId, order.getOrdersId()).eq(Orders::getUserId, order.getUserId())); + + payDetails.setState(2); + payDetailsDao.update(payDetails, new LambdaQueryWrapper() + .eq(PayDetails::getId, payDetails.getId()).eq(PayDetails::getUserId, payDetails.getUserId())); return Result.error("系统繁忙,请稍后再尝试购买"); } return Result.error(baseResp.getErrorMsg());