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 2024-07-31 11:17:09 +08:00
parent bc90d9f421
commit 0eafd90272
5 changed files with 1345 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

108
dev/workflow/TK_Cust/smart_ccc_ticket/smartccc工单信息/t01_ccc_work_ticket_info.sql Normal file
View File

@ -0,0 +1,108 @@
DROP TABLE IF EXISTS p20_pdm.t01_ccc_work_ticket_info;
CREATE TABLE IF NOT EXISTS p20_pdm.t01_ccc_work_ticket_info (
id varchar(10)
, workflow_id varchar(10)
, workflow_name varchar(50)
, workflow_category_id varchar(10)
, workflow_category_name varchar(50)
, type varchar(10)
, topic varchar(10)
, level varchar(10)
, status text
, state text
, creator_name varchar(50)
, creator_id varchar(20)
, creator_type varchar(20)
, modifier_id varchar(20)
, modifier_name varchar(50)
, modifier_type varchar(20)
, focus text
, source varchar(10)
, timeout char(1)
, end_time timestamp(0)
, create_time timestamp(0)
, update_time timestamp(0)
, close_time timestamp(0)
, operation_logs text
, operation_logs_new text
, comments text
, state_selected varchar(20)
, last_reminder_time timestamp(0)
, reminder_count int
, customer_id varchar(10)
, customer_name varchar(100)
, customer_tel varchar(100)
, customer_email varchar(100)
, customer_address text
, customer_creator_id varchar(10)
, customer_creator_name varchar(20)
, customer_modifier_id varchar(20)
, customer_modifier_name varchar(30)
, tags text
, call_id varchar(30)
, start_form text
, forms text
, system_form text
, Etl_Batch_No varchar(50)
, Etl_First_Dt timestamp(0)
, Etl_Job varchar(200)
, Etl_Proc_Dt timestamp(0)
, Etl_Tx_Dt timestamp(0)
, Src_Sysname varchar(50)
, Src_Table varchar(50)
,primary key( id )
);
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.id IS '工单 ID';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.workflow_id IS '模板 ID';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.workflow_name IS '模板名称';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.workflow_category_id IS '模板类别id';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.workflow_category_name IS '模板类别名称';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.type IS '工单类型';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.topic IS '工单主题';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.level IS '工单优先级';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.status IS '工单状态';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.state IS '自定义状态数组';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.creator_name IS '创建人名称';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.creator_id IS '创建人 ID';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.creator_type IS '';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.modifier_id IS '修改人 ID';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.modifier_name IS '修改人名称';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.modifier_type IS '';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.focus IS '关注人数组集合';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.source IS '来源';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.timeout IS '是否超时';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.end_time IS '结束时间';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.create_time IS '创建时间';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.update_time IS '更新时间';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.close_time IS '关闭时间';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.operation_logs IS '工单操作日志 ';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.operation_logs_new IS '工单操作日志v2';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.comments IS '评论人数组 ';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.state_selected IS '当前工单状态';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.last_reminder_time IS '最近催单时间';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.reminder_count IS '催单次数';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.customer_id IS '客户 ID';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.customer_name IS '客户名称';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.customer_tel IS '客户号码';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.customer_email IS '客户邮箱';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.customer_address IS '客户地址';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.customer_creator_id IS '客户资料创建人 ID';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.customer_creator_name IS '客户资料创建人名称';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.customer_modifier_id IS '客户资料修改人';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.customer_modifier_name IS '客户资料修改人姓名';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.tags IS '工单标签';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.call_id IS '通话记录唯一标识';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.start_form IS '起始表单';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.forms IS '历史表单';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.system_form IS '工单属性表单';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.Etl_Batch_No IS '作业批次号';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.Etl_First_Dt IS '最初入库时间';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.Etl_Job IS '作业名称';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.Etl_Proc_Dt IS '本次入库时间';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.Etl_Tx_Dt IS '作业运行时间';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.Src_Sysname IS '来源系统';
COMMENT ON COLUMN p20_pdm.t01_ccc_work_ticket_info.Src_Table IS '来源表';
COMMENT ON TABLE p20_pdm.t01_ccc_work_ticket_info IS 'smartccc工单信息';

517
dev/workflow/TK_Cust/smart_ccc_ticket/smartccc工单信息/t01_ccc_work_ticket_info_agi.sql Normal file
View File

