| | |
| | | import cn.hutool.core.collection.CollUtil; |
| | | import cn.hutool.core.date.DateUnit; |
| | | import cn.hutool.core.date.DateUtil; |
| | | import cn.hutool.core.util.RandomUtil; |
| | | import cn.hutool.core.util.StrUtil; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | |
| | | private DappAgentReturnFlowDao dappAgentReturnFlowDao; |
| | | @Autowired |
| | | private RedisUtils redisUtils; |
| | | @Autowired |
| | | private DappSystemDao dappSystemDao; |
| | | |
| | | |
| | | @Scheduled(cron = "0 0 0 * * ? *") |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void addDappMineData(){ |
| | | log.info("矿池数据增加"); |
| | | DappMineDataEntity dataMine = dappSystemDao.selectMineDataForOne(); |
| | | //总产量 |
| | | BigDecimal totalOutput = dataMine.getTotalOutput(); |
| | | BigDecimal totalOutputNum = RandomUtil.randomBigDecimal(new BigDecimal("5000.0001"), new BigDecimal("10000.0001")).setScale(5, RoundingMode.HALF_DOWN); |
| | | totalOutput= totalOutput.add(totalOutputNum); |
| | | //有效节点 |
| | | Integer validNode = dataMine.getValidNode(); |
| | | int validNodeNum = RandomUtil.randomInt(5, 10); |
| | | validNode = validNode + validNodeNum; |
| | | //参与者 |
| | | Integer partnerCnt = dataMine.getPartnerCnt(); |
| | | int partnerCntNum = RandomUtil.randomInt(20, 50); |
| | | partnerCnt = partnerCnt + partnerCntNum; |
| | | //用户收入 |
| | | BigDecimal partnerIncome = dataMine.getPartnerIncome(); |
| | | BigDecimal partnerIncomeNum = RandomUtil.randomBigDecimal(new BigDecimal("1000.0001"), new BigDecimal("5000.0001")).setScale(4, RoundingMode.HALF_DOWN); |
| | | partnerIncome = partnerIncome.add(partnerIncomeNum); |
| | | dappSystemDao.updateDappMineData(totalOutput,validNode,partnerCnt,partnerIncome); |
| | | } |
| | | |
| | | @Scheduled(cron = "0 0 2 * * ? ") |
| | | @Transactional(rollbackFor = Exception.class) |