DBA Data[Home] [Help]

APPS.PJI_PJP_SUM_MAIN dependencies on PJI_PJP_SUM_MAIN

Line 1: package body PJI_PJP_SUM_MAIN as

1: package body PJI_PJP_SUM_MAIN as
2: /* $Header: PJISP01B.pls 120.51.12020000.3 2013/04/12 02:13:17 sachandr ship $ */
3:
4:
5: -- -----------------------------------------------------

Line 107: If PJI_PJP_SUM_MAIN.WORKER_STATUS(p_worker_id, 'RUNNING') then

103:
104: l_e_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
105: (l_e_process, 'EXTRACTION_TYPE');
106:
107: If PJI_PJP_SUM_MAIN.WORKER_STATUS(p_worker_id, 'RUNNING') then
108:
109: -- Means its already running so get the request id and wait to complete that request
110:
111: select PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_e_process,l_e_process),

Line 438: for x in 1 .. PJI_PJP_SUM_MAIN.g_parallel_processes loop

434: l_no_selection := FND_MESSAGE.GET;
435:
436: l_header_flag := 'Y';
437:
438: for x in 1 .. PJI_PJP_SUM_MAIN.g_parallel_processes loop
439:
440: l_process := PJI_PJP_SUM_MAIN.g_process || x;
441:
442: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 440: l_process := PJI_PJP_SUM_MAIN.g_process || x;

436: l_header_flag := 'Y';
437:
438: for x in 1 .. PJI_PJP_SUM_MAIN.g_parallel_processes loop
439:
440: l_process := PJI_PJP_SUM_MAIN.g_process || x;
441:
442: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
443: (l_process, 'EXTRACTION_TYPE');
444:

Line 446: not PJI_PJP_SUM_MAIN.WORKER_STATUS(x, 'RUNNING')) then

442: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
443: (l_process, 'EXTRACTION_TYPE');
444:
445: if (l_extraction_type is not null and
446: not PJI_PJP_SUM_MAIN.WORKER_STATUS(x, 'RUNNING')) then
447:
448: if (l_header_flag = 'Y') then
449:
450: l_header_flag := 'N';

Line 2929: while l_worker_id < PJI_PJP_SUM_MAIN.g_parallel_processes loop

2925: l_incomplete_partial_count := 0;
2926: l_failed_process_count := 0;
2927: l_existing_worker := 'N'; -- To check the resubmit of failed run Bug 5057835
2928:
2929: while l_worker_id < PJI_PJP_SUM_MAIN.g_parallel_processes loop
2930:
2931: l_worker_id := l_worker_id + 1;
2932:
2933: l_process := g_process || l_worker_id;

