diff --git a/internal/repository/pg_advanced_outreach.go b/internal/repository/pg_advanced_outreach.go index 2db57bd4..f73c2414 100644 --- a/internal/repository/pg_advanced_outreach.go +++ b/internal/repository/pg_advanced_outreach.go @@ -664,7 +664,8 @@ func (r *advancedOutreachRepository) GetDeliverabilityDashboard(ctx context.Cont SELECT COUNT(*) FROM tasks t JOIN email_accounts ea ON ea.id = t.email_account_id WHERE ea.organization_id = $1 AND t.task_type = 'campaign' AND t.status = 'completed' - AND t.completed_at >= $2 AND t.completed_at <= $3` + AND t.completed_at >= $2 AND t.completed_at <= $3 + AND ` + taskDispatchedEmail _ = r.db.QueryRow(ctx, sentQuery, organizationID, from, to).Scan(&out.EmailsSent) out.BounceRate = models.Rate(out.BounceCount, out.EmailsSent) out.ComplaintRate = models.Rate(out.ComplaintCount, out.EmailsSent) diff --git a/internal/repository/pg_advisor_snapshot.go b/internal/repository/pg_advisor_snapshot.go index 920d2d7a..8f540fd6 100644 --- a/internal/repository/pg_advisor_snapshot.go +++ b/internal/repository/pg_advisor_snapshot.go @@ -70,6 +70,7 @@ func (r *advisorRepository) loadMailboxes(ctx context.Context, orgID uuid.UUID) WHERE t.email_account_id = ea.id AND t.task_type = 'campaign' AND t.status = 'completed' AND t.completed_at > NOW() - INTERVAL '30 days' + AND ` + taskDispatchedEmail + ` ) sent ON true LEFT JOIN LATERAL ( SELECT diff --git a/internal/repository/pg_organization.go b/internal/repository/pg_organization.go index 28a0c057..e355562a 100644 --- a/internal/repository/pg_organization.go +++ b/internal/repository/pg_organization.go @@ -641,6 +641,7 @@ func (r *organizationRepository) GetEmailsSentTodayCount(ctx context.Context, or AND t.task_type = 'campaign' AND t.status = 'completed' AND t.completed_at >= CURRENT_DATE + AND `+taskDispatchedEmail+` `, orgID).Scan(&count) return count, err }