diff --git a/dating-agency-mall-server/pom.xml b/dating-agency-mall-server/pom.xml index d5dae71..907d335 100644 --- a/dating-agency-mall-server/pom.xml +++ b/dating-agency-mall-server/pom.xml @@ -86,6 +86,11 @@ dating-agency-service-event 0.0.1-SNAPSHOT + + com.qniao + dating-agency-uec-event + 0.0.1-SNAPSHOT + com.qniao dating-agency-service-entity 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 98d13cd..f5dec1a 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 @@ -40,6 +40,7 @@ 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.dau.domian.aggregate.matchmakingcorner.event.MatchmakingCornerPaidMQ; import com.qniao.domain.BaseApplicationService; import com.qniao.domain.BaseDomainEvent; import lombok.extern.slf4j.Slf4j; @@ -126,6 +127,10 @@ public class OrderEventHandler extends BaseApplicationService { } PaidMatchmakerFeeBySdkDto dto = new PaidMatchmakerFeeBySdkDto(order.getUserId(), orderItem.getSubCategory(), order.getOriginalAmount(), validityPeriodDays, order.getId(), matchmakerOrderType); uecServerApplicationService.userPaidMatchmakerFee(dto); + } else if (OrderBelongingEnum.MATCHMAKING_CORNER.equals(order.getOrderBelonging())) { + OrderItem orderItem = order.getOrderItemList().get(0); + MatchmakingCornerPaidMQ mq = new MatchmakingCornerPaidMQ(order.getUserId(), orderItem.getSubCategory()); + amqpTemplate.convertAndSend(MqExchange.MATCHMAKING_CORNER_PAID, null, mq); } //悬赏招亲 if (OrderTypeEnum.MARRIAGE_BOUNTY.equals(order.getOrderType())) { diff --git a/dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/constant/MqExchange.java b/dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/constant/MqExchange.java index 41b65a1..aafad13 100644 --- a/dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/constant/MqExchange.java +++ b/dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/constant/MqExchange.java @@ -24,4 +24,5 @@ public interface MqExchange { String SITE_ACTIVITY_PARTICIPANT_SETTLED = "fanout.siteActivityParticipantSettled"; + String MATCHMAKING_CORNER_PAID = "fanout.matchmakingCornerPaid"; }