修改threshold阈值小数，修改数据库表不一致问题

Author: acd19ml

client/src/views/ChangeLogView.vue

@@ -68,14 +68,6 @@
           </template>
         </div>
       </el-tab-pane>
-
-      <el-tab-pane label="xxx 变更记录" name="other1">
-        <div class="placeholder">占位</div>
-      </el-tab-pane>
-
-      <el-tab-pane label="xxx 变更记录" name="other2">
-        <div class="placeholder">占位</div>
-      </el-tab-pane>
     </el-tabs>
   </div>
 </template>

docker-compose.prod.yml

@@ -56,6 +56,7 @@ services:
     volumes:
       - ./configs:/app/configs:ro
       - ./config.docker.json:/app/config.json:ro
+      - ./internal/deploy/config.yaml:/app/internal/deploy/config.yaml:ro
     ports:
       - "8080:8080"
     healthcheck:

docs/alerting/database-design.md

@@ -157,7 +157,7 @@ erDiagram
         timestamp report_at
         timestamp resolved_at
         varchar health_state
-        varchar correlation_id
+        varchar alert_issue_ids
     }
 
     alert_issues {

docs/service_manager/model/schema.sql

@@ -37,7 +37,7 @@ CREATE TABLE IF NOT EXISTS service_states (
     report_at TIMESTAMP,
     resolved_at TIMESTAMP,
     health_state VARCHAR(50),
-    correlation_id VARCHAR(255),
+    alert_issue_ids VARCHAR(255),
     PRIMARY KEY (service, version),
     FOREIGN KEY (service) REFERENCES services(name) ON DELETE CASCADE
 );

internal/alerting/service/healthcheck/common_test.go

@@ -0,0 +1,14 @@
+package healthcheck
+
+import (
+	"fmt"
+	"math"
+	"testing"
+)
+
+func TestCommon(t *testing.T) {
+	baseTh := 97.0
+
+	newThreshold := baseTh - math.Ceil(baseTh*0.01)
+	fmt.Println(newThreshold)
+}

internal/alerting/service/healthcheck/scheduler.go

@@ -357,7 +357,7 @@ func runPrometheusAnomalyDetection(ctx context.Context, deps PrometheusDeps) err
 			log.Debug().Str("alert_name", q.AlertName).Str("service", service).Str("version", version).Msg("no exact meta threshold found; skip")
 			continue
 		}
-		newThreshold := baseTh * 0.99
+		newThreshold := baseTh - math.Ceil(baseTh*0.01)
 
 		// fetch all metas for this service (across versions)
 		metas, ferr := fetchMetasForService(ctx, deps.DB, q.AlertName, service)

internal/service_manager/database/info_repo.go

@@ -155,7 +155,7 @@ func (d *Database) CreateServiceInstance(ctx context.Context, instance *model.Se
 
 // GetServiceState 获取服务状态
 func (d *Database) GetServiceState(ctx context.Context, serviceName string) (*model.ServiceState, error) {
-	query := `SELECT service, version, report_at, resolved_at, health_state, correlation_id
+	query := `SELECT service, version, report_at, resolved_at, health_state, alert_issue_ids
 	          FROM service_states WHERE service = $1 ORDER BY report_at DESC LIMIT 1`
 	row := d.QueryRowContext(ctx, query, serviceName)
 

internal/service_manager/model/service_state.go

@@ -4,10 +4,10 @@ import "time"
 
 // ServiceState 服务状态信息
 type ServiceState struct {
-	Service       string      `json:"service" db:"service"`              // varchar(255) - 联合PK
-	Version       string      `json:"version" db:"version"`              // varchar(255) - 联合PK
-	ReportAt      time.Time   `json:"reportAt" db:"report_at"`           // time - 报告时间
-	ResolvedAt    *time.Time  `json:"resolvedAt" db:"resolved_at"`       // time - 解决时间
-	HealthState   HealthState `json:"healthState" db:"health_state"`     // 健康状态
-	CorrelationID string      `json:"correlationId" db:"correlation_id"` // varchar - 关联ID
+	Service       string      `json:"service" db:"service"`               // varchar(255) - 联合PK
+	Version       string      `json:"version" db:"version"`               // varchar(255) - 联合PK
+	ReportAt      time.Time   `json:"reportAt" db:"report_at"`            // time - 报告时间
+	ResolvedAt    *time.Time  `json:"resolvedAt" db:"resolved_at"`        // time - 解决时间
+	HealthState   HealthState `json:"healthState" db:"health_state"`      // 健康状态
+	CorrelationID string      `json:"alertIssueIds" db:"alert_issue_ids"` // varchar - 关联ID
 }