diff --git a/dev/workflow/TK_Cust/smart_ccc_chat/tr_chat_messages/S98_S_tr_chat_messages.sql b/dev/workflow/TK_Cust/smart_ccc_chat/tr_chat_messages/S98_S_tr_chat_messages.sql
index eb72c70..2d6e298 100644
--- a/dev/workflow/TK_Cust/smart_ccc_chat/tr_chat_messages/S98_S_tr_chat_messages.sql
+++ b/dev/workflow/TK_Cust/smart_ccc_chat/tr_chat_messages/S98_S_tr_chat_messages.sql
@@ -5,69 +5,69 @@
 delete from p10_sa.S98_S_tr_chat_messages
 ;
 insert into p10_sa.S98_S_tr_chat_messages
-(	 unique_id  
-	, main_unique_id  
-	, sender_id  
-	, sender_name  
-	, sender_type  
-	, message_type  
-	, content  
-	, file_key  
-	, file_name  
-	, file_url  
-	, send_status  
-	, sensitive_word  
-	, create_time  
+(	 unique_id  
+	, main_unique_id  
+	, sender_id  
+	, sender_name  
+	, sender_type  
+	, message_type  
+	, content  
+	, file_key  
+	, file_name  
+	, file_url  
+	, send_status  
+	, sensitive_word  
+	, create_time  
 	, etl_tx_dt   )
   select 
-	 unique_id  
-	, main_unique_id  
-	, sender_id  
-	, sender_name  
-	, sender_type  
-	, message_type  
-	, content  
-	, file_key  
-	, file_name  
-	, file_url  
-	, send_status  
-	, sensitive_word  
-	, create_time  
+	 unique_id  
+	, main_unique_id  
+	, sender_id  
+	, sender_name  
+	, sender_type  
+	, message_type  
+	, content  
+	, file_key  
+	, file_name  
+	, file_url  
+	, send_status  
+	, sensitive_word  
+	, create_time  
 	, etl_tx_dt  
   from p00_tal.S98_S_tr_chat_messages
   ;
-  delete from p12_sfull.S98_S_tr_chat_messages
+  delete from p12_sfull.S98_S_tr_chat_messages where unique_id in (select unique_id from p10_sa.S98_S_tr_chat_messages)
 ;
 ;
 insert into p12_sfull.S98_S_tr_chat_messages
-(	 unique_id  
-	, main_unique_id  
-	, sender_id  
-	, sender_name  
-	, sender_type  
-	, message_type  
-	, content  
-	, file_key  
-	, file_name  
-	, file_url  
-	, send_status  
-	, sensitive_word  
-	, create_time  
+(	 unique_id  
+	, main_unique_id  
+	, sender_id  
+	, sender_name  
+	, sender_type  
+	, message_type  
+	, content  
+	, file_key  
+	, file_name  
+	, file_url  
+	, send_status  
+	, sensitive_word  
+	, create_time  
 	, etl_tx_dt   )
   select 
-	 unique_id  
-	, main_unique_id  
-	, sender_id  
-	, sender_name  
-	, sender_type  
-	, message_type  
-	, content  
-	, file_key  
-	, file_name  
-	, file_url  
-	, send_status  
-	, sensitive_word  
-	, create_time  
+	 unique_id  
+	, main_unique_id  
+	, sender_id  
+	, sender_name  
+	, sender_type  
+	, message_type  
+	, content  
+	, file_key  
+	, file_name  
+	, file_url  
+	, send_status  
+	, sensitive_word  
+	, create_time  
 	, etl_tx_dt  
   from p10_sa.S98_S_tr_chat_messages
 ;
diff --git a/dev/workflow/TK_Cust/smart_ccc_chat/天润Smart-ccc会话数据/wf_dag_smart_ccc_chat.py b/dev/workflow/TK_Cust/smart_ccc_chat/天润Smart-ccc会话数据/wf_dag_smart_ccc_chat.py
index 4492220..874714c 100644
--- a/dev/workflow/TK_Cust/smart_ccc_chat/天润Smart-ccc会话数据/wf_dag_smart_ccc_chat.py
+++ b/dev/workflow/TK_Cust/smart_ccc_chat/天润Smart-ccc会话数据/wf_dag_smart_ccc_chat.py
@@ -24,7 +24,7 @@ default_args = {
 }
 
 dag = DAG('wf_dag_smart_ccc_chat', default_args=default_args,
-schedule_interval="0 0-23/1 * * *",
+schedule_interval="59 0-23/1 * * *",
 catchup=False,
 dagrun_timeout=timedelta(minutes=160),
 max_active_runs=3)
diff --git a/dev/workflow/TK_Cust/smart_ccc_chat/查询会话记录列表/chat_records_feign.py b/dev/workflow/TK_Cust/smart_ccc_chat/查询会话记录列表/chat_records_feign.py
index 142c499..341c8e1 100644
--- a/dev/workflow/TK_Cust/smart_ccc_chat/查询会话记录列表/chat_records_feign.py
+++ b/dev/workflow/TK_Cust/smart_ccc_chat/查询会话记录列表/chat_records_feign.py
@@ -152,7 +152,7 @@ def load_detail_data_to_db(ids, dataList):
     json_object = json.dumps(dataList)
     idstr = ','.join(ids)
     cur=conn.cursor()
-    sql="update data_api.cc_details_ids_exp set is_loaded = '1' where api_id = '211b765fe3e04082a9f83a29e3b0c37c' and id in (%s); INSERT INTO data_api.cc_message_details (id,api_id,data,total_num,is_loaded,status,request_tm,execute_tm,remark) values (%s,%s,%s,%s,'0','0',current_timestamp(0),current_timestamp(0),'')"
+    sql="update data_api.cc_details_ids_exp set is_loaded = '1' where api_id = '211b765fe3e04082a9f83a29e3b0c37c' and id in (%s);update data_api.cc_message_details set is_loaded = '1' where api_id = '211b765fe3e04082a9f83a29e3b0c37c'; INSERT INTO data_api.cc_message_details (id,api_id,data,total_num,is_loaded,status,request_tm,execute_tm,remark) values (%s,%s,%s,%s,'0','0',current_timestamp(0),current_timestamp(0),'')"
     cur.execute(sql,[idstr,dataId,'211b765fe3e04082a9f83a29e3b0c37c', json_object, total])
     conn.commit()
     cur.close()