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_PROCESS_UTIL

Line 18: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process,

14: begin
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:

Line 92: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION (l_process,

88: tmp1.TIME_ID <= res_map.GL_CALENDAR_MAX_DATE and
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:

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 197: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process,

193: begin
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:

Line 202: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

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
203: (PJI_RM_SUM_MAIN.g_process,
204: 'EXTRACTION_TYPE') <> 'FULL' ) then
205: return;
206: end if;

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 507: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

503: delta.END_DATE);
504:
505: end if;
506:
507: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
508: (PJI_RM_SUM_MAIN.g_process, 'EXTRACTION_TYPE');
509:
510: if (l_extraction_type = 'FULL') then
511:

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 608: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

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
609: (PJI_RM_SUM_MAIN.g_process, 'EXTRACTION_TYPE');
610:
611: if (l_extraction_type = 'FULL' ) then
612: return;

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 975: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP

971: begin
972:
973: l_process := PJI_RM_SUM_MAIN.g_process || to_char(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

Line 1011: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION

1007: RECORD_TYPE = 'U' and
1008: CAPACITY_HRS >= 0 and
1009: UNASSIGNED_HRS_S >= 0;
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: );

Line 1037: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP

1033: begin
1034:
1035: l_process := PJI_RM_SUM_MAIN.g_process || to_char(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

Line 1045: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

1041: )) then
1042: return;
1043: end if;
1044:
1045: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
1046: (PJI_RM_SUM_MAIN.g_process, 'EXTRACTION_TYPE');
1047:
1048: insert /*+ append parallel(res1_i) */ into PJI_RM_AGGR_RES1 res1_i
1049: (

Line 1455: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION

1451: CALENDAR_TYPE,
1452: GL_CALENDAR_ID,
1453: PA_CALENDAR_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: );

Line 1480: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process,

1476: begin
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:

Line 1501: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION (l_process,

1497: PJI_RM_REXT_FCSTITEM
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:

Line 1532: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process,

1528: begin
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:

Line 1596: l_parallel_processes := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_RM_SUM_MAIN.g_process, 'PARALLEL_PROCESSES');

1592: where nvl(STATUS, 'X') <> 'C';
1593:
1594: if (l_row_count = 0) then
1595:
1596: l_parallel_processes := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_RM_SUM_MAIN.g_process, 'PARALLEL_PROCESSES');
1597:
1598: for x in 2 .. l_parallel_processes loop
1599:
1600: update PJI_SYSTEM_PRC_STATUS

Line 1618: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION (l_process,

1614: end if;
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:

Line 1640: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process,

1636: begin
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:

Line 1645: PJI_PROCESS_UTIL.TRUNC_INT_TABLE('PJI',

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',
1646: 'PJI_HELPER_BATCH_MAP',
1647: 'NORMAL',
1648: null);
1649:

Line 1650: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION (l_process,

1646: 'PJI_HELPER_BATCH_MAP',
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:

Line 1679: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,

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',
1681: 'NORMAL',
1682: null);
1683:

Line 1684: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,

1680: 'PJI_RM_REXT_FCSTITEM',
1681: 'NORMAL',
1682: null);
1683:
1684: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
1685: 'PJI_PJI_RMAP_RES',
1686: 'NORMAL',
1687: null);
1688:

Line 1689: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,

1685: 'PJI_PJI_RMAP_RES',
1686: 'NORMAL',
1687: null);
1688:
1689: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
1690: 'PJI_PJI_RMAP_FIN',
1691: 'NORMAL',
1692: null);
1693:

Line 1694: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,

1690: 'PJI_PJI_RMAP_FIN',
1691: 'NORMAL',
1692: null);
1693:
1694: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
1695: 'PJI_PJI_RMAP_ACT',
1696: 'NORMAL',
1697: null);
1698:

Line 1699: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,

1695: 'PJI_PJI_RMAP_ACT',
1696: 'NORMAL',
1697: null);
1698:
1699: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
1700: 'PJI_RM_AGGR_RES3',
1701: 'NORMAL',
1702: null);
1703:

Line 1704: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,

1700: 'PJI_RM_AGGR_RES3',
1701: 'NORMAL',
1702: null);
1703:
1704: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
1705: 'PJI_RES_DELTA',
1706: 'NORMAL',
1707: null);
1708:

Line 1713: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,

1709: delete
1710: from PJI_FM_AGGR_DLY_RATES
1711: where WORKER_ID = -1;
1712:
1713: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
1714: 'PJI_FM_RMAP_FIN',
1715: 'NORMAL',
1716: null);
1717:

Line 1718: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,

1714: 'PJI_FM_RMAP_FIN',
1715: 'NORMAL',
1716: null);
1717:
1718: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
1719: 'PJI_FM_RMAP_ACT',
1720: 'NORMAL',
1721: null);
1722:

