eTRM uses javascript that opens and focuses a separate window to display reports. Your browser does not appear to support javascript. This should not prevent you from using eTRM but it does mean the window focus feature will not work. Please check the contents of other windows on your desktop if you click on a link that does not appear to do anything.

APPS.PJI_FM_SUM_EXTR dependencies on PJI_PROCESS_UTIL

Line 19: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.POPULATE_TIME_DIMENSION(p_worker_id);')) then

15: begin
16:
17: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
18:
19: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.POPULATE_TIME_DIMENSION(p_worker_id);')) then
20: return;
21: end if;
22:
23: PJI_TIME_C.LOAD(null, null, l_return_status, l_msg_count, l_msg_data);

Line 25: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.POPULATE_TIME_DIMENSION(p_worker_id);');

21: end if;
22:
23: PJI_TIME_C.LOAD(null, null, l_return_status, l_msg_count, l_msg_data);
24:
25: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.POPULATE_TIME_DIMENSION(p_worker_id);');
26:
27: commit;
28:
29: end POPULATE_TIME_DIMENSION;

Line 43: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.ORG_EXTR_INFO_TABLE(p_worker_id);')) then

39: begin
40:
41: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
42:
43: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.ORG_EXTR_INFO_TABLE(p_worker_id);')) then
44: return;
45: end if;
46:
47: PJI_EXTRACTION_UTIL.UPDATE_ORG_EXTR_INFO;

Line 49: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.ORG_EXTR_INFO_TABLE(p_worker_id);');

45: end if;
46:
47: PJI_EXTRACTION_UTIL.UPDATE_ORG_EXTR_INFO;
48:
49: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.ORG_EXTR_INFO_TABLE(p_worker_id);');
50:
51: -- implicit commit
52: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
53: tabname => 'PJI_ORG_EXTR_INFO',

Line 79: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.CURR_CONV_TABLE(p_worker_id);')) then

75: begin
76:
77: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
78:
79: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.CURR_CONV_TABLE(p_worker_id);')) then
80: return;
81: end if;
82:
83: l_extract_commitments := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 83: l_extract_commitments := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

79: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.CURR_CONV_TABLE(p_worker_id);')) then
80: return;
81: end if;
82:
83: l_extract_commitments := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
84: (PJI_FM_SUM_MAIN.g_process,
85: 'EXTRACT_COMMITMENTS');
86:
87: insert /*+ append */ into PJI_FM_AGGR_DLY_RATES

Line 364: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.CURR_CONV_TABLE(p_worker_id);');

360: tmp.PF_CURRENCY_CODE = rates.PF_CURRENCY_CODE (+) and
361: tmp.TIME_ID = rates.TIME_ID (+) and
362: rates.WORKER_ID is null;
363:
364: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.CURR_CONV_TABLE(p_worker_id);');
365:
366: commit;
367:
368: end CURR_CONV_TABLE;

Line 387: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.DANGLING_FIN_ROWS(p_worker_id);')) then

383: begin
384:
385: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
386:
387: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.DANGLING_FIN_ROWS(p_worker_id);')) then
388: return;
389: end if;
390:
391: select

Line 1806: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.DANGLING_FIN_ROWS(p_worker_id);');

1802: tmp2.RECVR_PA_TIME_ID = prj_pa_rt.TIME_ID and
1803: prj_info.PF_CURRENCY_CODE = prj_pa_rt.PF_CURRENCY_CODE
1804: ) tmp2;
1805:
1806: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.DANGLING_FIN_ROWS(p_worker_id);');
1807:
1808: commit;
1809:
1810: end DANGLING_FIN_ROWS;

Line 1829: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.DANGLING_ACT_ROWS(p_worker_id);')) then

1825: begin
1826:
1827: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
1828:
1829: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.DANGLING_ACT_ROWS(p_worker_id);')) then
1830: return;
1831: end if;
1832:
1833: select

Line 3178: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.DANGLING_ACT_ROWS(p_worker_id);');

