From 0b4c658f7c085ad3ba83c1808960d9f7b6cb9d7b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=9F=A9=E9=B9=8F=E8=BE=89?= <18322780655@163.com>
Date: Fri, 28 Jun 2024 10:27:34 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E8=80=97=E6=9D=90?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../cashierservice/rabbit/RabbitConfig.java    | 18 ++++++++++++++++++
 .../cashierservice/rabbit/RabbitConstants.java | 10 ++++++++++
 .../cashierservice/rabbit/RabbitProducer.java  |  5 ++++-
 .../cashierservice/service/CartService.java    | 10 ++++++++++
 4 files changed, 42 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/RabbitConfig.java b/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/RabbitConfig.java
index e4be5fb..3b53083 100644
--- a/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/RabbitConfig.java
+++ b/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/RabbitConfig.java
@@ -114,4 +114,22 @@ public class RabbitConfig {
     public Binding bindingcons_Register() {
         return BindingBuilder.bind(queuePrint_Register()).to(printExchange_Register()).with(RabbitConstants.CONS_COLLECT_ROUTINGKEY_PUT);
     }
+
+
+    @Bean
+    public DirectExchange cons_msg_Exchange_Register() {
+        return new DirectExchange(RabbitConstants.CONS_MSG_COLLECT_PUT);
+    }
+
+    @Bean
+    public Queue queuecons_msg_Register() {
+        return new Queue(RabbitConstants.CONS_MSG_COLLECT_QUEUE_PUT, true); //队列持久
+    }
+
+    @Bean
+    public Binding bindingcons_msg_Register() {
+        return BindingBuilder.bind(queuePrint_Register()).to(printExchange_Register()).with(RabbitConstants.CONS_MSG_COLLECT_ROUTINGKEY_PUT);
+    }
+
+
 }
\ No newline at end of file
diff --git a/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/RabbitConstants.java b/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/RabbitConstants.java
index e60473e..b805fd1 100644
--- a/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/RabbitConstants.java
+++ b/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/RabbitConstants.java
@@ -49,4 +49,14 @@ public interface RabbitConstants {
 
 
 	public static final String CONS_COLLECT_ROUTINGKEY_PUT = "cons_collect_routingkey_put";
+
+
+	public static final String CONS_MSG_COLLECT_PUT="cons_msg_collect_put";
+
+	public static final String CONS_MSG_COLLECT_QUEUE_PUT = "cons_msg_collect_queue_put";
+
+
+	public static final String CONS_MSG_COLLECT_ROUTINGKEY_PUT = "cons_msg_collect_routingkey_put";
+
+
 }
diff --git a/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/RabbitProducer.java b/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/RabbitProducer.java
index e301c58..d45aea8 100644
--- a/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/RabbitProducer.java
+++ b/src/main/java/com/chaozhanggui/system/cashierservice/rabbit/RabbitProducer.java
@@ -51,7 +51,10 @@ public class RabbitProducer implements RabbitTemplate.ConfirmCallback  {
         rabbitTemplate.convertAndSend(RabbitConstants.CONS_COLLECT_PUT, RabbitConstants.CONS_COLLECT_ROUTINGKEY_PUT, content, correlationId);
     }
 
-
+    public void con_msg(String content){
+        CorrelationData correlationId = new CorrelationData(UUID.randomUUID().toString());
+        rabbitTemplate.convertAndSend(RabbitConstants.CONS_MSG_COLLECT_PUT, RabbitConstants.CONS_MSG_COLLECT_ROUTINGKEY_PUT, content, correlationId);
+    }
 
     @Override
     public void confirm(CorrelationData correlationData, boolean ack, String cause) {
diff --git a/src/main/java/com/chaozhanggui/system/cashierservice/service/CartService.java b/src/main/java/com/chaozhanggui/system/cashierservice/service/CartService.java
index 90fbdcc..2484e5e 100644
--- a/src/main/java/com/chaozhanggui/system/cashierservice/service/CartService.java
+++ b/src/main/java/com/chaozhanggui/system/cashierservice/service/CartService.java
@@ -117,6 +117,16 @@ public class CartService {
             TbProductSkuWithBLOBs tbProductSkuWithBLOBs = productSkuMapper.selectByPrimaryKey(Integer.valueOf(skuId));
 
 
+
+
+            JSONObject objectMsg=new JSONObject();
+            objectMsg.put("skuId",tbProductSkuWithBLOBs.getId());
+            objectMsg.put("shopId",Integer.valueOf(shopId));
+
+
+            producer.con_msg(objectMsg.toString());
+
+
             if (Integer.valueOf(tbProduct.getIsPauseSale()).equals(1)) {
                 JSONObject jsonObject1 = new JSONObject();
                 jsonObject1.put("status", "fail");