path: root/services/tag2tagservice.php

<?php
class Tag2TagService {
	var $db;
	var $tablename;

	function &getInstance(&$db) {
		static $instance;
		if (!isset($instance))
		$instance =& new Tag2TagService($db);
		return $instance;
	}

	function Tag2TagService(&$db) {
		$this->db =& $db;
		$this->tablename = $GLOBALS['tableprefix'] .'tags2tags';
	}

	function addLinkedTags($tag1, $tag2, $relationType, $uId) {
		$tagservice =& ServiceFactory::getServiceInstance('TagService');
		$tag1 = $tagservice->normalize($tag1);
		$tag2 = $tagservice->normalize($tag2);

		if($tag1 == $tag2 || strlen($tag1) == 0 || strlen($tag2) == 0
		|| ($relationType != ">" && $relationType != "=")
		|| !is_numeric($uId) || $uId<=0
		|| ($this->existsLinkedTags($tag1, $tag2, $relationType, $uId))) {
			return false;
		}

		$values = array('tag1' => $tag1, 'tag2' => $tag2, 'relationType'=> $relationType, 'uId'=> $uId);
		$query = 'INSERT INTO '. $this->getTableName() .' '. $this->db->sql_build_array('INSERT', $values);
		//die($query);
		if (!($dbresult =& $this->db->sql_query($query))) {
			$this->db->sql_transaction('rollback');
			message_die(GENERAL_ERROR, 'Could not attach tag to tag', '', __LINE__, __FILE__, $query, $this->db);
			return false;
		}
		$this->db->sql_transaction('commit');

		// Update stats and cache
		$this->update($tag1, $tag2, $relationType, $uId);

		return true;
	}

	// Return linked tags just for admin users
	function getAdminLinkedTags($tag, $relationType, $inverseRelation = false, $stopList = array()) {
		// look for admin ids
		$userservice = & ServiceFactory :: getServiceInstance('UserService');
		$adminIds = $userservice->getAdminIds();
		
		//ask for their linked tags
		return $this->getLinkedTags($tag, $relationType, $adminIds, $inverseRelation, $stopList);
	}
	
	// Return the target linked tags. If inverseRelation is true, return the source linked tags.
	function getLinkedTags($tag, $relationType, $uId = null, $inverseRelation = false, $stopList = array()) {
		// Set up the SQL query.
		if($inverseRelation) {
			$queriedTag = "tag1";
			$givenTag = "tag2";
		} else {
			$queriedTag = "tag2";
			$givenTag = "tag1";
		}

		$query = "SELECT DISTINCT ". $queriedTag ." as 'tag'";
		$query.= " FROM `". $this->getTableName() ."`";
		$query.= " WHERE 1=1";
		if($tag !=null) {
			$query.= " AND ". $givenTag ." = '". $tag ."'";
		}
		if($relationType) {
			$query.= " AND relationType = '". $relationType ."'";
		}
		if(is_array($uId)) {
			$query.= " AND ( 1=0 "; //tricks always false			
			foreach($uId as $u) {
				$query.= " OR uId = '".$u."'";
			}
			$query.= " ) "; 
		} elseif($uId != null) {
			$query.= " AND uId = '".$uId."'";
		}
		//die($query);
		if (! ($dbresult =& $this->db->sql_query($query)) ){
			message_die(GENERAL_ERROR, 'Could not get related tags', '', __LINE__, __FILE__, $query, $this->db);
			return false;
		}

		$rowset = $this->db->sql_fetchrowset($dbresult);
		$output = array();
		foreach($rowset as $row) {
			if(!in_array($row['tag'], $stopList)) {
				$output[] = $row['tag'];
			}
		}

		//bijective case for '='
		if($relationType == '=' && $inverseRelation == false) {
			//$stopList[] = $tag;
			$bijectiveOutput = $this->getLinkedTags($tag, $relationType, $uId, true, $stopList);
			$output = array_merge($output, $bijectiveOutput);
			//$output = array_unique($output); // remove duplication
		}

		$this->db->sql_freeresult($dbresult);
		return $output;
	}

	/*
	 * Returns all linked tags (all descendants if relation is >,
	 * all synonyms if relation is = )
	 * $stopList allows to avoid cycle (a > b > a) between tags
	 */
	function getAllLinkedTags($tag1, $relationType, $uId, $stopList=array()) {
		if(in_array($tag1, $stopList) || $tag1 == '') {
			return array();
		}

		// try to find data in cache
		$tcs = & ServiceFactory::getServiceInstance('TagCacheService');
		if(count($stopList) == 0) {
			$activatedCache = true;
		} else {
			$activatedCache = false;
		}

		// look for existing links
		$stopList[] = $tag1;
		$linkedTags = $this->getLinkedTags($tag1, $relationType, $uId, false, $stopList);
		if($relationType != '=') {
			$linkedTags = array_merge($linkedTags, $this->getLinkedTags($tag1, '=', $uId, false, $stopList));
		}

		if(count($linkedTags) == 0) {
			return array();

		} else {
			// use cache if possible
			if($activatedCache) {
				if($relationType == '>') {
					$output = $tcs->getChildren($tag1, $uId);
				} elseif($relationType == '=') {
					$output = $tcs->getSynonyms($tag1, $uId);
				}
				if(count($output)>0) {
					return $output;
				}
			}

			// else compute the links
			$output = array();

			foreach($linkedTags as $linkedTag) {
				$allLinkedTags = $this->getAllLinkedTags($linkedTag, $relationType, $uId, $stopList);
				$output[] = $linkedTag;
				if(is_array($allLinkedTags)) {
					$output = array_merge($output, $allLinkedTags);
				} else {
					$output[] = $allLinkedTags;
				}
			}

			// and save in cache
			if($activatedCache == true && $uId>0) {
				$tcs->updateTag($tag1, $relationType, $output, $uId);
			}
				
			//$output = array_unique($output); // remove duplication
			return $output;

		}
	}

	function getOrphewTags($relationType, $uId = 0, $limit = null, $orderBy = null) {
		$query = "SELECT DISTINCT tts.tag1 as tag";
		$query.= " FROM `". $this->getTableName() ."` tts";
		if($orderBy != null) {
			$tsts =& ServiceFactory::getServiceInstance('TagStatService');
			$query.= ", ".$tsts->getTableName() ." tsts";
		}
		$query.= " WHERE tts.tag1 <> ALL";
		$query.= " (SELECT DISTINCT tag2 FROM `". $this->getTableName() ."`";
		$query.= " WHERE relationType = '".$relationType."'";
		if($uId > 0) {
			$query.= " AND uId = '".$uId."'";
		}
		$query.= ")";
		if($uId > 0) {
			$query.= " AND tts.uId = '".$uId."'";
		}

		switch($orderBy) {
	  case "nb":
	  	$query.= " AND tts.tag1 = tsts.tag1";
	  	$query.= " AND tsts.relationType = '".$relationType."'";
	  	if($uId > 0) {
	  		$query.= " AND tsts.uId = ".$uId;
	  	}
	  	$query.= " ORDER BY tsts.nb DESC";
	  	break;
	  case "depth": // by nb of descendants
	  	$query.= " AND tts.tag1 = tsts.tag1";
	  	$query.= " AND tsts.relationType = '".$relationType."'";
	  	if($uId > 0) {
	  		$query.= " AND tsts.uId = ".$uId;
	  	}
	  	$query.= " ORDER BY tsts.depth DESC";
	  	break;
	  case "nbupdate":
	  	$query.= " AND tts.tag1 = tsts.tag1";
	  	$query.= " AND tsts.relationType = '".$relationType."'";
	  	if($uId > 0) {
	  		$query.= " AND tsts.uId = ".$uId;
	  	}
	  	$query.= " ORDER BY tsts.nbupdate DESC";
	  	break;
		}

		if($limit != null) {
			$query.= " LIMIT 0,".$limit;
		}

		if (! ($dbresult =& $this->db->sql_query($query)) ){
			message_die(GENERAL_ERROR, 'Could not get linked tags', '', __LINE__, __FILE__, $query, $this->db);
			return false;
		}
		$output = $this->db->sql_fetchrowset($dbresult);
		$this->db->sql_freeresult($dbresult);
		return $output;
	}

	function getMenuTags($uId) {
		if(strlen($GLOBALS['menuTag']) < 1) {
			return array();
		} else {
			// we don't use the getAllLinkedTags function in order to improve performance
			$query = "SELECT tag2 as 'tag', COUNT(tag2) as 'count'";
			$query.= " FROM `". $this->getTableName() ."`";
			$query.= " WHERE tag1 = '".$GLOBALS['menuTag']."'";
			$query.= " AND relationType = '>'";
			if($uId > 0) {
				$query.= " AND uId = '".$uId."'";
			}
			$query.= " GROUP BY tag2";
			$query.= " ORDER BY count DESC";
			$query.= " LIMIT 0, ".$GLOBALS['maxSizeMenuBlock'];

			if (! ($dbresult =& $this->db->sql_query($query)) ){
				message_die(GENERAL_ERROR, 'Could not get linked tags', '', __LINE__, __FILE__, $query, $this->db);
				return false;
			}
			$output = $this->db->sql_fetchrowset($dbresult);
			$this->db->sql_freeresult($dbresult);
			return $output;
		}
	}


