Perf workflow (#1492)

* perf: handle edge check * search model * feat: plugin input can render all input; fix: plugin default value * fix ts * feat: plugin input support required
2025-07-22 04:06:18 +00:00 · 2024-05-15 16:17:43 +08:00
parent cd876251b7
commit 8386f707cd
36 changed files with 256 additions and 160 deletions
--- a/.vscode/i18n-ally-custom-framework.yml
+++ b/.vscode/i18n-ally-custom-framework.yml
@@ -23,6 +23,7 @@ usageMatchRegex:
  - "[^\\w\\d]datasetT\\(['\"`]({key})['\"`]"
  - "[^\\w\\d]fileT\\(['\"`]({key})['\"`]"
  - "[^\\w\\d]publishT\\(['\"`]({key})['\"`]"
+  - "[^\\w\\d]workflowT\\(['\"`]({key})['\"`]"

 # A RegEx to set a custom scope range. This scope will be used as a prefix when detecting keys
 # and works like how the i18next framework identifies the namespace scope from the
--- a/docSite/content/docs/development/openapi/share.md
+++ b/docSite/content/docs/development/openapi/share.md
@@ -247,7 +247,7 @@ curl --location --request POST '{{host}}/shareAuth/finish' \

 ```ts
 type ResponseType = {
-    moduleType: `${FlowNodeTypeEnum}`; // 模块类型
+    moduleType: FlowNodeTypeEnum; // 模块类型
    moduleName: string; // 模块名
    moduleLogo?: string; // logo
    runningTime?: number; // 运行时间
--- a/docSite/content/docs/development/upgrading/481.md
+++ b/docSite/content/docs/development/upgrading/481.md
@@ -35,5 +35,8 @@ curl --location --request POST 'https://{{host}}/api/admin/clearInvalidData' \
 ## V4.8.1 更新说明

 1. 新增 - 知识库重新选择向量模型重建
-2. 修复 - 工作流删除节点的动态输入和输出时候，没有正确的删除连接线，导致可能出现逻辑异常。
-3. 修复 - 定时器清理脏数据任务
+2. 新增 - 工作流节点版本变更提示，并可以同步最新版本。
+3. 优化 - 插件输入的 debug 模式，支持全量参数输入渲染。
+4. 修复 - 插件输入默认值被清空问题。
+5. 修复 - 工作流删除节点的动态输入和输出时候，没有正确的删除连接线，导致可能出现逻辑异常。
+6. 修复 - 定时器清理脏数据任务
--- a/packages/global/core/chat/type.d.ts
+++ b/packages/global/core/chat/type.d.ts
@@ -139,7 +139,7 @@ export type ChatHistoryItemType = HistoryItemType & {
 /* ------- response data ------------ */
 export type ChatHistoryItemResType = DispatchNodeResponseType & {
  nodeId: string;
-  moduleType: `${FlowNodeTypeEnum}`;
+  moduleType: FlowNodeTypeEnum;
  moduleName: string;
 };

--- a/packages/global/core/workflow/api.d.ts
+++ b/packages/global/core/workflow/api.d.ts
@@ -1,7 +1,7 @@
 import { VectorModelItemType } from '../ai/model.d';
 import { NodeInputKeyEnum } from './constants';

-export type SelectedDatasetType = { datasetId: string; vectorModel: VectorModelItemType }[];
+export type SelectedDatasetType = { datasetId: string }[];

 export type HttpBodyType<T = Record<string, any>> = {
  [NodeInputKeyEnum.addInputParam]: Record<string, any>;
--- a/packages/global/core/workflow/template/system/datasetSearch.ts
+++ b/packages/global/core/workflow/template/system/datasetSearch.ts
@@ -36,7 +36,6 @@ export const DatasetSearchModule: FlowNodeTemplateType = {
      label: 'core.module.input.label.Select dataset',
      value: [],
      valueType: WorkflowIOValueTypeEnum.selectDataset,
-      list: [],
      required: true
    },
    {
--- a/packages/global/core/workflow/type/index.d.ts
+++ b/packages/global/core/workflow/type/index.d.ts
@@ -22,7 +22,7 @@ import { RuntimeEdgeItemType, StoreEdgeItemType } from './edge';
 import { NextApiResponse } from 'next';

 export type FlowNodeCommonType = {
-  flowNodeType: `${FlowNodeTypeEnum}`; // render node card
+  flowNodeType: FlowNodeTypeEnum; // render node card

  avatar?: string;
  name: string;
--- a/packages/global/core/workflow/utils.ts
+++ b/packages/global/core/workflow/utils.ts
@@ -1,4 +1,4 @@
-import { FlowNodeOutputTypeEnum, FlowNodeTypeEnum } from './node/constant';
+import { FlowNodeInputTypeEnum, FlowNodeOutputTypeEnum, FlowNodeTypeEnum } from './node/constant';
 import {
  WorkflowIOValueTypeEnum,
  NodeInputKeyEnum,
@@ -22,15 +22,9 @@ export const getHandleId = (nodeId: string, type: 'source' | 'target', key: stri
 };

 export const checkInputIsReference = (input: FlowNodeInputItemType) => {
-  const value = input.value;
-  if (
-    Array.isArray(value) &&
-    value.length === 2 &&
-    typeof value[0] === 'string' &&
-    typeof value[1] === 'string'
-  ) {
+  if (input.renderTypeList?.[input?.selectedTypeIndex || 0] === FlowNodeInputTypeEnum.reference)
    return true;
-  }
+
  return false;
 };

--- a/packages/service/core/workflow/dispatch/dataset/search.ts
+++ b/packages/service/core/workflow/dispatch/dataset/search.ts
@@ -15,6 +15,7 @@ import { getHistories } from '../utils';
 import { datasetSearchQueryExtension } from '../../../dataset/search/utils';
 import { ChatNodeUsageType } from '@fastgpt/global/support/wallet/bill/type';
 import { checkTeamReRankPermission } from '../../../../support/permission/teamLimit';
+import { MongoDataset } from '../../../dataset/schema';

 type DatasetSearchProps = ModuleDispatchProps<{
  [NodeInputKeyEnum.datasetSelectList]: SelectedDatasetType;
@@ -79,7 +80,9 @@ export async function dispatchDatasetSearch(
  // console.log(concatQueries, rewriteQuery, aiExtensionResult);

  // get vector
-  const vectorModel = getVectorModel(datasets[0]?.vectorModel?.model);
+  const vectorModel = getVectorModel(
+    (await MongoDataset.findById(datasets[0].datasetId, 'vectorModel').lean())?.vectorModel
+  );

  // start search
  const {
--- a/packages/service/core/workflow/dispatch/index.ts
+++ b/packages/service/core/workflow/dispatch/index.ts
@@ -45,7 +45,7 @@ import { getReferenceVariableValue } from '@fastgpt/global/core/workflow/runtime
 import { dispatchSystemConfig } from './init/systemConfig';
 import { dispatchUpdateVariable } from './tools/runUpdateVar';

-const callbackMap: Record<`${FlowNodeTypeEnum}`, Function> = {
+const callbackMap: Record<FlowNodeTypeEnum, Function> = {
  [FlowNodeTypeEnum.workflowStart]: dispatchWorkflowStart,
  [FlowNodeTypeEnum.answerNode]: dispatchAnswer,
  [FlowNodeTypeEnum.chatNode]: dispatchChatCompletion,
--- a/packages/web/components/common/Input/NumberInput/index.tsx
+++ b/packages/web/components/common/Input/NumberInput/index.tsx
@@ -0,0 +1,36 @@
+import {
+  NumberInput,
+  NumberIncrementStepper,
+  NumberInputField,
+  NumberInputStepper,
+  NumberDecrementStepper,
+  NumberInputProps
+} from '@chakra-ui/react';
+import React from 'react';
+
+type Props = Omit<NumberInputProps, 'onChange'> & {
+  onChange: (e: number | '') => any;
+};
+
+const MyNumberInput = (props: Props) => {
+  return (
+    <NumberInput
+      {...props}
+      onChange={(e) => {
+        if (isNaN(Number(e))) {
+          props?.onChange('');
+        } else {
+          props?.onChange(Number(e));
+        }
+      }}
+    >
+      <NumberInputField />
+      <NumberInputStepper>
+        <NumberIncrementStepper />
+        <NumberDecrementStepper />
+      </NumberInputStepper>
+    </NumberInput>
+  );
+};
+
+export default MyNumberInput;
--- a/packages/web/components/common/MyDrawer/MyRightDrawer.tsx
+++ b/packages/web/components/common/MyDrawer/MyRightDrawer.tsx
@@ -67,7 +67,7 @@ const MyRightDrawer = ({
          <DrawerCloseButton position={'relative'} fontSize={'sm'} top={0} right={0} />
        </Flex>

-        <DrawerBody>
+        <DrawerBody overflow={'unset'} px={props?.px}>
          {children}
          <Loading loading={isLoading} fixed={false} />
        </DrawerBody>
--- a/projects/app/i18n/en/dataset.json
+++ b/projects/app/i18n/en/dataset.json
@@ -1,7 +1,7 @@
 {
  "Common Dataset": "Common dataset",
  "Common Dataset Desc": "Can be built by importing files, web links, or manual entry",
-  "Confirm to rebuild embedding tip": "Are you sure to switch the knowledge base index? Switching index is a very heavy operation that requires re-indexing all the data in your knowledge base, which may take a long time. Please ensure that the remaining points in your account are sufficient.",
+  "Confirm to rebuild embedding tip": "Are you sure to switch the knowledge base index?\nSwitching index is a very heavy operation that requires re-indexing all the data in your knowledge base, which may take a long time. Please ensure that the remaining points in your account are sufficient.\n\nIn addition, you need to be careful to modify the applications that select this knowledge base to avoid mixing them with other index model knowledge bases.",
  "External file": "External file",
  "External file Dataset Desc": "You can import files from an external file library to build a knowledge base. Files are not stored twice",
  "External id": "File id",
--- a/projects/app/i18n/en/workflow.json
+++ b/projects/app/i18n/en/workflow.json
@@ -0,0 +1,3 @@
+{
+  "Field required": "Required"
+}
--- a/projects/app/i18n/zh/dataset.json
+++ b/projects/app/i18n/zh/dataset.json
@@ -1,7 +1,7 @@
 {
  "Common Dataset": "通用知识库",
  "Common Dataset Desc": "可通过导入文件、网页链接或手动录入形式构建知识库",
-  "Confirm to rebuild embedding tip": "确认为知识库切换索引？\n切换索引是一个非常重量的操作，需要对您知识库内所有数据进行重新索引，时间可能较长，请确保账号内剩余积分充足。",
+  "Confirm to rebuild embedding tip": "确认为知识库切换索引？\n切换索引是一个非常重量的操作，需要对您知识库内所有数据进行重新索引，时间可能较长，请确保账号内剩余积分充足。\n\n此外，你还需要注意修改选择该知识库的应用，避免它们与其他索引模型知识库混用。",
  "External File": "外部文件库",
  "External file Dataset Desc": "可以从外部文件库导入文件构建知识库，文件不会进行二次存储",
  "External id": "文件阅读ID",
--- a/projects/app/i18n/zh/workflow.json
+++ b/projects/app/i18n/zh/workflow.json
@@ -0,0 +1,3 @@
+{
+  "Field required": "必填"
+}
--- a/projects/app/src/components/core/app/DatasetSelectModal.tsx
+++ b/projects/app/src/components/core/app/DatasetSelectModal.tsx
@@ -96,7 +96,7 @@ export const DatasetSelectModal = ({
                        _hover={{ color: 'red.500' }}
                        onClick={() => {
                          setSelectedDatasets((state) =>
-                            state.filter((kb) => kb.datasetId !== item._id)
+                            state.filter((dataset) => dataset.datasetId !== item._id)
                          );
                        }}
                      />
@@ -141,7 +141,9 @@ export const DatasetSelectModal = ({
                        if (item.type === DatasetTypeEnum.folder) {
                          setParentId(item._id);
                        } else {
-                          const vectorModel = selectedDatasets[0]?.vectorModel?.model;
+                          const vectorModel = datasets.find(
+                            (dataset) => dataset._id === selectedDatasets[0]?.datasetId
+                          )?.vectorModel?.model;

                          if (vectorModel && vectorModel !== item.vectorModel.model) {
                            return toast({
@@ -149,10 +151,7 @@ export const DatasetSelectModal = ({
                              title: t('dataset.Select Dataset Tips')
                            });
                          }
-                          setSelectedDatasets((state) => [
-                            ...state,
-                            { datasetId: item._id, vectorModel: item.vectorModel }
-                          ]);
+                          setSelectedDatasets((state) => [...state, { datasetId: item._id }]);
                        }
                      }}
                    >
--- a/projects/app/src/components/core/workflow/Flow/hooks/useDebug.tsx
+++ b/projects/app/src/components/core/workflow/Flow/hooks/useDebug.tsx
@@ -26,6 +26,8 @@ import { WorkflowIOValueTypeEnum } from '@fastgpt/global/core/workflow/constants
 import { checkInputIsReference } from '@fastgpt/global/core/workflow/utils';
 import { useContextSelector } from 'use-context-selector';
 import { WorkflowContext, getWorkflowStore } from '../../context';
+import QuestionTip from '@fastgpt/web/components/common/MyTooltip/QuestionTip';
+import { FlowNodeTypeEnum } from '@fastgpt/global/core/workflow/node/constant';

 const MyRightDrawer = dynamic(
  () => import('@fastgpt/web/components/common/MyDrawer/MyRightDrawer')
@@ -109,15 +111,23 @@ export const useDebug = () => {
    const runtimeNode = runtimeNodes.find((node) => node.nodeId === runtimeNodeId);

    if (!runtimeNode) return <></>;
-    const referenceInputs = runtimeNode.inputs.filter((input) => {
+    const renderInputs = runtimeNode.inputs.filter((input) => {
+      if (runtimeNode.flowNodeType === FlowNodeTypeEnum.pluginInput) return true;
      if (checkInputIsReference(input)) return true;
      if (input.required && !input.value) return true;
    });

    const { register, getValues, setValue, handleSubmit } = useForm<Record<string, any>>({
-      defaultValues: referenceInputs.reduce((acc, input) => {
-        //@ts-ignore
-        acc[input.key] = undefined;
+      defaultValues: renderInputs.reduce((acc: Record<string, any>, input) => {
+        const isReference = checkInputIsReference(input);
+        if (isReference) {
+          acc[input.key] = undefined;
+        } else if (typeof input.value === 'object') {
+          acc[input.key] = JSON.stringify(input.value, null, 2);
+        } else {
+          acc[input.key] = input.value;
+        }
+
        return acc;
      }, {})
    });
@@ -153,73 +163,81 @@ export const useDebug = () => {
        iconSrc="core/workflow/debugBlue"
        title={t('core.workflow.Debug Node')}
        maxW={['90vw', '35vw']}
+        px={0}
      >
        <Flex flexDirection={'column'} h={'100%'}>
-          <Box flex={'1 0 0'} overflow={'auto'}>
-            {referenceInputs.map((input) => {
+          <Box flex={'1 0 0'} overflow={'auto'} px={6}>
+            {renderInputs.map((input) => {
              const required = input.required || false;
-              return (
-                <Box key={input.key} _notLast={{ mb: 4 }} px={1}>
-                  <Box display={'inline-block'} position={'relative'} mb={1}>
-                    {required && (
-                      <Box position={'absolute'} right={-2} top={-1} color={'red.600'}>
-                        *
-                      </Box>
-                    )}
-                    {t(input.debugLabel || input.label)}
-                  </Box>
-                  {(() => {
-                    if (input.valueType === WorkflowIOValueTypeEnum.string) {
-                      return (
-                        <Textarea
-                          {...register(input.key, {
-                            required
-                          })}
-                          placeholder={t(input.placeholder || '')}
-                          bg={'myGray.50'}
-                        />
-                      );
-                    }
-                    if (input.valueType === WorkflowIOValueTypeEnum.number) {
-                      return (
-                        <NumberInput
-                          step={input.step}
-                          min={input.min}
-                          max={input.max}
-                          bg={'myGray.50'}
-                        >
-                          <NumberInputField
-                            {...register(input.key, {
-                              required: input.required,
-                              min: input.min,
-                              max: input.max,
-                              valueAsNumber: true
-                            })}
-                          />
-                          <NumberInputStepper>
-                            <NumberIncrementStepper />
-                            <NumberDecrementStepper />
-                          </NumberInputStepper>
-                        </NumberInput>
-                      );
-                    }
-                    if (input.valueType === WorkflowIOValueTypeEnum.boolean) {
-                      return <Switch size={'lg'} {...register(input.key)} />;
-                    }
-                    return (
-                      <JsonEditor
-                        bg={'myGray.50'}
-                        placeholder={t(input.placeholder || '')}
-                        resize
-                        value={getValues(input.key)}
-                        onChange={(e) => {
-                          setValue(input.key, e);
-                        }}
+              console.log(input.valueType);
+              const RenderInput = (() => {
+                if (input.valueType === WorkflowIOValueTypeEnum.string) {
+                  return (
+                    <Textarea
+                      {...register(input.key, {
+                        required
+                      })}
+                      placeholder={t(input.placeholder || '')}
+                      bg={'myGray.50'}
+                    />
+                  );
+                }
+                if (input.valueType === WorkflowIOValueTypeEnum.number) {
+                  return (
+                    <NumberInput step={input.step} min={input.min} max={input.max} bg={'myGray.50'}>
+                      <NumberInputField
+                        {...register(input.key, {
+                          required: input.required,
+                          min: input.min,
+                          max: input.max,
+                          valueAsNumber: true
+                        })}
                      />
-                    );
-                  })()}
+                      <NumberInputStepper>
+                        <NumberIncrementStepper />
+                        <NumberDecrementStepper />
+                      </NumberInputStepper>
+                    </NumberInput>
+                  );
+                }
+                if (input.valueType === WorkflowIOValueTypeEnum.boolean) {
+                  return (
+                    <Box>
+                      <Switch size={'lg'} {...register(input.key)} />
+                    </Box>
+                  );
+                }
+                if (typeof input.value === 'string') {
+                  return (
+                    <JsonEditor
+                      bg={'myGray.50'}
+                      placeholder={t(input.placeholder || '')}
+                      resize
+                      value={getValues(input.key)}
+                      onChange={(e) => {
+                        setValue(input.key, e);
+                      }}
+                    />
+                  );
+                }
+              })();
+
+              return !!RenderInput ? (
+                <Box key={input.key} _notLast={{ mb: 4 }} px={1}>
+                  <Flex alignItems={'center'} mb={1}>
+                    <Box position={'relative'}>
+                      {required && (
+                        <Box position={'absolute'} right={-2} top={'-1px'} color={'red.600'}>
+                          *
+                        </Box>
+                      )}
+                      {t(input.debugLabel || input.label)}
+                    </Box>
+                    {input.description && <QuestionTip ml={2} label={input.description} />}
+                  </Flex>
+                  {RenderInput}
                </Box>
-              );
+              ) : null;
            })}
          </Box>
          <Flex py={2} justifyContent={'flex-end'}>
--- a/projects/app/src/components/core/workflow/Flow/index.tsx
+++ b/projects/app/src/components/core/workflow/Flow/index.tsx
@@ -35,7 +35,7 @@ import { useContextSelector } from 'use-context-selector';
 import { WorkflowContext } from '../context';

 const NodeSimple = dynamic(() => import('./nodes/NodeSimple'));
-const nodeTypes: Record<`${FlowNodeTypeEnum}`, any> = {
+const nodeTypes: Record<FlowNodeTypeEnum, any> = {
  [FlowNodeTypeEnum.emptyNode]: NodeSimple,
  [FlowNodeTypeEnum.globalVariable]: NodeSimple,
  [FlowNodeTypeEnum.systemConfig]: dynamic(() => import('./nodes/NodeSystemConfig')),
--- a/projects/app/src/components/core/workflow/Flow/nodes/NodePluginInput.tsx
+++ b/projects/app/src/components/core/workflow/Flow/nodes/NodePluginInput.tsx
@@ -146,17 +146,9 @@ const NodePluginInput = ({ data, selected }: NodeProps<FlowNodeItemType>) => {
              if (!input) return;

              setEditField({
+                ...input,
                inputType: input.renderTypeList[0],
-                valueType: input.valueType,
-                key: input.key,
-                label: input.label,
-                description: input.description,
-                isToolInput: !!input.toolDescription,
-                defaultValue: input.defaultValue,
-                maxLength: input.maxLength,
-                max: input.max,
-                min: input.min,
-                dynamicParamDefaultValue: input.dynamicParamDefaultValue
+                isToolInput: !!input.toolDescription
              });
            }}
            onEdit={({ data, changeKey }) => {
@@ -165,20 +157,14 @@ const NodePluginInput = ({ data, selected }: NodeProps<FlowNodeItemType>) => {
              const output = outputs.find((output) => output.key === editField.key);

              const newInput: FlowNodeInputItemType = {
+                ...data,
                key: data.key,
-                valueType: data.valueType,
                label: data.label || '',
                renderTypeList: [data.inputType],
-                required: data.required,
-                description: data.description,
                toolDescription: data.isToolInput ? data.description : undefined,
                canEdit: true,
                value: data.defaultValue,
-                editField: dynamicInputEditField,
-                maxLength: data.maxLength,
-                max: data.max,
-                min: data.min,
-                dynamicParamDefaultValue: data.dynamicParamDefaultValue
+                editField: dynamicInputEditField
              };
              const newOutput: FlowNodeOutputItemType = {
                ...(output as FlowNodeOutputItemType),
--- a/projects/app/src/components/core/workflow/Flow/nodes/render/FieldEditModal.tsx
+++ b/projects/app/src/components/core/workflow/Flow/nodes/render/FieldEditModal.tsx
@@ -24,6 +24,8 @@ import MySelect from '@fastgpt/web/components/common/MySelect';
 import { NodeInputKeyEnum, WorkflowIOValueTypeEnum } from '@fastgpt/global/core/workflow/constants';

 import dynamic from 'next/dynamic';
+import MyNumberInput from '@fastgpt/web/components/common/Input/NumberInput/index';
+import { useI18n } from '@/web/context/I18n';

 const JsonEditor = dynamic(() => import('@fastgpt/web/components/common/Textarea/JsonEditor'));
 const EmptyTip = dynamic(() => import('@fastgpt/web/components/common/EmptyTip'));
@@ -63,6 +65,7 @@ const FieldEditModal = ({
  onSubmit: (e: { data: EditNodeFieldType; changeKey: boolean }) => void;
 }) => {
  const { t } = useTranslation();
+  const { workflowT } = useI18n();
  const { toast } = useToast();
  const showDynamicInputSelect =
    !keys.includes(NodeInputKeyEnum.addInputParam) ||
@@ -274,7 +277,6 @@ const FieldEditModal = ({
  );
  const onSubmitError = useCallback(
    (e: Object) => {
-      console.log(e);
      for (const item of Object.values(e)) {
        if (item.message) {
          toast({
@@ -293,7 +295,6 @@ const FieldEditModal = ({
      isOpen={true}
      iconSrc="/imgs/workflow/extract.png"
      title={t('core.module.edit.Field Edit')}
-      onClose={onClose}
      maxW={['90vw', showInputTypeSelect ? '800px' : '400px']}
      w={'100%'}
      overflow={'unset'}
@@ -364,6 +365,10 @@ const FieldEditModal = ({
          {/* input type config */}
          {showInputTypeSelect && (
            <Stack flex={1} gap={5}>
+              <Flex alignItems={'center'}>
+                <Box flex={'0 0 70px'}>{workflowT('Field required')}</Box>
+                <Switch {...register('required')} />
+              </Flex>
              {showToolInput && (
                <Flex alignItems={'center'}>
                  <Box flex={'0 0 70px'}>工具参数</Box>
@@ -426,10 +431,16 @@ const FieldEditModal = ({
              {showMaxLenInput && (
                <Flex alignItems={'center'}>
                  <Box flex={'0 0 70px'}>{t('core.module.Max Length')}</Box>
-                  <Input
+                  <MyNumberInput
+                    flex={'1 0 0'}
                    bg={'myGray.50'}
                    placeholder={t('core.module.Max Length placeholder')}
-                    {...register('maxLength')}
+                    value={maxLength}
+                    onChange={(e) => {
+                      // @ts-ignore
+                      setValue('maxLength', e);
+                    }}
+                    // {...register('maxLength')}
                  />
                </Flex>
              )}
@@ -437,11 +448,27 @@ const FieldEditModal = ({
                <>
                  <Flex alignItems={'center'}>
                    <Box flex={'0 0 70px'}>{t('core.module.Max Value')}</Box>
-                    <Input bg={'myGray.50'} type={'number'} {...register('max')} />
+                    <MyNumberInput
+                      flex={'1 0 0'}
+                      bg={'myGray.50'}
+                      value={watch('max')}
+                      onChange={(e) => {
+                        // @ts-ignore
+                        setValue('max', e);
+                      }}
+                    />
                  </Flex>
                  <Flex alignItems={'center'}>
                    <Box flex={'0 0 70px'}>{t('core.module.Min Value')}</Box>
-                    <Input bg={'myGray.50'} type={'number'} {...register('min')} />
+                    <MyNumberInput
+                      flex={'1 0 0'}
+                      bg={'myGray.50'}
+                      value={watch('min')}
+                      onChange={(e) => {
+                        // @ts-ignore
+                        setValue('min', e);
+                      }}
+                    />
                  </Flex>
                </>
              )}
--- a/projects/app/src/components/core/workflow/Flow/nodes/render/NodeCard.tsx
+++ b/projects/app/src/components/core/workflow/Flow/nodes/render/NodeCard.tsx
@@ -55,7 +55,6 @@ const NodeCard = (props: Props) => {
    maxW = '600px',
    nodeId,
    flowNodeType,
-    inputs,
    selected,
    menuForbid,
    isTool = false,
--- a/projects/app/src/components/core/workflow/Flow/nodes/render/RenderInput/Label.tsx
+++ b/projects/app/src/components/core/workflow/Flow/nodes/render/RenderInput/Label.tsx
@@ -90,17 +90,13 @@ const InputLabel = ({ nodeId, input }: Props) => {
                _hover={{ color: 'primary.500' }}
                onClick={() =>
                  setEditField({
+                    ...input,
                    inputType: renderTypeList[0],
                    valueType: valueType,
                    key,
                    label,
                    description,
-                    isToolInput: !!toolDescription,
-                    defaultValue: input.defaultValue,
-                    maxLength: input.maxLength,
-                    max: input.max,
-                    min: input.min,
-                    dynamicParamDefaultValue: input.dynamicParamDefaultValue
+                    isToolInput: !!toolDescription
                  })
                }
              />
--- a/projects/app/src/components/core/workflow/Flow/nodes/render/VariableTable.tsx
+++ b/projects/app/src/components/core/workflow/Flow/nodes/render/VariableTable.tsx
@@ -106,7 +106,6 @@ const VariableTable = ({
          keys={keys}
          onClose={onCloseFieldEdit}
          onSubmit={(e) => {
-            console.log(e);
            if (!!createField && onCreate) {
              onCreate(e);
            } else if (!!editField && onEdit) {
--- a/projects/app/src/components/core/workflow/context.tsx
+++ b/projects/app/src/components/core/workflow/context.tsx
@@ -322,7 +322,6 @@ const WorkflowContextProvider = ({
            item.key === props.key ? props.value : item
          );
        } else if (type === 'replaceInput') {
-          onDelEdge({ nodeId, targetHandle: getHandleId(nodeId, 'target', props.key) });
          const oldInputIndex = node.data.inputs.findIndex((item) => item.key === props.key);
          updateObj.inputs = node.data.inputs.filter((item) => item.key !== props.key);
          setTimeout(() => {
@@ -351,7 +350,6 @@ const WorkflowContextProvider = ({
            }
          }
        } else if (type === 'delInput') {
-          onDelEdge({ nodeId, targetHandle: getHandleId(nodeId, 'target', props.key) });
          updateObj.inputs = node.data.inputs.filter((item) => item.key !== props.key);
        } else if (type === 'updateOutput') {
          updateObj.outputs = node.data.outputs.map((item) =>
--- a/projects/app/src/components/core/workflow/utils.ts
+++ b/projects/app/src/components/core/workflow/utils.ts
@@ -24,6 +24,15 @@ export const flowNode2StoreNodes = ({
    outputs: item.data.outputs,
    pluginId: item.data.pluginId
  }));
+
+  // get all handle
+  const reactFlowViewport = document.querySelector('.react-flow__viewport');
+  // Gets the value of data-handleid on all elements below it whose data-handleid is not empty
+  const handleList =
+    reactFlowViewport?.querySelectorAll('[data-handleid]:not([data-handleid=""])') || [];
+  const handleIdList = Array.from(handleList).map(
+    (item) => item.getAttribute('data-handleid') || ''
+  );
  const formatEdges: StoreEdgeItemType[] = edges
    .map((item) => ({
      source: item.source,
@@ -31,7 +40,11 @@ export const flowNode2StoreNodes = ({
      sourceHandle: item.sourceHandle || '',
      targetHandle: item.targetHandle || ''
    }))
-    .filter((item) => item.sourceHandle && item.targetHandle);
+    .filter((item) => item.sourceHandle && item.targetHandle)
+    .filter(
+      // Filter out edges that do not have both sourceHandle and targetHandle
+      (item) => handleIdList.includes(item.sourceHandle) && handleIdList.includes(item.targetHandle)
+    );

  return {
    nodes: formatNodes,
--- a/projects/app/src/pages/app/detail/components/FlowEdit/Header.tsx
+++ b/projects/app/src/pages/app/detail/components/FlowEdit/Header.tsx
@@ -131,7 +131,7 @@ const RenderHeaderContainer = React.memo(function RenderHeaderContainer({

      return null;
    },
-    [isShowVersionHistories, edges, updateAppDetail, app._id, t]
+    [isV2Workflow, isShowVersionHistories, edges, updateAppDetail, app._id, t]
  );

  const onclickPublish = useCallback(async () => {
--- a/projects/app/src/pages/app/detail/index.tsx
+++ b/projects/app/src/pages/app/detail/index.tsx
@@ -196,7 +196,10 @@ export async function getServerSideProps(context: any) {
  const currentTab = context?.query?.currentTab || TabEnum.simpleEdit;

  return {
-    props: { currentTab, ...(await serviceSideProps(context, ['app', 'file', 'publish'])) }
+    props: {
+      currentTab,
+      ...(await serviceSideProps(context, ['app', 'file', 'publish', 'workflow']))
+    }
  };
 }

--- a/projects/app/src/pages/plugin/edit/index.tsx
+++ b/projects/app/src/pages/plugin/edit/index.tsx
@@ -91,7 +91,7 @@ export async function getServerSideProps(context: any) {
  return {
    props: {
      pluginId: context?.query?.pluginId || '',
-      ...(await serviceSideProps(context))
+      ...(await serviceSideProps(context, ['app', 'workflow']))
    }
  };
 }
--- a/projects/app/src/pages/plugin/list/component/EditModal.tsx
+++ b/projects/app/src/pages/plugin/list/component/EditModal.tsx
@@ -20,6 +20,7 @@ import { MongoImageTypeEnum } from '@fastgpt/global/common/file/image/constants'
 import { PluginTypeEnum } from '@fastgpt/global/core/plugin/constants';
 import { useWorkflowStore } from '@/web/core/workflow/store/workflow';
 import { EditFormType } from './type';
+import { FlowNodeTypeEnum } from '@fastgpt/global/core/workflow/node/constant';
 const nanoid = customAlphabet('abcdefghijklmnopqrstuvwxyz1234567890', 12);

 export const defaultForm: EditFormType = {
@@ -33,7 +34,7 @@ export const defaultForm: EditFormType = {
      nodeId: nanoid(),
      name: '自定义插件输入',
      avatar: '/imgs/workflow/input.png',
-      flowNodeType: 'pluginInput',
+      flowNodeType: FlowNodeTypeEnum.pluginInput,
      showStatus: false,
      position: {
        x: 616.4226348688949,
@@ -47,7 +48,7 @@ export const defaultForm: EditFormType = {
      nodeId: nanoid(),
      name: '自定义插件输出',
      avatar: '/imgs/workflow/output.png',
-      flowNodeType: 'pluginOutput',
+      flowNodeType: FlowNodeTypeEnum.pluginOutput,
      showStatus: false,
      position: {
        x: 1607.7142331269126,
--- a/projects/app/src/types/i18n.d.ts
+++ b/projects/app/src/types/i18n.d.ts
@@ -4,6 +4,7 @@ import dataset from '../../i18n/zh/dataset.json';
 import app from '../../i18n/zh/app.json';
 import file from '../../i18n/zh/file.json';
 import publish from '../../i18n/zh/publish.json';
+import workflow from '../../i18n/zh/workflow.json';

 export interface I18nNamespaces {
  common: typeof common;
@@ -11,6 +12,7 @@ export interface I18nNamespaces {
  app: typeof app;
  file: typeof file;
  publish: typeof publish;
+  workflow: typeof workflow;
 }

 export type I18nNsType = (keyof I18nNamespaces)[];
--- a/projects/app/src/web/context/I18n.tsx
+++ b/projects/app/src/web/context/I18n.tsx
@@ -8,6 +8,7 @@ type I18nContextType = {
  datasetT: TFunction<['dataset'], undefined>;
  fileT: TFunction<['file'], undefined>;
  publishT: TFunction<['publish'], undefined>;
+  workflowT: TFunction<['workflow'], undefined>;
 };

 export const I18nContext = createContext<I18nContextType>({
@@ -21,6 +22,7 @@ const I18nContextProvider = ({ children }: { children: React.ReactNode }) => {
  const { t: datasetT } = useTranslation('dataset');
  const { t: fileT } = useTranslation('file');
  const { t: publishT } = useTranslation('publish');
+  const { t: workflowT } = useTranslation('workflow');

  return (
    <I18nContext.Provider
@@ -29,7 +31,8 @@ const I18nContextProvider = ({ children }: { children: React.ReactNode }) => {
        appT,
        datasetT,
        fileT,
-        publishT
+        publishT,
+        workflowT
      }}
    >
      {children}
--- a/projects/app/src/web/core/app/templates.ts
+++ b/projects/app/src/web/core/app/templates.ts
@@ -1,7 +1,10 @@
 import { AppItemType } from '@/types/app';
 import { AppTypeEnum } from '@fastgpt/global/core/app/constants';
 import { WorkflowIOValueTypeEnum } from '@fastgpt/global/core/workflow/constants';
-import { FlowNodeInputTypeEnum } from '@fastgpt/global/core/workflow/node/constant';
+import {
+  FlowNodeInputTypeEnum,
+  FlowNodeTypeEnum
+} from '@fastgpt/global/core/workflow/node/constant';

 // template
 export const appTemplates: (AppItemType & {
@@ -21,7 +24,7 @@ export const appTemplates: (AppItemType & {
        name: '系统配置',
        intro: '可以配置应用的系统参数',
        avatar: '/imgs/workflow/userGuide.png',
-        flowNodeType: 'userGuide',
+        flowNodeType: FlowNodeTypeEnum.systemConfig,
        position: {
          x: 531.2422736065552,
          y: -486.7611729549753
@@ -84,7 +87,7 @@ export const appTemplates: (AppItemType & {
        name: '流程开始',
        intro: '',
        avatar: '/imgs/workflow/userChatInput.svg',
-        flowNodeType: 'workflowStart',
+        flowNodeType: FlowNodeTypeEnum.workflowStart,
        position: {
          x: 558.4082376415505,
          y: 123.72387429194112
@@ -115,7 +118,7 @@ export const appTemplates: (AppItemType & {
        name: 'AI 对话',
        intro: 'AI 大模型对话',
        avatar: '/imgs/workflow/AI.png',
-        flowNodeType: 'chatNode',
+        flowNodeType: FlowNodeTypeEnum.chatNode,
        showStatus: true,
        position: {
          x: 1097.7317280958762,
@@ -251,7 +254,7 @@ export const appTemplates: (AppItemType & {
        name: '系统配置',
        intro: '可以配置应用的系统参数',
        avatar: '/imgs/workflow/userGuide.png',
-        flowNodeType: 'userGuide',
+        flowNodeType: FlowNodeTypeEnum.systemConfig,
        position: {
          x: 496.57560693988853,
          y: -490.7611729549753
@@ -331,7 +334,7 @@ export const appTemplates: (AppItemType & {
        name: '流程开始',
        intro: '',
        avatar: '/imgs/workflow/userChatInput.svg',
-        flowNodeType: 'workflowStart',
+        flowNodeType: FlowNodeTypeEnum.workflowStart,
        position: {
          x: 558.4082376415505,
          y: 123.72387429194112
@@ -362,7 +365,7 @@ export const appTemplates: (AppItemType & {
        name: 'AI 对话',
        intro: 'AI 大模型对话',
        avatar: '/imgs/workflow/AI.png',
-        flowNodeType: 'chatNode',
+        flowNodeType: FlowNodeTypeEnum.chatNode,
        showStatus: true,
        position: {
          x: 1097.7317280958762,
@@ -498,7 +501,7 @@ export const appTemplates: (AppItemType & {
        name: '系统配置',
        intro: '可以配置应用的系统参数',
        avatar: '/imgs/workflow/userGuide.png',
-        flowNodeType: 'userGuide',
+        flowNodeType: FlowNodeTypeEnum.systemConfig,
        position: {
          x: 531.2422736065552,
          y: -486.7611729549753
@@ -561,7 +564,7 @@ export const appTemplates: (AppItemType & {
        name: '流程开始',
        intro: '',
        avatar: '/imgs/workflow/userChatInput.svg',
-        flowNodeType: 'workflowStart',
+        flowNodeType: FlowNodeTypeEnum.workflowStart,
        position: {
          x: 558.4082376415505,
          y: 123.72387429194112
@@ -592,7 +595,7 @@ export const appTemplates: (AppItemType & {
        name: 'AI 对话',
        intro: 'AI 大模型对话',
        avatar: '/imgs/workflow/AI.png',
-        flowNodeType: 'chatNode',
+        flowNodeType: FlowNodeTypeEnum.chatNode,
        showStatus: true,
        position: {
          x: 1638.509551404687,
@@ -712,7 +715,7 @@ export const appTemplates: (AppItemType & {
        name: '知识库搜索',
        intro: '调用“语义检索”和“全文检索”能力，从“知识库”中查找可能与问题相关的参考内容',
        avatar: '/imgs/workflow/db.png',
-        flowNodeType: 'datasetSearchNode',
+        flowNodeType: FlowNodeTypeEnum.datasetSearchNode,
        showStatus: true,
        position: {
          x: 918.5901682164496,
@@ -826,7 +829,7 @@ export const appTemplates: (AppItemType & {
        name: '系统配置',
        intro: '可以配置应用的系统参数',
        avatar: '/imgs/workflow/userGuide.png',
-        flowNodeType: 'userGuide',
+        flowNodeType: FlowNodeTypeEnum.systemConfig,
        position: {
          x: 531.2422736065552,
          y: -486.7611729549753
@@ -889,7 +892,7 @@ export const appTemplates: (AppItemType & {
        name: '流程开始',
        intro: '',
        avatar: '/imgs/workflow/userChatInput.svg',
-        flowNodeType: 'workflowStart',
+        flowNodeType: FlowNodeTypeEnum.workflowStart,
        position: {
          x: 558.4082376415505,
          y: 123.72387429194112
@@ -920,7 +923,7 @@ export const appTemplates: (AppItemType & {
        name: 'AI 对话',
        intro: 'AI 大模型对话',
        avatar: '/imgs/workflow/AI.png',
-        flowNodeType: 'chatNode',
+        flowNodeType: FlowNodeTypeEnum.chatNode,
        showStatus: true,
        position: {
          x: 2701.1267277679685,
@@ -1041,7 +1044,7 @@ export const appTemplates: (AppItemType & {
        intro:
          '根据用户的历史记录和当前问题判断该次提问的类型。可以添加多组问题类型，下面是一个模板例子：\n类型1: 打招呼\n类型2: 关于商品“使用”问题\n类型3: 关于商品“购买”问题\n类型4: 其他问题',
        avatar: '/imgs/workflow/cq.png',
-        flowNodeType: 'classifyQuestion',
+        flowNodeType: FlowNodeTypeEnum.classifyQuestion,
        showStatus: true,
        position: {
          x: 1020.9667229609946,
@@ -1123,7 +1126,7 @@ export const appTemplates: (AppItemType & {
        intro:
          '该模块可以直接回复一段指定的内容。常用于引导、提示。非字符串内容传入时，会转成字符串进行输出。',
        avatar: '/imgs/workflow/reply.png',
-        flowNodeType: 'answerNode',
+        flowNodeType: FlowNodeTypeEnum.answerNode,
        position: {
          x: 1874.9167551056487,
          y: 434.98431875888207
@@ -1148,7 +1151,7 @@ export const appTemplates: (AppItemType & {
        name: '知识库搜索',
        intro: '调用“语义检索”和“全文检索”能力，从“知识库”中查找可能与问题相关的参考内容',
        avatar: '/imgs/workflow/db.png',
-        flowNodeType: 'datasetSearchNode',
+        flowNodeType: FlowNodeTypeEnum.datasetSearchNode,
        showStatus: true,
        position: {
          x: 1851.010152279949,
--- a/projects/app/src/web/core/app/utils.ts
+++ b/projects/app/src/web/core/app/utils.ts
@@ -75,7 +75,7 @@ export function form2AppWorkflow(data: AppSimpleEditFormType): WorkflowType {
      name: '流程开始',
      intro: '',
      avatar: '/imgs/workflow/userChatInput.svg',
-      flowNodeType: 'workflowStart',
+      flowNodeType: FlowNodeTypeEnum.workflowStart,
      position: {
        x: 558.4082376415505,
        y: 123.72387429194112
@@ -111,7 +111,7 @@ export function form2AppWorkflow(data: AppSimpleEditFormType): WorkflowType {
          name: 'AI 对话',
          intro: 'AI 大模型对话',
          avatar: '/imgs/workflow/AI.png',
-          flowNodeType: 'chatNode',
+          flowNodeType: FlowNodeTypeEnum.chatNode,
          showStatus: true,
          position: {
            x: 1106.3238387960757,
@@ -244,7 +244,7 @@ export function form2AppWorkflow(data: AppSimpleEditFormType): WorkflowType {
          name: 'AI 对话',
          intro: 'AI 大模型对话',
          avatar: '/imgs/workflow/AI.png',
-          flowNodeType: 'chatNode',
+          flowNodeType: FlowNodeTypeEnum.chatNode,
          showStatus: true,
          position: {
            x: 1638.509551404687,
@@ -364,7 +364,7 @@ export function form2AppWorkflow(data: AppSimpleEditFormType): WorkflowType {
          name: '知识库搜索',
          intro: '调用“语义检索”和“全文检索”能力，从“知识库”中查找可能与问题相关的参考内容',
          avatar: '/imgs/workflow/db.png',
-          flowNodeType: 'datasetSearchNode',
+          flowNodeType: FlowNodeTypeEnum.datasetSearchNode,
          showStatus: true,
          position: {
            x: 918.5901682164496,
@@ -483,7 +483,7 @@ export function form2AppWorkflow(data: AppSimpleEditFormType): WorkflowType {
                name: '知识库搜索',
                intro: '调用“语义检索”和“全文检索”能力，从“知识库”中查找可能与问题相关的参考内容',
                avatar: '/imgs/workflow/db.png',
-                flowNodeType: 'datasetSearchNode',
+                flowNodeType: FlowNodeTypeEnum.datasetSearchNode,
                showStatus: true,
                position: {
                  x: 500,
@@ -626,7 +626,7 @@ export function form2AppWorkflow(data: AppSimpleEditFormType): WorkflowType {
          name: '工具调用（实验）',
          intro: '通过AI模型自动选择一个或多个功能块进行调用，也可以对插件进行调用。',
          avatar: '/imgs/workflow/tool.svg',
-          flowNodeType: 'tools',
+          flowNodeType: FlowNodeTypeEnum.tools,
          showStatus: true,
          position: {
            x: 1062.1738942532802,
--- a/projects/app/src/web/core/workflow/constants/dataType.ts
+++ b/projects/app/src/web/core/workflow/constants/dataType.ts
@@ -70,7 +70,9 @@ export const FlowValueTypeMap = {
  [WorkflowIOValueTypeEnum.selectDataset]: {
    label: '选择知识库',
    value: WorkflowIOValueTypeEnum.selectDataset,
-    description: ''
+    description: `{
+  datasetId: string;
+}`
  },
  [WorkflowIOValueTypeEnum.any]: {
    label: 'any',
--- a/projects/app/src/web/core/workflow/utils.ts
+++ b/projects/app/src/web/core/workflow/utils.ts
@@ -323,7 +323,12 @@ export const updateFlowNodeVersion = (
    });
  }

-  const updatedNode: FlowNodeItemType = { ...node, ...template, name: node.name };
+  const updatedNode: FlowNodeItemType = {
+    ...node,
+    ...template,
+    name: node.name,
+    intro: node.intro
+  };

  if (node.inputs && template.inputs) {
    updatedNode.inputs = updateArrayBasedOnTemplate(node.inputs, template.inputs);