DBA Data[Home] [Help]

APPS.CSM_QUERY_INSTANCE_PKG dependencies on CSM_QUERY_INSTANCE_PKG

Line 1: PACKAGE BODY CSM_QUERY_INSTANCE_PKG AS

1: PACKAGE BODY CSM_QUERY_INSTANCE_PKG AS
2: /* $Header: csmuqib.pls 120.8.12020000.2 2012/08/10 09:37:53 pramosin ship $ */
3:
4: error EXCEPTION;
5:

Line 8: g_object_name CONSTANT VARCHAR2(30) := 'CSM_QUERY_INSTANCE_PKG';

4: error EXCEPTION;
5:
6:
7: /*** Globals ***/
8: g_object_name CONSTANT VARCHAR2(30) := 'CSM_QUERY_INSTANCE_PKG';
9: g_pub_name CONSTANT VARCHAR2(30) := 'CSM_QUERY_INSTANCES';
10: g_pub_qvv_name CONSTANT VARCHAR2(30) := 'CSM_QUERY_VARIABLE_VALUES';
11: g_debug_level NUMBER; -- debug level
12: g_seqno_lst CSM_INTEGER_LIST;

Line 111: CSM_UTIL_PKG.LOG('Entering CSM_QUERY_INSTANCE_PKG.APPLY_INSERT for Instance ID ' || p_record.INSTANCE_ID ,

107: l_query_type VARCHAR2(255);
108: BEGIN
109:
110: x_return_status := FND_API.G_RET_STS_SUCCESS;
111: CSM_UTIL_PKG.LOG('Entering CSM_QUERY_INSTANCE_PKG.APPLY_INSERT for Instance ID ' || p_record.INSTANCE_ID ,
112: 'CSM_QUERY_INSTANCE_PKG.APPLY_INSERT',FND_LOG.LEVEL_PROCEDURE);
113: l_query_id := p_record.QUERY_ID;
114: --Check if the Query id is valid
115: OPEN c_check_query(l_query_id);

Line 112: 'CSM_QUERY_INSTANCE_PKG.APPLY_INSERT',FND_LOG.LEVEL_PROCEDURE);

108: BEGIN
109:
110: x_return_status := FND_API.G_RET_STS_SUCCESS;
111: CSM_UTIL_PKG.LOG('Entering CSM_QUERY_INSTANCE_PKG.APPLY_INSERT for Instance ID ' || p_record.INSTANCE_ID ,
112: 'CSM_QUERY_INSTANCE_PKG.APPLY_INSERT',FND_LOG.LEVEL_PROCEDURE);
113: l_query_id := p_record.QUERY_ID;
114: --Check if the Query id is valid
115: OPEN c_check_query(l_query_id);
116: FETCH c_check_query INTO l_instance_name, l_level_id, l_level_value,l_query_type;

Line 293: CSM_UTIL_PKG.LOG('Leaving CSM_QUERY_INSTANCE_PKG.APPLY_INSERT for Instance ID ' || p_record.INSTANCE_ID ,

289: ROLLBACK TO INSERT_QUERY_INSTANCE;
290: RETURN;
291: END IF;
292:
293: CSM_UTIL_PKG.LOG('Leaving CSM_QUERY_INSTANCE_PKG.APPLY_INSERT for Instance ID ' || p_record.INSTANCE_ID ,
294: 'CSM_QUERY_INSTANCE_PKG.APPLY_INSERT',FND_LOG.LEVEL_PROCEDURE);
295: x_return_status := FND_API.G_RET_STS_SUCCESS;
296: p_error_msg := 'Upload Successful for the Instance Id : ' || l_instance_id ;
297: RETURN;

Line 294: 'CSM_QUERY_INSTANCE_PKG.APPLY_INSERT',FND_LOG.LEVEL_PROCEDURE);

290: RETURN;
291: END IF;
292:
293: CSM_UTIL_PKG.LOG('Leaving CSM_QUERY_INSTANCE_PKG.APPLY_INSERT for Instance ID ' || p_record.INSTANCE_ID ,
294: 'CSM_QUERY_INSTANCE_PKG.APPLY_INSERT',FND_LOG.LEVEL_PROCEDURE);
295: x_return_status := FND_API.G_RET_STS_SUCCESS;
296: p_error_msg := 'Upload Successful for the Instance Id : ' || l_instance_id ;
297: RETURN;
298:

