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
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;
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');
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;
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');
207: end if;
208:
209: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
210:
211: l_extract_commitments := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
212: (PJI_FM_SUM_MAIN.g_process,
213: 'EXTRACT_COMMITMENTS');
214:
215: if (l_extraction_type <> 'FULL' and l_extract_commitments = 'Y') then
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;
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');
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;
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
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;
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
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;
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');
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;
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');
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:
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:
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');
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:
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
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');
3439: end if;
3440:
3441: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
3442:
3443: l_extract_commitments := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
3444: (PJI_FM_SUM_MAIN.g_process,
3445: 'EXTRACT_COMMITMENTS');
3446:
3447: l_last_update_date := sysdate;
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: /*
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
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');
3684: end if;
3685:
3686: l_extraction_type := PJI_UTILS.GET_PARAMETER('EXTRACTION_TYPE');
3687:
3688: l_extract_commitments := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
3689: (PJI_FM_SUM_MAIN.g_process,
3690: 'EXTRACT_COMMITMENTS');
3691:
3692: l_last_update_date := sysdate;
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:
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:
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');
3947: FND_MESSAGE.SET_NAME('PJI', 'PJI_PJP_SUM_NO_SELECTION');
3948:
3949: l_no_selection := FND_MESSAGE.GET;
3950:
3951: l_operating_unit := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
3952: (PJI_FM_SUM_MAIN.g_process, 'PROJECT_OPERATING_UNIT');
3953:
3954: if (nvl(l_operating_unit, -1) = -1) then
3955: l_project_operating_unit_name := l_no_selection;
3960: where ORGANIZATION_ID = l_operating_unit;
3961: end if;
3962: */
3963:
3964: /* 4604355 l_from_project_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
3965: (PJI_FM_SUM_MAIN.g_process, 'FROM_PROJECT_ID');
3966:
3967: if (nvl(l_from_project_id, -1) = -1) then
3968:
3976: where PROJECT_ID = l_from_project_id;
3977:
3978: end if;
3979: 4604355 *//*
3980: l_from_project_num := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
3981: (PJI_FM_SUM_MAIN.g_process, 'FROM_PROJECT');
3982:
3983: if (nvl(l_from_project_num,'PJI$NULL') = 'PJI$NULL') then
3984:
3987:
3988: l_from_project := l_from_project_num;
3989: end if;*/
3990:
3991: /*4604355 l_to_project_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
3992: (PJI_FM_SUM_MAIN.g_process, 'TO_PROJECT_ID');
3993:
3994: if (nvl(l_to_project_id, -1) = -1) then
3995:
4004:
4005: end if;
4006: 4604355 */
4007: /*
4008: l_to_project_num := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
4009: (PJI_FM_SUM_MAIN.g_process, 'TO_PROJECT');
4010:
4011: if (nvl(l_to_project_num, 'PJI$NULL') = 'PJI$NULL') then
4012:
4015: l_to_project := l_to_project_num;
4016:
4017: end if;
4018:
4019: l_plan_type_id := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
4020: (PJI_FM_SUM_MAIN.g_process, 'PLAN_TYPE_ID');
4021:
4022: if (nvl(l_plan_type_id, -1) = -1) then
4023:
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;
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');
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');
4155:
4156: if (l_extraction_type = 'INCREMENTAL') then
4157:
4158: -- Actuals
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;
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');
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');
4255:
4256: l_last_update_date := sysdate;
4257: l_last_updated_by := FND_GLOBAL.USER_ID;
4258: l_last_update_login := FND_GLOBAL.LOGIN_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;
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');
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');
4454:
4455: l_last_update_date := sysdate;
4456: l_last_updated_by := FND_GLOBAL.USER_ID;
4457: l_creation_date := sysdate;
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;
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');
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');
4626:
4627: if (l_extraction_type = 'INCREMENTAL') then
4628:
4629: delete from PJI_FM_AGGR_FIN7
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;
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');
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');
4670:
4671: if (l_extraction_type = 'INCREMENTAL') then
4672:
4673: delete
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;
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');
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');
4725:
4726: l_last_update_date := sysdate;
4727: l_last_updated_by := FND_GLOBAL.USER_ID;
4728: l_creation_date := sysdate;
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;
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');
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');
4869:
4870: insert into PJI_PJP_RMAP_ACR psi_i
4871: (
4872: 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;
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');
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');
4919:
4920: if (l_extraction_type = 'FULL' or
4921: l_extraction_type = 'INCREMENTAL' or
4922: l_extraction_type = 'PARTIAL') then
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;
4952: begin
4953:
4954: l_schema := PJI_UTILS.GET_PJI_SCHEMA_NAME;
4955:
4956: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
4957: 'PJI_FM_AGGR_RES_TYPES',
4958: 'NORMAL',
4959: null);
4960:
4957: 'PJI_FM_AGGR_RES_TYPES',
4958: 'NORMAL',
4959: null);
4960:
4961: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
4962: 'PJI_FM_AGGR_FIN1',
4963: 'NORMAL',
4964: null);
4965:
4962: 'PJI_FM_AGGR_FIN1',
4963: 'NORMAL',
4964: null);
4965:
4966: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
4967: 'PJI_FM_AGGR_FIN2',
4968: 'NORMAL',
4969: null);
4970:
4967: 'PJI_FM_AGGR_FIN2',
4968: 'NORMAL',
4969: null);
4970:
4971: PJI_PROCESS_UTIL.TRUNC_INT_TABLE(l_schema,
4972: 'PJI_FM_AGGR_FIN6',
4973: 'NORMAL',
4974: null);
4975: