[Home] [Help]
100: l_commit number;
101: --
102: Begin
103: --
104: hr_utility.set_location ('Entering '||l_proc,05);
105: --
106: /*
107: l_effective_date:=to_date(p_effective_date,'YYYY/MM/DD HH24:MI:SS');
108: l_effective_date:=to_date(to_char(trunc(l_effective_date),'DD/MM/RRRR'),'DD/MM/RRRR');
181: -- 3) Put each row into the person cache.
182: -- 4) Process the person cache
183: -- 5) Go to number 1 again.
184: --
185: hr_utility.set_location('About to Loop for c_range_thread',38);
186:
187: Loop
188: l_actn := 'Opening c_range thread and fetch range...';
189: open c_range_thread;
209: l_actn := 'Clearing g_cache_person_process cache...';
210: g_cache_person_process.delete;
211: open c_person_thread;
212: l_record_number := 0;
213: hr_utility.set_location('about to loop for c_person_thread',46);
214: Loop
215: --
216: l_actn := 'Loading premium data into g_cache_person_process cache...';
217: --
230: If l_record_number > 0 then
231: --
232: -- Process the rows from the person process cache
233: --
234: hr_utility.set_location('about to Loop thru premiums....',50);
235: For l_cnt in 1..l_record_number loop
236: Begin
237: ben_prem_pl_oipl_monthly.main
238: (p_validate => p_validate
251: Exception
252: When others then
253: g_persons_errored := g_persons_errored + 1;
254: If (g_persons_errored > g_max_errors_allowed) then
255: hr_utility.set_location ('Errors received exceeds max allowed',05);
256: fnd_message.raise_error;
257: End if;
258: End;
259: End loop;
259: End loop;
260: Else
261: --
262: l_actn := 'Erroring out nocopy since not person is found in range...' ;
263: hr_utility.set_location ('BEN_92452_PREM_NOT_IN_RNG',05);
264: fnd_message.set_name('BEN','BEN_92452_PREM_NOT_IN_RNG');
265: fnd_message.set_token('PROC', l_proc);
266: fnd_message.raise_error;
267: End if;
268:
269: benutils.write_table_and_file(p_table => TRUE, p_file => FALSE);
270: End loop;
271:
272: hr_utility.set_location('End of loops',70);
273: benutils.write_table_and_file(p_table => TRUE, p_file => FALSE);
274: --
275: l_actn := 'Calling Log_statistics...';
276: ben_batch_utils.write_logfile(p_num_pers_processed => g_persons_processed
275: l_actn := 'Calling Log_statistics...';
276: ben_batch_utils.write_logfile(p_num_pers_processed => g_persons_processed
277: ,p_num_pers_errored => g_persons_errored
278: );
279: hr_utility.set_location ('Leaving '||l_proc,70);
280: Exception
281: When others then
282: ben_batch_utils.rpt_error(p_proc => l_proc
283: ,p_last_actn => l_actn
286: ben_batch_utils.write_logfile(p_num_pers_processed => g_persons_processed
287: ,p_num_pers_errored => g_persons_errored
288: );
289: benutils.write_table_and_file(p_table => TRUE, p_file => TRUE);
290: hr_utility.set_location ('HR_6153_ALL_PROCEDURE_FAIL',05);
291: fnd_message.set_name('PAY', 'HR_6153_ALL_PROCEDURE_FAIL');
292: fnd_message.set_token('PROCEDURE', l_proc);
293: fnd_message.set_token('STEP',l_actn );
294: fnd_message.raise_error;
359: l_num_row number := 0;
360: l_commit number;
361:
362: Begin
363: hr_utility.set_location ('Entering '||l_proc,10);
364: /*
365: l_effective_date:=to_date(p_effective_date,'YYYY/MM/DD HH24:MI:SS');
366: l_effective_date:=to_date(to_char(trunc(l_effective_date),'DD/MM/RRRR'),'DD/MM/RRRR');
367: --
382: --
383: l_benefit_action_id := p_benefit_action_id;
384:
385: If NOT(p_restart) then
386: hr_utility.set_location('Not a Restart',14);
387: --
388: -- Now lets create person actions for all the people we are going to
389: -- process in the Premium Calculation run.
390: --
396: fetch c_prems into l_prems;
397: Exit when c_prems%notfound;
398: l_cnt := l_cnt + 1;
399: l_actn := 'Calling ben_batch_utils.comp_obj_selection_rule...';
400: hr_utility.set_location('l_actl_prem_id='||to_char(l_prems.actl_prem_id)||
401: ' l_cnt='||to_char(l_cnt),18);
402: --
403: -- if comp_obj_selection_rule is pass, test rule.
404: -- If the rule return 'N' then
428: elsif p_pgm_id is not null and p_pgm_id <> l_pgm_id then
429: rl_ret := 'N';
430: elsif rl_ret = 'Y' and p_comp_selection_rule_id is not null then
431: l_actn := 'found a comp object rule...';
432: hr_utility.set_location('found a comp object rule',22);
433: rl_ret:=ben_maintain_designee_elig.comp_selection_rule(
434: p_person_id => null -- we have no person_id
435: ,p_business_group_id => p_business_group_id
436: ,p_pgm_id => l_pgm_id
453: --
454: -- Store actl_prem_id into person actions table.
455: --
456: If ( not skip) then
457: hr_utility.set_location('not skip...Inserting Ben_person_actions',28);
458: l_actn := 'Inserting Ben_person_actions...';
459: select ben_person_actions_s.nextval
460: into l_person_action_id
461: from sys.dual;
489: --
490: -- Create a range of data to be multithreaded.
491: --
492: l_actn := 'Inserting Ben_batch_ranges.......';
493: hr_utility.set_location('Inserting Ben_batch_ranges',32);
494: -- Select next sequence number for the range
495: --
496: select ben_batch_ranges_s.nextval
497: into l_range_id
519: End if;
520: End if;
521: End loop;
522: Close c_prems;
523: hr_utility.set_location('l_num_row='||to_char(l_num_row),34);
524: If (l_num_row <> 0) then
525: l_actn := 'Inserting Final Ben_batch_ranges...';
526: hr_utility.set_location('Inserting Final Ben_batch_ranges',38);
527:
522: Close c_prems;
523: hr_utility.set_location('l_num_row='||to_char(l_num_row),34);
524: If (l_num_row <> 0) then
525: l_actn := 'Inserting Final Ben_batch_ranges...';
526: hr_utility.set_location('Inserting Final Ben_batch_ranges',38);
527:
528: select ben_batch_ranges_s.nextval
529: into l_range_id
530: from sys.dual;
545: 1);
546: l_num_range := l_num_range + 1;
547: End if;
548: Else
549: hr_utility.set_location('This is a RESTART',42);
550: l_actn := 'Calling Ben_batch_utils.create_restart_person_actions...';
551: Ben_batch_utils.create_restart_person_actions
552: (p_benefit_action_id => p_benefit_action_id
553: ,p_effective_date => l_effective_date
561: commit;
562: --
563: -- Now to multithread the code.
564: --
565: hr_utility.set_location('l_num_range '||to_char(l_num_range),46);
566: If l_num_range > 1 then
567: For l_count in 1..least(p_threads,l_num_range)-1 loop
568: --
569: l_actn := 'Submitting job to con-current manager...';
566: If l_num_range > 1 then
567: For l_count in 1..least(p_threads,l_num_range)-1 loop
568: --
569: l_actn := 'Submitting job to con-current manager...';
570: hr_utility.set_location('Submitting BENPRPLC to con-current manager ',50);
571: -- Conncurrent manage needs the effective date in a varchar form.
572: l_request_id := fnd_request.submit_request
573: (application => 'BEN'
574: ,program => 'BENPRPLC'
591: := l_request_id;
592: End loop;
593: Elsif (l_num_range = 0 ) then
594: l_actn := 'Calling Ben_batch_utils.print_parameters...';
595: hr_utility.set_location('Calling Ben_batch_utils.print_parameters ',56);
596: Ben_batch_utils.print_parameters
597: (p_thread_id => 99
598: ,p_benefit_action_id => l_benefit_action_id
599: ,p_validate => p_validate
627:
628: if (l_num_range <> 0 ) then
629:
630: l_actn := 'Calling do_multithread...';
631: hr_utility.set_location('Calling do_multithread ',60);
632: do_multithread(errbuf => errbuf
633: ,retcode => retcode
634: ,p_validate => p_validate
635: ,p_benefit_action_id => l_benefit_action_id
641: ,p_first_day_of_month => p_first_day_of_month
642: );
643: l_actn := 'Calling ben_batch_utils.check_all_slaves_finished...';
644:
645: hr_utility.set_location('Calling ben_batch_utils.check_all_slaves_finished ',64);
646: ben_batch_utils.check_all_slaves_finished(p_rpt_flag => TRUE);
647: ben_batch_utils.end_process(p_benefit_action_id => l_benefit_action_id
648: ,p_person_selected => l_person_cnt
649: ,p_business_group_id => p_business_group_id
648: ,p_person_selected => l_person_cnt
649: ,p_business_group_id => p_business_group_id
650: ,p_non_person_cd => 'PREM');
651: end if;
652: hr_utility.set_location ('Leaving '||l_proc,99);
653: --
654: Exception
655: when others then
656: ben_batch_utils.rpt_error(p_proc => l_proc
667: ,p_person_selected => l_person_cnt
668: ,p_business_group_id => p_business_group_id
669: ) ;
670: End if;
671: hr_utility.set_location ('HR_6153_ALL_PROCEDURE_FAIL',25);
672: fnd_message.set_name('PAY', 'HR_6153_ALL_PROCEDURE_FAIL');
673: fnd_message.set_token('PROCEDURE', l_proc);
674: fnd_message.set_token('STEP', l_actn );
675: fnd_message.raise_error;