topnuomi
/
TOP-Framework-WeChat
mirror of https://gitee.com/topnuomi/TOP-Framework-WeChat
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Upload

This commit is contained in:
TOP糯米 2019-07-10 20:56:29 +08:00
parent 36b36774ba
commit 441645115c
4 changed files with 322 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
Index.php Normal file
View File

@ -0,0 +1,22 @@
<?php
namespace app\home\controller;
use top\blocks\Json;
use top\library\Register;
use top\extend\wechat\WeChatAPI;
class Index extends Common
{
use Json;
public function index()
{
$config = Register::get('Config')->get('wechat');
$wechat = new WeChatAPI($config);
$info = $wechat->getUserInfo();
return [
'userinfo' => $info
];
}
}

218
wechat/WeChatAPI.php Normal file
View File

@ -0,0 +1,218 @@
<?php
namespace top\extend\wechat;
/**
* 微信API
* Class WeChatAPI
* @package top\extend\wechat
*/
class WeChatAPI
{
/**
* @var null|string 当前页面的URL
*/
private $url = null;
/**
* @var null 错误信息
*/
private $error = null;
/**
* @var string 获取ACCESS_TOKEN的接口
*/
private $accessTokenAPI = 'https://api.weixin.qq.com/cgi-bin/token?';
/**
* @var string 获取OAuth ACCESS_TOKEN的接口
*/
private $oauthAccessTokenAPI = 'https://api.weixin.qq.com/sns/oauth2/access_token?';
/**
* @var string 获取CODE的接口
*/
private $codeAPI = 'https://open.weixin.qq.com/connect/oauth2/authorize?';
/**
* @var string 拉取用户信息接口
*/
private $userinfoAPI = 'https://api.weixin.qq.com/sns/userinfo?';
/**
* @var string 拉取用户信息接口（UnionID机制）
*/
private $userinfoUnionIdAPI = 'https://api.weixin.qq.com/cgi-bin/user/info?';
/**
* @var string 自定义菜单创建接口
*/
private $menuAPI = 'https://api.weixin.qq.com/cgi-bin/menu/create';
/**
* @var array 微信配置
*/
private $config = [];
public function __construct($config = [])
{
$this->url = $_SERVER['REQUEST_SCHEME'] . '://' . $_SERVER['SERVER_NAME'] . $_SERVER['REQUEST_URI'];
$this->config = $config;
}
/**
* 获取ACCESS_TOKEN
* @return bool|mixed
*/
private function getAccessToken()
{
$file = './access_token.json';
if (file_exists($file)) {
$content = file_get_contents($file);
$result = json_decode($content, true);
$expires = $result['expires_in'] - (time() - filemtime($file));
if ($expires <= 5) {
@unlink($file);
return $this->getAccessToken();
}
} else {
$api = $this->accessTokenAPI . "grant_type=client_credential&appid={$this->config['appid']}&secret={$this->config['appsecret']}";
$json = create_http_request($api);
$result = json_decode($json, true);
if (isset($result['errcode']) && $result['errcode'] != 0) {
throw new WeChatAPIException('code:' . $result['errcode'] . ',' . $result['errmsg']);
}
file_put_contents($file, $json);
}
return $result;
}
/**
* 获取CODE
* @param $scope
*/
private function getCode($scope)
{
$redirect = $this->url;
$api = $this->codeAPI . "appid={$this->config['appid']}&redirect_uri={$redirect}&response_type=code&scope={$scope}&state=0#wechat_redirect";
header('location:' . $api);
}
/**
* 获取OAuth的ACCESS_TOKEN
* @param string $scope
* @return bool|mixed|void
*/
private function getOAuthAccessToken($scope = 'snsapi_base')
{
$file = './oauth_access_token.json';
if (file_exists($file)) {
$content = file_get_contents($file);
$result = json_decode($content, true);
$expires = $result['expires_in'] - (time() - filemtime($file));
if ($expires <= 5) {
@unlink($file);
return $this->getOAuthAccessToken();
}
} else {
$code = isset($_GET['code']) ? $_GET['code'] : null;
if (!$code) {
return $this->getCode($scope);
}
$api = $this->oauthAccessTokenAPI . "appid={$this->config['appid']}&secret={$this->config['appsecret']}&code={$code}&grant_type=authorization_code";
$json = create_http_request($api);
$result = json_decode($json, true);
if (isset($result['errcode']) && $result['errcode'] != 0) {
throw new WeChatAPIException('code:' . $result['errcode'] . ',' . $result['errmsg']);
}
file_put_contents($file, $json);
}
return $result;
}
/**
* 拉取用户信息
* @param string $openid
* @return bool|mixed
*/
public function getUserInfo($openid = null)
{
$postData = [];
if ($openid) {
$accessToken = $this->getAccessToken();
if (is_array($openid)) {
$postData = [
'user_list' => $openid
];
$api = $this->userinfoUnionIdAPI . "access_token={$accessToken['access_token']}";
} else {
$api = $this->userinfoUnionIdAPI . "access_token={$accessToken['access_token']}&openid={$openid}&lang=zh_CN";
}
} else {
$accessToken = $this->getOAuthAccessToken('snsapi_userinfo');
$api = $this->userinfoAPI . "access_token={$accessToken['access_token']}&openid={$accessToken['openid']}&lang=zh_CN";
}
$json = create_http_request($api, json_encode($postData));
$result = json_decode($json, true);
if (isset($result['errcode']) && $result['errcode'] != 0) {
$this->error = 'code:' . $result['errcode'] . ',' . $result['errmsg'];
return false;
}
return $result;
}
/**
* 创建公众号菜单
* $menu数据示例
* [
* [
* 'type' => 'view',
* 'name' => 'TOP糯米',
* 'url' => 'https://www.topnuomi.com/'
* ],
* [
* 'name' => '测试多级',
* 'sub_button' => [
* [
* 'type' => 'view',
* 'name' => '我的主页',
* 'url' => 'https://topnuomi.com/'
* ],
* [
* 'type' => 'click',
* 'name' => '点击',
* 'key' => 'V1001_TODAY_MUSIC'
* ]
* ]
* ]
* ]
* @param array $menu
* @return bool
*/
public function createMenu($menu = [])
{
$accessToken = $this->getAccessToken();
$api = $this->menuAPI . "?access_token={$accessToken['access_token']}";
$menu = json_encode([
'button' => $menu
], JSON_UNESCAPED_UNICODE);
$json = create_http_request($api, $menu);
$result = json_decode($json, true);
if (isset($result['errcode']) && $result['errcode'] != 0) {
$this->error = 'code:' . $result['errcode'] . ',' . $result['errmsg'];
return false;
}
return true;
}
/**
* 获取错误信息
* @return null
*/
public function getError()
{
return $this->error;
}
}

8
wechat/WeChatAPIException.php Normal file
View File

@ -0,0 +1,8 @@
<?php
namespace top\extend\wechat;
class WeChatAPIException extends \Exception
{
}

74
wechat/token/WeChatCallbackAPITest.php Normal file
View File

@ -0,0 +1,74 @@
<?php
namespace top\extend\wechat\token;
class WeChatCallbackAPITest
{
private $token = null;
public function valid()
{
$echoStr = $_GET["echostr"];
//valid signature , option
if ($this->checkSignature()) {
echo $echoStr;
exit;
}
}
public function setToken($token)
{
$this->token = $token;
return $this;
}
public function responseMsg()
{
//get post data, May be due to the different environments
$postStr = $GLOBALS["HTTP_RAW_POST_DATA"];
//extract post data
if (!empty($postStr)) {
$postObj = simplexml_load_string($postStr, 'SimpleXMLElement', LIBXML_NOCDATA);
$fromUsername = $postObj->FromUserName;
$toUsername = $postObj->ToUserName;
$keyword = trim($postObj->Content);
$time = time();
$textTpl = "<xml>
<ToUserName><![CDATA[%s]]></ToUserName>
<FromUserName><![CDATA[%s]]></FromUserName>
<CreateTime>%s</CreateTime>
<MsgType><![CDATA[%s]]></MsgType>
<Content><![CDATA[%s]]></Content>
<FuncFlag>0</FuncFlag>
</xml>";
if (!empty($keyword)) {
$msgType = "text";
$contentStr = "Welcome to wechat world!";
$resultStr = sprintf($textTpl, $fromUsername, $toUsername, $time, $msgType, $contentStr);
echo $resultStr;
} else {
echo "Input something...";
}
} else {
echo "";
exit;
}
}
private function checkSignature()
{
$signature = $_GET["signature"];
$timestamp = $_GET["timestamp"];
$nonce = $_GET["nonce"];
$token = $this->token;
$tmpArr = array($token, $timestamp, $nonce);
sort($tmpArr);
$tmpStr = implode($tmpArr);
$tmpStr = sha1($tmpStr);
if ($tmpStr == $signature) {
return true;
} else {
return false;
}
}
}