sczx_group/sczx_order
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

计算重试次数

Browse Source
This commit is contained in:
zhangli
2025-09-27 23:47:28 +08:00
parent 9162888023
commit 164434b3da
2 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/com/sczx/order/task/NoPayOrderProcessTask.java
View File

@ -118,9 +118,10 @@ public class NoPayOrderProcessTask {
orderProcessPO.setRetryNum(1); orderProcessPO.setRetryNum(1);
orderProcessRepo.save(orderProcessPO); orderProcessRepo.save(orderProcessPO);
}else { }else {
orderProcessPO.setRetryNum(orderProcessPO.getRetryNum()+1);
LambdaUpdateWrapper<OrderProcessPO> updateWrapper = new LambdaUpdateWrapper<>(); LambdaUpdateWrapper<OrderProcessPO> updateWrapper = new LambdaUpdateWrapper<>();
updateWrapper.eq(OrderProcessPO::getId, orderProcessPO.getId()) updateWrapper.eq(OrderProcessPO::getId, orderProcessPO.getId())
.set(OrderProcessPO::getRetryNum, orderProcessPO.getRetryNum()+1); .set(OrderProcessPO::getRetryNum, orderProcessPO.getRetryNum());
orderProcessRepo.update(updateWrapper); orderProcessRepo.update(updateWrapper);
} }

3
src/main/java/com/sczx/order/task/RefundSubOrderProcessTask.java
View File

@ -118,9 +118,10 @@ public class RefundSubOrderProcessTask {
orderProcessPO.setRetryNum(1); orderProcessPO.setRetryNum(1);
orderProcessRepo.save(orderProcessPO); orderProcessRepo.save(orderProcessPO);
}else { }else {
orderProcessPO.setRetryNum(orderProcessPO.getRetryNum()+1);
LambdaUpdateWrapper<OrderProcessPO> updateWrapper = new LambdaUpdateWrapper<>(); LambdaUpdateWrapper<OrderProcessPO> updateWrapper = new LambdaUpdateWrapper<>();
updateWrapper.eq(OrderProcessPO::getId, orderProcessPO.getId()) updateWrapper.eq(OrderProcessPO::getId, orderProcessPO.getId())
.set(OrderProcessPO::getRetryNum, orderProcessPO.getRetryNum()+1); .set(OrderProcessPO::getRetryNum, orderProcessPO.getRetryNum());
orderProcessRepo.update(updateWrapper); orderProcessRepo.update(updateWrapper);
} }
if(orderProcessPO.getRetryNum()>5){ if(orderProcessPO.getRetryNum()>5){