package com.ruoyi.member.service.impl.coupon;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.ruoyi.member.domain.pojo.coupon.Coupon;
|
import com.ruoyi.member.domain.pojo.coupon.CouponTotal;
|
import com.ruoyi.member.domain.pojo.coupon.MemberCouponRecord;
|
import com.ruoyi.member.mapper.coupon.MemberCouponRecordMapper;
|
import com.ruoyi.member.service.coupon.CouponTotalService;
|
import com.ruoyi.member.service.coupon.MemberCouponRecordService;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
|
/**
|
* <p>
|
* 用户优惠券领取记录 服务实现类
|
* </p>
|
*
|
* @author jqs
|
* @since 2023-07-09
|
*/
|
@Service
|
public class MemberCouponRecordServiceImpl extends ServiceImpl<MemberCouponRecordMapper, MemberCouponRecord> implements MemberCouponRecordService {
|
|
|
@Resource
|
private CouponTotalService couponTotalService;
|
|
/**
|
* @description 获取用户优惠券领取记录
|
* @author jqs
|
* @date 2023/7/9 17:22
|
* @param couponId
|
* @param userId
|
* @return MemberCouponRecord
|
*/
|
@Override
|
public MemberCouponRecord getByCouponIdAndUserId(String couponId,Long userId){
|
LambdaQueryWrapper<MemberCouponRecord> queryWrapper = new LambdaQueryWrapper<>();
|
queryWrapper.eq(MemberCouponRecord::getCouponId,couponId);
|
queryWrapper.eq(MemberCouponRecord::getUserId,userId);
|
return this.getOne(queryWrapper,false);
|
}
|
|
/**
|
* @description 更新用户优惠券领取记录
|
* @author jqs
|
* @date 2023/7/9 17:20
|
* @param coupon
|
* @param userId
|
* @return void
|
*/
|
@Override
|
public void updateMemberCouponRecord(Coupon coupon, Long userId, Integer number) {
|
// 根据优惠券ID和用户ID获取会员优惠券记录
|
MemberCouponRecord memberCouponRecord = this.getByCouponIdAndUserId(coupon.getCouponId(), userId);
|
CouponTotal couponTotal = couponTotalService.getById(coupon.getCouponId());
|
if (memberCouponRecord != null) {
|
// 如果会员优惠券记录存在，则更新数量
|
memberCouponRecord.setNum(memberCouponRecord.getNum() + number);
|
// 设置限制数量
|
if (coupon.getLimitNumber() > 0) {
|
memberCouponRecord.setLimitNum(coupon.getLimitNumber());
|
} else {
|
memberCouponRecord.setLimitNum(99999);
|
}
|
// 如果数量达到限制数量，则设置限制标志为1
|
if (memberCouponRecord.getNum()>=memberCouponRecord.getLimitNum()) {
|
memberCouponRecord.setLimitFlag(1);
|
} else {
|
memberCouponRecord.setLimitFlag(0);
|
}
|
} else {
|
// 如果会员优惠券记录不存在，则创建新的记录
|
memberCouponRecord = new MemberCouponRecord();
|
memberCouponRecord.setCouponId(coupon.getCouponId());
|
memberCouponRecord.setUserId(userId);
|
memberCouponRecord.setNum(number);
|
// 设置限制数量
|
if (coupon.getLimitNumber() > 0) {
|
memberCouponRecord.setLimitNum(coupon.getLimitNumber());
|
} else {
|
memberCouponRecord.setLimitNum(99999);
|
}
|
// 根据数量是否达到限制数量设置限制标志
|
if (memberCouponRecord.getNum()>=memberCouponRecord.getLimitNum()) {
|
memberCouponRecord.setLimitFlag(1);
|
} else {
|
memberCouponRecord.setLimitFlag(0);
|
}
|
couponTotal.setSendUserCount(couponTotal.getSendUserCount()+1);
|
}
|
// 保存或更新会员优惠券记录
|
this.saveOrUpdate(memberCouponRecord);
|
couponTotal.setSendCount(couponTotal.getSendCount()+number);
|
couponTotalService.saveOrUpdate(couponTotal);
|
}
|
}
|
