EventLogDAO.inc.php

<?php
 
import ('lib.pkp.classes.log.EventLogEntry');
 
class EventLogDAO extends DAO {
 
   function getById($logId, $assocType = null, $assocId = null) {
      $params = array((int) $logId);
      if (isset($assocType)) {
         $params[] = (int) $assocType;
         $params[] = (int) $assocId;
      }
 
      $result = $this->retrieve(
         'SELECT * FROM event_log WHERE log_id = ?' .
         (isset($assocType)?' AND assoc_type = ? AND assoc_id = ?':''),
         $params
      );
 
      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner =& $this->build($result->GetRowAssoc(false));
      }
 
      $result->Close();
      return $returner;
   }
 
   function getByAssoc($assocType, $assocId, $rangeInfo = null) {
      $result = $this->retrieveRange(
         'SELECT * FROM event_log WHERE assoc_type = ? AND assoc_id = ? ORDER BY log_id DESC',
         array((int) $assocType, (int) $assocId),
         $rangeInfo
      );
 
      return new DAOResultFactory($result, $this, 'build');
   }
 
   function newDataObject() {
      return new EventLogEntry();
   }
 
   function build($row) {
      $entry = $this->newDataObject();
      $entry->setId($row['log_id']);
      $entry->setUserId($row['user_id']);
      $entry->setDateLogged($this->datetimeFromDB($row['date_logged']));
      $entry->setEventType($row['event_type']);
      $entry->setAssocType($row['assoc_type']);
      $entry->setAssocId($row['assoc_id']);
      $entry->setMessage($row['message']);
      $entry->setIsTranslated($row['is_translated']);
 
      $result = $this->retrieve('SELECT * FROM event_log_settings WHERE log_id = ?', array((int) $entry->getId()));
      $params = array();
      while (!$result->EOF) {
         $r = $result->getRowAssoc(false);
         $params[$r['setting_name']] = $this->convertFromDB(
            $r['setting_value'],
            $r['setting_type']
         );
         $result->MoveNext();
      }
      $result->Close();
      $entry->setParams($params);
 
      HookRegistry::call('EventLogDAO::build', array(&$entry, &$row));
 
      return $entry;
   }
 
   function insertObject($entry) {
      $this->update(
         sprintf('INSERT INTO event_log
            (user_id, date_logged, event_type, assoc_type, assoc_id, message, is_translated)
            VALUES
            (?, %s, ?, ?, ?, ?, ?)',
            $this->datetimeToDB($entry->getDateLogged())),
         array(
            (int) $entry->getUserId(),
            (int) $entry->getEventType(),
            (int) $entry->getAssocType(),
            (int) $entry->getAssocId(),
            $entry->getMessage(),
            (int) $entry->getIsTranslated()
         )
      );
      $entry->setId($this->getInsertId());
 
      // Add name => value entries into the settings table
      $params = $entry->getParams();
      if (is_array($params)) foreach ($params as $key => $value) {
         $type = null;
         $value = $this->convertToDB($value, $type);
         $params = array(
            (int) $entry->getId(),
            $key, $value, $type
         );
         $this->update(
            'INSERT INTO event_log_settings (log_id, setting_name, setting_value, setting_type) VALUES (?, ?, ?, ?)',
            $params
         );
      }
 
      return $entry->getId();
   }
 
   function deleteById($logId, $assocType = null, $assocId = null) {
      $params = array((int) $logId);
      if ($assocType !== null) {
         $params[] = (int) $assocType;
         $params[] = (int) $assocId;
      }
      $this->update(
         'DELETE FROM event_log WHERE log_id = ?' .
         ($assocType !== null?' AND assoc_type = ? AND assoc_id = ?':''),
         $params
      );
      if ($this->getAffectedRows()) $this->update('DELETE FROM event_log_settings WHERE log_id = ?', array((int) $logId));
   }
 
   function deleteByAssoc($assocType, $assocId) {
      $entries = $this->getByAssoc($assocType, $assocId);
      while ($entry = $entries->next()) {
         $this->deleteById($entry->getId());
      }
   }
 
   function changeUser($oldUserId, $newUserId) {
      return $this->update(
         'UPDATE event_log SET user_id = ? WHERE user_id = ?',
         array((int) $newUserId, (int) $oldUserId)
      );
   }
 
   function getInsertId() {
      return $this->_getInsertId('event_log', 'log_id');
   }
}