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 /*+ append parallel(fin2_i) */ into PJI_FM_AGGR_FIN2 fin2_i -- in DANGLING_FIN_ROWS
404: (

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 /*+ append parallel(fin2_i) */ into PJI_FM_AGGR_FIN2 fin2_i -- in DANGLING_FIN_ROWS
404: (
405: WORKER_ID,

Line 1839: l_g1_currency_code := PJI_UTILS.GET_GLOBAL_PRIMARY_CURRENCY;

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

Line 1840: l_g2_currency_code := PJI_UTILS.GET_GLOBAL_SECONDARY_CURRENCY;

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

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

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

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

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

Line 3302: l_g1_currency_code := PJI_UTILS.GET_GLOBAL_PRIMARY_CURRENCY;

3298: l_g2_currency_flag
3299: from
3300: PJI_SYSTEM_SETTINGS;
3301:
3302: l_g1_currency_code := PJI_UTILS.GET_GLOBAL_PRIMARY_CURRENCY;
3303: l_g2_currency_code := PJI_UTILS.GET_GLOBAL_SECONDARY_CURRENCY;
3304:
3305: insert /*+ append parallel(fin2_i) */ into PJI_FM_AGGR_FIN2 fin2_i -- in FIN_SUMMARY
3306: (

Line 3303: l_g2_currency_code := PJI_UTILS.GET_GLOBAL_SECONDARY_CURRENCY;

3299: from
3300: PJI_SYSTEM_SETTINGS;
3301:
3302: l_g1_currency_code := PJI_UTILS.GET_GLOBAL_PRIMARY_CURRENCY;
3303: l_g2_currency_code := PJI_UTILS.GET_GLOBAL_SECONDARY_CURRENCY;
3304:
3305: insert /*+ append parallel(fin2_i) */ into PJI_FM_AGGR_FIN2 fin2_i -- in FIN_SUMMARY
3306: (
3307: WORKER_ID,

Line 4339: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;

4335:
4336: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.FIN_SUMMARY(p_worker_id);');
4337:
4338: -- truncate intermediate tables no longer required
4339: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
4340: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_AGGR_FIN1' , 'NORMAL',null);
4341:
4342: commit;
4343:

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

4694: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.ACT_SUMMARY(p_worker_id);')) then
4695: return;
4696: end if;
4697:
4698: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
4699:
4700: select
4701: TXN_CURR_FLAG,
4702: GLOBAL_CURR2_FLAG

Line 4709: l_g1_currency_code := PJI_UTILS.GET_GLOBAL_PRIMARY_CURRENCY;

4705: l_g2_currency_flag
4706: from
4707: PJI_SYSTEM_SETTINGS;
4708:
4709: l_g1_currency_code := PJI_UTILS.GET_GLOBAL_PRIMARY_CURRENCY;
4710: l_g2_currency_code := PJI_UTILS.GET_GLOBAL_SECONDARY_CURRENCY;
4711:
4712: insert /*+ append parallel(act2_i) */ into PJI_FM_AGGR_ACT2 act2_i -- in ACT_SUMMARY
4713: (

Line 4710: l_g2_currency_code := PJI_UTILS.GET_GLOBAL_SECONDARY_CURRENCY;

4706: from
4707: PJI_SYSTEM_SETTINGS;
4708:
4709: l_g1_currency_code := PJI_UTILS.GET_GLOBAL_PRIMARY_CURRENCY;
4710: l_g2_currency_code := PJI_UTILS.GET_GLOBAL_SECONDARY_CURRENCY;
4711:
4712: insert /*+ append parallel(act2_i) */ into PJI_FM_AGGR_ACT2 act2_i -- in ACT_SUMMARY
4713: (
4714: WORKER_ID,

Line 5698: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;

5694:
5695: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.ACT_SUMMARY(p_worker_id);');
5696:
5697: -- truncate intermediate tables no longer required
5698: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
5699: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_AGGR_ACT1' , 'NORMAL',null);
5700:
5701: commit;
5702:

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

6067: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_RES_SLICES(p_worker_id);')) then
6068: return;
6069: end if;
6070:
6071: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
6072:
6073: if (l_extraction_type = 'PARTIAL') then
6074:
6075: delete

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

6151: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_FIN_SLICES(p_worker_id);')) then
6152: return;
6153: end if;
6154:
6155: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
6156:
6157: if (l_extraction_type = 'PARTIAL') then
6158:
6159: delete

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

6423: PJI_FM_SUM_MAIN.g_process,
6424: 'PA_CALENDAR_FLAG'
6425: );
6426:
6427: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
6428:
6429: if (l_extraction_type = 'PARTIAL') then
6430:
6431: delete

Line 6989: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;

6985:
6986: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_ACT_SLICES(p_worker_id);');
6987:
6988: -- truncate intermediate tables no longer required
6989: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
6990: PJI_PROCESS_UTIL.TRUNC_INT_TABLE( l_schema , 'PJI_FM_AGGR_ACT2' , 'NORMAL',null);
6991:
6992: commit;
6993:

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

7037: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.FORCE_SUBSEQUENT_RUN(p_worker_id);')) then
7038: return;
7039: end if;
7040:
7041: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
7042:
7043: if (l_extraction_type = 'PARTIAL') then
7044: null;
7045: /* Temporary removal of stage 1 dependency on stage 2. temptemp

Line 7052: PJI_UTILS.WRITE2OUT(l_newline ||

7048: l_no_selection := FND_MESSAGE.GET;
7049:
7050: FND_MESSAGE.SET_NAME('PJI', 'PJI_PJI_SUM_FORCE_PRTL');
7051:
7052: PJI_UTILS.WRITE2OUT(l_newline ||
7053: l_newline ||
7054: FND_MESSAGE.GET ||
7055: l_newline ||
7056: l_newline);

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

7078: FND_MESSAGE.SET_NAME('PJI', 'PJI_PJI_SUM_ORGANIZATION');
7079:
7080: l_organization_tg := substr(FND_MESSAGE.GET, 1, 30);
7081:
7082: -- PJI_UTILS.WRITE2OUT(l_plan_type_tg ||
7083: -- PJI_FM_SUM_MAIN.my_pad(30 -
7084: -- length(l_organization_tg),
7085: -- ' ') ||
7086: -- ': ' ||

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

7103: FND_MESSAGE.SET_NAME('PJI', 'PJI_PJI_SUM_INCLUDE_SUB_ORG');
7104:
7105: l_include_sub_org_tg := substr(FND_MESSAGE.GET, 1, 30);
7106:
7107: -- PJI_UTILS.WRITE2OUT(l_plan_type_tg ||
7108: -- PJI_FM_SUM_MAIN.my_pad(30 -
7109: -- length(l_include_sub_org_tg),
7110: -- ' ') ||
7111: -- ': ' ||

Line 7139: PJI_UTILS.WRITE2OUT(l_project_operating_unit_tg ||

7135: FND_MESSAGE.SET_NAME('PJI', 'PJI_PJP_SUM_PRJ_OP_UNIT');
7136:
7137: l_project_operating_unit_tg := substr(FND_MESSAGE.GET, 1, 30);
7138:
7139: PJI_UTILS.WRITE2OUT(l_project_operating_unit_tg ||
7140: PJI_FM_SUM_MAIN.my_pad(30 -
7141: length(l_project_operating_unit_tg), ' ') ||
7142: ': ' ||
7143: l_project_operating_unit_name ||

Line 7163: PJI_UTILS.WRITE2OUT(l_from_project_tg ||

7159: FND_MESSAGE.SET_NAME('PJI', 'PJI_PJP_SUM_FROM_PRJ');
7160:
7161: l_from_project_tg := substr(FND_MESSAGE.GET, 1, 30);
7162:
7163: PJI_UTILS.WRITE2OUT(l_from_project_tg ||
7164: PJI_FM_SUM_MAIN.my_pad(30-length(l_from_project_tg),
7165: ' ') ||
7166: ': ' ||
7167: l_from_project ||

Line 7187: PJI_UTILS.WRITE2OUT(l_to_project_tg ||

7183: FND_MESSAGE.SET_NAME('PJI', 'PJI_PJP_SUM_TO_PRJ');
7184:
7185: l_to_project_tg := substr(FND_MESSAGE.GET, 1, 30);
7186:
7187: PJI_UTILS.WRITE2OUT(l_to_project_tg ||
7188: PJI_FM_SUM_MAIN.my_pad(30 - length(l_to_project_tg),
7189: ' ') ||
7190: ': ' ||
7191: l_to_project ||

Line 7214: PJI_UTILS.WRITE2OUT(l_plan_type_tg ||

7210: FND_MESSAGE.SET_NAME('PJI', 'PJI_PJP_SUM_PLAN_TYPE');
7211:
7212: l_plan_type_tg := substr(FND_MESSAGE.GET, 1, 30);
7213:
7214: PJI_UTILS.WRITE2OUT(l_plan_type_tg ||
7215: PJI_FM_SUM_MAIN.my_pad(30 - length(l_plan_type_tg),
7216: ' ') ||
7217: ': ' ||
7218: l_plan_type ||

Line 7262: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;

7258: PJI_FM_EXTR.CLEANUP(p_worker_id);
7259: PJI_FM_SUM_PSI.CLEANUP(p_worker_id);
7260: PJI_FM_SUM_ACT.CLEANUP(p_worker_id);
7261:
7262: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
7263:
7264: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
7265: 'PJI_FM_AGGR_FIN1',
7266: 'NORMAL',

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

7298: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING', 'F');
7299:
7300: commit;
7301:
7302: pji_utils.write2log(sqlerrm, true, 0);
7303:
7304: commit;
7305:
7306: end WRAPUP_FAILURE;

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

7454: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process,
7455: PJI_FM_SUM_MAIN.g_process ||
7456: p_worker_id)
7457: <> FND_GLOBAL.CONC_REQUEST_ID) then
7458: pji_utils.write2log('Warning: Helper is already running.');
7459: commit;
7460: retcode := 0;
7461: return;
7462: end if;

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

7576: if (WORKER_STATUS(p_worker_id, 'RUNNING')) then
7577: return;
7578: end if;
7579:
7580: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
7581:
7582: -- Initialize status tables with worker details
7583:
7584: -- Note that adding a new step will do nothing if the step already

Line 7600: PJI_UTILS.GET_PJI_SCHEMA_NAME, -- Application name

7596: PJI_FM_SUM_MAIN.g_process,
7597: l_process,
7598: FND_REQUEST.SUBMIT_REQUEST
7599: (
7600: PJI_UTILS.GET_PJI_SCHEMA_NAME, -- Application name
7601: PJI_FM_SUM_MAIN.g_helper_name, -- concurrent program name
7602: null, -- description (optional)
7603: null, -- Start Time (optional)
7604: false, -- called from another conc. request

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

7629: l_extraction_type varchar2(30);
7630:
7631: begin
7632:
7633: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
7634:
7635: if (p_worker_id = 1) then
7636:
7637: if (l_extraction_type = 'FULL') then