blame | 历史 | 补丁 | 提交 | 提交对比 | 显示空白
gongzuming
2024-09-02 a92e296c28d4c09055f53293378da001117ec979 
 src/main/java/com/mzl/flower/service/impl/coupon/CouponRecordServiceImpl.java


@@ -1,5 +1,6 @@


package com.mzl.flower.service.impl.coupon;




import cn.hutool.core.util.IdUtil;


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


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


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


@@ -16,10 +17,13 @@


import com.mzl.flower.mapper.customer.CustomerMapper;


import com.mzl.flower.service.coupon.CouponRecordService;


import com.mzl.flower.service.coupon.CouponTemplateService2;


import com.mzl.flower.service.customer.CustomerService;


import com.mzl.flower.service.system.UserService;


import lombok.extern.slf4j.Slf4j;


import org.apache.commons.collections4.CollectionUtils;


import org.apache.commons.lang3.StringUtils;


import org.redisson.api.RLock;


import org.redisson.api.RedissonClient;


import org.springframework.beans.BeanUtils;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Service;


@@ -28,6 +32,7 @@


import java.time.LocalDateTime;


import java.time.temporal.TemporalAdjusters;


import java.util.List;


import java.util.concurrent.TimeUnit;


import java.util.stream.Collectors;




/**


@@ -54,26 +59,40 @@


    @Autowired


    private CustomerMapper customerMapper;




    @Autowired


    private CustomerService customerService;








    @Override


    public List<CouponRecordVO> getList(QueryCouponRecordDTO dto) {


        return couponRecordMapperCustom.getList(dto);


    }




    @Autowired


    RedissonClient redissonClient;




    private static final String COUPON_KEY="com:mzl:flower:service:impl:coupon:%s";




    @Transactional


    @Override


    public boolean createCouponRecord(CreateCouponRecordDTO dto) {




        // TODO 需要控制超领




        final Customer customer = customerMapper.selectById(dto.getCustomerId());


        if(null==customer){


            throw new ValidationException("商户信息不存在");


        }




        final CouponTemplateDO couponTemplateDO = couponTemplateService.getById(dto.getCouponId());


        if(couponTemplateDO==null){


            throw new ValidationException("优惠券不存在");


        }




        final Customer customer = customerMapper.selectById(dto.getCustomerId());


        if(null==customer){


            throw new ValidationException("商户信息不存在");


        }




        RLock lock = redissonClient.getLock(String.format(COUPON_KEY, couponTemplateDO.getId()));


        try {


            // 获取锁，最多等待 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())


@@ -168,6 +187,18 @@


        }




        return baseMapper.insert(couponRecordDO)>0;




                } finally {


                    lock.unlock();


                }


            }


        } catch (InterruptedException e) {


            Thread.currentThread().interrupt();


            // 处理异常


        }




        return false;




    }




    @Override


@@ -216,58 +247,60 @@


    @Override


    public boolean grantVipCouponRecordList() {




        // TODO 会员等级修改


//        try{


//            LocalDateTime now = LocalDateTime.now();


//            LocalDateTime firstDayStart = now.with(TemporalAdjusters.firstDayOfMonth()).withHour(0).withMinute(0).withSecond(0).withNano(0);


//            LocalDateTime lastDayEnd = now.with(TemporalAdjusters.lastDayOfMonth()).withHour(23).withMinute(59).withSecond(59).withNano(0);


//


//            // 获取所有会员模版列表


//            List<CouponTemplateDO> vipTemplateList= couponTemplateService.getVipCouponTemplate();


//


//            // 遍历所有相同等级用户信息，并根据优惠券设置的规则构造优惠券


//            final List<CouponTemplateDO> updateCouponTemplateList = vipTemplateList.stream().map(couponTemplateDO -> {


//                final List<User> vipGradeUserList = userService.getVipGradeUserList(couponTemplateDO.getVipGrade());


//                final List<CouponRecordDO> gradeCouponRecordList = vipGradeUserList.stream().map(user -> {


//                    CouponRecordDO couponRecordDO = new CouponRecordDO();


//                    BeanUtils.copyProperties(couponTemplateDO, couponRecordDO);


//                    couponRecordDO.setId(IdUtil.simpleUUID());


//                    couponRecordDO.setCouponId(couponTemplateDO.getId());


//                    couponRecordDO.setUserId(user.getId());


//                    couponRecordDO.setStatus(CouponUsedStatusEnum.UNUSED.getType());


//                    couponRecordDO.setEffectiveStart(firstDayStart);


//                    couponRecordDO.setEffectiveEnd(lastDayEnd);


//


//                    // 创建信息


//                    couponRecordDO.create();


//                    return couponRecordDO;


//                }).collect(Collectors.toList());


//


//                // 批量保存等级下的优惠券信息


//                saveBatch(gradeCouponRecordList);


//


//                couponTemplateDO.setUsageStartDate(firstDayStart);


//                couponTemplateDO.setUsageEndDate(lastDayEnd);


//                couponTemplateDO.setGetStartDate(firstDayStart);


//                couponTemplateDO.setGetEndDate(lastDayEnd);


//


//                // 设置默认类型固定


//                couponTemplateDO.setUsageType(CouponUsageTypeEnum.FIXED.getType());


//


//                return couponTemplateDO;


//


//            }).collect(Collectors.toList());


//


//            // 批量更新原模版时间


//            couponTemplateService.updateBatchById(updateCouponTemplateList);


//


//            return true;


//        }catch (Exception e){


//            // 报错日志信息报错


//            log.error(e.getMessage());


//            return false;


//        }


        try{


            LocalDateTime now = LocalDateTime.now();


            LocalDateTime firstDayStart = now.with(TemporalAdjusters.firstDayOfMonth()).withHour(0).withMinute(0).withSecond(0).withNano(0);


            LocalDateTime lastDayEnd = now.with(TemporalAdjusters.lastDayOfMonth()).withHour(23).withMinute(59).withSecond(59).withNano(0);




            // 获取所有会员模版列表


            List<CouponTemplateDO> vipTemplateList= couponTemplateService.getVipCouponTemplate();




            // 遍历所有相同等级用户信息，并根据优惠券设置的规则构造优惠券


            final List<CouponTemplateDO> updateCouponTemplateList = vipTemplateList.stream().map(couponTemplateDO -> {


                // 获取当前等级下的所有用户


                final List<Customer> customerList = customerService.getCustomerListByLevelId(couponTemplateDO.getMemberId());




                final List<CouponRecordDO> gradeCouponRecordList = customerList.stream().map(customer -> {


                    CouponRecordDO couponRecordDO = new CouponRecordDO();


                    BeanUtils.copyProperties(couponTemplateDO, couponRecordDO);


                    couponRecordDO.setId(IdUtil.simpleUUID());


                    couponRecordDO.setCouponId(couponTemplateDO.getId());


                    couponRecordDO.setUserId(customer.getUserId());


                    couponRecordDO.setCustomerId(customer.getId());


                    couponRecordDO.setStatus(CouponUsedStatusEnum.UNUSED.getType());


                    couponRecordDO.setEffectiveStart(firstDayStart);


                    couponRecordDO.setEffectiveEnd(lastDayEnd);


                    couponRecordDO.setMemberId(couponTemplateDO.getMemberId());




                    // 创建信息


                    couponRecordDO.create();


                    return couponRecordDO;


                }).collect(Collectors.toList());




                // 批量保存等级下的优惠券信息


                saveBatch(gradeCouponRecordList);




                couponTemplateDO.setUsageStartDate(firstDayStart);


                couponTemplateDO.setUsageEndDate(lastDayEnd);


                couponTemplateDO.setGetStartDate(firstDayStart);


                couponTemplateDO.setGetEndDate(lastDayEnd);




                // 设置默认类型固定


                couponTemplateDO.setUsageType(CouponUsageTypeEnum.FIXED.getType());




                return couponTemplateDO;




            }).collect(Collectors.toList());




            // 批量更新原模版时间


            couponTemplateService.updateBatchById(updateCouponTemplateList);




            return true;


        }catch (Exception e){


            // 报错日志信息报错


            log.error(e.getMessage());


        return false;


        }


    }




    @Override


@@ -350,6 +383,16 @@




    @Override


    public List<CouponRecordVO> getMineCouponRecordList(QueryMineCouponRecordDTO dto) {


        checkCouponExpired(dto);


        return couponRecordMapperCustom.getMineCouponRecordList(dto);


    }




    @Override


    public void checkCouponExpired(QueryMineCouponRecordDTO dto) {


        if(StringUtils.isBlank(dto.getUserId())){


            dto.setUserId(SecurityUtils.getUserId());


        }


        // 将未使用的优惠券直接过期


        couponRecordMapperCustom.checkCouponExpired(dto);


    }


}