uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-11 18:16: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
2013-12-18 20:05:58 +01:00
parent f3d0c49803 f7d7a34c17
commit 17af9c312a
2 changed files with 84 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
engine/loader_csv.go
View File

@@ -99,6 +99,7 @@ func openStringCSVReader(data string, comma rune, nrFields int) (csvReader *csv.
}
func (csvr *CSVReader) ShowStatistics() {
// destinations
destCount := len(csvr.destinations)
log.Print("Destinations: ", destCount)
prefixDist := make(map[int]int, 50)
@@ -112,6 +113,40 @@ func (csvr *CSVReader) ShowStatistics() {
for k, v := range prefixDist {
log.Printf("%d: %d", k, v)
}
// rating plans
rplCount := len(csvr.ratingPlans)
log.Print("Rating plans: ", rplCount)
destRatesDist := make(map[int]int, 50)
destRatesCount := 0
for _, rpl := range csvr.ratingPlans {
destRatesDist[len(rpl.DestinationRates)] += 1
destRatesCount += len(rpl.DestinationRates)
}
log.Print("Avg Destination Rates: ", destRatesCount/rplCount)
log.Print("Destination Rates distribution:")
for k, v := range destRatesDist {
log.Printf("%d: %d", k, v)
}
// rating profiles
rpfCount := len(csvr.ratingProfiles)
log.Print("Rating profiles: ", rpfCount)
activDist := make(map[int]int, 50)
activCount := 0
for _, rpf := range csvr.ratingProfiles {
activDist[len(rpf.RatingPlanActivations)] += 1
activCount += len(rpf.RatingPlanActivations)
}
log.Print("Avg Activations: ", activCount/rpfCount)
log.Print("Activation distribution:")
for k, v := range activDist {
log.Printf("%d: %d", k, v)
}
// actions
log.Print("Actions: ", len(csvr.actions))
// action timings
log.Print("Action timings: ", len(csvr.actionsTimings))
// account actions
log.Print("Account actions: ", len(csvr.accountActions))
}
func (csvr *CSVReader) WriteToDatabase(flush, verbose bool) (err error) {

49
engine/loader_db.go
View File

@@ -57,7 +57,56 @@ func NewDbReader(storDB LoadStorage, ratingDb RatingStorage, accountDb Accountin
return c
}
// FIXME: this method is code duplication from csv loader
func (dbr *DbReader) ShowStatistics() {
// destinations
destCount := len(dbr.destinations)
log.Print("Destinations: ", destCount)
prefixDist := make(map[int]int, 50)
prefixCount := 0
for _, d := range dbr.destinations {
prefixDist[len(d.Prefixes)] += 1
prefixCount += len(d.Prefixes)
}
log.Print("Avg Prefixes: ", prefixCount/destCount)
log.Print("Prefixes distribution:")
for k, v := range prefixDist {
log.Printf("%d: %d", k, v)
}
// rating plans
rplCount := len(dbr.ratingPlans)
log.Print("Rating plans: ", rplCount)
destRatesDist := make(map[int]int, 50)
destRatesCount := 0
for _, rpl := range dbr.ratingPlans {
destRatesDist[len(rpl.DestinationRates)] += 1
destRatesCount += len(rpl.DestinationRates)
}
log.Print("Avg Destination Rates: ", destRatesCount/rplCount)
log.Print("Destination Rates distribution:")
for k, v := range destRatesDist {
log.Printf("%d: %d", k, v)
}
// rating profiles
rpfCount := len(dbr.ratingProfiles)
log.Print("Rating profiles: ", rpfCount)
activDist := make(map[int]int, 50)
activCount := 0
for _, rpf := range dbr.ratingProfiles {
activDist[len(rpf.RatingPlanActivations)] += 1
activCount += len(rpf.RatingPlanActivations)
}
log.Print("Avg Activations: ", activCount/rpfCount)
log.Print("Activation distribution:")
for k, v := range activDist {
log.Printf("%d: %d", k, v)
}
// actions
log.Print("Actions: ", len(dbr.actions))
// action timings
log.Print("Action timings: ", len(dbr.actionsTimings))
// account actions
log.Print("Account actions: ", len(dbr.accountActions))
}
func (dbr *DbReader) WriteToDatabase(flush, verbose bool) (err error) {