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 1359: l_min_date := to_date(PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),

1355: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_ERDL_FULL(p_worker_id);')) then
1356: return;
1357: end if;
1358:
1359: l_min_date := to_date(PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),
1360: PJI_FM_SUM_MAIN.g_date_mask);
1361:
1362: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') = 'FULL') then
1363:

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

1358:
1359: l_min_date := to_date(PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),
1360: PJI_FM_SUM_MAIN.g_date_mask);
1361:
1362: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') = 'FULL') then
1363:
1364: -- insert for erdl
1365: INSERT /*+ APPEND */ INTO PJI_FM_AGGR_FIN1
1366: ( WORKER_ID

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

1559: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_CDL_ROWIDS(p_worker_id);')) then
1560: return;
1561: end if;
1562:
1563: if (PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') = 'FULL') then
1564:
1565: insert /*+ append */ into PJI_FM_REXT_CDL
1566: (
1567: WORKER_ID

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

1683: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_CRDL_ROWIDS(p_worker_id);')) then
1684: return;
1685: end if;
1686:
1687: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') <> 'FULL') then
1688:
1689: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process,
1690: 'CURRENT_BATCH') = 1) then
1691: -- implicit commit

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

1688:
1689: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process,
1690: 'CURRENT_BATCH') = 1) then
1691: -- implicit commit
1692: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
1693: tabname => 'PJI_FM_EXTR_DREVN',
1694: percent => 10,
1695: degree => PJI_UTILS.
1696: GET_DEGREE_OF_PARALLELISM);

Line 1695: degree => PJI_UTILS.

1691: -- implicit commit
1692: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
1693: tabname => 'PJI_FM_EXTR_DREVN',
1694: percent => 10,
1695: degree => PJI_UTILS.
1696: GET_DEGREE_OF_PARALLELISM);
1697: end if;
1698:
1699: INSERT /*+ APPEND */ INTO PJI_FM_REXT_CRDL

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

1769: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_ERDL_ROWIDS(p_worker_id);')) then
1770: return;
1771: end if;
1772:
1773: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') <> 'FULL') then
1774:
1775: INSERT /*+ APPEND */ INTO PJI_FM_REXT_ERDL
1776: (
1777: WORKER_ID

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

1873: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_CDL_AND_CRDL(p_worker_id);')) then
1874: return;
1875: end if;
1876:
1877: l_min_date := to_date(PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),
1878: PJI_FM_SUM_MAIN.g_date_mask);
1879:
1880: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') <> 'FULL') then
1881:

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

1876:
1877: l_min_date := to_date(PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),
1878: PJI_FM_SUM_MAIN.g_date_mask);
1879:
1880: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') <> 'FULL') then
1881:
1882: -- This cleanup is intentionally before the implicit commit so as not
1883: -- to interfere with the CDL extraction.
1884: if (nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

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

1908:
1909: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process,
1910: 'CURRENT_BATCH') = 1) then
1911: -- implicit commit
1912: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
1913: tabname => 'PJI_FM_REXT_CDL',
1914: percent => 10,
1915: degree => PJI_UTILS.
1916: GET_DEGREE_OF_PARALLELISM);

Line 1915: degree => PJI_UTILS.

1911: -- implicit commit
1912: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
1913: tabname => 'PJI_FM_REXT_CDL',
1914: percent => 10,
1915: degree => PJI_UTILS.
1916: GET_DEGREE_OF_PARALLELISM);
1917: -- implicit commit
1918: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
1919: tabname => 'PJI_FM_REXT_CRDL',

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

1914: percent => 10,
1915: degree => PJI_UTILS.
1916: GET_DEGREE_OF_PARALLELISM);
1917: -- implicit commit
1918: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
1919: tabname => 'PJI_FM_REXT_CRDL',
1920: percent => 10,
1921: degree => PJI_UTILS.
1922: GET_DEGREE_OF_PARALLELISM);

Line 1921: degree => PJI_UTILS.

1917: -- implicit commit
1918: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
1919: tabname => 'PJI_FM_REXT_CRDL',
1920: percent => 10,
1921: degree => PJI_UTILS.
1922: GET_DEGREE_OF_PARALLELISM);
1923: end if;
1924:
1925: INSERT /*+ APPEND PARALLEL(fin1_i) */ INTO PJI_FM_AGGR_FIN1 fin1_i

Line 2336: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;

2332:
2333: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_CDL_AND_CRDL(p_worker_id);');
2334:
2335: -- truncate intermediate tables no longer required
2336: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
2337: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_REXT_CRDL' , 'NORMAL',null);
2338:
2339: commit;
2340:

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

