[Home] [Help]
31: begin
32:
33: if (p_stage = 'STAGE1_EXTR') then
34:
35: l_permanent_param := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
36: l_running_param := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
37: (PJI_FM_SUM_MAIN.g_process, 'TRANSITION');
38:
39: if (l_running_param is not null) then
62: l_stage2_pji_process := null;
63:
64: end;
65:
66: l_permanent_param := PJI_UTILS.GET_PARAMETER('LAST_PJI_EXTR_DATE');
67: l_running_param := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
68: -- Remove dependency on STAGE2_PJI
69: (l_stage2_pji_process, 'PROCESS_RUNNING');
70: -- (PJI_RM_SUM_MAIN.g_process, 'PROCESS_RUNNING');
148: l_step varchar2(100);
149:
150: begin
151: /* Added for bug 13030627 */
152: if PJI_UTILS.GET_PARAMETER('PJP_SIN_PRG') = 'Y' then
153:
154: l_process := p_process;
155: l_step := p_step;
156:
196: where PROCESS_NAME = p_process and
197: STEP_NAME = p_step and
198: START_DATE is null;
199:
200: -- PJI_UTILS.SET_CURR_FUNCTION(p_process || '$' || to_char(l_seq));
201: PJI_UTILS.WRITE2LOG('Entering ' || p_step || ' for ' || p_process,
202: true, 0);
203: return true;
204: end if;
197: STEP_NAME = p_step and
198: START_DATE is null;
199:
200: -- PJI_UTILS.SET_CURR_FUNCTION(p_process || '$' || to_char(l_seq));
201: PJI_UTILS.WRITE2LOG('Entering ' || p_step || ' for ' || p_process,
202: true, 0);
203: return true;
204: end if;
205:
227:
228: begin
229:
230: /* Added for bug 13030627 */
231: if PJI_UTILS.GET_PARAMETER('PJP_SIN_PRG') = 'Y' then
232:
233: l_process := p_process;
234: l_step := p_step;
235:
251: END_DATE = sysdate
252: where PROCESS_NAME = p_process and
253: STEP_NAME = p_step;
254:
255: -- PJI_UTILS.RESET_CURR_FUNCTION;
256: PJI_UTILS.WRITE2LOG('Completed ' || p_step || ' for ' || p_process,
257: true, 0);
258:
259: end if;
252: where PROCESS_NAME = p_process and
253: STEP_NAME = p_step;
254:
255: -- PJI_UTILS.RESET_CURR_FUNCTION;
256: PJI_UTILS.WRITE2LOG('Completed ' || p_step || ' for ' || p_process,
257: true, 0);
258:
259: end if;
260:
293:
294: begin
295:
296: /* Added for bug 13030627 */
297: if PJI_UTILS.GET_PARAMETER('PJP_SIN_PRG') = 'Y' then
298:
299: l_process := p_process;
300: PJI_PJP_PRG_PERF_ALL.WRAPUP_PROCESS(p_process => l_process);
301:
360:
361: else -- l_transition is null or 'N'
362:
363: l_params_proj_perf_flag :=
364: nvl(PJI_UTILS.GET_PARAMETER('CONFIG_PROJ_PERF_FLAG'), 'N');
365: l_params_cost_flag :=
366: nvl(PJI_UTILS.GET_PARAMETER('CONFIG_COST_FLAG'), 'N');
367: l_params_profit_flag :=
368: nvl(PJI_UTILS.GET_PARAMETER('CONFIG_PROFIT_FLAG'), 'N');
362:
363: l_params_proj_perf_flag :=
364: nvl(PJI_UTILS.GET_PARAMETER('CONFIG_PROJ_PERF_FLAG'), 'N');
365: l_params_cost_flag :=
366: nvl(PJI_UTILS.GET_PARAMETER('CONFIG_COST_FLAG'), 'N');
367: l_params_profit_flag :=
368: nvl(PJI_UTILS.GET_PARAMETER('CONFIG_PROFIT_FLAG'), 'N');
369: l_params_util_flag :=
370: nvl(PJI_UTILS.GET_PARAMETER('CONFIG_UTIL_FLAG'), 'N');
364: nvl(PJI_UTILS.GET_PARAMETER('CONFIG_PROJ_PERF_FLAG'), 'N');
365: l_params_cost_flag :=
366: nvl(PJI_UTILS.GET_PARAMETER('CONFIG_COST_FLAG'), 'N');
367: l_params_profit_flag :=
368: nvl(PJI_UTILS.GET_PARAMETER('CONFIG_PROFIT_FLAG'), 'N');
369: l_params_util_flag :=
370: nvl(PJI_UTILS.GET_PARAMETER('CONFIG_UTIL_FLAG'), 'N');
371:
372: end if;
366: nvl(PJI_UTILS.GET_PARAMETER('CONFIG_COST_FLAG'), 'N');
367: l_params_profit_flag :=
368: nvl(PJI_UTILS.GET_PARAMETER('CONFIG_PROFIT_FLAG'), 'N');
369: l_params_util_flag :=
370: nvl(PJI_UTILS.GET_PARAMETER('CONFIG_UTIL_FLAG'), 'N');
371:
372: end if;
373:
374: if (p_extraction_type = 'FULL') then
452: ) return varchar2 is
453:
454: begin
455:
456: return PJI_UTILS.GET_PARAMETER(p_process || '$' || p_parameter);
457:
458: end;
459:
460: -- ----------------------------------------------------------
468: ) is
469:
470: begin
471:
472: PJI_UTILS.SET_PARAMETER(p_process || '$' || p_parameter, p_value);
473:
474: end;
475:
476:
499: l_pji_schema varchar2(30); /* Added for Bug 13813361 */
500:
501: begin
502:
503: l_pji_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME; /* Added for Bug 13813361 */
504:
505: IF 1=1 THEN -- so that this is a controlled feature
506:
507: IF (p_trunc_type = 'NORMAL') THEN
714:
715: if (FND_CONCURRENT.GET_REQUEST_STATUS
716: (
717: l_request_id,
718: PJI_UTILS.GET_PJI_SCHEMA_NAME,
719: p_request_name,
720: l_phase,
721: l_status,
722: l_dev_phase,
7653: l_partial_mode := p_partial_mode;
7654: l_fpm_upgrade := p_fpm_upgrade;
7655:
7656: /* Added for bug 13030627 */
7657: if PJI_UTILS.GET_PARAMETER('PJP_SIN_PRG') = 'Y' then
7658:
7659: l_worker_id := p_worker_id;
7660: PJI_PJP_PRG_PERF_ALL.EXECUTE_ROLLUP_FPR_WBS(
7661: p_worker_id => l_worker_id,
7684: /* Start bug 10338478 */
7685: If nvl(l_extraction_type,'N') = 'RBS' or
7686: -- Start Bug 10632599 (Base Bug 9488206 -- This code to run in case of
7687: -- PRC: DELETE PROJECT PERFORMANCE REPORTING DATA also)
7688: (nvl(l_extraction_type,'N') = 'FULL' and PJI_UTILS.GET_PARAMETER('PJI_FPM_UPGRADE') <> 'C') then
7689: -- End bug 10632599
7690: EXECUTE_ROLLUP_FPR_RBS(p_worker_id => p_worker_id,
7691: p_level => l_level,
7692: p_partial_mode => l_partial_mode,
40655: l_worker_id number; /* Added for bug 13030627 */
40656: begin
40657:
40658: /* Added for bug 13030627 */
40659: if PJI_UTILS.GET_PARAMETER('PJP_SIN_PRG') = 'Y' then
40660:
40661: l_worker_id := p_worker_id;
40662: PJI_PJP_PRG_PERF_ALL.EXECUTE_AGGREGATE_PLAN_DATA(
40663: p_worker_id => l_worker_id);
44872: where worker_id = PJI_PJP_FP_CURR_WRAP.GET_WORKER_ID
44873: order by batch_id;
44874:
44875: BEGIN
44876: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
44877: l_parallel_proc := nvl(fnd_profile.value('PJI_EXTRACTION_PARALLELISM'), 1);
44878:
44879: g_worker_id := PJI_PJP_FP_CURR_WRAP.GET_WORKER_ID;
44880: