DBA Data[Home] [Help]

APPS.PQP_NL_PGGM_PENSION_EXTRACTS dependencies on BEN_EXT_THREAD

Line 28: WHERE dfn.ext_dfn_id = Ben_Ext_Thread.g_ext_dfn_id

24: rcd.rcd_type_cd
25: FROM ben_ext_rcd rcd
26: ,ben_ext_rcd_in_file rin
27: ,ben_ext_dfn dfn
28: WHERE dfn.ext_dfn_id = Ben_Ext_Thread.g_ext_dfn_id
29: AND rin.ext_file_id = dfn.ext_file_id
30: AND rin.ext_rcd_id = rcd.ext_rcd_id
31: ORDER BY rin.seq_num;
32:

Line 131: WHERE dfn.ext_dfn_id = Ben_Ext_Thread.g_ext_dfn_id -- The extract executing currently

127: SELECT rcd.ext_rcd_id
128: FROM ben_ext_rcd rcd
129: ,ben_ext_rcd_in_file rin
130: ,ben_ext_dfn dfn
131: WHERE dfn.ext_dfn_id = Ben_Ext_Thread.g_ext_dfn_id -- The extract executing currently
132: AND rin.ext_file_id = dfn.ext_file_id
133: AND rin.ext_rcd_id = rcd.ext_rcd_id
134: AND rin.seq_num = c_seq;
135:

Line 146: WHERE dfn.ext_dfn_id = Ben_Ext_Thread.g_ext_dfn_id -- The extract

142: SELECT rcd.ext_rcd_id
143: FROM ben_ext_rcd rcd
144: ,ben_ext_rcd_in_file rin
145: ,ben_ext_dfn dfn
146: WHERE dfn.ext_dfn_id = Ben_Ext_Thread.g_ext_dfn_id -- The extract
147: AND rin.ext_file_id = dfn.ext_file_id
148: AND rin.hide_flag = c_hide_flag -- Y=Hidden, N=Not Hidden
149: AND rin.ext_rcd_id = rcd.ext_rcd_id
150: AND rcd.rcd_type_cd = c_rcd_type_cd; -- D=Detail,H=Header,F=Footer

Line 160: WHERE dfn.ext_dfn_id = Ben_Ext_Thread.g_ext_dfn_id

156: SELECT rcd.ext_rcd_id
157: FROM ben_ext_rcd rcd
158: ,ben_ext_rcd_in_file rin
159: ,ben_ext_dfn dfn
160: WHERE dfn.ext_dfn_id = Ben_Ext_Thread.g_ext_dfn_id
161: AND rin.ext_file_id = dfn.ext_file_id
162: AND rin.ext_rcd_id = rcd.ext_rcd_id
163: AND rcd.rcd_type_cd = c_rcd_type_cd
164: ORDER BY rin.seq_num;

Line 394: l_ext_rslt_id := Ben_Ext_Thread.g_ext_rslt_id;

390: e_extract_process_not_running EXCEPTION;
391: PRAGMA EXCEPTION_INIT(e_extract_process_not_running,-8002);
392: l_ext_rslt_id Number;
393: BEGIN
394: l_ext_rslt_id := Ben_Ext_Thread.g_ext_rslt_id;
395: RETURN l_ext_rslt_id;
396: EXCEPTION
397: WHEN e_extract_process_not_running THEN
398: RETURN -1;

Line 1328: ,p_param1_value => to_char(nvl(ben_ext_thread.g_ext_dfn_id, -1))

1324: ,p_organization_id => p_organization_id
1325: ,p_business_group_id => g_business_group_id
1326: ,p_jurisdiction_code => null
1327: ,p_param1 => 'EXT_DFN_ID'
1328: ,p_param1_value => to_char(nvl(ben_ext_thread.g_ext_dfn_id, -1))
1329: ,p_param2 => 'EXT_RSLT_ID'
1330: ,p_param2_value => to_char(nvl(ben_ext_thread.g_ext_rslt_id, -1))
1331: ,p_param3 => 'EXT_PERSON_ID'
1332: ,p_param3_value => to_char(nvl(ben_ext_person.g_person_id, -1))

Line 1330: ,p_param2_value => to_char(nvl(ben_ext_thread.g_ext_rslt_id, -1))

1326: ,p_jurisdiction_code => null
1327: ,p_param1 => 'EXT_DFN_ID'
1328: ,p_param1_value => to_char(nvl(ben_ext_thread.g_ext_dfn_id, -1))
1329: ,p_param2 => 'EXT_RSLT_ID'
1330: ,p_param2_value => to_char(nvl(ben_ext_thread.g_ext_rslt_id, -1))
1331: ,p_param3 => 'EXT_PERSON_ID'
1332: ,p_param3_value => to_char(nvl(ben_ext_person.g_person_id, -1))
1333: ,p_param4 => 'EXT_PROCESS_BUSINESS_GROUP'
1334: ,p_param4_value => to_char(g_business_group_id)

Line 1483: l_ext_rslt_id := Ben_Ext_Thread.g_ext_rslt_id;

1479:
1480: BEGIN
1481: Hr_Utility.set_location('Entering: '||l_proc_name, 5);
1482: bg_id := p_business_group_id;
1483: l_ext_rslt_id := Ben_Ext_Thread.g_ext_rslt_id;
1484: l_ext_dfn_id := Ben_Ext_Thread.g_ext_dfn_id;
1485:
1486: -- Get the Conc. request id
1487: OPEN csr_req_id(c_ext_rslt_id => l_ext_rslt_id

Line 1484: l_ext_dfn_id := Ben_Ext_Thread.g_ext_dfn_id;

1480: BEGIN
1481: Hr_Utility.set_location('Entering: '||l_proc_name, 5);
1482: bg_id := p_business_group_id;
1483: l_ext_rslt_id := Ben_Ext_Thread.g_ext_rslt_id;
1484: l_ext_dfn_id := Ben_Ext_Thread.g_ext_dfn_id;
1485:
1486: -- Get the Conc. request id
1487: OPEN csr_req_id(c_ext_rslt_id => l_ext_rslt_id
1488: ,c_ext_dfn_id => l_ext_dfn_id

Line 1507: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id

1503: l_record_num := g_ext_rcds(l_ext_rcd_id).record_number;
1504: Hr_Utility.set_location('l_record_num: '||l_record_num, 5);
1505: OPEN csr_rslt_dtl
1506: (c_person_id => p_person_id
1507: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id
1508: ,c_ext_dtl_rcd_id => l_ext_rcd_id
1509: );
1510: FETCH csr_rslt_dtl INTO l_main_rec;
1511: l_new_rec :=NULL;

Line 1513: l_new_rec.EXT_RSLT_ID:=Ben_Ext_Thread.g_ext_rslt_id;

1509: );
1510: FETCH csr_rslt_dtl INTO l_main_rec;
1511: l_new_rec :=NULL;
1512: IF csr_rslt_dtl%NOTFOUND THEN
1513: l_new_rec.EXT_RSLT_ID:=Ben_Ext_Thread.g_ext_rslt_id;
1514: l_new_rec.BUSINESS_GROUP_ID:=bg_id;
1515: l_new_rec.EXT_RCD_ID:=l_ext_rcd_id;
1516: l_new_rec.PERSON_ID :=p_person_id;
1517: l_new_rec.val_01 :=l_record_num;

Line 1679: ,c_ext_rslt_id => Ben_Ext_Thread .g_ext_rslt_id

1675: -- Loop through each detail record for the extract
1676: LOOP
1677: OPEN csr_rslt_dtl
1678: (c_person_id => l_person_id
1679: ,c_ext_rslt_id => Ben_Ext_Thread .g_ext_rslt_id
1680: ,c_ext_dtl_rcd_id => csr_rcd_rec.ext_rcd_id
1681: );
1682: FETCH csr_rslt_dtl INTO l_main_rec;
1683: WHILE csr_rslt_dtl%FOUND

Line 1703: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id

1699: -- Loop through each detail record for the extract
1700: LOOP
1701: OPEN csr_rslt_dtl
1702: (c_person_id => l_person_id
1703: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id
1704: ,c_ext_dtl_rcd_id => csr_rcd_rec.ext_rcd_id
1705: );
1706: FETCH csr_rslt_dtl INTO l_main_rec;
1707: WHILE csr_rslt_dtl%FOUND

Line 1867: Ben_Ext_Thread.process

1863: -- Call the actual benefit extract process with the effective date as the
1864: -- extract end date along with the ext def. id and business group id.
1865: --
1866: Hr_Utility.set_location('..Calling Benefit Ext Process'||l_proc_name, 6);
1867: Ben_Ext_Thread.process
1868: (errbuf => l_errbuff,
1869: retcode => l_retcode,
1870: p_benefit_action_id => NULL,
1871: p_ext_dfn_id => p_ext_dfn_id,

Line 1990: WHERE dfn.ext_dfn_id = Ben_Ext_Thread.g_ext_dfn_id

1986: rcd.rcd_type_cd
1987: FROM ben_ext_rcd rcd
1988: ,ben_ext_rcd_in_file rin
1989: ,ben_ext_dfn dfn
1990: WHERE dfn.ext_dfn_id = Ben_Ext_Thread.g_ext_dfn_id
1991: AND rin.ext_file_id = dfn.ext_file_id
1992: AND rin.ext_rcd_id = rcd.ext_rcd_id
1993: ORDER BY rin.seq_num;
1994:

Line 2339: l_ext_rslt_id := Ben_Ext_Thread.g_ext_rslt_id;

2335: Hr_Utility.set_location('Entering: '||l_proc_name, 5);
2336: bg_id := p_business_group_id;
2337: g_ptp_index := 0;
2338: g_retro_ptp_count := 0;
2339: l_ext_rslt_id := Ben_Ext_Thread.g_ext_rslt_id;
2340: l_ext_dfn_id := Ben_Ext_Thread.g_ext_dfn_id;
2341: -- Executed only once during extract run
2342: IF NOT g_extract_params .EXISTS(bg_id) THEN
2343: Hr_Utility.set_location('..Exract Params PL/SQL not populated ' ,7);

Line 2340: l_ext_dfn_id := Ben_Ext_Thread.g_ext_dfn_id;

2336: bg_id := p_business_group_id;
2337: g_ptp_index := 0;
2338: g_retro_ptp_count := 0;
2339: l_ext_rslt_id := Ben_Ext_Thread.g_ext_rslt_id;
2340: l_ext_dfn_id := Ben_Ext_Thread.g_ext_dfn_id;
2341: -- Executed only once during extract run
2342: IF NOT g_extract_params .EXISTS(bg_id) THEN
2343: Hr_Utility.set_location('..Exract Params PL/SQL not populated ' ,7);
2344: -- Get the extract type, Changes extract or Full Profile

Line 5627: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id

5623: CLOSE c_get_rcd_id;
5624:
5625: -- Fetch result dtl record
5626: OPEN csr_rslt_dtl(c_person_id => g_person_id
5627: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id
5628: ,c_ext_dtl_rcd_id => l_rcd_id
5629: );
5630: FETCH csr_rslt_dtl INTO l_main_rec;
5631: CLOSE csr_rslt_dtl;

Line 5749: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id

5745:
5746:
5747: -- Fetch result dtl record
5748: OPEN csr_rslt_dtl(c_person_id => g_person_id
5749: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id
5750: ,c_ext_dtl_rcd_id => l_rcd_id
5751: );
5752:
5753: Hr_Utility.set_location('l_rcd_id'||l_rcd_id,10);

Line 5754: Hr_Utility.set_location('g_ext_rslt_id'||Ben_Ext_Thread.g_ext_rslt_id,10);

5750: ,c_ext_dtl_rcd_id => l_rcd_id
5751: );
5752:
5753: Hr_Utility.set_location('l_rcd_id'||l_rcd_id,10);
5754: Hr_Utility.set_location('g_ext_rslt_id'||Ben_Ext_Thread.g_ext_rslt_id,10);
5755: Hr_Utility.set_location('g_person_id'||g_person_id,10);
5756:
5757: FETCH csr_rslt_dtl INTO l_main_rec;
5758: IF csr_rslt_dtl%FOUND THEN

Line 5947: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id

5943: CLOSE c_get_rcd_id;
5944:
5945: -- Fetch result dtl record
5946: OPEN csr_rslt_dtl(c_person_id => g_person_id
5947: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id
5948: ,c_ext_dtl_rcd_id => l_rcd_id
5949: );
5950: FETCH csr_rslt_dtl INTO l_main_rec;
5951: CLOSE csr_rslt_dtl;

Line 7647: Ben_Ext_Thread.g_err_num := p_error_NUMBER;

7643: Nvl(Ben_Ext_Person.g_elmt_name
7644: ,Ben_Ext_Fmt.g_elmt_name)||'. '||
7645: p_error_text;
7646: ELSE
7647: Ben_Ext_Thread.g_err_num := p_error_NUMBER;
7648: Ben_Ext_Thread.g_err_name := p_error_text;
7649: l_error_text :=
7650: Ben_Ext_Fmt.get_error_msg(To_Number(Substr(p_error_text, 5, 5)),
7651: p_error_text,Nvl(Ben_Ext_Person.g_elmt_name,Ben_Ext_Fmt.g_elmt_name) );

Line 7648: Ben_Ext_Thread.g_err_name := p_error_text;

7644: ,Ben_Ext_Fmt.g_elmt_name)||'. '||
7645: p_error_text;
7646: ELSE
7647: Ben_Ext_Thread.g_err_num := p_error_NUMBER;
7648: Ben_Ext_Thread.g_err_name := p_error_text;
7649: l_error_text :=
7650: Ben_Ext_Fmt.get_error_msg(To_Number(Substr(p_error_text, 5, 5)),
7651: p_error_text,Nvl(Ben_Ext_Person.g_elmt_name,Ben_Ext_Fmt.g_elmt_name) );
7652:

