后台修改

xiaoyong931011

2023-09-01 5772ee39bd00b83ecca16b0b472d86e945d8c0ea

 src/main/java/cc/mrbird/febs/job/BnbTransferJob.java

@@ -1,8 +1,11 @@
package cc.mrbird.febs.job;

import cc.mrbird.febs.dapp.entity.DappAKlineEntity;
import cc.mrbird.febs.dapp.entity.DappMemberEntity;
import cc.mrbird.febs.dapp.mapper.DappAKlineMapper;
import cc.mrbird.febs.dapp.service.DappSystemService;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.ObjectUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
@@ -20,8 +23,11 @@

    @Autowired
    private DappSystemService dappSystemService;
    @Autowired
    private DappAKlineMapper dappAKlineMapper;

    @Scheduled(cron = "0 0 0 * * ?")
//    @Scheduled(cron = "0 0 0 * * ?")
    @Scheduled(cron = "0 0 2 * * ?")
    public void memberPerk() {
        /**
         * 加速团队静态收益的70%（业绩全算）
@@ -52,4 +58,17 @@
        }
    }

    @Scheduled(cron = "0 0 0/4 * * ?")
    public void klineUpdate() {
        DappAKlineEntity dappAKlineEntity = new DappAKlineEntity();
        dappAKlineEntity.setType(2);
        DappAKlineEntity dappAKlineOld = dappAKlineMapper.selectOneHourByType();
        if(ObjectUtil.isEmpty(dappAKlineOld)){
            dappAKlineEntity.setOpenPrice(BigDecimal.ZERO);
        }else{
            dappAKlineEntity.setOpenPrice(dappAKlineOld.getOpenPrice());
        }
        dappAKlineMapper.insert(dappAKlineEntity);
    }

}