DBA Data[Home] [Help]

APPS.HZ_PARTY_STAGE dependencies on HZ_DQM_SYNC_INTERFACE

Line 391: log('Attempting to truncate HZ_DQM_SYNC_INTERFACE ..',FALSE);

387: log('Truncating HZ_STAGED_CONTACT_POINTS .. ', FALSE);
388: EXECUTE IMMEDIATE 'TRUNCATE TABLE '||l_owner||'.HZ_STAGED_CONTACT_POINTS';
389: log('Done');
390:
391: log('Attempting to truncate HZ_DQM_SYNC_INTERFACE ..',FALSE);
392: BEGIN
393: EXECUTE IMMEDIATE 'TRUNCATE TABLE '||l_owner||'.hz_dqm_sync_interface';
394: log('Done Successfully');
395: EXCEPTION

Line 393: EXECUTE IMMEDIATE 'TRUNCATE TABLE '||l_owner||'.hz_dqm_sync_interface';

389: log('Done');
390:
391: log('Attempting to truncate HZ_DQM_SYNC_INTERFACE ..',FALSE);
392: BEGIN
393: EXECUTE IMMEDIATE 'TRUNCATE TABLE '||l_owner||'.hz_dqm_sync_interface';
394: log('Done Successfully');
395: EXCEPTION
396: WHEN OTHERS THEN
397: log('Lock on table. Unable to truncate');

Line 1342: CURSOR c_sync is select 1 from hz_dqm_sync_interface where staged_flag <> 'E' and rownum=1;

1338: l_workers_completed boolean;
1339: --End of Bug No: 4292425
1340: --Start of Bug 4915282
1341: l_realtime_sync_value VARCHAR2(15);
1342: CURSOR c_sync is select 1 from hz_dqm_sync_interface where staged_flag <> 'E' and rownum=1;
1343: l_sync_count NUMBER;
1344: l_profile_save boolean;
1345: --End of Bug 4915282
1346: BEGIN

Line 2658: DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE mod(PARTY_ID,l_num_workers) = l_worker_number

2654: COMMIT;
2655:
2656: END IF;
2657:
2658: DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE mod(PARTY_ID,l_num_workers) = l_worker_number
2659: AND creation_date<=l_startdate;
2660:
2661: ELSE
2662: log('Updating Organization Party Records');

Line 4615: -- insert errored records into HZ_DQM_SYNC_INTERFACE table.

4611:
4612: END;
4613:
4614: -- REPURI added this procedure for generating a procedure to
4615: -- insert errored records into HZ_DQM_SYNC_INTERFACE table.
4616:
4617: PROCEDURE generate_ins_dqm_sync_err_rec IS
4618:
4619: BEGIN

Line 4633: l(' INSERT INTO hz_dqm_sync_interface ( ');

4629: l(' p_realtime_sync_flag IN VARCHAR2 DEFAULT ''Y'', ');
4630: l(' p_error_data IN VARCHAR2 ');
4631: l(' ) IS ');
4632: l(' BEGIN ');
4633: l(' INSERT INTO hz_dqm_sync_interface ( ');
4634: l(' PARTY_ID, ');
4635: l(' RECORD_ID, ');
4636: l(' PARTY_SITE_ID, ');
4637: l(' ORG_CONTACT_ID, ');

Line 4664: l(' HZ_DQM_SYNC_INTERFACE_S.nextval ');

4660: l(' hz_utility_pub.creation_date, ');
4661: l(' hz_utility_pub.last_update_login, ');
4662: l(' hz_utility_pub.last_update_date, ');
4663: l(' hz_utility_pub.user_id, ');
4664: l(' HZ_DQM_SYNC_INTERFACE_S.nextval ');
4665: l(' ); ');
4666: l(' END insert_dqm_sync_error_rec; ');
4667: l('');
4668:

Line 5057: l(' FROM HZ_PARTIES p, HZ_ORGANIZATION_PROFILES op, HZ_DQM_SYNC_INTERFACE dsi ');

