[Home] [Help]
298: l_person_id ben_person_actions.person_id%type;
299: l_person_action_id ben_person_actions.person_action_id%type;
300: l_object_version_number ben_person_actions.object_version_number%type;
301: l_ler_id ben_person_actions.ler_id%type;
302: l_range_id ben_batch_ranges.range_id%type;
303: l_record_number number := 0;
304: l_start_person_action_id number := 0;
305: l_end_person_action_id number := 0;
306: l_actn varchar2(80);
314: Cursor c_range_thread is
315: Select ran.range_id
316: ,ran.starting_person_action_id
317: ,ran.ending_person_action_id
318: From ben_batch_ranges ran
319: Where ran.range_status_cd = 'U'
320: And ran.BENEFIT_ACTION_ID = P_BENEFIT_ACTION_ID
321: And rownum < 2
322: For update of ran.range_status_cd
427: exit when c_range_thread%notfound;
428: close c_range_thread;
429: If(l_range_id is not NULL) then
430: --
431: l_actn := 'Updating ben_batch_ranges row...';
432: --
433: update ben_batch_ranges ran set ran.range_status_cd = 'P'
434: where ran.range_id = l_range_id;
435: commit;
429: If(l_range_id is not NULL) then
430: --
431: l_actn := 'Updating ben_batch_ranges row...';
432: --
433: update ben_batch_ranges ran set ran.range_status_cd = 'P'
434: where ran.range_id = l_range_id;
435: commit;
436: End if;
437: --
753: l_object_version_number ben_benefit_actions.object_version_number%type;
754: l_person_id /*per_people_f*/ per_all_people_f.person_id%type;
755: l_person_action_id ben_person_actions.person_action_id%type;
756: l_ler_id ben_ler_f.ler_id%type;
757: l_range_id ben_batch_ranges.range_id%type;
758: l_chunk_size number := 20;
759: l_threads number := 1;
760: l_start_person_action_id number := 0;
761: l_end_person_action_id number := 0;
865: ,p_program_update_date => sysdate
866: );
867: benutils.g_benefit_action_id := l_benefit_action_id;
868: --
869: -- Delete/clear ranges from ben_batch_ranges table
870: --
871: l_actn := 'Delete rows from ben_batch_ranges..';
872: Delete from ben_batch_ranges
873: Where benefit_action_id = l_benefit_action_id;
867: benutils.g_benefit_action_id := l_benefit_action_id;
868: --
869: -- Delete/clear ranges from ben_batch_ranges table
870: --
871: l_actn := 'Delete rows from ben_batch_ranges..';
872: Delete from ben_batch_ranges
873: Where benefit_action_id = l_benefit_action_id;
874: --
875: -- Now lets create person actions for all the people we are going to
868: --
869: -- Delete/clear ranges from ben_batch_ranges table
870: --
871: l_actn := 'Delete rows from ben_batch_ranges..';
872: Delete from ben_batch_ranges
873: Where benefit_action_id = l_benefit_action_id;
874: --
875: -- Now lets create person actions for all the people we are going to
876: -- process in the BENEADEB run.
930: If l_num_row = l_chunk_size then
931: --
932: -- Create a range of data to be multithreaded.
933: --
934: l_actn := 'Calling Ben_batch_ranges_api.create_batch_ranges(in)...';
935: Ben_batch_ranges_api.create_batch_ranges
936: (p_validate => false
937: ,p_benefit_action_id => l_benefit_action_id
938: ,p_range_id => l_range_id
931: --
932: -- Create a range of data to be multithreaded.
933: --
934: l_actn := 'Calling Ben_batch_ranges_api.create_batch_ranges(in)...';
935: Ben_batch_ranges_api.create_batch_ranges
936: (p_validate => false
937: ,p_benefit_action_id => l_benefit_action_id
938: ,p_range_id => l_range_id
939: ,p_range_status_cd => 'U'
951: End if;
952: End loop;
953: Close c_person;
954: If (l_num_row <> 0) then
955: l_actn := 'Calling Ben_batch_ranges_api.create_batch_ranges(Last)...';
956: Ben_batch_ranges_api.create_batch_ranges
957: (p_validate => false
958: ,p_benefit_action_id => l_benefit_action_id
959: ,p_range_id => l_range_id
952: End loop;
953: Close c_person;
954: If (l_num_row <> 0) then
955: l_actn := 'Calling Ben_batch_ranges_api.create_batch_ranges(Last)...';
956: Ben_batch_ranges_api.create_batch_ranges
957: (p_validate => false
958: ,p_benefit_action_id => l_benefit_action_id
959: ,p_range_id => l_range_id
960: ,p_range_status_cd => 'U'