DBA Data[Home] [Help]

APPS.CSM_DEBRIEF_HEADERS_PKG SQL Statements

The following lines contain the word 'select', 'insert', 'update' or 'delete':

Line: 21

  SELECT *
  FROM  csm_debrief_headers_inq
  WHERE tranid$$ = b_tranid
  AND   clid$$cs = b_user_name;
Line: 28

SELECT jtf_note_id, source_object_id
FROM csf_m_notes_inq
WHERE tranid$$ = b_tranid
AND clid$$cs = b_user_name
AND source_object_code = 'SD'
AND source_object_id = p_debrief_header_id
FOR UPDATE OF source_object_id NOWAIT;
Line: 38

SELECT debrief_header_id
FROM csf_debrief_headers
WHERE task_assignment_id = p_task_assignment_id;
Line: 45

SELECT file_id, pk1_value
FROM csf_m_lobs_inq
WHERE tranid$$ = b_tranid
AND clid$$cs = b_user_name
AND entity_name = 'CSF_DEBRIEF_HEADERS'
AND to_number(pk1_value) = p_debrief_header_id
FOR UPDATE OF pk1_value NOWAIT;
Line: 54

  This procedure is called by APPLY_CLIENT_CHANGES when an inserted record is to be processed.
***/
PROCEDURE APPLY_INSERT
         (
           p_record        IN c_debrief_headers%ROWTYPE,
           p_error_msg     out nocopy    VARCHAR2,
           x_return_status IN out nocopy VARCHAR2
         ) IS

cursor c_deb_head
       ( b_task_assignment_id number
       )
is
select debrief_header_id
,      debrief_number
,      debrief_date
,      debrief_status_id
,      task_assignment_id
,      last_updated_by
,      last_update_date
,      ATTRIBUTE1
,      ATTRIBUTE2
,      ATTRIBUTE3
,      ATTRIBUTE4
,      ATTRIBUTE5
,      ATTRIBUTE6
,      ATTRIBUTE7
,      ATTRIBUTE8
,      ATTRIBUTE9
,      ATTRIBUTE10
,      ATTRIBUTE11
,      ATTRIBUTE12
,      ATTRIBUTE13
,      ATTRIBUTE14
,      ATTRIBUTE15
,      ATTRIBUTE_CATEGORY
from   csf_debrief_headers
where  task_assignment_id = b_task_assignment_id;
Line: 111

CSM_UTIL_PKG.log( 'Entered APPLY_INSERT for debrief_header_id'|| p_record.debrief_header_id,'CSM_DEBRIEF_HEADERS_PKG.APPLY_INSERT',FND_LOG.LEVEL_ERROR);
Line: 143

   l_deb_rec.last_update_date   := l_date;
Line: 144

   l_deb_rec.last_updated_by    := NVL(p_record.last_updated_by,FND_GLOBAL.USER_ID);  --12.1
Line: 147

   l_deb_rec.last_update_login  := FND_GLOBAL.LOGIN_ID;
Line: 189

      CSM_UTIL_PKG.log( 'Error in ' || g_object_name || '.APPLY_INSERT:'
               || ' ROOT ERROR: csf_debrief_pub.create_debrief'
               || ' for PK ' || p_record.DEBRIEF_HEADER_ID,'CSM_DEBRIEF_HEADERS_PKG.APPLY_INSERT',FND_LOG.LEVEL_ERROR);
Line: 199

                 ,'CSM_DEBRIEF_HEADERS_PKG.APPLY_INSERT'
                 ,FND_LOG.LEVEL_PROCEDURE); -- put PK column here
Line: 219

                ,'CSM_DEBRIEF_HEADERS_PKG.APPLY_INSERT'
                ,FND_LOG.LEVEL_PROCEDURE); -- put PK column here
Line: 226

                ,'CSM_DEBRIEF_HEADERS_PKG.APPLY_INSERT'
                ,FND_LOG.LEVEL_PROCEDURE); -- put PK column here
Line: 238

                 ,'CSM_DEBRIEF_HEADERS_PKG.APPLY_INSERT'
                 ,FND_LOG.LEVEL_PROCEDURE); -- put PK column here
Line: 258

             ,'CSM_DEBRIEF_HEADERS_PKG.APPLY_INSERT'
             ,FND_LOG.LEVEL_PROCEDURE); -- put PK column here
Line: 265

              ,'CSM_DEBRIEF_HEADERS_PKG.APPLY_INSERT'
              ,FND_LOG.LEVEL_PROCEDURE); -- put PK column here
Line: 278

    IF(r_deb_head.last_update_date <> p_record.server_last_update_date AND r_deb_head.last_updated_by <> NVL(p_record.last_updated_by,asg_base.get_user_id(p_record.clid$$cs))) THEN  --12.1
      p_error_msg := 'UPWARD SYNC CONFLICT: CLIENT LOST For CSF_DEBRIEF_HEADERS: CSM_DEBRIEF_HEADERS_PKG.APPLY_UPDATE: P_KEY = '
        || p_record.debrief_header_id;
Line: 282

      csm_util_pkg.log(p_error_msg, g_object_name || '.APPLY_UPDATE',  FND_LOG.LEVEL_ERROR);
Line: 294

         l_deb_rec.last_update_date   := l_date;
Line: 295

         l_deb_rec.last_updated_by    := NVL(p_record.last_updated_by,FND_GLOBAL.USER_ID);  --12.1
Line: 298

         l_deb_rec.last_update_login  := FND_GLOBAL.LOGIN_ID;
Line: 322

         csf_debrief_pub.Update_debrief(
            p_api_version_number   => 1.0,
            p_init_msg_list        => FND_API.G_TRUE,
            p_commit               => FND_API.G_FALSE,
            p_debrief_rec          => l_deb_rec,
            X_Return_Status        => x_return_status,
            X_Msg_Count            => l_msg_count,
            X_Msg_Data             => l_msg_data
           );
Line: 340

            CSM_UTIL_PKG.log( 'Error in ' || g_object_name || '.APPLY_INSERT:'
                        || ' ROOT ERROR: csf_debrief_pub.create_debrief'
                        || ' for PK ' || r_deb_head.DEBRIEF_HEADER_ID,'CSM_DEBRIEF_HEADERS_PKG.APPLY_INSERT',FND_LOG.LEVEL_ERROR);
Line: 354

     fnd_msg_pub.Add_Exc_Msg( g_object_name, 'APPLY_INSERT', sqlerrm);
Line: 360

     CSM_UTIL_PKG.log( 'Exception in ' || g_object_name || '.APPLY_INSERT:'
               || ' for PK ' || p_record.DEBRIEF_HEADER_ID,'CSM_DEBRIEF_HEADERS_PKG.APPLY_INSERT',FND_LOG.LEVEL_EXCEPTION );
Line: 363

END APPLY_INSERT;
Line: 366

PROCEDURE APPLY_UPDATE
         (
           p_record        IN c_debrief_headers%ROWTYPE,
           p_error_msg     OUT NOCOPY    VARCHAR2,
           x_return_status IN OUT NOCOPY VARCHAR2
         ) IS

CURSOR c_debrief_header
   ( b_debrief_header_id number,
     b_task_assignment_id number
   )
IS
SELECT dh.debrief_header_id
,      dh.debrief_number
,      dh.last_update_date
,      dh.last_updated_by
 FROM csf_debrief_headers dh
WHERE dh.debrief_header_id = b_debrief_header_id
UNION
SELECT dh.debrief_header_id
,      dh.debrief_number
,      dh.last_update_date
,      dh.last_updated_by
 FROM csf_debrief_headers dh
WHERE dh.task_assignment_id = b_task_assignment_id
;
Line: 402

 CSM_UTIL_PKG.log( 'Entered APPLY_UPDATE for debrief_header_id'|| p_record.DEBRIEF_HEADER_ID,'CSM_DEBRIEF_HEADERS_PKG.APPLY_INSERT',FND_LOG.LEVEL_ERROR);
Line: 411

      IF (r_debrief_header.last_update_date <> p_record.server_last_update_date AND r_debrief_header.last_updated_by <> NVL(p_record.last_updated_by,asg_base.get_user_id(p_record.clid$$cs))) THEN --12.1
        CLOSE c_debrief_header;
Line: 413

        CSM_UTIL_PKG.log( 'Record has stale data. Leaving  ' || g_object_name || '.APPLY_UPDATE:'
          || ' for PK ' || p_record.debrief_header_id,
          g_object_name || '.APPLY_UPDATE',
          FND_LOG.LEVEL_PROCEDURE );
Line: 426

      CSM_UTIL_PKG.log( 'No record found in Apps Database in ' || g_object_name || '.APPLY_UPDATE:',
          g_object_name || '.APPLY_UPDATE',
          FND_LOG.LEVEL_PROCEDURE );
Line: 444

    l_deb_rec.last_update_date   := l_date;
Line: 445

    l_deb_rec.last_updated_by    := NVL(p_record.last_updated_by,FND_GLOBAL.USER_ID); --12.1
Line: 448

    l_deb_rec.last_update_login  := FND_GLOBAL.LOGIN_ID;
Line: 471

    csf_debrief_pub.Update_debrief(
            p_api_version_number   => 1.0,
            p_init_msg_list        => FND_API.G_TRUE,
            p_commit               => FND_API.G_FALSE,
            p_debrief_rec          => l_deb_rec,
            X_Return_Status        => x_return_status,
            X_Msg_Count            => l_msg_count,
            X_Msg_Data             => l_msg_data
           );
Line: 489

        CSM_UTIL_PKG.log( 'Error in ' || g_object_name || '.APPLY_UPDATE:'
                        || ' ROOT ERROR: csf_debrief_pub.update_debrief'
                        || ' for PK ' || p_record.DEBRIEF_HEADER_ID,'CSM_DEBRIEF_HEADERS_PKG.APPLY_UPDATE',FND_LOG.LEVEL_ERROR);
Line: 501

     CSM_UTIL_PKG.log( 'Exception in ' || g_object_name || '.APPLY_UPDATE:'
       || ' for PK ' || p_record.debrief_header_id,
       g_object_name || '.APPLY_UPDATE',
       FND_LOG.LEVEL_EXCEPTION );
Line: 508

END APPLY_UPDATE;
Line: 526

    APPLY_INSERT
      (
        p_record,
        p_error_msg,
        x_return_status
      );
Line: 534

    APPLY_UPDATE
      (
        p_record,
        p_error_msg,
        x_return_status
      );
Line: 543

        ( 'Delete is not supported for this entity'
      || ' for PK ' || p_record.debrief_header_id ,'CSM_DEBRIEF_HEADERS_PKG.APPLY_RECORD',FND_LOG.LEVEL_ERROR);
Line: 574

  a fast sync. This procedure will insert the data that came from mobile into the backend tables using
  public APIs.
***/
PROCEDURE APPLY_CLIENT_CHANGES
         (
           p_user_name     IN VARCHAR2,
           p_tranid        IN NUMBER,
           p_debug_level   IN NUMBER,
           x_return_status IN out nocopy VARCHAR2,
		   p_task_assignment_id IN NUMBER
         ) IS
l_process_status VARCHAR2(1);
Line: 600

   OPEN c_cur FOR 'SELECT * FROM  csm_debrief_headers_inq inq WHERE tranid$$ = '||p_tranid||' AND   clid$$cs = '''||p_user_name
    ||''' AND  TASK_ASSIGNMENT_ID NOT IN  ('||CSM_UTIL_PKG.get_String_fromList(g_processed_assignment_list)||')';
Line: 604

   OPEN c_cur FOR 'SELECT * FROM  csm_debrief_headers_inq WHERE tranid$$ = '||p_tranid||' AND   clid$$cs = '''||p_user_name
                   ||''' AND TASK_ASSIGNMENT_ID='||p_task_assignment_id;
Line: 631

           UPDATE csf_m_notes_inq
           SET source_object_id = l_debrief_header_id
           WHERE CURRENT OF c_debrief_notes;
Line: 637

           UPDATE csf_m_lobs_inq
           SET pk1_value = l_debrief_header_id
           WHERE CURRENT OF c_debrief_signature;
Line: 645

      /*** Yes -> delete record from inqueue ***/

      CSM_UTIL_PKG.DELETE_RECORD
        (
          p_user_name,
          p_tranid,
          r_debrief_headers.seqno$$,
          r_debrief_headers.debrief_header_id,
          g_object_name,
          g_pub_name,
          l_error_msg,
          l_process_status
        );
Line: 659

      /*** was delete successful? ***/
      IF l_process_status <> FND_API.G_RET_STS_SUCCESS THEN
        /*** no -> rollback ***/
          CSM_UTIL_PKG.LOG
          ( 'Deleting from inqueue failed, rolling back to savepoint'
      || ' for PK ' || r_debrief_headers.debrief_header_id,'CSM_DEBRIEF_HEADERS_PKG.APPLY_CLIENT_CHANGES',FND_LOG.LEVEL_ERROR ); -- put PK column here
Line: 675

           UPDATE csf_m_notes_inq
           SET source_object_id = l_debrief_header_id
           WHERE CURRENT OF c_debrief_notes;
Line: 680

           UPDATE csf_m_lobs_inq
           SET pk1_value = l_debrief_header_id
           WHERE CURRENT OF c_debrief_signature;
Line: 688

      /*** Record was not processed successfully or delete failed -> defer and reject record ***/
        CSM_UTIL_PKG.LOG
        ( 'Record not processed successfully, deferring and rejecting record'
      || ' for PK ' || r_debrief_headers.debrief_header_id,'CSM_DEBRIEF_HEADERS_PKG.APPLY_CLIENT_CHANGES',FND_LOG.LEVEL_ERROR ); -- put PK column here
Line: 738

SELECT b.last_updated_by
FROM csf_debrief_headers b,
     csm_debrief_headers_inq a
WHERE a.clid$$cs = l_user_name
AND tranid$$ = l_tran_id
AND seqno$$ = l_sequence
AND a.debrief_header_id = b.debrief_header_id ;