691: Process_Mode IN VARCHAR2)
692: IS
693: CURSOR c1 is
694: select HEADER_ID
695: from OE_HEADER_ACKS
696: where ship_to_org_id in
697: (select m.duplicate_site_id
698: from ra_customer_merges m
699: where m.process_flag = 'Y'
704:
705:
706: CURSOR c2 is
707: select HEADER_ID
708: from OE_HEADER_ACKS
709: where invoice_to_org_id in
710: (select m.duplicate_site_id
711: from ra_customer_merges m
712: where m.process_flag = 'Y'
717:
718:
719: CURSOR c3 is
720: select HEADER_ID
721: from OE_HEADER_ACKS
722: where deliver_to_org_id in
723: (select m.duplicate_site_id
724: from ra_customer_merges m
725: where m.process_flag = 'Y'
729: for update nowait;
730:
731: CURSOR c4 is
732: select HEADER_ID
733: from OE_HEADER_ACKS
734: where sold_to_org_id in
735: (select m.duplicate_id
736: from ra_customer_merges m
737: where m.process_flag = 'Y'
755: /* both customer and site level */
756:
757: IF( process_mode = 'LOCK' ) THEN
758: IF l_debug_level > 0 THEN
759: oe_debug_pub.add( 'LOCKING TABLE OE_HEADER_ACKS' ) ;
760: END IF;
761: -- arp_message.set_name( 'AR', 'AR_LOCKING_TABLE');
762: -- arp_message.set_token( 'TABLE_NAME', 'OE_HEADER_ACKS', FALSE );
763:
758: IF l_debug_level > 0 THEN
759: oe_debug_pub.add( 'LOCKING TABLE OE_HEADER_ACKS' ) ;
760: END IF;
761: -- arp_message.set_name( 'AR', 'AR_LOCKING_TABLE');
762: -- arp_message.set_token( 'TABLE_NAME', 'OE_HEADER_ACKS', FALSE );
763:
764: open c1;
765: close c1;
766:
781: oe_debug_pub.add( 'SITE LEVEL UPDATE' ) ;
782: END IF;
783:
784: -- arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
785: -- arp_message.set_token( 'TABLE_NAME', 'OE_HEADER_ACKS', FALSE );
786: IF l_debug_level > 0 THEN
787: oe_debug_pub.add( 'UPDATING OE_HEADER_ACKS.SHIP_TO_ORG_ID' ) ;
788: END IF;
789:
783:
784: -- arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
785: -- arp_message.set_token( 'TABLE_NAME', 'OE_HEADER_ACKS', FALSE );
786: IF l_debug_level > 0 THEN
787: oe_debug_pub.add( 'UPDATING OE_HEADER_ACKS.SHIP_TO_ORG_ID' ) ;
788: END IF;
789:
790: UPDATE OE_HEADER_ACKS a
791: set ship_to_org_id = (select distinct m.customer_site_id
786: IF l_debug_level > 0 THEN
787: oe_debug_pub.add( 'UPDATING OE_HEADER_ACKS.SHIP_TO_ORG_ID' ) ;
788: END IF;
789:
790: UPDATE OE_HEADER_ACKS a
791: set ship_to_org_id = (select distinct m.customer_site_id
792: from ra_customer_merges m
793: where a.ship_to_org_id = m.duplicate_site_id
794: and m.request_id = req_id
814: oe_debug_pub.add( G_COUNT || ' ROWS UPDATED' ) ;
815: END IF;
816:
817: -- arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
818: -- arp_message.set_token( 'TABLE_NAME', 'OE_HEADER_ACKS', FALSE );
819: IF l_debug_level > 0 THEN
820: oe_debug_pub.add( 'UPDATING OE_HEADER_ACKS.INVOICE_TO_ORG_ID' ) ;
821: END IF;
822:
816:
817: -- arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
818: -- arp_message.set_token( 'TABLE_NAME', 'OE_HEADER_ACKS', FALSE );
819: IF l_debug_level > 0 THEN
820: oe_debug_pub.add( 'UPDATING OE_HEADER_ACKS.INVOICE_TO_ORG_ID' ) ;
821: END IF;
822:
823: UPDATE OE_HEADER_ACKS a
824: set invoice_to_org_id = (select distinct m.customer_site_id
819: IF l_debug_level > 0 THEN
820: oe_debug_pub.add( 'UPDATING OE_HEADER_ACKS.INVOICE_TO_ORG_ID' ) ;
821: END IF;
822:
823: UPDATE OE_HEADER_ACKS a
824: set invoice_to_org_id = (select distinct m.customer_site_id
825: from ra_customer_merges m
826: where a.invoice_to_org_id = m.duplicate_site_id
827: and m.request_id = req_id
847: oe_debug_pub.add( G_COUNT || ' ROWS UPDATED' ) ;
848: END IF;
849:
850: -- arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
851: -- arp_message.set_token( 'TABLE_NAME', 'OE_HEADER_ACKS', FALSE );
852: IF l_debug_level > 0 THEN
853: oe_debug_pub.add( 'UPDATING OE_HEADER_ACKS.DELIVER_TO_ORG_ID' ) ;
854: END IF;
855:
849:
850: -- arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
851: -- arp_message.set_token( 'TABLE_NAME', 'OE_HEADER_ACKS', FALSE );
852: IF l_debug_level > 0 THEN
853: oe_debug_pub.add( 'UPDATING OE_HEADER_ACKS.DELIVER_TO_ORG_ID' ) ;
854: END IF;
855:
856: UPDATE OE_HEADER_ACKS a
857: set deliver_to_org_id = (select distinct m.customer_site_id
852: IF l_debug_level > 0 THEN
853: oe_debug_pub.add( 'UPDATING OE_HEADER_ACKS.DELIVER_TO_ORG_ID' ) ;
854: END IF;
855:
856: UPDATE OE_HEADER_ACKS a
857: set deliver_to_org_id = (select distinct m.customer_site_id
858: from ra_customer_merges m
859: where a.deliver_to_org_id = m.duplicate_site_id
860: and m.request_id = req_id
880: oe_debug_pub.add( G_COUNT || ' ROWS UPDATED' ) ;
881: END IF;
882:
883: -- arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
884: -- arp_message.set_token( 'TABLE_NAME', 'OE_HEADER_ACKS', FALSE );
885:
886:
887: /* customer level update */
888: IF l_debug_level > 0 THEN
888: IF l_debug_level > 0 THEN
889: oe_debug_pub.add( 'CUSTOMER LEVEL UPDATE' ) ;
890: END IF;
891: -- arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
892: -- arp_message.set_token( 'TABLE_NAME', 'OE_HEADER_ACKS', FALSE );
893:
894: IF l_debug_level > 0 THEN
895: oe_debug_pub.add( 'UPDATING OE_HEADER_ACKS.SOLD_TO_ORG_ID' ) ;
896: END IF;
891: -- arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
892: -- arp_message.set_token( 'TABLE_NAME', 'OE_HEADER_ACKS', FALSE );
893:
894: IF l_debug_level > 0 THEN
895: oe_debug_pub.add( 'UPDATING OE_HEADER_ACKS.SOLD_TO_ORG_ID' ) ;
896: END IF;
897:
898: UPDATE OE_HEADER_ACKS a
899: set sold_to_org_id = (select distinct m.customer_id
894: IF l_debug_level > 0 THEN
895: oe_debug_pub.add( 'UPDATING OE_HEADER_ACKS.SOLD_TO_ORG_ID' ) ;
896: END IF;
897:
898: UPDATE OE_HEADER_ACKS a
899: set sold_to_org_id = (select distinct m.customer_id
900: from ra_customer_merges m
901: where a.sold_to_org_id = m.duplicate_id
902: and m.process_flag = 'Y'