From c881dcbb782d209f43b9a2878de613e0124e0421 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Sun, 07 Jul 2024 12:53:00 +0800
Subject: [PATCH] 逻辑
---
src/main/java/cc/mrbird/febs/dapp/service/impl/BscCoinContractEvent.java | 19 ++++++++++++-------
1 files changed, 12 insertions(+), 7 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/BscCoinContractEvent.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/BscCoinContractEvent.java
index 85ee5f5..d1390ab 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/impl/BscCoinContractEvent.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/BscCoinContractEvent.java
@@ -13,6 +13,7 @@
import cc.mrbird.febs.dapp.mapper.DataDictionaryCustomMapper;
import cc.mrbird.febs.dapp.service.DappMemberService;
import cc.mrbird.febs.rabbit.producer.ChainProducer;
+import cn.hutool.core.util.ObjectUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@@ -80,7 +81,10 @@
}
// 判断是否已经同步过了
DappFundFlowEntity fundFlow = dappFundFlowDao.selectById(flowId);
- if (fundFlow != null && fundFlow.getStatus() != 1) {
+ if(ObjectUtil.isEmpty(fundFlow)){
+ return;
+ }
+ if(1 != fundFlow.getStatus()){
return;
}
// 更改状态为已同步
@@ -123,16 +127,17 @@
* 发送直推8%
*/
chainProducer.sendDirectPerkMsg(id);
- /**
- * DAO成员动态：
- * * 1.直推1个拿2代，直推10个拿20代，直推15个拿30代，最高30代
- */
- chainProducer.sendMemberDynamicPerkMsg(id);
+// /**
+// * DAO成员动态：
+// * * 1.直推1个拿2代，直推10个拿20代，直推15个拿30代，最高30代
+// */
+// chainProducer.sendMemberDynamicPerkMsg(id);
/**
*
* * 六、永动补偿池2％
* * 五、DAO永动激励池：6%
- * * 四、DAO联盟委员会 ： 5% （50名全球DAO委员）
+ * * 四、DAO联盟委员会 ： 5%
+ * 50名全球DAO委员）DAO成员团队奖：5%
*/
chainProducer.sendNodePerkMsg(id);
/**
--
Gitblit v1.9.1