580 lines
14 KiB
PHP
580 lines
14 KiB
PHP
<?php
|
||
|
||
namespace top\library;
|
||
|
||
/**
|
||
* 基础模型
|
||
* @author topnuomi 2018年11月23日
|
||
*/
|
||
class Model
|
||
{
|
||
|
||
// 数据库操作实例
|
||
private $db;
|
||
|
||
// 当前表名
|
||
protected $table;
|
||
|
||
// 主键
|
||
protected $pk = '';
|
||
|
||
// 字段映射
|
||
protected $map = [];
|
||
|
||
// insert值映射
|
||
protected $inReplace = [];
|
||
|
||
// update值映射
|
||
protected $updateReplace = [];
|
||
|
||
// 出库值映射
|
||
protected $outReplace = [];
|
||
|
||
// 模型消息（请注意：在方法中赋值会覆盖掉数据验证的message）
|
||
protected $message = '';
|
||
|
||
// 自动验证
|
||
protected $validate = [];
|
||
|
||
// 是否为insert操作，决定如何验证数据
|
||
// true：验证模型中配置的全部字段
|
||
// false：仅验证$data中存在的字段
|
||
private $isInsert = false;
|
||
|
||
/**
|
||
* 用数据库配置获取实例
|
||
* Model constructor.
|
||
* @param string $table
|
||
*/
|
||
public function __construct($table = '')
|
||
{
|
||
if ($table) {
|
||
$this->table = $table;
|
||
} else if (!$this->table) {
|
||
$table = get_table_name(get_called_class());
|
||
$this->table = $table;
|
||
}
|
||
// $this->getDb() = Database::table($this->table, $this->pk);
|
||
}
|
||
|
||
/**
|
||
* 获取Database实例
|
||
* @return mixed
|
||
*/
|
||
private function getDb()
|
||
{
|
||
return Database::table($this->table, $this->pk);
|
||
}
|
||
|
||
/**
|
||
* 影响的表（仅多表delete）
|
||
* @param $effect
|
||
* @return $this
|
||
*/
|
||
public function effect($effect)
|
||
{
|
||
$this->getDb()->effect($effect);
|
||
return $this;
|
||
}
|
||
|
||
/**
|
||
* 过滤重复值的字段
|
||
* @param $field
|
||
* @return $this
|
||
*/
|
||
public function distinct($field)
|
||
{
|
||
$this->getDb()->distinct($field);
|
||
return $this;
|
||
}
|
||
|
||
/**
|
||
* 指定字段
|
||
* @param $field
|
||
* @return $this
|
||
*/
|
||
public function field($field)
|
||
{
|
||
$this->getDb()->field($field);
|
||
return $this;
|
||
}
|
||
|
||
/**
|
||
* 查询条件
|
||
* @return $this
|
||
*/
|
||
public function where()
|
||
{
|
||
call_user_func_array([
|
||
$this->getDb(),
|
||
'where'
|
||
], func_get_args());
|
||
return $this;
|
||
}
|
||
|
||
/**
|
||
* 排序
|
||
* @return $this
|
||
*/
|
||
public function order()
|
||
{
|
||
call_user_func_array([
|
||
$this->getDb(),
|
||
'order'
|
||
], func_get_args());
|
||
return $this;
|
||
}
|
||
|
||
/**
|
||
* 限制
|
||
* @return $this
|
||
*/
|
||
public function limit()
|
||
{
|
||
call_user_func_array([
|
||
$this->getDb(),
|
||
'limit'
|
||
], func_get_args());
|
||
return $this;
|
||
}
|
||
|
||
/**
|
||
* 多表
|
||
* @param $type
|
||
* @param $table
|
||
* @param $name
|
||
* @return $this
|
||
*/
|
||
public function join($type, $table, $name)
|
||
{
|
||
$this->getDb()->join($type, $table, $name);
|
||
return $this;
|
||
}
|
||
|
||
/**
|
||
* 多表
|
||
* @param $on
|
||
* @return $this
|
||
*/
|
||
public function on($on)
|
||
{
|
||
$this->getDb()->on($on);
|
||
return $this;
|
||
}
|
||
|
||
/**
|
||
* 插入记录
|
||
* @param array $data
|
||
* @return bool
|
||
*/
|
||
public function insert($data = [])
|
||
{
|
||
$this->isInsert = true;
|
||
$data = $this->processData($data);
|
||
if ($data) {
|
||
// 此处取消了数据验证，在$this->>data()方法中验证，减少一次数据库查询
|
||
// 入库时最后的数据处理
|
||
$data = $this->inHandle($data);
|
||
return $this->getDb()->insert($data);
|
||
}
|
||
return false;
|
||
}
|
||
|
||
/**
|
||
* 删除记录
|
||
* @param string|bool $param
|
||
* @return number|boolean
|
||
*/
|
||
public function delete($param = false)
|
||
{
|
||
return $this->getDb()->delete($param);
|
||
}
|
||
|
||
/**
|
||
* 更新记录
|
||
* @param $data
|
||
* @param string|bool $param
|
||
* @return bool
|
||
*/
|
||
public function update($data, $param = false)
|
||
{
|
||
$this->isInsert = false;
|
||
$data = $this->processData($data);
|
||
if ($data) {
|
||
// 此处取消了数据验证，在$this->data()方法中验证，减少一次数据库查询
|
||
// 入库时最后的数据处理
|
||
$data = $this->inHandle($data);
|
||
return $this->getDb()->update($data, $param);
|
||
}
|
||
return false;
|
||
}
|
||
|
||
/**
|
||
* 查询单条记录
|
||
* @param string|bool $param
|
||
* @param bool $notRaw
|
||
* @return array
|
||
*/
|
||
public function find($param = false, $notRaw = true)
|
||
{
|
||
$result = $this->getDb()->find($param);
|
||
if ($notRaw) {
|
||
if (is_array($result)) {
|
||
$result = $this->outHandle($result);
|
||
}
|
||
}
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* 查询所有记录
|
||
* @param string|bool $param
|
||
* @param bool $notRaw
|
||
* @return array
|
||
*/
|
||
public function select($param = false, $notRaw = true)
|
||
{
|
||
$result = $this->getDb()->select($param);
|
||
if ($notRaw) {
|
||
if (is_array($result)) {
|
||
$result = $this->outHandle($result);
|
||
}
|
||
}
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* 计数
|
||
* @param string $param
|
||
* @return mixed
|
||
*/
|
||
public function count($param = '')
|
||
{
|
||
return $this->getDb()->common($param, 'count');
|
||
}
|
||
|
||
/**
|
||
* 平均值
|
||
* @param string $param
|
||
* @return mixed
|
||
*/
|
||
public function avg($param = '')
|
||
{
|
||
return $this->getDb()->common($param, 'avg');
|
||
}
|
||
|
||
/**
|
||
* 最大值
|
||
* @param string $param
|
||
* @return mixed
|
||
*/
|
||
public function max($param = '')
|
||
{
|
||
return $this->getDb()->common($param, 'max');
|
||
}
|
||
|
||
/**
|
||
* 最小值
|
||
* @param string $param
|
||
* @return mixed
|
||
*/
|
||
public function min($param = '')
|
||
{
|
||
return $this->getDb()->common($param, 'min');
|
||
}
|
||
|
||
/**
|
||
* 求和
|
||
* @param string $param
|
||
* @return mixed
|
||
*/
|
||
public function sum($param = '')
|
||
{
|
||
return $this->getDb()->common($param, 'sum');
|
||
}
|
||
|
||
/**
|
||
* 执行一条SQL
|
||
* @param $query
|
||
* @return mixed
|
||
*/
|
||
public function query($query)
|
||
{
|
||
return $this->getDb()->query($query);
|
||
}
|
||
|
||
/**
|
||
* 获取最后一次执行的SQL
|
||
*
|
||
* @return string
|
||
*/
|
||
public function _sql()
|
||
{
|
||
return $this->getDb()->_sql();
|
||
}
|
||
|
||
/**
|
||
* 获取表单数据
|
||
* @param array $data
|
||
* @param bool $notRaw
|
||
* @return array|bool
|
||
*/
|
||
public function data($data = [], $notRaw = true)
|
||
{
|
||
$mapData = $this->processMapped($data);
|
||
if ($mapData) { // 如果正确处理字段映射并且数据验证通过
|
||
if (!$notRaw) {
|
||
return $mapData;
|
||
} else {
|
||
$data = [];
|
||
$prefix = Config::instance()->get('db')['prefix'];
|
||
$tableDesc = $this->tableDesc($prefix . $this->table);
|
||
foreach ($tableDesc as $value) {
|
||
if (array_key_exists($value['Field'], $mapData)) {
|
||
// 如果表单值为空则赋值为数据库字段默认值
|
||
if (!$mapData[$value['Field']] && !is_numeric($mapData[$value['Field']])) {
|
||
$mapData[$value['Field']] = $value['Default'];
|
||
}
|
||
$data[$value['Field']] = $mapData[$value['Field']];
|
||
}
|
||
}
|
||
return $data;
|
||
}
|
||
}
|
||
return false;
|
||
}
|
||
|
||
/**
|
||
* 处理字段映射并验证数据
|
||
* @param array $data
|
||
* @return array|bool
|
||
*/
|
||
private function processMapped($data = [])
|
||
{
|
||
$data = (empty($data)) ? $_POST : $data;
|
||
foreach ($data as $key => $value) {
|
||
foreach ($this->map as $k => $v) {
|
||
if ($key == $k) {
|
||
$data[$v] = $value;
|
||
unset($data[$key]);
|
||
}
|
||
}
|
||
}
|
||
// 验证数据
|
||
if ($this->validate($data)) {
|
||
return $data;
|
||
}
|
||
return false;
|
||
}
|
||
|
||
/**
|
||
* 入库前进行数据处理
|
||
* @param $data
|
||
* @return array|bool
|
||
*/
|
||
private function processData($data)
|
||
{
|
||
if (is_callable($data)) {
|
||
// 如果$data是匿名函数，则处理$this->data()处理post的数据
|
||
$modelData = $this->data();
|
||
if ($modelData) {
|
||
$data = $data($modelData);
|
||
} else {
|
||
return false;
|
||
}
|
||
} else if (empty($data)) {
|
||
// 如果$data为空，则直接赋值为$this->data()
|
||
$data = $this->data();
|
||
} else {
|
||
// 否则用$this->data()处理$data的字段映射
|
||
$data = $this->data($data);
|
||
}
|
||
return $data;
|
||
}
|
||
|
||
/**
|
||
* 入库时替换值
|
||
*
|
||
* @param array $data
|
||
* @return array
|
||
*/
|
||
private function inHandle($data)
|
||
{
|
||
$replace = ($this->isInsert) ? $this->inReplace : $this->updateReplace;
|
||
foreach ($replace as $key => $value) {
|
||
$fieldValue = '';
|
||
if (!array_key_exists($key, $data)) {
|
||
$data[$key] = '';
|
||
}
|
||
if (is_array($value)) {
|
||
if (isset($value[1]) && $value[1] === true) {
|
||
$object = get_called_class();
|
||
if (method_exists($object, $value[0])) {
|
||
$methodName = $value[0];
|
||
$fieldValue = call_user_func_array([
|
||
new $object(),
|
||
$methodName
|
||
], [
|
||
$data[$key]
|
||
]);
|
||
}
|
||
} else if (isset($value[0]) && function_exists($value[0])) {
|
||
$fieldValue = $value[0]($data[$key]);
|
||
} else {
|
||
$fieldValue = isset($value[0]) ? $value[0] : $data[$key];
|
||
}
|
||
} else if (function_exists($value)) {
|
||
$fieldValue = $value($data[$key]);
|
||
} else {
|
||
$fieldValue = $value;
|
||
}
|
||
$data[$key] = $fieldValue;
|
||
}
|
||
return $data;
|
||
}
|
||
|
||
/**
|
||
* 出库时替换值
|
||
*
|
||
* @param array $data
|
||
* @return array
|
||
*/
|
||
private function outHandle($data)
|
||
{
|
||
foreach ($this->outReplace as $key => $value) {
|
||
if (count($data) == count($data, 1)) {
|
||
if (array_key_exists($key, $data)) {
|
||
$data[$key] = $this->callOutReplaceFunction($data[$key], $value);
|
||
}
|
||
} else {
|
||
foreach ($data as $k => $v) {
|
||
if (array_key_exists($key, $v)) {
|
||
$data[$k][$key] = $this->callOutReplaceFunction($data[$k][$key], $value);
|
||
}
|
||
}
|
||
}
|
||
}
|
||
return $data;
|
||
}
|
||
|
||
/**
|
||
* 调用函数、方法替换值
|
||
* @param $value
|
||
* @param $function
|
||
* @return mixed
|
||
*/
|
||
private function callOutReplaceFunction($value, $function)
|
||
{
|
||
if (is_array($function) && (isset($function[1]) && $function[1] === true)) {
|
||
$value = $this->{$function[0]}($value);
|
||
} else {
|
||
if (is_array($function)) {
|
||
$function = $function[0];
|
||
}
|
||
if (function_exists($function)) {
|
||
$value = $function($value);
|
||
}
|
||
}
|
||
return $value;
|
||
}
|
||
|
||
/**
|
||
* 验证表单
|
||
* @param $data
|
||
* @return bool
|
||
*/
|
||
private function validate($data)
|
||
{
|
||
foreach ($this->validate as $key => $value) {
|
||
if (is_array($value)) {
|
||
if (count($value) == count($value, 1)) {
|
||
if (!$this->validateCallUserFunction($key, $value, $data)) {
|
||
return false;
|
||
}
|
||
} else {
|
||
foreach ($value as $k => $v) {
|
||
if (!$this->validateCallUserFunction($key, $v, $data)) {
|
||
return false;
|
||
}
|
||
}
|
||
}
|
||
} /*else {
|
||
throw new BaseException('自动验证值必须为数组');
|
||
}*/
|
||
}
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 调用对应验证函数（如果update时不想验证数据，请在之前unset掉对应键值）
|
||
* @param string $key
|
||
* @param $validate
|
||
* @param $data
|
||
* @return bool
|
||
*/
|
||
private function validateCallUserFunction($key, $validate, $data)
|
||
{
|
||
$funcName = $validate[0];
|
||
$tips = end($validate);
|
||
// 将第一个值赋值为将要检查的值
|
||
if (array_key_exists($key, $data)) {
|
||
$validate[0] = $data[$key];
|
||
unset($validate[count($validate) - 1]);
|
||
if (call_user_func_array($funcName, $validate) === false) {
|
||
$this->message = $tips;
|
||
return false;
|
||
}
|
||
} else {
|
||
if ($this->isInsert) {
|
||
$this->message = $tips;
|
||
return false;
|
||
}
|
||
}
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 获取表结构
|
||
* @param $table
|
||
* @return mixed
|
||
*/
|
||
public function tableDesc($table)
|
||
{
|
||
return $this->getDb()->tableDesc($table);
|
||
}
|
||
|
||
/**
|
||
* 获取信息
|
||
* @return string
|
||
*/
|
||
public function getMessage()
|
||
{
|
||
return $this->message;
|
||
}
|
||
|
||
/**
|
||
* 某些方法提供以下替代方式
|
||
* @param $name
|
||
* @return array|mixed|null
|
||
*/
|
||
public function __get($name)
|
||
{
|
||
$data = null;
|
||
switch ($name) {
|
||
case 'one':
|
||
$data = $this->find();
|
||
break;
|
||
case 'all':
|
||
$data = $this->select();
|
||
break;
|
||
case 'sql':
|
||
$data = $this->_sql();
|
||
break;
|
||
default:
|
||
$data = $this->$name();
|
||
}
|
||
return $data;
|
||
}
|
||
|
||
}
|