123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570 |
- <?php
- namespace app\controller;
- use Illuminate\Database\Eloquent\Builder as EloquentBuilder;
- use Illuminate\Database\Query\Builder as QueryBuilder;
- use app\common\Auth;
- use app\common\Tree;
- use app\common\Util;
- use support\CustomException;
- use support\exception\BusinessException;
- use support\Model;
- use support\Request;
- use support\Response;
- use Tinywan\Jwt\JwtToken;
- class Curd
- {
- /**
- * @var Model
- */
- protected $model = null;
- /**
- * 数据限制
- * 例如当$dataLimit='personal'时将只返回当前管理员的数据
- * @var string
- */
- protected $dataLimit = null;
- /**
- * 数据限制字段
- */
- protected $dataLimitField = 'user_id';
- /**
- * 是否开启写操作验证
- */
- protected $validate = false;
- /**
- * 验证类
- */
- protected $validateClass = '';
- /**
- * 查询
- * @param Request $request
- * @return Response
- * @throws BusinessException
- */
- public function select(Request $request): Response
- {
- [$where, $format, $limit, $field, $order] = $this->selectInput($request);
- $query = $this->doSelect($where, $field, $order);
- return $this->doFormat($query, $format, $limit);
- }
- /**
- * @Desc 记录详情
- * @Author Gorden
- * @Date 2024/3/18 14:22
- *
- * @param Request $request
- * @return Response
- */
- public function info(Request $request): Response
- {
- $primaryKey = $this->model->getKeyName();
- $validateArr = [
- $primaryKey => $request->get('id')
- ];
- if ($this->validate && !$this->validateClass->scene('info')->check($validateArr)) {
- return json_fail($this->validateClass->getError());
- }
- $data = $this->model->where($primaryKey, $request->get('id'))->first();
- if (method_exists($this, "afterInfoQuery")) {
- $data = call_user_func([$this, "afterInfoQuery"], $data);
- }
- return json_success('', $data);
- }
- /**
- * 添加
- * @param Request $request
- * @return Response
- * @throws BusinessException
- */
- public function insert(Request $request): Response
- {
- if ($this->validate && !$this->validateClass->scene('add')->check($request->post())) {
- return json_fail($this->validateClass->getError());
- }
- try {
- $data = $this->insertInput($request);
- $this->doInsert($data);
- } catch (BusinessException $customException) {
- return json_fail($customException->getMessage());
- } catch (\Exception $e) {
- dump($e->getMessage());
- return json_fail('数据写入失败11');
- }
- return json_success('success');
- }
- /**
- * 更新
- * @param Request $request
- * @return Response
- * @throws BusinessException
- */
- public function update(Request $request): Response
- {
- if ($this->validate && !$this->validateClass->scene('update')->check($request->post())) {
- return json_fail($this->validateClass->getError());
- }
- try {
- [$id, $data] = $this->updateInput($request);
- $this->doUpdate($id, $data);
- } catch (BusinessException $e) {
- return json_fail($e->getMessage());
- } catch (\Exception $e) {
- dump($e->getMessage());
- return json_fail('数据更新失败');
- }
- return json_success('success');
- }
- /**
- * 删除
- * @param Request $request
- * @return Response
- * @throws BusinessException
- */
- public function delete(Request $request): Response
- {
- $ids = $this->deleteInput($request);
- $this->doDelete($ids);
- return json_success('success');
- }
- /**
- * @Desc 软删除
- * @Author Gorden
- * @Date 2024/2/26 9:27
- *
- * @param Request $request
- * @return Response
- * @throws BusinessException
- */
- public function softDelete(Request $request): Response
- {
- $ids = $this->deleteInput($request);
- $this->doSoftDelete($ids, ['is_del' => 1]);
- return json_success('success');
- }
- /**
- * 查询前置
- * @param Request $request
- * @return array
- * @throws BusinessException
- */
- protected function selectInput(Request $request): array
- {
- $field = $request->get('field');
- $order = $request->get('order', 'asc');
- $format = $request->get('format', 'normal');
- $limit = (int)$request->get('pageSize', $format === 'tree' ? 1000 : 10);
- $limit = $limit <= 0 ? 10 : $limit;
- $order = $order === 'asc' ? 'asc' : 'desc';
- $where = $request->get();
- $page = (int)$request->get('page');
- $page = $page > 0 ? $page : 1;
- $table = config('database.connections.mysql.prefix') . $this->model->getTable();
- $allow_column = Util::db()->select("desc `$table`");
- if (!$allow_column) {
- throw new BusinessException('表不存在');
- }
- $allow_column = array_column($allow_column, 'Field', 'Field');
- if (!in_array($field, $allow_column)) {
- $field = null;
- }
- foreach ($where as $column => $value) {
- if (
- $value === '' || !isset($allow_column[$column]) ||
- is_array($value) && (empty($value) || !in_array($value[0], ['null', 'not null']) && !isset($value[1]))
- ) {
- unset($where[$column]);
- }
- if (!is_array($value) && substr($value, 0,5) == 'like,') {
- $where[$column] = explode(',',$value);
- }
- }
- // 按照数据限制字段返回数据
- if ($this->dataLimit === 'personal') {
- $where[$this->dataLimitField] = JwtToken::getCurrentId();
- } elseif ($this->dataLimit === 'auth') {
- $primary_key = $this->model->getKeyName();
- if (!Auth::isSupperAdmin() && (!isset($where[$primary_key]) || $this->dataLimitField != $primary_key)) {
- $where[$this->dataLimitField] = ['in', Auth::getScopeAdminIds(true)];
- }
- }
- return [$where, $format, $limit, $field, $order, $page];
- }
- /**
- * 指定查询where条件,并没有真正的查询数据库操作
- * @param array $where
- * @param string|null $field
- * @param string $order
- * @return EloquentBuilder|QueryBuilder|Model
- */
- protected function doSelect(array $where, string $field = null, string $order = 'desc')
- {
- $model = $this->model;
- foreach ($where as $column => $value) {
- if (is_array($value)) {
- if ($value[0] === 'like' || $value[0] === 'not like') {
- $model = $model->where($column, $value[0], "%$value[1]%");
- } elseif (in_array($value[0], ['>', '=', '<', '<>'])) {
- $model = $model->where($column, $value[0], $value[1]);
- } elseif ($value[0] == 'in' && !empty($value[1])) {
- $valArr = $value[1];
- if (is_string($value[1])) {
- $valArr = explode(",", trim($value[1]));
- }
- $model = $model->whereIn($column, $valArr);
- } elseif ($value[0] == 'not in' && !empty($value[1])) {
- $valArr = $value[1];
- if (is_string($value[1])) {
- $valArr = explode(",", trim($value[1]));
- }
- $model = $model->whereNotIn($column, $valArr);
- } elseif ($value[0] == 'null') {
- $model = $model->whereNull($column);
- } elseif ($value[0] == 'not null') {
- $model = $model->whereNotNull($column);
- } elseif ($value[0] !== '' || $value[1] !== '') {
- $model = $model->whereBetween($column, $value);
- }
- } else {
- $model = $model->where($column, $value);
- }
- }
- if ($field) {
- $model = $model->orderBy($field, $order);
- }
- return $model;
- }
- /**
- * 执行真正查询,并返回格式化数据
- * @param $query
- * @param $format
- * @param $limit
- * @return Response
- */
- protected function doFormat($query, $format, $limit): Response
- {
- $methods = [
- 'select' => 'formatSelect',
- 'tree' => 'formatTree',
- 'table_tree' => 'formatTableTree',
- 'normal' => 'formatNormal',
- ];
- $paginator = $query->paginate($limit);
- $total = $paginator->total();
- $items = $paginator->items();
- if (method_exists($this, "afterQuery")) {
- $items = call_user_func([$this, "afterQuery"], $items);
- }
- $format_function = $methods[$format] ?? 'formatNormal';
- return call_user_func([$this, $format_function], $items, $total);
- }
- /**
- * 插入前置方法
- * @param Request $request
- * @return array
- * @throws BusinessException
- */
- protected function insertInput(Request $request): array
- {
- $data = $this->inputFilter($request->post());
- $password_filed = 'password';
- if (isset($data[$password_filed])) {
- $data[$password_filed] = Util::passwordHash($data[$password_filed]);
- }
- if (!Auth::isSupperAdmin() && $this->dataLimit) {
- if (!empty($data[$this->dataLimitField])) {
- $admin_id = $data[$this->dataLimitField];
- if (!in_array($admin_id, Auth::getScopeAdminIds(true))) {
- throw new BusinessException('无数据权限');
- }
- }
- }
- return $data;
- }
- /**
- * 执行插入
- * @param array $data
- * @return mixed|null
- */
- protected function doInsert(array $data)
- {
- $primary_key = $this->model->getKeyName();
- $model_class = get_class($this->model);
- $model = new $model_class;
- foreach ($data as $key => $val) {
- $model->{$key} = $val;
- }
- $model->save();
- return $primary_key ? $model->$primary_key : null;
- }
- /**
- * 更新前置方法
- * @param Request $request
- * @return array
- * @throws BusinessException
- */
- protected function updateInput(Request $request): array
- {
- $primary_key = $this->model->getKeyName();
- $id = $request->post($primary_key);
- $data = $this->inputFilter($request->post());
- $model = $this->model->find($id);
- if (!$model) {
- throw new BusinessException('记录不存在', 2);
- }
- if (!Auth::isSupperAdmin() && $this->dataLimit) {
- $scopeAdminIds = Auth::getScopeAdminIds(true);
- $admin_ids = [
- $data[$this->dataLimitField] ?? false, // 检查要更新的数据admin_id是否是有权限的值
- $model->{$this->dataLimitField} ?? false // 检查要更新的记录的admin_id是否有权限
- ];
- foreach ($admin_ids as $admin_id) {
- if ($admin_id && !in_array($admin_id, $scopeAdminIds)) {
- throw new BusinessException('无数据权限');
- }
- }
- }
- $password_filed = 'password';
- if (isset($data[$password_filed])) {
- // 密码为空,则不更新密码
- if ($data[$password_filed] === '') {
- unset($data[$password_filed]);
- } else {
- $data[$password_filed] = Util::passwordHash($data[$password_filed]);
- }
- }
- unset($data[$primary_key]);
- return [$id, $data];
- }
- /**
- * @Desc 更新单个字段
- * @Author Gorden
- * @Date 2024/2/28 10:31
- *
- * @param $primaryValue
- * @param $field
- * @param $value
- * @return Response
- */
- protected function updateField($primaryValue, $field, $value)
- {
- try {
- $primaryKey = $this->model->getKeyName();
- $this->model->where($primaryKey, $primaryValue)->update([$field => $value]);
- } catch (\Exception $e) {
- return json_fail($e->getMessage());
- }
- return json_success('success');
- }
- /**
- * 执行更新
- * @param $id
- * @param $data
- * @return void
- */
- protected function doUpdate($id, $data)
- {
- $model = $this->model->find($id);
- foreach ($data as $key => $val) {
- $model->{$key} = $val;
- }
- $model->save();
- }
- /**
- * 对用户输入表单过滤
- * @param array $data
- * @return array
- * @throws BusinessException
- */
- protected function inputFilter(array $data): array
- {
- $table = config('database.connections.mysql.prefix') . $this->model->getTable();
- $allow_column = $this->model->getConnection()->select("desc `$table`");
- if (!$allow_column) {
- throw new BusinessException('表不存在', 2);
- }
- $columns = array_column($allow_column, 'Type', 'Field');
- foreach ($data as $col => $item) {
- if (!isset($columns[$col])) {
- unset($data[$col]);
- continue;
- }
- // 非字符串类型传空则为null
- if ($item === '' && strpos(strtolower($columns[$col]), 'varchar') === false && strpos(strtolower($columns[$col]), 'text') === false) {
- $data[$col] = null;
- }
- if (is_array($item)) {
- $data[$col] = implode(',', $item);
- }
- if ($item != '' && (strpos(strtolower($columns[$col]), 'varchar') || strpos(strtolower($columns[$col]), 'text'))) {
- // $data[$col] = htmlspecialchars($item);
- }
- }
- if (empty($data['created_at'])) {
- unset($data['created_at']);
- }
- if (empty($data['updated_at'])) {
- unset($data['updated_at']);
- }
- return $data;
- }
- /**
- * 删除前置方法
- * @param Request $request
- * @return array
- * @throws BusinessException
- */
- protected function deleteInput(Request $request): array
- {
- $primary_key = $this->model->getKeyName();
- if (!$primary_key) {
- throw new BusinessException('该表无主键,不支持删除');
- }
- $ids = (array)$request->post($primary_key, []);
- if (!Auth::isSupperAdmin() && $this->dataLimit) {
- $admin_ids = $this->model->where($primary_key, $ids)->pluck($this->dataLimitField)->toArray();
- if (array_diff($admin_ids, Auth::getScopeAdminIds(true))) {
- throw new BusinessException('无数据权限');
- }
- }
- return $ids;
- }
- /**
- * 执行删除
- * @param array $ids
- * @return void
- */
- protected function doDelete(array $ids)
- {
- if (!$ids) {
- return;
- }
- $primary_key = $this->model->getKeyName();
- $this->model->whereIn($primary_key, $ids)->delete();
- }
- /**
- * @Desc 执行软删除
- * @Author Gorden
- * @Date 2024/2/26 9:27
- *
- * @param array $ids
- * @return void
- */
- protected function doSoftDelete(array $ids, $data)
- {
- if (!$ids) {
- return;
- }
- $primary_key = $this->model->getKeyName();
- $this->model->whereIn($primary_key, $ids)->update($data);
- }
- /**
- * 格式化树
- * @param $items
- * @return Response
- */
- protected function formatTree($items): Response
- {
- $format_items = [];
- foreach ($items as $item) {
- $format_items[] = [
- 'name' => $item->title ?? $item->name ?? $item->id,
- 'value' => (string)$item->id,
- 'id' => $item->id,
- 'pid' => $item->pid,
- ];
- }
- $tree = new Tree($format_items);
- return json_success('success', $tree->getTree());
- }
- /**
- * 格式化表格树
- * @param $items
- * @return Response
- */
- protected function formatTableTree($items): Response
- {
- $tree = new Tree($items);
- return json_success('success', $tree->getTree());
- }
- /**
- * 格式化下拉列表
- * @param $items
- * @return Response
- */
- protected function formatSelect($items): Response
- {
- $formatted_items = [];
- foreach ($items as $item) {
- $formatted_items[] = [
- 'name' => $item->title ?? $item->name ?? $item->id,
- 'value' => $item->id
- ];
- }
- return json_success('success', $formatted_items);
- }
- /**
- * 通用格式化
- * @param $items
- * @param $total
- * @return Response
- */
- protected function formatNormal($items, $total): Response
- {
- $data = [
- 'total' => $total,
- 'rows' => $items
- ];
- return json(['code' => 200, 'msg' => 'success', 'data' => $data]);
- }
- /**
- * 查询数据库后置方法,可用于修改数据
- * @param mixed $items 原数据
- * @return mixed 修改后数据
- */
- protected function afterQuery($items)
- {
- return $items;
- }
- }
|