From c08cb87e094603007957c667c51b641eb392ce9f Mon Sep 17 00:00:00 2001
From: xy <748613696@qq.com>
Date: Thu, 16 Jan 2025 16:20:43 +0800
Subject: [PATCH] =?UTF-8?q?=E9=A1=B9=E7=9B=AE=E5=88=9D=E5=A7=8B=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
README.md | 8 +-
algorithm/algorithm-api/pom.xml | 20 +
algorithm/algorithm-boot/pom.xml | 107 +++++
.../algorithm/AlgorithmBootApplication.java | 21 +
.../src/main/resources/bootstrap.yml | 51 +++
.../test/java/com/njcn/algorithm/AppTest.java | 38 ++
algorithm/pom.xml | 26 ++
analysis/event/event-api/pom.xml | 20 +
analysis/event/event-boot/pom.xml | 107 +++++
.../com/njcn/event/EventBootApplication.java | 21 +
.../src/main/resources/bootstrap.yml | 51 +++
.../src/test/java/com/njcn/event/AppTest.java | 38 ++
analysis/event/pom.xml | 27 ++
analysis/pom.xml | 27 ++
analysis/rt/pom.xml | 26 ++
analysis/rt/rt-api/pom.xml | 20 +
analysis/rt/rt-boot/pom.xml | 107 +++++
.../java/com/njcn/rt/RtBootApplication.java | 21 +
.../rt-boot/src/main/resources/bootstrap.yml | 51 +++
.../src/test/java/com/njcn/rt/AppTest.java | 38 ++
analysis/stat/pom.xml | 27 ++
analysis/stat/stat-api/pom.xml | 20 +
analysis/stat/stat-boot/pom.xml | 107 +++++
.../com/njcn/stat/StatBootApplication.java | 21 +
.../src/main/resources/bootstrap.yml | 51 +++
.../src/test/java/com/njcn/stat/AppTest.java | 38 ++
data-processing/data-processing-api/pom.xml | 20 +
data-processing/data-processing-data/pom.xml | 107 +++++
.../DataProcessBootApplication.java | 21 +
.../src/main/resources/bootstrap.yml | 51 +++
.../java/com/njcn/dataProcess/AppTest.java | 38 ++
data-processing/pom.xml | 27 ++
log/log-api/pom.xml | 28 ++
log/log-boot/pom.xml | 108 +++++
.../java/com/njcn/log/LogBootApplication.java | 21 +
log/log-boot/src/main/resources/bootstrap.yml | 51 +++
.../src/test/java/com/njcn/log/AppTest.java | 38 ++
log/pom.xml | 26 ++
message/message-api/pom.xml | 21 +
message/message-boot/pom.xml | 107 +++++
.../njcn/message/MessageBootApplication.java | 21 +
.../src/main/resources/bootstrap.yml | 51 +++
.../test/java/com/njcn/message/AppTest.java | 38 ++
message/pom.xml | 27 ++
pom.xml | 416 ++++++++++++++++++
45 files changed, 2305 insertions(+), 1 deletion(-)
create mode 100644 algorithm/algorithm-api/pom.xml
create mode 100644 algorithm/algorithm-boot/pom.xml
create mode 100644 algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/AlgorithmBootApplication.java
create mode 100644 algorithm/algorithm-boot/src/main/resources/bootstrap.yml
create mode 100644 algorithm/algorithm-boot/src/test/java/com/njcn/algorithm/AppTest.java
create mode 100644 algorithm/pom.xml
create mode 100644 analysis/event/event-api/pom.xml
create mode 100644 analysis/event/event-boot/pom.xml
create mode 100644 analysis/event/event-boot/src/main/java/com/njcn/event/EventBootApplication.java
create mode 100644 analysis/event/event-boot/src/main/resources/bootstrap.yml
create mode 100644 analysis/event/event-boot/src/test/java/com/njcn/event/AppTest.java
create mode 100644 analysis/event/pom.xml
create mode 100644 analysis/pom.xml
create mode 100644 analysis/rt/pom.xml
create mode 100644 analysis/rt/rt-api/pom.xml
create mode 100644 analysis/rt/rt-boot/pom.xml
create mode 100644 analysis/rt/rt-boot/src/main/java/com/njcn/rt/RtBootApplication.java
create mode 100644 analysis/rt/rt-boot/src/main/resources/bootstrap.yml
create mode 100644 analysis/rt/rt-boot/src/test/java/com/njcn/rt/AppTest.java
create mode 100644 analysis/stat/pom.xml
create mode 100644 analysis/stat/stat-api/pom.xml
create mode 100644 analysis/stat/stat-boot/pom.xml
create mode 100644 analysis/stat/stat-boot/src/main/java/com/njcn/stat/StatBootApplication.java
create mode 100644 analysis/stat/stat-boot/src/main/resources/bootstrap.yml
create mode 100644 analysis/stat/stat-boot/src/test/java/com/njcn/stat/AppTest.java
create mode 100644 data-processing/data-processing-api/pom.xml
create mode 100644 data-processing/data-processing-data/pom.xml
create mode 100644 data-processing/data-processing-data/src/main/java/com/njcn/dataProcess/DataProcessBootApplication.java
create mode 100644 data-processing/data-processing-data/src/main/resources/bootstrap.yml
create mode 100644 data-processing/data-processing-data/src/test/java/com/njcn/dataProcess/AppTest.java
create mode 100644 data-processing/pom.xml
create mode 100644 log/log-api/pom.xml
create mode 100644 log/log-boot/pom.xml
create mode 100644 log/log-boot/src/main/java/com/njcn/log/LogBootApplication.java
create mode 100644 log/log-boot/src/main/resources/bootstrap.yml
create mode 100644 log/log-boot/src/test/java/com/njcn/log/AppTest.java
create mode 100644 log/pom.xml
create mode 100644 message/message-api/pom.xml
create mode 100644 message/message-boot/pom.xml
create mode 100644 message/message-boot/src/main/java/com/njcn/message/MessageBootApplication.java
create mode 100644 message/message-boot/src/main/resources/bootstrap.yml
create mode 100644 message/message-boot/src/test/java/com/njcn/message/AppTest.java
create mode 100644 message/pom.xml
create mode 100644 pom.xml
diff --git a/README.md b/README.md
index 1cc39ef..87b8e91 100644
--- a/README.md
+++ b/README.md
@@ -1,3 +1,9 @@
# cn-data-platform
-灿能数据处理平台
\ No newline at end of file
+灿能数据处理平台
+
+data-processing 数据处理模块,主要用于对外提供数据,以及接收数据入库。
+message 消息处理模块,主要用于处理各类消息。
+analysis 数据解析模块,用来解析装置上送的各类数据。
+algorithm 算法模块,用来计算装置数据、业务数据。
+log 日志模块,用来存储各类日志。
\ No newline at end of file
diff --git a/algorithm/algorithm-api/pom.xml b/algorithm/algorithm-api/pom.xml
new file mode 100644
index 0000000..b85bcb5
--- /dev/null
+++ b/algorithm/algorithm-api/pom.xml
@@ -0,0 +1,20 @@
+
+ 4.0.0
+
+ com.njcn
+ algorithm
+ 1.0.0
+
+
+ algorithm-api
+
+ algorithm-api
+
+
+ UTF-8
+ 8
+ 8
+
+
+
diff --git a/algorithm/algorithm-boot/pom.xml b/algorithm/algorithm-boot/pom.xml
new file mode 100644
index 0000000..3dbafb2
--- /dev/null
+++ b/algorithm/algorithm-boot/pom.xml
@@ -0,0 +1,107 @@
+
+ 4.0.0
+
+ com.njcn
+ algorithm
+ 1.0.0
+
+
+ algorithm-boot
+
+ algorithm-boot
+
+
+ UTF-8
+ 8
+ 8
+
+
+
+
+ com.njcn
+ common-web
+ ${project.version}
+
+
+ com.njcn
+ common-core
+ ${project.version}
+
+
+ com.njcn
+ common-swagger
+ ${project.version}
+
+
+ org.mybatis
+ mybatis-spring
+ 2.0.5
+
+
+
+
+ algorithmboot
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+ 3.8.0
+
+ -Xlint:unchecked
+
+
+
+ org.springframework.boot
+ spring-boot-maven-plugin
+
+
+ package
+
+ repackage
+
+
+
+
+
+
+ com.spotify
+ docker-maven-plugin
+ 1.2.2
+
+
+
+ build-image
+ ${docker.operate}
+
+ build
+
+
+
+
+
+ http://${docker.repostory}
+
+ ${docker.repostory}/${docker.registry.name}/${project.artifactId}
+
+
+ latest
+
+
+ ${docker.url}
+ ${basedir}/
+
+
+
+ /ROOT
+
+ ${project.build.directory}
+
+ ${project.build.finalName}.jar
+
+
+
+
+
+
+
diff --git a/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/AlgorithmBootApplication.java b/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/AlgorithmBootApplication.java
new file mode 100644
index 0000000..ab750da
--- /dev/null
+++ b/algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/AlgorithmBootApplication.java
@@ -0,0 +1,21 @@
+package com.njcn.algorithm;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+
+
+/**
+ * @author xy
+ */
+@Slf4j
+@EnableFeignClients(basePackages = "com.njcn")
+@SpringBootApplication(scanBasePackages = "com.njcn")
+public class AlgorithmBootApplication {
+
+ public static void main(String[] args) {
+ SpringApplication.run(AlgorithmBootApplication.class, args);
+ }
+
+}
diff --git a/algorithm/algorithm-boot/src/main/resources/bootstrap.yml b/algorithm/algorithm-boot/src/main/resources/bootstrap.yml
new file mode 100644
index 0000000..ab4f921
--- /dev/null
+++ b/algorithm/algorithm-boot/src/main/resources/bootstrap.yml
@@ -0,0 +1,51 @@
+#当前服务的基本信息
+microservice:
+ ename: @artifactId@
+ name: '@name@'
+ version: @version@
+ sentinel:
+ url: @sentinel.url@
+ gateway:
+ url: @gateway.url@
+server:
+ port: 10401
+#feign接口开启服务熔断降级处理
+feign:
+ sentinel:
+ enabled: true
+spring:
+ application:
+ name: @artifactId@
+ cloud:
+ nacos:
+ discovery:
+ ip: @service.server.url@
+ server-addr: @nacos.url@
+ namespace: @nacos.namespace@
+ config:
+ server-addr: @nacos.url@
+ namespace: @nacos.namespace@
+ file-extension: yaml
+ shared-configs:
+ - data-id: share-config.yaml
+ refresh: true
+ - data-Id: algorithm-config.yaml
+ refresh: true
+ main:
+ allow-bean-definition-overriding: true
+
+
+#项目日志的配置
+logging:
+ config: http://@nacos.url@/nacos/v1/cs/configs?tenant=@nacos.namespace@&group=DEFAULT_GROUP&dataId=logback.xml
+ level:
+ root: info
+
+
+#mybatis配置信息
+mybatis-plus:
+ #别名扫描
+ type-aliases-package: com.njcn.harmonic.pojo
+
+mqtt:
+ client-id: @artifactId@${random.value}
\ No newline at end of file
diff --git a/algorithm/algorithm-boot/src/test/java/com/njcn/algorithm/AppTest.java b/algorithm/algorithm-boot/src/test/java/com/njcn/algorithm/AppTest.java
new file mode 100644
index 0000000..19fc48f
--- /dev/null
+++ b/algorithm/algorithm-boot/src/test/java/com/njcn/algorithm/AppTest.java
@@ -0,0 +1,38 @@
+package com.njcn.algorithm;
+
+import junit.framework.Test;
+import junit.framework.TestCase;
+import junit.framework.TestSuite;
+
+/**
+ * Unit test for simple App.
+ */
+public class AppTest
+ extends TestCase
+{
+ /**
+ * Create the test case
+ *
+ * @param testName name of the test case
+ */
+ public AppTest( String testName )
+ {
+ super( testName );
+ }
+
+ /**
+ * @return the suite of tests being tested
+ */
+ public static Test suite()
+ {
+ return new TestSuite( AppTest.class );
+ }
+
+ /**
+ * Rigourous Test :-)
+ */
+ public void testApp()
+ {
+ assertTrue( true );
+ }
+}
diff --git a/algorithm/pom.xml b/algorithm/pom.xml
new file mode 100644
index 0000000..f52443c
--- /dev/null
+++ b/algorithm/pom.xml
@@ -0,0 +1,26 @@
+
+ 4.0.0
+
+ com.njcn
+ cn-data-platform
+ 1.0.0
+
+
+ algorithm
+ pom
+
+ algorithm
+ 算法模块
+
+ algorithm-api
+ algorithm-boot
+
+
+
+ UTF-8
+ 8
+ 8
+
+
+
diff --git a/analysis/event/event-api/pom.xml b/analysis/event/event-api/pom.xml
new file mode 100644
index 0000000..565539a
--- /dev/null
+++ b/analysis/event/event-api/pom.xml
@@ -0,0 +1,20 @@
+
+ 4.0.0
+
+ com.njcn
+ event
+ 1.0.0
+
+
+ event-api
+
+ event-api
+
+
+ UTF-8
+ 8
+ 8
+
+
+
diff --git a/analysis/event/event-boot/pom.xml b/analysis/event/event-boot/pom.xml
new file mode 100644
index 0000000..daeac78
--- /dev/null
+++ b/analysis/event/event-boot/pom.xml
@@ -0,0 +1,107 @@
+
+ 4.0.0
+
+ com.njcn
+ event
+ 1.0.0
+
+
+ event-boot
+
+ event-boot
+
+
+ UTF-8
+ 8
+ 8
+
+
+
+
+ com.njcn
+ common-web
+ ${project.version}
+
+
+ com.njcn
+ common-core
+ ${project.version}
+
+
+ com.njcn
+ common-swagger
+ ${project.version}
+
+
+ org.mybatis
+ mybatis-spring
+ 2.0.5
+
+
+
+
+ eventboot
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+ 3.8.0
+
+ -Xlint:unchecked
+
+
+
+ org.springframework.boot
+ spring-boot-maven-plugin
+
+
+ package
+
+ repackage
+
+
+
+
+
+
+ com.spotify
+ docker-maven-plugin
+ 1.2.2
+
+
+
+ build-image
+ ${docker.operate}
+
+ build
+
+
+
+
+
+ http://${docker.repostory}
+
+ ${docker.repostory}/${docker.registry.name}/${project.artifactId}
+
+
+ latest
+
+
+ ${docker.url}
+ ${basedir}/
+
+
+
+ /ROOT
+
+ ${project.build.directory}
+
+ ${project.build.finalName}.jar
+
+
+
+
+
+
+
diff --git a/analysis/event/event-boot/src/main/java/com/njcn/event/EventBootApplication.java b/analysis/event/event-boot/src/main/java/com/njcn/event/EventBootApplication.java
new file mode 100644
index 0000000..5813ee6
--- /dev/null
+++ b/analysis/event/event-boot/src/main/java/com/njcn/event/EventBootApplication.java
@@ -0,0 +1,21 @@
+package com.njcn.event;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+
+
+/**
+ * @author xy
+ */
+@Slf4j
+@EnableFeignClients(basePackages = "com.njcn")
+@SpringBootApplication(scanBasePackages = "com.njcn")
+public class EventBootApplication {
+
+ public static void main(String[] args) {
+ SpringApplication.run(EventBootApplication.class, args);
+ }
+
+}
diff --git a/analysis/event/event-boot/src/main/resources/bootstrap.yml b/analysis/event/event-boot/src/main/resources/bootstrap.yml
new file mode 100644
index 0000000..da86ebe
--- /dev/null
+++ b/analysis/event/event-boot/src/main/resources/bootstrap.yml
@@ -0,0 +1,51 @@
+#当前服务的基本信息
+microservice:
+ ename: @artifactId@
+ name: '@name@'
+ version: @version@
+ sentinel:
+ url: @sentinel.url@
+ gateway:
+ url: @gateway.url@
+server:
+ port: 10402
+#feign接口开启服务熔断降级处理
+feign:
+ sentinel:
+ enabled: true
+spring:
+ application:
+ name: @artifactId@
+ cloud:
+ nacos:
+ discovery:
+ ip: @service.server.url@
+ server-addr: @nacos.url@
+ namespace: @nacos.namespace@
+ config:
+ server-addr: @nacos.url@
+ namespace: @nacos.namespace@
+ file-extension: yaml
+ shared-configs:
+ - data-id: share-config.yaml
+ refresh: true
+ - data-Id: algorithm-config.yaml
+ refresh: true
+ main:
+ allow-bean-definition-overriding: true
+
+
+#项目日志的配置
+logging:
+ config: http://@nacos.url@/nacos/v1/cs/configs?tenant=@nacos.namespace@&group=DEFAULT_GROUP&dataId=logback.xml
+ level:
+ root: info
+
+
+#mybatis配置信息
+mybatis-plus:
+ #别名扫描
+ type-aliases-package: com.njcn.harmonic.pojo
+
+mqtt:
+ client-id: @artifactId@${random.value}
\ No newline at end of file
diff --git a/analysis/event/event-boot/src/test/java/com/njcn/event/AppTest.java b/analysis/event/event-boot/src/test/java/com/njcn/event/AppTest.java
new file mode 100644
index 0000000..73a38f2
--- /dev/null
+++ b/analysis/event/event-boot/src/test/java/com/njcn/event/AppTest.java
@@ -0,0 +1,38 @@
+package com.njcn.event;
+
+import junit.framework.Test;
+import junit.framework.TestCase;
+import junit.framework.TestSuite;
+
+/**
+ * Unit test for simple App.
+ */
+public class AppTest
+ extends TestCase
+{
+ /**
+ * Create the test case
+ *
+ * @param testName name of the test case
+ */
+ public AppTest( String testName )
+ {
+ super( testName );
+ }
+
+ /**
+ * @return the suite of tests being tested
+ */
+ public static Test suite()
+ {
+ return new TestSuite( AppTest.class );
+ }
+
+ /**
+ * Rigourous Test :-)
+ */
+ public void testApp()
+ {
+ assertTrue( true );
+ }
+}
diff --git a/analysis/event/pom.xml b/analysis/event/pom.xml
new file mode 100644
index 0000000..0b4edbf
--- /dev/null
+++ b/analysis/event/pom.xml
@@ -0,0 +1,27 @@
+
+ 4.0.0
+
+ com.njcn
+ analysis
+ 1.0.0
+
+
+ event
+ pom
+
+ event
+ 事件处理模块
+
+
+ event-api
+ event-boot
+
+
+
+ UTF-8
+ 8
+ 8
+
+
+
diff --git a/analysis/pom.xml b/analysis/pom.xml
new file mode 100644
index 0000000..493c38c
--- /dev/null
+++ b/analysis/pom.xml
@@ -0,0 +1,27 @@
+
+ 4.0.0
+
+ com.njcn
+ cn-data-platform
+ 1.0.0
+
+
+ analysis
+ pom
+
+ analysis
+ 数据解析平台
+
+
+ stat
+ rt
+ event
+
+
+
+ UTF-8
+ 8
+ 8
+
+
diff --git a/analysis/rt/pom.xml b/analysis/rt/pom.xml
new file mode 100644
index 0000000..7e282d2
--- /dev/null
+++ b/analysis/rt/pom.xml
@@ -0,0 +1,26 @@
+
+ 4.0.0
+
+ com.njcn
+ analysis
+ 1.0.0
+
+
+ rt
+ pom
+
+ rt
+ 实时数据处理模块
+
+ rt-api
+ rt-boot
+
+
+
+ UTF-8
+ 8
+ 8
+
+
+
diff --git a/analysis/rt/rt-api/pom.xml b/analysis/rt/rt-api/pom.xml
new file mode 100644
index 0000000..937f0f2
--- /dev/null
+++ b/analysis/rt/rt-api/pom.xml
@@ -0,0 +1,20 @@
+
+ 4.0.0
+
+ com.njcn
+ rt
+ 1.0.0
+
+
+ rt-api
+
+ rt-api
+
+
+ UTF-8
+ 8
+ 8
+
+
+
diff --git a/analysis/rt/rt-boot/pom.xml b/analysis/rt/rt-boot/pom.xml
new file mode 100644
index 0000000..b51d679
--- /dev/null
+++ b/analysis/rt/rt-boot/pom.xml
@@ -0,0 +1,107 @@
+
+ 4.0.0
+
+ com.njcn
+ rt
+ 1.0.0
+
+
+ rt-boot
+
+ rt-boot
+
+
+ UTF-8
+ 8
+ 8
+
+
+
+
+ com.njcn
+ common-web
+ ${project.version}
+
+
+ com.njcn
+ common-core
+ ${project.version}
+
+
+ com.njcn
+ common-swagger
+ ${project.version}
+
+
+ org.mybatis
+ mybatis-spring
+ 2.0.5
+
+
+
+
+ rtboot
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+ 3.8.0
+
+ -Xlint:unchecked
+
+
+
+ org.springframework.boot
+ spring-boot-maven-plugin
+
+
+ package
+
+ repackage
+
+
+
+
+
+
+ com.spotify
+ docker-maven-plugin
+ 1.2.2
+
+
+
+ build-image
+ ${docker.operate}
+
+ build
+
+
+
+
+
+ http://${docker.repostory}
+
+ ${docker.repostory}/${docker.registry.name}/${project.artifactId}
+
+
+ latest
+
+
+ ${docker.url}
+ ${basedir}/
+
+
+
+ /ROOT
+
+ ${project.build.directory}
+
+ ${project.build.finalName}.jar
+
+
+
+
+
+
+
diff --git a/analysis/rt/rt-boot/src/main/java/com/njcn/rt/RtBootApplication.java b/analysis/rt/rt-boot/src/main/java/com/njcn/rt/RtBootApplication.java
new file mode 100644
index 0000000..e5ec78c
--- /dev/null
+++ b/analysis/rt/rt-boot/src/main/java/com/njcn/rt/RtBootApplication.java
@@ -0,0 +1,21 @@
+package com.njcn.rt;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+
+
+/**
+ * @author xy
+ */
+@Slf4j
+@EnableFeignClients(basePackages = "com.njcn")
+@SpringBootApplication(scanBasePackages = "com.njcn")
+public class RtBootApplication {
+
+ public static void main(String[] args) {
+ SpringApplication.run(RtBootApplication.class, args);
+ }
+
+}
diff --git a/analysis/rt/rt-boot/src/main/resources/bootstrap.yml b/analysis/rt/rt-boot/src/main/resources/bootstrap.yml
new file mode 100644
index 0000000..4e273c4
--- /dev/null
+++ b/analysis/rt/rt-boot/src/main/resources/bootstrap.yml
@@ -0,0 +1,51 @@
+#当前服务的基本信息
+microservice:
+ ename: @artifactId@
+ name: '@name@'
+ version: @version@
+ sentinel:
+ url: @sentinel.url@
+ gateway:
+ url: @gateway.url@
+server:
+ port: 10403
+#feign接口开启服务熔断降级处理
+feign:
+ sentinel:
+ enabled: true
+spring:
+ application:
+ name: @artifactId@
+ cloud:
+ nacos:
+ discovery:
+ ip: @service.server.url@
+ server-addr: @nacos.url@
+ namespace: @nacos.namespace@
+ config:
+ server-addr: @nacos.url@
+ namespace: @nacos.namespace@
+ file-extension: yaml
+ shared-configs:
+ - data-id: share-config.yaml
+ refresh: true
+ - data-Id: algorithm-config.yaml
+ refresh: true
+ main:
+ allow-bean-definition-overriding: true
+
+
+#项目日志的配置
+logging:
+ config: http://@nacos.url@/nacos/v1/cs/configs?tenant=@nacos.namespace@&group=DEFAULT_GROUP&dataId=logback.xml
+ level:
+ root: info
+
+
+#mybatis配置信息
+mybatis-plus:
+ #别名扫描
+ type-aliases-package: com.njcn.harmonic.pojo
+
+mqtt:
+ client-id: @artifactId@${random.value}
\ No newline at end of file
diff --git a/analysis/rt/rt-boot/src/test/java/com/njcn/rt/AppTest.java b/analysis/rt/rt-boot/src/test/java/com/njcn/rt/AppTest.java
new file mode 100644
index 0000000..86c566b
--- /dev/null
+++ b/analysis/rt/rt-boot/src/test/java/com/njcn/rt/AppTest.java
@@ -0,0 +1,38 @@
+package com.njcn.rt;
+
+import junit.framework.Test;
+import junit.framework.TestCase;
+import junit.framework.TestSuite;
+
+/**
+ * Unit test for simple App.
+ */
+public class AppTest
+ extends TestCase
+{
+ /**
+ * Create the test case
+ *
+ * @param testName name of the test case
+ */
+ public AppTest( String testName )
+ {
+ super( testName );
+ }
+
+ /**
+ * @return the suite of tests being tested
+ */
+ public static Test suite()
+ {
+ return new TestSuite( AppTest.class );
+ }
+
+ /**
+ * Rigourous Test :-)
+ */
+ public void testApp()
+ {
+ assertTrue( true );
+ }
+}
diff --git a/analysis/stat/pom.xml b/analysis/stat/pom.xml
new file mode 100644
index 0000000..a94f7ac
--- /dev/null
+++ b/analysis/stat/pom.xml
@@ -0,0 +1,27 @@
+
+ 4.0.0
+
+ com.njcn
+ analysis
+ 1.0.0
+
+
+ stat
+ pom
+
+ stat
+ 分钟数据处理模块
+
+
+ stat-api
+ stat-boot
+
+
+
+ UTF-8
+ 8
+ 8
+
+
+
diff --git a/analysis/stat/stat-api/pom.xml b/analysis/stat/stat-api/pom.xml
new file mode 100644
index 0000000..f8d2cac
--- /dev/null
+++ b/analysis/stat/stat-api/pom.xml
@@ -0,0 +1,20 @@
+
+ 4.0.0
+
+ com.njcn
+ stat
+ 1.0.0
+
+
+ stat-api
+
+ stat-api
+
+
+ UTF-8
+ 8
+ 8
+
+
+
diff --git a/analysis/stat/stat-boot/pom.xml b/analysis/stat/stat-boot/pom.xml
new file mode 100644
index 0000000..c7f352f
--- /dev/null
+++ b/analysis/stat/stat-boot/pom.xml
@@ -0,0 +1,107 @@
+
+ 4.0.0
+
+ com.njcn
+ stat
+ 1.0.0
+
+
+ stat-boot
+
+ stat-boot
+
+
+ UTF-8
+ 8
+ 8
+
+
+
+
+ com.njcn
+ common-web
+ ${project.version}
+
+
+ com.njcn
+ common-core
+ ${project.version}
+
+
+ com.njcn
+ common-swagger
+ ${project.version}
+
+
+ org.mybatis
+ mybatis-spring
+ 2.0.5
+
+
+
+
+ statboot
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+ 3.8.0
+
+ -Xlint:unchecked
+
+
+
+ org.springframework.boot
+ spring-boot-maven-plugin
+
+
+ package
+
+ repackage
+
+
+
+
+
+
+ com.spotify
+ docker-maven-plugin
+ 1.2.2
+
+
+
+ build-image
+ ${docker.operate}
+
+ build
+
+
+
+
+
+ http://${docker.repostory}
+
+ ${docker.repostory}/${docker.registry.name}/${project.artifactId}
+
+
+ latest
+
+
+ ${docker.url}
+ ${basedir}/
+
+
+
+ /ROOT
+
+ ${project.build.directory}
+
+ ${project.build.finalName}.jar
+
+
+
+
+
+
+
diff --git a/analysis/stat/stat-boot/src/main/java/com/njcn/stat/StatBootApplication.java b/analysis/stat/stat-boot/src/main/java/com/njcn/stat/StatBootApplication.java
new file mode 100644
index 0000000..d575af2
--- /dev/null
+++ b/analysis/stat/stat-boot/src/main/java/com/njcn/stat/StatBootApplication.java
@@ -0,0 +1,21 @@
+package com.njcn.stat;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+
+
+/**
+ * @author xy
+ */
+@Slf4j
+@EnableFeignClients(basePackages = "com.njcn")
+@SpringBootApplication(scanBasePackages = "com.njcn")
+public class StatBootApplication {
+
+ public static void main(String[] args) {
+ SpringApplication.run(StatBootApplication.class, args);
+ }
+
+}
diff --git a/analysis/stat/stat-boot/src/main/resources/bootstrap.yml b/analysis/stat/stat-boot/src/main/resources/bootstrap.yml
new file mode 100644
index 0000000..98893c2
--- /dev/null
+++ b/analysis/stat/stat-boot/src/main/resources/bootstrap.yml
@@ -0,0 +1,51 @@
+#当前服务的基本信息
+microservice:
+ ename: @artifactId@
+ name: '@name@'
+ version: @version@
+ sentinel:
+ url: @sentinel.url@
+ gateway:
+ url: @gateway.url@
+server:
+ port: 10404
+#feign接口开启服务熔断降级处理
+feign:
+ sentinel:
+ enabled: true
+spring:
+ application:
+ name: @artifactId@
+ cloud:
+ nacos:
+ discovery:
+ ip: @service.server.url@
+ server-addr: @nacos.url@
+ namespace: @nacos.namespace@
+ config:
+ server-addr: @nacos.url@
+ namespace: @nacos.namespace@
+ file-extension: yaml
+ shared-configs:
+ - data-id: share-config.yaml
+ refresh: true
+ - data-Id: algorithm-config.yaml
+ refresh: true
+ main:
+ allow-bean-definition-overriding: true
+
+
+#项目日志的配置
+logging:
+ config: http://@nacos.url@/nacos/v1/cs/configs?tenant=@nacos.namespace@&group=DEFAULT_GROUP&dataId=logback.xml
+ level:
+ root: info
+
+
+#mybatis配置信息
+mybatis-plus:
+ #别名扫描
+ type-aliases-package: com.njcn.harmonic.pojo
+
+mqtt:
+ client-id: @artifactId@${random.value}
\ No newline at end of file
diff --git a/analysis/stat/stat-boot/src/test/java/com/njcn/stat/AppTest.java b/analysis/stat/stat-boot/src/test/java/com/njcn/stat/AppTest.java
new file mode 100644
index 0000000..20ca088
--- /dev/null
+++ b/analysis/stat/stat-boot/src/test/java/com/njcn/stat/AppTest.java
@@ -0,0 +1,38 @@
+package com.njcn.stat;
+
+import junit.framework.Test;
+import junit.framework.TestCase;
+import junit.framework.TestSuite;
+
+/**
+ * Unit test for simple App.
+ */
+public class AppTest
+ extends TestCase
+{
+ /**
+ * Create the test case
+ *
+ * @param testName name of the test case
+ */
+ public AppTest( String testName )
+ {
+ super( testName );
+ }
+
+ /**
+ * @return the suite of tests being tested
+ */
+ public static Test suite()
+ {
+ return new TestSuite( AppTest.class );
+ }
+
+ /**
+ * Rigourous Test :-)
+ */
+ public void testApp()
+ {
+ assertTrue( true );
+ }
+}
diff --git a/data-processing/data-processing-api/pom.xml b/data-processing/data-processing-api/pom.xml
new file mode 100644
index 0000000..9a44ea5
--- /dev/null
+++ b/data-processing/data-processing-api/pom.xml
@@ -0,0 +1,20 @@
+
+ 4.0.0
+
+ com.njcn
+ data-processing
+ 1.0.0
+
+
+ data-processing-api
+
+ data-processing-api
+
+
+ UTF-8
+ 8
+ 8
+
+
+
diff --git a/data-processing/data-processing-data/pom.xml b/data-processing/data-processing-data/pom.xml
new file mode 100644
index 0000000..200d657
--- /dev/null
+++ b/data-processing/data-processing-data/pom.xml
@@ -0,0 +1,107 @@
+
+ 4.0.0
+
+ com.njcn
+ data-processing
+ 1.0.0
+
+
+ data-processing-data
+
+ data-processing-data
+
+
+ UTF-8
+ 8
+ 8
+
+
+
+
+ com.njcn
+ common-web
+ ${project.version}
+
+
+ com.njcn
+ common-core
+ ${project.version}
+
+
+ com.njcn
+ common-swagger
+ ${project.version}
+
+
+ org.mybatis
+ mybatis-spring
+ 2.0.5
+
+
+
+
+ dataprocessingboot
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+ 3.8.0
+
+ -Xlint:unchecked
+
+
+
+ org.springframework.boot
+ spring-boot-maven-plugin
+
+
+ package
+
+ repackage
+
+
+
+
+
+
+ com.spotify
+ docker-maven-plugin
+ 1.2.2
+
+
+
+ build-image
+ ${docker.operate}
+
+ build
+
+
+
+
+
+ http://${docker.repostory}
+
+ ${docker.repostory}/${docker.registry.name}/${project.artifactId}
+
+
+ latest
+
+
+ ${docker.url}
+ ${basedir}/
+
+
+
+ /ROOT
+
+ ${project.build.directory}
+
+ ${project.build.finalName}.jar
+
+
+
+
+
+
+
diff --git a/data-processing/data-processing-data/src/main/java/com/njcn/dataProcess/DataProcessBootApplication.java b/data-processing/data-processing-data/src/main/java/com/njcn/dataProcess/DataProcessBootApplication.java
new file mode 100644
index 0000000..58e8251
--- /dev/null
+++ b/data-processing/data-processing-data/src/main/java/com/njcn/dataProcess/DataProcessBootApplication.java
@@ -0,0 +1,21 @@
+package com.njcn.dataProcess;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+
+
+/**
+ * @author xy
+ */
+@Slf4j
+@EnableFeignClients(basePackages = "com.njcn")
+@SpringBootApplication(scanBasePackages = "com.njcn")
+public class DataProcessBootApplication {
+
+ public static void main(String[] args) {
+ SpringApplication.run(DataProcessBootApplication.class, args);
+ }
+
+}
diff --git a/data-processing/data-processing-data/src/main/resources/bootstrap.yml b/data-processing/data-processing-data/src/main/resources/bootstrap.yml
new file mode 100644
index 0000000..96921ae
--- /dev/null
+++ b/data-processing/data-processing-data/src/main/resources/bootstrap.yml
@@ -0,0 +1,51 @@
+#当前服务的基本信息
+microservice:
+ ename: @artifactId@
+ name: '@name@'
+ version: @version@
+ sentinel:
+ url: @sentinel.url@
+ gateway:
+ url: @gateway.url@
+server:
+ port: 10405
+#feign接口开启服务熔断降级处理
+feign:
+ sentinel:
+ enabled: true
+spring:
+ application:
+ name: @artifactId@
+ cloud:
+ nacos:
+ discovery:
+ ip: @service.server.url@
+ server-addr: @nacos.url@
+ namespace: @nacos.namespace@
+ config:
+ server-addr: @nacos.url@
+ namespace: @nacos.namespace@
+ file-extension: yaml
+ shared-configs:
+ - data-id: share-config.yaml
+ refresh: true
+ - data-Id: algorithm-config.yaml
+ refresh: true
+ main:
+ allow-bean-definition-overriding: true
+
+
+#项目日志的配置
+logging:
+ config: http://@nacos.url@/nacos/v1/cs/configs?tenant=@nacos.namespace@&group=DEFAULT_GROUP&dataId=logback.xml
+ level:
+ root: info
+
+
+#mybatis配置信息
+mybatis-plus:
+ #别名扫描
+ type-aliases-package: com.njcn.harmonic.pojo
+
+mqtt:
+ client-id: @artifactId@${random.value}
\ No newline at end of file
diff --git a/data-processing/data-processing-data/src/test/java/com/njcn/dataProcess/AppTest.java b/data-processing/data-processing-data/src/test/java/com/njcn/dataProcess/AppTest.java
new file mode 100644
index 0000000..a0e5dd7
--- /dev/null
+++ b/data-processing/data-processing-data/src/test/java/com/njcn/dataProcess/AppTest.java
@@ -0,0 +1,38 @@
+package com.njcn.dataProcess;
+
+import junit.framework.Test;
+import junit.framework.TestCase;
+import junit.framework.TestSuite;
+
+/**
+ * Unit test for simple App.
+ */
+public class AppTest
+ extends TestCase
+{
+ /**
+ * Create the test case
+ *
+ * @param testName name of the test case
+ */
+ public AppTest( String testName )
+ {
+ super( testName );
+ }
+
+ /**
+ * @return the suite of tests being tested
+ */
+ public static Test suite()
+ {
+ return new TestSuite( AppTest.class );
+ }
+
+ /**
+ * Rigourous Test :-)
+ */
+ public void testApp()
+ {
+ assertTrue( true );
+ }
+}
diff --git a/data-processing/pom.xml b/data-processing/pom.xml
new file mode 100644
index 0000000..5a6b30b
--- /dev/null
+++ b/data-processing/pom.xml
@@ -0,0 +1,27 @@
+
+ 4.0.0
+
+ com.njcn
+ cn-data-platform
+ 1.0.0
+
+
+ data-processing
+ pom
+
+ data-processing
+ 数据处理平台
+
+
+ data-processing-api
+ data-processing-data
+
+
+
+ UTF-8
+ 8
+ 8
+
+
+
diff --git a/log/log-api/pom.xml b/log/log-api/pom.xml
new file mode 100644
index 0000000..04b0e9b
--- /dev/null
+++ b/log/log-api/pom.xml
@@ -0,0 +1,28 @@
+
+ 4.0.0
+
+ com.njcn
+ log
+ 1.0.0
+
+
+ log-api
+ jar
+
+ log-api
+ http://maven.apache.org
+
+
+ UTF-8
+
+
+
+
+ junit
+ junit
+ 3.8.1
+ test
+
+
+
diff --git a/log/log-boot/pom.xml b/log/log-boot/pom.xml
new file mode 100644
index 0000000..8f38a71
--- /dev/null
+++ b/log/log-boot/pom.xml
@@ -0,0 +1,108 @@
+
+ 4.0.0
+
+ com.njcn
+ log
+ 1.0.0
+
+
+ log-boot
+
+ log-boot
+
+
+ UTF-8
+ 8
+ 8
+
+
+
+
+ com.njcn
+ common-web
+ ${project.version}
+
+
+ com.njcn
+ common-core
+ ${project.version}
+
+
+ com.njcn
+ common-swagger
+ ${project.version}
+
+
+ org.mybatis
+ mybatis-spring
+ 2.0.5
+
+
+
+
+ logboot
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+ 3.8.0
+
+ -Xlint:unchecked
+
+
+
+ org.springframework.boot
+ spring-boot-maven-plugin
+
+
+ package
+
+ repackage
+
+
+
+
+
+
+ com.spotify
+ docker-maven-plugin
+ 1.2.2
+
+
+
+ build-image
+ ${docker.operate}
+
+ build
+
+
+
+
+
+ http://${docker.repostory}
+
+ ${docker.repostory}/${docker.registry.name}/${project.artifactId}
+
+
+ latest
+
+
+ ${docker.url}
+ ${basedir}/
+
+
+
+ /ROOT
+
+ ${project.build.directory}
+
+ ${project.build.finalName}.jar
+
+
+
+
+
+
+
+
diff --git a/log/log-boot/src/main/java/com/njcn/log/LogBootApplication.java b/log/log-boot/src/main/java/com/njcn/log/LogBootApplication.java
new file mode 100644
index 0000000..41b96c6
--- /dev/null
+++ b/log/log-boot/src/main/java/com/njcn/log/LogBootApplication.java
@@ -0,0 +1,21 @@
+package com.njcn.log;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+
+
+/**
+ * @author xy
+ */
+@Slf4j
+@EnableFeignClients(basePackages = "com.njcn")
+@SpringBootApplication(scanBasePackages = "com.njcn")
+public class LogBootApplication {
+
+ public static void main(String[] args) {
+ SpringApplication.run(LogBootApplication.class, args);
+ }
+
+}
diff --git a/log/log-boot/src/main/resources/bootstrap.yml b/log/log-boot/src/main/resources/bootstrap.yml
new file mode 100644
index 0000000..80fdb44
--- /dev/null
+++ b/log/log-boot/src/main/resources/bootstrap.yml
@@ -0,0 +1,51 @@
+#当前服务的基本信息
+microservice:
+ ename: @artifactId@
+ name: '@name@'
+ version: @version@
+ sentinel:
+ url: @sentinel.url@
+ gateway:
+ url: @gateway.url@
+server:
+ port: 10406
+#feign接口开启服务熔断降级处理
+feign:
+ sentinel:
+ enabled: true
+spring:
+ application:
+ name: @artifactId@
+ cloud:
+ nacos:
+ discovery:
+ ip: @service.server.url@
+ server-addr: @nacos.url@
+ namespace: @nacos.namespace@
+ config:
+ server-addr: @nacos.url@
+ namespace: @nacos.namespace@
+ file-extension: yaml
+ shared-configs:
+ - data-id: share-config.yaml
+ refresh: true
+ - data-Id: algorithm-config.yaml
+ refresh: true
+ main:
+ allow-bean-definition-overriding: true
+
+
+#项目日志的配置
+logging:
+ config: http://@nacos.url@/nacos/v1/cs/configs?tenant=@nacos.namespace@&group=DEFAULT_GROUP&dataId=logback.xml
+ level:
+ root: info
+
+
+#mybatis配置信息
+mybatis-plus:
+ #别名扫描
+ type-aliases-package: com.njcn.harmonic.pojo
+
+mqtt:
+ client-id: @artifactId@${random.value}
\ No newline at end of file
diff --git a/log/log-boot/src/test/java/com/njcn/log/AppTest.java b/log/log-boot/src/test/java/com/njcn/log/AppTest.java
new file mode 100644
index 0000000..dafbe1b
--- /dev/null
+++ b/log/log-boot/src/test/java/com/njcn/log/AppTest.java
@@ -0,0 +1,38 @@
+package com.njcn.log;
+
+import junit.framework.Test;
+import junit.framework.TestCase;
+import junit.framework.TestSuite;
+
+/**
+ * Unit test for simple App.
+ */
+public class AppTest
+ extends TestCase
+{
+ /**
+ * Create the test case
+ *
+ * @param testName name of the test case
+ */
+ public AppTest( String testName )
+ {
+ super( testName );
+ }
+
+ /**
+ * @return the suite of tests being tested
+ */
+ public static Test suite()
+ {
+ return new TestSuite( AppTest.class );
+ }
+
+ /**
+ * Rigourous Test :-)
+ */
+ public void testApp()
+ {
+ assertTrue( true );
+ }
+}
diff --git a/log/pom.xml b/log/pom.xml
new file mode 100644
index 0000000..f725f86
--- /dev/null
+++ b/log/pom.xml
@@ -0,0 +1,26 @@
+
+ 4.0.0
+
+ com.njcn
+ cn-data-platform
+ 1.0.0
+
+
+ log
+ pom
+
+ log
+ 日志中心
+
+
+ log-api
+ log-boot
+
+
+
+ UTF-8
+ 8
+ 8
+
+
diff --git a/message/message-api/pom.xml b/message/message-api/pom.xml
new file mode 100644
index 0000000..0cde4e4
--- /dev/null
+++ b/message/message-api/pom.xml
@@ -0,0 +1,21 @@
+
+ 4.0.0
+
+ com.njcn
+ message
+ 1.0.0
+
+
+ message-api
+ jar
+
+ message-api
+
+
+ UTF-8
+ 8
+ 8
+
+
+
diff --git a/message/message-boot/pom.xml b/message/message-boot/pom.xml
new file mode 100644
index 0000000..4fd1bdc
--- /dev/null
+++ b/message/message-boot/pom.xml
@@ -0,0 +1,107 @@
+
+ 4.0.0
+
+ com.njcn
+ message
+ 1.0.0
+
+
+ message-boot
+
+ message-boot
+
+
+ UTF-8
+ 8
+ 8
+
+
+
+
+ com.njcn
+ common-web
+ ${project.version}
+
+
+ com.njcn
+ common-core
+ ${project.version}
+
+
+ com.njcn
+ common-swagger
+ ${project.version}
+
+
+ org.mybatis
+ mybatis-spring
+ 2.0.5
+
+
+
+
+ messageboot
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+ 3.8.0
+
+ -Xlint:unchecked
+
+
+
+ org.springframework.boot
+ spring-boot-maven-plugin
+
+
+ package
+
+ repackage
+
+
+
+
+
+
+ com.spotify
+ docker-maven-plugin
+ 1.2.2
+
+
+
+ build-image
+ ${docker.operate}
+
+ build
+
+
+
+
+
+ http://${docker.repostory}
+
+ ${docker.repostory}/${docker.registry.name}/${project.artifactId}
+
+
+ latest
+
+
+ ${docker.url}
+ ${basedir}/
+
+
+
+ /ROOT
+
+ ${project.build.directory}
+
+ ${project.build.finalName}.jar
+
+
+
+
+
+
+
diff --git a/message/message-boot/src/main/java/com/njcn/message/MessageBootApplication.java b/message/message-boot/src/main/java/com/njcn/message/MessageBootApplication.java
new file mode 100644
index 0000000..0709939
--- /dev/null
+++ b/message/message-boot/src/main/java/com/njcn/message/MessageBootApplication.java
@@ -0,0 +1,21 @@
+package com.njcn.message;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+
+
+/**
+ * @author xy
+ */
+@Slf4j
+@EnableFeignClients(basePackages = "com.njcn")
+@SpringBootApplication(scanBasePackages = "com.njcn")
+public class MessageBootApplication {
+
+ public static void main(String[] args) {
+ SpringApplication.run(MessageBootApplication.class, args);
+ }
+
+}
diff --git a/message/message-boot/src/main/resources/bootstrap.yml b/message/message-boot/src/main/resources/bootstrap.yml
new file mode 100644
index 0000000..3898c94
--- /dev/null
+++ b/message/message-boot/src/main/resources/bootstrap.yml
@@ -0,0 +1,51 @@
+#当前服务的基本信息
+microservice:
+ ename: @artifactId@
+ name: '@name@'
+ version: @version@
+ sentinel:
+ url: @sentinel.url@
+ gateway:
+ url: @gateway.url@
+server:
+ port: 10407
+#feign接口开启服务熔断降级处理
+feign:
+ sentinel:
+ enabled: true
+spring:
+ application:
+ name: @artifactId@
+ cloud:
+ nacos:
+ discovery:
+ ip: @service.server.url@
+ server-addr: @nacos.url@
+ namespace: @nacos.namespace@
+ config:
+ server-addr: @nacos.url@
+ namespace: @nacos.namespace@
+ file-extension: yaml
+ shared-configs:
+ - data-id: share-config.yaml
+ refresh: true
+ - data-Id: algorithm-config.yaml
+ refresh: true
+ main:
+ allow-bean-definition-overriding: true
+
+
+#项目日志的配置
+logging:
+ config: http://@nacos.url@/nacos/v1/cs/configs?tenant=@nacos.namespace@&group=DEFAULT_GROUP&dataId=logback.xml
+ level:
+ root: info
+
+
+#mybatis配置信息
+mybatis-plus:
+ #别名扫描
+ type-aliases-package: com.njcn.harmonic.pojo
+
+mqtt:
+ client-id: @artifactId@${random.value}
\ No newline at end of file
diff --git a/message/message-boot/src/test/java/com/njcn/message/AppTest.java b/message/message-boot/src/test/java/com/njcn/message/AppTest.java
new file mode 100644
index 0000000..a78b066
--- /dev/null
+++ b/message/message-boot/src/test/java/com/njcn/message/AppTest.java
@@ -0,0 +1,38 @@
+package com.njcn.message;
+
+import junit.framework.Test;
+import junit.framework.TestCase;
+import junit.framework.TestSuite;
+
+/**
+ * Unit test for simple App.
+ */
+public class AppTest
+ extends TestCase
+{
+ /**
+ * Create the test case
+ *
+ * @param testName name of the test case
+ */
+ public AppTest( String testName )
+ {
+ super( testName );
+ }
+
+ /**
+ * @return the suite of tests being tested
+ */
+ public static Test suite()
+ {
+ return new TestSuite( AppTest.class );
+ }
+
+ /**
+ * Rigourous Test :-)
+ */
+ public void testApp()
+ {
+ assertTrue( true );
+ }
+}
diff --git a/message/pom.xml b/message/pom.xml
new file mode 100644
index 0000000..10d3c32
--- /dev/null
+++ b/message/pom.xml
@@ -0,0 +1,27 @@
+
+ 4.0.0
+
+ com.njcn
+ cn-data-platform
+ 1.0.0
+
+
+ message
+ pom
+
+ message
+ 消息处理平台
+
+
+ message-api
+ message-boot
+
+
+
+ UTF-8
+ 8
+ 8
+
+
+
diff --git a/pom.xml b/pom.xml
new file mode 100644
index 0000000..03b1bbf
--- /dev/null
+++ b/pom.xml
@@ -0,0 +1,416 @@
+
+ 4.0.0
+
+ com.njcn
+ cn-data-platform
+ 1.0.0
+ pom
+
+ cn-data-platform
+ 灿能数据处理平台
+
+ message
+ analysis
+ algorithm
+ log
+ data-processing
+
+
+
+
+ nexus-releases
+ Nexus Release Repository
+ http://192.168.1.22:8001/nexus/content/repositories/releases/
+
+
+ nexus-snapshots
+ Nexus Snapshot Repository
+ http://192.168.1.22:8001/nexus/content/repositories/snapshots/
+
+
+
+
+
+ 192.168.1.22
+ 127.0.0.1
+ 192.168.1.22
+ ${middle.server.url}:18848
+ 415a1c87-33aa-47bd-8e25-13cc456c87ed
+
+ ${middle.server.url}:8080
+
+ ${service.server.url}:10215
+
+ http://${docker.server.url}:2375
+
+ ${docker.server.url}:8090
+
+ njcn
+
+ common-microservice
+
+ site
+ 1.8
+ 8
+ 8
+
+ 2.3.12.RELEASE
+
+ Hoxton.SR12
+ 2.2.7.RELEASE
+ 5.8.11
+ 3.0.2
+ 2.0.8
+ 1.18.18
+ 2.1.3
+ 1.2.5
+ 8.0.19
+ 2.4.0
+ 21.6.0.0
+ 21.1.0.0
+ 3.4.2
+ 3.5.1
+ 1.5.1-RELEASE
+ 3.5.1
+ 2.3
+ 0.9.1
+ 11.2
+ 4.9.0
+ 1.6.4
+ 2.3.2
+ 1.68
+ 3.12.0
+ 2.8.0
+ 1.15
+ 1.8.1
+ 2.12.4
+ 3.0.5
+ 2.22
+ 3.0.0.6
+ 2.8.9
+ 2.3.0
+ 1.2.7
+ 4.4.0
+ 1.2.83
+
+
+
+
+
+ org.springframework.boot
+ spring-boot-dependencies
+ ${springboot.version}
+ pom
+ import
+
+
+ org.springframework.cloud
+ spring-cloud-dependencies
+ ${springcloud.version}
+ pom
+ import
+
+
+ com.alibaba.cloud
+ spring-cloud-alibaba-dependencies
+ ${springcloud.alibaba.version}
+ pom
+ import
+
+
+
+
+ cn.hutool
+ hutool-all
+ ${hutool.version}
+
+
+
+ org.projectlombok
+ lombok
+ ${lombok.version}
+
+
+
+ com.github.xiaoymin
+ knife4j-spring-boot-starter
+ ${knife4j.version}
+
+
+ com.github.xiaoymin
+ knife4j-spring-ui
+ ${knife4j.version}
+
+
+ com.github.xiaoymin
+ knife4j-aggregation-spring-boot-starter
+
+ ${knife4j.aggregation.version}
+
+
+
+ org.mybatis.spring.boot
+ mybatis-spring-boot-starter
+ ${mybatis.version}
+
+
+
+ com.alibaba
+ druid-spring-boot-starter
+ ${druid.version}
+
+
+
+ mysql
+ mysql-connector-java
+ ${mysql.version}
+
+
+
+ org.mariadb.jdbc
+ mariadb-java-client
+ ${mariadb.version}
+
+
+
+ com.oracle.database.jdbc
+ ojdbc8
+ ${oracle.version}
+
+
+
+ com.oracle.database.nls
+ orai18n
+ ${orai18n.version}
+
+
+
+ com.baomidou
+ mybatis-plus-boot-starter
+ ${mybatis-plus.version}
+
+
+ com.baomidou
+ mybatis-plus-generator
+ ${mybatis-plus-generator.version}
+
+
+ com.github.jeffreyning
+ mybatisplus-plus
+ ${mybatis-plus.jeffreyning.version}
+
+
+ org.apache.velocity
+ velocity-engine-core
+ ${velocity.version}
+
+
+
+
+ io.jsonwebtoken
+ jjwt
+ ${jjwt.version}
+
+
+
+ io.github.openfeign
+ feign-okhttp
+ ${feignOkhttp.version}
+
+
+
+ org.owasp.antisamy
+ antisamy
+ ${antisamy.version}
+
+
+
+ com.github.penggle
+ kaptcha
+ ${kaptcha.version}
+
+
+
+ org.bouncycastle
+ bcprov-jdk15on
+ ${bcprov-jdk15on.version}
+
+
+
+ org.apache.commons
+ commons-lang3
+ ${commons-lang3.version}
+
+
+ commons-io
+ commons-io
+ ${commons-io.version}
+
+
+ commons-codec
+ commons-codec
+ ${commons-codec.version}
+
+
+ com.alibaba.csp
+ sentinel-datasource-nacos
+ ${sentinel.datasource.nacos.version}
+
+
+
+ com.fasterxml.jackson.core
+ jackson-databind
+ ${jackson}
+
+
+
+ com.fasterxml.jackson.core
+ jackson-core
+ ${jackson}
+
+
+ com.fasterxml.jackson.core
+ jackson-annotations
+ ${jackson}
+
+
+ com.fasterxml.jackson.datatype
+ jackson-datatype-jsr310
+ ${jackson}
+
+
+ com.alibaba
+ easyexcel
+ ${easyexcel}
+
+
+ com.github.abel533
+ ECharts
+ ${echarts.version}
+
+
+
+ com.google.code.gson
+ gson
+ ${gson.version}
+
+
+
+ com.xuxueli
+ xxl-job-core
+ ${xxl-job.version}
+
+
+ com.github.tocrhz
+ mqtt-spring-boot-starter
+ ${mqtt.version}
+
+
+ cn.afterturn
+ easypoi-spring-boot-starter
+ ${easypoi.version}
+
+
+
+ com.baomidou
+ dynamic-datasource-spring-boot-starter
+ ${dynamic-datasource.version}
+
+
+ com.squareup.okhttp3
+ logging-interceptor
+ ${okhttp3.version}
+
+
+ com.squareup.okhttp3
+ mockwebserver
+ ${okhttp3.version}
+
+
+ com.squareup.okhttp3
+ okcurl
+ ${okhttp3.version}
+
+
+ com.squareup.okhttp3
+ okhttp
+ ${okhttp3.version}
+
+
+ com.squareup.okhttp3
+ okhttp-dnsoverhttps
+ ${okhttp3.version}
+
+
+ com.squareup.okhttp3
+ okhttp-sse
+ ${okhttp3.version}
+
+
+ com.squareup.okhttp3
+ okhttp-testing-support
+ ${okhttp3.version}
+
+
+ com.squareup.okhttp3
+ okhttp-tls
+ ${okhttp3.version}
+
+
+ com.squareup.okhttp3
+ okhttp-urlconnection
+ ${okhttp3.version}
+
+
+ org.influxdb
+ influxdb-java
+ ${influxdb-java.version}
+
+
+ com.alibaba
+ fastjson
+ ${fastjson.version}
+
+
+ org.apache.logging.log4j
+ log4j-api
+ 2.18.0
+
+
+
+
+
+
+ org.springframework.boot
+ spring-boot-maven-plugin
+ 2.2.2.RELEASE
+
+ true
+ true
+
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+ 3.1
+
+ 1.8
+ 1.8
+
+
+
+
+
+ src/main/resources
+ true
+
+
+ src/main/java
+
+ **/*.xml
+
+
+
+
+