DBA Data[Home] [Help]

APPS.BIL_BI_PIPELINE_F_PKG dependencies on BIL_BI_OPDTL_DENLOG_TMP

Line 1367: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_OPDTL_DENLOG_TMP');

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: ----------------------------------------------------
1370: -- CHECK FOR RESUME
1371: ----------------------------------------------------

Line 1450: bil_bi_util_collection_pkg.analyze_table('BIL_BI_OPDTL_DENLOG_TMP',TRUE, 10, 'GLOBAL');

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:
1454: -- this will insert the first day record

Line 1532: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_OPDTL_DENLOG_TMP');

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)
1536: SELECT TO_CHAR(MIN(snap_date),'DD-MM-YYYY')

Line 1793: bil_bi_util_collection_pkg.analyze_table('BIL_BI_OPDTL_DENLOG_TMP',TRUE, 10, 'GLOBAL');

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:
1797: l_failure_from := g_global_start_date;

Line 1947: bil_bi_util_collection_pkg.analyze_table('BIL_BI_OPDTL_DENLOG_TMP',TRUE, 10, 'GLOBAL');

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:
1951: Populate_Currency_Rate('INCR');

Line 2198: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_OPDTL_DENLOG_TMP');

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
2202:

Line 2836: bil_bi_util_collection_pkg.Truncate_Table('BIL_BI_OPDTL_DENLOG_TMP');

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,
2840: g_row_num,

Line 4733: INSERT /*+ append parallel(tmp) */ INTO bil_bi_opdtl_denlog_tmp tmp

4729:
4730:
4731: BEGIN
4732:
4733: INSERT /*+ append parallel(tmp) */ INTO bil_bi_opdtl_denlog_tmp tmp
4734: (lead_id,
4735: lead_log_id,
4736: lead_line_id,
4737: lead_line_log_id,

Line 4954: -- delete /*+ parallel(tmp1) */ from BIL_BI_OPDTL_DENLOG_TMP tmp1

4950:
4951:
4952: -- we don't need to delete any more since we get
4953: --latest update for the day with endday_log_flag
4954: -- delete /*+ parallel(tmp1) */ from BIL_BI_OPDTL_DENLOG_TMP tmp1
4955: /* where exists (select 1 from BIL_BI_OPDTL_DENLOG_TMP tmp2
4956: where tmp1.lead_id = tmp2.lead_id
4957: and tmp1.lead_line_id = tmp2.lead_line_id
4958: and tmp1.sales_credit_id = tmp2.sales_credit_id

Line 4955: /* where exists (select 1 from BIL_BI_OPDTL_DENLOG_TMP tmp2

4951:
4952: -- we don't need to delete any more since we get
4953: --latest update for the day with endday_log_flag
4954: -- delete /*+ parallel(tmp1) */ from BIL_BI_OPDTL_DENLOG_TMP tmp1
4955: /* where exists (select 1 from BIL_BI_OPDTL_DENLOG_TMP tmp2
4956: where tmp1.lead_id = tmp2.lead_id
4957: and tmp1.lead_line_id = tmp2.lead_line_id
4958: and tmp1.sales_credit_id = tmp2.sales_credit_id
4959: and tmp1.last_update_date = tmp2.last_update_date

Line 5009: FROM BIL_BI_OPDTL_DENLOG_TMP tmp

5005: , status.opp_open_status_flag open_status_flag
5006: , creditlog.credit_amount
5007: , tmp.last_update_date
5008: , NVL(linelog.forecast_date, leadlog.decision_date)
5009: FROM BIL_BI_OPDTL_DENLOG_TMP tmp
5010: ,as_sales_credits_log creditlog
5011: , as_lead_lines_log linelog
5012: , as_leads_log leadlog
5013: , as_statuses_b status

Line 5057: INSERT INTO bil_bi_opdtl_denlog_tmp tmp

5053:
5054:
5055: ELSE
5056:
5057: INSERT INTO bil_bi_opdtl_denlog_tmp tmp
5058: (lead_id,
5059: lead_log_id,
5060: lead_line_id,
5061: lead_line_log_id,

Line 5265: /*delete from BIL_BI_OPDTL_DENLOG_TMP tmp1

5261: p_module => g_pkg || l_proc ,
5262: p_msg => 'inserted ' || sql%rowcount || 'into denlog_tmp');
5263: END IF;
5264:
5265: /*delete from BIL_BI_OPDTL_DENLOG_TMP tmp1
5266: where exists (select 1 from BIL_BI_OPDTL_DENLOG_TMP tmp2
5267: where tmp1.lead_id = tmp2.lead_id
5268: and tmp1.lead_line_id = tmp2.lead_line_id
5269: and tmp1.sales_credit_id = tmp2.sales_credit_id

Line 5266: where exists (select 1 from BIL_BI_OPDTL_DENLOG_TMP tmp2

5262: p_msg => 'inserted ' || sql%rowcount || 'into denlog_tmp');
5263: END IF;
5264:
5265: /*delete from BIL_BI_OPDTL_DENLOG_TMP tmp1
5266: where exists (select 1 from BIL_BI_OPDTL_DENLOG_TMP tmp2
5267: where tmp1.lead_id = tmp2.lead_id
5268: and tmp1.lead_line_id = tmp2.lead_line_id
5269: and tmp1.sales_credit_id = tmp2.sales_credit_id
5270: and tmp1.last_update_date = tmp2.last_update_date

Line 5323: FROM BIL_BI_OPDTL_DENLOG_TMP tmp

5319: , status.opp_open_status_flag open_status_flag
5320: , creditlog.credit_amount
5321: , tmp.last_update_date
5322: , NVL(linelog.forecast_date, leadlog.decision_date)
5323: FROM BIL_BI_OPDTL_DENLOG_TMP tmp
5324: ,as_sales_credits_log creditlog
5325: , as_lead_lines_log linelog
5326: , as_leads_log leadlog
5327: , as_statuses_b status

Line 5498: WHERE EXISTS (SELECT /*+ parallel(tmp) */ 1 FROM bil_bi_opdtl_denlog_tmp tmp

5494:
5495: IF (p_small_gap = FALSE) THEN
5496: -- if gap bigger than 3 days, delet and insert into staging for current date
5497: DELETE /*+ parallel(stg1) */ FROM bil_bi_pipeline_stg stg1
5498: WHERE EXISTS (SELECT /*+ parallel(tmp) */ 1 FROM bil_bi_opdtl_denlog_tmp tmp
5499: WHERE tmp.lead_id = stg1.lead_id
5500: AND tmp.lead_line_id = stg1.line_id
5501: AND tmp.sales_credit_id = stg1.credit_id
5502: AND last_update_date = l_cur_date);

Line 5808: WHERE EXISTS (SELECT 1 FROM bil_bi_opdtl_denlog_tmp tmp

5804:
5805: ELSE
5806: IF (p_small_gap = FALSE) THEN --gap bigger than 3 days
5807: DELETE /*+ index(stg1,BIL_BI_PIPELINE_STG_U1) */ FROM bil_bi_pipeline_stg stg1
5808: WHERE EXISTS (SELECT 1 FROM bil_bi_opdtl_denlog_tmp tmp
5809: WHERE tmp.lead_id = stg1.lead_id
5810: AND tmp.lead_line_id = stg1.line_id
5811:
5812: AND tmp.sales_credit_id = stg1.credit_id