package com.dsh.activity.service.impl;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.dsh.activity.entity.*;
|
import com.dsh.activity.feignclient.account.AppUserClient;
|
import com.dsh.activity.feignclient.account.StudentClient;
|
import com.dsh.activity.feignclient.account.model.AppUser;
|
import com.dsh.activity.feignclient.course.CoursePackageClient;
|
import com.dsh.activity.feignclient.course.model.CoursePackage;
|
import com.dsh.activity.feignclient.other.SiteClient;
|
import com.dsh.activity.feignclient.other.StoreClient;
|
import com.dsh.activity.feignclient.other.model.Site;
|
import com.dsh.activity.feignclient.other.model.StoreDetailOfCourse;
|
import com.dsh.activity.mapper.*;
|
import com.dsh.activity.model.ConponJsonRuleModel;
|
import com.dsh.activity.model.CouponDeductionQuery;
|
import com.dsh.activity.model.CouponDeductionVO;
|
import com.dsh.activity.model.CouponListVo;
|
import com.dsh.activity.model.request.CouponPackageReq;
|
import com.dsh.activity.model.response.CouponPackageResp;
|
import com.dsh.activity.service.UserCouponService;
|
import com.dsh.activity.util.DateUtil;
|
import com.dsh.activity.util.GDMapGeocodingUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
|
import javax.annotation.Resource;
|
import java.text.SimpleDateFormat;
|
import java.util.ArrayList;
|
import java.math.BigDecimal;
|
import java.util.Collections;
|
import java.util.LinkedHashSet;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Set;
|
import java.util.stream.Collectors;
|
|
/**
|
* <p>
|
* 用户优惠券领取记录 服务实现类
|
* </p>
|
*
|
* @author jqs
|
* @since 2023-06-29
|
*/
|
@Service
|
public class UserCouponServiceImpl extends ServiceImpl<UserCouponMapper, UserCoupon> implements UserCouponService {
|
|
private static final Logger LOGGER = LoggerFactory.getLogger(UserCouponServiceImpl.class);
|
|
@Resource
|
private CoursePackageClient coursePackageClient;
|
|
@Autowired
|
private GDMapGeocodingUtil gdMapGeocodingUtil;
|
@Autowired
|
private PointsMerchandiseMapper pointsMerchandiseMapper;
|
|
@Resource
|
private AppUserClient appClient;
|
|
@Resource
|
private StudentClient studentClient;
|
|
@Resource
|
private CouponMapper couponMapper;
|
|
@Resource
|
private CouponCityMapper couponCityMapper;
|
|
@Resource
|
private StoreClient storeClient;
|
|
@Resource
|
private CouponStoreMapper csMapper;
|
|
@Resource
|
private SiteClient siteClient;
|
|
/**
|
* 批量解析已核销优惠券的固定抵扣金额，避免统计页面逐条远程查询优惠券。
|
*
|
* @param query 用户优惠券领取记录 ID 集合
|
* @return 每条领取记录对应的抵扣金额；无固定抵扣规则时返回 0
|
*/
|
@Override
|
public List<CouponDeductionVO> queryDeductionAmounts(CouponDeductionQuery query) {
|
if (query == null || query.getUserCouponIds() == null || query.getUserCouponIds().isEmpty()) {
|
return Collections.emptyList();
|
}
|
|
Set<Long> userCouponIds = new LinkedHashSet<>(query.getUserCouponIds());
|
List<UserCoupon> userCoupons = this.list(new QueryWrapper<UserCoupon>()
|
.in("id", userCouponIds));
|
if (userCoupons.isEmpty()) {
|
return Collections.emptyList();
|
}
|
|
Set<Integer> couponIds = userCoupons.stream()
|
.map(UserCoupon::getCouponId)
|
.filter(java.util.Objects::nonNull)
|
.collect(Collectors.toSet());
|
List<Coupon> coupons = couponIds.isEmpty()
|
? Collections.emptyList()
|
: couponMapper.selectBatchIds(couponIds);
|
Map<Integer, Coupon> couponMap = coupons.stream()
|
.collect(Collectors.toMap(Coupon::getId, coupon -> coupon));
|
|
List<CouponDeductionVO> result = new ArrayList<>();
|
for (UserCoupon userCoupon : userCoupons) {
|
CouponDeductionVO deduction = new CouponDeductionVO();
|
deduction.setUserCouponId(userCoupon.getId());
|
deduction.setDeductionAmount(getCouponDeductionAmount(couponMap.get(userCoupon.getCouponId())));
|
result.add(deduction);
|
}
|
return result;
|
}
|
|
/** 解析优惠券规则中的固定抵扣金额。 */
|
private BigDecimal getCouponDeductionAmount(Coupon coupon) {
|
if (coupon == null || coupon.getContent() == null) {
|
return BigDecimal.ZERO;
|
}
|
try {
|
JSONObject content = JSON.parseObject(coupon.getContent());
|
// 满减券使用 deductionAmount，代金券历史规则将抵扣额存放在 conditionalAmount。
|
BigDecimal deductionAmount = Integer.valueOf(2).equals(coupon.getType())
|
? content.getBigDecimal("conditionalAmount")
|
: content.getBigDecimal("deductionAmount");
|
return deductionAmount == null ? BigDecimal.ZERO : deductionAmount.max(BigDecimal.ZERO);
|
} catch (Exception e) {
|
LOGGER.warn("解析优惠券抵扣规则失败，couponId={}", coupon.getId(), e);
|
return BigDecimal.ZERO;
|
}
|
}
|
|
|
/**
|
* 获取购买课程可用优惠券列表
|
*
|
* @param uid
|
* @param coursePackageId
|
* @return
|
*/
|
@Override
|
public List<CouponListVo> queryAvailableCouponList(Integer uid, Integer coursePackageId, Double price, String lon, String lat) throws Exception {
|
CoursePackage coursePackage = coursePackageClient.queryCoursePackageById(coursePackageId);
|
Integer storeId = coursePackage.getStoreId();
|
Map<String, String> geocode = gdMapGeocodingUtil.geocode(lon, lat);
|
String provinceCode = geocode.get("provinceCode");
|
String cityCode = geocode.get("cityCode");
|
List<Map<String, Object>> userCoupons = this.baseMapper.queryAvailableCouponList(uid, storeId, provinceCode, cityCode);
|
List<CouponListVo> listVos = new ArrayList<>();
|
for (Map<String, Object> userCoupon : userCoupons) {
|
Integer type = Integer.valueOf(userCoupon.get("type").toString());
|
// 支付减免只支持满减券和代金券；体验券/抵扣券不能用于订单金额计算。
|
if (type != 1 && type != 2) {
|
continue;
|
}
|
CouponListVo couponListVo = new CouponListVo();
|
couponListVo.setId(Long.valueOf(userCoupon.get("id").toString()));
|
couponListVo.setName(userCoupon.get("name").toString());
|
couponListVo.setType(type);
|
couponListVo.setEffectiveTime(userCoupon.get("endTime").toString());
|
String content = userCoupon.get("content").toString();
|
if (type == 1) {//满减{"num1":1,"num2":1}
|
JSONObject jsonObject = JSON.parseObject(content);
|
Double num1 = jsonObject.getDouble("conditionalAmount");
|
if (price.compareTo(num1) < 0) {
|
continue;
|
}
|
couponListVo.setUseCondition("满￥" + num1 + "元可用");
|
couponListVo.setFavorable(jsonObject.getString("deductionAmount"));
|
}
|
if (type == 2) {//代金券{"num1":1}
|
JSONObject jsonObject = JSON.parseObject(content);
|
Double num1 = jsonObject.getDouble("conditionalAmount");
|
if (num1 == null) {
|
num1 = 0d;
|
}
|
if (price.compareTo(num1) < 0) {
|
continue;
|
}
|
couponListVo.setUseCondition("");
|
couponListVo.setFavorable(num1 + "");
|
}
|
if (type == 3) {//体验券{"num1":1}
|
JSONObject jsonObject = JSON.parseObject(content);
|
couponListVo.setUseCondition("");
|
couponListVo.setFavorable(jsonObject.getString("experienceName"));
|
}
|
listVos.add(couponListVo);
|
}
|
return listVos;
|
}
|
|
|
/**
|
* 获取预约场地可用优惠券列表
|
*
|
* @param siteId
|
* @param price
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public List<CouponListVo> querySiteCouponList(Integer uid, Integer siteId, Double price, String lon, String lat) throws Exception {
|
Site site = siteClient.querySiteById(siteId);
|
return queryStoreCouponList(uid, site.getStoreId(), price, lon, lat);
|
}
|
|
@Override
|
public List<CouponListVo> queryStoreCouponList(Integer uid, Integer storeId, Double price, String lon, String lat) throws Exception {
|
Map<String, String> geocode = gdMapGeocodingUtil.geocode(lon, lat);
|
String provinceCode = geocode.get("provinceCode");
|
String cityCode = geocode.get("cityCode");
|
List<Map<String, Object>> userCoupons = this.baseMapper.queryAvailableCouponList(uid, storeId, provinceCode, cityCode);
|
List<CouponListVo> listVos = new ArrayList<>();
|
for (Map<String, Object> userCoupon : userCoupons) {
|
Integer type = Integer.valueOf(userCoupon.get("type").toString());
|
if (type != 1 && type != 2) {
|
continue;
|
}
|
CouponListVo couponListVo = new CouponListVo();
|
couponListVo.setId(Long.valueOf(userCoupon.get("id").toString()));
|
couponListVo.setName(userCoupon.get("name").toString());
|
couponListVo.setType(type);
|
couponListVo.setEffectiveTime(userCoupon.get("endTime").toString());
|
String content = userCoupon.get("content").toString();
|
BigDecimal orderAmount = BigDecimal.valueOf(price == null ? 0D : price).max(BigDecimal.ZERO);
|
if (type == 1) {//满减{"num1":1,"num2":1}
|
JSONObject jsonObject = JSON.parseObject(content);
|
Double num1 = jsonObject.getDouble("conditionalAmount");
|
if (price.compareTo(num1) < 0) {
|
continue;
|
}
|
couponListVo.setUseCondition("满" + num1 + "元可用");
|
couponListVo.setFavorable(jsonObject.getString("deductionAmount"));
|
BigDecimal discount = BigDecimal.valueOf(jsonObject.getDouble("deductionAmount"))
|
.min(orderAmount);
|
couponListVo.setDiscountAmount(discount);
|
couponListVo.setPayableAmount(orderAmount.subtract(discount));
|
}
|
if (type == 2) {//代金券{"num1":1}
|
JSONObject jsonObject = JSON.parseObject(content);
|
Double num1 = jsonObject.getDouble("conditionalAmount");
|
if (num1 == null) {
|
num1 = 0d;
|
}
|
// 代金券可全额抵扣，面额超过订单金额时按订单金额抵扣，不应从列表中剔除。
|
couponListVo.setUseCondition("");
|
couponListVo.setFavorable(num1 + "");
|
BigDecimal discount = BigDecimal.valueOf(num1).max(BigDecimal.ZERO).min(orderAmount);
|
couponListVo.setDiscountAmount(discount);
|
couponListVo.setPayableAmount(orderAmount.subtract(discount));
|
}
|
if (type == 3) {//体验券{"num1":1}
|
JSONObject jsonObject = JSON.parseObject(content);
|
couponListVo.setUseCondition("");
|
couponListVo.setFavorable(jsonObject.getString("experienceName"));
|
}
|
listVos.add(couponListVo);
|
}
|
return listVos;
|
}
|
|
@Override
|
public List<CouponPackageResp> queryCouponPackagesList(Integer uid, CouponPackageReq req) {
|
List<CouponPackageResp> respList = new ArrayList<>();
|
AppUser appUser = appClient.queryAppUser(uid);
|
if (null != appUser) {
|
List<UserCoupon> userCoupons = this.baseMapper.selectList(new QueryWrapper<UserCoupon>()
|
.eq("userId", appUser.getId())
|
.orderByDesc("insertTime"));
|
if (userCoupons.size() > 0) {
|
for (UserCoupon userCoupon : userCoupons) {
|
Coupon coupon = couponMapper.selectById(userCoupon.getCouponId());
|
CouponPackageResp packageResp = new CouponPackageResp();
|
packageResp.setId(coupon.getId());
|
packageResp.setName(coupon.getName());
|
packageResp.setType(coupon.getType());
|
packageResp.setUseCondition(coupon.getUseScope());
|
switch (coupon.getUseScope()) {
|
case 1:
|
packageResp.setAvailable("全国通用");
|
break;
|
case 2:
|
packageResp.setAvailable("指定城市可用");
|
List<CouponCity> couponId = couponCityMapper.selectList(new QueryWrapper<CouponCity>().eq("couponId", coupon.getId()));
|
StringBuilder stringBuilder = new StringBuilder();
|
for (CouponCity couponCity : couponId) {
|
stringBuilder.append(couponCity.getCity());
|
}
|
packageResp.setCityOrStore(String.valueOf(stringBuilder));
|
break;
|
case 3:
|
packageResp.setAvailable("指定门店可用");
|
CouponStore couponStore = csMapper.selectOne(new QueryWrapper<CouponStore>()
|
.eq("couponId", coupon.getId()).last("limit 1"));
|
StoreDetailOfCourse courseOfStore = storeClient.getCourseOfStore(couponStore.getStoreId());
|
// packageResp.setCityOrStore(courseOfStore.getStoreName()+","+courseOfStore.getStoreAddr());
|
packageResp.setCityOrStore(courseOfStore.getStoreName());
|
break;
|
default:
|
break;
|
}
|
packageResp.setInstructionsForUse(coupon.getIllustrate());
|
ConponJsonRuleModel ruleModel = new ConponJsonRuleModel();
|
JSONObject jsonObject = JSON.parseObject(coupon.getContent());
|
switch (coupon.getType()) {
|
case 1:
|
// {"conditionalAmount":50,"deductionAmount":10,"experienceName":""}
|
// 满减券
|
Double num1 = jsonObject.getDouble("conditionalAmount");
|
Double num2 = jsonObject.getDouble("deductionAmount");
|
ruleModel.setConditionalAmount("满" + num1 + "可用");
|
ruleModel.setDeductionAmount("¥ " + num2);
|
ruleModel.setExperienceName("");
|
break;
|
case 2:
|
// 代金券
|
Double jsonObjectDouble = jsonObject.getDouble("conditionalAmount");
|
ruleModel.setConditionalAmount("");
|
ruleModel.setDeductionAmount("¥ " + jsonObjectDouble);
|
ruleModel.setExperienceName("");
|
break;
|
case 3:
|
// 体验券
|
ruleModel.setConditionalAmount("");
|
ruleModel.setDeductionAmount("");
|
ruleModel.setExperienceName(jsonObject.getString("experienceName"));
|
break;
|
case 4:
|
// 抵扣券
|
Integer goodsId = coupon.getGoodsId();
|
PointsMerchandise pointsMerchandise = pointsMerchandiseMapper.selectById(goodsId);
|
ruleModel.setConditionalAmount("");
|
ruleModel.setDeductionAmount("");
|
ruleModel.setExperienceName(pointsMerchandise.getName());
|
break;
|
default:
|
break;
|
}
|
packageResp.setRuleModel(ruleModel);
|
|
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
|
packageResp.setEffectiveTime(simpleDateFormat.format(coupon.getEndTime()));
|
|
if (userCoupon.getStatus() == 1) {
|
if (DateUtil.getDate().before(coupon.getEndTime())) {
|
packageResp.setUseStatus(1);
|
} else {
|
packageResp.setUseStatus(3);
|
}
|
}
|
if (userCoupon.getStatus() == 2) {
|
packageResp.setUseStatus(2);
|
}
|
if (userCoupon.getStatus() == 3) {
|
packageResp.setUseStatus(3);
|
}
|
respList.add(packageResp);
|
}
|
if (null != req.getCouponType()) {
|
respList = respList.stream()
|
.filter(couponPackageResp -> couponPackageResp.getType().equals(req.getCouponType()))
|
.collect(Collectors.toList());
|
}
|
if (null != req.getUseStatus()) {
|
respList = respList.stream()
|
.filter(couponPackageResp -> couponPackageResp.getUseStatus().equals(req.getUseStatus()))
|
.collect(Collectors.toList());
|
}
|
}
|
|
}
|
return respList;
|
}
|
|
}
|
