mirror of
https://github.com/kuaifan/dootask.git
synced 2025-12-11 10:33:54 +00:00
4bfe33a37f
- 新增 `open__event` 方法用于处理打开会话事件 - 移除旧的 `open__webhook` 方法 - 更新前端调用逻辑，使用新的事件接口 - 优化 webhook 事件推送逻辑，简化参数传递
1040 lines
40 KiB
PHP
1040 lines
40 KiB
PHP
<?php
|
||
|
||
namespace App\Models;
|
||
|
||
use App\Exceptions\ApiException;
|
||
use App\Module\Base;
|
||
use App\Module\Doo;
|
||
use App\Tasks\PushTask;
|
||
use Cache;
|
||
use Carbon\Carbon;
|
||
use Hhxsv5\LaravelS\Swoole\Task\Task;
|
||
use Illuminate\Database\Eloquent\Model;
|
||
use Illuminate\Database\Eloquent\SoftDeletes;
|
||
use Illuminate\Support\Facades\DB;
|
||
|
||
/**
|
||
* App\Models\WebSocketDialog
|
||
*
|
||
* @property int $id
|
||
* @property string|null $type 对话类型
|
||
* @property string|null $group_type 聊天室类型
|
||
* @property int|null $session_id 会话ID
|
||
* @property string|null $name 对话名称
|
||
* @property string $avatar 头像（群）
|
||
* @property int|null $owner_id 群主用户ID
|
||
* @property int|null $link_id 关联id
|
||
* @property int|null $top_userid 置顶的用户ID
|
||
* @property int|null $top_msg_id 置顶的消息ID
|
||
* @property \Illuminate\Support\Carbon|null $created_at
|
||
* @property \Illuminate\Support\Carbon|null $updated_at
|
||
* @property \Illuminate\Support\Carbon|null $deleted_at
|
||
* @property-read \Illuminate\Database\Eloquent\Collection<int, \App\Models\WebSocketDialogUser> $dialogUser
|
||
* @property-read int|null $dialog_user_count
|
||
* @method static \Illuminate\Database\Eloquent\Builder|AbstractModel cancelAppend()
|
||
* @method static \Illuminate\Database\Eloquent\Builder|AbstractModel cancelHidden()
|
||
* @method static \Illuminate\Database\Eloquent\Builder|AbstractModel change($array)
|
||
* @method static \Illuminate\Database\Eloquent\Builder|AbstractModel getKeyValue()
|
||
* @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialog newModelQuery()
|
||
* @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialog newQuery()
|
||
* @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialog onlyTrashed()
|
||
* @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialog query()
|
||
* @method static \Illuminate\Database\Eloquent\Builder|AbstractModel remove()
|
||
* @method static \Illuminate\Database\Eloquent\Builder|AbstractModel saveOrIgnore()
|
||
* @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialog whereAvatar($value)
|
||
* @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialog whereCreatedAt($value)
|
||
* @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialog whereDeletedAt($value)
|
||
* @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialog whereGroupType($value)
|
||
* @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialog whereId($value)
|
||
* @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialog whereLinkId($value)
|
||
* @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialog whereName($value)
|
||
* @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialog whereOwnerId($value)
|
||
* @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialog whereSessionId($value)
|
||
* @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialog whereTopMsgId($value)
|
||
* @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialog whereTopUserid($value)
|
||
* @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialog whereType($value)
|
||
* @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialog whereUpdatedAt($value)
|
||
* @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialog withTrashed()
|
||
* @method static \Illuminate\Database\Eloquent\Builder|WebSocketDialog withoutTrashed()
|
||
* @mixin \Eloquent
|
||
*/
|
||
class WebSocketDialog extends AbstractModel
|
||
{
|
||
use SoftDeletes;
|
||
|
||
/**
|
||
* 头像地址
|
||
* @param $value
|
||
* @return string
|
||
*/
|
||
public function getAvatarAttribute($value)
|
||
{
|
||
return $value ? Base::fillUrl($value) : $value;
|
||
}
|
||
|
||
/**
|
||
* @return \Illuminate\Database\Eloquent\Relations\HasMany
|
||
*/
|
||
public function dialogUser(): \Illuminate\Database\Eloquent\Relations\HasMany
|
||
{
|
||
return $this->hasMany(WebSocketDialogUser::class, 'dialog_id', 'id');
|
||
}
|
||
|
||
/**
|
||
* 获取对话成员（连表查）
|
||
* @param $addField
|
||
* @return User|\Illuminate\Database\Eloquent\Builder|\Illuminate\Database\Query\Builder
|
||
*/
|
||
public function dialogUserBuilder($addField = [])
|
||
{
|
||
$columns = array_map(function ($column) {
|
||
return "users." . $column;
|
||
}, array_merge(User::$basicField, $addField));
|
||
$columns[] = "du.*";
|
||
return User::select($columns)
|
||
->join('web_socket_dialog_users as du', 'users.userid', '=', 'du.userid')
|
||
->where('du.dialog_id', $this->id)
|
||
->whereNull('users.disable_at');
|
||
}
|
||
|
||
/**
|
||
* 搜索对话
|
||
* @param $userid
|
||
* @param $key
|
||
* @param $take
|
||
* @return array
|
||
*/
|
||
public static function searchDialog($userid, $key, $take = 20)
|
||
{
|
||
return DB::table('web_socket_dialog_users as u')
|
||
->select(['d.*', 'u.top_at', 'u.last_at', 'u.mark_unread', 'u.silence', 'u.hide', 'u.color', 'u.updated_at as user_at'])
|
||
->join('web_socket_dialogs as d', 'u.dialog_id', '=', 'd.id')
|
||
->where('u.userid', $userid)
|
||
->where(function ($query) use ($key) {
|
||
$query->where('d.name', 'like', '%' . $key . '%');
|
||
})
|
||
->whereNull('d.deleted_at')
|
||
->orderByDesc('u.top_at')
|
||
->orderByDesc('u.last_at')
|
||
->take($take)
|
||
->get()
|
||
->map(function($item) use ($userid) {
|
||
return WebSocketDialog::synthesizeData($item, $userid);
|
||
})
|
||
->all();
|
||
}
|
||
|
||
/**
|
||
* 获取对话列表
|
||
* @param int $userid 会员ID
|
||
* @param $updated
|
||
* @param $deleted
|
||
* @return array
|
||
*/
|
||
public static function getDialogList($userid, $updated = "", $deleted = "")
|
||
{
|
||
$builder = DB::table('web_socket_dialog_users as u')
|
||
->select(['d.*', 'u.top_at', 'u.last_at', 'u.mark_unread', 'u.silence', 'u.hide', 'u.color', 'u.updated_at as user_at'])
|
||
->join('web_socket_dialogs as d', 'u.dialog_id', '=', 'd.id')
|
||
->where('u.userid', $userid)
|
||
->whereNull('d.deleted_at');
|
||
if ($updated) {
|
||
$builder->where('u.updated_at', '>', $updated);
|
||
}
|
||
$list = $builder
|
||
->orderByDesc('u.top_at')
|
||
->orderByDesc('u.last_at')
|
||
->paginate(Base::getPaginate(100, 50));
|
||
$list->transform(function ($item) use ($userid) {
|
||
return self::synthesizeData($item, $userid);
|
||
});
|
||
//
|
||
$data = $list->toArray();
|
||
if ($list->currentPage() === 1) {
|
||
$data['deleted_id'] = Deleted::ids('dialog', $userid, $deleted);
|
||
}
|
||
return $data;
|
||
}
|
||
|
||
/**
|
||
* 列表外的未读对话 和 列表外的待办对话
|
||
* @param $userid
|
||
* @param $unreadAt
|
||
* @param $todoAt
|
||
* @return WebSocketDialog[]
|
||
*/
|
||
public static function getDialogBeyond($userid, $unreadAt, $todoAt)
|
||
{
|
||
DB::statement("SET SQL_MODE=''");
|
||
$ids = [];
|
||
$array = [];
|
||
if ($unreadAt) {
|
||
// 未读对话
|
||
$list = DB::table('web_socket_dialog_users as u')
|
||
->select(['d.*', 'u.top_at', 'u.last_at', 'u.mark_unread', 'u.silence', 'u.hide', 'u.color', 'u.updated_at as user_at'])
|
||
->join('web_socket_dialogs as d', 'u.dialog_id', '=', 'd.id')
|
||
->join('web_socket_dialog_msg_reads as r', 'd.id', '=', 'r.dialog_id')
|
||
->where('u.userid', $userid)
|
||
->where('u.last_at', '<', $unreadAt)
|
||
->whereNull('d.deleted_at')
|
||
->where('r.userid', $userid)
|
||
->where('r.read_at')
|
||
->groupBy('u.dialog_id')
|
||
->take(20)
|
||
->get();
|
||
$list->transform(function ($item) use ($userid, &$ids, &$array) {
|
||
if (!in_array($item->id, $ids)) {
|
||
$ids[] = $item->id;
|
||
$array[] = self::synthesizeData($item, $userid);
|
||
}
|
||
});
|
||
// 标记未读会话
|
||
$list = DB::table('web_socket_dialog_users as u')
|
||
->select(['d.*', 'u.top_at', 'u.last_at', 'u.mark_unread', 'u.silence', 'u.hide', 'u.color', 'u.updated_at as user_at'])
|
||
->join('web_socket_dialogs as d', 'u.dialog_id', '=', 'd.id')
|
||
->where('u.userid', $userid)
|
||
->where('u.mark_unread', 1)
|
||
->where('u.last_at', '<', $unreadAt)
|
||
->whereNull('d.deleted_at')
|
||
->take(20)
|
||
->get();
|
||
$list->transform(function ($item) use ($userid, &$ids, &$array) {
|
||
if (!in_array($item->id, $ids)) {
|
||
$ids[] = $item->id;
|
||
$array[] = self::synthesizeData($item, $userid);
|
||
}
|
||
});
|
||
}
|
||
if ($todoAt) {
|
||
// 待办会话
|
||
$list = DB::table('web_socket_dialog_users as u')
|
||
->select(['d.*', 'u.top_at', 'u.last_at', 'u.mark_unread', 'u.silence', 'u.hide', 'u.color', 'u.updated_at as user_at'])
|
||
->join('web_socket_dialogs as d', 'u.dialog_id', '=', 'd.id')
|
||
->join('web_socket_dialog_msg_todos as t', 'd.id', '=', 't.dialog_id')
|
||
->where('u.userid', $userid)
|
||
->where('u.last_at', '<', $todoAt)
|
||
->whereNull('d.deleted_at')
|
||
->where('t.userid', $userid)
|
||
->where('t.done_at')
|
||
->groupBy('u.dialog_id')
|
||
->take(20)
|
||
->get();
|
||
$list->transform(function ($item) use ($userid, &$ids, &$array) {
|
||
if (!in_array($item->id, $ids)) {
|
||
$ids[] = $item->id;
|
||
$array[] = self::synthesizeData($item, $userid);
|
||
}
|
||
});
|
||
}
|
||
return $array;
|
||
}
|
||
|
||
/**
|
||
* 综合数据
|
||
* @param $data
|
||
* @param int $userid 会员ID
|
||
* @param bool $hasData 已存在的消息类型
|
||
* @return array
|
||
*/
|
||
public static function synthesizeData($data, $userid, $hasData = false)
|
||
{
|
||
// 判断数据
|
||
if (is_numeric($data)) {
|
||
$data = WebSocketDialog::find($data)?->toArray();
|
||
} elseif ($data instanceof Model) {
|
||
$data = $data->toArray();
|
||
} elseif (is_object($data)) {
|
||
$data = (array)$data;
|
||
}
|
||
if (!is_array($data) || !isset($data['id'])) {
|
||
return $data;
|
||
}
|
||
|
||
// 会话必要字段
|
||
$fields = [
|
||
'id', 'type', 'group_type', 'name', 'avatar', 'owner_id', 'link_id', 'top_userid', 'top_msg_id', 'created_at', 'updated_at', 'deleted_at',
|
||
];
|
||
if (!empty(array_diff($fields, array_keys($data)))) {
|
||
// 补全数据
|
||
foreach ($fields as $field) {
|
||
$data[$field] = $data[$field] ?? null;
|
||
}
|
||
}
|
||
$data['avatar'] = Base::fillUrl($data['avatar']);
|
||
|
||
// 会员必要字段
|
||
$fields = [
|
||
'top_at', 'last_at', 'mark_unread', 'silence', 'hide', 'color', 'user_at',
|
||
];
|
||
if (!empty(array_diff($fields, array_keys($data)))) {
|
||
// 补全数据（查询数据库）
|
||
$array = WebSocketDialogUser::whereDialogId($data['id'])->whereUserid($userid)->first()?->toArray();
|
||
foreach ($fields as $field) {
|
||
if ($field === 'user_at') {
|
||
$data[$field] = $data[$field] ?? $array['updated_at'] ?? null;
|
||
} else {
|
||
$data[$field] = $data[$field] ?? $array[$field] ?? null;
|
||
}
|
||
}
|
||
}
|
||
// 会员数据处理
|
||
if (isset($data['user_at']) && !isset($data['user_ms'])) {
|
||
$time = Carbon::parse($data['user_at']);
|
||
$data['user_at'] = $time->toDateTimeString('millisecond');
|
||
$data['user_ms'] = $time->valueOf();
|
||
}
|
||
|
||
// 信息数据
|
||
if (isset($data['search_msg_id'])) {
|
||
// 最后消息 (搜索预览消息)
|
||
$data['last_msg'] = $data['last_msg'] ?? WebSocketDialogMsg::whereDialogId($data['id'])->find($data['search_msg_id'])?->toArray();
|
||
$data['last_at'] = $data['last_msg'] ? Carbon::parse($data['last_msg']['created_at'])->toDateTimeString() : null;
|
||
} else {
|
||
// 未读消息
|
||
$data = array_merge($data, self::generateUnread($data['id'], $userid));
|
||
// 对话人数
|
||
if (!isset($data['people'])) {
|
||
$data = array_merge($data, self::generatePeople($data['id']));
|
||
}
|
||
// 有待办
|
||
$data['todo_num'] = $data['todo_num'] ?? WebSocketDialogMsgTodo::whereDialogId($data['id'])->whereUserid($userid)->whereDoneAt(null)->count();
|
||
// 最后消息
|
||
$data['last_msg'] = $data['last_msg'] ?? WebSocketDialogMsg::whereDialogId($data['id'])->orderByDesc('id')->first()?->toArray();
|
||
}
|
||
$data['last_msg'] = self::lastMsgFormat($data['last_msg']);
|
||
|
||
// 对方信息
|
||
$data['pinyin'] = Base::cn2pinyin($data['name']);
|
||
$data['quick_msgs'] = [];
|
||
$data['dialog_user'] = null;
|
||
$data['group_info'] = null;
|
||
$data['bot'] = 0;
|
||
switch ($data['type']) {
|
||
case "user":
|
||
$dialog_user = WebSocketDialogUser::whereDialogId($data['id'])->where('userid', '!=', $userid)->first();
|
||
if ($dialog_user->userid === 0) {
|
||
$dialog_user->userid = $userid;
|
||
}
|
||
$basic = User::userid2basic($dialog_user->userid);
|
||
if ($basic) {
|
||
$data['name'] = $basic->nickname;
|
||
$data['email'] = $basic->email;
|
||
$data['userimg'] = $basic->userimg;
|
||
$data['bot'] = $basic->getBotOwner();
|
||
$data['is_disable'] = $basic->isDisable(true);
|
||
$data['quick_msgs'] = UserBot::quickMsgs($basic->email);
|
||
} else {
|
||
$data['name'] = UserDelete::userid2nickname($dialog_user->userid) ?: '[Delete]';
|
||
$data['is_disable'] = 1;
|
||
$data['dialog_delete'] = 1;
|
||
}
|
||
$data['dialog_user'] = $dialog_user;
|
||
$data['dialog_mute'] = Base::settingFind('system', 'user_private_chat_mute');
|
||
break;
|
||
case "group":
|
||
switch ($data['group_type']) {
|
||
case 'user':
|
||
$data['dialog_mute'] = Base::settingFind('system', 'user_group_chat_mute');
|
||
break;
|
||
case 'project':
|
||
$data['group_info'] = Project::withTrashed()->select(['id', 'name', 'archived_at', 'deleted_at'])->whereDialogId($data['id'])->first()?->cancelAppend()->cancelHidden()->toArray();
|
||
if ($data['group_info']) {
|
||
$data['name'] = $data['group_info']['name'];
|
||
} else {
|
||
$data['name'] = '[Delete]';
|
||
$data['dialog_delete'] = 1;
|
||
}
|
||
break;
|
||
case 'task':
|
||
$data['group_info'] = ProjectTask::withTrashed()->select(['id', 'name', 'complete_at', 'archived_at', 'deleted_at'])->whereDialogId($data['id'])->first()?->cancelAppend()->cancelHidden()->toArray();
|
||
if ($data['group_info']) {
|
||
$data['name'] = $data['group_info']['name'];
|
||
} else {
|
||
$data['name'] = '[Delete]';
|
||
$data['dialog_delete'] = 1;
|
||
}
|
||
break;
|
||
case 'all':
|
||
$data['name'] = Doo::translate('全体成员');
|
||
$data['dialog_mute'] = Base::settingFind('system', 'all_group_mute');
|
||
break;
|
||
}
|
||
break;
|
||
}
|
||
if (empty($data['pinyin'])) {
|
||
$data['pinyin'] = Base::cn2pinyin($data['name']);
|
||
}
|
||
|
||
// 已存在的消息类型
|
||
if ($hasData === true) {
|
||
$msgBuilder = WebSocketDialogMsg::whereDialogId($data['id']);
|
||
$data['has_tag'] = $msgBuilder->clone()->where('tag', '>', 0)->exists();
|
||
$data['has_todo'] = $msgBuilder->clone()->where('todo', '>', 0)->exists();
|
||
$data['has_image'] = $msgBuilder->clone()->whereMtype('image')->exists();
|
||
$data['has_file'] = $msgBuilder->clone()->whereMtype('file')->exists();
|
||
$data['has_link'] = $msgBuilder->clone()->whereLink(1)->exists();
|
||
Cache::forever("Dialog::tag:" . $data['id'], Base::array2json([
|
||
'has_tag' => $data['has_tag'],
|
||
'has_todo' => $data['has_todo'],
|
||
'has_image' => $data['has_image'],
|
||
'has_file' => $data['has_file'],
|
||
'has_link' => $data['has_link'],
|
||
]));
|
||
} else {
|
||
$tagData = Base::json2array(Cache::get("Dialog::tag:" . $data['id']));
|
||
if ($tagData) {
|
||
$data['has_tag'] = !!$tagData['has_tag'];
|
||
$data['has_todo'] = !!$tagData['has_todo'];
|
||
$data['has_image'] = !!$tagData['has_image'];
|
||
$data['has_file'] = !!$tagData['has_file'];
|
||
$data['has_link'] = !!$tagData['has_link'];
|
||
}
|
||
}
|
||
return $data;
|
||
}
|
||
|
||
/**
|
||
* 格式化最后消息
|
||
* @param array $lastMsg
|
||
* @return array
|
||
*/
|
||
public static function lastMsgFormat($lastMsg)
|
||
{
|
||
if ($lastMsg && $lastMsg['type'] != 'preview') {
|
||
$msgData = $lastMsg;
|
||
$msgData['emoji'] = Base::array_only_recursive($msgData['emoji'], ['symbol']);
|
||
$msgData['msg'] = ['preview' => WebSocketDialogMsg::previewMsg($msgData)];
|
||
$msgData['type'] = 'preview';
|
||
$lastMsg = array_intersect_key($msgData, array_flip(['id', 'type', 'msg', 'userid', 'percentage', 'emoji', 'created_at']));
|
||
}
|
||
return $lastMsg;
|
||
}
|
||
|
||
/**
|
||
* 获取未读数据
|
||
* @param $dialogId
|
||
* @param $userid
|
||
* @return array
|
||
*/
|
||
public static function generateUnread($dialogId, $userid)
|
||
{
|
||
$data = [];
|
||
// 未读消息
|
||
$builder = WebSocketDialogMsgRead::whereDialogId($dialogId)->whereUserid($userid)->whereReadAt(null);
|
||
// 总未读消息
|
||
$data['unread'] = $builder->clone()->count();
|
||
// 最早一条未读消息
|
||
$data['unread_one'] = $data['unread'] > 0 ? intval($builder->clone()->orderBy('msg_id')->value('msg_id')) : 0;
|
||
// @我的消息
|
||
$data['mention'] = $data['unread'] > 0 ? $builder->clone()->whereMention(1)->count() : 0;
|
||
// @我的消息（id集合）
|
||
$data['mention_ids'] = $data['mention'] > 0 ? $builder->clone()->whereMention(1)->orderByDesc('msg_id')->take(20)->pluck('msg_id')->toArray() : [];
|
||
return $data;
|
||
}
|
||
|
||
/**
|
||
* 获取对话人数
|
||
* @param $dialogId
|
||
* @return array
|
||
*/
|
||
public static function generatePeople($dialogId)
|
||
{
|
||
$counts = WebSocketDialogUser::whereDialogId($dialogId)
|
||
->groupBy('bot')
|
||
->selectRaw('bot, COUNT(*) as count')
|
||
->pluck('count', 'bot');
|
||
$userCount = $counts->get(0, 0); // 非机器人数量
|
||
$botCount = $counts->get(1, 0); // 机器人数量
|
||
return [
|
||
'people' => $userCount + $botCount,
|
||
'people_user' => $userCount,
|
||
'people_bot' => $botCount,
|
||
];
|
||
}
|
||
|
||
/**
|
||
* 加入聊天室
|
||
* @param int|array $userid 加入的会员ID或会员ID组
|
||
* @param int $inviter 邀请人
|
||
* @param bool|null $important 重要人员(null不修改、bool修改)
|
||
* @return bool
|
||
*/
|
||
public function joinGroup($userid, $inviter, $important = null)
|
||
{
|
||
AbstractModel::transaction(function () use ($important, $inviter, $userid) {
|
||
foreach (is_array($userid) ? $userid : [$userid] as $value) {
|
||
if ($value > 0) {
|
||
$updateData = [
|
||
'inviter' => $inviter,
|
||
];
|
||
if (is_bool($important)) {
|
||
$updateData['important'] = $important ? 1 : 0;
|
||
}
|
||
$isInsert = false;
|
||
WebSocketDialogUser::updateInsert([
|
||
'dialog_id' => $this->id,
|
||
'userid' => $value,
|
||
], $updateData, function() use ($value, $updateData) {
|
||
return array_merge($updateData, [
|
||
'bot' => User::isBot($value) ? 1 : 0
|
||
]);
|
||
}, $isInsert);
|
||
if ($isInsert) {
|
||
WebSocketDialogMsg::sendMsg(null, $this->id, 'notice', [
|
||
'notice' => User::userid2nickname($value) . " 已加入群组"
|
||
], $inviter, true, true);
|
||
}
|
||
}
|
||
}
|
||
});
|
||
$data = WebSocketDialog::generatePeople($this->id);
|
||
$data['id'] = $this->id;
|
||
$this->pushMsg("groupUpdate", $data);
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 退出聊天室
|
||
* @param int|array $userid 退出的会员ID或会员ID组
|
||
* @param string $type exit|remove
|
||
* @param bool $checkDelete 是否检查删除
|
||
* @param bool $pushMsg 是否推送消息
|
||
*/
|
||
public function exitGroup($userid, $type = 'exit', $checkDelete = true, $pushMsg = true)
|
||
{
|
||
$typeDesc = $type === 'remove' ? '移出' : '退出';
|
||
AbstractModel::transaction(function () use ($pushMsg, $checkDelete, $typeDesc, $type, $userid) {
|
||
$builder = WebSocketDialogUser::whereDialogId($this->id);
|
||
if (is_array($userid)) {
|
||
$builder->whereIn('userid', $userid);
|
||
} else {
|
||
$builder->whereUserid($userid);
|
||
}
|
||
$builder->chunkById(100, function($list) use ($pushMsg, $checkDelete, $typeDesc, $type) {
|
||
/** @var WebSocketDialogUser $item */
|
||
foreach ($list as $item) {
|
||
if ($checkDelete) {
|
||
if ($type === 'remove') {
|
||
// 移出时：如果是全员群仅允许管理员操作，其他群仅群主或邀请人可以操作
|
||
if ($this->group_type === 'all') {
|
||
User::auth("admin");
|
||
} elseif (!in_array(User::userid(), [$this->owner_id, $item->inviter])) {
|
||
throw new ApiException('只有群主或邀请人可以移出成员');
|
||
}
|
||
}
|
||
if ($item->userid == $this->owner_id) {
|
||
throw new ApiException('群主不可' . $typeDesc);
|
||
}
|
||
if ($item->important) {
|
||
throw new ApiException('部门成员、项目人员或任务人员不可' . $typeDesc);
|
||
}
|
||
}
|
||
//
|
||
$item->operator_id = User::userid();
|
||
$item->delete();
|
||
//
|
||
if ($pushMsg) {
|
||
if ($type === 'remove') {
|
||
$notice = User::nickname() . " 将 " . User::userid2nickname($item->userid) . " 移出群组";
|
||
} else {
|
||
$notice = User::userid2nickname($item->userid) . " 退出群组";
|
||
}
|
||
WebSocketDialogMsg::sendMsg(null, $this->id, 'notice', [
|
||
'notice' => $notice
|
||
], User::userid(), true, true);
|
||
}
|
||
}
|
||
});
|
||
});
|
||
//
|
||
$data = WebSocketDialog::generatePeople($this->id);
|
||
$data['id'] = $this->id;
|
||
$this->pushMsg("groupUpdate", $data);
|
||
}
|
||
|
||
/**
|
||
* 推送成员事件到机器人 webhook
|
||
* @param string $event
|
||
* @param int $memberId
|
||
* @param int $operatorId
|
||
* @return void
|
||
*/
|
||
public function dispatchMemberWebhook(string $event, int $memberId, int $operatorId): void
|
||
{
|
||
$botIds = $this->dialogUser()->where('bot', 1)->pluck('userid')->toArray();
|
||
if (empty($botIds)) {
|
||
return;
|
||
}
|
||
|
||
$userBots = UserBot::whereIn('bot_id', $botIds)->get();
|
||
if ($userBots->isEmpty()) {
|
||
return;
|
||
}
|
||
|
||
$member = User::find($memberId, ['userid', 'nickname', 'email', 'bot'])?->toArray();
|
||
$operator = $operatorId === $memberId ? $member : User::find($operatorId, ['userid', 'nickname', 'email', 'bot'])?->toArray();
|
||
|
||
$payload = [
|
||
'dialog_id' => $this->id,
|
||
'dialog_type' => $this->type,
|
||
'group_type' => $this->group_type,
|
||
'dialog_name' => $this->getGroupName(),
|
||
'member' => $member,
|
||
'operator' => $operator,
|
||
];
|
||
|
||
foreach ($userBots as $userBot) {
|
||
$userBot->dispatchWebhook($event, $payload, 10);
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 删除会话
|
||
* @return bool
|
||
*/
|
||
public function deleteDialog()
|
||
{
|
||
AbstractModel::transaction(function () {
|
||
WebSocketDialogMsgRead::whereDialogId($this->id)
|
||
->whereNull('read_at')
|
||
->chunkById(100, function ($list) {
|
||
WebSocketDialogMsgRead::onlyMarkRead($list);
|
||
});
|
||
$this->delete();
|
||
});
|
||
$this->pushMsg("groupDelete");
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 还原会话
|
||
* @return bool
|
||
*/
|
||
public function restoreDialog()
|
||
{
|
||
$this->restore();
|
||
$this->pushMsg("groupRestore");
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 检查群组类型
|
||
* @param string|array|null $groupType
|
||
* @return void
|
||
*/
|
||
public function checkGroup($groupType = null)
|
||
{
|
||
if ($this->type !== 'group') {
|
||
throw new ApiException('仅限群组操作');
|
||
}
|
||
if ($groupType) {
|
||
$groupTypes = is_array($groupType) ? $groupType : [$groupType];
|
||
if (!in_array($this->group_type, $groupTypes)) {
|
||
throw new ApiException('操作的群组类型错误');
|
||
}
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 检查禁言
|
||
* @param $userid
|
||
* @return void
|
||
*/
|
||
public function checkMute($userid)
|
||
{
|
||
$muteMsgTip = null;
|
||
$systemConfig = Base::setting('system');
|
||
switch ($this->type) {
|
||
case 'user':
|
||
if ($systemConfig['user_private_chat_mute'] === 'close') {
|
||
$muteMsgTip = '个人会话禁言';
|
||
}
|
||
break;
|
||
|
||
case 'group':
|
||
if ($this->group_type === 'user') {
|
||
if ($systemConfig['user_group_chat_mute'] === 'close') {
|
||
$muteMsgTip = '个人群组禁言';
|
||
}
|
||
} elseif ($this->group_type === 'all') {
|
||
if ($systemConfig['all_group_mute'] === 'close') {
|
||
$muteMsgTip = '当前会话全员禁言';
|
||
}
|
||
}
|
||
break;
|
||
}
|
||
if ($muteMsgTip === null) {
|
||
return;
|
||
}
|
||
if ($userid) {
|
||
$user = User::find($userid);
|
||
if ($user?->bot || $user?->isAdmin()) { // 机器人或管理员不受禁言
|
||
return;
|
||
}
|
||
}
|
||
throw new ApiException($muteMsgTip);
|
||
}
|
||
|
||
/**
|
||
* 获取群组名称
|
||
* @return mixed|string|null
|
||
*/
|
||
public function getGroupName()
|
||
{
|
||
if (!isset($this->appendattrs['groupName'])) {
|
||
$name = $this->name;
|
||
if ($this->type == "group") {
|
||
switch ($this->group_type) {
|
||
case 'project':
|
||
$name = \DB::table('projects')->where('dialog_id', $this->id)->value('name');
|
||
break;
|
||
case 'task':
|
||
$name = \DB::table('project_tasks')->where('dialog_id', $this->id)->value('name');
|
||
break;
|
||
case 'all':
|
||
$name = Doo::translate('全体成员');
|
||
break;
|
||
}
|
||
}
|
||
$this->appendattrs['groupName'] = $name;
|
||
}
|
||
return $this->appendattrs['groupName'];
|
||
}
|
||
|
||
/**
|
||
* 推送消息
|
||
* @param $action
|
||
* @param array $data 发送内容，默认为[id=>会话ID]
|
||
* @param array $userid 指定会员，默认为群组所有成员
|
||
* @return void
|
||
*/
|
||
public function pushMsg($action, $data = null, $userid = null)
|
||
{
|
||
if ($data === null) {
|
||
$data = ['id' => $this->id];
|
||
}
|
||
//
|
||
if ($userid === null) {
|
||
$userid = $this->dialogUser->pluck('userid')->toArray();
|
||
}
|
||
//
|
||
$params = [
|
||
'userid' => $userid,
|
||
'msg' => [
|
||
'type' => 'dialog',
|
||
'mode' => $action,
|
||
'data' => $data,
|
||
]
|
||
];
|
||
$task = new PushTask($params, false);
|
||
Task::deliver($task);
|
||
}
|
||
|
||
/**
|
||
* 检查是否是单人对话
|
||
* @return bool
|
||
*/
|
||
public function isSelfDialog()
|
||
{
|
||
if ($this->type !== 'user') {
|
||
return false;
|
||
}
|
||
return WebSocketDialogUser::whereDialogId($this->id)->where('userid', '>', 0)->count() === 1;
|
||
}
|
||
|
||
/**
|
||
* 检查是否支持创建会话
|
||
* @return bool
|
||
*/
|
||
public function isSessionDialog()
|
||
{
|
||
// 这个不会有变化，所以可以使用永久缓存
|
||
return Cache::rememberForever('is-session-dialog-' . $this->id, function () {
|
||
if ($this->type !== 'user') {
|
||
return false;
|
||
}
|
||
$data = $this->dialogUserBuilder()->get();
|
||
foreach ($data as $item) {
|
||
if (preg_match('/^(ai-|user-session-)(.*?)@bot\.system$/', $item->email)) {
|
||
return true;
|
||
}
|
||
}
|
||
return false;
|
||
});
|
||
}
|
||
|
||
/**
|
||
* 检查是否是AI对话
|
||
* @return bool
|
||
*/
|
||
public function isAiDialog()
|
||
{
|
||
// 这个不会有变化，所以可以使用永久缓存
|
||
return Cache::rememberForever('is-ai-dialog-' . $this->id, function () {
|
||
if ($this->type !== 'user') {
|
||
return false;
|
||
}
|
||
$data = $this->dialogUserBuilder()->get();
|
||
foreach ($data as $item) {
|
||
if (preg_match('/^ai-(.*?)@bot\.system$/', $item->email)) {
|
||
return true;
|
||
}
|
||
}
|
||
return false;
|
||
});
|
||
}
|
||
|
||
/**
|
||
* 获取对话（同时检验对话身份）
|
||
* @param $dialog_id
|
||
* @param bool|string $checkOwner 是否校验群组身份，'auto'时有群主为true无群主为false
|
||
* @return self
|
||
*/
|
||
public static function checkDialog($dialog_id, $checkOwner = false)
|
||
{
|
||
if ($dialog_id <= 0) {
|
||
throw new ApiException('参数错误');
|
||
}
|
||
$dialog = WebSocketDialog::find($dialog_id);
|
||
if (empty($dialog)) {
|
||
throw new ApiException('对话不存在或已被删除', ['dialog_id' => $dialog_id], -4003);
|
||
}
|
||
//
|
||
$userid = User::userid();
|
||
if ($checkOwner === 'auto') {
|
||
$checkOwner = $dialog->owner_id > 0;
|
||
}
|
||
if ($checkOwner === true && $dialog->owner_id != $userid) {
|
||
throw new ApiException('仅限群主操作');
|
||
}
|
||
//
|
||
switch ($dialog->group_type) {
|
||
case 'project':
|
||
case 'task':
|
||
// 项目群、任务群对话校验是否在项目内
|
||
if ($dialog->group_type === 'project') {
|
||
$projectId = intval(Project::whereDialogId($dialog->id)->value('id'));
|
||
} else {
|
||
$projectId = intval(ProjectTask::whereDialogId($dialog->id)->value('project_id'));
|
||
}
|
||
if ($projectId > 0 && ProjectUser::whereProjectId($projectId)->whereUserid($userid)->exists()) {
|
||
return $dialog;
|
||
}
|
||
break;
|
||
|
||
case 'okr':
|
||
// OKR群对话不用校验
|
||
return $dialog;
|
||
}
|
||
//
|
||
if (!WebSocketDialogUser::whereDialogId($dialog->id)->whereUserid($userid)->exists()) {
|
||
WebSocketDialogMsgRead::forceRead($dialog_id, $userid);
|
||
throw new ApiException('不在成员列表内', ['dialog_id' => $dialog_id], -4003);
|
||
}
|
||
return $dialog;
|
||
}
|
||
|
||
/**
|
||
* 创建聊天室
|
||
* @param string $name 聊天室名称
|
||
* @param int|array $userid 加入的会员ID(组)
|
||
* @param string $group_type 聊天室类型
|
||
* @param int $owner_id 群主会员ID
|
||
* @return self|null
|
||
*/
|
||
public static function createGroup($name, $userid, $group_type = '', $owner_id = 0)
|
||
{
|
||
return AbstractModel::transaction(function () use ($owner_id, $userid, $group_type, $name) {
|
||
$dialog = self::createInstance([
|
||
'type' => 'group',
|
||
'name' => $name ?: '',
|
||
'group_type' => $group_type,
|
||
'owner_id' => $owner_id,
|
||
]);
|
||
$dialog->save();
|
||
foreach (is_array($userid) ? $userid : [$userid] as $value) {
|
||
if ($value > 0) {
|
||
WebSocketDialogUser::createInstance([
|
||
'dialog_id' => $dialog->id,
|
||
'userid' => $value,
|
||
'bot' => User::isBot($value) ? 1 : 0,
|
||
'important' => !in_array($group_type, ['user', 'all']),
|
||
'last_at' => in_array($group_type, ['user', 'department', 'all']) ? Carbon::now() : null,
|
||
])->save();
|
||
}
|
||
}
|
||
return $dialog;
|
||
});
|
||
}
|
||
|
||
/**
|
||
* 获取会员对话（没有自动创建）
|
||
* @param User $user 发起会话的会员
|
||
* @param int $receiver 另一个会员ID
|
||
* @return WebSocketDialog|null
|
||
*/
|
||
public static function checkUserDialog($user, $receiver)
|
||
{
|
||
if ($user->userid == $receiver) {
|
||
$receiver = 0;
|
||
}
|
||
$dialogUser = self::getUserDialog($user->userid, $receiver, 0, $cacheKey);
|
||
if ($dialogUser) {
|
||
return $dialogUser;
|
||
}
|
||
if ($receiver > 0 && $user->isTemp() && !User::whereUserid($receiver)->whereBot(1)->exists() ) {
|
||
throw new ApiException('无法发起会话，请联系管理员。');
|
||
}
|
||
return AbstractModel::transaction(function () use ($cacheKey, $receiver, $user) {
|
||
Cache::forget($cacheKey);
|
||
$dialog = self::createInstance([
|
||
'type' => 'user',
|
||
]);
|
||
$dialog->save();
|
||
WebSocketDialogUser::createInstance([
|
||
'dialog_id' => $dialog->id,
|
||
'userid' => $user->userid,
|
||
'bot' => User::isBot($user->userid) ? 1 : 0,
|
||
])->save();
|
||
WebSocketDialogUser::createInstance([
|
||
'dialog_id' => $dialog->id,
|
||
'userid' => $receiver,
|
||
'bot' => User::isBot($receiver) ? 1 : 0,
|
||
])->save();
|
||
//
|
||
if ($user->isAiBot() || User::find($receiver)?->isAiBot()) {
|
||
$session = WebSocketDialogSession::create([
|
||
'dialog_id' => $dialog->id,
|
||
]);
|
||
$session->save();
|
||
$dialog->session_id = $session->id;
|
||
$dialog->save();
|
||
}
|
||
return $dialog;
|
||
});
|
||
}
|
||
|
||
/**
|
||
* 获取用户对话（支持缓存）
|
||
* @param $userid1
|
||
* @param $userid2
|
||
* @param $ttl
|
||
* @param null $cacheKey
|
||
* @return \Illuminate\Database\Eloquent\Builder|WebSocketDialog|null
|
||
*/
|
||
public static function getUserDialog($userid1, $userid2, $ttl, &$cacheKey = null)
|
||
{
|
||
if ($userid1 == $userid2) {
|
||
$userid2 = 0;
|
||
}
|
||
$userids = [$userid1, $userid2];
|
||
sort($userids);
|
||
$cacheKey = "Dialog::user:" . implode('-', $userids);
|
||
if (empty($ttl)) {
|
||
return WebSocketDialog::query()
|
||
->whereType('user')
|
||
->whereExists(function ($query) use ($userids) {
|
||
$query->select(DB::raw(1))
|
||
->from('web_socket_dialog_users')
|
||
->whereColumn('web_socket_dialog_users.dialog_id', 'web_socket_dialogs.id')
|
||
->where('web_socket_dialog_users.userid', $userids[0]);
|
||
})
|
||
->whereExists(function ($query) use ($userids) {
|
||
$query->select(DB::raw(1))
|
||
->from('web_socket_dialog_users')
|
||
->whereColumn('web_socket_dialog_users.dialog_id', 'web_socket_dialogs.id')
|
||
->where('web_socket_dialog_users.userid', $userids[1]);
|
||
})
|
||
->first();
|
||
}
|
||
return Cache::remember($cacheKey, $ttl, function() use ($userids) {
|
||
return self::getUserDialog($userids[0], $userids[1], 0);
|
||
});
|
||
}
|
||
|
||
/**
|
||
* 发送消息文件
|
||
*
|
||
* @param User $user 发起会话的会员
|
||
* @param array $dialogIds 对话id
|
||
* @param file|mixed $files 文件对象
|
||
* @param string $image64 base64文件
|
||
* @param string $fileName 文件名称
|
||
* @param int $replyId 恢复id
|
||
* @param int $imageAttachment
|
||
* @return array
|
||
*/
|
||
public static function sendMsgFiles($user, $dialogIds, $files, $image64, $fileName, $replyId, $imageAttachment)
|
||
{
|
||
$filePath = '';
|
||
$result = [];
|
||
$data = [];
|
||
foreach ($dialogIds as $dialog_id) {
|
||
$dialog = WebSocketDialog::checkDialog($dialog_id);
|
||
|
||
$action = $replyId > 0 ? "reply-$replyId" : "";
|
||
$path = "uploads/chat/" . date("Ym") . "/" . $dialog_id . "/";
|
||
if ($image64) {
|
||
$data = Base::image64save([
|
||
"image64" => $image64,
|
||
"path" => $path,
|
||
"fileName" => $fileName,
|
||
"quality" => true
|
||
]);
|
||
} else if ($filePath) {
|
||
Base::makeDir(public_path($path));
|
||
copy($filePath, public_path($path) . basename($filePath));
|
||
} else {
|
||
$setting = Base::setting("system");
|
||
$data = Base::upload([
|
||
"file" => $files,
|
||
"type" => 'more',
|
||
"path" => $path,
|
||
"fileName" => $fileName,
|
||
"quality" => true,
|
||
"convertVideo" => $setting['convert_video'] === 'open',
|
||
"compressVideo" => $setting['compress_video'] === 'open',
|
||
]);
|
||
}
|
||
if (Base::isError($data)) {
|
||
throw new ApiException($data['msg']);
|
||
}
|
||
$fileData = $data['data'];
|
||
$filePath = $fileData['file'];
|
||
$fileName = $fileData['name'];
|
||
$fileData['thumb'] = Base::unFillUrl($fileData['thumb']);
|
||
$fileData['size'] *= 1024;
|
||
|
||
// 任务群组保存文件
|
||
if ($dialog->group_type === 'task') {
|
||
// 如果是图片不保存
|
||
if ($imageAttachment || !in_array($fileData['ext'], File::imageExt)) {
|
||
$task = ProjectTask::whereDialogId($dialog->id)->first();
|
||
if ($task) {
|
||
$file = ProjectTaskFile::createInstance([
|
||
'project_id' => $task->project_id,
|
||
'task_id' => $task->id,
|
||
'name' => $fileData['name'],
|
||
'size' => $fileData['size'],
|
||
'ext' => $fileData['ext'],
|
||
'path' => $fileData['path'],
|
||
'thumb' => $fileData['thumb'],
|
||
'userid' => $user->userid,
|
||
]);
|
||
$file->save();
|
||
}
|
||
}
|
||
}
|
||
|
||
// 发送消息
|
||
$result = WebSocketDialogMsg::sendMsg($action, $dialog_id, 'file', $fileData, $user->userid);
|
||
if (Base::isSuccess($result)) {
|
||
if (isset($task)) {
|
||
$result['data']['task_id'] = $task->id;
|
||
}
|
||
}
|
||
}
|
||
return $result;
|
||
}
|
||
}
|