1: PACKAGE BODY cac_task_purge_pub AS
2: /* $Header: cactkprb.pls 120.20 2012/01/11 06:55:09 anangupt ship $ */
3: /*=======================================================================+
4: | Copyright (c) 2002 Oracle Corporation Redwood Shores, California, USA|
5: | All rights reserved. |
90: ROLLBACK TO purge_task_attach;
91: x_return_status := fnd_api.g_ret_sts_unexp_error;
92: fnd_msg_pub.count_and_get (p_count => x_msg_count, p_data => x_msg_data);
93: if( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
94: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,'cac_task_purge_pub.delete_atth_to_tasks', ' x_return_status= '||x_return_status);
95: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,'cac_task_purge_pub.delete_atth_to_tasks', ' x_msg_data= '||x_msg_data);
96: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,'cac_task_purge_pub.delete_atth_to_tasks', ' x_msg_count= '||x_msg_count);
97: end if;
98:
91: x_return_status := fnd_api.g_ret_sts_unexp_error;
92: fnd_msg_pub.count_and_get (p_count => x_msg_count, p_data => x_msg_data);
93: if( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
94: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,'cac_task_purge_pub.delete_atth_to_tasks', ' x_return_status= '||x_return_status);
95: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,'cac_task_purge_pub.delete_atth_to_tasks', ' x_msg_data= '||x_msg_data);
96: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,'cac_task_purge_pub.delete_atth_to_tasks', ' x_msg_count= '||x_msg_count);
97: end if;
98:
99: WHEN OTHERS
92: fnd_msg_pub.count_and_get (p_count => x_msg_count, p_data => x_msg_data);
93: if( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
94: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,'cac_task_purge_pub.delete_atth_to_tasks', ' x_return_status= '||x_return_status);
95: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,'cac_task_purge_pub.delete_atth_to_tasks', ' x_msg_data= '||x_msg_data);
96: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,'cac_task_purge_pub.delete_atth_to_tasks', ' x_msg_count= '||x_msg_count);
97: end if;
98:
99: WHEN OTHERS
100: THEN
102: fnd_message.set_name ('JTF', 'JTF_ATTACHMENT_PURGE_EXCEP');
103: fnd_message.set_token ('P_TEXT', SQLCODE || SQLERRM);
104: fnd_msg_pub.add;
105: if( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
106: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,'cac_task_purge_pub.delete_atth_to_tasks', ' x_return_status= '||x_return_status);
107: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,'cac_task_purge_pub.delete_atth_to_tasks', ' x_msg_data= '||x_msg_data);
108: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,'cac_task_purge_pub.delete_atth_to_tasks', ' x_msg_count= '||x_msg_count);
109: end if;
110:
103: fnd_message.set_token ('P_TEXT', SQLCODE || SQLERRM);
104: fnd_msg_pub.add;
105: if( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
106: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,'cac_task_purge_pub.delete_atth_to_tasks', ' x_return_status= '||x_return_status);
107: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,'cac_task_purge_pub.delete_atth_to_tasks', ' x_msg_data= '||x_msg_data);
108: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,'cac_task_purge_pub.delete_atth_to_tasks', ' x_msg_count= '||x_msg_count);
109: end if;
110:
111: x_return_status := fnd_api.g_ret_sts_unexp_error;
104: fnd_msg_pub.add;
105: if( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
106: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,'cac_task_purge_pub.delete_atth_to_tasks', ' x_return_status= '||x_return_status);
107: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,'cac_task_purge_pub.delete_atth_to_tasks', ' x_msg_data= '||x_msg_data);
108: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,'cac_task_purge_pub.delete_atth_to_tasks', ' x_msg_count= '||x_msg_count);
109: end if;
110:
111: x_return_status := fnd_api.g_ret_sts_unexp_error;
112: fnd_msg_pub.count_and_get (
181: END IF;
182: --Logging input parameters
183:
184: if( FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
185: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,'cac_task_purge_pub.purge_tasks', ' p_object_type= '||p_object_type);
186: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,'cac_task_purge_pub.purge_tasks', ' p_processing_set_id= '||p_processing_set_id);
187: end if;
188:
189:
182: --Logging input parameters
183:
184: if( FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
185: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,'cac_task_purge_pub.purge_tasks', ' p_object_type= '||p_object_type);
186: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,'cac_task_purge_pub.purge_tasks', ' p_processing_set_id= '||p_processing_set_id);
187: end if;
188:
189:
190: Open get_tasks_ids(p_processing_set_id ,p_object_type );
201:
202:
203:
204: if( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
205: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'cac_task_purge_pub.purge_tasks', 'Inserting task data into global tem table');
206: end if;
207:
208: FORALL i in l_tab_tasks_id.first..l_tab_tasks_id.last
209:
228: --Calling the purge APIs for notes , UWQ, Mobile Field Service, Attachments
229: -- and interaction center to purge any references
230:
231: if( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
232: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'cac_task_purge_pub.purge_tasks', 'Before calling CSM_TASK_PURGE_PKG.DELETE_MFS_TASKS');
233: end if;
234:
235: CSM_TASK_PURGE_PKG.DELETE_MFS_TASKS(
236: P_API_VERSION => 1.0,
246: THEN
247: x_return_status := fnd_api.g_ret_sts_unexp_error;
248:
249: if( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
250: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,'cac_task_purge_pub.purge_tasks', 'return status error after calling CSM_TASK_PURGE_PKG.DELETE_MFS_TASKS');
251: end if;
252: RAISE fnd_api.g_exc_unexpected_error;
253: end if;
254:
257: -- Calling UWQ's purge API
258:
259: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL)
260: THEN
261: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'cac_task_purge_pub.purge_tasks', 'Before calling IEU_WR_PUB.PURGE_WR_ITEM');
262: END IF;
263:
264: IEU_WR_PUB.Purge_Wr_Item(
265: p_api_version_number => 1.0,
276: x_return_status := fnd_api.g_ret_sts_unexp_error;
277:
278: IF( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL)
279: THEN
280: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,'cac_task_purge_pub.purge_tasks', 'return status error after calling IEU_WR_PUB.PURGE_WR_ITEM');
281: END IF;
282:
283: RAISE fnd_api.g_exc_unexpected_error;
284:
288: -- Calling Interaction History's purge API
289:
290: IF( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL)
291: THEN
292: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'cac_task_purge_pub.purge_tasks', 'Before calling JTF_IH_PURGE.P_DELETE_INTERACTIONS');
293: END IF;
294:
295: JTF_IH_PURGE.P_Delete_Interactions(
296: p_api_version => 1.0,
307: x_return_status := fnd_api.g_ret_sts_unexp_error;
308:
309: IF( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL)
310: THEN
311: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,'cac_task_purge_pub.purge_tasks', 'return status error after calling JTF_IH_PURGE.P_DELETE_INTERACTIONS');
312: END IF;
313:
314: RAISE fnd_api.g_exc_unexpected_error;
315:
318: /************* End of addition by SBARAT on 03/02/2006 for bug# 4997851 *************/
319:
320: --calling attachment deletion wrapper api.
321: if( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
322: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'cac_task_purge_pub.purge_tasks', 'Before calling cac_task_purge_pub.delete_atth_to_tasks');
323: end if;
324:
325:
326: delete_atth_to_tasks(
338:
339:
340: if( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
341:
342: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,'cac_task_purge_pub.purge_tasks', 'return status error after calling cac_task_purge_pub.delete_atth_to_tasks');
343: end if;
344: RAISE fnd_api.g_exc_unexpected_error;
345: end if;
346:
346:
347:
348: --Calling notes api
349: if( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
350: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'cac_task_purge_pub.purge_tasks', 'Before calling cac_note_purge_pub.purge_notes');
351: end if;
352:
353:
354:
364: THEN
365: x_return_status := fnd_api.g_ret_sts_unexp_error;
366:
367: if( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
368: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,'cac_task_purge_pub.purge_tasks', 'return status error after calling cac_note_purge_pub.purge_notes');
369: end if;
370: RAISE fnd_api.g_exc_unexpected_error;
371: end if;
372:
373:
374: --calling the cac_task_purge_pvt.purge_task_entities API
375:
376: if( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
377: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'cac_task_purge_pub.purge_tasks', 'Before calling cac_task_purge_pvt.purge_task_entities');
378: end if;
379:
380: cac_task_purge_pvt.purge_task_entities(
381: p_api_version => 1.0,
394: THEN
395: x_return_status := fnd_api.g_ret_sts_unexp_error;
396:
397: if( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
398: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,'cac_task_purge_pub.purge_tasks', ' return status error after calling cac_task_purge_pvt.purge_task_entities');
399: end if;
400:
401: RAISE fnd_api.g_exc_unexpected_error;
402: END IF;
407:
408: -- dbms_output.put_line(' point 5');
409:
410: if( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
411: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'cac_task_purge_pub.purge_tasks', 'no task data exists for the given processing set id ');
412: end if;
413:
414: end if;-- for If ( l_tab_tasks_id.COUNT > 0)
415:
545: END IF;
546: --Logging input parameters
547:
548: if( FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
549: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,'cac_task_purge_pub.validate_tasks', ' p_object_type= '||p_object_type);
550: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,'cac_task_purge_pub.validate_tasks', ' p_processing_set_id= '||p_processing_set_id);
551: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,'cac_task_purge_pub.validate_tasks', ' p_purge_source_with_open_task= '||p_purge_source_with_open_task);
552: end if;
553:
546: --Logging input parameters
547:
548: if( FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
549: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,'cac_task_purge_pub.validate_tasks', ' p_object_type= '||p_object_type);
550: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,'cac_task_purge_pub.validate_tasks', ' p_processing_set_id= '||p_processing_set_id);
551: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,'cac_task_purge_pub.validate_tasks', ' p_purge_source_with_open_task= '||p_purge_source_with_open_task);
552: end if;
553:
554:
547:
548: if( FND_LOG.LEVEL_PROCEDURE >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
549: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,'cac_task_purge_pub.validate_tasks', ' p_object_type= '||p_object_type);
550: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,'cac_task_purge_pub.validate_tasks', ' p_processing_set_id= '||p_processing_set_id);
551: FND_LOG.STRING(FND_LOG.LEVEL_PROCEDURE,'cac_task_purge_pub.validate_tasks', ' p_purge_source_with_open_task= '||p_purge_source_with_open_task);
552: end if;
553:
554:
555: --calling validations for tasks
590:
591: --call MFS validation API
592:
593: if( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
594: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'cac_task_purge_pub.validate_tasks', 'Before calling CSM_TASK_PURGE_PKG.VALIDATE_MFS_TASKS');
595: end if;
596:
597: CSM_TASK_PURGE_PKG.VALIDATE_MFS_TASKS(
598: P_API_VERSION => 1.0,
608: THEN
609: x_return_status := fnd_api.g_ret_sts_unexp_error;
610:
611: if( FND_LOG.LEVEL_EXCEPTION >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
612: FND_LOG.STRING(FND_LOG.LEVEL_EXCEPTION,'cac_task_purge_pub.purge_tasks', 'return status error after calling CSM_TASK_PURGE_PKG.VALIDATE_MFS_TASKS');
613: end if;
614: RAISE fnd_api.g_exc_unexpected_error;
615: end if;
616:
617:
618: --bulk update the rows with error status E for which tasks validations have failed.
619:
620: if( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL) then
621: FND_LOG.STRING(FND_LOG.LEVEL_STATEMENT,'cac_task_purge_pub.validate_tasks', ' before updating jtf_object_purge_param_tmp');
622: end if;
623:
624: Update jtf_object_purge_param_tmp temp
625: Set temp.purge_status='E',
729: END IF;
730:
731: END validate_tasks;
732:
733: END CAC_TASK_PURGE_PUB;