[Home] [Help]
1: PACKAGE BODY PJI_FM_PLAN_MAINT AS
2: /* $Header: PJIPP01B.pls 120.37.12010000.3 2009/02/02 16:23:50 kmaddi ship $ */
3:
4:
5: g_package_name VARCHAR2(100) := 'PJI_FM_PLAN_MAINT';
1: PACKAGE BODY PJI_FM_PLAN_MAINT AS
2: /* $Header: PJIPP01B.pls 120.37.12010000.3 2009/02/02 16:23:50 kmaddi ship $ */
3:
4:
5: g_package_name VARCHAR2(100) := 'PJI_FM_PLAN_MAINT';
6:
7: g_worker_id NUMBER := PJI_PJP_FP_CURR_WRAP.GET_WORKER_ID; -- NULL;
8: g_event_rec PA_PJI_PROJ_EVENTS_LOG%ROWTYPE;
9: g_process_update_wbs_flag VARCHAR2(1) := 'N' ;
668: -------------------------------------------------------------------------
669: -- Preparing for extraction and extracting from budget lines.
670: -------------------------------------------------------------------------
671:
672: PJI_FM_PLAN_MAINT_T_PVT.CLEANUP_INTERIM_TABLES; print_time(' 3 ..1 ');
673:
674:
675: IF (p_is_primary_rbs = 'T') THEN
676:
673:
674:
675: IF (p_is_primary_rbs = 'T') THEN
676:
677: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_FIN_PLAN_VERSIONS(
678: p_fp_version_ids => p_fp_version_ids
679: , p_slice_type => 'PRI');
680:
681: ELSE
687: IF (CHECK_VER3_NOT_EMPTY(p_online => 'T') = 'F') THEN
688: RETURN;
689: END IF;
690:
691: PJI_FM_PLAN_MAINT_T_PVT.MAP_ORG_CAL_INFO('N');
692: print_time(' 2.. Update org/cal tables. ');
693:
694:
695: print_time(' ************** Denorm processing begin ************** ');
770: print_time(' ***************************************************** ');
771: print_time(' ************** Denorm processing end **************** ');
772:
773: --Introduced below api call for bug 7187487
774: --PJI_FM_PLAN_MAINT_T_PVT.GET_GLOBAL_EXCHANGE_RATES; -- Bug 7681331
775:
776: IF (p_is_primary_rbs = 'T') THEN
777: --Introduced below api call for bug 7187487
778: -- PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_PLAN_AMTS_PRIRBS_GLC12; --Bug 7681331
774: --PJI_FM_PLAN_MAINT_T_PVT.GET_GLOBAL_EXCHANGE_RATES; -- Bug 7681331
775:
776: IF (p_is_primary_rbs = 'T') THEN
777: --Introduced below api call for bug 7187487
778: -- PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_PLAN_AMTS_PRIRBS_GLC12; --Bug 7681331
779: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_PLAN_AMOUNTS_PRIRBS;
780: print_time(' 5.1 .. ');
781:
782: ELSE
775:
776: IF (p_is_primary_rbs = 'T') THEN
777: --Introduced below api call for bug 7187487
778: -- PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_PLAN_AMTS_PRIRBS_GLC12; --Bug 7681331
779: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_PLAN_AMOUNTS_PRIRBS;
780: print_time(' 5.1 .. ');
781:
782: ELSE
783:
781:
782: ELSE
783:
784: MAP_RESOURCE_LIST (p_fp_version_ids);
785: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_PLAN_AMOUNTS_SECRBS; print_time(' 5.2 .. ');
786:
787: END IF;
788:
789: -- With data in ver3 table and pjp1 tables,
792:
793:
794: PRI_SLICE_CREATE_T; print_time(' 6 .. ');
795: PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_SMART_SLICES;
796: PJI_FM_PLAN_MAINT_T_PVT.MERGE_INTO_FP_FACT; print_time(' 14 .. ');
797:
798: PJI_FM_PLAN_MAINT_T_PVT.MARK_EXTRACTED_PLANS('PRI'); print_time(' 15 .. ');
799:
800:
794: PRI_SLICE_CREATE_T; print_time(' 6 .. ');
795: PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_SMART_SLICES;
796: PJI_FM_PLAN_MAINT_T_PVT.MERGE_INTO_FP_FACT; print_time(' 14 .. ');
797:
798: PJI_FM_PLAN_MAINT_T_PVT.MARK_EXTRACTED_PLANS('PRI'); print_time(' 15 .. ');
799:
800:
801: IF (p_commit = 'T') THEN
802: COMMIT;
833:
834: print_time('CREATE_SECONDARY_PVT: begin.. ');
835:
836:
837: Pji_Fm_Plan_Maint_Pvt.EXTRACT_FIN_PLAN_VERS_BULK(p_slice_type => 'SEC_PROJ');
838: Pji_Fm_Plan_Maint_Pvt.EXTRACT_FIN_PLAN_VERS_BULK(p_slice_type => 'SECRBS_PROJ');
839: print_time(' Identified plan versions to be extracted. ');
840:
841: IF (CHECK_VER3_NOT_EMPTY(p_online => 'F') = 'F') THEN
834: print_time('CREATE_SECONDARY_PVT: begin.. ');
835:
836:
837: Pji_Fm_Plan_Maint_Pvt.EXTRACT_FIN_PLAN_VERS_BULK(p_slice_type => 'SEC_PROJ');
838: Pji_Fm_Plan_Maint_Pvt.EXTRACT_FIN_PLAN_VERS_BULK(p_slice_type => 'SECRBS_PROJ');
839: print_time(' Identified plan versions to be extracted. ');
840:
841: IF (CHECK_VER3_NOT_EMPTY(p_online => 'F') = 'F') THEN
842: print_time(' No data in ver3, returning. ');
842: print_time(' No data in ver3, returning. ');
843: RETURN;
844: END IF;
845:
846: Pji_Fm_Plan_Maint_Pvt.GET_GLOBAL_EXCHANGE_RATES;
847: print_time(' Got global exchange rates. ');
848:
849: Pji_Fm_Plan_Maint_Pvt.POPULATE_RBS_HDR;
850: print_time('Populated RBS header table.');
845:
846: Pji_Fm_Plan_Maint_Pvt.GET_GLOBAL_EXCHANGE_RATES;
847: print_time(' Got global exchange rates. ');
848:
849: Pji_Fm_Plan_Maint_Pvt.POPULATE_RBS_HDR;
850: print_time('Populated RBS header table.');
851:
852: Pji_Fm_Plan_Maint_Pvt.POPULATE_WBS_HDR;
853: print_time('Populated WBS header table.');
848:
849: Pji_Fm_Plan_Maint_Pvt.POPULATE_RBS_HDR;
850: print_time('Populated RBS header table.');
851:
852: Pji_Fm_Plan_Maint_Pvt.POPULATE_WBS_HDR;
853: print_time('Populated WBS header table.');
854:
855: Pji_Fm_Plan_Maint_Pvt.EXTRACT_PLAN_AMTS_PRIRBS_GLC12;
856: print_time(' Extracted plan data for primary RBSes.');
851:
852: Pji_Fm_Plan_Maint_Pvt.POPULATE_WBS_HDR;
853: print_time('Populated WBS header table.');
854:
855: Pji_Fm_Plan_Maint_Pvt.EXTRACT_PLAN_AMTS_PRIRBS_GLC12;
856: print_time(' Extracted plan data for primary RBSes.');
857:
858: Pji_Fm_Plan_Maint_Pvt.EXTRACT_PLAN_AMTS_SECRBS_GLC12;
859: print_time(' Extracted plan data for primary RBSes.');
854:
855: Pji_Fm_Plan_Maint_Pvt.EXTRACT_PLAN_AMTS_PRIRBS_GLC12;
856: print_time(' Extracted plan data for primary RBSes.');
857:
858: Pji_Fm_Plan_Maint_Pvt.EXTRACT_PLAN_AMTS_SECRBS_GLC12;
859: print_time(' Extracted plan data for primary RBSes.');
860:
861: Pji_Fm_Plan_Maint_Pvt.DELETE_GLOBAL_EXCHANGE_RATES;
862: print_time(' Deleted global exchange rates. ');
857:
858: Pji_Fm_Plan_Maint_Pvt.EXTRACT_PLAN_AMTS_SECRBS_GLC12;
859: print_time(' Extracted plan data for primary RBSes.');
860:
861: Pji_Fm_Plan_Maint_Pvt.DELETE_GLOBAL_EXCHANGE_RATES;
862: print_time(' Deleted global exchange rates. ');
863:
864: Pji_Fm_Plan_Maint_Pvt.PRORATE_TO_ALL_CALENDARS;
865: print_time(' Prorated to all calendars. ');
860:
861: Pji_Fm_Plan_Maint_Pvt.DELETE_GLOBAL_EXCHANGE_RATES;
862: print_time(' Deleted global exchange rates. ');
863:
864: Pji_Fm_Plan_Maint_Pvt.PRORATE_TO_ALL_CALENDARS;
865: print_time(' Prorated to all calendars. ');
866:
867: PJI_FM_PLAN_MAINT_PVT.UPDATE_WBS_HDR;
868: print_time(' Updated the WBS header table with min max txn dates.');
863:
864: Pji_Fm_Plan_Maint_Pvt.PRORATE_TO_ALL_CALENDARS;
865: print_time(' Prorated to all calendars. ');
866:
867: PJI_FM_PLAN_MAINT_PVT.UPDATE_WBS_HDR;
868: print_time(' Updated the WBS header table with min max txn dates.');
869:
870: Pji_Fm_Plan_Maint_Pvt.EXTRACT_DANGL_REVERSAL;
871: print_time(' Inserted Reversal records for dangling plans.');
866:
867: PJI_FM_PLAN_MAINT_PVT.UPDATE_WBS_HDR;
868: print_time(' Updated the WBS header table with min max txn dates.');
869:
870: Pji_Fm_Plan_Maint_Pvt.EXTRACT_DANGL_REVERSAL;
871: print_time(' Inserted Reversal records for dangling plans.');
872:
873: Pji_Fm_Plan_Maint_Pvt.MARK_EXTRACTED_PLANS('SEC');
874: print_time('Marked dangling versions.. ');
869:
870: Pji_Fm_Plan_Maint_Pvt.EXTRACT_DANGL_REVERSAL;
871: print_time(' Inserted Reversal records for dangling plans.');
872:
873: Pji_Fm_Plan_Maint_Pvt.MARK_EXTRACTED_PLANS('SEC');
874: print_time('Marked dangling versions.. ');
875: -- Back from unlock headers because at the time of dangling its not marking
876: -- due to purge before unlock headers bug 5155692
877:
901: -- Re-extract pri/sec rbs data with amounts converted to Global1 and
902: -- Global2 currencies also.
903: -------------------------------------------------------------------------
904:
905: PJI_FM_PLAN_MAINT_T_PVT.CLEANUP_INTERIM_TABLES; -- Clean up interim tables.
906: print_time(' Cleaned up interim tables. ');
907:
908: print_time(' !!!!!!!!!!!! Begin reextraction !!!!!!!! ');
909:
908: print_time(' !!!!!!!!!!!! Begin reextraction !!!!!!!! ');
909:
910:
911: IF (p_process_all = 'F') THEN
912: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_FIN_PLAN_VERSIONS(p_fp_version_ids, 'PRI');
913: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_FIN_PLAN_VERSIONS(p_fp_version_ids, 'SECRBS');
914: -- PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_FIN_PLAN_VERSIONS(p_fp_version_ids, '-3-4');
915: ELSE
916: print_time(' Incorrect parameters to CREATE_SECONDARY_T_PVT: p_process_all = ' || p_process_all );
909:
910:
911: IF (p_process_all = 'F') THEN
912: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_FIN_PLAN_VERSIONS(p_fp_version_ids, 'PRI');
913: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_FIN_PLAN_VERSIONS(p_fp_version_ids, 'SECRBS');
914: -- PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_FIN_PLAN_VERSIONS(p_fp_version_ids, '-3-4');
915: ELSE
916: print_time(' Incorrect parameters to CREATE_SECONDARY_T_PVT: p_process_all = ' || p_process_all );
917: RETURN;
910:
911: IF (p_process_all = 'F') THEN
912: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_FIN_PLAN_VERSIONS(p_fp_version_ids, 'PRI');
913: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_FIN_PLAN_VERSIONS(p_fp_version_ids, 'SECRBS');
914: -- PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_FIN_PLAN_VERSIONS(p_fp_version_ids, '-3-4');
915: ELSE
916: print_time(' Incorrect parameters to CREATE_SECONDARY_T_PVT: p_process_all = ' || p_process_all );
917: RETURN;
918: END IF;
922: print_time(' No data in ver3, returning. ');
923: RETURN;
924: END IF;
925:
926: PJI_FM_PLAN_MAINT_T_PVT.MAP_ORG_CAL_INFO('N') ;
927: print_time(' Updated calendar and org tables. ');
928:
929: PJI_FM_PLAN_MAINT_T_PVT.GET_GLOBAL_EXCHANGE_RATES;
930: print_time(' Got global exchange rates. ');
925:
926: PJI_FM_PLAN_MAINT_T_PVT.MAP_ORG_CAL_INFO('N') ;
927: print_time(' Updated calendar and org tables. ');
928:
929: PJI_FM_PLAN_MAINT_T_PVT.GET_GLOBAL_EXCHANGE_RATES;
930: print_time(' Got global exchange rates. ');
931:
932: SEC_SLICE_CREATE_T;
933: print_time('Proration done and rollups created.');
933: print_time('Proration done and rollups created.');
934:
935: PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_SMART_SLICES;
936:
937: PJI_FM_PLAN_MAINT_T_PVT.MERGE_INTO_FP_FACT;
938: print_time('Merged reversed data.');
939:
940: PJI_FM_PLAN_MAINT_T_PVT.MARK_EXTRACTED_PLANS('SEC');
941: print_time('Marked ');
936:
937: PJI_FM_PLAN_MAINT_T_PVT.MERGE_INTO_FP_FACT;
938: print_time('Merged reversed data.');
939:
940: PJI_FM_PLAN_MAINT_T_PVT.MARK_EXTRACTED_PLANS('SEC');
941: print_time('Marked ');
942:
943: PJI_FM_PLAN_MAINT_T_PVT.DELETE_GLOBAL_EXCHANGE_RATES;
944: print_time(' Deleted global exchange rates. ');
939:
940: PJI_FM_PLAN_MAINT_T_PVT.MARK_EXTRACTED_PLANS('SEC');
941: print_time('Marked ');
942:
943: PJI_FM_PLAN_MAINT_T_PVT.DELETE_GLOBAL_EXCHANGE_RATES;
944: print_time(' Deleted global exchange rates. ');
945:
946: PJI_FM_PLAN_MAINT_T_PVT.CLEANUP_INTERIM_TABLES; -- Clean up interim tables.
947:
942:
943: PJI_FM_PLAN_MAINT_T_PVT.DELETE_GLOBAL_EXCHANGE_RATES;
944: print_time(' Deleted global exchange rates. ');
945:
946: PJI_FM_PLAN_MAINT_T_PVT.CLEANUP_INTERIM_TABLES; -- Clean up interim tables.
947:
948: IF (p_commit = 'T') THEN
949: COMMIT;
950: END IF;
970: BEGIN
971:
972: print_time('UPDATE_PRIMARY_PVT: begin.. ');
973:
974: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_FIN_PLAN_VERSIONS(
975: p_fp_version_ids => p_plan_version_ids
976: , p_slice_type => 'PRI');
977:
978: print_time ( ' 1.1 ');
983:
984: WBSCHANGEPROC_PRERLP_SETUPS;
985: print_time(' Setups before calling WBS rollup code. ');
986:
987: PJI_FM_PLAN_MAINT_T_PVT.MAP_ORG_CAL_INFO('N');
988: print_time(' 1.a3 Updated org/cal tables. ');
989:
990: PJI_FM_PLAN_MAINT_T_PVT.RETRIEVE_DELTA_SLICE; print_time ( ' 2 ');
991: print_time(' 1.a4 Extracted data in plan lines. ');
986:
987: PJI_FM_PLAN_MAINT_T_PVT.MAP_ORG_CAL_INFO('N');
988: print_time(' 1.a3 Updated org/cal tables. ');
989:
990: PJI_FM_PLAN_MAINT_T_PVT.RETRIEVE_DELTA_SLICE; print_time ( ' 2 ');
991: print_time(' 1.a4 Extracted data in plan lines. ');
992:
993:
994: -- With data in ver3 table and pjp1 tables,
1000: PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_SMART_SLICES;
1001: WBSCHANGEPROC_POSTRLP_CLEANUP;
1002: print_time(' Cleanup after calling WBS rollup code. ');
1003:
1004: PJI_FM_PLAN_MAINT_T_PVT.MERGE_INTO_FP_FACT;
1005: print_time(' Merged into FP fact. ');
1006:
1007: PJI_FM_PLAN_MAINT_T_PVT.MARK_EXTRACTED_PLANS('PRI');
1008: print_time(' Marked extracted plans ');
1003:
1004: PJI_FM_PLAN_MAINT_T_PVT.MERGE_INTO_FP_FACT;
1005: print_time(' Merged into FP fact. ');
1006:
1007: PJI_FM_PLAN_MAINT_T_PVT.MARK_EXTRACTED_PLANS('PRI');
1008: print_time(' Marked extracted plans ');
1009:
1010: PJI_FM_PLAN_MAINT_T_PVT.CLEANUP_INTERIM_TABLES;
1011: print_time(' Cleaned up interim tables.');
1006:
1007: PJI_FM_PLAN_MAINT_T_PVT.MARK_EXTRACTED_PLANS('PRI');
1008: print_time(' Marked extracted plans ');
1009:
1010: PJI_FM_PLAN_MAINT_T_PVT.CLEANUP_INTERIM_TABLES;
1011: print_time(' Cleaned up interim tables.');
1012:
1013: print_time('UPDATE_PRIMARY_PVT: end. successful.. ');
1014:
1045: ( p_package_name => g_package_name
1046: , x_return_status => x_return_status );
1047:
1048:
1049: PJI_FM_PLAN_MAINT_T_PVT.CLEANUP_INTERIM_TABLES; -- Clean up interim tables.
1050:
1051: PJI_FM_PLAN_MAINT_T_PVT.POPULATE_PLN_VER_TABLE; print_time ( ' 1 ');
1052:
1053: -- WBSCHANGEPROC_PRERLP_SETUPS;
1047:
1048:
1049: PJI_FM_PLAN_MAINT_T_PVT.CLEANUP_INTERIM_TABLES; -- Clean up interim tables.
1050:
1051: PJI_FM_PLAN_MAINT_T_PVT.POPULATE_PLN_VER_TABLE; print_time ( ' 1 ');
1052:
1053: -- WBSCHANGEPROC_PRERLP_SETUPS;
1054: -- print_time(' Setups before calling WBS rollup code. ');
1055:
1052:
1053: -- WBSCHANGEPROC_PRERLP_SETUPS;
1054: -- print_time(' Setups before calling WBS rollup code. ');
1055:
1056: PJI_FM_PLAN_MAINT_T_PVT.REVERSE_ETC(
1057: p_new_pub_version_id => p_plan_version_id
1058: , p_prev_pub_version_id => p_prev_pub_version_id ) ; print_time ( ' 0.2 ');
1059:
1060: PRI_SLICE_CREATE_T; print_time ( ' 3 ');
1061: PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_SMART_SLICES;
1062: -- WBSCHANGEPROC_POSTRLP_CLEANUP;
1063: -- print_time(' Cleanup after calling WBS rollup code. ');
1064:
1065: PJI_FM_PLAN_MAINT_T_PVT.MERGE_INTO_FP_FACT; print_time(' 4 .. ');
1066:
1067: print_time('UPDATE_PRIMARY_PVT_ACT_ETC: end. successful.. ');
1068:
1069: EXCEPTION
1176:
1177: --------------------------------
1178: -- Header table population.
1179: --------------------------------
1180: PJI_FM_PLAN_MAINT_T_PVT.POPULATE_RBS_HDR;
1181: print_time('Populated new records into RBS Header Table.');
1182:
1183: PJI_FM_PLAN_MAINT_T_PVT.POPULATE_WBS_HDR;
1184: print_time('Populated new records into WBS Header Table.');
1179: --------------------------------
1180: PJI_FM_PLAN_MAINT_T_PVT.POPULATE_RBS_HDR;
1181: print_time('Populated new records into RBS Header Table.');
1182:
1183: PJI_FM_PLAN_MAINT_T_PVT.POPULATE_WBS_HDR;
1184: print_time('Populated new records into WBS Header Table.');
1185:
1186: --------------------------------
1187: -- Time rollups.
1204: --------------------------------
1205: -- RBS/WBS/Program rollups.
1206: --------------------------------
1207:
1208: PJI_FM_PLAN_MAINT_T_PVT.ROLLUP_FPR_RBS_T_SLICE;
1209: print_time('RBS rollup done.');
1210:
1211: PJI_FM_PLAN_MAINT_T_PVT.CREATE_WBSRLP;
1212: print_time('WBS rollup done.');
1207:
1208: PJI_FM_PLAN_MAINT_T_PVT.ROLLUP_FPR_RBS_T_SLICE;
1209: print_time('RBS rollup done.');
1210:
1211: PJI_FM_PLAN_MAINT_T_PVT.CREATE_WBSRLP;
1212: print_time('WBS rollup done.');
1213:
1214: PJI_FM_PLAN_MAINT_T_PVT.UPDATE_WBS_HDR;
1215: print_time('Updated the WBS header table with min max txn dates.');
1210:
1211: PJI_FM_PLAN_MAINT_T_PVT.CREATE_WBSRLP;
1212: print_time('WBS rollup done.');
1213:
1214: PJI_FM_PLAN_MAINT_T_PVT.UPDATE_WBS_HDR;
1215: print_time('Updated the WBS header table with min max txn dates.');
1216:
1217: EXCEPTION
1218: WHEN OTHERS THEN
1233: --------------------------------
1234: -- Header table population.
1235: --------------------------------
1236:
1237: PJI_FM_PLAN_MAINT_T_PVT.POPULATE_RBS_HDR;
1238: print_time('Populated new records into RBS Header Table.');
1239:
1240: PJI_FM_PLAN_MAINT_T_PVT.POPULATE_WBS_HDR;
1241: print_time('Populated new records into WBS Header Table.');
1236:
1237: PJI_FM_PLAN_MAINT_T_PVT.POPULATE_RBS_HDR;
1238: print_time('Populated new records into RBS Header Table.');
1239:
1240: PJI_FM_PLAN_MAINT_T_PVT.POPULATE_WBS_HDR;
1241: print_time('Populated new records into WBS Header Table.');
1242:
1243: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_PLAN_AMTS_PRIRBS_GLC12;
1244: print_time(' Extracted plan data for primary RBSes.');
1239:
1240: PJI_FM_PLAN_MAINT_T_PVT.POPULATE_WBS_HDR;
1241: print_time('Populated new records into WBS Header Table.');
1242:
1243: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_PLAN_AMTS_PRIRBS_GLC12;
1244: print_time(' Extracted plan data for primary RBSes.');
1245:
1246: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_PLAN_AMTS_SECRBS_GLC12;
1247: print_time(' Extracted plan data for secondary RBSes.');
1242:
1243: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_PLAN_AMTS_PRIRBS_GLC12;
1244: print_time(' Extracted plan data for primary RBSes.');
1245:
1246: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_PLAN_AMTS_SECRBS_GLC12;
1247: print_time(' Extracted plan data for secondary RBSes.');
1248:
1249: --
1250: -- Prorate
1251: -- 1. GL cal and Non time phased entries into PA cal.
1252: -- 2. PA cal and Non time phased entries into GL cal.
1253: -- 3. PA, GL cals and Non time phased entries into Ent cal.
1254: --
1255: PJI_FM_PLAN_MAINT_T_PVT.PRORATE_TO_ALL_CALENDARS;
1256: print_time(' Prorated to all calendars. ');
1257:
1258:
1259: --------------------------------
1270: --------------------------------
1271: -- RBS/WBS/Program rollups.
1272: --------------------------------
1273:
1274: PJI_FM_PLAN_MAINT_T_PVT.ROLLUP_FPR_RBS_T_SLICE;
1275: print_time(' RBS rollups done. ');
1276:
1277: PJI_FM_PLAN_MAINT_T_PVT.CREATE_WBSRLP;
1278: print_time(' WBS rollups done. ');
1273:
1274: PJI_FM_PLAN_MAINT_T_PVT.ROLLUP_FPR_RBS_T_SLICE;
1275: print_time(' RBS rollups done. ');
1276:
1277: PJI_FM_PLAN_MAINT_T_PVT.CREATE_WBSRLP;
1278: print_time(' WBS rollups done. ');
1279:
1280: PJI_FM_PLAN_MAINT_T_PVT.UPDATE_WBS_HDR;
1281: print_time('Updated the WBS header table with min max txn dates.');
1276:
1277: PJI_FM_PLAN_MAINT_T_PVT.CREATE_WBSRLP;
1278: print_time(' WBS rollups done. ');
1279:
1280: PJI_FM_PLAN_MAINT_T_PVT.UPDATE_WBS_HDR;
1281: print_time('Updated the WBS header table with min max txn dates.');
1282:
1283: EXCEPTION
1284: WHEN OTHERS THEN
1582:
1583: print_time(' PULL_PLANS_FOR_PR value of p_plan_type_id is ' || p_plan_type_id || ' and p_rbs_version_id is ' || p_rbs_version_id );
1584:
1585:
1586: PJI_FM_PLAN_MAINT_PVT.VALIDATE_SET_PR_PARAMS(
1587: p_rbs_version_id => p_rbs_version_id
1588: , p_plan_type_id => p_plan_type_id
1589: , p_context => p_context
1590: , x_num_rows => l_num_rows
1599: RETURN;
1600: END IF;
1601:
1602:
1603: Pji_Fm_Plan_Maint_Pvt.POPULATE_RBS_HDR;
1604: print_time('Populated new records into RBS Header Table.');
1605:
1606: -- Retrieve overridden ETC values for latest published WP structures in budget lines table.
1607: -- PJI_FM_PLAN_MAINT_PVT.RETRIEVE_OVERRIDDEN_WP_ETC;
1603: Pji_Fm_Plan_Maint_Pvt.POPULATE_RBS_HDR;
1604: print_time('Populated new records into RBS Header Table.');
1605:
1606: -- Retrieve overridden ETC values for latest published WP structures in budget lines table.
1607: -- PJI_FM_PLAN_MAINT_PVT.RETRIEVE_OVERRIDDEN_WP_ETC;
1608: print_time('Retrieved overridden ETC values.');
1609:
1610: -- Pull primary slice for workplans and relevant fin plans.
1611: -- Do not pull actuals/overriddend ETC values, they are extracted in "get plan res actuals" flow.
1608: print_time('Retrieved overridden ETC values.');
1609:
1610: -- Pull primary slice for workplans and relevant fin plans.
1611: -- Do not pull actuals/overriddend ETC values, they are extracted in "get plan res actuals" flow.
1612: PJI_FM_PLAN_MAINT_PVT.EXTRACT_PLAN_ETC_PRIRBS ;
1613: print_time('Extracted workplan data.');
1614:
1615: -- Plan lines for ETCs are populated in get plan res actuals flow.
1616: -- PJI_FM_PLAN_MAINT_PVT.DELETE_PLAN_LINES ( x_return_status => x_return_status );
1612: PJI_FM_PLAN_MAINT_PVT.EXTRACT_PLAN_ETC_PRIRBS ;
1613: print_time('Extracted workplan data.');
1614:
1615: -- Plan lines for ETCs are populated in get plan res actuals flow.
1616: -- PJI_FM_PLAN_MAINT_PVT.DELETE_PLAN_LINES ( x_return_status => x_return_status );
1617: -- print_time('Delete processed plan lines.');
1618:
1619: PJI_FM_PLAN_MAINT_PVT.GET_GLOBAL_EXCHANGE_RATES;
1620: print_time(' Got global exchange rates. ');
1615: -- Plan lines for ETCs are populated in get plan res actuals flow.
1616: -- PJI_FM_PLAN_MAINT_PVT.DELETE_PLAN_LINES ( x_return_status => x_return_status );
1617: -- print_time('Delete processed plan lines.');
1618:
1619: PJI_FM_PLAN_MAINT_PVT.GET_GLOBAL_EXCHANGE_RATES;
1620: print_time(' Got global exchange rates. ');
1621:
1622: PJI_FM_PLAN_MAINT_PVT.EXTRACT_PLAN_AMTS_PRIRBS_GLC12
1623: (p_pull_dangling_flag => 'N');
1618:
1619: PJI_FM_PLAN_MAINT_PVT.GET_GLOBAL_EXCHANGE_RATES;
1620: print_time(' Got global exchange rates. ');
1621:
1622: PJI_FM_PLAN_MAINT_PVT.EXTRACT_PLAN_AMTS_PRIRBS_GLC12
1623: (p_pull_dangling_flag => 'N');
1624: print_time('Extracted finplan data for pri RBS for secondary currencies as well.');
1625:
1626: PJI_FM_PLAN_MAINT_PVT.EXTRACT_PLAN_AMTS_SECRBS_GLC12
1622: PJI_FM_PLAN_MAINT_PVT.EXTRACT_PLAN_AMTS_PRIRBS_GLC12
1623: (p_pull_dangling_flag => 'N');
1624: print_time('Extracted finplan data for pri RBS for secondary currencies as well.');
1625:
1626: PJI_FM_PLAN_MAINT_PVT.EXTRACT_PLAN_AMTS_SECRBS_GLC12
1627: (p_pull_dangling_flag => 'N');
1628: print_time('Extracted finplan data for Secondary RBS for secondary currencies as well.');
1629:
1630: PJI_FM_PLAN_MAINT_PVT.PRORATE_TO_ALL_CALENDARS ;
1626: PJI_FM_PLAN_MAINT_PVT.EXTRACT_PLAN_AMTS_SECRBS_GLC12
1627: (p_pull_dangling_flag => 'N');
1628: print_time('Extracted finplan data for Secondary RBS for secondary currencies as well.');
1629:
1630: PJI_FM_PLAN_MAINT_PVT.PRORATE_TO_ALL_CALENDARS ;
1631: print_time('Prorated Fin plan data to all calendars.');
1632:
1633:
1634: --
1684: Pji_Fm_Xbs_Accum_Maint.debug_plan_lines;
1685:
1686:
1687: -- Populate ver3 table.
1688: PJI_FM_PLAN_MAINT_PVT.VALIDATE_SET_PR_PARAMS(
1689: p_rbs_version_id => NULL
1690: , p_plan_type_id => NULL
1691: , p_context => p_extr_type
1692: , x_num_rows => l_num_rows
1702: RETURN;
1703: END IF;
1704:
1705:
1706: Pji_Fm_Plan_Maint_Pvt.POPULATE_RBS_HDR;
1707: print_time('Populated new records into RBS Header Table.');
1708:
1709:
1710: -- Extract actuals from budget lines for FULL summarization.
1707: print_time('Populated new records into RBS Header Table.');
1708:
1709:
1710: -- Extract actuals from budget lines for FULL summarization.
1711: pji_fm_plan_maint_pvt.EXTRACT_ACTUALS(
1712: p_extrn_type => p_extr_type
1713: );
1714: print_time('Actuals/etc extraction.');
1715:
1716: --
1717: -- WBS and RBS headers will be populated in PROCESS_PENDING_PLAN_UPDATES
1718: --
1719:
1720: --PJI_FM_PLAN_MAINT_PVT.DELETE_PLAN_LINES ( x_return_status => x_return_status );
1721: --print_time('Delete processed plan lines for this worker id.');
1722:
1723: --
1724: -- All rollups are done for plans along with actuals from the calling
1875: p_worker_id => 1
1876: , p_extraction_type => 'ONLINE');
1877: print_time(' Cleaned up xbs delta denorm. ');
1878:
1879: Pji_Fm_Plan_Maint_T_Pvt.MERGE_INTO_AC_FACT;
1880: print_time(' Merged into AC fact. ');
1881:
1882:
1883: /*
2085: RAISE;
2086: END;
2087:
2088:
2089: END PJI_FM_PLAN_MAINT;