307 lines
9.2 KiB
PHP
307 lines
9.2 KiB
PHP
|
<?php
|
|||
|
|
|
|||
|
|
namespace app\service;
|
|||
|
|
|
|||
|
|
use Exception;
|
|||
|
|
use think\db\exception\DataNotFoundException;
|
|||
|
|
use think\db\exception\DbException;
|
|||
|
|
use think\db\exception\ModelNotFoundException;
|
|||
|
|
use think\Model;
|
|||
|
|
use think\facade\Db;
|
|||
|
|
use think\Collection;
|
|||
|
|
use think\facade\Env;
|
|||
|
|
use think\facade\Log;
|
|||
|
|
use think\Paginator;
|
|||
|
|
use app\exception\RepositoryException;
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 领域模型-仓储
|
|||
|
|
*
|
|||
|
|
* Class Repository
|
|||
|
|
* @package app\service
|
|||
|
|
*/
|
|||
|
|
class Repository
|
|||
|
|
{
|
|||
|
|
/**
|
|||
|
|
* @var array 已加载对象列表
|
|||
|
|
*/
|
|||
|
|
private static $objects = [];
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @var Model 模型对象
|
|||
|
|
*/
|
|||
|
|
protected $model;
|
|||
|
|
|
|||
|
|
// 布尔值数字关系
|
|||
|
|
public const BOOL_FALSE = 0;
|
|||
|
|
public const BOOL_TRUE = 1;
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 获取当前子对象实列（单例形式返回）
|
|||
|
|
*
|
|||
|
|
* @param Model|null $model 模型对象。未指定则自动获取
|
|||
|
|
* @return mixed
|
|||
|
|
*/
|
|||
|
|
public static function getInstance(Model $model = null)
|
|||
|
|
{
|
|||
|
|
$class = get_called_class();
|
|||
|
|
|
|||
|
|
if (isset(self::$objects[$class]) && self::$objects[$class] !== null) {
|
|||
|
|
return self::$objects[$class];
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
$obj = new $class();
|
|||
|
|
if ($model) {
|
|||
|
|
$obj->model = $model;
|
|||
|
|
} elseif (strpos($class, '\\repository') > 0) {
|
|||
|
|
$model = str_replace('\\repository', '\\model', $class);
|
|||
|
|
//去掉末尾Repository app\model\AccountRepository =》 app\model\Account
|
|||
|
|
$model = substr($model, 0, strlen($model) - strlen('Repository'));
|
|||
|
|
if (class_exists($model)) {
|
|||
|
|
$obj->model = new $model;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
self::$objects[$class] = $obj;
|
|||
|
|
return $obj;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @param callable $callback
|
|||
|
|
* @param mixed $failReturn
|
|||
|
|
* @param bool $transaction
|
|||
|
|
* @return mixed
|
|||
|
|
* @throws RepositoryException
|
|||
|
|
*/
|
|||
|
|
protected function access(callable $callback, $failReturn, bool $transaction = false)
|
|||
|
|
{
|
|||
|
|
$exception = null;
|
|||
|
|
try {
|
|||
|
|
if ($transaction) {
|
|||
|
|
Db::startTrans();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
$r = $callback();
|
|||
|
|
|
|||
|
|
if ($transaction) {
|
|||
|
|
Db::commit();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if ($r) {
|
|||
|
|
return $r;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if ($failReturn instanceof Exception) {
|
|||
|
|
return null;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return $failReturn;
|
|||
|
|
} catch (Exception $e) {
|
|||
|
|
if ($transaction) {
|
|||
|
|
Db::rollback();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if ($e instanceof RepositoryException) {
|
|||
|
|
throw $e;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
$name = 'Domain - Repository - 未知错误';
|
|||
|
|
|
|||
|
|
$traces = $e->getTrace();
|
|||
|
|
|
|||
|
|
foreach ($traces as $i => $trace) {
|
|||
|
|
if (!empty($trace['class']) && $trace['class'] === Repository::class && $trace['function'] === 'access') {
|
|||
|
|
$trace = $traces[$i - 2] ?? null;
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if (!empty($trace) && !empty($trace['file'][1]) && !empty($trace['line'])) {
|
|||
|
|
$parts = explode('application\\', $trace['file']);
|
|||
|
|
if (!empty($parts[1])) {
|
|||
|
|
$name = $parts[1].':'.$trace['line'];
|
|||
|
|
} else {
|
|||
|
|
$name = $trace['file'].':'.$trace['line'];
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
$exception = $e;
|
|||
|
|
|
|||
|
|
$line = '['.$name.'] '.$e->getMessage();
|
|||
|
|
Log::error($line);
|
|||
|
|
|
|||
|
|
throw new RepositoryException('Repository异常'.(Env::get('app_debug') ? ': '.$line : ''), 5009);
|
|||
|
|
} finally {
|
|||
|
|
if ($exception && $failReturn instanceof RepositoryException) {
|
|||
|
|
if (Env::get('app_debug')) {
|
|||
|
|
$failReturn = new RepositoryException($failReturn->getMessage().': '.$exception->getMessage(),
|
|||
|
|
$failReturn->getCode());
|
|||
|
|
}
|
|||
|
|
throw $failReturn;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 获取当前model对象
|
|||
|
|
*
|
|||
|
|
* @return Model
|
|||
|
|
*/
|
|||
|
|
public function getModel(): Model
|
|||
|
|
{
|
|||
|
|
return $this->model;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 根据条件查询列表
|
|||
|
|
*
|
|||
|
|
* @param array $where 查询条件
|
|||
|
|
* @param array $fields 查询字段 []表示全部
|
|||
|
|
* @param int $page 默认第一页 0不限制
|
|||
|
|
* @param int $limit 限制条数 0不限制
|
|||
|
|
* @param callable|null $callback 更为复杂的条件 使用闭包查询
|
|||
|
|
* @return array
|
|||
|
|
* @throws RepositoryException
|
|||
|
|
*/
|
|||
|
|
public function findList(array $where = [], array $fields = [], int $page = 1, int $limit = 0, callable $callback = null, array $order = []): ?array
|
|||
|
|
{
|
|||
|
|
$failData = [
|
|||
|
|
'total' => 0,
|
|||
|
|
'current' => $page,
|
|||
|
|
'size' => $limit,
|
|||
|
|
'list' => new Collection(),
|
|||
|
|
];
|
|||
|
|
return $this->access(function () use ($where, $fields, $page, $limit, $callback, $order) {
|
|||
|
|
return $this->model->findList($where, $fields, $page, $limit, $callback, $order);
|
|||
|
|
}, $failData);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 根据条件查询列表[带分页 适用于后台]
|
|||
|
|
*
|
|||
|
|
* @param array $data 查询数据
|
|||
|
|
* @param array $pageParams 分页参数
|
|||
|
|
* @param callable|null $callback 复杂查询条件 使用闭包查询
|
|||
|
|
* @return Paginator
|
|||
|
|
*/
|
|||
|
|
public function findListWithPaginate(array $data = [], array $pageParams = [], callable $callback = null): Paginator
|
|||
|
|
{
|
|||
|
|
return $this->model->findListWithPaginate($data, $pageParams, $callback);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 根据主键 ID 查询
|
|||
|
|
*
|
|||
|
|
* @param int $id ID
|
|||
|
|
* @param array $fields 要返回的字段，默认全部
|
|||
|
|
* @return Mixed
|
|||
|
|
* @throws RepositoryException
|
|||
|
|
*/
|
|||
|
|
public function findById(int $id, array $fields = [], callable $callback = null)
|
|||
|
|
{
|
|||
|
|
return $this->access(function () use ($id, $fields, $callback) {
|
|||
|
|
return $this->model->findById($id, $fields, $callback);
|
|||
|
|
}, null);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @param array $where
|
|||
|
|
* @param array $fields
|
|||
|
|
* @return array|Model|null
|
|||
|
|
* @throws DataNotFoundException
|
|||
|
|
* @throws DbException
|
|||
|
|
* @throws ModelNotFoundException
|
|||
|
|
*/
|
|||
|
|
public function findOneByWhere(array $where, array $fields = [])
|
|||
|
|
{
|
|||
|
|
return $this->model->field($fields)->where($where)->find();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 创建
|
|||
|
|
*
|
|||
|
|
* @param array $data 数据
|
|||
|
|
* @return Model
|
|||
|
|
* @throws RepositoryException
|
|||
|
|
*/
|
|||
|
|
public function create(array $data): Model
|
|||
|
|
{
|
|||
|
|
return $this->access(function () use ($data) {
|
|||
|
|
return $this->model->create($data);
|
|||
|
|
}, new RepositoryException('创建失败'));
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 更新
|
|||
|
|
*
|
|||
|
|
* @param array $data 数据
|
|||
|
|
* @param array $where 条件
|
|||
|
|
* @return bool|Exception
|
|||
|
|
* @throws RepositoryException
|
|||
|
|
*/
|
|||
|
|
public function update(array $data, array $where): bool
|
|||
|
|
{
|
|||
|
|
return $this->access(function () use ($data, $where) {
|
|||
|
|
return $this->model->where($where)->find()->save($data);
|
|||
|
|
}, new RepositoryException('更新失败'));
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 删除
|
|||
|
|
*
|
|||
|
|
* @param array $where 删除条件
|
|||
|
|
* @param bool $softDelete 是否软删除 默认false
|
|||
|
|
* @param string $softDeleteTime 删除时间 softDelete=true时有效
|
|||
|
|
* @param string $softDeleteField 软删除字段 softDelete=true时有效
|
|||
|
|
* @return bool
|
|||
|
|
* @throws RepositoryException
|
|||
|
|
*/
|
|||
|
|
public function delete(array $where, bool $softDelete = false, string $softDeleteTime = '', string $softDeleteField = 'deleted_at'): bool
|
|||
|
|
{
|
|||
|
|
return $this->access(function () use ($where, $softDelete, $softDeleteField, $softDeleteTime) {
|
|||
|
|
// 注意：如果model中引入了软删除trait，$softDelete又设置false 将无法正确删除
|
|||
|
|
return $this->model->where($where)
|
|||
|
|
->when($softDelete, function ($q) use ($softDeleteField, $softDeleteTime) {
|
|||
|
|
$softDeleteTime = $softDeleteTime ?: date('Y-m-d H:i:s');
|
|||
|
|
$q->useSoftDelete($softDeleteField, $softDeleteTime);
|
|||
|
|
})->delete();
|
|||
|
|
}, false);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 排序
|
|||
|
|
*
|
|||
|
|
* @param int $id 排序ID
|
|||
|
|
* @param string $type 排序类型 向上、向下
|
|||
|
|
* @param int $num 移动位数
|
|||
|
|
* @param string $listType 列表的排序类型 降序｜升序
|
|||
|
|
* @param array $where 额外条件 格式如：
|
|||
|
|
* $map[] = ['name','like','think'];
|
|||
|
|
* $map[] = ['status','=',1];
|
|||
|
|
* @return array
|
|||
|
|
*/
|
|||
|
|
public function sort(int $id,string $type,int $num,string $listType, array $where = []): array
|
|||
|
|
{
|
|||
|
|
return $this->model->sort($id, $type, $num, $listType, $where);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 日志记录
|
|||
|
|
*
|
|||
|
|
* @param string $msg
|
|||
|
|
* @param Exception|null $e
|
|||
|
|
* @param string $level
|
|||
|
|
* @param string $channel
|
|||
|
|
*/
|
|||
|
|
public static function log(string $msg, Exception $e = null, string $level = 'error', string $channel = 'file')
|
|||
|
|
{
|
|||
|
|
if ($e != null) {
|
|||
|
|
$msg = sprintf("[%s]%s:%s %s", $msg, $e->getFile(), $e->getLine(), $e->getMessage());
|
|||
|
|
} else {
|
|||
|
|
$msg = sprintf("%s", $msg);
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
Log::channel($channel)->$level($msg);
|
|||
|
|
}
|
|||
|
|
}
|