相亲角订单

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>

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

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";
 }