DBA Data[Home] [Help]

APPS.PJI_RM_SUM_AVL dependencies on PJI_RM_RES_BATCH_MAP

Line 4051: FROM PJI_RM_RES_BATCH_MAP

4047: BEGIN
4048:
4049: SELECT COUNT(*)
4050: INTO g_curr_res_left_count
4051: FROM PJI_RM_RES_BATCH_MAP
4052: WHERE worker_status IS NULL
4053: and worker_id IS NULL;
4054:
4055: END CALC_CURR_RES_COUNT;

Line 4423: UPDATE PJI_RM_RES_BATCH_MAP

4419: --Update status table to make sure that any resource
4420: --that was not processed last time is processed this
4421: --time
4422:
4423: UPDATE PJI_RM_RES_BATCH_MAP
4424: SET worker_id = null
4425: WHERE worker_status IS NULL
4426: AND worker_id IS NOT NULL;
4427:

Line 4464: execute immediate ('truncate table ' || PJI_UTILS.get_pji_schema_name || '.PJI_RM_RES_BATCH_MAP');

4460: execute immediate ('truncate table ' || PJI_UTILS.get_pji_schema_name || '.PJI_RM_AGGR_AVL4');
4461:
4462: execute immediate ('truncate table ' || PJI_UTILS.get_pji_schema_name || '.PJI_RM_AGGR_AVL5');
4463:
4464: execute immediate ('truncate table ' || PJI_UTILS.get_pji_schema_name || '.PJI_RM_RES_BATCH_MAP');
4465:
4466: PJI_PROCESS_UTIL.REGISTER_STEP_COMPLETION
4467: (
4468: l_process,

Line 4525: FROM PJI_RM_RES_BATCH_MAP;

4521: --of times the loop should run
4522:
4523: SELECT COUNT(*)
4524: INTO l_count_res_status
4525: FROM PJI_RM_RES_BATCH_MAP;
4526:
4527: FOR i in 1.. l_count_res_status
4528: LOOP
4529: l_try_res_again := 'N';

Line 4530: pji_utils.write2log(p_worker_id || ': R1: Before updating PJI_RM_RES_BATCH_MAP and returning resource id');

4526:
4527: FOR i in 1.. l_count_res_status
4528: LOOP
4529: l_try_res_again := 'N';
4530: pji_utils.write2log(p_worker_id || ': R1: Before updating PJI_RM_RES_BATCH_MAP and returning resource id');
4531: UPDATE PJI_RM_RES_BATCH_MAP
4532: SET worker_id = p_worker_id
4533: WHERE worker_status IS NULL
4534: and worker_id IS NULL

Line 4531: UPDATE PJI_RM_RES_BATCH_MAP

4527: FOR i in 1.. l_count_res_status
4528: LOOP
4529: l_try_res_again := 'N';
4530: pji_utils.write2log(p_worker_id || ': R1: Before updating PJI_RM_RES_BATCH_MAP and returning resource id');
4531: UPDATE PJI_RM_RES_BATCH_MAP
4532: SET worker_id = p_worker_id
4533: WHERE worker_status IS NULL
4534: and worker_id IS NULL
4535: and rownum < 2

Line 4538: pji_utils.write2log(p_worker_id || ': R1: After updating PJI_RM_RES_BATCH_MAP and returning resource id');

4534: and worker_id IS NULL
4535: and rownum < 2
4536: RETURNING person_id
4537: INTO l_person_id;
4538: pji_utils.write2log(p_worker_id || ': R1: After updating PJI_RM_RES_BATCH_MAP and returning resource id');
4539: IF SQL%ROWCOUNT <> 0 THEN
4540: COMMIT;
4541: ELSE
4542: CALC_CURR_RES_COUNT;

Line 4565: UPDATE PJI_RM_RES_BATCH_MAP

4561: );
4562: pji_utils.write2log(p_worker_id || ': R1: After Calculating availability');
4563: IF l_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4564: /*
4565: UPDATE PJI_RM_RES_BATCH_MAP
4566: SET worker_id = null
4567: WHERE person_id = l_person_id;
4568:
4569: COMMIT;

Line 4574: pji_utils.write2log(p_worker_id || ': R1: Before Updating PJI_RM_RES_BATCH_MAP for completion');

4570: */
4571: --Raise the error here
4572: raise RAISE_USER_DEF_EXCEPTION;
4573: ELSE
4574: pji_utils.write2log(p_worker_id || ': R1: Before Updating PJI_RM_RES_BATCH_MAP for completion');
4575: UPDATE PJI_RM_RES_BATCH_MAP
4576: SET worker_status = 'C'
4577: WHERE person_id = l_person_id
4578: and worker_id = p_worker_id;

