<?php
/**
 * 统一用户中心接口
 * 
 * @version0.1
 * @author XMG <guangyong.ma@yoho.cn> 2014.2.17 10:20
 * @name Api_Uuc
 */
class Api_Uuc
{

    /**
     * 统一用户中心域名
     * @var string
     */
    const UUC_DOMAIN = 'https://passport.yoho.cn';
    
    /**
     * 账号类型 - 邮箱
     * @var int
     */
    const AUTH_TYPE_EMAIL =  1  ;
    
    /**
     * 账号类型 - 手机
     * @var int
     */
    const AUTH_TYPE_MOBILE =  2  ;
    
    /**
     * 账号类型 - 微博
     * @var int
     */
    const AUTH_TYPE_WEIBO =  3  ;
    
    /**
     * 账号类型 - QQ
     * @var int
     */
    const AUTH_TYPE_QQ =  4  ;
    
    /**
     * 账号类型 - 支付宝
     * @var int
     */
    const AUTH_TYPE_ALIPAY =  5  ;
    
    /**
     * 账号类型 - 人人
     * @var int
     */
    const AUTH_TYPE_RENREN =  6  ;
    
    /**
     * 账号类型 - 豆瓣
     * @var int
     */
    const AUTH_TYPE_DOUBAN =  7  ;
    
    /**
     * 账号类型 - FACEBOOK
     * @var int
     */
    const AUTH_TYPE_FACEBOOK =  8  ;
    
    /**
     * 账号类型 - INSTAGRAM
     * @var int
     */
    const AUTH_TYPE_INSTAGRAM =  9  ;

    /**
     * UUC相关账号配置
     * @var array
     */
    protected static $_config = array(
        'APP_KEY' => '', //应用KEY
        'APP_SECRET' => '', //应用密钥
    );

    /*     * ****************** 账户操作 --开始 ***************** */

    /**
     * 注册至UUC -- 后端请求
     * 
     * @param string $account 邮箱/手机号
     * @param string $password 明文密码
     * @param string $fields 要返回的用户信息字段<默认为空,返回所有的订阅用户信息>
     * @return array
     */
    public static function register($account, $password, $fields = '')
    {
        return self::_send('register/back', array('account' => $account, 'password' => $password, 'fields' => $fields));
    }

    /**
     * 登录至UUC -- 后端请求
     * @param string $account 邮箱/手机号
     * @param string $password 明文密码
     */
    public static function login($account, $password)
    {
        return self::_send('login/back', array('account' => $account, 'password' => $password));
    }

    /**
     * 获取UUC当前的登录用户链接, (可使用JS，使用JSONP方式获取)
     * @param string $account 邮箱/手机号
     * @param string $password 明文密码
     */
    public static function getCurrentLoginUidLink()
    {
        $data = self::buildData(array('s' => uniqid()));
        $link = self::UUC_DOMAIN . '/activation/state?' . http_build_query($data) . '&callback=?';
        return $link;
    }
    
    /**
     * 根据SessionKey获取用户ID
     * @param string $sid 邮箱/手机号
     * @return array  data: {uid:用户ID}   uid为0表示没有该用户    
     */
    public static function getUidBySid($sid)
    {
        return self::_send('login/getUidBySid', array('sid' => $sid));
    }

    /**
     * 第三方登录 
     * 
     * @param integer $type  第三方类型：3:weibo，4:qq，5:支付宝，6:人人，7:豆瓣，8:facebook，9:instagram
     * @param string $auth  唯一标识(第三方用户)
     * @param string $token  访问令牌
     * @param string $refresh_token  刷新令牌
     * @param string $expires_in  使用周期(访问令牌)
     * @param string $nickname 用户的昵称
     * @param string $headpic 用户的头像
     * @param string $alipay_email  支付宝用户的邮箱或手机号，用于合并有货的老数据 (当$type=5时, 必须传递此参数)
     * @param string $fields  需要返回的信息，可不传，默认为订阅的用户信息
     * @return json
     */
    public static function partnerLogin($type, $auth, $token, $refresh_token, $expires_in, $nickname, $headpic = '', $alipay_email = '', $fields = '')
    {
        return self::_send('associate/index', array(
            'type' => $type, 'auth' => $auth, 'token' => $token, 'refresh_token' => $refresh_token, 'expires_in' => $expires_in, 
            'fields' => $fields, 'nick' => $nickname, 'headpic' => $headpic, 'alipay_email' => $alipay_email,
        ));
    }

    /**
     * 修改密码 -- 后端请求
     * @param string $uid	UUC对应的UID
     * @param string $password 明文密码
     */
    public static function changePassword($uid, $password)
    {
        return self::_send('userinfo/changepwd', array('uid' => $uid, 'password' => $password));
    }

