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_PJP_SUM_ROLLUP dependencies on PJI_PJP_SUM_ROLLUP

Line 1: package body PJI_PJP_SUM_ROLLUP as

1: package body PJI_PJP_SUM_ROLLUP as
2: /* $Header: PJISP02B.pls 120.75.12010000.5 2008/12/11 10:03:47 vgovvala ship $ */
3:
4: g_event_id number(15);
5: g_project_id number(15);

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

40: begin
41:
42: l_process := PJI_PJP_SUM_MAIN.g_process || p_worker_id;
43:
44: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_TIME_DIMENSION(p_worker_id);')) then
45: return;
46: end if;
47:
48: PJI_TIME_C.LOAD(null, null, l_return_status, l_msg_count, l_msg_data);

Line 50: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_TIME_DIMENSION(p_worker_id);');

46: end if;
47:
48: PJI_TIME_C.LOAD(null, null, l_return_status, l_msg_count, l_msg_data);
49:
50: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_TIME_DIMENSION(p_worker_id);');
51:
52: commit;
53:
54: end POPULATE_TIME_DIMENSION;

Line 312: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_EVENTS_SNAPSHOT(p_worker_id);')) then

308: begin
309:
310: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
311:
312: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_EVENTS_SNAPSHOT(p_worker_id);')) then
313: return;
314: end if;
315:
316: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 1104: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_EVENTS_SNAPSHOT(p_worker_id);');

1100: ATTRIBUTE16 = 'N';
1101:
1102: end if;
1103:
1104: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_EVENTS_SNAPSHOT(p_worker_id);');
1105:
1106: commit;
1107:
1108: end CREATE_EVENTS_SNAPSHOT;

Line 1147: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.PROCESS_RBS_CHANGES(p_worker_id);')) then

1143: begin
1144:
1145: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
1146:
1147: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.PROCESS_RBS_CHANGES(p_worker_id);')) then
1148: return;
1149: end if;
1150:
1151: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 1168: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PROCESS_RBS_CHANGES(p_worker_id);');

1164: end loop;
1165:
1166: end if;
1167:
1168: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PROCESS_RBS_CHANGES(p_worker_id);');
1169:
1170: commit;
1171:
1172: end PROCESS_RBS_CHANGES;

Line 1210: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_MAPPING_RULES(p_worker_id);')) then

1206: begin
1207:
1208: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
1209:
1210: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_MAPPING_RULES(p_worker_id);')) then
1211: return;
1212: end if;
1213:
1214: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 1230: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_MAPPING_RULES(p_worker_id);');

1226: end;
1227:
1228: end loop;
1229:
1230: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_MAPPING_RULES(p_worker_id);');
1231:
1232: commit;
1233:
1234: end CREATE_MAPPING_RULES;

Line 1261: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.MAP_RBS_HEADERS(p_worker_id);')) then

1257: begin
1258:
1259: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
1260:
1261: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.MAP_RBS_HEADERS(p_worker_id);')) then
1262: return;
1263: end if;
1264:
1265: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 1276: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.MAP_RBS_HEADERS(p_worker_id);');

1272: exception when others then
1273: PJI_UTILS.WRITE2LOG('MAP_RBS_HEADERS:' || SQLERRM);
1274: end;
1275:
1276: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.MAP_RBS_HEADERS(p_worker_id);');
1277:
1278: commit;
1279:
1280: end MAP_RBS_HEADERS;

Line 1315: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_XBS_DENORM_FULL(p_worker_id);')) then

1311: l_last_update_login := FND_GLOBAL.LOGIN_ID;
1312:
1313: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
1314:
1315: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_XBS_DENORM_FULL(p_worker_id);')) then
1316: return;
1317: end if;
1318:
1319: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 1453: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_XBS_DENORM_FULL(p_worker_id);');

1449: -- where map.WORKER_ID = p_worker_id);
1450:
1451: end if;
1452:
1453: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_XBS_DENORM_FULL(p_worker_id);');
1454:
1455: commit;
1456:
1457: end UPDATE_XBS_DENORM_FULL;

Line 1484: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.LOCK_HEADERS(p_worker_id);')) then

1480: begin
1481:
1482: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
1483:
1484: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.LOCK_HEADERS(p_worker_id);')) then
1485: return;
1486: end if;
1487:
1488: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 1505: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.LOCK_HEADERS(p_worker_id);');

1501: , x_return_status => l_return_status
1502: , x_msg_code => l_msg_code
1503: );
1504:
1505: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.LOCK_HEADERS(p_worker_id);');
1506:
1507: commit;
1508:
1509: end LOCK_HEADERS;

Line 1536: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_PROGRAM_WBS(p_worker_id);')) then

1532: begin
1533:
1534: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
1535:
1536: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_PROGRAM_WBS(p_worker_id);')) then
1537: return;
1538: end if;
1539:
1540: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 1702: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_PROGRAM_WBS(p_worker_id);');

1698: PROJECT_ID;
1699:
1700: end if;
1701:
1702: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_PROGRAM_WBS(p_worker_id);');
1703:
1704: commit;
1705:
1706: end UPDATE_PROGRAM_WBS;

Line 1729: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.PURGE_EVENT_DATA(p_worker_id);')) then

1725: begin
1726:
1727: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
1728:
1729: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.PURGE_EVENT_DATA(p_worker_id);')) then
1730: return;
1731: end if;
1732:
1733: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 1820: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PURGE_EVENT_DATA(p_worker_id);');

1816: log.EVENT_OBJECT);
1817:
1818: end if;
1819:
1820: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PURGE_EVENT_DATA(p_worker_id);');
1821:
1822: commit;
1823:
1824: end PURGE_EVENT_DATA;

Line 1957: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_PROGRAM_RBS(p_worker_id);')) then

1953: begin
1954:
1955: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
1956:
1957: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_PROGRAM_RBS(p_worker_id);')) then
1958: return;
1959: end if;
1960:
1961: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 2451: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_PROGRAM_RBS(p_worker_id);');

2447: end if;
2448:
2449: end if;
2450:
2451: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_PROGRAM_RBS(p_worker_id);');
2452:
2453: commit;
2454:
2455: end UPDATE_PROGRAM_RBS;

