扩展hook,快速钩子

浏览:2575 发布日期:2017/07/21 分类:功能实现
在钩子中实现要拦截的内容,不用再控制器中实现,不更改原有代码。大神勿喷
大神勿喷。
实现方法:
1.tags.php写入以下代码return array(
 'app_begin' => array('Behavior\CheckLangBehavior'),
    'action_begin' => array('Common\Behaviors\PlugsBehaviors'),
    'view_begin' => array('Common\Behaviors\PlugsBehaviors'),
    'view_parse' => array('Common\Behaviors\PlugsBehaviors'),
    'template_filter' => array('Common\Behaviors\PlugsBehaviors'),
    'view_filter' => array('Common\Behaviors\PlugsBehaviors'),
    'view_end' => array('Common\Behaviors\PlugsBehaviors'),
    'action_end' => array('Common\Behaviors\PlugsBehaviors'),
    'app_end' => array('Common\Behaviors\PlugsBehaviors'),
    'app_begin' => array('Common\Behaviors\PlugsBehaviors'),);
目的:集成所有系统调用的拦截器。不用再进行手动注册拦截器以及拦截方案。
2.在Common\Behaviors\建立三个文件
1.Controller.class.php 请勿继承controller的基础类<?php

/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */

namespace Common\Behaviors;

/**
 * Description of ThinkController
 *
 * @author Administrator
 */
class Controller {

    /**
     * 使用模版文件 默认不使用,如果使用请在声明的时候注明
     * @var type 
     */
    protected $__layout = '';

    /**
     * 视图实例对象
     * @var view
     * @access protected
     */
    protected $view = null;

    /**
     * 控制器参数
     * @var config
     * @access protected
     */
    protected $config = array();
    protected $route = '';

    /**
     * 架构函数 取得模板对象实例
     * @access public
     */
    public function __construct() {
        //实例化视图类
        $this->view = \Think\Think::instance('Think\View');
        //控制器初始化
        if (method_exists($this, '_initialize'))
            $this->_initialize();

        if (strtolower($this->route) == 'admin') {
            if (!session('Adminusername')) {
                $this->error('请登录后进行', U('Admin/Login/Index'));
                exit;
            }
        } elseif (strtolower($this->route) == 'user') {
            if (!session('uid')) {
                $this->error('请登录后进行', U('User/Login/Index'));
                exit;
            }
        }
    }

    /**
     * 模板显示 调用内置的模板引擎显示方法,
     * @access protected
     * @param string $templateFile 指定要调用的模板文件
     * 默认为空 由系统自动定位模板文件
     * @param string $charset 输出编码
     * @param string $contentType 输出类型
     * @param string $content 输出内容
     * @param string $prefix 模板缓存前缀
     * @return void
     */
    protected function display($templateFile = '', $charset = '', $contentType = '', $content = '', $prefix = '') {
        layout((!$this->__layout ? FALSE : $this->__layout));
        $plugs_name = explode('\\', get_called_class())[1];
        $controller = $GLOBALS['hook'][$plugs_name]['ctr'] ? $GLOBALS['hook'][$plugs_name]['ctr'] : CONTROLLER_NAME;
        $act = $GLOBALS['hook'][$plugs_name]['act'] ? $GLOBALS['hook'][$plugs_name]['act'] : ACTION_NAME;
        define('THEME_PATH', './App/Plugs/' . $plugs_name . '/View/');
        $v_layer = C("DEFAULT_V_LAYER");
        if ($templateFile == '') {
            $templateFile = $controller . '/' . $act;
        }
        $this->assign('plugs_static', $_SERVER['REQUEST_SCHEME'] . '://' . $_SERVER['HTTP_HOST'] . '/' . APP_PATH . 'Plugs/Static/');
        $this->view->display($templateFile, $charset, $contentType, $content, $prefix);
        exit;
    }

