xiaoyong931011
2022-11-11 1fd82a7201e94d65b78afdcb2ee6bd7cd92d2c0b
20221021
4 files modified
23 ■■■■ changed files
src/main/java/cc/mrbird/febs/dapp/mapper/DappWalletCoinDao.java 2 ●●●●● patch | view | raw | blame | history
src/main/java/cc/mrbird/febs/job/OnHookPlanJob.java 3 ●●●● patch | view | raw | blame | history
src/main/resources/mapper/dapp/DappWalletCoinDao.xml 15 ●●●●● patch | view | raw | blame | history
src/test/java/cc/mrbird/febs/JunitTest.java 3 ●●●● patch | view | raw | blame | history
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();
}
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();
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>
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();