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 1803: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.DANGLING_FIN_ROWS(p_worker_id);');

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

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

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

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

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

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

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

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

3207:
3208: 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);
3209: -- End for Bug# 7357456
3210:
3211: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.PURGE_DANGLING_FIN_ROWS(p_worker_id);');
3212:
3213: commit;
3214:
3215: end PURGE_DANGLING_FIN_ROWS;

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

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

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

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

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

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

Line 3272: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process,

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

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

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

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

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

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

4332: tmp1.RECVR_PA_TIME_ID = prj_pa_rt.TIME_ID and
4333: prj_info.PF_CURRENCY_CODE = prj_pa_rt.PF_CURRENCY_CODE
4334: ) tmp1;
4335:
4336: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.FIN_SUMMARY(p_worker_id);');
4337:
4338: -- truncate intermediate tables no longer required
4339: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
4340: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_AGGR_FIN1' , 'NORMAL',null);

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

4336: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.FIN_SUMMARY(p_worker_id);');
4337:
4338: -- truncate intermediate tables no longer required
4339: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
4340: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_AGGR_FIN1' , 'NORMAL',null);
4341:
4342: commit;
4343:
4344: end FIN_SUMMARY;

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

4354: begin
4355:
4356: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
4357:
4358: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.MOVE_DANGLING_FIN_ROWS(p_worker_id);')) then
4359: return;
4360: end if;
4361:
4362: insert into PJI_FM_DNGL_FIN

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

4665: DANGLING_PRVDR_PA_TIME_FLAG is not null or
4666: DANGLING_RECVR_PA_TIME_FLAG is not null or
4667: DANGLING_EXP_PA_TIME_FLAG is not null);
4668:
4669: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.MOVE_DANGLING_FIN_ROWS(p_worker_id);');
4670:
4671: commit;
4672:
4673: end MOVE_DANGLING_FIN_ROWS;

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

4690: begin
4691:
4692: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
4693:
4694: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.ACT_SUMMARY(p_worker_id);')) then
4695: return;
4696: end if;
4697:
4698: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

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

5691: delete
5692: from PJI_FM_AGGR_DLY_RATES
5693: where WORKER_ID = -1;
5694:
5695: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.ACT_SUMMARY(p_worker_id);');
5696:
5697: -- truncate intermediate tables no longer required
5698: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
5699: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_AGGR_ACT1' , 'NORMAL',null);

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

5695: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.ACT_SUMMARY(p_worker_id);');
5696:
5697: -- truncate intermediate tables no longer required
5698: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
5699: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_AGGR_ACT1' , 'NORMAL',null);
5700:
5701: commit;
5702:
5703: end ACT_SUMMARY;

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

5713: begin
5714:
5715: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
5716:
5717: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.MOVE_DANGLING_ACT_ROWS(p_worker_id);')) then
5718: return;
5719: end if;
5720:
5721: insert into PJI_FM_DNGL_ACT

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

6044: DANGLING_EN_TIME_FLAG is not null or
6045: DANGLING_GL_TIME_FLAG is not null or
6046: DANGLING_PA_TIME_FLAG is not null);
6047:
6048: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.MOVE_DANGLING_ACT_ROWS(p_worker_id);');
6049:
6050: commit;
6051:
6052: end MOVE_DANGLING_ACT_ROWS;

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

6063: begin
6064:
6065: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
6066:
6067: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_RES_SLICES(p_worker_id);')) then
6068: return;
6069: end if;
6070:
6071: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

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

6128: EXPENDITURE_ITEM_TIME_ID,
6129: RS_GL_CALENDAR_ID,
6130: RS_PA_CALENDAR_ID;
6131:
6132: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_RES_SLICES(p_worker_id);');
6133:
6134: commit;
6135:
6136: end AGGREGATE_RES_SLICES;

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

6147: begin
6148:
6149: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
6150:
6151: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_FIN_SLICES(p_worker_id);')) then
6152: return;
6153: end if;
6154:
6155: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

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