Line 1737: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(PJI_RM_SUM_MAIN.g_process, 'PROCESS_RUNNING', 'F');

1733: begin
1734:
1735: rollback;
1736:
1737: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(PJI_RM_SUM_MAIN.g_process, 'PROCESS_RUNNING', 'F');
1738:
1739: commit;
1740:
1741: pji_utils.write2log(sqlerrm, true, 0);

Line 1774: PJI_PROCESS_UTIL.CLEAN_HELPER_BATCH_TABLE;

1770:
1771: -- Populate Rolling Week Offset Table if it is not populated
1772: PJI_RM_SUM_AVL.POP_ROLL_WEEK_OFFSET;
1773:
1774: PJI_PROCESS_UTIL.CLEAN_HELPER_BATCH_TABLE;
1775:
1776: -- Procedure updates project classification dimension tables
1777: -- PJI_CLASS_CODES and PJI_CLASS_CATEGORIES. Data extraction is
1778: -- always incremental.

Line 1800: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

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
1804: return;

Line 1817: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

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
1821: return;

Line 1836: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

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);
1836: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
1837: (PJI_RM_SUM_MAIN.g_process,
1838: 'PJI_RM_SUM_AVL.START_RES_AVL_CALC_R1(p_worker_id);',
1839: PJI_RM_SUM_MAIN.g_process_delay)) then
1840: return;

Line 1891: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

1887: PJI_RM_SUM_ROLLUP_RES.MERGE_TMP2_INTO_RMS(p_worker_id);
1888: PJI_RM_SUM_ROLLUP_RES.CLEANUP_RMS(p_worker_id);
1889:
1890: PJI_RM_SUM_AVL.UPDATE_RES_STA_FOR_RUN2(p_worker_id);
1891: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
1892: (PJI_RM_SUM_MAIN.g_process,
1893: 'PJI_RM_SUM_AVL.START_RES_AVL_CALC_R2(p_worker_id);',
1894: PJI_RM_SUM_MAIN.g_process_delay)) then
1895: return;

Line 1908: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

1904: PJI_FM_SUM_ROLLUP_ACT.MERGE_ACT_INTO_ACP(p_worker_id, 'N');
1905:
1906: PJI_FM_SUM_BKLG.SCOPE_PROJECTS_BKLG(p_worker_id);
1907: PJI_FM_SUM_BKLG.CLEANUP_INT_TABLE(p_worker_id);
1908: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
1909: (PJI_RM_SUM_MAIN.g_process,
1910: 'PJI_FM_SUM_BKLG.PROCESS_DRMT_BKLG(p_worker_id);',
1911: PJI_RM_SUM_MAIN.g_process_delay)) then
1912: return;

Line 1967: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_RM_SUM_MAIN.g_process,

1963:
1964: -- If this helper's concurrent request ID does not exist in the
1965: -- parameters table, the dispatcher must have kicked off a new
1966: -- helper. Therefore do nothing.
1967: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_RM_SUM_MAIN.g_process,
1968: PJI_RM_SUM_MAIN.g_process ||
1969: to_char(p_worker_id))
1970: <> FND_GLOBAL.CONC_REQUEST_ID) then
1971: pji_utils.write2log('Warning: Helper is already running.');

Line 1979: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

1975: end if;
1976:
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

Line 1989: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

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

Line 1998: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

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);',
2001: PJI_RM_SUM_MAIN.g_process_delay)) then
2002: return;

Line 2007: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

2003: end if;
2004:
2005: PJI_RM_SUM_AVL.START_RES_AVL_CALC_R1(p_worker_id);
2006:
2007: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
2008: (PJI_RM_SUM_MAIN.g_process,
2009: 'PJI_RM_SUM_AVL.UPDATE_RES_STA_FOR_RUN2(p_worker_id);',
2010: PJI_RM_SUM_MAIN.g_process_delay)) then
2011: return;

Line 2016: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

2012: end if;
2013:
2014: PJI_RM_SUM_AVL.START_RES_AVL_CALC_R2(p_worker_id);
2015:
2016: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
2017: (PJI_RM_SUM_MAIN.g_process,
2018: 'PJI_FM_SUM_BKLG.CLEANUP_INT_TABLE(p_worker_id);',
2019: PJI_RM_SUM_MAIN.g_process_delay)) then
2020: return;