Line 2530: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_XBS_DENORM_DELTA(p_worker_id);')) then

2526: if (p_worker_id is not null) then
2527:
2528: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
2529:
2530: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_XBS_DENORM_DELTA(p_worker_id);')) then
2531: return;
2532: end if;
2533:
2534: l_last_update_date := sysdate;

Line 2967: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_XBS_DENORM_DELTA(p_worker_id);');

2963: end if;
2964:
2965: end if;
2966:
2967: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_XBS_DENORM_DELTA(p_worker_id);');
2968:
2969: commit;
2970:
2971: else -- online mode

Line 3107: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_RBS_DENORM_DELTA(p_worker_id);')) then

3103: begin
3104:
3105: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
3106:
3107: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_RBS_DENORM_DELTA(p_worker_id);')) then
3108: return;
3109: end if;
3110:
3111: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 3192: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_RBS_DENORM_DELTA(p_worker_id);');

3188: sum(SIGN) <> 0;
3189:
3190: end if;
3191:
3192: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_RBS_DENORM_DELTA(p_worker_id);');
3193:
3194: commit;
3195:
3196: end POPULATE_RBS_DENORM_DELTA;

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

3225: begin
3226:
3227: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
3228:
3229: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_FP_SLICES(p_worker_id);')) then
3230: return;
3231: end if;
3232:
3233: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 3246: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_FP_SLICES(p_worker_id);');

3242: end if;
3243:
3244: -- If condtion is true then mark the process as completed and return
3245: if ( l_extraction_type='PARTIAL' and ( bitand(l_refresh_code,1) <> 1) ) then
3246: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_FP_SLICES(p_worker_id);');
3247: commit;
3248: return;
3249: end if;
3250:

Line 4340: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_FP_SLICES(p_worker_id);');

4336: src.RBS_VERSION_ID,
4337: src.PLAN_VERSION_ID,
4338: src.PLAN_TYPE_ID;
4339:
4340: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_FP_SLICES(p_worker_id);');
4341:
4342: commit;
4343:
4344: end AGGREGATE_FP_SLICES;

Line 4378: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_AC_SLICES(p_worker_id);')) then

4374: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
4375:
4376: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
4377:
4378: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_AC_SLICES(p_worker_id);')) then
4379: return;
4380: end if;
4381:
4382: -- Bug#5099574 - Start

Line 4393: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_AC_SLICES(p_worker_id);');

4389: end if;
4390:
4391: -- If the condtion is true then mark the process as completed and return
4392: if ( l_extraction_type='PARTIAL' and ( l_plan_type_id is not null or bitand(l_refresh_code,1) <> 1) ) then
4393: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_AC_SLICES(p_worker_id);');
4394: commit;
4395: return;
4396: end if;
4397:

Line 5004: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_AC_SLICES(p_worker_id);');

5000: nvl(CURRENCY_CODE, 'PJI$NULL');
5001:
5002: end if;
5003:
5004: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_AC_SLICES(p_worker_id);');
5005:
5006: commit;
5007:
5008: end AGGREGATE_AC_SLICES;

Line 5031: l_err_msg VARCHAR2(100):= 'Error in PJI_PJP_SUM_ROLLUP.MARK_EXTRACTED_PROJECTS -> PJI_FM_PLAN_MAINT.POPULATE_FIN8';

5027: l_last_update_login number;
5028:
5029: l_return_status varchar2(255) := FND_API.G_RET_STS_SUCCESS;
5030: l_msg_data varchar2(2000);
5031: l_err_msg VARCHAR2(100):= 'Error in PJI_PJP_SUM_ROLLUP.MARK_EXTRACTED_PROJECTS -> PJI_FM_PLAN_MAINT.POPULATE_FIN8';
5032:
5033: begin
5034:
5035: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);

Line 5037: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.MARK_EXTRACTED_PROJECTS(p_worker_id);')) then

5033: begin
5034:
5035: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
5036:
5037: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.MARK_EXTRACTED_PROJECTS(p_worker_id);')) then
5038: return;
5039: end if;
5040:
5041: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 5145: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.MARK_EXTRACTED_PROJECTS(p_worker_id);');

5141: dbms_standard.raise_application_error(-20105, l_err_msg);
5142: END IF;
5143:
5144:
5145: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.MARK_EXTRACTED_PROJECTS(p_worker_id);');
5146:
5147: commit;
5148:
5149: end MARK_EXTRACTED_PROJECTS;

Line 5178: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_FP_CUST_SLICES(p_worker_id);')) then

5174:
5175: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
5176: l_refresh_code := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'REFRESH_CODE'); -- Bug#5099574
5177:
5178: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_FP_CUST_SLICES(p_worker_id);')) then
5179: return;
5180: end if;
5181:
5182: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 5846: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_FP_CUST_SLICES(p_worker_id);');

5842: if ( l_extraction_type = 'PARTIAL' ) then -- Partial Refresh Performance Improvement
5843: delete from PJI_FM_EXTR_PLNVER3_T where worker_id=p_worker_id;
5844: end if;
5845:
5846: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_FP_CUST_SLICES(p_worker_id);');
5847:
5848: commit;
5849:
5850: end AGGREGATE_FP_CUST_SLICES;

Line 5872: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_AC_CUST_SLICES(p_worker_id);')) then

5868: begin
5869:
5870: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
5871:
5872: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_AC_CUST_SLICES(p_worker_id);')) then
5873: return;
5874: end if;
5875:
5876: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 6986: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_AC_CUST_SLICES(p_worker_id);');

6982: nvl(sum(CUSTOM14), 0) = 0 and
6983: nvl(sum(CUSTOM15), 0) = 0);
6984: end if;
6985:
6986: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_AC_CUST_SLICES(p_worker_id);');
6987:
6988: commit;
6989:
6990: end AGGREGATE_AC_CUST_SLICES;

Line 7015: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.PULL_DANGLING_PLANS(p_worker_id);')) then

7011: begin
7012:
7013: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
7014:
7015: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.PULL_DANGLING_PLANS(p_worker_id);')) then
7016: return;
7017: end if;
7018:
7019: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 7026: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PULL_DANGLING_PLANS(p_worker_id);');

