diff --git a/definitions/staging/stg_csc_agent.sqlx b/definitions/staging/stg_csc_agent.sqlx index 3d4c171..4ba695b 100644 --- a/definitions/staging/stg_csc_agent.sqlx +++ b/definitions/staging/stg_csc_agent.sqlx @@ -22,6 +22,7 @@ select cr.RESORT, cr.MARKET_DESC, cr.CONFIRMATION_NO, cr.RESV_STATUS, + ms.RESV_STATUS_ID, cr.ARRIVAL, cr.DEPARTURE, cr.UPDATE_USER, @@ -36,8 +37,13 @@ select cr.RESORT, date(safe_cast(cr.CHANGE_DATE as timestamp)) DATE, extract(hour from safe_cast(cr.CHANGE_DATE as timestamp)) HOUR, cr.UPDATE_TYPE, + mu.UPDATE_TYPE_ID, 1 as COUNTER from csc_rev_deduplicated cr left join ${ref("pphe_five9_stg","stg_MAPPING_CSC_AGENT")} ca on cr.UPDATE_USER=ca.OPERA_UPDATE_USER +left join ${ref("pphe_five9_stg","stg_MAPPING_RESV_STATUS")} ms +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 where row_number = 1