45: -- Cursor for all the records in this processing group
46:
47: CURSOR genealogy_cur IS
48: SELECT *
49: FROM MTL_OBJECT_GENEALOGY_INTERFACE mogi
50: WHERE mogi.group_id = p_interface_group_id
51: AND mogi.process_status = 'R';
52:
53: BEGIN
225:
226: END IF;
227:
228: IF l_return_status = 'E' or l_return_status = 'U' THEN
229: UPDATE MTL_OBJECT_GENEALOGY_INTERFACE mogi
230: SET mogi.process_status = 'E',
231: mogi.error_message = l_msg_data
232: WHERE mogi.group_id = p_interface_group_id and mogi.interface_header_id = genealogy_rec.interface_header_id;
233:
231: mogi.error_message = l_msg_data
232: WHERE mogi.group_id = p_interface_group_id and mogi.interface_header_id = genealogy_rec.interface_header_id;
233:
234: ELSIF l_return_status = 'S' THEN
235: UPDATE MTL_OBJECT_GENEALOGY_INTERFACE mogi
236: SET mogi.process_status = 'S'
237: WHERE mogi.group_id = p_interface_group_id and mogi.interface_header_id = genealogy_rec.interface_header_id;
238: END IF;
239:
247: p_count => l_msg_count,
248: p_data => l_msg_data
249: );
250:
251: UPDATE MTL_OBJECT_GENEALOGY_INTERFACE mogi
252: SET mogi.process_status = 'E',
253: mogi.error_message = l_msg_data
254: WHERE mogi.group_id = p_interface_group_id and mogi.interface_header_id = genealogy_rec.interface_header_id;
255:
262: p_count => l_msg_count,
263: p_data => l_msg_data
264: );
265:
266: UPDATE MTL_OBJECT_GENEALOGY_INTERFACE mogi
267: SET mogi.process_status = 'E',
268: mogi.error_message = l_msg_data
269: WHERE mogi.group_id = p_interface_group_id and mogi.interface_header_id = genealogy_rec.interface_header_id;
270:
274:
275: -- delete rows marked as success
276:
277: IF p_purge_option = 'Y' THEN
278: DELETE FROM MTL_OBJECT_GENEALOGY_INTERFACE mogi
279: WHERE mogi.process_status = 'S' and
280: mogi.group_id = p_interface_group_id;
281: END IF;
282:
307: p_count => l_msg_count,
308: p_data => l_msg_data
309: );
310:
311: UPDATE MTL_OBJECT_GENEALOGY_INTERFACE mogi
312: SET mogi.process_status = 'E',
313: mogi.error_message = l_msg_data,
314: mogi.error_code = 9999
315: WHERE mogi.group_id = p_interface_group_id;