[Home] [Help]
1: PACKAGE BODY PJI_FM_PLAN_MAINT AS
2: /* $Header: PJIPP01B.pls 120.44.12020000.7 2013/04/26 06:55:27 sachandr 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.44.12020000.7 2013/04/26 06:55:27 sachandr 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;
836: print_time('CREATE_SECONDARY_PVT: begin.. ');
837:
838: l_pji_schema := pji_utils.get_pji_schema_name; /* Added for bug 13897252 */
839:
840: Pji_Fm_Plan_Maint_Pvt.EXTRACT_FIN_PLAN_VERS_BULK(p_slice_type => 'SEC_PROJ');
841: Pji_Fm_Plan_Maint_Pvt.EXTRACT_FIN_PLAN_VERS_BULK(p_slice_type => 'SECRBS_PROJ');
842: print_time(' Identified plan versions to be extracted. ');
843:
844: /* Added for bug 13897252 starts */
837:
838: l_pji_schema := pji_utils.get_pji_schema_name; /* Added for bug 13897252 */
839:
840: Pji_Fm_Plan_Maint_Pvt.EXTRACT_FIN_PLAN_VERS_BULK(p_slice_type => 'SEC_PROJ');
841: Pji_Fm_Plan_Maint_Pvt.EXTRACT_FIN_PLAN_VERS_BULK(p_slice_type => 'SECRBS_PROJ');
842: print_time(' Identified plan versions to be extracted. ');
843:
844: /* Added for bug 13897252 starts */
845: IF PJI_UTILS.GET_PARAMETER('PJP_SIN_PRG') = 'Y' then
854: print_time(' No data in ver3, returning. ');
855: RETURN;
856: END IF;
857:
858: Pji_Fm_Plan_Maint_Pvt.GET_GLOBAL_EXCHANGE_RATES;
859: print_time(' Got global exchange rates. ');
860:
861: Pji_Fm_Plan_Maint_Pvt.POPULATE_RBS_HDR;
862: print_time('Populated RBS header table.');
857:
858: Pji_Fm_Plan_Maint_Pvt.GET_GLOBAL_EXCHANGE_RATES;
859: print_time(' Got global exchange rates. ');
860:
861: Pji_Fm_Plan_Maint_Pvt.POPULATE_RBS_HDR;
862: print_time('Populated RBS header table.');
863:
864: Pji_Fm_Plan_Maint_Pvt.POPULATE_WBS_HDR;
865: print_time('Populated WBS header table.');
860:
861: Pji_Fm_Plan_Maint_Pvt.POPULATE_RBS_HDR;
862: print_time('Populated RBS header table.');
863:
864: Pji_Fm_Plan_Maint_Pvt.POPULATE_WBS_HDR;
865: print_time('Populated WBS header table.');
866:
867: -- Bug 15881881
868: -- Commented for bug 16360282
869: /*fnd_stats.gather_table_stats('PA','PA_RESOURCE_ASSIGNMENTS',PERCENT=>40);
870: fnd_stats.gather_table_stats('PA','PA_BUDGET_LINES',PERCENT=>40); */
871: -- End Bug 15881881
872:
873: Pji_Fm_Plan_Maint_Pvt.EXTRACT_PLAN_AMTS_PRIRBS_GLC12;
874: print_time(' Extracted plan data for primary RBSes.');
875:
876: Pji_Fm_Plan_Maint_Pvt.EXTRACT_PLAN_AMTS_SECRBS_GLC12;
877: print_time(' Extracted plan data for primary RBSes.');
872:
873: Pji_Fm_Plan_Maint_Pvt.EXTRACT_PLAN_AMTS_PRIRBS_GLC12;
874: print_time(' Extracted plan data for primary RBSes.');
875:
876: Pji_Fm_Plan_Maint_Pvt.EXTRACT_PLAN_AMTS_SECRBS_GLC12;
877: print_time(' Extracted plan data for primary RBSes.');
878:
879: Pji_Fm_Plan_Maint_Pvt.DELETE_GLOBAL_EXCHANGE_RATES;
880: print_time(' Deleted global exchange rates. ');
875:
876: Pji_Fm_Plan_Maint_Pvt.EXTRACT_PLAN_AMTS_SECRBS_GLC12;
877: print_time(' Extracted plan data for primary RBSes.');
878:
879: Pji_Fm_Plan_Maint_Pvt.DELETE_GLOBAL_EXCHANGE_RATES;
880: print_time(' Deleted global exchange rates. ');
881:
882: /* Added for bug 8708651 */
883: l_time_phase_flag := PJI_UTILS.GET_SETUP_PARAMETER('TIME_PHASE_FLAG');
887: -- End Bug 15881881
888: if l_time_phase_flag = 'Y' then
889: null;
890: else
891: PJI_FM_PLAN_MAINT_PVT.PRORATE_TO_ALL_CALENDARS; /* Modified to PJI_FM_PLAN_MAINT_PVT
892: for bug 12996111 */
893: end if;
894: /* Added for bug 8708651 */
895: print_time(' Prorated to all calendars. ');
893: end if;
894: /* Added for bug 8708651 */
895: print_time(' Prorated to all calendars. ');
896:
897: -- PJI_FM_PLAN_MAINT_PVT.UPDATE_WBS_HDR; /* Commented for bug 13897252 */
898: -- print_time(' Updated the WBS header table with min max txn dates.');
899:
900: -- Bug 15881881
901: fnd_stats.gather_table_stats('PJI','PJI_FP_AGGR_PJP1',PERCENT=>40);
902: -- Commented for bug 16360282
903: -- fnd_stats.gather_table_stats('PJI','PJI_FP_XBS_ACCUM_F',PERCENT=>40);
904: -- End Bug 15881881
905:
906: Pji_Fm_Plan_Maint_Pvt.EXTRACT_DANGL_REVERSAL;
907: print_time(' Inserted Reversal records for dangling plans.');
908:
909: Pji_Fm_Plan_Maint_Pvt.MARK_EXTRACTED_PLANS('SEC');
910: print_time('Marked dangling versions.. ');
905:
906: Pji_Fm_Plan_Maint_Pvt.EXTRACT_DANGL_REVERSAL;
907: print_time(' Inserted Reversal records for dangling plans.');
908:
909: Pji_Fm_Plan_Maint_Pvt.MARK_EXTRACTED_PLANS('SEC');
910: print_time('Marked dangling versions.. ');
911: -- Back from unlock headers because at the time of dangling its not marking
912: -- due to purge before unlock headers bug 5155692
913:
937: -- Re-extract pri/sec rbs data with amounts converted to Global1 and
938: -- Global2 currencies also.
939: -------------------------------------------------------------------------
940:
941: PJI_FM_PLAN_MAINT_T_PVT.CLEANUP_INTERIM_TABLES; -- Clean up interim tables.
942: print_time(' Cleaned up interim tables. ');
943:
944: print_time(' !!!!!!!!!!!! Begin reextraction !!!!!!!! ');
945:
944: print_time(' !!!!!!!!!!!! Begin reextraction !!!!!!!! ');
945:
946:
947: IF (p_process_all = 'F') THEN
948: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_FIN_PLAN_VERSIONS(p_fp_version_ids, 'PRI');
949: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_FIN_PLAN_VERSIONS(p_fp_version_ids, 'SECRBS');
950: -- PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_FIN_PLAN_VERSIONS(p_fp_version_ids, '-3-4');
951: ELSE
952: print_time(' Incorrect parameters to CREATE_SECONDARY_T_PVT: p_process_all = ' || p_process_all );
945:
946:
947: IF (p_process_all = 'F') THEN
948: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_FIN_PLAN_VERSIONS(p_fp_version_ids, 'PRI');
949: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_FIN_PLAN_VERSIONS(p_fp_version_ids, 'SECRBS');
950: -- PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_FIN_PLAN_VERSIONS(p_fp_version_ids, '-3-4');
951: ELSE
952: print_time(' Incorrect parameters to CREATE_SECONDARY_T_PVT: p_process_all = ' || p_process_all );
953: RETURN;
946:
947: IF (p_process_all = 'F') THEN
948: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_FIN_PLAN_VERSIONS(p_fp_version_ids, 'PRI');
949: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_FIN_PLAN_VERSIONS(p_fp_version_ids, 'SECRBS');
950: -- PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_FIN_PLAN_VERSIONS(p_fp_version_ids, '-3-4');
951: ELSE
952: print_time(' Incorrect parameters to CREATE_SECONDARY_T_PVT: p_process_all = ' || p_process_all );
953: RETURN;
954: END IF;
958: print_time(' No data in ver3, returning. ');
959: RETURN;
960: END IF;
961:
962: PJI_FM_PLAN_MAINT_T_PVT.MAP_ORG_CAL_INFO('N') ;
963: print_time(' Updated calendar and org tables. ');
964:
965: PJI_FM_PLAN_MAINT_T_PVT.GET_GLOBAL_EXCHANGE_RATES;
966: print_time(' Got global exchange rates. ');
961:
962: PJI_FM_PLAN_MAINT_T_PVT.MAP_ORG_CAL_INFO('N') ;
963: print_time(' Updated calendar and org tables. ');
964:
965: PJI_FM_PLAN_MAINT_T_PVT.GET_GLOBAL_EXCHANGE_RATES;
966: print_time(' Got global exchange rates. ');
967:
968: SEC_SLICE_CREATE_T;
969: print_time('Proration done and rollups created.');
969: print_time('Proration done and rollups created.');
970:
971: PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_SMART_SLICES;
972:
973: PJI_FM_PLAN_MAINT_T_PVT.MERGE_INTO_FP_FACT;
974: print_time('Merged reversed data.');
975:
976: PJI_FM_PLAN_MAINT_T_PVT.MARK_EXTRACTED_PLANS('SEC');
977: print_time('Marked ');
972:
973: PJI_FM_PLAN_MAINT_T_PVT.MERGE_INTO_FP_FACT;
974: print_time('Merged reversed data.');
975:
976: PJI_FM_PLAN_MAINT_T_PVT.MARK_EXTRACTED_PLANS('SEC');
977: print_time('Marked ');
978:
979: PJI_FM_PLAN_MAINT_T_PVT.DELETE_GLOBAL_EXCHANGE_RATES;
980: print_time(' Deleted global exchange rates. ');
975:
976: PJI_FM_PLAN_MAINT_T_PVT.MARK_EXTRACTED_PLANS('SEC');
977: print_time('Marked ');
978:
979: PJI_FM_PLAN_MAINT_T_PVT.DELETE_GLOBAL_EXCHANGE_RATES;
980: print_time(' Deleted global exchange rates. ');
981:
982: PJI_FM_PLAN_MAINT_T_PVT.CLEANUP_INTERIM_TABLES; -- Clean up interim tables.
983:
978:
979: PJI_FM_PLAN_MAINT_T_PVT.DELETE_GLOBAL_EXCHANGE_RATES;
980: print_time(' Deleted global exchange rates. ');
981:
982: PJI_FM_PLAN_MAINT_T_PVT.CLEANUP_INTERIM_TABLES; -- Clean up interim tables.
983:
984: IF (p_commit = 'T') THEN
985: COMMIT;
986: END IF;
1006: BEGIN
1007:
1008: print_time('UPDATE_PRIMARY_PVT: begin.. ');
1009:
1010: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_FIN_PLAN_VERSIONS(
1011: p_fp_version_ids => p_plan_version_ids
1012: , p_slice_type => 'PRI');
1013:
1014: print_time ( ' 1.1 ');
1019:
1020: WBSCHANGEPROC_PRERLP_SETUPS;
1021: print_time(' Setups before calling WBS rollup code. ');
1022:
1023: PJI_FM_PLAN_MAINT_T_PVT.MAP_ORG_CAL_INFO('N');
1024: print_time(' 1.a3 Updated org/cal tables. ');
1025:
1026: PJI_FM_PLAN_MAINT_T_PVT.RETRIEVE_DELTA_SLICE; print_time ( ' 2 ');
1027: print_time(' 1.a4 Extracted data in plan lines. ');
1022:
1023: PJI_FM_PLAN_MAINT_T_PVT.MAP_ORG_CAL_INFO('N');
1024: print_time(' 1.a3 Updated org/cal tables. ');
1025:
1026: PJI_FM_PLAN_MAINT_T_PVT.RETRIEVE_DELTA_SLICE; print_time ( ' 2 ');
1027: print_time(' 1.a4 Extracted data in plan lines. ');
1028:
1029:
1030: -- With data in ver3 table and pjp1 tables,
1036: PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_SMART_SLICES;
1037: WBSCHANGEPROC_POSTRLP_CLEANUP;
1038: print_time(' Cleanup after calling WBS rollup code. ');
1039:
1040: PJI_FM_PLAN_MAINT_T_PVT.MERGE_INTO_FP_FACT;
1041: print_time(' Merged into FP fact. ');
1042:
1043: PJI_FM_PLAN_MAINT_T_PVT.MARK_EXTRACTED_PLANS('PRI');
1044: print_time(' Marked extracted plans ');
1039:
1040: PJI_FM_PLAN_MAINT_T_PVT.MERGE_INTO_FP_FACT;
1041: print_time(' Merged into FP fact. ');
1042:
1043: PJI_FM_PLAN_MAINT_T_PVT.MARK_EXTRACTED_PLANS('PRI');
1044: print_time(' Marked extracted plans ');
1045:
1046: PJI_FM_PLAN_MAINT_T_PVT.CLEANUP_INTERIM_TABLES;
1047: print_time(' Cleaned up interim tables.');
1042:
1043: PJI_FM_PLAN_MAINT_T_PVT.MARK_EXTRACTED_PLANS('PRI');
1044: print_time(' Marked extracted plans ');
1045:
1046: PJI_FM_PLAN_MAINT_T_PVT.CLEANUP_INTERIM_TABLES;
1047: print_time(' Cleaned up interim tables.');
1048:
1049: print_time('UPDATE_PRIMARY_PVT: end. successful.. ');
1050:
1081: ( p_package_name => g_package_name
1082: , x_return_status => x_return_status );
1083:
1084:
1085: PJI_FM_PLAN_MAINT_T_PVT.CLEANUP_INTERIM_TABLES; -- Clean up interim tables.
1086:
1087: PJI_FM_PLAN_MAINT_T_PVT.POPULATE_PLN_VER_TABLE; print_time ( ' 1 ');
1088:
1089: -- WBSCHANGEPROC_PRERLP_SETUPS;
1083:
1084:
1085: PJI_FM_PLAN_MAINT_T_PVT.CLEANUP_INTERIM_TABLES; -- Clean up interim tables.
1086:
1087: PJI_FM_PLAN_MAINT_T_PVT.POPULATE_PLN_VER_TABLE; print_time ( ' 1 ');
1088:
1089: -- WBSCHANGEPROC_PRERLP_SETUPS;
1090: -- print_time(' Setups before calling WBS rollup code. ');
1091:
1088:
1089: -- WBSCHANGEPROC_PRERLP_SETUPS;
1090: -- print_time(' Setups before calling WBS rollup code. ');
1091:
1092: PJI_FM_PLAN_MAINT_T_PVT.REVERSE_ETC(
1093: p_new_pub_version_id => p_plan_version_id
1094: , p_prev_pub_version_id => p_prev_pub_version_id ) ; print_time ( ' 0.2 ');
1095:
1096: PRI_SLICE_CREATE_T; print_time ( ' 3 ');
1097: PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_SMART_SLICES;
1098: -- WBSCHANGEPROC_POSTRLP_CLEANUP;
1099: -- print_time(' Cleanup after calling WBS rollup code. ');
1100:
1101: PJI_FM_PLAN_MAINT_T_PVT.MERGE_INTO_FP_FACT; print_time(' 4 .. ');
1102:
1103: print_time('UPDATE_PRIMARY_PVT_ACT_ETC: end. successful.. ');
1104:
1105: EXCEPTION
1219:
1220: --------------------------------
1221: -- Header table population.
1222: --------------------------------
1223: PJI_FM_PLAN_MAINT_T_PVT.POPULATE_RBS_HDR;
1224: print_time('Populated new records into RBS Header Table.');
1225:
1226: PJI_FM_PLAN_MAINT_T_PVT.POPULATE_WBS_HDR;
1227: print_time('Populated new records into WBS Header Table.');
1222: --------------------------------
1223: PJI_FM_PLAN_MAINT_T_PVT.POPULATE_RBS_HDR;
1224: print_time('Populated new records into RBS Header Table.');
1225:
1226: PJI_FM_PLAN_MAINT_T_PVT.POPULATE_WBS_HDR;
1227: print_time('Populated new records into WBS Header Table.');
1228:
1229: --------------------------------
1230: -- Time rollups.
1247: --------------------------------
1248: -- RBS/WBS/Program rollups.
1249: --------------------------------
1250:
1251: PJI_FM_PLAN_MAINT_T_PVT.ROLLUP_FPR_RBS_T_SLICE;
1252: print_time('RBS rollup done.');
1253:
1254: PJI_FM_PLAN_MAINT_T_PVT.CREATE_WBSRLP;
1255: print_time('WBS rollup done.');
1250:
1251: PJI_FM_PLAN_MAINT_T_PVT.ROLLUP_FPR_RBS_T_SLICE;
1252: print_time('RBS rollup done.');
1253:
1254: PJI_FM_PLAN_MAINT_T_PVT.CREATE_WBSRLP;
1255: print_time('WBS rollup done.');
1256:
1257: PJI_FM_PLAN_MAINT_T_PVT.UPDATE_WBS_HDR;
1258: print_time('Updated the WBS header table with min max txn dates.');
1253:
1254: PJI_FM_PLAN_MAINT_T_PVT.CREATE_WBSRLP;
1255: print_time('WBS rollup done.');
1256:
1257: PJI_FM_PLAN_MAINT_T_PVT.UPDATE_WBS_HDR;
1258: print_time('Updated the WBS header table with min max txn dates.');
1259:
1260: EXCEPTION
1261: WHEN OTHERS THEN
1279: --------------------------------
1280: -- Header table population.
1281: --------------------------------
1282:
1283: PJI_FM_PLAN_MAINT_T_PVT.POPULATE_RBS_HDR;
1284: print_time('Populated new records into RBS Header Table.');
1285:
1286: PJI_FM_PLAN_MAINT_T_PVT.POPULATE_WBS_HDR;
1287: print_time('Populated new records into WBS Header Table.');
1282:
1283: PJI_FM_PLAN_MAINT_T_PVT.POPULATE_RBS_HDR;
1284: print_time('Populated new records into RBS Header Table.');
1285:
1286: PJI_FM_PLAN_MAINT_T_PVT.POPULATE_WBS_HDR;
1287: print_time('Populated new records into WBS Header Table.');
1288:
1289: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_PLAN_AMTS_PRIRBS_GLC12;
1290: print_time(' Extracted plan data for primary RBSes.');
1285:
1286: PJI_FM_PLAN_MAINT_T_PVT.POPULATE_WBS_HDR;
1287: print_time('Populated new records into WBS Header Table.');
1288:
1289: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_PLAN_AMTS_PRIRBS_GLC12;
1290: print_time(' Extracted plan data for primary RBSes.');
1291:
1292: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_PLAN_AMTS_SECRBS_GLC12;
1293: print_time(' Extracted plan data for secondary RBSes.');
1288:
1289: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_PLAN_AMTS_PRIRBS_GLC12;
1290: print_time(' Extracted plan data for primary RBSes.');
1291:
1292: PJI_FM_PLAN_MAINT_T_PVT.EXTRACT_PLAN_AMTS_SECRBS_GLC12;
1293: print_time(' Extracted plan data for secondary RBSes.');
1294:
1295: --
1296: -- Prorate
1303:
1304: if l_time_phase_flag = 'Y' then
1305: null;
1306: else
1307: PJI_FM_PLAN_MAINT_T_PVT.PRORATE_TO_ALL_CALENDARS;
1308: print_time(' Prorated to all calendars. ');
1309: end if;
1310: /* Added for bug 8708651 */
1311:
1323: --------------------------------
1324: -- RBS/WBS/Program rollups.
1325: --------------------------------
1326:
1327: PJI_FM_PLAN_MAINT_T_PVT.ROLLUP_FPR_RBS_T_SLICE;
1328: print_time(' RBS rollups done. ');
1329:
1330: PJI_FM_PLAN_MAINT_T_PVT.CREATE_WBSRLP;
1331: print_time(' WBS rollups done. ');
1326:
1327: PJI_FM_PLAN_MAINT_T_PVT.ROLLUP_FPR_RBS_T_SLICE;
1328: print_time(' RBS rollups done. ');
1329:
1330: PJI_FM_PLAN_MAINT_T_PVT.CREATE_WBSRLP;
1331: print_time(' WBS rollups done. ');
1332:
1333: PJI_FM_PLAN_MAINT_T_PVT.UPDATE_WBS_HDR;
1334: print_time('Updated the WBS header table with min max txn dates.');
1329:
1330: PJI_FM_PLAN_MAINT_T_PVT.CREATE_WBSRLP;
1331: print_time(' WBS rollups done. ');
1332:
1333: PJI_FM_PLAN_MAINT_T_PVT.UPDATE_WBS_HDR;
1334: print_time('Updated the WBS header table with min max txn dates.');
1335:
1336: EXCEPTION
1337: WHEN OTHERS THEN
1636:
1637: 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 );
1638:
1639:
1640: PJI_FM_PLAN_MAINT_PVT.VALIDATE_SET_PR_PARAMS(
1641: p_rbs_version_id => p_rbs_version_id
1642: , p_plan_type_id => p_plan_type_id
1643: , p_context => p_context
1644: , x_num_rows => l_num_rows
1653: RETURN;
1654: END IF;
1655:
1656:
1657: Pji_Fm_Plan_Maint_Pvt.POPULATE_RBS_HDR;
1658: print_time('Populated new records into RBS Header Table.');
1659:
1660: -- Retrieve overridden ETC values for latest published WP structures in budget lines table.
1661: -- PJI_FM_PLAN_MAINT_PVT.RETRIEVE_OVERRIDDEN_WP_ETC;
1657: Pji_Fm_Plan_Maint_Pvt.POPULATE_RBS_HDR;
1658: print_time('Populated new records into RBS Header Table.');
1659:
1660: -- Retrieve overridden ETC values for latest published WP structures in budget lines table.
1661: -- PJI_FM_PLAN_MAINT_PVT.RETRIEVE_OVERRIDDEN_WP_ETC;
1662: print_time('Retrieved overridden ETC values.');
1663:
1664: -- Pull primary slice for workplans and relevant fin plans.
1665: -- Do not pull actuals/overriddend ETC values, they are extracted in "get plan res actuals" flow.
1662: print_time('Retrieved overridden ETC values.');
1663:
1664: -- Pull primary slice for workplans and relevant fin plans.
1665: -- Do not pull actuals/overriddend ETC values, they are extracted in "get plan res actuals" flow.
1666: PJI_FM_PLAN_MAINT_PVT.EXTRACT_PLAN_ETC_PRIRBS ;
1667: print_time('Extracted workplan data.');
1668:
1669: -- Plan lines for ETCs are populated in get plan res actuals flow.
1670: -- PJI_FM_PLAN_MAINT_PVT.DELETE_PLAN_LINES ( x_return_status => x_return_status );
1666: PJI_FM_PLAN_MAINT_PVT.EXTRACT_PLAN_ETC_PRIRBS ;
1667: print_time('Extracted workplan data.');
1668:
1669: -- Plan lines for ETCs are populated in get plan res actuals flow.
1670: -- PJI_FM_PLAN_MAINT_PVT.DELETE_PLAN_LINES ( x_return_status => x_return_status );
1671: -- print_time('Delete processed plan lines.');
1672:
1673: PJI_FM_PLAN_MAINT_PVT.GET_GLOBAL_EXCHANGE_RATES;
1674: print_time(' Got global exchange rates. ');
1669: -- Plan lines for ETCs are populated in get plan res actuals flow.
1670: -- PJI_FM_PLAN_MAINT_PVT.DELETE_PLAN_LINES ( x_return_status => x_return_status );
1671: -- print_time('Delete processed plan lines.');
1672:
1673: PJI_FM_PLAN_MAINT_PVT.GET_GLOBAL_EXCHANGE_RATES;
1674: print_time(' Got global exchange rates. ');
1675:
1676: PJI_FM_PLAN_MAINT_PVT.EXTRACT_PLAN_AMTS_PRIRBS_GLC12
1677: (p_pull_dangling_flag => 'N');
1672:
1673: PJI_FM_PLAN_MAINT_PVT.GET_GLOBAL_EXCHANGE_RATES;
1674: print_time(' Got global exchange rates. ');
1675:
1676: PJI_FM_PLAN_MAINT_PVT.EXTRACT_PLAN_AMTS_PRIRBS_GLC12
1677: (p_pull_dangling_flag => 'N');
1678: print_time('Extracted finplan data for pri RBS for secondary currencies as well.');
1679:
1680: PJI_FM_PLAN_MAINT_PVT.EXTRACT_PLAN_AMTS_SECRBS_GLC12
1676: PJI_FM_PLAN_MAINT_PVT.EXTRACT_PLAN_AMTS_PRIRBS_GLC12
1677: (p_pull_dangling_flag => 'N');
1678: print_time('Extracted finplan data for pri RBS for secondary currencies as well.');
1679:
1680: PJI_FM_PLAN_MAINT_PVT.EXTRACT_PLAN_AMTS_SECRBS_GLC12
1681: (p_pull_dangling_flag => 'N');
1682: print_time('Extracted finplan data for Secondary RBS for secondary currencies as well.');
1683:
1684: /* Added for bug 8708651 */
1686:
1687: if l_time_phase_flag = 'Y' then
1688: null;
1689: else
1690: PJI_FM_PLAN_MAINT_PVT.PRORATE_TO_ALL_CALENDARS ;
1691: print_time('Prorated Fin plan data to all calendars.');
1692: end if;
1693: /* Added for bug 8708651 */
1694: --
1744: Pji_Fm_Xbs_Accum_Maint.debug_plan_lines;
1745:
1746:
1747: -- Populate ver3 table.
1748: PJI_FM_PLAN_MAINT_PVT.VALIDATE_SET_PR_PARAMS(
1749: p_rbs_version_id => NULL
1750: , p_plan_type_id => NULL
1751: , p_context => p_extr_type
1752: , x_num_rows => l_num_rows
1762: RETURN;
1763: END IF;
1764:
1765:
1766: Pji_Fm_Plan_Maint_Pvt.POPULATE_RBS_HDR;
1767: print_time('Populated new records into RBS Header Table.');
1768:
1769:
1770: -- Extract actuals from budget lines for FULL summarization.
1767: print_time('Populated new records into RBS Header Table.');
1768:
1769:
1770: -- Extract actuals from budget lines for FULL summarization.
1771: pji_fm_plan_maint_pvt.EXTRACT_ACTUALS(
1772: p_extrn_type => p_extr_type
1773: );
1774: print_time('Actuals/etc extraction.');
1775:
1776: --
1777: -- WBS and RBS headers will be populated in PROCESS_PENDING_PLAN_UPDATES
1778: --
1779:
1780: --PJI_FM_PLAN_MAINT_PVT.DELETE_PLAN_LINES ( x_return_status => x_return_status );
1781: --print_time('Delete processed plan lines for this worker id.');
1782:
1783: --
1784: -- All rollups are done for plans along with actuals from the calling
1935: p_worker_id => 1
1936: , p_extraction_type => 'ONLINE');
1937: print_time(' Cleaned up xbs delta denorm. ');
1938:
1939: Pji_Fm_Plan_Maint_T_Pvt.MERGE_INTO_AC_FACT;
1940: print_time(' Merged into AC fact. ');
1941:
1942:
1943: /*
2149: RAISE;
2150: END;
2151:
2152:
2153: END PJI_FM_PLAN_MAINT;