diff --git a/definitions/staging/stg_csc_agent.sqlx b/definitions/staging/stg_csc_agent.sqlx index f20163e..ca51e8a 100644 --- a/definitions/staging/stg_csc_agent.sqlx +++ b/definitions/staging/stg_csc_agent.sqlx @@ -40,6 +40,9 @@ csc_agent as ( extract(hour from safe_cast(cr.CHANGE_DATE as timestamp)) HOUR, cr.UPDATE_TYPE, mu.UPDATE_TYPE_ID, + mug.UPDATE_TYPE_GROUP_ID, + mugi.UPDATE_TYPE_GROUP, + mur.REVENUE_GENERATING_YN, 1 as COUNTER, from csc_rev_deduplicated cr left join ${ref("pphe_five9_stg","stg_MAPPING_CSC_AGENT")} ca @@ -48,6 +51,12 @@ csc_agent as ( on cr.RESV_STATUS=ms.RESV_STATUS left join ${ref("pphe_five9_stg","stg_MAPPING_UPDATE_TYPE")} mu on cr.UPDATE_TYPE=mu.UPDATE_TYPE + left join ${ref("pphe_five9_stg","stg_MAPPING_UPDATE_TYPE_GROUP")} mug + on mu.UPDATE_TYPE_ID=mug.UPDATE_TYPE_ID + left join ${ref("pphe_five9_stg","stg_MAPPING_UPDATE_TYPE_GROUP_ID")} mugi + on mug.UPDATE_TYPE_GROUP_ID=mugi.UPDATE_TYPE_GROUP_ID + left join ${ref("pphe_five9_stg","stg_MAPPING_UPDATE_TYPE_REVENUE")} mur + on mu.UPDATE_TYPE_ID=mur.UPDATE_TYPE_ID where row_number = 1 and cr.UPDATE_USER is not null and ca.AGENT_ID is not null