floraachy
/
console
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update message priority after rule changed

This commit is contained in:
liugq 2022-07-13 11:24:38 +08:00
parent a3d8e0bfd1
commit efb57041e5
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
service/alerting/elasticsearch/engine.go
View File

@ -659,7 +659,8 @@ func (engine *Engine) Do(rule *alerting.Rule) error {
if alertMessage != nil && alertMessage.Status != alerting.MessageStateRecovered && !checkResults.QueryResult.Nodata { if alertMessage != nil && alertMessage.Status != alerting.MessageStateRecovered && !checkResults.QueryResult.Nodata {
alertMessage.Status = alerting.MessageStateRecovered alertMessage.Status = alerting.MessageStateRecovered
alertMessage.Updated = time.Now() alertMessage.ResourceID = rule.Resource.ID
alertMessage.ResourceName= rule.Resource.Name
err = saveAlertMessage(alertMessage) err = saveAlertMessage(alertMessage)
if err != nil { if err != nil {
return fmt.Errorf("save alert message error: %w", err) return fmt.Errorf("save alert message error: %w", err)
@ -709,6 +710,9 @@ func (engine *Engine) Do(rule *alerting.Rule) error {
}else{ }else{
alertMessage.Title = alertItem.Title alertMessage.Title = alertItem.Title
alertMessage.Message = alertItem.Message alertMessage.Message = alertItem.Message
alertMessage.ResourceID = rule.Resource.ID
alertMessage.ResourceName= rule.Resource.Name
alertMessage.Priority = priority
err = saveAlertMessage(alertMessage) err = saveAlertMessage(alertMessage)
if err != nil { if err != nil {
return fmt.Errorf("save alert message error: %w", err) return fmt.Errorf("save alert message error: %w", err)