[Home] [Help]
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;
3003:
3004: PJI_TIME_C.LOAD(null, null, l_return_status, l_msg_count, l_msg_data);
3002: end if;
3003:
3004: PJI_TIME_C.LOAD(null, null, l_return_status, l_msg_count, l_msg_data);
3005:
3006: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_TIME_DIMENSION(p_worker_id);');
3007:
3008: commit;
3009:
3010: end POPULATE_TIME_DIMENSION;
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;
3295:
3296: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
3295:
3296: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
3297:
3298: l_last_update_date := sysdate;
3299: l_last_updated_by := FND_GLOBAL.USER_ID;
3300: l_creation_date := sysdate;
3645: null; -- do not process any events during partial refresh
3646:
3647: elsif (l_extraction_type = 'RBS') then
3648:
3649: l_rbs_header_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
3650: (l_process, 'RBS_HEADER_ID');
3651:
3652: if (l_rbs_header_id = -1) then
3653: l_rbs_header_id := null;
4250:
4251:
4252: end if;
4253:
4254: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_EVENTS_SNAPSHOT(p_worker_id);');
4255:
4256: commit;
4257:
4258: end CREATE_EVENTS_SNAPSHOT;
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;
4300:
4301: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
4300:
4301: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
4302:
4303: if (l_extraction_type = 'RBS') then
4304:
4305: for c in rbs_events(p_worker_id) loop
4314: end loop;
4315:
4316: end if;
4317:
4318: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PROCESS_RBS_CHANGES(p_worker_id);');
4319:
4320: commit;
4321:
4322: end PROCESS_RBS_CHANGES;
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;
4363:
4364: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
4363:
4364: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
4365:
4366: for c in required_rbs(p_worker_id) loop
4367:
4368: begin
4376: end;
4377:
4378: end loop;
4379:
4380: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_MAPPING_RULES(p_worker_id);');
4381:
4382: commit;
4383:
4384: end CREATE_MAPPING_RULES;
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;
4414:
4415: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
4414:
4415: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
4416:
4417: begin
4418: PA_RBS_MAPPING.MAP_RBS_ACTUALS(p_worker_id,
4419: l_return_status,
4422: exception when others then
4423: PJI_UTILS.WRITE2LOG('MAP_RBS_HEADERS:' || SQLERRM);
4424: end;
4425:
4426: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.MAP_RBS_HEADERS(p_worker_id);');
4427:
4428: commit;
4429:
4430: end MAP_RBS_HEADERS;
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;
4468:
4469: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
4468:
4469: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
4470:
4471: l_count := 0;
4472:
4473: if (l_extraction_type = 'FULL') then
4599: -- where map.WORKER_ID = p_worker_id);
4600:
4601: end if;
4602:
4603: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_XBS_DENORM_FULL(p_worker_id);');
4604:
4605: commit;
4606:
4607: end UPDATE_XBS_DENORM_FULL;
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;
4637:
4638: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
4637:
4638: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
4639:
4640: -- PJI_FM_XBS_ACCUM_MAINT.WBS_LOCK_PVT(p_online_flag => 'N',
4641: -- x_lock_mode => l_lock_mode,
4642: -- x_return_status => l_return_status);
4651: , x_return_status => l_return_status
4652: , x_msg_code => l_msg_code
4653: );
4654:
4655: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.LOCK_HEADERS(p_worker_id);');
4656:
4657: commit;
4658:
4659: end LOCK_HEADERS;
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;
4689:
4690: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
4689:
4690: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
4691:
4692: l_last_update_date := sysdate;
4693: l_last_updated_by := FND_GLOBAL.USER_ID;
4694: l_creation_date := sysdate;
4848: PROJECT_ID;
4849:
4850: end if;
4851:
4852: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_PROGRAM_WBS(p_worker_id);');
4853:
4854: commit;
4855:
4856: end UPDATE_PROGRAM_WBS;
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;
4926:
4927: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
4926:
4927: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
4928:
4929: if (l_extraction_type = 'INCREMENTAL') then
4930:
4931: delete
5010:
5011:
5012: end if;
5013:
5014: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PURGE_EVENT_DATA(p_worker_id);');
5015:
5016: commit;
5017:
5018: end PURGE_EVENT_DATA;
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;
5154:
5155: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
5154:
5155: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
5156:
5157: l_last_update_date := sysdate;
5158: l_last_updated_by := FND_GLOBAL.USER_ID;
5159: l_creation_date := sysdate;
5641: end if;
5642:
5643: end if;
5644:
5645: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_PROGRAM_RBS(p_worker_id);');
5646:
5647: commit;
5648:
5649: end UPDATE_PROGRAM_RBS;
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;
5727:
5728: l_last_update_date := sysdate;
5730: l_creation_date := sysdate;
5731: l_created_by := FND_GLOBAL.USER_ID;
5732: l_last_update_login := FND_GLOBAL.LOGIN_ID;
5733:
5734: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
5735:
5736: if (l_extraction_type = 'INCREMENTAL') then
5737:
5738: insert into PJI_XBS_DENORM_DELTA delta_i
6217: end if;
6218:
6219: end if;
6220:
6221: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_XBS_DENORM_DELTA(p_worker_id);');
6222:
6223: commit;
6224:
6225: else -- online mode
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;
6364:
6365: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
6364:
6365: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
6366:
6367: if (l_extraction_type = 'RBS') then
6368:
6369: insert into PJI_RBS_DENORM_DELTA delta_i
6442: sum(SIGN) <> 0;
6443:
6444: end if;
6445:
6446: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_RBS_DENORM_DELTA(p_worker_id);');
6447:
6448: commit;
6449:
6450: end POPULATE_RBS_DENORM_DELTA;
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;
6487:
6488: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
6487:
6488: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
6489:
6490: -- Bug#5099574 - Start
6491:
6492: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'PLAN_TYPE_ID');
6488: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
6489:
6490: -- Bug#5099574 - Start
6491:
6492: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'PLAN_TYPE_ID');
6493: l_refresh_code := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'REFRESH_CODE');
6494:
6495: if (l_plan_type_id = -1) then
6496: l_plan_type_id := null;
6489:
6490: -- Bug#5099574 - Start
6491:
6492: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'PLAN_TYPE_ID');
6493: l_refresh_code := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'REFRESH_CODE');
6494:
6495: if (l_plan_type_id = -1) then
6496: l_plan_type_id := null;
6497: end if;
6497: end if;
6498:
6499: -- If condtion is true then mark the process as completed and return
6500: if ( l_extraction_type='PARTIAL' and ( bitand(l_refresh_code,1) <> 1) ) then
6501: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_FP_SLICES(p_worker_id);');
6502: commit;
6503: return;
6504: end if;
6505:
7599: src.RBS_VERSION_ID,
7600: src.PLAN_VERSION_ID,
7601: src.PLAN_TYPE_ID;
7602:
7603: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_FP_SLICES(p_worker_id);');
7604:
7605: commit;
7606:
7607: end AGGREGATE_FP_SLICES;
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
7643: return;
7644: end if;
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
7643: return;
7644: end if;
7645:
7646: -- Bug#5099574 - Start
7644: end if;
7645:
7646: -- Bug#5099574 - Start
7647:
7648: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'PLAN_TYPE_ID');
7649: l_refresh_code := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'REFRESH_CODE');
7650:
7651: if (l_plan_type_id = -1) then
7652: l_plan_type_id := null;
7645:
7646: -- Bug#5099574 - Start
7647:
7648: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'PLAN_TYPE_ID');
7649: l_refresh_code := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'REFRESH_CODE');
7650:
7651: if (l_plan_type_id = -1) then
7652: l_plan_type_id := null;
7653: end if;
7653: end if;
7654:
7655: -- If the condtion is true then mark the process as completed and return
7656: if ( l_extraction_type='PARTIAL' and ( l_plan_type_id is not null or bitand(l_refresh_code,1) <> 1) ) then
7657: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_AC_SLICES(p_worker_id);');
7658: commit;
7659: return;
7660: end if;
7661:
8267: nvl(CURRENCY_CODE, 'PJI$NULL');
8268:
8269: end if;
8270:
8271: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_AC_SLICES(p_worker_id);');
8272:
8273: commit;
8274:
8275: end AGGREGATE_AC_SLICES;
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;
8307:
8308: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
8307:
8308: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
8309:
8310: l_last_update_date := sysdate;
8311: l_last_updated_by := FND_GLOBAL.USER_ID;
8312: l_last_update_login := FND_GLOBAL.LOGIN_ID;
8408: dbms_standard.raise_application_error(-20105, l_err_msg);
8409: END IF;
8410:
8411:
8412: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.MARK_EXTRACTED_PROJECTS(p_worker_id);');
8413:
8414: commit;
8415:
8416: end MARK_EXTRACTED_PROJECTS;
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:
8456: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_FP_CUST_SLICES(p_worker_id);')) then
8457: return;
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:
8456: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_FP_CUST_SLICES(p_worker_id);')) then
8457: return;
8458: end if;
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:
8456: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_FP_CUST_SLICES(p_worker_id);')) then
8457: return;
8458: end if;
8459:
8460: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
8456: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_FP_CUST_SLICES(p_worker_id);')) then
8457: return;
8458: end if;
8459:
8460: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
8461: (l_process, 'PLAN_TYPE_ID');
8462:
8463: if (l_plan_type_id = -1) then
8464: l_plan_type_id := null;
9120: if ( l_extraction_type = 'PARTIAL' ) then -- Partial Refresh Performance Improvement
9121: delete from PJI_FM_EXTR_PLNVER3_T where worker_id=p_worker_id;
9122: end if;
9123:
9124: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_FP_CUST_SLICES(p_worker_id);');
9125:
9126: commit;
9127:
9128: end if;
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;
9155:
9156: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
9155:
9156: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
9157:
9158: -- Bug#5099574
9159: l_refresh_code := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'REFRESH_CODE');
9160: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'PLAN_TYPE_ID');
9155:
9156: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
9157:
9158: -- Bug#5099574
9159: l_refresh_code := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'REFRESH_CODE');
9160: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'PLAN_TYPE_ID');
9161:
9162: -- Bug 15881881
9163: fnd_stats.gather_table_stats('PJI','PJI_AC_AGGR_PJP0',PERCENT=>40);
9156: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
9157:
9158: -- Bug#5099574
9159: l_refresh_code := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'REFRESH_CODE');
9160: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'PLAN_TYPE_ID');
9161:
9162: -- Bug 15881881
9163: fnd_stats.gather_table_stats('PJI','PJI_AC_AGGR_PJP0',PERCENT=>40);
9164: fnd_stats.gather_table_stats('PJI','PJI_AC_CUST_PJP0',PERCENT=>40);
10274: nvl(sum(CUSTOM14), 0) = 0 and
10275: nvl(sum(CUSTOM15), 0) = 0);
10276: end if;
10277:
10278: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_AC_CUST_SLICES(p_worker_id);');
10279:
10280: commit;
10281:
10282: end AGGREGATE_AC_CUST_SLICES;
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;
10310:
10311: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
10310:
10311: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
10312:
10313: IF (l_extraction_type = 'INCREMENTAL') THEN
10314: Pji_Fm_Plan_Maint.CREATE_SECONDARY_PVT;
10315: -- PJI_FM_PLAN_MAINT_PVT.PULL_DANGLING_PLANS; -- Removing redundant api nesting.
10314: Pji_Fm_Plan_Maint.CREATE_SECONDARY_PVT;
10315: -- PJI_FM_PLAN_MAINT_PVT.PULL_DANGLING_PLANS; -- Removing redundant api nesting.
10316: END IF;
10317:
10318: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PULL_DANGLING_PLANS(p_worker_id);');
10319:
10320: commit;
10321:
10322: end PULL_DANGLING_PLANS;
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;
10352:
10353: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
10352:
10353: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
10354:
10355: if (l_extraction_type = 'PARTIAL') then
10356:
10357: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
10353: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
10354:
10355: if (l_extraction_type = 'PARTIAL') then
10356:
10357: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
10358: (l_process, 'PLAN_TYPE_ID');
10359:
10360: if (l_plan_type_id = -1) then
10361: l_plan_type_id := null;
10368: l_msg_code);
10369:
10370: end if;
10371:
10372: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PULL_PLANS_FOR_PR(p_worker_id);');
10373:
10374: commit;
10375:
10376: end PULL_PLANS_FOR_PR;
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;
10408:
10409: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
10408:
10409: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
10410:
10411: if (l_extraction_type = 'RBS') then
10412:
10413: l_rbs_version_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
10409: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
10410:
10411: if (l_extraction_type = 'RBS') then
10412:
10413: l_rbs_version_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
10414: (l_process, 'RBS_VERSION_ID');
10415:
10416: PJI_FM_PLAN_MAINT.PULL_PLANS_FOR_PR(l_rbs_version_id,
10417: null,
10420: l_msg_code);
10421:
10422: end if;
10423:
10424: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PULL_PLANS_FOR_RBS(p_worker_id);');
10425:
10426: commit;
10427:
10428: end PULL_PLANS_FOR_RBS;
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;
10452:
10453: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
10452:
10453: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
10454:
10455: insert /*+ parallel(pjp1_i) */ into PJI_FP_AGGR_PJP1 pjp1_i /* Added for bug 13030627 */
10456: (
10457: WORKER_ID,
10955: pjp1.PLAN_VERSION_ID,
10956: pjp1.PLAN_TYPE_ID,
10957: pjp1.PLAN_TYPE_CODE;
10958:
10959: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_TOP(p_worker_id);');
10960:
10961: commit;
10962:
10963: end ROLLUP_FPR_RBS_TOP;
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;
11007:
11008: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
11007:
11008: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
11009:
11010: l_fpm_upgrade := nvl(PJI_UTILS.GET_PARAMETER('PJI_FPM_UPGRADE'), 'C');
11011:
11012: select decode(l_extraction_type,'PARTIAL','PARTIAL',NULL)
11049: den.STRUCT_TYPE = 'PRG' and
11050: den.SUB_LEVEL = den.SUP_LEVEL and
11051: den.SUP_PROJECT_ID = map.PROJECT_ID;
11052:
11053: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(l_process,
11054: 'MAX_PROGRAM_LEVEL',
11055: l_level);
11056:
11057: for x in 1 .. l_level loop
11078: end loop;
11079:
11080: end if;
11081:
11082: l_max_level := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
11083: (l_process, 'MAX_PROGRAM_LEVEL');
11084:
11085: select
11086: nvl(to_number(min(STEP_SEQ)), 0)
11135:
11136: end if;
11137: -- End Bug# 9904361
11138:
11139: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_WBS(p_worker_id);');
11140:
11141: commit;
11142:
11143: end if; /* Added for bug 13030627 */
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;
13232:
13233: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
13232:
13233: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
13234:
13235: insert into PJI_FP_AGGR_PJP1 pjp1_i
13236: (
13237: WORKER_ID,
13679: pjp1.PLAN_VERSION_ID,
13680: pjp1.PLAN_TYPE_ID,
13681: pjp1.PLAN_TYPE_CODE;
13682:
13683: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_SMART_SLICES(p_worker_id);');
13684:
13685: commit;
13686:
13687: else -- online mode
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;
14171:
14172: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
14171:
14172: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
14173:
14174: -- allow recovery after each level is processed
14175:
14176: select
14207: den.STRUCT_TYPE = 'PRG' and
14208: den.SUB_LEVEL = den.SUP_LEVEL and
14209: den.SUP_PROJECT_ID = map.PROJECT_ID;
14210:
14211: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(l_process,
14212: 'MAX_PROGRAM_LEVEL',
14213: l_level);
14214:
14215: for x in 1 .. l_level loop
14236: end loop;
14237:
14238: end if;
14239:
14240: l_max_level := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
14241: (l_process, 'MAX_PROGRAM_LEVEL');
14242:
14243: select
14244: nvl(to_number(min(STEP_SEQ)), 0)
14265: STEP_SEQ = l_level_seq;
14266:
14267: -- rollup project hiearchy
14268: /* Call to Paritioned procedure for bug 7551819 */
14269: PJI_PROCESS_UTIL.EXECUTE_ROLLUP_ACR_WBS(p_worker_id,
14270: l_level);
14271:
14272: /* Commented for bug 7551819 */
14273: -- insert /*+ parallel(pjp1_in)
14875: end if;
14876:
14877: end loop;
14878:
14879: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_WBS(p_worker_id);');
14880:
14881: commit;
14882:
14883: else -- online mode
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;
15510:
15511: l_prg_exists := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
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;
15510:
15511: l_prg_exists := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
15512: (l_process, 'PROGRAM_EXISTS');
15513:
15514: if (l_prg_exists = 'N') then
15515: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process,
15511: l_prg_exists := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
15512: (l_process, 'PROGRAM_EXISTS');
15513:
15514: if (l_prg_exists = 'N') then
15515: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process,
15516: 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_PRG(p_worker_id);');
15517: commit;
15518: return;
15519: end if;
15517: commit;
15518: return;
15519: end if;
15520:
15521: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
15522:
15523: -- allow recovery after each level is processed
15524:
15525: select
15553: where
15554: den.WORKER_ID = p_worker_id and
15555: den.STRUCT_TYPE = 'PRG';
15556:
15557: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(l_process,
15558: 'MAX_PROGRAM_LEVEL',
15559: l_level);
15560:
15561: insert into PJI_SYSTEM_PRC_STATUS
15612: SUP_LEVEL desc;
15613:
15614: end if;
15615:
15616: l_max_level := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
15617: (l_process, 'MAX_PROGRAM_LEVEL');
15618:
15619: select
15620: nvl(to_number(min(STEP_SEQ)), 0)
15641: STEP_SEQ = l_level_seq;
15642:
15643: -- rollup project hiearchy
15644: /* Call to Paritioned procedure for bug 7551819 */
15645: PJI_PROCESS_UTIL.EXECUTE_ROLLUP_FPR_PRG(p_worker_id,
15646: l_level);
15647:
15648: /* Commented for bug 7551819 */
15649: -- insert /*+ parallel(pjp1_in)
16714: end if;
16715:
16716: end loop;
16717:
16718: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_PRG(p_worker_id);');
16719:
16720: commit;
16721:
16722: end ROLLUP_FPR_PRG;
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;
16752:
16753: l_prg_exists := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
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;
16752:
16753: l_prg_exists := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
16754: (l_process, 'PROGRAM_EXISTS');
16755:
16756: if (l_prg_exists = 'N') then
16757: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process,
16753: l_prg_exists := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
16754: (l_process, 'PROGRAM_EXISTS');
16755:
16756: if (l_prg_exists = 'N') then
16757: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process,
16758: 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_PRG(p_worker_id);');
16759: commit;
16760: return;
16761: end if;
16759: commit;
16760: return;
16761: end if;
16762:
16763: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
16764:
16765: -- allow recovery after each level is processed
16766:
16767: select
16795: where
16796: den.WORKER_ID = p_worker_id and
16797: den.STRUCT_TYPE = 'PRG';
16798:
16799: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(l_process,
16800: 'MAX_PROGRAM_LEVEL',
16801: l_level);
16802:
16803: insert into PJI_SYSTEM_PRC_STATUS
16854: SUP_LEVEL desc;
16855:
16856: end if;
16857:
16858: l_max_level := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
16859: (l_process, 'MAX_PROGRAM_LEVEL');
16860:
16861: select
16862: nvl(to_number(min(STEP_SEQ)), 0)
16883: STEP_SEQ = l_level_seq;
16884:
16885: -- rollup project hiearchy
16886: /* Call to Paritioned procedure for bug 7551819 */
16887: PJI_PROCESS_UTIL.EXECUTE_ROLLUP_ACR_PRG(p_worker_id,
16888: l_level);
16889:
16890: /* Commented for bug 7551819 */
16891: -- insert /*+ parallel(pjp1_in)
17254: end if;
17255:
17256: end loop;
17257:
17258: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_PRG(p_worker_id);');
17259:
17260: commit;
17261:
17262: end ROLLUP_ACR_PRG;
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;
17292:
17293: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
17292:
17293: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17294:
17295: PJI_FM_PLAN_CAL_RLPS.CREATE_FP_NONTP_ROLLUP;
17296:
17297: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_NONTP(p_worker_id);');
17293: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17294:
17295: PJI_FM_PLAN_CAL_RLPS.CREATE_FP_NONTP_ROLLUP;
17296:
17297: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_NONTP(p_worker_id);');
17298:
17299: commit;
17300:
17301: end ROLLUP_FPR_CAL_NONTP;
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;
17331:
17332: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
17331:
17332: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17333:
17334: PJI_FM_PLAN_CAL_RLPS.CREATE_FP_PA_ROLLUP;
17335:
17336: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_PA(p_worker_id);');
17332: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17333:
17334: PJI_FM_PLAN_CAL_RLPS.CREATE_FP_PA_ROLLUP;
17335:
17336: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_PA(p_worker_id);');
17337:
17338: commit;
17339:
17340: end ROLLUP_FPR_CAL_PA;
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;
17370:
17371: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
17370:
17371: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17372:
17373: PJI_FM_PLAN_CAL_RLPS.CREATE_FP_GL_ROLLUP;
17374:
17375: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_GL(p_worker_id);');
17371: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17372:
17373: PJI_FM_PLAN_CAL_RLPS.CREATE_FP_GL_ROLLUP;
17374:
17375: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_GL(p_worker_id);');
17376:
17377: commit;
17378:
17379: end ROLLUP_FPR_CAL_GL;
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;
17409:
17410: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
17409:
17410: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17411:
17412: PJI_FM_PLAN_CAL_RLPS.CREATE_FP_ENT_ROLLUP;
17413:
17414: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_EN(p_worker_id);');
17410: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17411:
17412: PJI_FM_PLAN_CAL_RLPS.CREATE_FP_ENT_ROLLUP;
17413:
17414: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_EN(p_worker_id);');
17415:
17416: commit;
17417:
17418: end ROLLUP_FPR_CAL_EN;
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;
17448:
17449: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
17448:
17449: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17450:
17451: -- Changes done for bug 6381284
17452: --PJI_FM_PLAN_CAL_RLPS.CREATE_FP_ALL_T_PRI_ROLLUP('G');
17453: PJI_FM_PLAN_CAL_RLPS.CREATE_FP_ALL_T_PRI_ROLLUP('C');
17451: -- Changes done for bug 6381284
17452: --PJI_FM_PLAN_CAL_RLPS.CREATE_FP_ALL_T_PRI_ROLLUP('G');
17453: PJI_FM_PLAN_CAL_RLPS.CREATE_FP_ALL_T_PRI_ROLLUP('C');
17454:
17455: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_ALL(p_worker_id);');
17456:
17457: commit;
17458:
17459: end ROLLUP_FPR_CAL_ALL;
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;
17487:
17488: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
17487:
17488: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17489:
17490: PJI_FM_PLAN_CAL_RLPS.CREATE_AC_PA_ROLLUP;
17491:
17492: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_PA(p_worker_id);');
17488: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17489:
17490: PJI_FM_PLAN_CAL_RLPS.CREATE_AC_PA_ROLLUP;
17491:
17492: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_PA(p_worker_id);');
17493:
17494: commit;
17495:
17496: end ROLLUP_ACR_CAL_PA;
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;
17524:
17525: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
17524:
17525: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17526:
17527: PJI_FM_PLAN_CAL_RLPS.CREATE_AC_GL_ROLLUP;
17528:
17529: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_GL(p_worker_id);');
17525: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17526:
17527: PJI_FM_PLAN_CAL_RLPS.CREATE_AC_GL_ROLLUP;
17528:
17529: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_GL(p_worker_id);');
17530:
17531: commit;
17532:
17533: end ROLLUP_ACR_CAL_GL;
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;
17561:
17562: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
17561:
17562: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17563:
17564: PJI_FM_PLAN_CAL_RLPS.CREATE_AC_ENT_ROLLUP;
17565:
17566: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_EN(p_worker_id);');
17562: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17563:
17564: PJI_FM_PLAN_CAL_RLPS.CREATE_AC_ENT_ROLLUP;
17565:
17566: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_EN(p_worker_id);');
17567:
17568: commit;
17569:
17570: end ROLLUP_ACR_CAL_EN;
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;
17598:
17599: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
17598:
17599: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17600:
17601: PJI_FM_PLAN_CAL_RLPS.CREATE_AC_ALL_T_PRI_ROLLUP('G');
17602:
17603: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_ALL(p_worker_id);');
17599: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17600:
17601: PJI_FM_PLAN_CAL_RLPS.CREATE_AC_ALL_T_PRI_ROLLUP('G');
17602:
17603: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_ALL(p_worker_id);');
17604:
17605: commit;
17606:
17607: end ROLLUP_ACR_CAL_ALL;
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;
17634:
17635: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
17634:
17635: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17636:
17637: IF (l_extraction_type IN ('PARTIAL', 'RBS', 'INCREMENTAL', 'FULL')) THEN
17638: /* Call to Paritioned procedure for bug 7551819 */
17639: PJI_PROCESS_UTIL.EXECUTE_AGGREGATE_PLAN_DATA(p_worker_id);
17635: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17636:
17637: IF (l_extraction_type IN ('PARTIAL', 'RBS', 'INCREMENTAL', 'FULL')) THEN
17638: /* Call to Paritioned procedure for bug 7551819 */
17639: PJI_PROCESS_UTIL.EXECUTE_AGGREGATE_PLAN_DATA(p_worker_id);
17640:
17641: /* Commented for bug 7551819 */
17642: -- insert /*+ parallel(pjp1_in)
17643: -- noappend(pjp1_in) */ into PJI_FP_AGGR_PJP1 pjp1_in -- changed for bug 5927368
18053: nvl(sum(CUSTOM15), 0) = 0); */
18054:
18055: end if;
18056:
18057: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_PLAN_DATA(p_worker_id);');
18058:
18059: commit;
18060:
18061: end AGGREGATE_PLAN_DATA;
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;
18106:
18107: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
18106:
18107: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
18108:
18109: IF (l_extraction_type IN ('PARTIAL', 'RBS', 'INCREMENTAL', 'FULL')) THEN
18110:
18111: -- begin: bug 7146014
18145: nvl(pjp1.RECORD_TYPE, 'X') <> 'A';
18146:
18147: end if;
18148:
18149: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PURGE_PLAN_DATA(p_worker_id);');
18150:
18151: commit;
18152:
18153: end if; -- Added for bug 13451898
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;
18185:
18186: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
18185:
18186: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
18187:
18188: PJI_FM_PLAN_MAINT_PVT.GET_FP_ROW_IDS;
18189:
18190: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.GET_FPR_ROWIDS(p_worker_id);');
18186: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
18187:
18188: PJI_FM_PLAN_MAINT_PVT.GET_FP_ROW_IDS;
18189:
18190: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.GET_FPR_ROWIDS(p_worker_id);');
18191:
18192: commit;
18193:
18194: end GET_FPR_ROWIDS;
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;
18224:
18225: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
18224:
18225: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
18226:
18227: PJI_FM_PLAN_MAINT_PVT.UPDATE_FP_ROWS;
18228:
18229: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_FPR_ROWS(p_worker_id);');
18225: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
18226:
18227: PJI_FM_PLAN_MAINT_PVT.UPDATE_FP_ROWS;
18228:
18229: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_FPR_ROWS(p_worker_id);');
18230:
18231: commit;
18232:
18233: end UPDATE_FPR_ROWS;
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;
18263:
18264: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
18263:
18264: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
18265:
18266: PJI_FM_PLAN_MAINT_PVT.INSERT_FP_ROWS;
18267:
18268: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.INSERT_FPR_ROWS(p_worker_id);');
18264: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
18265:
18266: PJI_FM_PLAN_MAINT_PVT.INSERT_FP_ROWS;
18267:
18268: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.INSERT_FPR_ROWS(p_worker_id);');
18269:
18270: commit;
18271:
18272: end INSERT_FPR_ROWS;
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;
18302:
18303: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
18302:
18303: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
18304:
18305: -- PJI_FM_PLAN_MAINT_PVT.CLEANUP_FP_RMAP_FPR;
18306:
18307: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CLEANUP_FPR_ROWID_TABLE(p_worker_id);');
18303: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
18304:
18305: -- PJI_FM_PLAN_MAINT_PVT.CLEANUP_FP_RMAP_FPR;
18306:
18307: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CLEANUP_FPR_ROWID_TABLE(p_worker_id);');
18308:
18309: commit;
18310:
18311: end CLEANUP_FPR_ROWID_TABLE;
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;
18339:
18340: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
18339:
18340: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
18341:
18342: if (l_extraction_type = 'INCREMENTAL' or
18343: l_extraction_type = 'PARTIAL' or
18344: l_extraction_type = 'RBS') then
18346: PJI_FM_PLAN_MAINT_PVT.GET_AC_ROW_IDS;
18347:
18348: end if;
18349:
18350: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.GET_ACR_ROWIDS(p_worker_id);');
18351:
18352: commit;
18353:
18354: end GET_ACR_ROWIDS;
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;
18382:
18383: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
18382:
18383: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
18384:
18385: if (l_extraction_type = 'INCREMENTAL' or
18386: l_extraction_type = 'PARTIAL' or
18387: l_extraction_type = 'RBS') then
18389: PJI_FM_PLAN_MAINT_PVT.UPDATE_AC_ROWS;
18390:
18391: end if;
18392:
18393: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_ACR_ROWS(p_worker_id);');
18394:
18395: commit;
18396:
18397: end UPDATE_ACR_ROWS;
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;
18425:
18426: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
18425:
18426: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
18427:
18428: if (l_extraction_type = 'FULL') then
18429:
18430: PJI_FM_PLAN_MAINT_PVT.INSERT_INTO_AC_FACT;
18436: PJI_FM_PLAN_MAINT_PVT.INSERT_AC_ROWS;
18437:
18438: end if;
18439:
18440: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.INSERT_ACR_ROWS(p_worker_id);');
18441:
18442: commit;
18443:
18444: end INSERT_ACR_ROWS;
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;
18472:
18473: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
18472:
18473: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
18474:
18475: -- if (l_extraction_type = 'INCREMENTAL' or
18476: -- l_extraction_type = 'PARTIAL' or
18477: -- l_extraction_type = 'RBS') then
18479: -- PJI_FM_PLAN_MAINT_PVT.CLEANUP_AC_RMAP_FPR;
18480: --
18481: -- end if;
18482:
18483: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CLEANUP_ACR_ROWID_TABLE(p_worker_id);');
18484:
18485: commit;
18486:
18487: end CLEANUP_ACR_ROWID_TABLE;
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;
18528:
18529: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
18528:
18529: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
18530:
18531: l_count := 0;
18532:
18533: if (l_extraction_type = 'INCREMENTAL') then
18831: -- where map.WORKER_ID = p_worker_id);
18832:
18833: end if; -- Uncommented for bug 14571067
18834:
18835: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_XBS_DENORM(p_worker_id);');
18836:
18837: commit;
18838:
18839: else -- online mode
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;
19016:
19017: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
19016:
19017: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
19018:
19019: if (nvl(l_fpm_upgrade, 'P') <> 'C' and
19020: l_extraction_type = 'FULL') then
19021:
19221: den.STRUCT_VERSION_ID = log.EVENT_OBJECT;
19222:
19223: end if;
19224:
19225: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_RBS_DENORM(p_worker_id);');
19226:
19227: commit;
19228:
19229: else -- online mode
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;
19347:
19348: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
19347:
19348: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
19349:
19350: begin
19351: PJI_FM_XBS_ACCUM_MAINT.PROCESS_PENDING_EVENTS(l_return_status,
19352: l_msg_data);
19353: exception when others then
19354: PJI_UTILS.WRITE2LOG('PROCESS_PENDING_EVENTS:' || SQLERRM);
19355: end;
19356:
19357: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PROCESS_PENDING_EVENTS(p_worker_id);');
19358:
19359: commit;
19360:
19361: end PROCESS_PENDING_EVENTS;
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;
19390: end if;
19391:
19392: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
19390: end if;
19391:
19392: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
19393:
19394: PJI_FM_PLAN_MAINT_PVT.PROCESS_PENDING_PLAN_UPDATES(l_extraction_type,
19395: l_return_status,
19396: l_msg_data);
19403: ,p_percent => 10);
19404:
19405: END IF; /* Added for bug 13897252 ends */
19406:
19407: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PROCESS_PENDING_PLAN_UPDATES(p_worker_id);');
19408:
19409: commit;
19410:
19411: end PROCESS_PENDING_PLAN_UPDATES;
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;
19458: end if;
19459:
19460: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
19458: end if;
19459:
19460: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
19461:
19462: -- Incr-Incr, Full-Initial, rbs-full, pr-full.
19463: SELECT DECODE(l_extraction_type, 'INCREMENTAL', 'INCREMENTAL', 'FULL', 'INITIAL', 'FULL')
19464: INTO l_extraction_type_wp
19557: END IF;
19558:
19559: -- PA_ppr_rollup_PVT.CREATE_CBS_SLICE (p_worker_id, l_extraction_type ); -- This call is not needed since CBS version will not be frozen
19560:
19561: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.GET_PLANRES_ACTUALS(p_worker_id);');
19562:
19563: commit;
19564:
19565: end GET_PLANRES_ACTUALS;
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;
19618:
19619: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
19618:
19619: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
19620:
19621: if (l_extraction_type = 'FULL' or
19622: l_extraction_type = 'INCREMENTAL') then
19623:
19665: end if;
19666:
19667: end if;
19668:
19669: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.GET_TASK_ROLLUP_ACTUALS(p_worker_id);');
19670:
19671: commit;
19672:
19673: end GET_TASK_ROLLUP_ACTUALS;
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;
19702:
19703: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
19702:
19703: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
19704:
19705: update PJI_PJP_WBS_HEADER
19706: set LOCK_FLAG = null
19707: where LOCK_FLAG is not null
19725:
19726: -- Pji_Fm_Plan_Maint_Pvt.MARK_EXTRACTED_PLANS('SEC');
19727: -- Back to CREATE_SECONDARY_PVT due to issue 5155692
19728:
19729: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UNLOCK_ALL_HEADERS(p_worker_id);');
19730:
19731: commit;
19732:
19733: end UNLOCK_ALL_HEADERS;
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;
19761:
19762: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
19761:
19762: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
19763:
19764: PJI_FM_PLAN_MAINT_PVT.EXTRACT_FIN_PLAN_VERS_BULK(p_slice_type => 'PRI');
19765:
19766: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.EXTRACT_FIN_PLAN_VERS_BULK(p_worker_id);');
19762: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
19763:
19764: PJI_FM_PLAN_MAINT_PVT.EXTRACT_FIN_PLAN_VERS_BULK(p_slice_type => 'PRI');
19765:
19766: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.EXTRACT_FIN_PLAN_VERS_BULK(p_worker_id);');
19767:
19768: commit;
19769:
19770: end EXTRACT_FIN_PLAN_VERS_BULK;
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;
19798:
19799: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
19798:
19799: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
19800:
19801: PJI_FM_PLAN_MAINT_PVT.POPULATE_WBS_HDR;
19802:
19803: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_WBS_HDR(p_worker_id);');
19799: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
19800:
19801: PJI_FM_PLAN_MAINT_PVT.POPULATE_WBS_HDR;
19802:
19803: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_WBS_HDR(p_worker_id);');
19804:
19805: commit;
19806:
19807: end POPULATE_WBS_HDR;
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;
19835:
19836: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
19835:
19836: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
19837:
19838: -- PJI_FM_PLAN_MAINT_PVT.UPDATE_WBS_HDR;
19839: PJI_FM_PLAN_MAINT_PVT.UPDATE_WBS_HDR(p_worker_id);
19840:
19837:
19838: -- PJI_FM_PLAN_MAINT_PVT.UPDATE_WBS_HDR;
19839: PJI_FM_PLAN_MAINT_PVT.UPDATE_WBS_HDR(p_worker_id);
19840:
19841: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_WBS_HDR(p_worker_id);');
19842:
19843: commit;
19844:
19845: end UPDATE_WBS_HDR;
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;
19873:
19874: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
19873:
19874: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
19875:
19876: PJI_FM_PLAN_MAINT_PVT.POPULATE_RBS_HDR;
19877:
19878: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_RBS_HDR(p_worker_id);');
19874: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
19875:
19876: PJI_FM_PLAN_MAINT_PVT.POPULATE_RBS_HDR;
19877:
19878: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_RBS_HDR(p_worker_id);');
19879:
19880: commit;
19881:
19882: end POPULATE_RBS_HDR;
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;
19910:
19911: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
19910:
19911: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
19912:
19913: PJI_FM_PLAN_MAINT_PVT.EXTRACT_PLAN_AMOUNTS_PRIRBS;
19914:
19915: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.EXTRACT_PLAN_AMOUNTS_PRIRBS(p_worker_id);');
19911: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
19912:
19913: PJI_FM_PLAN_MAINT_PVT.EXTRACT_PLAN_AMOUNTS_PRIRBS;
19914:
19915: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.EXTRACT_PLAN_AMOUNTS_PRIRBS(p_worker_id);');
19916:
19917: commit;
19918:
19919: end EXTRACT_PLAN_AMOUNTS_PRIRBS;
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;
19947:
19948: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
19947:
19948: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
19949:
19950: PJI_FM_PLAN_MAINT_PVT.ROLLUP_FPR_RBS_T_SLICE;
19951:
19952: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_T_SLICE(p_worker_id);');
19948: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
19949:
19950: PJI_FM_PLAN_MAINT_PVT.ROLLUP_FPR_RBS_T_SLICE;
19951:
19952: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_T_SLICE(p_worker_id);');
19953:
19954: commit;
19955:
19956: end ROLLUP_FPR_RBS_T_SLICE;
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;
19984:
19985: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
19984:
19985: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
19986:
19987: PJI_FM_PLAN_CAL_RLPS.CREATE_FP_PA_PRI_ROLLUP;
19988:
19989: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_FP_PA_PRI_ROLLUP(p_worker_id);');
19985: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
19986:
19987: PJI_FM_PLAN_CAL_RLPS.CREATE_FP_PA_PRI_ROLLUP;
19988:
19989: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_FP_PA_PRI_ROLLUP(p_worker_id);');
19990:
19991: commit;
19992:
19993: end CREATE_FP_PA_PRI_ROLLUP;
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;
20021:
20022: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
20021:
20022: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
20023:
20024: PJI_FM_PLAN_CAL_RLPS.CREATE_FP_GL_PRI_ROLLUP;
20025:
20026: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_FP_GL_PRI_ROLLUP(p_worker_id);');
20022: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
20023:
20024: PJI_FM_PLAN_CAL_RLPS.CREATE_FP_GL_PRI_ROLLUP;
20025:
20026: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_FP_GL_PRI_ROLLUP(p_worker_id);');
20027:
20028: commit;
20029:
20030: end CREATE_FP_GL_PRI_ROLLUP;
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;
20058:
20059: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
20058:
20059: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
20060:
20061: PJI_FM_PLAN_CAL_RLPS.CREATE_FP_ALL_T_PRI_ROLLUP('G');
20062:
20063: PJI_FM_PLAN_CAL_RLPS.CREATE_FP_ALL_T_PRI_ROLLUP('P');
20061: PJI_FM_PLAN_CAL_RLPS.CREATE_FP_ALL_T_PRI_ROLLUP('G');
20062:
20063: PJI_FM_PLAN_CAL_RLPS.CREATE_FP_ALL_T_PRI_ROLLUP('P');
20064:
20065: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_FP_ALL_PRI_ROLLUP(p_worker_id);');
20066:
20067: commit;
20068:
20069: end CREATE_FP_ALL_PRI_ROLLUP;
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;
20097:
20098: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
20097:
20098: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
20099:
20100: PJI_FM_PLAN_MAINT_PVT.INSERT_INTO_FP_FACT;
20101:
20102: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.INSERT_INTO_FP_FACT(p_worker_id);');
20098: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
20099:
20100: PJI_FM_PLAN_MAINT_PVT.INSERT_INTO_FP_FACT;
20101:
20102: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.INSERT_INTO_FP_FACT(p_worker_id);');
20103:
20104: commit;
20105:
20106: end INSERT_INTO_FP_FACT;
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;
20134:
20135: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
20134:
20135: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
20136:
20137: PJI_FM_PLAN_MAINT_PVT.MARK_EXTRACTED_PLANS('PRI');
20138:
20139: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.MARK_EXTRACTED_PLANS(p_worker_id);');
20135: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
20136:
20137: PJI_FM_PLAN_MAINT_PVT.MARK_EXTRACTED_PLANS('PRI');
20138:
20139: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.MARK_EXTRACTED_PLANS(p_worker_id);');
20140:
20141: commit;
20142:
20143: end MARK_EXTRACTED_PLANS;
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;
20162:
20163: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
20162:
20163: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
20164: -- Extraction type is not needed for this step.
20165: -- Retaining it to maintain coding style as well as for potential future use.
20166:
20167: PJI_FM_XBS_ACCUM_UTILS.REMAP_RBS_TXN_ACCUM_HDRS (
20168: x_return_status => l_return_status
20169: ,x_msg_data => l_msg_data
20170: ,x_msg_count => l_msg_count );
20171:
20172: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.REMAP_RBS_TXN_ACCUM_HDRS(p_worker_id);');
20173:
20174: commit;
20175:
20176: end REMAP_RBS_TXN_ACCUM_HDRS ;
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;
20195:
20196: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
20195:
20196: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
20197: -- Extraction type is not needed for this step.
20198: -- Retaining it to maintain coding style as well as for potential future use.
20199:
20200: PJI_FM_PLAN_MAINT_PVT.RETRIEVE_OVERRIDDEN_WP_ETC;
20198: -- Retaining it to maintain coding style as well as for potential future use.
20199:
20200: PJI_FM_PLAN_MAINT_PVT.RETRIEVE_OVERRIDDEN_WP_ETC;
20201:
20202: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.RETRIEVE_OVERRIDDEN_WP_ETC(p_worker_id);');
20203:
20204: commit;
20205:
20206: end RETRIEVE_OVERRIDDEN_WP_ETC ;
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;
20225:
20226: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
20225:
20226: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
20227: -- Extraction type is not needed for this step.
20228: -- Retaining it to maintain coding style as well as for potential future use.
20229:
20230: PJI_FM_PLAN_MAINT_PVT.EXTRACT_PLAN_ETC_PRIRBS(p_slice_type => 'SEC');
20228: -- Retaining it to maintain coding style as well as for potential future use.
20229:
20230: PJI_FM_PLAN_MAINT_PVT.EXTRACT_PLAN_ETC_PRIRBS(p_slice_type => 'SEC');
20231:
20232: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.EXTRACT_PLAN_ETC_PRIRBS(p_worker_id);');
20233:
20234: commit;
20235:
20236: end EXTRACT_PLAN_ETC_PRIRBS ;
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;
20289: end if;
20290: 5755229 */
20291:
20295: FOR i IN 1..100 LOOP
20296: l_ctr := i;
20297: begin
20298: if l_tab1 = 'N' then
20299: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
20300: 'PJI_PJP_RMAP_FPR',
20301: 'PARTITION',
20302: 'P' || p_worker_id);
20303: l_tab1 := 'Y';
20302: 'P' || p_worker_id);
20303: l_tab1 := 'Y';
20304: end if;
20305: if l_tab2 = 'N' then
20306: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
20307: 'PJI_PJP_RMAP_ACR',
20308: 'PARTITION',
20309: 'P' || p_worker_id);
20310: l_tab2 := 'Y';
20309: 'P' || p_worker_id);
20310: l_tab2 := 'Y';
20311: end if;
20312: if l_tab3 = 'N' then
20313: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
20314: 'PJI_FP_AGGR_PJP0',
20315: 'PARTITION',
20316: 'P' || p_worker_id);
20317: l_tab3 := 'Y';
20316: 'P' || p_worker_id);
20317: l_tab3 := 'Y';
20318: end if;
20319: if l_tab4 = 'N' then
20320: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
20321: 'PJI_AC_AGGR_PJP0',
20322: 'PARTITION',
20323: 'P' || p_worker_id);
20324: l_tab4 := 'Y';
20323: 'P' || p_worker_id);
20324: l_tab4 := 'Y';
20325: end if;
20326: if l_tab5 = 'N' then
20327: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
20328: 'PJI_FP_CUST_PJP0',
20329: 'PARTITION',
20330: 'P' || p_worker_id);
20331: l_tab5 := 'Y';
20330: 'P' || p_worker_id);
20331: l_tab5 := 'Y';
20332: end if;
20333: if l_tab6 = 'N' then
20334: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
20335: 'PJI_AC_CUST_PJP0',
20336: 'PARTITION',
20337: 'P' || p_worker_id);
20338: l_tab6 := 'Y';
20337: 'P' || p_worker_id);
20338: l_tab6 := 'Y';
20339: end if;
20340: if l_tab7 = 'N' then
20341: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
20342: 'PJI_FM_EXTR_PLNVER4',
20343: 'PARTITION',
20344: 'P' || p_worker_id);
20345: l_tab7 := 'Y';
20344: 'P' || p_worker_id);
20345: l_tab7 := 'Y';
20346: end if;
20347: if l_tab8 = 'N' then
20348: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
20349: 'PJI_FP_AGGR_PJP1',
20350: 'PARTITION',
20351: 'P' || p_worker_id);
20352: l_tab8 := 'Y';
20351: 'P' || p_worker_id);
20352: l_tab8 := 'Y';
20353: end if;
20354: if l_tab9 = 'N' then
20355: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
20356: 'PJI_AC_AGGR_PJP1',
20357: 'PARTITION',
20358: 'P' || p_worker_id);
20359: l_tab9 := 'Y';
20358: 'P' || p_worker_id);
20359: l_tab9 := 'Y';
20360: end if;
20361: if l_tab10 = 'N' then
20362: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
20363: 'PJI_FP_AGGR_XBS',
20364: 'PARTITION',
20365: 'P' || p_worker_id);
20366: l_tab10 := 'Y';
20365: 'P' || p_worker_id);
20366: l_tab10 := 'Y';
20367: end if;
20368: if l_tab11 = 'N' then
20369: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
20370: 'PJI_FP_AGGR_RBS',
20371: 'PARTITION',
20372: 'P' || p_worker_id);
20373: l_tab11 := 'Y';
20372: 'P' || p_worker_id);
20373: l_tab11 := 'Y';
20374: end if;
20375: if l_tab12 = 'N' then
20376: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
20377: 'PJI_XBS_DENORM_DELTA',
20378: 'PARTITION',
20379: 'P' || p_worker_id);
20380: l_tab12 := 'Y';
20379: 'P' || p_worker_id);
20380: l_tab12 := 'Y';
20381: end if;
20382: if l_tab13 = 'N' then
20383: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
20384: 'PJI_RBS_DENORM_DELTA',
20385: 'PARTITION',
20386: 'P' || p_worker_id);
20387: l_tab13 := 'Y';
20386: 'P' || p_worker_id);
20387: l_tab13 := 'Y';
20388: end if;
20389: if l_tab14 = 'N' then
20390: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
20391: 'PJI_FP_RMAP_FPR',
20392: 'PARTITION',
20393: 'P' || p_worker_id);
20394: l_tab14 := 'Y';
20393: 'P' || p_worker_id);
20394: l_tab14 := 'Y';
20395: end if;
20396: if l_tab15 = 'N' then
20397: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
20398: 'PJI_AC_RMAP_ACR',
20399: 'PARTITION',
20400: 'P' || p_worker_id);
20401: l_tab15 := 'Y';
20400: 'P' || p_worker_id);
20401: l_tab15 := 'Y';
20402: end if;
20403: if l_tab16 = 'N' then
20404: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
20405: 'PJI_PA_PROJ_EVENTS_LOG',
20406: 'PARTITION',
20407: 'P' || p_worker_id);
20408: l_tab16 := 'Y';
20418: l_tab17 := 'Y';
20419: end if;
20420: /* Added for bug 13897252 starts */
20421: if l_tab18 = 'N' then
20422: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
20423: 'PJI_FP_AGGR_PJP2',
20424: 'PARTITION',
20425: 'P' || p_worker_id);
20426: l_tab18 := 'Y';
20425: 'P' || p_worker_id);
20426: l_tab18 := 'Y';
20427: end if;
20428: if l_tab19 = 'N' then
20429: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
20430: 'PJI_MERGE_HELPER',
20431: 'NORMAL',
20432: null);
20433: l_tab19 := 'Y';
20448: /* Added for bug 9736812 */
20449: /* execute immediate 'alter index '||l_schema||'.'||'PJI_FP_AGGR_PJP1_N1 rebuild'; */ /* commented for bug#11789673 */
20450: /* Added for bug 9736812 */
20451:
20452: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CLEANUP(p_worker_id);'); -- Bug#5171542
20453: -- commented below bcoz the global index is modified to local for bug15983044
20454: -- execute immediate 'alter index '||l_schema||'.'||'PJI_PA_PROJ_EVENTS_LOG_N1 rebuild'; /* Added for bug 9840828 */
20455: commit;
20456:
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;
20485:
20486: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
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;
20485:
20486: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
20487:
20488: PJI_FM_PLAN_MAINT_PVT.MERGE_INTO_FP_FACTS;
20489:
20490: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.MERGE_INTO_FP_FACT(p_worker_id);');
20486: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
20487:
20488: PJI_FM_PLAN_MAINT_PVT.MERGE_INTO_FP_FACTS;
20489:
20490: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.MERGE_INTO_FP_FACT(p_worker_id);');
20491:
20492: commit;
20493:
20494: end MERGE_INTO_FP_FACTS;