mint/app/collect/function.php

<?php
require_once '../path.php';
require_once "../share/function.php";
require_once "../db/table.php";
require_once "../article/function.php";

class CollectInfo
{
    private $dbh;
    private $buffer;
	private $_redis;
	private $errorMsg;
    public function __construct($redis=false) {
        $dns = ""._FILE_DB_USER_ARTICLE_;
        $this->dbh = new PDO($dns, "", "",array(PDO::ATTR_PERSISTENT=>true));
        $this->dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);  
		$this->_redis=$redis;
        $buffer = array();
    }

    public function get($id){
        if(empty($id)){
            return array("title"=>"","id"=>"");
        }
        if(isset($buffer[$id])){
            return $buffer[$id];
        }
        if($this->dbh){
            $query = "SELECT id,title,owner,status,lang, FROM collect WHERE id= ?";
            $stmt = $this->dbh->prepare($query);
            $stmt->execute(array($id));
			$collect = $stmt->fetch(PDO::FETCH_ASSOC);
            if($collect){
                $buffer[$id] = $collect;
                return $buffer[$id];
            }
            else{
                $buffer[$id] =false;
                return $buffer[$id];
            }
        }
        else{
            $buffer[$id] = false;
            return $buffer[$id];
        }
    }

	public function getArticleList($id){
        if(empty($id)){
            return array();
        }
        if($this->dbh){
            $query = "SELECT article_id FROM article_list WHERE collect_id= ? limit 0,1000";
            $stmt = $this->dbh->prepare($query);
            $stmt->execute(array($id));
			$article_list = $stmt->fetchAll(PDO::FETCH_ASSOC);
			$output=array();
			foreach ($article_list as $key => $value) {
				# code...
				$output[]=$value["article_id"];
			}
			return $output;
        }
        else{
            return array();
        }
    }

	public function getPower($id){
		#查询用户对此是否有权限	
		if(isset($_COOKIE["userid"])){
			$userId = $_COOKIE["userid"];
		}
		else{
			$userId='0';
		}
		if($this->_redis!==false){
			$power = $this->_redis->hGet("power://collection/".$id,$userId);
			if($power!==FALSE){
				return $power;
			}
		}
		$iPower = 0;
		$query = "SELECT owner,status FROM collect WHERE id=?  ";
		$stmt = $this->dbh->prepare($query);
		$stmt->execute(array($id));
		$result = $stmt->fetch(PDO::FETCH_ASSOC);
		if($result){
			if(!isset($_COOKIE["userid"])){
				#未登录用户
				if($result["status"]==30){
					#全网公开有读取和建议权限
					return 10;
				}
				else{
					#其他状态没有任何权限
					return 0;
				}
			}
			else{
				if($result["owner"]==$_COOKIE["userid"]){
					#自己的
					return 30;
				}
				else if($result["status"]>=30){
					#全网公开的 可以提交pr
					$iPower = 10;
				}			
			}
			#查询共享权限，如果共享权限更大，覆盖上面的的
			$sharePower = share_get_res_power($userId,$id);
			if($sharePower>$iPower){
				$iPower=$sharePower;
			}
			$this->_redis->hSet("power://collection/".$id,$userId,$iPower);			
		}
		return $iPower;
	}

	public function update($arrData){
		/* 修改现有数据 */
	
		if (count($arrData) > 0) {
			$this->dbh->beginTransaction();
			$query="UPDATE collect SET title = ? , subtitle = ? , summary = ?, article_list = ?  ,  status = ? , lang = ? , receive_time= ?  , modify_time= ?   where  id = ?  ";
			$sth = $this->dbh->prepare($query);
			foreach ($arrData as $data) {
				$sth->execute(array($data["title"] , $data["subtitle"] ,$data["summary"], $data["article_list"] , $data["status"] , $data["lang"] ,  mTime() , mTime() , $data["id"]));
			}
			$this->dbh->commit();
		
			if (!$sth || ($sth && $sth->errorCode() != 0)) {
				/*  识别错误且回滚更改  */
				$this->dbh->rollBack();
				$error = $this->dbh->errorInfo();
				$this->errorMsg = $error[2];
				return false;
			} else {
				#没错误 添加log 
				$this->errorMsg = "";
				//更新列表
				$ArticleList = new ArticleList($this->_redis);
				foreach ($arrData as $data) {
					$arrList = json_decode($data["article_list"],true);
					$ArticleList->upgrade($data["id"],$arrList);
				}
				return true;
			}
		}
		else{
			$this->errorMsg = "";
			return true;
		}
	}

	public function insert($arrData){
		/* 插入新数据 */
		$respond=array("status"=>0,"message"=>"");
		if (count($arrData) > 0) {
			$this->dbh->beginTransaction();
			$query="INSERT INTO collect ( id,  title  , subtitle  , summary , article_list , owner, lang  , status  , create_time , modify_time , receive_time   )  VALUES  ( ? , ? , ? , ?  , ? , ? , ? , ? , ? , ? , ? ) ";
			$sth = $this->dbh->prepare($query);
			$newDataList=array();
			foreach ($arrData as $data) {
				$newData = array();
				if(isset($data["title"]) && !empty($data["title"])){
					$newData["title"]=$data["title"];
					if(isset($data["id"])){
						$newData["id"]=$data["id"];
					}
					else{
						$newData["id"]=UUID::v4();
					}
					if(isset($data["subtitle"])){
						$newData["subtitle"]=$data["subtitle"];
					}
					else{
						$newData["subtitle"]="";
					}
					if(isset($data["summary"])){
						$newData["summary"]=$data["summary"];
					}
					else{
						$newData["summary"]="";
					}	
					if(isset($data["article_list"])){
						$newData["article_list"]=$data["article_list"];
					}
					else{
						$newData["article_list"]="";
					}		
					if(isset($data["lang"])){
						$newData["lang"]=$data["lang"];
					}
					else{
						$newData["lang"]="";
					}
					if(isset($data["status"])){
						$newData["status"]=$data["status"];
					}
					else{
						$newData["status"]="1";
					}
					$newDataList[]=$newData;
					$sth->execute(array($newData["id"] , $newData["title"] , $newData["subtitle"] ,$newData["summary"], $newData["article_list"] ,  $_COOKIE["userid"] , $newData["lang"] , $newData["status"] , mTime() ,  mTime() , mTime() ));				
				}
				else{
					$this->errorMsg="标题不能为空";
				}
			}
			$this->dbh->commit();
	
			if (!$sth || ($sth && $sth->errorCode() != 0)) {
				/*  识别错误且回滚更改  */
				$this->dbh->rollBack();
				$error = $this->dbh->errorInfo();
				$this->errorMsg = $error[2];
				return false;
			} else {
				$this->errorMsg = "";
				//更新列表
				$ArticleList = new ArticleList($this->_redis);
				foreach ($newDataList as $data) {
					$arrList = json_decode($data["article_list"],true);
					$ArticleList->upgrade($data["id"],$arrList);
				}
				return true;
			}
		}
		else{
			$this->errorMsg = "";
			return true;
		}
	}
}
?>