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

Update CreatedAt when working on TP inserts

Browse Source
This commit is contained in:
DanB
2014-11-12 18:59:02 +01:00
parent da21ffd32c
commit afb4a7e39f
4 changed files with 20 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
engine/models.go
View File

@@ -313,7 +313,6 @@ func (t TblCdrsExtra) TableName() string {
type TblCostDetail struct {
Id int64
CostTime time.Time
CostSource string
Cgrid string
Runid string

5
engine/storage_mysql.go
View File

@@ -23,6 +23,7 @@ import (
"github.com/cgrates/cgrates/config"
"github.com/cgrates/cgrates/utils"
"path"
"time"
_ "github.com/go-sql-driver/mysql"
"github.com/jinzhu/gorm"
@@ -68,8 +69,8 @@ func (self *MySQLStorage) SetTPTiming(tm *utils.ApierTPTiming) error {
if tm == nil {
return nil //Nothing to set
}
if _, err := self.Db.Exec(fmt.Sprintf("INSERT INTO %s (tpid, tag, years, months, month_days, week_days, time) VALUES('%s','%s','%s','%s','%s','%s','%s') ON DUPLICATE KEY UPDATE years=values(years), months=values(months), month_days=values(month_days), week_days=values(week_days), time=values(time)",
utils.TBL_TP_TIMINGS, tm.TPid, tm.TimingId, tm.Years, tm.Months, tm.MonthDays, tm.WeekDays, tm.Time)); err != nil {
if _, err := self.Db.Exec(fmt.Sprintf("INSERT INTO %s (tpid, tag, years, months, month_days, week_days, time, created_at) VALUES('%s','%s','%s','%s','%s','%s','%s', %d) ON DUPLICATE KEY UPDATE years=values(years), months=values(months), month_days=values(month_days), week_days=values(week_days), time=values(time)",
utils.TBL_TP_TIMINGS, tm.TPid, tm.TimingId, tm.Years, tm.Months, tm.MonthDays, tm.WeekDays, tm.Time, time.Now().Unix())); err != nil {
return err
}
return nil

3
engine/storage_postgres.go
View File

@@ -23,6 +23,7 @@ import (
"github.com/cgrates/cgrates/config"
"github.com/cgrates/cgrates/utils"
"path"
"time"
_ "github.com/bmizerany/pq"
"github.com/jinzhu/gorm"
@@ -73,7 +74,7 @@ func (self *PostgresStorage) SetTPTiming(tm *utils.ApierTPTiming) error {
tx.Rollback()
return err
}
if err := tx.Save(&TpTiming{Tpid: tm.TPid, Tag: tm.TimingId, Years: tm.Years, Months: tm.Months, MonthDays: tm.MonthDays, WeekDays: tm.WeekDays, Time: tm.Time}).Error; err != nil {
if err := tx.Save(&TpTiming{Tpid: tm.TPid, Tag: tm.TimingId, Years: tm.Years, Months: tm.Months, MonthDays: tm.MonthDays, WeekDays: tm.WeekDays, Time: tm.Time, CreatedAt: time.Now()}).Error; err != nil {
tx.Rollback()
return err
}

18
engine/storage_sql.go
View File

@@ -204,9 +204,10 @@ func (self *SQLStorage) SetTPDestination(tpid string, dest *Destination) error {
}
for _, prefix := range dest.Prefixes {
save := tx.Save(TpDestination{
Tpid: tpid,
Tag: dest.Id,
Prefix: prefix,
Tpid: tpid,
Tag: dest.Id,
Prefix: prefix,
CreatedAt: time.Now(),
})
if save.Error != nil {
tx.Rollback()
@@ -236,6 +237,7 @@ func (self *SQLStorage) SetTPRates(tpid string, rts map[string][]*utils.RateSlot
RateUnit: rs.RateUnit,
RateIncrement: rs.RateIncrement,
GroupIntervalStart: rs.GroupIntervalStart,
CreatedAt: time.Now(),
})
if save.Error != nil {
tx.Rollback()
@@ -267,6 +269,7 @@ func (self *SQLStorage) SetTPDestinationRates(tpid string, drs map[string][]*uti
RatesTag: dr.RateId,
RoundingMethod: dr.RoundingMethod,
RoundingDecimals: dr.RoundingDecimals,
CreatedAt: time.Now(),
})
if saved.Error != nil {
tx.Rollback()
@@ -295,6 +298,7 @@ func (self *SQLStorage) SetTPRatingPlans(tpid string, drts map[string][]*utils.T
DestratesTag: rp.DestinationRatesId,
TimingTag: rp.TimingId,
Weight: rp.Weight,
CreatedAt: time.Now(),
})
if saved.Error != nil {
tx.Rollback()
@@ -327,6 +331,7 @@ func (self *SQLStorage) SetTPRatingProfiles(tpid string, rpfs map[string]*utils.
ActivationTime: ra.ActivationTime,
RatingPlanTag: ra.RatingPlanId,
FallbackSubjects: ra.FallbackSubjects,
CreatedAt: time.Now(),
})
if saved.Error != nil {
tx.Rollback()
@@ -355,6 +360,7 @@ func (self *SQLStorage) SetTPSharedGroups(tpid string, sgs map[string][]*utils.T
Account: sg.Account,
Strategy: sg.Strategy,
RatingSubject: sg.RatingSubject,
CreatedAt: time.Now(),
})
if saved.Error != nil {
tx.Rollback()
@@ -401,6 +407,7 @@ func (self *SQLStorage) SetTPCdrStats(tpid string, css map[string][]*utils.TPCdr
RatedSubject: cs.RatedSubject,
CostInterval: cs.CostInterval,
ActionTriggers: cs.ActionTriggers,
CreatedAt: time.Now(),
})
if saved.Error != nil {
tx.Rollback()
@@ -442,6 +449,7 @@ func (self *SQLStorage) SetTPDerivedChargers(tpid string, sgs map[string][]*util
SetupTimeField: dc.SetupTimeField,
AnswerTimeField: dc.AnswerTimeField,
UsageField: dc.UsageField,
CreatedAt: time.Now(),
}
if err := newDc.SetDerivedChargersId(dcId); err != nil {
tx.Rollback()
@@ -509,6 +517,7 @@ func (self *SQLStorage) SetTPActions(tpid string, acts map[string][]*utils.TPAct
BalanceWeight: ac.BalanceWeight,
ExtraParameters: ac.ExtraParameters,
Weight: ac.Weight,
CreatedAt: time.Now(),
})
if saved.Error != nil {
tx.Rollback()
@@ -562,6 +571,7 @@ func (self *SQLStorage) SetTPActionTimings(tpid string, ats map[string][]*utils.
ActionsTag: ap.ActionsId,
TimingTag: ap.TimingId,
Weight: ap.Weight,
CreatedAt: time.Now(),
})
if saved.Error != nil {
tx.Rollback()
@@ -614,6 +624,7 @@ func (self *SQLStorage) SetTPActionTriggers(tpid string, ats map[string][]*utils
MinQueuedItems: at.MinQueuedItems,
ActionsTag: at.ActionsId,
Weight: at.Weight,
CreatedAt: time.Now(),
})
if saved.Error != nil {
tx.Rollback()
@@ -644,6 +655,7 @@ func (self *SQLStorage) SetTPAccountActions(tpid string, aas map[string]*utils.T
Direction: aa.Direction,
ActionPlanTag: aa.ActionPlanId,
ActionTriggersTag: aa.ActionTriggersId,
CreatedAt: time.Now(),
})
if saved.Error != nil {
tx.Rollback()