From 572df690f72ed4a077d934823f261dec39b3cc7d Mon Sep 17 00:00:00 2001
From: 刘帅 <rr.iii@qq.com>
Date: 星期二, 08 九月 2026 17:11:34 +0800
Subject: [PATCH] feat&bug：文档内容修改
---
cloud-server-activity/src/main/java/com/dsh/activity/service/impl/UserCouponServiceImpl.java | 64 ++++++++++++++++++++++++++++++++
1 files changed, 64 insertions(+), 0 deletions(-)
diff --git a/cloud-server-activity/src/main/java/com/dsh/activity/service/impl/UserCouponServiceImpl.java b/cloud-server-activity/src/main/java/com/dsh/activity/service/impl/UserCouponServiceImpl.java
index 83a7f6f..6bb6d60 100644
--- a/cloud-server-activity/src/main/java/com/dsh/activity/service/impl/UserCouponServiceImpl.java
+++ b/cloud-server-activity/src/main/java/com/dsh/activity/service/impl/UserCouponServiceImpl.java
@@ -16,6 +16,8 @@
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;
@@ -24,12 +26,18 @@
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;
/**
@@ -42,6 +50,8 @@
*/
@Service
public class UserCouponServiceImpl extends ServiceImpl<UserCouponMapper, UserCoupon> implements UserCouponService {
+
+ private static final Logger LOGGER = LoggerFactory.getLogger(UserCouponServiceImpl.class);
@Resource
private CoursePackageClient coursePackageClient;
@@ -72,6 +82,60 @@
@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());
+ BigDecimal deductionAmount = content.getBigDecimal("deductionAmount");
+ return deductionAmount == null ? BigDecimal.ZERO : deductionAmount.max(BigDecimal.ZERO);
+ } catch (Exception e) {
+ LOGGER.warn("解析优惠券抵扣规则失败，couponId={}", coupon.getId(), e);
+ return BigDecimal.ZERO;
+ }
+ }
+
/**
* 获取购买课程可用优惠券列表
--
Gitblit v1.7.1