Build cash flow analysis

models/staging/exchange/base/base_exchange__wallet_logs.sql

@@ -37,8 +37,8 @@ final__base_exchange__wallet_logs AS (
         currency_id,
 
         -- dimensions
-        owner_type,
         code,
+        owner_type,
 
         -- measures
         amount,

models/staging/exchange/base/base_exchange__wallets.sql

@@ -35,8 +35,8 @@ final__base_exchange__wallets AS (
         currency_id,
 
         -- dimensions
-        owner_type,
         code,
+        owner_type,
 
         -- measures
         amount,

models/staging/exchange/stg_exchange__wallet_balance_logs.sql

@@ -0,0 +1,58 @@
+-- IMPORT
+WITH wallet_logs AS (
+    SELECT * FROM {{ ref('base_exchange__wallet_logs') }}
+),
+
+
+-- LOGIC
+renamed AS (
+
+    SELECT
+        wallet_log_id,
+        wallet_id,
+        owner_id        AS company_id,
+        currency_id,
+        code,
+        amount          AS wallet_balance,
+        created_datetime,
+        updated_datetime,
+        deleted_datetime,
+
+        '{{ modules.datetime.datetime.now(modules.pytz.timezone("Asia/Kuala_Lumpur")) }}' AS _dbt_ran_datetime
+
+    FROM wallet_logs
+
+    WHERE owner_type = 'App\\Models\\Company'
+
+),
+
+
+-- FINAL
+final__base_exchange__wallet_logs AS (
+
+    SELECT
+        --ids
+        wallet_log_id,
+        wallet_id,
+        company_id,
+        currency_id,
+
+        --dimensions
+        code,
+        
+        --measures
+        wallet_balance,
+
+        --date/times
+        created_datetime,
+        updated_datetime,
+        deleted_datetime,
+
+        --metadata
+        _dbt_ran_datetime
+
+    FROM renamed
+
+)
+
+SELECT * FROM final__base_exchange__wallet_logs

models/staging/exchange/stg_exchange__wallet_balances.sql

@@ -0,0 +1,56 @@
+-- IMPORT
+WITH wallets AS (
+    SELECT * FROM {{ ref('base_exchange__wallets') }}
+),
+
+
+-- LOGIC
+renamed AS (
+
+    SELECT
+        wallet_id,
+        owner_id        AS company_id,
+        currency_id,
+        code,
+        amount          AS wallet_balance,
+        created_datetime,
+        updated_datetime,
+        deleted_datetime,
+
+        '{{ modules.datetime.datetime.now(modules.pytz.timezone("Asia/Kuala_Lumpur")) }}' AS _dbt_ran_datetime
+
+    FROM wallets
+
+    WHERE owner_type = 'App\\Models\\Company'
+
+),
+
+
+-- FINAL
+final__stg__exchange__wallets AS (
+
+    SELECT
+        --ids
+        wallet_id,
+        company_id,
+        currency_id,
+
+        --dimensions
+        code,
+        
+        --measures
+        wallet_balance,
+
+        --date/times
+        created_datetime,
+        updated_datetime,
+        deleted_datetime,
+
+        --metadata
+        _dbt_ran_datetime
+
+    FROM renamed
+
+)
+
+SELECT * FROM final__stg__exchange__wallets