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 1354: CURSOR c_sync is select 1 from hz_dqm_sync_interface where staged_flag <> 'E' and rownum=1;

1350: l_workers_completed boolean;
1351: --End of Bug No: 4292425
1352: --Start of Bug 4915282
1353: l_realtime_sync_value VARCHAR2(15);
1354: CURSOR c_sync is select 1 from hz_dqm_sync_interface where staged_flag <> 'E' and rownum=1;
1355: l_sync_count NUMBER;
1356: l_profile_save boolean;
1357: --End of Bug 4915282
1358: BEGIN

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

2769: COMMIT;
2770:
2771: END IF;*/
2772:
2773: DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE mod(PARTY_ID,l_num_workers) = l_worker_number
2774: AND creation_date<=l_startdate;
2775:
2776: ELSE
2777: log('Updating Organization Party Records');

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

4763:
4764: END;
4765:
4766: -- REPURI added this procedure for generating a procedure to
4767: -- insert errored records into HZ_DQM_SYNC_INTERFACE table.
4768:
4769: PROCEDURE generate_ins_dqm_sync_err_rec IS
4770:
4771: BEGIN

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

4781: l(' p_realtime_sync_flag IN VARCHAR2 DEFAULT ''Y'', ');
4782: l(' p_error_data IN VARCHAR2 ');
4783: l(' ) IS ');
4784: l(' BEGIN ');
4785: l(' INSERT INTO hz_dqm_sync_interface ( ');
4786: l(' PARTY_ID, ');
4787: l(' RECORD_ID, ');
4788: l(' PARTY_SITE_ID, ');
4789: l(' ORG_CONTACT_ID, ');

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

4812: l(' hz_utility_pub.creation_date, ');
4813: l(' hz_utility_pub.last_update_login, ');
4814: l(' hz_utility_pub.last_update_date, ');
4815: l(' hz_utility_pub.user_id, ');
4816: l(' HZ_DQM_SYNC_INTERFACE_S.nextval ');
4817: l(' ); ');
4818: l(' END insert_dqm_sync_error_rec; ');
4819: l('');
4820:

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

5205: l(' ,' || l_org_select(I));
5206: END IF;
5207: END LOOP;
5208:
5209: l(' FROM HZ_PARTIES p, HZ_ORGANIZATION_PROFILES op, HZ_DQM_SYNC_INTERFACE dsi ');
5210: l(' WHERE p.party_id = op.party_id ');
5211: l(' AND p.party_id = dsi.party_id ');
5212: l(' AND p.PARTY_TYPE = ''ORGANIZATION'' ');
5213: l(' AND dsi.entity = ''PARTY'' ');

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

5225: l(' ,' || l_per_select(I));
5226: END IF;
5227: END LOOP;
5228:
5229: l(' FROM HZ_PARTIES p, HZ_PERSON_PROFILES pe, HZ_DQM_SYNC_INTERFACE dsi ');
5230: l(' WHERE p.party_id = pe.party_id ');
5231: l(' AND p.party_id = dsi.party_id ');
5232: l(' AND p.PARTY_TYPE = ''PERSON'' ');
5233: l(' AND dsi.entity = ''PARTY'' ');

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

5245: l(' ,' || l_oth_select(I));
5246: END IF;
5247: END LOOP;
5248:
5249: l(' FROM HZ_PARTIES p, HZ_DQM_SYNC_INTERFACE dsi ');
5250: l(' WHERE p.party_id = dsi.party_id ');
5251: l(' AND dsi.entity = ''PARTY'' ');
5252: l(' AND dsi.staged_flag = ''N'' ');
5253: l(' AND dsi.operation = p_operation ');

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

5394: -- SCHITRAP: Bug:5357970 - Error code is a number. Oracle error for ''DUP_VAL_ON_INDEX'' is ORA-00001
5395: --l(' IF (SQL%BULK_EXCEPTIONS(indx).ERROR_CODE) = ''DUP_VAL_ON_INDEX'' THEN ');
5396: l(' IF (instr(l_sql_errm,''ORA-00001'')>0) THEN ');
5397: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting Party with PARTY_ID - ''||H_P_PARTY_ID(l_err_index)); ');
5398: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''PARTY'' AND OPERATION=''C'' AND PARTY_ID=H_P_PARTY_ID(l_err_index); ');
5399: l(' ELSE ');
5400: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
5401: l(' UPDATE hz_dqm_sync_interface ');
5402: l(' SET error_data = l_sql_errm ');

