| | |
| | | } |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void withdraw(WalletOperateDto walletOperateDto) { |
| | | DappMemberEntity member = LoginUserUtil.getAppUser(); |
| | | |
| | | List<DappFundFlowEntity> fundFlows = dappFundFlowDao.selectListForMemberAndDay(member.getId(), 2); |
| | | if (CollUtil.isNotEmpty(fundFlows)) { |
| | | throw new FebsException("一天只能提现一次"); |
| | | } |
| | | |
| | | DappWalletCoinEntity walletCoin = dappWalletCoinDao.selectByMemberId(member.getId()); |
| | | if (walletOperateDto.getAmount().compareTo(walletCoin.getAvailableAmount()) > 0) { |
| | | throw new FebsException("可用金额不足"); |
| | | } |
| | | |
| | | Integer fee = (Integer) redisUtils.get(AppContants.REDIS_KEY_CHANGE_FEE); |
| | | |
| | | //TODO 并发加悲观锁 |
| | | BigDecimal preAmount = walletCoin.getAvailableAmount(); |
| | | walletCoin.setAvailableAmount(walletCoin.getAvailableAmount().subtract(walletOperateDto.getAmount())); |
| | | walletCoin.setFrozenAmount(walletCoin.getFrozenAmount().add(walletOperateDto.getAmount())); |
| | | dappWalletCoinDao.updateById(walletCoin); |
| | | |
| | | DappFundFlowEntity fund = new DappFundFlowEntity(member.getId(), walletOperateDto.getAmount(), AppContants.MONEY_TYPE_WITHDRAWAL, 1, new BigDecimal(fee)); |
| | | dappFundFlowDao.insert(fund); |
| | | |
| | | DappAccountMoneyChangeEntity usdtChange = new DappAccountMoneyChangeEntity(member.getId(), preAmount, walletOperateDto.getAmount(), walletCoin.getAvailableAmount(), "USDT申请提现", AppContants.MONEY_TYPE_WITHDRAWAL); |
| | | dappAccountMoneyChangeDao.insert(usdtChange); |
| | | } |
| | | |
| | | @Override |
| | | public List<DappFundFlowEntity> recordInPage(RecordInPageDto recordInPageDto) { |
| | | Page<DappFundFlowEntity> page = new Page<>(recordInPageDto.getPageNum(), recordInPageDto.getPageSize()); |
| | | |