863:
864: PROCEDURE WRITE (p_string IN VARCHAR2)
865: IS
866: BEGIN
867: ben_batch_utils.WRITE (p_string);
868: END;
869:
870: --
871: -- ============================================================================
2726: p_pay_proposal_id := l_pay_proposal_id;
2727: p_element_entry_value_id := l_ELEMENT_ENTRY_VALUE_ID;
2728: write('Finished delete_elements_and_salary routine...');
2729: IF(p_warning) THEN
2730: RAISE ben_batch_utils.g_record_error;
2731: WRITE('Raising error in delete_elements_and_salary');
2732: END IF;
2733:
2734: exception
3232: OR l_promo_error)
3233: THEN
3234: l_error := TRUE;
3235: g_person_errored := TRUE;
3236: RAISE ben_batch_utils.g_record_error;
3237: END IF;
3238:
3239: process_life_event(p_person_id
3240: , p_lf_evt_ocrd_date
3773: g_cache_cwb_sum_person (p_person_id).status := 'SC';
3774: END IF;
3775: ELSE
3776: g_cache_cwb_sum_person (p_person_id).status := 'E';
3777: -- RAISE ben_batch_utils.g_record_error;
3778: END IF;
3779: END IF;
3780:
3781: else
3860: WRITE('Error at Process Person');
3861: ROLLBACK TO backout_post_process_person;
3862:
3863: g_persons_errored := g_persons_errored + 1;
3864: ben_batch_utils.rpt_error (p_proc => g_proc, p_last_actn => g_actn, p_rpt_flag => TRUE);
3865:
3866: IF p_person_action_id IS NOT NULL
3867: THEN
3868: ben_person_actions_api.update_person_actions
3880: END IF;
3881: WRITE (benutils.get_message_name);
3882: WRITE (fnd_message.get);
3883: WRITE (SQLERRM||' in process_person');
3884: RAISE ben_batch_utils.g_record_error;
3885: END;
3886:
3887:
3888: -- ============================================================================
4061: THEN
4062: g_actn := '<
4063: WRITE (g_actn);
4064: fnd_message.set_name ('BEN', 'BEN_93145_MAX_LIMIT_REACHED');
4065: -- removed RAISE ben_batch_utils.g_record_error;
4066: raise g_max_error;
4067: END IF;
4068:
4069: NULL;
4231: IF l_comp_reason_count > 0 THEN
4232: l_process_compents := 'Y';
4233: END IF;
4234:
4235: g_actn := 'Calling ben_batch_utils.ini...';
4236: WRITE (g_actn);
4237: write_h ('ben_batch_utils.ini with PROC_INFO');
4238: ben_batch_utils.ini (p_actn_cd => 'PROC_INFO');
4239: g_actn := 'Calling benutils.get_parameter...';
4233: END IF;
4234:
4235: g_actn := 'Calling ben_batch_utils.ini...';
4236: WRITE (g_actn);
4237: write_h ('ben_batch_utils.ini with PROC_INFO');
4238: ben_batch_utils.ini (p_actn_cd => 'PROC_INFO');
4239: g_actn := 'Calling benutils.get_parameter...';
4240: WRITE (g_actn);
4241: write_h ('benutils.get_parameter with ' || p_bg_id || ' ' || 'BENCWBBP' || ' '
4234:
4235: g_actn := 'Calling ben_batch_utils.ini...';
4236: WRITE (g_actn);
4237: write_h ('ben_batch_utils.ini with PROC_INFO');
4238: ben_batch_utils.ini (p_actn_cd => 'PROC_INFO');
4239: g_actn := 'Calling benutils.get_parameter...';
4240: WRITE (g_actn);
4241: write_h ('benutils.get_parameter with ' || p_bg_id || ' ' || 'BENCWBBP' || ' '
4242: || g_max_errors_allowed
4315:
4316: If p_person_selection_rule_id is not NULL then
4317: --
4318: begin
4319: ben_batch_utils.person_selection_rule
4320: (p_person_id => l_person_id
4321: ,p_business_group_id => pl_rec.business_group_id
4322: ,p_person_selection_rule_id=> p_person_selection_rule_id
4323: ,p_effective_date => l_effective_date
4325: ,p_err_message => l_err_message );
4326:
4327: if l_err_message is not null
4328: then
4329: Ben_batch_utils.write(p_text =>
4330: '<< Person id : '||to_char(l_person_id)||' failed.'||
4331: ' Reason : '|| l_err_message ||' >>' );
4332: l_err_message := NULL ;
4333: end if ;
4411:
4412: If p_person_selection_rule_id is not NULL then
4413: --
4414: begin
4415: ben_batch_utils.person_selection_rule
4416: (p_person_id => l_person_id
4417: ,p_business_group_id => ps_rec.business_group_id
4418: ,p_person_selection_rule_id=> p_person_selection_rule_id
4419: ,p_effective_date => l_effective_date
4421: ,p_err_message => l_err_message );
4422:
4423: if l_err_message is not null
4424: then
4425: Ben_batch_utils.write(p_text =>
4426: '<< Person id : '||to_char(l_person_id)||' failed.'||
4427: ' Reason : '|| l_err_message ||' >>' );
4428: l_err_message := NULL ;
4429: end if ;
4534: g_actn := 'Submitting job to con-current manager...';
4535: WRITE (g_actn);
4536: g_actn := 'Preparing for launching concurrent requests';
4537: WRITE (g_actn);
4538: ben_batch_utils.g_num_processes := 0;
4539: ben_batch_utils.g_processes_tbl.DELETE;
4540:
4541: write_m ('Time before launching the threads '||to_char(sysdate,'yyyy/mm/dd:hh:mi:ssam'));
4542:
4535: WRITE (g_actn);
4536: g_actn := 'Preparing for launching concurrent requests';
4537: WRITE (g_actn);
4538: ben_batch_utils.g_num_processes := 0;
4539: ben_batch_utils.g_processes_tbl.DELETE;
4540:
4541: write_m ('Time before launching the threads '||to_char(sysdate,'yyyy/mm/dd:hh:mi:ssam'));
4542:
4543: IF l_num_ranges > 1
4561: , argument5 => p_audit_log
4562: , argument6 => p_is_self_service
4563: , argument7 => p_is_backout_perf
4564: );
4565: ben_batch_utils.g_num_processes := ben_batch_utils.g_num_processes + 1;
4566: ben_batch_utils.g_processes_tbl (ben_batch_utils.g_num_processes) := l_request_id;
4567: write_m ('request id for this thread ' || l_request_id);
4568: COMMIT;
4569: END LOOP;
4562: , argument6 => p_is_self_service
4563: , argument7 => p_is_backout_perf
4564: );
4565: ben_batch_utils.g_num_processes := ben_batch_utils.g_num_processes + 1;
4566: ben_batch_utils.g_processes_tbl (ben_batch_utils.g_num_processes) := l_request_id;
4567: write_m ('request id for this thread ' || l_request_id);
4568: COMMIT;
4569: END LOOP;
4570: ELSIF l_num_ranges = 0
4591: , p_audit_log => p_audit_log
4592: , p_is_self_service => p_is_self_service
4593: , p_is_backout_perf => p_is_backout_perf
4594: );
4595: g_actn := 'Calling ben_batch_utils.check_all_slaves_finished...';
4596: WRITE (g_actn);
4597:
4598: ben_batch_utils.check_all_slaves_finished (p_rpt_flag => TRUE);
4599:
4594: );
4595: g_actn := 'Calling ben_batch_utils.check_all_slaves_finished...';
4596: WRITE (g_actn);
4597:
4598: ben_batch_utils.check_all_slaves_finished (p_rpt_flag => TRUE);
4599:
4600: IF(p_is_open_access = 'Y') THEN
4601: g_actn := 'Calling process_access...';
4602: WRITE (g_actn);
4626: g_actn := 'Finished Process Procedure...';
4627: WRITE (g_actn);
4628:
4629: BEGIN
4630: For l_count in 1..ben_batch_utils.g_num_processes loop
4631: open c_slaves(ben_batch_utils.g_processes_tbl(l_count));
4632: fetch c_slaves into l_dummy;
4633: If c_slaves%found then
4634: close c_slaves;
4627: WRITE (g_actn);
4628:
4629: BEGIN
4630: For l_count in 1..ben_batch_utils.g_num_processes loop
4631: open c_slaves(ben_batch_utils.g_processes_tbl(l_count));
4632: fetch c_slaves into l_dummy;
4633: If c_slaves%found then
4634: close c_slaves;
4635: raise l_slave_errored;
4651: THEN
4652: WRITE (fnd_message.get);
4653: IF (l_num_ranges > 0) THEN
4654: WRITE('END_PROCESS');
4655: ben_batch_utils.check_all_slaves_finished (p_rpt_flag => TRUE);
4656: end_process (p_benefit_action_id => l_benefit_action_id
4657: , p_person_selected => l_num_persons
4658: , p_business_group_id => p_bg_id
4659: );
4664: WRITE (SQLERRM);
4665: WRITE ('Big Error Occurred');
4666: IF (l_num_ranges > 0) THEN
4667: WRITE('END_PROCESS');
4668: ben_batch_utils.check_all_slaves_finished (p_rpt_flag => TRUE);
4669: end_process (p_benefit_action_id => l_benefit_action_id
4670: , p_person_selected => l_num_persons
4671: , p_business_group_id => p_bg_id
4672: );
4682: WRITE (SQLERRM);
4683: WRITE ('Big Error Occurred');
4684: IF (l_num_ranges > 0) THEN
4685: WRITE('END_PROCESS');
4686: ben_batch_utils.check_all_slaves_finished (p_rpt_flag => TRUE);
4687: end_process (p_benefit_action_id => l_benefit_action_id
4688: , p_person_selected => l_num_persons
4689: , p_business_group_id => p_bg_id
4690: );
4699: WRITE (SQLERRM);
4700: WRITE ('Big Error Occurred');
4701: IF (l_num_ranges > 0) THEN
4702: WRITE('END_PROCESS');
4703: ben_batch_utils.check_all_slaves_finished (p_rpt_flag => TRUE);
4704: end_process (p_benefit_action_id => l_benefit_action_id
4705: , p_person_selected => l_num_persons
4706: , p_business_group_id => p_bg_id
4707: );