悬赏招亲

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())) {