DBA Data[Home] [Help]

APPS.PJI_RM_SUM_MAIN dependencies on PJI_PROCESS_UTIL

Line 20: -- The package accesses status tables through API package PJI_PROCESS_UTIL.

16: -- if the process fails it will continue from the same step next time it
17: -- runs. In order to support error recovery we use tables
18: -- PJI_SYSTEM_PROCESS_STATUS and PJI_SYSTEM_PARAMETERS that store current
19: -- process status and process parameters such as batch id being processed.
20: -- The package accesses status tables through API package PJI_PROCESS_UTIL.
21: -- Scope of data extraction is defined by table PJI_ORG_EXTR_STATUS that
22: -- contains list of organizations for which we extract data.
23: -- We have to use persistent table, i.e. we cannot define scope dynamically
24: -- each time we run extraction because Table PJI_ORG_EXTR_STATUS may be

Line 63: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'TRANSITION') is not null) then

59: l_dangling_error varchar2(255) := 'Cannot run a configuration transition when dangling rows exist.';
60:
61: begin
62:
63: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'TRANSITION') is not null) then
64: return;
65: end if;
66:
67: select

Line 130: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process, 'TRANSITION', 'N');

126: commit;
127: dbms_standard.raise_application_error(-20040, l_setup_error);
128: end if;
129:
130: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process, 'TRANSITION', 'N');
131: l_transition_flag := 'N';
132:
133: if (l_settings_proj_perf_flag = 'Y' and l_params_proj_perf_flag = 'N') then
134: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER

Line 134: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER

130: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process, 'TRANSITION', 'N');
131: l_transition_flag := 'N';
132:
133: if (l_settings_proj_perf_flag = 'Y' and l_params_proj_perf_flag = 'N') then
134: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER
135: (g_process, 'TRANSITION', 'Y');
136: l_transition_flag := 'Y';
137: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER
138: (g_process, 'CONFIG_PROJ_PERF_FLAG', 'Y');

Line 137: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER

133: if (l_settings_proj_perf_flag = 'Y' and l_params_proj_perf_flag = 'N') then
134: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER
135: (g_process, 'TRANSITION', 'Y');
136: l_transition_flag := 'Y';
137: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER
138: (g_process, 'CONFIG_PROJ_PERF_FLAG', 'Y');
139: end if;
140:
141: if (l_settings_cost_flag = 'Y' and l_params_cost_flag = 'N') then

Line 142: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER

138: (g_process, 'CONFIG_PROJ_PERF_FLAG', 'Y');
139: end if;
140:
141: if (l_settings_cost_flag = 'Y' and l_params_cost_flag = 'N') then
142: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER
143: (g_process, 'TRANSITION', 'Y');
144: l_transition_flag := 'Y';
145: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER
146: (g_process, 'CONFIG_COST_FLAG', 'Y');

Line 145: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER

141: if (l_settings_cost_flag = 'Y' and l_params_cost_flag = 'N') then
142: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER
143: (g_process, 'TRANSITION', 'Y');
144: l_transition_flag := 'Y';
145: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER
146: (g_process, 'CONFIG_COST_FLAG', 'Y');
147: end if;
148:
149: if (l_settings_profit_flag = 'Y' and l_params_profit_flag = 'N') then

Line 150: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER

146: (g_process, 'CONFIG_COST_FLAG', 'Y');
147: end if;
148:
149: if (l_settings_profit_flag = 'Y' and l_params_profit_flag = 'N') then
150: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER
151: (g_process, 'TRANSITION', 'Y');
152: l_transition_flag := 'Y';
153: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER
154: (g_process, 'CONFIG_PROFIT_FLAG', 'Y');

Line 153: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER

149: if (l_settings_profit_flag = 'Y' and l_params_profit_flag = 'N') then
150: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER
151: (g_process, 'TRANSITION', 'Y');
152: l_transition_flag := 'Y';
153: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER
154: (g_process, 'CONFIG_PROFIT_FLAG', 'Y');
155: end if;
156:
157: if (l_settings_util_flag = 'Y' and l_params_util_flag = 'N') then

Line 158: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER

154: (g_process, 'CONFIG_PROFIT_FLAG', 'Y');
155: end if;
156:
157: if (l_settings_util_flag = 'Y' and l_params_util_flag = 'N') then
158: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER
159: (g_process, 'TRANSITION', 'Y');
160: l_transition_flag := 'Y';
161: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER
162: (g_process, 'CONFIG_UTIL_FLAG', 'Y');

Line 161: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER

157: if (l_settings_util_flag = 'Y' and l_params_util_flag = 'N') then
158: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER
159: (g_process, 'TRANSITION', 'Y');
160: l_transition_flag := 'Y';
161: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER
162: (g_process, 'CONFIG_UTIL_FLAG', 'Y');
163: end if;
164:
165: /*select count(*)

Line 171: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER

167: from PJI_RM_DNGL_RES;
168:
169: if (l_row_count > 0 and l_transition_flag = 'Y') then
170:
171: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER
172: (g_process, 'TRANSITION', 'N');
173: l_transition_flag := 'N';
174:
175: PJI_UTILS.WRITE2LOG('Error: ' || l_dangling_error);

Line 236: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, g_process) <>

232: begin
233:
234: l_count := 0;
235:
236: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, g_process) <>
237: FND_GLOBAL.CONC_REQUEST_ID and
238: (PJI_PROCESS_UTIL.REQUEST_STATUS
239: (
240: 'RUNNING',

Line 238: (PJI_PROCESS_UTIL.REQUEST_STATUS

234: l_count := 0;
235:
236: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, g_process) <>
237: FND_GLOBAL.CONC_REQUEST_ID and
238: (PJI_PROCESS_UTIL.REQUEST_STATUS
239: (
240: 'RUNNING',
241: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, g_process),
242: g_full_disp_name

Line 241: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, g_process),

237: FND_GLOBAL.CONC_REQUEST_ID and
238: (PJI_PROCESS_UTIL.REQUEST_STATUS
239: (
240: 'RUNNING',
241: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, g_process),
242: g_full_disp_name
243: ) or
244: PJI_PROCESS_UTIL.REQUEST_STATUS
245: (

Line 244: PJI_PROCESS_UTIL.REQUEST_STATUS

240: 'RUNNING',
241: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, g_process),
242: g_full_disp_name
243: ) or
244: PJI_PROCESS_UTIL.REQUEST_STATUS
245: (
246: 'RUNNING',
247: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, g_process),
248: g_incr_disp_name

Line 247: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, g_process),

243: ) or
244: PJI_PROCESS_UTIL.REQUEST_STATUS
245: (
246: 'RUNNING',
247: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, g_process),
248: g_incr_disp_name
249: ) or
250: PJI_PROCESS_UTIL.REQUEST_STATUS
251: (

Line 250: PJI_PROCESS_UTIL.REQUEST_STATUS

246: 'RUNNING',
247: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, g_process),
248: g_incr_disp_name
249: ) or
250: PJI_PROCESS_UTIL.REQUEST_STATUS
251: (
252: 'RUNNING',
253: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, g_process),
254: g_prtl_disp_name

Line 253: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, g_process),

249: ) or
250: PJI_PROCESS_UTIL.REQUEST_STATUS
251: (
252: 'RUNNING',
253: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, g_process),
254: g_prtl_disp_name
255: ))) then
256: l_count := l_count + 1;
257: end if;

Line 260: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PARALLEL_PROCESSES');

256: l_count := l_count + 1;
257: end if;
258:
259: l_parallel_processes :=
260: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PARALLEL_PROCESSES');
261:
262: /* if (l_parallel_processes is not null) then
263:
264: for x in 2 .. l_parallel_processes loop

Line 265: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

261:
262: /* if (l_parallel_processes is not null) then
263:
264: for x in 2 .. l_parallel_processes loop
265: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
266: (
267: g_process || to_char(x),
268: g_process || to_char(x)
269: ) < FND_GLOBAL.CONC_REQUEST_ID and

Line 283: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,

279: commit;
280: dbms_standard.raise_application_error(-20010, l_sum_rm_running);
281: end if;
282:
283: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,
284: 'PROCESS_RUNNING',
285: 'Y');
286:
287: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,

Line 287: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,

283: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,
284: 'PROCESS_RUNNING',
285: 'Y');
286:
287: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,
288: g_process,
289: FND_GLOBAL.CONC_REQUEST_ID);
290:
291: commit;

Line 297: return PJI_PROCESS_UTIL.PRIOR_ITERATION_SUCCESSFUL(g_process);

293: -- API call below check if table PJI_SYSTEM_PRC_STATUS has any
294: -- records for this process. If records exist, this means that prior
295: -- process did not complete successfully.
296:
297: return PJI_PROCESS_UTIL.PRIOR_ITERATION_SUCCESSFUL(g_process);
298:
299: end PRIOR_ITERATION_SUCCESSFUL;
300:
301:

Line 374: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_RM_SUM_MAIN.g_process,

370: 'N');
371: end if;
372: Commented for bug 13011859 */
373: l_transition_flag :=
374: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_RM_SUM_MAIN.g_process,
375: 'TRANSITION');
376:
377: if ((l_org_count = 0 and
378: l_project_count = 0) or l_transition_flag = 'Y') then

