classes/publicationFormat/SalesRightsDAO.inc.php

<?php

import('classes.publicationFormat.SalesRights');

class SalesRightsDAO extends DAO {
   function SalesRightsDAO() {
      parent::DAO();
   }

   function &getById($salesRightsId, $monographId = null){
      $sqlParams = array((int) $salesRightsId);
      if ($monographId) {
         $sqlParams[] = (int) $monographId;
      }

      $result =& $this->retrieve(
         'SELECT  s.*
         FROM  sales_rights s
            JOIN publication_formats pf ON (s.publication_format_id = pf.publication_format_id)
         WHERE s.sales_rights_id = ?
            ' . ($monographId?' AND pf.monograph_id = ?':''),
         $sqlParams
      );

      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner =& $this->_fromRow($result->GetRowAssoc(false));
      }
      $result->Close();
      return $returner;
   }

   function &getByPublicationFormatId($publicationFormatId) {
      $result =& $this->retrieveRange(
         'SELECT * FROM sales_rights WHERE publication_format_id = ?', (int) $publicationFormatId);

      $returner = new DAOResultFactory($result, $this, '_fromRow');
      return $returner;
   }

   function &getROWByPublicationFormatId($publicationFormatId) {
      $result =& $this->retrieve(
         'SELECT * FROM sales_rights WHERE row_setting = ? AND publication_format_id = ?',
         array(1, (int) $publicationFormatId)
      );

      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner =& $this->_fromRow($result->GetRowAssoc(false));
      }
      $result->Close();
      return $returner;
   }

   function newDataObject() {
      return new SalesRights();
   }

   function &_fromRow(&$row, $callHooks = true) {
      $salesRights = $this->newDataObject();
      $salesRights->setId($row['sales_rights_id']);
      $salesRights->setType($row['type']);
      $salesRights->setROWSetting($row['row_setting']);
      $salesRights->setCountriesIncluded(unserialize($row['countries_included']));
      $salesRights->setCountriesExcluded(unserialize($row['countries_excluded']));
      $salesRights->setRegionsIncluded(unserialize($row['regions_included']));
      $salesRights->setRegionsExcluded(unserialize($row['regions_excluded']));

      $salesRights->setPublicationFormatId($row['publication_format_id']);

      if ($callHooks) HookRegistry::call('SalesRightsDAO::_fromRow', array(&$salesRights, &$row));

      return $salesRights;
   }

   function insertObject(&$salesRights) {
      $this->update(
         'INSERT INTO sales_rights
            (publication_format_id, type, row_setting, countries_included, countries_excluded, regions_included, regions_excluded)
         VALUES
            (?, ?, ?, ?, ?, ?, ?)',
         array(
            (int) $salesRights->getPublicationFormatId(),
            $salesRights->getType(),
            $salesRights->getROWSetting(),
            serialize($salesRights->getCountriesIncluded() ? $salesRights->getCountriesIncluded() : array()),
            serialize($salesRights->getCountriesExcluded() ? $salesRights->getCountriesExcluded() : array()),
            serialize($salesRights->getRegionsIncluded() ? $salesRights->getRegionsIncluded() : array()),
            serialize($salesRights->getRegionsExcluded() ? $salesRights->getRegionsExcluded() : array())
         )
      );

      $salesRights->setId($this->getInsertSalesRightsId());
      return $salesRights->getId();
   }

   function updateObject(&$salesRights) {
      $this->update(
         'UPDATE sales_rights
            SET type = ?,
            row_setting = ?,
            countries_included = ?,
            countries_excluded = ?,
            regions_included = ?,
            regions_excluded = ?
         WHERE sales_rights_id = ?',
         array(
            $salesRights->getType(),
            $salesRights->getROWSetting(),
            serialize($salesRights->getCountriesIncluded() ? $salesRights->getCountriesIncluded() : array()),
            serialize($salesRights->getCountriesExcluded() ? $salesRights->getCountriesExcluded() : array()),
            serialize($salesRights->getRegionsIncluded() ? $salesRights->getRegionsIncluded() : array()),
            serialize($salesRights->getRegionsExcluded() ? $salesRights->getRegionsExcluded() : array()),
            (int) $salesRights->getId()
         )
      );
   }

   function deleteObject($salesRights) {
      return $this->deleteById($salesRights->getId());
   }

   function deleteById($entryId) {
      return $this->update(
         'DELETE FROM sales_rights WHERE sales_rights_id = ?', array((int) $entryId)
      );
   }

   function getInsertSalesRightsId() {
      return $this->getInsertId('sales_rights', 'sales_rights_id');
   }
}

?>