QueuedPaymentDAO.inc.php

<?php
 
import('lib.pkp.classes.payment.QueuedPayment');
 
class QueuedPaymentDAO extends DAO {
 
   function getById($queuedPaymentId) {
      $result = $this->retrieve(
         'SELECT * FROM queued_payments WHERE queued_payment_id = ?',
         (int) $queuedPaymentId
      );
 
      $queuedPayment = null;
      if ($result->RecordCount() != 0) {
         $queuedPayment = unserialize($result->fields['payment_data']);
         $queuedPayment->setId($result->fields['queued_payment_id']);
      }
      $result->Close();
      return $queuedPayment;
   }
 
   function insertObject($queuedPayment, $expiryDate = null) {
      $this->update(
         sprintf('INSERT INTO queued_payments
            (date_created, date_modified, expiry_date, payment_data)
            VALUES
            (%s, %s, %s, ?)',
            $this->datetimeToDB(Core::getCurrentDate()),
            $this->datetimeToDB(Core::getCurrentDate()),
            $this->datetimeToDB($expiryDate)),
         array(
            serialize($queuedPayment)
         )
      );
 
      return $queuedPayment->setId($this->getInsertId());
   }
 
   function updateObject($queuedPaymentId, $queuedPayment) {
      return $this->update(
         sprintf('UPDATE queued_payments
            SET
               date_modified = %s,
               payment_data = ?
            WHERE queued_payment_id = ?',
            $this->datetimeToDB(Core::getCurrentDate())),
         array(
            serialize($queuedPayment),
            (int) $queuedPaymentId
         )
      );
   }
 
   function getInsertId() {
      return $this->_getInsertId('queued_payments', 'queued_payment_id');
   }
 
   function deleteById($queuedPaymentId) {
      $notificationDao = DAORegistry::getDAO('NotificationDAO'); /* @var $notificationDao NotificationDAO */
      $notificationDao->deleteByAssoc(ASSOC_TYPE_QUEUED_PAYMENT, $queuedPaymentId);
      return $this->update(
         'DELETE FROM queued_payments WHERE queued_payment_id = ?',
         array((int) $queuedPaymentId)
      );
   }
 
   function deleteExpired() {
      return $this->update(
         'DELETE FROM queued_payments WHERE expiry_date < now()'
      );
   }
}