Scarfski/dootask
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

perf: 支持转发给最近聊天

Browse Source
This commit is contained in:
kuaifan
2022-07-12 12:11:09 +08:00
parent fcbbd2b64c
commit 0bf98ec9f8
4 changed files with 141 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
app/Models/WebSocketDialogMsg.php
View File

@@ -365,23 +365,42 @@ class WebSocketDialogMsg extends AbstractModel
/**
* 转发消息
* @param $userids
* @param array|int $dialogids
* @param array|int $userids
* @param int $sender 发送的会员ID
* @return mixed
*/
public function forwardMsg($userids, $sender)
public function forwardMsg($dialogids, $userids, $sender)
{
return AbstractModel::transaction(function() use ($sender, $userids) {
return AbstractModel::transaction(function() use ($dialogids, $sender, $userids) {
$msgs = [];
foreach ($userids as $userid) {
if (!User::whereUserid($userid)->exists()) {
continue;
$already = [];
if ($dialogids) {
if (!is_array($dialogids)) {
$dialogids = [$dialogids];
}
$dialog = WebSocketDialog::checkUserDialog($sender, $userid);
if ($dialog) {
$res = self::sendMsg(null, $dialog->id, $this->type, $this->getOriginal('msg'), $sender);
foreach ($dialogids as $dialogid) {
$res = self::sendMsg(null, $dialogid, $this->type, $this->getOriginal('msg'), $sender);
if (Base::isSuccess($res)) {
$msgs[] = $res['data'];
$already[] = $dialogid;
}
}
}
if ($userids) {
if (!is_array($userids)) {
$userids = [$userids];
}
foreach ($userids as $userid) {
if (!User::whereUserid($userid)->exists()) {
continue;
}
$dialog = WebSocketDialog::checkUserDialog($sender, $userid);
if ($dialog && !in_array($dialog->id, $already)) {
$res = self::sendMsg(null, $dialog->id, $this->type, $this->getOriginal('msg'), $sender);
if (Base::isSuccess($res)) {
$msgs[] = $res['data'];
}
}
}
}