Line 7699: WHERE dtl.ext_rslt_id = Ben_Ext_Thread.g_ext_rslt_id

7695: CURSOR csr_get_record_count(c_record_id IN Number
7696: ,c_org_id IN Number ) IS
7697: SELECT Count(dtl.ext_rslt_dtl_id)
7698: FROM ben_ext_rslt_dtl dtl
7699: WHERE dtl.ext_rslt_id = Ben_Ext_Thread.g_ext_rslt_id
7700: AND ext_rcd_id IN(c_record_id);
7701: --AND val_31=c_org_id;
7702:
7703: l_proc_name Varchar2(150) := g_proc_name ||'.Get_Trailer_Record_Count';

Line 7769: WHERE ext_rslt_id=Ben_Ext_Thread.g_ext_rslt_id

7765: -- Cursor to get the person existence flag
7766: CURSOR csr_get_person_exist(c_org_id IN Number) IS
7767: SELECT 'x'
7768: FROM ben_ext_rslt_dtl
7769: WHERE ext_rslt_id=Ben_Ext_Thread.g_ext_rslt_id
7770: AND val_31=c_org_id;
7771:
7772:
7773: l_ext_dtl_rcd_id ben_ext_rcd.ext_rcd_id%TYPE;

Line 7837: AND ext_rslt_id = Ben_Ext_Thread.g_ext_rslt_id

