farm/mazephp/.svn/pristine/e4/e496de3cd38198c2a98281767f1630623bfd50d9.svn-base

<?php namespace Maze\Data;

use Maze\Debug\Process as Debug;
use Maze\Config\Load as Config;
use Maze\Http\Output;
use Maze\Http\Input;
use Maze\Routing\Load;

class Model
{
	/**
     * database
     *
     * @var array
     */
	protected $database;

	/**
     * config
     *
     * @var array
     */
	protected $config;

	/**
     * db
     *
     * @var Object
     */
	protected $db;

	/**
     * __construct
     *
     * @return mixd
     */
	public function __construct($config)
	{
		$this->config =& $config;

		$this->database = Config::get('database', $config['project']);
	}

	/**
     * db
     *
     * @return mixd
     */
	protected function db($key = '')
	{
		if(!$key)
		{
			$key = isset($this->config['project']) ? $this->config['project'] : MAZE_PROJECT_NAME;
		}

		if(empty($this->database[$key]))
		{
			if(empty($this->database['default']))
			{
				Output::abert('core_database_exists', $key);
			}
			$this->database[$key] = $this->database['default'];
		}

		if(empty($this->db[$key]))
		{
			//$this->config['name'] = $key . '_' . $this->config['name'];
			
			$method = 'Maze\\Data\\' . ucwords($this->database[$key]['type']) . '\\Store';

			$this->db[$key] = new $method($this->database[$key]);

			$this->db[$key]->table($key . '_' . $this->config['name']);

			# 建表
			if(isset($this->config['struct']))
			{
				$create = $this->db[$key]->create($this->config['struct']);
				if($create === true)
				{
					# 写入默认值
					if(isset($this->config['default']))
					{
						$this->db[$key]->inserts($this->config['default']);
					}
				}
				else
				{
					if(isset($create['struct']))
					{
						if(count($create['struct']) < count($this->config['struct']))
						{
							$alter = array_diff_key($this->config['struct'], $create['struct']);
							if($alter)
							{
								$this->db[$key]->alter($alter, $this->config['struct']);
							}
						}
					}
					
					# 更改表结构
					if(isset($this->config['alter']))
					{
						$this->db[$key]->alter($this->config['alter']);
					}
				}				

				# 建立索引
				if(isset($this->config['index']))
				{
					$this->db[$key]->index($this->config['index']);
				}
			}
		}

		return $this->db[$key];
	}
	
	/**
     * 获取匹配的类型
     *
     * @return mixd
     */
	private function type($method)
	{
		switch($method)
		{
			case 1:
				$method = '=';
				break;
			case 2:
				$method = 'like';
				break;
			case 3:
				$method = '>';
				break;
			case 4:
				$method = '>=';
				break;
			case 5:
				$method = '<';
				break;
			case 6:
				$method = '<=';
				break;
		}
		
		return $method;
	}
	
