@@ -38,15 +38,15 @@ |
||
| 38 | 38 | * @return string |
| 39 | 39 | * @throws Exception |
| 40 | 40 | */ |
| 41 | - public function getCodeUrl($body,$out_trade_no,$total_fee,$product_id,$spbill_create_ip = null,$ext = null){ |
|
| 42 | - $data = ($ext && is_array($ext))?$ext:array(); |
|
| 41 | + public function getCodeUrl($body, $out_trade_no, $total_fee, $product_id, $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["SERVER_ADDR"]; |
|
| 46 | + $data["spbill_create_ip"] = $spbill_create_ip ?: $_SERVER["SERVER_ADDR"]; |
|
| 47 | 47 | $data["notify_url"] = $this->config["notify_url"]; |
| 48 | 48 | $data["trade_type"] = self::TRADETYPE_NATIVE; |
| 49 | - if(!$product_id) throw new Exception('product_id is required when trade_type is NATIVE'); |
|
| 49 | + if (!$product_id) throw new Exception('product_id is required when trade_type is NATIVE'); |
|
| 50 | 50 | $data["product_id"] = $product_id; |
| 51 | 51 | $result = $this->unifiedOrder($data); |
| 52 | 52 | return $result["code_url"]; |
@@ -46,7 +46,9 @@ |
||
| 46 | 46 | $data["spbill_create_ip"] = $spbill_create_ip?:$_SERVER["SERVER_ADDR"]; |
| 47 | 47 | $data["notify_url"] = $this->config["notify_url"]; |
| 48 | 48 | $data["trade_type"] = self::TRADETYPE_NATIVE; |
| 49 | - if(!$product_id) throw new Exception('product_id is required when trade_type is NATIVE'); |
|
| 49 | + if(!$product_id) { |
|
| 50 | + throw new Exception('product_id is required when trade_type is NATIVE'); |
|
| 51 | + } |
|
| 50 | 52 | $data["product_id"] = $product_id; |
| 51 | 53 | $result = $this->unifiedOrder($data); |
| 52 | 54 | return $result["code_url"]; |
@@ -22,14 +22,14 @@ discard block |
||
| 22 | 22 | * @param array $ext |
| 23 | 23 | * @return array |
| 24 | 24 | */ |
| 25 | - public function sendCoupon($coupon_stock_id,$open_id,$partner_trade_no,$op_user_id = '',$ext = array()){ |
|
| 26 | - $data = (!empty($ext) && is_array($ext))?$ext:array(); |
|
| 25 | + public function sendCoupon($coupon_stock_id, $open_id, $partner_trade_no, $op_user_id = '', $ext = array()) { |
|
| 26 | + $data = (!empty($ext) && is_array($ext)) ? $ext : array(); |
|
| 27 | 27 | $data["partner_trade_no"] = $partner_trade_no; |
| 28 | 28 | $data["coupon_stock_id"] = $coupon_stock_id; |
| 29 | 29 | $data["openid_count"] = 1; |
| 30 | 30 | $data["open_id"] = $open_id; |
| 31 | 31 | $data["op_user_id"] = $op_user_id; |
| 32 | - $result = $this->post(self::URL_SEND_COUPON,$data,true); |
|
| 32 | + $result = $this->post(self::URL_SEND_COUPON, $data, true); |
|
| 33 | 33 | return $result; |
| 34 | 34 | } |
| 35 | 35 | |
@@ -40,11 +40,11 @@ discard block |
||
| 40 | 40 | * @param string $op_user_id |
| 41 | 41 | * @return array |
| 42 | 42 | */ |
| 43 | - public function queryCouponStock($coupon_stock_id,$op_user_id = ''){ |
|
| 43 | + public function queryCouponStock($coupon_stock_id, $op_user_id = '') { |
|
| 44 | 44 | $data = array(); |
| 45 | 45 | $data["coupon_stock_id"] = $coupon_stock_id; |
| 46 | 46 | $data["op_user_id"] = $op_user_id; |
| 47 | - $result = $this->post(self::URL_QUERY_COUPON_STOCK,$data,false); |
|
| 47 | + $result = $this->post(self::URL_QUERY_COUPON_STOCK, $data, false); |
|
| 48 | 48 | return $result; |
| 49 | 49 | } |
| 50 | 50 | |
@@ -58,13 +58,13 @@ discard block |
||
| 58 | 58 | * @param array $ext |
| 59 | 59 | * @return array |
| 60 | 60 | */ |
| 61 | - public function queryCouponsInfo($coupon_id,$open_id,$stock_id,$op_user_id = '',$ext = array()){ |
|
| 62 | - $data = (!empty($ext) && is_array($ext))?$ext:array(); |
|
| 61 | + public function queryCouponsInfo($coupon_id, $open_id, $stock_id, $op_user_id = '', $ext = array()) { |
|
| 62 | + $data = (!empty($ext) && is_array($ext)) ? $ext : array(); |
|
| 63 | 63 | $data["coupon_id"] = $coupon_id; |
| 64 | 64 | $data["stock_id"] = $stock_id; |
| 65 | 65 | $data["open_id"] = $open_id; |
| 66 | 66 | $data["op_user_id"] = $op_user_id; |
| 67 | - $result = $this->post(self::URL_QUERY_COUPON_INFO,$data,false); |
|
| 67 | + $result = $this->post(self::URL_QUERY_COUPON_INFO, $data, false); |
|
| 68 | 68 | return $result; |
| 69 | 69 | } |
| 70 | 70 | |
@@ -36,8 +36,8 @@ discard block |
||
| 36 | 36 | * @param $ext array |
| 37 | 37 | * @return string |
| 38 | 38 | */ |
| 39 | - public function getPrepayId($body,$out_trade_no,$total_fee,$spbill_create_ip,$ext = null) { |
|
| 40 | - $data = ($ext && is_array($ext))?$ext:array(); |
|
| 39 | + public function getPrepayId($body, $out_trade_no, $total_fee, $spbill_create_ip, $ext = null) { |
|
| 40 | + $data = ($ext && is_array($ext)) ? $ext : array(); |
|
| 41 | 41 | $data["body"] = $body; |
| 42 | 42 | $data["out_trade_no"] = $out_trade_no; |
| 43 | 43 | $data["total_fee"] = $total_fee; |
@@ -62,7 +62,7 @@ discard block |
||
| 62 | 62 | $data["timestamp"] = time(); |
| 63 | 63 | $data["noncestr"] = $this->getNonceStr(); |
| 64 | 64 | $data["appid"] = $this->config["app_id"]; |
| 65 | - $data["sign"] = $this->sign($data); |
|
| 65 | + $data["sign"] = $this->sign($data); |
|
| 66 | 66 | return $data; |
| 67 | 67 | } |
| 68 | 68 | } |
| 69 | 69 | \ No newline at end of file |
@@ -8,7 +8,7 @@ discard block |
||
| 8 | 8 | namespace zhangv\wechat\pay\util; |
| 9 | 9 | |
| 10 | 10 | class WechatOAuth { |
| 11 | - const TICKETTYPE_JSAPI = 'jsapi',TICKETTYPE_WXCARD = 'wx_card'; |
|
| 11 | + const TICKETTYPE_JSAPI = 'jsapi', TICKETTYPE_WXCARD = 'wx_card'; |
|
| 12 | 12 | public $responseJSON = null; |
| 13 | 13 | public $errCode = null; |
| 14 | 14 | public $errMsg = null; |
@@ -18,46 +18,46 @@ discard block |
||
| 18 | 18 | private $httpClient = null; |
| 19 | 19 | private $accessToken = null; |
| 20 | 20 | |
| 21 | - public function __construct($appId,$appSecret) { |
|
| 21 | + public function __construct($appId, $appSecret) { |
|
| 22 | 22 | $this->appId = $appId; |
| 23 | 23 | $this->appSecret = $appSecret; |
| 24 | 24 | $this->httpClient = new HttpClient(); |
| 25 | 25 | } |
| 26 | 26 | |
| 27 | - public function setHttpClient($httpClient){ |
|
| 27 | + public function setHttpClient($httpClient) { |
|
| 28 | 28 | $this->httpClient = $httpClient; |
| 29 | 29 | } |
| 30 | 30 | |
| 31 | - public function authorizeURI($redirectURI,$scope = 'snsapi_userinfo',$state = ''){ |
|
| 31 | + public function authorizeURI($redirectURI, $scope = 'snsapi_userinfo', $state = '') { |
|
| 32 | 32 | $redirectURI = urlencode($redirectURI); |
| 33 | 33 | return "https://open.weixin.qq.com/connect/oauth2/authorize?appid={$this->appId}&redirect_uri={$redirectURI}&response_type=code&scope=$scope&state=$state#wechat_redirect"; |
| 34 | 34 | } |
| 35 | 35 | |
| 36 | - public function authorize($code){ |
|
| 36 | + public function authorize($code) { |
|
| 37 | 37 | $url = "https://api.weixin.qq.com/sns/oauth2/access_token?appid={$this->appId}&secret={$this->appSecret}&code=$code&grant_type=authorization_code"; |
| 38 | 38 | $this->responseJSON = $this->httpClient->get($url); |
| 39 | 39 | return json_decode($this->responseJSON); |
| 40 | 40 | } |
| 41 | 41 | |
| 42 | - public function getUserInfo($openId){ |
|
| 42 | + public function getUserInfo($openId) { |
|
| 43 | 43 | $url = "https://api.weixin.qq.com/sns/userinfo?access_token={$this->accessToken}&openid=$openId&lang=zh_CN"; |
| 44 | 44 | $this->responseJSON = $this->httpClient->get($url); |
| 45 | 45 | return json_decode($this->responseJSON); |
| 46 | 46 | } |
| 47 | 47 | |
| 48 | - public function refreshToken($refreshToken){ |
|
| 48 | + public function refreshToken($refreshToken) { |
|
| 49 | 49 | $url = "https://api.weixin.qq.com/sns/oauth2/refresh_token?appid={$this->appId}&grant_type=refresh_token&refresh_token=$refreshToken"; |
| 50 | 50 | $this->responseJSON = $this->httpClient->get($url); |
| 51 | 51 | return json_decode($this->responseJSON); |
| 52 | 52 | } |
| 53 | 53 | |
| 54 | - public function verifyToken($accessToken,$openId){ |
|
| 54 | + public function verifyToken($accessToken, $openId) { |
|
| 55 | 55 | $url = "https://api.weixin.qq.com/sns/auth?access_token=$accessToken&openid=$openId"; |
| 56 | 56 | $this->responseJSON = $this->httpClient->get($url); |
| 57 | 57 | return json_decode($this->responseJSON); |
| 58 | 58 | } |
| 59 | 59 | |
| 60 | - public function getAccessToken(){ |
|
| 60 | + public function getAccessToken() { |
|
| 61 | 61 | $url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={$this->appId}&secret={$this->appSecret}"; |
| 62 | 62 | $this->responseJSON = $this->httpClient->get($url); |
| 63 | 63 | $json = json_decode($this->responseJSON); |
@@ -65,27 +65,27 @@ discard block |
||
| 65 | 65 | return $this->accessToken; |
| 66 | 66 | } |
| 67 | 67 | |
| 68 | - public function getTicket($type = WechatOAuth::TICKETTYPE_JSAPI, $accessToken = null){ |
|
| 69 | - if(!$accessToken) $accessToken = $this->getAccessToken(); |
|
| 68 | + public function getTicket($type = WechatOAuth::TICKETTYPE_JSAPI, $accessToken = null) { |
|
| 69 | + if (!$accessToken) $accessToken = $this->getAccessToken(); |
|
| 70 | 70 | // $url = "https://qyapi.weixin.qq.com/cgi-bin/get_jsapi_ticket?access_token=$accessToken"; |
| 71 | 71 | $url = "https://api.weixin.qq.com/cgi-bin/ticket/getticket?type={$type}&access_token=$accessToken"; |
| 72 | 72 | $this->responseJSON = $this->httpClient->get($url); |
| 73 | 73 | return json_decode($this->responseJSON); |
| 74 | 74 | } |
| 75 | 75 | |
| 76 | - public function getSession($code){ |
|
| 76 | + public function getSession($code) { |
|
| 77 | 77 | $url = "https://api.weixin.qq.com/sns/jscode2session?appid={$this->appId}&secret={$this->appSecret}&js_code=$code&grant_type=authorization_code"; |
| 78 | 78 | $this->responseJSON = $this->httpClient->get($url); |
| 79 | 79 | return json_decode($this->responseJSON); |
| 80 | 80 | } |
| 81 | 81 | |
| 82 | - public function getSignPackage($url = null, $ticket = null){ |
|
| 83 | - if(!$url){ |
|
| 82 | + public function getSignPackage($url = null, $ticket = null) { |
|
| 83 | + if (!$url) { |
|
| 84 | 84 | $url = (!empty($_SERVER['HTTPS']) && $_SERVER['HTTPS'] !== 'off' || |
| 85 | 85 | (!empty($_SERVER['SERVER_PORT']) && $_SERVER['SERVER_PORT'] == 443)) ? "https://" : "http://"; |
| 86 | 86 | $url .= "{$_SERVER['HTTP_HOST']}{$_SERVER['REQUEST_URI']}"; |
| 87 | 87 | } |
| 88 | - if(!$ticket) $ticket = $this->getTicket(); |
|
| 88 | + if (!$ticket) $ticket = $this->getTicket(); |
|
| 89 | 89 | $timestamp = time(); |
| 90 | 90 | $nonceStr = $this->getNonceStr(); |
| 91 | 91 | $rawString = "jsapi_ticket=$ticket&noncestr=$nonceStr×tamp=$timestamp&url=$url"; |
@@ -103,6 +103,6 @@ discard block |
||
| 103 | 103 | } |
| 104 | 104 | |
| 105 | 105 | private function getNonceStr() { |
| 106 | - return substr(str_shuffle("abcdefghijklmnopqrstuvwxyz0123456789"),0,32); |
|
| 106 | + return substr(str_shuffle("abcdefghijklmnopqrstuvwxyz0123456789"), 0, 32); |
|
| 107 | 107 | } |
| 108 | 108 | } |
@@ -66,7 +66,9 @@ discard block |
||
| 66 | 66 | } |
| 67 | 67 | |
| 68 | 68 | public function getTicket($type = WechatOAuth::TICKETTYPE_JSAPI, $accessToken = null){ |
| 69 | - if(!$accessToken) $accessToken = $this->getAccessToken(); |
|
| 69 | + if(!$accessToken) { |
|
| 70 | + $accessToken = $this->getAccessToken(); |
|
| 71 | + } |
|
| 70 | 72 | // $url = "https://qyapi.weixin.qq.com/cgi-bin/get_jsapi_ticket?access_token=$accessToken"; |
| 71 | 73 | $url = "https://api.weixin.qq.com/cgi-bin/ticket/getticket?type={$type}&access_token=$accessToken"; |
| 72 | 74 | $this->responseJSON = $this->httpClient->get($url); |
@@ -85,7 +87,9 @@ discard block |
||
| 85 | 87 | (!empty($_SERVER['SERVER_PORT']) && $_SERVER['SERVER_PORT'] == 443)) ? "https://" : "http://"; |
| 86 | 88 | $url .= "{$_SERVER['HTTP_HOST']}{$_SERVER['REQUEST_URI']}"; |
| 87 | 89 | } |
| 88 | - if(!$ticket) $ticket = $this->getTicket(); |
|
| 90 | + if(!$ticket) { |
|
| 91 | + $ticket = $this->getTicket(); |
|
| 92 | + } |
|
| 89 | 93 | $timestamp = time(); |
| 90 | 94 | $nonceStr = $this->getNonceStr(); |
| 91 | 95 | $rawString = "jsapi_ticket=$ticket&noncestr=$nonceStr×tamp=$timestamp&url=$url"; |
@@ -7,9 +7,9 @@ discard block |
||
| 7 | 7 | */ |
| 8 | 8 | namespace zhangv\wechat\pay\util; |
| 9 | 9 | |
| 10 | -class HttpClient{ |
|
| 10 | +class HttpClient { |
|
| 11 | 11 | |
| 12 | - const GET = 'get',POST = 'post', DELETE = 'delete',PUT = 'put'; |
|
| 12 | + const GET = 'get', POST = 'post', DELETE = 'delete', PUT = 'put'; |
|
| 13 | 13 | private $instance = null; |
| 14 | 14 | private $errNo = null; |
| 15 | 15 | private $info = null; |
@@ -19,8 +19,8 @@ discard block |
||
| 19 | 19 | $this->initInstance($timeout); |
| 20 | 20 | } |
| 21 | 21 | |
| 22 | - public function initInstance($timeout){ |
|
| 23 | - if(!$this->instance) { |
|
| 22 | + public function initInstance($timeout) { |
|
| 23 | + if (!$this->instance) { |
|
| 24 | 24 | $this->instance = curl_init(); |
| 25 | 25 | curl_setopt($this->instance, CURLOPT_TIMEOUT, intval($timeout)); |
| 26 | 26 | curl_setopt($this->instance, CURLOPT_RETURNTRANSFER, true); |
@@ -29,26 +29,26 @@ discard block |
||
| 29 | 29 | } |
| 30 | 30 | } |
| 31 | 31 | |
| 32 | - public function get($url,$params = array(),$headers = array(),$opts = array()) { |
|
| 32 | + public function get($url, $params = array(), $headers = array(), $opts = array()) { |
|
| 33 | 33 | if (!$this->instance) $this->initInstance($this->timeout); |
| 34 | - if($params && count($params) > 0) $url .= '?' . http_build_query($params); |
|
| 34 | + if ($params && count($params) > 0) $url .= '?'.http_build_query($params); |
|
| 35 | 35 | curl_setopt($this->instance, CURLOPT_URL, $url); |
| 36 | 36 | curl_setopt($this->instance, CURLOPT_HTTPGET, true); |
| 37 | 37 | curl_setopt($this->instance, CURLOPT_HTTPHEADER, $headers); |
| 38 | - curl_setopt_array($this->instance,$opts); |
|
| 38 | + curl_setopt_array($this->instance, $opts); |
|
| 39 | 39 | $result = $this->execute(); |
| 40 | 40 | curl_close($this->instance); |
| 41 | 41 | $this->instance = null; |
| 42 | 42 | return $result; |
| 43 | 43 | } |
| 44 | 44 | |
| 45 | - public function post($url, $params = array(),$headers = array(),$opts = array()) { |
|
| 45 | + public function post($url, $params = array(), $headers = array(), $opts = array()) { |
|
| 46 | 46 | if (!$this->instance) $this->initInstance($this->timeout); |
| 47 | 47 | curl_setopt($this->instance, CURLOPT_URL, $url); |
| 48 | 48 | curl_setopt($this->instance, CURLOPT_POST, true); |
| 49 | 49 | curl_setopt($this->instance, CURLOPT_POSTFIELDS, $params); |
| 50 | 50 | curl_setopt($this->instance, CURLOPT_HTTPHEADER, $headers); |
| 51 | - curl_setopt_array($this->instance,$opts); |
|
| 51 | + curl_setopt_array($this->instance, $opts); |
|
| 52 | 52 | $result = $this->execute(); |
| 53 | 53 | curl_close($this->instance); |
| 54 | 54 | $this->instance = null; |
@@ -62,7 +62,7 @@ discard block |
||
| 62 | 62 | return $result; |
| 63 | 63 | } |
| 64 | 64 | |
| 65 | - public function getInfo(){ |
|
| 65 | + public function getInfo() { |
|
| 66 | 66 | return $this->info; |
| 67 | 67 | } |
| 68 | 68 | } |
| 69 | 69 | \ 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); |