DBA Data[Home] [Help]

APPS.RCV_ROI_PREPROCESSOR dependencies on RCV_TRANSACTIONS_INTERFACE

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 130: FROM rcv_transactions_interface

126: SELECT destination_type_code,
127: destination_context
128: INTO x_cascaded_table(n).destination_type_code,
129: x_cascaded_table(n).destination_context
130: FROM rcv_transactions_interface
131: WHERE interface_transaction_id = x_cascaded_table(n).parent_interface_txn_id;
132: END IF;
133: END IF;
134: END IF;

Line 195: l_lpn_grp_id rcv_transactions_interface.lpn_group_id%TYPE;

191: x_fail_if_one_line_fails BOOLEAN := FALSE;
192: n BINARY_INTEGER := 0;
193: x_empty_header_record rcv_roi_preprocessor.header_rec_type;
194: --added for lpn support
195: l_lpn_grp_id rcv_transactions_interface.lpn_group_id%TYPE;
196: l_proc_status_code rcv_transactions_interface.processing_status_code%TYPE;
197: l_group_id rcv_transactions_interface.GROUP_ID%TYPE; -- used in local query
198: p_group_id rcv_transactions_interface.GROUP_ID%TYPE; -- matches the passed in value
199: p_request_id rcv_transactions_interface.processing_request_id%TYPE;

Line 196: l_proc_status_code rcv_transactions_interface.processing_status_code%TYPE;

192: n BINARY_INTEGER := 0;
193: x_empty_header_record rcv_roi_preprocessor.header_rec_type;
194: --added for lpn support
195: l_lpn_grp_id rcv_transactions_interface.lpn_group_id%TYPE;
196: l_proc_status_code rcv_transactions_interface.processing_status_code%TYPE;
197: l_group_id rcv_transactions_interface.GROUP_ID%TYPE; -- used in local query
198: p_group_id rcv_transactions_interface.GROUP_ID%TYPE; -- matches the passed in value
199: p_request_id rcv_transactions_interface.processing_request_id%TYPE;
200: l_update_lpn_group BOOLEAN := FALSE;

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

193: x_empty_header_record rcv_roi_preprocessor.header_rec_type;
194: --added for lpn support
195: l_lpn_grp_id rcv_transactions_interface.lpn_group_id%TYPE;
196: l_proc_status_code rcv_transactions_interface.processing_status_code%TYPE;
197: l_group_id rcv_transactions_interface.GROUP_ID%TYPE; -- used in local query
198: p_group_id rcv_transactions_interface.GROUP_ID%TYPE; -- matches the passed in value
199: p_request_id rcv_transactions_interface.processing_request_id%TYPE;
200: l_update_lpn_group BOOLEAN := FALSE;
201: l_failed_rows_exist NUMBER := 0;

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

194: --added for lpn support
195: l_lpn_grp_id rcv_transactions_interface.lpn_group_id%TYPE;
196: l_proc_status_code rcv_transactions_interface.processing_status_code%TYPE;
197: l_group_id rcv_transactions_interface.GROUP_ID%TYPE; -- used in local query
198: p_group_id rcv_transactions_interface.GROUP_ID%TYPE; -- matches the passed in value
199: p_request_id rcv_transactions_interface.processing_request_id%TYPE;
200: l_update_lpn_group BOOLEAN := FALSE;
201: l_failed_rows_exist NUMBER := 0;
202: l_txn_code VARCHAR2(10);

Line 199: p_request_id rcv_transactions_interface.processing_request_id%TYPE;

195: l_lpn_grp_id rcv_transactions_interface.lpn_group_id%TYPE;
196: l_proc_status_code rcv_transactions_interface.processing_status_code%TYPE;
197: l_group_id rcv_transactions_interface.GROUP_ID%TYPE; -- used in local query
198: p_group_id rcv_transactions_interface.GROUP_ID%TYPE; -- matches the passed in value
199: p_request_id rcv_transactions_interface.processing_request_id%TYPE;
200: l_update_lpn_group BOOLEAN := FALSE;
201: l_failed_rows_exist NUMBER := 0;
202: l_txn_code VARCHAR2(10);
203: l_lpn_group_id NUMBER;