7022: Pji_Fm_Plan_Maint.CREATE_SECONDARY_PVT;
7023: -- PJI_FM_PLAN_MAINT_PVT.PULL_DANGLING_PLANS; -- Removing redundant api nesting.
7024: END IF;
7025:
7026: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PULL_DANGLING_PLANS(p_worker_id);');
7027:
7028: commit;
7029:
7030: end PULL_DANGLING_PLANS;

Line 7057: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.PULL_PLANS_FOR_PR(p_worker_id);')) then

7053: begin
7054:
7055: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
7056:
7057: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.PULL_PLANS_FOR_PR(p_worker_id);')) then
7058: return;
7059: end if;
7060:
7061: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 7080: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PULL_PLANS_FOR_PR(p_worker_id);');

7076: l_msg_code);
7077:
7078: end if;
7079:
7080: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PULL_PLANS_FOR_PR(p_worker_id);');
7081:
7082: commit;
7083:
7084: end PULL_PLANS_FOR_PR;

Line 7113: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.PULL_PLANS_FOR_RBS(p_worker_id);')) then

7109: begin
7110:
7111: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
7112:
7113: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.PULL_PLANS_FOR_RBS(p_worker_id);')) then
7114: return;
7115: end if;
7116:
7117: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 7132: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PULL_PLANS_FOR_RBS(p_worker_id);');

7128: l_msg_code);
7129:
7130: end if;
7131:
7132: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PULL_PLANS_FOR_RBS(p_worker_id);');
7133:
7134: commit;
7135:
7136: end PULL_PLANS_FOR_RBS;

Line 7157: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_TOP(p_worker_id);')) then

7153: begin
7154:
7155: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
7156:
7157: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_TOP(p_worker_id);')) then
7158: return;
7159: end if;
7160:
7161: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 7545: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_TOP(p_worker_id);');

7541: pjp1.PLAN_VERSION_ID,
7542: pjp1.PLAN_TYPE_ID,
7543: pjp1.PLAN_TYPE_CODE;
7544:
7545: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_TOP(p_worker_id);');
7546:
7547: commit;
7548:
7549: end ROLLUP_FPR_RBS_TOP;

Line 7579: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_WBS(p_worker_id);')) then

7575: if (p_worker_id is not null) then
7576:
7577: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
7578:
7579: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_WBS(p_worker_id);')) then
7580: return;
7581: end if;
7582:
7583: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 7601: STEP_NAME = 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_WBS(p_worker_id);';

7597: from
7598: PJI_SYSTEM_PRC_STATUS
7599: where
7600: PROCESS_NAME = l_process and
7601: STEP_NAME = 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_WBS(p_worker_id);';
7602:
7603: select
7604: count(*)
7605: into

Line 9028: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_WBS(p_worker_id);');

9024: end if;
9025:
9026: end loop;
9027:
9028: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_WBS(p_worker_id);');
9029:
9030: commit;
9031:
9032: else -- online mode

Line 11113: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_SMART_SLICES(p_worker_id);')) then

11109: if (p_worker_id is not null) then
11110:
11111: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
11112:
11113: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_SMART_SLICES(p_worker_id);')) then
11114: return;
11115: end if;
11116:
11117: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 11567: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_SMART_SLICES(p_worker_id);');

11563: pjp1.PLAN_VERSION_ID,
11564: pjp1.PLAN_TYPE_ID,
11565: pjp1.PLAN_TYPE_CODE;
11566:
11567: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_SMART_SLICES(p_worker_id);');
11568:
11569: commit;
11570:
11571: else -- online mode

Line 12052: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_WBS(p_worker_id);')) then

12048: if (p_worker_id is not null) then
12049:
12050: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
12051:
12052: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_WBS(p_worker_id);')) then
12053: return;
12054: end if;
12055:
12056: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 12068: STEP_NAME = 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_WBS(p_worker_id);';

12064: from
12065: PJI_SYSTEM_PRC_STATUS
12066: where
12067: PROCESS_NAME = l_process and
12068: STEP_NAME = 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_WBS(p_worker_id);';
12069:
12070: select
12071: count(*)
12072: into

Line 12759: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_WBS(p_worker_id);');

12755: end if;
12756:
12757: end loop;
12758:
12759: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_WBS(p_worker_id);');
12760:
12761: commit;
12762:
12763: else -- online mode

Line 13387: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_PRG(p_worker_id);')) then

13383: begin
13384:
13385: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
13386:
13387: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_PRG(p_worker_id);')) then
13388: return;
13389: end if;
13390:
13391: l_prg_exists := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 13396: 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_PRG(p_worker_id);');

13392: (l_process, 'PROGRAM_EXISTS');
13393:
13394: if (l_prg_exists = 'N') then
13395: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process,
13396: 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_PRG(p_worker_id);');
13397: commit;
13398: return;
13399: end if;
13400:

Line 13413: STEP_NAME = 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_PRG(p_worker_id);';

13409: from
13410: PJI_SYSTEM_PRC_STATUS
13411: where
13412: PROCESS_NAME = l_process and
13413: STEP_NAME = 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_PRG(p_worker_id);';
13414:
13415: select
13416: count(*)
13417: into

Line 14594: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_PRG(p_worker_id);');

14590: end if;
14591:
14592: end loop;
14593:
14594: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_PRG(p_worker_id);');
14595:
14596: commit;
14597:
14598: end ROLLUP_FPR_PRG;

Line 14625: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_PRG(p_worker_id);')) then

14621: begin
14622:
14623: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
14624:
14625: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_PRG(p_worker_id);')) then
14626: return;
14627: end if;
14628:
14629: l_prg_exists := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 14634: 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_PRG(p_worker_id);');

14630: (l_process, 'PROGRAM_EXISTS');
14631:
14632: if (l_prg_exists = 'N') then
14633: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process,
14634: 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_PRG(p_worker_id);');
14635: commit;
14636: return;
14637: end if;
14638:

Line 14651: STEP_NAME = 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_PRG(p_worker_id);';

