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

logging for user balance restore

Browse Source
This commit is contained in:
Radu Ioan Fericean
2012-09-21 15:06:18 +03:00
parent cdc7f8114b
commit aea3a158c3
4 changed files with 6 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
cmd/cgr-rater/cgr-rater.go
View File

@@ -204,7 +204,6 @@ func startMediator(responder *timespans.Responder, loggerDb timespans.DataStorag
timespans.Logger.Crit(fmt.Sprintf("Could not connect to rater: %v", err))
exitChan <- true
}
timespans.Logger.Debug(fmt.Sprintf("Using remote connector: %s.", mediator_rater))
connector = &timespans.RPCClientConnector{client}
}
if _, err := os.Stat(mediator_cdr_path); err != nil {

11
mediator/mediator.go
View File

@@ -158,17 +158,12 @@ func (m *Mediator) parseCSV(cdrfn string) (err error) {
cc, err = m.GetCostsFromDB(record)
} else {
cc, err = m.GetCostsFromRater(record)
}
if err != nil {
timespans.Logger.Err(fmt.Sprintf("Could not get the cost for mediator record (%v): %v", record, err))
timespans.Logger.Err(fmt.Sprintf("Could not get the cost for mediator record (%s): %v", record[m.uuidIndex], err))
} else {
if cc != nil {
timespans.Logger.Debug(fmt.Sprintf("Calculated cost: %v (%v)", cc.ConnectFee+cc.Cost, strconv.FormatFloat(cc.ConnectFee+cc.Cost, 'f', -1, 64)))
record = append(record, strconv.FormatFloat(cc.ConnectFee+cc.Cost, 'f', -1, 64))
} else {
timespans.Logger.Err(fmt.Sprintf("Got nil call cost for record (%v)", record))
}
timespans.Logger.Debug(fmt.Sprintf("Calculated cost: %v (%v)", cc.ConnectFee+cc.Cost, strconv.FormatFloat(cc.ConnectFee+cc.Cost, 'f', -1, 64)))
record = append(record, strconv.FormatFloat(cc.ConnectFee+cc.Cost, 'f', -1, 64))
}
w.WriteString(strings.Join(record, ",") + "\n")
}

1
timespans/storage_redis.go
View File

@@ -92,6 +92,7 @@ func (rs *RedisStorage) SetActions(key string, as []*Action) (err error) {
}
func (rs *RedisStorage) GetUserBalance(key string) (ub *UserBalance, err error) {
Logger.Debug(fmt.Sprintf("Getting ub for: %v", key))
if values, err := rs.db.Get(USER_BALANCE_PREFIX + key); err == nil {
ub = &UserBalance{Id: key}
err = rs.ms.Unmarshal(values, ub)

2
timespans/userbalance.go
View File

@@ -20,6 +20,7 @@ package timespans
import (
"errors"
"fmt"
"strconv"
"strings"
)
@@ -303,6 +304,7 @@ func (ub *UserBalance) store() (result string) {
De-serializes the user balance for the storage. Used for key-value storages.
*/
func (ub *UserBalance) restore(input string) {
Logger.Debug(fmt.Sprintf("User balance string", input))
elements := strings.Split(input, "|")
ub.Id = elements[0]
ub.Type = elements[1]