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.38.12010000.2 2008/12/11 09:30:29 vgovvala 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 415: for x in 1 .. PJI_PJP_SUM_MAIN.g_parallel_processes loop

411: l_no_selection := FND_MESSAGE.GET;
412:
413: l_header_flag := 'Y';
414:
415: for x in 1 .. PJI_PJP_SUM_MAIN.g_parallel_processes loop
416:
417: l_process := PJI_PJP_SUM_MAIN.g_process || x;
418:
419: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

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

413: l_header_flag := 'Y';
414:
415: for x in 1 .. PJI_PJP_SUM_MAIN.g_parallel_processes loop
416:
417: l_process := PJI_PJP_SUM_MAIN.g_process || x;
418:
419: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
420: (l_process, 'EXTRACTION_TYPE');
421:

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

419: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
420: (l_process, 'EXTRACTION_TYPE');
421:
422: if (l_extraction_type is not null and
423: not PJI_PJP_SUM_MAIN.WORKER_STATUS(x, 'RUNNING')) then
424:
425: if (l_header_flag = 'Y') then
426:
427: l_header_flag := 'N';

Line 2858: while l_worker_id < PJI_PJP_SUM_MAIN.g_parallel_processes loop

2854: l_incomplete_partial_count := 0;
2855: l_failed_process_count := 0;
2856: l_existing_worker := 'N'; -- To check the resubmit of failed run Bug 5057835
2857:
2858: while l_worker_id < PJI_PJP_SUM_MAIN.g_parallel_processes loop
2859:
2860: l_worker_id := l_worker_id + 1;
2861:
2862: l_process := g_process || l_worker_id;

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

2869: if (p_worker_id = 0) then
2870: p_worker_id := l_worker_id;
2871: end if;
2872:
2873: elsif (not PJI_PJP_SUM_MAIN.WORKER_STATUS(l_worker_id, 'RUNNING') and
2874: ((l_extraction_type = 'FULL' and
2875: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
2876: (l_process, 'EXTRACTION_TYPE') = 'FULL') or
2877: (l_extraction_type = 'INCREMENTAL' and

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

2928: l_type := 2;
2929: l_failed_process_count := l_failed_process_count + 1;
2930: end if;
2931:
2932: elsif (not PJI_PJP_SUM_MAIN.WORKER_STATUS(l_worker_id, 'RUNNING')) then
2933:
2934: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process,
2935: 'EXTRACTION_TYPE')
2936: = 'PARTIAL') then

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

3008: dual;
3009:
3010: -- If this is the resubmit of already existing failed run then Bug 5057835
3011: if l_existing_worker = 'Y' and
3012: (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_MAIN.INIT_PROCESS(p_worker_id, p_run_mode);')) then
3013: commit; -- To release lock/ stamp parameters / config hist
3014: return;
3015: end if;
3016:

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

3406:
3407: PJI_PROCESS_UTIL.ADD_STEPS(l_process, 'PJI_PJP', l_extraction_type);
3408:
3409:
3410: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_MAIN.INIT_PROCESS(p_worker_id, p_run_mode);')) then
3411: rollback to no_need_to_run_step;
3412: Commit; -- To release lock/ stamp parameters / config hist
3413: return;
3414: end if;

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

3661:
3662: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER
3663: (l_process, 'PROGRAM_EXISTS', l_prg_exists);
3664:
3665: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_MAIN.INIT_PROCESS(p_worker_id, p_run_mode);');
3666:
3667: commit;
3668:
3669: end INIT_PROCESS;

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

3684: l_extraction_type varchar2(30);
3685:
3686: begin
3687:
3688: l_process := PJI_PJP_SUM_MAIN.g_process || p_worker_id;
3689:
3690: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_MAIN.RUN_PROCESS(p_worker_id);')) then
3691: return;
3692: end if;

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

3686: begin
3687:
3688: l_process := PJI_PJP_SUM_MAIN.g_process || p_worker_id;
3689:
3690: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_MAIN.RUN_PROCESS(p_worker_id);')) then
3691: return;
3692: end if;
3693:
3694: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

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

3823: -- (l_process, 'TO_PROJECT_ID') = -1) then
3824: -- PJI_PJP_EXTRACTION_UTILS.ANALYZE_PJP_FACTS;
3825: -- end if;
3826:
3827: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_MAIN.RUN_PROCESS(p_worker_id);');
3828:
3829: commit;
3830:
3831: end RUN_PROCESS;

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

3859: l_to_project pa_projects_all.segment1%TYPE;
3860:
3861: begin
3862:
3863: l_process := PJI_PJP_SUM_MAIN.g_process || p_worker_id;
3864:
3865: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_MAIN.WRAPUP_PROCESS(p_worker_id);')) then
3866: return;
3867: end if;

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

3861: begin
3862:
3863: l_process := PJI_PJP_SUM_MAIN.g_process || p_worker_id;
3864:
3865: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_MAIN.WRAPUP_PROCESS(p_worker_id);')) then
3866: return;
3867: end if;
3868: -- Changes for bug 6266824
3869: /* Commented for bug 6266824

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

3995:
3996: -- update default report as-of date
3997:
3998: PJI_UTILS.SET_PARAMETER('LAST_PJP_EXTR_DATE_' || l_process,
3999: to_char(sysdate, PJI_PJP_SUM_MAIN.g_date_mask));
4000:
4001: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_MAIN.WRAPUP_PROCESS(p_worker_id);');
4002:
4003: if (l_preload = 'Y') then

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

3997:
3998: PJI_UTILS.SET_PARAMETER('LAST_PJP_EXTR_DATE_' || l_process,
3999: to_char(sysdate, PJI_PJP_SUM_MAIN.g_date_mask));
4000:
4001: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_MAIN.WRAPUP_PROCESS(p_worker_id);');
4002:
4003: if (l_preload = 'Y') then
4004:
4005: INIT_PROCESS(l_worker_id,

Line 4194: end PJI_PJP_SUM_MAIN;

4190: END IF;
4191:
4192: end SUMMARIZE;
4193:
4194: end PJI_PJP_SUM_MAIN;