增加消息的公共common

ruoyi-common/ruoyi-common-message/src/main/java/org/dromara/message/kafka/constant/MessageEventTypeEnum.java → ruoyi-common/ruoyi-common-message/src/main/java/org/dromara/common/message/kafka/constant/MessageEventTypeEnum.java

@@ -1,4 +1,4 @@
-package org.dromara.message.kafka.constant;
+package org.dromara.common.message.kafka.constant;
 
 /**
  * 消息 的event type

ruoyi-common/ruoyi-common-message/src/main/java/org/dromara/message/kafka/domain/KafkaHeader.java → ruoyi-common/ruoyi-common-message/src/main/java/org/dromara/common/message/kafka/domain/KafkaHeader.java

@@ -1,4 +1,4 @@
-package org.dromara.message.kafka.domain;
+package org.dromara.common.message.kafka.domain;
 
 import lombok.Data;
 

ruoyi-common/ruoyi-common-message/src/main/java/org/dromara/message/kafka/domain/KafkaMessage.java → ruoyi-common/ruoyi-common-message/src/main/java/org/dromara/common/message/kafka/domain/KafkaMessage.java

@@ -1,4 +1,4 @@
-package org.dromara.message.kafka.domain;
+package org.dromara.common.message.kafka.domain;
 
 import lombok.Data;
 /**

ruoyi-modules/ruoyi-backstage/pom.xml

@@ -120,6 +120,7 @@
         <dependency>
             <groupId>org.dromara</groupId>
             <artifactId>ruoyi-common-message</artifactId>
+            <version>${project.version}</version>
         </dependency>
 
     </dependencies>

ruoyi-server/ruoyi-server-common/pom.xml

@@ -10,7 +10,7 @@
     <artifactId>ruoyi-server-common</artifactId>
     <packaging>jar</packaging>
 
-    <name>ruoyi-server-base</name>
+    <name>ruoyi-server-common</name>
 
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
@@ -21,6 +21,7 @@
         <dependency>
             <groupId>org.dromara</groupId>
             <artifactId>ruoyi-common-message</artifactId>
+            <version>${project.version}</version>
         </dependency>
     </dependencies>
 </project>

ruoyi-server/ruoyi-server-mqdata/src/main/java/org/dromara/server/mq/consumer/KafkaConsumer.java

@@ -2,10 +2,11 @@ package org.dromara.server.mq.consumer;
 
 import cn.hutool.json.JSONObject;
 import cn.hutool.json.JSONUtil;
+import lombok.Data;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.kafka.clients.consumer.ConsumerRecord;
-import org.dromara.message.kafka.domain.KafkaMessage;
+import org.dromara.common.message.kafka.domain.KafkaMessage;
 import org.dromara.server.mq.event.kafka.EventStrategyContext;
 import org.springframework.kafka.annotation.KafkaListener;