bug修复

bnyer-common/bnyer-common-rocketmq/src/main/java/com/bnyer/common/rocketmq/domain/BaseMessage.java

@@ -42,6 +42,6 @@ public class BaseMessage {
     /**
      * 重试次数，用于判断重试次数，超过重试次数发送异常警告
      */
-    protected Integer retryTimes;
+    protected Integer retryTimes = 0;
 
 }

bnyer-common/bnyer-common-rocketmq/src/main/java/com/bnyer/common/rocketmq/template/RocketMQEnhanceTemplate.java

@@ -47,7 +47,7 @@ public class RocketMQEnhanceTemplate {
      * 根据环境重新隔离topic
      * @param topic 原始topic
      */
-    private String reBuildTopic(String topic) {
+    public String reBuildTopic(String topic) {
         if(rocketEnhanceProperties.isEnabledIsolation() && StringUtils.isNoneBlank(rocketEnhanceProperties.getEnvironment())){
             return topic +"-" + rocketEnhanceProperties.getEnvironment();
         }

bnyer-services/bnyer-order/src/main/java/com/bnyer/order/service/impl/OrderMqMessageRecordServiceImpl.java

@@ -106,6 +106,7 @@ public class OrderMqMessageRecordServiceImpl implements OrderMqMessageRecordServ
      */
     @Transactional
     public <T> OrderMqMessageRecord saveMessageRecord(String topic, String tag, T message){
+        topic = rocketMQEnhanceTemplate.reBuildTopic(topic);
         OrderMqMessageRecord orderMqMessageRecord = new OrderMqMessageRecord();
         orderMqMessageRecord.setStatus(EnumMessageStatus.PROCESS);
         orderMqMessageRecord.setConsumerGroupName(topic);