blame | history | patch | commit | commitdiff | ignore whitespace
KKSU
2024-04-29 0a22a881f09abd830fd0c8c7cb094e3ea23796a5 
 src/main/java/cc/mrbird/febs/dapp/service/impl/AdminBannerServiceImpl.java


@@ -3,16 +3,22 @@


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


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


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


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.common.enumerates.FlowTypeEnum;


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


import cc.mrbird.febs.common.utils.RedisUtils;


import cc.mrbird.febs.dapp.dto.TransferDto;


import cc.mrbird.febs.dapp.dto.ZhiyaAddDto;


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.DappWalletService;


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;


@@ -24,6 +30,7 @@


import javax.validation.Valid;


import javax.validation.constraints.NotNull;


import java.math.BigDecimal;


import java.util.List;




@Slf4j


@Service


@@ -36,6 +43,11 @@


    private final DappHdRecordMapper dappHdRecordMapper;


    private final DataDictionaryCustomMapper dataDictionaryCustomMapper;


    private final AsyncCjService asyncCjService;


    private final DappMemberDao dappMemberDao;


    private final DappAchieveMapper dappAchieveMapper;


    private final DappWalletService dappWalletService;


    private final DappFundFlowDao dappFundFlowDao;


    private final RedisUtils redisUtils;




    @Override


    public IPage<PlatformBanner> findPlatformBannerInPage(PlatformBanner platformBannerEntity,


@@ -108,8 +120,98 @@




    @Override


    public IPage<DappHdRecord> findHdRecordInPage(DappHdRecord dappHdRecord, QueryRequest request) {


        String startTime = dappHdRecord.getStartTime();


        String endTime = dappHdRecord.getEndTime();


        if(StrUtil.isNotBlank(startTime) && StrUtil.isNotBlank(endTime)){


            DateTime dateStartTime= DateUtil.parseDate(startTime);


            DateTime dateEndTime = DateUtil.parseDate(endTime);


            int compare = DateUtil.compare(dateStartTime, dateEndTime);


            if(compare >= 0){


                throw new FebsException("请输入正确的开始时间和结束时间");


            }


        }


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


        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(item-> item.getAmount().multiply(item.getPrice())).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2,BigDecimal.ROUND_DOWN);


                    memberEntity.setZhiYaAmount(teamAchieveMemberSum);


                }


            }


        }


        return dappMemberEntityIPage;


    }




    @Override


    public FebsResponse zhiyaAdd(ZhiyaAddDto zhiyaAddDto) {


        String address = zhiyaAddDto.getAddress();


        String hash = zhiyaAddDto.getZyHash();


        BigDecimal amount = new BigDecimal(zhiyaAddDto.getAmount()).setScale(2,BigDecimal.ROUND_DOWN);




        DappMemberEntity dappMemberEntity = dappMemberDao.selectByAddress(address, null);


        if(ObjectUtil.isEmpty(dappMemberEntity)){


            throw new FebsException("地址不存在");


        }


        if(BigDecimal.ZERO.compareTo(amount) >= 0){


            throw new FebsException("金额不正确");


        }




        QueryWrapper<DappFundFlowEntity> queryWrapper = new QueryWrapper<>();


        queryWrapper.eq("from_hash",hash);


        List<DappFundFlowEntity> dappFundFlowEntities = dappFundFlowDao.selectList(queryWrapper);


        if(CollUtil.isNotEmpty(dappFundFlowEntities)){


            throw new FebsException("HASH已经产生了质押记录");


        }




        DappFundFlowEntity fundFlow = new DappFundFlowEntity(


                dappMemberEntity.getId(),


                amount.negate(),


                FlowTypeEnum.ZHI_YA.getValue(),


                DappFundFlowEntity.WITHDRAW_STATUS_ING,


                BigDecimal.ZERO,


                null);


        dappFundFlowDao.insert(fundFlow);




        fundFlow.setFromHash(hash);


        fundFlow.setStatus(DappFundFlowEntity.WITHDRAW_STATUS_AGREE);


        fundFlow.setContent(FlowTypeEnum.ZHI_YA.getDescrition());


        dappFundFlowDao.updateById(fundFlow);




        //用户质押代币数量


        Long memberId = fundFlow.getMemberId();


        //新增一条用户质押记录


        DappAchieve dappAchieve = new DappAchieve();


        dappAchieve.setMemberId(memberId);


        dappAchieve.setAmount(amount);


        BigDecimal achieveReleasePercent = new BigDecimal("0.01").multiply(


                new BigDecimal(redisUtils.getString(DataDicEnum.GFA_ACHIEVE_RELEASE.getValue())).setScale(2,BigDecimal.ROUND_DOWN)


        );


        DappHdRecord dappHdRecord = dappHdRecordMapper.selectNewRecord();


        dappAchieve.setPrice(dappHdRecord.getPrice());


        dappAchieve.setAmountDay(achieveReleasePercent.multiply(amount).setScale(2,BigDecimal.ROUND_DOWN));


        BigDecimal achieveOut = new BigDecimal(redisUtils.getString(DataDicEnum.GFA_ACHIEVE_OUT.getValue())).setScale(2,BigDecimal.ROUND_DOWN);


        dappAchieve.setAmountMax(achieveOut.multiply(amount).setScale(2,BigDecimal.ROUND_DOWN));


        dappAchieve.setState(DappAchieve.STATUS_ING);


        dappAchieve.setAmountDone(BigDecimal.ZERO);


        dappAchieveMapper.insert(dappAchieve);


        asyncCjService.insertTeamPerk(fundFlow.getId(), dappAchieve.getId());


        return new FebsResponse().success();


    }


}