From 7155fd1886a3838abf1027c14068fc540494326b Mon Sep 17 00:00:00 2001
From: Jessica McInchak <jessica.mcinchak@gmail.com>
Date: Thu, 16 Nov 2023 08:19:19 +0000
Subject: [PATCH] feat: create a `submission_services_summary` database view
 for analytics (#2430)

---
 hasura.planx.uk/metadata/tables.yaml          |  3 ++
 .../down.sql                                  |  1 +
 .../up.sql                                    | 47 +++++++++++++++++++
 3 files changed, 51 insertions(+)
 create mode 100644 hasura.planx.uk/migrations/1700072112794_create_view_submission_services_summary/down.sql
 create mode 100644 hasura.planx.uk/migrations/1700072112794_create_view_submission_services_summary/up.sql

diff --git a/hasura.planx.uk/metadata/tables.yaml b/hasura.planx.uk/metadata/tables.yaml
index c81b9218b2..fade60a7e9 100644
--- a/hasura.planx.uk/metadata/tables.yaml
+++ b/hasura.planx.uk/metadata/tables.yaml
@@ -1217,6 +1217,9 @@
             - locked_at:
                 _is_null: true
         check: null
+- table:
+    schema: public
+    name: submission_services_summary
 - table:
     schema: public
     name: team_members
diff --git a/hasura.planx.uk/migrations/1700072112794_create_view_submission_services_summary/down.sql b/hasura.planx.uk/migrations/1700072112794_create_view_submission_services_summary/down.sql
new file mode 100644
index 0000000000..ce4411d705
--- /dev/null
+++ b/hasura.planx.uk/migrations/1700072112794_create_view_submission_services_summary/down.sql
@@ -0,0 +1 @@
+DROP VIEW public.submission_services_summary CASCADE;
diff --git a/hasura.planx.uk/migrations/1700072112794_create_view_submission_services_summary/up.sql b/hasura.planx.uk/migrations/1700072112794_create_view_submission_services_summary/up.sql
new file mode 100644
index 0000000000..824fa05854
--- /dev/null
+++ b/hasura.planx.uk/migrations/1700072112794_create_view_submission_services_summary/up.sql
@@ -0,0 +1,47 @@
+CREATE OR REPLACE VIEW public.submission_services_summary AS 
+with resumes_per_session as (
+    select 
+        session_id,
+        count(id) as number_times_resumed
+    from reconciliation_requests
+    group by session_id
+)
+select 
+    ls.id as session_id,
+    t.slug as team_slug,
+    f.slug as service_slug,
+    ls.created_at,
+    ls.submitted_at,
+    (ls.submitted_at::date - ls.created_at::date) as session_length_days,
+    ls.has_user_saved as user_clicked_save,
+    rps.number_times_resumed,
+    case 
+      when pr.id is null
+      then false
+      else true
+    end as user_invited_to_pay,
+    case 
+      when ba.bops_id is null
+      then false
+      else true
+    end as sent_to_bops,
+    case 
+      when ua.idox_submission_id is null
+      then false
+      else true
+    end as sent_to_uniform,
+    case 
+      when ea.id is null
+      then false
+      else true
+    end as sent_to_email
+from lowcal_sessions ls
+ left join flows f on f.id = ls.flow_id
+ left join teams t on t.id = f.team_id
+ left join resumes_per_session rps on rps.session_id = ls.id::text
+ left join payment_requests pr on pr.session_id = ls.id
+ left join bops_applications ba on ba.session_id = ls.id::text
+ left join uniform_applications ua on ua.submission_reference = ls.id::text
+ left join email_applications ea on ea.session_id = ls.id
+where f.slug IS NOT NULL
+ and t.slug IS NOT NULL;