rf3main/backend/modules/common/controllers/AddonsController.php

<?php

namespace backend\modules\common\controllers;

use Yii;
use yii\web\NotFoundHttpException;
use common\models\base\SearchModel;
use common\traits\Curd;
use common\models\common\Addons;
use common\enums\AppEnum;
use common\helpers\AddonHelper;
use common\helpers\ExecuteHelper;
use common\helpers\FileHelper;
use common\interfaces\AddonWidget;
use common\helpers\ResultHelper;
use common\helpers\ArrayHelper;
use backend\forms\AddonsForm;
use backend\controllers\BaseController;
use yii\web\UnprocessableEntityHttpException;

/**
 * Class AddonsController
 * @package backend\modules\common\controllers
 */
class AddonsController extends BaseController
{
    use Curd;

    /**
     * @var Addons
     */
    public $modelClass = Addons::class;

    /**
     * 首页
     *
     * @return mixed|string
     * @throws NotFoundHttpException
     * @throws \Throwable
     * @throws \yii\db\StaleObjectException
     */
    public function actionIndex()
    {
        $searchModel = new SearchModel([
            'model' => Addons::class,
            'scenario' => 'default',
            'partialMatchAttributes' => ['title', 'name'], // 模糊查询
            'defaultOrder' => [
                'id' => SORT_DESC,
            ],
            'pageSize' => $this->pageSize,
        ]);

        $dataProvider = $searchModel->search(Yii::$app->request->queryParams);

        $models = $dataProvider->getModels();
        $addons = [];
        foreach ($models as $model) {
            $addons[] = [
                'name' => $model->name,
                'version' => $model->version,
            ];
        }

        try {
            $newestVersion = Yii::$app->services->rageFrame->queryNewestByNames($addons);
        } catch (\Exception $e) {
            $newestVersion = [];
        }

        return $this->render($this->action->id, [
            'dataProvider' => $dataProvider,
            'searchModel' => $searchModel,
            'newestVersion' => ArrayHelper::map($newestVersion, 'version_name', 'version'),
            'addonsGroup' => Yii::$app->params['addonsGroup'],
        ]);
    }

    /**
     * 卸载
     *
     * @return mixed
     * @throws NotFoundHttpException
     * @throws \Throwable
     * @throws \yii\db\StaleObjectException
     */
    public function actionUnInstall()
    {
        $name = Yii::$app->request->get('name');
        // 删除数据库
        if ($model = Addons::findOne(['name' => $name])) {
            $model->delete();
        }

        try {
            // 进行卸载数据库
            if ($class = AddonHelper::getAddonConfig($name)) {
                $uninstallClass = AddonHelper::getAddonRoot($name) . (new $class)->uninstall;
                ExecuteHelper::map($uninstallClass, 'run', $model);
            }
        } catch (\Exception $e) {
        }

        return $this->message('卸载成功', $this->redirect(['index']));
    }

    /**
     * 在线升级
     *
     * @param $name
     * @return array|mixed
     */
    public function actionOnLineUpgrade($name = 'Authority')
    {
        try {
            Yii::$app->services->rageFrame->update($name);

            return ResultHelper::json(200, '升级成功');
        } catch (\Exception $e) {
            return ResultHelper::json(422, $e->getMessage());
        }
    }

    /**
     * 安装列表
     *
     * @return mixed|string
     * @throws \Throwable
     * @throws \yii\db\Exception
     */
    public function actionLocal()
    {
        return $this->render($this->action->id, [
            'list' => Yii::$app->services->addons->getLocalList(),
        ]);
    }

    /**
     * 安装
     *
     * @return mixed|string
     * @throws \Throwable
     * @throws \yii\db\Exception
     */
    public function actionInstall($installData = true)
    {
        $name = Yii::$app->request->get('name');

        if (!($class = AddonHelper::getAddonConfig($name))) {
            return $this->message('实例化失败,插件不存在或检查插件名称', $this->redirect(['index']), 'error');
        }

        ini_set("max_execution_time", 300);

        // 开启事务
        $transaction = Yii::$app->db->beginTransaction();
        try {
            $config = new $class;
            $rootPath = AddonHelper::getAddonRootPath($name);

            $allAuthItem = [];
            $defaultConfig = [];

            // 前置插件
            foreach ($config->preposition as $addon => $preposition) {
                if (empty(Yii::$app->services->addons->findByName($addon))) {
                    throw new NotFoundHttpException('请先安装「' . $preposition . '」插件');
                }
            }

            foreach ($config->appsConfig as $appId => $item) {
                $file = $rootPath . $item;

                if (!in_array($appId, array_keys(AppEnum::getMap()))) {
                    throw new NotFoundHttpException('找不到应用');
                }
                if (!file_exists($file)) {
                    throw new NotFoundHttpException("找不到 $appId 应用文件");
                }

                $appConfig = require $file;
                // 权限
                if (isset($appConfig['authItem']) && !empty($appConfig['authItem'])) {
                    $allAuthItem[$appId] = $appConfig['authItem'];
                }

                // 默认存储配置
                $defaultConfig[$appId] = $appConfig['config'] ?? [];
                // 菜单配置
                if (isset($defaultConfig[$appId]['menu'])) {
                    $cate = Yii::$app->services->menuCate->createByAddon(
                        $appId,
                        $config->info,
                        $defaultConfig[$appId]['menu']['icon'],
                        $defaultConfig[$appId]['menu']['location'],
                        $defaultConfig[$appId]['menu']['sort'] ?? 999,
                        $defaultConfig[$appId]['menu']['pattern'] ?? []
                    );
                    Yii::$app->services->menu->delByCate($cate);
                    Yii::$app->services->menu->createByAddon($appConfig['menu'], $cate);
                }
            }

            Yii::$app->services->rbacAuthItemChild->accreditByAddon($allAuthItem, $name, $installData);
            // 更新信息
            $model = Yii::$app->services->addons->updateByName($name, $config, $defaultConfig);

            // 进行安装数据库
            if ($installData == true) {
                $installClass = AddonHelper::getAddonRoot($name) . $config->install;
                ExecuteHelper::map($installClass, 'run', $model);
            }

            $transaction->commit();

            return ResultHelper::json(200, '操作成功');
        } catch (\Exception $e) {
            $transaction->rollBack();
            return ResultHelper::json(422, $e->getMessage());
        }
    }

    /**
     * 升级数据库
     *
     * @return mixed
     * @throws \yii\web\NotFoundHttpException
     */
    public function actionUpgrade()
    {
        $name = Yii::$app->request->get('name');

        if (
            !($class = AddonHelper::getConfigClass($name)) ||
            !($model = Yii::$app->services->addons->findByName($name))
        ) {
            return $this->message('实例化失败,插件不存在或检查插件名称', $this->redirect(['index']), 'error');
        }

        // 更新数据库
        $upgradeClass = AddonHelper::getAddonRoot($name) . (new $class)->upgrade;
        if (!class_exists($upgradeClass)) {
            throw new NotFoundHttpException($upgradeClass . '未找到');
        }

        /** @var AddonWidget $upgradeModel */
        $upgradeModel = new $upgradeClass;
        if (!method_exists($upgradeModel, 'run')) {
            throw new NotFoundHttpException($upgradeClass . '/run方法未找到');
        }

        if (!isset($upgradeModel->versions)) {
            throw new NotFoundHttpException($upgradeClass . '下 versions 属性未找到');
        }

        $versions = $upgradeModel->versions;
        $count = count($versions);

        for ($i = 0; $i < $count; $i++) {
            // 验证版本号和更新
            if ($model->version == $versions[$i] && isset($versions[$i + 1])) {
                // 开启事务
                $transaction = Yii::$app->db->beginTransaction();
                try {
                    $model->version = $versions[$i + 1];
                    $upgradeModel->run($model);
                    $model->save();
                    // 完成事务
                    $transaction->commit();
                } catch (\Exception $e) {
                    // 回滚事务
                    $transaction->rollBack();
                    if (YII_DEBUG) {
                        throw new UnprocessableEntityHttpException($e->getMessage());
                    }

                    ob_clean();
                    return ResultHelper::json(422, $e->getMessage());
                }
            }
        }

        ob_clean();
        return ResultHelper::json(200, '升级数据库成功');
    }

