97 lines
3.4 KiB
PHP
97 lines
3.4 KiB
PHP
<?php
|
|
|
|
namespace app\utils;
|
|
|
|
use app\constant\ResponseCode;
|
|
use GuzzleHttp\Client;
|
|
use support\Cache;
|
|
use think\Exception;
|
|
|
|
class WechatUtil
|
|
{
|
|
const GENERAL_ACCESS_TOKEN = 'general_access_token';
|
|
const CODE_ACCESS_TOKEN = 'code_access_token';
|
|
const BASE_URI = 'https://api.weixin.qq.com';
|
|
|
|
/**
|
|
* @desc 获取access token
|
|
* @return array|mixed|void
|
|
* @throws \GuzzleHttp\Exception\GuzzleException
|
|
*/
|
|
public static function getAccessToken()
|
|
{
|
|
try {
|
|
// $str = '83_0jVm82U7ri-UENTGoTTFh2jowRpAN379ahJvK_3HpLPbdIheIr-ahgYhc5kkHv6dDYyaHklwqffKRQYOxURrQ-H8xq8kYvjoajYZQBNFhMCaBJs0VOU4PE5_-bYPUXfAAAXCF';
|
|
// Cache::set(self::GENERAL_ACCESS_TOKEN, $str, 3500);
|
|
// Cache::delete(self::GENERAL_ACCESS_TOKEN);
|
|
if (Cache::has(self::GENERAL_ACCESS_TOKEN)) {
|
|
return Cache::get(self::GENERAL_ACCESS_TOKEN);
|
|
} else {
|
|
$client = new Client(['base_uri' => self::BASE_URI]);
|
|
$response = $client->request('post', 'cgi-bin/stable_token', [
|
|
'json' => [
|
|
'grant_type' => 'client_credential',
|
|
'appid' => getenv('APP_ID'),
|
|
'secret' => getenv('APP_SECRET'),
|
|
]
|
|
]);
|
|
$response_contents = $response->getBody()->getContents();
|
|
raw_log('wechat/access_token', ['result' => $response_contents]);
|
|
if ($response->getStatusCode() == 200) {
|
|
$result = json_decode($response_contents, true);
|
|
raw_log('wechat/access_token', ['result' => $result]);
|
|
if (isset($result['errcode'])) {
|
|
throw new Exception($result['errmsg']);
|
|
}
|
|
Cache::set(self::GENERAL_ACCESS_TOKEN, $result['access_token'], $result['expires_in'] - 60);
|
|
|
|
return $result['access_token'];
|
|
}
|
|
}
|
|
} catch (Exception $e) {
|
|
return [
|
|
'code' => ResponseCode::FAIL,
|
|
'msg' => $e->getMessage()
|
|
];
|
|
}
|
|
}
|
|
|
|
/**
|
|
* @desc 获取网页授权code的access_token
|
|
* @param $code
|
|
* @return array|void
|
|
* @throws \GuzzleHttp\Exception\GuzzleException
|
|
*/
|
|
public static function getCodeAccessToken($code)
|
|
{
|
|
try {
|
|
$client = new Client(['base_uri'=>self::BASE_URI]);
|
|
$response = $client->request('get', 'sns/oauth2/access_token', [
|
|
'query' => [
|
|
'appid' => getenv('APPID'),
|
|
'secret' => getenv('APPSECRET'),
|
|
'code'=>$code,
|
|
'grant_type'=>'authorization_code'
|
|
]
|
|
]);
|
|
|
|
$response_contents = $response->getBody()->getContents();
|
|
raw_log('wechat/code_access_token', ['result' => $response_contents]);
|
|
if ($response->getStatusCode() == 200) {
|
|
$result = json_decode($response_contents, true);
|
|
raw_log('wechat/code_access_token', ['result' => $result]);
|
|
if (isset($result['errcode'])) {
|
|
throw new Exception($result['errmsg']);
|
|
}
|
|
return $result;
|
|
}
|
|
|
|
}catch (Exception $e){
|
|
return [
|
|
'code'=>ResponseCode::FAIL,
|
|
'msg'=>$e->getMessage()
|
|
];
|
|
}
|
|
}
|
|
|
|
} |