diff --git a/cdrc/csv.go b/cdrc/csv.go index ff175e997..d6aabfa7e 100644 --- a/cdrc/csv.go +++ b/cdrc/csv.go @@ -309,7 +309,7 @@ func (self *CsvRecordsProcessor) recordToStoredCdr(record []string, cfgIdx int) return nil, err } } - storedCdr.CgrId = utils.Sha1(storedCdr.AccId, storedCdr.SetupTime.String()) + storedCdr.CgrId = utils.Sha1(storedCdr.AccId, storedCdr.SetupTime.UTC().String()) if storedCdr.TOR == utils.DATA && self.duMultiplyFactors[cfgIdx] != 0 { storedCdr.Usage = time.Duration(float64(storedCdr.Usage.Nanoseconds()) * self.duMultiplyFactors[cfgIdx]) } diff --git a/cdrc/fwv.go b/cdrc/fwv.go index 4b21ca508..0aa57818d 100644 --- a/cdrc/fwv.go +++ b/cdrc/fwv.go @@ -195,7 +195,7 @@ func (self *FwvRecordsProcessor) recordToStoredCdr(record string, cfgKey string) } } if storedCdr.CgrId == "" && storedCdr.AccId != "" && cfgKey != "*header" { - storedCdr.CgrId = utils.Sha1(storedCdr.AccId, storedCdr.SetupTime.String()) + storedCdr.CgrId = utils.Sha1(storedCdr.AccId, storedCdr.SetupTime.UTC().String()) } if storedCdr.TOR == utils.DATA && duMultiplyFactor != 0 { storedCdr.Usage = time.Duration(float64(storedCdr.Usage.Nanoseconds()) * duMultiplyFactor) diff --git a/engine/storedcdr.go b/engine/storedcdr.go index 98015d3e5..0b2bcd672 100644 --- a/engine/storedcdr.go +++ b/engine/storedcdr.go @@ -39,7 +39,7 @@ func NewStoredCdrFromExternalCdr(extCdr *ExternalCdr, timezone string) (*StoredC return nil, err } if len(storedCdr.CgrId) == 0 { // Populate CgrId if not present - storedCdr.CgrId = utils.Sha1(storedCdr.AccId, storedCdr.SetupTime.String()) + storedCdr.CgrId = utils.Sha1(storedCdr.AccId, storedCdr.SetupTime.UTC().String()) } if storedCdr.AnswerTime, err = utils.ParseTimeDetectLayout(extCdr.AnswerTime, timezone); err != nil { return nil, err