3174: tmp2.PA_TIME_ID = pa_rt.TIME_ID and
3175: prj_info.PF_CURRENCY_CODE = pa_rt.PF_CURRENCY_CODE
3176: ) tmp2;
3177:
3178: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.DANGLING_ACT_ROWS(p_worker_id);');
3179:
3180: commit;
3181:
3182: end DANGLING_ACT_ROWS;

Line 3196: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.PURGE_DANGLING_FIN_ROWS(p_worker_id);')) then

3192: begin
3193:
3194: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
3195:
3196: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.PURGE_DANGLING_FIN_ROWS(p_worker_id);')) then
3197: return;
3198: end if;
3199:
3200: /* delete /*+ parallel(fin)

Line 3214: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.PURGE_DANGLING_FIN_ROWS(p_worker_id);');

3210:
3211: delete from PJI_FM_DNGL_FIN where worker_id = 0 and ROWID in (select row_id from PJI_FM_AGGR_FIN2 where worker_id = p_worker_id);
3212: -- End for Bug# 7357456
3213:
3214: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.PURGE_DANGLING_FIN_ROWS(p_worker_id);');
3215:
3216: commit;
3217:
3218: end PURGE_DANGLING_FIN_ROWS;

Line 3232: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.PURGE_DANGLING_ACT_ROWS(p_worker_id);')) then

3228: begin
3229:
3230: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
3231:
3232: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.PURGE_DANGLING_ACT_ROWS(p_worker_id);')) then
3233: return;
3234: end if;
3235:
3236: delete /*+ parallel(act) */

Line 3243: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.PURGE_DANGLING_ACT_ROWS(p_worker_id);');

3239: ROWID in (select ROW_ID
3240: from PJI_FM_AGGR_ACT2
3241: where WORKER_ID = p_worker_id);
3242:
3243: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.PURGE_DANGLING_ACT_ROWS(p_worker_id);');
3244:
3245: commit;
3246:
3247: end PURGE_DANGLING_ACT_ROWS;

Line 3270: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.FIN_SUMMARY(p_worker_id);')) then

3266: begin
3267:
3268: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
3269:
3270: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.FIN_SUMMARY(p_worker_id);')) then
3271: return;
3272: end if;
3273:
3274: l_transition_flag :=

Line 3275: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process,

3271: return;
3272: end if;
3273:
3274: l_transition_flag :=
3275: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process,
3276: 'TRANSITION');
3277:
3278: if (l_transition_flag = 'Y') then
3279:

Line 3281: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process,

3277:
3278: if (l_transition_flag = 'Y') then
3279:
3280: l_params_cost_flag :=
3281: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process,
3282: 'CONFIG_COST_FLAG'), 'N');
3283: l_params_util_flag :=
3284: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process,
3285: 'CONFIG_UTIL_FLAG'), 'N');

Line 3284: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process,

3280: l_params_cost_flag :=
3281: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process,
3282: 'CONFIG_COST_FLAG'), 'N');
3283: l_params_util_flag :=
3284: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process,
3285: 'CONFIG_UTIL_FLAG'), 'N');
3286:
3287: else -- l_transition is null or 'N'
3288:

Line 4344: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.FIN_SUMMARY(p_worker_id);');

4340: tmp1.RECVR_PA_TIME_ID = prj_pa_rt.TIME_ID and
4341: prj_info.PF_CURRENCY_CODE = prj_pa_rt.PF_CURRENCY_CODE
4342: ) tmp1;
4343:
4344: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.FIN_SUMMARY(p_worker_id);');
4345:
4346: -- truncate intermediate tables no longer required
4347: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
4348: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_AGGR_FIN1' , 'NORMAL',null);

Line 4348: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_AGGR_FIN1' , 'NORMAL',null);

4344: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.FIN_SUMMARY(p_worker_id);');
4345:
4346: -- truncate intermediate tables no longer required
4347: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
4348: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_AGGR_FIN1' , 'NORMAL',null);
4349:
4350: commit;
4351:
4352: end FIN_SUMMARY;

Line 4366: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.MOVE_DANGLING_FIN_ROWS(p_worker_id);')) then

