超管后台 - 添加管理员返工

2025-04-17 17:15:21 +08:00
parent 49900ba9cb
commit 4f838149e9
4 changed files with 184 additions and 24 deletions
--- a/Server/application/superadmin/controller/administrator/AddAdministratorController.php
+++ b/Server/application/superadmin/controller/administrator/AddAdministratorController.php
@@ -0,0 +1,151 @@
+<?php
+
+namespace app\superadmin\controller\administrator;
+
+use app\common\model\Administrator as AdministratorModel;
+use app\common\model\AdministratorPermissions as AdministratorPermissionsModel;
+use app\superadmin\controller\BaseController;
+use think\Controller;
+use think\Db;
+use think\Validate;
+
+/**
+ * 管理员控制器
+ */
+class AddAdministratorController extends BaseController
+{
+    /**
+     * 检查账号是否已存在
+     *
+     * @param string $account
+     * @return void
+     * @throws \Exception
+     */
+    protected function chekAdminIsExist(string $account)
+    {
+        $exists = AdministratorModel::where('account', $account)->where('deleteTime', 0)->count() > 0;
+
+        if ($exists) {
+            throw new \Exception('账号已存在', 400);
+        }
+    }
+
+    /**
+     * 数据验证
+     *
+     * @param array $params
+     * @return $this
+     * @throws \Exception
+     */
+    protected function dataValidate(array $params): self
+    {
+        $validate = Validate::make([
+            'account' => 'require|/\S+/',
+            'name' => 'require|/\S+/',
+            'password' => 'require|/\S+/',
+            'permissionIds' => 'require|array',
+        ]);
+
+        if (!$validate->check($params)) {
+            throw new \Exception($validate->getError(), 400);
+        }
+
+        return $this;
+    }
+
+    /**
+     * 判断是否有权限修改
+     *
+     * @return $this
+     */
+    protected function checkPermission(): self
+    {
+        if ($this->getAdminInfo('id') != 1) {
+            throw new \Exception('您没有权限添加管理员', 403);
+        }
+
+        return $this;
+    }
+
+    /**
+     * 保存管理员权限
+     *
+     * @param int $adminId 管理员ID
+     * @param array $permissionIds 权限ID数组
+     * @return bool
+     */
+    protected function savePermissions(int $adminId, array $permissionIds)
+    {
+        $record = AdministratorPermissionsModel::where('adminId', $adminId)->find();
+
+        $permissionData = [
+            'ids' => is_array($permissionIds) ? implode(',', $permissionIds) : $permissionIds
+        ];
+
+        if ($record) {
+            return $record->save([
+                'permissions' => json_encode($permissionData),
+            ]);
+        } else {
+            return AdministratorPermissionsModel::create([
+                'adminId' => $adminId,
+                'permissions' => json_encode($permissionData),
+            ]);
+        }
+    }
+
+    /**
+     * 添加管理员信息
+     *
+     * @param array $params
+     * @return AdministratorModel
+     * @throws \Exception
+     */
+    protected function addAdministrator(array $params): AdministratorModel
+    {
+        $result = AdministratorModel::create(array_merge($params, ['password' => md5($params['password'])]));
+
+        if (!$result) {
+            throw new \Exception('添加管理员失败', 401);
+        }
+
+        return $result;
+    }
+
+    /**
+     * 添加管理员
+     *
+     * @return \think\response\Json
+     */
+    public function index()
+    {
+        try {
+            $params = $this->request->only(['account', 'name', 'password', 'permissionIds']);
+
+            $this->dataValidate($params);
+            $this->checkPermission()->chekAdminIsExist($params['account']);
+
+            Db::startTrans();
+            $admin = $this->addAdministrator($params);
+
+            // 保存权限
+            if (!empty($params['permissionIds'])) {
+                $this->savePermissions($admin->id, $params['permissionIds']);
+            }
+
+            Db::commit();
+
+            return json([
+                'code' => 200,
+                'msg' => '添加成功',
+            ]);
+        } catch (\Exception $e) {
+            Db::rollback();
+
+            return json([
+                'code' => $e->getCode(),
+                'msg' => $e->getMessage()
+            ]);
+        }
+    }
+}