<?php
header('Content-type:text/html; Charset=utf-8');
$appid = 'xxxxx';  //https://open.alipay.com 账户中心->密钥管理->开放平台密钥，填写添加了电脑网站支付的应用的APPID
$notifyUrl = 'http://www.xxx.com/alipay/notify.php';     //付款成功后的异步回调地址
$outTradeNo = uniqid();     //你自己的商品订单号
$payAmount = 0.01;          //付款金额，单位:元
$orderName = '支付测试';    //订单标题
$signType = 'RSA2';       //签名算法类型，支持RSA2和RSA，推荐使用RSA2
//商户私钥，填写对应签名算法类型的私钥，如何生成密钥参考：https://docs.open.alipay.com/291/105971和https://docs.open.alipay.com/200/105310
$saPrivateKey='MIIEpAIBAAKCAQEA1MV+OY6MvGfXPM0MkpjT+FdzGmPOvVmX2wF3gjwQpeHBEUP9jLXhVS32fZ1iXI1e7WUGQ5tvXn28P8190kpOn/c/G5t2CAksUvemvF7uJN/N3Z1HFMdt3omvCd14K05lgcFYz7Z4c+A7ZJF5bPCB6oshjjUmbCY3hibuWzX/1j8AgsoD9lLy1oFqxLj98k5ZrYIhk900gMQs/WJ3A1FC09Dln9fuhBUyjtPHaml+4w+sdkdzxPktxdFrMcI7M7rNEwg25XtST5Z49oFpE84AlXM7+oC9jYvIpTGE00WomsgtakN039ucT/59Bup6pLkO08Rv85UXbqzGTcYAhNHLfQIDAQABAoIBAQCbuPM58s+j8KgB8ty5yiqRPoeaj+O2h4Txn7A02/sfPQvNtCI0w3TpT5twsihULo+EVYTxJCitUn7df2sP5pyGzTEd5njLRtNu4Zvhj+Thjf8grERiu9b4oXI/WRzjLRxzi+uREi40OK+fWi0xgxDCdROY/eNiEdJfV8zpaqsUxG7VdwZIJQ/8d3Mi31OWv30kr9jfEd15DBInGJgSqR+qwrAB4pBSMcW8hL6PYlzoPi1ygceFjRrnbeMG40zt0OUPSexQIgAmFvGqxTl5xo3dFEziGHdfWYsBKZ2M8ubAe+R6LcndxI+o2Hw4TNcC1tDeNMtjw7+h9S5aef5A8uWBAoGBAPxCLWPhUHCYlIXUz0D1SoolZs9WK7Kz1YSWnzqrpegN+foS5/ji93YylGE+KL31TwbnGQLAwknwMX3qTzmkvTovmy8jevXBsCSEFm81q0wG/35e1SKkTXL66RqB2y0xFLdcF3f9s8ZiEclqkYwNSHh0nqzREfIxMMAsj+3n2vHdAoGBANftYkZYrbs4iI/ZcjmBYguYikNfNmrD+Ta6ckOGZqsHfwXJCAz1rF4/XCqVAc9nxuzJR/72qkn9z07uH6qSZCqlZDRkiiKaK2UVqFDB+0abMk/TGHXuMmdvMkyj2jEZxG2rkg0kmg4qYkkg/5tGG1On/2GeZNVPu8JpsFr1pDYhAoGBANr8pCTKC6fDfWP1C3qrtmrY7zhc6RB4d4pjq5UmP5+EypaiZQi2F/dfD1qfuIS3eURXyGmQZtoDDyPtDZvP/ImPnFs+pNbFryD0HfmrEKquhIvyzXoGQknnsgbV5iyEKCTJaII9FxzINAKzZei7+0a+jqUd1kN3Gogp50Sze2ltAoGARaM5Xpaa8RZ6dGocfI9Nn4/Ch5fdZPFvHkdjMoPV+LKiNKtw/Tz+KiclAlasDsfZT+RaY9AJe3NvuHTzoX807swIVR1Xr3EpLaCed+0XrN3AjB34dZAskU87WZw+cjdtMjFzGOoFBSyGJi+OP/WMOp6jo/YBbwoX88tCJROzsgECgYAT8pHHIyPt5Y/5pDb8EDvD3XNES1fBkfZffSoAodsrkeoKgrsKl+9M3rcGX+S9dscyoH0ur3BFTMHtIOOhC5qytt+BhMHIP5mAs4di4u/joQCWQbUyrUggVK5it+6BFgAT+jeB7zTAUtgGpTVFq3kLbV0NZ+XQyEHVlnoJnHYpQg==';
$aliPay = new AlipayService($appid,$returnUrl,$notifyUrl,$saPrivateKey);
$result = $aliPay->doPay($payAmount,$outTradeNo,$orderName,$returnUrl,$notifyUrl);
$result = $result['alipay_trade_precreate_response'];
if($result['code'] && $result['code']=='10000'){
    //生成二维码
    $url = 'http://pan.baidu.com/share/qrcode?w=300&h=300&url='.$result['qr_code'];
    echo "<img src='{$url}' style='width:300px;'><br>";
    echo '二维码内容：'.$result['qr_code'];
}else{
    echo $result['msg'].' : '.$result['sub_msg'];
}
class AlipayService
{
    protected $appId;
    protected $returnUrl;
    protected $notifyUrl;
    //私钥文件路径
    protected $rsaPrivateKeyFilePath;
    //私钥值
    protected $rsaPrivateKey;
    public function __construct($appid, $returnUrl, $notifyUrl,$saPrivateKey)
    {
        $this->appId = $appid;
        $this->returnUrl = $returnUrl;
        $this->notifyUrl = $notifyUrl;
        $this->charset = 'utf8';
        $this->rsaPrivateKey=$saPrivateKey;
    }
    /**
     * 发起订单
     * @param float $totalFee 收款总费用 单位元
     * @param string $outTradeNo 唯一的订单号
     * @param string $orderName 订单名称
     * @param string $notifyUrl 支付结果通知url 不要有问号
     * @param string $timestamp 订单发起时间
     * @return array
     */
    public function doPay($totalFee, $outTradeNo, $orderName, $returnUrl,$notifyUrl)
    {
        //请求参数
        $requestConfigs = array(
            'out_trade_no'=>$outTradeNo,
            'total_amount'=>$totalFee, //单位 元
            'subject'=>$orderName,  //订单标题
        );
        $commonConfigs = array(
            //公共参数
            'app_id' => $this->appId,
            'method' => 'alipay.trade.precreate',             //接口名称
            'format' => 'JSON',
            'charset'=>$this->charset,
            'sign_type'=>'RSA2',
            'timestamp'=>date('Y-m-d H:i:s'),
            'version'=>'1.0',
            'notify_url' => $notifyUrl,
            'biz_content'=>json_encode($requestConfigs),
        );
        $commonConfigs["sign"] = $this->generateSign($commonConfigs, $commonConfigs['sign_type']);
        $result = $this->curlPost('https://openapi.alipay.com/gateway.do',$commonConfigs);
        return json_decode($result,true);
    }
    public function generateSign($params, $signType = "RSA") {
        return $this->sign($this->getSignContent($params), $signType);
    }
    protected function sign($data, $signType = "RSA") {
        $priKey=$this->rsaPrivateKey;
        $res = "-----BEGIN RSA PRIVATE KEY-----\n" .
            wordwrap($priKey, 64, "\n", true) .
            "\n-----END RSA PRIVATE KEY-----";
        ($res) or die('您使用的私钥格式错误，请检查RSA私钥配置');
        if ("RSA2" == $signType) {
            openssl_sign($data, $sign, $res, version_compare(PHP_VERSION,'5.4.0', '<') ? SHA256 : OPENSSL_ALGO_SHA256); //OPENSSL_ALGO_SHA256是php5.4.8以上版本才支持
        } else {
            openssl_sign($data, $sign, $res);
        }
        $sign = base64_encode($sign);
        return $sign;
    }
    /**
     * 校验$value是否非空
     *  if not set ,return true;
     *    if is null , return true;
     **/
    protected function checkEmpty($value) {
        if (!isset($value))
            return true;
        if ($value === null)
            return true;
        if (trim($value) === "")
            return true;
        return false;
    }
    public function getSignContent($params) {
        ksort($params);
        $stringToBeSigned = "";
        $i = 0;
        foreach ($params as $k => $v) {
            if (false === $this->checkEmpty($v) && "@" != substr($v, 0, 1)) {
                // 转换成目标字符集
                $v = $this->characet($v, $this->charset);
                if ($i == 0) {
                    $stringToBeSigned .= "$k" . "=" . "$v";
                } else {
                    $stringToBeSigned .= "&" . "$k" . "=" . "$v";
                }
                $i++;
            }
        }
        unset ($k, $v);
        return $stringToBeSigned;
    }
    /**
     * 转换字符集编码
     * @param $data
     * @param $targetCharset
     * @return string
     */
    function characet($data, $targetCharset) {
        if (!empty($data)) {
            $fileType = $this->charset;
            if (strcasecmp($fileType, $targetCharset) != 0) {
                $data = mb_convert_encoding($data, $targetCharset, $fileType);
                //$data = iconv($fileType, $targetCharset.'//IGNORE', $data);
            }
        }
        return $data;
    }
    public function curlPost($url = '', $postData = '', $options = array())
    {
        if (is_array($postData)) {
            $postData = http_build_query($postData);
        }
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_POST, 1);
        curl_setopt($ch, CURLOPT_POSTFIELDS, $postData);
        curl_setopt($ch, CURLOPT_TIMEOUT, 30); //设置cURL允许执行的最长秒数
        if (!empty($options)) {
            curl_setopt_array($ch, $options);
        }
        //https请求 不验证证书和host
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
        $data = curl_exec($ch);
        curl_close($ch);
        return $data;
    }
}

