SalesRightsDAO.inc.php

<?php
 
import('classes.publicationFormat.SalesRights');
 
class SalesRightsDAO extends DAO {
   function __construct() {
      parent::__construct();
   }
 
   function getById($salesRightsId, $publicationId = null){
      $sqlParams = array((int) $salesRightsId);
      if ($publicationId) {
         $sqlParams[] = (int) $publicationId;
      }
 
      $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 = ?
            ' . ($publicationId?' AND pf.publication_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);
 
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
   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->getInsertId());
      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 getInsertId() {
      return $this->_getInsertId('sales_rights', 'sales_rights_id');
   }
}