| | |
|---|
| | | import cc.mrbird.febs.dapp.mapper.DappOnlineTransferDao; |
|---|
| | | import cc.mrbird.febs.dapp.mapper.DataDictionaryCustomMapper; |
|---|
| | | import cc.mrbird.febs.dapp.service.DappMemberService; |
|---|
| | | import cc.mrbird.febs.dapp.service.DappSystemService; |
|---|
| | | import cc.mrbird.febs.dapp.utils.OnlineTransferUtil; |
|---|
| | | import cc.mrbird.febs.rabbit.producer.ChainProducer; |
|---|
| | | import cn.hutool.core.collection.CollUtil; |
|---|
| | |
|---|
| | | private DappOnlineTransferDao dappOnlineTransferDao; |
|---|
| | | @Resource |
|---|
| | | private DataDictionaryCustomMapper dataDictionaryCustomMapper; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private DappSystemService dappSystemService; |
|---|
| | | |
|---|
| | | |
|---|
| | | @Override |
|---|
| | |
|---|
| | | |
|---|
| | | OnlineTransferUtil.addTransferRecord(e.from, e.to, amount, e.log.getTransactionHash(), DappTransferRecordEntity.TRANSFER_SOURCE_FLAG_APPLICATION, "USDT"); |
|---|
| | | |
|---|
| | | |
|---|
| | | // 这个方法主要是处理，tp钱包在调用transfer时，交易详情中的金额可能因为网速慢而显示晚，从而导致实际转账比记录中的少，顾做此处理 |
|---|
| | | BigDecimal realCoin = amount.divide(fundFlow.getNewestPrice(), decimals, RoundingMode.HALF_UP); |
|---|
| | | if (fundFlow.getAmount().subtract(new BigDecimal("0.1")).compareTo(realCoin) > 0) { |
|---|
| | | fundFlow.setAmount(realCoin); |
|---|
| | | |
|---|
| | | BigDecimal subtract = fundFlow.getAmount().subtract(realCoin); |
|---|
| | | BigDecimal poolRemain = (BigDecimal) redisUtils.get(AppContants.REDIS_KEY_TRANSFER_POOL_VOL_REMAIN); |
|---|
| | | redisUtils.set(AppContants.REDIS_KEY_TRANSFER_POOL_VOL_REMAIN, poolRemain.add(subtract)); |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 更改状态为已同步 |
|---|
| | | fundFlow.setStatus(2); |
|---|
| | | fundFlow.setTargetAmount(amount); |
|---|
| | |
|---|
| | | // 发送转账消息 |
|---|
| | | chainProducer.sendOnlineTransfer(JSONObject.toJSONString(map)); |
|---|
| | | |
|---|
| | | DataDictionaryCustom dic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(AppContants.DIC_TYPE_SYSTEM_SETTING, AppContants.DIC_VALUE_SYSTEM_START_TARGET); |
|---|
| | | BigDecimal target = new BigDecimal(dic.getValue()); |
|---|
| | | |
|---|
| | | // 若源池中的USDT达到或超过8万U，则启动整个系统 |
|---|
| | | BigDecimal balance = sourceUsdtInstance.balanceOf(ChainEnum.BSC_USDT_SOURCE.getAddress()); |
|---|
| | | if (target.compareTo(balance) < 1) { |
|---|
| | | redisUtils.set(AppContants.SYSTEM_START_FLAG, "start"); |
|---|
| | | |
|---|
| | | |
|---|
| | | } |
|---|
| | | fromMember.setMakerType(1); |
|---|
| | | dappMemberService.updateById(fromMember); |
|---|
| | | } else { |
|---|
| | | OnlineTransferUtil.addTransfer(e.from, fundFlow.getAmount(), 1, 1, ChainEnum.BSC_TFC_SOURCE.name(), AppContants.SYMBOL_COIN, fundFlow.getId().toString()); |
|---|
| | | |
|---|
