Amend models to be warehouse

Author: lukej-rd

jaffle_shop/models/customers.sql

@@ -1,8 +1,14 @@
 version: 2
 
 models:
-  - name: customers
-    description: This table has basic information about a customer, as well as some derived facts based on a customer's orders
+  - name: wh_customers
+    access: public
+    config:
+      group: industry_operations
+    meta:
+      owner: luke.ralphs-davies@octoenergy.com
+    description: |
+      This table has basic information about a customer, as well as some derived facts based on a customer's orders
 
     columns:
       - name: customer_id
@@ -12,10 +18,10 @@ models:
           - not_null
 
       - name: first_name
-        description: Customer's first name. PII.
+        description: Customer's first name (hashed).
 
       - name: last_name
-        description: Customer's last name. PII.
+        description: Customer's last name (hashed).
 
       - name: first_order
         description: Date (UTC) of a customer's first order
@@ -29,8 +35,14 @@ models:
       - name: total_order_amount
         description: Total value (AUD) of a customer's orders
 
-  - name: orders
-    description: This table has basic information about orders, as well as some derived facts based on payments
+  - name: wh_orders
+    access: public
+    config:
+      group: industry_operations
+    meta:
+      owner: luke.ralphs-davies@octoenergy.com
+    description: |
+      This table has basic information about orders, as well as some derived facts based on payments.
 
     columns:
       - name: order_id

jaffle_shop/models/orders.sql

@@ -0,0 +1,42 @@
+WITH customer_orders as (
+    SELECT
+        customer_id
+        , MIN(order_date) AS first_order
+        , MAX(order_date) as most_recent_order
+        , COUNT(order_id) as number_of_orders
+    FROM {{ ref('stg_orders') }}
+
+    GROUP BY customer_id
+
+),
+
+customer_payments as (
+    SELECT
+        orders.customer_id
+        , SUM(payments.amount) AS total_amount
+
+    FROM {{ ref('stg_payments') }} AS payments
+
+    LEFT JOIN orders ON
+         payments.order_id = orders.order_id
+
+    GROUP BY orders.customer_id
+
+),
+
+SELECT
+    customers.customer_id
+    , customers.first_name
+    , customers.last_name
+    , customer_orders.first_order
+    , customer_orders.most_recent_order
+    , customer_orders.number_of_orders
+    , customer_payments.total_amount AS customer_lifetime_value
+
+FROM {{ ref('stg_customers') }} AS customers
+
+LEFT JOIN customer_orders
+    ON customers.customer_id = customer_orders.customer_id
+
+LEFT JOIN customer_payments
+    ON customers.customer_id = customer_payments.customer_id

jaffle_shop/models/docs.md jaffle_shop/models/warehouse/_docs.mdjaffle_shop/models/docs.md renamed to jaffle_shop/models/warehouse/_docs.md

@@ -0,0 +1,36 @@
+{% set payment_methods = ['credit_card', 'coupon', 'bank_transfer', 'gift_card'] %}
+
+WITH order_payments AS (
+    SELECT
+        order_id
+
+        {% for payment_method in payment_methods -%}
+        , SUM(CASE WHEN payment_method = '{{ payment_method }}' THEN amount ELSE 0 END) AS {{ payment_method }}_amount
+        {% endfor -%}
+
+        , SUM(amount) AS total_amount
+
+    FROM {{ ref('stg_payments') }}
+
+    GROUP BY order_id
+
+),
+
+SELECT
+    orders.order_id
+    , orders.customer_id
+    , orders.order_date
+    , orders.status
+
+    {% for payment_method in payment_methods -%}
+
+    , order_payments.{{ payment_method }}_amount
+    {% endfor -%}
+
+    , order_payments.total_amount AS amount
+
+FROM {{ ref('stg_orders') }} AS orders
+
+
+LEFT JOIN order_payments
+    ON orders.order_id = order_payments.order_id