GC0202 / ThinkLibrary

src/service/taobao/bin/top/request/TopSecretRegisterRequest.php

Indentation +29 added lines, -29 removed lines

@@ -7,41 +7,41 @@
  */
 class TopSecretRegisterRequest
 {
-	/** 
-	 * 用户id，保证唯一
-	 **/
-	private $userId;
+    /** 
+     * 用户id，保证唯一
+     **/
+    private $userId;
 	
-	private $apiParas = array();
+    private $apiParas = array();
 	
-	public function setUserId($userId)
-	{
-		$this->userId = $userId;
-		$this->apiParas["user_id"] = $userId;
-	}
+    public function setUserId($userId)
+    {
+        $this->userId = $userId;
+        $this->apiParas["user_id"] = $userId;
+    }
 
-	public function getUserId()
-	{
-		return $this->userId;
-	}
+    public function getUserId()
+    {
+        return $this->userId;
+    }
 
-	public function getApiMethodName()
-	{
-		return "taobao.top.secret.register";
-	}
+    public function getApiMethodName()
+    {
+        return "taobao.top.secret.register";
+    }
 	
-	public function getApiParas()
-	{
-		return $this->apiParas;
-	}
+    public function getApiParas()
+    {
+        return $this->apiParas;
+    }
 	
-	public function check()
-	{
+    public function check()
+    {
 		
-	}
+    }
 	
-	public function putOtherTextParam($key, $value) {
-		$this->apiParas[$key] = $value;
-		$this->$key = $value;
-	}
+    public function putOtherTextParam($key, $value) {
+        $this->apiParas[$key] = $value;
+        $this->$key = $value;
+    }
 }

src/service/taobao/bin/top/request/TopAuthTokenRefreshRequest.php

Indentation +30 added lines, -30 removed lines

@@ -7,42 +7,42 @@
  */
 class TopAuthTokenRefreshRequest
 {
-	/** 
-	 * grantType==refresh_token 时需要
-	 **/
-	private $refreshToken;
+    /** 
+     * grantType==refresh_token 时需要
+     **/
+    private $refreshToken;
 	
-	private $apiParas = array();
+    private $apiParas = array();
 	
-	public function setRefreshToken($refreshToken)
-	{
-		$this->refreshToken = $refreshToken;
-		$this->apiParas["refresh_token"] = $refreshToken;
-	}
+    public function setRefreshToken($refreshToken)
+    {
+        $this->refreshToken = $refreshToken;
+        $this->apiParas["refresh_token"] = $refreshToken;
+    }
 
-	public function getRefreshToken()
-	{
-		return $this->refreshToken;
-	}
+    public function getRefreshToken()
+    {
+        return $this->refreshToken;
+    }
 
-	public function getApiMethodName()
-	{
-		return "taobao.top.auth.token.refresh";
-	}
+    public function getApiMethodName()
+    {
+        return "taobao.top.auth.token.refresh";
+    }
 	
-	public function getApiParas()
-	{
-		return $this->apiParas;
-	}
+    public function getApiParas()
+    {
+        return $this->apiParas;
+    }
 	
-	public function check()
-	{
+    public function check()
+    {
 		
-		RequestCheckUtil::checkNotNull($this->refreshToken,"refreshToken");
-	}
+        RequestCheckUtil::checkNotNull($this->refreshToken,"refreshToken");
+    }
 	
-	public function putOtherTextParam($key, $value) {
-		$this->apiParas[$key] = $value;
-		$this->$key = $value;
-	}
+    public function putOtherTextParam($key, $value) {
+        $this->apiParas[$key] = $value;
+        $this->$key = $value;
+    }
 }

src/service/taobao/bin/top/request/OpenuidGetRequest.php

Indentation +16 added lines, -16 removed lines

