1494: -- SELECT DECODE(l_extraction_type, 'PARTIAL', 'PLANTYPE', l_extraction_type)
1495: -- INTO l_extraction_type
1496: -- FROM DUAL ;
1497:
1498: Pji_Fm_Plan_Maint_Pvt.OBTAIN_RELEASE_LOCKS (
1499: p_context => l_extraction_type
1500: , p_lock_mode => 'P'
1501: , x_return_status => l_return_status
1502: , x_msg_code => l_msg_code
5027: l_last_update_login number;
5028:
5029: l_return_status varchar2(255) := FND_API.G_RET_STS_SUCCESS;
5030: l_msg_data varchar2(2000);
5031: l_err_msg VARCHAR2(100):= 'Error in PJI_PJP_SUM_ROLLUP.MARK_EXTRACTED_PROJECTS -> PJI_FM_PLAN_MAINT.POPULATE_FIN8';
5032:
5033: begin
5034:
5035: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
5131: -- This change needs to be kept in mind when performing changes to sumz (adding
5132: -- new steps or changing sequences) programs in future.
5133: --
5134:
5135: PJI_FM_PLAN_MAINT.POPULATE_FIN8 (p_worker_id => p_worker_id,
5136: p_extraction_type => l_extraction_type,
5137: x_return_status => l_return_status,
5138: x_msg_data => l_msg_data);
5139:
7018:
7019: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
7020:
7021: IF (l_extraction_type = 'INCREMENTAL') THEN
7022: Pji_Fm_Plan_Maint.CREATE_SECONDARY_PVT;
7023: -- PJI_FM_PLAN_MAINT_PVT.PULL_DANGLING_PLANS; -- Removing redundant api nesting.
7024: END IF;
7025:
7026: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PULL_DANGLING_PLANS(p_worker_id);');
7019: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
7020:
7021: IF (l_extraction_type = 'INCREMENTAL') THEN
7022: Pji_Fm_Plan_Maint.CREATE_SECONDARY_PVT;
7023: -- PJI_FM_PLAN_MAINT_PVT.PULL_DANGLING_PLANS; -- Removing redundant api nesting.
7024: END IF;
7025:
7026: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PULL_DANGLING_PLANS(p_worker_id);');
7027:
7068: if (l_plan_type_id = -1) then
7069: l_plan_type_id := null;
7070: end if;
7071:
7072: PJI_FM_PLAN_MAINT.PULL_PLANS_FOR_PR(null,
7073: l_plan_type_id,
7074: 'PLANTYPE',
7075: l_return_status,
7076: l_msg_code);
7120:
7121: l_rbs_version_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7122: (l_process, 'RBS_VERSION_ID');
7123:
7124: PJI_FM_PLAN_MAINT.PULL_PLANS_FOR_PR(l_rbs_version_id,
7125: null,
7126: 'RBS',
7127: l_return_status,
7128: l_msg_code);
16004: end if;
16005:
16006: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
16007:
16008: PJI_FM_PLAN_MAINT_PVT.GET_FP_ROW_IDS;
16009:
16010: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.GET_FPR_ROWIDS(p_worker_id);');
16011:
16012: commit;
16043: end if;
16044:
16045: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
16046:
16047: PJI_FM_PLAN_MAINT_PVT.UPDATE_FP_ROWS;
16048:
16049: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_FPR_ROWS(p_worker_id);');
16050:
16051: commit;
16082: end if;
16083:
16084: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
16085:
16086: PJI_FM_PLAN_MAINT_PVT.INSERT_FP_ROWS;
16087:
16088: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.INSERT_FPR_ROWS(p_worker_id);');
16089:
16090: commit;
16121: end if;
16122:
16123: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
16124:
16125: -- PJI_FM_PLAN_MAINT_PVT.CLEANUP_FP_RMAP_FPR;
16126:
16127: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CLEANUP_FPR_ROWID_TABLE(p_worker_id);');
16128:
16129: commit;
16162: if (l_extraction_type = 'INCREMENTAL' or
16163: l_extraction_type = 'PARTIAL' or
16164: l_extraction_type = 'RBS') then
16165:
16166: PJI_FM_PLAN_MAINT_PVT.GET_AC_ROW_IDS;
16167:
16168: end if;
16169:
16170: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.GET_ACR_ROWIDS(p_worker_id);');
16205: if (l_extraction_type = 'INCREMENTAL' or
16206: l_extraction_type = 'PARTIAL' or
16207: l_extraction_type = 'RBS') then
16208:
16209: PJI_FM_PLAN_MAINT_PVT.UPDATE_AC_ROWS;
16210:
16211: end if;
16212:
16213: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_ACR_ROWS(p_worker_id);');
16246: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
16247:
16248: if (l_extraction_type = 'FULL') then
16249:
16250: PJI_FM_PLAN_MAINT_PVT.INSERT_INTO_AC_FACT;
16251:
16252: elsif (l_extraction_type = 'INCREMENTAL' or
16253: l_extraction_type = 'PARTIAL' or
16254: l_extraction_type = 'RBS') then
16252: elsif (l_extraction_type = 'INCREMENTAL' or
16253: l_extraction_type = 'PARTIAL' or
16254: l_extraction_type = 'RBS') then
16255:
16256: PJI_FM_PLAN_MAINT_PVT.INSERT_AC_ROWS;
16257:
16258: end if;
16259:
16260: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.INSERT_ACR_ROWS(p_worker_id);');
16295: -- if (l_extraction_type = 'INCREMENTAL' or
16296: -- l_extraction_type = 'PARTIAL' or
16297: -- l_extraction_type = 'RBS') then
16298: --
16299: -- PJI_FM_PLAN_MAINT_PVT.CLEANUP_AC_RMAP_FPR;
16300: --
16301: -- end if;
16302:
16303: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CLEANUP_ACR_ROWID_TABLE(p_worker_id);');
17118: end if;
17119:
17120: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17121:
17122: PJI_FM_PLAN_MAINT_PVT.PROCESS_PENDING_PLAN_UPDATES(l_extraction_type,
17123: l_return_status,
17124: l_msg_data);
17125:
17126: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PROCESS_PENDING_PLAN_UPDATES(p_worker_id);');
17164: l_ret_msg_data varchar2(2000);
17165: l_ret_status varchar2(255);
17166: l_success varchar2(1) := 'Y';
17167: l_err_msg1 VARCHAR2(100):= 'Error in PJI_PJP_SUM_ROLLUP.GET_PLANRES_ACTUALS -> PA_PROGRESS_PUB.GET_SUMMARIZED_ACTUALS';
17168: l_err_msg2 VARCHAR2(100):= 'Error in PJI_PJP_SUM_ROLLUP.GET_PLANRES_ACTUALS -> PJI_FM_PLAN_MAINT.GET_ACTUALS_SUMM';
17169:
17170: begin
17171:
17172: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17265: WORKER_ID = p_worker_id and
17266: pji_project_status <> 'N';
17267:
17268:
17269: PJI_FM_PLAN_MAINT.GET_ACTUALS_SUMM (
17270: p_extr_type => l_extraction_type
17271: , x_return_status => l_return_status
17272: , x_msg_code => l_msg_data ) ;
17273:
17430: -- SELECT DECODE(l_extraction_type, 'PARTIAL', 'PLANTYPE', l_extraction_type)
17431: -- INTO l_extraction_type
17432: -- FROM DUAL ;
17433:
17434: Pji_Fm_Plan_Maint_Pvt.OBTAIN_RELEASE_LOCKS (
17435: p_context => l_extraction_type
17436: , p_lock_mode => NULL
17437: , x_return_status => l_return_status
17438: , x_msg_code => l_msg_code
17437: , x_return_status => l_return_status
17438: , x_msg_code => l_msg_code
17439: );
17440:
17441: PJI_FM_PLAN_MAINT_PVT.DELETE_PLAN_LINES ( x_return_status => l_return_status );
17442:
17443: -- Pji_Fm_Plan_Maint_Pvt.MARK_EXTRACTED_PLANS('SEC');
17444: -- Back to CREATE_SECONDARY_PVT due to issue 5155692
17445:
17439: );
17440:
17441: PJI_FM_PLAN_MAINT_PVT.DELETE_PLAN_LINES ( x_return_status => l_return_status );
17442:
17443: -- Pji_Fm_Plan_Maint_Pvt.MARK_EXTRACTED_PLANS('SEC');
17444: -- Back to CREATE_SECONDARY_PVT due to issue 5155692
17445:
17446: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UNLOCK_ALL_HEADERS(p_worker_id);');
17447:
17477: end if;
17478:
17479: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17480:
17481: PJI_FM_PLAN_MAINT_PVT.EXTRACT_FIN_PLAN_VERS_BULK(p_slice_type => 'PRI');
17482:
17483: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.EXTRACT_FIN_PLAN_VERS_BULK(p_worker_id);');
17484:
17485: commit;
17514: end if;
17515:
17516: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17517:
17518: PJI_FM_PLAN_MAINT_PVT.POPULATE_WBS_HDR;
17519:
17520: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_WBS_HDR(p_worker_id);');
17521:
17522: commit;
17551: end if;
17552:
17553: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17554:
17555: -- PJI_FM_PLAN_MAINT_PVT.UPDATE_WBS_HDR;
17556: PJI_FM_PLAN_MAINT_PVT.UPDATE_WBS_HDR(p_worker_id);
17557:
17558: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_WBS_HDR(p_worker_id);');
17559:
17552:
17553: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17554:
17555: -- PJI_FM_PLAN_MAINT_PVT.UPDATE_WBS_HDR;
17556: PJI_FM_PLAN_MAINT_PVT.UPDATE_WBS_HDR(p_worker_id);
17557:
17558: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_WBS_HDR(p_worker_id);');
17559:
17560: commit;
17589: end if;
17590:
17591: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17592:
17593: PJI_FM_PLAN_MAINT_PVT.POPULATE_RBS_HDR;
17594:
17595: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_RBS_HDR(p_worker_id);');
17596:
17597: commit;
17626: end if;
17627:
17628: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17629:
17630: PJI_FM_PLAN_MAINT_PVT.EXTRACT_PLAN_AMOUNTS_PRIRBS;
17631:
17632: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.EXTRACT_PLAN_AMOUNTS_PRIRBS(p_worker_id);');
17633:
17634: commit;
17663: end if;
17664:
17665: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17666:
17667: PJI_FM_PLAN_MAINT_PVT.ROLLUP_FPR_RBS_T_SLICE;
17668:
17669: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_T_SLICE(p_worker_id);');
17670:
17671: commit;
17813: end if;
17814:
17815: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17816:
17817: PJI_FM_PLAN_MAINT_PVT.INSERT_INTO_FP_FACT;
17818:
17819: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.INSERT_INTO_FP_FACT(p_worker_id);');
17820:
17821: commit;
17850: end if;
17851:
17852: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17853:
17854: PJI_FM_PLAN_MAINT_PVT.MARK_EXTRACTED_PLANS('PRI');
17855:
17856: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.MARK_EXTRACTED_PLANS(p_worker_id);');
17857:
17858: commit;
17913: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17914: -- Extraction type is not needed for this step.
17915: -- Retaining it to maintain coding style as well as for potential future use.
17916:
17917: PJI_FM_PLAN_MAINT_PVT.RETRIEVE_OVERRIDDEN_WP_ETC;
17918:
17919: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.RETRIEVE_OVERRIDDEN_WP_ETC(p_worker_id);');
17920:
17921: commit;
17943: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17944: -- Extraction type is not needed for this step.
17945: -- Retaining it to maintain coding style as well as for potential future use.
17946:
17947: PJI_FM_PLAN_MAINT_PVT.EXTRACT_PLAN_ETC_PRIRBS(p_slice_type => 'SEC');
17948:
17949: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.EXTRACT_PLAN_ETC_PRIRBS(p_worker_id);');
17950:
17951: commit;
18094: end if;
18095:
18096: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
18097:
18098: PJI_FM_PLAN_MAINT_PVT.MERGE_INTO_FP_FACTS;
18099:
18100: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.MERGE_INTO_FP_FACT(p_worker_id);');
18101:
18102: commit;