Line 306: || ' for Instance ID ' || p_record.INSTANCE_ID ,'CSM_QUERY_INSTANCE_PKG.APPLY_INSERT',FND_LOG.LEVEL_EXCEPTION);

302: (
303: p_api_error => TRUE
304: );
305: CSM_UTIL_PKG.log( 'Exception in ' || g_object_name || '.APPLY_INSERT: ' || sqlerrm
306: || ' for Instance ID ' || p_record.INSTANCE_ID ,'CSM_QUERY_INSTANCE_PKG.APPLY_INSERT',FND_LOG.LEVEL_EXCEPTION);
307: p_error_msg := 'Exception in APPLY_INSERT for Instance Id : ' || l_instance_id || substr(SQLERRM, 1,2000);
308: x_return_status := FND_API.G_RET_STS_ERROR;
309: ROLLBACK TO INSERT_QUERY_INSTANCE;
310: END APPLY_INSERT;

Line 345: CSM_UTIL_PKG.LOG('Entering CSM_QUERY_INSTANCE_PKG.APPLY_DELETE for Instance ID ' || p_record.INSTANCE_ID ,

341:
342: BEGIN
343:
344: x_return_status := FND_API.G_RET_STS_SUCCESS;
345: CSM_UTIL_PKG.LOG('Entering CSM_QUERY_INSTANCE_PKG.APPLY_DELETE for Instance ID ' || p_record.INSTANCE_ID ,
346: 'CSM_QUERY_INSTANCE_PKG.APPLY_DELETE',FND_LOG.LEVEL_PROCEDURE);
347: l_query_id := p_record.QUERY_ID;
348: l_instance_id := p_record.instance_id;
349: --get user_id

Line 346: 'CSM_QUERY_INSTANCE_PKG.APPLY_DELETE',FND_LOG.LEVEL_PROCEDURE);

342: BEGIN
343:
344: x_return_status := FND_API.G_RET_STS_SUCCESS;
345: CSM_UTIL_PKG.LOG('Entering CSM_QUERY_INSTANCE_PKG.APPLY_DELETE for Instance ID ' || p_record.INSTANCE_ID ,
346: 'CSM_QUERY_INSTANCE_PKG.APPLY_DELETE',FND_LOG.LEVEL_PROCEDURE);
347: l_query_id := p_record.QUERY_ID;
348: l_instance_id := p_record.instance_id;
349: --get user_id
350: OPEN c_get_user(p_record.CLID$$CS);

Line 382: CSM_UTIL_PKG.LOG('Leaving CSM_QUERY_INSTANCE_PKG.APPLY_DELETE for Instance ID ' || p_record.INSTANCE_ID ,

378: x_return_status := FND_API.G_RET_STS_ERROR;
379: RETURN;
380: END IF;
381:
382: CSM_UTIL_PKG.LOG('Leaving CSM_QUERY_INSTANCE_PKG.APPLY_DELETE for Instance ID ' || p_record.INSTANCE_ID ,
383: 'CSM_QUERY_INSTANCE_PKG.APPLY_DELETE',FND_LOG.LEVEL_PROCEDURE);
384: x_return_status := FND_API.G_RET_STS_SUCCESS;
385: p_error_msg := 'Delete Successful for the Instance Id : ' || l_instance_id ;
386: RETURN;

Line 383: 'CSM_QUERY_INSTANCE_PKG.APPLY_DELETE',FND_LOG.LEVEL_PROCEDURE);

379: RETURN;
380: END IF;
381:
382: CSM_UTIL_PKG.LOG('Leaving CSM_QUERY_INSTANCE_PKG.APPLY_DELETE for Instance ID ' || p_record.INSTANCE_ID ,
383: 'CSM_QUERY_INSTANCE_PKG.APPLY_DELETE',FND_LOG.LEVEL_PROCEDURE);
384: x_return_status := FND_API.G_RET_STS_SUCCESS;
385: p_error_msg := 'Delete Successful for the Instance Id : ' || l_instance_id ;
386: RETURN;
387:

Line 392: || ' for Instance ID ' || p_record.INSTANCE_ID ,'CSM_QUERY_INSTANCE_PKG.APPLY_DELETE',FND_LOG.LEVEL_EXCEPTION);

388: EXCEPTION WHEN OTHERS THEN
389: fnd_msg_pub.Add_Exc_Msg( g_object_name, 'APPLY_DELETE', sqlerrm);
390: p_error_msg := CSM_UTIL_PKG.GET_ERROR_MESSAGE_TEXT (p_api_error => TRUE);
391: CSM_UTIL_PKG.log( 'Exception in ' || g_object_name || '.APPLY_DELETE: ' || sqlerrm
392: || ' for Instance ID ' || p_record.INSTANCE_ID ,'CSM_QUERY_INSTANCE_PKG.APPLY_DELETE',FND_LOG.LEVEL_EXCEPTION);
393: p_error_msg := 'Exception in APPLY_DELETE for Instance Id : ' || l_instance_id || substr(SQLERRM, 1,2000);
394: x_return_status := FND_API.G_RET_STS_ERROR;
395: END APPLY_DELETE;
396: /***

Line 412: CSM_UTIL_PKG.LOG('Entering CSM_QUERY_INSTANCE_PKG.APPLY_RECORD for Query Instance ID ' || p_record.INSTANCE_ID ,

408: /*** initialize return status and message list ***/
409: x_return_status := FND_API.G_RET_STS_SUCCESS;
410: FND_MSG_PUB.INITIALIZE;
411:
412: CSM_UTIL_PKG.LOG('Entering CSM_QUERY_INSTANCE_PKG.APPLY_RECORD for Query Instance ID ' || p_record.INSTANCE_ID ,
413: 'CSM_QUERY_INSTANCE_PKG.APPLY_RECORD',FND_LOG.LEVEL_PROCEDURE);
414:
415: IF p_record.dmltype$$='I' THEN
416: -- Process insert

Line 413: 'CSM_QUERY_INSTANCE_PKG.APPLY_RECORD',FND_LOG.LEVEL_PROCEDURE);

409: x_return_status := FND_API.G_RET_STS_SUCCESS;
410: FND_MSG_PUB.INITIALIZE;
411:
412: CSM_UTIL_PKG.LOG('Entering CSM_QUERY_INSTANCE_PKG.APPLY_RECORD for Query Instance ID ' || p_record.INSTANCE_ID ,
413: 'CSM_QUERY_INSTANCE_PKG.APPLY_RECORD',FND_LOG.LEVEL_PROCEDURE);
414:
415: IF p_record.dmltype$$='I' THEN
416: -- Process insert
417: APPLY_INSERT

Line 435: || ' for Query Instance ID ' || p_record.INSTANCE_ID ,'CSM_QUERY_INSTANCE_PKG.APPLY_RECORD',FND_LOG.LEVEL_ERROR);

431: ELSE -- update is not supported for this PI
432: -- invalid dml type
433: CSM_UTIL_PKG.LOG
434: ( 'Invalid DML type: ' || p_record.dmltype$$ || ' is not supported for this entity'
435: || ' for Query Instance ID ' || p_record.INSTANCE_ID ,'CSM_QUERY_INSTANCE_PKG.APPLY_RECORD',FND_LOG.LEVEL_ERROR);
436:
437: p_error_msg := CSM_UTIL_PKG.GET_ERROR_MESSAGE_TEXT
438: (
439: p_message => 'CSM_DML_OPERATION'

Line 447: CSM_UTIL_PKG.LOG('Leaving CSM_QUERY_INSTANCE_PKG.APPLY_RECORD for Query Instance ID ' || p_record.INSTANCE_ID ,

443:
444: x_return_status := FND_API.G_RET_STS_ERROR;
445: END IF;
446:
447: CSM_UTIL_PKG.LOG('Leaving CSM_QUERY_INSTANCE_PKG.APPLY_RECORD for Query Instance ID ' || p_record.INSTANCE_ID ,
448: 'CSM_QUERY_INSTANCE_PKG.APPLY_RECORD',FND_LOG.LEVEL_PROCEDURE);
449: EXCEPTION WHEN OTHERS THEN
450: fnd_msg_pub.Add_Exc_Msg( g_object_name, 'APPLY_RECORD', sqlerrm);
451: p_error_msg := CSM_UTIL_PKG.GET_ERROR_MESSAGE_TEXT

Line 448: 'CSM_QUERY_INSTANCE_PKG.APPLY_RECORD',FND_LOG.LEVEL_PROCEDURE);

444: x_return_status := FND_API.G_RET_STS_ERROR;
445: END IF;
446:
447: CSM_UTIL_PKG.LOG('Leaving CSM_QUERY_INSTANCE_PKG.APPLY_RECORD for Query Instance ID ' || p_record.INSTANCE_ID ,
448: 'CSM_QUERY_INSTANCE_PKG.APPLY_RECORD',FND_LOG.LEVEL_PROCEDURE);
449: EXCEPTION WHEN OTHERS THEN
450: fnd_msg_pub.Add_Exc_Msg( g_object_name, 'APPLY_RECORD', sqlerrm);
451: p_error_msg := CSM_UTIL_PKG.GET_ERROR_MESSAGE_TEXT
452: (

Line 456: || ' for Query Instance ID ' || p_record.INSTANCE_ID ,'CSM_QUERY_INSTANCE_PKG.APPLY_RECORD',FND_LOG.LEVEL_EXCEPTION);

452: (
453: p_api_error => TRUE
454: );
455: CSM_UTIL_PKG.log( 'Exception in ' || g_object_name || '.APPLY_RECORD: ' || sqlerrm
456: || ' for Query Instance ID ' || p_record.INSTANCE_ID ,'CSM_QUERY_INSTANCE_PKG.APPLY_RECORD',FND_LOG.LEVEL_EXCEPTION);
457:
458: x_return_status := FND_API.G_RET_STS_ERROR;
459:
460: END APPLY_RECORD;

Line 481: CSM_UTIL_PKG.LOG('Entering CSM_QUERY_INSTANCE_PKG.APPLY_CLIENT_CHANGES ',

477: l_process_status VARCHAR2(1);
478: l_error_msg VARCHAR2(4000);
479:
480: BEGIN
481: CSM_UTIL_PKG.LOG('Entering CSM_QUERY_INSTANCE_PKG.APPLY_CLIENT_CHANGES ',
482: 'CSM_QUERY_INSTANCE_PKG.APPLY_CLIENT_CHANGES',FND_LOG.LEVEL_PROCEDURE);
483: g_debug_level := p_debug_level;
484: x_return_status := FND_API.G_RET_STS_SUCCESS;
485:

Line 482: 'CSM_QUERY_INSTANCE_PKG.APPLY_CLIENT_CHANGES',FND_LOG.LEVEL_PROCEDURE);

478: l_error_msg VARCHAR2(4000);
479:
480: BEGIN
481: CSM_UTIL_PKG.LOG('Entering CSM_QUERY_INSTANCE_PKG.APPLY_CLIENT_CHANGES ',
482: 'CSM_QUERY_INSTANCE_PKG.APPLY_CLIENT_CHANGES',FND_LOG.LEVEL_PROCEDURE);
483: g_debug_level := p_debug_level;
484: x_return_status := FND_API.G_RET_STS_SUCCESS;
485:
486: /*** loop through all the records in inqueue ***/

Line 537: || ' for Instance ID ' || r_qi_rec.INSTANCE_ID ,'CSM_QUERY_INSTANCE_PKG.APPLY_CLIENT_CHANGES',FND_LOG.LEVEL_ERROR); -- put PK column here

533: IF l_process_status <> FND_API.G_RET_STS_SUCCESS THEN
534: /*** no -> rollback ***/
535: CSM_UTIL_PKG.LOG
536: ( 'Deleting from inqueue failed, rolling back to savepoint'
537: || ' for Instance ID ' || r_qi_rec.INSTANCE_ID ,'CSM_QUERY_INSTANCE_PKG.APPLY_CLIENT_CHANGES',FND_LOG.LEVEL_ERROR); -- put PK column here
538: ROLLBACK TO save_rec;
539: x_return_status := FND_API.G_RET_STS_ERROR;
540: END IF;
541: ELSIF l_process_Status <> FND_API.G_RET_STS_SUCCESS AND p_from_sync = 'Y' THEN

Line 544: || ' for PK ' || r_qi_rec.INSTANCE_ID ,'CSM_QUERY_INSTANCE_PKG.APPLY_CLIENT_CHANGES',FND_LOG.LEVEL_ERROR); -- put PK column here

540: END IF;
541: ELSIF l_process_Status <> FND_API.G_RET_STS_SUCCESS AND p_from_sync = 'Y' THEN
542: CSM_UTIL_PKG.LOG
543: ( 'Defer record failed, rolling back to savepoint'
544: || ' for PK ' || r_qi_rec.INSTANCE_ID ,'CSM_QUERY_INSTANCE_PKG.APPLY_CLIENT_CHANGES',FND_LOG.LEVEL_ERROR); -- put PK column here
545: ROLLBACK TO save_rec;
546: x_return_status := FND_API.G_RET_STS_ERROR;
547: ELSIF l_process_Status <> FND_API.G_RET_STS_SUCCESS AND p_from_sync ='N' THEN
548: /*** Record was not applied successfully -> defer and reject records ***/

