From 2f6809e5c55453a31a807e948d566f22e866f67e Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Mon, 14 Aug 2023 12:29:47 +0800
Subject: [PATCH] 后台修改

---
 src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java |   68 +++++++++++++++++++++++++++++++++-
 1 files changed, 66 insertions(+), 2 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java
index 5cf58b0..94db04d 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java
@@ -2,6 +2,7 @@
 
 import cc.mrbird.febs.common.configure.i18n.MessageSourceUtils;
 import cc.mrbird.febs.common.contants.AppContants;
+import cc.mrbird.febs.common.entity.FebsResponse;
 import cc.mrbird.febs.common.entity.QueryRequest;
 import cc.mrbird.febs.common.exception.FebsException;
 import cc.mrbird.febs.common.utils.FebsUtil;
@@ -513,7 +514,7 @@
     }
 
     @Override
-    public List<DappFundFlowVo> getRecordVoInPage(RecordInPageDto recordInPageDto) {
+    public IPage<DappFundFlowVo> getRecordVoInPage(RecordInPageDto recordInPageDto) {
         Page<DappFundFlowVo> page = new Page<>(recordInPageDto.getPageNum(), recordInPageDto.getPageSize());
 
         DappMemberEntity member = LoginUserUtil.getAppUser();
@@ -521,9 +522,10 @@
         if (recordInPageDto.getType() != null && recordInPageDto.getType() != 0) {
             dappFundFlowEntity.setType(recordInPageDto.getType());
         }
+        dappFundFlowEntity.setFlowType(recordInPageDto.getFlowType());
         dappFundFlowEntity.setMemberId(member.getId());
         IPage<DappFundFlowVo> records = dappFundFlowDao.selectVoInPage(page, dappFundFlowEntity);
-        return records.getRecords();
+        return records;
     }
 
     @Override
@@ -685,4 +687,66 @@
 //                dappMemberEntity.getId());
 //        dappFundFlowDao.insert(aCoinCntFlowParent);
     }
+
+    @Override
+    public FebsResponse withdrawAgree(Long id) {
+        DappFundFlowEntity dappFundFlowEntity = dappFundFlowDao.selectById(id);
+
+        if(FundFlowEnum.WITHDRAW_USDT.getCode() != dappFundFlowEntity.getType()){
+            return new FebsResponse().fail().message("该记录不存在");
+        }
+        if(DappFundFlowEntity.WITHDRAW_STATUS_ING != dappFundFlowEntity.getStatus()){
+            return new FebsResponse().fail().message("提现记录不是进行中状态");
+        }
+        DappMemberEntity dappMemberEntity = dappMemberDao.selectById(dappFundFlowEntity.getMemberId());
+        if(ObjectUtil.isEmpty(dappMemberEntity)) {
+            return new FebsResponse().fail().message("会员信息不存在");
+        }
+        MemberCoinWithdrawEntity memberCoinWithdrawEntity = memberCoinWithdrawDao.selectByFlowId(dappMemberEntity.getId(),dappFundFlowEntity.getId());
+        if(ObjectUtil.isEmpty(memberCoinWithdrawEntity)){
+            return new FebsResponse().fail().message("该记录不存在");
+        }
+        if(MemberCoinWithdrawEntity.STATUS_DOING != memberCoinWithdrawEntity.getStatus()){
+            return new FebsResponse().fail().message("提现记录不是进行中状态");
+        }
+        dappFundFlowEntity.setStatus(DappFundFlowEntity.WITHDRAW_STATUS_AGREE);
+        dappFundFlowDao.updateById(dappFundFlowEntity);
+
+        memberCoinWithdrawEntity.setStatus(MemberCoinWithdrawEntity.STATUS_YES);
+        memberCoinWithdrawEntity.setIsInside(MemberCoinWithdrawEntity.ISINSIDE_NO);
+        memberCoinWithdrawDao.updateById(memberCoinWithdrawEntity);
+        return new FebsResponse().success();
+    }
+
+    @Override
+    public FebsResponse withdrawDisAgree(Long id) {
+        DappFundFlowEntity dappFundFlowEntity = dappFundFlowDao.selectById(id);
+
+        if(FundFlowEnum.WITHDRAW_USDT.getCode() != dappFundFlowEntity.getType()){
+            return new FebsResponse().fail().message("该记录不存在");
+        }
+        if(DappFundFlowEntity.WITHDRAW_STATUS_ING != dappFundFlowEntity.getStatus()){
+            return new FebsResponse().fail().message("提现记录不是进行中状态");
+        }
+        DappMemberEntity dappMemberEntity = dappMemberDao.selectById(dappFundFlowEntity.getMemberId());
+        if(ObjectUtil.isEmpty(dappMemberEntity)) {
+            return new FebsResponse().fail().message("会员信息不存在");
+        }
+        MemberCoinWithdrawEntity memberCoinWithdrawEntity = memberCoinWithdrawDao.selectByFlowId(dappMemberEntity.getId(),dappFundFlowEntity.getId());
+        if(ObjectUtil.isEmpty(memberCoinWithdrawEntity)){
+            return new FebsResponse().fail().message("该记录不存在");
+        }
+        if(MemberCoinWithdrawEntity.STATUS_DOING != memberCoinWithdrawEntity.getStatus()){
+            return new FebsResponse().fail().message("提现记录不是进行中状态");
+        }
+        dappFundFlowEntity.setStatus(DappFundFlowEntity.WITHDRAW_STATUS_DISAGREE);
+        dappFundFlowDao.updateById(dappFundFlowEntity);
+
+        memberCoinWithdrawEntity.setStatus(MemberCoinWithdrawEntity.STATUS_NO);
+        memberCoinWithdrawEntity.setIsInside(MemberCoinWithdrawEntity.ISINSIDE_NO);
+        memberCoinWithdrawDao.updateById(memberCoinWithdrawEntity);
+        //增加余额
+        this.updateWalletCoinWithLock(dappFundFlowEntity.getAmount().negate(), dappMemberEntity.getId(), 1);
+        return new FebsResponse().success();
+    }
 }

--
Gitblit v1.9.1