Line 2944: elsif (not PJI_PJP_SUM_MAIN.WORKER_STATUS(l_worker_id, 'RUNNING') and

2940: if (p_worker_id = 0) then
2941: p_worker_id := l_worker_id;
2942: end if;
2943:
2944: elsif (not PJI_PJP_SUM_MAIN.WORKER_STATUS(l_worker_id, 'RUNNING') and
2945: ((l_extraction_type = 'FULL' and
2946: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
2947: (l_process, 'EXTRACTION_TYPE') = 'FULL') or
2948: (l_extraction_type = 'INCREMENTAL' and

Line 3007: elsif (not PJI_PJP_SUM_MAIN.WORKER_STATUS(l_worker_id, 'RUNNING')) then

3003: l_type := 2;
3004: l_failed_process_count := l_failed_process_count + 1;
3005: end if;
3006:
3007: elsif (not PJI_PJP_SUM_MAIN.WORKER_STATUS(l_worker_id, 'RUNNING')) then
3008:
3009: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process,
3010: 'EXTRACTION_TYPE')
3011: = 'PARTIAL') then

Line 3089: (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_MAIN.INIT_PROCESS(p_worker_id, p_run_mode);')) then

3085: dual;
3086:
3087: -- If this is the resubmit of already existing failed run then Bug 5057835
3088: if l_existing_worker = 'Y' and
3089: (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_MAIN.INIT_PROCESS(p_worker_id, p_run_mode);')) then
3090: commit; -- To release lock/ stamp parameters / config hist
3091: return;
3092: end if;
3093:

Line 3606: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_MAIN.INIT_PROCESS(p_worker_id, p_run_mode);')) then

3602:
3603: PJI_PROCESS_UTIL.ADD_STEPS(l_process, 'PJI_PJP', l_extraction_type);
3604:
3605:
3606: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_MAIN.INIT_PROCESS(p_worker_id, p_run_mode);')) then
3607: rollback to no_need_to_run_step;
3608: Commit; -- To release lock/ stamp parameters / config hist
3609: return;
3610: end if;

Line 3867: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_MAIN.INIT_PROCESS(p_worker_id, p_run_mode);');

3863:
3864: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER
3865: (l_process, 'PROGRAM_EXISTS', l_prg_exists);
3866:
3867: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_MAIN.INIT_PROCESS(p_worker_id, p_run_mode);');
3868:
3869: commit;
3870:
3871: end INIT_PROCESS;

Line 3891: l_process := PJI_PJP_SUM_MAIN.g_process || p_worker_id;

3887: l_profile_check varchar2(30); /* Added for Bug 8708651 */
3888:
3889: begin
3890:
3891: l_process := PJI_PJP_SUM_MAIN.g_process || p_worker_id;
3892:
3893: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_MAIN.RUN_PROCESS(p_worker_id);')) then
3894: return;
3895: end if;

Line 3893: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_MAIN.RUN_PROCESS(p_worker_id);')) then

3889: begin
3890:
3891: l_process := PJI_PJP_SUM_MAIN.g_process || p_worker_id;
3892:
3893: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_MAIN.RUN_PROCESS(p_worker_id);')) then
3894: return;
3895: end if;
3896:
3897: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 4055: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_MAIN.RUN_PROCESS(p_worker_id);');

4051: -- (l_process, 'TO_PROJECT_ID') = -1) then
4052: -- PJI_PJP_EXTRACTION_UTILS.ANALYZE_PJP_FACTS;
4053: -- end if;
4054:
4055: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_MAIN.RUN_PROCESS(p_worker_id);');
4056:
4057: commit;
4058:
4059: end RUN_PROCESS;

Line 4092: l_process := PJI_PJP_SUM_MAIN.g_process || p_worker_id;

4088: l_project_status varchar2(30); --12.1.3 enhancement
4089:
4090: begin
4091:
4092: l_process := PJI_PJP_SUM_MAIN.g_process || p_worker_id;
4093:
4094: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_MAIN.WRAPUP_PROCESS(p_worker_id);')) then
4095: return;
4096: end if;

Line 4094: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_MAIN.WRAPUP_PROCESS(p_worker_id);')) then

4090: begin
4091:
4092: l_process := PJI_PJP_SUM_MAIN.g_process || p_worker_id;
4093:
4094: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_MAIN.WRAPUP_PROCESS(p_worker_id);')) then
4095: return;
4096: end if;
4097: -- Changes for bug 6266824
4098: /* Commented for bug 6266824

Line 4237: to_char(sysdate, PJI_PJP_SUM_MAIN.g_date_mask));

4233:
4234: -- update default report as-of date
4235:
4236: PJI_UTILS.SET_PARAMETER('LAST_PJP_EXTR_DATE_' || l_process,
4237: to_char(sysdate, PJI_PJP_SUM_MAIN.g_date_mask));
4238:
4239: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_MAIN.WRAPUP_PROCESS(p_worker_id);');
4240:
4241: if (l_preload = 'Y') then

Line 4239: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_MAIN.WRAPUP_PROCESS(p_worker_id);');

4235:
4236: PJI_UTILS.SET_PARAMETER('LAST_PJP_EXTR_DATE_' || l_process,
4237: to_char(sysdate, PJI_PJP_SUM_MAIN.g_date_mask));
4238:
4239: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_MAIN.WRAPUP_PROCESS(p_worker_id);');
4240:
4241: if (l_preload = 'Y') then
4242:
4243: INIT_PROCESS(l_worker_id,

Line 4438: end PJI_PJP_SUM_MAIN;

4434: END IF;
4435:
4436: end SUMMARIZE;
4437:
4438: end PJI_PJP_SUM_MAIN;