Compare commits

...

10 Commits

Author SHA1 Message Date
80824c0381 fix: 分支节点级联选择修复 2026-05-13 11:43:32 +08:00
6d18c510b8 feat: 调整失焦的问题的 2026-04-20 15:21:15 +08:00
57d2686738 fix: 删除节点移除错误 2026-04-17 15:07:36 +08:00
9d3ed51349 Merge branch 'refactor_flow' into 'dev'
Refactor flow

See merge request smart_bench/cmvr-iot-ui!1
2026-04-17 09:13:16 +08:00
a3b014f648 feat: 单节点启动 2026-04-17 09:07:20 +08:00
3be16102a3 feat: 商道智能体 2026-04-16 14:37:27 +08:00
4255c31b79 feat: 更改验证方式 2026-04-16 10:37:55 +08:00
0093f28d1d feat: 更改验证方式 2026-04-16 10:37:43 +08:00
9ccf62abd4 feat: 商道智能体 2026-04-16 09:32:52 +08:00
7f2f308057 feat: 增加整体运行时长 2026-04-15 16:33:11 +08:00
9 changed files with 969 additions and 112 deletions

View File

@ -342,5 +342,29 @@ export const transformHttpNodeData = (source) => {
}
});
return result;
}
export const transformSdAgentNodeData = (source) => {
// 初始化结果对象
const result = {};
// 遍历每一个顶级节点
source.forEach(item => {
const { name, children } = item;
if (!name) return; // 过滤无name的无效节点
// 处理普通节点config/headers/params直接取 children 数组
if (name !== 'invokeTts') {
result[name] = children || [];
return;
}
// 专门处理 tts 节点(特殊结构)
if (name === 'invokeTts') {
result.invokeTts = item.input;
}
});
return result;
}

View File

@ -5,11 +5,17 @@
<img :src="imageUrl()" alt="" />
<div class="text__container">
<div class="text__title" v-if="showTextTitle">
<span class="text">{{ nodeName }}</span>
<el-icon class="editIcon" @click="showTextTitle = false"><EditPen/></el-icon>
<span class="text">{{ localName }}</span>
<el-icon class="editIcon" @click="startEditing"><EditPen/></el-icon>
</div>
<div class="input_name_container" v-else>
<el-input v-model="nodeName" @keydown="handleInputKeydown" />
<div class="input_name_container" v-else >
<el-input
v-model="localName"
@focus="handleInputFocus"
@keydown="handleInputKeydown"
@click.stop
@mousedown.stop
/>
<el-button
class="input_name_select"
circle
@ -42,19 +48,6 @@
</el-icon>
</el-button>
</el-tooltip>
<!-- <el-tooltip
class="box-item"
effect="dark"
:content="zoomState ? '缩小' : '放大'"
placement="top"
>
<el-button v-if="showZoom" circle @click="zoom">
<el-icon>
<ZoomOut v-if="zoomState" />
<ZoomIn v-else />
</el-icon>
</el-button>
</el-tooltip> -->
<el-tooltip
class="box-item"
effect="dark"
@ -71,10 +64,11 @@
</div>
</template>
<script setup lang="js">
import { ref } from 'vue'
import { EditPen, Select, CloseBold, Delete, ZoomOut, ZoomIn, VideoPlay } from '@element-plus/icons-vue'
import { onUnmounted, ref } from 'vue'
import { EditPen, Select, CloseBold, Delete, VideoPlay } from '@element-plus/icons-vue'
import { ElMessageBox } from 'element-plus'
import { computed } from 'vue'
import { emitter } from "@/utils/eventBus";
const props = defineProps({
icon: {
@ -101,28 +95,25 @@ const props = defineProps({
type: String,
default: ''
},
showZoom: {
type: Boolean,
default: true
},
zoomState: {
type: Boolean,
default: false
}
})
const emits = defineEmits(['zoom', 'setNodeName'])
const emits = defineEmits(['setNodeName'])
const showTextTitle = ref(true)
const nodeName = ref(props.nodeProperties.name || props.nodeName)
const localName = ref('')
//
const startEditing = () => {
showTextTitle.value = false
}
const confirmNodeName = () => {
emits('setNodeName', nodeName.value)
emits('setNodeName', localName.value)
showTextTitle.value = true
}
const cancelNodeName = () => {
nodeName.value = props.nodeProperties?.name || props.nodeName
localName.value = props.nodeProperties?.name || props.nodeName
showTextTitle.value = true
}
@ -145,13 +136,10 @@ const deleteNode = () => {
})
}
lf.deleteNode(props.nodeId);
emitter.emit('deleteNode', props.nodeId);
})
}
const zoom = () => {
emits('zoom', !props.zoomState)
}
const execute = () => {
const myEvent = new CustomEvent('singleNodeExecution', {
bubbles: false, // false
@ -161,6 +149,13 @@ const execute = () => {
document.dispatchEvent(myEvent);
}
const handleInputFocus = (e) => {
// LogicFlow
e.stopPropagation()
e.preventDefault()
}
const handleInputKeydown = (e) => {
// Logic Flow
e.stopPropagation();
@ -173,6 +168,15 @@ const handleInputKeydown = (e) => {
const imageUrl = () => {
return new URL(props.icon, import.meta.url).href;
}
onMounted(() => {
localName.value = props.nodeProperties?.name || props.nodeName
})
onUnmounted(() => {
console.log(34566)
emitter.off("deleteNode");
})
</script>
<style lang="scss" scoped>
.title__container {
@ -183,6 +187,7 @@ const imageUrl = () => {
.left {
display: flex;
align-items: center; //
img {
width: 24px;
@ -212,6 +217,18 @@ const imageUrl = () => {
.el-input {
margin-left: 12px;
width: 120px;
// z-index
position: relative;
z-index: 1000;
// Element Plus
:deep(.el-input__wrapper) {
box-shadow: 0 0 0 1px #409eff !important;
&:focus-within {
box-shadow: 0 0 0 2px #409eff !important;
}
}
}
.input_name_select {
@ -245,4 +262,11 @@ const imageUrl = () => {
margin: 8px 0;
}
}
//
:global(.lf-node) {
.el-input__inner {
user-select: text !important;
}
}
</style>

View File

@ -2,31 +2,11 @@
<el-drawer
v-model="props.drawer"
custom-class="custom-drawer-header"
:title="props.data.properties?.name || '参数配置'"
class="no-header-margin"
:close-on-click-modal="false"
:close-on-press-escape="false"
:show-close="false"
:before-close="confirm"
>
<template #header>
<div class="drawer-header">
<div>{{ props.data.properties?.name || '参数配置' }}</div>
<div>
<el-popconfirm
width="220"
confirm-button-text="确认删除"
cancel-button-text="误点击,不删除"
:icon="InfoFilled"
icon-color="#626AEF"
title="是否删除此节点?"
@confirm="deleteNode"
>
<template #reference>
<el-button type="primary" size="small">删除</el-button>
</template>
</el-popconfirm>
</div>
</div>
</template>
<div class="input__container" v-if="props.data.type === 'start'">
<el-collapse v-model="activeNames">
<el-collapse-item name="1" icon-position="left">
@ -391,6 +371,14 @@
<info-filled />
</el-icon>
</el-tooltip>
<el-button
:circle="true"
size="small"
@click="(e) => addFormItem(e, 'outputParams')"
class="addFormItem"
>
<el-icon :size="14"><Plus /></el-icon>
</el-button>
</template>
<div class="form__container">
<el-form
@ -927,17 +915,288 @@
</el-form>
</div>
<template #footer>
<div v-if="props.data.type === 'sdAgent'">
<el-form
:inline="true"
:model="sdAgentNodeData"
:rules="rules"
ref="dynamicForm"
class="http-form"
label-position="top"
label-width="auto"
>
<el-collapse v-model="activeNames">
<el-collapse-item name="1" title="请求配置" icon-position="left">
<div class="form__container">
<div v-for="(property, index) in sdAgentNodeData.config" :key="index">
<el-row>
<el-form-item
:label="index === 0 ? '参数名' : ''"
:prop="`config.${index}.name`"
:rules="[
{ required: true, message: '请输入参数名', trigger: 'blur' },
]"
>
<el-input
:disabled="true"
class="param-name"
v-model="property.name"
placeholder="请输入"
clearable
/>
</el-form-item>
<el-form-item
:label="index === 0 ? '参数值' : ''"
:prop="`config.${index}.input`"
>
<el-select
v-model="property.type"
class="param-type"
@change="handleTypeChange(index)"
>
<el-option label="引用" value="quote" />
<el-option label="输入" value="input" />
</el-select>
<el-form-item
v-if="property.type === 'input'"
:rules="[
{
required: property?.required ?? true,
message: '请输入参数值',
trigger: 'blur',
},
]"
:prop="`config.${index}.input`"
>
<el-input-number
class="param-value"
v-if="property.componentType === 'number'"
v-model="property.input"
:min="0"
:max="property.max || Infinity"
:controls="false"
:step-strictly="true"
placeholder="请输入"
clearable
/>
<el-select
v-model="property.input"
class="param-value"
v-else-if="property.componentType === 'select'"
>
<el-option
v-for="item in property.selectOptions"
:key="item.value"
:label="item.label"
:value="item.value"
/>
</el-select>
<el-input
class="param-value"
v-else
v-model="property.input"
placeholder="请输入"
clearable
/>
</el-form-item>
<el-form-item
v-if="property.type === 'quote'"
:rules="[
{
required: true,
message: '请选择参数值',
trigger: 'blur',
},
]"
:prop="`config.${index}.quote`"
>
<el-cascader
:ref="
(el) => {
if (el) cascaderRefs[index] = el;
}
"
v-model="property.quote"
:checkStrictly="true"
:options="quoteOptions"
placeholder="请选择"
@visible-change="
(visible) => visibleChange(visible, index, property.quote)
"
@change="(value) => cascaderChange(value, index, 'sdAgentConfig')"
/>
</el-form-item>
</el-form-item>
</el-row>
</div>
<el-row>
<span style="margin-right: 24px">是否调用TTS接口</span>
<el-switch size="small" v-model="sdAgentNodeData.invokeTts" @change="handleTtsChange" />
</el-row>
<div v-if="sdAgentNodeData.invokeTts" >
<div style="margin: 10px 0">TTS参数设置</div>
<div v-for="(property, index) in sdAgentNodeData.tts" :key="index">
<el-row>
<el-form-item
:label="index === 0 ? '参数名' : ''"
:prop="`tts.${index}.name`"
:rules="[
{ required: true, message: '请输入参数名', trigger: 'blur' },
]"
>
<el-input
:disabled="true"
class="param-name"
v-model="property.name"
placeholder="请输入"
clearable
/>
</el-form-item>
<el-form-item
:label="index === 0 ? '参数值' : ''"
:prop="`tts.${index}.input`"
>
<el-select
v-model="property.type"
class="param-type"
@change="handleTypeChange(index)"
>
<el-option label="引用" value="quote" />
<el-option label="输入" value="input" />
</el-select>
<el-form-item
v-if="property.type === 'input'"
:rules="[
{
required: property?.required ?? true,
message: '请输入参数值',
trigger: 'blur',
},
]"
:prop="`tts.${index}.input`"
>
<el-input-number
class="param-value"
v-if="property.componentType === 'number'"
v-model="property.input"
:min="0"
:max="property.max || Infinity"
:controls="false"
:step-strictly="true"
placeholder="请输入"
clearable
/>
<el-select
v-model="property.input"
class="param-value"
v-else-if="property.componentType === 'select'"
>
<el-option
v-for="item in property.selectOptions"
:key="item.value"
:label="item.label"
:value="item.value"
/>
</el-select>
<el-input
class="param-value"
v-else
v-model="property.input"
placeholder="请输入"
clearable
/>
</el-form-item>
<el-form-item
v-if="property.type === 'quote'"
:rules="[
{
required: true,
message: '请选择参数值',
trigger: 'blur',
},
]"
:prop="`tts.${index}.quote`"
>
<el-cascader
:ref="
(el) => {
if (el) cascaderRefs[index] = el;
}
"
v-model="property.quote"
:checkStrictly="true"
:options="quoteOptions"
placeholder="请选择"
@visible-change="
(visible) => visibleChange(visible, index, property.quote)
"
@change="(value) => cascaderChange(value, index, 'sdAgentTts')"
/>
</el-form-item>
</el-form-item>
</el-row>
</div>
</div>
</div>
</el-collapse-item>
<el-collapse-item name="3" icon-position="left">
<template #title>
输出参数
<el-tooltip
class="box-item"
effect="dark"
content="这里定义的输出变量可以被后续节点引用。"
placement="top"
>
<el-icon class="header-icon" style="margin-left: 6px">
<info-filled />
</el-icon>
</el-tooltip>
<el-button
:circle="true"
size="small"
@click="(e) => addSdAgentItem(e)"
class="addFormItem"
>
<el-icon :size="14"><Plus /></el-icon>
</el-button>
</template>
<div class="form__container">
<el-form
:inline="true"
:model="sdAgentNodeData"
label-position="top"
label-width="auto"
:rules="outputRules"
ref="outputFormRef"
>
<FormItemRecursive
formType="output"
:current-list="sdAgentNodeData.outputParams"
prop-path="outputParams"
:depth="0"
:is-first-level="true"
:endDepth="2"
:parent-path="[]"
@delete-item="(path) => deleteSdAgentItem(path, 'outputParams')"
/>
</el-form>
</div>
</el-collapse-item>
</el-collapse>
</el-form>
</div>
<!-- <template #footer>
<el-button @click="cancel">取消</el-button>
<el-button type="primary" @click="confirm">保存</el-button>
</template>
</template> -->
</el-drawer>
</template>
<script setup>
import FormItemRecursive from "./FormItemRecursive.vue";
import { Plus, Minus } from "@element-plus/icons-vue";
import { ElMessage } from 'element-plus'
import { getInput, filterEmptyName, transformHttpNodeData } from "@/utils/flow";
import { getInput, transformHttpNodeData, transformSdAgentNodeData } from "@/utils/flow";
import { emitter } from "@/utils/eventBus";
import * as monaco from 'monaco-editor';
import { nextTick, onUnmounted, watch } from "vue";
@ -949,11 +1208,6 @@ const props = defineProps({
const emits = defineEmits(['close'])
const deleteNode = () => {
lf.deleteNode(props.data.id);
emits('close')
}
const formData = reactive({
inputParams: [],
nodeParams: [],
@ -968,17 +1222,23 @@ let editorInstance
const dynamicForm = ref()
const outputFormRef = ref()
const throwAnError = (flag) => {
if (dynamicForm.value) {
dynamicForm.value.clearValidate()
}
if (outputFormRef.value) {
outputFormRef.value.clearValidate()
}
emitter.emit("throwAnError", { id: props.data.id, hasError: flag });
emits('close')
}
const confirm = async () => {
if (props.data.type === 'http') {
if (dynamicForm.value) {
await dynamicForm.value.validate((valid, fields) => {
if (valid) {
if (httpNodeData.value.body.type === 'json') {
if (hasErrors()) {
ElMessage.error('JSON中存在错误请修正后再保存');
return;
}
}
const nodeParams = []
nodeParams.push({ name: "config", type: "input", input: "", children: httpNodeData.value.config, disabled: true, required: true })
if (httpNodeData.value?.headers?.length > 0) {
@ -996,26 +1256,64 @@ const confirm = async () => {
]
}
nodeParams.push(bodyObj)
lf.setProperties(props.data.id, {
...props.data.properties,
nodeParams
});
emitter.emit("setProperties", { id: props.data.id});
emits('close')
if (httpNodeData.value.body.type === 'json') {
if (hasErrors()) {
throwAnError(true)
}
}
throwAnError(false)
} else {
console.log('error submit!', fields)
throwAnError(true)
}
});
}
} else if (props.data.type === 'sdAgent') {
// sdAgent
let inputValidate = true
let outputValidate = true
if (dynamicForm.value) {
await dynamicForm.value.validate((valid) => {
if (!valid) {
inputValidate = false
}
});
}
if (outputFormRef.value) {
await outputFormRef.value.validate((valid) => {
if (!valid) {
outputValidate = false
}
})
}
const nodeParams = []
nodeParams.push({ name: "config", type: "input", input: "", children: sdAgentNodeData.value.config, required: true })
nodeParams.push({ name: "invokeTts", type: "input", input: sdAgentNodeData.value.invokeTts })
if (sdAgentNodeData.value.invokeTts) {
nodeParams.push({ name: "tts", type: "input", input: "", children: sdAgentNodeData.value.tts })
}
lf.setProperties(props.data.id, {
...props.data.properties,
nodeParams,
outputParams: sdAgentNodeData.value.outputParams
});
emitter.emit("setProperties", { id: props.data.id});
//
if (inputValidate && outputValidate) {
throwAnError(false)
} else {
throwAnError(true)
}
} else {
if (props.data.type === 'code') {
if (hasErrors()) {
ElMessage.error('代码中存在错误,请修正后再保存!');
return;
}
const targetObj = formData.nodeParams.find(item => item.name === 'code');
if (targetObj) {
// input
@ -1044,22 +1342,30 @@ const confirm = async () => {
})
}
lf.setProperties(props.data.id, {
...props.data.properties,
...formData
});
emitter.emit("setProperties", { id: props.data.id});
//
if (inputValidate && outputValidate) {
lf.setProperties(props.data.id, {
...props.data.properties,
...formData
});
if (props.data.type === 'code') {
if (hasErrors()) {
throwAnError(true)
}
}
emitter.emit("setProperties", { id: props.data.id});
emits('close')
throwAnError(false)
} else {
throwAnError(true)
}
}
}
//
const deleteTopLevelItem = (fullPath, propPath) => {
//
//
let currentLevel = formData[propPath];
//
@ -1134,6 +1440,12 @@ const cascaderChange = (value, index, type = 'default') => {
if (type === 'default') {
formData.nodeParams[index].quote = value;
formData.nodeParams[index].quoteType = selectedOptions[0].data.type;
}else if (type === 'sdAgentConfig') {
sdAgentNodeData.value.config[index].quote = value;
sdAgentNodeData.value.config[index].quoteType = selectedOptions[0].data.type;
} else if (type === 'sdAgentTts') {
sdAgentNodeData.value.tts[index].quote = value;
sdAgentNodeData.value.tts[index].quoteType = selectedOptions[0].data.type;
} else {
httpNodeData.value.body.formData[index].quote = value;
httpNodeData.value.body.formData[index].quoteType = selectedOptions[0].data.type;
@ -1251,6 +1563,7 @@ watch(
}
);
// HTTP
const httpNodeData = ref({});
const addHttpNodeFormItem = (e, type) => {
@ -1276,6 +1589,52 @@ const handleHttpNodeDelete = (type, index) => {
}
};
//
const sdAgentNodeData = ref({})
const voiceOptions = () => {
return [{
value: 'x4_xiaoyan',
label: 'x4_xiaoyan'
}]
}
const handleTtsChange = (val) => {
if (val) {
sdAgentNodeData.value.tts = []
if (!sdAgentNodeData.value.tts || sdAgentNodeData.value.tts.length === 0) {
sdAgentNodeData.value.tts = [
{ name: 'url', type: "input", input: "", disabled: true },
{ name: 'text', type: "input", input: "", disabled: true },
{ name: 'speed', type: "input", input: "", max: 100, disabled: true },
{ name: 'voice', type: "input", input: "", componentType: 'select', selectOptions: voiceOptions(), disabled: true },
{ name: 'volume', type: "input", input: "", componentType: 'number', max: 100, disabled: true }
]
}
}
}
const addSdAgentItem = (e) => {
e.stopPropagation();
sdAgentNodeData.value.outputParams.push({ name: "", type: "string", input: "" });
}
const deleteSdAgentItem = (fullPath, propPath) => {
//
let currentLevel = sdAgentNodeData.value[propPath];
//
for (let i = 0; i < fullPath.length - 1; i++) {
const index = fullPath[i];
//
currentLevel = currentLevel[index].children;
}
//
const lastIndex = fullPath[fullPath.length - 1];
currentLevel.splice(lastIndex, 1);
}
watch(
() => props.data,
() => {
@ -1304,7 +1663,6 @@ watch(
const nodeParams = JSON.parse(JSON.stringify(props.data.properties.nodeParams || []))
const transformedData = transformHttpNodeData(nodeParams);
httpNodeData.value = transformedData;
console.log('httpNodeData', httpNodeData.value);
if (httpNodeData.value.body.type === 'json') {
setTimeout(() => {
if (editorInstance) {
@ -1312,6 +1670,15 @@ watch(
}
}, 100)
}
} else if (props.data.type === 'sdAgent') {
const nodeParams = JSON.parse(JSON.stringify(props.data.properties.nodeParams || []))
const outputParams = JSON.parse(JSON.stringify(props.data.properties.outputParams || []))
const transformedData = transformSdAgentNodeData(nodeParams);
sdAgentNodeData.value = {
...transformedData,
outputParams
};
}
},
{
@ -1321,6 +1688,8 @@ watch(
);
onUnmounted(() => {
emitter.off('throwAnError');
emitter.off('setProperties');
disposeEditor()
})
</script>

View File

@ -292,6 +292,7 @@ export const collapseList = [
type: "http",
desc: "HTTP请求",
action: 'HTTP',
nodeType: 'HTTP',
nodeParams: [
{ name: "config", type: "input", input: "", children: [
{ name: "url", type: "input", input: "", disabled: true, required: true },
@ -323,15 +324,15 @@ export const collapseList = [
nodeParams: [
{ name: "input", type: "input", input: "", required: true },
{ name: "code", type: "input", input: `
// 方法定义不能修改
function handler(params) {
// 返回值是一个可序列化成 json 的 dict 或 object
const result ={
type: 2,
message: params.input
}
return result
}
// 方法定义不能修改
function handler(params) {
// 返回值是一个可序列化成 json 的 dict 或 object
const result ={
type: 2,
message: params.input
}
return result
}
`, required: true }
],
outputType: 'json',
@ -346,7 +347,6 @@ export const collapseList = [
type: "currentLoop",
desc: "获取当前循环对象",
action: 'GET_CURRENT_OBJECT',
nodeType: 'getCurrentObject',
nodeParams: [
{ name: "array", type: "input", input: "" }
],
@ -459,14 +459,24 @@ export const collapseList = [
}, {
icon: dialogueSvg,
name: "商道智能体",
type: "serviceNode",
type: "sdAgent",
desc: "通过apiKey调用商道大模型",
action: 'AI_AGENT_PLATFORM',
nodeType: "LLM",
outputType: 'json',
nodeParams: [
{ name: 'apiKey', type: "input", input: "", disabled: true },
{ name: 'text', type: "input", input: "", disabled: true }
{ name: "config", type: "input", input: "", children: [
{ name: 'apiKey', type: "input", input: "", disabled: true },
{ name: 'text', type: "input", input: "", disabled: true },
]},
{ name: 'invokeTts', type: "input", input: false },
{ name: 'tts', type: "input", input: "", children: [
{ name: 'url', type: "input", input: "", disabled: true },
{ name: 'text', type: "input", input: "", disabled: true },
{ name: 'speed', type: "input", input: "", max: 100, disabled: true },
{ name: 'voice', type: "input", input: "", componentType: 'select', selectOptions: voiceOptions(), disabled: true },
{ name: 'volume', type: "input", input: "", componentType: 'number', max: 100, disabled: true }
], disabled: true }
],
outputParams: [{ name: 'result', type: 'string', desc: '商道大模型的返回文案', disabled: true}]
}, {

View File

@ -8,6 +8,9 @@
</div>
<div class="btn__container">
<div class="btn">
<el-tag style="margin-right: 12px;" v-if="['testRunError', 'testRunFinish'].includes(flowState)" :type="flowState === 'testRunFinish' ? 'success' : 'danger'">
{{ totalRunningTime }}ms
</el-tag>
<el-button v-if="['testRunError', 'testRunFinish', 'stop'].includes(flowState)" @click="clearRun">清除上一次运行结果</el-button>
<el-button @click="group">分组</el-button>
<el-button v-if="flowState !== 'testRunning'" @click="testRun">试运行</el-button>
@ -271,6 +274,11 @@ const testRun = async () => {
return;
}
if (nodeErrorList.value.length > 0) {
ElMessage.warning("存在参数错误的节点,请检查!");
return;
}
isOpen.value = true;
};
@ -283,6 +291,8 @@ const flowPauseFn = async () => {
}
};
const totalRunningTime = ref(0);
const flowResumeFn = async () => {
const res = await flowResume(instId.value);
if (res.code === 200) {
@ -409,6 +419,7 @@ const loopFlowView = async (instId, taskId = null) => {
if (!flowInfoData.value.isLog) {
flowStore.updateDisableForm(false);
flowState.value = "testRunFinish";
totalRunningTime.value = arr[arr.length - 1].endTime - arr[0].startTime
}
} else {
if (!flowInfoData.value.isLog) {
@ -416,6 +427,7 @@ const loopFlowView = async (instId, taskId = null) => {
flowState.value = arr[arr.length - 1]?.status === "PAUSED" ? "pause" : "stop";
} else {
flowState.value = "testRunError";
totalRunningTime.value = arr[arr.length - 1].endTime - arr[0].startTime
flowStore.updateDisableForm(false);
}
}
@ -607,8 +619,6 @@ const initFlow = () => {
lf.on("node:mousemove", ({ data, e }) => {
const { nodes } = lf.getGraphData();
const arr = recursiveFilter(nodes, data.id, "loop");
// const arr = findRelationNodesById(nodes, data.id);
console.log('arr', arr)
arr.forEach((item) => {
const node = lf.getNodeModelById(item.id);
node.updateSize();
@ -629,7 +639,6 @@ const initFlow = () => {
) {
return;
}
console.log("data", data);
showParamsDrawer.value = true;
paramsDrawerData.value = data;
});
@ -639,7 +648,7 @@ const initFlow = () => {
}
};
const group = () => {
const group = () => {
const PADDING = 200;
lf.extension.selectionSelect.openSelectionSelect();
lf.once("selection:selected", (data) => {
@ -660,6 +669,8 @@ const group = () => {
}
});
if (children.length === 0) {
lf.clearSelectElements();
lf.extension.selectionSelect.closeSelectionSelect();
return;
}
let width = maxX - minX + PADDING;
@ -763,6 +774,8 @@ const clearRun = () => {
});
}
const nodeErrorList = ref([]);
onMounted(() => {
justLoadFlow();
initFlow();
@ -774,6 +787,27 @@ onMounted(() => {
paramsDrawerData.value = node;
});
emitter.on("throwAnError", (data) => {
//
const { id, hasError } = data;
const element = document.getElementsByClassName(`node__container ${id}`)[0].parentElement;
if (hasError) {
if (!nodeErrorList.value.includes(id)) {
nodeErrorList.value.push(id);
element.style.background = "#ff00001a";
}
} else {
nodeErrorList.value = nodeErrorList.value.filter((item) => item !== id);
element.style.background = "#fff";
}
});
emitter.on("deleteNode", (nodeId) => {
const index = nodeErrorList.value.findIndex((item) => item === nodeId);
if (index !== -1) {
nodeErrorList.value.splice(index, 1);
}
})
});
const operationEdge = (arr) => {
@ -785,6 +819,8 @@ const operationEdge = (arr) => {
onUnmounted(() => {
emitter.off("changeNodeState");
emitter.off("openParamsDrawer");
emitter.off("throwAnError");
emitter.off("deleteNode");
window.removeEventListener("beforeunload", handleBeforeUnload);
document.removeEventListener("singleNodeExecution", singleNodeExecution);

View File

@ -7,6 +7,7 @@ import { registerSleepNode } from './sleep'
import { registerHttpNode } from './httpNode'
import { registerCodeNode } from './codeNode'
import { registerCurrentLoopNode } from './currentLoopNode'
import { registerSdAgentNode } from './sdAgent'
export const registerFunction = (lf) => {
registerLoopBodyNode(lf)
@ -18,4 +19,5 @@ export const registerFunction = (lf) => {
registerHttpNode(lf)
registerCodeNode(lf)
registerCurrentLoopNode(lf)
registerSdAgentNode(lf)
}

View File

@ -0,0 +1,213 @@
// 导入 HtmlNode 及其模型,为后续继承做准备
import { HtmlNode, HtmlNodeModel } from "@logicflow/core";
// 导入 Vue 相关方法,用于渲染组件
import { createApp, h, nextTick } from "vue";
import ElementPlus from "element-plus";
// 导入 Vue 组件
// @ts-ignore
import SdAgent from "./sdAgent.vue";
import OuterNode from "../../components/OuterNode.vue";
import JsonViewer from 'vue3-json-viewer'
/**
* 定义一个 元素的 HTML 节点类继承自 HtmlNode
* 该类负责在 HTML 中渲染 元素并处理其交互逻辑
*/
class SdAgentNodeHtmlNode extends HtmlNode {
resizeObserver = null;
isMounted; // 标记组件是否已挂载
r; // 渲染函数
app; // Vue 应用实例
container = null;
static reusePool = new Map(); // 节点复用池
/**
* 构造函数
* @param props 传递给节点的属性包括模型图模型等
*/
constructor(props) {
super(props);
this.initVueApp(props);
}
initVueApp(props) {
this.isMounted = false;
this.hideAnchor = false;
this.autoExpand = true; // 防止锚点被折叠
this.anchorsPreset = "default"; // 重置锚点预设
// 创建 元素的渲染函数
this.r = h(OuterNode, {
model: props.model,
component: SdAgent,
properties: {
...props.model.getProperties(),
},
onContentChange: this.handleContentChange.bind(this),
onBindRef: this.handleComponentInstance.bind(this)
});
// 创建 Vue 应用实例,并指定渲染函数
this.app = createApp({
render: () => this.r,
});
}
/**
* HTML 内容设置到指定的根元素上
* @param rootEl 根元素
*/
async setHtml(rootEl) {
const nodeId = this.props.model.id;
if (SdAgentNodeHtmlNode.reusePool.has(nodeId)) {
rootEl.appendChild(SdAgentNodeHtmlNode.reusePool.get(nodeId));
return;
}
if (!this.isMounted) {
this.isMounted = true;
this.container = document.createElement("div");
this.container.style.display = "inline-block"; // 关键:确保容器自适应内容
rootEl.appendChild(this.container);
this.app.use(ElementPlus);
this.app.use(JsonViewer);
this.app.mount(this.container);
await nextTick();
this.setupSizeObserver();
SdAgentNodeHtmlNode.reusePool.set(nodeId, this.container);
} else {
this.r.component.props.properties = this.props.model.getProperties();
}
}
/**
* 获取节点文本内容
* 对于元素返回 null因为其内容由特定组件渲染
* @returns {null}
*/
getText() {
return null;
}
handleComponentInstance(data) {
// 将组件实例保存到节点模型
this.props.model.setComponentInstance(data)
}
handleContentChange() {
// 内容变化时强制更新尺寸
this.updateNodeSize();
}
// 渲染完成后获取实际尺寸
updateNodeSize() {
if (this.container) {
const { SCALE_X, SCALE_Y } = this.props.graphModel.transformModel;
const node = this.container.querySelector(".node__container");
const rect = node.getBoundingClientRect();
this.props.model.updateSize(rect.width / SCALE_X, rect.height / SCALE_Y);
}
}
setupSizeObserver() {
// 首次渲染立即检测
requestAnimationFrame(() => {
this.updateNodeSize();
// 持续监听变化
this.resizeObserver = new ResizeObserver(() => {
this.updateNodeSize();
});
this.resizeObserver.observe(this.container);
});
}
// 组件卸载时移除监听
onDestroy() {
this.resizeObserver?.disconnect();
}
}
/**
* 定义一个元素的 HTML 模型类继承自 HtmlNodeModel
* 该类主要设置节点的属性和样式
*/
class SdAgentNodeHtmlModel extends HtmlNodeModel {
initNodeData(data) {
super.initNodeData(data);
}
// 保存组件实例引用
setComponentInstance(instance) {
this.componentInstance = instance;
}
closePopover() {
this.componentInstance.closePopover()
}
/**
* 设置节点属性
* 包括宽度高度文本编辑属性等
*/
setAttributes() {
// 初始设置为0后续动态更新
this.width = 0;
this.height = 0;
this.text.editable = false;
}
updateSize(width, height) {
this.width = width + 24;
this.height = height + 50;
this.initNodeData(this); // 触发节点重绘
}
// 定义节点只有左右两个锚点. 锚点位置通过中心点和宽度算出来。
getDefaultAnchor() {
let _a = this,
x = _a.x,
y = _a.y,
width = _a.width,
height = _a.height;
return [
{
x: x + width / 2 + 4,
y: y,
name: "right",
id: "".concat(this.id, "_1"),
properties: { connectionType: "source" },
},
{
x: x - width / 2,
y: y,
name: "left",
id: "".concat(this.id, "_3"),
properties: { connectionType: "target" },
},
];
}
/**
* 获取节点轮廓样式
* 覆盖父类方法设置 stroke 属性为 none以适应特定的视觉效果
* @returns {object} 节点轮廓样式
*/
getOutlineStyle() {
const style = super.getOutlineStyle();
style.stroke = "none";
style.hover.stroke = "none";
return style;
}
}
// 导出方法注册
export function registerSdAgentNode(lf) {
lf.register({
type: "sdAgent",
view: SdAgentNodeHtmlNode,
model: SdAgentNodeHtmlModel
});
}

View File

@ -0,0 +1,124 @@
<template>
<div class="node__container" :class="props.model.id">
<NodeState :state="nodeOperatingStatus" :runtimes="runtimes" ref="nodeStateRef">
<template #input>
<JsonViewer :value="inputJsonData" copyable boxed sort theme="light" />
</template>
<template #output>
<JsonViewer v-if="props.properties.outputType === 'json'" :value="outputJsonData" copyable boxed sort theme="light" />
<el-image
v-if="props.properties.outputType === 'img'"
v-for="item in outputJsonData.imageUrl"
style="width: 60px; height: 60px"
:src="item"
:preview-src-list="outputJsonData.imageUrl"
:preview-teleported="true"
show-progress
fit="fill"
/>
<IPlayer v-if="props.properties.outputType === 'video'" v-for="item in outputJsonData.videoUrl" :videoUrl="item" />
</template>
</NodeState>
<NodeTitle
:icon="props.properties.icon"
:nodeId="props.model.id"
:nodeProperties="props.properties"
:nodeName="props.properties.name"
:nodeType="props.properties.nodeType || 'NONE'"
:nodeDesc="props.properties.desc"
@setNodeName="setNodeName"
/>
</div>
</template>
<script setup>
import { ref, onMounted, onUnmounted } from "vue";
import NodeTitle from "../../components/NodeTitle.vue";
import NodeState from "../../components/NodeState.vue";
import "vue3-json-viewer/dist/index.css";
import { emitter } from "@/utils/eventBus";
import IPlayer from "@/views/device/register/components/LogicFlow/IPlayer/index.vue";
const props = defineProps({
model: Object,
properties: Object,
});
const emits = defineEmits(["contentChange"]);
const setNodeName = (name) => {
const properties = lf.getProperties(props.model.id);
lf.setProperties(props.model.id, {
...properties,
name
});
emits("contentChange");
}
const nodeOperatingStatus = ref("NORMAL");
const runtimes = ref(0);
const inputJsonData = ref({});
const outputJsonData = ref({});
const nodeStateRef = ref(null);
const closePopover = () => {
if (nodeStateRef.value) {
nodeStateRef.value.closePopover();
}
}
onMounted(() => {
emitter.on("changeNodeState", (data) => {
if (data.nodeId === props.model.id) {
nodeOperatingStatus.value = data.status;
if (data.endTime && data.startTime) {
runtimes.value = data.endTime - data.startTime;
}
let inputData = {};
let output = {};
try {
inputData = JSON.parse(data.paramsIn) || {};
output = JSON.parse(data.paramsOut) || {};
} catch (error) {
inputData = data.paramsIn || {};
output = data.paramsOut || {};
}
inputJsonData.value = inputData;
outputJsonData.value = output;
emits("contentChange");
}
});
emitter.on("contentChange", (data) => {
if (data.id === props.model.id) {
nodeOperatingStatus.value = "NORMAL";
inputJsonData.value = {};
outputJsonData.value = {};
emits("contentChange");
}
});
emitter.on("setProperties", (data) => {
if (data.id === props.model.id) {
emits("contentChange");
}
});
});
onUnmounted(() => {
emitter.off("changeNodeState");
emitter.off("contentChange");
emitter.off("setProperties");
});
defineExpose({ closePopover })
</script>
<style lang="scss" scoped>
.node__container {
width: 100%;
height: auto;
}
</style>

View File

@ -72,6 +72,9 @@
v-model="params.withOr"
placeholder="Select"
style="width: 240px"
@focus="handleInputFocus"
@click.stop
@mousedown.stop
>
<el-option key="and" label="AND" value="and" />
<el-option key="or" label="OR" value="or" />
@ -80,14 +83,16 @@
</div>
<div class="form__container">
<el-row v-for="(property, pIndex) in params.list">
<!-- :prop="`nodeParams.${index}.list.${pIndex}.name`" :rules="[{ required: true, message: '请输入变量名', trigger: 'blur' }]" -->
<el-form-item
:label="pIndex === 0 ? '引用变量' : ''"
:prop="`nodeParams.${index}.list.${pIndex}.nameType`"
>
<!-- <el-input v-model="property.name" placeholder="请输入" clearable /> -->
<el-select
v-model="property.nameType"
@focus="handleInputFocus"
@keydown="handleInputKeydown"
@click.stop
@mousedown.stop
@change="handleTypeChange(index, pIndex)"
>
<el-option label="引用" value="quote" />
@ -108,6 +113,10 @@
v-model="property.name"
placeholder="请输入"
clearable
@focus="handleInputFocus"
@keydown="handleInputKeydown"
@click.stop
@mousedown.stop
/>
</el-form-item>
<el-form-item
@ -125,7 +134,12 @@
v-model="property.nameQuote"
:options="quoteOptions"
placeholder="请选择"
@visible-change="visibleChange"
:key="nameQuoteKey"
@visible-change="(val) => visibleChange(val, 'nameQuote', index, pIndex)"
@focus="handleInputFocus"
@keydown="handleInputKeydown"
@click.stop
@mousedown.stop
/>
</el-form-item>
</el-form-item>
@ -136,7 +150,13 @@
{ required: true, message: '请输入变量名', trigger: 'blur' },
]"
>
<el-select v-model="property.condition">
<el-select
v-model="property.condition"
@focus="handleInputFocus"
@keydown="handleInputKeydown"
@click.stop
@mousedown.stop
>
<el-option label="等于" value="equal" />
<el-option label="不等于" value="notEqualTo" />
<el-option label="为空" value="null" />
@ -156,6 +176,10 @@
<el-select
v-model="property.type"
@change="handleTypeChange(index, pIndex)"
@focus="handleInputFocus"
@keydown="handleInputKeydown"
@click.stop
@mousedown.stop
>
<el-option label="引用" value="quote" />
<el-option label="输入" value="input" />
@ -175,6 +199,10 @@
v-model="property.input"
placeholder="请输入"
clearable
@focus="handleInputFocus"
@keydown="handleInputKeydown"
@click.stop
@mousedown.stop
/>
</el-form-item>
<el-form-item
@ -192,7 +220,11 @@
v-model="property.quote"
:options="quoteOptions"
placeholder="请选择"
@visible-change="visibleChange"
@visible-change="(val) => visibleChange(val, 'quote', index, pIndex)"
@focus="handleInputFocus"
@keydown="handleInputKeydown"
@click.stop
@mousedown.stop
/>
</el-form-item>
</el-form-item>
@ -375,11 +407,17 @@ const setNodeName = (name) => {
emits("contentChange");
}
const visibleChange = (value) => {
const visibleChange = async (value, type, index, pIndex) => {
if (value) {
const option = getInput(props.model.id);
if (option) {
quoteOptions.value = option;
const currentValue = formData.nodeParams[index].list[pIndex][type]
if (currentValue) {
formData.nodeParams[index].list[pIndex][type] = null
await nextTick();
formData.nodeParams[index].list[pIndex][type] = currentValue;
}
}
}
};
@ -415,6 +453,23 @@ const closePopover = () => {
}
}
const isEditing = ref(false)
const handleInputFocus = (e) => {
// LogicFlow
e.stopPropagation()
e.preventDefault()
}
const handleInputKeydown = (e) => {
// Logic Flow
e.stopPropagation();
// Ctrl+V
if ((e.ctrlKey || e.metaKey) && e.key === "v") {
e.returnValue = true; //
}
}
onMounted(() => {
emits("addAnchor", 280, "".concat(props.model.id, "_else"));