From 200caf120a61594e97dd1adb7e7d120853926de9 Mon Sep 17 00:00:00 2001
From: Tankaikai <tankaikai@aliyun.com>
Date: Wed, 26 Feb 2025 15:17:39 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=9A=E5=91=98=E7=A7=AF=E5=88=86=E4=BB=A3?=
 =?UTF-8?q?=E7=A0=81=E6=8F=90=E4=BA=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../account/mapper/PointsExchangeRecordMapper.java        | 5 ++++-
 .../service/impl/PointsExchangeRecordServiceImpl.java     | 8 +-------
 .../main/resources/mapper/PointsExchangeRecordMapper.xml  | 8 ++++++++
 3 files changed, 13 insertions(+), 8 deletions(-)

diff --git a/cash-service/account-service/src/main/java/com/czg/service/account/mapper/PointsExchangeRecordMapper.java b/cash-service/account-service/src/main/java/com/czg/service/account/mapper/PointsExchangeRecordMapper.java
index a74a3f5ef..1fd495433 100644
--- a/cash-service/account-service/src/main/java/com/czg/service/account/mapper/PointsExchangeRecordMapper.java
+++ b/cash-service/account-service/src/main/java/com/czg/service/account/mapper/PointsExchangeRecordMapper.java
@@ -12,5 +12,8 @@ import org.apache.ibatis.annotations.Mapper;
  */
 @Mapper
 public interface PointsExchangeRecordMapper extends BaseMapper<PointsExchangeRecord> {
-
+    /**
+     * 自动取消兑换订单
+     */
+    int authCancel();
 }
\ No newline at end of file
diff --git a/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/PointsExchangeRecordServiceImpl.java b/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/PointsExchangeRecordServiceImpl.java
index aa841158a..42b1da72f 100644
--- a/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/PointsExchangeRecordServiceImpl.java
+++ b/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/PointsExchangeRecordServiceImpl.java
@@ -29,7 +29,6 @@ import com.czg.validator.group.InsertGroup;
 import com.mybatisflex.core.paginate.Page;
 import com.mybatisflex.core.query.QueryColumn;
 import com.mybatisflex.core.query.QueryWrapper;
-import com.mybatisflex.core.update.UpdateChain;
 import com.mybatisflex.spring.service.impl.ServiceImpl;
 import jakarta.servlet.http.HttpServletRequest;
 import lombok.AllArgsConstructor;
@@ -453,11 +452,6 @@ public class PointsExchangeRecordServiceImpl extends ServiceImpl<PointsExchangeR
 
     @Override
     public void authCancel() {
-        UpdateChain.of(PointsExchangeRecord.class)
-                .set(PointsExchangeRecord::getStatus, PointsExchangeStatusEnum.CANCEL.value())
-                .set(PointsExchangeRecord::getCancelOrRefundTime, new Date())
-                .set(PointsExchangeRecord::getCancelOrRefundReason, "超时未支付，系统自动取消订单")
-                .eq(PointsExchangeRecord::getStatus, PointsExchangeStatusEnum.UNPAID.value())
-                .ge("TIMESTAMPDIFF(MINUTE, create_time, NOW())", 5);
+        super.mapper.authCancel();
     }
 }
\ No newline at end of file
diff --git a/cash-service/account-service/src/main/resources/mapper/PointsExchangeRecordMapper.xml b/cash-service/account-service/src/main/resources/mapper/PointsExchangeRecordMapper.xml
index 86f3e98d3..34e8e2866 100644
--- a/cash-service/account-service/src/main/resources/mapper/PointsExchangeRecordMapper.xml
+++ b/cash-service/account-service/src/main/resources/mapper/PointsExchangeRecordMapper.xml
@@ -3,4 +3,12 @@
 
 <mapper namespace="com.czg.service.account.mapper.PointsExchangeRecordMapper">
 
+    <update id="authCancel">
+        update tb_points_exchange_record
+        set status                  = 'cancel',
+            cancel_or_refund_time   = now(),
+            cancel_or_refund_reason = '超时未支付，系统自动取消订单'
+        where status = 'unpaid'
+          and TIMESTAMPDIFF(MINUTE, create_time, NOW()) >= 5
+    </update>
 </mapper>
\ No newline at end of file