blackteay/ThinkAdmin
1
0
Fork 0
mirror of https://gitee.com/zoujingli/ThinkAdmin.git synced 2025-04-06 03:58:04 +08:00
Code Issues Projects Releases Wiki Activity

增加SQL监听

Browse Source
This commit is contained in:
Anyon 2020-09-19 18:12:23 +08:00
parent 29a11ac52f
commit 667bd65ff4
2 changed files with 44 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
app/admin/sys.php Normal file
View File

@ -0,0 +1,42 @@
<?php
// +----------------------------------------------------------------------
// | ThinkAdmin
// +----------------------------------------------------------------------
// | 版权所有 2014~2020 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
// +----------------------------------------------------------------------
// | 官方网站: https://thinkadmin.top
// +----------------------------------------------------------------------
// | 开源协议 ( https://mit-license.org )
// +----------------------------------------------------------------------
// | gitee 代码仓库：https://gitee.com/zoujingli/ThinkAdmin
// | github 代码仓库：https://github.com/zoujingli/ThinkAdmin
// +----------------------------------------------------------------------
use think\admin\service\AdminService;
use think\helper\Str;
/*! SQL 监听分析记录日志 */
app()->db->listen(function ($sqlstr) {
[$type,] = explode(' ', $sqlstr);
if (in_array($type, ['INSERT', 'UPDATE', 'DELETE']) && AdminService::instance()->isLogin()) {
[$sqlstr] = explode('GROUP BY', explode('ORDER BY', $sqlstr)[0]);
if (preg_match('/^INSERT\s+INTO\s+`(.*?)`\s+SET\s+(.*?)\s*$/i', $sqlstr, $matches)) {
if (stripos($matches[1] = Str::studly($matches[1]), 'SystemOplog') === false) {
$matches[2] = substr(str_replace(['`', ' '], '', $matches[2]), 0, 200);
return sysoplog("添加数据 {$matches[1]}", "添加数据：{$matches[2]}");
}
} elseif (preg_match('/^UPDATE\s+`(.*?)`\s+SET\s+(.*?)\s+WHERE\s+(.*?)\s*$/i', $sqlstr, $matches)) {
if (stripos($matches[1] = Str::studly($matches[1]), 'SystemOplog') === false) {
$matches[3] = substr(str_replace(['`', ' '], '', $matches[3]), 0, 200);
$matches[2] = substr(str_replace(['`', ' '], '', $matches[2]), 0, 200);
return sysoplog("更新数据 {$matches[1]}（ {$matches[3]} ）", "更新数据：{$matches[2]}");
}
} elseif (preg_match('/^DELETE\s*FROM\s*`(.*?)`\s*WHERE\s*(.*?)\s*$/i', $sqlstr, $matches)) {
if (stripos($matches[1] = Str::studly($matches[1]), 'SystemOplog') === false) {
$matches[2] = str_replace(['`', ' '], '', $matches[2]);
return sysoplog("删除数据 {$matches[1]}", "删除条件：{$matches[2]}");
}
}
}
});

4
app/admin/view/oplog/index.html
View File

@ -37,8 +37,8 @@
<span class="color-desc">{$vo.node|default='-'}</span>
</td>
<td class='text-left nowrap'>
<p class="color-text">{$vo.action|default='-'}</p>
<p class="color-desc">{$vo.content|default='-'}</p>
<p class="color-text layui-elip" style="max-width:400px">{$vo.action|default='-'}</p>
<p class="color-desc layui-elip" style="max-width:400px">{$vo.content|default='-'}</p>
</td>
<td class='text-left nowrap'>
<p class="color-text">{$vo.geoip|default='-'}</p>