eTRM uses javascript that opens and focuses a separate window to display reports. Your browser does not appear to support javascript. This should not prevent you from using eTRM but it does mean the window focus feature will not work. Please check the contents of other windows on your desktop if you click on a link that does not appear to do anything.

APPS.PJI_RM_SUM_EXTR dependencies on PJI_RM_SUM_EXTR

Line 1: package body PJI_RM_SUM_EXTR as

1: package body PJI_RM_SUM_EXTR as
2: /* $Header: PJISR02B.pls 120.8 2005/12/07 21:57:59 appldev noship $ */
3:
4: -- -----------------------------------------------------
5: -- procedure PROCESS_DANGLING_ROWS

Line 19: 'PJI_RM_SUM_EXTR.PROCESS_DANGLING_ROWS(p_worker_id);')) then

15:
16: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);
17:
18: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process,
19: 'PJI_RM_SUM_EXTR.PROCESS_DANGLING_ROWS(p_worker_id);')) then
20: return;
21: end if;
22:
23: --The calendar_type is hard coded as 'C'. The dangling 'P' and 'G'

Line 93: 'PJI_RM_SUM_EXTR.PROCESS_DANGLING_ROWS(p_worker_id);');

89: tmp1.TIME_ID >= res_map.EN_CALENDAR_MIN_DATE and
90: tmp1.TIME_ID <= res_map.EN_CALENDAR_MAX_DATE;
91:
92: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION (l_process,
93: 'PJI_RM_SUM_EXTR.PROCESS_DANGLING_ROWS(p_worker_id);');
94:
95: commit;
96:
97: end PROCESS_DANGLING_ROWS;

Line 111: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_RM_SUM_EXTR.PURGE_DANGLING_ROWS(p_worker_id);')) then

107: begin
108:
109: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);
110:
111: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_RM_SUM_EXTR.PURGE_DANGLING_ROWS(p_worker_id);')) then
112: return;
113: end if;
114:
115: delete /*+ parallel(res) */

Line 122: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION (l_process, 'PJI_RM_SUM_EXTR.PURGE_DANGLING_ROWS(p_worker_id);');

118: ROWID in (select ROW_ID
119: from PJI_RM_AGGR_RES1
120: where WORKER_ID = p_worker_id);
121:
122: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION (l_process, 'PJI_RM_SUM_EXTR.PURGE_DANGLING_ROWS(p_worker_id);');
123:
124: commit;
125:
126: end PURGE_DANGLING_ROWS;

Line 141: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_RM_SUM_EXTR.RES_ROWID_TABLE(p_worker_id);')) then

137: begin
138:
139: l_process := PJI_RM_SUM_MAIN.g_process || p_worker_id;
140:
141: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_RM_SUM_EXTR.RES_ROWID_TABLE(p_worker_id);')) then
142: return;
143: end if;
144:
145: insert /*+ append parallel(res_i) */ into PJI_PJI_RMAP_RES res_i

Line 165: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_RM_SUM_EXTR.RES_ROWID_TABLE(p_worker_id);');

161: denorm.UTILIZATION_FLAG = 'Y' and
162: to_date(to_char(res6.TIME_ID), 'J') between denorm.START_DATE and
163: denorm.END_DATE;
164:
165: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_RM_SUM_EXTR.RES_ROWID_TABLE(p_worker_id);');
166:
167: commit;
168:
169: end RES_ROWID_TABLE;

Line 198: 'PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID_FULL(p_worker_id);')) then

194:
195: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);
196:
197: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process,
198: 'PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID_FULL(p_worker_id);')) then
199: return;
200: end if;
201:
202: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 433: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID_FULL(p_worker_id);');

429: nvl(UNASSIGNED_HRS_S, 0) <> 0 or
430: nvl(CONF_OVERCOM_HRS_S, 0) <> 0 or
431: nvl(PROV_OVERCOM_HRS_S, 0) <> 0;
432:
433: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID_FULL(p_worker_id);');
434:
435: COMMIT;
436:
437: end EXTRACT_BATCH_FID_FULL;

Line 464: IF (NOT PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID_ROWIDS(p_worker_id);')) THEN

460: BEGIN
461:
462: l_process := PJI_RM_SUM_MAIN.g_process || TO_CHAR(p_worker_id);
463:
464: IF (NOT PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID_ROWIDS(p_worker_id);')) THEN
465: RETURN;
466: END IF;
467:
468: -- JOB_ID Util --> Non-Util: make sure source reversals are not summarized

Line 572: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID_ROWIDS(p_worker_id);');

568: fcst.WORKER_ID is null;
569:
570: end if;
571:
572: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID_ROWIDS(p_worker_id);');
573:
574: COMMIT;
575:
576: END EXTRACT_BATCH_FID_ROWIDS;

Line 604: IF (NOT PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID(p_worker_id);')) THEN

600: BEGIN
601:
602: l_process := PJI_RM_SUM_MAIN.g_process || TO_CHAR(p_worker_id);
603:
604: IF (NOT PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID(p_worker_id);')) THEN
605: RETURN;
606: END IF;
607:
608: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 848: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID(p_worker_id);');

844: nvl(UNASSIGNED_HRS_S, 0) <> 0 or
845: nvl(CONF_OVERCOM_HRS_S, 0) <> 0 or
846: nvl(PROV_OVERCOM_HRS_S, 0) <> 0;
847:
848: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID(p_worker_id);');
849:
850: COMMIT;
851:
852: END EXTRACT_BATCH_FID;

Line 866: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_RM_SUM_EXTR.MOVE_DANGLING_ROWS(p_worker_id);')) then

862: begin
863:
864: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);
865:
866: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_RM_SUM_EXTR.MOVE_DANGLING_ROWS(p_worker_id);')) then
867: return;
868: end if;
869:
870: insert into PJI_RM_DNGL_RES

Line 925: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION (l_process, 'PJI_RM_SUM_EXTR.MOVE_DANGLING_ROWS(p_worker_id);');

921: from PJI_RM_AGGR_RES1
922: where WORKER_ID = p_worker_id and
923: DANGLING_FLAG is not null;
924:
925: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION (l_process, 'PJI_RM_SUM_EXTR.MOVE_DANGLING_ROWS(p_worker_id);');
926:
927: commit;
928:
929: end MOVE_DANGLING_ROWS;

Line 944: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_RM_SUM_EXTR.PURGE_RES_DATA(p_worker_id);')) then

940: begin
941:
942: l_process := PJI_RM_SUM_MAIN.g_process || p_worker_id;
943:
944: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_RM_SUM_EXTR.PURGE_RES_DATA(p_worker_id);')) then
945: return;
946: end if;
947:
948: delete

Line 954: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_RM_SUM_EXTR.PURGE_RES_DATA(p_worker_id);');

950: where ROWID in (select STG_ROWID
951: from PJI_PJI_RMAP_RES
952: where WORKER_ID = p_worker_id);
953:
954: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_RM_SUM_EXTR.PURGE_RES_DATA(p_worker_id);');
955:
956: commit;
957:
958: end PURGE_RES_DATA;

Line 978: 'PJI_RM_SUM_EXTR.GET_JOB_ID_LOOKUPS(p_worker_id);'

974:
975: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP
976: (
977: l_process,
978: 'PJI_RM_SUM_EXTR.GET_JOB_ID_LOOKUPS(p_worker_id);'
979: )) then
980: return;
981: end if;
982:

Line 1014: 'PJI_RM_SUM_EXTR.GET_JOB_ID_LOOKUPS(p_worker_id);'

1010:
1011: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION
1012: (
1013: l_process,
1014: 'PJI_RM_SUM_EXTR.GET_JOB_ID_LOOKUPS(p_worker_id);'
1015: );
1016:
1017: commit;
1018:

Line 1040: 'PJI_RM_SUM_EXTR.PROCESS_JOB_ID(p_worker_id);'

1036:
1037: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP
1038: (
1039: l_process,
1040: 'PJI_RM_SUM_EXTR.PROCESS_JOB_ID(p_worker_id);'
1041: )) then
1042: return;
1043: end if;
1044:

Line 1458: 'PJI_RM_SUM_EXTR.PROCESS_JOB_ID(p_worker_id);'

1454:
1455: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION
1456: (
1457: l_process,
1458: 'PJI_RM_SUM_EXTR.PROCESS_JOB_ID(p_worker_id);'
1459: );
1460:
1461: commit;
1462:

Line 1481: 'PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS_PRE(p_worker_id);')) then

1477:
1478: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);
1479:
1480: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process,
1481: 'PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS_PRE(p_worker_id);')) then
1482: return;
1483: end if;
1484:
1485: insert /*+ append */ into PJI_HELPER_BATCH_MAP

Line 1502: 'PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS_PRE(p_worker_id);');

1498: where
1499: PJI_SUMMARIZED_FLAG is not null;
1500:
1501: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION (l_process,
1502: 'PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS_PRE(p_worker_id);');
1503:
1504: commit;
1505:
1506: end MARK_EXTRACTED_ROWS_PRE;

Line 1533: 'PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS(p_worker_id);')) then

1529:
1530: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);
1531:
1532: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process,
1533: 'PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS(p_worker_id);')) then
1534: return;
1535: end if;
1536:
1537: l_last_update_date := sysdate;

Line 1603: STEP_NAME = 'PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS(p_worker_id);' and

1599:
1600: update PJI_SYSTEM_PRC_STATUS
1601: set STEP_STATUS = 'C'
1602: where PROCESS_NAME like PJI_RM_SUM_MAIN.g_process|| to_char(x) and
1603: STEP_NAME = 'PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS(p_worker_id);' and
1604: START_DATE is null;
1605:
1606: commit;
1607:

Line 1619: 'PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS(p_worker_id);');

1615:
1616: end loop;
1617:
1618: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION (l_process,
1619: 'PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS(p_worker_id);');
1620:
1621: commit;
1622:
1623: end MARK_EXTRACTED_ROWS;

Line 1641: 'PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS_POST(p_worker_id);')) then

1637:
1638: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);
1639:
1640: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process,
1641: 'PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS_POST(p_worker_id);')) then
1642: return;
1643: end if;
1644:
1645: PJI_PROCESS_UTIL.TRUNC_INT_TABLE('PJI',

Line 1651: 'PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS_POST(p_worker_id);');

1647: 'NORMAL',
1648: null);
1649:
1650: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION (l_process,
1651: 'PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS_POST(p_worker_id);');
1652:
1653: commit;
1654:
1655: end MARK_EXTRACTED_ROWS_POST;

Line 1811: PJI_RM_SUM_EXTR.PROCESS_DANGLING_ROWS(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);
1812: PJI_RM_SUM_EXTR.PURGE_DANGLING_ROWS(p_worker_id);
1813: PJI_RM_SUM_ROLLUP_RES.JOB_NONUTIL2UTIL(p_worker_id);
1814: PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID_ROWIDS(p_worker_id);
1815:

Line 1812: PJI_RM_SUM_EXTR.PURGE_DANGLING_ROWS(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);
1812: PJI_RM_SUM_EXTR.PURGE_DANGLING_ROWS(p_worker_id);
1813: PJI_RM_SUM_ROLLUP_RES.JOB_NONUTIL2UTIL(p_worker_id);
1814: PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID_ROWIDS(p_worker_id);
1815:
1816: PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS_PRE(p_worker_id);

Line 1814: PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID_ROWIDS(p_worker_id);

