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<ProductSpec> 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);
     }
 }