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

更改中间件

This commit is contained in:
TOP糯米 2019-07-19 16:07:39 +08:00
parent b94686b976
commit 7a1647e220
12 changed files with 573 additions and 123 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
application/home/config/config.php
View File

@ -5,7 +5,7 @@ return [
// 'Smarty' => \top\library\template\driver\Smarty::class,
'Top' => \top\library\template\driver\Top::class,
],
'decorator' => [],
'middleware' => [],
'session' => [
'open' => true,
'prefix' => 'home',

0
application/home/decorator/index.html → application/home/middleware/index.html
View File

360
framework/extend/wechat/WeChatAPI.php Normal file
View File

@ -0,0 +1,360 @@
<?php
namespace top\extend\wechat;
/**
* 微信API
* Class WeChatAPI
* @package top\extend\wechat
* @author TOP糯米
*/
class WeChatAPI
{
/**
* @var null|string 当前页面的URL
*/
private $url = null;
/**
* @var null 错误信息
*/
private $error = null;
/**
* @var array 微信配置
*/
private $config = [];
/**
* @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';
/**
* @var string 获取自定义菜单配置接口
*/
private $currentSelfmenuAPI = 'https://api.weixin.qq.com/cgi-bin/get_current_selfmenu_info?';
/**
* @var string 模版消息接口
*/
private $templateAPI = 'https://api.weixin.qq.com/cgi-bin/template/';
/**
* @var string 语言
*/
private $lang = null;
public function __construct($config = [], $lang = null)
{
$this->url = $_SERVER['REQUEST_SCHEME'] . '://' . $_SERVER['SERVER_NAME'] . $_SERVER['REQUEST_URI'];
$this->config = $config;
$this->lang = $lang ? $lang : 'zh_CN';
}
/**
* 获取access_token
* @return mixed
* @throws WeChatAPIException
*/
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();
}
return $result;
} else {
$api = $this->accessTokenAPI . "grant_type=client_credential&appid={$this->config['appid']}";
$api .= "&secret={$this->config['appsecret']}";
$result = $this->createHttpRequest($api, null, true);
file_put_contents($file, $result[0]);
return $result[1];
}
}
/**
* 获取CODE
* @param $scope
*/
private function getCode($scope)
{
$redirect = $this->url;
$api = $this->codeAPI . "appid={$this->config['appid']}&redirect_uri={$redirect}";
$api .= "&response_type=code&scope={$scope}&state=0#wechat_redirect";
exit(header('location:' . $api));
}
/**
* 获取OAuth的access_token
* @param string $scope
* @return mixed
* @throws WeChatAPIException
*/
private function getOAuthAccessToken($scope = 'snsapi_base')
{
if (isset($_SESSION['oauth_access_token']) && !empty($_SESSION['oauth_access_token'])) {
$session = $_SESSION['oauth_access_token'];
$content = $session['content'];
$result = json_decode($content, true);
$expires = $result['expires_in'] - (time() - $session['time']);
if ($expires <= 5) {
unset($_SESSION['oauth_access_token']);
return $this->getOAuthAccessToken();
}
return $result;
} else {
$code = isset($_GET['code']) ? $_GET['code'] : null;
if (!$code) {
$this->getCode($scope);
}
$api = $this->oauthAccessTokenAPI . "appid={$this->config['appid']}";
$api .= "&secret={$this->config['appsecret']}&code={$code}&grant_type=authorization_code";
$result = $this->createHttpRequest($api, null, true);
$_SESSION['oauth_access_token'] = [
'time' => time(),
'content' => $result[0]
];
return $result[1];
}
}
/**
* 拉取用户信息
* @param null $openid
* @return bool|mixed
* @throws WeChatAPIException
*/
public function getUserInfo($openid = null)
{
$postData = [];
if ($openid) {
$accessToken = $this->getAccessToken();
$api = $this->userinfoUnionIdAPI . "access_token={$accessToken['access_token']}";
if (is_array($openid)) {
$postData = json_encode([
'user_list' => $openid
]);
} else {
$api .= "&openid={$openid}&lang={$this->lang}";
}
} else {
$accessToken = $this->getOAuthAccessToken('snsapi_userinfo');
$api = $this->userinfoAPI . "access_token={$accessToken['access_token']}";
$api .= "&openid={$accessToken['openid']}&lang={$this->lang}";
}
$result = $this->createHttpRequest($api, $postData);
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
* @param array $matchrule
* @return bool
* @throws WeChatAPIException
*/
public function createMenu($menu = [], $matchrule = [])
{
// 公众号菜单
$menu = [
'button' => $menu
];
// 个性化菜单
$matchrule = (!empty($matchrule)) ? [
'matchrule' => $matchrule
] : [];
$menu = array_merge($menu, $matchrule);
$menuJson = json_encode($menu, JSON_UNESCAPED_UNICODE);
$type = (!empty($matchrule)) ? 'addconditional' : 'create';
return $this->menuAction($type, $menuJson);
}
/**
* 获取公众号菜单
* @return mixed
* @throws WeChatAPIException
*/
public function getMenu()
{
return $this->menuAction('get');
}
/**
* 删除公众号自定义菜单
* @return mixed
* @throws WeChatAPIException
*/
public function deleteMenu($menuid = null)
{
$json = null;
if ($menuid) {
$json = json_encode([
'menuid' => $menuid
]);
}
$type = ($menuid) ? 'delconditional' : 'delete';
return $this->menuAction($type, $json, $menuid);
}
/**
* 公众号菜单的基础操作
* @param null $type
* @param null $postData
* @return bool|mixed
* @throws WeChatAPIException
*/
private function menuAction($type = null, $postData = null, $menuid = null)
{
$typePool = ['create', 'get', 'delete', 'addconditional', 'delconditional'];
if (in_array($type, $typePool)) {
$accessToken = $this->getAccessToken();
$api = $this->menuAPI . "/{$type}?access_token={$accessToken['access_token']}";
$result = $this->createHttpRequest($api, $postData);
return ($type == 'get' || $type == 'addconditional') ? $result : true;
} else {
throw new WeChatAPIException('对公众号菜单的操作不在允许列表');
}
}
/**
* 获取自定义菜单配置
* @return mixed
* @throws WeChatAPIException
*/
public function getCurrentSelfmenuInfo()
{
$accessToken = $this->getAccessToken();
$api = $this->currentSelfmenuAPI . "access_token={$accessToken['access_token']}";
$result = $this->createHttpRequest($api);
return $result;
}
/**
* 设置所属行业
* post数据示例
* {
* "industry_id1":"1",
* "industry_id2":"4"
* }
* @param $id1
* @param $id2
* @return bool
* @throws WeChatAPIException
*/
public function setIndustry($id1, $id2)
{
$accessToken = $this->getAccessToken();
$api = $this->templateAPI . "api_set_industry?access_token={$accessToken['access_token']}";
$postData = json_encode([
'industry_id1' => $id1,
'industry_id2' => $id2
]);
$this->createHttpRequest($api, $postData);
return true;
}
/**
* 获取设置的行业信息
* @return mixed
*/
public function getIndustry()
{
$accessToken = $this->getAccessToken();
$api = $this->templateAPI . "get_industry?access_token={$accessToken['access_token']}";
$result = $this->createHttpRequest($api);
return $result;
}
/**
* 获取模板列表
* @return mixed
*/
public function getTemplateList()
{
$accessToken = $this->getAccessToken();
$api = $this->templateAPI . "get_all_private_template?access_token={$accessToken['access_token']}";
$result = $this->createHttpRequest($api);
return $result;
}
/**
* 创建HTTP请求
* @param $api
* @param array $data
* @param bool $includeJson
* @return mixed
*/
private function createHttpRequest($api, $data = [], $includeJson = false)
{
$json = create_http_request($api, $data);
$result = json_decode($json, true);
if (isset($result['errcode']) && $result['errcode'] != 0) {
throw new WeChatAPIException("code:{$result['errcode']}, {$result['errmsg']}");
}
return ($includeJson) ? [$json, $result] : $result;
}
/**
* 获取错误信息
* @return null
*/
public function getError()
{
return $this->error;
}
}

