Server : Apache/2.4.41 (Ubuntu) System : Linux journalup 5.4.0-198-generic #218-Ubuntu SMP Fri Sep 27 20:18:53 UTC 2024 x86_64 User : www-data ( 33) PHP Version : 7.4.33 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wifcontinued,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_get_handler,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority,pcntl_async_signals,pcntl_unshare, Directory : /var/www/html/classes/payment/ojs/
Upload File :
Current File : /var/www/html/classes/payment/ojs/OJSCompletedPaymentDAO.inc.php
<?php
/**
* @file classes/payment/ojs/OJSCompletedPaymentDAO.inc.php
*
* Copyright (c) 2014-2020 Simon Fraser University
* Copyright (c) 2003-2020 John Willinsky
* Distributed under the GNU GPL v3. For full terms see the file docs/COPYING.
*
* @class OJSCompletedPaymentDAO
* @ingroup payment
* @see OJSCompletedPayment, Payment
*
* @brief Operations for retrieving and querying past payments
*
*/
import('lib.pkp.classes.payment.CompletedPayment');
class OJSCompletedPaymentDAO extends DAO {
/**
* Retrieve a CompletedPayment by its ID.
* @param $completedPaymentId int
* @param $contextId int optional
* @return CompletedPayment
*/
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;
}
/**
* Insert a new completed payment.
* @param $completedPayment CompletedPayment
*/
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();
}
/**
* Update an existing completed payment.
* @param $completedPayment CompletedPayment
* @return boolean
*/
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;
}
/**
* Get the ID of the last inserted completed payment.
* @return int
*/
function getInsertId() {
return $this->_getInsertId('completed_payments', 'completed_payment_id');
}
/**
* Get a payment by assoc info
* @param $userId int?
* @param $paymentType int PAYMENT_TYPE_...
* @param $assocId int
* @return CompletedPayment|null
*/
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;
}
/**
* Look for a completed PAYMENT_TYPE_PURCHASE_ARTICLE payment matching the article ID
* @param $userId int?
* @param $articleId int
*/
function hasPaidPurchaseArticle($userId, $articleId) {
return $userId && $this->getByAssoc($userId, PAYMENT_TYPE_PURCHASE_ARTICLE, $articleId);
}
/**
* Look for a completed PAYMENT_TYPE_PURCHASE_ISSUE payment matching the user and issue IDs
* @param $userId int?
* @param $issueId int
*/
function hasPaidPurchaseIssue($userId, $issueId) {
return $userId && $this->getByAssoc($userId, PAYMENT_TYPE_PURCHASE_ISSUE, $issueId);
}
/**
* Look for a completed PAYMENT_TYPE_PUBLICATION payment matching the user and article IDs
* @param int $userId
* @param int $articleId
*/
function hasPaidPublication($userId, $articleId) {
return $userId && $this->getByAssoc($userId, PAYMENT_TYPE_PUBLICATION, $articleId);
}
/**
* Retrieve an array of payments for a particular context ID.
* @param $contextId int
* @return array Matching payments
*/
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;
}
/**
* Retrieve an array of payments for a particular user ID.
* @param $userId int
* @return array Matching payments
*/
function getByUserId($userId, $rangeInfo = null) {
$result = $this->retrieveRange(
'SELECT * FROM completed_payments WHERE user_id = ? ORDER BY timestamp DESC',
(int) $userId,
$rangeInfo
);
$returner = array();
while (!$result->EOF) {
$payment = $this->_fromRow($result->fields);
$returner[$payment->getId()] = $payment;
$result->MoveNext();
}
return $returner;
}
/**
* Return a new data object.
* @return CompletedPayment
*/
function newDataObject() {
return new CompletedPayment();
}
/**
* Internal function to return a CompletedPayment object from a row.
* @param $row array
* @return 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;
}
}
