From 4001ecde70a7098096592885f095ec7a61865ba0 Mon Sep 17 00:00:00 2001 From: root Date: Mon, 10 Feb 2025 12:09:01 +0800 Subject: [PATCH] =?UTF-8?q?add=20workflow=20=E5=A4=A9=E6=B6=A6Smart-ccc?= =?UTF-8?q?=E4=BC=9A=E8=AF=9D=E6=95=B0=E6=8D=AE,dev?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../t01_ccc_chat_message_detail_agi.sql | 32 ++++---- .../t01_ccc_chat_record_agi.sql | 82 +++++++++---------- 2 files changed, 57 insertions(+), 57 deletions(-) diff --git a/dev/workflow/TK_Cust/smart_ccc_chat/smartccc会话消息详情/t01_ccc_chat_message_detail_agi.sql b/dev/workflow/TK_Cust/smart_ccc_chat/smartccc会话消息详情/t01_ccc_chat_message_detail_agi.sql index bda6bbc..8f10259 100644 --- a/dev/workflow/TK_Cust/smart_ccc_chat/smartccc会话消息详情/t01_ccc_chat_message_detail_agi.sql +++ b/dev/workflow/TK_Cust/smart_ccc_chat/smartccc会话消息详情/t01_ccc_chat_message_detail_agi.sql @@ -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 */ /*Brilliance stems from wisdoms. */ /*************Head Section**************************************************************************/ /*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 Date: 2024-07-19 */ /*SDM Checked By: dev */ -/*SDM Checked Date: 2024-07-19 */ +/*SDM Checked Date: 2025-02-10 */ /*Script Developed 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) */ /*Target Table: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) ON COMMIT PRESERVE ROWS; - + /*创建临时表加载不同数据 */ 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 ( message_unique_id /* 消息编号*/ @@ -64,28 +64,28 @@ INSERT INTO t01_ccc_chat_message_detail_agi_CUR_I ( ,Src_Table /*来源表*/ ) 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.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_type AS varchar(10))),'') /*sender_type*/ - ,COALESCE(TRIM(CAST(p0.message_type AS varchar(10))),'') /*message_type*/ + ,COALESCE(TRIM(CAST(p0.send_type_name AS varchar(10))),'') /*sender_type*/ + ,COALESCE(TRIM(CAST(p0.message_type_name AS varchar(10))),'') /*message_type*/ ,COALESCE(TRIM(p0.content),'') /*content*/ ,COALESCE(TRIM(p0.file_key),'') /*file_address*/ ,COALESCE(TRIM(CAST(p0.file_name AS varchar(100))),'') /*file_name*/ ,COALESCE(TRIM(p0.file_url),'') /*file_url*/ - ,COALESCE(TRIM(CAST(p0.send_status AS varchar(10))),'') /*send_status*/ - ,COALESCE(TRIM(p0.sensitive_word),'') /*sensitive_word*/ - ,to_timestamp(p0.create_time::bigint/1000)::timestamp(0) /*create_time*/ + ,'' /*send_status*/ + ,'' /*sensitive_word*/ + ,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*/ ,TO_DATE(:TXDATE,'YYYYMMDD') /*Etl_First_Dt*/ ,:ETLJOB /*Etl_Job*/ ,current_timestamp(0) /*Etl_Proc_Dt*/ ,TO_DATE(:TXDATE,'YYYYMMDD') /*Etl_Tx_Dt*/ - ,Substr('s98_s_tr_chat_messages',1,3) /*Src_Sysname*/ - ,'s98_s_tr_chat_messages' /*Src_Table*/ + ,Substr('s98_s_tr_chat_messages_new',1,3) /*Src_Sysname*/ + ,'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 ; diff --git a/dev/workflow/TK_Cust/smart_ccc_chat/smartccc会话记录/t01_ccc_chat_record_agi.sql b/dev/workflow/TK_Cust/smart_ccc_chat/smartccc会话记录/t01_ccc_chat_record_agi.sql index 1c2956e..63e10dc 100644 --- a/dev/workflow/TK_Cust/smart_ccc_chat/smartccc会话记录/t01_ccc_chat_record_agi.sql +++ b/dev/workflow/TK_Cust/smart_ccc_chat/smartccc会话记录/t01_ccc_chat_record_agi.sql @@ -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 */ /*Brilliance stems from wisdoms. */ /*************Head Section**************************************************************************/ /*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 Date: 2024-07-18 */ /*SDM Checked By: dev */ -/*SDM Checked Date: 2024-08-12 */ +/*SDM Checked Date: 2025-02-10 */ /*Script Developed 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) */ /*Target Table: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) ON COMMIT PRESERVE ROWS; - + /*创建临时表加载不同数据 */ 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 ( chat_unique_id /*在线客服会话ID*/ @@ -99,61 +99,61 @@ INSERT INTO t01_ccc_chat_record_agi_CUR_I ( ) SELECT 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.app_id AS varchar(50))),'') /*contact_app_id*/ + ,COALESCE(TRIM(CAST(p0.contact_type_name AS varchar(10))),'') /*contact_channel*/ + ,'' /*contact_app_id*/ ,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_name AS varchar(50))),'') /*visitor_name*/ - ,COALESCE(TRIM(CAST(p0.robot_id AS varchar(10))),'') /*robot_id*/ - ,COALESCE(TRIM(CAST(p0.robot_name AS varchar(10))),'') /*robot_name*/ - ,to_timestamp(p0.robot_start_time::bigint)::timestamp(0) /*robot_start_time*/ - ,to_timestamp(p0.robot_end_time::bigint)::timestamp(0) /*robot_end_time*/ - ,COALESCE(TRIM(CAST(p0.qno AS varchar(10))),'') /*queue_no*/ - ,COALESCE(TRIM(CAST(p0.qname AS varchar(10))),'') /*queue_name*/ - ,COALESCE(TRIM(CAST(p0.cno AS varchar(10))),'') /*client_no*/ - ,COALESCE(TRIM(CAST(p0.client_name AS varchar(10))),'') /*client_name*/ - ,COALESCE(TRIM(CAST(p0.chat_duration_type AS varchar(10))),'') /*chat_duration_type*/ - ,COALESCE(TRIM(CAST(p0.close_status AS varchar(10))),'') /*close_status*/ - ,COALESCE(TRIM(CAST(p0.close_reason AS varchar(10))),'') /*close_reason*/ - ,COALESCE(TRIM(CAST(p0.open_type AS varchar(10))),'') /*open_type*/ - ,COALESCE(CAST(p0.first_response_duration AS int),0) /*first_response_duration*/ - ,to_timestamp(p0.start_time::bigint)::timestamp(0) /*start_time*/ - ,to_timestamp(p0.end_time::bigint)::timestamp(0) /*end_time*/ - ,COALESCE(CAST(p0.queue_time AS int),0) /*queue_time*/ - ,to_timestamp(p0.join_queue_time::bigint)::timestamp(0) /*join_queue_time*/ - ,to_timestamp(p0.bridge_time::bigint)::timestamp(0) /*bridge_time*/ - ,COALESCE(TRIM(CAST(p0.session_type AS varchar(10))),'') /*session_type*/ - ,COALESCE(TRIM(CAST(p0.chat_valid_session AS varchar(10))),'') /*chat_valid_session*/ - ,COALESCE(TRIM(CAST(p0.comment_session AS varchar(10))),'') /*comment_session*/ - ,COALESCE(TRIM(CAST(p0.invitation_initiator AS varchar(10))),'') /*invitation_initiator*/ - ,COALESCE(TRIM(CAST(p0.keys AS varchar(10))),'') /*satisfaction_keys*/ - ,COALESCE(TRIM(CAST(p0.remark AS varchar(10))),'') /*satisfaction_remark*/ + ,'' /*robot_id*/ + ,'' /*robot_name*/ + ,COALESCE(TO_TIMESTAMP(CAST(p0.start_time AS VARCHAR(19)),'YYYY-MM-DD HH24:mi:ss'),TO_TIMESTAMP(:NULLDATE,'YYYYMMDD')) /*robot_start_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.first_qno AS varchar(10))),'') /*queue_no*/ + ,COALESCE(TRIM(CAST(p0.first_qname AS varchar(10))),'') /*queue_name*/ + ,COALESCE(TRIM(CAST(p0.first_cno AS varchar(10))),'') /*client_no*/ + ,COALESCE(TRIM(CAST(p0.first_cname AS varchar(10))),'') /*client_name*/ + ,'' /*chat_duration_type*/ + ,COALESCE(TRIM(CAST(p0.close_status_name AS varchar(10))),'') /*close_status*/ + ,COALESCE(TRIM(CAST(p0.close_reason_name AS varchar(10))),'') /*close_reason*/ + ,COALESCE(TRIM(CAST(p0.contact_type_name AS varchar(10))),'') /*open_type*/ + ,0 /*first_response_duration*/ + ,COALESCE(TO_TIMESTAMP(CAST(p0.start_time AS VARCHAR(19)),'YYYY-MM-DD HH24:mi:ss'),TO_TIMESTAMP(:NULLDATE,'YYYYMMDD')) /*start_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_duration AS int),0) /*queue_time*/ + ,0 /*join_queue_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_tags AS varchar(10))),'') /*session_type*/ + ,COALESCE(TRIM(CAST(p0.is_valid_name AS varchar(10))),'') /*chat_valid_session*/ + ,COALESCE(TRIM(CAST(p0.has_comment AS varchar(10))),'') /*comment_session*/ + ,'' /*invitation_initiator*/ + ,'' /*satisfaction_keys*/ + ,'' /*satisfaction_remark*/ ,COALESCE(TRIM(CAST(p0.ip AS varchar(20))),'') /*visitor_ip*/ - ,COALESCE(TRIM(CAST(p0.customer_region AS varchar(20))),'') /*visitor_region*/ - ,COALESCE(CAST(p0.chat_times AS int),0) /*chat_times*/ - ,COALESCE(CAST(p0.invited_times AS int),0) /*invited_times*/ + ,'' /*visitor_region*/ + ,0 /*chat_times*/ + ,0 /*invited_times*/ ,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.browser AS varchar(50))),'') /*browser*/ ,COALESCE(TRIM(p0.referer_url),'') /*referer_url*/ ,COALESCE(TRIM(p0.first_visit_page_url),'') /*first_visit_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(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.city AS varchar(10))),'') /*visitor_city*/ - ,COALESCE(TRIM(p0.referrer_name),'') /*referer_name*/ + ,'' /*referer_name*/ ,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('s98_s_tr_chat_records',1,3) /*Src_Sysname*/ - ,'s98_s_tr_chat_records' /*Src_Table*/ + ,Substr('s98_s_tr_chat_records_new',1,3) /*Src_Sysname*/ + ,'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 ;