自定义 Builder ，职责分离 - 图1

Builder.php

  1. <?php
  3. namespace App\Extensions;
  5. use Illuminate\Database\Eloquent\Model;
  6. use Illuminate\Support\Facades\DB;
  7. use Illuminate\Support\Facades\Log;
  8. use Symfony\Component\HttpKernel\Exception\HttpException;
  9. use Illuminate\Database\Eloquent\Builder as EloquentBuilder;
  10. use Illuminate\Database\Query\Builder as QueryBuilder;
  11. use Throwable;
  13. /**
  14.  * @property-read Model                $model
  15.  * @property-read EloquentBuilder|null $query
  16.  * @property-read string|null          $table
  17.  * @property-read QueryBuilder|null    $rawQuery
  18.  */
  19. class Builder
  20. {
  21.     private ?string $modelClass = null;
  22.     private ?string $table      = null;
  24.     public function __get(string $name)
  25.     {
  26.         switch ($name) {
  27.             case 'table':
  28.                 if (!$this->table) {
  29.                     $this->table = $this->makeModel()->getTable();
  30.                 }
  31.                 return $this->table;
  32.             case 'model':
  33.                 return $this->makeModel();
  34.             case 'query':
  35.                 return $this->makeModel(false)::query();
  36.             case 'rawQuery':
  37.                 abort_if($this->table === null,'获取当前模型错误',403);
  39.                 return DB::table($this->table);
  40.             default:
  41.                 return null;
  42.         }
  43.     }
  45.     private function getModel(): string
  46.     {
  47.         if (!$this->modelClass) {
  48.             $baseName = last(explode('\\', get_called_class()));
  50.             if (str_ends_with($baseName, 'Service')) {
  51.                 $baseName = substr($baseName, 0, -7);
  52.             } else if (str_ends_with($baseName, 'Repository')) {
  53.                 $baseName = substr($baseName, 0, -10);
  54.             }
  56.             $class = 'App\\Models\\' . $baseName;
  58.             if (!class_exists($class)) {
  59.                 abort(500,'缺少模型');
  60.             }
  62.             $this->modelClass = $class;
  63.             return $this->modelClass;
  64.         }
  65.         return $this->modelClass;
  66.     }
  68.     private function makeModel($instance = true): Model|string
  69.     {
  71.         $class = $this->getModel();
  73.         if (!is_subclass_of($class, Model::class)) {
  74.             Log::error('模型文件错误');
  75.             abort(500,'模型文件错误');
  76.         }
  78.         if (!$instance) {
  79.             return $class;
  80.         }
  82.         try {
  83.             return app($class);
  84.         } catch (Throwable $e) {
  85.             throw new HttpException(500, $e->getMessage());
  86.         }
  87.     }
  89. }

BaseService.php

实现了增、删、改

<?php

namespace App\Services;

use App\Extensions\Builder;
use Illuminate\Database\Eloquent\Model;
use Illuminate\Database\Eloquent\Builder as EloquentBuilder;
use Illuminate\Database\Eloquent\ModelNotFoundException;
use Illuminate\Support\Facades\Log;

class BaseService extends Builder
{
    public function createOrUpdate(array $data, string $by = 'id'): Model|EloquentBuilder|null
    {
        if ($byVal = ($data[$by] ?? null)) {
            if ($by === 'id') {
                unset($data['id']);
            }

            return $this->query->updateOrCreate([$by => $byVal], $data);
        }

        return $this->query->create($data);
    }

    public function destroy(int $value, string $by = 'id')
    {
        if (blank($value)) {
           abort(422,'参数不能为空');
        }

        $m = $this->query->where($by, $value)->first();

        try {
            $m->delete();
        } catch (ModelNotFoundException) {
            abort(422,'数据不存在');
        } catch (\Exception $e) {
            Log::error('[' . class_basename($this) . '::destroy' . $e->getMessage());
            abort(500,'删除数据失败!');
        }
    }
}

BaseRepository.php

<?php

namespace App\Repository;

use App\Extensions\Builder;

abstract class BaseRepository extends Builder
{

}