diff --git a/engine/cdrs.go b/engine/cdrs.go index c367eb345..5cbd7e63a 100644 --- a/engine/cdrs.go +++ b/engine/cdrs.go @@ -270,7 +270,9 @@ func (self *CdrServer) getCostFromRater(storedCdr *StoredCdr) (*CallCost, error) DurationIndex: storedCdr.Usage, } if utils.IsSliceMember([]string{utils.META_PSEUDOPREPAID, utils.META_POSTPAID, utils.META_PREPAID, utils.PSEUDOPREPAID, utils.POSTPAID, utils.PREPAID}, storedCdr.ReqType) { // Prepaid - Cost can be recalculated in case of missing records from SM + //Logger.Debug(utils.ToJSON(cd)) if err = self.rater.Debit(cd, cc); err == nil { // Debit has occured, we are forced to write the log, even if CDR store is disabled + //Logger.Debug(utils.ToJSON(cc)) self.cdrDb.LogCallCost(storedCdr.CgrId, utils.CDRS_SOURCE, storedCdr.MediationRunId, cc) } } else { @@ -314,7 +316,9 @@ func (self *CdrServer) rateCDR(storedCdr *StoredCdr) error { // ToDo: Add websocket support func (self *CdrServer) replicateCdr(cdr *StoredCdr) error { + Logger.Debug(fmt.Sprintf("replicateCdr cdr: %+v, configuration: %+v", cdr, self.cgrCfg.CDRSCdrReplication)) for _, rplCfg := range self.cgrCfg.CDRSCdrReplication { + Logger.Debug(fmt.Sprintf("Replicating CDR with configuration: %+v", rplCfg)) passesFilters := true for _, cdfFltr := range rplCfg.CdrFilter { if fltrPass, _ := cdr.PassesFieldFilter(cdfFltr); !fltrPass {