APPS.PJI_FM_SUM_EXTR dependencies on PJI_FM_SUM_MAIN

Line 17: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

13: l_msg_data varchar2(2000);
14:
15: begin
16:
17: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
18:
19: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.POPULATE_TIME_DIMENSION(p_worker_id);')) then
20: return;
21: end if;

Line 41: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

37: l_process varchar2(30);
38:
39: begin
40:
41: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
42:
43: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.ORG_EXTR_INFO_TABLE(p_worker_id);')) then
44: return;
45: end if;

Line 77: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

73: l_extract_commitments varchar2(30);
74:
75: begin
76:
77: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
78:
79: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.CURR_CONV_TABLE(p_worker_id);')) then
80: return;
81: end if;

Line 84: (PJI_FM_SUM_MAIN.g_process,

80: return;
81: end if;
82:
83: l_extract_commitments := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
84: (PJI_FM_SUM_MAIN.g_process,
85: 'EXTRACT_COMMITMENTS');
86:
87: insert /*+ append */ into PJI_FM_AGGR_DLY_RATES
88: (

Line 385: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

381: l_g2_currency_code varchar2(30);
382:
383: begin
384:
385: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
386:
387: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.DANGLING_FIN_ROWS(p_worker_id);')) then
388: return;
389: end if;

Line 1824: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

1820: l_g2_currency_code varchar2(30);
1821:
1822: begin
1823:
1824: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
1825:
1826: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.DANGLING_ACT_ROWS(p_worker_id);')) then
1827: return;
1828: end if;

Line 3191: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

3187: l_process varchar2(30);
3188:
3189: begin
3190:
3191: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
3192:
3193: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.PURGE_DANGLING_FIN_ROWS(p_worker_id);')) then
3194: return;
3195: end if;

Line 3227: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

3223: l_process varchar2(30);
3224:
3225: begin
3226:
3227: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
3228:
3229: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.PURGE_DANGLING_ACT_ROWS(p_worker_id);')) then
3230: return;
3231: end if;

Line 3265: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

3261: l_g2_currency_code varchar2(30);
3262:
3263: begin
3264:
3265: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
3266:
3267: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.FIN_SUMMARY(p_worker_id);')) then
3268: return;
3269: end if;

Line 3272: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process,

3268: return;
3269: end if;
3270:
3271: l_transition_flag :=
3272: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process,
3273: 'TRANSITION');
3274:
3275: if (l_transition_flag = 'Y') then
3276:

Line 3278: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process,

3274:
3275: if (l_transition_flag = 'Y') then
3276:
3277: l_params_cost_flag :=
3278: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process,
3279: 'CONFIG_COST_FLAG'), 'N');
3280: l_params_util_flag :=
3281: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process,
3282: 'CONFIG_UTIL_FLAG'), 'N');

Line 3281: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process,

3277: l_params_cost_flag :=
3278: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process,
3279: 'CONFIG_COST_FLAG'), 'N');
3280: l_params_util_flag :=
3281: nvl(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process,
3282: 'CONFIG_UTIL_FLAG'), 'N');
3283:
3284: else -- l_transition is null or 'N'
3285:

Line 4356: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

4352: l_process varchar2(30);
4353:
4354: begin
4355:
4356: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
4357:
4358: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.MOVE_DANGLING_FIN_ROWS(p_worker_id);')) then
4359: return;
4360: end if;

Line 4692: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

4688: l_g2_currency_code varchar2(30);
4689:
4690: begin
4691:
4692: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
4693:
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;

Line 5715: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

5711: l_process varchar2(30);
5712:
5713: begin
5714:
5715: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
5716:
5717: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.MOVE_DANGLING_ACT_ROWS(p_worker_id);')) then
5718: return;
5719: end if;

Line 6065: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

6061: l_extraction_type varchar2(30);
6062:
6063: begin
6064:
6065: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
6066:
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;

Line 6149: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

6145: l_extraction_type varchar2(30);
6146:
6147: begin
6148:
6149: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
6150:
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;

Line 6415: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

6411: l_schema varchar2(30);
6412:
6413: begin
6414:
6415: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
6416:
6417: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_ACT_SLICES(p_worker_id);')) then
6418: return;
6419: end if;

Line 6423: PJI_FM_SUM_MAIN.g_process,

