From 3c0ced171af49f5178e4ff9a0207a0c453b0ac4e Mon Sep 17 00:00:00 2001
From: CIEF ACC1 <cief.acc1@gmail.com>
Date: Tue, 12 Mar 2024 01:08:06 +0000
Subject: [PATCH] Build cash flow analysis

---
 .../base/base_exchange__wallet_logs.sql       |  2 +-
 .../exchange/base/base_exchange__wallets.sql  |  2 +-
 .../stg_exchange__wallet_balance_logs.sql     | 58 +++++++++++++++++++
 .../stg_exchange__wallet_balances.sql         | 56 ++++++++++++++++++
 4 files changed, 116 insertions(+), 2 deletions(-)
 create mode 100644 models/staging/exchange/stg_exchange__wallet_balance_logs.sql
 create mode 100644 models/staging/exchange/stg_exchange__wallet_balances.sql

diff --git a/models/staging/exchange/base/base_exchange__wallet_logs.sql b/models/staging/exchange/base/base_exchange__wallet_logs.sql
index c5b13d5..cab7d77 100644
--- a/models/staging/exchange/base/base_exchange__wallet_logs.sql
+++ b/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,
diff --git a/models/staging/exchange/base/base_exchange__wallets.sql b/models/staging/exchange/base/base_exchange__wallets.sql
index ead58e7..cfdbc29 100644
--- a/models/staging/exchange/base/base_exchange__wallets.sql
+++ b/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,
diff --git a/models/staging/exchange/stg_exchange__wallet_balance_logs.sql b/models/staging/exchange/stg_exchange__wallet_balance_logs.sql
new file mode 100644
index 0000000..8116af9
--- /dev/null
+++ b/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
\ No newline at end of file
diff --git a/models/staging/exchange/stg_exchange__wallet_balances.sql b/models/staging/exchange/stg_exchange__wallet_balances.sql
new file mode 100644
index 0000000..9409da4
--- /dev/null
+++ b/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
\ No newline at end of file