Line 385: PJI_PROCESS_UTIL.ADD_STEPS(g_process || 1, 'PJI_PJI', l_extraction_type);

381: l_project_count > 0) and l_extraction_type = 'FULL') then
382: l_extraction_type := 'INCREMENTAL';
383: end if;
384:
385: PJI_PROCESS_UTIL.ADD_STEPS(g_process || 1, 'PJI_PJI', l_extraction_type);
386:
387: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(g_process || 1, 'PJI_RM_SUM_MAIN.INIT_PROCESS;')) then
388: rollback;
389: return;

Line 387: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(g_process || 1, 'PJI_RM_SUM_MAIN.INIT_PROCESS;')) then

383: end if;
384:
385: PJI_PROCESS_UTIL.ADD_STEPS(g_process || 1, 'PJI_PJI', l_extraction_type);
386:
387: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(g_process || 1, 'PJI_RM_SUM_MAIN.INIT_PROCESS;')) then
388: rollback;
389: return;
390: end if;
391:

Line 392: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(l_process,

388: rollback;
389: return;
390: end if;
391:
392: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(l_process,
393: 'EXTRACTION_TYPE',
394: l_extraction_type);
395:
396: insert into PJI_SYSTEM_CONFIG_HIST

Line 441: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,

437: -- ------------------------------------------------------------------------
438:
439: PJI_UTILS.SET_PARAMETER('DANGLING_PJI_ROWS_EXIST', 'P');
440:
441: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,
442: 'ORGANIZATION_ID',
443: p_organization_id);
444:
445: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,

Line 445: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,

441: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,
442: 'ORGANIZATION_ID',
443: p_organization_id);
444:
445: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,
446: 'HIERARCHIAL',
447: p_include_sub_org);
448:
449: -- Update list of organizations to be extracted in case

Line 613: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,'PA_CALENDAR_FLAG','Y');

609: g_date_mask
610: ));
611:
612: if (PJI_UTILS.GET_SETUP_PARAMETER('PA_PERIOD_FLAG') = 'Y' ) then
613: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,'PA_CALENDAR_FLAG','Y');
614: else
615: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,'PA_CALENDAR_FLAG','N');
616: end if;
617:

Line 615: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,'PA_CALENDAR_FLAG','N');

611:
612: if (PJI_UTILS.GET_SETUP_PARAMETER('PA_PERIOD_FLAG') = 'Y' ) then
613: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,'PA_CALENDAR_FLAG','Y');
614: else
615: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,'PA_CALENDAR_FLAG','N');
616: end if;
617:
618: if (PJI_UTILS.GET_SETUP_PARAMETER('GL_PERIOD_FLAG') = 'Y' ) then
619: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,'GL_CALENDAR_FLAG','Y');

Line 619: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,'GL_CALENDAR_FLAG','Y');

615: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,'PA_CALENDAR_FLAG','N');
616: end if;
617:
618: if (PJI_UTILS.GET_SETUP_PARAMETER('GL_PERIOD_FLAG') = 'Y' ) then
619: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,'GL_CALENDAR_FLAG','Y');
620: else
621: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,'GL_CALENDAR_FLAG','N');
622: end if;
623:

Line 621: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,'GL_CALENDAR_FLAG','N');

617:
618: if (PJI_UTILS.GET_SETUP_PARAMETER('GL_PERIOD_FLAG') = 'Y' ) then
619: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,'GL_CALENDAR_FLAG','Y');
620: else
621: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,'GL_CALENDAR_FLAG','N');
622: end if;
623:
624: --Enable menu structure for Utilization
625: PA_PJI_MENU_UTIL.ENABLE_MENUS;

Line 783: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,

779: -- null = not dangling
780:
781: PJI_FM_PLAN_EXTR.INIT_GLOBAL_PARAMETERS;
782:
783: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,
784: 'PROJECT_OPERATING_UNIT',
785: p_operating_unit);
786:
787: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,

Line 787: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,

783: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,
784: 'PROJECT_OPERATING_UNIT',
785: p_operating_unit);
786:
787: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,
788: 'FROM_PROJECT_ID',
789: p_from_project_id);
790:
791: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,

Line 791: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,

787: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,
788: 'FROM_PROJECT_ID',
789: p_from_project_id);
790:
791: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,
792: 'TO_PROJECT_ID',
793: p_to_project_id);
794:
795: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,

Line 795: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,

791: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,
792: 'TO_PROJECT_ID',
793: p_to_project_id);
794:
795: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,
796: 'FROM_PROJECT',
797: p_from_project);
798:
799: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,

Line 799: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,

795: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,
796: 'FROM_PROJECT',
797: p_from_project);
798:
799: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,
800: 'TO_PROJECT',
801: p_to_project);
802:
803: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,

Line 803: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,

799: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,
800: 'TO_PROJECT',
801: p_to_project);
802:
803: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,
804: 'PLAN_TYPE_ID',
805: p_plan_type);
806:
807: g_parallel_processes := PJI_EXTRACTION_UTIL.GET_PARALLEL_PROCESSES;

Line 809: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,

805: p_plan_type);
806:
807: g_parallel_processes := PJI_EXTRACTION_UTIL.GET_PARALLEL_PROCESSES;
808:
809: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,
810: 'PARALLEL_PROCESSES',
811: least(g_parallel_processes,
812: g_parallel_limit));
813: Commented for bug 13011859 */

Line 814: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(g_process || 1, 'PJI_RM_SUM_MAIN.INIT_PROCESS;');

810: 'PARALLEL_PROCESSES',
811: least(g_parallel_processes,
812: g_parallel_limit));
813: Commented for bug 13011859 */
814: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(g_process || 1, 'PJI_RM_SUM_MAIN.INIT_PROCESS;');
815:
816: commit;
817:
818: end INIT_PROCESS;

Line 835: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PROCESS_RUNNING') <> 'Y' and

831:
832: -- if process is determined to be over or any worker has failed then signal
833: -- that workers should stop processing and wrapup
834:
835: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PROCESS_RUNNING') <> 'Y' and
836: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PROCESS_RUNNING') <> 'N') then
837: return false;
838: end if;
839:

Line 836: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PROCESS_RUNNING') <> 'N') then

832: -- if process is determined to be over or any worker has failed then signal
833: -- that workers should stop processing and wrapup
834:
835: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PROCESS_RUNNING') <> 'Y' and
836: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PROCESS_RUNNING') <> 'N') then
837: return false;
838: end if;
839:
840: /* l_parallel_processes :=

Line 841: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PARALLEL_PROCESSES');

837: return false;
838: end if;
839:
840: /* l_parallel_processes :=
841: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PARALLEL_PROCESSES');
842:
843: if (p_wait = 'WAIT') then
844: l_from_process := 2;
845: elsif (p_wait = 'DO_NOT_WAIT') then

Line 858: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,

854: end if;
855: end loop;
856:
857: if (l_batch_count > 0) then
858: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,
859: 'PROCESS_RUNNING',
860: 'F');
861: commit;
862: return false;

Line 869: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process, 'PROCESS_RUNNING','N');

865: if (p_wait = 'DO_NOT_WAIT') then
866: return true;
867: end if;
868:
869: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process, 'PROCESS_RUNNING','N');
870: commit;
871:
872: for x in l_from_process .. l_parallel_processes loop
873: PJI_RM_SUM_EXTR.WAIT_FOR_WORKER(x);

Line 891: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(g_process || 1, 'PJI_RM_SUM_MAIN.RUN_PROCESS;')) then

887: l_seq number;
888:
889: begin
890:
891: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(g_process || 1, 'PJI_RM_SUM_MAIN.RUN_PROCESS;')) then
892: return;
893: end if;
894:
895: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,

Line 895: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,

891: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(g_process || 1, 'PJI_RM_SUM_MAIN.RUN_PROCESS;')) then
892: return;
893: end if;
894:
895: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,
896: 'PROCESS_RUNNING',
897: 'Y');
898:
899: -- ensure that worker and helpers can run concurrently

Line 904: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PARALLEL_PROCESSES');

900: /* FND_PROFILE.PUT('CONC_SINGLE_THREAD', 'N');
901: commit;
902:
903: l_parallel_processes :=
904: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PARALLEL_PROCESSES');
905:
906: -- start extraction helpers
907:
908: for x in 2..l_parallel_processes loop

Line 919: PJI_PROCESS_UTIL.SLEEP(g_process_delay);

915:
916: -- sleep until process is complete
917:
918: while (PROCESS_RUNNING('WAIT')) loop
919: PJI_PROCESS_UTIL.SLEEP(g_process_delay);
920: end loop;
921:
922: -- process finished
923:

Line 924: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PROCESS_RUNNING') = 'N') thenCommented for bug 13011859 */

