721:
722: l_from_date :=to_date(p_from_date,'YYYY/MM/DD HH24:MI:SS');
723: l_to_date :=to_date(p_to_date, 'YYYY/MM/DD HH24:MI:SS');
724:
725: IF (Not EDW_COLLECTION_UTIL.setup(l_fact_name, l_staging_table,
726: l_staging_table, l_exception_msg)) THEN
727: errbuf := fnd_message.get;
728: RAISE_APPLICATION_ERROR (-20000, 'Error in SETUP: ' || errbuf);
729: END IF;
732: -- Taking care of cases where the input from/to
733: -- date is NULL.
734: -- --------------------------------------------
735: g_push_from_date := nvl(l_from_date,
736: EDW_COLLECTION_UTIL.G_local_last_push_start_date -
737: EDW_COLLECTION_UTIL.g_offset);
738:
739: g_push_to_date := nvl(l_to_date,
740: EDW_COLLECTION_UTIL.G_local_curr_push_start_date);
733: -- date is NULL.
734: -- --------------------------------------------
735: g_push_from_date := nvl(l_from_date,
736: EDW_COLLECTION_UTIL.G_local_last_push_start_date -
737: EDW_COLLECTION_UTIL.g_offset);
738:
739: g_push_to_date := nvl(l_to_date,
740: EDW_COLLECTION_UTIL.G_local_curr_push_start_date);
741:
736: EDW_COLLECTION_UTIL.G_local_last_push_start_date -
737: EDW_COLLECTION_UTIL.g_offset);
738:
739: g_push_to_date := nvl(l_to_date,
740: EDW_COLLECTION_UTIL.G_local_curr_push_start_date);
741:
742: edw_log.put_line( 'The collection range is from '||
743: to_char(g_push_from_date,'MM/DD/YYYY HH24:MI:SS')||' to '||
744: to_char(g_push_to_date,'MM/DD/YYYY HH24:MI:SS'));
833: edw_log.put_line('Inserted '||nvl(g_row_count,0)||
834: ' rows into the staging table');
835: edw_log.put_line(' ');
836:
837: EDW_COLLECTION_UTIL.wrapup(TRUE, g_row_count, l_exception_msg,
838: g_push_from_date, g_push_to_date);
839:
840:
841: -- ---------------------------------------------------------------------------
854:
855: l_exception_msg := Retcode || ':' || Errbuf;
856: rollback; -- Rollback insert into local staging
857: edw_log.put_line('Inserting into local staging have failed');
858: EDW_COLLECTION_UTIL.wrapup(FALSE, 0, l_exception_msg,
859: g_push_from_date, g_push_to_date);
860: raise;
861:
862: WHEN L_IDEN_CHANGE_FAILURE THEN
869:
870: l_exception_msg := Retcode || ':' || Errbuf;
871: TRUNCATE_INC;
872: edw_log.put_line('Identifying changed records have Failed');
873: EDW_COLLECTION_UTIL.wrapup(FALSE, 0, l_exception_msg,
874: g_push_from_date, g_push_to_date);
875: raise;
876:
877: WHEN L_INSERT_RCPT_FAILURE THEN
884:
885: l_exception_msg := Retcode || ':' || Errbuf;
886: rollback;
887: edw_log.put_line('Insert_rcpt has failed');
888: EDW_COLLECTION_UTIL.wrapup(FALSE, 0, l_exception_msg,
889: g_push_from_date, g_push_to_date);
890: raise;
891:
892: WHEN OTHERS THEN
899:
900: l_exception_msg := Retcode || ':' || Errbuf;
901: rollback;
902: edw_log.put_line('Other errors');
903: EDW_COLLECTION_UTIL.wrapup(FALSE, 0, l_exception_msg,
904: g_push_from_date, g_push_to_date);
905: raise;
906:
907: END;