    /**
     * 创建模块
     *
     * @return mixed|string
     */
    public function actionCreate()
    {
        $model = new AddonsForm();
        $data = Yii::$app->request->post();
        if ($model->load($data) && $model->validate()) {
            if (!is_writable(Yii::getAlias('@addons'))) {
                return $this->message('您没有创建目录写入权限，无法使用此功能', $this->redirect(['create']), 'error');
            }

            $addonDir = Yii::getAlias('@addons') . '/' . trim($model->name) . '/';
            if (is_dir($addonDir)) {
                return $this->message('插件已经存在，请删除后在试', $this->redirect(['create']), 'error');
            }

            // 创建目录结构
            $files = [];
            $files[] = $addonDir;
            $files[] = "{$addonDir}AddonConfig.php";

            $app = [
                AppEnum::BACKEND,
                AppEnum::FRONTEND,
                AppEnum::HTML5,
                AppEnum::OAUTH2,
                AppEnum::MERCHANT,
                AppEnum::API,
            ];

            $files[] = "{$addonDir}console/";
            $files[] = "{$addonDir}console/controllers/";
            $files[] = "{$addonDir}console/migrations/";
            $files[] = "{$addonDir}common/";
            $files[] = "{$addonDir}common/config/";
            $files[] = "{$addonDir}common/components/";
            $files[] = "{$addonDir}common/components/Bootstrap.php";
            $files[] = "{$addonDir}common/models/";
            $files[] = "{$addonDir}common/forms/";
            $files[] = "{$addonDir}common/models/DefaultModel.php";
            // 生成目录和空文件
            foreach ($app as $item) {
                $files[] = "{$addonDir}common/config/{$item}.php";
                $files[] = "{$addonDir}{$item}/";
                $files[] = "{$addonDir}{$item}/controllers/";

                if (!in_array($item,  AppEnum::api())) {
                    $files[] = "{$addonDir}{$item}/controllers/DefaultController.php";
                    $files[] = "{$addonDir}{$item}/views/";
                    $files[] = "{$addonDir}{$item}/views/layouts/";
                    $files[] = "{$addonDir}{$item}/views/layouts/main.php";
                    $files[] = "{$addonDir}{$item}/views/default/";
                    $files[] = "{$addonDir}{$item}/views/default/index.php";
                    $files[] = "{$addonDir}{$item}/assets/";
                    $files[] = "{$addonDir}{$item}/assets/AppAsset.php";
                    $files[] = "{$addonDir}{$item}/resources/";
                } else {
                    // api特殊目录
                    $files[] = "{$addonDir}{$item}/controllers/DefaultController.php";
                    $files[] = "{$addonDir}{$item}/modules/";
                    $files[] = "{$addonDir}{$item}/modules/v1/";
                    $files[] = "{$addonDir}{$item}/modules/v1/Module.php";
                    $files[] = "{$addonDir}{$item}/modules/v1/controllers/";
                    $files[] = "{$addonDir}{$item}/modules/v1/controllers/DefaultController.php";
                    $files[] = "{$addonDir}{$item}/modules/v2/";
                    $files[] = "{$addonDir}{$item}/modules/v2/Module.php";
                    $files[] = "{$addonDir}{$item}/modules/v2/controllers/";
                    $files[] = "{$addonDir}{$item}/modules/v2/controllers/DefaultController.php";
                }
            }

            // 参数设置支持
            $files[] = "{$addonDir}common/forms/SettingForm.php";
            $files[] = "{$addonDir}merchant/controllers/SettingController.php";
            $files[] = "{$addonDir}merchant/views/setting/";
            // 服务层支持
            $files[] = "{$addonDir}services/";
            $files[] = "{$addonDir}services/Application.php";
            $files[] = "{$addonDir}services/ConfigService.php";

            $model['install'] && $files[] = "{$addonDir}{$model['install']}.php";
            $model['uninstall'] && $files[] = "{$addonDir}{$model['uninstall']}.php";
            $model['upgrade'] && $files[] = "{$addonDir}{$model['upgrade']}.php";
            FileHelper::createDirOrFiles($files);

            // 写入文件
            foreach ($app as $item) {
                // 配置文件
                file_put_contents("{$addonDir}common/config/{$item}.php", $this->renderPartial('template/config/app', [
                    'menu' => $data['menu'] ?? [],
                    'appID' => $item,
                    'model' => $model
                ]));

                if (in_array($item, AppEnum::api())) {
                    // 默认控制器
                    file_put_contents("{$addonDir}{$item}/controllers/DefaultController.php", $this->renderPartial(
                        'template/controllers/ApiDefaultController',
                        ['model' => $model, 'appID' => $item]
                    ));
                    file_put_contents("{$addonDir}{$item}/modules/v1/controllers/DefaultController.php", $this->renderPartial(
                        'template/controllers/ApiModulesDefaultController',
                        ['appID' => $item, 'model' => $model, 'versions' => 'v1']
                    ));
                    file_put_contents("{$addonDir}{$item}/modules/v2/controllers/DefaultController.php", $this->renderPartial(
                        'template/controllers/ApiModulesDefaultController',
                        ['appID' => $item, 'model' => $model, 'versions' => 'v2']
                    ));

                    file_put_contents("{$addonDir}{$item}/modules/v1/Module.php", $this->renderPartial(
                        'template/ApiModules',
                        ['appID' => $item, 'model' => $model, 'versions' => 'v1']
                    ));
                    file_put_contents("{$addonDir}{$item}/modules/v2/Module.php", $this->renderPartial(
                        'template/ApiModules',
                        ['appID' => $item, 'model' => $model, 'versions' => 'v2']
                    ));

                    continue;
                }

                // 默认控制器
                file_put_contents("{$addonDir}{$item}/controllers/DefaultController.php", $this->renderPartial(
                    'template/controllers/DefaultController',
                    ['model' => $model, 'appID' => $item]
                ));
                // 基础控制器
                file_put_contents("{$addonDir}{$item}/controllers/BaseController.php", $this->renderPartial('template/controllers/BaseController', ['model' => $model, 'appID' => $item]));
                // 资源目录
                file_put_contents("{$addonDir}{$item}/resources/.gitkeep", '*');
                // 写入默认视图
                file_put_contents("{$addonDir}{$item}/views/default/index.php", $this->renderPartial('template/view/index', ['model' => $model, 'appID' => $item]));
                // 写入视图自动载入
                file_put_contents("{$addonDir}{$item}/views/layouts/main.php", $this->renderPartial('template/view/main', ['model' => $model, 'appID' => $item]));
                // 写入前台/后台/微信资源
                file_put_contents("{$addonDir}{$item}/assets/AppAsset.php", $this->renderPartial('template/AppAsset', ['model' => $model, 'appID' => $item]));
            }

            // 控制台控制器
            file_put_contents("{$addonDir}console/controllers/.gitkeep", '*');

            // 控制台数据迁移
            file_put_contents("{$addonDir}console/migrations/.gitkeep", '*');

            // 写入引导
            file_put_contents("{$addonDir}common/components/Bootstrap.php", $this->renderPartial('template/Bootstrap', ['model' => $model]));

            // 写入服务
            file_put_contents("{$addonDir}services/Application.php", $this->renderPartial('template/Application', ['model' => $model]));
            file_put_contents("{$addonDir}services/ConfigService.php", $this->renderPartial('template/ConfigService', ['model' => $model]));

            // 写入默认model
            file_put_contents("{$addonDir}common/models/DefaultModel.php", $this->renderPartial('template/models/DefaultModel', ['model' => $model, 'appID' => 'merchant']));

            // 参数设置支持
            file_put_contents("{$addonDir}merchant/controllers/SettingController.php", $this->renderPartial(
                'template/controllers/SettingController',
                ['model' => $model, 'appID' => 'merchant']
            ));
            file_put_contents("{$addonDir}common/forms/SettingForm.php", $this->renderPartial('template/forms/SettingFormModel', ['model' => $model, 'appID' => 'common']));
            file_put_contents("{$addonDir}merchant/views/setting/display.php", $this->renderPartial('template/view/display', ['model' => $model]));

            // 写入配置
            file_put_contents("{$addonDir}AddonConfig.php", $this->renderPartial('template/AddonConfig', [
                'model' => $model
            ]));

            // 写入文件
            $model['install'] && file_put_contents("{$addonDir}/{$model['install']}.php", $this->renderPartial('template/Install', ['model' => $model]));
            $model['uninstall'] && file_put_contents("{$addonDir}/{$model['uninstall']}.php", $this->renderPartial('template/UnInstall', ['model' => $model]));
            $model['upgrade'] && file_put_contents("{$addonDir}/{$model['upgrade']}.php", $this->renderPartial('template/Upgrade', ['model' => $model]));

            return $this->message('模块创建成功', $this->redirect(['local']));
        }

        return $this->render($this->action->id, [
            'model' => $model,
            'addonsGroup' => Yii::$app->params['addonsGroup'],
        ]);
    }
}