[Home] [Help]
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,
1698: end if;
1699:
1700: if x_msg_count > 1 then
1701: FOR i IN 1..x_msg_count LOOP
1702: x_tmp_var := fnd_msg_pub.get(p_encoded => fnd_api.g_false);
1703: x_tmp_var1 := substrb(x_tmp_var1 || ' '|| x_tmp_var,1,4000);
1704: END LOOP;
1705: x_msg_data := x_tmp_var1;
1706: END IF;
2096: end if;
2097:
2098: if x_msg_count > 1 then
2099: FOR i IN 1..x_msg_count LOOP
2100: x_tmp_var := fnd_msg_pub.get(p_encoded => fnd_api.g_false);
2101: x_tmp_var1 := substrb(x_tmp_var1 || ' '|| x_tmp_var,1,4000);
2102: END LOOP;
2103: x_msg_data := x_tmp_var1;
2104: END IF;
2475: user_status_id = l_user_status_id,
2476: status_date = sysdate
2477: where import_list_header_id = p_import_list_header_id;
2478: commit;
2479: RAISE FND_API.g_exc_unexpected_error;
2480: ELSE
2481: FND_MESSAGE.set_name ('AMS', 'AMS_IMP_LOAD_REQUEST_ID');
2482: FND_MESSAGE.set_token ('REQUEST_ID', l_request_id);
2483:
2547: user_status_id = l_user_status_id,
2548: status_date = sysdate
2549: where import_list_header_id = p_import_list_header_id;
2550: commit;
2551: RAISE FND_API.g_exc_unexpected_error;
2552: END IF;
2553:
2554: ---------------------------------------------
2555: OPEN c_loaded_rows;
2940: AMS_ListGeneration_PKG.create_import_list
2941: ( 1,
2942: 'T',
2943: 'T',
2944: FND_API.G_VALID_LEVEL_FULL,
2945: p_owner_user_id,
2946: p_import_list_header_id,
2947: i_return_status,
2948: i_msg_count,
3193: user_status_id = l_user_status_id,
3194: status_date = sysdate
3195: where import_list_header_id = p_import_list_header_id;
3196: commit;
3197: RAISE FND_API.g_exc_unexpected_error;
3198: end if;
3199:
3200: if l_import_type = 'LEAD' then
3201: /*
3227: */
3228: end if;
3229: /*
3230: IF l_request_id = 0 THEN
3231: RAISE FND_API.g_exc_unexpected_error;
3232: end if;
3233: */
3234: if l_import_type = 'EVENT' then
3235: -- Call the Validate Process
3336: user_status_id = l_user_status_id,
3337: status_date = sysdate
3338: where import_list_header_id = p_import_list_header_id;
3339: commit;
3340: RAISE FND_API.g_exc_unexpected_error;
3341: END IF;
3342: /*
3343: if l_import_type = 'LEAD' then
3344: capture_lead_error(p_import_list_header_id);
3564: status_date = sysdate
3565: where import_list_header_id = p_import_list_header_id;
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,
3683: user_status_id = l_user_status_id,
3684: status_date = sysdate
3685: where import_list_header_id = p_import_list_header_id;
3686: commit;
3687: RAISE FND_API.g_exc_unexpected_error;
3688: end if;
3689:
3690: EXCEPTION
3691: WHEN others THEN
4276: user_status_id = l_user_status_id,
4277: status_date = sysdate
4278: where import_list_header_id = p_import_list_header_id;
4279: commit;
4280: RAISE FND_API.g_exc_unexpected_error;
4281: end if;
4282:
4283: commit;
4284: -- The concurrent program MUST finish
4299: -- the conc request was not successfully
4300: -- submitted.
4301: ---------------------------------------------
4302: IF NOT l_wait_status THEN
4303: RAISE FND_API.g_exc_unexpected_error;
4304: END IF;
4305:
4306:
4307: l_rstatus := FND_CONCURRENT.get_REQUEST_status (
4932: FETCH b2borb2c into x_b2b,x_rented_list_flag,x_import_list_header_id;
4933: CLOSE b2borb2c;
4934:
4935: if x_rented_list_flag <> 'R' then
4936: p_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
4937: FND_MESSAGE.SET_NAME('AMS', 'API_DEBUG_MESSAGE');
4938: FND_MESSAGE.SET_TOKEN('ROW','Party was not created through rented list.');
4939: FND_MESSAGE.SET_TOKEN('ERROR' ,SQLERRM);
4940: FND_MSG_PUB.ADD;
5176: x_msg_count,
5177: x_msg_data);
5178: if x_msg_count > 1 then
5179: FOR i IN 1..x_msg_count LOOP
5180: x_tmp_var := fnd_msg_pub.get(p_encoded => fnd_api.g_false);
5181: x_tmp_var1 := substrb(x_tmp_var1 || ' '|| x_tmp_var,1,4000);
5182: END LOOP;
5183: x_msg_data := x_tmp_var1;
5184: END IF;
5213: x_msg_count,
5214: x_msg_data);
5215: if x_msg_count > 1 then
5216: FOR i IN 1..x_msg_count LOOP
5217: x_tmp_var := fnd_msg_pub.get(p_encoded => fnd_api.g_false);
5218: x_tmp_var1 := substrb(x_tmp_var1 || ' '|| x_tmp_var,1,4000);
5219: END LOOP;
5220: x_msg_data := x_tmp_var1;
5221: END IF;
5252: x_msg_count,
5253: x_msg_data);
5254: if x_msg_count > 1 then
5255: FOR i IN 1..x_msg_count LOOP
5256: x_tmp_var := fnd_msg_pub.get(p_encoded => fnd_api.g_false);
5257: x_tmp_var1 := substrb(x_tmp_var1 || ' '|| x_tmp_var,1,4000);
5258: END LOOP;
5259: x_msg_data := x_tmp_var1;
5260: END IF;
5580: x_msg_count,
5581: x_msg_data);
5582: if x_msg_count > 1 then
5583: FOR i IN 1..x_msg_count LOOP
5584: x_tmp_var := fnd_msg_pub.get(p_encoded => fnd_api.g_false);
5585: x_tmp_var1 := substrb(x_tmp_var1 || ' '|| x_tmp_var,1,4000);
5586: END LOOP;
5587: x_msg_data := x_tmp_var1;
5588: END IF;
6808:
6809: begin
6810:
6811: IF p_import_list_header_id IS NULL THEN
6812: RAISE FND_API.G_EXC_ERROR;
6813: END IF;
6814: p_return_status := FND_API.G_RET_STS_SUCCESS;
6815:
6816: FND_MESSAGE.set_name('AMS', 'AMS_IMP_FLD_DATATYPE_ERROR_CHK');
6810:
6811: IF p_import_list_header_id IS NULL THEN
6812: RAISE FND_API.G_EXC_ERROR;
6813: END IF;
6814: p_return_status := FND_API.G_RET_STS_SUCCESS;
6815:
6816: FND_MESSAGE.set_name('AMS', 'AMS_IMP_FLD_DATATYPE_ERROR_CHK');
6817: l_invalid_number := FND_MESSAGE.get;
6818: FND_MESSAGE.set_name('AMS', 'AMS_IMP_FLD_COL_SIZE_ERROR_CHK');
7657:
7658:
7659: EXCEPTION
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,
8266:
8267:
8268: EXCEPTION
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,
10044:
10045: begin
10046:
10047: IF p_import_list_header_id IS NULL THEN
10048: RAISE FND_API.G_EXC_ERROR;
10049: END IF;
10050: p_return_status := FND_API.G_RET_STS_SUCCESS;
10051:
10052: FND_MESSAGE.set_name('AMS', 'AMS_IMP_FLD_DATATYPE_ERROR_CHK');
10046:
10047: IF p_import_list_header_id IS NULL THEN
10048: RAISE FND_API.G_EXC_ERROR;
10049: END IF;
10050: p_return_status := FND_API.G_RET_STS_SUCCESS;
10051:
10052: FND_MESSAGE.set_name('AMS', 'AMS_IMP_FLD_DATATYPE_ERROR_CHK');
10053: l_invalid_number := FND_MESSAGE.get;
10054: FND_MESSAGE.set_name('AMS', 'AMS_IMP_FLD_COL_SIZE_ERROR_CHK');
11095: and error_type = 'E');
11096:
11097: EXCEPTION
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,
11982:
11983: begin
11984:
11985: IF p_import_list_header_id IS NULL THEN
11986: RAISE FND_API.G_EXC_ERROR;
11987: END IF;
11988: p_return_status := FND_API.G_RET_STS_SUCCESS;
11989:
11990: FND_MESSAGE.set_name('AMS', 'AMS_IMP_FLD_DATATYPE_ERROR_CHK');
11984:
11985: IF p_import_list_header_id IS NULL THEN
11986: RAISE FND_API.G_EXC_ERROR;
11987: END IF;
11988: p_return_status := FND_API.G_RET_STS_SUCCESS;
11989:
11990: FND_MESSAGE.set_name('AMS', 'AMS_IMP_FLD_DATATYPE_ERROR_CHK');
11991: l_invalid_number := FND_MESSAGE.get;
11992: FND_MESSAGE.set_name('AMS', 'AMS_IMP_FLD_COL_SIZE_ERROR_CHK');
13401: -- >>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>
13402:
13403: EXCEPTION
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,
13495: and loc.country = p_country
13496: and nvl(loc.city,nvl(p_city,'x')) = nvl(p_city,'x');
13497:
13498: begin
13499: x_return_status := FND_API.g_ret_sts_success;
13500: l_address_key := hz_fuzzy_pub.Generate_Key (
13501: p_key_type => 'ADDRESS',
13502: p_address1 => p_address1,
13503: p_postal_code => p_pcode
13513: end if;
13514: p_location_id := l_loc_id;
13515: exception
13516: when others then
13517: x_return_status := FND_API.g_ret_sts_unexp_error ;
13518: IF FND_MSG_PUB.check_msg_level(FND_MSG_PUB.g_msg_lvl_unexp_error) THEN
13519: FND_MSG_PUB.add_exc_msg(g_pkg_name,'address_echeck');
13520: END IF;
13521: FND_MSG_PUB.count_and_get(
13518: IF FND_MSG_PUB.check_msg_level(FND_MSG_PUB.g_msg_lvl_unexp_error) THEN
13519: FND_MSG_PUB.add_exc_msg(g_pkg_name,'address_echeck');
13520: END IF;
13521: FND_MSG_PUB.count_and_get(
13522: p_encoded => FND_API.g_false,
13523: p_count => x_msg_count,
13524: p_data => x_msg_data
13525: );
13526:
13840: if l_status_code = 'STAGED' then
13841: if l_file_type = 'XML' and l_execute_mode <> 'R' then
13842: Process_customers_xml (
13843: 1, -- p_api_version_number
13844: FND_API.G_FALSE , -- p_init_msg_list
13845: FND_API.G_FALSE , -- p_commit
13846: FND_API.G_VALID_LEVEL_FULL, -- p_validation_level
13847: x_rstatus ,
13848: x_mcount ,
13841: if l_file_type = 'XML' and l_execute_mode <> 'R' then
13842: Process_customers_xml (
13843: 1, -- p_api_version_number
13844: FND_API.G_FALSE , -- p_init_msg_list
13845: FND_API.G_FALSE , -- p_commit
13846: FND_API.G_VALID_LEVEL_FULL, -- p_validation_level
13847: x_rstatus ,
13848: x_mcount ,
13849: x_mdata ,
13842: Process_customers_xml (
13843: 1, -- p_api_version_number
13844: FND_API.G_FALSE , -- p_init_msg_list
13845: FND_API.G_FALSE , -- p_commit
13846: FND_API.G_VALID_LEVEL_FULL, -- p_validation_level
13847: x_rstatus ,
13848: x_mcount ,
13849: x_mdata ,
13850: p_import_list_header_id ,
13851: l_rec_update_flag -- p_update_flag
13852: );
13853: if x_mcount > 1 then
13854: FOR i IN 1..x_mcount LOOP
13855: x_tmp_var := fnd_msg_pub.get(p_encoded => fnd_api.g_false);
13856: x_tmp_var1 := substrb(x_tmp_var1 || ' '|| x_tmp_var,1,4000);
13857: END LOOP;
13858: x_mdata := x_tmp_var1;
13859: END IF;
14414: status_date = sysdate
14415: where import_list_header_id = p_import_list_header_id;
14416: commit;
14417:
14418: RAISE FND_API.g_exc_unexpected_error;
14419: end if;
14420:
14421: -- >>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>..
14422: /*
14518: AMS_ListGeneration_PKG.create_import_list
14519: ( 1,
14520: 'T',
14521: 'T',
14522: FND_API.G_VALID_LEVEL_FULL,
14523: p_owner_user_id,
14524: p_import_list_header_id,
14525: i_return_status,
14526: i_msg_count,
14574: p_msg_type => 'DEBUG'
14575: );
14576: commit;
14577: IF l_request_id = 0 THEN
14578: RAISE FND_API.g_exc_unexpected_error;
14579: end if;
14580: */
14581: end if;
14582: end if;
15368:
15369: begin
15370:
15371: IF p_import_list_header_id IS NULL THEN
15372: RAISE FND_API.G_EXC_ERROR;
15373: END IF;
15374: p_return_status := FND_API.G_RET_STS_SUCCESS;
15375:
15376: FND_MESSAGE.set_name('AMS', 'AMS_IMP_FLD_DATATYPE_ERROR_CHK');
15370:
15371: IF p_import_list_header_id IS NULL THEN
15372: RAISE FND_API.G_EXC_ERROR;
15373: END IF;
15374: p_return_status := FND_API.G_RET_STS_SUCCESS;
15375:
15376: FND_MESSAGE.set_name('AMS', 'AMS_IMP_FLD_DATATYPE_ERROR_CHK');
15377: l_invalid_number := FND_MESSAGE.get;
15378: FND_MESSAGE.set_name('AMS', 'AMS_IMP_FLD_COL_SIZE_ERROR_CHK');
15844:
15845:
15846: EXCEPTION
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,
16009: -- This program is for customer import for XML data.
16010:
16011: PROCEDURE Process_customers_xml (
16012: p_api_version_number IN NUMBER,
16013: p_init_msg_list IN VARCHAR2 := FND_API.G_FALSE,
16014: p_commit IN VARCHAR2 := FND_API.G_FALSE,
16015: p_validation_level IN NUMBER := FND_API.G_VALID_LEVEL_FULL,
16016: x_return_status OUT NOCOPY VARCHAR2,
16017: x_msg_count OUT NOCOPY NUMBER,
16010:
16011: PROCEDURE Process_customers_xml (
16012: p_api_version_number IN NUMBER,
16013: p_init_msg_list IN VARCHAR2 := FND_API.G_FALSE,
16014: p_commit IN VARCHAR2 := FND_API.G_FALSE,
16015: p_validation_level IN NUMBER := FND_API.G_VALID_LEVEL_FULL,
16016: x_return_status OUT NOCOPY VARCHAR2,
16017: x_msg_count OUT NOCOPY NUMBER,
16018: x_msg_data OUT NOCOPY VARCHAR2,
16011: PROCEDURE Process_customers_xml (
16012: p_api_version_number IN NUMBER,
16013: p_init_msg_list IN VARCHAR2 := FND_API.G_FALSE,
16014: p_commit IN VARCHAR2 := FND_API.G_FALSE,
16015: p_validation_level IN NUMBER := FND_API.G_VALID_LEVEL_FULL,
16016: x_return_status OUT NOCOPY VARCHAR2,
16017: x_msg_count OUT NOCOPY NUMBER,
16018: x_msg_data OUT NOCOPY VARCHAR2,
16019: p_import_list_header_id IN NUMBER,
18425: --==============================================================
18426: -- INITIALIZE THE API STATIC VALUES ===
18427: --==============================================================
18428: l_api_version := 1.0;
18429: l_init_msg_list := FND_API.g_true;
18430: l_validation_level := FND_API.g_valid_level_full;
18431: l_commit := FND_API.g_true;
18432: l_msg_count := 0;
18433: l_source_object_code := nvl(p_source_object_code,'PARTY');
18426: -- INITIALIZE THE API STATIC VALUES ===
18427: --==============================================================
18428: l_api_version := 1.0;
18429: l_init_msg_list := FND_API.g_true;
18430: l_validation_level := FND_API.g_valid_level_full;
18431: l_commit := FND_API.g_true;
18432: l_msg_count := 0;
18433: l_source_object_code := nvl(p_source_object_code,'PARTY');
18434: l_note_status := 'I';
18427: --==============================================================
18428: l_api_version := 1.0;
18429: l_init_msg_list := FND_API.g_true;
18430: l_validation_level := FND_API.g_valid_level_full;
18431: l_commit := FND_API.g_true;
18432: l_msg_count := 0;
18433: l_source_object_code := nvl(p_source_object_code,'PARTY');
18434: l_note_status := 'I';
18435: l_note_type := 'AS_USER';
18479: ,p_last_update_login => l_last_update_login
18480: );
18481: if x_msg_count > 1 then
18482: FOR i IN 1..x_msg_count LOOP
18483: x_tmp_var := fnd_msg_pub.get(p_encoded => fnd_api.g_false);
18484: x_tmp_var1 := substrb(x_tmp_var1 || ' '|| x_tmp_var,1,4000);
18485: END LOOP;
18486: END IF;
18487: if x_return_status <> 'S' then
18623: and pty.status = 'A'
18624: group by b2b.import_source_line_id;
18625:
18626: BEGIN
18627: x_return_status := FND_API.G_RET_STS_SUCCESS;
18628: -- TO POPULATE ORG_KEY
18629: l_last_fetch := FALSE;
18630:
18631: open c_org_key;
18778: -- TO GET THE MAX PARTY_ID
18779:
18780: EXCEPTION
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,
18896: and pty.status = 'A'
18897: group by b2b.import_source_line_id;
18898:
18899: BEGIN
18900: x_return_status := FND_API.G_RET_STS_SUCCESS;
18901: -- TO POPULATE ORG_KEY
18902: l_last_fetch := FALSE;
18903: open c_org_key;
18904: LOOP
19050: -- TO GET THE MAX PARTY_ID
19051:
19052: EXCEPTION
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,
19183: and load_status in ('ACTIVE','RELOAD')
19184: group by person_key,email_address,transposed_phone_number,address1,country;
19185:
19186: begin
19187: x_return_status := FND_API.G_RET_STS_SUCCESS;
19188: -- TO POPULATE person_KEY
19189: l_last_fetch := FALSE;
19190:
19191: open c_per_key;
19376: -- TO CHECK WITH dedup
19377:
19378: EXCEPTION
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,
19492: and b2c.orig_system_reference = party.orig_system_reference
19493: group by b2c.import_source_line_id;
19494:
19495: begin
19496: x_return_status := FND_API.G_RET_STS_SUCCESS;
19497: -- TO POPULATE person_KEY
19498: l_last_fetch := FALSE;
19499: open c_per_key;
19500: LOOP
19638: close c_address_country;
19639: -- TO CHECK WITH address and country
19640: EXCEPTION
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,
19843: and load_status in ('ACTIVE','RELOAD')
19844: group by org_key,person_key,email_address,transposed_phone_number;
19845:
19846: begin
19847: x_return_status := FND_API.G_RET_STS_SUCCESS;
19848: -- TO POPULATE person_KEY
19849: l_last_fetch := FALSE;
19850: open c_per_key;
19851: LOOP
20029: -- TO CHECK WITH dedup
20030:
20031: EXCEPTION
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,
20198: and cpoint.status = 'A'
20199: group by b2b.import_source_line_id;
20200:
20201: begin
20202: x_return_status := FND_API.G_RET_STS_SUCCESS;
20203: -- TO POPULATE person_KEY
20204: l_last_fetch := FALSE;
20205: open c_per_key;
20206: LOOP
20345: -- TO CHECK WITH phone
20346:
20347: EXCEPTION
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,
20414: and nvl(loc.city,nvl(b2b.city,'x')) = nvl(b2b.city,'x')
20415: group by b2b.import_source_line_id;
20416:
20417: begin
20418: x_return_status := FND_API.G_RET_STS_SUCCESS;
20419: -- TO POPULATE address_KEY
20420: l_last_fetch := FALSE;
20421: open c_addr_key;
20422: LOOP
20501: -- TO CHECK WITH address
20502:
20503: EXCEPTION
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,
20572: and nvl(loc.city,nvl(b2b.org_city,'x')) = nvl(b2b.org_city,'x')
20573: group by b2b.import_source_line_id;
20574:
20575: begin
20576: x_return_status := FND_API.G_RET_STS_SUCCESS;
20577: -- TO POPULATE address_KEY
20578: l_last_fetch := FALSE;
20579: open c_addr_key;
20580: LOOP
20659: -- TO CHECK WITH address
20660:
20661: EXCEPTION
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,
20730: and nvl(loc.city,nvl(b2c.city,'x')) = nvl(b2c.city,'x')
20731: group by b2c.import_source_line_id;
20732:
20733: begin
20734: x_return_status := FND_API.G_RET_STS_SUCCESS;
20735: -- TO POPULATE address_KEY
20736: l_last_fetch := FALSE;
20737: open c_addr_key;
20738: LOOP
20817: -- TO CHECK WITH address
20818:
20819: EXCEPTION
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,
21028: AMS_ListGeneration_PKG.create_import_list
21029: ( 1,
21030: 'T',
21031: 'T',
21032: FND_API.G_VALID_LEVEL_FULL,
21033: l_owner_user_id,
21034: p_import_list_header_id,
21035: i_return_status,
21036: i_msg_count,
21143: close c_ordered_recs;
21144: commit;
21145: EXCEPTION
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,
21256: end if ; -- l_b2b_flag = 'N'
21257: commit;
21258: EXCEPTION
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,