	/**
     * # 初始化默认方法one、list、update、insert、delete、total、all、check
     *
     * @return mixd
     */
	private function init($method, $param = array())
	{
		$array = array();
		$type = '';
		
		$this->config['request'][$method] = array
		(
			'type' => $method,
			'where' => array('id' => 'yes'),
		);
		
		# 支持单独字段更新
		$key = '';
		if(strpos($method, 'update_') !== false)
		{
			$key = str_replace('update_', '', $method);
			if($key && isset($this->config['struct'][$key]))
			{
				$match = $this->config['struct'][$key]['match'];
				if(is_array($this->config['struct'][$key]['match']))
				{
					$match = $this->config['struct'][$key]['match'][0];
				}
				$this->config['request'][$method]['type'] = 'update';
				$this->config['request'][$method]['set'][$key] = $match;
				$this->config['request'][$method]['where']['id'] = 'yes';

				return;
			}
		}

		switch($method)
		{
			case 'one':
			case 'delete':
				break;
			case 'updatemul':
				#批量更新操作，仅仅开启了mul_type配置或者后台可用
				if(isset(Config::$global['base']['mul_type']) && Config::$global['base']['mul_type'] > 0)
				{
					$this->config['request'][$method]['type'] = 'update';

					if(Config::$global['base']['mul_type'] == 2)
					{
						unset($this->config['request'][$method]['where']);
						$type = 'option';
					}
					else
					{
						$type = 'mul';
						$this->config['request'][$method]['where']['id'] = array('yes', 'in');
					}
				}

				break;
			case 'update':
				$type = 'set';
				$this->config['request'][$method]['input'] = false;
				break;
			case 'insert':
				$this->config['request'][$method]['input'] = false;
				unset($this->config['request'][$method]['where']);
				$type = 'add';
				break;
			case 'state':
				$this->config['request']['state'] = array
				(
					'type' => 'one',
					'where' => array
					(
						'state' => 1,
						'id' => 'yes'
					)
				);
				break;
			case 'list':
				$type = 'option';
				$this->config['request']['list'] = array
				(
					'type' => 'all',
					'order' => array('id', 'desc'),
					'page' => array(15, 'list'),
					'col' => '*|id',
					'option' => array(),
				);
				
				if(isset($this->config['manage']['list_type']) && $this->config['manage']['list_type'] == 'parent')
				{
					$this->config['request']['list']['page'][0] = 500;
				}
				
				if(isset(Config::$global['base']['excel']))
				{
					unset($this->config['request']['list']['page']);
				}
				break;
			case 'all':
				$type = 'option';
				$this->config['request']['all'] = array
				(
					'type' => 'all',
					'order' => array('id', 'desc'),
					'col' => '*|id',
					'where' => array
					(
						'state' => 1,
					),
					'option' => array(),
					'input' => false,
				);
				break;
			case 'check':
				$type = 'option';
				$this->config['request']['check'] = array
				(
					'type' => 'one',
					'col' => '*',
					'where' => array
					(
						'state' => 1,
					),
					'option' => array(),
					'input' => false,
				);
				break;
			case 'total':
				$type = 'option';
				$this->config['request']['total'] = array
				(
					'type' => 'all',
					'col' => 'count(*) as total',
					'group' => array('month'),
					'option' => array(),
				);
				break;
			default:
				unset($this->config['request'][$method]);
				break;
		}

		if($type)
		{
			if($type == 'option')
			{
				$param['search_type'] = isset($param['search_type']) ? $param['search_type'] : Input::get('search_fulltext_type', 1);
				
				$param['search_type'] = $this->type($param['search_type']);
			}
			foreach($this->config['struct'] as $k => $v)
			{
				if(isset($v['match']))
				{
					# 这里增加value，用以区分update/select的值
					if(is_array($v['match']))
					{
						$v['value'] = $v['match'][1];
						$v['match'] = $v['match'][0];
					}
					else
					{
						$v['value'] = $v['match'];
					}
					
					# 首先匹配批量更新
					if($method == 'updatemul' && isset($v['update']) && $v['update'] == 'radio' && (is_array($v['option']) || is_object($v['option'])))
					{
						$this->config['request'][$method]['set'][$k] = $v['value'];
					}

					if($type == 'option')
					{
						# 位运算
						if(isset($v['bit']))
						{
							$this->config['request'][$method][$type][$k] = array('option', '&');
						}
						# 默认排序
						elseif(isset($v['order']))
						{
							if(isset($this->config['request'][$method]['order']))
							{
								if($this->config['request'][$method]['order'][0] && $this->config['request'][$method]['order'][0] != $k)
								{
									$this->config['request'][$method]['order'][0] = $k . '` '.(is_string($v['order']) ? $v['order'] : 'desc').',`' . $this->config['request'][$method]['order'][0];
								}
							}
						}
						# 全文检索
						if(isset($v['search']) && strpos($v['search'], 'fulltext') !== false)
						{
							$this->config['request'][$method][$type][$k] = array('option', $param['search_type']);
						}
						# 时间区间
						elseif(isset($v['search']) && (strpos($v['search'], 'time') !== false || strpos($v['search'], 'date') !== false))
						{
							$this->config['request'][$method][$type]['start_' . $k] = array('yes-' . $k, '>=');
							$this->config['request'][$method][$type]['end_' . $k] = array('yes-' . $k, '<=');
						}
						else
						{
							$this->config['request'][$method][$type][$k] = $v['match'];
						}
					}
					elseif($type != 'mul' && !isset($v['table']))
					{
						if(!empty($v['insert']) && $type == 'set')
						{
							
						}
						else
						{
							$this->config['request'][$method][$type][$k] = $v['value'];
						}
					}
				}
			}
		}
		
		//print_r($_POST);die;
		//print_r($this->config['request'][$method]);die;
	}

