APPS.OPI_EDW_OPI_JOB_DETAIL_F_C dependencies on EDW_COLLECTION_UTIL

Line 418: IF (Not EDW_COLLECTION_UTIL.setup(l_fact_name,

414: BEGIN
415: Errbuf :=NULL;
416: Retcode:=0;
417:
418: IF (Not EDW_COLLECTION_UTIL.setup(l_fact_name,
419: l_staging_table,
420: l_staging_table,
421: l_exception_msg)) THEN
422: errbuf := fnd_message.get;

Line 431: EDW_COLLECTION_UTIL.G_local_last_push_start_date

427: l_to_date := To_date(p_to_date, 'YYYY/MM/DD HH24:MI:SS');
428:
429: g_push_from_date
430: := nvl(l_from_date,
431: EDW_COLLECTION_UTIL.G_local_last_push_start_date
432: - EDW_COLLECTION_UTIL.g_offset);
433:
434: g_push_to_date:= nvl(l_to_date,EDW_COLLECTION_UTIL.G_local_curr_push_start_date);
435:

Line 432: - EDW_COLLECTION_UTIL.g_offset);

428:
429: g_push_from_date
430: := nvl(l_from_date,
431: EDW_COLLECTION_UTIL.G_local_last_push_start_date
432: - EDW_COLLECTION_UTIL.g_offset);
433:
434: g_push_to_date:= nvl(l_to_date,EDW_COLLECTION_UTIL.G_local_curr_push_start_date);
435:
436: --l_date1 := g_push_date_range1;

Line 434: g_push_to_date:= nvl(l_to_date,EDW_COLLECTION_UTIL.G_local_curr_push_start_date);

430: := nvl(l_from_date,
431: EDW_COLLECTION_UTIL.G_local_last_push_start_date
432: - EDW_COLLECTION_UTIL.g_offset);
433:
434: g_push_to_date:= nvl(l_to_date,EDW_COLLECTION_UTIL.G_local_curr_push_start_date);
435:
436: --l_date1 := g_push_date_range1;
437: --l_date2 := g_push_date_range2;
438:

Line 541: if EDW_COLLECTION_UTIL.source_same_as_target then

537: edw_log.put_line ('--- END OF FILE ----');
538: END IF;
539: CLOSE cur_missing_rates;
540:
541: if EDW_COLLECTION_UTIL.source_same_as_target then
542: DELETE FROM OPI_EDW_JOB_DETAIL_FSTG
543: WHERE SUBSTRB(JOB_DETAIL_PK,LENGTH(JOB_DETAIL_PK)-2,3) = 'OPI'
544: AND COLLECTION_STATUS IN ('RATE NOT AVAILABLE', 'INVALID CURRENCY');
545: l_rows_deleted:= sql%rowcount;

Line 566: EDW_COLLECTION_UTIL.wrapup(TRUE,

562: edw_log.put_line('Inserted '|| to_char(nvl(g_row_count,0) - nvl(l_rows_deleted,0))||
563: ' rows into the staging table');
564: edw_log.put_line(' ');
565:
566: EDW_COLLECTION_UTIL.wrapup(TRUE,
567: g_row_count,
568: l_exception_msg,
569: g_push_from_date,
570: g_push_to_date);

Line 583: EDW_COLLECTION_UTIL.wrapup(FALSE, 0, l_exception_msg,g_push_from_date,g_push_to_date);

579: Retcode:=g_retcode;
580: l_exception_msg := Retcode || ':' || Errbuf;
581: rollback; -- Rollback insert into local staging
582: edw_log.put_line('Inserting into local staging have failed');
583: EDW_COLLECTION_UTIL.wrapup(FALSE, 0, l_exception_msg,g_push_from_date,g_push_to_date);
584: raise;
585:
586: WHEN L_IDEN_CHANGE_FAILURE THEN
587: Errbuf:=g_errbuf;

Line 597: EDW_COLLECTION_UTIL.wrapup(FALSE, 0, l_exception_msg,g_push_from_date,g_push_to_date);

593: execute immediate 'truncate table ' || l_opi_schema
594: || '.opi_edw_opi_job_detail_inc ';
595: END IF;
596: edw_log.put_line('Identifying changed records have Failed');
597: EDW_COLLECTION_UTIL.wrapup(FALSE, 0, l_exception_msg,g_push_from_date,g_push_to_date);
598: raise;
599:
600: WHEN OTHERS THEN
601: Errbuf:= Sqlerrm;

Line 606: EDW_COLLECTION_UTIL.wrapup(FALSE, 0, l_exception_msg,

602: Retcode:=sqlcode;
603: l_exception_msg := Retcode || ':' || Errbuf;
604: rollback;
605: edw_log.put_line('Other errors');
606: EDW_COLLECTION_UTIL.wrapup(FALSE, 0, l_exception_msg,
607: g_push_from_date, g_push_to_date);
608: raise;
609:
610: END push;