MarketDAO.inc.php

<?php
 
import('classes.publicationFormat.Market');
 
class MarketDAO extends DAO {
   function __construct() {
      parent::__construct();
   }
 
   function getById($marketId, $publicationId = null){
      $sqlParams = array((int) $marketId);
      if ($publicationId) {
         $sqlParams[] = (int) $publicationId;
      }
 
      $result = $this->retrieve(
         'SELECT  m.*
         FROM  markets m
            JOIN publication_formats pf ON (m.publication_format_id = pf.publication_format_id)
         WHERE m.market_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 markets WHERE publication_format_id = ?', (int) $publicationFormatId);
 
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
   function newDataObject() {
      return new Market();
   }
 
   function _fromRow($row, $callHooks = true) {
      $market = $this->newDataObject();
      $market->setId($row['market_id']);
      $market->setCountriesIncluded(unserialize($row['countries_included']));
      $market->setCountriesExcluded(unserialize($row['countries_excluded']));
      $market->setRegionsIncluded(unserialize($row['regions_included']));
      $market->setRegionsExcluded(unserialize($row['regions_excluded']));
      $market->setDateRole($row['market_date_role']);
      $market->setDateFormat($row['market_date_format']);
      $market->setDate($row['market_date']);
      $market->setDiscount($row['discount']);
      $market->setPrice($row['price']);
      $market->setPriceTypeCode($row['price_type_code']);
      $market->setCurrencyCode($row['currency_code']);
      $market->setTaxRateCode($row['tax_rate_code']);
      $market->setTaxTypeCode($row['tax_type_code']);
      $market->setAgentId($row['agent_id']);
      $market->setSupplierId($row['supplier_id']);
      $market->setPublicationFormatId($row['publication_format_id']);
 
      if ($callHooks) HookRegistry::call('MarketDAO::_fromRow', array(&$market, &$row));
 
      return $market;
   }
 
   function insertObject($market) {
      $this->update(
         'INSERT INTO markets
            (publication_format_id, countries_included, countries_excluded, regions_included, regions_excluded, market_date_role, market_date_format, market_date, price, discount, price_type_code, currency_code, tax_rate_code, tax_type_code, agent_id, supplier_id)
         VALUES
            (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)',
         array(
            (int) $market->getPublicationFormatId(),
            serialize($market->getCountriesIncluded() ? $market->getCountriesIncluded() : array()),
            serialize($market->getCountriesExcluded() ? $market->getCountriesExcluded() : array()),
            serialize($market->getRegionsIncluded() ? $market->getRegionsIncluded() : array()),
            serialize($market->getRegionsExcluded() ? $market->getRegionsExcluded() : array()),
            $market->getDateRole(),
            $market->getDateFormat(),
            $market->getDate(),
            $market->getPrice(),
            $market->getDiscount(),
            $market->getPriceTypeCode(),
            $market->getCurrencyCode(),
            $market->getTaxRateCode(),
            $market->getTaxTypeCode(),
            (int) $market->getAgentId(),
            (int) $market->getSupplierId()
         )
      );
 
      $market->setId($this->getInsertId());
      return $market->getId();
   }
 
   function updateObject($market) {
      $this->update(
         'UPDATE markets
            SET countries_included = ?,
            countries_excluded = ?,
            regions_included = ?,
            regions_excluded = ?,
            market_date_role = ?,
            market_date_format = ?,
            market_date = ?,
            price = ?,
            discount = ?,
            price_type_code = ?,
            currency_code = ?,
            tax_rate_code = ?,
            tax_type_code = ?,
            agent_id = ?,
            supplier_id = ?
         WHERE market_id = ?',
         array(
            serialize($market->getCountriesIncluded() ? $market->getCountriesIncluded() : array()),
            serialize($market->getCountriesExcluded() ? $market->getCountriesExcluded() : array()),
            serialize($market->getRegionsIncluded() ? $market->getRegionsIncluded() : array()),
            serialize($market->getRegionsExcluded() ? $market->getRegionsExcluded() : array()),
            $market->getDateRole(),
            $market->getDateFormat(),
            $market->getDate(),
            $market->getPrice(),
            $market->getDiscount(),
            $market->getPriceTypeCode(),
            $market->getCurrencyCode(),
            $market->getTaxRateCode(),
            $market->getTaxTypeCode(),
            (int) $market->getAgentId(),
            (int) $market->getSupplierId(),
            (int) $market->getId()
         )
      );
   }
 
   function deleteObject($market) {
      return $this->deleteById($market->getId());
   }
 
   function deleteById($entryId) {
      return $this->update(
         'DELETE FROM markets WHERE market_id = ?', array((int) $entryId)
      );
   }
 
   function getInsertId() {
      return $this->_getInsertId('markets', 'market_id');
   }
}