From dd3e09307bdf79935f0349a18fba5884657fd0e3 Mon Sep 17 00:00:00 2001
From: wuxicheng <1441859745@qq.com>
Date: Sun, 21 May 2023 13:16:00 +0800
Subject: [PATCH] =?UTF-8?q?bug=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../common/rocketmq/template/RocketMQEnhanceTemplate.java | 8 ++++----
 .../service/impl/OrderMqMessageRecordServiceImpl.java     | 8 ++++----
 2 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/bnyer-common/bnyer-common-rocketmq/src/main/java/com/bnyer/common/rocketmq/template/RocketMQEnhanceTemplate.java b/bnyer-common/bnyer-common-rocketmq/src/main/java/com/bnyer/common/rocketmq/template/RocketMQEnhanceTemplate.java
index 0c00482..9b9e0f2 100644
--- a/bnyer-common/bnyer-common-rocketmq/src/main/java/com/bnyer/common/rocketmq/template/RocketMQEnhanceTemplate.java
+++ b/bnyer-common/bnyer-common-rocketmq/src/main/java/com/bnyer/common/rocketmq/template/RocketMQEnhanceTemplate.java
@@ -107,12 +107,12 @@ public class RocketMQEnhanceTemplate {
             @Override
             public void onSuccess(SendResult sendResult) {
                 // 处理消息发送成功逻辑
-                log.info("消息发送成功,topic:{},tag:{},result:{}",topic,tag, JSON.toJSONString(sendResult));
+                log.info("消息发送成功,topic:{},tag:{},message:{},result:{}",topic,tag,message, JSON.toJSONString(sendResult));
             }
             @Override
             public void onException(Throwable throwable) {
                 // 处理消息发送失败逻辑
-                log.error("消息发送失败,topic:{},tag:{},error:{}",topic,tag,throwable.getMessage());
+                log.error("消息发送失败,topic:{},tag:{},message:{},error:{}",topic,tag,message,throwable.getMessage());
             }
         });
     }
@@ -126,11 +126,11 @@ public class RocketMQEnhanceTemplate {
             @Override
             public void onSuccess(SendResult sendResult) {
                 // 处理消息发送成功逻辑
-                log.info("消息发送成功,topic:{},tag:{},result:{}",topic,tag,JSON.toJSONString(sendResult));
+                log.info("消息发送成功,topic:{},tag:{},message:{},result:{}",topic,tag,message,JSON.toJSONString(sendResult));
             }
             @Override
             public void onException(Throwable throwable) {
-                log.error("消息发送失败,topic:{},tag:{},error:{}",topic,tag,throwable.getMessage());
+                log.error("消息发送失败,topic:{},tag:{},message:{},error:{}",topic,tag,message,throwable.getMessage());
             }
         },10000,delayLevel);
     }
diff --git a/bnyer-services/bnyer-order/src/main/java/com/bnyer/order/service/impl/OrderMqMessageRecordServiceImpl.java b/bnyer-services/bnyer-order/src/main/java/com/bnyer/order/service/impl/OrderMqMessageRecordServiceImpl.java
index 8981048..deec04a 100644
--- a/bnyer-services/bnyer-order/src/main/java/com/bnyer/order/service/impl/OrderMqMessageRecordServiceImpl.java
+++ b/bnyer-services/bnyer-order/src/main/java/com/bnyer/order/service/impl/OrderMqMessageRecordServiceImpl.java
@@ -93,11 +93,11 @@ public class OrderMqMessageRecordServiceImpl implements OrderMqMessageRecordServ
         rocketMQTemplate.asyncSend(rocketMQEnhanceTemplate.buildDestination(topic,tag), MessageBuilder.withPayload(mqLocalMessage).build(), new SendCallback() {
             @Override
             public void onSuccess(SendResult sendResult) {
-                log.info("消息发送成功,topic:{},tag:{},result:{}",topic,tag, JSON.toJSONString(sendResult));
+                log.info("消息发送成功,topic:{},tag:{},message:{},result:{}",topic,tag,message, JSON.toJSONString(sendResult));
             }
             @Override
             public void onException(Throwable throwable) {
-                log.error("消息发送失败,topic:{},tag:{},error:{}",topic,tag,throwable.getMessage());
+                log.error("消息发送失败,topic:{},tag:{},message:{},error:{}",topic,tag,message,throwable.getMessage());
                 log.info("消息发送失败，更新消息记录，等待定时任务进行消息补偿");
                 orderMqMessageRecord.setErrMsg(throwable.getMessage());
                 editMessageRecordStatus(orderMqMessageRecord.getId(),orderMqMessageRecord.getStatus(),orderMqMessageRecord.getErrMsg());
@@ -122,11 +122,11 @@ public class OrderMqMessageRecordServiceImpl implements OrderMqMessageRecordServ
         rocketMQTemplate.asyncSend(rocketMQEnhanceTemplate.buildDestination(topic,tag), MessageBuilder.withPayload(mqLocalMessage).build(), new SendCallback() {
             @Override
             public void onSuccess(SendResult sendResult) {
-                log.info("消息发送成功,topic:{},tag:{},result:{}",topic,tag,JSON.toJSONString(sendResult));
+                log.info("消息发送成功,topic:{},tag:{},message:{},result:{}",topic,tag,message,JSON.toJSONString(sendResult));
             }
             @Override
             public void onException(Throwable throwable) {
-                log.error("消息发送失败,topic:{},tag:{},error:{}",topic,tag,throwable.getMessage());
+                log.error("消息发送失败,topic:{},tag:{},message:{},error:{}",topic,tag,message,throwable.getMessage());
                 log.info("消息发送失败，更新消息记录，等待定时任务进行消息补偿");
                 editMessageRecordStatus(orderMqMessageRecord.getId(),orderMqMessageRecord.getStatus(),throwable.getMessage());
             }