6392: tmp2.PJ_GL_CALENDAR_ID,
6393: tmp2.PJ_PA_CALENDAR_ID,
6394: tmp2.TXN_CURRENCY_CODE;
6395:
6396: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_FIN_SLICES(p_worker_id);');
6397:
6398: commit;
6399:
6400: end AGGREGATE_FIN_SLICES;

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

6413: begin
6414:
6415: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
6416:
6417: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_ACT_SLICES(p_worker_id);')) then
6418: return;
6419: end if;
6420:
6421: l_pa_calendar_flag := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 6421: l_pa_calendar_flag := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

6417: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_ACT_SLICES(p_worker_id);')) then
6418: return;
6419: end if;
6420:
6421: l_pa_calendar_flag := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
6422: (
6423: PJI_FM_SUM_MAIN.g_process,
6424: 'PA_CALENDAR_FLAG'
6425: );

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

6982: tmp2.GL_CALENDAR_ID,
6983: tmp2.PA_CALENDAR_ID,
6984: tmp2.TXN_CURRENCY_CODE;
6985:
6986: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_ACT_SLICES(p_worker_id);');
6987:
6988: -- truncate intermediate tables no longer required
6989: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
6990: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_AGGR_ACT2' , 'NORMAL',null);

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

6986: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_ACT_SLICES(p_worker_id);');
6987:
6988: -- truncate intermediate tables no longer required
6989: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
6990: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_AGGR_ACT2' , 'NORMAL',null);
6991:
6992: commit;
6993:
6994: end AGGREGATE_ACT_SLICES;

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

7033: begin
7034:
7035: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
7036:
7037: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.FORCE_SUBSEQUENT_RUN(p_worker_id);')) then
7038: return;
7039: end if;
7040:
7041: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

Line 7062: l_organization_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7058: -- -----------------------
7059: -- Stage 2 - RM Parameters
7060: -- -----------------------
7061:
7062: l_organization_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7063: (PJI_FM_SUM_MAIN.g_process, 'ORGANIZATION_ID');
7064:
7065: if (nvl(l_organization_id, -1) = -1) then
7066:

Line 7090: l_include_sub_org_flag := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7086: -- ': ' ||
7087: -- l_organization ||
7088: -- l_newline);
7089:
7090: l_include_sub_org_flag := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7091: (PJI_FM_SUM_MAIN.g_process, 'INCLUDE_SUB_ORG');
7092:
7093: if (nvl(l_include_sub_org_flag, 'PJI$NULL') = 'PJI$NULL') then
7094:

Line 7119: l_operating_unit := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7115: -- -----------------------
7116: -- Stage 2 - FM Parameters
7117: -- -----------------------
7118:
7119: l_operating_unit := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7120: (PJI_FM_SUM_MAIN.g_process,'PROJECT_OPERATING_UNIT');
7121:
7122: if (nvl(l_operating_unit, -1) = -1) then
7123:

Line 7146: l_from_project_num := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7142: ': ' ||
7143: l_project_operating_unit_name ||
7144: l_newline);
7145:
7146: l_from_project_num := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7147: (PJI_FM_SUM_MAIN.g_process, 'FROM_PROJECT');
7148:
7149: if (nvl(l_from_project_num,'PJI$NULL') = 'PJI$NULL') then
7150:

Line 7170: l_to_project_num := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7166: ': ' ||
7167: l_from_project ||
7168: l_newline);
7169:
7170: l_to_project_num := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7171: (PJI_FM_SUM_MAIN.g_process, 'TO_PROJECT');
7172:
7173: if (nvl(l_to_project_num, 'PJI$NULL') = 'PJI$NULL') then
7174:

Line 7194: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7190: ': ' ||
7191: l_to_project ||
7192: l_newline);
7193:
7194: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7195: (PJI_FM_SUM_MAIN.g_process, 'PLAN_TYPE_ID');
7196:
7197: if (nvl(l_plan_type_id, -1) = -1) then
7198:

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

