[Home] [Help]
1: package body PJI_FM_SUM_ROLLUP_ACT as
2: /* $Header: PJISF05B.pls 120.7 2006/04/18 20:08:27 appldev noship $ */
3:
4: -- -----------------------------------------------------
5: -- procedure ACT_ROWID_TABLE
12: begin
13:
14: l_process := PJI_RM_SUM_MAIN.g_process || p_worker_id;
15:
16: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_ROLLUP_ACT.ACT_ROWID_TABLE(p_worker_id);')) then
17: return;
18: end if;
19:
20: insert /*+ append parallel(act_i) */ into PJI_PJI_RMAP_ACT act_i
31: where
32: map.WORKER_ID = p_worker_id and
33: act5.PROJECT_ID = map.PROJECT_ID;
34:
35: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_ROLLUP_ACT.ACT_ROWID_TABLE(p_worker_id);');
36:
37: commit;
38:
39: end ACT_ROWID_TABLE;
58: begin
59:
60: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);
61:
62: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_ROLLUP_ACT.AGGREGATE_ACT_SLICES(p_worker_id);')) then
63: return;
64: end if;
65:
66: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1069: src4.PA_CALENDAR_ID,
1070: src4.CURR_RECORD_TYPE_ID,
1071: src4.CURRENCY_CODE;
1072:
1073: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_ROLLUP_ACT.AGGREGATE_ACT_SLICES(p_worker_id);');
1074:
1075: commit;
1076:
1077: end AGGREGATE_ACT_SLICES;
1088: begin
1089:
1090: l_process := PJI_RM_SUM_MAIN.g_process || p_worker_id;
1091:
1092: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_ROLLUP_ACT.PURGE_ACT_DATA(p_worker_id);')) then
1093: return;
1094: end if;
1095:
1096: delete
1098: where ROWID in (select STG_ROWID
1099: from PJI_PJI_RMAP_ACT
1100: where WORKER_ID = p_worker_id);
1101:
1102: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_ROLLUP_ACT.PURGE_ACT_DATA(p_worker_id);');
1103:
1104: commit;
1105:
1106: end PURGE_ACT_DATA;
1120:
1121: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP
1122: (
1123: l_process,
1124: 'PJI_FM_SUM_ROLLUP_ACT.EXPAND_ACT_CAL_EN(p_worker_id, ''' ||
1125: p_backlog_flag || ''');'
1126: )) then
1127: return;
1128: end if;
1267:
1268: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION
1269: (
1270: l_process,
1271: 'PJI_FM_SUM_ROLLUP_ACT.EXPAND_ACT_CAL_EN(p_worker_id, ''' ||
1272: p_backlog_flag || ''');'
1273: );
1274:
1275: commit;
1299:
1300: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP
1301: (
1302: l_process,
1303: 'PJI_FM_SUM_ROLLUP_ACT.EXPAND_ACT_CAL_PA(p_worker_id, ''' ||
1304: p_backlog_flag || ''');'
1305: )) then
1306: return;
1307: end if;
1446:
1447: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION
1448: (
1449: l_process,
1450: 'PJI_FM_SUM_ROLLUP_ACT.EXPAND_ACT_CAL_PA(p_worker_id, ''' ||
1451: p_backlog_flag || ''');'
1452: );
1453:
1454: commit;
1478:
1479: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP
1480: (
1481: l_process,
1482: 'PJI_FM_SUM_ROLLUP_ACT.EXPAND_ACT_CAL_GL(p_worker_id, ''' ||
1483: p_backlog_flag || ''');'
1484: )) then
1485: return;
1486: end if;
1676:
1677: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION
1678: (
1679: l_process,
1680: 'PJI_FM_SUM_ROLLUP_ACT.EXPAND_ACT_CAL_GL(p_worker_id, ''' ||
1681: p_backlog_flag || ''');'
1682: );
1683:
1684: commit;
1700:
1701: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP
1702: (
1703: l_process,
1704: 'PJI_FM_SUM_ROLLUP_ACT.EXPAND_ACT_CAL_WK(p_worker_id, ''' ||
1705: p_backlog_flag || ''');'
1706: )) then
1707: return;
1708: end if;
1817:
1818: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION
1819: (
1820: l_process,
1821: 'PJI_FM_SUM_ROLLUP_ACT.EXPAND_ACT_CAL_WK(p_worker_id, ''' ||
1822: p_backlog_flag || ''');'
1823: );
1824:
1825: commit;
1848:
1849: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP
1850: (
1851: l_process,
1852: 'PJI_FM_SUM_ROLLUP_ACT.MERGE_ACT_INTO_ACP(p_worker_id, ''' ||
1853: p_backlog_flag ||
1854: ''');'
1855: )) then
1856: return;
2574:
2575: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION
2576: (
2577: l_process,
2578: 'PJI_FM_SUM_ROLLUP_ACT.MERGE_ACT_INTO_ACP(p_worker_id, ''' ||
2579: p_backlog_flag || ''');'
2580: );
2581:
2582: if (p_backlog_flag = 'Y') then
2633:
2634: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP
2635: (
2636: l_process,
2637: 'PJI_FM_SUM_ROLLUP_ACT.PROJECT_ORGANIZATION(p_worker_id);'
2638: )) then
2639: return;
2640: end if;
2641:
2709:
2710: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION
2711: (
2712: l_process,
2713: 'PJI_FM_SUM_ROLLUP_ACT.PROJECT_ORGANIZATION(p_worker_id);'
2714: );
2715:
2716: commit;
2717:
2738:
2739: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP
2740: (
2741: l_process,
2742: 'PJI_FM_SUM_ROLLUP_ACT.REFRESH_MVIEW_ACO(p_worker_id);'
2743: )) then
2744: return;
2745: end if;
2746:
2811:
2812: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION
2813: (
2814: l_process,
2815: 'PJI_FM_SUM_ROLLUP_ACT.REFRESH_MVIEW_ACO(p_worker_id);'
2816: );
2817:
2818: commit;
2819:
2840:
2841: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP
2842: (
2843: l_process,
2844: 'PJI_FM_SUM_ROLLUP_ACT.REFRESH_MVIEW_ACC(p_worker_id);'
2845: )) then
2846: return;
2847: end if;
2848:
2909:
2910: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION
2911: (
2912: l_process,
2913: 'PJI_FM_SUM_ROLLUP_ACT.REFRESH_MVIEW_ACC(p_worker_id);'
2914: );
2915:
2916: commit;
2917:
2916: commit;
2917:
2918: end REFRESH_MVIEW_ACC;
2919:
2920: end PJI_FM_SUM_ROLLUP_ACT;