@@ -8,25 +8,25 @@
 class OpenuidGetRequest
 {
 	
-	private $apiParas = array();
+    private $apiParas = array();
 	
-	public function getApiMethodName()
-	{
-		return "taobao.openuid.get";
-	}
+    public function getApiMethodName()
+    {
+        return "taobao.openuid.get";
+    }
 	
-	public function getApiParas()
-	{
-		return $this->apiParas;
-	}
+    public function getApiParas()
+    {
+        return $this->apiParas;
+    }
 	
-	public function check()
-	{
+    public function check()
+    {
 		
-	}
+    }
 	
-	public function putOtherTextParam($key, $value) {
-		$this->apiParas[$key] = $value;
-		$this->$key = $value;
-	}
+    public function putOtherTextParam($key, $value) {
+        $this->apiParas[$key] = $value;
+        $this->$key = $value;
+    }
 }

src/service/taobao/bin/top/ClusterTopClient.php

Indentation +192 added lines, -192 removed lines

@@ -1,199 +1,199 @@
 <?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;
+    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(!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); }
+        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); }
 }
 ?>
\ No newline at end of file

src/service/taobao/bin/aliyun/AliyunClient.php

Indentation +231 added lines, -231 removed lines

@@ -1,255 +1,255 @@
 <?php
 class AliyunClient
 {
-	public $accessKeyId;
+    public $accessKeyId;
 
-	public $accessKeySecret;
+    public $accessKeySecret;
 
-	public $serverUrl = "http://ecs.aliyuncs.com/";
+    public $serverUrl = "http://ecs.aliyuncs.com/";
 
-	public $format = "json";
+    public $format = "json";
 
-	public $connectTimeout = 3000;//3秒
+    public $connectTimeout = 3000;//3秒
 
-	public $readTimeout = 80000;//80秒
+    public $readTimeout = 80000;//80秒
 
-	/** 是否打开入参check**/
-	public $checkRequest = true;
+    /** 是否打开入参check**/
+    public $checkRequest = true;
 
-	protected $signatureMethod = "HMAC-SHA1";
+    protected $signatureMethod = "HMAC-SHA1";
 
-	protected $signatureVersion = "1.0";
+    protected $signatureVersion = "1.0";
 	
     protected  $dateTimeFormat = 'Y-m-d\TH:i:s\Z'; // ISO8601规范
 	
-	protected $sdkVersion = "1.0";
-
-	public function execute($request)
-	{
-		if($this->checkRequest) {
-			try {
-				$request->check();
-			} catch (Exception $e) {
-				$result->code = $e->getCode();
-				$result->message = $e->getMessage();
-				return $result;
-			}
-		}
-		//获取业务参数
-		$apiParams = $request->getApiParas();
-		//组装系统参数
-		$apiParams["AccessKeyId"] = $this->accessKeyId;
-		$apiParams["Format"] = $this->format;//
-		$apiParams["SignatureMethod"] = $this->signatureMethod;
-		$apiParams["SignatureVersion"] = $this->signatureVersion;
-		$apiParams["SignatureNonce"] = uniqid();
-		date_default_timezone_set("GMT");
-		$apiParams["TimeStamp"] = date($this->dateTimeFormat);
-		$apiParams["partner_id"] = $this->sdkVersion;
+    protected $sdkVersion = "1.0";
+
+    public function execute($request)
+    {
+        if($this->checkRequest) {
+            try {
+                $request->check();
+            } catch (Exception $e) {
+                $result->code = $e->getCode();
+                $result->message = $e->getMessage();
+                return $result;
+            }
+        }
+        //获取业务参数
+        $apiParams = $request->getApiParas();
+        //组装系统参数
+        $apiParams["AccessKeyId"] = $this->accessKeyId;
+        $apiParams["Format"] = $this->format;//
+        $apiParams["SignatureMethod"] = $this->signatureMethod;
+        $apiParams["SignatureVersion"] = $this->signatureVersion;
+        $apiParams["SignatureNonce"] = uniqid();
+        date_default_timezone_set("GMT");
+        $apiParams["TimeStamp"] = date($this->dateTimeFormat);
+        $apiParams["partner_id"] = $this->sdkVersion;
 		
-	    $apiNameArray =	split("\.", $request->getApiMethodName());
-		$apiParams["Action"] = $apiNameArray[3];
-		$apiParams["Version"] = $apiNameArray[4];
-		//签名
-		$apiParams["Signature"] = $this->computeSignature($apiParams, $this->accessKeySecret);
-
-		//系统参数放入GET请求串
-		$requestUrl = rtrim($this->serverUrl,"/") . "/?";
-		foreach ($apiParams as $apiParamKey => $apiParamValue)
-		{
-			$requestUrl .= "$apiParamKey=" . urlencode($apiParamValue) . "&";
-		}
-		$requestUrl = substr($requestUrl, 0, -1);
-		//发起HTTP请求
-		try
-		{
-			$resp = $this->curl($requestUrl, null);
-		}
-		catch (Exception $e)
-		{
-			$this->logCommunicationError($apiParams["Action"],$requestUrl,"HTTP_ERROR_" . $e->getCode(),$e->getMessage());
-			if ("json" == $this->format)
-			{
-				return  json_decode($e->getMessage());
-			}
-			else if("xml" == $this->format)
-			{
-				return  @simplexml_load_string($e->getMessage());
-			}
-	    }
-
-		//解析API返回结果
-		$respWellFormed = false;
-		if ("json" == $this->format)
-		{
-			$respObject = json_decode($resp);
-			if (null !== $respObject)
-			{
-				$respWellFormed = true;
-			}
-		}
-		else if("xml" == $this->format)
-		{
-			$respObject = @simplexml_load_string($resp);
-			if (false !== $respObject)
-			{
-				$respWellFormed = true;
-			}
-		}
-
-		//返回的HTTP文本不是标准JSON或者XML，记下错误日志
-		if (false === $respWellFormed)
-		{
-			$this->logCommunicationError($apiParams["Action"],$requestUrl,"HTTP_RESPONSE_NOT_WELL_FORMED",$resp);
-			$result->code = 0;
-			$result->message = "HTTP_RESPONSE_NOT_WELL_FORMED";
-			return $result;
-		}
-
-		//如果TOP返回了错误码，记录到业务错误日志中
-		if (isset($respObject->code))
-		{
-			$logger = new LtLogger;
-			$logger->conf["log_file"] = rtrim(TOP_SDK_WORK_DIR, '\\/') . '/' . "logs/top_biz_err_" . $this->appkey . "_" . date("Y-m-d") . ".log";
-			$logger->log(array(
-				date("Y-m-d H:i:s"),
-				$resp
-			));
-		}
-		return $respObject;
-	}
-
-	public function exec($paramsArray)
-	{
-		if (!isset($paramsArray["Action"]))
-		{
-			trigger_error("No api name passed");
-		}
-		$inflector = new LtInflector;
-		$inflector->conf["separator"] = ".";
-		$requestClassName = ucfirst($inflector->camelize(substr($paramsArray["Action"], 7))) . "Request";
-		if (!class_exists($requestClassName))
-		{
-			trigger_error("No such api: " . $paramsArray["Action"]);
-		}
-
-		$req = new $requestClassName;
-		foreach($paramsArray as $paraKey => $paraValue)
-		{
-			$inflector->conf["separator"] = "_";
-			$setterMethodName = $inflector->camelize($paraKey);
-			$inflector->conf["separator"] = ".";
-			$setterMethodName = "set" . $inflector->camelize($setterMethodName);
-			if (method_exists($req, $setterMethodName))
-			{
-				$req->$setterMethodName($paraValue);
-			}
-		}
-		return $this->execute($req, $session);
-	}
+        $apiNameArray =	split("\.", $request->getApiMethodName());
+        $apiParams["Action"] = $apiNameArray[3];
+        $apiParams["Version"] = $apiNameArray[4];
+        //签名
+        $apiParams["Signature"] = $this->computeSignature($apiParams, $this->accessKeySecret);
+
+        //系统参数放入GET请求串
+        $requestUrl = rtrim($this->serverUrl,"/") . "/?";
+        foreach ($apiParams as $apiParamKey => $apiParamValue)
+        {
+            $requestUrl .= "$apiParamKey=" . urlencode($apiParamValue) . "&";
+        }
+        $requestUrl = substr($requestUrl, 0, -1);
+        //发起HTTP请求
+        try
+        {
+            $resp = $this->curl($requestUrl, null);
+        }
+        catch (Exception $e)
+        {
+            $this->logCommunicationError($apiParams["Action"],$requestUrl,"HTTP_ERROR_" . $e->getCode(),$e->getMessage());
+            if ("json" == $this->format)
+            {
+                return  json_decode($e->getMessage());
+            }
+            else if("xml" == $this->format)
+            {
+                return  @simplexml_load_string($e->getMessage());
+            }
+        }
+
+        //解析API返回结果
+        $respWellFormed = false;
+        if ("json" == $this->format)
+        {
+            $respObject = json_decode($resp);
+            if (null !== $respObject)
+            {
+                $respWellFormed = true;
+            }
+        }
+        else if("xml" == $this->format)
+        {
+            $respObject = @simplexml_load_string($resp);
+            if (false !== $respObject)
+            {
+                $respWellFormed = true;
+            }
+        }
+
+        //返回的HTTP文本不是标准JSON或者XML，记下错误日志
+        if (false === $respWellFormed)
+        {
+            $this->logCommunicationError($apiParams["Action"],$requestUrl,"HTTP_RESPONSE_NOT_WELL_FORMED",$resp);
+            $result->code = 0;
+            $result->message = "HTTP_RESPONSE_NOT_WELL_FORMED";
+            return $result;
+        }
+
+        //如果TOP返回了错误码，记录到业务错误日志中
+        if (isset($respObject->code))
+        {
+            $logger = new LtLogger;
+            $logger->conf["log_file"] = rtrim(TOP_SDK_WORK_DIR, '\\/') . '/' . "logs/top_biz_err_" . $this->appkey . "_" . date("Y-m-d") . ".log";
+            $logger->log(array(
+                date("Y-m-d H:i:s"),
+                $resp
+            ));
+        }
+        return $respObject;
+    }
+
+    public function exec($paramsArray)
+    {
+        if (!isset($paramsArray["Action"]))
+        {
+            trigger_error("No api name passed");
+        }
+        $inflector = new LtInflector;
+        $inflector->conf["separator"] = ".";
+        $requestClassName = ucfirst($inflector->camelize(substr($paramsArray["Action"], 7))) . "Request";
+        if (!class_exists($requestClassName))
+        {
+            trigger_error("No such api: " . $paramsArray["Action"]);
+        }
+
+        $req = new $requestClassName;
+        foreach($paramsArray as $paraKey => $paraValue)
+        {
+            $inflector->conf["separator"] = "_";
+            $setterMethodName = $inflector->camelize($paraKey);
+            $inflector->conf["separator"] = ".";
+            $setterMethodName = "set" . $inflector->camelize($setterMethodName);
+            if (method_exists($req, $setterMethodName))
+            {
+                $req->$setterMethodName($paraValue);
+            }
+        }
+        return $this->execute($req, $session);
+    }
 	
-	protected function percentEncode($str)
-	{
-	    // 使用urlencode编码后，将"+","*","%7E"做替换即满足 API规定的编码规范
-	    $res = urlencode($str);
-	    $res = preg_replace('/\+/', '%20', $res);
-	    $res = preg_replace('/\*/', '%2A', $res);
-	    $res = preg_replace('/%7E/', '~', $res);
-	    return $res;
-	}
+    protected function percentEncode($str)
+    {
+        // 使用urlencode编码后，将"+","*","%7E"做替换即满足 API规定的编码规范
+        $res = urlencode($str);
+        $res = preg_replace('/\+/', '%20', $res);
+        $res = preg_replace('/\*/', '%2A', $res);
+        $res = preg_replace('/%7E/', '~', $res);
+        return $res;
+    }
 	
-	protected function computeSignature($parameters, $accessKeySecret)
-	{
-	    // 将参数Key按字典顺序排序
-	    ksort($parameters);
+    protected function computeSignature($parameters, $accessKeySecret)
+    {
+        // 将参数Key按字典顺序排序
+        ksort($parameters);
 	
-	    // 生成规范化请求字符串
-	    $canonicalizedQueryString = '';
-	    foreach($parameters as $key => $value)
-	    {
-		$canonicalizedQueryString .= '&' . $this->percentEncode($key) 
-		    . '=' . $this->percentEncode($value);
-	    }
+        // 生成规范化请求字符串
+        $canonicalizedQueryString = '';
+        foreach($parameters as $key => $value)
+        {
+        $canonicalizedQueryString .= '&' . $this->percentEncode($key) 
+            . '=' . $this->percentEncode($value);
+        }
 	
-	    // 生成用于计算签名的字符串 stringToSign
-	    $stringToSign = 'GET&%2F&' . $this->percentencode(substr($canonicalizedQueryString, 1));
+        // 生成用于计算签名的字符串 stringToSign
+        $stringToSign = 'GET&%2F&' . $this->percentencode(substr($canonicalizedQueryString, 1));
 	
-	    // 计算签名，注意accessKeySecret后面要加上字符'&'
-	    $signature = base64_encode(hash_hmac('sha1', $stringToSign, $accessKeySecret . '&', true));
-	    return $signature;
-	}
+        // 计算签名，注意accessKeySecret后面要加上字符'&'
+        $signature = base64_encode(hash_hmac('sha1', $stringToSign, $accessKeySecret . '&', true));
+        return $signature;
+    }
 	
     public function curl($url, $postFields = null)
-	{
-		$ch = curl_init();
-		curl_setopt($ch, CURLOPT_URL, $url);
-		curl_setopt($ch, CURLOPT_FAILONERROR, false);
-		curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
-		if ($this->readTimeout) {
-			curl_setopt($ch, CURLOPT_TIMEOUT, $this->readTimeout);
-		}
-		if ($this->connectTimeout) {
-			curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, $this->connectTimeout);
-		}
-		//https 请求
-		if(strlen($url) > 5 && strtolower(substr($url,0,5)) == "https" ) {
-			curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
-			curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
-		}
-
-		if (is_array($postFields) && 0 < count($postFields))
-		{
-			$postBodyString = "";
-			$postMultipart = false;
-			foreach ($postFields as $k => $v)
-			{
-				if("@" != substr($v, 0, 1))//判断是不是文件上传
-				{
-					$postBodyString .= "$k=" . urlencode($v) . "&"; 
-				}
-				else//文件上传用multipart/form-data，否则用www-form-urlencoded
-				{
-					$postMultipart = true;
-				}
-			}
-			unset($k, $v);
-			curl_setopt($ch, CURLOPT_POST, true);
-			if ($postMultipart)
-			{
-				curl_setopt($ch, CURLOPT_POSTFIELDS, $postFields);
-			}
-			else
-			{
-				curl_setopt($ch, CURLOPT_POSTFIELDS, substr($postBodyString,0,-1));
-			}
-		}
-		$reponse = curl_exec($ch);
+    {
+        $ch = curl_init();
+        curl_setopt($ch, CURLOPT_URL, $url);
+        curl_setopt($ch, CURLOPT_FAILONERROR, false);
+        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
+        if ($this->readTimeout) {
+            curl_setopt($ch, CURLOPT_TIMEOUT, $this->readTimeout);
+        }
+        if ($this->connectTimeout) {
+            curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, $this->connectTimeout);
+        }
+        //https 请求
+        if(strlen($url) > 5 && strtolower(substr($url,0,5)) == "https" ) {
+            curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
+            curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
+        }
+
+        if (is_array($postFields) && 0 < count($postFields))
+        {
+            $postBodyString = "";
+            $postMultipart = false;
+            foreach ($postFields as $k => $v)
+            {
+                if("@" != substr($v, 0, 1))//判断是不是文件上传
+                {
+                    $postBodyString .= "$k=" . urlencode($v) . "&"; 
+                }
+                else//文件上传用multipart/form-data，否则用www-form-urlencoded
+                {
+                    $postMultipart = true;
+                }
+            }
+            unset($k, $v);
+            curl_setopt($ch, CURLOPT_POST, true);
+            if ($postMultipart)
+            {
+                curl_setopt($ch, CURLOPT_POSTFIELDS, $postFields);
+            }
+            else
+            {
+                curl_setopt($ch, CURLOPT_POSTFIELDS, substr($postBodyString,0,-1));
+            }
+        }
+        $reponse = curl_exec($ch);
 		
-		if (curl_errno($ch))
-		{
-			throw new Exception(curl_error($ch),0);
-		}
-		curl_close($ch);
-		return $reponse;
-	}
-
-	protected function logCommunicationError($apiName, $requestUrl, $errorCode, $responseTxt)
-	{
-		$localIp = isset($_SERVER["SERVER_ADDR"]) ? $_SERVER["SERVER_ADDR"] : "CLI";
-		$logger = new LtLogger;
-		$logger->conf["log_file"] = rtrim(TOP_SDK_WORK_DIR, '\\/') . '/' . "logs/top_comm_err_" . $this->accessKeyId . "_" . date("Y-m-d") . ".log";
-		$logger->conf["separator"] = "^_^";
-		$logData = array(
-		date("Y-m-d H:i:s"),
-		$apiName,
-		$this->accessKeyId,
-		$localIp,
-		PHP_OS,
-		$this->sdkVersion,
-		$requestUrl,
-		$errorCode,
-		str_replace("\n","",$responseTxt)
-		);
-		$logger->log($logData);
-	}
+        if (curl_errno($ch))
+        {
+            throw new Exception(curl_error($ch),0);
+        }
+        curl_close($ch);
+        return $reponse;
+    }
+
+    protected function logCommunicationError($apiName, $requestUrl, $errorCode, $responseTxt)
+    {
+        $localIp = isset($_SERVER["SERVER_ADDR"]) ? $_SERVER["SERVER_ADDR"] : "CLI";
+        $logger = new LtLogger;
+        $logger->conf["log_file"] = rtrim(TOP_SDK_WORK_DIR, '\\/') . '/' . "logs/top_comm_err_" . $this->accessKeyId . "_" . date("Y-m-d") . ".log";
+        $logger->conf["separator"] = "^_^";
+        $logData = array(
+        date("Y-m-d H:i:s"),
+        $apiName,
+        $this->accessKeyId,
+        $localIp,
+        PHP_OS,
+        $this->sdkVersion,
+        $requestUrl,
+        $errorCode,
+        str_replace("\n","",$responseTxt)
+        );
+        $logger->log($logData);
+    }
 }

src/service/taobao/bin/Autoloader.php

Indentation +3 added lines, -3 removed lines

@@ -2,7 +2,7 @@ 
 
 class Autoloader{
   
-  /**
+    /**
      * 类库自动加载，写死路径，确保不加载其他文件。
      * @param string $class 对象类名
      * @return void
@@ -10,7 +10,7 @@ 
     public static function autoload($class) {
         $name = $class;
         if(false !== strpos($name,'\\')){
-          $name = strstr($class, '\\', true);
+            $name = strstr($class, '\\', true);
         }
         
         $filename = TOP_AUTOLOADER_PATH."/top/".$name.".php";
@@ -66,7 +66,7 @@ 
             return;
         }         
 		
-		$filename = TOP_AUTOLOADER_PATH."/QimenCloud/".$name.".php";
+        $filename = TOP_AUTOLOADER_PATH."/QimenCloud/".$name.".php";
         if(is_file($filename)) {
             include $filename;
             return;

src/service/pinduoduo/bin/src/Api/Request/PddStockDepotPriorityUpdateRequest.php

Indentation +80 added lines, -80 removed lines

@@ -7,98 +7,98 @@
 class PddStockDepotPriorityUpdateRequest extends PopBaseHttpRequest
 {
     public function __construct()
-	{
+    {
 
-	}
-	/**
-	* @JsonProperty(List<\Com\Pdd\Pop\Sdk\Api\Request\PddStockDepotPriorityUpdateRequest_PriorityListItem>, "priority_list")
-	*/
-	private $priorityList;
+    }
+    /**
+     * @JsonProperty(List<\Com\Pdd\Pop\Sdk\Api\Request\PddStockDepotPriorityUpdateRequest_PriorityListItem>, "priority_list")
+     */
+    private $priorityList;
 
-	protected function setUserParams(&$params)
-	{
-		$this->setUserParam($params, "priority_list", $this->priorityList);
+    protected function setUserParams(&$params)
+    {
+        $this->setUserParam($params, "priority_list", $this->priorityList);
 
-	}
+    }
 
-	public function getVersion()
-	{
-		return "V1";
-	}
+    public function getVersion()
+    {
+        return "V1";
+    }
 
-	public function getDataType()
-	{
-		return "JSON";
-	}
+    public function getDataType()
+    {
+        return "JSON";
+    }
 
-	public function getType()
-	{
-		return "pdd.stock.depot.priority.update";
-	}
+    public function getType()
+    {
+        return "pdd.stock.depot.priority.update";
+    }
 
-	public function setPriorityList($priorityList)
-	{
-		$this->priorityList = $priorityList;
-	}
+    public function setPriorityList($priorityList)
+    {
+        $this->priorityList = $priorityList;
+    }
 
 }
 
 class PddStockDepotPriorityUpdateRequest_PriorityListItem extends PopBaseJsonEntity
 {
 
-	public function __construct()
-	{
-
-	}
-
-	/**
-	* @JsonProperty(Integer, "priority")
-	*/
-	private $priority;
-
-	/**
-	* @JsonProperty(Integer, "district_id")
-	*/
-	private $districtId;
-
-	/**
-	* @JsonProperty(Integer, "city_id")
-	*/
-	private $cityId;
-
-	/**
-	* @JsonProperty(Integer, "province_id")
-	*/
-	private $provinceId;
-
-	/**
-	* @JsonProperty(Long, "depot_id")
-	*/
-	private $depotId;
-
-	public function setPriority($priority)
-	{
-		$this->priority = $priority;
-	}
-
-	public function setDistrictId($districtId)
-	{
-		$this->districtId = $districtId;
-	}
-
-	public function setCityId($cityId)
-	{
-		$this->cityId = $cityId;
-	}
-
-	public function setProvinceId($provinceId)
-	{
-		$this->provinceId = $provinceId;
-	}
-
-	public function setDepotId($depotId)
-	{
-		$this->depotId = $depotId;
-	}
+    public function __construct()
+    {
+
+    }
+
+    /**
+     * @JsonProperty(Integer, "priority")
+     */
+    private $priority;
+
+    /**
+     * @JsonProperty(Integer, "district_id")
+     */
+    private $districtId;
+
+    /**
+     * @JsonProperty(Integer, "city_id")
+     */
+    private $cityId;
+
+    /**
+     * @JsonProperty(Integer, "province_id")
+     */
+    private $provinceId;
+
+    /**
+     * @JsonProperty(Long, "depot_id")
+     */
+    private $depotId;
+
+    public function setPriority($priority)
+    {
+        $this->priority = $priority;
+    }
+
+    public function setDistrictId($districtId)
+    {
+        $this->districtId = $districtId;
+    }
+
+    public function setCityId($cityId)
+    {
+        $this->cityId = $cityId;
+    }
+
+    public function setProvinceId($provinceId)
+    {
+        $this->provinceId = $provinceId;
+    }
+
+    public function setDepotId($depotId)
+    {
+        $this->depotId = $depotId;
+    }
 
 }

