From 1552eb50e176c2c0e1fef146022bf160cc756dcf Mon Sep 17 00:00:00 2001 From: root Date: Thu, 23 Jan 2025 11:05:39 +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 --- .../S98_S_tr_chat_records_new.sql | 206 ++++++++++++++++++ .../tr_chat_records_new/sa_foreign_tables.sql | 58 +++++ .../tr_chat_records_new/sa_tables.sql | 203 +++++++++++++++++ 3 files changed, 467 insertions(+) create mode 100644 dev/workflow/TK_Cust/smart_ccc_chat/tr_chat_records_new/S98_S_tr_chat_records_new.sql create mode 100644 dev/workflow/TK_Cust/smart_ccc_chat/tr_chat_records_new/sa_foreign_tables.sql create mode 100644 dev/workflow/TK_Cust/smart_ccc_chat/tr_chat_records_new/sa_tables.sql diff --git a/dev/workflow/TK_Cust/smart_ccc_chat/tr_chat_records_new/S98_S_tr_chat_records_new.sql b/dev/workflow/TK_Cust/smart_ccc_chat/tr_chat_records_new/S98_S_tr_chat_records_new.sql new file mode 100644 index 0000000..40d1856 --- /dev/null +++ b/dev/workflow/TK_Cust/smart_ccc_chat/tr_chat_records_new/S98_S_tr_chat_records_new.sql @@ -0,0 +1,206 @@ +/*******Main Section**************************************************************************/ +\set ON_ERROR_STOP on +\set AUTOCOMMIT on +\timing on +delete from p10_sa.S98_S_tr_chat_records_new +; +insert into p10_sa.S98_S_tr_chat_records_new +( main_unique_id + , app_name + , start_time + , end_time + , session_tags + , is_valid + , first_qno + , first_qname + , first_cno + , first_cname + , has_comment + , has_agent_ticket + , open_type_name + , contact_type_name + , receive_type_name + , close_reason_name + , close_status_name + , repeat_visit_name + , is_robot_valid_name + , is_valid_name + , total_duration_pretty + , total_duration + , queue_duration_pretty + , queue_duration + , visitor_id + , visitor_name + , customer_name + , ip + , province + , city + , phone_type_name + , visitor_extra_info + , device_type + , browser + , operating_system + , search_word + , market_keyword + , first_visit_page_url + , initiation_page_url + , referer_url + , search_engine_name + , medium + , plan + , unit + , account + , source + , etl_tx_dt ) + select + main_unique_id + , app_name + , start_time + , end_time + , session_tags + , is_valid + , first_qno + , first_qname + , first_cno + , first_cname + , has_comment + , has_agent_ticket + , open_type_name + , contact_type_name + , receive_type_name + , close_reason_name + , close_status_name + , repeat_visit_name + , is_robot_valid_name + , is_valid_name + , total_duration_pretty + , total_duration + , queue_duration_pretty + , queue_duration + , visitor_id + , visitor_name + , customer_name + , ip + , province + , city + , phone_type_name + , visitor_extra_info + , device_type + , browser + , operating_system + , search_word + , market_keyword + , first_visit_page_url + , initiation_page_url + , referer_url + , search_engine_name + , medium + , plan + , unit + , account + , source + , etl_tx_dt + from p00_tal.S98_S_tr_chat_records_new + ; + delete from p12_sfull.S98_S_tr_chat_records_new +; +; +insert into p12_sfull.S98_S_tr_chat_records_new +( main_unique_id + , app_name + , start_time + , end_time + , session_tags + , is_valid + , first_qno + , first_qname + , first_cno + , first_cname + , has_comment + , has_agent_ticket + , open_type_name + , contact_type_name + , receive_type_name + , close_reason_name + , close_status_name + , repeat_visit_name + , is_robot_valid_name + , is_valid_name + , total_duration_pretty + , total_duration + , queue_duration_pretty + , queue_duration + , visitor_id + , visitor_name + , customer_name + , ip + , province + , city + , phone_type_name + , visitor_extra_info + , device_type + , browser + , operating_system + , search_word + , market_keyword + , first_visit_page_url + , initiation_page_url + , referer_url + , search_engine_name + , medium + , plan + , unit + , account + , source + , etl_tx_dt ) + select + main_unique_id + , app_name + , start_time + , end_time + , session_tags + , is_valid + , first_qno + , first_qname + , first_cno + , first_cname + , has_comment + , has_agent_ticket + , open_type_name + , contact_type_name + , receive_type_name + , close_reason_name + , close_status_name + , repeat_visit_name + , is_robot_valid_name + , is_valid_name + , total_duration_pretty + , total_duration + , queue_duration_pretty + , queue_duration + , visitor_id + , visitor_name + , customer_name + , ip + , province + , city + , phone_type_name + , visitor_extra_info + , device_type + , browser + , operating_system + , search_word + , market_keyword + , first_visit_page_url + , initiation_page_url + , referer_url + , search_engine_name + , medium + , plan + , unit + , account + , source + , etl_tx_dt + from p10_sa.S98_S_tr_chat_records_new +; +\q \ No newline at end of file diff --git a/dev/workflow/TK_Cust/smart_ccc_chat/tr_chat_records_new/sa_foreign_tables.sql b/dev/workflow/TK_Cust/smart_ccc_chat/tr_chat_records_new/sa_foreign_tables.sql new file mode 100644 index 0000000..921ca6b --- /dev/null +++ b/dev/workflow/TK_Cust/smart_ccc_chat/tr_chat_records_new/sa_foreign_tables.sql @@ -0,0 +1,58 @@ + +CREATE FOREIGN TABLE if not exists p00_tal.S98_S_tr_chat_records_new ( + main_unique_id TEXT + , app_name TEXT + , start_time TEXT + , end_time TEXT + , session_tags TEXT + , is_valid TEXT + , first_qno TEXT + , first_qname TEXT + , first_cno TEXT + , first_cname TEXT + , has_comment TEXT + , has_agent_ticket TEXT + , open_type_name TEXT + , contact_type_name TEXT + , receive_type_name TEXT + , close_reason_name TEXT + , close_status_name TEXT + , repeat_visit_name TEXT + , is_robot_valid_name TEXT + , is_valid_name TEXT + , total_duration_pretty TEXT + , total_duration TEXT + , queue_duration_pretty TEXT + , queue_duration TEXT + , visitor_id TEXT + , visitor_name TEXT + , customer_name TEXT + , ip TEXT + , province TEXT + , city TEXT + , phone_type_name TEXT + , visitor_extra_info TEXT + , device_type TEXT + , browser TEXT + , operating_system TEXT + , search_word TEXT + , market_keyword TEXT + , first_visit_page_url TEXT + , initiation_page_url TEXT + , referer_url TEXT + , search_engine_name TEXT + , medium TEXT + , plan TEXT + , unit TEXT + , account TEXT + , source TEXT + , etl_tx_dt TIMESTAMP +) + + +SERVER pgsql_server_S98_S OPTIONS(schema_name 'data_api', table_name 'tr_chat_records_new' ); + + + + + diff --git a/dev/workflow/TK_Cust/smart_ccc_chat/tr_chat_records_new/sa_tables.sql b/dev/workflow/TK_Cust/smart_ccc_chat/tr_chat_records_new/sa_tables.sql new file mode 100644 index 0000000..f970b81 --- /dev/null +++ b/dev/workflow/TK_Cust/smart_ccc_chat/tr_chat_records_new/sa_tables.sql @@ -0,0 +1,203 @@ + +create table if not exists p10_sa.S98_S_tr_chat_records_new ( + main_unique_id TEXT + , app_name TEXT + , start_time TEXT + , end_time TEXT + , session_tags TEXT + , is_valid TEXT + , first_qno TEXT + , first_qname TEXT + , first_cno TEXT + , first_cname TEXT + , has_comment TEXT + , has_agent_ticket TEXT + , open_type_name TEXT + , contact_type_name TEXT + , receive_type_name TEXT + , close_reason_name TEXT + , close_status_name TEXT + , repeat_visit_name TEXT + , is_robot_valid_name TEXT + , is_valid_name TEXT + , total_duration_pretty TEXT + , total_duration TEXT + , queue_duration_pretty TEXT + , queue_duration TEXT + , visitor_id TEXT + , visitor_name TEXT + , customer_name TEXT + , ip TEXT + , province TEXT + , city TEXT + , phone_type_name TEXT + , visitor_extra_info TEXT + , device_type TEXT + , browser TEXT + , operating_system TEXT + , search_word TEXT + , market_keyword TEXT + , first_visit_page_url TEXT + , initiation_page_url TEXT + , referer_url TEXT + , search_engine_name TEXT + , medium TEXT + , plan TEXT + , unit TEXT + , account TEXT + , source TEXT + , etl_tx_dt TIMESTAMP +) ; + + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.main_unique_id IS '在线客服会话ID'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.app_name IS '接入号名'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.start_time IS '会话开始时间'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.end_time IS '会话结束时间戳'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.session_tags IS '会话标签'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.is_valid IS '人工有效性'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.first_qno IS '首次进线队列号'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.first_qname IS '首次进线队列名称'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.first_cno IS '首次接待座席号'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.first_cname IS '首次接待座席名称'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.has_comment IS '是否留言'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.has_agent_ticket IS '存在座席创建工单'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.open_type_name IS '会话发起方式解释'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.contact_type_name IS '渠道类型'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.receive_type_name IS '接待类型名称'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.close_reason_name IS '结束原因'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.close_status_name IS '结束状态'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.repeat_visit_name IS '重复进线'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.is_robot_valid_name IS '机器人有效性'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.is_valid_name IS '首次接待座席号'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.total_duration_pretty IS '会话时长'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.total_duration IS '会话时长'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.queue_duration_pretty IS '排队时长'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.queue_duration IS '排队时长'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.visitor_id IS '访客ID'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.visitor_name IS '访客姓名'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.customer_name IS '客户名称'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.ip IS 'IP地址'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.province IS '客户省份'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.city IS '客户城市'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.phone_type_name IS '手机类型解释'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.visitor_extra_info IS '访客自定义参数'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.device_type IS '访客设备类型'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.browser IS '浏览器型号'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.operating_system IS '操作系统'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.search_word IS '搜索词'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.market_keyword IS '关键词'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.first_visit_page_url IS '着陆页'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.initiation_page_url IS '会话发起页'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.referer_url IS '来源页'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.search_engine_name IS '搜索引擎'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.medium IS '推广媒介'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.plan IS '推广计划'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.unit IS '推广单元'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.account IS '推广账户'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.source IS '推广来源'; + COMMENT ON COLUMN p10_sa.S98_S_tr_chat_records_new.etl_tx_dt IS ''; + +COMMENT ON TABLE p10_sa.S98_S_tr_chat_records_new IS ''; + + + +create table if not exists p12_sfull.S98_S_tr_chat_records_new ( + main_unique_id TEXT + , app_name TEXT + , start_time TEXT + , end_time TEXT + , session_tags TEXT + , is_valid TEXT + , first_qno TEXT + , first_qname TEXT + , first_cno TEXT + , first_cname TEXT + , has_comment TEXT + , has_agent_ticket TEXT + , open_type_name TEXT + , contact_type_name TEXT + , receive_type_name TEXT + , close_reason_name TEXT + , close_status_name TEXT + , repeat_visit_name TEXT + , is_robot_valid_name TEXT + , is_valid_name TEXT + , total_duration_pretty TEXT + , total_duration TEXT + , queue_duration_pretty TEXT + , queue_duration TEXT + , visitor_id TEXT + , visitor_name TEXT + , customer_name TEXT + , ip TEXT + , province TEXT + , city TEXT + , phone_type_name TEXT + , visitor_extra_info TEXT + , device_type TEXT + , browser TEXT + , operating_system TEXT + , search_word TEXT + , market_keyword TEXT + , first_visit_page_url TEXT + , initiation_page_url TEXT + , referer_url TEXT + , search_engine_name TEXT + , medium TEXT + , plan TEXT + , unit TEXT + , account TEXT + , source TEXT + , etl_tx_dt TIMESTAMP +) ; + + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.main_unique_id IS '在线客服会话ID'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.app_name IS '接入号名'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.start_time IS '会话开始时间'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.end_time IS '会话结束时间戳'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.session_tags IS '会话标签'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.is_valid IS '人工有效性'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.first_qno IS '首次进线队列号'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.first_qname IS '首次进线队列名称'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.first_cno IS '首次接待座席号'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.first_cname IS '首次接待座席名称'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.has_comment IS '是否留言'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.has_agent_ticket IS '存在座席创建工单'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.open_type_name IS '会话发起方式解释'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.contact_type_name IS '渠道类型'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.receive_type_name IS '接待类型名称'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.close_reason_name IS '结束原因'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.close_status_name IS '结束状态'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.repeat_visit_name IS '重复进线'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.is_robot_valid_name IS '机器人有效性'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.is_valid_name IS '首次接待座席号'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.total_duration_pretty IS '会话时长'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.total_duration IS '会话时长'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.queue_duration_pretty IS '排队时长'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.queue_duration IS '排队时长'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.visitor_id IS '访客ID'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.visitor_name IS '访客姓名'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.customer_name IS '客户名称'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.ip IS 'IP地址'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.province IS '客户省份'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.city IS '客户城市'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.phone_type_name IS '手机类型解释'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.visitor_extra_info IS '访客自定义参数'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.device_type IS '访客设备类型'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.browser IS '浏览器型号'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.operating_system IS '操作系统'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.search_word IS '搜索词'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.market_keyword IS '关键词'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.first_visit_page_url IS '着陆页'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.initiation_page_url IS '会话发起页'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.referer_url IS '来源页'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.search_engine_name IS '搜索引擎'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.medium IS '推广媒介'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.plan IS '推广计划'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.unit IS '推广单元'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.account IS '推广账户'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.source IS '推广来源'; + COMMENT ON COLUMN p12_sfull.S98_S_tr_chat_records_new.etl_tx_dt IS ''; + +COMMENT ON TABLE p12_sfull.S98_S_tr_chat_records_new IS ''; +