DBA Data[Home] [Help]

APPS.PJI_FM_EXTR dependencies on PJI_UTILS

Line 22: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

18: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_FND(p_worker_id);')) then
19: return;
20: end if;
21:
22: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
23:
24: INSERT /*+ APPEND */ INTO PJI_FM_EXTR_FUNDG
25: (
26: worker_id

Line 394: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

390: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_DREV(p_worker_id);')) then
391: return;
392: end if;
393:
394: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
395:
396: l_transition_flag :=
397: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process,
398: 'TRANSITION');

Line 873: l_min_date := to_date(PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),

869: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_CDL_CRDL_FULL(p_worker_id);')) then
870: return;
871: end if;
872:
873: l_min_date := to_date(PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),
874: PJI_FM_SUM_MAIN.g_date_mask);
875:
876: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') = 'FULL') then
877:

Line 876: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') = 'FULL') then

872:
873: l_min_date := to_date(PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),
874: PJI_FM_SUM_MAIN.g_date_mask);
875:
876: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') = 'FULL') then
877:
878: -- This cleanup is intentionally before the implicit commit so as not
879: -- to interfere with the CDL extraction.
880: if (nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 897: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,

893:
894: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process,
895: 'CURRENT_BATCH') = 1) then
896: -- implicit commit
897: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
898: tabname => 'PJI_FM_EXTR_DREVN',
899: percent => 10,
900: degree => PJI_UTILS.
901: GET_DEGREE_OF_PARALLELISM);

Line 900: degree => PJI_UTILS.

896: -- implicit commit
897: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
898: tabname => 'PJI_FM_EXTR_DREVN',
899: percent => 10,
900: degree => PJI_UTILS.
901: GET_DEGREE_OF_PARALLELISM);
902: -- implicit commit
903: FND_STATS.GATHER_COLUMN_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
904: tabname => 'PJI_FM_EXTR_DREVN',

Line 903: FND_STATS.GATHER_COLUMN_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,

899: percent => 10,
900: degree => PJI_UTILS.
901: GET_DEGREE_OF_PARALLELISM);
902: -- implicit commit
903: FND_STATS.GATHER_COLUMN_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
904: tabname => 'PJI_FM_EXTR_DREVN',
905: colname => 'PROJECT_ID',
906: percent => 10,
907: degree => PJI_UTILS.

Line 907: degree => PJI_UTILS.

903: FND_STATS.GATHER_COLUMN_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
904: tabname => 'PJI_FM_EXTR_DREVN',
905: colname => 'PROJECT_ID',
906: percent => 10,
907: degree => PJI_UTILS.
908: GET_DEGREE_OF_PARALLELISM);
909: end if;
910:
911: INSERT /*+ APPEND PARALLEL(fin1_i) */ INTO PJI_FM_AGGR_FIN1 fin1_i

Line 1366: l_min_date := to_date(PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),

1362: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_ERDL_FULL(p_worker_id);')) then
1363: return;
1364: end if;
1365:
1366: l_min_date := to_date(PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),
1367: PJI_FM_SUM_MAIN.g_date_mask);
1368:
1369: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') = 'FULL') then
1370:

Line 1369: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') = 'FULL') then

1365:
1366: l_min_date := to_date(PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),
1367: PJI_FM_SUM_MAIN.g_date_mask);
1368:
1369: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') = 'FULL') then
1370:
1371: -- insert for erdl
1372: INSERT /*+ APPEND */ INTO PJI_FM_AGGR_FIN1
1373: ( WORKER_ID

Line 1570: if (PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') = 'FULL') then

1566: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_CDL_ROWIDS(p_worker_id);')) then
1567: return;
1568: end if;
1569:
1570: if (PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') = 'FULL') then
1571:
1572: insert /*+ append */ into PJI_FM_REXT_CDL
1573: (
1574: WORKER_ID

Line 1694: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') <> 'FULL') then

1690: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_CRDL_ROWIDS(p_worker_id);')) then
1691: return;
1692: end if;
1693:
1694: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') <> 'FULL') then
1695:
1696: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process,
1697: 'CURRENT_BATCH') = 1) then
1698: -- implicit commit

Line 1699: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,

1695:
1696: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process,
1697: 'CURRENT_BATCH') = 1) then
1698: -- implicit commit
1699: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
1700: tabname => 'PJI_FM_EXTR_DREVN',
1701: percent => 10,
1702: degree => PJI_UTILS.
1703: GET_DEGREE_OF_PARALLELISM);

Line 1702: degree => PJI_UTILS.

1698: -- implicit commit
1699: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
1700: tabname => 'PJI_FM_EXTR_DREVN',
1701: percent => 10,
1702: degree => PJI_UTILS.
1703: GET_DEGREE_OF_PARALLELISM);
1704: end if;
1705:
1706: INSERT /*+ APPEND */ INTO PJI_FM_REXT_CRDL

Line 1780: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') <> 'FULL') then

1776: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_ERDL_ROWIDS(p_worker_id);')) then
1777: return;
1778: end if;
1779:
1780: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') <> 'FULL') then
1781:
1782: INSERT /*+ APPEND */ INTO PJI_FM_REXT_ERDL
1783: (
1784: WORKER_ID

Line 1884: l_min_date := to_date(PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),

1880: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_CDL_AND_CRDL(p_worker_id);')) then
1881: return;
1882: end if;
1883:
1884: l_min_date := to_date(PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),
1885: PJI_FM_SUM_MAIN.g_date_mask);
1886:
1887: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') <> 'FULL') then
1888:

Line 1887: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') <> 'FULL') then

1883:
1884: l_min_date := to_date(PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),
1885: PJI_FM_SUM_MAIN.g_date_mask);
1886:
1887: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') <> 'FULL') then
1888:
1889: -- This cleanup is intentionally before the implicit commit so as not
1890: -- to interfere with the CDL extraction.
1891: if (nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 1919: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,

1915:
1916: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process,
1917: 'CURRENT_BATCH') = 1) then
1918: -- implicit commit
1919: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
1920: tabname => 'PJI_FM_REXT_CDL',
1921: percent => 10,
1922: degree => PJI_UTILS.
1923: GET_DEGREE_OF_PARALLELISM);

Line 1922: degree => PJI_UTILS.

1918: -- implicit commit
1919: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
1920: tabname => 'PJI_FM_REXT_CDL',
1921: percent => 10,
1922: degree => PJI_UTILS.
1923: GET_DEGREE_OF_PARALLELISM);
1924: -- implicit commit
1925: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
1926: tabname => 'PJI_FM_REXT_CRDL',

Line 1925: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,

1921: percent => 10,
1922: degree => PJI_UTILS.
1923: GET_DEGREE_OF_PARALLELISM);
1924: -- implicit commit
1925: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
1926: tabname => 'PJI_FM_REXT_CRDL',
1927: percent => 10,
1928: degree => PJI_UTILS.
1929: GET_DEGREE_OF_PARALLELISM);

Line 1928: degree => PJI_UTILS.

1924: -- implicit commit
1925: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
1926: tabname => 'PJI_FM_REXT_CRDL',
1927: percent => 10,
1928: degree => PJI_UTILS.
1929: GET_DEGREE_OF_PARALLELISM);
1930: end if;
1931:
1932: INSERT /*+ APPEND PARALLEL(fin1_i) */ INTO PJI_FM_AGGR_FIN1 fin1_i

Line 2349: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;

2345:
2346: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_CDL_AND_CRDL(p_worker_id);');
2347:
2348: -- truncate intermediate tables no longer required
2349: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
2350: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_REXT_CRDL' , 'NORMAL',null);
2351:
2352: commit;
2353:

Line 2551: if (PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') = 'FULL') then

2547:
2548: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process,
2549: 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS_POST(p_worker_id);');
2550:
2551: if (PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') = 'FULL') then
2552: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(PJI_UTILS.GET_PJI_SCHEMA_NAME,
2553: 'PJI_FM_REXT_CDL', 'NORMAL',null);
2554: end if;
2555:

Line 2552: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(PJI_UTILS.GET_PJI_SCHEMA_NAME,

2548: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process,
2549: 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS_POST(p_worker_id);');
2550:
2551: if (PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') = 'FULL') then
2552: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(PJI_UTILS.GET_PJI_SCHEMA_NAME,
2553: 'PJI_FM_REXT_CDL', 'NORMAL',null);
2554: end if;
2555:
2556: commit;

Line 2578: l_min_date := to_date(PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),

2574: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_ERDL(p_worker_id);')) then
2575: return;
2576: end if;
2577:
2578: l_min_date := to_date(PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),
2579: PJI_FM_SUM_MAIN.g_date_mask);
2580:
2581: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') <> 'FULL') then
2582:

Line 2581: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') <> 'FULL') then

2577:
2578: l_min_date := to_date(PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),
2579: PJI_FM_SUM_MAIN.g_date_mask);
2580:
2581: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') <> 'FULL') then
2582:
2583: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process,
2584: 'CURRENT_BATCH') = 1) then
2585: -- implicit commit

