Build voucher users

models/staging/exchange/stg_exchange__voucher_redemptions.sql

@@ -1,9 +1,9 @@
 -- IMPORTS
 WITH source AS (
     SELECT * FROM {{ source('src_exchange_mysql', 'voucher_redemptions') }}
-
 ),
 
+
 -- LOGIC
 voucher_redemptions_rename AS (
 
@@ -15,14 +15,16 @@ voucher_redemptions_rename AS (
         value               AS voucher_credit,
         created_at          AS created_datetime,
         updated_at          AS updated_datetime,
+
         '{{ modules.datetime.datetime.now(modules.pytz.timezone("Asia/Kuala_Lumpur")) }}' AS _dbt_ran_datetime
 
     FROM source
 
 ),
 
+
 -- FINAL
-final__base_exchange__voucher_redemptions AS (
+final__stg_exchange__voucher_redemptions AS (
 
     SELECT
         -- ids
@@ -47,4 +49,4 @@ final__base_exchange__voucher_redemptions AS (
 
 )
 
-SELECT * FROM final__base_exchange__voucher_redemptions
+SELECT * FROM final__stg_exchange__voucher_redemptions

models/staging/exchange/stg_exchange__vouchers.sql

@@ -1,9 +1,9 @@
--- IMPORTS
+-- IMPORT
 WITH source AS (
     SELECT * FROM {{ source('src_exchange_mysql', 'vouchers') }}
-
 ),
 
+
 -- LOGIC
 vouchers_rename AS (
 
@@ -11,18 +11,22 @@ vouchers_rename AS (
         id              AS voucher_id,
         name,
         code,
-        type,
+        type            AS credit_type,
         value           AS voucher_credit,
+        start_date      AS voucher_start_datetime,
+        end_date        AS voucher_end_datetime
         created_at      AS created_datetime,
         updated_at      AS updated_datetime,
+
         '{{ modules.datetime.datetime.now(modules.pytz.timezone("Asia/Kuala_Lumpur")) }}' AS _dbt_ran_datetime
 
     FROM source
 
 ),
 
+
 -- FINAL
-final__base_exchange__vouchers AS (
+final__stg_exchange__vouchers AS (
 
     SELECT
         -- ids
@@ -32,11 +36,14 @@ final__base_exchange__vouchers AS (
         name,
         code,
         type,
-        voucher_credit,
+        credit_type,
 
         -- measures
+        voucher_credit,
 
         -- date/times
+        voucher_start_datetime,
+        voucher_end_datetime
         created_datetime,
         updated_datetime,
 
@@ -47,4 +54,4 @@ final__base_exchange__vouchers AS (
 
 )
 
-SELECT * FROM final__base_exchange__vouchers
+SELECT * FROM final__stg_exchange__vouchers