forked from helei112g/payment
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathAliNotify.php
More file actions
196 lines (178 loc) · 6.6 KB
/
AliNotify.php
File metadata and controls
196 lines (178 loc) · 6.6 KB
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
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
<?php
namespace Payment\Notify;
use Payment\Common\AliConfig;
use Payment\Common\PayException;
use Payment\Config;
use Payment\Utils\ArrayUtil;
use Payment\Utils\Rsa2Encrypt;
use Payment\Utils\RsaEncrypt;
/**
* @author: helei
* @createTime: 2016-07-20 16:21
* @description: 支付宝回调通知
*
* @link https://www.gitbook.com/book/helei112g1/payment-sdk/details
* @link https://helei112g.github.io/
*/
class AliNotify extends NotifyStrategy
{
/**
* AliNotify constructor.
* @param array $config
* @throws PayException
*/
public function __construct(array $config)
{
try {
$this->config = new AliConfig($config);
} catch (PayException $e) {
throw $e;
}
}
/**
* 获取移除通知的数据 并进行简单处理（如：格式化为数组）
*
* 如果获取数据失败，返回false
*
* @return array|boolean
* @author helei
*/
public function getNotifyData()
{
$data = empty($_POST) ? $_GET : $_POST;
if (empty($data) || ! is_array($data)) {
return false;
}
return $data;
}
/**
* 检查异步通知的数据是否合法
*
* 如果检查失败，返回false
*
* @param array $data 由 $this->getNotifyData() 返回的数据
* @return boolean
* @author helei
*/
public function checkNotifyData(array $data)
{
$status = $this->getTradeStatus($data['trade_status']);
if ($status !== Config::TRADE_STATUS_SUCC) {
// 如果不是交易成功状态，直接返回错误，
return false;
}
// 检查签名
$flag = $this->verifySign($data);
return $flag;
}
/**
* 向客户端返回必要的数据
* @param array $data 回调机构返回的回调通知数据
* @return array|false
* @author helei
*/
protected function getRetData(array $data)
{
if ($this->config->returnRaw) {
$data['channel'] = Config::ALI_CHARGE;
return $data;
}
$retData = [
'notify_time' => ArrayUtil::get($data, 'notify_time'),
'notify_type' => ArrayUtil::get($data, 'notify_type'),
'notify_id' => ArrayUtil::get($data, 'notify_id'),
'app_id' => ArrayUtil::get($data, 'app_id'),
'transaction_id' => ArrayUtil::get($data, 'trade_no'),
'order_no' => ArrayUtil::get($data, 'out_trade_no'),
'out_biz_no' => ArrayUtil::get($data, 'out_biz_no'),
'buyer_id' => ArrayUtil::get($data, 'buyer_id'),
'buyer_account' => ArrayUtil::get($data, 'buyer_logon_id'),
'seller_id' => ArrayUtil::get($data, 'seller_id'),
'seller_email' => ArrayUtil::get($data, 'seller_email'),
'trade_state' => $this->getTradeStatus($data['trade_status']),
'amount' => ArrayUtil::get($data, 'total_amount'),
'receipt_amount' => ArrayUtil::get($data, 'receipt_amount'),// 商家在交易中实际收到的款项，单位为元
'invoice_amount' => ArrayUtil::get($data, 'invoice_amount'),// 用户在交易中支付的可开发票的金额
'pay_amount' => ArrayUtil::get($data, 'buyer_pay_amount'),// 用户在交易中支付的金额
'point_amount' => ArrayUtil::get($data, 'point_amount'),// 使用集分宝支付的金额
'refund_fee' => ArrayUtil::get($data, 'refund_fee'), // 总退款金额
'subject' => ArrayUtil::get($data, 'subject'),
'body' => ArrayUtil::get($data, 'body'),
'trade_create_time' => ArrayUtil::get($data, 'gmt_create'),// 交易创建时间
'pay_time' => ArrayUtil::get($data, 'gmt_payment'),// 交易付款时间
'trade_refund_time' => ArrayUtil::get($data, 'gmt_refund'), // 交易退款时间
'trade_close_time' => ArrayUtil::get($data, 'gmt_close'), // 交易关闭时间
'channel' => Config::ALI_CHARGE,
];
// 检查是否存在用户自定义参数
if (isset($data['passback_params']) && ! empty($data['passback_params'])) {
$retData['return_param'] = $data['passback_params'];
}
// 支付成功的各个渠道金额信息
if (isset($data['fund_bill_list']) && ! empty($data['fund_bill_list'])) {
$retData['fund_bill_list'] = \GuzzleHttp\json_decode($data['fund_bill_list'], true);
}
// 优惠券信息
if (isset($data['voucher_detail_list']) && ! empty($data['voucher_detail_list'])) {
$retData['voucher_detail_list'] = \GuzzleHttp\json_decode($data['voucher_detail_list'], true);
}
return $retData;
}
/**
* 支付宝，成功返回 ‘success’ 失败，返回 ‘fail’
* @param boolean $flag 每次返回的bool值
* @param string $msg 错误原因 后期考虑记录日志
* @return string
* @author helei
*/
protected function replyNotify($flag, $msg = '')
{
if ($flag) {
return 'success';
} else {
return 'fail';
}
}
/**
* 返回统一的交易状态
* @param $status
* @return string
* @author helei
*/
protected function getTradeStatus($status)
{
if (in_array($status, ['TRADE_SUCCESS', 'TRADE_FINISHED'])) {
return Config::TRADE_STATUS_SUCC;
} else {
return Config::TRADE_STATUS_FAILD;
}
}
/**
* 检查支付宝数据 签名是否被篡改
* @param array $data
* @return boolean
* @author helei
*/
protected function verifySign(array $data)
{
$signType = strtoupper($data['sign_type']);
$sign = $data['sign'];
// 1. 剔除sign与sign_type参数
$values = ArrayUtil::removeKeys($data, ['sign', 'sign_type']);
// 2. 移除数组中的空值
$values = ArrayUtil::paraFilter($values);
// 3. 对待签名参数数组排序
$values = ArrayUtil::arraySort($values);
// 4. 将排序后的参数与其对应值，组合成“参数=参数值”的格式,用&字符连接起来
$preStr = ArrayUtil::createLinkstring($values);
if ($signType === 'RSA') {// 使用rsa方式
$rsa = new RsaEncrypt($this->config->rsaAliPubKey);
return $rsa->rsaVerify($preStr, $sign);
} elseif ($signType === 'RSA2') {
$rsa = new Rsa2Encrypt($this->config->rsaAliPubKey);
return $rsa->rsaVerify($preStr, $sign);
} else {
return false;
}
}
}