4362: begin
4363:
4364: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
4365:
4366: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.MOVE_DANGLING_FIN_ROWS(p_worker_id);')) then
4367: return;
4368: end if;
4369:
4370: insert into PJI_FM_DNGL_FIN

Line 4679: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.MOVE_DANGLING_FIN_ROWS(p_worker_id);');

4675: DANGLING_PRVDR_PA_TIME_FLAG is not null or
4676: DANGLING_RECVR_PA_TIME_FLAG is not null or
4677: DANGLING_EXP_PA_TIME_FLAG is not null);
4678:
4679: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.MOVE_DANGLING_FIN_ROWS(p_worker_id);');
4680:
4681: commit;
4682:
4683: end MOVE_DANGLING_FIN_ROWS;

Line 4704: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.ACT_SUMMARY(p_worker_id);')) then

4700: begin
4701:
4702: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
4703:
4704: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.ACT_SUMMARY(p_worker_id);')) then
4705: return;
4706: end if;
4707:
4708: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

Line 5705: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.ACT_SUMMARY(p_worker_id);');

5701: delete
5702: from PJI_FM_AGGR_DLY_RATES
5703: where WORKER_ID = -1;
5704:
5705: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.ACT_SUMMARY(p_worker_id);');
5706:
5707: -- truncate intermediate tables no longer required
5708: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
5709: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_AGGR_ACT1' , 'NORMAL',null);

Line 5709: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_AGGR_ACT1' , 'NORMAL',null);

5705: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.ACT_SUMMARY(p_worker_id);');
5706:
5707: -- truncate intermediate tables no longer required
5708: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
5709: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_AGGR_ACT1' , 'NORMAL',null);
5710:
5711: commit;
5712:
5713: end ACT_SUMMARY;

Line 5727: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.MOVE_DANGLING_ACT_ROWS(p_worker_id);')) then

5723: begin
5724:
5725: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
5726:
5727: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.MOVE_DANGLING_ACT_ROWS(p_worker_id);')) then
5728: return;
5729: end if;
5730:
5731: insert into PJI_FM_DNGL_ACT

Line 6058: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.MOVE_DANGLING_ACT_ROWS(p_worker_id);');

6054: DANGLING_EN_TIME_FLAG is not null or
6055: DANGLING_GL_TIME_FLAG is not null or
6056: DANGLING_PA_TIME_FLAG is not null);
6057:
6058: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.MOVE_DANGLING_ACT_ROWS(p_worker_id);');
6059:
6060: commit;
6061:
6062: end MOVE_DANGLING_ACT_ROWS;

Line 6077: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_RES_SLICES(p_worker_id);')) then

6073: begin
6074:
6075: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
6076:
6077: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_RES_SLICES(p_worker_id);')) then
6078: return;
6079: end if;
6080:
6081: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

Line 6142: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_RES_SLICES(p_worker_id);');

6138: EXPENDITURE_ITEM_TIME_ID,
6139: RS_GL_CALENDAR_ID,
6140: RS_PA_CALENDAR_ID;
6141:
6142: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_RES_SLICES(p_worker_id);');
6143:
6144: commit;
6145:
6146: end AGGREGATE_RES_SLICES;

Line 6161: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_FIN_SLICES(p_worker_id);')) then

6157: begin
6158:
6159: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
6160:
6161: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_FIN_SLICES(p_worker_id);')) then
6162: return;
6163: end if;
6164:
6165: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

Line 6776: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_FIN_SLICES(p_worker_id);');

6772: end if;
6773: /* Added for bug 9249905
6774: Commented for bug 13011859 */
6775:
6776: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_FIN_SLICES(p_worker_id);');
6777:
6778: commit;
6779:
6780: end AGGREGATE_FIN_SLICES;

Line 6797: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_ACT_SLICES(p_worker_id);')) then

6793: begin
6794:
6795: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
6796:
6797: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_ACT_SLICES(p_worker_id);')) then
6798: return;
6799: end if;
6800:
6801: l_pa_calendar_flag := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 6801: l_pa_calendar_flag := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

