| | |
|---|
| | | */ |
|---|
| | | @Override |
|---|
| | | public Long transfer(TransferDto transferDto) { |
|---|
| | | // DappMemberEntity member = LoginUserUtil.getAppUser(); |
|---|
| | | DappMemberEntity member = dappMemberDao.selectById(transferDto.getMemberId()); |
|---|
| | | DappMemberEntity member = LoginUserUtil.getAppUser(); |
|---|
| | | // DappMemberEntity member = dappMemberDao.selectById(transferDto.getMemberId()); |
|---|
| | | |
|---|
| | | String upgrade = redisUtils.getString("APP_UPGRADE"); |
|---|
| | | if ("upgrade".equals(upgrade)) { |
|---|
| | |
|---|
| | | 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"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | //插入一条会员入列记录,即加入动能队列 |
|---|
