From f23b33bbb9eaff76cac5b69e3b793fc7910fb0fa Mon Sep 17 00:00:00 2001
From: peternameyakj <908253177@qq.com>
Date: Tue, 30 Jul 2024 11:03:37 +0800
Subject: [PATCH] 新增资金账户以及与交易账户的互转
---
src/main/java/project/web/admin/AdminWithdrawController.java | 17 ++++++++++++++++-
1 files changed, 16 insertions(+), 1 deletions(-)
diff --git a/src/main/java/project/web/admin/AdminWithdrawController.java b/src/main/java/project/web/admin/AdminWithdrawController.java
index f334a35..2ff1f1e 100644
--- a/src/main/java/project/web/admin/AdminWithdrawController.java
+++ b/src/main/java/project/web/admin/AdminWithdrawController.java
@@ -10,6 +10,7 @@
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.servlet.ModelAndView;
@@ -20,6 +21,10 @@
import kernel.web.Page;
import kernel.web.PageActionSupport;
import project.Constants;
+import project.redis.RedisHandler;
+import project.wallet.WalletGatherService;
+import project.wallet.WalletService;
+import project.wallet.internal.WalletGatherServiceImpl;
import project.withdraw.AdminWithdrawService;
import util.LockFilter;
@@ -31,6 +36,15 @@
@Resource
private AdminWithdrawService adminWithdrawService;
+ @Autowired
+ private RedisHandler redisHandler;
+
+ @Autowired
+ private JdbcTemplate jdbcTemplate;
+
+ @Autowired
+ private WalletService walletService;
+
private static final String action = "normal/adminWithdrawAction!";
@@ -215,7 +229,8 @@
lock = true;
// 统一处理失败接口
- this.adminWithdrawService.saveReject(id, failure_msg, this.getUsername_login(), this.getLoginPartyId());
+ WalletGatherService walletGatherService = new WalletGatherServiceImpl(jdbcTemplate,redisHandler,walletService);
+ this.adminWithdrawService.saveReject(id, failure_msg, this.getUsername_login(), this.getLoginPartyId(),walletGatherService);
ThreadUtils.sleep(300);
} catch (BusinessException e) {
modelAndView.addObject("error", e.getMessage());
--
Gitblit v1.9.3