From c5948c4171f4cc701fefa999d5fa9f92f5fae3ef Mon Sep 17 00:00:00 2001
From: kuaifan <aipaw@live.cn>
Date: Mon, 7 Apr 2025 01:20:58 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E6=96=B0=E5=A2=9E=E8=BD=AC=E5=8F=91?=
 =?UTF-8?q?=E8=87=B3AI=E5=BC=80=E5=90=AF=E6=96=B0=E4=BC=9A=E8=AF=9D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/Http/Controllers/Api/DialogController.php | 14 ++--
 .../manage/components/Forwarder/confirm.vue   | 77 +++++++++++++++++--
 .../sass/pages/components/forwarder.scss      | 59 +++++++-------
 3 files changed, 110 insertions(+), 40 deletions(-)

diff --git a/app/Http/Controllers/Api/DialogController.php b/app/Http/Controllers/Api/DialogController.php
index 91205eb28..5f0a02577 100755
--- a/app/Http/Controllers/Api/DialogController.php
+++ b/app/Http/Controllers/Api/DialogController.php
@@ -3183,6 +3183,7 @@ class DialogController extends AbstractController
      * @apiName session_create
      *
      * @apiParam {Number} dialog_id         对话ID
+     * @apiParam {Number} [userid]          用户ID（与 dialog_id 二选一，userid 优先）
      *
      * @apiSuccess {Number} ret     返回状态码（1正确、0错误）
      * @apiSuccess {String} msg     返回信息（错误描述）