src/service/pinduoduo/bin/src/Api/Request/PddLogisticsTicketProblemTypeGetRequest.php

Indentation +17 added lines, -17 removed lines

@@ -7,27 +7,27 @@
 class PddLogisticsTicketProblemTypeGetRequest extends PopBaseHttpRequest
 {
     public function __construct()
-	{
+    {
 
-	}
-	protected function setUserParams(&$params)
-	{
+    }
+    protected function setUserParams(&$params)
+    {
 
-	}
+    }
 
-	public function getVersion()
-	{
-		return "V1";
-	}
+    public function getVersion()
+    {
+        return "V1";
+    }
 
-	public function getDataType()
-	{
-		return "JSON";
-	}
+    public function getDataType()
+    {
+        return "JSON";
+    }
 
-	public function getType()
-	{
-		return "pdd.logistics.ticket.problem.type.get";
-	}
+    public function getType()
+    {
+        return "pdd.logistics.ticket.problem.type.get";
+    }
 
 }

src/service/pinduoduo/bin/src/Api/Request/PddDdkOauthGoodsPidQueryRequest.php

Indentation +44 added lines, -44 removed lines

@@ -7,60 +7,60 @@
 class PddDdkOauthGoodsPidQueryRequest extends PopBaseHttpRequest
 {
     public function __construct()
-	{
+    {
 
-	}
-	/**
-	* @JsonProperty(Integer, "page")
-	*/
-	private $page;
+    }
+    /**
+     * @JsonProperty(Integer, "page")
+     */
+    private $page;
 
-	/**
-	* @JsonProperty(Integer, "page_size")
-	*/
-	private $pageSize;
+    /**
+     * @JsonProperty(Integer, "page_size")
+     */
+    private $pageSize;
 
-	/**
-	* @JsonProperty(List<String>, "pid_list")
-	*/
-	private $pidList;
+    /**
+     * @JsonProperty(List<String>, "pid_list")
+     */
+    private $pidList;
 
-	protected function setUserParams(&$params)
-	{
-		$this->setUserParam($params, "page", $this->page);
-		$this->setUserParam($params, "page_size", $this->pageSize);
-		$this->setUserParam($params, "pid_list", $this->pidList);
+    protected function setUserParams(&$params)
+    {
+        $this->setUserParam($params, "page", $this->page);
+        $this->setUserParam($params, "page_size", $this->pageSize);
+        $this->setUserParam($params, "pid_list", $this->pidList);
 
-	}
+    }
 
-	public function getVersion()
-	{
-		return "V1";
-	}
+    public function getVersion()
+    {
+        return "V1";
+    }
 
-	public function getDataType()
-	{
-		return "JSON";
-	}
+    public function getDataType()
+    {
+        return "JSON";
+    }
 
-	public function getType()
-	{
-		return "pdd.ddk.oauth.goods.pid.query";
-	}
+    public function getType()
+    {
+        return "pdd.ddk.oauth.goods.pid.query";
+    }
 
-	public function setPage($page)
-	{
-		$this->page = $page;
-	}
+    public function setPage($page)
+    {
+        $this->page = $page;
+    }
 
-	public function setPageSize($pageSize)
-	{
-		$this->pageSize = $pageSize;
-	}
+    public function setPageSize($pageSize)
+    {
+        $this->pageSize = $pageSize;
+    }
 
-	public function setPidList($pidList)
-	{
-		$this->pidList = $pidList;
-	}
+    public function setPidList($pidList)
+    {
+        $this->pidList = $pidList;
+    }
 
 }