Merge branch 'IGT-dev' of http://120.27.238.55:7000/r/sys-dapp into IGT-dev

xiaoyong931011

2022-11-15 6cc49e252929c182f0e47e4b79089cd51e1465ab

 src/test/java/cc/mrbird/febs/ChainTest.java

@@ -1,16 +1,22 @@
package cc.mrbird.febs;

import cc.mrbird.febs.common.utils.RedisUtils;
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.chain.TrxUsdtUpdateService;
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.enumerate.MemberOnHookPlanEnum;
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.MemberOnHookPlan;
import cc.mrbird.febs.dapp.service.impl.BscCoinContractEvent;
import cc.mrbird.febs.dapp.service.impl.BscUsdtContractEvent;
import cc.mrbird.febs.job.NotionalPoolingJob;
import cc.mrbird.febs.rabbit.producer.ChainProducer;
import com.alibaba.fastjson.JSONObject;
import org.junit.jupiter.api.Test;
@@ -32,137 +38,170 @@
@SpringBootTest
public class ChainTest {

    @Test
    public void balanceOfTest() {
        ContractChainService instance = ChainService.getInstance(ChainEnum.BSC_TFC.name());

        System.out.println(instance.balanceOf("0x0000000000000000000000000000000000000001"));
    }
//    @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<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);
//    }
//
//    @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;
//
//    @Autowired
//    private BscCoinContractEvent bscCoinContractEvent;
//
//    @Test
//    public void chainListener(){
////        ChainService.contractEventListener(new BigInteger("20895461"), new BigInteger("20895461"), bscUsdtContractEvent, ChainEnum.BSC_USDT_LISTENER.name());
//        ChainService.contractEventListener(new BigInteger("21351539"), new BigInteger("21351539"), bscCoinContractEvent, ChainEnum.BSC_TFC_LISTENER.name());
//    }
//
//    @Test
//    public void nftTest() {
//        ChainService.getInstance(ChainEnum.BSC_NFT_SDC.name()).safeMintNFT("0x691DEaf9b678Cba6747Eec9a4800a9ad2048E39C");
//    }
//
//    @Test
//    public void sendMsgTest() {
////        Map<String, String> map = new HashMap<>();
////        map.put("batchNo", "179");
////        map.put("type", "flow");
////        chainProducer.sendOnlineTransfer(JSONObject.toJSONString(map));
//
//        // 发送盲盒消息
////        chainProducer.sendNftBoxMsg(179L);
//    }
//
//    @Test
//    public void sendCardTest() {
////        ChainService.getInstance(ChainEnum.BSC_NFT_SDC.name()).safeMintNFT("0xbddfb8113ee3871774cb91cf1063cfba2a6becc8");
//    }
//
//    @Test
//    public void wssTest() {
//        ChainService.wssContractEventListener(new BigInteger("20888825"), bscUsdtContractEvent, ChainEnum.BSC_USDT_LISTENER.name());
//    }

//    @Autowired
//    private SystemTradeJob systemTradeJob;
//    TrxUsdtUpdateService trxUsdtUpdateService;
//
//    @Test
//    public void transferPoolTest() {
//        systemTradeJob.transferPoolVol();
//    public void poolByAddressTest() {
//        trxUsdtUpdateService.poolByAddress("TNmohnmZLqrPWNqT98CA8ZgmRdhMzSa4Z6");
//    }
//
//
//    @Test
//    public void sourceUsdtTest() {
//        systemTradeJob.sourcePoolUsdtOutLimit();
//    public void blockMsgTest() {
//        trxUsdtUpdateService.monitorCoinListener(45548841L);
//    }
//

//    @Autowired
//    NotionalPoolingJob notionalPoolingJob;

//    @Test
//    public void poolTest() {
//        systemTradeJob.transferPoolVol();
//        notionalPoolingJob.poolUsdtTrc20();
//    }

    @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());
    }
//    @Autowired
//    RedisUtils redisUtils;

//    @Test
//    public void mineTest() {
//        systemTradeJob.mineJob();
//    public void redisTest() {
//        redisUtils.setRemove("list_set", 11222);
//    }

    @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("20856307"), new BigInteger("20856307"), bscUsdtContractEvent, ChainEnum.BSC_USDT_LISTENER.name());
    }

    @Test
    public void nftTest() {
        ChainService.getInstance(ChainEnum.BSC_NFT_SDC.name()).safeMintNFT("0x691DEaf9b678Cba6747Eec9a4800a9ad2048E39C");
    }

    @Test
    public void sendMsgTest() {
//        Map<String, String> map = new HashMap<>();
//        map.put("batchNo", "179");
//        map.put("type", "flow");
//        chainProducer.sendOnlineTransfer(JSONObject.toJSONString(map));

        // 发送盲盒消息
//        chainProducer.sendNftBoxMsg(179L);
    }

    @Test
    public void sendCardTest() {
//        ChainService.getInstance(ChainEnum.BSC_NFT_SDC.name()).safeMintNFT("0x691DEaf9b678Cba6747Eec9a4800a9ad2048E39C");
    }

    @Test
    public void wssTest() {
        ChainService.wssContractEventListener(new BigInteger("20882595"), bscUsdtContractEvent, ChainEnum.BSC_USDT_LISTENER.name());
    }
}