| | |
|---|
| | | |
|---|
| | | DappFundFlowEntity fundFlow = dappFundFlowDao.selectByFromHashAndAndMemberId(e.log.getTransactionHash(), null,fromMember.getId()); |
|---|
| | | if(ObjectUtil.isNotEmpty(fundFlow) && 1 == fundFlow.getStatus()){ |
|---|
| | | if(1 == fundFlow.getType()){//认购贡献值 1 |
|---|
| | | if(18 == fundFlow.getType()){//认购贡献值 18 |
|---|
| | | log.info("买入贡献值，{}，金额：{}",fromAddress,amount); |
|---|
| | | if (fundFlow == null) { |
|---|
| | | List<DappFundFlowEntity> flows = dappFundFlowDao.selectFundFlowListByAddress(e.from, 1); |
|---|
| | |
|---|
| | | // } |
|---|
| | | //复投 |
|---|
| | | // chainProducer.sendAchieveTreeMsg(fundFlow.getMemberId()); |
|---|
| | | chainProducer.sendNodeMsg(fundFlow.getMemberId()); |
|---|
| | | chainProducer.sendNodeMsg(fundFlow.getId()); |
|---|
| | | //发送推荐规则奖励 |
|---|
| | | chainProducer.sendInvitePerkMsg(fundFlow.getId()); |
|---|
| | | //发送节点投资 |
|---|
