DBA Data[Home] [Help]

APPS.PQP_US_PENSION_EXTRACTS dependencies on BEN_EXT_THREAD

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

230: SELECT rcd.ext_rcd_id
231: FROM ben_ext_rcd rcd
232: ,ben_ext_rcd_in_file rin
233: ,ben_ext_dfn dfn
234: WHERE dfn.ext_dfn_id = Ben_Ext_Thread.g_ext_dfn_id -- The extract executing currently
235: AND rin.ext_file_id = dfn.ext_file_id
236: AND rin.hide_flag = c_hide_flag -- Y=Hidden, N=Not Hidden
237: AND rin.ext_rcd_id = rcd.ext_rcd_id
238: AND rcd.rcd_type_cd = c_rcd_type_cd; -- D=Detail,H=Header,F=Footer

Line 532: Ben_Ext_Thread.process

528: -- Call the actual benefit extract process with the effective date as the
529: -- extract end date along with the ext def. id and business group id.
530: --
531: Hr_Utility.set_location('..Calling Benefit Ext Process'||l_proc_name, 6);
532: Ben_Ext_Thread.process
533: (errbuf => l_errbuff,
534: retcode => l_retcode,
535: p_benefit_action_id => NULL,
536: p_ext_dfn_id => p_ext_dfn_id,

Line 2274: IF l_err_num >= ben_ext_thread.g_max_errors_allowed THEN

2270: OPEN err_cnt_c;
2271: FETCH err_cnt_c INTO l_err_num;
2272: CLOSE err_cnt_c;
2273: --
2274: IF l_err_num >= ben_ext_thread.g_max_errors_allowed THEN
2275: --
2276: ben_ext_thread.g_err_num := 91947;
2277: ben_ext_thread.g_err_name := 'BEN_91947_EXT_MX_ERR_NUM';
2278: RAISE ben_ext_thread.g_job_failure_error;

Line 2276: ben_ext_thread.g_err_num := 91947;

2272: CLOSE err_cnt_c;
2273: --
2274: IF l_err_num >= ben_ext_thread.g_max_errors_allowed THEN
2275: --
2276: ben_ext_thread.g_err_num := 91947;
2277: ben_ext_thread.g_err_name := 'BEN_91947_EXT_MX_ERR_NUM';
2278: RAISE ben_ext_thread.g_job_failure_error;
2279: --
2280: END IF;

Line 2277: ben_ext_thread.g_err_name := 'BEN_91947_EXT_MX_ERR_NUM';

2273: --
2274: IF l_err_num >= ben_ext_thread.g_max_errors_allowed THEN
2275: --
2276: ben_ext_thread.g_err_num := 91947;
2277: ben_ext_thread.g_err_name := 'BEN_91947_EXT_MX_ERR_NUM';
2278: RAISE ben_ext_thread.g_job_failure_error;
2279: --
2280: END IF;
2281:

Line 2278: RAISE ben_ext_thread.g_job_failure_error;

2274: IF l_err_num >= ben_ext_thread.g_max_errors_allowed THEN
2275: --
2276: ben_ext_thread.g_err_num := 91947;
2277: ben_ext_thread.g_err_name := 'BEN_91947_EXT_MX_ERR_NUM';
2278: RAISE ben_ext_thread.g_job_failure_error;
2279: --
2280: END IF;
2281:
2282: IF g_business_group_id IS NOT NULL THEN

Line 2405: RAISE; -- such that the error processing in ben_ext_thread occurs.

2401: WHEN Others THEN
2402: Fnd_File.put_line(Fnd_File.Log,
2403: 'Error in Advanced Conditions while processing this dynamic sql statement: ');
2404: Fnd_File.put_line(Fnd_File.Log, l_dynamic_condition);
2405: RAISE; -- such that the error processing in ben_ext_thread occurs.
2406: END;
2407: --
2408: IF l_condition = 'T' THEN
2409: IF p_sprs_cd = 'A' THEN

Line 2560: RAISE; -- such that the error processing in ben_ext_thread occurs.

2556: -- this needs replaced with a message for translation.
2557: Fnd_File.put_line(Fnd_File.Log,
2558: 'Error in Advanced Conditions while processing this dynamic sql statement: ');
2559: Fnd_File.put_line(Fnd_File.Log, l_dynamic_condition);
2560: RAISE; -- such that the error processing in ben_ext_thread occurs.
2561: END;
2562: --
2563: --
2564: IF l_condition = 'T' THEN

Line 2887: ,p_param1_value => To_Char(Nvl(Ben_Ext_Thread.g_ext_dfn_id, -1))

2883: ,p_organization_id => p_organization_id
2884: ,p_business_group_id => g_business_group_id
2885: ,p_jurisdiction_code => NULL
2886: ,p_param1 => 'EXT_DFN_ID'
2887: ,p_param1_value => To_Char(Nvl(Ben_Ext_Thread.g_ext_dfn_id, -1))
2888: ,p_param2 => 'EXT_RSLT_ID'
2889: ,p_param2_value => To_Char(Nvl(Ben_Ext_Thread.g_ext_rslt_id, -1))
2890: );
2891: l_ff_value := l_outputs(l_outputs.FIRST).VALUE;