6419: end if;
6420:
6421: l_pa_calendar_flag := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
6422: (
6423: PJI_FM_SUM_MAIN.g_process,
6424: 'PA_CALENDAR_FLAG'
6425: );
6426:
6427: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

Line 7035: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

7031: l_plan_type varchar2(200);
7032:
7033: begin
7034:
7035: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
7036:
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;

Line 7063: (PJI_FM_SUM_MAIN.g_process, 'ORGANIZATION_ID');

7059: -- Stage 2 - RM Parameters
7060: -- -----------------------
7061:
7062: l_organization_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7063: (PJI_FM_SUM_MAIN.g_process, 'ORGANIZATION_ID');
7064:
7065: if (nvl(l_organization_id, -1) = -1) then
7066:
7067: l_organization := l_no_selection;

Line 7083: -- PJI_FM_SUM_MAIN.my_pad(30 -

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: -- ': ' ||
7087: -- l_organization ||

Line 7091: (PJI_FM_SUM_MAIN.g_process, 'INCLUDE_SUB_ORG');

7087: -- l_organization ||
7088: -- l_newline);
7089:
7090: l_include_sub_org_flag := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7091: (PJI_FM_SUM_MAIN.g_process, 'INCLUDE_SUB_ORG');
7092:
7093: if (nvl(l_include_sub_org_flag, 'PJI$NULL') = 'PJI$NULL') then
7094:
7095: l_include_sub_org := l_no_selection;

Line 7108: -- PJI_FM_SUM_MAIN.my_pad(30 -

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: -- ': ' ||
7112: -- l_include_sub_org ||

Line 7120: (PJI_FM_SUM_MAIN.g_process,'PROJECT_OPERATING_UNIT');

7116: -- Stage 2 - FM Parameters
7117: -- -----------------------
7118:
7119: l_operating_unit := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7120: (PJI_FM_SUM_MAIN.g_process,'PROJECT_OPERATING_UNIT');
7121:
7122: if (nvl(l_operating_unit, -1) = -1) then
7123:
7124: l_project_operating_unit_name := l_no_selection;

Line 7140: PJI_FM_SUM_MAIN.my_pad(30 -

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 ||
7144: l_newline);

Line 7147: (PJI_FM_SUM_MAIN.g_process, 'FROM_PROJECT');

7143: l_project_operating_unit_name ||
7144: l_newline);
7145:
7146: l_from_project_num := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7147: (PJI_FM_SUM_MAIN.g_process, 'FROM_PROJECT');
7148:
7149: if (nvl(l_from_project_num,'PJI$NULL') = 'PJI$NULL') then
7150:
7151: l_from_project := l_no_selection;

Line 7164: PJI_FM_SUM_MAIN.my_pad(30-length(l_from_project_tg),

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 ||
7168: l_newline);

Line 7171: (PJI_FM_SUM_MAIN.g_process, 'TO_PROJECT');

7167: l_from_project ||
7168: l_newline);
7169:
7170: l_to_project_num := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7171: (PJI_FM_SUM_MAIN.g_process, 'TO_PROJECT');
7172:
7173: if (nvl(l_to_project_num, 'PJI$NULL') = 'PJI$NULL') then
7174:
7175: l_to_project := l_no_selection;

Line 7188: PJI_FM_SUM_MAIN.my_pad(30 - length(l_to_project_tg),

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 ||
7192: l_newline);

Line 7195: (PJI_FM_SUM_MAIN.g_process, 'PLAN_TYPE_ID');

7191: l_to_project ||
7192: l_newline);
7193:
7194: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7195: (PJI_FM_SUM_MAIN.g_process, 'PLAN_TYPE_ID');
7196:
7197: if (nvl(l_plan_type_id, -1) = -1) then
7198:
7199: l_plan_type := l_no_selection;

Line 7215: PJI_FM_SUM_MAIN.my_pad(30 - length(l_plan_type_tg),

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 ||
7219: l_newline);

Line 7254: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

7250: l_schema varchar2(30);
7251:
7252: begin
7253:
7254: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
7255:
7256: PJI_FM_DEBUG.CLEANUP_HOOK(l_process);
7257:
7258: PJI_FM_EXTR.CLEANUP(p_worker_id);

Line 7298: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING', 'F');

7294: begin
7295:
7296: rollback;
7297:
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);

Line 7318: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

