31: BEGIN
32:
33: /* Put the header in the report to identify the block to be run */
34:
35: arp_message.set_line('CP_CMERGE_BB7.MERGE()+');
36:
37: IF ( process_mode = 'LOCK' ) Then
38: arp_message.set_name('AR', 'AR_LOCKING_TABLE');
39: arp_message.set_token('TABLE_NAME', 'CS_REPAIRS',FALSE );
34:
35: arp_message.set_line('CP_CMERGE_BB7.MERGE()+');
36:
37: IF ( process_mode = 'LOCK' ) Then
38: arp_message.set_name('AR', 'AR_LOCKING_TABLE');
39: arp_message.set_token('TABLE_NAME', 'CS_REPAIRS',FALSE );
40: message_text := 'The locking is done in block CSP_CMERGE_BB7';
41: arp_message.set_line(message_text);
42: ELSE
35: arp_message.set_line('CP_CMERGE_BB7.MERGE()+');
36:
37: IF ( process_mode = 'LOCK' ) Then
38: arp_message.set_name('AR', 'AR_LOCKING_TABLE');
39: arp_message.set_token('TABLE_NAME', 'CS_REPAIRS',FALSE );
40: message_text := 'The locking is done in block CSP_CMERGE_BB7';
41: arp_message.set_line(message_text);
42: ELSE
43: arp_message.set_name('AR', 'AR_UPDATING_TABLE');
37: IF ( process_mode = 'LOCK' ) Then
38: arp_message.set_name('AR', 'AR_LOCKING_TABLE');
39: arp_message.set_token('TABLE_NAME', 'CS_REPAIRS',FALSE );
40: message_text := 'The locking is done in block CSP_CMERGE_BB7';
41: arp_message.set_line(message_text);
42: ELSE
43: arp_message.set_name('AR', 'AR_UPDATING_TABLE');
44: arp_message.set_token('TABLE_NAME', 'CS_REPAIRS',FALSE );
45: message_text := 'The merge is done in block CSP_CMERGE_BB7';
39: arp_message.set_token('TABLE_NAME', 'CS_REPAIRS',FALSE );
40: message_text := 'The locking is done in block CSP_CMERGE_BB7';
41: arp_message.set_line(message_text);
42: ELSE
43: arp_message.set_name('AR', 'AR_UPDATING_TABLE');
44: arp_message.set_token('TABLE_NAME', 'CS_REPAIRS',FALSE );
45: message_text := 'The merge is done in block CSP_CMERGE_BB7';
46: arp_message.set_line(message_text);
47: END IF;
40: message_text := 'The locking is done in block CSP_CMERGE_BB7';
41: arp_message.set_line(message_text);
42: ELSE
43: arp_message.set_name('AR', 'AR_UPDATING_TABLE');
44: arp_message.set_token('TABLE_NAME', 'CS_REPAIRS',FALSE );
45: message_text := 'The merge is done in block CSP_CMERGE_BB7';
46: arp_message.set_line(message_text);
47: END IF;
48:
42: ELSE
43: arp_message.set_name('AR', 'AR_UPDATING_TABLE');
44: arp_message.set_token('TABLE_NAME', 'CS_REPAIRS',FALSE );
45: message_text := 'The merge is done in block CSP_CMERGE_BB7';
46: arp_message.set_line(message_text);
47: END IF;
48:
49: /* merge the CS_REPAIRS table update the customer_id */
50:
48:
49: /* merge the CS_REPAIRS table update the customer_id */
50:
51: message_text := '***-- Procedure CS_MERGE_CUSTOMER_ID --**';
52: arp_message.set_line(message_text);
53:
54: CS_MERGE_CUSTOMER_ID( req_id, set_number, process_mode );
55:
56: message_text := '***-- End CS_MERGE_CUSTOMER_ID --**';
53:
54: CS_MERGE_CUSTOMER_ID( req_id, set_number, process_mode );
55:
56: message_text := '***-- End CS_MERGE_CUSTOMER_ID --**';
57: arp_message.set_line(message_text);
58:
59: /* Report that the process for CS_REPAIRS is complete */
60:
61: IF ( process_mode = 'LOCK' ) Then
59: /* Report that the process for CS_REPAIRS is complete */
60:
61: IF ( process_mode = 'LOCK' ) Then
62: message_text := '** LOCKING completed for table CS_REPAIRS **';
63: arp_message.set_line(message_text);
64: ELSE
65: message_text := '** MERGE completed for table CS_REPAIRS **';
66: arp_message.set_line(message_text);
67: END IF;
62: message_text := '** LOCKING completed for table CS_REPAIRS **';
63: arp_message.set_line(message_text);
64: ELSE
65: message_text := '** MERGE completed for table CS_REPAIRS **';
66: arp_message.set_line(message_text);
67: END IF;
68:
69: arp_message.set_line('CP_CMERGE_BB7.MERGE()-');
70:
65: message_text := '** MERGE completed for table CS_REPAIRS **';
66: arp_message.set_line(message_text);
67: END IF;
68:
69: arp_message.set_line('CP_CMERGE_BB7.MERGE()-');
70:
71: END MERGE;
72:
73: /* -----------------------------------------------------------------------------*/
100: BEGIN
101: IF ( process_mode = 'LOCK' ) Then
102:
103: message_text := 'LOCKING the rma_customer_id ( 1/1 )';
104: arp_message.set_line(message_text);
105:
106: OPEN LOCK_CUSTOMER_ID ( req_id, set_number );
107: CLOSE LOCK_CUSTOMER_ID;
108:
106: OPEN LOCK_CUSTOMER_ID ( req_id, set_number );
107: CLOSE LOCK_CUSTOMER_ID;
108:
109: message_text := 'Done locking rma_customer_id';
110: arp_message.set_line(message_text);
111:
112: ELSE
113:
114: message_text := 'Starting to update the rma_customer_id ( 1/1 )';
111:
112: ELSE
113:
114: message_text := 'Starting to update the rma_customer_id ( 1/1 )';
115: arp_message.set_line(message_text);
116:
117: UPDATE CS_REPAIRS yt
118: SET
119: yt.rma_customer_id = ( SELECT DISTINCT RACM.CUSTOMER_ID
128: WHERE RACM.PROCESS_FLAG = 'N'
129: AND RACM.REQUEST_ID = req_id
130: AND RACM.SET_NUMBER = set_number );
131:
132: arp_message.set_name( 'CS', 'CS_ROWS_UPDATED');
133: number_of_rows := sql%rowcount;
134: arp_message.set_token( 'NUM_ROWS',to_char( number_of_rows) );
135: message_text := 'Done with the update of rma_customer_id';
136: arp_message.set_line(message_text);
130: AND RACM.SET_NUMBER = set_number );
131:
132: arp_message.set_name( 'CS', 'CS_ROWS_UPDATED');
133: number_of_rows := sql%rowcount;
134: arp_message.set_token( 'NUM_ROWS',to_char( number_of_rows) );
135: message_text := 'Done with the update of rma_customer_id';
136: arp_message.set_line(message_text);
137:
138: END IF;
132: arp_message.set_name( 'CS', 'CS_ROWS_UPDATED');
133: number_of_rows := sql%rowcount;
134: arp_message.set_token( 'NUM_ROWS',to_char( number_of_rows) );
135: message_text := 'Done with the update of rma_customer_id';
136: arp_message.set_line(message_text);
137:
138: END IF;
139:
140: EXCEPTION
140: EXCEPTION
141: WHEN NO_DATA_FOUND THEN
142:
143: message_text := 'RMA_Customer_id NOT found -- proceeding *** ';
144: arp_message.set_line(message_text);
145: arp_message.set_name( 'CS', 'CS_ROWS_UPDATED');
146: number_of_rows := sql%rowcount;
147: arp_message.set_token( 'NUM_ROWS',to_char( number_of_rows) );
148: message_text := 'Done with the update of rma_customer_id';
141: WHEN NO_DATA_FOUND THEN
142:
143: message_text := 'RMA_Customer_id NOT found -- proceeding *** ';
144: arp_message.set_line(message_text);
145: arp_message.set_name( 'CS', 'CS_ROWS_UPDATED');
146: number_of_rows := sql%rowcount;
147: arp_message.set_token( 'NUM_ROWS',to_char( number_of_rows) );
148: message_text := 'Done with the update of rma_customer_id';
149: arp_message.set_line(message_text);
143: message_text := 'RMA_Customer_id NOT found -- proceeding *** ';
144: arp_message.set_line(message_text);
145: arp_message.set_name( 'CS', 'CS_ROWS_UPDATED');
146: number_of_rows := sql%rowcount;
147: arp_message.set_token( 'NUM_ROWS',to_char( number_of_rows) );
148: message_text := 'Done with the update of rma_customer_id';
149: arp_message.set_line(message_text);
150:
151: WHEN OTHERS THEN
145: arp_message.set_name( 'CS', 'CS_ROWS_UPDATED');
146: number_of_rows := sql%rowcount;
147: arp_message.set_token( 'NUM_ROWS',to_char( number_of_rows) );
148: message_text := 'Done with the update of rma_customer_id';
149: arp_message.set_line(message_text);
150:
151: WHEN OTHERS THEN
152:
153: message_text := SUBSTR(SQLERRM,1,70);
150:
151: WHEN OTHERS THEN
152:
153: message_text := SUBSTR(SQLERRM,1,70);
154: arp_message.set_error('CS_MERGE_CUSTOMER_ID',
155: message_text);
156: raise;
157:
158: END CS_MERGE_CUSTOMER_ID;