920: end loop;
921:
922: -- process finished
923:
924: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PROCESS_RUNNING') = 'N') thenCommented for bug 13011859 */
925:
926: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(g_process || 1, 'PJI_RM_SUM_MAIN.RUN_PROCESS;');
927:
928: commit;

Line 926: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(g_process || 1, 'PJI_RM_SUM_MAIN.RUN_PROCESS;');

922: -- process finished
923:
924: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PROCESS_RUNNING') = 'N') thenCommented for bug 13011859 */
925:
926: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(g_process || 1, 'PJI_RM_SUM_MAIN.RUN_PROCESS;');
927:
928: commit;
929:
930: -- end if;

Line 1333: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process,

1329: l_params_util_flag varchar2(1);
1330:
1331: begin
1332:
1333: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process,
1334: 'TRANSITION') = 'Y') then
1335:
1336: l_params_proj_perf_flag :=
1337: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process,

Line 1337: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process,

1333: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process,
1334: 'TRANSITION') = 'Y') then
1335:
1336: l_params_proj_perf_flag :=
1337: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process,
1338: 'CONFIG_PROJ_PERF_FLAG'), 'N');
1339: l_params_cost_flag :=
1340: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process,
1341: 'CONFIG_COST_FLAG'), 'N');

Line 1340: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process,

1336: l_params_proj_perf_flag :=
1337: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process,
1338: 'CONFIG_PROJ_PERF_FLAG'), 'N');
1339: l_params_cost_flag :=
1340: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process,
1341: 'CONFIG_COST_FLAG'), 'N');
1342: l_params_profit_flag :=
1343: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process,
1344: 'CONFIG_PROFIT_FLAG'), 'N');

Line 1343: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process,

1339: l_params_cost_flag :=
1340: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process,
1341: 'CONFIG_COST_FLAG'), 'N');
1342: l_params_profit_flag :=
1343: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process,
1344: 'CONFIG_PROFIT_FLAG'), 'N');
1345: l_params_util_flag :=
1346: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process,
1347: 'CONFIG_UTIL_FLAG'), 'N');

Line 1346: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process,

1342: l_params_profit_flag :=
1343: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process,
1344: 'CONFIG_PROFIT_FLAG'), 'N');
1345: l_params_util_flag :=
1346: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process,
1347: 'CONFIG_UTIL_FLAG'), 'N');
1348:
1349: if (l_params_proj_perf_flag = 'Y') then
1350: PJI_UTILS.SET_PARAMETER('CONFIG_PROJ_PERF_FLAG', 'Y');

Line 1388: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(g_process || 1, 'PJI_RM_SUM_MAIN.WRAPUP_PROCESS;')) then

1384: l_schema varchar2(30);
1385:
1386: begin
1387:
1388: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(g_process || 1, 'PJI_RM_SUM_MAIN.WRAPUP_PROCESS;')) then
1389: return;
1390: end if;
1391:
1392: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 1392: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

