[Home] [Help]
966: close party_mapped;
967:
968: -- FND_PROFILE.Get('CONC_REQUEST_ID', l_request_id);
969: l_request_id := FND_GLOBAL.CONC_REQUEST_ID;
970: AMS_Utility_PVT.Create_Log (
971: x_return_status => l_return_status,
972: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
973: p_log_used_by_id => p_import_list_header_id,
974: p_msg_data => 'IN import to HZ Request Id: '|| to_char(l_request_id),
993: if l_total_recs = 0 then
994: open c_header_status;
995: fetch c_header_status into i_batch_size,l_parent_request_id;
996: close c_header_status;
997: AMS_Utility_PVT.Create_Log (
998: x_return_status => l_return_status,
999: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
1000: p_log_used_by_id => p_import_list_header_id,
1001: p_msg_data => 'l_parent_request_id = '|| to_char(l_parent_request_id),
1001: p_msg_data => 'l_parent_request_id = '|| to_char(l_parent_request_id),
1002: p_msg_type => 'DEBUG'
1003: );
1004: if l_request_id = l_parent_request_id then
1005: AMS_Utility_PVT.Create_Log (
1006: x_return_status => l_ret_status,
1007: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
1008: p_log_used_by_id => p_import_list_header_id,
1009: p_msg_data => 'Stop processing size = '||to_char(i_batch_size),
1013:
1014: --TCA mandate: bug 4587049
1015: --Enable/restore TCA events status
1016: --g_prof := fnd_profile.value('HZ_EXECUTE_API_CALLOUTS');
1017: AMS_Utility_PVT.Create_Log (
1018: x_return_status => l_return_status,
1019: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
1020: p_log_used_by_id => p_import_list_header_id,
1021: p_msg_data => 'Restoring g_prof HZ_EXECUTE_API_CALLOUTS: '|| g_prof,
1026: end if;
1027:
1028: update_cust_import_status(p_import_list_header_id);
1029: end if;
1030: AMS_Utility_PVT.Create_Log (
1031: x_return_status => l_return_status,
1032: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
1033: p_log_used_by_id => p_import_list_header_id,
1034: p_msg_data => 'AMSILHZC ----- no records to process ZERO not submittng any child request.',
1038: end if;
1039: ELSE
1040: l_req_data := fnd_conc_global.request_data;
1041: /*
1042: AMS_Utility_PVT.Create_Log (
1043: x_return_status => l_return_status,
1044: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
1045: p_log_used_by_id => p_import_list_header_id,
1046: p_msg_data => 'l_req_data : '|| l_req_data,
1052: else
1053: l_req_data_counter := 1;
1054: end if;
1055: /*
1056: AMS_Utility_PVT.Create_Log (
1057: x_return_status => l_return_status,
1058: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
1059: p_log_used_by_id => p_import_list_header_id,
1060: p_msg_data => 'l_req_data_counter : '|| to_char(l_req_data_counter),
1067: else
1068: l_batch_size := ROUND(l_total_recs / l_numb_of_inst) + 1;
1069: end if;
1070:
1071: AMS_Utility_PVT.Create_Log (
1072: x_return_status => l_return_status,
1073: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
1074: p_log_used_by_id => p_import_list_header_id,
1075: p_msg_data => 'l_batch_size : '|| to_char(l_batch_size),
1085: parent_request_id = l_request_id
1086: where import_list_header_id = p_import_list_header_id;
1087: commit;
1088:
1089: AMS_Utility_PVT.Create_Log (
1090: x_return_status => l_return_status,
1091: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
1092: p_log_used_by_id => p_import_list_header_id,
1093: p_msg_data => 'l_numb_of_inst : '|| to_char(l_numb_of_inst),
1095:
1096: --TCA mandate: bug 4587049
1097: --Disable TCA events just before starting list import child to process TCA data
1098: --g_prof := fnd_profile.value('HZ_EXECUTE_API_CALLOUTS');
1099: AMS_Utility_PVT.Create_Log (
1100: x_return_status => l_return_status,
1101: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
1102: p_log_used_by_id => p_import_list_header_id,
1103: p_msg_data => 'Disabling g_prof HZ_EXECUTE_API_CALLOUTS: '|| g_prof,
1115: sub_request => TRUE,
1116: argument1 => p_import_list_header_id,
1117: argument2 => 0);
1118:
1119: AMS_Utility_PVT.Create_Log (
1120: x_return_status => l_return_status,
1121: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
1122: p_log_used_by_id => p_import_list_header_id,
1123: p_msg_data => 'List Import Child Req : -- concurrent program_id is '||to_char(new_request_id),
1124: p_msg_type => 'DEBUG'
1125: );
1126: IF new_request_id = 0 THEN
1127: -- RAISE FND_API.g_exc_unexpected_error;
1128: AMS_Utility_PVT.Create_Log (
1129: x_return_status => l_return_status,
1130: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
1131: p_log_used_by_id => p_import_list_header_id,
1132: p_msg_data => 'List Import Child Req : Error in submitting request',
1159: end if;
1160: */
1161: END LOOP;
1162: /*
1163: AMS_Utility_PVT.Create_Log (
1164: x_return_status => l_return_status,
1165: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
1166: p_log_used_by_id => p_import_list_header_id,
1167: p_msg_data => 'Start child prog pause --l_req_data_counter= '||to_char(l_req_data_counter),
1170: fnd_conc_global.set_req_globals(conc_status => 'PAUSED',
1171: request_data => to_char(l_req_data_counter));
1172:
1173: /*
1174: AMS_Utility_PVT.Create_Log (
1175: x_return_status => l_return_status,
1176: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
1177: p_log_used_by_id => p_import_list_header_id,
1178: p_msg_data => 'End AMSILHZC '||to_char(sysdate),
1187:
1188: -- *****************************************************
1189:
1190: if x_b2b = 'B2B' then
1191: AMS_Utility_PVT.Create_Log (
1192: x_return_status => l_ret_status,
1193: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
1194: p_log_used_by_id => p_import_list_header_id,
1195: p_msg_data => 'TCA import -- Start b2b customer import',
1752:
1753: -- >>>>>>>>>>>>>>>>>>>>>>><<<<<<<<<<<<<<<<<<<<<<<<<<
1754: if x_b2b = 'B2C' then
1755: i_number_of_rows_processed := 0;
1756: AMS_Utility_PVT.Create_Log (
1757: x_return_status => l_ret_status,
1758: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
1759: p_log_used_by_id => p_import_list_header_id,
1760: p_msg_data => 'TCA import -- Start b2c customer import',
1762: );
1763:
1764: OPEN b2c;
1765: LOOP
1766: AMS_Utility_PVT.Create_Log (
1767: x_return_status => l_ret_status,
1768: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
1769: p_log_used_by_id => p_import_list_header_id,
1770: p_msg_data => 'before FETCH .................. ',
1928:
1929: if b2c%notfound then
1930: exit;
1931: end if;
1932: AMS_Utility_PVT.Create_Log (
1933: x_return_status => l_ret_status,
1934: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
1935: p_log_used_by_id => p_import_list_header_id,
1936: p_msg_data => 'After FETCH .................. ',
1939: -- sranka 1/17/2003
1940: -- i_import_source_line_id := person_rec.party_rec.orig_system_reference; //original
1941: i_import_source_line_id := l_import_source_line_id;
1942:
1943: AMS_Utility_PVT.Create_Log (
1944: x_return_status => l_ret_status,
1945: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
1946: p_log_used_by_id => p_import_list_header_id,
1947: p_msg_data => 'before Create_Customer ',
1985: p_component_name => x_component_name,
1986: l_import_source_line_id => l_import_source_line_id
1987: );
1988:
1989: AMS_Utility_PVT.Create_Log (
1990: x_return_status => l_ret_status,
1991: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
1992: p_log_used_by_id => p_import_list_header_id,
1993: p_msg_data => 'after Create_Customer ' ,
1993: p_msg_data => 'after Create_Customer ' ,
1994: p_msg_type => 'DEBUG'
1995: );
1996:
1997: AMS_Utility_PVT.Create_Log (
1998: x_return_status => l_ret_status,
1999: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2000: p_log_used_by_id => p_import_list_header_id,
2001: p_msg_data => 'after Create_Customer x_return_status = '||x_return_status,
2001: p_msg_data => 'after Create_Customer x_return_status = '||x_return_status,
2002: p_msg_type => 'DEBUG'
2003: );
2004:
2005: AMS_Utility_PVT.Create_Log (
2006: x_return_status => l_ret_status,
2007: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2008: p_log_used_by_id => p_import_list_header_id,
2009: p_msg_data => 'after Create_Customer x_msg_count = '||to_char(x_msg_count),
2009: p_msg_data => 'after Create_Customer x_msg_count = '||to_char(x_msg_count),
2010: p_msg_type => 'DEBUG'
2011: );
2012:
2013: AMS_Utility_PVT.Create_Log (
2014: x_return_status => l_ret_status,
2015: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2016: p_log_used_by_id => p_import_list_header_id,
2017: p_msg_data => 'after Create_Customer x_msg_data = '||x_msg_data,
2152: /*
2153: open c_header_status;
2154: fetch c_header_status into i_batch_size,l_parent_request_id;
2155: close c_header_status;
2156: AMS_Utility_PVT.Create_Log (
2157: x_return_status => l_ret_status,
2158: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2159: p_log_used_by_id => p_import_list_header_id,
2160: p_msg_data => 'Stop processing size = '||to_char(i_batch_size),
2165: end if;
2166: */
2167: errbuf:= 'TCA import Program(-)';
2168: retcode:=0;
2169: AMS_Utility_PVT.Create_Log (
2170: x_return_status => l_ret_status,
2171: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2172: p_log_used_by_id => p_import_list_header_id,
2173: p_msg_data => 'TCA import Program(-)',
2206: where import_list_header_id = p_import_list_header_id;
2207: commit;
2208: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
2209: FND_MESSAGE.Set_Token('ROW','Error in TCA load program ' || SQLERRM||' '||SQLCODE);
2210: AMS_Utility_PVT.Create_Log (
2211: x_return_status => l_return_status,
2212: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2213: p_log_used_by_id => p_import_list_header_id,
2214: p_msg_data => FND_MESSAGE.get,
2362: and load_status in ('RELOAD','ACTIVE');
2363:
2364:
2365:
2366: AMS_Utility_PVT.Create_Log (
2367: x_return_status => l_return_status,
2368: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2369: p_log_used_by_id => p_import_list_header_id,
2370: p_msg_data => 'Starting List Import in RELOAD Mode.',
2413: status_date = sysdate
2414: where import_list_header_id = p_import_list_header_id;
2415: -- end ndadwal changes
2416:
2417: AMS_Utility_PVT.Create_Log (
2418: x_return_status => l_return_status,
2419: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2420: p_log_used_by_id => p_import_list_header_id,
2421: p_msg_data => 'Starting SQL*LOADER program to load the data.',
2458: );
2459:
2460: IF l_request_id = 0 THEN
2461: l_mesg_text := fnd_message.get;
2462: AMS_Utility_PVT.Create_Log (
2463: x_return_status => l_return_status,
2464: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2465: p_log_used_by_id => p_import_list_header_id,
2466: p_msg_data => l_mesg_text,
2480: ELSE
2481: FND_MESSAGE.set_name ('AMS', 'AMS_IMP_LOAD_REQUEST_ID');
2482: FND_MESSAGE.set_token ('REQUEST_ID', l_request_id);
2483:
2484: Ams_Utility_PVT.Create_Log (
2485: x_return_status => l_return_status,
2486: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2487: p_log_used_by_id => p_import_list_header_id,
2488: p_msg_data => FND_MESSAGE.get,
2489: p_msg_type => 'MILESTONE'
2490: );
2491: END IF;
2492: Commit;
2493: AMS_Utility_PVT.Create_Log (
2494: x_return_status => l_return_status,
2495: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2496: p_log_used_by_id => p_import_list_header_id,
2497: p_msg_data => 'SQL*LOADER -- For details Please check the log file '||p_control_file||'.log',
2497: p_msg_data => 'SQL*LOADER -- For details Please check the log file '||p_control_file||'.log',
2498: p_msg_type => 'DEBUG'
2499: );
2500:
2501: AMS_Utility_PVT.Create_Log (
2502: x_return_status => l_return_status,
2503: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2504: p_log_used_by_id => p_import_list_header_id,
2505: p_msg_data => 'SQL*LOADER -- For bad records Please check the bad file '||p_control_file||'.bad',
2530: -- submitted.
2531: ---------------------------------------------
2532: IF NOT l_wait_status THEN
2533: l_mesg_text := fnd_message.get;
2534: AMS_Utility_PVT.Create_Log (
2535: x_return_status => l_return_status,
2536: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2537: p_log_used_by_id => p_import_list_header_id,
2538: p_msg_data => l_mesg_text,
2558:
2559: FND_MESSAGE.set_name ('AMS', 'AMS_IMP_LOADED_NO_ROWS');
2560: FND_MESSAGE.set_token ('NUM_ROWS', l_loaded_rows);
2561:
2562: Ams_Utility_PVT.Create_Log (
2563: x_return_status => l_return_status,
2564: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2565: p_log_used_by_id => p_import_list_header_id,
2566: p_msg_data => FND_MESSAGE.get,
2612: open c_rec_in_stag_tab;
2613: fetch c_rec_in_stag_tab into l_rec_in_stag_tab;
2614: close c_rec_in_stag_tab;
2615: if l_rec_in_stag_tab is NULL then
2616: AMS_Utility_PVT.Create_Log (
2617: x_return_status => l_return_status,
2618: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2619: p_log_used_by_id => p_import_list_header_id,
2620: p_msg_data => 'Aborting import process, Staging table not populated.',
2701: end if;
2702: org_existence_checking(x_import_list_header_id,
2703: x_return_status,x_msg_count,x_msg_data);
2704: if x_return_status <> 'S' then
2705: AMS_Utility_PVT.Create_Log (
2706: x_return_status => l_return_status,
2707: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2708: p_log_used_by_id => p_import_list_header_id,
2709: p_msg_data => 'Aborting org_existence_checking.',
2728: end if;
2729: org_cont_existence_checking(x_import_list_header_id,
2730: x_return_status,x_msg_count,x_msg_data);
2731: if x_return_status <> 'S' then
2732: AMS_Utility_PVT.Create_Log (
2733: x_return_status => l_return_status,
2734: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2735: p_log_used_by_id => p_import_list_header_id,
2736: p_msg_data => 'Aborting org_cont_existence_checking.',
2750:
2751: org_address_existence_checking(x_import_list_header_id,
2752: x_return_status,x_msg_count,x_msg_data);
2753: if x_return_status <> 'S' then
2754: AMS_Utility_PVT.Create_Log (
2755: x_return_status => l_return_status,
2756: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2757: p_log_used_by_id => p_import_list_header_id,
2758: p_msg_data => 'Aborting org_address_existence_checking.',
2772:
2773: org_address1_exist_checking(x_import_list_header_id,
2774: x_return_status,x_msg_count,x_msg_data);
2775: if x_return_status <> 'S' then
2776: AMS_Utility_PVT.Create_Log (
2777: x_return_status => l_return_status,
2778: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2779: p_log_used_by_id => p_import_list_header_id,
2780: p_msg_data => 'Aborting org_address1_exist_checking.',
2800: end if;
2801: per_existence_checking(x_import_list_header_id,
2802: x_return_status,x_msg_count,x_msg_data);
2803: if x_return_status <> 'S' then
2804: AMS_Utility_PVT.Create_Log (
2805: x_return_status => l_return_status,
2806: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2807: p_log_used_by_id => p_import_list_header_id,
2808: p_msg_data => 'Aborting per_existence_checking.',
2822:
2823: per_address_existence_checking(x_import_list_header_id,
2824: x_return_status,x_msg_count,x_msg_data);
2825: if x_return_status <> 'S' then
2826: AMS_Utility_PVT.Create_Log (
2827: x_return_status => l_return_status,
2828: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2829: p_log_used_by_id => p_import_list_header_id,
2830: p_msg_data => 'Aborting per_address_existence_checking.',
2846: end if; -- if x_hz_dup_check = 'Y' then
2847: -- >>>>>>>>>>>>>
2848:
2849: if l_dedupe_flag = 'Y' then
2850: AMS_Utility_PVT.Create_Log (
2851: x_return_status => l_return_status,
2852: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2853: p_log_used_by_id => p_import_list_header_id,
2854: p_msg_data => 'Starting De-Duplicate check in the Marketing tables .',
2863: update ams_imp_list_headers_all
2864: set number_of_duplicate_records = l_duplicate_records
2865: where import_list_header_id = p_import_list_header_id;
2866:
2867: AMS_Utility_PVT.Create_Log (
2868: x_return_status => l_return_status,
2869: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2870: p_log_used_by_id => p_import_list_header_id,
2871: p_msg_data => 'END De-Duplicate check in the Marketing tables .',
2874: end if;
2875:
2876: if p_staged_only = 'N' then
2877: if l_st_code = 'STAGED' then
2878: AMS_Utility_PVT.Create_Log (
2879: x_return_status => l_return_status,
2880: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2881: p_log_used_by_id => p_import_list_header_id,
2882: p_msg_data => 'Starting TCA/LEAD/EVENT program to load the data.',
2884: );
2885: open c_total_records;
2886: fetch c_total_records into l_total_records;
2887: close c_total_records;
2888: AMS_Utility_PVT.Create_Log (
2889: x_return_status => l_return_status,
2890: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2891: p_log_used_by_id => p_import_list_header_id,
2892: p_msg_data => 'Total Number of records available for processing: '||to_char(l_total_records),
2908: l_total_records := 0;
2909: open c_total_records;
2910: fetch c_total_records into l_total_records;
2911: close c_total_records;
2912: AMS_Utility_PVT.Create_Log (
2913: x_return_status => l_return_status,
2914: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2915: p_log_used_by_id => p_import_list_header_id,
2916: p_msg_data => 'Total Number of records not processed: '||to_char(l_total_records),
2922: -- commenting out follwoing code as list gen was already called by AMSILHZC conc prog
2923: -- spawned from within list_loader API. This was generating a duplicate list.
2924: /*
2925: if p_generate_list = 'Y' then
2926: AMS_Utility_PVT.Create_Log (
2927: x_return_status => l_return_status,
2928: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2929: p_log_used_by_id => p_import_list_header_id,
2930: p_msg_data => 'Starting List Generation for List Import.',
2950: l_list_header_id,
2951: p_list_name) ;
2952:
2953: If i_return_status <> 'S' then
2954: AMS_Utility_PVT.Create_Log (
2955: x_return_status => l_return_status,
2956: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2957: p_log_used_by_id => p_import_list_header_id,
2958: p_msg_data => 'Error in List Generation --'||i_msg_data,
2959: p_msg_type => 'DEBUG'
2960: );
2961: End if;
2962: end if;
2963: AMS_Utility_PVT.Create_Log (
2964: x_return_status => l_return_status,
2965: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2966: p_log_used_by_id => p_import_list_header_id,
2967: p_msg_data => 'End List Generation for List Import.',
2975: -- Import completed successfully
2976: FND_MESSAGE.set_name ('AMS', 'AMS_IMP_LOAD_COMPLETE');
2977: FND_MESSAGE.set_token ('REQUEST_ID', l_request_id);
2978:
2979: AMS_Utility_PVT.Create_Log (
2980: x_return_status => l_return_status,
2981: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2982: p_log_used_by_id => p_import_list_header_id,
2983: p_msg_data => FND_MESSAGE.get,
2988: retcode := 0; -- no problems.
2989:
2990: EXCEPTION
2991: WHEN OTHERS THEN
2992: AMS_Utility_PVT.Create_Log (
2993: x_return_status => l_return_status,
2994: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
2995: p_log_used_by_id => p_import_list_header_id,
2996: p_msg_data => sqlerrm ,
2999: FND_MESSAGE.set_name ('AMS', 'AMS_IMP_LOAD_FAILED');
3000: FND_MESSAGE.set_token ('REQUEST_ID', l_request_id);
3001: l_msg_buf := FND_MESSAGE.get;
3002:
3003: AMS_Utility_PVT.Create_Log (
3004: x_return_status => l_return_status,
3005: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
3006: p_log_used_by_id => p_import_list_header_id,
3007: p_msg_data => l_msg_buf,
3101: -- if l_import_type = 'CUSTOMER' then
3102: if (l_import_type = 'B2B' or l_import_type = 'B2C') then
3103: -- Call the Validate Process
3104: if l_validate_file = 'Y' then
3105: AMS_Utility_PVT.Create_Log (
3106: x_return_status => l_return_status,
3107: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
3108: p_log_used_by_id => p_import_list_header_id,
3109: p_msg_data => 'Starting Validation for Customer data.',
3126: */
3127: l_return_status := null;
3128: execute_cust_data_validation ( p_import_list_header_id, l_return_status);
3129: if l_return_status <> 'S' then
3130: AMS_Utility_PVT.Create_Log (
3131: x_return_status => l_return_status,
3132: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
3133: p_log_used_by_id => p_import_list_header_id,
3134: p_msg_data => 'Customer import terminated because of error in Data validation process.',
3148: where import_list_header_id = p_import_list_header_id;
3149: return;
3150: end if;
3151:
3152: AMS_Utility_PVT.Create_Log (
3153: x_return_status => l_return_status,
3154: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
3155: p_log_used_by_id => p_import_list_header_id,
3156: p_msg_data => 'End Validation for Customer data.',
3164: argument1 => p_import_list_header_id,
3165: argument2 => l_numb_of_inst
3166: );
3167:
3168: AMS_Utility_PVT.Create_Log (
3169: x_return_status => l_return_status,
3170: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
3171: p_log_used_by_id => p_import_list_header_id,
3172: p_msg_data => 'Starting TCA program (AMSILHZC) -- concurrent program_id is '||to_char(l_request_id),
3176: end if;
3177:
3178: IF l_request_id = 0 THEN
3179: l_mesg_text := fnd_message.get;
3180: AMS_Utility_PVT.Create_Log (
3181: x_return_status => l_return_status,
3182: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
3183: p_log_used_by_id => p_import_list_header_id,
3184: p_msg_data => l_mesg_text,
3216: application => 'AMS',
3217: program => 'AMSILLDC',
3218: argument1 => p_import_list_header_id
3219: );
3220: AMS_Utility_PVT.Create_Log (
3221: x_return_status => l_return_status,
3222: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
3223: p_log_used_by_id => p_import_list_header_id,
3224: p_msg_data => 'Starting LEAD program (ASXSLIMP) -- concurrent program_id is '||to_char(l_request_id),
3233: */
3234: if l_import_type = 'EVENT' then
3235: -- Call the Validate Process
3236: if l_validate_file = 'Y' then
3237: AMS_Utility_PVT.Create_Log (
3238: x_return_status => l_return_status,
3239: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
3240: p_log_used_by_id => p_import_list_header_id,
3241: p_msg_data => 'Starting Validation for Event data.',
3252:
3253: l_return_status := null;
3254: execute_event_data_validation ( p_import_list_header_id, l_return_status);
3255: if l_return_status <> 'S' then
3256: AMS_Utility_PVT.Create_Log (
3257: x_return_status => l_return_status,
3258: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
3259: p_log_used_by_id => p_import_list_header_id,
3260: p_msg_data => 'Event import terminated because of error in Data validation process.',
3274: where import_list_header_id = p_import_list_header_id;
3275: return;
3276: end if;
3277:
3278: AMS_Utility_PVT.Create_Log (
3279: x_return_status => l_return_status,
3280: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
3281: p_log_used_by_id => p_import_list_header_id,
3282: p_msg_data => 'End Validation for Event data.',
3289: program => l_conc_prog_name, -- ' AMSERIMP',
3290: argument1 => p_import_list_header_id
3291: );
3292:
3293: AMS_Utility_PVT.Create_Log (
3294: x_return_status => l_return_status,
3295: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
3296: p_log_used_by_id => p_import_list_header_id,
3297: p_msg_data => 'Starting EVENT program (AMSERIMP) -- concurrent program_id is '||to_char(l_request_id),
3319: -- submitted.
3320: ---------------------------------------------
3321: IF NOT l_wait_status THEN
3322: l_mesg_text := fnd_message.get;
3323: AMS_Utility_PVT.Create_Log (
3324: x_return_status => l_return_status,
3325: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
3326: p_log_used_by_id => p_import_list_header_id,
3327: p_msg_data => l_mesg_text,
3417: end if;
3418:
3419: EXCEPTION
3420: WHEN others THEN
3421: AMS_Utility_PVT.Create_Log (
3422: x_return_status => l_return_status,
3423: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
3424: p_log_used_by_id => p_import_list_header_id,
3425: p_msg_data => sqlerrm ,
3468:
3469:
3470: begin
3471:
3472: AMS_Utility_PVT.Create_Log (
3473: x_return_status => l_ret_status,
3474: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
3475: p_log_used_by_id => p_import_list_header_id,
3476: p_msg_data => 'Starting List Import Process',
3485: open c_file_type;
3486: fetch c_file_type into l_file_type;
3487: close c_file_type;
3488: if l_file_type is NULL then
3489: AMS_Utility_PVT.Create_Log (
3490: x_return_status => l_return_status,
3491: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
3492: p_log_used_by_id => p_import_list_header_id,
3493: p_msg_data => 'Aborting import process, File type missing.',
3510: open c_imptype;
3511: fetch c_imptype into x_imp_type;
3512: close c_imptype;
3513: if (l_file_type = 'XML' and x_imp_type in ('LEAD','EVENT')) then
3514: AMS_Utility_PVT.Create_Log (
3515: x_return_status => l_return_status,
3516: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
3517: p_log_used_by_id => p_import_list_header_id,
3518: p_msg_data => 'XML import is not available for EVENT and LEADS, Aborting import process',
3546: argument6 => p_list_name
3547: );
3548: IF l_request_id = 0 THEN
3549: l_mesg_text := fnd_message.get;
3550: AMS_Utility_PVT.Create_Log (
3551: x_return_status => l_return_status,
3552: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
3553: p_log_used_by_id => p_import_list_header_id,
3554: p_msg_data => l_mesg_text,
3566: commit;
3567:
3568: RAISE FND_API.g_exc_unexpected_error;
3569: end if;
3570: AMS_Utility_PVT.Create_Log (
3571: x_return_status => l_ret_status,
3572: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
3573: p_log_used_by_id => p_import_list_header_id,
3574: p_msg_data => 'List Import Concurrent Program AMSILOMC Started.',
3630: where import_list_header_id = p_import_list_header_id;
3631: commit;
3632:
3633: if (x_file_type = 'XML' and x_imp_type in ('LEAD','EVENT')) then
3634: AMS_Utility_PVT.Create_Log (
3635: x_return_status => l_return_status,
3636: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
3637: p_log_used_by_id => p_import_list_header_id,
3638: p_msg_data => 'XML import is not available for EVENT and LEADS, Aborting import process',
3657: argument2 => p_owner_user_id,
3658: argument3 => p_generate_list,
3659: argument4 => p_list_name
3660: );
3661: AMS_Utility_PVT.Create_Log (
3662: x_return_status => l_return_status,
3663: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
3664: p_log_used_by_id => p_import_list_header_id,
3665: p_msg_data => 'Starting client side import program (AMSIMCCM) -- concurrent program_id is '||to_char(l_request_id),
3666: p_msg_type => 'DEBUG');
3667: commit;
3668: IF l_request_id = 0 THEN
3669: l_mesg_text := fnd_message.get;
3670: AMS_Utility_PVT.Create_Log (
3671: x_return_status => l_return_status,
3672: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
3673: p_log_used_by_id => p_import_list_header_id,
3674: p_msg_data => l_mesg_text,
3688: end if;
3689:
3690: EXCEPTION
3691: WHEN others THEN
3692: AMS_Utility_PVT.Create_Log (
3693: x_return_status => l_return_status,
3694: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
3695: p_log_used_by_id => p_import_list_header_id,
3696: p_msg_data => sqlerrm ,
3778: open c_rule_type ;
3779: fetch c_rule_type into l_rule_type;
3780: close c_rule_type;
3781:
3782: AMS_Utility_PVT.Create_Log (
3783: x_return_status => l_return_status,
3784: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
3785: p_log_used_by_id => p_import_list_header_id,
3786: p_msg_data => 'Dedupe Check Rule Type '||l_rule_type,
3790: open c_ruleid (l_rule_type);
3791: fetch c_ruleid into i_rule_id;
3792: close c_ruleid;
3793:
3794: AMS_Utility_PVT.Create_Log (
3795: x_return_status => l_return_status,
3796: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
3797: p_log_used_by_id => p_import_list_header_id,
3798: p_msg_data => 'Dedupe Check Rule Id '||i_rule_id,
3887: AND b.import_list_header_id = p_import_list_header_id
3888: );
3889: exception
3890: when others then
3891: AMS_Utility_PVT.Create_Log (
3892: x_return_status => l_return_status,
3893: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
3894: p_log_used_by_id => p_import_list_header_id,
3895: p_msg_data => sqlerrm ,
3918: OPEN c_error;
3919: LOOP
3920: FETCH c_error into i_lead_error;
3921: exit when c_error%notfound;
3922: AMS_Utility_PVT.Create_Log (
3923: x_return_status => l_ret_status,
3924: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
3925: p_log_used_by_id => p_import_list_header_id,
3926: p_msg_data => 'Lead Error- '||i_lead_error,
3929: END LOOP;
3930: CLOSE c_error;
3931: exception
3932: when others then
3933: AMS_Utility_PVT.Create_Log (
3934: x_return_status => l_ret_status,
3935: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
3936: p_log_used_by_id => p_import_list_header_id,
3937: p_msg_data => sqlerrm ,
4082:
4083:
4084: BEGIN
4085:
4086: AMS_Utility_PVT.Create_Log (
4087: x_return_status => l_return_status,
4088: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
4089: p_log_used_by_id => p_import_list_header_id,
4090: p_msg_data => 'Starting import for LEAD.',
4116: close c_lead_process;
4117:
4118: -- Call the Validate Process
4119: if l_validate_file = 'Y' then
4120: AMS_Utility_PVT.Create_Log (
4121: x_return_status => l_return_status,
4122: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
4123: p_log_used_by_id => p_import_list_header_id,
4124: p_msg_data => 'Starting Validation for LEAD data.',
4135:
4136: x_return_status := null;
4137: execute_lead_data_validation ( p_import_list_header_id,x_return_status );
4138: if x_return_status <> 'S' then
4139: AMS_Utility_PVT.Create_Log (
4140: x_return_status => l_return_status,
4141: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
4142: p_log_used_by_id => p_import_list_header_id,
4143: p_msg_data => 'Lead import terminated because of error in Data validation process.',
4157: where import_list_header_id = p_import_list_header_id;
4158: return;
4159: end if;
4160:
4161: AMS_Utility_PVT.Create_Log (
4162: x_return_status => l_return_status,
4163: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
4164: p_log_used_by_id => p_import_list_header_id,
4165: p_msg_data => 'End Validation for LEAD data.',
4170: fetch c_rec_failed_in_ams into l_rec_failed_in_ams;
4171: close c_rec_failed_in_ams;
4172:
4173: -- Uploads the Lead's interface table.
4174: AMS_Utility_PVT.Create_Log (
4175: x_return_status => l_return_status,
4176: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
4177: p_log_used_by_id => p_import_list_header_id,
4178: p_msg_data => 'Starting LEAD data upload.',
4178: p_msg_data => 'Starting LEAD data upload.',
4179: p_msg_type => 'DEBUG'
4180: );
4181: AMS_ImportClient_PVT.Load_Lead_Data_To_Interface(p_import_list_header_id,x_return_status);
4182: AMS_Utility_PVT.Create_Log (
4183: x_return_status => l_return_status,
4184: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
4185: p_log_used_by_id => p_import_list_header_id,
4186: p_msg_data => 'End LEAD data upload.',
4187: p_msg_type => 'DEBUG'
4188: );
4189:
4190: if x_return_status <> 'S' then
4191: AMS_Utility_PVT.Create_Log (
4192: x_return_status => l_return_status,
4193: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
4194: p_log_used_by_id => p_import_list_header_id,
4195: p_msg_data => 'Lead import terminated because of Data upload error.',
4213: open c_lead_source_system;
4214: fetch c_lead_source_system into l_source_system;
4215: close c_lead_source_system;
4216: if l_source_system is NULL then
4217: AMS_Utility_PVT.Create_Log (
4218: x_return_status => l_return_status,
4219: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
4220: p_log_used_by_id => p_import_list_header_id,
4221: p_msg_data => 'Aborting import process because SOURCE_SYSTEM is NULL.',
4249: argument3 => l_batch_id, -- NULL,
4250: argument4 => 'N'
4251: );
4252:
4253: AMS_Utility_PVT.Create_Log (
4254: x_return_status => l_return_status,
4255: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
4256: p_log_used_by_id => p_import_list_header_id,
4257: p_msg_data => 'Starting LEAD program (ASXSLIMP) -- concurrent program_id is '||to_char(l_request_id),
4259: );
4260:
4261: IF l_request_id = 0 THEN
4262: l_mesg_text := fnd_message.get;
4263: AMS_Utility_PVT.Create_Log (
4264: x_return_status => l_return_status,
4265: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
4266: p_log_used_by_id => p_import_list_header_id,
4267: p_msg_data => l_mesg_text,
4334: set status_code = l_lookup_code,
4335: user_status_id = l_user_status_id,
4336: status_date = sysdate
4337: where import_list_header_id = p_import_list_header_id;
4338: AMS_Utility_PVT.Create_Log (
4339: x_return_status => l_return_status,
4340: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
4341: p_log_used_by_id => p_import_list_header_id,
4342: p_msg_data => 'LEAD program completed with errors Please check the log file.',
4344: );
4345: end if;
4346:
4347: -- Post process for Lead import.
4348: AMS_Utility_PVT.Create_Log (
4349: x_return_status => l_return_status,
4350: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
4351: p_log_used_by_id => p_import_list_header_id,
4352: p_msg_data => 'Starting LEAD post process.',
4352: p_msg_data => 'Starting LEAD post process.',
4353: p_msg_type => 'DEBUG'
4354: );
4355: AMS_ImportClient_PVT.Mark_Insert_Lead_Errors(p_import_list_header_id,x_return_status);
4356: AMS_Utility_PVT.Create_Log (
4357: x_return_status => l_return_status,
4358: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
4359: p_log_used_by_id => p_import_list_header_id,
4360: p_msg_data => 'End LEAD post process.',
4372: SELECT user_status_id into l_user_status_id FROM ams_user_statuses_vl
4373: WHERE system_status_type = 'AMS_IMPORT_STATUS' AND
4374: system_status_code = 'ERROR' and default_flag = 'Y';
4375: */
4376: AMS_Utility_PVT.Create_Log (
4377: x_return_status => l_return_status,
4378: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
4379: p_log_used_by_id => p_import_list_header_id,
4380: p_msg_data => 'Some of the leads in the batch has errors.',
4390: end if;
4391:
4392: -- capture_lead_error(p_import_list_header_id);
4393:
4394: AMS_Utility_PVT.Create_Log (
4395: x_return_status => l_return_status,
4396: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
4397: p_log_used_by_id => p_import_list_header_id,
4398: p_msg_data => 'End client load for LEAD.',
4397: p_log_used_by_id => p_import_list_header_id,
4398: p_msg_data => 'End client load for LEAD.',
4399: p_msg_type => 'DEBUG'
4400: );
4401: AMS_Utility_PVT.Create_Log (
4402: x_return_status => l_return_status,
4403: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
4404: p_log_used_by_id => p_import_list_header_id,
4405: p_msg_data => 'Processing is done for Batch : '||to_char(l_batch_id),
4405: p_msg_data => 'Processing is done for Batch : '||to_char(l_batch_id),
4406: p_msg_type => 'DEBUG'
4407: );
4408:
4409: AMS_Utility_PVT.Create_Log (
4410: x_return_status => l_return_status,
4411: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
4412: p_log_used_by_id => p_import_list_header_id,
4413: p_msg_data => 'Records available for process : '||to_char(l_rec_in_ams),
4413: p_msg_data => 'Records available for process : '||to_char(l_rec_in_ams),
4414: p_msg_type => 'DEBUG'
4415: );
4416:
4417: AMS_Utility_PVT.Create_Log (
4418: x_return_status => l_return_status,
4419: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
4420: p_log_used_by_id => p_import_list_header_id,
4421: p_msg_data => 'Records failed data validation : '||to_char(l_rec_failed_in_ams),
4424:
4425: open c_rec_uploaded_in_as;
4426: fetch c_rec_uploaded_in_as into l_rec_in_as;
4427: close c_rec_uploaded_in_as;
4428: AMS_Utility_PVT.Create_Log (
4429: x_return_status => l_return_status,
4430: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
4431: p_log_used_by_id => p_import_list_header_id,
4432: p_msg_data => 'Records uploaded/available for Lead import process : '||to_char(l_rec_in_as),
4435:
4436: open c_rec_pro_fail_in_as;
4437: fetch c_rec_pro_fail_in_as into l_rec_fail_in_as;
4438: close c_rec_pro_fail_in_as;
4439: AMS_Utility_PVT.Create_Log (
4440: x_return_status => l_return_status,
4441: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
4442: p_log_used_by_id => p_import_list_header_id,
4443: p_msg_data => 'Records failed during Lead import process : '||to_char(l_rec_fail_in_as),
4447:
4448: open c_rec_pro_succ_in_as;
4449: fetch c_rec_pro_succ_in_as into l_rec_succ_in_as;
4450: close c_rec_pro_succ_in_as;
4451: AMS_Utility_PVT.Create_Log (
4452: x_return_status => l_return_status,
4453: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
4454: p_log_used_by_id => p_import_list_header_id,
4455: p_msg_data => 'Records successfully processed Lead import : '||to_char(l_rec_succ_in_as),
4459: open c_rec_pro_dup_in_as;
4460: fetch c_rec_pro_dup_in_as into l_rec_dup_in_as;
4461: close c_rec_pro_dup_in_as;
4462: if nvl(l_rec_dup_in_as,0) > 0 then
4463: AMS_Utility_PVT.Create_Log (
4464: x_return_status => l_return_status,
4465: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
4466: p_log_used_by_id => p_import_list_header_id,
4467: p_msg_data => 'Duplicate Leads in Lead import process : '||to_char(l_rec_dup_in_as),
4481:
4482:
4483: exception
4484: when others then
4485: AMS_Utility_PVT.Create_Log (
4486: x_return_status => l_ret_status,
4487: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
4488: p_log_used_by_id => p_import_list_header_id,
4489: p_msg_data => sqlerrm ,
7660: WHEN OTHERS THEN
7661: p_return_status := FND_API.G_RET_STS_ERROR;
7662: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
7663: FND_MESSAGE.Set_Token('ROW','Error in execute_lead_data_validation:' || SQLERRM||' '||SQLCODE);
7664: AMS_Utility_PVT.Create_Log (
7665: x_return_status => l_return_status,
7666: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
7667: p_log_used_by_id => p_import_list_header_id,
7668: p_msg_data => FND_MESSAGE.get,
7777: l_col4 := null;
7778: l_col5 := null;
7779: l_col6 := null;
7780: /*
7781: AMS_Utility_PVT.Create_Log (
7782: x_return_status => l_return_status,
7783: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
7784: p_log_used_by_id => p_import_list_header_id,
7785: p_msg_data => 'p_column1 = '||p_column1,
7784: p_log_used_by_id => p_import_list_header_id,
7785: p_msg_data => 'p_column1 = '||p_column1,
7786: p_msg_type => 'DEBUG'
7787: );
7788: AMS_Utility_PVT.Create_Log (
7789: x_return_status => l_return_status,
7790: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
7791: p_log_used_by_id => p_import_list_header_id,
7792: p_msg_data => 'p_column2 = '||p_column2,
7791: p_log_used_by_id => p_import_list_header_id,
7792: p_msg_data => 'p_column2 = '||p_column2,
7793: p_msg_type => 'DEBUG'
7794: );
7795: AMS_Utility_PVT.Create_Log (
7796: x_return_status => l_return_status,
7797: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
7798: p_log_used_by_id => p_import_list_header_id,
7799: p_msg_data => 'p_column3 = '||p_column3,
7798: p_log_used_by_id => p_import_list_header_id,
7799: p_msg_data => 'p_column3 = '||p_column3,
7800: p_msg_type => 'DEBUG'
7801: );
7802: AMS_Utility_PVT.Create_Log (
7803: x_return_status => l_return_status,
7804: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
7805: p_log_used_by_id => p_import_list_header_id,
7806: p_msg_data => 'p_column4 = '||p_column4,
7805: p_log_used_by_id => p_import_list_header_id,
7806: p_msg_data => 'p_column4 = '||p_column4,
7807: p_msg_type => 'DEBUG'
7808: );
7809: AMS_Utility_PVT.Create_Log (
7810: x_return_status => l_return_status,
7811: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
7812: p_log_used_by_id => p_import_list_header_id,
7813: p_msg_data => 'p_column5 = '||p_column5,
7812: p_log_used_by_id => p_import_list_header_id,
7813: p_msg_data => 'p_column5 = '||p_column5,
7814: p_msg_type => 'DEBUG'
7815: );
7816: AMS_Utility_PVT.Create_Log (
7817: x_return_status => l_return_status,
7818: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
7819: p_log_used_by_id => p_import_list_header_id,
7820: p_msg_data => 'p_column6 = '||p_column6,
7824: if p_column1 is not null then
7825: begin
7826: -- l_date1 := to_date(p_column1,'MM/DD/YYYY');
7827: select to_date(p_column1, x_date_format) into l_date1 from dual;
7828: AMS_Utility_PVT.Create_Log (
7829: x_return_status => l_return_status,
7830: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
7831: p_log_used_by_id => p_import_list_header_id,
7832: p_msg_data => 'l_date1 = '||to_char(l_date1),
7841: if p_column2 is not null then
7842: begin
7843: -- l_date2 := to_date(p_column2,'MM/DD/YYYY');
7844: select to_date(p_column2, x_date_format) into l_date2 from dual;
7845: AMS_Utility_PVT.Create_Log (
7846: x_return_status => l_return_status,
7847: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
7848: p_log_used_by_id => p_import_list_header_id,
7849: p_msg_data => 'l_date2 = '||to_char(l_date2),
7858: if p_column3 is not null then
7859: begin
7860: -- l_date3 := to_date(p_column3,'MM/DD/YYYY');
7861: select to_date(p_column3, x_date_format) into l_date3 from dual;
7862: AMS_Utility_PVT.Create_Log (
7863: x_return_status => l_return_status,
7864: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
7865: p_log_used_by_id => p_import_list_header_id,
7866: p_msg_data => 'l_date3 = '||to_char(l_date3),
7876: if p_column4 is not null then
7877: begin
7878: -- l_date4 := to_date(p_column4,'MM/DD/YYYY');
7879: select to_date(p_column4, x_date_format) into l_date4 from dual;
7880: AMS_Utility_PVT.Create_Log (
7881: x_return_status => l_return_status,
7882: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
7883: p_log_used_by_id => p_import_list_header_id,
7884: p_msg_data => 'l_date4 = '||to_char(l_date4),
7895: if p_column5 is not null then
7896: begin
7897: -- l_date5 := to_date(p_column5,'MM/DD/YYYY');
7898: select to_date(p_column5, x_date_format) into l_date5 from dual;
7899: AMS_Utility_PVT.Create_Log (
7900: x_return_status => l_return_status,
7901: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
7902: p_log_used_by_id => p_import_list_header_id,
7903: p_msg_data => 'l_date5 = '||to_char(l_date5),
7912: if p_column6 is not null then
7913: begin
7914: -- l_date6 := to_date(p_column6,'MM/DD/YYYY');
7915: select to_date(p_column6, x_date_format) into l_date6 from dual;
7916: AMS_Utility_PVT.Create_Log (
7917: x_return_status => l_return_status,
7918: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
7919: p_log_used_by_id => p_import_list_header_id,
7920: p_msg_data => 'l_date6 = '||to_char(l_date6),
8065: EXCEPTION
8066: WHEN OTHERS THEN
8067: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
8068: FND_MESSAGE.Set_Token('ROW','Error in date_validate:' || SQLERRM||' '||SQLCODE);
8069: AMS_Utility_PVT.Create_Log (
8070: x_return_status => l_return_status,
8071: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
8072: p_log_used_by_id => p_import_list_header_id,
8073: p_msg_data => FND_MESSAGE.get,
8269: WHEN OTHERS THEN
8270: p_return_status := FND_API.G_RET_STS_ERROR;
8271: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
8272: FND_MESSAGE.Set_Token('ROW','Error in execute_relationship_validation:' || SQLERRM||' '||SQLCODE);
8273: AMS_Utility_PVT.Create_Log (
8274: x_return_status => l_return_status,
8275: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
8276: p_log_used_by_id => p_import_list_header_id,
8277: p_msg_data => FND_MESSAGE.get,
11098: WHEN OTHERS THEN
11099: p_return_status := FND_API.G_RET_STS_ERROR;
11100: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
11101: FND_MESSAGE.Set_Token('ROW','Error in execute_cust_data_validation:' || SQLERRM||' '||SQLCODE);
11102: AMS_Utility_PVT.Create_Log (
11103: x_return_status => l_return_status,
11104: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
11105: p_log_used_by_id => p_import_list_header_id,
11106: p_msg_data => FND_MESSAGE.get,
13404: WHEN OTHERS THEN
13405: p_return_status := FND_API.G_RET_STS_ERROR;
13406: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
13407: FND_MESSAGE.Set_Token('ROW','Error in exe_custxml_data_validation:' || SQLERRM||' '||SQLCODE);
13408: AMS_Utility_PVT.Create_Log (
13409: x_return_status => l_return_status,
13410: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
13411: p_log_used_by_id => p_import_list_header_id,
13412: p_msg_data => FND_MESSAGE.get,
13767: fetch c_rec_in_xml_stag_tab into l_rec_in_stag_tab;
13768: close c_rec_in_xml_stag_tab;
13769: end if;
13770: if l_rec_in_stag_tab is NULL then
13771: AMS_Utility_PVT.Create_Log (
13772: x_return_status => l_return_status,
13773: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
13774: p_log_used_by_id => p_import_list_header_id,
13775: p_msg_data => 'Aborting import process, Staging table not populated.',
13818: request_id = NULL
13819: where import_list_header_id = p_import_list_header_id
13820: and load_status in ('RELOAD','ACTIVE');
13821:
13822: AMS_Utility_PVT.Create_Log (
13823: x_return_status => l_return_status,
13824: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
13825: p_log_used_by_id => p_import_list_header_id,
13826: p_msg_data => 'Starting List Import in RELOAD Mode.',
13827: p_msg_type => 'DEBUG'
13828: );
13829: end if;
13830:
13831: AMS_Utility_PVT.Create_Log (
13832: x_return_status => l_return_status,
13833: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
13834: p_log_used_by_id => p_import_list_header_id,
13835: p_msg_data => 'Starting Import process.',
13857: END LOOP;
13858: x_mdata := x_tmp_var1;
13859: END IF;
13860: if x_rstatus <> 'S' then
13861: AMS_Utility_PVT.Create_Log (
13862: x_return_status => l_return_status,
13863: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
13864: p_log_used_by_id => p_import_list_header_id,
13865: p_msg_data => 'Error while executing Process_customers_xml process.',
13889: where import_list_header_id = p_import_list_header_id;
13890: open c_total_records;
13891: fetch c_total_records into l_total_records;
13892: close c_total_records;
13893: AMS_Utility_PVT.Create_Log (
13894: x_return_status => l_return_status,
13895: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
13896: p_log_used_by_id => p_import_list_header_id,
13897: p_msg_data => 'Total Number of records available for processing: '||to_char(l_total_records),
13899: );
13900:
13901: -- ****************************************************8
13902: if l_dedupe_flag = 'Y' then
13903: AMS_Utility_PVT.Create_Log (
13904: x_return_status => l_return_status,
13905: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
13906: p_log_used_by_id => p_import_list_header_id,
13907: p_msg_data => 'Starting De-Duplicate check in the Marketing tables .',
13916: update ams_imp_list_headers_all
13917: set number_of_duplicate_records = l_duplicate_records
13918: where import_list_header_id = p_import_list_header_id;
13919:
13920: AMS_Utility_PVT.Create_Log (
13921: x_return_status => l_return_status,
13922: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
13923: p_log_used_by_id => p_import_list_header_id,
13924: p_msg_data => 'END De-Duplicate check in the Marketing tables .',
13925: p_msg_type => 'DEBUG'
13926: );
13927: end if;
13928: -- ****************************************************8
13929: AMS_Utility_PVT.Create_Log (
13930: x_return_status => l_return_status,
13931: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
13932: p_log_used_by_id => p_import_list_header_id,
13933: p_msg_data => 'Start gen_transposed_phone_number.',
13935: );
13936:
13937: gen_transposed_phone_number( x_import_list_header_id, x_return_status,
13938: x_msg_count, x_msg_data );
13939: AMS_Utility_PVT.Create_Log (
13940: x_return_status => l_return_status,
13941: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
13942: p_log_used_by_id => p_import_list_header_id,
13943: p_msg_data => 'End gen_transposed_phone_number.',
13994:
13995: if x_hz_dup_check = 'Y' then
13996: if l_import_type = 'B2B' then
13997: if l_osr_mapped = 'Y' then
13998: AMS_Utility_PVT.Create_Log (
13999: x_return_status => l_return_status,
14000: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14001: p_log_used_by_id => p_import_list_header_id,
14002: p_msg_data => 'Start org_existence_checking_osr.',
14003: p_msg_type => 'DEBUG'
14004: );
14005: org_existence_checking_osr(x_import_list_header_id,
14006: x_return_status,x_msg_count,x_msg_data);
14007: AMS_Utility_PVT.Create_Log (
14008: x_return_status => l_return_status,
14009: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14010: p_log_used_by_id => p_import_list_header_id,
14011: p_msg_data => 'End org_existence_checking_osr.',
14011: p_msg_data => 'End org_existence_checking_osr.',
14012: p_msg_type => 'DEBUG'
14013: );
14014: end if;
14015: AMS_Utility_PVT.Create_Log (
14016: x_return_status => l_return_status,
14017: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14018: p_log_used_by_id => p_import_list_header_id,
14019: p_msg_data => 'Start org_existence_checking.',
14020: p_msg_type => 'DEBUG'
14021: );
14022: org_existence_checking(x_import_list_header_id,
14023: x_return_status,x_msg_count,x_msg_data);
14024: AMS_Utility_PVT.Create_Log (
14025: x_return_status => l_return_status,
14026: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14027: p_log_used_by_id => p_import_list_header_id,
14028: p_msg_data => 'End org_existence_checking.',
14028: p_msg_data => 'End org_existence_checking.',
14029: p_msg_type => 'DEBUG'
14030: );
14031: if x_return_status <> 'S' then
14032: AMS_Utility_PVT.Create_Log (
14033: x_return_status => l_return_status,
14034: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14035: p_log_used_by_id => p_import_list_header_id,
14036: p_msg_data => 'Aborting org_existence_checking.',
14048: where import_list_header_id = p_import_list_header_id;
14049: return;
14050: end if;
14051: if l_osr_mapped = 'Y' then
14052: AMS_Utility_PVT.Create_Log (
14053: x_return_status => l_return_status,
14054: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14055: p_log_used_by_id => p_import_list_header_id,
14056: p_msg_data => 'Start org_cont_existence_chk_osr.',
14057: p_msg_type => 'DEBUG'
14058: );
14059: org_cont_existence_chk_osr(x_import_list_header_id,
14060: x_return_status,x_msg_count,x_msg_data);
14061: AMS_Utility_PVT.Create_Log (
14062: x_return_status => l_return_status,
14063: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14064: p_log_used_by_id => p_import_list_header_id,
14065: p_msg_data => 'End org_cont_existence_chk_osr.',
14065: p_msg_data => 'End org_cont_existence_chk_osr.',
14066: p_msg_type => 'DEBUG'
14067: );
14068: end if;
14069: AMS_Utility_PVT.Create_Log (
14070: x_return_status => l_return_status,
14071: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14072: p_log_used_by_id => p_import_list_header_id,
14073: p_msg_data => 'Start org_cont_existence_checking.',
14074: p_msg_type => 'DEBUG'
14075: );
14076: org_cont_existence_checking(x_import_list_header_id,
14077: x_return_status,x_msg_count,x_msg_data);
14078: AMS_Utility_PVT.Create_Log (
14079: x_return_status => l_return_status,
14080: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14081: p_log_used_by_id => p_import_list_header_id,
14082: p_msg_data => 'End org_cont_existence_checking.',
14082: p_msg_data => 'End org_cont_existence_checking.',
14083: p_msg_type => 'DEBUG'
14084: );
14085: if x_return_status <> 'S' then
14086: AMS_Utility_PVT.Create_Log (
14087: x_return_status => l_return_status,
14088: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14089: p_log_used_by_id => p_import_list_header_id,
14090: p_msg_data => 'Aborting org_cont_existence_checking.',
14101: status_date = sysdate
14102: where import_list_header_id = p_import_list_header_id;
14103: return;
14104: end if;
14105: AMS_Utility_PVT.Create_Log (
14106: x_return_status => l_return_status,
14107: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14108: p_log_used_by_id => p_import_list_header_id,
14109: p_msg_data => 'Start org_address_existence_checking.',
14110: p_msg_type => 'DEBUG'
14111: );
14112: org_address_existence_checking(x_import_list_header_id,
14113: x_return_status,x_msg_count,x_msg_data);
14114: AMS_Utility_PVT.Create_Log (
14115: x_return_status => l_return_status,
14116: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14117: p_log_used_by_id => p_import_list_header_id,
14118: p_msg_data => 'End org_address_existence_checking.',
14118: p_msg_data => 'End org_address_existence_checking.',
14119: p_msg_type => 'DEBUG'
14120: );
14121: if x_return_status <> 'S' then
14122: AMS_Utility_PVT.Create_Log (
14123: x_return_status => l_return_status,
14124: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14125: p_log_used_by_id => p_import_list_header_id,
14126: p_msg_data => 'Aborting org_address_existence_checking.',
14137: status_date = sysdate
14138: where import_list_header_id = p_import_list_header_id;
14139: return;
14140: end if;
14141: AMS_Utility_PVT.Create_Log (
14142: x_return_status => l_return_status,
14143: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14144: p_log_used_by_id => p_import_list_header_id,
14145: p_msg_data => 'Start org_address1_exist_checking.',
14146: p_msg_type => 'DEBUG'
14147: );
14148: org_address1_exist_checking(x_import_list_header_id,
14149: x_return_status,x_msg_count,x_msg_data);
14150: AMS_Utility_PVT.Create_Log (
14151: x_return_status => l_return_status,
14152: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14153: p_log_used_by_id => p_import_list_header_id,
14154: p_msg_data => 'End org_address1_exist_checking.',
14154: p_msg_data => 'End org_address1_exist_checking.',
14155: p_msg_type => 'DEBUG'
14156: );
14157: if x_return_status <> 'S' then
14158: AMS_Utility_PVT.Create_Log (
14159: x_return_status => l_return_status,
14160: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14161: p_log_used_by_id => p_import_list_header_id,
14162: p_msg_data => 'Aborting org_address1_exist_checking.',
14176:
14177: ELSE
14178:
14179: if l_osr_mapped = 'Y' then
14180: AMS_Utility_PVT.Create_Log (
14181: x_return_status => l_return_status,
14182: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14183: p_log_used_by_id => p_import_list_header_id,
14184: p_msg_data => 'Start per_existence_checking.',
14185: p_msg_type => 'DEBUG'
14186: );
14187: per_existence_checking_osr(x_import_list_header_id,
14188: x_return_status,x_msg_count,x_msg_data);
14189: AMS_Utility_PVT.Create_Log (
14190: x_return_status => l_return_status,
14191: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14192: p_log_used_by_id => p_import_list_header_id,
14193: p_msg_data => 'End per_existence_checking.',
14193: p_msg_data => 'End per_existence_checking.',
14194: p_msg_type => 'DEBUG'
14195: );
14196: end if;
14197: AMS_Utility_PVT.Create_Log (
14198: x_return_status => l_return_status,
14199: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14200: p_log_used_by_id => p_import_list_header_id,
14201: p_msg_data => 'Start per_existence_checking.',
14202: p_msg_type => 'DEBUG'
14203: );
14204: per_existence_checking(x_import_list_header_id,
14205: x_return_status,x_msg_count,x_msg_data);
14206: AMS_Utility_PVT.Create_Log (
14207: x_return_status => l_return_status,
14208: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14209: p_log_used_by_id => p_import_list_header_id,
14210: p_msg_data => 'End per_existence_checking.',
14210: p_msg_data => 'End per_existence_checking.',
14211: p_msg_type => 'DEBUG'
14212: );
14213: if x_return_status <> 'S' then
14214: AMS_Utility_PVT.Create_Log (
14215: x_return_status => l_return_status,
14216: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14217: p_log_used_by_id => p_import_list_header_id,
14218: p_msg_data => 'Aborting per_existence_checking.',
14229: status_date = sysdate
14230: where import_list_header_id = p_import_list_header_id;
14231: return;
14232: end if;
14233: AMS_Utility_PVT.Create_Log (
14234: x_return_status => l_return_status,
14235: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14236: p_log_used_by_id => p_import_list_header_id,
14237: p_msg_data => 'Start per_address_existence_checking.',
14238: p_msg_type => 'DEBUG'
14239: );
14240: per_address_existence_checking(x_import_list_header_id,
14241: x_return_status,x_msg_count,x_msg_data);
14242: AMS_Utility_PVT.Create_Log (
14243: x_return_status => l_return_status,
14244: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14245: p_log_used_by_id => p_import_list_header_id,
14246: p_msg_data => 'End per_address_existence_checking.',
14246: p_msg_data => 'End per_address_existence_checking.',
14247: p_msg_type => 'DEBUG'
14248: );
14249: if x_return_status <> 'S' then
14250: AMS_Utility_PVT.Create_Log (
14251: x_return_status => l_return_status,
14252: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14253: p_log_used_by_id => p_import_list_header_id,
14254: p_msg_data => 'Aborting per_address_existence_checking.',
14273:
14274: -- +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
14275: -- Call the Validate Process
14276: if l_validate_file = 'Y' then
14277: AMS_Utility_PVT.Create_Log (
14278: x_return_status => l_return_status,
14279: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14280: p_log_used_by_id => p_import_list_header_id,
14281: p_msg_data => 'Starting Validation for CUSTOMER data.',
14295: end if;
14296: l_return_status := null;
14297: execute_cust_data_validation ( p_import_list_header_id, l_return_status);
14298: if l_return_status <> 'S' then
14299: AMS_Utility_PVT.Create_Log (
14300: x_return_status => l_return_status,
14301: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14302: p_log_used_by_id => p_import_list_header_id,
14303: p_msg_data => 'Customer import terminated because of error in Data validation process.',
14321: if l_file_type = 'XML' then
14322: l_return_status := null;
14323: exe_custxml_data_validation ( p_import_list_header_id, l_return_status);
14324: if l_return_status <> 'S' then
14325: AMS_Utility_PVT.Create_Log (
14326: x_return_status => l_return_status,
14327: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14328: p_log_used_by_id => p_import_list_header_id,
14329: p_msg_data => 'Customer import terminated because of error in XML Data validation process.',
14344: end if;
14345: end if;
14346: -- ((((((((((((((((((((((((((((((((((((((((((((((
14347:
14348: AMS_Utility_PVT.Create_Log (
14349: x_return_status => l_return_status,
14350: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14351: p_log_used_by_id => p_import_list_header_id,
14352: p_msg_data => 'End Validation for CUSTOMER data.',
14353: p_msg_type => 'DEBUG'
14354: );
14355: end if;
14356:
14357: AMS_Utility_PVT.Create_Log (
14358: x_return_status => l_return_status,
14359: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14360: p_log_used_by_id => p_import_list_header_id,
14361: p_msg_data => 'Starting client load for TCA.',
14381: argument1 => p_import_list_header_id,
14382: argument2 => l_numb_of_inst
14383: );
14384:
14385: AMS_Utility_PVT.Create_Log (
14386: x_return_status => l_return_status,
14387: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14388: p_log_used_by_id => p_import_list_header_id,
14389: p_msg_data => 'Starting TCA program (AMSILHZC) -- concurrent program_id is '||to_char(l_request_id),
14389: p_msg_data => 'Starting TCA program (AMSILHZC) -- concurrent program_id is '||to_char(l_request_id),
14390: p_msg_type => 'DEBUG');
14391:
14392: IF l_request_id = 0 THEN
14393: AMS_Utility_PVT.Create_Log (
14394: x_return_status => l_return_status,
14395: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14396: p_log_used_by_id => p_import_list_header_id,
14397: p_msg_data => 'Error in (AMSILHZC) -- concurrent program_id is '||to_char(l_request_id),
14396: p_log_used_by_id => p_import_list_header_id,
14397: p_msg_data => 'Error in (AMSILHZC) -- concurrent program_id is '||to_char(l_request_id),
14398: p_msg_type => 'DEBUG');
14399: l_mesg_text := fnd_message.get;
14400: AMS_Utility_PVT.Create_Log (
14401: x_return_status => l_return_status,
14402: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14403: p_log_used_by_id => p_import_list_header_id,
14404: p_msg_data => l_mesg_text,
14425: l_msg_code,
14426: p_import_list_header_id
14427: );
14428: */
14429: AMS_Utility_PVT.Create_Log (
14430: x_return_status => l_return_status,
14431: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14432: p_log_used_by_id => p_import_list_header_id,
14433: p_msg_data => 'End client load for TCA.',
14500: */
14501: end if; -- CUSTOMER
14502: /*
14503: if p_generate_list = 'Y' then
14504: AMS_Utility_PVT.Create_Log (
14505: x_return_status => l_return_status,
14506: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14507: p_log_used_by_id => p_import_list_header_id,
14508: p_msg_data => 'Starting List Generation for List Import.',
14528: l_list_header_id,
14529: p_list_name) ;
14530:
14531: If i_return_status <> 'S' then
14532: AMS_Utility_PVT.Create_Log (
14533: x_return_status => l_return_status,
14534: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14535: p_log_used_by_id => p_import_list_header_id,
14536: p_msg_data => 'Error in List Generation --'||i_msg_data,
14537: p_msg_type => 'DEBUG'
14538: );
14539: End if;
14540: end if;
14541: AMS_Utility_PVT.Create_Log (
14542: x_return_status => l_return_status,
14543: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14544: p_log_used_by_id => p_import_list_header_id,
14545: p_msg_data => 'End List Generation for List Import.',
14565: application => 'AMS',
14566: program => 'AMSILLDC',
14567: argument1 => p_import_list_header_id
14568: );
14569: AMS_Utility_PVT.Create_Log (
14570: x_return_status => l_return_status,
14571: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14572: p_log_used_by_id => p_import_list_header_id,
14573: p_msg_data => 'Starting LEAD data upload program (AMSILLDC) -- concurrent program_id is '||to_char(l_request_id),
14594: where import_list_header_id = p_import_list_header_id;
14595:
14596: -- Call the Validate Process
14597: if l_validate_file = 'Y' then
14598: AMS_Utility_PVT.Create_Log (
14599: x_return_status => l_return_status,
14600: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14601: p_log_used_by_id => p_import_list_header_id,
14602: p_msg_data => 'Starting Validation for EVENT data.',
14612:
14613: l_return_status := null;
14614: execute_event_data_validation ( p_import_list_header_id, l_return_status);
14615: if l_return_status <> 'S' then
14616: AMS_Utility_PVT.Create_Log (
14617: x_return_status => l_return_status,
14618: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14619: p_log_used_by_id => p_import_list_header_id,
14620: p_msg_data => 'EVENT import terminated because of error in Data validation process.',
14634: where import_list_header_id = p_import_list_header_id;
14635: return;
14636: end if;
14637:
14638: AMS_Utility_PVT.Create_Log (
14639: x_return_status => l_return_status,
14640: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14641: p_log_used_by_id => p_import_list_header_id,
14642: p_msg_data => 'End Validation for Event data.',
14643: p_msg_type => 'DEBUG'
14644: );
14645: end if;
14646:
14647: AMS_Utility_PVT.Create_Log (
14648: x_return_status => l_return_status,
14649: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14650: p_log_used_by_id => p_import_list_header_id,
14651: p_msg_data => 'Starting client load for EVENT.',
14655: l_msg_buf,
14656: l_msg_code,
14657: p_import_list_header_id
14658: );
14659: AMS_Utility_PVT.Create_Log (
14660: x_return_status => l_return_status,
14661: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14662: p_log_used_by_id => p_import_list_header_id,
14663: p_msg_data => 'End client load for EVENT.',
14721: l_total_records := 0;
14722: open c_total_records;
14723: fetch c_total_records into l_total_records;
14724: close c_total_records;
14725: AMS_Utility_PVT.Create_Log (
14726: x_return_status => l_return_status,
14727: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14728: p_log_used_by_id => p_import_list_header_id,
14729: p_msg_data => 'Total Number of records not processed: '||to_char(l_total_records),
14734: -- **********************************************************
14735:
14736: EXCEPTION
14737: WHEN others THEN
14738: AMS_Utility_PVT.Create_Log (
14739: x_return_status => l_return_status,
14740: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14741: p_log_used_by_id => p_import_list_header_id,
14742: p_msg_data => sqlerrm ,
14763: p_generate_list,
14764: p_list_name );
14765: EXCEPTION
14766: WHEN others THEN
14767: AMS_Utility_PVT.Create_Log (
14768: x_return_status => l_return_status,
14769: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
14770: p_log_used_by_id => p_import_list_header_id,
14771: p_msg_data => sqlerrm ,
15847: WHEN OTHERS THEN
15848: p_return_status := FND_API.G_RET_STS_ERROR;
15849: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
15850: FND_MESSAGE.Set_Token('ROW','Error in execute_event_data_validation:' || SQLERRM||' '||SQLCODE);
15851: AMS_Utility_PVT.Create_Log (
15852: x_return_status => l_return_status,
15853: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
15854: p_log_used_by_id => p_import_list_header_id,
15855: p_msg_data => FND_MESSAGE.get,
15963: end if;
15964:
15965: -- CHECK ACTIVE/RELOAD STATUS RECORD
15966: if l_tot_numb_active_records > 0 then
15967: AMS_Utility_PVT.Create_Log (
15968: x_return_status => l_return_status,
15969: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
15970: p_log_used_by_id => p_import_list_header_id,
15971: p_msg_data => 'Some of the records are not processed .' ,
15993: exception
15994: WHEN OTHERS THEN
15995: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
15996: FND_MESSAGE.Set_Token('ROW','Error in process_status_code :' || SQLERRM||' '||SQLCODE);
15997: AMS_Utility_PVT.Create_Log (
15998: x_return_status => l_return_status,
15999: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
16000: p_log_used_by_id => p_import_list_header_id,
16001: p_msg_data => FND_MESSAGE.get,
16128: exception
16129: WHEN OTHERS THEN
16130: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
16131: FND_MESSAGE.Set_Token('ROW','Error in Process_customers_xml :' || SQLERRM||' '||SQLCODE);
16132: AMS_Utility_PVT.Create_Log (
16133: x_return_status => x_return_status,
16134: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
16135: p_log_used_by_id => p_import_list_header_id,
16136: p_msg_data => FND_MESSAGE.get,
17079: exception
17080: WHEN OTHERS THEN
17081: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
17082: FND_MESSAGE.Set_Token('ROW','Error in Process_b2b_xml_data :' || SQLERRM||' '||SQLCODE);
17083: AMS_Utility_PVT.Create_Log (
17084: x_return_status => x_return_status,
17085: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
17086: p_log_used_by_id => p_import_list_header_id,
17087: p_msg_data => FND_MESSAGE.get,
17586: exception
17587: WHEN OTHERS THEN
17588: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
17589: FND_MESSAGE.Set_Token('ROW','Error in Process_b2c_xml_data :' || SQLERRM||' '||SQLCODE);
17590: AMS_Utility_PVT.Create_Log (
17591: x_return_status => x_return_status,
17592: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
17593: p_log_used_by_id => p_import_list_header_id,
17594: p_msg_data => FND_MESSAGE.get,
18024: exception
18025: WHEN OTHERS THEN
18026: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
18027: FND_MESSAGE.Set_Token('ROW','Error in Create_b2b_src_lines:' || SQLERRM||' '||SQLCODE);
18028: AMS_Utility_PVT.Create_Log (
18029: x_return_status => x_return_status,
18030: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
18031: p_log_used_by_id => p_import_list_header_id,
18032: p_msg_data => FND_MESSAGE.get,
18294: exception
18295: WHEN OTHERS THEN
18296: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
18297: FND_MESSAGE.Set_Token('ROW','Error in Create_b2c_src_lines:' || SQLERRM||' '||SQLCODE);
18298: AMS_Utility_PVT.Create_Log (
18299: x_return_status => x_return_status,
18300: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
18301: p_log_used_by_id => p_import_list_header_id,
18302: p_msg_data => FND_MESSAGE.get,
18333: exception
18334: WHEN OTHERS THEN
18335: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
18336: FND_MESSAGE.Set_Token('ROW','Error in update_element_error :' || SQLERRM||' '||SQLCODE);
18337: AMS_Utility_PVT.Create_Log (
18338: x_return_status => x_return_status,
18339: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
18340: p_log_used_by_id => p_import_list_header_id,
18341: p_msg_data => FND_MESSAGE.get,
18499: exception
18500: WHEN OTHERS THEN
18501: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
18502: FND_MESSAGE.Set_Token('ROW','Error in create_list_note :' || SQLERRM||' '||SQLCODE);
18503: AMS_Utility_PVT.Create_Log (
18504: x_return_status => l_return_status,
18505: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
18506: p_log_used_by_id => p_import_list_header_id,
18507: p_msg_data => FND_MESSAGE.get,
18781: WHEN OTHERS THEN
18782: x_return_status := FND_API.G_RET_STS_ERROR;
18783: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
18784: FND_MESSAGE.Set_Token('ROW','Error in org_existence_checking :' || SQLERRM||' '||SQLCODE);
18785: AMS_Utility_PVT.Create_Log (
18786: x_return_status => x_return_status,
18787: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
18788: p_log_used_by_id => p_import_list_header_id,
18789: p_msg_data => FND_MESSAGE.get,
19053: WHEN OTHERS THEN
19054: x_return_status := FND_API.G_RET_STS_ERROR;
19055: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
19056: FND_MESSAGE.Set_Token('ROW','Error in org_existence_checking_osr :' || SQLERRM||' '||SQLCODE);
19057: AMS_Utility_PVT.Create_Log (
19058: x_return_status => x_return_status,
19059: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
19060: p_log_used_by_id => p_import_list_header_id,
19061: p_msg_data => FND_MESSAGE.get,
19379: WHEN OTHERS THEN
19380: x_return_status := FND_API.G_RET_STS_ERROR;
19381: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
19382: FND_MESSAGE.Set_Token('ROW','Error in per_existence_checking :' || SQLERRM||' '||SQLCODE);
19383: AMS_Utility_PVT.Create_Log (
19384: x_return_status => x_return_status,
19385: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
19386: p_log_used_by_id => p_import_list_header_id,
19387: p_msg_data => FND_MESSAGE.get,
19641: WHEN OTHERS THEN
19642: x_return_status := FND_API.G_RET_STS_ERROR;
19643: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
19644: FND_MESSAGE.Set_Token('ROW','Error in per_existence_checking_osr :' || SQLERRM||' '||SQLCODE);
19645: AMS_Utility_PVT.Create_Log (
19646: x_return_status => x_return_status,
19647: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
19648: p_log_used_by_id => p_import_list_header_id,
19649: p_msg_data => FND_MESSAGE.get,
20032: WHEN OTHERS THEN
20033: x_return_status := FND_API.G_RET_STS_ERROR;
20034: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
20035: FND_MESSAGE.Set_Token('ROW','Error in org_cont_existence_checking :' || SQLERRM||' '||SQLCODE);
20036: AMS_Utility_PVT.Create_Log (
20037: x_return_status => x_return_status,
20038: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
20039: p_log_used_by_id => p_import_list_header_id,
20040: p_msg_data => FND_MESSAGE.get,
20348: WHEN OTHERS THEN
20349: x_return_status := FND_API.G_RET_STS_ERROR;
20350: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
20351: FND_MESSAGE.Set_Token('ROW','Error in org_cont_existence_chk_osr :' || SQLERRM||' '||SQLCODE);
20352: AMS_Utility_PVT.Create_Log (
20353: x_return_status => x_return_status,
20354: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
20355: p_log_used_by_id => p_import_list_header_id,
20356: p_msg_data => FND_MESSAGE.get,
20504: WHEN OTHERS THEN
20505: x_return_status := FND_API.G_RET_STS_ERROR;
20506: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
20507: FND_MESSAGE.Set_Token('ROW','Error in org_address_existence_checking :' || SQLERRM||' '||SQLCODE);
20508: AMS_Utility_PVT.Create_Log (
20509: x_return_status => x_return_status,
20510: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
20511: p_log_used_by_id => p_import_list_header_id,
20512: p_msg_data => FND_MESSAGE.get,
20662: WHEN OTHERS THEN
20663: x_return_status := FND_API.G_RET_STS_ERROR;
20664: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
20665: FND_MESSAGE.Set_Token('ROW','Error in org_address1_exist_checking :' || SQLERRM||' '||SQLCODE);
20666: AMS_Utility_PVT.Create_Log (
20667: x_return_status => x_return_status,
20668: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
20669: p_log_used_by_id => p_import_list_header_id,
20670: p_msg_data => FND_MESSAGE.get,
20820: WHEN OTHERS THEN
20821: x_return_status := FND_API.G_RET_STS_ERROR;
20822: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
20823: FND_MESSAGE.Set_Token('ROW','Error in per_address_existence_checking :' || SQLERRM||' '||SQLCODE);
20824: AMS_Utility_PVT.Create_Log (
20825: x_return_status => x_return_status,
20826: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
20827: p_log_used_by_id => p_import_list_header_id,
20828: p_msg_data => FND_MESSAGE.get,
21012: close c_dup_xml_recs;
21013: end if;
21014:
21015: if l_gen_list = 'Y' then
21016: AMS_Utility_PVT.Create_Log (
21017: x_return_status => l_return_status,
21018: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
21019: p_log_used_by_id => p_import_list_header_id,
21020: p_msg_data => 'Starting List Generation for List Import.',
21038: l_list_header_id,
21039: l_list_name) ;
21040:
21041: If i_return_status <> 'S' then
21042: AMS_Utility_PVT.Create_Log (
21043: x_return_status => l_return_status,
21044: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
21045: p_log_used_by_id => p_import_list_header_id,
21046: p_msg_data => 'Error in List Generation --'||i_msg_data,
21047: p_msg_type => 'DEBUG'
21048: );
21049: End if;
21050: end if;
21051: AMS_Utility_PVT.Create_Log (
21052: x_return_status => l_return_status,
21053: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
21054: p_log_used_by_id => p_import_list_header_id,
21055: p_msg_data => 'End List Generation for List Import.',
21060: l_total_records := 0;
21061: open c_total_records;
21062: fetch c_total_records into l_total_records;
21063: close c_total_records;
21064: AMS_Utility_PVT.Create_Log (
21065: x_return_status => l_return_status,
21066: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
21067: p_log_used_by_id => p_import_list_header_id,
21068: p_msg_data => 'Total Number of records not processed: '||to_char(l_total_records),
21146: WHEN OTHERS THEN
21147: x_return_status := FND_API.G_RET_STS_ERROR;
21148: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
21149: FND_MESSAGE.Set_Token('ROW','Error in org_party_update:' || SQLERRM||' '||SQLCODE);
21150: AMS_Utility_PVT.Create_Log (
21151: x_return_status => x_return_status,
21152: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
21153: p_log_used_by_id => p_import_list_header_id,
21154: p_msg_data => FND_MESSAGE.get,
21259: WHEN OTHERS THEN
21260: x_return_status := FND_API.G_RET_STS_ERROR;
21261: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
21262: FND_MESSAGE.Set_Token('ROW','Error in gen_transposed_phone_number :' || SQLERRM||' '||SQLCODE);
21263: AMS_Utility_PVT.Create_Log (
21264: x_return_status => x_return_status,
21265: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
21266: p_log_used_by_id => p_import_list_header_id,
21267: p_msg_data => FND_MESSAGE.get,
21351: EXCEPTION
21352: WHEN OTHERS THEN
21353: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
21354: FND_MESSAGE.Set_Token('ROW','Error in update_xml_error_text :' || SQLERRM||' '||SQLCODE);
21355: AMS_Utility_PVT.Create_Log (
21356: x_return_status => l_return_status,
21357: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
21358: p_log_used_by_id => p_import_list_header_id,
21359: p_msg_data => FND_MESSAGE.get,
21384: select import_type,last_updated_by,vendor_id,charset from ams_imp_list_headers_all
21385: where import_list_header_id = p_import_list_header_id;
21386:
21387: Begin
21388: AMS_Utility_PVT.Create_Log (
21389: x_return_status => l_return_status,
21390: p_arc_log_used_by => 'IMPH',
21391: p_log_used_by_id => p_import_list_header_id,
21392: p_msg_data => ' Start Business event : '||p_event,
21434: ( p_event_name => p_event,
21435: p_event_key => l_new_item_key,
21436: p_parameters => l_parameter_list);
21437:
21438: AMS_Utility_PVT.Create_Log (
21439: x_return_status => l_return_status,
21440: p_arc_log_used_by => 'IMPH',
21441: p_log_used_by_id => p_import_list_header_id,
21442: p_msg_data => 'End Business event : '||p_event,
21444: );
21445: commit;
21446: /*
21447: if l_error_code = 'E' then
21448: AMS_Utility_PVT.Create_Log (
21449: x_return_status => l_return_status,
21450: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
21451: p_log_used_by_id => p_import_list_header_id,
21452: p_msg_data => 'Business Event Error: '||l_error_text,
21468: EXCEPTION
21469: WHEN OTHERS THEN
21470: FND_MESSAGE.set_name('AMS', 'API_DEBUG_MESSAGE');
21471: FND_MESSAGE.Set_Token('ROW','Error in Raise_Business_event :' ||SQLERRM||' '||SQLCODE);
21472: AMS_Utility_PVT.Create_Log (
21473: x_return_status => l_return_status,
21474: p_arc_log_used_by => G_ARC_IMPORT_HEADER,
21475: p_log_used_by_id => p_import_list_header_id,
21476: p_msg_data => FND_MESSAGE.get,
21503: l_user_id := p_event.GetValueForParameter('USER_ID');
21504: l_resp_id := p_event.GetValueForParameter('RESPONSIBILITY_ID');
21505: l_VENDOR_ID := p_event.GetValueForParameter('VENDOR_ID');
21506: l_LANGUAGE_ENCODING := p_event.GetValueForParameter('LANGUAGE_ENCODING');
21507: AMS_Utility_PVT.Create_Log (
21508: x_return_status => l_return_status,
21509: p_arc_log_used_by => 'IMPH',
21510: p_log_used_by_id => l_import_list_header_id,
21511: p_msg_data => 'COMING INSIDE TEST_Pre_sub EVENT.......',
21511: p_msg_data => 'COMING INSIDE TEST_Pre_sub EVENT.......',
21512: p_msg_type => 'DEBUG'
21513: );
21514:
21515: AMS_Utility_PVT.Create_Log (
21516: x_return_status => l_return_status,
21517: p_arc_log_used_by => 'IMPH',
21518: p_log_used_by_id => l_import_list_header_id,
21519: p_msg_data => 'IMPORT_LIST_HEADER_ID = '||to_char(l_import_list_header_id),
21518: p_log_used_by_id => l_import_list_header_id,
21519: p_msg_data => 'IMPORT_LIST_HEADER_ID = '||to_char(l_import_list_header_id),
21520: p_msg_type => 'DEBUG');
21521:
21522: AMS_Utility_PVT.Create_Log (
21523: x_return_status => l_return_status,
21524: p_arc_log_used_by => 'IMPH',
21525: p_log_used_by_id => l_import_list_header_id,
21526: p_msg_data => 'IMPORT_TYPE = '||l_import_type,
21525: p_log_used_by_id => l_import_list_header_id,
21526: p_msg_data => 'IMPORT_TYPE = '||l_import_type,
21527: p_msg_type => 'DEBUG');
21528:
21529: AMS_Utility_PVT.Create_Log (
21530: x_return_status => l_return_status,
21531: p_arc_log_used_by => 'IMPH',
21532: p_log_used_by_id => l_import_list_header_id,
21533: p_msg_data => 'USER_ID = '||to_char(l_user_id),
21532: p_log_used_by_id => l_import_list_header_id,
21533: p_msg_data => 'USER_ID = '||to_char(l_user_id),
21534: p_msg_type => 'DEBUG');
21535:
21536: AMS_Utility_PVT.Create_Log (
21537: x_return_status => l_return_status,
21538: p_arc_log_used_by => 'IMPH',
21539: p_log_used_by_id => l_import_list_header_id,
21540: p_msg_data => 'RESPONSIBILITY_ID = '||to_char(l_resp_id),
21539: p_log_used_by_id => l_import_list_header_id,
21540: p_msg_data => 'RESPONSIBILITY_ID = '||to_char(l_resp_id),
21541: p_msg_type => 'DEBUG');
21542:
21543: AMS_Utility_PVT.Create_Log (
21544: x_return_status => l_return_status,
21545: p_arc_log_used_by => 'IMPH',
21546: p_log_used_by_id => l_import_list_header_id,
21547: p_msg_data => 'VENDOR_ID = '||to_char(l_VENDOR_ID),
21546: p_log_used_by_id => l_import_list_header_id,
21547: p_msg_data => 'VENDOR_ID = '||to_char(l_VENDOR_ID),
21548: p_msg_type => 'DEBUG');
21549:
21550: AMS_Utility_PVT.Create_Log (
21551: x_return_status => l_return_status,
21552: p_arc_log_used_by => 'IMPH',
21553: p_log_used_by_id => l_import_list_header_id,
21554: p_msg_data => 'LANGUAGE_ENCODING = '||l_LANGUAGE_ENCODING,
21598: l_user_id := p_event.GetValueForParameter('USER_ID');
21599: l_resp_id := p_event.GetValueForParameter('RESPONSIBILITY_ID');
21600: l_VENDOR_ID := p_event.GetValueForParameter('VENDOR_ID');
21601: l_LANGUAGE_ENCODING := p_event.GetValueForParameter('LANGUAGE_ENCODING');
21602: AMS_Utility_PVT.Create_Log (
21603: x_return_status => l_return_status,
21604: p_arc_log_used_by => 'IMPH',
21605: p_log_used_by_id => l_import_list_header_id,
21606: p_msg_data => 'COMING INSIDE TEST_Post_sub EVENT.......',
21605: p_log_used_by_id => l_import_list_header_id,
21606: p_msg_data => 'COMING INSIDE TEST_Post_sub EVENT.......',
21607: p_msg_type => 'DEBUG'
21608: );
21609: AMS_Utility_PVT.Create_Log (
21610: x_return_status => l_return_status,
21611: p_arc_log_used_by => 'IMPH',
21612: p_log_used_by_id => l_import_list_header_id,
21613: p_msg_data => 'IMPORT_LIST_HEADER_ID = '||to_char(l_import_list_header_id),
21612: p_log_used_by_id => l_import_list_header_id,
21613: p_msg_data => 'IMPORT_LIST_HEADER_ID = '||to_char(l_import_list_header_id),
21614: p_msg_type => 'DEBUG');
21615:
21616: AMS_Utility_PVT.Create_Log (
21617: x_return_status => l_return_status,
21618: p_arc_log_used_by => 'IMPH',
21619: p_log_used_by_id => l_import_list_header_id,
21620: p_msg_data => 'IMPORT_TYPE = '||l_import_type,
21619: p_log_used_by_id => l_import_list_header_id,
21620: p_msg_data => 'IMPORT_TYPE = '||l_import_type,
21621: p_msg_type => 'DEBUG');
21622:
21623: AMS_Utility_PVT.Create_Log (
21624: x_return_status => l_return_status,
21625: p_arc_log_used_by => 'IMPH',
21626: p_log_used_by_id => l_import_list_header_id,
21627: p_msg_data => 'USER_ID = '||to_char(l_user_id),
21626: p_log_used_by_id => l_import_list_header_id,
21627: p_msg_data => 'USER_ID = '||to_char(l_user_id),
21628: p_msg_type => 'DEBUG');
21629:
21630: AMS_Utility_PVT.Create_Log (
21631: x_return_status => l_return_status,
21632: p_arc_log_used_by => 'IMPH',
21633: p_log_used_by_id => l_import_list_header_id,
21634: p_msg_data => 'RESPONSIBILITY_ID = '||to_char(l_resp_id),
21633: p_log_used_by_id => l_import_list_header_id,
21634: p_msg_data => 'RESPONSIBILITY_ID = '||to_char(l_resp_id),
21635: p_msg_type => 'DEBUG');
21636:
21637: AMS_Utility_PVT.Create_Log (
21638: x_return_status => l_return_status,
21639: p_arc_log_used_by => 'IMPH',
21640: p_log_used_by_id => l_import_list_header_id,
21641: p_msg_data => 'VENDOR_ID = '||to_char(l_VENDOR_ID),
21640: p_log_used_by_id => l_import_list_header_id,
21641: p_msg_data => 'VENDOR_ID = '||to_char(l_VENDOR_ID),
21642: p_msg_type => 'DEBUG');
21643:
21644: AMS_Utility_PVT.Create_Log (
21645: x_return_status => l_return_status,
21646: p_arc_log_used_by => 'IMPH',
21647: p_log_used_by_id => l_import_list_header_id,
21648: p_msg_data => 'LANGUAGE_ENCODING = '||l_LANGUAGE_ENCODING,