diff --git a/src/components/dialoguePanel/DialogueFlow.vue b/src/components/dialoguePanel/DialogueFlow.vue index 2a101c1152f59827efdd39381d012dd0a9af691f..884ea2b85fc8a7472aceeefe672985f823b5b4ce 100644 --- a/src/components/dialoguePanel/DialogueFlow.vue +++ b/src/components/dialoguePanel/DialogueFlow.vue @@ -1,6 +1,7 @@ + + diff --git a/src/i18n/lang/en.ts b/src/i18n/lang/en.ts index 913e5d2e9275d9d6fa0f9deed185fbaab3c6b79b..bc98748d4d4662698a676c2f823e60f6e9833e3c 100644 --- a/src/i18n/lang/en.ts +++ b/src/i18n/lang/en.ts @@ -399,6 +399,8 @@ export default { output: 'Output', params: 'Parameters', supplementaryParameters: 'Additional Parameters', + parameterConfiguration: 'Parameter Configuration', + additionalNotes: 'Additional notes', }, pagination: { prev: 'Previous', diff --git a/src/i18n/lang/zh-cn.ts b/src/i18n/lang/zh-cn.ts index 922987cf630fa7038b49bcd8e7f17d55895ec47e..18e226d75c5986050724446680a91d239ceef71b 100644 --- a/src/i18n/lang/zh-cn.ts +++ b/src/i18n/lang/zh-cn.ts @@ -430,6 +430,8 @@ export default { output: '输出', params: '参数', supplementaryParameters: '补充参数', + parameterConfiguration: '参数配置', + additionalNotes: '补充说明', }, pagination: { prev: 'Previous', diff --git a/src/store/conversation.ts b/src/store/conversation.ts index bc60195513eeb400c13e447e95e7a562e41a3060..b8944187174bebb03bb022183d1f974b4f902ff5 100644 --- a/src/store/conversation.ts +++ b/src/store/conversation.ts @@ -230,6 +230,26 @@ export const useSessionStore = defineStore('conversation', () => { conversationItem.flowdata.status = flow.stepStatus; } }, + waitingForParam: ( + conversationItem: RobotConversationItem, + message: Record, + ) => { + const flow = (message.flow || {}) as Record; + const content = (message.content || {}) as Record; + conversationItem.flowdata = { + id: flow.stepId, + title: flow.stepName, + status: flow.stepStatus, + taskId: currentTaskId, + data: { + exParam: content, + }, + }; + if (conversationItem.flowdata) { + conversationItem.flowdata.progress = flow.stepProgress; + conversationItem.flowdata.status = flow.stepStatus; + } + }, flowCancel: ( conversationItem: RobotConversationItem, message: Record, @@ -317,6 +337,10 @@ export const useSessionStore = defineStore('conversation', () => { // 事件流等待开始 dataTransfers.waitingForStart(conversationItem, message); break; + case 'step.waiting_for_param': + // 事件流等待参数 + dataTransfers.waitingForParam(conversationItem, message); + break; case 'flow.cancel': // 事件流取消 dataTransfers.flowCancel(conversationItem, message); @@ -439,7 +463,7 @@ export const useSessionStore = defineStore('conversation', () => { ) => { await fetchEventSource(url, { ...fetchParams, - body: JSON.stringify({ taskId: currentTaskId.value, params: params.params }), + body: JSON.stringify({ taskId: currentTaskId.value, params: params }), openWhenHidden: true, }); }, @@ -527,7 +551,11 @@ export const useSessionStore = defineStore('conversation', () => { // 新的工作流调试记录 await funcFetch.fetchAppNew(streamUrl, params, pp, fetchParams); } else if (waitType) { - await funcFetch.fetchWait(streamUrl, params, pp, fetchParams); + if (waitType === 'params') { + await funcFetch.fetchWait(streamUrl, params, pp, fetchParams); + } else { + await funcFetch.fetchWait(streamUrl, params.params, pp, fetchParams); + } } else { await funcFetch.fetchDefault(streamUrl, params, pp, fetchParams); } @@ -851,7 +879,7 @@ export const useSessionStore = defineStore('conversation', () => { data: { input: record.steps[i].input, output: record.steps[i].output, - exData: record.steps[i].exData, + ...(record.steps[i].exData && { exData: record.steps[i].exData }), }, }); if (record.steps[i].stepStatus === 'cancelled') {