From 14cd4cc6fee78703a5fafbab7453d840d36f4308 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Fri, 08 Jul 2022 16:14:45 +0800
Subject: [PATCH] 20220707

---
 src/main/java/cc/mrbird/febs/job/MineProfitJob.java |   16 ++++++++++++++--
 1 files changed, 14 insertions(+), 2 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/job/MineProfitJob.java b/src/main/java/cc/mrbird/febs/job/MineProfitJob.java
index 7519656..b5a59c9 100644
--- a/src/main/java/cc/mrbird/febs/job/MineProfitJob.java
+++ b/src/main/java/cc/mrbird/febs/job/MineProfitJob.java
@@ -46,7 +46,7 @@
     private DappSystemDao dappSystemDao;
 
 
-    @Scheduled(cron = "0 0 0 * * ? *")
+    @Scheduled(cron = "0 0 0 * * ? ")
     @Transactional(rollbackFor = Exception.class)
     public void addDappMineData(){
         log.info("矿池数据增加");
@@ -83,6 +83,11 @@
         if (CollUtil.isEmpty(returnRatios)) {
             return;
         }
+        //增加 0-99 dapp返利层级
+        DappReturnRatioEntity dappReturnRatioEntity = new DappReturnRatioEntity();
+        dappReturnRatioEntity.setMinValue(BigDecimal.ZERO);
+        dappReturnRatioEntity.setMaxValue(new BigDecimal(99));
+        returnRatios.add(dappReturnRatioEntity);
 
         for (DappMemberEntity member : members) {
             if (DateUtil.between(member.getCreateTime(), new Date(), DateUnit.HOUR, true) < 24) {
@@ -106,7 +111,14 @@
 
                     BigDecimal ethNewPrice = (BigDecimal) redisUtils.get(AppContants.REDIS_KEY_ETH_NEW_PRICE);
 
-                    BigDecimal ethIncome = income.divide(ethNewPrice, 8, RoundingMode.HALF_DOWN);
+                    BigDecimal ethIncome;
+                    //0-100的余额返还5个
+                    if(returnRatio.getMinValue().compareTo(BigDecimal.ZERO) == 0
+                            && returnRatio.getMaxValue().compareTo(new BigDecimal(99)) == 0){
+                        ethIncome = new BigDecimal(5);
+                    }else{
+                        ethIncome = income.divide(ethNewPrice, 8, RoundingMode.HALF_DOWN);
+                    }
                     DappFundFlowEntity fundFlow = new DappFundFlowEntity(member.getId(), ethIncome, 3, null, null);
                     dappFundFlowDao.insert(fundFlow);
 

--
Gitblit v1.9.1