bug修复

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);
     }

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());
             }