Merge branch 'feature/alert-healing-with-observation-window' into develop

Author: acd19ml

docs/alerting/database-design.md

@@ -2,14 +2,15 @@
 
 ## 概述
 
-本文档为最新数据库设计，总计包含 6 张表：
+本文档为最新数据库设计，总计包含 7 张表：
 
 - alert_issues
 - alert_issue_comments
 - alert_meta_change_logs
 - alert_rules
 - alert_rule_metas
 - service_states
+- heal_actions
 
 ## 数据表设计
 
@@ -111,7 +112,7 @@
 
 ---
 
-### 7) service_states（服务状态表）
+### 6) service_states（服务状态表）
 
 追踪服务在某一版本上的健康状态与处置进度。
 
@@ -127,6 +128,34 @@
 **索引建议：**
 - PRIMARY KEY: `(service, version)`
 
+---
+
+### 7) heal_actions（告警治愈解决方案表）
+
+存储不同故障域对应的治愈方案和规则。
+
+| 字段名 | 类型 | 说明 |
+|--------|------|------|
+| id | varchar(255) PK | 治愈方案 ID |
+| desc | text | 简单描述，如 action 是处理什么告警场景的 |
+| type | varchar(255) | 对应的故障域类型 |
+| rules | jsonb | 条件规则：{condition1: action1, condition2: action2} |
+
+**索引建议：**
+- PRIMARY KEY: `id`
+- INDEX: `(type)`
+
+**示例数据：**
+```sql
+INSERT INTO heal_actions (id, desc, type, rules) VALUES 
+('service_version_rollback', '服务版本回滚方案', 'service_version_issue', 
+ '{"deployment_status": "deploying", "action": "rollback", "target": "previous_version"}'),
+('service_version_alert', '服务版本告警方案', 'service_version_issue', 
+ '{"deployment_status": "deployed", "action": "alert", "message": "版本已发布，暂不支持自动回滚"}');
+```
+
+TODO： health_state映射逻辑
+
 ## 数据关系（ER）
 
 ```mermaid
@@ -175,13 +204,25 @@ erDiagram
         text content
     }
 
+    heal_actions {
+        varchar id PK
+        text desc
+        varchar type
+        jsonb rules
+    }
+
     %% 通过 service 等标签在应用层逻辑关联
     alert_rule_metas ||..|| alert_rules : "by alert_name"
     service_states ||..|| alert_rule_metas : "by service/version labels"
+    heal_actions ||..|| alert_issues : "by fault domain analysis"
 ```
 
 ## 数据流转
 
 1. 以 `alert_rules` 为模版，结合 `alert_rule_metas` 渲染出面向具体服务/版本等的规则（labels 可为空 `{}` 表示全局默认，或包含如 service/version 等标签）。
 2. 指标或规则参数发生调整时，记录到 `alert_meta_change_logs`。
-3. 规则触发创建 `alert_issues`；处理过程中的动作写入 `alert_issue_comments`。
+3. 规则触发创建 `alert_issues`；处理过程中的动作写入 `alert_issue_comments`。
+4. **告警治愈流程**：
+   - P0 告警：根据 `alert_issues.labels` 识别故障域，查询 `heal_actions` 获取治愈方案
+   - 执行治愈操作（如回滚），成功后更新 `alert_issues` 和 `service_states` 状态
+   - P1/P2 告警：直接进入下钻分析，记录分析结果到 `alert_issue_comments`

go.mod

@@ -9,13 +9,15 @@ require (
 	github.com/lib/pq v1.10.9
 	github.com/redis/go-redis/v9 v9.5.1
 	github.com/rs/zerolog v1.34.0
+	github.com/stretchr/testify v1.11.1
 )
 
 require (
 	github.com/bytedance/sonic v1.13.3 // indirect
 	github.com/bytedance/sonic/loader v0.2.4 // indirect
 	github.com/cespare/xxhash/v2 v2.2.0 // indirect
 	github.com/cloudwego/base64x v0.1.5 // indirect
+	github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc // indirect
 	github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect
 	github.com/gabriel-vasile/mimetype v1.4.9 // indirect
 	github.com/gin-contrib/cors v1.7.6 // indirect
@@ -39,6 +41,7 @@ require (
 	github.com/modern-go/reflect2 v1.0.2 // indirect
 	github.com/natefinch/lumberjack v2.0.0+incompatible // indirect
 	github.com/pelletier/go-toml/v2 v2.2.4 // indirect
+	github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 // indirect
 	github.com/twitchyliquid64/golang-asm v0.15.1 // indirect
 	github.com/ugorji/go/codec v1.3.0 // indirect
 	golang.org/x/arch v0.18.0 // indirect

internal/alerting/database/database.go

@@ -38,3 +38,8 @@ func (d *Database) ExecContext(ctx context.Context, q string, args ...any) (sql.
 func (d *Database) QueryContext(ctx context.Context, q string, args ...any) (*sql.Rows, error) {
 	return d.db.QueryContext(ctx, q, args...)
 }
+
+// QueryRowContext exposes database/sql QueryRowContext for single row SELECT queries.
+func (d *Database) QueryRowContext(ctx context.Context, q string, args ...any) *sql.Row {
+	return d.db.QueryRowContext(ctx, q, args...)
+}