diff --git a/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/order/OrderEventHandler.java b/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/order/OrderEventHandler.java index 9a61230..b373fba 100644 --- a/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/order/OrderEventHandler.java +++ b/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/order/OrderEventHandler.java @@ -18,6 +18,7 @@ import com.qniao.dam.domain.aggregate.product.entity.Product; import com.qniao.dam.domain.aggregate.product.repository.ProductRepository; import com.qniao.dam.domain.aggregate.productspec.entity.ProductSpec; import com.qniao.dam.domain.aggregate.productspec.repository.ProductSpecRepository; +import com.qniao.dam.domain.aggregate.productspec.valueobj.ProductSpecTerm; import com.qniao.dam.domain.aggregate.right.RightAggregate; import com.qniao.dam.domain.aggregate.right.entity.Right; import com.qniao.dam.domian.aggregate.externalorder.constant.ExternalOrderRelStatus; @@ -27,6 +28,7 @@ import com.qniao.dam.domian.aggregate.order.constant.OrderTypeEnum; import com.qniao.dam.domian.aggregate.order.event.ExternalOrderCompletedMQEvent; import com.qniao.dam.domian.aggregate.order.event.OrderCompletedEvent; import com.qniao.dam.domian.aggregate.product.constant.ProductTypeEnum; +import com.qniao.dam.domian.aggregate.productspec.constant.ProductSpecTermNameEnum; import com.qniao.dam.infrastructure.constant.MqExchange; import com.qniao.dam.infrastructure.persistent.dao.domain.ExternalOrderRelDao; import com.qniao.dam.infrastructure.persistent.dao.domain.MarriageInformationDao; @@ -36,6 +38,7 @@ import com.qniao.dam.query.product.ProductQueryService; import com.qniao.das.domian.aggregate.marriageinformation.MarriageInformation; import com.qniao.das.domian.aggregate.siteactivity.SiteActivity; import com.qniao.dau.application.UecServerApplicationService; +import com.qniao.dau.application.request.PaidMatchmakerFeeBySdkDto; import com.qniao.domain.BaseApplicationService; import com.qniao.domain.BaseDomainEvent; import lombok.extern.slf4j.Slf4j; @@ -115,7 +118,15 @@ public class OrderEventHandler extends BaseApplicationService { } //红娘加盟费 if (OrderBelongingEnum.MATCHMAKER.equals(order.getOrderBelonging())) { - uecServerApplicationService.userPaidMatchmakerFee(order.getUserId()); + OrderItem orderItem = order.getOrderItemList().get(0); + ProductSpec productSpec = productSpecRepository.load(orderItem.getProductSpecId()); + int validityPeriodDays = 0; + ProductSpecTerm term = productQueryService.getTermByName(productSpec.getProductSpecTermList(), ProductSpecTermNameEnum.VALIDITY_PERIOD); + if (Objects.nonNull(term)) { + validityPeriodDays = Integer.parseInt(term.getValue()); + } + PaidMatchmakerFeeBySdkDto dto = new PaidMatchmakerFeeBySdkDto(order.getUserId(), validityPeriodDays); + uecServerApplicationService.userPaidMatchmakerFee(dto); } //悬赏招亲 if (OrderTypeEnum.MARRIAGE_BOUNTY.equals(order.getOrderType())) {