From 92d9af40d592141285a444407aac5866a2b3f0e8 Mon Sep 17 00:00:00 2001
From: wangw <1594593906@qq.com>
Date: Wed, 26 Feb 2025 17:51:21 +0800
Subject: [PATCH] =?UTF-8?q?=E8=AE=A2=E5=8D=95=20=E6=89=93=E5=8D=B0?=
 =?UTF-8?q?=E7=A5=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/czg/mq/RabbitMqController.java   | 29 ------------
 .../java/com/czg/mq/RabbitmqReceiver.java     | 44 -------------------
 .../java/com/czg/config/RabbitPublisher.java  |  3 ++
 3 files changed, 3 insertions(+), 73 deletions(-)
 delete mode 100644 cash-api/order-server/src/main/java/com/czg/mq/RabbitMqController.java
 delete mode 100644 cash-api/order-server/src/main/java/com/czg/mq/RabbitmqReceiver.java

diff --git a/cash-api/order-server/src/main/java/com/czg/mq/RabbitMqController.java b/cash-api/order-server/src/main/java/com/czg/mq/RabbitMqController.java
deleted file mode 100644
index c62dee76..00000000
--- a/cash-api/order-server/src/main/java/com/czg/mq/RabbitMqController.java
+++ /dev/null
@@ -1,29 +0,0 @@
-package com.czg.mq;
-
-import com.czg.config.RabbitPublisher;
-import jakarta.annotation.Resource;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-/**
- * @author GYJoker
- */
-@RestController
-public class RabbitMqController {
-
-    @Resource
-    private RabbitPublisher rabbitPublisher;
-
-    @GetMapping("/sendOrderPrintMsg")
-    public String sendOrderPrintMsg(String msg) {
-        rabbitPublisher.sendOrderPrintMsg(msg);
-        return "success";
-    }
-
-    @GetMapping("/sendOrderStockMsg")
-    public String sendOrderStockPrintMsg(String msg) {
-        rabbitPublisher.sendOrderStockMsg(msg);
-        return "success";
-    }
-
-}
diff --git a/cash-api/order-server/src/main/java/com/czg/mq/RabbitmqReceiver.java b/cash-api/order-server/src/main/java/com/czg/mq/RabbitmqReceiver.java
deleted file mode 100644
index c10c340f..00000000
--- a/cash-api/order-server/src/main/java/com/czg/mq/RabbitmqReceiver.java
+++ /dev/null
@@ -1,44 +0,0 @@
-//package com.czg.mq;
-//
-//import com.czg.config.RabbitConstants;
-//import com.rabbitmq.client.Channel;
-//import lombok.extern.slf4j.Slf4j;
-//import org.springframework.amqp.core.Message;
-//import org.springframework.amqp.rabbit.annotation.*;
-//import org.springframework.stereotype.Component;
-//
-//import java.io.IOException;
-//
-///**
-// * @author GYJoker
-// */
-//@Slf4j
-//@Component
-//public class RabbitmqReceiver {
-//
-//    /**
-//     * 消费者监听，绑定队列
-//     * Queue RabbitConfig类的 orderPrintQueue
-//     */
-//    @RabbitListener(
-//            bindings = @QueueBinding(value = @Queue(value = "#{orderPrintQueue.name}", durable = "true",
-//                    arguments = {@Argument(name = "x-message-ttl", value = "180000", type = "java.lang.Long")}),
-//                    exchange = @Exchange(value = RabbitConstants.Exchange.CASH_EXCHANGE)),
-//            concurrency = "10"
-//    )
-//    @RabbitHandler
-//    public void receiveOrderPrintQueue(Channel channel, String orderId, Message message) throws IOException {
-//        try {
-//            log.info("订单监听 消息体：{},消息内容：{}", message, orderId);
-//            // 手动确认消息，multiple 参数表示是否批量确认
-//            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
-//        } catch (Exception e) {
-//            log.error(e.getMessage(), e);
-//            // 判断是否需要重新入队
-//            boolean requeue = false;
-//            // 拒绝消息，requeue 为 true 表示将消息重新放回队列
-//            channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, requeue);
-//        }
-//
-//    }
-//}
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 34777a77..1337934b 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
@@ -39,6 +39,9 @@ public class RabbitPublisher {
      * @param orderId 订单id
      */
     public void sendOrderPrintMsg(String orderId) {
+        //厨房票
+        sendMsg(RabbitConstants.Queue.ORDER_MACHINE_PRINT_QUEUE, orderId);
+        //前台票
         sendMsg(RabbitConstants.Queue.ORDER_PRINT_QUEUE, orderId);
     }