575: FND_MESSAGE.SET_NAME('AR', 'HZ_SYNC_SQL_EXCEP');
576: FND_MESSAGE.SET_TOKEN('PROC','sync_org');
577: FND_MESSAGE.SET_TOKEN('ERROR' ,SQLERRM);
578: FND_MSG_PUB.ADD;
579: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
580: END sync_org;
581:
582:
583: PROCEDURE sync_person (
631: FND_MESSAGE.SET_NAME('AR', 'HZ_SYNC_SQL_EXCEP');
632: FND_MESSAGE.SET_TOKEN('PROC','sync_person');
633: FND_MESSAGE.SET_TOKEN('ERROR' ,SQLERRM);
634: FND_MSG_PUB.ADD;
635: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
636: END sync_person;
637:
638:
639: PROCEDURE sync_party_site (
697: FND_MESSAGE.SET_NAME('AR', 'HZ_SYNC_SQL_EXCEP');
698: FND_MESSAGE.SET_TOKEN('PROC','sync_party_site');
699: FND_MESSAGE.SET_TOKEN('ERROR' ,SQLERRM);
700: FND_MSG_PUB.ADD;
701: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
702: END sync_party_site;
703:
704:
705: PROCEDURE sync_contact (
745: FND_MESSAGE.SET_NAME('AR', 'HZ_SYNC_SQL_EXCEP');
746: FND_MESSAGE.SET_TOKEN('PROC','sync_contact');
747: FND_MESSAGE.SET_TOKEN('ERROR' ,SQLERRM);
748: FND_MSG_PUB.ADD;
749: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
750: END sync_contact;
751:
752:
753: PROCEDURE sync_contact_point (
842: FND_MESSAGE.SET_NAME('AR', 'HZ_SYNC_SQL_EXCEP');
843: FND_MESSAGE.SET_TOKEN('PROC','sync_contact_point');
844: FND_MESSAGE.SET_TOKEN('ERROR' ,SQLERRM);
845: FND_MSG_PUB.ADD;
846: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
847: END sync_contact_point;
848:
849:
850: PROCEDURE sync_relationship (
873: CLOSE org_contacts;
874: END IF;
875:
876: EXCEPTION
877: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
878: hz_common_pub.enable_cont_source_security;
879: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
880: WHEN OTHERS THEN
881: hz_common_pub.enable_cont_source_security;
875:
876: EXCEPTION
877: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
878: hz_common_pub.enable_cont_source_security;
879: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
880: WHEN OTHERS THEN
881: hz_common_pub.enable_cont_source_security;
882: FND_MESSAGE.SET_NAME('AR', 'HZ_SYNC_SQL_EXCEP');
883: FND_MESSAGE.SET_TOKEN('PROC','sync_relationship');
882: FND_MESSAGE.SET_NAME('AR', 'HZ_SYNC_SQL_EXCEP');
883: FND_MESSAGE.SET_TOKEN('PROC','sync_relationship');
884: FND_MESSAGE.SET_TOKEN('ERROR' ,SQLERRM);
885: FND_MSG_PUB.ADD;
886: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
887: END;
888:
889: --- VJN CHANGED THIS PROCEDURE TO INCLUDE THE CHECK OF 'I' FOR THE
890: -- party_sites CURSOR (Bug 3139325)
914: CLOSE party_sites;
915: END IF;
916:
917: EXCEPTION
918: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
919: hz_common_pub.enable_cont_source_security;
920: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
921: WHEN OTHERS THEN
922: hz_common_pub.enable_cont_source_security;
916:
917: EXCEPTION
918: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
919: hz_common_pub.enable_cont_source_security;
920: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
921: WHEN OTHERS THEN
922: hz_common_pub.enable_cont_source_security;
923: FND_MESSAGE.SET_NAME('AR', 'HZ_SYNC_SQL_EXCEP');
924: FND_MESSAGE.SET_TOKEN('PROC','sync_location');
923: FND_MESSAGE.SET_NAME('AR', 'HZ_SYNC_SQL_EXCEP');
924: FND_MESSAGE.SET_TOKEN('PROC','sync_location');
925: FND_MESSAGE.SET_TOKEN('ERROR' ,SQLERRM);
926: FND_MSG_PUB.ADD;
927: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
928: END;
929:
930: PROCEDURE sync_cust_account (
931: p_cust_acct_id IN NUMBER,
962: END IF;
963: CLOSE c_cust_party;
964: END IF;
965: EXCEPTION
966: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
967: hz_common_pub.enable_cont_source_security;
968: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
969: WHEN OTHERS THEN
970: hz_common_pub.enable_cont_source_security;
964: END IF;
965: EXCEPTION
966: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
967: hz_common_pub.enable_cont_source_security;
968: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
969: WHEN OTHERS THEN
970: hz_common_pub.enable_cont_source_security;
971: FND_MESSAGE.SET_NAME('AR', 'HZ_SYNC_SQL_EXCEP');
972: FND_MESSAGE.SET_TOKEN('PROC','sync_cust_account');
971: FND_MESSAGE.SET_NAME('AR', 'HZ_SYNC_SQL_EXCEP');
972: FND_MESSAGE.SET_TOKEN('PROC','sync_cust_account');
973: FND_MESSAGE.SET_TOKEN('ERROR' ,SQLERRM);
974: FND_MSG_PUB.ADD;
975: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
976: END;
977:
978: -- VJN added for Reporting errored records into HZ_DQM_SYNC_INTERFACE
979:
1217:
1218: l_bool := fnd_installation.GET_APP_INFO('AR',l_status,l_tmp,l_index_owner);
1219: OPTIMIZE_INDEX(l_index_owner || '.hz_stage_parties_t1', 'FULL', l_prof_val, idx_retcode , idx_err);
1220: IF idx_retcode = 1 THEN
1221: RAISE FND_API.G_EXC_ERROR;
1222: END IF;
1223: log('Done');
1224:
1225: log('Optimizing party site index .. ', TRUE);
1224:
1225: log('Optimizing party site index .. ', TRUE);
1226: OPTIMIZE_INDEX(l_index_owner || '.hz_stage_party_sites_t1', 'FULL', l_prof_val, idx_retcode , idx_err);
1227: IF idx_retcode = 1 THEN
1228: RAISE FND_API.G_EXC_ERROR;
1229: END IF;
1230: log('Done');
1231:
1232: log('Optimizing contact index .. ', TRUE);
1231:
1232: log('Optimizing contact index .. ', TRUE);
1233: OPTIMIZE_INDEX(l_index_owner || '.hz_stage_contact_t1', 'FULL', l_prof_val, idx_retcode , idx_err);
1234: IF idx_retcode = 1 THEN
1235: RAISE FND_API.G_EXC_ERROR;
1236: END IF;
1237: log('Done');
1238:
1239: log('Optimizing contact point index .. ', TRUE);
1238:
1239: log('Optimizing contact point index .. ', TRUE);
1240: OPTIMIZE_INDEX(l_index_owner || '.hz_stage_cpt_t1', 'FULL', l_prof_val, idx_retcode , idx_err);
1241: IF idx_retcode = 1 THEN
1242: RAISE FND_API.G_EXC_ERROR;
1243: END IF;
1244: log('Done');
1245:
1246: outandlog('Concurrent Program Execution completed ');
1304: BEGIN
1305: FND_MSG_PUB.Reset;
1306:
1307: FOR I IN 1..FND_MSG_PUB.Count_Msg LOOP
1308: l_msg_data := l_msg_data || FND_MSG_PUB.Get(p_encoded => FND_API.G_FALSE );
1309: END LOOP;
1310: IF (SQLERRM IS NOT NULL) THEN
1311: l_msg_data := l_msg_data || SQLERRM;
1312: END IF;
1314: RETURN l_msg_data;
1315: END logerror;
1316:
1317: PROCEDURE stage_party_merge(
1318: p_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1319: p_from_id IN NUMBER:=FND_API.G_MISS_NUM,
1320: x_to_id IN OUT NOCOPY NUMBER,
1321: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1322: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1315: END logerror;
1316:
1317: PROCEDURE stage_party_merge(
1318: p_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1319: p_from_id IN NUMBER:=FND_API.G_MISS_NUM,
1320: x_to_id IN OUT NOCOPY NUMBER,
1321: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1322: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1323: p_par_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1317: PROCEDURE stage_party_merge(
1318: p_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1319: p_from_id IN NUMBER:=FND_API.G_MISS_NUM,
1320: x_to_id IN OUT NOCOPY NUMBER,
1321: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1322: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1323: p_par_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1324: p_batch_id IN NUMBER:=FND_API.G_MISS_NUM,
1325: p_batch_party_id IN NUMBER:=FND_API.G_MISS_NUM,
1318: p_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1319: p_from_id IN NUMBER:=FND_API.G_MISS_NUM,
1320: x_to_id IN OUT NOCOPY NUMBER,
1321: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1322: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1323: p_par_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1324: p_batch_id IN NUMBER:=FND_API.G_MISS_NUM,
1325: p_batch_party_id IN NUMBER:=FND_API.G_MISS_NUM,
1326: x_return_status OUT NOCOPY VARCHAR2
1319: p_from_id IN NUMBER:=FND_API.G_MISS_NUM,
1320: x_to_id IN OUT NOCOPY NUMBER,
1321: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1322: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1323: p_par_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1324: p_batch_id IN NUMBER:=FND_API.G_MISS_NUM,
1325: p_batch_party_id IN NUMBER:=FND_API.G_MISS_NUM,
1326: x_return_status OUT NOCOPY VARCHAR2
1327: ) IS
1320: x_to_id IN OUT NOCOPY NUMBER,
1321: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1322: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1323: p_par_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1324: p_batch_id IN NUMBER:=FND_API.G_MISS_NUM,
1325: p_batch_party_id IN NUMBER:=FND_API.G_MISS_NUM,
1326: x_return_status OUT NOCOPY VARCHAR2
1327: ) IS
1328:
1321: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1322: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1323: p_par_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1324: p_batch_id IN NUMBER:=FND_API.G_MISS_NUM,
1325: p_batch_party_id IN NUMBER:=FND_API.G_MISS_NUM,
1326: x_return_status OUT NOCOPY VARCHAR2
1327: ) IS
1328:
1329: l_party_type VARCHAR2(30);
1329: l_party_type VARCHAR2(30);
1330:
1331: BEGIN
1332:
1333: x_return_status := FND_API.G_RET_STS_SUCCESS;
1334:
1335: SELECT party_type INTO l_party_type
1336: FROM HZ_PARTIES
1337: WHERE party_id = p_from_id;
1351: WHEN OTHERS THEN
1352: FND_MESSAGE.SET_NAME('AR', 'HZ_MERGE_SQL_ERROR');
1353: FND_MESSAGE.SET_TOKEN('ERROR' ,SQLERRM);
1354: FND_MSG_PUB.ADD;
1355: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
1356: END stage_party_merge;
1357:
1358: PROCEDURE stage_party_site_merge(
1359: p_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1355: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
1356: END stage_party_merge;
1357:
1358: PROCEDURE stage_party_site_merge(
1359: p_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1360: p_from_id IN NUMBER:=FND_API.G_MISS_NUM,
1361: x_to_id IN OUT NOCOPY NUMBER,
1362: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1363: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1356: END stage_party_merge;
1357:
1358: PROCEDURE stage_party_site_merge(
1359: p_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1360: p_from_id IN NUMBER:=FND_API.G_MISS_NUM,
1361: x_to_id IN OUT NOCOPY NUMBER,
1362: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1363: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1364: p_par_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1358: PROCEDURE stage_party_site_merge(
1359: p_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1360: p_from_id IN NUMBER:=FND_API.G_MISS_NUM,
1361: x_to_id IN OUT NOCOPY NUMBER,
1362: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1363: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1364: p_par_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1365: p_batch_id IN NUMBER:=FND_API.G_MISS_NUM,
1366: p_batch_party_id IN NUMBER:=FND_API.G_MISS_NUM,
1359: p_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1360: p_from_id IN NUMBER:=FND_API.G_MISS_NUM,
1361: x_to_id IN OUT NOCOPY NUMBER,
1362: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1363: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1364: p_par_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1365: p_batch_id IN NUMBER:=FND_API.G_MISS_NUM,
1366: p_batch_party_id IN NUMBER:=FND_API.G_MISS_NUM,
1367: x_return_status OUT NOCOPY VARCHAR2
1360: p_from_id IN NUMBER:=FND_API.G_MISS_NUM,
1361: x_to_id IN OUT NOCOPY NUMBER,
1362: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1363: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1364: p_par_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1365: p_batch_id IN NUMBER:=FND_API.G_MISS_NUM,
1366: p_batch_party_id IN NUMBER:=FND_API.G_MISS_NUM,
1367: x_return_status OUT NOCOPY VARCHAR2
1368: ) IS
1361: x_to_id IN OUT NOCOPY NUMBER,
1362: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1363: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1364: p_par_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1365: p_batch_id IN NUMBER:=FND_API.G_MISS_NUM,
1366: p_batch_party_id IN NUMBER:=FND_API.G_MISS_NUM,
1367: x_return_status OUT NOCOPY VARCHAR2
1368: ) IS
1369:
1362: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1363: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1364: p_par_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1365: p_batch_id IN NUMBER:=FND_API.G_MISS_NUM,
1366: p_batch_party_id IN NUMBER:=FND_API.G_MISS_NUM,
1367: x_return_status OUT NOCOPY VARCHAR2
1368: ) IS
1369:
1370: l_party_id NUMBER;
1372: l_party_site_search_rec HZ_PARTY_SEARCH.party_site_search_rec_type;
1373: l_party_site_stage_rec HZ_PARTY_STAGE.PARTY_SITE_STAGE_REC_TYPE;
1374:
1375: BEGIN
1376: x_return_status := FND_API.G_RET_STS_SUCCESS;
1377:
1378: BEGIN
1379: DELETE FROM HZ_STAGED_PARTY_SITES
1380: WHERE party_site_id = p_from_id;
1406: WHEN OTHERS THEN
1407: FND_MESSAGE.SET_NAME('AR', 'HZ_MERGE_SQL_ERROR');
1408: FND_MESSAGE.SET_TOKEN('ERROR' ,SQLERRM);
1409: FND_MSG_PUB.ADD;
1410: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
1411: END stage_party_site_merge;
1412:
1413: PROCEDURE stage_contact_point_merge(
1414: p_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1410: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
1411: END stage_party_site_merge;
1412:
1413: PROCEDURE stage_contact_point_merge(
1414: p_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1415: p_from_id IN NUMBER:=FND_API.G_MISS_NUM,
1416: x_to_id IN OUT NOCOPY NUMBER,
1417: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1418: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1411: END stage_party_site_merge;
1412:
1413: PROCEDURE stage_contact_point_merge(
1414: p_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1415: p_from_id IN NUMBER:=FND_API.G_MISS_NUM,
1416: x_to_id IN OUT NOCOPY NUMBER,
1417: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1418: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1419: p_par_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1413: PROCEDURE stage_contact_point_merge(
1414: p_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1415: p_from_id IN NUMBER:=FND_API.G_MISS_NUM,
1416: x_to_id IN OUT NOCOPY NUMBER,
1417: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1418: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1419: p_par_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1420: p_batch_id IN NUMBER:=FND_API.G_MISS_NUM,
1421: p_batch_party_id IN NUMBER:=FND_API.G_MISS_NUM,
1414: p_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1415: p_from_id IN NUMBER:=FND_API.G_MISS_NUM,
1416: x_to_id IN OUT NOCOPY NUMBER,
1417: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1418: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1419: p_par_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1420: p_batch_id IN NUMBER:=FND_API.G_MISS_NUM,
1421: p_batch_party_id IN NUMBER:=FND_API.G_MISS_NUM,
1422: x_return_status OUT NOCOPY VARCHAR2
1415: p_from_id IN NUMBER:=FND_API.G_MISS_NUM,
1416: x_to_id IN OUT NOCOPY NUMBER,
1417: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1418: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1419: p_par_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1420: p_batch_id IN NUMBER:=FND_API.G_MISS_NUM,
1421: p_batch_party_id IN NUMBER:=FND_API.G_MISS_NUM,
1422: x_return_status OUT NOCOPY VARCHAR2
1423: ) IS
1416: x_to_id IN OUT NOCOPY NUMBER,
1417: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1418: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1419: p_par_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1420: p_batch_id IN NUMBER:=FND_API.G_MISS_NUM,
1421: p_batch_party_id IN NUMBER:=FND_API.G_MISS_NUM,
1422: x_return_status OUT NOCOPY VARCHAR2
1423: ) IS
1424:
1417: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1418: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1419: p_par_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1420: p_batch_id IN NUMBER:=FND_API.G_MISS_NUM,
1421: p_batch_party_id IN NUMBER:=FND_API.G_MISS_NUM,
1422: x_return_status OUT NOCOPY VARCHAR2
1423: ) IS
1424:
1425: l_contact_point_id NUMBER;
1463: l_cp_org_contact_id NUMBER;
1464:
1465: BEGIN
1466:
1467: x_return_status := FND_API.G_RET_STS_SUCCESS;
1468:
1469: BEGIN
1470: DELETE FROM HZ_STAGED_CONTACT_POINTS
1471: WHERE contact_point_id = p_from_id;
1534: fnd_file.put_line(fnd_file.log,'Error here1 '||SQLERRM);
1535: FND_MESSAGE.SET_NAME('AR', 'HZ_MERGE_SQL_ERROR');
1536: FND_MESSAGE.SET_TOKEN('ERROR' ,SQLERRM);
1537: FND_MSG_PUB.ADD;
1538: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
1539: END stage_contact_point_merge;
1540:
1541:
1542: PROCEDURE stage_contact_merge(
1539: END stage_contact_point_merge;
1540:
1541:
1542: PROCEDURE stage_contact_merge(
1543: p_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1544: p_from_id IN NUMBER:=FND_API.G_MISS_NUM,
1545: x_to_id IN OUT NOCOPY NUMBER,
1546: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1547: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1540:
1541:
1542: PROCEDURE stage_contact_merge(
1543: p_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1544: p_from_id IN NUMBER:=FND_API.G_MISS_NUM,
1545: x_to_id IN OUT NOCOPY NUMBER,
1546: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1547: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1548: p_par_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1542: PROCEDURE stage_contact_merge(
1543: p_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1544: p_from_id IN NUMBER:=FND_API.G_MISS_NUM,
1545: x_to_id IN OUT NOCOPY NUMBER,
1546: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1547: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1548: p_par_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1549: p_batch_id IN NUMBER:=FND_API.G_MISS_NUM,
1550: p_batch_party_id IN NUMBER:=FND_API.G_MISS_NUM,
1543: p_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1544: p_from_id IN NUMBER:=FND_API.G_MISS_NUM,
1545: x_to_id IN OUT NOCOPY NUMBER,
1546: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1547: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1548: p_par_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1549: p_batch_id IN NUMBER:=FND_API.G_MISS_NUM,
1550: p_batch_party_id IN NUMBER:=FND_API.G_MISS_NUM,
1551: x_return_status OUT NOCOPY VARCHAR2
1544: p_from_id IN NUMBER:=FND_API.G_MISS_NUM,
1545: x_to_id IN OUT NOCOPY NUMBER,
1546: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1547: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1548: p_par_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1549: p_batch_id IN NUMBER:=FND_API.G_MISS_NUM,
1550: p_batch_party_id IN NUMBER:=FND_API.G_MISS_NUM,
1551: x_return_status OUT NOCOPY VARCHAR2
1552: ) IS
1545: x_to_id IN OUT NOCOPY NUMBER,
1546: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1547: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1548: p_par_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1549: p_batch_id IN NUMBER:=FND_API.G_MISS_NUM,
1550: p_batch_party_id IN NUMBER:=FND_API.G_MISS_NUM,
1551: x_return_status OUT NOCOPY VARCHAR2
1552: ) IS
1553:
1546: p_from_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1547: p_to_fk_id IN NUMBER:=FND_API.G_MISS_NUM,
1548: p_par_entity_name IN VARCHAR2:=FND_API.G_MISS_CHAR,
1549: p_batch_id IN NUMBER:=FND_API.G_MISS_NUM,
1550: p_batch_party_id IN NUMBER:=FND_API.G_MISS_NUM,
1551: x_return_status OUT NOCOPY VARCHAR2
1552: ) IS
1553:
1554: l_org_contact_id NUMBER;
1557: l_contact_stage_rec HZ_PARTY_STAGE.CONTACT_STAGE_REC_TYPE;
1558: l_rel_party_id NUMBER;
1559: BEGIN
1560:
1561: x_return_status := FND_API.G_RET_STS_SUCCESS;
1562:
1563: BEGIN
1564: DELETE FROM HZ_STAGED_CONTACTS
1565: WHERE org_contact_id = p_from_id;
1612: WHEN OTHERS THEN
1613: FND_MESSAGE.SET_NAME('AR', 'HZ_MERGE_SQL_ERROR');
1614: FND_MESSAGE.SET_TOKEN('ERROR' ,SQLERRM);
1615: FND_MSG_PUB.ADD;
1616: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
1617:
1618: END stage_contact_merge;
1619:
1620:
1743: IF (i_party) THEN
1744: SYNC_INDEX_REALTIME(l_index_owner || '.hz_stage_parties_t1',
1745: idx_retcode , idx_err);
1746: IF idx_retcode = 1 THEN
1747: RAISE FND_API.G_EXC_ERROR;
1748: END IF;
1749:
1750: END IF;
1751: IF (i_party_sites) THEN
1751: IF (i_party_sites) THEN
1752: SYNC_INDEX_REALTIME(l_index_owner || '.hz_stage_party_sites_t1',
1753: idx_retcode , idx_err);
1754: IF idx_retcode = 1 THEN
1755: RAISE FND_API.G_EXC_ERROR;
1756: END IF;
1757:
1758: END IF;
1759: IF (i_contacts) THEN
1759: IF (i_contacts) THEN
1760: SYNC_INDEX_REALTIME(l_index_owner || '.hz_stage_contact_t1',
1761: idx_retcode , idx_err);
1762: IF idx_retcode = 1 THEN
1763: RAISE FND_API.G_EXC_ERROR;
1764: END IF;
1765:
1766: END IF;
1767: IF (i_contact_points) THEN
1767: IF (i_contact_points) THEN
1768: SYNC_INDEX_REALTIME(l_index_owner || '.hz_stage_cpt_t1',
1769: idx_retcode , idx_err);
1770: IF idx_retcode = 1 THEN
1771: RAISE FND_API.G_EXC_ERROR;
1772: END IF;
1773: END IF;
1774: END IF;
1775: EXCEPTION
1772: END IF;
1773: END IF;
1774: END IF;
1775: EXCEPTION
1776: WHEN FND_API.G_EXC_ERROR THEN
1777: outandlog('Error : Aborting Program');
1778: outandlog(idx_err);
1779: WHEN OTHERS THEN
1780: outandlog('Error : Aborting Program');
2170: outandlog('Worker with request id ' || l_sub_requests(I) );
2171: outandlog('Did not complete normally.');
2172: retcode := 2;
2173: log(' retcode = ' || retcode);
2174: RAISE FND_API.G_EXC_ERROR;
2175: END LOOP;
2176: END IF;
2177: --Start of Bug No : 4915282
2178: --Set the index transactional, if the search on non indexed records is enabled.
2188: --End of Bug No : 4915282
2189: END IF;
2190:
2191: EXCEPTION
2192: WHEN FND_API.G_EXC_ERROR THEN
2193: log('DQM Synchronization Program Aborted');
2194: retcode := 2;
2195: err := err || logerror || SQLERRM;
2196: RAISE;
2209: BEGIN
2210: log('Index being synched ... ' || p_index_name);
2211: sync_index( p_index_name, retcode, err);
2212: if (retcode=2) then
2213: RAISE FND_API.G_EXC_ERROR;
2214: end if;
2215: EXCEPTION
2216: WHEN OTHERS THEN
2217: retcode := 2;
2215: EXCEPTION
2216: WHEN OTHERS THEN
2217: retcode := 2;
2218: err := SQLERRM;
2219: RAISE FND_API.G_EXC_ERROR;--
2220: END sync_index_conc;
2221:
2222: ----------------------------------------
2223: -- VJN Changes for SYNC in R12