82 lines
2.3 KiB
PHP
82 lines
2.3 KiB
PHP
|
<?php
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
namespace service;
|
|||
|
|
|
|||
|
|
use GatewayWorker\Lib\Gateway;
|
|||
|
|
use think\Db;
|
|||
|
|
use think\db\Query;
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* 消息推送服务
|
|||
|
|
* Class MessageService
|
|||
|
|
* @package service
|
|||
|
|
*/
|
|||
|
|
class MessageService
|
|||
|
|
{
|
|||
|
|
public function __construct()
|
|||
|
|
{
|
|||
|
|
/**
|
|||
|
|
*====这个步骤是必须的====
|
|||
|
|
*这里填写Register服务的ip（通常是运行GatewayWorker的服务器ip）和端口
|
|||
|
|
*注意Register服务端口在start_register.php中可以找到（chat默认是1236）
|
|||
|
|
*这里假设GatewayClient和Register服务都在一台服务器上，ip填写127.0.0.1
|
|||
|
|
*注意：ip不能是0.0.0.0
|
|||
|
|
**/
|
|||
|
|
Gateway::$registerAddress = '192.168.0.159:2346';
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function sendToAll($message, $action = '', $client_id_array = null, $exclude_client_id = null, $raw = false)
|
|||
|
|
{
|
|||
|
|
Gateway::sendToAll($this->messageFormat($message, $action), $client_id_array, $exclude_client_id, $raw);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function sendToUid($uid, $message, $action = '')
|
|||
|
|
{
|
|||
|
|
Gateway::sendToUid($uid, $this->messageFormat($message, $action));
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function sendToClient($client_id, $message, $action = '')
|
|||
|
|
{
|
|||
|
|
Gateway::sendToClient($client_id, $this->messageFormat($message, $action));
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function sendToGroup($group, $message, $action = '')
|
|||
|
|
{
|
|||
|
|
Gateway::sendToGroup($group, $this->messageFormat($message, $action));
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function bindUid($client_id, $uid)
|
|||
|
|
{
|
|||
|
|
Gateway::bindUid($client_id, $uid);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function joinGroup($client_id, $group)
|
|||
|
|
{
|
|||
|
|
if ($group) {
|
|||
|
|
Gateway::joinGroup($client_id, $group);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public function messageFormat($message, $action = 'none')
|
|||
|
|
{
|
|||
|
|
$messageData = [
|
|||
|
|
'action' => $action, //推送场景
|
|||
|
|
'msg' => '', //推送内容
|
|||
|
|
'title' => '消息通知',//推送标题
|
|||
|
|
'data' => [],//推送数据
|
|||
|
|
'uid' => 0,//推送数据
|
|||
|
|
];
|
|||
|
|
if (is_array($message)) {
|
|||
|
|
$messageData['data'] = $message;
|
|||
|
|
$messageData['msg'] = isset($message['content']) ? $message['content'] : '';
|
|||
|
|
$messageData['title'] = isset($message['title']) ? $message['title'] : '';
|
|||
|
|
} else {
|
|||
|
|
$messageData['msg'] = $message;
|
|||
|
|
}
|
|||
|
|
return json_encode($messageData, JSON_UNESCAPED_UNICODE);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|