<?php  
class sqlsrv{    
    private $error_log = array();  
    private $sql_log = array();  
    private $query_id;  
    private $num_rows;  
    private $conn;  
    private $server=".";  
    private $userid="sa";  
    private $password="sa";  
    private $database="db";  
    
    //connection  
    function sqlsrv() {  
    }  
    function open(){  
        $this->conn = @sqlsrv_connect($this->server, array('UID' => $this->userid ,'PWD'=> $this->password, 'Database' => $this->database));  
        if($this->conn === false) {  
            $this->error_log[] = sqlsrv_errors();  
            die();  
        }  
    }  
    function close(){  
        sqlsrv_close($this->conn);  
    }  
    
    //query source  
    function query($sql,$params=array(),$open_close=1){  
        if($open_close){  
            $this->open();  
        }  
        $array=array();  
        for($i=0;$i<count($params);$i++) {  
            if(is_array($params[$i])){  
                $array[$i]=array($this->convert2gbk($params[$i][0]),$params[$i][1]);  
            }  
            else{    
                $array[$i] =array($this->convert2gbk($params[$i]),SQLSRV_PARAM_IN);  
            }  
        }  
        $stmt = sqlsrv_query($this->conn, $sql,$array);  
        $this->sql_log[] = $sql;  
        $res=false;  
        if($stmt === false) {  
            $this->error_log[] = sqlsrv_errors();  
        } else {  
            $this->query_id = $stmt;  
            $res=$this->num_rows = $this->affectedRows();  
        }  
        if($open_close){  
            $this->close();  
        }  
        return $res;  
    }  
    
    //fetch data  
    function fetch_all($sql,$params=array(),$open_close=1) {  
        if($open_close){  
            $this->open();  
        }  
        $this->query($sql,$params,0);  
        $data = array();  
        while($row = @sqlsrv_fetch_array($this->query_id)) {  
            $data[] = $row;  
        }  
         foreach ($data as $key => $value) {  
            foreach ($value as $key2 => $value2) {  
                @$data[$key][$key2] = $this->convert2utf8($value2);  
            }  
        }  
        if($open_close){  
            $this->close();  
        }  
        return $data;  
    }  
    // $DB->count(select   *   from  users)  
    function fetch_one($sql,$params=array(),$open_close=1){  
        if($open_close){  
            $this->open();        
        }  
        $this->query($sql,$params,0);  
        @$res= sqlsrv_fetch_array($this->query_id);  
        if(is_array($res)){  
            foreach ($res as $key => $value) {  
                @$res[$key] = $this->convert2utf8($value);  
            }          
        }  
        if($open_close){  
            $this->close();  
        }  
        return $res;          
    }  
    // $DB->count(select   count(*)   from  users)  
    function count($sql,$params=array(),$open_close=1){    
        if($open_close){  
            $this->open();  
        }  
        $count=$this->fetch_one($sql,$params,0);  
        $res= $count[0];      
        if($open_close){  
            $this->close();  
        }  
        return $res;  
    }  
    
    function affectedRows() {  
        $res=($this->query_id) ? @sqlsrv_num_rows($this->query_id) : false;  
        if($res==false){  
            $res=($this->query_id) ? @sqlsrv_rows_affected($this->query_id) : false;  
        }  
        return $res;  
    }  
      
    function convert2utf8($str)  
    {  
        return iconv("gbk","utf-8",$str);  
    }  
    function convert2gbk($str)  
    {  
        return iconv("utf-8","gbk",$str);  
    }  
}  
?>  

<?php
/*** Mongodb类**
examples:    
* $mongo = new HMongodb("127.0.0.1:11223");  
* $mongo->selectDb("test_db");  
* 创建索引  
* $mongo->ensureIndex("test_table", array("id"=>1), array('unique'=>true));  
* 获取表的记录  
* $mongo->count("test_table");  
* 插入记录  
* $mongo->insert("test_table", array("id"=>2, "title"=>"asdqw"));  
* 更新记录  array('$set'=>$newdata) 只修改指定字段
* $mongo->update("test_table", array("id"=>1),array("id"=>1,"title"=>"bbb"));  
* 更新记录-存在时更新，不存在时添加-相当于set  
* $mongo->update("test_table", array("id"=>1),array("id"=>1,"title"=>"bbb"),array("upsert"=>1));  
* 查找记录  
* $mongo->find("test_table", array("title"=>"asdqw"), array("start"=>2,"limit"=>2,"sort"=>array("id"=>1)))  
* 查找一条记录  
* $mongo->findOne("test_table", array("id"=>1));  
* 删除记录  
* $mongo->remove("ttt", array("title"=>"bbb"));  
* 仅删除一条记录  
* $mongo->remove("ttt", array("title"=>"bbb"), array("justOne"=>1));  
* 获取Mongo操作的错误信息  
* $mongo->getError();  
*/    


class HMongodb {    
    
  public $_idType=1;//主键类型 1 string 0 obj
  
    //Mongodb连接    
    var $mongo;    
    
    var $curr_db_name;    
    var $curr_table_name;    
    var $error;    
    
  
    /**  
    * 构造函数  
    * 支持传入多个mongo_server(1.一个出问题时连接其它的server 2.自动将查询均匀分发到不同server)  
    *  
    * 参数：  
    * $mongo_server:数组或字符串-array("127.0.0.1:1111", "127.0.0.1:2222")-"127.0.0.1:1111"  
    * $connect:初始化mongo对象时是否连接，默认连接  
    * $auto_balance:是否自动做负载均衡，默认是  
    *  
    * 返回值：  
    * 成功：mongo object  
    * 失败：false  
    */    
    function __construct($mongo_server, $connect=true, $auto_balance=true)    
    {    
        if (is_array($mongo_server))    
        {    
            $mongo_server_num = count($mongo_server);    
            if ($mongo_server_num > 1 && $auto_balance)    
            {    
                $prior_server_num = rand(1, $mongo_server_num);    
                $rand_keys = array_rand($mongo_server,$mongo_server_num);    
                $mongo_server_str = $mongo_server[$prior_server_num-1];    
                foreach ($rand_keys as $key)    
                {    
                    if ($key != $prior_server_num - 1)    
                    {    
                        $mongo_server_str .= ',' . $mongo_server[$key];    
                    }    
                }    
            }    
            else    
            {    
                $mongo_server_str = implode(',', $mongo_server);    
            }                  }    
        else    
        {    
            $mongo_server_str = trim($mongo_server);
      //$config_arr=explode('/',$mongo_server);
      //$this->curr_db_name = array_pop($config_arr);
      $last_index=strrpos($mongo_server_str,'/');
      $db_name=substr($mongo_server_str,$last_index+1,strlen($mongo_server_str));
      $this->curr_db_name = $db_name;//获取dbname
      //print_r($db_name);exit;
        }    
        try {    
            $this->mongo = new MongoClient($mongo_server, array('connect'=>$connect));    
        }    
        catch (MongoConnectionException $e)    
        {    
            $this->error = $e->getMessage();    
            return false;    
        }    
    }    
    
    function getInstance($mongo_server, $flag=array())    
    {    
        static $mongodb_arr;    
        if (empty($flag['tag']))    
        {    
            $flag['tag'] = 'default';          }    
        if (isset($flag['force']) && $flag['force'] == true)    
        {    
            $mongo = new HMongodb($mongo_server);    
            if (empty($mongodb_arr[$flag['tag']]))    
            {    
                $mongodb_arr[$flag['tag']] = $mongo;    
            }    
            return $mongo;    
        }    
        else if (isset($mongodb_arr[$flag['tag']]) && is_resource($mongodb_arr[$flag['tag']]))    
        {    
            return $mongodb_arr[$flag['tag']];    
        }    
        else    
        {    
            $mongo = new HMongodb($mongo_server);    
            $mongodb_arr[$flag['tag']] = $mongo;    
            return $mongo;                  }          }    
    
    /**  
    * 连接mongodb server  
    *  
    * 参数：无  
    *  
    * 返回值：  
    * 成功：true  
    * 失败：false  
    */    
    function connect()    
    {    
        try {    
            $this->mongo->connect();    
            return true;    
        }    
        catch (MongoConnectionException $e)    
        {    
            $this->error = $e->getMessage();    
            return false;    
        }    
    }    
    
    /**  
    * select db  
    *  
    * 参数：$dbname  
    *  
    * 返回值：无  
    */    
    function selectDb($dbname)    
    {    
        $this->curr_db_name = $dbname;    
    }    
    
    /**  
    * 创建索引：如索引已存在，则返回。  
    *  
    * 参数：  
    * $table_name:表名  
    * $index:索引-array("id"=>1)-在id字段建立升序索引  
    * $index_param:其它条件-是否唯一索引等  
    *  
    * 返回值：  
    * 成功：true  
    * 失败：false  
    */    
    function ensureIndex($table_name, $index, $index_param=array())    
    {    
        $dbname = $this->curr_db_name;    
        $index_param['safe'] = 1;    
        try {    
            $this->mongo->$dbname->$table_name->ensureIndex($index, $index_param);    
            return true;    
        }    
        catch (MongoCursorException $e)    
        {    
            $this->error = $e->getMessage();    
            return false;    
        }    
    }    
    
    /**  
    * 插入记录  
    *  
    * 参数：  
    * $table_name:表名  
    * $record:记录  
    *  
    * 返回值：  
    * 成功：true  
    * 失败：false  
    */    
    function insert($table_name, $record)    
    {    
        $dbname = $this->curr_db_name;    
        try {    
            $this->mongo->$dbname->$table_name->insert($record, array('safe'=>true));    
            return true;    
        }    
        catch (MongoCursorException $e)    
        {    
            $this->error = $e->getMessage();    
            return false;    
        }    
    }    
    
    /**  
    * 查询表的记录数  
    *  
    * 参数：  
    * $table_name:表名  
    *  
    * 返回值：表的记录数  
    */    
    function count($table_name,$query_condition=array())    
    {    
        $dbname = $this->curr_db_name;    
        return $this->mongo->$dbname->$table_name->find($query_condition)->count();    
    }    
    
  //$newdata存在有_id则更新 不存在则插入
  function save($table_name, $newdata) {    
    $dbname = $this->curr_db_name;    
    if($this->_idType && $newdata['_id']){
      $newdata['_id']=new MongoId($newdata['_id']);
    }
    return $this->mongo->$dbname->$table_name->save($newdata);    
  }
    /**  
    * 更新记录  
    *  
    * 参数：  
    * $table_name:表名  
    * $condition:更新条件  
    * $newdata:新的数据记录  
    * $options:更新选择-upsert/multiple  
    *  
    * 返回值：  
    * 成功：true  
    * 失败：false  
    */    
    function update($table_name, $condition, $newdata, $options=array())    
    {   if($this->_idType && $condition['_id']){
      $condition['_id']=new MongoId($condition['_id']);
    }  
        $dbname = $this->curr_db_name;    
        $options['safe'] = 1;    
        if (!isset($options['multiple']))    
        {    
            $options['multiple'] = 0;          }    
        try {    
            $this->mongo->$dbname->$table_name->update($condition, $newdata, $options);    
            return true;    
        }    
        catch (MongoCursorException $e)    
        {    
            $this->error = $e->getMessage();    
            return false;    
        }          }    
    
    /**  
    * 删除记录  
    *  
    * 参数：  
    * $table_name:表名  
    * $condition:删除条件  
    * $options:删除选择-justOne  
    *  
    * 返回值：  
    * 成功：true  
    * 失败：false  
    */    
    function remove($table_name, $condition, $options=array())    
    {  
    if($this->_idType && $condition['_id']){
      $condition['_id']=new MongoId($condition['_id']);
    }
        $dbname = $this->curr_db_name;    
        $options['safe'] = 1;    
        try {    
            $this->mongo->$dbname->$table_name->remove($condition, $options);    
            return true;    
        }    
        catch (MongoCursorException $e)    
        {    
            $this->error = $e->getMessage();    
            return false;    
        }          }    
    