Line 4575: UPDATE PJI_RM_RES_BATCH_MAP

4571: --Raise the error here
4572: raise RAISE_USER_DEF_EXCEPTION;
4573: ELSE
4574: pji_utils.write2log(p_worker_id || ': R1: Before Updating PJI_RM_RES_BATCH_MAP for completion');
4575: UPDATE PJI_RM_RES_BATCH_MAP
4576: SET worker_status = 'C'
4577: WHERE person_id = l_person_id
4578: and worker_id = p_worker_id;
4579: pji_utils.write2log(p_worker_id || ': R1: After Updating PJI_RM_RES_BATCH_MAP for completion');

Line 4579: pji_utils.write2log(p_worker_id || ': R1: After Updating PJI_RM_RES_BATCH_MAP for completion');

4575: UPDATE PJI_RM_RES_BATCH_MAP
4576: SET worker_status = 'C'
4577: WHERE person_id = l_person_id
4578: and worker_id = p_worker_id;
4579: pji_utils.write2log(p_worker_id || ': R1: After Updating PJI_RM_RES_BATCH_MAP for completion');
4580: COMMIT;
4581: END IF;
4582: END IF;
4583: END LOOP;

Line 4587: from PJI_RM_RES_BATCH_MAP

4583: END LOOP;
4584:
4585: select count(*)
4586: into l_row_count
4587: from PJI_RM_RES_BATCH_MAP
4588: where nvl(WORKER_STATUS, 'X') <> 'C';
4589:
4590: if (l_row_count = 0) then
4591:

Line 4673: FROM PJI_RM_RES_BATCH_MAP;

4669: --of times the loop should run
4670:
4671: SELECT COUNT(*)
4672: INTO l_count_res_status
4673: FROM PJI_RM_RES_BATCH_MAP;
4674:
4675: FOR i in 1.. l_count_res_status
4676: LOOP
4677: l_try_res_again := 'N';

Line 4678: pji_utils.write2log(p_worker_id || ': R2: Before updating PJI_RM_RES_BATCH_MAP and returning resource id');

4674:
4675: FOR i in 1.. l_count_res_status
4676: LOOP
4677: l_try_res_again := 'N';
4678: pji_utils.write2log(p_worker_id || ': R2: Before updating PJI_RM_RES_BATCH_MAP and returning resource id');
4679: UPDATE PJI_RM_RES_BATCH_MAP
4680: SET worker_id = p_worker_id
4681: WHERE worker_status IS NULL
4682: and worker_id IS NULL

Line 4679: UPDATE PJI_RM_RES_BATCH_MAP

4675: FOR i in 1.. l_count_res_status
4676: LOOP
4677: l_try_res_again := 'N';
4678: pji_utils.write2log(p_worker_id || ': R2: Before updating PJI_RM_RES_BATCH_MAP and returning resource id');
4679: UPDATE PJI_RM_RES_BATCH_MAP
4680: SET worker_id = p_worker_id
4681: WHERE worker_status IS NULL
4682: and worker_id IS NULL
4683: and rownum < 2

Line 4686: pji_utils.write2log(p_worker_id || ': R2: After updating PJI_RM_RES_BATCH_MAP and returning resource id');

4682: and worker_id IS NULL
4683: and rownum < 2
4684: RETURNING person_id
4685: INTO l_person_id;
4686: pji_utils.write2log(p_worker_id || ': R2: After updating PJI_RM_RES_BATCH_MAP and returning resource id');
4687: IF SQL%ROWCOUNT <> 0 THEN
4688: COMMIT;
4689: ELSE
4690: CALC_CURR_RES_COUNT;

Line 4713: UPDATE PJI_RM_RES_BATCH_MAP

4709: );
4710: pji_utils.write2log(p_worker_id || ': R2: After Calculating availability');
4711: IF l_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4712: /*
4713: UPDATE PJI_RM_RES_BATCH_MAP
4714: SET worker_id = null
4715: WHERE person_id = l_person_id;
4716:
4717: COMMIT;

Line 4722: pji_utils.write2log(p_worker_id || ': R2: Before Updating PJI_RM_RES_BATCH_MAP for completion');

4718: */
4719: --Raise the error here
4720: raise RAISE_USER_DEF_EXCEPTION;
4721: ELSE
4722: pji_utils.write2log(p_worker_id || ': R2: Before Updating PJI_RM_RES_BATCH_MAP for completion');
4723: UPDATE PJI_RM_RES_BATCH_MAP
4724: SET worker_status = 'C'
4725: WHERE person_id = l_person_id
4726: and worker_id = p_worker_id;

