zoumaliveServer/system/tim/TimRestApi.php

<?php
require_once dirname(__FILE__) . '/TimRestInterface.php';
class TimRestAPI extends TimRestInterface
{
	#app基本信息
	protected $sdkappid = 0;
	protected $usersig = '';
	protected $identifier = '';

	#开放IM https接口参数, 一般不需要修改
	protected $http_type = 'https://';
	protected $method = 'post';
	protected $im_yun_url = 'console.tim.qq.com';
	protected $version = 'v4';
	protected $contenttype = 'json';
	protected $apn = '0';

	
	/**
	 * 初始化函数
	 * @param int $sdkappid 应用的appid
	 * @param string $identifier 访问接口的用户
	 */
	function init($sdkappid, $identifier)
	{
	
		$this->sdkappid = $sdkappid;
		$this->identifier = $identifier;
	}

	/** 
	 * 构造访问REST服务器的参数,并访问REST接口
	 * @param string $server_name 服务名
	 * @param string $cmd_name 命令名
	 * @param string $identifier 用户名
	 * @param string $usersig 用来鉴权的usersig
	 * @param string $req_data 传递的json结构
	 * $param bool $print_flag 是否打印请求，默认为打印
	 * @return string $out 返回的签名字符串
	 */
	public function api($service_name, $cmd_name, $identifier, $usersig, $req_data, $print_flag = false)
	{   
		//$req_tmp用来做格式化输出
		$req_tmp = json_decode($req_data, true);
		# 构建HTTP请求参数，具体格式请参考 REST API接口文档 (http://avc.qcloud.com/wiki/im/)(即时通信云-数据管理REST接口)
        $parameter =  "usersig=" . $this->usersig
            . "&identifier=" . $this->identifier
            . "&sdkappid=" . $this->sdkappid
            . "&contenttype=" . $this->contenttype;
		$url = $this->http_type . $this->im_yun_url . '/' . $this->version . '/' . $service_name . '/' .$cmd_name . '?' . $parameter;
		
		if($print_flag)
		{
			echo "Request Url:\n";
			echo $url;
			echo "\n";
			echo "Request Body:\n";
			echo json_format($req_tmp);
			echo "\n";
		}
		$ret = $this->http_req('https', 'post', $url, $req_data);
		return $ret;

	}   

	/** 
	 * 构造访问REST服务器参数,并发访问REST服务器
	 * @param string $server_name 服务名
	 * @param string $cmd_name 命令名
	 * @param string $identifier 用户名
	 * @param string $usersig 用来鉴权的usersig
	 * @param string $req_data 传递的json结构
	 * $param bool $print_flag 是否打印请求，默认为打印
	 * @return string $out 返回的签名字符串
	 */
	public function multi_api($service_name, $cmd_name, $identifier, $usersig, $req_data, $print_flag = true)
	{   
		
		//$req_tmp用来做格式化控制台输出,同时作为多路访问需要的数组结构
		$req_tmp = json_decode($req_data, true);
		# 构建HTTP请求参数，具体格式请参考 REST API接口文档 (http://avc.qcloud.com/wiki/im/)(即时通信云-数据管理REST接口)
        $parameter =  "usersig=" . $this->usersig
            . "&identifier=" . $this->identifier
            . "&sdkappid=" . $this->sdkappid
            . "&contenttype=" . $this->contenttype;

		$url = $this->http_type . $this->im_yun_url . '/' . $this->version . '/' . $service_name . '/' .$cmd_name . '?' . $parameter;
		
		if($print_flag)
		{
			echo "Request Url:\n";
			echo $url;
			echo "\n";
			echo "Request Body:\n";
			echo json_format($req_tmp);
			echo "\n";
        }
		$ret = $this->http_req_multi('https', 'post', $url, $req_tmp);
        return $ret;

	}

	/**
	 * 独立模式根据Identifier生成UserSig的方法
	 * @param int $identifier 用户账号
	 * @param int $expiry_after 过期时间
	 * @param string $protected_key_path 私钥的存储路径及文件名
	 * @return string $out 返回的签名字符串
	 */
	public function generate_user_sig($identifier, $expiry_after, $protected_key_path, $tool_path)
	{
	
		# 这里需要写绝对路径，开发者根据自己的路径进行调整
		$command = escapeshellarg($tool_path)
			. ' '. escapeshellarg($protected_key_path)
			. ' ' . escapeshellarg($this->sdkappid)
			. ' ' .escapeshellarg($identifier);
		$ret = exec($command, $out, $status);
		if( $status == -1)
		{
			return null;
		}
		$this->usersig = $out[0];
		return $out;
	}
	
	/**
	 * 托管模式设置用户凭证
	 * @param string $protected_key_path 私钥的存储路径及文件名
	 * @return bool 返回成功与否
	 */
	public function set_user_sig($usr_sig)
	{
		$this->usersig = $usr_sig;
		return true;
	}

	/**
	 * 向Rest服务器发送请求
	 * @param string $http_type http类型,比如https
	 * @param string $method 请求方式，比如POST
	 * @param string $url 请求的url
	 * @return string $data 请求的数据
	 */
	public static function http_req($http_type, $method, $url, $data)
	{
		$ch = curl_init();
		if (strstr($http_type, 'https'))
		{
			curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
			curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0); 
		}   

		if ($method == 'post')
		{
			curl_setopt($ch, CURLOPT_POST, 1); 
			curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
		} else
		{
			$url = $url . '?' . $data;
		}		
		curl_setopt($ch, CURLOPT_URL, $url);
		curl_setopt($ch, CURLOPT_HEADER, 0); 
		curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); 
		curl_setopt($ch, CURLOPT_TIMEOUT,100000);//超时时间

		try
		{
			$ret=curl_exec($ch);
		}catch(Exception $e)
		{
			curl_close($ch);
			return json_encode(array('ret'=>0,'msg'=>'failure'));
		}
		curl_close($ch);
		return $ret;
	}

	/**
	 * 向Rest服务器发送多个请求(并发)
	 * @param string $http_type http类型,比如https
	 * @param string $method 请求方式，比如POST
	 * @param string $url 请求的url
	 * @return bool 是否成功
	 */
	public static function http_req_multi($http_type, $method, $url, $data)
	{
		$mh = curl_multi_init();
		$ch_list = array();
		$i = -1;
		$req_list = array();
		foreach($data as $req_data)
		{
			$i++;
			$req_data = json_encode($req_data);
			$ch = curl_init();
			if ($http_type == 'https://') 
			{
				curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
				curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 1); 
			}   

			if ($method == 'post')
			{
				curl_setopt($ch, CURLOPT_POST, 1); 
				curl_setopt($ch, CURLOPT_POSTFIELDS, $req_data);
			} else
			{
				$url = $url . '?' . $data;
			}   
			curl_setopt($ch, CURLOPT_URL, $url);
			curl_setopt($ch, CURLOPT_HEADER, 0); 
			curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); 
			curl_setopt($ch, CURLOPT_TIMEOUT,100000);//超时时间
			curl_multi_add_handle($mh, $ch);
			$ch_list[] = $ch;
			$req_list[] = $req_data;
		}
		try
		{
			do{
				$mret = curl_multi_exec($mh, $active);
			}while($mret == CURLM_CALL_MULTI_PERFORM);

			while($active and $mret == CURLM_OK){
				if(curl_multi_select($mh) === -1){
					usleep(100);
				}
				do{
					$mret = curl_multi_exec($mh, $active);
				}while($mret == CURLM_CALL_MULTI_PERFORM);
			}
		}catch(Exception $e)
		{
			curl_close($ch);
			return json_encode(array('ret'=>0,'msg'=>'failure'));
        }
        for($i = 0; $i < count($ch_list); $i++)
        {
            $ret = curl_multi_getcontent($ch_list[$i]);
            if(strstr($ret, "URL_INFO"))
            {
		        curl_multi_close($mh);
                return $ret;
            }
            $ret = json_decode($ret, true);
            echo json_format($ret);
        }
		curl_multi_close($mh);
		return true;
	}

	#REST API 访问接口集合
	#参数详情见RestInterface

	public function openim_send_msg($account_id, $receiver, $text_content)
	{
		
		#构造高级接口所需参数
		$msg_content = array();
		//创建array 所需元素
		$msg_content_elem = array(
				'MsgType' => 'TIMTextElem',       //文本类型
				'MsgContent' => array(
					'Text' => $text_content,                //hello 为文本信息
					)
				);
		//将创建的元素$msg_content_elem, 加入array $msg_content
		array_push($msg_content, $msg_content_elem);
		
		$ret = $this->openim_send_msg2($account_id, $receiver, $msg_content);
		return $ret;
	}

	/**
	 * 设置全局禁言 https://www.qcloud.com/doc/product/269/4230
	 * @param int time 禁言时长，默认最长 4294967295 表示永久禁言，0 取消禁言
	 */
	public function set_no_speaking($user_id, $time = 4294967295)
	{
        $user_id = (string)$user_id;
		$req_data = json_encode(array(
			'Set_Account' => $user_id,
			'C2CmsgNospeakingTime' => $time,
			'GroupmsgNospeakingTime' => $time,
			));
		$ret = $this->api("openconfigsvr", "setnospeaking", $this->identifier, $this->usersig, $req_data, false);
        return json_decode($ret,true);
	}
	
	public function openpic_pic_upload($account_id, $receiver, $pic_path, $busi_type)
	{
		
		#获取长度和md5值
		$pic_data = file_get_contents($pic_path);
		$md5 = md5($pic_data);
		$pic_size = filesize($pic_path);
		
		#进行base64处理	
		$fp = fopen($pic_path, "r");
		$pic_data = fread($fp, $pic_size);
		
		$slice_data = array();
		$slice_size = array();
		$SLICE_SIZE = 32*4096;
		
		//对文件进行分片
		for($i = 0; $i < $pic_size; $i = $i + $SLICE_SIZE)
		{
			if($i + $SLICE_SIZE > $pic_size)
			{
				break;
			}
			$slice_tmp = substr($pic_data, $i, $SLICE_SIZE);
			$slice_tmp = chunk_split(base64_encode($slice_tmp));
			$slice_tmp = str_replace("\r\n", '', $slice_tmp);
			$slice_size[] = $SLICE_SIZE;
			$slice_data[] = $slice_tmp;
		}
		
		//最后一个分片
		if($i - $SLICE_SIZE < $pic_size)
		{
			$slice_size[] = $pic_size-$i;
			$tmp = substr($pic_data, $i, $pic_size-$i);
			$slice_size[] = strlen($tmp);
			$tmp = chunk_split(base64_encode($tmp));
			$tmp = str_replace("\r\n", '', $tmp);
			
			$slice_data[] = $tmp;
		}

		$pic_rand = rand(1, 65535);
		$time_stamp = time();
        $req_data_list = array();
        $sentOut = 0;
        printf("handle %d segments\n", count($slice_data)-1);
        for($i = 0; $i < count($slice_data)-1; $i++)
        {
            #构造消息
            $msg = array(
                "From_Account" => $account_id,  //发送者
                "To_Account" => $receiver,      //接收者
                "App_Version" => 1.4,       //应用版本号
                "Seq" => $i+1,                      //同一个分片需要保持一致
                "Timestamp" => $time_stamp,         //同一张图片的不同分片需要保持一致
                "Random" => $pic_rand,              //同一张图片的不同分片需要保持一致
                "File_Str_Md5" => $md5,         //图片MD5，验证图片的完整性
                "File_Size" => $pic_size,       //图片原始大小
                "Busi_Id" => $busi_type,                    //群消息:1 c2c消息:2 个人头像：3 群头像：4
                "PkgFlag" => 1,                 //同一张图片要保持一致: 0表示图片数据没有被处理 ；1-表示图片经过base64编码，固定为1
                "Slice_Offset" => $i*$SLICE_SIZE,           //必须是4K的整数倍
                "Slice_Size" => $slice_size[$i],        //必须是4K的整数倍,除最后一个分片列外
                "Slice_Data" => $slice_data[$i]     //PkgFlag=1时，为base64编码
            );
            array_push($req_data_list, $msg);
            $sentOut = 0;
            if ($i != 0 && ($i+1) % 4 == 0)
            {
                //将消息序列化为json串
                $req_data_list = json_encode($req_data_list);
                printf("\ni = %d, call multi_api once\n", $i);
                $ret = $this->multi_api("openpic", "pic_up", $this->identifier, $this->usersig, $req_data_list, false);
                if(gettype($ret) == "string")
                {
                    $ret = json_decode($ret, true);
                    return $ret;
                }
                $req_data_list = array();
                $sentOut = 1;
            }
        }

        if ($sentOut == 0)
        {
            $req_data_list = json_encode($req_data_list);
            printf("\ni = %d, call multi_api once\n", $i);
            $this->multi_api("openpic", "pic_up", $this->identifier, $this->usersig, $req_data_list, false);
        }
        
        #最后一个分片
		$msg = array(
				"From_Account" => $account_id,	//发送者
				"To_Account" => $receiver,		//接收者
				"App_Version" => 1.4,		//应用版本号
				"Seq" => $i+1,						//同一个分片需要保持一致
				"Timestamp" => $time_stamp,			//同一张图片的不同分片需要保持一致
				"Random" => $pic_rand,				//同一张图片的不同分片需要保持一致
				"File_Str_Md5" => $md5,			//图片MD5，验证图片的完整性
				"File_Size" => $pic_size,		//图片原始大小
				"Busi_Id" => $busi_type,					//群消息:1 c2c消息:2 个人头像：3 群头像：4
				"PkgFlag" => 1,					//同一张图片要保持一致: 0表示图片数据没有被处理 ；1-表示图片经过base64编码，固定为1
				"Slice_Offset" => $i*$SLICE_SIZE,			//必须是4K的整数倍
				"Slice_Size" => $slice_size[count($slice_data)-1],		//必须是4K的整数倍,除最后一个分片列外
				"Slice_Data" => $slice_data[count($slice_data)-1]		//PkgFlag=1时，为base64编码
				); 
		
		$req_data = json_encode($msg);
		$ret = $this->api("openpic", "pic_up", $this->identifier, $this->usersig, $req_data, false);
        $ret = json_decode($ret, true);
        echo json_format($ret);
		return $ret;
	}

	public function openim_send_msg_pic($account_id, $receiver, $pic_path)
	{
		
		#构造高级接口所需参数
		//上传图片并获取url
		$busi_type = 2; //表示C2C消息
		$ret =  $this->openpic_pic_upload($account_id, $receiver, $pic_path, $busi_type);
		$tmp = $ret["URL_INFO"];
		
		$uuid = $ret["File_UUID"];
		$pic_url = $tmp[0]["DownUrl"];
		
		$img_info = array();
		$img_tmp = $ret["URL_INFO"][0];
		if($img_tmp["PIC_TYPE"] == 4){
			$img_tmp["PIC_TYPE"] = 3;
		}
		$img_info_elem1 = array(
				"URL" => $img_tmp["DownUrl"],
				"Height" => $img_tmp["PIC_Height"],
				"Size" => $img_tmp["PIC_Size"],
				"Type" => $img_tmp["PIC_TYPE"],
				"Width" => $img_tmp["PIC_Width"]
				);
		
		$img_tmp = $ret["URL_INFO"][1];
		if($img_tmp["PIC_TYPE"] == 4){
			$img_tmp["PIC_TYPE"] = 3;
		}
		$img_info_elem2 = array(
				"URL" => $img_tmp["DownUrl"],
				"Height" => $img_tmp["PIC_Height"],
				"Size" => $img_tmp["PIC_Size"],
				"Type" => $img_tmp["PIC_TYPE"],
				"Width" => $img_tmp["PIC_Width"]
				);
		
		$img_tmp = $ret["URL_INFO"][2];
		if($img_tmp["PIC_TYPE"] == 4){
			$img_tmp["PIC_TYPE"] = 3;
		}
		$img_info_elem3 = array(
				"URL" => $img_tmp["DownUrl"],
				"Height" => $img_tmp["PIC_Height"],
				"Size" => $img_tmp["PIC_Size"],
				"Type" => $img_tmp["PIC_TYPE"],
				"Width" => $img_tmp["PIC_Width"]
				);
		
		array_push($img_info, $img_info_elem1);
		array_push($img_info, $img_info_elem2);
		array_push($img_info, $img_info_elem3);
		$msg_content = array();
		//创建array 所需元素
		$msg_content_elem = array(
				'MsgType' => 'TIMImageElem',       //文本类型
				'MsgContent' => array(
					'UUID' => $uuid,
					'ImageInfoArray' => $img_info,               
					)
				);
		//将创建的元素$msg_content_elem, 加入array $msg_content
		array_push($msg_content, $msg_content_elem);
		
		$ret = $this->openim_send_msg2($account_id, $receiver, $msg_content);
		return $ret;
	}
	
	public function openim_send_msg2($account_id, $receiver, $msg_content)
	{

		#构造新消息 
		$msg = array(
				'To_Account' => $receiver,
				'MsgSeq' => rand(1, 65535),
				'MsgRandom' => rand(1, 65535),
				'MsgTimeStamp' => time(),
				'MsgBody' => $msg_content,
				'From_Account' => $account_id
				); 
		#将消息序列化为json串
		$req_data = json_encode($msg);

		$ret = $this->api("openim", "sendmsg", $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;
	}

	public function openim_batch_sendmsg($account_list, $text_content)
	{
		
		#构造高级接口所需参数
		$msg_content = array();
		//创建array 所需元素
		$msg_content_elem = array(
				'MsgType' => 'TIMTextElem',       //文本类型
				'MsgContent' => array(
					'Text' => $text_content,                //hello 为文本信息
					)
				);
		//将创建的元素$msg_content_elem, 加入array $msg_content
		array_push($msg_content, $msg_content_elem);
		
        $ret = $this->openim_batch_sendmsg2($account_list, $msg_content);
		return $ret;
	}

	public function openim_batch_sendmsg_pic($account_list, $pic_path)
	{
		
		#构造高级接口所需参数
		//上传图片并获取url
		$busi_type = 2; //表示C2C消息
		$ret =  $this->openpic_pic_upload($this->identifier, $account_list[0], $pic_path, $busi_type);
		$tmp = $ret["URL_INFO"];
		
		$uuid = $ret["File_UUID"];
		$pic_url = $tmp[0]["DownUrl"];
		
		$img_info = array();
		$img_tmp = $ret["URL_INFO"][0];
		if($img_tmp["PIC_TYPE"] == 4){
			$img_tmp["PIC_TYPE"] = 3;
		}
		$img_info_elem1 = array(
				"URL" => $img_tmp["DownUrl"],
				"Height" => $img_tmp["PIC_Height"],
				"Size" => $img_tmp["PIC_Size"],
				"Type" => $img_tmp["PIC_TYPE"],
				"Width" => $img_tmp["PIC_Width"]
				);
		
		$img_tmp = $ret["URL_INFO"][1];
		if($img_tmp["PIC_TYPE"] == 4){
			$img_tmp["PIC_TYPE"] = 3;
		}
		$img_info_elem2 = array(
				"URL" => $img_tmp["DownUrl"],
				"Height" => $img_tmp["PIC_Height"],
				"Size" => $img_tmp["PIC_Size"],
				"Type" => $img_tmp["PIC_TYPE"],
				"Width" => $img_tmp["PIC_Width"]
				);
		
		$img_tmp = $ret["URL_INFO"][2];
		if($img_tmp["PIC_TYPE"] == 4){
			$img_tmp["PIC_TYPE"] = 3;
		}
		$img_info_elem3 = array(
				"URL" => $img_tmp["DownUrl"],
				"Height" => $img_tmp["PIC_Height"],
				"Size" => $img_tmp["PIC_Size"],
				"Type" => $img_tmp["PIC_TYPE"],
				"Width" => $img_tmp["PIC_Width"]
				);
		
		array_push($img_info, $img_info_elem1);
		array_push($img_info, $img_info_elem2);
		array_push($img_info, $img_info_elem3);
		$msg_content = array();
		//创建array 所需元素
		$msg_content_elem = array(
				'MsgType' => 'TIMImageElem',       //文本类型
				'MsgContent' => array(
					'UUID' => $uuid,
					'ImageInfoArray' => $img_info,               
					)
				);
		//将创建的元素$msg_content_elem, 加入array $msg_content
		array_push($msg_content, $msg_content_elem);
		
        $ret = $this->openim_batch_sendmsg2($account_list, $msg_content);
		return $ret;
	}

	public function openim_batch_sendmsg2($account_list, $msg_content)
	{

		#构造新消息 
		$msg = array(
				'To_Account' => $account_list,
				'MsgRandom' => rand(1, 65535),
				'MsgBody' => $msg_content,
				); 
		#将消息序列化为json串
		$req_data = json_encode($msg);

		$ret = $this->api("openim", "batchsendmsg", $this->identifier, $this->usersig, $req_data);
        $ret = json_decode($ret, true);
		return $ret;
	}

    public function account_import($identifier, $nick, $face_url)
    {

        #构造新消息 
        $msg = array(
            'Identifier' => $identifier,
            'Nick' => $nick,
            'FaceUrl' => $face_url,
        );
        #将消息序列化为json串
        $req_data = json_encode($msg);

        $ret = $this->api("im_open_login_svc", "account_import", $this->identifier, $this->usersig, $req_data);
        $ret = json_decode($ret, true);
        return $ret;
    }

    public function register_account($identifier, $identifierType, $password)
    {

        #构造新消息 
        $msg = array(
            'Identifier' => $identifier,
            'IdentifierType' => $identifierType,
            'Password' => $password,
        );
        #将消息序列化为json串
        $req_data = json_encode($msg);

        $ret = $this->api("registration_service", "register_account_v1", $this->identifier, $this->usersig, $req_data);
        $ret = json_decode($ret, true);
        return $ret;
    }
                
	public function profile_portrait_get($account_id)
	{

		#构造高级接口所需参数
		$account_list = array();
		array_push($account_list, $account_id);
		$tag_list = array(
				"Tag_Profile_IM_Nick",    
				"Tag_Profile_IM_AllowType"
				);  

		$ret = $this->profile_portrait_get2($account_list, $tag_list);
		return $ret;
	}

	public function profile_portrait_get2($account_list, $tag_list)
	{
	
		#构造高级接口所需参数
		$msg = array(
				'From_Account' => $this->identifier,
				'To_Account' => $account_list,
				'TagList' => $tag_list,
				'LastStandardSequence' => 0
				);  
		#将消息序列化为json串
		$req_data = json_encode($msg);
	
		$ret = $this->api("profile", "portrait_get", $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;
	}

	public function profile_portrait_set($account_id, $new_name)
	{

		#构造高级接口所需参数
		$profile_list = array();
		$profile_nick = array(
				"Tag" => "Tag_Profile_IM_Nick",
				"Value" => $new_name 
				);  
		//加好友验证方式
		$profile_allow = array(
				"Tag" => "Tag_Profile_IM_AllowType",
				"Value" => "NeedPermission"
				);  
		array_push($profile_list, $profile_nick);
		//array_push($profile_list, $profile_allow);

		$ret = $this->profile_portrait_set2($account_id, $profile_list);
		return $ret;
	}

	public function profile_portrait_set2($account_id, $profile_list)
	{

		#构造新消息
		$msg = array(
				'From_Account' => $account_id,
				'ProfileItem' => $profile_list
				);
		#将消息序列化为json串
		$req_data = json_encode($msg);
	
		$ret = $this->api("profile", "portrait_set", $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;
	}

	public function sns_friend_import($account_id, $receiver)
	{

		#构造新消息
		$msg = array(
				'From_Account' => $account_id,
				'AddFriendItem' => array()
				);
		$receiver_arr = array(
			'To_Account' => $receiver,
			'Remark' => "",
			'AddSource' => "AddSource_Type_Unknow",
			'AddWording' => "" 
		);
		array_push($msg['AddFriendItem'], $receiver_arr);
		#将消息序列化为json串
		$req_data = json_encode($msg);

		$ret = $this->api("sns", "friend_import", $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;
	}
	

	public function sns_friend_delete($account_id, $frd_id)
	{

		#构造新消息
		$frd_list = array();
		//要添加的好友用户
		array_push($frd_list, $frd_id);

		$msg = array(
				'From_Account' => $account_id,
				'To_Account' => $frd_list,
				'DeleteType' => "Delete_Type_Both"
				);
		#将消息序列化为json串
		$req_data = json_encode($msg);
	
		$ret = $this->api("sns", "friend_delete", $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;
	}

	public function sns_friend_delete_all($account_id)
	{

		#构造新消息
		$msg = array(
				'From_Account' => $account_id,
				);
		#将消息序列化为json串
		$req_data = json_encode($msg);
	
		$ret = $this->api("sns", "friend_delete_all", $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;
	}

	public function sns_friend_check($account_id, $to_account)
	{

		#构造高级接口所需参数
		$to_account_list = array();
		//要添加的好友用户
		array_push($to_account_list, $to_account);

		$msg = array(
				'From_Account' => $account_id,
				'To_Account' => $to_account_list,
				);
	
		$ret = $this->sns_friend_check2($account_id, $to_account_list, "CheckResult_Type_Both");
		return $ret;
	}
	
	public function sns_friend_check2($account_id, $to_account_list, $check_type)
	{

		#构造新消息
		$msg = array(
				'From_Account' => $account_id,
				'To_Account' => $to_account_list,
				'CheckType' => $check_type
				);
		#将消息序列化为json串
		$req_data = json_encode($msg);
	
		$ret = $this->api("sns", "friend_check", $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;
	}

	function sns_friend_get_all($account_id)
	{

		#构造高级接口所需参数
		$tag_list = array(
				"Tag_Profile_IM_Nick",
				"Tag_SNS_IM_Remark"
				);
	
		$ret = $this->sns_friend_get_all2($account_id, $tag_list);
		return $ret;
	}

	function sns_friend_get_all2($account_id, $tag_list)
	{

		#构造新消息
		$msg = array(
				'From_Account' => $account_id,
				'TimeStamp' => 0,
				'TagList' => $tag_list,
				'LastStandardSequence' => 1,
				);
		#将消息序列化为json串
		$req_data = json_encode($msg);
	
		$ret = $this->api("sns", "friend_get_all", $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;
	}

	function sns_friend_get_list($account_id, $frd_id)
	{

		#构造高级接口所需参数
		$frd_list = array();
		array_push($frd_list, $frd_id);
		$tag_list = array(
				"Tag_Profile_IM_Nick",
				"Tag_SNS_IM_Remark"
				);
	
		$ret = $this->sns_friend_get_list2($account_id, $frd_list, $tag_list);
		return $ret;
	}

	function sns_friend_get_list2($account_id, $frd_list, $tag_list)
	{

		#构造新消息
		$msg = array(
				'From_Account' => $account_id,
				'To_Account' => $frd_list,
				'TagList' => $tag_list,
				);
		#将消息序列化为json串
		$req_data = json_encode($msg);
	
		$ret = $this->api("sns", "friend_get_list", $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;
	}

	function group_get_appid_group_list()
	{

		#构造高级接口所需参数
		$ret = $this->group_get_appid_group_list2(50, null, null);
		return $ret;
	}
	
	function group_get_appid_group_list2($limit, $offset, $group_type)
	{

		#构造新消息
		$msg = array(
				'Limit' => $limit,
				'Offset' => $offset,
				'GroupType' => $group_type
				);  
		#将消息序列化为json串
		$req_data = json_encode($msg);
	
		$ret = $this->api("group_open_http_svc", "get_appid_group_list", $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;
	}

    //创建全员广播大群
    function full_group_create($group_id,$aes_key){
        #构造新消息
		$Introduction = '';
		if($aes_key!=''){
			$Introduction = $aes_key;
		}
        $msg = array(
            'Owner_Account' => $this->identifier,
            'Type' => 'BChatRoom',
            'GroupId' => $group_id,
            'Name' => 'FullGroup',
            'Introduction' => $Introduction,
        );
        #将消息序列化为json串
        $req_data = json_encode($msg);

        $ret = $this->api("group_open_http_svc", "create_group", $this->identifier, $this->usersig, $req_data);
        $ret = json_decode($ret, true);
        return $ret;
    }

	function group_create_group($group_type, $group_name, $owner_id,$group_id=null)
	{

		#构造高级接口所需参数
		$info_set = array(
				'group_id' => $group_id,
				'introduction' => null,
				'notification' => null,
				'face_url' => null, 
				'max_member_num' => 500,
				);
		$mem_list = array();
	
		$ret = $this->group_create_group2($group_type, $group_name, $owner_id, $info_set, $mem_list);
		return $ret;
	}

	function group_create_group2($group_type, $group_name, $owner_id, $info_set, $mem_list)
	{

		#构造新消息
		$msg = array(
				'Type' => $group_type,
				'Name' => $group_name,
				'Owner_Account' => $owner_id,
				'GroupId' => $info_set['group_id'], 
				'Introduction' => $info_set['introduction'],
				'Notification' => $info_set['notification'],
				'FaceUrl' => $info_set['face_url'],
				'MaxMemberCount' => $info_set['max_member_num'],
			//	'ApplyJoinOption' => $info_set['apply_join'],
				'MemberList' => $mem_list
				);  
		#将消息序列化为json串
		$req_data = json_encode($msg);
	
		$ret = $this->api("group_open_http_svc", "create_group", $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;
	}

    function group_change_group_owner($group_id, $new_owner)
    {    

        #构造新消息
        $msg = array(
            'GroupId' => $group_id,
            'NewOwner_Account' => $new_owner
        );   
        #将消息序列化为json串
        $req_data = json_encode($msg);

        $ret = $this->api("group_open_http_svc", "change_group_owner", $this->identifier, $this->usersig, $req_data);
        $ret = json_decode($ret, true);
        return $ret;
    }                                                                                                                        
	function group_get_group_info($group_id)
	{
		
		#构造高级接口所需参数
		$group_list = array();
		array_push($group_list, $group_id);

		 $base_info_filter = array(
				 "Type",               //群类型(包括Public(公开群), Private(私密群), ChatRoom(聊天室))
				 "Name",               //群名称
				 "Introduction",       //群简介
				 "Notification",       //群公告
				 "FaceUrl",            //群头像url地址
				 "CreateTime",         //群组创建时间
				 "Owner_Account",      //群主id
				 "LastInfoTime",       //最后一次系统通知时间
				 "LastMsgTime",        //最后一次消息发送时间
				 "MemberNum",          //群组当前成员数目
				 "MaxMemberNum",       //群组内最大成员数目
				 "ApplyJoinOption"     //加群处理方式(比如FreeAccess 自由加入)
				 );
		 $member_info_filter = array(
				 "Account",         // 成员ID     
				 "Role",            // 成员身份
				 "JoinTime",        // 成员加入时间
				 "LastSendMsgTime", // 该成员最后一次发送消息时间
				 "ShutUpUntil"      // 该成员被禁言直到某时间
				 );
		 $app_define_filter = array(
				 "GroupTestData1",  //自定义数据
				 );
	
		$ret = $this->group_get_group_info2($group_list, $base_info_filter, $member_info_filter, $app_define_filter);
		return $ret;
	}

	function group_get_group_info2($group_list, $base_info_filter, $member_info_filter, $app_define_filter)
	{

		#构造新消息
		$filter = new Filter();
		$filter->GroupBaseInfoFilter = $base_info_filter;
		$filter->MemberInfoFilter = $member_info_filter;
		$filter->AppDefinedDataFilter_Group = $app_define_filter;
		$msg = array(
				'GroupIdList' => $group_list,
				'ResponseFilter' => $filter
				);  
		#将消息序列化为json串
		$req_data = json_encode($msg);
	
		$ret = $this->api("group_open_http_svc", "get_group_info", $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;
	}

	function group_get_group_member_info($group_id, $limit, $offset)
	{

		#构造新消息
		$msg = array(
				"GroupId" => $group_id,  
				"Limit" => $limit,   
				"Offset" => $offset 
				)
			;  
		#将消息序列化为json串
		$req_data = json_encode($msg);
	
		$ret = $this->api("group_open_http_svc", "get_group_member_info", $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;
	}
	
	function group_modify_group_base_info($group_id, $group_name)
	{
	
		#构造高级接口所需参数
		$info_set = array(
				'introduction' => null,
				'notification' => null,
				'face_url' => null,
				'max_member_num' => null,
			//	'apply_join' => "NeedPermission"
				);
		$app_define_list = array();
		
		$ret = $this->group_modify_group_base_info2($group_id, $group_name, $info_set, $app_define_list);
		return $ret;
	}
	
	function group_modify_group_base_info2($group_id, $group_name, $info_set, $app_define_list)
	{
		
		#构造新消息
		$msg = array(
				"GroupId" => $group_id,  
				"Name" => $group_name, 
				"Introduction" => $info_set['introduction'],  
				"Notification" => $info_set['notification'],   
				"FaceUrl" => $info_set['face_url'],				
				"MaxMemberNum" => $info_set['max_member_num'],  
			//	"ApplyJoinOption" => $info_set['apply_join'],  		
				"AppDefinedData" => $app_define_list
				);
		#将消息序列化为json串
		$req_data = json_encode($msg);
	
		$ret = $this->api("group_open_http_svc", "modify_group_base_info", $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;

	}
	function group_add_group_member($group_id, $member_id, $silence)
	{
		
		#构造新消息
		$mem_list = array();
		$mem_elem = array(
				"Member_Account" => $member_id
				);
		array_push($mem_list, $mem_elem);
		$msg = array(
				"GroupId" => $group_id,  
				"MemberList" => $mem_list,
				"Silence" => $silence
				);
		#将消息序列化为json串
		$req_data = json_encode($msg);

		$ret = $this->api("group_open_http_svc", "add_group_member", $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;
	}
	
	function group_add_group_member2($group_id, $mem_list, $silence)
	{
	
	#构造新消息
	$msg = array(
	"GroupId" => $group_id,
				"MemberList" => $mem_list,
				"Silence" => $silence
	);
		#将消息序列化为json串
			$req_data = json_encode($msg);
	
			$ret = $this->api("group_open_http_svc", "add_group_member", $this->identifier, $this->usersig, $req_data);
			$ret = json_decode($ret, true);
			return $ret;
	}
	
	function group_delete_group_member($group_id, $member_id, $silence)
	{
	
		#构造新消息
		$mem_list = array();
		array_push($mem_list, $member_id);
		$msg = array(
				"GroupId" => $group_id,  
				"MemberToDel_Account" => $mem_list,
				"Silence" => $silence
				);
		#将消息序列化为json串
		$req_data = json_encode($msg);
	
		$ret = $this->api("group_open_http_svc", "delete_group_member", $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;
	}

	function group_modify_group_member_info($group_id, $account_id, $role)
	{
	
		#构造高级接口所需参数
		$ret = $this->group_modify_group_member_info2($group_id, $account_id, $role, "AcceptAndNotify", 0);
		return $ret;
	}

	function group_modify_group_member_info2($group_id, $account_id, $role, $msg_flag, $shutup_time)
	{
		
		#构造新消息
		$msg = array(
				"GroupId" => $group_id,  
				"Member_Account" => $account_id,
				"Role" => $role
				)
			;  
		#将消息序列化为json串
		$req_data = json_encode($msg);
	
		$ret = $this->api("group_open_http_svc", "modify_group_member_info", $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;
	}

	function group_destroy_group($group_id)
	{
		
		#构造新消息
		$msg = array(
				"GroupId" => $group_id,  
				)
			;  
		#将消息序列化为json串
		$req_data = json_encode($msg);
	
		$ret = $this->api("group_open_http_svc", "destroy_group", $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;
	}

	function group_get_joined_group_list($account_id)
	{
	
		#构造高级接口所需参数
		$base_info_filter = array(
				"Type",               //群类型(包括Public(公开群), Private(私密群), ChatRoom(聊天室))
				"Name",               //群名称
				"Introduction",       //群简介
				"Notification",       //群公告
				"FaceUrl",            //群头像url地址
				"CreateTime",         //群组创建时间
				"Owner_Account",      //群主id
				"LastInfoTime",       //最后一次系统通知时间
				"LastMsgTime",        //最后一次消息发送时间
				"MemberNum",          //群组当前成员数目
				"MaxMemberNum",       //群组内最大成员数目
				"ApplyJoinOption"     //申请加群处理方式(比如FreeAccess 自由加入, NeedPermission 需要同意)
				);


		$self_info_filter = array( 
				"Role",            //群内身份(Amin/Member)
				"JoinTime",        //入群时间
				"MsgFlag",         //消息屏蔽类型
				"UnreadMsgNum"     //未读消息数量
				);

		$ret = $this->group_get_joined_group_list2($account_id, null, $base_info_filter, $self_info_filter);
		return $ret;
	}
	
	function group_get_joined_group_list2($account_id, $group_type, $base_info_filter, $self_info_filter)
	{
	
		#构造新消息
		$filter = new Filter();
		$filter->GroupBaseInfoFilter = $base_info_filter;
		$filter->SelfInfoFilter = $self_info_filter;
		$msg = array(
				"Member_Account" => $account_id, 
				"ResponseFilter" => $filter
				);  
		#将消息序列化为json串
		$req_data = json_encode($msg);

		$ret = $this->api("group_open_http_svc", "get_joined_group_list", $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;
	}
	
	function group_get_role_in_group($group_id, $member_id)
	{
		
		#构造新消息
		$mem_list = array();
		array_push($mem_list, $member_id);
		$msg = array(
				"GroupId" => $group_id,  
				"User_Account" => $mem_list,
				)
			;  
		#将消息序列化为json串
		$req_data = json_encode($msg);

		$ret = $this->api("group_open_http_svc", "get_role_in_group", $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;
	}
	
	function group_forbid_send_msg($group_id, $member_id, $second)
	{
		
		#构造新消息
		$mem_list = array();
		array_push($mem_list, $member_id);
		$msg = array(
				"GroupId" => $group_id,  
				"Members_Account" => $mem_list,
				"ShutUpTime" => $second
				);

		#将消息序列化为json串
		$req_data = json_encode($msg);

		$ret = $this->api("group_open_http_svc", "forbid_send_msg", $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;
	}
	
	//获取群组被禁言用户列表
	function get_group_shutted_uin($group_id)
	{	
		#构造新消息
		$msg = array(
				"GroupId" => $group_id,
				);
		
				#将消息序列化为json串
		$req_data = json_encode($msg);
		
		$ret = $this->api("group_open_http_svc", "get_group_shutted_uin", $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;
	}
	
	
	
	function group_send_group_msg($account_id, $group_id, $text_content)
	{

		#构造高级接口所需参数
		$msg_content = array();
		//创建array 所需元素
		$msg_content_elem = array(
				'MsgType' => 'TIMTextElem',       //文本类型
				'MsgContent' => array(
					'Text' => $text_content,                //hello 为文本信息
					)
				);
		array_push($msg_content, $msg_content_elem);
		$ret = $this->group_send_group_msg2($account_id, $group_id, $msg_content);
		return $ret;
	}

	function group_send_group_msg_pic($account_id, $group_id, $pic_path)
	{
		
		#构造高级接口所需参数
		//上传图片并获取url
		$busi_type = 1; //表示群消息
		$ret =  $this->openpic_pic_upload($account_id, $group_id, $pic_path, $busi_type);
		$tmp = $ret["URL_INFO"];
		
		$uuid = $ret["File_UUID"];
		$pic_url = $tmp[0]["DownUrl"];
		
		$img_info = array();
		$img_tmp = $ret["URL_INFO"][0];
		if($img_tmp["PIC_TYPE"] == 4){
			$img_tmp["PIC_TYPE"] = 3;
		}
		$img_info_elem1 = array(
				"URL" => $img_tmp["DownUrl"],
				"Height" => $img_tmp["PIC_Height"],
				"Size" => $img_tmp["PIC_Size"],
				"Type" => $img_tmp["PIC_TYPE"],
				"Width" => $img_tmp["PIC_Width"]
				);
		
		$img_tmp = $ret["URL_INFO"][1];
		if($img_tmp["PIC_TYPE"] == 4){
			$img_tmp["PIC_TYPE"] = 3;
		}
		$img_info_elem2 = array(
				"URL" => $img_tmp["DownUrl"],
				"Height" => $img_tmp["PIC_Height"],
				"Size" => $img_tmp["PIC_Size"],
				"Type" => $img_tmp["PIC_TYPE"],
				"Width" => $img_tmp["PIC_Width"]
				);
		
		$img_tmp = $ret["URL_INFO"][2];
		if($img_tmp["PIC_TYPE"] == 4){
			$img_tmp["PIC_TYPE"] = 3;
		}
		$img_info_elem3 = array(
				"URL" => $img_tmp["DownUrl"],
				"Height" => $img_tmp["PIC_Height"],
				"Size" => $img_tmp["PIC_Size"],
				"Type" => $img_tmp["PIC_TYPE"],
				"Width" => $img_tmp["PIC_Width"]
				);
		
		array_push($img_info, $img_info_elem1);
		array_push($img_info, $img_info_elem2);
		array_push($img_info, $img_info_elem3);
		$msg_content = array();
		//创建array 所需元素
		$msg_content_elem = array(
				'MsgType' => 'TIMImageElem',       //文本类型
				'MsgContent' => array(
					'UUID' => $uuid,
					'ImageInfoArray' => $img_info,               
					)
				);
		//将创建的元素$msg_content_elem, 加入array $msg_content
		array_push($msg_content, $msg_content_elem);
		
		$ret = $this->group_send_group_msg2($account_id, $group_id, $msg_content);
		return $ret;
	}

	function group_send_group_msg2($account_id, $group_id, $msg_content)
	{

		//MsgPriority 可以指定4种优先级，从高到低依次为High，Normal，Low，Lowest，区分大小写。
		$account_id = (string)$account_id;
        if($account_id==''){
            $account_id = $this->identifier;
        }
		#构造新消息 
		$msg = array(
				"GroupId" => $group_id,
				"From_Account" => $account_id,
				"MsgPriority" => "High",
				"Random" => rand(1, 65535),
				"MsgBody" => $msg_content
				);  
				
		#将消息序列化为json串
		$req_data = json_encode($msg);

		$ret = $this->api("group_open_http_svc", "send_group_msg", $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;
	}
	
	function group_send_group_system_notification($group_id, $text_content, $receiver_id)
	{
		
		#构造高级接口所需参数
		$receiver_list = array();
		if($receiver_id != null){
			array_push($receiver_list, $receiver_id);
		}
		$ret = $this->group_send_group_system_notification2($group_id, $text_content, $receiver_list);
		return $ret;
	}
    
    function group_send_group_system_notification2($group_id, $content, $receiver_list)
	{

		#构造新消息 
		$msg = array(
				"GroupId" => $group_id,
				"ToMembers_Account" => $receiver_list,
				"Content" => $content
				);  
		#将消息序列化为json串
		$req_data = json_encode($msg);

		$ret = $this->api("group_open_http_svc", "send_group_system_notification", $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;
	}

	function comm_rest($server, $command, $req_body)
	{   

		#将消息序列化为json串
		$req_data = json_encode($req_body);

		$ret = $this->api($server, $command, $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;
    }

    function group_import_group_member($group_id, $member_id, $role) 
    {

        #构造高级接口所需参数
        $member_list = array();
        $member_elem = array(
            "Member_Account" => $member_id,
            "Role" => $role
        );
        array_push($member_list, $member_elem);
		$ret = $this->group_import_group_member2($group_id, $member_list);
		return $ret;
    }  

    function group_import_group_member2($group_id, $member_list)
    {

		#构造新消息 
		$msg = array(
				"GroupId" => $group_id,
				"MemberList" => $member_list,
				);  
		#将消息序列化为json串
		$req_data = json_encode($msg);

		$ret = $this->api("group_open_http_svc", "import_group_member", $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;
    } 

    function group_import_group_msg($group_id, $from_account, $text)
    {
        
        #构造高级接口所需参数

        //构造MsgBody
        $msg_content = array(
            "Text" => $text
        );
        $msg_body_elem = array(
            "MsgType" => "TIMTextElem",
            "MsgContent" => $msg_content,
        );
        $msg_body_list = array();
        array_push($msg_body_list, $msg_body_elem);

        //构造MsgList的一个元素
        $msg_list_elem = array(
            "From_Account" => $from_account,
            "SendTime" => time(),
            "Random" => rand(1, 65535),
            "MsgBody" => $msg_body_list
        );

        //构造MsgList
        $msg_list = array();
        array_push($msg_list, $msg_list_elem);

		$ret = $this->group_import_group_msg2($group_id, $msg_list);
		return $ret;
    }

    function group_import_group_msg2($group_id, $msg_list)
    {

		#构造新消息 
		$msg = array(
				"GroupId" => $group_id,
				"MsgList" => $msg_list,
            );
        var_dump($msg);  
		#将消息序列化为json串
		$req_data = json_encode($msg);

		$ret = $this->api("group_open_http_svc", "import_group_msg", $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;
    }
    function group_set_unread_msg_num($group_id, $member_account, $unread_msg_num)
    {

		#构造新消息 
		$msg = array(
				"GroupId" => $group_id,
                "Member_Account" => $member_account,
                "UnreadMsgNum" => (int)$unread_msg_num
				);  
		#将消息序列化为json串
		$req_data = json_encode($msg);

		$ret = $this->api("group_open_http_svc", "set_unread_msg_num", $this->identifier, $this->usersig, $req_data);
		$ret = json_decode($ret, true);
		return $ret;
    }
    
    /**
     * 添加黑名单
     */
    public function sns_black_import($account_id, $receiver)
    {
    
	    #构造新消息
	    $msg = array(
	    		'From_Account' => $account_id,
	    		'To_Account' => array()
	    );
	    //$receiver_arr = array();
	    $msg['To_Account'][] = $receiver;
	    
	    //array_push($msg['To_Account'], $receiver_arr);
	    #将消息序列化为json串
	    $req_data = json_encode($msg);
	    
	    $ret = $this->api("sns", "black_list_add", $this->identifier, $this->usersig, $req_data);
	    $ret = json_decode($ret, true);
	    return $ret;
    }
    
    /**
     * 删除黑名单
     * @param unknown_type $account_id
     * @param unknown_type $blk_id
     * @return mixed
     */
    public function sns_black_delete($account_id, $blk_id)
    {
    
   		 #构造新消息
	    $msg = array(
	    		'From_Account' => $account_id,
	    		'To_Account' => array()
	    );
	   	//$receiver_arr = array();
	    //$receiver_arr[] = $blk_id;
	    $msg['To_Account'][] = $blk_id;
	    //array_push($msg['To_Account'], $receiver_arr);
    	#将消息序列化为json串
		$req_data = json_encode($msg);
    
    	$ret = $this->api("sns", "black_list_delete", $this->identifier, $this->usersig, $req_data);
    	$ret = json_decode($ret, true);
    	return $ret;
    }

    //批量发单聊消息
    public function openim_batchsendmsg($account_id,$msg_content,$to){
        #构造新消息
        $msg = array(
            "From_Account" => $account_id,
            "MsgRandom" => rand(1, 65535),       //消息随机数
            "MsgBody" => $msg_content
        );
        #将消息序列化为json串
        if($to){
            $msg['To_Account'] = $to;//目标账户列表
        }
        $req_data = json_encode($msg);

        $ret = $this->api("openim", "batchsendmsg", $this->identifier, $this->usersig, $req_data);
        $ret = json_decode($ret, true);
        return $ret;
    }
    
    /**
     * 
     * @param string $account_id 消息推送方账号。
     * @param MsgBody $msg_content 消息内容，具体格式请参考MsgBody消息内容说明。（一条消息可包括多种消息元素，所以MsgBody为Array类型）
     * @param int $msg_life_time 消息离线存储时间，单位秒，最多7 天。默认为0, 表示不离线存储
     * @return mixed
     */
    public function openim_push($account_id, $msg_content,$condition,$msg_life_time = 604800)
    {
    	$account_id = (string)$account_id;
	    #构造新消息
	    $msg = array(
	    		'From_Account' => $account_id,
	    		'MsgRandom' => rand(1, 65535),
	    		"MsgLifeTime"=> $msg_life_time,
	    		'MsgBody' => $msg_content,
	    		);
	    		#将消息序列化为json串
	    $req_data = json_encode($msg);
	    
	    $ret = $this->api("openim", "im_push", $this->identifier, $this->usersig, $req_data);
	    $ret = json_decode($ret, true);
	    return $ret;
    }
    
    /**
     * 查询APP自定义脏字
     * @return 
     * {
	    "ActionStatus": "OK", 
	    "ErrorInfo": "", 
	    "ErrorCode": 0,
	    "DirtyWordsList": [
	        "回收金币",
	        "代刷人气",
	        "抽奖"
	    ]
		}
     */
    public function openim_dirty_words_get()
    {
    	#构造新消息
    	$msg = array();
    	#将消息序列化为json串
    	$req_data = json_encode($msg);
    	
    	$ret = $this->api("openim_dirty_words", "get", $this->identifier, $this->usersig, $req_data);
    	$ret = json_decode($ret, true);
    	return $ret;
    }
    

    /**
     * 添加APP自定义脏字
     * @param unknown_type $dirty_words_list
     * @return mixed
     */
    public function openim_dirty_words_add($dirty_words_list = array())
    {
    	#构造新消息
    	$msg = array(
    		'DirtyWordsList'=>$dirty_words_list,
    	);
    	#将消息序列化为json串
    	$req_data = json_encode($msg);
    	 
    	$ret = $this->api("openim_dirty_words", "add", $this->identifier, $this->usersig, $req_data);
    	$ret = json_decode($ret, true);
    	return $ret;
    }
    
    /**
     * 删除APP自定义脏字
     * @param unknown_type $dirty_words_list
     * @return mixed
     */
    public function openim_dirty_words_delete($dirty_words_list = array())
    {
    #构造新消息
    	$msg = array(
    	'DirtyWordsList'=>$dirty_words_list,
    	);
    	#将消息序列化为json串
    	$req_data = json_encode($msg);
    
    	$ret = $this->api("openim_dirty_words", "delete", $this->identifier, $this->usersig, $req_data);
    	$ret = json_decode($ret, true);
    	return $ret;
    }    
};

//辅助过滤器类
class Filter{};

/** Json数据格式化方法
 * @param array $data 数组数据
 * @param string $indent 缩进字符，默认4个空格
 * @return sting json格式字符串
 */
function json_format($data, $indent=null)
{

	// 对数组中每个元素递归进行urlencode操作，保护中文字符
	array_walk_recursive($data, 'json_format_protect');

	// json encode
	$data = json_encode($data);

	// 将urlencode的内容进行urldecode
	$data = urldecode($data);

	// 缩进处理
	$ret = '';
	$pos = 0;
	$length = strlen($data);
	$indent = isset($indent)? $indent : '    ';
	$newline = "\n";
	$prevchar = '';
	$outofquotes = true;
	for($i=0; $i<=$length; $i++){
		$char = substr($data, $i, 1);
		if($char=='"' && $prevchar!='\\')
		{
			$outofquotes = !$outofquotes;
		}elseif(($char=='}' || $char==']') && $outofquotes)
		{
			$ret .= $newline;
			$pos --;
			for($j=0; $j<$pos; $j++){
				$ret .= $indent;
			}
		}
		$ret .= $char;
		if(($char==',' || $char=='{' || $char=='[') && $outofquotes)
		{
			$ret .= $newline;
			if($char=='{' || $char=='['){
				$pos ++;
			}

			for($j=0; $j<$pos; $j++){
				$ret .= $indent;
			}
		}
		$prevchar = $char;
	}
	return $ret;
}

/**
 * json_formart辅助函数
 * @param String $val 数组元素
 */
function json_format_protect(&$val)
{
	if($val!==true && $val!==false && $val!==null)
	{
		$val = urlencode($val);
	}
}

/**
 * 判断操作系统位数
 */
function is_64bit() {
	$int = "9223372036854775807";
	$int = intval($int);
	if ($int == 9223372036854775807) {
		/* 64bit */
		return true;
	}
	elseif ($int == 2147483647) {
		/* 32bit */
		return false;
	}
	else {
		/* error */
		return "error";
	}
}