    /**  
    * 查找记录  
    *  
    * 参数：  
    * $table_name:表名  
    * $query_condition:字段查找条件  
    * $result_condition:查询结果限制条件-limit/sort等  
    * $fields:获取字段  
    *  
    * 返回值：  
    * 成功：记录集  
    * 失败：false  
    */    
    function find($table_name, $query_condition, $result_condition=array(), $fields=array())    
    {    
        $dbname = $this->curr_db_name;    
        $cursor = $this->mongo->$dbname->$table_name->find($query_condition, $fields);    
        if (!empty($result_condition['start']))    
        {    
            $cursor->skip($result_condition['start']);    
        }    
        if (!empty($result_condition['limit']))    
        {    
            $cursor->limit($result_condition['limit']);    
        }    
        if (!empty($result_condition['sort']))    
        {    
            $cursor->sort($result_condition['sort']);    
        }    
        $result = array();    
        try {    
            while ($cursor->hasNext())    
            {  
        $row= $cursor->getNext();
        //print_r($cursor->getNext());exit;
        if($this->_idType && is_object($row['_id'])){
          $row['_id']=$row['_id']->__toString();//转换字符串
        }
                $result[] =$row;    
            }    
        }    
        catch (MongoConnectionException $e)    
        {    
            $this->error = $e->getMessage();    
            return false;    
        }    
        catch (MongoCursorTimeoutException $e)    
        {    
            $this->error = $e->getMessage();    
            return false;    
        }    
        return $result;    
    }    
    
    /**  
    * 查找一条记录  
    *  
    * 参数：  
    * $table_name:表名  
    * $condition:查找条件  
    * $fields:获取字段  
    *  
    * 返回值：  
    * 成功：一条记录  
    * 失败：false  
    */    
    function findOne($table_name, $condition, $fields=array())    
    {    
    if($this->_idType && $condition['_id']){
      $condition['_id']=new MongoId($condition['_id']);
    }  
        $dbname = $this->curr_db_name;    
        $row=$this->mongo->$dbname->$table_name->findOne($condition, $fields);
    if($this->_idType && is_object($row['_id'])){
      $row['_id']=$row['_id']->__toString();//转换字符串
    }  
    return $row;
    }    
    
    /**  
    * 获取当前错误信息  
    *  
    * 参数：无  
    *  
    * 返回值：当前错误信息  
    */    
    function getError()    
    {    
        return $this->error;    
    }  
  //返回原生mongodb collection集合对象
  function getCollection($table_name){
    $dbname = $this->curr_db_name;  
    return $this->mongo->$dbname->$table_name;
  }
  //分组统计
  function group($table_name,$keys,$initial,$reduce,$condition){
    $dbname = $this->curr_db_name;    
    $g = $this->mongo->$dbname->$table_name->group($keys, $initial, $reduce,$condition);
    return $g;
  }  
  
}    

<?php
/**
* Mongodb 基本操作API，支持基本类似关系统型数据库的操作接口
*
* @version 1.0
* [说明]
*
* 1：该版本API实现了 Mongodb 中最基本的插入/修改/查询/删除操作的封装
* 2：其它更高级的操作可通过 $this->getMongo() 得到原生的对象，更多API请自行查阅 Mongo PHP手册,后续版本将会对增加更多的原生API封装
* 3：该类所有API接口中的 $query 查询参数的使用请以下有关 [查询条件说明文档]
* 4: 如果要存储中文字符，则一定要使用 utf8 的编码．
* 5：有了本类接口基本可以按关系型数据库的概念完成Mongodb的大部分开发操作。
*
* [查询条件说明文档]
*
* 参数：array('id'=>1)
* 等同：where id=1
*
* 参数：array('id'=>1,'num'=>10)
* 等同：where id=1 and num=10
*
* 参数：array('id'=>array($mongo->cmd('>')=>5))
* 等同：where id>5
*
* 参数：array('id'=>array($mongo->cmd('!=')=>5))
* 等同：where id!=5
*
* 参数：array('id'=>array($mongo->cmd('>')=>5, $mongo->cmd('<')=>10))
* 等同：where id>5 and id<10
*
* 参数：array('id'=>array($mongo->cmd('in')=>array(2,5,6)))
* 等同：where id in (2,5,6)
*
* 参数：array('id'=>array($mongo->cmd('%')=>array(2,1)))
* 等同：where id % 2 = 1
*
* 参数：array($mongo->cmd('or') => array( array('id'=>array($mongo->cmd('>')=>5)), array('id'=>array($mongo->cmd('<')=>10)) ) )
* 等同：where id>5 or id<10
*
* 参数：array('username' => new mongoRegex("/yhp.*/"))
* 等同 where  username  like "%yhp%"
**/
class Library_Mongodb {

    /**
     * Mongodb 对象句柄
     *
     * @var object Mongo
     */
    private $_mongo = null;

    /**
     * 当前选择的数据库
     *
     * @var object MongoDB
     */
    private $_db = null;

    /**
     * 修改器命令前缀
     *
     * @var string
     */
    private $_cmd = '$';


    /**
     * 调试模式 TRUE 打开 FALSE 关闭
     * @var boolean
     */
    const DEBUG = TRUE;

    /**
     * 查询条件映射关系
     *
     * @var array
     */
    private $_condMap = array(
        '<'        =>    'lt', // id > 1
        '<='    =>    'lte', // id <= 10
        '>'        =>    'gt', // id > 5
        '>='    =>    'gte', // id >= 4
        '!='    =>    'ne', // id != 4
        '%'        =>    'mod', // id % 4 = 0
        'in'    =>    'in', // id in (1,2,3,4)
        'notin'    =>    'nin',// id not in (1,2,3,4)
        'or'    =>    'or', // id=1 or id=2
        'not'    =>    'not', // !(id=1)
    );


    /**
     * 构造函数
     *
     * @param array $config 服务器配置,默认为:
     * array(
     * 'host'=>'localhost', // 主机名或IP地址
     * 'port'=>27017, // 端口
     * 'cmd'=>'$', // 修改器命令前缀
     * )
     */
    public function __construct($config = array('host' => 'xxx', 'port' => 27017, 'username' => 'xxx', 'password' => 'xxx', 'db' => 'xxx',  'cmd' => '$')){
        $server = sprintf("mongodb://%s:%s@%s:%s/%s", $config['username'], $config['password'], $config['host'], $config['port'], $config['db']);

//        echo "connect\n";
        try {
            $this->_mongo = new MongoClient($server, array('connect'=>true));// 立即连接
        }catch (MongoConnectionException $e){
            if(self::DEBUG) {
                echo $e->getMessage();
            }
            return false;
        }

        $this->selectDB($config['db']);
        // 命令前缀
        if(!isset($config['cmd'])){
            $this->_cmd = ini_get('mongo.cmd');
            if($this->_cmd == ''){
                $this->_cmd = '$';
            }
        }
    }

