diff --git a/src/main/java/com/sczx/order/task/NoPayOrderProcessTask.java b/src/main/java/com/sczx/order/task/NoPayOrderProcessTask.java index be62bb7..9423d2f 100644 --- a/src/main/java/com/sczx/order/task/NoPayOrderProcessTask.java +++ b/src/main/java/com/sczx/order/task/NoPayOrderProcessTask.java @@ -118,9 +118,10 @@ public class NoPayOrderProcessTask { orderProcessPO.setRetryNum(1); orderProcessRepo.save(orderProcessPO); }else { + orderProcessPO.setRetryNum(orderProcessPO.getRetryNum()+1); LambdaUpdateWrapper updateWrapper = new LambdaUpdateWrapper<>(); updateWrapper.eq(OrderProcessPO::getId, orderProcessPO.getId()) - .set(OrderProcessPO::getRetryNum, orderProcessPO.getRetryNum()+1); + .set(OrderProcessPO::getRetryNum, orderProcessPO.getRetryNum()); orderProcessRepo.update(updateWrapper); } diff --git a/src/main/java/com/sczx/order/task/RefundSubOrderProcessTask.java b/src/main/java/com/sczx/order/task/RefundSubOrderProcessTask.java index 25cf1d7..d1fa053 100644 --- a/src/main/java/com/sczx/order/task/RefundSubOrderProcessTask.java +++ b/src/main/java/com/sczx/order/task/RefundSubOrderProcessTask.java @@ -118,9 +118,10 @@ public class RefundSubOrderProcessTask { orderProcessPO.setRetryNum(1); orderProcessRepo.save(orderProcessPO); }else { + orderProcessPO.setRetryNum(orderProcessPO.getRetryNum()+1); LambdaUpdateWrapper updateWrapper = new LambdaUpdateWrapper<>(); updateWrapper.eq(OrderProcessPO::getId, orderProcessPO.getId()) - .set(OrderProcessPO::getRetryNum, orderProcessPO.getRetryNum()+1); + .set(OrderProcessPO::getRetryNum, orderProcessPO.getRetryNum()); orderProcessRepo.update(updateWrapper); } if(orderProcessPO.getRetryNum()>5){