From 22018d21ce33077e63e6be2c716aea6788e3ffc6 Mon Sep 17 00:00:00 2001 From: DanB Date: Wed, 26 Aug 2015 15:45:21 +0200 Subject: [PATCH] Remove .Debug from CDRs --- engine/cdrs.go | 8 -------- engine/fscdr.go | 1 - 2 files changed, 9 deletions(-) diff --git a/engine/cdrs.go b/engine/cdrs.go index 7f5b91d8f..e76f8e03f 100644 --- a/engine/cdrs.go +++ b/engine/cdrs.go @@ -148,7 +148,6 @@ func (self *CdrServer) RateCdrs(cgrIds, runIds, tors, cdrHosts, cdrSources, reqT // Returns error if not able to properly store the CDR, mediation is async since we can always recover offline func (self *CdrServer) processCdr(storedCdr *StoredCdr) (err error) { - Logger.Debug(fmt.Sprintf("***processCdr: %+v", storedCdr)) if storedCdr.Direction == "" { storedCdr.Direction = utils.OUT } @@ -178,7 +177,6 @@ func (self *CdrServer) processCdr(storedCdr *StoredCdr) (err error) { if err := self.cdrDb.SetCdr(storedCdr); err != nil { // Only original CDR stored in primary table, no derived Logger.Err(fmt.Sprintf(" Storing primary CDR %+v, got error: %s", storedCdr, err.Error())) } - Logger.Debug(fmt.Sprintf("***Have set primary CDR to: %+v", storedCdr)) } go self.deriveRateStoreStatsReplicate(storedCdr) return nil @@ -186,27 +184,23 @@ func (self *CdrServer) processCdr(storedCdr *StoredCdr) (err error) { // Returns error if not able to properly store the CDR, mediation is async since we can always recover offline func (self *CdrServer) deriveRateStoreStatsReplicate(storedCdr *StoredCdr) error { - Logger.Debug(fmt.Sprintf("***deriveRateStoreStatsReplicate storedCdr: %+v", storedCdr)) cdrRuns, err := self.deriveCdrs(storedCdr) if err != nil { return err } for _, cdr := range cdrRuns { // Rate CDR - Logger.Debug(fmt.Sprintf("***deriveRateStoreStatsReplicate cdr in runs: %+v", cdr)) if self.rater != nil && !cdr.Rated { if err := self.rateCDR(cdr); err != nil { cdr.Cost = -1.0 // If there was an error, mark the CDR cdr.ExtraInfo = err.Error() } } - Logger.Debug(fmt.Sprintf("***deriveRateStoreStatsReplicate after rating cdr is: %+v", cdr)) if self.cgrCfg.CDRSStoreCdrs { // Store CDRs // Store RatedCDR if err := self.cdrDb.SetRatedCdr(cdr); err != nil { Logger.Err(fmt.Sprintf(" Storing rated CDR %+v, got error: %s", cdr, err.Error())) } - Logger.Debug(fmt.Sprintf("***deriveRateStoreStatsReplicate stored cdr is: %+v", cdr)) // Store CostDetails if cdr.Rated || utils.IsSliceMember([]string{utils.RATED, utils.META_RATED}, cdr.ReqType) { // Account related CDRs are saved automatically, so save the others here if requested if err := self.cdrDb.LogCallCost(cdr.CgrId, utils.CDRS_SOURCE, cdr.MediationRunId, cdr.CostDetails); err != nil { @@ -299,9 +293,7 @@ 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 { diff --git a/engine/fscdr.go b/engine/fscdr.go index 459122a88..5f857d54f 100644 --- a/engine/fscdr.go +++ b/engine/fscdr.go @@ -142,6 +142,5 @@ func (fsCdr FSCdr) AsStoredCdr(timezone string) *StoredCdr { storCdr.DisconnectCause = utils.FirstNonEmpty(fsCdr.vars[utils.CGR_DISCONNECT_CAUSE], fsCdr.vars["hangup_cause"]) storCdr.ExtraFields = fsCdr.getExtraFields() storCdr.Cost = -1 - Logger.Debug(fmt.Sprintf("***FSCdr.AsStoredCDR, original answer time: %s, timezone: %s, returning storCdr: %+v", fsCdr.vars[FS_ANSWER_TIME], timezone, storCdr)) return storCdr }