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

Compare commits

base: sczx_group:875ac87316d296ae26900ad97f1a155fa95d1dca
Branches Tags
sczx_group:main sczx_group:zhangli-test
...
compare: sczx_group:b811e01da6f2d62af1705382a1e630a40c869ede
Branches Tags
sczx_group:main sczx_group:zhangli-test

2 Commits
875ac87316 ... b811e01da6

Author SHA1 Message Date
zhangli
b811e01da6 Merge branch 'main' of http://115.190.8.52:3000/sczx_group/sczx_order 2025-09-27 23:47:32 +08:00
zhangli
164434b3da 计算重试次数 2025-09-27 23:47:28 +08:00
2 changed files with 4 additions and 2 deletions
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){