7833: LOOP
7834: -- Delete all detail records for the record which are hidden
7835: DELETE ben_ext_rslt_dtl
7836: WHERE ext_rcd_id = csr_rcd_rec.ext_rcd_id
7837: AND ext_rslt_id = Ben_Ext_Thread.g_ext_rslt_id
7838: AND business_group_id = p_business_group_id;
7839: END LOOP; -- FOR csr_rcd_rec
7840:
7841: --Fetch the record id from the sequence number

Line 7859: AND ext_rslt_id = Ben_Ext_Thread.g_ext_rslt_id

7855:
7856: --Delete all extra records created by system extract
7857: DELETE ben_ext_rslt_dtl
7858: WHERE ext_rcd_id IN ( l_rcd_id_060,l_rcd_id_080,l_rcd_id_081 )
7859: AND ext_rslt_id = Ben_Ext_Thread.g_ext_rslt_id
7860: AND business_group_id = p_business_group_id
7861: AND val_40='Delete';
7862:
7863:

Line 7867: (c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id )

7863:
7864: -- All orgs,fill up the temp. table with the org ids in order of
7865: --the sort value
7866: FOR val IN csr_get_rslt1
7867: (c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id )
7868: LOOP
7869: hr_utility.set_location('val 32 : '||val.val_32,10);
7870: IF g_org_list.EXISTS(val.val_31) THEN
7871: IF NOT g_ord_details1.EXISTS(val.val_31) THEN

Line 7898: OPEN csr_get_trailer_rslt(c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id

7894: --create our own trailer records for each org based on these
7895: FOR csr_rcd_rec IN csr_ext_rcd_id(c_hide_flag => 'N'
7896: ,c_rcd_type_cd => 'T')-- T-Trailer
7897: LOOP
7898: OPEN csr_get_trailer_rslt(c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id
7899: ,c_ext_dtl_rcd_id => csr_rcd_rec.ext_rcd_id);
7900: FETCH csr_get_trailer_rslt INTO l_trailer_main_rec;
7901: CLOSE csr_get_trailer_rslt;
7902: IF g_rcd_dtls(999).ext_rcd_id = csr_rcd_rec.ext_rcd_id THEN

Line 7914: OPEN csr_get_header_rslt(c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id

7910: FOR csr_rcd_rec IN csr_ext_rcd_id(c_hide_flag => 'N'
7911: ,c_rcd_type_cd => 'H')-- H-Header
7912: LOOP
7913:
7914: OPEN csr_get_header_rslt(c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id
7915: ,c_ext_dtl_rcd_id => csr_rcd_rec.ext_rcd_id
7916: );
7917: FETCH csr_get_header_rslt INTO l_header_main_rec;
7918: CLOSE csr_get_header_rslt;

Line 7943: OPEN csr_get_header_rslt(c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id

7939: --Loop through Header records
7940: FOR csr_rcd_rec IN csr_ext_rcd_id(c_hide_flag => 'N'
7941: ,c_rcd_type_cd => 'H')-- H-Header
7942: LOOP
7943: OPEN csr_get_header_rslt(c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id
7944: ,c_ext_dtl_rcd_id => csr_rcd_rec.ext_rcd_id);
7945: FETCH csr_get_header_rslt INTO l_header_main_rec;
7946: CLOSE csr_get_header_rslt;
7947: l_header_new_rec := l_header_main_rec;

Line 7974: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id )

7970:
7971: -- Get all records for orgid
7972: FOR val IN csr_get_rslt
7973: (c_org_id => g_ord_details(num).gre_org_id
7974: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id )
7975: LOOP
7976: -- Get the individual row using sortid key
7977: -- So we will get only one record related data per person
7978: FOR ind_dtl IN csr_rslt_dtl_sort

Line 7980: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id

7976: -- Get the individual row using sortid key
7977: -- So we will get only one record related data per person
7978: FOR ind_dtl IN csr_rslt_dtl_sort
7979: (c_val_32=> val.val_32
7980: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id
7981: )
7982: LOOP
7983: l_main_rec := ind_dtl;
7984: l_main_rec.object_version_NUMBER := Nvl(l_main_rec.object_version_NUMBER,0) + 1;

Line 8004: OPEN csr_get_trailer_rslt(c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id

8000: FOR csr_rcd_rec IN csr_ext_rcd_id(c_hide_flag => 'N'
8001: ,c_rcd_type_cd => 'T')-- T-Trailer
8002: LOOP
8003: l_insert_trailer := 1;
8004: OPEN csr_get_trailer_rslt(c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id
8005: ,c_ext_dtl_rcd_id => csr_rcd_rec.ext_rcd_id);
8006: FETCH csr_get_trailer_rslt INTO l_trailer_main_rec;
8007: CLOSE csr_get_trailer_rslt;
8008: l_trailer_new_rec := l_trailer_main_rec;

Line 8098: WHERE dtl.ext_rslt_id = Ben_Ext_Thread.g_ext_rslt_id

8094: END IF;
8095:
8096: DELETE
8097: FROM ben_ext_rslt_dtl dtl
8098: WHERE dtl.ext_rslt_id = Ben_Ext_Thread.g_ext_rslt_id
8099: AND dtl.ext_rcd_id = csr_rcd_rec.ext_rcd_id
8100: AND dtl.ext_rslt_dtl_id = l_ext_rslt_dtl_id
8101: AND business_group_id = p_business_group_id;
8102:

Line 8116: WHERE dtl.ext_rslt_id = Ben_Ext_Thread.g_ext_rslt_id

8112: END IF;
8113:
8114: DELETE
8115: FROM ben_ext_rslt_dtl dtl
8116: WHERE dtl.ext_rslt_id = Ben_Ext_Thread.g_ext_rslt_id
8117: AND dtl.ext_rcd_id = csr_rcd_rec.ext_rcd_id
8118: AND dtl.ext_rslt_dtl_id = l_ext_rslt_dtl_id
8119: AND business_group_id = p_business_group_id;
8120: