| | |
|---|
| | | if (transferDto.getId() == null) { |
|---|
| | | DappFundFlowEntity fundFlowOld = dappFundFlowDao.selectBymemberIdAndType(member.getId(),type); |
|---|
| | | if(ObjectUtil.isNotEmpty(fundFlowOld)){ |
|---|
| | | throw new FebsException("Do not repeat purchase"); |
|---|
| | | //网络问题导致第二次提交前，未成功就关闭了页面 |
|---|
| | | if (fundFlowOld.getStatus() == 1 && StrUtil.isEmpty(fundFlowOld.getFromHash())) { |
|---|
| | | dappFundFlowDao.deleteById(fundFlowOld.getId()); |
|---|
| | | } |
|---|
| | | throw new FebsException("Refresh and try again"); |
|---|
| | | } |
|---|
| | | DappFundFlowEntity fundFlow = new DappFundFlowEntity(member.getId(), transferDto.getAmount(), type, 1, transferDto.getFee(), transferDto.getTxHash()); |
|---|
| | | dappFundFlowDao.insert(fundFlow); |
|---|
| | |
|---|
| | | 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(); |
|---|
