2414: --
2415: l_line := 7;
2416: --
2417: if fnd_global.conc_request_id <> -1 then
2418: fnd_message.set_name('BEN', 'BEN_92190_THREAD_LABEL');
2419: fnd_file.put_line(fnd_file.log, fnd_message.get || ' ' ||to_char(p_thread_id));
2420: fnd_file.put_line(fnd_file.log, ' ');
2421: if p_master_process_flag <> 'Y' then
2422: fnd_message.set_name('BEN', 'BEN_92185_THREAD_SUCCESS');
2415: l_line := 7;
2416: --
2417: if fnd_global.conc_request_id <> -1 then
2418: fnd_message.set_name('BEN', 'BEN_92190_THREAD_LABEL');
2419: fnd_file.put_line(fnd_file.log, fnd_message.get || ' ' ||to_char(p_thread_id));
2420: fnd_file.put_line(fnd_file.log, ' ');
2421: if p_master_process_flag <> 'Y' then
2422: fnd_message.set_name('BEN', 'BEN_92185_THREAD_SUCCESS');
2423: fnd_file.put_line(fnd_file.log, fnd_message.get);
2418: fnd_message.set_name('BEN', 'BEN_92190_THREAD_LABEL');
2419: fnd_file.put_line(fnd_file.log, fnd_message.get || ' ' ||to_char(p_thread_id));
2420: fnd_file.put_line(fnd_file.log, ' ');
2421: if p_master_process_flag <> 'Y' then
2422: fnd_message.set_name('BEN', 'BEN_92185_THREAD_SUCCESS');
2423: fnd_file.put_line(fnd_file.log, fnd_message.get);
2424: fnd_file.put_line(fnd_file.log, ' ');
2425: end if;
2426: end if;
2419: fnd_file.put_line(fnd_file.log, fnd_message.get || ' ' ||to_char(p_thread_id));
2420: fnd_file.put_line(fnd_file.log, ' ');
2421: if p_master_process_flag <> 'Y' then
2422: fnd_message.set_name('BEN', 'BEN_92185_THREAD_SUCCESS');
2423: fnd_file.put_line(fnd_file.log, fnd_message.get);
2424: fnd_file.put_line(fnd_file.log, ' ');
2425: end if;
2426: end if;
2427: --
2455: if fnd_global.conc_request_id <> -1 then
2456: --
2457: -- write end of thread statistics which shows totals of what was
2458: -- processed
2459: fnd_message.set_name('BEN', 'BEN_92190_THREAD_LABEL');
2460: fnd_file.put_line(fnd_file.log, fnd_message.get || ' ' ||to_char(p_thread_id));
2461: --
2462: -- write the error message to the log file.
2463: --
2456: --
2457: -- write end of thread statistics which shows totals of what was
2458: -- processed
2459: fnd_message.set_name('BEN', 'BEN_92190_THREAD_LABEL');
2460: fnd_file.put_line(fnd_file.log, fnd_message.get || ' ' ||to_char(p_thread_id));
2461: --
2462: -- write the error message to the log file.
2463: --
2464: if ben_ext_thread.g_err_num <> 92184 then
2461: --
2462: -- write the error message to the log file.
2463: --
2464: if ben_ext_thread.g_err_num <> 92184 then
2465: fnd_message.set_name('BEN', 'BEN_92186_THREAD_FAILURE');
2466: fnd_file.put_line(fnd_file.log, fnd_message.get);
2467: fnd_file.put_line(fnd_file.log, ' ');
2468: end if;
2469: fnd_message.set_name('BEN', ben_ext_thread.g_err_name);
2462: -- write the error message to the log file.
2463: --
2464: if ben_ext_thread.g_err_num <> 92184 then
2465: fnd_message.set_name('BEN', 'BEN_92186_THREAD_FAILURE');
2466: fnd_file.put_line(fnd_file.log, fnd_message.get);
2467: fnd_file.put_line(fnd_file.log, ' ');
2468: end if;
2469: fnd_message.set_name('BEN', ben_ext_thread.g_err_name);
2470: fnd_file.put_line(fnd_file.log, fnd_message.get);
2465: fnd_message.set_name('BEN', 'BEN_92186_THREAD_FAILURE');
2466: fnd_file.put_line(fnd_file.log, fnd_message.get);
2467: fnd_file.put_line(fnd_file.log, ' ');
2468: end if;
2469: fnd_message.set_name('BEN', ben_ext_thread.g_err_name);
2470: fnd_file.put_line(fnd_file.log, fnd_message.get);
2471: --
2472: -- if slave process, we are done. If master process, raise job failure in
2473: -- calling program (ben_ext_thread.process)
2466: fnd_file.put_line(fnd_file.log, fnd_message.get);
2467: fnd_file.put_line(fnd_file.log, ' ');
2468: end if;
2469: fnd_message.set_name('BEN', ben_ext_thread.g_err_name);
2470: fnd_file.put_line(fnd_file.log, fnd_message.get);
2471: --
2472: -- if slave process, we are done. If master process, raise job failure in
2473: -- calling program (ben_ext_thread.process)
2474: --
2476: --
2477: if p_master_process_flag = 'Y' then
2478: raise;
2479: else -- slave
2480: fnd_message.raise_error;
2481: end if;
2482:
2483:
2484: when others then
2488: update ben_batch_ranges
2489: set range_status_cd = 'E'
2490: where range_id = l_range_id;
2491: --
2492: fnd_message.set_name('BEN', 'BEN_92190_THREAD_LABEL');
2493: fnd_file.put_line(fnd_file.log, fnd_message.get || ' ' ||to_char(p_thread_id));
2494: -- if slave process, we are done. If master process, raise job failure in
2495: -- calling program (ben_ext_thread.process)
2496: --
2489: set range_status_cd = 'E'
2490: where range_id = l_range_id;
2491: --
2492: fnd_message.set_name('BEN', 'BEN_92190_THREAD_LABEL');
2493: fnd_file.put_line(fnd_file.log, fnd_message.get || ' ' ||to_char(p_thread_id));
2494: -- if slave process, we are done. If master process, raise job failure in
2495: -- calling program (ben_ext_thread.process)
2496: --
2497: if p_master_process_flag = 'Y' then
2508: --
2509: commit;
2510: --
2511: if fnd_global.conc_request_id <> -1 then
2512: fnd_message.set_name('BEN', 'BEN_92186_THREAD_FAILURE');
2513: fnd_file.put_line(fnd_file.log, fnd_message.get);
2514: fnd_file.put_line(fnd_file.log, ' ');
2515: fnd_message.set_name('PER', 'FFU10_GENERAL_ORACLE_ERROR');
2516: fnd_message.set_token('2', substr(sqlerrm, 1, 200));
2509: commit;
2510: --
2511: if fnd_global.conc_request_id <> -1 then
2512: fnd_message.set_name('BEN', 'BEN_92186_THREAD_FAILURE');
2513: fnd_file.put_line(fnd_file.log, fnd_message.get);
2514: fnd_file.put_line(fnd_file.log, ' ');
2515: fnd_message.set_name('PER', 'FFU10_GENERAL_ORACLE_ERROR');
2516: fnd_message.set_token('2', substr(sqlerrm, 1, 200));
2517: fnd_file.put_line(fnd_file.log, fnd_message.get);
2511: if fnd_global.conc_request_id <> -1 then
2512: fnd_message.set_name('BEN', 'BEN_92186_THREAD_FAILURE');
2513: fnd_file.put_line(fnd_file.log, fnd_message.get);
2514: fnd_file.put_line(fnd_file.log, ' ');
2515: fnd_message.set_name('PER', 'FFU10_GENERAL_ORACLE_ERROR');
2516: fnd_message.set_token('2', substr(sqlerrm, 1, 200));
2517: fnd_file.put_line(fnd_file.log, fnd_message.get);
2518: fnd_message.raise_error;
2519: end if;
2512: fnd_message.set_name('BEN', 'BEN_92186_THREAD_FAILURE');
2513: fnd_file.put_line(fnd_file.log, fnd_message.get);
2514: fnd_file.put_line(fnd_file.log, ' ');
2515: fnd_message.set_name('PER', 'FFU10_GENERAL_ORACLE_ERROR');
2516: fnd_message.set_token('2', substr(sqlerrm, 1, 200));
2517: fnd_file.put_line(fnd_file.log, fnd_message.get);
2518: fnd_message.raise_error;
2519: end if;
2520: --
2513: fnd_file.put_line(fnd_file.log, fnd_message.get);
2514: fnd_file.put_line(fnd_file.log, ' ');
2515: fnd_message.set_name('PER', 'FFU10_GENERAL_ORACLE_ERROR');
2516: fnd_message.set_token('2', substr(sqlerrm, 1, 200));
2517: fnd_file.put_line(fnd_file.log, fnd_message.get);
2518: fnd_message.raise_error;
2519: end if;
2520: --
2521: end if;
2514: fnd_file.put_line(fnd_file.log, ' ');
2515: fnd_message.set_name('PER', 'FFU10_GENERAL_ORACLE_ERROR');
2516: fnd_message.set_token('2', substr(sqlerrm, 1, 200));
2517: fnd_file.put_line(fnd_file.log, fnd_message.get);
2518: fnd_message.raise_error;
2519: end if;
2520: --
2521: end if;
2522: --
2588: hr_utility.set_location ('Entering '||l_proc,5);
2589: end if;
2590: --
2591: fnd_file.put_line(fnd_file.log, ' ');
2592: fnd_message.set_name('BEN', 'BEN_92191_ALL_THREAD_LABEL');
2593: fnd_file.put_line(fnd_file.log, fnd_message.get);
2594: fnd_file.put_line(fnd_file.log, ' ');
2595: fnd_message.set_name('BEN', 'BEN_92192_EXT_STATS_LABEL');
2596: fnd_file.put_line(fnd_file.log, fnd_message.get);
2589: end if;
2590: --
2591: fnd_file.put_line(fnd_file.log, ' ');
2592: fnd_message.set_name('BEN', 'BEN_92191_ALL_THREAD_LABEL');
2593: fnd_file.put_line(fnd_file.log, fnd_message.get);
2594: fnd_file.put_line(fnd_file.log, ' ');
2595: fnd_message.set_name('BEN', 'BEN_92192_EXT_STATS_LABEL');
2596: fnd_file.put_line(fnd_file.log, fnd_message.get);
2597: fnd_message.set_name('BEN', 'BEN_91956_EXT_TOT_REC');
2591: fnd_file.put_line(fnd_file.log, ' ');
2592: fnd_message.set_name('BEN', 'BEN_92191_ALL_THREAD_LABEL');
2593: fnd_file.put_line(fnd_file.log, fnd_message.get);
2594: fnd_file.put_line(fnd_file.log, ' ');
2595: fnd_message.set_name('BEN', 'BEN_92192_EXT_STATS_LABEL');
2596: fnd_file.put_line(fnd_file.log, fnd_message.get);
2597: fnd_message.set_name('BEN', 'BEN_91956_EXT_TOT_REC');
2598: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_rec_cnt));
2599: --
2592: fnd_message.set_name('BEN', 'BEN_92191_ALL_THREAD_LABEL');
2593: fnd_file.put_line(fnd_file.log, fnd_message.get);
2594: fnd_file.put_line(fnd_file.log, ' ');
2595: fnd_message.set_name('BEN', 'BEN_92192_EXT_STATS_LABEL');
2596: fnd_file.put_line(fnd_file.log, fnd_message.get);
2597: fnd_message.set_name('BEN', 'BEN_91956_EXT_TOT_REC');
2598: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_rec_cnt));
2599: --
2600: fnd_message.set_name('BEN', 'BEN_91957_EXT_TOT_PER');
2593: fnd_file.put_line(fnd_file.log, fnd_message.get);
2594: fnd_file.put_line(fnd_file.log, ' ');
2595: fnd_message.set_name('BEN', 'BEN_92192_EXT_STATS_LABEL');
2596: fnd_file.put_line(fnd_file.log, fnd_message.get);
2597: fnd_message.set_name('BEN', 'BEN_91956_EXT_TOT_REC');
2598: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_rec_cnt));
2599: --
2600: fnd_message.set_name('BEN', 'BEN_91957_EXT_TOT_PER');
2601: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_per_cnt));
2594: fnd_file.put_line(fnd_file.log, ' ');
2595: fnd_message.set_name('BEN', 'BEN_92192_EXT_STATS_LABEL');
2596: fnd_file.put_line(fnd_file.log, fnd_message.get);
2597: fnd_message.set_name('BEN', 'BEN_91956_EXT_TOT_REC');
2598: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_rec_cnt));
2599: --
2600: fnd_message.set_name('BEN', 'BEN_91957_EXT_TOT_PER');
2601: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_per_cnt));
2602: --
2596: fnd_file.put_line(fnd_file.log, fnd_message.get);
2597: fnd_message.set_name('BEN', 'BEN_91956_EXT_TOT_REC');
2598: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_rec_cnt));
2599: --
2600: fnd_message.set_name('BEN', 'BEN_91957_EXT_TOT_PER');
2601: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_per_cnt));
2602: --
2603: fnd_message.set_name('BEN', 'BEN_91958_EXT_TOT_ERR');
2604: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_err_cnt));
2597: fnd_message.set_name('BEN', 'BEN_91956_EXT_TOT_REC');
2598: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_rec_cnt));
2599: --
2600: fnd_message.set_name('BEN', 'BEN_91957_EXT_TOT_PER');
2601: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_per_cnt));
2602: --
2603: fnd_message.set_name('BEN', 'BEN_91958_EXT_TOT_ERR');
2604: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_err_cnt));
2605: --
2599: --
2600: fnd_message.set_name('BEN', 'BEN_91957_EXT_TOT_PER');
2601: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_per_cnt));
2602: --
2603: fnd_message.set_name('BEN', 'BEN_91958_EXT_TOT_ERR');
2604: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_err_cnt));
2605: --
2606: fnd_file.put_line(fnd_file.log, ' ');
2607: --
2600: fnd_message.set_name('BEN', 'BEN_91957_EXT_TOT_PER');
2601: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_per_cnt));
2602: --
2603: fnd_message.set_name('BEN', 'BEN_91958_EXT_TOT_ERR');
2604: fnd_file.put_line(fnd_file.log, ' ' || fnd_message.get || ' ' || to_char(g_err_cnt));
2605: --
2606: fnd_file.put_line(fnd_file.log, ' ');
2607: --
2608: if g_debug then
6397: commit;
6398: --
6399: if l_conc_request_id <> -1 then
6400: --
6401: fnd_message.set_name('BEN', 'BEN_92185_THREAD_SUCCESS');
6402: fnd_file.put_line(fnd_file.log, fnd_message.get);
6403: fnd_file.put_line(fnd_file.log, ' ');
6404: --
6405: l_line := 127;
6398: --
6399: if l_conc_request_id <> -1 then
6400: --
6401: fnd_message.set_name('BEN', 'BEN_92185_THREAD_SUCCESS');
6402: fnd_file.put_line(fnd_file.log, fnd_message.get);
6403: fnd_file.put_line(fnd_file.log, ' ');
6404: --
6405: l_line := 127;
6406: --
6552: sub_request => FALSE,
6553: argument1 => l_conc_request_id);
6554: --
6555: thread_summary;
6556: fnd_message.set_name('BEN',g_err_name);
6557: fnd_file.put_line(fnd_file.log, fnd_message.get);
6558: fnd_message.raise_error;
6559: --
6560: end if;
6553: argument1 => l_conc_request_id);
6554: --
6555: thread_summary;
6556: fnd_message.set_name('BEN',g_err_name);
6557: fnd_file.put_line(fnd_file.log, fnd_message.get);
6558: fnd_message.raise_error;
6559: --
6560: end if;
6561: --
6554: --
6555: thread_summary;
6556: fnd_message.set_name('BEN',g_err_name);
6557: fnd_file.put_line(fnd_file.log, fnd_message.get);
6558: fnd_message.raise_error;
6559: --
6560: end if;
6561: --
6562: when others then
6619: sub_request => FALSE,
6620: argument1 => l_conc_request_id);
6621: --
6622: thread_summary;
6623: fnd_message.set_name('PER', 'FFU10_GENERAL_ORACLE_ERROR');
6624: fnd_message.set_token('2', substr(sqlerrm, 1, 200));
6625: fnd_file.put_line(fnd_file.log, fnd_message.get);
6626: fnd_message.raise_error;
6627: --
6620: argument1 => l_conc_request_id);
6621: --
6622: thread_summary;
6623: fnd_message.set_name('PER', 'FFU10_GENERAL_ORACLE_ERROR');
6624: fnd_message.set_token('2', substr(sqlerrm, 1, 200));
6625: fnd_file.put_line(fnd_file.log, fnd_message.get);
6626: fnd_message.raise_error;
6627: --
6628: end if;
6621: --
6622: thread_summary;
6623: fnd_message.set_name('PER', 'FFU10_GENERAL_ORACLE_ERROR');
6624: fnd_message.set_token('2', substr(sqlerrm, 1, 200));
6625: fnd_file.put_line(fnd_file.log, fnd_message.get);
6626: fnd_message.raise_error;
6627: --
6628: end if;
6629: --
6622: thread_summary;
6623: fnd_message.set_name('PER', 'FFU10_GENERAL_ORACLE_ERROR');
6624: fnd_message.set_token('2', substr(sqlerrm, 1, 200));
6625: fnd_file.put_line(fnd_file.log, fnd_message.get);
6626: fnd_message.raise_error;
6627: --
6628: end if;
6629: --
6630: End process;
6763: --
6764: fetch c_parameters into l_parameters;
6765: if c_parameters%notfound then
6766: --
6767: fnd_message.set_name('BEN','BEN_91666_BENMNGLE_NO_RESTART');
6768: fnd_message.raise_error;
6769: --
6770: end if;
6771: --
6764: fetch c_parameters into l_parameters;
6765: if c_parameters%notfound then
6766: --
6767: fnd_message.set_name('BEN','BEN_91666_BENMNGLE_NO_RESTART');
6768: fnd_message.raise_error;
6769: --
6770: end if;
6771: --
6772: close c_parameters;
6775: if l_ext_rslt_id is null then
6776: l_ext_rslt_id := p_ext_rslt_id ;
6777: if l_ext_rslt_id is null then
6778: --- create new error for this
6779: fnd_message.set_name('BEN','BEN_91666_RSLT_ID_NOT_FOUND');
6780: fnd_message.raise_error;
6781: end if ;
6782: end if ;
6783:
6776: l_ext_rslt_id := p_ext_rslt_id ;
6777: if l_ext_rslt_id is null then
6778: --- create new error for this
6779: fnd_message.set_name('BEN','BEN_91666_RSLT_ID_NOT_FOUND');
6780: fnd_message.raise_error;
6781: end if ;
6782: end if ;
6783:
6784:
7072: --
7073: fetch c_parameters into l_parameters;
7074: if c_parameters%notfound then
7075: --
7076: fnd_message.set_name('BEN','BEN_91666_BENMNGLE_NO_RESTART');
7077: fnd_message.raise_error;
7078: --
7079: end if;
7080: --
7073: fetch c_parameters into l_parameters;
7074: if c_parameters%notfound then
7075: --
7076: fnd_message.set_name('BEN','BEN_91666_BENMNGLE_NO_RESTART');
7077: fnd_message.raise_error;
7078: --
7079: end if;
7080: --
7081: close c_parameters;
7085: l_business_group_id := l_parameters.business_group_id;
7086:
7087: if l_ext_rslt_id is null then
7088: -- create new error for this
7089: fnd_message.set_name('BEN','BEN_91666_RSLT_ID_NOT_FOUND');
7090: fnd_message.raise_error;
7091: end if ;
7092: --
7093: -- Check to see if the extract being re-started is a PQP US/Global seeded
7086:
7087: if l_ext_rslt_id is null then
7088: -- create new error for this
7089: fnd_message.set_name('BEN','BEN_91666_RSLT_ID_NOT_FOUND');
7090: fnd_message.raise_error;
7091: end if ;
7092: --
7093: -- Check to see if the extract being re-started is a PQP US/Global seeded
7094: -- or copied extract, if yes then the following procedure insert the values
7223: open c_bg_name ;
7224: fetch c_bg_name into l_business_goup_name ;
7225: if c_bg_name%notfound then
7226: close c_bg_name ;
7227: fnd_message.set_name('BEN','BEN_91000_INVALID_BUS_GROUP');
7228: fnd_message.raise_error;
7229: end if ;
7230: close c_bg_name ;
7231:
7224: fetch c_bg_name into l_business_goup_name ;
7225: if c_bg_name%notfound then
7226: close c_bg_name ;
7227: fnd_message.set_name('BEN','BEN_91000_INVALID_BUS_GROUP');
7228: fnd_message.raise_error;
7229: end if ;
7230: close c_bg_name ;
7231:
7232: -- decide whether it is seede or not for when the process is export
7236: fetch c_ext into l_ext_file_name,l_business_group_id ;
7237: close c_ext ;
7238: --
7239: if l_ext_file_name is null then
7240: fnd_message.set_name('BEN','BEN_91000_INVALID_EXT_NAME');
7241: fnd_message.raise_error;
7242: end if ;
7243: --
7244: if l_business_group_id is not null then
7237: close c_ext ;
7238: --
7239: if l_ext_file_name is null then
7240: fnd_message.set_name('BEN','BEN_91000_INVALID_EXT_NAME');
7241: fnd_message.raise_error;
7242: end if ;
7243: --
7244: if l_business_group_id is not null then
7245: l_seeded := 'N' ;
7270: hr_utility.set_location('Bg Name ' || l_business_group_name , 20);
7271:
7272:
7273: if p_file_name is null then
7274: fnd_message.set_name('BEN','BEN_91000_INVALID_FILE_NAME');
7275: fnd_message.raise_error;
7276: end if ;
7277:
7278: if l_loader_file is null then
7271:
7272:
7273: if p_file_name is null then
7274: fnd_message.set_name('BEN','BEN_91000_INVALID_FILE_NAME');
7275: fnd_message.raise_error;
7276: end if ;
7277:
7278: if l_loader_file is null then
7279: l_loader_file := '@ben:/patch/115/import/benextse.lct';