| | |
|---|
| | | type = 6; |
|---|
| | | } |
|---|
| | | if (transferDto.getId() == null) { |
|---|
| | | DappFundFlowEntity fundFlowOld = dappFundFlowDao.selectBymemberIdAndType(member.getId(),type); |
|---|
| | | if(ObjectUtil.isNotEmpty(fundFlowOld)){ |
|---|
| | | throw new FebsException("Do not repeat purchase"); |
|---|
| | | } |
|---|
| | | DappFundFlowEntity fundFlow = new DappFundFlowEntity(member.getId(), transferDto.getAmount(), type, 1, transferDto.getFee(), transferDto.getTxHash()); |
|---|
| | | dappFundFlowDao.insert(fundFlow); |
|---|
| | | return fundFlow.getId(); |
|---|
| | |
|---|
| | | if ("success".equals(transferDto.getFlag())) { |
|---|
| | | DappFundFlowEntity flow = dappFundFlowDao.selectById(transferDto.getId()); |
|---|
| | | if(DappFundFlowEntity.WITHDRAW_STATUS_AGREE == flow.getStatus()){ |
|---|
| | | return null; |
|---|
| | | throw new FebsException("Do not repeat purchase"); |
|---|
| | | } |
|---|
| | | //是否已经加入动能 |
|---|
| | | DappSystemProfit dappSystemProfitIng = dappSystemProfitDao.selectByMemberIdAndState(member.getId(), DappSystemProfit.STATE_IN); |
|---|
| | | if(ObjectUtil.isNotEmpty(dappSystemProfitIng)){ |
|---|
| | | return null; |
|---|
| | | throw new FebsException("Do not repeat purchase"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | //插入一条会员入列记录,即加入动能队列 |
|---|
| | |
|---|
| | | DappFundFlowEntity systemProfitFlow = new DappFundFlowEntity(1L, new BigDecimal(systemProfitStr), 2, 1, BigDecimal.ZERO, null,dappSystemProfit.getId()); |
|---|
| | | dappFundFlowDao.insert(systemProfitFlow); |
|---|
| | | //发送转币消息 |
|---|
| | | chainProducer.sendBnbTransferMsg(systemProfitFlow.getId()); |
|---|
| | | // chainProducer.sendBnbTransferMsg(systemProfitFlow.getId()); |
|---|
| | | //直接返利30%给直接上级 |
|---|
| | | DappMemberEntity dappMemberEntity = dappMemberDao.selectById(member.getId()); |
|---|
| | | String refererId = dappMemberEntity.getRefererId(); |
|---|
