DBA Data[Home] [Help]

APPS.PJI_FM_SUM_PSI dependencies on PJI_FM_SUM_PSI

Line 1: package body PJI_FM_SUM_PSI as

1: package body PJI_FM_SUM_PSI as
2: /* $Header: PJISF09B.pls 120.24.12020000.7 2013/04/23 22:41:44 sachandr ship $ */
3:
4: -- -----------------------------------------------------
5: -- procedure RESOURCE_LOOKUP_TABLE

Line 24: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.RESOURCE_LOOKUP_TABLE(p_worker_id);')) then

20: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
21:
22: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
23:
24: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.RESOURCE_LOOKUP_TABLE(p_worker_id);')) then
25: return;
26: end if;
27:
28: insert into PJI_FM_AGGR_RES_TYPES

Line 116: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.RESOURCE_LOOKUP_TABLE(p_worker_id);');

112: 'MATERIAL_ITEMS',
113: 'EQUIPMENT',
114: 'PEOPLE');
115:
116: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.RESOURCE_LOOKUP_TABLE(p_worker_id);');
117:
118: commit;
119:
120: end RESOURCE_LOOKUP_TABLE;

Line 141: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.PURGE_FP_BALANCES(p_worker_id);')) then

137: begin
138:
139: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
140:
141: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.PURGE_FP_BALANCES(p_worker_id);')) then
142: return;
143: end if;
144:
145: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

Line 179: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.PURGE_FP_BALANCES(p_worker_id);');

175: */ -- COMMENTED TO REVERT OLAP CHANGES FOR 15900841
176:
177: end if;
178:
179: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.PURGE_FP_BALANCES(p_worker_id);');
180:
181: commit;
182:
183: end PURGE_FP_BALANCES;

Line 205: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.PURGE_CMT_BALANCES(p_worker_id);')) then

201: begin
202:
203: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
204:
205: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.PURGE_CMT_BALANCES(p_worker_id);')) then
206: return;
207: end if;
208:
209: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

Line 232: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.PURGE_CMT_BALANCES(p_worker_id);');

228: where map.WORKER_ID = p_worker_id);
229:
230: end if;
231:
232: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.PURGE_CMT_BALANCES(p_worker_id);');
233:
234: commit;
235:
236: end PURGE_CMT_BALANCES;

Line 257: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.PURGE_AC_BALANCES(p_worker_id);')) then

253: begin
254:
255: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
256:
257: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.PURGE_AC_BALANCES(p_worker_id);')) then
258: return;
259: end if;
260:
261: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

Line 479: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.PURGE_AC_BALANCES(p_worker_id);');

475: nvl(act4.G2_AR_AMOUNT_OVERDUE , 0) = 0;
476:
477: end if;
478:
479: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.PURGE_AC_BALANCES(p_worker_id);');
480:
481: commit;
482:
483: end PURGE_AC_BALANCES;

Line 503: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.AGGREGATE_FPR_PERIODS(p_worker_id);')) then

499: begin
500:
501: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
502:
503: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.AGGREGATE_FPR_PERIODS(p_worker_id);')) then
504: return;
505: end if;
506:
507: insert /*+ append parallel(tmp6_i) */ into PJI_FM_AGGR_FIN6 tmp6_i

Line 1444: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.AGGREGATE_FPR_PERIODS(p_worker_id);');

1440: 'PA', pa_cal.CAL_PERIOD_ID),
1441: tmp2.TXN_CURRENCY_CODE,
1442: tmp2.CBS_ELEMENT_ID /*Added for CBS Changes */;
1443:
1444: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.AGGREGATE_FPR_PERIODS(p_worker_id);');
1445:
1446: commit;
1447:
1448: end AGGREGATE_FPR_PERIODS;

Line 1468: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.AGGREGATE_ACR_PERIODS(p_worker_id);')) then