Line 213: l_to_org_id rcv_transactions_interface.to_organization_id%TYPE;

209: l_group_count NUMBER;
210: l_return_status1 VARCHAR2(1);
211: l_msg_count1 NUMBER;
212: l_msg_data1 fnd_new_messages.MESSAGE_TEXT%TYPE;
213: l_to_org_id rcv_transactions_interface.to_organization_id%TYPE;
214: l_drop_ship_exists NUMBER; /* Bug3705658 */
215: l_auto_deliver VARCHAR2(1) := 'N'; /* Bug3705658 */
216: x_site_id_count NUMBER := 0; -- Bug 4355172
217: l_count NUMBER; --Bug 4881909

Line 239: FROM rcv_transactions_interface

235: CURSOR distinct_groups(
236: p_request_id NUMBER
237: ) IS
238: SELECT DISTINCT (GROUP_ID)
239: FROM rcv_transactions_interface
240: WHERE processing_request_id = p_request_id
241: AND processing_status_code = 'RUNNING';
242:
243: /* Bug 3434460.

Line 252: FROM rcv_transactions_interface

248: p_request_id NUMBER,
249: p_group_id NUMBER
250: ) IS
251: SELECT DISTINCT (to_organization_id)
252: FROM rcv_transactions_interface
253: WHERE processing_request_id = p_request_id
254: AND (group_id = p_group_id or p_group_id = 0)
255: AND processing_status_code = 'RUNNING'
256: AND to_organization_id IS NOT NULL;

Line 266: rcv_transactions_interface rti,

262: 1, 1,
263: NULL
264: ) osa_flag
265: FROM rcv_headers_interface rsh,
266: rcv_transactions_interface rti,
267: po_line_locations_all poll
268: WHERE rsh.asn_type = 'ASBN'
269: AND rsh.header_interface_id = rti.header_interface_id
270: AND poll.line_location_id (+) = rti.po_line_location_id

Line 299: FROM rcv_transactions_interface rti

295: AND (group_id = p_group_id or p_group_id = 0)
296: AND (processing_status_code = 'ERROR'
297: OR
298: EXISTS (SELECT 1
299: FROM rcv_transactions_interface rti
300: WHERE rti.header_interface_id = rhi.header_interface_id
301: AND rti.processing_status_code = 'ERROR'));
302:
303: x_asn_rhi_record rcv_roi_preprocessor.header_rec_type;

Line 387: UPDATE rcv_transactions_interface

383: l_msg_data1,
384: l_to_org_id
385: )
386: AND l_return_status1 = fnd_api.g_ret_sts_success) THEN
387: UPDATE rcv_transactions_interface
388: SET transfer_lpn_id = NULL,
389: transfer_license_plate_number = NULL
390: WHERE processing_request_id = p_request_id
391: AND to_organization_id = l_to_org_id

Line 429: UPDATE rcv_transactions_interface

425: UPDATE rcv_headers_interface
426: SET processing_status_code = 'ERROR'
427: WHERE header_interface_id = bad_shikyu.header_interface_id;
428:
429: UPDATE rcv_transactions_interface
430: SET processing_status_code = 'ERROR'
431: WHERE header_interface_id = bad_shikyu.header_interface_id;
432: EXCEPTION
433: WHEN OTHERS THEN

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

444: x_progress := '010';
445: n := 0;
446: x_cascaded_table.DELETE;
447:
448: -- Loop through the entries in rcv_transactions_interface.
449: LOOP --{
450: asn_debug.put_line('enter loop');
451: n := n + 1;
452: FETCH rcv_roi_preprocessor.txns_cur INTO x_cascaded_table(n);

Line 511: FROM rcv_transactions_interface

507: IF x_cascaded_table(n).parent_interface_txn_id IS NOT NULL THEN --{
508: BEGIN
509: SELECT processing_status_code
510: INTO l_proc_status_code
511: FROM rcv_transactions_interface
512: WHERE interface_transaction_id = x_cascaded_table(n).parent_interface_txn_id;
513: EXCEPTION
514: WHEN NO_DATA_FOUND THEN
515: rcv_error_pkg.set_error_message('RCV_NO_PARENT_TRANSACTION');

Line 533: FROM rcv_transactions_interface

529: -- if parent not errored out, see if this row is already errored out in rti because of something else
530: BEGIN
531: SELECT processing_status_code
532: INTO l_proc_status_code
533: FROM rcv_transactions_interface
534: WHERE interface_transaction_id = x_cascaded_table(n).interface_transaction_id;
535:
536: EXCEPTION
537: WHEN NO_DATA_FOUND THEN

Line 564: FROM rcv_transactions_interface

560: AND (x_cascaded_table(n).error_status NOT IN ('P', 'E'))) THEN --{
561: -- find out if failed lines exist for this header in rti
562: SELECT COUNT(*)
563: INTO l_failed_rows_exist
564: FROM rcv_transactions_interface
565: WHERE processing_status_code = 'ERROR'
566: AND header_interface_id = x_cascaded_table(n).header_interface_id;
567:
568: -- if this is an asn which has failed lines and

Line 965: rcv_transactions_interface rti

961:
962: SELECT count(*)
963: INTO l_drop_ship_exists
964: FROM po_line_locations_all plla,
965: rcv_transactions_interface rti
966: WHERE rti.header_interface_id = x_header_record.header_record.header_interface_id
967: and rti.po_line_location_id = plla.line_location_id
968: and plla.drop_ship_flag = 'Y';
969:

Line 1097: FROM rcv_transactions_interface rti, rcv_headers_interface rhi

1093: AND NOT EXISTS(SELECT rt.transaction_id
1094: FROM rcv_transactions rt
1095: WHERE shipment_header_id = x_header_record.header_record.receipt_header_id)
1096: AND NOT EXISTS(SELECT rti.interface_transaction_id "Running rows in RTI" -- take care of multi RECEIVE txns under one header
1097: FROM rcv_transactions_interface rti, rcv_headers_interface rhi
1098: WHERE rhi.header_interface_id = rti.header_interface_id
1099: AND rti.processing_status_code in ('RUNNING', 'PENDING')
1100: AND rhi.receipt_header_id = x_header_record.header_record.receipt_header_id);
1101:

Line 1116: FROM rcv_transactions_interface rti

1112: rhi.validation_flag = 'Y',
1113: rhi.receipt_header_id = NULL
1114: WHERE header_interface_id = x_cascaded_table(n).header_interface_id
1115: AND NOT EXISTS ( SELECT rti.interface_transaction_id
1116: FROM rcv_transactions_interface rti
1117: WHERE rhi.header_interface_id = rti.header_interface_id
1118: AND rti.processing_status_code in ('RUNNING', 'PENDING'));
1119:
1120: IF (g_asn_debug = 'Y') THEN

Line 1143: FROM rcv_transactions_interface rti,

1139: DELETE FROM rcv_shipment_headers
1140: WHERE shipment_header_id = l_ship_header_id
1141: AND asn_status = 'NEW_SHIP'
1142: AND NOT EXISTS ( SELECT rti.interface_transaction_id
1143: FROM rcv_transactions_interface rti,
1144: rcv_headers_interface rhi
1145: WHERE rhi.header_interface_id = rti.header_interface_id
1146: AND rti.processing_status_code in ('RUNNING', 'PENDING')
1147: AND rhi.receipt_header_id = l_ship_header_id );

Line 1176: from rcv_transactions_interface

1172: if (x_header_record.header_record.receipt_source_code='VENDOR') then
1173:
1174: select count(count(vendor_site_id))
1175: into x_site_id_count
1176: from rcv_transactions_interface
1177: where shipment_header_id=x_header_record.header_record.receipt_header_id
1178: and vendor_site_id is not null
1179: group by vendor_site_id;
1180: -- Update only if all shipments have same vendor site id

Line 1185: from rcv_transactions_interface

1181: if (x_site_id_count = 1) then
1182: Begin
1183: update rcv_shipment_headers
1184: set vendor_site_id=(select distinct vendor_site_id
1185: from rcv_transactions_interface
1186: where shipment_header_id=x_header_record.header_record.receipt_header_id
1187: and vendor_site_id is not null)
1188: where shipment_header_id=x_header_record.header_record.receipt_header_id;
1189: Exception

Line 1446: FROM rcv_transactions_interface

1442: deliver_to_person_id,
1443: deliver_to_location_id,
1444: secondary_unit_of_measure,
1445: secondary_uom_code
1446: FROM rcv_transactions_interface
1447: WHERE interface_transaction_id = p_transaction_id;
1448:
1449: CURSOR get_parent_row_from_cascade(
1450: p_parent_index NUMBER

Line 1731: l_to_org_id rcv_transactions_interface.to_organization_id%TYPE;

1727: /* Bug 3434460 */
1728: l_return_status VARCHAR2(1);
1729: l_msg_count NUMBER;
1730: l_msg_data fnd_new_messages.MESSAGE_TEXT%TYPE;
1731: l_to_org_id rcv_transactions_interface.to_organization_id%TYPE;
1732: BEGIN
1733: IF (g_asn_debug = 'Y') THEN
1734: asn_debug.put_line('Enter create shipment line');
1735: END IF;

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

2146: END IF;
2147: END process_line;
2148:
2149: PROCEDURE explode_lpn_failed(
2150: x_interface_txn_id IN OUT NOCOPY rcv_transactions_interface.interface_transaction_id%TYPE,
2151: x_group_id NUMBER,
2152: x_lpn_group_id NUMBER
2153: ) IS
2154: BEGIN

Line 2175: p_group_id IN rcv_transactions_interface.GROUP_ID%TYPE,

2171: END IF;
2172: END explode_lpn_failed;
2173:
2174: PROCEDURE update_rti_error(
2175: p_group_id IN rcv_transactions_interface.GROUP_ID%TYPE,
2176: p_interface_id IN rcv_transactions_interface.interface_transaction_id%TYPE,
2177: p_header_interface_id IN rcv_transactions_interface.header_interface_id%TYPE,
2178: p_lpn_group_id IN rcv_transactions_interface.lpn_group_id%TYPE
2179: ) IS

Line 2176: p_interface_id IN rcv_transactions_interface.interface_transaction_id%TYPE,

2172: END explode_lpn_failed;
2173:
2174: PROCEDURE update_rti_error(
2175: p_group_id IN rcv_transactions_interface.GROUP_ID%TYPE,
2176: p_interface_id IN rcv_transactions_interface.interface_transaction_id%TYPE,
2177: p_header_interface_id IN rcv_transactions_interface.header_interface_id%TYPE,
2178: p_lpn_group_id IN rcv_transactions_interface.lpn_group_id%TYPE
2179: ) IS
2180: l_return_status VARCHAR2(1);

Line 2177: p_header_interface_id IN rcv_transactions_interface.header_interface_id%TYPE,

2173:
2174: PROCEDURE update_rti_error(
2175: p_group_id IN rcv_transactions_interface.GROUP_ID%TYPE,
2176: p_interface_id IN rcv_transactions_interface.interface_transaction_id%TYPE,
2177: p_header_interface_id IN rcv_transactions_interface.header_interface_id%TYPE,
2178: p_lpn_group_id IN rcv_transactions_interface.lpn_group_id%TYPE
2179: ) IS
2180: l_return_status VARCHAR2(1);
2181: l_msg_data VARCHAR2(2000);

Line 2178: p_lpn_group_id IN rcv_transactions_interface.lpn_group_id%TYPE

2174: PROCEDURE update_rti_error(
2175: p_group_id IN rcv_transactions_interface.GROUP_ID%TYPE,
2176: p_interface_id IN rcv_transactions_interface.interface_transaction_id%TYPE,
2177: p_header_interface_id IN rcv_transactions_interface.header_interface_id%TYPE,
2178: p_lpn_group_id IN rcv_transactions_interface.lpn_group_id%TYPE
2179: ) IS
2180: l_return_status VARCHAR2(1);
2181: l_msg_data VARCHAR2(2000);
2182: l_msg_count NUMBER;

