161: l_bundle_id := c_bls.bundle.extract('/ItemBundle/BundleId/text()').getNumberVal();
162: l_source_system_id := c_bls.bundle.extract('/ItemBundle/ItemSourceSystemId/text()').getNumberVal();
163: l_source_system_ref := c_bls.bundle.extract('/ItemBundle/ItemSourceSystemReference/text()').getStringVal();
164:
165: INSERT INTO MTL_ITEM_BULKLOAD_RECS (request_id,
166: creation_date,
167: last_update_date,
168: created_by,
169: last_updated_by,
188: ELSE
189: FOR c_bls IN c_bundles(p_bundles_xml)
190: LOOP
191: l_bundle_id := c_bls.bundle.extract('/Bundle/BundleId/text()').getNumberVal();
192: INSERT INTO MTL_ITEM_BULKLOAD_RECS (request_id,
193: creation_date,
194: last_update_date,
195: created_by,
196: last_updated_by,
231: )IS
232:
233: CURSOR getBundles(p_rcb_id NUMBER )
234: IS SELECT bundle_id
235: FROM MTL_ITEM_BULKLOAD_RECS
236: WHERE bundle_collection_id = p_rcb_id;
237:
238: l_gpc_list VARCHAR2(1000);
239: l_status VARCHAR2(1000);
313: x_BundleWithoutACC OUT NOCOPY NUMBER
314: )IS
315: CURSOR getBundles(p_rcb_id NUMBER ) IS
316: SELECT bundle_id
317: FROM MTL_ITEM_BULKLOAD_RECS
318: WHERE bundle_collection_id = p_rcb_id
319: AND entity_type LIKE 'ITEM';
320:
321: l_gpc_list VARCHAR2(1000);
523: SELECT set_process_id
524: FROM MTL_SYSTEM_ITEMS_INTERFACE
525: WHERE BUNDLE_ID IN
526: (SELECT BUNDLE_ID
527: FROM MTL_ITEM_BULKLOAD_RECS
528: WHERE BUNDLE_COLLECTION_ID = X_BUNDLE_COLLECTION_ID);
529:
530: BEGIN
531: l_collection_id := X_BUNDLE_COLLECTION_ID;
543: FROM EGO_IMPORT_BATCHES_B
544: WHERE BATCH_ID = ISTI.SET_PROCESS_ID)
545: WHERE BUNDLE_ID IN
546: (SELECT BUNDLE_ID
547: FROM MTL_ITEM_BULKLOAD_RECS
548: WHERE BUNDLE_COLLECTION_ID = X_BUNDLE_COLLECTION_ID)
549: AND ITEM_NUMBER IS NULL;
550:
551: UPDATE MTL_SYSTEM_ITEMS_INTERFACE ISTI
556: FROM EGO_IMPORT_BATCHES_B
557: WHERE BATCH_ID = ISTI.SET_PROCESS_ID)
558: WHERE BUNDLE_ID IN
559: (SELECT BUNDLE_ID
560: FROM MTL_ITEM_BULKLOAD_RECS
561: WHERE BUNDLE_COLLECTION_ID = X_BUNDLE_COLLECTION_ID)
562: AND ITEM_NUMBER IS NOT NULL;
563:
564: -- Updating items user attribute rows
569: FROM EGO_IMPORT_BATCHES_B
570: WHERE BATCH_ID = EIUAI.DATA_SET_ID)
571: WHERE BUNDLE_ID IN
572: (SELECT BUNDLE_ID
573: FROM MTL_ITEM_BULKLOAD_RECS
574: WHERE BUNDLE_COLLECTION_ID = X_BUNDLE_COLLECTION_ID);
575:
576: -- Updating items association rows
577: UPDATE EGO_ITEM_ASSOCIATIONS_INTF EIAI
581: FROM EGO_IMPORT_BATCHES_B
582: WHERE BATCH_ID = EIAI.BATCH_ID)
583: WHERE BUNDLE_ID IN
584: (SELECT BUNDLE_ID
585: FROM MTL_ITEM_BULKLOAD_RECS
586: WHERE BUNDLE_COLLECTION_ID = X_BUNDLE_COLLECTION_ID);
587:
588: -- Updating items caetgories rows
589: UPDATE MTL_ITEM_CATEGORIES_INTERFACE MICI
593: FROM EGO_IMPORT_BATCHES_B
594: WHERE BATCH_ID = MICI.SET_PROCESS_ID)
595: WHERE BUNDLE_ID IN
596: (SELECT BUNDLE_ID
597: FROM MTL_ITEM_BULKLOAD_RECS
598: WHERE BUNDLE_COLLECTION_ID = X_BUNDLE_COLLECTION_ID);
599:
600: -- Updating bill header rows
601: UPDATE BOM_BILL_OF_MTLS_INTERFACE BBOMI
602: SET TRANSACTION_TYPE = C_TRANSACTION_SYNC,
603: PROCESS_FLAG = 1
604: WHERE BUNDLE_ID IN
605: (SELECT BUNDLE_ID
606: FROM MTL_ITEM_BULKLOAD_RECS
607: WHERE BUNDLE_COLLECTION_ID = X_BUNDLE_COLLECTION_ID);
608:
609: -- Updating bill components rows
610: UPDATE BOM_INVENTORY_COMPS_INTERFACE BICI
611: SET TRANSACTION_TYPE = C_TRANSACTION_SYNC,
612: PROCESS_FLAG = 1
613: WHERE BUNDLE_ID IN
614: (SELECT BUNDLE_ID
615: FROM MTL_ITEM_BULKLOAD_RECS
616: WHERE BUNDLE_COLLECTION_ID = X_BUNDLE_COLLECTION_ID);
617:
618: -- Updating translatable rows
619: UPDATE EGO_INTERFACE_TL
619: UPDATE EGO_INTERFACE_TL
620: SET PROCESS_STATUS = 1
621: WHERE BUNDLE_ID IN
622: (SELECT BUNDLE_ID
623: FROM MTL_ITEM_BULKLOAD_RECS
624: WHERE BUNDLE_COLLECTION_ID = X_BUNDLE_COLLECTION_ID);
625:
626:
627: UPDATE EGO_UCCNET_EVENTS EUE
629: FROM EGO_IMPORT_BATCHES_B
630: WHERE BATCH_ID = EUE.import_batch_id)
631: WHERE CLN_ID IN
632: (SELECT BUNDLE_ID
633: FROM MTL_ITEM_BULKLOAD_RECS
634: WHERE BUNDLE_COLLECTION_ID = X_BUNDLE_COLLECTION_ID);
635:
636:
637: FOR batches IN bundles
651: AND msii.BUNDLE_ID = BBOMI.BUNDLE_ID
652: AND ROWNUM = 1)
653: WHERE BUNDLE_ID IN
654: (SELECT BUNDLE_ID
655: FROM MTL_ITEM_BULKLOAD_RECS
656: WHERE BUNDLE_COLLECTION_ID = X_BUNDLE_COLLECTION_ID);
657:
658: UPDATE BOM_INVENTORY_COMPS_INTERFACE BICI
659: SET ORGANIZATION_ID = (SELECT ORGANIZATION_ID
667: AND msii.BUNDLE_ID = BICI.BUNDLE_ID
668: AND ROWNUM = 1)
669: WHERE BUNDLE_ID IN
670: (SELECT BUNDLE_ID
671: FROM MTL_ITEM_BULKLOAD_RECS
672: WHERE BUNDLE_COLLECTION_ID = X_BUNDLE_COLLECTION_ID);
673:
674: UPDATE EGO_ITM_USR_ATTR_INTRFC EIUAI
675: SET pk2_value = (SELECT asa.VENDOR_SITE_ID
685: WHERE data_level_name = 'ITEM_SUP_SITE'
686: AND pk2_value IS NOT NULL
687: AND BUNDLE_ID IN
688: (SELECT BUNDLE_ID
689: FROM MTL_ITEM_BULKLOAD_RECS
690: WHERE BUNDLE_COLLECTION_ID = X_BUNDLE_COLLECTION_ID);
691:
692: UPDATE EGO_ITEM_ASSOCIATIONS_INTF EIAI
693: SET pk2_value = (SELECT asa.VENDOR_SITE_ID
703: WHERE data_level_name = 'ITEM_SUP_SITE'
704: AND pk2_value IS NOT NULL
705: AND BUNDLE_ID IN
706: (SELECT BUNDLE_ID
707: FROM MTL_ITEM_BULKLOAD_RECS
708: WHERE BUNDLE_COLLECTION_ID = X_BUNDLE_COLLECTION_ID);
709:
710: UPDATE EGO_ITM_USR_ATTR_INTRFC EIUAI
711: SET pk2_value = (SELECT asa.VENDOR_SITE_ID
721: WHERE data_level_name = 'ITEM_SUP_SITE_ORG'
722: AND pk2_value IS NOT NULL
723: AND BUNDLE_ID IN
724: (SELECT BUNDLE_ID
725: FROM MTL_ITEM_BULKLOAD_RECS
726: WHERE BUNDLE_COLLECTION_ID = X_BUNDLE_COLLECTION_ID);
727:
728: UPDATE EGO_ITEM_ASSOCIATIONS_INTF EIAI
729: SET pk2_value = (SELECT asa.VENDOR_SITE_ID
739: WHERE data_level_name = 'ITEM_SUP_SITE_ORG'
740: AND pk2_value IS NOT NULL
741: AND BUNDLE_ID IN
742: (SELECT BUNDLE_ID
743: FROM MTL_ITEM_BULKLOAD_RECS
744: WHERE BUNDLE_COLLECTION_ID = X_BUNDLE_COLLECTION_ID);
745:
746: RETURN l_collection_id;
747: EXCEPTION
765: XMLELEMENT("Bundles",
766: XMLAGG(XMLELEMENT("Bundle",
767: XMLELEMENT("BundleId", bundle_id)))))) XML_DOC
768: INTO l_xml_doc
769: FROM MTL_ITEM_BULKLOAD_RECS
770: WHERE bundle_collection_id = p_bundle_collection_id
771: AND bundle_id > Nvl(p_prior_bundle_id, 0)
772: AND ROWNUM < p_max_elements
773: GROUP BY bundle_collection_id;