ulthon/ulthon_information
1
0
Fork 0
mirror of https://gitee.com/ulthon/ulthon_information.git synced 2026-03-03 16:24:28 +08:00
Code Issues Packages Projects Releases Wiki Activity

增加自动清除缓存特性;

Browse Source
This commit is contained in:
augushong
2022-02-12 17:02:45 +08:00
parent 90bbf61b6a
commit 7d8b948543
7 changed files with 260 additions and 154 deletions
Download Patch File Download Diff File Expand all files Collapse all files

272
app/BaseController.php
View File

@@ -18,157 +18,159 @@ use think\exception\ValidateException;
use think\Validate; use think\Validate;
use think\facade\View; use think\facade\View;
use think\exception\HttpResponseException; use think\exception\HttpResponseException;
use think\facade\Log;
/** /**
* 控制器基础类 * 控制器基础类
*/ */
abstract class BaseController abstract class BaseController
{ {
/** /**
* Request实例 * Request实例
* @var \think\Request * @var \think\Request
*/ */
protected $request; protected $request;
/** /**
* 应用实例 * 应用实例
* @var \think\App * @var \think\App
*/ */
protected $app; protected $app;
/** /**
* 是否批量验证 * 是否批量验证
* @var bool * @var bool
*/ */
protected $batchValidate = false; protected $batchValidate = false;
/** /**
* 控制器中间件 * 控制器中间件
* @var array * @var array
*/ */
protected $middleware = []; protected $middleware = [];
/** /**
* 构造方法 * 构造方法
* @access public * @access public
* @param App $app 应用对象 * @param App $app 应用对象
*/ */
public function __construct(App $app) public function __construct(App $app)
{ {
$this->app = $app; $this->app = $app;
$this->request = $this->app->request; $this->request = $this->app->request;
// 控制器初始化 // 控制器初始化
$this->initialize(); $this->initialize();
}
// 初始化
protected function initialize()
{
}
/**
* 验证数据
* @access protected
* @param array $data 数据
* @param string|array $validate 验证器名或者验证规则数组
* @param array $message 提示信息
* @param bool $batch 是否批量验证
* @return array|string|true
* @throws ValidateException
*/
protected function validate(array $data, $validate, array $message = [], bool $batch = false)
{
if (is_array($validate)) {
$v = new Validate();
$v->rule($validate);
} else {
if (strpos($validate, '.')) {
// 支持场景
list($validate, $scene) = explode('.', $validate);
}
$class = false !== strpos($validate, '\\') ? $validate : $this->app->parseClass('validate', $validate);
$v = new $class();
if (!empty($scene)) {
$v->scene($scene);
}
} }
$v->message($message); // 初始化
protected function initialize()
// 是否批量验证 {
if ($batch || $this->batchValidate) { Log::debug('request url :'.$this->request->url());
$v->batch(true);
} }
return $v->failException(true)->check($data); /**
} * 验证数据
* @access protected
public function success($msg = '操作成功', $jump_to_url = null, $code = 200, $params = []) * @param array $data 数据
{ * @param string|array $validate 验证器名或者验证规则数组
$jump_to_url = $this->parseJumpUrl($jump_to_url); * @param array $message 提示信息
$data = [ * @param bool $batch 是否批量验证
'msg' => $msg, * @return array|string|true
'jump_to_url' => $jump_to_url, * @throws ValidateException
'params' => $params */
]; protected function validate(array $data, $validate, array $message = [], bool $batch = false)
{
if (\request()->isAjax()) { if (is_array($validate)) {
$data['jump_to_url'] = $jump_to_url; $v = new Validate();
if ($code == 200) { $v->rule($validate);
$code = 0; } else {
} if (strpos($validate, '.')) {
throw new HttpResponseException(json_message($data, $code, $msg)); // 支持场景
} list($validate, $scene) = explode('.', $validate);
}
View::assign($data); $class = false !== strpos($validate, '\\') ? $validate : $this->app->parseClass('validate', $validate);
throw new HttpResponseException(response(View::fetch('common@tpl/success'), $code)); $v = new $class();
} if (!empty($scene)) {
public function error($msg = '操作失败', $jump_to_url = null, $code = 200, $params = []) $v->scene($scene);
{ }
$jump_to_url = $this->parseJumpUrl($jump_to_url);
$data = [
'msg' => $msg,
'jump_to_url' => $jump_to_url,
'params' => $params
];
if (\request()->isAjax()) {
$data['jump_to_url'] = $jump_to_url;
if ($code == 200) {
$code = 500;
}
throw new HttpResponseException(json_message($data, $code, $msg));
}
View::assign($data);
throw new HttpResponseException(response(View::fetch('common@tpl/error'), $code));
}
public function redirect($jump_to_url, $code = 302)
{
$jump_to_url = $this->parseJumpUrl($jump_to_url);
throw new HttpResponseException(redirect($jump_to_url), $code);
}
public function parseJumpUrl($jump_to_url)
{
if (is_null($jump_to_url)) {
$jump_to_url = \request()->server('HTTP_REFERER');
} else {
if ($jump_to_url instanceof Url) {
$jump_to_url = (string)$jump_to_url;
} else {
if (strpos($jump_to_url, 'http') !== 0) {
$jump_to_url = url($jump_to_url);
} }
}
$v->message($message);
// 是否批量验证
if ($batch || $this->batchValidate) {
$v->batch(true);
}
return $v->failException(true)->check($data);
} }
return (string)$jump_to_url; public function success($msg = '操作成功', $jump_to_url = null, $code = 200, $params = [])
} {
$jump_to_url = $this->parseJumpUrl($jump_to_url);
$data = [
'msg' => $msg,
'jump_to_url' => $jump_to_url,
'params' => $params
];
if (\request()->isAjax()) {
$data['jump_to_url'] = $jump_to_url;
if ($code == 200) {
$code = 0;
}
throw new HttpResponseException(json_message($data, $code, $msg));
}
View::assign($data);
throw new HttpResponseException(response(View::fetch('common@tpl/success'), $code));
}
public function error($msg = '操作失败', $jump_to_url = null, $code = 200, $params = [])
{
$jump_to_url = $this->parseJumpUrl($jump_to_url);
$data = [
'msg' => $msg,
'jump_to_url' => $jump_to_url,
'params' => $params
];
if (\request()->isAjax()) {
$data['jump_to_url'] = $jump_to_url;
if ($code == 200) {
$code = 500;
}
throw new HttpResponseException(json_message($data, $code, $msg));
}
View::assign($data);
throw new HttpResponseException(response(View::fetch('common@tpl/error'), $code));
}
public function redirect($jump_to_url, $code = 302)
{
$jump_to_url = $this->parseJumpUrl($jump_to_url);
throw new HttpResponseException(redirect($jump_to_url), $code);
}
public function parseJumpUrl($jump_to_url)
{
if (is_null($jump_to_url)) {
$jump_to_url = \request()->server('HTTP_REFERER');
} else {
if ($jump_to_url instanceof Url) {
$jump_to_url = (string)$jump_to_url;
} else {
if (strpos($jump_to_url, 'http') !== 0) {
$jump_to_url = url($jump_to_url);
}
}
}
return (string)$jump_to_url;
}
} }

10
app/common/model/Base.php Normal file
View File

@@ -0,0 +1,10 @@
<?php
namespace app\common\model;
use app\common\traits\AutoClearCache;
use think\Model;
class Base extends Model
{
// use AutoClearCache;
}

65
app/common/traits/AutoClearCache.php Normal file
View File

@@ -0,0 +1,65 @@
<?php
namespace app\common\traits;
use think\facade\Cache;
/**
*
*/
trait AutoClearCache
{
/**
* 自动清除的缓存值
*
* [
* 'name'=>'',
* 'type'=>'', // tag/key
* 'field'=>'' // 为空则不做拼接
* ]
*
* @var array
*/
public static $autoClearCache = [];
public static function onAfterWrite($model)
{
static::autoRemoveCache($model);
}
public static function onAfterDelete($model)
{
static::autoRemoveCache($model);
}
public static function onAfterRestore($model)
{
static::autoRemoveCache($model);
}
public static function autoRemoveCache($model)
{
foreach (static::$autoClearCache as $cache_item) {
$type = $cache_item['type'] ?: 'key';
$field = $cache_item['field'] ?: '';
$cache_key = $cache_item['name'] ?: '';
if (empty($cache_key)) {
continue;
}
if (!empty($field)) {
if (!is_null($model->$field)) {
$cache_key = $cache_key . '_' . $model->$field;
}
}
if ($type == 'key') {
Cache::delete($type);
} else {
Cache::tag($cache_key)->clear();
}
}
}
}