6797: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_ACT_SLICES(p_worker_id);')) then
6798: return;
6799: end if;
6800:
6801: l_pa_calendar_flag := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
6802: (
6803: PJI_FM_SUM_MAIN.g_process,
6804: 'PA_CALENDAR_FLAG'
6805: );

Line 7366: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_ACT_SLICES(p_worker_id);');

7362: tmp2.GL_CALENDAR_ID,
7363: tmp2.PA_CALENDAR_ID,
7364: tmp2.TXN_CURRENCY_CODE; Commented for bug 13011859*/
7365:
7366: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_ACT_SLICES(p_worker_id);');
7367:
7368: -- truncate intermediate tables no longer required
7369: -- l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
7370: -- PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_AGGR_ACT2' , 'NORMAL',null);

Line 7370: -- PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_AGGR_ACT2' , 'NORMAL',null);

7366: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_ACT_SLICES(p_worker_id);');
7367:
7368: -- truncate intermediate tables no longer required
7369: -- l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
7370: -- PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_AGGR_ACT2' , 'NORMAL',null);
7371:
7372: commit;
7373:
7374: end AGGREGATE_ACT_SLICES;

Line 7417: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.FORCE_SUBSEQUENT_RUN(p_worker_id);')) then

7413: begin
7414:
7415: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
7416:
7417: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.FORCE_SUBSEQUENT_RUN(p_worker_id);')) then
7418: return;
7419: end if;
7420:
7421: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

Line 7442: l_organization_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7438: -- -----------------------
7439: -- Stage 2 - RM Parameters
7440: -- -----------------------
7441:
7442: l_organization_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7443: (PJI_FM_SUM_MAIN.g_process, 'ORGANIZATION_ID');
7444:
7445: if (nvl(l_organization_id, -1) = -1) then
7446:

Line 7470: l_include_sub_org_flag := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7466: -- ': ' ||
7467: -- l_organization ||
7468: -- l_newline);
7469:
7470: l_include_sub_org_flag := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7471: (PJI_FM_SUM_MAIN.g_process, 'INCLUDE_SUB_ORG');
7472:
7473: if (nvl(l_include_sub_org_flag, 'PJI$NULL') = 'PJI$NULL') then
7474:

Line 7499: l_operating_unit := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7495: -- -----------------------
7496: -- Stage 2 - FM Parameters
7497: -- -----------------------
7498:
7499: l_operating_unit := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7500: (PJI_FM_SUM_MAIN.g_process,'PROJECT_OPERATING_UNIT');
7501:
7502: if (nvl(l_operating_unit, -1) = -1) then
7503:

Line 7526: l_from_project_num := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7522: ': ' ||
7523: l_project_operating_unit_name ||
7524: l_newline);
7525:
7526: l_from_project_num := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7527: (PJI_FM_SUM_MAIN.g_process, 'FROM_PROJECT');
7528:
7529: if (nvl(l_from_project_num,'PJI$NULL') = 'PJI$NULL') then
7530:

Line 7550: l_to_project_num := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7546: ': ' ||
7547: l_from_project ||
7548: l_newline);
7549:
7550: l_to_project_num := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7551: (PJI_FM_SUM_MAIN.g_process, 'TO_PROJECT');
7552:
7553: if (nvl(l_to_project_num, 'PJI$NULL') = 'PJI$NULL') then
7554:

Line 7574: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7570: ': ' ||
7571: l_to_project ||
7572: l_newline);
7573:
7574: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7575: (PJI_FM_SUM_MAIN.g_process, 'PLAN_TYPE_ID');
7576:
7577: if (nvl(l_plan_type_id, -1) = -1) then
7578:

Line 7617: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.FORCE_SUBSEQUENT_RUN(p_worker_id);');

7613: */
7614:
7615: end if;
7616:
7617: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.FORCE_SUBSEQUENT_RUN(p_worker_id);');
7618:
7619: commit;
7620:
7621: end FORCE_SUBSEQUENT_RUN;

Line 7644: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,

