From 6c75b0c0fd6862b0d10793821db7017341a6a771 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Fri, 18 Aug 2023 16:48:31 +0800
Subject: [PATCH] 后台修改

---
 src/main/java/cc/mrbird/febs/job/BnbTransferJob.java |   18 ++++++++++++++++++
 1 files changed, 18 insertions(+), 0 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..85f57a2 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,6 +23,8 @@
 
     @Autowired
     private DappSystemService dappSystemService;
+    @Autowired
+    private DappAKlineMapper dappAKlineMapper;
 
     @Scheduled(cron = "0 0 0 * * ?")
     public void memberPerk() {
@@ -52,4 +57,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