    /* ==================================== 基本操作接口API　================================= */

    /**
     * 向集合(表)中插入新文档
     *
     * 说明：
     * 1:类似mysql中的: insert into $colName set id=1,name='name1';
     *
     * @param string $colName 集合名
     * @param array $sets 数据,如: array('id'=>1,'name'=>'name1')
     * @param boolean $safe 是否安全操作 false:不等待服务器的响应直接返回 true:等待服务器的响应(数据非常重要时推荐)
     * @param boolean $fsync 操作后是否立即更新到碰盘,默认情况下由服务器决定
     *
     * @return boolean
     */
    public function insert($colName, $sets, $safe=false, $fsync=false){
        $col = $this->_getCol($colName);
        try {
            $col->insert($sets,array('w'=>$safe,'fsync'=>$fsync));
            return true;
        }catch (MongoCursorException $e){
            return false;
        }
    }

    /**
     * 保存文档
     *
     * 说明：
     * 1:如果 $sets 中有字段 "_id" 的话，则更新对应的文档；否则插入新文档
     *
     * @param string $colName 集合名
     * @param array $sets 数据,如: array('id'=>1,'name'=>'name1')
     * @param boolean $safe 是否安全操作 false:不等待服务器的响应直接返回 true:等待服务器的响应(数据非常重要时推荐)
     * @param boolean $fsync 操作后是否立即更新到碰盘,默认情况下由服务器决定
     *
     * @return boolean
     */
    public function save($colName, $sets, $safe=false, $fsync=false){
        // 处理 '_id' 字段
        $sets = $this->_parseId($sets);
        $ret = $this->_getCol($colName)->save($sets,array('w'=>$safe,'fsync'=>$fsync));
        return $ret;
    }

    /**
     * 删除集合中的文档记录
     *
     * 说明：
     * 1：类似mysql中的: delete from $colName where id=1;
     *
     * @param string $colName 集合名
     * @param array $query 查询条件,如果为空数组的话，则会删除所有记录．具体请看 [查询条件说明文档]
     * @param boolean $delAll 是否删除所以条例查询的记录,默认为 true,当为 false是，类似效果 delete from tab where id=1 limit 1;
     * @param boolean $safe 是否安全操作 false:不等待服务器的响应直接返回 true:等待服务器的响应(数据非常重要时推荐)
     * @param boolean $fsync 操作后是否立即更新到碰盘,默认情况下由服务器决定
     *
     * @return boolean
     */
    public function delete($colName,$query=array(),$delAll=true,$safe=false,$fsync=false){
        // 自动处理 '_id' 字段
        $query = $this->_parseId($query);
        // 删除选项
        $options = array(
            'justOne'    =>    !$delAll,
            'w'            =>    $safe,
            'fsync'        =>    $fsync,
        );
        $col = $this->_getCol($colName);
        return $col->remove($query,$options);
    }

    /**
     * 删除整个集合
     *
     * 说明：
     * 1：集合中的索引也会被删除
     *
     * @param string $colName 集合名
     *
     * @return array
     */
    public function dropCol($colName){
        return $this->_getCol($colName)->drop();
    }

    /**
     * 更新集合文档记录
     *
     * 说明:
     * 1：类似mysql中的: update $colName set name='mongo' where id=10;
     *
     * @param string $colName 集合名
     * @param array $newDoc 要更新的文档记录
     * @param array $query 查询条件,如果为空数组则更新所有记录．具体请看 [查询条件说明文档]
     * @param string $option 操作选项,可选择项如下；
     *
     * 'set'：只修改指定的字段（默认值,如果这个键不存在，则创建它。存在则更新）.
     * 示例: update('user', array('name'=>'mongo'), array('id'=>10));
     * 类似: update user set name='mongo' where id=10;
     *
     * 'inc'：将指定的字段累加/减(如果值为负数则是相减,不存在键则创建。字段类型一定要是数字)
     * 示例：update('user', array('num'=>1), array('id'=>10), 'inc');
     * 类似: update user set num=num+1 where id=10;
     *
     * 'push'：将文档添加到指定键中（数组），如果键不存在则会自动创建，存在则添加到该键的尾端。
     * 示例：update('user', array('comm'=>array('commid'=>1,'title'=>'title1')), array('id'=>1), 'push');
     * 解说：为 id=1 的记录添加一个 comm 的评论字段，该字段对应一个 array('commid'=>1,'title'=>'title1') 的新文档。
     *
     * 'pop':将指定键中的文档删除（数组）
     * 示例：update('user', array('comm'=>array('commid'=>1)), array('id'=>1), 'pop');
     * 解说：删除 id=1 的记录中 comm 对应的文档集合中 'commid'=>1 对应的文档.
     *
     * 'unset':在文档中删除指定的键
     * 示例：update('user', array('name'=>1), array('id'=>1), 'unset');
     * 解说: 将 user 集合中将 id=1 对应的文档中的 name 字段删除
     *
     * 'pull':删除文档中匹配其值的键
     * 示例：update('user', array('name'=>'youname'), array('id'=>1), 'pull');
     * 解说：将 user 集合中将 id=1 对应的文档中的 name='youname' 的字段删除
     *
     * 'addToSet':如果值不存在就添加（避免重复添加）
     * 示例：update('user', array('names'=>'youname'), array('id'=>1), 'addToSet');
     * 解说：向 user 集合中 id=1 对应的文档中的 names 字段添加 'youname' 这个值(不存在时才添加)
     *
     * 'replace'：用 $newDoc 新文档替换 $query 所找到的文档
     * 示例：update('user', array('newid'=>1,'newnames'=>'name1'), array('id'=>1), 'replace');
     * 解说：将 user 集合中 id=1 对应的文档用 array('newid'=>1,'newnames'=>'name1') 的新文档替换
     *
     * @param boolean $upAll 是否更新找到的所有记录
     * @param boolean $upsert 如果查询条件不存在时，是否以查询条件和要更新的字段一起新建一个集合
     * @param boolean $safe 是否安全删除 false:不等待服务器的响应直接返回 true:等待服务器的响应(数据非常重要时推荐)
     * @param boolean $fsync 操作后是否立即更新到碰盘,默认情况下由服务器决定
     *
     * @return boolean
     */
    public function update($colName,$newDoc,$query=array(),$option='set',$upAll=true,$upsert=false,$safe=false,$fsync=false){
        // 自动处理 '_id' 字段
        $query = $this->_parseId($query);
        // 得到集合
        $col = $this->_getCol($colName);
        // 重新组合新文档
        if($option != 'replace'){
            $newDoc = array($this->cmd($option) => $newDoc);
        }
        // 更新条件
        $options = array(
            'upsert'    =>    $upsert,
            'multiple'    =>    $upAll,
            'w'            =>    $safe,
            'fsync'        =>    $fsync,
        );
        return $col->update($query,$newDoc,$options);
    }

