| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | //减少用户的总额度 |
|---|
| | | BigDecimal usdtBalance = dappMemberEntity.getUsdtBalance(); |
|---|
| | | if(BigDecimal.ZERO.compareTo(usdtBalance) >= 0){ |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | if(daoNodeAmount.compareTo(usdtBalance) >= 0){ |
|---|
| | | daoNodeAmount = usdtBalance; |
|---|
| | | usdtBalance = BigDecimal.ZERO; |
|---|
| | | }else{ |
|---|
| | | usdtBalance = usdtBalance.subtract(daoNodeAmount); |
|---|
| | | } |
|---|
| | | // BigDecimal usdtBalance = dappMemberEntity.getUsdtBalance(); |
|---|
| | | // if(BigDecimal.ZERO.compareTo(usdtBalance) >= 0){ |
|---|
| | | // return; |
|---|
| | | // } |
|---|
| | | // if(daoNodeAmount.compareTo(usdtBalance) >= 0){ |
|---|
| | | // daoNodeAmount = usdtBalance; |
|---|
| | | // usdtBalance = BigDecimal.ZERO; |
|---|
| | | // }else{ |
|---|
| | | // usdtBalance = usdtBalance.subtract(daoNodeAmount); |
|---|
| | | // } |
|---|
| | | |
|---|
| | | //总额度为0，用户变成未激活 |
|---|
| | | if(BigDecimal.ZERO.compareTo(usdtBalance) >= 0){ |
|---|
| | | dappMemberEntity.setActiveStatus(2); |
|---|
| | | //更新用户所有的业绩为已失效 |
|---|
| | | QueryWrapper<DappStorage> objectQueryWrapper = new QueryWrapper<>(); |
|---|
| | | objectQueryWrapper.eq("member_id",memberId); |
|---|
| | | objectQueryWrapper.eq("state",1); |
|---|
| | | List<DappStorage> dappStorages = dappStorageMapper.selectList(objectQueryWrapper); |
|---|
| | | if(CollUtil.isNotEmpty(dappStorages)){ |
|---|
| | | for(DappStorage dappStorage : dappStorages){ |
|---|
| | | dappStorage.setState(2); |
|---|
| | | dappStorageMapper.updateById(dappStorage); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | dappMemberEntity.setUsdtBalance(usdtBalance); |
|---|
| | | dappMemberDao.updateById(dappMemberEntity); |
|---|
| | | // if(BigDecimal.ZERO.compareTo(usdtBalance) >= 0){ |
|---|
| | | // dappMemberEntity.setActiveStatus(2); |
|---|
| | | // //更新用户所有的业绩为已失效 |
|---|
| | | // QueryWrapper<DappStorage> objectQueryWrapper = new QueryWrapper<>(); |
|---|
| | | // objectQueryWrapper.eq("member_id",memberId); |
|---|
| | | // objectQueryWrapper.eq("state",1); |
|---|
| | | // List<DappStorage> dappStorages = dappStorageMapper.selectList(objectQueryWrapper); |
|---|
| | | // if(CollUtil.isNotEmpty(dappStorages)){ |
|---|
| | | // for(DappStorage dappStorage : dappStorages){ |
|---|
| | | // dappStorage.setState(2); |
|---|
| | | // dappStorageMapper.updateById(dappStorage); |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | // dappMemberEntity.setUsdtBalance(usdtBalance); |
|---|
| | | // dappMemberDao.updateById(dappMemberEntity); |
|---|
| | | |
|---|
| | | dappWalletService.updateWalletCoinWithLock(daoNodeAmount, memberId, 1); |
|---|
| | | DappFundFlowEntity nodeFlow = new DappFundFlowEntity( |
|---|
