[Home] [Help]
303: l_person_id ben_person_actions.person_id%type;
304: l_person_action_id ben_person_actions.person_action_id%type;
305: l_object_version_number ben_person_actions.object_version_number%type;
306: l_ler_id ben_person_actions.ler_id%type;
307: l_range_id ben_batch_ranges.range_id%type;
308: l_record_number number := 0;
309: l_start_person_action_id number := 0;
310: l_end_person_action_id number := 0;
311: l_actn varchar2(80);
319: Cursor c_range_thread is
320: Select ran.range_id
321: ,ran.starting_person_action_id
322: ,ran.ending_person_action_id
323: From ben_batch_ranges ran
324: Where ran.range_status_cd = 'U'
325: And ran.BENEFIT_ACTION_ID = P_BENEFIT_ACTION_ID
326: And rownum < 2
327: For update of ran.range_status_cd
432: exit when c_range_thread%notfound;
433: close c_range_thread;
434: If(l_range_id is not NULL) then
435: --
436: l_actn := 'Updating ben_batch_ranges row...';
437: --
438: update ben_batch_ranges ran set ran.range_status_cd = 'P'
439: where ran.range_id = l_range_id;
440: commit;
434: If(l_range_id is not NULL) then
435: --
436: l_actn := 'Updating ben_batch_ranges row...';
437: --
438: update ben_batch_ranges ran set ran.range_status_cd = 'P'
439: where ran.range_id = l_range_id;
440: commit;
441: End if;
442: --
758: l_object_version_number ben_benefit_actions.object_version_number%type;
759: l_person_id /*per_people_f*/ per_all_people_f.person_id%type;
760: l_person_action_id ben_person_actions.person_action_id%type;
761: l_ler_id ben_ler_f.ler_id%type;
762: l_range_id ben_batch_ranges.range_id%type;
763: l_chunk_size number := 20;
764: l_threads number := 1;
765: l_start_person_action_id number := 0;
766: l_end_person_action_id number := 0;
870: ,p_program_update_date => sysdate
871: );
872: benutils.g_benefit_action_id := l_benefit_action_id;
873: --
874: -- Delete/clear ranges from ben_batch_ranges table
875: --
876: l_actn := 'Delete rows from ben_batch_ranges..';
877: Delete from ben_batch_ranges
878: Where benefit_action_id = l_benefit_action_id;
872: benutils.g_benefit_action_id := l_benefit_action_id;
873: --
874: -- Delete/clear ranges from ben_batch_ranges table
875: --
876: l_actn := 'Delete rows from ben_batch_ranges..';
877: Delete from ben_batch_ranges
878: Where benefit_action_id = l_benefit_action_id;
879: --
880: -- Now lets create person actions for all the people we are going to
873: --
874: -- Delete/clear ranges from ben_batch_ranges table
875: --
876: l_actn := 'Delete rows from ben_batch_ranges..';
877: Delete from ben_batch_ranges
878: Where benefit_action_id = l_benefit_action_id;
879: --
880: -- Now lets create person actions for all the people we are going to
881: -- process in the BENEADEB run.
935: If l_num_row = l_chunk_size then
936: --
937: -- Create a range of data to be multithreaded.
938: --
939: l_actn := 'Calling Ben_batch_ranges_api.create_batch_ranges(in)...';
940: Ben_batch_ranges_api.create_batch_ranges
941: (p_validate => false
942: ,p_benefit_action_id => l_benefit_action_id
943: ,p_range_id => l_range_id
936: --
937: -- Create a range of data to be multithreaded.
938: --
939: l_actn := 'Calling Ben_batch_ranges_api.create_batch_ranges(in)...';
940: Ben_batch_ranges_api.create_batch_ranges
941: (p_validate => false
942: ,p_benefit_action_id => l_benefit_action_id
943: ,p_range_id => l_range_id
944: ,p_range_status_cd => 'U'
956: End if;
957: End loop;
958: Close c_person;
959: If (l_num_row <> 0) then
960: l_actn := 'Calling Ben_batch_ranges_api.create_batch_ranges(Last)...';
961: Ben_batch_ranges_api.create_batch_ranges
962: (p_validate => false
963: ,p_benefit_action_id => l_benefit_action_id
964: ,p_range_id => l_range_id
957: End loop;
958: Close c_person;
959: If (l_num_row <> 0) then
960: l_actn := 'Calling Ben_batch_ranges_api.create_batch_ranges(Last)...';
961: Ben_batch_ranges_api.create_batch_ranges
962: (p_validate => false
963: ,p_benefit_action_id => l_benefit_action_id
964: ,p_range_id => l_range_id
965: ,p_range_status_cd => 'U'