1464: begin
1465:
1466: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
1467:
1468: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.AGGREGATE_ACR_PERIODS(p_worker_id);')) then
1469: return;
1470: end if;
1471:
1472: insert /*+ append parallel(tmp4_i) */ into PJI_FM_AGGR_ACT4 tmp4_i

Line 2325: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.AGGREGATE_ACR_PERIODS(p_worker_id);');

2321: 'GL', gl_cal.CAL_PERIOD_ID,
2322: 'PA', pa_cal.CAL_PERIOD_ID),
2323: tmp2.TXN_CURRENCY_CODE;
2324:
2325: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.AGGREGATE_ACR_PERIODS(p_worker_id);');
2326:
2327: commit;
2328:
2329: end AGGREGATE_ACR_PERIODS;

Line 2355: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.INSERT_NEW_HEADERS(p_worker_id);')) then

2351: begin
2352:
2353: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
2354:
2355: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.INSERT_NEW_HEADERS(p_worker_id);')) then
2356: return;
2357: end if;
2358:
2359: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

Line 2504: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.INSERT_NEW_HEADERS(p_worker_id);');

2500: tmp6.SYSTEM_LINKAGE_FUNCTION = hdr.SYSTEM_LINKAGE_FUNCTION and
2501: tmp6.NAMED_ROLE = nvl(hdr.NAMED_ROLE,'PJI$NULL')); /* Added for bug 13595112 */
2502:
2503:
2504: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.INSERT_NEW_HEADERS(p_worker_id);');
2505:
2506: commit;
2507:
2508: end INSERT_NEW_HEADERS;

Line 2534: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.BALANCES_INSERT(p_worker_id);')) then

2530: begin
2531:
2532: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
2533:
2534: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.BALANCES_INSERT(p_worker_id);')) then
2535: return;
2536: end if;
2537:
2538: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

Line 2895: --PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.BALANCES_INSERT(p_worker_id);');

2891:
2892: end if;
2893:
2894: -- OLAP
2895: --PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.BALANCES_INSERT(p_worker_id);');
2896:
2897: -- End OLAP
2898: commit;
2899:

Line 3145: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.BALANCES_INSERT(p_worker_id);');

3141:
3142:
3143: end if;
3144:
3145: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.BALANCES_INSERT(p_worker_id);');
3146: commit;
3147: -- End OLAP change
3148: */ -- COMMENTED TO REVERT OLAP CHANGES FOR 15900841
3149:

Line 3176: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.BALANCES_INCR_NEW_PRJ(p_worker_id);')) then

3172: begin
3173:
3174: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
3175:
3176: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.BALANCES_INCR_NEW_PRJ(p_worker_id);')) then
3177: return;
3178: end if;
3179:
3180: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

Line 3346: --PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.BALANCES_INCR_NEW_PRJ(p_worker_id);');

3342: /*
3343: end if;
3344:
3345: -- OLAP
3346: --PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.BALANCES_INCR_NEW_PRJ(p_worker_id);');
3347:
3348: -- End OLAP
3349: commit;
3350:

Line 3404: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.BALANCES_INCR_NEW_PRJ(p_worker_id);');

3400:
3401:
3402: end if;
3403:
3404: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.BALANCES_INCR_NEW_PRJ(p_worker_id);');
3405:
3406: commit;
3407:
3408: -- End OLAP Change

Line 3437: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.BALANCES_INSERT_CMT(p_worker_id);')) then

3433: begin
3434:
3435: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
3436:
3437: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.BALANCES_INSERT_CMT(p_worker_id);')) then
3438: return;
3439: end if;
3440:
3441: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

Line 3588: --PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.BALANCES_INSERT_CMT(p_worker_id);');

3584:
3585: end if;
3586:
3587: -- OLAP
3588: --PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.BALANCES_INSERT_CMT(p_worker_id);');
3589: -- End OLAP
3590:
3591: commit;
3592: /*

Line 3649: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.BALANCES_INSERT_CMT(p_worker_id);');

3645:
3646:
3647: end if;
3648:
3649: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.BALANCES_INSERT_CMT(p_worker_id);');
3650: commit;
3651:
3652: -- End OLAP
3653: */ -- COMMENTED TO REVERT OLAP CHANGES FOR 15900841

