From 25ef071217e6ed498668744286e03972c484f2a8 Mon Sep 17 00:00:00 2001 From: Anna Saiapina Date: Tue, 24 Sep 2024 15:05:06 +0000 Subject: [PATCH] Add reason code --- definitions/sources/MAPPING_AGENT_REASON_CODE_ID.sqlx | 2 +- ...ASON_CODE.sqlx => stg_MAPPING_AGENT_REASON_CODE_ID.sqlx} | 6 +++--- definitions/staging/stg_agent_status_history_report.sqlx | 3 +++ definitions/staging/stg_agent_status_report.sqlx | 3 +++ 4 files changed, 10 insertions(+), 4 deletions(-) rename definitions/staging/{stg_MAPPING_AGENT_REASON_CODE.sqlx => stg_MAPPING_AGENT_REASON_CODE_ID.sqlx} (56%) diff --git a/definitions/sources/MAPPING_AGENT_REASON_CODE_ID.sqlx b/definitions/sources/MAPPING_AGENT_REASON_CODE_ID.sqlx index 13084f2..743d1c8 100644 --- a/definitions/sources/MAPPING_AGENT_REASON_CODE_ID.sqlx +++ b/definitions/sources/MAPPING_AGENT_REASON_CODE_ID.sqlx @@ -1,6 +1,6 @@ config { type: "declaration", schema: "pphe_five9_raw", - name: "MAPPING_AGENT_REASON_CODE", + name: "MAPPING_AGENT_REASON_CODE_ID", description: "" } \ No newline at end of file diff --git a/definitions/staging/stg_MAPPING_AGENT_REASON_CODE.sqlx b/definitions/staging/stg_MAPPING_AGENT_REASON_CODE_ID.sqlx similarity index 56% rename from definitions/staging/stg_MAPPING_AGENT_REASON_CODE.sqlx rename to definitions/staging/stg_MAPPING_AGENT_REASON_CODE_ID.sqlx index df87199..a2a27fa 100644 --- a/definitions/staging/stg_MAPPING_AGENT_REASON_CODE.sqlx +++ b/definitions/staging/stg_MAPPING_AGENT_REASON_CODE_ID.sqlx @@ -6,9 +6,9 @@ config { nonNull: ["REASON_CODE_ID"] }, tags: ["daily"], - description: "Daily load of MAPPING_AGENT_REASON_CODE table from raw" + description: "Daily load of MAPPING_AGENT_REASON_CODE_ID table from raw" } select - * -from ${ref("MAPPING_AGENT_REASON_CODE")} \ No newline at end of file + * +from ${ref("MAPPING_AGENT_REASON_CODE_ID")} \ No newline at end of file diff --git a/definitions/staging/stg_agent_status_history_report.sqlx b/definitions/staging/stg_agent_status_history_report.sqlx index 7c7a27b..9947d89 100644 --- a/definitions/staging/stg_agent_status_history_report.sqlx +++ b/definitions/staging/stg_agent_status_history_report.sqlx @@ -28,6 +28,7 @@ select ags.AGENT_ID, ) as AGENT_STATE_TIME_FORMATTED, ags.AGENT_START_DATE, ags.REASON_CODE, + mrc.REASON_CODE_ID, ags.TIMESTAMP, date(ags.TIMESTAMP) DATE, EXTRACT(HOUR FROM ags.TIMESTAMP) HOUR, @@ -66,5 +67,7 @@ left join ${ref("stg_MAPPING_AGENT_STATE_GROUP_ID")} masgi on mas.STATE_ID = masgi.STATE_ID left join ${ref("stg_MAPPING_AGENT_GROUP")} masg on masgi.STATE_GROUP_ID = masg.STATE_GROUP_ID +left join ${ref("stg_MAPPING_AGENT_REASON_CODE_ID")} mrc +on ags.REASON_CODE = mrc.REASON_CODE ${ when(incremental(), `where date(ags.TIMESTAMP) >= DATE_SUB(CURRENT_DATE(), INTERVAL 7 DAY) and date(ags.TIMESTAMP) < CURRENT_DATE()`) } \ No newline at end of file diff --git a/definitions/staging/stg_agent_status_report.sqlx b/definitions/staging/stg_agent_status_report.sqlx index 58319b7..5e815a8 100644 --- a/definitions/staging/stg_agent_status_report.sqlx +++ b/definitions/staging/stg_agent_status_report.sqlx @@ -29,6 +29,7 @@ select ags.AGENT_ID, ) as AGENT_STATE_TIME_FORMATTED, ags.AGENT_START_DATE, ags.REASON_CODE, + mrc.REASON_CODE_ID, ags.TIMESTAMP, date(ags.TIMESTAMP) DATE, EXTRACT(HOUR FROM ags.TIMESTAMP) HOUR, @@ -67,5 +68,7 @@ left join ${ref("stg_MAPPING_AGENT_STATE_GROUP_ID")} masgi on mas.STATE_ID = masgi.STATE_ID left join ${ref("stg_MAPPING_AGENT_GROUP")} masg on masgi.STATE_GROUP_ID = masg.STATE_GROUP_ID +left join ${ref("stg_MAPPING_AGENT_REASON_CODE_ID")} mrc +on ags.REASON_CODE = mrc.REASON_CODE where date(ags.TIMESTAMP) >= DATE_SUB(CURRENT_DATE(), INTERVAL 7 DAY) and date(ags.TIMESTAMP) < CURRENT_DATE() \ No newline at end of file