    /**
     * 输出内容文本可以包括Html 并支持内容解析
     * @access protected
     * @param string $content 输出内容
     * @param string $charset 模板输出字符集
     * @param string $contentType 输出类型
     * @param string $prefix 模板缓存前缀
     * @return mixed
     */
    protected function show($content, $charset = '', $contentType = '', $prefix = '') {
        $this->view->display('', $charset, $contentType, $content, $prefix);
    }

    /**
     *  获取输出页面内容
     * 调用内置的模板引擎fetch方法,
     * @access protected
     * @param string $templateFile 指定要调用的模板文件
     * 默认为空 由系统自动定位模板文件
     * @param string $content 模板输出内容
     * @param string $prefix 模板缓存前缀* 
     * @return string
     */
    protected function fetch($templateFile = '', $content = '', $prefix = '') {
        return $this->view->fetch($templateFile, $content, $prefix);
    }

    /**
     * 模板主题设置
     * @access protected
     * @param string $theme 模版主题
     * @return Action
     */
    protected function theme($theme) {
        $this->view->theme($theme);
        return $this;
    }

    /**
     * 模板变量赋值
     * @access protected
     * @param mixed $name 要显示的模板变量
     * @param mixed $value 变量的值
     * @return Action
     */
    protected function assign($name, $value = '') {
        $this->view->assign($name, $value);
        return $this;
    }

    public function __set($name, $value) {
        $this->assign($name, $value);
    }

    /**
     * 取得模板显示变量的值
     * @access protected
     * @param string $name 模板显示变量
     * @return mixed
     */
    public function get($name = '') {
        return $this->view->get($name);
    }

    public function __get($name) {
        return $this->get($name);
    }

    /**
     * 检测模板变量的值
     * @access public
     * @param string $name 名称
     * @return boolean
     */
    public function __isset($name) {
        return $this->get($name);
    }

    /**
     * 魔术方法 有不存在的操作的时候执行
     * @access public
     * @param string $method 方法名
     * @param array $args 参数
     * @return mixed
     */
    public function __call($method, $args) {
        if (0 === strcasecmp($method, ACTION_NAME . C('ACTION_SUFFIX'))) {
            if (method_exists($this, '_empty')) {
                // 如果定义了_empty操作 则调用
                $this->_empty($method, $args);
            } elseif (file_exists_case($this->view->parseTemplate())) {
                // 检查是否存在默认模版 如果有直接输出模版
                $this->display();
            } else {
                E(L('_ERROR_ACTION_') . ':' . ACTION_NAME);
            }
        } else {
            E(__CLASS__ . ':' . $method . L('_METHOD_NOT_EXIST_'));
            return;
        }
    }

    /**
     * 操作错误跳转的快捷方法
     * @access protected
     * @param string $message 错误信息
     * @param string $jumpUrl 页面跳转地址
     * @param mixed $ajax 是否为Ajax方式 当数字时指定跳转时间
     * @return void
     */
    protected function error($message = '', $jumpUrl = '', $ajax = false) {
        $this->dispatchJump($message, 0, $jumpUrl, $ajax);
    }

    /**
     * 操作成功跳转的快捷方法
     * @access protected
     * @param string $message 提示信息
     * @param string $jumpUrl 页面跳转地址
     * @param mixed $ajax 是否为Ajax方式 当数字时指定跳转时间
     * @return void
     */
    protected function success($message = '', $jumpUrl = '', $ajax = false) {
        $this->dispatchJump($message, 1, $jumpUrl, $ajax);
    }

    /**
     * Ajax方式返回数据到客户端
     * @access protected
     * @param mixed $data 要返回的数据
     * @param String $type AJAX返回数据格式
     * @param int $json_option 传递给json_encode的option参数
     * @return void
     */
    protected function ajaxReturn($data, $type = '', $json_option = 0) {
        if (empty($type))
            $type = C('DEFAULT_AJAX_RETURN');
        switch (strtoupper($type)) {
            case 'JSON' :
                // 返回JSON数据格式到客户端 包含状态信息
                header('Content-Type:application/json; charset=utf-8');
                $data = json_encode($data, $json_option);
                break;
            case 'JSONP':
                // 返回JSON数据格式到客户端 包含状态信息
                header('Content-Type:application/json; charset=utf-8');
                $handler = isset($_GET[C('VAR_JSONP_HANDLER')]) ? $_GET[C('VAR_JSONP_HANDLER')] : C('DEFAULT_JSONP_HANDLER');
                $data = $handler . '(' . json_encode($data, $json_option) . ');';
                break;
            case 'EVAL' :
                // 返回可执行的js脚本
                header('Content-Type:text/html; charset=utf-8');
                break;
        }
        exit($data);
    }