14647: from
14648: PJI_SYSTEM_PRC_STATUS
14649: where
14650: PROCESS_NAME = l_process and
14651: STEP_NAME = 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_PRG(p_worker_id);';
14652:
14653: select
14654: count(*)
14655: into

Line 15129: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_PRG(p_worker_id);');

15125: end if;
15126:
15127: end loop;
15128:
15129: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_PRG(p_worker_id);');
15130:
15131: commit;
15132:
15133: end ROLLUP_ACR_PRG;

Line 15160: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_NONTP(p_worker_id);')) then

15156: begin
15157:
15158: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
15159:
15160: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_NONTP(p_worker_id);')) then
15161: return;
15162: end if;
15163:
15164: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 15168: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_NONTP(p_worker_id);');

15164: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
15165:
15166: PJI_FM_PLAN_CAL_RLPS.CREATE_FP_NONTP_ROLLUP;
15167:
15168: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_NONTP(p_worker_id);');
15169:
15170: commit;
15171:
15172: end ROLLUP_FPR_CAL_NONTP;

Line 15199: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_PA(p_worker_id);')) then

15195: begin
15196:
15197: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
15198:
15199: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_PA(p_worker_id);')) then
15200: return;
15201: end if;
15202:
15203: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 15207: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_PA(p_worker_id);');

15203: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
15204:
15205: PJI_FM_PLAN_CAL_RLPS.CREATE_FP_PA_ROLLUP;
15206:
15207: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_PA(p_worker_id);');
15208:
15209: commit;
15210:
15211: end ROLLUP_FPR_CAL_PA;

Line 15238: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_GL(p_worker_id);')) then

15234: begin
15235:
15236: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
15237:
15238: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_GL(p_worker_id);')) then
15239: return;
15240: end if;
15241:
15242: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 15246: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_GL(p_worker_id);');

15242: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
15243:
15244: PJI_FM_PLAN_CAL_RLPS.CREATE_FP_GL_ROLLUP;
15245:
15246: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_GL(p_worker_id);');
15247:
15248: commit;
15249:
15250: end ROLLUP_FPR_CAL_GL;

Line 15277: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_EN(p_worker_id);')) then

15273: begin
15274:
15275: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
15276:
15277: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_EN(p_worker_id);')) then
15278: return;
15279: end if;
15280:
15281: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 15285: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_EN(p_worker_id);');

15281: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
15282:
15283: PJI_FM_PLAN_CAL_RLPS.CREATE_FP_ENT_ROLLUP;
15284:
15285: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_EN(p_worker_id);');
15286:
15287: commit;
15288:
15289: end ROLLUP_FPR_CAL_EN;

Line 15316: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_ALL(p_worker_id);')) then

15312: begin
15313:
15314: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
15315:
15316: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_ALL(p_worker_id);')) then
15317: return;
15318: end if;
15319:
15320: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 15326: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_ALL(p_worker_id);');

15322: -- Changes done for bug 6381284
15323: --PJI_FM_PLAN_CAL_RLPS.CREATE_FP_ALL_T_PRI_ROLLUP('G');
15324: PJI_FM_PLAN_CAL_RLPS.CREATE_FP_ALL_T_PRI_ROLLUP('C');
15325:
15326: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_CAL_ALL(p_worker_id);');
15327:
15328: commit;
15329:
15330: end ROLLUP_FPR_CAL_ALL;

Line 15355: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_PA(p_worker_id);')) then

15351: begin
15352:
15353: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
15354:
15355: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_PA(p_worker_id);')) then
15356: return;
15357: end if;
15358:
15359: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 15363: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_PA(p_worker_id);');

15359: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
15360:
15361: PJI_FM_PLAN_CAL_RLPS.CREATE_AC_PA_ROLLUP;
15362:
15363: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_PA(p_worker_id);');
15364:
15365: commit;
15366:
15367: end ROLLUP_ACR_CAL_PA;

Line 15392: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_GL(p_worker_id);')) then

15388: begin
15389:
15390: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
15391:
15392: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_GL(p_worker_id);')) then
15393: return;
15394: end if;
15395:
15396: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 15400: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_GL(p_worker_id);');

15396: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
15397:
15398: PJI_FM_PLAN_CAL_RLPS.CREATE_AC_GL_ROLLUP;
15399:
15400: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_GL(p_worker_id);');
15401:
15402: commit;
15403:
15404: end ROLLUP_ACR_CAL_GL;

Line 15429: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_EN(p_worker_id);')) then

15425: begin
15426:
15427: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
15428:
15429: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_EN(p_worker_id);')) then
15430: return;
15431: end if;
15432:
15433: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 15437: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_EN(p_worker_id);');

15433: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
15434:
15435: PJI_FM_PLAN_CAL_RLPS.CREATE_AC_ENT_ROLLUP;
15436:
15437: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_EN(p_worker_id);');
15438:
15439: commit;
15440:
15441: end ROLLUP_ACR_CAL_EN;

Line 15466: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_ALL(p_worker_id);')) then

15462: begin
15463:
15464: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
15465:
15466: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_ALL(p_worker_id);')) then
15467: return;
15468: end if;
15469:
15470: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 15474: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_ALL(p_worker_id);');

15470: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
15471:
15472: PJI_FM_PLAN_CAL_RLPS.CREATE_AC_ALL_T_PRI_ROLLUP('G');
15473:
15474: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_ACR_CAL_ALL(p_worker_id);');
15475:
15476: commit;
15477:
15478: end ROLLUP_ACR_CAL_ALL;

Line 15502: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_PLAN_DATA(p_worker_id);')) then

15498: begin
15499:
15500: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
15501:
15502: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_PLAN_DATA(p_worker_id);')) then
15503: return;
15504: end if;
15505:
15506: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 15924: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_PLAN_DATA(p_worker_id);');

15920: nvl(sum(CUSTOM15), 0) = 0);
15921:
15922: end if;
15923:
15924: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.AGGREGATE_PLAN_DATA(p_worker_id);');
15925:
15926: commit;
15927:
15928: end AGGREGATE_PLAN_DATA;

Line 15951: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.PURGE_PLAN_DATA(p_worker_id);')) then

