逻辑

KKSU

2024-07-22 4575ae4dbedd7046f4b7aeeb79b49059676e2201

 src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java

@@ -96,7 +96,7 @@
        BigDecimal runPerk = dappFundFlowDao.selectSumRunPerkByMemberId(member.getId());
        walletInfo.setRunPerk(runPerk);


//        List<DappMemberEntity> dappMemberEntities = dappMemberDao.selectList(null);
        List<DappStorage> allAddressNums = dappStorageMapper.selectListGroupByMemberId();
        walletInfo.setAddressNum(CollUtil.isEmpty(allAddressNums) ? 0 : allAddressNums.size());

@@ -254,6 +254,10 @@
            }
            if(withdrawDto.getAmount().compareTo(usdtBalance) > 0){
                throw new FebsException("额度不足");
            }
            DappStorage dappStorage = dappStorageMapper.selectAmountByAmountDesc(member.getId(),0, 1);
            if(ObjectUtil.isEmpty(dappStorage)){
                throw new FebsException("请存储");
            }
        }else{
            if(BigDecimal.ZERO.compareTo(withdrawDto.getAmount()) >= 0){
@@ -820,12 +824,15 @@
            startTimeStr = DateUtil.formatDate(DateUtil.offsetDay(new Date(), -1)) + " 17:00:00";
        }
        DateTime startTime = DateUtil.parseDateTime(startTimeStr);
        List<DappMemberEntity> dappMemberEntityList = dappMemberDao.selectListByDateFiveToFiver(startTime);
//        List<DappMemberEntity> dappMemberEntityList = dappMemberDao.selectListByDateFiveToFiver(startTime);

        List<DappStorage> dappStorages = dappStorageMapper.selectListByDateFiveToFiver(startTime);
        Set<Long> collect = dappStorages.stream().map(DappStorage::getMemberId).collect(Collectors.toSet());

//        List<DappMemberEntity> dappMemberEntityList = dappMemberDao.selectListByDate(new Date());
        if(CollUtil.isNotEmpty(dappMemberEntityList)){
            for(DappMemberEntity member : dappMemberEntityList){

        if(CollUtil.isNotEmpty(collect)){
            for(Long memberId : collect){
                DappMemberEntity member = dappMemberDao.selectById(memberId);
                if(StrUtil.isEmpty(member.getRefererId())){
                    continue;
                }
@@ -862,10 +869,24 @@
                ApiDirectInfoVo apiDirectInfoVo = new ApiDirectInfoVo();
                apiDirectInfoVo.setAddress(dappMemberDao.selectById(memberId).getAddress());
                apiDirectInfoVo.setAmount(directCnt);

                DappStorage dappStorage = dappStorageMapper.selectNewRecordByRefMemberId(memberId);
                apiDirectInfoVo.setCreateTime(dappStorage.getCreateTime());
                apiDirectInfoVos.add(apiDirectInfoVo);
            }
        }
        if(CollUtil.isNotEmpty(apiDirectInfoVos)){
            apiDirectInfoVos = apiDirectInfoVos.stream()
                    .sorted((a, b) -> {
                        // 先按照amount从大到小排序
                        int compare = b.getAmount().compareTo(a.getAmount());
                        if (compare != 0) {
                            return compare;
                        }
                        // 如果amount相同，则按照createTime从小到大排序
                        return a.getCreateTime().compareTo(b.getCreateTime());
                    })
                    .collect(Collectors.toList());
        }


        return apiDirectInfoVos;