127:
128: IF l_staged_var='N' THEN
129: FND_MESSAGE.SET_NAME('AR', 'HZ_MATCH_RULE_TX_NOT_STAGED');
130: FND_MSG_PUB.ADD;
131: RAISE FND_API.G_EXC_ERROR;
132: END IF;
133:
134: -- End bug 4736139
135:
271:
272: -- No MATCH RULE FOUND
273: FND_MESSAGE.SET_NAME('AR', 'HZ_NO_MATCH_RULE');
274: FND_MSG_PUB.ADD;
275: RAISE FND_API.G_EXC_ERROR;
276: END IF;
277:
278: IF p_batch_name IS NULL OR p_batch_name = '' THEN
279: FND_MESSAGE.SET_NAME('AR', 'HZ_INVALID_BATCH_NAME');
277:
278: IF p_batch_name IS NULL OR p_batch_name = '' THEN
279: FND_MESSAGE.SET_NAME('AR', 'HZ_INVALID_BATCH_NAME');
280: FND_MSG_PUB.ADD;
281: RAISE FND_API.G_EXC_ERROR;
282: END IF;
283:
284: --- VJN INTRODUCED CODE FOR QUICK DUPLICATE IDENTIFICATION
285:
450: outandlog('End Time : '|| TO_CHAR(SYSDATE, 'MM-DD-YY HH24:MI:SS'));
451: END IF;
452:
453: EXCEPTION
454: WHEN FND_API.G_EXC_ERROR THEN
455: outandlog('Expected Error section in Parent concurrent program. Aborting duplicate batch.' ||SQLERRM);
456: retcode := 2;
457: errbuf := errbuf || logerror;
458: FND_FILE.close;
455: outandlog('Expected Error section in Parent concurrent program. Aborting duplicate batch.' ||SQLERRM);
456: retcode := 2;
457: errbuf := errbuf || logerror;
458: FND_FILE.close;
459: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
460: outandlog('UnExpected Error section in Parent concurrent program. Aborting duplicate batch.' ||SQLERRM);
461: retcode := 2;
462: errbuf := errbuf || logerror;
463: FND_FILE.close;
468: FND_FILE.close;
469: END;
470:
471: PROCEDURE find_party_dups (
472: p_init_msg_list IN VARCHAR2:= FND_API.G_FALSE,
473: p_rule_id IN NUMBER,
474: p_party_id IN NUMBER,
475: x_party_search_rec OUT NOCOPY HZ_PARTY_SEARCH.party_search_rec_type,
476: x_party_site_list OUT NOCOPY HZ_PARTY_SEARCH.party_site_list,
493: BEGIN
494: l_rule_id := p_rule_id;
495:
496: HZ_PARTY_SEARCH.get_party_for_search(
497: FND_API.G_FALSE,l_rule_id, p_party_id, x_party_search_rec,
498: x_party_site_list, x_contact_list, x_contact_point_list,
499: l_return_status, l_msg_count, l_msg_data);
500:
501: IF l_return_status <> FND_API.G_RET_STS_SUCCESS THEN
497: FND_API.G_FALSE,l_rule_id, p_party_id, x_party_search_rec,
498: x_party_site_list, x_contact_list, x_contact_point_list,
499: l_return_status, l_msg_count, l_msg_data);
500:
501: IF l_return_status <> FND_API.G_RET_STS_SUCCESS THEN
502: IF l_return_status = FND_API.G_RET_STS_ERROR THEN
503: FND_MESSAGE.SET_NAME('AR', 'HZ_PARTY_ACQUIRE_ERROR');
504: FND_MESSAGE.SET_TOKEN('PARTY_ID', TO_CHAR(p_party_id));
505: FND_MSG_PUB.ADD;
498: x_party_site_list, x_contact_list, x_contact_point_list,
499: l_return_status, l_msg_count, l_msg_data);
500:
501: IF l_return_status <> FND_API.G_RET_STS_SUCCESS THEN
502: IF l_return_status = FND_API.G_RET_STS_ERROR THEN
503: FND_MESSAGE.SET_NAME('AR', 'HZ_PARTY_ACQUIRE_ERROR');
504: FND_MESSAGE.SET_TOKEN('PARTY_ID', TO_CHAR(p_party_id));
505: FND_MSG_PUB.ADD;
506: RAISE FND_API.G_EXC_ERROR;
502: IF l_return_status = FND_API.G_RET_STS_ERROR THEN
503: FND_MESSAGE.SET_NAME('AR', 'HZ_PARTY_ACQUIRE_ERROR');
504: FND_MESSAGE.SET_TOKEN('PARTY_ID', TO_CHAR(p_party_id));
505: FND_MSG_PUB.ADD;
506: RAISE FND_API.G_EXC_ERROR;
507: ELSE
508: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
509: END IF;
510: ELSE
504: FND_MESSAGE.SET_TOKEN('PARTY_ID', TO_CHAR(p_party_id));
505: FND_MSG_PUB.ADD;
506: RAISE FND_API.G_EXC_ERROR;
507: ELSE
508: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
509: END IF;
510: ELSE
511: HZ_PARTY_SEARCH.find_duplicate_parties(
512: FND_API.G_FALSE,l_rule_id, p_party_id, NULL,
508: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
509: END IF;
510: ELSE
511: HZ_PARTY_SEARCH.find_duplicate_parties(
512: FND_API.G_FALSE,l_rule_id, p_party_id, NULL,
513: NULL, null, null, l_dup_set_id,x_search_ctx_id, l_num_matches,
514: l_return_status, l_msg_count, l_msg_data);
515: END IF;
516:
514: l_return_status, l_msg_count, l_msg_data);
515: END IF;
516:
517: EXCEPTION
518: WHEN FND_API.G_EXC_ERROR THEN
519: x_return_status := FND_API.G_RET_STS_ERROR;
520: FND_MSG_PUB.Count_And_Get(
521: p_encoded => FND_API.G_FALSE,
522: p_count => x_msg_count,
515: END IF;
516:
517: EXCEPTION
518: WHEN FND_API.G_EXC_ERROR THEN
519: x_return_status := FND_API.G_RET_STS_ERROR;
520: FND_MSG_PUB.Count_And_Get(
521: p_encoded => FND_API.G_FALSE,
522: p_count => x_msg_count,
523: p_data => x_msg_data);
517: EXCEPTION
518: WHEN FND_API.G_EXC_ERROR THEN
519: x_return_status := FND_API.G_RET_STS_ERROR;
520: FND_MSG_PUB.Count_And_Get(
521: p_encoded => FND_API.G_FALSE,
522: p_count => x_msg_count,
523: p_data => x_msg_data);
524: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
525: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
520: FND_MSG_PUB.Count_And_Get(
521: p_encoded => FND_API.G_FALSE,
522: p_count => x_msg_count,
523: p_data => x_msg_data);
524: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
525: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
526: FND_MSG_PUB.Count_And_Get(
527: p_encoded => FND_API.G_FALSE,
528: p_count => x_msg_count,
521: p_encoded => FND_API.G_FALSE,
522: p_count => x_msg_count,
523: p_data => x_msg_data);
524: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
525: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
526: FND_MSG_PUB.Count_And_Get(
527: p_encoded => FND_API.G_FALSE,
528: p_count => x_msg_count,
529: p_data => x_msg_data);
523: p_data => x_msg_data);
524: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
525: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
526: FND_MSG_PUB.Count_And_Get(
527: p_encoded => FND_API.G_FALSE,
528: p_count => x_msg_count,
529: p_data => x_msg_data);
530: WHEN OTHERS THEN
531: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
527: p_encoded => FND_API.G_FALSE,
528: p_count => x_msg_count,
529: p_data => x_msg_data);
530: WHEN OTHERS THEN
531: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
532: FND_MESSAGE.SET_NAME('AR', 'HZ_DQM_SQL_EXCEP');
533: FND_MESSAGE.SET_TOKEN('ERROR' ,SQLERRM);
534: FND_MSG_PUB.ADD;
535:
533: FND_MESSAGE.SET_TOKEN('ERROR' ,SQLERRM);
534: FND_MSG_PUB.ADD;
535:
536: FND_MSG_PUB.Count_And_Get(
537: p_encoded => FND_API.G_FALSE,
538: p_count => x_msg_count,
539: p_data => x_msg_data);
540: END;
541:
539: p_data => x_msg_data);
540: END;
541:
542: PROCEDURE find_party_dups (
543: p_init_msg_list IN VARCHAR2:= FND_API.G_FALSE,
544: p_rule_id IN NUMBER,
545: p_party_id IN NUMBER,
546: p_party_site_ids IN HZ_PARTY_SEARCH.IDList,
547: p_contact_ids IN HZ_PARTY_SEARCH.IDList,
566: BEGIN
567: l_rule_id := p_rule_id;
568:
569: HZ_PARTY_SEARCH.get_search_criteria(
570: FND_API.G_FALSE,l_rule_id, p_party_id, p_party_site_ids,p_contact_ids,
571: p_contact_pt_ids, x_party_search_rec,
572: x_party_site_list, x_contact_list, x_contact_point_list,
573: l_return_status, l_msg_count, l_msg_data);
574:
571: p_contact_pt_ids, x_party_search_rec,
572: x_party_site_list, x_contact_list, x_contact_point_list,
573: l_return_status, l_msg_count, l_msg_data);
574:
575: IF l_return_status <> FND_API.G_RET_STS_SUCCESS THEN
576: IF l_return_status = FND_API.G_RET_STS_ERROR THEN
577: FND_MESSAGE.SET_NAME('AR', 'HZ_PARTY_ACQUIRE_ERROR');
578: FND_MESSAGE.SET_TOKEN('PARTY_ID', TO_CHAR(p_party_id));
579: FND_MSG_PUB.ADD;
572: x_party_site_list, x_contact_list, x_contact_point_list,
573: l_return_status, l_msg_count, l_msg_data);
574:
575: IF l_return_status <> FND_API.G_RET_STS_SUCCESS THEN
576: IF l_return_status = FND_API.G_RET_STS_ERROR THEN
577: FND_MESSAGE.SET_NAME('AR', 'HZ_PARTY_ACQUIRE_ERROR');
578: FND_MESSAGE.SET_TOKEN('PARTY_ID', TO_CHAR(p_party_id));
579: FND_MSG_PUB.ADD;
580: RAISE FND_API.G_EXC_ERROR;
576: IF l_return_status = FND_API.G_RET_STS_ERROR THEN
577: FND_MESSAGE.SET_NAME('AR', 'HZ_PARTY_ACQUIRE_ERROR');
578: FND_MESSAGE.SET_TOKEN('PARTY_ID', TO_CHAR(p_party_id));
579: FND_MSG_PUB.ADD;
580: RAISE FND_API.G_EXC_ERROR;
581: ELSE
582: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
583: END IF;
584: ELSE
578: FND_MESSAGE.SET_TOKEN('PARTY_ID', TO_CHAR(p_party_id));
579: FND_MSG_PUB.ADD;
580: RAISE FND_API.G_EXC_ERROR;
581: ELSE
582: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
583: END IF;
584: ELSE
585: HZ_PARTY_SEARCH.find_parties(
586: FND_API.G_FALSE,l_rule_id,
582: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
583: END IF;
584: ELSE
585: HZ_PARTY_SEARCH.find_parties(
586: FND_API.G_FALSE,l_rule_id,
587: x_party_search_rec, x_party_site_list,x_contact_list, x_contact_point_list,
588: 'party_id <> '||p_party_id || ' and ROWNUM < 1000',
589: 'N', x_search_ctx_id,x_num_matches,x_return_status,
590: x_msg_count, x_msg_data);
590: x_msg_count, x_msg_data);
591: END IF;
592:
593: EXCEPTION
594: WHEN FND_API.G_EXC_ERROR THEN
595: x_return_status := FND_API.G_RET_STS_ERROR;
596: FND_MSG_PUB.Count_And_Get(
597: p_encoded => FND_API.G_FALSE,
598: p_count => x_msg_count,
591: END IF;
592:
593: EXCEPTION
594: WHEN FND_API.G_EXC_ERROR THEN
595: x_return_status := FND_API.G_RET_STS_ERROR;
596: FND_MSG_PUB.Count_And_Get(
597: p_encoded => FND_API.G_FALSE,
598: p_count => x_msg_count,
599: p_data => x_msg_data);
593: EXCEPTION
594: WHEN FND_API.G_EXC_ERROR THEN
595: x_return_status := FND_API.G_RET_STS_ERROR;
596: FND_MSG_PUB.Count_And_Get(
597: p_encoded => FND_API.G_FALSE,
598: p_count => x_msg_count,
599: p_data => x_msg_data);
600: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
601: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
596: FND_MSG_PUB.Count_And_Get(
597: p_encoded => FND_API.G_FALSE,
598: p_count => x_msg_count,
599: p_data => x_msg_data);
600: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
601: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
602: FND_MSG_PUB.Count_And_Get(
603: p_encoded => FND_API.G_FALSE,
604: p_count => x_msg_count,
597: p_encoded => FND_API.G_FALSE,
598: p_count => x_msg_count,
599: p_data => x_msg_data);
600: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
601: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
602: FND_MSG_PUB.Count_And_Get(
603: p_encoded => FND_API.G_FALSE,
604: p_count => x_msg_count,
605: p_data => x_msg_data);
599: p_data => x_msg_data);
600: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
601: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
602: FND_MSG_PUB.Count_And_Get(
603: p_encoded => FND_API.G_FALSE,
604: p_count => x_msg_count,
605: p_data => x_msg_data);
606: WHEN OTHERS THEN
607: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
603: p_encoded => FND_API.G_FALSE,
604: p_count => x_msg_count,
605: p_data => x_msg_data);
606: WHEN OTHERS THEN
607: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
608: FND_MESSAGE.SET_NAME('AR', 'HZ_DQM_SQL_EXCEP');
609: FND_MESSAGE.SET_TOKEN('ERROR' ,SQLERRM);
610: FND_MSG_PUB.ADD;
611:
609: FND_MESSAGE.SET_TOKEN('ERROR' ,SQLERRM);
610: FND_MSG_PUB.ADD;
611:
612: FND_MSG_PUB.Count_And_Get(
613: p_encoded => FND_API.G_FALSE,
614: p_count => x_msg_count,
615: p_data => x_msg_data);
616: END;
617:
799: l_subset_defn := 'EXISTS (select 1 FROM HZ_PARTIES parties '||
800: 'where parties.party_id = stage.party_id ' ||
801: 'and '||p_subset_defn||')';
802: HZ_PARTY_SEARCH.find_duplicate_parties(
803: FND_API.G_TRUE,l_rule_id, l_cur_party_id, l_subset_defn,
804: NULL, l_batch_id, p_search_merged, l_dup_set_id,l_search_ctx_id, l_num_matches,
805: l_return_status, l_msg_count, l_msg_data);
806: ELSE
807: HZ_PARTY_SEARCH.find_duplicate_parties(
804: NULL, l_batch_id, p_search_merged, l_dup_set_id,l_search_ctx_id, l_num_matches,
805: l_return_status, l_msg_count, l_msg_data);
806: ELSE
807: HZ_PARTY_SEARCH.find_duplicate_parties(
808: FND_API.G_TRUE,l_rule_id, l_cur_party_id, NULL,
809: NULL, l_batch_id, p_search_merged, l_dup_set_id,l_search_ctx_id, l_num_matches,
810: l_return_status, l_msg_count, l_msg_data);
811: END IF;
812:
813: -- Search is not Successful
814: -- EXPECTED ERRORS :: continue to the next iteration of the loop, log errors,
815: -- until a threshold of errors.
816: -- UNEXPECTED ERRORS :: log error and exit batch.
817: IF l_return_status <> FND_API.G_RET_STS_SUCCESS
818: THEN
819: -- Count Errors
820: error_count := error_count+1;
821: IF(error_count = error_limit)
821: IF(error_count = error_limit)
822: THEN
823: log('Errors exceeded the threshold of errors');
824: log('Exiting ..');
825: RAISE FND_API.G_EXC_ERROR ;
826: END IF;
827:
828: -- Expected Errors
829: IF l_return_status = FND_API.G_RET_STS_ERROR
825: RAISE FND_API.G_EXC_ERROR ;
826: END IF;
827:
828: -- Expected Errors
829: IF l_return_status = FND_API.G_RET_STS_ERROR
830: THEN
831: log('Expected Error during party_id '||l_cur_party_id);
832: log('Error is '||l_msg_data);
833: log('Continuing ..');
835: ELSE
836: log('Unexpected Error during party_id '||l_cur_party_id);
837: log('Error is '||l_msg_data);
838: log('Exiting ..');
839: RAISE FND_API.G_EXC_UNEXPECTED_ERROR ;
840: END IF;
841: -- Search is Successful
842: ELSE
843: IF l_num_matches>0 THEN
893:
894: END IF;
895:
896: EXCEPTION
897: WHEN FND_API.G_EXC_ERROR THEN
898: log('--------------------------------');
899: log('Expected Error ' || l_cur_party_id);
900: log('Error: Aborting duplicate batch');
901: log('THIS WORKER ERRORED OUT');
899: log('Expected Error ' || l_cur_party_id);
900: log('Error: Aborting duplicate batch');
901: log('THIS WORKER ERRORED OUT');
902: FOR I IN 1..FND_MSG_PUB.Count_Msg LOOP
903: log(FND_MSG_PUB.Get(p_encoded => FND_API.G_FALSE ));
904: END LOOP;
905: FND_MESSAGE.CLEAR;
906:
907: retcode := 2;
906:
907: retcode := 2;
908: errbuf := 'Expected Error ' || l_cur_party_id;
909: FND_FILE.close;
910: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
911: log('--------------------------------');
912: log('Unexpected Error ' || l_cur_party_id);
913: log('Error: Aborting duplicate batch');
914: log('THIS WORKER ERRORED OUT');
912: log('Unexpected Error ' || l_cur_party_id);
913: log('Error: Aborting duplicate batch');
914: log('THIS WORKER ERRORED OUT');
915: FOR I IN 1..FND_MSG_PUB.Count_Msg LOOP
916: log(FND_MSG_PUB.Get(p_encoded => FND_API.G_FALSE ));
917: END LOOP;
918: FND_MESSAGE.CLEAR;
919:
920: errbuf := 'UnExpected Error ' || l_cur_party_id;
925: log('Unknown Error ' || l_cur_party_id || ' : ' || SQLERRM);
926: log('Error: Aborting duplicate batch');
927: log('THIS WORKER ERRORED OUT');
928: FOR I IN 1..FND_MSG_PUB.Count_Msg LOOP
929: log(FND_MSG_PUB.Get(p_encoded => FND_API.G_FALSE ));
930: END LOOP;
931:
932: retcode := 2;
933: errbuf := 'UnExpected SQL Error ' || l_cur_party_id;
965: FND_MESSAGE.SET_NAME('AR', 'HZ_BATCH_SQL_ERROR');
966: FND_MESSAGE.SET_TOKEN('PROC' ,'check_party_in_dupset');
967: FND_MESSAGE.SET_TOKEN('ERROR' ,SQLERRM);
968: FND_MSG_PUB.ADD;
969: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
970: END;
971:
972: -- Remove mathes that have been indicated as non-duplicates in the
973: -- HZ_DUP_EXCLUSIONS table
1012: FND_MESSAGE.SET_NAME('AR', 'HZ_BATCH_SQL_ERROR');
1013: FND_MESSAGE.SET_TOKEN('PROC' ,'remove_non_duplicates');
1014: FND_MESSAGE.SET_TOKEN('ERROR' ,SQLERRM);
1015: FND_MSG_PUB.ADD;
1016: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
1017: END remove_non_duplicates;
1018:
1019: PROCEDURE insert_match_details (
1020: p_search_ctx_id IN NUMBER,
1057: FND_MESSAGE.SET_NAME('AR', 'HZ_BATCH_SQL_ERROR');
1058: FND_MESSAGE.SET_TOKEN('PROC' ,'create_dup_set');
1059: FND_MESSAGE.SET_TOKEN('ERROR' ,SQLERRM);
1060: FND_MSG_PUB.ADD;
1061: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
1062: END insert_match_details;
1063:
1064: PROCEDURE get_dup_match_details (
1065: p_init_msg_list IN VARCHAR2 := FND_API.G_FALSE,
1061: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
1062: END insert_match_details;
1063:
1064: PROCEDURE get_dup_match_details (
1065: p_init_msg_list IN VARCHAR2 := FND_API.G_FALSE,
1066: p_rule_id IN NUMBER,
1067: p_dup_set_id IN NUMBER,
1068: x_return_status OUT NOCOPY VARCHAR2,
1069: x_msg_count OUT NOCOPY NUMBER,
1091: l_mr_comp_flag VARCHAR2(1);
1092:
1093: BEGIN
1094: -- Initialize return status and message stack
1095: x_return_status := FND_API.G_RET_STS_SUCCESS;
1096: IF FND_API.to_Boolean(p_init_msg_list) THEN
1097: FND_MSG_PUB.initialize;
1098: END IF;
1099:
1092:
1093: BEGIN
1094: -- Initialize return status and message stack
1095: x_return_status := FND_API.G_RET_STS_SUCCESS;
1096: IF FND_API.to_Boolean(p_init_msg_list) THEN
1097: FND_MSG_PUB.initialize;
1098: END IF;
1099:
1100: SELECT count(1)
1117:
1118: IF l_mr_comp_flag <> 'C' OR l_mr_last_updated_date > l_dup_set_creation_date THEN
1119: FND_MESSAGE.SET_NAME('AR', 'HZ_CDL_NO_MATCH_DETAILS');
1120: FND_MSG_PUB.ADD;
1121: RAISE FND_API.G_EXC_ERROR;
1122: END IF;
1123:
1124: HZ_PARTY_SEARCH.get_party_for_search(
1125: FND_API.G_FALSE,p_rule_id, l_winner_party_id, l_party_rec,
1121: RAISE FND_API.G_EXC_ERROR;
1122: END IF;
1123:
1124: HZ_PARTY_SEARCH.get_party_for_search(
1125: FND_API.G_FALSE,p_rule_id, l_winner_party_id, l_party_rec,
1126: l_party_site_list, l_contact_list, l_cpt_list,
1127: l_return_status, l_msg_count, l_msg_data);
1128:
1129: IF l_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1125: FND_API.G_FALSE,p_rule_id, l_winner_party_id, l_party_rec,
1126: l_party_site_list, l_contact_list, l_cpt_list,
1127: l_return_status, l_msg_count, l_msg_data);
1128:
1129: IF l_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1130: FND_MESSAGE.SET_NAME('AR', 'HZ_PARTY_ACQUIRE_ERROR');
1131: FND_MESSAGE.SET_TOKEN('PARTY_ID', TO_CHAR(l_winner_party_id));
1132: FND_MSG_PUB.ADD;
1133: RAISE FND_API.G_EXC_ERROR;
1129: IF l_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1130: FND_MESSAGE.SET_NAME('AR', 'HZ_PARTY_ACQUIRE_ERROR');
1131: FND_MESSAGE.SET_TOKEN('PARTY_ID', TO_CHAR(l_winner_party_id));
1132: FND_MSG_PUB.ADD;
1133: RAISE FND_API.G_EXC_ERROR;
1134: ELSE
1135:
1136: FOR DUP IN (SELECT DUP_PARTY_ID
1137: FROM HZ_DUP_SET_PARTIES
1136: FOR DUP IN (SELECT DUP_PARTY_ID
1137: FROM HZ_DUP_SET_PARTIES
1138: WHERE DUP_SET_ID = p_dup_set_id and dup_party_id <> l_winner_party_id) LOOP
1139: HZ_PARTY_SEARCH.get_score_details (
1140: FND_API.G_FALSE,p_rule_id, DUP.DUP_PARTY_ID,
1141: l_party_rec, l_party_site_list,l_contact_list, l_cpt_list,
1142: l_search_ctx_id, l_return_status, l_msg_count, l_msg_data);
1143: IF l_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1144: FND_MESSAGE.SET_NAME('AR', 'HZ_PARTY_SEARCH_ERROR');
1139: HZ_PARTY_SEARCH.get_score_details (
1140: FND_API.G_FALSE,p_rule_id, DUP.DUP_PARTY_ID,
1141: l_party_rec, l_party_site_list,l_contact_list, l_cpt_list,
1142: l_search_ctx_id, l_return_status, l_msg_count, l_msg_data);
1143: IF l_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1144: FND_MESSAGE.SET_NAME('AR', 'HZ_PARTY_SEARCH_ERROR');
1145: FND_MESSAGE.SET_TOKEN('PARTY_ID', TO_CHAR(DUP.DUP_PARTY_ID));
1146: FND_MSG_PUB.ADD;
1147: RAISE FND_API.G_EXC_ERROR;
1143: IF l_return_status <> FND_API.G_RET_STS_SUCCESS THEN
1144: FND_MESSAGE.SET_NAME('AR', 'HZ_PARTY_SEARCH_ERROR');
1145: FND_MESSAGE.SET_TOKEN('PARTY_ID', TO_CHAR(DUP.DUP_PARTY_ID));
1146: FND_MSG_PUB.ADD;
1147: RAISE FND_API.G_EXC_ERROR;
1148: ELSE
1149: insert_match_details (l_search_ctx_id, p_dup_set_id, DUP.DUP_PARTY_ID);
1150: END IF;
1151: END LOOP;
1151: END LOOP;
1152: END IF;
1153:
1154: EXCEPTION
1155: WHEN FND_API.G_EXC_ERROR THEN
1156: x_return_status := FND_API.G_RET_STS_ERROR;
1157: FND_MSG_PUB.Count_And_Get(
1158: p_encoded => FND_API.G_FALSE,
1159: p_count => x_msg_count,
1152: END IF;
1153:
1154: EXCEPTION
1155: WHEN FND_API.G_EXC_ERROR THEN
1156: x_return_status := FND_API.G_RET_STS_ERROR;
1157: FND_MSG_PUB.Count_And_Get(
1158: p_encoded => FND_API.G_FALSE,
1159: p_count => x_msg_count,
1160: p_data => x_msg_data);
1154: EXCEPTION
1155: WHEN FND_API.G_EXC_ERROR THEN
1156: x_return_status := FND_API.G_RET_STS_ERROR;
1157: FND_MSG_PUB.Count_And_Get(
1158: p_encoded => FND_API.G_FALSE,
1159: p_count => x_msg_count,
1160: p_data => x_msg_data);
1161: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
1162: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
1157: FND_MSG_PUB.Count_And_Get(
1158: p_encoded => FND_API.G_FALSE,
1159: p_count => x_msg_count,
1160: p_data => x_msg_data);
1161: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
1162: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
1163: FND_MSG_PUB.Count_And_Get(
1164: p_encoded => FND_API.G_FALSE,
1165: p_count => x_msg_count,
1158: p_encoded => FND_API.G_FALSE,
1159: p_count => x_msg_count,
1160: p_data => x_msg_data);
1161: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
1162: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
1163: FND_MSG_PUB.Count_And_Get(
1164: p_encoded => FND_API.G_FALSE,
1165: p_count => x_msg_count,
1166: p_data => x_msg_data);
1160: p_data => x_msg_data);
1161: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
1162: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
1163: FND_MSG_PUB.Count_And_Get(
1164: p_encoded => FND_API.G_FALSE,
1165: p_count => x_msg_count,
1166: p_data => x_msg_data);
1167: WHEN OTHERS THEN
1168: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
1164: p_encoded => FND_API.G_FALSE,
1165: p_count => x_msg_count,
1166: p_data => x_msg_data);
1167: WHEN OTHERS THEN
1168: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
1169: FND_MESSAGE.SET_NAME('AR', 'HZ_DQM_SQL_EXCEP');
1170: FND_MESSAGE.SET_TOKEN('ERROR' ,SQLERRM);
1171: FND_MSG_PUB.ADD;
1172:
1170: FND_MESSAGE.SET_TOKEN('ERROR' ,SQLERRM);
1171: FND_MSG_PUB.ADD;
1172:
1173: FND_MSG_PUB.Count_And_Get(
1174: p_encoded => FND_API.G_FALSE,
1175: p_count => x_msg_count,
1176: p_data => x_msg_data);
1177: END;
1178:
1233: BEGIN
1234: FND_MSG_PUB.Reset;
1235:
1236: FOR I IN 1..FND_MSG_PUB.Count_Msg LOOP
1237: log(FND_MSG_PUB.Get(p_encoded => FND_API.G_FALSE ));
1238: END LOOP;
1239: FND_MSG_PUB.Delete_Msg;
1240: END logerror;
1241:
1244: BEGIN
1245: FND_MSG_PUB.Reset;
1246:
1247: FOR I IN 1..FND_MSG_PUB.Count_Msg LOOP
1248: l_msg_data := l_msg_data || ' ' || FND_MSG_PUB.Get(p_encoded => FND_API.G_FALSE );
1249: END LOOP;
1250: log(l_msg_data);
1251: RETURN l_msg_data;
1252: