From ad959c3690aea52a0e54e92b001d1959c26c4cc4 Mon Sep 17 00:00:00 2001
From: 2019232 <zh123456>
Date: Wed, 14 Dec 2022 15:40:59 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/BNBWEB' into BNBWEB

---
 src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java |   12 ++++++++----
 1 files changed, 8 insertions(+), 4 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 3a684a9..ae6f35b 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
@@ -185,8 +185,8 @@
      */
     @Override
     public Long transfer(TransferDto transferDto) {
-//        DappMemberEntity member = LoginUserUtil.getAppUser();
-        DappMemberEntity member = dappMemberDao.selectById(transferDto.getMemberId());
+        DappMemberEntity member = LoginUserUtil.getAppUser();
+//        DappMemberEntity member = dappMemberDao.selectById(transferDto.getMemberId());
 
         String upgrade = redisUtils.getString("APP_UPGRADE");
         if ("upgrade".equals(upgrade)) {
@@ -219,6 +219,10 @@
                 type = 6;
             }
             if (transferDto.getId() == null) {
+                DappFundFlowEntity fundFlowOld = dappFundFlowDao.selectBymemberIdAndType(member.getId(),type);
+                if(ObjectUtil.isNotEmpty(fundFlowOld)){
+                    throw new FebsException("Do not repeat purchase");
+                }
                 DappFundFlowEntity fundFlow = new DappFundFlowEntity(member.getId(), transferDto.getAmount(), type, 1, transferDto.getFee(), transferDto.getTxHash());
                 dappFundFlowDao.insert(fundFlow);
                 return fundFlow.getId();
@@ -227,12 +231,12 @@
             if ("success".equals(transferDto.getFlag())) {
                 DappFundFlowEntity flow = dappFundFlowDao.selectById(transferDto.getId());
                 if(DappFundFlowEntity.WITHDRAW_STATUS_AGREE == flow.getStatus()){
-                    return null;
+                    throw new FebsException("Do not repeat purchase");
                 }
                 //是否已经加入动能
                 DappSystemProfit dappSystemProfitIng = dappSystemProfitDao.selectByMemberIdAndState(member.getId(), DappSystemProfit.STATE_IN);
                 if(ObjectUtil.isNotEmpty(dappSystemProfitIng)){
-                    return null;
+                    throw new FebsException("Do not repeat purchase");
                 }
 
                 //插入一条会员入列记录,即加入动能队列

--
Gitblit v1.9.1