58: ) IS
59:
60: BEGIN
61:
62: arp_message.set_line( 'ARP_CMERGE_ARCPF.MERGE()+' );
63:
64: --merge hz_customer_profiles
65: ar_cp( req_id, set_num, process_mode );
66:
66:
67: --merge hz_customer_profile_amts
68: ar_cpa( req_id, set_num, process_mode );
69:
70: arp_message.set_line( 'ARP_CMERGE_ARCPF.MERGE()-' );
71:
72: END merge;
73:
74: /*===========================================================================+
133: FOR UPDATE NOWAIT;
134:
135: BEGIN
136:
137: arp_message.set_line( 'ARP_CMERGE_ARCPF.AR_CH()+' );
138:
139: --delete only if delete = 'Y', otherwise leave in as historical data
140: --lock table
141: OPEN c1;
145: CLOSE c2;
146:
147: --site level delete
148:
149: arp_message.set_name( 'AR', 'AR_DELETING_TABLE' );
150: arp_message.set_token( 'TABLE_NAME', 'AR_CREDIT_HISTORIES', FALSE );
151:
152: --Bug 1725662: Modified 'ar_ch' to use index.
153:
146:
147: --site level delete
148:
149: arp_message.set_name( 'AR', 'AR_DELETING_TABLE' );
150: arp_message.set_token( 'TABLE_NAME', 'AR_CREDIT_HISTORIES', FALSE );
151:
152: --Bug 1725662: Modified 'ar_ch' to use index.
153:
154: DELETE FROM AR_CREDIT_HISTORIES yt
161: AND m.delete_duplicate_flag = 'Y');
162:
163: g_count := sql%rowcount;
164:
165: arp_message.set_name( 'AR', 'AR_ROWS_DELETED' );
166: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
167:
168: --customer level delete
169:
162:
163: g_count := sql%rowcount;
164:
165: arp_message.set_name( 'AR', 'AR_ROWS_DELETED' );
166: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
167:
168: --customer level delete
169:
170: arp_message.set_name( 'AR', 'AR_DELETING_TABLE' );
166: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
167:
168: --customer level delete
169:
170: arp_message.set_name( 'AR', 'AR_DELETING_TABLE' );
171: arp_message.set_token( 'TABLE_NAME', 'AR_CREDIT_HISTORIES', FALSE );
172:
173: DELETE FROM AR_CREDIT_HISTORIES yt
174: WHERE customer_id IN (
167:
168: --customer level delete
169:
170: arp_message.set_name( 'AR', 'AR_DELETING_TABLE' );
171: arp_message.set_token( 'TABLE_NAME', 'AR_CREDIT_HISTORIES', FALSE );
172:
173: DELETE FROM AR_CREDIT_HISTORIES yt
174: WHERE customer_id IN (
175: SELECT m.duplicate_id
186: AND acct.status <> 'D' );
187:
188: g_count := sql%rowcount;
189:
190: arp_message.set_name( 'AR', 'AR_ROWS_DELETED' );
191: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
192:
193: arp_message.set_line( 'ARP_CMERGE_ARCPF.AR_CH()-' );
194:
187:
188: g_count := sql%rowcount;
189:
190: arp_message.set_name( 'AR', 'AR_ROWS_DELETED' );
191: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
192:
193: arp_message.set_line( 'ARP_CMERGE_ARCPF.AR_CH()-' );
194:
195: EXCEPTION
189:
190: arp_message.set_name( 'AR', 'AR_ROWS_DELETED' );
191: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
192:
193: arp_message.set_line( 'ARP_CMERGE_ARCPF.AR_CH()-' );
194:
195: EXCEPTION
196:
197: WHEN OTHERS THEN
194:
195: EXCEPTION
196:
197: WHEN OTHERS THEN
198: arp_message.set_error( 'ARP_CMERGE_ARCPF.AR_CH');
199: RAISE;
200:
201: END ar_ch;
202:
280: FOR UPDATE NOWAIT;
281:
282: BEGIN
283:
284: arp_message.set_line( 'ARP_CMERGE_ARCPF.AR_CP()+' );
285:
286: IF process_mode = 'LOCK' THEN
287:
288: arp_message.set_name( 'AR', 'AR_LOCKING_TABLE' );
284: arp_message.set_line( 'ARP_CMERGE_ARCPF.AR_CP()+' );
285:
286: IF process_mode = 'LOCK' THEN
287:
288: arp_message.set_name( 'AR', 'AR_LOCKING_TABLE' );
289: arp_message.set_token( 'TABLE_NAME', 'HZ_CUSTOMER_PROFILES', FALSE );
290:
291: OPEN c1;
292: CLOSE c1;
285:
286: IF process_mode = 'LOCK' THEN
287:
288: arp_message.set_name( 'AR', 'AR_LOCKING_TABLE' );
289: arp_message.set_token( 'TABLE_NAME', 'HZ_CUSTOMER_PROFILES', FALSE );
290:
291: OPEN c1;
292: CLOSE c1;
293:
301:
302: /*************** 'inactivate' mode ***************/
303:
304: --site level inactivate
305: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE' );
306: arp_message.set_token( 'TABLE_NAME', 'HZ_CUSTOMER_PROFILES', FALSE );
307:
308: UPDATE hz_customer_profiles yt
309: SET status = 'I',
302: /*************** 'inactivate' mode ***************/
303:
304: --site level inactivate
305: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE' );
306: arp_message.set_token( 'TABLE_NAME', 'HZ_CUSTOMER_PROFILES', FALSE );
307:
308: UPDATE hz_customer_profiles yt
309: SET status = 'I',
310: last_update_date = sysdate,
323: AND m.delete_duplicate_flag = 'N' ) ;
324:
325: g_count := sql%rowcount;
326:
327: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
328: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
329:
330: --customer level inactivate
331: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE' );
324:
325: g_count := sql%rowcount;
326:
327: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
328: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
329:
330: --customer level inactivate
331: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE' );
332: arp_message.set_token( 'TABLE_NAME', 'HZ_CUSTOMER_PROFILES', FALSE );
327: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
328: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
329:
330: --customer level inactivate
331: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE' );
332: arp_message.set_token( 'TABLE_NAME', 'HZ_CUSTOMER_PROFILES', FALSE );
333:
334: UPDATE hz_customer_profiles yt
335: SET status = 'I',
328: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
329:
330: --customer level inactivate
331: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE' );
332: arp_message.set_token( 'TABLE_NAME', 'HZ_CUSTOMER_PROFILES', FALSE );
333:
334: UPDATE hz_customer_profiles yt
335: SET status = 'I',
336: last_update_date = sysdate,
355: AND acct.status = 'A');
356:
357: g_count := sql%rowcount;
358:
359: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
360: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
361:
362: /*************** 'delete' mode ***************/
363: --Bug 1535542: Mark the rows need to be deleted by setting status to 'D'.
356:
357: g_count := sql%rowcount;
358:
359: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
360: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
361:
362: /*************** 'delete' mode ***************/
363: --Bug 1535542: Mark the rows need to be deleted by setting status to 'D'.
364: --Physically delete them after merge.
363: --Bug 1535542: Mark the rows need to be deleted by setting status to 'D'.
364: --Physically delete them after merge.
365:
366: --site level 'delete'
367: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE' );
368: arp_message.set_token( 'TABLE_NAME', 'HZ_CUSTOMER_PROFILES', FALSE );
369:
370: UPDATE hz_customer_profiles
371: SET status = 'D'
364: --Physically delete them after merge.
365:
366: --site level 'delete'
367: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE' );
368: arp_message.set_token( 'TABLE_NAME', 'HZ_CUSTOMER_PROFILES', FALSE );
369:
370: UPDATE hz_customer_profiles
371: SET status = 'D'
372: WHERE site_use_id IN (
378: AND m.delete_duplicate_flag = 'Y' ) ;
379:
380: g_count := sql%rowcount;
381:
382: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
383: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
384:
385: --customer level 'delete'
386: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE' );
379:
380: g_count := sql%rowcount;
381:
382: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
383: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
384:
385: --customer level 'delete'
386: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE' );
387: arp_message.set_token( 'TABLE_NAME', 'HZ_CUSTOMER_PROFILES', FALSE );
382: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
383: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
384:
385: --customer level 'delete'
386: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE' );
387: arp_message.set_token( 'TABLE_NAME', 'HZ_CUSTOMER_PROFILES', FALSE );
388:
389: UPDATE hz_customer_profiles yt
390: SET status = 'D'
383: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
384:
385: --customer level 'delete'
386: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE' );
387: arp_message.set_token( 'TABLE_NAME', 'HZ_CUSTOMER_PROFILES', FALSE );
388:
389: UPDATE hz_customer_profiles yt
390: SET status = 'D'
391: WHERE cust_account_id IN (
403: AND acct.status <> 'D' );
404:
405: g_count := sql%rowcount;
406:
407: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
408: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
409:
410: END IF;
411:
404:
405: g_count := sql%rowcount;
406:
407: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
408: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
409:
410: END IF;
411:
412: arp_message.set_line( 'ARP_CMERGE_ARCPF.AR_CP()-' );
408: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
409:
410: END IF;
411:
412: arp_message.set_line( 'ARP_CMERGE_ARCPF.AR_CP()-' );
413:
414: EXCEPTION
415:
416: WHEN OTHERS THEN
413:
414: EXCEPTION
415:
416: WHEN OTHERS THEN
417: arp_message.set_error( 'ARP_CMERGE_ARCPF.AR_CP');
418: RAISE;
419:
420: END ar_cp;
421:
483: FOR UPDATE NOWAIT;
484:
485: BEGIN
486:
487: arp_message.set_line( 'ARP_CMERGE_ARCPF.AR_CPA()+' );
488:
489: IF process_mode = 'LOCK' THEN
490:
491: arp_message.set_name( 'AR', 'AR_LOCKING_TABLE' );
487: arp_message.set_line( 'ARP_CMERGE_ARCPF.AR_CPA()+' );
488:
489: IF process_mode = 'LOCK' THEN
490:
491: arp_message.set_name( 'AR', 'AR_LOCKING_TABLE' );
492: arp_message.set_token( 'TABLE_NAME', 'HZ_CUST_PROFILE_AMTS', FALSE );
493:
494: OPEN c1;
495: CLOSE c1;
488:
489: IF process_mode = 'LOCK' THEN
490:
491: arp_message.set_name( 'AR', 'AR_LOCKING_TABLE' );
492: arp_message.set_token( 'TABLE_NAME', 'HZ_CUST_PROFILE_AMTS', FALSE );
493:
494: OPEN c1;
495: CLOSE c1;
496:
501:
502: /*************** 'inactivate' mode ***************/
503:
504: --site level inactivate
505: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
506: arp_message.set_token( 'TABLE_NAME', 'HZ_CUST_PROFILE_AMTS', FALSE );
507:
508: UPDATE HZ_CUST_PROFILE_AMTS yt
509: SET last_update_date = sysdate,
502: /*************** 'inactivate' mode ***************/
503:
504: --site level inactivate
505: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
506: arp_message.set_token( 'TABLE_NAME', 'HZ_CUST_PROFILE_AMTS', FALSE );
507:
508: UPDATE HZ_CUST_PROFILE_AMTS yt
509: SET last_update_date = sysdate,
510: last_updated_by = arp_standard.profile.user_id,
522: AND m.delete_duplicate_flag = 'N' );
523:
524: g_count := sql%rowcount;
525:
526: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
527: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
528:
529: --customer level inactivate
530: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE' );
523:
524: g_count := sql%rowcount;
525:
526: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
527: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
528:
529: --customer level inactivate
530: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE' );
531: arp_message.set_token( 'TABLE_NAME', 'HZ_CUST_PROFILE_AMTS', FALSE );
526: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
527: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
528:
529: --customer level inactivate
530: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE' );
531: arp_message.set_token( 'TABLE_NAME', 'HZ_CUST_PROFILE_AMTS', FALSE );
532:
533: UPDATE HZ_CUST_PROFILE_AMTS yt
534: SET last_update_date = sysdate,
527: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
528:
529: --customer level inactivate
530: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE' );
531: arp_message.set_token( 'TABLE_NAME', 'HZ_CUST_PROFILE_AMTS', FALSE );
532:
533: UPDATE HZ_CUST_PROFILE_AMTS yt
534: SET last_update_date = sysdate,
535: last_updated_by = arp_standard.profile.user_id,
553: AND acct.status = 'A') ;
554:
555: g_count := sql%rowcount;
556:
557: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
558: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
559:
560: END IF;
561:
554:
555: g_count := sql%rowcount;
556:
557: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
558: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
559:
560: END IF;
561:
562: arp_message.set_line( 'ARP_CMERGE_ARCPF.AR_CPA()-' );
558: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
559:
560: END IF;
561:
562: arp_message.set_line( 'ARP_CMERGE_ARCPF.AR_CPA()-' );
563:
564: EXCEPTION
565:
566: WHEN OTHERS THEN
563:
564: EXCEPTION
565:
566: WHEN OTHERS THEN
567: arp_message.set_error( 'ARP_CMERGE_ARCPF.AR_CPA');
568: RAISE;
569:
570: END ar_cpa;
571:
640: FOR UPDATE NOWAIT;
641:
642: BEGIN
643:
644: arp_message.set_line( 'ARP_CMERGE_ARCPF.delete_rows()+' );
645:
646: /*****************************************************/
647:
648: --Bug 1535542: Because ar_ch procedure works only in delete mode, we call it here
651: ar_ch( req_id, set_num, 'DUMMY' );
652:
653: /*****************************************************/
654:
655: arp_message.set_name( 'AR', 'AR_DELETING_TABLE');
656: arp_message.set_token( 'TABLE_NAME', 'HZ_CUSTOMER_PROFILES', FALSE );
657:
658: OPEN profiles;
659: CLOSE profiles;
652:
653: /*****************************************************/
654:
655: arp_message.set_name( 'AR', 'AR_DELETING_TABLE');
656: arp_message.set_token( 'TABLE_NAME', 'HZ_CUSTOMER_PROFILES', FALSE );
657:
658: OPEN profiles;
659: CLOSE profiles;
660:
669: AND status = 'D';
670:
671: g_count := sql%rowcount;
672:
673: arp_message.set_name( 'AR', 'AR_ROWS_DELETED' );
674: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
675:
676: /*****************************************************/
677:
670:
671: g_count := sql%rowcount;
672:
673: arp_message.set_name( 'AR', 'AR_ROWS_DELETED' );
674: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
675:
676: /*****************************************************/
677:
678: arp_message.set_name( 'AR', 'AR_DELETING_TABLE' );
674: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
675:
676: /*****************************************************/
677:
678: arp_message.set_name( 'AR', 'AR_DELETING_TABLE' );
679: arp_message.set_token( 'TABLE_NAME', 'HZ_CUST_PROFILE_AMTS', FALSE );
680:
681: OPEN profile_amt_site;
682: CLOSE profile_amt_site;
675:
676: /*****************************************************/
677:
678: arp_message.set_name( 'AR', 'AR_DELETING_TABLE' );
679: arp_message.set_token( 'TABLE_NAME', 'HZ_CUST_PROFILE_AMTS', FALSE );
680:
681: OPEN profile_amt_site;
682: CLOSE profile_amt_site;
683:
695: AND m.delete_duplicate_flag = 'Y' );
696:
697: g_count := sql%rowcount;
698:
699: arp_message.set_name( 'AR', 'AR_ROWS_DELETED' );
700: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
701:
702: arp_message.set_name( 'AR', 'AR_DELETING_TABLE' );
703: arp_message.set_token( 'TABLE_NAME', 'HZ_CUST_PROFILE_AMTS', FALSE );
696:
697: g_count := sql%rowcount;
698:
699: arp_message.set_name( 'AR', 'AR_ROWS_DELETED' );
700: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
701:
702: arp_message.set_name( 'AR', 'AR_DELETING_TABLE' );
703: arp_message.set_token( 'TABLE_NAME', 'HZ_CUST_PROFILE_AMTS', FALSE );
704:
698:
699: arp_message.set_name( 'AR', 'AR_ROWS_DELETED' );
700: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
701:
702: arp_message.set_name( 'AR', 'AR_DELETING_TABLE' );
703: arp_message.set_token( 'TABLE_NAME', 'HZ_CUST_PROFILE_AMTS', FALSE );
704:
705: --account level
706: DELETE FROM HZ_CUST_PROFILE_AMTS yt
699: arp_message.set_name( 'AR', 'AR_ROWS_DELETED' );
700: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
701:
702: arp_message.set_name( 'AR', 'AR_DELETING_TABLE' );
703: arp_message.set_token( 'TABLE_NAME', 'HZ_CUST_PROFILE_AMTS', FALSE );
704:
705: --account level
706: DELETE FROM HZ_CUST_PROFILE_AMTS yt
707: WHERE cust_account_id IN (
719: AND acct.status <> 'D' );
720:
721: g_count := sql%rowcount;
722:
723: arp_message.set_name( 'AR', 'AR_ROWS_DELETED' );
724: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
725:
726: arp_message.set_line( 'ARP_CMERGE_ARCPF.delete_rows()-' );
727:
720:
721: g_count := sql%rowcount;
722:
723: arp_message.set_name( 'AR', 'AR_ROWS_DELETED' );
724: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
725:
726: arp_message.set_line( 'ARP_CMERGE_ARCPF.delete_rows()-' );
727:
728: EXCEPTION
722:
723: arp_message.set_name( 'AR', 'AR_ROWS_DELETED' );
724: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
725:
726: arp_message.set_line( 'ARP_CMERGE_ARCPF.delete_rows()-' );
727:
728: EXCEPTION
729:
730: WHEN OTHERS THEN
727:
728: EXCEPTION
729:
730: WHEN OTHERS THEN
731: arp_message.set_error( 'ARP_CMERGE_ARCPF.delete_rows' );
732: RAISE;
733:
734: END delete_rows;
735: