DBA Data[Home] [Help]

APPS.PJI_PJP_PRG_PERF_ALL dependencies on PJI_PROCESS_UTIL

Line 572: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process,'EXTRACTION_TYPE');

568: g_worker_id := PJI_PJP_FP_CURR_WRAP.GET_WORKER_ID;
569:
570: /* Added for Bug 13813361 Start */
571: l_process := PJI_PJP_SUM_MAIN.G_PROCESS || to_char(g_worker_id);
572: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process,'EXTRACTION_TYPE');
573: l_pji_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
574:
575: IF (nvl(l_extraction_type,'N') = 'FULL' and PJI_UTILS.GET_PARAMETER('PJI_FPM_UPGRADE') <> 'C') THEN
576:

Line 4531: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(PJI_UTILS.GET_PJI_SCHEMA_NAME, 'PJI_MERGE_HELPER','NORMAL','P'||g_worker_id);

4527: p_percent => 10);
4528:
4529: IF UPPER(FND_PROFILE.VALUE('PJI_SUM_CLEANALL')) = 'Y' THEN
4530: /* Clear temporary table */
4531: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(PJI_UTILS.GET_PJI_SCHEMA_NAME, 'PJI_MERGE_HELPER','NORMAL','P'||g_worker_id);
4532:
4533: /* Disable Indexes PJI_FP_XBS_ACCUM_F*/
4534: FOR ind_lp IN (SELECT table_owner||'.'||index_name ind_name
4535: , partitioned

Line 4939: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(PJI_UTILS.GET_PJI_SCHEMA_NAME,

4935: p_tabname => 'PJI_MERGE_HELPER',
4936: p_partname=> NULL,
4937: p_percent => 10);
4938:
4939: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(PJI_UTILS.GET_PJI_SCHEMA_NAME,
4940: 'PJI_FP_AGGR_PJP2',
4941: 'PARTITION',
4942: 'P' || g_worker_id);
4943:

Line 5421: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION('PJI_PJP1', 'PJI_PJP_SUM_ROLLUP.MERGE_INTO_FP_FACT(p_worker_id);');

5417: END IF;
5418:
5419: END IF;
5420:
5421: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION('PJI_PJP1', 'PJI_PJP_SUM_ROLLUP.MERGE_INTO_FP_FACT(p_worker_id);');
5422:
5423: COMMIT;
5424:
5425: EXCEPTION

Line 5499: IF (PJI_PROCESS_UTIL.REQUEST_STATUS('OKAY',

5495:
5496: FOR i IN l_Batch_t.first..l_Batch_t.last LOOP
5497:
5498: IF (l_Batch_t(i).request_id > 0 ) THEN
5499: IF (PJI_PROCESS_UTIL.REQUEST_STATUS('OKAY',
5500: l_Batch_t(i).request_id,'PJI_MERGE_HELPER')) THEN -- Modified for Bug 13490251
5501: IF (PJI_PROCESS_UTIL.REQUEST_STATUS('RUNNING',
5502: l_Batch_t(i).request_id,'PJI_MERGE_HELPER')) THEN -- Modified for Bug 13490251
5503: l_Batch_t(i).request_status := 'RUNNING';

Line 5501: IF (PJI_PROCESS_UTIL.REQUEST_STATUS('RUNNING',

5497:
5498: IF (l_Batch_t(i).request_id > 0 ) THEN
5499: IF (PJI_PROCESS_UTIL.REQUEST_STATUS('OKAY',
5500: l_Batch_t(i).request_id,'PJI_MERGE_HELPER')) THEN -- Modified for Bug 13490251
5501: IF (PJI_PROCESS_UTIL.REQUEST_STATUS('RUNNING',
5502: l_Batch_t(i).request_id,'PJI_MERGE_HELPER')) THEN -- Modified for Bug 13490251
5503: l_Batch_t(i).request_status := 'RUNNING';
5504: ELSE
5505: l_Batch_t(i).request_status := 'COMPLETED';

Line 5628: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

5624: begin
5625:
5626: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
5627:
5628: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
5629: l_refresh_code := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'REFRESH_CODE'); -- Bug#5099574
5630:
5631: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_FP_CUST_SLICES(p_worker_id);')) then
5632: return;

Line 5629: l_refresh_code := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'REFRESH_CODE'); -- Bug#5099574

5625:
5626: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
5627:
5628: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
5629: l_refresh_code := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'REFRESH_CODE'); -- Bug#5099574
5630:
5631: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_FP_CUST_SLICES(p_worker_id);')) then
5632: return;
5633: end if;

Line 5631: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_FP_CUST_SLICES(p_worker_id);')) then

5627:
5628: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
5629: l_refresh_code := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'REFRESH_CODE'); -- Bug#5099574
5630:
5631: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_FP_CUST_SLICES(p_worker_id);')) then
5632: return;
5633: end if;
5634:
5635: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 5635: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

5631: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_FP_CUST_SLICES(p_worker_id);')) then
5632: return;
5633: end if;
5634:
5635: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
5636: (l_process, 'PLAN_TYPE_ID');
5637:
5638: if (l_plan_type_id = -1) then
5639: l_plan_type_id := null;

Line 6299: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_FP_CUST_SLICES(p_worker_id);');

6295: if ( l_extraction_type = 'PARTIAL' ) then -- Partial Refresh Performance Improvement
6296: delete from PJI_FM_EXTR_PLNVER3_T where worker_id=p_worker_id;
6297: end if;
6298:
6299: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_FP_CUST_SLICES(p_worker_id);');
6300:
6301: commit;
6302:
6303: end AGGREGATE_FP_CUST_SLICES;

Line 6325: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_WBS(p_worker_id);')) then

6321:
6322: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
6323: l_profile_check := FND_PROFILE.VALUE('PJI_SUM_CLEANALL');
6324:
6325: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_WBS(p_worker_id);')) then
6326: return;
6327: else
6328: if (upper(nvl(l_profile_check, 'N')) = 'Y') then
6329:

Line 6345: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

6341:
6342: end if;
6343: end if;
6344:
6345: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
6346: l_fpm_upgrade := nvl(PJI_UTILS.GET_PARAMETER('PJI_FPM_UPGRADE'), 'C');
6347:
6348: if l_fpm_upgrade = 'P' then
6349: execute immediate 'alter session force parallel query';

Line 6379: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(l_process,

6375: den.STRUCT_TYPE = 'PRG' and
6376: den.SUB_LEVEL = den.SUP_LEVEL and
6377: den.SUP_PROJECT_ID = map.PROJECT_ID;
6378:
6379: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(l_process,
6380: 'MAX_PROGRAM_LEVEL',
6381: l_level);
6382:
6383: for x in 1 .. l_level loop

Line 6408: l_max_level := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

6404: end loop;
6405:
6406: end if;
6407:
6408: l_max_level := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
6409: (l_process, 'MAX_PROGRAM_LEVEL');
6410:
6411: select
6412: nvl(to_number(min(STEP_SEQ)), 0)

Line 6436: PJI_PROCESS_UTIL.EXECUTE_ROLLUP_FPR_WBS(p_worker_id,

6432: where PROCESS_NAME = l_process and
6433: STEP_SEQ = l_level_seq;
6434:
6435: /* Call to Paritioned procedure for bug 8416116 */
6436: PJI_PROCESS_UTIL.EXECUTE_ROLLUP_FPR_WBS(p_worker_id,
6437: l_level,
6438: l_partial_mode,
6439: l_fpm_upgrade);
6440:

Line 6468: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_WBS(p_worker_id);');

6464: end if;
6465:
6466: end loop;
6467:
6468: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_WBS(p_worker_id);');
6469:
6470: commit;
6471:
6472: if (upper(nvl(l_profile_check, 'N')) = 'Y') then

Line 6517: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.PURGE_PLAN_DATA(p_worker_id);')) then

6513: end if;
6514:
6515: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
6516:
6517: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.PURGE_PLAN_DATA(p_worker_id);')) then
6518: return;
6519: end if;
6520:
6521: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 6521: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

6517: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.PURGE_PLAN_DATA(p_worker_id);')) then
6518: return;
6519: end if;
6520:
6521: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
6522:
6523: /* Added for bug 13897252 */
6524: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(PJI_UTILS.GET_PJI_SCHEMA_NAME, 'PJI_FP_AGGR_PJP1','NORMAL','P'||g_worker_id);
6525:

Line 6524: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(PJI_UTILS.GET_PJI_SCHEMA_NAME, 'PJI_FP_AGGR_PJP1','NORMAL','P'||g_worker_id);

6520:
6521: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
6522:
6523: /* Added for bug 13897252 */
6524: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(PJI_UTILS.GET_PJI_SCHEMA_NAME, 'PJI_FP_AGGR_PJP1','NORMAL','P'||g_worker_id);
6525:
6526: IF (l_extraction_type IN ('PARTIAL', 'RBS', 'INCREMENTAL', 'FULL')) THEN
6527:
6528: /* Commented for bug 13897252 */

Line 6541: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PURGE_PLAN_DATA(p_worker_id);');

6537: nvl(pjp1.RECORD_TYPE, 'X') <> 'A';
6538:
6539: end if;
6540:
6541: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PURGE_PLAN_DATA(p_worker_id);');
6542:
6543: commit;
6544:
6545: if (upper(nvl(l_profile_check, 'N')) = 'Y') then

Line 21619: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(PJI_UTILS.GET_PJI_SCHEMA_NAME, 'PJI_FP_AGGR_PJP2','NORMAL','P'||g_worker_id);

21615:
21616: begin
21617:
21618: /* Added for bug 13897252 starts */
21619: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(PJI_UTILS.GET_PJI_SCHEMA_NAME, 'PJI_FP_AGGR_PJP2','NORMAL','P'||g_worker_id);
21620:
21621: /* Drop Indexes */
21622: FOR ind_lp IN (SELECT table_owner||'.'||index_name ind_name
21623: , partitioned