在服务启动时根据配置文件是否装载bean

ruoyi-common/ruoyi-common-message/src/main/java/org/dromara/common/message/kafka/aop/aspect/SyncDataToLocalAspect.java

@@ -16,6 +16,7 @@ import org.dromara.common.core.domain.R;
 import org.dromara.common.message.kafka.constant.KafkaTopicConstants;
 import org.dromara.common.satoken.utils.LoginHelper;
 import org.dromara.system.api.model.LoginUser;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
 import org.springframework.stereotype.Component;
 import org.dromara.backstage.api.domain.bo.MessageBo;
 
@@ -32,6 +33,7 @@ import java.util.Map;
 @Slf4j
 @Aspect
 @Component
+@ConditionalOnExpression("'cloud'.equals('${locationFlag}')") // 只在云端时装载bean
 public class SyncDataToLocalAspect {
 
 //    private final KafkaNormalProducer kafkaProducer;

ruoyi-modules/ruoyi-backstage/src/main/java/org/dromara/backstage/mq/KafkaNormalProducer.java

@@ -6,6 +6,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.dromara.backstage.basics.domain.bo.SendMessageRecordBo;
 import org.dromara.backstage.basics.service.ISendMessageRecordService;
+import org.dromara.common.core.utils.StringUtils;
 import org.dromara.common.message.kafka.constant.KafkaTopicConstants;
 import org.dromara.common.message.kafka.domain.KafkaHeader;
 import org.dromara.common.message.kafka.domain.KafkaMessage;
@@ -93,7 +94,11 @@ public class KafkaNormalProducer {
             bo.setEventType(eventType);
             bo.setTenantId(tenantId);
             bo.setResult(result);
-            bo.setMessage(JSON.toJSONString(data));
+            String s = JSON.toJSONString(data);
+            if(StringUtils.isNotBlank(s) && s.length()> 5000){
+                s = s.substring(0,5000);
+            }
+            bo.setMessage(s);
 //            LoginUser loginUser = LoginHelper.getLoginUser();
             bo.setCreateBy(createBy);
             bo.setMqType("kafka");