@@ -655,7 +655,7 @@ |
||
655 | 655 | * @return array |
656 | 656 | */ |
657 | 657 | public function report($interface_url,$execution_time,$return_code,$result_code,$user_ip,$out_trade_no = null,$time = null,$device_info = null, |
658 | - $return_msg = null,$err_code = null,$err_code_des = null){ |
|
658 | + $return_msg = null,$err_code = null,$err_code_des = null){ |
|
659 | 659 | $data = array(); |
660 | 660 | $data["appid"] = $this->config["app_id"]; |
661 | 661 | $data["interface_url"] = $interface_url; |
@@ -30,10 +30,10 @@ discard block |
||
30 | 30 | * @method static service\Coupon Coupon(array $config) |
31 | 31 | */ |
32 | 32 | class WechatPay { |
33 | - const TRADETYPE_JSAPI = 'JSAPI',TRADETYPE_NATIVE = 'NATIVE',TRADETYPE_APP = 'APP',TRADETYPE_MWEB = 'MWEB'; |
|
33 | + const TRADETYPE_JSAPI = 'JSAPI', TRADETYPE_NATIVE = 'NATIVE', TRADETYPE_APP = 'APP', TRADETYPE_MWEB = 'MWEB'; |
|
34 | 34 | const SIGNTYPE_MD5 = 'MD5', SIGNTYPE_HMACSHA256 = 'HMAC-SHA256'; |
35 | - const CHECKNAME_FORCECHECK = 'FORCE_CHECK',CHECKNAME_NOCHECK = 'NO_CHECK'; |
|
36 | - const ACCOUNTTYPE_BASIC = 'Basic',ACCOUNTTYPE_OPERATION = 'Operation',ACCOUNTTYPE_FEES = 'Fees'; |
|
35 | + const CHECKNAME_FORCECHECK = 'FORCE_CHECK', CHECKNAME_NOCHECK = 'NO_CHECK'; |
|
36 | + const ACCOUNTTYPE_BASIC = 'Basic', ACCOUNTTYPE_OPERATION = 'Operation', ACCOUNTTYPE_FEES = 'Fees'; |
|
37 | 37 | const API_ENDPOINT = 'https://api.mch.weixin.qq.com/'; |
38 | 38 | /** 支付 */ |
39 | 39 | const URL_UNIFIEDORDER = 'pay/unifiedorder'; |
@@ -118,7 +118,7 @@ discard block |
||
118 | 118 | * @return mixed |
119 | 119 | */ |
120 | 120 | private static function load($name, $config) { |
121 | - $service = __NAMESPACE__ . "\\service\\{$name}"; |
|
121 | + $service = __NAMESPACE__."\\service\\{$name}"; |
|
122 | 122 | return new $service($config); |
123 | 123 | } |
124 | 124 | |
@@ -132,34 +132,34 @@ discard block |
||
132 | 132 | return self::load($name, ...$arguments); |
133 | 133 | } |
134 | 134 | |
135 | - public function setWechatOAuth($wechatOAuth){ |
|
135 | + public function setWechatOAuth($wechatOAuth) { |
|
136 | 136 | $this->wechatOAuth = $wechatOAuth; |
137 | 137 | } |
138 | 138 | |
139 | - public function getWechatOAuth(){ |
|
140 | - if(!$this->wechatOAuth){ |
|
141 | - $this->wechatOAuth = new WechatOAuth($this->config['app_id'],$this->config['app_secret']); |
|
139 | + public function getWechatOAuth() { |
|
140 | + if (!$this->wechatOAuth) { |
|
141 | + $this->wechatOAuth = new WechatOAuth($this->config['app_id'], $this->config['app_secret']); |
|
142 | 142 | } |
143 | 143 | return $this->wechatOAuth; |
144 | 144 | } |
145 | 145 | |
146 | - public function setConfig($config){ |
|
146 | + public function setConfig($config) { |
|
147 | 147 | $this->config = $config; |
148 | 148 | } |
149 | 149 | |
150 | - public function getConfig(){ |
|
150 | + public function getConfig() { |
|
151 | 151 | return $this->config; |
152 | 152 | } |
153 | 153 | |
154 | - public function setHttpClient($httpClient){ |
|
154 | + public function setHttpClient($httpClient) { |
|
155 | 155 | $this->httpClient = $httpClient; |
156 | 156 | } |
157 | 157 | |
158 | - public function setCacheProvider($cacheProvider){ |
|
158 | + public function setCacheProvider($cacheProvider) { |
|
159 | 159 | $this->cacheProvider = $cacheProvider; |
160 | 160 | } |
161 | 161 | |
162 | - public function getCacheProvider(){ |
|
162 | + public function getCacheProvider() { |
|
163 | 163 | return $this->cacheProvider; |
164 | 164 | } |
165 | 165 | |
@@ -173,25 +173,25 @@ discard block |
||
173 | 173 | public function unifiedOrder($params) { |
174 | 174 | $data = array(); |
175 | 175 | $data["appid"] = $this->config["app_id"]; |
176 | - $data["device_info"] = (isset($params['device_info'])&&trim($params['device_info'])!='')?$params['device_info']:null; |
|
176 | + $data["device_info"] = (isset($params['device_info']) && trim($params['device_info']) != '') ? $params['device_info'] : null; |
|
177 | 177 | $data["body"] = $params['body']; |
178 | - $data["detail"] = isset($params['detail'])?$params['detail']:null;//optional |
|
179 | - $data["attach"] = isset($params['attach'])?$params['attach']:null;//optional |
|
180 | - $data["out_trade_no"] = isset($params['out_trade_no'])?$params['out_trade_no']:null; |
|
181 | - $data["fee_type"] = isset($params['fee_type'])?$params['fee_type']:'CNY'; |
|
178 | + $data["detail"] = isset($params['detail']) ? $params['detail'] : null; //optional |
|
179 | + $data["attach"] = isset($params['attach']) ? $params['attach'] : null; //optional |
|
180 | + $data["out_trade_no"] = isset($params['out_trade_no']) ? $params['out_trade_no'] : null; |
|
181 | + $data["fee_type"] = isset($params['fee_type']) ? $params['fee_type'] : 'CNY'; |
|
182 | 182 | $data["total_fee"] = $params['total_fee']; |
183 | 183 | $data["spbill_create_ip"] = $params['spbill_create_ip']; |
184 | - $data["time_start"] = isset($params['time_start'])?$params['time_start']:null;//optional |
|
185 | - $data["time_expire"] = isset($params['time_expire'])?$params['time_expire']:null;//optional |
|
186 | - $data["goods_tag"] = isset($params['goods_tag'])?$params['goods_tag']:null; |
|
184 | + $data["time_start"] = isset($params['time_start']) ? $params['time_start'] : null; //optional |
|
185 | + $data["time_expire"] = isset($params['time_expire']) ? $params['time_expire'] : null; //optional |
|
186 | + $data["goods_tag"] = isset($params['goods_tag']) ? $params['goods_tag'] : null; |
|
187 | 187 | $data["notify_url"] = $this->config["notify_url"]; |
188 | 188 | $data["trade_type"] = $params['trade_type']; |
189 | - if($params['trade_type'] == WechatPay::TRADETYPE_NATIVE){ |
|
190 | - if(!isset($params['product_id'])) throw new Exception('product_id is required when trade_type is NATIVE'); |
|
189 | + if ($params['trade_type'] == WechatPay::TRADETYPE_NATIVE) { |
|
190 | + if (!isset($params['product_id'])) throw new Exception('product_id is required when trade_type is NATIVE'); |
|
191 | 191 | $data["product_id"] = $params['product_id']; |
192 | 192 | } |
193 | - if($params['trade_type'] == WechatPay::TRADETYPE_JSAPI){ |
|
194 | - if(!isset($params['openid'])) throw new Exception('openid is required when trade_type is JSAPI'); |
|
193 | + if ($params['trade_type'] == WechatPay::TRADETYPE_JSAPI) { |
|
194 | + if (!isset($params['openid'])) throw new Exception('openid is required when trade_type is JSAPI'); |
|
195 | 195 | $data["openid"] = $params['openid']; |
196 | 196 | } |
197 | 197 | $result = $this->post(self::URL_UNIFIEDORDER, $data); |
@@ -204,7 +204,7 @@ discard block |
||
204 | 204 | * @param $transaction_id string 微信订单号 |
205 | 205 | * @return array |
206 | 206 | */ |
207 | - public function queryOrderByTransactionId($transaction_id){ |
|
207 | + public function queryOrderByTransactionId($transaction_id) { |
|
208 | 208 | $data = array(); |
209 | 209 | $data["appid"] = $this->config["app_id"]; |
210 | 210 | $data["transaction_id"] = $transaction_id; |
@@ -218,7 +218,7 @@ discard block |
||
218 | 218 | * @param $out_trade_no string 商户订单号 |
219 | 219 | * @return array |
220 | 220 | */ |
221 | - public function queryOrderByOutTradeNo($out_trade_no){ |
|
221 | + public function queryOrderByOutTradeNo($out_trade_no) { |
|
222 | 222 | $data = array(); |
223 | 223 | $data["appid"] = $this->config["app_id"]; |
224 | 224 | $data["out_trade_no"] = $out_trade_no; |
@@ -233,7 +233,7 @@ discard block |
||
233 | 233 | * @param $offset int 偏移 |
234 | 234 | * @return array |
235 | 235 | */ |
236 | - public function queryRefundByTransactionId($transaction_id,$offset = 0){ |
|
236 | + public function queryRefundByTransactionId($transaction_id, $offset = 0) { |
|
237 | 237 | $data = array(); |
238 | 238 | $data["appid"] = $this->config["app_id"]; |
239 | 239 | $data["transaction_id"] = $transaction_id; |
@@ -249,7 +249,7 @@ discard block |
||
249 | 249 | * @param $offset int 偏移 |
250 | 250 | * @return array |
251 | 251 | */ |
252 | - public function queryRefundByOutTradeNo($out_trade_no,$offset = 0){ |
|
252 | + public function queryRefundByOutTradeNo($out_trade_no, $offset = 0) { |
|
253 | 253 | $data = array(); |
254 | 254 | $data["appid"] = $this->config["app_id"]; |
255 | 255 | $data["out_trade_no"] = $out_trade_no; |
@@ -265,7 +265,7 @@ discard block |
||
265 | 265 | * @param $offset int 偏移 |
266 | 266 | * @return array |
267 | 267 | */ |
268 | - public function queryRefundByRefundId($refund_id,$offset = 0){ |
|
268 | + public function queryRefundByRefundId($refund_id, $offset = 0) { |
|
269 | 269 | $data = array(); |
270 | 270 | $data["appid"] = $this->config["app_id"]; |
271 | 271 | $data["refund_id"] = $refund_id; |
@@ -281,7 +281,7 @@ discard block |
||
281 | 281 | * @param $offset int 偏移 |
282 | 282 | * @return array |
283 | 283 | */ |
284 | - public function queryRefundByOutRefundNo($out_refund_no,$offset = 0){ |
|
284 | + public function queryRefundByOutRefundNo($out_refund_no, $offset = 0) { |
|
285 | 285 | $data = array(); |
286 | 286 | $data["appid"] = $this->config["app_id"]; |
287 | 287 | $data["out_refund_no"] = $out_refund_no; |
@@ -296,11 +296,11 @@ discard block |
||
296 | 296 | * @param $out_trade_no string 商户订单号 |
297 | 297 | * @return array |
298 | 298 | */ |
299 | - public function closeOrder($out_trade_no){ |
|
299 | + public function closeOrder($out_trade_no) { |
|
300 | 300 | $data = array(); |
301 | 301 | $data["appid"] = $this->config["app_id"]; |
302 | 302 | $data["out_trade_no"] = $out_trade_no; |
303 | - $result = $this->post(self::URL_CLOSEORDER, $data,false); |
|
303 | + $result = $this->post(self::URL_CLOSEORDER, $data, false); |
|
304 | 304 | return $result; |
305 | 305 | } |
306 | 306 | |
@@ -315,14 +315,14 @@ discard block |
||
315 | 315 | * @param $ext array 扩展数组 |
316 | 316 | * @return array |
317 | 317 | */ |
318 | - public function refundByOutTradeNo($out_trade_no,$out_refund_no,$total_fee,$refund_fee,$ext = array()){ |
|
319 | - $data = ($ext && is_array($ext))?$ext:array(); |
|
318 | + public function refundByOutTradeNo($out_trade_no, $out_refund_no, $total_fee, $refund_fee, $ext = array()) { |
|
319 | + $data = ($ext && is_array($ext)) ? $ext : array(); |
|
320 | 320 | $data["appid"] = $this->config["app_id"]; |
321 | 321 | $data["out_trade_no"] = $out_trade_no; |
322 | 322 | $data["out_refund_no"] = $out_refund_no; |
323 | 323 | $data["total_fee"] = $total_fee; |
324 | 324 | $data["refund_fee"] = $refund_fee; |
325 | - $result = $this->post(self::URL_REFUND, $data,true); |
|
325 | + $result = $this->post(self::URL_REFUND, $data, true); |
|
326 | 326 | return $result; |
327 | 327 | } |
328 | 328 | |
@@ -337,14 +337,14 @@ discard block |
||
337 | 337 | * @param $ext array 扩展数组 |
338 | 338 | * @return array |
339 | 339 | */ |
340 | - public function refundByTransactionId($transaction_id,$out_refund_no,$total_fee,$refund_fee,$ext = array()){ |
|
341 | - $data = ($ext && is_array($ext))?$ext:array(); |
|
340 | + public function refundByTransactionId($transaction_id, $out_refund_no, $total_fee, $refund_fee, $ext = array()) { |
|
341 | + $data = ($ext && is_array($ext)) ? $ext : array(); |
|
342 | 342 | $data["appid"] = $this->config["app_id"]; |
343 | 343 | $data["transaction_id"] = $transaction_id; |
344 | 344 | $data["out_refund_no"] = $out_refund_no; |
345 | 345 | $data["total_fee"] = $total_fee; |
346 | 346 | $data["refund_fee"] = $refund_fee; |
347 | - $result = $this->post(self::URL_REFUND, $data,true); |
|
347 | + $result = $this->post(self::URL_REFUND, $data, true); |
|
348 | 348 | return $result; |
349 | 349 | } |
350 | 350 | |
@@ -355,7 +355,7 @@ discard block |
||
355 | 355 | * @param $bill_type string 类型 ALL|SUCCESS |
356 | 356 | * @return array |
357 | 357 | */ |
358 | - public function downloadBill($bill_date,$bill_type = 'ALL'){ |
|
358 | + public function downloadBill($bill_date, $bill_type = 'ALL') { |
|
359 | 359 | $data = array(); |
360 | 360 | $data["appid"] = $this->config["app_id"]; |
361 | 361 | $data["bill_date"] = $bill_date; |
@@ -372,7 +372,7 @@ discard block |
||
372 | 372 | * @param $tar_type string 压缩账单 |
373 | 373 | * @return array |
374 | 374 | */ |
375 | - public function downloadFundFlow($bill_date,$account_type = self::ACCOUNTTYPE_BASIC,$tar_type = 'GZIP'){ |
|
375 | + public function downloadFundFlow($bill_date, $account_type = self::ACCOUNTTYPE_BASIC, $tar_type = 'GZIP') { |
|
376 | 376 | $data = array(); |
377 | 377 | $data["appid"] = $this->config["app_id"]; |
378 | 378 | $data["bill_date"] = $bill_date; |
@@ -391,14 +391,14 @@ discard block |
||
391 | 391 | * @param int $limit 条数 |
392 | 392 | * @return array |
393 | 393 | */ |
394 | - public function batchQueryComment($begin_time,$end_time,$offset = 0,$limit = 200){ |
|
394 | + public function batchQueryComment($begin_time, $end_time, $offset = 0, $limit = 200) { |
|
395 | 395 | $data = array(); |
396 | 396 | $data["appid"] = $this->config["app_id"]; |
397 | 397 | $data["begin_time"] = $begin_time; |
398 | 398 | $data["end_time"] = $end_time; |
399 | 399 | $data["offset"] = $offset; |
400 | 400 | $data["limit"] = $limit; |
401 | - $data["sign"] = $this->sign($data,WechatPay::SIGNTYPE_HMACSHA256); |
|
401 | + $data["sign"] = $this->sign($data, WechatPay::SIGNTYPE_HMACSHA256); |
|
402 | 402 | $result = $this->post(self::URL_BATCHQUERYCOMMENT, $data, true); //cert is required |
403 | 403 | return $result; |
404 | 404 | } |
@@ -410,11 +410,11 @@ discard block |
||
410 | 410 | * @return null |
411 | 411 | * @throws Exception |
412 | 412 | */ |
413 | - public function onPaidNotify($notify_data,callable $callback = null){ |
|
414 | - if(!is_array($notify_data)) $notify_data = $this->xml2array($notify_data); |
|
415 | - if(!$this->validateSign($notify_data)) throw new Exception('Invalid paid notify data'); |
|
416 | - if($callback && is_callable($callback)){ |
|
417 | - return call_user_func_array( $callback , [$notify_data] ); |
|
413 | + public function onPaidNotify($notify_data, callable $callback = null) { |
|
414 | + if (!is_array($notify_data)) $notify_data = $this->xml2array($notify_data); |
|
415 | + if (!$this->validateSign($notify_data)) throw new Exception('Invalid paid notify data'); |
|
416 | + if ($callback && is_callable($callback)) { |
|
417 | + return call_user_func_array($callback, [$notify_data]); |
|
418 | 418 | } |
419 | 419 | } |
420 | 420 | |
@@ -425,11 +425,11 @@ discard block |
||
425 | 425 | * @return mixed |
426 | 426 | * @throws Exception |
427 | 427 | */ |
428 | - public function onRefundedNotify($notify_data,callable $callback = null){ |
|
429 | - if(!is_array($notify_data)) $notify_data = $this->xml2array($notify_data); |
|
430 | - if(!$this->validateSign($notify_data)) throw new Exception('Invalid refund notify data'); |
|
431 | - if($callback && is_callable($callback)){ |
|
432 | - return call_user_func_array( $callback ,[$notify_data] ); |
|
428 | + public function onRefundedNotify($notify_data, callable $callback = null) { |
|
429 | + if (!is_array($notify_data)) $notify_data = $this->xml2array($notify_data); |
|
430 | + if (!$this->validateSign($notify_data)) throw new Exception('Invalid refund notify data'); |
|
431 | + if ($callback && is_callable($callback)) { |
|
432 | + return call_user_func_array($callback, [$notify_data]); |
|
433 | 433 | } |
434 | 434 | } |
435 | 435 | |
@@ -455,13 +455,13 @@ discard block |
||
455 | 455 | * @param bool $print |
456 | 456 | * @return string |
457 | 457 | */ |
458 | - public function responseNotify($print = true,$data = [],$return_code="SUCCESS", $return_msg= 'OK') { |
|
458 | + public function responseNotify($print = true, $data = [], $return_code = "SUCCESS", $return_msg = 'OK') { |
|
459 | 459 | $data["return_code"] = $return_code; |
460 | 460 | if ($return_msg) { |
461 | 461 | $data["return_msg"] = $return_msg; |
462 | 462 | } |
463 | 463 | $xml = $this->array2xml($data); |
464 | - if($print === true) print $xml; |
|
464 | + if ($print === true) print $xml; |
|
465 | 465 | else return $xml; |
466 | 466 | } |
467 | 467 | |
@@ -481,8 +481,8 @@ discard block |
||
481 | 481 | * @param string $err_code_des |
482 | 482 | * @return array |
483 | 483 | */ |
484 | - public function report($interface_url,$execution_time,$return_code,$result_code,$user_ip,$out_trade_no = null,$time = null,$device_info = null, |
|
485 | - $return_msg = null,$err_code = null,$err_code_des = null){ |
|
484 | + public function report($interface_url, $execution_time, $return_code, $result_code, $user_ip, $out_trade_no = null, $time = null, $device_info = null, |
|
485 | + $return_msg = null, $err_code = null, $err_code_des = null) { |
|
486 | 486 | $data = array(); |
487 | 487 | $data["appid"] = $this->config["app_id"]; |
488 | 488 | $data["interface_url"] = $interface_url; |
@@ -490,12 +490,12 @@ discard block |
||
490 | 490 | $data["return_code"] = $return_code; |
491 | 491 | $data["result_code"] = $result_code; |
492 | 492 | $data["user_ip"] = $user_ip; |
493 | - if($out_trade_no) $data["out_trade_no"] = $out_trade_no; |
|
494 | - if($time) $data["time"] = $time; |
|
495 | - if($device_info) $data["device_info"] = $device_info; |
|
496 | - if($return_msg) $data["return_msg"] = $return_msg; |
|
497 | - if($err_code) $data["err_code"] = $err_code; |
|
498 | - if($err_code_des) $data["err_code_des"] = $err_code_des; |
|
493 | + if ($out_trade_no) $data["out_trade_no"] = $out_trade_no; |
|
494 | + if ($time) $data["time"] = $time; |
|
495 | + if ($device_info) $data["device_info"] = $device_info; |
|
496 | + if ($return_msg) $data["return_msg"] = $return_msg; |
|
497 | + if ($err_code) $data["err_code"] = $err_code; |
|
498 | + if ($err_code_des) $data["err_code_des"] = $err_code_des; |
|
499 | 499 | return $this->post(self::URL_REPORT, $data, false); |
500 | 500 | } |
501 | 501 | |
@@ -505,19 +505,19 @@ discard block |
||
505 | 505 | * @param $longurl |
506 | 506 | * @return string |
507 | 507 | */ |
508 | - public function shortUrl($longurl){ |
|
508 | + public function shortUrl($longurl) { |
|
509 | 509 | $data = array(); |
510 | 510 | $data["appid"] = $this->config["app_id"]; |
511 | 511 | $data["long_url"] = $longurl; |
512 | - $result = $this->post(self::URL_SHORTURL,$data,false); |
|
512 | + $result = $this->post(self::URL_SHORTURL, $data, false); |
|
513 | 513 | return $result['short_url']; |
514 | 514 | } |
515 | 515 | |
516 | - public function rsaEncrypt($data,$pubkey = null){ |
|
517 | - if(!$pubkey) $pubkey = $this->getPublicKey(); |
|
516 | + public function rsaEncrypt($data, $pubkey = null) { |
|
517 | + if (!$pubkey) $pubkey = $this->getPublicKey(); |
|
518 | 518 | $encrypted = null; |
519 | 519 | $pubkey = openssl_get_publickey($pubkey); |
520 | - if (@openssl_public_encrypt($data, $encrypted, $pubkey,OPENSSL_PKCS1_OAEP_PADDING)) |
|
520 | + if (@openssl_public_encrypt($data, $encrypted, $pubkey, OPENSSL_PKCS1_OAEP_PADDING)) |
|
521 | 521 | $data = base64_encode($encrypted); |
522 | 522 | else |
523 | 523 | throw new Exception('Unable to encrypt data'); |
@@ -529,10 +529,10 @@ discard block |
||
529 | 529 | * @link https://pay.weixin.qq.com/wiki/doc/api/native.php?chapter=23_1 |
530 | 530 | * @return array |
531 | 531 | */ |
532 | - public function getSignKey(){ |
|
532 | + public function getSignKey() { |
|
533 | 533 | $data = array(); |
534 | 534 | $data["mch_id"] = $this->config["mch_id"]; |
535 | - $result = $this->post($this->getSignKeyUrl,$data,false); |
|
535 | + $result = $this->post($this->getSignKeyUrl, $data, false); |
|
536 | 536 | return $result['sandbox_signkey']; |
537 | 537 | } |
538 | 538 | |
@@ -542,8 +542,8 @@ discard block |
||
542 | 542 | * @param string $ticket |
543 | 543 | * @return array |
544 | 544 | */ |
545 | - public function getSignPackage($url, $ticket = null){ |
|
546 | - if(!$ticket) $ticket = $this->getTicket(); |
|
545 | + public function getSignPackage($url, $ticket = null) { |
|
546 | + if (!$ticket) $ticket = $this->getTicket(); |
|
547 | 547 | $timestamp = time(); |
548 | 548 | $nonceStr = $this->getNonceStr(); |
549 | 549 | $rawString = "jsapi_ticket=$ticket&noncestr=$nonceStr×tamp=$timestamp&url=$url"; |
@@ -565,29 +565,29 @@ discard block |
||
565 | 565 | * @param boolean $cache |
566 | 566 | * @return string |
567 | 567 | */ |
568 | - public function getTicket($cache = true){ |
|
568 | + public function getTicket($cache = true) { |
|
569 | 569 | $ticket = null; |
570 | 570 | $cacheKey = 'jsapi_ticket'; |
571 | - if($cache === true){ |
|
571 | + if ($cache === true) { |
|
572 | 572 | $data = $this->cacheProvider->get($cacheKey); |
573 | 573 | if ($data && $data->expires_at > time()) { |
574 | 574 | $ticket = $data->ticket; |
575 | 575 | } |
576 | 576 | } |
577 | - if(!$ticket){ |
|
577 | + if (!$ticket) { |
|
578 | 578 | $data = $this->getWechatOAuth()->getTicket(); |
579 | - if($cache === true){ |
|
580 | - $this->cacheProvider->set($cacheKey,$data,time() + $data->expires_in); |
|
579 | + if ($cache === true) { |
|
580 | + $this->cacheProvider->set($cacheKey, $data, time() + $data->expires_in); |
|
581 | 581 | } |
582 | 582 | $ticket = $data->ticket; |
583 | 583 | } |
584 | 584 | return $ticket; |
585 | 585 | } |
586 | 586 | |
587 | - protected function post($url, $data,$cert = true) { |
|
588 | - if(!isset($data['mch_id']) && !isset($data['mchid'])) $data["mch_id"] = $this->config["mch_id"]; |
|
589 | - if(!isset($data['nonce_str'])) $data["nonce_str"] = $this->getNonceStr(); |
|
590 | - if(!isset($data['sign'])) $data['sign'] = $this->sign($data); |
|
587 | + protected function post($url, $data, $cert = true) { |
|
588 | + if (!isset($data['mch_id']) && !isset($data['mchid'])) $data["mch_id"] = $this->config["mch_id"]; |
|
589 | + if (!isset($data['nonce_str'])) $data["nonce_str"] = $this->getNonceStr(); |
|
590 | + if (!isset($data['sign'])) $data['sign'] = $this->sign($data); |
|
591 | 591 | $this->requestXML = $this->responseXML = null; |
592 | 592 | $this->requestArray = $this->responseArray = null; |
593 | 593 | |
@@ -599,23 +599,23 @@ discard block |
||
599 | 599 | CURLOPT_RETURNTRANSFER => true, |
600 | 600 | CURLOPT_TIMEOUT => 10 |
601 | 601 | ]; |
602 | - if($cert == true){ |
|
602 | + if ($cert == true) { |
|
603 | 603 | $opts[CURLOPT_SSLCERTTYPE] = 'PEM'; |
604 | 604 | $opts[CURLOPT_SSLCERT] = $this->config['ssl_cert_path']; |
605 | 605 | $opts[CURLOPT_SSLKEYTYPE] = 'PEM'; |
606 | 606 | $opts[CURLOPT_SSLKEY] = $this->config['ssl_key_path']; |
607 | 607 | } |
608 | 608 | $processResponse = true; |
609 | - if(in_array($url,[self::URL_DOWNLOADBILL,self::URL_DOWNLOAD_FUND_FLOW,self::URL_BATCHQUERYCOMMENT])){ |
|
609 | + if (in_array($url, [self::URL_DOWNLOADBILL, self::URL_DOWNLOAD_FUND_FLOW, self::URL_BATCHQUERYCOMMENT])) { |
|
610 | 610 | $processResponse = false; |
611 | 611 | } |
612 | - if($this->sandbox === true) $url = "sandboxnew/{$url}"; |
|
612 | + if ($this->sandbox === true) $url = "sandboxnew/{$url}"; |
|
613 | 613 | |
614 | - $content = $this->httpClient->post(self::API_ENDPOINT . $url,$this->requestXML,[],$opts); |
|
615 | - if(!$content) throw new Exception("Empty response with {$this->requestXML}"); |
|
614 | + $content = $this->httpClient->post(self::API_ENDPOINT.$url, $this->requestXML, [], $opts); |
|
615 | + if (!$content) throw new Exception("Empty response with {$this->requestXML}"); |
|
616 | 616 | |
617 | 617 | $this->responseXML = $content; |
618 | - if($processResponse) |
|
618 | + if ($processResponse) |
|
619 | 619 | return $this->processResponseXML($this->responseXML); |
620 | 620 | else return $this->responseXML; |
621 | 621 | } |
@@ -625,51 +625,51 @@ discard block |
||
625 | 625 | * @return array |
626 | 626 | * @throws Exception |
627 | 627 | */ |
628 | - private function processResponseXML($responseXML){ |
|
628 | + private function processResponseXML($responseXML) { |
|
629 | 629 | $result = $this->xml2array($responseXML); |
630 | 630 | $this->responseArray = $result; |
631 | - if(empty($result['return_code'])){ |
|
631 | + if (empty($result['return_code'])) { |
|
632 | 632 | throw new Exception("No return code presents in {$this->responseXML}"); |
633 | 633 | } |
634 | 634 | $this->returnCode = $result["return_code"]; |
635 | - $this->returnMsg = isset($result['return_msg'])?$result['return_msg']:''; |
|
635 | + $this->returnMsg = isset($result['return_msg']) ? $result['return_msg'] : ''; |
|
636 | 636 | |
637 | 637 | if ($this->returnCode == "SUCCESS") { |
638 | - if(isset($result['result_code']) && $result['result_code'] == "FAIL"){ |
|
638 | + if (isset($result['result_code']) && $result['result_code'] == "FAIL") { |
|
639 | 639 | $this->resultCode = $result['result_code']; |
640 | 640 | $this->errCode = $result['err_code']; |
641 | 641 | $this->errCodeDes = $result['err_code_des']; |
642 | 642 | throw new Exception("[$this->errCode]$this->errCodeDes"); |
643 | - }else{ |
|
643 | + }else { |
|
644 | 644 | return $result; |
645 | 645 | } |
646 | - } else if($this->returnCode == 'FAIL'){ |
|
646 | + }else if ($this->returnCode == 'FAIL') { |
|
647 | 647 | throw new Exception($this->returnMsg); |
648 | 648 | } |
649 | 649 | } |
650 | 650 | |
651 | - public function sign($data,$sign_type = WechatPay::SIGNTYPE_MD5) { |
|
651 | + public function sign($data, $sign_type = WechatPay::SIGNTYPE_MD5) { |
|
652 | 652 | ksort($data); |
653 | 653 | $string1 = ""; |
654 | 654 | foreach ($data as $k => $v) { |
655 | - if ($v && trim($v)!='') { |
|
655 | + if ($v && trim($v) != '') { |
|
656 | 656 | $string1 .= "$k=$v&"; |
657 | 657 | } |
658 | 658 | } |
659 | - $stringSignTemp = $string1 . "key=" . $this->config["api_key"]; |
|
660 | - if($sign_type == WechatPay::SIGNTYPE_MD5){ |
|
659 | + $stringSignTemp = $string1."key=".$this->config["api_key"]; |
|
660 | + if ($sign_type == WechatPay::SIGNTYPE_MD5) { |
|
661 | 661 | $sign = strtoupper(md5($stringSignTemp)); |
662 | - }elseif($sign_type == WechatPay::SIGNTYPE_HMACSHA256){ |
|
663 | - $sign = strtoupper(hash_hmac('sha256',$stringSignTemp,$this->config["api_key"])); |
|
662 | + }elseif ($sign_type == WechatPay::SIGNTYPE_HMACSHA256) { |
|
663 | + $sign = strtoupper(hash_hmac('sha256', $stringSignTemp, $this->config["api_key"])); |
|
664 | 664 | }else throw new Exception("Not supported sign type - $sign_type"); |
665 | 665 | return $sign; |
666 | 666 | } |
667 | 667 | |
668 | 668 | private function array2xml($array) { |
669 | - $xml = "<xml>" . PHP_EOL; |
|
669 | + $xml = "<xml>".PHP_EOL; |
|
670 | 670 | foreach ($array as $k => $v) { |
671 | - if($v && trim($v)!='') |
|
672 | - $xml .= "<$k><![CDATA[$v]]></$k>" . PHP_EOL; |
|
671 | + if ($v && trim($v) != '') |
|
672 | + $xml .= "<$k><![CDATA[$v]]></$k>".PHP_EOL; |
|
673 | 673 | } |
674 | 674 | $xml .= "</xml>"; |
675 | 675 | return $xml; |
@@ -678,14 +678,14 @@ discard block |
||
678 | 678 | private function xml2array($xml) { |
679 | 679 | $array = []; |
680 | 680 | $tmp = (array) simplexml_load_string($xml); |
681 | - foreach ( $tmp as $k => $v) { |
|
681 | + foreach ($tmp as $k => $v) { |
|
682 | 682 | $array[$k] = (string) $v; |
683 | 683 | } |
684 | 684 | return $array; |
685 | 685 | } |
686 | 686 | |
687 | 687 | protected function getNonceStr() { |
688 | - return substr(str_shuffle("abcdefghijklmnopqrstuvwxyz0123456789"),0,32); |
|
688 | + return substr(str_shuffle("abcdefghijklmnopqrstuvwxyz0123456789"), 0, 32); |
|
689 | 689 | } |
690 | 690 | |
691 | 691 | } |
692 | 692 | \ No newline at end of file |
@@ -187,11 +187,15 @@ discard block |
||
187 | 187 | $data["notify_url"] = $this->config["notify_url"]; |
188 | 188 | $data["trade_type"] = $params['trade_type']; |
189 | 189 | if($params['trade_type'] == WechatPay::TRADETYPE_NATIVE){ |
190 | - if(!isset($params['product_id'])) throw new Exception('product_id is required when trade_type is NATIVE'); |
|
190 | + if(!isset($params['product_id'])) { |
|
191 | + throw new Exception('product_id is required when trade_type is NATIVE'); |
|
192 | + } |
|
191 | 193 | $data["product_id"] = $params['product_id']; |
192 | 194 | } |
193 | 195 | if($params['trade_type'] == WechatPay::TRADETYPE_JSAPI){ |
194 | - if(!isset($params['openid'])) throw new Exception('openid is required when trade_type is JSAPI'); |
|
196 | + if(!isset($params['openid'])) { |
|
197 | + throw new Exception('openid is required when trade_type is JSAPI'); |
|
198 | + } |
|
195 | 199 | $data["openid"] = $params['openid']; |
196 | 200 | } |
197 | 201 | $result = $this->post(self::URL_UNIFIEDORDER, $data); |
@@ -411,8 +415,12 @@ discard block |
||
411 | 415 | * @throws Exception |
412 | 416 | */ |
413 | 417 | public function onPaidNotify($notify_data,callable $callback = null){ |
414 | - if(!is_array($notify_data)) $notify_data = $this->xml2array($notify_data); |
|
415 | - if(!$this->validateSign($notify_data)) throw new Exception('Invalid paid notify data'); |
|
418 | + if(!is_array($notify_data)) { |
|
419 | + $notify_data = $this->xml2array($notify_data); |
|
420 | + } |
|
421 | + if(!$this->validateSign($notify_data)) { |
|
422 | + throw new Exception('Invalid paid notify data'); |
|
423 | + } |
|
416 | 424 | if($callback && is_callable($callback)){ |
417 | 425 | return call_user_func_array( $callback , [$notify_data] ); |
418 | 426 | } |
@@ -426,8 +434,12 @@ discard block |
||
426 | 434 | * @throws Exception |
427 | 435 | */ |
428 | 436 | public function onRefundedNotify($notify_data,callable $callback = null){ |
429 | - if(!is_array($notify_data)) $notify_data = $this->xml2array($notify_data); |
|
430 | - if(!$this->validateSign($notify_data)) throw new Exception('Invalid refund notify data'); |
|
437 | + if(!is_array($notify_data)) { |
|
438 | + $notify_data = $this->xml2array($notify_data); |
|
439 | + } |
|
440 | + if(!$this->validateSign($notify_data)) { |
|
441 | + throw new Exception('Invalid refund notify data'); |
|
442 | + } |
|
431 | 443 | if($callback && is_callable($callback)){ |
432 | 444 | return call_user_func_array( $callback ,[$notify_data] ); |
433 | 445 | } |
@@ -461,8 +473,11 @@ discard block |
||
461 | 473 | $data["return_msg"] = $return_msg; |
462 | 474 | } |
463 | 475 | $xml = $this->array2xml($data); |
464 | - if($print === true) print $xml; |
|
465 | - else return $xml; |
|
476 | + if($print === true) { |
|
477 | + print $xml; |
|
478 | + } else { |
|
479 | + return $xml; |
|
480 | + } |
|
466 | 481 | } |
467 | 482 | |
468 | 483 | /** |
@@ -490,12 +505,24 @@ discard block |
||
490 | 505 | $data["return_code"] = $return_code; |
491 | 506 | $data["result_code"] = $result_code; |
492 | 507 | $data["user_ip"] = $user_ip; |
493 | - if($out_trade_no) $data["out_trade_no"] = $out_trade_no; |
|
494 | - if($time) $data["time"] = $time; |
|
495 | - if($device_info) $data["device_info"] = $device_info; |
|
496 | - if($return_msg) $data["return_msg"] = $return_msg; |
|
497 | - if($err_code) $data["err_code"] = $err_code; |
|
498 | - if($err_code_des) $data["err_code_des"] = $err_code_des; |
|
508 | + if($out_trade_no) { |
|
509 | + $data["out_trade_no"] = $out_trade_no; |
|
510 | + } |
|
511 | + if($time) { |
|
512 | + $data["time"] = $time; |
|
513 | + } |
|
514 | + if($device_info) { |
|
515 | + $data["device_info"] = $device_info; |
|
516 | + } |
|
517 | + if($return_msg) { |
|
518 | + $data["return_msg"] = $return_msg; |
|
519 | + } |
|
520 | + if($err_code) { |
|
521 | + $data["err_code"] = $err_code; |
|
522 | + } |
|
523 | + if($err_code_des) { |
|
524 | + $data["err_code_des"] = $err_code_des; |
|
525 | + } |
|
499 | 526 | return $this->post(self::URL_REPORT, $data, false); |
500 | 527 | } |
501 | 528 | |
@@ -514,13 +541,16 @@ discard block |
||
514 | 541 | } |
515 | 542 | |
516 | 543 | public function rsaEncrypt($data,$pubkey = null){ |
517 | - if(!$pubkey) $pubkey = $this->getPublicKey(); |
|
544 | + if(!$pubkey) { |
|
545 | + $pubkey = $this->getPublicKey(); |
|
546 | + } |
|
518 | 547 | $encrypted = null; |
519 | 548 | $pubkey = openssl_get_publickey($pubkey); |
520 | - if (@openssl_public_encrypt($data, $encrypted, $pubkey,OPENSSL_PKCS1_OAEP_PADDING)) |
|
521 | - $data = base64_encode($encrypted); |
|
522 | - else |
|
523 | - throw new Exception('Unable to encrypt data'); |
|
549 | + if (@openssl_public_encrypt($data, $encrypted, $pubkey,OPENSSL_PKCS1_OAEP_PADDING)) { |
|
550 | + $data = base64_encode($encrypted); |
|
551 | + } else { |
|
552 | + throw new Exception('Unable to encrypt data'); |
|
553 | + } |
|
524 | 554 | return $data; |
525 | 555 | } |
526 | 556 | |
@@ -543,7 +573,9 @@ discard block |
||
543 | 573 | * @return array |
544 | 574 | */ |
545 | 575 | public function getSignPackage($url, $ticket = null){ |
546 | - if(!$ticket) $ticket = $this->getTicket(); |
|
576 | + if(!$ticket) { |
|
577 | + $ticket = $this->getTicket(); |
|
578 | + } |
|
547 | 579 | $timestamp = time(); |
548 | 580 | $nonceStr = $this->getNonceStr(); |
549 | 581 | $rawString = "jsapi_ticket=$ticket&noncestr=$nonceStr×tamp=$timestamp&url=$url"; |
@@ -585,9 +617,15 @@ discard block |
||
585 | 617 | } |
586 | 618 | |
587 | 619 | protected function post($url, $data,$cert = true) { |
588 | - if(!isset($data['mch_id']) && !isset($data['mchid'])) $data["mch_id"] = $this->config["mch_id"]; |
|
589 | - if(!isset($data['nonce_str'])) $data["nonce_str"] = $this->getNonceStr(); |
|
590 | - if(!isset($data['sign'])) $data['sign'] = $this->sign($data); |
|
620 | + if(!isset($data['mch_id']) && !isset($data['mchid'])) { |
|
621 | + $data["mch_id"] = $this->config["mch_id"]; |
|
622 | + } |
|
623 | + if(!isset($data['nonce_str'])) { |
|
624 | + $data["nonce_str"] = $this->getNonceStr(); |
|
625 | + } |
|
626 | + if(!isset($data['sign'])) { |
|
627 | + $data['sign'] = $this->sign($data); |
|
628 | + } |
|
591 | 629 | $this->requestXML = $this->responseXML = null; |
592 | 630 | $this->requestArray = $this->responseArray = null; |
593 | 631 | |
@@ -609,15 +647,21 @@ discard block |
||
609 | 647 | if(in_array($url,[self::URL_DOWNLOADBILL,self::URL_DOWNLOAD_FUND_FLOW,self::URL_BATCHQUERYCOMMENT])){ |
610 | 648 | $processResponse = false; |
611 | 649 | } |
612 | - if($this->sandbox === true) $url = "sandboxnew/{$url}"; |
|
650 | + if($this->sandbox === true) { |
|
651 | + $url = "sandboxnew/{$url}"; |
|
652 | + } |
|
613 | 653 | |
614 | 654 | $content = $this->httpClient->post(self::API_ENDPOINT . $url,$this->requestXML,[],$opts); |
615 | - if(!$content) throw new Exception("Empty response with {$this->requestXML}"); |
|
655 | + if(!$content) { |
|
656 | + throw new Exception("Empty response with {$this->requestXML}"); |
|
657 | + } |
|
616 | 658 | |
617 | 659 | $this->responseXML = $content; |
618 | - if($processResponse) |
|
619 | - return $this->processResponseXML($this->responseXML); |
|
620 | - else return $this->responseXML; |
|
660 | + if($processResponse) { |
|
661 | + return $this->processResponseXML($this->responseXML); |
|
662 | + } else { |
|
663 | + return $this->responseXML; |
|
664 | + } |
|
621 | 665 | } |
622 | 666 | |
623 | 667 | /** |
@@ -640,7 +684,7 @@ discard block |
||
640 | 684 | $this->errCode = $result['err_code']; |
641 | 685 | $this->errCodeDes = $result['err_code_des']; |
642 | 686 | throw new Exception("[$this->errCode]$this->errCodeDes"); |
643 | - }else{ |
|
687 | + } else{ |
|
644 | 688 | return $result; |
645 | 689 | } |
646 | 690 | } else if($this->returnCode == 'FAIL'){ |
@@ -659,17 +703,20 @@ discard block |
||
659 | 703 | $stringSignTemp = $string1 . "key=" . $this->config["api_key"]; |
660 | 704 | if($sign_type == WechatPay::SIGNTYPE_MD5){ |
661 | 705 | $sign = strtoupper(md5($stringSignTemp)); |
662 | - }elseif($sign_type == WechatPay::SIGNTYPE_HMACSHA256){ |
|
706 | + } elseif($sign_type == WechatPay::SIGNTYPE_HMACSHA256){ |
|
663 | 707 | $sign = strtoupper(hash_hmac('sha256',$stringSignTemp,$this->config["api_key"])); |
664 | - }else throw new Exception("Not supported sign type - $sign_type"); |
|
708 | + } else { |
|
709 | + throw new Exception("Not supported sign type - $sign_type"); |
|
710 | + } |
|
665 | 711 | return $sign; |
666 | 712 | } |
667 | 713 | |
668 | 714 | private function array2xml($array) { |
669 | 715 | $xml = "<xml>" . PHP_EOL; |
670 | 716 | foreach ($array as $k => $v) { |
671 | - if($v && trim($v)!='') |
|
672 | - $xml .= "<$k><![CDATA[$v]]></$k>" . PHP_EOL; |
|
717 | + if($v && trim($v)!='') { |
|
718 | + $xml .= "<$k><![CDATA[$v]]></$k>" . PHP_EOL; |
|
719 | + } |
|
673 | 720 | } |
674 | 721 | $xml .= "</xml>"; |
675 | 722 | return $xml; |
@@ -10,8 +10,11 @@ |
||
10 | 10 | private $cacheDir = null; |
11 | 11 | |
12 | 12 | public function __construct($cacheDir = null){ |
13 | - if(!$cacheDir) $this->cacheDir = __DIR__; |
|
14 | - else $this->cacheDir = $cacheDir; |
|
13 | + if(!$cacheDir) { |
|
14 | + $this->cacheDir = __DIR__; |
|
15 | + } else { |
|
16 | + $this->cacheDir = $cacheDir; |
|
17 | + } |
|
15 | 18 | } |
16 | 19 | |
17 | 20 | public function set($key,$jsonobj,$expireAt = null){ |
@@ -6,30 +6,30 @@ discard block |
||
6 | 6 | * @author zhangv |
7 | 7 | */ |
8 | 8 | namespace zhangv\wechat\pay\cache; |
9 | -class JsonFileCacheProvider implements CacheProvider{ |
|
9 | +class JsonFileCacheProvider implements CacheProvider { |
|
10 | 10 | private $cacheDir = null; |
11 | 11 | |
12 | - public function __construct($cacheDir = null){ |
|
13 | - if(!$cacheDir) $this->cacheDir = __DIR__; |
|
12 | + public function __construct($cacheDir = null) { |
|
13 | + if (!$cacheDir) $this->cacheDir = __DIR__; |
|
14 | 14 | else $this->cacheDir = $cacheDir; |
15 | 15 | } |
16 | 16 | |
17 | - public function set($key,$jsonobj,$expireAt = null){ |
|
17 | + public function set($key, $jsonobj, $expireAt = null) { |
|
18 | 18 | $data = $jsonobj; |
19 | 19 | $data->expires_at = $expireAt; |
20 | 20 | $file = "{$this->cacheDir}/{$key}.json"; |
21 | - if($fp = @fopen($file, "w")){ |
|
21 | + if ($fp = @fopen($file, "w")) { |
|
22 | 22 | fwrite($fp, json_encode($data)); |
23 | 23 | fclose($fp); |
24 | 24 | } |
25 | 25 | } |
26 | 26 | |
27 | - public function get($key){ |
|
27 | + public function get($key) { |
|
28 | 28 | $file = "{$this->cacheDir}/{$key}.json"; |
29 | 29 | $cache = null; |
30 | - if(file_exists($file)){ |
|
30 | + if (file_exists($file)) { |
|
31 | 31 | $cache = json_decode(file_get_contents($file)); |
32 | - if($cache->expires_at < time()){ |
|
32 | + if ($cache->expires_at < time()) { |
|
33 | 33 | $cache = null; |
34 | 34 | $this->clear($key); |
35 | 35 | } |
@@ -37,7 +37,7 @@ discard block |
||
37 | 37 | return $cache; |
38 | 38 | } |
39 | 39 | |
40 | - public function clear($key){ |
|
40 | + public function clear($key) { |
|
41 | 41 | $file = "{$this->cacheDir}/{$key}.json"; |
42 | 42 | if (file_exists($file)) { |
43 | 43 | unlink($file); |
@@ -7,8 +7,8 @@ |
||
7 | 7 | */ |
8 | 8 | namespace zhangv\wechat\pay\cache; |
9 | 9 | |
10 | -interface CacheProvider{ |
|
11 | - function set($key,$value,$expireAt); |
|
10 | +interface CacheProvider { |
|
11 | + function set($key, $value, $expireAt); |
|
12 | 12 | function get($key); |
13 | 13 | function clear($key); |
14 | 14 | } |
15 | 15 | \ No newline at end of file |
@@ -6,25 +6,25 @@ |
||
6 | 6 | * @author zhangv |
7 | 7 | */ |
8 | 8 | namespace zhangv\wechat\pay\cache; |
9 | -class RedisCacheProvider implements CacheProvider{ |
|
9 | +class RedisCacheProvider implements CacheProvider { |
|
10 | 10 | /** @var Redis */ |
11 | 11 | private $redis = null; |
12 | 12 | |
13 | - public function __construct($redis = null){ |
|
13 | + public function __construct($redis = null) { |
|
14 | 14 | $this->redis = $redis; |
15 | 15 | } |
16 | 16 | |
17 | - public function set($key,$jsonobj,$expireAt){ |
|
17 | + public function set($key, $jsonobj, $expireAt) { |
|
18 | 18 | $data = $jsonobj; |
19 | 19 | $data->expires_at = $expireAt; |
20 | 20 | $this->redis->set($key, json_encode($data)); |
21 | 21 | } |
22 | 22 | |
23 | - public function get($key){ |
|
23 | + public function get($key) { |
|
24 | 24 | return $this->redis->get($key); |
25 | 25 | } |
26 | 26 | |
27 | - public function clear($key){ |
|
27 | + public function clear($key) { |
|
28 | 28 | $this->redis->delete($key); |
29 | 29 | } |
30 | 30 | } |
31 | 31 | \ No newline at end of file |
@@ -35,15 +35,15 @@ |
||
35 | 35 | * @return string |
36 | 36 | * @throws Exception |
37 | 37 | */ |
38 | - public function getMwebUrl($body,$out_trade_no,$total_fee,$ext = null){ |
|
39 | - $data = ($ext && is_array($ext))?$ext:array(); |
|
38 | + public function getMwebUrl($body, $out_trade_no, $total_fee, $ext = null) { |
|
39 | + $data = ($ext && is_array($ext)) ? $ext : array(); |
|
40 | 40 | $data["body"] = $body; |
41 | 41 | $data["out_trade_no"] = $out_trade_no; |
42 | 42 | $data["total_fee"] = $total_fee; |
43 | - $data["spbill_create_ip"] = isset($_SERVER["REMOTE_ADDR"])?$_SERVER["REMOTE_ADDR"]:''; |
|
43 | + $data["spbill_create_ip"] = isset($_SERVER["REMOTE_ADDR"]) ? $_SERVER["REMOTE_ADDR"] : ''; |
|
44 | 44 | $data["notify_url"] = $this->config["notify_url"]; |
45 | 45 | $data["trade_type"] = self::TRADETYPE_MWEB; |
46 | - if(!isset($this->config['h5_scene_info'])) throw new Exception('h5_scene_info should be configured'); |
|
46 | + if (!isset($this->config['h5_scene_info'])) throw new Exception('h5_scene_info should be configured'); |
|
47 | 47 | $data["scene_info"] = json_encode($this->config['h5_scene_info']); |
48 | 48 | $result = $this->unifiedOrder($data); |
49 | 49 | return $result["mweb_url"]; |
@@ -43,7 +43,9 @@ |
||
43 | 43 | $data["spbill_create_ip"] = isset($_SERVER["REMOTE_ADDR"])?$_SERVER["REMOTE_ADDR"]:''; |
44 | 44 | $data["notify_url"] = $this->config["notify_url"]; |
45 | 45 | $data["trade_type"] = self::TRADETYPE_MWEB; |
46 | - if(!isset($this->config['h5_scene_info'])) throw new Exception('h5_scene_info should be configured'); |
|
46 | + if(!isset($this->config['h5_scene_info'])) { |
|
47 | + throw new Exception('h5_scene_info should be configured'); |
|
48 | + } |
|
47 | 49 | $data["scene_info"] = json_encode($this->config['h5_scene_info']); |
48 | 50 | $result = $this->unifiedOrder($data); |
49 | 51 | return $result["mweb_url"]; |
@@ -37,15 +37,15 @@ discard block |
||
37 | 37 | * @param array $ext |
38 | 38 | * @return array |
39 | 39 | */ |
40 | - public function microPay($body,$out_trade_no,$total_fee,$spbill_create_ip,$auth_code,$ext = array()){ |
|
41 | - $data = (!empty($ext) && is_array($ext))?$ext:array(); |
|
40 | + public function microPay($body, $out_trade_no, $total_fee, $spbill_create_ip, $auth_code, $ext = array()) { |
|
41 | + $data = (!empty($ext) && is_array($ext)) ? $ext : array(); |
|
42 | 42 | $data["appid"] = $this->config["app_id"]; |
43 | 43 | $data["body"] = $body; |
44 | 44 | $data["out_trade_no"] = $out_trade_no; |
45 | 45 | $data["total_fee"] = $total_fee; |
46 | 46 | $data["spbill_create_ip"] = $spbill_create_ip; |
47 | 47 | $data["auth_code"] = $auth_code; |
48 | - $result = $this->post(self::URL_MICROPAY,$data,true); |
|
48 | + $result = $this->post(self::URL_MICROPAY, $data, true); |
|
49 | 49 | return $result; |
50 | 50 | } |
51 | 51 | |
@@ -55,11 +55,11 @@ discard block |
||
55 | 55 | * @param $auth_code |
56 | 56 | * @return mixed |
57 | 57 | */ |
58 | - public function authCodeToOpenId($auth_code){ |
|
58 | + public function authCodeToOpenId($auth_code) { |
|
59 | 59 | $data = array(); |
60 | 60 | $data["appid"] = $this->config["app_id"]; |
61 | 61 | $data["auth_code"] = $auth_code; |
62 | - $result = $this->post(self::URL_AUTHCODETOOPENID,$data,false); |
|
62 | + $result = $this->post(self::URL_AUTHCODETOOPENID, $data, false); |
|
63 | 63 | return $result['openid']; |
64 | 64 | } |
65 | 65 | |
@@ -70,11 +70,11 @@ discard block |
||
70 | 70 | * @param $out_trade_no string 商户订单号 |
71 | 71 | * @return array |
72 | 72 | */ |
73 | - public function reverseByOutTradeNo($out_trade_no){ |
|
73 | + public function reverseByOutTradeNo($out_trade_no) { |
|
74 | 74 | $data = array(); |
75 | 75 | $data["appid"] = $this->config["app_id"]; |
76 | 76 | $data["out_trade_no"] = $out_trade_no; |
77 | - $result = $this->post(self::URL_REVERSE, $data,true); |
|
77 | + $result = $this->post(self::URL_REVERSE, $data, true); |
|
78 | 78 | return $result; |
79 | 79 | } |
80 | 80 | |
@@ -84,11 +84,11 @@ discard block |
||
84 | 84 | * @param $transaction_id string 微信订单号 |
85 | 85 | * @return array |
86 | 86 | */ |
87 | - public function reverseByTransactionId($transaction_id){ |
|
87 | + public function reverseByTransactionId($transaction_id) { |
|
88 | 88 | $data = array(); |
89 | 89 | $data["appid"] = $this->config["app_id"]; |
90 | 90 | $data["transaction_id"] = $transaction_id; |
91 | - $result = $this->post(self::URL_REVERSE, $data,true); |
|
91 | + $result = $this->post(self::URL_REVERSE, $data, true); |
|
92 | 92 | return $result; |
93 | 93 | } |
94 | 94 | } |
95 | 95 | \ No newline at end of file |
@@ -29,14 +29,14 @@ discard block |
||
29 | 29 | * @return array |
30 | 30 | * @throws Exception |
31 | 31 | */ |
32 | - public function sendRedPack($mch_billno,$send_name,$re_openid,$total_amount,$total_num,$wishing,$act_name,$remark,$scene_id = '',$riskinfo = '',$consume_mch_id = ''){ |
|
32 | + public function sendRedPack($mch_billno, $send_name, $re_openid, $total_amount, $total_num, $wishing, $act_name, $remark, $scene_id = '', $riskinfo = '', $consume_mch_id = '') { |
|
33 | 33 | $data = array(); |
34 | 34 | $data["wxappid"] = $this->config["app_id"]; |
35 | 35 | $data["mch_billno"] = $mch_billno; |
36 | 36 | $data["send_name"] = $send_name; |
37 | 37 | $data["re_openid"] = $re_openid; |
38 | 38 | $data["total_amount"] = $total_amount; |
39 | - if($total_amount > 20000 && trim($scene_id)=='') throw new Exception("scene_id is required when total_amount beyond 20000"); |
|
39 | + if ($total_amount > 20000 && trim($scene_id) == '') throw new Exception("scene_id is required when total_amount beyond 20000"); |
|
40 | 40 | $data["total_num"] = $total_num; |
41 | 41 | $data["wishing"] = $wishing; |
42 | 42 | $data["act_name"] = $act_name; |
@@ -65,14 +65,14 @@ discard block |
||
65 | 65 | * @return array |
66 | 66 | * @throws Exception |
67 | 67 | */ |
68 | - public function sendGroupRedPack($mch_billno,$send_name,$re_openid,$total_amount,$total_num,$wishing,$act_name,$remark,$scene_id = '',$riskinfo = '',$consume_mch_id = ''){ |
|
68 | + public function sendGroupRedPack($mch_billno, $send_name, $re_openid, $total_amount, $total_num, $wishing, $act_name, $remark, $scene_id = '', $riskinfo = '', $consume_mch_id = '') { |
|
69 | 69 | $data = array(); |
70 | - $data["wxappid"] = $this->config["app_id"];//NOTE: WXappid |
|
70 | + $data["wxappid"] = $this->config["app_id"]; //NOTE: WXappid |
|
71 | 71 | $data["mch_billno"] = $mch_billno; |
72 | 72 | $data["send_name"] = $send_name; |
73 | 73 | $data["re_openid"] = $re_openid; |
74 | 74 | $data["total_amount"] = $total_amount; |
75 | - if($total_amount > 20000 && trim($scene_id)=='') throw new Exception("scene_id is required when total_amount beyond 20000(200rmb)"); |
|
75 | + if ($total_amount > 20000 && trim($scene_id) == '') throw new Exception("scene_id is required when total_amount beyond 20000(200rmb)"); |
|
76 | 76 | $data["total_num"] = $total_num; |
77 | 77 | $data["amt_type"] = 'ALL_RAND'; //红包金额设置方式 ALL_RAND—全部随机 |
78 | 78 | $data["wishing"] = $wishing; |
@@ -92,7 +92,7 @@ discard block |
||
92 | 92 | * @throws Exception |
93 | 93 | * @link https://pay.weixin.qq.com/wiki/doc/api/tools/cash_coupon.php?chapter=13_6&index=5 |
94 | 94 | */ |
95 | - public function getHbInfo($mch_billno){ |
|
95 | + public function getHbInfo($mch_billno) { |
|
96 | 96 | $data = array(); |
97 | 97 | $data["mch_billno"] = $mch_billno; |
98 | 98 | $data["appid"] = $this->config["app_id"]; |
@@ -36,7 +36,9 @@ discard block |
||
36 | 36 | $data["send_name"] = $send_name; |
37 | 37 | $data["re_openid"] = $re_openid; |
38 | 38 | $data["total_amount"] = $total_amount; |
39 | - if($total_amount > 20000 && trim($scene_id)=='') throw new Exception("scene_id is required when total_amount beyond 20000"); |
|
39 | + if($total_amount > 20000 && trim($scene_id)=='') { |
|
40 | + throw new Exception("scene_id is required when total_amount beyond 20000"); |
|
41 | + } |
|
40 | 42 | $data["total_num"] = $total_num; |
41 | 43 | $data["wishing"] = $wishing; |
42 | 44 | $data["act_name"] = $act_name; |
@@ -72,7 +74,9 @@ discard block |
||
72 | 74 | $data["send_name"] = $send_name; |
73 | 75 | $data["re_openid"] = $re_openid; |
74 | 76 | $data["total_amount"] = $total_amount; |
75 | - if($total_amount > 20000 && trim($scene_id)=='') throw new Exception("scene_id is required when total_amount beyond 20000(200rmb)"); |
|
77 | + if($total_amount > 20000 && trim($scene_id)=='') { |
|
78 | + throw new Exception("scene_id is required when total_amount beyond 20000(200rmb)"); |
|
79 | + } |
|
76 | 80 | $data["total_num"] = $total_num; |
77 | 81 | $data["amt_type"] = 'ALL_RAND'; //红包金额设置方式 ALL_RAND—全部随机 |
78 | 82 | $data["wishing"] = $wishing; |
@@ -38,16 +38,16 @@ |
||
38 | 38 | * @return string |
39 | 39 | * @throws \Exception |
40 | 40 | */ |
41 | - public function getPrepayId($body,$out_trade_no,$total_fee,$openid,$spbill_create_ip = null,$ext = null) { |
|
42 | - $data = ($ext && is_array($ext))?$ext:array(); |
|
41 | + public function getPrepayId($body, $out_trade_no, $total_fee, $openid, $spbill_create_ip = null, $ext = null) { |
|
42 | + $data = ($ext && is_array($ext)) ? $ext : array(); |
|
43 | 43 | $data["body"] = $body; |
44 | 44 | $data["out_trade_no"] = $out_trade_no; |
45 | 45 | $data["total_fee"] = $total_fee; |
46 | - $data["spbill_create_ip"] = $spbill_create_ip?:$_SERVER["REMOTE_ADDR"]; |
|
46 | + $data["spbill_create_ip"] = $spbill_create_ip ?: $_SERVER["REMOTE_ADDR"]; |
|
47 | 47 | $data["notify_url"] = $this->config["notify_url"]; |
48 | 48 | $data["trade_type"] = WechatPay::TRADETYPE_JSAPI; |
49 | - if(!$openid) throw new Exception('openid is required when trade_type is JSAPI'); |
|
50 | - $data["openid"] = $openid; |
|
49 | + if (!$openid) throw new Exception('openid is required when trade_type is JSAPI'); |
|
50 | + $data["openid"] = $openid; |
|
51 | 51 | $result = $this->unifiedOrder($data); |
52 | 52 | return $result["prepay_id"]; |
53 | 53 | } |
@@ -46,7 +46,9 @@ |
||
46 | 46 | $data["spbill_create_ip"] = $spbill_create_ip?:$_SERVER["REMOTE_ADDR"]; |
47 | 47 | $data["notify_url"] = $this->config["notify_url"]; |
48 | 48 | $data["trade_type"] = WechatPay::TRADETYPE_JSAPI; |
49 | - if(!$openid) throw new Exception('openid is required when trade_type is JSAPI'); |
|
49 | + if(!$openid) { |
|
50 | + throw new Exception('openid is required when trade_type is JSAPI'); |
|
51 | + } |
|
50 | 52 | $data["openid"] = $openid; |
51 | 53 | $result = $this->unifiedOrder($data); |
52 | 54 | return $result["prepay_id"]; |
@@ -25,19 +25,19 @@ discard block |
||
25 | 25 | * @return array |
26 | 26 | * @throws Exception |
27 | 27 | */ |
28 | - public function transferWallet($partner_trade_no,$openid,$amount,$desc,$spbill_create_ip = null,$re_user_name = null,$check_name = WechatPay::CHECKNAME_FORCECHECK){ |
|
28 | + public function transferWallet($partner_trade_no, $openid, $amount, $desc, $spbill_create_ip = null, $re_user_name = null, $check_name = WechatPay::CHECKNAME_FORCECHECK) { |
|
29 | 29 | $data = array(); |
30 | - if($check_name == WechatPay::CHECKNAME_FORCECHECK && !$re_user_name) throw new Exception('Real name is required'); |
|
30 | + if ($check_name == WechatPay::CHECKNAME_FORCECHECK && !$re_user_name) throw new Exception('Real name is required'); |
|
31 | 31 | $data["mch_appid"] = $this->config["app_id"]; |
32 | 32 | $data["mchid"] = $this->config["mch_id"]; |
33 | 33 | $data["partner_trade_no"] = $partner_trade_no; |
34 | 34 | $data["openid"] = $openid; |
35 | 35 | $data["amount"] = $amount; |
36 | 36 | $data["desc"] = $desc; |
37 | - $data['spbill_create_ip'] = $spbill_create_ip?:$_SERVER['SERVER_ADDR']; |
|
37 | + $data['spbill_create_ip'] = $spbill_create_ip ?: $_SERVER['SERVER_ADDR']; |
|
38 | 38 | $data["check_name"] = $check_name; |
39 | 39 | $data["re_user_name"] = $re_user_name; |
40 | - $result = $this->post(self::URL_TRANSFER_WALLET,$data,true); |
|
40 | + $result = $this->post(self::URL_TRANSFER_WALLET, $data, true); |
|
41 | 41 | return $result; |
42 | 42 | } |
43 | 43 | |
@@ -47,12 +47,12 @@ discard block |
||
47 | 47 | * @param $partner_trade_no |
48 | 48 | * @return array |
49 | 49 | */ |
50 | - public function queryTransferWallet($partner_trade_no){ |
|
50 | + public function queryTransferWallet($partner_trade_no) { |
|
51 | 51 | $data = array(); |
52 | 52 | $data["appid"] = $this->config["app_id"]; |
53 | 53 | $data["mch_id"] = $this->config["mch_id"]; |
54 | 54 | $data["partner_trade_no"] = $partner_trade_no; |
55 | - $result = $this->post(self::URL_QUERY_TRANSFER_WALLET,$data,true); |
|
55 | + $result = $this->post(self::URL_QUERY_TRANSFER_WALLET, $data, true); |
|
56 | 56 | return $result; |
57 | 57 | } |
58 | 58 | |
@@ -68,8 +68,8 @@ discard block |
||
68 | 68 | * @return array |
69 | 69 | * @throws Exception |
70 | 70 | */ |
71 | - public function transferBankCard($partner_trade_no,$bank_no,$true_name,$bank_code,$amount,$desc){ |
|
72 | - if(!in_array($bank_code,array_values(self::$BANKCODE))) throw new Exception("Unsupported bank code: $bank_code"); |
|
71 | + public function transferBankCard($partner_trade_no, $bank_no, $true_name, $bank_code, $amount, $desc) { |
|
72 | + if (!in_array($bank_code, array_values(self::$BANKCODE))) throw new Exception("Unsupported bank code: $bank_code"); |
|
73 | 73 | $data = array(); |
74 | 74 | $data["partner_trade_no"] = $partner_trade_no; |
75 | 75 | $enc_bank_no = $this->rsaEncrypt($bank_no); |
@@ -79,7 +79,7 @@ discard block |
||
79 | 79 | $data["bank_code"] = $bank_code; |
80 | 80 | $data["desc"] = $desc; |
81 | 81 | $data["amount"] = $amount; |
82 | - $result = $this->post(self::URL_TRANSFER_BANKCARD,$data,true); |
|
82 | + $result = $this->post(self::URL_TRANSFER_BANKCARD, $data, true); |
|
83 | 83 | return $result; |
84 | 84 | } |
85 | 85 | |
@@ -89,12 +89,12 @@ discard block |
||
89 | 89 | * @param $partner_trade_no |
90 | 90 | * @return array |
91 | 91 | */ |
92 | - public function queryTransferBankCard($partner_trade_no){ |
|
92 | + public function queryTransferBankCard($partner_trade_no) { |
|
93 | 93 | $data = array(); |
94 | 94 | $data["appid"] = $this->config["app_id"]; |
95 | 95 | $data["mch_id"] = $this->config["mch_id"]; |
96 | 96 | $data["partner_trade_no"] = $partner_trade_no; |
97 | - $result = $this->post(self::URL_QUERY_TRANSFER_WALLET,$data,true); |
|
97 | + $result = $this->post(self::URL_QUERY_TRANSFER_WALLET, $data, true); |
|
98 | 98 | return $result; |
99 | 99 | } |
100 | 100 | |
@@ -105,18 +105,18 @@ discard block |
||
105 | 105 | * @return string |
106 | 106 | * @throws Exception |
107 | 107 | */ |
108 | - public function getPublicKey($refresh = false){ |
|
109 | - if(!$this->publicKey) { |
|
108 | + public function getPublicKey($refresh = false) { |
|
109 | + if (!$this->publicKey) { |
|
110 | 110 | if (!$refresh && file_exists($this->config["rsa_pubkey_path"])) { |
111 | 111 | $this->publicKey = file_get_contents($this->config["rsa_pubkey_path"]); |
112 | - }else{ |
|
112 | + }else { |
|
113 | 113 | $data = array(); |
114 | 114 | $data["mch_id"] = $this->config["mch_id"]; |
115 | 115 | $data["sign_type"] = $this->config["sign_type"]; |
116 | 116 | $result = $this->post(self::URL_GETPUBLICKEY, $data, true); |
117 | 117 | $pubkey = $result['pub_key']; |
118 | 118 | $this->publicKey = $this->convertPKCS1toPKCS8($pubkey); |
119 | - if($fp = @fopen($this->config["rsa_pubkey_path"], "w")) { |
|
119 | + if ($fp = @fopen($this->config["rsa_pubkey_path"], "w")) { |
|
120 | 120 | fwrite($fp, $this->publicKey); |
121 | 121 | fclose($fp); |
122 | 122 | } |
@@ -125,16 +125,16 @@ discard block |
||
125 | 125 | return $this->publicKey; |
126 | 126 | } |
127 | 127 | |
128 | - public function setPublicKey($publicKey){ |
|
128 | + public function setPublicKey($publicKey) { |
|
129 | 129 | $this->publicKey = $publicKey; |
130 | 130 | } |
131 | 131 | |
132 | - private function convertPKCS1toPKCS8($pkcs1){ |
|
132 | + private function convertPKCS1toPKCS8($pkcs1) { |
|
133 | 133 | $start_key = $pkcs1; |
134 | 134 | $start_key = str_replace('-----BEGIN RSA PUBLIC KEY-----', '', $start_key); |
135 | 135 | $start_key = trim(str_replace('-----END RSA PUBLIC KEY-----', '', $start_key)); |
136 | - $key = 'MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8A' . str_replace("\n", '', $start_key); |
|
137 | - $key = "-----BEGIN PUBLIC KEY-----\n" . wordwrap($key, 64, "\n", true) . "\n-----END PUBLIC KEY-----"; |
|
136 | + $key = 'MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8A'.str_replace("\n", '', $start_key); |
|
137 | + $key = "-----BEGIN PUBLIC KEY-----\n".wordwrap($key, 64, "\n", true)."\n-----END PUBLIC KEY-----"; |
|
138 | 138 | return $key; |
139 | 139 | } |
140 | 140 | } |
141 | 141 | \ No newline at end of file |
@@ -27,7 +27,9 @@ discard block |
||
27 | 27 | */ |
28 | 28 | public function transferWallet($partner_trade_no,$openid,$amount,$desc,$spbill_create_ip = null,$re_user_name = null,$check_name = WechatPay::CHECKNAME_FORCECHECK){ |
29 | 29 | $data = array(); |
30 | - if($check_name == WechatPay::CHECKNAME_FORCECHECK && !$re_user_name) throw new Exception('Real name is required'); |
|
30 | + if($check_name == WechatPay::CHECKNAME_FORCECHECK && !$re_user_name) { |
|
31 | + throw new Exception('Real name is required'); |
|
32 | + } |
|
31 | 33 | $data["mch_appid"] = $this->config["app_id"]; |
32 | 34 | $data["mchid"] = $this->config["mch_id"]; |
33 | 35 | $data["partner_trade_no"] = $partner_trade_no; |
@@ -69,7 +71,9 @@ discard block |
||
69 | 71 | * @throws Exception |
70 | 72 | */ |
71 | 73 | public function transferBankCard($partner_trade_no,$bank_no,$true_name,$bank_code,$amount,$desc){ |
72 | - if(!in_array($bank_code,array_values(self::$BANKCODE))) throw new Exception("Unsupported bank code: $bank_code"); |
|
74 | + if(!in_array($bank_code,array_values(self::$BANKCODE))) { |
|
75 | + throw new Exception("Unsupported bank code: $bank_code"); |
|
76 | + } |
|
73 | 77 | $data = array(); |
74 | 78 | $data["partner_trade_no"] = $partner_trade_no; |
75 | 79 | $enc_bank_no = $this->rsaEncrypt($bank_no); |
@@ -109,7 +113,7 @@ discard block |
||
109 | 113 | if(!$this->publicKey) { |
110 | 114 | if (!$refresh && file_exists($this->config["rsa_pubkey_path"])) { |
111 | 115 | $this->publicKey = file_get_contents($this->config["rsa_pubkey_path"]); |
112 | - }else{ |
|
116 | + } else{ |
|
113 | 117 | $data = array(); |
114 | 118 | $data["mch_id"] = $this->config["mch_id"]; |
115 | 119 | $data["sign_type"] = $this->config["sign_type"]; |