    /**
     * Action跳转(URL重定向) 支持指定模块和延时跳转
     * @access protected
     * @param string $url 跳转的URL表达式
     * @param array $params 其它URL参数
     * @param integer $delay 延时跳转的时间 单位为秒
     * @param string $msg 跳转提示信息
     * @return void
     */
    protected function redirect($url, $params = array(), $delay = 0, $msg = '') {
        $url = U($url, $params);
        redirect($url, $delay, $msg);
    }

    /**
     * 默认跳转操作 支持错误导向和正确跳转
     * 调用模板显示 默认为public目录下面的success页面
     * 提示页面为可配置 支持模板标签
     * @param string $message 提示信息
     * @param Boolean $status 状态
     * @param string $jumpUrl 页面跳转地址
     * @param mixed $ajax 是否为Ajax方式 当数字时指定跳转时间
     * @access private
     * @return void
     */
    private function dispatchJump($message, $status = 1, $jumpUrl = '', $ajax = false) {
        if (true === $ajax || IS_AJAX) {// AJAX提交
            $data = is_array($ajax) ? $ajax : array();
            $data['info'] = $message;
            $data['status'] = $status;
            $data['url'] = $jumpUrl;
            $this->ajaxReturn($data);
        }
        if (is_int($ajax))
            $this->assign('waitSecond', $ajax);
        if (!empty($jumpUrl))
            $this->assign('jumpUrl', $jumpUrl);
        // 提示标题
        $this->assign('msgTitle', $status ? L('_OPERATION_SUCCESS_') : L('_OPERATION_FAIL_'));
        //如果设置了关闭窗口,则提示完毕后自动关闭窗口
        if ($this->get('closeWin'))
            $this->assign('jumpUrl', 'javascript:window.close();');
        $this->assign('status', $status);   // 状态
        //保证输出不受静态缓存影响
        C('HTML_CACHE_ON', false);
        if ($status) { //发送成功信息
            $this->assign('message', $message); // 提示信息
            // 成功操作后默认停留1秒
            if (!isset($this->waitSecond))
                $this->assign('waitSecond', '1');
            // 默认操作成功自动返回操作前页面
            if (!isset($this->jumpUrl))
                $this->assign("jumpUrl", $_SERVER["HTTP_REFERER"]);
            $this->display(C('TMPL_ACTION_SUCCESS'));
        }else {
            $this->assign('error', $message); // 提示信息
            //发生错误时候默认停留3秒
            if (!isset($this->waitSecond))
                $this->assign('waitSecond', '3');
            // 默认发生错误的话自动返回上页
            if (!isset($this->jumpUrl))
                $this->assign('jumpUrl', "javascript:history.back(-1);");
            $this->display(C('TMPL_ACTION_ERROR'));
            // 中止执行  避免出错后继续执行
            exit;
        }
    }

}
第二个文件:PlugsBehaviors.class.php<?php

/**
 * 插件自动初始化类
 *
 * @author Administrator
 */

namespace Common\Behaviors;

use Think\Behavior;

class PlugsBehaviors extends Behavior {

    private $_config = array();
    //默认开启的插件列表
    public static $defaultList = array('SiteReport');

    public function run(&$params) {
        
    }

    /*
     * 标签类初始化信息
     */

    public function __construct() {
        
    }

    private function loadConfig() {
        $this->_config = S('Plugs');
    }

