| | |
| | | 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; |
| | |
| | | } |
| | | // 判断是否已经同步过了 |
| | | DappFundFlowEntity fundFlow = dappFundFlowDao.selectById(flowId); |
| | | if (fundFlow != null && fundFlow.getStatus() != 1) { |
| | | if(ObjectUtil.isEmpty(fundFlow)){ |
| | | return; |
| | | } |
| | | if(1 != fundFlow.getStatus()){ |
| | | return; |
| | | } |
| | | // 更改状态为已同步 |
| | |
| | | * 发送直推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); |
| | | /** |