diff --git a/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/orderCatch/OrderMessageConsumer.java b/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/orderCatch/OrderMessageConsumer.java
index f8fed81370..93327f25ed 100644
--- a/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/orderCatch/OrderMessageConsumer.java
+++ b/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/orderCatch/OrderMessageConsumer.java
@@ -1,8 +1,8 @@
 package cn.iocoder.yudao.module.haoka.service.orderCatch;
 
+import cn.hutool.json.JSONUtil;
 import cn.iocoder.yudao.framework.tenant.core.context.TenantContextHolder;
 import cn.iocoder.yudao.module.haoka.controller.admin.orderCatch.po.DouDianOrderMessage;
-import com.doudian.open.utils.JsonUtil;
 import jakarta.annotation.Resource;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.rabbit.annotation.Queue;
@@ -21,11 +21,12 @@ public class OrderMessageConsumer {
     private OrderCatchService orderCatchService;
 
     @RabbitListener(queuesToDeclare = { @Queue(value = DouDianOrderMessage.QUEUE,durable = "true", autoDelete = "false") }, ackMode = "MANUAL")
-    public void onMessage(DouDianOrderMessage message, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag) {
+    public void onMessage(String message, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag) {
         try {
-            log.info("[onMessage][消息内容({})]", JsonUtil.toJson(message));
+            log.info("[onMessage][消息内容({})]", message);
             TenantContextHolder.setTenantId(162L);
-            orderCatchService.catchOrders(message.getMessages());
+            DouDianOrderMessage orderMessage = JSONUtil.toBean(message, DouDianOrderMessage.class);
+            orderCatchService.catchOrders(orderMessage.getMessages());
             // 手动确认消息
             channel.basicAck(deliveryTag, false);
         } catch (Exception e) {
diff --git a/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/orderCatch/OrderMessageProducer.java b/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/orderCatch/OrderMessageProducer.java
index 98929b6618..f5c821087c 100644
--- a/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/orderCatch/OrderMessageProducer.java
+++ b/yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/orderCatch/OrderMessageProducer.java
@@ -1,5 +1,6 @@
 package cn.iocoder.yudao.module.haoka.service.orderCatch;
 
+import cn.hutool.json.JSONUtil;
 import cn.iocoder.yudao.module.haoka.controller.admin.orderCatch.po.DouDianOrderMessage;
 import cn.iocoder.yudao.module.haoka.controller.admin.orderCatch.po.Message;
 import jakarta.annotation.Resource;
@@ -9,6 +10,7 @@ import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.stereotype.Component;
 
 import java.util.List;
+import java.util.Optional;
 import java.util.UUID;
 
 @Slf4j
@@ -27,6 +29,8 @@ public class OrderMessageProducer {
         message.setMessages(messages);
         // 为消息添加唯一ID
         CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
-        rabbitTemplate.convertAndSend(DouDianOrderMessage.QUEUE, message, correlationData);
+        String jsonStr = JSONUtil.toJsonStr(message);
+        log.error("订单消息内容：{}", jsonStr);
+        rabbitTemplate.convertAndSend(DouDianOrderMessage.QUEUE, Optional.ofNullable(jsonStr), correlationData);
     }
 }
\ No newline at end of file