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 1827: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

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

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

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

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

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

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

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

Line 3275: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(PJI_FM_SUM_MAIN.g_process,

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

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

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

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

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

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

4360: l_process varchar2(30);
4361:
4362: begin
4363:
4364: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
4365:
4366: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.MOVE_DANGLING_FIN_ROWS(p_worker_id);')) then
4367: return;
4368: end if;

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

4698: l_g2_currency_code varchar2(30);
4699:
4700: begin
4701:
4702: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
4703:
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;

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

5721: l_process varchar2(30);
5722:
5723: begin
5724:
5725: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
5726:
5727: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.MOVE_DANGLING_ACT_ROWS(p_worker_id);')) then
5728: return;
5729: end if;

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

6071: l_extraction_type varchar2(30);
6072:
6073: begin
6074:
6075: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
6076:
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;

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

6155: l_extraction_type varchar2(30);
6156:
6157: begin
6158:
6159: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
6160:
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;

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

6791: l_schema varchar2(30);
6792:
6793: begin
6794:
6795: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
6796:
6797: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_EXTR.AGGREGATE_ACT_SLICES(p_worker_id);')) then
6798: return;
6799: end if;

Line 6803: PJI_FM_SUM_MAIN.g_process,

6799: end if;
6800:
6801: l_pa_calendar_flag := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
6802: (
6803: PJI_FM_SUM_MAIN.g_process,
6804: 'PA_CALENDAR_FLAG'
6805: );
6806:
6807: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

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

7411: l_plan_type varchar2(200);
7412:
7413: begin
7414:
7415: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
7416:
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;

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

7439: -- Stage 2 - RM Parameters
7440: -- -----------------------
7441:
7442: l_organization_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7443: (PJI_FM_SUM_MAIN.g_process, 'ORGANIZATION_ID');
7444:
7445: if (nvl(l_organization_id, -1) = -1) then
7446:
7447: l_organization := l_no_selection;

Line 7463: -- PJI_FM_SUM_MAIN.my_pad(30 -

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

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

7467: -- l_organization ||
7468: -- l_newline);
7469:
7470: l_include_sub_org_flag := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7471: (PJI_FM_SUM_MAIN.g_process, 'INCLUDE_SUB_ORG');
7472:
7473: if (nvl(l_include_sub_org_flag, 'PJI$NULL') = 'PJI$NULL') then
7474:
7475: l_include_sub_org := l_no_selection;

Line 7488: -- PJI_FM_SUM_MAIN.my_pad(30 -

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

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

7496: -- Stage 2 - FM Parameters
7497: -- -----------------------
7498:
7499: l_operating_unit := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7500: (PJI_FM_SUM_MAIN.g_process,'PROJECT_OPERATING_UNIT');
7501:
7502: if (nvl(l_operating_unit, -1) = -1) then
7503:
7504: l_project_operating_unit_name := l_no_selection;

Line 7520: PJI_FM_SUM_MAIN.my_pad(30 -

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

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

7523: l_project_operating_unit_name ||
7524: l_newline);
7525:
7526: l_from_project_num := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7527: (PJI_FM_SUM_MAIN.g_process, 'FROM_PROJECT');
7528:
7529: if (nvl(l_from_project_num,'PJI$NULL') = 'PJI$NULL') then
7530:
7531: l_from_project := l_no_selection;

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

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

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

7547: l_from_project ||
7548: l_newline);
7549:
7550: l_to_project_num := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7551: (PJI_FM_SUM_MAIN.g_process, 'TO_PROJECT');
7552:
7553: if (nvl(l_to_project_num, 'PJI$NULL') = 'PJI$NULL') then
7554:
7555: l_to_project := l_no_selection;

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

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

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

7571: l_to_project ||
7572: l_newline);
7573:
7574: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7575: (PJI_FM_SUM_MAIN.g_process, 'PLAN_TYPE_ID');
7576:
7577: if (nvl(l_plan_type_id, -1) = -1) then
7578:
7579: l_plan_type := l_no_selection;

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

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

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

7630: l_schema varchar2(30);
7631:
7632: begin
7633:
7634: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
7635:
7636: PJI_FM_DEBUG.CLEANUP_HOOK(l_process);
7637:
7638: PJI_FM_EXTR.CLEANUP(p_worker_id);

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

