1672:
1673: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
1674:
1675: PJI_PJ_PROJ_CLASS_EXTR.CLEANUP(p_worker_id);
1676: PJI_FM_PLAN_EXTR.CLEANUP(p_worker_id);
1677: PJI_RM_SUM_ROLLUP_RES.CLEANUP(p_worker_id);
1678:
1679: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
1680: 'PJI_RM_REXT_FCSTITEM',
1780:
1781: -- Populates PJI_ORG_DENORM to be used with the Materialized views
1782: PJI_PJI_EXTRACTION_UTILS.UPDATE_PJI_ORG_HRCHY;
1783:
1784: PJI_FM_PLAN_EXTR.UPDATE_PLAN_ORG_INFO(p_worker_id);
1785: PJI_FM_PLAN_EXTR.EXTRACT_PLAN_VERSIONS(p_worker_id);
1786: PJI_FM_PLAN_EXTR.EXTRACT_BATCH_PLAN(p_worker_id );
1787: PJI_FM_PLAN_EXTR.SPREAD_ENT_PLANS(p_worker_id);
1788: PJI_FM_PLAN_EXTR.PLAN_CURR_CONV_TABLE(p_worker_id);
1781: -- Populates PJI_ORG_DENORM to be used with the Materialized views
1782: PJI_PJI_EXTRACTION_UTILS.UPDATE_PJI_ORG_HRCHY;
1783:
1784: PJI_FM_PLAN_EXTR.UPDATE_PLAN_ORG_INFO(p_worker_id);
1785: PJI_FM_PLAN_EXTR.EXTRACT_PLAN_VERSIONS(p_worker_id);
1786: PJI_FM_PLAN_EXTR.EXTRACT_BATCH_PLAN(p_worker_id );
1787: PJI_FM_PLAN_EXTR.SPREAD_ENT_PLANS(p_worker_id);
1788: PJI_FM_PLAN_EXTR.PLAN_CURR_CONV_TABLE(p_worker_id);
1789: PJI_FM_PLAN_EXTR.CONVERT_TO_GLOBAL_CURRENCY(p_worker_id);
1782: PJI_PJI_EXTRACTION_UTILS.UPDATE_PJI_ORG_HRCHY;
1783:
1784: PJI_FM_PLAN_EXTR.UPDATE_PLAN_ORG_INFO(p_worker_id);
1785: PJI_FM_PLAN_EXTR.EXTRACT_PLAN_VERSIONS(p_worker_id);
1786: PJI_FM_PLAN_EXTR.EXTRACT_BATCH_PLAN(p_worker_id );
1787: PJI_FM_PLAN_EXTR.SPREAD_ENT_PLANS(p_worker_id);
1788: PJI_FM_PLAN_EXTR.PLAN_CURR_CONV_TABLE(p_worker_id);
1789: PJI_FM_PLAN_EXTR.CONVERT_TO_GLOBAL_CURRENCY(p_worker_id);
1790: PJI_FM_PLAN_EXTR.CONVERT_TO_GLOBAL2_CURRENCY(p_worker_id);
1783:
1784: PJI_FM_PLAN_EXTR.UPDATE_PLAN_ORG_INFO(p_worker_id);
1785: PJI_FM_PLAN_EXTR.EXTRACT_PLAN_VERSIONS(p_worker_id);
1786: PJI_FM_PLAN_EXTR.EXTRACT_BATCH_PLAN(p_worker_id );
1787: PJI_FM_PLAN_EXTR.SPREAD_ENT_PLANS(p_worker_id);
1788: PJI_FM_PLAN_EXTR.PLAN_CURR_CONV_TABLE(p_worker_id);
1789: PJI_FM_PLAN_EXTR.CONVERT_TO_GLOBAL_CURRENCY(p_worker_id);
1790: PJI_FM_PLAN_EXTR.CONVERT_TO_GLOBAL2_CURRENCY(p_worker_id);
1791: PJI_FM_PLAN_EXTR.CONVERT_TO_PA_PERIODS(p_worker_id);
1784: PJI_FM_PLAN_EXTR.UPDATE_PLAN_ORG_INFO(p_worker_id);
1785: PJI_FM_PLAN_EXTR.EXTRACT_PLAN_VERSIONS(p_worker_id);
1786: PJI_FM_PLAN_EXTR.EXTRACT_BATCH_PLAN(p_worker_id );
1787: PJI_FM_PLAN_EXTR.SPREAD_ENT_PLANS(p_worker_id);
1788: PJI_FM_PLAN_EXTR.PLAN_CURR_CONV_TABLE(p_worker_id);
1789: PJI_FM_PLAN_EXTR.CONVERT_TO_GLOBAL_CURRENCY(p_worker_id);
1790: PJI_FM_PLAN_EXTR.CONVERT_TO_GLOBAL2_CURRENCY(p_worker_id);
1791: PJI_FM_PLAN_EXTR.CONVERT_TO_PA_PERIODS(p_worker_id);
1792: PJI_FM_PLAN_EXTR.CONVERT_TO_GL_PERIODS(p_worker_id);
1785: PJI_FM_PLAN_EXTR.EXTRACT_PLAN_VERSIONS(p_worker_id);
1786: PJI_FM_PLAN_EXTR.EXTRACT_BATCH_PLAN(p_worker_id );
1787: PJI_FM_PLAN_EXTR.SPREAD_ENT_PLANS(p_worker_id);
1788: PJI_FM_PLAN_EXTR.PLAN_CURR_CONV_TABLE(p_worker_id);
1789: PJI_FM_PLAN_EXTR.CONVERT_TO_GLOBAL_CURRENCY(p_worker_id);
1790: PJI_FM_PLAN_EXTR.CONVERT_TO_GLOBAL2_CURRENCY(p_worker_id);
1791: PJI_FM_PLAN_EXTR.CONVERT_TO_PA_PERIODS(p_worker_id);
1792: PJI_FM_PLAN_EXTR.CONVERT_TO_GL_PERIODS(p_worker_id);
1793: PJI_FM_PLAN_EXTR.CONVERT_TO_ENT_PERIODS(p_worker_id);
1786: PJI_FM_PLAN_EXTR.EXTRACT_BATCH_PLAN(p_worker_id );
1787: PJI_FM_PLAN_EXTR.SPREAD_ENT_PLANS(p_worker_id);
1788: PJI_FM_PLAN_EXTR.PLAN_CURR_CONV_TABLE(p_worker_id);
1789: PJI_FM_PLAN_EXTR.CONVERT_TO_GLOBAL_CURRENCY(p_worker_id);
1790: PJI_FM_PLAN_EXTR.CONVERT_TO_GLOBAL2_CURRENCY(p_worker_id);
1791: PJI_FM_PLAN_EXTR.CONVERT_TO_PA_PERIODS(p_worker_id);
1792: PJI_FM_PLAN_EXTR.CONVERT_TO_GL_PERIODS(p_worker_id);
1793: PJI_FM_PLAN_EXTR.CONVERT_TO_ENT_PERIODS(p_worker_id);
1794: PJI_FM_PLAN_EXTR.CONVERT_TO_ENTW_PERIODS(p_worker_id);
1787: PJI_FM_PLAN_EXTR.SPREAD_ENT_PLANS(p_worker_id);
1788: PJI_FM_PLAN_EXTR.PLAN_CURR_CONV_TABLE(p_worker_id);
1789: PJI_FM_PLAN_EXTR.CONVERT_TO_GLOBAL_CURRENCY(p_worker_id);
1790: PJI_FM_PLAN_EXTR.CONVERT_TO_GLOBAL2_CURRENCY(p_worker_id);
1791: PJI_FM_PLAN_EXTR.CONVERT_TO_PA_PERIODS(p_worker_id);
1792: PJI_FM_PLAN_EXTR.CONVERT_TO_GL_PERIODS(p_worker_id);
1793: PJI_FM_PLAN_EXTR.CONVERT_TO_ENT_PERIODS(p_worker_id);
1794: PJI_FM_PLAN_EXTR.CONVERT_TO_ENTW_PERIODS(p_worker_id);
1795: PJI_FM_PLAN_EXTR.DANGLING_PLAN_VERSIONS(p_worker_id);
1788: PJI_FM_PLAN_EXTR.PLAN_CURR_CONV_TABLE(p_worker_id);
1789: PJI_FM_PLAN_EXTR.CONVERT_TO_GLOBAL_CURRENCY(p_worker_id);
1790: PJI_FM_PLAN_EXTR.CONVERT_TO_GLOBAL2_CURRENCY(p_worker_id);
1791: PJI_FM_PLAN_EXTR.CONVERT_TO_PA_PERIODS(p_worker_id);
1792: PJI_FM_PLAN_EXTR.CONVERT_TO_GL_PERIODS(p_worker_id);
1793: PJI_FM_PLAN_EXTR.CONVERT_TO_ENT_PERIODS(p_worker_id);
1794: PJI_FM_PLAN_EXTR.CONVERT_TO_ENTW_PERIODS(p_worker_id);
1795: PJI_FM_PLAN_EXTR.DANGLING_PLAN_VERSIONS(p_worker_id);
1796: PJI_FM_PLAN_EXTR.SUMMARIZE_EXTRACT(p_worker_id);
1789: PJI_FM_PLAN_EXTR.CONVERT_TO_GLOBAL_CURRENCY(p_worker_id);
1790: PJI_FM_PLAN_EXTR.CONVERT_TO_GLOBAL2_CURRENCY(p_worker_id);
1791: PJI_FM_PLAN_EXTR.CONVERT_TO_PA_PERIODS(p_worker_id);
1792: PJI_FM_PLAN_EXTR.CONVERT_TO_GL_PERIODS(p_worker_id);
1793: PJI_FM_PLAN_EXTR.CONVERT_TO_ENT_PERIODS(p_worker_id);
1794: PJI_FM_PLAN_EXTR.CONVERT_TO_ENTW_PERIODS(p_worker_id);
1795: PJI_FM_PLAN_EXTR.DANGLING_PLAN_VERSIONS(p_worker_id);
1796: PJI_FM_PLAN_EXTR.SUMMARIZE_EXTRACT(p_worker_id);
1797: PJI_FM_PLAN_EXTR.EXTRACT_UPDATED_VERSIONS(p_worker_id);
1790: PJI_FM_PLAN_EXTR.CONVERT_TO_GLOBAL2_CURRENCY(p_worker_id);
1791: PJI_FM_PLAN_EXTR.CONVERT_TO_PA_PERIODS(p_worker_id);
1792: PJI_FM_PLAN_EXTR.CONVERT_TO_GL_PERIODS(p_worker_id);
1793: PJI_FM_PLAN_EXTR.CONVERT_TO_ENT_PERIODS(p_worker_id);
1794: PJI_FM_PLAN_EXTR.CONVERT_TO_ENTW_PERIODS(p_worker_id);
1795: PJI_FM_PLAN_EXTR.DANGLING_PLAN_VERSIONS(p_worker_id);
1796: PJI_FM_PLAN_EXTR.SUMMARIZE_EXTRACT(p_worker_id);
1797: PJI_FM_PLAN_EXTR.EXTRACT_UPDATED_VERSIONS(p_worker_id);
1798:
1791: PJI_FM_PLAN_EXTR.CONVERT_TO_PA_PERIODS(p_worker_id);
1792: PJI_FM_PLAN_EXTR.CONVERT_TO_GL_PERIODS(p_worker_id);
1793: PJI_FM_PLAN_EXTR.CONVERT_TO_ENT_PERIODS(p_worker_id);
1794: PJI_FM_PLAN_EXTR.CONVERT_TO_ENTW_PERIODS(p_worker_id);
1795: PJI_FM_PLAN_EXTR.DANGLING_PLAN_VERSIONS(p_worker_id);
1796: PJI_FM_PLAN_EXTR.SUMMARIZE_EXTRACT(p_worker_id);
1797: PJI_FM_PLAN_EXTR.EXTRACT_UPDATED_VERSIONS(p_worker_id);
1798:
1799: PJI_FM_PLAN_EXTR.UPDATE_BATCH_VERSIONS_PRE(p_worker_id);
1792: PJI_FM_PLAN_EXTR.CONVERT_TO_GL_PERIODS(p_worker_id);
1793: PJI_FM_PLAN_EXTR.CONVERT_TO_ENT_PERIODS(p_worker_id);
1794: PJI_FM_PLAN_EXTR.CONVERT_TO_ENTW_PERIODS(p_worker_id);
1795: PJI_FM_PLAN_EXTR.DANGLING_PLAN_VERSIONS(p_worker_id);
1796: PJI_FM_PLAN_EXTR.SUMMARIZE_EXTRACT(p_worker_id);
1797: PJI_FM_PLAN_EXTR.EXTRACT_UPDATED_VERSIONS(p_worker_id);
1798:
1799: PJI_FM_PLAN_EXTR.UPDATE_BATCH_VERSIONS_PRE(p_worker_id);
1800: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
1793: PJI_FM_PLAN_EXTR.CONVERT_TO_ENT_PERIODS(p_worker_id);
1794: PJI_FM_PLAN_EXTR.CONVERT_TO_ENTW_PERIODS(p_worker_id);
1795: PJI_FM_PLAN_EXTR.DANGLING_PLAN_VERSIONS(p_worker_id);
1796: PJI_FM_PLAN_EXTR.SUMMARIZE_EXTRACT(p_worker_id);
1797: PJI_FM_PLAN_EXTR.EXTRACT_UPDATED_VERSIONS(p_worker_id);
1798:
1799: PJI_FM_PLAN_EXTR.UPDATE_BATCH_VERSIONS_PRE(p_worker_id);
1800: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
1801: (PJI_RM_SUM_MAIN.g_process,
1795: PJI_FM_PLAN_EXTR.DANGLING_PLAN_VERSIONS(p_worker_id);
1796: PJI_FM_PLAN_EXTR.SUMMARIZE_EXTRACT(p_worker_id);
1797: PJI_FM_PLAN_EXTR.EXTRACT_UPDATED_VERSIONS(p_worker_id);
1798:
1799: PJI_FM_PLAN_EXTR.UPDATE_BATCH_VERSIONS_PRE(p_worker_id);
1800: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
1801: (PJI_RM_SUM_MAIN.g_process,
1802: 'PJI_FM_PLAN_EXTR.UPDATE_BATCH_VERSIONS(p_worker_id);',
1803: PJI_RM_SUM_MAIN.g_process_delay)) then
1798:
1799: PJI_FM_PLAN_EXTR.UPDATE_BATCH_VERSIONS_PRE(p_worker_id);
1800: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
1801: (PJI_RM_SUM_MAIN.g_process,
1802: 'PJI_FM_PLAN_EXTR.UPDATE_BATCH_VERSIONS(p_worker_id);',
1803: PJI_RM_SUM_MAIN.g_process_delay)) then
1804: return;
1805: end if;
1806: PJI_FM_PLAN_EXTR.UPDATE_BATCH_VERSIONS_POST(p_worker_id);
1802: 'PJI_FM_PLAN_EXTR.UPDATE_BATCH_VERSIONS(p_worker_id);',
1803: PJI_RM_SUM_MAIN.g_process_delay)) then
1804: return;
1805: end if;
1806: PJI_FM_PLAN_EXTR.UPDATE_BATCH_VERSIONS_POST(p_worker_id);
1807: PJI_FM_PLAN_EXTR.UPDATE_BATCH_STATUSES(p_worker_id);
1808:
1809: PJI_PJ_PROJ_CLASS_EXTR.EXTR_PROJECT_CLASSES(p_worker_id);
1810:
1803: PJI_RM_SUM_MAIN.g_process_delay)) then
1804: return;
1805: end if;
1806: PJI_FM_PLAN_EXTR.UPDATE_BATCH_VERSIONS_POST(p_worker_id);
1807: PJI_FM_PLAN_EXTR.UPDATE_BATCH_STATUSES(p_worker_id);
1808:
1809: PJI_PJ_PROJ_CLASS_EXTR.EXTR_PROJECT_CLASSES(p_worker_id);
1810:
1811: PJI_RM_SUM_EXTR.PROCESS_DANGLING_ROWS(p_worker_id);
1977: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);
1978:
1979: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
1980: (PJI_RM_SUM_MAIN.g_process,
1981: 'PJI_FM_PLAN_EXTR.UPDATE_BATCH_VERSIONS_PRE(p_worker_id);',
1982: PJI_RM_SUM_MAIN.g_process_delay,
1983: 'EVEN_IF_NOT_EXISTS')) then
1984: return;
1985: end if;
1983: 'EVEN_IF_NOT_EXISTS')) then
1984: return;
1985: end if;
1986:
1987: PJI_FM_PLAN_EXTR.UPDATE_BATCH_VERSIONS(p_worker_id);
1988:
1989: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
1990: (PJI_RM_SUM_MAIN.g_process,
1991: 'PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS_PRE(p_worker_id);',