2994: l_msg_data varchar2(2000);
2995:
2996: begin
2997:
2998: l_process := PJI_PJP_SUM_MAIN.g_process || p_worker_id;
2999:
3000: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_TIME_DIMENSION(p_worker_id);')) then
3001: return;
3002: end if;
3286: l_rbs_version_id := -1;
3287: -- OLAP CHANGES END
3288:
3289:
3290: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
3291:
3292: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_EVENTS_SNAPSHOT(p_worker_id);')) then
3293: return;
3294: end if;
4291: l_msg_data varchar2(2000);
4292:
4293: begin
4294:
4295: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
4296:
4297: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.PROCESS_RBS_CHANGES(p_worker_id);')) then
4298: return;
4299: end if;
4354: l_msg_data varchar2(2000);
4355:
4356: begin
4357:
4358: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
4359:
4360: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_MAPPING_RULES(p_worker_id);')) then
4361: return;
4362: end if;
4405: l_msg_data varchar2(2000);
4406:
4407: begin
4408:
4409: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
4410:
4411: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.MAP_RBS_HEADERS(p_worker_id);')) then
4412: return;
4413: end if;
4459: l_creation_date := sysdate;
4460: l_created_by := FND_GLOBAL.USER_ID;
4461: l_last_update_login := FND_GLOBAL.LOGIN_ID;
4462:
4463: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
4464:
4465: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_XBS_DENORM_FULL(p_worker_id);')) then
4466: return;
4467: end if;
4628: l_msg_code varchar2(255);
4629:
4630: begin
4631:
4632: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
4633:
4634: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.LOCK_HEADERS(p_worker_id);')) then
4635: return;
4636: end if;
4680: l_last_update_login number;
4681:
4682: begin
4683:
4684: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
4685:
4686: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_PROGRAM_WBS(p_worker_id);')) then
4687: return;
4688: end if;
4917: /* Bug Fix 9212516 */
4918:
4919: begin
4920:
4921: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
4922:
4923: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.PURGE_EVENT_DATA(p_worker_id);')) then
4924: return;
4925: end if;
5145: l_last_update_login number;
5146:
5147: begin
5148:
5149: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
5150:
5151: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_PROGRAM_RBS(p_worker_id);')) then
5152: return;
5153: end if;
5718: begin
5719:
5720: if (p_worker_id is not null) then
5721:
5722: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
5723:
5724: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_XBS_DENORM_DELTA(p_worker_id);')) then
5725: return;
5726: end if;
6355: l_extraction_type varchar2(30);
6356:
6357: begin
6358:
6359: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
6360:
6361: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_RBS_DENORM_DELTA(p_worker_id);')) then
6362: return;
6363: end if;
6478:
6479:
6480: begin
6481:
6482: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
6483:
6484: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_FP_SLICES(p_worker_id);')) then
6485: return;
6486: end if;
7634:
7635:
7636: begin
7637:
7638: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
7639:
7640: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
7641:
7642: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_AC_SLICES(p_worker_id);')) then
8298: l_err_msg VARCHAR2(100):= 'Error in PJI_PJP_SUM_ROLLUP.MARK_EXTRACTED_PROJECTS -> PJI_FM_PLAN_MAINT.POPULATE_FIN8';
8299:
8300: begin
8301:
8302: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
8303:
8304: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.MARK_EXTRACTED_PROJECTS(p_worker_id);')) then
8305: return;
8306: end if;
8447:
8448: else
8449: /* Added for bug 13030627 */
8450:
8451: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
8452:
8453: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
8454: l_refresh_code := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'REFRESH_CODE'); -- Bug#5099574
8455:
9146: l_refresh_code number; -- Bug#5099574
9147: l_plan_type_id number;
9148: begin
9149:
9150: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
9151:
9152: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_AC_CUST_SLICES(p_worker_id);')) then
9153: return;
9154: end if;
10301: l_msg_data varchar2(2000);
10302:
10303: begin
10304:
10305: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
10306:
10307: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.PULL_DANGLING_PLANS(p_worker_id);')) then
10308: return;
10309: end if;
10343: l_plan_type_id number;
10344:
10345: begin
10346:
10347: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
10348:
10349: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.PULL_PLANS_FOR_PR(p_worker_id);')) then
10350: return;
10351: end if;
10399: l_rbs_version_id number;
10400:
10401: begin
10402:
10403: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
10404:
10405: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.PULL_PLANS_FOR_RBS(p_worker_id);')) then
10406: return;
10407: end if;
10443: l_extraction_type varchar2(30);
10444:
10445: begin
10446:
10447: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
10448:
10449: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_TOP(p_worker_id);')) then
10450: return;
10451: end if;
10998:
10999: else
11000: /* Added for bug 13030627 */
11001:
11002: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
11003:
11004: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_WBS(p_worker_id);')) then
11005: return;
11006: end if;
13223: begin
13224:
13225: if (p_worker_id is not null) then
13226:
13227: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
13228:
13229: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_SMART_SLICES(p_worker_id);')) then
13230: return;
13231: end if;
14162: begin
14163:
14164: if (p_worker_id is not null) then
14165:
14166: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
14167:
14168: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_WBS(p_worker_id);')) then
14169: return;
14170: end if;
15501: l_count number;
15502:
15503: begin
15504:
15505: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
15506:
15507: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_PRG(p_worker_id);')) then
15508: return;
15509: end if;
16743: l_count number;
16744:
16745: begin
16746:
16747: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
16748:
16749: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_PRG(p_worker_id);')) then
16750: return;
16751: end if;
17283: l_msg_data varchar2(2000);
17284:
17285: begin
17286:
17287: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17288:
17289: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_NONTP(p_worker_id);')) then
17290: return;
17291: end if;
17322: l_msg_data varchar2(2000);
17323:
17324: begin
17325:
17326: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17327:
17328: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_PA(p_worker_id);')) then
17329: return;
17330: end if;
17361: l_msg_data varchar2(2000);
17362:
17363: begin
17364:
17365: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17366:
17367: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_GL(p_worker_id);')) then
17368: return;
17369: end if;
17400: l_msg_data varchar2(2000);
17401:
17402: begin
17403:
17404: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17405:
17406: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_EN(p_worker_id);')) then
17407: return;
17408: end if;
17439: l_msg_data varchar2(2000);
17440:
17441: begin
17442:
17443: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17444:
17445: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_ALL(p_worker_id);')) then
17446: return;
17447: end if;
17478: l_msg_data varchar2(2000);
17479:
17480: begin
17481:
17482: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17483:
17484: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_PA(p_worker_id);')) then
17485: return;
17486: end if;
17515: l_msg_data varchar2(2000);
17516:
17517: begin
17518:
17519: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17520:
17521: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_GL(p_worker_id);')) then
17522: return;
17523: end if;
17552: l_msg_data varchar2(2000);
17553:
17554: begin
17555:
17556: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17557:
17558: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_EN(p_worker_id);')) then
17559: return;
17560: end if;
17589: l_msg_data varchar2(2000);
17590:
17591: begin
17592:
17593: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17594:
17595: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_ALL(p_worker_id);')) then
17596: return;
17597: end if;
17625: l_extraction_type varchar2(30);
17626:
17627: begin
17628:
17629: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17630:
17631: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_PLAN_DATA(p_worker_id);')) then
17632: return;
17633: end if;
18097: p_worker_id => l_worker_id);
18098:
18099: else
18100:
18101: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
18102:
18103: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.PURGE_PLAN_DATA(p_worker_id);')) then
18104: return;
18105: end if;
18176: l_msg_data varchar2(2000);
18177:
18178: begin
18179:
18180: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
18181:
18182: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.GET_FPR_ROWIDS(p_worker_id);')) then
18183: return;
18184: end if;
18215: l_msg_data varchar2(2000);
18216:
18217: begin
18218:
18219: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
18220:
18221: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_FPR_ROWS(p_worker_id);')) then
18222: return;
18223: end if;
18254: l_msg_data varchar2(2000);
18255:
18256: begin
18257:
18258: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
18259:
18260: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.INSERT_FPR_ROWS(p_worker_id);')) then
18261: return;
18262: end if;
18293: l_msg_data varchar2(2000);
18294:
18295: begin
18296:
18297: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
18298:
18299: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.CLEANUP_FPR_ROWID_TABLE(p_worker_id);')) then
18300: return;
18301: end if;
18330: l_msg_data varchar2(2000);
18331:
18332: begin
18333:
18334: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
18335:
18336: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.GET_ACR_ROWIDS(p_worker_id);')) then
18337: return;
18338: end if;
18373: l_msg_data varchar2(2000);
18374:
18375: begin
18376:
18377: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
18378:
18379: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_ACR_ROWS(p_worker_id);')) then
18380: return;
18381: end if;
18416: l_msg_data varchar2(2000);
18417:
18418: begin
18419:
18420: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
18421:
18422: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.INSERT_ACR_ROWS(p_worker_id);')) then
18423: return;
18424: end if;
18463: l_msg_data varchar2(2000);
18464:
18465: begin
18466:
18467: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
18468:
18469: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.CLEANUP_ACR_ROWID_TABLE(p_worker_id);')) then
18470: return;
18471: end if;
18519: l_last_update_login := FND_GLOBAL.LOGIN_ID;
18520:
18521: if (p_worker_id is not null) then
18522:
18523: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
18524:
18525: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_XBS_DENORM(p_worker_id);')) then
18526: return;
18527: end if;
19007: l_fpm_upgrade := PJI_UTILS.GET_PARAMETER('PJI_FPM_UPGRADE');
19008:
19009: if (p_worker_id is not null) then
19010:
19011: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
19012:
19013: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_RBS_DENORM(p_worker_id);')) then
19014: return;
19015: end if;
19338: l_msg_data varchar2(2000);
19339:
19340: begin
19341:
19342: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
19343:
19344: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.PROCESS_PENDING_EVENTS(p_worker_id);')) then
19345: return;
19346: end if;
19381: l_pji_schema varchar2(30); -- Added for bug 13897252
19382:
19383: begin
19384:
19385: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
19386: l_pji_schema := pji_utils.get_pji_schema_name; -- Added for bug 13897252
19387:
19388: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.PROCESS_PENDING_PLAN_UPDATES(p_worker_id);')) then
19389: return;
19449: l_err_msg2 VARCHAR2(100):= 'Error in PJI_PJP_SUM_ROLLUP.GET_PLANRES_ACTUALS -> PJI_FM_PLAN_MAINT.GET_ACTUALS_SUMM';
19450:
19451: begin
19452:
19453: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
19454: l_ret_status := FND_API.G_RET_STS_SUCCESS;
19455:
19456: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.GET_PLANRES_ACTUALS(p_worker_id);')) then
19457: return;
19609:
19610: begin
19611:
19612:
19613: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
19614:
19615: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.GET_TASK_ROLLUP_ACTUALS(p_worker_id);')) then
19616: return;
19617: end if;
19693: l_msg_code varchar2(255);
19694:
19695: begin
19696:
19697: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
19698:
19699: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.UNLOCK_ALL_HEADERS(p_worker_id);')) then
19700: return;
19701: end if;
19752: l_msg_data varchar2(2000);
19753:
19754: begin
19755:
19756: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
19757:
19758: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.EXTRACT_FIN_PLAN_VERS_BULK(p_worker_id);')) then
19759: return;
19760: end if;
19789: l_msg_data varchar2(2000);
19790:
19791: begin
19792:
19793: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
19794:
19795: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_WBS_HDR(p_worker_id);')) then
19796: return;
19797: end if;
19826: l_msg_data varchar2(2000);
19827:
19828: begin
19829:
19830: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
19831:
19832: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_WBS_HDR(p_worker_id);')) then
19833: return;
19834: end if;
19864: l_msg_data varchar2(2000);
19865:
19866: begin
19867:
19868: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
19869:
19870: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_RBS_HDR(p_worker_id);')) then
19871: return;
19872: end if;
19901: l_msg_data varchar2(2000);
19902:
19903: begin
19904:
19905: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
19906:
19907: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.EXTRACT_PLAN_AMOUNTS_PRIRBS(p_worker_id);')) then
19908: return;
19909: end if;
19938: l_msg_data varchar2(2000);
19939:
19940: begin
19941:
19942: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
19943:
19944: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_T_SLICE(p_worker_id);')) then
19945: return;
19946: end if;
19975: l_msg_data varchar2(2000);
19976:
19977: begin
19978:
19979: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
19980:
19981: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_FP_PA_PRI_ROLLUP(p_worker_id);')) then
19982: return;
19983: end if;
20012: l_msg_data varchar2(2000);
20013:
20014: begin
20015:
20016: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
20017:
20018: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_FP_GL_PRI_ROLLUP(p_worker_id);')) then
20019: return;
20020: end if;
20049: l_msg_data varchar2(2000);
20050:
20051: begin
20052:
20053: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
20054:
20055: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_FP_ALL_PRI_ROLLUP(p_worker_id);')) then
20056: return;
20057: end if;
20088: l_msg_data varchar2(2000);
20089:
20090: begin
20091:
20092: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
20093:
20094: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.INSERT_INTO_FP_FACT(p_worker_id);')) then
20095: return;
20096: end if;
20125: l_msg_data varchar2(2000);
20126:
20127: begin
20128:
20129: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
20130:
20131: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.MARK_EXTRACTED_PLANS(p_worker_id);')) then
20132: return;
20133: end if;
20153: l_msg_data varchar2(2000);
20154:
20155: begin
20156:
20157: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
20158:
20159: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.REMAP_RBS_TXN_ACCUM_HDRS(p_worker_id);')) then
20160: return;
20161: end if;
20186: l_msg_data varchar2(2000);
20187:
20188: begin
20189:
20190: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
20191:
20192: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.RETRIEVE_OVERRIDDEN_WP_ETC(p_worker_id);')) then
20193: return;
20194: end if;
20216: l_msg_data varchar2(2000);
20217:
20218: begin
20219:
20220: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
20221:
20222: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.EXTRACT_PLAN_ETC_PRIRBS(p_worker_id);')) then
20223: return;
20224: end if;
20280: begin
20281:
20282: if (p_worker_id is not null) then
20283:
20284: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
20285:
20286: /* 5755229 Because No step entry in the delete process FPM Upgrade
20287: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.CLEANUP(p_worker_id);')) then -- Bug#5171542
20288: return;
20476: l_msg_data varchar2(2000);
20477:
20478: begin
20479:
20480: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
20481:
20482: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.MERGE_INTO_FP_FACT(p_worker_id);')) then
20483: return;
20484: end if;