From 73f6576344bcad250293edaff8e56f35ddea0dcd Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Thu, 07 Jul 2022 21:52:36 +0800
Subject: [PATCH] 20220707 缓慢增加
---
src/main/java/cc/mrbird/febs/job/MineProfitJob.java | 28 ++++++++++++++++++++++++++++
src/main/resources/mapper/dapp/DappSystemDao.xml | 9 +++++++++
src/main/java/cc/mrbird/febs/dapp/mapper/DappSystemDao.java | 7 +++++++
3 files changed, 44 insertions(+), 0 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/dapp/mapper/DappSystemDao.java b/src/main/java/cc/mrbird/febs/dapp/mapper/DappSystemDao.java
index a93f511..e6c9c4d 100644
--- a/src/main/java/cc/mrbird/febs/dapp/mapper/DappSystemDao.java
+++ b/src/main/java/cc/mrbird/febs/dapp/mapper/DappSystemDao.java
@@ -1,9 +1,16 @@
package cc.mrbird.febs.dapp.mapper;
import cc.mrbird.febs.dapp.entity.DappMineDataEntity;
+import org.apache.ibatis.annotations.Param;
+
+import java.math.BigDecimal;
public interface DappSystemDao {
DappMineDataEntity selectMineDataForOne();
+ int updateDappMineData(@Param("totalOutput")BigDecimal totalOutput,
+ @Param("validNode")Integer validNode,
+ @Param("partnerCnt")Integer partnerCnt,
+ @Param("partnerIncome")BigDecimal partnerIncome);
}
diff --git a/src/main/java/cc/mrbird/febs/job/MineProfitJob.java b/src/main/java/cc/mrbird/febs/job/MineProfitJob.java
index 684400f..7519656 100644
--- a/src/main/java/cc/mrbird/febs/job/MineProfitJob.java
+++ b/src/main/java/cc/mrbird/febs/job/MineProfitJob.java
@@ -8,6 +8,7 @@
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;
@@ -41,6 +42,33 @@
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)
diff --git a/src/main/resources/mapper/dapp/DappSystemDao.xml b/src/main/resources/mapper/dapp/DappSystemDao.xml
index 176511a..8bebc0c 100644
--- a/src/main/resources/mapper/dapp/DappSystemDao.xml
+++ b/src/main/resources/mapper/dapp/DappSystemDao.xml
@@ -6,4 +6,13 @@
select * from dapp_mine_data limit 1
</select>
+ <update id="updateDappMineData">
+ update dapp_mine_data
+ set
+ total_output = #{totalOutput},
+ valid_node = #{validNode},
+ partner_cnt = #{partnerCnt},
+ partner_income = #{partnerIncome}
+ </update>
+
</mapper>
\ No newline at end of file
--
Gitblit v1.9.1