[Home] [Help]
292:
293: /* this belongs before the transaction looping */
294: FOR bad_shikyu IN get_bad_asbn_shikyu LOOP --Shikyu project
295: BEGIN
296: rcv_error_pkg.set_error_message('RCV_BAD_ASBN_SHIKYU');
297: rcv_error_pkg.set_token('HEADER_INTERFACE_ID', bad_shikyu.header_interface_id);
298: rcv_error_pkg.log_interface_error('RCV_HEADERS_INTERFACE',
299: 'HEADER_INTERFACE_ID',
300: x_group_id,
293: /* this belongs before the transaction looping */
294: FOR bad_shikyu IN get_bad_asbn_shikyu LOOP --Shikyu project
295: BEGIN
296: rcv_error_pkg.set_error_message('RCV_BAD_ASBN_SHIKYU');
297: rcv_error_pkg.set_token('HEADER_INTERFACE_ID', bad_shikyu.header_interface_id);
298: rcv_error_pkg.log_interface_error('RCV_HEADERS_INTERFACE',
299: 'HEADER_INTERFACE_ID',
300: x_group_id,
301: bad_shikyu.header_interface_id,
294: FOR bad_shikyu IN get_bad_asbn_shikyu LOOP --Shikyu project
295: BEGIN
296: rcv_error_pkg.set_error_message('RCV_BAD_ASBN_SHIKYU');
297: rcv_error_pkg.set_token('HEADER_INTERFACE_ID', bad_shikyu.header_interface_id);
298: rcv_error_pkg.log_interface_error('RCV_HEADERS_INTERFACE',
299: 'HEADER_INTERFACE_ID',
300: x_group_id,
301: bad_shikyu.header_interface_id,
302: NULL,
347: asn_debug.put_line('header interface id is ' || TO_CHAR(x_cascaded_table(n).header_interface_id));
348: END IF;
349:
350: x_progress := '040';
351: rcv_error_pkg.initialize(x_cascaded_table(n).GROUP_ID,
352: x_cascaded_table(n).header_interface_id,
353: x_cascaded_table(n).interface_transaction_id
354: );
355:
357: -- Check if it's a valid transaction type
358: IF NOT is_valid_txn_type(x_cascaded_table(n).transaction_type) THEN
359: x_cascaded_table(n).error_status := 'E';
360: x_cascaded_table(n).error_message := 'RCV_ROI_INVALID_TXN_TYPE';
361: rcv_error_pkg.set_error_message('RCV_ROI_INVALID_TXN_TYPE');
362: rcv_error_pkg.set_token('TXN_TYPE', x_cascaded_table(n).transaction_type);
363: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE', FALSE);
364: -- mark it's a line error
365: l_update_lpn_group := TRUE;
358: IF NOT is_valid_txn_type(x_cascaded_table(n).transaction_type) THEN
359: x_cascaded_table(n).error_status := 'E';
360: x_cascaded_table(n).error_message := 'RCV_ROI_INVALID_TXN_TYPE';
361: rcv_error_pkg.set_error_message('RCV_ROI_INVALID_TXN_TYPE');
362: rcv_error_pkg.set_token('TXN_TYPE', x_cascaded_table(n).transaction_type);
363: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE', FALSE);
364: -- mark it's a line error
365: l_update_lpn_group := TRUE;
366: END IF ;
359: x_cascaded_table(n).error_status := 'E';
360: x_cascaded_table(n).error_message := 'RCV_ROI_INVALID_TXN_TYPE';
361: rcv_error_pkg.set_error_message('RCV_ROI_INVALID_TXN_TYPE');
362: rcv_error_pkg.set_token('TXN_TYPE', x_cascaded_table(n).transaction_type);
363: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE', FALSE);
364: -- mark it's a line error
365: l_update_lpn_group := TRUE;
366: END IF ;
367:
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');
396: rcv_error_pkg.log_interface_error('PARENT_INTERFACE_TXN_ID');
397: END;
398:
399: IF l_proc_status_code = 'ERROR' THEN
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');
396: rcv_error_pkg.log_interface_error('PARENT_INTERFACE_TXN_ID');
397: END;
398:
399: IF l_proc_status_code = 'ERROR' THEN
400: RAISE rcv_error_pkg.e_fatal_error;
396: rcv_error_pkg.log_interface_error('PARENT_INTERFACE_TXN_ID');
397: END;
398:
399: IF l_proc_status_code = 'ERROR' THEN
400: RAISE rcv_error_pkg.e_fatal_error;
401: END IF;
402: END IF; --}
403:
404: IF x_cascaded_table(n).parent_source_transaction_num IS NOT NULL THEN
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');
413: rcv_error_pkg.log_interface_error('PARENT_SOURCE_TRANSACTION_NUM');
414: END;
415: IF l_proc_status_code = 'ERROR' THEN
416: RAISE rcv_error_pkg.e_fatal_error;
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');
413: rcv_error_pkg.log_interface_error('PARENT_SOURCE_TRANSACTION_NUM');
414: END;
415: IF l_proc_status_code = 'ERROR' THEN
416: RAISE rcv_error_pkg.e_fatal_error;
417: END IF;
412: rcv_error_pkg.set_error_message('RCV_NO_PARENT_TRANSACTION');
413: rcv_error_pkg.log_interface_error('PARENT_SOURCE_TRANSACTION_NUM');
414: END;
415: IF l_proc_status_code = 'ERROR' THEN
416: RAISE rcv_error_pkg.e_fatal_error;
417: END IF;
418: END IF; --}
419: -- end added for parent child support(*)
420:
426: WHERE interface_transaction_id = x_cascaded_table(n).interface_transaction_id;
427:
428: EXCEPTION
429: WHEN NO_DATA_FOUND THEN
430: rcv_error_pkg.set_error_message('RCV_INVALID_TRANSACTION_TYPE');
431: rcv_error_pkg.log_interface_error('INTERFACE_TRANSACTION_ID');
432: END;
433:
434: IF l_proc_status_code = 'ERROR' THEN
427:
428: EXCEPTION
429: WHEN NO_DATA_FOUND THEN
430: rcv_error_pkg.set_error_message('RCV_INVALID_TRANSACTION_TYPE');
431: rcv_error_pkg.log_interface_error('INTERFACE_TRANSACTION_ID');
432: END;
433:
434: IF l_proc_status_code = 'ERROR' THEN
435: RAISE rcv_error_pkg.e_fatal_error;
431: rcv_error_pkg.log_interface_error('INTERFACE_TRANSACTION_ID');
432: END;
433:
434: IF l_proc_status_code = 'ERROR' THEN
435: RAISE rcv_error_pkg.e_fatal_error;
436: END IF;
437:
438: EXCEPTION
439: WHEN rcv_error_pkg.e_fatal_error THEN
435: RAISE rcv_error_pkg.e_fatal_error;
436: END IF;
437:
438: EXCEPTION
439: WHEN rcv_error_pkg.e_fatal_error THEN
440: x_cascaded_table(n).error_status := 'E';
441: x_cascaded_table(n).error_message := rcv_error_pkg.get_last_message;
442: x_cascaded_table(n).processing_status_code := 'ERROR';
443: END;
437:
438: EXCEPTION
439: WHEN rcv_error_pkg.e_fatal_error THEN
440: x_cascaded_table(n).error_status := 'E';
441: x_cascaded_table(n).error_message := rcv_error_pkg.get_last_message;
442: x_cascaded_table(n).processing_status_code := 'ERROR';
443: END;
444:
445: IF (g_asn_debug = 'Y') THEN
541: asn_debug.put_line('The header has failed ' || TO_CHAR(x_header_record.header_record.header_interface_id));
542: asn_debug.put_line('ASN could not be cancelled');
543: END IF;
544:
545: rcv_error_pkg.set_error_message('RCV_ASN_NOT_ACCEPT');
546: rcv_error_pkg.set_token('SHIPMENT', x_header_record.header_record.shipment_num);
547: rcv_error_pkg.log_interface_error('SHIPMENT_NUM', FALSE);
548: END IF; --}
549: END IF; -- }
542: asn_debug.put_line('ASN could not be cancelled');
543: END IF;
544:
545: rcv_error_pkg.set_error_message('RCV_ASN_NOT_ACCEPT');
546: rcv_error_pkg.set_token('SHIPMENT', x_header_record.header_record.shipment_num);
547: rcv_error_pkg.log_interface_error('SHIPMENT_NUM', FALSE);
548: END IF; --}
549: END IF; -- }
550: END IF; -- } switch on transaction type (supporting new/cancel)
543: END IF;
544:
545: rcv_error_pkg.set_error_message('RCV_ASN_NOT_ACCEPT');
546: rcv_error_pkg.set_token('SHIPMENT', x_header_record.header_record.shipment_num);
547: rcv_error_pkg.log_interface_error('SHIPMENT_NUM', FALSE);
548: END IF; --}
549: END IF; -- }
550: END IF; -- } switch on transaction type (supporting new/cancel)
551: ELSE --}{ if transaction_type is receive or ship
553: -- Keep the header_interface_id so that if the txn fails the header can be errored.
554: -- x_cascaded_table(n).header_interface_id := NULL;
555: x_header_record := x_empty_header_record;
556: x_header_record.error_record.error_status := 'W';
557: rcv_error_pkg.set_error_message('RCV_ROI_FAULT_HEADER');
558: rcv_error_pkg.set_token('TXN_TYPE', x_cascaded_table(n).transaction_type);
559: rcv_error_pkg.log_interface_error('TRANSACTION_HEADER_ID', FALSE);
560:
561: END IF; --}
554: -- x_cascaded_table(n).header_interface_id := NULL;
555: x_header_record := x_empty_header_record;
556: x_header_record.error_record.error_status := 'W';
557: rcv_error_pkg.set_error_message('RCV_ROI_FAULT_HEADER');
558: rcv_error_pkg.set_token('TXN_TYPE', x_cascaded_table(n).transaction_type);
559: rcv_error_pkg.log_interface_error('TRANSACTION_HEADER_ID', FALSE);
560:
561: END IF; --}
562: END IF; --} if processing_status_code is running
555: x_header_record := x_empty_header_record;
556: x_header_record.error_record.error_status := 'W';
557: rcv_error_pkg.set_error_message('RCV_ROI_FAULT_HEADER');
558: rcv_error_pkg.set_token('TXN_TYPE', x_cascaded_table(n).transaction_type);
559: rcv_error_pkg.log_interface_error('TRANSACTION_HEADER_ID', FALSE);
560:
561: END IF; --}
562: END IF; --} if processing_status_code is running
563: ELSE -- } { no header row is picked up by header cursor
567: to_char(x_cascaded_table(n).interface_transaction_id) ||', set error_status to E');
568: END IF;
569: x_header_record.error_record.error_status := 'E';
570: -- need to insert po_inerface_errors
571: rcv_error_pkg.set_error_message('RCV_ROI_HEADER_MISSING');
572: rcv_error_pkg.set_token('TXN_TYPE', x_cascaded_table(n).transaction_type);
573: rcv_error_pkg.log_interface_error('HEADER_INTERFACE_ID', FALSE);
574: END IF; --} this is the check for whether header is processed
575:
568: END IF;
569: x_header_record.error_record.error_status := 'E';
570: -- need to insert po_inerface_errors
571: rcv_error_pkg.set_error_message('RCV_ROI_HEADER_MISSING');
572: rcv_error_pkg.set_token('TXN_TYPE', x_cascaded_table(n).transaction_type);
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));
569: x_header_record.error_record.error_status := 'E';
570: -- need to insert po_inerface_errors
571: rcv_error_pkg.set_error_message('RCV_ROI_HEADER_MISSING');
572: rcv_error_pkg.set_token('TXN_TYPE', x_cascaded_table(n).transaction_type);
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;
591: x_header_record.header_record.processing_status_code := 'ERROR';
592: x_header_record.error_record.error_status := 'E';
593:
594: /* Bug 4344351: Log a message indicating an error in RCV_HEADERS_INTERFACE table.*/
595: rcv_error_pkg.log_interface_error('RCV_HEADERS_INTERFACE','',FALSE);
596:
597: -- 2) update rti
598: IF (g_asn_debug = 'Y') THEN
599: asn_debug.put_line('update_rti_error after rhi error ');
693: -- process the line
694: /* Error out if receipt_source_code is null. We need it
695: * to process rti row.
696: */
697: rcv_error_pkg.test_is_null(x_cascaded_table(n).receipt_source_code,
698: 'RECEIPT_SOURCE_CODE',
699: 'RCV_RECEIPT_SOURCE_CODE_REQ'
700: );
701: process_line(x_cascaded_table,
731:
732: END IF; --}
733:
734: EXCEPTION
735: WHEN rcv_error_pkg.e_fatal_error THEN
736: x_cascaded_table(n).error_status := 'E';
737: x_cascaded_table(n).error_message := rcv_error_pkg.get_last_message;
738: END; --} processing lines
739: -- update the rti row to error
733:
734: EXCEPTION
735: WHEN rcv_error_pkg.e_fatal_error THEN
736: x_cascaded_table(n).error_status := 'E';
737: x_cascaded_table(n).error_message := rcv_error_pkg.get_last_message;
738: END; --} processing lines
739: -- update the rti row to error
740:
741: IF ( x_cascaded_table(n).error_status NOT IN('S', 'W')
747: OR ( x_cascaded_table(n).error_message = 'RCV_REJECT_ASBN_CONSIGNED_PO'
748: OR x_cascaded_table(n).error_message = 'RCV_REJECT_CONSUMPTION_PO'
749: OR x_cascaded_table(n).error_message = 'RCV_REJECT_CONSUMPTION_RELEASE')
750: ) THEN
751: rcv_error_pkg.set_error_message('RCV_ASN_NOT_ACCEPT');
752: rcv_error_pkg.set_token('SHIPMENT', x_header_record.header_record.shipment_num);
753: rcv_error_pkg.log_interface_error('SHIPMENT_NUM', FALSE);
754: END IF;
755: END IF;
748: OR x_cascaded_table(n).error_message = 'RCV_REJECT_CONSUMPTION_PO'
749: OR x_cascaded_table(n).error_message = 'RCV_REJECT_CONSUMPTION_RELEASE')
750: ) THEN
751: rcv_error_pkg.set_error_message('RCV_ASN_NOT_ACCEPT');
752: rcv_error_pkg.set_token('SHIPMENT', x_header_record.header_record.shipment_num);
753: rcv_error_pkg.log_interface_error('SHIPMENT_NUM', FALSE);
754: END IF;
755: END IF;
756:
749: OR x_cascaded_table(n).error_message = 'RCV_REJECT_CONSUMPTION_RELEASE')
750: ) THEN
751: rcv_error_pkg.set_error_message('RCV_ASN_NOT_ACCEPT');
752: rcv_error_pkg.set_token('SHIPMENT', x_header_record.header_record.shipment_num);
753: rcv_error_pkg.log_interface_error('SHIPMENT_NUM', FALSE);
754: END IF;
755: END IF;
756:
757: -- insert the split rti rows back into rti
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;
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;
1106: END IF;
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);
1115: WHEN OTHERS THEN
1116: IF (g_asn_debug = 'Y') 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);
1115: WHEN OTHERS THEN
1116: IF (g_asn_debug = 'Y') THEN
1117: asn_debug.put_line('Exception in preprocessor:');
1118: asn_debug.put_line('sqlerrm: ' || SQLERRM);
1386: RETURN;
1387: END IF;
1388:
1389: --mandatory matching values
1390: rcv_error_pkg.default_and_check(x_parent_row.shipment_header_id,
1391: x_cascaded_table(n).shipment_header_id,
1392: 'SHIPMENT_HEADER_ID'
1393: );
1394: rcv_error_pkg.default_and_check(x_parent_row.shipment_line_id,
1390: rcv_error_pkg.default_and_check(x_parent_row.shipment_header_id,
1391: x_cascaded_table(n).shipment_header_id,
1392: 'SHIPMENT_HEADER_ID'
1393: );
1394: rcv_error_pkg.default_and_check(x_parent_row.shipment_line_id,
1395: x_cascaded_table(n).shipment_line_id,
1396: 'SHIPMENT_LINE_ID'
1397: );
1398: rcv_error_pkg.default_and_check(x_parent_row.source_document_code,
1394: rcv_error_pkg.default_and_check(x_parent_row.shipment_line_id,
1395: x_cascaded_table(n).shipment_line_id,
1396: 'SHIPMENT_LINE_ID'
1397: );
1398: rcv_error_pkg.default_and_check(x_parent_row.source_document_code,
1399: x_cascaded_table(n).source_document_code,
1400: 'SOURCE_DOCUMENT_CODE'
1401: );
1402: rcv_error_pkg.default_and_check(x_parent_row.po_header_id,
1398: rcv_error_pkg.default_and_check(x_parent_row.source_document_code,
1399: x_cascaded_table(n).source_document_code,
1400: 'SOURCE_DOCUMENT_CODE'
1401: );
1402: rcv_error_pkg.default_and_check(x_parent_row.po_header_id,
1403: x_cascaded_table(n).po_header_id,
1404: 'PO_HEADER_ID'
1405: );
1406: rcv_error_pkg.default_and_check(x_parent_row.po_release_id,
1402: rcv_error_pkg.default_and_check(x_parent_row.po_header_id,
1403: x_cascaded_table(n).po_header_id,
1404: 'PO_HEADER_ID'
1405: );
1406: rcv_error_pkg.default_and_check(x_parent_row.po_release_id,
1407: x_cascaded_table(n).po_release_id,
1408: 'PO_RELEASE_ID'
1409: );
1410: rcv_error_pkg.default_and_check(x_parent_row.po_line_id,
1406: rcv_error_pkg.default_and_check(x_parent_row.po_release_id,
1407: x_cascaded_table(n).po_release_id,
1408: 'PO_RELEASE_ID'
1409: );
1410: rcv_error_pkg.default_and_check(x_parent_row.po_line_id,
1411: x_cascaded_table(n).po_line_id,
1412: 'PO_LINE_ID'
1413: );
1414: rcv_error_pkg.default_and_check(x_parent_row.po_line_location_id,
1410: rcv_error_pkg.default_and_check(x_parent_row.po_line_id,
1411: x_cascaded_table(n).po_line_id,
1412: 'PO_LINE_ID'
1413: );
1414: rcv_error_pkg.default_and_check(x_parent_row.po_line_location_id,
1415: x_cascaded_table(n).po_line_location_id,
1416: 'PO_LINE_LOCATION_ID'
1417: );
1418: rcv_error_pkg.default_and_check(x_parent_row.po_distribution_id,
1414: rcv_error_pkg.default_and_check(x_parent_row.po_line_location_id,
1415: x_cascaded_table(n).po_line_location_id,
1416: 'PO_LINE_LOCATION_ID'
1417: );
1418: rcv_error_pkg.default_and_check(x_parent_row.po_distribution_id,
1419: x_cascaded_table(n).po_distribution_id,
1420: 'PO_DISTRIBUTION_ID'
1421: );
1422: rcv_error_pkg.default_and_check(x_parent_row.po_revision_num,
1418: rcv_error_pkg.default_and_check(x_parent_row.po_distribution_id,
1419: x_cascaded_table(n).po_distribution_id,
1420: 'PO_DISTRIBUTION_ID'
1421: );
1422: rcv_error_pkg.default_and_check(x_parent_row.po_revision_num,
1423: x_cascaded_table(n).po_revision_num,
1424: 'PO_REVISION_NUM'
1425: );
1426: rcv_error_pkg.default_and_check(x_parent_row.requisition_line_id,
1422: rcv_error_pkg.default_and_check(x_parent_row.po_revision_num,
1423: x_cascaded_table(n).po_revision_num,
1424: 'PO_REVISION_NUM'
1425: );
1426: rcv_error_pkg.default_and_check(x_parent_row.requisition_line_id,
1427: x_cascaded_table(n).requisition_line_id,
1428: 'REQUISITION_LINE_ID'
1429: );
1430: rcv_error_pkg.default_and_check(x_parent_row.po_unit_price,
1426: rcv_error_pkg.default_and_check(x_parent_row.requisition_line_id,
1427: x_cascaded_table(n).requisition_line_id,
1428: 'REQUISITION_LINE_ID'
1429: );
1430: rcv_error_pkg.default_and_check(x_parent_row.po_unit_price,
1431: x_cascaded_table(n).po_unit_price,
1432: 'PO_UNIT_PRICE'
1433: );
1434: rcv_error_pkg.default_and_check(x_parent_row.currency_code,
1430: rcv_error_pkg.default_and_check(x_parent_row.po_unit_price,
1431: x_cascaded_table(n).po_unit_price,
1432: 'PO_UNIT_PRICE'
1433: );
1434: rcv_error_pkg.default_and_check(x_parent_row.currency_code,
1435: x_cascaded_table(n).currency_code,
1436: 'CURRENCY_CODE'
1437: );
1438: rcv_error_pkg.default_and_check(x_parent_row.currency_conversion_type,
1434: rcv_error_pkg.default_and_check(x_parent_row.currency_code,
1435: x_cascaded_table(n).currency_code,
1436: 'CURRENCY_CODE'
1437: );
1438: rcv_error_pkg.default_and_check(x_parent_row.currency_conversion_type,
1439: x_cascaded_table(n).currency_conversion_type,
1440: 'CURRENCY_CONVERSION_TYPE'
1441: );
1442: rcv_error_pkg.default_and_check(x_parent_row.vendor_id,
1438: rcv_error_pkg.default_and_check(x_parent_row.currency_conversion_type,
1439: x_cascaded_table(n).currency_conversion_type,
1440: 'CURRENCY_CONVERSION_TYPE'
1441: );
1442: rcv_error_pkg.default_and_check(x_parent_row.vendor_id,
1443: x_cascaded_table(n).vendor_id,
1444: 'VENDOR_ID'
1445: );
1446: rcv_error_pkg.default_and_check(x_parent_row.vendor_site_id,
1442: rcv_error_pkg.default_and_check(x_parent_row.vendor_id,
1443: x_cascaded_table(n).vendor_id,
1444: 'VENDOR_ID'
1445: );
1446: rcv_error_pkg.default_and_check(x_parent_row.vendor_site_id,
1447: x_cascaded_table(n).vendor_site_id,
1448: 'VENDOR_SITE_ID'
1449: );
1450: rcv_error_pkg.default_and_check(x_parent_row.source_doc_unit_of_measure,
1446: rcv_error_pkg.default_and_check(x_parent_row.vendor_site_id,
1447: x_cascaded_table(n).vendor_site_id,
1448: 'VENDOR_SITE_ID'
1449: );
1450: rcv_error_pkg.default_and_check(x_parent_row.source_doc_unit_of_measure,
1451: x_cascaded_table(n).source_doc_unit_of_measure,
1452: 'SOURCE_DOC_UNIT_OF_MEASURE'
1453: );
1454: rcv_error_pkg.default_and_check(x_parent_row.oe_order_header_id,
1450: rcv_error_pkg.default_and_check(x_parent_row.source_doc_unit_of_measure,
1451: x_cascaded_table(n).source_doc_unit_of_measure,
1452: 'SOURCE_DOC_UNIT_OF_MEASURE'
1453: );
1454: rcv_error_pkg.default_and_check(x_parent_row.oe_order_header_id,
1455: x_cascaded_table(n).oe_order_header_id,
1456: 'OE_ORDER_HEADER_ID'
1457: );
1458: rcv_error_pkg.default_and_check(x_parent_row.oe_order_line_id,
1454: rcv_error_pkg.default_and_check(x_parent_row.oe_order_header_id,
1455: x_cascaded_table(n).oe_order_header_id,
1456: 'OE_ORDER_HEADER_ID'
1457: );
1458: rcv_error_pkg.default_and_check(x_parent_row.oe_order_line_id,
1459: x_cascaded_table(n).oe_order_line_id,
1460: 'OE_ORDER_LINE_ID'
1461: );
1462: rcv_error_pkg.default_and_check(x_parent_row.customer_id,
1458: rcv_error_pkg.default_and_check(x_parent_row.oe_order_line_id,
1459: x_cascaded_table(n).oe_order_line_id,
1460: 'OE_ORDER_LINE_ID'
1461: );
1462: rcv_error_pkg.default_and_check(x_parent_row.customer_id,
1463: x_cascaded_table(n).customer_id,
1464: 'CUSTOMER_ID'
1465: );
1466: rcv_error_pkg.default_and_check(x_parent_row.customer_site_id,
1462: rcv_error_pkg.default_and_check(x_parent_row.customer_id,
1463: x_cascaded_table(n).customer_id,
1464: 'CUSTOMER_ID'
1465: );
1466: rcv_error_pkg.default_and_check(x_parent_row.customer_site_id,
1467: x_cascaded_table(n).customer_site_id,
1468: 'CUSTOMER_SITE_ID'
1469: );
1470: rcv_error_pkg.default_and_check(x_parent_row.job_id,
1466: rcv_error_pkg.default_and_check(x_parent_row.customer_site_id,
1467: x_cascaded_table(n).customer_site_id,
1468: 'CUSTOMER_SITE_ID'
1469: );
1470: rcv_error_pkg.default_and_check(x_parent_row.job_id,
1471: x_cascaded_table(n).job_id,
1472: 'JOB_ID'
1473: );
1474: rcv_error_pkg.default_and_check(x_parent_row.timecard_id,
1470: rcv_error_pkg.default_and_check(x_parent_row.job_id,
1471: x_cascaded_table(n).job_id,
1472: 'JOB_ID'
1473: );
1474: rcv_error_pkg.default_and_check(x_parent_row.timecard_id,
1475: x_cascaded_table(n).timecard_id,
1476: 'TIMECARD_ID'
1477: );
1478: rcv_error_pkg.default_and_check(x_parent_row.timecard_ovn,
1474: rcv_error_pkg.default_and_check(x_parent_row.timecard_id,
1475: x_cascaded_table(n).timecard_id,
1476: 'TIMECARD_ID'
1477: );
1478: rcv_error_pkg.default_and_check(x_parent_row.timecard_ovn,
1479: x_cascaded_table(n).timecard_ovn,
1480: 'TIMECARD_OVN'
1481: );
1482: rcv_error_pkg.default_and_check(x_parent_row.project_id,
1478: rcv_error_pkg.default_and_check(x_parent_row.timecard_ovn,
1479: x_cascaded_table(n).timecard_ovn,
1480: 'TIMECARD_OVN'
1481: );
1482: rcv_error_pkg.default_and_check(x_parent_row.project_id,
1483: x_cascaded_table(n).project_id,
1484: 'PROJECT_ID'
1485: );
1486: rcv_error_pkg.default_and_check(x_parent_row.task_id,
1482: rcv_error_pkg.default_and_check(x_parent_row.project_id,
1483: x_cascaded_table(n).project_id,
1484: 'PROJECT_ID'
1485: );
1486: rcv_error_pkg.default_and_check(x_parent_row.task_id,
1487: x_cascaded_table(n).task_id,
1488: 'TASK_ID'
1489: );
1490: rcv_error_pkg.default_and_check(x_parent_row.category_id,
1486: rcv_error_pkg.default_and_check(x_parent_row.task_id,
1487: x_cascaded_table(n).task_id,
1488: 'TASK_ID'
1489: );
1490: rcv_error_pkg.default_and_check(x_parent_row.category_id,
1491: x_cascaded_table(n).category_id,
1492: 'CATEGORY_ID'
1493: );
1494: rcv_error_pkg.default_and_check(x_parent_row.item_description,
1490: rcv_error_pkg.default_and_check(x_parent_row.category_id,
1491: x_cascaded_table(n).category_id,
1492: 'CATEGORY_ID'
1493: );
1494: rcv_error_pkg.default_and_check(x_parent_row.item_description,
1495: x_cascaded_table(n).item_description,
1496: 'ITEM_DESCRIPTION'
1497: );
1498: rcv_error_pkg.default_and_check(x_parent_row.item_id,
1494: rcv_error_pkg.default_and_check(x_parent_row.item_description,
1495: x_cascaded_table(n).item_description,
1496: 'ITEM_DESCRIPTION'
1497: );
1498: rcv_error_pkg.default_and_check(x_parent_row.item_id,
1499: x_cascaded_table(n).item_id,
1500: 'ITEM_ID'
1501: );
1502: rcv_error_pkg.default_and_check(x_parent_row.item_revision,
1498: rcv_error_pkg.default_and_check(x_parent_row.item_id,
1499: x_cascaded_table(n).item_id,
1500: 'ITEM_ID'
1501: );
1502: rcv_error_pkg.default_and_check(x_parent_row.item_revision,
1503: x_cascaded_table(n).item_revision,
1504: 'ITEM_REVISION'
1505: );
1506: rcv_error_pkg.default_and_check(x_parent_row.vendor_item_num,
1502: rcv_error_pkg.default_and_check(x_parent_row.item_revision,
1503: x_cascaded_table(n).item_revision,
1504: 'ITEM_REVISION'
1505: );
1506: rcv_error_pkg.default_and_check(x_parent_row.vendor_item_num,
1507: x_cascaded_table(n).vendor_item_num,
1508: 'VENDOR_ITEM_NUM'
1509: );
1510: rcv_error_pkg.default_and_check(x_parent_row.vendor_lot_num,
1506: rcv_error_pkg.default_and_check(x_parent_row.vendor_item_num,
1507: x_cascaded_table(n).vendor_item_num,
1508: 'VENDOR_ITEM_NUM'
1509: );
1510: rcv_error_pkg.default_and_check(x_parent_row.vendor_lot_num,
1511: x_cascaded_table(n).vendor_lot_num,
1512: 'VENDOR_LOT_NUM'
1513: );
1514: rcv_error_pkg.default_and_check(x_parent_row.from_organization_id,
1510: rcv_error_pkg.default_and_check(x_parent_row.vendor_lot_num,
1511: x_cascaded_table(n).vendor_lot_num,
1512: 'VENDOR_LOT_NUM'
1513: );
1514: rcv_error_pkg.default_and_check(x_parent_row.from_organization_id,
1515: x_cascaded_table(n).from_organization_id,
1516: 'FROM_ORGANIZATION_ID'
1517: );
1518: rcv_error_pkg.default_and_check(x_parent_row.to_organization_id,
1514: rcv_error_pkg.default_and_check(x_parent_row.from_organization_id,
1515: x_cascaded_table(n).from_organization_id,
1516: 'FROM_ORGANIZATION_ID'
1517: );
1518: rcv_error_pkg.default_and_check(x_parent_row.to_organization_id,
1519: x_cascaded_table(n).to_organization_id,
1520: 'TO_ORGANIZATION_ID'
1521: );
1522: --defaulting values
1530: default_no_check(x_parent_row.deliver_to_location_id, x_cascaded_table(n).deliver_to_location_id);
1531: default_no_check(x_parent_row.secondary_unit_of_measure, x_cascaded_table(n).secondary_unit_of_measure);
1532: default_no_check(x_parent_row.secondary_uom_code, x_cascaded_table(n).secondary_uom_code);
1533: EXCEPTION
1534: WHEN rcv_error_pkg.e_fatal_error THEN
1535: x_cascaded_table(n).error_status := rcv_error_pkg.g_ret_sts_error;
1536: x_cascaded_table(n).error_message := rcv_error_pkg.get_last_message;
1537: END default_from_parent_trx;
1538:
1531: default_no_check(x_parent_row.secondary_unit_of_measure, x_cascaded_table(n).secondary_unit_of_measure);
1532: default_no_check(x_parent_row.secondary_uom_code, x_cascaded_table(n).secondary_uom_code);
1533: EXCEPTION
1534: WHEN rcv_error_pkg.e_fatal_error THEN
1535: x_cascaded_table(n).error_status := rcv_error_pkg.g_ret_sts_error;
1536: x_cascaded_table(n).error_message := rcv_error_pkg.get_last_message;
1537: END default_from_parent_trx;
1538:
1539: PROCEDURE process_line(
1532: default_no_check(x_parent_row.secondary_uom_code, x_cascaded_table(n).secondary_uom_code);
1533: EXCEPTION
1534: WHEN rcv_error_pkg.e_fatal_error THEN
1535: x_cascaded_table(n).error_status := rcv_error_pkg.g_ret_sts_error;
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,
1610: v_header_record
1611: );
1612: ELSE
1613: asn_debug.put_line('We do not support transaction type ' || x_cascaded_table(n).transaction_type);
1614: rcv_error_pkg.set_error_message('RCV_INVALID_TRANSACTION_TYPE');
1615: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE');
1616: END IF;
1617: ELSIF(x_cascaded_table(n).receipt_source_code = 'INTERNAL ORDER') THEN
1618: IF (x_cascaded_table(n).transaction_type = 'RECEIVE') THEN
1611: );
1612: ELSE
1613: asn_debug.put_line('We do not support transaction type ' || x_cascaded_table(n).transaction_type);
1614: rcv_error_pkg.set_error_message('RCV_INVALID_TRANSACTION_TYPE');
1615: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE');
1616: END IF;
1617: ELSIF(x_cascaded_table(n).receipt_source_code = 'INTERNAL ORDER') THEN
1618: IF (x_cascaded_table(n).transaction_type = 'RECEIVE') THEN
1619: asn_debug.put_line('calling derive routine for transaction ' || x_cascaded_table(n).transaction_type);
1637: v_header_record
1638: );
1639: ELSE
1640: asn_debug.put_line('We do not support transaction type ' || x_cascaded_table(n).transaction_type);
1641: rcv_error_pkg.set_error_message('RCV_INVALID_TRANSACTION_TYPE');
1642: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE');
1643: END IF; -- IF INTERNAL ORDER
1644: ELSIF(x_cascaded_table(n).receipt_source_code = 'INVENTORY') THEN --} {
1645: IF (x_cascaded_table(n).transaction_type = 'RECEIVE') THEN
1638: );
1639: ELSE
1640: asn_debug.put_line('We do not support transaction type ' || x_cascaded_table(n).transaction_type);
1641: rcv_error_pkg.set_error_message('RCV_INVALID_TRANSACTION_TYPE');
1642: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE');
1643: END IF; -- IF INTERNAL ORDER
1644: ELSIF(x_cascaded_table(n).receipt_source_code = 'INVENTORY') THEN --} {
1645: IF (x_cascaded_table(n).transaction_type = 'RECEIVE') THEN
1646: rcv_int_org_transfer.derive_int_org_rcv_line(x_cascaded_table,
1663: v_header_record
1664: );
1665: ELSE
1666: asn_debug.put_line('We do not support transaction type ' || x_cascaded_table(n).transaction_type);
1667: rcv_error_pkg.set_error_message('RCV_INVALID_TRANSACTION_TYPE');
1668: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE');
1669: END IF;
1670: ELSIF(x_cascaded_table(n).receipt_source_code = 'CUSTOMER') THEN --} {
1671: asn_debug.put_line('calling derive routine for RMA transaction ' || x_cascaded_table(n).transaction_type);
1664: );
1665: ELSE
1666: asn_debug.put_line('We do not support transaction type ' || x_cascaded_table(n).transaction_type);
1667: rcv_error_pkg.set_error_message('RCV_INVALID_TRANSACTION_TYPE');
1668: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE');
1669: END IF;
1670: ELSIF(x_cascaded_table(n).receipt_source_code = 'CUSTOMER') THEN --} {
1671: asn_debug.put_line('calling derive routine for RMA transaction ' || x_cascaded_table(n).transaction_type);
1672:
1695: v_header_record
1696: );
1697: ELSE
1698: asn_debug.put_line('We do not support transaction type ' || x_cascaded_table(n).transaction_type);
1699: rcv_error_pkg.set_error_message('RCV_INVALID_TRANSACTION_TYPE');
1700: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE');
1701: END IF; --}
1702: ELSE --}{
1703: asn_debug.put_line('We do not support receipt_source_code ' || x_cascaded_table(n).receipt_source_code);
1696: );
1697: ELSE
1698: asn_debug.put_line('We do not support transaction type ' || x_cascaded_table(n).transaction_type);
1699: rcv_error_pkg.set_error_message('RCV_INVALID_TRANSACTION_TYPE');
1700: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE');
1701: END IF; --}
1702: ELSE --}{
1703: asn_debug.put_line('We do not support receipt_source_code ' || x_cascaded_table(n).receipt_source_code);
1704: rcv_error_pkg.set_error_message('RCV_INVALID_TRANSACTION_TYPE');
1700: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE');
1701: END IF; --}
1702: ELSE --}{
1703: asn_debug.put_line('We do not support receipt_source_code ' || x_cascaded_table(n).receipt_source_code);
1704: rcv_error_pkg.set_error_message('RCV_INVALID_TRANSACTION_TYPE');
1705: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE');
1706: END IF; --}
1707: END IF;
1708: IF (g_asn_debug = 'Y') THEN
1701: END IF; --}
1702: ELSE --}{
1703: asn_debug.put_line('We do not support receipt_source_code ' || x_cascaded_table(n).receipt_source_code);
1704: rcv_error_pkg.set_error_message('RCV_INVALID_TRANSACTION_TYPE');
1705: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE');
1706: END IF; --}
1707: END IF;
1708: IF (g_asn_debug = 'Y') THEN
1709: asn_debug.put_line('Back from derive routine with ' || TO_CHAR(used_for_cascaded_rows.COUNT) || ' rows');
1927: IF (g_asn_debug = 'Y') THEN
1928: asn_debug.put_line('Exit create shipment line');
1929: END IF;
1930: EXCEPTION
1931: WHEN rcv_error_pkg.e_fatal_error THEN
1932: x_cascaded_table(n).error_status := 'E';
1933: x_cascaded_table(n).error_message := rcv_error_pkg.get_last_message;
1934: WHEN OTHERS THEN
1935: IF (g_asn_debug = 'Y') THEN
1929: END IF;
1930: EXCEPTION
1931: WHEN rcv_error_pkg.e_fatal_error THEN
1932: x_cascaded_table(n).error_status := 'E';
1933: x_cascaded_table(n).error_message := rcv_error_pkg.get_last_message;
1934: WHEN OTHERS THEN
1935: IF (g_asn_debug = 'Y') THEN
1936: asn_debug.put_line('Exception in process_line');
1937: END IF;
1951: p_interface_id => x_interface_txn_id,
1952: p_header_interface_id => NULL,
1953: p_lpn_group_id => x_lpn_group_id
1954: );
1955: rcv_error_pkg.set_error_message('RCV_LPN_EXPLOSION_FAILED');
1956: rcv_error_pkg.set_token('LPN_GROUP_ID', x_lpn_group_id);
1957: rcv_error_pkg.log_interface_warning('LPN_GROUP_ID');
1958: EXCEPTION
1959: WHEN OTHERS THEN
1952: p_header_interface_id => NULL,
1953: p_lpn_group_id => x_lpn_group_id
1954: );
1955: rcv_error_pkg.set_error_message('RCV_LPN_EXPLOSION_FAILED');
1956: rcv_error_pkg.set_token('LPN_GROUP_ID', x_lpn_group_id);
1957: rcv_error_pkg.log_interface_warning('LPN_GROUP_ID');
1958: EXCEPTION
1959: WHEN OTHERS THEN
1960: IF (g_asn_debug = 'Y') THEN
1953: p_lpn_group_id => x_lpn_group_id
1954: );
1955: rcv_error_pkg.set_error_message('RCV_LPN_EXPLOSION_FAILED');
1956: rcv_error_pkg.set_token('LPN_GROUP_ID', x_lpn_group_id);
1957: rcv_error_pkg.log_interface_warning('LPN_GROUP_ID');
1958: EXCEPTION
1959: WHEN OTHERS THEN
1960: IF (g_asn_debug = 'Y') THEN
1961: asn_debug.put_line('Exception in explode_lpn_failed');
1983: asn_debug.put_line('p_lpn_group_id ' || p_lpn_group_id);
1984: END IF;
1985:
1986: -- bug 3676436, if there is a pending error message than we log it
1987: rcv_error_pkg.log_interface_error('INTERFACE_TRANSACTION_ID',FALSE);
1988:
1989: IF (p_header_interface_id IS NOT NULL) THEN
1990: SELECT DISTINCT (processing_mode_code)
1991: INTO l_processing_mode_code