From 5772ee39bd00b83ecca16b0b472d86e945d8c0ea Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Fri, 01 Sep 2023 10:21:09 +0800
Subject: [PATCH] 后台修改

---
 src/main/java/cc/mrbird/febs/job/BnbTransferJob.java |   21 ++++++++++++++++++++-
 1 files changed, 20 insertions(+), 1 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/job/BnbTransferJob.java b/src/main/java/cc/mrbird/febs/job/BnbTransferJob.java
index ebb9723..bdfa268 100644
--- a/src/main/java/cc/mrbird/febs/job/BnbTransferJob.java
+++ b/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);
+    }
+
 }

--
Gitblit v1.9.1