7674: begin
7675:
7676: rollback;
7677:
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);

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

7694: l_process varchar2(30);
7695:
7696: begin
7697:
7698: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
7699:
7700: PJI_FM_DEBUG.CONC_REQUEST_HOOK(l_process);
7701:
7702: PJI_EXTRACTION_UTIL.SEED_PJI_FM_STATS;

Line 7713: (PJI_FM_SUM_MAIN.g_process,

7709: PJI_FM_EXTR.EXTRACT_BATCH_DREV(p_worker_id);
7710:
7711: PJI_FM_EXTR.MARK_EXTRACTED_DREV_PRE(p_worker_id);
7712: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7713: (PJI_FM_SUM_MAIN.g_process,
7714: 'PJI_FM_EXTR.MARK_EXTRACTED_DREV(p_worker_id);',
7715: PJI_FM_SUM_MAIN.g_process_delay)) then
7716: return;
7717: end if;

Line 7715: PJI_FM_SUM_MAIN.g_process_delay)) then

7711: PJI_FM_EXTR.MARK_EXTRACTED_DREV_PRE(p_worker_id);
7712: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7713: (PJI_FM_SUM_MAIN.g_process,
7714: 'PJI_FM_EXTR.MARK_EXTRACTED_DREV(p_worker_id);',
7715: PJI_FM_SUM_MAIN.g_process_delay)) then
7716: return;
7717: end if;
7718: PJI_FM_EXTR.MARK_EXTRACTED_DREV_POST(p_worker_id);
7719:

Line 7724: (PJI_FM_SUM_MAIN.g_process,

7720: PJI_FM_EXTR.EXTRACT_BATCH_CDL_ROWIDS(p_worker_id);
7721:
7722: PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS_PRE(p_worker_id);
7723: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7724: (PJI_FM_SUM_MAIN.g_process,
7725: 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS(p_worker_id);',
7726: PJI_FM_SUM_MAIN.g_process_delay)) then
7727: return;
7728: end if;

Line 7726: PJI_FM_SUM_MAIN.g_process_delay)) then

7722: PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS_PRE(p_worker_id);
7723: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7724: (PJI_FM_SUM_MAIN.g_process,
7725: 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS(p_worker_id);',
7726: PJI_FM_SUM_MAIN.g_process_delay)) then
7727: return;
7728: end if;
7729: PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS_POST(p_worker_id);
7730:

Line 7741: (PJI_FM_SUM_MAIN.g_process,

7737: PJI_FM_EXTR.EXTRACT_BATCH_FND(p_worker_id);
7738:
7739: PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS_PRE(p_worker_id);
7740: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7741: (PJI_FM_SUM_MAIN.g_process,
7742: 'PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS(p_worker_id);',
7743: PJI_FM_SUM_MAIN.g_process_delay)) then
7744: return;
7745: end if;

Line 7743: PJI_FM_SUM_MAIN.g_process_delay)) then

7739: PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS_PRE(p_worker_id);
7740: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7741: (PJI_FM_SUM_MAIN.g_process,
7742: 'PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS(p_worker_id);',
7743: PJI_FM_SUM_MAIN.g_process_delay)) then
7744: return;
7745: end if;
7746: PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS_POST(p_worker_id);
7747:

Line 7755: (PJI_FM_SUM_MAIN.g_process,

7751: PJI_FM_EXTR.EXTRACT_BATCH_ARINV(p_worker_id);
7752:
7753: PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES_PRE(p_worker_id);
7754: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7755: (PJI_FM_SUM_MAIN.g_process,
7756: 'PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES(p_worker_id);',
7757: PJI_FM_SUM_MAIN.g_process_delay)) then
7758: return;
7759: end if;

Line 7757: PJI_FM_SUM_MAIN.g_process_delay)) then

7753: PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES_PRE(p_worker_id);
7754: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7755: (PJI_FM_SUM_MAIN.g_process,
7756: 'PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES(p_worker_id);',
7757: PJI_FM_SUM_MAIN.g_process_delay)) then
7758: return;
7759: end if;
7760: PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES_POST(p_worker_id);
7761:

