Changed breakdown to use a composite PK

models/amendment.go

@@ -9,23 +9,9 @@ type DBAmendment struct {
 	AmendmentValue  string
 	Requestor       string
 	RequestedAt     time.Time
+	Sequence        string
 }
 
 func (DBAmendment) TableName() string {
 	return "gc_amendments"
 }
-
-type DBAmendmentLog struct {
-	Id              int    `gorm:"primaryKey;autoIncrement"`
-	ConversationId  string `gorm:"index"`
-	AmendmentColumn string
-	OldValue        string
-	NewValue        string
-	Requestor       string
-	RequestedAt     time.Time
-	AmendedAt       time.Time
-}
-
-func (DBAmendmentLog) TableName() string {
-	return "gc_amendment_logs"
-}

models/base_call.go

@@ -1,5 +1,6 @@
 package models
 
+/*
 import (
 	"time"
 )
@@ -9,8 +10,10 @@ type BaseCall struct {
 	CallType             string `gorm:"index"`
 	GenderPreference     string
 	ClientId             int `gorm:"index"`
+	LanguageId           int
 	CustomerDnis         string
 	CustomerAni          string
+	SearchStartTime      *time.Time
 	P1ConnectTime        time.Time `gorm:"index"`
 	P1DisconnectTime     time.Time `gorm:"index"`
 	P3ConnectTime        *time.Time
@@ -24,3 +27,4 @@ type BaseCall struct {
 func (BaseCall) TableName() string {
 	return "gc_base_calls"
 }
+*/

models/booking.go

@@ -0,0 +1,28 @@
+package models
+
+import "time"
+
+type Booking struct {
+	BookingReference int        `gorm:"primaryKey;index"`
+	BookingTime      *time.Time `gorm:"index"`
+	Timezone         *string
+	Language         *string
+	CustomData       *string
+	Method           *string `gorm:"index"`
+	Duration         *int
+	BookedDuration   *int
+	ConversationId   *string `gorm:"index"`
+	CancellationTime *time.Time
+	InterpreterId    *int `gorm:"index"`
+	ClientId         *int `gorm:"index"`
+	AgentName        *string
+	AgentEmail       *string
+	AgentPhone       *string
+	Comments         *string
+	BillingCode      *string
+	TicketId         string
+}
+
+func (Booking) TableName() string {
+	return "gc_bookings"
+}

models/call_stat.go

@@ -0,0 +1,29 @@
+package models
+
+/*
+import (
+	"time"
+)
+
+type CallStat struct {
+	ClientConversationId string `gorm:"primaryKey;index"`
+	CallType             string `gorm:"index"`
+	ClientId             int    `gorm:"index"`
+	CustomerDnis         string
+	CustomerAni          string
+	P1ConnectTime        time.Time `gorm:"index"`
+	P1DisconnectTime     time.Time `gorm:"index"`
+	BookingRequestNumber *int      `gorm:"index"`
+	UtsQueue             bool
+	InterpreterCount     int
+	InterpreterConnected bool
+	ClientDisconnected   bool
+	UtsDuration          int
+	UtsEntries           int
+	Status               string
+}
+
+func (CallStat) TableName() string {
+	return "gc_call_stats"
+}
+*/

models/crm_invoice_config.go

@@ -23,8 +23,8 @@ type CrmInvoiceConfig struct {
 	PartnerAudioBookingBH *string `gorm:"column:partner_audio_booking_bh" json:"partner_audio_booking_bh"`
 	PartnerVideoBookingAH *string `gorm:"column:partner_video_booking_ah" json:"partner_video_booking_ah"`
 	PartnerVideoBookingBH *string `gorm:"column:partner_video_booking_bh" json:"partner_video_booking_bh"`
+	RoundingFunction      *string `gorm:"column:rounding_function" json:"rounding_function"`
 	RoundBookings         *bool   `gorm:"column:round_bookings" json:"round_bookings"`
-	RoundingFunction      *bool   `gorm:"column:rounding_function" json:"rounding_function"`
 	SplitBookings         *bool   `gorm:"column:split_bookings" json:"split_bookings"`
 	SplitOnDemand         *bool   `gorm:"column:split_on_demand" json:"split_on_demand"`
 }

models/formatter.go