7640: PJI_FM_SUM_ACT.CLEANUP(p_worker_id);
7641:
7642: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
7643:
7644: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
7645: 'PJI_FM_AGGR_FIN1',
7646: 'NORMAL',
7647: null);
7648:

Line 7649: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,

7645: 'PJI_FM_AGGR_FIN1',
7646: 'NORMAL',
7647: null);
7648:
7649: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
7650: 'PJI_FM_AGGR_FIN2',
7651: 'NORMAL',
7652: null);
7653:

Line 7654: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,

7650: 'PJI_FM_AGGR_FIN2',
7651: 'NORMAL',
7652: null);
7653:
7654: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
7655: 'PJI_FM_AGGR_ACT1',
7656: 'NORMAL',
7657: null);
7658:

Line 7659: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,

7655: 'PJI_FM_AGGR_ACT1',
7656: 'NORMAL',
7657: null);
7658:
7659: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
7660: 'PJI_FM_AGGR_ACT2',
7661: 'NORMAL',
7662: null);
7663:

Line 7678: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING', 'F');

7674: begin
7675:
7676: rollback;
7677:
7678: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING', 'F');
7679:
7680: commit;
7681:
7682: pji_utils.write2log(sqlerrm, true, 0);

Line 7704: PJI_PROCESS_UTIL.CLEAN_HELPER_BATCH_TABLE;

7700: PJI_FM_DEBUG.CONC_REQUEST_HOOK(l_process);
7701:
7702: PJI_EXTRACTION_UTIL.SEED_PJI_FM_STATS;
7703:
7704: PJI_PROCESS_UTIL.CLEAN_HELPER_BATCH_TABLE;
7705:
7706: PJI_FM_SUM_EXTR.POPULATE_TIME_DIMENSION(p_worker_id);
7707: PJI_EXTRACTION_UTIL.POPULATE_ORG_EXTR_INFO;
7708:

Line 7712: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

7708:
7709: PJI_FM_EXTR.EXTRACT_BATCH_DREV(p_worker_id);
7710:
7711: PJI_FM_EXTR.MARK_EXTRACTED_DREV_PRE(p_worker_id);
7712: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7713: (PJI_FM_SUM_MAIN.g_process,
7714: 'PJI_FM_EXTR.MARK_EXTRACTED_DREV(p_worker_id);',
7715: PJI_FM_SUM_MAIN.g_process_delay)) then
7716: return;

Line 7723: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

7719:
7720: PJI_FM_EXTR.EXTRACT_BATCH_CDL_ROWIDS(p_worker_id);
7721:
7722: PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS_PRE(p_worker_id);
7723: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7724: (PJI_FM_SUM_MAIN.g_process,
7725: 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS(p_worker_id);',
7726: PJI_FM_SUM_MAIN.g_process_delay)) then
7727: return;

Line 7740: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

7736: PJI_FM_EXTR.EXTRACT_BATCH_ERDL(p_worker_id);
7737: PJI_FM_EXTR.EXTRACT_BATCH_FND(p_worker_id);
7738:
7739: PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS_PRE(p_worker_id);
7740: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7741: (PJI_FM_SUM_MAIN.g_process,
7742: 'PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS(p_worker_id);',
7743: PJI_FM_SUM_MAIN.g_process_delay)) then
7744: return;

Line 7754: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

7750: PJI_FM_EXTR.EXTRACT_BATCH_DINVITEM(p_worker_id);
7751: PJI_FM_EXTR.EXTRACT_BATCH_ARINV(p_worker_id);
7752:
7753: PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES_PRE(p_worker_id);
7754: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7755: (PJI_FM_SUM_MAIN.g_process,
7756: 'PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES(p_worker_id);',
7757: PJI_FM_SUM_MAIN.g_process_delay)) then
7758: return;

Line 7765: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

7761:
7762: PJI_FM_SUM_ACT.BASE_SUMMARY(p_worker_id);
7763:
7764: PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT_PRE(p_worker_id);
7765: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7766: (PJI_FM_SUM_MAIN.g_process,
7767: 'PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT(p_worker_id);',
7768: PJI_FM_SUM_MAIN.g_process_delay)) then
7769: return;

Line 7834: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process,

7830:
7831: -- If this helper's concurrent request ID does not exist in the
7832: -- parameters table, the dispatcher must have kicked off a new
7833: -- helper. Therefore do nothing.
7834: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process,
7835: PJI_FM_SUM_MAIN.g_process ||
7836: p_worker_id)
7837: <> FND_GLOBAL.CONC_REQUEST_ID) then
7838: pji_utils.write2log('Warning: Helper is already running.');

Line 7848: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

7844: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
7845:
7846: PJI_FM_DEBUG.CONC_REQUEST_HOOK(l_process);
7847:
7848: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7849: (PJI_FM_SUM_MAIN.g_process,
7850: 'PJI_FM_EXTR.MARK_EXTRACTED_DREV_PRE(p_worker_id);',
7851: PJI_FM_SUM_MAIN.g_process_delay,
7852: 'EVEN_IF_NOT_EXISTS')) then

Line 7853: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7849: (PJI_FM_SUM_MAIN.g_process,
7850: 'PJI_FM_EXTR.MARK_EXTRACTED_DREV_PRE(p_worker_id);',
7851: PJI_FM_SUM_MAIN.g_process_delay,
7852: 'EVEN_IF_NOT_EXISTS')) then
7853: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7854: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7855: null;
7856: else
7857: return;

Line 7863: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

7859: end if;
7860:
7861: PJI_FM_EXTR.MARK_EXTRACTED_DREV(p_worker_id);
7862:
7863: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7864: (PJI_FM_SUM_MAIN.g_process,
7865: 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS_PRE(p_worker_id);',
7866: PJI_FM_SUM_MAIN.g_process_delay)) then
7867: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 7867: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7863: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7864: (PJI_FM_SUM_MAIN.g_process,
7865: 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS_PRE(p_worker_id);',
7866: PJI_FM_SUM_MAIN.g_process_delay)) then
7867: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7868: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7869: null;
7870: else
7871: return;

Line 7877: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

7873: end if;
7874:
7875: PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS(p_worker_id);
7876:
7877: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7878: (PJI_FM_SUM_MAIN.g_process,
7879: 'PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS_PRE(p_worker_id);',
7880: PJI_FM_SUM_MAIN.g_process_delay)) then
7881: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 7881: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7877: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7878: (PJI_FM_SUM_MAIN.g_process,
7879: 'PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS_PRE(p_worker_id);',
7880: PJI_FM_SUM_MAIN.g_process_delay)) then
7881: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7882: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7883: null;
7884: else
7885: return;

Line 7891: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

7887: end if;
7888:
7889: PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS(p_worker_id);
7890:
7891: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7892: (PJI_FM_SUM_MAIN.g_process,
7893: 'PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES_PRE(p_worker_id);',
7894: PJI_FM_SUM_MAIN.g_process_delay)) then
7895: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 7895: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7891: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7892: (PJI_FM_SUM_MAIN.g_process,
7893: 'PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES_PRE(p_worker_id);',
7894: PJI_FM_SUM_MAIN.g_process_delay)) then
7895: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7896: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7897: null;
7898: else
7899: return;

Line 7905: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

7901: end if;
7902:
7903: PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES(p_worker_id);
7904:
7905: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7906: (PJI_FM_SUM_MAIN.g_process,
7907: 'PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT_PRE(p_worker_id);',
7908: PJI_FM_SUM_MAIN.g_process_delay)) then
7909: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 7909: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7905: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7906: (PJI_FM_SUM_MAIN.g_process,
7907: 'PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT_PRE(p_worker_id);',
7908: PJI_FM_SUM_MAIN.g_process_delay)) then
7909: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7910: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7911: null;
7912: else
7913: return;