Line 7766: (PJI_FM_SUM_MAIN.g_process,

7762: PJI_FM_SUM_ACT.BASE_SUMMARY(p_worker_id);
7763:
7764: PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT_PRE(p_worker_id);
7765: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7766: (PJI_FM_SUM_MAIN.g_process,
7767: 'PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT(p_worker_id);',
7768: PJI_FM_SUM_MAIN.g_process_delay)) then
7769: return;
7770: end if;

Line 7768: PJI_FM_SUM_MAIN.g_process_delay)) then

7764: PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT_PRE(p_worker_id);
7765: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7766: (PJI_FM_SUM_MAIN.g_process,
7767: 'PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT(p_worker_id);',
7768: PJI_FM_SUM_MAIN.g_process_delay)) then
7769: return;
7770: end if;
7771: PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT_POST(p_worker_id);
7772:

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

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

Line 7835: PJI_FM_SUM_MAIN.g_process ||

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

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

7840: retcode := 0;
7841: return;
7842: end if;
7843:
7844: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
7845:
7846: PJI_FM_DEBUG.CONC_REQUEST_HOOK(l_process);
7847:
7848: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP

Line 7849: (PJI_FM_SUM_MAIN.g_process,

7845:
7846: PJI_FM_DEBUG.CONC_REQUEST_HOOK(l_process);
7847:
7848: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7849: (PJI_FM_SUM_MAIN.g_process,
7850: 'PJI_FM_EXTR.MARK_EXTRACTED_DREV_PRE(p_worker_id);',
7851: PJI_FM_SUM_MAIN.g_process_delay,
7852: 'EVEN_IF_NOT_EXISTS')) then
7853: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 7851: PJI_FM_SUM_MAIN.g_process_delay,

7847:
7848: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7849: (PJI_FM_SUM_MAIN.g_process,
7850: 'PJI_FM_EXTR.MARK_EXTRACTED_DREV_PRE(p_worker_id);',
7851: PJI_FM_SUM_MAIN.g_process_delay,
7852: 'EVEN_IF_NOT_EXISTS')) then
7853: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7854: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7855: null;

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

7850: 'PJI_FM_EXTR.MARK_EXTRACTED_DREV_PRE(p_worker_id);',
7851: PJI_FM_SUM_MAIN.g_process_delay,
7852: 'EVEN_IF_NOT_EXISTS')) then
7853: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7854: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7855: null;
7856: else
7857: return;
7858: end if;

Line 7864: (PJI_FM_SUM_MAIN.g_process,

7860:
7861: PJI_FM_EXTR.MARK_EXTRACTED_DREV(p_worker_id);
7862:
7863: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7864: (PJI_FM_SUM_MAIN.g_process,
7865: 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS_PRE(p_worker_id);',
7866: PJI_FM_SUM_MAIN.g_process_delay)) then
7867: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7868: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then

Line 7866: PJI_FM_SUM_MAIN.g_process_delay)) then

7862:
7863: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7864: (PJI_FM_SUM_MAIN.g_process,
7865: 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS_PRE(p_worker_id);',
7866: PJI_FM_SUM_MAIN.g_process_delay)) then
7867: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7868: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7869: null;
7870: else

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

7864: (PJI_FM_SUM_MAIN.g_process,
7865: 'PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS_PRE(p_worker_id);',
7866: PJI_FM_SUM_MAIN.g_process_delay)) then
7867: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7868: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7869: null;
7870: else
7871: return;
7872: end if;

Line 7878: (PJI_FM_SUM_MAIN.g_process,

7874:
7875: PJI_FM_EXTR.MARK_EXTRACTED_CDL_ROWS(p_worker_id);
7876:
7877: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7878: (PJI_FM_SUM_MAIN.g_process,
7879: 'PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS_PRE(p_worker_id);',
7880: PJI_FM_SUM_MAIN.g_process_delay)) then
7881: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7882: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then

Line 7880: PJI_FM_SUM_MAIN.g_process_delay)) then

7876:
7877: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7878: (PJI_FM_SUM_MAIN.g_process,
7879: 'PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS_PRE(p_worker_id);',
7880: PJI_FM_SUM_MAIN.g_process_delay)) then
7881: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7882: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7883: null;
7884: else

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

7878: (PJI_FM_SUM_MAIN.g_process,
7879: 'PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS_PRE(p_worker_id);',
7880: PJI_FM_SUM_MAIN.g_process_delay)) then
7881: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7882: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7883: null;
7884: else
7885: return;
7886: end if;

