|
@@ 163-191 (lines=29) @@
|
| 160 |
|
/** |
| 161 |
|
* 推送消息给单个设备 |
| 162 |
|
*/ |
| 163 |
|
public function PushSingleDevice($deviceToken, $message, $environment = 0) |
| 164 |
|
{ |
| 165 |
|
$ret = array('ret_code' => -1, 'err_msg' => 'message not valid'); |
| 166 |
|
|
| 167 |
|
if (!($message instanceof Message) && !($message instanceof MessageIOS)) return $ret; |
| 168 |
|
if (!$this->ValidateMessageType($message)) { |
| 169 |
|
$ret['err_msg'] = 'message type not fit accessId'; |
| 170 |
|
return $ret; |
| 171 |
|
} |
| 172 |
|
if ($message instanceof MessageIOS) { |
| 173 |
|
if ($environment != XingeApp::IOSENV_DEV && $environment != XingeApp::IOSENV_PROD) { |
| 174 |
|
$ret['err_msg'] = "ios message environment invalid"; |
| 175 |
|
return $ret; |
| 176 |
|
} |
| 177 |
|
} |
| 178 |
|
if (!$message->isValid()) return $ret; |
| 179 |
|
$params = array(); |
| 180 |
|
$params['access_id'] = $this->accessId; |
| 181 |
|
$params['expire_time'] = $message->getExpireTime(); |
| 182 |
|
$params['send_time'] = $message->getSendTime(); |
| 183 |
|
if ($message instanceof Message) $params['multi_pkg'] = $message->getMultiPkg(); |
| 184 |
|
$params['device_token'] = $deviceToken; |
| 185 |
|
$params['message_type'] = $message->getType(); |
| 186 |
|
$params['message'] = $message->toJson(); |
| 187 |
|
$params['timestamp'] = time(); |
| 188 |
|
$params['environment'] = $environment; |
| 189 |
|
|
| 190 |
|
return $this->callRestful(self::RESTAPI_PUSHSINGLEDEVICE, $params); |
| 191 |
|
} |
| 192 |
|
|
| 193 |
|
/** |
| 194 |
|
* 推送消息给单个账户 |
|
@@ 392-424 (lines=33) @@
|
| 389 |
|
/** |
| 390 |
|
* 创建批量推送任务 |
| 391 |
|
*/ |
| 392 |
|
public function CreateMultipush($message, $environment = 0) |
| 393 |
|
{ |
| 394 |
|
$ret = array('ret_code' => -1); |
| 395 |
|
if (!($message instanceof Message) && !($message instanceof MessageIOS)) { |
| 396 |
|
$ret['err_msg'] = 'message is not android or ios'; |
| 397 |
|
return $ret; |
| 398 |
|
} |
| 399 |
|
if (!$this->ValidateMessageType($message)) { |
| 400 |
|
$ret['err_msg'] = 'message type not fit accessId'; |
| 401 |
|
return $ret; |
| 402 |
|
} |
| 403 |
|
if ($message instanceof MessageIOS) { |
| 404 |
|
if ($environment != XingeApp::IOSENV_DEV && $environment != XingeApp::IOSENV_PROD) { |
| 405 |
|
$ret['err_msg'] = "ios message environment invalid"; |
| 406 |
|
return $ret; |
| 407 |
|
} |
| 408 |
|
} |
| 409 |
|
if (!$message->isValid()) { |
| 410 |
|
$ret['err_msg'] = 'message not valid'; |
| 411 |
|
return $ret; |
| 412 |
|
} |
| 413 |
|
$params = array(); |
| 414 |
|
$params['access_id'] = $this->accessId; |
| 415 |
|
$params['expire_time'] = $message->getExpireTime(); |
| 416 |
|
if ($message instanceof Message) |
| 417 |
|
$params['multi_pkg'] = $message->getMultiPkg(); |
| 418 |
|
$params['message_type'] = $message->getType(); |
| 419 |
|
$params['message'] = $message->toJson(); |
| 420 |
|
$params['timestamp'] = time(); |
| 421 |
|
$params['environment'] = $environment; |
| 422 |
|
|
| 423 |
|
return $this->callRestful(self::RESTAPI_CREATEMULTIPUSH, $params); |
| 424 |
|
} |
| 425 |
|
|
| 426 |
|
/** |
| 427 |
|
* 按帐号大批量推送 |