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
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
|
<?php
class ModelExtensionPaymentPPPayflowIFrame extends Model {
public function install() {
$this->db->query("
CREATE TABLE `" . DB_PREFIX . "paypal_payflow_iframe_order` (
`order_id` int(11) DEFAULT NULL,
`secure_token_id` varchar(255) NOT NULL,
`transaction_reference` varchar(255) DEFAULT NULL,
`transaction_type` varchar(1) DEFAULT NULL,
`complete` tinyint(4) NOT NULL DEFAULT '0',
PRIMARY KEY(`order_id`),
KEY `secure_token_id` (`secure_token_id`)
) ENGINE=MyISAM DEFAULT COLLATE=utf8_general_ci");
$this->db->query("
CREATE TABLE `" . DB_PREFIX . "paypal_payflow_iframe_order_transaction` (
`order_id` int(11) NOT NULL,
`transaction_reference` varchar(255) NOT NULL,
`transaction_type` char(1) NOT NULL,
`time` datetime NOT NULL,
`amount` decimal(10,4) DEFAULT NULL,
PRIMARY KEY (`transaction_reference`),
KEY `order_id` (`order_id`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8;");
}
public function uninstall() {
$this->db->query("DROP TABLE IF EXISTS `" . DB_PREFIX . "paypal_payflow_iframe_order`;");
$this->db->query("DROP TABLE IF EXISTS `" . DB_PREFIX . "paypal_payflow_iframe_order_transaction`;");
}
public function log($message) {
if ($this->config->get('payment_pp_payflow_iframe_debug')) {
$log = new Log('payflow-iframe.log');
$log->write($message);
}
}
public function getOrder($order_id) {
$result = $this->db->query("SELECT * FROM " . DB_PREFIX . "paypal_payflow_iframe_order WHERE order_id = " . (int)$order_id);
if ($result->num_rows) {
$order = $result->row;
} else {
$order = false;
}
return $order;
}
public function updateOrderStatus($order_id, $status) {
$this->db->query("
UPDATE " . DB_PREFIX . "paypal_payflow_iframe_order
SET `complete` = " . (int)$status . "
WHERE order_id = '" . (int)$order_id . "'
");
}
public function addTransaction($data) {
$this->db->query("
INSERT INTO " . DB_PREFIX . "paypal_payflow_iframe_order_transaction
SET order_id = " . (int)$data['order_id'] . ",
transaction_reference = '" . $this->db->escape($data['transaction_reference']) . "',
transaction_type = '" . $this->db->escape($data['type']) . "',
`time` = NOW(),
`amount` = '" . $this->db->escape($data['amount']) . "'
");
}
public function getTransactions($order_id) {
return $this->db->query("
SELECT *
FROM " . DB_PREFIX . "paypal_payflow_iframe_order_transaction
WHERE order_id = " . (int)$order_id . "
ORDER BY `time` ASC")->rows;
}
public function getTransaction($transaction_reference) {
$result = $this->db->query("
SELECT *
FROM " . DB_PREFIX . "paypal_payflow_iframe_order_transaction
WHERE transaction_reference = '" . $this->db->escape($transaction_reference) . "'")->row;
if ($result) {
$transaction = $result;
} else {
$transaction = false;
}
return $transaction;
}
public function call($data) {
$default_parameters = array(
'USER' => $this->config->get('payment_pp_payflow_iframe_user'),
'VENDOR' => $this->config->get('payment_pp_payflow_iframe_vendor'),
'PWD' => $this->config->get('payment_pp_payflow_iframe_password'),
'PARTNER' => $this->config->get('payment_pp_payflow_iframe_partner'),
'BUTTONSOURCE' => 'OpenCart_Cart_PFP',
);
$call_parameters = array_merge($data, $default_parameters);
if ($this->config->get('payment_pp_payflow_iframe_test')) {
$url = 'https://pilot-payflowpro.paypal.com';
} else {
$url = 'https://payflowpro.paypal.com';
}
$query_params = array();
foreach ($call_parameters as $key => $value) {
$query_params[] = $key . '=' . utf8_decode($value);
}
$this->log('Call data: ' . implode('&', $query_params));
$curl = curl_init($url);
curl_setopt($curl, CURLOPT_POST, true);
curl_setopt($curl, CURLOPT_POSTFIELDS, implode('&', $query_params));
curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
curl_setopt($curl, CURLOPT_HEADER, false);
curl_setopt($curl, CURLOPT_TIMEOUT, 30);
curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
$response = curl_exec($curl);
$this->log('Response data: ' . $response);
$response_params = array();
parse_str($response, $response_params);
return $response_params;
}
}
|
