9: error_str VARCHAR2(3);
10: no_of_rows NUMBER;
11: BEGIN
12:
13: arp_message.set_line('CSI_ACCT_MERGE_PKG.MERGE()+');
14: /*
15: error_str := '001';
16: write_to_cr_log( ' Processing Item Instances Merge ' );
17: CSI_ITEM_INSTANCES_MERGE(req_id, set_num, process_mode);
37: CSI_T_TXN_SYSTEMS_MERGE(req_id, set_num, process_mode);
38: write_to_cr_log( ' Ending process for CSI Transaction Systems Merge ' );
39: */
40:
41: arp_message.set_line('CSI_ACCT_MERGE_PKG.MERGE()-');
42:
43: EXCEPTION
44: WHEN OTHERS THEN
45: arp_message.set_line( 'CSI_ACCT_MERGE_PKG.MERGE()-');
41: arp_message.set_line('CSI_ACCT_MERGE_PKG.MERGE()-');
42:
43: EXCEPTION
44: WHEN OTHERS THEN
45: arp_message.set_line( 'CSI_ACCT_MERGE_PKG.MERGE()-');
46: RAISE;
47: END MERGE;
48:
49: PROCEDURE csi_item_instances_merge( req_id IN NUMBER,
49: PROCEDURE csi_item_instances_merge( req_id IN NUMBER,
50: set_num IN NUMBER,
51: process_mode IN VARCHAR2 ) IS
52: BEGIN
53: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_ITEM_INSTANCES_MERGE()+');
54: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_ITEM_INSTANCES_MERGE()-');
55: EXCEPTION
56: WHEN OTHERS THEN
57: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_ITEM_INSTANCES_MERGE()');
50: set_num IN NUMBER,
51: process_mode IN VARCHAR2 ) IS
52: BEGIN
53: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_ITEM_INSTANCES_MERGE()+');
54: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_ITEM_INSTANCES_MERGE()-');
55: EXCEPTION
56: WHEN OTHERS THEN
57: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_ITEM_INSTANCES_MERGE()');
58: RAISE;
53: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_ITEM_INSTANCES_MERGE()+');
54: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_ITEM_INSTANCES_MERGE()-');
55: EXCEPTION
56: WHEN OTHERS THEN
57: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_ITEM_INSTANCES_MERGE()');
58: RAISE;
59: END CSI_ITEM_INSTANCES_MERGE;
60:
61: PROCEDURE csi_ip_accounts_merge( req_id IN NUMBER,
240:
241: BEGIN -- {1
242:
243: error_str := '001';
244: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_IP_ACCOUNTS_MERGE()+');
245:
246: IF (process_mode = 'LOCK') THEN -- {2
247:
248: error_str := '002';
247:
248: error_str := '002';
249: write_to_cr_log( 'Locking the csi_ip_accounts table' );
250:
251: arp_message.set_name('AR','AR_LOCKING_TABLE');
252: arp_message.set_token('TABLE_NAME','CSI_IP_ACCOUNTS',FALSE);
253:
254: OPEN merged_records;
255: CLOSE merged_records;
248: error_str := '002';
249: write_to_cr_log( 'Locking the csi_ip_accounts table' );
250:
251: arp_message.set_name('AR','AR_LOCKING_TABLE');
252: arp_message.set_token('TABLE_NAME','CSI_IP_ACCOUNTS',FALSE);
253:
254: OPEN merged_records;
255: CLOSE merged_records;
256:
261: l_msg_string := 'CSI:Processing';
262: write_to_cr_log( l_msg_string );
263:
264: error_str := '003';
265: ARP_MESSAGE.SET_NAME('AR','AR_UPDATING_TABLE');
266: ARP_MESSAGE.SET_TOKEN('TABLE_NAME','CSI_IP_ACCOUNTS',FALSE);
267: HZ_ACCT_MERGE_UTIL.load_set(set_num, req_id);
268:
269: error_str := '004';
262: write_to_cr_log( l_msg_string );
263:
264: error_str := '003';
265: ARP_MESSAGE.SET_NAME('AR','AR_UPDATING_TABLE');
266: ARP_MESSAGE.SET_TOKEN('TABLE_NAME','CSI_IP_ACCOUNTS',FALSE);
267: HZ_ACCT_MERGE_UTIL.load_set(set_num, req_id);
268:
269: error_str := '004';
270: l_profile_val := FND_PROFILE.VALUE('HZ_AUDIT_ACCT_MERGE');
520:
521: -- TODO : remove the next line
522: --NUM_COL1_NEW_LIST(i) := 4565;
523:
524: ARP_MESSAGE.SET_NAME('AR','AR_UPDATING_TABLE');
525: ARP_MESSAGE.SET_TOKEN('TABLE_NAME','site_id'||INSTALL_CUSTOMER_SITE_ID_LIST(I),FALSE);
526:
527: l_msg_string := 'CSI : primary_key_id_list(i), l_party_account_Id , l_bill_to_address, l_ship_to_address :'
528: || to_char(primary_key_id_list(i)) || '<>'
521: -- TODO : remove the next line
522: --NUM_COL1_NEW_LIST(i) := 4565;
523:
524: ARP_MESSAGE.SET_NAME('AR','AR_UPDATING_TABLE');
525: ARP_MESSAGE.SET_TOKEN('TABLE_NAME','site_id'||INSTALL_CUSTOMER_SITE_ID_LIST(I),FALSE);
526:
527: l_msg_string := 'CSI : primary_key_id_list(i), l_party_account_Id , l_bill_to_address, l_ship_to_address :'
528: || to_char(primary_key_id_list(i)) || '<>'
529: || to_char(l_party_account_id) || '<>'
1313: error_str := '021';
1314: p_u_instance_rec.instance_id := INSTANCE_ID_LIST(I);
1315: p_u_instance_rec.object_version_number := l_g_instance_rec.object_version_number;
1316:
1317: ARP_MESSAGE.SET_NAME('AR','AR_UPDATING_TABLE');
1318: ARP_MESSAGE.SET_TOKEN('TABLE_NAME','location_id'||NUM_COL4_NEW_LIST(I),FALSE);
1319:
1320: ARP_MESSAGE.SET_NAME('AR','AR_UPDATING_TABLE');
1321: ARP_MESSAGE.SET_TOKEN('TABLE_NAME','install_location_id'||NUM_COL5_NEW_LIST(I),FALSE);
1314: p_u_instance_rec.instance_id := INSTANCE_ID_LIST(I);
1315: p_u_instance_rec.object_version_number := l_g_instance_rec.object_version_number;
1316:
1317: ARP_MESSAGE.SET_NAME('AR','AR_UPDATING_TABLE');
1318: ARP_MESSAGE.SET_TOKEN('TABLE_NAME','location_id'||NUM_COL4_NEW_LIST(I),FALSE);
1319:
1320: ARP_MESSAGE.SET_NAME('AR','AR_UPDATING_TABLE');
1321: ARP_MESSAGE.SET_TOKEN('TABLE_NAME','install_location_id'||NUM_COL5_NEW_LIST(I),FALSE);
1322:
1316:
1317: ARP_MESSAGE.SET_NAME('AR','AR_UPDATING_TABLE');
1318: ARP_MESSAGE.SET_TOKEN('TABLE_NAME','location_id'||NUM_COL4_NEW_LIST(I),FALSE);
1319:
1320: ARP_MESSAGE.SET_NAME('AR','AR_UPDATING_TABLE');
1321: ARP_MESSAGE.SET_TOKEN('TABLE_NAME','install_location_id'||NUM_COL5_NEW_LIST(I),FALSE);
1322:
1323: IF NUM_COL5_NEW_LIST(I) IS NOT NULL AND NUM_COL4_NEW_LIST(I) IS NOT NULL THEN
1324:
1317: ARP_MESSAGE.SET_NAME('AR','AR_UPDATING_TABLE');
1318: ARP_MESSAGE.SET_TOKEN('TABLE_NAME','location_id'||NUM_COL4_NEW_LIST(I),FALSE);
1319:
1320: ARP_MESSAGE.SET_NAME('AR','AR_UPDATING_TABLE');
1321: ARP_MESSAGE.SET_TOKEN('TABLE_NAME','install_location_id'||NUM_COL5_NEW_LIST(I),FALSE);
1322:
1323: IF NUM_COL5_NEW_LIST(I) IS NOT NULL AND NUM_COL4_NEW_LIST(I) IS NOT NULL THEN
1324:
1325: p_u_instance_rec.install_location_id := NUM_COL5_NEW_LIST(I);
1353: x_msg_count => l_msg_count,
1354: x_msg_data => l_msg_data);
1355: write_to_cr_log( 'return status :'||l_return_status);
1356:
1357: ARP_MESSAGE.SET_NAME('AR','AR_UPDATING_TABLE');
1358: ARP_MESSAGE.SET_TOKEN('TABLE_NAME','return_status'||l_return_status,FALSE);
1359: IF l_return_status <> 'S' Then
1360: write_to_cr_log( 'Msg Count : '||to_char(l_msg_count));
1361: FOR l_msg_ctr in 1..l_msg_count LOOP
1354: x_msg_data => l_msg_data);
1355: write_to_cr_log( 'return status :'||l_return_status);
1356:
1357: ARP_MESSAGE.SET_NAME('AR','AR_UPDATING_TABLE');
1358: ARP_MESSAGE.SET_TOKEN('TABLE_NAME','return_status'||l_return_status,FALSE);
1359: IF l_return_status <> 'S' Then
1360: write_to_cr_log( 'Msg Count : '||to_char(l_msg_count));
1361: FOR l_msg_ctr in 1..l_msg_count LOOP
1362: fnd_msg_pub.get ( l_msg_ctr, FND_API.G_FALSE, l_msg_data, l_msg_dummy );
1396: END LOOP; -- } 3 merge records Loop
1397:
1398: CLOSE merged_records;
1399:
1400: arp_message.set_name('CSI','CSI_ROWS_UPDATED');
1401: arp_message.set_token('NUM_ROWS',to_char(l_count));
1402: arp_message.set_line( 'Done with the update of CSI_IP_ACCOUNTS' );
1403: END IF; -- } 2
1404:
1397:
1398: CLOSE merged_records;
1399:
1400: arp_message.set_name('CSI','CSI_ROWS_UPDATED');
1401: arp_message.set_token('NUM_ROWS',to_char(l_count));
1402: arp_message.set_line( 'Done with the update of CSI_IP_ACCOUNTS' );
1403: END IF; -- } 2
1404:
1405: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_IP_ACCOUNTS_MERGE()-');
1398: CLOSE merged_records;
1399:
1400: arp_message.set_name('CSI','CSI_ROWS_UPDATED');
1401: arp_message.set_token('NUM_ROWS',to_char(l_count));
1402: arp_message.set_line( 'Done with the update of CSI_IP_ACCOUNTS' );
1403: END IF; -- } 2
1404:
1405: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_IP_ACCOUNTS_MERGE()-');
1406:
1401: arp_message.set_token('NUM_ROWS',to_char(l_count));
1402: arp_message.set_line( 'Done with the update of CSI_IP_ACCOUNTS' );
1403: END IF; -- } 2
1404:
1405: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_IP_ACCOUNTS_MERGE()-');
1406:
1407: EXCEPTION
1408: WHEN OTHERS THEN
1409: CLOSE merged_records;
1407: EXCEPTION
1408: WHEN OTHERS THEN
1409: CLOSE merged_records;
1410: l_msg_data := error_str || '-' || l_msg_data;
1411: arp_message.set_error('CRM_MERGE.CUSTOMER_PRODUCTS_MERGE', l_msg_data);
1412: RAISE;
1413: END csi_ip_accounts_merge; -- } 1
1414:
1415: PROCEDURE csi_systems_b_merge(req_id IN NUMBER,
1482: I NUMBER;
1483: v_system_history_id NUMBER;
1484: BEGIN
1485:
1486: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_SYSTEMS_B_MERGE()+');
1487:
1488: IF (process_mode = 'LOCK') THEN
1489:
1490: write_to_cr_log( 'CSI : csi_systems_b_merge...' || process_mode ) ;
1489:
1490: write_to_cr_log( 'CSI : csi_systems_b_merge...' || process_mode ) ;
1491:
1492: write_to_cr_log( 'Locking the csi_systems_b table' );
1493: arp_message.set_name('AR','AR_LOCKING_TABLE');
1494: arp_message.set_token('TABLE_NAME','CSI_SYSTEMS_B',FALSE);
1495:
1496: OPEN merged_records;
1497: CLOSE merged_records;
1490: write_to_cr_log( 'CSI : csi_systems_b_merge...' || process_mode ) ;
1491:
1492: write_to_cr_log( 'Locking the csi_systems_b table' );
1493: arp_message.set_name('AR','AR_LOCKING_TABLE');
1494: arp_message.set_token('TABLE_NAME','CSI_SYSTEMS_B',FALSE);
1495:
1496: OPEN merged_records;
1497: CLOSE merged_records;
1498:
1501: ELSE
1502:
1503: write_to_cr_log( 'CSI : csi_systems_b_merge.....' || process_mode );
1504:
1505: ARP_MESSAGE.SET_NAME('AR','AR_UPDATING_TABLE');
1506: ARP_MESSAGE.SET_TOKEN('TABLE_NAME','CSI_SYSTEMS_B',FALSE);
1507: HZ_ACCT_MERGE_UTIL.load_set(set_num, req_id);
1508: l_profile_val := FND_PROFILE.VALUE('HZ_AUDIT_ACCT_MERGE');
1509:
1502:
1503: write_to_cr_log( 'CSI : csi_systems_b_merge.....' || process_mode );
1504:
1505: ARP_MESSAGE.SET_NAME('AR','AR_UPDATING_TABLE');
1506: ARP_MESSAGE.SET_TOKEN('TABLE_NAME','CSI_SYSTEMS_B',FALSE);
1507: HZ_ACCT_MERGE_UTIL.load_set(set_num, req_id);
1508: l_profile_val := FND_PROFILE.VALUE('HZ_AUDIT_ACCT_MERGE');
1509:
1510: OPEN merged_records;
1797: EXIT;
1798: END IF;
1799:
1800: no_of_rows := sql%rowcount;
1801: arp_message.set_token('NUM_ROWS',to_char(no_of_rows));
1802: arp_message.set_line( 'Done with the insert of systems history' );
1803:
1804: END LOOP; -- } End merged records loop
1805:
1798: END IF;
1799:
1800: no_of_rows := sql%rowcount;
1801: arp_message.set_token('NUM_ROWS',to_char(no_of_rows));
1802: arp_message.set_line( 'Done with the insert of systems history' );
1803:
1804: END LOOP; -- } End merged records loop
1805:
1806: CLOSE merged_records;
1806: CLOSE merged_records;
1807:
1808: END IF;
1809:
1810: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_SYSTEMS_B_MERGE()-');
1811:
1812: EXCEPTION
1813: WHEN OTHERS THEN
1814: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_SYSTEMS_B_MERGE()-');
1810: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_SYSTEMS_B_MERGE()-');
1811:
1812: EXCEPTION
1813: WHEN OTHERS THEN
1814: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_SYSTEMS_B_MERGE()-');
1815: CLOSE merged_records;
1816: raise;
1817: END csi_systems_b_merge;
1818:
1875: AND m.set_number = set_num;
1876:
1877: BEGIN
1878:
1879: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_T_PARTY_ACCOUNTS_MERGE()+');
1880:
1881: IF (process_mode = 'LOCK') THEN
1882:
1883: write_to_cr_log( 'Locking the csi_t_party_accounts' );
1881: IF (process_mode = 'LOCK') THEN
1882:
1883: write_to_cr_log( 'Locking the csi_t_party_accounts' );
1884:
1885: arp_message.set_name('AR','AR_LOCKING_TABLE');
1886: arp_message.set_token('TABLE_NAME','CSI_T_PARTY_ACCOUNTS',FALSE);
1887:
1888: OPEN merged_records;
1889: CLOSE merged_records;
1882:
1883: write_to_cr_log( 'Locking the csi_t_party_accounts' );
1884:
1885: arp_message.set_name('AR','AR_LOCKING_TABLE');
1886: arp_message.set_token('TABLE_NAME','CSI_T_PARTY_ACCOUNTS',FALSE);
1887:
1888: OPEN merged_records;
1889: CLOSE merged_records;
1890:
1891: write_to_cr_log( 'Done Locking the csi_t_party_accounts' );
1892: ELSE
1893: write_to_cr_log( 'Starting to update the csi_t_party_accounts' );
1894:
1895: ARP_MESSAGE.SET_NAME('AR','AR_UPDATING_TABLE');
1896: ARP_MESSAGE.SET_TOKEN('TABLE_NAME','CSI_T_PARTY_ACCOUNTS',FALSE);
1897: HZ_ACCT_MERGE_UTIL.load_set(set_num, req_id);
1898: l_profile_val := FND_PROFILE.VALUE('HZ_AUDIT_ACCT_MERGE');
1899:
1892: ELSE
1893: write_to_cr_log( 'Starting to update the csi_t_party_accounts' );
1894:
1895: ARP_MESSAGE.SET_NAME('AR','AR_UPDATING_TABLE');
1896: ARP_MESSAGE.SET_TOKEN('TABLE_NAME','CSI_T_PARTY_ACCOUNTS',FALSE);
1897: HZ_ACCT_MERGE_UTIL.load_set(set_num, req_id);
1898: l_profile_val := FND_PROFILE.VALUE('HZ_AUDIT_ACCT_MERGE');
1899:
1900: OPEN merged_records;
1989: END LOOP;
1990:
1991: CLOSE merged_records;
1992:
1993: arp_message.set_name('AR','AR_ROWS_UPDATED');
1994: arp_message.set_token('NUM_ROWS',to_char(l_count));
1995: arp_message.set_line( 'Done with the update of csi_t_party_accounts' );
1996:
1997: END IF;
1990:
1991: CLOSE merged_records;
1992:
1993: arp_message.set_name('AR','AR_ROWS_UPDATED');
1994: arp_message.set_token('NUM_ROWS',to_char(l_count));
1995: arp_message.set_line( 'Done with the update of csi_t_party_accounts' );
1996:
1997: END IF;
1998:
1991: CLOSE merged_records;
1992:
1993: arp_message.set_name('AR','AR_ROWS_UPDATED');
1994: arp_message.set_token('NUM_ROWS',to_char(l_count));
1995: arp_message.set_line( 'Done with the update of csi_t_party_accounts' );
1996:
1997: END IF;
1998:
1999: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_T_PARTY_ACCOUNTS_MERGE()-');
1995: arp_message.set_line( 'Done with the update of csi_t_party_accounts' );
1996:
1997: END IF;
1998:
1999: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_T_PARTY_ACCOUNTS_MERGE()-');
2000:
2001: EXCEPTION
2002: WHEN OTHERS THEN
2003: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_T_PARTY_ACCOUNTS_MERGE()-');
1999: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_T_PARTY_ACCOUNTS_MERGE()-');
2000:
2001: EXCEPTION
2002: WHEN OTHERS THEN
2003: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_T_PARTY_ACCOUNTS_MERGE()-');
2004: CLOSE merged_records;
2005: raise;
2006: END csi_t_party_accounts_merge;
2007:
2073: AND m.set_number = set_num;
2074:
2075: BEGIN
2076:
2077: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_T_TXN_SYSTEMS_MERGE()+');
2078:
2079: IF (process_mode = 'LOCK') THEN
2080: write_to_cr_log( 'Locking the CSI_T_TXN_SYSTEMS table' );
2081:
2078:
2079: IF (process_mode = 'LOCK') THEN
2080: write_to_cr_log( 'Locking the CSI_T_TXN_SYSTEMS table' );
2081:
2082: arp_message.set_name('AR','AR_LOCKING_TABLE');
2083: arp_message.set_token('TABLE_NAME','CSI_T_TXN_SYSTEMS',FALSE);
2084:
2085: OPEN merged_records;
2086: CLOSE merged_records;
2079: IF (process_mode = 'LOCK') THEN
2080: write_to_cr_log( 'Locking the CSI_T_TXN_SYSTEMS table' );
2081:
2082: arp_message.set_name('AR','AR_LOCKING_TABLE');
2083: arp_message.set_token('TABLE_NAME','CSI_T_TXN_SYSTEMS',FALSE);
2084:
2085: OPEN merged_records;
2086: CLOSE merged_records;
2087:
2086: CLOSE merged_records;
2087:
2088: write_to_cr_log( 'Done Locking the CSI_T_TXN_SYSTEMS table' );
2089: ELSE
2090: ARP_MESSAGE.SET_NAME('AR','AR_UPDATING_TABLE');
2091: ARP_MESSAGE.SET_TOKEN('TABLE_NAME','CSI_T_TXN_SYSTEMS',FALSE);
2092: HZ_ACCT_MERGE_UTIL.load_set(set_num, req_id);
2093: l_profile_val := FND_PROFILE.VALUE('HZ_AUDIT_ACCT_MERGE');
2094:
2087:
2088: write_to_cr_log( 'Done Locking the CSI_T_TXN_SYSTEMS table' );
2089: ELSE
2090: ARP_MESSAGE.SET_NAME('AR','AR_UPDATING_TABLE');
2091: ARP_MESSAGE.SET_TOKEN('TABLE_NAME','CSI_T_TXN_SYSTEMS',FALSE);
2092: HZ_ACCT_MERGE_UTIL.load_set(set_num, req_id);
2093: l_profile_val := FND_PROFILE.VALUE('HZ_AUDIT_ACCT_MERGE');
2094:
2095: OPEN merged_records;
2186: END LOOP;
2187:
2188: CLOSE merged_records;
2189:
2190: arp_message.set_name('AR','AR_ROWS_UPDATED');
2191: arp_message.set_token('NUM_ROWS',to_char(l_count));
2192: arp_message.set_line( 'Done with the update of CSI_T_TXN_SYSTEMS' );
2193:
2194: END IF;
2187:
2188: CLOSE merged_records;
2189:
2190: arp_message.set_name('AR','AR_ROWS_UPDATED');
2191: arp_message.set_token('NUM_ROWS',to_char(l_count));
2192: arp_message.set_line( 'Done with the update of CSI_T_TXN_SYSTEMS' );
2193:
2194: END IF;
2195:
2188: CLOSE merged_records;
2189:
2190: arp_message.set_name('AR','AR_ROWS_UPDATED');
2191: arp_message.set_token('NUM_ROWS',to_char(l_count));
2192: arp_message.set_line( 'Done with the update of CSI_T_TXN_SYSTEMS' );
2193:
2194: END IF;
2195:
2196: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_T_TXN_SYSTEMS_MERGE()-');
2192: arp_message.set_line( 'Done with the update of CSI_T_TXN_SYSTEMS' );
2193:
2194: END IF;
2195:
2196: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_T_TXN_SYSTEMS_MERGE()-');
2197:
2198: EXCEPTION
2199: WHEN OTHERS THEN
2200: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_T_TXN_SYSTEMS_MERGE()-');
2196: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_T_TXN_SYSTEMS_MERGE()-');
2197:
2198: EXCEPTION
2199: WHEN OTHERS THEN
2200: arp_message.set_line('CSI_ACCT_MERGE_PKG.CSI_T_TXN_SYSTEMS_MERGE()-');
2201: CLOSE merged_records;
2202: raise;
2203: END csi_t_txn_systems_merge;
2204:
2204:
2205: PROCEDURE write_to_cr_log ( p_message IN VARCHAR2) IS
2206: BEGIN
2207: IF csi_acct_merge_pkg.g_debug_on > 0 THEN
2208: arp_message.set_line( p_message );
2209: END IF;
2210: END write_to_cr_log;
2211:
2212: END CSI_ACCT_MERGE_PKG;