| | |
|---|
| | | package cc.mrbird.febs.dapp.service.impl; |
|---|
| | | |
|---|
| | | import cc.mrbird.febs.common.contants.AppContants; |
|---|
| | | import cc.mrbird.febs.common.utils.RedisUtils; |
|---|
| | | import cc.mrbird.febs.common.utils.ShareCodeUtil; |
|---|
| | | import cc.mrbird.febs.dapp.chain.ChainEnum; |
|---|
| | | import cc.mrbird.febs.dapp.chain.ChainService; |
|---|
| | | import cc.mrbird.febs.dapp.chain.ContractEventService; |
|---|
| | | import cc.mrbird.febs.dapp.chain.EthUsdtContract; |
|---|
| | | import cc.mrbird.febs.dapp.entity.DappFundFlowEntity; |
|---|
| | | import cc.mrbird.febs.dapp.entity.DappMemberEntity; |
|---|
| | | import cc.mrbird.febs.dapp.entity.DappOnlineTransferEntity; |
|---|
| | | import cc.mrbird.febs.dapp.entity.DappTransferRecordEntity; |
|---|
| | | import cc.mrbird.febs.dapp.mapper.DappFundFlowDao; |
|---|
| | | import cc.mrbird.febs.dapp.mapper.DappMemberDao; |
|---|
| | | import cc.mrbird.febs.dapp.mapper.DappOnlineTransferDao; |
|---|
| | | import cc.mrbird.febs.dapp.service.DappMemberService; |
|---|
| | | import cc.mrbird.febs.dapp.service.DappSystemService; |
|---|
| | | import cc.mrbird.febs.dapp.service.DappWalletService; |
|---|
| | | import cc.mrbird.febs.dapp.utils.OnlineTransferUtil; |
|---|
| | | import cc.mrbird.febs.rabbit.producer.ChainProducer; |
|---|
| | | import cn.hutool.core.collection.CollUtil; |
|---|
| | | import cn.hutool.core.util.StrUtil; |
|---|
| | | import com.alibaba.fastjson.JSONObject; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.apache.commons.lang3.StringUtils; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | | import org.springframework.transaction.annotation.Transactional; |
|---|
| | | import org.web3j.utils.Numeric; |
|---|
| | | |
|---|
| | | import javax.annotation.Resource; |
|---|
| | | import java.math.BigDecimal; |
|---|
| | | import java.math.BigInteger; |
|---|
| | | import java.math.RoundingMode; |
|---|
| | | import java.util.HashMap; |
|---|
| | | import java.util.List; |
|---|
| | | import java.util.Map; |
|---|
| | | |
|---|
| | | @Slf4j |
|---|
| | | @Service |
|---|
| | | public class BscCoinContractEvent implements ContractEventService { |
|---|
| | | |
|---|
| | | @Resource |
|---|
| | | private DappMemberService dappMemberService; |
|---|
| | | |
|---|
| | | @Resource |
|---|
| | | private DappFundFlowDao dappFundFlowDao; |
|---|
| | | |
|---|
| | | @Resource |
|---|
| | | private RedisUtils redisUtils; |
|---|
| | | |
|---|
| | | @Resource |
|---|
| | | private DappWalletService dappWalletService; |
|---|
| | | |
|---|
| | | public static void main(String[] args) { |
|---|
| | | System.out.println(Numeric.toBigInt("0x12e4e85")); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Transactional(rollbackFor = Exception.class) |
|---|
| | | @Override |
|---|
| | | public void compile(EthUsdtContract.TransferEventResponse e) { |
|---|
| | | if (e.to != null && e.to.equals(ChainEnum.BSC_TFC.getAddress().toLowerCase())) { |
|---|
| | | log.info("触发TFC监听"); |
|---|
| | | |
|---|
| | | try { |
|---|
| | | Thread.sleep(5000); |
|---|
| | | } catch (InterruptedException ex) { |
|---|
| | | ex.printStackTrace(); |
|---|
| | | } |
|---|
| | | redisUtils.set(AppContants.REDIS_KEY_BLOCK_COIN_NUM, e.log.getBlockNumber()); |
|---|
| | | redisUtils.set(AppContants.REDIS_KEY_BLOCK_ETH_INCREMENT_NUM, e.log.getBlockNumber()); |
|---|
| | | int decimals = ChainService.getInstance(ChainEnum.BSC_TFC.name()).decimals(); |
|---|
| | | |
|---|
| | | // 更新余额 |
|---|
| | | DappMemberEntity fromMember = dappMemberService.findByAddress(e.from, null); |
|---|
| | | if (fromMember == null) { |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | BigInteger tokens = e.tokens; |
|---|
| | | BigDecimal amount = new BigDecimal(tokens.toString()).divide(BigDecimal.TEN.pow(decimals), decimals, RoundingMode.HALF_DOWN); |
|---|
| | | |
|---|
| | | // 卖币 |
|---|
| | | DappFundFlowEntity fundFlow = dappFundFlowDao.selectByFromHash(e.log.getTransactionHash(), null); |
|---|
| | | if (fundFlow != null && fundFlow.getStatus() != 1) { |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | if (fundFlow == null) { |
|---|
| | | List<DappFundFlowEntity> flows = dappFundFlowDao.selectFundFlowListByAddress(e.from, 1); |
|---|
| | | if (CollUtil.isEmpty(flows)) { |
|---|
| | | OnlineTransferUtil.addTransferRecord(e.from, e.to, amount, e.log.getTransactionHash(), DappTransferRecordEntity.TRANSFER_SOURCE_FLAG_ONLINE, AppContants.SYMBOL_COIN); |
|---|
| | | log.info("本地无交易:{}", e.log.getTransactionHash()); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | for (DappFundFlowEntity flow : flows) { |
|---|
| | | if (flow.getStatus() == 1) { |
|---|
| | | if (amount.compareTo(flow.getAmount()) == 0) { |
|---|
| | | fundFlow = flow; |
|---|
| | | fundFlow.setFromHash(e.log.getTransactionHash()); |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | if (fundFlow == null) { |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 更改状态为已同步 |
|---|
| | | fundFlow.setStatus(2); |
|---|
| | | dappFundFlowDao.updateById(fundFlow); |
|---|
| | | |
|---|
| | | dappWalletService.updateWalletMineWithLock(amount, fromMember.getId(), 1); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
