From 9ea1fa6df763a8ad4ae4ffc6049f2c6604616725 Mon Sep 17 00:00:00 2001 From: kuaifan Date: Sat, 29 Jul 2023 15:43:48 +0800 Subject: [PATCH] =?UTF-8?q?perf:=20=E4=BC=9A=E8=AF=9D=E6=B6=88=E6=81=AF?= =?UTF-8?q?=E6=B2=A1=E6=9C=89=E6=8E=A5=E6=94=B6=E4=BA=BA=E6=97=B6=E5=B7=B2?= =?UTF-8?q?=E8=AF=BB=E8=BF=9B=E5=BA=A6=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/Tasks/WebSocketDialogMsgTask.php | 15 +++++++++++++++ 1 file changed, 15 insertions(+) diff --git a/app/Tasks/WebSocketDialogMsgTask.php b/app/Tasks/WebSocketDialogMsgTask.php index 916d78284..396825826 100644 --- a/app/Tasks/WebSocketDialogMsgTask.php +++ b/app/Tasks/WebSocketDialogMsgTask.php @@ -157,6 +157,21 @@ class WebSocketDialogMsgTask extends AbstractTask // 更新已发送数量 $msg->send = WebSocketDialogMsgRead::whereMsgId($msg->id)->count(); $msg->save(); + // 没有接收人时通知发送人已读 + if ($msg->send === 0) { + PushTask::push([ + 'userid' => $msg->userid, + 'msg' => [ + 'type' => 'dialog', + 'mode' => 'readed', + 'data' => [ + 'id' => $msg->id, + 'read' => $msg->read, + 'percentage' => $msg->percentage, + ], + ] + ]); + } // 开始推送消息 $umengUserid = []; foreach ($array as $item) {