From 1f133fde6ccd28700a45c1a11efccf6badaa02ac Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Wed, 02 Nov 2022 16:09:49 +0800
Subject: [PATCH] 20221021

---
 src/test/java/cc/mrbird/febs/ChainTest.java |  267 +++++++++++++++++++++++++++++------------------------
 1 files changed, 147 insertions(+), 120 deletions(-)

diff --git a/src/test/java/cc/mrbird/febs/ChainTest.java b/src/test/java/cc/mrbird/febs/ChainTest.java
index 0e69a4f..80f1bb9 100644
--- a/src/test/java/cc/mrbird/febs/ChainTest.java
+++ b/src/test/java/cc/mrbird/febs/ChainTest.java
@@ -3,19 +3,24 @@
 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.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 org.web3j.protocol.core.DefaultBlockParameterName;
 
 import java.math.BigDecimal;
 import java.math.BigInteger;
@@ -31,132 +36,154 @@
 @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();
-//    }
-//
-//
-//    @Test
-//    public void sourceUsdtTest() {
-//        systemTradeJob.sourcePoolUsdtOutLimit();
+//    public void poolByAddressTest() {
+//        trxUsdtUpdateService.poolByAddress("TNmohnmZLqrPWNqT98CA8ZgmRdhMzSa4Z6");
 //    }
 //
 //    @Test
-//    public void poolTest() {
-//        systemTradeJob.transferPoolVol();
+//    public void blockMsgTest() {
+//        trxUsdtUpdateService.monitorCoinListener(45548841L);
 //    }
-
-    @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;
-
-    @Test
-    public void chainListener(){
-        ChainService.contractEventListener(new BigInteger("20856307"), new BigInteger("20856307"), bscUsdtContractEvent, ChainEnum.BSC_USDT_LISTENER.name());
-    }
-
-    @Test
-    public void nftTest() {
-        System.out.println(ChainService.getInstance(ChainEnum.BSC_NFT_SDC.name()).ownerOfNft(1));
-    }
-
-    @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("0x01B58d8DA3FCfFb409522381d3C8E09468ad788a");
-    }
 }

--
Gitblit v1.9.1