[Home] [Help]
67: write_log(3, 'Message Count:'||G_MESG_COUNT);
68: For i IN 1..G_MESG_COUNT Loop
69: FND_MSG_PUB.Get(
70: p_msg_index => i,
71: p_encoded => FND_API.G_FALSE,
72: p_data => l_msg_data,
73: p_msg_index_out =>l_msg_index_out
74: );
75:
144: -- dbms_output.put_line(l_msg_data);
145: Exception
146: when others then
147: write_log(2, 'write_errors failed!');
148: G_return_status := FND_API.G_RET_STS_ERROR;
149: END write_errors;
150:
151: --------------------------------------------------------
152: -- name: writeBak
239: update as_import_interface
240: set load_status = 'DUPLICATE', sales_lead_id = pI.sales_lead_id
241: where import_interface_id = pI.import_interface_id;
242: else
243: G_return_status := FND_API.G_RET_STS_ERROR;
244: End if;
245: Exception
246: when others then
247: write_log(2, 'writeBak failed!');
244: End if;
245: Exception
246: when others then
247: write_log(2, 'writeBak failed!');
248: G_return_status := FND_API.G_RET_STS_ERROR;
249: end writeBak;
250:
251: --------------------------------------------------------
252: -- name: cont_pnt_dedupe
459: x_msg_count,
460: x_msg_data
461: );
462:
463: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
464: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
465: END IF;
466:
467: End deDupe_Check;
460: x_msg_data
461: );
462:
463: IF x_return_status <> FND_API.G_RET_STS_SUCCESS THEN
464: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
465: END IF;
466:
467: End deDupe_Check;
468:
859: end if;
860:
861: l_index := l_index + 1;
862: End Loop;
863: G_return_status := FND_API.G_RET_STS_SUCCESS ;
864:
865: Exception
866: when NO_DATA_FOUND then
867: G_return_status := FND_API.G_RET_STS_SUCCESS ;
863: G_return_status := FND_API.G_RET_STS_SUCCESS ;
864:
865: Exception
866: when NO_DATA_FOUND then
867: G_return_status := FND_API.G_RET_STS_SUCCESS ;
868: when others then
869: G_return_status := FND_API.G_RET_STS_ERROR;
870: write_log(2, sqlerrm);
871: End do_assign_flex;
865: Exception
866: when NO_DATA_FOUND then
867: G_return_status := FND_API.G_RET_STS_SUCCESS ;
868: when others then
869: G_return_status := FND_API.G_RET_STS_ERROR;
870: write_log(2, sqlerrm);
871: End do_assign_flex;
872:
873: --------------------------------------------------------
923: l_per_rec.party_rec.party_number := pI.party_number;
924: l_per_rec.party_rec.validated_flag := pI.parties_validated_flag;
925: -- orig_system_reference
926: if (pI.orig_system_reference is not null) or
927: (pI.orig_system_reference <> FND_API.G_MISS_CHAR) Then
928: l_per_rec.party_rec.orig_system_reference := pI.orig_system_reference;
929: else
930: l_per_rec.party_rec.orig_system_reference := pI.import_interface_id;
931: end if;
967: 'HZ_PARTIES',
968: pI.import_interface_id,
969: G_return_status
970: );
971: if G_return_status = FND_API.G_RET_STS_SUCCESS Then
972: If (pType = 'PERSON') then
973: -- l_per_rec.party_rec.customer_key := pI.customer_key;
974: HZ_PARTY_V2PUB.create_person (
975: p_init_msg_list => FND_API.G_FALSE,
971: if G_return_status = FND_API.G_RET_STS_SUCCESS Then
972: If (pType = 'PERSON') then
973: -- l_per_rec.party_rec.customer_key := pI.customer_key;
974: HZ_PARTY_V2PUB.create_person (
975: p_init_msg_list => FND_API.G_FALSE,
976: p_person_rec => l_per_rec,
977: x_return_status => G_return_status,
978: x_msg_count => G_MESG_COUNT,
979: x_msg_data => l_msg_data,
983: );
984: Elsif (pType = 'CONTACT') then
985: -- l_per_rec.party_rec.customer_key := pI.contact_key;
986: HZ_PARTY_V2PUB.create_person (
987: p_init_msg_list => FND_API.G_FALSE,
988: p_person_rec => l_per_rec,
989: x_return_status => G_return_status,
990: x_msg_count => G_MESG_COUNT,
991: x_msg_data => l_msg_data,
993: x_party_number => l_partyNumber,
994: x_profile_id => l_profile
995: );
996: Else
997: G_return_status := FND_API.G_RET_STS_ERROR;
998: End if;
999: End If;
1000:
1001: -- If error raise exception
998: End if;
999: End If;
1000:
1001: -- If error raise exception
1002: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1003: write_log(3, 'Creating Person failed');
1004: RAISE FND_API.G_EXC_ERROR;
1005: ELSE
1006: If (pType = 'PERSON') then
1000:
1001: -- If error raise exception
1002: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1003: write_log(3, 'Creating Person failed');
1004: RAISE FND_API.G_EXC_ERROR;
1005: ELSE
1006: If (pType = 'PERSON') then
1007: write_log (3, 'Person created: '||pI.party_id);
1008: Elsif (pType = 'CONTACT') then
1052: l_res_rec.contact_level_table_id:= pI.party_site_id;
1053:
1054: write_log (3, 'Creating CntPreference: AMAIL');
1055: HZ_CONTACT_PREFERENCE_V2PUB.create_contact_preference (
1056: p_init_msg_list => FND_API.G_FALSE,
1057: p_contact_preference_rec => l_res_rec,
1058: x_return_status => G_return_status,
1059: x_msg_count => G_MESG_COUNT,
1060: x_msg_data => l_msg_data,
1059: x_msg_count => G_MESG_COUNT,
1060: x_msg_data => l_msg_data,
1061: x_contact_preference_id => l_res_id
1062: );
1063: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1064: write_log(3, 'Create CntPreference failed');
1065: ELSE
1066: write_log(3, 'CntPreference created: ' || l_res_id);
1067: END IF;
1066: write_log(3, 'CntPreference created: ' || l_res_id);
1067: END IF;
1068: when others then
1069: write_log(3, 'Select on Contact Preference Failed');
1070: RAISE FND_API.G_EXC_ERROR;
1071: End;
1072: End if;
1073:
1074: IF (pI.cont_do_not_mail_flag is not Null)
1092: l_res_rec.contact_level_table_id:= pI.rel_party_id;
1093:
1094: write_log (3, 'Creating CntPreference: CMAIL');
1095: HZ_CONTACT_PREFERENCE_V2PUB.create_contact_preference (
1096: p_init_msg_list => FND_API.G_FALSE,
1097: p_contact_preference_rec => l_res_rec,
1098: x_return_status => G_return_status,
1099: x_msg_count => G_MESG_COUNT,
1100: x_msg_data => l_msg_data,
1099: x_msg_count => G_MESG_COUNT,
1100: x_msg_data => l_msg_data,
1101: x_contact_preference_id => l_res_id
1102: );
1103: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1104: write_log(3, 'Create CntPreference failed');
1105: ELSE
1106: write_log(3, 'CntPreference created: ' || l_res_id);
1107: END IF;
1105: ELSE
1106: write_log(3, 'CntPreference created: ' || l_res_id);
1107: END IF;
1108: when others then
1109: RAISE FND_API.G_EXC_ERROR;
1110: End;
1111: End if;
1112:
1113: If (pI.do_not_phone_flag is not Null) and
1132: l_res_rec.contact_level_table_id:= pI.rel_party_id;
1133:
1134: write_log (3, 'Creating CntPreference: PHONE');
1135: HZ_CONTACT_PREFERENCE_V2PUB.create_contact_preference (
1136: p_init_msg_list => FND_API.G_FALSE,
1137: p_contact_preference_rec => l_res_rec,
1138: x_return_status => G_return_status,
1139: x_msg_count => G_MESG_COUNT,
1140: x_msg_data => l_msg_data,
1139: x_msg_count => G_MESG_COUNT,
1140: x_msg_data => l_msg_data,
1141: x_contact_preference_id => l_res_id
1142: );
1143: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1144: write_log(3, 'Create CntPreference failed');
1145: ELSE
1146: write_log(3, 'CntPreference created: ' || l_res_id);
1147: END IF;
1145: ELSE
1146: write_log(3, 'CntPreference created: ' || l_res_id);
1147: END IF;
1148: when others then
1149: RAISE FND_API.G_EXC_ERROR;
1150: End;
1151: -- SOLIN, bug 4637420
1152: Begin
1153: l_res_id := NULL;
1167: l_res_rec.contact_level_table_id:= pI.phone_id;
1168:
1169: write_log (3, 'Creating CntPreference: PHONE');
1170: HZ_CONTACT_PREFERENCE_V2PUB.create_contact_preference (
1171: p_init_msg_list => FND_API.G_FALSE,
1172: p_contact_preference_rec => l_res_rec,
1173: x_return_status => G_return_status,
1174: x_msg_count => G_MESG_COUNT,
1175: x_msg_data => l_msg_data,
1174: x_msg_count => G_MESG_COUNT,
1175: x_msg_data => l_msg_data,
1176: x_contact_preference_id => l_res_id
1177: );
1178: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1179: write_log(3, 'Create CntPreference failed');
1180: ELSE
1181: write_log(3, 'CntPreference created: ' || l_res_id);
1182: END IF;
1180: ELSE
1181: write_log(3, 'CntPreference created: ' || l_res_id);
1182: END IF;
1183: when others then
1184: RAISE FND_API.G_EXC_ERROR;
1185: End;
1186: -- SOLIN, end bug 4637420
1187: End if;
1188:
1206: l_res_rec.contact_level_table_id:= pI.rel_party_id;
1207:
1208: write_log (3, 'Creating CntPreference: FAX');
1209: HZ_CONTACT_PREFERENCE_V2PUB.create_contact_preference (
1210: p_init_msg_list => FND_API.G_FALSE,
1211: p_contact_preference_rec => l_res_rec,
1212: x_return_status => G_return_status,
1213: x_msg_count => G_MESG_COUNT,
1214: x_msg_data => l_msg_data,
1213: x_msg_count => G_MESG_COUNT,
1214: x_msg_data => l_msg_data,
1215: x_contact_preference_id => l_res_id
1216: );
1217: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1218: write_log(3, 'Create CntPreference failed');
1219: ELSE
1220: write_log(3, 'CntPreference created: ' || l_res_id);
1221: END IF;
1219: ELSE
1220: write_log(3, 'CntPreference created: ' || l_res_id);
1221: END IF;
1222: when others then
1223: RAISE FND_API.G_EXC_ERROR;
1224: End;
1225: End if;
1226:
1227: If (pI.do_not_email_flag is not Null) and
1244: l_res_rec.contact_level_table_id:= pI.rel_party_id;
1245:
1246: write_log (3, 'Creating CntPreference: EMAIL');
1247: HZ_CONTACT_PREFERENCE_V2PUB.create_contact_preference (
1248: p_init_msg_list => FND_API.G_FALSE,
1249: p_contact_preference_rec => l_res_rec,
1250: x_return_status => G_return_status,
1251: x_msg_count => G_MESG_COUNT,
1252: x_msg_data => l_msg_data,
1251: x_msg_count => G_MESG_COUNT,
1252: x_msg_data => l_msg_data,
1253: x_contact_preference_id => l_res_id
1254: );
1255: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1256: write_log(3, 'Create CntPreference failed');
1257: ELSE
1258: write_log(3, 'CntPreference created: ' || l_res_id);
1259: END IF;
1257: ELSE
1258: write_log(3, 'CntPreference created: ' || l_res_id);
1259: END IF;
1260: when others then
1261: RAISE FND_API.G_EXC_ERROR;
1262: End;
1263: End if;
1264: End do_contact_preference;
1265:
1317: -- swkhanna 5/20/02 commented for Bug 2381261
1318: --l_cp_rec.primary_flag := 'Y';
1319: l_cp_rec.orig_system_reference := pI.import_interface_id;
1320: IF (pI.cnt_pnt_content_source_type is not null and
1321: pI.cnt_pnt_content_source_type <> FND_API.G_MISS_CHAR)
1322: THEN
1323: l_cp_rec.content_source_type := pI.cnt_pnt_content_source_type;
1324: ELSE
1325: l_cp_rec.content_source_type := 'USER_ENTERED';
1339: pI.import_interface_id,
1340: G_return_status
1341: );
1342:
1343: If G_return_status = FND_API.G_RET_STS_SUCCESS Then
1344: If l_dup_phone = 'N' then
1345: If (pI.phone_number is not null) then
1346: l_cp_rec.contact_point_type := 'PHONE';
1347: -- swkhanna 5/20 for bug 2381261
1359:
1360: write_log(3, 'Inserting the phone rec');
1361:
1362: HZ_CONTACT_POINT_V2PUB.create_contact_point (
1363: p_init_msg_list => FND_API.G_FALSE,
1364: p_contact_point_rec => l_cp_rec,
1365: p_phone_rec => l_ph_rec,
1366: x_return_status => G_return_status,
1367: x_msg_count => G_MESG_COUNT,
1369: x_contact_point_id => l_cpid
1370: );
1371:
1372: -- ffang 062001, put contact_point_id into phone_id
1373: IF G_return_status = FND_API.G_RET_STS_SUCCESS Then
1374: pI.phone_id := l_cpid;
1375: write_log(3, 'Contact Point created-PHONE: ' || l_cpid);
1376: ELSE
1377: write_log(3, 'Contact Point creation faild for PHONE');
1398: l_ph_rec.raw_phone_number := NULL;
1399:
1400: write_log(3, 'Inserting the fax rec');
1401: HZ_CONTACT_POINT_V2PUB.create_contact_point (
1402: p_init_msg_list => FND_API.G_FALSE,
1403: p_contact_point_rec => l_cp_rec,
1404: p_phone_rec => l_ph_rec,
1405: x_return_status => G_return_status,
1406: x_msg_count => G_MESG_COUNT,
1406: x_msg_count => G_MESG_COUNT,
1407: x_msg_data => l_msg_data,
1408: x_contact_point_id => l_cpid
1409: );
1410: IF G_return_status = FND_API.G_RET_STS_SUCCESS Then
1411: write_log(3, 'Contact Point created-FAX: ' || l_cpid);
1412: ELSE
1413: write_log(3, 'Contact Point creation faild for FAX');
1414: return;
1427: l_email_rec.email_address := pI.email_address;
1428: write_log(3, 'Inserting an email rec');
1429:
1430: HZ_CONTACT_POINT_V2PUB.create_contact_point (
1431: p_init_msg_list => FND_API.G_FALSE,
1432: p_contact_point_rec => l_cp_rec,
1433: p_email_rec => l_email_rec,
1434: x_return_status => G_return_status,
1435: x_msg_count => G_MESG_COUNT,
1435: x_msg_count => G_MESG_COUNT,
1436: x_msg_data => l_msg_data,
1437: x_contact_point_id => l_cpid
1438: );
1439: IF G_return_status = FND_API.G_RET_STS_SUCCESS Then
1440: write_log(3, 'Contact Point created-EMAIL: ' || l_cpid);
1441: ELSE
1442: write_log(3, 'Contact Point creation faild for EMAIL');
1443: return;
1456: l_web_rec.url := pI.url;
1457: write_log(3, 'Inserting an url rec');
1458:
1459: HZ_CONTACT_POINT_V2PUB.create_contact_point (
1460: p_init_msg_list => FND_API.G_FALSE,
1461: p_contact_point_rec => l_cp_rec,
1462: p_web_rec => l_web_rec,
1463: x_return_status => G_return_status,
1464: x_msg_count => G_MESG_COUNT,
1464: x_msg_count => G_MESG_COUNT,
1465: x_msg_data => l_msg_data,
1466: x_contact_point_id => l_cpid
1467: );
1468: IF G_return_status = FND_API.G_RET_STS_SUCCESS Then
1469: write_log(3, 'Contact Point created-URL: ' || l_cpid);
1470: ELSE
1471: write_log(3, 'Contact Point creation faild for WEB');
1472: return;
1521: l_cp_rec.status := 'A';
1522: -- ffang 082101, is it OK to use interface table's owner_table_name and
1523: -- owner_table_id?
1524: IF (pCP.owner_table_name is not null and
1525: pCP.owner_table_name <> FND_API.G_MISS_CHAR)
1526: THEN
1527: l_cp_rec.owner_table_name := pCP.owner_table_name;
1528: ELSE
1529: l_cp_rec.owner_table_name := 'HZ_PARTIES';
1528: ELSE
1529: l_cp_rec.owner_table_name := 'HZ_PARTIES';
1530: END IF;
1531: IF (pCP.owner_table_id is not null and
1532: pCP.owner_table_id <> FND_API.G_MISS_NUM)
1533: THEN
1534: l_cp_rec.owner_table_id := pCP.owner_table_id;
1535: ELSE
1536: If(pI.party_type = 'ORGANIZATION') Then
1539: l_cp_rec.owner_table_id := pI.party_id;
1540: End if;
1541: END IF;
1542: IF (pCP.primary_flag is not null AND
1543: pCP.primary_flag <> FND_API.G_MISS_CHAR) THEN
1544: l_cp_rec.primary_flag := pCP.primary_flag;
1545: ELSE
1546: l_cp_rec.primary_flag := 'N';
1547: END IF;
1545: ELSE
1546: l_cp_rec.primary_flag := 'N';
1547: END IF;
1548: IF (pCP.orig_system_reference is not NULL AND
1549: pCP.orig_system_reference <> FND_API.G_MISS_CHAR) THEN
1550: l_cp_rec.orig_system_reference := pCP.orig_system_reference;
1551: ELSE
1552: l_cp_rec.orig_system_reference := pI.import_interface_id;
1553: END IF;
1551: ELSE
1552: l_cp_rec.orig_system_reference := pI.import_interface_id;
1553: END IF;
1554: IF (pCP.content_source_type is not null and
1555: pCP.content_source_type <> FND_API.G_MISS_CHAR)
1556: THEN
1557: l_cp_rec.content_source_type := pCP.content_source_type;
1558: ELSE
1559: l_cp_rec.content_source_type := 'USER_ENTERED';
1582: write_log (3, pCP.contact_point_type ||'-'||pCP.phone_line_type||':'
1583: ||G_return_status);
1584: -- ffang 082101, should use contact_point_type and phone_line_type to
1585: -- determine what's the type.
1586: -- If G_return_status = FND_API.G_RET_STS_SUCCESS Then
1587: -- If (pI.phone_number is not null) then
1588: IF pCP.contact_point_type = 'PHONE' THEN
1589:
1590: IF pCP.phone_line_type <> 'FAX' THEN -- 'PHONE'
1603: l_ph_rec.raw_phone_number := pCP.raw_phone_number;
1604:
1605: write_log(3, 'Inserting the phone rec');
1606: HZ_CONTACT_POINT_V2PUB.create_contact_point (
1607: p_init_msg_list => FND_API.G_FALSE,
1608: p_contact_point_rec => l_cp_rec,
1609: p_phone_rec => l_ph_rec,
1610: x_return_status => G_return_status,
1611: x_msg_count => G_MESG_COUNT,
1612: x_msg_data => l_msg_data,
1613: x_contact_point_id => l_cpid
1614: );
1615: -- ffang 062001, put contact_point_id into phone_id
1616: IF G_return_status = FND_API.G_RET_STS_SUCCESS Then
1617: pI.phone_id := l_cpid;
1618: write_log(3, 'Contact Point created: ' || l_cpid);
1619: END IF;
1620: END IF; -- if l_dup_phone = N
1640: l_ph_rec.raw_phone_number := pCP.raw_phone_number;
1641:
1642: write_log(3, 'Inserting the fax rec');
1643: HZ_CONTACT_POINT_V2PUB.create_contact_point (
1644: p_init_msg_list => FND_API.G_FALSE,
1645: p_contact_point_rec => l_cp_rec,
1646: p_phone_rec => l_ph_rec,
1647: x_return_status => G_return_status,
1648: x_msg_count => G_MESG_COUNT,
1648: x_msg_count => G_MESG_COUNT,
1649: x_msg_data => l_msg_data,
1650: x_contact_point_id => l_cpid
1651: );
1652: IF G_return_status = FND_API.G_RET_STS_SUCCESS Then
1653: write_log(3, 'Contact Point created: ' || l_cpid);
1654: END IF;
1655: End If;
1656: End If;
1662: l_email_rec.email_address := pCP.email_address; --pI.email_address;
1663:
1664: write_log(3, 'Inserting an email rec');
1665: HZ_CONTACT_POINT_V2PUB.create_contact_point (
1666: p_init_msg_list => FND_API.G_FALSE,
1667: p_contact_point_rec => l_cp_rec,
1668: p_email_rec => l_email_rec,
1669: x_return_status => G_return_status,
1670: x_msg_count => G_MESG_COUNT,
1670: x_msg_count => G_MESG_COUNT,
1671: x_msg_data => l_msg_data,
1672: x_contact_point_id => l_cpid
1673: );
1674: IF G_return_status = FND_API.G_RET_STS_SUCCESS Then
1675: write_log(3, 'Contact Point created: ' || l_cpid);
1676: END IF;
1677: END IF;
1678: -- End If;
1684: l_web_rec.url := pCP.url; -- pI.url;
1685:
1686: write_log(3, 'Inserting an url rec');
1687: HZ_CONTACT_POINT_V2PUB.create_contact_point (
1688: p_init_msg_list => FND_API.G_FALSE,
1689: p_contact_point_rec => l_cp_rec,
1690: p_web_rec => l_web_rec,
1691: x_return_status => G_return_status,
1692: x_msg_count => G_MESG_COUNT,
1692: x_msg_count => G_MESG_COUNT,
1693: x_msg_data => l_msg_data,
1694: x_contact_point_id => l_cpid
1695: );
1696: IF G_return_status = FND_API.G_RET_STS_SUCCESS Then
1697: write_log(3, 'Contact Point created: ' || l_cpid);
1698: END IF;
1699: -- End If;
1700: End If;
1771: l_location_rec.created_by_module := 'AML_LEAD_IMPORT';
1772: l_location_rec.application_id := 530;
1773:
1774: IF (pI.content_source_type is not NULL AND
1775: pI.content_source_type <> FND_API.G_MISS_CHAR)
1776: THEN
1777: l_location_rec.content_source_type := pI.content_source_type;
1778: ELSE
1779: l_location_rec.content_source_type := 'USER_ENTERED';
1793: pI.import_interface_id,
1794: G_return_status
1795: );
1796:
1797: If G_return_status = FND_API.G_RET_STS_SUCCESS Then
1798: HZ_LOCATION_V2PUB.create_location (
1799: p_init_msg_list => FND_API.G_FALSE,
1800: p_location_rec => l_location_rec,
1801: x_return_status => G_return_status,
1795: );
1796:
1797: If G_return_status = FND_API.G_RET_STS_SUCCESS Then
1798: HZ_LOCATION_V2PUB.create_location (
1799: p_init_msg_list => FND_API.G_FALSE,
1800: p_location_rec => l_location_rec,
1801: x_return_status => G_return_status,
1802: x_msg_count => G_MESG_COUNT,
1803: x_msg_data => l_msg_data,
1802: x_msg_count => G_MESG_COUNT,
1803: x_msg_data => l_msg_data,
1804: x_location_id => pI.location_id
1805: );
1806: If G_return_status <> FND_API.G_RET_STS_SUCCESS Then
1807: write_log(3, 'Create location failed');
1808: ELSE
1809: write_log(3, 'Location created: ' || pI.location_id);
1810: END IF;
1868: l_org_rec.party_rec.validated_flag := pI.parties_validated_flag;
1869: -- The expectation is pI.orig_system_reference will be concatenated with
1870: -- pI.orig_system_code.
1871: if (pI.orig_system_reference is not null) or
1872: (pI.orig_system_reference <> FND_API.G_MISS_CHAR) Then
1873: l_org_rec.party_rec.orig_system_reference := pI.orig_system_reference;
1874: else
1875: l_org_rec.party_rec.orig_system_reference := pI.import_interface_id;
1876: end if;
1902: pI.import_interface_id,
1903: G_return_status
1904: );
1905:
1906: if G_return_status = FND_API.G_RET_STS_SUCCESS Then
1907: HZ_PARTY_V2PUB.create_organization (
1908: p_init_msg_list => FND_API.G_FALSE,
1909: p_organization_rec => l_org_rec,
1910: x_return_status => G_return_status,
1904: );
1905:
1906: if G_return_status = FND_API.G_RET_STS_SUCCESS Then
1907: HZ_PARTY_V2PUB.create_organization (
1908: p_init_msg_list => FND_API.G_FALSE,
1909: p_organization_rec => l_org_rec,
1910: x_return_status => G_return_status,
1911: x_msg_count => G_MESG_COUNT,
1912: x_msg_data => l_msg_data,
1913: x_party_id => pI.party_id,
1914: x_party_number => l_hz_partyNumber,
1915: x_profile_id => l_hz_profile
1916: );
1917: IF G_return_status = FND_API.G_RET_STS_SUCCESS Then
1918: write_log (3, 'Organization created: '||pI.party_id);
1919: END IF;
1920: End if ;
1921:
1988: pI.import_interface_id,
1989: G_return_status
1990: );
1991: ELSIF p_type = 'REL' THEN
1992: G_return_status := FND_API.G_RET_STS_SUCCESS;
1993: END IF;
1994:
1995: If G_return_status = FND_API.G_RET_STS_SUCCESS Then
1996: HZ_PARTY_SITE_V2PUB.create_party_site (
1991: ELSIF p_type = 'REL' THEN
1992: G_return_status := FND_API.G_RET_STS_SUCCESS;
1993: END IF;
1994:
1995: If G_return_status = FND_API.G_RET_STS_SUCCESS Then
1996: HZ_PARTY_SITE_V2PUB.create_party_site (
1997: p_init_msg_list => FND_API.G_FALSE,
1998: p_party_site_rec => l_ps_rec,
1999: x_return_status => G_return_status,
1993: END IF;
1994:
1995: If G_return_status = FND_API.G_RET_STS_SUCCESS Then
1996: HZ_PARTY_SITE_V2PUB.create_party_site (
1997: p_init_msg_list => FND_API.G_FALSE,
1998: p_party_site_rec => l_ps_rec,
1999: x_return_status => G_return_status,
2000: x_msg_count => G_MESG_COUNT,
2001: x_msg_data => l_msg_data,
2003: x_party_site_number=> l_hz_psNumber
2004: );
2005:
2006: -- If error raise exception
2007: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
2008: write_log(3, 'Creating Party Site failed');
2009: write_log(3, 'insert error messages into as_imp_errors table');
2010: RAISE FND_API.G_EXC_ERROR;
2011: ELSE
2006: -- If error raise exception
2007: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
2008: write_log(3, 'Creating Party Site failed');
2009: write_log(3, 'insert error messages into as_imp_errors table');
2010: RAISE FND_API.G_EXC_ERROR;
2011: ELSE
2012: write_log(3, p_type||' Party Site created: '||l_hz_psid);
2013: -- IF p_type = 'ORG' THEN
2014: IF p_type in ('ORGANIZATION','PERSON') THEN
2020: l_ps_use_rec.party_site_id := l_hz_psid; -- pI.hz_psid;
2021: -- l_ps_use_rec.begin_date := sysdate;
2022: -- ffang 100501, if site_use_type is not passed in, then default it
2023: -- to 'BILL_TO'
2024: IF (pI.site_use_type is null OR pI.site_use_type = FND_API.G_MISS_CHAR)
2025: THEN
2026: l_ps_use_rec.site_use_type := 'BILL_TO';
2027: ELSE
2028: l_ps_use_rec.site_use_type := pI.site_use_type; -- 'BILL_TO';
2034: l_ps_use_rec.created_by_module := 'AML_LEAD_IMPORT';
2035: l_ps_use_rec.application_id := 530;
2036:
2037: HZ_PARTY_SITE_V2PUB.create_party_site_use (
2038: p_init_msg_list => FND_API.G_FALSE,
2039: p_party_site_use_rec => l_ps_use_rec,
2040: x_return_status => G_return_status,
2041: x_msg_count => G_MESG_COUNT,
2042: x_msg_data => l_msg_data,
2041: x_msg_count => G_MESG_COUNT,
2042: x_msg_data => l_msg_data,
2043: x_party_site_use_id => l_ps_use_id
2044: );
2045: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
2046: write_log(3, 'Creating Party Site Use failed');
2047: ELSE
2048: write_log(3, 'PS Use created: ' || l_ps_use_id);
2049: END IF;
2156: 'HZ_ORG_CONTACTS',
2157: pI.import_interface_id,
2158: G_return_status
2159: );
2160: If G_return_status = FND_API.G_RET_STS_SUCCESS Then
2161: write_log(3, 'Creating OrgContact');
2162: HZ_PARTY_CONTACT_V2PUB.create_org_contact (
2163: p_init_msg_list => FND_API.G_FALSE,
2164: p_org_contact_rec => l_org_con_rec,
2159: );
2160: If G_return_status = FND_API.G_RET_STS_SUCCESS Then
2161: write_log(3, 'Creating OrgContact');
2162: HZ_PARTY_CONTACT_V2PUB.create_org_contact (
2163: p_init_msg_list => FND_API.G_FALSE,
2164: p_org_contact_rec => l_org_con_rec,
2165: x_return_status => G_return_status,
2166: x_msg_count => G_MESG_COUNT,
2167: x_msg_data => l_msg_data,
2169: x_party_rel_id => l_party_rel_id,
2170: x_party_id => pI.rel_party_id,
2171: x_party_number => l_party_number
2172: );
2173: If G_return_status = FND_API.G_RET_STS_SUCCESS Then
2174: write_log (3, 'OrgContact created: '||
2175: G_LOCAL_ORG_CONTACT_ID);
2176: write_log (3, 'Party Relationship created: '||
2177: l_party_rel_id||':'||pI.rel_party_id);
2177: l_party_rel_id||':'||pI.rel_party_id);
2178: -- ffang 102401, for bug 2075424, if location is not
2179: -- created, don't create party_site
2180: IF (pI.location_id is not null and
2181: pI.location_id <> FND_API.G_MISS_NUM)
2182: THEN
2183: write_log(3,'Creating party site for Relationship');
2184: do_create_ps_psu(pI, pI.rel_party_id, 'REL',
2185: G_return_status);
2183: write_log(3,'Creating party site for Relationship');
2184: do_create_ps_psu(pI, pI.rel_party_id, 'REL',
2185: G_return_status);
2186: -- If error raise exception
2187: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
2188: write_log(3, 'Creating PS for Rel failed');
2189: END IF;
2190: END IF;
2191:
2190: END IF;
2191:
2192: -- Creating OrgContact Role(in as_imp_cnt_rol_interface)
2193: IF (pI.customer_rank is not NULL AND
2194: pI.customer_rank <> FND_API.G_MISS_CHAR) THEN
2195: l_role_rec.role_type := pI.customer_rank;
2196: l_role_rec.primary_flag := 'N'; --'Y';
2197: l_role_rec.org_contact_id := G_LOCAL_ORG_CONTACT_ID;
2198: l_role_rec.orig_system_reference :=
2205: l_role_rec.created_by_module := 'AML_LEAD_IMPORT';
2206: l_role_rec.application_id := 530;
2207:
2208: If (( l_role_rec.role_type is not null) OR
2209: (l_role_rec.role_type <> FND_API.G_MISS_CHAR))
2210: Then
2211: If G_return_status = FND_API.G_RET_STS_SUCCESS
2212: Then
2213: write_log(3, 'Creating OrgContactRole(1)');
2207:
2208: If (( l_role_rec.role_type is not null) OR
2209: (l_role_rec.role_type <> FND_API.G_MISS_CHAR))
2210: Then
2211: If G_return_status = FND_API.G_RET_STS_SUCCESS
2212: Then
2213: write_log(3, 'Creating OrgContactRole(1)');
2214: HZ_PARTY_CONTACT_V2PUB.create_org_contact_role (
2215: p_init_msg_list => FND_API.G_FALSE,
2211: If G_return_status = FND_API.G_RET_STS_SUCCESS
2212: Then
2213: write_log(3, 'Creating OrgContactRole(1)');
2214: HZ_PARTY_CONTACT_V2PUB.create_org_contact_role (
2215: p_init_msg_list => FND_API.G_FALSE,
2216: p_org_contact_role_rec => l_role_rec,
2217: x_return_status => G_return_status,
2218: x_msg_count => G_MESG_COUNT,
2219: x_msg_data => l_msg_data,
2219: x_msg_data => l_msg_data,
2220: x_org_contact_role_id => l_role_id
2221: );
2222: If G_return_status <>
2223: FND_API.G_RET_STS_SUCCESS
2224: Then
2225: write_log(3,
2226: 'Creating OrgCntRole failed');
2227: ELSE
2236: FOR OCR IN c_cnt_role(pI.import_interface_id) LOOP
2237: l_role_rec.role_type := OCR.role_type;
2238: -- pI.customer_rank;
2239: IF (OCR.primary_flag is not NULL AND
2240: OCR.primary_flag <> FND_API.G_MISS_CHAR) THEN
2241: l_role_rec.primary_flag := OCR.primary_flag;
2242: ELSE
2243: l_role_rec.primary_flag := 'N';
2244: END IF;
2243: l_role_rec.primary_flag := 'N';
2244: END IF;
2245: l_role_rec.org_contact_id := G_LOCAL_ORG_CONTACT_ID;
2246: IF (OCR.orig_system_reference is not NULL AND
2247: OCR.orig_system_reference<>FND_API.G_MISS_CHAR)
2248: THEN
2249: l_role_rec.orig_system_reference :=
2250: OCR.orig_system_reference;
2251: ELSE
2260: l_role_rec.created_by_module := 'AML_LEAD_IMPORT';
2261: l_role_rec.application_id := 530;
2262:
2263: If (( l_role_rec.role_type is not null) OR
2264: (l_role_rec.role_type <> FND_API.G_MISS_CHAR))
2265: Then
2266: -- ffang 082001, hz_org_contacts_roles'
2267: -- flexfields are going to be obsolete.
2268: -- No need to populate.
2281: pI.import_interface_id,
2282: G_return_status
2283: );
2284: *** */
2285: If G_return_status = FND_API.G_RET_STS_SUCCESS
2286: Then
2287: write_log(3, 'Creating OrgContactRole(2)');
2288: HZ_PARTY_CONTACT_V2PUB.create_org_contact_role (
2289: p_init_msg_list => FND_API.G_FALSE,
2285: If G_return_status = FND_API.G_RET_STS_SUCCESS
2286: Then
2287: write_log(3, 'Creating OrgContactRole(2)');
2288: HZ_PARTY_CONTACT_V2PUB.create_org_contact_role (
2289: p_init_msg_list => FND_API.G_FALSE,
2290: p_org_contact_role_rec => l_role_rec,
2291: x_return_status => G_return_status,
2292: x_msg_count => G_MESG_COUNT,
2293: x_msg_data => l_msg_data,
2293: x_msg_data => l_msg_data,
2294: x_org_contact_role_id => l_role_id
2295: );
2296: If G_return_status <>
2297: FND_API.G_RET_STS_SUCCESS
2298: Then
2299: write_log(3,
2300: 'Creating OrgContRole failed');
2301: ELSE
2318: write_log(3, 'Creating OrgContact failed');
2319: End if;
2320: End if;
2321: When Others Then
2322: RAISE FND_API.G_EXC_ERROR;
2323: End;
2324: END do_create_relationship;
2325:
2326: ----------------------------------------------------------
2409:
2410: write_log(3, 'do_create_saleslead:Start');
2411:
2412: -- PROMOTION_ID/PROMOTION_CODE
2413: IF (pI.promotion_id is not null AND pI.promotion_id <> FND_API.G_MISS_NUM)
2414: THEN
2415: l_temp_promotion_id := NULL;
2416: l_temp_promotion_code := NULL;
2417:
2430: p_token1_value => 'PROMOTION ID',
2431: p_token2 => 'VALUE',
2432: p_token2_value => pI.PROMOTION_ID );
2433: -- RAISE NO_DATA_FOUND;
2434: RAISE FND_API.G_EXC_ERROR;
2435: ELSE
2436: -- l_sales_lead_rec.SOURCE_PROMOTION_ID := l_temp_promotion_id;
2437: pI.promotion_id := l_temp_promotion_id;
2438: END IF;
2439: CLOSE c_get_source_code;
2440:
2441: -- ffang 101601, bug 2053591, if promotion_code is not null, match them
2442: IF (pI.promotion_code is not null
2443: AND pI.promotion_code <> FND_API.G_MISS_CHAR)
2444: THEN
2445: IF UPPER(pI.promotion_code) <> UPPER(l_temp_promotion_code) THEN
2446: write_log(3,'promotion_id and promotion_code not match:');
2447: write_log(3,'promotion_id: '||pI.promotion_id);
2453: p_token1 => 'VALUE1',
2454: p_token1_value => pI.promotion_id,
2455: p_token2 => 'VALUE2',
2456: p_token2_value => pI.promotion_code );
2457: RAISE FND_API.G_EXC_ERROR;
2458: END IF;
2459: ELSE
2460: -- promotion_code is not given, populate it in as_import_interface
2461: -- swkhanna 05/28/02
2464:
2465: ELSE -- promotion_id is not given
2466:
2467: IF (pI.promotion_code is not null AND
2468: pI.promotion_code <> FND_API.G_MISS_CHAR)
2469: THEN
2470: l_temp_promotion_id := NULL;
2471:
2472: -- Validate promotion_code and get promotion_id
2484: p_token1_value => 'PROMOTION CODE',
2485: p_token2 => 'VALUE',
2486: p_token2_value => pI.PROMOTION_CODE );
2487: -- RAISE NO_DATA_FOUND;
2488: RAISE FND_API.G_EXC_ERROR;
2489: ELSE
2490: -- l_sales_lead_rec.SOURCE_PROMOTION_ID := l_temp_promotion_id;
2491: pI.promotion_id := l_temp_promotion_id;
2492: END IF;
2512: l_sales_lead_rec.PARENT_PROJECT := pI.PARENT_PROJECT;
2513: l_sales_lead_rec.DESCRIPTION := pI.DESCRIPTION;
2514:
2515: /* -- Removed logic for lead_name
2516: IF (pI.DESCRIPTION is not NULL AND pI.DESCRIPTION <> FND_API.G_MISS_CHAR)
2517: THEN
2518: l_sales_lead_rec.DESCRIPTION := pI.DESCRIPTION;
2519: ELSE
2520: IF (pI.last_name is not NULL AND pI.last_name <> FND_API.G_MISS_CHAR)
2516: IF (pI.DESCRIPTION is not NULL AND pI.DESCRIPTION <> FND_API.G_MISS_CHAR)
2517: THEN
2518: l_sales_lead_rec.DESCRIPTION := pI.DESCRIPTION;
2519: ELSE
2520: IF (pI.last_name is not NULL AND pI.last_name <> FND_API.G_MISS_CHAR)
2521: THEN
2522: IF(pI.first_name is not NULL AND pI.first_name<>FND_API.G_MISS_CHAR)
2523: THEN
2524: l_sales_lead_rec.DESCRIPTION:=pI.last_name||', '||pI.first_name;
2518: l_sales_lead_rec.DESCRIPTION := pI.DESCRIPTION;
2519: ELSE
2520: IF (pI.last_name is not NULL AND pI.last_name <> FND_API.G_MISS_CHAR)
2521: THEN
2522: IF(pI.first_name is not NULL AND pI.first_name<>FND_API.G_MISS_CHAR)
2523: THEN
2524: l_sales_lead_rec.DESCRIPTION:=pI.last_name||', '||pI.first_name;
2525: ELSE
2526: l_sales_lead_rec.DESCRIPTION := pI.last_name;
2525: ELSE
2526: l_sales_lead_rec.DESCRIPTION := pI.last_name;
2527: END IF;
2528: ELSE
2529: IF(pI.first_name is not NULL AND pI.first_name<>FND_API.G_MISS_CHAR)
2530: THEN
2531: l_sales_lead_rec.DESCRIPTION := pI.first_name;
2532: END IF;
2533: END IF;
2737: -- bugfix 2098158.
2738: /*
2739: l_sales_lead_contact_tbl(1).phone_id := pI.phone_id;
2740:
2741: IF (pI.primary_contact_flag is not null and pI.primary_contact_flag <> FND_API.G_MISS_CHAR) THEN
2742: l_sales_lead_contact_tbl(1).primary_contact_flag := pI.primary_contact_flag;
2743: ELSE
2744: l_sales_lead_contact_tbl(1).primary_contact_flag := 'N';
2745: END IF;
2829: pI.import_interface_id,
2830: G_return_status
2831: );
2832:
2833: If G_return_status = FND_API.G_RET_STS_SUCCESS Then
2834: write_log(3, 'create_sales_lead:Start');
2835:
2836: --Bug 3680824: non resource user can import the lead for sales campaign
2837: -- in which case, user validation needs to be bypassed
2837: -- in which case, user validation needs to be bypassed
2838: IF pI.source_system = 'SALES_CAMPAIGN' THEN
2839: l_validation_level := AS_UTILITY_PUB.G_VALID_LEVEL_ITEM;
2840: ELSE
2841: l_validation_level := FND_API.G_VALID_LEVEL_FULL;
2842: END IF;
2843:
2844: as_sales_leads_pvt.create_sales_lead(
2845: p_api_version_number => 2.0,
2842: END IF;
2843:
2844: as_sales_leads_pvt.create_sales_lead(
2845: p_api_version_number => 2.0,
2846: p_init_msg_list => FND_API.G_FALSE,
2847: p_commit => FND_API.G_FALSE,
2848: p_validation_level => l_validation_level,
2849: p_check_access_flag => 'N',
2850: p_admin_flag => 'N',
2843:
2844: as_sales_leads_pvt.create_sales_lead(
2845: p_api_version_number => 2.0,
2846: p_init_msg_list => FND_API.G_FALSE,
2847: p_commit => FND_API.G_FALSE,
2848: p_validation_level => l_validation_level,
2849: p_check_access_flag => 'N',
2850: p_admin_flag => 'N',
2851: p_admin_group_id => NULL,
2861: x_sales_lead_line_out_tbl => l_sales_lead_line_out_tbl,
2862: x_sales_lead_cnt_out_tbl => l_sales_lead_cnt_out_tbl);
2863: End if;
2864:
2865: If G_return_status = FND_API.G_RET_STS_SUCCESS Then
2866: write_log(3, 'Sales lead created: ' || pI.sales_lead_id);
2867:
2868: select last_update_date into l_sales_lead_rec.last_update_date
2869: from as_sales_leads where sales_lead_id=pI.sales_lead_id;
2952: end if;
2953:
2954: AS_INTEREST_PUB.Create_Interest(
2955: p_api_version_number => 2.0 ,
2956: p_init_msg_list => FND_API.G_FALSE,
2957: p_Commit => FND_API.G_FALSE,
2958: p_interest_rec => l_classification_tbl(i),
2959: p_customer_id => pI.party_id,
2960: p_address_id => pI.party_site_id,
2953:
2954: AS_INTEREST_PUB.Create_Interest(
2955: p_api_version_number => 2.0 ,
2956: p_init_msg_list => FND_API.G_FALSE,
2957: p_Commit => FND_API.G_FALSE,
2958: p_interest_rec => l_classification_tbl(i),
2959: p_customer_id => pI.party_id,
2960: p_address_id => pI.party_site_id,
2961: p_contact_id => G_local_org_contact_id,
2994: end if;
2995:
2996: AS_INTEREST_PUB.Create_Interest(
2997: p_api_version_number => 2.0 ,
2998: p_init_msg_list => FND_API.G_FALSE,
2999: p_Commit => FND_API.G_FALSE,
3000: p_interest_rec => l_classification_tbl(l_ll_index),
3001: p_customer_id => pI.party_id,
3002: p_address_id => pI.party_site_id,
2995:
2996: AS_INTEREST_PUB.Create_Interest(
2997: p_api_version_number => 2.0 ,
2998: p_init_msg_list => FND_API.G_FALSE,
2999: p_Commit => FND_API.G_FALSE,
3000: p_interest_rec => l_classification_tbl(l_ll_index),
3001: p_customer_id => pI.party_id,
3002: p_address_id => pI.party_site_id,
3003: p_contact_id => G_local_org_contact_id,
3132: -- l_org_rec.party_rec.party_id := pI.hz_partyId;
3133: -- l_per_rec.party_rec.party_id := pI.hz_partyId;
3134:
3135: IF (pI.orig_system_reference is not null) or
3136: (pI.orig_system_reference <> FND_API.G_MISS_CHAR)
3137: THEN
3138: -- l_org_rec.party_rec.orig_system_reference:= pI.orig_system_reference;
3139: -- l_per_rec.party_rec.orig_system_reference:= pI.orig_system_reference;
3140: l_osysref := pI.orig_system_reference;
3156: /* ***
3157: If (pI.party_type = 'ORGANIZATION') then
3158: hz_party_pub.update_organization (
3159: p_api_version => G_api_version,
3160: p_init_msg_list => FND_API.G_FALSE,
3161: p_commit => FND_API.G_FALSE,
3162: p_organization_rec => l_org_rec,
3163: p_party_last_update_date => pI.last_update_date,
3164: x_return_status => G_return_status,
3157: If (pI.party_type = 'ORGANIZATION') then
3158: hz_party_pub.update_organization (
3159: p_api_version => G_api_version,
3160: p_init_msg_list => FND_API.G_FALSE,
3161: p_commit => FND_API.G_FALSE,
3162: p_organization_rec => l_org_rec,
3163: p_party_last_update_date => pI.last_update_date,
3164: x_return_status => G_return_status,
3165: x_msg_count => G_MESG_COUNT,
3164: x_return_status => G_return_status,
3165: x_msg_count => G_MESG_COUNT,
3166: x_msg_data => l_msg_data,
3167: x_profile_id => l_hz_profile,
3168: p_validation_level => FND_API.G_VALID_LEVEL_FULL
3169: );
3170: elsif (pI.party_type ='PERSON') then
3171: hz_party_pub.update_person (
3172: p_api_version => G_api_version,
3169: );
3170: elsif (pI.party_type ='PERSON') then
3171: hz_party_pub.update_person (
3172: p_api_version => G_api_version,
3173: p_init_msg_list => FND_API.G_FALSE,
3174: p_commit => FND_API.G_FALSE,
3175: p_person_rec => l_per_rec,
3176: p_party_last_update_date => pI.last_update_date,
3177: x_profile_id => l_hz_profile,
3170: elsif (pI.party_type ='PERSON') then
3171: hz_party_pub.update_person (
3172: p_api_version => G_api_version,
3173: p_init_msg_list => FND_API.G_FALSE,
3174: p_commit => FND_API.G_FALSE,
3175: p_person_rec => l_per_rec,
3176: p_party_last_update_date => pI.last_update_date,
3177: x_profile_id => l_hz_profile,
3178: x_return_status => G_return_status,
3177: x_profile_id => l_hz_profile,
3178: x_return_status => G_return_status,
3179: x_msg_count => G_MESG_COUNT,
3180: x_msg_data => l_msg_data,
3181: p_validation_level => FND_API.G_VALID_LEVEL_FULL
3182: );
3183: else
3184: null;
3185: end if;
3310: THEN
3311: write_log(3, 'Call user_hook is true');
3312: AS_IMPORT_SL_CUHK.Is_Duplicate_Lead_Pre(
3313: p_api_version_number => 2.0,
3314: p_init_msg_list => FND_API.G_FALSE,
3315: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
3316: p_commit => FND_API.G_FALSE,
3317: p_import_interface_id => pI.import_interface_id,
3318: x_duplicate_flag => l_duplicate_flag,
3311: write_log(3, 'Call user_hook is true');
3312: AS_IMPORT_SL_CUHK.Is_Duplicate_Lead_Pre(
3313: p_api_version_number => 2.0,
3314: p_init_msg_list => FND_API.G_FALSE,
3315: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
3316: p_commit => FND_API.G_FALSE,
3317: p_import_interface_id => pI.import_interface_id,
3318: x_duplicate_flag => l_duplicate_flag,
3319: x_return_status => l_return_status,
3312: AS_IMPORT_SL_CUHK.Is_Duplicate_Lead_Pre(
3313: p_api_version_number => 2.0,
3314: p_init_msg_list => FND_API.G_FALSE,
3315: p_validation_level => FND_API.G_VALID_LEVEL_FULL,
3316: p_commit => FND_API.G_FALSE,
3317: p_import_interface_id => pI.import_interface_id,
3318: x_duplicate_flag => l_duplicate_flag,
3319: x_return_status => l_return_status,
3320: x_msg_count => l_msg_count,
3320: x_msg_count => l_msg_count,
3321: x_msg_data => l_msg_data);
3322:
3323: write_log(3, 'x_duplicate_flag=' || l_duplicate_flag);
3324: IF l_return_status <> FND_API.G_RET_STS_SUCCESS THEN
3325: RAISE FND_API.G_EXC_ERROR;
3326: END IF;
3327:
3328: IF l_duplicate_flag = 'Y' THEN
3321: x_msg_data => l_msg_data);
3322:
3323: write_log(3, 'x_duplicate_flag=' || l_duplicate_flag);
3324: IF l_return_status <> FND_API.G_RET_STS_SUCCESS THEN
3325: RAISE FND_API.G_EXC_ERROR;
3326: END IF;
3327:
3328: IF l_duplicate_flag = 'Y' THEN
3329: RETURN TRUE;
3685: p_msg_name => 'AS_INVALID_PARTY_TYPE',
3686: p_token1 => 'VALUE',
3687: p_token1_value => I.party_type);
3688: write_log (3, 'Party_type is invalid');
3689: RAISE FND_API.G_EXC_ERROR;
3690: END IF;
3691:
3692: write_log(3,'#1 :: Calling FIND_PARTIES with OSR found = '||l_orig_sys_party_found);
3693: write_log(3,'rule_id '||to_char(l_rule_id));
3712: 'N',l_search_context_id, l_num_matches, l_return_status, l_msg_count, l_msg_data);
3713: END IF;
3714: END IF;
3715:
3716: IF l_return_status <> FND_API.g_ret_sts_success THEN
3717: RAISE FND_API.g_exc_error;
3718: END IF;
3719:
3720: write_log(3,'After find_parties matches '||to_char(l_num_matches));
3713: END IF;
3714: END IF;
3715:
3716: IF l_return_status <> FND_API.g_ret_sts_success THEN
3717: RAISE FND_API.g_exc_error;
3718: END IF;
3719:
3720: write_log(3,'After find_parties matches '||to_char(l_num_matches));
3721:
3743: THEN
3744: l_organization_rec.party_rec.party_id := l_party_id;
3745: l_organization_rec.party_rec.status := 'A';
3746: HZ_PARTY_V2PUB.update_organization(
3747: p_init_msg_list => FND_API.G_FALSE,
3748: p_organization_rec => l_organization_rec,
3749: p_party_object_version_number => l_object_version_number,
3750: x_profile_id => l_profile_id,
3751: x_return_status => l_return_status,
3756: THEN
3757: l_person_rec.party_rec.party_id := l_party_id;
3758: l_person_rec.party_rec.status := 'A';
3759: HZ_PARTY_V2PUB.update_person(
3760: p_init_msg_list => FND_API.G_FALSE,
3761: p_person_rec => l_person_rec,
3762: p_party_object_version_number => l_object_version_number,
3763: x_profile_id => l_profile_id,
3764: x_return_status => l_return_status,
3809: l_rule_id := to_number(FND_PROFILE.value('AS_USE_DQM_RULE_CODE_PARTY_SITE'));
3810: HZ_PARTY_SEARCH.get_matching_party_sites ('T',l_rule_id, I.party_id, party_site_cond,
3811: contact_point_cond, l_search_context_id, l_return_status, l_msg_count, l_msg_data);
3812:
3813: IF l_return_status <> FND_API.g_ret_sts_success THEN
3814: RAISE FND_API.g_exc_error;
3815: END IF;
3816:
3817: OPEN C_matched_party_sites;
3810: HZ_PARTY_SEARCH.get_matching_party_sites ('T',l_rule_id, I.party_id, party_site_cond,
3811: contact_point_cond, l_search_context_id, l_return_status, l_msg_count, l_msg_data);
3812:
3813: IF l_return_status <> FND_API.g_ret_sts_success THEN
3814: RAISE FND_API.g_exc_error;
3815: END IF;
3816:
3817: OPEN C_matched_party_sites;
3818: FETCH C_matched_party_sites INTO l_party_id, l_party_site_id, l_score, l_creation_date;
3859: l_rule_id := to_number(FND_PROFILE.value('AS_USE_DQM_RULE_CODE_CONTACT'));
3860: HZ_PARTY_SEARCH.get_matching_contacts('T',l_rule_id, I.party_id, contact_cond, contact_point_cond,
3861: l_search_context_id, l_return_status, l_msg_count, l_msg_data);
3862:
3863: IF l_return_status <> FND_API.g_ret_sts_success THEN
3864: RAISE FND_API.g_exc_error;
3865: END IF;
3866:
3867: OPEN C_matched_contacts;
3860: HZ_PARTY_SEARCH.get_matching_contacts('T',l_rule_id, I.party_id, contact_cond, contact_point_cond,
3861: l_search_context_id, l_return_status, l_msg_count, l_msg_data);
3862:
3863: IF l_return_status <> FND_API.g_ret_sts_success THEN
3864: RAISE FND_API.g_exc_error;
3865: END IF;
3866:
3867: OPEN C_matched_contacts;
3868: FETCH C_matched_contacts INTO l_party_id, l_org_contact_id, l_score, l_creation_date;
3941: write_log(3,'#4 :: Calling GET_MATCHING_CONTACT_POINTS with party_id: '||to_char(I.party_id));
3942: l_rule_id := to_number(FND_PROFILE.value('AS_USE_DQM_RULE_CODE_CONTACT'));
3943: HZ_PARTY_SEARCH.get_matching_contact_points('T',l_rule_id, I.party_id, contact_point_cond, l_search_context_id, l_return_status, l_msg_count, l_msg_data);
3944:
3945: IF l_return_status <> FND_API.g_ret_sts_success THEN
3946: RAISE FND_API.g_exc_error;
3947: END IF;
3948:
3949: -- Check EMAIL
3942: l_rule_id := to_number(FND_PROFILE.value('AS_USE_DQM_RULE_CODE_CONTACT'));
3943: HZ_PARTY_SEARCH.get_matching_contact_points('T',l_rule_id, I.party_id, contact_point_cond, l_search_context_id, l_return_status, l_msg_count, l_msg_data);
3944:
3945: IF l_return_status <> FND_API.g_ret_sts_success THEN
3946: RAISE FND_API.g_exc_error;
3947: END IF;
3948:
3949: -- Check EMAIL
3950: IF I.email_address IS NOT NULL THEN
4219: p_token1 => 'COLUMN',
4220: p_token1_value => 'SOURCE_SYSTEM',
4221: p_token2 => 'VALUE',
4222: p_token2_value => I.SOURCE_SYSTEM );
4223: RAISE FND_API.G_EXC_ERROR;
4224: END IF;
4225:
4226: -- Begin enh: Support for Currency : aanjaria 100402
4227: IF I.currency_code IS NULL AND I.budget_amount IS NOT NULL THEN
4234: p_token1_value => 'CURRENCY_CODE',
4235: p_token2 => 'VALUE',
4236: p_token2_value => 'NULL' );
4237: write_log(3, 'Please enter currency_code when your budget_amount is entered.');
4238: raise FND_API.G_EXC_ERROR;
4239:
4240: -- Get the currency of the customer country
4241: --OPEN C_currency_code(I.country);
4242: --FETCH C_currency_code INTO l_currency_code;
4258: aml_find_party_match_pvt.main(I, --IN OUT param
4259: x_return_status --OUT param
4260: );
4261:
4262: IF x_return_status <> FND_API.G_RET_STS_SUCCESS then
4263: write_log(3, 'aml_find_party_match failed');
4264: raise FND_API.G_EXC_ERROR;
4265: END IF;
4266:
4260: );
4261:
4262: IF x_return_status <> FND_API.G_RET_STS_SUCCESS then
4263: write_log(3, 'aml_find_party_match failed');
4264: raise FND_API.G_EXC_ERROR;
4265: END IF;
4266:
4267: write_log(3, 'Returned from custom hook with party_id: '||to_char(I.party_id));
4268:
4294: write_log(3, 'Duplicate lead');
4295: I.load_status := 'DUPLICATE';
4296: writeBak(I, G_return_status);
4297: commit;
4298: IF ((G_return_status <> FND_API.G_RET_STS_SUCCESS) AND (G_return_status <> 'W')) THEN
4299: write_log(3, 'writeBak failed');
4300: RAISE FND_API.G_EXC_ERROR;
4301: END IF;
4302: END IF;
4296: writeBak(I, G_return_status);
4297: commit;
4298: IF ((G_return_status <> FND_API.G_RET_STS_SUCCESS) AND (G_return_status <> 'W')) THEN
4299: write_log(3, 'writeBak failed');
4300: RAISE FND_API.G_EXC_ERROR;
4301: END IF;
4302: END IF;
4303:
4304: IF l_duplicate_lead = 'U' THEN
4308: IF Is_duplicate_lead(I) THEN
4309: write_log(3, 'Duplicate lead');
4310: I.load_status := 'DUPLICATE';
4311: writeBak(I, G_return_status);
4312: IF ((G_return_status <> FND_API.G_RET_STS_SUCCESS) AND
4313: (G_return_status <> 'W'))
4314: THEN
4315: write_log(3, 'writeBak failed');
4316: RAISE FND_API.G_EXC_ERROR;
4312: IF ((G_return_status <> FND_API.G_RET_STS_SUCCESS) AND
4313: (G_return_status <> 'W'))
4314: THEN
4315: write_log(3, 'writeBak failed');
4316: RAISE FND_API.G_EXC_ERROR;
4317: END IF;
4318:
4319: ELSE
4320: -- Create TCA entities
4326: IF (I.address1 IS NOT NULL AND I.country IS NOT NULL) THEN
4327: write_log(3, 'Creating location');
4328: do_create_location(I, G_return_status);
4329: -- If error raise exception
4330: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4331: write_log(3, 'Creating location failed');
4332: RAISE FND_API.G_EXC_ERROR;
4333: END IF;
4334: I.new_loc_flag := 1; -- new location flag set
4328: do_create_location(I, G_return_status);
4329: -- If error raise exception
4330: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4331: write_log(3, 'Creating location failed');
4332: RAISE FND_API.G_EXC_ERROR;
4333: END IF;
4334: I.new_loc_flag := 1; -- new location flag set
4335: ELSE
4336: write_log (3, 'No add1/country-skip creating location');
4343: IF l_create_party = 'Y' or I.party_id IS NULL THEN
4344: IF I.party_type = 'ORGANIZATION' THEN
4345: do_create_organization(I, G_return_status);
4346: -- If error raise exception
4347: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4348: write_log(3, 'Creating Organization failed');
4349: RAISE FND_API.G_EXC_ERROR;
4350: END IF;
4351: I.new_party_flag := 1; --new party flag set
4345: do_create_organization(I, G_return_status);
4346: -- If error raise exception
4347: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4348: write_log(3, 'Creating Organization failed');
4349: RAISE FND_API.G_EXC_ERROR;
4350: END IF;
4351: I.new_party_flag := 1; --new party flag set
4352: ELSIF I.party_type ='PERSON' THEN
4353: do_create_person(I, I.party_type, G_return_status);
4351: I.new_party_flag := 1; --new party flag set
4352: ELSIF I.party_type ='PERSON' THEN
4353: do_create_person(I, I.party_type, G_return_status);
4354: -- If error raise exception
4355: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4356: write_log(3, 'do_create_Person failed');
4357: RAISE FND_API.G_EXC_ERROR;
4358: END IF;
4359: I.new_party_flag := 1; --new party flag set
4353: do_create_person(I, I.party_type, G_return_status);
4354: -- If error raise exception
4355: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4356: write_log(3, 'do_create_Person failed');
4357: RAISE FND_API.G_EXC_ERROR;
4358: END IF;
4359: I.new_party_flag := 1; --new party flag set
4360: ELSE
4361: -- ffang 101201, bug2050535, push error message
4365: p_token1 => 'VALUE',
4366: p_token1_value => I.party_type);
4367: write_log (3, 'Party_type is invalid');
4368: -- end ffang 101201
4369: RAISE FND_API.G_EXC_ERROR;
4370: END IF; -- party_type condition end
4371: --2851215: orig_system_reference should not be updated
4372: /*
4373: ELSIF l_create_party = 'N' and I.party_id IS NOT NULL THEN
4374: IF I.party_type IS NOT NULL THEN
4375: write_log (3, 'dup party:' || I.party_id || '-' || I.party_type);
4376: do_update_party(I, G_return_status);
4377: -- If error raise exception
4378: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4379: write_log(3, 'do_update_party failed');
4380: RAISE FND_API.G_EXC_ERROR;
4381: END IF;
4382: END IF;
4376: do_update_party(I, G_return_status);
4377: -- If error raise exception
4378: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4379: write_log(3, 'do_update_party failed');
4380: RAISE FND_API.G_EXC_ERROR;
4381: END IF;
4382: END IF;
4383: */
4384: END IF; -- l_party_found condition end
4393: -- swkhanna 6/12/02 Bug 2404796
4394: -- do_create_ps_psu(I, I.party_id, 'ORG', G_return_status);
4395: do_create_ps_psu(I, I.party_id, I.party_type, G_return_status);
4396: -- If error raise exception
4397: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4398: write_log(3, 'Creating Party Site / Use failed');
4399: RAISE FND_API.G_EXC_ERROR;
4400: END IF;
4401: I.new_ps_flag := 1; --new party flag set
4395: do_create_ps_psu(I, I.party_id, I.party_type, G_return_status);
4396: -- If error raise exception
4397: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4398: write_log(3, 'Creating Party Site / Use failed');
4399: RAISE FND_API.G_EXC_ERROR;
4400: END IF;
4401: I.new_ps_flag := 1; --new party flag set
4402: ELSE
4403: write_log(3,'no location created-skip create PS');
4407: -- Create contact points for 'PERSON'
4408: FOR cpp in c_cnt_pnt('PERSON', I.import_interface_id) LOOP
4409: write_log(3, 'Creating contact points for PERSON');
4410: do_create_contact_points(I, cpp, 'PERSON', G_return_status);
4411: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4412: write_log(3, 'createContactPoints for person failed');
4413: RAISE FND_API.G_EXC_ERROR;
4414: END IF;
4415: END LOOP;
4409: write_log(3, 'Creating contact points for PERSON');
4410: do_create_contact_points(I, cpp, 'PERSON', G_return_status);
4411: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4412: write_log(3, 'createContactPoints for person failed');
4413: RAISE FND_API.G_EXC_ERROR;
4414: END IF;
4415: END LOOP;
4416:
4417: -- Create contacts
4422: IF (I.first_name IS NOT NULL and I.last_name IS NOT NULL) THEN
4423: write_log(3, 'Creating the Contact');
4424: do_create_person(I, 'CONTACT', G_return_status);
4425: -- If error raise exception
4426: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4427: write_log(3, 'do_create_Person-contact failed');
4428: RAISE FND_API.G_EXC_ERROR;
4429: END IF;
4430: I.new_con_flag := 1; -- new contact flag set
4424: do_create_person(I, 'CONTACT', G_return_status);
4425: -- If error raise exception
4426: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4427: write_log(3, 'do_create_Person-contact failed');
4428: RAISE FND_API.G_EXC_ERROR;
4429: END IF;
4430: I.new_con_flag := 1; -- new contact flag set
4431: ELSE
4432: write_log(3, 'no first/last name-skip create cnt');
4439: -- ffang 100901, for bug 2042181, if contact is not created,
4440: -- then don't create relationship
4441: IF (I.rel_party_id is NULL and I.contact_party_id is not NULL) THEN
4442: do_create_relationship(I, G_return_status);
4443: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4444: write_log(3, 'createRelationship failed');
4445: RAISE FND_API.G_EXC_ERROR;
4446: END IF;
4447: I.new_rel_flag := 1; -- new relationship flag set
4441: IF (I.rel_party_id is NULL and I.contact_party_id is not NULL) THEN
4442: do_create_relationship(I, G_return_status);
4443: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4444: write_log(3, 'createRelationship failed');
4445: RAISE FND_API.G_EXC_ERROR;
4446: END IF;
4447: I.new_rel_flag := 1; -- new relationship flag set
4448: END IF;
4449: END IF; --if party_type = 'ORGANIZATION'
4453: (I.party_type <> 'ORGANIZATION' and I.party_id is not null) THEN
4454: write_log (3, 'Creating contact point (1)');
4455:
4456: do_create_contact_points_old (I, p_dup_phone, p_dup_fax, p_dup_email, p_dup_url, G_return_status);
4457: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4458: write_log(3, 'createContactPoints for contact (1) failed');
4459: RAISE FND_API.G_EXC_ERROR;
4460: END IF;
4461:
4455:
4456: do_create_contact_points_old (I, p_dup_phone, p_dup_fax, p_dup_email, p_dup_url, G_return_status);
4457: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4458: write_log(3, 'createContactPoints for contact (1) failed');
4459: RAISE FND_API.G_EXC_ERROR;
4460: END IF;
4461:
4462: -- SOLIN, bug 4637420
4463: -- create_contact_preferences should be called after
4462: -- SOLIN, bug 4637420
4463: -- create_contact_preferences should be called after
4464: -- contact point is created.
4465: do_contact_preference(I, G_return_status);
4466: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4467: write_log(3, 'createContactPreference failed');
4468: RAISE FND_API.G_EXC_ERROR;
4469: END IF;
4470: -- SOLIN, end bug 4637420
4464: -- contact point is created.
4465: do_contact_preference(I, G_return_status);
4466: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4467: write_log(3, 'createContactPreference failed');
4468: RAISE FND_API.G_EXC_ERROR;
4469: END IF;
4470: -- SOLIN, end bug 4637420
4471: ELSE
4472: write_log (3, ' Contact Point Not Created ');
4475: -- create contact points (in as_imp_cnt_pnt_interface) for 'CONTACT'
4476: FOR cpc in c_cnt_pnt('CONTACT', I.import_interface_id) LOOP
4477: write_log (3, 'Creating contact point (2)');
4478: do_create_contact_points(I, cpc, 'CONTACT',G_return_status);
4479: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4480: write_log(3, 'createContactPoints for contact failed');
4481: RAISE FND_API.G_EXC_ERROR;
4482: END IF;
4483: END LOOP;
4477: write_log (3, 'Creating contact point (2)');
4478: do_create_contact_points(I, cpc, 'CONTACT',G_return_status);
4479: IF G_return_status <> FND_API.G_RET_STS_SUCCESS THEN
4480: write_log(3, 'createContactPoints for contact failed');
4481: RAISE FND_API.G_EXC_ERROR;
4482: END IF;
4483: END LOOP;
4484:
4485: SELECT to_char(sysdate,'yyyymmddhhmiss')
4515:
4516:
4517: do_create_saleslead(I, G_return_status);
4518:
4519: If G_return_status <> FND_API.G_RET_STS_SUCCESS Then
4520: write_log(3, 'do_create_saleslead failed');
4521: RAISE FND_API.G_EXC_ERROR;
4522: End If;
4523:
4517: do_create_saleslead(I, G_return_status);
4518:
4519: If G_return_status <> FND_API.G_RET_STS_SUCCESS Then
4520: write_log(3, 'do_create_saleslead failed');
4521: RAISE FND_API.G_EXC_ERROR;
4522: End If;
4523:
4524: -- Added by Ajoy, 08/21, bugfix# 2521850
4525: -- If the lead creation is successful, update the import record with sales_lead_id
4523:
4524: -- Added by Ajoy, 08/21, bugfix# 2521850
4525: -- If the lead creation is successful, update the import record with sales_lead_id
4526: -- so that the marketing_score (lead_score) attribute can be used in rule engine
4527: If G_return_status = FND_API.G_RET_STS_SUCCESS Then
4528: /* --redundent update..after purge project this update is not needed
4529: UPDATE as_import_interface
4530: SET sales_lead_id = I.sales_lead_id
4531: WHERE import_interface_id = I.import_interface_id;
4538: -- End If;
4539:
4540: -- createInterest
4541: --do_create_Interest(I, G_return_status);
4542: If G_return_status <> FND_API.G_RET_STS_SUCCESS Then
4543: write_log(3, 'do_create_interest failed');
4544: RAISE FND_API.G_EXC_ERROR;
4545: End If;
4546:
4540: -- createInterest
4541: --do_create_Interest(I, G_return_status);
4542: If G_return_status <> FND_API.G_RET_STS_SUCCESS Then
4543: write_log(3, 'do_create_interest failed');
4544: RAISE FND_API.G_EXC_ERROR;
4545: End If;
4546:
4547: -- do_create_LeadNoteAndContext
4548: If ((I.sales_lead_id is not null) AND (I.party_id is not null)
4546:
4547: -- do_create_LeadNoteAndContext
4548: If ((I.sales_lead_id is not null) AND (I.party_id is not null)
4549: AND ((I.lead_note is not null) OR
4550: (I.lead_note <> FND_API.G_MISS_CHAR)))
4551: then
4552: do_create_LeadNoteAndContext(I, G_return_status);
4553: If G_return_status <> FND_API.G_RET_STS_SUCCESS Then
4554: write_log(3, 'do_create_LeadNoteAndContext failed');
4549: AND ((I.lead_note is not null) OR
4550: (I.lead_note <> FND_API.G_MISS_CHAR)))
4551: then
4552: do_create_LeadNoteAndContext(I, G_return_status);
4553: If G_return_status <> FND_API.G_RET_STS_SUCCESS Then
4554: write_log(3, 'do_create_LeadNoteAndContext failed');
4555: RAISE FND_API.G_EXC_ERROR;
4556: End If;
4557: End if;
4551: then
4552: do_create_LeadNoteAndContext(I, G_return_status);
4553: If G_return_status <> FND_API.G_RET_STS_SUCCESS Then
4554: write_log(3, 'do_create_LeadNoteAndContext failed');
4555: RAISE FND_API.G_EXC_ERROR;
4556: End If;
4557: End if;
4558:
4559: G_LOCAL_ORG_CONTACT_ID := Null;
4563: -- in which case, user validation needs to be bypassed
4564: IF I.source_system = 'SALES_CAMPAIGN' THEN
4565: l_validation_level := AS_UTILITY_PUB.G_VALID_LEVEL_ITEM;
4566: ELSE
4567: l_validation_level := FND_API.G_VALID_LEVEL_FULL;
4568: END IF;
4569:
4570: AS_SALES_LEAD_ENGINE_PVT.Lead_Process_After_Create (
4571: P_Api_Version_Number => 2.0,
4568: END IF;
4569:
4570: AS_SALES_LEAD_ENGINE_PVT.Lead_Process_After_Create (
4571: P_Api_Version_Number => 2.0,
4572: P_Init_Msg_List => FND_API.G_FALSE,
4573: P_Commit => FND_API.G_FALSE,
4574: P_Validation_Level => l_validation_level,
4575: P_Check_Access_Flag => FND_API.G_MISS_CHAR,
4576: P_Admin_Flag => FND_API.G_MISS_CHAR,
4569:
4570: AS_SALES_LEAD_ENGINE_PVT.Lead_Process_After_Create (
4571: P_Api_Version_Number => 2.0,
4572: P_Init_Msg_List => FND_API.G_FALSE,
4573: P_Commit => FND_API.G_FALSE,
4574: P_Validation_Level => l_validation_level,
4575: P_Check_Access_Flag => FND_API.G_MISS_CHAR,
4576: P_Admin_Flag => FND_API.G_MISS_CHAR,
4577: P_Admin_Group_Id => FND_API.G_MISS_NUM,
4571: P_Api_Version_Number => 2.0,
4572: P_Init_Msg_List => FND_API.G_FALSE,
4573: P_Commit => FND_API.G_FALSE,
4574: P_Validation_Level => l_validation_level,
4575: P_Check_Access_Flag => FND_API.G_MISS_CHAR,
4576: P_Admin_Flag => FND_API.G_MISS_CHAR,
4577: P_Admin_Group_Id => FND_API.G_MISS_NUM,
4578: P_identity_salesforce_id => G_SL_SALESFORCE_ID,
4579: P_Salesgroup_id => l_group_id,
4572: P_Init_Msg_List => FND_API.G_FALSE,
4573: P_Commit => FND_API.G_FALSE,
4574: P_Validation_Level => l_validation_level,
4575: P_Check_Access_Flag => FND_API.G_MISS_CHAR,
4576: P_Admin_Flag => FND_API.G_MISS_CHAR,
4577: P_Admin_Group_Id => FND_API.G_MISS_NUM,
4578: P_identity_salesforce_id => G_SL_SALESFORCE_ID,
4579: P_Salesgroup_id => l_group_id,
4580: P_Sales_Lead_Id => I.sales_lead_id,
4573: P_Commit => FND_API.G_FALSE,
4574: P_Validation_Level => l_validation_level,
4575: P_Check_Access_Flag => FND_API.G_MISS_CHAR,
4576: P_Admin_Flag => FND_API.G_MISS_CHAR,
4577: P_Admin_Group_Id => FND_API.G_MISS_NUM,
4578: P_identity_salesforce_id => G_SL_SALESFORCE_ID,
4579: P_Salesgroup_id => l_group_id,
4580: P_Sales_Lead_Id => I.sales_lead_id,
4581: X_Return_Status => l_return_status,
4584: );
4585:
4586: -- bugfix# 2891236 , should check for l_return_status
4587: -- Bug 2893436, it shouldn't raise exception if return status is W
4588: IF l_return_status = FND_API.G_RET_STS_ERROR THEN
4589: write_log(3, 'Lead_Process_After_Create errors');
4590: raise FND_API.G_EXC_ERROR;
4591: ELSIF l_return_status = FND_API.G_RET_STS_UNEXP_ERROR THEN
4592: write_log(3, 'Lead_Process_After_Create unexp errors');
4586: -- bugfix# 2891236 , should check for l_return_status
4587: -- Bug 2893436, it shouldn't raise exception if return status is W
4588: IF l_return_status = FND_API.G_RET_STS_ERROR THEN
4589: write_log(3, 'Lead_Process_After_Create errors');
4590: raise FND_API.G_EXC_ERROR;
4591: ELSIF l_return_status = FND_API.G_RET_STS_UNEXP_ERROR THEN
4592: write_log(3, 'Lead_Process_After_Create unexp errors');
4593: raise FND_API.G_EXC_UNEXPECTED_ERROR;
4594: ELSE
4587: -- Bug 2893436, it shouldn't raise exception if return status is W
4588: IF l_return_status = FND_API.G_RET_STS_ERROR THEN
4589: write_log(3, 'Lead_Process_After_Create errors');
4590: raise FND_API.G_EXC_ERROR;
4591: ELSIF l_return_status = FND_API.G_RET_STS_UNEXP_ERROR THEN
4592: write_log(3, 'Lead_Process_After_Create unexp errors');
4593: raise FND_API.G_EXC_UNEXPECTED_ERROR;
4594: ELSE
4595: write_log(3, 'Lead_Process_After_Create ' || l_return_status);
4589: write_log(3, 'Lead_Process_After_Create errors');
4590: raise FND_API.G_EXC_ERROR;
4591: ELSIF l_return_status = FND_API.G_RET_STS_UNEXP_ERROR THEN
4592: write_log(3, 'Lead_Process_After_Create unexp errors');
4593: raise FND_API.G_EXC_UNEXPECTED_ERROR;
4594: ELSE
4595: write_log(3, 'Lead_Process_After_Create ' || l_return_status);
4596: END IF;
4597:
4602:
4603: --writing bak to as_import_interface
4604: I.load_status := G_LOAD_STATUS_SUCC;
4605: writeBak(I, G_return_status);
4606: IF ((G_return_status <> FND_API.G_RET_STS_SUCCESS) AND
4607: (G_return_status <> 'W'))
4608: THEN
4609: write_log(3, 'writeBak failed');
4610: RAISE FND_API.G_EXC_ERROR;
4606: IF ((G_return_status <> FND_API.G_RET_STS_SUCCESS) AND
4607: (G_return_status <> 'W'))
4608: THEN
4609: write_log(3, 'writeBak failed');
4610: RAISE FND_API.G_EXC_ERROR;
4611: END IF;
4612: l_batch_succ := l_batch_succ +1;
4613:
4614: -- ffang 071701, bug 1888388, temporary solution
4625: commit;
4626:
4627: Exception
4628:
4629: when FND_API.G_EXC_ERROR Then
4630: rollback;
4631: l_batch_err := l_batch_err +1;
4632: l_error_type := 'EXP';
4633: write_errors(I,l_error_type, G_return_status );
4630: rollback;
4631: l_batch_err := l_batch_err +1;
4632: l_error_type := 'EXP';
4633: write_errors(I,l_error_type, G_return_status );
4634: If G_return_status <> FND_API.G_RET_STS_SUCCESS Then
4635: write_log(3, 'write_errors failed');
4636: else
4637: I.load_status := G_LOAD_STATUS_ERR;
4638: writeBak(I, G_return_status);
4635: write_log(3, 'write_errors failed');
4636: else
4637: I.load_status := G_LOAD_STATUS_ERR;
4638: writeBak(I, G_return_status);
4639: If G_return_status <> FND_API.G_RET_STS_SUCCESS Then
4640: write_log(3, 'writeBak failed');
4641: End if;
4642: End if;
4643: commit;
4640: write_log(3, 'writeBak failed');
4641: End if;
4642: End if;
4643: commit;
4644: when FND_API.G_EXC_UNEXPECTED_ERROR Then
4645: l_batch_unexp := l_batch_unexp +1;
4646: rollback;
4647: l_error_type := 'UNEXP';
4648: write_errors(I,l_error_type, G_return_status );
4645: l_batch_unexp := l_batch_unexp +1;
4646: rollback;
4647: l_error_type := 'UNEXP';
4648: write_errors(I,l_error_type, G_return_status );
4649: If G_return_status <> FND_API.G_RET_STS_SUCCESS Then
4650: write_log(3, 'write_errors failed');
4651: else
4652: I.load_status := G_LOAD_STATUS_UNEXP_ERR;
4653: writeBak(I, G_return_status);
4650: write_log(3, 'write_errors failed');
4651: else
4652: I.load_status := G_LOAD_STATUS_UNEXP_ERR;
4653: writeBak(I, G_return_status);
4654: If G_return_status <> FND_API.G_RET_STS_SUCCESS Then
4655: write_log(3, 'writeBak failed');
4656: End if;
4657: End if;
4658: commit;
4660: l_batch_unexp := l_batch_unexp +1;
4661: rollback;
4662: l_error_type := 'OTHER';
4663: write_errors(I,l_error_type, G_return_status );
4664: If G_return_status <> FND_API.G_RET_STS_SUCCESS Then
4665: write_log(3, 'write_errors failed');
4666: else
4667: I.load_status := G_LOAD_STATUS_UNEXP_ERR;
4668: writeBak(I, G_return_status);
4665: write_log(3, 'write_errors failed');
4666: else
4667: I.load_status := G_LOAD_STATUS_UNEXP_ERR;
4668: writeBak(I, G_return_status);
4669: If G_return_status <> FND_API.G_RET_STS_SUCCESS Then
4670: write_log(3, 'writeBak failed');
4671: End if;
4672: End if;
4673: commit;