Skip to content

Commit

Permalink
更新:优化自定义菜单功能,支持导入/恢复数据
Browse files Browse the repository at this point in the history
  • Loading branch information
@zhuchunshu
zhuchunshu committed Jan 17, 2023
1 parent 1e929c9 commit a3c0b8d
Show file tree
Hide file tree
Showing 11 changed files with 1,637 additions and 1,318 deletions.
2 changes: 1 addition & 1 deletion app/Controller/Admin/BackupController.php
View file
Expand Up @@ -64,7 +64,7 @@ public function delete()
public function create()
{
go(function () {
backup('backup-' . date('y-m-d') . '-' . Str::random() . '.zip');
backup('backup-' . date('y-m-d') . '-' . Str::random());
});
return redirect()->back()->with('success', '任务已创建')->go();
}
Expand Down
145 changes: 124 additions & 21 deletions app/Controller/Admin/MenuController.php
View file
Expand Up @@ -8,7 +8,6 @@
* @contact laravel@88.com
* @license https://github.com/zhuchunshu/SForum/blob/master/LICENSE
*/

namespace App\Controller\Admin;

use App\Controller\AbstractController;
Expand All @@ -19,6 +18,9 @@
use Hyperf\HttpServer\Annotation\PostMapping;
use Hyperf\Paginator\LengthAwarePaginator;
use Hyperf\Utils\Collection;
use Noodlehaus\Config;
use Swoole\Coroutine\System;
use Symfony\Component\Finder\Finder;

#[Controller(prefix: '/admin/setting/menu')]
#[Middleware(AdminMiddleware::class)]
Expand All @@ -36,10 +38,58 @@ public function create()
return view('admin.setting.menu.create');
}

#[GetMapping(path: 'import')]
public function import()
{
$page = $this->backup_page();
return view('admin.setting.menu.import', ['page' => $page]);
}

#[PostMapping(path: 'import')]
public function _import()
{
_menu_instance()->backup('before-import-' . date('Y-m-d-H:i:s'));
$path = request()->input('path');
if (! file_exists($path)) {
return admin_abort('文件不存在');
}
$data = Config::load($path)->all();
_menu_instance()->import($data);
return Json_Api(200, true, ['msg' => '导入成功!']);
}

/**
* 恢复备份.
* @return array|\Psr\Http\Message\ResponseInterface
*/
#[PostMapping(path: 'recover')]
public function _recover()
{
_menu_instance()->backup('before-recover-' . date('Y-m-d-H:i:s'));
$path = request()->input('path');
if (! file_exists($path)) {
return admin_abort('文件不存在');
}
$data = Config::load($path)->all();
_menu_instance()->import($data, true);
return Json_Api(200, true, ['msg' => '恢复成功!']);
}

#[PostMapping(path: 'import.delete.file')]
public function _import_remove_file()
{
$path = request()->input('path');
if (! file_exists($path)) {
return admin_abort('文件不存在');
}
removeFiles($path);
return Json_Api(200, true, ['msg' => '删除成功!']);
}

