blame | history | patch | commit | commitdiff | ignore whitespace
KKSU
2024-05-15 fa039ab4ede44c9ae3f07056bdcaa9cae8f94ad8 
 src/main/java/cc/mrbird/febs/job/GiveMeMoneyJob.java


@@ -1,19 +1,14 @@


package cc.mrbird.febs.job;




import cc.mrbird.febs.common.contants.AppContants;


import cc.mrbird.febs.common.enumerates.DataDicEnum;


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.entity.DappAchieve;


import cc.mrbird.febs.dapp.entity.DappAddressList;


import cc.mrbird.febs.dapp.entity.DappHdRecord;


import cc.mrbird.febs.dapp.mapper.DappAchieveMapper;


import cc.mrbird.febs.dapp.mapper.DappAdressListDao;


import cc.mrbird.febs.dapp.mapper.DappHdRecordMapper;


import cc.mrbird.febs.dapp.mapper.DappMemberDao;


import cc.mrbird.febs.dapp.service.DappSystemService;


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;


@@ -25,12 +20,8 @@


import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;


import org.springframework.scheduling.annotation.Scheduled;


import org.springframework.stereotype.Component;


import org.tron.trident.core.ApiWrapper;


import org.tron.trident.core.contract.Contract;


import org.tron.trident.core.contract.Trc20Contract;




import java.math.BigDecimal;


import java.math.BigInteger;


import java.util.Date;


import java.util.List;




@@ -77,7 +68,7 @@


        DateTime dateTime = DateUtil.offsetDay(new Date(), 75);


        System.out.println(dateTime);


        System.out.println(DateUtil.compare(new Date(),dateTime));


        System.out.println(DateUtil.compare(dateTime,dateTime));


        System.out.println(DateUtil.compare(new Date(),dateTime) > 0);




    }


    /**


@@ -112,6 +103,9 @@


        //这个时间段的新增余额


        //此刻的余额-上一次账户的余额 = 这个时间段的新增余额


        BigDecimal subtract = coinCnt.subtract(coinAmountOld);


        if(BigDecimal.ZERO.compareTo(subtract) >= 0){


            return;


        }


        //获取这个时刻的滑点入账数量


        BigDecimal multiply = coinPrice.multiply(subtract).multiply(new BigDecimal("0.97")).setScale(8,BigDecimal.ROUND_DOWN);


        //更新这个时间段的滑点数量


@@ -124,10 +118,6 @@


        dappHdRecordAdd.setCoinEvery(subtract);


        dappHdRecordAdd.setCoinAmount(coinCnt);


        dappHdRecordMapper.insert(dappHdRecordAdd);




        if(BigDecimal.ZERO.compareTo(subtract) >= 0){


            return;


        }


        dappSystemService.tradeProfitDistribute(1L);


    }