567:
568: if g_debug_flag = 'Y' then
569: edw_log.put_line(' ');
570: edw_log.put_line('Cleaning up unprocessed records left in local staging table');
571: fii_util.start_timer;
572: end if;
573:
574: IF (NOT LOCAL_SAME_AS_REMOTE) THEN
575: TRUNCATE_STG;
577: DELETE_STG;
578: END IF;
579:
580: if g_debug_flag = 'Y' then
581: fii_util.stop_timer;
582: fii_util.print_timer('Process Time');
583: end if;
584:
585: -- --------------------------------------------------------
578: END IF;
579:
580: if g_debug_flag = 'Y' then
581: fii_util.stop_timer;
582: fii_util.print_timer('Process Time');
583: end if;
584:
585: -- --------------------------------------------------------
586: -- 2. Identify Changed records int the PA_BUDGET_LINES table
587: -- --------------------------------------------------------
588:
589: if g_debug_flag = 'Y' then
590: edw_log.put_line(' ');
591: fii_util.start_timer;
592: end if;
593:
594: if NOT IDENTIFY_CHANGE(l_conversion_date) THEN
595: RAISE l_iden_change_failure;
595: RAISE l_iden_change_failure;
596: end if;
597:
598: if g_debug_flag = 'Y' then
599: fii_util.stop_timer;
600: fii_util.print_timer('Process Time');
601: end if;
602:
603: -- --------------------------------------------------------
596: end if;
597:
598: if g_debug_flag = 'Y' then
599: fii_util.stop_timer;
600: fii_util.print_timer('Process Time');
601: end if;
602:
603: -- --------------------------------------------------------
604: -- 3. Pushing data to local staging table
606:
607: if g_debug_flag = 'Y' then
608: edw_log.put_line(' ');
609: edw_log.put_line('Pushing data');
610: fii_util.start_timer;
611: end if;
612:
613: g_row_count := PUSH_TO_LOCAL;
614:
612:
613: g_row_count := PUSH_TO_LOCAL;
614:
615: if g_debug_flag = 'Y' then
616: fii_util.stop_timer;
617: fii_util.print_timer('Process Time');
618: end if;
619:
620: IF (g_row_count = -1) THEN
613: g_row_count := PUSH_TO_LOCAL;
614:
615: if g_debug_flag = 'Y' then
616: fii_util.stop_timer;
617: fii_util.print_timer('Process Time');
618: end if;
619:
620: IF (g_row_count = -1) THEN
621: RAISE L_push_local_failure;
680:
681: if g_debug_flag = 'Y' then
682: edw_log.put_line(' ');
683: edw_log.put_line('Moving data from local staging table to remote staging table');
684: fii_util.start_timer;
685: end if;
686:
687: g_row_count := PUSH_REMOTE;
688:
686:
687: g_row_count := PUSH_REMOTE;
688:
689: if g_debug_flag = 'Y' then
690: fii_util.stop_timer;
691: fii_util.print_timer('Process Time');
692: end if;
693:
694: IF (g_row_count = -1) THEN RAISE l_push_remote_failure; END IF;
687: g_row_count := PUSH_REMOTE;
688:
689: if g_debug_flag = 'Y' then
690: fii_util.stop_timer;
691: fii_util.print_timer('Process Time');
692: end if;
693:
694: IF (g_row_count = -1) THEN RAISE l_push_remote_failure; END IF;
695:
695:
696: if g_debug_flag = 'Y' then
697: edw_log.put_line(' ');
698: edw_log.put_line('Cleaning local staging table');
699: fii_util.start_timer;
700: end if;
701:
702: TRUNCATE_STG;
703:
701:
702: TRUNCATE_STG;
703:
704: if g_debug_flag = 'Y' then
705: fii_util.stop_timer;
706: fii_util.print_timer('Process Time');
707: end if;
708:
709: ELSE
702: TRUNCATE_STG;
703:
704: if g_debug_flag = 'Y' then
705: fii_util.stop_timer;
706: fii_util.print_timer('Process Time');
707: end if;
708:
709: ELSE
710: -- -----------------------------------------------
715:
716: if g_debug_flag = 'Y' then
717: edw_log.put_line(' ');
718: edw_log.put_line('Marking records in staging table with READY status');
719: fii_util.start_timer;
720: end if;
721:
722: g_row_count := SET_STATUS_READY;
723:
721:
722: g_row_count := SET_STATUS_READY;
723:
724: if g_debug_flag = 'Y' then
725: fii_util.stop_timer;
726: fii_util.print_timer('Duration');
727: end if;
728:
729: DELETE_STG;
722: g_row_count := SET_STATUS_READY;
723:
724: if g_debug_flag = 'Y' then
725: fii_util.stop_timer;
726: fii_util.print_timer('Duration');
727: end if;
728:
729: DELETE_STG;
730: IF (g_row_count = -1) THEN RAISE l_set_status_failure; END IF;