20221021

xiaoyong931011

2022-11-04 cdc27a7a63b4ff81125ec594eb23deb22bd76e21

 src/test/java/cc/mrbird/febs/JunitTest.java

@@ -220,14 +220,14 @@
//    @Autowired
//    private IgtOnHookPlanOrderDao igtOnHookPlanOrderDao;
//
//    @Autowired
//    private DappWalletCoinDao dappWalletCoinDao;
    @Autowired
    private DappWalletCoinDao dappWalletCoinDao;
//
//    @Autowired
//    private DappAccountMoneyChangeDao dappAccountMoneyChangeDao;
//
//    @Autowired
//    private DappMemberDao dappMemberDao;
    @Autowired
    private DappMemberDao dappMemberDao;
//
//    @Autowired
//    private DappOnHookAwardDao dappOnHookAwardDao;
@@ -253,46 +253,46 @@
//        System.out.println(active);
//    }
//
//    @Test
//    public void testUpdateIgt(){Log.info("更新用户代理等级");
//        DateTime date = DateUtil.date();
//        //查询账户总金额大于51的有效用户
//        List<DappMemberEntity> dappMemberEntities = dappWalletCoinDao.selectTotalAmount();
//        if(CollUtil.isEmpty(dappMemberEntities)){
//            //没有账户金额大于51，则全部为会员
//            dappMemberDao.updateIdentity();
//        }else{
//            List<DappMemberEntity> LEVEL_IB = getMemberLevelList(dappMemberEntities, DataDictionaryEnum.LEVEL_MB.getCode(), DataDictionaryEnum.LEVEL_IB.getCode());
//            List<DappMemberEntity> LEVEL_FIB = getMemberLevelList(LEVEL_IB, DataDictionaryEnum.LEVEL_IB.getCode(), DataDictionaryEnum.LEVEL_FIB.getCode());
//            List<DappMemberEntity> LEVEL_CIB = getMemberLevelList(LEVEL_FIB, DataDictionaryEnum.LEVEL_FIB.getCode(), DataDictionaryEnum.LEVEL_CIB.getCode());
//            List<DappMemberEntity> LEVEL_AIB = getMemberLevelList(LEVEL_CIB, DataDictionaryEnum.LEVEL_CIB.getCode(), DataDictionaryEnum.LEVEL_AIB.getCode());
//            List<DappMemberEntity> LEVEL_GIB = getMemberLevelList(LEVEL_AIB, DataDictionaryEnum.LEVEL_AIB.getCode(), DataDictionaryEnum.LEVEL_GIB.getCode());
//            List<DappMemberEntity> LEVEL_BP = getMemberLevelList(LEVEL_GIB, DataDictionaryEnum.LEVEL_GIB.getCode(), DataDictionaryEnum.LEVEL_BP.getCode());
//            List<DappMemberEntity> LEVEL_SP = getMemberLevelList(LEVEL_BP, DataDictionaryEnum.LEVEL_BP.getCode(), DataDictionaryEnum.LEVEL_SP.getCode());
//            List<DappMemberEntity> LEVEL_GP = getMemberLevelList(LEVEL_SP, DataDictionaryEnum.LEVEL_SP.getCode(), DataDictionaryEnum.LEVEL_GP.getCode());
//        }
//    }
//
//    private List<DappMemberEntity> getMemberLevelList(List<DappMemberEntity> dappMemberEntities,String identity,String identityNext){
//        List<DappMemberEntity> dappMemberEntitiesNext = new ArrayList<>();
//        if(CollUtil.isNotEmpty(dappMemberEntities)){
//            for(DappMemberEntity dappMemberEntity : dappMemberEntities){
//                Long memberEntityId = dappMemberEntity.getId();
//                String refererId = dappMemberEntity.getRefererId();
//                String inviteId = dappMemberEntity.getInviteId();
//                //下级是否存在三个账户总金额大于51的会员，并且代理等级为identity
//                List<DappMemberEntity> levelMbMembers = dappMemberDao.selectTotalAmountByRefererIdAndIdentity(inviteId,identity);
//                if(CollUtil.isNotEmpty(levelMbMembers) && 3 <= levelMbMembers.size()){
//                    //设置identityNext级别
//                    dappMemberDao.updateIdentityByMemberId(identityNext,memberEntityId);
//                    //获取他的上级会员信息
//                    DappMemberEntity dappMemberEntityNext = dappMemberDao.selectMemberInfoByInviteId(refererId);
//                    dappMemberEntitiesNext.add(dappMemberEntityNext);
//                }
//            }
//        }
//        return dappMemberEntitiesNext;
//    }
    @Test
    public void testUpdateIgt(){Log.info("更新用户代理等级");
        DateTime date = DateUtil.date();
        //查询账户总金额大于51的有效用户
        List<DappMemberEntity> dappMemberEntities = dappWalletCoinDao.selectTotalAmount();
        if(CollUtil.isEmpty(dappMemberEntities)){
            //没有账户金额大于51，则全部为会员
            dappMemberDao.updateIdentity();
        }else{
            List<DappMemberEntity> LEVEL_IB = getMemberLevelList(dappMemberEntities, DataDictionaryEnum.LEVEL_MB.getCode(), DataDictionaryEnum.LEVEL_IB.getCode());
            List<DappMemberEntity> LEVEL_FIB = getMemberLevelList(LEVEL_IB, DataDictionaryEnum.LEVEL_IB.getCode(), DataDictionaryEnum.LEVEL_FIB.getCode());
            List<DappMemberEntity> LEVEL_CIB = getMemberLevelList(LEVEL_FIB, DataDictionaryEnum.LEVEL_FIB.getCode(), DataDictionaryEnum.LEVEL_CIB.getCode());
            List<DappMemberEntity> LEVEL_AIB = getMemberLevelList(LEVEL_CIB, DataDictionaryEnum.LEVEL_CIB.getCode(), DataDictionaryEnum.LEVEL_AIB.getCode());
            List<DappMemberEntity> LEVEL_GIB = getMemberLevelList(LEVEL_AIB, DataDictionaryEnum.LEVEL_AIB.getCode(), DataDictionaryEnum.LEVEL_GIB.getCode());
            List<DappMemberEntity> LEVEL_BP = getMemberLevelList(LEVEL_GIB, DataDictionaryEnum.LEVEL_GIB.getCode(), DataDictionaryEnum.LEVEL_BP.getCode());
            List<DappMemberEntity> LEVEL_SP = getMemberLevelList(LEVEL_BP, DataDictionaryEnum.LEVEL_BP.getCode(), DataDictionaryEnum.LEVEL_SP.getCode());
            List<DappMemberEntity> LEVEL_GP = getMemberLevelList(LEVEL_SP, DataDictionaryEnum.LEVEL_SP.getCode(), DataDictionaryEnum.LEVEL_GP.getCode());
        }
    }

    private List<DappMemberEntity> getMemberLevelList(List<DappMemberEntity> dappMemberEntities,String identity,String identityNext){
        List<DappMemberEntity> dappMemberEntitiesNext = new ArrayList<>();
        if(CollUtil.isNotEmpty(dappMemberEntities)){
            for(DappMemberEntity dappMemberEntity : dappMemberEntities){
                Long memberEntityId = dappMemberEntity.getId();
                String refererId = dappMemberEntity.getRefererId();
                String inviteId = dappMemberEntity.getInviteId();
                //下级是否存在三个账户总金额大于51的会员，并且代理等级为identity
                List<DappMemberEntity> levelMbMembers = dappMemberDao.selectTotalAmountByRefererIdAndIdentity(inviteId,identity);
                if(CollUtil.isNotEmpty(levelMbMembers) && 3 <= levelMbMembers.size()){
                    //设置identityNext级别
                    dappMemberDao.updateIdentityByMemberId(identityNext,memberEntityId);
                    //获取他的上级会员信息
                    DappMemberEntity dappMemberEntityNext = dappMemberDao.selectMemberInfoByInviteId(refererId);
                    dappMemberEntitiesNext.add(dappMemberEntityNext);
                }
            }
        }
        return dappMemberEntitiesNext;
    }
//
//    @Test
//    public void testProfitSharing(){