1388: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(g_process || 1, 'PJI_RM_SUM_MAIN.WRAPUP_PROCESS;')) then
1389: return;
1390: end if;
1391:
1392: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1393: (g_process, 'EXTRACTION_TYPE');
1394:
1395: l_parallel_processes :=
1396: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PARALLEL_PROCESSES');

Line 1396: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PARALLEL_PROCESSES');

1392: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1393: (g_process, 'EXTRACTION_TYPE');
1394:
1395: l_parallel_processes :=
1396: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PARALLEL_PROCESSES');
1397:
1398: /* for x in 2 .. l_parallel_processes loop
1399: PJI_RM_SUM_EXTR.WAIT_FOR_WORKER(x);
1400: end loop;

Line 1402: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PROCESS_RUNNING') = 'A') then

1398: /* for x in 2 .. l_parallel_processes loop
1399: PJI_RM_SUM_EXTR.WAIT_FOR_WORKER(x);
1400: end loop;
1401:
1402: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PROCESS_RUNNING') = 'A') then
1403: fnd_message.set_name('PJI','PJI_SUM_ABORT');
1404: dbms_standard.raise_application_error(-20000, fnd_message.get);
1405: elsif (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PROCESS_RUNNING') = 'F') then
1406: fnd_message.set_name('PJI','PJI_SUM_FAIL');

Line 1405: elsif (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PROCESS_RUNNING') = 'F') then

1401:
1402: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PROCESS_RUNNING') = 'A') then
1403: fnd_message.set_name('PJI','PJI_SUM_ABORT');
1404: dbms_standard.raise_application_error(-20000, fnd_message.get);
1405: elsif (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PROCESS_RUNNING') = 'F') then
1406: fnd_message.set_name('PJI','PJI_SUM_FAIL');
1407: dbms_standard.raise_application_error(-20000, fnd_message.get);
1408: end if;
1409:

Line 1417: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,

1413: PJI_FM_PLAN_EXTR.CLEANUP_LOG;
1414:
1415: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
1416:
1417: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
1418: 'PJI_RM_ORG_BATCH_MAP','NORMAL',null);
1419:
1420: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
1421: 'PJI_PJI_PROJ_BATCH_MAP','NORMAL',null);

Line 1420: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,

1416:
1417: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
1418: 'PJI_RM_ORG_BATCH_MAP','NORMAL',null);
1419:
1420: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
1421: 'PJI_PJI_PROJ_BATCH_MAP','NORMAL',null);
1422:
1423: WRAPUP_SETUP;
1424:

Line 1425: PJI_PROCESS_UTIL.WRAPUP_PROCESS(g_process || 1);

1421: 'PJI_PJI_PROJ_BATCH_MAP','NORMAL',null);
1422:
1423: WRAPUP_SETUP;
1424:
1425: PJI_PROCESS_UTIL.WRAPUP_PROCESS(g_process || 1);
1426: PJI_PROCESS_UTIL.WRAPUP_PROCESS(g_process);
1427:
1428: update PJI_SYSTEM_CONFIG_HIST
1429: set END_DATE = sysdate,

Line 1426: PJI_PROCESS_UTIL.WRAPUP_PROCESS(g_process);

1422:
1423: WRAPUP_SETUP;
1424:
1425: PJI_PROCESS_UTIL.WRAPUP_PROCESS(g_process || 1);
1426: PJI_PROCESS_UTIL.WRAPUP_PROCESS(g_process);
1427:
1428: update PJI_SYSTEM_CONFIG_HIST
1429: set END_DATE = sysdate,
1430: COMPLETION_TEXT = 'Normal completion'

Line 1457: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,

1453: begin
1454:
1455: rollback;
1456:
1457: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,
1458: 'PROCESS_RUNNING',
1459: 'F');
1460:
1461: commit;

Line 1486: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PROCESS_RUNNING') <> 'Y') then

1482: retcode out nocopy varchar2) is
1483:
1484: begin
1485:
1486: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PROCESS_RUNNING') <> 'Y') then
1487:
1488: retcode := 1;
1489:
1490: else

Line 1492: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,

1488: retcode := 1;
1489:
1490: else
1491:
1492: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,
1493: 'PROCESS_RUNNING',
1494: 'A');
1495: commit;
1496: retcode := 0;

Line 1563: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, g_process) <>

1559: commit;
1560: raise l_pji_not_licensed;
1561: end if;*
1562:
1563: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, g_process) <>
1564: FND_GLOBAL.CONC_REQUEST_ID and
1565: (PJI_PROCESS_UTIL.REQUEST_STATUS
1566: (
1567: 'RUNNING',

Line 1565: (PJI_PROCESS_UTIL.REQUEST_STATUS

1561: end if;*
1562:
1563: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, g_process) <>
1564: FND_GLOBAL.CONC_REQUEST_ID and
1565: (PJI_PROCESS_UTIL.REQUEST_STATUS
1566: (
1567: 'RUNNING',
1568: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, g_process),
1569: g_full_disp_name

Line 1568: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, g_process),

1564: FND_GLOBAL.CONC_REQUEST_ID and
1565: (PJI_PROCESS_UTIL.REQUEST_STATUS
1566: (
1567: 'RUNNING',
1568: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, g_process),
1569: g_full_disp_name
1570: ) or
1571: PJI_PROCESS_UTIL.REQUEST_STATUS
1572: (

Line 1571: PJI_PROCESS_UTIL.REQUEST_STATUS

1567: 'RUNNING',
1568: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, g_process),
1569: g_full_disp_name
1570: ) or
1571: PJI_PROCESS_UTIL.REQUEST_STATUS
1572: (
1573: 'RUNNING',
1574: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, g_process),
1575: g_incr_disp_name

Line 1574: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, g_process),

1570: ) or
1571: PJI_PROCESS_UTIL.REQUEST_STATUS
1572: (
1573: 'RUNNING',
1574: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, g_process),
1575: g_incr_disp_name
1576: ))) then
1577: pji_utils.write2log('Error: Summarization is already running.');
1578: commit;

Line 1612: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,

1608: commit;
1609: execute immediate 'alter session enable parallel query';
1610: execute immediate 'alter session enable parallel dml';
1611:
1612: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,
1613: g_process,
1614: FND_GLOBAL.CONC_REQUEST_ID);
1615:
1616: commit;

Line 1618: PJI_PROCESS_UTIL.REFRESH_STEP_TABLE;

1614: FND_GLOBAL.CONC_REQUEST_ID);
1615:
1616: commit;
1617:
1618: PJI_PROCESS_UTIL.REFRESH_STEP_TABLE;
1619:
1620: -- determine if a transitional configuration is needed
1621: /* RUN_SETUP;
1622:

Line 1623: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

1619:
1620: -- determine if a transitional configuration is needed
1621: /* RUN_SETUP;
1622:
1623: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1624: (g_process, 'TRANSITION') = 'N' and
1625: (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1626: (g_process, 'CONFIG_PROJ_PERF_FLAG') = 'Y' or
1627: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 1625: (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

1621: /* RUN_SETUP;
1622:
1623: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1624: (g_process, 'TRANSITION') = 'N' and
1625: (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1626: (g_process, 'CONFIG_PROJ_PERF_FLAG') = 'Y' or
1627: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1628: (g_process, 'CONFIG_COST_FLAG') = 'Y' or
1629: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 1627: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

1623: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1624: (g_process, 'TRANSITION') = 'N' and
1625: (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1626: (g_process, 'CONFIG_PROJ_PERF_FLAG') = 'Y' or
1627: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1628: (g_process, 'CONFIG_COST_FLAG') = 'Y' or
1629: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1630: (g_process, 'CONFIG_PROFIT_FLAG') = 'Y' or
1631: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 1629: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

1625: (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1626: (g_process, 'CONFIG_PROJ_PERF_FLAG') = 'Y' or
1627: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1628: (g_process, 'CONFIG_COST_FLAG') = 'Y' or
1629: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1630: (g_process, 'CONFIG_PROFIT_FLAG') = 'Y' or
1631: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1632: (g_process, 'CONFIG_UTIL_FLAG') = 'Y')) then
1633: retcode := 1;

Line 1631: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

1627: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1628: (g_process, 'CONFIG_COST_FLAG') = 'Y' or
1629: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1630: (g_process, 'CONFIG_PROFIT_FLAG') = 'Y' or
1631: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1632: (g_process, 'CONFIG_UTIL_FLAG') = 'Y')) then
1633: retcode := 1;
1634: else
1635: retcode := 0;