package com.ruoyi.member.service.impl.member;
|
|
import com.baomidou.dynamic.datasource.annotation.DS;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.ruoyi.common.core.exception.ServiceException;
|
import com.ruoyi.common.core.utils.StringUtils;
|
import com.ruoyi.member.domain.dto.AppMemberCouponPageDto;
|
import com.ruoyi.member.domain.dto.MemberSelectCouponDto;
|
import com.ruoyi.member.domain.dto.MerGoodsCouponListDto;
|
import com.ruoyi.member.domain.vo.AppMemberCouponPageVo;
|
import com.ruoyi.member.mapper.member.MemberCouponMapper;
|
import com.ruoyi.member.service.member.MemberCouponService;
|
import com.ruoyi.system.api.constant.AppErrorConstant;
|
import com.ruoyi.system.api.domain.dto.MerBaseDto;
|
import com.ruoyi.system.api.domain.dto.MgtBaseBathDto;
|
import com.ruoyi.system.api.domain.poji.goods.Goods;
|
import com.ruoyi.system.api.domain.poji.member.Member;
|
import com.ruoyi.system.api.domain.poji.member.MemberCoupon;
|
import com.ruoyi.system.api.domain.vo.AppMemberCouponVo;
|
import com.ruoyi.system.api.domain.vo.MerMemberCouponVo;
|
import com.ruoyi.system.api.domain.vo.MerVerifyCouponGetVo;
|
import com.ruoyi.system.api.domain.vo.MgtSimpleShopVo;
|
import com.ruoyi.system.api.service.RemoteGoodsService;
|
import com.ruoyi.system.api.service.RemoteShopService;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Propagation;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.annotation.Resource;
|
import java.math.BigDecimal;
|
import java.util.*;
|
import java.util.function.Function;
|
import java.util.stream.Collectors;
|
|
/**
|
* <p>
|
* 用户关联优惠券 服务实现类
|
* </p>
|
*
|
* @author jqs
|
* @since 2023-04-25
|
*/
|
@Service
|
@DS("sharding")
|
public class MemberCouponServiceImpl extends ServiceImpl<MemberCouponMapper, MemberCoupon> implements MemberCouponService {
|
|
@Resource
|
private MemberCouponMapper memberCouponMapper;
|
|
@Resource
|
private RemoteGoodsService remoteGoodsService;
|
|
@Resource
|
private RemoteShopService remoteShopService;
|
|
|
/**
|
* @description: TODO
|
* @author jqs34
|
* @date 2023/5/3 1:47
|
* @version 1.0
|
*/
|
@Override
|
public List<AppMemberCouponVo> listVoMemberCouponByUserId(MerBaseDto merBaseDto){
|
List<AppMemberCouponVo> appMemberCouponVoList = memberCouponMapper.listVoMemberCouponByUserId(merBaseDto);
|
return appMemberCouponVoList;
|
}
|
|
/**
|
* @description 核销优惠券
|
* @author jqs
|
* @date 2023/6/26 17:02
|
* @param verifyCoupon
|
* @return void
|
*/
|
@Override
|
public MerVerifyCouponGetVo getVerifyCoupon(Long verifyCoupon){
|
MemberCoupon memberCoupon = this.getById(verifyCoupon);
|
// 检查是否存在该优惠券
|
if (memberCoupon == null) {
|
throw new ServiceException(AppErrorConstant.COUPON_NO_FIND);
|
}
|
// 检查优惠券状态
|
int couponStatus = memberCoupon.getCouponStatus();
|
if (couponStatus == 0) {
|
throw new ServiceException(AppErrorConstant.COUPON_EXPIRED);
|
} else if (couponStatus == 2) {
|
throw new ServiceException(AppErrorConstant.COUPON_USED);
|
} else if (couponStatus != 1) {
|
throw new ServiceException(AppErrorConstant.COUPON_NO_FIND);
|
}
|
// 检查优惠券类型
|
int couponType = memberCoupon.getCouponType();
|
if (couponType != 4) {
|
throw new ServiceException(AppErrorConstant.COUPON_TYPE_ERROR);
|
}
|
MerVerifyCouponGetVo merVerifyCouponGetVo = new MerVerifyCouponGetVo();
|
merVerifyCouponGetVo.setUserId(memberCoupon.getUserId());
|
String relGoodsIds = memberCoupon.getRelGoodsIds();
|
List<Goods> goodsList = remoteGoodsService.listGoodsByGoodsId(relGoodsIds).getData();
|
if (goodsList != null) {
|
merVerifyCouponGetVo.setGoodsList(goodsList);
|
}
|
merVerifyCouponGetVo.setMemberCouponId(memberCoupon.getId());
|
if (memberCoupon.getShopId()!=null&&memberCoupon.getShopId()>0) {
|
merVerifyCouponGetVo.setCouponFrom("商户");
|
} else {
|
merVerifyCouponGetVo.setCouponFrom("平台");
|
}
|
merVerifyCouponGetVo.setMemberCoupon(memberCoupon);
|
return merVerifyCouponGetVo;
|
}
|
|
/**
|
* @description 核销优惠券
|
* @author jqs
|
* @date 2023/6/28 11:44
|
* @param memberCouponId
|
* @return MerVerifyCouponGetVo
|
*/
|
@Override
|
public MerVerifyCouponGetVo sureVerifyCoupon(Long memberCouponId){
|
MemberCoupon memberCoupon = this.getById(memberCouponId);
|
if(memberCoupon==null||memberCoupon.getDelFlag()==1){
|
throw new ServiceException(AppErrorConstant.COUPON_NO_FIND);
|
}
|
if(memberCoupon.getCouponStatus()==0){
|
throw new ServiceException(AppErrorConstant.COUPON_EXPIRED);
|
}else if(memberCoupon.getCouponStatus()==2){
|
throw new ServiceException(AppErrorConstant.COUPON_USED);
|
}else if(memberCoupon.getCouponStatus()!=1){
|
throw new ServiceException(AppErrorConstant.COUPON_NO_FIND);
|
}
|
if(memberCoupon.getCouponType()!=4){
|
throw new ServiceException(AppErrorConstant.COUPON_TYPE_ERROR);
|
}
|
MerVerifyCouponGetVo merVerifyCouponGetVo = new MerVerifyCouponGetVo();
|
merVerifyCouponGetVo.setUserId(memberCoupon.getUserId());
|
String relGoodsIds = memberCoupon.getRelGoodsIds();
|
List<Goods> goodsList = remoteGoodsService.listGoodsByGoodsId(relGoodsIds).getData();
|
if(goodsList!=null){
|
merVerifyCouponGetVo.setGoodsList(goodsList);
|
}
|
merVerifyCouponGetVo.setMemberCouponId(memberCoupon.getId());
|
if (memberCoupon.getShopId()!=null&&memberCoupon.getShopId()>0) {
|
merVerifyCouponGetVo.setCouponFrom("商户");
|
} else {
|
merVerifyCouponGetVo.setCouponFrom("平台");
|
}
|
memberCoupon.setCouponStatus(2);
|
|
memberCoupon.setUseTime(new Date());
|
this.saveOrUpdate(memberCoupon);
|
merVerifyCouponGetVo.setMemberCoupon(memberCoupon);
|
return merVerifyCouponGetVo;
|
}
|
|
/**
|
* @description
|
* @author jqs
|
* @date 2023/6/29 11:42
|
* @param userId
|
* @param couponId
|
* @return Integer
|
*/
|
@Override
|
public Integer totalMemberCouponByUserAndCoupon(Long userId,String couponId){
|
LambdaQueryWrapper<MemberCoupon> queryWrapper = new LambdaQueryWrapper<>();
|
queryWrapper.eq(MemberCoupon::getUserId,userId);
|
queryWrapper.eq(MemberCoupon::getCouponId,couponId);
|
Integer total = this.count(queryWrapper);
|
return total;
|
}
|
|
/**
|
* @description 用户分页获取已领取优惠券列表
|
* @author jqs
|
* @date 2023/7/11 16:25
|
* @param page
|
* @param appMemberCouponPageDto
|
* @return List<AppMemberCouponPageVo>
|
*/
|
@Override
|
public List<AppMemberCouponPageVo> pageAppUserGetCoupon(Page page, AppMemberCouponPageDto appMemberCouponPageDto, Member member){
|
List<AppMemberCouponPageVo> memberCouponPageVoList = memberCouponMapper.pageAppUserGetCoupon(page, appMemberCouponPageDto);
|
if(!memberCouponPageVoList.isEmpty()){
|
String relGoodsIds;
|
HashSet<Long> shopIdSet = new HashSet<>();
|
HashSet<String> goodsIdSet = new HashSet<>();
|
String[] goodsIdArr;
|
for(AppMemberCouponPageVo appGetAbleCouponPageVo : memberCouponPageVoList){
|
if(appGetAbleCouponPageVo.getShopId()!=null){
|
shopIdSet.add(appGetAbleCouponPageVo.getShopId());
|
}
|
if(appGetAbleCouponPageVo.getCouponType()==4){
|
appGetAbleCouponPageVo.setVerifyCode("2-"+appGetAbleCouponPageVo.getMemberCouponId());
|
}
|
if(StringUtils.isNotBlank(appGetAbleCouponPageVo.getRelGoodsIds())){
|
relGoodsIds = appGetAbleCouponPageVo.getRelGoodsIds();
|
goodsIdArr = relGoodsIds.split(",");
|
for(String str : goodsIdArr){
|
goodsIdSet.add(str);
|
}
|
}
|
}
|
//获取关联商户和商品信息并转换为Map
|
String shopJoinedString;
|
Map<Long, MgtSimpleShopVo> shopMap = null;
|
if(shopIdSet!=null&&!shopIdSet.isEmpty()) {
|
shopJoinedString = String.join(",", shopIdSet.stream().map(Object::toString).collect(Collectors.toList()));
|
MgtBaseBathDto mgtBaseBathDto = new MgtBaseBathDto();
|
mgtBaseBathDto.setIds(shopJoinedString);
|
List<MgtSimpleShopVo> simpleShopVoList = remoteShopService.listShopSimpleVoByIds(mgtBaseBathDto).getData();
|
shopMap = simpleShopVoList.stream()
|
.collect(Collectors.toMap(MgtSimpleShopVo::getShopId, Function.identity()));
|
}
|
String goodsJoinedString = null;
|
if(goodsIdSet!=null&&!goodsIdSet.isEmpty()){
|
goodsJoinedString = String.join(",", goodsIdSet.stream().map(Object::toString).collect(Collectors.toList()));
|
}
|
Map<String, Goods> goodsMap = null;
|
if(goodsJoinedString!=null){
|
List<Goods> goodsList = remoteGoodsService.listGoodsByGoodsId(goodsJoinedString).getData();
|
goodsMap = goodsList.stream()
|
.collect(Collectors.toMap(Goods::getGoodsId, Function.identity()));
|
}
|
//处理返回信息
|
String shopLimit = "全门店通用";
|
String goodsLimit;
|
StringJoiner goodsNameSj;
|
for(AppMemberCouponPageVo appGetAbleCouponPageVo : memberCouponPageVoList){
|
goodsLimit = null;
|
goodsNameSj = new StringJoiner(",");
|
//商户限制
|
if(appGetAbleCouponPageVo.getShopId()!=null){
|
shopLimit = shopMap.get(appGetAbleCouponPageVo.getShopId()).getShopName()+"可用";
|
}
|
appGetAbleCouponPageVo.setShopLimit(shopLimit);
|
//商品限制
|
relGoodsIds = appGetAbleCouponPageVo.getRelGoodsIds();
|
if(StringUtils.isNotBlank(relGoodsIds)){
|
relGoodsIds = appGetAbleCouponPageVo.getRelGoodsIds();
|
goodsIdArr = relGoodsIds.split(",");
|
for(String goodsIs : goodsIdArr){
|
if(goodsMap.get(goodsIs)!=null){
|
goodsNameSj.add(goodsMap.get(goodsIs).getGoodsName());
|
}else{
|
log.debug("用户优惠券未找到关联商品"+appGetAbleCouponPageVo.getMemberCouponId()+"-"+appGetAbleCouponPageVo.getRelGoodsIds());
|
}
|
}
|
goodsLimit = goodsNameSj.toString();
|
}
|
appGetAbleCouponPageVo.setGoodsLimit(goodsLimit);
|
//核销商店
|
if(appGetAbleCouponPageVo.getShopId()!=null){
|
appGetAbleCouponPageVo.setVerifyShopName(shopMap.get(appGetAbleCouponPageVo.getShopId()).getShopName());
|
}
|
}
|
}
|
return memberCouponPageVoList;
|
}
|
|
/**
|
* @description 定时检查优惠券过期
|
* @author jqs
|
* @date 2023/7/12 19:19
|
* @param
|
* @return void
|
*/
|
@Override
|
public void timingCheckMemberCoupon(){
|
memberCouponMapper.timingCheckMemberCoupon();
|
}
|
|
/**
|
* @description 使用优惠券
|
* @author jqs
|
* @date 2023/7/13 19:38
|
* @param memberCouponIds
|
* @return void
|
*/
|
@Override
|
@Transactional(propagation = Propagation.REQUIRES_NEW)
|
public void useMemberCoupon(String memberCouponIds){
|
memberCouponMapper.useMemberCoupon(memberCouponIds);
|
}
|
|
/**
|
* @description 使用优惠券
|
* @author jqs
|
* @date 2023/7/13 19:38
|
* @param memberCouponIds
|
* @return void
|
*/
|
@Override
|
public void backMemberCoupon(String memberCouponIds){
|
memberCouponMapper.backMemberCoupon(memberCouponIds);
|
}
|
|
/**
|
* @description
|
* @author jqs
|
* @date 2023/7/19 17:35
|
* @param
|
* @return List<MerMemberCouponVo>
|
*/
|
@Override
|
public List<MerMemberCouponVo> listMerShopGoodsMemberCoupon(MerGoodsCouponListDto merGoodsCouponListDto){
|
List<MerMemberCouponVo> merMemberCouponVoList = memberCouponMapper.listMerShopGoodsMemberCoupon(merGoodsCouponListDto);
|
if(merMemberCouponVoList!=null&&merMemberCouponVoList.size()>0){
|
List<MemberSelectCouponDto> goodsCpuponList = merGoodsCouponListDto.getGoodsCpuponList();
|
List<Long> selectCouponList = new ArrayList<>();
|
Map<Long, String> selectCouponMap = new HashMap<>();
|
Boolean checkSelect = false;
|
if(merGoodsCouponListDto.getGoodsCpuponList()!=null&&merGoodsCouponListDto.getGoodsCpuponList().size()>0) {
|
for (MemberSelectCouponDto couponDto : goodsCpuponList) {
|
selectCouponList.add(couponDto.getMemberCouponId());
|
selectCouponMap.put(couponDto.getMemberCouponId(), couponDto.getGoodsId());
|
}
|
checkSelect = true;
|
}
|
Iterator<MerMemberCouponVo> iterator = merMemberCouponVoList.iterator();
|
while (iterator.hasNext()) {
|
MerMemberCouponVo couponVo = iterator.next();
|
//处理已选择优惠券过滤
|
if(checkSelect){
|
if (selectCouponList.contains(couponVo.getMemberCouponId()) && selectCouponMap.containsKey(couponVo.getMemberCouponId())) {
|
String goodsId = selectCouponMap.get(couponVo.getMemberCouponId());
|
if (!merGoodsCouponListDto.getGoodsId().equals(goodsId)) {
|
iterator.remove();
|
continue;
|
}
|
}
|
}
|
//处理满减卷门槛过滤
|
if(merGoodsCouponListDto.getBuyNum()!=null&&merGoodsCouponListDto.getSalesPrice()!=null){
|
if(couponVo.getCouponType()==1){
|
BigDecimal goodsMoney = merGoodsCouponListDto.getSalesPrice().multiply(new BigDecimal(merGoodsCouponListDto.getBuyNum().toString()));
|
if(goodsMoney.compareTo(couponVo.getMoneyThreshold())<0){
|
iterator.remove();
|
}
|
}
|
}
|
}
|
}
|
return merMemberCouponVoList;
|
}
|
|
|
/**
|
* @description 确认核销优惠券
|
* @author jqs
|
* @date 2023/8/15 11:21
|
* @param memberCouponId
|
* @param shopId
|
* @return void
|
*/
|
@Override
|
public void sureMemberCoupon(Long memberCouponId, Long shopId){
|
memberCouponMapper.sureMemberCoupon(memberCouponId, shopId);
|
}
|
|
@Override
|
@Transactional(propagation = Propagation.REQUIRES_NEW, rollbackFor = Exception.class)
|
public void insert(MemberCoupon memberCoupon) {
|
this.baseMapper.insert(memberCoupon);
|
}
|
}
|
