短信时间设置为10分钟，CPV不能互转

zainali5120

2020-12-12 73323434da5af65661adb4f57b816351b0a54ce1

短信时间设置为10分钟，CPV不能互转

 src/main/java/com/xcong/excoin/modules/blackchain/service/UsdtEthService.java

@@ -57,20 +57,14 @@
    public void pool() throws ExecutionException, InterruptedException {
        String gasPrice = getGasString();
        // 查询不归集的账号
        String not_pool_address = redisUtils.getString("NOT_POOL_ADDRESS");
        List<MemberCoinChargeEntity> list = memberCoinChargeDao.selectAllBySymbolAndTag(CoinTypeEnum.USDT.name(), "ERC20", 1);
        if (CollUtil.isNotEmpty(list)) {
            EthService ethService = new EthService();

            for (MemberCoinChargeEntity coinCharge : list) {
                // 首先根据每个地址查询其是否有ETH 如果没有就充值ETH并设置1 表示初始状态 status=2（待充值）3：表示已提过
                String address = coinCharge.getAddress();
                Long memberId = coinCharge.getMemberId();
                BigDecimal usdt = coinCharge.getAmount();
                if(StringUtils.isNotBlank(not_pool_address) && not_pool_address.contains(address)){
                    // 不归集的
                    continue;
                }
                if (usdt == null || usdt.compareTo(LIMIT) < 0) {
                    continue;
                }

 src/main/resources/mapper/member/MemberCoinChargeDao.xml

@@ -15,7 +15,7 @@
    <select id="selectAllBySymbolAndTag" resultType="com.xcong.excoin.modules.member.entity.MemberCoinChargeEntity">

        select * from member_coin_charge

        where symbol=#{symbol}

        and create_time &gt; "2020-11-25 00:00:00"

        and create_time &gt; "2020-11-20 00:00:00"

        <if test="tag !=null and tag != ''">

            and tag = #{tag}

        </if>