blame | history | patch | commit | commitdiff | show whitespace
KKSU
2024-04-19 0005fc44abfc506716618f3f131b846c089a5906 
 src/main/java/cc/mrbird/febs/dapp/service/impl/AdminBannerServiceImpl.java


@@ -4,19 +4,16 @@


import cc.mrbird.febs.common.entity.QueryRequest;


import cc.mrbird.febs.common.enumerates.DataDicEnum;


import cc.mrbird.febs.common.exception.FebsException;


import cc.mrbird.febs.dapp.entity.DappCoinPrice;


import cc.mrbird.febs.dapp.entity.DappHdRecord;


import cc.mrbird.febs.dapp.entity.DataDictionaryCustom;


import cc.mrbird.febs.dapp.entity.PlatformBanner;


import cc.mrbird.febs.dapp.mapper.DappCoinPriceMapper;


import cc.mrbird.febs.dapp.mapper.DappHdRecordMapper;


import cc.mrbird.febs.dapp.mapper.DataDictionaryCustomMapper;


import cc.mrbird.febs.dapp.mapper.PlatformBannerMapper;


import cc.mrbird.febs.dapp.entity.*;


import cc.mrbird.febs.dapp.mapper.*;


import cc.mrbird.febs.dapp.service.AsyncCjService;


import cc.mrbird.febs.dapp.service.IAdminBannerService;


import cn.hutool.core.collection.CollUtil;


import cn.hutool.core.date.DateTime;


import cn.hutool.core.date.DateUtil;


import cn.hutool.core.util.ObjectUtil;


import cn.hutool.core.util.StrUtil;


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import com.baomidou.mybatisplus.core.metadata.IPage;


import com.baomidou.mybatisplus.extension.plugins.pagination.Page;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


@@ -28,6 +25,7 @@


import javax.validation.Valid;


import javax.validation.constraints.NotNull;


import java.math.BigDecimal;


import java.util.List;




@Slf4j


@Service


@@ -40,6 +38,8 @@


    private final DappHdRecordMapper dappHdRecordMapper;


    private final DataDictionaryCustomMapper dataDictionaryCustomMapper;


    private final AsyncCjService asyncCjService;


    private final DappMemberDao dappMemberDao;


    private final DappAchieveMapper dappAchieveMapper;




    @Override


    public IPage<PlatformBanner> findPlatformBannerInPage(PlatformBanner platformBannerEntity,


@@ -126,4 +126,28 @@


        IPage<DappHdRecord> dappHdRecordIPage = dappHdRecordMapper.findHdRecordInPage(page, dappHdRecord);


        return dappHdRecordIPage;


    }




    @Override


    public IPage<DappMemberEntity> inviteList(DappMemberEntity dappMemberEntity, QueryRequest request) {


        Page<DappMemberEntity> page = new Page<>(request.getPageNum(), request.getPageSize());


        IPage<DappMemberEntity> dappMemberEntityIPage = dappMemberDao.findInviteListInPage(page, dappMemberEntity);


        List<DappMemberEntity> records = dappMemberEntityIPage.getRecords();


        if(CollUtil.isNotEmpty(records)){


            for(DappMemberEntity memberEntity : records){


                DappMemberEntity refererMember = dappMemberDao.selectMemberInfoByInviteId(memberEntity.getRefererId());


                if(ObjectUtil.isNotEmpty(refererMember)){


                    memberEntity.setRefererAddress(refererMember.getAddress());


                }


                QueryWrapper<DappAchieve> objectQueryWrapper = new QueryWrapper<>();


                objectQueryWrapper.eq("member_id",memberEntity.getId());


                objectQueryWrapper.eq("state",1);


                List<DappAchieve> dappAchieves = dappAchieveMapper.selectList(objectQueryWrapper);


                if(CollUtil.isNotEmpty(dappAchieves)){


                    BigDecimal teamAchieveMemberSum = dappAchieves.stream().map(DappAchieve::getAmount).reduce(BigDecimal.ZERO, BigDecimal::add);


                    memberEntity.setZhiYaAmount(teamAchieveMemberSum);


                }


            }


        }


        return dappMemberEntityIPage;


    }


}