From b431c0b82897ab8491ba6aee113dafd7ffd91c6d Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=BC=A0=E6=9D=BE?=
 <8605635+zhang3064194730@user.noreply.gitee.com>
Date: Fri, 28 Nov 2025 16:46:25 +0800
Subject: [PATCH] =?UTF-8?q?=E8=AE=A2=E5=8D=95=E8=AF=A6=E6=83=85?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/czg/config/RabbitConfig.java    | 11 +++++++++++
 .../src/main/java/com/czg/config/RabbitConstants.java |  1 +
 .../src/main/java/com/czg/config/RabbitPublisher.java |  8 ++++++++
 .../service/impl/OrderInfoCustomServiceImpl.java      |  2 ++
 4 files changed, 22 insertions(+)

diff --git a/cash-common/cash-common-mq/src/main/java/com/czg/config/RabbitConfig.java b/cash-common/cash-common-mq/src/main/java/com/czg/config/RabbitConfig.java
index 73137b7d0..5ba087dca 100644
--- a/cash-common/cash-common-mq/src/main/java/com/czg/config/RabbitConfig.java
+++ b/cash-common/cash-common-mq/src/main/java/com/czg/config/RabbitConfig.java
@@ -153,4 +153,15 @@ public class RabbitConfig {
     public Binding bindingOrderProductStatusExchange(Queue orderProductStatusQueue, DirectExchange exchange) {
         return BindingBuilder.bind(orderProductStatusQueue).to(exchange).with(activeProfile + "-" + RabbitConstants.Queue.ORDER_PRODUCT_STATUS_QUEUE);
     }
+
+
+    //------------------------------------------------------ 订单详情状态
+    @Bean
+    public Queue orderDetailStatusQueue() {
+        return new Queue(activeProfile + "-" + RabbitConstants.Queue.ORDER_DETAIL_STATUS_QUEUE, true);
+    }
+    @Bean
+    public Binding bindingOrderDetailStatusExchange(Queue orderDetailStatusQueue, DirectExchange exchange) {
+        return BindingBuilder.bind(orderDetailStatusQueue).to(exchange).with(activeProfile + "-" + RabbitConstants.Queue.ORDER_DETAIL_STATUS_QUEUE);
+    }
 }
diff --git a/cash-common/cash-common-mq/src/main/java/com/czg/config/RabbitConstants.java b/cash-common/cash-common-mq/src/main/java/com/czg/config/RabbitConstants.java
index d59ec931e..697b18f56 100644
--- a/cash-common/cash-common-mq/src/main/java/com/czg/config/RabbitConstants.java
+++ b/cash-common/cash-common-mq/src/main/java/com/czg/config/RabbitConstants.java
@@ -23,6 +23,7 @@ public interface RabbitConstants {
          * 订单商品状态队列
          */
         public static final String ORDER_PRODUCT_STATUS_QUEUE = "order.product.status.queue";
+        public static final String ORDER_DETAIL_STATUS_QUEUE = "order.detail.change.queue";
 
         /**
          * 1,2,applySmsTemp  模版审核
diff --git a/cash-common/cash-common-mq/src/main/java/com/czg/config/RabbitPublisher.java b/cash-common/cash-common-mq/src/main/java/com/czg/config/RabbitPublisher.java
index 545c9c1d0..a246fe6ad 100644
--- a/cash-common/cash-common-mq/src/main/java/com/czg/config/RabbitPublisher.java
+++ b/cash-common/cash-common-mq/src/main/java/com/czg/config/RabbitPublisher.java
@@ -128,6 +128,14 @@ public class RabbitPublisher {
         sendMsg(RabbitConstants.Queue.ORDER_PRODUCT_STATUS_QUEUE, qrContent);
     }
 
+
+    /**
+     * 订单商品状态消息
+     */
+    public void sendOrderDetailStatusMsg(String shopId) {
+        sendMsg(RabbitConstants.Queue.ORDER_DETAIL_STATUS_QUEUE, shopId);
+    }
+
     private void sendMsg(String queue, String msg) {
         log.info("开始发送mq消息,exchange:{}, queue: {}, msg: {}", activeProfile + "-" + RabbitConstants.Exchange.CASH_EXCHANGE, activeProfile + "-" + queue, msg);
         rabbitTemplate.convertAndSend(activeProfile + "-" + RabbitConstants.Exchange.CASH_EXCHANGE, activeProfile + "-" + queue, msg);
diff --git a/cash-service/order-service/src/main/java/com/czg/service/order/service/impl/OrderInfoCustomServiceImpl.java b/cash-service/order-service/src/main/java/com/czg/service/order/service/impl/OrderInfoCustomServiceImpl.java
index ce1d20c01..872fd102a 100644
--- a/cash-service/order-service/src/main/java/com/czg/service/order/service/impl/OrderInfoCustomServiceImpl.java
+++ b/cash-service/order-service/src/main/java/com/czg/service/order/service/impl/OrderInfoCustomServiceImpl.java
@@ -1785,6 +1785,8 @@ public class OrderInfoCustomServiceImpl implements OrderInfoCustomService {
                         .eq(OrderDetail::getId, detailStatusDTO.getOrderDetailId()).update();
             }
         }
+
+        rabbitPublisher.sendOrderDetailStatusMsg(shopId.toString());
         return true;
     }
 }