DBA Data[Home] [Help]

APPS.BOM_BULKLOAD_PVT_PKG dependencies on EGO_BULKLOAD_INTF

Line 68: * EGO_BULKLOAD_INTF prior to running all the heavy dbms_sqls.

64: TYPE RD_VARCHAR_TBL_TYPE IS TABLE OF VARCHAR2(30) INDEX BY BINARY_INTEGER;
65: G_MISS_RD_VARCHAR_TBL RD_VARCHAR_TBL_TYPE;
66:
67: /* Function that checks if there are any rows to be processed in the
68: * EGO_BULKLOAD_INTF prior to running all the heavy dbms_sqls.
69: * This will give a performance boost if the users are loading data
70: * through the same batch_id
71: */
72: FUNCTION Interface_Rows_Exist

Line 82: EGO_BULKLOAD_INTF E

78: begin
79: SELECT
80: COUNT(RESULTFMT_USAGE_ID) into l_unprocessed_rowcount
81: FROM
82: EGO_BULKLOAD_INTF E
83: where
84: E.RESULTFMT_USAGE_ID = p_resultfmt_usage_id
85: and E.PROCESS_STATUS = 1;
86: IF (l_unprocessed_rowcount > 0) then

Line 261: UPDATE EGO_BULKLOAD_INTF EBI