@ -0,0 +1,517 @@
/***************************************************************************************************/
/*script in Sql, generate by SdmCreateScript 2020(by Qihang Feng, QF255001@TERADATA.COM) */
/*VERSION 01.10 revised on 2020-08-25 */
/*Brilliance stems from wisdoms. */
/*************Head Section**************************************************************************/
/*Script Use: Periodically load data to :t01_ccc_work_ticket_info(smartccc工单信息) */
/*Create Date:2024-07-08 19:12:14 */
/*SDM Developed By: dev */
/*SDM Developed Date: 2024-07-08 */
/*SDM Checked By: dev */
/*SDM Checked Date: 2024-07-08 */
/*Script Developed By: dev */
/*Script Checked By: dev */
/*Source table 1: :SADB.s98_s_tr_ticket_detail */
/*Source table 2: p10_sa.s98_s_tr_ticket_list */
/*Job Type: Inbound transform (Tier 1 to Tier 2) */
/*Target Table:t01_ccc_work_ticket_info */
/*ETL Job Name:t01_ccc_work_ticket_info */
/*ETL Frequency:Daily */
/*ETL Policy:F2 */
/********************************************************************************************/
/*******Main Section**************************************************************************/
\set ON_ERROR_STOP on
\set AUTOCOMMIT on
\timing on
/*创建临时表加载当前数据 */
CREATE TEMPORARY TABLE t01_ccc_work_ticket_info_agi_CUR_I
( LIKE :PDMDB.t01_ccc_work_ticket_info)
ON COMMIT PRESERVE ROWS;
/*创建临时表加载不同数据 */
CREATE TEMPORARY TABLE t01_ccc_work_ticket_info_agi_INS
( LIKE :PDMDB.t01_ccc_work_ticket_info)
ON COMMIT PRESERVE ROWS;
/*****************************************************************************************************/
/* GROUP 1:Source Table:s98_s_tr_ticket_list**********************************************************/
/*****************************************************************************************************/
INSERT INTO t01_ccc_work_ticket_info_agi_CUR_I (
id /*工单 ID*/
,workflow_id /*模板 ID*/
,workflow_name /*模板名称*/
,workflow_category_id /*模板类别id*/
,workflow_category_name /*模板类别名称*/
,type /*工单类型*/
,topic /*工单主题*/
,level /*工单优先级*/
,status /*工单状态*/
,state /*自定义状态数组*/
,creator_name /*创建人名称*/
,creator_id /*创建人 ID*/
,creator_type /**/
,modifier_id /*修改人 ID*/
,modifier_name /*修改人名称*/
,modifier_type /**/
,focus /*关注人数组集合*/
,source /*来源*/
,timeout /*是否超时*/
,end_time /*结束时间*/
,create_time /*创建时间*/
,update_time /*更新时间*/
,close_time /*关闭时间*/
,operation_logs /*工单操作日志 */
,operation_logs_new /*工单操作日志v2*/
,comments /*评论人数组 */
,state_selected /*当前工单状态*/
,last_reminder_time /*最近催单时间*/
,reminder_count /*催单次数*/
,customer_id /*客户 ID*/
,customer_name /*客户名称*/
,customer_tel /*客户号码*/
,customer_email /*客户邮箱*/
,customer_address /*客户地址*/
,customer_creator_id /*客户资料创建人 ID*/
,customer_creator_name /*客户资料创建人名称*/
,customer_modifier_id /*客户资料修改人*/
,customer_modifier_name /*客户资料修改人姓名*/
,tags /*工单标签*/
,call_id /*通话记录唯一标识*/
,start_form /*起始表单*/
,forms /*历史表单*/
,system_form /*工单属性表单*/
,Etl_Batch_No /*作业批次号*/
,Etl_First_Dt /*最初入库时间*/
,Etl_Job /*作业名称*/
,Etl_Proc_Dt /*本次入库时间*/
,Etl_Tx_Dt /*作业运行时间*/
,Src_Sysname /*来源系统*/
,Src_Table /*来源表*/
)
SELECT
COALESCE(TRIM(CAST(p0.id AS varchar(10))),'') /*id*/
,COALESCE(TRIM(CAST(p0.workflow_id AS varchar(10))),'') /*workflow_id*/
,COALESCE(TRIM(CAST(p0.workflow_name AS varchar(50))),'') /*workflow_name*/
,p1.workflow_category_id /*workflow_category_id*/
,p1.workflow_category_name /*workflow_category_name*/
,COALESCE(TRIM(CAST(p0.type AS varchar(10))),'') /*type*/
,COALESCE(TRIM(CAST(p0.topic AS varchar(10))),'') /*topic*/
,COALESCE(TRIM(CAST(p0.level AS varchar(10))),'') /*level*/
,COALESCE(TRIM(p0.status),'') /*status*/
,p1.state /*state*/
,COALESCE(TRIM(CAST(p0.creator_name AS varchar(50))),'') /*creator_name*/
,COALESCE(TRIM(CAST(p0.creator_id AS varchar(20))),'') /*creator_id*/
,COALESCE(TRIM(CAST(p0.creator_type AS varchar(20))),'') /*creator_type*/
,COALESCE(TRIM(CAST(p0.modifier_id AS varchar(20))),'') /*modifier_id*/
,p1.modifier_name /*modifier_name*/
,COALESCE(TRIM(CAST(p0.modifier_type AS varchar(20))),'') /*modifier_type*/
,p1.focus /*focus*/
,COALESCE(TRIM(CAST(p0.source AS varchar(10))),'') /*source*/
,COALESCE(TRIM(CAST(p0.timeout AS char(1))),'') /*timeout*/
,to_timestamp(p0.end_time::bigint/1000)::timestamp(0) /*end_time*/
,to_timestamp(p0.create_time::bigint/1000)::timestamp(0) /*create_time*/
,to_timestamp(p1.update_time::bigint/1000)::timestamp(0) /*update_time*/
,to_timestamp(p0.close_time::bigint/1000)::timestamp(0) /*close_time*/
,p1.operation_logs /*operation_logs*/
,p1.operation_logs_new /*operation_logs_new*/
,p1.comments /*comments*/
,COALESCE(TRIM(CAST(p0.state_selected AS varchar(20))),'') /*state_selected*/
,to_timestamp(p0.last_reminder_time::bigint/1000)::timestamp(0) /*last_reminder_time*/
,COALESCE(CAST(p0.reminder_count AS int),0) /*reminder_count*/
,COALESCE(TRIM(CAST(p0.customer_id AS varchar(10))),'') /*customer_id*/
,COALESCE(TRIM(CAST(p0.customer_name AS varchar(100))),'') /*customer_name*/
,COALESCE(TRIM(CAST(p0.customer_tel AS varchar(100))),'') /*customer_tel*/
,COALESCE(TRIM(CAST(p0.customer_email AS varchar(100))),'') /*customer_email*/
,COALESCE(TRIM(p0.customer_address),'') /*customer_address*/
,COALESCE(TRIM(CAST(p0.customer_creator_id AS varchar(10))),'') /*customer_creator_id*/
,COALESCE(TRIM(CAST(p0.customer_creator_name AS varchar(20))),'') /*customer_creator_name*/
,COALESCE(TRIM(CAST(p0.customer_modifier_id AS varchar(20))),'') /*customer_modifier_id*/
,COALESCE(TRIM(CAST(p0.customer_modifier_name AS varchar(30))),'') /*customer_modifier_name*/
,COALESCE(TRIM(p0.tags),'') /*tags*/
,p1.call_id /*call_id*/
,p1.start_form /*start_form*/
,p1.forms /*forms*/
,COALESCE(TRIM(p0.system_form),'') /*system_form*/
,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_ticket_list',1,3) /*Src_Sysname*/
,'s98_s_tr_ticket_list' /*Src_Table*/
FROM p10_sa.s98_s_tr_ticket_list p0
LEFT JOIN :SADB.s98_s_tr_ticket_detail p1
ON p1.id=p0.id
;
/*将不同数据插入到临时表 */
;INSERT INTO t01_ccc_work_ticket_info_agi_INS (
workflow_id /*模板 ID*/
,workflow_name /*模板名称*/
,workflow_category_id /*模板类别id*/
,workflow_category_name /*模板类别名称*/
,type /*工单类型*/
,topic /*工单主题*/
,level /*工单优先级*/
,status /*工单状态*/
,state /*自定义状态数组*/
,creator_name /*创建人名称*/
,creator_id /*创建人 ID*/
,creator_type /**/
,modifier_id /*修改人 ID*/
,modifier_name /*修改人名称*/
,modifier_type /**/
,focus /*关注人数组集合*/
,source /*来源*/
,timeout /*是否超时*/
,end_time /*结束时间*/
,create_time /*创建时间*/
,update_time /*更新时间*/
,close_time /*关闭时间*/
,operation_logs /*工单操作日志 */
,operation_logs_new /*工单操作日志v2*/
,comments /*评论人数组 */
,state_selected /*当前工单状态*/
,last_reminder_time /*最近催单时间*/
,reminder_count /*催单次数*/
,customer_id /*客户 ID*/
,customer_name /*客户名称*/
,customer_tel /*客户号码*/
,customer_email /*客户邮箱*/
,customer_address /*客户地址*/
,customer_creator_id /*客户资料创建人 ID*/
,customer_creator_name /*客户资料创建人名称*/
,customer_modifier_id /*客户资料修改人*/
,customer_modifier_name /*客户资料修改人姓名*/
,tags /*工单标签*/
,call_id /*通话记录唯一标识*/
,start_form /*起始表单*/
,forms /*历史表单*/
,system_form /*工单属性表单*/
,id /*工单 ID*/
,Etl_Batch_No /*作业批次号*/
,Etl_First_Dt /*最初入库时间*/
,Etl_Job /*作业名称*/
,Etl_Proc_Dt /*本次入库时间*/
,Etl_Tx_Dt /*作业运行时间*/
,Src_Sysname /*来源系统*/
,Src_Table /*来源表*/
)
SELECT
P1.workflow_id /*模板 ID*/
,P1.workflow_name /*模板名称*/
,P1.workflow_category_id /*模板类别id*/
,P1.workflow_category_name /*模板类别名称*/
,P1.type /*工单类型*/
,P1.topic /*工单主题*/
,P1.level /*工单优先级*/
,P1.status /*工单状态*/
,P1.state /*自定义状态数组*/
,P1.creator_name /*创建人名称*/
,P1.creator_id /*创建人 ID*/
,P1.creator_type /**/
,P1.modifier_id /*修改人 ID*/
,P1.modifier_name /*修改人名称*/
,P1.modifier_type /**/
,P1.focus /*关注人数组集合*/
,P1.source /*来源*/
,P1.timeout /*是否超时*/
,P1.end_time /*结束时间*/
,P1.create_time /*创建时间*/
,P1.update_time /*更新时间*/
,P1.close_time /*关闭时间*/
,P1.operation_logs /*工单操作日志 */
,P1.operation_logs_new /*工单操作日志v2*/
,P1.comments /*评论人数组 */
,P1.state_selected /*当前工单状态*/
,P1.last_reminder_time /*最近催单时间*/
,P1.reminder_count /*催单次数*/
,P1.customer_id /*客户 ID*/
,P1.customer_name /*客户名称*/
,P1.customer_tel /*客户号码*/
,P1.customer_email /*客户邮箱*/
,P1.customer_address /*客户地址*/
,P1.customer_creator_id /*客户资料创建人 ID*/
,P1.customer_creator_name /*客户资料创建人名称*/
,P1.customer_modifier_id /*客户资料修改人*/
,P1.customer_modifier_name /*客户资料修改人姓名*/
,P1.tags /*工单标签*/
,P1.call_id /*通话记录唯一标识*/
,P1.start_form /*起始表单*/
,P1.forms /*历史表单*/
,P1.system_form /*工单属性表单*/
,P1.id /*工单 ID*/
,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_work_ticket_info_agi_CUR_I P1
LEFT JOIN :PDMDB.t01_ccc_work_ticket_info P2
ON P1.workflow_id = P2.workflow_id
AND P1.workflow_name = P2.workflow_name
AND P1.workflow_category_id = P2.workflow_category_id
AND P1.workflow_category_name = P2.workflow_category_name
AND P1.type = P2.type
AND P1.topic = P2.topic
AND P1.level = P2.level
AND P1.status = P2.status
AND P1.state = P2.state
AND P1.creator_name = P2.creator_name
AND P1.creator_id = P2.creator_id
AND P1.creator_type = P2.creator_type
AND P1.modifier_id = P2.modifier_id
AND P1.modifier_name = P2.modifier_name
AND P1.modifier_type = P2.modifier_type
AND P1.focus = P2.focus
AND P1.source = P2.source
AND P1.timeout = P2.timeout
AND P1.end_time = P2.end_time
AND P1.create_time = P2.create_time
AND P1.update_time = P2.update_time
AND P1.close_time = P2.close_time
AND P1.operation_logs = P2.operation_logs
AND P1.operation_logs_new = P2.operation_logs_new
AND P1.comments = P2.comments
AND P1.state_selected = P2.state_selected
AND P1.last_reminder_time = P2.last_reminder_time
AND P1.reminder_count = P2.reminder_count
AND P1.customer_id = P2.customer_id
AND P1.customer_name = P2.customer_name
AND P1.customer_tel = P2.customer_tel
AND P1.customer_email = P2.customer_email
AND P1.customer_address = P2.customer_address
AND P1.customer_creator_id = P2.customer_creator_id
AND P1.customer_creator_name = P2.customer_creator_name
AND P1.customer_modifier_id = P2.customer_modifier_id
AND P1.customer_modifier_name = P2.customer_modifier_name
AND P1.tags = P2.tags
AND P1.call_id = P2.call_id
AND P1.start_form = P2.start_form
AND P1.forms = P2.forms
AND P1.system_form = P2.system_form
AND P1.id = P2.id
WHERE P2.workflow_id IS NULL
OR P2.workflow_name IS NULL
OR P2.workflow_category_id IS NULL
OR P2.workflow_category_name IS NULL
OR P2.type IS NULL
OR P2.topic IS NULL
OR P2.level IS NULL
OR P2.status IS NULL
OR P2.state IS NULL
OR P2.creator_name IS NULL
OR P2.creator_id IS NULL
OR P2.creator_type IS NULL
OR P2.modifier_id IS NULL
OR P2.modifier_name IS NULL
OR P2.modifier_type IS NULL
OR P2.focus IS NULL
OR P2.source IS NULL
OR P2.timeout IS NULL
OR P2.end_time IS NULL
OR P2.create_time IS NULL
OR P2.update_time IS NULL
OR P2.close_time IS NULL
OR P2.operation_logs IS NULL
OR P2.operation_logs_new IS NULL
OR P2.comments IS NULL
OR P2.state_selected IS NULL
OR P2.last_reminder_time IS NULL
OR P2.reminder_count IS NULL
OR P2.customer_id IS NULL
OR P2.customer_name IS NULL
OR P2.customer_tel IS NULL
OR P2.customer_email IS NULL
OR P2.customer_address IS NULL
OR P2.customer_creator_id IS NULL
OR P2.customer_creator_name IS NULL
OR P2.customer_modifier_id IS NULL
OR P2.customer_modifier_name IS NULL
OR P2.tags IS NULL
OR P2.call_id IS NULL
OR P2.start_form IS NULL
OR P2.forms IS NULL
OR P2.system_form IS NULL
OR P2.id IS NULL
;
/*将新增数据插入到目标表 */
;INSERT INTO :PDMDB.t01_ccc_work_ticket_info (
workflow_id /*模板 ID*/
,workflow_name /*模板名称*/
,workflow_category_id /*模板类别id*/
,workflow_category_name /*模板类别名称*/
,type /*工单类型*/
,topic /*工单主题*/
,level /*工单优先级*/
,status /*工单状态*/
,state /*自定义状态数组*/
,creator_name /*创建人名称*/
,creator_id /*创建人 ID*/
,creator_type /**/
,modifier_id /*修改人 ID*/
,modifier_name /*修改人名称*/
,modifier_type /**/
,focus /*关注人数组集合*/
,source /*来源*/
,timeout /*是否超时*/
,end_time /*结束时间*/
,create_time /*创建时间*/
,update_time /*更新时间*/
,close_time /*关闭时间*/
,operation_logs /*工单操作日志 */
,operation_logs_new /*工单操作日志v2*/
,comments /*评论人数组 */
,state_selected /*当前工单状态*/
,last_reminder_time /*最近催单时间*/
,reminder_count /*催单次数*/
,customer_id /*客户 ID*/
,customer_name /*客户名称*/
,customer_tel /*客户号码*/
,customer_email /*客户邮箱*/
,customer_address /*客户地址*/
,customer_creator_id /*客户资料创建人 ID*/
,customer_creator_name /*客户资料创建人名称*/
,customer_modifier_id /*客户资料修改人*/
,customer_modifier_name /*客户资料修改人姓名*/
,tags /*工单标签*/
,call_id /*通话记录唯一标识*/
,start_form /*起始表单*/
,forms /*历史表单*/
,system_form /*工单属性表单*/
,id /*工单 ID*/
,Etl_Batch_No /*作业批次号*/
,Etl_First_Dt /*最初入库时间*/
,Etl_Job /*作业名称*/
,Etl_Proc_Dt /*本次入库时间*/
,Etl_Tx_Dt /*作业运行时间*/
,Src_Sysname /*来源系统*/
,Src_Table /*来源表*/
)
SELECT
P1.workflow_id /*模板 ID*/
,P1.workflow_name /*模板名称*/
,P1.workflow_category_id /*模板类别id*/
,P1.workflow_category_name /*模板类别名称*/
,P1.type /*工单类型*/
,P1.topic /*工单主题*/
,P1.level /*工单优先级*/
,P1.status /*工单状态*/
,P1.state /*自定义状态数组*/
,P1.creator_name /*创建人名称*/
,P1.creator_id /*创建人 ID*/
,P1.creator_type /**/
,P1.modifier_id /*修改人 ID*/
,P1.modifier_name /*修改人名称*/
,P1.modifier_type /**/
,P1.focus /*关注人数组集合*/
,P1.source /*来源*/
,P1.timeout /*是否超时*/
,P1.end_time /*结束时间*/
,P1.create_time /*创建时间*/
,P1.update_time /*更新时间*/
,P1.close_time /*关闭时间*/
,P1.operation_logs /*工单操作日志 */
,P1.operation_logs_new /*工单操作日志v2*/
,P1.comments /*评论人数组 */
,P1.state_selected /*当前工单状态*/
,P1.last_reminder_time /*最近催单时间*/
,P1.reminder_count /*催单次数*/
,P1.customer_id /*客户 ID*/
,P1.customer_name /*客户名称*/
,P1.customer_tel /*客户号码*/
,P1.customer_email /*客户邮箱*/
,P1.customer_address /*客户地址*/
,P1.customer_creator_id /*客户资料创建人 ID*/
,P1.customer_creator_name /*客户资料创建人名称*/
,P1.customer_modifier_id /*客户资料修改人*/
,P1.customer_modifier_name /*客户资料修改人姓名*/
,P1.tags /*工单标签*/
,P1.call_id /*通话记录唯一标识*/
,P1.start_form /*起始表单*/
,P1.forms /*历史表单*/
,P1.system_form /*工单属性表单*/
,P1.id /*工单 ID*/
,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_work_ticket_info_agi_INS P1
ON CONFLICT ( id)
DO UPDATE SET
id=excluded.id
,workflow_id=excluded.workflow_id
,workflow_name=excluded.workflow_name
,workflow_category_id=excluded.workflow_category_id
,workflow_category_name=excluded.workflow_category_name
,type=excluded.type
,topic=excluded.topic
,level=excluded.level
,status=excluded.status
,state=excluded.state
,creator_name=excluded.creator_name
,creator_id=excluded.creator_id
,creator_type=excluded.creator_type
,modifier_id=excluded.modifier_id
,modifier_name=excluded.modifier_name
,modifier_type=excluded.modifier_type
,focus=excluded.focus
,source=excluded.source
,timeout=excluded.timeout
,end_time=excluded.end_time
,create_time=excluded.create_time
,update_time=excluded.update_time
,close_time=excluded.close_time
,operation_logs=excluded.operation_logs
,operation_logs_new=excluded.operation_logs_new
,comments=excluded.comments
,state_selected=excluded.state_selected
,last_reminder_time=excluded.last_reminder_time
,reminder_count=excluded.reminder_count
,customer_id=excluded.customer_id
,customer_name=excluded.customer_name
,customer_tel=excluded.customer_tel
,customer_email=excluded.customer_email
,customer_address=excluded.customer_address
,customer_creator_id=excluded.customer_creator_id
,customer_creator_name=excluded.customer_creator_name
,customer_modifier_id=excluded.customer_modifier_id
,customer_modifier_name=excluded.customer_modifier_name
,tags=excluded.tags
,call_id=excluded.call_id
,start_form=excluded.start_form
,forms=excluded.forms
,system_form=excluded.system_form
,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
;
/*****程序结束退出 */
\q

