|
|
@ -756,8 +756,6 @@ async function handleSendMessage(input) { |
|
|
|
|
|
|
|
const result = await getReplyAPI(params); |
|
|
|
const response = await result.json(); // 解析返回的 JSON 数据 |
|
|
|
console.log("工作流接口返回数据:", response); |
|
|
|
|
|
|
|
// 解析 data 字段 |
|
|
|
const parsedData = JSON.parse(response.data); // 将字符串形式的 JSON 转换为对象 |
|
|
|
console.log("解析后的数据:", parsedData); |
|
|
@ -776,12 +774,6 @@ async function handleSendMessage(input) { |
|
|
|
code: parsedData.code, |
|
|
|
market: parsedData.market, |
|
|
|
}; |
|
|
|
console.log('======================================') |
|
|
|
|
|
|
|
// 取消自动滚动效果 |
|
|
|
// console.log('第二个工作流接口开始调用,立即开始缓慢滚动'); |
|
|
|
// startAutoScroll(); |
|
|
|
|
|
|
|
// 同时调用第二个数据流接口和fetchData方法 |
|
|
|
const [conclusionResult, fetchDataResult] = await Promise.all([ |
|
|
|
getConclusionAPI(conclusionParams), |
|
|
@ -797,13 +789,9 @@ async function handleSendMessage(input) { |
|
|
|
conclusionData.value = conclusionResponse.data; |
|
|
|
// 将结论数据存储到store中的当前激活股票 |
|
|
|
emotionStore.updateActiveStockConclusion(conclusionResponse.data); |
|
|
|
console.log("结论数据已存储到响应式变量和store中:", conclusionData.value); |
|
|
|
} |
|
|
|
|
|
|
|
console.log('------------------------------------') |
|
|
|
|
|
|
|
} else { |
|
|
|
ElMessage.error('工作流接口未返回非股票信息'); |
|
|
|
ElMessage.error(parsedData.refuse); |
|
|
|
} |
|
|
|
} catch (error) { |
|
|
|
ElMessage.error('请求工作流接口失败,请检查网络连接'); |
|
|
@ -812,7 +800,7 @@ async function handleSendMessage(input) { |
|
|
|
isRotating.value = false; |
|
|
|
} |
|
|
|
} else { |
|
|
|
ElMessage.error('消息发送失败,请检查网络连接'); |
|
|
|
ElMessage.error(parsedData.refuse); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
@ -857,17 +845,13 @@ async function fetchData(code, market, stockName, queryText) { |
|
|
|
conclusionData: conclusionData.value, // 包含结论数据 |
|
|
|
timestamp: new Date().toISOString() |
|
|
|
}; |
|
|
|
|
|
|
|
// 将股票数据添加到store中 |
|
|
|
emotionStore.addStock(stockData); |
|
|
|
|
|
|
|
console.log('股票数据已添加到store'); |
|
|
|
|
|
|
|
} else { |
|
|
|
ElMessage.error('获取接口数据失败'); |
|
|
|
ElMessage.error(stockDataResponse.refuse); |
|
|
|
} |
|
|
|
} catch (error) { |
|
|
|
ElMessage.error('获取接口数据失败。。。'); |
|
|
|
ElMessage.error(stockDataResponse.refuse); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
@ -1141,6 +1125,9 @@ onUnmounted(() => { |
|
|
|
} |
|
|
|
}); |
|
|
|
|
|
|
|
// 声明组件可以触发的事件 |
|
|
|
const emit = defineEmits(['updateMessage', 'sendMessage', 'ensureAIchat']); |
|
|
|
|
|
|
|
// 导出方法供外部使用 |
|
|
|
defineExpose({ |
|
|
|
handleSendMessage, |
|
|
|