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_MAIN

Line 16: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);

12: l_process varchar2(30);
13:
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;

Line 109: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);

105: l_process varchar2(30);
106:
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;

Line 139: l_process := PJI_RM_SUM_MAIN.g_process || p_worker_id;

135: l_schema varchar2(30);
136:
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;

Line 195: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);

191: and fid.pji_summarized_flag = 'N';
192:
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;

Line 203: (PJI_RM_SUM_MAIN.g_process,

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;
207:

Line 210: PJI_RM_SUM_MAIN.g_date_mask), 'J'));

206: end if;
207:
208: l_min_date := to_number(to_char(to_date(
209: PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),
210: PJI_RM_SUM_MAIN.g_date_mask), 'J'));
211:
212: insert /*+ append parallel(res1_i) */ into PJI_RM_AGGR_RES1 res1_i
213: (
214: WORKER_ID,

Line 462: l_process := PJI_RM_SUM_MAIN.g_process || TO_CHAR(p_worker_id);

458: l_program_update_date date;
459:
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;

Line 508: (PJI_RM_SUM_MAIN.g_process, 'EXTRACTION_TYPE');

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:
512: insert /*+ append */ into PJI_RM_REXT_FCSTITEM

Line 527: , ceil(ROWNUM / PJI_RM_SUM_MAIN.g_commit_threshold)

523: , fid.ROWID
524: , null
525: , null
526: , fid.PJI_SUMMARIZED_FLAG
527: , ceil(ROWNUM / PJI_RM_SUM_MAIN.g_commit_threshold)
528: FROM
529: PA_FORECAST_ITEM_DETAILS fid
530: WHERE
531: fid.PJI_SUMMARIZED_FLAG = 'N';

Line 554: , ceil(ROWNUM / PJI_RM_SUM_MAIN.g_commit_threshold)

550: , fid.ROWID FID_ROWID
551: , bat.start_date START_DATE
552: , bat.end_date END_DATE
553: , fid.PJI_SUMMARIZED_FLAG
554: , ceil(ROWNUM / PJI_RM_SUM_MAIN.g_commit_threshold)
555: FROM
556: pji_rm_org_batch_map bat
557: , pa_forecast_item_details fid
558: , pji_rm_rext_fcstitem fcst

Line 602: l_process := PJI_RM_SUM_MAIN.g_process || TO_CHAR(p_worker_id);

598: l_program_update_date date;
599:
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;

Line 609: (PJI_RM_SUM_MAIN.g_process, 'EXTRACTION_TYPE');

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

Line 617: PJI_RM_SUM_MAIN.g_date_mask), 'J'));

613: end if;
614:
615: l_min_date := to_number(to_char(to_date(
616: PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),
617: PJI_RM_SUM_MAIN.g_date_mask), 'J'));
618:
619: -- implicit commit
620: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
621: tabname => 'PJI_RM_REXT_FCSTITEM',

Line 864: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);

860: l_process varchar2(30);
861:
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;

Line 942: l_process := PJI_RM_SUM_MAIN.g_process || p_worker_id;

938: l_schema varchar2(30);
939:
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;

Line 973: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);

969: l_process varchar2(30);
970:
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,

Line 1035: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);

1031: l_extraction_type varchar2(30);
1032:
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,

Line 1046: (PJI_RM_SUM_MAIN.g_process, 'EXTRACTION_TYPE');

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: (
1050: WORKER_ID,

Line 1478: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);

1474: l_process varchar2(30);
1475:
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;

Line 1530: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);

1526: l_row_count number;
1527:
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;

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 1602: where PROCESS_NAME like PJI_RM_SUM_MAIN.g_process|| to_char(x) and

1598: for x in 2 .. l_parallel_processes loop
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;

Line 1638: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);

1634: l_process varchar2(30);
1635:
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;

Line 1671: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);

