92: BEGIN --Procedure add_derived_entities
93:
94: l_stmt_num := 0;
95: delete from Ego_Publication_Batch_GT;
96: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
97: ,p_module => 'EGO_PUB_FWK_PK.add_derived_entities'
98: ,p_message => 'Enter EGO_PUB_FWK_PK.add_derived_entities ... '
99: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
100:
130: END IF;*/
131:
132: l_stmt_num := 10;
133:
134: EGO_COMMON_PVT.WRITE_DIAGNOSTIC ( p_log_level => FND_LOG.LEVEL_STATEMENT
135: ,p_module => 'EGO_PUB_FWK_PK.add_derived_entities'
136: ,p_message =>' i --' ||
137: ' pk1_value(i) --' ||
138: ' pk2_value(i) --' ||
153:
154: entity_type_id(i) := der_bat_ent_objs(i).entity_type_id;
155:
156:
157: EGO_COMMON_PVT.WRITE_DIAGNOSTIC ( p_log_level => FND_LOG.LEVEL_STATEMENT
158: ,p_module => 'EGO_PUB_FWK_PK.add_derived_entities'
159: ,p_message => i || ' --' ||
160: der_bat_ent_objs(i).pk1_value || ' --' ||
161: der_bat_ent_objs(i).pk2_value || ' --' ||
203: ,SYSDATE
204: ,FND_GLOBAL.USER_ID
205: ,FND_GLOBAL.LOGIN_ID
206: );
207: EGO_COMMON_PVT.WRITE_DIAGNOSTIC ( p_log_level => FND_LOG.LEVEL_STATEMENT
208: ,p_module => 'EGO_PUB_FWK_PK.add_derived_entities'
209: ,p_message => 'lStmtNum=' || to_char(l_stmt_num)
210: ||' ' || sql%rowcount || ' rows are inserted into EGO_PUBLICATION_BATCH_GT.');
211:
224: END IF;
225:
226: delete from EGO_PUBLICATION_BATCH_GT;
227:
228: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
229: ,p_module => 'EGO_PUB_FWK_PK.add_derived_entities'
230: ,p_message => 'Exit EGO_PUB_FWK_PK.add_derived_entities successfully... '
231: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
232:
231: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
232:
233: EXCEPTION
234: WHEN EGO_NO_DERIVED_ENTITIES THEN
235: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_EXCEPTION
236: ,p_module => 'EGO_PUB_FWK_PK.add_derived_entities'
237: ,p_message => 'Exception EGO_NO_DERIVED_ENTITIES in stmt num: ' || l_stmt_num|| ': '||'sqlerrm=>' ||sqlerrm);
238:
239:
242: x_return_status := FND_API.G_RET_STS_ERROR;
243: EGO_UTIL_PK.count_and_get (p_msg_count => x_msg_count
244: ,p_msg_data => x_msg_data );
245: WHEN EGO_PUB_BATCHID_NULL THEN
246: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_EXCEPTION
247: ,p_module => 'EGO_PUB_FWK_PK.add_derived_entities'
248: ,p_message => 'Exception EGO_PUB_BATCHID_NULL in stmt num: ' || l_stmt_num|| ': '||'sqlerrm=>' ||sqlerrm );
249: EGO_UTIL_PK.put_fnd_stack_msg (p_appln_short_name=>'EGO'
250: ,p_message =>'EGO_PUB_BATCHID_NULL');
252: EGO_UTIL_PK.count_and_get (p_msg_count => x_msg_count
253: ,p_msg_data => x_msg_data );
254:
255: WHEN FND_API.G_EXC_ERROR THEN
256: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_EXCEPTION
257: ,p_module => 'EGO_PUB_FWK_PK.add_derived_entities'
258: ,p_message => 'Exception in stmt num: ' || l_stmt_num || ': '||'sqlerrm=>' ||sqlerrm );
259:
260: x_return_status := FND_API.G_RET_STS_ERROR;
261: EGO_UTIL_PK.count_and_get (p_msg_count => x_msg_count
262: ,p_msg_data => x_msg_data );
263:
264: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
265: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_UNEXPECTED
266: ,p_module => 'EGO_PUB_FWK_PK.add_derived_entities'
267: ,p_message => 'Unexpedted Exception in stmt num: ' || l_stmt_num || ': '||'sqlerrm=>' ||sqlerrm );
268: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
269: EGO_UTIL_PK.count_and_get (p_msg_count => x_msg_count
269: EGO_UTIL_PK.count_and_get (p_msg_count => x_msg_count
270: ,p_msg_data => x_msg_data );
271:
272: WHEN OTHERS THEN
273: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_UNEXPECTED
274: ,p_module => 'EGO_PUB_FWK_PK.add_derived_entities'
275: ,p_message => 'Others Exception in stmt num: ' || l_stmt_num || ': '||'sqlerrm=>' ||sqlerrm );
276: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
277: EGO_UTIL_PK.count_and_get (p_msg_count => x_msg_count
300: --i NUMBER; --FOR LOOP
301:
302: BEGIN
303: l_stmt_num := 0;
304: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
305: ,p_module => 'EGO_PUB_FWK_PK.add_derived_entities'
306: ,p_message => 'Enter EGO_PUB_FWK_PK.process_entities ... '
307: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
308:
345: ,FND_GLOBAL.LOGIN_ID
346: ,1
347: FROM Ego_Publication_Batch_GT
348: WHERE Batch_Id = p_batch_id;
349: EGO_COMMON_PVT.WRITE_DIAGNOSTIC ( p_log_level => FND_LOG.LEVEL_STATEMENT
350: ,p_module => 'EGO_PUB_FWK_PK.process_entities'
351: ,p_message => 'lStmtNum=' || to_char(l_stmt_num)
352: ||' ' || sql%rowcount || ' rows are inserted into EGO_PUB_BAT_ENT_OBJS_B.');
353:
367: IF t_system_code.count() = 0 THEN
368: RAISE EGO_NO_BATCH_SYSTEMS;
369: END IF;
370:
371: EGO_COMMON_PVT.WRITE_DIAGNOSTIC ( p_log_level => FND_LOG.LEVEL_STATEMENT
372: ,p_module => 'EGO_PUB_FWK_PK.process_entities'
373: ,p_message => 'i'|| '---' || 't_batch_ent_obj_id(i)' || '---'|| 't_system_code(i)'
374: );
375: FOR i in t_batch_ent_obj_id.FIRST..t_batch_ent_obj_id.LAST
373: ,p_message => 'i'|| '---' || 't_batch_ent_obj_id(i)' || '---'|| 't_system_code(i)'
374: );
375: FOR i in t_batch_ent_obj_id.FIRST..t_batch_ent_obj_id.LAST
376: LOOP
377: EGO_COMMON_PVT.WRITE_DIAGNOSTIC ( p_log_level => FND_LOG.LEVEL_STATEMENT
378: ,p_module => 'EGO_PUB_FWK_PK.process_entities'
379: ,p_message => i ||'---' || t_batch_ent_obj_id(i) || '---'|| t_system_code(i)
380: );
381: END LOOP; --for debugging message
408: ,FND_GLOBAL.USER_ID
409: ,FND_GLOBAL.LOGIN_ID
410: ,1
411: );
412: EGO_COMMON_PVT.WRITE_DIAGNOSTIC ( p_log_level => FND_LOG.LEVEL_STATEMENT
413: ,p_module => 'EGO_PUB_FWK_PK.process_entities'
414: ,p_message => 'lStmtNum=' || to_char(l_stmt_num)
415: ||' ' || sql%rowcount || ' rows are inserted into EGO_PUB_BAT_STATUS_B.');
416:
413: ,p_module => 'EGO_PUB_FWK_PK.process_entities'
414: ,p_message => 'lStmtNum=' || to_char(l_stmt_num)
415: ||' ' || sql%rowcount || ' rows are inserted into EGO_PUB_BAT_STATUS_B.');
416:
417: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
418: ,p_module => 'EGO_PUB_FWK_PK.add_derived_entities'
419: ,p_message => 'Exit EGO_PUB_FWK_PK.process_entities successfully... '
420: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
421:
420: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
421:
422: EXCEPTION
423: WHEN EGO_NO_BATCH_SYSTEMS THEN
424: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_EXCEPTION
425: ,p_module => 'EGO_PUB_FWK_PK.process_entities'
426: ,p_message => 'Exception EGO_NO_BATCH_SYSTEMS in stmt num: '||l_stmt_num || ':' ||'sqlerrm=>'|| sqlerrm);
427: EGO_UTIL_PK.put_fnd_stack_msg (p_appln_short_name=>'EGO'
428: ,p_message =>'EGO_NO_BATCH_SYSTEMS');
431: (p_msg_count => x_msg_count
432: ,p_msg_data => x_msg_data );
433:
434: WHEN OTHERS THEN
435: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_UNEXPECTED
436: ,p_module => 'EGO_PUB_FWK_PK.process_entities'
437: ,p_message => 'Others Exception in stmt num: ' || l_stmt_num || ': '||'sqlerrm=>' ||sqlerrm );
438: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
439: EGO_UTIL_PK.count_and_get
470:
471: BEGIN
472: l_stmt_num := 0;
473:
474: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
475: ,p_module => 'EGO_PUB_FWK_PK.Update_Pub_Status_Thru_AIA'
476: ,p_message => 'Enter EGO_PUB_FWK_PK.Update_Pub_Status_Thru_AIA ... '
477: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
478:
518: FROM Ego_Publication_Batch_GT
519: WHERE Batch_id = p_batch_id;
520:
521:
522: EGO_COMMON_PVT.WRITE_DIAGNOSTIC ( p_log_level => FND_LOG.LEVEL_STATEMENT
523: ,p_module => 'EGO_PUB_FWK_PK.Update_Pub_Status_Thru_AIA'
524: ,p_message =>' i --' ||
525: ' batch_id(i) --' ||
526: ' pk1_value(i) --' ||
533: ' msg(i)--'
534: );
535:
536: FOR i IN t_dbg_batchid.FIRST..t_dbg_batchid.LAST LOOP
537: EGO_COMMON_PVT.WRITE_DIAGNOSTIC ( p_log_level => FND_LOG.LEVEL_STATEMENT
538: ,p_module => 'EGO_PUB_FWK_PK.Update_Pub_Status_Thru_AIA'
539: ,p_message => i || ' --' ||
540: t_dbg_batchid(i) || ' --' ||
541: dbg_pk1_value(i) || ' --' ||
563: END IF;
564:
565: x_return_status := calc_return_status(p_batch_id=>p_batch_id);
566:
567: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
568: ,p_module => 'EGO_PUB_FWK_PK.Update_Pub_Status_Thru_AIA'
569: ,p_message => 'Exit EGO_PUB_FWK_PK.Update_Pub_Status_Thru_AIA successfully... '
570: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
571:
574:
575: Exception
576:
577: When OTHERS Then
578: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_UNEXPECTED
579: ,p_module => 'EGO_PUB_FWK_PK.Update_Pub_Status_Thru_AIA'
580: ,p_message => 'Unexpedted Exception in stmt num: ' || l_stmt_num || ': '||'sqlerrm=>' ||sqlerrm );
581: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
582: EGO_UTIL_PK.count_and_get (p_msg_count => x_msg_count
591: l_ct_S NUMBER ;
592: l_ct_bat NUMBER;
593: l_stmt_num NUMBER;
594: BEGIN
595: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
596: ,p_module => 'EGO_PUB_FWK_PK.calc_return_status'
597: ,p_message => 'Enter EGO_PUB_FWK_PK.calc_return_status ... '
598: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
599:
608: WHEN no_data_found THEN
609: return C_FAILED;
610: END;
611:
612: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_STATEMENT
613: ,p_module => 'EGO_PUB_FWK_PK.calc_return_status'
614: ,p_message => 'row_count_Success=> '||l_ct_S
615: );
616:
624: into l_ct_bat
625: from ego_publication_batch_gt
626: WHERE batch_id = p_batch_id;
627:
628: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_STATEMENT
629: ,p_module => 'EGO_PUB_FWK_PK.calc_return_status'
630: ,p_message => 'total rows=> '||l_ct_bat
631: );
632:
638: return C_WARNING;
639:
640: END IF;
641:
642: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
643: ,p_module => 'EGO_PUB_FWK_PK.calc_return_status'
644: ,p_message => 'Exit EGO_PUB_FWK_PK.calc_return_status ... '
645: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
646:
660:
661: EGO_INVALID_MODE Exception;
662: BEGIN
663: l_stmt_num := 0;
664: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
665: ,p_module => 'EGO_PUB_FWK_PK.Basic_Validation'
666: ,p_message => 'Enter EGO_PUB_FWK_PK.Basic_Validation ... '
667: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
668:
687: C_BATCH_SYSTEM_ENTITY_MODE)) THEN
688: Raise EGO_INVALID_MODE;
689: END IF;
690:
691: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
692: ,p_module => 'EGO_PUB_FWK_PK.Basic_Validation'
693: ,p_message => 'Exit EGO_PUB_FWK_PK.Basic_Validation ... '
694: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
695:
695:
696: Exception
697:
698: When FND_API.G_EXC_UNEXPECTED_ERROR Then
699: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_UNEXPECTED
700: ,p_module => 'EGO_PUB_FWK_PK.Basic_validation'
701: ,p_message => 'Unexpedted Exception in stmt num: ' || l_stmt_num || ': '||'sqlerrm=>' ||sqlerrm );
702: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
703: EGO_UTIL_PK.count_and_get (p_msg_count => x_msg_count
704: ,p_msg_data => x_msg_data );
705:
706:
707: When EGO_INVALID_MODE Then
708: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_UNEXPECTED
709: ,p_module => 'EGO_PUB_FWK_PK.Basic_validation'
710: ,p_message => 'Inavlid Batch mode in stmt num: ' || l_stmt_num );
711:
712: l_stmt_num := 30;
743: EGO_NULL_BATCH_ID EXCEPTION;
744: EGO_NO_HEADER EXCEPTION;
745: BEGIN
746: l_stmt_num := 0;
747: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
748: ,p_module => 'EGO_PUB_FWK_PK.validate_batch_id'
749: ,p_message => 'Enter EGO_PUB_FWK_PK.validate_batch_id ... '
750: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
751:
768: When No_Data_Found THEN
769: RAISE EGO_NO_HEADER;
770: End;
771:
772: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
773: ,p_module => 'EGO_PUB_FWK_PK.validate_batch_id'
774: ,p_message => 'Exit EGO_PUB_FWK_PK.validate_batch_id ... '
775: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
776:
777:
778:
779: EXCEPTION
780: When EGO_NULL_BATCH_ID Then
781: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_EXCEPTION
782: ,p_module => 'EGO_PUB_FWK_PK.validate_batch_id'
783: ,p_message => 'Exception EGO_PUB_BATCHID_NULL in stmt num: '||l_stmt_num || ':' ||'sqlerrm=>'|| sqlerrm);
784:
785:
800: x_return_status := C_FAILED;
801:
802: WHEN EGO_NO_HEADER THEN
803:
804: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_EXCEPTION
805: ,p_module => 'EGO_PUB_FWK_PK.validate_batch_id'
806: ,p_message => 'Exception EGO_NO_HEADER in stmt num: '||l_stmt_num || ':' ||'sqlerrm=>'|| sqlerrm);
807:
808:
824:
825:
826: x_return_status := C_FAILED;
827: WHEN OTHERS THEN
828: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_UNEXPECTED
829: ,p_module => 'EGO_PUB_FWK_PK.validate_batch_id'
830: ,p_message => 'Others Exception in stmt num: ' || l_stmt_num || ': '||'sqlerrm=>' ||sqlerrm );
831:
832:
841: IS
842: l_stmt_num NUMBER;
843: BEGIN
844: l_stmt_num := 0;
845: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
846: ,p_module => 'EGO_PUB_FWK_PK.validateStatus'
847: ,p_message => 'Enter EGO_PUB_FWK_PK.validateStatus ... '
848: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
849:
858: from fnd_lookups
859: where Lookup_Type = 'EGO_PUBLICATION_STATUS')
860: and batch_id = p_batch_id;
861:
862: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
863: ,p_module => 'EGO_PUB_FWK_PK.validateStatus'
864: ,p_message => 'Exit EGO_PUB_FWK_PK.validateStatus ... '
865: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
866:
867:
868:
869: EXCEPTION
870: WHEN OTHERS THEN
871: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_UNEXPECTED
872: ,p_module => 'EGO_PUB_FWK_PK.validate_status'
873: ,p_message => 'Others Exception in stmt num: ' || l_stmt_num || ': '||'sqlerrm=>' ||sqlerrm );
874:
875:
885:
886: l_stmt_num NUMBER;
887: BEGIN
888: l_stmt_num := 0;
889: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
890: ,p_module => 'EGO_PUB_FWK_PK.valdiateBatSystem'
891: ,p_message => 'Enter EGO_PUB_FWK_PK.valdiateBatSystem ... '
892: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
893:
906: where batch_id = p_batch_id)
907: and batch_id = p_batch_id
908: and process_flag is null;
909:
910: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
911: ,p_module => 'EGO_PUB_FWK_PK.valdiateBatSystem'
912: ,p_message => 'Exit EGO_PUB_FWK_PK.valdiateBatSystem ... '
913: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
914:
914:
915:
916: EXCEPTION
917: WHEN OTHERS THEN
918: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_UNEXPECTED
919: ,p_module => 'EGO_PUB_FWK_PK.valdiateBatSystem'
920: ,p_message => 'Others Exception in stmt num: ' || l_stmt_num || ': '||'sqlerrm=>' ||sqlerrm );
921:
922:
932: l_stmt_num NUMBER;
933:
934: BEGIN
935: l_stmt_num := 0;
936: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
937: ,p_module => 'EGO_PUB_FWK_PK.validateBatSysEnt'
938: ,p_message => 'Enter EGO_PUB_FWK_PK.validateBatSysEnt ... '
939: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
940:
971: WHERE batch_id = p_batch_id)
972: AND batch_id = p_batch_id
973: and process_flag is null;
974:
975: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
976: ,p_module => 'EGO_PUB_FWK_PK.validateBatSysEnt'
977: ,p_message => 'Exit EGO_PUB_FWK_PK.validateBatSysEnt ... '
978: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
979:
979:
980:
981: EXCEPTION
982: WHEN OTHERS THEN
983: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_UNEXPECTED
984: ,p_module => 'EGO_PUB_FWK_PK.validateBatSysEnt'
985: ,p_message => 'Others Exception in stmt num: ' || l_stmt_num || ': '||'sqlerrm=>' ||sqlerrm );
986:
987:
1010: l_stmt_num NUMBER;
1011: --i NUMBER; --FOR LOOP
1012: BEGIN
1013: l_stmt_num := 0;
1014: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
1015: ,p_module => 'EGO_PUB_FWK_PK.Process_Pub_Status'
1016: ,p_message => 'Enter EGO_PUB_FWK_PK.Process_Pub_Status ... '
1017: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
1018:
1091: set return_status = C_SUCCESS
1092: where batch_id = p_batch_id
1093: and process_flag is null;
1094:
1095: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
1096: ,p_module => 'EGO_PUB_FWK_PK.Process_Pub_Status'
1097: ,p_message => 'Exit EGO_PUB_FWK_PK.Process_Pub_Status ... '
1098: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
1099:
1099:
1100:
1101: EXCEPTION
1102: WHEN OTHERS THEN
1103: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_UNEXPECTED
1104: ,p_module => 'EGO_PUB_FWK_PK.Process_Pub_Status'
1105: ,p_message => 'Others Exception in stmt num: ' || l_stmt_num || ': '||'sqlerrm=>' ||sqlerrm );
1106:
1107: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
1155: BEGIN
1156: delete from Ego_Publication_Batch_GT;
1157:
1158: l_stmt_num := 0;
1159: EGO_COMMON_PVT.WRITE_DIAGNOSTIC( p_log_level => FND_LOG.LEVEL_PROCEDURE
1160: ,p_module => 'EGO_PUB_FWK_PK.Update_Pub_Status'
1161: ,p_message => 'Enter EGO_PUB_FWK_PK.Update_Pub_Status ...'
1162: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
1163:
1178: IF ( p_bat_status_in.count() = 0 OR p_bat_status_in IS NULL ) THEN
1179: RAISE EGO_NO_BAT_STS_IN; --!!!!!!!!! should I raise exception or put error message into GT
1180: END IF;
1181:
1182: EGO_COMMON_PVT.WRITE_DIAGNOSTIC ( p_log_level => FND_LOG.LEVEL_STATEMENT
1183: ,p_module => 'EGO_PUB_FWK_PK.Update_Pub_Status'
1184: ,p_message =>' i --' ||
1185: ' pk1_value(i) --' ||
1186: ' pk2_value(i) --' ||
1199: pk5_value(i) := p_bat_status_in(i).pk5_value;
1200: t_system_code(i) := p_bat_status_in(i).system_code;
1201: t_status(i) := p_bat_status_in(i).status;
1202: t_message(i) := p_bat_status_in(i).message;
1203: EGO_COMMON_PVT.WRITE_DIAGNOSTIC ( p_log_level => FND_LOG.LEVEL_STATEMENT
1204: ,p_module => 'EGO_PUB_FWK_PK.Update_Pub_Status'
1205: ,p_message => i || ' --' ||
1206: p_bat_status_in(i).pk1_value || ' --' ||
1207: p_bat_status_in(i).pk2_value || ' --' ||
1248: ,SYSDATE
1249: ,FND_GLOBAL.USER_ID
1250: ,FND_GLOBAL.LOGIN_ID
1251: );
1252: EGO_COMMON_PVT.WRITE_DIAGNOSTIC ( p_log_level => FND_LOG.LEVEL_STATEMENT
1253: ,p_module => 'EGO_PUB_FWK_PK.Update_Pub_Status'
1254: ,p_message => 'lStmtNum=' || to_char(l_stmt_num)
1255: ||' ' ||sql%rowcount || ' rows are inserted into EGO_PUBLICATION_BATCH_GT.');
1256:
1296: FROM Ego_Publication_Batch_GT
1297: WHERE Batch_id = p_batch_id;
1298:
1299:
1300: EGO_COMMON_PVT.WRITE_DIAGNOSTIC ( p_log_level => FND_LOG.LEVEL_STATEMENT
1301: ,p_module => 'EGO_PUB_FWK_PK.Update_Pub_Status'
1302: ,p_message =>' i --' ||
1303: ' batch_id(i) --' ||
1304: ' pk1_value(i) --' ||
1323: x_bat_status_out(i).ret_status := t_ret_status(i);
1324: x_bat_status_out(i).ret_err_msg := t_ret_err_msg(i);
1325: x_bat_status_out(i).ret_err_code := t_ret_err_code(i);
1326: x_bat_status_out(i).ret_err_msg_lang := t_ret_err_msg_lang(i);
1327: EGO_COMMON_PVT.WRITE_DIAGNOSTIC ( p_log_level => FND_LOG.LEVEL_STATEMENT
1328: ,p_module => 'EGO_PUB_FWK_PK.Update_Pub_Status'
1329: ,p_message => i || ' --' ||
1330: t_ret_batchid(i) || ' --' ||
1331: ret_pk1_value(i) || ' --' ||
1341: END LOOP;
1342:
1343: delete from Ego_Publication_Batch_GT;
1344:
1345: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
1346: ,p_module => 'EGO_PUB_FWK_PK.Update_Pub_Status'
1347: ,p_message => 'Exit EGO_PUB_FWK_PK.Update_Pub_Status successfully... '
1348: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
1349:
1348: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
1349:
1350: EXCEPTION
1351: WHEN EGO_NO_BAT_STS_IN THEN
1352: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_EXCEPTION
1353: ,p_module => 'EGO_PUB_FWK_PK.Update_Pub_Status'
1354: ,p_message => 'Exception EGO_NO_BAT_STS_IN in stmt num: ' || l_stmt_num|| ': '||'sqlerrm=>' ||sqlerrm);
1355:
1356:
1359: x_return_status := FND_API.G_RET_STS_ERROR;
1360: EGO_UTIL_PK.count_and_get (p_msg_count => x_msg_count
1361: ,p_msg_data => x_msg_data );
1362: WHEN OTHERS THEN
1363: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_UNEXPECTED
1364: ,p_module => 'EGO_PUB_FWK_PK.Update_Pub_Status'
1365: ,p_message => 'Others Exception in stmt num: ' || l_stmt_num || ': '||'sqlerrm=>' ||sqlerrm );
1366:
1367:
1381: Delete from Ego_Publication_Batch_GT;
1382:
1383: EXCEPTION
1384: WHEN OTHERS THEN
1385: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_UNEXPECTED
1386: ,p_module => 'EGO_PUB_FWK_PK.DeleteGTTableData'
1387: ,p_message => 'sqlerrm=>' ||sqlerrm );
1388:
1389: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
1395: -- private functions of public apis
1396: procedure debugBatchParam(p_module_name in varchar2, p_pub_param in BAT_PARAM_REC_TYPE )
1397: is
1398: begin
1399: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
1400: ,p_module => p_module_name
1401: ,p_message => 'l_pub_params, name:' || p_pub_param.param_name
1402: || ', param type:' || to_char(p_pub_param.param_type)
1403: || ', data type:' || to_char(p_pub_param.data_type)
1435: where ssm.Status = 'A' AND ssm.orig_system_type = 'SPOKE'
1436: AND ORIG_SYSTEM = l_system_code;
1437: exception
1438: when no_data_found then
1439: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
1440: ,p_module => l_module_name
1441: ,p_message => l_system_code || ' is invalid, by code');
1442: l_valid := false;
1443: end;
1448: where ssm.Status = 'A' AND ssm.orig_system_type = 'SPOKE'
1449: AND ORIG_SYSTEM_NAME = l_system_name;
1450: exception
1451: when no_data_found then
1452: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
1453: ,p_module => l_module_name
1454: ,p_message => l_system_name || ' is invalid, by name');
1455: l_valid := false;
1456: end;
1454: ,p_message => l_system_name || ' is invalid, by name');
1455: l_valid := false;
1456: end;
1457: else -- l_system_code, l_system_name both null
1458: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
1459: ,p_module => l_module_name
1460: ,p_message => ' system name and code are null');
1461: l_valid := false;
1462: end if;
1465: if (l_target_systems.count > 0) then
1466: FOR j IN 1..l_target_systems.count loop
1467: IF (l_target_systems(j).system_code = l_system_code) THEN
1468: x_return_status := FND_API.G_RET_STS_ERROR;
1469: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
1470: ,p_module => l_module_name
1471: ,p_message => 'target systems have duplicate, ' || l_system_code);
1472: EGO_UTIL_PK.put_fnd_stack_msg (p_appln_short_name=>'EGO'
1473: ,p_message =>'SELECT_DIFFERENT_SYSTEM');
1479: end if;
1480: -- end check for duplicate
1481:
1482: l_target_systems(i).system_code := l_system_code;
1483: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
1484: ,P_MODULE => l_module_name
1485: ,P_MESSAGE => ' system code: ' || l_system_code );
1486: end loop;
1487:
1486: end loop;
1487:
1488: if (not l_valid ) then
1489: x_return_status := FND_API.G_RET_STS_ERROR;
1490: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
1491: ,p_module => l_module_name
1492: ,p_message => 'target systems have invalid');
1493: EGO_UTIL_PK.put_fnd_stack_msg (p_appln_short_name=>'EGO'
1494: ,p_message =>'ADD_TARGET_SYSTEMS');
1566: EGO_PUB_PARAM_REQ_EXPL_DATE exception;
1567: begin
1568: x_return_status := FND_API.G_RET_STS_SUCCESS;
1569: l_pub_params := p_pub_params;
1570: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
1571: ,p_module => l_module_name
1572: ,p_message => 'batch_type: ' || p_batch_type);
1573:
1574: -- validate param: data_type, param_type, value
1736: l_pub_params(i).date_value := null;
1737: else
1738: l_param_date_val := l_pub_params(i).date_value;
1739: if (l_param_date_val is null) then
1740: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
1741: ,p_module => l_module_name
1742: ,p_message => 'param: structure name is not null, explosion date cannot be null');
1743: raise EGO_PUB_PARAM_VALUE_INVL;
1744: end if;
1756: -- valid range: 0, 60
1757: l_param_num_val := l_pub_params(i).number_value;
1758: if (l_param_num_val < 0 or l_param_num_val > 60) then
1759: l_pub_params(i).number_value := 60; -- reset it as maximum level+++
1760: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
1761: ,p_module => l_module_name
1762: ,p_message => 'param: explosion level not in 0, 60, reset it as 60');
1763: --raise EGO_PUB_PARM_LEVLEXPL_INVL;
1764: end if;
1896:
1897: exception
1898: when EGO_PUB_PARAM_VALUE_INVL then
1899: x_return_status := FND_API.G_RET_STS_ERROR;
1900: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
1901: ,p_module => l_module_name
1902: ,p_message => l_param_name || ' value is invalid');
1903: l_token(1).token_name := 'PARAM_NAME';
1904: l_token(1).token_value := l_param_name;
1908: EGO_UTIL_PK.count_and_get (p_msg_count => x_msg_count
1909: ,p_msg_data => x_msg_data );
1910: when EGO_PUB_PARAM_INVL then
1911: x_return_status := FND_API.G_RET_STS_ERROR;
1912: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
1913: ,p_module => l_module_name
1914: ,p_message => 'the type should not has ' || l_param_name);
1915: EGO_UTIL_PK.put_fnd_stack_msg (p_appln_short_name=>'EGO'
1916: , p_message => 'EGO_PUB_PARAM_INVL'
1918: EGO_UTIL_PK.count_and_get (p_msg_count => x_msg_count
1919: ,p_msg_data => x_msg_data );
1920: when EGO_PUB_PARAM_REQ_EXPL_DATE then
1921: x_return_status := FND_API.G_RET_STS_ERROR;
1922: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
1923: ,p_module => l_module_name
1924: ,p_message => ' struct_name is not null, explosion date is required');
1925: EGO_UTIL_PK.put_fnd_stack_msg (p_appln_short_name=>'EGO'
1926: ,p_message => 'EGO_PUB_PARAM_REQ_EXPL_DATE');
1927: EGO_UTIL_PK.count_and_get (p_msg_count => x_msg_count
1928: ,p_msg_data => x_msg_data );
1929: when others then
1930: x_return_status := FND_API.G_RET_STS_ERROR;
1931: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
1932: ,p_module => l_module_name
1933: ,p_message => 'unknown excpetion!!!' || sqlerrm);
1934: end validateBatchParams;
1935:
1957: elsif (p_entity_type = C_BATCH_ENTITY_VS) THEN
1958: l_func_name := 'EGO_CREATE_ATTR_EXT';
1959: END IF;
1960:
1961: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
1962: ,p_module => l_module_name
1963: ,p_message => 'check func: ' || l_func_name);
1964: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
1965: ,p_module => l_module_name
1960:
1961: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
1962: ,p_module => l_module_name
1963: ,p_message => 'check func: ' || l_func_name);
1964: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
1965: ,p_module => l_module_name
1966: ,p_message => 'check user has the resp or not ');
1967:
1968: -- check the user has the responsiblity
1968: -- check the user has the responsiblity
1969: begin
1970: l_user_id := FND_GLOBAL.user_id;
1971: l_resp_id := FND_GLOBAL.resp_id;
1972: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
1973: ,p_module => l_module_name
1974: ,p_message => 'user_id :' || l_user_id || ', resp_id: ' || l_resp_id);
1975:
1976: select rkey into l_resp_key from (
1997: and r.responsibility_id = l_resp_id) rdi;
1998: exception
1999: when no_data_found then
2000: x_return_status := FND_API.G_RET_STS_ERROR;
2001: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2002: ,p_module => l_module_name
2003: ,p_message => 'user doesnot has the resp');
2004: EGO_UTIL_PK.put_fnd_stack_msg (p_appln_short_name=>'EGO'
2005: ,p_message =>'EGO_NO_FUNC_PRIVILEGE_FOR_USER');
2007: ,p_msg_data => x_msg_data );
2008: return ;
2009: end;
2010:
2011: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2012: ,p_module => l_module_name
2013: ,p_message => 'call fnd_function.test ');
2014:
2015: if fnd_function.test(function_name => l_func_name) then
2024: end if;
2025: exception
2026: when others then
2027: l_err_msg := ' others error ' ||sqlerrm ;
2028: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2029: ,p_module => l_module_name
2030: ,p_message => l_err_msg
2031: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
2032: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
2063: where user_id = p_user_id;
2064: exception
2065: when no_data_found then
2066: l_err_msg := 'Cannot get party_id by user_id: ' || to_char(p_user_id);
2067: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2068: ,p_module => l_module_name
2069: ,p_message => l_err_msg
2070: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
2071: x_return_status := FND_API.G_RET_STS_ERROR;
2077: end ;
2078:
2079: l_party_idstr := 'HZ_PARTY:' || to_char(l_party_id);
2080:
2081: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2082: ,p_module => l_module_name
2083: ,p_message => 'party_id: ' || l_party_idstr);
2084:
2085: FOR i IN p_batch_entities.FIRST..p_batch_entities.LAST LOOP
2084:
2085: FOR i IN p_batch_entities.FIRST..p_batch_entities.LAST LOOP
2086: l_item_id := to_number(p_batch_entities(i).pk1_value);
2087: l_org_id := to_number(p_batch_entities(i).pk2_value);
2088: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2089: ,p_module => l_module_name
2090: ,p_message => p_privilege_name || ' ids: ' || l_item_id || ',' || l_org_id);
2091: l_has_prv := EGO_DATA_SECURITY.check_function(
2092: p_api_version => 1.0,
2100: -- refer to impl: EGOCHUAB.pls
2101: if (l_has_prv = 'F') then
2102: l_err_msg := ', no item privilege '|| p_privilege_name ||', item: '
2103: || p_batch_entities(i).pk1_value || ', org: ' ||p_batch_entities(i).pk2_value;
2104: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2105: ,p_module => l_module_name
2106: ,p_message => l_err_msg
2107: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
2108:
2124: elsif (l_has_prv <> 'T') then
2125: l_err_msg := ', error while check item privilege '
2126: || p_privilege_name ||', item: ' || p_batch_entities(i).pk1_value
2127: || ', org: ' ||p_batch_entities(i).pk2_value;
2128: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2129: ,p_module => l_module_name
2130: ,p_message => l_err_msg
2131: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
2132: end if;
2147: , p_token => l_token);
2148: EGO_UTIL_PK.count_and_get (p_msg_count => x_msg_count
2149: ,p_msg_data => x_msg_data );
2150: END IF;
2151: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2152: ,P_MODULE => L_MODULE_NAME
2153: ,p_message => 'checking Item Privs, x_return_status ' || x_return_status);
2154:
2155: exception
2154:
2155: exception
2156: when others then
2157: l_err_msg := ' others error ' ||sqlerrm ;
2158: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2159: ,p_module => l_module_name
2160: ,p_message => l_err_msg
2161: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
2162: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
2203: l_item_id := to_number(p_batch_entities(i).pk1_value);
2204: l_org_id := to_number(p_batch_entities(i).pk2_value);
2205: l_rev_id := to_number(p_batch_entities(i).pk3_value);
2206:
2207: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2208: ,p_module => l_module_name
2209: ,p_message => 'item:' || l_item_id
2210: || ', org_id:' || l_org_id
2211: || ', rev_id:' || l_rev_id);
2239: l_err_msg := l_err_msg || ' item explosion date is invalid';
2240: l_has_expl_err := true;
2241: end if;
2242:
2243: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2244: ,p_module => l_module_name
2245: ,p_message => l_err_msg);
2246:
2247: begin
2307: l_module_name varchar2(50) := 'EGO_PUB_FWK_PK.hasPublishPrivilege';
2308: begin
2309: if (p_batch_type = C_BATCH_ENTITY_ITEM ) then
2310: -- check user has view item priv 'EGO_VIEW_ITEM'
2311: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2312: ,p_module => l_module_name
2313: ,p_message => 'check item view privilege');
2314: hasItemPriv(p_user_id, p_batch_entities, 'EGO_VIEW_ITEM',
2315: x_return_status, x_msg_count, x_msg_data);
2316: if x_return_status <> FND_API.G_RET_STS_SUCCESS then
2317: return ;
2318: end if;
2319: -- check user has publish item priv 'EGO_PUBLISH_ITEM'
2320: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2321: ,p_module => l_module_name
2322: ,p_message => 'check item publish privilege');
2323: hasItemPriv(p_user_id, p_batch_entities, 'EGO_PUBLISH_ITEM',
2324: x_return_status, x_msg_count, x_msg_data);
2326: return ;
2327: end if;
2328:
2329: -- check the selected item rev is implemented
2330: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2331: ,p_module => l_module_name
2332: ,p_message => 'check item rev implemented status, explosion date valid');
2333:
2334: hasItemsRevsImplExplValid(p_batch_entities, p_expl_date,
2337: return ;
2338: end if;
2339: else
2340: -- check user has pub/sync privileges of icc/ag/vs
2341: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2342: ,p_module => l_module_name
2343: ,p_message => 'check icc/ag/vs access priv');
2344: hasPublishSyncPriv(p_user_id, p_batch_type,
2345: x_return_status, x_msg_count, x_msg_data);
2493: end if;
2494:
2495: if (not l_valid ) then
2496: x_return_status := FND_API.G_RET_STS_ERROR;
2497: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2498: ,p_module => l_module_name
2499: ,p_message => 'invalid entity data, ' || l_msg);
2500: end if;
2501: end loop;
2500: end if;
2501: end loop;
2502:
2503: if (x_return_status = FND_API.G_RET_STS_ERROR) then
2504: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2505: ,p_module => l_module_name
2506: ,p_message => ' entities have invalid '
2507: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
2508: EGO_UTIL_PK.put_fnd_stack_msg (p_appln_short_name=>'EGO'
2525: l_batch_entities TBL_OF_BAT_ENT_OBJ_TYPE;
2526: begin
2527: x_return_status := FND_API.G_RET_STS_SUCCESS;
2528: l_batch_entities := p_batch_entities;
2529: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2530: ,p_module => l_module_name
2531: ,p_message => 'check entity with multi-rev' );
2532:
2533: for i in 1..p_batch_entities.count loop
2536: and nvl(l_batch_entities(j).pk1_value, 0) = nvl(l_batch_entities(i).pk1_value, 0)
2537: and nvl(l_batch_entities(j).pk2_value, 0) = nvl(l_batch_entities(i).pk2_value, 0)
2538: and nvl(l_batch_entities(j).pk3_value, 0) <> nvl(l_batch_entities(i).pk3_value, 0)
2539: ) then
2540: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2541: ,p_module => l_module_name
2542: ,p_message => 'item:' || l_batch_entities(i).pk1_value
2543: || ', org_id:' || l_batch_entities(i).pk2_value
2544: || ', rev_id:' || l_batch_entities(i).pk3_value
2548: if (p_batch_type = C_BATCH_ENTITY_VS
2549: and nvl(l_batch_entities(j).pk1_value, 0) = nvl(l_batch_entities(i).pk1_value, 0)
2550: and nvl(l_batch_entities(j).pk2_value, 0) <> nvl(l_batch_entities(i).pk2_value, 0)
2551: ) then
2552: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2553: ,p_module => l_module_name
2554: ,p_message => 'valueset:' || l_batch_entities(i).pk1_value
2555: || ', rev_id:' || l_batch_entities(i).pk2_value
2556: || ' has another rev !!!' );
2636: where batch_id = p_batch_id and created_by = l_user_id;
2637: exception
2638: when no_data_found then
2639: x_return_status := FND_API.G_RET_STS_ERROR;
2640: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2641: ,p_module => l_module_name
2642: ,p_message => to_char(p_batch_id) || ', not batch creator');
2643: EGO_UTIL_PK.put_fnd_stack_msg (p_appln_short_name=>'EGO'
2644: ,p_message =>'EGO_PUB_USR_NOT_OWNER');
2652: where batch_id = p_batch_id and STATUS_CODE = C_STATUS_DRAFT;
2653: exception
2654: when no_data_found then
2655: x_return_status := FND_API.G_RET_STS_ERROR;
2656: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2657: ,p_module => l_module_name
2658: ,p_message => to_char(p_batch_id) || ', not draft batch');
2659: EGO_UTIL_PK.put_fnd_stack_msg (p_appln_short_name=>'EGO'
2660: ,p_message =>'EGO_PUB_STATUS_NOT_DRAFT');
2690:
2691: update EGO_PUB_BAT_STATUS_B set STATUS_CODE = C_STATUS_SUBMITTED
2692: where batch_id = l_batch_id and STATUS_CODE <> C_STATUS_SUBMITTED;
2693:
2694: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2695: ,p_module => l_module_name
2696: ,p_message => 'prepare evt params');
2697:
2698: -- invoke business event
2864: ,p_value => lower(l_user_name) || '.password'
2865: ,p_ParameterList => l_parameter_List);
2866:
2867: l_event_key := l_event_name || '-' || l_event_key;
2868: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2869: ,p_module => l_module_name
2870: ,p_message => 'raise evt ' || l_event_key);
2871:
2872: begin
2880: commit;
2881: exception
2882: WHEN OTHERS THEN
2883: ROLLBACK TO PUB_BAT_STATUS_CHANGE;
2884: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2885: ,p_module => l_module_name
2886: ,p_message => ' publish failure: ' || sqlerrm);
2887: x_return_status := FND_API.G_RET_STS_ERROR;
2888: end;
2890: exception
2891: WHEN OTHERS THEN
2892: ROLLBACK TO PUB_BAT_STATUS_CHANGE;
2893: x_return_status := FND_API.G_RET_STS_ERROR;
2894: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_UNEXPECTED
2895: ,p_module => l_module_name
2896: ,p_message => ' publish failure, general: ' || sqlerrm);
2897:
2898: END publish_pvt;
2991: when no_data_found then
2992: null; -- it should be unqiue
2993: end;
2994:
2995: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2996: ,p_module => l_module_name
2997: ,p_message => '-- Create_batch Params --');
2998: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2999: ,p_module => l_module_name
2994:
2995: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2996: ,p_module => l_module_name
2997: ,p_message => '-- Create_batch Params --');
2998: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2999: ,p_module => l_module_name
3000: ,p_message => 'p_api_version ' || to_char(p_api_version));
3001: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3002: ,p_module => l_module_name
2997: ,p_message => '-- Create_batch Params --');
2998: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
2999: ,p_module => l_module_name
3000: ,p_message => 'p_api_version ' || to_char(p_api_version));
3001: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3002: ,p_module => l_module_name
3003: ,p_message => 'p_batch_name ' || p_batch_name);
3004: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3005: ,p_module => l_module_name
3000: ,p_message => 'p_api_version ' || to_char(p_api_version));
3001: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3002: ,p_module => l_module_name
3003: ,p_message => 'p_batch_name ' || p_batch_name);
3004: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3005: ,p_module => l_module_name
3006: ,p_message => 'p_batch_type ' || to_char(p_batch_type));
3007: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3008: ,p_module => l_module_name
3003: ,p_message => 'p_batch_name ' || p_batch_name);
3004: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3005: ,p_module => l_module_name
3006: ,p_message => 'p_batch_type ' || to_char(p_batch_type));
3007: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3008: ,p_module => l_module_name
3009: ,p_message => 'p_submit_flag ' ||
3010: (case p_submit_flag when true then 'true' when false then 'false' end));
3011:
3036: x_return_status, x_msg_count, x_msg_data);
3037: if x_return_status <> FND_API.G_RET_STS_SUCCESS then
3038: return ;
3039: end if;
3040: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3041: ,P_MODULE => L_MODULE_NAME
3042: ,p_message => 'checked invalid Entities, x_return_status ' || x_return_status);
3043:
3044: -- entities with same id and different version are exception case
3046: x_return_status, x_msg_count, x_msg_data);
3047: if x_return_status <> FND_API.G_RET_STS_SUCCESS then
3048: raise EGO_PUB_MUL_ENTITY_REVS;
3049: end if;
3050: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3051: ,p_module => l_module_name
3052: ,p_message => 'checked multi EntRevs, x_return_status ' || x_return_status);
3053:
3054: l_expl_date := getExplosionDate(l_pub_params);
3056: l_expl_date, x_return_status, x_msg_count, x_msg_data);
3057: if x_return_status <> FND_API.G_RET_STS_SUCCESS then
3058: return ;
3059: end if;
3060: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3061: ,P_MODULE => L_MODULE_NAME
3062: ,p_message => 'checked Privs, x_return_status ' || x_return_status);
3063:
3064: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3060: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3061: ,P_MODULE => L_MODULE_NAME
3062: ,p_message => 'checked Privs, x_return_status ' || x_return_status);
3063:
3064: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3065: ,p_module => l_module_name
3066: ,p_message => 'user has privilege to publish');
3067: -- end of input validation
3068:
3075: l_submit_date := null;
3076: end if;
3077:
3078: x_return_status := FND_API.G_RET_STS_SUCCESS;
3079: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3080: ,P_MODULE => L_MODULE_NAME
3081: ,p_message => 'x_return_status ' || x_return_status);
3082:
3083: -- insert data into batch tables
3153: end LOOP;
3154:
3155: -- insert batch entities with batch_entities and batch_id
3156: for i in 1..l_batch_entities.count loop
3157: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3158: ,p_module => l_module_name
3159: ,p_message => 'l_batch_entities '
3160: || ', pk1:' || nvl(l_batch_entities(i).pk1_value, 'null')
3161: || ', pk2:' || nvl(l_batch_entities(i).pk2_value, 'null')
3203: end loop;
3204:
3205: -- insert target systems with target_systems and batch_id
3206: for i in 1..l_target_systems.count loop
3207: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3208: ,P_MODULE => L_MODULE_NAME
3209: ,P_MESSAGE => ' system code: ' || l_target_systems(i).SYSTEM_CODE );
3210: insert into EGO_PUB_BAT_SYSTEMS_B (
3211: batch_id,
3275: end if;
3276: exception
3277: when others then
3278: l_err_msg := ' publish failure: ' || l_batch_id || '; ' ||sqlerrm ;
3279: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3280: ,p_module => l_module_name
3281: ,p_message => l_err_msg
3282: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
3283: x_return_status := FND_API.G_RET_STS_ERROR;
3284: x_msg_data := l_err_msg;
3285: raise EGO_PUB_PUBLISH_FAILED;
3286: end;
3287: end if;
3288: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3289: ,P_MODULE => L_MODULE_NAME
3290: ,p_message => 'creat_batch end: x_return_status ' || x_return_status);
3291:
3292: exception
3292: exception
3293: -- EGO_INVALID_RESPONSIBILITY_ID
3294: when EGO_PUB_BATCHNAME_NULL then
3295: x_return_status := FND_API.G_RET_STS_ERROR;
3296: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3297: ,p_module => l_module_name
3298: ,p_message => ' batch name is null'
3299: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
3300: l_token(1).token_name := 'PARAM';
3305: EGO_UTIL_PK.count_and_get (p_msg_count => x_msg_count
3306: ,p_msg_data => x_msg_data );
3307: when EGO_PUB_BATCHNAME_DUP then
3308: x_return_status := FND_API.G_RET_STS_ERROR;
3309: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3310: ,p_module => l_module_name
3311: ,p_message => p_batch_name || ', batch name is duplicated '
3312: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
3313: EGO_UTIL_PK.put_fnd_stack_msg (p_appln_short_name=>'EGO'
3316: ,p_msg_data => x_msg_data );
3317:
3318: when EGO_PUB_BATCHTYPE_NULL then
3319: x_return_status := FND_API.G_RET_STS_ERROR;
3320: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3321: ,p_module => l_module_name
3322: ,p_message => ' batch type is null'
3323: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
3324: l_token(1).token_name := 'PARAM';
3330: ,p_msg_data => x_msg_data );
3331:
3332: when EGO_PUB_BATCHTYPE_INVL then
3333: x_return_status := FND_API.G_RET_STS_ERROR;
3334: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3335: ,p_module => l_module_name
3336: ,p_message => ' batch type is invalid'
3337: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
3338: EGO_UTIL_PK.put_fnd_stack_msg (p_appln_short_name=>'EGO'
3341: ,p_msg_data => x_msg_data );
3342:
3343: when EGO_PUB_PARAMS_NULL then
3344: x_return_status := FND_API.G_RET_STS_ERROR;
3345: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3346: ,p_module => l_module_name
3347: ,p_message => ' batch param is null'
3348: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
3349: l_token(1).token_name := 'PARAM';
3355: ,p_msg_data => x_msg_data );
3356:
3357: when EGO_PUB_ENTITIES_NULL then
3358: x_return_status := FND_API.G_RET_STS_ERROR;
3359: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3360: ,p_module => l_module_name
3361: ,p_message => ' EGO_NO_ITEMS_TO_PUBLISH'
3362: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
3363: EGO_UTIL_PK.put_fnd_stack_msg (p_appln_short_name=>'EGO'
3366: ,p_msg_data => x_msg_data );
3367:
3368: when EGO_PUB_TARGET_SYS_NULL then
3369: x_return_status := FND_API.G_RET_STS_ERROR;
3370: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3371: ,p_module => l_module_name
3372: ,p_message => ' target system is null'
3373: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
3374: EGO_UTIL_PK.put_fnd_stack_msg (p_appln_short_name=>'EGO'
3377: ,p_msg_data => x_msg_data );
3378:
3379: when EGO_PUB_MUL_ENTITY_REVS then
3380: x_return_status := FND_API.G_RET_STS_ERROR;
3381: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3382: ,p_module => l_module_name
3383: ,p_message => ' it has entities with multi-rev '
3384: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
3385: EGO_UTIL_PK.put_fnd_stack_msg (p_appln_short_name=>'EGO'
3388: ,p_msg_data => x_msg_data );
3389:
3390: when EGO_PUB_PUBLISH_FAILED then
3391: x_return_status := FND_API.G_RET_STS_ERROR;
3392: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3393: ,p_module => l_module_name
3394: ,p_message => ' raise event failed'
3395: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
3396: EGO_UTIL_PK.put_fnd_stack_msg (p_appln_short_name=>'EGO'
3399: ,p_msg_data => x_msg_data );
3400:
3401: when others then
3402: l_err_msg := ' others error ' ||sqlerrm ;
3403: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3404: ,p_module => l_module_name
3405: ,p_message => l_err_msg
3406: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
3407: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
3467: l_params_count := p_batch_ids.count;
3468: else
3469: l_params_count := p_batch_names.count;
3470: end if;
3471: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3472: ,p_module => l_module_name
3473: ,p_message => ' params count: ' || l_params_count);
3474:
3475: -- raise biz event
3515: end if;
3516:
3517: -- for item type, get batch entities to check privileges also
3518: if (l_batch_type = C_BATCH_ENTITY_ITEM ) then
3519: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3520: ,p_module => l_module_name
3521: ,p_message => 'get items');
3522: l_batch_entities := getBatchEntities(l_batch_id);
3523: else
3520: ,p_module => l_module_name
3521: ,p_message => 'get items');
3522: l_batch_entities := getBatchEntities(l_batch_id);
3523: else
3524: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3525: ,p_module => l_module_name
3526: ,p_message => 'get meta pub type');
3527: select nvl(char_value, 'PUBLISH') into l_pub_type
3528: from ego_pub_bat_params_b
3538: exception
3539: when no_data_found then
3540: l_err_msg := ' invalid batch name/id pair: ' || l_batch_name
3541: || ', ' || l_batch_id;
3542: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3543: ,p_module => l_module_name
3544: ,p_message => l_err_msg);
3545: l_invl_count := l_invl_count + 1;
3546:
3545: l_invl_count := l_invl_count + 1;
3546:
3547: when EGO_PUB_BATCH_NOT_CREATOR then
3548: l_err_msg := ' the user is not batch creator ';
3549: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3550: ,p_module => l_module_name
3551: ,p_message => l_err_msg);
3552: EGO_UTIL_PK.put_fnd_stack_msg (p_appln_short_name=>'EGO'
3553: ,p_message =>'EGO_PUB_BATCH_NOT_CREATOR');
3557: l_invl_count := l_invl_count + 1;
3558:
3559: when EGO_PUB_BATCH_NOT_DRAFT then
3560: l_err_msg := ' the batch status is not draft ';
3561: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3562: ,p_module => l_module_name
3563: ,p_message => l_err_msg);
3564: EGO_UTIL_PK.put_fnd_stack_msg (p_appln_short_name=>'EGO'
3565: ,p_message =>'EGO_PUB_BATCH_NOT_DRAFT');
3570:
3571: when others then
3572: l_invl_count := l_invl_count + 1;
3573: l_err_msg := ' others error ' || l_batch_name || ',' ||sqlerrm ;
3574: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3575: ,p_module => l_module_name
3576: ,p_message => l_err_msg);
3577: end;
3578: END LOOP;
3577: end;
3578: END LOOP;
3579:
3580: if (l_invl_count = l_params_count) then
3581: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3582: ,p_module => l_module_name
3583: ,p_message => 'no valid name, id pair');
3584: raise EGO_PUB_BATCH_NAMEIDS_INVL;
3585: end if;
3588: end if;
3589:
3590: EXCEPTION
3591: when EGO_PUB_BATCH_NAMEIDS_NULL then
3592: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3593: ,p_module => l_module_name
3594: ,p_message => ' names & ids are null ');
3595: l_token(1).token_name := 'PARAM';
3596: l_token(1).token_value := 'p_batch_ids & p_batch_names';
3601: EGO_UTIL_PK.count_and_get (p_msg_count => x_msg_count
3602: ,p_msg_data => x_msg_data );
3603:
3604: when EGO_PUB_BATCH_NAMEIDS_INVL then
3605: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3606: ,p_module => l_module_name
3607: ,p_message => ' names, ids length not match, no valid pair');
3608: EGO_UTIL_PK.put_fnd_stack_msg (p_appln_short_name=>'EGO'
3609: ,p_message =>'EGO_PUB_BATCH_NAMEIDS_INVL');
3611: EGO_UTIL_PK.count_and_get (p_msg_count => x_msg_count
3612: ,p_msg_data => x_msg_data );
3613:
3614: when EGO_PUB_PUBLISH_FAILED then
3615: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3616: ,p_module => l_module_name
3617: ,p_message => ' it has failed publish batches'
3618: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
3619: EGO_UTIL_PK.put_fnd_stack_msg (p_appln_short_name=>'EGO'
3712: l_pub_params(l_counter).char_value := l_param_char_vals(i);
3713: l_pub_params(l_counter).number_value := l_param_num_vals(i);
3714: l_counter := l_counter + 1;
3715: end loop;
3716: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3717: ,p_module => l_module_name
3718: ,p_message => 'get pub params, ' || l_pub_params.count);
3719:
3720: -- build entities
3718: ,p_message => 'get pub params, ' || l_pub_params.count);
3719:
3720: -- build entities
3721: l_batch_entities := getBatchEntities(l_batch_id);
3722: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3723: ,p_module => l_module_name
3724: ,p_message => 'get pub entities, ' || l_batch_entities.count);
3725:
3726: -- build target systems
3756: x_new_batch_id, x_return_status, x_msg_count, x_msg_data);
3757:
3758: exception
3759: when EGO_PUB_BATCHNAMEID_NULL then
3760: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3761: ,p_module => l_module_name
3762: ,p_message => ' batch_name & id are null '
3763: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
3764: x_return_status := FND_API.G_RET_STS_ERROR;
3770: EGO_UTIL_PK.count_and_get (p_msg_count => x_msg_count
3771: ,p_msg_data => x_msg_data );
3772:
3773: when EGO_PUB_BATCHNAMEID_DUP then
3774: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3775: ,p_module => l_module_name
3776: ,p_message => ' batch_name, id pair has dup '
3777: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
3778: x_return_status := FND_API.G_RET_STS_ERROR;
3781: ego_util_pk.count_and_get (p_msg_count => x_msg_count
3782: ,p_msg_data => x_msg_data );
3783:
3784: when EGO_PUB_BATCHNAMEID_INVL then
3785: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3786: ,p_module => l_module_name
3787: ,p_message => ' batch_name, id pair is invalid '
3788: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
3789: x_return_status := FND_API.G_RET_STS_ERROR;
3793: ,p_msg_data => x_msg_data );
3794:
3795: when others then
3796: l_err_msg := ' others error ' ||sqlerrm ;
3797: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3798: ,p_module => l_module_name
3799: ,p_message => l_err_msg
3800: ||to_char(sysdate, 'dd-mon-yyyy hh:mi:ss'));
3801: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
3850: l_params_count := p_batch_ids.count;
3851: else
3852: l_params_count := p_batch_names.count;
3853: end if;
3854: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3855: ,p_module => l_module_name
3856: ,p_message => ' params count: ' || l_params_count);
3857:
3858: if (p_batch_names.count > 0 or p_batch_ids.count > 0) then
3862: end if;
3863: if (p_batch_ids.count > 0) then
3864: l_batch_id := p_batch_ids(i);
3865: end if;
3866: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3867: ,p_module => l_module_name
3868: ,p_message => ' name:' || l_batch_name
3869: || ', id:' || l_batch_id);
3870:
3894: l_batch_ids := l_batch_ids || ', ' || l_batch_id;
3895: end if;
3896: exception
3897: when no_data_found then
3898: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3899: ,p_module => l_module_name
3900: ,p_message => 'invalid name/id pair, no data');
3901: when too_many_rows then
3902: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3898: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3899: ,p_module => l_module_name
3900: ,p_message => 'invalid name/id pair, no data');
3901: when too_many_rows then
3902: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3903: ,p_module => l_module_name
3904: ,p_message => 'invalid name/id pair, dup data');
3905: end;
3906: end loop;
3940: end if;
3941:
3942: EXCEPTION
3943: when EGO_PUB_BATCH_PARAMS_NULL then
3944: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3945: ,p_module => l_module_name
3946: ,p_message => ' params are null');
3947: l_token(1).token_name := 'PARAM';
3948: l_token(1).token_value := 'p_batch_names, p_batch_ids & p_purge_days';
3953: EGO_UTIL_PK.count_and_get (p_msg_count => x_msg_count
3954: ,p_msg_data => x_msg_data );
3955:
3956: when EGO_PUB_BATCH_NAMEIDS_INVL then
3957: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3958: ,p_module => l_module_name
3959: ,p_message => ' names/ids length not match, or invalid pair ');
3960: EGO_UTIL_PK.put_fnd_stack_msg (p_appln_short_name=>'EGO'
3961: ,p_message =>'EGO_PUB_BATCH_NAMEIDS_INVL');
3963: EGO_UTIL_PK.count_and_get (p_msg_count => x_msg_count
3964: ,p_msg_data => x_msg_data );
3965:
3966: when EGO_PUB_BATCH_PURGE_CP_FAIL then
3967: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3968: ,p_module => l_module_name
3969: ,p_message => ' cannot launch the purge cp, pls contact admin ');
3970: EGO_UTIL_PK.put_fnd_stack_msg (p_appln_short_name=>'EGO'
3971: ,p_message =>'EGO_PUB_BATCH_PURGE_CP_FAIL');
3974: ,p_msg_data => x_msg_data );
3975:
3976: when others then
3977: l_err_msg := l_err_msg || ' others error ' || sqlerrm ;
3978: EGO_COMMON_PVT.WRITE_DIAGNOSTIC(p_log_level => FND_LOG.LEVEL_PROCEDURE
3979: ,p_module => l_module_name
3980: ,p_message => l_err_msg);
3981: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR;
3982: x_msg_data := l_err_msg;