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-14 12:09:48 +08:00
parent b4375c5627
commit df0f921229
2 changed files with 48 additions and 156 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -21,7 +21,7 @@ CREATE TABLE IF NOT EXISTS p20_pdm.t01_ccc_chat_message_detail (
, Etl_Tx_Dt timestamp(0) , Etl_Tx_Dt timestamp(0)
, Src_Sysname varchar(50) , Src_Sysname varchar(50)
, Src_Table varchar(50) , Src_Table varchar(50)
,primary key( message_unique_id,create_time )
); );
COMMENT ON COLUMN p20_pdm.t01_ccc_chat_message_detail.message_unique_id IS ' 消息编号'; COMMENT ON COLUMN p20_pdm.t01_ccc_chat_message_detail.message_unique_id IS ' 消息编号';

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

@ -4,7 +4,7 @@
/*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:2025-02-14 12:02:48 */ /*Create Date:2025-02-14 12:09:18 */
/*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 */
@ -16,7 +16,7 @@
/*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 */
/*ETL Frequency:Daily */ /*ETL Frequency:Daily */
/*ETL Policy:F2 */ /*ETL Policy:I */
/********************************************************************************************/ /********************************************************************************************/
/*******Main Section**************************************************************************/ /*******Main Section**************************************************************************/
\set ON_ERROR_STOP on \set ON_ERROR_STOP on
@ -31,13 +31,6 @@ CREATE TEMPORARY TABLE t01_ccc_chat_message_detail_agi_CUR_I
ON COMMIT PRESERVE ROWS; ON COMMIT PRESERVE ROWS;
/*创建临时表加载不同数据 */
CREATE TEMPORARY TABLE t01_ccc_chat_message_detail_agi_INS
( LIKE :PDMDB.t01_ccc_chat_message_detail)
ON COMMIT PRESERVE ROWS;
/*****************************************************************************************************/ /*****************************************************************************************************/
/* GROUP 1:Source Table:s98_s_tr_chat_messages_new****************************************************/ /* GROUP 1:Source Table:s98_s_tr_chat_messages_new****************************************************/
/*****************************************************************************************************/ /*****************************************************************************************************/
@ -90,9 +83,9 @@ FROM p10_sa.s98_s_tr_chat_messages_new p0
/*将不同数据插入到临时表 */ INSERT INTO :PDMDB.t01_ccc_chat_message_detail (
;INSERT INTO t01_ccc_chat_message_detail_agi_INS ( message_unique_id /* 消息编号*/
chat_unique_id /*在线客服会话ID*/ ,chat_unique_id /*在线客服会话ID*/
,sender_id /*消息发送方ID*/ ,sender_id /*消息发送方ID*/
,sender_name /*消息发送方名称*/ ,sender_name /*消息发送方名称*/
,sender_type /*消息发送方类型*/ ,sender_type /*消息发送方类型*/
@ -103,7 +96,6 @@ FROM p10_sa.s98_s_tr_chat_messages_new p0
,file_url /*文件访问路径*/ ,file_url /*文件访问路径*/
,send_status /*消息发送状态*/ ,send_status /*消息发送状态*/
,sensitive_word /*敏感词*/ ,sensitive_word /*敏感词*/
,message_unique_id /* 消息编号*/
,create_time /*消息创建时间戳*/ ,create_time /*消息创建时间戳*/
,Etl_Batch_No /*作业批次号*/ ,Etl_Batch_No /*作业批次号*/
,Etl_First_Dt /*最初入库时间*/ ,Etl_First_Dt /*最初入库时间*/
@ -115,7 +107,8 @@ FROM p10_sa.s98_s_tr_chat_messages_new p0
) )
SELECT SELECT
P1.chat_unique_id /*在线客服会话ID*/ P1.message_unique_id /* 消息编号*/
,P1.chat_unique_id /*在线客服会话ID*/
,P1.sender_id /*消息发送方ID*/ ,P1.sender_id /*消息发送方ID*/
,P1.sender_name /*消息发送方名称*/ ,P1.sender_name /*消息发送方名称*/
,P1.sender_type /*消息发送方类型*/ ,P1.sender_type /*消息发送方类型*/
@ -126,7 +119,6 @@ FROM p10_sa.s98_s_tr_chat_messages_new p0
,P1.file_url /*文件访问路径*/ ,P1.file_url /*文件访问路径*/
,P1.send_status /*消息发送状态*/ ,P1.send_status /*消息发送状态*/
,P1.sensitive_word /*敏感词*/ ,P1.sensitive_word /*敏感词*/
,P1.message_unique_id /* 消息编号*/
,P1.create_time /*消息创建时间戳*/ ,P1.create_time /*消息创建时间戳*/
,P1.Etl_Batch_No /*作业批次号*/ ,P1.Etl_Batch_No /*作业批次号*/
,P1.Etl_First_Dt /*最初入库时间*/ ,P1.Etl_First_Dt /*最初入库时间*/
@ -136,107 +128,7 @@ FROM p10_sa.s98_s_tr_chat_messages_new p0
,P1.Src_Sysname /*来源系统*/ ,P1.Src_Sysname /*来源系统*/
,P1.Src_Table /*来源表*/ ,P1.Src_Table /*来源表*/
FROM t01_ccc_chat_message_detail_agi_CUR_I P1 FROM t01_ccc_chat_message_detail_agi_CUR_I P1;
LEFT JOIN :PDMDB.t01_ccc_chat_message_detail P2
ON P1.chat_unique_id = P2.chat_unique_id
AND P1.sender_id = P2.sender_id
AND P1.sender_name = P2.sender_name
AND P1.sender_type = P2.sender_type
AND P1.message_type = P2.message_type
AND P1.content = P2.content
AND P1.file_address = P2.file_address
AND P1.file_name = P2.file_name
AND P1.file_url = P2.file_url
AND P1.send_status = P2.send_status
AND P1.sensitive_word = P2.sensitive_word
AND P1.message_unique_id = P2.message_unique_id
AND P1.create_time = P2.create_time
WHERE P2.chat_unique_id IS NULL
OR P2.sender_id IS NULL
OR P2.sender_name IS NULL
OR P2.sender_type IS NULL
OR P2.message_type IS NULL
OR P2.content IS NULL
OR P2.file_address IS NULL
OR P2.file_name IS NULL
OR P2.file_url IS NULL
OR P2.send_status IS NULL
OR P2.sensitive_word IS NULL
OR P2.message_unique_id IS NULL
OR P2.create_time IS NULL
;
/*将新增数据插入到目标表 */
;INSERT INTO :PDMDB.t01_ccc_chat_message_detail (
chat_unique_id /*在线客服会话ID*/
,sender_id /*消息发送方ID*/
,sender_name /*消息发送方名称*/
,sender_type /*消息发送方类型*/
,message_type /*消息类型*/
,content /*消息内容*/
,file_address /*文件的地址*/
,file_name /*文件名称*/
,file_url /*文件访问路径*/
,send_status /*消息发送状态*/
,sensitive_word /*敏感词*/
,message_unique_id /* 消息编号*/
,create_time /*消息创建时间戳*/
,Etl_Batch_No /*作业批次号*/
,Etl_First_Dt /*最初入库时间*/
,Etl_Job /*作业名称*/
,Etl_Proc_Dt /*本次入库时间*/
,Etl_Tx_Dt /*作业运行时间*/
,Src_Sysname /*来源系统*/
,Src_Table /*来源表*/
)
SELECT
P1.chat_unique_id /*在线客服会话ID*/
,P1.sender_id /*消息发送方ID*/
,P1.sender_name /*消息发送方名称*/
,P1.sender_type /*消息发送方类型*/
,P1.message_type /*消息类型*/
,P1.content /*消息内容*/
,P1.file_address /*文件的地址*/
,P1.file_name /*文件名称*/
,P1.file_url /*文件访问路径*/
,P1.send_status /*消息发送状态*/
,P1.sensitive_word /*敏感词*/
,P1.message_unique_id /* 消息编号*/
,P1.create_time /*消息创建时间戳*/
,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 t01_ccc_chat_message_detail_agi_INS P1
ON CONFLICT ( message_unique_id,create_time)
DO UPDATE SET
message_unique_id=excluded.message_unique_id
,create_time=excluded.create_time
,chat_unique_id=excluded.chat_unique_id
,sender_id=excluded.sender_id
,sender_name=excluded.sender_name
,sender_type=excluded.sender_type
,message_type=excluded.message_type
,content=excluded.content
,file_address=excluded.file_address
,file_name=excluded.file_name
,file_url=excluded.file_url
,send_status=excluded.send_status
,sensitive_word=excluded.sensitive_word
,Etl_Batch_No=excluded.Etl_Batch_No
,Etl_First_Dt=excluded.Etl_First_Dt
,Etl_Job=excluded.Etl_Job
,Etl_Proc_Dt=excluded.Etl_Proc_Dt
,Etl_Tx_Dt=excluded.Etl_Tx_Dt
,Src_Sysname=excluded.Src_Sysname
,Src_Table=excluded.Src_Table
; ;
/*****程序结束退出 */ /*****程序结束退出 */