xtu_mall/app/admin/controller/Addon.php

<?php
// +----------------------------------------------------------------------
// | 
// +----------------------------------------------------------------------
// | 
// +----------------------------------------------------------------------
// | 
// +----------------------------------------------------------------------
// | 
// +----------------------------------------------------------------------

// +----------------------------------------------------------------------
// | 插件管理
// +----------------------------------------------------------------------
namespace app\admin\controller;

use app\admin\model\Adminlog;
use app\admin\model\general\Lang as LangModel;
use app\common\controller\Backend;
use think\addons\AddonException;
use think\addons\Service;
use think\Exception;
use think\facade\Cache;
use think\facade\Config;
use think\facade\Db;
use think\facade\Env;

class Addon extends Backend
{
    protected function getCmsConfigLangFields()
    {
        return ['site_name', 'site_title', 'site_keyword', 'site_description', 'site_logo_light', 'site_logo_dark'];
    }

    protected function getCmsConfigData($lang)
    {
        return Db::name('cms_config_data')->where('lang', $lang)->find();
    }

    protected function saveCmsConfigData($lang, array $params)
    {
        $data = ['lang' => $lang, 'update_time' => time()];
        foreach ($this->getCmsConfigLangFields() as $field) {
            $data[$field] = $params[$field] ?? '';
        }
        $exists = Db::name('cms_config_data')->where('lang', $lang)->find();
        if ($exists) {
            Db::name('cms_config_data')->where('lang', $lang)->update($data);
        } else {
            $data['create_time'] = time();
            Db::name('cms_config_data')->insert($data);
        }
    }

    //初始化
    protected function initialize()
    {
        parent::initialize();
        if (!$this->auth->isAdministrator() && in_array($this->request->action(), ['install', 'uninstall', 'local', 'upgrade', 'testdata'])) {
            $this->error('非超级管理员禁止操作！');
        }
    }

    //显示插件列表
    public function index()
    {
        $type   = $this->request->param("type", 'online');
        $limit  = $this->request->param("limit/d");
        $page   = $this->request->param("page/d", 1);
        $search = $this->request->param("search", '', 'strip_tags,htmlspecialchars');

        if ($this->request->isAjax()) {
            if ($type == 'local') {
                $addons = get_addon_list();
                if ($search) {
                    $addons = array_filter($addons, function ($v) use ($search) {
                        return stripos($v['name'], $search) !== false ||
                        stripos($v['title'], $search) !== false ||
                        stripos($v['description'], $search) !== false;
                    });
                }
                $list = [];
                foreach ($addons as $k => $v) {
                    $config              = get_addon_config($v['name']);
                    $v['config']         = $config ? 1 : 0;
                    $addons[$k]['addon'] = $v;
                }
                $count = count($addons);
                if ($limit) {
                    $addons = array_slice($addons, ($page - 1) * $limit, $limit);
                }
                $result = ["code" => 0, "data" => $addons, 'count' => $count];
            } else {
                //在线插件
                $list         = $this->getAddonList($search, $page, $limit);
                $onlineaddons = $list['list'] ?? [];
                $category     = $list['category'] ?? [];
                $count        = $list['count'] ?? -1;
                //本地插件
                $addons = get_addon_list();
                foreach ($addons as &$v) {
                    $config      = get_addon_config($v['name']);
                    $v['config'] = $config ? 1 : 0;
                }
                foreach ($onlineaddons as &$item) {
                    $item['addon'] = $addons[$item['name']] ?? '';
                }
                $result = ["code" => 0, "data" => $onlineaddons, "category" => $category, 'count' => $count];
            }

            return json($result);
        }
        $this->assign(['type' => $type]);
        $this->assignconfig('addon', ['type' => $type, 'api_url' => config::get('yzn.api_url')]);
        return $this->fetch();
    }

    /**
     * 设置插件页面
     */
    public function config($name = null)
    {
        $name = $name ?: $this->request->get("name");
        if (!$name) {
            $this->error('参数不得为空！');
        }
        if (!preg_match('/^[a-zA-Z0-9]+$/', $name)) {
            $this->error('插件名称不正确！');
        }
        if (!is_dir(ADDON_PATH . $name)) {
            $this->error('目录不存在！');
        }
        $info   = get_addon_info($name);
        $config = get_addon_fullconfig($name);
        if (!$info) {
            $this->error('配置不存在！');
        }
        $defaultLang = LangModel::getDefaultMark();
        $currentLang = $this->request->param('lang/s', $defaultLang);
        if ($name === 'cms' && $currentLang !== $defaultLang) {
            $translate = $this->getCmsConfigData($currentLang) ?: [];
            foreach ($config as &$item) {
                if (in_array($item['name'], $this->getCmsConfigLangFields(), true) && isset($translate[$item['name']])) {
                    $item['value'] = $translate[$item['name']];
                }
            }
            unset($item);
        }
        if ($this->request->isPost()) {
            $params = $this->request->post("row/a", [], 'trim');
            if ($params) {
                try {
                    if ($name === 'cms' && $currentLang !== $defaultLang) {
                        $this->saveCmsConfigData($currentLang, $params);
                    } else {
                        foreach ($config as $k => &$v) {
                            if (isset($params[$v['name']])) {
                                if ($v['type'] == 'array') {
                                    $params[$v['name']] = is_array($params[$v['name']]) ? $params[$v['name']] : (array) json_decode($params[$v['name']], true);
                                    $value = $params[$v['name']];
                                } else {
                                    $value = is_array($params[$v['name']]) ? implode(',', $params[$v['name']]) : $params[$v['name']];
                                }
                                $v['value'] = $value;
                            } elseif ($v['type'] == 'checkbox' && !isset($params[$v['name']])) {
                                //单独处理多选框为空不传参
                                $v['value'] = '';
                            }
                        }
                        $addon = get_addon_instance($name);
                        //插件自定义配置实现逻辑
                        if (method_exists($addon, 'config')) {
                            $addon->config($config);
                        } else {
                            //更新配置文件
                            set_addon_fullconfig($name, $config);
                            Service::refresh();
                        }
                    }
                } catch (\Exception $e) {
                    $this->error($e->getMessage());
                }
            }
            $this->success('插件配置成功！');
        }
        $tips        = [];
        $groupList   = [];
        $ungroupList = [];
        foreach ($config as $index => &$item) {
            //如果有设置分组
            if (isset($item['group']) && $item['group']) {
                if (!in_array($item['group'], $groupList)) {
                    $groupList["custom" . (count($groupList) + 1)] = $item['group'];
                }
            } elseif ($item['name'] != '__tips__') {
                $ungroupList[] = $item['name'];
            }
            $item['extend'] = $item['extend'] ?? '';
            if ($item['name'] == '__tips__') {
                $tips = $item;
                unset($config[$index]);
            }
        }
        if ($ungroupList) {
            $groupList['other'] = '其它';
        }
        $this->assign("groupList", $groupList);
        $this->assign('data', ['info' => $info, 'config' => $config, 'tips' => $tips]);
        $this->assign('configLangs', $name === 'cms' ? LangModel::getEnabledList() : []);
        $this->assign('currentConfigLang', $currentLang);
        $this->assign('defaultConfigLang', $defaultLang);
        $configFile = ADDON_PATH . $name . DS . 'config.html';
        $viewFile   = is_file($configFile) ? $configFile : '';
        return $this->fetch($viewFile);
    }

    /**
     * 禁用启用.
     */
    public function state()
    {
        $name   = $this->request->param('name');
        $action = $this->request->param('action');
        $force  = $this->request->post("force/d");
        if (!$name) {
            $this->error('参数不得为空！');
        }
        if (!preg_match('/^[a-zA-Z0-9]+$/', $name)) {
            $this->error('插件名称不正确');
        }
        try {
            $action = $action == 'enable' ? $action : 'disable';
            //调用启用、禁用的方法
            Service::$action($name, $force);
            Cache::delete('__menu__');
        } catch (AddonException $e) {
            $this->result($e->getData(), $e->getCode(), $e->getMessage());
        } catch (\Exception $e) {
            $this->error($e->getMessage());
        }
        $this->success('操作成功');
    }

    /**
     * 安装插件
     */
    public function install()
    {
        Adminlog::setTitle('插件安装');
        $name  = $this->request->param('name');
        $force = $this->request->param("force/d");
        if (empty($name)) {
            $this->error('请选择需要安装的插件！');
        }
        if (!preg_match('/^[a-zA-Z0-9]+$/', $name)) {
            $this->error('插件标识错误！');
        }
        $info = [];
        try {
            $uid     = $this->request->post("uid");
            $token   = $this->request->post("token");
            $version = $this->request->post("version");
            $extend  = [
                'uid'            => $uid,
                'token'          => $token,
                'version'        => $version,
                'yzncms_version' => Config::get('version.yzncms_version'),
            ];
            $info = Service::install($name, $force, $extend);
            Cache::delete('__menu__');
        } catch (AddonException $e) {
            $this->result($e->getData(), $e->getCode(), $e->getMessage());
        } catch (\Exception $e) {
            $this->error($e->getMessage());
        }
        $this->success('插件安装成功！清除浏览器缓存和框架缓存后生效！', '', ['addon' => $info]);
    }

    /**
     * 卸载插件
     */
    public function uninstall()
    {
        Adminlog::setTitle('插件卸载');
        $name       = $this->request->param('name');
        $force      = $this->request->param("force/d");
        $droptables = $this->request->param("droptables/d");
        if (empty($name)) {
            $this->error('请选择需要安装的插件！');
        }
        if (!preg_match('/^[a-zA-Z0-9]+$/', $name)) {
            $this->error('插件标识错误！');
        }
        //只有开启调试且为超级管理员才允许删除相关数据库
        $tables = [];
        if ($droptables && Env::get('APP_DEBUG') && $this->auth->isAdministrator()) {
            $tables = get_addon_tables($name);
        }
        try {
            Service::uninstall($name, $force);
            if ($tables) {
                //$prefix = Config::get('database.prefix');
                //删除插件关联表
                foreach ($tables as $table) {
                    Db::execute("DROP TABLE IF EXISTS `{$table}`");
                }
            }
        } catch (AddonException $e) {
            $this->result($e->getData(), $e->getCode(), $e->getMessage());
        } catch (\Exception $e) {
            $this->error($e->getMessage());
        }
        $this->success('插件卸载成功！清除浏览器缓存和框架缓存后生效！');
    }

    /**
     * 本地上传
     */
    public function local()
    {
        Adminlog::setTitle('插件上传安装');
        if (!Env::get('APP_DEBUG')) {
            $this->error('本地上传安装需要开启调试模式！');
        }
        $file = $this->request->file('file');
        try {
            $force  = $this->request->post("force");
            $extend = [];
            $info   = Service::local($file, $extend, $force);
        } catch (AddonException $e) {
            $this->result($e->getData(), $e->getCode(), $e->getMessage());
        } catch (\Exception $e) {
            $this->error($e->getMessage());
        }
        $this->success('插件安装成功！清除浏览器缓存和框架缓存后生效！', '', ['addon' => $info]);
    }

    /**
     * 更新插件
     */
    public function upgrade()
    {
        $name        = $this->request->param('name');
        $addonTmpDir = app()->getRuntimePath() . 'addons' . DS;
        if (empty($name)) {
            $this->error('请选择需要安装的插件！');
        }
        if (!preg_match('/^[a-zA-Z0-9]+$/', $name)) {
            $this->error('插件标识错误！');
        }
        if (!is_dir($addonTmpDir)) {
            @mkdir($addonTmpDir, 0755, true);
        }
        $info = [];
        try {
            $info    = get_addon_info($name);
            $uid     = $this->request->post("uid");
            $token   = $this->request->post("token");
            $version = $this->request->post("version");
            $extend  = [
                'uid'            => $uid,
                'token'          => $token,
                'version'        => $version,
                'oldversion'     => $info['version'] ?? '',
                'yzncms_version' => Config::get('version.yzncms_version'),
            ];
            //调用更新的方法
            $info = Service::upgrade($name, $extend);
            Cache::delete('__menu__');
        } catch (AddonException $e) {
            $this->result($e->getData(), $e->getCode(), $e->getMessage());
        } catch (Exception $e) {
            $this->error($e->getMessage());
        }
        $this->success('升级成功', '', ['addon' => $info]);
    }

    /**
     * 测试数据
     */
    public function testdata()
    {
        Adminlog::setTitle('插件导入测试数据');
        $name = $this->request->post("name");
        if (empty($name)) {
            $this->error('请选择需要安装的插件！');
        }
        if (!preg_match("/^[a-zA-Z0-9]+$/", $name)) {
            $this->error('插件标识错误！');
        }

        try {
            Service::runSQL($name, 'testdata');
        } catch (AddonException $e) {
            $this->result($e->getData(), $e->getCode(), $e->getMessage());
        } catch (Exception $e) {
            $this->error($e->getMessage(), $e->getCode());
        }
        $this->success('导入成功');
    }

    /**
     * 检测
     */
    public function isbuy()
    {
        $name    = $this->request->post("name");
        $uid     = $this->request->post("uid");
        $token   = $this->request->post("token");
        $version = $this->request->post("version");
        $extend  = [
            'uid'            => $uid,
            'token'          => $token,
            'version'        => $version,
            'yzncms_version' => Config::get('version.yzncms_version'),
        ];
        try {
            $result = Service::isBuy($name, $extend);
        } catch (Exception $e) {
            $this->error($e->getMessage());
        }
        return json($result);
    }

    /**
     * 获取插件相关表
     */
    public function get_table_list()
    {
        $name = $this->request->post("name");
        if (!preg_match("/^[a-zA-Z0-9]+$/", $name)) {
            $this->error('插件标识错误！');
        }
        $tables = get_addon_tables($name);
        //$prefix = Config::get('database.prefix');
        $tables = array_values($tables);
        $this->success('', null, ['tables' => $tables]);
    }

    protected function getAddonList($search, $page, $limit)
    {
        $params = [
            'uid'         => $this->request->param('uid/d'),
            'token'       => $this->request->param('token'),
            'category_id' => $this->request->param('category_id/d'),
            'version'     => Config::get('version.yzncms_version'),
            'page'        => $page,
            'limit'       => $limit,
            'search'      => $search,
        ];
        $json = [];
        try {
            $json = Service::addons($params);
        } catch (\Exception $e) {

        }
        return $json;
    }
}