1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
|
<?php
class ModelExtensionPaymentSquareup extends Model {
const RECURRING_ACTIVE = 1;
const RECURRING_INACTIVE = 2;
const RECURRING_CANCELLED = 3;
const RECURRING_SUSPENDED = 4;
const RECURRING_EXPIRED = 5;
const RECURRING_PENDING = 6;
public function getTransaction($squareup_transaction_id) {
return $this->db->query("SELECT * FROM `" . DB_PREFIX . "squareup_transaction` WHERE squareup_transaction_id='" . (int)$squareup_transaction_id . "'")->row;
}
public function getTransactions($data) {
$sql = "SELECT * FROM `" . DB_PREFIX . "squareup_transaction`";
if (isset($data['order_id'])) {
$sql .= " WHERE order_id='" . (int)$data['order_id'] . "'";
}
$sql .= " ORDER BY created_at DESC";
if (isset($data['start']) && isset($data['limit'])) {
$sql .= " LIMIT " . $data['start'] . ', ' . $data['limit'];
}
return $this->db->query($sql)->rows;
}
public function getTotalTransactions($data) {
$sql = "SELECT COUNT(*) as total FROM `" . DB_PREFIX . "squareup_transaction`";
if (isset($data['order_id'])) {
$sql .= " WHERE order_id='" . (int)$data['order_id'] . "'";
}
return $this->db->query($sql)->row['total'];
}
public function updateTransaction($squareup_transaction_id, $type, $refunds = array()) {
$this->db->query("UPDATE `" . DB_PREFIX . "squareup_transaction` SET transaction_type='" . $this->db->escape($type) . "', is_refunded='" . (int)!empty($refunds) . "', refunds='" . $this->db->escape(json_encode($refunds)) . "' WHERE squareup_transaction_id='" . (int)$squareup_transaction_id . "'");
}
public function getOrderStatusId($order_id, $transaction_status = null) {
if ($transaction_status) {
return $this->config->get('payment_squareup_status_' . strtolower($transaction_status));
} else {
$this->load->model('sale/order');
$order_info = $this->model_sale_order->getOrder($order_id);
return $order_info['order_status_id'];
}
}
public function editOrderRecurringStatus($order_recurring_id, $status) {
$this->db->query("UPDATE `" . DB_PREFIX . "order_recurring` SET `status` = '" . (int)$status . "' WHERE `order_recurring_id` = '" . (int)$order_recurring_id . "'");
}
public function createTables() {
$this->db->query("CREATE TABLE IF NOT EXISTS `" . DB_PREFIX . "squareup_transaction` (
`squareup_transaction_id` int(11) UNSIGNED NOT NULL AUTO_INCREMENT,
`transaction_id` char(40) NOT NULL,
`merchant_id` char(32) NOT NULL,
`location_id` varchar(32) NOT NULL,
`order_id` int(11) NOT NULL,
`transaction_type` char(20) NOT NULL,
`transaction_amount` decimal(15,2) NOT NULL,
`transaction_currency` char(3) NOT NULL,
`billing_address_city` char(100) NOT NULL,
`billing_address_company` char(100) NOT NULL,
`billing_address_country` char(3) NOT NULL,
`billing_address_postcode` char(10) NOT NULL,
`billing_address_province` char(20) NOT NULL,
`billing_address_street_1` char(100) NOT NULL,
`billing_address_street_2` char(100) NOT NULL,
`device_browser` char(255) NOT NULL,
`device_ip` char(15) NOT NULL,
`created_at` char(29) NOT NULL,
`is_refunded` tinyint(1) NOT NULL,
`refunded_at` varchar(29) NOT NULL,
`tenders` text NOT NULL,
`refunds` text NOT NULL,
PRIMARY KEY (`squareup_transaction_id`),
KEY `order_id` (`order_id`),
KEY `transaction_id` (`transaction_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;");
$this->db->query("CREATE TABLE IF NOT EXISTS `" . DB_PREFIX . "squareup_token` (
`squareup_token_id` int(11) unsigned NOT NULL AUTO_INCREMENT,
`customer_id` int(11) NOT NULL,
`sandbox` tinyint(1) NOT NULL,
`token` char(40) NOT NULL,
`date_added` datetime NOT NULL,
`brand` VARCHAR(32) NOT NULL,
`ends_in` VARCHAR(4) NOT NULL,
PRIMARY KEY (`squareup_token_id`),
KEY `getCards` (`customer_id`, `sandbox`),
KEY `verifyCardCustomer` (`squareup_token_id`, `customer_id`),
KEY `cardExists` (`customer_id`, `brand`, `ends_in`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8");
$this->db->query("CREATE TABLE IF NOT EXISTS `" . DB_PREFIX . "squareup_customer` (
`customer_id` int(11) NOT NULL,
`sandbox` tinyint(1) NOT NULL,
`square_customer_id` varchar(32) NOT NULL,
PRIMARY KEY (`customer_id`, `sandbox`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8");
}
public function dropTables() {
$this->db->query("DROP TABLE IF EXISTS `" . DB_PREFIX . "squareup_transaction`");
$this->db->query("DROP TABLE IF EXISTS `" . DB_PREFIX . "squareup_token`");
$this->db->query("DROP TABLE IF EXISTS `" . DB_PREFIX . "squareup_customer`");
}
}
|