15947: begin
15948:
15949: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
15950:
15951: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.PURGE_PLAN_DATA(p_worker_id);')) then
15952: return;
15953: end if;
15954:
15955: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 15971: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PURGE_PLAN_DATA(p_worker_id);');

15967: nvl(pjp1.RECORD_TYPE, 'X') <> 'A';
15968:
15969: end if;
15970:
15971: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PURGE_PLAN_DATA(p_worker_id);');
15972:
15973: commit;
15974:
15975: end PURGE_PLAN_DATA;

Line 16002: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.GET_FPR_ROWIDS(p_worker_id);')) then

15998: begin
15999:
16000: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
16001:
16002: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.GET_FPR_ROWIDS(p_worker_id);')) then
16003: return;
16004: end if;
16005:
16006: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 16010: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.GET_FPR_ROWIDS(p_worker_id);');

16006: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
16007:
16008: PJI_FM_PLAN_MAINT_PVT.GET_FP_ROW_IDS;
16009:
16010: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.GET_FPR_ROWIDS(p_worker_id);');
16011:
16012: commit;
16013:
16014: end GET_FPR_ROWIDS;

Line 16041: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_FPR_ROWS(p_worker_id);')) then

16037: begin
16038:
16039: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
16040:
16041: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_FPR_ROWS(p_worker_id);')) then
16042: return;
16043: end if;
16044:
16045: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 16049: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_FPR_ROWS(p_worker_id);');

16045: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
16046:
16047: PJI_FM_PLAN_MAINT_PVT.UPDATE_FP_ROWS;
16048:
16049: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_FPR_ROWS(p_worker_id);');
16050:
16051: commit;
16052:
16053: end UPDATE_FPR_ROWS;

Line 16080: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.INSERT_FPR_ROWS(p_worker_id);')) then

16076: begin
16077:
16078: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
16079:
16080: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.INSERT_FPR_ROWS(p_worker_id);')) then
16081: return;
16082: end if;
16083:
16084: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 16088: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.INSERT_FPR_ROWS(p_worker_id);');

16084: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
16085:
16086: PJI_FM_PLAN_MAINT_PVT.INSERT_FP_ROWS;
16087:
16088: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.INSERT_FPR_ROWS(p_worker_id);');
16089:
16090: commit;
16091:
16092: end INSERT_FPR_ROWS;

Line 16119: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.CLEANUP_FPR_ROWID_TABLE(p_worker_id);')) then

16115: begin
16116:
16117: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
16118:
16119: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.CLEANUP_FPR_ROWID_TABLE(p_worker_id);')) then
16120: return;
16121: end if;
16122:
16123: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 16127: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CLEANUP_FPR_ROWID_TABLE(p_worker_id);');

16123: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
16124:
16125: -- PJI_FM_PLAN_MAINT_PVT.CLEANUP_FP_RMAP_FPR;
16126:
16127: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CLEANUP_FPR_ROWID_TABLE(p_worker_id);');
16128:
16129: commit;
16130:
16131: end CLEANUP_FPR_ROWID_TABLE;

Line 16156: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.GET_ACR_ROWIDS(p_worker_id);')) then

16152: begin
16153:
16154: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
16155:
16156: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.GET_ACR_ROWIDS(p_worker_id);')) then
16157: return;
16158: end if;
16159:
16160: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 16170: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.GET_ACR_ROWIDS(p_worker_id);');

16166: PJI_FM_PLAN_MAINT_PVT.GET_AC_ROW_IDS;
16167:
16168: end if;
16169:
16170: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.GET_ACR_ROWIDS(p_worker_id);');
16171:
16172: commit;
16173:
16174: end GET_ACR_ROWIDS;

Line 16199: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_ACR_ROWS(p_worker_id);')) then

16195: begin
16196:
16197: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
16198:
16199: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_ACR_ROWS(p_worker_id);')) then
16200: return;
16201: end if;
16202:
16203: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 16213: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_ACR_ROWS(p_worker_id);');

16209: PJI_FM_PLAN_MAINT_PVT.UPDATE_AC_ROWS;
16210:
16211: end if;
16212:
16213: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_ACR_ROWS(p_worker_id);');
16214:
16215: commit;
16216:
16217: end UPDATE_ACR_ROWS;

Line 16242: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.INSERT_ACR_ROWS(p_worker_id);')) then

16238: begin
16239:
16240: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
16241:
16242: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.INSERT_ACR_ROWS(p_worker_id);')) then
16243: return;
16244: end if;
16245:
16246: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 16260: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.INSERT_ACR_ROWS(p_worker_id);');

16256: PJI_FM_PLAN_MAINT_PVT.INSERT_AC_ROWS;
16257:
16258: end if;
16259:
16260: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.INSERT_ACR_ROWS(p_worker_id);');
16261:
16262: commit;
16263:
16264: end INSERT_ACR_ROWS;

Line 16289: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.CLEANUP_ACR_ROWID_TABLE(p_worker_id);')) then

16285: begin
16286:
16287: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
16288:
16289: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.CLEANUP_ACR_ROWID_TABLE(p_worker_id);')) then
16290: return;
16291: end if;
16292:
16293: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 16303: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CLEANUP_ACR_ROWID_TABLE(p_worker_id);');

16299: -- PJI_FM_PLAN_MAINT_PVT.CLEANUP_AC_RMAP_FPR;
16300: --
16301: -- end if;
16302:
16303: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CLEANUP_ACR_ROWID_TABLE(p_worker_id);');
16304:
16305: commit;
16306:
16307: end CLEANUP_ACR_ROWID_TABLE;

Line 16345: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_XBS_DENORM(p_worker_id);')) then

16341: if (p_worker_id is not null) then
16342:
16343: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
16344:
16345: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_XBS_DENORM(p_worker_id);')) then
16346: return;
16347: end if;
16348:
16349: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 16654: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_XBS_DENORM(p_worker_id);');

16650: -- where map.WORKER_ID = p_worker_id);
16651:
16652: end if;
16653:
16654: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_XBS_DENORM(p_worker_id);');
16655:
16656: commit;
16657:
16658: else -- online mode

