DBA Data[Home] [Help]

APPS.BIL_BI_PIPELINE_F_PKG dependencies on BIL_BI_DENLOG_STG

Line 1365: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_DENLOG_STG');

1361: BIS_COLLECTION_UTILITIES.deleteLogForObject ('BIL_BI_PIPEC_F');
1362: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_PIPELINE_STG');
1363: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_PIPELINE_F');
1364: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_PIPEC_F');
1365: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_DENLOG_STG');
1366: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_TIME');
1367: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_OPDTL_DENLOG_TMP');
1368: ELSE
1369: ----------------------------------------------------

Line 1373: union all select count(1) cnt from BIL_BI_DENLOG_STG)

1369: ----------------------------------------------------
1370: -- CHECK FOR RESUME
1371: ----------------------------------------------------
1372: SELECT sum(cnt) INTO l_count FROM (select count(1) cnt from bil_bi_pipeline_stg
1373: union all select count(1) cnt from BIL_BI_DENLOG_STG)
1374: ;
1375: IF bil_bi_util_collection_pkg.chkLogLevel(fnd_log.LEVEL_EVENT) THEN
1376: bil_bi_util_collection_pkg.writeLog
1377: (

Line 1449: bil_bi_util_collection_pkg.analyze_table('BIL_BI_DENLOG_STG',TRUE, 10, 'GLOBAL');

1445: );
1446: END IF;
1447:
1448: bil_bi_util_collection_pkg.analyze_table('BIL_BI_PIPELINE_STG',TRUE, 10, 'GLOBAL');
1449: bil_bi_util_collection_pkg.analyze_table('BIL_BI_DENLOG_STG',TRUE, 10, 'GLOBAL');
1450: bil_bi_util_collection_pkg.analyze_table('BIL_BI_OPDTL_DENLOG_TMP',TRUE, 10, 'GLOBAL');
1451:
1452:
1453:

Line 1530: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_DENLOG_STG');

1526:
1527:
1528: l_resume_flag := 'Y';
1529: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_PIPELINE_STG');
1530: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_DENLOG_STG');
1531: --execute immediate 'Truncate table BIL_BI_DENLOG_STG';
1532: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_OPDTL_DENLOG_TMP');
1533:
1534: -- Added by TR (to populate the correct period_to and period_from dates in Attribute

Line 1531: --execute immediate 'Truncate table BIL_BI_DENLOG_STG';

1527:
1528: l_resume_flag := 'Y';
1529: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_PIPELINE_STG');
1530: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_DENLOG_STG');
1531: --execute immediate 'Truncate table BIL_BI_DENLOG_STG';
1532: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_OPDTL_DENLOG_TMP');
1533:
1534: -- Added by TR (to populate the correct period_to and period_from dates in Attribute
1535: -- columns of bis_refresh_log)

Line 1792: bil_bi_util_collection_pkg.analyze_table('BIL_BI_DENLOG_STG',TRUE, 10, 'GLOBAL');

1788: -- l_date instead of l_date -1 is because denlog will check for time < l_date
1789: Build_Denlog(l_start_date+1, l_date, l_curr_coll_start, 'INIT');
1790:
1791: bil_bi_util_collection_pkg.analyze_table('BIL_BI_PIPELINE_STG',TRUE, 10, 'GLOBAL');
1792: bil_bi_util_collection_pkg.analyze_table('BIL_BI_DENLOG_STG',TRUE, 10, 'GLOBAL');
1793: bil_bi_util_collection_pkg.analyze_table('BIL_BI_OPDTL_DENLOG_TMP',TRUE, 10, 'GLOBAL');
1794:
1795: Populate_Currency_Rate('INIT');
1796:

Line 1946: bil_bi_util_collection_pkg.analyze_table('BIL_BI_DENLOG_STG',TRUE, 10, 'GLOBAL');

1942:
1943: Build_Denlog(l_last_run+2, l_date, l_curr_coll_start, 'INCR');
1944:
1945: bil_bi_util_collection_pkg.analyze_table('BIL_BI_PIPELINE_STG',TRUE, 10, 'GLOBAL');
1946: bil_bi_util_collection_pkg.analyze_table('BIL_BI_DENLOG_STG',TRUE, 10, 'GLOBAL');
1947: bil_bi_util_collection_pkg.analyze_table('BIL_BI_OPDTL_DENLOG_TMP',TRUE, 10, 'GLOBAL');
1948:
1949:
1950:

Line 2196: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_DENLOG_STG');

2192:
2193: -- clean up
2194:
2195: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_PIPELINE_STG');
2196: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_DENLOG_STG');
2197: --execute immediate 'Truncate table BIL_BI_DENLOG_STG';
2198: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_OPDTL_DENLOG_TMP');
2199: -- regular snapshot
2200:

Line 2197: --execute immediate 'Truncate table BIL_BI_DENLOG_STG';

2193: -- clean up
2194:
2195: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_PIPELINE_STG');
2196: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_DENLOG_STG');
2197: --execute immediate 'Truncate table BIL_BI_DENLOG_STG';
2198: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_OPDTL_DENLOG_TMP');
2199: -- regular snapshot
2200:
2201: -- delete the existing snapshot, since could be multiple runs anyway in the same day

Line 2834: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_DENLOG_STG');

2830: WHEN OTHERS Then
2831:
2832:
2833: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_PIPELINE_STG');
2834: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_DENLOG_STG');
2835: --execute immediate 'Truncate table BIL_BI_DENLOG_STG';
2836: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_OPDTL_DENLOG_TMP');
2837:
2838: commit;

Line 2835: --execute immediate 'Truncate table BIL_BI_DENLOG_STG';

2831:
2832:
2833: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_PIPELINE_STG');
2834: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_DENLOG_STG');
2835: --execute immediate 'Truncate table BIL_BI_DENLOG_STG';
2836: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_OPDTL_DENLOG_TMP');
2837:
2838: commit;
2839: BIS_COLLECTION_UTILITIES.wrapup(FALSE,

Line 2894: from BIL_BI_DENLOG_STG stg

2890: from bil_bi_pipeline_stg stg
2891: where effective_date >= g_global_start_date
2892: UNION ALL
2893: select /*+ parallel(stg) */ currency_code, decision_date
2894: from BIL_BI_DENLOG_STG stg
2895: where decision_date >= g_global_start_date
2896: )
2897: )
2898: ) rates

Line 2949: from BIL_BI_DENLOG_STG stg

2945: from bil_bi_pipeline_stg stg
2946: where effective_date >= g_global_start_date
2947: UNION ALL
2948: select currency_code, decision_date
2949: from BIL_BI_DENLOG_STG stg
2950: where decision_date >= g_global_start_date
2951: )
2952: )
2953: ) rates

Line 3043: SELECT lead_number FROM BIL_BI_DENLOG_STG

3039: SELECT lead_number FROM bil_bi_pipeline_stg
3040: WHERE nvl(product_category_id,-1)=-1
3041: and effective_date >= g_global_start_date
3042: union all
3043: SELECT lead_number FROM BIL_BI_DENLOG_STG
3044: WHERE nvl(product_category_id,-1)=-1
3045: and decision_date >= g_global_start_date;
3046:
3047:

Line 3078: MERGE /*+ PARALLEL(stg) */ INTO bil_bi_denlog_stg stg

3074: exchange_date = stg.effective_date
3075: );
3076:
3077:
3078: MERGE /*+ PARALLEL(stg) */ INTO bil_bi_denlog_stg stg
3079: USING
3080: (SELECT /*+ PARALLEL(rates) */
3081: exchange_rate,
3082: exchange_rate_s,

Line 3106: UPDATE BIL_BI_DENLOG_STG stg

3102: exchange_date = stg.effective_date
3103: );
3104:
3105:
3106: UPDATE BIL_BI_DENLOG_STG stg
3107: SET (stg.prim_conversion_rate,conversion_rate_s) =
3108: (
3109: select
3110: exchange_rate,exchange_rate_s

Line 3141: select /*+ parallel(stg) */ count(1) cnt from BIL_BI_DENLOG_STG stg

3137: WHERE ((prim_conversion_rate < 0 OR prim_conversion_rate IS NULL)
3138: OR (g_sec_currency IS NOT NULL and (conversion_rate_s < 0 OR conversion_rate_s IS NULL)))
3139: and effective_date >= g_global_start_date
3140: union all
3141: select /*+ parallel(stg) */ count(1) cnt from BIL_BI_DENLOG_STG stg
3142: WHERE ((prim_conversion_rate < 0 OR prim_conversion_rate IS NULL)
3143: OR (g_sec_currency IS NOT NULL and (conversion_rate_s < 0 OR conversion_rate_s IS NULL)))
3144: and decision_date >= g_global_start_date
3145: );

Line 3155: select count(1) cnt from BIL_BI_DENLOG_STG

3151: WHERE ((prim_conversion_rate < 0 OR prim_conversion_rate IS NULL)
3152: OR (g_sec_currency IS NOT NULL and (conversion_rate_s < 0 OR conversion_rate_s IS NULL)))
3153: and effective_date >= g_global_start_date
3154: union all
3155: select count(1) cnt from BIL_BI_DENLOG_STG
3156: WHERE ((prim_conversion_rate < 0 OR prim_conversion_rate IS NULL)
3157: OR (g_sec_currency IS NOT NULL and (conversion_rate_s < 0 OR conversion_rate_s IS NULL)))
3158: and decision_date >= g_global_start_date
3159: );

Line 3190: select /*+ parallel(stg) stg*/last_update_date snap_date, decision_date effective_date from BIL_BI_DENLOG_STG stg

3186: INTO l_stg_min_txn_dt, l_stg_max_txn_dt, l_stg_min_eff_dt, l_stg_max_eff_dt
3187: FROM (select /*+ parallel(stg) stg*/ snap_date , effective_date from BIL_BI_PIPELINE_STG stg
3188: where effective_date >= g_global_start_date
3189: union all
3190: select /*+ parallel(stg) stg*/last_update_date snap_date, decision_date effective_date from BIL_BI_DENLOG_STG stg
3191: where decision_date >= g_global_start_date) stg;
3192: ELSE
3193: SELECT MIN(stg.SNAP_DATE), Max(stg.SNAP_DATE)
3194: ,MIN(stg.Effective_DATE), Max(stg.Effective_DATE)

Line 3199: select last_update_date snap_date, decision_date effective_date from BIL_BI_DENLOG_STG

3195: INTO l_stg_min_txn_dt, l_stg_max_txn_dt, l_stg_min_eff_dt, l_stg_max_eff_dt
3196: FROM (select snap_date , effective_date from BIL_BI_PIPELINE_STG
3197: where effective_date >= g_global_start_date
3198: union all
3199: select last_update_date snap_date, decision_date effective_date from BIL_BI_DENLOG_STG
3200: where decision_date >= g_global_start_date) stg;
3201: END IF;
3202:
3203: IF (l_stg_min_txn_dt < l_stg_min_eff_dt) THEN

Line 3466: from BIL_BI_DENLOG_STG

3462: OR (g_sec_currency IS NOT NULL and (conversion_rate_s < 0 OR conversion_rate_s IS NULL)))
3463: and effective_date >= g_global_start_date
3464: union all
3465: select currency_code , decision_date, prim_conversion_rate, CONVERSION_RATE_S
3466: from BIL_BI_DENLOG_STG
3467: WHERE
3468: ((prim_conversion_rate < 0 OR prim_conversion_rate IS NULL )
3469: OR (g_sec_currency IS NOT NULL and (conversion_rate_s < 0 OR conversion_rate_s IS NULL)))
3470: and decision_date >= g_global_start_date

Line 4969: INSERT /*+ append parallel(denlog_stg) */ INTO BIL_BI_DENLOG_STG denlog_stg

4965:
4966:
4967: --- ok to filter stuff out here since checking is using denlog_tmp table not denlog_stg
4968: BEGIN
4969: INSERT /*+ append parallel(denlog_stg) */ INTO BIL_BI_DENLOG_STG denlog_stg
4970: (
4971:
4972: LEAD_LINE_ID ,
4973: SALES_CREDIT_ID ,

Line 5283: INSERT INTO BIL_BI_DENLOG_STG denlog_stg

5279: p_module => g_pkg || l_proc ,
5280: p_msg => 'deleted ' || sql%rowcount || 'from denlog_tmp for same day update ');
5281: END IF;
5282:
5283: INSERT INTO BIL_BI_DENLOG_STG denlog_stg
5284: (
5285:
5286: LEAD_LINE_ID ,
5287: SALES_CREDIT_ID ,

Line 5592: FROM BIL_BI_DENLOG_STG tmp

5588: , decision_date
5589: , prim_conversion_rate
5590:
5591: , conversion_rate_s
5592: FROM BIL_BI_DENLOG_STG tmp
5593: WHERE tmp.last_update_date = l_cur_date
5594: AND product_category_id is not null;
5595:
5596:

Line 5899: FROM BIL_BI_DENLOG_STG tmp

5895:
5896: , decision_date
5897: , prim_conversion_rate
5898: , conversion_rate_s
5899: FROM BIL_BI_DENLOG_STG tmp
5900: WHERE tmp.last_update_date = l_cur_date
5901: AND product_category_id is not null;
5902:
5903: