直推奖励，冻结的用户，则直推奖励销毁，用户未冻结才能领取成功

KKSU

2023-12-27 165a67bdad4c4ca98c284dd831584d36209fa8ea

 src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java

@@ -64,6 +64,7 @@
    private final MallProductSellRecordMapper mallProductSellRecordMapper;
    private final MallProductNftMapper mallProductNftMapper;
    private final AgentProducer agentProducer;
    private final MallMemberAmountMapper mallMemberAmountMapper;

    @Override
    @Transactional(rollbackFor = Exception.class)
@@ -850,7 +851,7 @@
                //偏移时间
                DateTime dateTime = DateUtil.offsetDay(payTime, cycle);
                int compare = DateUtil.compare(now, dateTime);
                if(compare <= 0){
                if(compare >= 0){
                    /**
                     * 更新买单状态
                     * 收益生成一条卖单
@@ -862,6 +863,47 @@
                    insertSell(mallProductBuy.getMemberId(),nftTotal,nftTotal,BigDecimal.ZERO,BigDecimal.ZERO);
                    BigDecimal profit = nftTotal.multiply(profitPercent.multiply(new BigDecimal(0.01)));
                    insertSell(mallProductBuy.getMemberId(),profit,profit,BigDecimal.ZERO,BigDecimal.ZERO);

                    /**
                     * 更新用户上级收益，冻结7天，7天时间到期自动释放到动态钱包
                     */
                    Long memberId = mallProductBuy.getMemberId();
                    MallMember mallMember = memberMapper.selectById(memberId);
                    if(ObjectUtil.isNotEmpty(mallMember)){
                        //直推
                        String referrerId = mallMember.getReferrerId();
                        MallMember directMember = memberMapper.selectInfoByInviteId(referrerId);
                        if(ObjectUtil.isNotEmpty(directMember)){
                            BigDecimal basicPerkDirectPercent = new BigDecimal(dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                                    DataDictionaryEnum.BASIC_PERK_DIRECT.getType(),
                                    DataDictionaryEnum.BASIC_PERK_DIRECT.getCode()
                            ).getValue()).multiply(new BigDecimal("0.01"));
                            BigDecimal basicPerkDirect = profit.multiply(basicPerkDirectPercent).setScale(2, BigDecimal.ROUND_DOWN);
                            /**
                             * 先插入流水记录，然后定时器每小时，循环一次找寻对应的数据执行
                             */
                            String frozenDays = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                                    DataDictionaryEnum.BASIC_PERK_DIRECT_FROZEN.getType(),
                                    DataDictionaryEnum.BASIC_PERK_DIRECT_FROZEN.getCode()
                            ).getValue();
                            String orderNo = MallUtils.getOrderNum("FNFT");
                            mallMoneyFlowService.addMoneyFlow(
                                    directMember.getId(),
                                    basicPerkDirect,
                                    MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT.getValue(),
                                    orderNo,
                                    null,
                                    FlowTypeNewEnum.NFT.getValue(),
                                    MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT.getDescrition(),
                                    AppContants.MEMBER_FLOW_ING);

                            MallMemberAmount mallMemberAmountDirect = mallMemberAmountMapper.selectByMemberId(directMember.getId());
                            mallMemberAmountDirect.setFrozenNft(mallMemberAmountDirect.getFrozenNft().add(basicPerkDirect));
                            mallMemberAmountMapper.updateFrozenNftById(mallMemberAmountDirect);
                        }


                    }
                }
            }
        }
@@ -933,7 +975,8 @@
         * 当前时间比结束时间大
         */
        if(nowTime.compareTo(endTime) >= 0){
            List<MallProductSellRecord> mallProductSellRecords = mallProductSellRecordMapper.selectListByState(ProductEnum.PRODUCT_MATE_STATE_PAY.getValue());
            List<MallProductSellRecord> mallProductSellRecords = mallProductSellRecordMapper.selectListByState(
                    ProductEnum.PRODUCT_MATE_STATE_PAY.getValue());
            if(CollUtil.isNotEmpty(mallProductSellRecords)){
                for(MallProductSellRecord mallProductSellRecord : mallProductSellRecords){
                    /**
@@ -946,6 +989,136 @@
                    mallMember.setIsFrozen(ProductEnum.MEMBER_FROZEN.getValue());
                    memberMapper.updateById(mallMember);
                }
            }
        }
    }

    @Override
    public void timeGetOrderBuyCancel() {
        /**
         * nft产品周期到期的已完成买单变成卖单
         * 计算收益，本金
         */
        List<MallProductNft> mallProductNfts = mallProductNftMapper.selectList(null);
        if(CollUtil.isEmpty(mallProductNfts)){
            return;
        }
        DateTime nowTime = DateUtil.parseTime(DateUtil.formatTime(DateUtil.date()));
        DataDictionaryCustom endTimeDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                DataDictionaryEnum.YU_YUE_END_TIME.getType(),
                DataDictionaryEnum.YU_YUE_END_TIME.getCode()
        );
        DateTime endTime = DateUtil.parseTime(endTimeDic.getValue());
        for(MallProductNft mallProductNft : mallProductNfts){
            Long nftId = mallProductNft.getId();
            List<MallProductBuy> mallProductBuys = mallProductBuyMapper.selectListByStateAndProductNFTId(
                    ProductEnum.PRODUCT_BUY_ON_GOING.getValue(),
                    nftId,
                    ProductEnum.PRODUCT_BUY_MATE_STATE_FAIL.getValue());
            if(CollUtil.isEmpty(mallProductBuys)){
                continue;
            }
            for(MallProductBuy mallProductBuy : mallProductBuys){
                /**
                 * 当前时间比结束时间大
                 */
                if(nowTime.compareTo(endTime) >= 0){
                    /**
                     * 返回令牌
                     * 预约记录超时
                     */
                    String orderNo = mallProductBuy.getOrderNo();
                    /**
                     * 只要存在匹配记录，则不退回。
                     */
                    List<MallProductBuyRecord> mallProductBuyRecords = mallProductBuyRecordMapper.selectRecordListByBuyId(mallProductBuy.getId());
                    if(CollUtil.isNotEmpty(mallProductBuyRecords)){
                        continue;
                    }
                    mallProductBuy.setState(ProductEnum.PRODUCT_BUY_TIMEOUT.getValue());
                    mallProductBuyMapper.updateById(mallProductBuy);

                    Long memberId = mallProductBuy.getMemberId();
                    MallMoneyFlow mallMoneyFlow = mallMoneyFlowMapper.selectByOrderAndType(orderNo,
                            MoneyFlowTypeNewEnum.TOKEN_BUY_FROZEN.getValue(),
                            FlowTypeNewEnum.TOKEN.getValue(),
                            memberId);
                    if(ObjectUtil.isEmpty(mallMoneyFlow)){
                        continue;
                    }
                    BigDecimal absAmount = mallMoneyFlow.getAmount().abs();
                    MallMemberAmount mallMemberAmount = mallMemberAmountMapper.selectByMemberId(memberId);
                    mallMemberAmount.setTokenAva(mallMemberAmount.getTokenAva().add(absAmount));
                    mallMemberAmount.setTokenFrozen(mallMemberAmount.getTokenFrozen().subtract(absAmount));
                    mallMemberAmountMapper.updateTokenAvaAndTokenFrozenById(mallMemberAmount);

                    mallMoneyFlowService.addMoneyFlow(
                            memberId,
                            absAmount,
                            MoneyFlowTypeNewEnum.TOKEN_BUY_FROZEN_RETURN.getValue(),
                            orderNo,
                            null,
                            FlowTypeNewEnum.TOKEN.getValue(),
                            MoneyFlowTypeNewEnum.TOKEN_BUY_FROZEN_RETURN.getDescrition());


                }
            }
        }
    }

    @Override
    public void basicMemberPerk() {
        QueryWrapper<MallMoneyFlow> queryMallMoneyFlow = new QueryWrapper<>();
        queryMallMoneyFlow.eq("type",MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT.getValue());
        queryMallMoneyFlow.eq("is_return",AppContants.MEMBER_FLOW_ING);
        queryMallMoneyFlow.eq("flow_type",FlowTypeNewEnum.NFT.getValue());
        List<MallMoneyFlow> mallMoneyFlows = mallMoneyFlowMapper.selectList(queryMallMoneyFlow);
        if(CollUtil.isNotEmpty(mallMoneyFlows)){
            return;
        }
        for(MallMoneyFlow mallMoneyFlow : mallMoneyFlows){
            mallMoneyFlow.setIsReturn(AppContants.MEMBER_FLOW_DONE);
            mallMoneyFlowMapper.updateById(mallMoneyFlow);
            /**
             * 如果用户是冻结，则直接销毁
             */
            Long memberId = mallMoneyFlow.getMemberId();
            MallMember mallMember = memberMapper.selectById(memberId);
            Integer isFrozen = mallMember.getIsFrozen();
            if(ProductEnum.MEMBER_UNFROZEN.getValue() == isFrozen){
                MallMemberAmount mallMemberAmount = mallMemberAmountMapper.selectByMemberId(memberId);
                mallMemberAmount.setFrozenNft(mallMemberAmount.getFrozenNft().subtract(mallMoneyFlow.getAmount()));
                mallMemberAmountMapper.updateFrozenNftById(mallMemberAmount);
                //插入一条流水记录
                String orderNo = MallUtils.getOrderNum("FNFTW");
                mallMoneyFlowService.addMoneyFlow(
                        memberId,
                        mallMoneyFlow.getAmount().negate(),
                        MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_WRONG.getValue(),
                        orderNo,
                        null,
                        FlowTypeNewEnum.NFT.getValue(),
                        MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_WRONG.getDescrition(),
                        AppContants.MEMBER_FLOW_ING);

            }else {
                MallMemberAmount mallMemberAmount = mallMemberAmountMapper.selectByMemberId(memberId);
                mallMemberAmount.setFrozenNft(mallMemberAmount.getFrozenNft().subtract(mallMoneyFlow.getAmount()));
                mallMemberAmount.setTrendsNft(mallMemberAmount.getTrendsNft().add(mallMoneyFlow.getAmount()));
                mallMemberAmountMapper.updateTrendsNftAndFrozenNftById(mallMemberAmount);

                //插入一条流水记录
                String orderNo = MallUtils.getOrderNum("NFT");
                mallMoneyFlowService.addMoneyFlow(
                        memberId,
                        mallMoneyFlow.getAmount().negate(),
                        MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_DONE.getValue(),
                        orderNo,
                        null,
                        FlowTypeNewEnum.NFT.getValue(),
                        MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_DONE.getDescrition(),
                        AppContants.MEMBER_FLOW_DONE);
            }
        }
    }
@@ -965,4 +1138,41 @@
        mallProductSellMapper.insert(mallProductSell);
    }

    public static List<Integer> findMissingNumbers(int[] nums) {
        //定义一个标记数组，标记出现过的下表为true
        boolean[] flag = new boolean[nums.length+1];
        for(int temp:nums){
            flag[temp] = true;
        }
        List<Integer> arr = new ArrayList<Integer>();
        //以连续的i作为本应该的下标，查找之前的标记数组，没有被标记过的下标，就是消失的数字
        for(int i = 1;i <= nums.length; i++){
            if(!flag[i]){
                arr.add(i);
            }
        }
        return arr;
    }

    public static List<Integer> findDisappearedNumbers(int[] nums) {
        Set<Integer> set = new HashSet<>(); // 利用Set对象元素不重复的特性
        // 把nums里的每一个数字都添加至set中
        for(int i = 0; i < nums.length; ++i) {
            set.add(nums[i]);
        }
        List<Integer> list = new ArrayList<>();
        // 把1~n的每一个数字都添加至set中，若添加成功则说明原数组不存在该数字，加入list即可
        for(int i = 1; i <= nums.length; ++i) {
            if(set.add(i)) {
                list.add(i);
            }
        }
        return list;
    }
    public static void main(String[] args) {
        int[] nums = {1, 2, 2, 5, 2};
        List<Integer> missingNumbers = findDisappearedNumbers(nums);
        System.out.println("缺失的数字为：" + missingNumbers);
    }

}