5053: l(' ,' || l_org_select(I));
5054: END IF;
5055: END LOOP;
5056:
5057: l(' FROM HZ_PARTIES p, HZ_ORGANIZATION_PROFILES op, HZ_DQM_SYNC_INTERFACE dsi ');
5058: l(' WHERE p.party_id = op.party_id ');
5059: l(' AND p.party_id = dsi.party_id ');
5060: l(' AND p.PARTY_TYPE = ''ORGANIZATION'' ');
5061: l(' AND dsi.entity = ''PARTY'' ');

Line 5077: l(' FROM HZ_PARTIES p, HZ_PERSON_PROFILES pe, HZ_DQM_SYNC_INTERFACE dsi ');

5073: l(' ,' || l_per_select(I));
5074: END IF;
5075: END LOOP;
5076:
5077: l(' FROM HZ_PARTIES p, HZ_PERSON_PROFILES pe, HZ_DQM_SYNC_INTERFACE dsi ');
5078: l(' WHERE p.party_id = pe.party_id ');
5079: l(' AND p.party_id = dsi.party_id ');
5080: l(' AND p.PARTY_TYPE = ''PERSON'' ');
5081: l(' AND dsi.entity = ''PARTY'' ');

Line 5097: l(' FROM HZ_PARTIES p, HZ_DQM_SYNC_INTERFACE dsi ');

5093: l(' ,' || l_oth_select(I));
5094: END IF;
5095: END LOOP;
5096:
5097: l(' FROM HZ_PARTIES p, HZ_DQM_SYNC_INTERFACE dsi ');
5098: l(' WHERE p.party_id = dsi.party_id ');
5099: l(' AND dsi.entity = ''PARTY'' ');
5100: l(' AND dsi.staged_flag = ''N'' ');
5101: l(' AND dsi.operation = p_operation ');

Line 5246: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''PARTY'' AND OPERATION=''C'' AND PARTY_ID=H_P_PARTY_ID(l_err_index); ');

5242: -- SCHITRAP: Bug:5357970 - Error code is a number. Oracle error for ''DUP_VAL_ON_INDEX'' is ORA-00001
5243: --l(' IF (SQL%BULK_EXCEPTIONS(indx).ERROR_CODE) = ''DUP_VAL_ON_INDEX'' THEN ');
5244: l(' IF (instr(l_sql_errm,''ORA-00001'')>0) THEN ');
5245: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting Party with PARTY_ID - ''||H_P_PARTY_ID(l_err_index)); ');
5246: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''PARTY'' AND OPERATION=''C'' AND PARTY_ID=H_P_PARTY_ID(l_err_index); ');
5247: l(' ELSE ');
5248: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
5249: l(' UPDATE hz_dqm_sync_interface ');
5250: l(' SET error_data = l_sql_errm ');

Line 5249: l(' UPDATE hz_dqm_sync_interface ');

5245: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting Party with PARTY_ID - ''||H_P_PARTY_ID(l_err_index)); ');
5246: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''PARTY'' AND OPERATION=''C'' AND PARTY_ID=H_P_PARTY_ID(l_err_index); ');
5247: l(' ELSE ');
5248: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
5249: l(' UPDATE hz_dqm_sync_interface ');
5250: l(' SET error_data = l_sql_errm ');
5251: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
5252: l(' WHERE rowid = H_ROWID(l_err_index); ');
5253: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');

Line 5254: l(' -- Insert the Error Record into HZ_DQM_SYNC_INTERFACE table ');

5250: l(' SET error_data = l_sql_errm ');
5251: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
5252: l(' WHERE rowid = H_ROWID(l_err_index); ');
5253: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');
5254: l(' -- Insert the Error Record into HZ_DQM_SYNC_INTERFACE table ');
5255: l(' insert_dqm_sync_error_rec(H_P_PARTY_ID(l_err_index), NULL, NULL, NULL, ''PARTY'', p_operation, ''E'', ''N'', l_sql_errm); ');
5256: l(' END IF; ');
5257: l(' END IF; ');
5258: l(' END LOOP; ');

Line 5285: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''PARTY'' AND OPERATION=''U'' AND PARTY_ID=H_P_PARTY_ID(l_err_index); ');

5281: -- SCHITRAP: Bug:5357970 - Error code is a number. Oracle error for ''DUP_VAL_ON_INDEX'' is ORA-00001
5282: --l(' IF (SQL%BULK_EXCEPTIONS(indx).ERROR_CODE) = ''DUP_VAL_ON_INDEX'' THEN ');
5283: l(' IF (instr(l_sql_errm,''ORA-00001'')>0) THEN ');
5284: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting Party with PARTY_ID - ''||H_P_PARTY_ID(l_err_index)); ');
5285: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''PARTY'' AND OPERATION=''U'' AND PARTY_ID=H_P_PARTY_ID(l_err_index); ');
5286: l(' ELSE ');
5287: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
5288: l(' UPDATE hz_dqm_sync_interface ');
5289: l(' SET error_data = l_sql_errm ');

Line 5288: l(' UPDATE hz_dqm_sync_interface ');

5284: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting Party with PARTY_ID - ''||H_P_PARTY_ID(l_err_index)); ');
5285: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''PARTY'' AND OPERATION=''U'' AND PARTY_ID=H_P_PARTY_ID(l_err_index); ');
5286: l(' ELSE ');
5287: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
5288: l(' UPDATE hz_dqm_sync_interface ');
5289: l(' SET error_data = l_sql_errm ');
5290: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
5291: l(' WHERE rowid = H_ROWID(l_err_index); ');
5292: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');

Line 5293: l(' -- Insert the Error Record into HZ_DQM_SYNC_INTERFACE table ');

5289: l(' SET error_data = l_sql_errm ');
5290: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
5291: l(' WHERE rowid = H_ROWID(l_err_index); ');
5292: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');
5293: l(' -- Insert the Error Record into HZ_DQM_SYNC_INTERFACE table ');
5294: l(' insert_dqm_sync_error_rec(H_P_PARTY_ID(l_err_index), NULL, NULL, NULL, ''PARTY'', p_operation, ''E'', ''N'', l_sql_errm); ');
5295: l(' END IF; ');
5296: l(' END IF; ');
5297: l(' END LOOP; ');

Line 6002: l(' -- FAILOVER : REPORT RECORD TO HZ_DQM_SYNC_INTERFACE ');

5998: l(' EXIT WHEN c_contact%NOTFOUND; ');
5999: l(' BEGIN ');
6000: l(' sync_single_contact_online(l_org_contact_id, p_operation); ');
6001: l(' EXCEPTION WHEN OTHERS THEN ');
6002: l(' -- FAILOVER : REPORT RECORD TO HZ_DQM_SYNC_INTERFACE ');
6003: l(' -- FOR ONLINE FLOWS ');
6004: l(' l_sql_err_message := SQLERRM; ');
6005: l(' insert_dqm_sync_error_rec(p_party_id,l_org_contact_id,null,null,''CONTACTS'',''U'',''E'',''Y'', l_sql_err_message); ');
6006: l(' END ; ');

Line 6187: l(' -- FAILOVER : REPORT RECORD TO HZ_DQM_SYNC_INTERFACE ');

6183: l('');
6184: -- Fix for Bug 4862121.
6185: -- Added the Exception handling at this context, for the procedure.
6186: l(' EXCEPTION WHEN OTHERS THEN ');
6187: l(' -- FAILOVER : REPORT RECORD TO HZ_DQM_SYNC_INTERFACE ');
6188: l(' -- FOR ONLINE FLOWS ');
6189: l(' l_sql_err_message := SQLERRM; ');
6190: l(' insert_dqm_sync_error_rec(p_party_id, NULL, NULL, NULL, ''PARTY'', p_operation, ''E'', ''Y'', l_sql_err_message); ');
6191: l(' END;');

Line 6490: l(' FROM HZ_DQM_SYNC_INTERFACE dsi, HZ_PARTY_SITES ps, HZ_LOCATIONS l');

6486: l(' ,' || l_select(I));
6487: END IF;
6488: END LOOP;
6489:
6490: l(' FROM HZ_DQM_SYNC_INTERFACE dsi, HZ_PARTY_SITES ps, HZ_LOCATIONS l');
6491: l(' WHERE dsi.record_id = ps.party_site_id ');
6492: l(' AND dsi.entity = ''PARTY_SITES'' ');
6493: l(' AND dsi.operation = p_operation ');
6494: l(' AND dsi.staged_flag = ''N'' ');

Line 6636: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''PARTY_SITES'' AND OPERATION=''C'' AND RECORD_ID=H_PARTY_SITE_ID(l_err_index); ');

6632: -- SCHITRAP: Bug:5357970 - Error code is a number. Oracle error for ''DUP_VAL_ON_INDEX'' is ORA-00001
6633: --l(' IF (SQL%BULK_EXCEPTIONS(indx).ERROR_CODE) = ''DUP_VAL_ON_INDEX'' THEN ');
6634: l(' IF (instr(l_sql_errm,''ORA-00001'')>0) THEN ');
6635: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting Party Site with PARTY_SITE_ID - ''||H_PARTY_SITE_ID(l_err_index)); ');
6636: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''PARTY_SITES'' AND OPERATION=''C'' AND RECORD_ID=H_PARTY_SITE_ID(l_err_index); ');
6637: l(' ELSE ');
6638: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
6639: l(' UPDATE hz_dqm_sync_interface ');
6640: l(' SET error_data = l_sql_errm ');

Line 6639: l(' UPDATE hz_dqm_sync_interface ');

6635: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting Party Site with PARTY_SITE_ID - ''||H_PARTY_SITE_ID(l_err_index)); ');
6636: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''PARTY_SITES'' AND OPERATION=''C'' AND RECORD_ID=H_PARTY_SITE_ID(l_err_index); ');
6637: l(' ELSE ');
6638: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
6639: l(' UPDATE hz_dqm_sync_interface ');
6640: l(' SET error_data = l_sql_errm ');
6641: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
6642: l(' WHERE rowid = H_ROWID(l_err_index); ');
6643: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');

Line 6644: l(' -- Insert the Error Record into HZ_DQM_SYNC_INTERFACE table ');

6640: l(' SET error_data = l_sql_errm ');
6641: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
6642: l(' WHERE rowid = H_ROWID(l_err_index); ');
6643: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');
6644: l(' -- Insert the Error Record into HZ_DQM_SYNC_INTERFACE table ');
6645: l(' insert_dqm_sync_error_rec(H_PS_PARTY_ID(l_err_index), H_PARTY_SITE_ID(l_err_index), NULL, H_PS_ORG_CONTACT_ID(l_err_index), ''PARTY_SITES'', p_operation, ''E'', ''N'', l_sql_errm); ');
6646: l(' END IF; ');
6647: l(' END IF; ');
6648: l(' END LOOP; ');

Line 6679: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''PARTY_SITES'' AND OPERATION=''U'' AND RECORD_ID=H_PARTY_SITE_ID(l_err_index); ');

6675: -- SCHITRAP: Bug:5357970 - Error code is a number. Oracle error for ''DUP_VAL_ON_INDEX'' is ORA-00001
6676: --l(' IF (SQL%BULK_EXCEPTIONS(indx).ERROR_CODE) = ''DUP_VAL_ON_INDEX'' THEN ');
6677: l(' IF (instr(l_sql_errm,''ORA-00001'')>0) THEN ');
6678: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting Party Site with PARTY_SITE_ID - ''||H_PARTY_SITE_ID(l_err_index)); ');
6679: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''PARTY_SITES'' AND OPERATION=''U'' AND RECORD_ID=H_PARTY_SITE_ID(l_err_index); ');
6680: l(' ELSE ');
6681: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
6682: l(' UPDATE hz_dqm_sync_interface ');
6683: l(' SET error_data = l_sql_errm ');

Line 6682: l(' UPDATE hz_dqm_sync_interface ');

6678: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting Party Site with PARTY_SITE_ID - ''||H_PARTY_SITE_ID(l_err_index)); ');
6679: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''PARTY_SITES'' AND OPERATION=''U'' AND RECORD_ID=H_PARTY_SITE_ID(l_err_index); ');
6680: l(' ELSE ');
6681: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
6682: l(' UPDATE hz_dqm_sync_interface ');
6683: l(' SET error_data = l_sql_errm ');
6684: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
6685: l(' WHERE rowid = H_ROWID(l_err_index); ');
6686: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');

