| | |
| | | String address = addressEntity.getAddress(); |
| | | Long memberId = addressEntity.getMemberId(); |
| | | |
| | | if (StrUtil.isNotBlank(address)) { |
| | | if (StrUtil.isBlank(address)) { |
| | | continue; |
| | | } |
| | | |
| | |
| | | |
| | | if (balance.compareTo(early) > 0) { |
| | | BigDecimal newBalance = balance.subtract(early); |
| | | memberWalletCoinDao.updateBlockBalance(memberId, newBalance, balance, 0); |
| | | memberWalletCoinDao.updateBlockBalance(walletCoinEntity.getId(), newBalance, balance, 0); |
| | | |
| | | insertCoinCharge(address, memberId, newBalance, CoinTypeEnum.USDT.name(), "ERC20", balance); |
| | | // 插入财务记录 |
| | | LogRecordUtils.insertMemberAccountMoneyChange(memberId, "转入", newBalance, CoinTypeEnum.USDT.name(), 1, 1); |
| | | // TODO 钉钉发送, 短信提醒 |
| | | } |
| | | } |
| | |
| | | log.info("#ETH更新:{},{},{}#", memberId, balance, early); |
| | | |
| | | BigDecimal newBalance = balance.subtract(early); |
| | | memberWalletCoinDao.updateBlockBalance(memberId, newBalance, balance, 0); |
| | | memberWalletCoinDao.updateBlockBalance(walletCoin.getId(), newBalance, balance, 0); |
| | | insertCoinCharge(address, memberId, newBalance, CoinTypeEnum.ETH.name(), null, balance); |
| | | |
| | | // 插入财务记录 |
| | |
| | | if (balance.compareTo(early) > 0) { |
| | | BigDecimal newBalance = balance.subtract(early); |
| | | |
| | | memberWalletCoinDao.updateBlockBalance(memberId, newBalance, balance, 0); |
| | | memberWalletCoinDao.updateBlockBalance(walletCoin.getId(), newBalance, balance, 0); |
| | | insertCoinCharge(address, memberId, newBalance, CoinTypeEnum.USDT.name(), "OMNI", balance); |
| | | |
| | | // TODO 钉钉消息, 短信提醒 |
| | |
| | | if (balance.compareTo(early) > 0) { |
| | | log.info("#btc同步:{}, {}, {}#", memberId, balance, early); |
| | | BigDecimal newBalance = balance.subtract(early); |
| | | memberWalletCoinDao.updateBlockBalance(memberId, newBalance, balance, 0); |
| | | memberWalletCoinDao.updateBlockBalance(walletCoin.getId(), newBalance, balance, 0); |
| | | |
| | | insertCoinCharge(address, memberId, newBalance, CoinTypeEnum.BTC.name(), null, balance); |
| | | LogRecordUtils.insertMemberAccountMoneyChange(memberId, "转入", newBalance, CoinTypeEnum.BTC.name(), 1, 1); |