From e8235dd0a276f0beeb03d2f656a1843575673b1c Mon Sep 17 00:00:00 2001
From: kuaifan <aipaw@live.cn>
Date: Fri, 17 Oct 2025 00:41:38 +0000
Subject: [PATCH] =?UTF-8?q?feat:=20=E4=BC=98=E5=8C=96=E5=B7=B2=E8=AF=BB?=
 =?UTF-8?q?=E6=B6=88=E6=81=AF=E6=A0=87=E8=AE=B0=E9=80=BB=E8=BE=91=EF=BC=8C?=
 =?UTF-8?q?=E6=8F=90=E5=8D=87=E6=80=A7=E8=83=BD=E5=92=8C=E5=8F=AF=E8=AF=BB?=
 =?UTF-8?q?=E6=80=A7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/Http/Controllers/Api/DialogController.php |  5 +-
 app/Models/WebSocketDialogMsgRead.php         | 53 ++++++++++++++-----
 2 files changed, 43 insertions(+), 15 deletions(-)

diff --git a/app/Http/Controllers/Api/DialogController.php b/app/Http/Controllers/Api/DialogController.php
index b39c4f8bf..03e6a81d9 100755
--- a/app/Http/Controllers/Api/DialogController.php
+++ b/app/Http/Controllers/Api/DialogController.php
@@ -2196,7 +2196,10 @@ class DialogController extends AbstractController
         switch ($type) {
             case 'read':
                 // 标记已读
-                $builder = WebSocketDialogMsgRead::whereDialogId($dialog_id)->whereUserid($user->userid)->whereReadAt(null);
+                $builder = WebSocketDialogMsgRead::whereDialogId($dialog_id)
+                    ->whereUserid($user->userid)
+                    ->whereReadAt(null)
+                    ->select(['id', 'msg_id']);
                 if ($after_msg_id > 0) {
                     $builder->where('msg_id', '>=', $after_msg_id);
                 }
diff --git a/app/Models/WebSocketDialogMsgRead.php b/app/Models/WebSocketDialogMsgRead.php
index 4a24866c1..151c3f8a0 100644
--- a/app/Models/WebSocketDialogMsgRead.php
+++ b/app/Models/WebSocketDialogMsgRead.php
@@ -3,6 +3,7 @@
 namespace App\Models;
 
 use Carbon\Carbon;
+use Illuminate\Support\Facades\DB;
 
 /**
  * App\Models\WebSocketDialogMsgRead
@@ -76,24 +77,48 @@ class WebSocketDialogMsgRead extends AbstractModel
      */
     public static function onlyMarkRead($list)
     {
-        $dialogMsg = [];
+        if (empty($list)) {
+            return;
+        }
+
+        $collection = collect($list);
+        if ($collection->isEmpty()) {
+            return;
+        }
+
+        $now = Carbon::now();
+        $ids = [];
+        $msgCounts = [];
+
         /** @var WebSocketDialogMsgRead $item */
-        foreach ($list as $item) {
-            $item->read_at = Carbon::now();
-            $item->save();
-            if (isset($dialogMsg[$item->msg_id])) {
-                $dialogMsg[$item->msg_id]['readNum']++;
-            } else {
-                $dialogMsg[$item->msg_id] = [
-                    'dialogMsg' => $item->webSocketDialogMsg,
-                    'readNum' => 1
-                ];
+        foreach ($collection as $item) {
+            $ids[] = $item->id;
+            if ($item->msg_id) {
+                $msgCounts[$item->msg_id] = ($msgCounts[$item->msg_id] ?? 0) + 1;
             }
         }
-        foreach ($dialogMsg as $item) {
-            if ($item['dialogMsg']) {
-                $item['dialogMsg']->increment('read', $item['readNum']);
+
+        if (!empty($ids)) {
+            DB::table((new self())->getTable())
+                ->whereIn('id', $ids)
+                ->whereNull('read_at')
+                ->update(['read_at' => $now]);
+        }
+
+        if (!empty($msgCounts)) {
+            $cases = [];
+            $bindings = [];
+            foreach ($msgCounts as $msgId => $num) {
+                $cases[] = 'WHEN ? THEN ?';
+                $bindings[] = $msgId;
+                $bindings[] = $num;
             }
+            $msgIds = array_keys($msgCounts);
+            $bindings = array_merge($bindings, $msgIds);
+            $placeholders = implode(',', array_fill(0, count($msgIds), '?'));
+            $table = DB::getTablePrefix() . (new WebSocketDialogMsg())->getTable();
+            $sql = "UPDATE {$table} SET `read` = `read` + CASE `id` " . implode(' ', $cases) . " END WHERE `deleted_at` IS NULL AND `id` IN ({$placeholders})";
+            DB::update($sql, $bindings);
         }
     }
 }