Line 2025: while (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

2021: end if;
2022:
2023: PJI_FM_SUM_BKLG.PROCESS_DRMT_BKLG(p_worker_id);
2024:
2025: while (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
2026: (PJI_RM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'Y') loop
2027: PJI_PROCESS_UTIL.SLEEP(PJI_RM_SUM_MAIN.g_process_delay);
2028: end loop;
2029:

Line 2027: PJI_PROCESS_UTIL.SLEEP(PJI_RM_SUM_MAIN.g_process_delay);

2023: PJI_FM_SUM_BKLG.PROCESS_DRMT_BKLG(p_worker_id);
2024:
2025: while (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
2026: (PJI_RM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'Y') loop
2027: PJI_PROCESS_UTIL.SLEEP(PJI_RM_SUM_MAIN.g_process_delay);
2028: end loop;
2029:
2030: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
2031: (PJI_RM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'F') then

Line 2030: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

2026: (PJI_RM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'Y') loop
2027: PJI_PROCESS_UTIL.SLEEP(PJI_RM_SUM_MAIN.g_process_delay);
2028: end loop;
2029:
2030: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
2031: (PJI_RM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'F') then
2032: return;
2033: end if;
2034:

Line 2035: PJI_PROCESS_UTIL.WRAPUP_PROCESS(l_process);

2031: (PJI_RM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'F') then
2032: return;
2033: end if;
2034:
2035: PJI_PROCESS_UTIL.WRAPUP_PROCESS(l_process);
2036:
2037: commit;
2038:
2039: retcode := 0;

Line 2077: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

2073: -- Note that adding a new step will do nothing if the step already
2074: -- exists. Therefore, no state will be overwritten in the case of
2075: -- error recovery.
2076:
2077: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
2078: (PJI_RM_SUM_MAIN.g_process, 'EXTRACTION_TYPE');
2079:
2080: PJI_PROCESS_UTIL.ADD_STEPS(l_process, 'PJI_PJI_HELPER', l_extraction_type);
2081:

Line 2080: PJI_PROCESS_UTIL.ADD_STEPS(l_process, 'PJI_PJI_HELPER', l_extraction_type);

2076:
2077: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
2078: (PJI_RM_SUM_MAIN.g_process, 'EXTRACTION_TYPE');
2079:
2080: PJI_PROCESS_UTIL.ADD_STEPS(l_process, 'PJI_PJI_HELPER', l_extraction_type);
2081:
2082: -- Kick off worker
2083:
2084: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER

Line 2084: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER

2080: PJI_PROCESS_UTIL.ADD_STEPS(l_process, 'PJI_PJI_HELPER', l_extraction_type);
2081:
2082: -- Kick off worker
2083:
2084: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER
2085: (
2086: PJI_RM_SUM_MAIN.g_process,
2087: l_process,
2088: FND_REQUEST.SUBMIT_REQUEST

Line 2099: if (nvl(to_number(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

2095: p_worker_id -- first parameter
2096: )
2097: );
2098:
2099: if (nvl(to_number(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
2100: (PJI_RM_SUM_MAIN.g_process, l_process)), 0) = 0) then
2101: fnd_message.set_name('PJI', 'PJI_SUM_NO_SUB_REQ');
2102: dbms_standard.raise_application_error(-20030, fnd_message.get);
2103: end if;

Line 2123: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

2119: l_extraction_type varchar2(30);
2120:
2121: begin
2122:
2123: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
2124: (PJI_RM_SUM_MAIN.g_process, 'EXTRACTION_TYPE');
2125:
2126: if (p_worker_id = 1) then
2127:

Line 2136: l_request_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

2132: elsif (l_extraction_type = 'PARTIAL') then
2133: l_worker_name := PJI_RM_SUM_MAIN.g_prtl_disp_name;
2134: end if;
2135:
2136: l_request_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
2137: (PJI_RM_SUM_MAIN.g_process,
2138: PJI_RM_SUM_MAIN.g_process);
2139:
2140: else

Line 2146: l_request_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

2142: l_process := PJI_RM_SUM_MAIN.g_process || p_worker_id;
2143:
2144: l_worker_name := PJI_RM_SUM_MAIN.g_helper_name;
2145:
2146: l_request_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
2147: (PJI_RM_SUM_MAIN.g_process, l_process);
2148:
2149: end if;
2150:

Line 2151: return PJI_PROCESS_UTIL.REQUEST_STATUS(p_mode,

2147: (PJI_RM_SUM_MAIN.g_process, l_process);
2148:
2149: end if;
2150:
2151: return PJI_PROCESS_UTIL.REQUEST_STATUS(p_mode,
2152: l_request_id,
2153: l_worker_name);
2154:
2155: end WORKER_STATUS;

Line 2171: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

2167:
2168: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);
2169:
2170: l_request_id :=
2171: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
2172: (
2173: PJI_RM_SUM_MAIN.g_process,
2174: l_process
2175: );

Line 2177: PJI_PROCESS_UTIL.WAIT_FOR_REQUEST(l_request_id,

2173: PJI_RM_SUM_MAIN.g_process,
2174: l_process
2175: );
2176:
2177: PJI_PROCESS_UTIL.WAIT_FOR_REQUEST(l_request_id,
2178: PJI_RM_SUM_MAIN.g_process_delay);
2179:
2180: end WAIT_FOR_WORKER;
2181: