diff --git a/util/extract.go b/util/extract.go index dc4e022..c27ecfe 100644 --- a/util/extract.go +++ b/util/extract.go @@ -95,7 +95,7 @@ func ExtractWithoutAttributes(base models.AnalyticsConversationWithoutAttributes } sessions = append(sessions, session) - for _, seg := range sess.Segments { + for idx, seg := range sess.Segments { segmentStart, err := time.Parse(time.RFC3339, seg.SegmentStart) if err != nil { @@ -113,7 +113,7 @@ func ExtractWithoutAttributes(base models.AnalyticsConversationWithoutAttributes } segment := models.DBSegment{ - Id: fmt.Sprintf("%s_%s", session.Id, seg.SegmentType), + Id: fmt.Sprintf("%s_%s_%d", session.Id, seg.SegmentType, idx), Conference: seg.Conference, DisconnectType: seg.DisconnectType, Q850ResponseCodes: string(q850ResponseCodesBytes),