[Home] [Help]
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);
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;
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');
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');
317:
318: l_last_update_date := sysdate;
319: l_last_updated_by := FND_GLOBAL.USER_ID;
320: l_creation_date := sysdate;
665: null; -- do not process any events during partial refresh
666:
667: elsif (l_extraction_type = 'RBS') then
668:
669: l_rbs_header_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
670: (l_process, 'RBS_HEADER_ID');
671:
672: if (l_rbs_header_id = -1) then
673: l_rbs_header_id := null;
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;
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');
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');
1152:
1153: if (l_extraction_type = 'RBS') then
1154:
1155: for c in rbs_events(p_worker_id) loop
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;
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');
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');
1215:
1216: for c in required_rbs(p_worker_id) loop
1217:
1218: begin
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;
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');
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');
1266:
1267: begin
1268: PA_RBS_MAPPING.MAP_RBS_ACTUALS(p_worker_id,
1269: l_return_status,
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;
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');
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');
1320:
1321: l_count := 0;
1322:
1323: if (l_extraction_type = 'FULL') then
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;
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');
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');
1489:
1490: -- PJI_FM_XBS_ACCUM_MAINT.WBS_LOCK_PVT(p_online_flag => 'N',
1491: -- x_lock_mode => l_lock_mode,
1492: -- x_return_status => l_return_status);
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;
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');
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');
1541:
1542: l_last_update_date := sysdate;
1543: l_last_updated_by := FND_GLOBAL.USER_ID;
1544: l_creation_date := sysdate;
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;
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');
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');
1734:
1735: if (l_extraction_type = 'INCREMENTAL') then
1736:
1737: delete
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;
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');
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');
1962:
1963: l_last_update_date := sysdate;
1964: l_last_updated_by := FND_GLOBAL.USER_ID;
1965: l_creation_date := sysdate;
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;
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;
2536: l_creation_date := sysdate;
2537: l_created_by := FND_GLOBAL.USER_ID;
2538: l_last_update_login := FND_GLOBAL.LOGIN_ID;
2539:
2540: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
2541:
2542: if (l_extraction_type = 'INCREMENTAL') then
2543:
2544: insert into PJI_XBS_DENORM_DELTA delta_i
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
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');
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');
3112:
3113: if (l_extraction_type = 'RBS') then
3114:
3115: insert into PJI_RBS_DENORM_DELTA delta_i
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;
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');
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');
3234:
3235: -- Bug#5099574 - Start
3236:
3237: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'PLAN_TYPE_ID');
3233: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
3234:
3235: -- Bug#5099574 - Start
3236:
3237: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'PLAN_TYPE_ID');
3238: l_refresh_code := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'REFRESH_CODE');
3239:
3240: if (l_plan_type_id = -1) then
3241: l_plan_type_id := null;
3234:
3235: -- Bug#5099574 - Start
3236:
3237: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'PLAN_TYPE_ID');
3238: l_refresh_code := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'REFRESH_CODE');
3239:
3240: if (l_plan_type_id = -1) then
3241: l_plan_type_id := null;
3242: end if;
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:
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;
4372: begin
4373:
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;
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
4380: end if;
4381:
4382: -- Bug#5099574 - Start
4383:
4384: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'PLAN_TYPE_ID');
4385: l_refresh_code := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'REFRESH_CODE');
4386:
4387: if (l_plan_type_id = -1) then
4388: l_plan_type_id := null;
4381:
4382: -- Bug#5099574 - Start
4383:
4384: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'PLAN_TYPE_ID');
4385: l_refresh_code := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'REFRESH_CODE');
4386:
4387: if (l_plan_type_id = -1) then
4388: l_plan_type_id := null;
4389: end if;
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:
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;
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');
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');
5042:
5043: l_last_update_date := sysdate;
5044: l_last_updated_by := FND_GLOBAL.USER_ID;
5045: l_last_update_login := FND_GLOBAL.LOGIN_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;
5171: begin
5172:
5173: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
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;
5172:
5173: l_process := PJI_PJP_SUM_MAIN.g_process || to_char(p_worker_id);
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;
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
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
5183: (l_process, 'PLAN_TYPE_ID');
5184:
5185: if (l_plan_type_id = -1) then
5186: l_plan_type_id := null;
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;
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');
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');
5877:
5878: -- Bug#5099574
5879: l_refresh_code := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'REFRESH_CODE');
5880: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'PLAN_TYPE_ID');
5875:
5876: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
5877:
5878: -- Bug#5099574
5879: l_refresh_code := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'REFRESH_CODE');
5880: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'PLAN_TYPE_ID');
5881:
5882: if (l_plan_type_id = -1) then
5883: l_plan_type_id := null;
5876: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
5877:
5878: -- Bug#5099574
5879: l_refresh_code := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'REFRESH_CODE');
5880: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER (l_process, 'PLAN_TYPE_ID');
5881:
5882: if (l_plan_type_id = -1) then
5883: l_plan_type_id := null;
5884: end if;
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;
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');
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');
7020:
7021: IF (l_extraction_type = 'INCREMENTAL') THEN
7022: Pji_Fm_Plan_Maint.CREATE_SECONDARY_PVT;
7023: -- PJI_FM_PLAN_MAINT_PVT.PULL_DANGLING_PLANS; -- Removing redundant api nesting.
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;
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');
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');
7062:
7063: if (l_extraction_type = 'PARTIAL') then
7064:
7065: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7061: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
7062:
7063: if (l_extraction_type = 'PARTIAL') then
7064:
7065: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7066: (l_process, 'PLAN_TYPE_ID');
7067:
7068: if (l_plan_type_id = -1) then
7069: l_plan_type_id := null;
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;
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');
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');
7118:
7119: if (l_extraction_type = 'RBS') then
7120:
7121: l_rbs_version_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7117: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
7118:
7119: if (l_extraction_type = 'RBS') then
7120:
7121: l_rbs_version_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7122: (l_process, 'RBS_VERSION_ID');
7123:
7124: PJI_FM_PLAN_MAINT.PULL_PLANS_FOR_PR(l_rbs_version_id,
7125: null,
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;
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');
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');
7162:
7163: insert into PJI_FP_AGGR_PJP1 pjp1_i
7164: (
7165: 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;
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');
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');
7584:
7585: l_fpm_upgrade := nvl(PJI_UTILS.GET_PARAMETER('PJI_FPM_UPGRADE'), 'C');
7586:
7587: select decode(l_extraction_type,'PARTIAL','PARTIAL',NULL)
7624: den.STRUCT_TYPE = 'PRG' and
7625: den.SUB_LEVEL = den.SUP_LEVEL and
7626: den.SUP_PROJECT_ID = map.PROJECT_ID;
7627:
7628: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(l_process,
7629: 'MAX_PROGRAM_LEVEL',
7630: l_level);
7631:
7632: for x in 1 .. l_level loop
7653: end loop;
7654:
7655: end if;
7656:
7657: l_max_level := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7658: (l_process, 'MAX_PROGRAM_LEVEL');
7659:
7660: select
7661: nvl(to_number(min(STEP_SEQ)), 0)
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
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');
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');
11118:
11119: insert into PJI_FP_AGGR_PJP1 pjp1_i
11120: (
11121: 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
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');
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');
12057:
12058: -- allow recovery after each level is processed
12059:
12060: select
12091: den.STRUCT_TYPE = 'PRG' and
12092: den.SUB_LEVEL = den.SUP_LEVEL and
12093: den.SUP_PROJECT_ID = map.PROJECT_ID;
12094:
12095: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(l_process,
12096: 'MAX_PROGRAM_LEVEL',
12097: l_level);
12098:
12099: for x in 1 .. l_level loop
12120: end loop;
12121:
12122: end if;
12123:
12124: l_max_level := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
12125: (l_process, 'MAX_PROGRAM_LEVEL');
12126:
12127: select
12128: nvl(to_number(min(STEP_SEQ)), 0)
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
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
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
13392: (l_process, 'PROGRAM_EXISTS');
13393:
13394: if (l_prg_exists = 'N') then
13395: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process,
13391: l_prg_exists := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
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;
13397: commit;
13398: return;
13399: end if;
13400:
13401: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
13402:
13403: -- allow recovery after each level is processed
13404:
13405: select
13433: where
13434: den.WORKER_ID = p_worker_id and
13435: den.STRUCT_TYPE = 'PRG';
13436:
13437: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(l_process,
13438: 'MAX_PROGRAM_LEVEL',
13439: l_level);
13440:
13441: insert into PJI_SYSTEM_PRC_STATUS
13492: SUP_LEVEL desc;
13493:
13494: end if;
13495:
13496: l_max_level := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
13497: (l_process, 'MAX_PROGRAM_LEVEL');
13498:
13499: select
13500: nvl(to_number(min(STEP_SEQ)), 0)
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;
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
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
14630: (l_process, 'PROGRAM_EXISTS');
14631:
14632: if (l_prg_exists = 'N') then
14633: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process,
14629: l_prg_exists := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
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;
14635: commit;
14636: return;
14637: end if;
14638:
14639: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');
14640:
14641: -- allow recovery after each level is processed
14642:
14643: select
14671: where
14672: den.WORKER_ID = p_worker_id and
14673: den.STRUCT_TYPE = 'PRG';
14674:
14675: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(l_process,
14676: 'MAX_PROGRAM_LEVEL',
14677: l_level);
14678:
14679: insert into PJI_SYSTEM_PRC_STATUS
14730: SUP_LEVEL desc;
14731:
14732: end if;
14733:
14734: l_max_level := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
14735: (l_process, 'MAX_PROGRAM_LEVEL');
14736:
14737: select
14738: nvl(to_number(min(STEP_SEQ)), 0)
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;
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');
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');
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);');
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;
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');
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');
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);');
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;
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');
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');
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);');
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;
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');
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');
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);');
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;
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');
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');
15321:
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');
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;
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');
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');
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);');
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;
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');
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');
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);');
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;
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');
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');
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);');
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;
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');
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');
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);');
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;
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');
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');
15507:
15508: IF (l_extraction_type IN ('PARTIAL', 'RBS', 'INCREMENTAL', 'FULL')) THEN
15509:
15510: insert into PJI_FP_AGGR_PJP1 pjp1_i
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;
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');
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');
15956:
15957: IF (l_extraction_type IN ('PARTIAL', 'RBS', 'INCREMENTAL', 'FULL')) THEN
15958:
15959: delete
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;
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');
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');
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);');
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;
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');
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');
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);');
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;
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');
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');
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);');
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;
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');
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');
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);');
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;
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');
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');
16161:
16162: if (l_extraction_type = 'INCREMENTAL' or
16163: l_extraction_type = 'PARTIAL' or
16164: l_extraction_type = 'RBS') then
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;
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');
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');
16204:
16205: if (l_extraction_type = 'INCREMENTAL' or
16206: l_extraction_type = 'PARTIAL' or
16207: l_extraction_type = 'RBS') then
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;
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');
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');
16247:
16248: if (l_extraction_type = 'FULL') then
16249:
16250: PJI_FM_PLAN_MAINT_PVT.INSERT_INTO_AC_FACT;
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;
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');
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');
16294:
16295: -- if (l_extraction_type = 'INCREMENTAL' or
16296: -- l_extraction_type = 'PARTIAL' or
16297: -- l_extraction_type = 'RBS') then
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;
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');
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');
16350:
16351: l_count := 0;
16352:
16353: if (l_extraction_type = 'INCREMENTAL') then
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
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');
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');
16836:
16837: if (nvl(l_fpm_upgrade, 'P') <> 'C' and
16838: l_extraction_type = 'FULL') then
16839:
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
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');
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');
17079:
17080: begin
17081: PJI_FM_XBS_ACCUM_MAINT.PROCESS_PENDING_EVENTS(l_return_status,
17082: l_msg_data);
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;
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');
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');
17121:
17122: PJI_FM_PLAN_MAINT_PVT.PROCESS_PENDING_PLAN_UPDATES(l_extraction_type,
17123: l_return_status,
17124: l_msg_data);
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;
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');
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');
17180:
17181: -- Incr-Incr, Full-Initial, rbs-full, pr-full.
17182: SELECT DECODE(l_extraction_type, 'INCREMENTAL', 'INCREMENTAL', 'FULL', 'INITIAL', 'FULL')
17183: INTO l_extraction_type_wp
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;
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');
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');
17337:
17338: if (l_extraction_type = 'FULL' or
17339: l_extraction_type = 'INCREMENTAL') then
17340:
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;
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');
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');
17421:
17422: update PJI_PJP_WBS_HEADER
17423: set LOCK_FLAG = null
17424: where LOCK_FLAG is not null
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;
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');
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');
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);');
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;
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');
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');
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);');
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;
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');
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');
17554:
17555: -- PJI_FM_PLAN_MAINT_PVT.UPDATE_WBS_HDR;
17556: PJI_FM_PLAN_MAINT_PVT.UPDATE_WBS_HDR(p_worker_id);
17557:
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;
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');
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');
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);');
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;
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');
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');
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);');
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;
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');
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');
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);');
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;
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');
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');
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);');
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;
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');
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');
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);');
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;
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');
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');
17777:
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');
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;
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');
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');
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);');
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;
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');
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');
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);');
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;
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');
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');
17881: -- Extraction type is not needed for this step.
17882: -- Retaining it to maintain coding style as well as for potential future use.
17883:
17884: PJI_FM_XBS_ACCUM_UTILS.REMAP_RBS_TXN_ACCUM_HDRS (
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 ;
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');
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');
17914: -- Extraction type is not needed for this step.
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;
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 ;
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');
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');
17944: -- Extraction type is not needed for this step.
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');
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 ;
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:
17980: 5755229 */
17981:
17982: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
17983:
17984: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
17985: 'PJI_PJP_RMAP_FPR',
17986: 'PARTITION',
17987: 'P' || p_worker_id);
17988:
17985: 'PJI_PJP_RMAP_FPR',
17986: 'PARTITION',
17987: 'P' || p_worker_id);
17988:
17989: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
17990: 'PJI_PJP_RMAP_ACR',
17991: 'PARTITION',
17992: 'P' || p_worker_id);
17993:
17990: 'PJI_PJP_RMAP_ACR',
17991: 'PARTITION',
17992: 'P' || p_worker_id);
17993:
17994: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
17995: 'PJI_FP_AGGR_PJP0',
17996: 'PARTITION',
17997: 'P' || p_worker_id);
17998:
17995: 'PJI_FP_AGGR_PJP0',
17996: 'PARTITION',
17997: 'P' || p_worker_id);
17998:
17999: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
18000: 'PJI_AC_AGGR_PJP0',
18001: 'PARTITION',
18002: 'P' || p_worker_id);
18003:
18000: 'PJI_AC_AGGR_PJP0',
18001: 'PARTITION',
18002: 'P' || p_worker_id);
18003:
18004: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
18005: 'PJI_FP_CUST_PJP0',
18006: 'PARTITION',
18007: 'P' || p_worker_id);
18008:
18005: 'PJI_FP_CUST_PJP0',
18006: 'PARTITION',
18007: 'P' || p_worker_id);
18008:
18009: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
18010: 'PJI_AC_CUST_PJP0',
18011: 'PARTITION',
18012: 'P' || p_worker_id);
18013:
18010: 'PJI_AC_CUST_PJP0',
18011: 'PARTITION',
18012: 'P' || p_worker_id);
18013:
18014: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
18015: 'PJI_FM_EXTR_PLNVER4',
18016: 'PARTITION',
18017: 'P' || p_worker_id);
18018:
18015: 'PJI_FM_EXTR_PLNVER4',
18016: 'PARTITION',
18017: 'P' || p_worker_id);
18018:
18019: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
18020: 'PJI_FP_AGGR_PJP1',
18021: 'PARTITION',
18022: 'P' || p_worker_id);
18023:
18020: 'PJI_FP_AGGR_PJP1',
18021: 'PARTITION',
18022: 'P' || p_worker_id);
18023:
18024: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
18025: 'PJI_AC_AGGR_PJP1',
18026: 'PARTITION',
18027: 'P' || p_worker_id);
18028:
18025: 'PJI_AC_AGGR_PJP1',
18026: 'PARTITION',
18027: 'P' || p_worker_id);
18028:
18029: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
18030: 'PJI_FP_AGGR_XBS',
18031: 'PARTITION',
18032: 'P' || p_worker_id);
18033:
18030: 'PJI_FP_AGGR_XBS',
18031: 'PARTITION',
18032: 'P' || p_worker_id);
18033:
18034: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
18035: 'PJI_FP_AGGR_RBS',
18036: 'PARTITION',
18037: 'P' || p_worker_id);
18038:
18035: 'PJI_FP_AGGR_RBS',
18036: 'PARTITION',
18037: 'P' || p_worker_id);
18038:
18039: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
18040: 'PJI_XBS_DENORM_DELTA',
18041: 'PARTITION',
18042: 'P' || p_worker_id);
18043:
18040: 'PJI_XBS_DENORM_DELTA',
18041: 'PARTITION',
18042: 'P' || p_worker_id);
18043:
18044: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
18045: 'PJI_RBS_DENORM_DELTA',
18046: 'PARTITION',
18047: 'P' || p_worker_id);
18048:
18045: 'PJI_RBS_DENORM_DELTA',
18046: 'PARTITION',
18047: 'P' || p_worker_id);
18048:
18049: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
18050: 'PJI_FP_RMAP_FPR',
18051: 'PARTITION',
18052: 'P' || p_worker_id);
18053:
18050: 'PJI_FP_RMAP_FPR',
18051: 'PARTITION',
18052: 'P' || p_worker_id);
18053:
18054: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
18055: 'PJI_AC_RMAP_ACR',
18056: 'PARTITION',
18057: 'P' || p_worker_id);
18058:
18055: 'PJI_AC_RMAP_ACR',
18056: 'PARTITION',
18057: 'P' || p_worker_id);
18058:
18059: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
18060: 'PJI_PA_PROJ_EVENTS_LOG',
18061: 'PARTITION',
18062: 'P' || p_worker_id);
18063:
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:
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');
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');
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);');
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;