Line 16831: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_RBS_DENORM(p_worker_id);')) then

16827: if (p_worker_id is not null) then
16828:
16829: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
16830:
16831: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_RBS_DENORM(p_worker_id);')) then
16832: return;
16833: end if;
16834:
16835: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 17003: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_RBS_DENORM(p_worker_id);');

16999: den.STRUCT_VERSION_ID = log.EVENT_OBJECT;
17000:
17001: end if;
17002:
17003: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_RBS_DENORM(p_worker_id);');
17004:
17005: commit;
17006:
17007: else -- online mode

Line 17074: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.PROCESS_PENDING_EVENTS(p_worker_id);')) then

17070: begin
17071:
17072: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17073:
17074: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.PROCESS_PENDING_EVENTS(p_worker_id);')) then
17075: return;
17076: end if;
17077:
17078: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 17087: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PROCESS_PENDING_EVENTS(p_worker_id);');

17083: exception when others then
17084: PJI_UTILS.WRITE2LOG('PROCESS_PENDING_EVENTS:' || SQLERRM);
17085: end;
17086:
17087: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PROCESS_PENDING_EVENTS(p_worker_id);');
17088:
17089: commit;
17090:
17091: end PROCESS_PENDING_EVENTS;

Line 17116: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.PROCESS_PENDING_PLAN_UPDATES(p_worker_id);')) then

17112: begin
17113:
17114: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17115:
17116: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.PROCESS_PENDING_PLAN_UPDATES(p_worker_id);')) then
17117: return;
17118: end if;
17119:
17120: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 17126: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PROCESS_PENDING_PLAN_UPDATES(p_worker_id);');

17122: PJI_FM_PLAN_MAINT_PVT.PROCESS_PENDING_PLAN_UPDATES(l_extraction_type,
17123: l_return_status,
17124: l_msg_data);
17125:
17126: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.PROCESS_PENDING_PLAN_UPDATES(p_worker_id);');
17127:
17128: commit;
17129:
17130: end PROCESS_PENDING_PLAN_UPDATES;

Line 17167: l_err_msg1 VARCHAR2(100):= 'Error in PJI_PJP_SUM_ROLLUP.GET_PLANRES_ACTUALS -> PA_PROGRESS_PUB.GET_SUMMARIZED_ACTUALS';

17163: l_msg_data varchar2(2000);
17164: l_ret_msg_data varchar2(2000);
17165: l_ret_status varchar2(255);
17166: l_success varchar2(1) := 'Y';
17167: l_err_msg1 VARCHAR2(100):= 'Error in PJI_PJP_SUM_ROLLUP.GET_PLANRES_ACTUALS -> PA_PROGRESS_PUB.GET_SUMMARIZED_ACTUALS';
17168: l_err_msg2 VARCHAR2(100):= 'Error in PJI_PJP_SUM_ROLLUP.GET_PLANRES_ACTUALS -> PJI_FM_PLAN_MAINT.GET_ACTUALS_SUMM';
17169:
17170: begin
17171:

Line 17168: l_err_msg2 VARCHAR2(100):= 'Error in PJI_PJP_SUM_ROLLUP.GET_PLANRES_ACTUALS -> PJI_FM_PLAN_MAINT.GET_ACTUALS_SUMM';

17164: l_ret_msg_data varchar2(2000);
17165: l_ret_status varchar2(255);
17166: l_success varchar2(1) := 'Y';
17167: l_err_msg1 VARCHAR2(100):= 'Error in PJI_PJP_SUM_ROLLUP.GET_PLANRES_ACTUALS -> PA_PROGRESS_PUB.GET_SUMMARIZED_ACTUALS';
17168: l_err_msg2 VARCHAR2(100):= 'Error in PJI_PJP_SUM_ROLLUP.GET_PLANRES_ACTUALS -> PJI_FM_PLAN_MAINT.GET_ACTUALS_SUMM';
17169:
17170: begin
17171:
17172: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);

Line 17175: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.GET_PLANRES_ACTUALS(p_worker_id);')) then

17171:
17172: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17173: l_ret_status := FND_API.G_RET_STS_SUCCESS;
17174:
17175: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.GET_PLANRES_ACTUALS(p_worker_id);')) then
17176: return;
17177: end if;
17178:
17179: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 17278: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.GET_PLANRES_ACTUALS(p_worker_id);');

17274: IF (l_return_status <> FND_API.G_RET_STS_SUCCESS) THEN
17275: dbms_standard.raise_application_error(-20120, l_err_msg2);
17276: END IF;
17277:
17278: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.GET_PLANRES_ACTUALS(p_worker_id);');
17279:
17280: commit;
17281:
17282: end GET_PLANRES_ACTUALS;

Line 17332: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.GET_TASK_ROLLUP_ACTUALS(p_worker_id);')) then

17328:
17329:
17330: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17331:
17332: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.GET_TASK_ROLLUP_ACTUALS(p_worker_id);')) then
17333: return;
17334: end if;
17335:
17336: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 17381: dbms_standard.raise_application_error(-20130, 'Error in PJI_PJP_SUM_ROLLUP.GET_TASK_ROLLUP_ACTUALS -> PA_PROGRESS_PUB.GET_SUMMARIZED_ACTUALS');

17377: x_msg_data => l_msg_data);
17378:
17379:
17380: if (l_return_status <> FND_API.G_RET_STS_SUCCESS) then
17381: dbms_standard.raise_application_error(-20130, 'Error in PJI_PJP_SUM_ROLLUP.GET_TASK_ROLLUP_ACTUALS -> PA_PROGRESS_PUB.GET_SUMMARIZED_ACTUALS');
17382: end if;
17383:
17384: end if;
17385:

Line 17386: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.GET_TASK_ROLLUP_ACTUALS(p_worker_id);');

17382: end if;
17383:
17384: end if;
17385:
17386: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.GET_TASK_ROLLUP_ACTUALS(p_worker_id);');
17387:
17388: commit;
17389:
17390: end GET_TASK_ROLLUP_ACTUALS;

Line 17416: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.UNLOCK_ALL_HEADERS(p_worker_id);')) then

