DBA Data[Home] [Help]

APPS.CN_CALC_SQL_EXPS_PVT dependencies on CN_IMPORT_PVT

Line 2195: cn_import_pvt.build_error_rec(p_imp_header_id => p_imp_header_id

2191: , p_message_type => 'MILESTONE'
2192: );
2193:
2194: -- Get source column name list and target column dynamic sql statement
2195: cn_import_pvt.build_error_rec(p_imp_header_id => p_imp_header_id
2196: , x_header_list => l_header_list, x_sql_stmt => l_sql_stmt);
2197:
2198: OPEN get_api_recs;
2199:

Line 2222: cn_import_pvt.update_imp_lines(

2218: IF l_api_rec.expression_name IS NULL OR l_api_rec.sql_select IS NULL THEN
2219: l_failed_row := l_failed_row + 1;
2220: l_error_code := 'CN_IMP_MISS_REQUIRED';
2221: l_message := fnd_message.get_string('CN', 'CN_IMP_MISS_REQUIRED');
2222: cn_import_pvt.update_imp_lines(
2223: p_imp_line_id => l_api_rec.imp_line_id
2224: , p_status_code => 'FAIL'
2225: , p_error_code => l_error_code
2226: );

Line 2227: cn_import_pvt.update_imp_headers(

2223: p_imp_line_id => l_api_rec.imp_line_id
2224: , p_status_code => 'FAIL'
2225: , p_error_code => l_error_code
2226: );
2227: cn_import_pvt.update_imp_headers(
2228: p_imp_header_id => p_imp_header_id
2229: , p_status_code => 'IMPORT_FAIL'
2230: , p_failed_row => l_failed_row
2231: );

Line 2237: cn_import_pvt.write_error_rec(

2233: p_message_text => 'Record ' || TO_CHAR(l_processed_row) || ':'
2234: || l_message
2235: , p_message_type => 'ERROR'
2236: );
2237: cn_import_pvt.write_error_rec(
2238: p_imp_header_id => p_imp_header_id
2239: , p_imp_line_id => l_api_rec.imp_line_id
2240: , p_header_list => l_header_list
2241: , p_sql_stmt => l_sql_stmt

Line 2323: cn_import_pvt.update_imp_lines(

2319: l_error_code := my_message;
2320: my_message := fnd_msg_pub.get(p_encoded => fnd_api.g_false);
2321: END LOOP;
2322:
2323: cn_import_pvt.update_imp_lines(
2324: p_imp_line_id => l_api_rec.imp_line_id
2325: , p_status_code => 'FAIL'
2326: , p_error_code => NULL
2327: , p_error_msg => NVL(l_error_code, 'Unexpected Error')

Line 2329: cn_import_pvt.update_imp_headers(

2325: , p_status_code => 'FAIL'
2326: , p_error_code => NULL
2327: , p_error_msg => NVL(l_error_code, 'Unexpected Error')
2328: );
2329: cn_import_pvt.update_imp_headers(
2330: p_imp_header_id => p_imp_header_id
2331: , p_status_code => 'IMPORT_FAIL'
2332: , p_failed_row => l_failed_row
2333: );

Line 2339: cn_import_pvt.write_error_rec(

2335: p_message_text => 'Record ' || TO_CHAR(l_processed_row) || ':'
2336: || l_message
2337: , p_message_type => 'ERROR'
2338: );
2339: cn_import_pvt.write_error_rec(
2340: p_imp_header_id => p_imp_header_id
2341: , p_imp_line_id => l_api_rec.imp_line_id
2342: , p_header_list => l_header_list
2343: , p_sql_stmt => l_sql_stmt

Line 2350: cn_import_pvt.update_imp_lines(

2346: errbuf := l_message;
2347: GOTO end_loop;
2348: ELSE
2349: l_error_code := '';
2350: cn_import_pvt.update_imp_lines(
2351: p_imp_line_id => l_api_rec.imp_line_id
2352: , p_status_code => 'COMPLETE'
2353: , p_error_code => l_error_code
2354: );

Line 2364: cn_import_pvt.update_imp_headers(

2360: END IF;
2361:
2362: <>
2363: -- update update_imp_headers:process_row
2364: cn_import_pvt.update_imp_headers(
2365: p_imp_header_id => p_imp_header_id
2366: , p_status_code => NULL
2367: , p_processed_row => l_processed_row
2368: );

Line 2374: cn_import_pvt.update_imp_lines(

2370: WHEN OTHERS THEN
2371: l_failed_row := l_failed_row + 1;
2372: l_error_code := SQLCODE;
2373: l_message := SUBSTR(SQLERRM, 1, 2000);
2374: cn_import_pvt.update_imp_lines(
2375: p_imp_line_id => l_api_rec.imp_line_id
2376: , p_status_code => 'FAIL'
2377: , p_error_code => NULL
2378: , p_error_msg => l_message

Line 2380: cn_import_pvt.update_imp_headers(

2376: , p_status_code => 'FAIL'
2377: , p_error_code => NULL
2378: , p_error_msg => l_message
2379: );
2380: cn_import_pvt.update_imp_headers(
2381: p_imp_header_id => p_imp_header_id
2382: , p_status_code => 'IMPORT_FAIL'
2383: , p_processed_row => l_processed_row
2384: , p_failed_row => l_failed_row

Line 2391: cn_import_pvt.write_error_rec(

2387: p_message_text => 'Record ' || TO_CHAR(l_processed_row) || ':'
2388: || l_message
2389: , p_message_type => 'ERROR'
2390: );
2391: cn_import_pvt.write_error_rec(
2392: p_imp_header_id => p_imp_header_id
2393: , p_imp_line_id => l_api_rec.imp_line_id
2394: , p_header_list => l_header_list
2395: , p_sql_stmt => l_sql_stmt

Line 2410: cn_import_pvt.update_imp_headers(

2406: CLOSE get_api_recs;
2407:
2408: IF l_failed_row = 0 AND retcode = 0 THEN
2409: -- update update_imp_headers
2410: cn_import_pvt.update_imp_headers(
2411: p_imp_header_id => p_imp_header_id
2412: , p_status_code => 'COMPLETE'
2413: , p_processed_row => l_processed_row
2414: , p_failed_row => l_failed_row

Line 2466: l_col_names cn_import_pvt.char_data_set_type;

2462: l_process_audit_id cn_process_audits.process_audit_id%TYPE;
2463: l_return_status VARCHAR2(1);
2464: l_msg_data VARCHAR2(4000);
2465: l_msg_count NUMBER;
2466: l_col_names cn_import_pvt.char_data_set_type;
2467: l_data cn_import_pvt.char_data_set_type;
2468: l_rowcount NUMBER := 0;
2469: l_longcount NUMBER := 0;
2470: l_rec_num NUMBER := 0;

Line 2467: l_data cn_import_pvt.char_data_set_type;

2463: l_return_status VARCHAR2(1);
2464: l_msg_data VARCHAR2(4000);
2465: l_msg_count NUMBER;
2466: l_col_names cn_import_pvt.char_data_set_type;
2467: l_data cn_import_pvt.char_data_set_type;
2468: l_rowcount NUMBER := 0;
2469: l_longcount NUMBER := 0;
2470: l_rec_num NUMBER := 0;
2471: l_message VARCHAR2(4000);

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

2622: , x_msg_data => l_msg_data
2623: );
2624:
2625: IF l_return_status <> fnd_api.g_ret_sts_success THEN
2626: cn_import_pvt.update_imp_headers(p_imp_header_id => p_imp_header_id, p_status_code => 'FAIL'
2627: , p_failed_row => l_rowcount);
2628: cn_message_pkg.WRITE(
2629: p_message_text => 'Export threw exception : rts sts ' || l_return_status
2630: , p_message_type => 'ERROR'

Line 2644: cn_import_pvt.update_imp_headers(

2640: retcode := 2;
2641: errbuf := l_message;
2642: ELSE
2643: -- normal completion
2644: cn_import_pvt.update_imp_headers(
2645: p_imp_header_id => p_imp_header_id
2646: , p_status_code => 'COMPLETE'
2647: , p_processed_row => l_rowcount
2648: , p_staged_row => l_rowcount - l_longcount