commit

yxl

2025-02-19 3dc17dbcb1fb1d64c469deed1518d1817846b452

 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 @@
        // 将流中的字节数据解码为文本字符串

        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) {