24:
25: )
26: IS
27: --
28: l_debug_level CONSTANT NUMBER := oe_debug_pub.g_debug_level;
29: --
30: BEGIN
31:
32: IF l_debug_level > 0 THEN
29: --
30: BEGIN
31:
32: IF l_debug_level > 0 THEN
33: oe_debug_pub.add( 'BEFORE CALLING PERF STATISTICS API' ) ;
34: END IF;
35:
36: FND_STATS.Gather_Table_Stats(ownname => 'ONT',
37: tabname => 'OE_HEADERS_IFACE_ALL');
50: FND_STATS.Gather_Table_Stats(ownname => 'ONT',
51: tabname => 'OE_PAYMENTS_IFACE_ALL');
52:
53: IF l_debug_level > 0 THEN
54: oe_debug_pub.add( 'AFTER CALLING PERF STATISTICS API' ) ;
55: END IF;
56:
57: EXCEPTION
58: WHEN OTHERS THEN
56:
57: EXCEPTION
58: WHEN OTHERS THEN
59: IF l_debug_level > 0 THEN
60: oe_debug_pub.add( 'UNEXPECTED ERROR: '||SQLERRM ) ;
61: END IF;
62: IF OE_MSG_PUB.Check_Msg_Level(OE_MSG_PUB.G_MSG_LVL_UNEXP_ERROR) THEN
63: OE_MSG_PUB.Add_Exc_Msg (G_PKG_NAME, 'Import_Order_stats');
64: END IF;
242: ;
243:
244:
245: --
246: l_debug_level CONSTANT NUMBER := oe_debug_pub.g_debug_level;
247: --
248: BEGIN
249:
250: --MOAC set policy context for single Org
254:
255: fnd_profile.get('ONT_IMP_MULTIPLE_SHIPMENTS', G_IMPORT_SHIPMENTS);
256: G_IMPORT_SHIPMENTS := nvl(G_IMPORT_SHIPMENTS, 'NO');
257: IF l_debug_level > 0 THEN
258: oe_debug_pub.add( 'IMP SHIPMENTS PROFILE = '||G_IMPORT_SHIPMENTS ) ;
259: END IF;
260:
261: If OE_CODE_CONTROL.GET_CODE_RELEASE_LEVEL >= '110510' Then
262: fnd_profile.get('ONT_INCLUDE_CUST_IN_OI_KEY', l_customer_key_profile);
261: If OE_CODE_CONTROL.GET_CODE_RELEASE_LEVEL >= '110510' Then
262: fnd_profile.get('ONT_INCLUDE_CUST_IN_OI_KEY', l_customer_key_profile);
263: l_customer_key_profile := nvl(l_customer_key_profile, 'N');
264: IF l_debug_level > 0 THEN
265: oe_debug_pub.add( 'DERIVED CUSTOMER KEY PROFILE SETTING = '||l_customer_key_profile ) ;
266: END IF;
267: End If;
268:
269:
314: Setting Debug On
315: -----------------------------------------------------------
316: */
317: -- Removing this initialization as per change in debug package
318: -- OE_DEBUG_PUB.debug_on;
319: -- OE_DEBUG_PUB.SetDebugLevel(5);
320: -- OE_DEBUG_PUB.initialize;
321: -- If l_debug_level Is Null
322: -- Then
315: -----------------------------------------------------------
316: */
317: -- Removing this initialization as per change in debug package
318: -- OE_DEBUG_PUB.debug_on;
319: -- OE_DEBUG_PUB.SetDebugLevel(5);
320: -- OE_DEBUG_PUB.initialize;
321: -- If l_debug_level Is Null
322: -- Then
323: -- l_debug_level := to_number(nvl(fnd_profile.value('ONT_DEBUG_LEVEL'),'0'));
316: */
317: -- Removing this initialization as per change in debug package
318: -- OE_DEBUG_PUB.debug_on;
319: -- OE_DEBUG_PUB.SetDebugLevel(5);
320: -- OE_DEBUG_PUB.initialize;
321: -- If l_debug_level Is Null
322: -- Then
323: -- l_debug_level := to_number(nvl(fnd_profile.value('ONT_DEBUG_LEVEL'),'0'));
324: -- End If;
323: -- l_debug_level := to_number(nvl(fnd_profile.value('ONT_DEBUG_LEVEL'),'0'));
324: -- End If;
325:
326: IF l_debug_level > 0 THEN
327: oe_debug_pub.add( 'AFTER SETTING DEBUG ON' ) ;
328: END IF;
329:
330:
331: -----------------------------------------------------------
335: FND_FILE.Put_Line(FND_FILE.OUTPUT,'Debug Level: '||l_debug_level);
336:
337: IF nvl(l_debug_level, 1) > 0 THEN
338: -- fnd_profile.put('OE_DEBUG_LOG_DIRECTORY','/sqlcom/outbound');
339: l_filename := OE_DEBUG_PUB.set_debug_mode ('FILE');
340: FND_FILE.Put_Line(FND_FILE.OUTPUT,'Debug File: ' || l_filename);
341: FND_FILE.Put_Line(FND_FILE.OUTPUT, '');
342: -- Following line moved inside because of the bug 3328608
343: l_filename := OE_DEBUG_PUB.set_debug_mode ('CONC');
339: l_filename := OE_DEBUG_PUB.set_debug_mode ('FILE');
340: FND_FILE.Put_Line(FND_FILE.OUTPUT,'Debug File: ' || l_filename);
341: FND_FILE.Put_Line(FND_FILE.OUTPUT, '');
342: -- Following line moved inside because of the bug 3328608
343: l_filename := OE_DEBUG_PUB.set_debug_mode ('CONC');
344: END IF;
345:
346:
347:
349: Initialization
350: -----------------------------------------------------------
351: */
352: IF l_debug_level > 0 THEN
353: oe_debug_pub.add( 'BEFORE INITIALIZATION' ) ;
354: END IF;
355: --Changes made for Bug no 5493479 start
356: /*-----------------------------------------------------------
357: Set the Context for Order Import
368: Get Concurrent Request Id
369: -----------------------------------------------------------
370: */
371: IF l_debug_level > 0 THEN
372: oe_debug_pub.add( 'BEFORE GETTING REQUEST ID' ) ;
373: oe_debug_pub.add( 'PERFORMANCE PARAMETER:' || p_perf_param);
374: END IF;
375:
376: --Bug# 12333065 FND_PROFILE.Get('CONC_REQUEST_ID', l_request_id);
369: -----------------------------------------------------------
370: */
371: IF l_debug_level > 0 THEN
372: oe_debug_pub.add( 'BEFORE GETTING REQUEST ID' ) ;
373: oe_debug_pub.add( 'PERFORMANCE PARAMETER:' || p_perf_param);
374: END IF;
375:
376: --Bug# 12333065 FND_PROFILE.Get('CONC_REQUEST_ID', l_request_id);
377: l_request_id := FND_GLOBAL.CONC_REQUEST_ID; --bug# 12333065
376: --Bug# 12333065 FND_PROFILE.Get('CONC_REQUEST_ID', l_request_id);
377: l_request_id := FND_GLOBAL.CONC_REQUEST_ID; --bug# 12333065
378:
379: IF l_debug_level > 0 THEN
380: oe_debug_pub.add( 'REQUEST ID: '|| TO_CHAR ( L_REQUEST_ID ) ) ;
381: END IF;
382: fnd_file.put_line(FND_FILE.OUTPUT, 'Request Id: '|| to_char(l_request_id));
383:
384:
387: Sources
388: -----------------------------------------------------------
389: */
390: IF l_debug_level > 0 THEN
391: oe_debug_pub.add( 'INSIDE NUM INSTANCES LOOP' ) ;
392: oe_debug_pub.add( 'BEFORE SOURCES LOOP' ) ;
393: END IF;
394:
395: OPEN l_source_cursor;
388: -----------------------------------------------------------
389: */
390: IF l_debug_level > 0 THEN
391: oe_debug_pub.add( 'INSIDE NUM INSTANCES LOOP' ) ;
392: oe_debug_pub.add( 'BEFORE SOURCES LOOP' ) ;
393: END IF;
394:
395: OPEN l_source_cursor;
396: LOOP
397: FETCH l_source_cursor
398: INTO l_order_source_id
399: ;
400: IF l_debug_level > 0 THEN
401: oe_debug_pub.add( 'SOURCE CURSOR VALUE = '||L_ORDER_SOURCE_ID ) ;
402: END IF;
403: EXIT WHEN l_source_cursor%NOTFOUND;
404:
405: /* -----------------------------------------------------------
405: /* -----------------------------------------------------------
406: Update Concurrent Request Ids
407: -----------------------------------------------------------
408: */
409: /* oe_debug_pub.add('No of orders in inf table');
410: SELECT COUNT(*) INTO l_ord_count
411: FROM oe_headers_iface_all
412: WHERE order_source_id = 1084
413: AND ( nvl(NULL,' ') = ' ' OR
417: (nvl(NULL,' ') <> ' ' AND
418: nvl(NULL,' ') = nvl(operation_code,' ')))
419: AND request_id IS NULL
420: AND nvl(error_flag,'N') = 'N';
421: oe_debug_pub.add('No of ord in inf table = '||l_ord_count);
422: oe_debug_pub.add('before updating concurrent request id');
423: */
424:
425: UPDATE oe_headers_interface
418: nvl(NULL,' ') = nvl(operation_code,' ')))
419: AND request_id IS NULL
420: AND nvl(error_flag,'N') = 'N';
421: oe_debug_pub.add('No of ord in inf table = '||l_ord_count);
422: oe_debug_pub.add('before updating concurrent request id');
423: */
424:
425: UPDATE oe_headers_interface
426: SET request_id = l_request_id
492: INTO l_row_count
493: FROM oe_headers_iface_all -- MOAC
494: WHERE request_id = l_request_id;
495: IF l_debug_level > 0 THEN
496: oe_debug_pub.add( 'ROW COUNT = '||L_ROW_COUNT ) ;
497: END IF;
498:
499: IF l_row_count = 0 THEN
500: fnd_file.put_line(FND_FILE.OUTPUT,'No orders to process');
518: l_mod := MOD(l_row_count,l_num_instances);
519: --batch_last := batch_size_all + MOD(l_row_count,l_num_instances);
520: END IF;
521: IF l_debug_level > 0 THEN
522: oe_debug_pub.add( 'BATCH SIZE = '||BATCH_SIZE_ALL ) ;
523: oe_debug_pub.add( 'MOD = '||L_MOD ) ;
524: END IF;
525:
526: IF l_num_instances > l_row_count THEN
519: --batch_last := batch_size_all + MOD(l_row_count,l_num_instances);
520: END IF;
521: IF l_debug_level > 0 THEN
522: oe_debug_pub.add( 'BATCH SIZE = '||BATCH_SIZE_ALL ) ;
523: oe_debug_pub.add( 'MOD = '||L_MOD ) ;
524: END IF;
525:
526: IF l_num_instances > l_row_count THEN
527: l_num_instances := l_row_count;
527: l_num_instances := l_row_count;
528: END IF;
529:
530: IF l_debug_level > 0 THEN
531: oe_debug_pub.add( 'NUM INSTANCES = '||L_NUM_INSTANCES ) ;
532: END IF;
533: FOR loop_counter IN 1..l_num_instances LOOP
534: IF l_debug_level > 0 THEN
535: oe_debug_pub.add( 'INSIDE FOR LOOP FOR SPAWNING CHILD REQ' ) ;
531: oe_debug_pub.add( 'NUM INSTANCES = '||L_NUM_INSTANCES ) ;
532: END IF;
533: FOR loop_counter IN 1..l_num_instances LOOP
534: IF l_debug_level > 0 THEN
535: oe_debug_pub.add( 'INSIDE FOR LOOP FOR SPAWNING CHILD REQ' ) ;
536: END IF;
537: batch_size := batch_size_all;
538: x_num_instances := 0;
539: -- x_new_request_id := new_request_id;
542: p_validate_only, p_debug_level, 0, NULL, NULL, NULL, p_perf_param,p_rtrim_data,
543: p_process_orders_with_null_org,p_default_org_id,p_validate_desc_flex);
544:
545: IF l_debug_level > 0 THEN
546: oe_debug_pub.add( 'CHILD REQUEST ID = '||NEW_REQUEST_ID ) ;
547: END IF;
548: fnd_file.put_line(FND_FILE.OUTPUT, 'Child Request ID: '||new_request_id);
549:
550: IF (new_request_id = 0) THEN
555: IF loop_counter <= l_mod THEN
556: batch_size := batch_size_all + 1;
557: END IF;
558: IF l_debug_level > 0 THEN
559: oe_debug_pub.add( 'BEFORE UPDATING REQ ID' ) ;
560: oe_debug_pub.add( 'LOOP COUNT = '||LOOP_COUNTER ) ;
561: oe_debug_pub.add( 'BATCH_SIZE_ALL = '||BATCH_SIZE_ALL ) ;
562: oe_debug_pub.add( 'BATCH_SIZE = '||BATCH_SIZE ) ;
563: END IF;
556: batch_size := batch_size_all + 1;
557: END IF;
558: IF l_debug_level > 0 THEN
559: oe_debug_pub.add( 'BEFORE UPDATING REQ ID' ) ;
560: oe_debug_pub.add( 'LOOP COUNT = '||LOOP_COUNTER ) ;
561: oe_debug_pub.add( 'BATCH_SIZE_ALL = '||BATCH_SIZE_ALL ) ;
562: oe_debug_pub.add( 'BATCH_SIZE = '||BATCH_SIZE ) ;
563: END IF;
564:
557: END IF;
558: IF l_debug_level > 0 THEN
559: oe_debug_pub.add( 'BEFORE UPDATING REQ ID' ) ;
560: oe_debug_pub.add( 'LOOP COUNT = '||LOOP_COUNTER ) ;
561: oe_debug_pub.add( 'BATCH_SIZE_ALL = '||BATCH_SIZE_ALL ) ;
562: oe_debug_pub.add( 'BATCH_SIZE = '||BATCH_SIZE ) ;
563: END IF;
564:
565: IF (p_perf_param = 'Y') THEN
558: IF l_debug_level > 0 THEN
559: oe_debug_pub.add( 'BEFORE UPDATING REQ ID' ) ;
560: oe_debug_pub.add( 'LOOP COUNT = '||LOOP_COUNTER ) ;
561: oe_debug_pub.add( 'BATCH_SIZE_ALL = '||BATCH_SIZE_ALL ) ;
562: oe_debug_pub.add( 'BATCH_SIZE = '||BATCH_SIZE ) ;
563: END IF;
564:
565: IF (p_perf_param = 'Y') THEN
566: -- only update one record
593: /* -----------------------------------------------------------
594: Headers
595: -----------------------------------------------------------
596: */
597: --oe_debug_pub.add('before headers loop');
598:
599: l_count_header := 0;
600: l_count_header_success := 0;
601: l_count_header_failure := 0;
602:
603: <
604:
605: IF l_debug_level > 0 THEN
606: oe_debug_pub.add( 'after goto') ;
607: END IF;
608:
609: -- if profile is set to 'Y' do updates in interface table based on
610: -- customer-inclusive key information
612:
613: if (l_customer_key_profile = 'Y') then
614:
615: IF l_debug_level > 0 THEN
616: oe_debug_pub.add( 'customer key profile was yes') ;
617: END IF;
618:
619:
620: -- start of customer inclusive request_id updates
631: = decode(p_perf_param, 'Y',
632: 'N', ' '); */ -- Bug 5205691
633:
634: IF l_debug_level > 0 THEN
635: oe_debug_pub.add('rows updated: ' || sql%rowcount);
636: END IF;
637:
638: COMMIT;
639:
667: 'N', ' '); */ -- Bug 5205691
668:
669:
670: IF l_debug_level > 0 THEN
671: oe_debug_pub.add('oe payments rows updated: ' || sql%rowcount);
672: END IF;
673:
674: COMMIT;
675:
775: -- been set already
776: If p_perf_param = 'Y' then
777: If l_looped_flag = 'N' then
778: IF l_debug_level > 0 THEN
779: oe_debug_pub.add('setting looped flag');
780: END IF;
781: l_looped_flag := 'Y';
782: End If;
783: End If;
782: End If;
783: End If;
784:
785: IF l_debug_level > 0 THEN
786: oe_debug_pub.add('Performance Parameter: ' || p_perf_param);
787: END IF;
788:
789: IF ( p_perf_param = 'Y') THEN
790:
798:
799: exception
800: when others then
801: IF l_debug_level > 0 THEN
802: oe_debug_pub.add('Unexpected error: '||sqlerrm);
803: END IF;
804: IF OE_MSG_PUB.Check_Msg_Level(OE_MSG_PUB.G_MSG_LVL_UNEXP_ERROR) THEN
805: OE_MSG_PUB.Add_Exc_Msg (G_PKG_NAME, 'Order_Import_Conc_Pgm');
806: END IF;
811:
812: end if;
813:
814: IF l_debug_level > 0 THEN
815: oe_debug_pub.add('first parent ' || l_pnt_request_id);
816: END IF;
817: END IF;
818:
819: --if customer_key_profile <> 'Y'
960:
961: l_count_header := l_count_header + 1;
962:
963: IF l_debug_level > 0 THEN
964: oe_debug_pub.add( 'ORDER SOURCE ID: '|| TO_CHAR ( L_ORDER_SOURCE_ID ) ) ;
965: oe_debug_pub.add( 'ORIG SYS REFERENCE: '|| L_ORIG_SYS_DOCUMENT_REF ) ;
966: oe_debug_pub.add( 'CHANGE SEQUENCE: ' || L_CHANGE_SEQUENCE ) ;
967: oe_debug_pub.add( 'ORG ID: '||l_org_id);
968: oe_debug_pub.add( 'L_RETURN_STATUS: ' || L_RETURN_STATUS ) ;
961: l_count_header := l_count_header + 1;
962:
963: IF l_debug_level > 0 THEN
964: oe_debug_pub.add( 'ORDER SOURCE ID: '|| TO_CHAR ( L_ORDER_SOURCE_ID ) ) ;
965: oe_debug_pub.add( 'ORIG SYS REFERENCE: '|| L_ORIG_SYS_DOCUMENT_REF ) ;
966: oe_debug_pub.add( 'CHANGE SEQUENCE: ' || L_CHANGE_SEQUENCE ) ;
967: oe_debug_pub.add( 'ORG ID: '||l_org_id);
968: oe_debug_pub.add( 'L_RETURN_STATUS: ' || L_RETURN_STATUS ) ;
969: END IF;
962:
963: IF l_debug_level > 0 THEN
964: oe_debug_pub.add( 'ORDER SOURCE ID: '|| TO_CHAR ( L_ORDER_SOURCE_ID ) ) ;
965: oe_debug_pub.add( 'ORIG SYS REFERENCE: '|| L_ORIG_SYS_DOCUMENT_REF ) ;
966: oe_debug_pub.add( 'CHANGE SEQUENCE: ' || L_CHANGE_SEQUENCE ) ;
967: oe_debug_pub.add( 'ORG ID: '||l_org_id);
968: oe_debug_pub.add( 'L_RETURN_STATUS: ' || L_RETURN_STATUS ) ;
969: END IF;
970:
963: IF l_debug_level > 0 THEN
964: oe_debug_pub.add( 'ORDER SOURCE ID: '|| TO_CHAR ( L_ORDER_SOURCE_ID ) ) ;
965: oe_debug_pub.add( 'ORIG SYS REFERENCE: '|| L_ORIG_SYS_DOCUMENT_REF ) ;
966: oe_debug_pub.add( 'CHANGE SEQUENCE: ' || L_CHANGE_SEQUENCE ) ;
967: oe_debug_pub.add( 'ORG ID: '||l_org_id);
968: oe_debug_pub.add( 'L_RETURN_STATUS: ' || L_RETURN_STATUS ) ;
969: END IF;
970:
971: -- MOAC set the policy context based on the org_id
964: oe_debug_pub.add( 'ORDER SOURCE ID: '|| TO_CHAR ( L_ORDER_SOURCE_ID ) ) ;
965: oe_debug_pub.add( 'ORIG SYS REFERENCE: '|| L_ORIG_SYS_DOCUMENT_REF ) ;
966: oe_debug_pub.add( 'CHANGE SEQUENCE: ' || L_CHANGE_SEQUENCE ) ;
967: oe_debug_pub.add( 'ORG ID: '||l_org_id);
968: oe_debug_pub.add( 'L_RETURN_STATUS: ' || L_RETURN_STATUS ) ;
969: END IF;
970:
971: -- MOAC set the policy context based on the org_id
972: If G_ORG_ID IS NULL THEN
982: /* -----------------------------------------------------------
983: Call Import_Order procedure
984: -----------------------------------------------------------
985: */
986: --oe_debug_pub.add('before calling Import_Order procedure');
987:
988:
989: IF l_closed_flag = 'N' THEN
990: --
988:
989: IF l_closed_flag = 'N' THEN
990: --
991: IF l_debug_level > 0 THEN
992: oe_debug_pub.add( 'BEFORE CALLING IMPORT_ORDER PROCEDURE' ) ;
993: oe_debug_pub.add('rtrim data ='||nvl(l_rtrim_data,'Null'));
994: END IF;
995: OE_ORDER_IMPORT_PVT.Import_Order (
996: p_request_id => l_request_id,
989: IF l_closed_flag = 'N' THEN
990: --
991: IF l_debug_level > 0 THEN
992: oe_debug_pub.add( 'BEFORE CALLING IMPORT_ORDER PROCEDURE' ) ;
993: oe_debug_pub.add('rtrim data ='||nvl(l_rtrim_data,'Null'));
994: END IF;
995: OE_ORDER_IMPORT_PVT.Import_Order (
996: p_request_id => l_request_id,
997: p_order_source_id => l_order_source_id,
1011:
1012: ELSE
1013: --
1014: IF l_debug_level > 0 THEN
1015: oe_debug_pub.add( 'BEFORE CALLING IMPORT_ORDER PROCEDURE FOR CLOSED' ) ;
1016: END IF;
1017: OE_CNCL_ORDER_IMPORT_PVT.Import_Order (
1018: p_request_id => l_request_id,
1019: p_order_source_id => l_order_source_id,
1030: );
1031: --
1032: END IF;
1033:
1034: --oe_debug_pub.add('after call Import_Order l_return_status ' || l_return_status);
1035: IF l_return_status = FND_API.G_RET_STS_ERROR OR
1036: l_return_status = FND_API.G_RET_STS_UNEXP_ERROR
1037: THEN
1038: l_count_header_failure := l_count_header_failure + 1;
1043:
1044: IF (p_perf_param = 'Y') THEN
1045:
1046: IF l_debug_level > 0 THEN
1047: oe_debug_pub.add('after order_import for docref='|| l_orig_sys_document_ref || ' and request_id ' || l_request_id);
1048: oe_debug_pub.add('parent request_id:' || l_pnt_request_id);
1049: END IF;
1050:
1051:
1044: IF (p_perf_param = 'Y') THEN
1045:
1046: IF l_debug_level > 0 THEN
1047: oe_debug_pub.add('after order_import for docref='|| l_orig_sys_document_ref || ' and request_id ' || l_request_id);
1048: oe_debug_pub.add('parent request_id:' || l_pnt_request_id);
1049: END IF;
1050:
1051:
1052: begin
1069:
1070:
1071: if sql%rowcount > 0 then
1072: IF l_debug_level > 0 THEN
1073: oe_debug_pub.add('rowcount:' || sql%rowcount || ' updated docref:' || l_updated_docref);
1074: END IF;
1075: commit;
1076: exit;
1077: end if;
1079: end loop;
1080:
1081: close l_request_cursor;
1082: IF l_debug_level > 0 THEN
1083: oe_debug_pub.add('after cursor closed');
1084: END IF;
1085: goto dist;
1086:
1087: exception
1086:
1087: exception
1088: when no_data_found then
1089: IF l_debug_level > 0 THEN
1090: oe_debug_pub.add('In handled no data found exception');
1091: oe_debug_pub.add('No more records to process');
1092: END IF;
1093:
1094: EXIT;
1087: exception
1088: when no_data_found then
1089: IF l_debug_level > 0 THEN
1090: oe_debug_pub.add('In handled no data found exception');
1091: oe_debug_pub.add('No more records to process');
1092: END IF;
1093:
1094: EXIT;
1095: when others then
1093:
1094: EXIT;
1095: when others then
1096: IF l_debug_level > 0 THEN
1097: oe_debug_pub.add('others exception when attempting update' ||sqlerrm);
1098: END IF;
1099: IF OE_MSG_PUB.Check_Msg_Level(OE_MSG_PUB.G_MSG_LVL_UNEXP_ERROR) THEN
1100: OE_MSG_PUB.Add_Exc_Msg (G_PKG_NAME, 'Order_Import_Conc_Pgm');
1101: END IF;
1110:
1111: CLOSE l_request_cursor;
1112:
1113: IF l_debug_level > 0 THEN
1114: oe_debug_pub.add( 'NO. OF ORDERS FOUND: ' || L_COUNT_HEADER ) ;
1115: oe_debug_pub.add( 'NO. OF ORDERS IMPORTED: '|| L_COUNT_HEADER_SUCCESS ) ;
1116: oe_debug_pub.add( 'NO. OF ORDERS FAILED: ' || L_COUNT_HEADER_FAILURE ) ;
1117: END IF;
1118:
1111: CLOSE l_request_cursor;
1112:
1113: IF l_debug_level > 0 THEN
1114: oe_debug_pub.add( 'NO. OF ORDERS FOUND: ' || L_COUNT_HEADER ) ;
1115: oe_debug_pub.add( 'NO. OF ORDERS IMPORTED: '|| L_COUNT_HEADER_SUCCESS ) ;
1116: oe_debug_pub.add( 'NO. OF ORDERS FAILED: ' || L_COUNT_HEADER_FAILURE ) ;
1117: END IF;
1118:
1119: fnd_file.put_line(FND_FILE.OUTPUT,'No. of orders found: ' ||
1112:
1113: IF l_debug_level > 0 THEN
1114: oe_debug_pub.add( 'NO. OF ORDERS FOUND: ' || L_COUNT_HEADER ) ;
1115: oe_debug_pub.add( 'NO. OF ORDERS IMPORTED: '|| L_COUNT_HEADER_SUCCESS ) ;
1116: oe_debug_pub.add( 'NO. OF ORDERS FAILED: ' || L_COUNT_HEADER_FAILURE ) ;
1117: END IF;
1118:
1119: fnd_file.put_line(FND_FILE.OUTPUT,'No. of orders found: ' ||
1120: l_count_header);
1138: Messages
1139: -----------------------------------------------------------
1140: */
1141: IF l_debug_level > 0 THEN
1142: oe_debug_pub.add( 'BEFORE MESSAGES LOOP' ) ;
1143: END IF;
1144:
1145: fnd_file.put_line(FND_FILE.OUTPUT,'');
1146: fnd_file.put_line(FND_FILE.OUTPUT,'Source/Order/Seq/Line Message');
1170: End of Order_Import_Conc_Pgm
1171: -----------------------------------------------------------
1172: */
1173: IF l_debug_level > 0 THEN
1174: oe_debug_pub.add( 'END OF ORDER IMPORT CONCURRENT PROGRAM' ) ;
1175: END IF;
1176: fnd_file.put_line(FND_FILE.OUTPUT, 'End of Order Import Concurrent Program');
1177: retcode := 0;
1178: --return;
1179:
1180: EXCEPTION
1181: WHEN OTHERS THEN
1182: IF l_debug_level > 0 THEN
1183: oe_debug_pub.add( 'UNEXPECTED ERROR: '||SQLERRM ) ;
1184: END IF;
1185: IF OE_MSG_PUB.Check_Msg_Level(OE_MSG_PUB.G_MSG_LVL_UNEXP_ERROR) THEN
1186: OE_MSG_PUB.Add_Exc_Msg (G_PKG_NAME, 'Import_Order');
1187: END IF;
1221:
1222: l_closed_flag VARCHAR2(1) DEFAULT 'N';
1223:
1224: --
1225: l_debug_level CONSTANT NUMBER := oe_debug_pub.g_debug_level;
1226: --
1227: BEGIN
1228:
1229:
1229:
1230: --MOAC set policy context for single Org
1231: IF p_org_id IS NOT NULL THEN
1232: IF l_debug_level > 0 THEN
1233: oe_debug_pub.add( 'Setting policy context to single-org' ) ;
1234: END IF;
1235: MO_GLOBAL.set_policy_context('S',p_org_id);
1236: END IF;
1237:
1250:
1251: IF (NVL(l_closed_flag,'N') = 'N') THEN
1252: --
1253: IF l_debug_level > 0 THEN
1254: oe_debug_pub.add( 'BEFORE CALLING IMPORT_ORDER PROCEDURE' ) ;
1255: END IF;
1256:
1257:
1258: OE_ORDER_IMPORT_PVT.Import_Order (
1274:
1275: ELSE
1276: --
1277: IF l_debug_level > 0 THEN
1278: oe_debug_pub.add( 'BEFORE CALLING IMPORT_ORDER PROCEDURE FOR CLOSED' ) ;
1279: END IF;
1280:
1281:
1282: OE_CNCL_ORDER_IMPORT_PVT.Import_Order (