DBA Data[Home] [Help]

APPS.RCV_ROI_PREPROCESSOR dependencies on RCV_ROI_PREPROCESSOR

Line 1: PACKAGE BODY rcv_roi_preprocessor AS

1: PACKAGE BODY rcv_roi_preprocessor AS
2: /* $Header: RCVPREPB.pls 120.19.12010000.4 2009/01/22 12:54:23 smididud ship $*/
3: -- Read the profile option that enables/disables the debug log
4: g_asn_debug VARCHAR2(1) := NVL(fnd_profile.VALUE('RCV_DEBUG_MODE'), 'N');
5: x_interface_type VARCHAR2(25) := 'RCV-856';

Line 83: x_error_record rcv_roi_preprocessor.error_rec_type;

79: PROCEDURE preprocessor(
80: x_request_id NUMBER,
81: x_group_id NUMBER
82: ) IS
83: x_error_record rcv_roi_preprocessor.error_rec_type;
84: x_header_record rcv_roi_preprocessor.header_rec_type;
85: x_cascaded_table rcv_roi_preprocessor.cascaded_trans_tab_type;
86: x_progress VARCHAR2(3) := '000';
87: x_fail_all_lines VARCHAR2(1) := 'N';

Line 84: x_header_record rcv_roi_preprocessor.header_rec_type;

80: x_request_id NUMBER,
81: x_group_id NUMBER
82: ) IS
83: x_error_record rcv_roi_preprocessor.error_rec_type;
84: x_header_record rcv_roi_preprocessor.header_rec_type;
85: x_cascaded_table rcv_roi_preprocessor.cascaded_trans_tab_type;
86: x_progress VARCHAR2(3) := '000';
87: x_fail_all_lines VARCHAR2(1) := 'N';
88: x_fail_if_one_line_fails BOOLEAN := FALSE;

Line 85: x_cascaded_table rcv_roi_preprocessor.cascaded_trans_tab_type;

81: x_group_id NUMBER
82: ) IS
83: x_error_record rcv_roi_preprocessor.error_rec_type;
84: x_header_record rcv_roi_preprocessor.header_rec_type;
85: x_cascaded_table rcv_roi_preprocessor.cascaded_trans_tab_type;
86: x_progress VARCHAR2(3) := '000';
87: x_fail_all_lines VARCHAR2(1) := 'N';
88: x_fail_if_one_line_fails BOOLEAN := FALSE;
89: n BINARY_INTEGER := 0;

Line 90: x_empty_header_record rcv_roi_preprocessor.header_rec_type;

86: x_progress VARCHAR2(3) := '000';
87: x_fail_all_lines VARCHAR2(1) := 'N';
88: x_fail_if_one_line_fails BOOLEAN := FALSE;
89: n BINARY_INTEGER := 0;
90: x_empty_header_record rcv_roi_preprocessor.header_rec_type;
91: --added for lpn support
92: l_lpn_grp_id rcv_transactions_interface.lpn_group_id%TYPE;
93: l_proc_status_code rcv_transactions_interface.processing_status_code%TYPE;
94: l_group_id rcv_transactions_interface.GROUP_ID%TYPE; -- used in local query

Line 124: x_empty_error_record rcv_roi_preprocessor.error_rec_type;

120:
121: l_exception_group_id group_id_pool;
122: l_return_status VARCHAR2(1);
123: l_check_dcp NUMBER;
124: x_empty_error_record rcv_roi_preprocessor.error_rec_type;
125:
126: /* TYPE header_record_cache IS TABLE OF rcv_roi_preprocessor.header_rec_type
127: INDEX BY BINARY_INTEGER;
128:

Line 126: /* TYPE header_record_cache IS TABLE OF rcv_roi_preprocessor.header_rec_type

122: l_return_status VARCHAR2(1);
123: l_check_dcp NUMBER;
124: x_empty_error_record rcv_roi_preprocessor.error_rec_type;
125:
126: /* TYPE header_record_cache IS TABLE OF rcv_roi_preprocessor.header_rec_type
127: INDEX BY BINARY_INTEGER;
128:
129: l_header_record_cache header_record_cache;
130: */

Line 319: OPEN rcv_roi_preprocessor.txns_cur(p_request_id, p_group_id);

315: NULL;
316: END;
317: END LOOP;
318:
319: OPEN rcv_roi_preprocessor.txns_cur(p_request_id, p_group_id);
320:
321: IF (g_asn_debug = 'Y') THEN
322: asn_debug.put_line('Opened transactions cursor.');
323: END IF;

Line 333: FETCH rcv_roi_preprocessor.txns_cur INTO x_cascaded_table(n);

329: -- Loop through the entries in rcv_transactions_interface.
330: LOOP --{
331: asn_debug.put_line('enter loop');
332: n := n + 1;
333: FETCH rcv_roi_preprocessor.txns_cur INTO x_cascaded_table(n);
334: EXIT WHEN rcv_roi_preprocessor.txns_cur%NOTFOUND;
335: x_cascaded_table(n).error_status := 'S';
336: x_cascaded_table(n).error_message := NULL;
337: x_cascaded_table(n).derive := 'N';

Line 334: EXIT WHEN rcv_roi_preprocessor.txns_cur%NOTFOUND;

330: LOOP --{
331: asn_debug.put_line('enter loop');
332: n := n + 1;
333: FETCH rcv_roi_preprocessor.txns_cur INTO x_cascaded_table(n);
334: EXIT WHEN rcv_roi_preprocessor.txns_cur%NOTFOUND;
335: x_cascaded_table(n).error_status := 'S';
336: x_cascaded_table(n).error_message := NULL;
337: x_cascaded_table(n).derive := 'N';
338: x_cascaded_table(n).matching_basis := 'QUANTITY';

Line 495: OPEN rcv_roi_preprocessor.headers_cur(p_request_id,

491: x_header_record := x_empty_header_record;
492: -- initialize error_record
493: x_header_record.error_record := x_error_record;
494:
495: OPEN rcv_roi_preprocessor.headers_cur(p_request_id,
496: p_group_id,
497: x_cascaded_table(n).header_interface_id
498: );
499: IF (g_asn_debug = 'Y') THEN

Line 503: FETCH rcv_roi_preprocessor.headers_cur INTO x_header_record.header_record;

499: IF (g_asn_debug = 'Y') THEN
500: asn_debug.put_line('Before processing header');
501: END IF;
502:
503: FETCH rcv_roi_preprocessor.headers_cur INTO x_header_record.header_record;
504: -- there should be 1 header record for this transaction
505: asn_debug.put_line('Processing header for interface txn id =' ||
506: TO_CHAR(x_cascaded_table(n).interface_transaction_id));
507: -- header cursor found, header is not processed yet : process the header

Line 508: IF RCV_ROI_PREPROCESSOR.headers_cur%FOUND THEN --{

504: -- there should be 1 header record for this transaction
505: asn_debug.put_line('Processing header for interface txn id =' ||
506: TO_CHAR(x_cascaded_table(n).interface_transaction_id));
507: -- header cursor found, header is not processed yet : process the header
508: IF RCV_ROI_PREPROCESSOR.headers_cur%FOUND THEN --{
509: IF x_header_record.header_record.processing_status_code = 'RUNNING' THEN --{
510: IF (x_cascaded_table(n).transaction_type IN ('SHIP', 'RECEIVE')) THEN --{
511:
512: IF x_header_record.header_record.transaction_type = 'NEW' THEN --{

Line 577: CLOSE rcv_roi_preprocessor.headers_cur;

573: rcv_error_pkg.log_interface_error('HEADER_INTERFACE_ID', FALSE);
574: END IF; --} this is the check for whether header is processed
575:
576: asn_debug.put_line('closing the header cursor for txn = ' || TO_CHAR(x_cascaded_table(n).interface_transaction_id));
577: CLOSE rcv_roi_preprocessor.headers_cur;
578: END IF; --} matches excluding shared header.
579:
580: -- after processing header update rhi/rti
581: -- IF (x_header_record.error_record.error_status = 'E') THEN -- Bugfix 5592848

Line 1057: CLOSE rcv_roi_preprocessor.txns_cur;

1053:
1054: /* End 4355172 */
1055:
1056:
1057: CLOSE rcv_roi_preprocessor.txns_cur;
1058: asn_debug.put_line('after loop');
1059:
1060: --DCP call
1061: BEGIN

Line 1101: rcv_error_pkg.set_sql_error_message('RCV_ROI_PREPROCESSOR.preprocessor','sqlcode');

1097: asn_debug.put_line('Exit preprocessor');
1098: END IF;
1099: EXCEPTION
1100: WHEN NO_DATA_FOUND THEN
1101: rcv_error_pkg.set_sql_error_message('RCV_ROI_PREPROCESSOR.preprocessor','sqlcode');
1102: rcv_error_pkg.log_interface_error('PARENT_SOURCE_TRANSACTION_NUM', FALSE);
1103:
1104: IF rcv_roi_preprocessor.txns_cur%ISOPEN THEN
1105: CLOSE rcv_roi_preprocessor.txns_cur;

Line 1104: IF rcv_roi_preprocessor.txns_cur%ISOPEN THEN

1100: WHEN NO_DATA_FOUND THEN
1101: rcv_error_pkg.set_sql_error_message('RCV_ROI_PREPROCESSOR.preprocessor','sqlcode');
1102: rcv_error_pkg.log_interface_error('PARENT_SOURCE_TRANSACTION_NUM', FALSE);
1103:
1104: IF rcv_roi_preprocessor.txns_cur%ISOPEN THEN
1105: CLOSE rcv_roi_preprocessor.txns_cur;
1106: END IF;
1107:
1108: --pjiang, close header cursor explicitly

Line 1105: CLOSE rcv_roi_preprocessor.txns_cur;

1101: rcv_error_pkg.set_sql_error_message('RCV_ROI_PREPROCESSOR.preprocessor','sqlcode');
1102: rcv_error_pkg.log_interface_error('PARENT_SOURCE_TRANSACTION_NUM', FALSE);
1103:
1104: IF rcv_roi_preprocessor.txns_cur%ISOPEN THEN
1105: CLOSE rcv_roi_preprocessor.txns_cur;
1106: END IF;
1107:
1108: --pjiang, close header cursor explicitly
1109: IF rcv_roi_preprocessor.headers_cur%ISOPEN THEN

Line 1109: IF rcv_roi_preprocessor.headers_cur%ISOPEN THEN

1105: CLOSE rcv_roi_preprocessor.txns_cur;
1106: END IF;
1107:
1108: --pjiang, close header cursor explicitly
1109: IF rcv_roi_preprocessor.headers_cur%ISOPEN THEN
1110: CLOSE rcv_roi_preprocessor.headers_cur;
1111: END IF;
1112: WHEN rcv_error_pkg.e_fatal_error THEN --we didn't catch an error that we should have caught
1113: asn_debug.put_line('uncaught e_fatal_error in rcv_roi_preprocess.preprocessor - abnormal execution');

Line 1110: CLOSE rcv_roi_preprocessor.headers_cur;

1106: END IF;
1107:
1108: --pjiang, close header cursor explicitly
1109: IF rcv_roi_preprocessor.headers_cur%ISOPEN THEN
1110: CLOSE rcv_roi_preprocessor.headers_cur;
1111: END IF;
1112: WHEN rcv_error_pkg.e_fatal_error THEN --we didn't catch an error that we should have caught
1113: asn_debug.put_line('uncaught e_fatal_error in rcv_roi_preprocess.preprocessor - abnormal execution');
1114: asn_debug.put_line('last error message = ' || rcv_error_pkg.get_last_message);

Line 1124: IF rcv_roi_preprocessor.txns_cur%ISOPEN THEN

1120: asn_debug.put_line('l_msg_data: ' || l_msg_data);
1121: asn_debug.put_line('Set rti rows to error for this and call txn complete');
1122: END IF;
1123:
1124: IF rcv_roi_preprocessor.txns_cur%ISOPEN THEN
1125: CLOSE rcv_roi_preprocessor.txns_cur;
1126: END IF;
1127:
1128: --pjiang, close header cursor explicitly

Line 1125: CLOSE rcv_roi_preprocessor.txns_cur;

1121: asn_debug.put_line('Set rti rows to error for this and call txn complete');
1122: END IF;
1123:
1124: IF rcv_roi_preprocessor.txns_cur%ISOPEN THEN
1125: CLOSE rcv_roi_preprocessor.txns_cur;
1126: END IF;
1127:
1128: --pjiang, close header cursor explicitly
1129: IF rcv_roi_preprocessor.headers_cur%ISOPEN THEN

Line 1129: IF rcv_roi_preprocessor.headers_cur%ISOPEN THEN

1125: CLOSE rcv_roi_preprocessor.txns_cur;
1126: END IF;
1127:
1128: --pjiang, close header cursor explicitly
1129: IF rcv_roi_preprocessor.headers_cur%ISOPEN THEN
1130: CLOSE rcv_roi_preprocessor.headers_cur;
1131: END IF;
1132:
1133: /*We default p_group_id to 0 */

Line 1130: CLOSE rcv_roi_preprocessor.headers_cur;

1126: END IF;
1127:
1128: --pjiang, close header cursor explicitly
1129: IF rcv_roi_preprocessor.headers_cur%ISOPEN THEN
1130: CLOSE rcv_roi_preprocessor.headers_cur;
1131: END IF;
1132:
1133: /*We default p_group_id to 0 */
1134: IF ( p_group_id IS NOT NULL

Line 1170: x_cascaded_table IN OUT NOCOPY rcv_roi_preprocessor.cascaded_trans_tab_type,

1166: END IF;
1167: END preprocessor;
1168:
1169: PROCEDURE default_from_parent_trx(
1170: x_cascaded_table IN OUT NOCOPY rcv_roi_preprocessor.cascaded_trans_tab_type,
1171: n IN OUT NOCOPY BINARY_INTEGER
1172: ) IS
1173: CURSOR get_parent_row_from_rt(
1174: p_transaction_id rcv_transactions.transaction_id%TYPE

Line 1540: x_cascaded_table IN OUT NOCOPY rcv_roi_preprocessor.cascaded_trans_tab_type,

1536: x_cascaded_table(n).error_message := rcv_error_pkg.get_last_message;
1537: END default_from_parent_trx;
1538:
1539: PROCEDURE process_line(
1540: x_cascaded_table IN OUT NOCOPY rcv_roi_preprocessor.cascaded_trans_tab_type,
1541: n IN OUT NOCOPY BINARY_INTEGER,
1542: x_header_id IN rcv_headers_interface.header_interface_id%TYPE,
1543: x_asn_type IN rcv_headers_interface.asn_type%TYPE,
1544: v_header_record IN OUT NOCOPY rcv_roi_preprocessor.header_rec_type

Line 1544: v_header_record IN OUT NOCOPY rcv_roi_preprocessor.header_rec_type

1540: x_cascaded_table IN OUT NOCOPY rcv_roi_preprocessor.cascaded_trans_tab_type,
1541: n IN OUT NOCOPY BINARY_INTEGER,
1542: x_header_id IN rcv_headers_interface.header_interface_id%TYPE,
1543: x_asn_type IN rcv_headers_interface.asn_type%TYPE,
1544: v_header_record IN OUT NOCOPY rcv_roi_preprocessor.header_rec_type
1545: ) IS
1546: x_parent_id NUMBER;
1547: x_progress VARCHAR2(3);
1548: x_error_record rcv_shipment_object_sv.errorrectype;

Line 1551: used_for_cascaded_rows rcv_roi_preprocessor.cascaded_trans_tab_type;

1547: x_progress VARCHAR2(3);
1548: x_error_record rcv_shipment_object_sv.errorrectype;
1549: x_start_indice BINARY_INTEGER := NULL;
1550: i BINARY_INTEGER := NULL;
1551: used_for_cascaded_rows rcv_roi_preprocessor.cascaded_trans_tab_type;
1552: /* Bug 3434460 */
1553: l_return_status VARCHAR2(1);
1554: l_msg_count NUMBER;
1555: l_msg_data fnd_new_messages.MESSAGE_TEXT%TYPE;

Line 2114: END rcv_roi_preprocessor;

2110: IF (g_asn_debug = 'Y') THEN
2111: asn_debug.put_line('Exception in update_rti_error');
2112: END IF;
2113: END update_rti_error;
2114: END rcv_roi_preprocessor;