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; import com.mzl.flower.config.exception.ValidationException; import com.mzl.flower.config.security.SecurityUtils; import com.mzl.flower.dto.request.coupon.CreateCouponRecordDTO; import com.mzl.flower.dto.request.coupon.QueryCouponRecordDTO; import com.mzl.flower.dto.request.coupon.QueryCouponStatisticsBO; import com.mzl.flower.dto.request.coupon.QueryExistCouponDTO; import com.mzl.flower.dto.response.coupon.CouponRecordVO; import com.mzl.flower.entity.coupon.CouponRecordDO; import com.mzl.flower.entity.coupon.CouponTemplateDO; import com.mzl.flower.entity.customer.Customer; import com.mzl.flower.entity.system.User; import com.mzl.flower.enums.*; import com.mzl.flower.mapper.coupon.CouponRecordMapper; import com.mzl.flower.mapper.coupon.CouponRecordMapperCustom; 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.system.UserService; import lombok.extern.slf4j.Slf4j; import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.time.LocalDateTime; import java.time.temporal.TemporalAdjusters; import java.util.List; import java.util.stream.Collectors; /** *

* 服务实现类 *

* * @author @TaoJie * @since 2024-08-27 */ @Slf4j @Service public class CouponRecordServiceImpl extends ServiceImpl implements CouponRecordService { @Autowired private CouponRecordMapperCustom couponRecordMapperCustom; @Autowired private CouponTemplateService2 couponTemplateService; @Autowired private UserService userService; @Autowired private CustomerMapper customerMapper; @Override public List getList(QueryCouponRecordDTO dto) { return couponRecordMapperCustom.getList(dto); } @Override public boolean createCouponRecord(CreateCouponRecordDTO dto) { final Customer customer = customerMapper.selectById(dto.getCustomerId()); if(null==customer){ throw new ValidationException("商户信息不存在"); } final CouponTemplateDO couponTemplateDO = couponTemplateService.getById(dto.getCouponId()); // TODO 活动优惠券和积分优惠券需要根据库存来控制- 根据优惠券的发放数量来控制有没有超发 // TODO 根据用户领取设置的getLimit 查看当前用户是否已经超领优惠券 CouponRecordDO couponRecordDO=new CouponRecordDO(); BeanUtils.copyProperties(dto,couponRecordDO); couponRecordDO.create(SecurityUtils.getUserId()); // 设置为待使用状态 couponRecordDO.setStatus(CouponUsedStatusEnum.UNUSED.getType()); // 根据商户设置用户id if(StringUtils.isBlank(dto.getUserId()) && StringUtils.isNotBlank(customer.getUserId())){ couponRecordDO.setUserId(customer.getUserId()); } // 优惠券字段冗余 if(null!=couponTemplateDO){ couponRecordDO.setCategory(couponTemplateDO.getGetUserType()); couponRecordDO.setCouponCode(couponTemplateDO.getCouponCode()); couponRecordDO.setCouponName(couponTemplateDO.getCouponName()); couponRecordDO.setCouponDiscountValue(couponTemplateDO.getCouponDiscountValue()); couponRecordDO.setMinOrderAmount(couponTemplateDO.getMinOrderAmount()); couponRecordDO.setGetType(couponTemplateDO.getGetType()); couponRecordDO.setCouponDiscountType(couponTemplateDO.getCouponDiscountType()); couponRecordDO.setGetUserType(couponTemplateDO.getGetUserType()); couponRecordDO.setPoint(couponTemplateDO.getPoint()); // 根据优惠券模板来计算优惠券的生效开始时间和结束时间 if(StringUtils.isNotBlank(couponTemplateDO.getCategory()) && couponTemplateDO.getCategory().equals(CouponCategoryEnum.MEMBER.getStatus())){ // 如果是会员优惠券的话,则设置为优惠券的使用条件为优惠券的时间 couponRecordDO.setEffectiveStart(couponTemplateDO.getUsageStartDate()); couponRecordDO.setEffectiveEnd(couponTemplateDO.getUsageEndDate()); }else{ // 非会员的根据领取时间类型来计算优惠券的时间 if(StringUtils.isNotBlank(couponTemplateDO.getUsageType()) && couponTemplateDO.getUsageType().equals(CouponUsageTypeEnum.GET.getType())){ // 与领取时间一致 couponRecordDO.setEffectiveStart(couponTemplateDO.getGetStartDate()); couponRecordDO.setEffectiveEnd(couponTemplateDO.getGetEndDate()); } if(StringUtils.isNotBlank(couponTemplateDO.getUsageType()) && couponTemplateDO.getUsageType().equals(CouponUsageTypeEnum.FIXED.getType())){ // 固定时间 couponRecordDO.setEffectiveStart(couponTemplateDO.getUsageStartDate()); couponRecordDO.setEffectiveEnd(couponTemplateDO.getUsageEndDate()); } if(StringUtils.isNotBlank(couponTemplateDO.getUsageType()) && couponTemplateDO.getUsageType().equals(CouponUsageTypeEnum.GET_AFTER_TIME.getType())){ // 领取后有段时间 领取后有效时间 // 根据发放后有效期来设置时间 if (couponTemplateDO.getUsageTimeNum() == null || couponTemplateDO.getUsageTimeNum() <= 0) { throw new IllegalArgumentException("使用时间数量必须为正整数"); } LocalDateTime currentTime = LocalDateTime.now(); couponRecordDO.setEffectiveStart(currentTime); if (couponTemplateDO.getUsageTimeType().equals(CouponUsageTimeTypeEnum.DAY.getType())) { // 天 couponRecordDO.setEffectiveEnd(currentTime.plusDays(couponTemplateDO.getUsageTimeNum())); } if (couponTemplateDO.getUsageTimeType().equals(CouponUsageTimeTypeEnum.HOUR.getType())) { // 小时 couponRecordDO.setEffectiveEnd(currentTime.plusHours(couponTemplateDO.getUsageTimeNum())); } if (couponTemplateDO.getUsageTimeType().equals(CouponUsageTimeTypeEnum.MINUTE.getType())) { // 分钟 couponRecordDO.setEffectiveEnd(currentTime.plusMinutes(couponTemplateDO.getUsageTimeNum())); } } } } return baseMapper.insert(couponRecordDO)>0; } @Override public boolean updateCouponRecord(CreateCouponRecordDTO dto) { CouponRecordDO couponRecordDO=baseMapper.selectById(dto.getId()); BeanUtils.copyProperties(dto,couponRecordDO); couponRecordDO.update(SecurityUtils.getUserId()); // 优惠券字段冗余 final CouponTemplateDO couponTemplateDO = couponTemplateService.getById(dto.getCouponId()); if(null!=couponTemplateDO){ couponRecordDO.setCategory(couponTemplateDO.getGetUserType()); couponRecordDO.setCouponCode(couponTemplateDO.getCouponCode()); couponRecordDO.setCouponName(couponTemplateDO.getCouponName()); couponRecordDO.setCouponDiscountValue(couponTemplateDO.getCouponDiscountValue()); couponRecordDO.setMinOrderAmount(couponTemplateDO.getMinOrderAmount()); } return baseMapper.updateById(couponRecordDO)>0; } @Override public boolean deleteCouponRecord(String id) { return baseMapper.deleteById(id)>0; } @Override public CouponRecordVO getCouponRecordById(String id) { QueryCouponRecordDTO dto=new QueryCouponRecordDTO(); dto.setId(id); final List list = couponRecordMapperCustom.getList(dto); if(CollectionUtils.isNotEmpty(list)){ return list.get(0); } return null; } @Override public Page getPage(Page page, QueryCouponRecordDTO dto) { List result=couponRecordMapperCustom.getPage(page,dto); return page.setRecords(result); } @Transactional @Override public boolean grantVipCouponRecordList() { 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 vipTemplateList= couponTemplateService.getVipCouponTemplate(); // 遍历所有相同等级用户信息,并根据优惠券设置的规则构造优惠券 final List updateCouponTemplateList = vipTemplateList.stream().map(couponTemplateDO -> { final List vipGradeUserList = userService.getVipGradeUserList(couponTemplateDO.getVipGrade()); final List 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; } } @Override public boolean expiredCouponRecordByListCurMonth() { 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); // 只要找出时间小于当月的首天的设置成过期就可以 QueryWrapper queryWrapper=new QueryWrapper<>(); queryWrapper.lambda().eq(CouponRecordDO::getOrderId,"") .lt(CouponRecordDO::getEffectiveEnd,firstDayStart); final List couponRecordDOS = baseMapper.selectList(queryWrapper); final List expiredCouponRecordList = couponRecordDOS.stream().map(couponRecordDO -> { couponRecordDO.setStatus(CouponUsedStatusEnum.EXPIRED.getType()); return couponRecordDO; }).collect(Collectors.toList()); //更新 updateBatchById(expiredCouponRecordList); return true; }catch (Exception e){ log.error(e.getMessage()); return false; } } @Override public Integer statisCouponTemplateCount(QueryCouponStatisticsBO queryCouponStatisticsBO) { return couponRecordMapperCustom.statisCouponTemplateCount(queryCouponStatisticsBO); } @Override public Integer statisCouponTemplateCurMonCount(QueryCouponStatisticsBO queryCouponStatisticsBO) { return couponRecordMapperCustom.statisCouponTemplateCurMonCount(queryCouponStatisticsBO); } @Override public Integer statisCouponPointCurMonPontAmonut(QueryCouponStatisticsBO queryCouponStatisticsBO) { return couponRecordMapperCustom.statisCouponPointCurMonPointAmonut(queryCouponStatisticsBO); } @Override public int getExistCouponAmount(QueryExistCouponDTO dto) { QueryWrapper queryWrapper=new QueryWrapper<>(); queryWrapper.lambda().eq(CouponRecordDO::getDeleted, TrueOrFalseEnum.FALSE.isFlag()) .eq(StringUtils.isNotBlank(dto.getCouponId()), CouponRecordDO::getCouponId,dto.getCouponId()) .eq(StringUtils.isNotBlank(dto.getCustomerId()),CouponRecordDO::getCustomerId,dto.getCustomerId()) .eq(StringUtils.isNotBlank(dto.getCategory()),CouponRecordDO::getCategory,dto.getCategory()); return baseMapper.selectCount(queryWrapper); } }