DBA Data[Home] [Help]

APPS.CN_CALC_SQL_EXPS_PVT dependencies on CN_IMPORT_PVT

Line 2213: cn_import_pvt.build_error_rec(p_imp_header_id => p_imp_header_id

2209: p_message_text => 'CALCEXPIMP: Start Transfer Data. imp_header_id = ' || TO_CHAR(p_imp_header_id)
2210: , p_message_type => 'MILESTONE'
2211: );
2212: -- Get source column name list and target column dynamic sql statement
2213: cn_import_pvt.build_error_rec(p_imp_header_id => p_imp_header_id
2214: , x_header_list => l_header_list, x_sql_stmt => l_sql_stmt);
2215:
2216: OPEN get_api_recs;
2217:

Line 2240: cn_import_pvt.update_imp_lines(

2236: IF l_api_rec.expression_name IS NULL OR l_api_rec.sql_select IS NULL THEN
2237: l_failed_row := l_failed_row + 1;
2238: l_error_code := 'CN_IMP_MISS_REQUIRED';
2239: l_message := fnd_message.get_string('CN', 'CN_IMP_MISS_REQUIRED');
2240: cn_import_pvt.update_imp_lines(
2241: p_imp_line_id => l_api_rec.imp_line_id
2242: , p_status_code => 'FAIL'
2243: , p_error_code => l_error_code
2244: );

Line 2245: cn_import_pvt.update_imp_headers(

2241: p_imp_line_id => l_api_rec.imp_line_id
2242: , p_status_code => 'FAIL'
2243: , p_error_code => l_error_code
2244: );
2245: cn_import_pvt.update_imp_headers(
2246: p_imp_header_id => p_imp_header_id
2247: , p_status_code => 'IMPORT_FAIL'
2248: , p_failed_row => l_failed_row
2249: );

Line 2255: cn_import_pvt.write_error_rec(

2251: p_message_text => 'Record ' || TO_CHAR(l_processed_row) || ':'
2252: || l_message
2253: , p_message_type => 'ERROR'
2254: );
2255: cn_import_pvt.write_error_rec(
2256: p_imp_header_id => p_imp_header_id
2257: , p_imp_line_id => l_api_rec.imp_line_id
2258: , p_header_list => l_header_list
2259: , p_sql_stmt => l_sql_stmt

Line 2341: cn_import_pvt.update_imp_lines(

2337: l_error_code := my_message;
2338: my_message := fnd_msg_pub.get(p_encoded => fnd_api.g_false);
2339: END LOOP;
2340:
2341: cn_import_pvt.update_imp_lines(
2342: p_imp_line_id => l_api_rec.imp_line_id
2343: , p_status_code => 'FAIL'
2344: , p_error_code => NULL
2345: , p_error_msg => NVL(l_error_code, 'Unexpected Error')

Line 2347: cn_import_pvt.update_imp_headers(

2343: , p_status_code => 'FAIL'
2344: , p_error_code => NULL
2345: , p_error_msg => NVL(l_error_code, 'Unexpected Error')
2346: );
2347: cn_import_pvt.update_imp_headers(
2348: p_imp_header_id => p_imp_header_id
2349: , p_status_code => 'IMPORT_FAIL'
2350: , p_failed_row => l_failed_row
2351: );

Line 2357: cn_import_pvt.write_error_rec(

2353: p_message_text => 'Record ' || TO_CHAR(l_processed_row) || ':'
2354: || l_message
2355: , p_message_type => 'ERROR'
2356: );
2357: cn_import_pvt.write_error_rec(
2358: p_imp_header_id => p_imp_header_id
2359: , p_imp_line_id => l_api_rec.imp_line_id
2360: , p_header_list => l_header_list
2361: , p_sql_stmt => l_sql_stmt

Line 2368: cn_import_pvt.update_imp_lines(

2364: errbuf := l_message;
2365: GOTO end_loop;
2366: ELSE
2367: l_error_code := '';
2368: cn_import_pvt.update_imp_lines(
2369: p_imp_line_id => l_api_rec.imp_line_id
2370: , p_status_code => 'COMPLETE'
2371: , p_error_code => l_error_code
2372: );

Line 2382: cn_import_pvt.update_imp_headers(

2378: END IF;
2379:
2380: <>
2381: -- update update_imp_headers:process_row
2382: cn_import_pvt.update_imp_headers(
2383: p_imp_header_id => p_imp_header_id
2384: , p_status_code => NULL
2385: , p_processed_row => l_processed_row
2386: );

Line 2392: cn_import_pvt.update_imp_lines(

2388: WHEN OTHERS THEN
2389: l_failed_row := l_failed_row + 1;
2390: l_error_code := SQLCODE;
2391: l_message := SUBSTR(SQLERRM, 1, 2000);
2392: cn_import_pvt.update_imp_lines(
2393: p_imp_line_id => l_api_rec.imp_line_id
2394: , p_status_code => 'FAIL'
2395: , p_error_code => NULL
2396: , p_error_msg => l_message

Line 2398: cn_import_pvt.update_imp_headers(

2394: , p_status_code => 'FAIL'
2395: , p_error_code => NULL
2396: , p_error_msg => l_message
2397: );
2398: cn_import_pvt.update_imp_headers(
2399: p_imp_header_id => p_imp_header_id
2400: , p_status_code => 'IMPORT_FAIL'
2401: , p_processed_row => l_processed_row
2402: , p_failed_row => l_failed_row

Line 2409: cn_import_pvt.write_error_rec(

2405: p_message_text => 'Record ' || TO_CHAR(l_processed_row) || ':'
2406: || l_message
2407: , p_message_type => 'ERROR'
2408: );
2409: cn_import_pvt.write_error_rec(
2410: p_imp_header_id => p_imp_header_id
2411: , p_imp_line_id => l_api_rec.imp_line_id
2412: , p_header_list => l_header_list
2413: , p_sql_stmt => l_sql_stmt

Line 2428: cn_import_pvt.update_imp_headers(

2424: CLOSE get_api_recs;
2425:
2426: IF l_failed_row = 0 AND retcode = 0 THEN
2427: -- update update_imp_headers
2428: cn_import_pvt.update_imp_headers(
2429: p_imp_header_id => p_imp_header_id
2430: , p_status_code => 'COMPLETE'
2431: , p_processed_row => l_processed_row
2432: , p_failed_row => l_failed_row

Line 2484: l_col_names cn_import_pvt.char_data_set_type;

2480: l_process_audit_id cn_process_audits.process_audit_id%TYPE;
2481: l_return_status VARCHAR2(1);
2482: l_msg_data VARCHAR2(4000);
2483: l_msg_count NUMBER;
2484: l_col_names cn_import_pvt.char_data_set_type;
2485: l_data cn_import_pvt.char_data_set_type;
2486: l_rowcount NUMBER := 0;
2487: l_longcount NUMBER := 0;
2488: l_rec_num NUMBER := 0;

Line 2485: l_data cn_import_pvt.char_data_set_type;

2481: l_return_status VARCHAR2(1);
2482: l_msg_data VARCHAR2(4000);
2483: l_msg_count NUMBER;
2484: l_col_names cn_import_pvt.char_data_set_type;
2485: l_data cn_import_pvt.char_data_set_type;
2486: l_rowcount NUMBER := 0;
2487: l_longcount NUMBER := 0;
2488: l_rec_num NUMBER := 0;
2489: l_message VARCHAR2(4000);

Line 2644: cn_import_pvt.update_imp_headers(p_imp_header_id => p_imp_header_id, p_status_code => 'FAIL'

2640: , x_msg_data => l_msg_data
2641: );
2642:
2643: IF l_return_status <> fnd_api.g_ret_sts_success THEN
2644: cn_import_pvt.update_imp_headers(p_imp_header_id => p_imp_header_id, p_status_code => 'FAIL'
2645: , p_failed_row => l_rowcount);
2646: cn_message_pkg.WRITE(
2647: p_message_text => 'Export threw exception : rts sts ' || l_return_status
2648: , p_message_type => 'ERROR'

Line 2662: cn_import_pvt.update_imp_headers(

2658: retcode := 2;
2659: errbuf := l_message;
2660: ELSE
2661: -- normal completion
2662: cn_import_pvt.update_imp_headers(
2663: p_imp_header_id => p_imp_header_id
2664: , p_status_code => 'COMPLETE'
2665: , p_processed_row => l_rowcount
2666: , p_staged_row => l_rowcount - l_longcount