7233: */
7234:
7235: end if;
7236:
7237: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.FORCE_SUBSEQUENT_RUN(p_worker_id);');
7238:
7239: commit;
7240:
7241: end FORCE_SUBSEQUENT_RUN;

Line 7264: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,

7260: PJI_FM_SUM_ACT.CLEANUP(p_worker_id);
7261:
7262: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
7263:
7264: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
7265: 'PJI_FM_AGGR_FIN1',
7266: 'NORMAL',
7267: null);
7268:

Line 7269: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,

7265: 'PJI_FM_AGGR_FIN1',
7266: 'NORMAL',
7267: null);
7268:
7269: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
7270: 'PJI_FM_AGGR_FIN2',
7271: 'NORMAL',
7272: null);
7273:

Line 7274: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,

7270: 'PJI_FM_AGGR_FIN2',
7271: 'NORMAL',
7272: null);
7273:
7274: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
7275: 'PJI_FM_AGGR_ACT1',
7276: 'NORMAL',
7277: null);
7278:

Line 7279: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,

7275: 'PJI_FM_AGGR_ACT1',
7276: 'NORMAL',
7277: null);
7278:
7279: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
7280: 'PJI_FM_AGGR_ACT2',
7281: 'NORMAL',
7282: null);
7283:

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

7294: begin
7295:
7296: rollback;
7297:
7298: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING', 'F');
7299:
7300: commit;
7301:
7302: pji_utils.write2log(sqlerrm, true, 0);

Line 7324: PJI_PROCESS_UTIL.CLEAN_HELPER_BATCH_TABLE;

7320: PJI_FM_DEBUG.CONC_REQUEST_HOOK(l_process);
7321:
7322: PJI_EXTRACTION_UTIL.SEED_PJI_FM_STATS;
7323:
7324: PJI_PROCESS_UTIL.CLEAN_HELPER_BATCH_TABLE;
7325:
7326: PJI_FM_SUM_EXTR.POPULATE_TIME_DIMENSION(p_worker_id);
7327: PJI_EXTRACTION_UTIL.POPULATE_ORG_EXTR_INFO;
7328:

Line 7332: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

7328:
7329: PJI_FM_EXTR.EXTRACT_BATCH_DREV(p_worker_id);
7330:
7331: PJI_FM_EXTR.MARK_EXTRACTED_DREV_PRE(p_worker_id);
7332: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7333: (PJI_FM_SUM_MAIN.g_process,
7334: 'PJI_FM_EXTR.MARK_EXTRACTED_DREV(p_worker_id);',
7335: PJI_FM_SUM_MAIN.g_process_delay)) then
7336: return;

Line 7343: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

7339:
7340: PJI_FM_EXTR.EXTRACT_BATCH_CDL_ROWIDS(p_worker_id);
7341:
7342: PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS_PRE(p_worker_id);
7343: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7344: (PJI_FM_SUM_MAIN.g_process,
7345: 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS(p_worker_id);',
7346: PJI_FM_SUM_MAIN.g_process_delay)) then
7347: return;

Line 7360: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

7356: PJI_FM_EXTR.EXTRACT_BATCH_ERDL(p_worker_id);
7357: PJI_FM_EXTR.EXTRACT_BATCH_FND(p_worker_id);
7358:
7359: PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS_PRE(p_worker_id);
7360: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7361: (PJI_FM_SUM_MAIN.g_process,
7362: 'PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS(p_worker_id);',
7363: PJI_FM_SUM_MAIN.g_process_delay)) then
7364: return;

Line 7374: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

7370: PJI_FM_EXTR.EXTRACT_BATCH_DINVITEM(p_worker_id);
7371: PJI_FM_EXTR.EXTRACT_BATCH_ARINV(p_worker_id);
7372:
7373: PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES_PRE(p_worker_id);
7374: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7375: (PJI_FM_SUM_MAIN.g_process,
7376: 'PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES(p_worker_id);',
7377: PJI_FM_SUM_MAIN.g_process_delay)) then
7378: return;

Line 7385: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