6
app/index/controller/Common.php
View File

@@ -17,9 +17,11 @@ class Common extends BaseController
{ {
parent::initialize(); parent::initialize();
$list_nav_slide = Nav::where('type', 3)->order('sort asc')->where('status', 1)->select(); $list_nav_slide = Nav::where('type', 3)->cache('type_3_list')->order('sort asc')->where('status', 1)->select();
View::assign('list_nav_slide', $list_nav_slide); View::assign('list_nav_slide', $list_nav_slide);
$list_nav_friend_url = Nav::where('type', 2)->order('sort asc')->where('status', 1)->select();
$list_nav_friend_url = Nav::where('type', 2)->cache('type_2_list')->order('sort asc')->where('status', 1)->select();
View::assign('list_nav_friend_url', $list_nav_friend_url); View::assign('list_nav_friend_url', $list_nav_friend_url);
$list_header_nav = Nav::where('type', 11)->order('sort asc')->where('status', 1)->select(); $list_header_nav = Nav::where('type', 11)->order('sort asc')->where('status', 1)->select();

2
app/middleware.php
View File

@@ -12,5 +12,5 @@ return [
// 页面Trace调试 // 页面Trace调试
// \think\middleware\TraceDebug::class, // \think\middleware\TraceDebug::class,
'\app\\middleware\ConfigInit' // '\app\\middleware\ConfigInit'
]; ];

37
app/model/Nav.php
View File

@@ -4,26 +4,33 @@ declare(strict_types=1);
namespace app\model; namespace app\model;
use think\Model; use app\common\model\Base;
/** /**
* @mixin think\Model * @mixin think\Model
*/ */
class Nav extends Model class Nav extends Base
{ {
public static $statusName = [ public static $autoClearCache = [
0=>'不显示', [
1=>'显示' 'name' => 'type_3_list'
]; ]
// ];
public function getImgAttr($value)
{
return get_source_link($value);
}
public function getStatusNameAttr() public static $statusName = [
{ 0 => '不显示',
return self::$statusName[$this->getData('status')]; 1 => '显示'
} ];
//
public function getImgAttr($value)
{
return get_source_link($value);
}
public function getStatusNameAttr()
{
return self::$statusName[$this->getData('status')];
}
} }

22
config/log.php
View File

@@ -6,7 +6,7 @@ use think\facade\Env;
// +---------------------------------------------------------------------- // +----------------------------------------------------------------------
return [ return [
// 默认日志记录通道 // 默认日志记录通道
'default' => Env::get('log.channel', 'file'), 'default' => Env::get('log.channel', 'debug_mysql'),
// 日志记录级别 // 日志记录级别
'level' => [], 'level' => [],
// 日志类型记录的通道 ['error'=>'email',...] // 日志类型记录的通道 ['error'=>'email',...]
@@ -41,6 +41,26 @@ return [
'realtime_write' => false, 'realtime_write' => false,
], ],
// 其它日志通道配置 // 其它日志通道配置
// 其它日志通道配置
'debug_mysql' => [
'type' => 'DebugMysql',
// 服务器地址
'hostname' => Env::get('database.hostname', ''),
// 数据库名
'database' => Env::get('database.database', ''),
// 用户名
'username' => Env::get('database.username', ''),
// 密码
'password' => Env::get('database.password', ''),
// 端口
'hostport' => Env::get('database.hostport', '3306'),
// 数据库连接参数
'params' => [],
// 数据库编码默认采用utf8
'charset' => Env::get('database.charset', 'utf8'),
// 数据库表前缀
'prefix' => Env::get('database.prefix', 'ul_'),
]
], ],
]; ];