    /**
     * 查询文档集,返回二维数组
     *
     * 说明:
     * 1:类似mysql中的 select * from table
     *
     * 示例：select('user');
     * 类似：select * from user;
     *
     * 示例：select('user',array('id','name'));
     * 类似：select id,name from user;
     *
     * 示例：select('user',array('id','name'),array('id'=>1));
     * 类似：select id,name from user where id=1;
     *
     * 示例：select('user',array('id','name'),array('id'=>1),array('num'=>1));
     * 类似：select id,name from user where id=1 order by num asc;
     *
     * 示例：select('user',array('id','name'),array('id'=>1),array('num'=>1),10);
     * 类似：select id,name from user where id=1 order by num asc limit 10;
     *
     * 示例：select('user',array('id','name'),array('id'=>1),array('num'=>1),10,2);
     * 类似：select id,name from user where id=1 order by num asc limit 2,10;
     *
     *
     *
     * @param string $colName 集合名
     * @param array $query 查询条件,具体请看 [查询条件说明文档]
     * @param array $fields 结果集返回的字段, array():表示返回所有字段 array('id','name'):表示只返回字段 "id,name"
     * @param array $sort 排序字段, array('id'=>1):表示按id字段升序 array('id'=>-1):表示按id字段降序 array('id'=>1, 'age'=>-1):表示按id升序后再按age降序
     * @param int $limit 取多少条记录
     * @param int $skip 跳过多少条(从多少条开始)
     *
     * @return array
     */
    public function select($colName,$query=array(),$fields=array(),$sort=array(),$limit=0,$skip=0){
        // 得到集合
        $col = $this->_getCol($colName);
        // 自动处理 '_id' 字段
        $query = $this->_parseId($query);
        // 结果集偏历
        $cursor  = $col->find($query,$fields);
        // 排序
        if($sort){
            $cursor->sort($sort);
        }
        // 跳过记录数
        if($skip > 0){
            $cursor->skip($skip);
        }
        // 取多少行记录
        if($limit > 0){
            $cursor->limit($limit);
        }
        $result = array();
        foreach($cursor  as $row){
            $result[] = $this->_parseArr($row);
        }
        return $result;
    }

    /**
     * 统计文档记录数
     *
     * @param string $colName 集合名
     * @param array $query 查询条件,具体请看 [查询条件说明文档]
     * @param int $limit 取多少条记录
     * @param int $skip 跳过多少条
     * @return unknown
     */
    public function count($colName,$query=array(),$limit=0,$skip=0){
        return $this->_getCol($colName)->count($query,$limit,$skip);
    }

    /**
     * 返回集合中的一条记录(一维数组)
     *
     * @param string $colName 集合名
     * @param array $query 查询条件,具体请看 [查询条件说明文档]
     * @param array $fields 结果集返回的字段, array():表示返回所有字段 array('id','name'):表示只返回字段 "id,name"
     *
     * @return array
     */
    public function fetchRow($colName,$query=array(), $fields=array()){
        // 得到集合名
        $col = $this->_getCol($colName);
        // 自动处理 '_id' 字段
        $query = $this->_parseId($query);
        // 处理结果集
        return $this->_parseArr($col->findOne($query,$fields));
    }

    /**
     * 返回符合条件的文档中字段的值
     *
     * @param string $colName 集合名
     * @param array $query 查询条件,具体请看 [查询条件说明文档]
     * @param string $fields 要取其值的字段,默认为 "_id" 字段,类似mysql中的自增主键
     *
     * @return mixed
     */
    public function fetchOne($colName,$query=array(), $fields='_id'){
        $ret = $this->fetchRow($colName,$query,array($fields));
        return isset($ret[$fields]) ? $ret[$fields] : false;
    }

    /**
     * 返回查询文档集合集中指定字段的值(一维数组)
     *
     * @param string $colName 集合名
     * @param array $query 查询条件,具体请看 [查询条件说明文档]
     * @param string $fields 要取其值的字段,默认为 "_id" 字段,类似mysql中的自增主键
     *
     * @return array
     */
    public function fetchCol($colName,$query=array(), $fields='_id'){
        $result = array();
        $list = $this->select($colName,$query,array($fields));
        foreach ($list as $row){
            $result[] = $row[$fields];
        }
        return $result;
    }

    /**
     * 返回指定下标的查询文档集合(二维数组)
     *
     * @param string $colName 集合名
     * @param array $query 查询条件,具体请看 [查询条件说明文档]
     * @param string $fields 要取其值的字段,默认为 "_id" 字段,类似mysql中的自增主键
     *
     * @return array
     */
    public function fetchAssoc($colName,$query=array(), $fields='_id'){
        $result = array();
        $list = $this->select($colName,$query);
        foreach ($list as $row){
            $key = $row[$fields];
            $result[][$key] = $row;
        }
        return $result;
    }

    /* ==================================== 辅助操作接口API　================================= */

    /**
     * 返回命令或命令前缀
     *
     * @param string $option 命令，如果为空时则返回命令前缀
     *
     * @return string
     */
    public function cmd($option=''){
        // 只返回命令前缀
        if($option == ''){
            return $this->_cmd;
        }
        // 如果是操作符
        if(isset($this->_condMap[$option])){
            $option = $this->_condMap[$option];
        }
        return $this->_cmd.$option;
    }

    /**
     * 选择或创建数据库(注意：新创建的数据库如果在关闭连接前没有写入数据将会被自动删除)
     *
     * @param string $dbname 数据库名
     */
    public function selectDB($dbname){
        $this->_db = $this->_mongo->selectDB($dbname);
    }

    /**
     * 得到所有的数据库
     *
     * @param boolean $onlyName 是否只返回数据库名的数组
     * @return array
     */
    public function allDB($onlyName=false){
        $ary = $this->_mongo->listDBs();
        if($onlyName){
            $ret = array();
            foreach ($ary['databases'] as $row){
                $ret[] = $row['name'];
            }
            return $ret;
        }else{
            return $ary;
        }
    }

    /**
     * 删除数据库
     *
     * @return array
     */
    public function dropDB($dbname){
        return $this->_mongo->dropDB($dbname);
    }

    /**
     * 关闭连接
     *
     */
    public function close(){
        $this->_mongo->close();
    }

    /**
     * 得到 Mongo 原生对象，进行其它更高级的操作，详细请看PHP手册
     *
     */
    public function getMongo(){
        return $this->_mongo;
    }

    /**
     * 返回最后的错误信息
     *
     * @return array
     */
    public function getError(){
        return $this->_db->lastError();
    }

    /* ======================= 以下为私有方法 ====================== */

    // 解析数据组中的'_id'字段(如果有的话)
    private function _parseId($arr){
        if(isset($arr['_id'])){
            $arr['_id'] = new MongoId($arr['_id']);
        }
        return $arr;
    }

    // 得到集合对象
    private function _getCol($colName){
        return $this->_db->selectCollection($colName);
    }

    // 解析数组中的"_id"并且返回
    private function _parseArr($arr){
        if(!empty($arr)) {
            $ret = (array)$arr['_id'];
            $arr['_id'] = $ret['$id'];
        }
        return $arr;
    }
}//End Class
?>