110
dev/workflow/TK_Cust/smart_ccc_ticket/smartccc工单信息集成/f_ccc_work_ticket_integ.sql Normal file
View File

@ -0,0 +1,110 @@
DROP TABLE IF EXISTS p30_common.f_ccc_work_ticket_integ;
CREATE TABLE IF NOT EXISTS p30_common.f_ccc_work_ticket_integ (
PEXTENSION_CODE varchar(20)
, PEXTENSION varchar(20)
, LAST_NAME varchar(20)
, SUFFIX varchar(20)
, COMPANY_NAME varchar(50)
, JOB_TITLE varchar(20)
, CITY varchar(20)
, STATE_COUNTY_LOCATION varchar(20)
, COUNTRY_CODE varchar(20)
, POSTAL_CODE varchar(20)
, CONTACT_MOBILE_NUMBER varchar(20)
, EMAIL_ADDRESS varchar(50)
, REQUEST_A_DEMO varchar(10)
, REQUEST_A_QUOTE varchar(10)
, HAMCAM varchar(10)
, PURCHASE_INTENT varchar(10)
, COMMENTS text
, INDUSTRY varchar(20)
, CCP_PRODUCT_INTEREST_01 varchar(20)
, CCP_APP_01_5 varchar(20)
, LEAD_PRODUCTS_01_5 varchar(20)
, PERMISSION_PHONE varchar(10)
, PERMISSION_PHONE_DATE timestamp(0)
, PERMISSION_EMAIL varchar(10)
, PERMISSION_EMAIL_DATE timestamp(0)
, PERMISSION_MAIL varchar(10)
, PERMISSION_MAIL_DATE timestamp(0)
, PERMISSION_SMS varchar(10)
, PERMISSION_SMS_DATE timestamp(0)
, AGREES_TO_PRIVACY_POLICY varchar(10)
, PORTAL_TERMS_AGREEMENT_DATE timestamp(0)
, CONSENT_TO_COLLECT_PERSONAL_INFO varchar(10)
, CONSENT_TO_COLLECT_PERSONAL_INFO_DATE timestamp(0)
, MARKETING_CONSENT varchar(10)
, MARKETING_CONSENT_DATE timestamp(0)
, MEANS_OF_CONSENT varchar(10)
, SOURCE_OF_CONSENT varchar(10)
, VERSION_OF_PRIVACY_NOTICE varchar(10)
, RECORD_OF_CONSENT varchar(10)
, EXACT_CONSENT_LANGUAGE varchar(10)
, BRAND_TEKTRONIX varchar(10)
, BRAND_SSO varchar(10)
, BRAND_KEITHLEY varchar(10)
, EMAIL_PREFERENCE varchar(10)
, Src_Sysname varchar(50)
, Etl_Job varchar(200)
, Src_Table varchar(50)
, Etl_Tx_Dt timestamp(0)
, Etl_First_Dt timestamp(0)
, Etl_Proc_Dt timestamp(0)
, Etl_Batch_No varchar(50)
,primary key( SUFFIX )
);
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.PEXTENSION_CODE IS '来源代码';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.PEXTENSION IS '来源';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.LAST_NAME IS '姓名';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.SUFFIX IS '工单ID';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.COMPANY_NAME IS '公司名称';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.JOB_TITLE IS '职位';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.CITY IS '城市';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.STATE_COUNTY_LOCATION IS '省份';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.COUNTRY_CODE IS '国家';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.POSTAL_CODE IS '邮编';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.CONTACT_MOBILE_NUMBER IS '电话';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.EMAIL_ADDRESS IS '邮箱';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.REQUEST_A_DEMO IS 'demo标志';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.REQUEST_A_QUOTE IS '引用标志';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.HAMCAM IS '账户管理员标志';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.PURCHASE_INTENT IS '购买意向';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.COMMENTS IS '备注';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.INDUSTRY IS '行业';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.CCP_PRODUCT_INTEREST_01 IS '产品偏好';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.CCP_APP_01_5 IS '应用';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.LEAD_PRODUCTS_01_5 IS '产品型号';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.PERMISSION_PHONE IS '电话授权标志';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.PERMISSION_PHONE_DATE IS '电话授权时间';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.PERMISSION_EMAIL IS '电子邮件授权标志';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.PERMISSION_EMAIL_DATE IS '电子邮件授权时间';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.PERMISSION_MAIL IS '邮件授权标志';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.PERMISSION_MAIL_DATE IS '邮件授权时间';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.PERMISSION_SMS IS 'SMS授权标志';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.PERMISSION_SMS_DATE IS 'SMS授权时间';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.AGREES_TO_PRIVACY_POLICY IS '个人信息授权标志';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.PORTAL_TERMS_AGREEMENT_DATE IS '协议授权时间';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.CONSENT_TO_COLLECT_PERSONAL_INFO IS '个人信息收集标志';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.CONSENT_TO_COLLECT_PERSONAL_INFO_DATE IS '个人信息收集时间';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.MARKETING_CONSENT IS 'MARKETING_CONSENT';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.MARKETING_CONSENT_DATE IS 'MARKETING_CONSENT_DATE';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.MEANS_OF_CONSENT IS 'MEANS_OF_CONSENT';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.SOURCE_OF_CONSENT IS 'SOURCE_OF_CONSENT';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.VERSION_OF_PRIVACY_NOTICE IS 'VERSION_OF_PRIVACY_NOTICE';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.RECORD_OF_CONSENT IS 'RECORD_OF_CONSENT';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.EXACT_CONSENT_LANGUAGE IS 'EXACT_CONSENT_LANGUAGE';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.BRAND_TEKTRONIX IS 'BRAND_TEKTRONIX';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.BRAND_SSO IS 'BRAND_SSO';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.BRAND_KEITHLEY IS 'BRAND_KEITHLEY';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.EMAIL_PREFERENCE IS 'EMAIL_PREFERENCE';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.Src_Sysname IS '来源系统';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.Etl_Job IS '作业名称';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.Src_Table IS '来源表';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.Etl_Tx_Dt IS '作业运行时间';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.Etl_First_Dt IS '最初入库时间';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.Etl_Proc_Dt IS '本次入库时间';
COMMENT ON COLUMN p30_common.f_ccc_work_ticket_integ.Etl_Batch_No IS '作业批次号';
COMMENT ON TABLE p30_common.f_ccc_work_ticket_integ IS 'smartccc工单信息集成';