2534:
2535: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process,
2536: 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS_POST(p_worker_id);');
2537:
2538: if (PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') = 'FULL') then
2539: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(PJI_UTILS.GET_PJI_SCHEMA_NAME,
2540: 'PJI_FM_REXT_CDL', 'NORMAL',null);
2541: end if;
2542:

Line 2539: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(PJI_UTILS.GET_PJI_SCHEMA_NAME,

2535: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process,
2536: 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS_POST(p_worker_id);');
2537:
2538: if (PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') = 'FULL') then
2539: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(PJI_UTILS.GET_PJI_SCHEMA_NAME,
2540: 'PJI_FM_REXT_CDL', 'NORMAL',null);
2541: end if;
2542:
2543: commit;

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

2561: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_ERDL(p_worker_id);')) then
2562: return;
2563: end if;
2564:
2565: l_min_date := to_date(PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),
2566: PJI_FM_SUM_MAIN.g_date_mask);
2567:
2568: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') <> 'FULL') then
2569:

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

2564:
2565: l_min_date := to_date(PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE'),
2566: PJI_FM_SUM_MAIN.g_date_mask);
2567:
2568: if ( PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE') <> 'FULL') then
2569:
2570: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process,
2571: 'CURRENT_BATCH') = 1) then
2572: -- implicit commit

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

2569:
2570: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process,
2571: 'CURRENT_BATCH') = 1) then
2572: -- implicit commit
2573: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
2574: tabname => 'PJI_FM_REXT_ERDL',
2575: percent => 10,
2576: degree => PJI_UTILS.
2577: GET_DEGREE_OF_PARALLELISM);

Line 2576: degree => PJI_UTILS.

2572: -- implicit commit
2573: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
2574: tabname => 'PJI_FM_REXT_ERDL',
2575: percent => 10,
2576: degree => PJI_UTILS.
2577: GET_DEGREE_OF_PARALLELISM);
2578: end if;
2579:
2580: INSERT /*+ APPEND */ INTO PJI_FM_AGGR_FIN1

Line 2838: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;

2834:
2835: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_ERDL(p_worker_id);');
2836:
2837: -- truncate intermediate tables no longer required
2838: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
2839: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_REXT_ERDL' , 'NORMAL',null);
2840:
2841: commit;
2842:

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

2860: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_DINV(p_worker_id);')) then
2861: return;
2862: end if;
2863:
2864: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
2865:
2866: INSERT /*+ APPEND */ INTO PJI_FM_EXTR_DINVC
2867: ( WORKER_ID
2868: , ROW_ID

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

3157:
3158: begin
3159:
3160: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
3161: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
3162:
3163: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.MARK_EXTRACTED_DINV_ROWS(p_worker_id);')) then
3164: return;
3165: end if;

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

3206:
3207: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process,
3208: 'CURRENT_BATCH') = 1) then
3209: -- implicit commit
3210: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
3211: tabname => 'PJI_FM_EXTR_DINVC',
3212: percent => 10,
3213: degree => PJI_UTILS.
3214: GET_DEGREE_OF_PARALLELISM);

Line 3213: degree => PJI_UTILS.

3209: -- implicit commit
3210: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
3211: tabname => 'PJI_FM_EXTR_DINVC',
3212: percent => 10,
3213: degree => PJI_UTILS.
3214: GET_DEGREE_OF_PARALLELISM);
3215: -- implicit commit
3216: FND_STATS.GATHER_COLUMN_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
3217: tabname => 'PJI_FM_EXTR_DINVC',

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

3212: percent => 10,
3213: degree => PJI_UTILS.
3214: GET_DEGREE_OF_PARALLELISM);
3215: -- implicit commit
3216: FND_STATS.GATHER_COLUMN_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
3217: tabname => 'PJI_FM_EXTR_DINVC',
3218: colname => 'PROJECT_ID',
3219: percent => 10,
3220: degree => PJI_UTILS.

Line 3220: degree => PJI_UTILS.

3216: FND_STATS.GATHER_COLUMN_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
3217: tabname => 'PJI_FM_EXTR_DINVC',
3218: colname => 'PROJECT_ID',
3219: percent => 10,
3220: degree => PJI_UTILS.
3221: GET_DEGREE_OF_PARALLELISM);
3222: end if;
3223:
3224: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

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

3220: degree => PJI_UTILS.
3221: GET_DEGREE_OF_PARALLELISM);
3222: end if;
3223:
3224: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
3225:
3226: INSERT /*+ APPEND */ INTO PJI_FM_EXTR_DINVCITM
3227: ( WORKER_ID
3228: , PROJECT_ORG_ID

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

3478: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_EXTR.EXTRACT_BATCH_ARINV(p_worker_id);')) then
3479: return;
3480: end if;
3481:
3482: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
3483:
3484: INSERT /*+ APPEND */ INTO PJI_FM_EXTR_ARINV
3485: ( WORKER_ID
3486: , ROW_ID

Line 3772: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;

3768: l_schema varchar2(30);
3769:
3770: begin
3771:
3772: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
3773:
3774: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_FUNDG', 'NORMAL',null);
3775:
3776: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_EXTR_DREVN', 'NORMAL',null);