xunfeiAI/pages/index/index.vue

<template>
  <view class="wrapper">
    <view class="tips color_fff size_12 align_c" :class="{ 'show':ajax.loading }" @tap="getHistoryMsg">{{ajax.loadText}}
    </view>
    <view class="placeholder"></view>
    <view class="box-1" id="list-box" ref="box">
      <view class="talk-list">
        <scroll-view :scroll-y="true" style="height: 100%;overflow: hidden;" :scroll-top="scrollTop"
				:scroll-with-animation="true" @scrolltoupper="bindScroll">
        <view v-for="(item,index) in talkList" :key="index" :id="`msg-${item.id}`">
          <view class="item flex_col" :class=" item.type == 1 ? 'push':'pull' ">
            <image :src="item.pic" mode="aspectFill" class="pic"></image>
            <view v-if="talkList.length-1==index" class="content multiline-text">
              <!-- <rich-text :nodes="item.content"></rich-text> -->
              <bing-math v-if="c_content!=''" :key="`math-${item.id}`" class="bing-math" :latex="c_content"></bing-math>
              <view v-else class="blinking-box">|</view>
            </view>
            <view v-else class="content multiline-text">
              <!-- <rich-text :nodes="item.content"></rich-text> -->
              <bing-math :key="`math-${item.id}`" class="bing-math" :latex="item.content"></bing-math>
            </view>
          </view>
        </view>
        </scroll-view>
      </view>
    </view>
    <view class="box-2">
      <view class="flex_col">
        <view class="flex_grow">
          <input type="text" class="content" v-model="content" placeholder="请输入聊天内容" @focus="focus" @confirm="send"
            placeholder-style="color:#DDD;" :cursor-spacing="6">
        </view>
        <button class="send" @tap="send">发送</button>
      </view>
    </view>
    <!-- <view v-show="showplc" :style="{'min-height': (keyboardHeight+200)+'px'}" class="placeholder">显示</view> -->
  </view>
</template>