562
dev/workflow/TK_Cust/smart_ccc_ticket/smartccc工单信息集成/f_ccc_work_ticket_integ_agi.sql Normal file
View File

@ -0,0 +1,562 @@
/***************************************************************************************************/
/*script in Sql, generate by SdmCreateScript 2020(by Qihang Feng, QF255001@TERADATA.COM) */
/*VERSION 01.10 revised on 2020-08-25 */
/*Brilliance stems from wisdoms. */
/*************Head Section**************************************************************************/
/*Script Use: Periodically load data to :f_ccc_work_ticket_integ(smartccc工单信息集成) */
/*Create Date:2024-07-09 15:13:26 */
/*SDM Developed By: dev */
/*SDM Developed Date: 2024-07-09 */
/*SDM Checked By: dev */
/*SDM Checked Date: 2024-07-09 */
/*Script Developed By: dev */
/*Script Checked By: dev */
/*Source table 1: :PDMDB.t01_ccc_cust_info */
/*Source table 2: :PDMDB.t00_china_city_info */
/*Source table 3: :PDMDB.t01_ccc_work_ticket_info */
/*Job Type: Inbound transform (Tier 1 to Tier 2) */
/*Target Table:f_ccc_work_ticket_integ */
/*ETL Job Name:f_ccc_work_ticket_integ */
/*ETL Frequency:Daily */
/*ETL Policy:F2 */
/********************************************************************************************/
/*******Main Section**************************************************************************/
\set ON_ERROR_STOP on
\set AUTOCOMMIT on
\timing on
/*创建临时表加载当前数据 */
CREATE TEMPORARY TABLE f_ccc_work_ticket_integ_agi_CUR_I
( LIKE :COMMDB.f_ccc_work_ticket_integ)
ON COMMIT PRESERVE ROWS;
/*创建临时表加载不同数据 */
CREATE TEMPORARY TABLE f_ccc_work_ticket_integ_agi_INS
( LIKE :COMMDB.f_ccc_work_ticket_integ)
ON COMMIT PRESERVE ROWS;
/*****************************************************************************************************/
/* GROUP 1:Source Table:t01_ccc_work_ticket_info******************************************************/
/*****************************************************************************************************/
INSERT INTO f_ccc_work_ticket_integ_agi_CUR_I (
PEXTENSION_CODE /*来源代码*/
,PEXTENSION /*来源*/
,LAST_NAME /*姓名*/
,SUFFIX /*工单ID*/
,COMPANY_NAME /*公司名称*/
,JOB_TITLE /*职位*/
,CITY /*城市*/
,STATE_COUNTY_LOCATION /*省份*/
,COUNTRY_CODE /*国家*/
,POSTAL_CODE /*邮编*/
,CONTACT_MOBILE_NUMBER /*电话*/
,EMAIL_ADDRESS /*邮箱*/
,REQUEST_A_DEMO /*demo标志*/
,REQUEST_A_QUOTE /*引用标志*/
,HAMCAM /*账户管理员标志*/
,PURCHASE_INTENT /*购买意向*/
,COMMENTS /*备注*/
,INDUSTRY /*行业*/
,CCP_PRODUCT_INTEREST_01 /*产品偏好*/
,CCP_APP_01_5 /*应用*/
,LEAD_PRODUCTS_01_5 /*产品型号*/
,PERMISSION_PHONE /*电话授权标志*/
,PERMISSION_PHONE_DATE /*电话授权时间*/
,PERMISSION_EMAIL /*电子邮件授权标志*/
,PERMISSION_EMAIL_DATE /*电子邮件授权时间*/
,PERMISSION_MAIL /*邮件授权标志*/
,PERMISSION_MAIL_DATE /*邮件授权时间*/
,PERMISSION_SMS /*SMS授权标志*/
,PERMISSION_SMS_DATE /*SMS授权时间*/
,AGREES_TO_PRIVACY_POLICY /*个人信息授权标志*/
,PORTAL_TERMS_AGREEMENT_DATE /*协议授权时间*/
,CONSENT_TO_COLLECT_PERSONAL_INFO /*个人信息收集标志*/
,CONSENT_TO_COLLECT_PERSONAL_INFO_DATE /*个人信息收集时间*/
,MARKETING_CONSENT /*MARKETING_CONSENT*/
,MARKETING_CONSENT_DATE /*MARKETING_CONSENT_DATE*/
,MEANS_OF_CONSENT /*MEANS_OF_CONSENT*/
,SOURCE_OF_CONSENT /*SOURCE_OF_CONSENT*/
,VERSION_OF_PRIVACY_NOTICE /*VERSION_OF_PRIVACY_NOTICE*/
,RECORD_OF_CONSENT /*RECORD_OF_CONSENT*/
,EXACT_CONSENT_LANGUAGE /*EXACT_CONSENT_LANGUAGE*/
,BRAND_TEKTRONIX /*BRAND_TEKTRONIX*/
,BRAND_SSO /*BRAND_SSO*/
,BRAND_KEITHLEY /*BRAND_KEITHLEY*/
,EMAIL_PREFERENCE /*EMAIL_PREFERENCE*/
,Src_Sysname /*来源系统*/
,Etl_Job /*作业名称*/
,Src_Table /*来源表*/
,Etl_Tx_Dt /*作业运行时间*/
,Etl_First_Dt /*最初入库时间*/
,Etl_Proc_Dt /*本次入库时间*/
,Etl_Batch_No /*作业批次号*/
)
SELECT
case when p1."source" ='在线咨询' then '401890X401890'
when p1."source" ='接口创建' then '445769X445769'
when p1."source" ='呼叫中心' then '305972X317938'
else '401890X401890' end /*PEXTENSION_CODE*/
,p1."source" /*PEXTENSION*/
,(SELECT jsonb_extract_path_text(j, 'value')
FROM jsonb_array_elements(p1.customize::jsonb) j
WHERE jsonb_extract_path_text(j, 'name') = '姓名') /*LAST_NAME*/
,p0.id /*SUFFIX*/
,(SELECT jsonb_extract_path_text(j, 'value')
FROM jsonb_array_elements(p1.customize::jsonb) j
WHERE jsonb_extract_path_text(j, 'name') = '公司名称') /*COMPANY_NAME*/
,(SELECT jsonb_extract_path_text(j, 'value')
FROM jsonb_array_elements(p1.customize::jsonb) j
WHERE jsonb_extract_path_text(j, 'name') = '职位') /*JOB_TITLE*/
,(SELECT jsonb_extract_path_text(j, 'value')
FROM jsonb_array_elements(p1.customize::jsonb) j
WHERE jsonb_extract_path_text(j, 'name') = '城市') /*CITY*/
,p2.prov_name /*STATE_COUNTY_LOCATION*/
,'CN' /*COUNTRY_CODE*/
,p2.postalcode /*POSTAL_CODE*/
,replace(replace(replace(split_part(p1.tel,',',1),'"',''),'[',''),']','') /*CONTACT_MOBILE_NUMBER*/
,p1.email /*EMAIL_ADDRESS*/
,'YES' /*REQUEST_A_DEMO*/
,'YES' /*REQUEST_A_QUOTE*/
,'YES' /*HAMCAM*/
,4 /*PURCHASE_INTENT*/
,'L - mql '||(SELECT jsonb_extract_path_text(field, 'value') AS value_298245
FROM (
SELECT jsonb_array_elements(p0.start_form::jsonb->'fields') AS field
) AS t
WHERE jsonb_extract_path_text(field, 'id')::int = 298246) /*COMMENTS*/
,(SELECT jsonb_extract_path_text(field, 'value') AS value_297729
FROM (
SELECT jsonb_array_elements(p0.start_form::jsonb->'fields') AS field
) AS t
WHERE jsonb_extract_path_text(field, 'id')::int = 297729) /*INDUSTRY*/
,(SELECT jsonb_extract_path_text(field, 'value') AS value_298247
FROM (
SELECT jsonb_array_elements(p0.start_form::jsonb->'fields') AS field
) AS t
WHERE jsonb_extract_path_text(field, 'id')::int = 298247) /*CCP_PRODUCT_INTEREST_01*/
,(SELECT jsonb_extract_path_text(field, 'value') AS value_297730
FROM (
SELECT jsonb_array_elements(p0.start_form::jsonb->'fields') AS field
) AS t
WHERE jsonb_extract_path_text(field, 'id')::int = 297730) /*CCP_APP_01_5*/
,(SELECT jsonb_extract_path_text(field, 'value') AS value_298300
FROM (
SELECT jsonb_array_elements(p0.start_form::jsonb->'fields') AS field
) AS t
WHERE jsonb_extract_path_text(field, 'id')::int = 298300) /*LEAD_PRODUCTS_01_5*/
,'YES' /*PERMISSION_PHONE*/
,p0.create_time /*PERMISSION_PHONE_DATE*/
,'YES' /*PERMISSION_EMAIL*/
,p0.create_time /*PERMISSION_EMAIL_DATE*/
,'YES' /*PERMISSION_MAIL*/
,p0.create_time /*PERMISSION_MAIL_DATE*/
,'YES' /*PERMISSION_SMS*/
,p0.create_time /*PERMISSION_SMS_DATE*/
,'YES' /*AGREES_TO_PRIVACY_POLICY*/
,p0.create_time /*PORTAL_TERMS_AGREEMENT_DATE*/
,'YES' /*CONSENT_TO_COLLECT_PERSONAL_INFO*/
,p0.create_time /*CONSENT_TO_COLLECT_PERSONAL_INFO_DATE*/
,'' /*MARKETING_CONSENT*/
,TO_TIMESTAMP(:NULLDATE,'YYYYMMDD') /*MARKETING_CONSENT_DATE*/
,'' /*MEANS_OF_CONSENT*/
,'' /*SOURCE_OF_CONSENT*/
,'' /*VERSION_OF_PRIVACY_NOTICE*/
,'' /*RECORD_OF_CONSENT*/
,'' /*EXACT_CONSENT_LANGUAGE*/
,'' /*BRAND_TEKTRONIX*/
,'' /*BRAND_SSO*/
,'' /*BRAND_KEITHLEY*/
,'' /*EMAIL_PREFERENCE*/
,Substr('t01_ccc_work_ticket_info',1,3) /*Src_Sysname*/
,:ETLJOB /*Etl_Job*/
,'t01_ccc_work_ticket_info' /*Src_Table*/
,TO_DATE(:TXDATE,'YYYYMMDD') /*Etl_Tx_Dt*/
,TO_DATE(:TXDATE,'YYYYMMDD') /*Etl_First_Dt*/
,current_timestamp(0) /*Etl_Proc_Dt*/
,0 /*Etl_Batch_No*/
FROM :PDMDB.t01_ccc_work_ticket_info p0
LEFT JOIN :PDMDB.t01_ccc_cust_info p1
ON p0.customer_id =p1.id
LEFT JOIN :PDMDB.t00_china_city_info p2
ON (SELECT jsonb_extract_path_text(j, 'value')
FROM jsonb_array_elements(p1.customize::jsonb) j
WHERE jsonb_extract_path_text(j, 'name') = '城市') = p2.city_name
;
/*将不同数据插入到临时表 */
;INSERT INTO f_ccc_work_ticket_integ_agi_INS (
PEXTENSION_CODE /*来源代码*/
,PEXTENSION /*来源*/
,LAST_NAME /*姓名*/
,COMPANY_NAME /*公司名称*/
,JOB_TITLE /*职位*/
,CITY /*城市*/
,STATE_COUNTY_LOCATION /*省份*/
,COUNTRY_CODE /*国家*/
,POSTAL_CODE /*邮编*/
,CONTACT_MOBILE_NUMBER /*电话*/
,EMAIL_ADDRESS /*邮箱*/
,REQUEST_A_DEMO /*demo标志*/
,REQUEST_A_QUOTE /*引用标志*/
,HAMCAM /*账户管理员标志*/
,PURCHASE_INTENT /*购买意向*/
,COMMENTS /*备注*/
,INDUSTRY /*行业*/
,CCP_PRODUCT_INTEREST_01 /*产品偏好*/
,CCP_APP_01_5 /*应用*/
,LEAD_PRODUCTS_01_5 /*产品型号*/
,PERMISSION_PHONE /*电话授权标志*/
,PERMISSION_PHONE_DATE /*电话授权时间*/
,PERMISSION_EMAIL /*电子邮件授权标志*/
,PERMISSION_EMAIL_DATE /*电子邮件授权时间*/
,PERMISSION_MAIL /*邮件授权标志*/
,PERMISSION_MAIL_DATE /*邮件授权时间*/
,PERMISSION_SMS /*SMS授权标志*/
,PERMISSION_SMS_DATE /*SMS授权时间*/
,AGREES_TO_PRIVACY_POLICY /*个人信息授权标志*/
,PORTAL_TERMS_AGREEMENT_DATE /*协议授权时间*/
,CONSENT_TO_COLLECT_PERSONAL_INFO /*个人信息收集标志*/
,CONSENT_TO_COLLECT_PERSONAL_INFO_DATE /*个人信息收集时间*/
,MARKETING_CONSENT /*MARKETING_CONSENT*/
,MARKETING_CONSENT_DATE /*MARKETING_CONSENT_DATE*/
,MEANS_OF_CONSENT /*MEANS_OF_CONSENT*/
,SOURCE_OF_CONSENT /*SOURCE_OF_CONSENT*/
,VERSION_OF_PRIVACY_NOTICE /*VERSION_OF_PRIVACY_NOTICE*/
,RECORD_OF_CONSENT /*RECORD_OF_CONSENT*/
,EXACT_CONSENT_LANGUAGE /*EXACT_CONSENT_LANGUAGE*/
,BRAND_TEKTRONIX /*BRAND_TEKTRONIX*/
,BRAND_SSO /*BRAND_SSO*/
,BRAND_KEITHLEY /*BRAND_KEITHLEY*/
,EMAIL_PREFERENCE /*EMAIL_PREFERENCE*/
,SUFFIX /*工单ID*/
,Src_Sysname /*来源系统*/
,Etl_Job /*作业名称*/
,Src_Table /*来源表*/
,Etl_Tx_Dt /*作业运行时间*/
,Etl_First_Dt /*最初入库时间*/
,Etl_Proc_Dt /*本次入库时间*/
,Etl_Batch_No /*作业批次号*/
)
SELECT
P1.PEXTENSION_CODE /*来源代码*/
,P1.PEXTENSION /*来源*/
,P1.LAST_NAME /*姓名*/
,P1.COMPANY_NAME /*公司名称*/
,P1.JOB_TITLE /*职位*/
,P1.CITY /*城市*/
,P1.STATE_COUNTY_LOCATION /*省份*/
,P1.COUNTRY_CODE /*国家*/
,P1.POSTAL_CODE /*邮编*/
,P1.CONTACT_MOBILE_NUMBER /*电话*/
,P1.EMAIL_ADDRESS /*邮箱*/
,P1.REQUEST_A_DEMO /*demo标志*/
,P1.REQUEST_A_QUOTE /*引用标志*/
,P1.HAMCAM /*账户管理员标志*/
,P1.PURCHASE_INTENT /*购买意向*/
,P1.COMMENTS /*备注*/
,P1.INDUSTRY /*行业*/
,P1.CCP_PRODUCT_INTEREST_01 /*产品偏好*/
,P1.CCP_APP_01_5 /*应用*/
,P1.LEAD_PRODUCTS_01_5 /*产品型号*/
,P1.PERMISSION_PHONE /*电话授权标志*/
,P1.PERMISSION_PHONE_DATE /*电话授权时间*/
,P1.PERMISSION_EMAIL /*电子邮件授权标志*/
,P1.PERMISSION_EMAIL_DATE /*电子邮件授权时间*/
,P1.PERMISSION_MAIL /*邮件授权标志*/
,P1.PERMISSION_MAIL_DATE /*邮件授权时间*/
,P1.PERMISSION_SMS /*SMS授权标志*/
,P1.PERMISSION_SMS_DATE /*SMS授权时间*/
,P1.AGREES_TO_PRIVACY_POLICY /*个人信息授权标志*/
,P1.PORTAL_TERMS_AGREEMENT_DATE /*协议授权时间*/
,P1.CONSENT_TO_COLLECT_PERSONAL_INFO /*个人信息收集标志*/
,P1.CONSENT_TO_COLLECT_PERSONAL_INFO_DATE /*个人信息收集时间*/
,P1.MARKETING_CONSENT /*MARKETING_CONSENT*/
,P1.MARKETING_CONSENT_DATE /*MARKETING_CONSENT_DATE*/
,P1.MEANS_OF_CONSENT /*MEANS_OF_CONSENT*/
,P1.SOURCE_OF_CONSENT /*SOURCE_OF_CONSENT*/
,P1.VERSION_OF_PRIVACY_NOTICE /*VERSION_OF_PRIVACY_NOTICE*/
,P1.RECORD_OF_CONSENT /*RECORD_OF_CONSENT*/
,P1.EXACT_CONSENT_LANGUAGE /*EXACT_CONSENT_LANGUAGE*/
,P1.BRAND_TEKTRONIX /*BRAND_TEKTRONIX*/
,P1.BRAND_SSO /*BRAND_SSO*/
,P1.BRAND_KEITHLEY /*BRAND_KEITHLEY*/
,P1.EMAIL_PREFERENCE /*EMAIL_PREFERENCE*/
,P1.SUFFIX /*工单ID*/
,P1.Src_Sysname /*来源系统*/
,P1.Etl_Job /*作业名称*/
,P1.Src_Table /*来源表*/
,P1.Etl_Tx_Dt /*作业运行时间*/
,P1.Etl_First_Dt /*最初入库时间*/
,P1.Etl_Proc_Dt /*本次入库时间*/
,P1.Etl_Batch_No /*作业批次号*/
FROM f_ccc_work_ticket_integ_agi_CUR_I P1
LEFT JOIN :COMMDB.f_ccc_work_ticket_integ P2
ON P1.PEXTENSION_CODE = P2.PEXTENSION_CODE
AND P1.PEXTENSION = P2.PEXTENSION
AND P1.LAST_NAME = P2.LAST_NAME
AND P1.COMPANY_NAME = P2.COMPANY_NAME
AND P1.JOB_TITLE = P2.JOB_TITLE
AND P1.CITY = P2.CITY
AND P1.STATE_COUNTY_LOCATION = P2.STATE_COUNTY_LOCATION
AND P1.COUNTRY_CODE = P2.COUNTRY_CODE
AND P1.POSTAL_CODE = P2.POSTAL_CODE
AND P1.CONTACT_MOBILE_NUMBER = P2.CONTACT_MOBILE_NUMBER
AND P1.EMAIL_ADDRESS = P2.EMAIL_ADDRESS
AND P1.REQUEST_A_DEMO = P2.REQUEST_A_DEMO
AND P1.REQUEST_A_QUOTE = P2.REQUEST_A_QUOTE
AND P1.HAMCAM = P2.HAMCAM
AND P1.PURCHASE_INTENT = P2.PURCHASE_INTENT
AND P1.COMMENTS = P2.COMMENTS
AND P1.INDUSTRY = P2.INDUSTRY
AND P1.CCP_PRODUCT_INTEREST_01 = P2.CCP_PRODUCT_INTEREST_01
AND P1.CCP_APP_01_5 = P2.CCP_APP_01_5
AND P1.LEAD_PRODUCTS_01_5 = P2.LEAD_PRODUCTS_01_5
AND P1.PERMISSION_PHONE = P2.PERMISSION_PHONE
AND P1.PERMISSION_PHONE_DATE = P2.PERMISSION_PHONE_DATE
AND P1.PERMISSION_EMAIL = P2.PERMISSION_EMAIL
AND P1.PERMISSION_EMAIL_DATE = P2.PERMISSION_EMAIL_DATE
AND P1.PERMISSION_MAIL = P2.PERMISSION_MAIL
AND P1.PERMISSION_MAIL_DATE = P2.PERMISSION_MAIL_DATE
AND P1.PERMISSION_SMS = P2.PERMISSION_SMS
AND P1.PERMISSION_SMS_DATE = P2.PERMISSION_SMS_DATE
AND P1.AGREES_TO_PRIVACY_POLICY = P2.AGREES_TO_PRIVACY_POLICY
AND P1.PORTAL_TERMS_AGREEMENT_DATE = P2.PORTAL_TERMS_AGREEMENT_DATE
AND P1.CONSENT_TO_COLLECT_PERSONAL_INFO = P2.CONSENT_TO_COLLECT_PERSONAL_INFO
AND P1.CONSENT_TO_COLLECT_PERSONAL_INFO_DATE = P2.CONSENT_TO_COLLECT_PERSONAL_INFO_DATE
AND P1.MARKETING_CONSENT = P2.MARKETING_CONSENT
AND P1.MARKETING_CONSENT_DATE = P2.MARKETING_CONSENT_DATE
AND P1.MEANS_OF_CONSENT = P2.MEANS_OF_CONSENT
AND P1.SOURCE_OF_CONSENT = P2.SOURCE_OF_CONSENT
AND P1.VERSION_OF_PRIVACY_NOTICE = P2.VERSION_OF_PRIVACY_NOTICE
AND P1.RECORD_OF_CONSENT = P2.RECORD_OF_CONSENT
AND P1.EXACT_CONSENT_LANGUAGE = P2.EXACT_CONSENT_LANGUAGE
AND P1.BRAND_TEKTRONIX = P2.BRAND_TEKTRONIX
AND P1.BRAND_SSO = P2.BRAND_SSO
AND P1.BRAND_KEITHLEY = P2.BRAND_KEITHLEY
AND P1.EMAIL_PREFERENCE = P2.EMAIL_PREFERENCE
AND P1.SUFFIX = P2.SUFFIX
WHERE P2.PEXTENSION_CODE IS NULL
OR P2.PEXTENSION IS NULL
OR P2.LAST_NAME IS NULL
OR P2.COMPANY_NAME IS NULL
OR P2.JOB_TITLE IS NULL
OR P2.CITY IS NULL
OR P2.STATE_COUNTY_LOCATION IS NULL
OR P2.COUNTRY_CODE IS NULL
OR P2.POSTAL_CODE IS NULL
OR P2.CONTACT_MOBILE_NUMBER IS NULL
OR P2.EMAIL_ADDRESS IS NULL
OR P2.REQUEST_A_DEMO IS NULL
OR P2.REQUEST_A_QUOTE IS NULL
OR P2.HAMCAM IS NULL
OR P2.PURCHASE_INTENT IS NULL
OR P2.COMMENTS IS NULL
OR P2.INDUSTRY IS NULL
OR P2.CCP_PRODUCT_INTEREST_01 IS NULL
OR P2.CCP_APP_01_5 IS NULL
OR P2.LEAD_PRODUCTS_01_5 IS NULL
OR P2.PERMISSION_PHONE IS NULL
OR P2.PERMISSION_PHONE_DATE IS NULL
OR P2.PERMISSION_EMAIL IS NULL
OR P2.PERMISSION_EMAIL_DATE IS NULL
OR P2.PERMISSION_MAIL IS NULL
OR P2.PERMISSION_MAIL_DATE IS NULL
OR P2.PERMISSION_SMS IS NULL
OR P2.PERMISSION_SMS_DATE IS NULL
OR P2.AGREES_TO_PRIVACY_POLICY IS NULL
OR P2.PORTAL_TERMS_AGREEMENT_DATE IS NULL
OR P2.CONSENT_TO_COLLECT_PERSONAL_INFO IS NULL
OR P2.CONSENT_TO_COLLECT_PERSONAL_INFO_DATE IS NULL
OR P2.MARKETING_CONSENT IS NULL
OR P2.MARKETING_CONSENT_DATE IS NULL
OR P2.MEANS_OF_CONSENT IS NULL
OR P2.SOURCE_OF_CONSENT IS NULL
OR P2.VERSION_OF_PRIVACY_NOTICE IS NULL
OR P2.RECORD_OF_CONSENT IS NULL
OR P2.EXACT_CONSENT_LANGUAGE IS NULL
OR P2.BRAND_TEKTRONIX IS NULL
OR P2.BRAND_SSO IS NULL
OR P2.BRAND_KEITHLEY IS NULL
OR P2.EMAIL_PREFERENCE IS NULL
OR P2.SUFFIX IS NULL
;
/*将新增数据插入到目标表 */
;INSERT INTO :COMMDB.f_ccc_work_ticket_integ (
PEXTENSION_CODE /*来源代码*/
,PEXTENSION /*来源*/
,LAST_NAME /*姓名*/
,COMPANY_NAME /*公司名称*/
,JOB_TITLE /*职位*/
,CITY /*城市*/
,STATE_COUNTY_LOCATION /*省份*/
,COUNTRY_CODE /*国家*/
,POSTAL_CODE /*邮编*/
,CONTACT_MOBILE_NUMBER /*电话*/
,EMAIL_ADDRESS /*邮箱*/
,REQUEST_A_DEMO /*demo标志*/
,REQUEST_A_QUOTE /*引用标志*/
,HAMCAM /*账户管理员标志*/
,PURCHASE_INTENT /*购买意向*/
,COMMENTS /*备注*/
,INDUSTRY /*行业*/
,CCP_PRODUCT_INTEREST_01 /*产品偏好*/
,CCP_APP_01_5 /*应用*/
,LEAD_PRODUCTS_01_5 /*产品型号*/
,PERMISSION_PHONE /*电话授权标志*/
,PERMISSION_PHONE_DATE /*电话授权时间*/
,PERMISSION_EMAIL /*电子邮件授权标志*/
,PERMISSION_EMAIL_DATE /*电子邮件授权时间*/
,PERMISSION_MAIL /*邮件授权标志*/
,PERMISSION_MAIL_DATE /*邮件授权时间*/
,PERMISSION_SMS /*SMS授权标志*/
,PERMISSION_SMS_DATE /*SMS授权时间*/
,AGREES_TO_PRIVACY_POLICY /*个人信息授权标志*/
,PORTAL_TERMS_AGREEMENT_DATE /*协议授权时间*/
,CONSENT_TO_COLLECT_PERSONAL_INFO /*个人信息收集标志*/
,CONSENT_TO_COLLECT_PERSONAL_INFO_DATE /*个人信息收集时间*/
,MARKETING_CONSENT /*MARKETING_CONSENT*/
,MARKETING_CONSENT_DATE /*MARKETING_CONSENT_DATE*/
,MEANS_OF_CONSENT /*MEANS_OF_CONSENT*/
,SOURCE_OF_CONSENT /*SOURCE_OF_CONSENT*/
,VERSION_OF_PRIVACY_NOTICE /*VERSION_OF_PRIVACY_NOTICE*/
,RECORD_OF_CONSENT /*RECORD_OF_CONSENT*/
,EXACT_CONSENT_LANGUAGE /*EXACT_CONSENT_LANGUAGE*/
,BRAND_TEKTRONIX /*BRAND_TEKTRONIX*/
,BRAND_SSO /*BRAND_SSO*/
,BRAND_KEITHLEY /*BRAND_KEITHLEY*/
,EMAIL_PREFERENCE /*EMAIL_PREFERENCE*/
,SUFFIX /*工单ID*/
,Src_Sysname /*来源系统*/
,Etl_Job /*作业名称*/
,Src_Table /*来源表*/
,Etl_Tx_Dt /*作业运行时间*/
,Etl_First_Dt /*最初入库时间*/
,Etl_Proc_Dt /*本次入库时间*/
,Etl_Batch_No /*作业批次号*/
)
SELECT
P1.PEXTENSION_CODE /*来源代码*/
,P1.PEXTENSION /*来源*/
,P1.LAST_NAME /*姓名*/
,P1.COMPANY_NAME /*公司名称*/
,P1.JOB_TITLE /*职位*/
,P1.CITY /*城市*/
,P1.STATE_COUNTY_LOCATION /*省份*/
,P1.COUNTRY_CODE /*国家*/
,P1.POSTAL_CODE /*邮编*/
,P1.CONTACT_MOBILE_NUMBER /*电话*/
,P1.EMAIL_ADDRESS /*邮箱*/
,P1.REQUEST_A_DEMO /*demo标志*/
,P1.REQUEST_A_QUOTE /*引用标志*/
,P1.HAMCAM /*账户管理员标志*/
,P1.PURCHASE_INTENT /*购买意向*/
,P1.COMMENTS /*备注*/
,P1.INDUSTRY /*行业*/
,P1.CCP_PRODUCT_INTEREST_01 /*产品偏好*/
,P1.CCP_APP_01_5 /*应用*/
,P1.LEAD_PRODUCTS_01_5 /*产品型号*/
,P1.PERMISSION_PHONE /*电话授权标志*/
,P1.PERMISSION_PHONE_DATE /*电话授权时间*/
,P1.PERMISSION_EMAIL /*电子邮件授权标志*/
,P1.PERMISSION_EMAIL_DATE /*电子邮件授权时间*/
,P1.PERMISSION_MAIL /*邮件授权标志*/
,P1.PERMISSION_MAIL_DATE /*邮件授权时间*/
,P1.PERMISSION_SMS /*SMS授权标志*/
,P1.PERMISSION_SMS_DATE /*SMS授权时间*/
,P1.AGREES_TO_PRIVACY_POLICY /*个人信息授权标志*/
,P1.PORTAL_TERMS_AGREEMENT_DATE /*协议授权时间*/
,P1.CONSENT_TO_COLLECT_PERSONAL_INFO /*个人信息收集标志*/
,P1.CONSENT_TO_COLLECT_PERSONAL_INFO_DATE /*个人信息收集时间*/
,P1.MARKETING_CONSENT /*MARKETING_CONSENT*/
,P1.MARKETING_CONSENT_DATE /*MARKETING_CONSENT_DATE*/
,P1.MEANS_OF_CONSENT /*MEANS_OF_CONSENT*/
,P1.SOURCE_OF_CONSENT /*SOURCE_OF_CONSENT*/
,P1.VERSION_OF_PRIVACY_NOTICE /*VERSION_OF_PRIVACY_NOTICE*/
,P1.RECORD_OF_CONSENT /*RECORD_OF_CONSENT*/
,P1.EXACT_CONSENT_LANGUAGE /*EXACT_CONSENT_LANGUAGE*/
,P1.BRAND_TEKTRONIX /*BRAND_TEKTRONIX*/
,P1.BRAND_SSO /*BRAND_SSO*/
,P1.BRAND_KEITHLEY /*BRAND_KEITHLEY*/
,P1.EMAIL_PREFERENCE /*EMAIL_PREFERENCE*/
,P1.SUFFIX /*工单ID*/
,P1.Src_Sysname /*来源系统*/
,P1.Etl_Job /*作业名称*/
,P1.Src_Table /*来源表*/
,P1.Etl_Tx_Dt /*作业运行时间*/
,P1.Etl_First_Dt /*最初入库时间*/
,P1.Etl_Proc_Dt /*本次入库时间*/
,P1.Etl_Batch_No /*作业批次号*/
FROM f_ccc_work_ticket_integ_agi_INS P1
ON CONFLICT ( SUFFIX)
DO UPDATE SET
SUFFIX=excluded.SUFFIX
,PEXTENSION_CODE=excluded.PEXTENSION_CODE
,PEXTENSION=excluded.PEXTENSION
,LAST_NAME=excluded.LAST_NAME
,COMPANY_NAME=excluded.COMPANY_NAME
,JOB_TITLE=excluded.JOB_TITLE
,CITY=excluded.CITY
,STATE_COUNTY_LOCATION=excluded.STATE_COUNTY_LOCATION
,COUNTRY_CODE=excluded.COUNTRY_CODE
,POSTAL_CODE=excluded.POSTAL_CODE
,CONTACT_MOBILE_NUMBER=excluded.CONTACT_MOBILE_NUMBER
,EMAIL_ADDRESS=excluded.EMAIL_ADDRESS
,REQUEST_A_DEMO=excluded.REQUEST_A_DEMO
,REQUEST_A_QUOTE=excluded.REQUEST_A_QUOTE
,HAMCAM=excluded.HAMCAM
,PURCHASE_INTENT=excluded.PURCHASE_INTENT
,COMMENTS=excluded.COMMENTS
,INDUSTRY=excluded.INDUSTRY
,CCP_PRODUCT_INTEREST_01=excluded.CCP_PRODUCT_INTEREST_01
,CCP_APP_01_5=excluded.CCP_APP_01_5
,LEAD_PRODUCTS_01_5=excluded.LEAD_PRODUCTS_01_5
,PERMISSION_PHONE=excluded.PERMISSION_PHONE
,PERMISSION_PHONE_DATE=excluded.PERMISSION_PHONE_DATE
,PERMISSION_EMAIL=excluded.PERMISSION_EMAIL
,PERMISSION_EMAIL_DATE=excluded.PERMISSION_EMAIL_DATE
,PERMISSION_MAIL=excluded.PERMISSION_MAIL
,PERMISSION_MAIL_DATE=excluded.PERMISSION_MAIL_DATE
,PERMISSION_SMS=excluded.PERMISSION_SMS
,PERMISSION_SMS_DATE=excluded.PERMISSION_SMS_DATE
,AGREES_TO_PRIVACY_POLICY=excluded.AGREES_TO_PRIVACY_POLICY
,PORTAL_TERMS_AGREEMENT_DATE=excluded.PORTAL_TERMS_AGREEMENT_DATE
,CONSENT_TO_COLLECT_PERSONAL_INFO=excluded.CONSENT_TO_COLLECT_PERSONAL_INFO
,CONSENT_TO_COLLECT_PERSONAL_INFO_DATE=excluded.CONSENT_TO_COLLECT_PERSONAL_INFO_DATE
,MARKETING_CONSENT=excluded.MARKETING_CONSENT
,MARKETING_CONSENT_DATE=excluded.MARKETING_CONSENT_DATE
,MEANS_OF_CONSENT=excluded.MEANS_OF_CONSENT
,SOURCE_OF_CONSENT=excluded.SOURCE_OF_CONSENT
,VERSION_OF_PRIVACY_NOTICE=excluded.VERSION_OF_PRIVACY_NOTICE
,RECORD_OF_CONSENT=excluded.RECORD_OF_CONSENT
,EXACT_CONSENT_LANGUAGE=excluded.EXACT_CONSENT_LANGUAGE
,BRAND_TEKTRONIX=excluded.BRAND_TEKTRONIX
,BRAND_SSO=excluded.BRAND_SSO
,BRAND_KEITHLEY=excluded.BRAND_KEITHLEY
,EMAIL_PREFERENCE=excluded.EMAIL_PREFERENCE
,Src_Sysname=excluded.Src_Sysname
,Etl_Job=excluded.Etl_Job
,Src_Table=excluded.Src_Table
,Etl_Tx_Dt=excluded.Etl_Tx_Dt
,Etl_First_Dt=excluded.Etl_First_Dt
,Etl_Proc_Dt=excluded.Etl_Proc_Dt
,Etl_Batch_No=excluded.Etl_Batch_No
;
/*****程序结束退出 */
\q

