增加QueryBuilderRepository

src/Actions/HasActionHandler.php

@@ -123,8 +123,9 @@ JS;
      */
     protected function handleHtmlResponse()
     {
+        // 处理返回的HTML代码
         return <<<'JS'
-function (target, html, data) { // 处理返回的HTML代码
+function (target, html, data) {
     target.html(html);
 }
 JS;

src/Repositories/QueryBuilderRepository.php

@@ -0,0 +1,475 @@
+<?php
+
+namespace Dcat\Admin\Repositories;
+
+use Dcat\Admin\Contracts\TreeRepository;
+use Dcat\Admin\Form;
+use Dcat\Admin\Grid;
+use Dcat\Admin\Show;
+use Illuminate\Database\Eloquent\Builder;
+use Illuminate\Support\Collection;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Str;
+
+class QueryBuilderRepository extends Repository implements TreeRepository
+{
+    /**
+     * @var string
+     */
+    protected $table;
+
+    /**
+     * @var string
+     */
+    protected $connection;
+
+    /**
+     * @var string
+     */
+    protected $createdAtColumn = 'created_at';
+
+    /**
+     * @var string
+     */
+    protected $updatedAtColumn = 'updated_at';
+
+    /**
+     * @var Builder
+     */
+    protected $queryBuilder;
+
+    /**
+     * QueryBuilderRepository constructor.
+     */
+    public function __construct()
+    {
+        $this->initQueryBuilder();
+    }
+
+    /**
+     * 初始化.
+     */
+    protected function initQueryBuilder()
+    {
+        $this->queryBuilder = $this->connection
+            ? DB::connection($this->connection)->table($this->getTable())
+            : DB::table($this->getTable());
+    }
+
+    /**
+     * @return string
+     */
+    public function getTable()
+    {
+        return $this->table;
+    }
+
+    /**
+     * @return string
+     */
+    public function getCreatedAtColumn()
+    {
+        return $this->createdAtColumn;
+    }
+
+    /**
+     * @return string
+     */
+    public function getUpdatedAtColumn()
+    {
+        return $this->updatedAtColumn;
+    }
+
+    /**
+     * 获取列表页面查询的字段.
+     *
+     * @return array
+     */
+    public function getGridColumns()
+    {
+        return ['*'];
+    }
+
+    /**
+     * 获取表单页面查询的字段.
+     *
+     * @return array
+     */
+    public function getFormColumns()
+    {
+        return ['*'];
+    }
+
+    /**
+     * 获取详情页面查询的字段.
+     *
+     * @return array
+     */
+    public function getDetailColumns()
+    {
+        return ['*'];
+    }
+
+    /**
+     * 查询Grid表格数据.
+     *
+     * @param Grid\Model $model
+     *
+     * @return \Illuminate\Contracts\Pagination\LengthAwarePaginator|Collection|array
+     */
+    public function get(Grid\Model $model)
+    {
+        $this->setSort($model);
+        $this->setPaginate($model);
+
+        $query = $this->newQuery();
+
+        $model->getQueries()->unique()->each(function ($value) use (&$query) {
+            if ($value['method'] == 'paginate') {
+                $value['arguments'][1] = $this->getGridColumns();
+            } elseif ($value['method'] == 'get') {
+                $value['arguments'] = [$this->getGridColumns()];
+            }
+
+            $query = call_user_func_array([$query, $value['method']], $value['arguments'] ?? []);
+        });
+
+        return $query;
+    }
+
+    /**
+     * 设置表格数据排序.
+     *
+     * @param Grid\Model $model
+     *
+     * @return void
+     */
+    protected function setSort(Grid\Model $model)
+    {
+        [$column, $type] = $model->getSort();
+
+        if (empty($column) || empty($type)) {
+            return;
+        }
+
+        if (Str::contains($column, '.')) {
+            $this->setRelationSort($model, $column, $type);
+        } else {
+            $model->resetOrderBy();
+
+            $model->addQuery('orderBy', [$column, $type]);
+        }
+    }
+
+    /**
+     * 设置关联数据排序.
+     *
+     * @param Grid\Model $model
+     * @param string     $column
+     * @param string     $type
+     *
+     * @return void
+     */
+    protected function setRelationSort(Grid\Model $model, $column, $type)
+    {
+        [$relationName, $relationColumn] = explode('.', $column);
+
+        if ($model->getQueries()->contains(function ($query) use ($relationName) {
+            return $query['method'] == 'with' && in_array($relationName, $query['arguments']);
+        })) {
+            $model->addQuery('select', [$this->getGridColumns()]);
+
+            $model->resetOrderBy();
+
+            $model->addQuery('orderBy', [
+                $relationColumn,
+                $type,
+            ]);
+        }
+    }
+
+    /**
+     * 设置分页参数.
+     *
+     * @param Grid\Model $model
+     *
+     * @return void
+     */
+    protected function setPaginate(Grid\Model $model)
+    {
+        $paginate = $model->findQueryByMethod('paginate');
+
+        $model->rejectQuery(['paginate']);
+
+        if (! $model->allowPagination()) {
+            $model->addQuery('get', [$this->getGridColumns()]);
+        } else {
+            $model->addQuery('paginate', $this->resolvePerPage($model, $paginate));
+        }
+    }
+
+    /**
+     * 获取分页参数.
+     *
+     * @param Grid\Model $model
+     * @param array|null $paginate
+     *
+     * @return array
+     */
+    protected function resolvePerPage(Grid\Model $model, $paginate)
+    {
+        if ($paginate && is_array($paginate)) {
+            if ($perPage = request()->input($model->getPerPageName())) {
+                $paginate['arguments'][0] = (int) $perPage;
+            }
+
+            return $paginate['arguments'];
+        }
+
+        return [
+            $model->getPerPage(),
+            $this->getGridColumns(),
+            $model->getPageName(),
+            $model->getCurrentPage(),
+        ];
+    }
+
+    /**
+     * 查询编辑页面数据.
+     *
+     * @param Form $form
+     *
+     * @return array
+     */
+    public function edit(Form $form): array
+    {
+        $result = $this->newQuery()
+            ->where($this->getKeyName(), $form->getKey())
+            ->first($this->getFormColumns());
+
+        if (! $result) {
+            abort(404);
+        }
+
+        return (array) $result;
+    }
+
+    /**
+     * 查询详情页面数据.
+     *
+     * @param Show $show
+     *
+     * @return array
+     */
+    public function detail(Show $show): array
+    {
+        $result = $this->newQuery()
+            ->where($this->getKeyName(), $show->getKey())
+            ->first($this->getDetailColumns());
+
+        if (! $result) {
+            abort(404);
+        }
+
+        return (array) $result;
+    }
+
+    /**
+     * 新增记录.
+     *
+     * @param Form $form
+     *
+     * @return mixed
+     */
+    public function store(Form $form)
+    {
+        $result = null;
+
+        DB::transaction(function () use ($form, &$result) {
+            $result = $this->newQuery()
+                ->insertGetId($form->updates());
+        });
+
+        return $result;
+    }
+
+    /**
+     * 查询更新前的行数据.
+     *
+     * @param Form $form
+     *
+     * @return array
+     */
+    public function getDataWhenUpdating(Form $form): array
+    {
+        return $this->edit($form);
+    }
+
+    /**
+     * 更新数据.
+     *
+     * @param Form $form
+     *
+     * @return bool
+     */
+    public function update(Form $form)
+    {
+        $result = null;
+
+        DB::transaction(function () use ($form, &$result) {
+            $result = $this->newQuery()
+                ->where($this->getKeyName(), $form->getKey())
+                ->limit(1)
+                ->update($form->updates());
+        });
+
+        return $result;
+    }
+
+    /**
+     * 数据行排序上移一个单位.
+     *
+     * @return bool
+     */
+    public function moveOrderUp()
+    {
+        throw new \RuntimeException('Not support.');
+    }
+
+    /**
+     * 数据行排序下移一个单位.
+     *
+     * @return bool
+     */
+    public function moveOrderDown()
+    {
+        throw new \RuntimeException('Not support.');
+    }
+
+    /**
+     * 删除数据.
+     *
+     * @param Form $form
+     *
+     * @return bool
+     */
+    public function destroy(Form $form, array $deletingData)
+    {
+        $id = $form->getKey();
+
+        $deletingData = collect($deletingData)->keyBy($this->getKeyName());
+
+        collect(explode(',', $id))->filter()->each(function ($id) use ($form, $deletingData) {
+            $data = $deletingData->get($id, []);
+
+            if (! $data) {
+                return;
+            }
+
+            $form->deleteFiles($data);
+
+            $this->newQuery()
+                ->where($this->getKeyName(), $id)
+                ->limit(1)
+                ->delete();
+        });
+
+        return true;
+    }
+
+    /**
+     * 查询删除前的行数据.
+     *
+     * @param Form $form
+     *
+     * @return array
+     */
+    public function getDataWhenDeleting(Form $form): array
+    {
+        $query = $this->newQuery();
+
+        $id = $form->getKey();
+
+        return $query
+            ->whereIn(
+                $this->getKeyName(),
+                collect(explode(',', $id))->filter()->toArray()
+            )
+            ->get($this->getFormColumns())
+            ->transform(function ($value) {
+                return (array) $value;
+            })
+            ->toArray();
+    }
+
+    /**
+     * 获取父级ID字段名称.
+     *
+     * @return string
+     */
+    public function getParentColumn()
+    {
+        throw new \RuntimeException('Not support.');
+    }
+
+    /**
+     * 获取标题字段名称.
+     *
+     * @return string
+     */
+    public function getTitleColumn()
+    {
+        throw new \RuntimeException('Not support.');
+    }
+
+    /**
+     * 获取排序字段名称.
+     *
+     * @return string
+     */
+    public function getOrderColumn()
+    {
+        throw new \RuntimeException('Not support.');
+    }
+
+    /**
+     * 保存层级数据排序.
+     *
+     * @param array $tree
+     * @param int   $parentId
+     */
+    public function saveOrder($tree = [], $parentId = 0)
+    {
+        throw new \RuntimeException('Not support.');
+    }
+
+    /**
+     * 设置数据查询回调.
+     *
+     * @param \Closure|null $query
+     *
+     * @return $this
+     */
+    public function withQuery($queryCallback)
+    {
+        throw new \RuntimeException('Not support.');
+    }
+
+    /**
+     * 获取层级数据.
+     *
+     * @return array
+     */
+    public function toTree()
+    {
+        throw new \RuntimeException('Not support.');
+    }
+
+    /**
+     * @return Builder
+     */
+    protected function newQuery()
+    {
+        return clone $this->queryBuilder;
+    }
+}