zoujing/YGChatCS
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: 对网络请求的调整优化处理

Browse Source
This commit is contained in:
zoujing
2025-07-22 22:33:27 +08:00
parent e6b9407e69
commit bad3b2987d
8 changed files with 99 additions and 121 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
manager/LoginManager.js
View File

@@ -1,4 +1,4 @@
import { login } from "../request/api/Index";
import { login } from "../request/api/LoginApi";
import { getWeChatAuthCode } from "./AuthManager";
@@ -12,7 +12,8 @@ export async function loginAuth() {
scope: 'server',
//clientId: '1',
username: 'admin',
password: 'YehdBPev'
password: 'YehdBPev',
});
if (response.access_token) {
uni.setStorageSync('token', response.access_token)

3
pages/chat/ChatMainList.vue
View File

@@ -74,6 +74,7 @@
import OneFeelMK001 from '../module/OneFeelMK001.vue';
import request from '../../request/base/request';
import { agentChatStream } from '../../request/api/AgentChatStream';
// 导航栏相关
const statusBarHeight = ref(20);
@@ -225,7 +226,7 @@
}
// 2. 流式接收内容
request.getAIChatStream(args, (chunk) => {
agentChatStream(args, (chunk) => {
console.log('分段内容:', chunk)
if (chunk && chunk.content) {
// 收到内容，停止动画

21
pages/drawer/DrawerHome.vue
View File

@@ -22,8 +22,7 @@
const emits = defineEmits(['closeDrawer'])
import * as loginMnager from '@/manager/LoginManager'
import { getAgentChatMessage } from '@/request/api/AgentChatApi.js'
import request from '../../request/base/request'
import request from '../../request/base/request'
const closeDrawer = () => {
emits('closeDrawer')
@@ -44,24 +43,6 @@ import request from '../../request/base/request'
// 这里可以处理登录逻辑，比如调用登录接口等
}
const sendChat = () => {
console.log('=============会话测试')
const args = {
"conversationId":"1931957498711957505",
"agentId":"1",
"messageType": 0,
"messageContent":"酒店一共有哪些温泉？"
}
request.getAIChatStream(args, (chunk) => {
// 每收到一段数据都会回调
console.log('分段内容:', chunk)
// 你可以在这里追加到消息列表
})
}
</script>

19
request/api/AgentChatApi.js
View File

@@ -1,19 +0,0 @@
import request from "../base/request";
function getAgentChatMessage() {
const args = {
"conversationId":"1931957498711957505",
"agentId":"1",
"messageType": 0,
"messageContent":"酒店一共有哪些温泉？"
}
const defaultConfig = {
header: {
Accept: 'text/event-stream',
'Content-Type': 'application/json'
},
};
return request.post('/agent/assistant/chat', args, defaultConfig);
}
export { getAgentChatMessage }

79
request/api/AgentChatStream.js Normal file
View File

@@ -0,0 +1,79 @@
import { BASE_URL } from "../../constant/base";
/// 请求流式数据的API
const API = '/agent/assistant/chat';
/**
* 获取AI聊天流式信息（仅微信小程序支持）
* @param {Object} params 请求参数
* @param {Function} onChunk 回调，每收到一段数据触发
* @returns {Promise}
*/
function agentChatStream(params, onChunk) {
return new Promise((resolve, reject) => {
const token = uni.getStorageSync('token');
console.log("发送请求内容: ", params)
// #ifdef MP-WEIXIN
const requestTask = uni.request({
url: BASE_URL + API, // 替换为你的接口地址
method: 'POST',
data: params,
enableChunked: true,
header: {
Accept: 'text/event-stream',
'Content-Type': 'application/json',
Authorization: `Bearer ${token}`, // 如需token可加
},
responseType: 'arraybuffer',
success(res) {
resolve(res.data);
},
fail(err) {
reject(err);
}
});
requestTask.onHeadersReceived(res => {
console.log('onHeadersReceived', res);
});
requestTask.onChunkReceived(res => {
const base64 = uni.arrayBufferToBase64(res.data);
let data = '';
try {
data = decodeURIComponent(escape(atob(base64)));
} catch (e) {
// 某些平台可能不支持 atob，可以直接用 base64
data = base64;
}
const messages = parseSSEChunk(data);
messages.forEach(msg => {
if (onChunk) onChunk(msg);
});
});
// #endif
});
}
// 解析SSE分段数据
function parseSSEChunk(raw) {
// 拆分为多段
const lines = raw.split('\n\n');
const results = [];
lines.forEach(line => {
// 只处理包含 data: 的行
const dataMatch = line.match(/data:(\{.*\})/);
if (dataMatch && dataMatch[1]) {
try {
const obj = JSON.parse(dataMatch[1]);
results.push(obj);
} catch (e) {
// 解析失败忽略
}
}
});
return results;
}
export { agentChatStream }

1
request/api/Index.js
View File

@@ -1 +0,0 @@
export * from './LoginApi.js'

9
request/api/LoginApi.js
View File

@@ -1,7 +1,14 @@
import request from "../base/request";
function login(args) {
return request.post('/auth/oauth2/token', args);
const config = {
header: {
Authorization: 'Basic Y3VzdG9tOmN1c3RvbQ==', // 可在此动态设置 token
'Content-Type': 'application/x-www-form-urlencoded'
},
};
uni.setStorageSync('token', '')
return request.post('/auth/oauth2/token', args, config);
}
export { login }

81
request/base/request.js
View File

@@ -2,8 +2,8 @@ import { BASE_URL } from "../../constant/base";
const defaultConfig = {
header: {
Authorization: 'Basic Y3VzdG9tOmN1c3RvbQ==', // 可在此动态设置 token
'Content-Type': 'application/x-www-form-urlencoded'
Authorization: '', // 可在此动态设置 token
'Content-Type': 'application/json'
},
};
@@ -35,6 +35,7 @@ function request(url, args = {}, method = 'POST', customConfig = {}) {
...customConfig,
header
};
console.log("请求接口:" + url)
console.log("请求头:" + JSON.stringify(config))
console.log("请求参数:" + JSON.stringify(args))
@@ -63,81 +64,9 @@ request.post = function(url, args = {}, config = {}) {
};
// 支持 GET
request.get = function(url, args = {}) {
return request(url, args, 'GET');
request.get = function(url, args = {}, config = {}) {
return request(url, args, 'GET', config);
};
/**
* 获取AI聊天流式信息（仅微信小程序支持）
* @param {Object} params 请求参数
* @param {Function} onChunk 回调，每收到一段数据触发
* @returns {Promise}
*/
request.getAIChatStream = function(params, onChunk) {
return new Promise((resolve, reject) => {
const token = uni.getStorageSync('token');
console.log("发送请求内容: ", params)
// #ifdef MP-WEIXIN
const requestTask = uni.request({
url: BASE_URL + '/agent/assistant/chat', // 替换为你的接口地址
method: 'POST',
data: params,
enableChunked: true,
header: {
Accept: 'text/event-stream',
'Content-Type': 'application/json',
Authorization: `Bearer ${token}`, // 如需token可加
},
responseType: 'arraybuffer',
success(res) {
resolve(res.data);
},
fail(err) {
reject(err);
}
});
requestTask.onHeadersReceived(res => {
console.log('onHeadersReceived', res);
});
requestTask.onChunkReceived(res => {
const base64 = uni.arrayBufferToBase64(res.data);
let data = '';
try {
data = decodeURIComponent(escape(atob(base64)));
} catch (e) {
// 某些平台可能不支持 atob，可以直接用 base64
data = base64;
}
const messages = parseSSEChunk(data);
messages.forEach(msg => {
if (onChunk) onChunk(msg);
});
});
// #endif
});
}
// 解析SSE分段数据
function parseSSEChunk(raw) {
// 拆分为多段
const lines = raw.split('\n\n');
const results = [];
lines.forEach(line => {
// 只处理包含 data: 的行
const dataMatch = line.match(/data:(\{.*\})/);
if (dataMatch && dataMatch[1]) {
try {
const obj = JSON.parse(dataMatch[1]);
results.push(obj);
} catch (e) {
// 解析失败忽略
}
}
});
return results;
}
export default request;