From 91628880233b2f2e56dc3580370843ebf5468c44 Mon Sep 17 00:00:00 2001 From: zhangli <123879394@qq.com> Date: Sat, 27 Sep 2025 22:56:42 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0=E6=AC=A1=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/sczx/order/task/NoPayOrderProcessTask.java | 7 +++++-- .../com/sczx/order/task/RefundSubOrderProcessTask.java | 6 ++++-- 2 files changed, 9 insertions(+), 4 deletions(-) diff --git a/src/main/java/com/sczx/order/task/NoPayOrderProcessTask.java b/src/main/java/com/sczx/order/task/NoPayOrderProcessTask.java index f78a4b8..be62bb7 100644 --- a/src/main/java/com/sczx/order/task/NoPayOrderProcessTask.java +++ b/src/main/java/com/sczx/order/task/NoPayOrderProcessTask.java @@ -1,6 +1,7 @@ package com.sczx.order.task; 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.dto.PayOrderReq; import com.sczx.order.po.OrderMainPO; @@ -117,8 +118,10 @@ public class NoPayOrderProcessTask { orderProcessPO.setRetryNum(1); orderProcessRepo.save(orderProcessPO); }else { - orderProcessPO.setRetryNum(orderProcessPO.getRetryNum()+1); - orderProcessRepo.saveOrUpdate(orderProcessPO); + LambdaUpdateWrapper updateWrapper = new LambdaUpdateWrapper<>(); + updateWrapper.eq(OrderProcessPO::getId, orderProcessPO.getId()) + .set(OrderProcessPO::getRetryNum, orderProcessPO.getRetryNum()+1); + orderProcessRepo.update(updateWrapper); } if(orderProcessPO.getRetryNum()>5){ diff --git a/src/main/java/com/sczx/order/task/RefundSubOrderProcessTask.java b/src/main/java/com/sczx/order/task/RefundSubOrderProcessTask.java index 0bfb445..25cf1d7 100644 --- a/src/main/java/com/sczx/order/task/RefundSubOrderProcessTask.java +++ b/src/main/java/com/sczx/order/task/RefundSubOrderProcessTask.java @@ -118,8 +118,10 @@ public class RefundSubOrderProcessTask { orderProcessPO.setRetryNum(1); orderProcessRepo.save(orderProcessPO); }else { - orderProcessPO.setRetryNum(orderProcessPO.getRetryNum()+1); - orderProcessRepo.saveOrUpdate(orderProcessPO); + LambdaUpdateWrapper updateWrapper = new LambdaUpdateWrapper<>(); + updateWrapper.eq(OrderProcessPO::getId, orderProcessPO.getId()) + .set(OrderProcessPO::getRetryNum, orderProcessPO.getRetryNum()+1); + orderProcessRepo.update(updateWrapper); } if(orderProcessPO.getRetryNum()>5){ log.info("支付单单{}已超过最大重试次数，强行关闭支付单", subPO.getSuborderNo());