uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-14 20:59:53 +05:00
Code Issues Packages Projects Releases Wiki Activity

[CdrStats] Fix issue with LASTExecutionID on update triggers

Browse Source
This commit is contained in:
Eloy Coto
2016-08-17 17:16:26 +01:00
parent e142227780
commit bdc30af37a
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 {