7314: l_process varchar2(30);
7315:
7316: begin
7317:
7318: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
7319:
7320: PJI_FM_DEBUG.CONC_REQUEST_HOOK(l_process);
7321:
7322: PJI_EXTRACTION_UTIL.SEED_PJI_FM_STATS;

Line 7333: (PJI_FM_SUM_MAIN.g_process,

7329: PJI_FM_EXTR.EXTRACT_BATCH_DREV(p_worker_id);
7330:
7331: PJI_FM_EXTR.MARK_EXTRACTED_DREV_PRE(p_worker_id);
7332: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7333: (PJI_FM_SUM_MAIN.g_process,
7334: 'PJI_FM_EXTR.MARK_EXTRACTED_DREV(p_worker_id);',
7335: PJI_FM_SUM_MAIN.g_process_delay)) then
7336: return;
7337: end if;

Line 7335: PJI_FM_SUM_MAIN.g_process_delay)) then

7331: PJI_FM_EXTR.MARK_EXTRACTED_DREV_PRE(p_worker_id);
7332: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7333: (PJI_FM_SUM_MAIN.g_process,
7334: 'PJI_FM_EXTR.MARK_EXTRACTED_DREV(p_worker_id);',
7335: PJI_FM_SUM_MAIN.g_process_delay)) then
7336: return;
7337: end if;
7338: PJI_FM_EXTR.MARK_EXTRACTED_DREV_POST(p_worker_id);
7339:

Line 7344: (PJI_FM_SUM_MAIN.g_process,

7340: PJI_FM_EXTR.EXTRACT_BATCH_CDL_ROWIDS(p_worker_id);
7341:
7342: PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS_PRE(p_worker_id);
7343: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7344: (PJI_FM_SUM_MAIN.g_process,
7345: 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS(p_worker_id);',
7346: PJI_FM_SUM_MAIN.g_process_delay)) then
7347: return;
7348: end if;

Line 7346: PJI_FM_SUM_MAIN.g_process_delay)) then

7342: PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS_PRE(p_worker_id);
7343: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7344: (PJI_FM_SUM_MAIN.g_process,
7345: 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS(p_worker_id);',
7346: PJI_FM_SUM_MAIN.g_process_delay)) then
7347: return;
7348: end if;
7349: PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS_POST(p_worker_id);
7350:

Line 7361: (PJI_FM_SUM_MAIN.g_process,

7357: PJI_FM_EXTR.EXTRACT_BATCH_FND(p_worker_id);
7358:
7359: PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS_PRE(p_worker_id);
7360: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7361: (PJI_FM_SUM_MAIN.g_process,
7362: 'PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS(p_worker_id);',
7363: PJI_FM_SUM_MAIN.g_process_delay)) then
7364: return;
7365: end if;

Line 7363: PJI_FM_SUM_MAIN.g_process_delay)) then

7359: PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS_PRE(p_worker_id);
7360: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7361: (PJI_FM_SUM_MAIN.g_process,
7362: 'PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS(p_worker_id);',
7363: PJI_FM_SUM_MAIN.g_process_delay)) then
7364: return;
7365: end if;
7366: PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS_POST(p_worker_id);
7367:

Line 7375: (PJI_FM_SUM_MAIN.g_process,

7371: PJI_FM_EXTR.EXTRACT_BATCH_ARINV(p_worker_id);
7372:
7373: PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES_PRE(p_worker_id);
7374: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7375: (PJI_FM_SUM_MAIN.g_process,
7376: 'PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES(p_worker_id);',
7377: PJI_FM_SUM_MAIN.g_process_delay)) then
7378: return;
7379: end if;

Line 7377: PJI_FM_SUM_MAIN.g_process_delay)) then

7373: PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES_PRE(p_worker_id);
7374: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7375: (PJI_FM_SUM_MAIN.g_process,
7376: 'PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES(p_worker_id);',
7377: PJI_FM_SUM_MAIN.g_process_delay)) then
7378: return;
7379: end if;
7380: PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES_POST(p_worker_id);
7381:

Line 7386: (PJI_FM_SUM_MAIN.g_process,

7382: PJI_FM_SUM_ACT.BASE_SUMMARY(p_worker_id);
7383:
7384: PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT_PRE(p_worker_id);
7385: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7386: (PJI_FM_SUM_MAIN.g_process,
7387: 'PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT(p_worker_id);',
7388: PJI_FM_SUM_MAIN.g_process_delay)) then
7389: return;
7390: end if;

Line 7388: PJI_FM_SUM_MAIN.g_process_delay)) then

7384: PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT_PRE(p_worker_id);
7385: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7386: (PJI_FM_SUM_MAIN.g_process,
7387: 'PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT(p_worker_id);',
7388: PJI_FM_SUM_MAIN.g_process_delay)) then
7389: return;
7390: end if;
7391: PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT_POST(p_worker_id);
7392:

Line 7454: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process,

7450:
7451: -- If this helper's concurrent request ID does not exist in the
7452: -- parameters table, the dispatcher must have kicked off a new
7453: -- helper. Therefore do nothing.
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.');

Line 7455: PJI_FM_SUM_MAIN.g_process ||

7451: -- If this helper's concurrent request ID does not exist in the
7452: -- parameters table, the dispatcher must have kicked off a new
7453: -- helper. Therefore do nothing.
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;

Line 7464: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

7460: retcode := 0;
7461: return;
7462: end if;
7463:
7464: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
7465:
7466: PJI_FM_DEBUG.CONC_REQUEST_HOOK(l_process);
7467:
7468: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

Line 7469: (PJI_FM_SUM_MAIN.g_process,

7465:
7466: PJI_FM_DEBUG.CONC_REQUEST_HOOK(l_process);
7467:
7468: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7469: (PJI_FM_SUM_MAIN.g_process,
7470: 'PJI_FM_EXTR.MARK_EXTRACTED_DREV_PRE(p_worker_id);',
7471: PJI_FM_SUM_MAIN.g_process_delay,
7472: 'EVEN_IF_NOT_EXISTS')) then
7473: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 7471: PJI_FM_SUM_MAIN.g_process_delay,

7467:
7468: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7469: (PJI_FM_SUM_MAIN.g_process,
7470: 'PJI_FM_EXTR.MARK_EXTRACTED_DREV_PRE(p_worker_id);',
7471: PJI_FM_SUM_MAIN.g_process_delay,
7472: 'EVEN_IF_NOT_EXISTS')) then
7473: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7474: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7475: null;

Line 7474: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then

7470: 'PJI_FM_EXTR.MARK_EXTRACTED_DREV_PRE(p_worker_id);',
7471: PJI_FM_SUM_MAIN.g_process_delay,
7472: 'EVEN_IF_NOT_EXISTS')) then
7473: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7474: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7475: null;
7476: else
7477: return;
7478: end if;

Line 7484: (PJI_FM_SUM_MAIN.g_process,

7480:
7481: PJI_FM_EXTR.MARK_EXTRACTED_DREV(p_worker_id);
7482:
7483: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7484: (PJI_FM_SUM_MAIN.g_process,
7485: 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS_PRE(p_worker_id);',
7486: PJI_FM_SUM_MAIN.g_process_delay)) then
7487: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7488: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then

Line 7486: PJI_FM_SUM_MAIN.g_process_delay)) then

7482:
7483: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7484: (PJI_FM_SUM_MAIN.g_process,
7485: 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS_PRE(p_worker_id);',
7486: PJI_FM_SUM_MAIN.g_process_delay)) then
7487: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7488: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7489: null;
7490: else

Line 7488: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then

7484: (PJI_FM_SUM_MAIN.g_process,
7485: 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS_PRE(p_worker_id);',
7486: PJI_FM_SUM_MAIN.g_process_delay)) then
7487: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7488: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7489: null;
7490: else
7491: return;
7492: end if;

Line 7498: (PJI_FM_SUM_MAIN.g_process,

7494:
7495: PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS(p_worker_id);
7496:
7497: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7498: (PJI_FM_SUM_MAIN.g_process,
7499: 'PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS_PRE(p_worker_id);',
7500: PJI_FM_SUM_MAIN.g_process_delay)) then
7501: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7502: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then

Line 7500: PJI_FM_SUM_MAIN.g_process_delay)) then

7496:
7497: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7498: (PJI_FM_SUM_MAIN.g_process,
7499: 'PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS_PRE(p_worker_id);',
7500: PJI_FM_SUM_MAIN.g_process_delay)) then
7501: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7502: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7503: null;
7504: else

Line 7502: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then

7498: (PJI_FM_SUM_MAIN.g_process,
7499: 'PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS_PRE(p_worker_id);',
7500: PJI_FM_SUM_MAIN.g_process_delay)) then
7501: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7502: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7503: null;
7504: else
7505: return;
7506: end if;