Line 4723: UPDATE PJI_RM_RES_BATCH_MAP

4719: --Raise the error here
4720: raise RAISE_USER_DEF_EXCEPTION;
4721: ELSE
4722: pji_utils.write2log(p_worker_id || ': R2: Before Updating PJI_RM_RES_BATCH_MAP for completion');
4723: UPDATE PJI_RM_RES_BATCH_MAP
4724: SET worker_status = 'C'
4725: WHERE person_id = l_person_id
4726: and worker_id = p_worker_id;
4727: pji_utils.write2log(p_worker_id || ': R2: After Updating PJI_RM_RES_BATCH_MAP for completion');

Line 4727: pji_utils.write2log(p_worker_id || ': R2: After Updating PJI_RM_RES_BATCH_MAP for completion');

4723: UPDATE PJI_RM_RES_BATCH_MAP
4724: SET worker_status = 'C'
4725: WHERE person_id = l_person_id
4726: and worker_id = p_worker_id;
4727: pji_utils.write2log(p_worker_id || ': R2: After Updating PJI_RM_RES_BATCH_MAP for completion');
4728: COMMIT;
4729: END IF;
4730: END IF;
4731: END LOOP;

Line 4735: from PJI_RM_RES_BATCH_MAP

4731: END LOOP;
4732:
4733: select count(*)
4734: into l_row_count
4735: from PJI_RM_RES_BATCH_MAP
4736: where nvl(WORKER_STATUS, 'X') <> 'C';
4737:
4738: if (l_row_count = 0) then
4739:

Line 4811: FROM PJI_RM_RES_BATCH_MAP

4807: --process has run for even one new record, then this update
4808: --should not happen
4809: SELECT count(*)
4810: INTO l_res_process_cnt
4811: FROM PJI_RM_RES_BATCH_MAP
4812: where worker_id IS NOT NULL
4813: AND worker_status IS NOT NULL;
4814:
4815: SELECT count(*)

Line 4817: FROM PJI_RM_RES_BATCH_MAP;

4813: AND worker_status IS NOT NULL;
4814:
4815: SELECT count(*)
4816: INTO l_res_full_cnt
4817: FROM PJI_RM_RES_BATCH_MAP;
4818:
4819: IF (l_res_full_cnt = l_res_process_cnt) THEN
4820:
4821: --update all resources with null values for

Line 4825: UPDATE PJI_RM_RES_BATCH_MAP

4821: --update all resources with null values for
4822: --worker and status to make it available
4823: --for next run with new fact records
4824:
4825: UPDATE PJI_RM_RES_BATCH_MAP
4826: SET worker_id = null,
4827: worker_status = null;
4828: END IF;
4829:

Line 4870: FROM PJI_RM_RES_BATCH_MAP;

4866: END IF;
4867:
4868: SELECT COUNT(*)
4869: INTO l_count_res_status
4870: FROM PJI_RM_RES_BATCH_MAP;
4871:
4872: IF (l_count_res_status = 0) THEN
4873: --If this is the first time program is being run then'
4874: --no data would be present, so insert the resources

Line 4876: INSERT INTO PJI_RM_RES_BATCH_MAP(person_id)

4872: IF (l_count_res_status = 0) THEN
4873: --If this is the first time program is being run then'
4874: --no data would be present, so insert the resources
4875: --one needs to process
4876: INSERT INTO PJI_RM_RES_BATCH_MAP(person_id)
4877: SELECT DISTINCT person_id from PJI_RM_AGGR_RES2;
4878: END IF;
4879:
4880: -- implicit commit

Line 4882: tabname => 'PJI_RM_RES_BATCH_MAP',

4878: END IF;
4879:
4880: -- implicit commit
4881: FND_STATS.GATHER_TABLE_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
4882: tabname => 'PJI_RM_RES_BATCH_MAP',
4883: percent => 10,
4884: degree => BIS_COMMON_PARAMETERS.
4885: GET_DEGREE_OF_PARALLELISM);
4886: -- implicit commit

Line 4888: tabname => 'PJI_RM_RES_BATCH_MAP',

4884: degree => BIS_COMMON_PARAMETERS.
4885: GET_DEGREE_OF_PARALLELISM);
4886: -- implicit commit
4887: FND_STATS.GATHER_COLUMN_STATS(ownname => PJI_UTILS.GET_PJI_SCHEMA_NAME,
4888: tabname => 'PJI_RM_RES_BATCH_MAP',
4889: colname => 'PERSON_ID',
4890: percent => 10,
4891: degree => BIS_COMMON_PARAMETERS.
4892: GET_DEGREE_OF_PARALLELISM);