Line 6687: l(' -- Insert the Error Record into HZ_DQM_SYNC_INTERFACE table ');

6683: l(' SET error_data = l_sql_errm ');
6684: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
6685: l(' WHERE rowid = H_ROWID(l_err_index); ');
6686: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');
6687: l(' -- Insert the Error Record into HZ_DQM_SYNC_INTERFACE table ');
6688: l(' insert_dqm_sync_error_rec(H_PS_PARTY_ID(l_err_index), H_PARTY_SITE_ID(l_err_index), NULL, H_PS_ORG_CONTACT_ID(l_err_index), ''PARTY_SITES'', p_operation, ''E'', ''N'', l_sql_errm); ');
6689: l(' END IF; ');
6690: l(' END IF; ');
6691: l(' END LOOP; ');

Line 7114: l(' FROM HZ_PARTY_SITES ps, HZ_DQM_SYNC_INTERFACE d, HZ_LOCATIONS l ');

7110: l_custom_list(I) = 'N' THEN
7111: l(' , H_TX'||I||'(1)');
7112: END IF;
7113: END LOOP;
7114: l(' FROM HZ_PARTY_SITES ps, HZ_DQM_SYNC_INTERFACE d, HZ_LOCATIONS l ');
7115: l(' WHERE d.ENTITY=''PARTY_SITES'' ');
7116: l(' AND ps.party_site_id = p_party_site_id');
7117: l(' AND d.record_id = ps.party_site_id ');
7118: l(' AND ps.location_id = l.location_id ');

Line 7443: l(' -- FAILOVER : REPORT RECORD TO HZ_DQM_SYNC_INTERFACE ');

7439: l('');
7440: -- Fix for Bug 4862121.
7441: -- Added the Exception handling at this context, for the procedure.
7442: l(' EXCEPTION WHEN OTHERS THEN ');
7443: l(' -- FAILOVER : REPORT RECORD TO HZ_DQM_SYNC_INTERFACE ');
7444: l(' -- FOR ONLINE FLOWS ');
7445: l(' l_sql_err_message := SQLERRM; ');
7446: l(' insert_dqm_sync_error_rec(l_party_id, p_party_site_id, NULL, l_org_contact_id, ''PARTY_SITES'', p_operation, ''E'', ''Y'', l_sql_err_message); ');
7447: l(' END;');

Line 7796: l(' FROM HZ_DQM_SYNC_INTERFACE dsi, HZ_RELATIONSHIPS r,');

7792: l(' ,' || l_select(I));
7793: END IF;
7794: END LOOP;
7795:
7796: l(' FROM HZ_DQM_SYNC_INTERFACE dsi, HZ_RELATIONSHIPS r,');
7797: l(' HZ_ORG_CONTACTS oc, HZ_PERSON_PROFILES pp');
7798: l(' WHERE oc.party_relationship_id = r.relationship_id ');
7799: l(' AND dsi.record_id = oc.org_contact_id ');
7800: l(' AND r.subject_id = pp.party_id ');

Line 7945: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''CONTACTS'' AND OPERATION=''C'' AND RECORD_ID=H_ORG_CONTACT_ID(l_err_index); ');

7941: -- SCHITRAP: Bug:5357970 - Error code is a number. Oracle error for ''DUP_VAL_ON_INDEX'' is ORA-00001
7942: --l(' IF (SQL%BULK_EXCEPTIONS(indx).ERROR_CODE) = ''DUP_VAL_ON_INDEX'' THEN ');
7943: l(' IF (instr(l_sql_errm,''ORA-00001'')>0) THEN ');
7944: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting a Contact with ORG_CONTACT_ID - ''||H_ORG_CONTACT_ID(l_err_index)); ');
7945: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''CONTACTS'' AND OPERATION=''C'' AND RECORD_ID=H_ORG_CONTACT_ID(l_err_index); ');
7946: l(' ELSE ');
7947: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
7948: l(' UPDATE hz_dqm_sync_interface ');
7949: l(' SET error_data = l_sql_errm ');

Line 7948: l(' UPDATE hz_dqm_sync_interface ');

7944: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting a Contact with ORG_CONTACT_ID - ''||H_ORG_CONTACT_ID(l_err_index)); ');
7945: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''CONTACTS'' AND OPERATION=''C'' AND RECORD_ID=H_ORG_CONTACT_ID(l_err_index); ');
7946: l(' ELSE ');
7947: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
7948: l(' UPDATE hz_dqm_sync_interface ');
7949: l(' SET error_data = l_sql_errm ');
7950: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
7951: l(' WHERE rowid = H_ROWID(l_err_index); ');
7952: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');

Line 7953: l(' -- Insert the Error Record into HZ_DQM_SYNC_INTERFACE table ');

7949: l(' SET error_data = l_sql_errm ');
7950: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
7951: l(' WHERE rowid = H_ROWID(l_err_index); ');
7952: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');
7953: l(' -- Insert the Error Record into HZ_DQM_SYNC_INTERFACE table ');
7954: l(' insert_dqm_sync_error_rec(H_C_PARTY_ID(l_err_index), H_ORG_CONTACT_ID(l_err_index), NULL, NULL, ''CONTACTS'', p_operation, ''E'', ''N'', l_sql_errm); ');
7955: l(' END IF; ');
7956: l(' END IF; ');
7957: l(' END LOOP; ');

Line 7988: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''CONTACTS'' AND OPERATION=''U'' AND RECORD_ID=H_ORG_CONTACT_ID(l_err_index); ');

7984: -- SCHITRAP: Bug:5357970 - Error code is a number. Oracle error for ''DUP_VAL_ON_INDEX'' is ORA-00001
7985: --l(' IF (SQL%BULK_EXCEPTIONS(indx).ERROR_CODE) = ''DUP_VAL_ON_INDEX'' THEN ');
7986: l(' IF (instr(l_sql_errm,''ORA-00001'')>0) THEN ');
7987: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting a Contact with ORG_CONTACT_ID - ''||H_ORG_CONTACT_ID(l_err_index)); ');
7988: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''CONTACTS'' AND OPERATION=''U'' AND RECORD_ID=H_ORG_CONTACT_ID(l_err_index); ');
7989: l(' ELSE ');
7990: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
7991: l(' UPDATE hz_dqm_sync_interface ');
7992: l(' SET error_data = l_sql_errm ');

Line 7991: l(' UPDATE hz_dqm_sync_interface ');

7987: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting a Contact with ORG_CONTACT_ID - ''||H_ORG_CONTACT_ID(l_err_index)); ');
7988: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''CONTACTS'' AND OPERATION=''U'' AND RECORD_ID=H_ORG_CONTACT_ID(l_err_index); ');
7989: l(' ELSE ');
7990: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
7991: l(' UPDATE hz_dqm_sync_interface ');
7992: l(' SET error_data = l_sql_errm ');
7993: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
7994: l(' WHERE rowid = H_ROWID(l_err_index); ');
7995: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');

Line 7996: l(' -- Insert the Error Record into HZ_DQM_SYNC_INTERFACE table ');

7992: l(' SET error_data = l_sql_errm ');
7993: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
7994: l(' WHERE rowid = H_ROWID(l_err_index); ');
7995: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');
7996: l(' -- Insert the Error Record into HZ_DQM_SYNC_INTERFACE table ');
7997: l(' insert_dqm_sync_error_rec(H_C_PARTY_ID(l_err_index), H_ORG_CONTACT_ID(l_err_index), NULL, NULL, ''CONTACTS'', p_operation, ''E'', ''N'', l_sql_errm); ');
7998: l(' END IF; ');
7999: l(' END IF; ');
8000: l(' END LOOP; ');

Line 8423: l(' FROM HZ_ORG_CONTACTS oc, HZ_DQM_SYNC_INTERFACE d, ');

8419: l(' , H_TX'||I||'(1)');
8420: END IF;
8421: END LOOP;
8422:
8423: l(' FROM HZ_ORG_CONTACTS oc, HZ_DQM_SYNC_INTERFACE d, ');
8424: l(' HZ_RELATIONSHIPS r, HZ_PERSON_PROFILES pp');
8425: l(' WHERE d.ENTITY = ''CONTACTS'' ');
8426: l(' AND oc.org_contact_id = p_org_contact_id');
8427: l(' AND oc.org_contact_id = d.RECORD_ID');