	function existsLinkedTags($tag1, $tag2, $relationType, $uId) {

		//$tag1 = mysql_real_escape_string($tag1);
		//$tag2 = mysql_real_escape_string($tag2);

		$query = "SELECT tag1, tag2, relationType, uId FROM `". $this->getTableName() ."`";
		$query.= " WHERE tag1 = '" .$tag1 ."'";
		$query.= " AND tag2 = '".$tag2."'";
		$query.= " AND relationType = '". $relationType ."'";
		$query.= " AND uId = '".$uId."'";

		//echo($query."<br>\n");

		return $this->db->sql_numrows($this->db->sql_query($query)) > 0;
	}

	function getLinks($uId) {
		$query = "SELECT tag1, tag2, relationType, uId FROM `". $this->getTableName() ."`";
		$query.= " WHERE 1=1";
		if($uId > 0) {
			$query.= " AND uId = '".$uId."'";
		}

		return $this->db->sql_fetchrowset($this->db->sql_query($query));
	}

	function removeLinkedTags($tag1, $tag2, $relationType, $uId) {
		if(($tag1 != '' && $tag1 == $tag2) ||
		($relationType != ">" && $relationType != "=" && $relationType != "") ||
		($tag1 == '' && $tag2 == '')) {
			return false;
		}
		$query = 'DELETE FROM '. $this->getTableName();
		$query.= ' WHERE 1=1';
		$query.= strlen($tag1)>0 ? ' AND tag1 = "'. $tag1 .'"' : '';
		$query.= strlen($tag2)>0 ? ' AND tag2 = "'. $tag2 .'"' : '';
		$query.= strlen($relationType)>0 ? ' AND relationType = "'. $relationType .'"' : '';
		$query.= strlen($uId)>0 ? ' AND uId = "'. $uId .'"' : '';

		if (!($dbresult =& $this->db->sql_query($query))) {
			message_die(GENERAL_ERROR, 'Could not remove tag relation', '', __LINE__, __FILE__, $query, $this->db);
			return false;
		}


		// Update stats and cache
		$this->update($tag1, $tag2, $relationType, $uId);
		
		$this->db->sql_freeresult($dbresult);
		return true;
	}
	
	function removeLinkedTagsForUser($uId) {
		$query = 'DELETE FROM '. $this->getTableName();
		$query.= ' WHERE uId = "'. $uId .'"';

		if (!($dbresult =& $this->db->sql_query($query))) {
			message_die(GENERAL_ERROR, 'Could not remove tag relation', '', __LINE__, __FILE__, $query, $this->db);
			return false;
		}


		// Update stats and cache
		$this->update('', '', '', $uId);
		
		$this->db->sql_freeresult($dbresult);
		return true;
	}	

	function renameTag($uId, $oldName, $newName) {
		$tagservice =& ServiceFactory::getServiceInstance('TagService');
		$newName = $tagservice->normalize($newName);

		$query = 'UPDATE `'. $this->getTableName() .'`';
		$query.= ' SET tag1="'.$newName.'"';
		$query.= ' WHERE tag1="'.$oldName.'"';
		$query.= ' AND uId="'.$uId.'"';
		$this->db->sql_query($query);

		$query = 'UPDATE `'. $this->getTableName() .'`';
		$query.= ' SET tag2="'.$newName.'"';
		$query.= ' WHERE tag2="'.$oldName.'"';
		$query.= ' AND uId="'.$uId.'"';
		$this->db->sql_query($query);


		// Update stats and cache
		$this->update($oldName, NULL, '=', $uId);
		$this->update($oldName, NULL, '>', $uId);
		$this->update($newName, NULL, '=', $uId);
		$this->update($newName, NULL, '>', $uId);

		return true;

	}

	function update($tag1, $tag2, $relationType, $uId) {
		$tsts =& ServiceFactory::getServiceInstance('TagStatService');
		$tsts->updateStat($tag1, $relationType, $uId);

		$tcs = & ServiceFactory::getServiceInstance('TagCacheService');
		$tcs->deleteByUser($uId);
	}

	function deleteAll() {
		$query = 'TRUNCATE TABLE `'. $this->getTableName() .'`';
		$this->db->sql_query($query);

		$tsts =& ServiceFactory::getServiceInstance('TagStatService');
		$tsts->deleteAll();
	}

	// Properties
	function getTableName()       { return $this->tablename; }
	function setTableName($value) { $this->tablename = $value; }
}
?>