Line 7892: (PJI_FM_SUM_MAIN.g_process,

7888:
7889: PJI_FM_EXTR.MARK_EXTRACTED_FND_ROWS(p_worker_id);
7890:
7891: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7892: (PJI_FM_SUM_MAIN.g_process,
7893: 'PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES_PRE(p_worker_id);',
7894: PJI_FM_SUM_MAIN.g_process_delay)) then
7895: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7896: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then

Line 7894: PJI_FM_SUM_MAIN.g_process_delay)) then

7890:
7891: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7892: (PJI_FM_SUM_MAIN.g_process,
7893: 'PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES_PRE(p_worker_id);',
7894: PJI_FM_SUM_MAIN.g_process_delay)) then
7895: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7896: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7897: null;
7898: else

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

7892: (PJI_FM_SUM_MAIN.g_process,
7893: 'PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES_PRE(p_worker_id);',
7894: PJI_FM_SUM_MAIN.g_process_delay)) then
7895: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7896: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7897: null;
7898: else
7899: return;
7900: end if;

Line 7906: (PJI_FM_SUM_MAIN.g_process,

7902:
7903: PJI_FM_EXTR.MARK_FULLY_PAID_INVOICES(p_worker_id);
7904:
7905: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7906: (PJI_FM_SUM_MAIN.g_process,
7907: 'PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT_PRE(p_worker_id);',
7908: PJI_FM_SUM_MAIN.g_process_delay)) then
7909: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7910: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then

Line 7908: PJI_FM_SUM_MAIN.g_process_delay)) then

7904:
7905: if (not PJI_PROCESS_UTIL.WAIT_FOR_STEP
7906: (PJI_FM_SUM_MAIN.g_process,
7907: 'PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT_PRE(p_worker_id);',
7908: PJI_FM_SUM_MAIN.g_process_delay)) then
7909: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7910: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7911: null;
7912: else

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

7906: (PJI_FM_SUM_MAIN.g_process,
7907: 'PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT_PRE(p_worker_id);',
7908: PJI_FM_SUM_MAIN.g_process_delay)) then
7909: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7910: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'N') then
7911: null;
7912: else
7913: return;
7914: end if;

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

7916:
7917: PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT(p_worker_id);
7918:
7919: while (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7920: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'Y') loop
7921: PJI_PROCESS_UTIL.SLEEP(PJI_FM_SUM_MAIN.g_process_delay);
7922: end loop;
7923:
7924: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

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

7917: PJI_FM_CMT_EXTR.REFRESH_PROJPERF_CMT(p_worker_id);
7918:
7919: while (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7920: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'Y') loop
7921: PJI_PROCESS_UTIL.SLEEP(PJI_FM_SUM_MAIN.g_process_delay);
7922: end loop;
7923:
7924: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7925: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'F') then

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

7921: PJI_PROCESS_UTIL.SLEEP(PJI_FM_SUM_MAIN.g_process_delay);
7922: end loop;
7923:
7924: if (PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7925: (PJI_FM_SUM_MAIN.g_process, 'PROCESS_RUNNING') = 'F') then
7926: return;
7927: end if;
7928:
7929: PJI_PROCESS_UTIL.WRAPUP_PROCESS(l_process);

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

7964: -- Note that adding a new step will do nothing if the step already
7965: -- exists. Therefore, no state will be overwritten in the case of
7966: -- error recovery.
7967:
7968: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
7969:
7970: PJI_PROCESS_UTIL.ADD_STEPS(l_process, 'PJI_EXTR_HELPER', l_extraction_type);
7971:
7972: -- Kick off helper

Line 7976: PJI_FM_SUM_MAIN.g_process,

7972: -- Kick off helper
7973:
7974: PJI_PROCESS_UTIL.SET_PROCESS_PARAMETER
7975: (
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

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

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

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

7986: )
7987: );
7988:
7989: if (nvl(to_number(PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
7990: (PJI_FM_SUM_MAIN.g_process, l_process)), 0) = 0) then
7991: fnd_message.set_name('PJI', 'PJI_SUM_NO_SUB_REQ');
7992: dbms_standard.raise_application_error(-20030, fnd_message.get);
7993: end if;
7994:

Line 8018: l_worker_name := PJI_FM_SUM_MAIN.g_full_disp_name;

