From 7ded360e7c442105871046d84a35ebe146b8f91f Mon Sep 17 00:00:00 2001
From: jieyuu <645634619@qq.com>
Date: Tue, 27 Aug 2024 22:08:38 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8F=91=E9=80=81task=E8=87=B3=E5=BB=B6?=
 =?UTF-8?q?=E8=BF=9F=E9=98=9F=E5=88=97=E5=BC=80=E5=8F=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../net/jieyuu/model/CouponRecordMessage.java | 23 +++++++++++++++++++
 .../service/impl/CouponRecordServiceImpl.java | 20 ++++++++++++++--
 2 files changed, 41 insertions(+), 2 deletions(-)
 create mode 100644 xdclass-common/src/main/java/net/jieyuu/model/CouponRecordMessage.java

diff --git a/xdclass-common/src/main/java/net/jieyuu/model/CouponRecordMessage.java b/xdclass-common/src/main/java/net/jieyuu/model/CouponRecordMessage.java
new file mode 100644
index 0000000..f0ef710
--- /dev/null
+++ b/xdclass-common/src/main/java/net/jieyuu/model/CouponRecordMessage.java
@@ -0,0 +1,23 @@
+package net.jieyuu.model;
+
+import lombok.Data;
+
+@Data
+public class CouponRecordMessage {
+
+    /**
+     * 消息队列id
+     */
+    private Long messageId;
+
+    /**
+     * 订单号
+     */
+    private String outTradeNo;
+
+    /**
+     * 库存锁定工作单id
+     */
+    private Long taskId;
+
+}
\ No newline at end of file
diff --git a/xdclass-coupon-service/src/main/java/net/jieyuu/service/impl/CouponRecordServiceImpl.java b/xdclass-coupon-service/src/main/java/net/jieyuu/service/impl/CouponRecordServiceImpl.java
index e51f5ea..4dda75e 100644
--- a/xdclass-coupon-service/src/main/java/net/jieyuu/service/impl/CouponRecordServiceImpl.java
+++ b/xdclass-coupon-service/src/main/java/net/jieyuu/service/impl/CouponRecordServiceImpl.java
@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import lombok.extern.slf4j.Slf4j;
 import net.jieyuu.config.InterceptorConfig;
+import net.jieyuu.config.RabbitMQConfig;
 import net.jieyuu.enums.BizCodeEnum;
 import net.jieyuu.enums.CouponStateEnum;
 import net.jieyuu.enums.StockTaskStateEnum;
@@ -13,6 +14,7 @@ import net.jieyuu.interceptor.LoginInterceptor;
 import net.jieyuu.mapper.CouponTaskMapper;
 import net.jieyuu.model.CouponRecordDO;
 import net.jieyuu.mapper.CouponRecordMapper;
+import net.jieyuu.model.CouponRecordMessage;
 import net.jieyuu.model.CouponTaskDO;
 import net.jieyuu.model.LoginUser;
 import net.jieyuu.request.LockCouponRecordRequest;
@@ -20,6 +22,7 @@ import net.jieyuu.service.CouponRecordService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import net.jieyuu.utils.JsonData;
 import net.jieyuu.vo.CouponRecordVO;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -47,6 +50,11 @@ public class CouponRecordServiceImpl extends ServiceImpl<CouponRecordMapper, Cou
     @Autowired
     private CouponTaskMapper couponTaskMapper;
 
+    @Autowired
+    private RabbitTemplate rabbitTemplate;
+    @Autowired
+    private RabbitMQConfig rabbitMQConfig;
+
     @Override
     public Map<String, Object> page(int page, int size) {
         LoginUser loginUser = LoginInterceptor.threadLocal.get();
@@ -111,8 +119,16 @@ public class CouponRecordServiceImpl extends ServiceImpl<CouponRecordMapper, Cou
 
         //mq延迟队列投递
         if (insertRows == couponTaskDOList.size() && insertRows == updateRows) {
-            //发送延迟消息 TODO
-
+            //发送延迟消息
+            for (CouponTaskDO couponTaskDO : couponTaskDOList) {
+                // 构建CouponRecordMessage
+                CouponRecordMessage couponRecordMessage = new CouponRecordMessage();
+                couponRecordMessage.setOutTradeNo(orderOutTradeNo);
+                couponRecordMessage.setTaskId(couponTaskDO.getId());
+                // 传入交换机 投入延迟队列
+                rabbitTemplate.convertAndSend(rabbitMQConfig.getEventExchange(), rabbitMQConfig.getCouponReleaseDelayRoutingKey(), couponRecordMessage);
+                log.info("优惠券锁定消息发送成功:{}", couponRecordMessage.toString());
+            }
             return JsonData.buildSuccess();
         } else {
             throw new BizException(BizCodeEnum.COUPON_RECORD_LOCK_FAIL);