From f88589aea3cc41e3c0e4b94a703ff147a4520894 Mon Sep 17 00:00:00 2001 From: root Date: Mon, 30 Jun 2025 10:55:22 +0800 Subject: [PATCH] =?UTF-8?q?add=20workflow=20=E5=A4=A9=E6=B6=A6Smart-ccc?= =?UTF-8?q?=E9=80=9A=E8=AF=9D=E8=AE=B0=E5=BD=95,dev?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cust_call_record_info_agi.sql | 58 ++++++++++++++++--- 1 file changed, 50 insertions(+), 8 deletions(-) diff --git a/dev/workflow/TK_Cust/smart_ccc_cdr/ccc客户通话记录信息/cust_call_record_info_agi.sql b/dev/workflow/TK_Cust/smart_ccc_cdr/ccc客户通话记录信息/cust_call_record_info_agi.sql index 0788053..871e857 100644 --- a/dev/workflow/TK_Cust/smart_ccc_cdr/ccc客户通话记录信息/cust_call_record_info_agi.sql +++ b/dev/workflow/TK_Cust/smart_ccc_cdr/ccc客户通话记录信息/cust_call_record_info_agi.sql @@ -4,7 +4,7 @@ /*Brilliance stems from wisdoms. */ /*************Head Section**************************************************************************/ /*Script Use: Periodically load data to :cust_call_record_info(ccc客户通话记录信息) */ -/*Create Date:2025-06-30 10:25:24 */ +/*Create Date:2025-06-30 10:54:55 */ /*SDM Developed By: dev */ /*SDM Developed Date: 2024-09-19 */ /*SDM Checked By: dev */ @@ -38,7 +38,7 @@ ON COMMIT PRESERVE ROWS; /*****************************************************************************************************/ INSERT INTO cust_call_record_info_agi_CUR_I ( - call_id /*通话编号*/ + call_unique_id /*通话编号*/ ,call_channel /*通话渠道*/ ,start_time /*开始时间*/ ,bridge_duration /*持续时间*/ @@ -48,9 +48,16 @@ INSERT INTO cust_call_record_info_agi_CUR_I ( ,name /*姓名*/ ,email /*邮箱*/ ,company /*公司*/ + ,etl_batch_no /*作业批次号*/ + ,etl_first_dt /*最初入库时间*/ + ,etl_job /*作业名称*/ + ,etl_proc_dt /*本次入库时间*/ + ,etl_tx_dt /*作业运行时间*/ + ,src_sysname /*来源系统*/ + ,src_table /*来源表*/ ) SELECT - coalesce(p0.unique_id,'') /*call_id*/ + coalesce(p0.unique_id,'') /*call_unique_id*/ ,'Smart CCC' /*call_channel*/ ,COALESCE(p0.start_time,TO_TIMESTAMP(:NULLDATE,'YYYYMMDD')) /*start_time*/ ,COALESCE(CAST(p0.bridge_duration AS numeric (24,3)),0) /*bridge_duration*/ @@ -65,6 +72,13 @@ SELECT ,coalesce(p1."name",'无') /*name*/ ,coalesce(p1.email,'') /*email*/ ,coalesce(p1.company,'') /*company*/ + ,0 /*etl_batch_no*/ + ,TO_DATE(:TXDATE,'YYYYMMDD') /*etl_first_dt*/ + ,:ETLJOB /*etl_job*/ + ,current_timestamp(0) /*etl_proc_dt*/ + ,TO_DATE(:TXDATE,'YYYYMMDD') /*etl_tx_dt*/ + ,Substr('cust_call_ccc_record',1,3) /*src_sysname*/ + ,'cust_call_ccc_record' /*src_table*/ FROM :COMMDB.cust_call_ccc_record p0 LEFT JOIN (select distinct on (tel) * from p30_common.d_ccc_cust_info) p1 @@ -80,7 +94,7 @@ group by 1,2,3,4,5,6,7,8,9,10 /*****************************************************************************************************/ INSERT INTO cust_call_record_info_agi_CUR_I ( - call_id /*通话编号*/ + call_unique_id /*通话编号*/ ,call_channel /*通话渠道*/ ,start_time /*开始时间*/ ,bridge_duration /*持续时间*/ @@ -90,9 +104,16 @@ INSERT INTO cust_call_record_info_agi_CUR_I ( ,name /*姓名*/ ,email /*邮箱*/ ,company /*公司*/ + ,etl_batch_no /*作业批次号*/ + ,etl_first_dt /*最初入库时间*/ + ,etl_job /*作业名称*/ + ,etl_proc_dt /*本次入库时间*/ + ,etl_tx_dt /*作业运行时间*/ + ,src_sysname /*来源系统*/ + ,src_table /*来源表*/ ) SELECT - COALESCE(TRIM(p0.call_id),'') /*call_id*/ + COALESCE(TRIM(p0.call_id),'') /*call_unique_id*/ ,'Udesk' /*call_channel*/ ,p0.record_time /*start_time*/ ,extract (epoch from duration::time) /*bridge_duration*/ @@ -106,6 +127,13 @@ else '其他' end /*service_group*/ ,cust /*name*/ ,'' /*email*/ ,company_name /*company*/ + ,0 /*etl_batch_no*/ + ,TO_DATE(:TXDATE,'YYYYMMDD') /*etl_first_dt*/ + ,:ETLJOB /*etl_job*/ + ,current_timestamp(0) /*etl_proc_dt*/ + ,TO_DATE(:TXDATE,'YYYYMMDD') /*etl_tx_dt*/ + ,Substr('t01_udesk_record',1,3) /*src_sysname*/ + ,'t01_udesk_record' /*src_table*/ FROM :PDMDB.t01_udesk_record p0 where p0.type = '呼入' and p0.relay_number not like '%MKT%' and p0.relay_number not like '%Fluke%' and record_time ::date >='2024-01-01' @@ -118,12 +146,12 @@ and udesk_source in ('队列: IAM','队列: SSO-TEK','队列: TSC-KEI','队列: /*从目标表中删除所有数据 cust_call_record_info(ccc客户通话记录信息) */ DELETE FROM :MARTDB.cust_call_record_info -; +WHERE ETL_JOB=:ETLJOB; /*将新增数据插入到目标表 */ ;INSERT INTO :MARTDB.cust_call_record_info ( - call_id /*通话编号*/ + call_unique_id /*通话编号*/ ,call_channel /*通话渠道*/ ,start_time /*开始时间*/ ,bridge_duration /*持续时间*/ @@ -133,10 +161,17 @@ DELETE FROM :MARTDB.cust_call_record_info ,name /*姓名*/ ,email /*邮箱*/ ,company /*公司*/ + ,etl_batch_no /*作业批次号*/ + ,etl_first_dt /*最初入库时间*/ + ,etl_job /*作业名称*/ + ,etl_proc_dt /*本次入库时间*/ + ,etl_tx_dt /*作业运行时间*/ + ,src_sysname /*来源系统*/ + ,src_table /*来源表*/ ) SELECT - P1.call_id /*通话编号*/ + P1.call_unique_id /*通话编号*/ ,P1.call_channel /*通话渠道*/ ,P1.start_time /*开始时间*/ ,P1.bridge_duration /*持续时间*/ @@ -146,6 +181,13 @@ DELETE FROM :MARTDB.cust_call_record_info ,P1.name /*姓名*/ ,P1.email /*邮箱*/ ,P1.company /*公司*/ + ,P1.etl_batch_no /*作业批次号*/ + ,P1.etl_first_dt /*最初入库时间*/ + ,P1.etl_job /*作业名称*/ + ,P1.etl_proc_dt /*本次入库时间*/ + ,P1.etl_tx_dt /*作业运行时间*/ + ,P1.src_sysname /*来源系统*/ + ,P1.src_table /*来源表*/ FROM cust_call_record_info_agi_CUR_I P1