8014:
8015: if (p_worker_id = 1) then
8016:
8017: if (l_extraction_type = 'FULL') then
8018: l_worker_name := PJI_FM_SUM_MAIN.g_full_disp_name;
8019: elsif (l_extraction_type = 'INCREMENTAL') then
8020: l_worker_name := PJI_FM_SUM_MAIN.g_incr_disp_name;
8021: elsif (l_extraction_type = 'PARTIAL') then
8022: l_worker_name := PJI_FM_SUM_MAIN.g_prtl_disp_name;

Line 8020: l_worker_name := PJI_FM_SUM_MAIN.g_incr_disp_name;

8016:
8017: if (l_extraction_type = 'FULL') then
8018: l_worker_name := PJI_FM_SUM_MAIN.g_full_disp_name;
8019: elsif (l_extraction_type = 'INCREMENTAL') then
8020: l_worker_name := PJI_FM_SUM_MAIN.g_incr_disp_name;
8021: elsif (l_extraction_type = 'PARTIAL') then
8022: l_worker_name := PJI_FM_SUM_MAIN.g_prtl_disp_name;
8023: end if;
8024:

Line 8022: l_worker_name := PJI_FM_SUM_MAIN.g_prtl_disp_name;

8018: l_worker_name := PJI_FM_SUM_MAIN.g_full_disp_name;
8019: elsif (l_extraction_type = 'INCREMENTAL') then
8020: l_worker_name := PJI_FM_SUM_MAIN.g_incr_disp_name;
8021: elsif (l_extraction_type = 'PARTIAL') then
8022: l_worker_name := PJI_FM_SUM_MAIN.g_prtl_disp_name;
8023: end if;
8024:
8025: l_request_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
8026: (PJI_FM_SUM_MAIN.g_process,

Line 8026: (PJI_FM_SUM_MAIN.g_process,

8022: l_worker_name := PJI_FM_SUM_MAIN.g_prtl_disp_name;
8023: end if;
8024:
8025: l_request_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
8026: (PJI_FM_SUM_MAIN.g_process,
8027: PJI_FM_SUM_MAIN.g_process);
8028:
8029: else
8030:

Line 8027: PJI_FM_SUM_MAIN.g_process);

8023: end if;
8024:
8025: l_request_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
8026: (PJI_FM_SUM_MAIN.g_process,
8027: PJI_FM_SUM_MAIN.g_process);
8028:
8029: else
8030:
8031: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;

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

8027: PJI_FM_SUM_MAIN.g_process);
8028:
8029: else
8030:
8031: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
8032:
8033: l_worker_name := PJI_FM_SUM_MAIN.g_helper_name;
8034:
8035: l_request_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER

Line 8033: l_worker_name := PJI_FM_SUM_MAIN.g_helper_name;

8029: else
8030:
8031: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
8032:
8033: l_worker_name := PJI_FM_SUM_MAIN.g_helper_name;
8034:
8035: l_request_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
8036: (PJI_FM_SUM_MAIN.g_process, l_process);
8037:

Line 8036: (PJI_FM_SUM_MAIN.g_process, l_process);

8032:
8033: l_worker_name := PJI_FM_SUM_MAIN.g_helper_name;
8034:
8035: l_request_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
8036: (PJI_FM_SUM_MAIN.g_process, l_process);
8037:
8038: end if;
8039:
8040: return PJI_PROCESS_UTIL.REQUEST_STATUS(p_mode,

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

8053: l_request_id number;
8054:
8055: begin
8056:
8057: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
8058:
8059: l_request_id :=
8060: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
8061: (

Line 8062: PJI_FM_SUM_MAIN.g_process,

8058:
8059: l_request_id :=
8060: PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
8061: (
8062: PJI_FM_SUM_MAIN.g_process,
8063: l_process
8064: );
8065:
8066: PJI_PROCESS_UTIL.WAIT_FOR_REQUEST(l_request_id,

Line 8067: PJI_FM_SUM_MAIN.g_process_delay);

8063: l_process
8064: );
8065:
8066: PJI_PROCESS_UTIL.WAIT_FOR_REQUEST(l_request_id,
8067: PJI_FM_SUM_MAIN.g_process_delay);
8068:
8069: end WAIT_FOR_WORKER;
8070:
8071: end PJI_FM_SUM_EXTR;