1667: l_schema varchar2(30);
1668:
1669: begin
1670:
1671: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);
1672:
1673: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
1674:
1675: PJI_PJ_PROJ_CLASS_EXTR.CLEANUP(p_worker_id);

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 1801: (PJI_RM_SUM_MAIN.g_process,

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

Line 1803: PJI_RM_SUM_MAIN.g_process_delay)) then

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);
1807: PJI_FM_PLAN_EXTR.UPDATE_BATCH_STATUSES(p_worker_id);

Line 1818: (PJI_RM_SUM_MAIN.g_process,

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

Line 1820: PJI_RM_SUM_MAIN.g_process_delay)) then

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);
1824:

Line 1837: (PJI_RM_SUM_MAIN.g_process,

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

Line 1839: PJI_RM_SUM_MAIN.g_process_delay)) then

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;
1841: end if;
1842:
1843: PJI_FM_SUM_BKLG.ROWID_ACTIVITY_DATES_FIN(p_worker_id);

Line 1892: (PJI_RM_SUM_MAIN.g_process,

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

Line 1894: PJI_RM_SUM_MAIN.g_process_delay)) then

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;
1896: end if;
1897: PJI_RM_SUM_AVL.MERGE_ORG_AVL_DUR(p_worker_id);
1898: PJI_RM_SUM_AVL.MERGE_CURR_ORG_AVL(p_worker_id);

Line 1909: (PJI_RM_SUM_MAIN.g_process,

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

Line 1911: PJI_RM_SUM_MAIN.g_process_delay)) then

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;
1913: end if;
1914:
1915: PJI_FM_SUM_ROLLUP_ACT.EXPAND_ACT_CAL_EN(p_worker_id, 'Y');

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 1968: PJI_RM_SUM_MAIN.g_process ||

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.');
1972: commit;

Line 1977: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);

1973: retcode := 0;
1974: return;
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);',

Line 1980: (PJI_RM_SUM_MAIN.g_process,

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

Line 1982: PJI_RM_SUM_MAIN.g_process_delay,

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;
1986:

Line 1990: (PJI_RM_SUM_MAIN.g_process,

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

Line 1992: PJI_RM_SUM_MAIN.g_process_delay)) then

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:
1996: PJI_RM_SUM_EXTR.MARK_EXTRACTED_ROWS(p_worker_id);

Line 1999: (PJI_RM_SUM_MAIN.g_process,

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

Line 2001: PJI_RM_SUM_MAIN.g_process_delay)) then

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;
2003: end if;
2004:
2005: PJI_RM_SUM_AVL.START_RES_AVL_CALC_R1(p_worker_id);

Line 2008: (PJI_RM_SUM_MAIN.g_process,

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

Line 2010: PJI_RM_SUM_MAIN.g_process_delay)) then

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;
2012: end if;
2013:
2014: PJI_RM_SUM_AVL.START_RES_AVL_CALC_R2(p_worker_id);

Line 2017: (PJI_RM_SUM_MAIN.g_process,

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

Line 2019: PJI_RM_SUM_MAIN.g_process_delay)) then

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;
2021: end if;
2022:
2023: PJI_FM_SUM_BKLG.PROCESS_DRMT_BKLG(p_worker_id);

Line 2026: (PJI_RM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'Y') loop

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:
2030: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

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 2031: (PJI_RM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'F') then

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:
2035: PJI_PROCESS_UTIL.WRAPUP_PROCESS(l_process);

Line 2069: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);

2065: if (WORKER_STATUS(p_worker_id, 'RUNNING')) then
2066: return;
2067: end if;
2068:
2069: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);
2070:
2071: -- Initialize status tables with worker details
2072:
2073: -- Note that adding a new step will do nothing if the step already

Line 2078: (PJI_RM_SUM_MAIN.g_process, 'EXTRACTION_TYPE');

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:
2082: -- Kick off worker