Line 8735: l(' -- FAILOVER : REPORT RECORD TO HZ_DQM_SYNC_INTERFACE ');

8731: l('');
8732: -- Fix for Bug 4862121.
8733: -- Added the Exception handling at this context, for the procedure.
8734: l(' EXCEPTION WHEN OTHERS THEN ');
8735: l(' -- FAILOVER : REPORT RECORD TO HZ_DQM_SYNC_INTERFACE ');
8736: l(' -- FOR ONLINE FLOWS ');
8737: l(' l_sql_err_message := SQLERRM; ');
8738: l(' insert_dqm_sync_error_rec(l_party_id, p_org_contact_id, NULL, NULL, ''CONTACTS'', p_operation, ''E'', ''Y'', l_sql_err_message); ');
8739: l(' END;');

Line 9069: l(' FROM HZ_DQM_SYNC_INTERFACE dsi,HZ_CONTACT_POINTS cp');

9065: l(' ,' || l_select(I));
9066: END IF;
9067: END LOOP;
9068:
9069: l(' FROM HZ_DQM_SYNC_INTERFACE dsi,HZ_CONTACT_POINTS cp');
9070: l(' WHERE dsi.record_id = cp.contact_point_id ');
9071: l(' AND dsi.entity = ''CONTACT_POINTS'' ');
9072: l(' AND dsi.operation = p_operation ');
9073: l(' AND dsi.staged_flag = ''N'' ');

Line 9218: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''CONTACT_POINTS'' AND OPERATION=''C'' AND RECORD_ID=H_CONTACT_POINT_ID(l_err_index); ');

9214: -- SCHITRAP: Bug:5357970 - Error code is a number. Oracle error for ''DUP_VAL_ON_INDEX'' is ORA-00001
9215: --l(' IF (SQL%BULK_EXCEPTIONS(indx).ERROR_CODE) = ''DUP_VAL_ON_INDEX'' THEN ');
9216: l(' IF (instr(l_sql_errm,''ORA-00001'')>0) THEN ');
9217: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting a Contact Point with CONTACT_POINT_ID - ''||H_CONTACT_POINT_ID(l_err_index)); ');
9218: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''CONTACT_POINTS'' AND OPERATION=''C'' AND RECORD_ID=H_CONTACT_POINT_ID(l_err_index); ');
9219: l(' ELSE ');
9220: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
9221: l(' UPDATE hz_dqm_sync_interface ');
9222: l(' SET error_data = l_sql_errm ');

Line 9221: l(' UPDATE hz_dqm_sync_interface ');

9217: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting a Contact Point with CONTACT_POINT_ID - ''||H_CONTACT_POINT_ID(l_err_index)); ');
9218: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''CONTACT_POINTS'' AND OPERATION=''C'' AND RECORD_ID=H_CONTACT_POINT_ID(l_err_index); ');
9219: l(' ELSE ');
9220: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
9221: l(' UPDATE hz_dqm_sync_interface ');
9222: l(' SET error_data = l_sql_errm ');
9223: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
9224: l(' WHERE rowid = H_ROWID(l_err_index); ');
9225: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');

Line 9226: l(' -- Insert the Error Record into HZ_DQM_SYNC_INTERFACE table ');

9222: l(' SET error_data = l_sql_errm ');
9223: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
9224: l(' WHERE rowid = H_ROWID(l_err_index); ');
9225: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');
9226: l(' -- Insert the Error Record into HZ_DQM_SYNC_INTERFACE table ');
9227: l(' insert_dqm_sync_error_rec(H_CPT_PARTY_ID(l_err_index), H_CONTACT_POINT_ID(l_err_index), H_CPT_PARTY_SITE_ID(l_err_index), H_CPT_ORG_CONTACT_ID(l_err_index), ''CONTACT_POINTS'', p_operation, ''E'', ''N'', l_sql_errm); ');
9228: l(' END IF; ');
9229: l(' END IF; ');
9230: l(' END LOOP; ');

