手机 APP 消息推送极光推送 jpush-php 实例

执行 $ php composer.phar install 或 $ composer install 进行安装。

require 'path_to_sdk/autoload.php';

<?php/** * 极光推送 */namespace app\common;
use JPush\Client;
class JPush{    private $key = '';    private $secret = '';
    use InstanceTrait;
    public function _init()    {        $this->key = '3412f';        $this->secret = '2c23';    }
    /**     * 指定注册ID发送     */    public function push($registrationId, $title, $text, $url, $itemId)    {        $registrationId = array_filter($registrationId);        \Log::info(var_export([$registrationId, $title, $text, $url, $itemId], true));        $this->_init();
        $client = new Client($this->key, $this->secret);        $push = $client->push();
        $push->setPlatform('all');        $push->addRegistrationId($registrationId);        $push->addAndroidNotification($title, $text);        $push->androidNotification($text, ['title' => $title, 'alert_type' => 2, 'extras' => ['url' => $url, 'id' => $itemId]]);        $push->iosNotification(['title' => $title, 'body' => $text], ['extras' => ['url' => $url, 'id' => $itemId]]);        $push->options(['apns_production' => false]);        $push->send();    }}

<?php/** * 推送服务 */
namespace app\lucky\push\service;
use app\common\JPush;use app\lucky\follow\service\FollowService;use app\lucky\push\model\UserPushConfigModel;use app\lucky\subscribe\service\SubscribeService;use app\sports\match\service\FollowMatchService;use app\sports\match\service\SportsApiService;
class PushService{    public function push()    {        try {            $push = JPush::getInstance()->push(['1517badf006e81e'], '我是标题', '我是内容', 'GameDetails:1909991');            var_dump($push);        } catch (\Exception $e) {            var_dump($e->getMessage());        }
    }
    /**     * 推送设置     */    public function pushConfig($userId, $sys, $ext)    {        $userPushConfigModel = new UserPushConfigModel();        $result = $userPushConfigModel->updateConfig($userId, $sys, ['ext' => json_encode($ext), 'update_time' => time()]);
        if ($result) {            return ['code' => 0, 'msg' => '添加成功'];        }
        return ['code' => -1, 'msg' => '添加失败'];    }
    /**     * 获取配置     */    public function getPushConfig($userId, $sys)    {        $userPushConfigModel = new UserPushConfigModel();        $result = $userPushConfigModel->getConfigByUserId($userId, $sys);        $data = isset($result['ext']) ? $result['ext'] : '';        $data = (array)json_decode($data, true);
        return ['code' => 0, 'msg' => '获取成功', 'data' => $data];    }

    /**     * 发布资讯推送     */    public function blogPush($authorId, $title, $text, $blogId)    {        //获取作者的粉丝列表ID        $followService = new FollowService();        $followListId = $followService->getAuthorFollowList($authorId, 'sports');
        //获取用户ID的配置        $pushModel = new UserPushConfigModel();        $pushConfig = $pushModel->getConfigByUserIdArr($followListId, 'sports');
        $identifyArr = [];        foreach ($pushConfig as $value) {            $ext = (array)json_decode($value['ext'], true);            if (in_array('information', $ext)) {                $identifyArr[] = $value['identify'];            }        }
        if (!empty($identifyArr)) {            try {                JPush::getInstance()->push($identifyArr, $title, $text, 'InfoDetails', $blogId);            } catch (\Exception $exception) {                \Log::error($exception->getMessage());            }        }    }
    
    /**     * 登录关联极光ID     */    public function loginLinkPush($userId, $identify, $sys = '343')    {        $userPushConfigModel = new UserPushConfigModel();        $config = $userPushConfigModel->getConfigByUserId($userId, 'sports');
        if (empty($config)) {            $data = [                'user_id' => $userId,                'identify' => $identify,                'update_time' => time(),                'sys' => $sys,                'ext' => json_encode(['start' => true, 'end' => true, 'score' => true, 'news' => true, 'information' => true])            ];
            $result = $userPushConfigModel->addConfig($data);            if (empty($result)) {                return ['code' => -1, 'msg' => '添加极光推送失败'];            }
            return ['code' => 0, 'msg' => '添加极光推送成功'];        }
        $data = [            'identify' => $identify,            'update_time' => time(),        ];        $result = $userPushConfigModel->updateConfig($userId, $sys, $data);        if (empty($result)) {            return ['code' => -1, 'msg' => '更新极光推送失败'];        }
        return ['code' => 0, 'msg' => '更新极光推送成功'];    }
    /**     * 退出登录关联极光ID     */    public function logoutLinkPush($userId, $sys = '343')    {        $userPushConfigModel = new UserPushConfigModel();        $data = [            'identify' => '',            'update_time' => time(),        ];        $result = $userPushConfigModel->updateConfig($userId, $sys, $data);        if (empty($result)) {            return ['code' => -1, 'msg' => '退出登录,更新极光推送失败'];        }
        return ['code' => 0, 'msg' => '退出登录,更新极光推送成功'];    }}

//调用推送APP PUSH$data['author_id']=123;$data['title']='文章标题今天三美好的一天';$title = '张三发布资讯';$pushService = new PushService();$pushService->blogPush($data['author_id'], $title, mb_substr($data['title'], 0, 10) . '...', $result);

use JPush\Client as JPush;......
    $client = new JPush($app_key, $master_secret);
...

$client = new \JPush\Client($app_key, $master_secret);

$client->push()    ->setPlatform('all')    ->addAllAudience()    ->setNotificationAlert('Hello, JPush')    ->send();

$pusher = $client->push();$pusher->setPlatform('all');$pusher->addAllAudience();$pusher->setNotificationAlert('Hello, JPush');try {    $pusher->send();} catch (\JPush\Exceptions\JPushException $e) {    // try something else here    print $e;}

# 假定当前目录为 JPush 源码所在的根目录$ php examples/push_example.php

# 编辑 tests/bootstrap.php 文件，填入必须的变量值# OR 设置相应的环境变量
# 运行全部测试用例$ composer tests
# 运行某一具体测试用例$ composer tests/JPush/xxTest.php