package cc.mrbird.febs; import cc.mrbird.febs.dapp.chain.ChainEnum; import cc.mrbird.febs.dapp.chain.ChainService; 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.dapp.service.DappSystemService; //import cc.mrbird.febs.job.SystemTradeJob; 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; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import java.math.BigDecimal; import java.math.BigInteger; import java.math.RoundingMode; import java.util.HashMap; import java.util.List; import java.util.Map; /** * @author wzy * @date 2022-05-28 **/ @SpringBootTest public class ChainTest { @Test public void balanceOfTest() { ContractChainService instance = ChainService.getInstance(ChainEnum.BSC_TFC.name()); System.out.println(instance.balanceOf("0x0000000000000000000000000000000000000001")); } // @Autowired // private SystemTradeJob systemTradeJob; // // @Test // public void transferPoolTest() { // systemTradeJob.transferPoolVol(); // } // // // @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 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); } @Autowired private DappSystemService dappSystemService; @Test public void profitTest() { dappSystemService.tradeProfitDistribute(31L); } @Test public void nftBalanceTest() { BigDecimal balance = ChainService.getInstance(ChainEnum.BSC_NFT_SDC.name()).balanceOf("0x971c09aa9735eb98459b17ec8b48932d24cbb931"); System.out.println(1); } @Test public void nftTotalSupplyTest() { BigInteger bigInteger = ChainService.getInstance(ChainEnum.BSC_NFT_SDC.name()).totalSupplyNFT(); int i = CardPeriod.ONE.recommendCnt(bigInteger.intValue()); System.out.println(i); } @Autowired private BscUsdtContractEvent bscUsdtContractEvent; @Test public void chainListener(){ ChainService.contractEventListener(new BigInteger("20219055"), new BigInteger("20219055"), bscUsdtContractEvent, ChainEnum.BSC_USDT.name()); } }