Line 9261: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''CONTACT_POINTS'' AND OPERATION=''U'' AND RECORD_ID=H_CONTACT_POINT_ID(l_err_index); ');

9257: -- SCHITRAP: Bug:5357970 - Error code is a number. Oracle error for ''DUP_VAL_ON_INDEX'' is ORA-00001
9258: --l(' IF (SQL%BULK_EXCEPTIONS(indx).ERROR_CODE) = ''DUP_VAL_ON_INDEX'' THEN ');
9259: l(' IF (instr(l_sql_errm,''ORA-00001'')>0) THEN ');
9260: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting a Contact Point with CONTACT_POINT_ID - ''||H_CONTACT_POINT_ID(l_err_index)); ');
9261: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''CONTACT_POINTS'' AND OPERATION=''U'' AND RECORD_ID=H_CONTACT_POINT_ID(l_err_index); ');
9262: l(' ELSE ');
9263: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
9264: l(' UPDATE hz_dqm_sync_interface ');
9265: l(' SET error_data = l_sql_errm ');

Line 9264: l(' UPDATE hz_dqm_sync_interface ');

9260: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting a Contact Point with CONTACT_POINT_ID - ''||H_CONTACT_POINT_ID(l_err_index)); ');
9261: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''CONTACT_POINTS'' AND OPERATION=''U'' AND RECORD_ID=H_CONTACT_POINT_ID(l_err_index); ');
9262: l(' ELSE ');
9263: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
9264: l(' UPDATE hz_dqm_sync_interface ');
9265: l(' SET error_data = l_sql_errm ');
9266: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
9267: l(' WHERE rowid = H_ROWID(l_err_index); ');
9268: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');

Line 9269: l(' -- Insert the Error Record into HZ_DQM_SYNC_INTERFACE table ');

9265: l(' SET error_data = l_sql_errm ');
9266: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
9267: l(' WHERE rowid = H_ROWID(l_err_index); ');
9268: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');
9269: l(' -- Insert the Error Record into HZ_DQM_SYNC_INTERFACE table ');
9270: l(' insert_dqm_sync_error_rec(H_CPT_PARTY_ID(l_err_index), H_CONTACT_POINT_ID(l_err_index), H_CPT_PARTY_SITE_ID(l_err_index), H_CPT_ORG_CONTACT_ID(l_err_index), ''CONTACT_POINTS'', p_operation, ''E'', ''N'', l_sql_errm); ');
9271: l(' END IF; ');
9272: l(' END IF; ');
9273: l(' END LOOP; ');

Line 9701: l(' FROM HZ_CONTACT_POINTS cp, HZ_DQM_SYNC_INTERFACE d ');

9697: l_custom_list(I) = 'N' THEN
9698: l(' , H_TX'||I||'(1)');
9699: END IF;
9700: END LOOP;
9701: l(' FROM HZ_CONTACT_POINTS cp, HZ_DQM_SYNC_INTERFACE d ');
9702: l(' WHERE d.ENTITY = ''CONTACT_POINTS'' ');
9703: l(' AND cp.contact_point_id = p_contact_point_id ');
9704: l(' AND cp.contact_point_id = d.RECORD_ID ');
9705: l(' AND (cp.status is null OR cp.status = ''A'' or cp.status = ''I'') and rownum = 1 ; ');

Line 10061: l(' -- FAILOVER : REPORT RECORD TO HZ_DQM_SYNC_INTERFACE ');

10057: l('');
10058: -- Fix for Bug 4862121.
10059: -- Added the Exception handling at this context, for the procedure.
10060: l(' EXCEPTION WHEN OTHERS THEN ');
10061: l(' -- FAILOVER : REPORT RECORD TO HZ_DQM_SYNC_INTERFACE ');
10062: l(' -- FOR ONLINE FLOWS ');
10063: l(' l_sql_err_message := SQLERRM; ');
10064: l(' insert_dqm_sync_error_rec(l_party_id, p_contact_point_id, l_party_site_id, l_org_contact_id, ''CONTACT_POINTS'', p_operation, ''E'', ''Y'', l_sql_err_message); ');
10065: l(' END;');