@@ -6,7 +6,7 @@ discard block |
||
6 | 6 | namespace zhangv\wechat; |
7 | 7 | |
8 | 8 | class WechatOAuth { |
9 | - const TICKETTYPE_JSAPI = 'jsapi',TICKETTYPE_WXCARD = 'wx_card'; |
|
9 | + const TICKETTYPE_JSAPI = 'jsapi', TICKETTYPE_WXCARD = 'wx_card'; |
|
10 | 10 | public $responseJSON = null; |
11 | 11 | public $errCode = null; |
12 | 12 | public $errMsg = null; |
@@ -16,46 +16,46 @@ discard block |
||
16 | 16 | private $httpClient = null; |
17 | 17 | private $accessToken = null; |
18 | 18 | |
19 | - public function __construct($appId,$appSecret) { |
|
19 | + public function __construct($appId, $appSecret) { |
|
20 | 20 | $this->appId = $appId; |
21 | 21 | $this->appSecret = $appSecret; |
22 | 22 | $this->httpClient = new HttpClient(); |
23 | 23 | } |
24 | 24 | |
25 | - public function setHttpClient($httpClient){ |
|
25 | + public function setHttpClient($httpClient) { |
|
26 | 26 | $this->httpClient = $httpClient; |
27 | 27 | } |
28 | 28 | |
29 | - public function authorizeURI($redirectURI,$scope = 'snsapi_userinfo',$state = ''){ |
|
29 | + public function authorizeURI($redirectURI, $scope = 'snsapi_userinfo', $state = '') { |
|
30 | 30 | $redirectURI = urlencode($redirectURI); |
31 | 31 | return "https://open.weixin.qq.com/connect/oauth2/authorize?appid={$this->appId}&redirect_uri={$redirectURI}&response_type=code&scope=$scope&state=$state#wechat_redirect"; |
32 | 32 | } |
33 | 33 | |
34 | - public function authorize($code){ |
|
34 | + public function authorize($code) { |
|
35 | 35 | $url = "https://api.weixin.qq.com/sns/oauth2/access_token?appid={$this->appId}&secret={$this->appSecret}&code=$code&grant_type=authorization_code"; |
36 | 36 | $this->responseJSON = $this->httpClient->get($url); |
37 | 37 | return json_decode($this->responseJSON); |
38 | 38 | } |
39 | 39 | |
40 | - public function getUserInfo($openId){ |
|
40 | + public function getUserInfo($openId) { |
|
41 | 41 | $url = "https://api.weixin.qq.com/sns/userinfo?access_token={$this->accessToken}&openid=$openId&lang=zh_CN"; |
42 | 42 | $this->responseJSON = $this->httpClient->get($url); |
43 | 43 | return json_decode($this->responseJSON); |
44 | 44 | } |
45 | 45 | |
46 | - public function refreshToken($refreshToken){ |
|
46 | + public function refreshToken($refreshToken) { |
|
47 | 47 | $url = "https://api.weixin.qq.com/sns/oauth2/refresh_token?appid={$this->appId}&grant_type=refresh_token&refresh_token=$refreshToken"; |
48 | 48 | $this->responseJSON = $this->httpClient->get($url); |
49 | 49 | return json_decode($this->responseJSON); |
50 | 50 | } |
51 | 51 | |
52 | - public function verifyToken($accessToken,$openId){ |
|
52 | + public function verifyToken($accessToken, $openId) { |
|
53 | 53 | $url = "https://api.weixin.qq.com/sns/auth?access_token=$accessToken&openid=$openId"; |
54 | 54 | $this->responseJSON = $this->httpClient->get($url); |
55 | 55 | return json_decode($this->responseJSON); |
56 | 56 | } |
57 | 57 | |
58 | - public function getAccessToken(){ |
|
58 | + public function getAccessToken() { |
|
59 | 59 | $url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={$this->appId}&secret={$this->appSecret}"; |
60 | 60 | $this->responseJSON = $this->httpClient->get($url); |
61 | 61 | $json = json_decode($this->responseJSON); |
@@ -63,8 +63,8 @@ discard block |
||
63 | 63 | return $this->accessToken; |
64 | 64 | } |
65 | 65 | |
66 | - public function getTicket($type = WechatOAuth::TICKETTYPE_JSAPI, $accessToken = null){ |
|
67 | - if(!$accessToken) $accessToken = $this->getAccessToken(); |
|
66 | + public function getTicket($type = WechatOAuth::TICKETTYPE_JSAPI, $accessToken = null) { |
|
67 | + if (!$accessToken) $accessToken = $this->getAccessToken(); |
|
68 | 68 | // $url = "https://qyapi.weixin.qq.com/cgi-bin/get_jsapi_ticket?access_token=$accessToken"; |
69 | 69 | $url = "https://api.weixin.qq.com/cgi-bin/ticket/getticket?type={$type}&access_token=$accessToken"; |
70 | 70 | $this->responseJSON = $this->httpClient->get($url); |
@@ -64,7 +64,9 @@ |
||
64 | 64 | } |
65 | 65 | |
66 | 66 | public function getTicket($type = WechatOAuth::TICKETTYPE_JSAPI, $accessToken = null){ |
67 | - if(!$accessToken) $accessToken = $this->getAccessToken(); |
|
67 | + if(!$accessToken) { |
|
68 | + $accessToken = $this->getAccessToken(); |
|
69 | + } |
|
68 | 70 | // $url = "https://qyapi.weixin.qq.com/cgi-bin/get_jsapi_ticket?access_token=$accessToken"; |
69 | 71 | $url = "https://api.weixin.qq.com/cgi-bin/ticket/getticket?type={$type}&access_token=$accessToken"; |
70 | 72 | $this->responseJSON = $this->httpClient->get($url); |
@@ -5,9 +5,9 @@ discard block |
||
5 | 5 | */ |
6 | 6 | namespace zhangv\wechat; |
7 | 7 | |
8 | -class HttpClient{ |
|
8 | +class HttpClient { |
|
9 | 9 | |
10 | - const GET = 'get',POST = 'post', DELETE = 'delete',PUT = 'put'; |
|
10 | + const GET = 'get', POST = 'post', DELETE = 'delete', PUT = 'put'; |
|
11 | 11 | private $instance = null; |
12 | 12 | private $errNo = null; |
13 | 13 | private $info = null; |
@@ -17,8 +17,8 @@ discard block |
||
17 | 17 | $this->initInstance($timeout); |
18 | 18 | } |
19 | 19 | |
20 | - public function initInstance($timeout){ |
|
21 | - if(!$this->instance) { |
|
20 | + public function initInstance($timeout) { |
|
21 | + if (!$this->instance) { |
|
22 | 22 | $this->instance = curl_init(); |
23 | 23 | curl_setopt($this->instance, CURLOPT_TIMEOUT, intval($timeout)); |
24 | 24 | curl_setopt($this->instance, CURLOPT_RETURNTRANSFER, true); |
@@ -27,26 +27,26 @@ discard block |
||
27 | 27 | } |
28 | 28 | } |
29 | 29 | |
30 | - public function get($url,$params = array(),$headers = array(),$opts = array()) { |
|
30 | + public function get($url, $params = array(), $headers = array(), $opts = array()) { |
|
31 | 31 | if (!$this->instance) $this->initInstance($this->timeout); |
32 | - if($params && count($params) > 0) $url .= '?' . http_build_query($params); |
|
32 | + if ($params && count($params) > 0) $url .= '?'.http_build_query($params); |
|
33 | 33 | curl_setopt($this->instance, CURLOPT_URL, $url); |
34 | 34 | curl_setopt($this->instance, CURLOPT_HTTPGET, true); |
35 | 35 | curl_setopt($this->instance, CURLOPT_HTTPHEADER, $headers); |
36 | - curl_setopt_array($this->instance,$opts); |
|
36 | + curl_setopt_array($this->instance, $opts); |
|
37 | 37 | $result = $this->execute(); |
38 | 38 | curl_close($this->instance); |
39 | 39 | $this->instance = null; |
40 | 40 | return $result; |
41 | 41 | } |
42 | 42 | |
43 | - public function post($url, $params = array(),$headers = array(),$opts = array()) { |
|
43 | + public function post($url, $params = array(), $headers = array(), $opts = array()) { |
|
44 | 44 | if (!$this->instance) $this->initInstance($this->timeout); |
45 | 45 | curl_setopt($this->instance, CURLOPT_URL, $url); |
46 | 46 | curl_setopt($this->instance, CURLOPT_POST, true); |
47 | 47 | curl_setopt($this->instance, CURLOPT_POSTFIELDS, $params); |
48 | 48 | curl_setopt($this->instance, CURLOPT_HTTPHEADER, $headers); |
49 | - curl_setopt_array($this->instance,$opts); |
|
49 | + curl_setopt_array($this->instance, $opts); |
|
50 | 50 | $result = $this->execute(); |
51 | 51 | curl_close($this->instance); |
52 | 52 | $this->instance = null; |
@@ -60,7 +60,7 @@ discard block |
||
60 | 60 | return $result; |
61 | 61 | } |
62 | 62 | |
63 | - public function getInfo(){ |
|
63 | + public function getInfo() { |
|
64 | 64 | return $this->info; |
65 | 65 | } |
66 | 66 | } |
67 | 67 | \ No newline at end of file |
@@ -28,8 +28,12 @@ discard block |
||
28 | 28 | } |
29 | 29 | |
30 | 30 | public function get($url,$params = array(),$headers = array(),$opts = array()) { |
31 | - if (!$this->instance) $this->initInstance($this->timeout); |
|
32 | - if($params && count($params) > 0) $url .= '?' . http_build_query($params); |
|
31 | + if (!$this->instance) { |
|
32 | + $this->initInstance($this->timeout); |
|
33 | + } |
|
34 | + if($params && count($params) > 0) { |
|
35 | + $url .= '?' . http_build_query($params); |
|
36 | + } |
|
33 | 37 | curl_setopt($this->instance, CURLOPT_URL, $url); |
34 | 38 | curl_setopt($this->instance, CURLOPT_HTTPGET, true); |
35 | 39 | curl_setopt($this->instance, CURLOPT_HTTPHEADER, $headers); |
@@ -41,7 +45,9 @@ discard block |
||
41 | 45 | } |
42 | 46 | |
43 | 47 | public function post($url, $params = array(),$headers = array(),$opts = array()) { |
44 | - if (!$this->instance) $this->initInstance($this->timeout); |
|
48 | + if (!$this->instance) { |
|
49 | + $this->initInstance($this->timeout); |
|
50 | + } |
|
45 | 51 | curl_setopt($this->instance, CURLOPT_URL, $url); |
46 | 52 | curl_setopt($this->instance, CURLOPT_POST, true); |
47 | 53 | curl_setopt($this->instance, CURLOPT_POSTFIELDS, $params); |
@@ -1,13 +1,13 @@ |
||
1 | 1 | <?php |
2 | 2 | |
3 | -require_once __DIR__ . "/autoload.php"; |
|
3 | +require_once __DIR__."/autoload.php"; |
|
4 | 4 | use zhangv\wechat\WechatPay; |
5 | 5 | |
6 | 6 | $xml = file_get_contents("php://input"); |
7 | 7 | |
8 | 8 | $cfg = require './config.php'; |
9 | 9 | $payment = new WechatPay($cfg); |
10 | -$payment->onPaidNotify($xml,function($notifydata) use ($payment){ |
|
10 | +$payment->onPaidNotify($xml, function($notifydata) use ($payment){ |
|
11 | 11 | //do stuff |
12 | 12 | print_r($notifydata); |
13 | 13 | $payment->responseNotify(); |