From 3dc17dbcb1fb1d64c469deed1518d1817846b452 Mon Sep 17 00:00:00 2001
From: yxl <584911253@qq.com>
Date: 星期三, 19 二月 2025 09:49:50 +0800
Subject: [PATCH] commit

---
 src/views/chartView/index.vue |  104 +++++++++++++++++++++++++++++++++------------------
 1 files changed, 67 insertions(+), 37 deletions(-)

diff --git a/src/views/chartView/index.vue b/src/views/chartView/index.vue
index 0fd05cc..f4f4ec2 100644
--- a/src/views/chartView/index.vue
+++ b/src/views/chartView/index.vue
@@ -108,12 +108,6 @@
         this.setRagMoreList(res);
       }
     });
-    // axios.get("http://192.168.11.89:12315/Markdown.md").then((response) => {
-    //     if (response.status == 200) {
-    //       console.log(response);
-    //       this.setMarkDownInfo(response.data);
-    //     }
-    //   });
   },
   methods: {
     createSocket() {
@@ -251,11 +245,6 @@
       this.$store.state.setListColor = [];
       this.$store.state.showLenged = false;
       this.$store.state.showRelationBox = false;
-
-      // const formData = new FormData();
-      // formData.append("message", res);
-      // formData.append("lib_id", "No1");
-      // formData.append("session_id", this.uuid.toString());
       const formData = {
         message: res.replace(/\s+/g, ""),
         lib_id: "No1",
@@ -281,22 +270,6 @@
           this.setRagAgentIntention(obj, formData);
         }
       });
-
-      // var obj = {
-      //   ai: "",
-      //   create_time: msgData.getDate1(),
-      //   human: res,
-      //   sessionid: this.uuid,
-      //   update_time: "",
-      //   userid: 0,
-      // };
-      // getAgentThistorySave(obj).then((response) => {
-      //   if (response.code == 200) {
-      //     obj.id = response.id;
-      //     this.obj = obj;
-      //   }
-      //   this.setAgentIntention(obj, formData);
-      // });
     },
     //鍦板浘鐩稿叧闂瓟
     async setAgentIntention(obj, formData) {
@@ -425,8 +398,9 @@
         // 灏嗘祦涓殑瀛楄妭鏁版嵁瑙g爜涓烘枃鏈瓧绗︿覆
         const textDecoder = new TextDecoder();
         let result = true;
-        let sendMsg = true;
+        let thinkMsg = false;
         let sqlValue = "";
+        let afterText = "";
         while (result) {
           // done琛ㄧず娴佹槸鍚﹀凡缁忓畬鎴愯鍙�  value鍖呭惈璇诲彇鍒扮殑鏁版嵁鍧�
           const { done, value } = await reader.read();
@@ -441,25 +415,80 @@
           //鍖呭惈</think>缁х画杈撳嚭
           console.log(resText, "杩斿洖鐨勬暟鎹�");
           if (resText.indexOf("<think>") > -1) {
-            sendMsg = false;
-          }
-          if (resText.indexOf("</think>") > -1) {
-            sendMsg = true;
-            let position = resText.indexOf("</think>");
-            resText = resText.substring(position + "</think>".length);
-          }
-          if (sendMsg) {
+            resText = resText.replace(/<think>/, "");
+            thinkMsg = true;
             sqlValue += resText;
             var rolMsg = [
               {
                 type: "stream",
+                thinkMsg: thinkMsg,
                 val: marked(sqlValue),
               },
             ];
             this.refashMsg(rolMsg);
+          } else if (resText.indexOf("</think>") > -1) {
+            let position = resText.indexOf("</think>");
+            //</think>涔嬪墠鐨勫唴瀹�
+            const beforeText = resText.substring(0, position);
+            //鍒锋柊
+            sqlValue += beforeText;
+            var rolMsg = [
+              {
+                type: "stream",
+                thinkMsg: thinkMsg,
+                val: marked(sqlValue),
+              },
+            ];
+            this.refashMsg(rolMsg);
+            thinkMsg = false;
+            // </think>涔嬪悗鐨勫唴瀹�
+            const afterT = resText.substring(position + "</think>".length);
+            //鍒锋柊
+            if (afterT) {
+              afterText += afterT;
+              var rolMsg = [
+                {
+                  type: "stream",
+                  thinkMsg: true,
+                  val: marked(sqlValue),
+                },
+                {
+                  type: "stream",
+                  thinkMsg: false,
+                  val: marked(afterText),
+                },
+              ];
+              this.refashMsg(rolMsg);
+            }
+          } else {
+            if (thinkMsg) {
+              sqlValue += resText;
+              var rolMsg = [
+                {
+                  type: "stream",
+                  thinkMsg: thinkMsg,
+                  val: marked(sqlValue),
+                },
+              ];
+              this.refashMsg(rolMsg);
+            } else {
+              afterText += resText;
+              var rolMsg = [
+                {
+                  type: "stream",
+                  thinkMsg: true,
+                  val: marked(sqlValue),
+                },
+                {
+                  type: "stream",
+                  thinkMsg: false,
+                  val: marked(afterText),
+                },
+              ];
+              this.refashMsg(rolMsg);
+            }
           }
         }
-        // console.log(sqlValue, "杈撳嚭鎵�鏈夎繑鍥炴暟鎹�");
       } catch (err) {
         var rolMsg = [
           {
@@ -470,6 +499,7 @@
         this.refashMsg(rolMsg);
       }
     },
+
     setMapfunc(res, obj) {
       this.$store.state.showLenged = false;
       switch (res.func) {

--
Gitblit v1.9.3