westdc-zf1/vendor/Westdc/Metadata/Outlink.php

<?php
namespace Westdc\Metadata;

use Sookon\Helpers\View as view;
use Sookon\Helpers\Dbh as dbh;
use Sookon\Helpers\PDO;
use Sookon\Helpers\Config;
use Sookon\Helpers\Table;
use Zend\Http\PhpEnvironment\Request;
use Zend\EventManager\EventManagerInterface;
use Zend\EventManager\EventManager;
use Zend\EventManager\EventManagerAwareInterface;
use Westdc\Metadata\Listener\OutlinkListener as Listener;

class Outlink
{
	private $db;				//传入PDO对象
	private $config;			//站点设置
	private $table;
	
	public $opt;
	
	protected $events = NULL;
		
	function __construct()
	{
		$this->db = new PDO;
		$this->config = Config::get();
		$this->table = new Table;
		
		$this->opt = new \stdClass();
		
		$this->opt->sort = "DESC";
		$this->opt->logic = "AND";
		
		$Listener = new Listener();
		$this->getEventManager()->attachAggregate($Listener);
	}
	
	public function setEventManager(EventManagerInterface $events)
    {
        $events->setIdentifiers(array(
            __CLASS__,
            get_called_class(),
        ));
        $this->events = $events;
        return $this;
    }

    public function getEventManager()
    {
        if (NULL === $this->events) {
            $this->setEventManager(new EventManager());
        }
        return $this->events;
    }
	
	public function fetchAll()
	{
		$wheresql = array();
		
		if(isset($this->opt->where) && !empty($this->opt->where))
			$wheresql = array_merge($wheresql,$this->opt->where);
		
		if(count($wheresql)>0)
		{
			$wheresql = " WHERE ".join($wheresql," ".$this->opt->logic." ");
		}else{
			$wheresql = '';
		}
		
		if(!empty($this->opt->order))
		{
			$order = $this->opt->order;
		}else{
			$order = "m.id";
		}
		
		$sql = "SELECT 
					m.*,md.viewed, ds.id as datasetid ,ol.url
				FROM {$this->table->metadata} m
				LEFT join {$this->table->metadata_stat} md on m.uuid=md.uuid
				LEFT JOIN mdstatus st ON md.uuid=st.uuid
				left join dataset ds on m.uuid=ds.uuid
				LEFT JOIN mdoutlink ol ON m.uuid = ol.uuid
				$wheresql
				ORDER BY $order {$this->opt->sort}";
		
		if(!empty($this->opt->start))
		{
			$sql .= " START {$this->opt->start} ";
		}
		
		if(!empty($this->opt->limit)){
			$sql .= " LIMIT {$this->opt->limit} ";
		}
		//view::Dump($sql);
		$rs = $this->db->query($sql);
		return $rs->fetchAll();
	}
	
	public function fetchAllOutlink()
	{
		$wheresql = array();
		
		if(isset($this->opt->where) && !empty($this->opt->where))
			$wheresql = array_merge($wheresql,$this->opt->where);
		
		if(count($wheresql)>0)
		{
			$wheresql = " WHERE ".join($wheresql," ".$this->opt->logic." ");
		}else{
			$wheresql = '';
		}
		
		if(!empty($this->opt->order))
		{
			$order = $this->opt->order;
		}else{
			$order = "ol.id";
		}
		
		$sql = "SELECT 
					ol.*
				FROM {$this->table->metadata_outlink} ol
				$wheresql
				ORDER BY $order {$this->opt->sort}";
		
		if(!empty($this->opt->start))
		{
			$sql .= " START {$this->opt->start} ";
		}
		
		if(!empty($this->opt->limit)){
			$sql .= " LIMIT {$this->opt->limit} ";
		}
		//view::Dump($sql);
		$rs = $this->db->query($sql);
		return $rs->fetchAll();
	}
	
	public function fetch($id)
	{
		$sql = "SELECT m.*,ol.url FROM {$this->table->metadata} m
				LEFT JOIN mdoutlink ol ON m.uuid = ol.uuid \r\n";
		if(is_numeric($id))
		{
			$sql .= "WHERE m.id=$id";
		}else if(\Sookon\Helpers\Uuid::test($id)){
			$sql .= "WHERE m.uuid='$id'";
		}else{
			return false;
		}
		//view::Dump($sql);
		$rs = $this->db->query($sql);
		return $rs->fetch();
	}
	
	public function getParam()
	{
		$request = new Request;
		
		$data = array(
			'uuid' => $request->getPost('uuid'),
			'url' => $request->getPost('url'),
			'remark' => $request->getPost('remark'),
			'status' => $request->getPost('status')
		);
		
		return $data;
	}
	
	//添加
	public function add($data,$id = 0)
	{	
		$params = compact('data');
        $results = $this->getEventManager()->trigger('submit.checkParam', $this, $params);
		$cache_data = $results->last();
		
		if($cache_data !== true)
		{
			return $cache_data;
		}
		
		$results = $this->getEventManager()->trigger('submit.processData', $this, $params);
		$data = $results->last();
		
		$dbh = new dbh();
		
		if(empty($id))
		{
			$id = $dbh->insert($this->table->metadata_outlink,$data,true);
			
			if(!empty($id) && is_numeric($id))
			{
				return true;
			}else{
				if($id === false)
				{
					return '服务器开小差了，请稍后再试';
				}else{
					return '服务器处理中遇到错误，请联系管理员';
				}
			}
		}//add
		
		else{
			if(!$dbh->update($this->table->metadata_outlink,$data," id=$id ",true))
			{
				return "修改失败!请重试";
			}else{
				return true;
			}
		}//edit
		
	}// add()
	
	//通过uuid获得url
	public function getOutlinkByUuid($uuid)
	{
		$sql = "SELECT * FROM {$this->table->metadata_outlink} WHERE uuid='$uuid'";
		$rs = $this->db->query($sql);
		return $rs->fetch();
	}
	
}