Line 2185: l_processing_mode_code rcv_transactions_interface.processing_mode_code%TYPE;

2181: l_msg_data VARCHAR2(2000);
2182: l_msg_count NUMBER;
2183: l_inventory_id NUMBER;
2184: l_txn_mode VARCHAR2(25);
2185: l_processing_mode_code rcv_transactions_interface.processing_mode_code%TYPE;
2186: BEGIN
2187: IF (g_asn_debug = 'Y') THEN
2188: asn_debug.put_line('Set rti row to error');
2189: asn_debug.put_line('p_group_id ' || p_group_id);

Line 2201: FROM rcv_transactions_interface

2197:
2198: IF (p_header_interface_id IS NOT NULL) THEN
2199: SELECT DISTINCT (processing_mode_code)
2200: INTO l_processing_mode_code
2201: FROM rcv_transactions_interface
2202: WHERE header_interface_id = p_header_interface_id;
2203: ELSIF(p_interface_id IS NOT NULL) THEN
2204: SELECT processing_mode_code
2205: INTO l_processing_mode_code

Line 2206: FROM rcv_transactions_interface

2202: WHERE header_interface_id = p_header_interface_id;
2203: ELSIF(p_interface_id IS NOT NULL) THEN
2204: SELECT processing_mode_code
2205: INTO l_processing_mode_code
2206: FROM rcv_transactions_interface
2207: WHERE interface_transaction_id = p_interface_id;
2208: ELSIF(p_group_id IS NOT NULL) THEN
2209: /* Bug 3361395.
2210: * When there is an when others exception in the

Line 2217: FROM rcv_transactions_interface

2213: * in this procedure.
2214: */
2215: SELECT DISTINCT (processing_mode_code)
2216: INTO l_processing_mode_code
2217: FROM rcv_transactions_interface
2218: WHERE GROUP_ID = p_group_id;
2219: END IF;
2220:
2221: IF (g_asn_debug = 'Y') THEN

Line 2230: UPDATE rcv_transactions_interface

2226: IF (g_asn_debug = 'Y') THEN
2227: asn_debug.put_line('online error ');
2228: END IF;
2229:
2230: UPDATE rcv_transactions_interface
2231: SET processing_status_code = 'ERROR'
2232: WHERE GROUP_ID = p_group_id;
2233:
2234: inv_receiving_transaction.txn_complete(p_group_id => p_group_id,

Line 2247: UPDATE rcv_transactions_interface

2243: IF (g_asn_debug = 'Y') THEN
2244: asn_debug.put_line('header_interface_id not null ');
2245: END IF;
2246:
2247: UPDATE rcv_transactions_interface
2248: SET processing_status_code = 'ERROR'
2249: WHERE header_interface_id = p_header_interface_id;
2250:
2251: l_inventory_id := p_header_interface_id;

Line 2258: UPDATE rcv_transactions_interface

2254: IF (g_asn_debug = 'Y') THEN
2255: asn_debug.put_line('lpn_group_id not null ');
2256: END IF;
2257:
2258: UPDATE rcv_transactions_interface
2259: SET processing_status_code = 'ERROR'
2260: WHERE lpn_group_id = p_lpn_group_id;
2261:
2262: l_inventory_id := p_lpn_group_id;

Line 2269: UPDATE rcv_transactions_interface

2265: IF (g_asn_debug = 'Y') THEN
2266: asn_debug.put_line('interface_id not null ');
2267: END IF;
2268:
2269: UPDATE rcv_transactions_interface
2270: SET processing_status_code = 'ERROR'
2271: WHERE interface_transaction_id = p_interface_id;
2272:
2273: l_inventory_id := p_interface_id;

Line 2293: UPDATE rcv_transactions_interface

2289: UPDATE rcv_headers_interface
2290: SET processing_status_code = 'ERROR'
2291: WHERE GROUP_ID = p_group_id;
2292:
2293: UPDATE rcv_transactions_interface
2294: SET processing_status_code = 'ERROR'
2295: WHERE GROUP_ID = p_group_id;
2296:
2297: l_inventory_id := p_group_id;