58
dev/workflow/TK_Cust/smart_ccc_ticket/天润Smart-ccc工单数据/wf_dag_smart_ccc_ticket.py
View File

@ -24,7 +24,7 @@ default_args = {
}
dag = DAG('wf_dag_smart_ccc_ticket', default_args=default_args,
schedule_interval="0 */1 * * *",
schedule_interval="0 0-23/1 * * *",
catchup=False,
dagrun_timeout=timedelta(minutes=160),
max_active_runs=3)
@ -35,9 +35,9 @@ task_failed = EmailOperator (
task_id="task_failed",
to=["info@idgvalue.com"],
cc=[""],
subject="smart_ccc_failed",
html_content='<h3>您好，smart_ccc作业失败，请及时处理" </h3>')
subject="smart_ccc_ticket_failed",
html_content='<h3>您好，smart_ccc_ticket作业失败，请及时处理" </h3>')
tickets_list_feign = SSHOperator(
ssh_hook=sshHook,
task_id='tickets_list_feign',
@ -56,7 +56,7 @@ retries=3,
dag=dag)
tickets_list_feign >> tickets_list_load
tr_ticket_detail_4125 = SSHOperator(
ssh_hook=sshHook,
task_id='tr_ticket_detail_4125',
@ -65,7 +65,7 @@ params={'my_param':"S98_S_tr_ticket_detail"},
depends_on_past=False,
retries=3,
dag=dag)
tr_ticket_list_4585 = SSHOperator(
ssh_hook=sshHook,
task_id='tr_ticket_list_4585',
@ -74,8 +74,46 @@ params={'my_param':"S98_S_tr_ticket_list"},
depends_on_past=False,
retries=3,
dag=dag)
tickets_detail_feign = SSHOperator(
ssh_hook=sshHook,
task_id='tickets_detail_feign',
command='python3 /data/airflow/etl/API/tickets_detail_feign.py',
depends_on_past=False,
retries=3,
dag=dag)
tickets_list_load >> tr_ticket_list_4585
tickets_list_load >> tr_ticket_detail_4125
tr_ticket_detail_4125 >> task_failed
tr_ticket_list_4585 >> task_failed
tickets_detail_load = SSHOperator(
ssh_hook=sshHook,
task_id='tickets_detail_load',
command='/data/airflow/etl/API/run_psql.sh {{ ds_nodash }} {{params.my_param }}',
params={'my_param':"tickets_detail_load"},
depends_on_past=False,
retries=3,
dag=dag)
tickets_detail_feign >> tickets_detail_load
t01_ccc_work_ticket_info = SSHOperator(
ssh_hook=sshHook,
task_id='t01_ccc_work_ticket_info',
command='/data/airflow/etl/PDM/run_psql.sh {{ ds_nodash }} {{params.my_param}} >>/data/airflow/logs/run_tpt_{{ds_nodash}}.log 2>&1 ',
params={'my_param':"t01_ccc_work_ticket_info_agi"},
depends_on_past=False,
retries=3,
dag=dag)
f_ccc_work_ticket_integ = SSHOperator(
ssh_hook=sshHook,
task_id='f_ccc_work_ticket_integ',
command='/data/airflow/etl/COM/run_psql.sh {{ ds_nodash }} {{params.my_param}} >>/data/airflow/logs/run_tpt_{{ds_nodash}}.log 2>&1 ',
params={'my_param':"f_ccc_work_ticket_integ_agi"},
depends_on_past=False,
retries=3,
dag=dag)
tickets_list_load >> tr_ticket_list_4585
tickets_list_load >> tr_ticket_detail_4125
tr_ticket_list_4585 >> t01_ccc_work_ticket_info
tr_ticket_detail_4125 >> t01_ccc_work_ticket_info
t01_ccc_work_ticket_info >> f_ccc_work_ticket_integ
f_ccc_work_ticket_integ >> task_failed
tickets_detail_load >> task_failed