Line 5401: l(' UPDATE hz_dqm_sync_interface ');

5397: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting Party with PARTY_ID - ''||H_P_PARTY_ID(l_err_index)); ');
5398: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''PARTY'' AND OPERATION=''C'' AND PARTY_ID=H_P_PARTY_ID(l_err_index); ');
5399: l(' ELSE ');
5400: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
5401: l(' UPDATE hz_dqm_sync_interface ');
5402: l(' SET error_data = l_sql_errm ');
5403: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
5404: l(' WHERE rowid = H_ROWID(l_err_index); ');
5405: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');

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

5402: l(' SET error_data = l_sql_errm ');
5403: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
5404: l(' WHERE rowid = H_ROWID(l_err_index); ');
5405: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');
5406: l(' -- Insert the Error Record into HZ_DQM_SYNC_INTERFACE table ');
5407: l(' insert_dqm_sync_error_rec(H_P_PARTY_ID(l_err_index), NULL, NULL, NULL, ''PARTY'', p_operation, ''E'', ''N'', l_sql_errm); ');
5408: l(' END IF; ');
5409: l(' END IF; ');
5410: l(' END LOOP; ');

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

5433: -- SCHITRAP: Bug:5357970 - Error code is a number. Oracle error for ''DUP_VAL_ON_INDEX'' is ORA-00001
5434: --l(' IF (SQL%BULK_EXCEPTIONS(indx).ERROR_CODE) = ''DUP_VAL_ON_INDEX'' THEN ');
5435: l(' IF (instr(l_sql_errm,''ORA-00001'')>0) THEN ');
5436: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting Party with PARTY_ID - ''||H_P_PARTY_ID(l_err_index)); ');
5437: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''PARTY'' AND OPERATION=''U'' AND PARTY_ID=H_P_PARTY_ID(l_err_index); ');
5438: l(' ELSE ');
5439: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
5440: l(' UPDATE hz_dqm_sync_interface ');
5441: l(' SET error_data = l_sql_errm ');

Line 5440: l(' UPDATE hz_dqm_sync_interface ');

5436: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting Party with PARTY_ID - ''||H_P_PARTY_ID(l_err_index)); ');
5437: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''PARTY'' AND OPERATION=''U'' AND PARTY_ID=H_P_PARTY_ID(l_err_index); ');
5438: l(' ELSE ');
5439: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
5440: l(' UPDATE hz_dqm_sync_interface ');
5441: l(' SET error_data = l_sql_errm ');
5442: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
5443: l(' WHERE rowid = H_ROWID(l_err_index); ');
5444: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');

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

5441: l(' SET error_data = l_sql_errm ');
5442: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
5443: l(' WHERE rowid = H_ROWID(l_err_index); ');
5444: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');
5445: l(' -- Insert the Error Record into HZ_DQM_SYNC_INTERFACE table ');
5446: l(' insert_dqm_sync_error_rec(H_P_PARTY_ID(l_err_index), NULL, NULL, NULL, ''PARTY'', p_operation, ''E'', ''N'', l_sql_errm); ');
5447: l(' END IF; ');
5448: l(' END IF; ');
5449: l(' END LOOP; ');

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

6152: l(' EXIT WHEN c_contact%NOTFOUND; ');
6153: l(' BEGIN ');
6154: l(' sync_single_contact_online(l_org_contact_id, p_operation); ');
6155: l(' EXCEPTION WHEN OTHERS THEN ');
6156: l(' -- FAILOVER : REPORT RECORD TO HZ_DQM_SYNC_INTERFACE ');
6157: l(' -- FOR ONLINE FLOWS ');
6158: l(' l_sql_err_message := SQLERRM; ');
6159: l(' insert_dqm_sync_error_rec(p_party_id,l_org_contact_id,null,null,''CONTACTS'',''U'',''E'',''Y'', l_sql_err_message); ');
6160: l(' END ; ');

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

6337: l('');
6338: -- Fix for Bug 4862121.
6339: -- Added the Exception handling at this context, for the procedure.
6340: l(' EXCEPTION WHEN OTHERS THEN ');
6341: l(' -- FAILOVER : REPORT RECORD TO HZ_DQM_SYNC_INTERFACE ');
6342: l(' -- FOR ONLINE FLOWS ');
6343: l(' l_sql_err_message := SQLERRM; ');
6344: l(' insert_dqm_sync_error_rec(p_party_id, NULL, NULL, NULL, ''PARTY'', p_operation, ''E'', ''Y'', l_sql_err_message); ');
6345: l(' END;');

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

6640: l(' ,' || l_select(I));
6641: END IF;
6642: END LOOP;
6643:
6644: l(' FROM HZ_DQM_SYNC_INTERFACE dsi, HZ_PARTY_SITES ps, HZ_LOCATIONS l');
6645: l(' WHERE dsi.record_id = ps.party_site_id ');
6646: l(' AND dsi.entity = ''PARTY_SITES'' ');
6647: l(' AND dsi.operation = p_operation ');
6648: l(' AND dsi.staged_flag = ''N'' ');

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

6786: -- SCHITRAP: Bug:5357970 - Error code is a number. Oracle error for ''DUP_VAL_ON_INDEX'' is ORA-00001
6787: --l(' IF (SQL%BULK_EXCEPTIONS(indx).ERROR_CODE) = ''DUP_VAL_ON_INDEX'' THEN ');
6788: l(' IF (instr(l_sql_errm,''ORA-00001'')>0) THEN ');
6789: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting Party Site with PARTY_SITE_ID - ''||H_PARTY_SITE_ID(l_err_index)); ');
6790: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''PARTY_SITES'' AND OPERATION=''C'' AND RECORD_ID=H_PARTY_SITE_ID(l_err_index); ');
6791: l(' ELSE ');
6792: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
6793: l(' UPDATE hz_dqm_sync_interface ');
6794: l(' SET error_data = l_sql_errm ');

Line 6793: l(' UPDATE hz_dqm_sync_interface ');

6789: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting Party Site with PARTY_SITE_ID - ''||H_PARTY_SITE_ID(l_err_index)); ');
6790: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''PARTY_SITES'' AND OPERATION=''C'' AND RECORD_ID=H_PARTY_SITE_ID(l_err_index); ');
6791: l(' ELSE ');
6792: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
6793: l(' UPDATE hz_dqm_sync_interface ');
6794: l(' SET error_data = l_sql_errm ');
6795: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
6796: l(' WHERE rowid = H_ROWID(l_err_index); ');
6797: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');

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

6794: l(' SET error_data = l_sql_errm ');
6795: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
6796: l(' WHERE rowid = H_ROWID(l_err_index); ');
6797: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');
6798: l(' -- Insert the Error Record into HZ_DQM_SYNC_INTERFACE table ');
6799: 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); ');
6800: l(' END IF; ');
6801: l(' END IF; ');
6802: l(' END LOOP; ');

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

6829: -- SCHITRAP: Bug:5357970 - Error code is a number. Oracle error for ''DUP_VAL_ON_INDEX'' is ORA-00001
6830: --l(' IF (SQL%BULK_EXCEPTIONS(indx).ERROR_CODE) = ''DUP_VAL_ON_INDEX'' THEN ');
6831: l(' IF (instr(l_sql_errm,''ORA-00001'')>0) THEN ');
6832: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting Party Site with PARTY_SITE_ID - ''||H_PARTY_SITE_ID(l_err_index)); ');
6833: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''PARTY_SITES'' AND OPERATION=''U'' AND RECORD_ID=H_PARTY_SITE_ID(l_err_index); ');
6834: l(' ELSE ');
6835: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
6836: l(' UPDATE hz_dqm_sync_interface ');
6837: l(' SET error_data = l_sql_errm ');

Line 6836: l(' UPDATE hz_dqm_sync_interface ');

6832: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting Party Site with PARTY_SITE_ID - ''||H_PARTY_SITE_ID(l_err_index)); ');
6833: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''PARTY_SITES'' AND OPERATION=''U'' AND RECORD_ID=H_PARTY_SITE_ID(l_err_index); ');
6834: l(' ELSE ');
6835: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
6836: l(' UPDATE hz_dqm_sync_interface ');
6837: l(' SET error_data = l_sql_errm ');
6838: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
6839: l(' WHERE rowid = H_ROWID(l_err_index); ');
6840: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');

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

6837: l(' SET error_data = l_sql_errm ');
6838: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
6839: l(' WHERE rowid = H_ROWID(l_err_index); ');
6840: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');
6841: l(' -- Insert the Error Record into HZ_DQM_SYNC_INTERFACE table ');
6842: 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); ');
6843: l(' END IF; ');
6844: l(' END IF; ');
6845: l(' END LOOP; ');

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

7264: l_custom_list(I) = 'N' THEN
7265: l(' , H_TX'||I||'(1)');
7266: END IF;
7267: END LOOP;
7268: l(' FROM HZ_PARTY_SITES ps, HZ_DQM_SYNC_INTERFACE d, HZ_LOCATIONS l ');
7269: l(' WHERE d.ENTITY=''PARTY_SITES'' ');
7270: l(' AND ps.party_site_id = p_party_site_id');
7271: l(' AND d.record_id = ps.party_site_id ');
7272: l(' AND ps.location_id = l.location_id ');

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

7593: l('');
7594: -- Fix for Bug 4862121.
7595: -- Added the Exception handling at this context, for the procedure.
7596: l(' EXCEPTION WHEN OTHERS THEN ');
7597: l(' -- FAILOVER : REPORT RECORD TO HZ_DQM_SYNC_INTERFACE ');
7598: l(' -- FOR ONLINE FLOWS ');
7599: l(' l_sql_err_message := SQLERRM; ');
7600: 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); ');
7601: l(' END;');

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

7946: l(' ,' || l_select(I));
7947: END IF;
7948: END LOOP;
7949:
7950: l(' FROM HZ_DQM_SYNC_INTERFACE dsi, HZ_RELATIONSHIPS r,');
7951: l(' HZ_ORG_CONTACTS oc, HZ_PERSON_PROFILES pp');
7952: l(' WHERE oc.party_relationship_id = r.relationship_id ');
7953: l(' AND dsi.record_id = oc.org_contact_id ');
7954: l(' AND r.subject_id = pp.party_id ');

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

8095: -- SCHITRAP: Bug:5357970 - Error code is a number. Oracle error for ''DUP_VAL_ON_INDEX'' is ORA-00001
8096: --l(' IF (SQL%BULK_EXCEPTIONS(indx).ERROR_CODE) = ''DUP_VAL_ON_INDEX'' THEN ');
8097: l(' IF (instr(l_sql_errm,''ORA-00001'')>0) THEN ');
8098: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting a Contact with ORG_CONTACT_ID - ''||H_ORG_CONTACT_ID(l_err_index)); ');
8099: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''CONTACTS'' AND OPERATION=''C'' AND RECORD_ID=H_ORG_CONTACT_ID(l_err_index); ');
8100: l(' ELSE ');
8101: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
8102: l(' UPDATE hz_dqm_sync_interface ');
8103: l(' SET error_data = l_sql_errm ');

Line 8102: l(' UPDATE hz_dqm_sync_interface ');

8098: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting a Contact with ORG_CONTACT_ID - ''||H_ORG_CONTACT_ID(l_err_index)); ');
8099: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''CONTACTS'' AND OPERATION=''C'' AND RECORD_ID=H_ORG_CONTACT_ID(l_err_index); ');
8100: l(' ELSE ');
8101: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
8102: l(' UPDATE hz_dqm_sync_interface ');
8103: l(' SET error_data = l_sql_errm ');
8104: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
8105: l(' WHERE rowid = H_ROWID(l_err_index); ');
8106: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');

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

8103: l(' SET error_data = l_sql_errm ');
8104: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
8105: l(' WHERE rowid = H_ROWID(l_err_index); ');
8106: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');
8107: l(' -- Insert the Error Record into HZ_DQM_SYNC_INTERFACE table ');
8108: 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); ');
8109: l(' END IF; ');
8110: l(' END IF; ');
8111: l(' END LOOP; ');

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

8138: -- SCHITRAP: Bug:5357970 - Error code is a number. Oracle error for ''DUP_VAL_ON_INDEX'' is ORA-00001
8139: --l(' IF (SQL%BULK_EXCEPTIONS(indx).ERROR_CODE) = ''DUP_VAL_ON_INDEX'' THEN ');
8140: l(' IF (instr(l_sql_errm,''ORA-00001'')>0) THEN ');
8141: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting a Contact with ORG_CONTACT_ID - ''||H_ORG_CONTACT_ID(l_err_index)); ');
8142: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''CONTACTS'' AND OPERATION=''U'' AND RECORD_ID=H_ORG_CONTACT_ID(l_err_index); ');
8143: l(' ELSE ');
8144: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
8145: l(' UPDATE hz_dqm_sync_interface ');
8146: l(' SET error_data = l_sql_errm ');

Line 8145: l(' UPDATE hz_dqm_sync_interface ');

8141: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting a Contact with ORG_CONTACT_ID - ''||H_ORG_CONTACT_ID(l_err_index)); ');
8142: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''CONTACTS'' AND OPERATION=''U'' AND RECORD_ID=H_ORG_CONTACT_ID(l_err_index); ');
8143: l(' ELSE ');
8144: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
8145: l(' UPDATE hz_dqm_sync_interface ');
8146: l(' SET error_data = l_sql_errm ');
8147: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
8148: l(' WHERE rowid = H_ROWID(l_err_index); ');
8149: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');

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

8146: l(' SET error_data = l_sql_errm ');
8147: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
8148: l(' WHERE rowid = H_ROWID(l_err_index); ');
8149: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');
8150: l(' -- Insert the Error Record into HZ_DQM_SYNC_INTERFACE table ');
8151: 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); ');
8152: l(' END IF; ');
8153: l(' END IF; ');
8154: l(' END LOOP; ');

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

8573: l(' , H_TX'||I||'(1)');
8574: END IF;
8575: END LOOP;
8576:
8577: l(' FROM HZ_ORG_CONTACTS oc, HZ_DQM_SYNC_INTERFACE d, ');
8578: l(' HZ_RELATIONSHIPS r, HZ_PERSON_PROFILES pp');
8579: l(' WHERE d.ENTITY = ''CONTACTS'' ');
8580: l(' AND oc.org_contact_id = p_org_contact_id');
8581: l(' AND oc.org_contact_id = d.RECORD_ID');

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

8885: l('');
8886: -- Fix for Bug 4862121.
8887: -- Added the Exception handling at this context, for the procedure.
8888: l(' EXCEPTION WHEN OTHERS THEN ');
8889: l(' -- FAILOVER : REPORT RECORD TO HZ_DQM_SYNC_INTERFACE ');
8890: l(' -- FOR ONLINE FLOWS ');
8891: l(' l_sql_err_message := SQLERRM; ');
8892: l(' insert_dqm_sync_error_rec(l_party_id, p_org_contact_id, NULL, NULL, ''CONTACTS'', p_operation, ''E'', ''Y'', l_sql_err_message); ');
8893: l(' END;');

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

9219: l(' ,' || l_select(I));
9220: END IF;
9221: END LOOP;
9222:
9223: l(' FROM HZ_DQM_SYNC_INTERFACE dsi,HZ_CONTACT_POINTS cp');
9224: l(' WHERE dsi.record_id = cp.contact_point_id ');
9225: l(' AND dsi.entity = ''CONTACT_POINTS'' ');
9226: l(' AND dsi.operation = p_operation ');
9227: l(' AND dsi.staged_flag = ''N'' ');

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

9368: -- SCHITRAP: Bug:5357970 - Error code is a number. Oracle error for ''DUP_VAL_ON_INDEX'' is ORA-00001
9369: --l(' IF (SQL%BULK_EXCEPTIONS(indx).ERROR_CODE) = ''DUP_VAL_ON_INDEX'' THEN ');
9370: l(' IF (instr(l_sql_errm,''ORA-00001'')>0) THEN ');
9371: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting a Contact Point with CONTACT_POINT_ID - ''||H_CONTACT_POINT_ID(l_err_index)); ');
9372: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''CONTACT_POINTS'' AND OPERATION=''C'' AND RECORD_ID=H_CONTACT_POINT_ID(l_err_index); ');
9373: l(' ELSE ');
9374: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
9375: l(' UPDATE hz_dqm_sync_interface ');
9376: l(' SET error_data = l_sql_errm ');

Line 9375: l(' UPDATE hz_dqm_sync_interface ');

9371: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting a Contact Point with CONTACT_POINT_ID - ''||H_CONTACT_POINT_ID(l_err_index)); ');
9372: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''CONTACT_POINTS'' AND OPERATION=''C'' AND RECORD_ID=H_CONTACT_POINT_ID(l_err_index); ');
9373: l(' ELSE ');
9374: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
9375: l(' UPDATE hz_dqm_sync_interface ');
9376: l(' SET error_data = l_sql_errm ');
9377: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
9378: l(' WHERE rowid = H_ROWID(l_err_index); ');
9379: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');

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

9376: l(' SET error_data = l_sql_errm ');
9377: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
9378: l(' WHERE rowid = H_ROWID(l_err_index); ');
9379: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');
9380: l(' -- Insert the Error Record into HZ_DQM_SYNC_INTERFACE table ');
9381: 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); ');
9382: l(' END IF; ');
9383: l(' END IF; ');
9384: l(' END LOOP; ');

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

9411: -- SCHITRAP: Bug:5357970 - Error code is a number. Oracle error for ''DUP_VAL_ON_INDEX'' is ORA-00001
9412: --l(' IF (SQL%BULK_EXCEPTIONS(indx).ERROR_CODE) = ''DUP_VAL_ON_INDEX'' THEN ');
9413: l(' IF (instr(l_sql_errm,''ORA-00001'')>0) THEN ');
9414: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting a Contact Point with CONTACT_POINT_ID - ''||H_CONTACT_POINT_ID(l_err_index)); ');
9415: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''CONTACT_POINTS'' AND OPERATION=''U'' AND RECORD_ID=H_CONTACT_POINT_ID(l_err_index); ');
9416: l(' ELSE ');
9417: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
9418: l(' UPDATE hz_dqm_sync_interface ');
9419: l(' SET error_data = l_sql_errm ');

Line 9418: l(' UPDATE hz_dqm_sync_interface ');

9414: l(' log (''Exception DUP_VAL_ON_INDEX occured while inserting a Contact Point with CONTACT_POINT_ID - ''||H_CONTACT_POINT_ID(l_err_index)); ');
9415: l(' DELETE FROM HZ_DQM_SYNC_INTERFACE WHERE ENTITY=''CONTACT_POINTS'' AND OPERATION=''U'' AND RECORD_ID=H_CONTACT_POINT_ID(l_err_index); ');
9416: l(' ELSE ');
9417: l(' IF p_bulk_sync_type = ''DQM_SYNC'' THEN ');
9418: l(' UPDATE hz_dqm_sync_interface ');
9419: l(' SET error_data = l_sql_errm ');
9420: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
9421: l(' WHERE rowid = H_ROWID(l_err_index); ');
9422: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');

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

9419: l(' SET error_data = l_sql_errm ');
9420: l(' ,staged_flag = decode (error_data, NULL, ''N'', ''E'') ');
9421: l(' WHERE rowid = H_ROWID(l_err_index); ');
9422: l(' ELSIF p_bulk_sync_type = ''IMPORT_SYNC'' THEN ');
9423: l(' -- Insert the Error Record into HZ_DQM_SYNC_INTERFACE table ');
9424: 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); ');
9425: l(' END IF; ');
9426: l(' END IF; ');
9427: l(' END LOOP; ');

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

9851: l_custom_list(I) = 'N' THEN
9852: l(' , H_TX'||I||'(1)');
9853: END IF;
9854: END LOOP;
9855: l(' FROM HZ_CONTACT_POINTS cp, HZ_DQM_SYNC_INTERFACE d ');
9856: l(' WHERE d.ENTITY = ''CONTACT_POINTS'' ');
9857: l(' AND cp.contact_point_id = p_contact_point_id ');
9858: l(' AND cp.contact_point_id = d.RECORD_ID ');
9859: l(' AND (cp.status is null OR cp.status = ''A'' or cp.status = ''I'') and rownum = 1 ; ');

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

10211: l('');
10212: -- Fix for Bug 4862121.
10213: -- Added the Exception handling at this context, for the procedure.
10214: l(' EXCEPTION WHEN OTHERS THEN ');
10215: l(' -- FAILOVER : REPORT RECORD TO HZ_DQM_SYNC_INTERFACE ');
10216: l(' -- FOR ONLINE FLOWS ');
10217: l(' l_sql_err_message := SQLERRM; ');
10218: 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); ');
10219: l(' END;');