<script>
  import * as base64 from "base-64"
  import CryptoJS from '../../static/crypto-js/crypto-js.js'
  import parser from '../../static/fast-xml-parser/src/parser'
  import * as utf8 from "utf8"
  import fetch from 'miniprogram-fetch';
  import axios from 'axios';
  import BingMath from "@/components/bing-math/bing-math.vue"
  export default {
    components: {
      'bing-math': BingMath
    },
    data() {
      return {
        talkList: [],
        ajax: {
          rows: 20, //每页数量
          page: 1, //页码
          flag: false, // 请求开关
          loading: false, // 加载中
          loadText: '正在获取消息'
        },
        keyboardHeight: 0,
        showplc: true,
        content: '',
        c_content: '',
        n_content: '',
        timer: '',
        socketTask: {},
        TEXT: '',
        historyTextList: [], // 历史会话信息，由于最大token12000,可以结合实际使用，进行移出
        tempRes: '', // 临时答复保存
        scrollTop: 0
      }
    },
    mounted() {
      this.$nextTick(() => {
        this.getHistoryMsg();
      });
      uni.onKeyboardHeightChange(e => {
        let h = this.keyboardHeight;
        this.keyboardHeight = e.height;
        if(e.height==0)h *= -1;
        else h = e.height;
        uni.createSelectorQuery().selectViewport().scrollOffset(function(res) {
          let scrollTop = res.scrollTop; // 页面滚动距离
          // let os = uni.getSystemInfoSync();
          // // 可视窗口高度 = 设备可使用高度 - 状态栏高度 - 导航栏高度
          // const viewportHeight = os.windowHeight - os.statusBarHeight - (os.platform == "android" ? 50 : 45)-10;
          // if(scrollTop<viewportHeight)scrollTop=viewportHeight;
          scrollTop+=h;
          uni.pageScrollTo({
            scrollTop: scrollTop, // 当前位置向下滚动
            duration: 0 // 滚动过渡时间为300ms，默认值为300ms
          });
        }).exec();
      })
    },
    beforeDestroy() {
      // #ifdef APP-PLUS
      uni.offKeyboardHeightChange();
      // #endif
    },
    onPageScroll(e) {
      if (e.scrollTop < 5) {
        this.getHistoryMsg();
      }
    },
    watch: {
      n_content(n, o) {
        // this.c_content = n;
        if (this.timer) clearInterval(this.timer);
        let cl = this.c_content.length;
        let nc = this.n_content.split('')
        this.timer = setInterval(() => {
          if (cl < nc.length) {
            this.c_content += nc[cl];
            cl++;
            if (cl % 6 == 0) this.$nextTick(()=>{
              uni.pageScrollTo({
                scrollTop: 999999,
              })
            })
          } else {
            clearInterval(this.timer);
            this.$nextTick(() => {
              uni.pageScrollTo({
                scrollTop: 9999999,
              })
            })
          }
        }, 60)
      }
    },
    methods: {
      copyText(str) {
        uni.setClipboardData({
          data: str,
          success: function() {
            uni.showToast({
              icon: 'none',
              title: '复制成功'
            });
          }
        });
      },
      // 获取历史消息
      getHistoryMsg() {
        if (!this.ajax.flag) {
          return; //
        }

        let get = async () => {
          this.hideLoadTips();
          this.ajax.flag = false;
          let data = await this.joinHistoryMsg();

          console.log('----- 模拟数据格式，供参考 -----');
          console.log(data); // 查看请求返回的数据结构 

          // 获取待滚动元素选择器，解决插入数据后，滚动条定位时使用
          let selector = '';

          if (this.ajax.page > 1) {
            // 非第一页，则取历史消息数据的第一条信息元素
            selector = `#msg-${this.talkList[0].id}`;
          } else {
            // 第一页，则取当前消息数据的最后一条信息元素
            selector = `#msg-${data[data.length-1].id}`;
          }

          // 将获取到的消息数据合并到消息数组中
          this.talkList = [...data, ...this.talkList];

          // 数据挂载后执行，不懂的请自行阅读 Vue.js 文档对 Vue.nextTick 函数说明。
          this.$nextTick(() => {
            // 设置当前滚动的位置
            this.setPageScrollTo(selector);

            this.hideLoadTips(true);

            if (data.length < this.ajax.rows) {
              // 当前消息数据条数小于请求要求条数时，则无更多消息，不再允许请求。
              // 可在此处编写无更多消息数据时的逻辑
            } else {
              this.ajax.page++;

              // 延迟 200ms ，以保证设置窗口滚动已完成
              setTimeout(() => {
                this.ajax.flag = true;
              }, 200)
            }

          })
        }
        get();
      },
      // 拼接历史记录消息
      joinHistoryMsg() {
        let join = () => {
          let arr = [];

          //通过当前页码及页数，模拟数据内容
          let startIndex = (this.ajax.page - 1) * this.ajax.rows;
          let endIndex = startIndex + this.ajax.rows;
          for (let i = startIndex; i < endIndex; i++) {
            arr.push({
              "id": i, // 消息的ID
              "content": `这是历史记录的第${i+1}条消息`, // 消息内容
              "type": Math.random() > 0.5 ? 1 : 0, // 此为消息类别，设 1 为发出去的消息，0 为收到对方的消息,
              "pic": "/static/avatar.png" // 头像
            })
          }

          /*
          	颠倒数组中元素的顺序。将最新的数据排在本次接口返回数据的最后面。
          	后端接口按 消息的时间降序查找出当前页的数据后，再将本页数据按消息时间降序排序返回。
          	这是数据的重点，因为页面滚动条和上拉加载历史的问题。
           */
          arr.reverse();

          return arr;
        }

        // 此处用到 ES6 的 Promise 知识，不懂的请自行学习。
        return new Promise((done, fail) => {
          // 无数据请求接口，由 setTimeout 模拟，正式项目替换为 ajax 即可。
          setTimeout(() => {
            let data = join();
            done(data);
          }, 1500);
        })
      },
      focus(){
        uni.pageScrollTo({
          top: this.keyboardHeight
        })
      },
      // 设置页面滚动位置
      setPageScrollTo(selector) {
        let view = uni.createSelectorQuery().in(this).select(selector);
        view.boundingClientRect((res) => {
          uni.pageScrollTo({
            scrollTop: res.top - 30, // -30 为多显示出大半个消息的高度，示意上面还有信息。
            duration: 0
          });
        }).exec();
      },
      // 隐藏加载提示
      hideLoadTips(flag) {
        if (flag) {
          this.ajax.loadText = '消息获取成功';
          setTimeout(() => {
            this.ajax.loading = false;
          }, 300);
        } else {
          this.ajax.loading = true;
          this.ajax.loadText = '正在获取消息';
        }
      },
      // 发送信息
      send() {
        if (!this.content) {
          uni.showToast({
            title: '请输入有效的内容',
            icon: 'none'
          })
          return;
        }
        try{
          clearInterval(this.timer);
          this.talkList[this.talkList.length-1].content = this.c_content+'';
          this.c_content = '';
          this.n_content = '';
          this.socketTask.close({
            success:(res)=> {
              console.log('关闭成功', res);
              this.wsLiveFlag = false;
            },
            fail(err) {
              console.log('关闭失败', err)
            }
          })
        }catch(e){
          //TODO handle the exception
        }
        // 将当前发送信息 添加到消息列表。
        let data = {
          "id": new Date().getTime(),
          "content": this.content,
          "type": 1,
          "pic": "/static/avatar.png"
        }
        this.TEXT = this.content;
        this.n_content = '';
        this.c_content = '';
        this.talkList.push(data);
        this.talkList.push({
          "id": new Date().getTime(),
          "content": '',
          "type": 2,
          "pic": "/static/avatar.png"
        });
        // return ;
        this.$nextTick(() => {
          // 清空内容框中的内容
          this.content = '';
          uni.pageScrollTo({
            scrollTop: 999999, // 设置一个超大值，以保证滚动条滚动到底部
            duration: 0
          });
        })
        this.sendToSpark();
        
      },
      async sendToSpark() {
        // let myUrl = await this.getWebSocketUrl();
        this.tempRes = "";
        let realThis = this;
        this.socketTask = uni.connectSocket({
          //url: encodeURI(encodeURI(myUrl).replace(/\+/g, '%2B')),
          url: 'wss://chat.lihaink.cn/chat',
          method: 'GET',
          success: res => {
            console.log(res, "ws成功连接...")
            realThis.wsLiveFlag = true;
          }
        })
        realThis.socketTask.onError((res) => {
          console.log("连接发生错误，请检查appid是否填写", res)
        })
        realThis.socketTask.onOpen((res) => {
          this.historyTextList.push({
            "role": "user",
            "content": this.TEXT
          })
          // 第一帧..........................................
          console.log('连接成功...')
          // let params = {
          //   "header": {
          //     "app_id": this.APPID,
          //     "uid": "aef9f963-7"
          //   },
          //   "parameter": {
          //     "chat": {
          //       "domain": "generalv2",
          //       "temperature": 0.5,
          //       "max_tokens": 1024
          //     }
          //   },
          //   "payload": {
          //     "message": {
          //       "text": this.historyTextList
          //     }
          //   }
          // };
          let params = this.TEXT
          realThis.socketTask.send({ // 发送消息，，都用uni的官方版本
            data: JSON.stringify(params),
            success() {
              console.log('第一帧发送成功')
            }
          });
        });

        // 接受到消息时
        realThis.socketTask.onMessage((res) => {
          console.log('收到API返回的内容：', res.data);
          let obj = JSON.parse(res.data)
          // console.log("我打印的"+obj.payload);
          let dataArray = obj.payload.choices.text;
          for (let i = 0; i < dataArray.length; i++) {
            this.talkList[this.talkList.length - 1].content += dataArray[i].content;
            this.n_content = this.talkList[this.talkList.length - 1].content;
            realThis.tempRes = realThis.tempRes + dataArray[i].content
          }
          let temp = JSON.parse(res.data)
          // console.log("0726",temp.header.code)
          if (temp.header.code !== 0) {
            console.log(`${temp.header.code}:${temp.message}`);
            realThis.socketTask.close({
              success(res) {
                console.log('关闭成功', res)
                realThis.wsLiveFlag = false;
              },
              fail(err) {
                console.log('关闭失败', err)
              }
            })
          }
          if (temp.header.code === 0) {
            if (res.data && temp.header.status === 2) {
              this.historyTextList.push({
                "role": "assistant",
                "content": this.tempRes
              })
              setTimeout(() => {
                realThis.socketTask.close({
                  success(res) {
                    console.log('关闭成功', res)
                  },
                  fail(err) {
                    // console.log('关闭失败', err)
                  }
                })
              }, 1000)
            }
          }
        })
      },
      // 鉴权
      getWebSocketUrl() {
        return new Promise((resolve, reject) => {
          // https://spark-api.xf-yun.com/v1.1/chat  V1.5 domain general
          // https://spark-api.xf-yun.com/v2.1/chat  V2.0 domain generalv2
          var url = "wss://spark-api.xf-yun.com/v2.1/chat";
          var host = "spark-api.xf-yun.com";
          var apiKeyName = "api_key";
          var date = new Date().toGMTString();
          var algorithm = "hmac-sha256";
          var headers = "host date request-line";
          var signatureOrigin = `host: ${host}\ndate: ${date}\nGET /v2.1/chat HTTP/1.1`;
          var signatureSha = CryptoJS.HmacSHA256(signatureOrigin, this.APISecret);
          var signature = CryptoJS.enc.Base64.stringify(signatureSha);
          var authorizationOrigin =
            `${apiKeyName}="${this.APIKey}", algorithm="${algorithm}", headers="${headers}", signature="${signature}"`;
          var authorization = base64.encode(authorizationOrigin);
          url = `${url}?authorization=${authorization}&date=${encodeURI(date)}&host=${host}`;

          // console.log(url)
          resolve(url);
        });
      },
      // 滚动到头部
      bindScroll() {
      	if (this.userId == 0) {
      		this.getHistory();
      		this.getproductInfo();
      		this.getOrderInfo();
      		this.getRefundDetail();
      		this.getStoreDetail();
      	} else {
      		this.getMerHistory();
      	}
      },
    }
  }
