From 9391775dc245b08e7e1ec294a10763f42a92af82 Mon Sep 17 00:00:00 2001 From: Derran Date: Wed, 8 Jan 2025 15:54:18 +0800 Subject: [PATCH] =?UTF-8?q?=E7=BA=A2=E5=A8=98=E7=A7=AF=E5=88=86=E5=8D=87?= =?UTF-8?q?=E7=BA=A7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../puc/event/MatchmakerPointUpgradeExchangedMQ.java | 4 ++++ .../handler/puc/PointUpgradeConfigEventHandler.java | 4 +++- 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/dating-agency-mall-event/src/main/java/com/qniao/dam/domian/aggregate/puc/event/MatchmakerPointUpgradeExchangedMQ.java b/dating-agency-mall-event/src/main/java/com/qniao/dam/domian/aggregate/puc/event/MatchmakerPointUpgradeExchangedMQ.java index 408c1f6..7a284f9 100644 --- a/dating-agency-mall-event/src/main/java/com/qniao/dam/domian/aggregate/puc/event/MatchmakerPointUpgradeExchangedMQ.java +++ b/dating-agency-mall-event/src/main/java/com/qniao/dam/domian/aggregate/puc/event/MatchmakerPointUpgradeExchangedMQ.java @@ -5,6 +5,7 @@ import io.swagger.annotations.ApiModelProperty; import lombok.Data; import java.io.Serializable; +import java.math.BigDecimal; @Data public class MatchmakerPointUpgradeExchangedMQ implements Serializable { @@ -17,4 +18,7 @@ public class MatchmakerPointUpgradeExchangedMQ implements Serializable { private Integer validityPeriodDays; + @ApiModelProperty("加盟费") + private BigDecimal franchiseFee; + } diff --git a/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/puc/PointUpgradeConfigEventHandler.java b/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/puc/PointUpgradeConfigEventHandler.java index 42999a1..82160d0 100644 --- a/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/puc/PointUpgradeConfigEventHandler.java +++ b/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/puc/PointUpgradeConfigEventHandler.java @@ -34,12 +34,14 @@ public class PointUpgradeConfigEventHandler extends BaseApplicationService { //4.红娘对应等级的有效期查询 Product product = productQueryService.queryBy(event.getUpgradeType()); List productSpecList = productQueryService.listProductSpecBy(product.getId()); + ProductSpec productSpec = productSpecList.get(0); int validityPeriodDays = 0; - ProductSpecTerm term = productQueryService.getTermByName(productSpecList.get(0).getProductSpecTermList(), ProductSpecTermNameEnum.VALIDITY_PERIOD); + ProductSpecTerm term = productQueryService.getTermByName(productSpec.getProductSpecTermList(), ProductSpecTermNameEnum.VALIDITY_PERIOD); if (Objects.nonNull(term)) { validityPeriodDays = Integer.parseInt(term.getValue()); } mq.setValidityPeriodDays(validityPeriodDays); + mq.setFranchiseFee(productSpec.getUnitSellingPrice()); amqpTemplate.convertAndSend(MqExchange.MATCHMAKER_POINT_UPGRADE_EXCHANGED, null, mq); } }