685: x_insert_threshold number := 55;
686: l_party_limit NUMBER := 50000;
687: l_detail_limit NUMBER := 100000;
688: BEGIN
689: FND_FILE.put_line(FND_FILE.log,'Start time of insert of Parties '||to_char(sysdate,'hh24:mi:ss'));
690: insert into hz_dup_results(fid, tid, ord_fid, ord_tid, score)
691: select f, t, least(f,t), greatest(f,t), sum(score) score from (
692: select /*+ ORDERED */ s1.party_id f, s2.party_id t,
693: -------PARTY ENTITY: SCORING SECTION ---------
783: group by f, t
784: having sum(score) >= x_insert_threshold
785: ;
786: inserted_duplicates := (SQL%ROWCOUNT);
787: FND_FILE.put_line(FND_FILE.log,'Number of parties inserted '||SQL%ROWCOUNT);
788: FND_FILE.put_line(FND_FILE.log,'End time of insert '||to_char(sysdate,'hh24:mi:ss'));
789: FND_CONCURRENT.AF_Commit;
790:
791:
784: having sum(score) >= x_insert_threshold
785: ;
786: inserted_duplicates := (SQL%ROWCOUNT);
787: FND_FILE.put_line(FND_FILE.log,'Number of parties inserted '||SQL%ROWCOUNT);
788: FND_FILE.put_line(FND_FILE.log,'End time of insert '||to_char(sysdate,'hh24:mi:ss'));
789: FND_CONCURRENT.AF_Commit;
790:
791:
792: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
788: FND_FILE.put_line(FND_FILE.log,'End time of insert '||to_char(sysdate,'hh24:mi:ss'));
789: FND_CONCURRENT.AF_Commit;
790:
791:
792: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
793: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACT_POINTS');
794: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
795: open x_ent_cur for
796: select f, t, max(score) score from (
789: FND_CONCURRENT.AF_Commit;
790:
791:
792: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
793: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACT_POINTS');
794: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
795: open x_ent_cur for
796: select f, t, max(score) score from (
797: select /*+ ORDERED */ s1.party_id f, s2.party_id t,
790:
791:
792: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
793: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACT_POINTS');
794: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
795: open x_ent_cur for
796: select f, t, max(score) score from (
797: select /*+ ORDERED */ s1.party_id f, s2.party_id t,
798: decode(instrb(s2.TX7,s1.TX7),1,20,
821: )
822: ) group by f,t ;
823: HZ_DQM_DUP_ID_PKG.update_hz_dup_results(x_ent_cur);
824: close x_ent_cur;
825: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
826: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
827: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACT_POINTS');
828: FND_CONCURRENT.AF_Commit;
829:
822: ) group by f,t ;
823: HZ_DQM_DUP_ID_PKG.update_hz_dup_results(x_ent_cur);
824: close x_ent_cur;
825: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
826: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
827: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACT_POINTS');
828: FND_CONCURRENT.AF_Commit;
829:
830:
823: HZ_DQM_DUP_ID_PKG.update_hz_dup_results(x_ent_cur);
824: close x_ent_cur;
825: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
826: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
827: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACT_POINTS');
828: FND_CONCURRENT.AF_Commit;
829:
830:
831: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
827: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACT_POINTS');
828: FND_CONCURRENT.AF_Commit;
829:
830:
831: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
832: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACTS');
833: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
834: open x_ent_cur for
835: select f, t, max(score) score from (
828: FND_CONCURRENT.AF_Commit;
829:
830:
831: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
832: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACTS');
833: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
834: open x_ent_cur for
835: select f, t, max(score) score from (
836: select /*+ ORDERED */ s1.party_id f, s2.party_id t,
829:
830:
831: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
832: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACTS');
833: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
834: open x_ent_cur for
835: select f, t, max(score) score from (
836: select /*+ ORDERED */ s1.party_id f, s2.party_id t,
837: decode(instrb(s2.TX2,s1.TX2),1,20,
855: )
856: ) group by f,t ;
857: HZ_DQM_DUP_ID_PKG.update_hz_dup_results(x_ent_cur);
858: close x_ent_cur;
859: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
860: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
861: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACTS');
862: FND_CONCURRENT.AF_Commit;
863:
856: ) group by f,t ;
857: HZ_DQM_DUP_ID_PKG.update_hz_dup_results(x_ent_cur);
858: close x_ent_cur;
859: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
860: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
861: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACTS');
862: FND_CONCURRENT.AF_Commit;
863:
864:
857: HZ_DQM_DUP_ID_PKG.update_hz_dup_results(x_ent_cur);
858: close x_ent_cur;
859: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
860: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
861: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACTS');
862: FND_CONCURRENT.AF_Commit;
863:
864:
865: ---------- exception block ---------------
888: IS
889: x_ent_cur HZ_DQM_DUP_ID_PKG.EntityCur;
890: x_insert_threshold number := 55;
891: BEGIN
892: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
893: FND_FILE.put_line(FND_FILE.log,'WU: '||from_osr||' to '||to_osr);
894: FND_FILE.put_line(FND_FILE.log,'Start time of insert of Parties '||to_char(sysdate,'hh24:mi:ss'));
895: insert into hz_imp_dup_parties(party_id,dup_party_id, score, party_osr, party_os, batch_id, auto_merge_flag
896: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
889: x_ent_cur HZ_DQM_DUP_ID_PKG.EntityCur;
890: x_insert_threshold number := 55;
891: BEGIN
892: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
893: FND_FILE.put_line(FND_FILE.log,'WU: '||from_osr||' to '||to_osr);
894: FND_FILE.put_line(FND_FILE.log,'Start time of insert of Parties '||to_char(sysdate,'hh24:mi:ss'));
895: insert into hz_imp_dup_parties(party_id,dup_party_id, score, party_osr, party_os, batch_id, auto_merge_flag
896: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
897: select f, t, sum(score) sc, party_osr, party_os, p_batch_id, 'N'
890: x_insert_threshold number := 55;
891: BEGIN
892: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
893: FND_FILE.put_line(FND_FILE.log,'WU: '||from_osr||' to '||to_osr);
894: FND_FILE.put_line(FND_FILE.log,'Start time of insert of Parties '||to_char(sysdate,'hh24:mi:ss'));
895: insert into hz_imp_dup_parties(party_id,dup_party_id, score, party_osr, party_os, batch_id, auto_merge_flag
896: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
897: select f, t, sum(score) sc, party_osr, party_os, p_batch_id, 'N'
898: ,hz_utility_v2pub.created_by,hz_utility_v2pub.creation_date,hz_utility_v2pub.last_update_login
987: )
988: group by f, t, party_osr, party_os
989: having sum(score) >= x_insert_threshold
990: ;
991: FND_FILE.put_line(FND_FILE.log,'Number of parties inserted '||SQL%ROWCOUNT);
992: FND_FILE.put_line(FND_FILE.log,'End time of insert '||to_char(sysdate,'hh24:mi:ss'));
993:
994:
995: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
988: group by f, t, party_osr, party_os
989: having sum(score) >= x_insert_threshold
990: ;
991: FND_FILE.put_line(FND_FILE.log,'Number of parties inserted '||SQL%ROWCOUNT);
992: FND_FILE.put_line(FND_FILE.log,'End time of insert '||to_char(sysdate,'hh24:mi:ss'));
993:
994:
995: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
996: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACT_POINTS');
991: FND_FILE.put_line(FND_FILE.log,'Number of parties inserted '||SQL%ROWCOUNT);
992: FND_FILE.put_line(FND_FILE.log,'End time of insert '||to_char(sysdate,'hh24:mi:ss'));
993:
994:
995: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
996: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACT_POINTS');
997: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
998: open x_ent_cur for
999: select f,t,max(score) from (
992: FND_FILE.put_line(FND_FILE.log,'End time of insert '||to_char(sysdate,'hh24:mi:ss'));
993:
994:
995: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
996: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACT_POINTS');
997: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
998: open x_ent_cur for
999: select f,t,max(score) from (
1000: select /*+ USE_CONCAT */ s1.party_id f, s2.party_id t,
993:
994:
995: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
996: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACT_POINTS');
997: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
998: open x_ent_cur for
999: select f,t,max(score) from (
1000: select /*+ USE_CONCAT */ s1.party_id f, s2.party_id t,
1001: decode(instrb(s2.TX7,s1.TX7),1,20,
1025: )
1026: ) group by f,t ;
1027: HZ_DQM_DUP_ID_PKG.update_hz_imp_dup_parties(p_batch_id, x_ent_cur);
1028: close x_ent_cur;
1029: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
1030: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1031: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACT_POINTS');
1032:
1033:
1026: ) group by f,t ;
1027: HZ_DQM_DUP_ID_PKG.update_hz_imp_dup_parties(p_batch_id, x_ent_cur);
1028: close x_ent_cur;
1029: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
1030: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1031: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACT_POINTS');
1032:
1033:
1034: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1027: HZ_DQM_DUP_ID_PKG.update_hz_imp_dup_parties(p_batch_id, x_ent_cur);
1028: close x_ent_cur;
1029: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
1030: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1031: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACT_POINTS');
1032:
1033:
1034: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1035: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACTS');
1030: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1031: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACT_POINTS');
1032:
1033:
1034: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1035: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACTS');
1036: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
1037: open x_ent_cur for
1038: select f,t,max(score) from (
1031: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACT_POINTS');
1032:
1033:
1034: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1035: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACTS');
1036: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
1037: open x_ent_cur for
1038: select f,t,max(score) from (
1039: select /*+ USE_CONCAT */ s1.party_id f, s2.party_id t,
1032:
1033:
1034: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1035: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACTS');
1036: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
1037: open x_ent_cur for
1038: select f,t,max(score) from (
1039: select /*+ USE_CONCAT */ s1.party_id f, s2.party_id t,
1040: decode(instrb(s2.TX2,s1.TX2),1,20,
1059: )
1060: ) group by f,t ;
1061: HZ_DQM_DUP_ID_PKG.update_hz_imp_dup_parties(p_batch_id, x_ent_cur);
1062: close x_ent_cur;
1063: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
1064: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1065: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACTS');
1066:
1067: --------DELETE ON THRESHOLD AND REMOVE INDIRECT TRANSITIVITY ---------------------
1060: ) group by f,t ;
1061: HZ_DQM_DUP_ID_PKG.update_hz_imp_dup_parties(p_batch_id, x_ent_cur);
1062: close x_ent_cur;
1063: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
1064: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1065: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACTS');
1066:
1067: --------DELETE ON THRESHOLD AND REMOVE INDIRECT TRANSITIVITY ---------------------
1068:
1061: HZ_DQM_DUP_ID_PKG.update_hz_imp_dup_parties(p_batch_id, x_ent_cur);
1062: close x_ent_cur;
1063: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
1064: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1065: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACTS');
1066:
1067: --------DELETE ON THRESHOLD AND REMOVE INDIRECT TRANSITIVITY ---------------------
1068:
1069: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1065: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACTS');
1066:
1067: --------DELETE ON THRESHOLD AND REMOVE INDIRECT TRANSITIVITY ---------------------
1068:
1069: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1070: FND_FILE.put_line(FND_FILE.log,'DELETE ON THRESHOLD AND INDIRECT TRANSITIVITY ');
1071: FND_FILE.put_line(FND_FILE.log,'Begin time to delete '||to_char(sysdate,'hh24:mi:ss'));
1072:
1073: delete from hz_imp_dup_parties a
1066:
1067: --------DELETE ON THRESHOLD AND REMOVE INDIRECT TRANSITIVITY ---------------------
1068:
1069: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1070: FND_FILE.put_line(FND_FILE.log,'DELETE ON THRESHOLD AND INDIRECT TRANSITIVITY ');
1071: FND_FILE.put_line(FND_FILE.log,'Begin time to delete '||to_char(sysdate,'hh24:mi:ss'));
1072:
1073: delete from hz_imp_dup_parties a
1074: where (a.party_osr >= from_osr and a.party_osr <= to_osr
1067: --------DELETE ON THRESHOLD AND REMOVE INDIRECT TRANSITIVITY ---------------------
1068:
1069: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1070: FND_FILE.put_line(FND_FILE.log,'DELETE ON THRESHOLD AND INDIRECT TRANSITIVITY ');
1071: FND_FILE.put_line(FND_FILE.log,'Begin time to delete '||to_char(sysdate,'hh24:mi:ss'));
1072:
1073: delete from hz_imp_dup_parties a
1074: where (a.party_osr >= from_osr and a.party_osr <= to_osr
1075: and a.batch_id = p_batch_id)
1086: (Select 1 from hz_imp_dup_parties b
1087: where b.batch_id=p_batch_id and a.party_id=b.party_id and a.score < b.score)
1088: );
1089:
1090: FND_FILE.put_line(FND_FILE.log,'Number of records deleted from hz_imp_dup_parties '||SQL%ROWCOUNT);
1091: FND_FILE.put_line(FND_FILE.log,'End time to delete '||to_char(sysdate,'hh24:mi:ss'));
1092: --------UPDATE AUTO MERGE FLAG --------------
1093: update hz_imp_dup_parties a
1094: set a.auto_merge_flag = 'Y'
1087: where b.batch_id=p_batch_id and a.party_id=b.party_id and a.score < b.score)
1088: );
1089:
1090: FND_FILE.put_line(FND_FILE.log,'Number of records deleted from hz_imp_dup_parties '||SQL%ROWCOUNT);
1091: FND_FILE.put_line(FND_FILE.log,'End time to delete '||to_char(sysdate,'hh24:mi:ss'));
1092: --------UPDATE AUTO MERGE FLAG --------------
1093: update hz_imp_dup_parties a
1094: set a.auto_merge_flag = 'Y'
1095: where a.score >= p_auto_merge_threshold
1106: ----------------------PARTY LEVEL DUPLICATE IDENTIFICATION ENDS --------------------
1107:
1108:
1109: -------------PARTY_SITES LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1110: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1111: FND_FILE.put_line(FND_FILE.log,'Beginning insert of PARTY_SITES');
1112: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1113: insert into hz_imp_dup_details(party_id, score, party_osr, party_os, batch_id, entity, record_id, record_osr, record_os, dup_record_id
1114: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
1107:
1108:
1109: -------------PARTY_SITES LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1110: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1111: FND_FILE.put_line(FND_FILE.log,'Beginning insert of PARTY_SITES');
1112: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1113: insert into hz_imp_dup_details(party_id, score, party_osr, party_os, batch_id, entity, record_id, record_osr, record_os, dup_record_id
1114: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
1115: select /*+ USE_CONCAT */ s1.party_id f,
1108:
1109: -------------PARTY_SITES LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1110: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1111: FND_FILE.put_line(FND_FILE.log,'Beginning insert of PARTY_SITES');
1112: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1113: insert into hz_imp_dup_details(party_id, score, party_osr, party_os, batch_id, entity, record_id, record_osr, record_os, dup_record_id
1114: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
1115: select /*+ USE_CONCAT */ s1.party_id f,
1116: decode(instrb(s2.TX26,s1.TX26),1,100,
1158: where a.batch_id = p_batch_id
1159: and a.party_osr between from_osr and to_osr and a.entity ='PARTY_SITES';
1160: HZ_DQM_DUP_ID_PKG.update_detail_dqm_action_flag('PARTY_SITES',p_batch_id, x_ent_cur);
1161: -------------PARTY_SITES LEVEL DUPLICATE IDENTIFICATION ENDS ------------------------
1162: FND_FILE.put_line(FND_FILE.log,'Ending insert of PARTY_SITES');
1163: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1164: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1165:
1166:
1159: and a.party_osr between from_osr and to_osr and a.entity ='PARTY_SITES';
1160: HZ_DQM_DUP_ID_PKG.update_detail_dqm_action_flag('PARTY_SITES',p_batch_id, x_ent_cur);
1161: -------------PARTY_SITES LEVEL DUPLICATE IDENTIFICATION ENDS ------------------------
1162: FND_FILE.put_line(FND_FILE.log,'Ending insert of PARTY_SITES');
1163: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1164: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1165:
1166:
1167:
1160: HZ_DQM_DUP_ID_PKG.update_detail_dqm_action_flag('PARTY_SITES',p_batch_id, x_ent_cur);
1161: -------------PARTY_SITES LEVEL DUPLICATE IDENTIFICATION ENDS ------------------------
1162: FND_FILE.put_line(FND_FILE.log,'Ending insert of PARTY_SITES');
1163: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1164: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1165:
1166:
1167:
1168: -------------CONTACT_POINTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1165:
1166:
1167:
1168: -------------CONTACT_POINTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1169: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1170: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACT_POINTS');
1171: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1172: insert into hz_imp_dup_details(party_id, score, party_osr, party_os, batch_id, entity, record_id, record_osr, record_os, dup_record_id
1173: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
1166:
1167:
1168: -------------CONTACT_POINTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1169: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1170: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACT_POINTS');
1171: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1172: insert into hz_imp_dup_details(party_id, score, party_osr, party_os, batch_id, entity, record_id, record_osr, record_os, dup_record_id
1173: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
1174: select /*+ USE_CONCAT */ s1.party_id f,
1167:
1168: -------------CONTACT_POINTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1169: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1170: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACT_POINTS');
1171: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1172: insert into hz_imp_dup_details(party_id, score, party_osr, party_os, batch_id, entity, record_id, record_osr, record_os, dup_record_id
1173: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
1174: select /*+ USE_CONCAT */ s1.party_id f,
1175: decode(instrb(s2.TX7,s1.TX7),1,20,
1210: where a.batch_id = p_batch_id
1211: and a.party_osr between from_osr and to_osr and a.entity ='CONTACT_POINTS';
1212: HZ_DQM_DUP_ID_PKG.update_detail_dqm_action_flag('CONTACT_POINTS',p_batch_id, x_ent_cur);
1213: -------------CONTACT_POINTS LEVEL DUPLICATE IDENTIFICATION ENDS ------------------------
1214: FND_FILE.put_line(FND_FILE.log,'Ending insert of CONTACT_POINTS');
1215: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1216: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1217:
1218:
1211: and a.party_osr between from_osr and to_osr and a.entity ='CONTACT_POINTS';
1212: HZ_DQM_DUP_ID_PKG.update_detail_dqm_action_flag('CONTACT_POINTS',p_batch_id, x_ent_cur);
1213: -------------CONTACT_POINTS LEVEL DUPLICATE IDENTIFICATION ENDS ------------------------
1214: FND_FILE.put_line(FND_FILE.log,'Ending insert of CONTACT_POINTS');
1215: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1216: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1217:
1218:
1219:
1212: HZ_DQM_DUP_ID_PKG.update_detail_dqm_action_flag('CONTACT_POINTS',p_batch_id, x_ent_cur);
1213: -------------CONTACT_POINTS LEVEL DUPLICATE IDENTIFICATION ENDS ------------------------
1214: FND_FILE.put_line(FND_FILE.log,'Ending insert of CONTACT_POINTS');
1215: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1216: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1217:
1218:
1219:
1220: -------------CONTACTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1217:
1218:
1219:
1220: -------------CONTACTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1221: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1222: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACTS');
1223: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1224: insert into hz_imp_dup_details(party_id, score, party_osr, party_os, batch_id, entity, record_id, record_osr, record_os, dup_record_id
1225: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
1218:
1219:
1220: -------------CONTACTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1221: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1222: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACTS');
1223: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1224: insert into hz_imp_dup_details(party_id, score, party_osr, party_os, batch_id, entity, record_id, record_osr, record_os, dup_record_id
1225: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
1226: select /*+ USE_CONCAT */ s1.party_id f,
1219:
1220: -------------CONTACTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1221: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1222: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACTS');
1223: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1224: insert into hz_imp_dup_details(party_id, score, party_osr, party_os, batch_id, entity, record_id, record_osr, record_os, dup_record_id
1225: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
1226: select /*+ USE_CONCAT */ s1.party_id f,
1227: decode(instrb(s2.TX2,s1.TX2),1,20,
1257: where a.batch_id = p_batch_id
1258: and a.party_osr between from_osr and to_osr and a.entity ='CONTACTS';
1259: HZ_DQM_DUP_ID_PKG.update_detail_dqm_action_flag('CONTACTS',p_batch_id, x_ent_cur);
1260: -------------CONTACTS LEVEL DUPLICATE IDENTIFICATION ENDS ------------------------
1261: FND_FILE.put_line(FND_FILE.log,'Ending insert of CONTACTS');
1262: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1263: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1264:
1265:
1258: and a.party_osr between from_osr and to_osr and a.entity ='CONTACTS';
1259: HZ_DQM_DUP_ID_PKG.update_detail_dqm_action_flag('CONTACTS',p_batch_id, x_ent_cur);
1260: -------------CONTACTS LEVEL DUPLICATE IDENTIFICATION ENDS ------------------------
1261: FND_FILE.put_line(FND_FILE.log,'Ending insert of CONTACTS');
1262: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1263: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1264:
1265:
1266:
1259: HZ_DQM_DUP_ID_PKG.update_detail_dqm_action_flag('CONTACTS',p_batch_id, x_ent_cur);
1260: -------------CONTACTS LEVEL DUPLICATE IDENTIFICATION ENDS ------------------------
1261: FND_FILE.put_line(FND_FILE.log,'Ending insert of CONTACTS');
1262: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1263: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1264:
1265:
1266:
1267: ---------- exception block ---------------
1285: IS
1286: x_ent_cur HZ_DQM_DUP_ID_PKG.EntityCur;
1287: x_insert_threshold number := 55;
1288: BEGIN
1289: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1290: FND_FILE.put_line(FND_FILE.log,'WU: '||from_osr||' to '||to_osr);
1291: FND_FILE.put_line(FND_FILE.log,'Start time of insert of Parties '||to_char(sysdate,'hh24:mi:ss'));
1292: insert into hz_int_dup_results(batch_id, f_osr,t_osr,ord_f_osr,ord_t_osr,score,f_os, t_os)
1293: select p_batch_id, f, t, least(f,t), greatest(f,t), sum(score) score, fos, tos from (
1286: x_ent_cur HZ_DQM_DUP_ID_PKG.EntityCur;
1287: x_insert_threshold number := 55;
1288: BEGIN
1289: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1290: FND_FILE.put_line(FND_FILE.log,'WU: '||from_osr||' to '||to_osr);
1291: FND_FILE.put_line(FND_FILE.log,'Start time of insert of Parties '||to_char(sysdate,'hh24:mi:ss'));
1292: insert into hz_int_dup_results(batch_id, f_osr,t_osr,ord_f_osr,ord_t_osr,score,f_os, t_os)
1293: select p_batch_id, f, t, least(f,t), greatest(f,t), sum(score) score, fos, tos from (
1294: ------------------ PARTY LEVEL DUPLICATE IDENTIFICATION BEGINS --------------------
1287: x_insert_threshold number := 55;
1288: BEGIN
1289: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1290: FND_FILE.put_line(FND_FILE.log,'WU: '||from_osr||' to '||to_osr);
1291: FND_FILE.put_line(FND_FILE.log,'Start time of insert of Parties '||to_char(sysdate,'hh24:mi:ss'));
1292: insert into hz_int_dup_results(batch_id, f_osr,t_osr,ord_f_osr,ord_t_osr,score,f_os, t_os)
1293: select p_batch_id, f, t, least(f,t), greatest(f,t), sum(score) score, fos, tos from (
1294: ------------------ PARTY LEVEL DUPLICATE IDENTIFICATION BEGINS --------------------
1295: select /*+ USE_CONCAT */ s1.party_osr f, s2.party_osr t,
1380: )
1381: group by f, t, fos, tos
1382: having sum(score) >= x_insert_threshold
1383: ;
1384: FND_FILE.put_line(FND_FILE.log,'Number of parties inserted '||SQL%ROWCOUNT);
1385: FND_FILE.put_line(FND_FILE.log,'End time of insert '||to_char(sysdate,'hh24:mi:ss'));
1386: FND_CONCURRENT.AF_Commit;
1387:
1388:
1381: group by f, t, fos, tos
1382: having sum(score) >= x_insert_threshold
1383: ;
1384: FND_FILE.put_line(FND_FILE.log,'Number of parties inserted '||SQL%ROWCOUNT);
1385: FND_FILE.put_line(FND_FILE.log,'End time of insert '||to_char(sysdate,'hh24:mi:ss'));
1386: FND_CONCURRENT.AF_Commit;
1387:
1388:
1389: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1385: FND_FILE.put_line(FND_FILE.log,'End time of insert '||to_char(sysdate,'hh24:mi:ss'));
1386: FND_CONCURRENT.AF_Commit;
1387:
1388:
1389: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1390: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACT_POINTS');
1391: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
1392: open x_ent_cur for
1393: select f,t,max(score) from (
1386: FND_CONCURRENT.AF_Commit;
1387:
1388:
1389: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1390: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACT_POINTS');
1391: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
1392: open x_ent_cur for
1393: select f,t,max(score) from (
1394: select /*+ USE_CONCAT */ s1.party_osr f, s2.party_osr t,
1387:
1388:
1389: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1390: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACT_POINTS');
1391: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
1392: open x_ent_cur for
1393: select f,t,max(score) from (
1394: select /*+ USE_CONCAT */ s1.party_osr f, s2.party_osr t,
1395: decode(instrb(s2.TX7,s1.TX7),1,20,
1421: )
1422: ) group by f,t ;
1423: HZ_DQM_DUP_ID_PKG.update_hz_int_dup_results(p_batch_id,x_ent_cur);
1424: close x_ent_cur;
1425: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
1426: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1427: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACT_POINTS');
1428: FND_CONCURRENT.AF_Commit;
1429:
1422: ) group by f,t ;
1423: HZ_DQM_DUP_ID_PKG.update_hz_int_dup_results(p_batch_id,x_ent_cur);
1424: close x_ent_cur;
1425: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
1426: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1427: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACT_POINTS');
1428: FND_CONCURRENT.AF_Commit;
1429:
1430:
1423: HZ_DQM_DUP_ID_PKG.update_hz_int_dup_results(p_batch_id,x_ent_cur);
1424: close x_ent_cur;
1425: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
1426: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1427: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACT_POINTS');
1428: FND_CONCURRENT.AF_Commit;
1429:
1430:
1431: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1427: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACT_POINTS');
1428: FND_CONCURRENT.AF_Commit;
1429:
1430:
1431: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1432: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACTS');
1433: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
1434: open x_ent_cur for
1435: select f,t,max(score) from (
1428: FND_CONCURRENT.AF_Commit;
1429:
1430:
1431: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1432: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACTS');
1433: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
1434: open x_ent_cur for
1435: select f,t,max(score) from (
1436: select /*+ USE_CONCAT */ s1.party_osr f, s2.party_osr t,
1429:
1430:
1431: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1432: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACTS');
1433: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
1434: open x_ent_cur for
1435: select f,t,max(score) from (
1436: select /*+ USE_CONCAT */ s1.party_osr f, s2.party_osr t,
1437: decode(instrb(s2.TX2,s1.TX2),1,20,
1457: )
1458: ) group by f,t ;
1459: HZ_DQM_DUP_ID_PKG.update_hz_int_dup_results(p_batch_id,x_ent_cur);
1460: close x_ent_cur;
1461: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
1462: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1463: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACTS');
1464: FND_CONCURRENT.AF_Commit;
1465: -------------PARTY_SITES LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1458: ) group by f,t ;
1459: HZ_DQM_DUP_ID_PKG.update_hz_int_dup_results(p_batch_id,x_ent_cur);
1460: close x_ent_cur;
1461: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
1462: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1463: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACTS');
1464: FND_CONCURRENT.AF_Commit;
1465: -------------PARTY_SITES LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1466: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1459: HZ_DQM_DUP_ID_PKG.update_hz_int_dup_results(p_batch_id,x_ent_cur);
1460: close x_ent_cur;
1461: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
1462: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1463: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACTS');
1464: FND_CONCURRENT.AF_Commit;
1465: -------------PARTY_SITES LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1466: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1467: FND_FILE.put_line(FND_FILE.log,'Beginning insert of PARTY_SITES');
1462: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1463: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACTS');
1464: FND_CONCURRENT.AF_Commit;
1465: -------------PARTY_SITES LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1466: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1467: FND_FILE.put_line(FND_FILE.log,'Beginning insert of PARTY_SITES');
1468: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1469: insert into hz_imp_int_dedup_results(batch_id, winner_record_osr, winner_record_os,
1470: dup_record_osr, dup_record_os, detail_party_osr, detail_party_os, entity, score,
1463: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACTS');
1464: FND_CONCURRENT.AF_Commit;
1465: -------------PARTY_SITES LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1466: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1467: FND_FILE.put_line(FND_FILE.log,'Beginning insert of PARTY_SITES');
1468: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1469: insert into hz_imp_int_dedup_results(batch_id, winner_record_osr, winner_record_os,
1470: dup_record_osr, dup_record_os, detail_party_osr, detail_party_os, entity, score,
1471: dup_creation_date,dup_last_update_date
1464: FND_CONCURRENT.AF_Commit;
1465: -------------PARTY_SITES LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1466: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1467: FND_FILE.put_line(FND_FILE.log,'Beginning insert of PARTY_SITES');
1468: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1469: insert into hz_imp_int_dedup_results(batch_id, winner_record_osr, winner_record_os,
1470: dup_record_osr, dup_record_os, detail_party_osr, detail_party_os, entity, score,
1471: dup_creation_date,dup_last_update_date
1472: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
1508: (
1509: ((s1.TX11 is null and s2.TX11 is null) or s2.TX11 = s1.TX11)
1510: )
1511: ;
1512: FND_FILE.put_line(FND_FILE.log,'Ending insert of PARTY_SITES');
1513: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1514: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1515: FND_CONCURRENT.AF_Commit;
1516: -------------CONTACT_POINTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1509: ((s1.TX11 is null and s2.TX11 is null) or s2.TX11 = s1.TX11)
1510: )
1511: ;
1512: FND_FILE.put_line(FND_FILE.log,'Ending insert of PARTY_SITES');
1513: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1514: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1515: FND_CONCURRENT.AF_Commit;
1516: -------------CONTACT_POINTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1517: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1510: )
1511: ;
1512: FND_FILE.put_line(FND_FILE.log,'Ending insert of PARTY_SITES');
1513: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1514: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1515: FND_CONCURRENT.AF_Commit;
1516: -------------CONTACT_POINTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1517: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1518: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACT_POINTS');
1513: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1514: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1515: FND_CONCURRENT.AF_Commit;
1516: -------------CONTACT_POINTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1517: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1518: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACT_POINTS');
1519: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1520: insert into hz_imp_int_dedup_results(batch_id, winner_record_osr, winner_record_os,
1521: dup_record_osr, dup_record_os, detail_party_osr, detail_party_os, entity, score,
1514: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1515: FND_CONCURRENT.AF_Commit;
1516: -------------CONTACT_POINTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1517: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1518: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACT_POINTS');
1519: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1520: insert into hz_imp_int_dedup_results(batch_id, winner_record_osr, winner_record_os,
1521: dup_record_osr, dup_record_os, detail_party_osr, detail_party_os, entity, score,
1522: dup_creation_date,dup_last_update_date
1515: FND_CONCURRENT.AF_Commit;
1516: -------------CONTACT_POINTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1517: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1518: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACT_POINTS');
1519: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1520: insert into hz_imp_int_dedup_results(batch_id, winner_record_osr, winner_record_os,
1521: dup_record_osr, dup_record_os, detail_party_osr, detail_party_os, entity, score,
1522: dup_creation_date,dup_last_update_date
1523: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
1553: (s1.TX158 is not null and s2.TX158 like s1.TX158 || decode(sign(lengthb(s1.TX158)-3),1,'%',''))
1554: )
1555: )
1556: ;
1557: FND_FILE.put_line(FND_FILE.log,'Ending insert of CONTACT_POINTS');
1558: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1559: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1560: FND_CONCURRENT.AF_Commit;
1561: -------------CONTACTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1554: )
1555: )
1556: ;
1557: FND_FILE.put_line(FND_FILE.log,'Ending insert of CONTACT_POINTS');
1558: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1559: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1560: FND_CONCURRENT.AF_Commit;
1561: -------------CONTACTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1562: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1555: )
1556: ;
1557: FND_FILE.put_line(FND_FILE.log,'Ending insert of CONTACT_POINTS');
1558: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1559: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1560: FND_CONCURRENT.AF_Commit;
1561: -------------CONTACTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1562: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1563: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACTS');
1558: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1559: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1560: FND_CONCURRENT.AF_Commit;
1561: -------------CONTACTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1562: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1563: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACTS');
1564: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1565: insert into hz_imp_int_dedup_results(batch_id, winner_record_osr, winner_record_os,
1566: dup_record_osr, dup_record_os, detail_party_osr, detail_party_os, entity, score,
1559: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1560: FND_CONCURRENT.AF_Commit;
1561: -------------CONTACTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1562: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1563: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACTS');
1564: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1565: insert into hz_imp_int_dedup_results(batch_id, winner_record_osr, winner_record_os,
1566: dup_record_osr, dup_record_os, detail_party_osr, detail_party_os, entity, score,
1567: dup_creation_date,dup_last_update_date
1560: FND_CONCURRENT.AF_Commit;
1561: -------------CONTACTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1562: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1563: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACTS');
1564: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1565: insert into hz_imp_int_dedup_results(batch_id, winner_record_osr, winner_record_os,
1566: dup_record_osr, dup_record_os, detail_party_osr, detail_party_os, entity, score,
1567: dup_creation_date,dup_last_update_date
1568: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
1592: (s1.TX23 is not null and s2.TX23 like s1.TX23 || decode(sign(lengthb(s1.TX23)-3),1,'%',''))
1593: )
1594: )
1595: ;
1596: FND_FILE.put_line(FND_FILE.log,'Ending insert of CONTACTS');
1597: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1598: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1599: FND_CONCURRENT.AF_Commit;
1600:
1593: )
1594: )
1595: ;
1596: FND_FILE.put_line(FND_FILE.log,'Ending insert of CONTACTS');
1597: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1598: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1599: FND_CONCURRENT.AF_Commit;
1600:
1601: ---------- exception block ---------------
1594: )
1595: ;
1596: FND_FILE.put_line(FND_FILE.log,'Ending insert of CONTACTS');
1597: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1598: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1599: FND_CONCURRENT.AF_Commit;
1600:
1601: ---------- exception block ---------------
1602: EXCEPTION