add：会员等级筛选

cloudroam

2024-09-24 3b4ff9fba93ee13919f990ef8c2910a902a2a8f3

 src/main/java/com/mzl/flower/service/impl/coupon/CouponRecordServiceImpl.java

@@ -95,15 +95,29 @@
            // 获取锁，最多等待 10 秒，锁自动释放时间 30 秒
            if (lock.tryLock(10, 30, TimeUnit.SECONDS)) {
                try {
                    // 活动优惠券和积分优惠券需要根据库存来控制- 根据优惠券的发放数量来控制有没有超发
                    if(StringUtils.isNotBlank(couponTemplateDO.getCategory()) && (
                            couponTemplateDO.getCategory().equals(CouponCategoryEnum.ACTIVITY.getStatus()) || couponTemplateDO.getCategory().equals(CouponCategoryEnum.POINT.getStatus())
                    )){
                    // 活动优惠券 根据优惠券的发放数量来控制有没有超发
                    if(StringUtils.isNotBlank(couponTemplateDO.getCategory()) &&
                            couponTemplateDO.getCategory().equals(CouponCategoryEnum.ACTIVITY.getStatus())
                    ){
                        // 获取当前优惠券已经领取的数量
                        final Integer gainTotal = getExistGainCouponRecordAmountById(couponTemplateDO.getId());
                        if(couponTemplateDO.getCouponAmount().compareTo(gainTotal)<=0){
                            throw new ValidationException("当前优惠券已经领完！");
                        }
                    }
                    if(StringUtils.isNotBlank(couponTemplateDO.getCategory())
                            && couponTemplateDO.getCategory().equals(CouponCategoryEnum.POINT.getStatus()
                    )){
                        // 获取当前优惠券已经领取的数量

                        if(couponTemplateDO.getCouponAmount()<=0){
                            throw new ValidationException("当前优惠券已经领完！");
                        }else{
                            couponTemplateDO.setCouponAmount(couponTemplateDO.getCouponAmount()-1);
                            // 更新库存
                            couponTemplateService.updateById(couponTemplateDO);
                        }

                    }

                    // 根据用户领取设置的getLimit 查看当前用户是否已经超领优惠券
@@ -144,7 +158,8 @@
                    couponRecordDO.setCouponDiscountType(couponTemplateDO.getCouponDiscountType());
                    couponRecordDO.setGetUserType(couponTemplateDO.getGetUserType());
                    couponRecordDO.setPoint(couponTemplateDO.getPoint());
                    couponRecordDO.setMemberId(couponRecordDO.getMemberId());
                    couponRecordDO.setMemberId(couponTemplateDO.getMemberId());
                    couponRecordDO.setImageUrl(couponTemplateDO.getImageUrl());


                    // 根据优惠券模板来计算优惠券的生效开始时间和结束时间
@@ -276,6 +291,7 @@
                    couponRecordDO.setEffectiveStart(firstDayStart);
                    couponRecordDO.setEffectiveEnd(lastDayEnd);
                    couponRecordDO.setMemberId(couponTemplateDO.getMemberId());
                    couponRecordDO.setImageUrl(couponTemplateDO.getImageUrl());
                    // 创建信息
                    couponRecordDO.create();
                    if(!checkCurMonVipCouponExists(couponRecordDO.getCouponId(),couponRecordDO.getCustomerId(),firstDayStart,lastDayEnd)){
@@ -390,6 +406,17 @@
                .eq(StringUtils.isNotBlank(couponId), CouponRecordDO::getCouponId,couponId)
                .eq(null!=customerId,CouponRecordDO::getCustomerId,customerId)
                ;

        return baseMapper.selectCount(queryWrapper);
    }

    @Override
    public Integer getUserGainCouponRecordAmountByUserId(String couponId, String userId) {
        QueryWrapper<CouponRecordDO> queryWrapper=new QueryWrapper<>();
        queryWrapper.lambda().eq(CouponRecordDO::getDeleted, TrueOrFalseEnum.FALSE.isFlag())
                .eq(StringUtils.isNotBlank(couponId), CouponRecordDO::getCouponId,couponId)
                .eq(null!=userId,CouponRecordDO::getUserId,userId)
        ;

        return baseMapper.selectCount(queryWrapper);
    }
@@ -536,4 +563,10 @@
        ;
        return baseMapper.selectCount(queryWrapper)>0;
    }

    @Override
    public boolean expireCouponRecordAll() {

        return couponRecordMapperCustom.expireCouponRecordAll();
    }
}