single修改版

<?php

/**

* 获取和设置配置参数 支持批量定义

* 如果$key是关联型数组，则会按K-V的形式写入配置

* 如果$key是数字索引数组，则返回对应的配置数组

* @param string|array $key 配置变量

* @param array|null $value 配置值

* @return array|null

*/

function C($key,$value=null){

static $_config = array();

$args = func_num_args();

if($args == 1){

if(is_string($key)){ //如果传入的key是字符串

return isset($_config[$key])?$_config[$key]:null;

}

if(is_array($key)){

if(array_keys($key) !== range(0, count($key) - 1)){ //如果传入的key是关联数组

$_config = array_merge($_config, $key);

}else{

$ret = array();

foreach ($key as $k) {

$ret[$k] = isset($_config[$k])?$_config[$k]:null;

}

return $ret;

}

}

}else{

if(is_string($key)){

$_config[$key] = $value;

}else{

halt('传入参数不正确');

}

}

return null;

}

/**

* 调用Widget

* @param string $name widget名

* @param array $data 传递给widget的变量列表，key为变量名，value为变量值

* @return void

*/

function W($name, $data = array()){

$fullName = $name.'Widget';

if(!class_exists($fullName)){

halt('Widget '.$name.'不存在');

}

$widget = new $fullName();

$widget->invoke($data);

}

/**

* 终止程序运行

* @param string $str 终止原因

* @param bool $display 是否显示调用栈，默认不显示

* @return void

*/

function halt($str, $display=false){

Log::fatal($str.' debug_backtrace:'.var_export(debug_backtrace(), true));

header("Content-Type:text/html; charset=utf-8");

if($display){

echo "<pre>";

debug_print_backtrace();

echo "</pre>";

}

echo $str;

exit;

}

/*

<?php

// Default connection

ORM::configure('sqlite:./example.db');

// A named connection, where 'remote' is an arbitrary key name

ORM::configure('mysql:host=localhost;dbname=my_database', null, 'remote');

ORM::configure('username', 'database_user', 'remote');

ORM::configure('password', 'top_secret', 'remote');

// Using default connection

$person = ORM::for_table('person')->find_one(5);

// Using default connection, explicitly

$person = ORM::for_table('person', ORM::DEFAULT_CONNECTION)->find_one(5);

// Using named connection

$person = ORM::for_table('different_person', 'remote')->find_one(5);

*/

//增加idiorm支持

function Model($dbConf=null){

require_once(__DIR__."/lib/idiorm.php");

//缓存配置，可配成REDIS等

$my_cache = array();

ORM::configure('cache_query_result', function ($cache_key, $value, $table_name, $connection_name) use (&$my_cache) {

$my_cache[$cache_key] = $value;

});

ORM::configure('check_query_cache', function ($cache_key, $table_name, $connection_name) use (&$my_cache) {

if(isset($my_cache[$cache_key])){

return $my_cache[$cache_key];

} else {

return false;

}

});

ORM::configure('clear_cache', function ($table_name, $connection_name) use (&$my_cache) {

$my_cache = array();

});

ORM::configure('caching', false);

ORM::configure('caching_auto_clear', true); //ORM::clear_cache()

ORM::configure('create_cache_key', function ($query, $parameters, $table_name, $connection_name) {

$parameter_string = join(',', $parameters);

$key = $query . ':' . $parameter_string;

$my_key = 'my-prefix'.crc32($key);

return $my_key;

});

if($dbConf==null)

{

$dbConf = C(array('DB_HOST','DB_PORT','DB_USER','DB_PWD','DB_NAME','DB_CHARSET','DB_DEBUG'));

ORM::configure('mysql:host='. $dbConf['DB_HOST'].':'.$dbConf['DB_PORT'].';dbname='.$dbConf['DB_NAME']);

ORM::configure('username', $dbConf['DB_USER']);

ORM::configure('password', $dbConf['DB_PWD']);

ORM::configure('driver_options', array(PDO::MYSQL_ATTR_INIT_COMMAND => "set names ".$dbConf['DB_CHARSET']));

ORM::configure('return_result_sets',false); // returns result sets

ORM::configure('logging', $dbConf['DB_DEBUG']);

ORM::configure('logger', function($log_string, $query_time) {

echo $log_string . ' in ' . $query_time.'<br/>';

});

return 'default';

}

else

{

$conn=md5(implode('',$dbConf));

ORM::configure('mysql:host='. $dbConf['DB_HOST'].':'.$dbConf['DB_PORT'].';dbname='.$dbConf['DB_NAME'],null,$conn);

ORM::configure('username', $dbConf['DB_USER'],$conn);

ORM::configure('password', $dbConf['DB_PWD'],$conn);

ORM::configure('driver_options', array(PDO::MYSQL_ATTR_INIT_COMMAND => "set names ".$dbConf['DB_CHARSET']),$conn);

ORM::configure('return_result_sets',false,$conn); // returns result sets

ORM::configure('logging', $dbConf['DB_DEBUG'],$conn);

ORM::configure('logger', function($log_string, $query_time) {

echo $log_string . ' in ' . $query_time.'<br/>';

},$conn);

return $conn;

}

$instance = ORM::get_db();

return $instance;

}

/**

* 获取数据库实例

* @return DB

*/

function M(){

$dbConf = C(array('DB_HOST','DB_PORT','DB_USER','DB_PWD','DB_NAME','DB_CHARSET'));

return DB::getInstance($dbConf);

}

/**

* 如果文件存在就include进来

* @param string $path 文件路径

* @return void

*/

function includeIfExist($path){

if(file_exists($path)){

include $path;

}

}

/**

* 总控类

*/

class SinglePHP {

/**

* 控制器

* @var string

*/

private $c;

/**

* Action

* @var string

*/

private $a;

/**

* 单例

* @var SinglePHP

*/

private static $_instance;

/**

* 构造函数，初始化配置

* @param array $conf

*/

private function __construct($conf){

C($conf);

}

private function __clone(){}

function parseUrl(){

if (isset($_SERVER['PATH_INFO'])){

//获取 pathinfo

$pathinfo = explode('/', trim($_SERVER['PATH_INFO'], "/"));

// 获取 control

$_GET['C'] = (!empty($pathinfo[0]) ? $pathinfo[0] : 'Index');

$this->c =$_GET['C'];

array_shift($pathinfo); //将数组开头的单元移出数组

// 获取 action

$_GET['A'] = (!empty($pathinfo[0]) ? $pathinfo[0] : 'Index');

$this->a =$_GET['A'];

array_shift($pathinfo); //再将将数组开头的单元移出数组

for($i=0; $i<count($pathinfo); $i+=2){

if(isset($pathinfo[$i+1])){

$_GET[$pathinfo[$i]]=$pathinfo[$i+1];

$_REQUEST[$pathinfo[$i]]=$pathinfo[$i+1];

}

}

}else{

$_GET["C"]= (!empty($_GET['C']) ? $_GET['C']: 'Index'); //默认是index模块

$_GET["A"]= (!empty($_GET['A']) ? $_GET['A'] : 'Index'); //默认是index动作

if($_SERVER["QUERY_STRING"]){

$m=$_GET["C"];

unset($_GET["C"]); //去除数组中的m

$a=$_GET["A"];

unset($_GET["A"]); //去除数组中的a

$query=http_build_query($_GET); //形成0=foo&1=bar&2=baz&3=boom&cow=milk格式

//组成新的URL

$url=$_SERVER["SCRIPT_NAME"]."/{$m}/{$a}/".str_replace(array("&","="), "/", $query);

header("Location:".$url);

}

}

}

/**

* 获取单例

* @param array $conf

* @return SinglePHP

*/

public static function getInstance($conf){

if(!(self::$_instance instanceof self)){

self::$_instance = new self($conf);

}

return self::$_instance;

}

/**

* 运行应用实例

* @access public

* @return void

*/

public function run(){

if(C('USE_SESSION') == true){

session_start();

}

C('APP_FULL_PATH', getcwd().'/'.C('APP_PATH').'/');

includeIfExist( C('APP_FULL_PATH').'/common.php');

$pathMod = C('PATH_MOD');

$pathMod = empty($pathMod)?'NORMAL':$pathMod;

spl_autoload_register(array('SinglePHP', 'autoload'));

/*

if(strcmp(strtoupper($pathMod),'NORMAL') === 0 || !isset($_SERVER['PATH_INFO'])){ //

$this->c = isset($_GET['c'])?$_GET['c']:'Index';

$this->a = isset($_GET['a'])?$_GET['a']:'Index';

}else{

$pathInfo = isset($_SERVER['PATH_INFO'])?$_SERVER['PATH_INFO']:'';

$pathInfoArr = explode('/',trim($pathInfo,'/'));

if(isset($pathInfoArr[0]) && $pathInfoArr[0] !== ''){

$this->c = $pathInfoArr[0];

}else{

$this->c = 'Index';

}

if(isset($pathInfoArr[1])){

$this->a = $pathInfoArr[1];

}else{

$this->a = 'Index';

}

for($i=2; $i<count($pathInfoArr); $i+=2){

$_GET[$pathInfoArr[$i]]=$pathInfoArr[$i+1];

}

}

*/

$this->parseUrl();

if(!class_exists($this->c.'Controller')){

header("Content-Type:text/html; charset=utf-8");

$tpl = $this->c . '/' . $this->a;

$view = new View();

$view->display($tpl);

return;

}

$controllerClass = $this->c.'Controller';

$controller = new $controllerClass();

if(!method_exists($controller, $this->a.'Action')){

header("Content-Type:text/html; charset=utf-8");

$tpl = $this->c . '/' . $this->a;

$view = new View();

$view->display($tpl);

return;

//halt('方法'.$this->a.'不存在');

}

call_user_func(array($controller,$this->a.'Action'));

}

/**

* 自动加载函数

* @param string $class 类名

*/

public static function autoload($class){

if(substr($class,-10)=='Controller'){

includeIfExist(C('APP_FULL_PATH').'/Controller/'.$class.'.class.php');

}elseif(substr($class,-6)=='Widget'){

includeIfExist(C('APP_FULL_PATH').'/Widget/'.$class.'.class.php');

}else{

includeIfExist(C('APP_FULL_PATH').'/Lib/'.$class.'.class.php');

}

}

}

/**

* 控制器类

*/

class Controller {

/**

* 视图实例

* @var View

*/

private $_view;

/**

* 构造函数，初始化视图实例，调用hook

*/

public function __construct(){

$this->_view = new View();

$this->_init();

}

/**

* 前置hook

*/

protected function _init(){}

/**

* 渲染模板并输出

* @param null|string $tpl 模板文件路径

* 参数为相对于App/View/文件的相对路径，不包含后缀名，例如index/index

* 如果参数为空，则默认使用$controller/$action.php

* 如果参数不包含"/"，则默认使用$controller/$tpl

* @return void

*/

protected function display($tpl=''){

if($tpl === ''){

$trace = debug_backtrace();

$controller = substr($trace[1]['class'], 0, -10);

$action = substr($trace[1]['function'], 0 , -6);

$tpl = $controller . '/' . $action;

}elseif(strpos($tpl, '/') === false){

$trace = debug_backtrace();

$controller = substr($trace[1]['class'], 0, -10);

$tpl = $controller . '/' . $tpl;

}

$this->_view->display($tpl);

}

/**

* 为视图引擎设置一个模板变量

* @param string $name 要在模板中使用的变量名

* @param mixed $value 模板中该变量名对应的值

* @return void

*/

protected function assign($name,$value){

$this->_view->assign($name,$value);

}

/**

* 将数据用json格式输出至浏览器，并停止执行代码

* @param array $data 要输出的数据

*/

protected function ajaxReturn($data){

echo json_encode($data);

exit;

}

/**

* 重定向至指定url

* @param string $url 要跳转的url

* @param void

*/

protected function redirect($url){

header("Location: $url");

exit;

}

}

/**

* 视图类

*/

class View {

/**

* 视图文件目录

* @var string

*/

private $_tplDir;

/**

* 视图文件路径

* @var string

*/

private $_viewPath;

/**

* 视图变量列表

* @var array

*/

private $_data = array();

/**

* 给tplInclude用的变量列表

* @var array

*/

private static $tmpData;

/**

* @param string $tplDir

*/

public function __construct($tplDir=''){

if($tplDir == ''){

$this->_tplDir = './'.C('APP_PATH').'/View/';

}else{

$this->_tplDir = $tplDir;

}

}

/**

* 为视图引擎设置一个模板变量

* @param string $key 要在模板中使用的变量名

* @param mixed $value 模板中该变量名对应的值

* @return void

*/

public function assign($key, $value) {

$this->_data[$key] = $value;

}

/**

* 渲染模板并输出

* @param null|string $tplFile 模板文件路径，相对于App/View/文件的相对路径，不包含后缀名，例如index/index

* @return void

*/

public function display($tplFile) {

$this->_viewPath = $this->_tplDir . $tplFile . '.php';

if(!file_exists($this->_viewPath))

{

halt("视图文件".$this->_viewPath."不存在！");

}

unset($tplFile);

extract($this->_data);

include $this->_viewPath;

}

/**

* 用于在模板文件中包含其他模板

* @param string $path 相对于View目录的路径

* @param array $data 传递给子模板的变量列表，key为变量名，value为变量值

* @return void

*/

public static function tplInclude($path, $data=array()){

self::$tmpData = array(

'path' => C('APP_FULL_PATH') . '/View/' . $path . '.php',

'data' => $data,

);

unset($path);

unset($data);

if(self::$tmpData['data']!=null)

extract(self::$tmpData['data']);

include self::$tmpData['path'];

}

}

/**

* Widget类

* 使用时需继承此类，重写invoke方法，并在invoke方法中调用display

*/

class Widget {

/**

* 视图实例

* @var View

*/

protected $_view;

/**

* Widget名

* @var string

*/

protected $_widgetName;

/**

* 构造函数，初始化视图实例

*/

public function __construct(){

$this->_widgetName = get_class($this);

$dir = C('APP_FULL_PATH') . '/Widget/Tpl/';

$this->_view = new View($dir);

}

/**

* 处理逻辑

* @param mixed $data 参数

*/

public function invoke($data){}

/**

* 渲染模板

* @param string $tpl 模板路径，如果为空则用类名作为模板名

*/

protected function display($tpl=''){

if($tpl == ''){

$tpl = $this->_widgetName;

}

$this->_view->display($tpl);

}

/**

* 为视图引擎设置一个模板变量

* @param string $name 要在模板中使用的变量名

* @param mixed $value 模板中该变量名对应的值

* @return void

*/

protected function assign($name,$value){

$this->_view->assign($name,$value);

}

}

/**

* 数据库操作类

* 使用方法：

* DB::getInstance($conf)->query('select * from table');

* 其中$conf是一个关联数组，需要包含以下key：

* DB_HOST DB_USER DB_PWD DB_NAME

* 可以用DB_PORT和DB_CHARSET来指定端口和编码，默认3306和utf8

*/

class DB {

/**

* 数据库链接

* @var resource

*/

private $_db;

/**

* 保存最后一条sql

* @var string

*/

private $_lastSql;

/**

* 上次sql语句影响的行数

* @var int

*/

private $_rows;

/**

* 上次sql执行的错误

* @var string

*/

private $_error;

/**

* 实例数组

* @var array

*/

private static $_instance = array();

/**

* 构造函数

* @param array $dbConf 配置数组

*/

private function __construct($dbConf){

if(!isset($dbConf['DB_CHARSET'])){

$dbConf['DB_CHARSET'] = 'utf8';

}

$this->_db = mysql_connect($dbConf['DB_HOST'].':'.$dbConf['DB_PORT'],$dbConf['DB_USER'],$dbConf['DB_PWD']);

if($this->_db === false){

halt(mysql_error());

}

$selectDb = mysql_select_db($dbConf['DB_NAME'],$this->_db);

if($selectDb === false){

halt(mysql_error());

}

mysql_set_charset($dbConf['DB_CHARSET']);

}

private function __clone(){}

/**

* 获取DB类

* @param array $dbConf 配置数组

* @return DB

*/

static public function getInstance($dbConf){

if(!isset($dbConf['DB_PORT'])){

$dbConf['DB_PORT'] = '3306';

}

$key = $dbConf['DB_HOST'].':'.$dbConf['DB_PORT'];

if(!isset(self::$_instance[$key]) || !(self::$_instance[$key] instanceof self)){

self::$_instance[$key] = new self($dbConf);

}

return self::$_instance[$key];

}

/**

* 转义字符串

* @param string $str 要转义的字符串

* @return string 转义后的字符串

*/

public function escape($str){

return mysql_real_escape_string($str, $this->_db);

}

/**

* 查询，用于select语句

* @param string $sql 要查询的sql

* @return bool|array 查询成功返回对应数组，失败返回false

*/

public function query($sql){

$this->_rows = 0;

$this->_error = '';

$this->_lastSql = $sql;

$this->logSql();

$res = mysql_query($sql,$this->_db);

if($res === false){

$this->_error = mysql_error($this->_db);

$this->logError();

return false;

}else{

$this->_rows = mysql_num_rows($res);

$result = array();

if($this->_rows >0) {

while($row = mysql_fetch_array($res, MYSQL_ASSOC)){

$result[] = $row;

}

mysql_data_seek($res,0);

}

return $result;

}

}

/**

* 查询，用于insert/update/delete语句

* @param string $sql 要查询的sql

* @return bool|int 查询成功返回影响的记录数量，失败返回false

*/

public function execute($sql) {

$this->_rows = 0;

$this->_error = '';

$this->_lastSql = $sql;

$this->logSql();

$result = mysql_query($sql, $this->_db) ;

if ( false === $result) {

$this->_error = mysql_error($this->_db);

$this->logError();

return false;

} else {

$this->_rows = mysql_affected_rows($this->_db);

return $this->_rows;

}

}

/**

* 获取上一次查询影响的记录数量

* @return int 影响的记录数量

*/

public function getRows(){

return $this->_rows;

}

/**

* 获取上一次insert后生成的自增id

* @return int 自增ID

*/

public function getInsertId() {

return mysql_insert_id($this->_db);

}

/**

* 获取上一次查询的sql

* @return string sql

*/

public function getLastSql(){

return $this->_lastSql;

}

/**

* 获取上一次查询的错误信息

* @return string 错误信息

*/

public function getError(){

return $this->_error;

}

/**

* 记录sql到文件

*/

private function logSql(){

Log::sql($this->_lastSql);

}

/**

* 记录错误日志到文件

*/

private function logError(){

$str = '[SQL ERR]'.$this->_error.' SQL:'.$this->_lastSql;

Log::warn($str);

}

}

/**

* 日志类

* 使用方法：Log::fatal('error msg');

* 保存路径为 App/Log，按天存放

* fatal和warning会记录在.log.wf文件中

*/

class Log{

/**

* 打日志，支持SAE环境

* @param string $msg 日志内容

* @param string $level 日志等级

* @param bool $wf 是否为错误日志

*/

public static function write($msg, $level='DEBUG', $wf=false){

if(function_exists('sae_debug')){ //如果是SAE，则使用sae_debug函数打日志

$msg = "[{$level}]".$msg;

sae_set_display_errors(false);

sae_debug(trim($msg));

sae_set_display_errors(true);

}else{

$msg = date('[ Y-m-d H:i:s ]')."[{$level}]".$msg."\r\n";

$logPath = C('APP_FULL_PATH').'/Log/'.date('Ymd').'.log';

if($wf){

$logPath .= '.wf';

}

file_put_contents($logPath, $msg, FILE_APPEND);

}

}

/**

* 打印fatal日志

* @param string $msg 日志信息

*/

public static function fatal($msg){

self::write($msg, 'FATAL', true);

}

/**

* 打印warning日志

* @param string $msg 日志信息

*/

public static function warn($msg){

self::write($msg, 'WARN', true);

}

/**

* 打印notice日志

* @param string $msg 日志信息

*/

public static function notice($msg){

self::write($msg, 'NOTICE');

}

/**

* 打印debug日志

* @param string $msg 日志信息

*/

public static function debug($msg){

self::write($msg, 'DEBUG');

}

/**

* 打印sql日志

* @param string $msg 日志信息

*/

public static function sql($msg){

self::write($msg, 'SQL');

}

}

/**

* ExtException类，记录额外的异常信息

*/

class ExtException extends Exception{

/**

* @var array

*/

protected $extra;

/**

* @param string $message

* @param array $extra

* @param int $code

* @param null $previous

*/

public function __construct($message = "", $extra = array(), $code = 0, $previous = null){

$this->extra = $extra;

parent::__construct($message, $code, $previous);

}

/**

* 获取额外的异常信息

* @return array

*/

public function getExtra(){

return $this->extra;

}

}