diff --git a/dev/workflow/TK_Cust/partner_one_site_file/partner数据导入/wf_dag_partner_one_site_file.py b/dev/workflow/TK_Cust/partner_one_site_file/partner数据导入/wf_dag_partner_one_site_file.py index 6b07984..79aeac4 100644 --- a/dev/workflow/TK_Cust/partner_one_site_file/partner数据导入/wf_dag_partner_one_site_file.py +++ b/dev/workflow/TK_Cust/partner_one_site_file/partner数据导入/wf_dag_partner_one_site_file.py @@ -68,6 +68,34 @@ retries=3, dag=dag) -file_visits_ytd >> task_failed -file_report_daily_checked >> task_failed -file_report_daily_complet >> task_failed +visits_ytd_7151 = SSHOperator( +ssh_hook=sshHook, +task_id='visits_ytd_7151', +command='/data/airflow/etl/SA/run_sa.sh {{ ds_nodash }} {{ params.my_param }} >>/data/airflow/logs/run_psql_{{ds_nodash}}.log 2>&1 ', +params={'my_param':"S98_S_visits_ytd"}, +depends_on_past=False, +retries=3, +dag=dag) + +report_daily_completed_3672 = SSHOperator( +ssh_hook=sshHook, +task_id='report_daily_completed_3672', +command='/data/airflow/etl/SA/run_sa.sh {{ ds_nodash }} {{ params.my_param }} >>/data/airflow/logs/run_psql_{{ds_nodash}}.log 2>&1 ', +params={'my_param':"S98_S_report_daily_completed"}, +depends_on_past=False, +retries=3, +dag=dag) + +report_daily_checked_8821 = SSHOperator( +ssh_hook=sshHook, +task_id='report_daily_checked_8821', +command='/data/airflow/etl/SA/run_sa.sh {{ ds_nodash }} {{ params.my_param }} >>/data/airflow/logs/run_psql_{{ds_nodash}}.log 2>&1 ', +params={'my_param':"S98_S_report_daily_checked"}, +depends_on_past=False, +retries=3, +dag=dag) + +file_report_daily_checked >> report_daily_checked_8821 +file_report_daily_complet >> report_daily_completed_3672 +file_visits_ytd >> visits_ytd_7151 +visits_ytd_7151 >> task_failed diff --git a/dev/workflow/TK_Cust/partner_one_site_file/report_daily_checked/S98_S_report_daily_checked.sql b/dev/workflow/TK_Cust/partner_one_site_file/report_daily_checked/S98_S_report_daily_checked.sql new file mode 100644 index 0000000..9e39579 --- /dev/null +++ b/dev/workflow/TK_Cust/partner_one_site_file/report_daily_checked/S98_S_report_daily_checked.sql @@ -0,0 +1,238 @@ +/*******Main Section**************************************************************************/ +\set ON_ERROR_STOP on +\set AUTOCOMMIT on +\timing on +delete from p10_sa.S98_S_report_daily_checked +; +insert into p10_sa.S98_S_report_daily_checked +( regist_id + , partner_name + , region + , applicant + , applicant_tel + , applicant_email + , apply_time + , review_sales_manager + , review_status + , review_time + , cust_name + , procure_method + , trader_name + , trader_contact_name + , trader_contct_tel + , prov + , city + , address_detail + , system_integration_sales_flag + , using_depart + , using_depart_attr + , industry + , sub_industry + , contact_name + , contact_tel + , financial_status + , project_approval_status + , expected_compelete_ate + , key_features + , our_advantages + , our_benefits + , progress_stage + , lose_reason_type + , lose_reason + , close_time + , source_of_information + , leads_id + , delay_90_day_ind + , delay_reason + , review_remark + , regist_total_price + , packaging_solution_type + , packaging_solution + , product_series + , product_type + , model_type + , product_solution + , selected_products + , unit_price + , qty + , discounted_total_price + , last_modify_time + , alias + , remark + , etl_tx_dt ) + select + regist_id + , partner_name + , region + , applicant + , applicant_tel + , applicant_email + , apply_time + , review_sales_manager + , review_status + , review_time + , cust_name + , procure_method + , trader_name + , trader_contact_name + , trader_contct_tel + , prov + , city + , address_detail + , system_integration_sales_flag + , using_depart + , using_depart_attr + , industry + , sub_industry + , contact_name + , contact_tel + , financial_status + , project_approval_status + , expected_compelete_ate + , key_features + , our_advantages + , our_benefits + , progress_stage + , lose_reason_type + , lose_reason + , close_time + , source_of_information + , leads_id + , delay_90_day_ind + , delay_reason + , review_remark + , regist_total_price + , packaging_solution_type + , packaging_solution + , product_series + , product_type + , model_type + , product_solution + , selected_products + , unit_price + , qty + , discounted_total_price + , last_modify_time + , alias + , remark + , etl_tx_dt + from p00_tal.S98_S_report_daily_checked + ; + delete from p12_sfull.S98_S_report_daily_checked +; +; +insert into p12_sfull.S98_S_report_daily_checked +( regist_id + , partner_name + , region + , applicant + , applicant_tel + , applicant_email + , apply_time + , review_sales_manager + , review_status + , review_time + , cust_name + , procure_method + , trader_name + , trader_contact_name + , trader_contct_tel + , prov + , city + , address_detail + , system_integration_sales_flag + , using_depart + , using_depart_attr + , industry + , sub_industry + , contact_name + , contact_tel + , financial_status + , project_approval_status + , expected_compelete_ate + , key_features + , our_advantages + , our_benefits + , progress_stage + , lose_reason_type + , lose_reason + , close_time + , source_of_information + , leads_id + , delay_90_day_ind + , delay_reason + , review_remark + , regist_total_price + , packaging_solution_type + , packaging_solution + , product_series + , product_type + , model_type + , product_solution + , selected_products + , unit_price + , qty + , discounted_total_price + , last_modify_time + , alias + , remark + , etl_tx_dt ) + select + regist_id + , partner_name + , region + , applicant + , applicant_tel + , applicant_email + , apply_time + , review_sales_manager + , review_status + , review_time + , cust_name + , procure_method + , trader_name + , trader_contact_name + , trader_contct_tel + , prov + , city + , address_detail + , system_integration_sales_flag + , using_depart + , using_depart_attr + , industry + , sub_industry + , contact_name + , contact_tel + , financial_status + , project_approval_status + , expected_compelete_ate + , key_features + , our_advantages + , our_benefits + , progress_stage + , lose_reason_type + , lose_reason + , close_time + , source_of_information + , leads_id + , delay_90_day_ind + , delay_reason + , review_remark + , regist_total_price + , packaging_solution_type + , packaging_solution + , product_series + , product_type + , model_type + , product_solution + , selected_products + , unit_price + , qty + , discounted_total_price + , last_modify_time + , alias + , remark + , etl_tx_dt + from p10_sa.S98_S_report_daily_checked +; +\q \ No newline at end of file diff --git a/dev/workflow/TK_Cust/partner_one_site_file/report_daily_checked/sa_foreign_tables.sql b/dev/workflow/TK_Cust/partner_one_site_file/report_daily_checked/sa_foreign_tables.sql new file mode 100644 index 0000000..ffbcc84 --- /dev/null +++ b/dev/workflow/TK_Cust/partner_one_site_file/report_daily_checked/sa_foreign_tables.sql @@ -0,0 +1,66 @@ + +CREATE FOREIGN TABLE if not exists p00_tal.S98_S_report_daily_checked ( + regist_id TEXT + , partner_name TEXT + , region TEXT + , applicant TEXT + , applicant_tel TEXT + , applicant_email TEXT + , apply_time TEXT + , review_sales_manager TEXT + , review_status TEXT + , review_time TEXT + , cust_name TEXT + , procure_method TEXT + , trader_name TEXT + , trader_contact_name TEXT + , trader_contct_tel TEXT + , prov TEXT + , city TEXT + , address_detail TEXT + , system_integration_sales_flag TEXT + , using_depart TEXT + , using_depart_attr TEXT + , industry TEXT + , sub_industry TEXT + , contact_name TEXT + , contact_tel TEXT + , financial_status TEXT + , project_approval_status TEXT + , expected_compelete_ate TEXT + , key_features TEXT + , our_advantages TEXT + , our_benefits TEXT + , progress_stage TEXT + , lose_reason_type TEXT + , lose_reason TEXT + , close_time TEXT + , source_of_information TEXT + , leads_id TEXT + , delay_90_day_ind TEXT + , delay_reason TEXT + , review_remark TEXT + , regist_total_price TEXT + , packaging_solution_type TEXT + , packaging_solution TEXT + , product_series TEXT + , product_type TEXT + , model_type TEXT + , product_solution TEXT + , selected_products TEXT + , unit_price TEXT + , qty TEXT + , discounted_total_price TEXT + , last_modify_time TEXT + , alias TEXT + , remark TEXT + , etl_tx_dt TIMESTAMP +) + + +SERVER pgsql_server_S98_S OPTIONS(schema_name 'data_api', table_name 'report_daily_checked' ); + + + + + diff --git a/dev/workflow/TK_Cust/partner_one_site_file/report_daily_checked/sa_tables.sql b/dev/workflow/TK_Cust/partner_one_site_file/report_daily_checked/sa_tables.sql new file mode 100644 index 0000000..879bfee --- /dev/null +++ b/dev/workflow/TK_Cust/partner_one_site_file/report_daily_checked/sa_tables.sql @@ -0,0 +1,235 @@ + +create table if not exists p10_sa.S98_S_report_daily_checked ( + regist_id TEXT + , partner_name TEXT + , region TEXT + , applicant TEXT + , applicant_tel TEXT + , applicant_email TEXT + , apply_time TEXT + , review_sales_manager TEXT + , review_status TEXT + , review_time TEXT + , cust_name TEXT + , procure_method TEXT + , trader_name TEXT + , trader_contact_name TEXT + , trader_contct_tel TEXT + , prov TEXT + , city TEXT + , address_detail TEXT + , system_integration_sales_flag TEXT + , using_depart TEXT + , using_depart_attr TEXT + , industry TEXT + , sub_industry TEXT + , contact_name TEXT + , contact_tel TEXT + , financial_status TEXT + , project_approval_status TEXT + , expected_compelete_ate TEXT + , key_features TEXT + , our_advantages TEXT + , our_benefits TEXT + , progress_stage TEXT + , lose_reason_type TEXT + , lose_reason TEXT + , close_time TEXT + , source_of_information TEXT + , leads_id TEXT + , delay_90_day_ind TEXT + , delay_reason TEXT + , review_remark TEXT + , regist_total_price TEXT + , packaging_solution_type TEXT + , packaging_solution TEXT + , product_series TEXT + , product_type TEXT + , model_type TEXT + , product_solution TEXT + , selected_products TEXT + , unit_price TEXT + , qty TEXT + , discounted_total_price TEXT + , last_modify_time TEXT + , alias TEXT + , remark TEXT + , etl_tx_dt TIMESTAMP +) ; + + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.regist_id IS '报备编号'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.partner_name IS '合作伙伴'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.region IS '大区'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.applicant IS '申请人'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.applicant_tel IS '申请人电话'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.applicant_email IS '申请人邮箱'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.apply_time IS '申请时间'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.review_sales_manager IS '审核销售经理'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.review_status IS '审核状态'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.review_time IS '审核时间'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.cust_name IS '客户名称'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.procure_method IS '采购方式及渠道'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.trader_name IS '贸易商名称'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.trader_contact_name IS '贸易商联系人'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.trader_contct_tel IS '贸易商联系人电话'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.prov IS '省份'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.city IS '城市'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.address_detail IS '用户详细地址'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.system_integration_sales_flag IS '系统集成销售'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.using_depart IS '使用部门'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.using_depart_attr IS '使用部门属性'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.industry IS '行业'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.sub_industry IS '子行业'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.contact_name IS '联系人姓名'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.contact_tel IS '联系人电话'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.financial_status IS '资金情况'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.project_approval_status IS '项目批准情况'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.expected_compelete_ate IS '预计结单时间'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.key_features IS '主要特点'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.our_advantages IS '优于竞争对手的地方'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.our_benefits IS '我们方案的好处'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.progress_stage IS '进展阶段'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.lose_reason_type IS '丢单原因类型'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.lose_reason IS '丢单原因'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.close_time IS '结单/丢单时间'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.source_of_information IS '信息来源'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.leads_id IS 'leads编号'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.delay_90_day_ind IS '报备需要延期90天'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.delay_reason IS '延期原因'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.review_remark IS '审核备注'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.regist_total_price IS '报备总价'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.packaging_solution_type IS '打包方案类型'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.packaging_solution IS '打包方案名称'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.product_series IS '产品系列/方案类型'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.product_type IS '产品类型'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.model_type IS '型号类型'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.product_solution IS '产品/方案名称'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.selected_products IS '方案中选择产品'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.unit_price IS '单价'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.qty IS '数量'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.discounted_total_price IS '折扣后总价'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.last_modify_time IS '最后修改时间'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.alias IS '别名'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.remark IS '特别备注'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_checked.etl_tx_dt IS ''; + +COMMENT ON TABLE p10_sa.S98_S_report_daily_checked IS ''; + + + +create table if not exists p12_sfull.S98_S_report_daily_checked ( + regist_id TEXT + , partner_name TEXT + , region TEXT + , applicant TEXT + , applicant_tel TEXT + , applicant_email TEXT + , apply_time TEXT + , review_sales_manager TEXT + , review_status TEXT + , review_time TEXT + , cust_name TEXT + , procure_method TEXT + , trader_name TEXT + , trader_contact_name TEXT + , trader_contct_tel TEXT + , prov TEXT + , city TEXT + , address_detail TEXT + , system_integration_sales_flag TEXT + , using_depart TEXT + , using_depart_attr TEXT + , industry TEXT + , sub_industry TEXT + , contact_name TEXT + , contact_tel TEXT + , financial_status TEXT + , project_approval_status TEXT + , expected_compelete_ate TEXT + , key_features TEXT + , our_advantages TEXT + , our_benefits TEXT + , progress_stage TEXT + , lose_reason_type TEXT + , lose_reason TEXT + , close_time TEXT + , source_of_information TEXT + , leads_id TEXT + , delay_90_day_ind TEXT + , delay_reason TEXT + , review_remark TEXT + , regist_total_price TEXT + , packaging_solution_type TEXT + , packaging_solution TEXT + , product_series TEXT + , product_type TEXT + , model_type TEXT + , product_solution TEXT + , selected_products TEXT + , unit_price TEXT + , qty TEXT + , discounted_total_price TEXT + , last_modify_time TEXT + , alias TEXT + , remark TEXT + , etl_tx_dt TIMESTAMP +) ; + + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.regist_id IS '报备编号'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.partner_name IS '合作伙伴'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.region IS '大区'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.applicant IS '申请人'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.applicant_tel IS '申请人电话'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.applicant_email IS '申请人邮箱'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.apply_time IS '申请时间'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.review_sales_manager IS '审核销售经理'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.review_status IS '审核状态'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.review_time IS '审核时间'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.cust_name IS '客户名称'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.procure_method IS '采购方式及渠道'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.trader_name IS '贸易商名称'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.trader_contact_name IS '贸易商联系人'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.trader_contct_tel IS '贸易商联系人电话'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.prov IS '省份'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.city IS '城市'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.address_detail IS '用户详细地址'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.system_integration_sales_flag IS '系统集成销售'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.using_depart IS '使用部门'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.using_depart_attr IS '使用部门属性'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.industry IS '行业'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.sub_industry IS '子行业'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.contact_name IS '联系人姓名'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.contact_tel IS '联系人电话'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.financial_status IS '资金情况'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.project_approval_status IS '项目批准情况'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.expected_compelete_ate IS '预计结单时间'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.key_features IS '主要特点'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.our_advantages IS '优于竞争对手的地方'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.our_benefits IS '我们方案的好处'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.progress_stage IS '进展阶段'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.lose_reason_type IS '丢单原因类型'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.lose_reason IS '丢单原因'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.close_time IS '结单/丢单时间'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.source_of_information IS '信息来源'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.leads_id IS 'leads编号'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.delay_90_day_ind IS '报备需要延期90天'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.delay_reason IS '延期原因'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.review_remark IS '审核备注'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.regist_total_price IS '报备总价'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.packaging_solution_type IS '打包方案类型'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.packaging_solution IS '打包方案名称'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.product_series IS '产品系列/方案类型'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.product_type IS '产品类型'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.model_type IS '型号类型'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.product_solution IS '产品/方案名称'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.selected_products IS '方案中选择产品'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.unit_price IS '单价'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.qty IS '数量'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.discounted_total_price IS '折扣后总价'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.last_modify_time IS '最后修改时间'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.alias IS '别名'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.remark IS '特别备注'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_checked.etl_tx_dt IS ''; + +COMMENT ON TABLE p12_sfull.S98_S_report_daily_checked IS ''; + diff --git a/dev/workflow/TK_Cust/partner_one_site_file/report_daily_completed/S98_S_report_daily_completed.sql b/dev/workflow/TK_Cust/partner_one_site_file/report_daily_completed/S98_S_report_daily_completed.sql new file mode 100644 index 0000000..5eb928b --- /dev/null +++ b/dev/workflow/TK_Cust/partner_one_site_file/report_daily_completed/S98_S_report_daily_completed.sql @@ -0,0 +1,238 @@ +/*******Main Section**************************************************************************/ +\set ON_ERROR_STOP on +\set AUTOCOMMIT on +\timing on +delete from p10_sa.S98_S_report_daily_completed +; +insert into p10_sa.S98_S_report_daily_completed +( regist_id + , partner_name + , region + , applicant + , applicant_tel + , applicant_email + , apply_time + , review_sales_manager + , review_status + , review_time + , cust_name + , procure_method + , trader_name + , trader_contact_name + , trader_contct_tel + , prov + , city + , address_detail + , system_integration_sales_flag + , using_depart + , using_depart_attr + , industry + , sub_industry + , contact_name + , contact_tel + , financial_status + , project_approval_status + , expected_compelete_date + , key_features + , our_advantages + , our_benefits + , progress_stage + , lose_reason_type + , lose_reason + , close_time + , source_of_information + , leads_id + , delay_90_day_ind + , delay_reason + , review_remark + , regist_total_price + , packaging_solution_type + , packaging_solution + , product_series + , product_type + , model_type + , product_solution + , selected_products + , unit_price + , qty + , discounted_total_price + , last_modify_time + , alias + , remark + , etl_tx_dt ) + select + regist_id + , partner_name + , region + , applicant + , applicant_tel + , applicant_email + , apply_time + , review_sales_manager + , review_status + , review_time + , cust_name + , procure_method + , trader_name + , trader_contact_name + , trader_contct_tel + , prov + , city + , address_detail + , system_integration_sales_flag + , using_depart + , using_depart_attr + , industry + , sub_industry + , contact_name + , contact_tel + , financial_status + , project_approval_status + , expected_compelete_date + , key_features + , our_advantages + , our_benefits + , progress_stage + , lose_reason_type + , lose_reason + , close_time + , source_of_information + , leads_id + , delay_90_day_ind + , delay_reason + , review_remark + , regist_total_price + , packaging_solution_type + , packaging_solution + , product_series + , product_type + , model_type + , product_solution + , selected_products + , unit_price + , qty + , discounted_total_price + , last_modify_time + , alias + , remark + , etl_tx_dt + from p00_tal.S98_S_report_daily_completed + ; + delete from p12_sfull.S98_S_report_daily_completed +; +; +insert into p12_sfull.S98_S_report_daily_completed +( regist_id + , partner_name + , region + , applicant + , applicant_tel + , applicant_email + , apply_time + , review_sales_manager + , review_status + , review_time + , cust_name + , procure_method + , trader_name + , trader_contact_name + , trader_contct_tel + , prov + , city + , address_detail + , system_integration_sales_flag + , using_depart + , using_depart_attr + , industry + , sub_industry + , contact_name + , contact_tel + , financial_status + , project_approval_status + , expected_compelete_date + , key_features + , our_advantages + , our_benefits + , progress_stage + , lose_reason_type + , lose_reason + , close_time + , source_of_information + , leads_id + , delay_90_day_ind + , delay_reason + , review_remark + , regist_total_price + , packaging_solution_type + , packaging_solution + , product_series + , product_type + , model_type + , product_solution + , selected_products + , unit_price + , qty + , discounted_total_price + , last_modify_time + , alias + , remark + , etl_tx_dt ) + select + regist_id + , partner_name + , region + , applicant + , applicant_tel + , applicant_email + , apply_time + , review_sales_manager + , review_status + , review_time + , cust_name + , procure_method + , trader_name + , trader_contact_name + , trader_contct_tel + , prov + , city + , address_detail + , system_integration_sales_flag + , using_depart + , using_depart_attr + , industry + , sub_industry + , contact_name + , contact_tel + , financial_status + , project_approval_status + , expected_compelete_date + , key_features + , our_advantages + , our_benefits + , progress_stage + , lose_reason_type + , lose_reason + , close_time + , source_of_information + , leads_id + , delay_90_day_ind + , delay_reason + , review_remark + , regist_total_price + , packaging_solution_type + , packaging_solution + , product_series + , product_type + , model_type + , product_solution + , selected_products + , unit_price + , qty + , discounted_total_price + , last_modify_time + , alias + , remark + , etl_tx_dt + from p10_sa.S98_S_report_daily_completed +; +\q \ No newline at end of file diff --git a/dev/workflow/TK_Cust/partner_one_site_file/report_daily_completed/sa_foreign_tables.sql b/dev/workflow/TK_Cust/partner_one_site_file/report_daily_completed/sa_foreign_tables.sql new file mode 100644 index 0000000..d6dfe42 --- /dev/null +++ b/dev/workflow/TK_Cust/partner_one_site_file/report_daily_completed/sa_foreign_tables.sql @@ -0,0 +1,66 @@ + +CREATE FOREIGN TABLE if not exists p00_tal.S98_S_report_daily_completed ( + regist_id TEXT + , partner_name TEXT + , region TEXT + , applicant TEXT + , applicant_tel TEXT + , applicant_email TEXT + , apply_time TEXT + , review_sales_manager TEXT + , review_status TEXT + , review_time TEXT + , cust_name TEXT + , procure_method TEXT + , trader_name TEXT + , trader_contact_name TEXT + , trader_contct_tel TEXT + , prov TEXT + , city TEXT + , address_detail TEXT + , system_integration_sales_flag TEXT + , using_depart TEXT + , using_depart_attr TEXT + , industry TEXT + , sub_industry TEXT + , contact_name TEXT + , contact_tel TEXT + , financial_status TEXT + , project_approval_status TEXT + , expected_compelete_date TEXT + , key_features TEXT + , our_advantages TEXT + , our_benefits TEXT + , progress_stage TEXT + , lose_reason_type TEXT + , lose_reason TEXT + , close_time TEXT + , source_of_information TEXT + , leads_id TEXT + , delay_90_day_ind TEXT + , delay_reason TEXT + , review_remark TEXT + , regist_total_price TEXT + , packaging_solution_type TEXT + , packaging_solution TEXT + , product_series TEXT + , product_type TEXT + , model_type TEXT + , product_solution TEXT + , selected_products TEXT + , unit_price TEXT + , qty TEXT + , discounted_total_price TEXT + , last_modify_time TEXT + , alias TEXT + , remark TEXT + , etl_tx_dt TIMESTAMP +) + + +SERVER pgsql_server_S98_S OPTIONS(schema_name 'data_api', table_name 'report_daily_completed' ); + + + + + diff --git a/dev/workflow/TK_Cust/partner_one_site_file/report_daily_completed/sa_tables.sql b/dev/workflow/TK_Cust/partner_one_site_file/report_daily_completed/sa_tables.sql new file mode 100644 index 0000000..0303718 --- /dev/null +++ b/dev/workflow/TK_Cust/partner_one_site_file/report_daily_completed/sa_tables.sql @@ -0,0 +1,235 @@ + +create table if not exists p10_sa.S98_S_report_daily_completed ( + regist_id TEXT + , partner_name TEXT + , region TEXT + , applicant TEXT + , applicant_tel TEXT + , applicant_email TEXT + , apply_time TEXT + , review_sales_manager TEXT + , review_status TEXT + , review_time TEXT + , cust_name TEXT + , procure_method TEXT + , trader_name TEXT + , trader_contact_name TEXT + , trader_contct_tel TEXT + , prov TEXT + , city TEXT + , address_detail TEXT + , system_integration_sales_flag TEXT + , using_depart TEXT + , using_depart_attr TEXT + , industry TEXT + , sub_industry TEXT + , contact_name TEXT + , contact_tel TEXT + , financial_status TEXT + , project_approval_status TEXT + , expected_compelete_date TEXT + , key_features TEXT + , our_advantages TEXT + , our_benefits TEXT + , progress_stage TEXT + , lose_reason_type TEXT + , lose_reason TEXT + , close_time TEXT + , source_of_information TEXT + , leads_id TEXT + , delay_90_day_ind TEXT + , delay_reason TEXT + , review_remark TEXT + , regist_total_price TEXT + , packaging_solution_type TEXT + , packaging_solution TEXT + , product_series TEXT + , product_type TEXT + , model_type TEXT + , product_solution TEXT + , selected_products TEXT + , unit_price TEXT + , qty TEXT + , discounted_total_price TEXT + , last_modify_time TEXT + , alias TEXT + , remark TEXT + , etl_tx_dt TIMESTAMP +) ; + + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.regist_id IS '报备编号'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.partner_name IS '合作伙伴'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.region IS '大区'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.applicant IS '申请人'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.applicant_tel IS '申请人电话'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.applicant_email IS '申请人邮箱'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.apply_time IS '申请时间'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.review_sales_manager IS '审核销售经理'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.review_status IS '审核状态'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.review_time IS '审核时间'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.cust_name IS '客户名称'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.procure_method IS '采购方式及渠道'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.trader_name IS '贸易商名称'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.trader_contact_name IS '贸易商联系人'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.trader_contct_tel IS '贸易商联系人电话'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.prov IS '省份'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.city IS '城市'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.address_detail IS '用户详细地址'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.system_integration_sales_flag IS '系统集成销售'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.using_depart IS '使用部门'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.using_depart_attr IS '使用部门属性'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.industry IS '行业'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.sub_industry IS '子行业'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.contact_name IS '联系人姓名'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.contact_tel IS '联系人电话'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.financial_status IS '资金情况'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.project_approval_status IS '项目批准情况'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.expected_compelete_date IS '预计结单时间'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.key_features IS '主要特点'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.our_advantages IS '优于竞争对手的地方'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.our_benefits IS '我们方案的好处'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.progress_stage IS '进展阶段'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.lose_reason_type IS '丢单原因类型'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.lose_reason IS '丢单原因'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.close_time IS '结单/丢单时间'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.source_of_information IS '信息来源'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.leads_id IS 'leads编号'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.delay_90_day_ind IS '报备需要延期90天'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.delay_reason IS '延期原因'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.review_remark IS '审核备注'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.regist_total_price IS '报备总价'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.packaging_solution_type IS '打包方案类型'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.packaging_solution IS '打包方案名称'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.product_series IS '产品系列/方案类型'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.product_type IS '产品类型'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.model_type IS '型号类型'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.product_solution IS '产品/方案名称'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.selected_products IS '方案中选择产品'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.unit_price IS '单价'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.qty IS '数量'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.discounted_total_price IS '折扣后总价'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.last_modify_time IS '最后修改时间'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.alias IS '别名'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.remark IS '特别备注'; + COMMENT ON COLUMN p10_sa.S98_S_report_daily_completed.etl_tx_dt IS ''; + +COMMENT ON TABLE p10_sa.S98_S_report_daily_completed IS ''; + + + +create table if not exists p12_sfull.S98_S_report_daily_completed ( + regist_id TEXT + , partner_name TEXT + , region TEXT + , applicant TEXT + , applicant_tel TEXT + , applicant_email TEXT + , apply_time TEXT + , review_sales_manager TEXT + , review_status TEXT + , review_time TEXT + , cust_name TEXT + , procure_method TEXT + , trader_name TEXT + , trader_contact_name TEXT + , trader_contct_tel TEXT + , prov TEXT + , city TEXT + , address_detail TEXT + , system_integration_sales_flag TEXT + , using_depart TEXT + , using_depart_attr TEXT + , industry TEXT + , sub_industry TEXT + , contact_name TEXT + , contact_tel TEXT + , financial_status TEXT + , project_approval_status TEXT + , expected_compelete_date TEXT + , key_features TEXT + , our_advantages TEXT + , our_benefits TEXT + , progress_stage TEXT + , lose_reason_type TEXT + , lose_reason TEXT + , close_time TEXT + , source_of_information TEXT + , leads_id TEXT + , delay_90_day_ind TEXT + , delay_reason TEXT + , review_remark TEXT + , regist_total_price TEXT + , packaging_solution_type TEXT + , packaging_solution TEXT + , product_series TEXT + , product_type TEXT + , model_type TEXT + , product_solution TEXT + , selected_products TEXT + , unit_price TEXT + , qty TEXT + , discounted_total_price TEXT + , last_modify_time TEXT + , alias TEXT + , remark TEXT + , etl_tx_dt TIMESTAMP +) ; + + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.regist_id IS '报备编号'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.partner_name IS '合作伙伴'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.region IS '大区'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.applicant IS '申请人'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.applicant_tel IS '申请人电话'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.applicant_email IS '申请人邮箱'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.apply_time IS '申请时间'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.review_sales_manager IS '审核销售经理'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.review_status IS '审核状态'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.review_time IS '审核时间'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.cust_name IS '客户名称'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.procure_method IS '采购方式及渠道'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.trader_name IS '贸易商名称'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.trader_contact_name IS '贸易商联系人'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.trader_contct_tel IS '贸易商联系人电话'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.prov IS '省份'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.city IS '城市'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.address_detail IS '用户详细地址'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.system_integration_sales_flag IS '系统集成销售'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.using_depart IS '使用部门'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.using_depart_attr IS '使用部门属性'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.industry IS '行业'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.sub_industry IS '子行业'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.contact_name IS '联系人姓名'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.contact_tel IS '联系人电话'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.financial_status IS '资金情况'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.project_approval_status IS '项目批准情况'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.expected_compelete_date IS '预计结单时间'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.key_features IS '主要特点'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.our_advantages IS '优于竞争对手的地方'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.our_benefits IS '我们方案的好处'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.progress_stage IS '进展阶段'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.lose_reason_type IS '丢单原因类型'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.lose_reason IS '丢单原因'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.close_time IS '结单/丢单时间'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.source_of_information IS '信息来源'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.leads_id IS 'leads编号'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.delay_90_day_ind IS '报备需要延期90天'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.delay_reason IS '延期原因'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.review_remark IS '审核备注'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.regist_total_price IS '报备总价'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.packaging_solution_type IS '打包方案类型'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.packaging_solution IS '打包方案名称'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.product_series IS '产品系列/方案类型'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.product_type IS '产品类型'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.model_type IS '型号类型'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.product_solution IS '产品/方案名称'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.selected_products IS '方案中选择产品'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.unit_price IS '单价'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.qty IS '数量'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.discounted_total_price IS '折扣后总价'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.last_modify_time IS '最后修改时间'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.alias IS '别名'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.remark IS '特别备注'; + COMMENT ON COLUMN p12_sfull.S98_S_report_daily_completed.etl_tx_dt IS ''; + +COMMENT ON TABLE p12_sfull.S98_S_report_daily_completed IS ''; + diff --git a/dev/workflow/TK_Cust/partner_one_site_file/visits_ytd/S98_S_visits_ytd.sql b/dev/workflow/TK_Cust/partner_one_site_file/visits_ytd/S98_S_visits_ytd.sql new file mode 100644 index 0000000..7aa7549 --- /dev/null +++ b/dev/workflow/TK_Cust/partner_one_site_file/visits_ytd/S98_S_visits_ytd.sql @@ -0,0 +1,110 @@ +/*******Main Section**************************************************************************/ +\set ON_ERROR_STOP on +\set AUTOCOMMIT on +\timing on +delete from p10_sa.S98_S_visits_ytd +; +insert into p10_sa.S98_S_visits_ytd +( record_time + , visit_name + , agent_name + , cust_name + , contact_name + , contact_depart + , product_type + , intend_product + , regist_ind + , contact_info + , attachment + , visit_remark + , comment_number + , like_number + , region + , contact_tel + , contact_email + , contact_address + , like_person + , alias + , industry + , sub_industry + , etl_tx_dt ) + select + record_time + , visit_name + , agent_name + , cust_name + , contact_name + , contact_depart + , product_type + , intend_product + , regist_ind + , contact_info + , attachment + , visit_remark + , comment_number + , like_number + , region + , contact_tel + , contact_email + , contact_address + , like_person + , alias + , industry + , sub_industry + , etl_tx_dt + from p00_tal.S98_S_visits_ytd + ; + delete from p12_sfull.S98_S_visits_ytd +; +; +insert into p12_sfull.S98_S_visits_ytd +( record_time + , visit_name + , agent_name + , cust_name + , contact_name + , contact_depart + , product_type + , intend_product + , regist_ind + , contact_info + , attachment + , visit_remark + , comment_number + , like_number + , region + , contact_tel + , contact_email + , contact_address + , like_person + , alias + , industry + , sub_industry + , etl_tx_dt ) + select + record_time + , visit_name + , agent_name + , cust_name + , contact_name + , contact_depart + , product_type + , intend_product + , regist_ind + , contact_info + , attachment + , visit_remark + , comment_number + , like_number + , region + , contact_tel + , contact_email + , contact_address + , like_person + , alias + , industry + , sub_industry + , etl_tx_dt + from p10_sa.S98_S_visits_ytd +; +\q \ No newline at end of file diff --git a/dev/workflow/TK_Cust/partner_one_site_file/visits_ytd/sa_foreign_tables.sql b/dev/workflow/TK_Cust/partner_one_site_file/visits_ytd/sa_foreign_tables.sql new file mode 100644 index 0000000..cb6d69c --- /dev/null +++ b/dev/workflow/TK_Cust/partner_one_site_file/visits_ytd/sa_foreign_tables.sql @@ -0,0 +1,34 @@ + +CREATE FOREIGN TABLE if not exists p00_tal.S98_S_visits_ytd ( + record_time TEXT + , visit_name TEXT + , agent_name TEXT + , cust_name TEXT + , contact_name TEXT + , contact_depart TEXT + , product_type TEXT + , intend_product TEXT + , regist_ind TEXT + , contact_info TEXT + , attachment TEXT + , visit_remark TEXT + , comment_number TEXT + , like_number TEXT + , region TEXT + , contact_tel TEXT + , contact_email TEXT + , contact_address TEXT + , like_person TEXT + , alias TEXT + , industry TEXT + , sub_industry TEXT + , etl_tx_dt TIMESTAMP +) + + +SERVER pgsql_server_S98_S OPTIONS(schema_name 'data_api', table_name 'visits_ytd' ); + + + + + diff --git a/dev/workflow/TK_Cust/partner_one_site_file/visits_ytd/sa_tables.sql b/dev/workflow/TK_Cust/partner_one_site_file/visits_ytd/sa_tables.sql new file mode 100644 index 0000000..562c087 --- /dev/null +++ b/dev/workflow/TK_Cust/partner_one_site_file/visits_ytd/sa_tables.sql @@ -0,0 +1,107 @@ + +create table if not exists p10_sa.S98_S_visits_ytd ( + record_time TEXT + , visit_name TEXT + , agent_name TEXT + , cust_name TEXT + , contact_name TEXT + , contact_depart TEXT + , product_type TEXT + , intend_product TEXT + , regist_ind TEXT + , contact_info TEXT + , attachment TEXT + , visit_remark TEXT + , comment_number TEXT + , like_number TEXT + , region TEXT + , contact_tel TEXT + , contact_email TEXT + , contact_address TEXT + , like_person TEXT + , alias TEXT + , industry TEXT + , sub_industry TEXT + , etl_tx_dt TIMESTAMP +) ; + + COMMENT ON COLUMN p10_sa.S98_S_visits_ytd.record_time IS '录入时间'; + COMMENT ON COLUMN p10_sa.S98_S_visits_ytd.visit_name IS '拜访人'; + COMMENT ON COLUMN p10_sa.S98_S_visits_ytd.agent_name IS '代理商名称'; + COMMENT ON COLUMN p10_sa.S98_S_visits_ytd.cust_name IS '客户名称'; + COMMENT ON COLUMN p10_sa.S98_S_visits_ytd.contact_name IS '联系人姓名'; + COMMENT ON COLUMN p10_sa.S98_S_visits_ytd.contact_depart IS '联系人部门'; + COMMENT ON COLUMN p10_sa.S98_S_visits_ytd.product_type IS '产品分类'; + COMMENT ON COLUMN p10_sa.S98_S_visits_ytd.intend_product IS '意向产品'; + COMMENT ON COLUMN p10_sa.S98_S_visits_ytd.regist_ind IS '是否进入报备'; + COMMENT ON COLUMN p10_sa.S98_S_visits_ytd.contact_info IS '联络方式'; + COMMENT ON COLUMN p10_sa.S98_S_visits_ytd.attachment IS '附件'; + COMMENT ON COLUMN p10_sa.S98_S_visits_ytd.visit_remark IS '拜访备注'; + COMMENT ON COLUMN p10_sa.S98_S_visits_ytd.comment_number IS '评论数'; + COMMENT ON COLUMN p10_sa.S98_S_visits_ytd.like_number IS '点赞数'; + COMMENT ON COLUMN p10_sa.S98_S_visits_ytd.region IS '区域'; + COMMENT ON COLUMN p10_sa.S98_S_visits_ytd.contact_tel IS '联系人电话'; + COMMENT ON COLUMN p10_sa.S98_S_visits_ytd.contact_email IS '联系人邮箱'; + COMMENT ON COLUMN p10_sa.S98_S_visits_ytd.contact_address IS '联系人地址'; + COMMENT ON COLUMN p10_sa.S98_S_visits_ytd.like_person IS '点赞人姓名'; + COMMENT ON COLUMN p10_sa.S98_S_visits_ytd.alias IS '别名'; + COMMENT ON COLUMN p10_sa.S98_S_visits_ytd.industry IS '行业'; + COMMENT ON COLUMN p10_sa.S98_S_visits_ytd.sub_industry IS '子行业'; + COMMENT ON COLUMN p10_sa.S98_S_visits_ytd.etl_tx_dt IS ''; + +COMMENT ON TABLE p10_sa.S98_S_visits_ytd IS ''; + + + +create table if not exists p12_sfull.S98_S_visits_ytd ( + record_time TEXT + , visit_name TEXT + , agent_name TEXT + , cust_name TEXT + , contact_name TEXT + , contact_depart TEXT + , product_type TEXT + , intend_product TEXT + , regist_ind TEXT + , contact_info TEXT + , attachment TEXT + , visit_remark TEXT + , comment_number TEXT + , like_number TEXT + , region TEXT + , contact_tel TEXT + , contact_email TEXT + , contact_address TEXT + , like_person TEXT + , alias TEXT + , industry TEXT + , sub_industry TEXT + , etl_tx_dt TIMESTAMP +) ; + + COMMENT ON COLUMN p12_sfull.S98_S_visits_ytd.record_time IS '录入时间'; + COMMENT ON COLUMN p12_sfull.S98_S_visits_ytd.visit_name IS '拜访人'; + COMMENT ON COLUMN p12_sfull.S98_S_visits_ytd.agent_name IS '代理商名称'; + COMMENT ON COLUMN p12_sfull.S98_S_visits_ytd.cust_name IS '客户名称'; + COMMENT ON COLUMN p12_sfull.S98_S_visits_ytd.contact_name IS '联系人姓名'; + COMMENT ON COLUMN p12_sfull.S98_S_visits_ytd.contact_depart IS '联系人部门'; + COMMENT ON COLUMN p12_sfull.S98_S_visits_ytd.product_type IS '产品分类'; + COMMENT ON COLUMN p12_sfull.S98_S_visits_ytd.intend_product IS '意向产品'; + COMMENT ON COLUMN p12_sfull.S98_S_visits_ytd.regist_ind IS '是否进入报备'; + COMMENT ON COLUMN p12_sfull.S98_S_visits_ytd.contact_info IS '联络方式'; + COMMENT ON COLUMN p12_sfull.S98_S_visits_ytd.attachment IS '附件'; + COMMENT ON COLUMN p12_sfull.S98_S_visits_ytd.visit_remark IS '拜访备注'; + COMMENT ON COLUMN p12_sfull.S98_S_visits_ytd.comment_number IS '评论数'; + COMMENT ON COLUMN p12_sfull.S98_S_visits_ytd.like_number IS '点赞数'; + COMMENT ON COLUMN p12_sfull.S98_S_visits_ytd.region IS '区域'; + COMMENT ON COLUMN p12_sfull.S98_S_visits_ytd.contact_tel IS '联系人电话'; + COMMENT ON COLUMN p12_sfull.S98_S_visits_ytd.contact_email IS '联系人邮箱'; + COMMENT ON COLUMN p12_sfull.S98_S_visits_ytd.contact_address IS '联系人地址'; + COMMENT ON COLUMN p12_sfull.S98_S_visits_ytd.like_person IS '点赞人姓名'; + COMMENT ON COLUMN p12_sfull.S98_S_visits_ytd.alias IS '别名'; + COMMENT ON COLUMN p12_sfull.S98_S_visits_ytd.industry IS '行业'; + COMMENT ON COLUMN p12_sfull.S98_S_visits_ytd.sub_industry IS '子行业'; + COMMENT ON COLUMN p12_sfull.S98_S_visits_ytd.etl_tx_dt IS ''; + +COMMENT ON TABLE p12_sfull.S98_S_visits_ytd IS ''; +