DepositDAO.inc.php

<?php
 
import('lib.pkp.classes.db.DAO');
 
class DepositDAO extends DAO {
   public function newDataObject() {
      return new Deposit(null);
   }
 
   public function getById($depositId, $journalId = null) {
      $params = array((int) $depositId);
      if ($journalId !== null) $params[] = (int) $journalId;
      $result = $this->retrieve(
         'SELECT *
         FROM pln_deposits
         WHERE deposit_id = ?'
         . ($journalId !== null?' AND journal_id = ?':''),
         $params
      );
      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner = $this->_fromRow($result->GetRowAssoc(false));
      }
      $result->Close();
      return $returner;
   }
 
   public function insertObject($deposit) {
      $this->update(
         sprintf('
            INSERT INTO pln_deposits
               (journal_id,
               uuid,
               status,
               date_status,
               date_created,
               date_modified)
            VALUES
               (?, ?, ?, %s, NOW(), %s)',
            $this->datetimeToDB($deposit->getLastStatusDate()),
            $this->datetimeToDB($deposit->getDateModified())
         ),
         array(
            (int) $deposit->getJournalId(),
            $deposit->getUUID(),
            (int) $deposit->getStatus()
         )
      );
      $deposit->setId($this->getInsertId());
      return $deposit->getId();
   }
 
   public function updateObject($deposit) {
      $this->update(
         sprintf('
            UPDATE pln_deposits SET
               journal_id = ?,
               uuid = ?,
               status = ?,
               date_status = %s,
               date_created = %s,
               date_modified = NOW(),
               export_deposit_error = ?
            WHERE deposit_id = ?',
            $this->datetimeToDB($deposit->getLastStatusDate()),
            $this->datetimeToDB($deposit->getDateCreated())
         ),
         array(
            (int) $deposit->getJournalId(),
            $deposit->getUUID(),
            (int) $deposit->getStatus(),
            $deposit->getExportDepositError(),
            (int) $deposit->getId()
         )
      );
   }
 
   public function deleteObject($deposit) {
      $depositObjectDao = DAORegistry::getDAO('DepositObjectDAO');
      foreach($deposit->getDepositObjects() as $depositObject) {
         $depositObjectDao->deleteObject($depositObject);
      }
 
      $this->update(
         'DELETE from pln_deposits WHERE deposit_id = ?',
         (int) $deposit->getId()
      );
   }
 
   public function getInsertId() {
      return $this->_getInsertId('pln_deposits', 'deposit_id');
   }
 
   public function _fromRow($row) {
      $deposit = $this->newDataObject();
      $deposit->setId($row['deposit_id']);
      $deposit->setJournalId($row['journal_id']);
      $deposit->setUUID($row['uuid']);
      $deposit->setStatus($row['status']);
      $deposit->setLastStatusDate($this->datetimeFromDB($row['date_status']));
      $deposit->setDateCreated($this->datetimeFromDB($row['date_created']));
      $deposit->setDateModified($this->datetimeFromDB($row['date_modified']));
      $deposit->setExportDepositError($row['export_deposit_error']);
 
      HookRegistry::call('DepositDAO::_fromRow', array(&$deposit, &$row));
 
      return $deposit;
   }
 
   public function getByUUID($journalId, $depositUuid) {
      $result = $this->retrieve(
         'SELECT *
         FROM pln_deposits
         WHERE journal_id = ?
         AND uuid = ?',
         array (
            (int) $journalId,
            $depositUuid
         )
      );
      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner = $this->_fromRow($result->GetRowAssoc(false));
      }
      $result->Close();
      return $returner;
   }
 
   public function getByJournalId($journalId, $dbResultRange = null) {
      $result = $this->retrieveRange(
         'SELECT *
         FROM pln_deposits
         WHERE journal_id = ?
         ORDER BY deposit_id',
         array (
            (int) $journalId
         ),
         $dbResultRange
      );
 
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
   public function getNew($journalId) {
      $result = $this->retrieve(
         'SELECT * FROM pln_deposits WHERE journal_id = ? AND status = ?',
         array(
            (int) $journalId,
            (int) PLN_PLUGIN_DEPOSIT_STATUS_NEW
         )
      );
 
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
   public function getNeedTransferring($journalId) {
      $result = $this->retrieve(
         'SELECT *
         FROM pln_deposits AS d
         WHERE d.journal_id = ?
         AND d.status & ? = 0
         AND d.status & ? = 0
         AND d.status & ? = 0',
         array (
            (int) $journalId,
            (int) PLN_PLUGIN_DEPOSIT_STATUS_PACKAGING_FAILED,
            (int) PLN_PLUGIN_DEPOSIT_STATUS_TRANSFERRED,
            (int) PLN_PLUGIN_DEPOSIT_STATUS_LOCKSS_AGREEMENT
         )
      );
 
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
   public function getNeedPackaging($journalId) {
      $result = $this->retrieve(
         'SELECT *
         FROM pln_deposits AS d
         WHERE d.journal_id = ?
         AND d.status & ? = 0
         AND d.status & ? = 0
         AND d.status & ? = 0',
         array(
            (int) $journalId,
            (int) PLN_PLUGIN_DEPOSIT_STATUS_PACKAGED,
            (int) PLN_PLUGIN_DEPOSIT_STATUS_LOCKSS_AGREEMENT,
            (int) PLN_PLUGIN_DEPOSIT_STATUS_PACKAGING_FAILED
         )
      );
 
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
   public function getNeedStagingStatusUpdate($journalId) {
      $result = $this->retrieve(
         'SELECT *
         FROM pln_deposits AS d
         WHERE d.journal_id = ?
         AND d.status & ? <> 0
         AND d.status & ? = 0
         AND d.status & ? = 0',
         array (
            (int) $journalId,
            (int) PLN_PLUGIN_DEPOSIT_STATUS_TRANSFERRED,
            (int) PLN_PLUGIN_DEPOSIT_STATUS_LOCKSS_AGREEMENT,
            (int) PLN_PLUGIN_DEPOSIT_STATUS_PACKAGING_FAILED
         )
      );
 
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
   public function deleteByJournalId($journalId) {
      $deposits = $this->getByJournalId($journalId);
      foreach($deposits as $deposit) {
         $this->deleteDeposit($deposit);
      }
   }
}