17412: begin
17413:
17414: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17415:
17416: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.UNLOCK_ALL_HEADERS(p_worker_id);')) then
17417: return;
17418: end if;
17419:
17420: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 17446: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UNLOCK_ALL_HEADERS(p_worker_id);');

17442:
17443: -- Pji_Fm_Plan_Maint_Pvt.MARK_EXTRACTED_PLANS('SEC');
17444: -- Back to CREATE_SECONDARY_PVT due to issue 5155692
17445:
17446: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UNLOCK_ALL_HEADERS(p_worker_id);');
17447:
17448: commit;
17449:
17450: end UNLOCK_ALL_HEADERS;

Line 17475: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.EXTRACT_FIN_PLAN_VERS_BULK(p_worker_id);')) then

17471: begin
17472:
17473: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17474:
17475: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.EXTRACT_FIN_PLAN_VERS_BULK(p_worker_id);')) then
17476: return;
17477: end if;
17478:
17479: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 17483: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.EXTRACT_FIN_PLAN_VERS_BULK(p_worker_id);');

17479: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17480:
17481: PJI_FM_PLAN_MAINT_PVT.EXTRACT_FIN_PLAN_VERS_BULK(p_slice_type => 'PRI');
17482:
17483: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.EXTRACT_FIN_PLAN_VERS_BULK(p_worker_id);');
17484:
17485: commit;
17486:
17487: end EXTRACT_FIN_PLAN_VERS_BULK;

Line 17512: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_WBS_HDR(p_worker_id);')) then

17508: begin
17509:
17510: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17511:
17512: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_WBS_HDR(p_worker_id);')) then
17513: return;
17514: end if;
17515:
17516: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 17520: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_WBS_HDR(p_worker_id);');

17516: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17517:
17518: PJI_FM_PLAN_MAINT_PVT.POPULATE_WBS_HDR;
17519:
17520: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_WBS_HDR(p_worker_id);');
17521:
17522: commit;
17523:
17524: end POPULATE_WBS_HDR;

Line 17549: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_WBS_HDR(p_worker_id);')) then

17545: begin
17546:
17547: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17548:
17549: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_WBS_HDR(p_worker_id);')) then
17550: return;
17551: end if;
17552:
17553: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 17558: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_WBS_HDR(p_worker_id);');

17554:
17555: -- PJI_FM_PLAN_MAINT_PVT.UPDATE_WBS_HDR;
17556: PJI_FM_PLAN_MAINT_PVT.UPDATE_WBS_HDR(p_worker_id);
17557:
17558: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.UPDATE_WBS_HDR(p_worker_id);');
17559:
17560: commit;
17561:
17562: end UPDATE_WBS_HDR;

Line 17587: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_RBS_HDR(p_worker_id);')) then

17583: begin
17584:
17585: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17586:
17587: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_RBS_HDR(p_worker_id);')) then
17588: return;
17589: end if;
17590:
17591: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 17595: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_RBS_HDR(p_worker_id);');

17591: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17592:
17593: PJI_FM_PLAN_MAINT_PVT.POPULATE_RBS_HDR;
17594:
17595: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.POPULATE_RBS_HDR(p_worker_id);');
17596:
17597: commit;
17598:
17599: end POPULATE_RBS_HDR;

Line 17624: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.EXTRACT_PLAN_AMOUNTS_PRIRBS(p_worker_id);')) then

17620: begin
17621:
17622: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17623:
17624: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.EXTRACT_PLAN_AMOUNTS_PRIRBS(p_worker_id);')) then
17625: return;
17626: end if;
17627:
17628: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 17632: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.EXTRACT_PLAN_AMOUNTS_PRIRBS(p_worker_id);');

17628: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17629:
17630: PJI_FM_PLAN_MAINT_PVT.EXTRACT_PLAN_AMOUNTS_PRIRBS;
17631:
17632: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.EXTRACT_PLAN_AMOUNTS_PRIRBS(p_worker_id);');
17633:
17634: commit;
17635:
17636: end EXTRACT_PLAN_AMOUNTS_PRIRBS;

Line 17661: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_T_SLICE(p_worker_id);')) then

17657: begin
17658:
17659: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17660:
17661: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_T_SLICE(p_worker_id);')) then
17662: return;
17663: end if;
17664:
17665: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 17669: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_T_SLICE(p_worker_id);');

17665: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17666:
17667: PJI_FM_PLAN_MAINT_PVT.ROLLUP_FPR_RBS_T_SLICE;
17668:
17669: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.ROLLUP_FPR_RBS_T_SLICE(p_worker_id);');
17670:
17671: commit;
17672:
17673: end ROLLUP_FPR_RBS_T_SLICE;

Line 17698: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_FP_PA_PRI_ROLLUP(p_worker_id);')) then

17694: begin
17695:
17696: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17697:
17698: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_FP_PA_PRI_ROLLUP(p_worker_id);')) then
17699: return;
17700: end if;
17701:
17702: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 17706: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_FP_PA_PRI_ROLLUP(p_worker_id);');

17702: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17703:
17704: PJI_FM_PLAN_CAL_RLPS.CREATE_FP_PA_PRI_ROLLUP;
17705:
17706: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_FP_PA_PRI_ROLLUP(p_worker_id);');
17707:
17708: commit;
17709:
17710: end CREATE_FP_PA_PRI_ROLLUP;

Line 17735: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_FP_GL_PRI_ROLLUP(p_worker_id);')) then

17731: begin
17732:
17733: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17734:
17735: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_FP_GL_PRI_ROLLUP(p_worker_id);')) then
17736: return;
17737: end if;
17738:
17739: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 17743: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_FP_GL_PRI_ROLLUP(p_worker_id);');

17739: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17740:
17741: PJI_FM_PLAN_CAL_RLPS.CREATE_FP_GL_PRI_ROLLUP;
17742:
17743: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_FP_GL_PRI_ROLLUP(p_worker_id);');
17744:
17745: commit;
17746:
17747: end CREATE_FP_GL_PRI_ROLLUP;

Line 17772: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_FP_ALL_PRI_ROLLUP(p_worker_id);')) then

