refactor: 优化

Author: zhou-hao

jetlinks-components/timeseries-component/src/main/java/org/jetlinks/community/timeseries/error/TimeseriesExceptionAnalyzerReporter.java

@@ -16,6 +16,13 @@ public TimeseriesExceptionAnalyzerReporter() {
     }
 
     void init() {
+
+        addReporter(
+            err -> err.toString().contains("create_hypertable") &&
+                err.toString().contains("does not exist"),
+            err ->
+                log.warn(wrapLog("请使用TimescaleDB.或者Postgres安装并启用TimescaleDB插件."), err));
+
         addReporter(
             err -> err instanceof NoSuchBeanDefinitionException &&
                 Objects.equals(((NoSuchBeanDefinitionException) err).getBeanType(),

jetlinks-manager/rule-engine-manager/src/main/java/org/jetlinks/community/rule/engine/scene/SceneRule.java

@@ -331,7 +331,7 @@ public Disposable createBranchHandler(Flux<Map<String, Object>> sourceData,
                         trigger
                             .provider()
                             .shakeLimit(
-                                DigestUtils.md5Hex(id + ":" + _branchIndex),
+                                id + ":" + _branchIndex,
                                 sinks.asFlux(),
                                 shakeLimit,
                                 resetSignal)

pom.xml

@@ -35,9 +35,9 @@
         <!-- https://github.com/jetlinks/reactor-ql -->
         <reactor.ql.version>1.0.19</reactor.ql.version>
         <!-- https://github.com/jetlinks/jetlinks-plugin -->
-        <jetlinks.plugin.version>1.0.3</jetlinks.plugin.version>
+        <jetlinks.plugin.version>1.0.5-SNAPSHOT</jetlinks.plugin.version>
         <!-- https://github.com/jetlinks/jetlinks-sdk -->
-        <jetlinks.sdk.version>1.0.2</jetlinks.sdk.version>
+        <jetlinks.sdk.version>1.1.0-SNAPSHOT</jetlinks.sdk.version>
         <!-- https://github.com/hsweb/hsweb-utils -->
         <hsweb.utils.version>3.0.5</hsweb.utils.version>
 
@@ -723,6 +723,12 @@
                 <version>${hsweb.framework.version}</version>
             </dependency>
 
+            <dependency>
+                <groupId>org.jetlinks</groupId>
+                <artifactId>rule-engine-api</artifactId>
+                <version>${jetlinks.version}</version>
+            </dependency>
+
             <dependency>
                 <groupId>org.jetlinks</groupId>
                 <artifactId>rule-engine-support</artifactId>