From c0989001fbddc1b6e24783c3a4b8cb8775eab1fe Mon Sep 17 00:00:00 2001 From: wzy <wzy19931122ai@163.com> Date: Sun, 06 Nov 2022 19:32:01 +0800 Subject: [PATCH] fix --- src/test/java/cc/mrbird/febs/ChainTest.java | 84 +++++++---------------------------------- 1 files changed, 15 insertions(+), 69 deletions(-) diff --git a/src/test/java/cc/mrbird/febs/ChainTest.java b/src/test/java/cc/mrbird/febs/ChainTest.java index 95c5b3d..37af5f0 100644 --- a/src/test/java/cc/mrbird/febs/ChainTest.java +++ b/src/test/java/cc/mrbird/febs/ChainTest.java @@ -5,9 +5,13 @@ import cc.mrbird.febs.dapp.chain.ContractChainService; import cc.mrbird.febs.dapp.entity.DappFundFlowEntity; import cc.mrbird.febs.dapp.entity.DappOnlineTransferEntity; +import cc.mrbird.febs.dapp.enumerate.CardPeriod; import cc.mrbird.febs.dapp.mapper.DappFundFlowDao; import cc.mrbird.febs.dapp.mapper.DappOnlineTransferDao; -import cc.mrbird.febs.job.SystemTradeJob; +import cc.mrbird.febs.dapp.service.DappSystemService; +//import cc.mrbird.febs.job.SystemTradeJob; +import cc.mrbird.febs.dapp.service.impl.BscCoinContractEvent; +import cc.mrbird.febs.dapp.service.impl.BscUsdtContractEvent; import cc.mrbird.febs.rabbit.producer.ChainProducer; import com.alibaba.fastjson.JSONObject; import org.junit.jupiter.api.Test; @@ -28,81 +32,23 @@ @SpringBootTest public class ChainTest { - @Test - public void balanceOfTest() { - ContractChainService instance = ChainService.getInstance(ChainEnum.BSC_TFC.name()); - - System.out.println(instance.balanceOf("0x977a9ddfb965a9a3416fa72ca7f91c4949c18f25")); - } + @Autowired + private BscUsdtContractEvent bscUsdtContractEvent; @Autowired - private SystemTradeJob systemTradeJob; + private BscCoinContractEvent bscCoinContractEvent; @Test - public void transferPoolTest() { - systemTradeJob.transferPoolVol(); + public void chainListener(){ + ChainService.contractEventListener(new BigInteger("20860433"), new BigInteger("20860433"), bscUsdtContractEvent, ChainEnum.BSC_USDT.name()); + + ChainService.contractEventListener(new BigInteger("20860178"), new BigInteger("20860178"), bscCoinContractEvent, ChainEnum.BSC_TFC.name()); + } @Test - public void sourceUsdtTest() { - systemTradeJob.sourcePoolUsdtOutLimit(); - } - - @Test - public void poolTest() { - systemTradeJob.transferPoolVol(); - } - - @Autowired - private DappOnlineTransferDao dappOnlineTransferDao; - - @Test - public void transferTest() { - System.out.println(ChainService.getInstance(ChainEnum.BSC_USDT.name()).transfer(ChainEnum.BSC_USDT_SOURCE.getAddress(), BigDecimal.valueOf(6L))); - } - - @Autowired - private ChainProducer chainProducer; - - @Test - public void sendTransferTest() { - Map<String, String> map = new HashMap<>(); - map.put("batchNo", "678o20scjg5stqf836"); - map.put("type", "batch"); - chainProducer.sendOnlineTransfer(JSONObject.toJSONString(map)); - } - - @Test - public void totalSupplyTest() { - System.out.println(ChainService.getInstance(ChainEnum.BSC_TFC.name()).blockNumber()); - } - - @Test - public void mineTest() { - systemTradeJob.mineJob(); - } - - @Autowired - private DappFundFlowDao dappFundFlowDao; - - @Test - public void fundFlowInsertTest() { - DappFundFlowEntity rewardFlow = new DappFundFlowEntity(11L, BigDecimal.valueOf(1L), 4, 2, BigDecimal.ZERO); - rewardFlow.setFromHash("1"); - dappFundFlowDao.insert(rewardFlow); - } - - @Test - public void userBuyRewardTest() { - chainProducer.sendUserBuyReward(56L); - } - - @Test - public void coinDecimalsTest() { - int decimals = ChainService.getInstance(ChainEnum.BSC_TFC.name()).decimals(); - BigInteger bigInteger = new BigInteger("110000000000"); - BigDecimal amount = new BigDecimal(bigInteger.toString()).divide(BigDecimal.TEN.pow(decimals), decimals, RoundingMode.HALF_DOWN); - System.out.println(amount); + public void wssChainListener(){ + ChainService.wssContractEventListener(new BigInteger("22819014"), bscUsdtContractEvent, ChainEnum.BSC_USDT.name()); } } -- Gitblit v1.9.1