121: PROCEDURE oe_pb (req_id NUMBER, set_num NUMBER, process_mode VARCHAR2) is
122:
123: CURSOR c1 is
124: select batch_id
125: from so_picking_batches
126: where site_use_id in (select m.duplicate_site_id
127: from ra_customer_merges m
128: where m.process_flag = 'N'
129: and m.request_id = req_id
131: for update nowait;
132:
133: CURSOR c2 is
134: select batch_id
135: from so_picking_batches
136: where customer_id in (select m.duplicate_id
137: from ra_customer_merges m
138: where m.process_flag = 'N'
139: and m.request_id = req_id
144:
145: arp_message.set_line( 'OEP_CMERGE_OEPIC.OE_PB()+' );
146:
147: /*-----------------------------+
148: | SO_PICKING_BATCHES |
149: +-----------------------------*/
150: /* both customer and site level */
151:
152: IF( process_mode = 'LOCK' ) THEN
151:
152: IF( process_mode = 'LOCK' ) THEN
153:
154: arp_message.set_name( 'AR', 'AR_LOCKING_TABLE');
155: arp_message.set_token( 'TABLE_NAME', 'SO_PICKING_BATCHES', FALSE );
156:
157: open c1;
158: close c1;
159:
164:
165:
166: /* site level update */
167: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
168: arp_message.set_token( 'TABLE_NAME', 'SO_PICKING_BATCHES', FALSE );
169:
170: UPDATE SO_PICKING_BATCHES a
171: set (site_use_id) = (select distinct m.customer_site_id
172: from ra_customer_merges m
166: /* site level update */
167: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
168: arp_message.set_token( 'TABLE_NAME', 'SO_PICKING_BATCHES', FALSE );
169:
170: UPDATE SO_PICKING_BATCHES a
171: set (site_use_id) = (select distinct m.customer_site_id
172: from ra_customer_merges m
173: where a.site_use_id =
174: m.duplicate_site_id
190: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
191:
192: /* customer level update */
193: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
194: arp_message.set_token( 'TABLE_NAME', 'SO_PICKING_BATCHES', FALSE );
195:
196: UPDATE SO_PICKING_BATCHES a
197: set customer_id = (select distinct m.customer_id
198: from ra_customer_merges m
192: /* customer level update */
193: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
194: arp_message.set_token( 'TABLE_NAME', 'SO_PICKING_BATCHES', FALSE );
195:
196: UPDATE SO_PICKING_BATCHES a
197: set customer_id = (select distinct m.customer_id
198: from ra_customer_merges m
199: where a.customer_id =
200: m.duplicate_id