@@ -0,0 +1,107 @@
+package models
+
+import "time"
+
+type BaseCall struct {
+	ClientConversationId string `gorm:"primaryKey;index"`
+	CallType             string `gorm:"index"`
+	GenderPreference     string
+	ClientId             int `gorm:"index"`
+	LanguageId           int
+	CustomerDnis         string
+	CustomerAni          string
+	SearchStartTime      *time.Time
+	P1ConnectTime        time.Time `gorm:"index"`
+	P1DisconnectTime     time.Time `gorm:"index"`
+	P3ConnectTime        *time.Time
+	P3DisconnectTime     *time.Time
+	BookingRequestNumber *int `gorm:"index"`
+	IvrData              *int
+	UtsEntries           int
+	InterpreterCount     int
+	Status               string
+}
+
+func (BaseCall) TableName() string {
+	return "gc_base_calls"
+}
+
+type InterpreterAttempt struct {
+	InterpreterConversationId string `gorm:"primaryKey;index"`
+	InterpreterResponseTime   time.Time
+	InterpreterAccepted       bool
+	InterpreterId             int `gorm:"index"`
+	CallType                  string
+	CallConnected             string
+	ClientConversationId      string `gorm:"index"`
+	LanguageId                int
+	InterpreterPhone          string
+	ConversationStart         time.Time
+	ConversationEnd           time.Time
+}
+
+func (InterpreterAttempt) TableName() string {
+	return "gc_interpreter_attempts"
+}
+
+type InterpreterConnection struct {
+	InterpreterConversationId string `gorm:"primaryKey;index"`
+	InterpreterAccepted       bool
+	InterpreterId             int `gorm:"index"`
+	CallType                  string
+	CallConnected             string
+	ClientConversationId      string `gorm:"index"`
+	LanguageId                int
+	InterpreterPhone          string
+	ConferenceStart           time.Time
+	ConferenceEnd             time.Time
+}
+
+func (InterpreterConnection) TableName() string {
+	return "gc_interpreter_connections"
+}
+
+type CallStat struct {
+	ClientConversationId      string `gorm:"primaryKey;index"`
+	CallType                  string `gorm:"index"`
+	ClientId                  int    `gorm:"index"`
+	CustomerDnis              string
+	CustomerAni               string
+	ConversationStart         *time.Time `gorm:"index"`
+	ConversationEnd           *time.Time `gorm:"index"`
+	SearchStartTime           *time.Time
+	P1ConnectTime             time.Time `gorm:"index"`
+	P1DisconnectTime          time.Time `gorm:"index"`
+	BookingRequestNumber      *int      `gorm:"index"`
+	UtsQueue                  bool
+	InterpreterAcceptedCount  int
+	InterpreterAccepted       bool
+	InterpreterConnectedCount int
+	InterpreterConnected      bool
+	ClientDisconnected        bool
+	UtsDuration               int
+	UtsEntries                int
+	Status                    string
+	SubStatus                 string
+	FirstLanguageId           int
+	LastLanguageId            int
+	FirstInterpreter          string
+}
+
+func (CallStat) TableName() string {
+	return "gc_call_stats"
+}
+
+type Breakdown struct {
+	ClientConversationId      string    `gorm:"primaryKey;index"`
+	InterpreterConversationId string    `gorm:"index"`
+	Timestamp                 time.Time `gorm:"primaryKey;index"`
+	Task                      string    `gorm:"primaryKey"`
+	Duration                  int
+	Message                   string
+	Metadata                  *string `gorm:"type:json"`
+}
+
+func (Breakdown) TableName() string {
+	return "gc_call_breakdown"
+}

models/gencloud.go

@@ -16,7 +16,7 @@ type AnalyticsConversationWithAttributes struct {
 	OriginatingDirection             string   `json:"originatingDirection"`
 	Participants                     []struct {
 		ExternalContactId string `json:"externalContactId"`
-		ParticipantId     string `json:"participantId"`
+		ParticipantId     string `json:"id"`
 		ParticipantName   string `json:"participantName"`
 		Purpose           string `json:"purpose"`
 		Sessions          []struct {

models/interpreter_attempt.go

@@ -0,0 +1,25 @@
+package models
+
+/*
+import (
+	"time"
+)
+
+type InterpreterAttempt struct {
+	InterpreterConversationId string `gorm:"primaryKey;index"`
+	InterpreterResponseTime   time.Time
+	InterpreterAccepted       bool
+	InterpreterId             int `gorm:"index"`
+	CallType                  string
+	CallConnected             string
+	ClientConversationId      string `gorm:"index"`
+	LanguageId                int
+	InterpreterPhone          string
+	ConversationStart         time.Time
+	ConversationEnd           time.Time
+}
+
+func (InterpreterAttempt) TableName() string {
+	return "gc_interpreter_attempts"
+}
+*/

models/interpreter_connection.go

@@ -1,5 +1,6 @@
 package models
 
+/*
 import (
 	"time"
 )
@@ -20,3 +21,4 @@ type InterpreterConnection struct {
 func (InterpreterConnection) TableName() string {
 	return "gc_interpreter_connections"
 }
+*/

models/processed.go

@@ -4,6 +4,144 @@ import (
 	"time"
 )
 
+type DBClientProcessed struct {
+
+	// CALL DETAILS
+	// ---
+	ClientConversationId string `gorm:"primaryKey"`
+	CallType             string
+	GenderPreference     string
+	BookingReference     *int
+	IvrData              *int
+	BillableClient       bool
+	CallOutcome          string
+
+	// FLAGS / METADATA:
+	// ---
+	BuggedCall  bool
+	Amended     bool
+	CreatedAt   time.Time `gorm:"autoCreateTime"`
+	ModifiedAt  time.Time
+	CustomData  *string `gorm:"type:json"`
+	InternalUse *string `gorm:"type:json"`
+
+	// LANGUAGE DETAILS:
+	// ---
+	LanguageId    int
+	LanguageCrmId string
+	LanguageName  string
+
+	// CLIENT DETAILS:
+	// ---
+	ClientId           int
+	CustomerDnis       string
+	CustomerAni        string
+	ClientName         string
+	ClientState        string
+	ClientFunding      bool
+	ClientGroupId      int
+	ClientGroupName    string
+	ClientPoReference  string
+	InvoiceConfigCrmId string
+	InvoiceConfigName  string
+	InvoiceConfigUsed  string
+	ClientCallDuration int
+	ClientTimeOfDay    string
+	ClientBill         float64
+	ClientRate         float64
+	ClientTaxStatus    string
+
+	// PARTNER DETAILS:
+	// ---
+	PartnerBill float64
+	PartnerRate float64
+
+	// TIMESTAMP DETAILS:
+	// ---
+	P1SearchStartTime *time.Time
+	P1ConnectTime     time.Time
+	P1DisconnectTime  time.Time
+	P3ConnectTime     *time.Time
+	P3DisconnectTime  *time.Time
+}
+
+func (DBClientProcessed) TableName() string {
+	return "gc_client_processed"
+}
+
+type DBInterpreterProcessed struct {
+
+	// CALL DETAILS
+	// ---
+	ClientConversationId      string
+	InterpreterConversationId string `gorm:"primaryKey"`
+	CallType                  string
+	GenderPreference          string
+	BookingReference          *int
+	BillableInterpreter       bool
+	BillableTpa               bool
+
+	// FLAGS / METADATA:
+	// ---
+	BuggedCall  bool
+	Amended     bool
+	CreatedAt   time.Time `gorm:"autoCreateTime"`
+	ModifiedAt  time.Time
+	CustomData  *string `gorm:"type:json"`
+	InternalUse *string `gorm:"type:json"`
+
+	// LANGUAGE DETAILS:
+	// ---
+	LanguageId    int
+	LanguageCrmId string
+	LanguageName  string
+
+	// CLIENT DETAILS:
+	// ---
+	ClientId    int
+	ClientName  string
+	ClientState string
+
+	// INTERPRETER DETAILS:
+	// ---
+	InterpreterId                       int
+	InterpreterCrmId                    string
+	InterpreterName                     string
+	InterpreterPhone                    string
+	InterpreterGst                      bool
+	InterpreterNaatiId                  string
+	InterpreterGender                   string
+	InterpreterState                    string
+	InterpreterPaymentState             string
+	InterpreterEmployer                 string
+	InterpreterLanguagePriority         int
+	InterpreterLanguageNaatiLevel       int
+	InterpreterLanguageNaatiDescription string
+	InterpreterLanguageWtn              bool
+	InterpreterCallDuration             int
+	InterpreterTimeOfDay                string
+	InterpreterPayment                  float64
+	InterpreterRate                     float64
+	PaymentConfigCrmId                  string
+	PaymentConfigName                   string
+	PaymentConfigUsed                   string
+
+	// TIMESTAMP DETAILS:
+	// ---
+	P1SearchStartTime *time.Time
+	P1ConnectTime     time.Time
+	P1DisconnectTime  time.Time
+	P2SearchStartTime *time.Time
+	P2AcceptanceTime  time.Time
+	P2ConferenceTime  time.Time
+	P2DisconnectTime  time.Time
+}
+
+func (DBInterpreterProcessed) TableName() string {
+	return "gc_interpreter_processed"
+}
+
+/*
 type Processed struct {
 	ClientConversationId      string `gorm:"index"`
 	InterpreterConversationId string `gorm:"primaryKey;index"`
@@ -43,3 +181,4 @@ type Processed struct {
 func (Processed) TableName() string {
 	return "gc_processed"
 }
+*/

models/queue_log.go

@@ -8,6 +8,7 @@ type DBQueueLog struct {
 	Start          time.Time `gorm:"index"`
 	End            time.Time `gorm:"index"`
 	Duration       float64
+	NextQueue      string
 	Result         string `gorm:"type:json"`
 }
 

models/segment.go

@@ -12,7 +12,7 @@ type DBSegment struct {
 	SegmentEnd        time.Time `gorm:"index"`
 	SegmentStart      time.Time `gorm:"index"`
 	SegmentType       string    `gorm:"index"`
-	SessionId         string    `gorm:"foreignKey"`
+	SessionId         string    `gorm:"index;foreignKey"`
 	WrapUpCode        string
 }
 

models/ticket.go

@@ -2,6 +2,73 @@ package models
 
 import "time"
 
+type DBTicket struct {
+	AccountId            int
+	ApprovalCount        int
+	Assignee             string `gorm:"type:json"`
+	AssigneeId           int
+	AttachmentCount      int
+	Category             string
+	CF                   string `gorm:"type:json"`
+	Channel              string
+	ChannelCode          string
+	ChannelRelatedInfo   string
+	Classification       string
+	ClosedTime           *time.Time
+	CommentCount         int
+	Contact              string `gorm:"type:json"`
+	ContactId            int
+	CreatedBy            int
+	CreatedTime          time.Time
+	CustomerResponseTime time.Time
+	DepartmentId         int
+	DescAttachments      string `gorm:"type:json"`
+	Description          string
+	DueDate              *time.Time
+	Email                string
+	EntitySkills         string `gorm:"type:json"`
+	FirstThread          string `gorm:"type:json"`
+	FollowerCount        int
+	Id                   string `gorm:"primaryKey"`
+	IsArchived           bool
+	IsDeleted            bool
+	IsEscalated          bool
+	IsOverdue            bool
+	IsResponseOverdue    bool
+	IsSpam               bool
+	IsTrashed            bool
+	Language             string
+	LayoutDetails        string `gorm:"type:json"`
+	LayoutId             int
+	ModifiedBy           int
+	ModifiedTime         time.Time
+	OnHoldTime           *time.Time
+	Phone                string
+	Priority             string
+	ProductId            string
+	Resolution           string
+	ResponseDueDate      *time.Time
+	SecondaryContacts    string `gorm:"type:json"`
+	Sentiment            string
+	SharedDepartments    string `gorm:"type:json"`
+	Source               string `gorm:"type:json"`
+	Status               string
+	StatusType           string
+	SubCategory          string
+	Subject              string
+	TagCount             int
+	TaskCount            int
+	TeamId               int
+	ThreadCount          int
+	TicketNumber         int
+	TimeEntryCount       int
+	WebUrl               string
+}
+
+func (DBTicket) TableName() string {
+	return "zoho_live_tickets"
+}
+
 type Ticket struct {
 	TicketID                        string     `gorm:"primaryKey;column:ticket_id" json:"ticket_id"`
 	TicketReferenceID               *string    `gorm:"column:ticket_reference_id" json:"ticket_reference_id"`

util/extract.go

@@ -22,9 +22,9 @@ func ExtractWithoutAttributes(base models.AnalyticsConversationWithoutAttributes
 	var endTime *time.Time
 	parsedEndTime, err := time.Parse(time.RFC3339, base.ConversationEnd)
 	if err != nil {
-		startTime = nil
+		endTime = nil
 	} else {
-		startTime = &parsedEndTime
+		endTime = &parsedEndTime
 	}
 
 	divisionIdsBytes, err := json.Marshal(base.DivisionIds)