OJSCompletedPaymentDAO.inc.php

<?php
 
import('lib.pkp.classes.payment.CompletedPayment');
 
class OJSCompletedPaymentDAO extends DAO {
   function getById($completedPaymentId, $contextId = null) {
      $params = array((int) $completedPaymentId);
      if ($contextId) $params[] = (int) $contextId;
 
      $result = $this->retrieve(
         'SELECT * FROM completed_payments WHERE completed_payment_id = ?' . ($contextId?' AND context_id = ?':''),
         $params
      );
 
      $returner = null;
      if ($result->RecordCount() != 0) {
         $returner = $this->_fromRow($result->GetRowAssoc(false));
      }
 
      $result->Close();
      return $returner;
   }
 
   function insertObject($completedPayment) {
      $this->update(
         sprintf('INSERT INTO completed_payments
            (timestamp, payment_type, context_id, user_id, assoc_id, amount, currency_code_alpha, payment_method_plugin_name)
            VALUES
            (%s, ?, ?, ?, ?, ?, ?, ?)',
            $this->datetimeToDB(Core::getCurrentDate())),
         array(
            (int) $completedPayment->getType(),
            (int) $completedPayment->getContextId(),
            (int) $completedPayment->getUserId(),
            (int) $completedPayment->getAssocId(),
            $completedPayment->getAmount(),
            $completedPayment->getCurrencyCode(),
            $completedPayment->getPayMethodPluginName()
         )
      );
 
      return $this->getInsertId();
   }
 
   function updateObject($completedPayment) {
      $returner = false;
      
      $returner = $this->update(
         sprintf('UPDATE completed_payments
         SET
            timestamp = %s,
            payment_type = ?,
            context_id = ?,
            user_id = ?,
            assoc_id = ?,
            amount = ?,
            currency_code_alpha = ?,
            payment_method_plugin_name = ? 
         WHERE completed_payment_id = ?',
         $this->datetimeToDB($completedPayment->getTimestamp())),
         array(
            (int) $completedPayment->getType(),
            (int) $completedPayment->getContextId(),
            (int) $completedPayment->getUserId(),
            (int) $completedPayment->getAssocId(),
            $completedPayment->getAmount(),
            $completedPayment->getCurrencyCode(),
            $completedPayment->getPayMethodPluginName(),
            (int) $completedPayment->getId()
         )
      );
 
      return $returner;
   }
 
   function getInsertId() {
      return $this->_getInsertId('completed_payments', 'completed_payment_id');
   }
 
   function getByAssoc($userId = null, $paymentType = null, $assocId = null) {
      $params = array();
      if ($userId) $params[] = (int) $userId;
      if ($paymentType) $params[] = (int) $paymentType;
      if ($assocId) $params[] = (int) $assocId;
      $result = $this->retrieve(
         'SELECT * FROM completed_payments WHERE 1=1' .
         ($userId?' AND user_id = ?':'') .
         ($paymentType?' AND payment_type = ?':'') .
         ($assocId?' AND assoc_id = ?':''),
         $params
      );
 
      $returner = null;
      if (isset($result->fields[0]) && $result->fields[0] != 0) {
         $returner = $this->_fromRow($result->fields);
      }
 
      $result->Close();
      return $returner;
   }
 
   function hasPaidPurchaseArticle($userId, $articleId) {
      return $this->getByAssoc($userId, PAYMENT_TYPE_PURCHASE_ARTICLE, $articleId)?true:false;
   }
 
   function hasPaidPurchaseIssue($userId, $issueId) {
      return $this->getByAssoc($userId, PAYMENT_TYPE_PURCHASE_ISSUE, $issueId)?true:false;
   }
 
   function hasPaidPublication($userId, $articleId) {
      return $this->getByAssoc($userId, PAYMENT_TYPE_PUBLICATION, $articleId)?true:false;
   }
 
   function getByContextId($contextId, $rangeInfo = null) {
      $result = $this->retrieveRange(
         'SELECT * FROM completed_payments WHERE context_id = ? ORDER BY timestamp DESC',
         (int) $contextId,
         $rangeInfo
      );
 
      $returner = array();
      while (!$result->EOF) {
         $payment = $this->_fromRow($result->fields);
         $returner[$payment->getId()] = $payment;
         $result->MoveNext();
      }
      return $returner;
   }
 
   function getByUserId($userId, $rangeInfo = null) {
      $result = $this->retrieveRange(
         'SELECT * FROM completed_payments WHERE user_id = ? ORDER BY timestamp DESC',
         (int) $userId,
         $rangeInfo
      );
 
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
   function newDataObject() {
      return new CompletedPayment();
   }
 
   function _fromRow($row) {
      $payment = $this->newDataObject();
      $payment->setTimestamp($this->datetimeFromDB($row['timestamp']));
      $payment->setId($row['completed_payment_id']);
      $payment->setType($row['payment_type']);
      $payment->setContextId($row['context_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;
   }
}