Line 7919: while (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7915: end if;
7916:
7917: PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT(p_worker_id);
7918:
7919: while (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7920: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'Y') loop
7921: PJI_PROCESS_UTIL.SLEEP(PJI_FM_SUM_MAIN.g_process_delay);
7922: end loop;
7923:

Line 7921: PJI_PROCESS_UTIL.SLEEP(PJI_FM_SUM_MAIN.g_process_delay);

7917: PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT(p_worker_id);
7918:
7919: while (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7920: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'Y') loop
7921: PJI_PROCESS_UTIL.SLEEP(PJI_FM_SUM_MAIN.g_process_delay);
7922: end loop;
7923:
7924: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7925: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'F') then

Line 7924: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7920: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'Y') loop
7921: PJI_PROCESS_UTIL.SLEEP(PJI_FM_SUM_MAIN.g_process_delay);
7922: end loop;
7923:
7924: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7925: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'F') then
7926: return;
7927: end if;
7928:

Line 7929: PJI_PROCESS_UTIL.WRAPUP_PROCESS(l_process);

7925: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'F') then
7926: return;
7927: end if;
7928:
7929: PJI_PROCESS_UTIL.WRAPUP_PROCESS(l_process);
7930:
7931: commit;
7932:
7933: retcode := 0;

Line 7970: PJI_PROCESS_UTIL.ADD_STEPS(l_process, 'PJI_EXTR_HELPER', l_extraction_type);

7966: -- error recovery.
7967:
7968: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
7969:
7970: PJI_PROCESS_UTIL.ADD_STEPS(l_process, 'PJI_EXTR_HELPER', l_extraction_type);
7971:
7972: -- Kick off helper
7973:
7974: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER

Line 7974: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER

7970: PJI_PROCESS_UTIL.ADD_STEPS(l_process, 'PJI_EXTR_HELPER', l_extraction_type);
7971:
7972: -- Kick off helper
7973:
7974: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER
7975: (
7976: PJI_FM_SUM_MAIN.g_process,
7977: l_process,
7978: FND_REQUEST.SUBMIT_REQUEST

Line 7989: if (nvl(to_number(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7985: p_worker_id -- first parameter
7986: )
7987: );
7988:
7989: if (nvl(to_number(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7990: (PJI_FM_SUM_MAIN.g_process, l_process)), 0) = 0) then
7991: fnd_message.set_name('PJI', 'PJI_SUM_NO_SUB_REQ');
7992: dbms_standard.raise_application_error(-20030, fnd_message.get);
7993: end if;

Line 8025: l_request_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

8021: elsif (l_extraction_type = 'PARTIAL') then
8022: l_worker_name := PJI_FM_SUM_MAIN.g_prtl_disp_name;
8023: end if;
8024:
8025: l_request_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
8026: (PJI_FM_SUM_MAIN.g_process,
8027: PJI_FM_SUM_MAIN.g_process);
8028:
8029: else

Line 8035: l_request_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

8031: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
8032:
8033: l_worker_name := PJI_FM_SUM_MAIN.g_helper_name;
8034:
8035: l_request_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
8036: (PJI_FM_SUM_MAIN.g_process, l_process);
8037:
8038: end if;
8039:

Line 8040: return PJI_PROCESS_UTIL.REQUEST_STATUS(p_mode,

8036: (PJI_FM_SUM_MAIN.g_process, l_process);
8037:
8038: end if;
8039:
8040: return PJI_PROCESS_UTIL.REQUEST_STATUS(p_mode,
8041: l_request_id,
8042: l_worker_name);
8043:
8044: end WORKER_STATUS;

Line 8060: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

8056:
8057: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
8058:
8059: l_request_id :=
8060: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
8061: (
8062: PJI_FM_SUM_MAIN.g_process,
8063: l_process
8064: );

Line 8066: PJI_PROCESS_UTIL.WAIT_FOR_REQUEST(l_request_id,

8062: PJI_FM_SUM_MAIN.g_process,
8063: l_process
8064: );
8065:
8066: PJI_PROCESS_UTIL.WAIT_FOR_REQUEST(l_request_id,
8067: PJI_FM_SUM_MAIN.g_process_delay);
8068:
8069: end WAIT_FOR_WORKER;
8070: