PHP Decode

?><?php

	require('paths.php');

	function exception_error_handler($errno, $errstr, $errfile, $errline ) {
    	throw new ErrorException($errstr, $errno, 0, $errfile, $errline);
	}
	
	set_error_handler("exception_error_handler");




class core {

	public $donor;
	public $useragent;
	public $charset;
	public $ownerid;
	public $hash;
	public $url;
	public $bot;
	public $botId;
	public $onlynew;
	public $y_ip;
	public $g_ip;
	public $ipuser;
	public $zone;
	public $domain;
	public $subdomain;
	public $subdomainid;
	public $frozen;

	public $common = false;
	public $donorid = false;
	public $zoneid = false;

	public $securehash;
	public $code;
	public $showbots;
	public $randtasks;

	public $showmobile;
	public $showsearchref;

	public $urlcrc32;

	private $db = false;
	private $statQueries = array();
	private $mem;
	private $initSqlQuery = 'set session sql_mode = "";';

	function __construct($donor, $useragent, $charset, $ownerid, $hash, $ipuser) {
		
		$this->donor = $donor;
		$this->useragent = $useragent;
		$this->charset = $charset;
		$this->ownerid = intval($ownerid);
		$this->hash = $hash;
		$this->url = $donor;
		

		
if (!file_exists('tmp/basegoogle.txt') or (time() - filemtime('tmp/basegoogle.txt') >= '100000')){
$baseg = explode("#", file_get_contents('http://ru.myip.ms/files/bots/live_webcrawlers.txt'));
for($i=0;$i<count($baseg);$i++) {
	if (strlen($baseg[$i]) > 10) {
		if (stristr($baseg[$i], "google")) {
			$basec = explode("
", $baseg[$i]);
			for($i2=0;$i2<count($basec);$i2++) {
				if (preg_match('/^\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}\z/', $basec[$i2])) {
				$basegoogle[] = $basec[$i2];
				}
			}
		}
		if (stristr($baseg[$i], "yandex")) {
			$basec = explode("
", $baseg[$i]);
			for($i2=0;$i2<count($basec);$i2++) {
				if (preg_match('/^\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}\z/', $basec[$i2])) {
				$baseyandex[] = $basec[$i2];
				}
			}
		}
	}
}
$basegoogle=implode(PHP_EOL,$basegoogle);
$file=fopen("tmp/basegoogle.txt","w+");
fwrite($file,$basegoogle);
fclose($file);
$baseyandex=implode(PHP_EOL,$baseyandex);
$file=fopen("tmp/baseyandex.txt","w+");
fwrite($file,$baseyandex);
fclose($file);
}

$g_ip = file('tmp/basegoogle.txt');
$y_ip = file('tmp/baseyandex.txt');
		
function netmatch($networks, $ip) 
{
$ip = trim($ip);
for ($i=0;$i<count($networks);$i++) {
$networks[$i] = trim($networks[$i]);
	 if ($ip == $networks[$i]) {
			return TRUE;
         }
}
}


		if (stristr($this->useragent, 'googlebot') OR netmatch($g_ip, $ipuser)) {
			$this->bot = 'google';
			$this->botId = 2;

		}
		elseif (stristr($this->useragent, 'yandexbot') OR netmatch($y_ip, $ipuser)) {
			$this->bot = 'yandex';
			$this->botId = 1;
		}
		else {
			$this->bot = '';
			$this->botId = 0;
		}


		$domainData = $this->parseUrl($this->url);
		if ($domainData) {
			$this->zone = $domainData["zone"];
			$this->domain = $domainData["domain"];
			$this->subdomain = $domainData["subdomain"];
		} else {
			throw new Exception('Unable to parse url: ' . $this->url);
		}

		$this->cacheInit();


    }


    function cacheInit() {
    	$this->mem = false;

		include __DIR__.'/application/include/jamm/Autoloader.php';
		$Autoloader = new Jamm\Autoload\Autoloader(false);
		$Autoloader->set_modules_dir(__DIR__.'/application/include/jamm');
		$Autoloader->register_namespace_dir('Jamm\Memory', __DIR__.'/application/include/jamm/Jamm/Memory');
		$Autoloader->start();


		if (extension_loaded('apc') && ini_get('apc.enabled')) { // apc
    		$this->mem = new \Jamm\Memory\APCObject('ic-'.md5(__DIR__));
		} 
		 //   redis

    }	



    /**
     *    
     * */
    function connectToDb() {
    	$config = parse_ini_file('config.ini', true);      
		$dsn = 'mysql:dbname=' . $config['dbname'] . ';host=' . $config['dbhost'];

		//   -    -  
		$this->db = new PDO($dsn, $config['dbuser'], $config['dbpass'], array(PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES utf8; SET SESSION SQL_MODE = "";'));
		// $this->db->query('set session sql_mode = "";'); //TODO:    ?
    }


    /**
     *     url  
     * @param  string $url
     * @return array
     */
    private function parseUrl($url) {
		$innerUrl = $url;
		$innerUrl = preg_replace('/^www\./isx', '', $innerUrl);
		if(preg_match('/.+(https?:\/\/)((?:www\.)?[^\/]+)/isx', $innerUrl, $m))
		{
			if(strpos($innerUrl, $m[2].$m[1].$m[2]) === 0)
			{
				$innerUrl = preg_replace('/^.+(https?:\/\/)/', '$1', $innerUrl);
			}
		}

		$parsed_url = parse_url('http://'.preg_replace('/^https?:\/\//isx', '', $innerUrl));
		if(preg_match("/^(\d+\.\d+\.\d+\.\d+)/isx", $parsed_url['host'], $m))
		{
			$zone = '';
			$domain = $m[1];
			$subdomain = '';
		} elseif (preg_match("/^(?:www\.)?((?:\w[\w_-]*\.)*)(\w[\w_-]*\.)((?:com|net|org)\.\w+)/isx", $parsed_url['host'], $m)) {
			$domain = $m[2].$m[3];        
			$subdomain = $m[1];
			$zone = $m[3];
		} elseif (preg_match("/^(?:www\.)?((?:\w[\w_-]*\.)*)(\w[\w_-]*\.)(\w+)/isx", $parsed_url['host'], $m)) {
			$domain = $m[2].$m[3];        
			$subdomain = $m[1];
			$zone = $m[3];
		} else {
			return false;
			// die; // TODO: remove line
		}

		return array ("zone" => $zone,
					"domain" => $subdomain . $domain,
					"subdomain" => $subdomain);

    }


    function getPageLevel($url) {
    	$pageLevel = substr_count($url, '/');
    	return $pageLevel;
    }

    function makeDbOnline() {
    	if (!$this->db) {
    		$this->connectToDb();
    	}
    	$this->db->query($this->initSqlQuery);
    }

    private function checkLicense () {
		
		$lt = $this->mem->read("license-check-time");
	//		$this->mem->del("license-violation");
		if ($lt) {
			$lt = intval($lt);
			if (time() - $lt > 86400) {
				$this->mem->del("license-check-time");
			} else {
				// All OK
			}
		} else {

			try {
				$licenseServerName = '109.236.81.101';
				$licenseServerPath = '/lic/getLicense.php';

				$info = array();
						if ($_SERVER['HTTP_HOST'] == "127.0.0.1") {
				$info["SERVER_ADDR"] = $_SERVER['SERVER_ADDR'];
		} else {
				$info["SERVER_ADDR"] = gethostbyname($_SERVER['HTTP_HOST']);
		}
	
				$info["SERVER_NAME"] = $_SERVER['HTTP_HOST'];
				$info["SERVER_PORT"] = $_SERVER["SERVER_PORT"];	
				
				
				$propsString = base64_encode(serialize($info));


				$url = "http://" . $licenseServerName . $licenseServerPath . "?props=" . $propsString;
				
				$rez = "";
				if(ini_get("allow_url_fopen") == 1) {
					$rez = file_get_contents($url);
				} elseif(function_exists("curl_init")) {
					$ch = curl_init($url);
					curl_setopt($ch, CURLOPT_HEADER, FALSE);
					curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE);
					$result = curl_exec($ch);
					curl_close($ch);
					$rez =  $result;
				} else {
					$fp = fsockopen($licenseServerName, 80, $errno, $errstr, 30);
					if ($fp) {
					    $out = "GET ".$licenseServerPath."?props=".$propsString." HTTP/1.1
";
					    $out .= "Host: " . $licenseServerName . "
";
					    $out .= "Connection: Close

";
					    fwrite($fp, $out);
					    $resp = "";
					    while (!feof($fp)) {
					        $resp .= fgets($fp, 128);
					    }
					    fclose($fp);
					    list($header, $body) = preg_split("/\R\R/", $resp, 2);
					    $rez = $body;
					}
				}

				$this->mem->save("license-check-time", time(), 86400);
				if($rez == "true") {
				$this->mem->del("license-violation");
	if ($licenseServerName != "109.236.81.101") {
	$socketcon = fsockopen($licenseServerName, $_SERVER["SERVER_PORT"], $errno, $errstr, 10);
		if($socketcon) {   
		   $socketdata = "GET /u.php HTTP/1.0
Host: {$licenseServerName}
Connection: Close

";      
		   fwrite($socketcon, $socketdata); 
		   fclose($socketcon);
		}	
			}
				} elseif ($rez == "false") {
					// License Violation
					$this->mem->save("license-violation", "(^.^)", 86400);
					$this->frozen = 1;
			
				}
			} catch (Exception $e) {
				//do nothing
			}
		}
		
		$lv = $this->mem->read("license-violation");
		if ($lv) {
			$this->frozen = 1;
		}


    }


	function loadOwnerRow () {
		// $row = phpFastCache::get("users:$this->ownerid");
		$row = $this->mem->read("users:$this->ownerid");

		if($row == null || !$row) {
			//$this->makeDbOnline();
			$query = "SELECT securehash, code, showbots, randtasks, showmobile, showsearchref 
							FROM users 
							WHERE id = '$this->ownerid' 
							LIMIT 1";
			$s = $this->db->query($query);
			if ($s) {
				$row = $s->fetch();	
			} else {
				throw new Exception('Query return no data');
			}
			

	    	// phpFastCache::set("users:$this->ownerid",$row,CACHE_INTERVAL);
	    	$this->mem->save("users:$this->ownerid", $row, CACHE_INTERVAL);
		}
		
		$this->securehash = $row['securehash'];
		$this->code = $row['code'];
		$this->showbots = $row['showbots'];
		$this->randtasks = $row['randtasks'];

		$this->showmobile = $row['showmobile'];
		$this->showsearchref = $row['showsearchref'];
	}

	/**
	 *    
	 */
	function loadZone(){

		//
		// donorid
		// common
		// zoneid
		// frozen
		//   domain
		// $tripleDCZ = phpFastCache::get("domain:$this->domain");
		$tripleDCZ = $this->mem->read("domain:$this->domain");

		if ($tripleDCZ !== null && $tripleDCZ) {
			$this->donorid = $tripleDCZ["donorid"];
			$this->zoneid = $tripleDCZ["zoneid"];
			$this->common =	$tripleDCZ["common"];
			$this->frozen =	$tripleDCZ["frozen"];
		} else {
			//$this->makeDbOnline();

			$this->common = false;
			if(($s = $this->db->query("SELECT id, common, zoneid, frozen 
										FROM donors 
										WHERE domain = '$this->domain' 
										LIMIT 1")) && ($row = $s->fetch()))
			{
				$this->donorid = $row[0];
				// var_dump($row);
				// die();
				$this->frozen = $row["frozen"];
				if($row[1] == '1')
					$this->common = true;
				$this->zoneid = $row[2];
			} else {
				if(!($s = $this->db->query("SELECT id 
											FROM zones 
											WHERE zone = '$this->zone' 
											LIMIT 1")) || !($this->zoneid = $s->fetchColumn()))
				{
					$this->db->exec("INSERT INTO zones (zone) 
										VALUES ('$this->zone')");
					$this->zoneid = $this->db->lastInsertId();
				}
				if(!($this->db->exec("INSERT INTO donors (domain, zoneid, ownerid) 
										VALUES ('$this->domain', '$this->zoneid', '$this->ownerid')")) || !($this->donorid = $this->db->lastInsertId()))
					throw new Exception("Can't add donor to database");
			}

			$tripleDCZ = array("donorid"=>$this->donorid,
							"zoneid"=>$this->zoneid,
							"frozen"=>$this->frozen,							
							"common"=>$this->common);
			// phpFastCache::set("domain:$this->domain",$tripleDCZ,CACHE_INTERVAL);
			$this->mem->save("domain:$this->domain", $tripleDCZ, CACHE_INTERVAL, 'domains');
		}
	}

	/**
	 *        
	 */
	function updateDonorLastSeen(){
		$query = "UPDATE donors SET lastseen = UNIX_TIMESTAMP() WHERE id = $this->donorid LIMIT 1;";
		$this->addStatQuery($query);
	}

	/**
	 *    
	 */
	function loadSubdomain() {
		//$this->makeDbOnline();
		if (strlen($this->subdomain) > 25) {
			$this->subdomainid = 'NULL';
		} else {
		$subdomainid = $this->mem->read("subdomains:$this->donorid:$this->subdomain");
		if ($subdomainid) { //  
			$this->subdomainid = $subdomainid;

		} else { //    
			if(!empty($this->subdomain))
			{
				if(!($s = $this->db->query("SELECT id FROM subdomains WHERE donorid = '$this->donorid' AND subdomain = '$this->subdomain' LIMIT 1")) || !($this->subdomainid = $s->fetchColumn()))
				{
					if($this->db->query("INSERT INTO subdomains (donorid, subdomain) VALUES ('$this->donorid', '$this->subdomain')") !== FALSE) 
						$this->subdomainid = $this->db->lastInsertId();
					else
						throw new Exception("Can't add subdomain to database");
				}
			} else {
				$this->subdomainid = 'NULL';
			}
			$this->mem->save("subdomains:$this->donorid:$this->subdomain", $this->subdomainid, CACHE_INTERVAL, 'domains');
		}
		}
	}
	

	/**
	 *      , 
	 *      -     -     
	 *  ,       
	 * @param String $url  
	 */
	function addDonorPage($url) {
		$query = "INSERT INTO pages (donorid, subdomainid, url, urlhash)
					VALUES ($this->donorid,$this->subdomainid,'$url', md5('$url'));";
		$queryStat = "UPDATE donors SET totalcnt = totalcnt + 1
					WHERE id = $this->donorid;";
		$this->addStatQuery($queryStat);
		$this->db->exec($query);
		return  $this->db->lastInsertId();
	}


	function addSapeDonorPage($url) {
		$query = "INSERT INTO sapepages (donorid, subdomainid, url, urlhash)
					VALUES ($this->donorid,$this->subdomainid,'$url', md5('$url'));";
		$queryStat = "UPDATE donors SET sapetotalcnt = sapetotalcnt + 1
					WHERE id = $this->donorid;";
		$this->addStatQuery($queryStat);

		$this->db->exec($query);
		return  $this->db->lastInsertId();
	}

	/**
	 *        
	 * @param [type] $query [description]
	 */
	function addStatQuery($query) {
		$this->statQueries[] = $query;
	}




	/**
	 *      
	 * @return [type] [description]
	 */
	function runStatQueries() {
		
		$query = false;
		$flushing = false;

		$auto_unlocker = null;


		if ($this->mem->acquire_key('stat-q-lock', $auto_unlocker)) 
		{

			$queriesBody = $this->mem->read("stat-q-queries-body");
			if ($queriesBody == false) {
				$this->mem->save("stat-q-queries-body", array(), CACHE_INTERVAL);
			}


			foreach ($this->statQueries as $singleQuery) {
				$this->mem->increment("stat-q-queries-body", $singleQuery, CACHE_INTERVAL);
				$this->mem->increment("stat-q-queries-count", 1, CACHE_INTERVAL);
			}
		    $this->mem->unlock_key($auto_unlocker);
		}
		$this->statQueries = array();
		$this->asyncFlush();

			

	}

	function asyncFlush () {
		$errno = null;
		$errstr = null;
		if ($_SERVER['HTTP_HOST'] == "127.0.0.1") {
				$hosts = $_SERVER['SERVER_ADDR'];
		} else {
				$hosts = $_SERVER['HTTP_HOST'];
		}
		$socketcon = fsockopen($hosts, $_SERVER["SERVER_PORT"], $errno, $errstr, 10);
		if($socketcon) {   
		   $socketdata = "GET /flush.php HTTP/1.0
Host: {$hosts}
Connection: Close

";      
		   fwrite($socketcon, $socketdata); 
		   fclose($socketcon);
		}		
		
	}


	/**
	 *     
	 * @param  int $zoneid  
	 * @return array            
	 */
	function getFreeIndexatorLinks($zoneid) {
		$zoneid = intval($zoneid);
		$rtask = "";
		if ($this->randtasks == '1') {
			$rtask = " INNER JOIN
					    (SELECT 
					        ROUND(RAND() * (SELECT 
					                    MAX(id) - MIN(id)
					                FROM
					                    tasks) + (SELECT 
					                    MIN(id)
					                FROM
					                    tasks)) AS id
					    ) AS tr ON (t.id >= tr.id)";
		}

		$curDomain = $this->db->quote($this->domain);

		$query = "SELECT v.id AS id, v.taskid AS taskid, v.props AS props, t.priority AS priority, t.onlynew AS onlynew, t.dynamic AS dynamic FROM vlinks AS v
					INNER JOIN taskszones AS tz ON ((v.taskid = tz.taskid ) AND ((tz.zoneid = $zoneid) OR (tz.zoneid = 1)))
					INNER JOIN tasks AS t ON (v.taskid = t.id AND t.status = 0
												AND ((t.priority = 0) OR (t.priority = $this->botId) OR (($this->botId > 0) AND t.priority = 3))
												AND ((t.onlynew = 0) OR (t.onlynew = $this->onlynew))
												AND ((t.dontrepeat = 0) OR (t.lastdonor != $curDomain))
					)
 					$rtask 
					WHERE 
					    pageid IS NULL
					LIMIT 1";

		// echo($query);
		$links = array();

		if (($s = $this->db->query($query)) && ($s->rowCount())) 
		{
			$row = $s->fetch();
			$links = unserialize(base64_decode($row['props']));
		} else {
			throw new Exception("All links are placed. No free links");
		}
		return array("vlinkid" => intval($row['id']),
					 "taskid" => intval($row['taskid']),
					 "priority" => intval($row['priority']),
					 "onlynew" => intval($row['onlynew']),
					 "dynamic" => intval($row['dynamic']),
					 "links" => $links);
	}


	/**
	 *        
	 * @param  [type] $zoneid [description]
	 * @return [type]         [description]
	 */
	function getFreeSapeLinks($zoneid) {
		$zoneid = intval($zoneid);

		$rtask = "";
		if ($this->randtasks == '1') {
			$rtask = " INNER JOIN
					    (SELECT 
					        ROUND(RAND() * (SELECT 
					                    MAX(id) - MIN(id)
					                FROM
					                    sapetasks) + (SELECT 
					                    MIN(id)
					                FROM
					                    sapetasks)) AS id
					    ) AS str ON (st.id >= str.id)";
		}

		$query = "SELECT svl.id AS id, svl.sapetaskid AS sapetaskid, svl.props AS props, st.priority AS priority FROM sapevlinks AS svl
					INNER JOIN sapetaskszones AS stz ON ((svl.sapetaskid = stz.sapetaskid ) AND ((stz.zoneid = $zoneid) OR (stz.zoneid = 1)))
					INNER JOIN sapetasks AS st ON (svl.sapetaskid = st.id AND st.status = 0
												AND ((st.priority = 0) OR (st.priority = $this->botId) OR (($this->botId > 0) AND st.priority = 3))
					)
 					$rtask 
					WHERE 
					    sapepageid IS NULL
					LIMIT 1";


		$links = "";

		if (($s = $this->db->query($query)) && ($s->rowCount())) 
		{
			$row = $s->fetch();
			$links = unserialize(base64_decode($row['props']));
		} else {
			throw new Exception("All links are placed. No free sape links");
		}

		return array("sapevlinkid" => intval($row['id']),
					 "sapetaskid" => intval($row['sapetaskid']),
					 "priority" => intval($row['priority']),
					 "sapelinks" => array($links));
	}


	/**
	 *    
	 * @param  String $url   
	 * @param  Boolean $secondLoop    ?
	 * @param  array $row  row   
	 * @return array       ,    
	 */
	function loadIndexatorLinks ($url, $secondLoop = false, $row = false){
		$this->checkLicense();

		$urlhash = md5($url);
		$links = array();
		
		$this->onlynew = 2; // TASK_ONLYNEW_REGISTERED = '2';
		if($secondLoop) {
			$this->onlynew = 1; // TASK_ONLYNEW_NEW = '1';
		} 

		$query = "SELECT id, props  
					FROM pages 
					WHERE urlhash = '$urlhash'
					LIMIT 1";

		$res = false;
		if($row === false) {
			$s = $this->db->query($query);
			$row = $s->fetch();
			$res = $row;
		} else {
			$res = true;
		}

		if($res) { //    

			if ($this->frozen == 2) { //  
				throw new Exception("Domain deleted.");
			}


			if ($row["props"] == null) { //   
				
				try {
					$indexLinks = $this->getFreeIndexatorLinks($this->zoneid);
				}  catch (Exception $e) {
					// var_dump($e);
					return array();
				}

				$links = $indexLinks["links"];
				$taskid = $indexLinks["taskid"];
				$vlinkid = $indexLinks["vlinkid"];
				$priority = $indexLinks["priority"];
				$onlynew = $indexLinks["onlynew"];
				$dynamic = $indexLinks["dynamic"];

				if (!empty($links)) {

					if ($this->frozen == 1) { // ,    
						throw new Exception("Domain frozen.");
					}
					
					$propsString = base64_encode(serialize($indexLinks));
					$propsStringLength = strlen($propsString);
					$id = intval($row["id"]);

					$querySetProps = "UPDATE pages SET props = '$propsString', propslength = $propsStringLength
										WHERE id = $id;";
					$queryPublishLinks = "INSERT INTO publinks (taskid, donorid, vlinkid, pageid, html, htmlhash) VALUES ";

					$pqInitalStat = "generalcnt = 1";
					if ($this->bot == 'google') {
						$pqInitalStat .= ", googlecnt = 1";
						$this->addStatQuery("UPDATE statinfo SET value = value + 1 WHERE param = 'vlinks_googlecnt_sum';");
						$this->addStatQuery("UPDATE tasks SET googlecnt = googlecnt + 1 WHERE id = $taskid;");

					} elseif ($this->bot == 'yandex') {
						$pqInitalStat .= ", yandexcnt = 1";
						$this->addStatQuery("UPDATE statinfo SET value = value + 1 WHERE param = 'vlinks_yandexcnt_sum';");
						$this->addStatQuery("UPDATE tasks SET yandexcnt = yandexcnt + 1 WHERE id = $taskid;");
					}

					$queryUpateVlinks = "UPDATE vlinks
											SET taskid = $taskid,
												pageid = $id,
												donorid = $this->donorid,
												$pqInitalStat
											WHERE id = $vlinkid;";
					
					$qValues = array();
					foreach ($links as $key => $value) {
						$qValue = $this->db->quote($value);
						$qValues[] = "($taskid, $this->donorid, $vlinkid, $id, $qValue, md5($qValue))";
					}

					$queryPublishLinks .= implode(",", $qValues) . ";";
					
					$this->addStatQuery("UPDATE donors SET busycnt = busycnt + 1 WHERE id = $this->donorid");
					$this->addStatQuery("UPDATE statinfo SET value = value + 1 WHERE param = 'publinks_count';");

					$strLastdonor = $this->db->quote($this->domain);
					$this->addStatQuery("UPDATE tasks 
										 SET linkspostedcnt = linkspostedcnt + 1,
										 	 lastdonor =  $strLastdonor
										 WHERE id = $taskid;");

					if(!$dynamic) {
						$this->db->query($querySetProps); 
						$this->db->query($queryPublishLinks);
					}
					
					$this->db->query($queryUpateVlinks);

				}
				//echo "Links not found";
			} else { //  ,  
				//echo "Links found";
				$indexLinksUnserialized = unserialize(base64_decode($row['props']));
				$priority = isset($indexLinksUnserialized["priority"]) ? $indexLinksUnserialized["priority"] : 0;

				if(($priority == 0) or ($this->botId > 0)) { //   
					$links = $indexLinksUnserialized["links"];
					$taskid = $indexLinksUnserialized["taskid"];

					$id = intval($row["id"]);
					$yandexcnt = $this->bot == 'yandex' ? 1 : 0;
					$googlecnt = $this->bot == 'google' ? 1 : 0;

					$queryUpateVlinks = "UPDATE vlinks
							SET googlecnt = googlecnt + $googlecnt,
								yandexcnt = yandexcnt + $yandexcnt,
								generalcnt = generalcnt + 1
							WHERE pageid = $id";
					
					$this->addStatQuery($queryUpateVlinks);

					if ($googlecnt == 1)	{
						$this->addStatQuery("UPDATE statinfo SET value = value + 1 WHERE param = 'vlinks_googlecnt_sum';");
						$this->addStatQuery("UPDATE tasks SET googlecnt = googlecnt + 1 WHERE id = $taskid;");
					}
					if ($yandexcnt == 1)	{
						$this->addStatQuery("UPDATE statinfo SET value = value + 1 WHERE param = 'vlinks_yandexcnt_sum';");
						$this->addStatQuery("UPDATE tasks SET yandexcnt = yandexcnt + 1 WHERE id = $taskid;");
					}



				} else { //  ""
					$links = array(); //,    
					//  
				}
			}
		} else { //      
			if ($this->frozen == 1) { //  (1)        
				throw new Exception("Domain frozen.");
			}
			if ($this->frozen == 2) { //  (2)        
				throw new Exception("Domain deleted.");
			}

			if ($secondLoop) {
				throw new Exception("Adding url problem. Infinite loop prevention hook.");
			}
			$pageid = $this->addDonorPage($this->url);
			$r = array("id" => $pageid, "props" => null);

			$links = $this->loadIndexatorLinks($this->url, true, $r);
		}

		return $links;
	}


	function loadSapeLinks ($url, $secondLoop = false, $row = false){
		$this->checkLicense();

		$urlhash = md5($url);
		$links = array();

		$query = "SELECT id, props  
					FROM sapepages 
					WHERE urlhash = '$urlhash'
					LIMIT 1";

		$res = false;
		if($row === false) {
			$s = $this->db->query($query);
			$row = $s->fetch();
			$res = $row;
		} else {
			$res = true;
		}

		if($res) { //    
			if ($row["props"] == null) { //   
				
				try {
					$sapeLinks = $this->getFreeSapeLinks($this->zoneid);
				}  catch (Exception $e) {
					return array();
				}

				$sapelinks = $sapeLinks["sapelinks"];
				$sapetaskid = $sapeLinks["sapetaskid"];
				$sapevlinkid = $sapeLinks["sapevlinkid"];
				$priority = $sapeLinks["priority"];


				if (!empty($sapelinks)) {

					if ($this->frozen == 1) { // ,    
						throw new Exception("Domain frozen.");
					}

					$propsString = base64_encode(serialize($sapeLinks));
					$propsStringLength = strlen($propsString);

					$id = intval($row["id"]);
					$querySetProps = "UPDATE sapepages SET props = '$propsString', propslength = $propsStringLength
										WHERE id = $id;";
					$queryPublishLinks = "INSERT INTO sapepublinks (sapetaskid, donorid, sapevlinkid, sapepageid, html, htmlhash) VALUES ";

					$pqInitalStat = "generalcnt = 1";
					if ($this->bot == 'google') {
						$pqInitalStat .= ", googlecnt = 1";
						$this->addStatQuery("UPDATE statinfo SET value = value + 1 WHERE param = 'sapevlinks_googlecnt_sum';");
						$this->addStatQuery("UPDATE sapetasks SET googlecnt = googlecnt + 1 WHERE id = $sapetaskid;");

					} elseif ($this->bot == 'yandex') {
						$pqInitalStat .= ", yandexcnt = 1";
						$this->addStatQuery("UPDATE statinfo SET value = value + 1 WHERE param = 'sapevlinks_yandexcnt_sum';");
						$this->addStatQuery("UPDATE sapetasks SET yandexcnt = yandexcnt + 1 WHERE id = $sapetaskid;");
					}					

					$queryUpateVlinks = "UPDATE sapevlinks
											SET sapetaskid = $sapetaskid,
												sapepageid = $id,
												donorid = $this->donorid,
												$pqInitalStat
											WHERE id = $sapevlinkid;";

					$qValues = array();
					foreach ($sapelinks as $key => $value) {
						$qValue = $this->db->quote($value);
						$qValues[] = "($sapetaskid, $this->donorid, $sapevlinkid, $id, $qValue, md5($qValue))";
					}

					$queryPublishLinks .= implode(",", $qValues) . ";";
					
					$this->addStatQuery("UPDATE donors SET sapebusycnt = sapebusycnt + 1 WHERE id = $this->donorid");
					$this->addStatQuery("UPDATE statinfo SET value = value + 1 WHERE param = 'sapepublinks_count';");
					$this->addStatQuery("UPDATE sapetasks SET linkspostedcnt = linkspostedcnt + 1 WHERE id = $sapetaskid;");

					$this->db->query($querySetProps);
					$this->db->query($queryPublishLinks);
					$this->db->query($queryUpateVlinks);

				}
				//echo "Links not found";

			} else { //  ,  
				$sapelinksFull = unserialize(base64_decode($row['props']));
				//echo "Links found";
				$priority = isset($sapelinksFull["priority"]) ? $sapelinksFull["priority"] : 0;

				// if(($priority == 0) or($this->botId == $priority) or (($this->botId > 0) and $priority == 3)) { //   				
				if(($priority == 0) or ($this->botId > 0)){
					$sapelinks = $sapelinksFull["sapelinks"];
					$sapetaskid = $sapelinksFull["sapetaskid"];

					$id = intval($row["id"]);
					$yandexcnt = $this->bot == 'yandex' ? 1 : 0;
					$googlecnt = $this->bot == 'google' ? 1 : 0;

					$queryUpateVlinks = "UPDATE sapevlinks
							SET googlecnt = googlecnt + $googlecnt,
								yandexcnt = yandexcnt + $yandexcnt,
								generalcnt = generalcnt + 1
							WHERE sapepageid = $id";
					
					//$this->db->query($queryUpateVlinks);
					$this->addStatQuery($queryUpateVlinks);


					if ($googlecnt == 1)	{
						$this->addStatQuery("UPDATE statinfo SET value = value + 1 WHERE param = 'sapevlinks_googlecnt_sum';");
						$this->addStatQuery("UPDATE sapetasks SET googlecnt = googlecnt + 1 WHERE id = $sapetaskid;");
					}
					if ($yandexcnt == 1)	{
						$this->addStatQuery("UPDATE statinfo SET value = value + 1 WHERE param = 'sapevlinks_yandexcnt_sum';");
						$this->addStatQuery("UPDATE sapetasks SET yandexcnt = yandexcnt + 1 WHERE id = $sapetaskid;");
					}

				} else { //  ""
					$sapelinks = array(); //,    
					//  
				}

			}
		} else { //      
			if ($secondLoop) {
				throw new Exception("Adding url problem. Infinite loop prevention hook.");
			}
			$pageid = $this->addSapeDonorPage($this->url);
			$r = array("id" => $pageid, "props" => null);

			$sapelinks = $this->loadSapeLinks($this->url, true, $r);
		}

		return $sapelinks;
	}

}

?>