@@ -3190,11 +3191,16 @@ class DialogController extends AbstractController
      */
     public function session__create()
     {
-        User::auth();
+        $user = User::auth();
         //
         $dialog_id = intval(Request::input('dialog_id'));
+        $userid = intval(Request::input('userid'));
         //
-        $dialog = WebSocketDialog::checkDialog($dialog_id);
+        if ($userid) {
+            $dialog = WebSocketDialog::checkUserDialog($user, $userid);
+        } else {
+            $dialog = WebSocketDialog::checkDialog($dialog_id);
+        }
         //
         if ($dialog->type != 'user') {
             return Base::retError('当前对话不支持');
@@ -3208,9 +3214,7 @@ class DialogController extends AbstractController
             return Base::retError('当前对话不支持');
         }
         //
-        $session = WebSocketDialogSession::whereDialogId($dialog->id)
-            ->whereTitle('')
-            ->first();
+        $session = WebSocketDialogSession::whereDialogId($dialog->id)->whereTitle('')->first();
         if ($session) {
             $dialog->session_id = $session->id;
             $dialog->save();
diff --git a/resources/assets/js/pages/manage/components/Forwarder/confirm.vue b/resources/assets/js/pages/manage/components/Forwarder/confirm.vue
index 0dbacf2f0..1b221ad71 100644
--- a/resources/assets/js/pages/manage/components/Forwarder/confirm.vue
+++ b/resources/assets/js/pages/manage/components/Forwarder/confirm.vue
@@ -61,13 +61,19 @@
                         :disabled="loading"
                         clearable/>
                 </div>
+                <ul class="radio-group">
+                    <li v-if="aiUser.length > 0" :class="{selected: ainew}">
+                        <Icon @click="onAinew" class="radio-icon" :type="ainew ? 'ios-checkmark-circle' : 'ios-radio-button-off'"/>
+                        <span class="radio-label">{{ $L('AI开启新会话') }}</span>
+                    </li>
+                    <li v-if="!senderHidden" :class="{selected: !sender}">
+                        <Icon @click="onSender" class="radio-icon" :type="sender ? 'ios-radio-button-off' : 'ios-checkmark-circle'"/>
+                        <span class="radio-label">{{ $L('不显示原发送者信息') }}</span>
+                    </li>
+                </ul>
             </div>
         </div>
         <template #footer>
-            <div v-if="!senderHidden" class="forwarder-wrapper-footer" :class="{selected: !sender}" @click="onSender">
-                <Icon class="user-modal-icon" :type="sender ? 'ios-radio-button-off' : 'ios-checkmark-circle'" />
-                <span class="forward-text-tip">{{$L('不显示原发送者信息')}}</span>
-            </div>
             <Button type="primary" :loading="loading" @click="onSubmit">
                 {{$L('确定')}}
                 <template v-if="forwardTo.length > 0">({{forwardTo.length}})</template>
@@ -79,6 +85,7 @@
 <script>
 import DialogItem from "../DialogItem.vue";
 import ChatInput from "../ChatInput/index.vue";
+import {mapState} from "vuex";
 
 export default {
     components: {ChatInput, DialogItem},
@@ -128,12 +135,21 @@ export default {
             loading: false,
 
             message: '',    // 留言
-            sender: true,  // 是否隐藏原发送者信息
+            ainew: true,    // 是否AI开启新会话
+            sender: true,   // 是否隐藏原发送者信息
         }
     },
 
     computed: {
+        ...mapState(['cacheUserBasic']),
 
+        aiUser({forwardTo, cacheUserBasic}) {
+            const users = forwardTo.filter(item => item.type !== 'group');
+            return users.filter(user => {
+                const cachedUser = cacheUserBasic.find(item => item.userid === user.userid);
+                return cachedUser && cachedUser.bot && /^ai-(.*?)@bot\.system/.test(cachedUser.email);
+            });
+        }
     },
 
     watch: {
@@ -145,6 +161,7 @@ export default {
             if (!val) {
                 this.loading = false;
                 this.message = '';
+                this.ainew = true;
                 this.sender = true;
             }
         }
@@ -167,6 +184,13 @@ export default {
             this.$emit('on-other', ...args);
         },
 
+        onAinew() {
+            if (this.loading) {
+                return
+            }
+            this.ainew = !this.ainew
+        },
+
         onSender() {
             if (this.loading) {
                 return
@@ -174,7 +198,7 @@ export default {
             this.sender = !this.sender
         },
 
-        onSubmit() {
+        async onSubmit() {
             if (this.loading) {
                 return
             }
@@ -188,9 +212,17 @@ export default {
             if (!this.senderHidden) {
                 data.sender = this.sender
             }
+            //
+            this.loading = true
+            try {
+                await this.onAiNew()
+            } catch (e) {
+                this.loading = false
+                return
+            }
+            //
             const before = this.beforeSubmit(data);
             if (before && before.then) {
-                this.loading = true
                 before.then(() => {
                     this.hide()
                 }).catch(_ => {
@@ -199,10 +231,41 @@ export default {
                     this.loading = false
                 })
             } else {
+                this.loading = false
                 this.hide()
             }
         },
 
+        onAiNew() {
+            return new Promise((resolve, reject) => {
+                if (this.aiUser.length === 0 || !this.ainew) {
+                    return resolve();
+                }
+
+                const processQueue = async () => {
+                    try {
+                        for (const user of this.aiUser) {
+                            await this.$store.dispatch("call", {
+                                url: 'dialog/session/create',
+                                data: {
+                                    userid: user.userid,
+                                },
+                            });
+                        }
+                        resolve();
+                    } catch (error) {
+                        $A.modalError({
+                            language: false,
+                            content: this.$L("AI开启新会话失败") + `: ${error.msg || error}`,
+                        });
+                        reject(error);
+                    }
+                };
+
+                processQueue();
+            });
+        },
+
         hide() {
             this.show = false
         }
diff --git a/resources/assets/sass/pages/components/forwarder.scss b/resources/assets/sass/pages/components/forwarder.scss
index f885ab1a9..1929ed754 100644
--- a/resources/assets/sass/pages/components/forwarder.scss
+++ b/resources/assets/sass/pages/components/forwarder.scss
@@ -88,39 +88,42 @@
                             background: #f7f7f7;
                         }
                     }
-                }
-            }
-        }
 
-        .ivu-modal-footer {
-            display: flex;
-            justify-content: flex-end;
-            gap: 20px;
+                    .radio-group {
+                        z-index: 2;
+                        display: flex;
+                        flex-direction: column;
 
-            .forwarder-wrapper-footer {
-                flex: 1;
-                width: 0;
-                display: flex;
-                line-height: 34px;
-                cursor: pointer;
+                        > li {
+                            display: flex;
+                            align-items: center;
+                            line-height: 22px;
+                            margin-bottom: 8px;
 
-                .user-modal-icon {
-                    flex-shrink: 0;
-                    font-size: 22px;
-                    margin-right: 5px;
-                    color: rgba($primary-desc-color, 0.7);
-                    margin-top: 6px;
-                }
+                            .radio-icon {
+                                flex-shrink: 0;
+                                font-size: 22px;
+                                color: rgba($primary-desc-color, 0.7);
+                                cursor: pointer;
+                            }
 
-                .forward-text-tip {
-                    overflow: hidden;
-                    text-overflow: ellipsis;
-                    white-space: nowrap;
-                }
+                            .radio-label {
+                                padding-left: 6px;
+                                overflow: hidden;
+                                text-overflow: ellipsis;
+                                white-space: nowrap;
+                            }
 
-                &.selected {
-                    .user-modal-icon {
-                        color: $primary-color;
+                            &.selected {
+                                .radio-icon {
+                                    color: $primary-color;
+                                }
+                            }
+
+                            &:last-child {
+                                margin-bottom: 16px;
+                            }
+                        }
                     }
                 }
             }