From 0d9efa874050e31617640f4938184c0695a1083d Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Wed, 17 Apr 2024 10:38:49 +0800
Subject: [PATCH] 提现批量修改

---
 src/main/java/cc/mrbird/febs/dapp/controller/MemberMoneyFlowController.java |   39 +++++++++++++++++++++++++++++++++++++++
 1 files changed, 39 insertions(+), 0 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/dapp/controller/MemberMoneyFlowController.java b/src/main/java/cc/mrbird/febs/dapp/controller/MemberMoneyFlowController.java
index c900507..379f84c 100644
--- a/src/main/java/cc/mrbird/febs/dapp/controller/MemberMoneyFlowController.java
+++ b/src/main/java/cc/mrbird/febs/dapp/controller/MemberMoneyFlowController.java
@@ -1,5 +1,6 @@
 package cc.mrbird.febs.dapp.controller;
 
+import cc.mrbird.febs.common.annotation.ControllerEndpoint;
 import cc.mrbird.febs.common.controller.BaseController;
 import cc.mrbird.febs.common.entity.FebsResponse;
 import cc.mrbird.febs.common.entity.QueryRequest;
@@ -7,14 +8,18 @@
 import cc.mrbird.febs.dapp.entity.DappAccountMoneyChangeEntity;
 import cc.mrbird.febs.dapp.entity.DappAchieve;
 import cc.mrbird.febs.dapp.entity.DappFundFlowEntity;
+import cc.mrbird.febs.dapp.mapper.DappFundFlowDao;
+import cc.mrbird.febs.dapp.service.AsyncCjService;
 import cc.mrbird.febs.dapp.service.DappWalletService;
 import cc.mrbird.febs.system.entity.User;
+import cn.hutool.core.util.StrUtil;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.shiro.authz.annotation.RequiresPermissions;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
+import java.util.List;
 import java.util.Map;
 
 /**
@@ -29,6 +34,8 @@
 public class MemberMoneyFlowController extends BaseController {
 
     private final DappWalletService dappWalletService;
+    private final DappFundFlowDao dappFundFlowDao;
+    private final AsyncCjService asyncCjService;
 
     @GetMapping("/dappAchieveItem")
     public FebsResponse dappAchieveItem(QueryRequest request, DappAchieve dappAchieve, Integer parentId) {
@@ -54,6 +61,38 @@
         return new FebsResponse().success().data(getDataTable(dappWalletService.fundFlowInPage(dappFundFlowEntity, request)));
     }
 
+    @GetMapping("confirmOrder")
+    @ControllerEndpoint(operation = "批量转账", exceptionMessage = "操作失败")
+    public FebsResponse confirmOrder(DappFundFlowEntity dappFundFlowIn){
+        String orderIds = dappFundFlowIn.getOrderIds();
+        List<String> ids = StrUtil.splitTrim(orderIds, ",");
+        for(String id : ids){
+            long orderId = Long.parseLong(id);
+            DappFundFlowEntity dappFundFlowEntity = dappFundFlowDao.selectById(orderId);
+            if(1 != dappFundFlowEntity.getStatus()){
+                continue;
+            }
+            asyncCjService.confirmOrder(dappFundFlowEntity);
+        }
+        return new FebsResponse().success();
+    }
+
+    @GetMapping("confirmCancel")
+    @ControllerEndpoint(operation = "取消", exceptionMessage = "操作失败")
+    public FebsResponse confirmCancel(DappFundFlowEntity dappFundFlowIn){
+        String orderIds = dappFundFlowIn.getOrderIds();
+        List<String> ids = StrUtil.splitTrim(orderIds, ",");
+        for(String id : ids){
+            long orderId = Long.parseLong(id);
+            DappFundFlowEntity dappFundFlowEntity = dappFundFlowDao.selectById(orderId);
+            if(1 != dappFundFlowEntity.getStatus()){
+                continue;
+            }
+            asyncCjService.confirmCancel(dappFundFlowEntity);
+        }
+        return new FebsResponse().success();
+    }
+
     @PostMapping(value = "/withdrawAgree/{id}")
     public FebsResponse withdrawAgree(@PathVariable("id") Long id) {
         dappWalletService.withdrawAgreeOrNot(id, 1);

--
Gitblit v1.9.1