DBA Data[Home] [Help]

APPS.RCV_ROI_PREPROCESSOR dependencies on RCV_TRANSACTIONS

Line 43: p_txn_type rcv_transactions_interface.transaction_type%TYPE

39:
40: /* Checking if the transaction type is supported by ROI
41: * */
42: FUNCTION is_valid_txn_type(
43: p_txn_type rcv_transactions_interface.transaction_type%TYPE
44: ) RETURN BOOLEAN IS
45: TYPE txn_type_table IS TABLE OF rcv_transactions_interface.transaction_type%TYPE;
46: -- define supported transaction types
47: l_txn_type_tbl txn_type_table := txn_type_table ('SHIP'

Line 45: TYPE txn_type_table IS TABLE OF rcv_transactions_interface.transaction_type%TYPE;

41: * */
42: FUNCTION is_valid_txn_type(
43: p_txn_type rcv_transactions_interface.transaction_type%TYPE
44: ) RETURN BOOLEAN IS
45: TYPE txn_type_table IS TABLE OF rcv_transactions_interface.transaction_type%TYPE;
46: -- define supported transaction types
47: l_txn_type_tbl txn_type_table := txn_type_table ('SHIP'
48: ,'RECEIVE'
49: ,'DELIVER'

Line 73: p_header_id rcv_transactions_interface.interface_header_id%TYPE

69: RETURN FALSE;
70: END is_valid_txn_type;
71:
72: /* FUNCTION get_header_record(
73: p_header_id rcv_transactions_interface.interface_header_id%TYPE
74: ) RETURN header_record_type IS
75:
76: END get_header_record;
77: */

Line 92: l_lpn_grp_id rcv_transactions_interface.lpn_group_id%TYPE;

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
95: p_group_id rcv_transactions_interface.GROUP_ID%TYPE; -- matches the passed in value
96: p_request_id rcv_transactions_interface.processing_request_id%TYPE;

Line 93: l_proc_status_code rcv_transactions_interface.processing_status_code%TYPE;

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
95: p_group_id rcv_transactions_interface.GROUP_ID%TYPE; -- matches the passed in value
96: p_request_id rcv_transactions_interface.processing_request_id%TYPE;
97: l_update_lpn_group BOOLEAN := FALSE;

Line 94: l_group_id rcv_transactions_interface.GROUP_ID%TYPE; -- used in local query

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
95: p_group_id rcv_transactions_interface.GROUP_ID%TYPE; -- matches the passed in value
96: p_request_id rcv_transactions_interface.processing_request_id%TYPE;
97: l_update_lpn_group BOOLEAN := FALSE;
98: l_failed_rows_exist NUMBER := 0;

Line 95: p_group_id rcv_transactions_interface.GROUP_ID%TYPE; -- matches the passed in value

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
95: p_group_id rcv_transactions_interface.GROUP_ID%TYPE; -- matches the passed in value
96: p_request_id rcv_transactions_interface.processing_request_id%TYPE;
97: l_update_lpn_group BOOLEAN := FALSE;
98: l_failed_rows_exist NUMBER := 0;
99: l_txn_code VARCHAR2(10);

Line 96: p_request_id rcv_transactions_interface.processing_request_id%TYPE;

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
95: p_group_id rcv_transactions_interface.GROUP_ID%TYPE; -- matches the passed in value
96: p_request_id rcv_transactions_interface.processing_request_id%TYPE;
97: l_update_lpn_group BOOLEAN := FALSE;
98: l_failed_rows_exist NUMBER := 0;
99: l_txn_code VARCHAR2(10);
100: l_lpn_group_id NUMBER;

Line 110: l_to_org_id rcv_transactions_interface.to_organization_id%TYPE;

106: l_group_count NUMBER;
107: l_return_status1 VARCHAR2(1);
108: l_msg_count1 NUMBER;
109: l_msg_data1 fnd_new_messages.MESSAGE_TEXT%TYPE;
110: l_to_org_id rcv_transactions_interface.to_organization_id%TYPE;
111: l_drop_ship_exists NUMBER; /* Bug3705658 */
112: l_auto_deliver VARCHAR2(1) := 'N'; /* Bug3705658 */
113: x_site_id_count NUMBER := 0; -- Bug 4355172
114: l_count NUMBER; --Bug 4881909

Line 135: FROM rcv_transactions_interface

131: CURSOR distinct_groups(
132: p_request_id NUMBER
133: ) IS
134: SELECT DISTINCT (GROUP_ID)
135: FROM rcv_transactions_interface
136: WHERE processing_request_id = p_request_id
137: AND processing_status_code = 'RUNNING';
138:
139: /* Bug 3434460.

Line 148: FROM rcv_transactions_interface

144: p_request_id NUMBER,
145: p_group_id NUMBER
146: ) IS
147: SELECT DISTINCT (to_organization_id)
148: FROM rcv_transactions_interface
149: WHERE processing_request_id = p_request_id
150: AND (group_id = p_group_id or p_group_id = 0)
151: AND processing_status_code = 'RUNNING'
152: AND to_organization_id IS NOT NULL;

Line 162: rcv_transactions_interface rti,

158: 1, 1,
159: NULL
160: ) osa_flag
161: FROM rcv_headers_interface rsh,
162: rcv_transactions_interface rti,
163: po_line_locations_all poll
164: WHERE rsh.asn_type = 'ASBN'
165: AND rsh.header_interface_id = rti.header_interface_id
166: AND poll.line_location_id (+) = rti.po_line_location_id

Line 268: UPDATE rcv_transactions_interface

264: l_msg_data1,
265: l_to_org_id
266: )
267: AND l_return_status1 = fnd_api.g_ret_sts_success) THEN
268: UPDATE rcv_transactions_interface
269: SET transfer_lpn_id = NULL,
270: transfer_license_plate_number = NULL
271: WHERE processing_request_id = p_request_id
272: AND to_organization_id = l_to_org_id

Line 310: UPDATE rcv_transactions_interface

306: UPDATE rcv_headers_interface
307: SET processing_status_code = 'ERROR'
308: WHERE header_interface_id = bad_shikyu.header_interface_id;
309:
310: UPDATE rcv_transactions_interface
311: SET processing_status_code = 'ERROR'
312: WHERE header_interface_id = bad_shikyu.header_interface_id;
313: EXCEPTION
314: WHEN OTHERS THEN

Line 329: -- Loop through the entries in rcv_transactions_interface.

325: x_progress := '010';
326: n := 0;
327: x_cascaded_table.DELETE;
328:
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);

Line 391: FROM rcv_transactions_interface

387: IF x_cascaded_table(n).parent_interface_txn_id IS NOT NULL THEN --{
388: BEGIN
389: SELECT processing_status_code
390: INTO l_proc_status_code
391: FROM rcv_transactions_interface
392: WHERE interface_transaction_id = x_cascaded_table(n).parent_interface_txn_id;
393: EXCEPTION
394: WHEN NO_DATA_FOUND THEN
395: rcv_error_pkg.set_error_message('RCV_NO_PARENT_TRANSACTION');

Line 408: FROM rcv_transactions_interface

404: IF x_cascaded_table(n).parent_source_transaction_num IS NOT NULL THEN
405: BEGIN --{
406: SELECT processing_status_code
407: INTO l_proc_status_code
408: FROM rcv_transactions_interface
409: WHERE source_transaction_num = x_cascaded_table(n).parent_source_transaction_num;
410: EXCEPTION
411: WHEN NO_DATA_FOUND THEN
412: rcv_error_pkg.set_error_message('RCV_NO_PARENT_TRANSACTION');

Line 425: FROM rcv_transactions_interface

421: -- if parent not errored out, see if this row is already errored out in rti because of something else
422: BEGIN
423: SELECT processing_status_code
424: INTO l_proc_status_code
425: FROM rcv_transactions_interface
426: WHERE interface_transaction_id = x_cascaded_table(n).interface_transaction_id;
427:
428: EXCEPTION
429: WHEN NO_DATA_FOUND THEN

Line 456: FROM rcv_transactions_interface

452: AND (x_cascaded_table(n).error_status NOT IN ('P', 'E'))) THEN --{
453: -- find out if failed lines exist for this header in rti
454: SELECT COUNT(*)
455: INTO l_failed_rows_exist
456: FROM rcv_transactions_interface
457: WHERE processing_status_code = 'ERROR'
458: AND header_interface_id = x_cascaded_table(n).header_interface_id;
459:
460: -- if this is an asn which has failed lines and

Line 819: rcv_transactions_interface rti

815:
816: SELECT count(*)
817: INTO l_drop_ship_exists
818: FROM po_line_locations_all plla,
819: rcv_transactions_interface rti
820: WHERE rti.header_interface_id = x_header_record.header_record.header_interface_id
821: and rti.po_line_location_id = plla.line_location_id
822: and plla.drop_ship_flag = 'Y';
823:

Line 932: FROM rcv_transactions_interface rti

928: rhi.validation_flag = 'Y',
929: rhi.receipt_header_id = NULL
930: WHERE header_interface_id = x_cascaded_table(n).header_interface_id
931: AND NOT EXISTS ( SELECT rti.interface_transaction_id
932: FROM rcv_transactions_interface rti
933: WHERE rhi.header_interface_id = rti.header_interface_id
934: AND rti.processing_status_code in ('RUNNING', 'PENDING'));
935:
936: IF (g_asn_debug = 'Y') THEN

Line 954: FROM rcv_transactions_interface rti,

950: DELETE FROM rcv_shipment_headers
951: WHERE shipment_header_id = l_ship_header_id
952: AND asn_status = 'NEW_SHIP'
953: AND NOT EXISTS ( SELECT rti.interface_transaction_id
954: FROM rcv_transactions_interface rti,
955: rcv_headers_interface rhi
956: WHERE rhi.header_interface_id = rti.header_interface_id
957: AND rti.processing_status_code in ('RUNNING', 'PENDING')
958: AND rhi.receipt_header_id = l_ship_header_id );

Line 1002: from rcv_transactions_interface

998: select 1
999: into l_count
1000: from dual
1001: where exists (select 'Errored RTIs'
1002: from rcv_transactions_interface
1003: where processing_status_code = 'ERROR'
1004: and header_interface_id = x_header_record.header_record.header_interface_id);
1005:
1006: exception

Line 1034: from rcv_transactions_interface

1030: if (x_header_record.header_record.receipt_source_code='VENDOR') then
1031:
1032: select count(count(vendor_site_id))
1033: into x_site_id_count
1034: from rcv_transactions_interface
1035: where shipment_header_id=x_header_record.header_record.receipt_header_id
1036: and vendor_site_id is not null
1037: group by vendor_site_id;
1038: -- Update only if all shipments have same vendor site id

Line 1043: from rcv_transactions_interface

1039: if (x_site_id_count = 1) then
1040: Begin
1041: update rcv_shipment_headers
1042: set vendor_site_id=(select distinct vendor_site_id
1043: from rcv_transactions_interface
1044: where shipment_header_id=x_header_record.header_record.receipt_header_id
1045: and vendor_site_id is not null)
1046: where shipment_header_id=x_header_record.header_record.receipt_header_id;
1047: Exception

Line 1174: p_transaction_id rcv_transactions.transaction_id%TYPE

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
1175: ) IS
1176: SELECT --mandatory matching values
1177: rt.shipment_header_id,
1178: rt.shipment_line_id,

Line 1221: FROM rcv_transactions rt,

1217: rt.deliver_to_person_id,
1218: rt.deliver_to_location_id,
1219: rt.secondary_unit_of_measure,
1220: rt.secondary_uom_code
1221: FROM rcv_transactions rt,
1222: rcv_shipment_lines rsl
1223: WHERE transaction_id = p_transaction_id
1224: AND rt.shipment_line_id = rsl.shipment_line_id(+);
1225:

Line 1227: p_transaction_id rcv_transactions.transaction_id%TYPE

1223: WHERE transaction_id = p_transaction_id
1224: AND rt.shipment_line_id = rsl.shipment_line_id(+);
1225:
1226: CURSOR get_parent_row_from_rti(
1227: p_transaction_id rcv_transactions.transaction_id%TYPE
1228: ) IS
1229: SELECT --mandatory matching values
1230: shipment_header_id,
1231: shipment_line_id,

Line 1274: FROM rcv_transactions_interface

1270: deliver_to_person_id,
1271: deliver_to_location_id,
1272: secondary_unit_of_measure,
1273: secondary_uom_code
1274: FROM rcv_transactions_interface
1275: WHERE interface_transaction_id = p_transaction_id;
1276:
1277: CURSOR get_parent_row_from_cascade(
1278: p_parent_index NUMBER

Line 1556: l_to_org_id rcv_transactions_interface.to_organization_id%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;
1556: l_to_org_id rcv_transactions_interface.to_organization_id%TYPE;
1557: BEGIN
1558: IF (g_asn_debug = 'Y') THEN
1559: asn_debug.put_line('Enter create shipment line');
1560: END IF;

Line 1941: x_interface_txn_id IN OUT NOCOPY rcv_transactions_interface.interface_transaction_id%TYPE,

1937: END IF;
1938: END process_line;
1939:
1940: PROCEDURE explode_lpn_failed(
1941: x_interface_txn_id IN OUT NOCOPY rcv_transactions_interface.interface_transaction_id%TYPE,
1942: x_group_id NUMBER,
1943: x_lpn_group_id NUMBER
1944: ) IS
1945: BEGIN

Line 1966: p_group_id IN rcv_transactions_interface.GROUP_ID%TYPE,

1962: END IF;
1963: END explode_lpn_failed;
1964:
1965: PROCEDURE update_rti_error(
1966: p_group_id IN rcv_transactions_interface.GROUP_ID%TYPE,
1967: p_interface_id IN rcv_transactions_interface.interface_transaction_id%TYPE,
1968: p_header_interface_id IN rcv_transactions_interface.header_interface_id%TYPE,
1969: p_lpn_group_id IN rcv_transactions_interface.lpn_group_id%TYPE
1970: ) IS

Line 1967: p_interface_id IN rcv_transactions_interface.interface_transaction_id%TYPE,

1963: END explode_lpn_failed;
1964:
1965: PROCEDURE update_rti_error(
1966: p_group_id IN rcv_transactions_interface.GROUP_ID%TYPE,
1967: p_interface_id IN rcv_transactions_interface.interface_transaction_id%TYPE,
1968: p_header_interface_id IN rcv_transactions_interface.header_interface_id%TYPE,
1969: p_lpn_group_id IN rcv_transactions_interface.lpn_group_id%TYPE
1970: ) IS
1971: l_return_status VARCHAR2(1);

Line 1968: p_header_interface_id IN rcv_transactions_interface.header_interface_id%TYPE,

1964:
1965: PROCEDURE update_rti_error(
1966: p_group_id IN rcv_transactions_interface.GROUP_ID%TYPE,
1967: p_interface_id IN rcv_transactions_interface.interface_transaction_id%TYPE,
1968: p_header_interface_id IN rcv_transactions_interface.header_interface_id%TYPE,
1969: p_lpn_group_id IN rcv_transactions_interface.lpn_group_id%TYPE
1970: ) IS
1971: l_return_status VARCHAR2(1);
1972: l_msg_data VARCHAR2(2000);

Line 1969: p_lpn_group_id IN rcv_transactions_interface.lpn_group_id%TYPE

1965: PROCEDURE update_rti_error(
1966: p_group_id IN rcv_transactions_interface.GROUP_ID%TYPE,
1967: p_interface_id IN rcv_transactions_interface.interface_transaction_id%TYPE,
1968: p_header_interface_id IN rcv_transactions_interface.header_interface_id%TYPE,
1969: p_lpn_group_id IN rcv_transactions_interface.lpn_group_id%TYPE
1970: ) IS
1971: l_return_status VARCHAR2(1);
1972: l_msg_data VARCHAR2(2000);
1973: l_msg_count NUMBER;

Line 1976: l_processing_mode_code rcv_transactions_interface.processing_mode_code%TYPE;

1972: l_msg_data VARCHAR2(2000);
1973: l_msg_count NUMBER;
1974: l_inventory_id NUMBER;
1975: l_txn_mode VARCHAR2(25);
1976: l_processing_mode_code rcv_transactions_interface.processing_mode_code%TYPE;
1977: BEGIN
1978: IF (g_asn_debug = 'Y') THEN
1979: asn_debug.put_line('Set rti row to error');
1980: asn_debug.put_line('p_group_id ' || p_group_id);

Line 1992: FROM rcv_transactions_interface

1988:
1989: IF (p_header_interface_id IS NOT NULL) THEN
1990: SELECT DISTINCT (processing_mode_code)
1991: INTO l_processing_mode_code
1992: FROM rcv_transactions_interface
1993: WHERE header_interface_id = p_header_interface_id;
1994: ELSIF(p_interface_id IS NOT NULL) THEN
1995: SELECT processing_mode_code
1996: INTO l_processing_mode_code

Line 1997: FROM rcv_transactions_interface

1993: WHERE header_interface_id = p_header_interface_id;
1994: ELSIF(p_interface_id IS NOT NULL) THEN
1995: SELECT processing_mode_code
1996: INTO l_processing_mode_code
1997: FROM rcv_transactions_interface
1998: WHERE interface_transaction_id = p_interface_id;
1999: ELSIF(p_group_id IS NOT NULL) THEN
2000: /* Bug 3361395.
2001: * When there is an when others exception in the

Line 2008: FROM rcv_transactions_interface

2004: * in this procedure.
2005: */
2006: SELECT DISTINCT (processing_mode_code)
2007: INTO l_processing_mode_code
2008: FROM rcv_transactions_interface
2009: WHERE GROUP_ID = p_group_id;
2010: END IF;
2011:
2012: IF (g_asn_debug = 'Y') THEN

Line 2021: UPDATE rcv_transactions_interface

2017: IF (g_asn_debug = 'Y') THEN
2018: asn_debug.put_line('online error ');
2019: END IF;
2020:
2021: UPDATE rcv_transactions_interface
2022: SET processing_status_code = 'ERROR'
2023: WHERE GROUP_ID = p_group_id;
2024:
2025: inv_receiving_transaction.txn_complete(p_group_id => p_group_id,

Line 2038: UPDATE rcv_transactions_interface

2034: IF (g_asn_debug = 'Y') THEN
2035: asn_debug.put_line('header_interface_id not null ');
2036: END IF;
2037:
2038: UPDATE rcv_transactions_interface
2039: SET processing_status_code = 'ERROR'
2040: WHERE header_interface_id = p_header_interface_id;
2041:
2042: l_inventory_id := p_header_interface_id;

Line 2049: UPDATE rcv_transactions_interface

2045: IF (g_asn_debug = 'Y') THEN
2046: asn_debug.put_line('lpn_group_id not null ');
2047: END IF;
2048:
2049: UPDATE rcv_transactions_interface
2050: SET processing_status_code = 'ERROR'
2051: WHERE lpn_group_id = p_lpn_group_id;
2052:
2053: l_inventory_id := p_lpn_group_id;

Line 2060: UPDATE rcv_transactions_interface

2056: IF (g_asn_debug = 'Y') THEN
2057: asn_debug.put_line('interface_id not null ');
2058: END IF;
2059:
2060: UPDATE rcv_transactions_interface
2061: SET processing_status_code = 'ERROR'
2062: WHERE interface_transaction_id = p_interface_id;
2063:
2064: l_inventory_id := p_interface_id;

Line 2084: UPDATE rcv_transactions_interface

2080: UPDATE rcv_headers_interface
2081: SET processing_status_code = 'ERROR'
2082: WHERE GROUP_ID = p_group_id;
2083:
2084: UPDATE rcv_transactions_interface
2085: SET processing_status_code = 'ERROR'
2086: WHERE GROUP_ID = p_group_id;
2087:
2088: l_inventory_id := p_group_id;