7381:
7382: PJI_FM_SUM_ACT.BASE_SUMMARY(p_worker_id);
7383:
7384: PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT_PRE(p_worker_id);
7385: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7386: (PJI_FM_SUM_MAIN.g_process,
7387: 'PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT(p_worker_id);',
7388: PJI_FM_SUM_MAIN.g_process_delay)) then
7389: return;

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

7450:
7451: -- If this helper's concurrent request ID does not exist in the
7452: -- parameters table, the dispatcher must have kicked off a new
7453: -- helper. Therefore do nothing.
7454: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process,
7455: PJI_FM_SUM_MAIN.g_process ||
7456: p_worker_id)
7457: <> FND_GLOBAL.CONC_REQUEST_ID) then
7458: pji_utils.write2log('Warning: Helper is already running.');

Line 7468: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

7464: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
7465:
7466: PJI_FM_DEBUG.CONC_REQUEST_HOOK(l_process);
7467:
7468: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7469: (PJI_FM_SUM_MAIN.g_process,
7470: 'PJI_FM_EXTR.MARK_EXTRACTED_DREV_PRE(p_worker_id);',
7471: PJI_FM_SUM_MAIN.g_process_delay,
7472: 'EVEN_IF_NOT_EXISTS')) then

Line 7473: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7469: (PJI_FM_SUM_MAIN.g_process,
7470: 'PJI_FM_EXTR.MARK_EXTRACTED_DREV_PRE(p_worker_id);',
7471: PJI_FM_SUM_MAIN.g_process_delay,
7472: 'EVEN_IF_NOT_EXISTS')) then
7473: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7474: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7475: null;
7476: else
7477: return;

Line 7483: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

7479: end if;
7480:
7481: PJI_FM_EXTR.MARK_EXTRACTED_DREV(p_worker_id);
7482:
7483: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7484: (PJI_FM_SUM_MAIN.g_process,
7485: 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS_PRE(p_worker_id);',
7486: PJI_FM_SUM_MAIN.g_process_delay)) then
7487: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 7487: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7483: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7484: (PJI_FM_SUM_MAIN.g_process,
7485: 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS_PRE(p_worker_id);',
7486: PJI_FM_SUM_MAIN.g_process_delay)) then
7487: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7488: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7489: null;
7490: else
7491: return;

Line 7497: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

7493: end if;
7494:
7495: PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS(p_worker_id);
7496:
7497: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7498: (PJI_FM_SUM_MAIN.g_process,
7499: 'PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS_PRE(p_worker_id);',
7500: PJI_FM_SUM_MAIN.g_process_delay)) then
7501: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 7501: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7497: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7498: (PJI_FM_SUM_MAIN.g_process,
7499: 'PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS_PRE(p_worker_id);',
7500: PJI_FM_SUM_MAIN.g_process_delay)) then
7501: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7502: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7503: null;
7504: else
7505: return;

Line 7511: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

7507: end if;
7508:
7509: PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS(p_worker_id);
7510:
7511: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7512: (PJI_FM_SUM_MAIN.g_process,
7513: 'PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES_PRE(p_worker_id);',
7514: PJI_FM_SUM_MAIN.g_process_delay)) then
7515: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 7515: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7511: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7512: (PJI_FM_SUM_MAIN.g_process,
7513: 'PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES_PRE(p_worker_id);',
7514: PJI_FM_SUM_MAIN.g_process_delay)) then
7515: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7516: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7517: null;
7518: else
7519: return;

Line 7525: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

7521: end if;
7522:
7523: PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES(p_worker_id);
7524:
7525: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7526: (PJI_FM_SUM_MAIN.g_process,
7527: 'PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT_PRE(p_worker_id);',
7528: PJI_FM_SUM_MAIN.g_process_delay)) then
7529: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 7529: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7525: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7526: (PJI_FM_SUM_MAIN.g_process,
7527: 'PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT_PRE(p_worker_id);',
7528: PJI_FM_SUM_MAIN.g_process_delay)) then
7529: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7530: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7531: null;
7532: else
7533: return;

