sales exchange lead activations

2026-08-19 04:14:00 +00:00 · 2023-08-02 04:12:27 +00:00
parent 973f835d15
commit 851c9afbb9
1 changed files with 78 additions and 0 deletions
@@ -0,0 +1,78 @@
+-- IMPORT
+WITH lead_activations AS (
+    SELECT * FROM {{ source('src_googlesheet_airbyte', '_airbyte_raw_leads_activations') }}
+),
+
+-- LOGIC
+parse_json_leads AS (
+    SELECT
+        _airbyte_ab_id  AS sales_team_lead_activation_id,
+        parse_json(_airbyte_data)                       AS leads_json,
+        _airbyte_emitted_at     AS _airbyte_emitted_datetime
+    
+    FROM lead_activations
+),
+
+flatten_json AS (
+
+    SELECT
+        sales_team_lead_activation_id,
+        leads_json['agent_name']::STRING                AS agent_name,
+        leads_json['company_marking']::STRING           AS company_marking_id,
+        leads_json['contact_number']::STRING            AS contact_number,
+        leads_json['email']::STRING                     AS contact_email,
+        leads_json['sorce']::STRING                     AS contact_method,
+        leads_json['tag']::STRING                       AS contact_status,
+        leads_json['user_name']::STRING                 AS contact_name,
+        leads_json['remark']::STRING                    AS sales_team_remark,
+        COALESCE(
+            TRY_TO_TIMESTAMP(leads_json['contacted_datetime']::STRING, 'DD-MM-YYYY'),
+            TRY_TO_TIMESTAMP(leads_json['contacted_datetime']::STRING, 'DD-MM-YYYY HH24:MI:SS')        
+        )                                               AS sales_team_contacted_datetime,
+        COALESCE(
+            TRY_TO_TIMESTAMP(leads_json['register_date']::STRING, 'DD-MM-YYYY'),
+            TRY_TO_TIMESTAMP(leads_json['register_date']::STRING, 'DD-MM-YYYY HH24:MI:SS')        
+        )                                               AS exchange_registered_datetime,
+        COALESCE(
+            TRY_TO_TIMESTAMP(leads_json['user_first_reply_datetime']::STRING, 'DD-MM-YYYY'),
+            TRY_TO_TIMESTAMP(leads_json['user_first_reply_datetime']::STRING, 'DD-MM-YYYY HH24:MI:SS')        
+        )                                               AS first_reply_datetime,      
+
+        _airbyte_emitted_datetime,
+        '{{ modules.datetime.datetime.now(modules.pytz.timezone("Asia/Kuala_Lumpur")) }}' AS _dbt_ran_datetime
+
+    FROM parse_json_leads
+),
+
+-- FINAL
+final__stg_googlesheet__sales_exchange_lead_activations AS (
+    
+    SELECT
+        -- ids
+        sales_team_lead_activation_id,
+
+        -- dimensions
+        company_marking_id,
+        agent_name,
+        contact_name,
+        contact_number,
+        contact_email,
+        contact_method,
+        contact_status,
+        sales_team_remark,
+
+        -- measures
+
+        -- date/times
+        sales_team_contacted_datetime,
+        first_reply_datetime,
+        exchange_registered_datetime,
+
+        -- metadata  
+        _airbyte_emitted_datetime,
+        _dbt_ran_datetime
+    
+    FROM flatten_json
+)
+
+SELECT * FROM final__stg_googlesheet__sales_exchange_lead_activations