[Home] [Help]
60: l_assignment_id number;
61: l_actn varchar2(80);
62: value_exception exception ;
63: Begin
64: hr_utility.set_location ('Entering '||l_proc,10);
65: --
66: -- Get assignment ID form per_assignments_f table.
67: --
68: l_actn := 'Opening C1 Assignment cursor...';
93: --
94: If upper(p_return) not in ('Y', 'N') then
95: Raise value_exception ;
96: End if;
97: hr_utility.set_location ('Leaving '||l_proc,10);
98: Exception
99: When ben_batch_utils.g_record_error then
100: p_return := 'N' ;
101: fnd_message.set_name('BEN','BEN_91698_NO_ASSIGNMENT_FND');
144: l_proc varchar2(80) := g_package||'.print_parameters';
145: l_string varchar2(80);
146: l_actn varchar2(80);
147: begin
148: hr_utility.set_location ('Entering '||l_proc,10);
149: ben_batch_utils.write(p_text => 'Runtime Parameters');
150: ben_batch_utils.write(p_text => '------------------');
151: ben_batch_utils.write(p_text => 'Thread ID :'||to_char(p_thread_id));
152: ben_batch_utils.write(p_text => 'Validation Mode :' ||
246: If (nvl(p_audit_log,'xxxx') <> hr_api.g_varchar2) then
247: ben_batch_utils.write(p_text => 'Audit log flag :'||
248: hr_general.decode_lookup('YES_NO',p_audit_log));
249: End if;
250: hr_utility.set_location ('Leaving '||l_proc,10);
251: exception
252: when others then
253: ben_batch_utils.rpt_error(p_proc => l_proc
254: ,p_last_actn => l_actn );
368: l_err_message varchar2(2000);
369: l_commit number;
370: Begin
371: --
372: hr_utility.set_location('Entering '||l_proc, 1);
373: /*
374: l_effective_date := to_date(p_effective_date
375: ,'YYYY/MM/DD HH24:MI:SS');
376: --
440: --
441: delete from ben_batch_ranges
442: where benefit_action_id = l_benefit_action_id;
443:
444: hr_utility.set_location ('Before c_person',11);
445: for l_rec in c_person
446: loop
447: --
448: hr_utility.set_location (' c_person',11);
444: hr_utility.set_location ('Before c_person',11);
445: for l_rec in c_person
446: loop
447: --
448: hr_utility.set_location (' c_person',11);
449: -- set variables for this iteration
450: --
451: l_person_ok := 'Y';
452: --
558: -- for restarting.
559: --
560: l_benefit_action_id := p_benefit_action_id;
561: --
562: hr_utility.set_location('Restarting for benefit action id : ' ||
563: to_char(l_benefit_action_id), 10);
564: ben_batch_utils.create_restart_person_actions
565: (p_benefit_action_id => p_benefit_action_id
566: ,p_effective_date => l_effective_date
577: -- that got created.
578: --
579: if l_num_ranges > 1 then
580: --
581: hr_utility.set_location('More than one range got created.', 10);
582: --
583: --
584: -- Set the number of threads to the lesser of the defined number of threads
585: -- and the number of ranges created above. There's no point in submitting
593: -- We are subtracting one from the number of threads because the main
594: -- process will act as the last thread and will be able to keep track of
595: -- the child requests that get submitted.
596: --
597: hr_utility.set_location('Submitting request ' || l_count, 10);
598: --
599: l_request_id := fnd_request.submit_request
600: (application => 'BEN'
601: ,program => 'BENPRTRD'
652: end if;
653: --
654: -- Carry on with the master. This will ensure that the master finishes last.
655: --
656: hr_utility.set_location('Submitting the master process', 10);
657: --
658: do_multithread
659: (errbuf => errbuf
660: ,retcode => retcode
740: (p_benefit_action_id => l_benefit_action_id
741: ,p_person_selected => l_person_actn_cnt
742: ,p_business_group_id => p_business_group_id);
743: --
744: hr_utility.set_location ('Leaving ' || l_proc, 10);
745: --
746: commit;
747: --
748: exception
865: -- end bug 3079317
866:
867: begin
868: --
869: hr_utility.set_location ('Entering '||l_proc,10);
870: --
871: /*
872: l_effective_date := to_date(p_effective_date,'YYYY/MM/DD HH24:MI:SS');
873: l_effective_date := to_date(to_char(trunc(l_effective_date),'DD/MM/RRRR')
973: update ben_batch_ranges ran
974: set ran.range_status_cd = 'P'
975: where ran.range_id = l_range_id;
976: --
977: hr_utility.set_location('Updated range ' || to_char(l_range_id) ||
978: ' status code to P', 10);
979: --
980: commit;
981: --
986: open c_person_thread;
987: --
988: l_record_number := 0;
989: --
990: hr_utility.set_location('Load person actions into the cache', 10);
991: --
992: loop
993: --
994: fetch c_person_thread into
1017: --
1018: for l_cnt in 1..l_record_number
1019: loop
1020: --
1021: hr_utility.set_location('Purge rows for ' ||
1022: to_char(g_cache_per_proc(l_cnt).person_id), 10);
1023: --
1024: begin
1025: --
1077: end loop;
1078: --
1079: else
1080: --
1081: hr_utility.set_location('No records found. Erroring out.', 10);
1082: --
1083: l_actn := 'Reporting error since there is no record found';
1084: --
1085: fnd_message.set_name('BEN','BEN_91906_PER_NOT_FND_IN_RNG');
1129: --
1130: ben_batch_utils.write_logfile(p_num_pers_processed => g_persons_procd
1131: ,p_num_pers_errored => g_persons_errored);
1132: --
1133: hr_utility.set_location ('Leaving '||l_proc,70);
1134: --
1135: exception
1136: --
1137: when others then
1138: --
1139: rollback;
1140: benutils.write(p_text => sqlerrm);
1141: --
1142: hr_utility.set_location('BENPRBCK Super Error ' || l_proc, 10);
1143: --
1144: ben_batch_utils.rpt_error(p_proc => l_proc
1145: ,p_last_actn => l_actn
1146: ,p_rpt_flag => TRUE);
1200: l_proc varchar2(80) := g_package||'.restart';
1201: --
1202: begin
1203: --
1204: hr_utility.set_location ('Entering '||l_proc,10);
1205: --
1206: -- get the parameters for a previous run and do a restart
1207: --
1208: open c_parameters;
1241: ,p_bckt_stat_cd => l_parameters.PTNL_LER_FOR_PER_STAT_CD
1242: ,p_audit_log_flag => l_parameters.audit_log_flag
1243: );
1244: --
1245: hr_utility.set_location ('Leaving '||l_proc,70);
1246: --
1247: end restart;
1248: --
1249: procedure purge_single_person
1314: t_rslt per_in_tab;
1315:
1316: Begin
1317: --
1318: --hr_utility.trace_on(null,'ORACLE');
1319: hr_utility.set_location('Entering purge_single_person',1);
1320: l_from_ocrd_date := nvl(p_from_ocrd_date, to_date('01/01/1900','dd/mm/yyyy'));
1321: --
1322: open c_per_in_ler_1;
1315:
1316: Begin
1317: --
1318: --hr_utility.trace_on(null,'ORACLE');
1319: hr_utility.set_location('Entering purge_single_person',1);
1320: l_from_ocrd_date := nvl(p_from_ocrd_date, to_date('01/01/1900','dd/mm/yyyy'));
1321: --
1322: open c_per_in_ler_1;
1323: fetch c_per_in_ler_1 bulk collect into t_per_in_ler;
1331: else
1332: t_per_in_ler2 := t_per_in_ler;
1333: end if;
1334: --
1335: hr_utility.set_location('delete elig per',2);
1336: if t_per_in_ler.count > 0 then
1337: --
1338: forall i in 1..t_per_in_ler.last
1339: --
1347: g_elig_per_rows := g_elig_per_rows + sql%rowcount;
1348: --
1349: end if;
1350: --
1351: hr_utility.set_location('delete elig per',3);
1352: if t_per_in_ler2.count > 0 then
1353: --
1354: -- added here during bug fix 3670708
1355: forall i in 1..t_per_in_ler2.last
1374:
1375: -- delete all the rows related to elig per elctbl choice for the voided life event
1376: if t_elctbl_chc.count > 0 then
1377: --
1378: hr_utility.set_location('delete enrt rt',1);
1379: forall i in 1..t_elctbl_chc.last
1380: delete from ben_enrt_rt
1381: where elig_per_elctbl_chc_id = t_elctbl_chc(i);
1382: g_enrt_rt_rows := g_enrt_rt_rows + sql%rowcount;
1519: end if;
1520: --
1521: commit;
1522: --
1523: hr_utility.set_location('Leaving purge_single_person',100);
1524: end ;
1525:
1526: end ben_purge_bckdt_voided;