</script>

<style lang="scss">
  @import "../../lib/global.scss";

  page {
    background-color: #f5f5f5;
    font-size: 28rpx;
  }
  
  @keyframes blink {
    0% { opacity: 1; }
    50% { opacity: 0; }
    100% { opacity: 1; }
  }
  
  .blinking-box {
    background-color: #333;
    color: #333;
    animation: blink 1s infinite;
    width: 2px;
    overflow: hidden;
  }

  .wrapper {
    height: auto !important;
  }

  /* 加载数据提示 */
  .tips {
    position: fixed;
    left: 0;
    top: var(--window-top);
    width: 100%;
    z-index: 9;
    background-color: rgba(0, 0, 0, 0.15);
    height: 72rpx;
    line-height: 72rpx;
    transform: translateY(-80rpx);
    transition: transform 0.3s ease-in-out 0s;

    &.show {
      transform: translateY(0);
    }
  }

  .box-1 {
    width: 100%;
    height: auto;
    padding-bottom: 100rpx;
    box-sizing: content-box;

    /* 兼容iPhoneX */
    margin-bottom: 0;
    margin-bottom: constant(safe-area-inset-bottom);
    margin-bottom: env(safe-area-inset-bottom);
  }

  .multiline-text {
    white-space: pre-line;
    /* 或 white-space: pre-wrap; */
  }

  .box-2 {
    position: fixed;
    left: 0;
    width: 100%;
    bottom: 0;
    height: auto;
    z-index: 2;
    border-top: #e5e5e5 solid 1px;
    box-sizing: content-box;
    background-color: #f5f5f5;
    transform: translateY(0); /* 初始化 transform 属性 */
    transition: transform 0.3s ease; /* 添加过渡效果 */

    /* 兼容iPhoneX */
    padding-bottom: 0;
    padding-bottom: constant(safe-area-inset-bottom);
    padding-bottom: env(safe-area-inset-bottom);

    >view {
      padding: 0 20rpx;
      height: 100rpx;
    }

    .content {
      background-color: #fff;
      height: 64rpx;
      padding: 0 20rpx;
      border-radius: 6rpx;
      font-size: 28rpx;
    }

    .send {
      background-color: #2573fb;
      color: #fff;
      height: 64rpx;
      margin-left: 20rpx;
      border-radius: 6rpx;
      padding: 0;
      width: 120rpx;
      line-height: 62rpx;

      &:active {
        background-color: #1573fb;
      }
    }
  }

  .talk-list {
    padding-bottom: 20rpx;

    /* 消息项，基础类 */
    .item {
      padding: 20rpx 20rpx 0 20rpx;
      align-items: flex-start;
      align-content: flex-start;
      color: #333;

      .pic {
        width: 92rpx;
        height: 92rpx;
        border-radius: 50%;
        border: #fff solid 1px;
      }

      .content {
        padding: 20rpx;
        border-radius: 4px;
        max-width: 500rpx;
        word-break: break-all;
        line-height: 52rpx;
        position: relative;
      }

      /* 收到的消息 */
      &.pull {
        .content {
          min-width: 20rpx;
          min-height: 52rpx;
          margin-left: 32rpx;
          background-color: #fff;

          &::after {
            content: '';
            display: block;
            width: 0;
            height: 0;
            border-top: 16rpx solid transparent;
            border-bottom: 16rpx solid transparent;
            border-right: 20rpx solid #fff;
            position: absolute;
            top: 30rpx;
            left: -18rpx;
          }
        }
      }

      /* 发出的消息 */
      &.push {
        /* 主轴为水平方向，起点在右端。使不修改DOM结构，也能改变元素排列顺序 */
        flex-direction: row-reverse;

        .content {
          min-width: 20rpx;
          min-height: 52rpx;
          margin-right: 32rpx;
          background-color: #2573fb;
          color: #fff;

          &::after {
            content: '';
            display: block;
            width: 0;
            height: 0;
            border-top: 16rpx solid transparent;
            border-bottom: 16rpx solid transparent;
            border-left: 20rpx solid #2573fb;
            position: absolute;
            top: 30rpx;
            right: -18rpx;
          }
        }
      }
    }
  }

  .bing-math {
    margin: 0 !important;
    padding: 0 !important;
  }
  .placeholder {
    width: 100vw;
    background-color: #1573fb;
    // background-color: transparent;
    // transform: translateY(0); /* 初始化 transform 属性 */
    // transition: transform 0.3s ease; /* 添加过渡效果 */
  }
</style>