uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-12 10:36:24 +05:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' of https://github.com/cgrates/cgrates

Browse Source
This commit is contained in:
DanB
2016-08-23 18:38:10 +02:00
parent 0a73acf5af 27de55ed42
commit 48c52d357d
1 changed files with 12 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
engine/stats_queue.go
View File

@@ -77,6 +77,9 @@ func (sq *StatsQueue) UpdateConf(conf *CdrStats) {
defer sq.mux.Unlock()
// check if new conf asks for action trigger reset only
if sq.conf != nil && (conf.hasGeneralConfigs() || sq.conf.equalExceptTriggers(conf)) {
for _, trigger := range conf.Triggers {
trigger.LastExecutionTime = sq.GetTriggerLastExecution(&trigger.ID)
}
sq.conf.Triggers = conf.Triggers
return
}
@@ -172,6 +175,15 @@ func (sq *StatsQueue) appendQcdr(qcdr *QCdr, runTrigger bool) {
}
}
func (sq *StatsQueue) GetTriggerLastExecution(trigger_id *string) time.Time {
for _, trigger := range sq.conf.Triggers {
if trigger.ID == *trigger_id {
return trigger.LastExecutionTime
}
}
return time.Time{}
}
func (sq *StatsQueue) addToMetrics(cdr *QCdr) {
//log.Print("AddToMetrics: " + utils.ToIJSON(cdr))
for _, metric := range sq.metrics {