From ac67323f0dabd375d536dbaf5685a0c5f703905c Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=BC=A0=E6=9D=BE?=
 <8605635+zhang3064194730@user.noreply.gitee.com>
Date: Wed, 29 Oct 2025 18:23:42 +0800
Subject: [PATCH] =?UTF-8?q?=E5=88=86=E9=94=80=E6=8F=90=E7=8E=B0=E5=A4=B1?=
 =?UTF-8?q?=E8=B4=A5=E5=8E=9F=E5=9B=A0=E8=AE=B0=E5=BD=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/czg/controller/NotifyController.java     | 3 ++-
 .../java/com/czg/market/entity/MkDistributionWithdrawFlow.java | 2 ++
 .../java/com/czg/market/service/MkDistributionUserService.java | 2 +-
 .../market/service/impl/MkDistributionUserServiceImpl.java     | 3 ++-
 4 files changed, 7 insertions(+), 3 deletions(-)

diff --git a/cash-api/order-server/src/main/java/com/czg/controller/NotifyController.java b/cash-api/order-server/src/main/java/com/czg/controller/NotifyController.java
index 1c745adc..fc89ec59 100644
--- a/cash-api/order-server/src/main/java/com/czg/controller/NotifyController.java
+++ b/cash-api/order-server/src/main/java/com/czg/controller/NotifyController.java
@@ -80,8 +80,9 @@ public class NotifyController {
         log.info("参数信息: {}", jsonObject.toJSONString());
         String outBillNo = jsonObject.getString("out_bill_no");
         String state = jsonObject.getString("state");
+        String failReason = jsonObject.getString("fail_reason");
         try {
-            distributionUserService.withdrawNotify(outBillNo, state);
+            distributionUserService.withdrawNotify(outBillNo, state, failReason);
         }catch (Exception e) {
             log.warn("转账回调失败", e);
         }
diff --git a/cash-common/cash-common-service/src/main/java/com/czg/market/entity/MkDistributionWithdrawFlow.java b/cash-common/cash-common-service/src/main/java/com/czg/market/entity/MkDistributionWithdrawFlow.java
index 3a3dc383..63d501ed 100644
--- a/cash-common/cash-common-service/src/main/java/com/czg/market/entity/MkDistributionWithdrawFlow.java
+++ b/cash-common/cash-common-service/src/main/java/com/czg/market/entity/MkDistributionWithdrawFlow.java
@@ -80,6 +80,8 @@ public class MkDistributionWithdrawFlow implements Serializable {
     private String status;
 
 
+    private String failReason;
+
 
 
 }
diff --git a/cash-common/cash-common-service/src/main/java/com/czg/market/service/MkDistributionUserService.java b/cash-common/cash-common-service/src/main/java/com/czg/market/service/MkDistributionUserService.java
index dd412e2e..ebfd6c88 100644
--- a/cash-common/cash-common-service/src/main/java/com/czg/market/service/MkDistributionUserService.java
+++ b/cash-common/cash-common-service/src/main/java/com/czg/market/service/MkDistributionUserService.java
@@ -144,5 +144,5 @@ public interface MkDistributionUserService extends IService<MkDistributionUser>
      * CANCELING： 撤销中
      * CANCELLED： 已撤销
      */
-    void withdrawNotify(String outBillNo, String state);
+    void withdrawNotify(String outBillNo, String state, String failReason);
 }
diff --git a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkDistributionUserServiceImpl.java b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkDistributionUserServiceImpl.java
index 2a4fc50f..ea6f3ad2 100644
--- a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkDistributionUserServiceImpl.java
+++ b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkDistributionUserServiceImpl.java
@@ -693,7 +693,7 @@ public class MkDistributionUserServiceImpl extends ServiceImpl<MkDistributionUse
 
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void withdrawNotify(String outBillNo, String state) {
+    public void withdrawNotify(String outBillNo, String state, String failReason) {
         MkDistributionWithdrawFlow flow = withdrawFlowService.getOne(new QueryWrapper().eq(MkDistributionWithdrawFlow::getBillNo, outBillNo));
         AssertUtil.isNull(flow, "提现记录不存在");
         switch (state) {
@@ -709,6 +709,7 @@ public class MkDistributionUserServiceImpl extends ServiceImpl<MkDistributionUse
                 break;
 
         }
+        flow.setFailReason(failReason);
         withdrawFlowService.updateById(flow);
     }
 }