1: PACKAGE BODY PJI_RM_SUM_AVL AS
2: /* $Header: PJISR04B.pls 120.7 2006/05/03 17:15:08 appldev noship $ */
3:
4: --Defining Global PL/SQL Table variables for bulk insert in PJI_RM_AGGR_AVL3
5: g_exp_organization_id_in_tbl N_TYPE_TAB;
4074:
4075: IF (NOT PJI_PROCESS_UTIL.NEED_TO_RUN_STEP
4076: (
4077: l_process,
4078: 'PJI_RM_SUM_AVL.MERGE_ORG_AVL_DUR(p_worker_id);'
4079: )) THEN
4080: RETURN;
4081: END IF;
4082:
4269:
4270: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION
4271: (
4272: l_process,
4273: 'PJI_RM_SUM_AVL.MERGE_ORG_AVL_DUR(p_worker_id);'
4274: );
4275:
4276: COMMIT;
4277:
4298:
4299: IF (NOT PJI_PROCESS_UTIL.NEED_TO_RUN_STEP
4300: (
4301: l_process,
4302: 'PJI_RM_SUM_AVL.MERGE_CURR_ORG_AVL(p_worker_id);'
4303: )) THEN
4304: RETURN;
4305: END IF;
4306:
4396:
4397: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION
4398: (
4399: l_process,
4400: 'PJI_RM_SUM_AVL.MERGE_CURR_ORG_AVL(p_worker_id);'
4401: );
4402:
4403: COMMIT;
4404:
4445:
4446: IF (NOT PJI_PROCESS_UTIL.NEED_TO_RUN_STEP
4447: (
4448: l_process,
4449: 'PJI_RM_SUM_AVL.RES_CALC_CLEANUP(p_worker_id);'
4450: )) THEN
4451: RETURN;
4452: END IF;
4453:
4465:
4466: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION
4467: (
4468: l_process,
4469: 'PJI_RM_SUM_AVL.RES_CALC_CLEANUP(p_worker_id);'
4470: );
4471: COMMIT;
4472:
4473: END RES_CALC_CLEANUP;
4507:
4508: IF (NOT PJI_PROCESS_UTIL.NEED_TO_RUN_STEP
4509: (
4510: l_process,
4511: 'PJI_RM_SUM_AVL.START_RES_AVL_CALC_R1(p_worker_id);'
4512: )) THEN
4513: RETURN;
4514: END IF;
4515:
4595:
4596: update PJI_SYSTEM_PRC_STATUS
4597: set STEP_STATUS = 'C'
4598: where PROCESS_NAME = PJI_RM_SUM_MAIN.g_process || to_char(x)
4599: and STEP_NAME = 'PJI_RM_SUM_AVL.START_RES_AVL_CALC_R1(p_worker_id);';
4600:
4601: commit;
4602:
4603: end loop;
4606:
4607: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION
4608: (
4609: l_process,
4610: 'PJI_RM_SUM_AVL.START_RES_AVL_CALC_R1(p_worker_id);'
4611: );
4612:
4613: COMMIT;
4614: EXCEPTION
4653:
4654: IF (NOT PJI_PROCESS_UTIL.NEED_TO_RUN_STEP
4655: (
4656: l_process,
4657: 'PJI_RM_SUM_AVL.START_RES_AVL_CALC_R2(p_worker_id);'
4658: )) THEN
4659: RETURN;
4660: END IF;
4661:
4743:
4744: update PJI_SYSTEM_PRC_STATUS
4745: set STEP_STATUS = 'C'
4746: where PROCESS_NAME = PJI_RM_SUM_MAIN.g_process || to_char(x)
4747: and STEP_NAME = 'PJI_RM_SUM_AVL.START_RES_AVL_CALC_R2(p_worker_id);';
4748:
4749: commit;
4750:
4751: end loop;
4754:
4755: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION
4756: (
4757: l_process,
4758: 'PJI_RM_SUM_AVL.START_RES_AVL_CALC_R2(p_worker_id);'
4759: );
4760:
4761: COMMIT;
4762: EXCEPTION
4796:
4797: IF (NOT PJI_PROCESS_UTIL.NEED_TO_RUN_STEP
4798: (
4799: l_process,
4800: 'PJI_RM_SUM_AVL.UPDATE_RES_STA_FOR_RUN2(p_worker_id);'
4801: )) THEN
4802: RETURN;
4803: END IF;
4804:
4829:
4830: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION
4831: (
4832: l_process,
4833: 'PJI_RM_SUM_AVL.UPDATE_RES_STA_FOR_RUN2(p_worker_id);'
4834: );
4835:
4836: COMMIT;
4837:
4859:
4860: IF (NOT PJI_PROCESS_UTIL.NEED_TO_RUN_STEP
4861: (
4862: l_process,
4863: 'PJI_RM_SUM_AVL.INS_INTO_RES_STATUS(p_worker_id);'
4864: )) THEN
4865: RETURN;
4866: END IF;
4867:
4893:
4894: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION
4895: (
4896: l_process,
4897: 'PJI_RM_SUM_AVL.INS_INTO_RES_STATUS(p_worker_id);'
4898: );
4899:
4900: COMMIT;
4901:
4924:
4925: IF (NOT PJI_PROCESS_UTIL.NEED_TO_RUN_STEP
4926: (
4927: l_process,
4928: 'PJI_RM_SUM_AVL.REFRESH_AV_ORGO_F_MV(p_worker_id);'
4929: )) THEN
4930: RETURN;
4931: END IF;
4932: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
4980:
4981: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION
4982: (
4983: l_process,
4984: 'PJI_RM_SUM_AVL.REFRESH_AV_ORGO_F_MV(p_worker_id);'
4985: );
4986:
4987: COMMIT;
4988:
5011:
5012: IF (NOT PJI_PROCESS_UTIL.NEED_TO_RUN_STEP
5013: (
5014: l_process,
5015: 'PJI_RM_SUM_AVL.REFRESH_CA_ORGO_F_MV(p_worker_id);'
5016: )) THEN
5017: RETURN;
5018: END IF;
5019: l_extraction_type := PJI_PROCESS_UTIL.GET_PROCESS_PARAMETER
5062:
5063: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION
5064: (
5065: l_process,
5066: 'PJI_RM_SUM_AVL.REFRESH_CA_ORGO_F_MV(p_worker_id);'
5067: );
5068:
5069: COMMIT;
5070:
5069: COMMIT;
5070:
5071: END REFRESH_CA_ORGO_F_MV;
5072:
5073: END PJI_RM_SUM_AVL;