seafood/app/libs/aliyun/top/ClusterTopCl...

<?php
class ClusterTopClient extends TopClient {

	private static $dnsconfig;
	private static $syncDate = 0;
	private static $applicationVar ;
	private static $cfgDuration = 10;

	public function __construct($appkey = "",$secretKey = ""){
		ClusterTopClient::$applicationVar = new ApplicationVar;
		$this->appkey = $appkey;
		$this->secretKey = $secretKey ;
		$saveConfig = ClusterTopClient::$applicationVar->getValue();

		if($saveConfig){
			$tmpConfig = $saveConfig['dnsconfig'];
			ClusterTopClient::$dnsconfig = $this->object_to_array($tmpConfig);
			unset($tmpConfig);

			ClusterTopClient::$syncDate = $saveConfig['syncDate'];
			if(!ClusterTopClient::$syncDate)
				ClusterTopClient::$syncDate = 0;
		}
	}

	public function __destruct(){
		if(ClusterTopClient::$dnsconfig && ClusterTopClient::$syncDate){
			ClusterTopClient::$applicationVar->setValue("dnsconfig",ClusterTopClient::$dnsconfig);
			ClusterTopClient::$applicationVar->setValue("syncDate",ClusterTopClient::$syncDate);
			ClusterTopClient::$applicationVar->write();
		}
	}

	public function execute($request = null, $session = null,$bestUrl = null){
		$currentDate = date('U');
		$syncDuration = $this->getDnsConfigSyncDuration();
		$bestUrl = $this->getBestVipUrl($this->gatewayUrl,$request->getApiMethodName(),$session);
		if($currentDate - ClusterTopClient::$syncDate > $syncDuration * 60){
			$httpdns = new HttpdnsGetRequest;
			ClusterTopClient::$dnsconfig = json_decode(parent::execute($httpdns,null,$bestUrl)->result,true);
			$syncDate = date('U');
			ClusterTopClient::$syncDate = $syncDate ;
		}
		return parent::execute($request,$session,$bestUrl);
	}

	private function getDnsConfigSyncDuration(){
		if(ClusterTopClient::$cfgDuration){
			return ClusterTopClient::$cfgDuration;
		}
		if(!ClusterTopClient::$dnsconfig){
			return ClusterTopClient::$cfgDuration;
		}
		$config = json_encode(ClusterTopClient::$dnsconfig);
		if(!$config){
			return ClusterTopClient::$cfgDuration;
		}
		$config = ClusterTopClient::$dnsconfig['config'];
		$duration = $config['interval'];
		ClusterTopClient::$cfgDuration = $duration;

		return ClusterTopClient::$cfgDuration;
	}

	private function getBestVipUrl($url,$apiname = null,$session = null){
		$config = ClusterTopClient::$dnsconfig['config'];
		$degrade = $config['degrade'];
		if(strcmp($degrade,'true') == 0){
			return $url;
		}		
		$currentEnv = $this->getEnvByApiName($apiname,$session);
		$vip = $this->getVipByEnv($url,$currentEnv);
		if($vip)
			return $vip;
		return $url;
	}

	private function getVipByEnv($comUrl,$currentEnv){
		$urlSchema = parse_url($comUrl);
		if(!$urlSchema)
			return null;
		if(!ClusterTopClient::$dnsconfig['env'])
			return null;
		
		if(!array_key_exists($currentEnv,ClusterTopClient::$dnsconfig['env']))
			return null;

		$hostList = ClusterTopClient::$dnsconfig['env'][$currentEnv];
		if(!$hostList)
			return null ;

		$vipList = null;
		foreach ($hostList as $key => $value) {
			if(strcmp($key,$urlSchema['host']) == 0 && strcmp($value['proto'],$urlSchema['scheme']) == 0){
				$vipList = $value;
				break;
			}
		}
		$vip = $this->getRandomWeightElement($vipList['vip']);
		
		if($vip){
			return $urlSchema['scheme']."://".$vip.$urlSchema['path'];
		}
		return null;
	}

	private function getEnvByApiName($apiName,$session=""){
		$apiCfgArray = ClusterTopClient::$dnsconfig['api'];
		if($apiCfgArray){	
			if(array_key_exists($apiName,$apiCfgArray)){
				$apiCfg = $apiCfgArray[$apiName];
				if(array_key_exists('user',$apiCfg)){
					$userFlag = $apiCfg['user'];
					$flag = $this->getUserFlag($session);
					if($userFlag && $flag ){
						return $this->getEnvBySessionFlag($userFlag,$flag);
					}else{
						return $this->getRandomWeightElement($apiCfg['rule']);
					}
				}
			}
		}
		return $this->getDeafultEnv();
	}

	private function getUserFlag($session){
		if($session && strlen($session) > 5){
			if($session[0] == '6' || $session[0] == '7'){
				return $session[strlen($session) -1];
			}else if($session[0] == '5' || $session[0] == '8'){
				return $session[5];
			}
		}
		return null;
	}

	private function getEnvBySessionFlag($targetConfig,$flag){
		if($flag){
			$userConf = ClusterTopClient::$dnsconfig['user'];
			$cfgArry = $userConf[$targetConfig];
			foreach ($cfgArry as $key => $value) {
				if(in_array($flag,$value))
					return $key;
			}
		}else{
			return null;
		}
	}

	private function getRandomWeightElement($elements){
		$totalWeight = 0;
		if($elements){
			foreach ($elements as $ele) {
				$weight = $this->getElementWeight($ele);
				$r = $this->randomFloat() * ($weight + $totalWeight);
				if($r >= $totalWeight){
					$selected = $ele;
				}
				$totalWeight += $weight;
			}
			if($selected){
				return $this->getElementValue($selected);
			}
		}
		return null;

	}

	private function getElementWeight($ele){
		$params = explode('|', $ele);
		return floatval($params[1]);
	}
	private function getElementValue($ele){
		$params = explode('|', $ele);
		return $params[0];		
	}

	private function getDeafultEnv(){
		return ClusterTopClient::$dnsconfig['config']['def_env'];
	}

	private static function startsWith($haystack, $needle) {
    	return $needle === "" || strpos($haystack, $needle) === 0;
	}

	private function object_to_array($obj) 
	{ 
    	$_arr= is_object($obj) ? get_object_vars($obj) : $obj; 
    	foreach($_arr as $key=> $val) 
    	{ 
        	$val= (is_array($val) || is_object($val))? $this->object_to_array($val) : $val; 
        	$arr[$key] = $val; 
    	} 
    	return$arr; 
	}

	private function randomFloat($min = 0, $max = 1) { return $min + mt_rand() / mt_getrandmax() * ($max - $min); }
}
?>