classes/monograph/RepresentativeDAO.inc.php

<?php

import('classes.monograph.Representative');

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

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

      $result =& $this->retrieve(
         'SELECT r.*
            FROM representatives r
         JOIN published_monographs pm ON (r.monograph_id = pm.monograph_id)
         WHERE r.representative_id = ?
            ' . ($monographId?' AND pm.monograph_id = ?':''),
         $sqlParams);

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

   function &getSuppliersByMonographId($monographId) {
      $result =& $this->retrieveRange(
         'SELECT * FROM representatives WHERE monograph_id = ? AND is_supplier = ?', array((int) $monographId, 1));

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

   function &getAgentsByMonographId($monographId) {
      $result =& $this->retrieveRange(
            'SELECT * FROM representatives WHERE monograph_id = ? AND is_supplier = ?', array((int) $monographId, 0));

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

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

   function &_fromRow(&$row, $callHooks = true) {
      $representative = $this->newDataObject();
      $representative->setId($row['representative_id']);
      $representative->setRole($row['role']);
      $representative->setRepresentativeIdType($row['representative_id_type']);
      $representative->setRepresentativeIdValue($row['representative_id_value']);
      $representative->setName($row['name']);
      $representative->setPhone($row['phone']);
      $representative->setFax($row['fax']);
      $representative->setEmail($row['email']);
      $representative->setUrl($row['url']);
      $representative->setIsSupplier($row['is_supplier']);
      $representative->setMonographId($row['monograph_id']);

      if ($callHooks) HookRegistry::call('RepresentativeDAO::_fromRow', array(&$representative, &$row));

      return $representative;
   }

   function insertObject(&$representative) {
      $this->update(
         'INSERT INTO representatives
            (monograph_id, role, representative_id_type, representative_id_value, name, phone, fax, email, url, is_supplier)
         VALUES
            (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)',
         array(
            (int) $representative->getMonographId(),
            $representative->getRole(),
            $representative->getRepresentativeIdType(),
            $representative->getRepresentativeIdValue(),
            $representative->getName(),
            $representative->getPhone(),
            $representative->getFax(),
            $representative->getEmail(),
            $representative->getUrl(),
            (int) $representative->getIsSupplier()
         )
      );

      $representative->setId($this->getInsertRepresentativeId());
      return $representative->getId();
   }

   function updateObject(&$representative) {
      $this->update(
         'UPDATE representatives
            SET role = ?,
            representative_id_type = ?,
            representative_id_value = ?,
            name = ?,
            phone = ?,
            fax = ?,
            email = ?,
            url = ?,
            is_supplier = ?
         WHERE representative_id = ?',
         array(
            $representative->getRole(),
            $representative->getRepresentativeIdType(),
            $representative->getRepresentativeIdValue(),
            $representative->getName(),
            $representative->getPhone(),
            $representative->getFax(),
            $representative->getEmail(),
            $representative->getUrl(),
            (int) $representative->getIsSupplier(),
            (int) $representative->getId()
         )
      );
   }

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

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

   function getInsertRepresentativeId() {
      return $this->getInsertId('representatives', 'representative_id');
   }
}

?>