Line 3682: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.BALANCES_INCR_NEW_PRJ_CMT(p_worker_id);')) then

3678: begin
3679:
3680: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
3681:
3682: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.BALANCES_INCR_NEW_PRJ_CMT(p_worker_id);')) then
3683: return;
3684: end if;
3685:
3686: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

Line 3829: --PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.BALANCES_INCR_NEW_PRJ_CMT(p_worker_id);');

3825: tmp6.CBS_ELEMENT_ID /* Added for CBS Changes */;
3826: end if;
3827: /*
3828: -- OLAP
3829: --PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.BALANCES_INCR_NEW_PRJ_CMT(p_worker_id);');
3830: -- End OLAP
3831:
3832: commit;
3833:

Line 3887: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.BALANCES_INCR_NEW_PRJ_CMT(p_worker_id);');

3883:
3884: end if;
3885: */
3886: -- COMMENTED TO REVERT OLAP CHANGES FOR 15900841
3887: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.BALANCES_INCR_NEW_PRJ_CMT(p_worker_id);');
3888:
3889:
3890: commit;
3891:

Line 3940: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.FORCE_SUBSEQUENT_RUN(p_worker_id);')) then

3936: --Commenting out this procedure for Bug 8365073. Please check bug for details
3937: /*
3938: l_process := PJI_FM_SUM_MAIN.g_process || p_worker_id;
3939:
3940: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.FORCE_SUBSEQUENT_RUN(p_worker_id);')) then
3941: return;
3942: end if;
3943:
3944: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');

Line 4121: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.FORCE_SUBSEQUENT_RUN(p_worker_id);');

4117:
4118: end if;
4119: */
4120:
4121: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.FORCE_SUBSEQUENT_RUN(p_worker_id);');
4122:
4123: commit;
4124:
4125: end FORCE_SUBSEQUENT_RUN;

Line 4150: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.BALANCES_ROWID_TABLE(p_worker_id);')) then

4146: begin
4147:
4148: l_process := PJI_PJP_SUM_MAIN.g_process || p_worker_id;
4149:
4150: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.BALANCES_ROWID_TABLE(p_worker_id);')) then
4151: return;
4152: end if;
4153:
4154: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 4218: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.BALANCES_ROWID_TABLE(p_worker_id);');

4214: tmp7.RECORD_TYPE = 'M';
4215:
4216: end if;
4217:
4218: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.BALANCES_ROWID_TABLE(p_worker_id);');
4219:
4220: commit;
4221:
4222: end BALANCES_ROWID_TABLE;

Line 4250: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.BALANCES_UPDATE_DELTA(p_worker_id);')) then

4246: begin
4247:
4248: l_process := PJI_PJP_SUM_MAIN.g_process || p_worker_id;
4249:
4250: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.BALANCES_UPDATE_DELTA(p_worker_id);')) then
4251: return;
4252: end if;
4253:
4254: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 4415: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.BALANCES_UPDATE_DELTA(p_worker_id);');

4411: tmp7_r.TXN_ROWID is not null);
4412:
4413: end if;
4414:
4415: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.BALANCES_UPDATE_DELTA(p_worker_id);');
4416:
4417: commit;
4418:
4419: end BALANCES_UPDATE_DELTA;

Line 4449: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.BALANCES_INSERT_DELTA(p_worker_id);')) then

4445: begin
4446:
4447: l_process := PJI_PJP_SUM_MAIN.g_process || p_worker_id;
4448:
4449: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.BALANCES_INSERT_DELTA(p_worker_id);')) then
4450: return;
4451: end if;
4452:
4453: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 4592: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.BALANCES_INSERT_DELTA(p_worker_id);');

4588: tmp7.cbs_element_id;
4589:
4590: end if;
4591:
4592: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.BALANCES_INSERT_DELTA(p_worker_id);');
4593:
4594: commit;
4595:
4596: end BALANCES_INSERT_DELTA;

