gilles/hammond
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

some alerting code

Browse Source
This commit is contained in:
Akhil Gupta
2022-04-26 11:54:55 +05:30
parent fca2c3e7fa
commit dcb58bbbdb
1 changed files with 11 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
server/service/alertSevice.go
View File

@@ -38,11 +38,15 @@ func CreateAlertInstance(alertId string) error {
return err return err
} }
existingOccurence, err := db.GetAlertOccurenceByAlertId(alertId) existingOccurence, err := db.GetAlertOccurenceByAlertId(alertId)
if err != nil {
return err
}
var lastOccurance db.AlertOccurance var lastOccurance db.AlertOccurance
useOccurance := false
if len(*existingOccurence) > 0 { if len(*existingOccurence) > 0 {
lastOccurance = (*existingOccurence)[0] lastOccurance = (*existingOccurence)[0]
useOccurance = true
if alert.AlertFrequency == db.ONETIME { if alert.AlertFrequency == db.ONETIME {
return errors.New("Only single occurance is possible for this kind of alert") return errors.New("Only single occurance is possible for this kind of alert")
} }
@@ -68,13 +72,13 @@ func CreateAlertInstance(alertId string) error {
if alert.AlertType == db.DISTANCE || alert.AlertType == db.BOTH { if alert.AlertType == db.DISTANCE || alert.AlertType == db.BOTH {
model.OdoReading = alert.StartOdoReading + alert.OdoFrequency model.OdoReading = alert.StartOdoReading + alert.OdoFrequency
if &lastOccurance != nil { if useOccurance {
model.OdoReading = lastOccurance.OdoReading + alert.OdoFrequency model.OdoReading = lastOccurance.OdoReading + alert.OdoFrequency
} }
} }
if alert.AlertType == db.TIME || alert.AlertType == db.BOTH { if alert.AlertType == db.TIME || alert.AlertType == db.BOTH {
date := alert.StartDate.Add(time.Duration(alert.DayFrequency) * 24 * time.Hour) date := alert.StartDate.Add(time.Duration(alert.DayFrequency) * 24 * time.Hour)
if &lastOccurance != nil { if useOccurance {
date = lastOccurance.Date.Add(time.Duration(alert.DayFrequency) * 24 * time.Hour) date = lastOccurance.Date.Add(time.Duration(alert.DayFrequency) * 24 * time.Hour)
} }
model.Date = &date model.Date = &date
@@ -162,3 +166,7 @@ func FindAlertOccurancesToProcess(today time.Time) ([]db.AlertOccurance, error)
} }
return toReturn, nil return toReturn, nil
} }
func MarkAlertOccuranceAsCompleted() {
}