257:
258: BEGIN
259:
260: -- Update process flag in Ego Bulkload interface table
261: UPDATE EGO_BULKLOAD_INTF EBI
262: SET EBI.PROCESS_STATUS =
263: (
264: SELECT BMI.PROCESS_FLAG
265: FROM BOM_BILL_OF_MTLS_INTERFACE BMI

Line 277: UPDATE EGO_BULKLOAD_INTF EBI

273: )
274: AND EBI.RESULTFMT_USAGE_ID = p_resultfmt_usage_id;
275:
276:
277: UPDATE EGO_BULKLOAD_INTF EBI
278: SET EBI.PROCESS_STATUS =
279: (
280: SELECT BICI.PROCESS_FLAG
281: FROM BOM_INVENTORY_COMPS_INTERFACE BICI

Line 774: DELETE FROM EGO_BULKLOAD_INTF

770: Error_Handler.initialize();
771: Error_Handler.set_bo_identifier(G_BO_IDENTIFIER);
772: -- Delete all the earlier uploads from the same spreadsheet.
773: /*
774: DELETE FROM EGO_BULKLOAD_INTF
775: WHERE RESULTFMT_USAGE_ID = p_resultfmt_usage_id
776: AND PROCESS_STATUS <> 1;
777: */
778:

Line 844: l_dyn_sql := l_dyn_sql || ' UPDATE EGO_BULKLOAD_INTF SET '||G_INTF_COMP_SEQ_ID||' = NULL ';

840:
841: --bug 13829520 begin
842: IF (G_INTF_COMP_SEQ_ID IS NOT NULL AND G_INTF_COMP_SEQ_ID <> 'NULL') THEN
843: l_dyn_sql := '';
844: l_dyn_sql := l_dyn_sql || ' UPDATE EGO_BULKLOAD_INTF SET '||G_INTF_COMP_SEQ_ID||' = NULL ';
845: l_dyn_sql := l_dyn_sql || ' WHERE Resultfmt_Usage_Id = :RESULTFMT_USAGE_ID ';
846: l_dyn_sql := l_dyn_sql || ' AND PROCESS_STATUS = 1 ';
847: l_dyn_sql := l_dyn_sql || ' AND UPPER(TRANSACTION_TYPE) IN (''ADD'',''CREATE'') ';
848:

Line 864: UPDATE EGO_BULKLOAD_INTF

860: Write_Debug('G_INTF_REF_DESIG after :--->' || G_INTF_REF_DESIG);
861: --Populate the Transaction IDs for current result fmt usage ID
862: --New Transaction ID. It will be replaced by old Transaction ID Seq.
863: --SET transaction_id = MSII_TRANSACTION_ID_S.NEXTVAL
864: UPDATE EGO_BULKLOAD_INTF
865: SET Transaction_Id = MTL_SYSTEM_ITEMS_INTERFACE_S.NEXTVAL
866: WHERE Resultfmt_Usage_Id = p_Resultfmt_Usage_Id AND PROCESS_STATUS = 1 ;
867:
868: IF l_debug = 'Y' THEN

Line 924: l_dyn_sql := 'UPDATE EGO_BULKLOAD_INTF EBI';

920: -----------------------------------------------------
921: -- Update Instance PK2 Value with ORG ID.
922: -----------------------------------------------------
923: l_dyn_sql := '';
924: l_dyn_sql := 'UPDATE EGO_BULKLOAD_INTF EBI';
925: l_dyn_sql := l_dyn_sql || ' SET INSTANCE_PK2_VALUE = ';
926: l_dyn_sql := l_dyn_sql || ' ( ';
927: l_dyn_sql := l_dyn_sql || ' SELECT ORGANIZATION_ID ';
928: l_dyn_sql := l_dyn_sql || ' FROM MTL_PARAMETERS ';

Line 942: l_dyn_sql := 'UPDATE EGO_BULKLOAD_INTF EBI';

938: -----------------------------------------------------
939: -- Update Instance PK1 Value with Component Item ID
940: -----------------------------------------------------
941: l_dyn_sql := '';
942: l_dyn_sql := 'UPDATE EGO_BULKLOAD_INTF EBI';
943: l_dyn_sql := l_dyn_sql || ' SET INSTANCE_PK1_VALUE = ';
944: l_dyn_sql := l_dyn_sql || ' ( ';
945: l_dyn_sql := l_dyn_sql || ' SELECT inventory_item_id ';
946: l_dyn_sql := l_dyn_sql || ' FROM mtl_system_items_vl mvll ';

Line 961: l_dyn_sql := 'UPDATE EGO_BULKLOAD_INTF EBI';

957: -----------------------------------------------------
958: -- Populate Assembly Item ID
959: -----------------------------------------------------
960: l_dyn_sql := '';
961: l_dyn_sql := 'UPDATE EGO_BULKLOAD_INTF EBI';
962: l_dyn_sql := l_dyn_sql || ' SET ' || G_ASSEMBLY_ITEM_ID || ' = ';
963: l_dyn_sql := l_dyn_sql || ' ( ';
964: l_dyn_sql := l_dyn_sql || ' SELECT inventory_item_id ';
965: l_dyn_sql := l_dyn_sql || ' FROM mtl_system_items_vl mvll ';

Line 980: l_dyn_sql := 'UPDATE EGO_BULKLOAD_INTF EBI';

976: -----------------------------------------------------
977: -- Populate BillSequenceId to Instance PK4
978: -----------------------------------------------------
979: l_dyn_sql := '';
980: l_dyn_sql := 'UPDATE EGO_BULKLOAD_INTF EBI';
981: l_dyn_sql := l_dyn_sql || ' SET INSTANCE_PK4_VALUE = ';
982: l_dyn_sql := l_dyn_sql || ' ( ';
983: l_dyn_sql := l_dyn_sql || ' SELECT bill_sequence_id ';
984: l_dyn_sql := l_dyn_sql || ' FROM bom_structures_b bsb, mtl_system_items_vl mvll ';

Line 1003: l_dyn_sql := 'UPDATE EGO_BULKLOAD_INTF EBI SET';

999: -- Resolve user time zone conversions
1000: fnd_date_tz.init_timezones_for_fnd_date;
1001: IF (l_eff_date_col_name IS NOT NULL OR l_dis_date_col_name IS NOT NULL OR l_imp_date_col_name IS NOT NULL) THEN
1002: l_dyn_sql := '';
1003: l_dyn_sql := 'UPDATE EGO_BULKLOAD_INTF EBI SET';
1004: IF l_eff_date_col_name IS NOT NULL THEN
1005: l_dyn_sql := l_dyn_sql || ' EBI.'|| l_eff_date_col_name;
1006: l_dyn_sql := l_dyn_sql || ' = decode(EBI.'|| l_eff_date_col_name || ', NULL, NULL,';
1007: l_dyn_sql := l_dyn_sql || ' to_char(BOM_BULKLOAD_PVT_PKG.displayDT_to_date(EBI.' || l_eff_date_col_name;

Line 1046: l_dyn_sql := 'UPDATE EGO_BULKLOAD_INTF EBI';

1042: -- Populate ComponentSequenceId to Instance PK5
1043: -----------------------------------------------------
1044: IF l_eff_date_col_name IS NOT NULL AND l_oper_seq_col_name IS NOT NULL AND l_oper_seq_col_name <> '' AND l_eff_date_col_name <> '' THEN
1045: l_dyn_sql := '';
1046: l_dyn_sql := 'UPDATE EGO_BULKLOAD_INTF EBI';
1047: l_dyn_sql := l_dyn_sql || ' SET INSTANCE_PK5_VALUE = ';
1048: l_dyn_sql := l_dyn_sql || ' ( ';
1049: l_dyn_sql := l_dyn_sql || ' SELECT COMPONENT_SEQUENCE_ID ';
1050: l_dyn_sql := l_dyn_sql || ' FROM bom_components_b BCB ';

Line 1091: l_dyn_sql_select := l_dyn_sql_select || ' FROM EGO_BULKLOAD_INTF WHERE RESULTFMT_USAGE_ID = :4 ';

1087: l_dyn_sql_select := l_dyn_sql_select || ' , (SELECT Lookup_Code FROM Fnd_Lookup_Values WHERE Lookup_Type = ''BOM_EFFECTIVITY_CONTROL'' AND LANGUAGE=USERENV(''LANG'') AND Meaning=' || G_INTF_EFFEC_CONTROL || ')';
1088: l_dyn_sql_select := l_dyn_sql_select || ' , (SELECT Lookup_Code FROM Fnd_Lookup_Values WHERE Lookup_Type = ''EGO_YES_NO'' AND LANGUAGE=USERENV(''LANG'') AND Meaning = ' || G_INTF_IS_PREFERRED || ')';
1089: l_dyn_sql_select := l_dyn_sql_select || ' , (SELECT Lookup_Code FROM Mfg_Lookups WHERE Lookup_Type = ''BOM_ASSEMBLY_TYPE'' AND Meaning=' || G_INTF_ASSEMBLY_TYPE || ')';
1090: l_dyn_sql_select := l_dyn_sql_select || ' , ' || G_INTF_REVISION || ' ';
1091: l_dyn_sql_select := l_dyn_sql_select || ' FROM EGO_BULKLOAD_INTF WHERE RESULTFMT_USAGE_ID = :4 ';
1092: --Sreejith
1093: if (p_is_pdh_batch = 'Y') then
1094: l_dyn_sql_select := l_dyn_sql_select || ' AND PROCESS_STATUS = 1 AND ' || l_parent_column || ' IS NULL ';
1095: else

Line 1130: l_dyn_sql_cursor := l_dyn_sql_cursor || ' FROM EGO_BULKLOAD_INTF WHERE Process_Status = 1';

1126: l_dyn_sql_cursor := l_dyn_sql_cursor || ' , ' || G_INTF_IS_PREFERRED;
1127: l_dyn_sql_cursor := l_dyn_sql_cursor || ' , ' || G_INTF_ASSEMBLY_TYPE;
1128: l_dyn_sql_cursor := l_dyn_sql_cursor || ' , ' || G_INTF_PARENT_REVISION;
1129: l_dyn_sql_cursor := l_dyn_sql_cursor || ' , Transaction_Id ';
1130: l_dyn_sql_cursor := l_dyn_sql_cursor || ' FROM EGO_BULKLOAD_INTF WHERE Process_Status = 1';
1131: l_dyn_sql_cursor := l_dyn_sql_cursor || ' AND Resultfmt_Usage_Id = :4 ';
1132: if (p_is_pdh_batch = 'Y') then
1133: l_dyn_sql_cursor := l_dyn_sql_cursor || ' AND ' || l_parent_column || ' IS NOT NULL ';
1134: else

Line 1400: l_dyn_sql_select := l_dyn_sql_select || ' FROM EGO_BULKLOAD_INTF ';

1396:
1397: l_dyn_sql_insert := SUBSTR(l_dyn_sql_insert,0,LENGTH(l_dyn_sql_insert) - 1);
1398: l_dyn_sql_select := SUBSTR(l_dyn_sql_select,0,LENGTH(l_dyn_sql_select) - 1);
1399: l_dyn_sql_insert := l_dyn_sql_insert || ' ) ';
1400: l_dyn_sql_select := l_dyn_sql_select || ' FROM EGO_BULKLOAD_INTF ';
1401: l_dyn_sql_select := l_dyn_sql_select || ' WHERE RESULTFMT_USAGE_ID = :3 ';
1402: l_dyn_sql_select := l_dyn_sql_select || ' AND PROCESS_STATUS = 1 AND ';
1403:
1404: if (p_is_pdh_batch = 'Y') then

Line 1481: l_dyn_sql_select := l_dyn_sql_select || ' FROM EGO_BULKLOAD_INTF ';

1477:
1478: l_dyn_sql_insert := SUBSTR(l_dyn_sql_insert,0,LENGTH(l_dyn_sql_insert) - 1);
1479: l_dyn_sql_select := SUBSTR(l_dyn_sql_select,0,LENGTH(l_dyn_sql_select) - 1);
1480: l_dyn_sql_insert := l_dyn_sql_insert || ' ) ';
1481: l_dyn_sql_select := l_dyn_sql_select || ' FROM EGO_BULKLOAD_INTF ';
1482: l_dyn_sql_select := l_dyn_sql_select || ' WHERE RESULTFMT_USAGE_ID = :3 ';
1483: l_dyn_sql_select := l_dyn_sql_select || ' AND PROCESS_STATUS = 1 AND ';
1484: -- Sreejith
1485: if (p_is_pdh_batch = 'Y') then

Line 1552: l_dyn_sql_select := l_dyn_sql_select || ' FROM EGO_BULKLOAD_INTF ';

1548:
1549: l_dyn_sql_insert := SUBSTR(l_dyn_sql_insert,0,LENGTH(l_dyn_sql_insert) - 1);
1550: l_dyn_sql_select := SUBSTR(l_dyn_sql_select,0,LENGTH(l_dyn_sql_select) - 1);
1551: l_dyn_sql_insert := l_dyn_sql_insert || ' ) ';
1552: l_dyn_sql_select := l_dyn_sql_select || ' FROM EGO_BULKLOAD_INTF ';
1553: l_dyn_sql_select := l_dyn_sql_select || ' WHERE RESULTFMT_USAGE_ID = :3 ';
1554: l_dyn_sql_select := l_dyn_sql_select || ' AND PROCESS_STATUS = 1 AND ';
1555: -- Sreejith
1556: if (p_is_pdh_batch = 'Y') then

Line 1630: --Setting the transaction_id in the ego_bulkload_intf to be the same for multi row comp attr

1626: WHERE REQUEST_ID = G_REQUEST_ID AND PROCESS_FLAG = 1
1627: AND Transaction_Id IS NULL;
1628:
1629:
1630: --Setting the transaction_id in the ego_bulkload_intf to be the same for multi row comp attr
1631:
1632: IF l_eff_date_col_name IS NOT NULL AND l_oper_seq_col_name IS NOT NULL AND l_item_seq_col_name IS NOT NULL THEN
1633:
1634: l_upd_sql := ' UPDATE EGO_BULKLOAD_INTF EBI1 ' ||

Line 1634: l_upd_sql := ' UPDATE EGO_BULKLOAD_INTF EBI1 ' ||

1630: --Setting the transaction_id in the ego_bulkload_intf to be the same for multi row comp attr
1631:
1632: IF l_eff_date_col_name IS NOT NULL AND l_oper_seq_col_name IS NOT NULL AND l_item_seq_col_name IS NOT NULL THEN
1633:
1634: l_upd_sql := ' UPDATE EGO_BULKLOAD_INTF EBI1 ' ||
1635: ' SET EBI1.transaction_id = ( SELECT EBI2.transaction_id ' ||
1636: ' FROM EGO_BULKLOAD_INTF EBI2 ' ||
1637: ' WHERE EBI2.resultfmt_usage_id = EBI1.resultfmt_usage_id AND EBI2.process_status = 1 ' ||
1638: ' AND EBI2.' || l_item_seq_col_name || ' IS NOT NULL' ;

Line 1636: ' FROM EGO_BULKLOAD_INTF EBI2 ' ||

1632: IF l_eff_date_col_name IS NOT NULL AND l_oper_seq_col_name IS NOT NULL AND l_item_seq_col_name IS NOT NULL THEN
1633:
1634: l_upd_sql := ' UPDATE EGO_BULKLOAD_INTF EBI1 ' ||
1635: ' SET EBI1.transaction_id = ( SELECT EBI2.transaction_id ' ||
1636: ' FROM EGO_BULKLOAD_INTF EBI2 ' ||
1637: ' WHERE EBI2.resultfmt_usage_id = EBI1.resultfmt_usage_id AND EBI2.process_status = 1 ' ||
1638: ' AND EBI2.' || l_item_seq_col_name || ' IS NOT NULL' ;
1639: IF p_is_pdh_batch = 'Y' THEN
1640: l_upd_sql := l_upd_sql || ' AND EBI2.' || l_parent_column || ' = EBI1.' || l_parent_column ||

Line 1656: ' FROM EGO_BULKLOAD_INTF EBI3 ' ||

1652: ' AND EBI1.' || l_item_seq_col_name || ' IS NULL ' ;
1653: IF p_is_pdh_batch = 'Y' THEN
1654: l_upd_sql := l_upd_sql || ' AND EBI1.' || l_parent_column || ' IS NOT NULL ' ||
1655: ' AND EBI1.' || l_parent_column || ' = (SELECT EBI3.' || l_parent_column ||
1656: ' FROM EGO_BULKLOAD_INTF EBI3 ' ||
1657: ' WHERE EBI3.resultfmt_usage_id = EBI1.resultfmt_usage_id AND EBI3.process_status = 1 ' ||
1658: ' AND EBI3.' || l_item_seq_col_name || ' IS NOT NULL' ||
1659: ' AND EBI3.' || l_parent_column || ' = EBI1.' || l_parent_column ||
1660: ' AND EBI3.' || l_item_col_name || ' = EBI1.' || l_item_col_name ||

Line 1664: ' FROM EGO_BULKLOAD_INTF EBI4 ' ||

1660: ' AND EBI3.' || l_item_col_name || ' = EBI1.' || l_item_col_name ||
1661: ' ) ' ||
1662: ' AND EBI1.' || l_item_col_name || ' IS NOT NULL ' ||
1663: ' AND EBI1.' || l_item_col_name || ' = (SELECT EBI4.' || l_item_col_name ||
1664: ' FROM EGO_BULKLOAD_INTF EBI4 ' ||
1665: ' WHERE EBI4.resultfmt_usage_id = EBI1.resultfmt_usage_id AND EBI4.process_status = 1 ' ||
1666: ' AND EBI4.' || l_item_seq_col_name || ' IS NOT NULL' ||
1667: ' AND EBI4.' || l_item_col_name || ' = EBI1.' || l_item_col_name ||
1668: ' AND EBI4.' || l_parent_column || ' = EBI1.' || l_parent_column ||

Line 1673: ' FROM EGO_BULKLOAD_INTF EBI3 ' ||

1669: ' ) ';
1670: ELSE
1671: l_upd_sql := l_upd_sql || ' AND EBI1.' || G_INTF_SRCSYS_PARENT || ' IS NOT NULL ' ||
1672: ' AND EBI1.' || G_INTF_SRCSYS_PARENT || ' = (SELECT EBI3.' || G_INTF_SRCSYS_PARENT ||
1673: ' FROM EGO_BULKLOAD_INTF EBI3 ' ||
1674: ' WHERE EBI3.resultfmt_usage_id = EBI1.resultfmt_usage_id AND EBI3.process_status = 1 ' ||
1675: ' AND EBI3.' || l_item_seq_col_name || ' IS NOT NULL' ||
1676: ' AND EBI3.' || G_INTF_SRCSYS_PARENT || ' = EBI1.' || G_INTF_SRCSYS_PARENT ||
1677: ' AND EBI3.' || G_INTF_SRCSYS_COMPONENT || ' = EBI1.' || G_INTF_SRCSYS_COMPONENT ||

Line 1681: ' FROM EGO_BULKLOAD_INTF EBI4 ' ||

1677: ' AND EBI3.' || G_INTF_SRCSYS_COMPONENT || ' = EBI1.' || G_INTF_SRCSYS_COMPONENT ||
1678: ' ) ' ||
1679: ' AND EBI1.' || G_INTF_SRCSYS_COMPONENT || ' IS NOT NULL ' ||
1680: ' AND EBI1.' || G_INTF_SRCSYS_COMPONENT || ' = (SELECT EBI4.' || G_INTF_SRCSYS_COMPONENT ||
1681: ' FROM EGO_BULKLOAD_INTF EBI4 ' ||
1682: ' WHERE EBI4.resultfmt_usage_id = EBI1.resultfmt_usage_id AND EBI4.process_status = 1 ' ||
1683: ' AND EBI4.' || l_item_seq_col_name || ' IS NOT NULL' ||
1684: ' AND EBI4.' || G_INTF_SRCSYS_COMPONENT || ' = EBI1.' || G_INTF_SRCSYS_COMPONENT ||
1685: ' AND EBI4.' || G_INTF_SRCSYS_PARENT || ' = EBI1.' || G_INTF_SRCSYS_PARENT ||

Line 1727: l_dyn_sql_cursor := l_dyn_sql_cursor || ' FROM EGO_BULKLOAD_INTF WHERE Process_Status = 1';

1723: l_dyn_sql_cursor := l_dyn_sql_cursor || ' , ' || l_parent_column || ',' || G_INTF_SRCSYS_PARENT ;
1724: l_dyn_sql_cursor := l_dyn_sql_cursor || ' , ' || G_INTF_ORG_CODE;
1725: l_dyn_sql_cursor := l_dyn_sql_cursor || ' , DECODE(' || G_INTF_STRUCT_NAME || ', Bom_Globals.Retrieve_Message(''BOM'', ''BOM_PRIMARY''),NULL,' || G_INTF_STRUCT_NAME || ')';
1726: l_dyn_sql_cursor := l_dyn_sql_cursor || ' , ' || G_INTF_REF_DESIG || ' , Transaction_Id , Transaction_Type ' ;
1727: l_dyn_sql_cursor := l_dyn_sql_cursor || ' FROM EGO_BULKLOAD_INTF WHERE Process_Status = 1';
1728: l_dyn_sql_cursor := l_dyn_sql_cursor || ' AND Resultfmt_Usage_Id = :RESULTFMT_USAGE_ID ';
1729: l_dyn_sql_cursor := l_dyn_sql_cursor || ' AND ' || l_parent_column || ' IS NOT NULL ';
1730: l_dyn_sql_cursor := l_dyn_sql_cursor || ' AND ( UPPER(Transaction_Type) = ''' || G_TXN_CREATE || ''' OR UPPER(Transaction_Type) = ''' || G_TXN_ADD || ''' ';
1731: l_dyn_sql_cursor := l_dyn_sql_cursor || ' OR UPPER(Transaction_Type) = ''' || G_TXN_UPDATE || ''' OR UPPER(Transaction_Type) = ''' || G_TXN_SYNC || ''' )';

Line 1829: UPDATE EGO_BULKLOAD_INTF EBI

1825: );
1826: */
1827:
1828: -- Updating the Bulkload interface rows with success.
1829: UPDATE EGO_BULKLOAD_INTF EBI
1830: SET EBI.PROCESS_STATUS = 7
1831: WHERE EBI.RESULTFMT_USAGE_ID = p_resultfmt_usage_id AND EBI.PROCESS_STATUS = 1;
1832:
1833: -- Call to launch the Java Concurrent Program

Line 2263: l_dyn_attr_id_val_sql := l_dyn_attr_id_val_sql || ' FROM EGO_BULKLOAD_INTF ' ;

2259: l_dyn_attr_id_val_sql := l_dyn_attr_id_val_sql || l_intf_col_name_table(i) ;
2260: END IF;
2261: END LOOP; --end: FOR i IN 1..l_attr_id_table.COUNT LOOP
2262:
2263: l_dyn_attr_id_val_sql := l_dyn_attr_id_val_sql || ' FROM EGO_BULKLOAD_INTF ' ;
2264: l_dyn_attr_id_val_sql := l_dyn_attr_id_val_sql || ' WHERE RESULTFMT_USAGE_ID = :RESULTFMT_USAGE_ID';
2265: l_dyn_attr_id_val_sql := l_dyn_attr_id_val_sql || ' AND PROCESS_STATUS = :PROCESS_STATUS ';
2266:
2267: Write_Debug(l_dyn_attr_id_val_sql);