Line 4621: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.PURGE_INCREMENTAL_BALANCES(p_worker_id);')) then

4617: begin
4618:
4619: l_process := PJI_PJP_SUM_MAIN.g_process || p_worker_id;
4620:
4621: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.PURGE_INCREMENTAL_BALANCES(p_worker_id);')) then
4622: return;
4623: end if;
4624:
4625: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 4636: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.PURGE_INCREMENTAL_BALANCES(p_worker_id);');

4632: where WORKER_ID = p_worker_id);
4633:
4634: end if;
4635:
4636: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.PURGE_INCREMENTAL_BALANCES(p_worker_id);');
4637:
4638: commit;
4639:
4640: end PURGE_INCREMENTAL_BALANCES;

Line 4665: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.PURGE_BALANCES_CMT(p_worker_id);')) then

4661: begin
4662:
4663: l_process := PJI_PJP_SUM_MAIN.g_process || p_worker_id;
4664:
4665: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.PURGE_BALANCES_CMT(p_worker_id);')) then
4666: return;
4667: end if;
4668:
4669: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 4686: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.PURGE_BALANCES_CMT(p_worker_id);');

4682:
4683:
4684: end if;
4685:
4686: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.PURGE_BALANCES_CMT(p_worker_id);');
4687:
4688: commit;
4689:
4690: end PURGE_BALANCES_CMT;

Line 4720: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.BALANCES_INSERT_DELTA_CMT(p_worker_id);')) then

4716: begin
4717:
4718: l_process := PJI_PJP_SUM_MAIN.g_process || p_worker_id;
4719:
4720: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.BALANCES_INSERT_DELTA_CMT(p_worker_id);')) then
4721: return;
4722: end if;
4723:
4724: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 4835: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.BALANCES_INSERT_DELTA_CMT(p_worker_id);');

4831: tmp7.cbs_element_id;
4832:
4833: end if;
4834:
4835: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.BALANCES_INSERT_DELTA_CMT(p_worker_id);');
4836:
4837: commit;
4838:
4839: end BALANCES_INSERT_DELTA_CMT;

Line 4864: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.ACT_ROWID_TABLE(p_worker_id);')) then

4860: begin
4861:
4862: l_process := PJI_PJP_SUM_MAIN.g_process || p_worker_id;
4863:
4864: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.ACT_ROWID_TABLE(p_worker_id);')) then
4865: return;
4866: end if;
4867:
4868: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 4885: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.ACT_ROWID_TABLE(p_worker_id);');

4881: where
4882: map.WORKER_ID = p_worker_id and
4883: act4.PROJECT_ID = map.PROJECT_ID;
4884:
4885: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.ACT_ROWID_TABLE(p_worker_id);');
4886:
4887: commit;
4888:
4889: end ACT_ROWID_TABLE;

Line 4914: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.PURGE_BALANCES_ACT(p_worker_id);')) then

4910: begin
4911:
4912: l_process := PJI_PJP_SUM_MAIN.g_process || p_worker_id;
4913:
4914: if (not PJI_PROCESS_UTIL.NEED_TO_RUN_STEP(l_process, 'PJI_FM_SUM_PSI.PURGE_BALANCES_ACT(p_worker_id);')) then
4915: return;
4916: end if;
4917:
4918: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER(l_process, 'EXTRACTION_TYPE');

Line 4932: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.PURGE_BALANCES_ACT(p_worker_id);');

4928: where WORKER_ID = p_worker_id);
4929:
4930: end if;
4931:
4932: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION(l_process, 'PJI_FM_SUM_PSI.PURGE_BALANCES_ACT(p_worker_id);');
4933:
4934: commit;
4935:
4936: end PURGE_BALANCES_ACT;

Line 4978: end PJI_FM_SUM_PSI;

4974: null);
4975:
4976: end CLEANUP;
4977:
4978: end PJI_FM_SUM_PSI;