DBA Data[Home] [Help]

APPS.PJI_FM_SUM_EXTR dependencies on PJI_UTILS

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

48:
49: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.ORG_EXTR_INFO_TABLE(p_worker_id);');
50:
51: -- implicit commit
52: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
53: tabname => 'PJI_ORG_EXTR_INFO',
54: percent => 10,
55: degree => PJI_UTILS.
56: GET_DEGREE_OF_PARALLELISM);

Line 55: degree => PJI_UTILS.

51: -- implicit commit
52: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
53: tabname => 'PJI_ORG_EXTR_INFO',
54: percent => 10,
55: degree => PJI_UTILS.
56: GET_DEGREE_OF_PARALLELISM);
57: -- implicit commit
58: FND_STATS.GATHER_INDEX_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
59: indname => 'PJI_ORG_EXTR_INFO_N1',

Line 58: FND_STATS.GATHER_INDEX_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,

54: percent => 10,
55: degree => PJI_UTILS.
56: GET_DEGREE_OF_PARALLELISM);
57: -- implicit commit
58: FND_STATS.GATHER_INDEX_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
59: indname => 'PJI_ORG_EXTR_INFO_N1',
60: percent => 10);
61:
62: commit;

Line 124: PJI_UTILS.GET_GLOBAL_RATE_PRIMARY(PF_CURRENCY_CODE,

120: select
121: p_worker_id WORKER_ID,
122: PF_CURRENCY_CODE PF_CURRENCY_CODE,
123: TIME_ID TIME_ID,
124: PJI_UTILS.GET_GLOBAL_RATE_PRIMARY(PF_CURRENCY_CODE,
125: to_date(to_char(TIME_ID), 'J')) RATE,
126: PJI_UTILS.GET_MAU_PRIMARY MAU,
127: PJI_UTILS.GET_GLOBAL_RATE_SECONDARY(PF_CURRENCY_CODE,
128: to_date(to_char(TIME_ID), 'J')) RATE2,

Line 126: PJI_UTILS.GET_MAU_PRIMARY MAU,

122: PF_CURRENCY_CODE PF_CURRENCY_CODE,
123: TIME_ID TIME_ID,
124: PJI_UTILS.GET_GLOBAL_RATE_PRIMARY(PF_CURRENCY_CODE,
125: to_date(to_char(TIME_ID), 'J')) RATE,
126: PJI_UTILS.GET_MAU_PRIMARY MAU,
127: PJI_UTILS.GET_GLOBAL_RATE_SECONDARY(PF_CURRENCY_CODE,
128: to_date(to_char(TIME_ID), 'J')) RATE2,
129: PJI_UTILS.GET_MAU_SECONDARY MAU2
130: from

Line 127: PJI_UTILS.GET_GLOBAL_RATE_SECONDARY(PF_CURRENCY_CODE,

123: TIME_ID TIME_ID,
124: PJI_UTILS.GET_GLOBAL_RATE_PRIMARY(PF_CURRENCY_CODE,
125: to_date(to_char(TIME_ID), 'J')) RATE,
126: PJI_UTILS.GET_MAU_PRIMARY MAU,
127: PJI_UTILS.GET_GLOBAL_RATE_SECONDARY(PF_CURRENCY_CODE,
128: to_date(to_char(TIME_ID), 'J')) RATE2,
129: PJI_UTILS.GET_MAU_SECONDARY MAU2
130: from
131: (

Line 129: PJI_UTILS.GET_MAU_SECONDARY MAU2

125: to_date(to_char(TIME_ID), 'J')) RATE,
126: PJI_UTILS.GET_MAU_PRIMARY MAU,
127: PJI_UTILS.GET_GLOBAL_RATE_SECONDARY(PF_CURRENCY_CODE,
128: to_date(to_char(TIME_ID), 'J')) RATE2,
129: PJI_UTILS.GET_MAU_SECONDARY MAU2
130: from
131: (
132: select /*+ ordered
133: full(tmp1) use_hash(tmp1) parallel(tmp1)

Line 400: l_g1_currency_code := PJI_UTILS.GET_GLOBAL_PRIMARY_CURRENCY;

396: l_g2_currency_flag
397: from
398: PJI_SYSTEM_SETTINGS;
399:
400: l_g1_currency_code := PJI_UTILS.GET_GLOBAL_PRIMARY_CURRENCY;
401: l_g2_currency_code := PJI_UTILS.GET_GLOBAL_SECONDARY_CURRENCY;
402:
403: insert /*+ noappend parallel(fin2_i) */ into PJI_FM_AGGR_FIN2 fin2_i -- in DANGLING_FIN_ROWS
404: ( --Bug 7139059

Line 401: l_g2_currency_code := PJI_UTILS.GET_GLOBAL_SECONDARY_CURRENCY;

397: from
398: PJI_SYSTEM_SETTINGS;
399:
400: l_g1_currency_code := PJI_UTILS.GET_GLOBAL_PRIMARY_CURRENCY;
401: l_g2_currency_code := PJI_UTILS.GET_GLOBAL_SECONDARY_CURRENCY;
402:
403: insert /*+ noappend parallel(fin2_i) */ into PJI_FM_AGGR_FIN2 fin2_i -- in DANGLING_FIN_ROWS
404: ( --Bug 7139059
405: WORKER_ID,

Line 1842: l_g1_currency_code := PJI_UTILS.GET_GLOBAL_PRIMARY_CURRENCY;

1838: l_g2_currency_flag
1839: from
1840: PJI_SYSTEM_SETTINGS;
1841:
1842: l_g1_currency_code := PJI_UTILS.GET_GLOBAL_PRIMARY_CURRENCY;
1843: l_g2_currency_code := PJI_UTILS.GET_GLOBAL_SECONDARY_CURRENCY;
1844:
1845: insert /*+ append parallel(act2_i) */ into PJI_FM_AGGR_ACT2 act2_i -- in DANGLING_ACT_ROWS
1846: (

Line 1843: l_g2_currency_code := PJI_UTILS.GET_GLOBAL_SECONDARY_CURRENCY;

1839: from
1840: PJI_SYSTEM_SETTINGS;
1841:
1842: l_g1_currency_code := PJI_UTILS.GET_GLOBAL_PRIMARY_CURRENCY;
1843: l_g2_currency_code := PJI_UTILS.GET_GLOBAL_SECONDARY_CURRENCY;
1844:
1845: insert /*+ append parallel(act2_i) */ into PJI_FM_AGGR_ACT2 act2_i -- in DANGLING_ACT_ROWS
1846: (
1847: WORKER_ID,

Line 3290: nvl(PJI_UTILS.GET_PARAMETER('CONFIG_COST_FLAG'), 'N');

3286:
3287: else -- l_transition is null or 'N'
3288:
3289: l_params_cost_flag :=
3290: nvl(PJI_UTILS.GET_PARAMETER('CONFIG_COST_FLAG'), 'N');
3291: l_params_util_flag :=
3292: nvl(PJI_UTILS.GET_PARAMETER('CONFIG_UTIL_FLAG'), 'N');
3293:
3294: end if;

Line 3292: nvl(PJI_UTILS.GET_PARAMETER('CONFIG_UTIL_FLAG'), 'N');

3288:
3289: l_params_cost_flag :=
3290: nvl(PJI_UTILS.GET_PARAMETER('CONFIG_COST_FLAG'), 'N');
3291: l_params_util_flag :=
3292: nvl(PJI_UTILS.GET_PARAMETER('CONFIG_UTIL_FLAG'), 'N');
3293:
3294: end if;
3295:
3296: select

Line 3305: l_g1_currency_code := PJI_UTILS.GET_GLOBAL_PRIMARY_CURRENCY;

3301: l_g2_currency_flag
3302: from
3303: PJI_SYSTEM_SETTINGS;
3304:
3305: l_g1_currency_code := PJI_UTILS.GET_GLOBAL_PRIMARY_CURRENCY;
3306: l_g2_currency_code := PJI_UTILS.GET_GLOBAL_SECONDARY_CURRENCY;
3307:
3308: insert /*+ noappend parallel(fin2_i) */ into PJI_FM_AGGR_FIN2 fin2_i -- in FIN_SUMMARY
3309: ( --Bug 7139059

Line 3306: l_g2_currency_code := PJI_UTILS.GET_GLOBAL_SECONDARY_CURRENCY;

3302: from
3303: PJI_SYSTEM_SETTINGS;
3304:
3305: l_g1_currency_code := PJI_UTILS.GET_GLOBAL_PRIMARY_CURRENCY;
3306: l_g2_currency_code := PJI_UTILS.GET_GLOBAL_SECONDARY_CURRENCY;
3307:
3308: insert /*+ noappend parallel(fin2_i) */ into PJI_FM_AGGR_FIN2 fin2_i -- in FIN_SUMMARY
3309: ( --Bug 7139059
3310: WORKER_ID,

Line 4347: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;

4343:
4344: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.FIN_SUMMARY(p_worker_id);');
4345:
4346: -- truncate intermediate tables no longer required
4347: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
4348: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_AGGR_FIN1' , 'NORMAL',null);
4349:
4350: commit;
4351:

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

4704: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.ACT_SUMMARY(p_worker_id);')) then
4705: return;
4706: end if;
4707:
4708: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
4709:
4710: select
4711: TXN_CURR_FLAG,
4712: GLOBAL_CURR2_FLAG

Line 4719: l_g1_currency_code := PJI_UTILS.GET_GLOBAL_PRIMARY_CURRENCY;

4715: l_g2_currency_flag
4716: from
4717: PJI_SYSTEM_SETTINGS;
4718:
4719: l_g1_currency_code := PJI_UTILS.GET_GLOBAL_PRIMARY_CURRENCY;
4720: l_g2_currency_code := PJI_UTILS.GET_GLOBAL_SECONDARY_CURRENCY;
4721:
4722: insert /*+ append parallel(act2_i) */ into PJI_FM_AGGR_ACT2 act2_i -- in ACT_SUMMARY
4723: (

Line 4720: l_g2_currency_code := PJI_UTILS.GET_GLOBAL_SECONDARY_CURRENCY;

4716: from
4717: PJI_SYSTEM_SETTINGS;
4718:
4719: l_g1_currency_code := PJI_UTILS.GET_GLOBAL_PRIMARY_CURRENCY;
4720: l_g2_currency_code := PJI_UTILS.GET_GLOBAL_SECONDARY_CURRENCY;
4721:
4722: insert /*+ append parallel(act2_i) */ into PJI_FM_AGGR_ACT2 act2_i -- in ACT_SUMMARY
4723: (
4724: WORKER_ID,

Line 5708: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;

5704:
5705: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.ACT_SUMMARY(p_worker_id);');
5706:
5707: -- truncate intermediate tables no longer required
5708: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
5709: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_AGGR_ACT1' , 'NORMAL',null);
5710:
5711: commit;
5712:

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

6077: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_RES_SLICES(p_worker_id);')) then
6078: return;
6079: end if;
6080:
6081: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
6082:
6083: if (l_extraction_type = 'PARTIAL') then
6084:
6085: delete

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

6161: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_FIN_SLICES(p_worker_id);')) then
6162: return;
6163: end if;
6164:
6165: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
6166:
6167: /* if (l_extraction_type = 'PARTIAL') then
6168:
6169: delete

Line 6629: if PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE') is not null then

6625: tmp2.PJ_PA_CALENDAR_ID,
6626: tmp2.TXN_CURRENCY_CODE;
6627:
6628: /* Added for bug 9249905 *
6629: if PJI_UTILS.GET_PARAMETER('GLOBAL_START_DATE') is not null then
6630: /* Modified for bug 9483220 *
6631: delete from PJI_FM_PJI_CMT
6632: where project_id in (select distinct project_id
6633: from PJI_FM_AGGR_FIN2);

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

6803: PJI_FM_SUM_MAIN.g_process,
6804: 'PA_CALENDAR_FLAG'
6805: );
6806:
6807: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
6808:
6809: /* if (l_extraction_type = 'PARTIAL') then
6810:
6811: delete

Line 7369: -- l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;

7365:
7366: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_ACT_SLICES(p_worker_id);');
7367:
7368: -- truncate intermediate tables no longer required
7369: -- l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
7370: -- PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_AGGR_ACT2' , 'NORMAL',null);
7371:
7372: commit;
7373:

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

7417: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.FORCE_SUBSEQUENT_RUN(p_worker_id);')) then
7418: return;
7419: end if;
7420:
7421: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
7422:
7423: if (l_extraction_type = 'PARTIAL') then
7424: null;
7425: /* Temporary removal of stage 1 dependency on stage 2. temptemp

Line 7432: PJI_UTILS.WRITE2OUT(l_newline ||

7428: l_no_selection := FND_MESSAGE.GET;
7429:
7430: FND_MESSAGE.SET_NAME('PJI', 'PJI_PJI_SUM_FORCE_PRTL');
7431:
7432: PJI_UTILS.WRITE2OUT(l_newline ||
7433: l_newline ||
7434: FND_MESSAGE.GET ||
7435: l_newline ||
7436: l_newline);

Line 7462: -- PJI_UTILS.WRITE2OUT(l_plan_type_tg ||

7458: FND_MESSAGE.SET_NAME('PJI', 'PJI_PJI_SUM_ORGANIZATION');
7459:
7460: l_organization_tg := substr(FND_MESSAGE.GET, 1, 30);
7461:
7462: -- PJI_UTILS.WRITE2OUT(l_plan_type_tg ||
7463: -- PJI_FM_SUM_MAIN.my_pad(30 -
7464: -- length(l_organization_tg),
7465: -- ' ') ||
7466: -- ': ' ||

Line 7487: -- PJI_UTILS.WRITE2OUT(l_plan_type_tg ||

7483: FND_MESSAGE.SET_NAME('PJI', 'PJI_PJI_SUM_INCLUDE_SUB_ORG');
7484:
7485: l_include_sub_org_tg := substr(FND_MESSAGE.GET, 1, 30);
7486:
7487: -- PJI_UTILS.WRITE2OUT(l_plan_type_tg ||
7488: -- PJI_FM_SUM_MAIN.my_pad(30 -
7489: -- length(l_include_sub_org_tg),
7490: -- ' ') ||
7491: -- ': ' ||

Line 7519: PJI_UTILS.WRITE2OUT(l_project_operating_unit_tg ||

7515: FND_MESSAGE.SET_NAME('PJI', 'PJI_PJP_SUM_PRJ_OP_UNIT');
7516:
7517: l_project_operating_unit_tg := substr(FND_MESSAGE.GET, 1, 30);
7518:
7519: PJI_UTILS.WRITE2OUT(l_project_operating_unit_tg ||
7520: PJI_FM_SUM_MAIN.my_pad(30 -
7521: length(l_project_operating_unit_tg), ' ') ||
7522: ': ' ||
7523: l_project_operating_unit_name ||

Line 7543: PJI_UTILS.WRITE2OUT(l_from_project_tg ||

7539: FND_MESSAGE.SET_NAME('PJI', 'PJI_PJP_SUM_FROM_PRJ');
7540:
7541: l_from_project_tg := substr(FND_MESSAGE.GET, 1, 30);
7542:
7543: PJI_UTILS.WRITE2OUT(l_from_project_tg ||
7544: PJI_FM_SUM_MAIN.my_pad(30-length(l_from_project_tg),
7545: ' ') ||
7546: ': ' ||
7547: l_from_project ||

Line 7567: PJI_UTILS.WRITE2OUT(l_to_project_tg ||

7563: FND_MESSAGE.SET_NAME('PJI', 'PJI_PJP_SUM_TO_PRJ');
7564:
7565: l_to_project_tg := substr(FND_MESSAGE.GET, 1, 30);
7566:
7567: PJI_UTILS.WRITE2OUT(l_to_project_tg ||
7568: PJI_FM_SUM_MAIN.my_pad(30 - length(l_to_project_tg),
7569: ' ') ||
7570: ': ' ||
7571: l_to_project ||

Line 7594: PJI_UTILS.WRITE2OUT(l_plan_type_tg ||

7590: FND_MESSAGE.SET_NAME('PJI', 'PJI_PJP_SUM_PLAN_TYPE');
7591:
7592: l_plan_type_tg := substr(FND_MESSAGE.GET, 1, 30);
7593:
7594: PJI_UTILS.WRITE2OUT(l_plan_type_tg ||
7595: PJI_FM_SUM_MAIN.my_pad(30 - length(l_plan_type_tg),
7596: ' ') ||
7597: ': ' ||
7598: l_plan_type ||

Line 7642: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;

7638: PJI_FM_EXTR.CLEANUP(p_worker_id);
7639: PJI_FM_SUM_PSI.CLEANUP(p_worker_id);
7640: PJI_FM_SUM_ACT.CLEANUP(p_worker_id);
7641:
7642: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
7643:
7644: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
7645: 'PJI_FM_AGGR_FIN1',
7646: 'NORMAL',

Line 7682: pji_utils.write2log(sqlerrm, true, 0);

7678: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING', 'F');
7679:
7680: commit;
7681:
7682: pji_utils.write2log(sqlerrm, true, 0);
7683:
7684: commit;
7685:
7686: end WRAPUP_FAILURE;

Line 7838: pji_utils.write2log('Warning: Helper is already running.');

7834: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process,
7835: PJI_FM_SUM_MAIN.g_process ||
7836: p_worker_id)
7837: <> FND_GLOBAL.CONC_REQUEST_ID) then
7838: pji_utils.write2log('Warning: Helper is already running.');
7839: commit;
7840: retcode := 0;
7841: return;
7842: end if;

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

7956: if (WORKER_STATUS(p_worker_id, 'RUNNING')) then
7957: return;
7958: end if;
7959:
7960: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
7961:
7962: -- Initialize status tables with worker details
7963:
7964: -- Note that adding a new step will do nothing if the step already

Line 7980: PJI_UTILS.GET_PJI_SCHEMA_NAME, -- Application name

7976: PJI_FM_SUM_MAIN.g_process,
7977: l_process,
7978: FND_REQUEST.SUBMIT_REQUEST
7979: (
7980: PJI_UTILS.GET_PJI_SCHEMA_NAME, -- Application name
7981: PJI_FM_SUM_MAIN.g_helper_name, -- concurrent program name
7982: null, -- description (optional)
7983: null, -- Start Time (optional)
7984: false, -- called from another conc. request

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

8009: l_extraction_type varchar2(30);
8010:
8011: begin
8012:
8013: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
8014:
8015: if (p_worker_id = 1) then
8016:
8017: if (l_extraction_type = 'FULL') then