51: AND process_status = 'R';
52: COMMIT;
53:
54: IF(l_debug_level>1) THEN
55: FND_File.Put_Line(Fnd_File.LOG,'Invoking Pre-processor');
56: END IF;
57:
58: LOOP
59: OPEN syncup_instance_cur;
82: x_error_msg => l_error_message
83: );
84: IF l_return_status <> FND_API.G_RET_STS_SUCCESS THEN
85: IF(l_debug_level>1) THEN
86: FND_File.Put_Line(Fnd_File.LOG,'Error : '||l_error_message);
87: end if;
88: RAISE fnd_api.g_exc_error;
89: END IF;
90:
96: x_error_msg => l_error_message
97: );
98: IF l_return_status <> FND_API.G_RET_STS_SUCCESS THEN
99: IF(l_debug_level>1) THEN
100: FND_File.Put_Line(Fnd_File.LOG,'Error : '||l_error_message);
101: END IF;
102: RAISE fnd_api.g_exc_error;
103: END IF;
104:
258: -- Step 1: Run the create process to create all instances in the
259: -- Interface Tables.
260:
261: IF(l_debug_level>1) THEN
262: FND_File.Put_Line(Fnd_File.LOG,'Calling Process_iface_txns: ');
263: END IF;
264: CSI_ML_interface_txn_pvt.process_iface_txns(l_error_message,
265: l_return_status,
266: p_txn_from_date,
275:
276: EXCEPTION
277: WHEN fnd_api.g_exc_error THEN
278: IF(l_debug_level>1) THEN
279: FND_File.Put_Line(Fnd_File.LOG,l_error_message);
280: END IF;
281:
282:
283: WHEN others THEN
284: l_sql_error := SQLERRM;
285: fnd_message.set_name('CSI','CSI_ML_UNEXP_SQL_ERROR');
286: fnd_message.set_token('API_NAME',l_api_name);
287: fnd_message.set_token('SQL_ERROR',SQLERRM);
288: FND_File.Put_Line(Fnd_File.LOG,'CSI_ML_PROGRAM_PUB.execute_openinterface - Into when others exception ');
289:
290:
291: END execute_openinterface;
292:
393: BEGIN
394:
395: req_data:= fnd_conc_global.request_data;
396: IF(l_debug_level>1) THEN
397: FND_File.Put_Line(Fnd_File.LOG,'Value of req_data is :'||req_data);
398: END IF;
399: IF req_data IS NULL
400: THEN
401: -- Since req_data is null, I'll assume this is the first run.
471: IF NOT l_return_status = l_fnd_success THEN
472: RAISE fnd_api.g_exc_error;
473: END IF;
474: IF(l_debug_level>1) THEN
475: FND_File.Put_Line(Fnd_File.LOG,'Begin Execute paralle create: '||p_worker_count);
476: END IF;
477: -- x_return_status := l_fnd_success;
478:
479: -- If the worker number is not provided default to 32
478:
479: -- If the worker number is not provided default to 32
480:
481: IF(l_debug_level>1) THEN
482: FND_File.Put_Line(Fnd_File.LOG,'p_worker_count: '||p_worker_count);
483: END IF;
484: IF (p_worker_count is NULL OR
485: p_worker_count > 32) THEN
486: l_worker_count := 32;
549: l_tbl_count := 0;
550: l_tbl_count := l_inst_id_tbl.count;
551:
552: IF(l_debug_level>1) THEN
553: FND_File.Put_Line(Fnd_File.LOG,'Records In Table: '||l_tbl_count);
554: END IF;
555:
556: -- Now that the parallel_worker_id column is updated and committed
557: -- we can run the create procedure using multiple concurrent workers
560: -- Set FND security valiables
561: END LOOP;
562:
563: IF(l_debug_level>1) THEN
564: FND_File.Put_Line(Fnd_File.LOG,'Before apps initialize: ');
565: END IF;
566:
567: OPEN candidates_exist_cur;
568: FETCH candidates_exist_cur INTO l_dummy;
575: THEN
576: FOR l_count in 1..l_worker_count LOOP
577:
578: IF(l_debug_level>1) THEN
579: FND_File.Put_Line(Fnd_File.LOG,'Before submit request: ');
580: END IF;
581: l_request_id := FND_REQUEST.SUBMIT_REQUEST
582: ('CSI',
583: 'CSIMCPAW',
590: l_count, -- Argument4 Worker ID
591: p_resolve_ids); -- Resolve IDS
592:
593: IF(l_debug_level>1) THEN
594: FND_File.Put_Line(Fnd_File.LOG,'Calling Open Interface Parallel Instance Creation Process');
595: FND_File.Put_Line(Fnd_File.LOG,'Request ID: '||l_request_id||' has been submitted');
596: FND_File.Put_Line(Fnd_File.LOG,'');
597: END IF;
598:
591: p_resolve_ids); -- Resolve IDS
592:
593: IF(l_debug_level>1) THEN
594: FND_File.Put_Line(Fnd_File.LOG,'Calling Open Interface Parallel Instance Creation Process');
595: FND_File.Put_Line(Fnd_File.LOG,'Request ID: '||l_request_id||' has been submitted');
596: FND_File.Put_Line(Fnd_File.LOG,'');
597: END IF;
598:
599: IF (l_request_id = 0) THEN
592:
593: IF(l_debug_level>1) THEN
594: FND_File.Put_Line(Fnd_File.LOG,'Calling Open Interface Parallel Instance Creation Process');
595: FND_File.Put_Line(Fnd_File.LOG,'Request ID: '||l_request_id||' has been submitted');
596: FND_File.Put_Line(Fnd_File.LOG,'');
597: END IF;
598:
599: IF (l_request_id = 0) THEN
600: l_req_count:=l_req_count+1;
599: IF (l_request_id = 0) THEN
600: l_req_count:=l_req_count+1;
601: l_errbuf := FND_MESSAGE.GET;
602: IF(l_debug_level>1) THEN
603: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,76,150));
604: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,151,225));
605: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,226,300));
606: END IF;
607: END IF;
600: l_req_count:=l_req_count+1;
601: l_errbuf := FND_MESSAGE.GET;
602: IF(l_debug_level>1) THEN
603: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,76,150));
604: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,151,225));
605: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,226,300));
606: END IF;
607: END IF;
608: COMMIT;
601: l_errbuf := FND_MESSAGE.GET;
602: IF(l_debug_level>1) THEN
603: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,76,150));
604: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,151,225));
605: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,226,300));
606: END IF;
607: END IF;
608: COMMIT;
609: END LOOP;
610:
611: IF l_req_count>0
612: THEN
613: IF(l_debug_level>1) THEN
614: fnd_file.put_line(FND_FILE.OUTPUT,'--------------------------------------------------------------------------');
615: fnd_file.put_line(FND_FILE.OUTPUT,' PARALLEL WORKER SUBMISSION ERROR ');
616: fnd_file.put_line(FND_FILE.OUTPUT,'--------------------------------------------------------------------------');
617: fnd_file.put_line(FND_FILE.OUTPUT,'One or more sub-requests/parallel workers were not submitted successfully.');
618: fnd_file.put_line(FND_FILE.OUTPUT,'--------------------------------------------------------------------------');
611: IF l_req_count>0
612: THEN
613: IF(l_debug_level>1) THEN
614: fnd_file.put_line(FND_FILE.OUTPUT,'--------------------------------------------------------------------------');
615: fnd_file.put_line(FND_FILE.OUTPUT,' PARALLEL WORKER SUBMISSION ERROR ');
616: fnd_file.put_line(FND_FILE.OUTPUT,'--------------------------------------------------------------------------');
617: fnd_file.put_line(FND_FILE.OUTPUT,'One or more sub-requests/parallel workers were not submitted successfully.');
618: fnd_file.put_line(FND_FILE.OUTPUT,'--------------------------------------------------------------------------');
619: END IF;
612: THEN
613: IF(l_debug_level>1) THEN
614: fnd_file.put_line(FND_FILE.OUTPUT,'--------------------------------------------------------------------------');
615: fnd_file.put_line(FND_FILE.OUTPUT,' PARALLEL WORKER SUBMISSION ERROR ');
616: fnd_file.put_line(FND_FILE.OUTPUT,'--------------------------------------------------------------------------');
617: fnd_file.put_line(FND_FILE.OUTPUT,'One or more sub-requests/parallel workers were not submitted successfully.');
618: fnd_file.put_line(FND_FILE.OUTPUT,'--------------------------------------------------------------------------');
619: END IF;
620: END IF;
613: IF(l_debug_level>1) THEN
614: fnd_file.put_line(FND_FILE.OUTPUT,'--------------------------------------------------------------------------');
615: fnd_file.put_line(FND_FILE.OUTPUT,' PARALLEL WORKER SUBMISSION ERROR ');
616: fnd_file.put_line(FND_FILE.OUTPUT,'--------------------------------------------------------------------------');
617: fnd_file.put_line(FND_FILE.OUTPUT,'One or more sub-requests/parallel workers were not submitted successfully.');
618: fnd_file.put_line(FND_FILE.OUTPUT,'--------------------------------------------------------------------------');
619: END IF;
620: END IF;
621:
614: fnd_file.put_line(FND_FILE.OUTPUT,'--------------------------------------------------------------------------');
615: fnd_file.put_line(FND_FILE.OUTPUT,' PARALLEL WORKER SUBMISSION ERROR ');
616: fnd_file.put_line(FND_FILE.OUTPUT,'--------------------------------------------------------------------------');
617: fnd_file.put_line(FND_FILE.OUTPUT,'One or more sub-requests/parallel workers were not submitted successfully.');
618: fnd_file.put_line(FND_FILE.OUTPUT,'--------------------------------------------------------------------------');
619: END IF;
620: END IF;
621:
622: IF(l_debug_level>1) THEN
619: END IF;
620: END IF;
621:
622: IF(l_debug_level>1) THEN
623: FND_File.Put_Line(Fnd_File.LOG,'Note : Please check the request "view log" of all the child processors for any un-expected error messages.');
624: END IF;
625: -- All the child requests were successfully requested.
626: -- Now I'll put the parent program to sleep/paused state.
627: req_data:=to_char(l_old_error);
627: req_data:=to_char(l_old_error);
628: fnd_conc_global.set_req_globals (conc_status => 'PAUSED',
629: request_data => req_data);
630: IF(l_debug_level>1) THEN
631: FND_File.Put_Line(Fnd_File.LOG,'Value of request_data that was passed to fnd_conc_global.set_req_globals is: '||FND_CONC_GLOBAL.request_data);
632: END IF;
633: errbuf := 'sub-requests submitted';
634: retcode := 0;
635: return;
648: END;
649:
650: IF l_rel_count>0
651: THEN
652: FND_File.Put_Line(Fnd_File.LOG,'l_rel_count <> zero');
653: FND_File.Put_Line(Fnd_File.LOG,'Begin - parallel creation of relationships: '||p_worker_count);
654: FND_File.Put_Line(Fnd_File.LOG,'p_worker_count: '||p_worker_count);
655: IF (p_worker_count IS NULL OR
656: p_worker_count > 32)
649:
650: IF l_rel_count>0
651: THEN
652: FND_File.Put_Line(Fnd_File.LOG,'l_rel_count <> zero');
653: FND_File.Put_Line(Fnd_File.LOG,'Begin - parallel creation of relationships: '||p_worker_count);
654: FND_File.Put_Line(Fnd_File.LOG,'p_worker_count: '||p_worker_count);
655: IF (p_worker_count IS NULL OR
656: p_worker_count > 32)
657: THEN
650: IF l_rel_count>0
651: THEN
652: FND_File.Put_Line(Fnd_File.LOG,'l_rel_count <> zero');
653: FND_File.Put_Line(Fnd_File.LOG,'Begin - parallel creation of relationships: '||p_worker_count);
654: FND_File.Put_Line(Fnd_File.LOG,'p_worker_count: '||p_worker_count);
655: IF (p_worker_count IS NULL OR
656: p_worker_count > 32)
657: THEN
658: l_r_worker_count := 32;
682: COMMIT;
683: END LOOP;
684:
685: IF(l_debug_level>1) THEN
686: FND_File.Put_Line(Fnd_File.LOG,'Before calling csi_ml_util_pvt.resolve_rel_ids');
687: END IF;
688: -- To resolve id columns
689: csi_ml_util_pvt.resolve_rel_ids
690: (p_source_system => p_source_system_name
693: ,x_return_status => l_return_status
694: ,x_error_message => l_error_message
695: );
696: IF(l_debug_level>1) THEN
697: FND_File.Put_Line(Fnd_File.LOG,'After calling csi_ml_util_pvt.resolve_rel_ids');
698: END IF;
699:
700: csi_ml_util_pvt.eliminate_dup_records;
701: csi_ml_util_pvt.eliminate_dup_subject;
713: THEN
714: FOR l_count in 1..l_r_worker_count
715: LOOP
716: IF(l_debug_level>1) THEN
717: FND_File.Put_Line(Fnd_File.LOG,'Before submitting request for relationships: ');
718: FND_File.Put_Line(Fnd_File.LOG,'Start time in validate mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
719: END IF;
720: l_request_id := FND_REQUEST.SUBMIT_REQUEST
721: ( 'CSI'
714: FOR l_count in 1..l_r_worker_count
715: LOOP
716: IF(l_debug_level>1) THEN
717: FND_File.Put_Line(Fnd_File.LOG,'Before submitting request for relationships: ');
718: FND_File.Put_Line(Fnd_File.LOG,'Start time in validate mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
719: END IF;
720: l_request_id := FND_REQUEST.SUBMIT_REQUEST
721: ( 'CSI'
722: ,'CSIMCREL'
729: ,p_txn_to_date
730: ,p_source_system_name
731: );
732: IF(l_debug_level>1) THEN
733: FND_File.Put_Line(Fnd_File.LOG,'End time in validate mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
734: FND_File.Put_Line(Fnd_File.LOG,'Calling Open Interface Parallel Relationship Creation Process');
735: FND_File.Put_Line(Fnd_File.LOG,'Request ID: '||l_request_id||' has been submitted');
736: FND_File.Put_Line(Fnd_File.LOG,'');
737: END IF;
730: ,p_source_system_name
731: );
732: IF(l_debug_level>1) THEN
733: FND_File.Put_Line(Fnd_File.LOG,'End time in validate mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
734: FND_File.Put_Line(Fnd_File.LOG,'Calling Open Interface Parallel Relationship Creation Process');
735: FND_File.Put_Line(Fnd_File.LOG,'Request ID: '||l_request_id||' has been submitted');
736: FND_File.Put_Line(Fnd_File.LOG,'');
737: END IF;
738:
731: );
732: IF(l_debug_level>1) THEN
733: FND_File.Put_Line(Fnd_File.LOG,'End time in validate mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
734: FND_File.Put_Line(Fnd_File.LOG,'Calling Open Interface Parallel Relationship Creation Process');
735: FND_File.Put_Line(Fnd_File.LOG,'Request ID: '||l_request_id||' has been submitted');
736: FND_File.Put_Line(Fnd_File.LOG,'');
737: END IF;
738:
739: IF (l_request_id = 0) THEN
732: IF(l_debug_level>1) THEN
733: FND_File.Put_Line(Fnd_File.LOG,'End time in validate mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
734: FND_File.Put_Line(Fnd_File.LOG,'Calling Open Interface Parallel Relationship Creation Process');
735: FND_File.Put_Line(Fnd_File.LOG,'Request ID: '||l_request_id||' has been submitted');
736: FND_File.Put_Line(Fnd_File.LOG,'');
737: END IF;
738:
739: IF (l_request_id = 0) THEN
740: l_req_count:=l_req_count+1;
739: IF (l_request_id = 0) THEN
740: l_req_count:=l_req_count+1;
741: l_errbuf := FND_MESSAGE.GET;
742: IF(l_debug_level>1) THEN
743: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,76,150));
744: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,151,225));
745: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,226,300));
746: END IF;
747: END IF;
740: l_req_count:=l_req_count+1;
741: l_errbuf := FND_MESSAGE.GET;
742: IF(l_debug_level>1) THEN
743: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,76,150));
744: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,151,225));
745: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,226,300));
746: END IF;
747: END IF;
748: COMMIT;
741: l_errbuf := FND_MESSAGE.GET;
742: IF(l_debug_level>1) THEN
743: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,76,150));
744: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,151,225));
745: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,226,300));
746: END IF;
747: END IF;
748: COMMIT;
749: END LOOP;
757: RETURN;
758: ELSE
759:
760: IF(l_debug_level>1) THEN
761: FND_File.Put_Line(Fnd_File.LOG,'No candidate records in the interface tables: ');
762: END IF;
763: l_old_error:=0;
764: l_new_error:=0;
765: errbuf := 'Done!';
772:
773: ELSE
774:
775: IF(l_debug_level>1) THEN
776: FND_File.Put_Line(Fnd_File.LOG,'Start time RELATIONSHIP: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
777: END IF;
778: -- Added for relationship interface
779: BEGIN
780: SELECT COUNT(*)
787: WHEN NO_DATA_FOUND THEN
788: l_rel_count :=0;
789: END;
790: IF(l_debug_level>1) THEN
791: FND_File.Put_Line(Fnd_File.LOG,'Value of l_rel_count is: '||l_rel_count);
792: END IF;
793: BEGIN
794: SELECT COUNT(*)
795: INTO l_valid_count
802: WHEN NO_DATA_FOUND THEN
803: l_valid_count :=0;
804: END;
805: IF(l_debug_level>1) THEN
806: FND_File.Put_Line(Fnd_File.LOG,'Value of l_valid_count is: '||l_valid_count);
807: END IF;
808: BEGIN
809: SELECT COUNT(*)
810: INTO l_update_count
818: l_update_count :=0;
819: END;
820:
821: IF(l_debug_level>1) THEN
822: FND_File.Put_Line(Fnd_File.LOG,'Value of l_valid_count is: '||l_valid_count);
823: END IF;
824:
825: BEGIN
826: SELECT COUNT(*)
834: WHEN NO_DATA_FOUND THEN
835: l_insert_count :=0;
836: END;
837: IF(l_debug_level>1) THEN
838: FND_File.Put_Line(Fnd_File.LOG,'Value of l_insert_count is: '||l_insert_count);
839: END IF;
840: -- End addition for relationship interface
841: IF ( l_rel_count = 0
842: AND l_valid_count = 0
843: AND l_update_count = 0
844: AND l_insert_count = 0 )
845: THEN
846: IF(l_debug_level>1) THEN
847: FND_File.Put_Line(Fnd_File.LOG,'Values for l_rel_count l_valid_count l_update_count and l_insert_count are zero');
848: END IF;
849:
850: -- Parent program wakes up after successful completion of child programs.
851: l_old_error:=to_number(req_data);
866:
867: IF l_new_error>l_old_error
868: THEN
869: -- I found that there were some new errors for the current run.
870: --FND_File.Put_Line(Fnd_File.LOG,'Total error records in interface table before submission of program are :'||l_old_error);
871: --FND_File.Put_Line(Fnd_File.LOG,'Total error records in interface table after submission of program are :'||l_new_error);
872: IF(l_debug_level>1) THEN
873: fnd_file.put_line(FND_FILE.OUTPUT,' ');
874: fnd_file.put_line(FND_FILE.OUTPUT,' ');
867: IF l_new_error>l_old_error
868: THEN
869: -- I found that there were some new errors for the current run.
870: --FND_File.Put_Line(Fnd_File.LOG,'Total error records in interface table before submission of program are :'||l_old_error);
871: --FND_File.Put_Line(Fnd_File.LOG,'Total error records in interface table after submission of program are :'||l_new_error);
872: IF(l_debug_level>1) THEN
873: fnd_file.put_line(FND_FILE.OUTPUT,' ');
874: fnd_file.put_line(FND_FILE.OUTPUT,' ');
875: fnd_file.put_line(FND_FILE.OUTPUT,' ');
869: -- I found that there were some new errors for the current run.
870: --FND_File.Put_Line(Fnd_File.LOG,'Total error records in interface table before submission of program are :'||l_old_error);
871: --FND_File.Put_Line(Fnd_File.LOG,'Total error records in interface table after submission of program are :'||l_new_error);
872: IF(l_debug_level>1) THEN
873: fnd_file.put_line(FND_FILE.OUTPUT,' ');
874: fnd_file.put_line(FND_FILE.OUTPUT,' ');
875: fnd_file.put_line(FND_FILE.OUTPUT,' ');
876: fnd_file.put_line(FND_FILE.OUTPUT,'-----------------------------------------------------------------------------------');
877: fnd_file.put_line(FND_FILE.OUTPUT,' OPEN INTERFACE - PARALLEL WORKER ERROR RECORDS ');
870: --FND_File.Put_Line(Fnd_File.LOG,'Total error records in interface table before submission of program are :'||l_old_error);
871: --FND_File.Put_Line(Fnd_File.LOG,'Total error records in interface table after submission of program are :'||l_new_error);
872: IF(l_debug_level>1) THEN
873: fnd_file.put_line(FND_FILE.OUTPUT,' ');
874: fnd_file.put_line(FND_FILE.OUTPUT,' ');
875: fnd_file.put_line(FND_FILE.OUTPUT,' ');
876: fnd_file.put_line(FND_FILE.OUTPUT,'-----------------------------------------------------------------------------------');
877: fnd_file.put_line(FND_FILE.OUTPUT,' OPEN INTERFACE - PARALLEL WORKER ERROR RECORDS ');
878: fnd_file.put_line(FND_FILE.OUTPUT,'-----------------------------------------------------------------------------------');
871: --FND_File.Put_Line(Fnd_File.LOG,'Total error records in interface table after submission of program are :'||l_new_error);
872: IF(l_debug_level>1) THEN
873: fnd_file.put_line(FND_FILE.OUTPUT,' ');
874: fnd_file.put_line(FND_FILE.OUTPUT,' ');
875: fnd_file.put_line(FND_FILE.OUTPUT,' ');
876: fnd_file.put_line(FND_FILE.OUTPUT,'-----------------------------------------------------------------------------------');
877: fnd_file.put_line(FND_FILE.OUTPUT,' OPEN INTERFACE - PARALLEL WORKER ERROR RECORDS ');
878: fnd_file.put_line(FND_FILE.OUTPUT,'-----------------------------------------------------------------------------------');
879: fnd_file.put_line(FND_FILE.OUTPUT,to_number(l_new_error-l_old_error)||' records were completed with error. Please check the instance interface table');
872: IF(l_debug_level>1) THEN
873: fnd_file.put_line(FND_FILE.OUTPUT,' ');
874: fnd_file.put_line(FND_FILE.OUTPUT,' ');
875: fnd_file.put_line(FND_FILE.OUTPUT,' ');
876: fnd_file.put_line(FND_FILE.OUTPUT,'-----------------------------------------------------------------------------------');
877: fnd_file.put_line(FND_FILE.OUTPUT,' OPEN INTERFACE - PARALLEL WORKER ERROR RECORDS ');
878: fnd_file.put_line(FND_FILE.OUTPUT,'-----------------------------------------------------------------------------------');
879: fnd_file.put_line(FND_FILE.OUTPUT,to_number(l_new_error-l_old_error)||' records were completed with error. Please check the instance interface table');
880: fnd_file.put_line(FND_FILE.OUTPUT,' for detailed error message.');
873: fnd_file.put_line(FND_FILE.OUTPUT,' ');
874: fnd_file.put_line(FND_FILE.OUTPUT,' ');
875: fnd_file.put_line(FND_FILE.OUTPUT,' ');
876: fnd_file.put_line(FND_FILE.OUTPUT,'-----------------------------------------------------------------------------------');
877: fnd_file.put_line(FND_FILE.OUTPUT,' OPEN INTERFACE - PARALLEL WORKER ERROR RECORDS ');
878: fnd_file.put_line(FND_FILE.OUTPUT,'-----------------------------------------------------------------------------------');
879: fnd_file.put_line(FND_FILE.OUTPUT,to_number(l_new_error-l_old_error)||' records were completed with error. Please check the instance interface table');
880: fnd_file.put_line(FND_FILE.OUTPUT,' for detailed error message.');
881: fnd_file.put_line(FND_FILE.OUTPUT,'-----------------------------------------------------------------------------------');
874: fnd_file.put_line(FND_FILE.OUTPUT,' ');
875: fnd_file.put_line(FND_FILE.OUTPUT,' ');
876: fnd_file.put_line(FND_FILE.OUTPUT,'-----------------------------------------------------------------------------------');
877: fnd_file.put_line(FND_FILE.OUTPUT,' OPEN INTERFACE - PARALLEL WORKER ERROR RECORDS ');
878: fnd_file.put_line(FND_FILE.OUTPUT,'-----------------------------------------------------------------------------------');
879: fnd_file.put_line(FND_FILE.OUTPUT,to_number(l_new_error-l_old_error)||' records were completed with error. Please check the instance interface table');
880: fnd_file.put_line(FND_FILE.OUTPUT,' for detailed error message.');
881: fnd_file.put_line(FND_FILE.OUTPUT,'-----------------------------------------------------------------------------------');
882: END IF;
875: fnd_file.put_line(FND_FILE.OUTPUT,' ');
876: fnd_file.put_line(FND_FILE.OUTPUT,'-----------------------------------------------------------------------------------');
877: fnd_file.put_line(FND_FILE.OUTPUT,' OPEN INTERFACE - PARALLEL WORKER ERROR RECORDS ');
878: fnd_file.put_line(FND_FILE.OUTPUT,'-----------------------------------------------------------------------------------');
879: fnd_file.put_line(FND_FILE.OUTPUT,to_number(l_new_error-l_old_error)||' records were completed with error. Please check the instance interface table');
880: fnd_file.put_line(FND_FILE.OUTPUT,' for detailed error message.');
881: fnd_file.put_line(FND_FILE.OUTPUT,'-----------------------------------------------------------------------------------');
882: END IF;
883: l_old_error:=0;
876: fnd_file.put_line(FND_FILE.OUTPUT,'-----------------------------------------------------------------------------------');
877: fnd_file.put_line(FND_FILE.OUTPUT,' OPEN INTERFACE - PARALLEL WORKER ERROR RECORDS ');
878: fnd_file.put_line(FND_FILE.OUTPUT,'-----------------------------------------------------------------------------------');
879: fnd_file.put_line(FND_FILE.OUTPUT,to_number(l_new_error-l_old_error)||' records were completed with error. Please check the instance interface table');
880: fnd_file.put_line(FND_FILE.OUTPUT,' for detailed error message.');
881: fnd_file.put_line(FND_FILE.OUTPUT,'-----------------------------------------------------------------------------------');
882: END IF;
883: l_old_error:=0;
884: l_new_error:=0;
877: fnd_file.put_line(FND_FILE.OUTPUT,' OPEN INTERFACE - PARALLEL WORKER ERROR RECORDS ');
878: fnd_file.put_line(FND_FILE.OUTPUT,'-----------------------------------------------------------------------------------');
879: fnd_file.put_line(FND_FILE.OUTPUT,to_number(l_new_error-l_old_error)||' records were completed with error. Please check the instance interface table');
880: fnd_file.put_line(FND_FILE.OUTPUT,' for detailed error message.');
881: fnd_file.put_line(FND_FILE.OUTPUT,'-----------------------------------------------------------------------------------');
882: END IF;
883: l_old_error:=0;
884: l_new_error:=0;
885: ELSE
897: -- Start relationship creation
898: IF l_rel_count <> 0
899: THEN
900: IF(l_debug_level>1) THEN
901: FND_File.Put_Line(Fnd_File.LOG,'l_rel_count <> zero');
902: FND_File.Put_Line(Fnd_File.LOG,'Begin - parallel creation of relationships: '||p_worker_count);
903: FND_File.Put_Line(Fnd_File.LOG,'p_worker_count: '||p_worker_count);
904: END IF;
905:
898: IF l_rel_count <> 0
899: THEN
900: IF(l_debug_level>1) THEN
901: FND_File.Put_Line(Fnd_File.LOG,'l_rel_count <> zero');
902: FND_File.Put_Line(Fnd_File.LOG,'Begin - parallel creation of relationships: '||p_worker_count);
903: FND_File.Put_Line(Fnd_File.LOG,'p_worker_count: '||p_worker_count);
904: END IF;
905:
906: IF (p_worker_count IS NULL OR
899: THEN
900: IF(l_debug_level>1) THEN
901: FND_File.Put_Line(Fnd_File.LOG,'l_rel_count <> zero');
902: FND_File.Put_Line(Fnd_File.LOG,'Begin - parallel creation of relationships: '||p_worker_count);
903: FND_File.Put_Line(Fnd_File.LOG,'p_worker_count: '||p_worker_count);
904: END IF;
905:
906: IF (p_worker_count IS NULL OR
907: p_worker_count > 32)
910: ELSE
911: l_r_worker_count := p_worker_count;
912: END IF;
913:
914: FND_File.Put_Line(Fnd_File.LOG,'source' || p_source_system_name);
915:
916: SELECT ceil(count(1)/l_r_worker_count)
917: INTO x_r_count
918: FROM csi_ii_relation_interface
923: AND process_status = 'R'
924: AND source_system_name = nvl(p_source_system_name,source_system_name)
925: AND parallel_worker_id = -1;
926:
927: FND_File.Put_Line(Fnd_File.LOG,'xrcount' || x_r_count);
928: FND_File.Put_Line(Fnd_File.LOG,'wkcount' || l_r_worker_count);
929:
930:
931: FOR l_r_count in 1 .. l_r_worker_count
924: AND source_system_name = nvl(p_source_system_name,source_system_name)
925: AND parallel_worker_id = -1;
926:
927: FND_File.Put_Line(Fnd_File.LOG,'xrcount' || x_r_count);
928: FND_File.Put_Line(Fnd_File.LOG,'wkcount' || l_r_worker_count);
929:
930:
931: FOR l_r_count in 1 .. l_r_worker_count
932: LOOP
930:
931: FOR l_r_count in 1 .. l_r_worker_count
932: LOOP
933:
934: FND_File.Put_Line(Fnd_File.LOG,'updating CIRI');
935: UPDATE csi_ii_relation_interface
936: SET parallel_worker_id = l_r_count
937: WHERE ROWNUM <= x_r_count
938: AND parallel_worker_id = -1
941: COMMIT;
942: END LOOP;
943:
944: IF(l_debug_level>1) THEN
945: FND_File.Put_Line(Fnd_File.LOG,'Before calling csi_ml_util_pvt.resolve_rel_ids');
946: END IF;
947: -- To resolve id columns
948: csi_ml_util_pvt.resolve_rel_ids
949: (p_source_system => p_source_system_name
952: ,x_return_status => l_return_status
953: ,x_error_message => l_error_message
954: );
955: IF(l_debug_level>1) THEN
956: FND_File.Put_Line(Fnd_File.LOG,'After calling csi_ml_util_pvt.resolve_rel_ids');
957: END IF;
958:
959: csi_ml_util_pvt.eliminate_dup_records;
960: csi_ml_util_pvt.eliminate_dup_subject;
971: THEN
972: FOR l_count in 1..l_r_worker_count
973: LOOP
974: IF(l_debug_level>1) THEN
975: FND_File.Put_Line(Fnd_File.LOG,'Before submitting request for relationships: ');
976: FND_File.Put_Line(Fnd_File.LOG,'Start time in validate mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
977: END IF;
978: l_request_id := FND_REQUEST.SUBMIT_REQUEST
979: ( 'CSI'
972: FOR l_count in 1..l_r_worker_count
973: LOOP
974: IF(l_debug_level>1) THEN
975: FND_File.Put_Line(Fnd_File.LOG,'Before submitting request for relationships: ');
976: FND_File.Put_Line(Fnd_File.LOG,'Start time in validate mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
977: END IF;
978: l_request_id := FND_REQUEST.SUBMIT_REQUEST
979: ( 'CSI'
980: ,'CSIMCREL'
987: ,p_txn_to_date
988: ,p_source_system_name
989: );
990: IF(l_debug_level>1) THEN
991: FND_File.Put_Line(Fnd_File.LOG,'End time in validate mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
992: FND_File.Put_Line(Fnd_File.LOG,'Calling Open Interface Parallel Relationship Creation Process');
993: FND_File.Put_Line(Fnd_File.LOG,'Request ID: '||l_request_id||' has been submitted');
994: FND_File.Put_Line(Fnd_File.LOG,'');
995: END IF;
988: ,p_source_system_name
989: );
990: IF(l_debug_level>1) THEN
991: FND_File.Put_Line(Fnd_File.LOG,'End time in validate mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
992: FND_File.Put_Line(Fnd_File.LOG,'Calling Open Interface Parallel Relationship Creation Process');
993: FND_File.Put_Line(Fnd_File.LOG,'Request ID: '||l_request_id||' has been submitted');
994: FND_File.Put_Line(Fnd_File.LOG,'');
995: END IF;
996:
989: );
990: IF(l_debug_level>1) THEN
991: FND_File.Put_Line(Fnd_File.LOG,'End time in validate mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
992: FND_File.Put_Line(Fnd_File.LOG,'Calling Open Interface Parallel Relationship Creation Process');
993: FND_File.Put_Line(Fnd_File.LOG,'Request ID: '||l_request_id||' has been submitted');
994: FND_File.Put_Line(Fnd_File.LOG,'');
995: END IF;
996:
997: IF (l_request_id = 0) THEN
990: IF(l_debug_level>1) THEN
991: FND_File.Put_Line(Fnd_File.LOG,'End time in validate mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
992: FND_File.Put_Line(Fnd_File.LOG,'Calling Open Interface Parallel Relationship Creation Process');
993: FND_File.Put_Line(Fnd_File.LOG,'Request ID: '||l_request_id||' has been submitted');
994: FND_File.Put_Line(Fnd_File.LOG,'');
995: END IF;
996:
997: IF (l_request_id = 0) THEN
998: l_req_count:=l_req_count+1;
997: IF (l_request_id = 0) THEN
998: l_req_count:=l_req_count+1;
999: l_errbuf := FND_MESSAGE.GET;
1000: IF(l_debug_level>1) THEN
1001: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,76,150));
1002: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,151,225));
1003: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,226,300));
1004: END IF;
1005: END IF;
998: l_req_count:=l_req_count+1;
999: l_errbuf := FND_MESSAGE.GET;
1000: IF(l_debug_level>1) THEN
1001: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,76,150));
1002: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,151,225));
1003: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,226,300));
1004: END IF;
1005: END IF;
1006: COMMIT;
999: l_errbuf := FND_MESSAGE.GET;
1000: IF(l_debug_level>1) THEN
1001: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,76,150));
1002: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,151,225));
1003: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,226,300));
1004: END IF;
1005: END IF;
1006: COMMIT;
1007: END LOOP;
1023:
1024: FOR l_count IN 1..l_r_worker_count
1025: LOOP
1026: IF(l_debug_level>1) THEN
1027: FND_File.Put_Line(Fnd_File.LOG,'Before submit request for l_valid_count <> 0: ');
1028: FND_File.Put_Line(Fnd_File.LOG,'Start time in update mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
1029: END IF;
1030: l_request_id := FND_REQUEST.SUBMIT_REQUEST
1031: ( 'CSI'
1024: FOR l_count IN 1..l_r_worker_count
1025: LOOP
1026: IF(l_debug_level>1) THEN
1027: FND_File.Put_Line(Fnd_File.LOG,'Before submit request for l_valid_count <> 0: ');
1028: FND_File.Put_Line(Fnd_File.LOG,'Start time in update mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
1029: END IF;
1030: l_request_id := FND_REQUEST.SUBMIT_REQUEST
1031: ( 'CSI'
1032: ,'CSIMCREL'
1039: ,p_txn_to_date
1040: ,p_source_system_name
1041: );
1042: IF(l_debug_level>1) THEN
1043: FND_File.Put_Line(Fnd_File.LOG,'End time in update mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
1044: FND_File.Put_Line(Fnd_File.LOG,'Calling Open Interface Parallel Relationship Creation Process');
1045: FND_File.Put_Line(Fnd_File.LOG,'Request ID: '||l_request_id||' has been submitted');
1046: FND_File.Put_Line(Fnd_File.LOG,'');
1047: END IF;
1040: ,p_source_system_name
1041: );
1042: IF(l_debug_level>1) THEN
1043: FND_File.Put_Line(Fnd_File.LOG,'End time in update mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
1044: FND_File.Put_Line(Fnd_File.LOG,'Calling Open Interface Parallel Relationship Creation Process');
1045: FND_File.Put_Line(Fnd_File.LOG,'Request ID: '||l_request_id||' has been submitted');
1046: FND_File.Put_Line(Fnd_File.LOG,'');
1047: END IF;
1048:
1041: );
1042: IF(l_debug_level>1) THEN
1043: FND_File.Put_Line(Fnd_File.LOG,'End time in update mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
1044: FND_File.Put_Line(Fnd_File.LOG,'Calling Open Interface Parallel Relationship Creation Process');
1045: FND_File.Put_Line(Fnd_File.LOG,'Request ID: '||l_request_id||' has been submitted');
1046: FND_File.Put_Line(Fnd_File.LOG,'');
1047: END IF;
1048:
1049: IF (l_request_id = 0) THEN
1042: IF(l_debug_level>1) THEN
1043: FND_File.Put_Line(Fnd_File.LOG,'End time in update mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
1044: FND_File.Put_Line(Fnd_File.LOG,'Calling Open Interface Parallel Relationship Creation Process');
1045: FND_File.Put_Line(Fnd_File.LOG,'Request ID: '||l_request_id||' has been submitted');
1046: FND_File.Put_Line(Fnd_File.LOG,'');
1047: END IF;
1048:
1049: IF (l_request_id = 0) THEN
1050: l_req_count:=l_req_count+1;
1049: IF (l_request_id = 0) THEN
1050: l_req_count:=l_req_count+1;
1051: l_errbuf := FND_MESSAGE.GET;
1052: IF(l_debug_level>1) THEN
1053: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,76,150));
1054: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,151,225));
1055: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,226,300));
1056: END IF;
1057: END IF;
1050: l_req_count:=l_req_count+1;
1051: l_errbuf := FND_MESSAGE.GET;
1052: IF(l_debug_level>1) THEN
1053: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,76,150));
1054: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,151,225));
1055: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,226,300));
1056: END IF;
1057: END IF;
1058: COMMIT;
1051: l_errbuf := FND_MESSAGE.GET;
1052: IF(l_debug_level>1) THEN
1053: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,76,150));
1054: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,151,225));
1055: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,226,300));
1056: END IF;
1057: END IF;
1058: COMMIT;
1059: END LOOP;
1075:
1076: FOR l_count IN 1..l_r_worker_count
1077: LOOP
1078: IF(l_debug_level>1) THEN
1079: FND_File.Put_Line(Fnd_File.LOG,'Before submit request for l_update_count <> 0: ');
1080: FND_File.Put_Line(Fnd_File.LOG,'Start time in update mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
1081: END IF;
1082: l_request_id := FND_REQUEST.SUBMIT_REQUEST
1083: ( 'CSI'
1076: FOR l_count IN 1..l_r_worker_count
1077: LOOP
1078: IF(l_debug_level>1) THEN
1079: FND_File.Put_Line(Fnd_File.LOG,'Before submit request for l_update_count <> 0: ');
1080: FND_File.Put_Line(Fnd_File.LOG,'Start time in update mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
1081: END IF;
1082: l_request_id := FND_REQUEST.SUBMIT_REQUEST
1083: ( 'CSI'
1084: ,'CSIMCREL'
1091: ,p_txn_to_date
1092: ,p_source_system_name
1093: );
1094: IF(l_debug_level>1) THEN
1095: FND_File.Put_Line(Fnd_File.LOG,'End time in update mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
1096: FND_File.Put_Line(Fnd_File.LOG,'Calling Open Interface Parallel Relationship Creation Process');
1097: FND_File.Put_Line(Fnd_File.LOG,'Request ID: '||l_request_id||' has been submitted');
1098: FND_File.Put_Line(Fnd_File.LOG,'');
1099: END IF;
1092: ,p_source_system_name
1093: );
1094: IF(l_debug_level>1) THEN
1095: FND_File.Put_Line(Fnd_File.LOG,'End time in update mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
1096: FND_File.Put_Line(Fnd_File.LOG,'Calling Open Interface Parallel Relationship Creation Process');
1097: FND_File.Put_Line(Fnd_File.LOG,'Request ID: '||l_request_id||' has been submitted');
1098: FND_File.Put_Line(Fnd_File.LOG,'');
1099: END IF;
1100:
1093: );
1094: IF(l_debug_level>1) THEN
1095: FND_File.Put_Line(Fnd_File.LOG,'End time in update mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
1096: FND_File.Put_Line(Fnd_File.LOG,'Calling Open Interface Parallel Relationship Creation Process');
1097: FND_File.Put_Line(Fnd_File.LOG,'Request ID: '||l_request_id||' has been submitted');
1098: FND_File.Put_Line(Fnd_File.LOG,'');
1099: END IF;
1100:
1101: IF (l_request_id = 0) THEN
1094: IF(l_debug_level>1) THEN
1095: FND_File.Put_Line(Fnd_File.LOG,'End time in update mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
1096: FND_File.Put_Line(Fnd_File.LOG,'Calling Open Interface Parallel Relationship Creation Process');
1097: FND_File.Put_Line(Fnd_File.LOG,'Request ID: '||l_request_id||' has been submitted');
1098: FND_File.Put_Line(Fnd_File.LOG,'');
1099: END IF;
1100:
1101: IF (l_request_id = 0) THEN
1102: l_req_count:=l_req_count+1;
1101: IF (l_request_id = 0) THEN
1102: l_req_count:=l_req_count+1;
1103: l_errbuf := FND_MESSAGE.GET;
1104: IF(l_debug_level>1) THEN
1105: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,76,150));
1106: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,151,225));
1107: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,226,300));
1108: END IF;
1109: END IF;
1102: l_req_count:=l_req_count+1;
1103: l_errbuf := FND_MESSAGE.GET;
1104: IF(l_debug_level>1) THEN
1105: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,76,150));
1106: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,151,225));
1107: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,226,300));
1108: END IF;
1109: END IF;
1110: COMMIT;
1103: l_errbuf := FND_MESSAGE.GET;
1104: IF(l_debug_level>1) THEN
1105: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,76,150));
1106: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,151,225));
1107: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,226,300));
1108: END IF;
1109: END IF;
1110: COMMIT;
1111: END LOOP;
1127:
1128: FOR l_count in 1..l_r_worker_count
1129: LOOP
1130: IF(l_debug_level>1) THEN
1131: FND_File.Put_Line(Fnd_File.LOG,'Before submit request for l_insert_count <> 0: ');
1132: FND_File.Put_Line(Fnd_File.LOG,'Start time in insert mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
1133: END IF;
1134: l_request_id := FND_REQUEST.SUBMIT_REQUEST
1135: ( 'CSI'
1128: FOR l_count in 1..l_r_worker_count
1129: LOOP
1130: IF(l_debug_level>1) THEN
1131: FND_File.Put_Line(Fnd_File.LOG,'Before submit request for l_insert_count <> 0: ');
1132: FND_File.Put_Line(Fnd_File.LOG,'Start time in insert mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
1133: END IF;
1134: l_request_id := FND_REQUEST.SUBMIT_REQUEST
1135: ( 'CSI'
1136: ,'CSIMCREL'
1143: ,p_txn_to_date
1144: ,p_source_system_name
1145: );
1146: IF(l_debug_level>1) THEN
1147: FND_File.Put_Line(Fnd_File.LOG,'End time in insert mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
1148: FND_File.Put_Line(Fnd_File.LOG,'Calling Open Interface Parallel Relationship Creation Process');
1149: FND_File.Put_Line(Fnd_File.LOG,'Request ID: '||l_request_id||' has been submitted');
1150: FND_File.Put_Line(Fnd_File.LOG,'');
1151: END IF;
1144: ,p_source_system_name
1145: );
1146: IF(l_debug_level>1) THEN
1147: FND_File.Put_Line(Fnd_File.LOG,'End time in insert mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
1148: FND_File.Put_Line(Fnd_File.LOG,'Calling Open Interface Parallel Relationship Creation Process');
1149: FND_File.Put_Line(Fnd_File.LOG,'Request ID: '||l_request_id||' has been submitted');
1150: FND_File.Put_Line(Fnd_File.LOG,'');
1151: END IF;
1152:
1145: );
1146: IF(l_debug_level>1) THEN
1147: FND_File.Put_Line(Fnd_File.LOG,'End time in insert mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
1148: FND_File.Put_Line(Fnd_File.LOG,'Calling Open Interface Parallel Relationship Creation Process');
1149: FND_File.Put_Line(Fnd_File.LOG,'Request ID: '||l_request_id||' has been submitted');
1150: FND_File.Put_Line(Fnd_File.LOG,'');
1151: END IF;
1152:
1153: IF (l_request_id = 0) THEN
1146: IF(l_debug_level>1) THEN
1147: FND_File.Put_Line(Fnd_File.LOG,'End time in insert mode: '||to_char(sysdate,'dd-mon-yy hh24:mi:ss'));
1148: FND_File.Put_Line(Fnd_File.LOG,'Calling Open Interface Parallel Relationship Creation Process');
1149: FND_File.Put_Line(Fnd_File.LOG,'Request ID: '||l_request_id||' has been submitted');
1150: FND_File.Put_Line(Fnd_File.LOG,'');
1151: END IF;
1152:
1153: IF (l_request_id = 0) THEN
1154: l_req_count:=l_req_count+1;
1153: IF (l_request_id = 0) THEN
1154: l_req_count:=l_req_count+1;
1155: l_errbuf := FND_MESSAGE.GET;
1156: IF(l_debug_level>1) THEN
1157: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,76,150));
1158: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,151,225));
1159: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,226,300));
1160: END IF;
1161: END IF;
1154: l_req_count:=l_req_count+1;
1155: l_errbuf := FND_MESSAGE.GET;
1156: IF(l_debug_level>1) THEN
1157: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,76,150));
1158: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,151,225));
1159: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,226,300));
1160: END IF;
1161: END IF;
1162: COMMIT;
1155: l_errbuf := FND_MESSAGE.GET;
1156: IF(l_debug_level>1) THEN
1157: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,76,150));
1158: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,151,225));
1159: FND_File.Put_Line(Fnd_File.LOG,' :'||substr(l_errbuf,226,300));
1160: END IF;
1161: END IF;
1162: COMMIT;
1163: END LOOP;
1183:
1184: EXCEPTION
1185:
1186: WHEN others THEN
1187: FND_File.Put_Line(Fnd_File.LOG,'csi_ml_program_pub.execute_parallel_create -Into when others exception ' || SQLERRM);
1188: l_sql_error := SQLERRM;
1189: fnd_message.set_name('CSI','CSI_ML_UNEXP_SQL_ERROR');
1190: fnd_message.set_token('API_NAME',l_api_name);
1191: fnd_message.set_token('SQL_ERROR',SQLERRM);