8
framework/extend/wechat/WeChatAPIException.php Normal file
View File

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

74
framework/extend/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;
}
}
}

8
framework/library/exception/RequestException.php Normal file
View File

@ -0,0 +1,8 @@
<?php
namespace top\library\exception;
class RequestException extends BaseException
{
}

225
framework/library/http/Request.php
View File

@ -2,9 +2,8 @@
namespace top\library\http;
use top\decorator\ifs\DecoratorIfs;
use top\decorator\InitDecorator;
use top\library\exception\RequestException;
use top\middleware\ifs\MiddlewareIfs;
use top\middleware\Init;
use top\library\Register;
use top\library\route\driver\Command;
use top\library\route\driver\Pathinfo;
@ -30,10 +29,10 @@ class Request
private $server = [];
/**
* 装饰器
* 中间件
* @var array
*/
private $decorator = [];
private $middleware = [];
/**
* 路由实例
@ -66,7 +65,7 @@ class Request
private $params = [];
/**
* post、get数据移除的值
* post、get数据删除的值
* @var array
*/
private $except = [];
@ -240,113 +239,6 @@ class Request
return $this->router->params;
}
/**
* 指定装饰器
* @param DecoratorIfs $decorator
*/
private function decorator(DecoratorIfs $decorator)
{
$this->decorator[] = $decorator;
}
/**
* 装饰器前置方法
*/
private function beforeRoute()
{
foreach ($this->decorator as $decorator) {
$decorator->before();
}
}
/**
* 装饰器后置方法
* @param $data
*/
private function afterRoute($data)
{
$this->decorator = array_reverse($this->decorator);
foreach ($this->decorator as $decorator) {
$decorator->after($data);
}
}
/**
* 指定路由驱动
* @param $type
* @return string|Command|Pathinfo
*/
private function routeDriver($type)
{
$routeDriver = '';
if (php_sapi_name() == 'cli') {
// 命令行运行程序
$routeDriver = new Command();
} else {
// 其他方式
switch ($type) {
case 1:
$routeDriver = new Pathinfo();
break;
default:
// 其他
}
}
return $routeDriver;
}
/**
* 设置路由并执行程序
* @param $type
* @param $defaultModule
* @return mixed
* @throws \top\library\exception\RouteException
*/
public function execute($type, $defaultModule)
{
// 实例化路由，并执行对应方法
$routeDriver = $this->routeDriver($type);
$this->router = (new Router($routeDriver, $defaultModule))->handler();
$data = $this->runAction();
return $data;
}
/**
* 调用对应方法
* @return mixed
* @throws \ReflectionException
*/
private function runAction()
{
$userDecorators = Register::get('Config')->get('decorator');
$systemDecorators = [InitDecorator::class];
$decorators = array_merge($systemDecorators, $userDecorators);
foreach ($decorators as $key => $value) {
$this->decorator(new $value());
}
$this->beforeRoute();
$ctrl = $this->router->class;
$method = $this->router->method;
$params = $this->router->params;
$object = new $ctrl();
$reflectionClass = new \ReflectionClass($ctrl);
if ($reflectionClass->hasMethod('_init')) {
$data = $object->_init();
}
if (!isset($data)) {
$reflectionMethod = new \ReflectionMethod($ctrl, $method);
$data = $reflectionMethod->invokeArgs($object, $params);
}
$this->afterRoute($data);
return $data;
}
/**
* 移除值
* @param $field
@ -426,6 +318,113 @@ class Request
}
}
/**
* 设置中间件
* @param MiddlewareIfs $middleware
*/
private function middleware(MiddlewareIfs $middleware)
{
$this->middleware[] = $middleware;
}
/**
* 中间件前置方法
*/
private function beforeRoute()
{
foreach ($this->middleware as $middleware) {
$middleware->before();
}
}
/**
* 中间件后置方法
* @param $data
*/
private function afterRoute($data)
{
$this->middleware = array_reverse($this->middleware);
foreach ($this->middleware as $middleware) {
$middleware->after($data);
}
}
/**
* 指定路由驱动
* @param $type
* @return string|Command|Pathinfo
*/
private function routeDriver($type)
{
$routeDriver = '';
if (php_sapi_name() == 'cli') {
// 命令行运行程序
$routeDriver = new Command();
} else {
// 其他方式
switch ($type) {
case 1:
$routeDriver = new Pathinfo();
break;
default:
// 其他
}
}
return $routeDriver;
}
/**
* 设置路由并执行程序
* @param $type
* @param $defaultModule
* @return mixed
* @throws \top\library\exception\RouteException
*/
public function execute($type, $defaultModule)
{
// 实例化路由，并执行对应方法
$routeDriver = $this->routeDriver($type);
$this->router = (new Router($routeDriver, $defaultModule))->handler();
$data = $this->runAction();
return $data;
}
/**
* 调用对应方法
* @return mixed
* @throws \ReflectionException
*/
private function runAction()
{
$userMiddleware = Register::get('Config')->get('middleware');
$systemMiddleware = [Init::class];
$middleware = array_merge($systemMiddleware, $userMiddleware);
foreach ($middleware as $key => $value) {
$this->middleware(new $value());
}
$this->beforeRoute();
$ctrl = $this->router->class;
$method = $this->router->method;
$params = $this->router->params;
$object = new $ctrl();
$reflectionClass = new \ReflectionClass($ctrl);
if ($reflectionClass->hasMethod('_init')) {
$data = $object->_init();
}
if (!isset($data)) {
$reflectionMethod = new \ReflectionMethod($ctrl, $method);
$data = $reflectionMethod->invokeArgs($object, $params);
}
$this->afterRoute($data);
return $data;
}
public function __destruct()
{
}

