From 4a1d1bb0aaeeeb3cb2c3abf7f09ecc8fce5367a3 Mon Sep 17 00:00:00 2001
From: Derran <zhangpengjie@qniao.cn>
Date: Sat, 12 Apr 2025 09:39:12 +0800
Subject: [PATCH] =?UTF-8?q?=E7=9B=B8=E4=BA=B2=E8=A7=92=E8=AE=A2=E5=8D=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 dating-agency-mall-server/pom.xml                            | 5 +++++
 .../dam/application/handler/order/OrderEventHandler.java     | 5 +++++
 .../com/qniao/dam/infrastructure/constant/MqExchange.java    | 1 +
 3 files changed, 11 insertions(+)

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 @@
             <artifactId>dating-agency-service-event</artifactId>
             <version>0.0.1-SNAPSHOT</version>
         </dependency>
+        <dependency>
+            <groupId>com.qniao</groupId>
+            <artifactId>dating-agency-uec-event</artifactId>
+            <version>0.0.1-SNAPSHOT</version>
+        </dependency>
         <dependency>
             <groupId>com.qniao</groupId>
             <artifactId>dating-agency-service-entity</artifactId>
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";
 }