From 609d2e5f259aeb07b9579fb0ea0c01dd36b482d0 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Tue, 06 Aug 2024 16:04:48 +0800
Subject: [PATCH] 逻辑
---
src/main/java/cc/mrbird/febs/dapp/service/impl/BscCoinContractEvent.java | 26 +++++++++++++++++++-------
1 files changed, 19 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..5eb46ee 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;
}
// 更改状态为已同步
@@ -117,22 +121,30 @@
fromMember.setActiveStatus(1);
dappMemberDao.updateById(fromMember);
+ DataDictionaryCustom symbolDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.BUCHANG_SYMBOL.getType(),
+ DataDictionaryEnum.BUCHANG_SYMBOL.getCode()
+ );
+ symbolDic.setValue("1");
+ dataDictionaryCustomMapper.updateById(symbolDic);
+
Long id = fundFlow.getId();
Long memberId = fromMember.getId();
/**
* 发送直推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