diff --git a/dev/workflow/TK_Cust/tk_crm/CRM销售机会/t01_crm_opportunity.sql b/dev/workflow/TK_Cust/tk_crm/CRM销售机会/t01_crm_opportunity.sql index 1f2cf06..c0e7edc 100644 --- a/dev/workflow/TK_Cust/tk_crm/CRM销售机会/t01_crm_opportunity.sql +++ b/dev/workflow/TK_Cust/tk_crm/CRM销售机会/t01_crm_opportunity.sql @@ -51,8 +51,6 @@ CREATE TABLE IF NOT EXISTS p20_pdm.t01_crm_opportunity ( , marketing_program_type varchar(100) , lead_number varchar(20) , crm_contact_number varchar(20) - , Scd_Start_Dt date - , Scd_End_Dt date , Etl_Batch_No varchar(50) , Etl_First_Dt timestamp(0) , Etl_Job varchar(50) @@ -60,7 +58,7 @@ CREATE TABLE IF NOT EXISTS p20_pdm.t01_crm_opportunity ( , Etl_Tx_Dt timestamp(0) , Src_Sysname varchar(50) , Src_Table varchar(50) - ,primary key( tek_opportunity_id,Scd_Start_Dt ) + ,primary key( tek_opportunity_id ) ); COMMENT ON COLUMN p20_pdm.t01_crm_opportunity.tek_opportunity_id IS '泰克机会编号'; @@ -113,8 +111,6 @@ CREATE TABLE IF NOT EXISTS p20_pdm.t01_crm_opportunity ( COMMENT ON COLUMN p20_pdm.t01_crm_opportunity.marketing_program_type IS '市场项目类型'; COMMENT ON COLUMN p20_pdm.t01_crm_opportunity.lead_number IS '线索编号'; COMMENT ON COLUMN p20_pdm.t01_crm_opportunity.crm_contact_number IS '联系人编号'; - COMMENT ON COLUMN p20_pdm.t01_crm_opportunity.Scd_Start_Dt IS '开始时间'; - COMMENT ON COLUMN p20_pdm.t01_crm_opportunity.Scd_End_Dt IS '结束时间'; COMMENT ON COLUMN p20_pdm.t01_crm_opportunity.Etl_Batch_No IS '作业批次号'; COMMENT ON COLUMN p20_pdm.t01_crm_opportunity.Etl_First_Dt IS '最初入库时间'; COMMENT ON COLUMN p20_pdm.t01_crm_opportunity.Etl_Job IS '作业名称'; diff --git a/dev/workflow/TK_Cust/tk_crm/CRM销售机会/t01_crm_opportunity_agi.sql b/dev/workflow/TK_Cust/tk_crm/CRM销售机会/t01_crm_opportunity_agi.sql index 22df2f0..ef2c6f6 100644 --- a/dev/workflow/TK_Cust/tk_crm/CRM销售机会/t01_crm_opportunity_agi.sql +++ b/dev/workflow/TK_Cust/tk_crm/CRM销售机会/t01_crm_opportunity_agi.sql @@ -4,7 +4,7 @@ /*Brilliance stems from wisdoms. */ /*************Head Section**************************************************************************/ /*Script Use: Periodically load data to :t01_crm_opportunity(CRM销售机会) */ -/*Create Date:2025-12-20 19:24:16 */ +/*Create Date:2025-12-20 19:33:31 */ /*SDM Developed By: dev */ /*SDM Developed Date: 2024-04-19 */ /*SDM Checked By: dev */ @@ -16,7 +16,7 @@ /*Target Table:t01_crm_opportunity */ /*ETL Job Name:t01_crm_opportunity */ /*ETL Frequency:Daily */ -/*ETL Policy:F5 */ +/*ETL Policy:F2 */ /********************************************************************************************/ /*******Main Section**************************************************************************/ \set ON_ERROR_STOP on @@ -37,17 +37,7 @@ CREATE TEMPORARY TABLE t01_crm_opportunity_agi_INS ( LIKE :PDMDB.t01_crm_opportunity) ON COMMIT PRESERVE ROWS; - /*创建临时表加载当前有效数据 */ -CREATE TEMPORARY TABLE t01_crm_opportunity_agi_CUR -( LIKE :PDMDB.t01_crm_opportunity) -ON COMMIT PRESERVE ROWS; - -/*创建临时表加载缺失数据 */ -CREATE TEMPORARY TABLE t01_crm_opportunity_agi_CUR_D -( LIKE :PDMDB.t01_crm_opportunity) -ON COMMIT PRESERVE ROWS; - - + /*****************************************************************************************************/ /* GROUP 1:Source Table:s98_s_crm_opp*****************************************************************/ /*****************************************************************************************************/ @@ -102,8 +92,6 @@ INSERT INTO t01_crm_opportunity_agi_CUR_I ( ,marketing_program_type /*市场项目类型*/ ,lead_number /*线索编号*/ ,crm_contact_number /*联系人编号*/ - ,Scd_Start_Dt /*开始时间*/ - ,Scd_End_Dt /*结束时间*/ ,Etl_Batch_No /*作业批次号*/ ,Etl_First_Dt /*最初入库时间*/ ,Etl_Job /*作业名称*/ @@ -163,8 +151,6 @@ SELECT ,COALESCE(TRIM(CAST(p0.tek_marketing_program_type_idname AS varchar(100))),'') /*marketing_program_type*/ ,COALESCE(TRIM(CAST(p0.tek_leadnumber AS varchar(20))),'') /*lead_number*/ ,COALESCE(TRIM(CAST(p0.tek_contactnumber AS varchar(20))),'') /*crm_contact_number*/ - ,TO_DATE(:TXDATE,'YYYYMMDD') /*Scd_Start_Dt*/ - ,TO_DATE(:MAXDATE,'YYYYMMDD') /*Scd_End_Dt*/ ,0 /*Etl_Batch_No*/ ,TO_DATE(:TXDATE,'YYYYMMDD') /*Etl_First_Dt*/ ,:ETLJOB /*Etl_Job*/ @@ -178,658 +164,412 @@ FROM p10_sa.s98_s_crm_opp p0 -/*避免同一天多次运行造成数据重复 */ - -DELETE FROM :PDMDB.t01_crm_opportunity -WHERE ETL_JOB=:ETLJOB -AND scd_End_Dt=TO_DATE(:MAXDATE,'YYYYMMDD') -AND scd_Start_Dt=TO_DATE(:TXDATE,'YYYYMMDD'); -UPDATE :PDMDB.t01_crm_opportunity -SET scd_End_Dt=TO_DATE(:MAXDATE,'YYYYMMDD') -WHERE ETL_JOB=:ETLJOB -AND scd_End_Dt=TO_DATE(:TXDATE,'YYYYMMDD'); - -/*往临时表插入当前数据。 */ -INSERT INTO t01_crm_opportunity_agi_CUR( - tek_opportunity_id /*泰克机会编号*/ - ,currency_name /*交易币种*/ - ,uint_price /*单价*/ - ,discount_percent /*折扣率*/ - ,discount_amount_base /*基础折扣金额*/ - ,base_amount /*基础金额*/ - ,total_amount /*总金额*/ - ,sales_funnel_stage /*销售漏斗层级*/ - ,sales_funnel_stage_id /*销售漏斗层级编号*/ - ,status /*状况*/ - ,state /*状态*/ - ,opportunity_name /*机会名称*/ - ,region /*区域*/ - ,acount_manager /*账号经理*/ - ,territory_id /*领域编号*/ - ,forecast_opp_ind /*预期机会标志*/ - ,risk_ind /*风险标志*/ - ,opportunity_age /*机会年份*/ - ,create_time /*创建时间*/ - ,create_person /*创建人*/ - ,pipline_last_update /*pipline最后更新时间*/ - ,status_last_update /*状况最后更新时间*/ - ,tektronix_apname /*tek_tektronixapname*/ - ,channel_id /*渠道编号*/ - ,purchase_method /*采购方式*/ - ,campaign_name /*活动名称*/ - ,web_medium /*网络媒介*/ - ,web_source /*网络来源*/ - ,customer_app /*客户应用*/ - ,vertical_segment /*垂直领域*/ - ,competitive_status /*竞争状态*/ - ,important_opportunity_ind /*重要机会标志*/ - ,application_name /*应用名称*/ - ,estimated_close_time /*预期关闭时间*/ - ,opp_industry /*行业（opp)*/ - ,tag_list /*标签列表*/ - ,discount_amount /*折扣金额*/ - ,area_id /*地区编号*/ - ,branch_id /*分支编号*/ - ,extension_id /*扩展编号*/ - ,legal_company_name /*法定公司名称*/ - ,account_number /*账号编号*/ - ,marketing_program_type /*市场项目类型*/ - ,lead_number /*线索编号*/ - ,actual_close_time /*实际关闭日期*/ - ,crm_contact_number /*联系人编号*/ - ,Scd_Start_Dt /*开始时间*/ - ,Scd_End_Dt /*结束时间*/ - ,Etl_Batch_No /*作业批次号*/ - ,Etl_First_Dt /*最初入库时间*/ - ,Etl_Job /*作业名称*/ - ,Etl_Proc_Dt /*本次入库时间*/ - ,Etl_Tx_Dt /*作业运行时间*/ - ,Src_Sysname /*来源系统*/ - ,Src_Table /*来源表*/ - ,parent_account_name /*父账号名称*/ - ,parent_contact_name /*父联系人名称*/ - ,product_name /*产品名称*/ - ,product_class /*产品类别*/ - ) -SELECT - P1.tek_opportunity_id /*泰克机会编号*/ - ,P1.currency_name /*交易币种*/ - ,P1.uint_price /*单价*/ - ,P1.discount_percent /*折扣率*/ - ,P1.discount_amount_base /*基础折扣金额*/ - ,P1.base_amount /*基础金额*/ - ,P1.total_amount /*总金额*/ - ,P1.sales_funnel_stage /*销售漏斗层级*/ - ,P1.sales_funnel_stage_id /*销售漏斗层级编号*/ - ,P1.status /*状况*/ - ,P1.state /*状态*/ - ,P1.opportunity_name /*机会名称*/ - ,P1.region /*区域*/ - ,P1.acount_manager /*账号经理*/ - ,P1.territory_id /*领域编号*/ - ,P1.forecast_opp_ind /*预期机会标志*/ - ,P1.risk_ind /*风险标志*/ - ,P1.opportunity_age /*机会年份*/ - ,P1.create_time /*创建时间*/ - ,P1.create_person /*创建人*/ - ,P1.pipline_last_update /*pipline最后更新时间*/ - ,P1.status_last_update /*状况最后更新时间*/ - ,P1.tektronix_apname /*tek_tektronixapname*/ - ,P1.channel_id /*渠道编号*/ - ,P1.purchase_method /*采购方式*/ - ,P1.campaign_name /*活动名称*/ - ,P1.web_medium /*网络媒介*/ - ,P1.web_source /*网络来源*/ - ,P1.customer_app /*客户应用*/ - ,P1.vertical_segment /*垂直领域*/ - ,P1.competitive_status /*竞争状态*/ - ,P1.important_opportunity_ind /*重要机会标志*/ - ,P1.application_name /*应用名称*/ - ,P1.estimated_close_time /*预期关闭时间*/ - ,P1.opp_industry /*行业（opp)*/ - ,P1.tag_list /*标签列表*/ - ,P1.discount_amount /*折扣金额*/ - ,P1.area_id /*地区编号*/ - ,P1.branch_id /*分支编号*/ - ,P1.extension_id /*扩展编号*/ - ,P1.legal_company_name /*法定公司名称*/ - ,P1.account_number /*账号编号*/ - ,P1.marketing_program_type /*市场项目类型*/ - ,P1.lead_number /*线索编号*/ - ,P1.actual_close_time /*实际关闭日期*/ - ,P1.crm_contact_number /*联系人编号*/ - ,P1.Scd_Start_Dt /*开始时间*/ - ,P1.Scd_End_Dt /*结束时间*/ - ,P1.Etl_Batch_No /*作业批次号*/ - ,P1.Etl_First_Dt /*最初入库时间*/ - ,P1.Etl_Job /*作业名称*/ - ,P1.Etl_Proc_Dt /*本次入库时间*/ - ,P1.Etl_Tx_Dt /*作业运行时间*/ - ,P1.Src_Sysname /*来源系统*/ - ,P1.Src_Table /*来源表*/ - ,P1.parent_account_name /*父账号名称*/ - ,P1.parent_contact_name /*父联系人名称*/ - ,P1.product_name /*产品名称*/ - ,P1.product_class /*产品类别*/ +/*将不同数据插入到临时表 */ +;INSERT INTO t01_crm_opportunity_agi_INS ( + opportunity_name /*机会名称*/ + ,tektronix_apname /*tek_tektronixapname*/ + ,estimated_close_time /*预期关闭时间*/ + ,actual_close_time /*实际关闭日期*/ + ,parent_account_name /*父账号名称*/ + ,parent_contact_name /*父联系人名称*/ + ,product_name /*产品名称*/ + ,product_class /*产品类别*/ + ,currency_name /*交易币种*/ + ,uint_price /*单价*/ + ,discount_percent /*折扣率*/ + ,discount_amount_base /*基础折扣金额*/ + ,base_amount /*基础金额*/ + ,total_amount /*总金额*/ + ,sales_funnel_stage /*销售漏斗层级*/ + ,sales_funnel_stage_id /*销售漏斗层级编号*/ + ,status /*状况*/ + ,state /*状态*/ + ,region /*区域*/ + ,acount_manager /*账号经理*/ + ,territory_id /*领域编号*/ + ,forecast_opp_ind /*预期机会标志*/ + ,risk_ind /*风险标志*/ + ,opportunity_age /*机会年份*/ + ,create_time /*创建时间*/ + ,create_person /*创建人*/ + ,pipline_last_update /*pipline最后更新时间*/ + ,status_last_update /*状况最后更新时间*/ + ,channel_id /*渠道编号*/ + ,purchase_method /*采购方式*/ + ,campaign_name /*活动名称*/ + ,web_medium /*网络媒介*/ + ,web_source /*网络来源*/ + ,customer_app /*客户应用*/ + ,vertical_segment /*垂直领域*/ + ,competitive_status /*竞争状态*/ + ,important_opportunity_ind /*重要机会标志*/ + ,application_name /*应用名称*/ + ,opp_industry /*行业（opp)*/ + ,tag_list /*标签列表*/ + ,discount_amount /*折扣金额*/ + ,area_id /*地区编号*/ + ,branch_id /*分支编号*/ + ,extension_id /*扩展编号*/ + ,legal_company_name /*法定公司名称*/ + ,account_number /*账号编号*/ + ,marketing_program_type /*市场项目类型*/ + ,lead_number /*线索编号*/ + ,crm_contact_number /*联系人编号*/ + ,tek_opportunity_id /*泰克机会编号*/ + ,Etl_Batch_No /*作业批次号*/ + ,Etl_First_Dt /*最初入库时间*/ + ,Etl_Job /*作业名称*/ + ,Etl_Proc_Dt /*本次入库时间*/ + ,Etl_Tx_Dt /*作业运行时间*/ + ,Src_Sysname /*来源系统*/ + ,Src_Table /*来源表*/ + +) + SELECT + P1.opportunity_name /*机会名称*/ + ,P1.tektronix_apname /*tek_tektronixapname*/ + ,P1.estimated_close_time /*预期关闭时间*/ + ,P1.actual_close_time /*实际关闭日期*/ + ,P1.parent_account_name /*父账号名称*/ + ,P1.parent_contact_name /*父联系人名称*/ + ,P1.product_name /*产品名称*/ + ,P1.product_class /*产品类别*/ + ,P1.currency_name /*交易币种*/ + ,P1.uint_price /*单价*/ + ,P1.discount_percent /*折扣率*/ + ,P1.discount_amount_base /*基础折扣金额*/ + ,P1.base_amount /*基础金额*/ + ,P1.total_amount /*总金额*/ + ,P1.sales_funnel_stage /*销售漏斗层级*/ + ,P1.sales_funnel_stage_id /*销售漏斗层级编号*/ + ,P1.status /*状况*/ + ,P1.state /*状态*/ + ,P1.region /*区域*/ + ,P1.acount_manager /*账号经理*/ + ,P1.territory_id /*领域编号*/ + ,P1.forecast_opp_ind /*预期机会标志*/ + ,P1.risk_ind /*风险标志*/ + ,P1.opportunity_age /*机会年份*/ + ,P1.create_time /*创建时间*/ + ,P1.create_person /*创建人*/ + ,P1.pipline_last_update /*pipline最后更新时间*/ + ,P1.status_last_update /*状况最后更新时间*/ + ,P1.channel_id /*渠道编号*/ + ,P1.purchase_method /*采购方式*/ + ,P1.campaign_name /*活动名称*/ + ,P1.web_medium /*网络媒介*/ + ,P1.web_source /*网络来源*/ + ,P1.customer_app /*客户应用*/ + ,P1.vertical_segment /*垂直领域*/ + ,P1.competitive_status /*竞争状态*/ + ,P1.important_opportunity_ind /*重要机会标志*/ + ,P1.application_name /*应用名称*/ + ,P1.opp_industry /*行业（opp)*/ + ,P1.tag_list /*标签列表*/ + ,P1.discount_amount /*折扣金额*/ + ,P1.area_id /*地区编号*/ + ,P1.branch_id /*分支编号*/ + ,P1.extension_id /*扩展编号*/ + ,P1.legal_company_name /*法定公司名称*/ + ,P1.account_number /*账号编号*/ + ,P1.marketing_program_type /*市场项目类型*/ + ,P1.lead_number /*线索编号*/ + ,P1.crm_contact_number /*联系人编号*/ + ,P1.tek_opportunity_id /*泰克机会编号*/ + ,P1.Etl_Batch_No /*作业批次号*/ + ,P1.Etl_First_Dt /*最初入库时间*/ + ,P1.Etl_Job /*作业名称*/ + ,P1.Etl_Proc_Dt /*本次入库时间*/ + ,P1.Etl_Tx_Dt /*作业运行时间*/ + ,P1.Src_Sysname /*来源系统*/ + ,P1.Src_Table /*来源表*/ + +FROM t01_crm_opportunity_agi_CUR_I P1 +LEFT JOIN :PDMDB.t01_crm_opportunity P2 +ON P1.opportunity_name = P2.opportunity_name + AND P1.tektronix_apname = P2.tektronix_apname + AND P1.estimated_close_time = P2.estimated_close_time + AND P1.actual_close_time = P2.actual_close_time + AND P1.parent_account_name = P2.parent_account_name + AND P1.parent_contact_name = P2.parent_contact_name + AND P1.product_name = P2.product_name + AND P1.product_class = P2.product_class + AND P1.currency_name = P2.currency_name + AND P1.uint_price = P2.uint_price + AND P1.discount_percent = P2.discount_percent + AND P1.discount_amount_base = P2.discount_amount_base + AND P1.base_amount = P2.base_amount + AND P1.total_amount = P2.total_amount + AND P1.sales_funnel_stage = P2.sales_funnel_stage + AND P1.sales_funnel_stage_id = P2.sales_funnel_stage_id + AND P1.status = P2.status + AND P1.state = P2.state + AND P1.region = P2.region + AND P1.acount_manager = P2.acount_manager + AND P1.territory_id = P2.territory_id + AND P1.forecast_opp_ind = P2.forecast_opp_ind + AND P1.risk_ind = P2.risk_ind + AND P1.opportunity_age = P2.opportunity_age + AND P1.create_time = P2.create_time + AND P1.create_person = P2.create_person + AND P1.pipline_last_update = P2.pipline_last_update + AND P1.status_last_update = P2.status_last_update + AND P1.channel_id = P2.channel_id + AND P1.purchase_method = P2.purchase_method + AND P1.campaign_name = P2.campaign_name + AND P1.web_medium = P2.web_medium + AND P1.web_source = P2.web_source + AND P1.customer_app = P2.customer_app + AND P1.vertical_segment = P2.vertical_segment + AND P1.competitive_status = P2.competitive_status + AND P1.important_opportunity_ind = P2.important_opportunity_ind + AND P1.application_name = P2.application_name + AND P1.opp_industry = P2.opp_industry + AND P1.tag_list = P2.tag_list + AND P1.discount_amount = P2.discount_amount + AND P1.area_id = P2.area_id + AND P1.branch_id = P2.branch_id + AND P1.extension_id = P2.extension_id + AND P1.legal_company_name = P2.legal_company_name + AND P1.account_number = P2.account_number + AND P1.marketing_program_type = P2.marketing_program_type + AND P1.lead_number = P2.lead_number + AND P1.crm_contact_number = P2.crm_contact_number + AND P1.tek_opportunity_id = P2.tek_opportunity_id -FROM :PDMDB.t01_crm_opportunity P1 -WHERE P1.Scd_End_Dt = TO_DATE(:MAXDATE,'YYYYMMDD') - AND P1.ETL_Job = :ETLJOB - ; -/*"今日数据"与"当前有效数据"进行比较找出新增及更新的数据，比对条件是：除去开始日期和结束日期的所有 */ -/*字段。 */ -INSERT INTO t01_crm_opportunity_agi_INS( - tek_opportunity_id /*泰克机会编号*/ - , currency_name /*交易币种*/ - , uint_price /*单价*/ - , discount_percent /*折扣率*/ - , discount_amount_base /*基础折扣金额*/ - , base_amount /*基础金额*/ - , total_amount /*总金额*/ - , sales_funnel_stage /*销售漏斗层级*/ - , sales_funnel_stage_id /*销售漏斗层级编号*/ - , status /*状况*/ - , state /*状态*/ - , opportunity_name /*机会名称*/ - , region /*区域*/ - , acount_manager /*账号经理*/ - , territory_id /*领域编号*/ - , forecast_opp_ind /*预期机会标志*/ - , risk_ind /*风险标志*/ - , opportunity_age /*机会年份*/ - , create_time /*创建时间*/ - , create_person /*创建人*/ - , pipline_last_update /*pipline最后更新时间*/ - , status_last_update /*状况最后更新时间*/ - , tektronix_apname /*tek_tektronixapname*/ - , channel_id /*渠道编号*/ - , purchase_method /*采购方式*/ - , campaign_name /*活动名称*/ - , web_medium /*网络媒介*/ - , web_source /*网络来源*/ - , customer_app /*客户应用*/ - , vertical_segment /*垂直领域*/ - , competitive_status /*竞争状态*/ - , important_opportunity_ind /*重要机会标志*/ - , application_name /*应用名称*/ - , estimated_close_time /*预期关闭时间*/ - , opp_industry /*行业（opp)*/ - , tag_list /*标签列表*/ - , discount_amount /*折扣金额*/ - , area_id /*地区编号*/ - , branch_id /*分支编号*/ - , extension_id /*扩展编号*/ - , legal_company_name /*法定公司名称*/ - , account_number /*账号编号*/ - , marketing_program_type /*市场项目类型*/ - , lead_number /*线索编号*/ - , actual_close_time /*实际关闭日期*/ - , crm_contact_number /*联系人编号*/ - , Scd_Start_Dt /*开始时间*/ - , Scd_End_Dt /*结束时间*/ - , Etl_Batch_No /*作业批次号*/ - , Etl_First_Dt /*最初入库时间*/ - , Etl_Job /*作业名称*/ - , Etl_Proc_Dt /*本次入库时间*/ - , Etl_Tx_Dt /*作业运行时间*/ - , Src_Sysname /*来源系统*/ - , Src_Table /*来源表*/ - , parent_account_name /*父账号名称*/ - , parent_contact_name /*父联系人名称*/ - , product_name /*产品名称*/ - , product_class /*产品类别*/ - ) -SELECT - P1.tek_opportunity_id /*泰克机会编号*/ - , P1.currency_name /*交易币种*/ - , P1.uint_price /*单价*/ - , P1.discount_percent /*折扣率*/ - , P1.discount_amount_base /*基础折扣金额*/ - , P1.base_amount /*基础金额*/ - , P1.total_amount /*总金额*/ - , P1.sales_funnel_stage /*销售漏斗层级*/ - , P1.sales_funnel_stage_id /*销售漏斗层级编号*/ - , P1.status /*状况*/ - , P1.state /*状态*/ - , P1.opportunity_name /*机会名称*/ - , P1.region /*区域*/ - , P1.acount_manager /*账号经理*/ - , P1.territory_id /*领域编号*/ - , P1.forecast_opp_ind /*预期机会标志*/ - , P1.risk_ind /*风险标志*/ - , P1.opportunity_age /*机会年份*/ - , P1.create_time /*创建时间*/ - , P1.create_person /*创建人*/ - , P1.pipline_last_update /*pipline最后更新时间*/ - , P1.status_last_update /*状况最后更新时间*/ - , P1.tektronix_apname /*tek_tektronixapname*/ - , P1.channel_id /*渠道编号*/ - , P1.purchase_method /*采购方式*/ - , P1.campaign_name /*活动名称*/ - , P1.web_medium /*网络媒介*/ - , P1.web_source /*网络来源*/ - , P1.customer_app /*客户应用*/ - , P1.vertical_segment /*垂直领域*/ - , P1.competitive_status /*竞争状态*/ - , P1.important_opportunity_ind /*重要机会标志*/ - , P1.application_name /*应用名称*/ - , P1.estimated_close_time /*预期关闭时间*/ - , P1.opp_industry /*行业（opp)*/ - , P1.tag_list /*标签列表*/ - , P1.discount_amount /*折扣金额*/ - , P1.area_id /*地区编号*/ - , P1.branch_id /*分支编号*/ - , P1.extension_id /*扩展编号*/ - , P1.legal_company_name /*法定公司名称*/ - , P1.account_number /*账号编号*/ - , P1.marketing_program_type /*市场项目类型*/ - , P1.lead_number /*线索编号*/ - , P1.actual_close_time /*实际关闭日期*/ - , P1.crm_contact_number /*联系人编号*/ - , P1.Scd_Start_Dt /*开始时间*/ - , P1.Scd_End_Dt /*结束时间*/ - , P1.Etl_Batch_No /*作业批次号*/ - , P1.Etl_First_Dt /*最初入库时间*/ - , P1.Etl_Job /*作业名称*/ - , P1.Etl_Proc_Dt /*本次入库时间*/ - , P1.Etl_Tx_Dt /*作业运行时间*/ - , P1.Src_Sysname /*来源系统*/ - , P1.Src_Table /*来源表*/ - , P1.parent_account_name /*父账号名称*/ - , P1.parent_contact_name /*父联系人名称*/ - , P1.product_name /*产品名称*/ - , P1.product_class /*产品类别*/ +WHERE P2.opportunity_name IS NULL + OR P2.tektronix_apname IS NULL + OR P2.estimated_close_time IS NULL + OR P2.actual_close_time IS NULL + OR P2.parent_account_name IS NULL + OR P2.parent_contact_name IS NULL + OR P2.product_name IS NULL + OR P2.product_class IS NULL + OR P2.currency_name IS NULL + OR P2.uint_price IS NULL + OR P2.discount_percent IS NULL + OR P2.discount_amount_base IS NULL + OR P2.base_amount IS NULL + OR P2.total_amount IS NULL + OR P2.sales_funnel_stage IS NULL + OR P2.sales_funnel_stage_id IS NULL + OR P2.status IS NULL + OR P2.state IS NULL + OR P2.region IS NULL + OR P2.acount_manager IS NULL + OR P2.territory_id IS NULL + OR P2.forecast_opp_ind IS NULL + OR P2.risk_ind IS NULL + OR P2.opportunity_age IS NULL + OR P2.create_time IS NULL + OR P2.create_person IS NULL + OR P2.pipline_last_update IS NULL + OR P2.status_last_update IS NULL + OR P2.channel_id IS NULL + OR P2.purchase_method IS NULL + OR P2.campaign_name IS NULL + OR P2.web_medium IS NULL + OR P2.web_source IS NULL + OR P2.customer_app IS NULL + OR P2.vertical_segment IS NULL + OR P2.competitive_status IS NULL + OR P2.important_opportunity_ind IS NULL + OR P2.application_name IS NULL + OR P2.opp_industry IS NULL + OR P2.tag_list IS NULL + OR P2.discount_amount IS NULL + OR P2.area_id IS NULL + OR P2.branch_id IS NULL + OR P2.extension_id IS NULL + OR P2.legal_company_name IS NULL + OR P2.account_number IS NULL + OR P2.marketing_program_type IS NULL + OR P2.lead_number IS NULL + OR P2.crm_contact_number IS NULL + OR P2.tek_opportunity_id IS NULL -FROM t01_crm_opportunity_agi_CUR_I P1 -LEFT JOIN t01_crm_opportunity_agi_CUR P2 - ON P1.tek_opportunity_id = P2.tek_opportunity_id - AND P1.opportunity_name = P2.opportunity_name - AND P1.tektronix_apname = P2.tektronix_apname - AND P1.estimated_close_time = P2.estimated_close_time - AND P1.actual_close_time = P2.actual_close_time - AND P1.parent_account_name = P2.parent_account_name - AND P1.parent_contact_name = P2.parent_contact_name - AND P1.product_name = P2.product_name - AND P1.product_class = P2.product_class - AND P1.currency_name = P2.currency_name - AND P1.uint_price = P2.uint_price - AND P1.discount_percent = P2.discount_percent - AND P1.discount_amount_base = P2.discount_amount_base - AND P1.base_amount = P2.base_amount - AND P1.total_amount = P2.total_amount - AND P1.sales_funnel_stage = P2.sales_funnel_stage - AND P1.sales_funnel_stage_id = P2.sales_funnel_stage_id - AND P1.status = P2.status - AND P1.state = P2.state - AND P1.region = P2.region - AND P1.acount_manager = P2.acount_manager - AND P1.territory_id = P2.territory_id - AND P1.forecast_opp_ind = P2.forecast_opp_ind - AND P1.risk_ind = P2.risk_ind - AND P1.opportunity_age = P2.opportunity_age - AND P1.create_time = P2.create_time - AND P1.create_person = P2.create_person - AND P1.pipline_last_update = P2.pipline_last_update - AND P1.status_last_update = P2.status_last_update - AND P1.channel_id = P2.channel_id - AND P1.purchase_method = P2.purchase_method - AND P1.campaign_name = P2.campaign_name - AND P1.web_medium = P2.web_medium - AND P1.web_source = P2.web_source - AND P1.customer_app = P2.customer_app - AND P1.vertical_segment = P2.vertical_segment - AND P1.competitive_status = P2.competitive_status - AND P1.important_opportunity_ind = P2.important_opportunity_ind - AND P1.application_name = P2.application_name - AND P1.opp_industry = P2.opp_industry - AND P1.tag_list = P2.tag_list - AND P1.discount_amount = P2.discount_amount - AND P1.area_id = P2.area_id - AND P1.branch_id = P2.branch_id - AND P1.extension_id = P2.extension_id - AND P1.legal_company_name = P2.legal_company_name - AND P1.account_number = P2.account_number - AND P1.marketing_program_type = P2.marketing_program_type - AND P1.lead_number = P2.lead_number - AND P1.crm_contact_number = P2.crm_contact_number - AND P2.ETL_Job =:ETLJOB -WHERE - P2.tek_opportunity_id IS NULL - AND P2.Scd_Start_Dt IS NULL - AND P2.opportunity_name IS NULL - AND P2.tektronix_apname IS NULL - AND P2.estimated_close_time IS NULL - AND P2.actual_close_time IS NULL - AND P2.parent_account_name IS NULL - AND P2.parent_contact_name IS NULL - AND P2.product_name IS NULL - AND P2.product_class IS NULL - AND P2.currency_name IS NULL - AND P2.uint_price IS NULL - AND P2.discount_percent IS NULL - AND P2.discount_amount_base IS NULL - AND P2.base_amount IS NULL - AND P2.total_amount IS NULL - AND P2.sales_funnel_stage IS NULL - AND P2.sales_funnel_stage_id IS NULL - AND P2.status IS NULL - AND P2.state IS NULL - AND P2.region IS NULL - AND P2.acount_manager IS NULL - AND P2.territory_id IS NULL - AND P2.forecast_opp_ind IS NULL - AND P2.risk_ind IS NULL - AND P2.opportunity_age IS NULL - AND P2.create_time IS NULL - AND P2.create_person IS NULL - AND P2.pipline_last_update IS NULL - AND P2.status_last_update IS NULL - AND P2.channel_id IS NULL - AND P2.purchase_method IS NULL - AND P2.campaign_name IS NULL - AND P2.web_medium IS NULL - AND P2.web_source IS NULL - AND P2.customer_app IS NULL - AND P2.vertical_segment IS NULL - AND P2.competitive_status IS NULL - AND P2.important_opportunity_ind IS NULL - AND P2.application_name IS NULL - AND P2.opp_industry IS NULL - AND P2.tag_list IS NULL - AND P2.discount_amount IS NULL - AND P2.area_id IS NULL - AND P2.branch_id IS NULL - AND P2.extension_id IS NULL - AND P2.legal_company_name IS NULL - AND P2.account_number IS NULL - AND P2.marketing_program_type IS NULL - AND P2.lead_number IS NULL - AND P2.crm_contact_number IS NULL - -; - - -INSERT INTO t01_crm_opportunity_agi_CUR_D ( - tek_opportunity_id /*泰克机会编号*/ - , currency_name /*交易币种*/ - , uint_price /*单价*/ - , discount_percent /*折扣率*/ - , discount_amount_base /*基础折扣金额*/ - , base_amount /*基础金额*/ - , total_amount /*总金额*/ - , sales_funnel_stage /*销售漏斗层级*/ - , sales_funnel_stage_id /*销售漏斗层级编号*/ - , status /*状况*/ - , state /*状态*/ - , opportunity_name /*机会名称*/ - , region /*区域*/ - , acount_manager /*账号经理*/ - , territory_id /*领域编号*/ - , forecast_opp_ind /*预期机会标志*/ - , risk_ind /*风险标志*/ - , opportunity_age /*机会年份*/ - , create_time /*创建时间*/ - , create_person /*创建人*/ - , pipline_last_update /*pipline最后更新时间*/ - , status_last_update /*状况最后更新时间*/ - , tektronix_apname /*tek_tektronixapname*/ - , channel_id /*渠道编号*/ - , purchase_method /*采购方式*/ - , campaign_name /*活动名称*/ - , web_medium /*网络媒介*/ - , web_source /*网络来源*/ - , customer_app /*客户应用*/ - , vertical_segment /*垂直领域*/ - , competitive_status /*竞争状态*/ - , important_opportunity_ind /*重要机会标志*/ - , application_name /*应用名称*/ - , estimated_close_time /*预期关闭时间*/ - , opp_industry /*行业（opp)*/ - , tag_list /*标签列表*/ - , discount_amount /*折扣金额*/ - , area_id /*地区编号*/ - , branch_id /*分支编号*/ - , extension_id /*扩展编号*/ - , legal_company_name /*法定公司名称*/ - , account_number /*账号编号*/ - , marketing_program_type /*市场项目类型*/ - , lead_number /*线索编号*/ - , actual_close_time /*实际关闭日期*/ - , crm_contact_number /*联系人编号*/ - , Scd_Start_Dt /*开始时间*/ - , Scd_End_Dt /*结束时间*/ - , Etl_Batch_No /*作业批次号*/ - , Etl_First_Dt /*最初入库时间*/ - , Etl_Job /*作业名称*/ - , Etl_Proc_Dt /*本次入库时间*/ - , Etl_Tx_Dt /*作业运行时间*/ - , Src_Sysname /*来源系统*/ - , Src_Table /*来源表*/ - , parent_account_name /*父账号名称*/ - , parent_contact_name /*父联系人名称*/ - , product_name /*产品名称*/ - , product_class /*产品类别*/ - ) -SELECT - P1.tek_opportunity_id /*泰克机会编号*/ - , P1.currency_name /*交易币种*/ - , P1.uint_price /*单价*/ - , P1.discount_percent /*折扣率*/ - , P1.discount_amount_base /*基础折扣金额*/ - , P1.base_amount /*基础金额*/ - , P1.total_amount /*总金额*/ - , P1.sales_funnel_stage /*销售漏斗层级*/ - , P1.sales_funnel_stage_id /*销售漏斗层级编号*/ - , P1.status /*状况*/ - , P1.state /*状态*/ - , P1.opportunity_name /*机会名称*/ - , P1.region /*区域*/ - , P1.acount_manager /*账号经理*/ - , P1.territory_id /*领域编号*/ - , P1.forecast_opp_ind /*预期机会标志*/ - , P1.risk_ind /*风险标志*/ - , P1.opportunity_age /*机会年份*/ - , P1.create_time /*创建时间*/ - , P1.create_person /*创建人*/ - , P1.pipline_last_update /*pipline最后更新时间*/ - , P1.status_last_update /*状况最后更新时间*/ - , P1.tektronix_apname /*tek_tektronixapname*/ - , P1.channel_id /*渠道编号*/ - , P1.purchase_method /*采购方式*/ - , P1.campaign_name /*活动名称*/ - , P1.web_medium /*网络媒介*/ - , P1.web_source /*网络来源*/ - , P1.customer_app /*客户应用*/ - , P1.vertical_segment /*垂直领域*/ - , P1.competitive_status /*竞争状态*/ - , P1.important_opportunity_ind /*重要机会标志*/ - , P1.application_name /*应用名称*/ - , P1.estimated_close_time /*预期关闭时间*/ - , P1.opp_industry /*行业（opp)*/ - , P1.tag_list /*标签列表*/ - , P1.discount_amount /*折扣金额*/ - , P1.area_id /*地区编号*/ - , P1.branch_id /*分支编号*/ - , P1.extension_id /*扩展编号*/ - , P1.legal_company_name /*法定公司名称*/ - , P1.account_number /*账号编号*/ - , P1.marketing_program_type /*市场项目类型*/ - , P1.lead_number /*线索编号*/ - , P1.actual_close_time /*实际关闭日期*/ - , P1.crm_contact_number /*联系人编号*/ - , P1.Scd_Start_Dt /*开始时间*/ - , P1.Scd_End_Dt /*结束时间*/ - , P1.Etl_Batch_No /*作业批次号*/ - , P1.Etl_First_Dt /*最初入库时间*/ - , P1.Etl_Job /*作业名称*/ - , P1.Etl_Proc_Dt /*本次入库时间*/ - , P1.Etl_Tx_Dt /*作业运行时间*/ - , P1.Src_Sysname /*来源系统*/ - , P1.Src_Table /*来源表*/ - , P1.parent_account_name /*父账号名称*/ - , P1.parent_contact_name /*父联系人名称*/ - , P1.product_name /*产品名称*/ - , P1.product_class /*产品类别*/ - -FROM t01_crm_opportunity_agi_CUR_I P1 -LEFT JOIN t01_crm_opportunity_agi_CUR P2 -ON P1.tek_opportunity_id = P2.tek_opportunity_id -WHERE P2.tek_opportunity_id IS NULL -AND P2.Scd_End_Dt = TO_DATE(:MAXDATE,'YYYYMMDD') -AND P2.ETL_Job = :ETLJOB -; - - -/*更新目标表中数据,对更新的数据进行封口,即置结束日期为TX_DATE */ -UPDATE :PDMDB.t01_crm_opportunity - SET Scd_End_Dt = TO_DATE(:TXDATE,'YYYYMMDD') - ,Etl_Tx_Dt=:TXDATE - ,Etl_Proc_Dt=CURRENT_TIMESTAMP(0) -WHERE Scd_End_Dt = TO_DATE(:MAXDATE, 'YYYYMMDD') - AND (:PDMDB.t01_crm_opportunity.ETL_Job = :ETLJOB) - AND ( tek_opportunity_id) -IN (SELECT tek_opportunity_id - FROM t01_crm_opportunity_agi_INS) - -/*根据比对条件将目标表中删除数据进行相应的处理 */ -;UPDATE :PDMDB.t01_crm_opportunity - SET Scd_End_Dt= TO_DATE(:TXDATE, 'YYYYMMDD') - ,Etl_Tx_Dt=:TXDATE - ,ETL_Proc_Dt=CURRENT_TIMESTAMP(0) - WHERE Scd_End_Dt=TO_DATE(:MAXDATE,'YYYYMMDD') - AND (:PDMDB.t01_crm_opportunity.ETL_Job = :ETLJOB) - AND ( tek_opportunity_id) -IN (SELECT - tek_opportunity_id -FROM t01_crm_opportunity_agi_CUR_D) -/*然后将新增的数据插入到目标表中，置开始日期为TX_DATE，结束日期置为MAXDATE */ +; +/*将新增数据插入到目标表 */ ;INSERT INTO :PDMDB.t01_crm_opportunity ( - tek_opportunity_id /*泰克机会编号*/ - ,currency_name /*交易币种*/ - ,uint_price /*单价*/ - ,discount_percent /*折扣率*/ - ,discount_amount_base /*基础折扣金额*/ - ,base_amount /*基础金额*/ - ,total_amount /*总金额*/ - ,sales_funnel_stage /*销售漏斗层级*/ - ,sales_funnel_stage_id /*销售漏斗层级编号*/ - ,status /*状况*/ - ,state /*状态*/ - ,opportunity_name /*机会名称*/ - ,region /*区域*/ - ,acount_manager /*账号经理*/ - ,territory_id /*领域编号*/ - ,forecast_opp_ind /*预期机会标志*/ - ,risk_ind /*风险标志*/ - ,opportunity_age /*机会年份*/ - ,create_time /*创建时间*/ - ,create_person /*创建人*/ - ,pipline_last_update /*pipline最后更新时间*/ - ,status_last_update /*状况最后更新时间*/ - ,tektronix_apname /*tek_tektronixapname*/ - ,channel_id /*渠道编号*/ - ,purchase_method /*采购方式*/ - ,campaign_name /*活动名称*/ - ,web_medium /*网络媒介*/ - ,web_source /*网络来源*/ - ,customer_app /*客户应用*/ - ,vertical_segment /*垂直领域*/ - ,competitive_status /*竞争状态*/ - ,important_opportunity_ind /*重要机会标志*/ - ,application_name /*应用名称*/ - ,estimated_close_time /*预期关闭时间*/ - ,opp_industry /*行业（opp)*/ - ,tag_list /*标签列表*/ - ,discount_amount /*折扣金额*/ - ,area_id /*地区编号*/ - ,branch_id /*分支编号*/ - ,extension_id /*扩展编号*/ - ,legal_company_name /*法定公司名称*/ - ,account_number /*账号编号*/ - ,marketing_program_type /*市场项目类型*/ - ,lead_number /*线索编号*/ - ,actual_close_time /*实际关闭日期*/ - ,crm_contact_number /*联系人编号*/ - ,Scd_Start_Dt /*开始时间*/ - ,Scd_End_Dt /*结束时间*/ - ,Etl_Batch_No /*作业批次号*/ - ,Etl_First_Dt /*最初入库时间*/ - ,Etl_Job /*作业名称*/ - ,Etl_Proc_Dt /*本次入库时间*/ - ,Etl_Tx_Dt /*作业运行时间*/ - ,Src_Sysname /*来源系统*/ - ,Src_Table /*来源表*/ - ,parent_account_name /*父账号名称*/ - ,parent_contact_name /*父联系人名称*/ - ,product_name /*产品名称*/ - ,product_class /*产品类别*/ - ) + opportunity_name /*机会名称*/ + ,tektronix_apname /*tek_tektronixapname*/ + ,estimated_close_time /*预期关闭时间*/ + ,actual_close_time /*实际关闭日期*/ + ,parent_account_name /*父账号名称*/ + ,parent_contact_name /*父联系人名称*/ + ,product_name /*产品名称*/ + ,product_class /*产品类别*/ + ,currency_name /*交易币种*/ + ,uint_price /*单价*/ + ,discount_percent /*折扣率*/ + ,discount_amount_base /*基础折扣金额*/ + ,base_amount /*基础金额*/ + ,total_amount /*总金额*/ + ,sales_funnel_stage /*销售漏斗层级*/ + ,sales_funnel_stage_id /*销售漏斗层级编号*/ + ,status /*状况*/ + ,state /*状态*/ + ,region /*区域*/ + ,acount_manager /*账号经理*/ + ,territory_id /*领域编号*/ + ,forecast_opp_ind /*预期机会标志*/ + ,risk_ind /*风险标志*/ + ,opportunity_age /*机会年份*/ + ,create_time /*创建时间*/ + ,create_person /*创建人*/ + ,pipline_last_update /*pipline最后更新时间*/ + ,status_last_update /*状况最后更新时间*/ + ,channel_id /*渠道编号*/ + ,purchase_method /*采购方式*/ + ,campaign_name /*活动名称*/ + ,web_medium /*网络媒介*/ + ,web_source /*网络来源*/ + ,customer_app /*客户应用*/ + ,vertical_segment /*垂直领域*/ + ,competitive_status /*竞争状态*/ + ,important_opportunity_ind /*重要机会标志*/ + ,application_name /*应用名称*/ + ,opp_industry /*行业（opp)*/ + ,tag_list /*标签列表*/ + ,discount_amount /*折扣金额*/ + ,area_id /*地区编号*/ + ,branch_id /*分支编号*/ + ,extension_id /*扩展编号*/ + ,legal_company_name /*法定公司名称*/ + ,account_number /*账号编号*/ + ,marketing_program_type /*市场项目类型*/ + ,lead_number /*线索编号*/ + ,crm_contact_number /*联系人编号*/ + ,tek_opportunity_id /*泰克机会编号*/ + ,Etl_Batch_No /*作业批次号*/ + ,Etl_First_Dt /*最初入库时间*/ + ,Etl_Job /*作业名称*/ + ,Etl_Proc_Dt /*本次入库时间*/ + ,Etl_Tx_Dt /*作业运行时间*/ + ,Src_Sysname /*来源系统*/ + ,Src_Table /*来源表*/ + +) SELECT - P1.tek_opportunity_id /*泰克机会编号*/ - ,P1.currency_name /*交易币种*/ - ,P1.uint_price /*单价*/ - ,P1.discount_percent /*折扣率*/ - ,P1.discount_amount_base /*基础折扣金额*/ - ,P1.base_amount /*基础金额*/ - ,P1.total_amount /*总金额*/ - ,P1.sales_funnel_stage /*销售漏斗层级*/ - ,P1.sales_funnel_stage_id /*销售漏斗层级编号*/ - ,P1.status /*状况*/ - ,P1.state /*状态*/ - ,P1.opportunity_name /*机会名称*/ - ,P1.region /*区域*/ - ,P1.acount_manager /*账号经理*/ - ,P1.territory_id /*领域编号*/ - ,P1.forecast_opp_ind /*预期机会标志*/ - ,P1.risk_ind /*风险标志*/ - ,P1.opportunity_age /*机会年份*/ - ,P1.create_time /*创建时间*/ - ,P1.create_person /*创建人*/ - ,P1.pipline_last_update /*pipline最后更新时间*/ - ,P1.status_last_update /*状况最后更新时间*/ - ,P1.tektronix_apname /*tek_tektronixapname*/ - ,P1.channel_id /*渠道编号*/ - ,P1.purchase_method /*采购方式*/ - ,P1.campaign_name /*活动名称*/ - ,P1.web_medium /*网络媒介*/ - ,P1.web_source /*网络来源*/ - ,P1.customer_app /*客户应用*/ - ,P1.vertical_segment /*垂直领域*/ - ,P1.competitive_status /*竞争状态*/ - ,P1.important_opportunity_ind /*重要机会标志*/ - ,P1.application_name /*应用名称*/ - ,P1.estimated_close_time /*预期关闭时间*/ - ,P1.opp_industry /*行业（opp)*/ - ,P1.tag_list /*标签列表*/ - ,P1.discount_amount /*折扣金额*/ - ,P1.area_id /*地区编号*/ - ,P1.branch_id /*分支编号*/ - ,P1.extension_id /*扩展编号*/ - ,P1.legal_company_name /*法定公司名称*/ - ,P1.account_number /*账号编号*/ - ,P1.marketing_program_type /*市场项目类型*/ - ,P1.lead_number /*线索编号*/ - ,P1.actual_close_time /*实际关闭日期*/ - ,P1.crm_contact_number /*联系人编号*/ - ,P1.Scd_Start_Dt /*开始时间*/ - ,P1.Scd_End_Dt /*结束时间*/ - ,P1.Etl_Batch_No /*作业批次号*/ - ,P1.Etl_First_Dt /*最初入库时间*/ - ,P1.Etl_Job /*作业名称*/ - ,P1.Etl_Proc_Dt /*本次入库时间*/ - ,P1.Etl_Tx_Dt /*作业运行时间*/ - ,P1.Src_Sysname /*来源系统*/ - ,P1.Src_Table /*来源表*/ - ,P1.parent_account_name /*父账号名称*/ - ,P1.parent_contact_name /*父联系人名称*/ - ,P1.product_name /*产品名称*/ - ,P1.product_class /*产品类别*/ - -FROM t01_crm_opportunity_agi_INS P1 -; - - -; + P1.opportunity_name /*机会名称*/ + ,P1.tektronix_apname /*tek_tektronixapname*/ + ,P1.estimated_close_time /*预期关闭时间*/ + ,P1.actual_close_time /*实际关闭日期*/ + ,P1.parent_account_name /*父账号名称*/ + ,P1.parent_contact_name /*父联系人名称*/ + ,P1.product_name /*产品名称*/ + ,P1.product_class /*产品类别*/ + ,P1.currency_name /*交易币种*/ + ,P1.uint_price /*单价*/ + ,P1.discount_percent /*折扣率*/ + ,P1.discount_amount_base /*基础折扣金额*/ + ,P1.base_amount /*基础金额*/ + ,P1.total_amount /*总金额*/ + ,P1.sales_funnel_stage /*销售漏斗层级*/ + ,P1.sales_funnel_stage_id /*销售漏斗层级编号*/ + ,P1.status /*状况*/ + ,P1.state /*状态*/ + ,P1.region /*区域*/ + ,P1.acount_manager /*账号经理*/ + ,P1.territory_id /*领域编号*/ + ,P1.forecast_opp_ind /*预期机会标志*/ + ,P1.risk_ind /*风险标志*/ + ,P1.opportunity_age /*机会年份*/ + ,P1.create_time /*创建时间*/ + ,P1.create_person /*创建人*/ + ,P1.pipline_last_update /*pipline最后更新时间*/ + ,P1.status_last_update /*状况最后更新时间*/ + ,P1.channel_id /*渠道编号*/ + ,P1.purchase_method /*采购方式*/ + ,P1.campaign_name /*活动名称*/ + ,P1.web_medium /*网络媒介*/ + ,P1.web_source /*网络来源*/ + ,P1.customer_app /*客户应用*/ + ,P1.vertical_segment /*垂直领域*/ + ,P1.competitive_status /*竞争状态*/ + ,P1.important_opportunity_ind /*重要机会标志*/ + ,P1.application_name /*应用名称*/ + ,P1.opp_industry /*行业（opp)*/ + ,P1.tag_list /*标签列表*/ + ,P1.discount_amount /*折扣金额*/ + ,P1.area_id /*地区编号*/ + ,P1.branch_id /*分支编号*/ + ,P1.extension_id /*扩展编号*/ + ,P1.legal_company_name /*法定公司名称*/ + ,P1.account_number /*账号编号*/ + ,P1.marketing_program_type /*市场项目类型*/ + ,P1.lead_number /*线索编号*/ + ,P1.crm_contact_number /*联系人编号*/ + ,P1.tek_opportunity_id /*泰克机会编号*/ + ,P1.Etl_Batch_No /*作业批次号*/ + ,P1.Etl_First_Dt /*最初入库时间*/ + ,P1.Etl_Job /*作业名称*/ + ,P1.Etl_Proc_Dt /*本次入库时间*/ + ,P1.Etl_Tx_Dt /*作业运行时间*/ + ,P1.Src_Sysname /*来源系统*/ + ,P1.Src_Table /*来源表*/ + +FROM t01_crm_opportunity_agi_INS P1 +ON CONFLICT ( tek_opportunity_id) +DO UPDATE SET + tek_opportunity_id=excluded.tek_opportunity_id + ,opportunity_name=excluded.opportunity_name + ,tektronix_apname=excluded.tektronix_apname + ,estimated_close_time=excluded.estimated_close_time + ,actual_close_time=excluded.actual_close_time + ,parent_account_name=excluded.parent_account_name + ,parent_contact_name=excluded.parent_contact_name + ,product_name=excluded.product_name + ,product_class=excluded.product_class + ,currency_name=excluded.currency_name + ,uint_price=excluded.uint_price + ,discount_percent=excluded.discount_percent + ,discount_amount_base=excluded.discount_amount_base + ,base_amount=excluded.base_amount + ,total_amount=excluded.total_amount + ,sales_funnel_stage=excluded.sales_funnel_stage + ,sales_funnel_stage_id=excluded.sales_funnel_stage_id + ,status=excluded.status + ,state=excluded.state + ,region=excluded.region + ,acount_manager=excluded.acount_manager + ,territory_id=excluded.territory_id + ,forecast_opp_ind=excluded.forecast_opp_ind + ,risk_ind=excluded.risk_ind + ,opportunity_age=excluded.opportunity_age + ,create_time=excluded.create_time + ,create_person=excluded.create_person + ,pipline_last_update=excluded.pipline_last_update + ,status_last_update=excluded.status_last_update + ,channel_id=excluded.channel_id + ,purchase_method=excluded.purchase_method + ,campaign_name=excluded.campaign_name + ,web_medium=excluded.web_medium + ,web_source=excluded.web_source + ,customer_app=excluded.customer_app + ,vertical_segment=excluded.vertical_segment + ,competitive_status=excluded.competitive_status + ,important_opportunity_ind=excluded.important_opportunity_ind + ,application_name=excluded.application_name + ,opp_industry=excluded.opp_industry + ,tag_list=excluded.tag_list + ,discount_amount=excluded.discount_amount + ,area_id=excluded.area_id + ,branch_id=excluded.branch_id + ,extension_id=excluded.extension_id + ,legal_company_name=excluded.legal_company_name + ,account_number=excluded.account_number + ,marketing_program_type=excluded.marketing_program_type + ,lead_number=excluded.lead_number + ,crm_contact_number=excluded.crm_contact_number + ,Etl_Batch_No=excluded.Etl_Batch_No + ,Etl_First_Dt=excluded.Etl_First_Dt + ,Etl_Job=excluded.Etl_Job + ,Etl_Proc_Dt=excluded.Etl_Proc_Dt + ,Etl_Tx_Dt=excluded.Etl_Tx_Dt + ,Src_Sysname=excluded.Src_Sysname + ,Src_Table=excluded.Src_Table + ; /*****程序结束退出 */