Line 2586: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,

2582:
2583: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process,
2584: 'CURRENT_BATCH') = 1) then
2585: -- implicit commit
2586: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
2587: tabname => 'PJI_FM_REXT_ERDL',
2588: percent => 10,
2589: degree => PJI_UTILS.
2590: GET_DEGREE_OF_PARALLELISM);

Line 2589: degree => PJI_UTILS.

2585: -- implicit commit
2586: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
2587: tabname => 'PJI_FM_REXT_ERDL',
2588: percent => 10,
2589: degree => PJI_UTILS.
2590: GET_DEGREE_OF_PARALLELISM);
2591: end if;
2592:
2593: INSERT /*+ APPEND */ INTO PJI_FM_AGGR_FIN1

Line 2851: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;

2847:
2848: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_ERDL(p_worker_id);');
2849:
2850: -- truncate intermediate tables no longer required
2851: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
2852: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_REXT_ERDL' , 'NORMAL',null);
2853:
2854: commit;
2855:

Line 2877: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

2873: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_DINV(p_worker_id);')) then
2874: return;
2875: end if;
2876:
2877: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
2878:
2879: INSERT /*+ APPEND */ INTO PJI_FM_EXTR_DINVC
2880: ( WORKER_ID
2881: , ROW_ID

Line 3174: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

3170:
3171: begin
3172:
3173: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
3174: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
3175:
3176: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.MARK_EXTRACTED_DINV_ROWS(p_worker_id);')) then
3177: return;
3178: end if;

Line 3223: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,

3219:
3220: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process,
3221: 'CURRENT_BATCH') = 1) then
3222: -- implicit commit
3223: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
3224: tabname => 'PJI_FM_EXTR_DINVC',
3225: percent => 10,
3226: degree => PJI_UTILS.
3227: GET_DEGREE_OF_PARALLELISM);

Line 3226: degree => PJI_UTILS.

3222: -- implicit commit
3223: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
3224: tabname => 'PJI_FM_EXTR_DINVC',
3225: percent => 10,
3226: degree => PJI_UTILS.
3227: GET_DEGREE_OF_PARALLELISM);
3228: -- implicit commit
3229: FND_STATS.GATHER_COLUMN_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
3230: tabname => 'PJI_FM_EXTR_DINVC',

Line 3229: FND_STATS.GATHER_COLUMN_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,

3225: percent => 10,
3226: degree => PJI_UTILS.
3227: GET_DEGREE_OF_PARALLELISM);
3228: -- implicit commit
3229: FND_STATS.GATHER_COLUMN_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
3230: tabname => 'PJI_FM_EXTR_DINVC',
3231: colname => 'PROJECT_ID',
3232: percent => 10,
3233: degree => PJI_UTILS.

Line 3233: degree => PJI_UTILS.

3229: FND_STATS.GATHER_COLUMN_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
3230: tabname => 'PJI_FM_EXTR_DINVC',
3231: colname => 'PROJECT_ID',
3232: percent => 10,
3233: degree => PJI_UTILS.
3234: GET_DEGREE_OF_PARALLELISM);
3235: end if;
3236:
3237: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

Line 3237: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

3233: degree => PJI_UTILS.
3234: GET_DEGREE_OF_PARALLELISM);
3235: end if;
3236:
3237: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
3238:
3239: INSERT /*+ APPEND */ INTO PJI_FM_EXTR_DINVCITM
3240: ( WORKER_ID
3241: , PROJECT_ORG_ID

Line 3495: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

3491: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_ARINV(p_worker_id);')) then
3492: return;
3493: end if;
3494:
3495: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
3496:
3497: INSERT /*+ APPEND */ INTO PJI_FM_EXTR_ARINV
3498: ( WORKER_ID
3499: , ROW_ID

Line 3785: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;

3781: l_schema varchar2(30);
3782:
3783: begin
3784:
3785: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
3786:
3787: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_FUNDG', 'NORMAL',null);
3788:
3789: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_DREVN', 'NORMAL',null);