DBA Data[Home] [Help]

APPS.PQP_GB_PSI_FUNCTIONS dependencies on BEN_EXT_THREAD

Line 274: l_ext_rslt_id := ben_ext_thread.g_ext_rslt_id;

270: -- SELECT ben_ext_rslt_s.CURRVAL
271: -- INTO l_ext_rslt_id
272: -- FROM DUAL;
273:
274: l_ext_rslt_id := ben_ext_thread.g_ext_rslt_id;
275:
276: RETURN l_ext_rslt_id;
277: --
278: EXCEPTION

Line 1597: ben_ext_thread.restart

1593: IF l_ext_dfn_id IS NOT NULL THEN
1594:
1595: IF p_execution_mode = '1REP'
1596: THEN
1597: ben_ext_thread.restart
1598: (errbuf => l_errbuff
1599: ,retcode => l_retcode
1600: ,p_ext_dfn_id => l_ext_dfn_id
1601: ,p_concurrent_request_id => p_concurrent_request_id

Line 1611: ben_ext_thread.process

1607: fnd_file.put_line(fnd_file.log, 'calling ben_process' || ' : ' || get_time);
1608:
1609: IF p_extract_type <> '1PED' -- cutover/code extract (full profile)
1610: THEN
1611: ben_ext_thread.process
1612: (errbuf => l_errbuff
1613: ,retcode => l_retcode
1614: ,p_benefit_action_id => NULL
1615: ,p_ext_dfn_id => l_ext_dfn_id

Line 1637: ben_ext_thread.process

1633:
1634: debug('p_dfn_name : ' || p_dfn_name );
1635: debug('l_penserv_mode : ' || l_penserv_mode );
1636:
1637: ben_ext_thread.process
1638: (errbuf => l_errbuff
1639: ,retcode => l_retcode
1640: ,p_benefit_action_id => NULL
1641: ,p_ext_dfn_id => l_ext_dfn_id

Line 2737: debug('ben_ext_thread.g_ext_dfn_id: '|| ben_ext_thread.g_ext_dfn_id);

2733: FETCH csr_get_bas_ext_dfn_id INTO l_bas_ext_dfn_id;
2734: CLOSE csr_get_bas_ext_dfn_id;
2735:
2736: debug('l_bas_ext_dfn_id: '|| l_bas_ext_dfn_id);
2737: debug('ben_ext_thread.g_ext_dfn_id: '|| ben_ext_thread.g_ext_dfn_id);
2738:
2739: IF l_bas_ext_dfn_id = ben_ext_thread.g_ext_dfn_id
2740: --115.88:Bug 7291713: Stop
2741: THEN

Line 2739: IF l_bas_ext_dfn_id = ben_ext_thread.g_ext_dfn_id

2735:
2736: debug('l_bas_ext_dfn_id: '|| l_bas_ext_dfn_id);
2737: debug('ben_ext_thread.g_ext_dfn_id: '|| ben_ext_thread.g_ext_dfn_id);
2738:
2739: IF l_bas_ext_dfn_id = ben_ext_thread.g_ext_dfn_id
2740: --115.88:Bug 7291713: Stop
2741: THEN
2742:
2743: --115.87:Bug 7291713: Start

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

2991:
2992: debug_enter(l_proc_name);
2993:
2994:
2995: OPEN csr_ben (c_ext_dfn_id => Ben_Ext_Thread.g_ext_dfn_id
2996: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id
2997: ,c_business_group_id => p_business_group_id);
2998: Fetch csr_ben Into l_ben_params;
2999: CLOSE csr_ben;

Line 2996: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id

2992: debug_enter(l_proc_name);
2993:
2994:
2995: OPEN csr_ben (c_ext_dfn_id => Ben_Ext_Thread.g_ext_dfn_id
2996: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id
2997: ,c_business_group_id => p_business_group_id);
2998: Fetch csr_ben Into l_ben_params;
2999: CLOSE csr_ben;
3000:

Line 3010: WHERE EXT_RSLT_ID= Ben_Ext_Thread.g_ext_rslt_id -- 2891 -- c_ext_rslt_id

3006: Where bpa.benefit_action_id = l_ben_params.benefit_action_id -- 3629 -- p_benefit_action_id
3007: and bpa.person_id -- = p_person_id;
3008: IN ( SELECT PERSON_ID
3009: FROM BEN_EXT_RSLT_ERR
3010: WHERE EXT_RSLT_ID= Ben_Ext_Thread.g_ext_rslt_id -- 2891 -- c_ext_rslt_id
3011: AND typ_cd = 'E');
3012:
3013: Update ben_batch_ranges bbr
3014: set bbr.range_status_cd = 'E'

Line 3024: AND bere.EXT_RSLT_ID= Ben_Ext_Thread.g_ext_rslt_id

3020: AND bbr.benefit_action_id = bpa.benefit_action_id
3021: AND (bpa.person_action_id Between
3022: bbr.starting_person_action_id And bbr.ending_person_action_id)
3023: And bpa.person_id = bere.person_id
3024: AND bere.EXT_RSLT_ID= Ben_Ext_Thread.g_ext_rslt_id
3025: AND bere.typ_cd = 'E');
3026:
3027: debug_exit(l_proc_name);
3028:

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

3097:
3098: debug_enter(l_proc_name);
3099:
3100:
3101: OPEN csr_ben (c_ext_dfn_id => Ben_Ext_Thread.g_ext_dfn_id
3102: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id
3103: ,c_business_group_id => p_business_group_id);
3104: Fetch csr_ben Into l_ben_params;
3105: CLOSE csr_ben;

Line 3102: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id

3098: debug_enter(l_proc_name);
3099:
3100:
3101: OPEN csr_ben (c_ext_dfn_id => Ben_Ext_Thread.g_ext_dfn_id
3102: ,c_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id
3103: ,c_business_group_id => p_business_group_id);
3104: Fetch csr_ben Into l_ben_params;
3105: CLOSE csr_ben;
3106:

Line 3111: OPEN csr_err_person_id(p_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id);

3107: debug('l_ben_params.benefit_action_id :' || l_ben_params.benefit_action_id);
3108:
3109:
3110: -- (1) fetch all person_ids which have errored
3111: OPEN csr_err_person_id(p_ext_rslt_id => Ben_Ext_Thread.g_ext_rslt_id);
3112: FETCH csr_err_person_id BULK COLLECT INTO l_person_collection;
3113: CLOSE csr_err_person_id;
3114:
3115: debug('Step 1 Completed');

Line 3212: where ext_dfn_id = ben_ext_thread.g_ext_dfn_id;

3208: CURSOR csr_dfn_code
3209: IS
3210: Select output_name
3211: from ben_ext_dfn
3212: where ext_dfn_id = ben_ext_thread.g_ext_dfn_id;
3213:
3214: l_extract_code csr_dfn_code%rowtype;
3215: l_file_name VARCHAR2(100);
3216: l_run_date DATE;

Line 3254: OPEN csr_get_run_date(c_ext_dfn_id => ben_ext_thread.g_ext_dfn_id

3250: debug('g_sequence_number : ' || g_sequence_number);
3251:
3252:
3253: -- Get the output file name
3254: OPEN csr_get_run_date(c_ext_dfn_id => ben_ext_thread.g_ext_dfn_id
3255: ,c_business_group_id => l_business_group_id);
3256: FETCH csr_get_run_date INTO l_run_date,g_output_name;
3257: CLOSE csr_get_run_date;
3258:

Line 3288: AND ext_rslt_id = ben_ext_thread.g_ext_rslt_id;

3284:
3285: update ben_ext_rslt
3286: SET output_name = l_file_name
3287: WHERE business_group_id = l_business_group_id
3288: AND ext_rslt_id = ben_ext_thread.g_ext_rslt_id;
3289:
3290: debug_exit(l_proc_name);
3291:
3292: -- fnd_file.put_line(fnd_file.log, 'Done : ' || l_proc_name || to_char(SYSDATE,'dd-Mon-yyyy hh:mm:ss am'));

Line 3382: ben_ext_thread.g_err_num := p_error_number;

3378: --if no message token is defined then egt the message from
3379: --ben_ext_fmt.
3380: Elsif p_token1 is null Then
3381:
3382: ben_ext_thread.g_err_num := p_error_number;
3383: ben_ext_thread.g_err_name := p_error_text;
3384: l_error_text :=
3385: ben_ext_fmt.get_error_msg(fnd_number.canonical_to_number(substr(p_error_text, 5, 5)),
3386: p_error_text,ben_ext_fmt.g_elmt_name);

Line 3383: ben_ext_thread.g_err_name := p_error_text;

3379: --ben_ext_fmt.
3380: Elsif p_token1 is null Then
3381:
3382: ben_ext_thread.g_err_num := p_error_number;
3383: ben_ext_thread.g_err_name := p_error_text;
3384: l_error_text :=
3385: ben_ext_fmt.get_error_msg(fnd_number.canonical_to_number(substr(p_error_text, 5, 5)),
3386: p_error_text,ben_ext_fmt.g_elmt_name);
3387:

Line 3395: ben_ext_thread.g_err_num := p_error_number;

3391:
3392: -- set the Tokens in the warning message and then
3393: -- get the warning message from fnd_messages.
3394:
3395: ben_ext_thread.g_err_num := p_error_number;
3396: ben_ext_thread.g_err_name := p_error_text;
3397:
3398: fnd_message.set_name('BEN',p_error_text);
3399: fnd_message.set_token('TOKEN1',p_token1);

Line 3396: ben_ext_thread.g_err_name := p_error_text;

3392: -- set the Tokens in the warning message and then
3393: -- get the warning message from fnd_messages.
3394:
3395: ben_ext_thread.g_err_num := p_error_number;
3396: ben_ext_thread.g_err_name := p_error_text;
3397:
3398: fnd_message.set_name('BEN',p_error_text);
3399: fnd_message.set_token('TOKEN1',p_token1);
3400: debug('token1 : '||p_token1);

Line 3528: ben_ext_thread.g_err_num := p_error_number;

3524:
3525: Elsif p_token1 is null Then
3526:
3527: debug('p_token1 is null');
3528: ben_ext_thread.g_err_num := p_error_number;
3529: ben_ext_thread.g_err_name := p_error_text;
3530: l_error_text :=
3531: ben_ext_fmt.get_error_msg(fnd_number.canonical_to_number(substr(p_error_text, 5, 5)),
3532: p_error_text,ben_ext_fmt.g_elmt_name);

Line 3529: ben_ext_thread.g_err_name := p_error_text;

3525: Elsif p_token1 is null Then
3526:
3527: debug('p_token1 is null');
3528: ben_ext_thread.g_err_num := p_error_number;
3529: ben_ext_thread.g_err_name := p_error_text;
3530: l_error_text :=
3531: ben_ext_fmt.get_error_msg(fnd_number.canonical_to_number(substr(p_error_text, 5, 5)),
3532: p_error_text,ben_ext_fmt.g_elmt_name);
3533:

Line 3541: ben_ext_thread.g_err_num := p_error_number;

3537:
3538: -- set the Tokens in the warning message and then
3539: -- get the warning message from fnd_messages.
3540:
3541: ben_ext_thread.g_err_num := p_error_number;
3542: ben_ext_thread.g_err_name := p_error_text;
3543:
3544: fnd_message.set_name('BEN',p_error_text);
3545: fnd_message.set_token('TOKEN1',p_token1);

Line 3542: ben_ext_thread.g_err_name := p_error_text;

3538: -- set the Tokens in the warning message and then
3539: -- get the warning message from fnd_messages.
3540:
3541: ben_ext_thread.g_err_num := p_error_number;
3542: ben_ext_thread.g_err_name := p_error_text;
3543:
3544: fnd_message.set_name('BEN',p_error_text);
3545: fnd_message.set_token('TOKEN1',p_token1);
3546:

Line 3592: --raise ben_ext_thread.g_job_failure_error;

3588: );
3589:
3590: --commit;
3591:
3592: --raise ben_ext_thread.g_job_failure_error;
3593: l_return_value:= 0; /* All Well ! */
3594: --
3595: ELSE
3596: --

Line 3689: g_errors(l_error_index + 1).ext_rslt_id := ben_ext_thread.g_ext_rslt_id;

3685: g_errors(l_error_index + 1).assignment_id := -(l_error_index+1);
3686: END IF;
3687:
3688: -- store extract result ID for cases of multiple parallel extracts run
3689: g_errors(l_error_index + 1).ext_rslt_id := ben_ext_thread.g_ext_rslt_id;
3690:
3691: -- debug
3692: --=================================
3693: debug('g_errors('||(l_error_index + 1)||').extract_type : '|| g_errors(l_error_index + 1).extract_type);

Line 3725: g_warnings(l_warning_index + 1).ext_rslt_id := ben_ext_thread.g_ext_rslt_id;

3721: g_warnings(l_warning_index + 1).assignment_id := -(l_warning_index+1);
3722: END IF;
3723:
3724: -- store extract result ID for cases of multiple parallel extracts run
3725: g_warnings(l_warning_index + 1).ext_rslt_id := ben_ext_thread.g_ext_rslt_id;
3726:
3727:
3728: -- debug
3729: --=================================

Line 3839: g_errors(l_index).ext_rslt_id = ben_ext_thread.g_ext_rslt_id

3835: g_errors(l_index).assignment_id < 0 -- IS NULL
3836: )
3837: )
3838: and
3839: g_errors(l_index).ext_rslt_id = ben_ext_thread.g_ext_rslt_id
3840:
3841:
3842: THEN
3843: debug('This error qualified to be raised - ',30);

Line 3920: g_warnings(l_index).ext_rslt_id = ben_ext_thread.g_ext_rslt_id

3916: g_warnings(l_index).assignment_id < 0 -- IS NULL
3917: )
3918: )
3919: and
3920: g_warnings(l_index).ext_rslt_id = ben_ext_thread.g_ext_rslt_id
3921:
3922: THEN
3923: debug('This warning qualified to be raised - ',30);
3924:

Line 3951: raise ben_ext_thread.g_job_failure_error;

3947: IF l_fatal_error_flag = 'Y'
3948: THEN
3949: commit;
3950:
3951: raise ben_ext_thread.g_job_failure_error;
3952: END IF;
3953:
3954: debug_exit(l_proc_name);
3955:

Line 4052: p_ext_dfn_id := ben_ext_thread.g_ext_dfn_id;

4048: -- store in a global
4049: g_cutover_date := p_cutover_date;
4050:
4051: -- extract definition ID
4052: p_ext_dfn_id := ben_ext_thread.g_ext_dfn_id;
4053: debug('p_ext_dfn_id : ' || p_ext_dfn_id, 60);
4054:
4055:
4056: -- fetch configuration value for employment type mapping

Line 4795: WHERE ext_dfn_id = ben_ext_thread.g_ext_dfn_id

4791: CURSOR csr_get_run_date
4792: IS
4793: SELECT MAX(eff_dt)
4794: FROM ben_ext_rslt
4795: WHERE ext_dfn_id = ben_ext_thread.g_ext_dfn_id
4796: AND business_group_id = g_business_group_id
4797: AND ext_stat_cd = 'A';
4798: */
4799:

Line 4841: l_ext_dfn_id := ben_ext_thread.g_ext_dfn_id;

4837: OPEN csr_ext_dfn_id(c_extract_name => 'PQP GB PenServer Periodic Changes Interface - Basic Data');
4838: FETCH csr_ext_dfn_id INTO l_ext_dfn_id;
4839: CLOSE csr_ext_dfn_id;
4840: ELSE
4841: l_ext_dfn_id := ben_ext_thread.g_ext_dfn_id;
4842: END IF;
4843:
4844:
4845: -- Get the run date