add workflow 荟聚API_2,dev

This commit is contained in:
root 2024-06-17 11:30:52 +08:00
parent c4b8012b14
commit f3e6e3883e
1 changed files with 17 additions and 12 deletions

View File

@ -4,11 +4,11 @@
/*Brilliance stems from wisdoms. */ /*Brilliance stems from wisdoms. */
/*************Head Section**************************************************************************/ /*************Head Section**************************************************************************/
/*Script Use: Periodically load data to :data_source_update(数据源更新时间) */ /*Script Use: Periodically load data to :data_source_update(数据源更新时间) */
/*Create Date:2024-05-30 15:30:54 */ /*Create Date:2024-06-17 11:29:47 */
/*SDM Developed By: dev */ /*SDM Developed By: dev */
/*SDM Developed Date: 2024-05-28 */ /*SDM Developed Date: 2024-05-28 */
/*SDM Checked By: dev */ /*SDM Checked By: dev */
/*SDM Checked Date: 2024-05-30 */ /*SDM Checked Date: 2024-06-17 */
/*Script Developed By: dev */ /*Script Developed By: dev */
/*Script Checked By: dev */ /*Script Checked By: dev */
/*Source table 1: p10_sa.s98_s_customer_event_meta */ /*Source table 1: p10_sa.s98_s_customer_event_meta */
@ -60,7 +60,7 @@ INSERT INTO data_source_update_agi_CUR_I (
SELECT SELECT
'Data Source' /*date_layer*/ 'Data Source' /*date_layer*/
,case when p0 .data_table like '%scrm%' then 'SCRM' ,case when p0 .data_table like '%scrm%' then 'SCRM'
when p0.data_table like '%customer%' then 'SCRM' when p0.data_table like '%custom%' then 'SCRM'
when p0.data_table like '%crm%' then 'CRM' when p0.data_table like '%crm%' then 'CRM'
when p0.data_table like '%livechat%' then 'LiveChat' when p0.data_table like '%livechat%' then 'LiveChat'
when p0.data_table like '%udesk%' when p0.data_table like '%udesk%'
@ -178,20 +178,21 @@ else 'All' end /*data_area*/
,Substr('s98_s_customer_event_meta',1,3) /*Src_Sysname*/ ,Substr('s98_s_customer_event_meta',1,3) /*Src_Sysname*/
,'s98_s_customer_event_meta' /*Src_Table*/ ,'s98_s_customer_event_meta' /*Src_Table*/
FROM (select 'cust_contact_info' data_table,count(*) row_count ,max(etl_tx_dt) last_upt_tm , 51 columns_qty from p30_common.cust_contact_info FROM (select 'cust_contact_info' data_table,count(*) row_count ,max(etl_proc_dt) last_upt_tm , 51 columns_qty from p30_common.cust_contact_info
union all union all
select 'cust_contact_mapping' data_table,count(*) row_count ,max(etl_tx_dt) last_upt_tm , 13 columns_qty from p30_common.cust_contact_mapping select 'cust_contact_mapping' data_table,count(*) row_count ,max(etl_proc_dt) last_upt_tm , 13 columns_qty from p30_common.cust_contact_mapping
union all union all
select 'cust_leads' data_table,count(*) row_count ,max(etl_tx_dt) last_upt_tm , 10 columns_qty from p30_common.cust_leads select 'cust_leads' data_table,count(*) row_count ,max(etl_proc_dt) last_upt_tm , 10 columns_qty from p30_common.cust_leads
union all union all
select 'd_crm_contact' data_table,count(*) row_count ,max(etl_tx_dt) last_upt_tm , 65 columns_qty from p30_common.d_crm_contact select 'cust_leads_detail' data_table,count(*) row_count ,max(etl_proc_dt) last_upt_tm , 10 columns_qty from p30_common.cust_leads_detail
union all union all
select 'd_livechat_contact' data_table,count(*) row_count ,max(etl_tx_dt) last_upt_tm , 19 columns_qty from p30_common.d_livechat_contact select 'd_crm_contact' data_table,count(*) row_count ,max(etl_proc_dt) last_upt_tm , 65 columns_qty from p30_common.d_crm_contact
union all union all
select 'd_scrm_contact' data_table,count(*) row_count ,max(etl_tx_dt) last_upt_tm , 20 columns_qty from p30_common.d_scrm_contact select 'd_livechat_contact' data_table,count(*) row_count ,max(etl_proc_dt) last_upt_tm , 19 columns_qty from p30_common.d_livechat_contact
union all union all
select 'd_udesk_contact' data_table,count(*) row_count ,max(etl_tx_dt) last_upt_tm , 16 columns_qty from p30_common.d_udesk_contact select 'd_scrm_contact' data_table,count(*) row_count ,max(etl_proc_dt) last_upt_tm , 20 columns_qty from p30_common.d_scrm_contact
) p0 union all
select 'd_udesk_contact' data_table,count(*) row_count ,max(etl_proc_dt) last_upt_tm , 16 columns_qty from p30_common.d_udesk_contact ) p0
; ;
@ -238,7 +239,11 @@ else 'All' end /*data_area*/
,Substr('s98_s_customer_event_meta',1,3) /*Src_Sysname*/ ,Substr('s98_s_customer_event_meta',1,3) /*Src_Sysname*/
,'s98_s_customer_event_meta' /*Src_Table*/ ,'s98_s_customer_event_meta' /*Src_Table*/
FROM (select 'cust_all_info' data_table,count(*) row_count ,max(etl_tx_dt) last_upt_tm , 33 columns_qty from p60_mart.cust_all_info ) p0 FROM (select 'cust_all_info' data_table,count(*) row_count ,max(etl_proc_dt) last_upt_tm , 33 columns_qty from p60_mart.cust_all_info
union all
select 'cust_enagement_records' data_table,count(*) row_count ,max(etl_proc_dt) last_upt_tm , 13 columns_qty from p60_mart.cust_enagement_records
union all
select 'v_dq_result' data_table,count(*) row_count ,max(check_run_date) last_upt_tm , 7 columns_qty from p51_dqc.dq_check_result) p0
; ;