twoCoin项目修改

xiaoyong931011

2023-05-31 62c1a7f2638542a2ad2d326b47b4b6201cd983da

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

@@ -6,8 +6,10 @@
import cc.mrbird.febs.dapp.chain.ChainEnum;
import cc.mrbird.febs.dapp.chain.ChainService;
import cc.mrbird.febs.dapp.contract.ContractMain;
import cc.mrbird.febs.dapp.entity.DappAKlineEntity;
import cc.mrbird.febs.dapp.entity.DappMemberEntity;
import cc.mrbird.febs.dapp.entity.DataDictionaryCustom;
import cc.mrbird.febs.dapp.mapper.DappAKlineMapper;
import cc.mrbird.febs.dapp.mapper.DappFundFlowDao;
import cc.mrbird.febs.dapp.mapper.DappMemberDao;
import cc.mrbird.febs.dapp.mapper.DataDictionaryCustomMapper;
@@ -15,6 +17,8 @@
import cc.mrbird.febs.dapp.vo.AKLineLimitVo;
import cc.mrbird.febs.dapp.vo.AKLineVo;
import cc.mrbird.febs.rabbit.producer.ChainProducer;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONArray;
@@ -30,6 +34,7 @@
import java.math.BigInteger;
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;

/**
 * @author wzy
@@ -54,6 +59,9 @@
    private ChainProducer chainProducer;

    @Autowired
    private DappAKlineMapper dappAKlineMapper;

    @Autowired
    private RedisUtils redisUtils;
    //        String address = dappMemberEntity.getAddress();
//        String hash = ChainService.getInstance(ChainEnum.BSC_USDT.name()).transfer(address, amount);
@@ -62,25 +70,15 @@
//        }

    public static void main(String[] args) {

        List<JSONObject> objects = new ArrayList<>();
        AKLineVo akLineVo = new AKLineVo();
        akLineVo.setCreateTime(DateUtil.date());
        akLineVo.setClosePrice(BigDecimal.ZERO);
        akLineVo.setOpenPrice(BigDecimal.ZERO);
        akLineVo.setLowestPrice(BigDecimal.ZERO);
        akLineVo.setHighestPrice(BigDecimal.ZERO);
        JSONObject parseObj = JSONUtil.parseObj(akLineVo);
        objects.add(parseObj);
        objects.add(parseObj);
        objects.add(parseObj);
        objects.add(parseObj);
        System.out.println(objects);
    }
    @Test
    public void tranfer(){
//        dappSystemService.antKLineMsg(1);
        dappSystemService.aKlineJobHour();
        dappSystemService.antKLineMsg(1);
//        boolean allowance = ChainService.getInstance(ChainEnum.BSC_USDT_A_POOL.name()).isAllowance("0x458ff43d5ddddb4fd44dd60170ae4831e0d97c9c");
//        System.out.println(allowance);

//        dappSystemService.AntACoinInMsg(780L);
//        dappSystemService.aKlineJobHour();
//        dappSystemService.aKlineJobDay();
//        dappSystemService.AntACoinInMsg(164L);

@@ -133,19 +131,19 @@
    @Test
    public void balance() {

//        dappSystemService.selectAndInsertDics();
        dappSystemService.selectAndInsertDics();
//        /**
//         * 从contractAddress合约地址中转移对应发行的代币到address中
//         */
//        dappSystemService.bnbTransfer(6L);


        String address = AppContants.ADDRESS_A_POOL_PEOJECT;
        /**
         * 发起USDT转账
         */
        String hash = ChainService.getInstance(ChainEnum.BSC_USDT.name()).transfer(address, new BigDecimal("0.01"));
        System.out.println(hash);
//        String address = AppContants.ADDRESS_A_POOL_PEOJECT;
//        /**
//         * 发起USDT转账
//         */
//        String hash = ChainService.getInstance(ChainEnum.BSC_USDT.name()).transfer(address, new BigDecimal("0.01"));
//        System.out.println(hash);
    }

    @Test