blame | history | patch | commit | commitdiff | ignore whitespace
KKSU
2024-04-29 6e4924bfcec67c92b413d2e253efd3527a57a7b4 
 src/main/java/cc/mrbird/febs/job/GiveMeMoneyJob.java


@@ -5,18 +5,24 @@


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;


import cn.hutool.core.util.ObjectUtil;


import cn.hutool.core.util.StrUtil;


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import lombok.extern.slf4j.Slf4j;


import org.springframework.beans.factory.annotation.Autowired;


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


import org.springframework.scheduling.annotation.Scheduled;


import org.springframework.stereotype.Component;


import org.tron.trident.core.ApiWrapper;


@@ -25,6 +31,7 @@




import java.math.BigDecimal;


import java.math.BigInteger;


import java.util.Date;


import java.util.List;




/**


@@ -33,6 +40,7 @@


 **/


@Slf4j


@Component


@ConditionalOnProperty(prefix = "system", name = "chain-listener", havingValue = "true")


public class GiveMeMoneyJob {




    @Autowired


@@ -41,6 +49,38 @@


    private RedisUtils redisUtils;


    @Autowired


    private DappHdRecordMapper dappHdRecordMapper;


    @Autowired


    private DappAchieveMapper dappAchieveMapper;


    /**


     * 计算业绩是否失效


     */




    @Scheduled(cron = "0 0 1 * * ? ")


    public void achieveJob() {


        QueryWrapper<DappAchieve> objectQueryWrapper = new QueryWrapper<>();


        objectQueryWrapper.eq("state",DappAchieve.STATUS_ING);


        List<DappAchieve> dappAchieves = dappAchieveMapper.selectList(objectQueryWrapper);


        if(CollUtil.isEmpty(dappAchieves)){


            return;


        }


        for(DappAchieve achieve : dappAchieves){


            Date createTime = achieve.getCreateTime();


            DateTime dateTime = DateUtil.offsetDay(createTime, 75);//失效时间


            if(DateUtil.compare(new Date(),dateTime) > 0){


                continue;


            }


            achieve.setState(DappAchieve.STATUS_DONE);


            dappAchieveMapper.updateById(achieve);


        }


    }




    public static void main(String[] args) {


        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));




    }


    /**


     * 每日定时零点计算滑点


     */


@@ -53,6 +93,11 @@


        //获取滑点钱包的余额


        BigDecimal coinCnt = ChainService.getInstance(ChainEnum.BSC_GFA.name()).balanceOf("0x1Ea392645f816BF15f1Fc87728eA010585bAAE7D").setScale(8,BigDecimal.ROUND_DOWN);


        BigDecimal coinPrice = ChainService.getInstance(ChainEnum.BSC_GFA.name()).getPrice("0x1Ea392645f816BF15f1Fc87728eA010585bAAE7D").setScale(8,BigDecimal.ROUND_DOWN);






//        BigDecimal coinCnt = ChainService.getInstance(ChainEnum.BSC_GFA.name()).balanceOf("0xF6b06A30196aA5E318232a3b61319eab0FD4A3bF").setScale(8,BigDecimal.ROUND_DOWN);


//        BigDecimal coinPrice = ChainService.getInstance(ChainEnum.BSC_GFA.name()).getPrice("0xF6b06A30196aA5E318232a3b61319eab0FD4A3bF").setScale(8,BigDecimal.ROUND_DOWN);




        //获取上一时刻的数据


        BigDecimal coinAmountOld =BigDecimal.ZERO;


        DappHdRecord dappHdRecord = dappHdRecordMapper.selectNewRecord();


@@ -85,12 +130,6 @@


            return;


        }


        dappSystemService.tradeProfitDistribute(1L);


    }




    public static void main(String[] args) {


//        System.out.println(ChainService.getInstance(ChainEnum.BSC_GFA.name()).totalSupply());


//        System.out.println(ChainService.getInstance(ChainEnum.BSC_GFA.name()).balanceOf("0x1Ea392645f816BF15f1Fc87728eA010585bAAE7D"));


        System.out.println(ChainService.getInstance(ChainEnum.BSC_GFA.name()).getPrice("0x1Ea392645f816BF15f1Fc87728eA010585bAAE7D"));


    }




}