From b4375c56271c28f258f3d69f534c97a4d06955f4 Mon Sep 17 00:00:00 2001 From: root Date: Fri, 14 Feb 2025 12:03:35 +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.sql | 2 +- .../t01_ccc_chat_message_detail_agi.sql | 20 +++++++++---------- 2 files changed, 11 insertions(+), 11 deletions(-) diff --git a/dev/workflow/TK_Cust/smart_ccc_chat/smartccc会话消息详情/t01_ccc_chat_message_detail.sql b/dev/workflow/TK_Cust/smart_ccc_chat/smartccc会话消息详情/t01_ccc_chat_message_detail.sql index 3b60be4..21fa24f 100644 --- a/dev/workflow/TK_Cust/smart_ccc_chat/smartccc会话消息详情/t01_ccc_chat_message_detail.sql +++ b/dev/workflow/TK_Cust/smart_ccc_chat/smartccc会话消息详情/t01_ccc_chat_message_detail.sql @@ -21,7 +21,7 @@ CREATE TABLE IF NOT EXISTS p20_pdm.t01_ccc_chat_message_detail ( , Etl_Tx_Dt timestamp(0) , Src_Sysname varchar(50) , Src_Table varchar(50) - ,primary key( message_unique_id ) + ,primary key( message_unique_id,create_time ) ); COMMENT ON COLUMN p20_pdm.t01_ccc_chat_message_detail.message_unique_id IS ' 消息编号'; 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 34d3714..dc41767 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 @@ -4,11 +4,11 @@ /*Brilliance stems from wisdoms. */ /*************Head Section**************************************************************************/ /*Script Use: Periodically load data to :t01_ccc_chat_message_detail(smartccc会话消息详情) */ -/*Create Date:2025-02-10 12:21:15 */ +/*Create Date:2025-02-14 12:02:48 */ /*SDM Developed By: dev */ /*SDM Developed Date: 2024-07-19 */ /*SDM Checked By: dev */ -/*SDM Checked Date: 2025-02-10 */ +/*SDM Checked Date: 2025-02-14 */ /*Script Developed By: dev */ /*Script Checked By: dev */ /*Source table 1: p10_sa.s98_s_tr_chat_messages_new */ @@ -103,8 +103,8 @@ FROM p10_sa.s98_s_tr_chat_messages_new p0 ,file_url /*文件访问路径*/ ,send_status /*消息发送状态*/ ,sensitive_word /*敏感词*/ - ,create_time /*消息创建时间戳*/ ,message_unique_id /* 消息编号*/ + ,create_time /*消息创建时间戳*/ ,Etl_Batch_No /*作业批次号*/ ,Etl_First_Dt /*最初入库时间*/ ,Etl_Job /*作业名称*/ @@ -126,8 +126,8 @@ FROM p10_sa.s98_s_tr_chat_messages_new p0 ,P1.file_url /*文件访问路径*/ ,P1.send_status /*消息发送状态*/ ,P1.sensitive_word /*敏感词*/ - ,P1.create_time /*消息创建时间戳*/ ,P1.message_unique_id /* 消息编号*/ + ,P1.create_time /*消息创建时间戳*/ ,P1.Etl_Batch_No /*作业批次号*/ ,P1.Etl_First_Dt /*最初入库时间*/ ,P1.Etl_Job /*作业名称*/ @@ -149,8 +149,8 @@ ON P1.chat_unique_id = P2.chat_unique_id AND P1.file_url = P2.file_url AND P1.send_status = P2.send_status AND P1.sensitive_word = P2.sensitive_word - AND P1.create_time = P2.create_time 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 @@ -163,8 +163,8 @@ WHERE P2.chat_unique_id IS NULL OR P2.file_url IS NULL OR P2.send_status IS NULL OR P2.sensitive_word IS NULL - OR P2.create_time IS NULL OR P2.message_unique_id IS NULL + OR P2.create_time IS NULL ; /*将新增数据插入到目标表 */ @@ -180,8 +180,8 @@ WHERE P2.chat_unique_id IS NULL ,file_url /*文件访问路径*/ ,send_status /*消息发送状态*/ ,sensitive_word /*敏感词*/ - ,create_time /*消息创建时间戳*/ ,message_unique_id /* 消息编号*/ + ,create_time /*消息创建时间戳*/ ,Etl_Batch_No /*作业批次号*/ ,Etl_First_Dt /*最初入库时间*/ ,Etl_Job /*作业名称*/ @@ -203,8 +203,8 @@ SELECT ,P1.file_url /*文件访问路径*/ ,P1.send_status /*消息发送状态*/ ,P1.sensitive_word /*敏感词*/ - ,P1.create_time /*消息创建时间戳*/ ,P1.message_unique_id /* 消息编号*/ + ,P1.create_time /*消息创建时间戳*/ ,P1.Etl_Batch_No /*作业批次号*/ ,P1.Etl_First_Dt /*最初入库时间*/ ,P1.Etl_Job /*作业名称*/ @@ -214,9 +214,10 @@ SELECT ,P1.Src_Table /*来源表*/ FROM t01_ccc_chat_message_detail_agi_INS P1 -ON CONFLICT ( message_unique_id) +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 @@ -228,7 +229,6 @@ DO UPDATE SET ,file_url=excluded.file_url ,send_status=excluded.send_status ,sensitive_word=excluded.sensitive_word - ,create_time=excluded.create_time ,Etl_Batch_No=excluded.Etl_Batch_No ,Etl_First_Dt=excluded.Etl_First_Dt ,Etl_Job=excluded.Etl_Job