dtgitea
/
dataops
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add workflow 泰克CRM,dev

This commit is contained in:
root 2025-12-20 19:19:52 +08:00
parent d202e3fb81
commit 8538279ab8
1 changed files with 61 additions and 52 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

111
dev/workflow/TK_Cust/tk_crm/CRM销售机会/t01_crm_opportunity_agi.sql
View File

@ -1,14 +1,14 @@
/***************************************************************************************************/ /***************************************************************************************************/
/*script in Sql, generate by SdmCreateScript 2020(by Qihang Feng, QF255001@TERADATA.COM) */ /*script in Sql, generate by SdmCreateScript 2024(by IdgValue, qihang.feng@idgvalue.COM) */
/*VERSION 01.10 revised on 2020-08-25 */ /*VERSION 01.10 revised on 2020-08-25 */
/*Brilliance stems from wisdoms. */ /*Brilliance stems from wisdoms. */
/*************Head Section**************************************************************************/ /*************Head Section**************************************************************************/
/*Script Use: Periodically load data to :t01_crm_opportunity(CRM销售机会) */ /*Script Use: Periodically load data to :t01_crm_opportunity(CRM销售机会) */
/*Create Date:2024-04-19 16:39:32 */ /*Create Date:2025-12-20 19:18:39 */
/*SDM Developed By: dev */ /*SDM Developed By: dev */
/*SDM Developed Date: 2024-04-19 */ /*SDM Developed Date: 2024-04-19 */
/*SDM Checked By: dev */ /*SDM Checked By: dev */
/*SDM Checked Date: 2024-04-19 */ /*SDM Checked Date: 2025-12-20 */
/*Script Developed By: dev */ /*Script Developed By: dev */
/*Script Checked By: dev */ /*Script Checked By: dev */
/*Source table 1: p10_sa.s98_s_crm_opp */ /*Source table 1: p10_sa.s98_s_crm_opp */
@ -37,7 +37,7 @@ CREATE TEMPORARY TABLE t01_crm_opportunity_agi_INS
( LIKE :PDMDB.t01_crm_opportunity) ( LIKE :PDMDB.t01_crm_opportunity)
ON COMMIT PRESERVE ROWS; ON COMMIT PRESERVE ROWS;
/*创建临时表加载当前有效数据 */ /*创建临时表加载当前有效数据 */
CREATE TEMPORARY TABLE t01_crm_opportunity_agi_CUR CREATE TEMPORARY TABLE t01_crm_opportunity_agi_CUR
( LIKE :PDMDB.t01_crm_opportunity) ( LIKE :PDMDB.t01_crm_opportunity)
ON COMMIT PRESERVE ROWS; ON COMMIT PRESERVE ROWS;
@ -56,6 +56,7 @@ INSERT INTO t01_crm_opportunity_agi_CUR_I (
,opportunity_name /*机会名称*/ ,opportunity_name /*机会名称*/
,tektronix_apname /*tek_tektronixapname*/ ,tektronix_apname /*tek_tektronixapname*/
,estimated_close_time /*预期关闭时间*/ ,estimated_close_time /*预期关闭时间*/
,actualclosedate /*实际关闭日期*/
,parent_account_name /*父账号名称*/ ,parent_account_name /*父账号名称*/
,parent_contact_name /*父联系人名称*/ ,parent_contact_name /*父联系人名称*/
,product_name /*产品名称*/ ,product_name /*产品名称*/
@ -116,6 +117,7 @@ SELECT
,COALESCE(TRIM(CAST(p0.name AS varchar(100))),'') /*opportunity_name*/ ,COALESCE(TRIM(CAST(p0.name AS varchar(100))),'') /*opportunity_name*/
,COALESCE(TRIM(p0.tek_tektronixapname),'') /*tektronix_apname*/ ,COALESCE(TRIM(p0.tek_tektronixapname),'') /*tektronix_apname*/
,COALESCE(TO_TIMESTAMP(CAST(p0.estimatedclosedate AS VARCHAR(19)),'YYYY-MM-DD HH24:mi:ss'),TO_TIMESTAMP(:NULLDATE,'YYYYMMDD')) /*estimated_close_time*/ ,COALESCE(TO_TIMESTAMP(CAST(p0.estimatedclosedate AS VARCHAR(19)),'YYYY-MM-DD HH24:mi:ss'),TO_TIMESTAMP(:NULLDATE,'YYYYMMDD')) /*estimated_close_time*/
,COALESCE(TO_TIMESTAMP(CAST(p0.actualclosedate AS VARCHAR(19)),'YYYY-MM-DD HH24:mi:ss'),TO_TIMESTAMP(:NULLDATE,'YYYYMMDD')) /*actualclosedate*/
,COALESCE(TRIM(CAST(p0.parentaccountidname AS varchar(200))),'') /*parent_account_name*/ ,COALESCE(TRIM(CAST(p0.parentaccountidname AS varchar(200))),'') /*parent_account_name*/
,COALESCE(TRIM(CAST(p0.parentcontactidname AS varchar(20))),'') /*parent_contact_name*/ ,COALESCE(TRIM(CAST(p0.parentcontactidname AS varchar(20))),'') /*parent_contact_name*/
,COALESCE(TRIM(CAST(p0.tek_productidname AS varchar(50))),'') /*product_name*/ ,COALESCE(TRIM(CAST(p0.tek_productidname AS varchar(50))),'') /*product_name*/
@ -190,6 +192,7 @@ AND scd_End_Dt=TO_DATE(:TXDATE,'YYYYMMDD');
/*往临时表插入当前数据。 */ /*往临时表插入当前数据。 */
INSERT INTO t01_crm_opportunity_agi_CUR( INSERT INTO t01_crm_opportunity_agi_CUR(
tek_opportunity_id /*泰克机会编号*/ tek_opportunity_id /*泰克机会编号*/
,currency_name /*交易币种*/
,uint_price /*单价*/ ,uint_price /*单价*/
,discount_percent /*折扣率*/ ,discount_percent /*折扣率*/
,discount_amount_base /*基础折扣金额*/ ,discount_amount_base /*基础折扣金额*/
@ -199,8 +202,8 @@ INSERT INTO t01_crm_opportunity_agi_CUR(
,sales_funnel_stage_id /*销售漏斗层级编号*/ ,sales_funnel_stage_id /*销售漏斗层级编号*/
,status /*状况*/ ,status /*状况*/
,state /*状态*/ ,state /*状态*/
,region /*区域*/
,opportunity_name /*机会名称*/ ,opportunity_name /*机会名称*/
,region /*区域*/
,acount_manager /*账号经理*/ ,acount_manager /*账号经理*/
,territory_id /*领域编号*/ ,territory_id /*领域编号*/
,forecast_opp_ind /*预期机会标志*/ ,forecast_opp_ind /*预期机会标志*/
@ -210,8 +213,8 @@ INSERT INTO t01_crm_opportunity_agi_CUR(
,create_person /*创建人*/ ,create_person /*创建人*/
,pipline_last_update /*pipline最后更新时间*/ ,pipline_last_update /*pipline最后更新时间*/
,status_last_update /*状况最后更新时间*/ ,status_last_update /*状况最后更新时间*/
,channel_id /*渠道编号*/
,tektronix_apname /*tek_tektronixapname*/ ,tektronix_apname /*tek_tektronixapname*/
,channel_id /*渠道编号*/
,purchase_method /*采购方式*/ ,purchase_method /*采购方式*/
,campaign_name /*活动名称*/ ,campaign_name /*活动名称*/
,web_medium /*网络媒介*/ ,web_medium /*网络媒介*/
@ -221,8 +224,8 @@ INSERT INTO t01_crm_opportunity_agi_CUR(
,competitive_status /*竞争状态*/ ,competitive_status /*竞争状态*/
,important_opportunity_ind /*重要机会标志*/ ,important_opportunity_ind /*重要机会标志*/
,application_name /*应用名称*/ ,application_name /*应用名称*/
,opp_industry /*行业（opp)*/
,estimated_close_time /*预期关闭时间*/ ,estimated_close_time /*预期关闭时间*/
,opp_industry /*行业（opp)*/
,tag_list /*标签列表*/ ,tag_list /*标签列表*/
,discount_amount /*折扣金额*/ ,discount_amount /*折扣金额*/
,area_id /*地区编号*/ ,area_id /*地区编号*/
@ -232,8 +235,8 @@ INSERT INTO t01_crm_opportunity_agi_CUR(
,account_number /*账号编号*/ ,account_number /*账号编号*/
,marketing_program_type /*市场项目类型*/ ,marketing_program_type /*市场项目类型*/
,lead_number /*线索编号*/ ,lead_number /*线索编号*/
,actualclosedate /*实际关闭日期*/
,crm_contact_number /*联系人编号*/ ,crm_contact_number /*联系人编号*/
,parent_account_name /*父账号名称*/
,Scd_Start_Dt /*开始时间*/ ,Scd_Start_Dt /*开始时间*/
,Scd_End_Dt /*结束时间*/ ,Scd_End_Dt /*结束时间*/
,Etl_Batch_No /*作业批次号*/ ,Etl_Batch_No /*作业批次号*/
@ -243,13 +246,14 @@ INSERT INTO t01_crm_opportunity_agi_CUR(
,Etl_Tx_Dt /*作业运行时间*/ ,Etl_Tx_Dt /*作业运行时间*/
,Src_Sysname /*来源系统*/ ,Src_Sysname /*来源系统*/
,Src_Table /*来源表*/ ,Src_Table /*来源表*/
,parent_account_name /*父账号名称*/
,parent_contact_name /*父联系人名称*/ ,parent_contact_name /*父联系人名称*/
,product_name /*产品名称*/ ,product_name /*产品名称*/
,product_class /*产品类别*/ ,product_class /*产品类别*/
,currency_name /*交易币种*/
) )
SELECT SELECT
P1.tek_opportunity_id /*泰克机会编号*/ P1.tek_opportunity_id /*泰克机会编号*/
,P1.currency_name /*交易币种*/
,P1.uint_price /*单价*/ ,P1.uint_price /*单价*/
,P1.discount_percent /*折扣率*/ ,P1.discount_percent /*折扣率*/
,P1.discount_amount_base /*基础折扣金额*/ ,P1.discount_amount_base /*基础折扣金额*/
@ -259,8 +263,8 @@ SELECT
,P1.sales_funnel_stage_id /*销售漏斗层级编号*/ ,P1.sales_funnel_stage_id /*销售漏斗层级编号*/
,P1.status /*状况*/ ,P1.status /*状况*/
,P1.state /*状态*/ ,P1.state /*状态*/
,P1.region /*区域*/
,P1.opportunity_name /*机会名称*/ ,P1.opportunity_name /*机会名称*/
,P1.region /*区域*/
,P1.acount_manager /*账号经理*/ ,P1.acount_manager /*账号经理*/
,P1.territory_id /*领域编号*/ ,P1.territory_id /*领域编号*/
,P1.forecast_opp_ind /*预期机会标志*/ ,P1.forecast_opp_ind /*预期机会标志*/
@ -270,8 +274,8 @@ SELECT
,P1.create_person /*创建人*/ ,P1.create_person /*创建人*/
,P1.pipline_last_update /*pipline最后更新时间*/ ,P1.pipline_last_update /*pipline最后更新时间*/
,P1.status_last_update /*状况最后更新时间*/ ,P1.status_last_update /*状况最后更新时间*/
,P1.channel_id /*渠道编号*/
,P1.tektronix_apname /*tek_tektronixapname*/ ,P1.tektronix_apname /*tek_tektronixapname*/
,P1.channel_id /*渠道编号*/
,P1.purchase_method /*采购方式*/ ,P1.purchase_method /*采购方式*/
,P1.campaign_name /*活动名称*/ ,P1.campaign_name /*活动名称*/
,P1.web_medium /*网络媒介*/ ,P1.web_medium /*网络媒介*/
@ -281,8 +285,8 @@ SELECT
,P1.competitive_status /*竞争状态*/ ,P1.competitive_status /*竞争状态*/
,P1.important_opportunity_ind /*重要机会标志*/ ,P1.important_opportunity_ind /*重要机会标志*/
,P1.application_name /*应用名称*/ ,P1.application_name /*应用名称*/
,P1.opp_industry /*行业（opp)*/
,P1.estimated_close_time /*预期关闭时间*/ ,P1.estimated_close_time /*预期关闭时间*/
,P1.opp_industry /*行业（opp)*/
,P1.tag_list /*标签列表*/ ,P1.tag_list /*标签列表*/
,P1.discount_amount /*折扣金额*/ ,P1.discount_amount /*折扣金额*/
,P1.area_id /*地区编号*/ ,P1.area_id /*地区编号*/
@ -292,8 +296,8 @@ SELECT
,P1.account_number /*账号编号*/ ,P1.account_number /*账号编号*/
,P1.marketing_program_type /*市场项目类型*/ ,P1.marketing_program_type /*市场项目类型*/
,P1.lead_number /*线索编号*/ ,P1.lead_number /*线索编号*/
,P1.actualclosedate /*实际关闭日期*/
,P1.crm_contact_number /*联系人编号*/ ,P1.crm_contact_number /*联系人编号*/
,P1.parent_account_name /*父账号名称*/
,P1.Scd_Start_Dt /*开始时间*/ ,P1.Scd_Start_Dt /*开始时间*/
,P1.Scd_End_Dt /*结束时间*/ ,P1.Scd_End_Dt /*结束时间*/
,P1.Etl_Batch_No /*作业批次号*/ ,P1.Etl_Batch_No /*作业批次号*/
@ -303,10 +307,10 @@ SELECT
,P1.Etl_Tx_Dt /*作业运行时间*/ ,P1.Etl_Tx_Dt /*作业运行时间*/
,P1.Src_Sysname /*来源系统*/ ,P1.Src_Sysname /*来源系统*/
,P1.Src_Table /*来源表*/ ,P1.Src_Table /*来源表*/
,P1.parent_account_name /*父账号名称*/
,P1.parent_contact_name /*父联系人名称*/ ,P1.parent_contact_name /*父联系人名称*/
,P1.product_name /*产品名称*/ ,P1.product_name /*产品名称*/
,P1.product_class /*产品类别*/ ,P1.product_class /*产品类别*/
,P1.currency_name /*交易币种*/
FROM :PDMDB.t01_crm_opportunity P1 FROM :PDMDB.t01_crm_opportunity P1
WHERE P1.Scd_End_Dt = TO_DATE(:MAXDATE,'YYYYMMDD') WHERE P1.Scd_End_Dt = TO_DATE(:MAXDATE,'YYYYMMDD')
@ -316,6 +320,7 @@ WHERE P1.Scd_End_Dt = TO_DATE(:MAXDATE,'YYYYMMDD')
/*字段。 */ /*字段。 */
INSERT INTO t01_crm_opportunity_agi_INS( INSERT INTO t01_crm_opportunity_agi_INS(
tek_opportunity_id /*泰克机会编号*/ tek_opportunity_id /*泰克机会编号*/
, currency_name /*交易币种*/
, uint_price /*单价*/ , uint_price /*单价*/
, discount_percent /*折扣率*/ , discount_percent /*折扣率*/
, discount_amount_base /*基础折扣金额*/ , discount_amount_base /*基础折扣金额*/
@ -325,8 +330,8 @@ INSERT INTO t01_crm_opportunity_agi_INS(
, sales_funnel_stage_id /*销售漏斗层级编号*/ , sales_funnel_stage_id /*销售漏斗层级编号*/
, status /*状况*/ , status /*状况*/
, state /*状态*/ , state /*状态*/
, region /*区域*/
, opportunity_name /*机会名称*/ , opportunity_name /*机会名称*/
, region /*区域*/
, acount_manager /*账号经理*/ , acount_manager /*账号经理*/
, territory_id /*领域编号*/ , territory_id /*领域编号*/
, forecast_opp_ind /*预期机会标志*/ , forecast_opp_ind /*预期机会标志*/
@ -336,8 +341,8 @@ INSERT INTO t01_crm_opportunity_agi_INS(
, create_person /*创建人*/ , create_person /*创建人*/
, pipline_last_update /*pipline最后更新时间*/ , pipline_last_update /*pipline最后更新时间*/
, status_last_update /*状况最后更新时间*/ , status_last_update /*状况最后更新时间*/
, channel_id /*渠道编号*/
, tektronix_apname /*tek_tektronixapname*/ , tektronix_apname /*tek_tektronixapname*/
, channel_id /*渠道编号*/
, purchase_method /*采购方式*/ , purchase_method /*采购方式*/
, campaign_name /*活动名称*/ , campaign_name /*活动名称*/
, web_medium /*网络媒介*/ , web_medium /*网络媒介*/
@ -347,8 +352,8 @@ INSERT INTO t01_crm_opportunity_agi_INS(
, competitive_status /*竞争状态*/ , competitive_status /*竞争状态*/
, important_opportunity_ind /*重要机会标志*/ , important_opportunity_ind /*重要机会标志*/
, application_name /*应用名称*/ , application_name /*应用名称*/
, opp_industry /*行业（opp)*/
, estimated_close_time /*预期关闭时间*/ , estimated_close_time /*预期关闭时间*/
, opp_industry /*行业（opp)*/
, tag_list /*标签列表*/ , tag_list /*标签列表*/
, discount_amount /*折扣金额*/ , discount_amount /*折扣金额*/
, area_id /*地区编号*/ , area_id /*地区编号*/
@ -358,8 +363,8 @@ INSERT INTO t01_crm_opportunity_agi_INS(
, account_number /*账号编号*/ , account_number /*账号编号*/
, marketing_program_type /*市场项目类型*/ , marketing_program_type /*市场项目类型*/
, lead_number /*线索编号*/ , lead_number /*线索编号*/
, actualclosedate /*实际关闭日期*/
, crm_contact_number /*联系人编号*/ , crm_contact_number /*联系人编号*/
, parent_account_name /*父账号名称*/
, Scd_Start_Dt /*开始时间*/ , Scd_Start_Dt /*开始时间*/
, Scd_End_Dt /*结束时间*/ , Scd_End_Dt /*结束时间*/
, Etl_Batch_No /*作业批次号*/ , Etl_Batch_No /*作业批次号*/
@ -369,13 +374,14 @@ INSERT INTO t01_crm_opportunity_agi_INS(
, Etl_Tx_Dt /*作业运行时间*/ , Etl_Tx_Dt /*作业运行时间*/
, Src_Sysname /*来源系统*/ , Src_Sysname /*来源系统*/
, Src_Table /*来源表*/ , Src_Table /*来源表*/
, parent_account_name /*父账号名称*/
, parent_contact_name /*父联系人名称*/ , parent_contact_name /*父联系人名称*/
, product_name /*产品名称*/ , product_name /*产品名称*/
, product_class /*产品类别*/ , product_class /*产品类别*/
, currency_name /*交易币种*/
) )
SELECT SELECT
P1.tek_opportunity_id /*泰克机会编号*/ P1.tek_opportunity_id /*泰克机会编号*/
, P1.currency_name /*交易币种*/
, P1.uint_price /*单价*/ , P1.uint_price /*单价*/
, P1.discount_percent /*折扣率*/ , P1.discount_percent /*折扣率*/
, P1.discount_amount_base /*基础折扣金额*/ , P1.discount_amount_base /*基础折扣金额*/
@ -385,8 +391,8 @@ SELECT
, P1.sales_funnel_stage_id /*销售漏斗层级编号*/ , P1.sales_funnel_stage_id /*销售漏斗层级编号*/
, P1.status /*状况*/ , P1.status /*状况*/
, P1.state /*状态*/ , P1.state /*状态*/
, P1.region /*区域*/
, P1.opportunity_name /*机会名称*/ , P1.opportunity_name /*机会名称*/
, P1.region /*区域*/
, P1.acount_manager /*账号经理*/ , P1.acount_manager /*账号经理*/
, P1.territory_id /*领域编号*/ , P1.territory_id /*领域编号*/
, P1.forecast_opp_ind /*预期机会标志*/ , P1.forecast_opp_ind /*预期机会标志*/
@ -396,8 +402,8 @@ SELECT
, P1.create_person /*创建人*/ , P1.create_person /*创建人*/
, P1.pipline_last_update /*pipline最后更新时间*/ , P1.pipline_last_update /*pipline最后更新时间*/
, P1.status_last_update /*状况最后更新时间*/ , P1.status_last_update /*状况最后更新时间*/
, P1.channel_id /*渠道编号*/
, P1.tektronix_apname /*tek_tektronixapname*/ , P1.tektronix_apname /*tek_tektronixapname*/
, P1.channel_id /*渠道编号*/
, P1.purchase_method /*采购方式*/ , P1.purchase_method /*采购方式*/
, P1.campaign_name /*活动名称*/ , P1.campaign_name /*活动名称*/
, P1.web_medium /*网络媒介*/ , P1.web_medium /*网络媒介*/
@ -407,8 +413,8 @@ SELECT
, P1.competitive_status /*竞争状态*/ , P1.competitive_status /*竞争状态*/
, P1.important_opportunity_ind /*重要机会标志*/ , P1.important_opportunity_ind /*重要机会标志*/
, P1.application_name /*应用名称*/ , P1.application_name /*应用名称*/
, P1.opp_industry /*行业（opp)*/
, P1.estimated_close_time /*预期关闭时间*/ , P1.estimated_close_time /*预期关闭时间*/
, P1.opp_industry /*行业（opp)*/
, P1.tag_list /*标签列表*/ , P1.tag_list /*标签列表*/
, P1.discount_amount /*折扣金额*/ , P1.discount_amount /*折扣金额*/
, P1.area_id /*地区编号*/ , P1.area_id /*地区编号*/
@ -418,8 +424,8 @@ SELECT
, P1.account_number /*账号编号*/ , P1.account_number /*账号编号*/
, P1.marketing_program_type /*市场项目类型*/ , P1.marketing_program_type /*市场项目类型*/
, P1.lead_number /*线索编号*/ , P1.lead_number /*线索编号*/
, P1.actualclosedate /*实际关闭日期*/
, P1.crm_contact_number /*联系人编号*/ , P1.crm_contact_number /*联系人编号*/
, P1.parent_account_name /*父账号名称*/
, P1.Scd_Start_Dt /*开始时间*/ , P1.Scd_Start_Dt /*开始时间*/
, P1.Scd_End_Dt /*结束时间*/ , P1.Scd_End_Dt /*结束时间*/
, P1.Etl_Batch_No /*作业批次号*/ , P1.Etl_Batch_No /*作业批次号*/
@ -429,18 +435,18 @@ SELECT
, P1.Etl_Tx_Dt /*作业运行时间*/ , P1.Etl_Tx_Dt /*作业运行时间*/
, P1.Src_Sysname /*来源系统*/ , P1.Src_Sysname /*来源系统*/
, P1.Src_Table /*来源表*/ , P1.Src_Table /*来源表*/
, P1.parent_account_name /*父账号名称*/
, P1.parent_contact_name /*父联系人名称*/ , P1.parent_contact_name /*父联系人名称*/
, P1.product_name /*产品名称*/ , P1.product_name /*产品名称*/
, P1.product_class /*产品类别*/ , P1.product_class /*产品类别*/
, P1.currency_name /*交易币种*/
FROM t01_crm_opportunity_agi_CUR_I P1 FROM t01_crm_opportunity_agi_CUR_I P1
LEFT JOIN t01_crm_opportunity_agi_CUR P2 LEFT JOIN t01_crm_opportunity_agi_CUR P2
ON P1.tek_opportunity_id = P2.tek_opportunity_id ON P1.tek_opportunity_id = P2.tek_opportunity_id
AND P1.Scd_Start_Dt = P2.Scd_Start_Dt
AND P1.opportunity_name = P2.opportunity_name AND P1.opportunity_name = P2.opportunity_name
AND P1.tektronix_apname = P2.tektronix_apname AND P1.tektronix_apname = P2.tektronix_apname
AND P1.estimated_close_time = P2.estimated_close_time AND P1.estimated_close_time = P2.estimated_close_time
AND P1.actualclosedate = P2.actualclosedate
AND P1.parent_account_name = P2.parent_account_name AND P1.parent_account_name = P2.parent_account_name
AND P1.parent_contact_name = P2.parent_contact_name AND P1.parent_contact_name = P2.parent_contact_name
AND P1.product_name = P2.product_name AND P1.product_name = P2.product_name
@ -493,6 +499,7 @@ WHERE
AND P2.opportunity_name IS NULL AND P2.opportunity_name IS NULL
AND P2.tektronix_apname IS NULL AND P2.tektronix_apname IS NULL
AND P2.estimated_close_time IS NULL AND P2.estimated_close_time IS NULL
AND P2.actualclosedate IS NULL
AND P2.parent_account_name IS NULL AND P2.parent_account_name IS NULL
AND P2.parent_contact_name IS NULL AND P2.parent_contact_name IS NULL
AND P2.product_name IS NULL AND P2.product_name IS NULL
@ -544,6 +551,7 @@ WHERE
INSERT INTO t01_crm_opportunity_agi_CUR_D ( INSERT INTO t01_crm_opportunity_agi_CUR_D (
tek_opportunity_id /*泰克机会编号*/ tek_opportunity_id /*泰克机会编号*/
, currency_name /*交易币种*/
, uint_price /*单价*/ , uint_price /*单价*/
, discount_percent /*折扣率*/ , discount_percent /*折扣率*/
, discount_amount_base /*基础折扣金额*/ , discount_amount_base /*基础折扣金额*/
@ -553,8 +561,8 @@ INSERT INTO t01_crm_opportunity_agi_CUR_D (
, sales_funnel_stage_id /*销售漏斗层级编号*/ , sales_funnel_stage_id /*销售漏斗层级编号*/
, status /*状况*/ , status /*状况*/
, state /*状态*/ , state /*状态*/
, region /*区域*/
, opportunity_name /*机会名称*/ , opportunity_name /*机会名称*/
, region /*区域*/
, acount_manager /*账号经理*/ , acount_manager /*账号经理*/
, territory_id /*领域编号*/ , territory_id /*领域编号*/
, forecast_opp_ind /*预期机会标志*/ , forecast_opp_ind /*预期机会标志*/
@ -564,8 +572,8 @@ INSERT INTO t01_crm_opportunity_agi_CUR_D (
, create_person /*创建人*/ , create_person /*创建人*/
, pipline_last_update /*pipline最后更新时间*/ , pipline_last_update /*pipline最后更新时间*/
, status_last_update /*状况最后更新时间*/ , status_last_update /*状况最后更新时间*/
, channel_id /*渠道编号*/
, tektronix_apname /*tek_tektronixapname*/ , tektronix_apname /*tek_tektronixapname*/
, channel_id /*渠道编号*/
, purchase_method /*采购方式*/ , purchase_method /*采购方式*/
, campaign_name /*活动名称*/ , campaign_name /*活动名称*/
, web_medium /*网络媒介*/ , web_medium /*网络媒介*/
@ -575,8 +583,8 @@ INSERT INTO t01_crm_opportunity_agi_CUR_D (
, competitive_status /*竞争状态*/ , competitive_status /*竞争状态*/
, important_opportunity_ind /*重要机会标志*/ , important_opportunity_ind /*重要机会标志*/
, application_name /*应用名称*/ , application_name /*应用名称*/
, opp_industry /*行业（opp)*/
, estimated_close_time /*预期关闭时间*/ , estimated_close_time /*预期关闭时间*/
, opp_industry /*行业（opp)*/
, tag_list /*标签列表*/ , tag_list /*标签列表*/
, discount_amount /*折扣金额*/ , discount_amount /*折扣金额*/
, area_id /*地区编号*/ , area_id /*地区编号*/
@ -586,8 +594,8 @@ INSERT INTO t01_crm_opportunity_agi_CUR_D (
, account_number /*账号编号*/ , account_number /*账号编号*/
, marketing_program_type /*市场项目类型*/ , marketing_program_type /*市场项目类型*/
, lead_number /*线索编号*/ , lead_number /*线索编号*/
, actualclosedate /*实际关闭日期*/
, crm_contact_number /*联系人编号*/ , crm_contact_number /*联系人编号*/
, parent_account_name /*父账号名称*/
, Scd_Start_Dt /*开始时间*/ , Scd_Start_Dt /*开始时间*/
, Scd_End_Dt /*结束时间*/ , Scd_End_Dt /*结束时间*/
, Etl_Batch_No /*作业批次号*/ , Etl_Batch_No /*作业批次号*/
@ -597,13 +605,14 @@ INSERT INTO t01_crm_opportunity_agi_CUR_D (
, Etl_Tx_Dt /*作业运行时间*/ , Etl_Tx_Dt /*作业运行时间*/
, Src_Sysname /*来源系统*/ , Src_Sysname /*来源系统*/
, Src_Table /*来源表*/ , Src_Table /*来源表*/
, parent_account_name /*父账号名称*/
, parent_contact_name /*父联系人名称*/ , parent_contact_name /*父联系人名称*/
, product_name /*产品名称*/ , product_name /*产品名称*/
, product_class /*产品类别*/ , product_class /*产品类别*/
, currency_name /*交易币种*/
) )
SELECT SELECT
P1.tek_opportunity_id /*泰克机会编号*/ P1.tek_opportunity_id /*泰克机会编号*/
, P1.currency_name /*交易币种*/
, P1.uint_price /*单价*/ , P1.uint_price /*单价*/
, P1.discount_percent /*折扣率*/ , P1.discount_percent /*折扣率*/
, P1.discount_amount_base /*基础折扣金额*/ , P1.discount_amount_base /*基础折扣金额*/
@ -613,8 +622,8 @@ SELECT
, P1.sales_funnel_stage_id /*销售漏斗层级编号*/ , P1.sales_funnel_stage_id /*销售漏斗层级编号*/
, P1.status /*状况*/ , P1.status /*状况*/
, P1.state /*状态*/ , P1.state /*状态*/
, P1.region /*区域*/
, P1.opportunity_name /*机会名称*/ , P1.opportunity_name /*机会名称*/
, P1.region /*区域*/
, P1.acount_manager /*账号经理*/ , P1.acount_manager /*账号经理*/
, P1.territory_id /*领域编号*/ , P1.territory_id /*领域编号*/
, P1.forecast_opp_ind /*预期机会标志*/ , P1.forecast_opp_ind /*预期机会标志*/
@ -624,8 +633,8 @@ SELECT
, P1.create_person /*创建人*/ , P1.create_person /*创建人*/
, P1.pipline_last_update /*pipline最后更新时间*/ , P1.pipline_last_update /*pipline最后更新时间*/
, P1.status_last_update /*状况最后更新时间*/ , P1.status_last_update /*状况最后更新时间*/
, P1.channel_id /*渠道编号*/
, P1.tektronix_apname /*tek_tektronixapname*/ , P1.tektronix_apname /*tek_tektronixapname*/
, P1.channel_id /*渠道编号*/
, P1.purchase_method /*采购方式*/ , P1.purchase_method /*采购方式*/
, P1.campaign_name /*活动名称*/ , P1.campaign_name /*活动名称*/
, P1.web_medium /*网络媒介*/ , P1.web_medium /*网络媒介*/
@ -635,8 +644,8 @@ SELECT
, P1.competitive_status /*竞争状态*/ , P1.competitive_status /*竞争状态*/
, P1.important_opportunity_ind /*重要机会标志*/ , P1.important_opportunity_ind /*重要机会标志*/
, P1.application_name /*应用名称*/ , P1.application_name /*应用名称*/
, P1.opp_industry /*行业（opp)*/
, P1.estimated_close_time /*预期关闭时间*/ , P1.estimated_close_time /*预期关闭时间*/
, P1.opp_industry /*行业（opp)*/
, P1.tag_list /*标签列表*/ , P1.tag_list /*标签列表*/
, P1.discount_amount /*折扣金额*/ , P1.discount_amount /*折扣金额*/
, P1.area_id /*地区编号*/ , P1.area_id /*地区编号*/
@ -646,8 +655,8 @@ SELECT
, P1.account_number /*账号编号*/ , P1.account_number /*账号编号*/
, P1.marketing_program_type /*市场项目类型*/ , P1.marketing_program_type /*市场项目类型*/
, P1.lead_number /*线索编号*/ , P1.lead_number /*线索编号*/
, P1.actualclosedate /*实际关闭日期*/
, P1.crm_contact_number /*联系人编号*/ , P1.crm_contact_number /*联系人编号*/
, P1.parent_account_name /*父账号名称*/
, P1.Scd_Start_Dt /*开始时间*/ , P1.Scd_Start_Dt /*开始时间*/
, P1.Scd_End_Dt /*结束时间*/ , P1.Scd_End_Dt /*结束时间*/
, P1.Etl_Batch_No /*作业批次号*/ , P1.Etl_Batch_No /*作业批次号*/
@ -657,17 +666,15 @@ SELECT
, P1.Etl_Tx_Dt /*作业运行时间*/ , P1.Etl_Tx_Dt /*作业运行时间*/
, P1.Src_Sysname /*来源系统*/ , P1.Src_Sysname /*来源系统*/
, P1.Src_Table /*来源表*/ , P1.Src_Table /*来源表*/
, P1.parent_account_name /*父账号名称*/
, P1.parent_contact_name /*父联系人名称*/ , P1.parent_contact_name /*父联系人名称*/
, P1.product_name /*产品名称*/ , P1.product_name /*产品名称*/
, P1.product_class /*产品类别*/ , P1.product_class /*产品类别*/
, P1.currency_name /*交易币种*/
FROM t01_crm_opportunity_agi_CUR_I P1 FROM t01_crm_opportunity_agi_CUR_I P1
LEFT JOIN t01_crm_opportunity_agi_CUR P2 LEFT JOIN t01_crm_opportunity_agi_CUR P2
ON P1.tek_opportunity_id = P2.tek_opportunity_id ON P1.tek_opportunity_id = P2.tek_opportunity_id
AND P1.Scd_Start_Dt = P2.Scd_Start_Dt
WHERE P2.tek_opportunity_id IS NULL WHERE P2.tek_opportunity_id IS NULL
AND P2.Scd_Start_Dt IS NULL
AND P2.Scd_End_Dt = TO_DATE(:MAXDATE,'YYYYMMDD') AND P2.Scd_End_Dt = TO_DATE(:MAXDATE,'YYYYMMDD')
AND P2.ETL_Job = :ETLJOB AND P2.ETL_Job = :ETLJOB
; ;
@ -680,8 +687,8 @@ UPDATE :PDMDB.t01_crm_opportunity
,Etl_Proc_Dt=CURRENT_TIMESTAMP(0) ,Etl_Proc_Dt=CURRENT_TIMESTAMP(0)
WHERE Scd_End_Dt = TO_DATE(:MAXDATE, 'YYYYMMDD') WHERE Scd_End_Dt = TO_DATE(:MAXDATE, 'YYYYMMDD')
AND (:PDMDB.t01_crm_opportunity.ETL_Job = :ETLJOB) AND (:PDMDB.t01_crm_opportunity.ETL_Job = :ETLJOB)
AND ( tek_opportunity_id , Scd_Start_Dt) AND ( tek_opportunity_id)
IN (SELECT tek_opportunity_id , Scd_Start_Dt IN (SELECT tek_opportunity_id
FROM t01_crm_opportunity_agi_INS) FROM t01_crm_opportunity_agi_INS)
/*根据比对条件将目标表中删除数据进行相应的处理 */ /*根据比对条件将目标表中删除数据进行相应的处理 */
@ -691,13 +698,14 @@ IN (SELECT tek_opportunity_id , Scd_Start_Dt
,ETL_Proc_Dt=CURRENT_TIMESTAMP(0) ,ETL_Proc_Dt=CURRENT_TIMESTAMP(0)
WHERE Scd_End_Dt=TO_DATE(:MAXDATE,'YYYYMMDD') WHERE Scd_End_Dt=TO_DATE(:MAXDATE,'YYYYMMDD')
AND (:PDMDB.t01_crm_opportunity.ETL_Job = :ETLJOB) AND (:PDMDB.t01_crm_opportunity.ETL_Job = :ETLJOB)
AND ( tek_opportunity_id , Scd_Start_Dt) AND ( tek_opportunity_id)
IN (SELECT IN (SELECT
tek_opportunity_id , Scd_Start_Dt tek_opportunity_id
FROM t01_crm_opportunity_agi_CUR_D) FROM t01_crm_opportunity_agi_CUR_D)
/*然后将新增的数据插入到目标表中，置开始日期为TX_DATE，结束日期置为MAXDATE */ /*然后将新增的数据插入到目标表中，置开始日期为TX_DATE，结束日期置为MAXDATE */
;INSERT INTO :PDMDB.t01_crm_opportunity ( ;INSERT INTO :PDMDB.t01_crm_opportunity (
tek_opportunity_id /*泰克机会编号*/ tek_opportunity_id /*泰克机会编号*/
,currency_name /*交易币种*/
,uint_price /*单价*/ ,uint_price /*单价*/
,discount_percent /*折扣率*/ ,discount_percent /*折扣率*/
,discount_amount_base /*基础折扣金额*/ ,discount_amount_base /*基础折扣金额*/
@ -707,8 +715,8 @@ FROM t01_crm_opportunity_agi_CUR_D)
,sales_funnel_stage_id /*销售漏斗层级编号*/ ,sales_funnel_stage_id /*销售漏斗层级编号*/
,status /*状况*/ ,status /*状况*/
,state /*状态*/ ,state /*状态*/
,region /*区域*/
,opportunity_name /*机会名称*/ ,opportunity_name /*机会名称*/
,region /*区域*/
,acount_manager /*账号经理*/ ,acount_manager /*账号经理*/
,territory_id /*领域编号*/ ,territory_id /*领域编号*/
,forecast_opp_ind /*预期机会标志*/ ,forecast_opp_ind /*预期机会标志*/
@ -718,8 +726,8 @@ FROM t01_crm_opportunity_agi_CUR_D)
,create_person /*创建人*/ ,create_person /*创建人*/
,pipline_last_update /*pipline最后更新时间*/ ,pipline_last_update /*pipline最后更新时间*/
,status_last_update /*状况最后更新时间*/ ,status_last_update /*状况最后更新时间*/
,channel_id /*渠道编号*/
,tektronix_apname /*tek_tektronixapname*/ ,tektronix_apname /*tek_tektronixapname*/
,channel_id /*渠道编号*/
,purchase_method /*采购方式*/ ,purchase_method /*采购方式*/
,campaign_name /*活动名称*/ ,campaign_name /*活动名称*/
,web_medium /*网络媒介*/ ,web_medium /*网络媒介*/
@ -729,8 +737,8 @@ FROM t01_crm_opportunity_agi_CUR_D)
,competitive_status /*竞争状态*/ ,competitive_status /*竞争状态*/
,important_opportunity_ind /*重要机会标志*/ ,important_opportunity_ind /*重要机会标志*/
,application_name /*应用名称*/ ,application_name /*应用名称*/
,opp_industry /*行业（opp)*/
,estimated_close_time /*预期关闭时间*/ ,estimated_close_time /*预期关闭时间*/
,opp_industry /*行业（opp)*/
,tag_list /*标签列表*/ ,tag_list /*标签列表*/
,discount_amount /*折扣金额*/ ,discount_amount /*折扣金额*/
,area_id /*地区编号*/ ,area_id /*地区编号*/
@ -740,8 +748,8 @@ FROM t01_crm_opportunity_agi_CUR_D)
,account_number /*账号编号*/ ,account_number /*账号编号*/
,marketing_program_type /*市场项目类型*/ ,marketing_program_type /*市场项目类型*/
,lead_number /*线索编号*/ ,lead_number /*线索编号*/
,actualclosedate /*实际关闭日期*/
,crm_contact_number /*联系人编号*/ ,crm_contact_number /*联系人编号*/
,parent_account_name /*父账号名称*/
,Scd_Start_Dt /*开始时间*/ ,Scd_Start_Dt /*开始时间*/
,Scd_End_Dt /*结束时间*/ ,Scd_End_Dt /*结束时间*/
,Etl_Batch_No /*作业批次号*/ ,Etl_Batch_No /*作业批次号*/
@ -751,13 +759,14 @@ FROM t01_crm_opportunity_agi_CUR_D)
,Etl_Tx_Dt /*作业运行时间*/ ,Etl_Tx_Dt /*作业运行时间*/
,Src_Sysname /*来源系统*/ ,Src_Sysname /*来源系统*/
,Src_Table /*来源表*/ ,Src_Table /*来源表*/
,parent_account_name /*父账号名称*/
,parent_contact_name /*父联系人名称*/ ,parent_contact_name /*父联系人名称*/
,product_name /*产品名称*/ ,product_name /*产品名称*/
,product_class /*产品类别*/ ,product_class /*产品类别*/
,currency_name /*交易币种*/
) )
SELECT SELECT
P1.tek_opportunity_id /*泰克机会编号*/ P1.tek_opportunity_id /*泰克机会编号*/
,P1.currency_name /*交易币种*/
,P1.uint_price /*单价*/ ,P1.uint_price /*单价*/
,P1.discount_percent /*折扣率*/ ,P1.discount_percent /*折扣率*/
,P1.discount_amount_base /*基础折扣金额*/ ,P1.discount_amount_base /*基础折扣金额*/
@ -767,8 +776,8 @@ SELECT
,P1.sales_funnel_stage_id /*销售漏斗层级编号*/ ,P1.sales_funnel_stage_id /*销售漏斗层级编号*/
,P1.status /*状况*/ ,P1.status /*状况*/
,P1.state /*状态*/ ,P1.state /*状态*/
,P1.region /*区域*/
,P1.opportunity_name /*机会名称*/ ,P1.opportunity_name /*机会名称*/
,P1.region /*区域*/
,P1.acount_manager /*账号经理*/ ,P1.acount_manager /*账号经理*/
,P1.territory_id /*领域编号*/ ,P1.territory_id /*领域编号*/
,P1.forecast_opp_ind /*预期机会标志*/ ,P1.forecast_opp_ind /*预期机会标志*/
@ -778,8 +787,8 @@ SELECT
,P1.create_person /*创建人*/ ,P1.create_person /*创建人*/
,P1.pipline_last_update /*pipline最后更新时间*/ ,P1.pipline_last_update /*pipline最后更新时间*/
,P1.status_last_update /*状况最后更新时间*/ ,P1.status_last_update /*状况最后更新时间*/
,P1.channel_id /*渠道编号*/
,P1.tektronix_apname /*tek_tektronixapname*/ ,P1.tektronix_apname /*tek_tektronixapname*/
,P1.channel_id /*渠道编号*/
,P1.purchase_method /*采购方式*/ ,P1.purchase_method /*采购方式*/
,P1.campaign_name /*活动名称*/ ,P1.campaign_name /*活动名称*/
,P1.web_medium /*网络媒介*/ ,P1.web_medium /*网络媒介*/
@ -789,8 +798,8 @@ SELECT
,P1.competitive_status /*竞争状态*/ ,P1.competitive_status /*竞争状态*/
,P1.important_opportunity_ind /*重要机会标志*/ ,P1.important_opportunity_ind /*重要机会标志*/
,P1.application_name /*应用名称*/ ,P1.application_name /*应用名称*/
,P1.opp_industry /*行业（opp)*/
,P1.estimated_close_time /*预期关闭时间*/ ,P1.estimated_close_time /*预期关闭时间*/
,P1.opp_industry /*行业（opp)*/
,P1.tag_list /*标签列表*/ ,P1.tag_list /*标签列表*/
,P1.discount_amount /*折扣金额*/ ,P1.discount_amount /*折扣金额*/
,P1.area_id /*地区编号*/ ,P1.area_id /*地区编号*/
@ -800,8 +809,8 @@ SELECT
,P1.account_number /*账号编号*/ ,P1.account_number /*账号编号*/
,P1.marketing_program_type /*市场项目类型*/ ,P1.marketing_program_type /*市场项目类型*/
,P1.lead_number /*线索编号*/ ,P1.lead_number /*线索编号*/
,P1.actualclosedate /*实际关闭日期*/
,P1.crm_contact_number /*联系人编号*/ ,P1.crm_contact_number /*联系人编号*/
,P1.parent_account_name /*父账号名称*/
,P1.Scd_Start_Dt /*开始时间*/ ,P1.Scd_Start_Dt /*开始时间*/
,P1.Scd_End_Dt /*结束时间*/ ,P1.Scd_End_Dt /*结束时间*/
,P1.Etl_Batch_No /*作业批次号*/ ,P1.Etl_Batch_No /*作业批次号*/
@ -811,10 +820,10 @@ SELECT
,P1.Etl_Tx_Dt /*作业运行时间*/ ,P1.Etl_Tx_Dt /*作业运行时间*/
,P1.Src_Sysname /*来源系统*/ ,P1.Src_Sysname /*来源系统*/
,P1.Src_Table /*来源表*/ ,P1.Src_Table /*来源表*/
,P1.parent_account_name /*父账号名称*/
,P1.parent_contact_name /*父联系人名称*/ ,P1.parent_contact_name /*父联系人名称*/
,P1.product_name /*产品名称*/ ,P1.product_name /*产品名称*/
,P1.product_class /*产品类别*/ ,P1.product_class /*产品类别*/
,P1.currency_name /*交易币种*/
FROM t01_crm_opportunity_agi_INS P1 FROM t01_crm_opportunity_agi_INS P1
; ;