[Home] [Help]
37: orig_sys_line_ref,
38: orig_sys_shipment_ref,
39: sold_to_org_id,
40: org_id
41: FROM OE_LINES_EXT_IFACE_ALL
42: WHERE PROCESS_STATUS=1
43: AND DATA_SET_ID=l_data_set_id;
44:
45:
198: ||',' || 'orig_sys_shipment_ref : ' ||i.orig_sys_shipment_ref);
199: END;
200:
201: IF l_line_id IS NOT NULL THEN
202: UPDATE OE_LINES_EXT_IFACE_ALL
203: SET PROCESS_STATUS = 2, LINE_ID= l_line_id
204: WHERE data_set_id = l_data_set_id
205: AND PROCESS_STATUS = 1
206: AND order_source_id = i.order_source_id
209: AND (sold_to_org_id is NULL OR decode(l_customer_key_profile, 'Y', nvl(sold_to_org_id, FND_API.G_MISS_NUM), 1)
210: = decode(l_customer_key_profile, 'Y', nvl(i.sold_to_org_id, FND_API.G_MISS_NUM), 1));
211: END IF;
212: ELSE
213: UPDATE OE_LINES_EXT_IFACE_ALL
214: SET PROCESS_STATUS = 2
215: WHERE data_set_id = l_data_set_id
216: AND line_id = i.line_id
217: AND PROCESS_STATUS = 1;
220: END LOOP ;
221:
222: BEGIN
223: SELECT COUNT(*) INTO l_line_count
224: FROM OE_LINES_EXT_IFACE_ALL
225: WHERE PROCESS_STATUS=2
226: AND LINE_ID IS NOT NULL;
227: EXCEPTION
228: WHEN NO_DATA_FOUND THEN
228: WHEN NO_DATA_FOUND THEN
229: l_line_count := NULL;
230: END;
231: IF l_line_count = 0 THEN
232: FND_FILE.PUT_LINE( FND_FILE.LOG, 'NO records in OE_LINES_EXT_IFACE_ALL to process');
233: END IF;
234:
235: IF l_line_count > 0 THEN
236:
233: END IF;
234:
235: IF l_line_count > 0 THEN
236:
237: FND_FILE.PUT_LINE( FND_FILE.LOG, 'Calling EGO_USER_ATTRS_BULK_PVT.Bulk_Load_User_Attrs_Data to import OE_LINES_EXT_IFACE_ALL data');
238:
239: EGO_USER_ATTRS_BULK_PVT.Bulk_Load_User_Attrs_Data
240: ( p_api_version => 1.0
241: , p_application_id => 660
241: , p_application_id => 660
242: , p_attr_group_type => 'OE_LINE_ATTRIBUTES_EXT'
243: , p_object_name => 'OE_ORDER_LINES_ALL'
244: , p_hz_party_id => 'OPERATIONS:5877'
245: , p_interface_table_name => 'OE_LINES_EXT_IFACE_ALL'
246: , p_data_set_id => l_data_set_id
247: ,p_related_class_codes_query => l_rel_sql
248: , p_init_fnd_msg_list => 'F'
249: , p_log_errors => 'T'
256: , x_msg_count => l_msg_count
257: , x_msg_data => l_err_text
258: );
259:
260: FND_FILE.PUT_LINE(FND_FILE.LOG, 'l_return_status after importing OE_LINES_EXT_IFACE_ALL : '||l_return_status);
261: FND_FILE.PUT_LINE(FND_FILE.LOG, 'l_err_code : '||l_err_code);
262: FND_FILE.PUT_LINE(FND_FILE.LOG, 'l_err_text : '||l_err_text);
263: FND_FILE.PUT_LINE(FND_FILE.LOG, 'l_msg_count : '||l_msg_count);
264:
263: FND_FILE.PUT_LINE(FND_FILE.LOG, 'l_msg_count : '||l_msg_count);
264:
265: IF l_return_status = FND_API.G_RET_STS_SUCCESS THEN
266: retcode := 0;
267: FND_FILE.PUT_LINE(FND_FILE.OUTPUT, 'Sucessfully imported OE_LINES_EXT_IFACE_ALL data');
268: ELSIF l_return_status = 'W' THEN
269: retcode := 1;
270: FND_FILE.PUT_LINE(FND_FILE.OUTPUT,'Warning while importing OE_LINES_EXT_IFACE_ALL');
271: ELSE
266: retcode := 0;
267: FND_FILE.PUT_LINE(FND_FILE.OUTPUT, 'Sucessfully imported OE_LINES_EXT_IFACE_ALL data');
268: ELSIF l_return_status = 'W' THEN
269: retcode := 1;
270: FND_FILE.PUT_LINE(FND_FILE.OUTPUT,'Warning while importing OE_LINES_EXT_IFACE_ALL');
271: ELSE
272: retcode := 2;
273: FND_FILE.PUT_LINE(FND_FILE.OUTPUT, 'Error reported while importing OE_LINES_EXT_IFACE_ALL. Please fix the errors in this log file and re-run the concurrent program.');
274: END IF;
269: retcode := 1;
270: FND_FILE.PUT_LINE(FND_FILE.OUTPUT,'Warning while importing OE_LINES_EXT_IFACE_ALL');
271: ELSE
272: retcode := 2;
273: FND_FILE.PUT_LINE(FND_FILE.OUTPUT, 'Error reported while importing OE_LINES_EXT_IFACE_ALL. Please fix the errors in this log file and re-run the concurrent program.');
274: END IF;
275:
276:
277: ERROR_HANDLER.Log_Error(
280: ,p_write_err_to_debugfile => 'N'
281: );
282:
283: IF l_return_status = FND_API.G_RET_STS_SUCCESS OR l_return_status = 'W' THEN
284: DELETE FROM OE_LINES_EXT_IFACE_ALL
285: WHERE data_set_id = l_data_set_id
286: AND PROCESS_STATUS = 2;
287: COMMIT;
288: END IF;