    /**
     * 回调登录方式  -- 前端请求
     * 用户提交登录请求到各自的应用后,应用使用该方法做二次跳转至UUC，uuc进行相关校验并返回数据到指定的URL
     *
     * @param string $account  账号
     * @param string $password 密码
     * @param string $callback 回调地址
     * @param string $fields   返回的字段信息
     * @param string $method   回调类型<POST|GET>,UUC校验后,数据以指定的类型,提交到回调地址
     * @param string
     */
    public static function getLoginForm($account, $password, $callback, $fields = '', $method = 'post')
    {
        $data = self::buildData(array('account' => $account, 'password' => $password, 'callback' => $callback, 'fields' => $fields, 'method' => $method));
        $url = self::UUC_DOMAIN . '/login/callbacklogin';
        return self::_callback($url, $data);
    }

    /**
     * 回调注册方式  -- 前端请求
     * 用户提交登录请求到各自的应用后,应用使用该方法做二次跳转至UUC，uuc进行相关校验并返回数据到指定的URL
     *
     * @param string $account  账号
     * @param string $password 密码
     * @param string $callback 回调地址
     * @param string $fields   返回的字段信息
     * @param string $method   回调类型<POST|GET>,UUC校验后,数据以指定的类型,提交到回调地址
     * @param string
     */
    public static function getRegisterForm($account, $password, $callback, $fields = '', $method = 'post')
    {
        $data = self::buildData(array('account' => $account, 'password' => $password, 'callback' => $callback, 'fields' => $fields, 'method' => $method));
        $url = self::UUC_DOMAIN . '/register/callbackregister';
        return self::_callback($url, $data);
    }

    /**
     * 获取用户所有的口令列表
     * @param int $uid 用户中心ID
     * @return array
     */
    public static function getAllAccount($uid)
    {
        return self::_send('userinfo/getAllAccount', array('uid' => $uid));
    }

    /*     * ****************** 账户操作 --结束 ***************** */



    /*     * ****************** 用户信息操作 --开始 ***************** */

    /**
     * 获取用户信息
     * 
     * @param string $account 邮箱/手机号 	<account与uid必须传递一个,两者都传,以uid为准>
     * @param string $uid UUC对应的UID   	<account与uid必须传递一个,两者都传,以uid为准>
     * @param string $fields 获取的用户信息,默认返回所有订阅的用户资料 
     * @return array  
     */
    public static function getUserinfo($account, $uid = 0, $fields = '')
    {
        if (!$account && !$uid)
        {
            return array('code' => 500001, 'message' => '缺少参数');
        }
        return self::_send('userinfo/getUserinfo', array('uid' => $uid, 'account' => $account, 'fields' => $fields));
    }

    /**
     * 更新用户资料
     * 
     * @param string $account UUC对应的UID
     * @param string $data   要更新用户资料<用户资料详见资料列表>
     * @return array 
     */
    public static function updateUserinfo($uid, array $data)
    {
        if (empty($data))
        {
            return array('code' => 500001, 'message' => '缺少参数');
        }
        $data['uid'] = $uid;
        return self::_send('userinfo/update', $data);
    }

    /**
     * 绑定/更新用户口令
     *
     * @param string $account UUC对应的UID
     * @param string $auth_id   口令名称<邮箱/手机/第三方的唯一ID>
     * @param string $auth_type 口令类型<1:邮箱，2手机，3weibo，4qq，5支付宝，6人人，7豆瓣，8facebook，9instagram>
     * @return array
     */
    public static function setAuth($uid, $auth_id, $auth_type)
    {
        return self::_send('userinfo/setauth', array('uid' => $uid, 'auth' => $auth_id, 'type' => $auth_type));
    }

    /**
     * 取消口令绑定
     *
     * @param string $account UUC对应的UID
     * @param string $auth_id   口令名称<邮箱/手机/第三方的唯一ID>
     * @return array $auth_type 口令类型<1:邮箱，2手机，3weibo，4qq，5支付宝，6人人，7豆瓣，8facebook，9instagram>
     * @return array
     */
    public static function delAuth($uid, $auth_id, $auth_type)
    {
        return self::_send('userinfo/delauth', array('uid' => $uid, 'auth_id' => $auth_id, 'auth_type' => $auth_type));
    }
    
    /**
     * 获取登录账号的相关信息
     * 
     * @param string $auth_id  口令名称<邮箱/手机/第三方的唯一ID>
     * @param integer $auth_type  口令类型<1:邮箱，2手机，3weibo，4qq，5支付宝，6人人，7豆瓣，8facebook，9instagram>
     * @return array
     */
    public static function getAuth($auth_id, $auth_type)
    {
        return self::_send('userinfo/getauth', array('auth_id' => $auth_id, 'auth_type' => $auth_type));
    }

    /*     * ****************** 用户信息操作 --结束 ***************** */

    /*     * ****************** 相关链接操作 --开始 ***************** */

    /**
     * 获取登录/登出状态通知链接
     * 
     * @param string $uid
     * @param int $state 1:登录  2:退出
     * @return string 
     */
    public static function getSyncStatusLink($uid, $state)
    {
        $link = self::UUC_DOMAIN;
        $data = self::buildData(array('uid' => $uid, 'state' => $state));
        $link .= '/activation/index?' . http_build_query($data);
        return $link;
    }

    /**
     * 获取第三方登录地址链接
     * 
     */
    public static function getAssociateLink($type = '')
    {
        $list = array
            (
            'sina' => '新浪Weibo',
            'qq' => 'QQ',
            //'alipay'	=> '支付宝',
            'renren' => '人人网',
            'douban' => '豆瓣网',
            'facebook' => 'FACEBOOK',
            'instagram' => 'INSTAGRAM',
        );
        if ($type)
        {
            if (isset($list[$type]))
            {
                $data = self::buildData(array('t' => $type));
                return self::UUC_DOMAIN . '/Oauth?' . http_build_query($data);
            }
            return '';
        }
        $result = array();
        foreach ($list as $k => $v)
        {
            $data = self::buildData(array('t' => $k));
            $result[$k] = self::UUC_DOMAIN . '/Oauth?' . http_build_query($data);
        }
        return $result;
    }

    /**
     * 发送请求
     * @param string $method 接口名称
     * @param array  $data 发送的数据
     */
    private static function _send($method, $data = array())
    {
        //组装URL信息
        $url =  self::UUC_DOMAIN . '/' . $method;
        $data = self::buildData($data);
        $options = array
            (
            CURLOPT_POST => 1,
            CURLOPT_HEADER => 1,
            CURLOPT_URL => $url,
            CURLOPT_FRESH_CONNECT => 1,
            CURLOPT_RETURNTRANSFER => 1,
            CURLOPT_FORBID_REUSE => 1,
            CURLOPT_POSTFIELDS => http_build_query($data),
           // CURLOPT_HTTPHEADER => array('Expect:'),
            
        );
        $SSL = ( strtolower( substr($url, 0, 8) ) == "https://" ) ? true : false;
        if ($SSL)
        {
            $options[CURLOPT_SSL_VERIFYHOST] = true;
            $options[CURLOPT_SSL_VERIFYPEER] = false; //暂时取消本地证书校验
            $options[CURLOPT_CAINFO] =  dirname(__FILE__) . '/cacert.pem'; //CA根证书  ;
        }
       //echo $url . '?' .http_build_query($data);
        $ch = curl_init();
        curl_setopt_array($ch, $options);
        $result = curl_exec($ch);
        $header_size = curl_getinfo($ch, CURLINFO_HEADER_SIZE);
        $result = substr($result, $header_size);
        curl_close($ch);
        $decode = json_decode($result, true);
        return is_array($decode) ? $decode : $result;
    }

    /**
     * 对传递的数据进行加密处理
     * 
     * @param array $data
     * @param string $key APP_KEY
     * @param string $private_key 密钥
     * @return array
     */
    public static function buildData(array $params, $key = null, $private_key = null)
    {
        //添加密钥 
        $params['private_key'] = ($private_key === null) ? self::$_config['APP_SECRET'] : $private_key;
        $params['key'] = ($key === null) ? self::$_config['APP_KEY'] : $key;
        // 排序
        ksort($params);
        reset($params);
        $str = '';
        foreach ($params as $key => $val)
        {
            $str .= $key . '=' . trim($val) . '&';
        }
        $str = substr($str, 0, -1);
        $params['sign'] = md5($str);
        unset($params['private_key']);
        return $params;
    }

    /**
     * 校验签名是否正确
     * 
     * @param array $params
     * @param string $sign 签名
     * @param string $key APP_KEY
     * @param string $private_key 密钥
     * @return boolean
     */
    public static function checkSign(array $params, $sign, $key = null, $private_key = null)
    {
        $build = self::buildData($params, $key, $private_key);
        return ($build['sign'] == $sign);
    }

    /**
     * 页面回调方法
     * 
     * @param string $callback 地址
     * @param array $data 数据
     * @param string $method 方法(post|get)
     * @return string 
     */
    private static function _callback($callback, $data, $method = 'post')
    {
        $method = strtolower($method);
        $method = ($method == 'get') ? 'get' : 'post';
        if ($method == 'get')
        {
            $data = http_build_query($data);
            if (strstr($callback, '?') !== false)
            {
                $callback .= '&' . $data;
            }
            else
            {
                $callback .= '?' . $data;
            }
            return <<<EOT
<html>
	<head>
		<meta http-equiv="refresh" content="0;URL=$callback" />
	</head>
</html>
EOT;
        }
        else
        {
            //POST提交
            $postString = '';
            foreach ($data as $k => $v)
            {
                $postString .= "\n" . '<input type="hidden" name="' . $k . '" value="' . $v . '">';
            }
            return <<<EOT
<html>
	<head>
		<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
	</head>
	<body onload="document.yohoSubmit.submit();">
		<form method="POST" action="$callback"  name="yohoSubmit" id="yohoSubmit" >
		$postString
		</form>
	</body>
</html>
EOT;
        }
    }

}