1:   2:   3:   4:   5:   6:   7:   8:   9:  10:  11:  12:  13:  14:  15:  16:  17:  18:  19:  20:  21:  22:  23:  24:  25:  26:  27:  28:  29:  30:  31:  32:  33:  34:  35:  36:  37:  38:  39:  40:  41:  42:  43:  44:  45:  46:  47:  48:  49:  50:  51:  52:  53:  54:  55:  56:  57:  58:  59:  60:  61:  62:  63:  64:  65:  66:  67:  68:  69:  70:  71:  72:  73:  74:  75:  76:  77:  78:  79:  80:  81:  82:  83:  84:  85:  86:  87:  88:  89:  90:  91:  92:  93:  94:  95:  96:  97:  98:  99: 100: 101: 102: 103: 104: 105: 106: 107: 108: 109: 110: 111: 112: 113: 114: 115: 116: 117: 118: 119: 120: 121: 122: 123: 124: 125: 126: 127: 128: 129: 130: 131: 132: 133: 134: 135: 136: 137: 138: 139: 140: 141: 142: 143: 144: 145: 146: 147: 148: 149: 150: 151: 152: 153: 154: 155: 156: 157: 158: 159: 160: 161: 162: 163: 164: 165: 166: 167: 168: 169: 170: 171: 172: 173: 174: 175: 176: 177: 178: 179: 180: 181: 182: 

<?php
/**
 * Android 应用消息推送服务
 *
 * <code>
 * <?php
 * $appid=20001;
 * $token='BYfkQcUYULUB';
 * $title='title';
 * $msg='hello wolrd';
 * $acts="[\"2,sina.Apns,sina.Apns.MainActivity\"]";
 * $extra=array(
 *     'handle_by_app'=>'0'
 *  );
 * $adpns = new SaeADPNS();
 * $result = $adpns->push($appid, $token, $title, $msg, $acts, $extra);
 * 
 * if( $result && is_array($result) ){
 *     echo '发送成功！';
 *     var_dump( $result );
 * }
 * else {
 *     echo '发送失败。';
 *     var_dump($apns->errno(), $apns->errmsg());
 * }
 * ?>
 * </code>
 *
 * 错误码参考：
 *  - errno: 0         成功
 *  - errno: -1        信息内容为空
 *  - errno: -2        连接server http请求错误
 *  - errno: -3        server端错误
 *
 * @package sae
 *
 */

class SaeADPNS extends SaeObject
{
    private $_accesskey = "";    
    private $_secretkey = "";
    private $_errno = SAE_Success;
    private $_errmsg = "OK";

    /**
     * @ignore
     */
    const baseurl = "http://push.sae.sina.com.cn:81/android/android.php";

    /**
     * 构造对象
     *
     */
    function __construct() {
        $this->_accesskey = SAE_ACCESSKEY;
        $this->_secretkey = SAE_SECRETKEY;
    }

    /**
     * 推送消息
     * 
     * @param int $appid  SAE分配的应用序号
     * @param string $token 设备令牌
     * @param string $title 消息标题
     * @param string $msg 消息体
     * @param string $acts 跳转行为参数
     *  - ["2,app包名,Activity类名"]：跳转到APP的Activity。例如：["2,com.sina.news,com.sina.news.ui.NewContentActivity"]
     *  - ["4,URL地址"]：跳转到浏览器。例如：["4,http://www.sina.com"]
     *  - ["5,Scheme"]：通过Scheme跳转。例如：["5,sinaweibo://sendweibo"]
     * @param array  $extra 额外的传递信息 
     *  - $extra = array(
     *      'handle_by_app'=>'1'  // "1"，表示消息交由App处理。
     *    )
     * @return bool 成功返回true，失败返回false
     */
    function push($appid, $token, $title, $msg, $acts, $extra=array()) {
        $params = array();
        
        if (is_string($title) === false) {
            $this->_errmsg = 'title must be string';
            $this->_errno = -1;
            return false;
        }
        if (is_string($msg) === false) {
            $this->_errmsg = 'msg must be string';
            $this->_errno = -1;
            return false;
        }
        if (is_array($extra) === false) {
            $this->_errmsg = 'extra must be array';
            $this->_errno = -1;
            return false;
        }
        
        $params['act'] = "push";
        $params['appid'] = intval($appid);
        $params['token'] = trim($token);
        $params['ak'] = $this->_accesskey;
        $params['title'] = trim($title);
        $params['msg'] = trim($msg);
        $params['acts'] = trim($acts);

        if (empty($extra) === false) {
            $extra = json_encode($extra);
            $params['extra'] = $extra;
        }

        $ret = $this->postData($params);
        return $ret;
    }

    /**
     * 取得错误码
     *
     * @return int 
     * @author Elmer Zhang
     */
    public function errno() {
        return $this->_errno;
    }

    /**
     * 取得错误信息
     *
     * @return string 
     * @author Elmer Zhang
     */
    public function errmsg() {
        return $this->_errmsg;
    }

    private function postData($post) {
        $url = self::baseurl;
        $s = curl_init();
        if (is_array($post)) {
            $post = http_build_query($post);
        }
        curl_setopt($s,CURLOPT_URL,$url);
        curl_setopt($s,CURLOPT_HTTP_VERSION,CURL_HTTP_VERSION_1_0);
        curl_setopt($s,CURLOPT_TIMEOUT,5);
        curl_setopt($s,CURLOPT_RETURNTRANSFER,true);
        curl_setopt($s,CURLINFO_HEADER_OUT, true);
        curl_setopt($s,CURLOPT_POST,true);
        curl_setopt($s,CURLOPT_POSTFIELDS,$post); 
        $ret = curl_exec($s);
        $info = curl_getinfo($s);
        curl_close($s);

        if (empty($info['http_code'])) {
            $this->_errno = -2;
            $this->_errmsg = "can not reach push service server";
        } else if ($info['http_code'] != 200) {
            $code = $info['http_code'];
            $this->_errno = -2;
            $this->_errmsg = "httpd code: $code";
        } else {
            if ($info['size_download'] == 0) { // get MailError header
                $this->_errno = -2;
                $this->_errmsg = "apple push service internal error";
            } else {
                $array = json_decode(trim($ret), true);
                if (is_array($array) && is_int($array['code']) && $array['code'] < 0) {
                    $this->_errno = -3;
                    $this->_errmsg = $array['message'];
                    return false;
                } else if (is_array($array) && is_int($array['code'])) {
                    $this->_errno = SAE_Success;
                    $this->_errmsg = 'OK';
                    return $array;
                } else {
                    $this->_errno = -3;
                    $this->errmsg = "service response error";
                    return false;
                }
            }
        }
        return false;
    }
}
?>