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 22:56:42 +08:00
parent 872d1d1b7b
commit 9162888023
2 changed files with 9 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1,6 +1,7 @@
package com.sczx.order.task; package com.sczx.order.task;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.sczx.order.common.enums.OrderStatusEnum; import com.sczx.order.common.enums.OrderStatusEnum;
import com.sczx.order.dto.PayOrderReq; import com.sczx.order.dto.PayOrderReq;
import com.sczx.order.po.OrderMainPO; import com.sczx.order.po.OrderMainPO;
@ -117,8 +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<>();
orderProcessRepo.saveOrUpdate(orderProcessPO); updateWrapper.eq(OrderProcessPO::getId, orderProcessPO.getId())
.set(OrderProcessPO::getRetryNum, orderProcessPO.getRetryNum()+1);
orderProcessRepo.update(updateWrapper);
} }
if(orderProcessPO.getRetryNum()>5){ if(orderProcessPO.getRetryNum()>5){

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

@ -118,8 +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<>();
orderProcessRepo.saveOrUpdate(orderProcessPO); updateWrapper.eq(OrderProcessPO::getId, orderProcessPO.getId())
.set(OrderProcessPO::getRetryNum, orderProcessPO.getRetryNum()+1);
orderProcessRepo.update(updateWrapper);
} }
if(orderProcessPO.getRetryNum()>5){ if(orderProcessPO.getRetryNum()>5){
log.info("支付单单{}已超过最大重试次数，强行关闭支付单", subPO.getSuborderNo()); log.info("支付单单{}已超过最大重试次数，强行关闭支付单", subPO.getSuborderNo());