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