uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-13 19:56:38 +05:00
Code Issues Packages Projects Releases Wiki Activity

Stats configured within CDRS

Browse Source
This commit is contained in:
DanB
2017-08-09 00:58:46 +02:00
parent ae54392a85
commit 94686b36cd
1 changed files with 25 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
engine/cdrs.go
View File

@@ -197,11 +197,21 @@ func (self *CdrServer) processCdr(cdr *CDR) (err error) {
var out int
go self.cdrstats.Call("CDRStatsV1.AppendCDR", cdr, &out)
}
if self.stats != nil {
cdrIf, _ := cdr.AsMapStringIface()
cdrIf[utils.ID] = cdr.CGRID
if cdrIf[utils.ID] == "" {
cdrIf[utils.ID] = cdr.OriginID
}
var reply string
go self.stats.Call("StatSV1.ProcessEvent", cdrIf, &reply)
}
if len(self.cgrCfg.CDRSOnlineCDRExports) != 0 { // Replicate raw CDR
self.replicateCDRs([]*CDR{cdr})
}
if self.rals != nil && !cdr.Rated { // CDRs not rated will be processed by Rating
go self.deriveRateStoreStatsReplicate(cdr, self.cgrCfg.CDRSStoreCdrs, self.cdrstats != nil, len(self.cgrCfg.CDRSOnlineCDRExports) != 0)
go self.deriveRateStoreStatsReplicate(cdr, self.cgrCfg.CDRSStoreCdrs,
self.cdrstats != nil, len(self.cgrCfg.CDRSOnlineCDRExports) != 0)
}
return nil
}
@@ -278,9 +288,20 @@ func (self *CdrServer) deriveRateStoreStatsReplicate(cdr *CDR, store, cdrstats,
// Attach CDR to stats
if cdrstats { // Send CDR to stats
for _, ratedCDR := range ratedCDRs {
var out int
if err := self.cdrstats.Call("CDRStatsV1.AppendCDR", ratedCDR, &out); err != nil {
utils.Logger.Err(fmt.Sprintf("<CDRS> Could not send CDR to cdrstats: %s", err.Error()))
if self.cdrstats != nil {
var out int
if err := self.cdrstats.Call("CDRStatsV1.AppendCDR", ratedCDR, &out); err != nil {
utils.Logger.Err(fmt.Sprintf("<CDRS> Could not send CDR to cdrstats: %s", err.Error()))
}
}
if self.stats != nil {
cdrIf, _ := ratedCDR.AsMapStringIface()
cdrIf[utils.ID] = ratedCDR.CGRID
if cdrIf[utils.ID] == "" {
cdrIf[utils.ID] = ratedCDR.OriginID
}
var reply string
go self.stats.Call("StatSV1.ProcessEvent", cdrIf, &reply)
}
}
}