OMPCompletedPaymentDAO.inc.php

<?php
 
import('classes.payment.omp.OMPPaymentManager'); // PAYMENT_TYPE_... consts
import('lib.pkp.classes.payment.CompletedPayment');
 
class OMPCompletedPaymentDAO 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 insertCompletedPayment($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(),
            $completedPayment->getAssocId(), /* NOT int */
            $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 hasPaidPurchaseFile ($userId, $fileIdAndRevision) {
      $result = $this->retrieve(
         'SELECT count(*) FROM completed_payments WHERE payment_type = ? AND user_id = ? AND assoc_id = ?',
         array(
            PAYMENT_TYPE_PURCHASE_FILE,
            (int) $userId,
            $fileIdAndRevision
         )
      );
 
      $returner = false;
      if (isset($result->fields[0]) && $result->fields[0] != 0) {
         $returner = true;
      }
 
      $result->Close();
      return $returner;
   }
 
   function getByContextId($contextId, $rangeInfo = null) {
      $result = $this->retrieveRange(
         'SELECT * FROM completed_payments WHERE context_id = ? ORDER BY timestamp DESC',
         (int) $contextId,
         $rangeInfo
      );
 
      return new DAOResultFactory($result, $this, '_fromRow');
   }
 
   function getByUserId($userId, $rangeInfo = null) {
      $result =& $this->retrieveRange(
         'SELECT * FROM completed_payments WHERE user_id = ? ORDER BY timestamp DESC',
         (int) $userId,
         $rangeInfo
      );
 
      $returner = new DAOResultFactory($result, $this, '_returnPaymentFromRow');
      return $returner;
   }
 
   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;
   }
}