42: for update nowait;
43:
44: BEGIN
45:
46: arp_message.set_line( 'OEP_CMERGE_OEORD.OE_SH()+' );
47:
48: /*-----------------------------+
49: | SO_HEADERS |
50: +-----------------------------*/
51: /* both customer and site level */
52:
53: IF( process_mode = 'LOCK' ) THEN
54:
55: arp_message.set_name( 'AR', 'AR_LOCKING_TABLE');
56: arp_message.set_token( 'TABLE_NAME', 'SO_HEADERS', FALSE );
57:
58: open c1;
59: close c1;
52:
53: IF( process_mode = 'LOCK' ) THEN
54:
55: arp_message.set_name( 'AR', 'AR_LOCKING_TABLE');
56: arp_message.set_token( 'TABLE_NAME', 'SO_HEADERS', FALSE );
57:
58: open c1;
59: close c1;
60:
67: ELSE
68:
69:
70: /* site level update */
71: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
72: arp_message.set_token( 'TABLE_NAME', 'SO_HEADERS', FALSE );
73:
74: UPDATE SO_HEADERS a
75: set (ship_to_site_use_id) = (select distinct m.customer_site_id
68:
69:
70: /* site level update */
71: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
72: arp_message.set_token( 'TABLE_NAME', 'SO_HEADERS', FALSE );
73:
74: UPDATE SO_HEADERS a
75: set (ship_to_site_use_id) = (select distinct m.customer_site_id
76: from ra_customer_merges m
93: and m.set_number = set_num);
94:
95: g_count := sql%rowcount;
96:
97: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
98: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
99:
100: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
101: arp_message.set_token( 'TABLE_NAME', 'SO_HEADERS', FALSE );
94:
95: g_count := sql%rowcount;
96:
97: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
98: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
99:
100: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
101: arp_message.set_token( 'TABLE_NAME', 'SO_HEADERS', FALSE );
102:
96:
97: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
98: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
99:
100: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
101: arp_message.set_token( 'TABLE_NAME', 'SO_HEADERS', FALSE );
102:
103: UPDATE SO_HEADERS a
104: set (invoice_to_site_use_id) = (select distinct m.customer_site_id
97: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
98: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
99:
100: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
101: arp_message.set_token( 'TABLE_NAME', 'SO_HEADERS', FALSE );
102:
103: UPDATE SO_HEADERS a
104: set (invoice_to_site_use_id) = (select distinct m.customer_site_id
105: from ra_customer_merges m
122: and m.set_number = set_num);
123:
124: g_count := sql%rowcount;
125:
126: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
127: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
128:
129: /* customer level update */
130: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
123:
124: g_count := sql%rowcount;
125:
126: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
127: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
128:
129: /* customer level update */
130: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
131: arp_message.set_token( 'TABLE_NAME', 'SO_HEADERS', FALSE );
126: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
127: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
128:
129: /* customer level update */
130: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
131: arp_message.set_token( 'TABLE_NAME', 'SO_HEADERS', FALSE );
132:
133: UPDATE SO_HEADERS a
134: set customer_id = (select distinct m.customer_id
127: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
128:
129: /* customer level update */
130: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
131: arp_message.set_token( 'TABLE_NAME', 'SO_HEADERS', FALSE );
132:
133: UPDATE SO_HEADERS a
134: set customer_id = (select distinct m.customer_id
135: from ra_customer_merges m
152: and m.set_number = set_num);
153:
154: g_count := sql%rowcount;
155:
156: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
157: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
158:
159: END IF;
160:
153:
154: g_count := sql%rowcount;
155:
156: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
157: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
158:
159: END IF;
160:
161: arp_message.set_line( 'OEP_CMERGE_OEORD.OE_SH()-' );
157: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
158:
159: END IF;
160:
161: arp_message.set_line( 'OEP_CMERGE_OEORD.OE_SH()-' );
162:
163:
164: EXCEPTION
165: when others then
162:
163:
164: EXCEPTION
165: when others then
166: arp_message.set_error( 'OEP_CMERGE_OEORD.OE_SH');
167: raise;
168:
169: END;
170:
183: for update nowait;
184:
185: BEGIN
186:
187: arp_message.set_line( 'OEP_CMERGE_OEORD.OE_SL()+' );
188:
189: /*-----------------------------+
190: | SO_LINES |
191: +-----------------------------*/
192: /* both customer and site level */
193:
194: IF( process_mode = 'LOCK' ) THEN
195:
196: arp_message.set_name( 'AR', 'AR_LOCKING_TABLE');
197: arp_message.set_token( 'TABLE_NAME', 'SO_LINES', FALSE );
198:
199: open c1;
200: close c1;
193:
194: IF( process_mode = 'LOCK' ) THEN
195:
196: arp_message.set_name( 'AR', 'AR_LOCKING_TABLE');
197: arp_message.set_token( 'TABLE_NAME', 'SO_LINES', FALSE );
198:
199: open c1;
200: close c1;
201:
202: ELSE
203:
204:
205: /* site level update */
206: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
207: arp_message.set_token( 'TABLE_NAME', 'SO_LINES', FALSE );
208:
209: UPDATE SO_LINES a
210: set (ship_to_site_use_id) = (select distinct m.customer_site_id
203:
204:
205: /* site level update */
206: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
207: arp_message.set_token( 'TABLE_NAME', 'SO_LINES', FALSE );
208:
209: UPDATE SO_LINES a
210: set (ship_to_site_use_id) = (select distinct m.customer_site_id
211: from ra_customer_merges m
228: and m.set_number = set_num);
229:
230: g_count := sql%rowcount;
231:
232: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
233: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
234:
235: END IF;
236:
229:
230: g_count := sql%rowcount;
231:
232: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
233: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
234:
235: END IF;
236:
237: arp_message.set_line( 'OEP_CMERGE_OEORD.OE_SL()-' );
233: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
234:
235: END IF;
236:
237: arp_message.set_line( 'OEP_CMERGE_OEORD.OE_SL()-' );
238:
239:
240: EXCEPTION
241: when others then
238:
239:
240: EXCEPTION
241: when others then
242: arp_message.set_error( 'OEP_CMERGE_OEORD.OE_SL');
243: raise;
244:
245: END;
246:
257: for update nowait;
258:
259: BEGIN
260:
261: arp_message.set_line( 'OEP_CMERGE_OEORD.OE_SD()+' );
262:
263: /*-----------------------------+
264: | SO_LINE_SERVICE_DETAILS |
265: +-----------------------------*/
266: /* both customer and site level */
267:
268: IF( process_mode = 'LOCK' ) THEN
269:
270: arp_message.set_name( 'AR', 'AR_LOCKING_TABLE');
271: arp_message.set_token( 'TABLE_NAME', 'SO_LINE_SERVICE_DETAILS', FALSE );
272:
273: open c1;
274: close c1;
267:
268: IF( process_mode = 'LOCK' ) THEN
269:
270: arp_message.set_name( 'AR', 'AR_LOCKING_TABLE');
271: arp_message.set_token( 'TABLE_NAME', 'SO_LINE_SERVICE_DETAILS', FALSE );
272:
273: open c1;
274: close c1;
275:
276: ELSE
277:
278:
279: /* site level update */
280: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
281: arp_message.set_token( 'TABLE_NAME', 'SO_LINE_SERVICE_DETAILS', FALSE );
282:
283: UPDATE SO_LINE_SERVICE_DETAILS a
284: set (installation_site_use_id) = (select distinct m.customer_site_id
277:
278:
279: /* site level update */
280: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
281: arp_message.set_token( 'TABLE_NAME', 'SO_LINE_SERVICE_DETAILS', FALSE );
282:
283: UPDATE SO_LINE_SERVICE_DETAILS a
284: set (installation_site_use_id) = (select distinct m.customer_site_id
285: from ra_customer_merges m
298: and m.set_number = set_num);
299:
300: g_count := sql%rowcount;
301:
302: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
303: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
304:
305: END IF;
306:
299:
300: g_count := sql%rowcount;
301:
302: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
303: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
304:
305: END IF;
306:
307: arp_message.set_line( 'OEP_CMERGE_OEORD.OE_SD()-' );
303: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
304:
305: END IF;
306:
307: arp_message.set_line( 'OEP_CMERGE_OEORD.OE_SD()-' );
308:
309:
310: EXCEPTION
311: when others then
308:
309:
310: EXCEPTION
311: when others then
312: arp_message.set_error( 'OEP_CMERGE_OEORD.OE_SD');
313: raise;
314:
315: END;
316:
328: for update nowait;
329:
330: BEGIN
331:
332: arp_message.set_line( 'OEP_CMERGE_OEORD.OE_OA()+' );
333:
334: /*-----------------------------+
335: | SO_ORDER_APPROVALS |
336: +-----------------------------*/
337: /* both customer and site level */
338:
339: IF( process_mode = 'LOCK' ) THEN
340:
341: arp_message.set_name( 'AR', 'AR_LOCKING_TABLE');
342: arp_message.set_token( 'TABLE_NAME', 'SO_ORDER_APPROVALS', FALSE );
343:
344: open c1;
345: close c1;
338:
339: IF( process_mode = 'LOCK' ) THEN
340:
341: arp_message.set_name( 'AR', 'AR_LOCKING_TABLE');
342: arp_message.set_token( 'TABLE_NAME', 'SO_ORDER_APPROVALS', FALSE );
343:
344: open c1;
345: close c1;
346:
346:
347: ELSE
348:
349: /* customer level update */
350: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
351: arp_message.set_token( 'TABLE_NAME', 'SO_ORDER_APPROVALS', FALSE );
352:
353: UPDATE SO_ORDER_APPROVALS a
354: set customer_id = (select distinct m.customer_id
347: ELSE
348:
349: /* customer level update */
350: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
351: arp_message.set_token( 'TABLE_NAME', 'SO_ORDER_APPROVALS', FALSE );
352:
353: UPDATE SO_ORDER_APPROVALS a
354: set customer_id = (select distinct m.customer_id
355: from ra_customer_merges m
368: and m.set_number = set_num);
369:
370: g_count := sql%rowcount;
371:
372: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
373: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
374:
375: END IF;
376:
369:
370: g_count := sql%rowcount;
371:
372: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
373: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
374:
375: END IF;
376:
377: arp_message.set_line( 'OEP_CMERGE_OEORD.OE_OA()-' );
373: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
374:
375: END IF;
376:
377: arp_message.set_line( 'OEP_CMERGE_OEORD.OE_OA()-' );
378:
379:
380: EXCEPTION
381: when others then
378:
379:
380: EXCEPTION
381: when others then
382: arp_message.set_error( 'OEP_CMERGE_OEORD.OE_OA');
383: raise;
384:
385: END;
386:
413:
414:
415: BEGIN
416:
417: arp_message.set_line( 'OEP_CMERGE_OEORD.OE_VR()+' );
418:
419:
420:
421: /*-----------------------------+
424: /* both customer and site level */
425:
426: IF( process_mode = 'LOCK' ) THEN
427:
428: arp_message.set_name( 'AR', 'AR_LOCKING_TABLE');
429: arp_message.set_token( 'TABLE_NAME', 'SO_STANDARD_VALUE_RULES', FALSE );
430:
431: open c1;
432: close c1;
425:
426: IF( process_mode = 'LOCK' ) THEN
427:
428: arp_message.set_name( 'AR', 'AR_LOCKING_TABLE');
429: arp_message.set_token( 'TABLE_NAME', 'SO_STANDARD_VALUE_RULES', FALSE );
430:
431: open c1;
432: close c1;
433:
438: ELSE
439:
440:
441: /* site level update */
442: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
443: arp_message.set_token( 'TABLE_NAME', 'SO_STANDARD_VALUE_RULES', FALSE );
444:
445:
446:
439:
440:
441: /* site level update */
442: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
443: arp_message.set_token( 'TABLE_NAME', 'SO_STANDARD_VALUE_RULES', FALSE );
444:
445:
446:
447: UPDATE SO_STANDARD_VALUE_RULES a
464: and attribute_id = 10026;
465:
466: g_count := sql%rowcount;
467:
468: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
469: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
470:
471:
472: /* site level update */
465:
466: g_count := sql%rowcount;
467:
468: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
469: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
470:
471:
472: /* site level update */
473: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
469: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
470:
471:
472: /* site level update */
473: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
474: arp_message.set_token( 'TABLE_NAME', 'SO_STANDARD_VALUE_RULES', FALSE );
475:
476:
477:
470:
471:
472: /* site level update */
473: arp_message.set_name( 'AR', 'AR_UPDATING_TABLE');
474: arp_message.set_token( 'TABLE_NAME', 'SO_STANDARD_VALUE_RULES', FALSE );
475:
476:
477:
478: UPDATE SO_STANDARD_VALUE_RULES a
495: and attribute_id = 10028;
496:
497: g_count := sql%rowcount;
498:
499: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
500: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
501:
502:
503: END IF;
496:
497: g_count := sql%rowcount;
498:
499: arp_message.set_name( 'AR', 'AR_ROWS_UPDATED' );
500: arp_message.set_token( 'NUM_ROWS', to_char(g_count) );
501:
502:
503: END IF;
504:
501:
502:
503: END IF;
504:
505: arp_message.set_line( 'OEP_CMERGE_OEORD.OE_VR()-' );
506:
507:
508: EXCEPTION
509: when others then
506:
507:
508: EXCEPTION
509: when others then
510: arp_message.set_error( 'OEP_CMERGE_OEORD.OE_VR');
511: raise;
512:
513: END;
514:
519:
520: PROCEDURE MERGE (REQ_ID NUMBER, SET_NUM NUMBER, PROCESS_MODE VARCHAR2) IS
521: BEGIN
522:
523: arp_message.set_line( 'OEP_CMERGE_OEORD.MERGE()+' );
524:
525: oe_sh( req_id, set_num, process_mode );
526: oe_sl( req_id, set_num, process_mode );
527: oe_oa( req_id, set_num, process_mode );
527: oe_oa( req_id, set_num, process_mode );
528: oe_sd( req_id, set_num, process_mode );
529: oe_vr( req_id, set_num, process_mode );
530:
531: arp_message.set_line( 'OEP_CMERGE_OEORD.MERGE()-' );
532:
533: EXCEPTION
534: when others then
535: raise;