From bd12554d425e49409bbc525865fd1f008cd92e56 Mon Sep 17 00:00:00 2001
From: jieyuu <645634619@qq.com>
Date: Mon, 2 Sep 2024 21:11:46 +0800
Subject: [PATCH] =?UTF-8?q?=E5=95=86=E5=93=81=E5=BA=93=E5=AD=98=E5=9B=9E?=
 =?UTF-8?q?=E6=94=B6=E6=B6=88=E6=81=AF=E6=B5=8B=E8=AF=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/net/jieyuu/config/InterceptorConfig.java  |  2 +-
 .../java/net/jieyuu/mq/ProductStockMQListener.java | 14 +++++++-------
 .../java/net/jieyuu/biz/DemoApplicationTests.java  | 10 ++++++++++
 3 files changed, 18 insertions(+), 8 deletions(-)

diff --git a/xdclass-coupon-service/src/main/java/net/jieyuu/config/InterceptorConfig.java b/xdclass-coupon-service/src/main/java/net/jieyuu/config/InterceptorConfig.java
index e963528..93d690b 100644
--- a/xdclass-coupon-service/src/main/java/net/jieyuu/config/InterceptorConfig.java
+++ b/xdclass-coupon-service/src/main/java/net/jieyuu/config/InterceptorConfig.java
@@ -16,7 +16,7 @@ public class InterceptorConfig implements WebMvcConfigurer {
         registry
                 .addInterceptor(new LoginInterceptor())
                 //拦截的路径
-                .addPathPatterns("/api/coupon/*/**","/api/coupon_record/v1/*/**")
+                .addPathPatterns("/api/coupon/*/**","/api/coupon_record/*/**")
                 //放行的路径
                 .excludePathPatterns("/api/coupon/*/page_coupon","/api/coupon/*/new_user_coupon");
 
diff --git a/xdclass-product-service/src/main/java/net/jieyuu/mq/ProductStockMQListener.java b/xdclass-product-service/src/main/java/net/jieyuu/mq/ProductStockMQListener.java
index 508af20..ca4a3bb 100644
--- a/xdclass-product-service/src/main/java/net/jieyuu/mq/ProductStockMQListener.java
+++ b/xdclass-product-service/src/main/java/net/jieyuu/mq/ProductStockMQListener.java
@@ -27,7 +27,7 @@ public class ProductStockMQListener {
     @RabbitHandler
     public void releaseProductStock(ProductMessage productMessage, Message message, Channel channel) throws IOException {
 
-        log.info("监听到消息:releaseProductStock", productMessage);
+        log.info("监听到消息:releaseProductStock消息内容:{}", productMessage);
         long msgTag = message.getMessageProperties().getDeliveryTag();
         boolean flag = productService.releaseProductStock(productMessage);
         // 防止同时解锁多任务并发进入
@@ -51,10 +51,10 @@ public class ProductStockMQListener {
     }
 
 
-//    @RabbitHandler
-//    public void releaseCouponRecord2(String msg, Message message, Channel channel) throws IOException {
-//        log.info(msg);
-//        channel.basicAck(message.getMessageProperties().getDeliveryTag(), true);
-//
-//    }
+    @RabbitHandler
+    public void releaseCouponRecord2(String msg, Message message, Channel channel) throws IOException {
+        log.info(msg);
+        channel.basicAck(message.getMessageProperties().getDeliveryTag(), true);
+
+    }
 }
diff --git a/xdclass-product-service/src/test/java/net/jieyuu/biz/DemoApplicationTests.java b/xdclass-product-service/src/test/java/net/jieyuu/biz/DemoApplicationTests.java
index 78bcf4b..83c7125 100644
--- a/xdclass-product-service/src/test/java/net/jieyuu/biz/DemoApplicationTests.java
+++ b/xdclass-product-service/src/test/java/net/jieyuu/biz/DemoApplicationTests.java
@@ -2,6 +2,8 @@ package net.jieyuu.biz;
 
 import lombok.extern.slf4j.Slf4j;
 import net.jieyuu.ProductApplication;
+import net.jieyuu.model.CouponRecordMessage;
+import net.jieyuu.model.ProductMessage;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
@@ -23,4 +25,12 @@ public class DemoApplicationTests {
       
   }
 
+
+    @Test
+    public void testCouponRecordRelease() {
+        ProductMessage message = new ProductMessage();
+        message.setOutTradeNo("123456abc");
+        message.setTaskId(1l);
+        rabbitTemplate.convertAndSend("stock.event.exchange", "stock.release.delay.routing.key", message);
+    }
 }