    private function init($tag_name) {
        $action_name = strtolower(ACTION_NAME);
        $controller_name = strtolower(CONTROLLER_NAME);
        $module_name = strtolower(MODULE_NAME);
        //加载开启的插件列表
        $plugs = M('Hooks')->where(array('status' => 1))->select();
        //加载默认插件
        foreach (self::$defaultList as $val) {
            $plugs[] = array('name' => $val);
        }
        //读取已经缓存的拦截内容
        $cache_plug = S('hook/' . $tag_name . '/' . $module_name . '/' . $controller_name . '/' . $action_name);
        if ($cache_plug) {
            foreach ($plugs as $key => $value) {
                if ($value['name'] == $cache_plug['name']) {
                    if (class_exists($cache_plug['plug_act'])) {
                        $GLOBALS['hook'][$cache_plug['name']] = array('act' => $cache_plug['act'], 'ctr' => $cache_plug['ctr']);
                        \Think\Hook::exec($cache_plug['plug_act'], $cache_plug['act']);
                    } else {
                        throw_exception('在读取功能的时候出错,请联系管理员,错误名称:' . $cache_plug['plug_act']);
                    }
                }
            }
            return;
        }
        //开启已经注册监听时间触发
        foreach ($plugs as $key => $val) {
            $className = '\Plugs\\' . $val['name'] . '\config';
            $obj = new $className;
            if ($obj) {
                $obj->setlisten($tag_name);
                $obj->reg();    //注册监听事件
            }
        }
        unset($pluginList);
    }

    /*
     * 应用开始之前
     */

    public static function app_begin() {
        self::init('app_begin');
    }

    /*
     * 控制器开始标签位
     */

    public static function action_begin() {
        self::init('action_begin');
    }

    /* 视图输出开始标签位
     * 
     */

    public static function view_begin() {
        self::init('view_begin');
    }

    /*
     * 模板内容解析标签位
     */

    public static function template_filter() {
        self::init('template_filter');
    }

    /*
     * 视图解析标签位
     */

    public static function view_parse() {
        self::init('view_parse');
    }

    /*
     * 视图输出过滤标签位
     */

    public static function view_filter() {
        self::init('view_filter');
    }

    /*
     * 视图输出结束标签位
     */

    public static function view_end() {
        self::init('view_end');
    }

    /*
     * 控制器结束标签位
     */

    public static function action_end() {
        self::init('action_end');
    }

    /*
     * 应用结束标签位
     */

    public static function app_end() {
        self::init('app_end');
    }

}
第三个文件:PlugsConfig.class.phpnamespace Common\Behaviors;

use Think\Behavior;

/**
 * Description of Config
 *
 * @author Administrator
 */
class PlugsConfig extends Behavior {

    protected static $__plugs_path = 'Plugs';    //插件的公共目录
    protected static $__plugs_name = '';        //插件名称
    private static $_tag_name = '';

    public function run(&$params) {
        
    }

    /**
     * 注册监听事件
     * @param type $event               事件名称   示例: app_begin@User@AXConfig@Index  触发位置@模块名@控制器名[@动作名称]
     * @param type $classObj            触发动作   控制器名称,如果不填写则与事件中的控制器名称以及方法相同
     * @param type $method              参数
     */
    public static function reg($event, $classObj = '', $method = "") {
        $event = explode('@', $event);
        $plug_add = $event[0] ? $event[0] : '';     //触发位置
        $module_name = $event[1] ? $event[1] : '';  //模块名称
        $controller = $event[2] ? $event[2] : 'Index';   //控制器名称
        $action = $event[3] ? $event[3] : '';   //控制器名称
        if (!$controller) {
            throw_exception('当前插件无法加载控制器,请联系管理员,错误名称:' . get_called_class() . '注册的控制器错误');
        }

        if (self::$_tag_name != $plug_add) { //非当前触发的则直接进行返回
            return;
        }

        if (strtolower($module_name) != strtolower(MODULE_NAME)) { //未注册当前模块直接返回
            return;
        }

        if (strtolower($controller) != strtolower(CONTROLLER_NAME)) { //未注册当前控制器直接返回
            return;
        }
        if (strtolower($action) != strtolower(ACTION_NAME)) { //未注册当前动作直接返回
            return;
        }

        $plugs_name = self::$__plugs_name;
        if (!$plugs_name) {
            $sub_class_path = explode('\\', get_called_class()); //获取子类的全名
            if ($sub_class_path[0] != self::$__plugs_path) {
                throw_exception('当前插件无法加载响应类,请联系管理员,错误名称:' . get_called_class());
            }
            $plugs_name = $sub_class_path[1];
        }
        $plug_controller = $controller;
        $plug_action = $action;
        if ($classObj) {
            $classObj = explode('@', $classObj);
            $plug_controller = $classObj[0];
            $plug_action = isset($classObj[1]) ? $classObj[1] : $plug_action;
        }
        $plug_url = 'hook/' . $plug_add . '/' . strtolower($module_name) . '/' . strtolower($controller) . '/' . strtolower($action);
        $plug_act = '\\' . self::$__plugs_path . '\\' . $plugs_name . '\\' . C('DEFAULT_C_LAYER') . '\\' . $plug_controller . C('DEFAULT_C_LAYER');

        if (class_exists($plug_act)) {
            $GLOBALS['hook'][$plugs_name] = array('act' => $plug_action, 'ctr' => $plug_controller);
            S($plug_url, array('plug_act' => $plug_act, 'ctr' => $plug_controller, 'act' => $plug_action, 'name' => $plugs_name)); //缓存插件的数据
            \Think\Hook::exec($plug_act, $plug_action);
        } else {
            throw_exception('当前插件无法加载动作,请联系管理员,错误名称:' . $plug_act . '->' . $plug_action);
        }

        //判断并实例化插件
    }

    /*
     * 设置被触发的的当前监听的标签
     */

    public function setlisten($tag_name) {
        self::$_tag_name = $tag_name;
    }

}
三个文件建立后可以实现功能 直接在插件中可以注册拦截位置,而不用单独的去页面中书写。
示例:
新建文件夹 Plugs与Common同级。
在Plugs建立插件的目录如下
--test 插件目录
-----Controller 插件的控制器目录
-----View 插件功能渲染模版文件夹
-----config.class.php 插件的配置文件
配置文件如下:namespace Plugs\test;

use Common\Behaviors\PlugsConfig;

class config extends PlugsConfig {

    public static function reg() {
        parent::reg("action_begin@User@Login@Index", 'Index');
    }

    public static function name() {
        return '用户对接';
    }

    public static function description() {
        return '专门用于用户对接管理,用户对接后可以直接使用第三方的账户进行登陆';
    }

}
说明: public static function reg() {
parent::reg("action_begin@User@Login@Index", 'Index');
} 是注册拦截器的位置,当前注册的是 user/login/index,路径 第二个参数 index 是要相应的插件的控制器名称,参数也是是 Index@index,如果没有动作则直接调去注册名中的动作,如当前没有写动作而是写了控制器名称则自动调去 user/login/index中的index动作。也就是 Index中的index动作。
indexController.class.php中的代码namespace Plugs\test\Controller;

use Common\Behaviors\Controller;

class IndexController extends Controller {

    //put your code here
    public function Index() {
        $this->assign('a', '123');
        $this->display();
    }

}
可以进行执行了。
如果要让拦截器更好的工作 则需要在不同的模块中建立
EmptyController.class.php文件namespace Admin\Controller;


use Think\Controller;

class EmptyController extends Controller{

    public function _empty() {
        echo'访问的动作不存在';exit;
    }

}
建立这个文件的作用是当拦截器拦截后 如果thinkphp未找到controller的时候会报错。

插件功能的实现可以直接使用thinkphp中的功能,和写模块差不多。
好了,简单的实现就到这了,不喜勿喷,大神勿喷。
评论( 相关
后面还有条评论,点击查看>>