From 562fbf16954da56357fe16eb40b389d3aa871535 Mon Sep 17 00:00:00 2001
From: wangw <1594593906@qq.com>
Date: Fri, 7 Mar 2025 11:24:38 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=9A=E5=91=98=E5=85=85=E5=80=BC=20?=
 =?UTF-8?q?=E9=80=80=E6=AC=BE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/czg/account/service/ShopUserFlowService.java  |  3 +++
 .../account/service/impl/ShopUserFlowServiceImpl.java | 10 ++++++++++
 .../service/order/service/impl/PayServiceImpl.java    | 11 ++---------
 3 files changed, 15 insertions(+), 9 deletions(-)

diff --git a/cash-common/cash-common-service/src/main/java/com/czg/account/service/ShopUserFlowService.java b/cash-common/cash-common-service/src/main/java/com/czg/account/service/ShopUserFlowService.java
index c9a1e6b4..f5f186da 100644
--- a/cash-common/cash-common-service/src/main/java/com/czg/account/service/ShopUserFlowService.java
+++ b/cash-common/cash-common-service/src/main/java/com/czg/account/service/ShopUserFlowService.java
@@ -3,6 +3,8 @@ package com.czg.account.service;
 import com.czg.account.entity.ShopUserFlow;
 import com.mybatisflex.core.service.IService;
 
+import java.math.BigDecimal;
+
 /**
  * 用户余额流水 服务层。
  *
@@ -11,4 +13,5 @@ import com.mybatisflex.core.service.IService;
  */
 public interface ShopUserFlowService extends IService<ShopUserFlow> {
 
+   void updateRefund(Long id, BigDecimal refundAmount);
 }
diff --git a/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/ShopUserFlowServiceImpl.java b/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/ShopUserFlowServiceImpl.java
index 648d04d2..61449b73 100644
--- a/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/ShopUserFlowServiceImpl.java
+++ b/cash-service/account-service/src/main/java/com/czg/service/account/service/impl/ShopUserFlowServiceImpl.java
@@ -3,9 +3,12 @@ package com.czg.service.account.service.impl;
 import com.czg.account.entity.ShopUserFlow;
 import com.czg.account.service.ShopUserFlowService;
 import com.czg.service.account.mapper.ShopUserFlowMapper;
+import com.mybatisflex.core.update.UpdateChain;
 import com.mybatisflex.spring.service.impl.ServiceImpl;
 import org.apache.dubbo.config.annotation.DubboService;
 
+import java.math.BigDecimal;
+
 /**
  * 用户余额流水 服务层实现。
  *
@@ -15,4 +18,11 @@ import org.apache.dubbo.config.annotation.DubboService;
 @DubboService
 public class ShopUserFlowServiceImpl extends ServiceImpl<ShopUserFlowMapper, ShopUserFlow> implements ShopUserFlowService {
 
+    @Override
+    public void updateRefund(Long id, BigDecimal refundAmount) {
+        UpdateChain.of(ShopUserFlow.class)
+                .setRaw(ShopUserFlow::getRefundAmount, "refund_amount + " + refundAmount)
+                .eq(ShopUserFlow::getId, id)
+                .update();
+    }
 }
diff --git a/cash-service/order-service/src/main/java/com/czg/service/order/service/impl/PayServiceImpl.java b/cash-service/order-service/src/main/java/com/czg/service/order/service/impl/PayServiceImpl.java
index a8f5aee4..367d72fd 100644
--- a/cash-service/order-service/src/main/java/com/czg/service/order/service/impl/PayServiceImpl.java
+++ b/cash-service/order-service/src/main/java/com/czg/service/order/service/impl/PayServiceImpl.java
@@ -471,16 +471,9 @@ public class PayServiceImpl implements PayService {
                 .build();
         //更新会员余额 并生成流水
         shopUserService.updateMoney(shopUser.getShopId(), shopUserMoneyEditDTO);
-
-        UpdateChain.of(ShopUserFlow.class)
-                .setRaw(ShopUserFlow::getRefundAmount, "refund_amount" + refPayParam.getRefAmount())
-                .eq(ShopUserFlow::getId, inFlow.getId())
-                .update();
+        userFlowService.updateRefund(inFlow.getId(), refPayParam.getRefAmount());
         if (giftFlow != null) {
-            UpdateChain.of(ShopUserFlow.class)
-                    .setRaw(ShopUserFlow::getRefundAmount, "refund_amount" + giftFlow.getAmount())
-                    .eq(ShopUserFlow::getId, giftFlow.getId())
-                    .update();
+            userFlowService.updateRefund( giftFlow.getId(), giftFlow.getAmount());
         }
         //移除优惠券
         inRecordService.remove(QueryWrapper.create()