<?php    

    
    /***
    * 生成excle文件
    ***/
    $time = time();
    $filename = date("Y年m月d日h点m分s秒", $time).'问卷数据';
    $rows =  Sp_Looks_Vote::downvote();
    $file = $filename.".csv";
    header('Content-Description: File Transfer');
    header('Content-Type: application/octet-stream');  
    header('Content-Disposition: attachment; filename='.basename($file));
    header('Content-Transfer-Encoding: binary');
    header('Expires: 0');
    header('Cache-Control: must-revalidate, post-check=0, pre-check=0');
    header('Pragma: public');

    $tabletitle .= "购买地址,常常购买,喜欢模特,内容如何,印象如何,是否购买,感觉如何,购买方式,购买方式建议,吸引点,改进建议";

    $conter = iconv('utf-8','gbk',$tabletitle)."\n";

    echo $conter;die;





    /***
    * 生成word文件
    ***/

    header("Content-Type:   application/msword");        
    header("Content-Disposition:   attachment;   filename=doc.doc");        
    header("Pragma:   no-cache");        
    header("Expires:   0");        

    $output    =   '<table border="1" cellspacing="2" cellpadding="2"  width="90%" align="center">';        
    $output   .=   '<tr bgcolor="#cccccc"><td   align="center">图片</td></tr>';        
    $output   .=   '<tr bgcolor="#f6f7fa"><td><span style="color:#FF0000;"><strong>下面是一张图片</strong></span& gt;</td></tr>';        
    $output   .=   '<tr><td align="center"><img src="http://zi.csdn.net/48260_2.gif"></td></tr>';        
    $output   .=   '</table>';  


    echo   $output;  



  ?>

非缓冲查询方法一: mysqli
<?php
$mysqli  = new mysqli("localhost", "my_user", "my_password", "world");
$uresult = $mysqli->query("SELECT Name FROM City", MYSQLI_USE_RESULT);
if ($uresult) {
   while ($row = $uresult->fetch_assoc()) {
       echo $row['Name'] . PHP_EOL;
   }
}
$uresult->close();
?>

非缓冲查询方法二: pdo_mysql
<?php
$pdo = new PDO("mysql:host=localhost;dbname=world", 'my_user', 'my_pass');
$pdo->setAttribute(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY, false);
$uresult = $pdo->query("SELECT Name FROM City");
if ($uresult) {
   while ($row = $uresult->fetch(PDO::FETCH_ASSOC)) {
       echo $row['Name'] . PHP_EOL;
   }
}
?>

非缓冲查询方法三: mysql
<?php
$conn = mysql_connect("localhost", "my_user", "my_pass");
$db   = mysql_select_db("world");
$uresult = mysql_unbuffered_query("SELECT Name FROM City");
if ($uresult) {
   while ($row = mysql_fetch_assoc($uresult)) {
       echo $row['Name'] . PHP_EOL;
   }
}
?>

<?php
/**
* 操纵文件类
*
* 例子：
* FileUtil::createDir('a/1/2/3'); 测试建立文件夹 建一个a/1/2/3文件夹
* FileUtil::createFile('b/1/2/3'); 测试建立文件 在b/1/2/文件夹下面建一个3文件
* FileUtil::createFile('b/1/2/3.exe'); 测试建立文件 在b/1/2/文件夹下面建一个3.exe文件
* FileUtil::copyDir('b','d/e'); 测试复制文件夹 建立一个d/e文件夹，把b文件夹下的内容复制进去
* FileUtil::copyFile('b/1/2/3.exe','b/b/3.exe'); 测试复制文件 建立一个b/b文件夹，并把b/1/2文件夹中的3.exe文件复制进去
* FileUtil::moveDir('a/','b/c'); 测试移动文件夹 建立一个b/c文件夹,并把a文件夹下的内容移动进去，并删除a文件夹
* FileUtil::moveFile('b/1/2/3.exe','b/d/3.exe'); 测试移动文件 建立一个b/d文件夹，并把b/1/2中的3.exe移动进去
* FileUtil::unlinkFile('b/d/3.exe'); 测试删除文件 删除b/d/3.exe文件
* FileUtil::unlinkDir('d'); 测试删除文件夹 删除d文件夹
*/
class FileUtil {
/**
* 建立文件夹
*
* @param string $aimUrl
* @return viod
*/
function createDir($aimUrl) {
$aimUrl = str_replace('', '/', $aimUrl);
$aimDir = '';
$arr = explode('/', $aimUrl);
$result = true;
foreach ($arr as $str) {
$aimDir .= $str . '/';
if (!file_exists($aimDir)) {
$result = mkdir($aimDir);
}
}
return $result;
}
/**
* 建立文件
*
* @param string $aimUrl
* @param boolean $overWrite 该参数控制是否覆盖原文件
* @return boolean
*/
function createFile($aimUrl, $overWrite = false) {
if (file_exists($aimUrl) && $overWrite == false) {
return false;
} elseif (file_exists($aimUrl) && $overWrite == true) {
FileUtil :: unlinkFile($aimUrl);
}
$aimDir = dirname($aimUrl);
FileUtil :: createDir($aimDir);
touch($aimUrl);
return true;
}
/**
* 移动文件夹
*
* @param string $oldDir
* @param string $aimDir
* @param boolean $overWrite 该参数控制是否覆盖原文件
* @return boolean
*/
function moveDir($oldDir, $aimDir, $overWrite = false) {
$aimDir = str_replace('', '/', $aimDir);
$aimDir = substr($aimDir, -1) == '/' ? $aimDir : $aimDir . '/';
$oldDir = str_replace('', '/', $oldDir);
$oldDir = substr($oldDir, -1) == '/' ? $oldDir : $oldDir . '/';
if (!is_dir($oldDir)) {
return false;
}
if (!file_exists($aimDir)) {
FileUtil :: createDir($aimDir);
}
@ $dirHandle = opendir($oldDir);
if (!$dirHandle) {
return false;
}
while (false !== ($file = readdir($dirHandle))) {
if ($file == '.' || $file == '..') {
continue;
}
if (!is_dir($oldDir . $file)) {
FileUtil :: moveFile($oldDir . $file, $aimDir . $file, $overWrite);
} else {
FileUtil :: moveDir($oldDir . $file, $aimDir . $file, $overWrite);
}
}
closedir($dirHandle);
return rmdir($oldDir);
}
/**
* 移动文件
*
* @param string $fileUrl
* @param string $aimUrl
* @param boolean $overWrite 该参数控制是否覆盖原文件
* @return boolean
*/
function moveFile($fileUrl, $aimUrl, $overWrite = false) {
if (!file_exists($fileUrl)) {
return false;
}
if (file_exists($aimUrl) && $overWrite = false) {
return false;
} elseif (file_exists($aimUrl) && $overWrite = true) {
FileUtil :: unlinkFile($aimUrl);
}
$aimDir = dirname($aimUrl);
FileUtil :: createDir($aimDir);
rename($fileUrl, $aimUrl);
return true;
}
/**
* 删除文件夹
*
* @param string $aimDir
* @return boolean
*/
function unlinkDir($aimDir) {
$aimDir = str_replace('', '/', $aimDir);
$aimDir = substr($aimDir, -1) == '/' ? $aimDir : $aimDir . '/';
if (!is_dir($aimDir)) {
return false;
}
$dirHandle = opendir($aimDir);
while (false !== ($file = readdir($dirHandle))) {
if ($file == '.' || $file == '..') {
continue;
}
if (!is_dir($aimDir . $file)) {
FileUtil :: unlinkFile($aimDir . $file);
} else {
FileUtil :: unlinkDir($aimDir . $file);
}
}
closedir($dirHandle);
return rmdir($aimDir);
}
/**
* 删除文件
*
* @param string $aimUrl
* @return boolean
*/
function unlinkFile($aimUrl) {
if (file_exists($aimUrl)) {
unlink($aimUrl);
return true;
} else {
return false;
}
}
/**
* 复制文件夹
*
* @param string $oldDir
* @param string $aimDir
* @param boolean $overWrite 该参数控制是否覆盖原文件
* @return boolean
*/
function copyDir($oldDir, $aimDir, $overWrite = false) {
$aimDir = str_replace('', '/', $aimDir);
$aimDir = substr($aimDir, -1) == '/' ? $aimDir : $aimDir . '/';
$oldDir = str_replace('', '/', $oldDir);
$oldDir = substr($oldDir, -1) == '/' ? $oldDir : $oldDir . '/';
if (!is_dir($oldDir)) {
return false;
}
if (!file_exists($aimDir)) {
FileUtil :: createDir($aimDir);
}
$dirHandle = opendir($oldDir);
while (false !== ($file = readdir($dirHandle))) {
if ($file == '.' || $file == '..') {
continue;
}
if (!is_dir($oldDir . $file)) {
FileUtil :: copyFile($oldDir . $file, $aimDir . $file, $overWrite);
} else {
FileUtil :: copyDir($oldDir . $file, $aimDir . $file, $overWrite);
}
}
return closedir($dirHandle);
}
/**
* 复制文件
*
* @param string $fileUrl
* @param string $aimUrl
* @param boolean $overWrite 该参数控制是否覆盖原文件
* @return boolean
*/
function copyFile($fileUrl, $aimUrl, $overWrite = false) {
if (!file_exists($fileUrl)) {
return false;
}
if (file_exists($aimUrl) && $overWrite == false) {
return false;
} elseif (file_exists($aimUrl) && $overWrite == true) {
FileUtil :: unlinkFile($aimUrl);
}
$aimDir = dirname($aimUrl);
FileUtil :: createDir($aimDir);
copy($fileUrl, $aimUrl);
return true;
}
}
?>

