| | |
|---|
| | | boolean hasFlow = false; |
|---|
| | | for (DappFundFlowEntity flow : flows) { |
|---|
| | | if (flow.getStatus() == 1) { |
|---|
| | | if (amount.compareTo(flow.getTargetAmount()) == 0) { |
|---|
| | | if (amount.compareTo(flow.getAmount().multiply(flow.getNewestPrice()).setScale(4, RoundingMode.HALF_UP)) == 0) { |
|---|
| | | hasFlow = true; |
|---|
| | | fundFlow = flow; |
|---|
| | | fundFlow.setFromHash(e.log.getTransactionHash()); |
|---|
| | |
|---|
| | | 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)); |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 更改状态为已同步 |
|---|
