Skip to content

feat: candidate submission (amber-khan) #17

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
phil510 wants to merge 1 commit into
base: master
Choose a base branch
from
Open

feat: candidate submission (amber-khan) #17

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
17 changes: 11 additions & 6 deletions models/orders/dw/order_fact.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -8,10 +8,7 @@ WITH shipment_lines AS (
sl.shipment_id
, sl.line_item_id
, sl.quantity_shipped
, li.unit_price
FROM {{ ref('stg_shipment_line_items') }} AS sl
INNER JOIN {{ ref('stg_line_items') }} AS li
ON sl.line_item_id = li.line_item_id
)

, joined AS (
Expand All @@ -27,7 +24,6 @@ WITH shipment_lines AS (
, s.shipped_at
, sl.line_item_id
, sl.quantity_shipped
, sl.unit_price
FROM {{ ref('stg_orders') }} AS o
LEFT JOIN {{ ref('stg_shipments') }} AS s
ON o.order_id = s.order_id
Expand All @@ -49,7 +45,6 @@ WITH shipment_lines AS (
, shipped_at
, count(DISTINCT line_item_id) AS line_count
, sum(quantity_shipped) AS total_quantity
, sum(quantity_shipped * unit_price) AS shipment_revenue
FROM joined
GROUP BY order_id, merchant_id, customer_id, order_status, is_test, ordered_at, paid_at, shipment_id, shipped_at
)
Expand All @@ -62,6 +57,14 @@ WITH shipment_lines AS (
GROUP BY order_id
)

, line_revenue AS (
SELECT
order_id
, sum(quantity * unit_price) AS revenue
FROM {{ ref('stg_line_items') }}
GROUP BY order_id
)

, enriched AS (
SELECT
st.order_id
Expand All @@ -77,12 +80,14 @@ WITH shipment_lines AS (
, sc.shipment_count
, st.line_count
, st.total_quantity
, st.shipment_revenue AS revenue
, lr.revenue
FROM shipment_totals AS st
LEFT JOIN {{ ref('lkp_merchants') }} AS m
ON st.merchant_id = m.merchant_id
LEFT JOIN shipment_counts AS sc
ON st.order_id = sc.order_id
LEFT JOIN line_revenue AS lr
ON st.order_id = lr.order_id
)

SELECT
Expand Down