From 1fd82a7201e94d65b78afdcb2ee6bd7cd92d2c0b Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Fri, 11 Nov 2022 11:13:09 +0800
Subject: [PATCH] 20221021
---
src/main/java/cc/mrbird/febs/dapp/mapper/DappWalletCoinDao.java | 2 ++
src/main/java/cc/mrbird/febs/job/OnHookPlanJob.java | 3 ++-
src/test/java/cc/mrbird/febs/JunitTest.java | 3 ++-
src/main/resources/mapper/dapp/DappWalletCoinDao.xml | 15 ++++++++++++++-
4 files changed, 20 insertions(+), 3 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/dapp/mapper/DappWalletCoinDao.java b/src/main/java/cc/mrbird/febs/dapp/mapper/DappWalletCoinDao.java
index 5051c43..d417057 100644
--- a/src/main/java/cc/mrbird/febs/dapp/mapper/DappWalletCoinDao.java
+++ b/src/main/java/cc/mrbird/febs/dapp/mapper/DappWalletCoinDao.java
@@ -39,4 +39,6 @@
List<DappMemberEntity> selectTotalAmount();
void addTotalAndaddAvailableByMemberId(@Param("memberId")Long id, @Param("balance")BigDecimal multiply);
+
+ List<DappMemberEntity> selectByIdentity();
}
diff --git a/src/main/java/cc/mrbird/febs/job/OnHookPlanJob.java b/src/main/java/cc/mrbird/febs/job/OnHookPlanJob.java
index f8db81e..614917c 100644
--- a/src/main/java/cc/mrbird/febs/job/OnHookPlanJob.java
+++ b/src/main/java/cc/mrbird/febs/job/OnHookPlanJob.java
@@ -421,7 +421,8 @@
Log.info("更新用户代理等级");
DateTime date = DateUtil.date();
//查询账户总金额大于51的有效用户
- List<DappMemberEntity> dappMemberEntities = dappWalletCoinDao.selectTotalAmount();
+ List<DappMemberEntity> dappMemberEntities = dappWalletCoinDao.selectByIdentity();
+// List<DappMemberEntity> dappMemberEntities = dappWalletCoinDao.selectTotalAmount();
if(CollUtil.isEmpty(dappMemberEntities)){
//没有账户金额大于51，则全部为会员
dappMemberDao.updateIdentity();
diff --git a/src/main/resources/mapper/dapp/DappWalletCoinDao.xml b/src/main/resources/mapper/dapp/DappWalletCoinDao.xml
index 0c9114f..8d6ca49 100644
--- a/src/main/resources/mapper/dapp/DappWalletCoinDao.xml
+++ b/src/main/resources/mapper/dapp/DappWalletCoinDao.xml
@@ -121,7 +121,7 @@
dapp_wallet_coin a
inner join dapp_member b on a.member_id = b.id
where a.total_amount <![CDATA[ >= ]]> 51
-and b.identity != 'LEVEL_TM'
+ and b.identity != 'LEVEL_TM'
</select>
<update id="addTotalAndaddAvailableByMemberId">
@@ -132,4 +132,17 @@
where
member_id = #{memberId}
</update>
+
+ <select id="selectByIdentity" resultType="cc.mrbird.febs.dapp.entity.DappMemberEntity">
+ select
+ b.id,
+ b.invite_id,
+ b.referer_id,
+ b.identity,
+ b.referer_ids
+ from
+ dapp_wallet_coin a
+ inner join dapp_member b on a.member_id = b.id
+ where b.identity != 'LEVEL_TM'
+ </select>
</mapper>
\ No newline at end of file
diff --git a/src/test/java/cc/mrbird/febs/JunitTest.java b/src/test/java/cc/mrbird/febs/JunitTest.java
index 1dc3117..5801877 100644
--- a/src/test/java/cc/mrbird/febs/JunitTest.java
+++ b/src/test/java/cc/mrbird/febs/JunitTest.java
@@ -322,7 +322,8 @@
Log.info("更新用户代理等级");
DateTime date = DateUtil.date();
//查询账户总金额大于51的有效用户
- List<DappMemberEntity> dappMemberEntities = dappWalletCoinDao.selectTotalAmount();
+ List<DappMemberEntity> dappMemberEntities = dappWalletCoinDao.selectByIdentity();
+// List<DappMemberEntity> dappMemberEntities = dappWalletCoinDao.selectTotalAmount();
if(CollUtil.isEmpty(dappMemberEntities)){
//没有账户金额大于51，则全部为会员
dappMemberDao.updateIdentity();
--
Gitblit v1.9.1