5
framework/library/route/driver/Pathinfo.php
View File

@ -119,7 +119,7 @@ class Pathinfo implements RouteIfs
unset($this->uriArray[0], $this->uriArray[1], $this->uriArray[2]);
$this->uriArray = array_merge($this->uriArray, []);
if (!empty($this->uriArray) && class_exists($this->class)) {
$paramName = (new \ReflectionMethod($this->class, $this->action))->getParameters();
$paramName = (new \ReflectionMethod($this->class, $this->method))->getParameters();
$paramNameArray = [];
for ($i = 0; $i < count($paramName); $i++) {
$paramNameArray[$paramName[$i]->name] = '';
@ -127,7 +127,7 @@ class Pathinfo implements RouteIfs
$params = [];
for ($i = 0; $i < count($this->uriArray); $i = $i + 2) {
if (isset($this->uriArray[$i + 1]) && $this->uriArray[$i + 1] != '') {
$_GET[$this->uriArray[$i]] = $this->uriArray[$i + 1];
// $_GET[$this->uriArray[$i]] = $this->uriArray[$i + 1];
if (isset($paramNameArray[$this->uriArray[$i]])) {
$params[$this->uriArray[$i]] = $this->uriArray[$i + 1];
}
@ -150,6 +150,7 @@ class Pathinfo implements RouteIfs
$uri = ($pathinfo != '') ? $pathinfo : $this->default;
} else {
$uri = isset($_GET['s']) ? ltrim($_GET['s'], '/') : $this->default;
unset($_GET['s']);
}
$uri = str_replace('.html', '', $uri);
$this->rawUri = $uri;

10
framework/decorator/InitDecorator.php → framework/middleware/Init.php
View File

@ -1,18 +1,18 @@
<?php
namespace top\decorator;
namespace top\middleware;
use top\decorator\ifs\DecoratorIfs;
use top\middleware\ifs\MiddlewareIfs;
use top\library\Register;
use top\library\View;
use top\library\cache\FileCache;
use top\library\cache\File;
/**
* 初始化
*
* @author topnuomi 2018年11月20日
*/
class InitDecorator implements DecoratorIfs
class Init implements MiddlewareIfs
{
/**
@ -36,7 +36,7 @@ class InitDecorator implements DecoratorIfs
// 视图文件缓存
/*Register::set('ViewCache', function () {
return FileCache::instance();
return File::instance();
});*/
// 配置文件中配置的注册

4
framework/decorator/ifs/DecoratorIfs.php → framework/middleware/ifs/MiddlewareIfs.php
View File

@ -1,13 +1,13 @@
<?php
namespace top\decorator\ifs;
namespace top\middleware\ifs;
/**
* 默认装饰器接口
*
* @author topnuomi 2018年11月22日
*/
interface DecoratorIfs
interface MiddlewareIfs
{
/**

0
framework/decorator/ifs/index.html → framework/middleware/ifs/index.html
View File

0
framework/decorator/index.html → framework/middleware/index.html
View File