145: SELECT
146: ORGANIZATION_ID,
147: TRANSACTION_ID,
148: PROCESS_FLAG
149: FROM EGO_AML_INTF
150: WHERE DATA_SET_ID = p_data_set_id
151: AND PROCESS_FLAG IN (33379, 33389);
152: --R12C:BEGIN
153: CURSOR c_ssxref_null_assocs IS
246: )
247: );
248:
249: -- EAI
250: UPDATE EGO_AML_INTF EAI
251: SET PROCESS_FLAG = (CASE WHEN EAI.SOURCE_SYSTEM_REFERENCE IS NULL THEN 33379 ELSE 33389 END),
252: TRANSACTION_ID = NVL(TRANSACTION_ID, MTL_SYSTEM_ITEMS_INTERFACE_S.NEXTVAL),
253: PROGRAM_APPLICATION_ID = l_prog_appid,
254: PROGRAM_ID = l_prog_id,
482: ,l_request_id
483: ,i.TRANSACTION_ID
484: ,l_msg_text
485: ,'SOURCE_SYSTEM_REFERENCE'
486: ,'EGO_AML_INTF'
487: ,'INV_IOI_ERR_SSXREF_IS_NULL_06'--bug 11894684, replace INV_IOI_ERR
488: ,l_err_text);
489: ELSIF i.PROCESS_FLAG = 33389 THEN
490: FND_MESSAGE.SET_NAME('EGO', 'EGO_SSXID_INVALID');
498: ,l_request_id
499: ,i.TRANSACTION_ID
500: ,l_msg_text
501: ,'SOURCE_SYSTEM_ID'
502: ,'EGO_AML_INTF'
503: ,'INV_IOI_ERR_SSXID_INVALID_06'--bug 11894684, replace INV_IOI_ERR
504: ,l_err_text);
505: END IF;
506: END LOOP;
569: SET PROCESS_STATUS =3
570: WHERE PROCESS_STATUS IN (33379, 33389)
571: AND DATA_SET_ID = p_data_set_id;
572:
573: UPDATE EGO_AML_INTF
574: SET PROCESS_FLAG =3
575: WHERE PROCESS_FLAG IN (33379, 33389)
576: AND DATA_SET_ID = p_data_set_id;
577: --R12C: BEGIN
687: FND_STATS.GATHER_TABLE_STATS(l_schema, 'EGO_ITEM_PEOPLE_INTF');
688: Debug_Conc_Log('Collected Statistics on EGO_ITEM_PEOPLE_INTF');
689: END IF;
690:
691: -- checking whether stats needs to be collected on EGO_AML_INTF
692: SELECT COUNT(1) INTO l_records
693: FROM EGO_AML_INTF
694: WHERE DATA_SET_ID = p_data_set_id;
695:
689: END IF;
690:
691: -- checking whether stats needs to be collected on EGO_AML_INTF
692: SELECT COUNT(1) INTO l_records
693: FROM EGO_AML_INTF
694: WHERE DATA_SET_ID = p_data_set_id;
695:
696: IF (l_records > l_stats_profile) AND l_ego_installed AND l_schema IS NOT NULL THEN
697: FND_STATS.GATHER_TABLE_STATS(l_schema, 'EGO_AML_INTF');
693: FROM EGO_AML_INTF
694: WHERE DATA_SET_ID = p_data_set_id;
695:
696: IF (l_records > l_stats_profile) AND l_ego_installed AND l_schema IS NOT NULL THEN
697: FND_STATS.GATHER_TABLE_STATS(l_schema, 'EGO_AML_INTF');
698: Debug_Conc_Log('Collected Statistics on EGO_AML_INTF');
699: END IF;
700: /* Bug 12669090 : Commenting the Gather Stats.
701: As mentioned in the note 1208945.1 and suggested by performance team,
694: WHERE DATA_SET_ID = p_data_set_id;
695:
696: IF (l_records > l_stats_profile) AND l_ego_installed AND l_schema IS NOT NULL THEN
697: FND_STATS.GATHER_TABLE_STATS(l_schema, 'EGO_AML_INTF');
698: Debug_Conc_Log('Collected Statistics on EGO_AML_INTF');
699: END IF;
700: /* Bug 12669090 : Commenting the Gather Stats.
701: As mentioned in the note 1208945.1 and suggested by performance team,
702: for any performance issues we need to gather stats manualy so no need to gather stats in the code.
5812: AND PROCESS_STATUS = 0
5813: AND SOURCE_SYSTEM_ID = i.SOURCE_SYSTEM_ID
5814: AND SOURCE_SYSTEM_REFERENCE = i.SOURCE_SYSTEM_REFERENCE;
5815:
5816: UPDATE EGO_AML_INTF
5817: SET PROCESS_FLAG = 7,
5818: PROGRAM_APPLICATION_ID = l_prog_appid,
5819: PROGRAM_ID = l_prog_id,
5820: REQUEST_ID = l_request_id,
5876: AND PROCESS_STATUS = 0
5877: AND SOURCE_SYSTEM_ID = i.SOURCE_SYSTEM_ID
5878: AND SOURCE_SYSTEM_REFERENCE = i.SOURCE_SYSTEM_REFERENCE;
5879:
5880: UPDATE EGO_AML_INTF
5881: SET PROCESS_FLAG = 7,
5882: PROGRAM_APPLICATION_ID = l_prog_appid,
5883: PROGRAM_ID = l_prog_id,
5884: REQUEST_ID = l_request_id,
6602: WHERE DATA_SET_ID = p_data_set_id AND
6603: (PROCESS_STATUS IS NULL OR PROCESS_STATUS IN (0, 1)) AND
6604: ORGANIZATION_ID IS NULL;
6605:
6606: UPDATE EGO_AML_INTF EAI
6607: SET ORGANIZATION_ID =
6608: CASE
6609: WHEN ORGANIZATION_CODE IS NOT NULL
6610: THEN (SELECT ORGANIZATION_ID FROM MTL_PARAMETERS WHERE ORGANIZATION_CODE = EAI.ORGANIZATION_CODE)
6792: AND PROCESS_STATUS = 1
6793: AND ITEM_NUMBER IS NULL
6794: AND INVENTORY_ITEM_ID IS NOT NULL;
6795:
6796: UPDATE EGO_AML_INTF EAI
6797: SET item_number = (SELECT CONCATENATED_SEGMENTS
6798: FROM MTL_SYSTEM_ITEMS_KFV
6799: WHERE INVENTORY_ITEM_ID = EAI.INVENTORY_ITEM_ID
6800: AND ORGANIZATION_ID = EAI.ORGANIZATION_ID)
6882: , l_insert_date -- LAST_UPDATE_DATE
6883: , MAX( EAI.created_by ) KEEP ( DENSE_RANK FIRST ORDER BY INVENTORY_ITEM_ID NULLS LAST, LAST_UPDATE_DATE NULLS LAST ) CREATED_BY
6884: , MAX( EAI.last_updated_by ) KEEP ( DENSE_RANK FIRST ORDER BY INVENTORY_ITEM_ID NULLS LAST, LAST_UPDATE_DATE NULLS LAST ) UPDATED_BY
6885: , MAX( EAI.last_update_login ) KEEP ( DENSE_RANK FIRST ORDER BY INVENTORY_ITEM_ID NULLS LAST, LAST_UPDATE_DATE NULLS LAST ) LAST_UPDATE_LOGIN
6886: FROM EGO_AML_INTF EAI
6887: -- , MTL_PARAMETERS MP
6888: WHERE
6889: EAI.data_set_id = p_data_set_id
6890: AND EAI.process_flag = 1
7032: SET PROCESS_STATUS = 0
7033: WHERE DATA_SET_ID = p_data_set_id AND
7034: PROCESS_STATUS IS NULL;
7035:
7036: UPDATE EGO_AML_INTF
7037: SET PROCESS_FLAG = 0
7038: WHERE DATA_SET_ID = p_data_set_id AND
7039: PROCESS_FLAG IS NULL;
7040:
7113: , l_insert_date -- LAST_UPDATE_DATE
7114: , MAX( EAI.created_by ) KEEP ( DENSE_RANK FIRST ORDER BY INVENTORY_ITEM_ID NULLS LAST, ITEM_NUMBER NULLS LAST, LAST_UPDATE_DATE NULLS LAST ) CREATED_BY
7115: , MAX( EAI.last_updated_by ) KEEP ( DENSE_RANK FIRST ORDER BY INVENTORY_ITEM_ID NULLS LAST, ITEM_NUMBER NULLS LAST, LAST_UPDATE_DATE NULLS LAST ) UPDATED_BY
7116: , MAX( EAI.last_update_login ) KEEP ( DENSE_RANK FIRST ORDER BY INVENTORY_ITEM_ID NULLS LAST, ITEM_NUMBER NULLS LAST, LAST_UPDATE_DATE NULLS LAST ) LAST_UPDATE_LOGIN
7117: FROM EGO_AML_INTF EAI
7118: -- , MTL_PARAMETERS MP
7119: WHERE
7120: EAI.data_set_id = p_data_set_id
7121: AND EAI.process_flag = 0
8924: AND MSII.ORGANIZATION_ID = l_org_id);
8925:
8926: Debug_Conc_Log('Resolve_Child_Entities - After resolving item people rows' );
8927: -- updating item_number, item_id from MSII table
8928: UPDATE EGO_AML_INTF EAI
8929: SET (PROCESS_FLAG, TRANSACTION_TYPE, INVENTORY_ITEM_ID, ITEM_NUMBER) =
8930: (SELECT
8931: 1,
8932: (CASE
9263: Debug_Conc_Log('Resolve_Child_Entities - After updating user attrs intf table for items that has XXref');
9264:
9265: -- updating the item AML interface
9266: l_sql := q'#
9267: UPDATE EGO_AML_INTF EAI
9268: SET (PROCESS_FLAG, TRANSACTION_TYPE, INVENTORY_ITEM_ID) =
9269: (SELECT
9270: 1,
9271: NVL(EAI.TRANSACTION_TYPE, 'SYNC'),
9696: );
9697: l_is_reimport := l_is_reimport OR ( 0 <> SQL%ROWCOUNT );
9698:
9699: -- updating item AML
9700: UPDATE EGO_AML_INTF
9701: SET PROCESS_FLAG = 1
9702: WHERE ( INVENTORY_ITEM_ID = l_item_id
9703: OR ( ITEM_NUMBER = l_item_number
9704: AND INVENTORY_ITEM_ID IS NULL
9795: );
9796: l_is_reimport := l_is_reimport OR ( 0 <> SQL%ROWCOUNT );
9797:
9798: -- updating item AML
9799: UPDATE EGO_AML_INTF
9800: SET PROCESS_FLAG = 1
9801: WHERE ITEM_NUMBER = l_item_number
9802: AND PROCESS_FLAG = 3
9803: AND DATA_SET_ID = p_batch_id
10058: );
10059: l_is_reimport := l_is_reimport OR ( 0 <> SQL%ROWCOUNT );
10060:
10061: -- updating item AML
10062: UPDATE EGO_AML_INTF
10063: SET PROCESS_FLAG = 1
10064: WHERE SOURCE_SYSTEM_ID = l_ss_id
10065: AND SOURCE_SYSTEM_REFERENCE = l_ssr
10066: AND PROCESS_FLAG = 3
12011: AND SOURCE_SYSTEM_REFERENCE = p_src_system_ref
12012: AND PROCESS_FLAG = 0;
12013:
12014: ------------------
12015: -- EGO_AML_INTF --
12016: ------------------
12017: UPDATE EGO_AML_INTF EAI
12018: SET ORGANIZATION_ID =
12019: NVL(ORGANIZATION_ID,
12013:
12014: ------------------
12015: -- EGO_AML_INTF --
12016: ------------------
12017: UPDATE EGO_AML_INTF EAI
12018: SET ORGANIZATION_ID =
12019: NVL(ORGANIZATION_ID,
12020: (SELECT MP.ORGANIZATION_ID
12021: FROM MTL_PARAMETERS MP
12704: THEN 1
12705: ELSE NULL
12706: END
12707: ) UPDATE_CNT
12708: FROM EGO_AML_INTF eai
12709: WHERE eai.DATA_SET_ID = p_set_process_id
12710: AND EXISTS
12711: (
12712: SELECT NULL