181: )
182: FOR UPDATE NOWAIT;
183:
184: BEGIN
185: arp_message.set_line('OKC_HZ_MERGE_PUB.LOCK_TABLES()+');
186:
187: -- party roles for accounts
188: arp_message.set_name('AR','AR_LOCKING_TABLE');
189: arp_message.set_token('TABLE_NAME','OKC_K_PARTY_ROLES_B',FALSE);
184: BEGIN
185: arp_message.set_line('OKC_HZ_MERGE_PUB.LOCK_TABLES()+');
186:
187: -- party roles for accounts
188: arp_message.set_name('AR','AR_LOCKING_TABLE');
189: arp_message.set_token('TABLE_NAME','OKC_K_PARTY_ROLES_B',FALSE);
190: arp_message.set_line('Locking for accounts');
191: open c_lock_kpr(c_account);
192: close c_lock_kpr;
185: arp_message.set_line('OKC_HZ_MERGE_PUB.LOCK_TABLES()+');
186:
187: -- party roles for accounts
188: arp_message.set_name('AR','AR_LOCKING_TABLE');
189: arp_message.set_token('TABLE_NAME','OKC_K_PARTY_ROLES_B',FALSE);
190: arp_message.set_line('Locking for accounts');
191: open c_lock_kpr(c_account);
192: close c_lock_kpr;
193:
186:
187: -- party roles for accounts
188: arp_message.set_name('AR','AR_LOCKING_TABLE');
189: arp_message.set_token('TABLE_NAME','OKC_K_PARTY_ROLES_B',FALSE);
190: arp_message.set_line('Locking for accounts');
191: open c_lock_kpr(c_account);
192: close c_lock_kpr;
193:
194: arp_message.set_line('Locking for site uses');
190: arp_message.set_line('Locking for accounts');
191: open c_lock_kpr(c_account);
192: close c_lock_kpr;
193:
194: arp_message.set_line('Locking for site uses');
195: open c_lock_kpr(c_c_site_use); -- added for bug 3950642
196: close c_lock_kpr;
197:
198: -- rules for accounts
195: open c_lock_kpr(c_c_site_use); -- added for bug 3950642
196: close c_lock_kpr;
197:
198: -- rules for accounts
199: arp_message.set_name('AR','AR_LOCKING_TABLE');
200: arp_message.set_token('TABLE_NAME','OKC_RULES_B',FALSE);
201: arp_message.set_line('Locking for accounts');
202: open c_lock_rle1(c_account);
203: close c_lock_rle1;
196: close c_lock_kpr;
197:
198: -- rules for accounts
199: arp_message.set_name('AR','AR_LOCKING_TABLE');
200: arp_message.set_token('TABLE_NAME','OKC_RULES_B',FALSE);
201: arp_message.set_line('Locking for accounts');
202: open c_lock_rle1(c_account);
203: close c_lock_rle1;
204: open c_lock_rle2(c_account);
197:
198: -- rules for accounts
199: arp_message.set_name('AR','AR_LOCKING_TABLE');
200: arp_message.set_token('TABLE_NAME','OKC_RULES_B',FALSE);
201: arp_message.set_line('Locking for accounts');
202: open c_lock_rle1(c_account);
203: close c_lock_rle1;
204: open c_lock_rle2(c_account);
205: close c_lock_rle2;
206: open c_lock_rle3(c_account);
207: close c_lock_rle3;
208:
209: -- rules for sites
210: arp_message.set_name('AR','AR_LOCKING_TABLE');
211: arp_message.set_token('TABLE_NAME','OKC_RULES_B',FALSE);
212: arp_message.set_line('Locking for sites');
213: open c_lock_rle1(c_c_site);
214: close c_lock_rle1;
207: close c_lock_rle3;
208:
209: -- rules for sites
210: arp_message.set_name('AR','AR_LOCKING_TABLE');
211: arp_message.set_token('TABLE_NAME','OKC_RULES_B',FALSE);
212: arp_message.set_line('Locking for sites');
213: open c_lock_rle1(c_c_site);
214: close c_lock_rle1;
215: open c_lock_rle2(c_c_site);
208:
209: -- rules for sites
210: arp_message.set_name('AR','AR_LOCKING_TABLE');
211: arp_message.set_token('TABLE_NAME','OKC_RULES_B',FALSE);
212: arp_message.set_line('Locking for sites');
213: open c_lock_rle1(c_c_site);
214: close c_lock_rle1;
215: open c_lock_rle2(c_c_site);
216: close c_lock_rle2;
217: open c_lock_rle3(c_c_site);
218: close c_lock_rle3;
219:
220: -- rules for site uses
221: arp_message.set_name('AR','AR_LOCKING_TABLE');
222: arp_message.set_token('TABLE_NAME','OKC_RULES_B.OBJECT3_ID1',FALSE);
223: arp_message.set_line('Locking for site uses');
224: open c_lock_rle1(c_c_site_use);
225: close c_lock_rle1;
218: close c_lock_rle3;
219:
220: -- rules for site uses
221: arp_message.set_name('AR','AR_LOCKING_TABLE');
222: arp_message.set_token('TABLE_NAME','OKC_RULES_B.OBJECT3_ID1',FALSE);
223: arp_message.set_line('Locking for site uses');
224: open c_lock_rle1(c_c_site_use);
225: close c_lock_rle1;
226: open c_lock_rle2(c_c_site_use);
219:
220: -- rules for site uses
221: arp_message.set_name('AR','AR_LOCKING_TABLE');
222: arp_message.set_token('TABLE_NAME','OKC_RULES_B.OBJECT3_ID1',FALSE);
223: arp_message.set_line('Locking for site uses');
224: open c_lock_rle1(c_c_site_use);
225: close c_lock_rle1;
226: open c_lock_rle2(c_c_site_use);
227: close c_lock_rle2;
228: open c_lock_rle3(c_c_site_use);
229: close c_lock_rle3;
230:
231: -- items for accounts (covered level in OKS)
232: arp_message.set_name('AR','AR_LOCKING_TABLE');
233: arp_message.set_token('TABLE_NAME','OKC_K_ITEMS',FALSE);
234: arp_message.set_line('Locking for accounts');
235: open c_lock_cim(c_account);
236: close c_lock_cim;
229: close c_lock_rle3;
230:
231: -- items for accounts (covered level in OKS)
232: arp_message.set_name('AR','AR_LOCKING_TABLE');
233: arp_message.set_token('TABLE_NAME','OKC_K_ITEMS',FALSE);
234: arp_message.set_line('Locking for accounts');
235: open c_lock_cim(c_account);
236: close c_lock_cim;
237:
230:
231: -- items for accounts (covered level in OKS)
232: arp_message.set_name('AR','AR_LOCKING_TABLE');
233: arp_message.set_token('TABLE_NAME','OKC_K_ITEMS',FALSE);
234: arp_message.set_line('Locking for accounts');
235: open c_lock_cim(c_account);
236: close c_lock_cim;
237:
238: -- items for sites
235: open c_lock_cim(c_account);
236: close c_lock_cim;
237:
238: -- items for sites
239: arp_message.set_name('AR','AR_LOCKING_TABLE');
240: arp_message.set_token('TABLE_NAME','OKC_K_ITEMS',FALSE);
241: arp_message.set_line('Locking for sites');
242: open c_lock_cim(c_c_site);
243: close c_lock_cim;
236: close c_lock_cim;
237:
238: -- items for sites
239: arp_message.set_name('AR','AR_LOCKING_TABLE');
240: arp_message.set_token('TABLE_NAME','OKC_K_ITEMS',FALSE);
241: arp_message.set_line('Locking for sites');
242: open c_lock_cim(c_c_site);
243: close c_lock_cim;
244:
237:
238: -- items for sites
239: arp_message.set_name('AR','AR_LOCKING_TABLE');
240: arp_message.set_token('TABLE_NAME','OKC_K_ITEMS',FALSE);
241: arp_message.set_line('Locking for sites');
242: open c_lock_cim(c_c_site);
243: close c_lock_cim;
244:
245: -- items for site uses
242: open c_lock_cim(c_c_site);
243: close c_lock_cim;
244:
245: -- items for site uses
246: arp_message.set_name('AR','AR_LOCKING_TABLE');
247: arp_message.set_token('TABLE_NAME','OKC_K_ITEMS',FALSE);
248: arp_message.set_line('Locking for site uses');
249: open c_lock_cim(c_c_site_use);
250: close c_lock_cim;
243: close c_lock_cim;
244:
245: -- items for site uses
246: arp_message.set_name('AR','AR_LOCKING_TABLE');
247: arp_message.set_token('TABLE_NAME','OKC_K_ITEMS',FALSE);
248: arp_message.set_line('Locking for site uses');
249: open c_lock_cim(c_c_site_use);
250: close c_lock_cim;
251:
244:
245: -- items for site uses
246: arp_message.set_name('AR','AR_LOCKING_TABLE');
247: arp_message.set_token('TABLE_NAME','OKC_K_ITEMS',FALSE);
248: arp_message.set_line('Locking for site uses');
249: open c_lock_cim(c_c_site_use);
250: close c_lock_cim;
251:
252: arp_message.set_line('OKC_HZ_MERGE_PUB.LOCK_TABLES()-');
248: arp_message.set_line('Locking for site uses');
249: open c_lock_cim(c_c_site_use);
250: close c_lock_cim;
251:
252: arp_message.set_line('OKC_HZ_MERGE_PUB.LOCK_TABLES()-');
253: EXCEPTION
254: WHEN TIMEOUT_ON_RESOURCE THEN
255: arp_message.set_line('Could not obtain lock for records');
256: raise;
251:
252: arp_message.set_line('OKC_HZ_MERGE_PUB.LOCK_TABLES()-');
253: EXCEPTION
254: WHEN TIMEOUT_ON_RESOURCE THEN
255: arp_message.set_line('Could not obtain lock for records');
256: raise;
257: END; -- lock_tables
258:
259: --
394: l_log_party_id NUMBER;
395:
396: l_merge_not_allowed_excp EXCEPTION;
397: BEGIN
398: arp_message.set_line('OKC_HZ_MERGE_PUB.PARTY_MERGE()+');
399: arp_message.set_line('At the begining of Party Merge procedure');
400:
401: --
402: -- initialize the status to check whether any contract has more than one
395:
396: l_merge_not_allowed_excp EXCEPTION;
397: BEGIN
398: arp_message.set_line('OKC_HZ_MERGE_PUB.PARTY_MERGE()+');
399: arp_message.set_line('At the begining of Party Merge procedure');
400:
401: --
402: -- initialize the status to check whether any contract has more than one
403: -- account for the source party and one of the accounts is merged acount.
423: -- and one of the accounts is the merged account
424: OPEN c_header_info(l_chr_id);
425: FETCH c_header_info INTO l_contract_number, l_contract_number_modifier;
426: CLOSE c_header_info;
427: arp_message.set_line('Contract ' || l_contract_number || ' should be manually updated');
428:
429: EXIT;
430: END IF;
431: END LOOP; -- cursor c_rules
471: IF l_count > 0 THEN
472: OPEN c_header_info(l_chr_id);
473: FETCH c_header_info INTO l_contract_number, l_contract_number_modifier;
474: CLOSE c_header_info;
475: arp_message.set_line('Contract ' || l_contract_number || ' is updated');
476:
477: OPEN c_party_id_log(l_chr_id);
478: FETCH c_party_id_log INTO l_log_party_id;
479: CLOSE c_party_id_log;
549: CLOSE c_account_count;
550: END LOOP; -- cursor c_cpr
551: CLOSE c_cpr;
552:
553: arp_message.set_line('At the end of Party Merge procedure');
554: arp_message.set_line('OKC_HZ_MERGE_PUB.PARTY_MERGE()-');
555:
556: EXCEPTION
557: WHEN l_merge_not_allowed_excp THEN
550: END LOOP; -- cursor c_cpr
551: CLOSE c_cpr;
552:
553: arp_message.set_line('At the end of Party Merge procedure');
554: arp_message.set_line('OKC_HZ_MERGE_PUB.PARTY_MERGE()-');
555:
556: EXCEPTION
557: WHEN l_merge_not_allowed_excp THEN
558: arp_message.set_line('Contract exists for duplicate party with more than one account, merge cannot proceed');
554: arp_message.set_line('OKC_HZ_MERGE_PUB.PARTY_MERGE()-');
555:
556: EXCEPTION
557: WHEN l_merge_not_allowed_excp THEN
558: arp_message.set_line('Contract exists for duplicate party with more than one account, merge cannot proceed');
559: arp_message.set_line('Please update the above mentioned contracts and run customer merge again');
560: arp_message.set_error('OKC_HZ_MERGE_PUB.MERGE_ACCOUNT');
561: RAISE;
562:
555:
556: EXCEPTION
557: WHEN l_merge_not_allowed_excp THEN
558: arp_message.set_line('Contract exists for duplicate party with more than one account, merge cannot proceed');
559: arp_message.set_line('Please update the above mentioned contracts and run customer merge again');
560: arp_message.set_error('OKC_HZ_MERGE_PUB.MERGE_ACCOUNT');
561: RAISE;
562:
563: WHEN others THEN
556: EXCEPTION
557: WHEN l_merge_not_allowed_excp THEN
558: arp_message.set_line('Contract exists for duplicate party with more than one account, merge cannot proceed');
559: arp_message.set_line('Please update the above mentioned contracts and run customer merge again');
560: arp_message.set_error('OKC_HZ_MERGE_PUB.MERGE_ACCOUNT');
561: RAISE;
562:
563: WHEN others THEN
564: l_error_msg := substr(SQLERRM,1,70);
561: RAISE;
562:
563: WHEN others THEN
564: l_error_msg := substr(SQLERRM,1,70);
565: arp_message.set_error('OKC_HZ_MERGE_PUB.MERGE_ACCOUNT', l_error_msg);
566: RAISE;
567:
568: END; -- party_merge
569:
577:
578: l_count NUMBER;
579:
580: BEGIN
581: arp_message.set_line('OKC_HZ_MERGE_PUB.ACCOUNT_MERGE()+');
582:
583: -- contract party roles
584: -- Insert into log table
585: IF l_profile_val IS NOT NULL AND l_profile_val = 'Y' THEN
627: WHERE ojt.object_code = oue.object_code
628: AND oue.object_user_code = c_account);
629: End If;
630:
631: arp_message.set_name('AR','AR_UPDATING_TABLE');
632: arp_message.set_token('TABLE_NAME','OKC_K_PARTY_ROLES',FALSE);
633: UPDATE okc_k_party_roles_b kpr
634: SET kpr.object1_id1 = (SELECT DISTINCT to_char(rcm.customer_id)
635: FROM ra_customer_merges rcm
628: AND oue.object_user_code = c_account);
629: End If;
630:
631: arp_message.set_name('AR','AR_UPDATING_TABLE');
632: arp_message.set_token('TABLE_NAME','OKC_K_PARTY_ROLES',FALSE);
633: UPDATE okc_k_party_roles_b kpr
634: SET kpr.object1_id1 = (SELECT DISTINCT to_char(rcm.customer_id)
635: FROM ra_customer_merges rcm
636: WHERE kpr.object1_id1 = rcm.duplicate_id
652: WHERE ojt.object_code = oue.object_code
653: AND oue.object_user_code = c_account)
654: ;
655: l_count := sql%rowcount;
656: arp_message.set_name('AR','AR_ROWS_UPDATED');
657: arp_message.set_token('NUM_ROWS',to_char(l_count));
658:
659: -- Rules ID1
660: -- Insert into log table
653: AND oue.object_user_code = c_account)
654: ;
655: l_count := sql%rowcount;
656: arp_message.set_name('AR','AR_ROWS_UPDATED');
657: arp_message.set_token('NUM_ROWS',to_char(l_count));
658:
659: -- Rules ID1
660: -- Insert into log table
661: IF l_profile_val IS NOT NULL AND l_profile_val = 'Y' THEN
703: WHERE ojt.object_code = oue.object_code
704: AND oue.object_user_code = c_account);
705: End If;
706:
707: arp_message.set_name('AR','AR_UPDATING_TABLE');
708: arp_message.set_token('TABLE_NAME','OKC_RULES_B.OBJECT1_ID1',FALSE);
709: UPDATE okc_rules_b rle
710: SET rle.object1_id1 = (SELECT DISTINCT to_char(rcm.customer_id)
711: FROM ra_customer_merges rcm
704: AND oue.object_user_code = c_account);
705: End If;
706:
707: arp_message.set_name('AR','AR_UPDATING_TABLE');
708: arp_message.set_token('TABLE_NAME','OKC_RULES_B.OBJECT1_ID1',FALSE);
709: UPDATE okc_rules_b rle
710: SET rle.object1_id1 = (SELECT DISTINCT to_char(rcm.customer_id)
711: FROM ra_customer_merges rcm
712: WHERE rle.object1_id1 = rcm.duplicate_id
728: WHERE ojt.object_code = oue.object_code
729: AND oue.object_user_code = c_account)
730: ;
731: l_count := sql%rowcount;
732: arp_message.set_name('AR','AR_ROWS_UPDATED');
733: arp_message.set_token('NUM_ROWS',to_char(l_count));
734:
735:
736: -- Rules ID2
729: AND oue.object_user_code = c_account)
730: ;
731: l_count := sql%rowcount;
732: arp_message.set_name('AR','AR_ROWS_UPDATED');
733: arp_message.set_token('NUM_ROWS',to_char(l_count));
734:
735:
736: -- Rules ID2
737: -- Insert into log table
780: WHERE ojt.object_code = oue.object_code
781: AND oue.object_user_code = c_account);
782: End If;
783:
784: arp_message.set_name('AR','AR_UPDATING_TABLE');
785: arp_message.set_token('TABLE_NAME','OKC_RULES_B.OBJECT2_ID1',FALSE);
786: UPDATE okc_rules_b rle
787: SET rle.object2_id1 = (SELECT DISTINCT to_char(rcm.customer_id)
788: FROM ra_customer_merges rcm
781: AND oue.object_user_code = c_account);
782: End If;
783:
784: arp_message.set_name('AR','AR_UPDATING_TABLE');
785: arp_message.set_token('TABLE_NAME','OKC_RULES_B.OBJECT2_ID1',FALSE);
786: UPDATE okc_rules_b rle
787: SET rle.object2_id1 = (SELECT DISTINCT to_char(rcm.customer_id)
788: FROM ra_customer_merges rcm
789: WHERE rle.object2_id1 = rcm.duplicate_id
805: WHERE ojt.object_code = oue.object_code
806: AND oue.object_user_code = c_account)
807: ;
808: l_count := sql%rowcount;
809: arp_message.set_name('AR','AR_ROWS_UPDATED');
810: arp_message.set_token('NUM_ROWS',to_char(l_count));
811:
812:
813: -- Rules ID3
806: AND oue.object_user_code = c_account)
807: ;
808: l_count := sql%rowcount;
809: arp_message.set_name('AR','AR_ROWS_UPDATED');
810: arp_message.set_token('NUM_ROWS',to_char(l_count));
811:
812:
813: -- Rules ID3
814: -- Insert into log table
857: WHERE ojt.object_code = oue.object_code
858: AND oue.object_user_code = c_account);
859: End If;
860:
861: arp_message.set_name('AR','AR_UPDATING_TABLE');
862: arp_message.set_token('TABLE_NAME','OKC_RULES_B.OBJECT3_ID1',FALSE);
863: UPDATE okc_rules_b rle
864: SET rle.object3_id1 = (SELECT DISTINCT to_char(rcm.customer_id)
865: FROM ra_customer_merges rcm
858: AND oue.object_user_code = c_account);
859: End If;
860:
861: arp_message.set_name('AR','AR_UPDATING_TABLE');
862: arp_message.set_token('TABLE_NAME','OKC_RULES_B.OBJECT3_ID1',FALSE);
863: UPDATE okc_rules_b rle
864: SET rle.object3_id1 = (SELECT DISTINCT to_char(rcm.customer_id)
865: FROM ra_customer_merges rcm
866: WHERE rle.object3_id1 = rcm.duplicate_id
882: WHERE ojt.object_code = oue.object_code
883: AND oue.object_user_code = c_account)
884: ;
885: l_count := sql%rowcount;
886: arp_message.set_name('AR','AR_ROWS_UPDATED');
887: arp_message.set_token('NUM_ROWS',to_char(l_count));
888:
889: -- Start:Code added for Bug 3555739
890: -- Updating okc_k_headers_b
883: AND oue.object_user_code = c_account)
884: ;
885: l_count := sql%rowcount;
886: arp_message.set_name('AR','AR_ROWS_UPDATED');
887: arp_message.set_token('NUM_ROWS',to_char(l_count));
888:
889: -- Start:Code added for Bug 3555739
890: -- Updating okc_k_headers_b
891: -- Cust_Acct_Id
931: AND rcm.set_number = set_number);
932:
933: End If;
934:
935: arp_message.set_name('AR','AR_UPDATING_TABLE');
936: arp_message.set_token('TABLE_NAME','OKC_K_HEADERS_B.CUST_ACCT_ID',FALSE);
937:
938: UPDATE okc_k_headers_b okh
939: SET okh.cust_acct_id = (SELECT DISTINCT (rcm.customer_id)
932:
933: End If;
934:
935: arp_message.set_name('AR','AR_UPDATING_TABLE');
936: arp_message.set_token('TABLE_NAME','OKC_K_HEADERS_B.CUST_ACCT_ID',FALSE);
937:
938: UPDATE okc_k_headers_b okh
939: SET okh.cust_acct_id = (SELECT DISTINCT (rcm.customer_id)
940: FROM ra_customer_merges rcm
952: AND rcm.request_id = req_id
953: AND rcm.set_number = set_number);
954:
955: l_count := sql%rowcount;
956: arp_message.set_name('AR','AR_ROWS_UPDATED');
957: arp_message.set_token('NUM_ROWS',to_char(l_count));
958:
959:
960:
953: AND rcm.set_number = set_number);
954:
955: l_count := sql%rowcount;
956: arp_message.set_name('AR','AR_ROWS_UPDATED');
957: arp_message.set_token('NUM_ROWS',to_char(l_count));
958:
959:
960:
961: -- Updating okc_k_lines_b
1002: AND rcm.set_number = set_number);
1003:
1004: End If;
1005:
1006: arp_message.set_name('AR','AR_UPDATING_TABLE');
1007: arp_message.set_token('TABLE_NAME','OKC_K_LINES_B.CUST_ACCT_ID',FALSE);
1008:
1009: UPDATE okc_k_lines_b okl
1010: SET okl.cust_acct_id = (SELECT DISTINCT (rcm.customer_id)
1003:
1004: End If;
1005:
1006: arp_message.set_name('AR','AR_UPDATING_TABLE');
1007: arp_message.set_token('TABLE_NAME','OKC_K_LINES_B.CUST_ACCT_ID',FALSE);
1008:
1009: UPDATE okc_k_lines_b okl
1010: SET okl.cust_acct_id = (SELECT DISTINCT (rcm.customer_id)
1011: FROM ra_customer_merges rcm
1023: AND rcm.request_id = req_id
1024: AND rcm.set_number = set_number);
1025:
1026: l_count := sql%rowcount;
1027: arp_message.set_name('AR','AR_ROWS_UPDATED');
1028: arp_message.set_token('NUM_ROWS',to_char(l_count));
1029:
1030: -- Updating okc_k_party_roles_b
1031: -- Cust_Acct_Id
1024: AND rcm.set_number = set_number);
1025:
1026: l_count := sql%rowcount;
1027: arp_message.set_name('AR','AR_ROWS_UPDATED');
1028: arp_message.set_token('NUM_ROWS',to_char(l_count));
1029:
1030: -- Updating okc_k_party_roles_b
1031: -- Cust_Acct_Id
1032: -- Insert into log table
1071: AND rcm.set_number = set_number);
1072:
1073: End If;
1074:
1075: arp_message.set_name('AR','AR_UPDATING_TABLE');
1076: arp_message.set_token('TABLE_NAME','OKC_K_PARTY_ROLES_B.CUST_ACCT_ID',FALSE);
1077:
1078: UPDATE okc_k_party_roles_b okpr
1079: SET okpr.cust_acct_id = (SELECT DISTINCT (rcm.customer_id)
1072:
1073: End If;
1074:
1075: arp_message.set_name('AR','AR_UPDATING_TABLE');
1076: arp_message.set_token('TABLE_NAME','OKC_K_PARTY_ROLES_B.CUST_ACCT_ID',FALSE);
1077:
1078: UPDATE okc_k_party_roles_b okpr
1079: SET okpr.cust_acct_id = (SELECT DISTINCT (rcm.customer_id)
1080: FROM ra_customer_merges rcm
1092: AND rcm.request_id = req_id
1093: AND rcm.set_number = set_number);
1094:
1095: l_count := sql%rowcount;
1096: arp_message.set_name('AR','AR_ROWS_UPDATED');
1097: arp_message.set_token('NUM_ROWS',to_char(l_count));
1098:
1099: -- End:Code added for Bug 3555739
1100:
1093: AND rcm.set_number = set_number);
1094:
1095: l_count := sql%rowcount;
1096: arp_message.set_name('AR','AR_ROWS_UPDATED');
1097: arp_message.set_token('NUM_ROWS',to_char(l_count));
1098:
1099: -- End:Code added for Bug 3555739
1100:
1101: -- contract items
1145: WHERE ojt.object_code = oue.object_code
1146: AND oue.object_user_code = c_account);
1147: End If;
1148:
1149: arp_message.set_name('AR','AR_UPDATING_TABLE');
1150: arp_message.set_token('TABLE_NAME','OKC_K_ITEMS',FALSE);
1151: UPDATE okc_k_items cim
1152: SET cim.object1_id1 = (SELECT DISTINCT to_char(rcm.customer_id)
1153: FROM ra_customer_merges rcm
1146: AND oue.object_user_code = c_account);
1147: End If;
1148:
1149: arp_message.set_name('AR','AR_UPDATING_TABLE');
1150: arp_message.set_token('TABLE_NAME','OKC_K_ITEMS',FALSE);
1151: UPDATE okc_k_items cim
1152: SET cim.object1_id1 = (SELECT DISTINCT to_char(rcm.customer_id)
1153: FROM ra_customer_merges rcm
1154: WHERE cim.object1_id1 = rcm.duplicate_id
1170: WHERE ojt.object_code = oue.object_code
1171: AND oue.object_user_code = c_account)
1172: ;
1173: l_count := sql%rowcount;
1174: arp_message.set_name('AR','AR_ROWS_UPDATED');
1175: arp_message.set_token('NUM_ROWS',to_char(l_count));
1176:
1177: arp_message.set_line('OKC_HZ_MERGE_PUB.ACCOUNT_MERGE()-');
1178:
1171: AND oue.object_user_code = c_account)
1172: ;
1173: l_count := sql%rowcount;
1174: arp_message.set_name('AR','AR_ROWS_UPDATED');
1175: arp_message.set_token('NUM_ROWS',to_char(l_count));
1176:
1177: arp_message.set_line('OKC_HZ_MERGE_PUB.ACCOUNT_MERGE()-');
1178:
1179:
1173: l_count := sql%rowcount;
1174: arp_message.set_name('AR','AR_ROWS_UPDATED');
1175: arp_message.set_token('NUM_ROWS',to_char(l_count));
1176:
1177: arp_message.set_line('OKC_HZ_MERGE_PUB.ACCOUNT_MERGE()-');
1178:
1179:
1180: END; -- account_merge
1181:
1188:
1189: l_count NUMBER;
1190:
1191: BEGIN
1192: arp_message.set_line('OKC_HZ_MERGE_PUB.ACCOUNT_SITE_MERGE()+');
1193: arp_message.set_line('Updating account sites');
1194: --
1195: -- Account Sites come first, then site uses
1196: --
1189: l_count NUMBER;
1190:
1191: BEGIN
1192: arp_message.set_line('OKC_HZ_MERGE_PUB.ACCOUNT_SITE_MERGE()+');
1193: arp_message.set_line('Updating account sites');
1194: --
1195: -- Account Sites come first, then site uses
1196: --
1197: -- Account Sites in Rules. There are three ids in rules that could hold the site id
1244: WHERE ojt.object_code = oue.object_code
1245: AND oue.object_user_code = c_c_site);
1246: End If;
1247:
1248: arp_message.set_name('AR','AR_UPDATING_TABLE');
1249: arp_message.set_token('TABLE_NAME','OKC_RULES_B.OBJECT1_ID1',FALSE);
1250: UPDATE okc_rules_b rle
1251: SET rle.object1_id1 = (SELECT DISTINCT to_char(rcm.customer_address_id)
1252: FROM ra_customer_merges rcm
1245: AND oue.object_user_code = c_c_site);
1246: End If;
1247:
1248: arp_message.set_name('AR','AR_UPDATING_TABLE');
1249: arp_message.set_token('TABLE_NAME','OKC_RULES_B.OBJECT1_ID1',FALSE);
1250: UPDATE okc_rules_b rle
1251: SET rle.object1_id1 = (SELECT DISTINCT to_char(rcm.customer_address_id)
1252: FROM ra_customer_merges rcm
1253: WHERE rle.object1_id1 = rcm.duplicate_address_id
1270: WHERE ojt.object_code = oue.object_code
1271: AND oue.object_user_code = c_c_site)
1272: ;
1273: l_count := sql%rowcount;
1274: arp_message.set_name('AR','AR_ROWS_UPDATED');
1275: arp_message.set_token('NUM_ROWS',to_char(l_count));
1276:
1277:
1278: -- Rules ID2
1271: AND oue.object_user_code = c_c_site)
1272: ;
1273: l_count := sql%rowcount;
1274: arp_message.set_name('AR','AR_ROWS_UPDATED');
1275: arp_message.set_token('NUM_ROWS',to_char(l_count));
1276:
1277:
1278: -- Rules ID2
1279: -- Insert into log table
1322: WHERE ojt.object_code = oue.object_code
1323: AND oue.object_user_code = c_c_site);
1324: End If;
1325:
1326: arp_message.set_name('AR','AR_UPDATING_TABLE');
1327: arp_message.set_token('TABLE_NAME','OKC_RULES_B.OBJECT2_ID1',FALSE);
1328: UPDATE okc_rules_b rle
1329: SET rle.object2_id1 = (SELECT DISTINCT to_char(rcm.customer_address_id)
1330: FROM ra_customer_merges rcm
1323: AND oue.object_user_code = c_c_site);
1324: End If;
1325:
1326: arp_message.set_name('AR','AR_UPDATING_TABLE');
1327: arp_message.set_token('TABLE_NAME','OKC_RULES_B.OBJECT2_ID1',FALSE);
1328: UPDATE okc_rules_b rle
1329: SET rle.object2_id1 = (SELECT DISTINCT to_char(rcm.customer_address_id)
1330: FROM ra_customer_merges rcm
1331: WHERE rle.object2_id1 = rcm.duplicate_address_id
1348: WHERE ojt.object_code = oue.object_code
1349: AND oue.object_user_code = c_c_site)
1350: ;
1351: l_count := sql%rowcount;
1352: arp_message.set_name('AR','AR_ROWS_UPDATED');
1353: arp_message.set_token('NUM_ROWS',to_char(l_count));
1354:
1355: -- Rules ID3
1356: -- Insert into log table
1349: AND oue.object_user_code = c_c_site)
1350: ;
1351: l_count := sql%rowcount;
1352: arp_message.set_name('AR','AR_ROWS_UPDATED');
1353: arp_message.set_token('NUM_ROWS',to_char(l_count));
1354:
1355: -- Rules ID3
1356: -- Insert into log table
1357: IF l_profile_val IS NOT NULL AND l_profile_val = 'Y' THEN
1399: WHERE ojt.object_code = oue.object_code
1400: AND oue.object_user_code = c_c_site);
1401: End If;
1402:
1403: arp_message.set_name('AR','AR_UPDATING_TABLE');
1404: arp_message.set_token('TABLE_NAME','OKC_RULES_B.OBJECT3_ID1',FALSE);
1405: UPDATE okc_rules_b rle
1406: SET rle.object3_id1 = (SELECT DISTINCT to_char(rcm.customer_address_id)
1407: FROM ra_customer_merges rcm
1400: AND oue.object_user_code = c_c_site);
1401: End If;
1402:
1403: arp_message.set_name('AR','AR_UPDATING_TABLE');
1404: arp_message.set_token('TABLE_NAME','OKC_RULES_B.OBJECT3_ID1',FALSE);
1405: UPDATE okc_rules_b rle
1406: SET rle.object3_id1 = (SELECT DISTINCT to_char(rcm.customer_address_id)
1407: FROM ra_customer_merges rcm
1408: WHERE rle.object3_id1 = rcm.duplicate_address_id
1425: WHERE ojt.object_code = oue.object_code
1426: AND oue.object_user_code = c_c_site)
1427: ;
1428: l_count := sql%rowcount;
1429: arp_message.set_name('AR','AR_ROWS_UPDATED');
1430: arp_message.set_token('NUM_ROWS',to_char(l_count));
1431:
1432:
1433: --
1426: AND oue.object_user_code = c_c_site)
1427: ;
1428: l_count := sql%rowcount;
1429: arp_message.set_name('AR','AR_ROWS_UPDATED');
1430: arp_message.set_token('NUM_ROWS',to_char(l_count));
1431:
1432:
1433: --
1434: -- Account Sites in Items
1479: WHERE ojt.object_code = oue.object_code
1480: AND oue.object_user_code = c_c_site);
1481: End If;
1482:
1483: arp_message.set_name('AR','AR_UPDATING_TABLE');
1484: arp_message.set_token('TABLE_NAME','OKC_K_ITEMS',FALSE);
1485: UPDATE okc_k_items cim
1486: SET cim.object1_id1 = (SELECT DISTINCT to_char(rcm.customer_address_id)
1487: FROM ra_customer_merges rcm
1480: AND oue.object_user_code = c_c_site);
1481: End If;
1482:
1483: arp_message.set_name('AR','AR_UPDATING_TABLE');
1484: arp_message.set_token('TABLE_NAME','OKC_K_ITEMS',FALSE);
1485: UPDATE okc_k_items cim
1486: SET cim.object1_id1 = (SELECT DISTINCT to_char(rcm.customer_address_id)
1487: FROM ra_customer_merges rcm
1488: WHERE cim.object1_id1 = rcm.duplicate_address_id
1505: WHERE ojt.object_code = oue.object_code
1506: AND oue.object_user_code = c_c_site)
1507: ;
1508: l_count := sql%rowcount;
1509: arp_message.set_name('AR','AR_ROWS_UPDATED');
1510: arp_message.set_token('NUM_ROWS',to_char(l_count));
1511:
1512: --
1513: -- Account Site Uses
1506: AND oue.object_user_code = c_c_site)
1507: ;
1508: l_count := sql%rowcount;
1509: arp_message.set_name('AR','AR_ROWS_UPDATED');
1510: arp_message.set_token('NUM_ROWS',to_char(l_count));
1511:
1512: --
1513: -- Account Site Uses
1514: --
1518: -- Account Site Use in OKC_K_PARTY_ROLES_B (see Bug 3950642)
1519: -- OKE only uses the first object1_id1 to hold the site use id
1520: --
1521: --chkrishn 11/03/2004
1522: arp_message.set_line('Updating account site uses for OKE');
1523: -- Insert into log table
1524: IF l_profile_val IS NOT NULL AND l_profile_val = 'Y' THEN
1525: INSERT INTO HZ_CUSTOMER_MERGE_LOG (
1526: MERGE_LOG_ID,
1568: End If;
1569:
1570: --chkrishn 11/03/2004
1571:
1572: arp_message.set_name('AR','AR_UPDATING_TABLE');
1573: arp_message.set_token('TABLE_NAME','OKC_K_PARTY_ROLES_B',FALSE);
1574:
1575: UPDATE okc_k_party_roles_b rle
1576: SET rle.object1_id1 = (SELECT DISTINCT to_char(rcm.customer_site_id)
1569:
1570: --chkrishn 11/03/2004
1571:
1572: arp_message.set_name('AR','AR_UPDATING_TABLE');
1573: arp_message.set_token('TABLE_NAME','OKC_K_PARTY_ROLES_B',FALSE);
1574:
1575: UPDATE okc_k_party_roles_b rle
1576: SET rle.object1_id1 = (SELECT DISTINCT to_char(rcm.customer_site_id)
1577: FROM ra_customer_merges rcm
1595: AND rle.dnz_chr_id in (select k_header_id from oke_k_headers);
1596:
1597: --chkrishn 11/03/2004
1598: l_count := sql%rowcount;
1599: arp_message.set_name('AR','AR_ROWS_UPDATED');
1600: arp_message.set_token('NUM_ROWS',to_char(l_count));
1601:
1602: --
1603: -- End of bug fix 3950642
1596:
1597: --chkrishn 11/03/2004
1598: l_count := sql%rowcount;
1599: arp_message.set_name('AR','AR_ROWS_UPDATED');
1600: arp_message.set_token('NUM_ROWS',to_char(l_count));
1601:
1602: --
1603: -- End of bug fix 3950642
1604: --
1609: -- could hold the site use id
1610: --
1611:
1612:
1613: arp_message.set_line('Updating account site uses');
1614:
1615: -- Rules ID1
1616: -- Insert into log table
1617: IF l_profile_val IS NOT NULL AND l_profile_val = 'Y' THEN
1659: WHERE ojt.object_code = oue.object_code
1660: AND oue.object_user_code = c_c_site_use);
1661: End If;
1662:
1663: arp_message.set_name('AR','AR_UPDATING_TABLE');
1664: arp_message.set_token('TABLE_NAME','OKC_RULES_B.OBJECT1_ID1',FALSE);
1665: UPDATE okc_rules_b rle
1666: SET rle.object1_id1 = (SELECT DISTINCT to_char(rcm.customer_site_id)
1667: FROM ra_customer_merges rcm
1660: AND oue.object_user_code = c_c_site_use);
1661: End If;
1662:
1663: arp_message.set_name('AR','AR_UPDATING_TABLE');
1664: arp_message.set_token('TABLE_NAME','OKC_RULES_B.OBJECT1_ID1',FALSE);
1665: UPDATE okc_rules_b rle
1666: SET rle.object1_id1 = (SELECT DISTINCT to_char(rcm.customer_site_id)
1667: FROM ra_customer_merges rcm
1668: WHERE rle.object1_id1 = rcm.duplicate_site_id
1684: WHERE ojt.object_code = oue.object_code
1685: AND oue.object_user_code = c_c_site_use)
1686: ;
1687: l_count := sql%rowcount;
1688: arp_message.set_name('AR','AR_ROWS_UPDATED');
1689: arp_message.set_token('NUM_ROWS',to_char(l_count));
1690:
1691: -- Rules ID2
1692: -- Insert into log table
1685: AND oue.object_user_code = c_c_site_use)
1686: ;
1687: l_count := sql%rowcount;
1688: arp_message.set_name('AR','AR_ROWS_UPDATED');
1689: arp_message.set_token('NUM_ROWS',to_char(l_count));
1690:
1691: -- Rules ID2
1692: -- Insert into log table
1693: IF l_profile_val IS NOT NULL AND l_profile_val = 'Y' THEN
1735: WHERE ojt.object_code = oue.object_code
1736: AND oue.object_user_code = c_c_site_use);
1737: End If;
1738:
1739: arp_message.set_name('AR','AR_UPDATING_TABLE');
1740: arp_message.set_token('TABLE_NAME','OKC_RULES_B.OBJECT2_ID1',FALSE);
1741: UPDATE okc_rules_b rle
1742: SET rle.object2_id1 = (SELECT DISTINCT to_char(rcm.customer_site_id)
1743: FROM ra_customer_merges rcm
1736: AND oue.object_user_code = c_c_site_use);
1737: End If;
1738:
1739: arp_message.set_name('AR','AR_UPDATING_TABLE');
1740: arp_message.set_token('TABLE_NAME','OKC_RULES_B.OBJECT2_ID1',FALSE);
1741: UPDATE okc_rules_b rle
1742: SET rle.object2_id1 = (SELECT DISTINCT to_char(rcm.customer_site_id)
1743: FROM ra_customer_merges rcm
1744: WHERE rle.object2_id1 = rcm.duplicate_site_id
1760: WHERE ojt.object_code = oue.object_code
1761: AND oue.object_user_code = c_c_site_use)
1762: ;
1763: l_count := sql%rowcount;
1764: arp_message.set_name('AR','AR_ROWS_UPDATED');
1765: arp_message.set_token('NUM_ROWS',to_char(l_count));
1766:
1767:
1768: -- Rules ID3
1761: AND oue.object_user_code = c_c_site_use)
1762: ;
1763: l_count := sql%rowcount;
1764: arp_message.set_name('AR','AR_ROWS_UPDATED');
1765: arp_message.set_token('NUM_ROWS',to_char(l_count));
1766:
1767:
1768: -- Rules ID3
1769: -- Insert into log table
1812: WHERE ojt.object_code = oue.object_code
1813: AND oue.object_user_code = c_c_site_use);
1814: End If;
1815:
1816: arp_message.set_name('AR','AR_UPDATING_TABLE');
1817: arp_message.set_token('TABLE_NAME','OKC_RULES_B.OBJECT3_ID1',FALSE);
1818: UPDATE okc_rules_b rle
1819: SET rle.object3_id1 = (SELECT DISTINCT to_char(rcm.customer_site_id)
1820: FROM ra_customer_merges rcm
1813: AND oue.object_user_code = c_c_site_use);
1814: End If;
1815:
1816: arp_message.set_name('AR','AR_UPDATING_TABLE');
1817: arp_message.set_token('TABLE_NAME','OKC_RULES_B.OBJECT3_ID1',FALSE);
1818: UPDATE okc_rules_b rle
1819: SET rle.object3_id1 = (SELECT DISTINCT to_char(rcm.customer_site_id)
1820: FROM ra_customer_merges rcm
1821: WHERE rle.object3_id1 = rcm.duplicate_site_id
1837: WHERE ojt.object_code = oue.object_code
1838: AND oue.object_user_code = c_c_site_use)
1839: ;
1840: l_count := sql%rowcount;
1841: arp_message.set_name('AR','AR_ROWS_UPDATED');
1842: arp_message.set_token('NUM_ROWS',to_char(l_count));
1843:
1844: -- Start:Code added for Bug 3555739
1845: -- Updating okc_k_headers_b
1838: AND oue.object_user_code = c_c_site_use)
1839: ;
1840: l_count := sql%rowcount;
1841: arp_message.set_name('AR','AR_ROWS_UPDATED');
1842: arp_message.set_token('NUM_ROWS',to_char(l_count));
1843:
1844: -- Start:Code added for Bug 3555739
1845: -- Updating okc_k_headers_b
1846: -- Ship_to_site_use_id
1886: AND rcm.set_number = set_number);
1887:
1888: End If;
1889:
1890: arp_message.set_name('AR','AR_UPDATING_TABLE');
1891: arp_message.set_token('TABLE_NAME','OKC_K_HEADERS_B.SHIP_TO_SITE_USE_ID',FALSE);
1892:
1893: UPDATE okc_k_headers_b okh
1894: SET okh.ship_to_site_use_id = (SELECT DISTINCT (rcm.customer_site_id)
1887:
1888: End If;
1889:
1890: arp_message.set_name('AR','AR_UPDATING_TABLE');
1891: arp_message.set_token('TABLE_NAME','OKC_K_HEADERS_B.SHIP_TO_SITE_USE_ID',FALSE);
1892:
1893: UPDATE okc_k_headers_b okh
1894: SET okh.ship_to_site_use_id = (SELECT DISTINCT (rcm.customer_site_id)
1895: FROM ra_customer_merges rcm
1906: WHERE rcm.process_flag = 'N'
1907: AND rcm.request_id = req_id
1908: AND rcm.set_number = set_number);
1909: l_count := sql%rowcount;
1910: arp_message.set_name('AR','AR_ROWS_UPDATED');
1911: arp_message.set_token('NUM_ROWS',to_char(l_count));
1912:
1913:
1914: -- Updating okc_k_headers_b
1907: AND rcm.request_id = req_id
1908: AND rcm.set_number = set_number);
1909: l_count := sql%rowcount;
1910: arp_message.set_name('AR','AR_ROWS_UPDATED');
1911: arp_message.set_token('NUM_ROWS',to_char(l_count));
1912:
1913:
1914: -- Updating okc_k_headers_b
1915: -- Bill_to_site_use_id
1955: AND rcm.set_number = set_number);
1956:
1957: End If;
1958:
1959: arp_message.set_name('AR','AR_UPDATING_TABLE');
1960: arp_message.set_token('TABLE_NAME','OKC_K_LINES_B.BILL_TO_SITE_USE_ID',FALSE);
1961:
1962: UPDATE okc_k_headers_b okh
1963: SET okh.bill_to_site_use_id = (SELECT DISTINCT (rcm.customer_site_id)
1956:
1957: End If;
1958:
1959: arp_message.set_name('AR','AR_UPDATING_TABLE');
1960: arp_message.set_token('TABLE_NAME','OKC_K_LINES_B.BILL_TO_SITE_USE_ID',FALSE);
1961:
1962: UPDATE okc_k_headers_b okh
1963: SET okh.bill_to_site_use_id = (SELECT DISTINCT (rcm.customer_site_id)
1964: FROM ra_customer_merges rcm
1975: WHERE rcm.process_flag = 'N'
1976: AND rcm.request_id = req_id
1977: AND rcm.set_number = set_number);
1978: l_count := sql%rowcount;
1979: arp_message.set_name('AR','AR_ROWS_UPDATED');
1980: arp_message.set_token('NUM_ROWS',to_char(l_count));
1981:
1982: -- Updating okc_k_lines_b
1983: -- Ship_to_site_use_id
1976: AND rcm.request_id = req_id
1977: AND rcm.set_number = set_number);
1978: l_count := sql%rowcount;
1979: arp_message.set_name('AR','AR_ROWS_UPDATED');
1980: arp_message.set_token('NUM_ROWS',to_char(l_count));
1981:
1982: -- Updating okc_k_lines_b
1983: -- Ship_to_site_use_id
1984: -- Insert into log table
2023: AND rcm.set_number = set_number);
2024:
2025: End If;
2026:
2027: arp_message.set_name('AR','AR_UPDATING_TABLE');
2028: arp_message.set_token('TABLE_NAME','OKC_K_LINES_B.SHIP_TO_SITE_USE_ID',FALSE);
2029:
2030: UPDATE okc_k_lines_b okl
2031: SET okl.ship_to_site_use_id = (SELECT DISTINCT (rcm.customer_site_id)
2024:
2025: End If;
2026:
2027: arp_message.set_name('AR','AR_UPDATING_TABLE');
2028: arp_message.set_token('TABLE_NAME','OKC_K_LINES_B.SHIP_TO_SITE_USE_ID',FALSE);
2029:
2030: UPDATE okc_k_lines_b okl
2031: SET okl.ship_to_site_use_id = (SELECT DISTINCT (rcm.customer_site_id)
2032: FROM ra_customer_merges rcm
2043: WHERE rcm.process_flag = 'N'
2044: AND rcm.request_id = req_id
2045: AND rcm.set_number = set_number);
2046: l_count := sql%rowcount;
2047: arp_message.set_name('AR','AR_ROWS_UPDATED');
2048: arp_message.set_token('NUM_ROWS',to_char(l_count));
2049:
2050:
2051: -- Updating okc_k_lines_b
2044: AND rcm.request_id = req_id
2045: AND rcm.set_number = set_number);
2046: l_count := sql%rowcount;
2047: arp_message.set_name('AR','AR_ROWS_UPDATED');
2048: arp_message.set_token('NUM_ROWS',to_char(l_count));
2049:
2050:
2051: -- Updating okc_k_lines_b
2052: -- Bill_to_site_use_id
2092: AND rcm.set_number = set_number);
2093:
2094: End If;
2095:
2096: arp_message.set_name('AR','AR_UPDATING_TABLE');
2097: arp_message.set_token('TABLE_NAME','OKC_K_LINES_B.BILL_TO_SITE_USE_ID',FALSE);
2098:
2099: UPDATE okc_k_lines_b okl
2100: SET okl.bill_to_site_use_id = (SELECT DISTINCT (rcm.customer_site_id)
2093:
2094: End If;
2095:
2096: arp_message.set_name('AR','AR_UPDATING_TABLE');
2097: arp_message.set_token('TABLE_NAME','OKC_K_LINES_B.BILL_TO_SITE_USE_ID',FALSE);
2098:
2099: UPDATE okc_k_lines_b okl
2100: SET okl.bill_to_site_use_id = (SELECT DISTINCT (rcm.customer_site_id)
2101: FROM ra_customer_merges rcm
2112: WHERE rcm.process_flag = 'N'
2113: AND rcm.request_id = req_id
2114: AND rcm.set_number = set_number);
2115: l_count := sql%rowcount;
2116: arp_message.set_name('AR','AR_ROWS_UPDATED');
2117: arp_message.set_token('NUM_ROWS',to_char(l_count));
2118:
2119:
2120: -- Updating okc_k_party_roles_b
2113: AND rcm.request_id = req_id
2114: AND rcm.set_number = set_number);
2115: l_count := sql%rowcount;
2116: arp_message.set_name('AR','AR_ROWS_UPDATED');
2117: arp_message.set_token('NUM_ROWS',to_char(l_count));
2118:
2119:
2120: -- Updating okc_k_party_roles_b
2121: -- Bill_to_site_use_id
2161: AND rcm.set_number = set_number);
2162:
2163: End If;
2164:
2165: arp_message.set_name('AR','AR_UPDATING_TABLE');
2166: arp_message.set_token('TABLE_NAME','OKC_K_PARTY_ROLES_B.BILL_TO_SITE_USE_ID',FALSE);
2167:
2168: UPDATE okc_k_party_roles_b okpr
2169: SET okpr.bill_to_site_use_id = (SELECT DISTINCT (rcm.customer_site_id)
2162:
2163: End If;
2164:
2165: arp_message.set_name('AR','AR_UPDATING_TABLE');
2166: arp_message.set_token('TABLE_NAME','OKC_K_PARTY_ROLES_B.BILL_TO_SITE_USE_ID',FALSE);
2167:
2168: UPDATE okc_k_party_roles_b okpr
2169: SET okpr.bill_to_site_use_id = (SELECT DISTINCT (rcm.customer_site_id)
2170: FROM ra_customer_merges rcm
2181: WHERE rcm.process_flag = 'N'
2182: AND rcm.request_id = req_id
2183: AND rcm.set_number = set_number);
2184: l_count := sql%rowcount;
2185: arp_message.set_name('AR','AR_ROWS_UPDATED');
2186: arp_message.set_token('NUM_ROWS',to_char(l_count));
2187:
2188: -- End:Code added for Bug 3555739
2189:
2182: AND rcm.request_id = req_id
2183: AND rcm.set_number = set_number);
2184: l_count := sql%rowcount;
2185: arp_message.set_name('AR','AR_ROWS_UPDATED');
2186: arp_message.set_token('NUM_ROWS',to_char(l_count));
2187:
2188: -- End:Code added for Bug 3555739
2189:
2190: --
2236: WHERE ojt.object_code = oue.object_code
2237: AND oue.object_user_code = c_c_site_use);
2238: End If;
2239:
2240: arp_message.set_name('AR','AR_UPDATING_TABLE');
2241: arp_message.set_token('TABLE_NAME','OKC_K_ITEMS',FALSE);
2242: UPDATE okc_k_items cim
2243: SET cim.object1_id1 = (SELECT DISTINCT to_char(rcm.customer_site_id)
2244: FROM ra_customer_merges rcm
2237: AND oue.object_user_code = c_c_site_use);
2238: End If;
2239:
2240: arp_message.set_name('AR','AR_UPDATING_TABLE');
2241: arp_message.set_token('TABLE_NAME','OKC_K_ITEMS',FALSE);
2242: UPDATE okc_k_items cim
2243: SET cim.object1_id1 = (SELECT DISTINCT to_char(rcm.customer_site_id)
2244: FROM ra_customer_merges rcm
2245: WHERE cim.object1_id1 = rcm.duplicate_site_id
2261: WHERE ojt.object_code = oue.object_code
2262: AND oue.object_user_code = c_c_site_use)
2263: ;
2264: l_count := sql%rowcount;
2265: arp_message.set_name('AR','AR_ROWS_UPDATED');
2266: arp_message.set_token('NUM_ROWS',to_char(l_count));
2267:
2268: arp_message.set_line('OKC_HZ_MERGE_PUB.ACCOUNT_SITE_MERGE()-');
2269:
2262: AND oue.object_user_code = c_c_site_use)
2263: ;
2264: l_count := sql%rowcount;
2265: arp_message.set_name('AR','AR_ROWS_UPDATED');
2266: arp_message.set_token('NUM_ROWS',to_char(l_count));
2267:
2268: arp_message.set_line('OKC_HZ_MERGE_PUB.ACCOUNT_SITE_MERGE()-');
2269:
2270:
2264: l_count := sql%rowcount;
2265: arp_message.set_name('AR','AR_ROWS_UPDATED');
2266: arp_message.set_token('NUM_ROWS',to_char(l_count));
2267:
2268: arp_message.set_line('OKC_HZ_MERGE_PUB.ACCOUNT_SITE_MERGE()-');
2269:
2270:
2271: END; -- account_site_merge
2272:
2356: l_no_data_found_excp EXCEPTION;
2357: l_lock_excp EXCEPTION;
2358:
2359: BEGIN
2360: arp_message.set_line('OKC_HZ_MERGE_PUB.MERGE_ACCOUNT()+');
2361:
2362: --
2363: -- check process mode. If LOCK, then just lock the tables
2364: --
2446: account_site_merge(req_id => req_id
2447: ,set_number => set_number);
2448: END IF; -- if customer ids the same
2449:
2450: arp_message.set_line('OKC_HZ_MERGE_PUB.MERGE_ACCOUNT()-');
2451:
2452: EXCEPTION
2453: WHEN l_merge_disallowed_excp THEN
2454: arp_message.set_line('Contract exists for duplicate party, merge cannot proceed');
2450: arp_message.set_line('OKC_HZ_MERGE_PUB.MERGE_ACCOUNT()-');
2451:
2452: EXCEPTION
2453: WHEN l_merge_disallowed_excp THEN
2454: arp_message.set_line('Contract exists for duplicate party, merge cannot proceed');
2455: arp_message.set_error('OKC_HZ_MERGE_PUB.MERGE_ACCOUNT');
2456: RAISE;
2457: WHEN l_no_data_found_excp THEN
2458: arp_message.set_line('No data found for merge information');
2451:
2452: EXCEPTION
2453: WHEN l_merge_disallowed_excp THEN
2454: arp_message.set_line('Contract exists for duplicate party, merge cannot proceed');
2455: arp_message.set_error('OKC_HZ_MERGE_PUB.MERGE_ACCOUNT');
2456: RAISE;
2457: WHEN l_no_data_found_excp THEN
2458: arp_message.set_line('No data found for merge information');
2459: arp_message.set_error('OKC_HZ_MERGE_PUB.MERGE_ACCOUNT');
2454: arp_message.set_line('Contract exists for duplicate party, merge cannot proceed');
2455: arp_message.set_error('OKC_HZ_MERGE_PUB.MERGE_ACCOUNT');
2456: RAISE;
2457: WHEN l_no_data_found_excp THEN
2458: arp_message.set_line('No data found for merge information');
2459: arp_message.set_error('OKC_HZ_MERGE_PUB.MERGE_ACCOUNT');
2460: RAISE;
2461: WHEN l_lock_excp THEN -- normal exit after locking
2462: arp_message.set_line('OKC_HZ_MERGE_PUB.MERGE_ACCOUNT()-');
2455: arp_message.set_error('OKC_HZ_MERGE_PUB.MERGE_ACCOUNT');
2456: RAISE;
2457: WHEN l_no_data_found_excp THEN
2458: arp_message.set_line('No data found for merge information');
2459: arp_message.set_error('OKC_HZ_MERGE_PUB.MERGE_ACCOUNT');
2460: RAISE;
2461: WHEN l_lock_excp THEN -- normal exit after locking
2462: arp_message.set_line('OKC_HZ_MERGE_PUB.MERGE_ACCOUNT()-');
2463: WHEN others THEN
2458: arp_message.set_line('No data found for merge information');
2459: arp_message.set_error('OKC_HZ_MERGE_PUB.MERGE_ACCOUNT');
2460: RAISE;
2461: WHEN l_lock_excp THEN -- normal exit after locking
2462: arp_message.set_line('OKC_HZ_MERGE_PUB.MERGE_ACCOUNT()-');
2463: WHEN others THEN
2464: l_error_msg := substr(SQLERRM,1,70);
2465: arp_message.set_error('OKC_HZ_MERGE_PUB.MERGE_ACCOUNT', l_error_msg);
2466: RAISE;
2461: WHEN l_lock_excp THEN -- normal exit after locking
2462: arp_message.set_line('OKC_HZ_MERGE_PUB.MERGE_ACCOUNT()-');
2463: WHEN others THEN
2464: l_error_msg := substr(SQLERRM,1,70);
2465: arp_message.set_error('OKC_HZ_MERGE_PUB.MERGE_ACCOUNT', l_error_msg);
2466: RAISE;
2467: END; -- merge_account
2468:
2469: END; -- Package Body OKC_HZ_MERGE_PUB