44:
45:
46: BEGIN
47:
48: FND_FILE.PUT_LINE( FND_FILE.LOG,'Import_Order_Extn: BEGIN');
49: FND_FILE.PUT_LINE( FND_FILE.LOG,'Data Set ID: ' ||p_data_set_id);
50:
51: l_rel_sql := 'SELECT ''ADMIN_DEFINED'' FROM DUAL';
52:
45:
46: BEGIN
47:
48: FND_FILE.PUT_LINE( FND_FILE.LOG,'Import_Order_Extn: BEGIN');
49: FND_FILE.PUT_LINE( FND_FILE.LOG,'Data Set ID: ' ||p_data_set_id);
50:
51: l_rel_sql := 'SELECT ''ADMIN_DEFINED'' FROM DUAL';
52:
53: IF OE_CODE_CONTROL.GET_CODE_RELEASE_LEVEL >= '110510' Then
52:
53: IF OE_CODE_CONTROL.GET_CODE_RELEASE_LEVEL >= '110510' Then
54: fnd_profile.get('ONT_INCLUDE_CUST_IN_OI_KEY', l_customer_key_profile);
55: l_customer_key_profile := nvl(l_customer_key_profile, 'N');
56: FND_FILE.PUT_LINE( FND_FILE.LOG, 'CUSTOMER KEY PROFILE SETTING = '||l_customer_key_profile ) ;
57:
58: fnd_profile.get('DEFAULT_ORG_ID', l_org_id);
59: FND_FILE.PUT_LINE( FND_FILE.LOG, 'DEFAULT ORG ID = '||l_org_id ) ;
60: IF l_org_id IS NULL THEN
55: l_customer_key_profile := nvl(l_customer_key_profile, 'N');
56: FND_FILE.PUT_LINE( FND_FILE.LOG, 'CUSTOMER KEY PROFILE SETTING = '||l_customer_key_profile ) ;
57:
58: fnd_profile.get('DEFAULT_ORG_ID', l_org_id);
59: FND_FILE.PUT_LINE( FND_FILE.LOG, 'DEFAULT ORG ID = '||l_org_id ) ;
60: IF l_org_id IS NULL THEN
61: FND_FILE.PUT_LINE( FND_FILE.LOG, 'Unable to derive org_id from MO: Default Operating Unit. Please set the profile value.');
62: RAISE FND_API.G_EXC_ERROR;
63: END IF;
57:
58: fnd_profile.get('DEFAULT_ORG_ID', l_org_id);
59: FND_FILE.PUT_LINE( FND_FILE.LOG, 'DEFAULT ORG ID = '||l_org_id ) ;
60: IF l_org_id IS NULL THEN
61: FND_FILE.PUT_LINE( FND_FILE.LOG, 'Unable to derive org_id from MO: Default Operating Unit. Please set the profile value.');
62: RAISE FND_API.G_EXC_ERROR;
63: END IF;
64:
65: END IF;
63: END IF;
64:
65: END IF;
66:
67: FND_FILE.PUT_LINE( FND_FILE.LOG, 'Deriving Header_id from OE_ORDER_HEADERS_ALL...');
68: FOR i IN l_header_cur
69: LOOP
70: IF i.header_id IS NULL THEN
71: BEGIN
75: AND orig_sys_document_ref = i.orig_sys_document_ref
76: AND org_id = Nvl(i.org_id,l_org_id)
77: 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)
78: = decode(l_customer_key_profile, 'Y',nvl(i.sold_to_org_id, FND_API.G_MISS_NUM), 1));
79: FND_FILE.PUT_LINE( FND_FILE.LOG, 'l_header_id : ' || l_header_id);
80: EXCEPTION
81: WHEN NO_DATA_FOUND THEN
82: l_header_id :=NULL;
83: FND_FILE.PUT_LINE(FND_FILE.LOG, 'Unable to derive header_id for order_source_id :'||i.order_source_id
79: FND_FILE.PUT_LINE( FND_FILE.LOG, 'l_header_id : ' || l_header_id);
80: EXCEPTION
81: WHEN NO_DATA_FOUND THEN
82: l_header_id :=NULL;
83: FND_FILE.PUT_LINE(FND_FILE.LOG, 'Unable to derive header_id for order_source_id :'||i.order_source_id
84: ||',' || 'orig_sys_document_ref : ' ||i.orig_sys_document_ref);
85: END;
86:
87: IF l_header_id IS NOT NULL THEN
115: l_header_count := NULL;
116: END;
117:
118: IF l_header_count = 0 THEN
119: FND_FILE.PUT_LINE( FND_FILE.LOG, 'NO records in OE_HEADERS_EXT_IFACE_ALL to process');
120: END IF;
121:
122: IF l_header_count > 0 THEN
123: FND_FILE.PUT_LINE( FND_FILE.LOG, 'Calling EGO_USER_ATTRS_BULK_PVT.Bulk_Load_User_Attrs_Data to import OE_HEADERS_EXT_IFACE_ALL data');
119: FND_FILE.PUT_LINE( FND_FILE.LOG, 'NO records in OE_HEADERS_EXT_IFACE_ALL to process');
120: END IF;
121:
122: IF l_header_count > 0 THEN
123: FND_FILE.PUT_LINE( FND_FILE.LOG, 'Calling EGO_USER_ATTRS_BULK_PVT.Bulk_Load_User_Attrs_Data to import OE_HEADERS_EXT_IFACE_ALL data');
124:
125: EGO_USER_ATTRS_BULK_PVT.Bulk_Load_User_Attrs_Data
126: ( p_api_version => 1.0
127: , p_application_id => 660
142: , x_msg_count => l_msg_count
143: , x_msg_data => l_err_text
144: );
145:
146: FND_FILE.PUT_LINE(FND_FILE.LOG, 'l_return_status after importing OE_HEADERS_EXT_IFACE_ALL : '||l_return_status);
147: FND_FILE.PUT_LINE(FND_FILE.LOG, 'l_err_code : '||l_err_code);
148: FND_FILE.PUT_LINE(FND_FILE.LOG, 'l_err_text : '||l_err_text);
149: FND_FILE.PUT_LINE(FND_FILE.LOG, 'l_msg_count : '||l_msg_count);
150:
143: , x_msg_data => l_err_text
144: );
145:
146: FND_FILE.PUT_LINE(FND_FILE.LOG, 'l_return_status after importing OE_HEADERS_EXT_IFACE_ALL : '||l_return_status);
147: FND_FILE.PUT_LINE(FND_FILE.LOG, 'l_err_code : '||l_err_code);
148: FND_FILE.PUT_LINE(FND_FILE.LOG, 'l_err_text : '||l_err_text);
149: FND_FILE.PUT_LINE(FND_FILE.LOG, 'l_msg_count : '||l_msg_count);
150:
151: IF l_return_status = FND_API.G_RET_STS_SUCCESS THEN
144: );
145:
146: FND_FILE.PUT_LINE(FND_FILE.LOG, 'l_return_status after importing OE_HEADERS_EXT_IFACE_ALL : '||l_return_status);
147: FND_FILE.PUT_LINE(FND_FILE.LOG, 'l_err_code : '||l_err_code);
148: FND_FILE.PUT_LINE(FND_FILE.LOG, 'l_err_text : '||l_err_text);
149: FND_FILE.PUT_LINE(FND_FILE.LOG, 'l_msg_count : '||l_msg_count);
150:
151: IF l_return_status = FND_API.G_RET_STS_SUCCESS THEN
152: retcode := 0;
145:
146: FND_FILE.PUT_LINE(FND_FILE.LOG, 'l_return_status after importing OE_HEADERS_EXT_IFACE_ALL : '||l_return_status);
147: FND_FILE.PUT_LINE(FND_FILE.LOG, 'l_err_code : '||l_err_code);
148: FND_FILE.PUT_LINE(FND_FILE.LOG, 'l_err_text : '||l_err_text);
149: FND_FILE.PUT_LINE(FND_FILE.LOG, 'l_msg_count : '||l_msg_count);
150:
151: IF l_return_status = FND_API.G_RET_STS_SUCCESS THEN
152: retcode := 0;
153: FND_FILE.PUT_LINE(FND_FILE.OUTPUT, 'Sucessfully imported OE_HEADERS_EXT_IFACE_ALL data');
149: FND_FILE.PUT_LINE(FND_FILE.LOG, 'l_msg_count : '||l_msg_count);
150:
151: IF l_return_status = FND_API.G_RET_STS_SUCCESS THEN
152: retcode := 0;
153: FND_FILE.PUT_LINE(FND_FILE.OUTPUT, 'Sucessfully imported OE_HEADERS_EXT_IFACE_ALL data');
154: ELSIF l_return_status = 'W' THEN
155: retcode := 1;
156: FND_FILE.PUT_LINE(FND_FILE.OUTPUT, 'Warning while importing OE_HEADERS_EXT_IFACE_ALL');
157: ELSE
152: retcode := 0;
153: FND_FILE.PUT_LINE(FND_FILE.OUTPUT, 'Sucessfully imported OE_HEADERS_EXT_IFACE_ALL data');
154: ELSIF l_return_status = 'W' THEN
155: retcode := 1;
156: FND_FILE.PUT_LINE(FND_FILE.OUTPUT, 'Warning while importing OE_HEADERS_EXT_IFACE_ALL');
157: ELSE
158: retcode := 2;
159: FND_FILE.PUT_LINE(FND_FILE.OUTPUT, 'Error reported while importing OE_HEADERS_EXT_IFACE_ALL. Please fix the errors in this log file and re-run the concurrent program.');
160: END IF;
155: retcode := 1;
156: FND_FILE.PUT_LINE(FND_FILE.OUTPUT, 'Warning while importing OE_HEADERS_EXT_IFACE_ALL');
157: ELSE
158: retcode := 2;
159: FND_FILE.PUT_LINE(FND_FILE.OUTPUT, 'Error reported while importing OE_HEADERS_EXT_IFACE_ALL. Please fix the errors in this log file and re-run the concurrent program.');
160: END IF;
161:
162:
163: ERROR_HANDLER.Log_Error(
173: COMMIT;
174: END IF;
175: END IF;
176:
177: FND_FILE.PUT_LINE( FND_FILE.LOG, 'Deriving Line_id from OE_ORDER_LINES_ALL...');
178: FOR i IN l_line_cur
179: LOOP
180: IF i.line_id IS NULL THEN
181: BEGIN
191:
192: EXCEPTION
193: WHEN NO_DATA_FOUND THEN
194: l_line_id :=NULL;
195: FND_FILE.PUT_LINE(FND_FILE.LOG, 'Unable to derive line_id for order_source_id :'||i.order_source_id
196: ||',' || 'orig_sys_document_ref : ' ||i.orig_sys_document_ref
197: ||',' || 'orig_sys_line_ref : ' ||i.orig_sys_line_ref
198: ||',' || 'orig_sys_shipment_ref : ' ||i.orig_sys_shipment_ref);
199: END;
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
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:
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:
265: IF l_return_status = FND_API.G_RET_STS_SUCCESS THEN
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:
265: IF l_return_status = FND_API.G_RET_STS_SUCCESS THEN
266: retcode := 0;
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:
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');
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(
292: EXCEPTION
293: WHEN FND_API.G_EXC_ERROR THEN
294: retcode := 2;
295: errbuf := 'Please fix the error in the log file';
296: FND_FILE.PUT_LINE(FND_FILE.LOG, 'Please fix the errors in this log file and re-run the concurrent program.');
297:
298: WHEN OTHERS THEN
299: retcode := 2;
300: errbuf := sqlerrm;
297:
298: WHEN OTHERS THEN
299: retcode := 2;
300: errbuf := sqlerrm;
301: FND_FILE.PUT_LINE(FND_FILE.LOG, 'An Exception has occured. Returning with ERROR :'||sqlerrm);
302: END;
303: END OE_ORDER_EXTN_IMPORT_PVT;