| | |
| | | } |
| | | member = insertMember(connectDto.getAddress(), connectDto.getInviteId()); |
| | | //升级用户的代理等级 |
| | | DappMemberEntity dappMemberEntity = dappMemberDao.selectMemberInfoByInviteId(connectDto.getInviteId()); |
| | | chainProducer.sendAgentUpMsg(dappMemberEntity.getId()); |
| | | // DappMemberEntity dappMemberEntity = dappMemberDao.selectMemberInfoByInviteId(connectDto.getInviteId()); |
| | | // chainProducer.sendAgentUpMsg(dappMemberEntity.getId()); |
| | | } |
| | | |
| | | String key = LoginUserUtil.getLoginKey(connectDto.getAddress(), connectDto.getNonce(), connectDto.getSign()); |
| | |
| | | if(ObjectUtil.isEmpty(dappSystemProfit)){ |
| | | return null; |
| | | } |
| | | //升级用户的代理等级 |
| | | DappMemberEntity dappMemberEntity = dappMemberDao.selectMemberInfoByInviteId(member.getRefererId()); |
| | | chainProducer.sendAgentUpMsg(dappMemberEntity.getId()); |
| | | return buildTeamMatrix(member.getId()); |
| | | } |
| | | |
| | |
| | | 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(transferDto.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); |