From 87888de2e42d93d95e8b985a64fb0a93dd0aa6b3 Mon Sep 17 00:00:00 2001
From: root <root@64792e78fd4d>
Date: Thu, 7 Nov 2024 18:53:38 +0800
Subject: [PATCH] =?UTF-8?q?add=20workflow=20partner=E6=95=B0=E6=8D=AE?=
=?UTF-8?q?=E5=AF=BC=E5=85=A5,dev?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../wf_dag_partner_one_site_file.py | 34 ++-
.../S98_S_report_daily_checked.sql | 238 ++++++++++++++++++
.../sa_foreign_tables.sql | 66 +++++
.../report_daily_checked/sa_tables.sql | 235 +++++++++++++++++
.../S98_S_report_daily_completed.sql | 238 ++++++++++++++++++
.../sa_foreign_tables.sql | 66 +++++
.../report_daily_completed/sa_tables.sql | 235 +++++++++++++++++
.../visits_ytd/S98_S_visits_ytd.sql | 110 ++++++++
.../visits_ytd/sa_foreign_tables.sql | 34 +++
.../visits_ytd/sa_tables.sql | 107 ++++++++
10 files changed, 1360 insertions(+), 3 deletions(-)
create mode 100644 dev/workflow/TK_Cust/partner_one_site_file/report_daily_checked/S98_S_report_daily_checked.sql
create mode 100644 dev/workflow/TK_Cust/partner_one_site_file/report_daily_checked/sa_foreign_tables.sql
create mode 100644 dev/workflow/TK_Cust/partner_one_site_file/report_daily_checked/sa_tables.sql
create mode 100644 dev/workflow/TK_Cust/partner_one_site_file/report_daily_completed/S98_S_report_daily_completed.sql
create mode 100644 dev/workflow/TK_Cust/partner_one_site_file/report_daily_completed/sa_foreign_tables.sql
create mode 100644 dev/workflow/TK_Cust/partner_one_site_file/report_daily_completed/sa_tables.sql
create mode 100644 dev/workflow/TK_Cust/partner_one_site_file/visits_ytd/S98_S_visits_ytd.sql
create mode 100644 dev/workflow/TK_Cust/partner_one_site_file/visits_ytd/sa_foreign_tables.sql
create mode 100644 dev/workflow/TK_Cust/partner_one_site_file/visits_ytd/sa_tables.sql
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 '';
+