classes/payment/ojs/OJSCompletedPaymentDAO.inc.php

<?php

class OJSCompletedPaymentDAO extends DAO {
   function &getCompletedPayment($completedPaymentId) {
      $result = &$this->retrieve(
         'SELECT * FROM completed_payments WHERE completed_payment_id = ?', $completedPaymentId
      );

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

      $result->Close();
      unset($result);
      return $returner;
   }
   
   function insertCompletedPayment(&$completedPayment) {
      $this->update(
         sprintf('INSERT INTO completed_payments
            (timestamp, payment_type, journal_id, user_id, assoc_id, amount, currency_code_alpha, payment_method_plugin_name)
            VALUES
            (%s, ?, ?, ?, ?, ?, ?, ?)',
            $this->datetimeToDB(Core::getCurrentDate())),
         array(
            $completedPayment->getType(), 
            $completedPayment->getJournalId(), 
            $completedPayment->getUserId(), 
            $completedPayment->getAssocId(), 
            $completedPayment->getAmount(), 
            $completedPayment->getCurrencyCode(), 
            $completedPayment->getPayMethodPluginName()
            )
      );

      return $this->getInsertCompletedPaymentId();
   }

   function getInsertCompletedPaymentId() {
      return $this->getInsertId('completed_payments', 'completed_payment_id');
   }
   
   function hasPaidPerViewArticle ( $userId, $articleId ) {
      $result =& $this->retrieve(
         'SELECT count(*) FROM completed_payments WHERE payment_type = ? AND user_id = ? AND assoc_id = ?', 
            array(PAYMENT_TYPE_PURCHASE_ARTICLE,
               $userId,
               $articleId )
      );
      
      $returner = false;
      if (isset($result->fields[0]) && $result->fields[0] != 0) {
         $returner = true;
      }
      
      $result->Close();
      return $returner;
   }

   function hasPaidSubmission ( $journalId, $articleId ) {
      $result =& $this->retrieve(
         'SELECT count(*) FROM completed_payments WHERE payment_type = ? AND journal_id = ? AND assoc_id = ?', 
         array(
            PAYMENT_TYPE_SUBMISSION,
            $journalId, 
            $articleId
            )
      );
      
      $returner = false;
      if (isset($result->fields[0]) && $result->fields[0] != 0) {
         $returner = true;
      }
      
      $result->Close();
      return $returner;
   }
   
   function &getSubmissionCompletedPayment ( $journalId, $articleId ) { 
      $result =& $this->retrieve(
         'SELECT * FROM completed_payments WHERE payment_type = ? AND journal_id = ? AND assoc_id = ?', 
         array(
            PAYMENT_TYPE_SUBMISSION,
            $journalId, 
            $articleId
            )
      );

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

      $result->Close();
      unset($result);
      return $returner;
   }     

   function hasPaidFastTrack ( $journalId, $articleId ) {
      $result =& $this->retrieve(
         'SELECT count(*) FROM completed_payments WHERE payment_type = ? AND journal_id = ? AND assoc_id = ?', 
         array(
            PAYMENT_TYPE_FASTTRACK,
            $journalId, 
            $articleId
            )
      );
      
      $returner = false;
      if (isset($result->fields[0]) && $result->fields[0] != 0) 
         $returner =  true;
      
      $result->Close();
      return $returner;
   }
   
   function getFastTrackCompletedPayment ( $journalId, $articleId ) {
      $result =& $this->retrieve(
         'SELECT * FROM completed_payments WHERE payment_type = ? AND journal_id = ? AND assoc_id = ?', 
         array(
            PAYMENT_TYPE_FASTTRACK,
            $journalId, 
            $articleId
            )
      );
         
      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner = &$this->_returnPaymentFromRow($result->GetRowAssoc(false));
      }

      $result->Close();
      unset($result);
      return $returner;
   }     
   
   function hasPaidPublication ( $journalId, $articleId ) {
      $result =& $this->retrieve(
         'SELECT count(*) FROM completed_payments WHERE payment_type = ? AND journal_id = ? AND assoc_id = ?', 
         array(
            PAYMENT_TYPE_PUBLICATION,
            $journalId, 
            $articleId
            )
      );
   
      $returner = (isset($result->fields[0]) && $result->fields[0] != 0) ;
      $result->Close();
      return $returner; 
   }     

   function getPublicationCompletedPayment ( $journalId, $articleId ) {
      $result =& $this->retrieve(
         'SELECT * FROM completed_payments WHERE payment_type = ? AND journal_id = ? AND assoc_id = ?', 
         array(
            PAYMENT_TYPE_PUBLICATION,
            $journalId, 
            $articleId
            )
      ); 

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

      $result->Close();
      unset($result);
      return $returner;
   }  
      
   function &getPaymentsByJournalId($journalId, $rangeInfo = null) {
      $result = &$this->retrieveRange(
         'SELECT * FROM completed_payments WHERE journal_id = ? ORDER BY timestamp DESC', $journalId, $rangeInfo
      );

      $returner = &new DAOResultFactory($result, $this, '_returnPaymentFromRow');
      return $returner;
   }     
   
   function &_returnPaymentFromRow(&$row) {
      import('payment.ojs.OJSCompletedPayment');

      $payment = &new OJSCompletedPayment();
      $payment->setTimestamp($this->datetimeFromDB($row['timestamp']));
      $payment->setPaymentId($row['completed_payment_id']);
      $payment->setType($row['payment_type']); 
      $payment->setJournalId($row['journal_id']); 
      $payment->setAmount($row['amount']); 
      $payment->setCurrencyCode($row['currency_code_alpha']);
      $payment->setUserId($row['user_id']);
      $payment->setAssocId($row['assoc_id']);
      $payment->setPayMethodPluginName($row['payment_method_plugin_name']);
      
      return $payment;
   }
   
}

?>

---