|
|
@@ -170,6 +170,7 @@
|
|
|
enableChunked: true, // 启用流式接收
|
|
|
responseType:'text',
|
|
|
success: (res) => {
|
|
|
+ console.log(res,'res');
|
|
|
if (res.statusCode === 200) {
|
|
|
this._handleSuccess(res.data);
|
|
|
resolve();
|
|
|
@@ -178,6 +179,7 @@
|
|
|
}
|
|
|
},
|
|
|
fail: (err) => {
|
|
|
+ console.log(err,'err');
|
|
|
this._handleError(err.errMsg, resolve, reject);
|
|
|
},
|
|
|
complete: (com) => {
|
|
|
@@ -189,6 +191,7 @@
|
|
|
const uint8Array = new Uint8Array(res.data);
|
|
|
const decoder = new TextEncoding.TextDecoder("utf-8");
|
|
|
const decodedString = decoder.decode(uint8Array);
|
|
|
+ console.log(decodedString,'decodedString');
|
|
|
try {
|
|
|
let newtext = decodedString.replaceAll('data:','').replaceAll(':keepAlive','');
|
|
|
let ntArr = newtext.split('\n\n');
|
|
|
@@ -198,7 +201,7 @@
|
|
|
let nj = JSON.parse(n);
|
|
|
if(nj.event=='message'){
|
|
|
this.conversation_id = nj.conversation_id;
|
|
|
- let answer = this.dialogList[this.dialogList.length-1].answer+nj.answer?.replace(/(\r\n|\n|\r)+/g, '<br>');
|
|
|
+ let answer = this.dialogList[this.dialogList.length-1].answer+nj.answer?.replace(/(\r\n|\n|\r)+/g, '<br>').replace(/<think>.*?<\/think>/gs, '');
|
|
|
this.$set(this.dialogList[this.dialogList.length-1],'answer',answer);
|
|
|
this.$set(this.dialogList[this.dialogList.length-1],'id',nj.id);
|
|
|
this.$set(this.dialogList[this.dialogList.length-1],'task_id',nj.task_id);
|