package com.doumee.service.business.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.doumee.core.constants.Constants;
|
import com.doumee.core.constants.ResponseStatus;
|
import com.doumee.core.exception.BusinessException;
|
import com.doumee.core.model.LoginUserInfo;
|
import com.doumee.core.model.PageData;
|
import com.doumee.core.model.PageWrap;
|
import com.doumee.core.utils.Utils;
|
import com.doumee.dao.business.CouponMapper;
|
import com.doumee.dao.business.MemberCouponMapper;
|
import com.doumee.dao.business.model.Coupon;
|
import com.doumee.dao.business.model.MemberCoupon;
|
import com.doumee.dao.system.model.SystemUser;
|
import com.doumee.service.business.MemberCouponService;
|
import com.github.yulichang.wrapper.MPJLambdaWrapper;
|
import org.apache.shiro.SecurityUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.CollectionUtils;
|
|
import java.util.Calendar;
|
import java.util.Date;
|
import java.util.LinkedHashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Objects;
|
|
@Service
|
public class MemberCouponServiceImpl implements MemberCouponService {
|
|
@Autowired
|
private MemberCouponMapper memberCouponMapper;
|
@Autowired
|
private CouponMapper couponMapper;
|
|
@Override
|
@Transactional(rollbackFor = {Exception.class, BusinessException.class})
|
public Integer create(MemberCoupon memberCoupon) {
|
if (Objects.isNull(memberCoupon) || Objects.isNull(memberCoupon.getCouponId()) || Objects.isNull(memberCoupon.getMemberId())) {
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
memberCoupon.setIsdeleted(Constants.ZERO);
|
memberCoupon.setCreateDate(new Date());
|
memberCoupon.setCreator(loginUserInfo.getId());
|
memberCoupon.setEditDate(new Date());
|
memberCoupon.setEditor(loginUserInfo.getId());
|
memberCouponMapper.insert(memberCoupon);
|
return memberCoupon.getId();
|
}
|
|
@Override
|
public void deleteById(Integer id) {
|
memberCouponMapper.update(new UpdateWrapper<MemberCoupon>().lambda()
|
.set(MemberCoupon::getIsdeleted, Constants.ONE)
|
.eq(MemberCoupon::getId, id));
|
}
|
|
@Override
|
public void deleteByIdInBatch(List<Integer> ids) {
|
if (CollectionUtils.isEmpty(ids)) {
|
return;
|
}
|
for (Integer id : ids) {
|
this.deleteById(id);
|
}
|
}
|
|
@Override
|
@Transactional(rollbackFor = {Exception.class, BusinessException.class})
|
public void updateById(MemberCoupon memberCoupon) {
|
if (Objects.isNull(memberCoupon) || Objects.isNull(memberCoupon.getId())) {
|
throw new BusinessException(ResponseStatus.BAD_REQUEST);
|
}
|
LoginUserInfo loginUserInfo = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();
|
memberCoupon.setEditDate(new Date());
|
memberCoupon.setEditor(loginUserInfo.getId());
|
memberCouponMapper.updateById(memberCoupon);
|
}
|
|
@Override
|
public MemberCoupon findById(Integer id) {
|
MemberCoupon memberCoupon = memberCouponMapper.selectById(id);
|
if (Objects.isNull(memberCoupon)) {
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
return memberCoupon;
|
}
|
|
@Override
|
public List<MemberCoupon> findList(MemberCoupon memberCoupon) {
|
QueryWrapper<MemberCoupon> wrapper = new QueryWrapper<>(memberCoupon);
|
return memberCouponMapper.selectList(wrapper);
|
}
|
|
@Override
|
public PageData<MemberCoupon> findPage(PageWrap<MemberCoupon> pageWrap) {
|
IPage<MemberCoupon> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
|
MPJLambdaWrapper<MemberCoupon> queryWrapper = new MPJLambdaWrapper<>();
|
Utils.MP.blankToNull(pageWrap.getModel());
|
pageWrap.getModel().setIsdeleted(Constants.ZERO);
|
queryWrapper.selectAll(MemberCoupon.class)
|
.select("m.NAME AS MEMBER_NAME")
|
.select("m.TELEPHONE AS MEMBER_TELEPHONE")
|
.select("m.NICK_NAME AS MEMBER_NICK_NAME")
|
.leftJoin("member m ON m.ID = t.MEMBER_ID");
|
if (pageWrap.getModel().getId() != null) {
|
queryWrapper.eq(MemberCoupon::getId, pageWrap.getModel().getId());
|
}
|
if (pageWrap.getModel().getIsdeleted() != null) {
|
queryWrapper.eq(MemberCoupon::getIsdeleted, pageWrap.getModel().getIsdeleted());
|
}
|
if (pageWrap.getModel().getStatus() != null) {
|
queryWrapper.eq(MemberCoupon::getStatus, pageWrap.getModel().getStatus());
|
}
|
if (pageWrap.getModel().getCouponId() != null) {
|
queryWrapper.eq(MemberCoupon::getCouponId, pageWrap.getModel().getCouponId());
|
}
|
if (pageWrap.getModel().getMemberId() != null) {
|
queryWrapper.eq(MemberCoupon::getMemberId, pageWrap.getModel().getMemberId());
|
}
|
if (pageWrap.getModel().getOrderId() != null) {
|
queryWrapper.eq(MemberCoupon::getOrderId, pageWrap.getModel().getOrderId());
|
}
|
if (pageWrap.getModel().getType() != null) {
|
queryWrapper.eq(MemberCoupon::getType, pageWrap.getModel().getType());
|
}
|
if (pageWrap.getModel().getCouponType() != null) {
|
queryWrapper.eq(MemberCoupon::getCouponType, pageWrap.getModel().getCouponType());
|
}
|
if (pageWrap.getModel().getGetMethod() != null) {
|
queryWrapper.eq(MemberCoupon::getGetMethod, pageWrap.getModel().getGetMethod());
|
}
|
if (pageWrap.getModel().getName() != null) {
|
queryWrapper.like(MemberCoupon::getName, pageWrap.getModel().getName());
|
}
|
if (pageWrap.getModel().getCreateDate() != null) {
|
queryWrapper.ge(MemberCoupon::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate()));
|
queryWrapper.le(MemberCoupon::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate()));
|
}
|
queryWrapper.orderByDesc(MemberCoupon::getId);
|
return PageData.from(memberCouponMapper.selectJoinPage(page, MemberCoupon.class, queryWrapper));
|
}
|
|
@Override
|
public long count(MemberCoupon memberCoupon) {
|
QueryWrapper<MemberCoupon> wrapper = new QueryWrapper<>(memberCoupon);
|
return memberCouponMapper.selectCount(wrapper);
|
}
|
|
@Override
|
public PageData<MemberCoupon> findMemberPage(Integer memberId, Integer status, PageWrap<MemberCoupon> pageWrap) {
|
IPage<MemberCoupon> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
|
MPJLambdaWrapper<MemberCoupon> qw = new MPJLambdaWrapper<>();
|
qw.selectAll(MemberCoupon.class)
|
.eq(MemberCoupon::getMemberId, memberId)
|
.eq(MemberCoupon::getIsdeleted, Constants.ZERO);
|
|
if (status != null) {
|
if (status == Constants.CouponStatus.expired.getKey()) {
|
// 已失效包含两种：98=未领取已过期, 99=已过期
|
qw.in(MemberCoupon::getStatus,
|
Constants.CouponStatus.expiredUnclaimed.getKey(),
|
Constants.CouponStatus.expired.getKey());
|
} else {
|
qw.eq(MemberCoupon::getStatus, status);
|
}
|
}
|
|
// 按状态排序
|
if (status != null) {
|
switch (status) {
|
case 0: // 待领取 → 创建时间倒序
|
case 98: // 已失效(查询时包含了98和99)
|
case 99:
|
qw.orderByDesc(MemberCoupon::getCreateDate);
|
break;
|
case 1: // 待使用 → 领取时间倒序
|
qw.orderByDesc(MemberCoupon::getValidDate);
|
break;
|
case 2: // 已使用 → 使用时间倒序
|
qw.orderByDesc(MemberCoupon::getUseDate);
|
break;
|
default:
|
qw.orderByDesc(MemberCoupon::getId);
|
break;
|
}
|
} else {
|
qw.orderByDesc(MemberCoupon::getId);
|
}
|
|
return PageData.from(memberCouponMapper.selectJoinPage(page, MemberCoupon.class, qw));
|
}
|
|
@Override
|
public Map<String, Integer> findPendingCount(Integer memberId) {
|
Long waitClaim = memberCouponMapper.selectCount(new QueryWrapper<MemberCoupon>().lambda()
|
.eq(MemberCoupon::getMemberId, memberId)
|
.eq(MemberCoupon::getStatus, Constants.CouponStatus.waitClaim.getKey())
|
.eq(MemberCoupon::getIsdeleted, Constants.ZERO));
|
Long waitUse = memberCouponMapper.selectCount(new QueryWrapper<MemberCoupon>().lambda()
|
.eq(MemberCoupon::getMemberId, memberId)
|
.eq(MemberCoupon::getStatus, Constants.CouponStatus.claimed.getKey())
|
.eq(MemberCoupon::getIsdeleted, Constants.ZERO));
|
Map<String, Integer> result = new LinkedHashMap<>();
|
result.put("waitClaim", waitClaim != null ? waitClaim.intValue() : 0);
|
result.put("waitUse", waitUse != null ? waitUse.intValue() : 0);
|
return result;
|
}
|
|
@Override
|
@Transactional(rollbackFor = {Exception.class, BusinessException.class})
|
public void claimCoupon(Integer memberId, Integer couponId) {
|
// 查询该会员的待领取优惠券记录
|
MemberCoupon mc = memberCouponMapper.selectOne(new QueryWrapper<MemberCoupon>().lambda()
|
.eq(MemberCoupon::getId, couponId)
|
.eq(MemberCoupon::getMemberId, memberId)
|
.eq(MemberCoupon::getStatus, Constants.CouponStatus.waitClaim.getKey())
|
.eq(MemberCoupon::getIsdeleted, Constants.ZERO));
|
if (mc == null) {
|
throw new BusinessException(ResponseStatus.DATA_EMPTY);
|
}
|
// 标记已领取，计算有效期
|
Date now = new Date();
|
Calendar cal = Calendar.getInstance();
|
cal.setTime(now);
|
cal.add(Calendar.DAY_OF_MONTH, mc.getValidDays() != null ? mc.getValidDays() : 0);
|
memberCouponMapper.update(new UpdateWrapper<MemberCoupon>().lambda()
|
.set(MemberCoupon::getStatus, Constants.CouponStatus.claimed.getKey())
|
.set(MemberCoupon::getValidDate, now)
|
.set(MemberCoupon::getStartDate, now)
|
.set(MemberCoupon::getEndDate, cal.getTime())
|
.set(MemberCoupon::getEditDate, now)
|
.eq(MemberCoupon::getId, mc.getId()));
|
}
|
}
|
