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:
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:

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:
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') then

920: end loop;
921:
922: -- process finished
923:
924: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process, 'PROCESS_RUNNING') = 'N') then
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') then
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 1334: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process,

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

Line 1338: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process,

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

Line 1341: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process,

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

Line 1344: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process,

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

Line 1347: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(g_process,

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

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

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

Line 1393: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

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

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

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

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

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

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

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

Line 1418: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,

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

Line 1421: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,

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

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

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

Line 1427: PJI_PROCESS_UTIL.WRAPUP_PROCESS(g_process);

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

Line 1458: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,

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

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

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

Line 1493: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,

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

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

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

Line 1566: (PJI_PROCESS_UTIL.REQUEST_STATUS

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

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

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

Line 1572: PJI_PROCESS_UTIL.REQUEST_STATUS

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

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

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

Line 1613: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(g_process,

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

Line 1619: PJI_PROCESS_UTIL.REFRESH_STEP_TABLE;

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

Line 1624: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

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

Line 1626: (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

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

Line 1628: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

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

Line 1630: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

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

Line 1632: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

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