@@ -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"]; |
@@ -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 | } |
@@ -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"]; |
@@ -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 | } |
@@ -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 |
@@ -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 | } |