基础配置

dating-agency-mall-server/pom.xml

@@ -81,6 +81,11 @@
             <artifactId>dating-agency-mall-event</artifactId>
             <version>0.0.1-SNAPSHOT</version>
         </dependency>
+        <dependency>
+            <groupId>com.qniao</groupId>
+            <artifactId>dating-agency-service-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/api/command/reward/user/RewardUserCommandController.java

@@ -1,8 +1,6 @@
 package com.qniao.dam.api.command.reward.user;
 
-import com.qniao.dam.api.command.reward.user.request.AcquireMatchmakerConfirmMeetingRewardDto;
 import com.qniao.dam.api.command.reward.user.request.UserAcquireMatchmakerJoinRecommendRewardDto;
-import com.qniao.dam.application.service.marriagebounty.MarriageBountyOrderApplicationService;
 import com.qniao.dam.application.service.reward.RewardApplicationService;
 import com.qniao.framework.annotation.IgnoreResponseAdvice;
 import io.swagger.annotations.Api;
@@ -19,8 +17,6 @@ public class RewardUserCommandController {
 
     @Resource
     private RewardApplicationService rewardApplicationService;
-    @Resource
-    private MarriageBountyOrderApplicationService marriageBountyOrderApplicationService;
 
     @ApiOperation("通过SDK获得奖励")
     @PostMapping("acquire/matchmaker-join-recommend/reward/by/sdk")
@@ -29,11 +25,4 @@ public class RewardUserCommandController {
         rewardApplicationService.acquireMatchmakerJoinRecommendReward(dto);
     }
 
-    @ApiOperation("红娘获得悬赏招亲见面奖励")
-    @GetMapping("acquire/matchmaker-confirm-meeting/reward")
-    public void acquireMatchmakerConfirmMeetingReward(@RequestParam Long marriageBountyOrderId,
-                                                      @RequestParam Long receiver,
-                                                      @RequestParam Long meetingMiId) {
-        marriageBountyOrderApplicationService.confirmMeeting(marriageBountyOrderId, receiver, meetingMiId);
-    }
 }

dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/marriagebounty/MarriageBountyOrderEventHandle.java

@@ -2,15 +2,23 @@ package com.qniao.dam.application.handler.marriagebounty;
 
 import com.google.common.eventbus.Subscribe;
 import com.qniao.dam.api.command.reward.user.request.AcquireMatchmakerConfirmMeetingRewardDto;
+import com.qniao.dam.application.service.marriagebounty.MarriageBountyOrderApplicationService;
 import com.qniao.dam.application.service.reward.RewardApplicationService;
 import com.qniao.dam.domian.aggregate.marriagebounty.event.MarriageBountyOrderConfirmedMeetingEvent;
 import com.qniao.dam.domian.aggregate.marriagebounty.event.MarriageBountyOrderCreatedEvent;
 import com.qniao.dam.domian.aggregate.marriagebounty.event.MarriageBountyOrderCreatedMQ;
 import com.qniao.dam.infrastructure.constant.MqExchange;
+import com.qniao.dam.infrastructure.constant.MqQueue;
+import com.qniao.das.domian.aggregate.marriageseekingreward.event.RewardSelectedGuestEvent;
 import com.qniao.domain.BaseApplicationService;
 import com.qniao.framework.utils.TypeConvertUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.core.AmqpTemplate;
+import org.springframework.amqp.core.ExchangeTypes;
+import org.springframework.amqp.rabbit.annotation.Exchange;
+import org.springframework.amqp.rabbit.annotation.Queue;
+import org.springframework.amqp.rabbit.annotation.QueueBinding;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
@@ -24,6 +32,8 @@ public class MarriageBountyOrderEventHandle extends BaseApplicationService {
     private AmqpTemplate amqpTemplate;
     @Resource
     private RewardApplicationService rewardApplicationService;
+    @Resource
+    private MarriageBountyOrderApplicationService marriageBountyOrderApplicationService;
 
     @Subscribe
     public void handle(MarriageBountyOrderCreatedEvent event) {
@@ -50,4 +60,17 @@ public class MarriageBountyOrderEventHandle extends BaseApplicationService {
         }
     }
 
+
+    @RabbitListener(bindings = @QueueBinding(value = @Queue(MqQueue.REWARD_SELECTED_GUEST),
+            exchange = @Exchange(value = MqExchange.REWARD_SELECTED_GUEST,
+                    type = ExchangeTypes.FANOUT)))
+    public void handle(RewardSelectedGuestEvent event) {
+        try {
+            //创建榜单
+            marriageBountyOrderApplicationService.confirmMeeting(event.getMarriageBountyOrderId(),event.getMatchmakerUserId(),event.getMiId());
+            log.error("接收到MQ事件：{}", event);
+        } catch (Exception e) {
+            log.error("悬赏招亲确认见面处理异常", e);
+        }
+    }
 }

dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/constant/MqExchange.java

@@ -5,4 +5,8 @@ public interface MqExchange {
     String MARRIAGE_BOUNTY_ORDER_CREATED = "fanout.marriageBountyOrderCreated";
 
     String MARRIAGE_BOUNTY_ORDER_CANCELLED = "fanout.marriageBountyOrderCancelled";
+
+    String REWARD_SELECTED_GUEST = "fanout.rewardSelectedGuest";
+
+    String REWARD_MATCH_SUCCESSFULLY = "fanout.rewardMatchSuccessfully";
 }

dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/constant/MqQueue.java

@@ -6,4 +6,10 @@ package com.qniao.dam.infrastructure.constant;
  */
 public interface MqQueue {
 
+    String serviceName = ".dating-agency-mall";
+
+    String REWARD_SELECTED_GUEST = MqExchange.REWARD_SELECTED_GUEST + serviceName;
+
+    String REWARD_MATCH_SUCCESSFULLY = MqExchange.REWARD_MATCH_SUCCESSFULLY + serviceName;
+
 }