Line 7512: (PJI_FM_SUM_MAIN.g_process,

7508:
7509: PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS(p_worker_id);
7510:
7511: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7512: (PJI_FM_SUM_MAIN.g_process,
7513: 'PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES_PRE(p_worker_id);',
7514: PJI_FM_SUM_MAIN.g_process_delay)) then
7515: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7516: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then

Line 7514: PJI_FM_SUM_MAIN.g_process_delay)) then

7510:
7511: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7512: (PJI_FM_SUM_MAIN.g_process,
7513: 'PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES_PRE(p_worker_id);',
7514: PJI_FM_SUM_MAIN.g_process_delay)) then
7515: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7516: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7517: null;
7518: else

Line 7516: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then

7512: (PJI_FM_SUM_MAIN.g_process,
7513: 'PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES_PRE(p_worker_id);',
7514: PJI_FM_SUM_MAIN.g_process_delay)) then
7515: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7516: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7517: null;
7518: else
7519: return;
7520: end if;

Line 7526: (PJI_FM_SUM_MAIN.g_process,

7522:
7523: PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES(p_worker_id);
7524:
7525: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7526: (PJI_FM_SUM_MAIN.g_process,
7527: 'PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT_PRE(p_worker_id);',
7528: PJI_FM_SUM_MAIN.g_process_delay)) then
7529: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7530: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then

Line 7528: PJI_FM_SUM_MAIN.g_process_delay)) then

7524:
7525: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7526: (PJI_FM_SUM_MAIN.g_process,
7527: 'PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT_PRE(p_worker_id);',
7528: PJI_FM_SUM_MAIN.g_process_delay)) then
7529: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7530: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7531: null;
7532: else

Line 7530: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then

7526: (PJI_FM_SUM_MAIN.g_process,
7527: 'PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT_PRE(p_worker_id);',
7528: PJI_FM_SUM_MAIN.g_process_delay)) then
7529: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7530: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7531: null;
7532: else
7533: return;
7534: end if;

Line 7540: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'Y') loop

7536:
7537: PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT(p_worker_id);
7538:
7539: while (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7540: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'Y') loop
7541: PJI_PROCESS_UTIL.SLEEP(PJI_FM_SUM_MAIN.g_process_delay);
7542: end loop;
7543:
7544: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 7541: PJI_PROCESS_UTIL.SLEEP(PJI_FM_SUM_MAIN.g_process_delay);

7537: PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT(p_worker_id);
7538:
7539: while (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7540: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'Y') loop
7541: PJI_PROCESS_UTIL.SLEEP(PJI_FM_SUM_MAIN.g_process_delay);
7542: end loop;
7543:
7544: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7545: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'F') then

Line 7545: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'F') then

7541: PJI_PROCESS_UTIL.SLEEP(PJI_FM_SUM_MAIN.g_process_delay);
7542: end loop;
7543:
7544: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7545: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'F') then
7546: return;
7547: end if;
7548:
7549: PJI_PROCESS_UTIL.WRAPUP_PROCESS(l_process);

Line 7588: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

7584: -- Note that adding a new step will do nothing if the step already
7585: -- exists. Therefore, no state will be overwritten in the case of
7586: -- error recovery.
7587:
7588: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
7589:
7590: PJI_PROCESS_UTIL.ADD_STEPS(l_process, 'PJI_EXTR_HELPER', l_extraction_type);
7591:
7592: -- Kick off helper

Line 7596: PJI_FM_SUM_MAIN.g_process,

7592: -- Kick off helper
7593:
7594: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER
7595: (
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

Line 7601: PJI_FM_SUM_MAIN.g_helper_name, -- concurrent program name

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
7605: p_worker_id -- first parameter

Line 7610: (PJI_FM_SUM_MAIN.g_process, l_process)), 0) = 0) then

7606: )
7607: );
7608:
7609: if (nvl(to_number(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7610: (PJI_FM_SUM_MAIN.g_process, l_process)), 0) = 0) then
7611: fnd_message.set_name('PJI', 'PJI_SUM_NO_SUB_REQ');
7612: dbms_standard.raise_application_error(-20030, fnd_message.get);
7613: end if;
7614:

Line 7638: l_worker_name := PJI_FM_SUM_MAIN.g_full_disp_name;

7634:
7635: if (p_worker_id = 1) then
7636:
7637: if (l_extraction_type = 'FULL') then
7638: l_worker_name := PJI_FM_SUM_MAIN.g_full_disp_name;
7639: elsif (l_extraction_type = 'INCREMENTAL') then
7640: l_worker_name := PJI_FM_SUM_MAIN.g_incr_disp_name;
7641: elsif (l_extraction_type = 'PARTIAL') then
7642: l_worker_name := PJI_FM_SUM_MAIN.g_prtl_disp_name;

Line 7640: l_worker_name := PJI_FM_SUM_MAIN.g_incr_disp_name;

7636:
7637: if (l_extraction_type = 'FULL') then
7638: l_worker_name := PJI_FM_SUM_MAIN.g_full_disp_name;
7639: elsif (l_extraction_type = 'INCREMENTAL') then
7640: l_worker_name := PJI_FM_SUM_MAIN.g_incr_disp_name;
7641: elsif (l_extraction_type = 'PARTIAL') then
7642: l_worker_name := PJI_FM_SUM_MAIN.g_prtl_disp_name;
7643: end if;
7644:

Line 7642: l_worker_name := PJI_FM_SUM_MAIN.g_prtl_disp_name;

7638: l_worker_name := PJI_FM_SUM_MAIN.g_full_disp_name;
7639: elsif (l_extraction_type = 'INCREMENTAL') then
7640: l_worker_name := PJI_FM_SUM_MAIN.g_incr_disp_name;
7641: elsif (l_extraction_type = 'PARTIAL') then
7642: l_worker_name := PJI_FM_SUM_MAIN.g_prtl_disp_name;
7643: end if;
7644:
7645: l_request_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7646: (PJI_FM_SUM_MAIN.g_process,

Line 7646: (PJI_FM_SUM_MAIN.g_process,

7642: l_worker_name := PJI_FM_SUM_MAIN.g_prtl_disp_name;
7643: end if;
7644:
7645: l_request_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7646: (PJI_FM_SUM_MAIN.g_process,
7647: PJI_FM_SUM_MAIN.g_process);
7648:
7649: else
7650:

Line 7647: PJI_FM_SUM_MAIN.g_process);

7643: end if;
7644:
7645: l_request_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7646: (PJI_FM_SUM_MAIN.g_process,
7647: PJI_FM_SUM_MAIN.g_process);
7648:
7649: else
7650:
7651: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

Line 7651: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

7647: PJI_FM_SUM_MAIN.g_process);
7648:
7649: else
7650:
7651: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
7652:
7653: l_worker_name := PJI_FM_SUM_MAIN.g_helper_name;
7654:
7655: l_request_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 7653: l_worker_name := PJI_FM_SUM_MAIN.g_helper_name;

7649: else
7650:
7651: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
7652:
7653: l_worker_name := PJI_FM_SUM_MAIN.g_helper_name;
7654:
7655: l_request_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7656: (PJI_FM_SUM_MAIN.g_process, l_process);
7657:

Line 7656: (PJI_FM_SUM_MAIN.g_process, l_process);

7652:
7653: l_worker_name := PJI_FM_SUM_MAIN.g_helper_name;
7654:
7655: l_request_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7656: (PJI_FM_SUM_MAIN.g_process, l_process);
7657:
7658: end if;
7659:
7660: return PJI_PROCESS_UTIL.REQUEST_STATUS(p_mode,

Line 7677: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

7673: l_request_id number;
7674:
7675: begin
7676:
7677: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
7678:
7679: l_request_id :=
7680: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7681: (

Line 7682: PJI_FM_SUM_MAIN.g_process,

7678:
7679: l_request_id :=
7680: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7681: (
7682: PJI_FM_SUM_MAIN.g_process,
7683: l_process
7684: );
7685:
7686: PJI_PROCESS_UTIL.WAIT_FOR_REQUEST(l_request_id,

Line 7687: PJI_FM_SUM_MAIN.g_process_delay);

7683: l_process
7684: );
7685:
7686: PJI_PROCESS_UTIL.WAIT_FOR_REQUEST(l_request_id,
7687: PJI_FM_SUM_MAIN.g_process_delay);
7688:
7689: end WAIT_FOR_WORKER;
7690:
7691: end PJI_FM_SUM_EXTR;