Line 2086: PJI_RM_SUM_MAIN.g_process,

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
2089: (
2090: PJI_UTILS.GET_PJI_SCHEMA_NAME, -- Application name

Line 2091: PJI_RM_SUM_MAIN.g_helper_name, -- concurrent program name

2087: l_process,
2088: FND_REQUEST.SUBMIT_REQUEST
2089: (
2090: PJI_UTILS.GET_PJI_SCHEMA_NAME, -- Application name
2091: PJI_RM_SUM_MAIN.g_helper_name, -- concurrent program name
2092: null, -- description (optional)
2093: null, -- Start Time (optional)
2094: false, -- called from another conc. request
2095: p_worker_id -- first parameter

Line 2100: (PJI_RM_SUM_MAIN.g_process, l_process)), 0) = 0) then

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;
2104:

Line 2124: (PJI_RM_SUM_MAIN.g_process, 'EXTRACTION_TYPE');

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:
2128: if (l_extraction_type = 'FULL') then

Line 2129: l_worker_name := PJI_RM_SUM_MAIN.g_full_disp_name;

2125:
2126: if (p_worker_id = 1) then
2127:
2128: if (l_extraction_type = 'FULL') then
2129: l_worker_name := PJI_RM_SUM_MAIN.g_full_disp_name;
2130: elsif (l_extraction_type = 'INCREMENTAL') then
2131: l_worker_name := PJI_RM_SUM_MAIN.g_incr_disp_name;
2132: elsif (l_extraction_type = 'PARTIAL') then
2133: l_worker_name := PJI_RM_SUM_MAIN.g_prtl_disp_name;

Line 2131: l_worker_name := PJI_RM_SUM_MAIN.g_incr_disp_name;

2127:
2128: if (l_extraction_type = 'FULL') then
2129: l_worker_name := PJI_RM_SUM_MAIN.g_full_disp_name;
2130: elsif (l_extraction_type = 'INCREMENTAL') then
2131: l_worker_name := PJI_RM_SUM_MAIN.g_incr_disp_name;
2132: elsif (l_extraction_type = 'PARTIAL') then
2133: l_worker_name := PJI_RM_SUM_MAIN.g_prtl_disp_name;
2134: end if;
2135:

Line 2133: l_worker_name := PJI_RM_SUM_MAIN.g_prtl_disp_name;

2129: l_worker_name := PJI_RM_SUM_MAIN.g_full_disp_name;
2130: elsif (l_extraction_type = 'INCREMENTAL') then
2131: l_worker_name := PJI_RM_SUM_MAIN.g_incr_disp_name;
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,

Line 2137: (PJI_RM_SUM_MAIN.g_process,

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
2141:

Line 2138: PJI_RM_SUM_MAIN.g_process);

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
2141:
2142: l_process := PJI_RM_SUM_MAIN.g_process || p_worker_id;

Line 2142: l_process := PJI_RM_SUM_MAIN.g_process || p_worker_id;

2138: PJI_RM_SUM_MAIN.g_process);
2139:
2140: else
2141:
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

Line 2144: l_worker_name := PJI_RM_SUM_MAIN.g_helper_name;

2140: else
2141:
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:

Line 2147: (PJI_RM_SUM_MAIN.g_process, l_process);

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:
2151: return PJI_PROCESS_UTIL.REQUEST_STATUS(p_mode,

Line 2168: l_process := PJI_RM_SUM_MAIN.g_process || to_char(p_worker_id);

2164: l_request_id number;
2165:
2166: begin
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: (

Line 2173: PJI_RM_SUM_MAIN.g_process,

2169:
2170: l_request_id :=
2171: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
2172: (
2173: PJI_RM_SUM_MAIN.g_process,
2174: l_process
2175: );
2176:
2177: PJI_PROCESS_UTIL.WAIT_FOR_REQUEST(l_request_id,

Line 2178: PJI_RM_SUM_MAIN.g_process_delay);

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:
2182: end PJI_RM_SUM_EXTR;