121 lines
3.7 KiB
PHP
121 lines
3.7 KiB
PHP
<?php
|
||
|
||
namespace app\api\model;
|
||
|
||
class WebSocketPush
|
||
{
|
||
public $websocket_api_address;
|
||
public $websocket_api_key;
|
||
/*
|
||
200 通用数据
|
||
|
||
房间PK
|
||
220 推送PK当前结果数据
|
||
|
||
300
|
||
用户进入房间推送消息
|
||
301
|
||
房间麦位信息
|
||
302
|
||
房间赠送礼物推送数据
|
||
303
|
||
开宝箱房间播报数据
|
||
304
|
||
开宝箱全服播报数据
|
||
400
|
||
房间相亲数据
|
||
*/
|
||
public function __construct()
|
||
{
|
||
$config = model('admin/Config')->get_system_config();
|
||
$this->websocket_api_address = $config['websocket_api_address'];
|
||
$this->websocket_api_key = $config['websocket_api_key'];
|
||
}
|
||
|
||
//发送消息给个人
|
||
public function send_to_one($uid, $content)
|
||
{
|
||
$post_data = [];
|
||
$post_data['action'] = 'send_to_one';
|
||
$post_data['key'] = $this->websocket_api_key;
|
||
if (is_array($content)) {
|
||
$post_data['content'] = json_encode($content);
|
||
} else {
|
||
$post_data['content'] = $content;
|
||
}
|
||
$post_data['uid'] = $uid;
|
||
$content = $this->myCurl($this->websocket_api_address, $post_data);
|
||
return $content;
|
||
}
|
||
//发送消息到指定房间
|
||
public function send_to_group($rid, $content)
|
||
{
|
||
$post_data = [];
|
||
$post_data['action'] = 'send_to_group';
|
||
$post_data['key'] = $this->websocket_api_key;
|
||
if (is_array($content)) {
|
||
$post_data['content'] = json_encode($content);
|
||
} else {
|
||
$post_data['content'] = $content;
|
||
}
|
||
$post_data['hid'] = $rid;
|
||
$content = $this->myCurl($this->websocket_api_address, $post_data);
|
||
return $content;
|
||
}
|
||
//发送群体消息
|
||
public function send_to_all($content)
|
||
{
|
||
$post_data = [];
|
||
$post_data['action'] = 'send_to_all';
|
||
$post_data['key'] = $this->websocket_api_key;
|
||
if (is_array($content)) {
|
||
$post_data['content'] = json_encode($content);
|
||
} else {
|
||
$post_data['content'] = $content;
|
||
}
|
||
// dump($post_data);
|
||
$content = $this->myCurl($this->websocket_api_address, $post_data);
|
||
return $content;
|
||
}
|
||
|
||
public function getallclients()
|
||
{
|
||
$post_data = [];
|
||
$post_data['action'] = 'getallclients';
|
||
$post_data['key'] = $this->websocket_api_key;
|
||
$content = $this->myCurl($this->websocket_api_address, $post_data);
|
||
return $content;
|
||
}
|
||
|
||
//参数1：访问的URL，参数2：post数据(不填则为GET)，参数3：提交的$cookies,参数4：是否返回$cookies
|
||
public function myCurl($url, $post_data = array(), $header = array(), $cookie = "")
|
||
{
|
||
// $url = 'http://paysystem.local.com/index/apip/cc';
|
||
// dump($url);
|
||
$ch = curl_init();
|
||
curl_setopt($ch, CURLOPT_URL, $url);
|
||
curl_setopt($ch, CURLOPT_HEADER, false);
|
||
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); //如果把这行注释掉的话，就会直接输出
|
||
$curl_header = array();
|
||
if (!empty($header)) {
|
||
foreach ($header as $k => $v) {
|
||
$curl_header[] = "$k:$v";
|
||
}
|
||
curl_setopt($ch, CURLOPT_HTTPHEADER, $curl_header);
|
||
}
|
||
|
||
if (!empty($post_data)) {
|
||
curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($post_data));
|
||
}
|
||
if (!empty($cookie)) {
|
||
curl_setopt($ch, CURLOPT_COOKIEFILE, $cookie);
|
||
}
|
||
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
|
||
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
|
||
curl_setopt($ch, CURLOPT_TIMEOUT, 10);
|
||
$result = curl_exec($ch);
|
||
curl_close($ch);
|
||
return $result;
|
||
}
|
||
}
|