	/**
     * method
     *
     * @return mixd
     */
	public function method($method = 'one', $param = array())
	{
		if(isset($param[0]) && is_array($param[0]))
		{
			$result = array();
			foreach($param as $k => $v)
			{
				$result[] = $this->method($method, $v);
			}
			
			return $result;
		}

		if(!isset($this->config['request'][$method])) $this->init($method, $param);
		
		//print_r($this->config['request']);die;
		
		$this->config['param'] = array();
		if(isset($this->config['request']) && isset($this->config['request'][$method]))
		{
			$this->hook('request', 'onload');
			$this->hook($method, 'start');
			
			if($param && !is_array($param))
			{
				$param = array('where_id' => $param, 'option_id' => $param);
			}
				
			# 验证头部权限
			if(isset($this->config['auth']) && is_string($this->config['auth']))
			{
				$value = isset($param[$this->config['auth_key']]) ? $param[$this->config['auth_key']] : Input::get($this->config['auth_key']);
				if($value)
				{
					$top['value'] = $value;
				}
				else
				{
					$top = Load::get('manage/auth.getTop', array($this->config['auth']));
				}

				if($top)
				{
					if(!Input::get('where_' . $this->config['auth_key'])) Input::set('where_' . $this->config['auth_key'], $top['value']);
					if(!Input::get('option_' . $this->config['auth_key'])) Input::set('option_' . $this->config['auth_key'], $top['value']);
					if(!Input::get('set_' . $this->config['auth_key'])) Input::set('set_' . $this->config['auth_key'], $top['value']);
					if(!Input::get('add_' . $this->config['auth_key'])) Input::set('add_' . $this->config['auth_key'], $top['value']);
					
					if(!isset($param['where_' . $this->config['auth_key']])) $param['where_' . $this->config['auth_key']] = $top['value'];
					if(!isset($param['option_' . $this->config['auth_key']])) $param['option_' . $this->config['auth_key']] = $top['value'];
					if(!isset($param['set_' . $this->config['auth_key']])) $param['set_' . $this->config['auth_key']] = $top['value'];
					if(!isset($param['add_' . $this->config['auth_key']])) $param['add_' . $this->config['auth_key']] = $top['value'];
				}
			}

			if($param)
			{
				$this->config['param'] =& $param;
			}
			
			# 创建全局参数，给hook使用
			Config::$global['base']['_param'] =& $this->config['param'];
			
			$this->config['response'] = $this->config['request'][$method];
			
			$this->config['input'] = true;
			
			if(isset($this->config['response']['input']))
			{
				$this->config['input'] = $this->config['response']['input'];
			}

			$this->push(array('where', 'add', 'set', 'option'))->condition(array('page', 'order', 'limit', 'group'));

			$type = isset($this->config['response']['type']) ? $this->config['response']['type'] : $method;

			$this->config['response']['col'] = isset($this->config['response']['col']) ? $this->config['response']['col'] : '';

			$data = $this->db()->$type($this->config['response']['col']);
			
			$this->hook($method, 'end', $data);
			
			return $data;
		}

		return array();
	}

	/**
     * hook 插件钩子处理
     * @param string $key
     *
     * @return mixd
     */
	private function hook($key, $method = 'start', $param = false)
	{
		# 不再继续执行hook，就设置这个参数
		if(Input::get('maze_onload') == 'no')
		{
			if($method == 'end')
			{
				Input::set('maze_onload', 'yes');
			}
		}
		elseif(isset($this->config[$method][$key]))
		{
			# 如果定义了auth，就要传过去
			if(isset($this->config['auth']) && is_array($this->config['auth']))
			{
				$param = array($param, $this->config['auth']);
			}
			if(is_array($this->config[$method][$key]))
			{
				foreach($this->config[$method][$key] as $k => $v)
				{
					Load::get($v, $param);
				}
			}
			else
			{
				Load::get($this->config[$method][$key], $param);
			}
		}
	}

	/**
     * push
     *
     * @return mixd
     */
	private function push($param)
	{
		foreach($param as $k => $v)
		{
			if(isset($this->config['response'][$v]))
			{
				# 验证传入参数与配置是否相同
				/*
				$request = Input::prefix($v . '_');
				if($v == 'where')
				{
					$request = Input::prefix('where_');
				}
				*/
				
				$value = array();
				foreach($this->config['response'][$v] as $i => $j)
				{
					$t = array();
					if(is_array($j))
					{
						$t = $j;
						$j = $t[0];
					}
					$temp = $this->request($v. '_' . $i, $j, '', $i, $v);
					//if($temp || (($v == 'add' || $v == 'set') && $temp && $temp == 0))
					if($temp || ($temp === '0' || $temp === 0))
					//if($temp)
					{
						if(is_array($temp))
						{
							if(isset($this->config['struct'][$i]) && isset($this->config['struct'][$i]['bit']))
							{
								$vt = 0;
								foreach($temp as $ki => $vi)
								{
									if(isset($this->config['struct'][$i]['bit'][$vi]))
									{
										$vt += $this->config['struct'][$i]['bit'][$vi];
									}
								}
								$temp = $vt;
							}
							elseif(isset($temp[0]) && is_array($temp[0]))
							{
								$temp = base64_encode(json_encode($temp));
							}
							else
							{
								$temp = implode(',', $temp);
							}
						}
						
						if($temp === 'null')
						{
							$temp = '';
						}
						$g = array($i, $temp);
						if(isset($t[1]))
						{
							$g[2] = $t[1];
						}
						if(isset($t[2]))
						{
							$g[3] = $t[2];
						}
						$value[] = $g;
					}
				}

				if($value)
				{
					if($v == 'option')
					{
						$v = 'where';
					}

					$this->db()->$v($value);
				}
			}
		}

		return $this;
	}

	/**
     * condition
     *
     * @return mixd
     */
	private function condition($param)
	{
		foreach($param as $k => $v)
		{
			if(isset($this->config['response'][$v]))
			{
				if($v == 'page')
				{
					$value = $this->config['response'][$v];
					if(is_string($value[1]))
					{
						$temp[] = $value[1];
						unset($value[1]);
						$value[1] = $temp;
					}

					if(isset($value[2])) $value[1][2] = $value[2];

					if(isset($this->config['param']['page']))
					{
						$value[1] = array_merge($value[1], $this->config['param']['page']);
					}
				}
				else
				{
					$temp = '';
					$value = $this->request($v, $this->config['response'][$v], '-', $temp);

					if(!$value)
					{
						$value = $this->config['response'][$v];
					}
				}

				if(is_string($value))
				{
					$value = array($value, '');
				}

				if(empty($value[1])) $value[1] = '';

				$this->db()->$v($value[0], $value[1]);
			}
		}

		return $this;
	}

	/**
     * request
     *
     * @return mixd
     */
	private function request($key, $value, $split = '', &$index, $method = '')
	{
		//$index = str_replace(array('add_', 'where_', 'set_', 'option_'), '', $key);
		
		if($index && strpos($value, 'yes-') !== false)
		{
			$temp = explode('-', $value);
			$value = $temp[0];
			$index = $temp[1];
		}
		
		if($index && $value == 'yes' && isset($this->config['struct'][$index]) && is_array($this->config['struct'][$index]) && isset($this->config['struct'][$index]['match']) && $this->config['struct'][$index]['match'])
		{
			if(is_array($this->config['struct'][$index]['match']))
			{
				$value = $this->config['struct'][$index]['match'][0];
			}
			else
			{
				$value = $this->config['struct'][$index]['match'];
			}
		}
		$state 		= false;
		
		if(isset($this->config['param'][$key]))
		{
			$request 	= $this->config['param'][$key];
		}

		

		if($value == 'option')
		{
			$value = '';
			$state = true;
		}

		$callback = is_string($value) && function_exists($value);
		if($callback)
		{
			$callback = $value;
			$value = '';
		}

		if(isset($request) && ($request === '0' || $request === 0))
		{
			return 0;
		}
		
		if(empty($request))
		{	
			if($this->config['input'])
			{
				$request 	= Input::get($key, $value);
			}
			else
			{
				$request = $value;
			}
		}
		
		/*
		if(($method == 'set' || $method == 'add') && empty($request) && isset($this->config['struct'][$index]['default']) && $this->config['struct'][$index]['default'])
		{
			$request 	= $this->config['struct'][$index]['default'];
		}
		*/

		/*
		if(is_array($request))
		{
			$request = implode(',', $request);
		}
		*/
		if(is_string($value) && strpos($value, '/') !== false)
		{
			$state = preg_match($value, $request);
		}
		elseif(!empty($request))
		{
			if($callback)
			{
				$state = $callback($request);
			}
			elseif(is_string($request) && $split && strpos($request, $split) !== false)
			{
				$request = explode($split, $request);
			}

			$state = true;
		}

		//Debug::log(array('text' => 'model', 'state' => $state, 'preg' => $value, 'key' => $key, 'value' => $request));


		if($state)
		{
			if($index && isset($this->config['struct'][$index]) && is_array($this->config['struct'][$index]) && isset($this->config['struct'][$index]['callback']) && $this->config['struct'][$index]['callback'] && $request)
			{
				$call = $this->config['struct'][$index]['callback'];
				if($call == 'maketime')
				{
					if(is_string($request))
					{
						$request = \Maze::maketime($request);
					}
				}
				else
				{
					$request = $call($request);
				}
			}
			return $request;
		}

		# error
		if($method != 'option' && $method != 'add' && $method != 'set')
		{
			if(isset($this->config['struct'][$index]['desc']) && $this->config['struct'][$index]['desc'])
			{
				Output::abert($this->config['struct'][$index]['desc']);
			}
			else
			{
				Output::abert('core_database_request', array($key, ($value ? $value : $callback)));
			}
		}

		return false;
	}
}