47: l_api_name VARCHAR2(255):='create_pp_queue';
48: l_api_version_number NUMBER:=1.0;
49: l_seq_id NUMBER;
50:
51: l_return_status VARCHAR2(20) := FND_API.G_RET_STS_SUCCESS;
52: l_msg_count NUMBER := 0;
53: l_msg_data VARCHAR2(2000);
54: i INTEGER;
55: l_action number :=1;
60: SAVEPOINT create_item_tag_PVT;
61:
62: -- Standard call to check for call compatibility.
63:
64: IF NOT FND_API.Compatible_API_Call (l_api_version_number,
65: p_api_version_number,
66: l_api_name,
67: G_PKG_NAME)
68: THEN
65: p_api_version_number,
66: l_api_name,
67: G_PKG_NAME)
68: THEN
69: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
70: END IF;
71:
72:
73: -- Initialize message list if p_init_msg_list is set to TRUE.
70: END IF;
71:
72:
73: -- Initialize message list if p_init_msg_list is set to TRUE.
74: IF FND_API.to_Boolean( p_init_msg_list )
75: THEN
76: FND_MSG_PUB.initialize;
77: END IF;
78:
76: FND_MSG_PUB.initialize;
77: END IF;
78:
79: -- Initialize API return status to SUCCESS
80: x_return_status := FND_API.G_RET_STS_SUCCESS;
81:
82: --begins here
83:
84: --get next sequential number for msg_meta_id
160:
161: end if; -- FIRST is not null
162:
163: -- Standard Check Of p_commit.
164: IF FND_API.To_Boolean(p_commit) THEN
165: COMMIT WORK;
166: END IF;
167:
168:
173: );
174:
175: EXCEPTION
176:
177: WHEN FND_API.G_EXC_ERROR THEN
178: ROLLBACK TO create_item_tag_PVT;
179: x_return_status := FND_API.G_RET_STS_ERROR ;
180: FND_MSG_PUB.Count_And_Get
181:
175: EXCEPTION
176:
177: WHEN FND_API.G_EXC_ERROR THEN
178: ROLLBACK TO create_item_tag_PVT;
179: x_return_status := FND_API.G_RET_STS_ERROR ;
180: FND_MSG_PUB.Count_And_Get
181:
182: ( p_count => x_msg_count,
183: p_data => x_msg_data
182: ( p_count => x_msg_count,
183: p_data => x_msg_data
184: );
185:
186: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
187: ROLLBACK TO create_item_tag_PVT;
188: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR ;
189: FND_MSG_PUB.Count_And_Get
190: ( p_count => x_msg_count,
184: );
185:
186: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
187: ROLLBACK TO create_item_tag_PVT;
188: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR ;
189: FND_MSG_PUB.Count_And_Get
190: ( p_count => x_msg_count,
191: p_data => x_msg_data
192: );
192: );
193:
194: WHEN OTHERS THEN
195: ROLLBACK TO create_item_tag_PVT;
196: x_return_status := FND_API.G_RET_STS_ERROR;
197: IF FND_MSG_PUB.Check_Msg_Level
198: (FND_MSG_PUB.G_MSG_LVL_UNEXP_ERROR)
199: THEN
200: FND_MSG_PUB.Add_Exc_Msg
229: l_api_name VARCHAR2(255):='create_item_tag';
230: l_api_version_number NUMBER:=1.0;
231: l_seq_id NUMBER;
232:
233: l_return_status VARCHAR2(20) := FND_API.G_RET_STS_SUCCESS;
234: l_msg_count NUMBER := 0;
235: l_msg_data VARCHAR2(2000);
236:
237: l_queue_rec iem_rt_pp_queues%rowtype;
243: SAVEPOINT get_queue_rec_PVT;
244:
245: -- Standard call to check for call compatibility.
246:
247: IF NOT FND_API.Compatible_API_Call (l_api_version_number,
248: p_api_version_number,
249: l_api_name,
250: G_PKG_NAME)
251: THEN
248: p_api_version_number,
249: l_api_name,
250: G_PKG_NAME)
251: THEN
252: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
253: END IF;
254:
255:
256: -- Initialize message list if p_init_msg_list is set to TRUE.
253: END IF;
254:
255:
256: -- Initialize message list if p_init_msg_list is set to TRUE.
257: IF FND_API.to_Boolean( p_init_msg_list )
258: THEN
259: FND_MSG_PUB.initialize;
260: END IF;
261:
259: FND_MSG_PUB.initialize;
260: END IF;
261:
262: -- Initialize API return status to SUCCESS
263: x_return_status := FND_API.G_RET_STS_SUCCESS;
264:
265: for x in ( select email_id
266: from IEM_RT_PP_QUEUES
267: where flag = 'N' and retry_count < 5
291: x_action := l_queue_rec.action;
292: END IF;
293:
294: -- Standard Check Of p_commit.
295: IF FND_API.To_Boolean(p_commit) THEN
296: COMMIT WORK;
297: END IF;
298:
299: -- Standard callto get message count and if count is 1, get message info.
301: ( p_count => x_msg_count,
302: p_data => x_msg_data
303: );
304: EXCEPTION
305: WHEN FND_API.G_EXC_ERROR THEN
306: ROLLBACK TO get_queue_rec_PVT;
307: x_return_status := FND_API.G_RET_STS_ERROR ;
308: FND_MSG_PUB.Count_And_Get
309:
303: );
304: EXCEPTION
305: WHEN FND_API.G_EXC_ERROR THEN
306: ROLLBACK TO get_queue_rec_PVT;
307: x_return_status := FND_API.G_RET_STS_ERROR ;
308: FND_MSG_PUB.Count_And_Get
309:
310: ( p_count => x_msg_count,
311: p_data => x_msg_data
310: ( p_count => x_msg_count,
311: p_data => x_msg_data
312: );
313:
314: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
315: ROLLBACK TO get_queue_rec_PVT;
316: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR ;
317: FND_MSG_PUB.Count_And_Get
318: ( p_count => x_msg_count,
312: );
313:
314: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
315: ROLLBACK TO get_queue_rec_PVT;
316: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR ;
317: FND_MSG_PUB.Count_And_Get
318: ( p_count => x_msg_count,
319: p_data => x_msg_data
320: );
320: );
321:
322: WHEN OTHERS THEN
323: ROLLBACK TO get_queue_rec_PVT;
324: x_return_status := FND_API.G_RET_STS_ERROR;
325: IF FND_MSG_PUB.Check_Msg_Level
326: (FND_MSG_PUB.G_MSG_LVL_UNEXP_ERROR)
327: THEN
328: FND_MSG_PUB.Add_Exc_Msg
350: l_api_name VARCHAR2(255):='expunge_queue';
351: l_api_version_number NUMBER:=1.0;
352: l_seq_id NUMBER;
353:
354: l_return_status VARCHAR2(20) := FND_API.G_RET_STS_SUCCESS;
355: l_msg_count NUMBER := 0;
356: l_msg_data VARCHAR2(2000);
357:
358: BEGIN
360: SAVEPOINT create_item_tag_PVT;
361:
362: -- Standard call to check for call compatibility.
363:
364: IF NOT FND_API.Compatible_API_Call (l_api_version_number,
365: p_api_version_number,
366: l_api_name,
367: G_PKG_NAME)
368: THEN
365: p_api_version_number,
366: l_api_name,
367: G_PKG_NAME)
368: THEN
369: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
370: END IF;
371:
372:
373: -- Initialize message list if p_init_msg_list is set to TRUE.
370: END IF;
371:
372:
373: -- Initialize message list if p_init_msg_list is set to TRUE.
374: IF FND_API.to_Boolean( p_init_msg_list )
375: THEN
376: FND_MSG_PUB.initialize;
377: END IF;
378:
376: FND_MSG_PUB.initialize;
377: END IF;
378:
379: -- Initialize API return status to SUCCESS
380: x_return_status := FND_API.G_RET_STS_SUCCESS;
381:
382: --begins here
383:
384: delete IEM_RT_PP_QUEUE_DTLS where email_id in
388: delete IEM_RT_PP_QUEUES where flag = 'S' and email_account_id=p_acct_id ;
389:
390:
391: -- Standard Check Of p_commit.
392: IF FND_API.To_Boolean(p_commit) THEN
393: COMMIT WORK;
394: END IF;
395:
396:
401: );
402:
403: EXCEPTION
404:
405: WHEN FND_API.G_EXC_ERROR THEN
406: ROLLBACK TO create_item_tag_PVT;
407: x_return_status := FND_API.G_RET_STS_ERROR ;
408: FND_MSG_PUB.Count_And_Get
409:
403: EXCEPTION
404:
405: WHEN FND_API.G_EXC_ERROR THEN
406: ROLLBACK TO create_item_tag_PVT;
407: x_return_status := FND_API.G_RET_STS_ERROR ;
408: FND_MSG_PUB.Count_And_Get
409:
410: ( p_count => x_msg_count,
411: p_data => x_msg_data
410: ( p_count => x_msg_count,
411: p_data => x_msg_data
412: );
413:
414: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
415: ROLLBACK TO create_item_tag_PVT;
416: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR ;
417: FND_MSG_PUB.Count_And_Get
418: ( p_count => x_msg_count,
412: );
413:
414: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
415: ROLLBACK TO create_item_tag_PVT;
416: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR ;
417: FND_MSG_PUB.Count_And_Get
418: ( p_count => x_msg_count,
419: p_data => x_msg_data
420: );
420: );
421:
422: WHEN OTHERS THEN
423: ROLLBACK TO create_item_tag_PVT;
424: x_return_status := FND_API.G_RET_STS_ERROR;
425: IF FND_MSG_PUB.Check_Msg_Level
426: (FND_MSG_PUB.G_MSG_LVL_UNEXP_ERROR)
427: THEN
428: FND_MSG_PUB.Add_Exc_Msg
459: l_api_name VARCHAR2(255):='get_queue_recs';
460: l_api_version_number NUMBER:=1.0;
461: l_seq_id NUMBER;
462:
463: l_return_status VARCHAR2(20) := FND_API.G_RET_STS_SUCCESS;
464: l_msg_count NUMBER := 0;
465: l_msg_data VARCHAR2(2000);
466:
467: l_queue_rec iem_rt_pp_queues%rowtype;
482: SAVEPOINT get_queue_rec_PVT;
483:
484: -- Standard call to check for call compatibility.
485:
486: IF NOT FND_API.Compatible_API_Call (l_api_version_number,
487: p_api_version_number,
488: l_api_name,
489: G_PKG_NAME)
490: THEN
487: p_api_version_number,
488: l_api_name,
489: G_PKG_NAME)
490: THEN
491: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
492: END IF;
493:
494:
495: -- Initialize message list if p_init_msg_list is set to TRUE.
492: END IF;
493:
494:
495: -- Initialize message list if p_init_msg_list is set to TRUE.
496: IF FND_API.to_Boolean( p_init_msg_list )
497: THEN
498: FND_MSG_PUB.initialize;
499: END IF;
500:
498: FND_MSG_PUB.initialize;
499: END IF;
500:
501: -- Initialize API return status to SUCCESS
502: x_return_status := FND_API.G_RET_STS_SUCCESS;
503:
504:
505: i := 1;
506: for y in ( select email_account_id, count(*) total,
564: x_actions := l_actions;
565: x_rfc_msgids := l_rfc_msgids;
566:
567: -- Standard Check Of p_commit.
568: IF FND_API.To_Boolean(p_commit) THEN
569: COMMIT WORK;
570: END IF;
571:
572: -- Standard callto get message count and if count is 1, get message info.
574: ( p_count => x_msg_count,
575: p_data => x_msg_data
576: );
577: EXCEPTION
578: WHEN FND_API.G_EXC_ERROR THEN
579: ROLLBACK TO get_queue_rec_PVT;
580: x_return_status := FND_API.G_RET_STS_ERROR ;
581: FND_MSG_PUB.Count_And_Get
582:
576: );
577: EXCEPTION
578: WHEN FND_API.G_EXC_ERROR THEN
579: ROLLBACK TO get_queue_rec_PVT;
580: x_return_status := FND_API.G_RET_STS_ERROR ;
581: FND_MSG_PUB.Count_And_Get
582:
583: ( p_count => x_msg_count,
584: p_data => x_msg_data
583: ( p_count => x_msg_count,
584: p_data => x_msg_data
585: );
586:
587: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
588: ROLLBACK TO get_queue_rec_PVT;
589: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR ;
590: FND_MSG_PUB.Count_And_Get
591: ( p_count => x_msg_count,
585: );
586:
587: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
588: ROLLBACK TO get_queue_rec_PVT;
589: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR ;
590: FND_MSG_PUB.Count_And_Get
591: ( p_count => x_msg_count,
592: p_data => x_msg_data
593: );
593: );
594:
595: WHEN OTHERS THEN
596: ROLLBACK TO get_queue_rec_PVT;
597: x_return_status := FND_API.G_RET_STS_ERROR;
598: IF FND_MSG_PUB.Check_Msg_Level
599: (FND_MSG_PUB.G_MSG_LVL_UNEXP_ERROR)
600: THEN
601: FND_MSG_PUB.Add_Exc_Msg
626: l_api_version_number NUMBER:=1.0;
627: l_seq_id NUMBER;
628: l_count NUMBER;
629:
630: l_return_status VARCHAR2(20) := FND_API.G_RET_STS_SUCCESS;
631: l_msg_count NUMBER := 0;
632: l_msg_data VARCHAR2(2000);
633:
634: BEGIN
636: SAVEPOINT create_item_tag_PVT;
637:
638: -- Standard call to check for call compatibility.
639:
640: IF NOT FND_API.Compatible_API_Call (l_api_version_number,
641: p_api_version_number,
642: l_api_name,
643: G_PKG_NAME)
644: THEN
641: p_api_version_number,
642: l_api_name,
643: G_PKG_NAME)
644: THEN
645: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
646: END IF;
647:
648:
649: -- Initialize message list if p_init_msg_list is set to TRUE.
646: END IF;
647:
648:
649: -- Initialize message list if p_init_msg_list is set to TRUE.
650: IF FND_API.to_Boolean( p_init_msg_list )
651: THEN
652: FND_MSG_PUB.initialize;
653: END IF;
654:
652: FND_MSG_PUB.initialize;
653: END IF;
654:
655: -- Initialize API return status to SUCCESS
656: x_return_status := FND_API.G_RET_STS_SUCCESS;
657:
658: --begins here
659: For j in 1..p_queue_ids.count loop
660:
676: );
677:
678: EXCEPTION
679:
680: WHEN FND_API.G_EXC_ERROR THEN
681: ROLLBACK TO create_item_tag_PVT;
682: x_return_status := FND_API.G_RET_STS_ERROR ;
683: FND_MSG_PUB.Count_And_Get
684:
678: EXCEPTION
679:
680: WHEN FND_API.G_EXC_ERROR THEN
681: ROLLBACK TO create_item_tag_PVT;
682: x_return_status := FND_API.G_RET_STS_ERROR ;
683: FND_MSG_PUB.Count_And_Get
684:
685: ( p_count => x_msg_count,
686: p_data => x_msg_data
685: ( p_count => x_msg_count,
686: p_data => x_msg_data
687: );
688:
689: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
690: ROLLBACK TO create_item_tag_PVT;
691: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR ;
692: FND_MSG_PUB.Count_And_Get
693: ( p_count => x_msg_count,
687: );
688:
689: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
690: ROLLBACK TO create_item_tag_PVT;
691: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR ;
692: FND_MSG_PUB.Count_And_Get
693: ( p_count => x_msg_count,
694: p_data => x_msg_data
695: );
695: );
696:
697: WHEN OTHERS THEN
698: ROLLBACK TO create_item_tag_PVT;
699: x_return_status := FND_API.G_RET_STS_ERROR;
700: IF FND_MSG_PUB.Check_Msg_Level
701: (FND_MSG_PUB.G_MSG_LVL_UNEXP_ERROR)
702: THEN
703: FND_MSG_PUB.Add_Exc_Msg
726: l_api_version_number NUMBER:=1.0;
727: l_seq_id NUMBER;
728: l_count NUMBER;
729:
730: l_return_status VARCHAR2(20) := FND_API.G_RET_STS_SUCCESS;
731: l_msg_count NUMBER := 0;
732: l_msg_data VARCHAR2(2000);
733:
734: BEGIN
736: SAVEPOINT reset_data_PVT;
737:
738: -- Standard call to check for call compatibility.
739:
740: IF NOT FND_API.Compatible_API_Call (l_api_version_number,
741: p_api_version_number,
742: l_api_name,
743: G_PKG_NAME)
744: THEN
741: p_api_version_number,
742: l_api_name,
743: G_PKG_NAME)
744: THEN
745: RAISE FND_API.G_EXC_UNEXPECTED_ERROR;
746: END IF;
747:
748:
749: -- Initialize message list if p_init_msg_list is set to TRUE.
746: END IF;
747:
748:
749: -- Initialize message list if p_init_msg_list is set to TRUE.
750: IF FND_API.to_Boolean( p_init_msg_list )
751: THEN
752: FND_MSG_PUB.initialize;
753: END IF;
754:
752: FND_MSG_PUB.initialize;
753: END IF;
754:
755: -- Initialize API return status to SUCCESS
756: x_return_status := FND_API.G_RET_STS_SUCCESS;
757:
758: --begins here
759: update iem_rt_pp_queues set flag='N' where flag='A' and retry_count<=4;
760:
765: );
766:
767: EXCEPTION
768:
769: WHEN FND_API.G_EXC_ERROR THEN
770: ROLLBACK TO create_item_tag_PVT;
771: x_return_status := FND_API.G_RET_STS_ERROR ;
772: FND_MSG_PUB.Count_And_Get
773:
767: EXCEPTION
768:
769: WHEN FND_API.G_EXC_ERROR THEN
770: ROLLBACK TO create_item_tag_PVT;
771: x_return_status := FND_API.G_RET_STS_ERROR ;
772: FND_MSG_PUB.Count_And_Get
773:
774: ( p_count => x_msg_count,
775: p_data => x_msg_data
774: ( p_count => x_msg_count,
775: p_data => x_msg_data
776: );
777:
778: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
779: ROLLBACK TO create_item_tag_PVT;
780: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR ;
781: FND_MSG_PUB.Count_And_Get
782: ( p_count => x_msg_count,
776: );
777:
778: WHEN FND_API.G_EXC_UNEXPECTED_ERROR THEN
779: ROLLBACK TO create_item_tag_PVT;
780: x_return_status := FND_API.G_RET_STS_UNEXP_ERROR ;
781: FND_MSG_PUB.Count_And_Get
782: ( p_count => x_msg_count,
783: p_data => x_msg_data
784: );
784: );
785:
786: WHEN OTHERS THEN
787: ROLLBACK TO create_item_tag_PVT;
788: x_return_status := FND_API.G_RET_STS_ERROR;
789: IF FND_MSG_PUB.Check_Msg_Level
790: (FND_MSG_PUB.G_MSG_LVL_UNEXP_ERROR)
791: THEN
792: FND_MSG_PUB.Add_Exc_Msg