1810:
1811: PJI_RM_SUM_EXTR.PROCESS_DANGLING_ROWS(p_worker_id);
1812: PJI_RM_SUM_EXTR.PURGE_DANGLING_ROWS(p_worker_id);
1813: PJI_RM_SUM_ROLLUP_RES.JOB_NONUTIL2UTIL(p_worker_id);
1814: PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID_ROWIDS(p_worker_id);
1815:
1816: PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS_PRE(p_worker_id);
1817: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
1818: (PJI_RM_SUM_MAIN.g_process,

Line 1816: PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS_PRE(p_worker_id);

1812: PJI_RM_SUM_EXTR.PURGE_DANGLING_ROWS(p_worker_id);
1813: PJI_RM_SUM_ROLLUP_RES.JOB_NONUTIL2UTIL(p_worker_id);
1814: PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID_ROWIDS(p_worker_id);
1815:
1816: PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS_PRE(p_worker_id);
1817: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
1818: (PJI_RM_SUM_MAIN.g_process,
1819: 'PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS(p_worker_id);',
1820: PJI_RM_SUM_MAIN.g_process_delay)) then

Line 1819: 'PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS(p_worker_id);',

1815:
1816: PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS_PRE(p_worker_id);
1817: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
1818: (PJI_RM_SUM_MAIN.g_process,
1819: 'PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS(p_worker_id);',
1820: PJI_RM_SUM_MAIN.g_process_delay)) then
1821: return;
1822: end if;
1823: PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS_POST(p_worker_id);

Line 1823: PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS_POST(p_worker_id);

1819: 'PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS(p_worker_id);',
1820: PJI_RM_SUM_MAIN.g_process_delay)) then
1821: return;
1822: end if;
1823: PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS_POST(p_worker_id);
1824:
1825: PJI_RM_SUM_EXTR.RES_ROWID_TABLE(p_worker_id);
1826: PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID_FULL(p_worker_id);
1827: PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID(p_worker_id);

Line 1825: PJI_RM_SUM_EXTR.RES_ROWID_TABLE(p_worker_id);

1821: return;
1822: end if;
1823: PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS_POST(p_worker_id);
1824:
1825: PJI_RM_SUM_EXTR.RES_ROWID_TABLE(p_worker_id);
1826: PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID_FULL(p_worker_id);
1827: PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID(p_worker_id);
1828: PJI_RM_SUM_EXTR.MOVE_DANGLING_ROWS(p_worker_id);
1829: PJI_RM_SUM_EXTR.PURGE_RES_DATA(p_worker_id);

Line 1826: PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID_FULL(p_worker_id);

1822: end if;
1823: PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS_POST(p_worker_id);
1824:
1825: PJI_RM_SUM_EXTR.RES_ROWID_TABLE(p_worker_id);
1826: PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID_FULL(p_worker_id);
1827: PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID(p_worker_id);
1828: PJI_RM_SUM_EXTR.MOVE_DANGLING_ROWS(p_worker_id);
1829: PJI_RM_SUM_EXTR.PURGE_RES_DATA(p_worker_id);
1830: PJI_RM_SUM_EXTR.GET_JOB_ID_LOOKUPS(p_worker_id);

Line 1827: PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID(p_worker_id);

1823: PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS_POST(p_worker_id);
1824:
1825: PJI_RM_SUM_EXTR.RES_ROWID_TABLE(p_worker_id);
1826: PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID_FULL(p_worker_id);
1827: PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID(p_worker_id);
1828: PJI_RM_SUM_EXTR.MOVE_DANGLING_ROWS(p_worker_id);
1829: PJI_RM_SUM_EXTR.PURGE_RES_DATA(p_worker_id);
1830: PJI_RM_SUM_EXTR.GET_JOB_ID_LOOKUPS(p_worker_id);
1831: PJI_RM_SUM_EXTR.PROCESS_JOB_ID(p_worker_id);

Line 1828: PJI_RM_SUM_EXTR.MOVE_DANGLING_ROWS(p_worker_id);

1824:
1825: PJI_RM_SUM_EXTR.RES_ROWID_TABLE(p_worker_id);
1826: PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID_FULL(p_worker_id);
1827: PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID(p_worker_id);
1828: PJI_RM_SUM_EXTR.MOVE_DANGLING_ROWS(p_worker_id);
1829: PJI_RM_SUM_EXTR.PURGE_RES_DATA(p_worker_id);
1830: PJI_RM_SUM_EXTR.GET_JOB_ID_LOOKUPS(p_worker_id);
1831: PJI_RM_SUM_EXTR.PROCESS_JOB_ID(p_worker_id);
1832:

Line 1829: PJI_RM_SUM_EXTR.PURGE_RES_DATA(p_worker_id);

1825: PJI_RM_SUM_EXTR.RES_ROWID_TABLE(p_worker_id);
1826: PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID_FULL(p_worker_id);
1827: PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID(p_worker_id);
1828: PJI_RM_SUM_EXTR.MOVE_DANGLING_ROWS(p_worker_id);
1829: PJI_RM_SUM_EXTR.PURGE_RES_DATA(p_worker_id);
1830: PJI_RM_SUM_EXTR.GET_JOB_ID_LOOKUPS(p_worker_id);
1831: PJI_RM_SUM_EXTR.PROCESS_JOB_ID(p_worker_id);
1832:
1833: PJI_RM_SUM_ROLLUP_RES.CALC_RMS_AVL_AND_WT(p_worker_id);

Line 1830: PJI_RM_SUM_EXTR.GET_JOB_ID_LOOKUPS(p_worker_id);

1826: PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID_FULL(p_worker_id);
1827: PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID(p_worker_id);
1828: PJI_RM_SUM_EXTR.MOVE_DANGLING_ROWS(p_worker_id);
1829: PJI_RM_SUM_EXTR.PURGE_RES_DATA(p_worker_id);
1830: PJI_RM_SUM_EXTR.GET_JOB_ID_LOOKUPS(p_worker_id);
1831: PJI_RM_SUM_EXTR.PROCESS_JOB_ID(p_worker_id);
1832:
1833: PJI_RM_SUM_ROLLUP_RES.CALC_RMS_AVL_AND_WT(p_worker_id);
1834:

Line 1831: PJI_RM_SUM_EXTR.PROCESS_JOB_ID(p_worker_id);

1827: PJI_RM_SUM_EXTR.EXTRACT_BATCH_FID(p_worker_id);
1828: PJI_RM_SUM_EXTR.MOVE_DANGLING_ROWS(p_worker_id);
1829: PJI_RM_SUM_EXTR.PURGE_RES_DATA(p_worker_id);
1830: PJI_RM_SUM_EXTR.GET_JOB_ID_LOOKUPS(p_worker_id);
1831: PJI_RM_SUM_EXTR.PROCESS_JOB_ID(p_worker_id);
1832:
1833: PJI_RM_SUM_ROLLUP_RES.CALC_RMS_AVL_AND_WT(p_worker_id);
1834:
1835: PJI_RM_SUM_AVL.INS_INTO_RES_STATUS(p_worker_id);

Line 1991: 'PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS_PRE(p_worker_id);',

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);',
1992: PJI_RM_SUM_MAIN.g_process_delay)) then
1993: return;
1994: end if;
1995:

Line 1996: PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS(p_worker_id);

1992: PJI_RM_SUM_MAIN.g_process_delay)) then
1993: return;
1994: end if;
1995:
1996: PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS(p_worker_id);
1997:
1998: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
1999: (PJI_RM_SUM_MAIN.g_process,
2000: 'PJI_RM_SUM_AVL.INS_INTO_RES_STATUS(p_worker_id);',

Line 2182: end PJI_RM_SUM_EXTR;

2178: PJI_RM_SUM_MAIN.g_process_delay);
2179:
2180: end WAIT_FOR_WORKER;
2181:
2182: end PJI_RM_SUM_EXTR;