[Home] [Help]
1514: l_person_id ben_person_actions.person_id%type;
1515: l_person_action_id ben_person_actions.person_action_id%type;
1516: l_object_version_number ben_person_actions.object_version_number%type;
1517: l_ler_id ben_person_actions.ler_id%type;
1518: l_range_id ben_batch_ranges.range_id%type;
1519: l_record_number number := 0;
1520: l_start_person_action_id number := 0;
1521: l_end_person_action_id number := 0;
1522: l_actn varchar2(80);
1531: is
1532: select ran.range_id
1533: ,ran.starting_person_action_id
1534: ,ran.ending_person_action_id
1535: from ben_batch_ranges ran
1536: where ran.range_status_cd = 'U'
1537: and ran.benefit_action_id = p_benefit_action_id
1538: and rownum < 2
1539: for update of ran.range_status_cd;
1644: --
1645: end if;
1646: --
1647: -- The processing for this thread is as follows:
1648: -- 1) Lock the rows in ben_batch_ranges that are not processed.
1649: -- 2) Fetch the start and ending person action id for the range.
1650: -- 3) Loop through the person actions in the range and close unresolved
1651: -- action items for each.
1652: -- 4) Go to number 1 again and repeat until all ranges are processed.
1664: end if;
1665: --
1666: close c_range_thread;
1667: --
1668: update ben_batch_ranges ran
1669: set ran.range_status_cd = 'P'
1670: where ran.range_id = l_range_id;
1671: --
1672: commit;
2064: --
2065: -- The number of person actions that got created equals the chunk
2066: -- size. Create a batch range for the person actions.
2067: --
2068: ben_batch_ranges_api.create_batch_ranges
2069: (p_validate => FALSE
2070: ,p_effective_date => l_effective_date
2071: ,p_benefit_action_id => l_benefit_action_id
2072: ,p_range_id => l_range_id
2092: if l_person_actn_cnt > 0 and
2093: mod(l_person_actn_cnt, l_chunk_size) <> 0
2094: then
2095: --
2096: ben_batch_ranges_api.create_batch_ranges
2097: (p_validate => FALSE
2098: ,p_effective_date => l_effective_date
2099: ,p_benefit_action_id => l_benefit_action_id
2100: ,p_range_id => l_range_id