[Home] [Help]
172: IF (g_asn_debug = 'Y') THEN
173: asn_debug.put_line('Exception in derive_destination_info');
174: asn_debug.put_line('sqlerrm : ' || SQLERRM);
175: END IF;
176: x_cascaded_table(n).error_status := rcv_error_pkg.g_ret_sts_error;
177:
178: END derive_destination_info;
179: -- Bug 10227549 : End
180:
411:
412: /* this belongs before the transaction looping */
413: FOR bad_shikyu IN get_bad_asbn_shikyu LOOP --Shikyu project
414: BEGIN
415: rcv_error_pkg.set_error_message('RCV_BAD_ASBN_SHIKYU');
416: rcv_error_pkg.set_token('HEADER_INTERFACE_ID', bad_shikyu.header_interface_id);
417: rcv_error_pkg.log_interface_error('RCV_HEADERS_INTERFACE',
418: 'HEADER_INTERFACE_ID',
419: x_group_id,
412: /* this belongs before the transaction looping */
413: FOR bad_shikyu IN get_bad_asbn_shikyu LOOP --Shikyu project
414: BEGIN
415: rcv_error_pkg.set_error_message('RCV_BAD_ASBN_SHIKYU');
416: rcv_error_pkg.set_token('HEADER_INTERFACE_ID', bad_shikyu.header_interface_id);
417: rcv_error_pkg.log_interface_error('RCV_HEADERS_INTERFACE',
418: 'HEADER_INTERFACE_ID',
419: x_group_id,
420: bad_shikyu.header_interface_id,
413: FOR bad_shikyu IN get_bad_asbn_shikyu LOOP --Shikyu project
414: BEGIN
415: rcv_error_pkg.set_error_message('RCV_BAD_ASBN_SHIKYU');
416: rcv_error_pkg.set_token('HEADER_INTERFACE_ID', bad_shikyu.header_interface_id);
417: rcv_error_pkg.log_interface_error('RCV_HEADERS_INTERFACE',
418: 'HEADER_INTERFACE_ID',
419: x_group_id,
420: bad_shikyu.header_interface_id,
421: NULL,
467: asn_debug.put_line('header interface id is ' || TO_CHAR(x_cascaded_table(n).header_interface_id));
468: END IF;
469:
470: x_progress := '040';
471: rcv_error_pkg.initialize(x_cascaded_table(n).GROUP_ID,
472: x_cascaded_table(n).header_interface_id,
473: x_cascaded_table(n).interface_transaction_id
474: );
475:
477: -- Check if it's a valid transaction type
478: IF NOT is_valid_txn_type(x_cascaded_table(n).transaction_type) THEN
479: x_cascaded_table(n).error_status := 'E';
480: x_cascaded_table(n).error_message := 'RCV_ROI_INVALID_TXN_TYPE';
481: rcv_error_pkg.set_error_message('RCV_ROI_INVALID_TXN_TYPE');
482: rcv_error_pkg.set_token('TXN_TYPE', x_cascaded_table(n).transaction_type);
483: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE', FALSE);
484: -- mark it's a line error
485: l_update_lpn_group := TRUE;
478: IF NOT is_valid_txn_type(x_cascaded_table(n).transaction_type) THEN
479: x_cascaded_table(n).error_status := 'E';
480: x_cascaded_table(n).error_message := 'RCV_ROI_INVALID_TXN_TYPE';
481: rcv_error_pkg.set_error_message('RCV_ROI_INVALID_TXN_TYPE');
482: rcv_error_pkg.set_token('TXN_TYPE', x_cascaded_table(n).transaction_type);
483: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE', FALSE);
484: -- mark it's a line error
485: l_update_lpn_group := TRUE;
486: END IF ;
479: x_cascaded_table(n).error_status := 'E';
480: x_cascaded_table(n).error_message := 'RCV_ROI_INVALID_TXN_TYPE';
481: rcv_error_pkg.set_error_message('RCV_ROI_INVALID_TXN_TYPE');
482: rcv_error_pkg.set_token('TXN_TYPE', x_cascaded_table(n).transaction_type);
483: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE', FALSE);
484: -- mark it's a line error
485: l_update_lpn_group := TRUE;
486: END IF ;
487:
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');
516: rcv_error_pkg.log_interface_error('PARENT_INTERFACE_TXN_ID');
517: END;
518:
519: IF l_proc_status_code = 'ERROR' THEN
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');
516: rcv_error_pkg.log_interface_error('PARENT_INTERFACE_TXN_ID');
517: END;
518:
519: IF l_proc_status_code = 'ERROR' THEN
520: RAISE rcv_error_pkg.e_fatal_error;
516: rcv_error_pkg.log_interface_error('PARENT_INTERFACE_TXN_ID');
517: END;
518:
519: IF l_proc_status_code = 'ERROR' THEN
520: RAISE rcv_error_pkg.e_fatal_error;
521: END IF;
522: END IF; --}
523:
524: -- Bug 7651646:
534: WHERE interface_transaction_id = x_cascaded_table(n).interface_transaction_id;
535:
536: EXCEPTION
537: WHEN NO_DATA_FOUND THEN
538: rcv_error_pkg.set_error_message('RCV_INVALID_TRANSACTION_TYPE');
539: rcv_error_pkg.log_interface_error('INTERFACE_TRANSACTION_ID');
540: END;
541:
542: IF l_proc_status_code = 'ERROR' THEN
535:
536: EXCEPTION
537: WHEN NO_DATA_FOUND THEN
538: rcv_error_pkg.set_error_message('RCV_INVALID_TRANSACTION_TYPE');
539: rcv_error_pkg.log_interface_error('INTERFACE_TRANSACTION_ID');
540: END;
541:
542: IF l_proc_status_code = 'ERROR' THEN
543: RAISE rcv_error_pkg.e_fatal_error;
539: rcv_error_pkg.log_interface_error('INTERFACE_TRANSACTION_ID');
540: END;
541:
542: IF l_proc_status_code = 'ERROR' THEN
543: RAISE rcv_error_pkg.e_fatal_error;
544: END IF;
545:
546: EXCEPTION
547: WHEN rcv_error_pkg.e_fatal_error THEN
543: RAISE rcv_error_pkg.e_fatal_error;
544: END IF;
545:
546: EXCEPTION
547: WHEN rcv_error_pkg.e_fatal_error THEN
548: x_cascaded_table(n).error_status := 'E';
549: x_cascaded_table(n).error_message := rcv_error_pkg.get_last_message;
550: x_cascaded_table(n).processing_status_code := 'ERROR';
551: END;
545:
546: EXCEPTION
547: WHEN rcv_error_pkg.e_fatal_error THEN
548: x_cascaded_table(n).error_status := 'E';
549: x_cascaded_table(n).error_message := rcv_error_pkg.get_last_message;
550: x_cascaded_table(n).processing_status_code := 'ERROR';
551: END;
552:
553: IF (g_asn_debug = 'Y') THEN
653: asn_debug.put_line('The header has failed ' || TO_CHAR(x_header_record.header_record.header_interface_id));
654: asn_debug.put_line('ASN could not be cancelled');
655: END IF;
656:
657: rcv_error_pkg.set_error_message('RCV_ASN_NOT_ACCEPT');
658: rcv_error_pkg.set_token('SHIPMENT', x_header_record.header_record.shipment_num);
659: rcv_error_pkg.log_interface_error('SHIPMENT_NUM', FALSE);
660: END IF; --}
661: END IF; -- }
654: asn_debug.put_line('ASN could not be cancelled');
655: END IF;
656:
657: rcv_error_pkg.set_error_message('RCV_ASN_NOT_ACCEPT');
658: rcv_error_pkg.set_token('SHIPMENT', x_header_record.header_record.shipment_num);
659: rcv_error_pkg.log_interface_error('SHIPMENT_NUM', FALSE);
660: END IF; --}
661: END IF; -- }
662: END IF; -- } switch on transaction type (supporting new/cancel)
655: END IF;
656:
657: rcv_error_pkg.set_error_message('RCV_ASN_NOT_ACCEPT');
658: rcv_error_pkg.set_token('SHIPMENT', x_header_record.header_record.shipment_num);
659: rcv_error_pkg.log_interface_error('SHIPMENT_NUM', FALSE);
660: END IF; --}
661: END IF; -- }
662: END IF; -- } switch on transaction type (supporting new/cancel)
663: ELSE --}{ if transaction_type is receive or ship
665: -- Keep the header_interface_id so that if the txn fails the header can be errored.
666: -- x_cascaded_table(n).header_interface_id := NULL;
667: x_header_record := x_empty_header_record;
668: x_header_record.error_record.error_status := 'W';
669: rcv_error_pkg.set_error_message('RCV_ROI_FAULT_HEADER');
670: rcv_error_pkg.set_token('TXN_TYPE', x_cascaded_table(n).transaction_type);
671: rcv_error_pkg.log_interface_error('TRANSACTION_HEADER_ID', FALSE);
672:
673: END IF; --}
666: -- x_cascaded_table(n).header_interface_id := NULL;
667: x_header_record := x_empty_header_record;
668: x_header_record.error_record.error_status := 'W';
669: rcv_error_pkg.set_error_message('RCV_ROI_FAULT_HEADER');
670: rcv_error_pkg.set_token('TXN_TYPE', x_cascaded_table(n).transaction_type);
671: rcv_error_pkg.log_interface_error('TRANSACTION_HEADER_ID', FALSE);
672:
673: END IF; --}
674: END IF; --} if processing_status_code is running
667: x_header_record := x_empty_header_record;
668: x_header_record.error_record.error_status := 'W';
669: rcv_error_pkg.set_error_message('RCV_ROI_FAULT_HEADER');
670: rcv_error_pkg.set_token('TXN_TYPE', x_cascaded_table(n).transaction_type);
671: rcv_error_pkg.log_interface_error('TRANSACTION_HEADER_ID', FALSE);
672:
673: END IF; --}
674: END IF; --} if processing_status_code is running
675: ELSE -- } { no header row is picked up by header cursor
679: to_char(x_cascaded_table(n).interface_transaction_id) ||', set error_status to E');
680: END IF;
681: x_header_record.error_record.error_status := 'E';
682: -- need to insert po_inerface_errors
683: rcv_error_pkg.set_error_message('RCV_ROI_HEADER_MISSING');
684: rcv_error_pkg.set_token('TXN_TYPE', x_cascaded_table(n).transaction_type);
685: rcv_error_pkg.log_interface_error('HEADER_INTERFACE_ID', FALSE);
686: END IF; --} this is the check for whether header is processed
687:
680: END IF;
681: x_header_record.error_record.error_status := 'E';
682: -- need to insert po_inerface_errors
683: rcv_error_pkg.set_error_message('RCV_ROI_HEADER_MISSING');
684: rcv_error_pkg.set_token('TXN_TYPE', x_cascaded_table(n).transaction_type);
685: rcv_error_pkg.log_interface_error('HEADER_INTERFACE_ID', FALSE);
686: END IF; --} this is the check for whether header is processed
687:
688: asn_debug.put_line('closing the header cursor for txn = ' || TO_CHAR(x_cascaded_table(n).interface_transaction_id));
681: x_header_record.error_record.error_status := 'E';
682: -- need to insert po_inerface_errors
683: rcv_error_pkg.set_error_message('RCV_ROI_HEADER_MISSING');
684: rcv_error_pkg.set_token('TXN_TYPE', x_cascaded_table(n).transaction_type);
685: rcv_error_pkg.log_interface_error('HEADER_INTERFACE_ID', FALSE);
686: END IF; --} this is the check for whether header is processed
687:
688: asn_debug.put_line('closing the header cursor for txn = ' || TO_CHAR(x_cascaded_table(n).interface_transaction_id));
689: CLOSE rcv_roi_preprocessor.headers_cur;
703: x_header_record.header_record.processing_status_code := 'ERROR';
704: x_header_record.error_record.error_status := 'E';
705:
706: /* Bug 4344351: Log a message indicating an error in RCV_HEADERS_INTERFACE table.*/
707: rcv_error_pkg.log_interface_error('RCV_HEADERS_INTERFACE','',FALSE);
708:
709: -- 2) update rti
710: IF (g_asn_debug = 'Y') THEN
711: asn_debug.put_line('update_rti_error after rhi error ');
765: to_char(x_cascaded_table(n).interface_transaction_id) ||', set error_status to E');
766: END IF;
767: x_header_record.error_record.error_status := 'E';
768: -- need to insert po_inerface_errors
769: rcv_error_pkg.set_error_message('RCV_ROI_HEADER_MISSING');
770: rcv_error_pkg.set_token('TXN_TYPE', x_cascaded_table(n).transaction_type);
771: rcv_error_pkg.log_interface_error('HEADER_INTERFACE_ID', FALSE);
772:
773: END IF;
766: END IF;
767: x_header_record.error_record.error_status := 'E';
768: -- need to insert po_inerface_errors
769: rcv_error_pkg.set_error_message('RCV_ROI_HEADER_MISSING');
770: rcv_error_pkg.set_token('TXN_TYPE', x_cascaded_table(n).transaction_type);
771: rcv_error_pkg.log_interface_error('HEADER_INTERFACE_ID', FALSE);
772:
773: END IF;
774: asn_debug.put_line('closing the header cursor for txn = ' || TO_CHAR(x_cascaded_table(n).interface_transaction_id));
767: x_header_record.error_record.error_status := 'E';
768: -- need to insert po_inerface_errors
769: rcv_error_pkg.set_error_message('RCV_ROI_HEADER_MISSING');
770: rcv_error_pkg.set_token('TXN_TYPE', x_cascaded_table(n).transaction_type);
771: rcv_error_pkg.log_interface_error('HEADER_INTERFACE_ID', FALSE);
772:
773: END IF;
774: asn_debug.put_line('closing the header cursor for txn = ' || TO_CHAR(x_cascaded_table(n).interface_transaction_id));
775: CLOSE rcv_roi_preprocessor.headers_cur;
839: -- process the line
840: /* Error out if receipt_source_code is null. We need it
841: * to process rti row.
842: */
843: rcv_error_pkg.test_is_null(x_cascaded_table(n).receipt_source_code,
844: 'RECEIPT_SOURCE_CODE',
845: 'RCV_RECEIPT_SOURCE_CODE_REQ'
846: );
847: process_line(x_cascaded_table,
877:
878: END IF; --}
879:
880: EXCEPTION
881: WHEN rcv_error_pkg.e_fatal_error THEN
882: x_cascaded_table(n).error_status := 'E';
883: x_cascaded_table(n).error_message := rcv_error_pkg.get_last_message;
884: END; --} processing lines
885: -- update the rti row to error
879:
880: EXCEPTION
881: WHEN rcv_error_pkg.e_fatal_error THEN
882: x_cascaded_table(n).error_status := 'E';
883: x_cascaded_table(n).error_message := rcv_error_pkg.get_last_message;
884: END; --} processing lines
885: -- update the rti row to error
886:
887: IF ( x_cascaded_table(n).error_status NOT IN('S', 'W')
893: OR ( x_cascaded_table(n).error_message = 'RCV_REJECT_ASBN_CONSIGNED_PO'
894: OR x_cascaded_table(n).error_message = 'RCV_REJECT_CONSUMPTION_PO'
895: OR x_cascaded_table(n).error_message = 'RCV_REJECT_CONSUMPTION_RELEASE')
896: ) THEN
897: rcv_error_pkg.set_error_message('RCV_ASN_NOT_ACCEPT');
898: rcv_error_pkg.set_token('SHIPMENT', x_header_record.header_record.shipment_num);
899: rcv_error_pkg.log_interface_error('SHIPMENT_NUM', FALSE);
900: END IF;
901: END IF;
894: OR x_cascaded_table(n).error_message = 'RCV_REJECT_CONSUMPTION_PO'
895: OR x_cascaded_table(n).error_message = 'RCV_REJECT_CONSUMPTION_RELEASE')
896: ) THEN
897: rcv_error_pkg.set_error_message('RCV_ASN_NOT_ACCEPT');
898: rcv_error_pkg.set_token('SHIPMENT', x_header_record.header_record.shipment_num);
899: rcv_error_pkg.log_interface_error('SHIPMENT_NUM', FALSE);
900: END IF;
901: END IF;
902:
895: OR x_cascaded_table(n).error_message = 'RCV_REJECT_CONSUMPTION_RELEASE')
896: ) THEN
897: rcv_error_pkg.set_error_message('RCV_ASN_NOT_ACCEPT');
898: rcv_error_pkg.set_token('SHIPMENT', x_header_record.header_record.shipment_num);
899: rcv_error_pkg.log_interface_error('SHIPMENT_NUM', FALSE);
900: END IF;
901: END IF;
902:
903: -- insert the split rti rows back into rti
1262: asn_debug.put_line('Exit preprocessor');
1263: END IF;
1264: EXCEPTION
1265: WHEN NO_DATA_FOUND THEN
1266: rcv_error_pkg.set_sql_error_message('RCV_ROI_PREPROCESSOR.preprocessor','sqlcode');
1267: rcv_error_pkg.log_interface_error('PARENT_SOURCE_TRANSACTION_NUM', FALSE);
1268:
1269: IF rcv_roi_preprocessor.txns_cur%ISOPEN THEN
1270: CLOSE rcv_roi_preprocessor.txns_cur;
1263: END IF;
1264: EXCEPTION
1265: WHEN NO_DATA_FOUND THEN
1266: rcv_error_pkg.set_sql_error_message('RCV_ROI_PREPROCESSOR.preprocessor','sqlcode');
1267: rcv_error_pkg.log_interface_error('PARENT_SOURCE_TRANSACTION_NUM', FALSE);
1268:
1269: IF rcv_roi_preprocessor.txns_cur%ISOPEN THEN
1270: CLOSE rcv_roi_preprocessor.txns_cur;
1271: END IF;
1273: --pjiang, close header cursor explicitly
1274: IF rcv_roi_preprocessor.headers_cur%ISOPEN THEN
1275: CLOSE rcv_roi_preprocessor.headers_cur;
1276: END IF;
1277: WHEN rcv_error_pkg.e_fatal_error THEN --we didn't catch an error that we should have caught
1278: asn_debug.put_line('uncaught e_fatal_error in rcv_roi_preprocess.preprocessor - abnormal execution');
1279: asn_debug.put_line('last error message = ' || rcv_error_pkg.get_last_message);
1280:
1281: rcv_error_pkg.set_sql_error_message('RCV_ROI_PREPROCESSOR.preprocessor','sqlcode'); -- Bug 13093917
1275: CLOSE rcv_roi_preprocessor.headers_cur;
1276: END IF;
1277: WHEN rcv_error_pkg.e_fatal_error THEN --we didn't catch an error that we should have caught
1278: asn_debug.put_line('uncaught e_fatal_error in rcv_roi_preprocess.preprocessor - abnormal execution');
1279: asn_debug.put_line('last error message = ' || rcv_error_pkg.get_last_message);
1280:
1281: rcv_error_pkg.set_sql_error_message('RCV_ROI_PREPROCESSOR.preprocessor','sqlcode'); -- Bug 13093917
1282: rcv_error_pkg.log_interface_error('INTERFACE_TRANSACTION_ID', FALSE); -- Bug 13093917
1283:
1277: WHEN rcv_error_pkg.e_fatal_error THEN --we didn't catch an error that we should have caught
1278: asn_debug.put_line('uncaught e_fatal_error in rcv_roi_preprocess.preprocessor - abnormal execution');
1279: asn_debug.put_line('last error message = ' || rcv_error_pkg.get_last_message);
1280:
1281: rcv_error_pkg.set_sql_error_message('RCV_ROI_PREPROCESSOR.preprocessor','sqlcode'); -- Bug 13093917
1282: rcv_error_pkg.log_interface_error('INTERFACE_TRANSACTION_ID', FALSE); -- Bug 13093917
1283:
1284: WHEN OTHERS THEN
1285: IF (g_asn_debug = 'Y') THEN
1278: asn_debug.put_line('uncaught e_fatal_error in rcv_roi_preprocess.preprocessor - abnormal execution');
1279: asn_debug.put_line('last error message = ' || rcv_error_pkg.get_last_message);
1280:
1281: rcv_error_pkg.set_sql_error_message('RCV_ROI_PREPROCESSOR.preprocessor','sqlcode'); -- Bug 13093917
1282: rcv_error_pkg.log_interface_error('INTERFACE_TRANSACTION_ID', FALSE); -- Bug 13093917
1283:
1284: WHEN OTHERS THEN
1285: IF (g_asn_debug = 'Y') THEN
1286: asn_debug.put_line('Exception in preprocessor:');
1289: asn_debug.put_line('l_msg_data: ' || l_msg_data);
1290: asn_debug.put_line('Set rti rows to error for this and call txn complete');
1291: END IF;
1292:
1293: rcv_error_pkg.set_sql_error_message('RCV_ROI_PREPROCESSOR.preprocessor','sqlcode'); -- Bug 13093917
1294: rcv_error_pkg.log_interface_error('INTERFACE_TRANSACTION_ID', FALSE); -- Bug 13093917
1295:
1296: IF rcv_roi_preprocessor.txns_cur%ISOPEN THEN
1297: CLOSE rcv_roi_preprocessor.txns_cur;
1290: asn_debug.put_line('Set rti rows to error for this and call txn complete');
1291: END IF;
1292:
1293: rcv_error_pkg.set_sql_error_message('RCV_ROI_PREPROCESSOR.preprocessor','sqlcode'); -- Bug 13093917
1294: rcv_error_pkg.log_interface_error('INTERFACE_TRANSACTION_ID', FALSE); -- Bug 13093917
1295:
1296: IF rcv_roi_preprocessor.txns_cur%ISOPEN THEN
1297: CLOSE rcv_roi_preprocessor.txns_cur;
1298: END IF;
1558: RETURN;
1559: END IF;
1560:
1561: --mandatory matching values
1562: rcv_error_pkg.default_and_check(x_parent_row.shipment_header_id,
1563: x_cascaded_table(n).shipment_header_id,
1564: 'SHIPMENT_HEADER_ID'
1565: );
1566: rcv_error_pkg.default_and_check(x_parent_row.shipment_line_id,
1562: rcv_error_pkg.default_and_check(x_parent_row.shipment_header_id,
1563: x_cascaded_table(n).shipment_header_id,
1564: 'SHIPMENT_HEADER_ID'
1565: );
1566: rcv_error_pkg.default_and_check(x_parent_row.shipment_line_id,
1567: x_cascaded_table(n).shipment_line_id,
1568: 'SHIPMENT_LINE_ID'
1569: );
1570: rcv_error_pkg.default_and_check(x_parent_row.source_document_code,
1566: rcv_error_pkg.default_and_check(x_parent_row.shipment_line_id,
1567: x_cascaded_table(n).shipment_line_id,
1568: 'SHIPMENT_LINE_ID'
1569: );
1570: rcv_error_pkg.default_and_check(x_parent_row.source_document_code,
1571: x_cascaded_table(n).source_document_code,
1572: 'SOURCE_DOCUMENT_CODE'
1573: );
1574: rcv_error_pkg.default_and_check(x_parent_row.po_header_id,
1570: rcv_error_pkg.default_and_check(x_parent_row.source_document_code,
1571: x_cascaded_table(n).source_document_code,
1572: 'SOURCE_DOCUMENT_CODE'
1573: );
1574: rcv_error_pkg.default_and_check(x_parent_row.po_header_id,
1575: x_cascaded_table(n).po_header_id,
1576: 'PO_HEADER_ID'
1577: );
1578: rcv_error_pkg.default_and_check(x_parent_row.po_release_id,
1574: rcv_error_pkg.default_and_check(x_parent_row.po_header_id,
1575: x_cascaded_table(n).po_header_id,
1576: 'PO_HEADER_ID'
1577: );
1578: rcv_error_pkg.default_and_check(x_parent_row.po_release_id,
1579: x_cascaded_table(n).po_release_id,
1580: 'PO_RELEASE_ID'
1581: );
1582: rcv_error_pkg.default_and_check(x_parent_row.po_line_id,
1578: rcv_error_pkg.default_and_check(x_parent_row.po_release_id,
1579: x_cascaded_table(n).po_release_id,
1580: 'PO_RELEASE_ID'
1581: );
1582: rcv_error_pkg.default_and_check(x_parent_row.po_line_id,
1583: x_cascaded_table(n).po_line_id,
1584: 'PO_LINE_ID'
1585: );
1586: rcv_error_pkg.default_and_check(x_parent_row.po_line_location_id,
1582: rcv_error_pkg.default_and_check(x_parent_row.po_line_id,
1583: x_cascaded_table(n).po_line_id,
1584: 'PO_LINE_ID'
1585: );
1586: rcv_error_pkg.default_and_check(x_parent_row.po_line_location_id,
1587: x_cascaded_table(n).po_line_location_id,
1588: 'PO_LINE_LOCATION_ID'
1589: );
1590: rcv_error_pkg.default_and_check(x_parent_row.po_distribution_id,
1586: rcv_error_pkg.default_and_check(x_parent_row.po_line_location_id,
1587: x_cascaded_table(n).po_line_location_id,
1588: 'PO_LINE_LOCATION_ID'
1589: );
1590: rcv_error_pkg.default_and_check(x_parent_row.po_distribution_id,
1591: x_cascaded_table(n).po_distribution_id,
1592: 'PO_DISTRIBUTION_ID'
1593: );
1594: rcv_error_pkg.default_and_check(x_parent_row.po_revision_num,
1590: rcv_error_pkg.default_and_check(x_parent_row.po_distribution_id,
1591: x_cascaded_table(n).po_distribution_id,
1592: 'PO_DISTRIBUTION_ID'
1593: );
1594: rcv_error_pkg.default_and_check(x_parent_row.po_revision_num,
1595: x_cascaded_table(n).po_revision_num,
1596: 'PO_REVISION_NUM'
1597: );
1598: rcv_error_pkg.default_and_check(x_parent_row.requisition_line_id,
1594: rcv_error_pkg.default_and_check(x_parent_row.po_revision_num,
1595: x_cascaded_table(n).po_revision_num,
1596: 'PO_REVISION_NUM'
1597: );
1598: rcv_error_pkg.default_and_check(x_parent_row.requisition_line_id,
1599: x_cascaded_table(n).requisition_line_id,
1600: 'REQUISITION_LINE_ID'
1601: );
1602: rcv_error_pkg.default_and_check(x_parent_row.po_unit_price,
1598: rcv_error_pkg.default_and_check(x_parent_row.requisition_line_id,
1599: x_cascaded_table(n).requisition_line_id,
1600: 'REQUISITION_LINE_ID'
1601: );
1602: rcv_error_pkg.default_and_check(x_parent_row.po_unit_price,
1603: x_cascaded_table(n).po_unit_price,
1604: 'PO_UNIT_PRICE'
1605: );
1606: rcv_error_pkg.default_and_check(x_parent_row.currency_code,
1602: rcv_error_pkg.default_and_check(x_parent_row.po_unit_price,
1603: x_cascaded_table(n).po_unit_price,
1604: 'PO_UNIT_PRICE'
1605: );
1606: rcv_error_pkg.default_and_check(x_parent_row.currency_code,
1607: x_cascaded_table(n).currency_code,
1608: 'CURRENCY_CODE'
1609: );
1610: rcv_error_pkg.default_and_check(x_parent_row.currency_conversion_type,
1606: rcv_error_pkg.default_and_check(x_parent_row.currency_code,
1607: x_cascaded_table(n).currency_code,
1608: 'CURRENCY_CODE'
1609: );
1610: rcv_error_pkg.default_and_check(x_parent_row.currency_conversion_type,
1611: x_cascaded_table(n).currency_conversion_type,
1612: 'CURRENCY_CONVERSION_TYPE'
1613: );
1614: rcv_error_pkg.default_and_check(x_parent_row.vendor_id,
1610: rcv_error_pkg.default_and_check(x_parent_row.currency_conversion_type,
1611: x_cascaded_table(n).currency_conversion_type,
1612: 'CURRENCY_CONVERSION_TYPE'
1613: );
1614: rcv_error_pkg.default_and_check(x_parent_row.vendor_id,
1615: x_cascaded_table(n).vendor_id,
1616: 'VENDOR_ID'
1617: );
1618: rcv_error_pkg.default_and_check(x_parent_row.vendor_site_id,
1614: rcv_error_pkg.default_and_check(x_parent_row.vendor_id,
1615: x_cascaded_table(n).vendor_id,
1616: 'VENDOR_ID'
1617: );
1618: rcv_error_pkg.default_and_check(x_parent_row.vendor_site_id,
1619: x_cascaded_table(n).vendor_site_id,
1620: 'VENDOR_SITE_ID'
1621: );
1622: rcv_error_pkg.default_and_check(x_parent_row.source_doc_unit_of_measure,
1618: rcv_error_pkg.default_and_check(x_parent_row.vendor_site_id,
1619: x_cascaded_table(n).vendor_site_id,
1620: 'VENDOR_SITE_ID'
1621: );
1622: rcv_error_pkg.default_and_check(x_parent_row.source_doc_unit_of_measure,
1623: x_cascaded_table(n).source_doc_unit_of_measure,
1624: 'SOURCE_DOC_UNIT_OF_MEASURE'
1625: );
1626: rcv_error_pkg.default_and_check(x_parent_row.oe_order_header_id,
1622: rcv_error_pkg.default_and_check(x_parent_row.source_doc_unit_of_measure,
1623: x_cascaded_table(n).source_doc_unit_of_measure,
1624: 'SOURCE_DOC_UNIT_OF_MEASURE'
1625: );
1626: rcv_error_pkg.default_and_check(x_parent_row.oe_order_header_id,
1627: x_cascaded_table(n).oe_order_header_id,
1628: 'OE_ORDER_HEADER_ID'
1629: );
1630: rcv_error_pkg.default_and_check(x_parent_row.oe_order_line_id,
1626: rcv_error_pkg.default_and_check(x_parent_row.oe_order_header_id,
1627: x_cascaded_table(n).oe_order_header_id,
1628: 'OE_ORDER_HEADER_ID'
1629: );
1630: rcv_error_pkg.default_and_check(x_parent_row.oe_order_line_id,
1631: x_cascaded_table(n).oe_order_line_id,
1632: 'OE_ORDER_LINE_ID'
1633: );
1634: rcv_error_pkg.default_and_check(x_parent_row.customer_id,
1630: rcv_error_pkg.default_and_check(x_parent_row.oe_order_line_id,
1631: x_cascaded_table(n).oe_order_line_id,
1632: 'OE_ORDER_LINE_ID'
1633: );
1634: rcv_error_pkg.default_and_check(x_parent_row.customer_id,
1635: x_cascaded_table(n).customer_id,
1636: 'CUSTOMER_ID'
1637: );
1638: rcv_error_pkg.default_and_check(x_parent_row.customer_site_id,
1634: rcv_error_pkg.default_and_check(x_parent_row.customer_id,
1635: x_cascaded_table(n).customer_id,
1636: 'CUSTOMER_ID'
1637: );
1638: rcv_error_pkg.default_and_check(x_parent_row.customer_site_id,
1639: x_cascaded_table(n).customer_site_id,
1640: 'CUSTOMER_SITE_ID'
1641: );
1642: rcv_error_pkg.default_and_check(x_parent_row.job_id,
1638: rcv_error_pkg.default_and_check(x_parent_row.customer_site_id,
1639: x_cascaded_table(n).customer_site_id,
1640: 'CUSTOMER_SITE_ID'
1641: );
1642: rcv_error_pkg.default_and_check(x_parent_row.job_id,
1643: x_cascaded_table(n).job_id,
1644: 'JOB_ID'
1645: );
1646: rcv_error_pkg.default_and_check(x_parent_row.timecard_id,
1642: rcv_error_pkg.default_and_check(x_parent_row.job_id,
1643: x_cascaded_table(n).job_id,
1644: 'JOB_ID'
1645: );
1646: rcv_error_pkg.default_and_check(x_parent_row.timecard_id,
1647: x_cascaded_table(n).timecard_id,
1648: 'TIMECARD_ID'
1649: );
1650: /* For bug 7112839, no need to do this check.
1647: x_cascaded_table(n).timecard_id,
1648: 'TIMECARD_ID'
1649: );
1650: /* For bug 7112839, no need to do this check.
1651: * rcv_error_pkg.default_and_check(x_parent_row.timecard_ovn,
1652: * x_cascaded_table(n).timecard_ovn,
1653: * 'TIMECARD_OVN'
1654: * );
1655: */
1652: * x_cascaded_table(n).timecard_ovn,
1653: * 'TIMECARD_OVN'
1654: * );
1655: */
1656: rcv_error_pkg.default_and_check(x_parent_row.project_id,
1657: x_cascaded_table(n).project_id,
1658: 'PROJECT_ID'
1659: );
1660: rcv_error_pkg.default_and_check(x_parent_row.task_id,
1656: rcv_error_pkg.default_and_check(x_parent_row.project_id,
1657: x_cascaded_table(n).project_id,
1658: 'PROJECT_ID'
1659: );
1660: rcv_error_pkg.default_and_check(x_parent_row.task_id,
1661: x_cascaded_table(n).task_id,
1662: 'TASK_ID'
1663: );
1664: rcv_error_pkg.default_and_check(x_parent_row.category_id,
1660: rcv_error_pkg.default_and_check(x_parent_row.task_id,
1661: x_cascaded_table(n).task_id,
1662: 'TASK_ID'
1663: );
1664: rcv_error_pkg.default_and_check(x_parent_row.category_id,
1665: x_cascaded_table(n).category_id,
1666: 'CATEGORY_ID'
1667: );
1668: --Bug 9308272 No need to validate for Item description
1665: x_cascaded_table(n).category_id,
1666: 'CATEGORY_ID'
1667: );
1668: --Bug 9308272 No need to validate for Item description
1669: /*rcv_error_pkg.default_and_check(x_parent_row.item_description,
1670: x_cascaded_table(n).item_description,
1671: 'ITEM_DESCRIPTION'
1672: );*/
1673: rcv_error_pkg.default_and_check(x_parent_row.item_id,
1669: /*rcv_error_pkg.default_and_check(x_parent_row.item_description,
1670: x_cascaded_table(n).item_description,
1671: 'ITEM_DESCRIPTION'
1672: );*/
1673: rcv_error_pkg.default_and_check(x_parent_row.item_id,
1674: x_cascaded_table(n).item_id,
1675: 'ITEM_ID'
1676: );
1677: rcv_error_pkg.default_and_check(x_parent_row.item_revision,
1673: rcv_error_pkg.default_and_check(x_parent_row.item_id,
1674: x_cascaded_table(n).item_id,
1675: 'ITEM_ID'
1676: );
1677: rcv_error_pkg.default_and_check(x_parent_row.item_revision,
1678: x_cascaded_table(n).item_revision,
1679: 'ITEM_REVISION'
1680: );
1681: rcv_error_pkg.default_and_check(x_parent_row.vendor_item_num,
1677: rcv_error_pkg.default_and_check(x_parent_row.item_revision,
1678: x_cascaded_table(n).item_revision,
1679: 'ITEM_REVISION'
1680: );
1681: rcv_error_pkg.default_and_check(x_parent_row.vendor_item_num,
1682: x_cascaded_table(n).vendor_item_num,
1683: 'VENDOR_ITEM_NUM'
1684: );
1685: rcv_error_pkg.default_and_check(x_parent_row.vendor_lot_num,
1681: rcv_error_pkg.default_and_check(x_parent_row.vendor_item_num,
1682: x_cascaded_table(n).vendor_item_num,
1683: 'VENDOR_ITEM_NUM'
1684: );
1685: rcv_error_pkg.default_and_check(x_parent_row.vendor_lot_num,
1686: x_cascaded_table(n).vendor_lot_num,
1687: 'VENDOR_LOT_NUM'
1688: );
1689: rcv_error_pkg.default_and_check(x_parent_row.from_organization_id,
1685: rcv_error_pkg.default_and_check(x_parent_row.vendor_lot_num,
1686: x_cascaded_table(n).vendor_lot_num,
1687: 'VENDOR_LOT_NUM'
1688: );
1689: rcv_error_pkg.default_and_check(x_parent_row.from_organization_id,
1690: x_cascaded_table(n).from_organization_id,
1691: 'FROM_ORGANIZATION_ID'
1692: );
1693: rcv_error_pkg.default_and_check(x_parent_row.to_organization_id,
1689: rcv_error_pkg.default_and_check(x_parent_row.from_organization_id,
1690: x_cascaded_table(n).from_organization_id,
1691: 'FROM_ORGANIZATION_ID'
1692: );
1693: rcv_error_pkg.default_and_check(x_parent_row.to_organization_id,
1694: x_cascaded_table(n).to_organization_id,
1695: 'TO_ORGANIZATION_ID'
1696: );
1697: --defaulting values
1705: default_no_check(x_parent_row.deliver_to_location_id, x_cascaded_table(n).deliver_to_location_id);
1706: default_no_check(x_parent_row.secondary_unit_of_measure, x_cascaded_table(n).secondary_unit_of_measure);
1707: default_no_check(x_parent_row.secondary_uom_code, x_cascaded_table(n).secondary_uom_code);
1708: EXCEPTION
1709: WHEN rcv_error_pkg.e_fatal_error THEN
1710: x_cascaded_table(n).error_status := rcv_error_pkg.g_ret_sts_error;
1711: x_cascaded_table(n).error_message := rcv_error_pkg.get_last_message;
1712: END default_from_parent_trx;
1713:
1706: default_no_check(x_parent_row.secondary_unit_of_measure, x_cascaded_table(n).secondary_unit_of_measure);
1707: default_no_check(x_parent_row.secondary_uom_code, x_cascaded_table(n).secondary_uom_code);
1708: EXCEPTION
1709: WHEN rcv_error_pkg.e_fatal_error THEN
1710: x_cascaded_table(n).error_status := rcv_error_pkg.g_ret_sts_error;
1711: x_cascaded_table(n).error_message := rcv_error_pkg.get_last_message;
1712: END default_from_parent_trx;
1713:
1714: PROCEDURE process_line(
1707: default_no_check(x_parent_row.secondary_uom_code, x_cascaded_table(n).secondary_uom_code);
1708: EXCEPTION
1709: WHEN rcv_error_pkg.e_fatal_error THEN
1710: x_cascaded_table(n).error_status := rcv_error_pkg.g_ret_sts_error;
1711: x_cascaded_table(n).error_message := rcv_error_pkg.get_last_message;
1712: END default_from_parent_trx;
1713:
1714: PROCEDURE process_line(
1715: x_cascaded_table IN OUT NOCOPY rcv_roi_preprocessor.cascaded_trans_tab_type,
1789: v_header_record
1790: );
1791: ELSE
1792: asn_debug.put_line('We do not support transaction type ' || x_cascaded_table(n).transaction_type);
1793: rcv_error_pkg.set_error_message('RCV_INVALID_TRANSACTION_TYPE');
1794: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE');
1795: END IF;
1796: ELSIF(x_cascaded_table(n).receipt_source_code = 'INTERNAL ORDER') THEN
1797: IF (x_cascaded_table(n).transaction_type = 'RECEIVE') THEN
1790: );
1791: ELSE
1792: asn_debug.put_line('We do not support transaction type ' || x_cascaded_table(n).transaction_type);
1793: rcv_error_pkg.set_error_message('RCV_INVALID_TRANSACTION_TYPE');
1794: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE');
1795: END IF;
1796: ELSIF(x_cascaded_table(n).receipt_source_code = 'INTERNAL ORDER') THEN
1797: IF (x_cascaded_table(n).transaction_type = 'RECEIVE') THEN
1798: asn_debug.put_line('calling derive routine for transaction ' || x_cascaded_table(n).transaction_type);
1816: v_header_record
1817: );
1818: ELSE
1819: asn_debug.put_line('We do not support transaction type ' || x_cascaded_table(n).transaction_type);
1820: rcv_error_pkg.set_error_message('RCV_INVALID_TRANSACTION_TYPE');
1821: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE');
1822: END IF; -- IF INTERNAL ORDER
1823: ELSIF(x_cascaded_table(n).receipt_source_code = 'INVENTORY') THEN --} {
1824: IF (x_cascaded_table(n).transaction_type = 'RECEIVE') THEN
1817: );
1818: ELSE
1819: asn_debug.put_line('We do not support transaction type ' || x_cascaded_table(n).transaction_type);
1820: rcv_error_pkg.set_error_message('RCV_INVALID_TRANSACTION_TYPE');
1821: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE');
1822: END IF; -- IF INTERNAL ORDER
1823: ELSIF(x_cascaded_table(n).receipt_source_code = 'INVENTORY') THEN --} {
1824: IF (x_cascaded_table(n).transaction_type = 'RECEIVE') THEN
1825: rcv_int_org_transfer.derive_int_org_rcv_line(x_cascaded_table,
1842: v_header_record
1843: );
1844: ELSE
1845: asn_debug.put_line('We do not support transaction type ' || x_cascaded_table(n).transaction_type);
1846: rcv_error_pkg.set_error_message('RCV_INVALID_TRANSACTION_TYPE');
1847: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE');
1848: END IF;
1849: ELSIF(x_cascaded_table(n).receipt_source_code = 'CUSTOMER') THEN --} {
1850: asn_debug.put_line('calling derive routine for RMA transaction ' || x_cascaded_table(n).transaction_type);
1843: );
1844: ELSE
1845: asn_debug.put_line('We do not support transaction type ' || x_cascaded_table(n).transaction_type);
1846: rcv_error_pkg.set_error_message('RCV_INVALID_TRANSACTION_TYPE');
1847: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE');
1848: END IF;
1849: ELSIF(x_cascaded_table(n).receipt_source_code = 'CUSTOMER') THEN --} {
1850: asn_debug.put_line('calling derive routine for RMA transaction ' || x_cascaded_table(n).transaction_type);
1851:
1874: v_header_record
1875: );
1876: ELSE
1877: asn_debug.put_line('We do not support transaction type ' || x_cascaded_table(n).transaction_type);
1878: rcv_error_pkg.set_error_message('RCV_INVALID_TRANSACTION_TYPE');
1879: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE');
1880: END IF; --}
1881: ELSE --}{
1882: asn_debug.put_line('We do not support receipt_source_code ' || x_cascaded_table(n).receipt_source_code);
1875: );
1876: ELSE
1877: asn_debug.put_line('We do not support transaction type ' || x_cascaded_table(n).transaction_type);
1878: rcv_error_pkg.set_error_message('RCV_INVALID_TRANSACTION_TYPE');
1879: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE');
1880: END IF; --}
1881: ELSE --}{
1882: asn_debug.put_line('We do not support receipt_source_code ' || x_cascaded_table(n).receipt_source_code);
1883: rcv_error_pkg.set_error_message('RCV_INVALID_TRANSACTION_TYPE');
1879: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE');
1880: END IF; --}
1881: ELSE --}{
1882: asn_debug.put_line('We do not support receipt_source_code ' || x_cascaded_table(n).receipt_source_code);
1883: rcv_error_pkg.set_error_message('RCV_INVALID_TRANSACTION_TYPE');
1884: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE');
1885: END IF; --}
1886: END IF;
1887: IF (g_asn_debug = 'Y') THEN
1880: END IF; --}
1881: ELSE --}{
1882: asn_debug.put_line('We do not support receipt_source_code ' || x_cascaded_table(n).receipt_source_code);
1883: rcv_error_pkg.set_error_message('RCV_INVALID_TRANSACTION_TYPE');
1884: rcv_error_pkg.log_interface_error('TRANSACTION_TYPE');
1885: END IF; --}
1886: END IF;
1887: IF (g_asn_debug = 'Y') THEN
1888: asn_debug.put_line('Back from derive routine with ' || TO_CHAR(used_for_cascaded_rows.COUNT) || ' rows');
2136: IF (g_asn_debug = 'Y') THEN
2137: asn_debug.put_line('Exit create shipment line');
2138: END IF;
2139: EXCEPTION
2140: WHEN rcv_error_pkg.e_fatal_error THEN
2141: x_cascaded_table(n).error_status := 'E';
2142: x_cascaded_table(n).error_message := rcv_error_pkg.get_last_message;
2143: WHEN OTHERS THEN
2144: IF (g_asn_debug = 'Y') THEN
2138: END IF;
2139: EXCEPTION
2140: WHEN rcv_error_pkg.e_fatal_error THEN
2141: x_cascaded_table(n).error_status := 'E';
2142: x_cascaded_table(n).error_message := rcv_error_pkg.get_last_message;
2143: WHEN OTHERS THEN
2144: IF (g_asn_debug = 'Y') THEN
2145: asn_debug.put_line('Exception in process_line');
2146: END IF;
2160: p_interface_id => x_interface_txn_id,
2161: p_header_interface_id => NULL,
2162: p_lpn_group_id => x_lpn_group_id
2163: );
2164: rcv_error_pkg.set_error_message('RCV_LPN_EXPLOSION_FAILED');
2165: rcv_error_pkg.set_token('LPN_GROUP_ID', x_lpn_group_id);
2166: rcv_error_pkg.log_interface_warning('LPN_GROUP_ID');
2167: EXCEPTION
2168: WHEN OTHERS THEN
2161: p_header_interface_id => NULL,
2162: p_lpn_group_id => x_lpn_group_id
2163: );
2164: rcv_error_pkg.set_error_message('RCV_LPN_EXPLOSION_FAILED');
2165: rcv_error_pkg.set_token('LPN_GROUP_ID', x_lpn_group_id);
2166: rcv_error_pkg.log_interface_warning('LPN_GROUP_ID');
2167: EXCEPTION
2168: WHEN OTHERS THEN
2169: IF (g_asn_debug = 'Y') THEN
2162: p_lpn_group_id => x_lpn_group_id
2163: );
2164: rcv_error_pkg.set_error_message('RCV_LPN_EXPLOSION_FAILED');
2165: rcv_error_pkg.set_token('LPN_GROUP_ID', x_lpn_group_id);
2166: rcv_error_pkg.log_interface_warning('LPN_GROUP_ID');
2167: EXCEPTION
2168: WHEN OTHERS THEN
2169: IF (g_asn_debug = 'Y') THEN
2170: asn_debug.put_line('Exception in explode_lpn_failed');
2192: asn_debug.put_line('p_lpn_group_id ' || p_lpn_group_id);
2193: END IF;
2194:
2195: -- bug 3676436, if there is a pending error message than we log it
2196: rcv_error_pkg.log_interface_error('INTERFACE_TRANSACTION_ID',FALSE);
2197:
2198: IF (p_header_interface_id IS NOT NULL) THEN
2199: SELECT DISTINCT (processing_mode_code)
2200: INTO l_processing_mode_code