Line 7539: while (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7535: end if;
7536:
7537: PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT(p_worker_id);
7538:
7539: while (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7540: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'Y') loop
7541: PJI_PROCESS_UTIL.SLEEP(PJI_FM_SUM_MAIN.g_process_delay);
7542: end loop;
7543:

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

7537: PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT(p_worker_id);
7538:
7539: while (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7540: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'Y') loop
7541: PJI_PROCESS_UTIL.SLEEP(PJI_FM_SUM_MAIN.g_process_delay);
7542: end loop;
7543:
7544: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7545: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'F') then

Line 7544: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7540: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'Y') loop
7541: PJI_PROCESS_UTIL.SLEEP(PJI_FM_SUM_MAIN.g_process_delay);
7542: end loop;
7543:
7544: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7545: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'F') then
7546: return;
7547: end if;
7548:

Line 7549: PJI_PROCESS_UTIL.WRAPUP_PROCESS(l_process);

7545: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'F') then
7546: return;
7547: end if;
7548:
7549: PJI_PROCESS_UTIL.WRAPUP_PROCESS(l_process);
7550:
7551: commit;
7552:
7553: retcode := 0;

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

7586: -- error recovery.
7587:
7588: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
7589:
7590: PJI_PROCESS_UTIL.ADD_STEPS(l_process, 'PJI_EXTR_HELPER', l_extraction_type);
7591:
7592: -- Kick off helper
7593:
7594: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER

Line 7594: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER

7590: PJI_PROCESS_UTIL.ADD_STEPS(l_process, 'PJI_EXTR_HELPER', l_extraction_type);
7591:
7592: -- Kick off helper
7593:
7594: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER
7595: (
7596: PJI_FM_SUM_MAIN.g_process,
7597: l_process,
7598: FND_REQUEST.SUBMIT_REQUEST

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

7605: p_worker_id -- first parameter
7606: )
7607: );
7608:
7609: if (nvl(to_number(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7610: (PJI_FM_SUM_MAIN.g_process, l_process)), 0) = 0) then
7611: fnd_message.set_name('PJI', 'PJI_SUM_NO_SUB_REQ');
7612: dbms_standard.raise_application_error(-20030, fnd_message.get);
7613: end if;

Line 7645: l_request_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7641: elsif (l_extraction_type = 'PARTIAL') then
7642: l_worker_name := PJI_FM_SUM_MAIN.g_prtl_disp_name;
7643: end if;
7644:
7645: l_request_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7646: (PJI_FM_SUM_MAIN.g_process,
7647: PJI_FM_SUM_MAIN.g_process);
7648:
7649: else

Line 7655: l_request_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7651: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
7652:
7653: l_worker_name := PJI_FM_SUM_MAIN.g_helper_name;
7654:
7655: l_request_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7656: (PJI_FM_SUM_MAIN.g_process, l_process);
7657:
7658: end if;
7659:

Line 7660: return PJI_PROCESS_UTIL.REQUEST_STATUS(p_mode,

7656: (PJI_FM_SUM_MAIN.g_process, l_process);
7657:
7658: end if;
7659:
7660: return PJI_PROCESS_UTIL.REQUEST_STATUS(p_mode,
7661: l_request_id,
7662: l_worker_name);
7663:
7664: end WORKER_STATUS;

Line 7680: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

7676:
7677: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
7678:
7679: l_request_id :=
7680: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7681: (
7682: PJI_FM_SUM_MAIN.g_process,
7683: l_process
7684: );

Line 7686: PJI_PROCESS_UTIL.WAIT_FOR_REQUEST(l_request_id,

7682: PJI_FM_SUM_MAIN.g_process,
7683: l_process
7684: );
7685:
7686: PJI_PROCESS_UTIL.WAIT_FOR_REQUEST(l_request_id,
7687: PJI_FM_SUM_MAIN.g_process_delay);
7688:
7689: end WAIT_FOR_WORKER;
7690: