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;
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;
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<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
//    TrxUsdtUpdateService trxUsdtUpdateService;
//
//    @Test
//    public void poolByAddressTest() {
//        trxUsdtUpdateService.poolByAddress("TNmohnmZLqrPWNqT98CA8ZgmRdhMzSa4Z6");
//    }
//
//    @Test
//    public void blockMsgTest() {
//        trxUsdtUpdateService.monitorCoinListener(45548841L);
//    }

    @Autowired
    NotionalPoolingJob notionalPoolingJob;

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

    @Autowired
    RedisUtils redisUtils;

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