hawind/gdoo
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

创建版本

Browse Source
This commit is contained in:
hawind
2021-02-22 12:17:00 +08:00
commit af555f49c3
2332 changed files with 369202 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/Gdoo/Chat/Services/ChatService.php
+723
View File
@@ -0,0 +1,723 @@
<?php namespace Gdoo\Chat\Services;
use DB;
use URL;
use Gdoo\Chat\Models\History;
use Gdoo\Chat\Models\GroupUser;
use Gdoo\Chat\Models\Message;
class ChatService
{
/**
* 构建ws连接url
*
* @param array $user
* @access public
* @return array
*/
public static function getServerURL($user) {
$key = env('REALTIME_KEY');
$url = env('REALTIME_URL');
$timestamp = time();
$nonce = rand(10000, 99999);
$signature = hash_hmac('sha256', $key.$timestamp.$nonce, $key);
$query = [
'signature' => $signature,
'timestamp' => $timestamp,
'nonce' => $nonce,
'user_id' => $user['id'],
'user_name' => $user['name'],
];
return ['url' => $url. '?'. http_build_query($query)];
}
/**
* 获取组
*
* @param int $admin_id
* @access public
* @return array
*/
public static function getGroup($auth_id = 0, $admin_id = 0)
{
static $rows = null;
if ($rows == null) {
$model = DB::table('chat_group as cg')
->leftJoin('chat_group_user', 'chat_group_user.group_id', '=', 'cg.id');
if ($auth_id > 0) {
$model->where('chat_group_user.user_id', $auth_id);
}
if ($admin_id > 0) {
$model->whereRaw(db_instr('admin_ids', $admin_id));
}
$model->leftJoin(DB::raw('(select count(id) utotal, group_id
FROM chat_group_user
GROUP BY group_id
) cgu
'), 'cg.id', '=', 'cgu.group_id')
->selectRaw('cg.*, cgu.utotal, cg.logo as face');
$rows = $model->get()->keyBy('id');
}
return $rows;
}
/**
* 撤回消息
*
* @param int $type
* @param int $auth_id
* @param int $group_id
* @param int $id
* @access public
* @return array
*/
public static function recallMessage($type, $auth_id, $group_id, $id)
{
$chehui = 5;
if ($chehui <= 0) {
abort_error('没有开启此功能');
}
$message = DB::table('chat_message')->where('id', $id)->first();
if(!$message) {
abort_error('记录不存在了');
}
$outtime = time() - strtotime($message['created_dt']);
if($outtime > $chehui * 60) {
abort_error('已经超过'.$chehui.'分钟无法撤回');
}
if ($type == 'user') {
$receiver = [$auth_id, (int)$message['receive_id']];
} elseif ($type == 'group') {
$user_ids = DB::table('chat_group_user')->where('group_id', $group_id)->pluck('user_id');
foreach($user_ids as $user_id) {
$receiver[] = (int)$user_id;
}
}
$msg = '已撤回';
DB::table('chat_message')->where('id', $message['id'])->update([
'file_id' => 0,
'content' => $msg,
]);
$pushData = [
'send_id' => $auth_id,
'content' => $msg,
'event' => 'recallMessage',
'receive_ids' => $receiver,
'message_id' => (int)$message['id'],
];
$push = new PushService();
$push->send($pushData);
return $pushData;
}
/**
* 格式化消息
*
* @param array $rows
* @access public
* @return array
*/
public static function formatMessage($rows)
{
$file_ids = [];
foreach($rows as $row) {
if ($row['file_id'] > 0) {
$file_ids[] = $row['file_id'];
}
}
$imgext = ['gif','png','jpg','jpeg','bmp'];
if (count($file_ids) > 0) {
$model = DB::table('attachment');
$farr = [];
$files = $model->whereIn('id', $file_ids)->get();
foreach ($files as $file)
$farr[$file['id']] = $file;
if ($farr) {
foreach ($rows as $k => $row) {
$frs = [];
$fid = $row['file_id'];
if (isset($farr[$fid])) {
$frs = $farr[$fid];
$frs['fileext'] = $frs['type'];
$frs['fileid'] = $fid;
}
if ($frs) {
$type = $frs['type'];
$path = $frs['path'];
$boc = false;
if (substr($path, 0, 4) == 'http') {
$boc = true;
} else {
if (is_file(upload_path().'/'.$path)) {
$path = url('uploads/'.$path);
$frs['thumbpath'] = $path;
$frs['filepath'] = $path;
$frs['filesize'] = $frs['size'];
$frs['filesizecn'] = human_filesize($frs['size']);
$frs['filename'] = $frs['name'];
$boc = true;
}
}
if ($boc) {
if (in_array($type, $imgext)) {
// $frs['thumbpath'] = $fobj->getthumbpath($frs);
$rows[$k]['cont'] = '<img fid="'.$fid.'" src="'.$path.'">';
}
$rows[$k]['filers'] = $frs;
} else {
$rows[$k]['fileid'] = 0;
}
}
}
}
}
return $rows;
}
/**
* 获取用户
*
* @param int $user_id
* @param int $group_id
* @access public
* @return array
*/
public static function getUser($status = 1, $group_id = 1)
{
static $rows = null;
if ($rows == null) {
$model = DB::table('user');
if (is_numeric($status)) {
$model->where('status', $status);
}
if (is_numeric($group_id)) {
$model->where('group_id', $group_id);
}
$model->selectRaw("''as pingyin,tel,(CASE WHEN (gender = 1) THEN '男' ELSE '女' END) as sex, email, id, name, phone, phone as mobile, role_id, department_id, department_id as deptid");
$rows = $model->get()->keyBy('id');
}
return $rows;
}
/**
* 邀请用户到组
*
* @param string $ids
* @param int $group_id
*/
public static function inviteUser($auth, $group_id, $ids)
{
$user_ids = explode(',', $ids);
if (count($user_ids) > 0) {
foreach($user_ids as $index => $user_id) {
$model = GroupUser::firstOrNew([
'user_id' => $user_id,
'group_id' => $group_id,
]);
if ($model->exists == true) {
unset($user_ids[$index]);
}
$model->save();
}
if (count($user_ids) > 0) {
$users = DB::table('user')->whereIn('id', $user_ids)->get()->pluck('name')->implode(',');
$gets = [
"cont" => $auth['name'].'邀请['.$users.']加入本会话',
"sendid" => $auth['id'],
"receid" => $group_id,
"type" => 'group',
"optdt" => date('Y-m-d H:i:s'),
"zt" => 0,
"fileid" => '',
"msgid" => "",
"gid" => $group_id,
"nuid" => time(),
];
$json = ChatService::sendMessage('group', $auth['id'], $group_id, $gets);
}
}
}
/**
* 退出用户组
*
* @param int $group_id
* @param int $auth_id
* @access public
* @return void
*/
public static function exitGroup($group_id, $auth_id)
{
// 删除用户组权限
GroupUser::where('group_id', $group_id)
->where('user_id', $auth_id)
->delete();
// 删除组聊天记录
DB::table('chat_message_status')
->where('type', 'group')
->where('group_id', $group_id)
->where('user_id', $auth_id)
->delete();
// 删除会话记录
DB::table('chat_history')
->where('type', 'group')
->where('receive_id', $group_id)
->where('send_id', $auth_id)
->delete();
}
/**
* 删除服务器上记录
*
* @param string $type
* @param int $group_id
* @param int $auth_id
* @param string $ids
* @param int $day
* @access public
* @return void
*/
public static function clearRecord($type, $group_id, $auth_id, $ids = [], $day = 0)
{
DB::beginTransaction();
try {
// 获取聊天记录数量
$model = DB::table('chat_message_status')
->where('type', $type);
if (count($ids) > 0) {
$model->whereIn('message_id', $ids);
}
if ($type == 'group') {
$model->where('group_id', $group_id);
} else if ($type == 'user') {
$model->whereRaw("((group_id = '$group_id' and user_id = '$auth_id') or (group_id = '$auth_id' and user_id = '$group_id'))");
}
$messages = $model->groupBy('message_id')
->selectRaw('message_id, count(id) as count')
->get();
$model = DB::table('chat_message_status')
->where('group_id', $group_id)
->where('user_id', $auth_id);
if (count($ids) > 0) {
$model->whereIn('message_id', $ids);
}
$model->delete();
// 获取回话的最后消息id
$last_message_id = DB::table('chat_message_status')
->where('type', $type)
->where('group_id', $group_id)
->where('user_id', $auth_id)
->orderBy('message_id', 'desc')
->value('message_id');
// 更新回话的最后消息id
DB::table('chat_history')
->where('type', $type)
->where('receive_id', $group_id)
->where('send_id', $auth_id)
->update(['last_message_id' => (int)$last_message_id]);
// 删除消息状统计为1的数据
foreach($messages as $message) {
if ($message['count'] == 1) {
DB::table('chat_message')->where('id', $message['message_id'])->delete();
}
}
DB::commit();
} catch (\Exception $e) {
DB::rollBack();
abort_error($e->getMessage());
}
}
/**
* 删除会话记录
*
* @param string $type
* @param int $group_id
* @param int $auth_id
* @access public
* @return void
*/
public static function clearHistory($type, $group_id, $auth_id)
{
DB::beginTransaction();
try {
// 获取聊天记录数量
$model = DB::table('chat_message_status')
->where('type', $type);
if ($type == 'group') {
$model->where('group_id', $group_id);
} else if ($type == 'user') {
$model->whereRaw("((group_id = '$group_id' and user_id = '$auth_id') or (group_id = '$auth_id' and user_id = '$group_id'))");
}
$messages = $model->groupBy('message_id')
->selectRaw('message_id, count(id) as count')
->get();
// 删除聊天记录
$model = DB::table('chat_message_status')
->where('type', $type)
->where('group_id', $group_id)
->where('user_id', $auth_id)
->delete();
// 删除会话记录
DB::table('chat_history')
->where('type', $type)
->where('receive_id', $group_id)
->where('send_id', $auth_id)
->delete();
// 删除消息状统计为1的数据
foreach($messages as $message) {
if ($message['count'] == 1) {
DB::table('chat_message')->where('id', $message['message_id'])->delete();
}
}
DB::commit();
} catch (\Exception $e) {
DB::rollBack();
abort_error($e->getMessage());
}
}
/**
* 获取组和用户
*
* @param int $group_id
* @param int $auth_id
* @access public
* @return array
*/
public static function getGroupUser($group_id, $auth_id)
{
$group = DB::table('chat_group')->where('id', $group_id)->first();
$group['face'] = $group['logo'];
$group['deptid'] = $group['department_id'];
$group['utotal'] = DB::table('chat_group_user')->where('group_id', $group_id)->count();
$group['innei'] = DB::table('chat_group_user')->where('user_id', $auth_id)->count();
$rows = DB::table('chat_group_user as cgu')
->leftJoin('user', 'user.id', 'cgu.user_id')
->where('cgu.group_id', $group_id)
->get(['user.id', 'user.name', 'user.avatar as face']);
$users = [];
foreach($rows as $row) {
$row['face'] = avatar($row['avatar']);
$users[] = $row;
}
$json['infor'] = $group;
$json['uarr'] = $users;
return $json;
}
/**
* 获取发送者
* @access public
* @param int $type 回话类型
* @param int $send_id 发送人
* @param int $receive_id 接受者id，如果是group那就是group_id
* @param int $user_id group的user_id
* @param int $message_id 消息id
* @return array
*/
public static function getReceiver($type, $receive_id, $send_id)
{
if ($type == 'user') {
$receiver = DB::table('user')
->where('id', $receive_id)
->selectRaw('id, name, role_id, department_id as deptid, avatar')
->first();
$receiver['face'] = avatar($receiver['avatar']);
$receiver['type'] = 'user';
$receiver['utotal'] = 0;
$receiver['gid'] = $receiver['id'];
}
else if ($type == 'group') {
$receiver = DB::table('chat_group')
->where('id', $receive_id)
->selectRaw('id, name, logo')
->first();
$receiver['face'] = $receiver['logo'];
$receiver['type'] = 'group';
// 查询用户数量
$receiver['utotal'] = DB::table('chat_group_user')
->where('group_id', $receive_id)
->count();
// 查询自己是否在组中
$receiver['innei'] = DB::table('chat_group_user')
->where('group_id', $receive_id)
->where('user_id', $send_id)
->count();
$receiver['gid'] = $receiver['id'];
}
return $receiver;
}
/**
* 获取发送者
* @access public
* @param int $type 回话类型
* @param int $send_id 发送人
* @param int $receive_id 接受者id，如果是group那就是group_id
* @param array $data 发送内容
* @param int $client 0=app发送 1=web客户端
* @return array
*/
public static function sendMessage($type, $send_id, $receive_id, $data, $client = 1)
{
$gets = $data;
$data = [
'send_id' => $send_id,
'receive_id' => $receive_id,
"content" => $gets['cont'],
'type' => $type,
'url' => $gets['url'],
'file_id' => $gets['fileid'],
'created_dt' => date('Y-m-d H:i:s')
];
$message_id = Message::insertGetId($data);
// 返回数据
$json = [
"cont" => $gets['cont'],
"sendid" => $send_id,
"receid" => $receive_id,
"type" => $type,
"optdt" => date('Y-m-d H:i:s'),
"zt" => 0,
"fileid" => $gets['fileid'],
"msgid" => "",
"gid" => $receive_id,
"id" => $message_id,
"nuid" => $gets['nuid'],
];
$json['event'] = 'message';
$json['content'] = $gets['cont'];
$json['send_id'] = $send_id;
// 写入历史记录
$user_ids = ChatService::setHistory($type, $send_id, $receive_id, $message_id);
if ($type == 'user') {
// 写入已读(自己)
DB::table('chat_message_status')->insert([
'group_id' => $receive_id,
'user_id' => $send_id,
'message_id' => $message_id,
'status' => 1,
'type' => $type,
]);
// 写入未读(对方)
DB::table('chat_message_status')->insert([
'group_id' => $send_id,
'user_id' => $receive_id,
'message_id' => $message_id,
'status' => 0,
'type' => $type,
]);
} else if ($type == 'group') {
// 写入未读(讨论组)
foreach($user_ids as $user_id) {
// 设置为已读(自己)
$status = $send_id == $user_id ? 1 : 0;
DB::table('chat_message_status')->insert([
'group_id' => $receive_id,
'user_id' => $user_id,
'message_id' => $message_id,
'status' => $status,
'type' => $type,
]);
}
// 组的名称
$group = DB::table('chat_group')->where('id', $receive_id)->first();
$json['gname'] = $group['name'];
}
$json['receuid'] = join(',', $user_ids);
$json['receive_ids'] = $user_ids;
return $json;
}
/**
* 写入会话
* @access public
* @param int $type 会话类型
* @param int $send_id 发送人
* @param int $receive_id 接受者id，如果是group那就是group_id
* @param int $user_id group的user_id
* @param int $message_id 消息id
* @return array
*/
public static function setHistory($type, $send_id, $receive_id, $message_id)
{
$model = History::firstOrNew([
'send_id' => $send_id,
'receive_id' => $receive_id,
'type' => $type,
]);
$model->last_message_id = $message_id;
$model->updated_dt = date('Y-m-d H:i:s');
$model->save();
if ($type == 'user') {
$receive_ids = [$send_id, $receive_id];
$model = History::firstOrNew([
'send_id' => $receive_id,
'receive_id' => $send_id,
'type' => $type,
]);
$model->last_message_id = $message_id;
$model->updated_dt = date('Y-m-d H:i:s');
if ($send_id != $receive_id) {
$model->unread_total = $model->unread_total + 1;
}
$model->save();
} else if($type == 'group') {
$user_ids = DB::table('chat_group_user')
->where('group_id', $receive_id)
->pluck('user_id');
// 写入接收者历史记录
foreach($user_ids as $user_id) {
// 返回所有接受者
$receive_ids[] = (int)$user_id;
// 发送人和接收人相同
if ($send_id == $user_id) {
continue;
}
$model = History::firstOrNew([
'send_id' => $user_id,
'receive_id' => $receive_id,
'type' => $type,
]);
$model->last_message_id = $message_id;
$model->updated_dt = date('Y-m-d H:i:s');
if ($send_id != $user_id) {
$model->unread_total = $model->unread_total + 1;
}
$model->save();
}
}
return array_unique($receive_ids);
}
/**
* 获取回话历史
*
* @param int $user_id
* @param datetime $updated_dt
* @param int $unread
* @access public
* @return array
*/
public static function getHistory($user_id, $updated_dt = '', $unread = 0)
{
$model = DB::table('chat_history as ch')
->leftJoin('chat_message as cm', 'cm.id', '=', 'ch.last_message_id')
->where('ch.send_id', $user_id)
->orderBy('ch.updated_dt', 'desc')
->selectRaw("
ch.type type,
ch.send_id uid,
ch.receive_id receid,
ch.send_id sendid,
".sql_month_day('ch.updated_dt')." optdts,
cm.content cont,
cm.id messid,
cm.send_id,
ch.unread_total stotal,
0 utotal,
ch.updated_dt as optdt
");
if ($updated_dt) {
$model->where('ch.updated_dt', '>', $updated_dt);
}
if ($unread) {
$model->where('ch.unread_total', '>', $unread);
}
$rows = $model->get();
$users = static::getUser();
$groups = static::getGroup();
$historys = [];
foreach ($rows as $row) {
if ($row['type'] == 'user') {
$row['face'] = avatar($users[$row['receid']]['avatar']);
$row['name'] = $users[$row['receid']]['name'];
if (empty($row['cont'])) {
$row['cont'] = '';
}
}
if ($row['type'] == 'group') {
$row['deptid'] = $groups[$row['receid']]['department_id'];
$row['face'] = $groups[$row['receid']]['face'];
$row['name'] = $groups[$row['receid']]['name'];
if (empty($row['cont'])) {
$row['cont'] = '';
} else {
$row['cont'] = $users[$row['send_id']]['name'].':'.$row['cont'];
}
}
$historys[] = $row;
}
return $historys;
}
}
app/Gdoo/Chat/Services/PushService.php
+100
View File
@@ -0,0 +1,100 @@
<?php namespace Gdoo\Chat\Services;
class PushService
{
private $api;
private $key;
private $cert;
private $caPath;
private $connectTimeout;
private $timeout;
private $useSSL = false;
public function __construct() {
$this->api = env('REALTIME_API');
$this->key = env('REALTIME_KEY');
$this->api = $this->api.'?'.$this->generateSignature();
}
public function generateSignature() {
$timestamp = time();
$nonce = rand(10000, 99999);
$signature = hash_hmac('sha256', $this->key.$timestamp.$nonce, $this->key);
$query = "signature={$signature}&amp;timestamp={$timestamp}&amp;nonce={$nonce}";
return $query;
}
public function send(array $data) {
return $this->request($data);
}
public function useSSL(bool $value) {
$this->useSSL = $value;
return $this;
}
public function setCert(string $cert) {
$this->cert = $cert;
return $this;
}
public function setCAPath(string $caPath) {
$this->caPath = $caPath;
return $this;
}
public function setConnectTimeout(int $connectTimeout) {
$this->connectTimeout = $connectTimeout;
return $this;
}
public function setTimeout(int $timeout) {
$this->timeout = $timeout;
return $this;
}
private function request(array $params) {
$ch = curl_init();
if ($this->connectTimeout) {
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, $this->connectTimeout);
}
if ($this->timeout) {
curl_setopt($ch, CURLOPT_TIMEOUT, $this->timeout);
}
if ($this->useSSL) {
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, true);
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 2);
if ($this->cert) {
curl_setopt($ch, CURLOPT_CAINFO, $this->cert);
}
if ($this->caPath) {
curl_setopt($ch, CURLOPT_CAPATH, $this->caPath);
}
} else {
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);
}
curl_setopt($ch, CURLOPT_USERAGENT, 'realtime/1.0');
curl_setopt($ch, CURLOPT_HEADER, 0);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($ch, CURLOPT_POST, true);
curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($params));
curl_setopt($ch, CURLOPT_HTTPHEADER, $this->getHeaders());
curl_setopt($ch, CURLOPT_URL, $this->api);
$data = curl_exec($ch);
$error = curl_error($ch);
$headers = curl_getinfo($ch);
curl_close($ch);
if (empty($headers["http_code"]) || ($headers["http_code"] != 200)) {
$data = '{"success":false,"code":'.$headers["http_code"].',"msg":"'.$error.'"}';
}
$json = json_decode($data, true);
return $json;
}
private function getHeaders() {
return [
'Content-Type: application/json',
];
}
}