From 7077ee9414f5c827f8d7c7ba3cc09071245803d6 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Tue, 13 Dec 2022 15:43:49 +0800
Subject: [PATCH] 20221213转币

---
 src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java |   14 ++++++++++----
 1 files changed, 10 insertions(+), 4 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java
index bcbae19..e6999fc 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java
@@ -355,7 +355,7 @@
                 DappFundFlowEntity fundFlow = new DappFundFlowEntity(refererMember.getId(), memberLevelProfit, 4, 1, BigDecimal.ZERO,null,dappSystemProfit.getId());
                 dappFundFlowDao.insert(fundFlow);
                 //发送转币消息
-                chainProducer.sendBnbTransferMsg(fundFlow.getId());
+//                chainProducer.sendBnbTransferMsg(fundFlow.getId());
                 systemProfitTotal = systemProfitTotal.add(memberLevelProfit);
             }
         }
@@ -365,7 +365,7 @@
             DappFundFlowEntity fundFlow = new DappFundFlowEntity(1L, avaProfit, 5, 1, BigDecimal.ZERO,null,dappSystemProfit.getId());
             dappFundFlowDao.insert(fundFlow);
             //发送转币消息
-            chainProducer.sendBnbTransferMsg(fundFlow.getId());
+//            chainProducer.sendBnbTransferMsg(fundFlow.getId());
         }
 
         dappSystemProfitDao.updateLevelProfitById(DappSystemProfit.ENUM_YES,dappSystemProfit.getId());
@@ -555,12 +555,18 @@
         //金额
         BigDecimal amount = dappFundFlow.getAmount();
         //目标地址
-        String address = dappFundFlow.getAddress();
+        Long memberId = dappFundFlow.getMemberId();
+        DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId);
+        if(ObjectUtil.isEmpty(dappMemberEntity)){
+            return;
+        }
+        String address = dappMemberEntity.getAddress();
+        log.info("{}",address);
         String hash = ChainService.getInstance(ChainEnum.BNB.name()).transferBaseToken(address, amount);
         if(StrUtil.isEmpty(hash)){
             return;
         }
-        log.info("{},{}",id,hash);
+
         dappFundFlow.setFromHash(hash);
         dappFundFlowDao.updateById(dappFundFlow);
     }

--
Gitblit v1.9.1