feat(app-store): 添加应用市场终端任务管理功能，增强校验安全性。 (#733)

Author: kanyxmo

plugin/mine-admin/app-store/install.lock

@@ -0,0 +1 @@
+1

plugin/mine-admin/app-store/src/Controller/IndexController.php

@@ -37,55 +37,64 @@ class IndexController extends AbstractController
     public Service $service;
 
     #[GetMapping('index')]
+    #[Permission(code: 'plugin:store:list')]
     public function index(): Result
     {
         return $this->success($this->serviceImpl->list($this->request->all()));
     }
 
     #[GetMapping('getPayApp')]
+    #[Permission(code: 'plugin:store:list')]
     public function getPayApp(): Result
     {
         return $this->success($this->serviceImpl->payApp());
     }
 
     #[GetMapping('getLocalAppInstallList')]
+    #[Permission(code: 'plugin:store:local-list')]
     public function getLocalAppInstallList(): Result
     {
         return $this->success($this->service->getLocalAppInstallList());
     }
 
     #[GetMapping('detail')]
+    #[Permission(code: 'plugin:store:detail')]
     public function detail(): Result
     {
         return $this->success($this->serviceImpl->view($this->request->input('identifier')));
     }
 
     #[PostMapping('download')]
+    #[Permission(code: 'plugin:store:download')]
     public function download(): Result
     {
         return $this->success(['result' => $this->service->download($this->request->all())]);
     }
 
     #[PostMapping('install')]
+    #[Permission(code: 'plugin:store:install')]
     public function install(): Result
     {
         return $this->success(['result' => $this->service->install($this->request->all())]);
     }
 
     #[PostMapping('unInstall')]
+    #[Permission(code: 'plugin:store:uninstall')]
     public function unInstall(): Result
     {
         return $this->success(['result' => $this->service->unInstall($this->request->all())]);
     }
 
     #[PostMapping('uploadLocalApp')]
+    #[Permission(code: 'plugin:store:upload')]
     public function uploadLocalApp(): Result
     {
         $this->service->uploadLocalApp($this->request->file('file'));
         return $this->success();
     }
 
     #[GetMapping('hasAccessToken')]
+    #[Permission(code: 'plugin:store:config')]
     public function hasAccessToken(): Result
     {
         return $this->success(['isHas' => env('MINE_ACCESS_TOKEN') !== null]);

plugin/mine-admin/app-store/src/Controller/TerminalController.php

@@ -0,0 +1,62 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Plugin\MineAdmin\AppStore\Controller;
+
+use App\Http\Admin\Middleware\PermissionMiddleware;
+use App\Http\Common\Middleware\AccessTokenMiddleware;
+use App\Http\Common\Result;
+use Hyperf\HttpServer\Annotation\Controller;
+use Hyperf\HttpServer\Annotation\GetMapping;
+use Hyperf\HttpServer\Annotation\Middleware;
+use Hyperf\HttpServer\Annotation\PostMapping;
+use Mine\Access\Attribute\Permission;
+use Plugin\MineAdmin\AppStore\Request\TerminalTaskRequest;
+use Plugin\MineAdmin\AppStore\Service\TerminalTaskService;
+
+#[Controller(prefix: 'admin/plugin/store/terminal')]
+#[Middleware(middleware: AccessTokenMiddleware::class, priority: 100)]
+#[Middleware(middleware: PermissionMiddleware::class, priority: 99)]
+#[Permission(code: 'plugin:store:terminal')]
+class TerminalController extends AbstractController
+{
+    public function __construct(
+        \Hyperf\HttpServer\Contract\RequestInterface $request,
+        private readonly TerminalTaskService $service
+    ) {
+        parent::__construct($request);
+    }
+
+    #[PostMapping('tasks')]
+    #[Permission(code: 'plugin:store:terminal')]
+    public function create(TerminalTaskRequest $request): Result
+    {
+        return $this->success($this->service->create($request->validated()));
+    }
+
+    #[GetMapping('tasks/{taskNo}')]
+    #[Permission(code: 'plugin:store:terminal')]
+    public function status(string $taskNo): Result
+    {
+        return $this->success($this->service->status($taskNo));
+    }
+
+    #[GetMapping('tasks/{taskNo}/logs')]
+    #[Permission(code: 'plugin:store:terminal')]
+    public function logs(string $taskNo): Result
+    {
+        return $this->success($this->service->logs(
+            $taskNo,
+            (int) $this->request->input('after_seq', 0),
+            (int) $this->request->input('limit', 200)
+        ));
+    }
+
+    #[PostMapping('tasks/{taskNo}/cancel')]
+    #[Permission(code: 'plugin:store:terminal:cancel')]
+    public function cancel(string $taskNo): Result
+    {
+        return $this->success($this->service->cancel($taskNo));
+    }
+}

plugin/mine-admin/app-store/src/Enum/TerminalAction.php

@@ -0,0 +1,60 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Plugin\MineAdmin\AppStore\Enum;
+
+enum TerminalAction: string
+{
+    case Download = 'download';
+    case Install = 'install';
+    case Uninstall = 'uninstall';
+    case FrontendDeps = 'frontend_deps';
+    case BackendDeps = 'backend_deps';
+    case InstallPnpm = 'install_pnpm';
+    case CheckEnvironment = 'check_environment';
+
+    public static function values(): array
+    {
+        return array_column(self::cases(), 'value');
+    }
+
+    public function permissionCode(): string
+    {
+        return match ($this) {
+            self::Download => 'plugin:store:terminal:download',
+            self::Install => 'plugin:store:terminal:install',
+            self::Uninstall => 'plugin:store:terminal:uninstall',
+            self::FrontendDeps => 'plugin:store:terminal:frontend-deps',
+            self::BackendDeps => 'plugin:store:terminal:backend-deps',
+            self::InstallPnpm => 'plugin:store:terminal:pnpm',
+            self::CheckEnvironment => 'plugin:store:terminal',
+        };
+    }
+
+    public function label(): string
+    {
+        return match ($this) {
+            self::Download => '下载插件',
+            self::Install => '安装插件',
+            self::Uninstall => '卸载插件',
+            self::FrontendDeps => '安装前端依赖',
+            self::BackendDeps => '安装后端依赖',
+            self::InstallPnpm => '安装 pnpm',
+            self::CheckEnvironment => '检查环境',
+        };
+    }
+
+    public function requiresIdentifier(): bool
+    {
+        return match ($this) {
+            self::Download,
+            self::Install,
+            self::Uninstall,
+            self::FrontendDeps,
+            self::BackendDeps => true,
+            self::InstallPnpm,
+            self::CheckEnvironment => false,
+        };
+    }
+}

plugin/mine-admin/app-store/src/Enum/TerminalStatus.php

@@ -0,0 +1,32 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Plugin\MineAdmin\AppStore\Enum;
+
+enum TerminalStatus: string
+{
+    case Pending = 'pending';
+    case Running = 'running';
+    case Success = 'success';
+    case Failed = 'failed';
+    case Cancelled = 'cancelled';
+    case Expired = 'expired';
+    case Lost = 'lost';
+
+    public static function terminalValues(): array
+    {
+        return [
+            self::Success->value,
+            self::Failed->value,
+            self::Cancelled->value,
+            self::Expired->value,
+            self::Lost->value,
+        ];
+    }
+
+    public function isTerminal(): bool
+    {
+        return in_array($this->value, self::terminalValues(), true);
+    }
+}

plugin/mine-admin/app-store/src/Request/TerminalTaskRequest.php

@@ -0,0 +1,23 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Plugin\MineAdmin\AppStore\Request;
+
+use App\Http\Common\Request\Traits\NoAuthorizeTrait;
+use Hyperf\Validation\Request\FormRequest;
+use Plugin\MineAdmin\AppStore\Enum\TerminalAction;
+
+class TerminalTaskRequest extends FormRequest
+{
+    use NoAuthorizeTrait;
+
+    public function rules(): array
+    {
+        return [
+            'action' => 'required|string|in:' . implode(',', TerminalAction::values()),
+            'identifier' => 'sometimes|nullable|string|max:120',
+            'version' => 'sometimes|nullable|string|max:80',
+        ];
+    }
+}