[alarm] refactor new alarm

hertzbeat-alerter/pom.xml

@@ -32,9 +32,14 @@
         <!-- common -->
         <dependency>
             <groupId>org.apache.hertzbeat</groupId>
-            <artifactId>hertzbeat-common</artifactId>
+            <artifactId>hertzbeat-base</artifactId>
             <scope>provided</scope>
         </dependency>
+        <!-- plugin -->
+        <dependency>
+            <groupId>org.apache.hertzbeat</groupId>
+            <artifactId>hertzbeat-plugin</artifactId>
+        </dependency>
         <!-- spring -->
         <dependency>
             <groupId>org.springframework.boot</groupId>
@@ -50,6 +55,21 @@
             <artifactId>spring-boot-configuration-processor</artifactId>
             <optional>true</optional>
         </dependency>
+        <!-- email -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-mail</artifactId>
+        </dependency>
+        <!--   freemarker     -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-freemarker</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>net.sourceforge.nekohtml</groupId>
+            <artifactId>nekohtml</artifactId>
+            <version>${nekohtml.version}</version>
+        </dependency>
         <!-- kafka -->
         <dependency>
             <groupId>org.apache.kafka</groupId>
@@ -73,6 +93,36 @@
             <version>${easy-poi.version}</version>
             <scope>compile</scope>
         </dependency>
+        <!-- sms -->
+        <dependency>
+            <groupId>com.tencentcloudapi</groupId>
+            <artifactId>tencentcloud-sdk-java-sms</artifactId>
+            <exclusions>
+                <exclusion>
+                    <groupId>com.squareup.okhttp</groupId>
+                    <artifactId>logging-interceptor</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>com.squareup.okhttp</groupId>
+                    <artifactId>okhttp</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>com.squareup.okio</groupId>
+                    <artifactId>okio</artifactId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+        <dependency>
+            <groupId>com.huaweicloud.sdk</groupId>
+            <artifactId>huaweicloud-sdk-smn</artifactId>
+            <version>${huawei.sdk.version}</version>
+            <exclusions>
+                <exclusion>
+                    <groupId>org.openeuler</groupId>
+                    <artifactId>bgmprovider</artifactId>
+                </exclusion>
+            </exclusions>
+        </dependency>
         <dependency>
             <groupId>org.apache.arrow</groupId>
             <artifactId>arrow-vector</artifactId>

hertzbeat-alerter/src/main/java/org/apache/hertzbeat/alert/AlerterWorkerPool.java

@@ -44,7 +44,7 @@ public AlerterWorkerPool() {
     private void initWorkExecutor() {
         ThreadFactory threadFactory = new ThreadFactoryBuilder()
                 .setUncaughtExceptionHandler((thread, throwable) -> {
-                    log.error("workerExecutor has uncaughtException.");
+                    log.error("Alerter workerExecutor has uncaughtException.");
                     log.error(throwable.getMessage(), throwable);
                 })
                 .setDaemon(true)
@@ -62,7 +62,7 @@ private void initWorkExecutor() {
     private void initNotifyExecutor() {
         ThreadFactory threadFactory = new ThreadFactoryBuilder()
                 .setUncaughtExceptionHandler((thread, throwable) -> {
-                    log.error("notifyExecutor has uncaughtException.");
+                    log.error("Alerter notifyExecutor has uncaughtException.");
                     log.error(throwable.getMessage(), throwable);
                 })
                 .setDaemon(true)

hertzbeat-alerter/src/main/java/org/apache/hertzbeat/alert/calculate/PeriodicAlertCalculator.java

@@ -0,0 +1,89 @@
+package org.apache.hertzbeat.alert.calculate;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.hertzbeat.alert.service.DataSourceService;
+import org.apache.hertzbeat.common.entity.alerter.AlertDefine;
+import org.apache.hertzbeat.common.entity.alerter.SingleAlert;
+import org.apache.hertzbeat.common.util.JexlExpressionRunner;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+import java.util.Collections;
+import java.util.concurrent.ConcurrentHashMap;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.commons.collections4.CollectionUtils;
+
+/**
+ * Periodic Alert Calculator
+ */
+
+@Slf4j
+@RequiredArgsConstructor
+public class PeriodicAlertCalculator {
+
+    private final DataSourceService dataSourceService;
+    private final JexlExpressionRunner expressionRunner;
+    private final Map<String, SingleAlert> notRecoveredAlertMap = new ConcurrentHashMap<>(16);
+
+
+    public List<SingleAlert> calculate(AlertDefine rule) {
+        if (!rule.isEnable() || StringUtils.isEmpty(rule.getExpr())) {
+            return Collections.emptyList();
+        }
+        // todo: implement the following logic
+        try {
+            // Execute query
+            List<Map<String, Object>> queryResults = dataSourceService.query(
+                rule.getDatasource(), 
+                rule.getExpr()
+            );
+
+            if (CollectionUtils.isEmpty(queryResults)) {
+                return Collections.emptyList();
+            }
+
+            // Execute expression calculation on query results
+            List<SingleAlert> newAlerts = queryResults.stream()
+                .filter(result -> execAlertExpression(result, rule.getExpr()))
+                .map(result -> buildAlert(rule, result))
+                .collect(Collectors.toList());
+
+            // Handle recovery notification
+            if (newAlerts.isEmpty()) {
+                return handleAlertRecover(rule);
+            }
+
+            return newAlerts;
+        } catch (Exception e) {
+            log.error("Calculate periodic rule {} failed: {}", rule.getName(), e.getMessage());
+            return Collections.emptyList();
+        }
+    }
+
+    private boolean execAlertExpression(Map<String, Object> result, String expr) {
+        return false;
+    }
+
+    private SingleAlert buildAlert(AlertDefine rule, Map<String, Object> metrics) {
+        return SingleAlert.builder()
+                .labels(rule.getLabels())
+                .annotations(rule.getAnnotations())
+                .triggerTimes(1)
+                .startAt(System.currentTimeMillis())
+                .activeAt(System.currentTimeMillis())
+                .build();
+    }
+
+    private List<SingleAlert> handleAlertRecover(AlertDefine rule) {
+        SingleAlert firingAlert = notRecoveredAlertMap.remove(rule.getId().toString());
+        if (firingAlert != null) {
+            return Collections.singletonList(buildResolvedAlert(rule, firingAlert));
+        }
+        return Collections.emptyList();
+    }
+
+    private SingleAlert buildResolvedAlert(AlertDefine rule, SingleAlert firingAlert) {
+        return null;
+    }
+} 

hertzbeat-alerter/src/main/java/org/apache/hertzbeat/alert/calculate/PeriodicAlertRuleScheduler.java

@@ -0,0 +1,12 @@
+package org.apache.hertzbeat.alert.calculate;
+
+import lombok.extern.slf4j.Slf4j;
+
+/**
+ * period alert rule scheduler
+ */
+@Slf4j
+public class PeriodicAlertRuleScheduler {
+
+    // todo implement the following logic
+}