Line 2889: ,p_param2_value => To_Char(Nvl(Ben_Ext_Thread.g_ext_rslt_id, -1))

2885: ,p_jurisdiction_code => NULL
2886: ,p_param1 => 'EXT_DFN_ID'
2887: ,p_param1_value => To_Char(Nvl(Ben_Ext_Thread.g_ext_dfn_id, -1))
2888: ,p_param2 => 'EXT_RSLT_ID'
2889: ,p_param2_value => To_Char(Nvl(Ben_Ext_Thread.g_ext_rslt_id, -1))
2890: );
2891: l_ff_value := l_outputs(l_outputs.FIRST).VALUE;
2892: IF l_ff_value IS NULL THEN
2893: l_ff_value := i.dflt_val;

Line 2958: ,c_ext_dfn_id => Ben_Ext_Thread.g_ext_dfn_id )

2954: END IF;
2955: -- Check the Adv. Conditions for records in file
2956: FOR rif IN csr_xrif
2957: (c_rcd_id => p_rslt_rec.ext_rcd_id
2958: ,c_ext_dfn_id => Ben_Ext_Thread.g_ext_dfn_id )
2959: LOOP
2960: Rcd_In_File
2961: (p_ext_rcd_in_file_id => rif.ext_rcd_in_file_id
2962: ,p_sprs_cd => rif.sprs_cd

Line 2988: OPEN csr_ben (c_ext_dfn_id => Ben_Ext_Thread.g_ext_dfn_id

2984: ,p_val_tab => l_val_tab);
2985: END IF; --IF g_total_dtl_lines
2986: ELSIF l_exclude_this_rcd_flag THEN
2987:
2988: OPEN csr_ben (c_ext_dfn_id => Ben_Ext_Thread.g_ext_dfn_id
2989: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id
2990: ,c_business_group_id => g_business_group_id);
2991: FETCH csr_ben INTO l_ben_params;
2992: CLOSE csr_ben;

Line 2989: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id

2985: END IF; --IF g_total_dtl_lines
2986: ELSIF l_exclude_this_rcd_flag THEN
2987:
2988: OPEN csr_ben (c_ext_dfn_id => Ben_Ext_Thread.g_ext_dfn_id
2989: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id
2990: ,c_business_group_id => g_business_group_id);
2991: FETCH csr_ben INTO l_ben_params;
2992: CLOSE csr_ben;
2993:

Line 3034: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id

3030: LOOP
3031: g_ext_dtl_rcd_id := csr_rcd_rec.ext_rcd_id;
3032: OPEN csr_rslt_dtl
3033: (c_person_id => p_person_id
3034: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id
3035: ,c_ext_dtl_rcd_id => g_ext_dtl_rcd_id
3036: );
3037: FETCH csr_rslt_dtl INTO l_main_rec;
3038: CLOSE csr_rslt_dtl;

Line 3735: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id

3731: FETCH csr_ext_rcd_id INTO g_ext_dtl_rcd_id;
3732: CLOSE csr_ext_rcd_id;
3733: OPEN csr_rslt_dtl
3734: (c_person_id => l_person_id
3735: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id
3736: ,c_ext_dtl_rcd_id => g_ext_dtl_rcd_id
3737: );
3738: FETCH csr_rslt_dtl INTO l_main_rec;
3739: CLOSE csr_rslt_dtl;

Line 5031: l_ext_rslt_id := Ben_Ext_Thread.g_ext_rslt_id;

5027: BEGIN
5028:
5029: Hr_Utility.set_location('Entering: '||l_proc_name, 5);
5030: i := p_business_group_id;
5031: l_ext_rslt_id := Ben_Ext_Thread.g_ext_rslt_id;
5032: l_ext_dfn_id := Ben_Ext_Thread.g_ext_dfn_id;
5033:
5034: IF NOT g_extract_params.EXISTS(i) THEN
5035: Hr_Utility.set_location('..Exract Params PL/SQL not populated ', 7);

Line 5032: l_ext_dfn_id := Ben_Ext_Thread.g_ext_dfn_id;

5028:
5029: Hr_Utility.set_location('Entering: '||l_proc_name, 5);
5030: i := p_business_group_id;
5031: l_ext_rslt_id := Ben_Ext_Thread.g_ext_rslt_id;
5032: l_ext_dfn_id := Ben_Ext_Thread.g_ext_dfn_id;
5033:
5034: IF NOT g_extract_params.EXISTS(i) THEN
5035: Hr_Utility.set_location('..Exract Params PL/SQL not populated ', 7);
5036:

Line 5316: AND ext_rslt_id = Ben_Ext_Thread.g_ext_rslt_id

5312: -- Delete all hidden detail records for the all persons
5313: DELETE
5314: FROM ben_ext_rslt_dtl
5315: WHERE ext_rcd_id = csr_rcd_rec.ext_rcd_id
5316: AND ext_rslt_id = Ben_Ext_Thread.g_ext_rslt_id
5317: AND business_group_id = p_business_group_id;
5318: END LOOP;
5319: -- Get the benefit action id for the extract
5320: OPEN csr_ben (c_ext_dfn_id => Ben_Ext_Thread.g_ext_dfn_id

Line 5320: OPEN csr_ben (c_ext_dfn_id => Ben_Ext_Thread.g_ext_dfn_id

5316: AND ext_rslt_id = Ben_Ext_Thread.g_ext_rslt_id
5317: AND business_group_id = p_business_group_id;
5318: END LOOP;
5319: -- Get the benefit action id for the extract
5320: OPEN csr_ben (c_ext_dfn_id => Ben_Ext_Thread.g_ext_dfn_id
5321: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id
5322: ,c_business_group_id => p_business_group_id);
5323: FETCH csr_ben INTO l_ben_params;
5324: CLOSE csr_ben;

Line 5321: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id

5317: AND business_group_id = p_business_group_id;
5318: END LOOP;
5319: -- Get the benefit action id for the extract
5320: OPEN csr_ben (c_ext_dfn_id => Ben_Ext_Thread.g_ext_dfn_id
5321: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id
5322: ,c_business_group_id => p_business_group_id);
5323: FETCH csr_ben INTO l_ben_params;
5324: CLOSE csr_ben;
5325: -- Flag the person in ben_person_actions and ben_batch_ranges

Line 5328: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id)

5324: CLOSE csr_ben;
5325: -- Flag the person in ben_person_actions and ben_batch_ranges
5326: -- as Unporcessed and errored.
5327: FOR err_rec IN csr_err(c_bg_id => p_business_group_id
5328: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id)
5329: LOOP
5330: Exclude_Person
5331: (p_person_id => err_rec.person_id
5332: ,p_business_group_id => p_business_group_id

Line 5338: WHERE dtl.ext_rslt_id = Ben_Ext_Thread.g_ext_rslt_id

5334: ,p_flag_thread => 'Y');
5335:
5336: DELETE
5337: FROM ben_ext_rslt_dtl dtl
5338: WHERE dtl.ext_rslt_id = Ben_Ext_Thread.g_ext_rslt_id
5339: AND dtl.person_id = err_rec.person_id
5340: AND dtl.business_group_id = p_business_group_id;
5341: END LOOP;
5342:

Line 5391: Ben_Ext_Thread.g_err_num := p_error_NUMBER;

5387: Nvl(Ben_Ext_Person.g_elmt_name
5388: ,Ben_Ext_Fmt.g_elmt_name)||'. '||
5389: p_error_text;
5390: ELSE
5391: Ben_Ext_Thread.g_err_num := p_error_NUMBER;
5392: Ben_Ext_Thread.g_err_name := p_error_text;
5393: l_error_text :=
5394: Ben_Ext_Fmt.get_error_msg(To_Number(Substr(p_error_text, 5, 5)),
5395: p_error_text,Nvl(Ben_Ext_Person.g_elmt_name,Ben_Ext_Fmt.g_elmt_name) );

Line 5392: Ben_Ext_Thread.g_err_name := p_error_text;

5388: ,Ben_Ext_Fmt.g_elmt_name)||'. '||
5389: p_error_text;
5390: ELSE
5391: Ben_Ext_Thread.g_err_num := p_error_NUMBER;
5392: Ben_Ext_Thread.g_err_name := p_error_text;
5393: l_error_text :=
5394: Ben_Ext_Fmt.get_error_msg(To_Number(Substr(p_error_text, 5, 5)),
5395: p_error_text,Nvl(Ben_Ext_Person.g_elmt_name,Ben_Ext_Fmt.g_elmt_name) );
5396:

Line 5444: l_ext_rslt_id := Ben_Ext_Thread.g_ext_rslt_id;

5440: e_extract_process_not_running EXCEPTION;
5441: PRAGMA EXCEPTION_INIT(e_extract_process_not_running,-8002);
5442: l_ext_rslt_id NUMBER;
5443: BEGIN
5444: l_ext_rslt_id := Ben_Ext_Thread.g_ext_rslt_id;
5445: RETURN l_ext_rslt_id;
5446: EXCEPTION
5447: WHEN e_extract_process_not_running THEN
5448: RETURN -1;