package cc.mrbird.febs; 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.entity.DappAchieve; import cc.mrbird.febs.dapp.entity.DappMemberEntity; import cc.mrbird.febs.dapp.entity.DataDictionaryCustom; import cc.mrbird.febs.dapp.mapper.DappAchieveMapper; import cc.mrbird.febs.dapp.mapper.DappMemberDao; import cc.mrbird.febs.dapp.mapper.DataDictionaryCustomMapper; import cc.mrbird.febs.dapp.service.AsyncCjService; import cc.mrbird.febs.dapp.service.DappSystemService; import cc.mrbird.febs.rabbit.producer.ChainProducer; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.util.StrUtil; import org.apache.commons.lang3.StringUtils; import org.junit.jupiter.api.Test; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.scheduling.annotation.Scheduled; import java.math.BigDecimal; import java.util.List; /** * @author wzy * @date 2022-06-09 **/ @SpringBootTest public class MemberTest { @Autowired private ChainProducer chainProducer; @Autowired private RedisUtils redisUtils; @Autowired private DappSystemService dappSystemService; @Autowired private DappAchieveMapper dappAchieveMapper; @Autowired private AsyncCjService asyncCjService; @Test public void mineJob() { List dappAchieves = dappAchieveMapper.selectList(null); if(CollUtil.isNotEmpty(dappAchieves)){ for(DappAchieve dappAchieve : dappAchieves){ asyncCjService.calculateAchieve(dappAchieve); } } // dappSystemService.tradeProfitDistribute(1L); } }