17768: begin
17769:
17770: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17771:
17772: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_FP_ALL_PRI_ROLLUP(p_worker_id);')) then
17773: return;
17774: end if;
17775:
17776: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 17782: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_FP_ALL_PRI_ROLLUP(p_worker_id);');

17778: PJI_FM_PLAN_CAL_RLPS.CREATE_FP_ALL_T_PRI_ROLLUP('G');
17779:
17780: PJI_FM_PLAN_CAL_RLPS.CREATE_FP_ALL_T_PRI_ROLLUP('P');
17781:
17782: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CREATE_FP_ALL_PRI_ROLLUP(p_worker_id);');
17783:
17784: commit;
17785:
17786: end CREATE_FP_ALL_PRI_ROLLUP;

Line 17811: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.INSERT_INTO_FP_FACT(p_worker_id);')) then

17807: begin
17808:
17809: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17810:
17811: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.INSERT_INTO_FP_FACT(p_worker_id);')) then
17812: return;
17813: end if;
17814:
17815: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 17819: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.INSERT_INTO_FP_FACT(p_worker_id);');

17815: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17816:
17817: PJI_FM_PLAN_MAINT_PVT.INSERT_INTO_FP_FACT;
17818:
17819: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.INSERT_INTO_FP_FACT(p_worker_id);');
17820:
17821: commit;
17822:
17823: end INSERT_INTO_FP_FACT;

Line 17848: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.MARK_EXTRACTED_PLANS(p_worker_id);')) then

17844: begin
17845:
17846: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17847:
17848: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.MARK_EXTRACTED_PLANS(p_worker_id);')) then
17849: return;
17850: end if;
17851:
17852: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 17856: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.MARK_EXTRACTED_PLANS(p_worker_id);');

17852: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
17853:
17854: PJI_FM_PLAN_MAINT_PVT.MARK_EXTRACTED_PLANS('PRI');
17855:
17856: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.MARK_EXTRACTED_PLANS(p_worker_id);');
17857:
17858: commit;
17859:
17860: end MARK_EXTRACTED_PLANS;

Line 17876: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.REMAP_RBS_TXN_ACCUM_HDRS(p_worker_id);')) then

17872: begin
17873:
17874: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17875:
17876: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.REMAP_RBS_TXN_ACCUM_HDRS(p_worker_id);')) then
17877: return;
17878: end if;
17879:
17880: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 17889: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.REMAP_RBS_TXN_ACCUM_HDRS(p_worker_id);');

17885: x_return_status => l_return_status
17886: ,x_msg_data => l_msg_data
17887: ,x_msg_count => l_msg_count );
17888:
17889: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.REMAP_RBS_TXN_ACCUM_HDRS(p_worker_id);');
17890:
17891: commit;
17892:
17893: end REMAP_RBS_TXN_ACCUM_HDRS ;

Line 17909: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.RETRIEVE_OVERRIDDEN_WP_ETC(p_worker_id);')) then

17905: begin
17906:
17907: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17908:
17909: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.RETRIEVE_OVERRIDDEN_WP_ETC(p_worker_id);')) then
17910: return;
17911: end if;
17912:
17913: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 17919: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.RETRIEVE_OVERRIDDEN_WP_ETC(p_worker_id);');

17915: -- Retaining it to maintain coding style as well as for potential future use.
17916:
17917: PJI_FM_PLAN_MAINT_PVT.RETRIEVE_OVERRIDDEN_WP_ETC;
17918:
17919: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.RETRIEVE_OVERRIDDEN_WP_ETC(p_worker_id);');
17920:
17921: commit;
17922:
17923: end RETRIEVE_OVERRIDDEN_WP_ETC ;

Line 17939: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.EXTRACT_PLAN_ETC_PRIRBS(p_worker_id);')) then

17935: begin
17936:
17937: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17938:
17939: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.EXTRACT_PLAN_ETC_PRIRBS(p_worker_id);')) then
17940: return;
17941: end if;
17942:
17943: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 17949: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.EXTRACT_PLAN_ETC_PRIRBS(p_worker_id);');

17945: -- Retaining it to maintain coding style as well as for potential future use.
17946:
17947: PJI_FM_PLAN_MAINT_PVT.EXTRACT_PLAN_ETC_PRIRBS(p_slice_type => 'SEC');
17948:
17949: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.EXTRACT_PLAN_ETC_PRIRBS(p_worker_id);');
17950:
17951: commit;
17952:
17953: end EXTRACT_PLAN_ETC_PRIRBS ;

Line 17977: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.CLEANUP(p_worker_id);')) then -- Bug#5171542

17973:
17974: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
17975:
17976: /* 5755229 Because No step entry in the delete process FPM Upgrade
17977: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.CLEANUP(p_worker_id);')) then -- Bug#5171542
17978: return;
17979: end if;
17980: 5755229 */
17981:

Line 18064: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CLEANUP(p_worker_id);'); -- Bug#5171542

18060: 'PJI_PA_PROJ_EVENTS_LOG',
18061: 'PARTITION',
18062: 'P' || p_worker_id);
18063:
18064: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.CLEANUP(p_worker_id);'); -- Bug#5171542
18065: commit;
18066:
18067: else -- online mode
18068:

Line 18092: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.MERGE_INTO_FP_FACT(p_worker_id);')) then

18088: begin
18089:
18090: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
18091:
18092: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_PJP_SUM_ROLLUP.MERGE_INTO_FP_FACT(p_worker_id);')) then
18093: return;
18094: end if;
18095:
18096: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 18100: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.MERGE_INTO_FP_FACT(p_worker_id);');

18096: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
18097:
18098: PJI_FM_PLAN_MAINT_PVT.MERGE_INTO_FP_FACTS;
18099:
18100: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_PJP_SUM_ROLLUP.MERGE_INTO_FP_FACT(p_worker_id);');
18101:
18102: commit;
18103:
18104: end MERGE_INTO_FP_FACTS;

Line 18108: end PJI_PJP_SUM_ROLLUP;

18104: end MERGE_INTO_FP_FACTS;
18105: -- bug 6520936
18106:
18107:
18108: end PJI_PJP_SUM_ROLLUP;