686: x_insert_threshold number := 20;
687: l_party_limit NUMBER := 50000;
688: l_detail_limit NUMBER := 100000;
689: BEGIN
690: FND_FILE.put_line(FND_FILE.log,'Start time of insert of Parties '||to_char(sysdate,'hh24:mi:ss'));
691: insert into hz_dup_results(fid, tid, ord_fid, ord_tid, score)
692: select f, t, least(f,t), greatest(f,t), sum(score) score from (
693: select /*+ ORDERED */ s1.party_id f, s2.party_id t,
694: -------PARTY ENTITY: SCORING SECTION ---------
786: group by f, t
787: having sum(score) >= x_insert_threshold
788: ;
789: inserted_duplicates := (SQL%ROWCOUNT);
790: FND_FILE.put_line(FND_FILE.log,'Number of parties inserted '||SQL%ROWCOUNT);
791: FND_FILE.put_line(FND_FILE.log,'End time of insert '||to_char(sysdate,'hh24:mi:ss'));
792: FND_CONCURRENT.AF_Commit;
793:
794:
787: having sum(score) >= x_insert_threshold
788: ;
789: inserted_duplicates := (SQL%ROWCOUNT);
790: FND_FILE.put_line(FND_FILE.log,'Number of parties inserted '||SQL%ROWCOUNT);
791: FND_FILE.put_line(FND_FILE.log,'End time of insert '||to_char(sysdate,'hh24:mi:ss'));
792: FND_CONCURRENT.AF_Commit;
793:
794:
795: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
791: FND_FILE.put_line(FND_FILE.log,'End time of insert '||to_char(sysdate,'hh24:mi:ss'));
792: FND_CONCURRENT.AF_Commit;
793:
794:
795: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
796: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of PARTY_SITES');
797: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
798: open x_ent_cur for
799: select f, t, max(score) score from (
792: FND_CONCURRENT.AF_Commit;
793:
794:
795: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
796: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of PARTY_SITES');
797: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
798: open x_ent_cur for
799: select f, t, max(score) score from (
800: select /*+ ORDERED */ s1.party_id f, s2.party_id t,
793:
794:
795: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
796: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of PARTY_SITES');
797: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
798: open x_ent_cur for
799: select f, t, max(score) score from (
800: select /*+ ORDERED */ s1.party_id f, s2.party_id t,
801: decode(instrb(s2.TX26,s1.TX26),1,100,
831: )
832: ) group by f,t ;
833: HZ_DQM_DUP_ID_PKG.update_hz_dup_results(x_ent_cur);
834: close x_ent_cur;
835: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
836: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
837: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of PARTY_SITES');
838: FND_CONCURRENT.AF_Commit;
839:
832: ) group by f,t ;
833: HZ_DQM_DUP_ID_PKG.update_hz_dup_results(x_ent_cur);
834: close x_ent_cur;
835: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
836: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
837: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of PARTY_SITES');
838: FND_CONCURRENT.AF_Commit;
839:
840:
833: HZ_DQM_DUP_ID_PKG.update_hz_dup_results(x_ent_cur);
834: close x_ent_cur;
835: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
836: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
837: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of PARTY_SITES');
838: FND_CONCURRENT.AF_Commit;
839:
840:
841: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
837: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of PARTY_SITES');
838: FND_CONCURRENT.AF_Commit;
839:
840:
841: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
842: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACTS');
843: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
844: open x_ent_cur for
845: select f, t, max(score) score from (
838: FND_CONCURRENT.AF_Commit;
839:
840:
841: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
842: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACTS');
843: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
844: open x_ent_cur for
845: select f, t, max(score) score from (
846: select /*+ ORDERED */ s1.party_id f, s2.party_id t,
839:
840:
841: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
842: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACTS');
843: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
844: open x_ent_cur for
845: select f, t, max(score) score from (
846: select /*+ ORDERED */ s1.party_id f, s2.party_id t,
847: decode(instrb(s2.TX2,s1.TX2),1,20,
865: )
866: ) group by f,t ;
867: HZ_DQM_DUP_ID_PKG.update_hz_dup_results(x_ent_cur);
868: close x_ent_cur;
869: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
870: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
871: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACTS');
872: FND_CONCURRENT.AF_Commit;
873:
866: ) group by f,t ;
867: HZ_DQM_DUP_ID_PKG.update_hz_dup_results(x_ent_cur);
868: close x_ent_cur;
869: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
870: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
871: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACTS');
872: FND_CONCURRENT.AF_Commit;
873:
874:
867: HZ_DQM_DUP_ID_PKG.update_hz_dup_results(x_ent_cur);
868: close x_ent_cur;
869: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
870: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
871: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACTS');
872: FND_CONCURRENT.AF_Commit;
873:
874:
875: ---------- exception block ---------------
898: IS
899: x_ent_cur HZ_DQM_DUP_ID_PKG.EntityCur;
900: x_insert_threshold number := 20;
901: BEGIN
902: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
903: FND_FILE.put_line(FND_FILE.log,'WU: '||from_osr||' to '||to_osr);
904: FND_FILE.put_line(FND_FILE.log,'Start time of insert of Parties '||to_char(sysdate,'hh24:mi:ss'));
905: insert into hz_imp_dup_parties(party_id,dup_party_id, score, party_osr, party_os, batch_id, auto_merge_flag
906: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
899: x_ent_cur HZ_DQM_DUP_ID_PKG.EntityCur;
900: x_insert_threshold number := 20;
901: BEGIN
902: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
903: FND_FILE.put_line(FND_FILE.log,'WU: '||from_osr||' to '||to_osr);
904: FND_FILE.put_line(FND_FILE.log,'Start time of insert of Parties '||to_char(sysdate,'hh24:mi:ss'));
905: insert into hz_imp_dup_parties(party_id,dup_party_id, score, party_osr, party_os, batch_id, auto_merge_flag
906: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
907: select f, t, sum(score) sc, party_osr, party_os, p_batch_id, 'N'
900: x_insert_threshold number := 20;
901: BEGIN
902: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
903: FND_FILE.put_line(FND_FILE.log,'WU: '||from_osr||' to '||to_osr);
904: FND_FILE.put_line(FND_FILE.log,'Start time of insert of Parties '||to_char(sysdate,'hh24:mi:ss'));
905: insert into hz_imp_dup_parties(party_id,dup_party_id, score, party_osr, party_os, batch_id, auto_merge_flag
906: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
907: select f, t, sum(score) sc, party_osr, party_os, p_batch_id, 'N'
908: ,hz_utility_v2pub.created_by,hz_utility_v2pub.creation_date,hz_utility_v2pub.last_update_login
999: )
1000: group by f, t, party_osr, party_os
1001: having sum(score) >= x_insert_threshold
1002: ;
1003: FND_FILE.put_line(FND_FILE.log,'Number of parties inserted '||SQL%ROWCOUNT);
1004: FND_FILE.put_line(FND_FILE.log,'End time of insert '||to_char(sysdate,'hh24:mi:ss'));
1005:
1006:
1007: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1000: group by f, t, party_osr, party_os
1001: having sum(score) >= x_insert_threshold
1002: ;
1003: FND_FILE.put_line(FND_FILE.log,'Number of parties inserted '||SQL%ROWCOUNT);
1004: FND_FILE.put_line(FND_FILE.log,'End time of insert '||to_char(sysdate,'hh24:mi:ss'));
1005:
1006:
1007: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1008: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of PARTY_SITES');
1003: FND_FILE.put_line(FND_FILE.log,'Number of parties inserted '||SQL%ROWCOUNT);
1004: FND_FILE.put_line(FND_FILE.log,'End time of insert '||to_char(sysdate,'hh24:mi:ss'));
1005:
1006:
1007: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1008: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of PARTY_SITES');
1009: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
1010: open x_ent_cur for
1011: select f,t,max(score) from (
1004: FND_FILE.put_line(FND_FILE.log,'End time of insert '||to_char(sysdate,'hh24:mi:ss'));
1005:
1006:
1007: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1008: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of PARTY_SITES');
1009: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
1010: open x_ent_cur for
1011: select f,t,max(score) from (
1012: select /*+ USE_CONCAT */ s1.party_id f, s2.party_id t,
1005:
1006:
1007: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1008: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of PARTY_SITES');
1009: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
1010: open x_ent_cur for
1011: select f,t,max(score) from (
1012: select /*+ USE_CONCAT */ s1.party_id f, s2.party_id t,
1013: decode(instrb(s2.TX26,s1.TX26),1,100,
1044: )
1045: ) group by f,t ;
1046: HZ_DQM_DUP_ID_PKG.update_hz_imp_dup_parties(p_batch_id, x_ent_cur);
1047: close x_ent_cur;
1048: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
1049: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1050: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of PARTY_SITES');
1051:
1052:
1045: ) group by f,t ;
1046: HZ_DQM_DUP_ID_PKG.update_hz_imp_dup_parties(p_batch_id, x_ent_cur);
1047: close x_ent_cur;
1048: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
1049: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1050: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of PARTY_SITES');
1051:
1052:
1053: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1046: HZ_DQM_DUP_ID_PKG.update_hz_imp_dup_parties(p_batch_id, x_ent_cur);
1047: close x_ent_cur;
1048: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
1049: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1050: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of PARTY_SITES');
1051:
1052:
1053: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1054: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACTS');
1049: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1050: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of PARTY_SITES');
1051:
1052:
1053: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1054: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACTS');
1055: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
1056: open x_ent_cur for
1057: select f,t,max(score) from (
1050: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of PARTY_SITES');
1051:
1052:
1053: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1054: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACTS');
1055: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
1056: open x_ent_cur for
1057: select f,t,max(score) from (
1058: select /*+ USE_CONCAT */ s1.party_id f, s2.party_id t,
1051:
1052:
1053: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1054: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACTS');
1055: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
1056: open x_ent_cur for
1057: select f,t,max(score) from (
1058: select /*+ USE_CONCAT */ s1.party_id f, s2.party_id t,
1059: decode(instrb(s2.TX2,s1.TX2),1,20,
1078: )
1079: ) group by f,t ;
1080: HZ_DQM_DUP_ID_PKG.update_hz_imp_dup_parties(p_batch_id, x_ent_cur);
1081: close x_ent_cur;
1082: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
1083: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1084: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACTS');
1085:
1086: --------DELETE ON THRESHOLD AND REMOVE INDIRECT TRANSITIVITY ---------------------
1079: ) group by f,t ;
1080: HZ_DQM_DUP_ID_PKG.update_hz_imp_dup_parties(p_batch_id, x_ent_cur);
1081: close x_ent_cur;
1082: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
1083: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1084: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACTS');
1085:
1086: --------DELETE ON THRESHOLD AND REMOVE INDIRECT TRANSITIVITY ---------------------
1087:
1080: HZ_DQM_DUP_ID_PKG.update_hz_imp_dup_parties(p_batch_id, x_ent_cur);
1081: close x_ent_cur;
1082: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
1083: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1084: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACTS');
1085:
1086: --------DELETE ON THRESHOLD AND REMOVE INDIRECT TRANSITIVITY ---------------------
1087:
1088: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1084: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACTS');
1085:
1086: --------DELETE ON THRESHOLD AND REMOVE INDIRECT TRANSITIVITY ---------------------
1087:
1088: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1089: FND_FILE.put_line(FND_FILE.log,'DELETE ON THRESHOLD AND INDIRECT TRANSITIVITY ');
1090: FND_FILE.put_line(FND_FILE.log,'Begin time to delete '||to_char(sysdate,'hh24:mi:ss'));
1091:
1092: delete from hz_imp_dup_parties a
1085:
1086: --------DELETE ON THRESHOLD AND REMOVE INDIRECT TRANSITIVITY ---------------------
1087:
1088: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1089: FND_FILE.put_line(FND_FILE.log,'DELETE ON THRESHOLD AND INDIRECT TRANSITIVITY ');
1090: FND_FILE.put_line(FND_FILE.log,'Begin time to delete '||to_char(sysdate,'hh24:mi:ss'));
1091:
1092: delete from hz_imp_dup_parties a
1093: where (a.party_osr >= from_osr and a.party_osr <= to_osr
1086: --------DELETE ON THRESHOLD AND REMOVE INDIRECT TRANSITIVITY ---------------------
1087:
1088: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1089: FND_FILE.put_line(FND_FILE.log,'DELETE ON THRESHOLD AND INDIRECT TRANSITIVITY ');
1090: FND_FILE.put_line(FND_FILE.log,'Begin time to delete '||to_char(sysdate,'hh24:mi:ss'));
1091:
1092: delete from hz_imp_dup_parties a
1093: where (a.party_osr >= from_osr and a.party_osr <= to_osr
1094: and a.batch_id = p_batch_id)
1105: (Select 1 from hz_imp_dup_parties b
1106: where b.batch_id=p_batch_id and a.party_id=b.party_id and a.score < b.score)
1107: );
1108:
1109: FND_FILE.put_line(FND_FILE.log,'Number of records deleted from hz_imp_dup_parties '||SQL%ROWCOUNT);
1110: FND_FILE.put_line(FND_FILE.log,'End time to delete '||to_char(sysdate,'hh24:mi:ss'));
1111: --------UPDATE AUTO MERGE FLAG --------------
1112: update hz_imp_dup_parties a
1113: set a.auto_merge_flag = 'Y'
1106: where b.batch_id=p_batch_id and a.party_id=b.party_id and a.score < b.score)
1107: );
1108:
1109: FND_FILE.put_line(FND_FILE.log,'Number of records deleted from hz_imp_dup_parties '||SQL%ROWCOUNT);
1110: FND_FILE.put_line(FND_FILE.log,'End time to delete '||to_char(sysdate,'hh24:mi:ss'));
1111: --------UPDATE AUTO MERGE FLAG --------------
1112: update hz_imp_dup_parties a
1113: set a.auto_merge_flag = 'Y'
1114: where a.score >= p_auto_merge_threshold
1125: ----------------------PARTY LEVEL DUPLICATE IDENTIFICATION ENDS --------------------
1126:
1127:
1128: -------------CONTACT_POINTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1129: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1130: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACT_POINTS');
1131: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1132: 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
1133: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
1126:
1127:
1128: -------------CONTACT_POINTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1129: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1130: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACT_POINTS');
1131: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1132: 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
1133: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
1134: select /*+ USE_CONCAT */ s1.party_id f,
1127:
1128: -------------CONTACT_POINTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1129: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1130: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACT_POINTS');
1131: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1132: 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
1133: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
1134: select /*+ USE_CONCAT */ s1.party_id f,
1135: decode(instrb(s2.TX5,s1.TX5),1,60,
1179: where a.batch_id = p_batch_id
1180: and a.party_osr between from_osr and to_osr and a.entity ='CONTACT_POINTS';
1181: HZ_DQM_DUP_ID_PKG.update_detail_dqm_action_flag('CONTACT_POINTS',p_batch_id, x_ent_cur);
1182: -------------CONTACT_POINTS LEVEL DUPLICATE IDENTIFICATION ENDS ------------------------
1183: FND_FILE.put_line(FND_FILE.log,'Ending insert of CONTACT_POINTS');
1184: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1185: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1186:
1187:
1180: and a.party_osr between from_osr and to_osr and a.entity ='CONTACT_POINTS';
1181: HZ_DQM_DUP_ID_PKG.update_detail_dqm_action_flag('CONTACT_POINTS',p_batch_id, x_ent_cur);
1182: -------------CONTACT_POINTS LEVEL DUPLICATE IDENTIFICATION ENDS ------------------------
1183: FND_FILE.put_line(FND_FILE.log,'Ending insert of CONTACT_POINTS');
1184: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1185: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1186:
1187:
1188:
1181: HZ_DQM_DUP_ID_PKG.update_detail_dqm_action_flag('CONTACT_POINTS',p_batch_id, x_ent_cur);
1182: -------------CONTACT_POINTS LEVEL DUPLICATE IDENTIFICATION ENDS ------------------------
1183: FND_FILE.put_line(FND_FILE.log,'Ending insert of CONTACT_POINTS');
1184: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1185: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1186:
1187:
1188:
1189: -------------PARTY_SITES LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1186:
1187:
1188:
1189: -------------PARTY_SITES LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1190: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1191: FND_FILE.put_line(FND_FILE.log,'Beginning insert of PARTY_SITES');
1192: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1193: 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
1194: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
1187:
1188:
1189: -------------PARTY_SITES LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1190: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1191: FND_FILE.put_line(FND_FILE.log,'Beginning insert of PARTY_SITES');
1192: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1193: 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
1194: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
1195: select /*+ USE_CONCAT */ s1.party_id f,
1188:
1189: -------------PARTY_SITES LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1190: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1191: FND_FILE.put_line(FND_FILE.log,'Beginning insert of PARTY_SITES');
1192: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1193: 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
1194: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
1195: select /*+ USE_CONCAT */ s1.party_id f,
1196: decode(instrb(s2.TX26,s1.TX26),1,100,
1238: where a.batch_id = p_batch_id
1239: and a.party_osr between from_osr and to_osr and a.entity ='PARTY_SITES';
1240: HZ_DQM_DUP_ID_PKG.update_detail_dqm_action_flag('PARTY_SITES',p_batch_id, x_ent_cur);
1241: -------------PARTY_SITES LEVEL DUPLICATE IDENTIFICATION ENDS ------------------------
1242: FND_FILE.put_line(FND_FILE.log,'Ending insert of PARTY_SITES');
1243: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1244: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1245:
1246:
1239: and a.party_osr between from_osr and to_osr and a.entity ='PARTY_SITES';
1240: HZ_DQM_DUP_ID_PKG.update_detail_dqm_action_flag('PARTY_SITES',p_batch_id, x_ent_cur);
1241: -------------PARTY_SITES LEVEL DUPLICATE IDENTIFICATION ENDS ------------------------
1242: FND_FILE.put_line(FND_FILE.log,'Ending insert of PARTY_SITES');
1243: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1244: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1245:
1246:
1247:
1240: HZ_DQM_DUP_ID_PKG.update_detail_dqm_action_flag('PARTY_SITES',p_batch_id, x_ent_cur);
1241: -------------PARTY_SITES LEVEL DUPLICATE IDENTIFICATION ENDS ------------------------
1242: FND_FILE.put_line(FND_FILE.log,'Ending insert of PARTY_SITES');
1243: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1244: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1245:
1246:
1247:
1248: -------------CONTACTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1245:
1246:
1247:
1248: -------------CONTACTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1249: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1250: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACTS');
1251: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1252: 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
1253: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
1246:
1247:
1248: -------------CONTACTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1249: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1250: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACTS');
1251: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1252: 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
1253: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
1254: select /*+ USE_CONCAT */ s1.party_id f,
1247:
1248: -------------CONTACTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1249: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1250: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACTS');
1251: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1252: 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
1253: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
1254: select /*+ USE_CONCAT */ s1.party_id f,
1255: decode(instrb(s2.TX2,s1.TX2),1,20,
1285: where a.batch_id = p_batch_id
1286: and a.party_osr between from_osr and to_osr and a.entity ='CONTACTS';
1287: HZ_DQM_DUP_ID_PKG.update_detail_dqm_action_flag('CONTACTS',p_batch_id, x_ent_cur);
1288: -------------CONTACTS LEVEL DUPLICATE IDENTIFICATION ENDS ------------------------
1289: FND_FILE.put_line(FND_FILE.log,'Ending insert of CONTACTS');
1290: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1291: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1292:
1293:
1286: and a.party_osr between from_osr and to_osr and a.entity ='CONTACTS';
1287: HZ_DQM_DUP_ID_PKG.update_detail_dqm_action_flag('CONTACTS',p_batch_id, x_ent_cur);
1288: -------------CONTACTS LEVEL DUPLICATE IDENTIFICATION ENDS ------------------------
1289: FND_FILE.put_line(FND_FILE.log,'Ending insert of CONTACTS');
1290: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1291: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1292:
1293:
1294:
1287: HZ_DQM_DUP_ID_PKG.update_detail_dqm_action_flag('CONTACTS',p_batch_id, x_ent_cur);
1288: -------------CONTACTS LEVEL DUPLICATE IDENTIFICATION ENDS ------------------------
1289: FND_FILE.put_line(FND_FILE.log,'Ending insert of CONTACTS');
1290: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1291: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1292:
1293:
1294:
1295: ---------- exception block ---------------
1313: IS
1314: x_ent_cur HZ_DQM_DUP_ID_PKG.EntityCur;
1315: x_insert_threshold number := 20;
1316: BEGIN
1317: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1318: FND_FILE.put_line(FND_FILE.log,'WU: '||from_osr||' to '||to_osr);
1319: FND_FILE.put_line(FND_FILE.log,'Start time of insert of Parties '||to_char(sysdate,'hh24:mi:ss'));
1320: insert into hz_int_dup_results(batch_id, f_osr,t_osr,ord_f_osr,ord_t_osr,score,f_os, t_os)
1321: select p_batch_id, f, t, least(f,t), greatest(f,t), sum(score) score, fos, tos from (
1314: x_ent_cur HZ_DQM_DUP_ID_PKG.EntityCur;
1315: x_insert_threshold number := 20;
1316: BEGIN
1317: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1318: FND_FILE.put_line(FND_FILE.log,'WU: '||from_osr||' to '||to_osr);
1319: FND_FILE.put_line(FND_FILE.log,'Start time of insert of Parties '||to_char(sysdate,'hh24:mi:ss'));
1320: insert into hz_int_dup_results(batch_id, f_osr,t_osr,ord_f_osr,ord_t_osr,score,f_os, t_os)
1321: select p_batch_id, f, t, least(f,t), greatest(f,t), sum(score) score, fos, tos from (
1322: ------------------ PARTY LEVEL DUPLICATE IDENTIFICATION BEGINS --------------------
1315: x_insert_threshold number := 20;
1316: BEGIN
1317: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1318: FND_FILE.put_line(FND_FILE.log,'WU: '||from_osr||' to '||to_osr);
1319: FND_FILE.put_line(FND_FILE.log,'Start time of insert of Parties '||to_char(sysdate,'hh24:mi:ss'));
1320: insert into hz_int_dup_results(batch_id, f_osr,t_osr,ord_f_osr,ord_t_osr,score,f_os, t_os)
1321: select p_batch_id, f, t, least(f,t), greatest(f,t), sum(score) score, fos, tos from (
1322: ------------------ PARTY LEVEL DUPLICATE IDENTIFICATION BEGINS --------------------
1323: select /*+ USE_CONCAT */ s1.party_osr f, s2.party_osr t,
1411: )
1412: group by f, t, fos, tos
1413: having sum(score) >= x_insert_threshold
1414: ;
1415: FND_FILE.put_line(FND_FILE.log,'Number of parties inserted '||SQL%ROWCOUNT);
1416: FND_FILE.put_line(FND_FILE.log,'End time of insert '||to_char(sysdate,'hh24:mi:ss'));
1417: FND_CONCURRENT.AF_Commit;
1418:
1419:
1412: group by f, t, fos, tos
1413: having sum(score) >= x_insert_threshold
1414: ;
1415: FND_FILE.put_line(FND_FILE.log,'Number of parties inserted '||SQL%ROWCOUNT);
1416: FND_FILE.put_line(FND_FILE.log,'End time of insert '||to_char(sysdate,'hh24:mi:ss'));
1417: FND_CONCURRENT.AF_Commit;
1418:
1419:
1420: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1416: FND_FILE.put_line(FND_FILE.log,'End time of insert '||to_char(sysdate,'hh24:mi:ss'));
1417: FND_CONCURRENT.AF_Commit;
1418:
1419:
1420: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1421: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of PARTY_SITES');
1422: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
1423: open x_ent_cur for
1424: select f,t,max(score) from (
1417: FND_CONCURRENT.AF_Commit;
1418:
1419:
1420: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1421: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of PARTY_SITES');
1422: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
1423: open x_ent_cur for
1424: select f,t,max(score) from (
1425: select /*+ USE_CONCAT */ s1.party_osr f, s2.party_osr t,
1418:
1419:
1420: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1421: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of PARTY_SITES');
1422: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
1423: open x_ent_cur for
1424: select f,t,max(score) from (
1425: select /*+ USE_CONCAT */ s1.party_osr f, s2.party_osr t,
1426: decode(instrb(s2.TX26,s1.TX26),1,100,
1458: )
1459: ) group by f,t ;
1460: HZ_DQM_DUP_ID_PKG.update_hz_int_dup_results(p_batch_id,x_ent_cur);
1461: close x_ent_cur;
1462: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
1463: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1464: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of PARTY_SITES');
1465: FND_CONCURRENT.AF_Commit;
1466:
1459: ) group by f,t ;
1460: HZ_DQM_DUP_ID_PKG.update_hz_int_dup_results(p_batch_id,x_ent_cur);
1461: close x_ent_cur;
1462: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
1463: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1464: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of PARTY_SITES');
1465: FND_CONCURRENT.AF_Commit;
1466:
1467:
1460: HZ_DQM_DUP_ID_PKG.update_hz_int_dup_results(p_batch_id,x_ent_cur);
1461: close x_ent_cur;
1462: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
1463: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1464: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of PARTY_SITES');
1465: FND_CONCURRENT.AF_Commit;
1466:
1467:
1468: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1464: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of PARTY_SITES');
1465: FND_CONCURRENT.AF_Commit;
1466:
1467:
1468: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1469: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACTS');
1470: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
1471: open x_ent_cur for
1472: select f,t,max(score) from (
1465: FND_CONCURRENT.AF_Commit;
1466:
1467:
1468: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1469: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACTS');
1470: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
1471: open x_ent_cur for
1472: select f,t,max(score) from (
1473: select /*+ USE_CONCAT */ s1.party_osr f, s2.party_osr t,
1466:
1467:
1468: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1469: FND_FILE.put_line(FND_FILE.log,'Beginning update of Parties on the basis of CONTACTS');
1470: FND_FILE.put_line(FND_FILE.log,'Start time of update '||to_char(sysdate,'hh24:mi:ss'));
1471: open x_ent_cur for
1472: select f,t,max(score) from (
1473: select /*+ USE_CONCAT */ s1.party_osr f, s2.party_osr t,
1474: decode(instrb(s2.TX2,s1.TX2),1,20,
1494: )
1495: ) group by f,t ;
1496: HZ_DQM_DUP_ID_PKG.update_hz_int_dup_results(p_batch_id,x_ent_cur);
1497: close x_ent_cur;
1498: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
1499: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1500: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACTS');
1501: FND_CONCURRENT.AF_Commit;
1502: -------------CONTACT_POINTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1495: ) group by f,t ;
1496: HZ_DQM_DUP_ID_PKG.update_hz_int_dup_results(p_batch_id,x_ent_cur);
1497: close x_ent_cur;
1498: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
1499: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1500: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACTS');
1501: FND_CONCURRENT.AF_Commit;
1502: -------------CONTACT_POINTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1503: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1496: HZ_DQM_DUP_ID_PKG.update_hz_int_dup_results(p_batch_id,x_ent_cur);
1497: close x_ent_cur;
1498: FND_FILE.put_line(FND_FILE.log,'Number of parties updated '||SQL%ROWCOUNT);
1499: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1500: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACTS');
1501: FND_CONCURRENT.AF_Commit;
1502: -------------CONTACT_POINTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1503: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1504: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACT_POINTS');
1499: FND_FILE.put_line(FND_FILE.log,'End time to update '||to_char(sysdate,'hh24:mi:ss'));
1500: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACTS');
1501: FND_CONCURRENT.AF_Commit;
1502: -------------CONTACT_POINTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1503: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1504: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACT_POINTS');
1505: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1506: insert into hz_imp_int_dedup_results(batch_id, winner_record_osr, winner_record_os,
1507: dup_record_osr, dup_record_os, detail_party_osr, detail_party_os, entity, score,
1500: FND_FILE.put_line(FND_FILE.log,'Ending update of Parties on the basis of CONTACTS');
1501: FND_CONCURRENT.AF_Commit;
1502: -------------CONTACT_POINTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1503: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1504: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACT_POINTS');
1505: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1506: insert into hz_imp_int_dedup_results(batch_id, winner_record_osr, winner_record_os,
1507: dup_record_osr, dup_record_os, detail_party_osr, detail_party_os, entity, score,
1508: dup_creation_date,dup_last_update_date
1501: FND_CONCURRENT.AF_Commit;
1502: -------------CONTACT_POINTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1503: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1504: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACT_POINTS');
1505: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1506: insert into hz_imp_int_dedup_results(batch_id, winner_record_osr, winner_record_os,
1507: dup_record_osr, dup_record_os, detail_party_osr, detail_party_os, entity, score,
1508: dup_creation_date,dup_last_update_date
1509: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
1548: (s1.TX158 is not null and s2.TX158 like s1.TX158 || decode(sign(lengthb(s1.TX158)-3),1,'%',''))
1549: )
1550: )
1551: ;
1552: FND_FILE.put_line(FND_FILE.log,'Ending insert of CONTACT_POINTS');
1553: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1554: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1555: FND_CONCURRENT.AF_Commit;
1556: -------------PARTY_SITES LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1549: )
1550: )
1551: ;
1552: FND_FILE.put_line(FND_FILE.log,'Ending insert of CONTACT_POINTS');
1553: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1554: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1555: FND_CONCURRENT.AF_Commit;
1556: -------------PARTY_SITES LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1557: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1550: )
1551: ;
1552: FND_FILE.put_line(FND_FILE.log,'Ending insert of CONTACT_POINTS');
1553: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1554: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1555: FND_CONCURRENT.AF_Commit;
1556: -------------PARTY_SITES LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1557: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1558: FND_FILE.put_line(FND_FILE.log,'Beginning insert of PARTY_SITES');
1553: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1554: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1555: FND_CONCURRENT.AF_Commit;
1556: -------------PARTY_SITES LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1557: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1558: FND_FILE.put_line(FND_FILE.log,'Beginning insert of PARTY_SITES');
1559: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1560: insert into hz_imp_int_dedup_results(batch_id, winner_record_osr, winner_record_os,
1561: dup_record_osr, dup_record_os, detail_party_osr, detail_party_os, entity, score,
1554: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1555: FND_CONCURRENT.AF_Commit;
1556: -------------PARTY_SITES LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1557: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1558: FND_FILE.put_line(FND_FILE.log,'Beginning insert of PARTY_SITES');
1559: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1560: insert into hz_imp_int_dedup_results(batch_id, winner_record_osr, winner_record_os,
1561: dup_record_osr, dup_record_os, detail_party_osr, detail_party_os, entity, score,
1562: dup_creation_date,dup_last_update_date
1555: FND_CONCURRENT.AF_Commit;
1556: -------------PARTY_SITES LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1557: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1558: FND_FILE.put_line(FND_FILE.log,'Beginning insert of PARTY_SITES');
1559: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1560: insert into hz_imp_int_dedup_results(batch_id, winner_record_osr, winner_record_os,
1561: dup_record_osr, dup_record_os, detail_party_osr, detail_party_os, entity, score,
1562: dup_creation_date,dup_last_update_date
1563: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
1599: (
1600: ((s1.TX11 is null and s2.TX11 is null) or s2.TX11 = s1.TX11)
1601: )
1602: ;
1603: FND_FILE.put_line(FND_FILE.log,'Ending insert of PARTY_SITES');
1604: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1605: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1606: FND_CONCURRENT.AF_Commit;
1607: -------------CONTACTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1600: ((s1.TX11 is null and s2.TX11 is null) or s2.TX11 = s1.TX11)
1601: )
1602: ;
1603: FND_FILE.put_line(FND_FILE.log,'Ending insert of PARTY_SITES');
1604: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1605: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1606: FND_CONCURRENT.AF_Commit;
1607: -------------CONTACTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1608: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1601: )
1602: ;
1603: FND_FILE.put_line(FND_FILE.log,'Ending insert of PARTY_SITES');
1604: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1605: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1606: FND_CONCURRENT.AF_Commit;
1607: -------------CONTACTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1608: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1609: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACTS');
1604: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1605: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1606: FND_CONCURRENT.AF_Commit;
1607: -------------CONTACTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1608: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1609: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACTS');
1610: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1611: insert into hz_imp_int_dedup_results(batch_id, winner_record_osr, winner_record_os,
1612: dup_record_osr, dup_record_os, detail_party_osr, detail_party_os, entity, score,
1605: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1606: FND_CONCURRENT.AF_Commit;
1607: -------------CONTACTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1608: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1609: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACTS');
1610: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1611: insert into hz_imp_int_dedup_results(batch_id, winner_record_osr, winner_record_os,
1612: dup_record_osr, dup_record_os, detail_party_osr, detail_party_os, entity, score,
1613: dup_creation_date,dup_last_update_date
1606: FND_CONCURRENT.AF_Commit;
1607: -------------CONTACTS LEVEL DUPLICATE IDENTIFICATION BEGINS ------------------------
1608: FND_FILE.put_line(FND_FILE.log,'------------------------------------------------');
1609: FND_FILE.put_line(FND_FILE.log,'Beginning insert of CONTACTS');
1610: FND_FILE.put_line(FND_FILE.log,'Start time of insert '||to_char(sysdate,'hh24:mi:ss'));
1611: insert into hz_imp_int_dedup_results(batch_id, winner_record_osr, winner_record_os,
1612: dup_record_osr, dup_record_os, detail_party_osr, detail_party_os, entity, score,
1613: dup_creation_date,dup_last_update_date
1614: ,created_by,creation_date,last_update_login,last_update_date,last_updated_by)
1638: (s1.TX23 is not null and s2.TX23 like s1.TX23 || decode(sign(lengthb(s1.TX23)-3),1,'%',''))
1639: )
1640: )
1641: ;
1642: FND_FILE.put_line(FND_FILE.log,'Ending insert of CONTACTS');
1643: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1644: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1645: FND_CONCURRENT.AF_Commit;
1646:
1639: )
1640: )
1641: ;
1642: FND_FILE.put_line(FND_FILE.log,'Ending insert of CONTACTS');
1643: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1644: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1645: FND_CONCURRENT.AF_Commit;
1646:
1647: ---------- exception block ---------------
1640: )
1641: ;
1642: FND_FILE.put_line(FND_FILE.log,'Ending insert of CONTACTS');
1643: FND_FILE.put_line(FND_FILE.log,'Number of records inserted '||SQL%ROWCOUNT);
1644: FND_FILE.put_line(FND_FILE.log,'End time to insert '||to_char(sysdate,'hh24:mi:ss'));
1645: FND_CONCURRENT.AF_Commit;
1646:
1647: ---------- exception block ---------------
1648: EXCEPTION