/**
* 日志记录，按照"Y-m-d.log"生成当天日志文件
* 日志路径为：入口文件所在目录/logs/$type/当天日期.log.php，例如 /logs/error/2012-01-05.log.php
* @param string $content 日志内容
* @param string $type 对应logs目录下的子文件夹名
* @return bool true/false 返回写入的字符数，出现错误时则返回 FALSE 。
*/
function writelog($content = "", $type = "")
{
    date_default_timezone_set('PRC');
    //判断日志根目录是否存在，不存在则创建
    $log_root = getcwd() . DIRECTORY_SEPARATOR . 'logs';
//    $log_root = ROOT_PATH . 'logs';

    if (!is_dir($log_root)) {
        mkdir($log_root, 0777);
    }

    //如传入第二个参数，则生成子文件夹；否则在根目录创建日志
    if ($type) {
        $dir = $log_root . DIRECTORY_SEPARATOR . $type;
        if (!is_dir($dir)) {
            if (!mkdir($dir, 0777, true)) {
                return false;
            }
        }
    } else {
        $dir = $log_root;
    }
    $filename = $dir . DIRECTORY_SEPARATOR . date("Y-m-d") . '.log.txt';
    if (is_array($content)) {
        $content = print_r($content, true);
    }

    $ss = '';
    for ($i = 1; $i <= 115; $i++) {
        $ss .= '-';
    }
    $exec_url = 'http://' . $_SERVER['SERVER_NAME'] . $_SERVER["REQUEST_URI"];
    //组装数据
    $str = "\r\n" . 'time:' . date("Y-m-d H:i:s")
        . "\r\n" . 'exec_url:' . $exec_url;
    $str .= "\r\n" . 'content:' . $content
        . "\r\n"
        . $ss;
    if (!$fp = @fopen($filename, "ab")) {
        return false;
    }
    flock($fp, LOCK_EX);
    $res = fwrite($fp, $str);
    flock($fp, LOCK_UN);
    fclose($fp);
    return $res;
}

/**
* 日志记录，按照"Y-m-d.log"生成当天日志文件
* 日志路径为：入口文件所在目录/logs/$type/当天日期.log.php，例如 /logs/error/2012-01-05.log.php
* @param string $content 日志内容
* @param string $type 对应logs目录下的子文件夹名
* @return bool true/false 返回写入的字符数，出现错误时则返回 FALSE 。
*/
function write_log($content = "", $type = "")
{
    date_default_timezone_set('PRC');
    //判断日志根目录是否存在，不存在则创建
    $log_root = getcwd() . DIRECTORY_SEPARATOR . 'logs';
//    $log_root = ROOT_PATH . 'logs';

    if (!is_dir($log_root)) {
        mkdir($log_root, 0777);
    }

    //如传入第二个参数，则生成子文件夹；否则在根目录创建日志
    if ($type) {
        $dir = $log_root . DIRECTORY_SEPARATOR . $type;
        if (!is_dir($dir)) {
            if (!mkdir($dir, 0777, true)) {
                return false;
            }
        }
    } else {
        $dir = $log_root;
    }
    //判断日志文件是否存在,以及内容是否为数组，不是数组则删除文件;
    $filename = $dir . DIRECTORY_SEPARATOR . date("Y-m-d") . '.log.php';
    @$logs = include $filename;
    if ($logs && !is_array($logs)) {
        unlink($filename);
        $logs = array();
    }

    //将时间和内容写入日志
    $exec_url = 'http://' . $_SERVER['SERVER_NAME'] . $_SERVER["REQUEST_URI"];
    //组装数据
    $this_log = array(
        "time" => date("Y-m-d H:i:s"),
        'exec_url' => $exec_url,
    );
    $this_log['content'] = $content;
    $logs[] = $this_log;
    $str = "<?php \r\n return " . array_eval($logs) . ";";
    if (!$fp = @fopen($filename, "wb")) {
        return false;
    }
    flock($fp, LOCK_EX);
    $res = fwrite($fp, $str);
    flock($fp, LOCK_UN);
    fclose($fp);
    return $res;
}
/**
* @desc 数组转换成字串
* @param $array
* @param bool $format
* @param int $level
* @return string
*/
function array_eval($array, $format = false, $level = 0)
{
    $space = $line = '';
    if (!$format) {
        for ($i = 0; $i <= $level; $i++) {
            $space .= "\t";
        }
        $line = "\n";
    }
    $evaluate = 'array' . $line . $space . '(' . $line;
    $comma = $space;
    foreach ($array as $key => $val) {
        $key = is_string($key) ? '\'' . addcslashes($key, '\'\\') . '\'' : $key;
        $val = !is_array($val) && (!preg_match('/^\-?\d+$/', $val) || strlen($val) > 12) ? '\'' . addcslashes($val, '\'\\') . '\'' : $val;
        if (is_array($val)) {
            $evaluate .= $comma . $key . ' => ' . array_eval($val, $format, $level + 1);
        } else {
            $evaluate .= $comma . $key . ' => ' . $val;
        }
        $comma = ',' . $line . $space;
    }
    $evaluate .= $line . $space . ')';
    return $evaluate;
}