2412: --
2413: l_line := 7;
2414: --
2415: if fnd_global.conc_request_id <> -1 then
2416: fnd_message.set_name('BEN', 'BEN_92190_THREAD_LABEL');
2417: fnd_file.put_line(fnd_file.log, fnd_message.get || ' ' ||to_char(p_thread_id));
2418: fnd_file.put_line(fnd_file.log, ' ');
2419: if p_master_process_flag <> 'Y' then
2420: fnd_message.set_name('BEN', 'BEN_92185_THREAD_SUCCESS');
2413: l_line := 7;
2414: --
2415: if fnd_global.conc_request_id <> -1 then
2416: fnd_message.set_name('BEN', 'BEN_92190_THREAD_LABEL');
2417: fnd_file.put_line(fnd_file.log, fnd_message.get || ' ' ||to_char(p_thread_id));
2418: fnd_file.put_line(fnd_file.log, ' ');
2419: if p_master_process_flag <> 'Y' then
2420: fnd_message.set_name('BEN', 'BEN_92185_THREAD_SUCCESS');
2421: fnd_file.put_line(fnd_file.log, fnd_message.get);
2416: fnd_message.set_name('BEN', 'BEN_92190_THREAD_LABEL');
2417: fnd_file.put_line(fnd_file.log, fnd_message.get || ' ' ||to_char(p_thread_id));
2418: fnd_file.put_line(fnd_file.log, ' ');
2419: if p_master_process_flag <> 'Y' then
2420: fnd_message.set_name('BEN', 'BEN_92185_THREAD_SUCCESS');
2421: fnd_file.put_line(fnd_file.log, fnd_message.get);
2422: fnd_file.put_line(fnd_file.log, ' ');
2423: end if;
2424: end if;
2417: fnd_file.put_line(fnd_file.log, fnd_message.get || ' ' ||to_char(p_thread_id));
2418: fnd_file.put_line(fnd_file.log, ' ');
2419: if p_master_process_flag <> 'Y' then
2420: fnd_message.set_name('BEN', 'BEN_92185_THREAD_SUCCESS');
2421: fnd_file.put_line(fnd_file.log, fnd_message.get);
2422: fnd_file.put_line(fnd_file.log, ' ');
2423: end if;
2424: end if;
2425: --
2453: if fnd_global.conc_request_id <> -1 then
2454: --
2455: -- write end of thread statistics which shows totals of what was
2456: -- processed
2457: fnd_message.set_name('BEN', 'BEN_92190_THREAD_LABEL');
2458: fnd_file.put_line(fnd_file.log, fnd_message.get || ' ' ||to_char(p_thread_id));
2459: --
2460: -- write the error message to the log file.
2461: --
2454: --
2455: -- write end of thread statistics which shows totals of what was
2456: -- processed
2457: fnd_message.set_name('BEN', 'BEN_92190_THREAD_LABEL');
2458: fnd_file.put_line(fnd_file.log, fnd_message.get || ' ' ||to_char(p_thread_id));
2459: --
2460: -- write the error message to the log file.
2461: --
2462: if ben_ext_thread.g_err_num <> 92184 then
2459: --
2460: -- write the error message to the log file.
2461: --
2462: if ben_ext_thread.g_err_num <> 92184 then
2463: fnd_message.set_name('BEN', 'BEN_92186_THREAD_FAILURE');
2464: fnd_file.put_line(fnd_file.log, fnd_message.get);
2465: fnd_file.put_line(fnd_file.log, ' ');
2466: end if;
2467: fnd_message.set_name('BEN', ben_ext_thread.g_err_name);
2460: -- write the error message to the log file.
2461: --
2462: if ben_ext_thread.g_err_num <> 92184 then
2463: fnd_message.set_name('BEN', 'BEN_92186_THREAD_FAILURE');
2464: fnd_file.put_line(fnd_file.log, fnd_message.get);
2465: fnd_file.put_line(fnd_file.log, ' ');
2466: end if;
2467: fnd_message.set_name('BEN', ben_ext_thread.g_err_name);
2468: fnd_file.put_line(fnd_file.log, fnd_message.get);
2463: fnd_message.set_name('BEN', 'BEN_92186_THREAD_FAILURE');
2464: fnd_file.put_line(fnd_file.log, fnd_message.get);
2465: fnd_file.put_line(fnd_file.log, ' ');
2466: end if;
2467: fnd_message.set_name('BEN', ben_ext_thread.g_err_name);
2468: fnd_file.put_line(fnd_file.log, fnd_message.get);
2469: --
2470: -- if slave process, we are done. If master process, raise job failure in
2471: -- calling program (ben_ext_thread.process)
2464: fnd_file.put_line(fnd_file.log, fnd_message.get);
2465: fnd_file.put_line(fnd_file.log, ' ');
2466: end if;
2467: fnd_message.set_name('BEN', ben_ext_thread.g_err_name);
2468: fnd_file.put_line(fnd_file.log, fnd_message.get);
2469: --
2470: -- if slave process, we are done. If master process, raise job failure in
2471: -- calling program (ben_ext_thread.process)
2472: --
2474: --
2475: if p_master_process_flag = 'Y' then
2476: raise;
2477: else -- slave
2478: fnd_message.raise_error;
2479: end if;
2480:
2481:
2482: when others then
2486: update ben_batch_ranges
2487: set range_status_cd = 'E'
2488: where range_id = l_range_id;
2489: --
2490: fnd_message.set_name('BEN', 'BEN_92190_THREAD_LABEL');
2491: fnd_file.put_line(fnd_file.log, fnd_message.get || ' ' ||to_char(p_thread_id));
2492: -- if slave process, we are done. If master process, raise job failure in
2493: -- calling program (ben_ext_thread.process)
2494: --
2487: set range_status_cd = 'E'
2488: where range_id = l_range_id;
2489: --
2490: fnd_message.set_name('BEN', 'BEN_92190_THREAD_LABEL');
2491: fnd_file.put_line(fnd_file.log, fnd_message.get || ' ' ||to_char(p_thread_id));
2492: -- if slave process, we are done. If master process, raise job failure in
2493: -- calling program (ben_ext_thread.process)
2494: --
2495: if p_master_process_flag = 'Y' then
2506: --
2507: commit;
2508: --
2509: if fnd_global.conc_request_id <> -1 then
2510: fnd_message.set_name('BEN', 'BEN_92186_THREAD_FAILURE');
2511: fnd_file.put_line(fnd_file.log, fnd_message.get);
2512: fnd_file.put_line(fnd_file.log, ' ');
2513: fnd_message.set_name('PER', 'FFU10_GENERAL_ORACLE_ERROR');
2514: fnd_message.set_token('2', substr(sqlerrm, 1, 200));
2507: commit;
2508: --
2509: if fnd_global.conc_request_id <> -1 then
2510: fnd_message.set_name('BEN', 'BEN_92186_THREAD_FAILURE');
2511: fnd_file.put_line(fnd_file.log, fnd_message.get);
2512: fnd_file.put_line(fnd_file.log, ' ');
2513: fnd_message.set_name('PER', 'FFU10_GENERAL_ORACLE_ERROR');
2514: fnd_message.set_token('2', substr(sqlerrm, 1, 200));
2515: fnd_file.put_line(fnd_file.log, fnd_message.get);
2509: if fnd_global.conc_request_id <> -1 then
2510: fnd_message.set_name('BEN', 'BEN_92186_THREAD_FAILURE');
2511: fnd_file.put_line(fnd_file.log, fnd_message.get);
2512: fnd_file.put_line(fnd_file.log, ' ');
2513: fnd_message.set_name('PER', 'FFU10_GENERAL_ORACLE_ERROR');
2514: fnd_message.set_token('2', substr(sqlerrm, 1, 200));
2515: fnd_file.put_line(fnd_file.log, fnd_message.get);
2516: fnd_message.raise_error;
2517: end if;
2510: fnd_message.set_name('BEN', 'BEN_92186_THREAD_FAILURE');
2511: fnd_file.put_line(fnd_file.log, fnd_message.get);
2512: fnd_file.put_line(fnd_file.log, ' ');
2513: fnd_message.set_name('PER', 'FFU10_GENERAL_ORACLE_ERROR');
2514: fnd_message.set_token('2', substr(sqlerrm, 1, 200));
2515: fnd_file.put_line(fnd_file.log, fnd_message.get);
2516: fnd_message.raise_error;
2517: end if;
2518: --
2511: fnd_file.put_line(fnd_file.log, fnd_message.get);
2512: fnd_file.put_line(fnd_file.log, ' ');
2513: fnd_message.set_name('PER', 'FFU10_GENERAL_ORACLE_ERROR');
2514: fnd_message.set_token('2', substr(sqlerrm, 1, 200));
2515: fnd_file.put_line(fnd_file.log, fnd_message.get);
2516: fnd_message.raise_error;
2517: end if;
2518: --
2519: end if;
2512: fnd_file.put_line(fnd_file.log, ' ');
2513: fnd_message.set_name('PER', 'FFU10_GENERAL_ORACLE_ERROR');
2514: fnd_message.set_token('2', substr(sqlerrm, 1, 200));
2515: fnd_file.put_line(fnd_file.log, fnd_message.get);
2516: fnd_message.raise_error;
2517: end if;
2518: --
2519: end if;
2520: --
2586: hr_utility.set_location ('Entering '||l_proc,5);
2587: end if;
2588: --
2589: fnd_file.put_line(fnd_file.log, ' ');
2590: fnd_message.set_name('BEN', 'BEN_92191_ALL_THREAD_LABEL');
2591: fnd_file.put_line(fnd_file.log, fnd_message.get);
2592: fnd_file.put_line(fnd_file.log, ' ');
2593: fnd_message.set_name('BEN', 'BEN_92192_EXT_STATS_LABEL');
2594: fnd_file.put_line(fnd_file.log, fnd_message.get);
2587: end if;
2588: --
2589: fnd_file.put_line(fnd_file.log, ' ');
2590: fnd_message.set_name('BEN', 'BEN_92191_ALL_THREAD_LABEL');
2591: fnd_file.put_line(fnd_file.log, fnd_message.get);
2592: fnd_file.put_line(fnd_file.log, ' ');
2593: fnd_message.set_name('BEN', 'BEN_92192_EXT_STATS_LABEL');
2594: fnd_file.put_line(fnd_file.log, fnd_message.get);
2595: fnd_message.set_name('BEN', 'BEN_91956_EXT_TOT_REC');
2589: fnd_file.put_line(fnd_file.log, ' ');
2590: fnd_message.set_name('BEN', 'BEN_92191_ALL_THREAD_LABEL');
2591: fnd_file.put_line(fnd_file.log, fnd_message.get);
2592: fnd_file.put_line(fnd_file.log, ' ');
2593: fnd_message.set_name('BEN', 'BEN_92192_EXT_STATS_LABEL');
2594: fnd_file.put_line(fnd_file.log, fnd_message.get);
2595: fnd_message.set_name('BEN', 'BEN_91956_EXT_TOT_REC');
2596: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_rec_cnt));
2597: --
2590: fnd_message.set_name('BEN', 'BEN_92191_ALL_THREAD_LABEL');
2591: fnd_file.put_line(fnd_file.log, fnd_message.get);
2592: fnd_file.put_line(fnd_file.log, ' ');
2593: fnd_message.set_name('BEN', 'BEN_92192_EXT_STATS_LABEL');
2594: fnd_file.put_line(fnd_file.log, fnd_message.get);
2595: fnd_message.set_name('BEN', 'BEN_91956_EXT_TOT_REC');
2596: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_rec_cnt));
2597: --
2598: fnd_message.set_name('BEN', 'BEN_91957_EXT_TOT_PER');
2591: fnd_file.put_line(fnd_file.log, fnd_message.get);
2592: fnd_file.put_line(fnd_file.log, ' ');
2593: fnd_message.set_name('BEN', 'BEN_92192_EXT_STATS_LABEL');
2594: fnd_file.put_line(fnd_file.log, fnd_message.get);
2595: fnd_message.set_name('BEN', 'BEN_91956_EXT_TOT_REC');
2596: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_rec_cnt));
2597: --
2598: fnd_message.set_name('BEN', 'BEN_91957_EXT_TOT_PER');
2599: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_per_cnt));
2592: fnd_file.put_line(fnd_file.log, ' ');
2593: fnd_message.set_name('BEN', 'BEN_92192_EXT_STATS_LABEL');
2594: fnd_file.put_line(fnd_file.log, fnd_message.get);
2595: fnd_message.set_name('BEN', 'BEN_91956_EXT_TOT_REC');
2596: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_rec_cnt));
2597: --
2598: fnd_message.set_name('BEN', 'BEN_91957_EXT_TOT_PER');
2599: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_per_cnt));
2600: --
2594: fnd_file.put_line(fnd_file.log, fnd_message.get);
2595: fnd_message.set_name('BEN', 'BEN_91956_EXT_TOT_REC');
2596: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_rec_cnt));
2597: --
2598: fnd_message.set_name('BEN', 'BEN_91957_EXT_TOT_PER');
2599: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_per_cnt));
2600: --
2601: fnd_message.set_name('BEN', 'BEN_91958_EXT_TOT_ERR');
2602: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_err_cnt));
2595: fnd_message.set_name('BEN', 'BEN_91956_EXT_TOT_REC');
2596: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_rec_cnt));
2597: --
2598: fnd_message.set_name('BEN', 'BEN_91957_EXT_TOT_PER');
2599: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_per_cnt));
2600: --
2601: fnd_message.set_name('BEN', 'BEN_91958_EXT_TOT_ERR');
2602: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_err_cnt));
2603: --
2597: --
2598: fnd_message.set_name('BEN', 'BEN_91957_EXT_TOT_PER');
2599: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_per_cnt));
2600: --
2601: fnd_message.set_name('BEN', 'BEN_91958_EXT_TOT_ERR');
2602: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_err_cnt));
2603: --
2604: fnd_file.put_line(fnd_file.log, ' ');
2605: --
2598: fnd_message.set_name('BEN', 'BEN_91957_EXT_TOT_PER');
2599: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_per_cnt));
2600: --
2601: fnd_message.set_name('BEN', 'BEN_91958_EXT_TOT_ERR');
2602: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_err_cnt));
2603: --
2604: fnd_file.put_line(fnd_file.log, ' ');
2605: --
2606: if g_debug then
6356: commit;
6357: --
6358: if l_conc_request_id <> -1 then
6359: --
6360: fnd_message.set_name('BEN', 'BEN_92185_THREAD_SUCCESS');
6361: fnd_file.put_line(fnd_file.log, fnd_message.get);
6362: fnd_file.put_line(fnd_file.log, ' ');
6363: --
6364: l_line := 127;
6357: --
6358: if l_conc_request_id <> -1 then
6359: --
6360: fnd_message.set_name('BEN', 'BEN_92185_THREAD_SUCCESS');
6361: fnd_file.put_line(fnd_file.log, fnd_message.get);
6362: fnd_file.put_line(fnd_file.log, ' ');
6363: --
6364: l_line := 127;
6365: --
6511: sub_request => FALSE,
6512: argument1 => l_conc_request_id);
6513: --
6514: thread_summary;
6515: fnd_message.set_name('BEN',g_err_name);
6516: fnd_file.put_line(fnd_file.log, fnd_message.get);
6517: fnd_message.raise_error;
6518: --
6519: end if;
6512: argument1 => l_conc_request_id);
6513: --
6514: thread_summary;
6515: fnd_message.set_name('BEN',g_err_name);
6516: fnd_file.put_line(fnd_file.log, fnd_message.get);
6517: fnd_message.raise_error;
6518: --
6519: end if;
6520: --
6513: --
6514: thread_summary;
6515: fnd_message.set_name('BEN',g_err_name);
6516: fnd_file.put_line(fnd_file.log, fnd_message.get);
6517: fnd_message.raise_error;
6518: --
6519: end if;
6520: --
6521: when others then
6578: sub_request => FALSE,
6579: argument1 => l_conc_request_id);
6580: --
6581: thread_summary;
6582: fnd_message.set_name('PER', 'FFU10_GENERAL_ORACLE_ERROR');
6583: fnd_message.set_token('2', substr(sqlerrm, 1, 200));
6584: fnd_file.put_line(fnd_file.log, fnd_message.get);
6585: fnd_message.raise_error;
6586: --
6579: argument1 => l_conc_request_id);
6580: --
6581: thread_summary;
6582: fnd_message.set_name('PER', 'FFU10_GENERAL_ORACLE_ERROR');
6583: fnd_message.set_token('2', substr(sqlerrm, 1, 200));
6584: fnd_file.put_line(fnd_file.log, fnd_message.get);
6585: fnd_message.raise_error;
6586: --
6587: end if;
6580: --
6581: thread_summary;
6582: fnd_message.set_name('PER', 'FFU10_GENERAL_ORACLE_ERROR');
6583: fnd_message.set_token('2', substr(sqlerrm, 1, 200));
6584: fnd_file.put_line(fnd_file.log, fnd_message.get);
6585: fnd_message.raise_error;
6586: --
6587: end if;
6588: --
6581: thread_summary;
6582: fnd_message.set_name('PER', 'FFU10_GENERAL_ORACLE_ERROR');
6583: fnd_message.set_token('2', substr(sqlerrm, 1, 200));
6584: fnd_file.put_line(fnd_file.log, fnd_message.get);
6585: fnd_message.raise_error;
6586: --
6587: end if;
6588: --
6589: End process;
6722: --
6723: fetch c_parameters into l_parameters;
6724: if c_parameters%notfound then
6725: --
6726: fnd_message.set_name('BEN','BEN_91666_BENMNGLE_NO_RESTART');
6727: fnd_message.raise_error;
6728: --
6729: end if;
6730: --
6723: fetch c_parameters into l_parameters;
6724: if c_parameters%notfound then
6725: --
6726: fnd_message.set_name('BEN','BEN_91666_BENMNGLE_NO_RESTART');
6727: fnd_message.raise_error;
6728: --
6729: end if;
6730: --
6731: close c_parameters;
6734: if l_ext_rslt_id is null then
6735: l_ext_rslt_id := p_ext_rslt_id ;
6736: if l_ext_rslt_id is null then
6737: --- create new error for this
6738: fnd_message.set_name('BEN','BEN_91666_RSLT_ID_NOT_FOUND');
6739: fnd_message.raise_error;
6740: end if ;
6741: end if ;
6742:
6735: l_ext_rslt_id := p_ext_rslt_id ;
6736: if l_ext_rslt_id is null then
6737: --- create new error for this
6738: fnd_message.set_name('BEN','BEN_91666_RSLT_ID_NOT_FOUND');
6739: fnd_message.raise_error;
6740: end if ;
6741: end if ;
6742:
6743:
7031: --
7032: fetch c_parameters into l_parameters;
7033: if c_parameters%notfound then
7034: --
7035: fnd_message.set_name('BEN','BEN_91666_BENMNGLE_NO_RESTART');
7036: fnd_message.raise_error;
7037: --
7038: end if;
7039: --
7032: fetch c_parameters into l_parameters;
7033: if c_parameters%notfound then
7034: --
7035: fnd_message.set_name('BEN','BEN_91666_BENMNGLE_NO_RESTART');
7036: fnd_message.raise_error;
7037: --
7038: end if;
7039: --
7040: close c_parameters;
7044: l_business_group_id := l_parameters.business_group_id;
7045:
7046: if l_ext_rslt_id is null then
7047: -- create new error for this
7048: fnd_message.set_name('BEN','BEN_91666_RSLT_ID_NOT_FOUND');
7049: fnd_message.raise_error;
7050: end if ;
7051: --
7052: -- Check to see if the extract being re-started is a PQP US/Global seeded
7045:
7046: if l_ext_rslt_id is null then
7047: -- create new error for this
7048: fnd_message.set_name('BEN','BEN_91666_RSLT_ID_NOT_FOUND');
7049: fnd_message.raise_error;
7050: end if ;
7051: --
7052: -- Check to see if the extract being re-started is a PQP US/Global seeded
7053: -- or copied extract, if yes then the following procedure insert the values
7182: open c_bg_name ;
7183: fetch c_bg_name into l_business_goup_name ;
7184: if c_bg_name%notfound then
7185: close c_bg_name ;
7186: fnd_message.set_name('BEN','BEN_91000_INVALID_BUS_GROUP');
7187: fnd_message.raise_error;
7188: end if ;
7189: close c_bg_name ;
7190:
7183: fetch c_bg_name into l_business_goup_name ;
7184: if c_bg_name%notfound then
7185: close c_bg_name ;
7186: fnd_message.set_name('BEN','BEN_91000_INVALID_BUS_GROUP');
7187: fnd_message.raise_error;
7188: end if ;
7189: close c_bg_name ;
7190:
7191: -- decide whether it is seede or not for when the process is export
7195: fetch c_ext into l_ext_file_name,l_business_group_id ;
7196: close c_ext ;
7197: --
7198: if l_ext_file_name is null then
7199: fnd_message.set_name('BEN','BEN_91000_INVALID_EXT_NAME');
7200: fnd_message.raise_error;
7201: end if ;
7202: --
7203: if l_business_group_id is not null then
7196: close c_ext ;
7197: --
7198: if l_ext_file_name is null then
7199: fnd_message.set_name('BEN','BEN_91000_INVALID_EXT_NAME');
7200: fnd_message.raise_error;
7201: end if ;
7202: --
7203: if l_business_group_id is not null then
7204: l_seeded := 'N' ;
7229: hr_utility.set_location('Bg Name ' || l_business_group_name , 20);
7230:
7231:
7232: if p_file_name is null then
7233: fnd_message.set_name('BEN','BEN_91000_INVALID_FILE_NAME');
7234: fnd_message.raise_error;
7235: end if ;
7236:
7237: if l_loader_file is null then
7230:
7231:
7232: if p_file_name is null then
7233: fnd_message.set_name('BEN','BEN_91000_INVALID_FILE_NAME');
7234: fnd_message.raise_error;
7235: end if ;
7236:
7237: if l_loader_file is null then
7238: l_loader_file := '@ben:/patch/115/import/benextse.lct';