mirror of
https://github.com/hanzoai/datastore.git
synced 2026-09-26 13:55:07 +00:00
96 lines
3.1 KiB
SQL
96 lines
3.1 KiB
SQL
WITH
|
|
ssr AS
|
|
(
|
|
SELECT
|
|
s_store_id AS store_id,
|
|
sum(ss_ext_sales_price) AS sales,
|
|
sum(coalesce(sr_return_amt, 0)) AS returns,
|
|
sum(ss_net_profit - coalesce(sr_net_loss, 0)) AS profit
|
|
FROM store_sales
|
|
LEFT JOIN store_returns ON (ss_item_sk = sr_item_sk) AND (ss_ticket_number = sr_ticket_number), date_dim, store, item, promotion
|
|
WHERE (ss_sold_date_sk = d_date_sk)
|
|
AND ((d_date >= CAST('2000-08-23', 'date')) AND (d_date <= (CAST('2000-08-23', 'date') + INTERVAL 30 DAY)))
|
|
AND (ss_store_sk = s_store_sk)
|
|
AND (ss_item_sk = i_item_sk)
|
|
AND (i_current_price > 50)
|
|
AND (ss_promo_sk = p_promo_sk)
|
|
AND (p_channel_tv = 'N')
|
|
GROUP BY s_store_id
|
|
),
|
|
csr AS
|
|
(
|
|
SELECT
|
|
cp_catalog_page_id AS catalog_page_id,
|
|
sum(cs_ext_sales_price) AS sales,
|
|
sum(coalesce(cr_return_amount, 0)) AS returns,
|
|
sum(cs_net_profit - coalesce(cr_net_loss, 0)) AS profit
|
|
FROM catalog_sales
|
|
LEFT JOIN catalog_returns ON (cs_item_sk = cr_item_sk) AND (cs_order_number = cr_order_number), date_dim, catalog_page, item, promotion
|
|
WHERE (cs_sold_date_sk = d_date_sk)
|
|
AND ((d_date >= CAST('2000-08-23', 'date')) AND (d_date <= (CAST('2000-08-23', 'date') + INTERVAL 30 DAY)))
|
|
AND (cs_catalog_page_sk = cp_catalog_page_sk)
|
|
AND (cs_item_sk = i_item_sk)
|
|
AND (i_current_price > 50)
|
|
AND (cs_promo_sk = p_promo_sk)
|
|
AND (p_channel_tv = 'N')
|
|
GROUP BY cp_catalog_page_id
|
|
),
|
|
wsr AS
|
|
(
|
|
SELECT
|
|
web_site_id,
|
|
sum(ws_ext_sales_price) AS sales,
|
|
sum(coalesce(wr_return_amt, 0)) AS returns,
|
|
sum(ws_net_profit - coalesce(wr_net_loss, 0)) AS profit
|
|
FROM web_sales
|
|
LEFT JOIN web_returns ON (ws_item_sk = wr_item_sk) AND (ws_order_number = wr_order_number), date_dim, web_site, item, promotion
|
|
WHERE (ws_sold_date_sk = d_date_sk)
|
|
AND ((d_date >= CAST('2000-08-23', 'date')) AND (d_date <= (CAST('2000-08-23', 'date') + INTERVAL 30 DAY)))
|
|
AND (ws_web_site_sk = web_site_sk)
|
|
AND (ws_item_sk = i_item_sk)
|
|
AND (i_current_price > 50)
|
|
AND (ws_promo_sk = p_promo_sk)
|
|
AND (p_channel_tv = 'N')
|
|
GROUP BY web_site_id
|
|
)
|
|
SELECT
|
|
channel,
|
|
id,
|
|
sum(sales) AS sales,
|
|
sum(returns) AS returns,
|
|
sum(profit) AS profit
|
|
FROM
|
|
(
|
|
SELECT
|
|
'store channel' AS channel,
|
|
concat('store', store_id) AS id,
|
|
sales,
|
|
returns,
|
|
profit
|
|
FROM ssr
|
|
UNION ALL
|
|
SELECT
|
|
'catalog channel' AS channel,
|
|
concat('catalog_page', catalog_page_id) AS id,
|
|
sales,
|
|
returns,
|
|
profit
|
|
FROM csr
|
|
UNION ALL
|
|
SELECT
|
|
'web channel' AS channel,
|
|
concat('web_site', web_site_id) AS id,
|
|
sales,
|
|
returns,
|
|
profit
|
|
FROM wsr
|
|
) AS x
|
|
GROUP BY
|
|
channel,
|
|
id
|
|
WITH ROLLUP
|
|
ORDER BY
|
|
channel,
|
|
id
|
|
LIMIT 100;
|