dtgitea
/
dataops
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add workflow 天润Smart-ccc会话数据,dev

This commit is contained in:
root 2025-02-10 12:09:01 +08:00
parent dfab5adecb
commit 4001ecde70
2 changed files with 57 additions and 57 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
dev/workflow/TK_Cust/smart_ccc_chat/smartccc会话消息详情/t01_ccc_chat_message_detail_agi.sql
View File

@ -1,17 +1,17 @@
/***************************************************************************************************/ /***************************************************************************************************/
/*script in Sql, generate by SdmCreateScript 2020(by Qihang Feng, QF255001@TERADATA.COM) */ /*script in Sql, generate by SdmCreateScript 2024(by IdgValue, qihang.feng@idgvalue.COM) */
/*VERSION 01.10 revised on 2020-08-25 */ /*VERSION 01.10 revised on 2020-08-25 */
/*Brilliance stems from wisdoms. */ /*Brilliance stems from wisdoms. */
/*************Head Section**************************************************************************/ /*************Head Section**************************************************************************/
/*Script Use: Periodically load data to :t01_ccc_chat_message_detail(smartccc会话消息详情) */ /*Script Use: Periodically load data to :t01_ccc_chat_message_detail(smartccc会话消息详情) */
/*Create Date:2024-07-19 15:52:26 */ /*Create Date:2025-02-10 12:07:41 */
/*SDM Developed By: dev */ /*SDM Developed By: dev */
/*SDM Developed Date: 2024-07-19 */ /*SDM Developed Date: 2024-07-19 */
/*SDM Checked By: dev */ /*SDM Checked By: dev */
/*SDM Checked Date: 2024-07-19 */ /*SDM Checked Date: 2025-02-10 */
/*Script Developed By: dev */ /*Script Developed By: dev */
/*Script Checked By: dev */ /*Script Checked By: dev */
/*Source table 1: p10_sa.s98_s_tr_chat_messages */ /*Source table 1: p10_sa.s98_s_tr_chat_messages_new */
/*Job Type: Inbound transform (Tier 1 to Tier 2) */ /*Job Type: Inbound transform (Tier 1 to Tier 2) */
/*Target Table:t01_ccc_chat_message_detail */ /*Target Table:t01_ccc_chat_message_detail */
/*ETL Job Name:t01_ccc_chat_message_detail */ /*ETL Job Name:t01_ccc_chat_message_detail */
@ -30,7 +30,7 @@ CREATE TEMPORARY TABLE t01_ccc_chat_message_detail_agi_CUR_I
( LIKE :PDMDB.t01_ccc_chat_message_detail) ( LIKE :PDMDB.t01_ccc_chat_message_detail)
ON COMMIT PRESERVE ROWS; ON COMMIT PRESERVE ROWS;
/*创建临时表加载不同数据 */ /*创建临时表加载不同数据 */
CREATE TEMPORARY TABLE t01_ccc_chat_message_detail_agi_INS CREATE TEMPORARY TABLE t01_ccc_chat_message_detail_agi_INS
@ -39,7 +39,7 @@ ON COMMIT PRESERVE ROWS;
/*****************************************************************************************************/ /*****************************************************************************************************/
/* GROUP 1:Source Table:s98_s_tr_chat_messages********************************************************/ /* GROUP 1:Source Table:s98_s_tr_chat_messages_new****************************************************/
/*****************************************************************************************************/ /*****************************************************************************************************/
INSERT INTO t01_ccc_chat_message_detail_agi_CUR_I ( INSERT INTO t01_ccc_chat_message_detail_agi_CUR_I (
message_unique_id /* 消息编号*/ message_unique_id /* 消息编号*/
@ -64,28 +64,28 @@ INSERT INTO t01_ccc_chat_message_detail_agi_CUR_I (
,Src_Table /*来源表*/ ,Src_Table /*来源表*/
) )
SELECT SELECT
COALESCE(TRIM(CAST(p0.unique_id AS varchar(50))),'') /*message_unique_id*/ COALESCE(TRIM(CAST(p0.detail_unique_id AS varchar(50))),'') /*message_unique_id*/
,COALESCE(TRIM(CAST(p0.main_unique_id AS varchar(50))),'') /*chat_unique_id*/ ,COALESCE(TRIM(CAST(p0.main_unique_id AS varchar(50))),'') /*chat_unique_id*/
,COALESCE(TRIM(CAST(p0.sender_id AS varchar(50))),'') /*sender_id*/ ,COALESCE(TRIM(CAST(p0.sender AS varchar(50))),'') /*sender_id*/
,COALESCE(TRIM(CAST(p0.sender_name AS varchar(50))),'') /*sender_name*/ ,COALESCE(TRIM(CAST(p0.sender_name AS varchar(50))),'') /*sender_name*/
,COALESCE(TRIM(CAST(p0.sender_type AS varchar(10))),'') /*sender_type*/ ,COALESCE(TRIM(CAST(p0.send_type_name AS varchar(10))),'') /*sender_type*/
,COALESCE(TRIM(CAST(p0.message_type AS varchar(10))),'') /*message_type*/ ,COALESCE(TRIM(CAST(p0.message_type_name AS varchar(10))),'') /*message_type*/
,COALESCE(TRIM(p0.content),'') /*content*/ ,COALESCE(TRIM(p0.content),'') /*content*/
,COALESCE(TRIM(p0.file_key),'') /*file_address*/ ,COALESCE(TRIM(p0.file_key),'') /*file_address*/
,COALESCE(TRIM(CAST(p0.file_name AS varchar(100))),'') /*file_name*/ ,COALESCE(TRIM(CAST(p0.file_name AS varchar(100))),'') /*file_name*/
,COALESCE(TRIM(p0.file_url),'') /*file_url*/ ,COALESCE(TRIM(p0.file_url),'') /*file_url*/
,COALESCE(TRIM(CAST(p0.send_status AS varchar(10))),'') /*send_status*/ ,'' /*send_status*/
,COALESCE(TRIM(p0.sensitive_word),'') /*sensitive_word*/ ,'' /*sensitive_word*/
,to_timestamp(p0.create_time::bigint/1000)::timestamp(0) /*create_time*/ ,COALESCE(TO_TIMESTAMP(CAST(p0.create_time AS VARCHAR(19)),'YYYY-MM-DD HH24:mi:ss'),TO_TIMESTAMP(:NULLDATE,'YYYYMMDD')) /*create_time*/
,0 /*Etl_Batch_No*/ ,0 /*Etl_Batch_No*/
,TO_DATE(:TXDATE,'YYYYMMDD') /*Etl_First_Dt*/ ,TO_DATE(:TXDATE,'YYYYMMDD') /*Etl_First_Dt*/
,:ETLJOB /*Etl_Job*/ ,:ETLJOB /*Etl_Job*/
,current_timestamp(0) /*Etl_Proc_Dt*/ ,current_timestamp(0) /*Etl_Proc_Dt*/
,TO_DATE(:TXDATE,'YYYYMMDD') /*Etl_Tx_Dt*/ ,TO_DATE(:TXDATE,'YYYYMMDD') /*Etl_Tx_Dt*/
,Substr('s98_s_tr_chat_messages',1,3) /*Src_Sysname*/ ,Substr('s98_s_tr_chat_messages_new',1,3) /*Src_Sysname*/
,'s98_s_tr_chat_messages' /*Src_Table*/ ,'s98_s_tr_chat_messages_new' /*Src_Table*/
FROM p10_sa.s98_s_tr_chat_messages p0 FROM p10_sa.s98_s_tr_chat_messages_new p0
; ;

82
dev/workflow/TK_Cust/smart_ccc_chat/smartccc会话记录/t01_ccc_chat_record_agi.sql
View File

@ -1,17 +1,17 @@
/***************************************************************************************************/ /***************************************************************************************************/
/*script in Sql, generate by SdmCreateScript 2020(by Qihang Feng, QF255001@TERADATA.COM) */ /*script in Sql, generate by SdmCreateScript 2024(by IdgValue, qihang.feng@idgvalue.COM) */
/*VERSION 01.10 revised on 2020-08-25 */ /*VERSION 01.10 revised on 2020-08-25 */
/*Brilliance stems from wisdoms. */ /*Brilliance stems from wisdoms. */
/*************Head Section**************************************************************************/ /*************Head Section**************************************************************************/
/*Script Use: Periodically load data to :t01_ccc_chat_record(smartccc会话记录) */ /*Script Use: Periodically load data to :t01_ccc_chat_record(smartccc会话记录) */
/*Create Date:2024-08-12 18:51:12 */ /*Create Date:2025-02-10 12:01:37 */
/*SDM Developed By: dev */ /*SDM Developed By: dev */
/*SDM Developed Date: 2024-07-18 */ /*SDM Developed Date: 2024-07-18 */
/*SDM Checked By: dev */ /*SDM Checked By: dev */
/*SDM Checked Date: 2024-08-12 */ /*SDM Checked Date: 2025-02-10 */
/*Script Developed By: dev */ /*Script Developed By: dev */
/*Script Checked By: dev */ /*Script Checked By: dev */
/*Source table 1: p10_sa.s98_s_tr_chat_records */ /*Source table 1: p10_sa.s98_s_tr_chat_records_new */
/*Job Type: Inbound transform (Tier 1 to Tier 2) */ /*Job Type: Inbound transform (Tier 1 to Tier 2) */
/*Target Table:t01_ccc_chat_record */ /*Target Table:t01_ccc_chat_record */
/*ETL Job Name:t01_ccc_chat_record */ /*ETL Job Name:t01_ccc_chat_record */
@ -30,7 +30,7 @@ CREATE TEMPORARY TABLE t01_ccc_chat_record_agi_CUR_I
( LIKE :PDMDB.t01_ccc_chat_record) ( LIKE :PDMDB.t01_ccc_chat_record)
ON COMMIT PRESERVE ROWS; ON COMMIT PRESERVE ROWS;
/*创建临时表加载不同数据 */ /*创建临时表加载不同数据 */
CREATE TEMPORARY TABLE t01_ccc_chat_record_agi_INS CREATE TEMPORARY TABLE t01_ccc_chat_record_agi_INS
@ -39,7 +39,7 @@ ON COMMIT PRESERVE ROWS;
/*****************************************************************************************************/ /*****************************************************************************************************/
/* GROUP 1:Source Table:s98_s_tr_chat_records*********************************************************/ /* GROUP 1:Source Table:s98_s_tr_chat_records_new*****************************************************/
/*****************************************************************************************************/ /*****************************************************************************************************/
INSERT INTO t01_ccc_chat_record_agi_CUR_I ( INSERT INTO t01_ccc_chat_record_agi_CUR_I (
chat_unique_id /*在线客服会话ID*/ chat_unique_id /*在线客服会话ID*/
@ -99,61 +99,61 @@ INSERT INTO t01_ccc_chat_record_agi_CUR_I (
) )
SELECT SELECT
COALESCE(TRIM(CAST(p0.main_unique_id AS varchar(50))),'') /*chat_unique_id*/ COALESCE(TRIM(CAST(p0.main_unique_id AS varchar(50))),'') /*chat_unique_id*/
,COALESCE(TRIM(CAST(p0.contact_type AS varchar(10))),'') /*contact_channel*/ ,COALESCE(TRIM(CAST(p0.contact_type_name AS varchar(10))),'') /*contact_channel*/
,COALESCE(TRIM(CAST(p0.app_id AS varchar(50))),'') /*contact_app_id*/ ,'' /*contact_app_id*/
,COALESCE(TRIM(CAST(p0.app_name AS varchar(50))),'') /*app_namecontact_*/ ,COALESCE(TRIM(CAST(p0.app_name AS varchar(50))),'') /*app_namecontact_*/
,COALESCE(TRIM(CAST(p0.visitor_id AS varchar(50))),'') /*visitor_id*/ ,COALESCE(TRIM(CAST(p0.visitor_id AS varchar(50))),'') /*visitor_id*/
,COALESCE(TRIM(CAST(p0.visitor_name AS varchar(50))),'') /*visitor_name*/ ,COALESCE(TRIM(CAST(p0.visitor_name AS varchar(50))),'') /*visitor_name*/
,COALESCE(TRIM(CAST(p0.robot_id AS varchar(10))),'') /*robot_id*/ ,'' /*robot_id*/
,COALESCE(TRIM(CAST(p0.robot_name AS varchar(10))),'') /*robot_name*/ ,'' /*robot_name*/
,to_timestamp(p0.robot_start_time::bigint)::timestamp(0) /*robot_start_time*/ ,COALESCE(TO_TIMESTAMP(CAST(p0.start_time AS VARCHAR(19)),'YYYY-MM-DD HH24:mi:ss'),TO_TIMESTAMP(:NULLDATE,'YYYYMMDD')) /*robot_start_time*/
,to_timestamp(p0.robot_end_time::bigint)::timestamp(0) /*robot_end_time*/ ,COALESCE(TO_TIMESTAMP(CAST(p0.end_time AS VARCHAR(19)),'YYYY-MM-DD HH24:mi:ss'),TO_TIMESTAMP(:NULLDATE,'YYYYMMDD')) /*robot_end_time*/
,COALESCE(TRIM(CAST(p0.qno AS varchar(10))),'') /*queue_no*/ ,COALESCE(TRIM(CAST(p0.first_qno AS varchar(10))),'') /*queue_no*/
,COALESCE(TRIM(CAST(p0.qname AS varchar(10))),'') /*queue_name*/ ,COALESCE(TRIM(CAST(p0.first_qname AS varchar(10))),'') /*queue_name*/
,COALESCE(TRIM(CAST(p0.cno AS varchar(10))),'') /*client_no*/ ,COALESCE(TRIM(CAST(p0.first_cno AS varchar(10))),'') /*client_no*/
,COALESCE(TRIM(CAST(p0.client_name AS varchar(10))),'') /*client_name*/ ,COALESCE(TRIM(CAST(p0.first_cname AS varchar(10))),'') /*client_name*/
,COALESCE(TRIM(CAST(p0.chat_duration_type AS varchar(10))),'') /*chat_duration_type*/ ,'' /*chat_duration_type*/
,COALESCE(TRIM(CAST(p0.close_status AS varchar(10))),'') /*close_status*/ ,COALESCE(TRIM(CAST(p0.close_status_name AS varchar(10))),'') /*close_status*/
,COALESCE(TRIM(CAST(p0.close_reason AS varchar(10))),'') /*close_reason*/ ,COALESCE(TRIM(CAST(p0.close_reason_name AS varchar(10))),'') /*close_reason*/
,COALESCE(TRIM(CAST(p0.open_type AS varchar(10))),'') /*open_type*/ ,COALESCE(TRIM(CAST(p0.contact_type_name AS varchar(10))),'') /*open_type*/
,COALESCE(CAST(p0.first_response_duration AS int),0) /*first_response_duration*/ ,0 /*first_response_duration*/
,to_timestamp(p0.start_time::bigint)::timestamp(0) /*start_time*/ ,COALESCE(TO_TIMESTAMP(CAST(p0.start_time AS VARCHAR(19)),'YYYY-MM-DD HH24:mi:ss'),TO_TIMESTAMP(:NULLDATE,'YYYYMMDD')) /*start_time*/
,to_timestamp(p0.end_time::bigint)::timestamp(0) /*end_time*/ ,COALESCE(TO_TIMESTAMP(CAST(p0.end_time AS VARCHAR(19)),'YYYY-MM-DD HH24:mi:ss'),TO_TIMESTAMP(:NULLDATE,'YYYYMMDD')) /*end_time*/
,COALESCE(CAST(p0.queue_time AS int),0) /*queue_time*/ ,COALESCE(CAST(p0.queue_duration AS int),0) /*queue_time*/
,to_timestamp(p0.join_queue_time::bigint)::timestamp(0) /*join_queue_time*/ ,0 /*join_queue_time*/
,to_timestamp(p0.bridge_time::bigint)::timestamp(0) /*bridge_time*/ ,COALESCE(TO_TIMESTAMP(CAST(p0.start_time AS VARCHAR(19)),'YYYY-MM-DD HH24:mi:ss'),TO_TIMESTAMP(:NULLDATE,'YYYYMMDD')) /*bridge_time*/
,COALESCE(TRIM(CAST(p0.session_type AS varchar(10))),'') /*session_type*/ ,COALESCE(TRIM(CAST(p0.session_tags AS varchar(10))),'') /*session_type*/
,COALESCE(TRIM(CAST(p0.chat_valid_session AS varchar(10))),'') /*chat_valid_session*/ ,COALESCE(TRIM(CAST(p0.is_valid_name AS varchar(10))),'') /*chat_valid_session*/
,COALESCE(TRIM(CAST(p0.comment_session AS varchar(10))),'') /*comment_session*/ ,COALESCE(TRIM(CAST(p0.has_comment AS varchar(10))),'') /*comment_session*/
,COALESCE(TRIM(CAST(p0.invitation_initiator AS varchar(10))),'') /*invitation_initiator*/ ,'' /*invitation_initiator*/
,COALESCE(TRIM(CAST(p0.keys AS varchar(10))),'') /*satisfaction_keys*/ ,'' /*satisfaction_keys*/
,COALESCE(TRIM(CAST(p0.remark AS varchar(10))),'') /*satisfaction_remark*/ ,'' /*satisfaction_remark*/
,COALESCE(TRIM(CAST(p0.ip AS varchar(20))),'') /*visitor_ip*/ ,COALESCE(TRIM(CAST(p0.ip AS varchar(20))),'') /*visitor_ip*/
,COALESCE(TRIM(CAST(p0.customer_region AS varchar(20))),'') /*visitor_region*/ ,'' /*visitor_region*/
,COALESCE(CAST(p0.chat_times AS int),0) /*chat_times*/ ,0 /*chat_times*/
,COALESCE(CAST(p0.invited_times AS int),0) /*invited_times*/ ,0 /*invited_times*/
,COALESCE(TRIM(CAST(p0.search_word AS varchar(20))),'') /*search_word*/ ,COALESCE(TRIM(CAST(p0.search_word AS varchar(20))),'') /*search_word*/
,COALESCE(TRIM(CAST(p0.operating_system AS varchar(50))),'') /*operating_system*/ ,COALESCE(TRIM(CAST(p0.operating_system AS varchar(50))),'') /*operating_system*/
,COALESCE(TRIM(CAST(p0.browser AS varchar(50))),'') /*browser*/ ,COALESCE(TRIM(CAST(p0.browser AS varchar(50))),'') /*browser*/
,COALESCE(TRIM(p0.referer_url),'') /*referer_url*/ ,COALESCE(TRIM(p0.referer_url),'') /*referer_url*/
,COALESCE(TRIM(p0.first_visit_page_url),'') /*first_visit_page_url*/ ,COALESCE(TRIM(p0.first_visit_page_url),'') /*first_visit_page_url*/
,COALESCE(TRIM(p0.initiation_page_url),'') /*initiation_page_url*/ ,COALESCE(TRIM(p0.initiation_page_url),'') /*initiation_page_url*/
,COALESCE(TRIM(p0.visit_tracks),'') /*visit_tracks*/ ,undefined. /*visit_tracks*/
,COALESCE(TRIM(p0.visitor_extra_info),'') /*visitor_extra_info*/ ,COALESCE(TRIM(p0.visitor_extra_info),'') /*visitor_extra_info*/
,COALESCE(TRIM(CAST(p0.device_type AS varchar(20))),'') /*device_type*/ ,COALESCE(TRIM(CAST(p0.device_type AS varchar(20))),'') /*device_type*/
,COALESCE(TRIM(CAST(p0.app_type AS varchar(10))),'') /*contact_app_type*/ ,COALESCE(TRIM(CAST(p0.contact_type_name AS varchar(10))),'') /*contact_app_type*/
,COALESCE(TRIM(CAST(p0.province AS varchar(10))),'') /*visitor_province*/ ,COALESCE(TRIM(CAST(p0.province AS varchar(10))),'') /*visitor_province*/
,COALESCE(TRIM(CAST(p0.city AS varchar(10))),'') /*visitor_city*/ ,COALESCE(TRIM(CAST(p0.city AS varchar(10))),'') /*visitor_city*/
,COALESCE(TRIM(p0.referrer_name),'') /*referer_name*/ ,'' /*referer_name*/
,0 /*Etl_Batch_No*/ ,0 /*Etl_Batch_No*/
,TO_DATE(:TXDATE,'YYYYMMDD') /*Etl_First_Dt*/ ,TO_DATE(:TXDATE,'YYYYMMDD') /*Etl_First_Dt*/
,:ETLJOB /*Etl_Job*/ ,:ETLJOB /*Etl_Job*/
,current_timestamp(0) /*Etl_Proc_Dt*/ ,current_timestamp(0) /*Etl_Proc_Dt*/
,TO_DATE(:TXDATE,'YYYYMMDD') /*Etl_Tx_Dt*/ ,TO_DATE(:TXDATE,'YYYYMMDD') /*Etl_Tx_Dt*/
,Substr('s98_s_tr_chat_records',1,3) /*Src_Sysname*/ ,Substr('s98_s_tr_chat_records_new',1,3) /*Src_Sysname*/
,'s98_s_tr_chat_records' /*Src_Table*/ ,'s98_s_tr_chat_records_new' /*Src_Table*/
FROM p10_sa.s98_s_tr_chat_records p0 FROM p10_sa.s98_s_tr_chat_records_new p0
; ;