From 0c19b95cac1bed28ea09d6edbc8d14f4d9cdd474 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Wed, 16 Aug 2023 16:20:34 +0800
Subject: [PATCH] 后台修改

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

diff --git a/src/main/java/cc/mrbird/febs/job/BnbTransferJob.java b/src/main/java/cc/mrbird/febs/job/BnbTransferJob.java
index 3380cf7..ebb9723 100644
--- a/src/main/java/cc/mrbird/febs/job/BnbTransferJob.java
+++ b/src/main/java/cc/mrbird/febs/job/BnbTransferJob.java
@@ -1,16 +1,8 @@
 package cc.mrbird.febs.job;
 
-import cc.mrbird.febs.dapp.entity.DappFundFlowEntity;
-import cc.mrbird.febs.dapp.entity.DataDictionaryCustom;
-import cc.mrbird.febs.dapp.enumerate.FundFlowEnum;
-import cc.mrbird.febs.dapp.enumerate.MemberLevelEnum;
-import cc.mrbird.febs.dapp.enumerate.NodeCodeEnum;
-import cc.mrbird.febs.dapp.enumerate.PoolEnum;
-import cc.mrbird.febs.dapp.mapper.DappFundFlowDao;
-import cc.mrbird.febs.dapp.mapper.DataDictionaryCustomMapper;
+import cc.mrbird.febs.dapp.entity.DappMemberEntity;
 import cc.mrbird.febs.dapp.service.DappSystemService;
-import cc.mrbird.febs.rabbit.producer.ChainProducer;
-import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.collection.CollUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
@@ -18,10 +10,11 @@
 import org.springframework.stereotype.Component;
 
 import java.math.BigDecimal;
+import java.util.Set;
 
 @Slf4j
 @Component
-@ConditionalOnProperty(prefix = "system", name = "quartz-job", havingValue = "true")
+@ConditionalOnProperty(prefix = "system", name = "online-transfer", havingValue = "true")
 public class BnbTransferJob{
 
 
@@ -50,7 +43,13 @@
         /**
          * 实际更新账户业绩余额和积分
          */
-        dappSystemService.updateAchieve();
+        Set<DappMemberEntity> dappMemberEntities = dappSystemService.updateAchieve();
+        if(CollUtil.isNotEmpty(dappMemberEntities)){
+            /**
+             * 奖励;团队产生的收益1%奖励积分,对标价格
+             */
+            dappSystemService.updatePackage(dappMemberEntities);
+        }
     }
 
 }

--
Gitblit v1.9.1