#[GetMapping(path: '{id}/edit')]
public function edit($id)
{
if (!in_array($id, _menu_keys())) {
if (! in_array($id, _menu_keys())) {
return admin_abort('菜单不存在', 403);
}
$data = _menu_get_data($id);
Expand All @@ -54,20 +104,20 @@ public function store()
{
$data = $this->request->input('data');
$data = json_decode($data, true);
if (arr_has($data, 'parent_id') && data_get($data, 'parent_id') && !in_array($data['parent_id'], _menu_keys())) {
if (arr_has($data, 'parent_id') && data_get($data, 'parent_id') && ! in_array($data['parent_id'], _menu_keys())) {
return Json_Api(403, false, ['msg' => '上级id不存在']);
}
$data['sort'] = (int)$data['sort'];
$data['sort'] = (int) $data['sort'];
if (arr_has($data, 'parent_id') && data_get($data, 'parent_id')) {
$data['parent_id'] = (int)$data['parent_id'];
$data['parent_id'] = (int) $data['parent_id'];
} else {
unset($data['parent_id']);
}
if (arr_has($data, 'parent_id') && data_get($data, 'parent_id') && arr_has(_menu_get_data($data['parent_id']), 'parent_id')) {
return Json_Api(403, false, ['msg' => '子菜单不能作为上级菜单使用']);
}
$prefix_name = config('cache.default.prefix') . 'menu';
redis()->hSetNx($prefix_name, (string)((int)max(_menu_keys()) + 1), _menu_instance()->serialize($data));
redis()->hSetNx($prefix_name, (string) ((int) max(_menu_keys()) + 1), _menu_instance()->serialize($data));
return Json_Api(200, true, ['msg' => '创建成功!']);
}

Expand All @@ -76,18 +126,13 @@ public function update()
{
$data = $this->request->input('data');
$data = json_decode($data, true);
if (!in_array($this->request->input('id'), _menu_keys())) {
if (! in_array($this->request->input('id'), _menu_keys())) {
return Json_Api(403, false, ['msg' => '被修改的菜单id不存在']);
}
if (arr_has($data, 'parent_id') && data_get($data, 'parent_id') && !in_array($data['parent_id'], _menu_keys())) {
if (arr_has($data, 'parent_id') && data_get($data, 'parent_id') && ! in_array($data['parent_id'], _menu_keys())) {
return Json_Api(403, false, ['msg' => '上级id不存在']);
}
$data['sort'] = (int)$data['sort'];
if (arr_has($data, 'parent_id') && data_get($data, 'parent_id')) {
$data['parent_id'] = (int)$data['parent_id'];
} else {
unset($data['parent_id']);
}
$data['sort'] = (int) $data['sort'];
if (arr_has($data, 'parent_id') && data_get($data, 'parent_id') && arr_has(_menu_get_data($data['parent_id']), 'parent_id')) {
return Json_Api(403, false, ['msg' => '子菜单不能作为上级菜单使用']);
}
Expand All @@ -96,37 +141,95 @@ public function update()
if (arr_has($data, 'quanxian')) {
$data['quanxian'] = _menu_instance()->serialize($data['quanxian']);
}
// 处理上级id
if (arr_has($data, 'parent_id') && data_get($data, 'parent_id')) {
$data['parent_id'] = (int) $data['parent_id'];
} else {
unset($data['parent_id']);
}
$prefix_name = config('cache.default.prefix') . 'menu';
redis()->hDel($prefix_name, (string)$this->request->input('id'));
redis()->hSetNx($prefix_name, (string)$this->request->input('id'), _menu_instance()->serialize($data));
redis()->hDel($prefix_name, (string) $this->request->input('id'));
redis()->hSetNx($prefix_name, (string) $this->request->input('id'), _menu_instance()->serialize($data));
return Json_Api(200, true, ['msg' => '修改成功!']);
}

#[PostMapping(path: "delete")]
#[PostMapping(path: 'delete')]
public function delete()
{
$id = $this->request->input('id');
if (!in_array($this->request->input('id'), _menu_keys())) {
if (! in_array($this->request->input('id'), _menu_keys())) {
return Json_Api(403, false, ['msg' => '被删除的菜单id不存在']);
}
if (arr_has(Itf()->get('menu'), $id)) {
return Json_Api(403, false, ['msg' => '这是不可删除的菜单']);
}
$prefix_name = config('cache.default.prefix') . 'menu';
redis()->hDel($prefix_name, (string)$this->request->input('id'));
redis()->hDel($prefix_name, (string) $this->request->input('id'));
return Json_Api(200, true, ['msg' => '删除成功!']);
}

/**
* 获取分页结果.
* @return LengthAwarePaginator
*/
private function page()
{
//_menu()
$currentPage = (int)request()->input('page', 1);
$perPage = (int)request()->input('per_page', 15);
$currentPage = (int) request()->input('page', 1);
$perPage = (int) request()->input('per_page', 15);

// 这里根据 $currentPage 和 $perPage 进行数据查询，以下使用 Collection 代替
$collection = new Collection(_menu());

$data = array_values($collection->forPage($currentPage, $perPage)->toArray());
return new LengthAwarePaginator($data, count(_menu()), $perPage, $currentPage);
}

/**
* 获取菜单备份.
* @return array
*/
private function menu_backup()
{
// 目录不存在则创建
if (! is_dir(BASE_PATH . '/runtime/backup/menu')) {
if (! is_dir(BASE_PATH . '/runtime/backup')) {
System::exec('cd ' . BASE_PATH . '/runtime' . '&& mkdir ' . 'backup');
}
if (! is_dir(BASE_PATH . '/runtime/backup/menu')) {
System::exec('cd ' . BASE_PATH . '/runtime/backup' . '&& mkdir ' . 'menu');
}
}

// 获取所有可以恢复的文件
$path = BASE_PATH . '/runtime/backup/menu';
$files = [];
$result = Finder::create()->in($path)->files()->name('*.json');
foreach ($result as $item) {
$files[$item->getCTime()] = [
'filename' => $item->getFilename(),
'path' => $item->getRealPath(),
'created_at' => date('Y-m-d H:i:s', $item->getCTime()),
];
}
krsort($files);
return array_values($files);
}

/**
* 获取备份文件分页.
* @return LengthAwarePaginator
*/
private function backup_page()
{
//_menu()
$currentPage = (int) request()->input('page', 1);
$perPage = (int) request()->input('per_page', 15);

// 这里根据 $currentPage 和 $perPage 进行数据查询，以下使用 Collection 代替
$collection = new Collection($this->menu_backup());

$data = array_values($collection->forPage($currentPage, $perPage)->toArray());
return new LengthAwarePaginator($data, count($this->menu_backup()), $perPage, $currentPage);
}
}
21 changes: 18 additions & 3 deletions app/Plugins/Core/Menu.php
View file
Expand Up @@ -126,7 +126,7 @@ private function unserialize($data)
}


public function backup()
public function backup($name='menu')
{

$data = [];
Expand All @@ -144,8 +144,23 @@ public function backup()
if (! is_dir(BASE_PATH . '/runtime/backup/menu')) {
System::exec('cd ' . BASE_PATH . '/runtime/backup' . '&& mkdir ' . 'menu');
}
file_put_contents(BASE_PATH."/runtime/backup/menu/menu_serialize.txt",$menu_serialize);
file_put_contents(BASE_PATH."/runtime/backup/menu/menu.json",$menu);
file_put_contents(BASE_PATH."/runtime/backup/menu/".$name."_serialize.txt",$menu_serialize);
file_put_contents(BASE_PATH."/runtime/backup/menu/".$name.".json",$menu);
return true;
}

/**
* 导入
*/
public function import(array $data,$recover=false){
$prefix_name = config('cache.default.prefix') . 'menu';
if($recover===true){
redis()->del($prefix_name);
}
foreach ($data as$item) {
if (! redis()->hExists($prefix_name, (string) $item['id'])) {
redis()->hSetNx($prefix_name, (string) $item['id'], $this->serialize($item));
}
}
}
}

0 comments on commit a3c0b8d

Please sign in to comment.