Line 550: || ' for PK ' || r_qi_rec.INSTANCE_ID ,'CSM_QUERY_INSTANCE_PKG.APPLY_CLIENT_CHANGES',FND_LOG.LEVEL_ERROR); -- put PK column here

546: x_return_status := FND_API.G_RET_STS_ERROR;
547: ELSIF l_process_Status <> FND_API.G_RET_STS_SUCCESS AND p_from_sync ='N' THEN
548: /*** Record was not applied successfully -> defer and reject records ***/
549: csm_util_pkg.log( 'Record not processed successfully, deferring and rejecting record'
550: || ' for PK ' || r_qi_rec.INSTANCE_ID ,'CSM_QUERY_INSTANCE_PKG.APPLY_CLIENT_CHANGES',FND_LOG.LEVEL_ERROR); -- put PK column here
551:
552: CSM_UTIL_PKG.DEFER_RECORD
553: (
554: p_user_name

Line 593: || ' for PK ' || r_qi_rec.INSTANCE_ID ,'CSM_QUERY_INSTANCE_PKG.APPLY_CLIENT_CHANGES',FND_LOG.LEVEL_ERROR); -- put PK column here

589: IF l_process_status <> FND_API.G_RET_STS_SUCCESS THEN
590: /*** no -> rollback ***/
591: CSM_UTIL_PKG.LOG
592: ( 'Defer record failed, rolling back to savepoint'
593: || ' for PK ' || r_qi_rec.INSTANCE_ID ,'CSM_QUERY_INSTANCE_PKG.APPLY_CLIENT_CHANGES',FND_LOG.LEVEL_ERROR); -- put PK column here
594: ROLLBACK TO save_rec;
595: x_return_status := FND_API.G_RET_STS_ERROR;
596: END IF;
597: END IF;

Line 601: CSM_UTIL_PKG.LOG('Leaving CSM_QUERY_INSTANCE_PKG.APPLY_CLIENT_CHANGES',

597: END IF;
598:
599: END LOOP;
600:
601: CSM_UTIL_PKG.LOG('Leaving CSM_QUERY_INSTANCE_PKG.APPLY_CLIENT_CHANGES',
602: 'CSM_QUERY_INSTANCE_PKG.APPLY_CLIENT_CHANGES',FND_LOG.LEVEL_PROCEDURE);
603:
604: EXCEPTION WHEN OTHERS THEN
605: /*** catch and log exceptions ***/

Line 602: 'CSM_QUERY_INSTANCE_PKG.APPLY_CLIENT_CHANGES',FND_LOG.LEVEL_PROCEDURE);

598:
599: END LOOP;
600:
601: CSM_UTIL_PKG.LOG('Leaving CSM_QUERY_INSTANCE_PKG.APPLY_CLIENT_CHANGES',
602: 'CSM_QUERY_INSTANCE_PKG.APPLY_CLIENT_CHANGES',FND_LOG.LEVEL_PROCEDURE);
603:
604: EXCEPTION WHEN OTHERS THEN
605: /*** catch and log exceptions ***/
606: CSM_UTIL_PKG.log( 'Exception in ' || g_object_name || '.APPLY_CLIENT_CHANGES: ' || sqlerrm

Line 607: ,'CSM_QUERY_INSTANCE_PKG.APPLY_CLIENT_CHANGES',FND_LOG.LEVEL_EXCEPTION);

603:
604: EXCEPTION WHEN OTHERS THEN
605: /*** catch and log exceptions ***/
606: CSM_UTIL_PKG.log( 'Exception in ' || g_object_name || '.APPLY_CLIENT_CHANGES: ' || sqlerrm
607: ,'CSM_QUERY_INSTANCE_PKG.APPLY_CLIENT_CHANGES',FND_LOG.LEVEL_EXCEPTION);
608:
609: x_return_status := FND_API.G_RET_STS_ERROR;
610:
611: END APPLY_CLIENT_CHANGES;

Line 613: END CSM_QUERY_INSTANCE_PKG;

609: x_return_status := FND_API.G_RET_STS_ERROR;
610:
611: END APPLY_CLIENT_CHANGES;
612:
613: END CSM_QUERY_INSTANCE_PKG;