admin/model/sale/recurring.php
<?php
/**
* @package Arastta eCommerce
* @copyright 2015-2017 Arastta Association. All rights reserved.
* @copyright See CREDITS.txt for credits and other copyright notices.
* @license GNU GPL version 3; see LICENSE.txt
* @link https://arastta.org
*/
class ModelSaleRecurring extends Model {
public function getTotalRecurrings($data) {
$sql = "SELECT COUNT(*) AS `total` FROM `" . DB_PREFIX . "order_recurring` `or` JOIN `" . DB_PREFIX . "order` o USING(order_id) WHERE 1 = 1";
if (!empty($data['filter_order_recurring_id'])) {
$sql .= " AND or.order_recurring_id = " . (int)$data['filter_order_recurring_id'];
}
if (!empty($data['filter_order_id'])) {
$sql .= " AND or.order_id = " . (int)$data['filter_order_id'];
}
if (!empty($data['filter_payment_reference'])) {
$sql .= " AND or.reference LIKE '" . $this->db->escape($data['filter_reference']) . "%'";
}
if (!empty($data['filter_customer'])) {
$sql .= " AND CONCAT(o.firstname, ' ', o.lastname) LIKE '" . $this->db->escape($data['filter_customer']) . "%'";
}
if (!empty($data['filter_status'])) {
$sql .= " AND or.status = " . (int)$data['filter_status'];
}
if (!empty($data['filter_date_added'])) {
$sql .= " AND DATE(or.date_added) = DATE('" . $this->db->escape($data['filter_date_added']) . "')";
}
$query = $this->db->query($sql);
return $query->row['total'];
}
public function getRecurrings($data) {
$sql = "SELECT `or`.order_recurring_id, `or`.order_id, `or`.reference, `or`.`status`, `or`.`date_added`, CONCAT(`o`.`firstname`, ' ', `o`.`lastname`) AS `customer` FROM `" . DB_PREFIX . "order_recurring` `or` JOIN `" . DB_PREFIX . "order` `o` USING(`order_id`) WHERE 1 = 1 ";
if (!empty($data['filter_order_recurring_id'])) {
$sql .= " AND or.order_recurring_id = " . (int)$data['filter_order_recurring_id'];
}
if (!empty($data['filter_order_id'])) {
$sql .= " AND or.order_id = " . (int)$data['filter_order_id'];
}
if (!empty($data['filter_reference'])) {
$sql .= " AND or.reference LIKE '" . $this->db->escape($data['filter_reference']) . "%'";
}
if (!empty($data['filter_customer'])) {
$sql .= " AND CONCAT(o.firstname, ' ', o.lastname) LIKE '" . $this->db->escape($data['filter_customer']) . "%'";
}
if (!empty($data['filter_status'])) {
$sql .= " AND or.status = " . (int)$data['filter_status'];
}
if (!empty($data['filter_date_added'])) {
$sql .= " AND DATE(or.date_added) = DATE('" . $this->db->escape($data['filter_date_added']) . "')";
}
$sort_data = array(
'or.order_recurring_id',
'or.order_id',
'or.reference',
'customer',
'or.status',
'or.date_added'
);
if (isset($data['sort']) && in_array($data['sort'], $sort_data)) {
$sql .= " ORDER BY " . $data['sort'];
} else {
$sql .= " ORDER BY or.order_recurring_id";
}
if (isset($data['order']) && ($data['order'] == 'DESC')) {
$sql .= " DESC";
} else {
$sql .= " ASC";
}
if (isset($data['start']) || isset($data['limit'])) {
if ($data['start'] < 0) {
$data['start'] = 0;
}
if ($data['limit'] < 1) {
$data['limit'] = 20;
}
$sql .= " LIMIT " . (int)$data['start'] . "," . (int)$data['limit'];
}
$recurrings = array();
$results = $this->db->query($sql)->rows;
foreach ($results as $result) {
$recurrings[] = array(
'order_recurring_id' => $result['order_recurring_id'],
'order_id' => $result['order_id'],
'reference' => $result['reference'],
'customer' => $result['customer'],
'status' => $this->getStatus($result['status']),
'date_added' => $result['date_added']
);
}
return $recurrings;
}
public function getRecurring($order_recurring_id) {
$recurring = array();
$query = $this->db->query("SELECT * FROM " . DB_PREFIX . "order_recurring WHERE order_recurring_id = " . (int)$order_recurring_id);
if ($query->num_rows) {
$recurring = array(
'order_recurring_id' => $query->row['order_recurring_id'],
'order_id' => $query->row['order_id'],
'reference' => $query->row['reference'],
'recurring_id' => $query->row['recurring_id'],
'recurring_name' => $query->row['recurring_name'],
'recurring_description' => $query->row['recurring_description'],
'product_name' => $query->row['product_name'],
'product_quantity' => $query->row['product_quantity'],
'status' => $this->getStatus($query->row['status']),
'status_id' => $query->row['status']
);
}
return $recurring;
}
public function getRecurringTransactions($order_recurring_id) {
$transactions = array();
$query = $this->db->query("SELECT amount, type, date_added FROM " . DB_PREFIX . "order_recurring_transaction WHERE order_recurring_id = " . (int)$order_recurring_id . " ORDER BY date_added DESC");
if ($query->num_rows) {
foreach ($query->rows as $result) {
switch ($result['type']) {
case 0:
$type = $this->language->get('text_transaction_date_added');
break;
case 1:
$type = $this->language->get('text_transaction_payment');
break;
case 2:
$type = $this->language->get('text_transaction_outstanding_payment');
break;
case 3:
$type = $this->language->get('text_transaction_skipped');
break;
case 4:
$type = $this->language->get('text_transaction_failed');
break;
case 5:
$type = $this->language->get('text_transaction_cancelled');
break;
case 6:
$type = $this->language->get('text_transaction_suspended');
break;
case 7:
$type = $this->language->get('text_transaction_suspended_failed');
break;
case 8:
$type = $this->language->get('text_transaction_outstanding_failed');
break;
case 9:
$type = $this->language->get('text_transaction_expired');
break;
default:
$type = '';
break;
}
$transactions[] = array(
'date_added' => $result['date_added'],
'amount' => $result['amount'],
'type' => $type
);
}
}
return $transactions;
}
private function getStatus($status) {
switch ($status) {
case 1:
$result = $this->language->get('text_status_inactive');
break;
case 2:
$result = $this->language->get('text_status_active');
break;
case 3:
$result = $this->language->get('text_status_suspended');
break;
case 4:
$result = $this->language->get('text_status_cancelled');
break;
case 5:
$result = $this->language->get('text_status_expired');
break;
case 6:
$result = $this->language->get('text_status_pending');
break;
default:
$result = '';
break;
}
return $result;
}
}