From eda9eb08d5d01685978d75267e0f5535784a0005 Mon Sep 17 00:00:00 2001
From: kuaifan <aipaw@live.cn>
Date: Sun, 12 May 2024 13:16:39 +0900
Subject: [PATCH] no message

---
 app/Http/Controllers/Api/DialogController.php | 16 ++++++++++++----
 app/Models/WebSocketDialogMsg.php             |  8 ++++++++
 2 files changed, 20 insertions(+), 4 deletions(-)

diff --git a/app/Http/Controllers/Api/DialogController.php b/app/Http/Controllers/Api/DialogController.php
index 5eeed9f77..88e8f02a1 100755
--- a/app/Http/Controllers/Api/DialogController.php
+++ b/app/Http/Controllers/Api/DialogController.php
@@ -1493,7 +1493,7 @@ class DialogController extends AbstractController
      */
     public function msg__voice2text()
     {
-        User::auth();
+        $user = User::auth();
         //
         $msg_id = intval(Request::input("msg_id"));
         $msg = WebSocketDialogMsg::whereId($msg_id)->first();
@@ -1503,19 +1503,27 @@ class DialogController extends AbstractController
         if ($msg->type !== 'record') {
             return Base::retError("仅支持语音消息");
         }
-        if ($msg['msg']['text']) {
+        $msgData = Base::json2array($msg->getRawOriginal('msg'));
+        if ($msgData['text']) {
+            $textUserid = is_array($msgData['text_userid']) ? $msgData['text_userid'] : [];
+            if (!in_array($user->userid, $textUserid)) {
+                $textUserid[] = $user->userid;
+                $msg->updateInstance([
+                    'msg' => array_merge($msgData, ['text_userid' => $textUserid]),
+                ]);
+                $msg->save();
+            }
             return Base::retSuccess("success", $msg);
         }
         WebSocketDialog::checkDialog($msg->dialog_id);
         //
-        $msgData = Base::json2array($msg->getRawOriginal('msg'));
         $res = Extranet::openAItranscriptions(public_path($msgData['path']));
         if (Base::isError($res)) {
             return $res;
         }
         //
         $msg->updateInstance([
-            'msg' => array_merge($msgData, ['text' => $res['data']]),
+            'msg' => array_merge($msgData, ['text' => $res['data'], 'text_userid' => [$user->userid]]),
         ]);
         $msg->save();
         return Base::retSuccess("success", $msg);
diff --git a/app/Models/WebSocketDialogMsg.php b/app/Models/WebSocketDialogMsg.php
index 9b1bb69c0..2737801b7 100644
--- a/app/Models/WebSocketDialogMsg.php
+++ b/app/Models/WebSocketDialogMsg.php
@@ -4,6 +4,7 @@ namespace App\Models;
 
 use Carbon\Carbon;
 use App\Module\Base;
+use App\Module\Doo;
 use App\Module\Image;
 use App\Tasks\PushTask;
 use App\Exceptions\ApiException;
@@ -154,6 +155,13 @@ class WebSocketDialogMsg extends AbstractModel
             $msg['thumb'] = Base::fillUrl($msg['thumb'] ?: Base::extIcon($msg['ext']));
         } else if ($type === 'record') {
             $msg['path'] = Base::fillUrl($msg['path']);
+            $textUserid = is_array($msg['text_userid']) ? $msg['text_userid'] : [];
+            if (isset($msg['text_userid'])) {
+                unset($msg['text_userid']);
+            }
+            if ($msg['text'] && !in_array(Doo::userId(), $textUserid)) {
+                $msg['text'] = "";
+            }
         }
         return $msg;
     }