From c53caaf6504a64f682a12f62b22e1902ad10f791 Mon Sep 17 00:00:00 2001
From: heheer <zhiyu44@qq.com>
Date: Wed, 7 Jan 2026 16:27:31 +0800
Subject: [PATCH 1/9] fix v4.14.5 bugs

---
 document/content/docs/upgrading/4-14/4145.mdx |  6 +++
 document/data/doc-last-modified.json          |  4 +-
 .../global/openapi/core/chat/controler/api.ts |  5 +-
 packages/service/core/chat/controller.ts      | 54 ++++++++++---------
 .../workflow/dispatch/tools/runUpdateVar.ts   | 13 +----
 .../core/chat/components/AIResponseBox.tsx    | 16 ++++--
 .../Flow/nodes/NodeCode/Copilot.tsx           | 41 ++++++++------
 .../Flow/nodes/NodeCode/index.tsx             |  4 +-
 .../app/src/pages/api/v2/chat/completions.ts  | 17 ++++--
 9 files changed, 94 insertions(+), 66 deletions(-)

diff --git a/document/content/docs/upgrading/4-14/4145.mdx b/document/content/docs/upgrading/4-14/4145.mdx
index 494087bb7208..3d9d990074c0 100644
--- a/document/content/docs/upgrading/4-14/4145.mdx
+++ b/document/content/docs/upgrading/4-14/4145.mdx
@@ -36,5 +36,11 @@ description: 'FastGPT V4.14.5 更新说明'
 5. 加载默认模型时，maxTokens 字段未赋值，导致模型最大响应值配置为空。
 6. S3 文件清理队列因网络稳定问题出现阻塞，导致删除任务不再执行。
 7. 对话日志接口适配 mongo4.x 语法。
+8. 变量更新节点将文件 URL 字符串数组错误转换为对象数组。
+9. 多个表单输入节点共享 sessionStorage 导致默认值不显示。
+10. 代码运行节点切换语言后，AI 仍使用旧语言生成代码。
+11. 多个自定义反馈节点并发写入触发数据库写入冲突。
+12. 交互节点后续的自定义反馈节点写入失败。
+
 
 ## 插件
diff --git a/document/data/doc-last-modified.json b/document/data/doc-last-modified.json
index 315e4521f8f9..4c9c1630ab1f 100644
--- a/document/data/doc-last-modified.json
+++ b/document/data/doc-last-modified.json
@@ -104,7 +104,7 @@
   "document/content/docs/protocol/terms.en.mdx": "2025-12-15T23:36:54+08:00",
   "document/content/docs/protocol/terms.mdx": "2025-12-15T23:36:54+08:00",
   "document/content/docs/toc.en.mdx": "2025-08-04T13:42:36+08:00",
-  "document/content/docs/toc.mdx": "2026-01-06T18:19:42+08:00",
+  "document/content/docs/toc.mdx": "2026-01-06T13:25:46+08:00",
   "document/content/docs/upgrading/4-10/4100.mdx": "2025-08-02T19:38:37+08:00",
   "document/content/docs/upgrading/4-10/4101.mdx": "2025-09-08T20:07:20+08:00",
   "document/content/docs/upgrading/4-11/4110.mdx": "2025-08-05T23:20:39+08:00",
@@ -204,4 +204,4 @@
   "document/content/docs/use-cases/external-integration/openapi.mdx": "2025-09-29T11:34:11+08:00",
   "document/content/docs/use-cases/external-integration/wecom.mdx": "2025-12-10T20:07:05+08:00",
   "document/content/docs/use-cases/index.mdx": "2025-07-24T14:23:04+08:00"
-}
\ No newline at end of file
+}
diff --git a/packages/global/openapi/core/chat/controler/api.ts b/packages/global/openapi/core/chat/controler/api.ts
index 76d1b4314d04..9eb891584f18 100644
--- a/packages/global/openapi/core/chat/controler/api.ts
+++ b/packages/global/openapi/core/chat/controler/api.ts
@@ -8,7 +8,10 @@ export const InitChatQuerySchema = z
   .object({
     appId: ObjectIdSchema.describe('应用ID'),
     chatId: z.string().min(1).describe('对话ID'),
-    loadCustomFeedbacks: z.coerce.boolean().optional().describe('是否加载自定义反馈')
+    loadCustomFeedbacks: z
+      .union([z.boolean(), z.string().transform((val) => val === 'true')])
+      .optional()
+      .describe('是否加载自定义反馈')
   })
   .meta({
     example: {
diff --git a/packages/service/core/chat/controller.ts b/packages/service/core/chat/controller.ts
index 1ef39b10c033..f48e2051769a 100644
--- a/packages/service/core/chat/controller.ts
+++ b/packages/service/core/chat/controller.ts
@@ -194,6 +194,9 @@ export async function getChatItems({
   return { histories, total, hasMorePrev, hasMoreNext };
 }
 
+// Maintain a write queue per document to avoid concurrent write conflicts
+const customFeedbackQueues = new Map<string, Promise<void>>();
+
 export const addCustomFeedbacks = async ({
   appId,
   chatId,
@@ -207,32 +210,33 @@ export const addCustomFeedbacks = async ({
 }) => {
   if (!chatId || !dataId) return;
 
-  try {
-    await mongoSessionRun(async (session) => {
-      // Add custom feedbacks to ChatItem
-      await MongoChatItem.updateOne(
-        {
-          appId,
-          chatId,
-          dataId
-        },
-        {
-          $push: { customFeedbacks: { $each: feedbacks } }
-        },
-        { session }
-      );
-
-      // Update ChatLog feedback statistics
-      await updateChatFeedbackCount({
-        appId,
-        chatId,
-        session
-      });
+  const queueKey = `${chatId}_${dataId}`;
+  const previousTask = customFeedbackQueues.get(queueKey) || Promise.resolve();
+
+  const task = previousTask
+    .then(() =>
+      mongoSessionRun(async (session) => {
+        await MongoChatItem.updateOne(
+          { appId, chatId, dataId },
+          { $push: { customFeedbacks: { $each: feedbacks } } },
+          { session }
+        );
+
+        await updateChatFeedbackCount({ appId, chatId, session });
+      })
+    )
+    .catch((error) => {
+      addLog.error('addCustomFeedbacks error', error);
+      throw error;
+    })
+    .finally(() => {
+      if (customFeedbackQueues.get(queueKey) === task) {
+        customFeedbackQueues.delete(queueKey);
+      }
     });
-  } catch (error) {
-    addLog.error('addCustomFeedbacks error', error);
-    throw error;
-  }
+
+  customFeedbackQueues.set(queueKey, task);
+  await task;
 };
 
 /**
diff --git a/packages/service/core/workflow/dispatch/tools/runUpdateVar.ts b/packages/service/core/workflow/dispatch/tools/runUpdateVar.ts
index cb16b4c0d5fc..0196c89da693 100644
--- a/packages/service/core/workflow/dispatch/tools/runUpdateVar.ts
+++ b/packages/service/core/workflow/dispatch/tools/runUpdateVar.ts
@@ -14,8 +14,6 @@ import { type ModuleDispatchProps } from '@fastgpt/global/core/workflow/runtime/
 import { runtimeSystemVar2StoreType } from '../utils';
 import { isValidReferenceValue } from '@fastgpt/global/core/workflow/utils';
 import { valueTypeFormat } from '@fastgpt/global/core/workflow/runtime/utils';
-import { parseUrlToFileType } from '@fastgpt/global/common/file/tools';
-import { z } from 'zod';
 
 type Props = ModuleDispatchProps<{
   [NodeInputKeyEnum.updateList]: TUpdateListItem[];
@@ -36,7 +34,6 @@ export const dispatchUpdateVariable = async (props: Props): Promise<Response> =>
 
   const { updateList } = params;
   const nodeIds = runtimeNodes.map((node) => node.nodeId);
-  const urlSchema = z.string().url();
 
   const result = updateList.map((item) => {
     const variable = item.variable;
@@ -66,19 +63,11 @@ export const dispatchUpdateVariable = async (props: Props): Promise<Response> =>
 
         return valueTypeFormat(val, item.valueType);
       } else {
-        const val = getReferenceVariableValue({
+        return getReferenceVariableValue({
           value: item.value,
           variables,
           nodes: runtimeNodes
         });
-
-        if (
-          Array.isArray(val) &&
-          val.every((url) => typeof url === 'string' && urlSchema.safeParse(url).success)
-        ) {
-          return val.map((url) => parseUrlToFileType(url)).filter(Boolean);
-        }
-        return val;
       }
     })();
 
diff --git a/projects/app/src/components/core/chat/components/AIResponseBox.tsx b/projects/app/src/components/core/chat/components/AIResponseBox.tsx
index 1a05f0692f4f..2438267629ef 100644
--- a/projects/app/src/components/core/chat/components/AIResponseBox.tsx
+++ b/projects/app/src/components/core/chat/components/AIResponseBox.tsx
@@ -225,9 +225,15 @@ const RenderUserFormInteractive = React.memo(function RenderFormInput({
 }) {
   const { t } = useTranslation();
 
+  // 使用 entryNodeIds 生成唯一的 storage key，避免不同表单节点共用同一个缓存
+  const uniqueStorageKey = useMemo(() => {
+    const nodeIds = interactive.entryNodeIds?.join('-') || 'unknown';
+    return `${chatItemDataId}_${nodeIds}`;
+  }, [chatItemDataId, interactive.entryNodeIds]);
+
   const defaultValues = useMemo(() => {
     if (interactive.type === 'userInput') {
-      return interactive.params.inputForm?.reduce((acc: Record<string, any>, item, index) => {
+      return interactive.params.inputForm?.reduce((acc: Record<string, any>, item) => {
         // 使用 ?? 运算符，只有 undefined 或 null 时才使用 defaultValue
         acc[item.key] = item.value ?? item.defaultValue;
         return acc;
@@ -239,7 +245,7 @@ const RenderUserFormInteractive = React.memo(function RenderFormInput({
   const handleFormSubmit = useCallback(
     (data: Record<string, any>) => {
       const finalData: Record<string, any> = {};
-      interactive.params.inputForm?.forEach((item, index) => {
+      interactive.params.inputForm?.forEach((item) => {
         if (item.key in data) {
           finalData[item.key] = data[item.key];
         }
@@ -266,7 +272,7 @@ const RenderUserFormInteractive = React.memo(function RenderFormInput({
             }
           }
         });
-        sessionStorage.setItem(`interactiveForm_${chatItemDataId}`, JSON.stringify(dataToSave));
+        sessionStorage.setItem(`interactiveForm_${uniqueStorageKey}`, JSON.stringify(dataToSave));
       }
 
       onSendPrompt({
@@ -274,7 +280,7 @@ const RenderUserFormInteractive = React.memo(function RenderFormInput({
         isInteractivePrompt: true
       });
     },
-    [interactive.params.inputForm, chatItemDataId]
+    [interactive.params.inputForm, uniqueStorageKey]
   );
 
   return (
@@ -282,7 +288,7 @@ const RenderUserFormInteractive = React.memo(function RenderFormInput({
       <FormInputComponent
         interactiveParams={interactive.params}
         defaultValues={defaultValues}
-        chatItemDataId={chatItemDataId}
+        chatItemDataId={uniqueStorageKey}
         SubmitButton={({ onSubmit, isFileUploading }) => (
           <Button
             onClick={() => onSubmit(handleFormSubmit)()}
diff --git a/projects/app/src/pageComponents/app/detail/WorkflowComponents/Flow/nodes/NodeCode/Copilot.tsx b/projects/app/src/pageComponents/app/detail/WorkflowComponents/Flow/nodes/NodeCode/Copilot.tsx
index 173eba51e7b7..912cc40fbffc 100644
--- a/projects/app/src/pageComponents/app/detail/WorkflowComponents/Flow/nodes/NodeCode/Copilot.tsx
+++ b/projects/app/src/pageComponents/app/detail/WorkflowComponents/Flow/nodes/NodeCode/Copilot.tsx
@@ -15,7 +15,6 @@ import { ArrayTypeMap, NodeInputKeyEnum } from '@fastgpt/global/core/workflow/co
 import { AppContext } from '../../../../context';
 import { useTranslation } from 'next-i18next';
 import PromptEditor from '@fastgpt/web/components/common/Textarea/PromptEditor';
-import { useCreation } from 'ahooks';
 import { useToast } from '@fastgpt/web/hooks/useToast';
 import {
   FlowNodeInputTypeEnum,
@@ -27,14 +26,15 @@ import {
   JS_TEMPLATE,
   SandboxCodeTypeEnum
 } from '@fastgpt/global/core/workflow/template/system/sandbox/constants';
-import {
-  WorkflowBufferDataContext,
-  WorkflowNodeDataContext
-} from '../../../context/workflowInitContext';
+import { WorkflowBufferDataContext } from '../../../context/workflowInitContext';
 import { getEditorVariables } from '../../../utils';
 import { extractCodeFromMarkdown } from './parser';
 import { WorkflowActionsContext } from '../../../context/workflowActionsContext';
 import { useMemoEnhance } from '@fastgpt/web/hooks/useMemoEnhance';
+import type {
+  FlowNodeInputItemType,
+  FlowNodeOutputItemType
+} from '@fastgpt/global/core/workflow/type/io';
 
 export type OnOptimizeCodeProps = {
   optimizerInput: string;
@@ -44,7 +44,17 @@ export type OnOptimizeCodeProps = {
   abortController?: AbortController;
 };
 
-const NodeCopilot = ({ nodeId, trigger }: { nodeId: string; trigger: React.ReactNode }) => {
+const NodeCopilot = ({
+  nodeId,
+  inputs: realTimeInputs,
+  outputs: realTimeOutputs,
+  trigger
+}: {
+  nodeId: string;
+  inputs: FlowNodeInputItemType[];
+  outputs: FlowNodeOutputItemType[];
+  trigger: React.ReactNode;
+}) => {
   const { t } = useTranslation();
   const { toast } = useToast();
   const { llmModelList, defaultModels } = useSystemStore();
@@ -76,25 +86,23 @@ const NodeCopilot = ({ nodeId, trigger }: { nodeId: string; trigger: React.React
   }, [nodeId, systemConfigNode, getNodeById, edges, appDetail, t]);
 
   const { codeType, code, dynamicInputs, dynamicOutputs } = useMemo(() => {
-    const currentNode = getNodeById(nodeId);
-    const codeTypeInput = currentNode?.inputs?.find(
-      (input) => input.key === NodeInputKeyEnum.codeType
-    );
-    const codeInput = currentNode?.inputs?.find((input) => input.key === NodeInputKeyEnum.code);
+    const codeTypeInput = realTimeInputs?.find((input) => input.key === NodeInputKeyEnum.codeType);
+    const codeInput = realTimeInputs?.find((input) => input.key === NodeInputKeyEnum.code);
+
     return {
       codeType: codeTypeInput?.value || SandboxCodeTypeEnum.js,
       code: codeInput?.value || JS_TEMPLATE,
       dynamicInputs:
-        currentNode?.inputs?.filter(
+        realTimeInputs?.filter(
           (input) =>
             !['system_addInputParam', 'codeType', NodeInputKeyEnum.code].includes(input.key)
         ) || [],
       dynamicOutputs:
-        currentNode?.outputs?.filter(
+        realTimeOutputs?.filter(
           (output) => !['system_rawResponse', 'error', 'system_addOutputParam'].includes(output.key)
         ) || []
     };
-  }, [getNodeById, nodeId]);
+  }, [realTimeInputs, realTimeOutputs]);
 
   useEffect(() => {
     if (conversationHistory.length === 0) {
@@ -216,9 +224,8 @@ const NodeCopilot = ({ nodeId, trigger }: { nodeId: string; trigger: React.React
     try {
       const extractedResult = extractCodeFromMarkdown(codeResult);
       const { code, inputs, outputs } = extractedResult;
-      const currentNode = getNodeById(nodeId);
-      const codeInput = currentNode?.inputs?.find((input) => input.key === NodeInputKeyEnum.code);
-      if (!codeInput || !currentNode) return;
+      const codeInput = realTimeInputs?.find((input) => input.key === NodeInputKeyEnum.code);
+      if (!codeInput) return;
       onChangeNode({
         nodeId,
         type: 'updateInput',
diff --git a/projects/app/src/pageComponents/app/detail/WorkflowComponents/Flow/nodes/NodeCode/index.tsx b/projects/app/src/pageComponents/app/detail/WorkflowComponents/Flow/nodes/NodeCode/index.tsx
index 5bafcb919638..68b20da8758c 100644
--- a/projects/app/src/pageComponents/app/detail/WorkflowComponents/Flow/nodes/NodeCode/index.tsx
+++ b/projects/app/src/pageComponents/app/detail/WorkflowComponents/Flow/nodes/NodeCode/index.tsx
@@ -147,6 +147,8 @@ const NodeCode = ({ data, selected }: NodeProps<FlowNodeItemType>) => {
       <NodeCopilot
         key="copilot"
         nodeId={nodeId}
+        inputs={inputs}
+        outputs={outputs}
         trigger={
           <Button
             variant={'grayGhost'}
@@ -159,7 +161,7 @@ const NodeCode = ({ data, selected }: NodeProps<FlowNodeItemType>) => {
         }
       />
     ];
-  }, [t]);
+  }, [t, nodeId, inputs, outputs]);
 
   return (
     <NodeCard minW={'400px'} selected={selected} rtDoms={rtDoms} {...data}>
diff --git a/projects/app/src/pages/api/v2/chat/completions.ts b/projects/app/src/pages/api/v2/chat/completions.ts
index 73f49df53897..006d73deb1ea 100644
--- a/projects/app/src/pages/api/v2/chat/completions.ts
+++ b/projects/app/src/pages/api/v2/chat/completions.ts
@@ -119,7 +119,7 @@ async function handler(req: NextApiRequest, res: NextApiResponse) {
     retainDatasetCite = false,
     messages = [],
     variables = {},
-    responseChatItemId = getNanoid(),
+    responseChatItemId: userProvidedChatItemId,
     metadata
   } = req.body as Props;
 
@@ -261,6 +261,19 @@ async function handler(req: NextApiRequest, res: NextApiResponse) {
     // Get chat histories
     const newHistories = concatHistories(histories, chatMessages);
     const interactive = getLastInteractiveValue(newHistories) || undefined;
+
+    const isInteractiveRequest = !!getLastInteractiveValue(histories);
+    const responseChatItemId = (() => {
+      // For interactive request, use the last AI ChatItem dataId
+      if (isInteractiveRequest) {
+        const lastAiChat = histories.findLast((item) => item.obj === ChatRoleEnum.AI);
+        if (lastAiChat?.dataId) {
+          return lastAiChat.dataId;
+        }
+      }
+
+      return userProvidedChatItemId || getNanoid();
+    })();
     // Get runtimeNodes
     let runtimeNodes = storeNodes2RuntimeNodes(nodes, getWorkflowEntryNodeIds(nodes, interactive));
     if (isPlugin) {
@@ -342,8 +355,6 @@ async function handler(req: NextApiRequest, res: NextApiResponse) {
       return ChatSourceEnum.online;
     })();
 
-    const isInteractiveRequest = !!getLastInteractiveValue(histories);
-
     const newTitle = isPlugin
       ? variables.cTime || formatTime2YMDHM(new Date())
       : getChatTitleFromChatMessage(userQuestion);

From aeef905600605c4de384c21d3f154395842ecbb4 Mon Sep 17 00:00:00 2001
From: heheer <zhiyu44@qq.com>
Date: Wed, 7 Jan 2026 16:33:27 +0800
Subject: [PATCH 2/9] type

---
 packages/global/openapi/core/chat/controler/api.ts | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git a/packages/global/openapi/core/chat/controler/api.ts b/packages/global/openapi/core/chat/controler/api.ts
index 9eb891584f18..76d1b4314d04 100644
--- a/packages/global/openapi/core/chat/controler/api.ts
+++ b/packages/global/openapi/core/chat/controler/api.ts
@@ -8,10 +8,7 @@ export const InitChatQuerySchema = z
   .object({
     appId: ObjectIdSchema.describe('应用ID'),
     chatId: z.string().min(1).describe('对话ID'),
-    loadCustomFeedbacks: z
-      .union([z.boolean(), z.string().transform((val) => val === 'true')])
-      .optional()
-      .describe('是否加载自定义反馈')
+    loadCustomFeedbacks: z.coerce.boolean().optional().describe('是否加载自定义反馈')
   })
   .meta({
     example: {

From 3648d38098c54e2ebf613c3fb542c3d278d26ae9 Mon Sep 17 00:00:00 2001
From: heheer <zhiyu44@qq.com>
Date: Thu, 8 Jan 2026 14:41:10 +0800
Subject: [PATCH 3/9] fix

---
 .../global/core/workflow/runtime/type.d.ts    |  1 -
 packages/service/core/chat/controller.ts      | 18 ++-----
 .../service/core/workflow/dispatch/index.ts   | 28 ++++++----
 .../workflow/dispatch/tools/customFeedback.ts |  2 +-
 .../workflow/dispatch/tools/runUpdateVar.ts   |  2 -
 .../service/core/workflow/dispatch/utils.ts   | 33 ++++++++++--
 .../core/chat/components/AIResponseBox.tsx    | 41 ++------------
 .../Interactive/InteractiveComponents.tsx     | 54 +++----------------
 .../app/src/pages/api/v2/chat/completions.ts  | 12 +----
 9 files changed, 61 insertions(+), 130 deletions(-)

diff --git a/packages/global/core/workflow/runtime/type.d.ts b/packages/global/core/workflow/runtime/type.d.ts
index 0900795dd68f..444f5f6eb21d 100644
--- a/packages/global/core/workflow/runtime/type.d.ts
+++ b/packages/global/core/workflow/runtime/type.d.ts
@@ -68,7 +68,6 @@ export type ChatDispatchProps = {
   responseChatItemId?: string;
   histories: ChatItemType[];
   variables: Record<string, any>; // global variable
-  cloneVariables: Record<string, any>;
   query: UserChatItemValueItemType[]; // trigger query
   chatConfig: AppSchema['chatConfig'];
   lastInteractive?: WorkflowInteractiveResponseType; // last interactive response
diff --git a/packages/service/core/chat/controller.ts b/packages/service/core/chat/controller.ts
index f48e2051769a..ad88beb21306 100644
--- a/packages/service/core/chat/controller.ts
+++ b/packages/service/core/chat/controller.ts
@@ -194,8 +194,8 @@ export async function getChatItems({
   return { histories, total, hasMorePrev, hasMoreNext };
 }
 
-// Maintain a write queue per document to avoid concurrent write conflicts
-const customFeedbackQueues = new Map<string, Promise<void>>();
+// Maintain a global write queue to avoid concurrent write conflicts
+let customFeedbackQueue = Promise.resolve();
 
 export const addCustomFeedbacks = async ({
   appId,
@@ -210,10 +210,8 @@ export const addCustomFeedbacks = async ({
 }) => {
   if (!chatId || !dataId) return;
 
-  const queueKey = `${chatId}_${dataId}`;
-  const previousTask = customFeedbackQueues.get(queueKey) || Promise.resolve();
-
-  const task = previousTask
+  // Queue all feedback operations sequentially
+  customFeedbackQueue = customFeedbackQueue
     .then(() =>
       mongoSessionRun(async (session) => {
         await MongoChatItem.updateOne(
@@ -228,15 +226,9 @@ export const addCustomFeedbacks = async ({
     .catch((error) => {
       addLog.error('addCustomFeedbacks error', error);
       throw error;
-    })
-    .finally(() => {
-      if (customFeedbackQueues.get(queueKey) === task) {
-        customFeedbackQueues.delete(queueKey);
-      }
     });
 
-  customFeedbackQueues.set(queueKey, task);
-  await task;
+  await customFeedbackQueue;
 };
 
 /**
diff --git a/packages/service/core/workflow/dispatch/index.ts b/packages/service/core/workflow/dispatch/index.ts
index a2a35d2bd85c..ce2e13599c29 100644
--- a/packages/service/core/workflow/dispatch/index.ts
+++ b/packages/service/core/workflow/dispatch/index.ts
@@ -24,7 +24,7 @@ import type {
 } from '@fastgpt/global/core/workflow/runtime/type';
 import type { RuntimeNodeItemType } from '@fastgpt/global/core/workflow/runtime/type.d';
 import { getErrText, UserError } from '@fastgpt/global/common/error/utils';
-import { ChatItemValueTypeEnum } from '@fastgpt/global/core/chat/constants';
+import { ChatItemValueTypeEnum, ChatRoleEnum } from '@fastgpt/global/core/chat/constants';
 import { filterPublicNodeResponseData } from '@fastgpt/global/core/chat/utils';
 import {
   checkNodeRunStatus,
@@ -57,13 +57,12 @@ import { addPreviewUrlToChatItems, presignVariablesFileUrls } from '../../chat/u
 import type { MCPClient } from '../../app/mcp';
 import { TeamErrEnum } from '@fastgpt/global/common/error/code/team';
 import { i18nT } from '../../../../web/i18n/utils';
-import { clone } from 'lodash';
 import { validateFileUrlDomain } from '../../../common/security/fileUrlValidator';
 import { delAgentRuntimeStopSign, shouldWorkflowStop } from './workflowStatus';
 
 type Props = Omit<
   ChatDispatchProps,
-  'checkIsStopping' | 'workflowDispatchDeep' | 'timezone' | 'externalProvider' | 'cloneVariables'
+  'checkIsStopping' | 'workflowDispatchDeep' | 'timezone' | 'externalProvider'
 > & {
   runtimeNodes: RuntimeNodeItemType[];
   runtimeEdges: RuntimeEdgeItemType[];
@@ -100,6 +99,16 @@ export async function dispatchWorkFlow({
     apiVersion
   } = data;
 
+  const responseChatItemId = (() => {
+    if (!!lastInteractive) {
+      const lastAiChat = histories.findLast((item) => item.obj === ChatRoleEnum.AI);
+      if (lastAiChat?.dataId) {
+        return lastAiChat.dataId;
+      }
+    }
+    return data.responseChatItemId;
+  })();
+
   // Check url valid
   const invalidInput = query.some((item) => {
     if (item.type === ChatItemValueTypeEnum.file && item.file?.url) {
@@ -182,14 +191,14 @@ export async function dispatchWorkFlow({
   }
 
   // Get default variables
-  const cloneVariables = clone(data.variables);
   const defaultVariables = {
     ...externalProvider.externalWorkflowVariables,
     ...(await getSystemVariables({
       ...data,
       query,
       histories,
-      timezone
+      timezone,
+      responseChatItemId
     }))
   };
   // MCP
@@ -219,6 +228,7 @@ export async function dispatchWorkFlow({
   // Init some props
   return runWorkflow({
     ...data,
+    responseChatItemId,
     checkIsStopping,
     query,
     histories,
@@ -228,8 +238,7 @@ export async function dispatchWorkFlow({
     workflowDispatchDeep: 0,
     usageId: newUsageId,
     concatUsage,
-    mcpClientMemory,
-    cloneVariables
+    mcpClientMemory
   }).finally(async () => {
     if (streamCheckTimer) {
       clearInterval(streamCheckTimer);
@@ -273,8 +282,7 @@ export const runWorkflow = async (data: RunWorkflowProps): Promise<DispatchFlowR
     usageId,
     concatUsage,
     runningUserInfo: { teamId },
-    mcpClientMemory,
-    cloneVariables
+    mcpClientMemory
   } = data;
 
   // Over max depth
@@ -296,7 +304,6 @@ export const runWorkflow = async (data: RunWorkflowProps): Promise<DispatchFlowR
       [DispatchNodeResponseKeyEnum.toolResponses]: null,
       [DispatchNodeResponseKeyEnum.newVariables]: runtimeSystemVar2StoreType({
         variables,
-        cloneVariables,
         removeObj: externalProvider.externalWorkflowVariables,
         userVariablesConfigs: data.chatConfig?.variables
       }),
@@ -1120,7 +1127,6 @@ export const runWorkflow = async (data: RunWorkflowProps): Promise<DispatchFlowR
     [DispatchNodeResponseKeyEnum.toolResponses]: workflowQueue.toolRunResponse,
     [DispatchNodeResponseKeyEnum.newVariables]: runtimeSystemVar2StoreType({
       variables,
-      cloneVariables,
       removeObj: externalProvider.externalWorkflowVariables,
       userVariablesConfigs: data.chatConfig?.variables
     }),
diff --git a/packages/service/core/workflow/dispatch/tools/customFeedback.ts b/packages/service/core/workflow/dispatch/tools/customFeedback.ts
index bb56352fce22..fdd83df60122 100644
--- a/packages/service/core/workflow/dispatch/tools/customFeedback.ts
+++ b/packages/service/core/workflow/dispatch/tools/customFeedback.ts
@@ -30,7 +30,7 @@ export const dispatchCustomFeedback = (props: Record<string, any>): Response =>
       dataId,
       feedbacks: [feedbackText]
     });
-  }, 60000);
+  }, 600);
 
   if (stream) {
     if (!chatId || !dataId) {
diff --git a/packages/service/core/workflow/dispatch/tools/runUpdateVar.ts b/packages/service/core/workflow/dispatch/tools/runUpdateVar.ts
index 0196c89da693..c0fc0373956a 100644
--- a/packages/service/core/workflow/dispatch/tools/runUpdateVar.ts
+++ b/packages/service/core/workflow/dispatch/tools/runUpdateVar.ts
@@ -25,7 +25,6 @@ export const dispatchUpdateVariable = async (props: Props): Promise<Response> =>
     chatConfig,
     params,
     variables,
-    cloneVariables,
     runtimeNodes,
     workflowStreamResponse,
     externalProvider,
@@ -95,7 +94,6 @@ export const dispatchUpdateVariable = async (props: Props): Promise<Response> =>
       event: SseResponseEventEnum.updateVariables,
       data: runtimeSystemVar2StoreType({
         variables,
-        cloneVariables,
         removeObj: externalProvider.externalWorkflowVariables,
         userVariablesConfigs: chatConfig?.variables
       })
diff --git a/packages/service/core/workflow/dispatch/utils.ts b/packages/service/core/workflow/dispatch/utils.ts
index ec66dd67722e..4b1fc6249b41 100644
--- a/packages/service/core/workflow/dispatch/utils.ts
+++ b/packages/service/core/workflow/dispatch/utils.ts
@@ -1,9 +1,10 @@
 import { getErrText } from '@fastgpt/global/common/error/utils';
-import { ChatRoleEnum } from '@fastgpt/global/core/chat/constants';
+import { ChatRoleEnum, ChatFileTypeEnum } from '@fastgpt/global/core/chat/constants';
 import type { ChatItemType, UserChatItemFileItemType } from '@fastgpt/global/core/chat/type.d';
 import { NodeOutputKeyEnum, VariableInputEnum } from '@fastgpt/global/core/workflow/constants';
 import type { VariableItemType } from '@fastgpt/global/core/app/type';
 import { encryptSecret } from '../../../common/secret/aes256gcm';
+import { imageFileType } from '@fastgpt/global/common/file/constants';
 import {
   type RuntimeEdgeItemType,
   type RuntimeNodeItemType,
@@ -120,12 +121,10 @@ export const checkQuoteQAValue = (quoteQA?: SearchDataResponseItemType[]) => {
 /* remove system variable */
 export const runtimeSystemVar2StoreType = ({
   variables,
-  cloneVariables,
   removeObj = {},
   userVariablesConfigs = []
 }: {
   variables: Record<string, any>;
-  cloneVariables: Record<string, any>;
   removeObj?: Record<string, string>;
   userVariablesConfigs?: VariableItemType[];
 }) => {
@@ -155,9 +154,33 @@ export const runtimeSystemVar2StoreType = ({
         };
       }
     }
-    // Remove URL from file variables
+    // Handle file variables
     else if (item.type === VariableInputEnum.file) {
-      copyVariables[item.key] = cloneVariables[item.key];
+      const currentValue = copyVariables[item.key];
+
+      copyVariables[item.key] = currentValue
+        .map((url: string) => {
+          try {
+            const urlObj = new URL(url);
+            // Extract key: remove bucket prefix (e.g., "/fastgpt-private/")
+            const key = decodeURIComponent(urlObj.pathname.replace(/^\/[^/]+\//, ''));
+            const filename = key.split('/').pop() || 'file';
+            const extension = filename.split('.').pop()?.toLowerCase() || '';
+
+            // Check if it's an image type
+            const isImage = extension && imageFileType.includes(`.${extension}`);
+
+            return {
+              id: filename.replace(/\.[^.]+$/, ''), // Use filename without extension as id
+              key,
+              name: filename,
+              type: isImage ? ChatFileTypeEnum.image : ChatFileTypeEnum.file
+            };
+          } catch {
+            return null;
+          }
+        })
+        .filter((file: any) => file !== null);
     }
   });
 
diff --git a/projects/app/src/components/core/chat/components/AIResponseBox.tsx b/projects/app/src/components/core/chat/components/AIResponseBox.tsx
index 2438267629ef..6c7fc314aef3 100644
--- a/projects/app/src/components/core/chat/components/AIResponseBox.tsx
+++ b/projects/app/src/components/core/chat/components/AIResponseBox.tsx
@@ -217,20 +217,12 @@ const RenderUserSelectInteractive = React.memo(function RenderInteractive({
   );
 });
 const RenderUserFormInteractive = React.memo(function RenderFormInput({
-  interactive,
-  chatItemDataId
+  interactive
 }: {
   interactive: InteractiveBasicType & UserInputInteractive;
-  chatItemDataId: string;
 }) {
   const { t } = useTranslation();
 
-  // 使用 entryNodeIds 生成唯一的 storage key，避免不同表单节点共用同一个缓存
-  const uniqueStorageKey = useMemo(() => {
-    const nodeIds = interactive.entryNodeIds?.join('-') || 'unknown';
-    return `${chatItemDataId}_${nodeIds}`;
-  }, [chatItemDataId, interactive.entryNodeIds]);
-
   const defaultValues = useMemo(() => {
     if (interactive.type === 'userInput') {
       return interactive.params.inputForm?.reduce((acc: Record<string, any>, item) => {
@@ -251,36 +243,12 @@ const RenderUserFormInteractive = React.memo(function RenderFormInput({
         }
       });
 
-      if (typeof window !== 'undefined') {
-        const dataToSave = { ...data };
-        interactive.params.inputForm?.forEach((item) => {
-          if (
-            item.type === 'fileSelect' &&
-            Array.isArray(dataToSave[item.key]) &&
-            dataToSave[item.key].length > 0
-          ) {
-            const files = dataToSave[item.key];
-            if (files[0]?.url !== undefined) {
-              dataToSave[item.key] = files
-                .map((file: any) => ({
-                  url: file.url,
-                  key: file.key,
-                  name: file.name,
-                  type: file.type
-                }))
-                .filter((file: any) => file.url);
-            }
-          }
-        });
-        sessionStorage.setItem(`interactiveForm_${uniqueStorageKey}`, JSON.stringify(dataToSave));
-      }
-
       onSendPrompt({
         text: JSON.stringify(finalData),
         isInteractivePrompt: true
       });
     },
-    [interactive.params.inputForm, uniqueStorageKey]
+    [interactive.params.inputForm]
   );
 
   return (
@@ -288,7 +256,6 @@ const RenderUserFormInteractive = React.memo(function RenderFormInput({
       <FormInputComponent
         interactiveParams={interactive.params}
         defaultValues={defaultValues}
-        chatItemDataId={uniqueStorageKey}
         SubmitButton={({ onSubmit, isFileUploading }) => (
           <Button
             onClick={() => onSubmit(handleFormSubmit)()}
@@ -372,9 +339,7 @@ const AIResponseBox = ({
       return <RenderUserSelectInteractive interactive={finalInteractive} />;
     }
     if (finalInteractive.type === 'userInput') {
-      return (
-        <RenderUserFormInteractive interactive={finalInteractive} chatItemDataId={chatItemDataId} />
-      );
+      return <RenderUserFormInteractive interactive={finalInteractive} />;
     }
     if (finalInteractive.type === 'paymentPause') {
       return <RenderPaymentPauseInteractive interactive={finalInteractive} />;
diff --git a/projects/app/src/components/core/chat/components/Interactive/InteractiveComponents.tsx b/projects/app/src/components/core/chat/components/Interactive/InteractiveComponents.tsx
index 6e9a950c877b..9040931e7fef 100644
--- a/projects/app/src/components/core/chat/components/Interactive/InteractiveComponents.tsx
+++ b/projects/app/src/components/core/chat/components/Interactive/InteractiveComponents.tsx
@@ -69,59 +69,24 @@ export const SelectOptionsComponent = React.memo(function SelectOptionsComponent
 export const FormInputComponent = React.memo(function FormInputComponent({
   interactiveParams: { description, inputForm, submitted },
   defaultValues = {},
-  chatItemDataId,
   SubmitButton
 }: {
   interactiveParams: UserInputInteractive['params'];
   defaultValues?: Record<string, any>;
-  chatItemDataId?: string;
   SubmitButton: (e: {
     onSubmit: UseFormHandleSubmit<Record<string, any>>;
     isFileUploading: boolean;
   }) => React.JSX.Element;
 }) {
   const { t } = useTranslation();
-  const savedFormData = React.useMemo(() => {
-    const saved = sessionStorage.getItem(`interactiveForm_${chatItemDataId}`);
-    if (saved) {
-      try {
-        const parsedData = JSON.parse(saved);
-        inputForm?.forEach((item) => {
-          if (
-            item.type === 'fileSelect' &&
-            Array.isArray(parsedData[item.key]) &&
-            parsedData[item.key].length > 0
-          ) {
-            const files = parsedData[item.key];
-            if (files[0]?.url && !files[0]?.id) {
-              parsedData[item.key] = files.map((file: any) => ({
-                id: file.key || `${Date.now()}-${Math.random()}`,
-                type: file.type || 'file',
-                name: file.name || 'file',
-                url: file.url,
-                key: file.key,
-                icon: file.type === 'image' ? file.url : 'common/file',
-                status: 1
-              }));
-            }
-          }
-        });
-        return parsedData;
-      } catch (e) {}
-    }
-    return defaultValues;
-  }, [chatItemDataId, defaultValues, inputForm]);
 
-  const { handleSubmit, control, watch, reset, setValue } = useForm({
-    defaultValues: savedFormData
+  const { handleSubmit, control, watch, setValue } = useForm({
+    defaultValues
   });
 
   const appId = useContextSelector(WorkflowRuntimeContext, (v) => v.appId);
   const outLinkAuthData = useContextSelector(WorkflowRuntimeContext, (v) => v.outLinkAuthData);
-
-  React.useEffect(() => {
-    reset(savedFormData);
-  }, [savedFormData, reset]);
+  const formValues = watch();
 
   // 刷新文件 URL（处理 TTL 过期）
   useEffect(() => {
@@ -129,8 +94,8 @@ export const FormInputComponent = React.memo(function FormInputComponent({
 
     const refreshFileUrls = async () => {
       for (const item of inputForm) {
-        if (item.type === 'fileSelect' && savedFormData[item.key]) {
-          const files = savedFormData[item.key];
+        if (item.type === 'fileSelect' && defaultValues[item.key]) {
+          const files = defaultValues[item.key];
           if (Array.isArray(files) && files.length > 0 && files[0]?.key) {
             try {
               const refreshedFiles = await Promise.all(
@@ -160,14 +125,7 @@ export const FormInputComponent = React.memo(function FormInputComponent({
     };
 
     refreshFileUrls();
-  }, [submitted, inputForm, savedFormData, appId, outLinkAuthData, setValue]);
-
-  const formValues = watch();
-  useEffect(() => {
-    if (typeof window !== 'undefined' && chatItemDataId && !submitted) {
-      sessionStorage.setItem(`interactiveForm_${chatItemDataId}`, JSON.stringify(formValues));
-    }
-  }, [formValues, chatItemDataId, submitted]);
+  }, [submitted, inputForm, defaultValues, appId, outLinkAuthData, setValue]);
 
   const isFileUploading = React.useMemo(() => {
     return inputForm.some((input) => {
diff --git a/projects/app/src/pages/api/v2/chat/completions.ts b/projects/app/src/pages/api/v2/chat/completions.ts
index 006d73deb1ea..29e53f47b0ba 100644
--- a/projects/app/src/pages/api/v2/chat/completions.ts
+++ b/projects/app/src/pages/api/v2/chat/completions.ts
@@ -119,7 +119,7 @@ async function handler(req: NextApiRequest, res: NextApiResponse) {
     retainDatasetCite = false,
     messages = [],
     variables = {},
-    responseChatItemId: userProvidedChatItemId,
+    responseChatItemId,
     metadata
   } = req.body as Props;
 
@@ -263,17 +263,7 @@ async function handler(req: NextApiRequest, res: NextApiResponse) {
     const interactive = getLastInteractiveValue(newHistories) || undefined;
 
     const isInteractiveRequest = !!getLastInteractiveValue(histories);
-    const responseChatItemId = (() => {
-      // For interactive request, use the last AI ChatItem dataId
-      if (isInteractiveRequest) {
-        const lastAiChat = histories.findLast((item) => item.obj === ChatRoleEnum.AI);
-        if (lastAiChat?.dataId) {
-          return lastAiChat.dataId;
-        }
-      }
 
-      return userProvidedChatItemId || getNanoid();
-    })();
     // Get runtimeNodes
     let runtimeNodes = storeNodes2RuntimeNodes(nodes, getWorkflowEntryNodeIds(nodes, interactive));
     if (isPlugin) {

From 593d68ee871f63e521c4ade9c4e1fafc9bc052b3 Mon Sep 17 00:00:00 2001
From: heheer <zhiyu44@qq.com>
Date: Thu, 8 Jan 2026 15:27:28 +0800
Subject: [PATCH 4/9] fix

---
 packages/service/core/workflow/dispatch/tools/customFeedback.ts | 2 +-
 projects/app/src/pages/api/v2/chat/completions.ts               | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/packages/service/core/workflow/dispatch/tools/customFeedback.ts b/packages/service/core/workflow/dispatch/tools/customFeedback.ts
index fdd83df60122..bb56352fce22 100644
--- a/packages/service/core/workflow/dispatch/tools/customFeedback.ts
+++ b/packages/service/core/workflow/dispatch/tools/customFeedback.ts
@@ -30,7 +30,7 @@ export const dispatchCustomFeedback = (props: Record<string, any>): Response =>
       dataId,
       feedbacks: [feedbackText]
     });
-  }, 600);
+  }, 60000);
 
   if (stream) {
     if (!chatId || !dataId) {
diff --git a/projects/app/src/pages/api/v2/chat/completions.ts b/projects/app/src/pages/api/v2/chat/completions.ts
index 29e53f47b0ba..29cf1fe6d291 100644
--- a/projects/app/src/pages/api/v2/chat/completions.ts
+++ b/projects/app/src/pages/api/v2/chat/completions.ts
@@ -119,7 +119,7 @@ async function handler(req: NextApiRequest, res: NextApiResponse) {
     retainDatasetCite = false,
     messages = [],
     variables = {},
-    responseChatItemId,
+    responseChatItemId = getNanoid(),
     metadata
   } = req.body as Props;
 

From 670545588fa1210306552b2ef9b0808481ee4702 Mon Sep 17 00:00:00 2001
From: heheer <zhiyu44@qq.com>
Date: Thu, 8 Jan 2026 17:11:55 +0800
Subject: [PATCH 5/9] custom feedback

---
 .../global/core/workflow/runtime/constants.ts |  3 +-
 .../global/core/workflow/runtime/type.d.ts    |  1 +
 packages/service/core/chat/controller.ts      | 42 ++++++------
 .../core/workflow/dispatch/child/runApp.ts    |  6 +-
 .../service/core/workflow/dispatch/index.ts   | 31 ++++++++-
 .../core/workflow/dispatch/loop/runLoop.ts    | 10 ++-
 .../core/workflow/dispatch/plugin/run.ts      | 65 ++++++++++---------
 .../workflow/dispatch/tools/customFeedback.ts | 35 +---------
 .../service/core/workflow/dispatch/type.d.ts  |  1 +
 9 files changed, 105 insertions(+), 89 deletions(-)

diff --git a/packages/global/core/workflow/runtime/constants.ts b/packages/global/core/workflow/runtime/constants.ts
index 2f7740501754..ad94b9de5818 100644
--- a/packages/global/core/workflow/runtime/constants.ts
+++ b/packages/global/core/workflow/runtime/constants.ts
@@ -31,7 +31,8 @@ export enum DispatchNodeResponseKeyEnum {
   interactive = 'INTERACTIVE', // is interactive
   runTimes = 'runTimes', // run times
   newVariables = 'newVariables', // new variables
-  memories = 'system_memories' // memories
+  memories = 'system_memories', // memories
+  customFeedbacks = 'customFeedbacks' // custom feedbacks
 }
 
 export const needReplaceReferenceInputTypeList = [
diff --git a/packages/global/core/workflow/runtime/type.d.ts b/packages/global/core/workflow/runtime/type.d.ts
index 444f5f6eb21d..aa2e6096db45 100644
--- a/packages/global/core/workflow/runtime/type.d.ts
+++ b/packages/global/core/workflow/runtime/type.d.ts
@@ -273,6 +273,7 @@ export type DispatchNodeResultType<T = {}, ERR = { [NodeOutputKeyEnum.errorText]
   [DispatchNodeResponseKeyEnum.newVariables]?: Record<string, any>;
   [DispatchNodeResponseKeyEnum.memories]?: Record<string, any>;
   [DispatchNodeResponseKeyEnum.interactive]?: InteractiveNodeResponseType;
+  [DispatchNodeResponseKeyEnum.customFeedbacks]?: string[];
 
   data?: T;
   error?: ERR;
diff --git a/packages/service/core/chat/controller.ts b/packages/service/core/chat/controller.ts
index ad88beb21306..c4550e9c93f6 100644
--- a/packages/service/core/chat/controller.ts
+++ b/packages/service/core/chat/controller.ts
@@ -194,9 +194,6 @@ export async function getChatItems({
   return { histories, total, hasMorePrev, hasMoreNext };
 }
 
-// Maintain a global write queue to avoid concurrent write conflicts
-let customFeedbackQueue = Promise.resolve();
-
 export const addCustomFeedbacks = async ({
   appId,
   chatId,
@@ -208,27 +205,26 @@ export const addCustomFeedbacks = async ({
   dataId?: string;
   feedbacks: string[];
 }) => {
-  if (!chatId || !dataId) return;
-
-  // Queue all feedback operations sequentially
-  customFeedbackQueue = customFeedbackQueue
-    .then(() =>
-      mongoSessionRun(async (session) => {
-        await MongoChatItem.updateOne(
-          { appId, chatId, dataId },
-          { $push: { customFeedbacks: { $each: feedbacks } } },
-          { session }
-        );
-
-        await updateChatFeedbackCount({ appId, chatId, session });
-      })
-    )
-    .catch((error) => {
-      addLog.error('addCustomFeedbacks error', error);
-      throw error;
-    });
+  if (!chatId || !dataId || !feedbacks || feedbacks.length === 0) return;
+
+  try {
+    await mongoSessionRun(async (session) => {
+      await MongoChatItem.updateOne(
+        {
+          appId: new Types.ObjectId(appId),
+          chatId,
+          dataId
+        },
+        { $push: { customFeedbacks: { $each: feedbacks } } },
+        { session }
+      );
 
-  await customFeedbackQueue;
+      await updateChatFeedbackCount({ appId, chatId, session });
+    });
+  } catch (error) {
+    addLog.error('addCustomFeedbacks error', error);
+    throw error;
+  }
 };
 
 /**
diff --git a/packages/service/core/workflow/dispatch/child/runApp.ts b/packages/service/core/workflow/dispatch/child/runApp.ts
index 4c2d4773d3a9..5a0282b45002 100644
--- a/packages/service/core/workflow/dispatch/child/runApp.ts
+++ b/packages/service/core/workflow/dispatch/child/runApp.ts
@@ -131,7 +131,8 @@ export const dispatchRunAppNode = async (props: Props): Promise<Response> => {
       assistantResponses,
       runTimes,
       workflowInteractiveResponse,
-      system_memories
+      system_memories,
+      [DispatchNodeResponseKeyEnum.customFeedbacks]: customFeedbacks
     } = await runWorkflow({
       ...props,
       usageId: undefined,
@@ -205,7 +206,8 @@ export const dispatchRunAppNode = async (props: Props): Promise<Response> => {
           totalPoints: usagePoints
         }
       ],
-      [DispatchNodeResponseKeyEnum.toolResponses]: text
+      [DispatchNodeResponseKeyEnum.toolResponses]: text,
+      [DispatchNodeResponseKeyEnum.customFeedbacks]: customFeedbacks
     };
   } catch (error) {
     return getNodeErrResponse({ error });
diff --git a/packages/service/core/workflow/dispatch/index.ts b/packages/service/core/workflow/dispatch/index.ts
index ce2e13599c29..866e5653481b 100644
--- a/packages/service/core/workflow/dispatch/index.ts
+++ b/packages/service/core/workflow/dispatch/index.ts
@@ -42,6 +42,7 @@ import type { RuntimeEdgeItemType } from '@fastgpt/global/core/workflow/type/edg
 import type { ChatNodeUsageType } from '@fastgpt/global/support/wallet/bill/type';
 import { addLog } from '../../../common/system/log';
 import { surrenderProcess } from '../../../common/system/tools';
+import { addCustomFeedbacks } from '../../chat/controller';
 import type { DispatchFlowResponse, WorkflowDebugResponse } from './type';
 import { rewriteRuntimeWorkFlow, runtimeSystemVar2StoreType } from './utils';
 import { getHandleId } from '@fastgpt/global/core/workflow/utils';
@@ -350,6 +351,7 @@ export const runWorkflow = async (data: RunWorkflowProps): Promise<DispatchFlowR
         }
       | undefined;
     system_memories: Record<string, any> = {}; // Workflow node memories
+    customFeedbackList: string[] = []; // Custom feedbacks collected from nodes
 
     // Debug
     debugNextStepRunNodes: RuntimeNodeItemType[] = []; // 记录 Debug 模式下，下一个阶段需要执行的节点。
@@ -727,7 +729,8 @@ export const runWorkflow = async (data: RunWorkflowProps): Promise<DispatchFlowR
         assistantResponses,
         rewriteHistories,
         runTimes = 1,
-        system_memories: newMemories
+        system_memories: newMemories,
+        customFeedbacks
       }: NodeResponseCompleteType) => {
         // Add run times
         this.workflowRunTimes += runTimes;
@@ -744,6 +747,11 @@ export const runWorkflow = async (data: RunWorkflowProps): Promise<DispatchFlowR
           this.chatResponses.push(responseData);
         }
 
+        // Collect custom feedbacks
+        if (customFeedbacks && Array.isArray(customFeedbacks)) {
+          this.customFeedbackList = this.customFeedbackList.concat(customFeedbacks);
+        }
+
         // Push usage in real time. Avoid a workflow usage a large number of points
         if (nodeDispatchUsages) {
           if (usageId) {
@@ -1115,6 +1123,25 @@ export const runWorkflow = async (data: RunWorkflowProps): Promise<DispatchFlowR
     });
   }
 
+  if (
+    isRootRuntime &&
+    !isDebugMode &&
+    workflowQueue.customFeedbackList.length > 0 &&
+    data.chatId &&
+    data.responseChatItemId
+  ) {
+    setTimeout(() => {
+      addCustomFeedbacks({
+        appId: data.runningAppInfo.id,
+        chatId: data.chatId,
+        dataId: data.responseChatItemId,
+        feedbacks: workflowQueue.customFeedbackList
+      }).catch((error) => {
+        addLog.error('Add custom feedbacks error', error);
+      });
+    }, 500);
+  }
+
   return {
     flowResponses: workflowQueue.chatResponses,
     flowUsages: workflowQueue.chatNodeUsages,
@@ -1134,6 +1161,8 @@ export const runWorkflow = async (data: RunWorkflowProps): Promise<DispatchFlowR
       Object.keys(workflowQueue.system_memories).length > 0
         ? workflowQueue.system_memories
         : undefined,
+    [DispatchNodeResponseKeyEnum.customFeedbacks]:
+      workflowQueue.customFeedbackList.length > 0 ? workflowQueue.customFeedbackList : undefined,
     durationSeconds
   };
 };
diff --git a/packages/service/core/workflow/dispatch/loop/runLoop.ts b/packages/service/core/workflow/dispatch/loop/runLoop.ts
index 0b019e5caae2..164dec897d30 100644
--- a/packages/service/core/workflow/dispatch/loop/runLoop.ts
+++ b/packages/service/core/workflow/dispatch/loop/runLoop.ts
@@ -51,6 +51,7 @@ export const dispatchLoop = async (props: Props): Promise<Response> => {
   const outputValueArr = interactiveData ? interactiveData.loopResult : [];
   const loopResponseDetail: ChatHistoryItemResType[] = [];
   let assistantResponses: AIChatItemValueItemType[] = [];
+  const customFeedbacks: string[] = [];
   let totalPoints = 0;
   let newVariables: Record<string, any> = props.variables;
   let interactiveResponse: WorkflowInteractiveResponseType | undefined = undefined;
@@ -116,6 +117,11 @@ export const dispatchLoop = async (props: Props): Promise<Response> => {
     assistantResponses.push(...response.assistantResponses);
     totalPoints += response.flowUsages.reduce((acc, usage) => acc + usage.totalPoints, 0);
 
+    // Collect custom feedbacks
+    if (response[DispatchNodeResponseKeyEnum.customFeedbacks]) {
+      customFeedbacks.push(...response[DispatchNodeResponseKeyEnum.customFeedbacks]);
+    }
+
     // Concat new variables
     newVariables = {
       ...newVariables,
@@ -163,6 +169,8 @@ export const dispatchLoop = async (props: Props): Promise<Response> => {
           }
         ]
       : [],
-    [DispatchNodeResponseKeyEnum.newVariables]: newVariables
+    [DispatchNodeResponseKeyEnum.newVariables]: newVariables,
+    [DispatchNodeResponseKeyEnum.customFeedbacks]:
+      customFeedbacks.length > 0 ? customFeedbacks : undefined
   };
 };
diff --git a/packages/service/core/workflow/dispatch/plugin/run.ts b/packages/service/core/workflow/dispatch/plugin/run.ts
index defaf4dbea94..0c776b0ad3a2 100644
--- a/packages/service/core/workflow/dispatch/plugin/run.ts
+++ b/packages/service/core/workflow/dispatch/plugin/run.ts
@@ -132,35 +132,41 @@ export const dispatchRunPlugin = async (props: RunPluginProps): Promise<RunPlugi
       appId: String(plugin.id),
       ...(externalProvider ? externalProvider.externalWorkflowVariables : {})
     };
-    const { flowResponses, flowUsages, assistantResponses, runTimes, system_memories } =
-      await runWorkflow({
-        ...props,
-        usageId: undefined,
-        // Rewrite stream mode
-        ...(system_forbid_stream
-          ? {
-              stream: false,
-              workflowStreamResponse: undefined
-            }
-          : {}),
-        runningAppInfo: {
-          id: String(plugin.id),
-          name: plugin.name,
-          // 如果系统插件有 teamId 和 tmbId，则使用系统插件的 teamId 和 tmbId（管理员指定了插件作为系统插件）
-          teamId: plugin.teamId || runningAppInfo.teamId,
-          tmbId: plugin.tmbId || runningAppInfo.tmbId,
-          isChildApp: true
-        },
+    const {
+      flowResponses,
+      flowUsages,
+      assistantResponses,
+      runTimes,
+      system_memories,
+      [DispatchNodeResponseKeyEnum.customFeedbacks]: customFeedbacks
+    } = await runWorkflow({
+      ...props,
+      usageId: undefined,
+      // Rewrite stream mode
+      ...(system_forbid_stream
+        ? {
+            stream: false,
+            workflowStreamResponse: undefined
+          }
+        : {}),
+      runningAppInfo: {
+        id: String(plugin.id),
+        name: plugin.name,
+        // 如果系统插件有 teamId 和 tmbId，则使用系统插件的 teamId 和 tmbId（管理员指定了插件作为系统插件）
+        teamId: plugin.teamId || runningAppInfo.teamId,
+        tmbId: plugin.tmbId || runningAppInfo.tmbId,
+        isChildApp: true
+      },
+      variables: runtimeVariables,
+      query: serverGetWorkflowToolRunUserQuery({
+        pluginInputs: getWorkflowToolInputsFromStoreNodes(plugin.nodes),
         variables: runtimeVariables,
-        query: serverGetWorkflowToolRunUserQuery({
-          pluginInputs: getWorkflowToolInputsFromStoreNodes(plugin.nodes),
-          variables: runtimeVariables,
-          files
-        }).value,
-        chatConfig: {},
-        runtimeNodes,
-        runtimeEdges: storeEdges2RuntimeEdges(plugin.edges)
-      });
+        files
+      }).value,
+      chatConfig: {},
+      runtimeNodes,
+      runtimeEdges: storeEdges2RuntimeEdges(plugin.edges)
+    });
     const output = flowResponses.find((item) => item.moduleType === FlowNodeTypeEnum.pluginOutput);
 
     const usagePoints = await computedAppToolUsage({
@@ -200,7 +206,8 @@ export const dispatchRunPlugin = async (props: RunPluginProps): Promise<RunPlugi
               acc[key] = output.pluginOutput![key];
               return acc;
             }, {})
-        : null
+        : null,
+      [DispatchNodeResponseKeyEnum.customFeedbacks]: customFeedbacks
     };
   } catch (error) {
     return getNodeErrResponse({
diff --git a/packages/service/core/workflow/dispatch/tools/customFeedback.ts b/packages/service/core/workflow/dispatch/tools/customFeedback.ts
index bb56352fce22..938904a7ce10 100644
--- a/packages/service/core/workflow/dispatch/tools/customFeedback.ts
+++ b/packages/service/core/workflow/dispatch/tools/customFeedback.ts
@@ -1,12 +1,7 @@
-import {
-  DispatchNodeResponseKeyEnum,
-  SseResponseEventEnum
-} from '@fastgpt/global/core/workflow/runtime/constants';
+import { DispatchNodeResponseKeyEnum } from '@fastgpt/global/core/workflow/runtime/constants';
 import type { ModuleDispatchProps } from '@fastgpt/global/core/workflow/runtime/type';
 import type { NodeInputKeyEnum } from '@fastgpt/global/core/workflow/constants';
 import { type DispatchNodeResultType } from '@fastgpt/global/core/workflow/runtime/type';
-import { addCustomFeedbacks } from '../../../chat/controller';
-import { textAdaptGptResponse } from '@fastgpt/global/core/workflow/runtime/utils';
 
 type Props = ModuleDispatchProps<{
   [NodeInputKeyEnum.textareaInput]: string;
@@ -15,37 +10,13 @@ type Response = DispatchNodeResultType<{}>;
 
 export const dispatchCustomFeedback = (props: Record<string, any>): Response => {
   const {
-    runningAppInfo: { id: appId },
-    chatId,
-    responseChatItemId: dataId,
-    stream,
-    workflowStreamResponse,
     params: { system_textareaInput: feedbackText = '' }
   } = props as Props;
 
-  setTimeout(() => {
-    addCustomFeedbacks({
-      appId,
-      chatId,
-      dataId,
-      feedbacks: [feedbackText]
-    });
-  }, 60000);
-
-  if (stream) {
-    if (!chatId || !dataId) {
-      workflowStreamResponse?.({
-        event: SseResponseEventEnum.fastAnswer,
-        data: textAdaptGptResponse({
-          text: `\n\n**自定义反馈成功: (仅调试模式下展示该内容)**: "${feedbackText}"\n\n`
-        })
-      });
-    }
-  }
-
   return {
     [DispatchNodeResponseKeyEnum.nodeResponse]: {
       textOutput: feedbackText
-    }
+    },
+    [DispatchNodeResponseKeyEnum.customFeedbacks]: [feedbackText]
   };
 };
diff --git a/packages/service/core/workflow/dispatch/type.d.ts b/packages/service/core/workflow/dispatch/type.d.ts
index 2bf3280e856b..aafc0d78eeef 100644
--- a/packages/service/core/workflow/dispatch/type.d.ts
+++ b/packages/service/core/workflow/dispatch/type.d.ts
@@ -37,6 +37,7 @@ export type DispatchFlowResponse = {
   [DispatchNodeResponseKeyEnum.assistantResponses]: AIChatItemValueItemType[];
   [DispatchNodeResponseKeyEnum.runTimes]: number;
   [DispatchNodeResponseKeyEnum.memories]?: Record<string, any>;
+  [DispatchNodeResponseKeyEnum.customFeedbacks]?: string[];
   [DispatchNodeResponseKeyEnum.newVariables]: Record<string, string>;
   durationSeconds: number;
 };

From 8ad137e443556abac55d6cda479aff9dddb3112c Mon Sep 17 00:00:00 2001
From: heheer <zhiyu44@qq.com>
Date: Fri, 9 Jan 2026 14:15:27 +0800
Subject: [PATCH 6/9] fix

---
 .../service/core/workflow/dispatch/index.ts   | 20 ------
 .../service/core/workflow/dispatch/utils.ts   |  9 +--
 .../app/src/pages/api/core/chat/chatTest.ts   | 69 ++++++++++---------
 .../app/src/pages/api/v1/chat/completions.ts  |  6 +-
 .../app/src/pages/api/v2/chat/completions.ts  |  6 +-
 projects/app/src/service/core/app/utils.ts    | 61 +++++++++-------
 6 files changed, 86 insertions(+), 85 deletions(-)

diff --git a/packages/service/core/workflow/dispatch/index.ts b/packages/service/core/workflow/dispatch/index.ts
index 866e5653481b..b7d13e8c16fa 100644
--- a/packages/service/core/workflow/dispatch/index.ts
+++ b/packages/service/core/workflow/dispatch/index.ts
@@ -42,7 +42,6 @@ import type { RuntimeEdgeItemType } from '@fastgpt/global/core/workflow/type/edg
 import type { ChatNodeUsageType } from '@fastgpt/global/support/wallet/bill/type';
 import { addLog } from '../../../common/system/log';
 import { surrenderProcess } from '../../../common/system/tools';
-import { addCustomFeedbacks } from '../../chat/controller';
 import type { DispatchFlowResponse, WorkflowDebugResponse } from './type';
 import { rewriteRuntimeWorkFlow, runtimeSystemVar2StoreType } from './utils';
 import { getHandleId } from '@fastgpt/global/core/workflow/utils';
@@ -1123,25 +1122,6 @@ export const runWorkflow = async (data: RunWorkflowProps): Promise<DispatchFlowR
     });
   }
 
-  if (
-    isRootRuntime &&
-    !isDebugMode &&
-    workflowQueue.customFeedbackList.length > 0 &&
-    data.chatId &&
-    data.responseChatItemId
-  ) {
-    setTimeout(() => {
-      addCustomFeedbacks({
-        appId: data.runningAppInfo.id,
-        chatId: data.chatId,
-        dataId: data.responseChatItemId,
-        feedbacks: workflowQueue.customFeedbackList
-      }).catch((error) => {
-        addLog.error('Add custom feedbacks error', error);
-      });
-    }, 500);
-  }
-
   return {
     flowResponses: workflowQueue.chatResponses,
     flowUsages: workflowQueue.chatNodeUsages,
diff --git a/packages/service/core/workflow/dispatch/utils.ts b/packages/service/core/workflow/dispatch/utils.ts
index 4b1fc6249b41..03a432ecdfe0 100644
--- a/packages/service/core/workflow/dispatch/utils.ts
+++ b/packages/service/core/workflow/dispatch/utils.ts
@@ -1,3 +1,4 @@
+import path from 'path';
 import { getErrText } from '@fastgpt/global/common/error/utils';
 import { ChatRoleEnum, ChatFileTypeEnum } from '@fastgpt/global/core/chat/constants';
 import type { ChatItemType, UserChatItemFileItemType } from '@fastgpt/global/core/chat/type.d';
@@ -164,14 +165,14 @@ export const runtimeSystemVar2StoreType = ({
             const urlObj = new URL(url);
             // Extract key: remove bucket prefix (e.g., "/fastgpt-private/")
             const key = decodeURIComponent(urlObj.pathname.replace(/^\/[^/]+\//, ''));
-            const filename = key.split('/').pop() || 'file';
-            const extension = filename.split('.').pop()?.toLowerCase() || '';
+            const filename = path.basename(key) || 'file';
+            const extname = path.extname(key).toLowerCase(); // includes the dot, e.g., ".jpg"
 
             // Check if it's an image type
-            const isImage = extension && imageFileType.includes(`.${extension}`);
+            const isImage = extname && imageFileType.includes(extname);
 
             return {
-              id: filename.replace(/\.[^.]+$/, ''), // Use filename without extension as id
+              id: path.basename(key, path.extname(key)), // filename without extension
               key,
               name: filename,
               type: isImage ? ChatFileTypeEnum.image : ChatFileTypeEnum.file
diff --git a/projects/app/src/pages/api/core/chat/chatTest.ts b/projects/app/src/pages/api/core/chat/chatTest.ts
index 4c013943f7bb..461c5a604514 100644
--- a/projects/app/src/pages/api/core/chat/chatTest.ts
+++ b/projects/app/src/pages/api/core/chat/chatTest.ts
@@ -180,39 +180,45 @@ async function handler(req: NextApiRequest, res: NextApiResponse) {
     });
 
     /* start process */
-    const { flowResponses, assistantResponses, system_memories, newVariables, durationSeconds } =
-      await dispatchWorkFlow({
-        apiVersion: 'v2',
-        res,
-        lang: getLocale(req),
-        requestOrigin: req.headers.origin,
-        mode: 'test',
-        usageSource: UsageSourceEnum.fastgpt,
+    const {
+      flowResponses,
+      assistantResponses,
+      system_memories,
+      newVariables,
+      durationSeconds,
+      customFeedbacks
+    } = await dispatchWorkFlow({
+      apiVersion: 'v2',
+      res,
+      lang: getLocale(req),
+      requestOrigin: req.headers.origin,
+      mode: 'test',
+      usageSource: UsageSourceEnum.fastgpt,
 
-        uid: tmbId,
+      uid: tmbId,
 
-        runningAppInfo: {
-          id: appId,
-          name: appName,
-          teamId: app.teamId,
-          tmbId: app.tmbId
-        },
-        runningUserInfo: await getRunningUserInfoByTmbId(tmbId),
+      runningAppInfo: {
+        id: appId,
+        name: appName,
+        teamId: app.teamId,
+        tmbId: app.tmbId
+      },
+      runningUserInfo: await getRunningUserInfoByTmbId(tmbId),
 
-        chatId,
-        responseChatItemId,
-        runtimeNodes,
-        runtimeEdges: storeEdges2RuntimeEdges(edges, interactive),
-        variables,
-        query: removeEmptyUserInput(userQuestion.value),
-        lastInteractive: interactive,
-        chatConfig,
-        histories: newHistories,
-        stream: true,
-        maxRunTimes: WORKFLOW_MAX_RUN_TIMES,
-        workflowStreamResponse: workflowResponseWrite,
-        responseDetail: true
-      });
+      chatId,
+      responseChatItemId,
+      runtimeNodes,
+      runtimeEdges: storeEdges2RuntimeEdges(edges, interactive),
+      variables,
+      query: removeEmptyUserInput(userQuestion.value),
+      lastInteractive: interactive,
+      chatConfig,
+      histories: newHistories,
+      stream: true,
+      maxRunTimes: WORKFLOW_MAX_RUN_TIMES,
+      workflowStreamResponse: workflowResponseWrite,
+      responseDetail: true
+    });
 
     workflowResponseWrite({
       event: SseResponseEventEnum.answer,
@@ -239,7 +245,8 @@ async function handler(req: NextApiRequest, res: NextApiResponse) {
       obj: ChatRoleEnum.AI,
       value: assistantResponses,
       memories: system_memories,
-      [DispatchNodeResponseKeyEnum.nodeResponse]: flowResponses
+      [DispatchNodeResponseKeyEnum.nodeResponse]: flowResponses,
+      customFeedbacks
     };
     const params = {
       chatId,
diff --git a/projects/app/src/pages/api/v1/chat/completions.ts b/projects/app/src/pages/api/v1/chat/completions.ts
index c929d1025143..616a03c2f8c0 100644
--- a/projects/app/src/pages/api/v1/chat/completions.ts
+++ b/projects/app/src/pages/api/v1/chat/completions.ts
@@ -288,7 +288,8 @@ async function handler(req: NextApiRequest, res: NextApiResponse) {
       assistantResponses,
       newVariables,
       durationSeconds,
-      system_memories
+      system_memories,
+      customFeedbacks
     } = await (async () => {
       if (app.version === 'v2') {
         return dispatchWorkFlow({
@@ -351,7 +352,8 @@ async function handler(req: NextApiRequest, res: NextApiResponse) {
       obj: ChatRoleEnum.AI,
       value: assistantResponses,
       [DispatchNodeResponseKeyEnum.nodeResponse]: flowResponses,
-      memories: system_memories
+      memories: system_memories,
+      customFeedbacks
     };
 
     const params: SaveChatProps = {
diff --git a/projects/app/src/pages/api/v2/chat/completions.ts b/projects/app/src/pages/api/v2/chat/completions.ts
index 29cf1fe6d291..d22de2ea529c 100644
--- a/projects/app/src/pages/api/v2/chat/completions.ts
+++ b/projects/app/src/pages/api/v2/chat/completions.ts
@@ -291,7 +291,8 @@ async function handler(req: NextApiRequest, res: NextApiResponse) {
       assistantResponses,
       newVariables,
       durationSeconds,
-      system_memories
+      system_memories,
+      customFeedbacks
     } = await (async () => {
       if (app.version === 'v2') {
         return dispatchWorkFlow({
@@ -354,7 +355,8 @@ async function handler(req: NextApiRequest, res: NextApiResponse) {
       obj: ChatRoleEnum.AI,
       value: assistantResponses,
       [DispatchNodeResponseKeyEnum.nodeResponse]: flowResponses,
-      memories: system_memories
+      memories: system_memories,
+      customFeedbacks
     };
 
     const params: SaveChatProps = {
diff --git a/projects/app/src/service/core/app/utils.ts b/projects/app/src/service/core/app/utils.ts
index cde645cab545..76bf29381dcd 100644
--- a/projects/app/src/service/core/app/utils.ts
+++ b/projects/app/src/service/core/app/utils.ts
@@ -84,13 +84,15 @@ export const getScheduleTriggerApp = async () => {
         durationSeconds = 0,
         assistantResponses = [],
         flowResponses = [],
-        system_memories
+        system_memories,
+        customFeedbacks
       }: {
         error?: any;
         durationSeconds?: number;
         assistantResponses?: AIChatItemValueItemType[];
         flowResponses?: ChatHistoryItemResType[];
         system_memories?: Record<string, any>;
+        customFeedbacks?: string[];
       }) =>
         saveChat({
           chatId,
@@ -111,37 +113,43 @@ export const getScheduleTriggerApp = async () => {
             obj: ChatRoleEnum.AI,
             value: assistantResponses,
             [DispatchNodeResponseKeyEnum.nodeResponse]: flowResponses,
-            memories: system_memories
+            memories: system_memories,
+            customFeedbacks
           },
           durationSeconds,
           errorMsg: getErrText(error)
         });
 
       try {
-        const { assistantResponses, flowResponses, durationSeconds, system_memories } =
-          await retryFn(async () => {
-            return dispatchWorkFlow({
-              chatId,
-              mode: 'chat',
-              usageId,
-              runningAppInfo: {
-                id: String(app._id),
-                name: app.name,
-                teamId: String(app.teamId),
-                tmbId: String(app.tmbId)
-              },
-              runningUserInfo: await getRunningUserInfoByTmbId(app.tmbId),
-              uid: String(app.tmbId),
-              runtimeNodes: storeNodes2RuntimeNodes(nodes, getWorkflowEntryNodeIds(nodes)),
-              runtimeEdges: storeEdges2RuntimeEdges(edges),
-              variables: {},
-              query: userQuery,
-              chatConfig,
-              histories: [],
-              stream: false,
-              maxRunTimes: WORKFLOW_MAX_RUN_TIMES
-            });
+        const {
+          assistantResponses,
+          flowResponses,
+          durationSeconds,
+          system_memories,
+          customFeedbacks
+        } = await retryFn(async () => {
+          return dispatchWorkFlow({
+            chatId,
+            mode: 'chat',
+            usageId,
+            runningAppInfo: {
+              id: String(app._id),
+              name: app.name,
+              teamId: String(app.teamId),
+              tmbId: String(app.tmbId)
+            },
+            runningUserInfo: await getRunningUserInfoByTmbId(app.tmbId),
+            uid: String(app.tmbId),
+            runtimeNodes: storeNodes2RuntimeNodes(nodes, getWorkflowEntryNodeIds(nodes)),
+            runtimeEdges: storeEdges2RuntimeEdges(edges),
+            variables: {},
+            query: userQuery,
+            chatConfig,
+            histories: [],
+            stream: false,
+            maxRunTimes: WORKFLOW_MAX_RUN_TIMES
           });
+        });
 
         const error = flowResponses[flowResponses.length - 1]?.error;
 
@@ -151,7 +159,8 @@ export const getScheduleTriggerApp = async () => {
           durationSeconds,
           assistantResponses,
           flowResponses,
-          system_memories
+          system_memories,
+          customFeedbacks
         });
       } catch (error) {
         addLog.error('[Schedule app] run error', error);

From 0aa6d79d5952f6974c584f175b3e4e43516b3675 Mon Sep 17 00:00:00 2001
From: heheer <zhiyu44@qq.com>
Date: Fri, 9 Jan 2026 14:23:59 +0800
Subject: [PATCH 7/9] code

---
 packages/service/core/workflow/dispatch/child/runApp.ts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/packages/service/core/workflow/dispatch/child/runApp.ts b/packages/service/core/workflow/dispatch/child/runApp.ts
index 5a0282b45002..b5d90abc86ce 100644
--- a/packages/service/core/workflow/dispatch/child/runApp.ts
+++ b/packages/service/core/workflow/dispatch/child/runApp.ts
@@ -132,7 +132,7 @@ export const dispatchRunAppNode = async (props: Props): Promise<Response> => {
       runTimes,
       workflowInteractiveResponse,
       system_memories,
-      [DispatchNodeResponseKeyEnum.customFeedbacks]: customFeedbacks
+      customFeedbacks
     } = await runWorkflow({
       ...props,
       usageId: undefined,

From 28eb29b1071367e7953b3cba1f7e7f444116c5e1 Mon Sep 17 00:00:00 2001
From: heheer <zhiyu44@qq.com>
Date: Fri, 9 Jan 2026 15:33:07 +0800
Subject: [PATCH 8/9] fix

---
 packages/service/core/workflow/dispatch/index.ts | 14 +-------------
 projects/app/src/pages/api/core/app/logs/list.ts |  4 +---
 2 files changed, 2 insertions(+), 16 deletions(-)

diff --git a/packages/service/core/workflow/dispatch/index.ts b/packages/service/core/workflow/dispatch/index.ts
index b7d13e8c16fa..6be99b9f0d83 100644
--- a/packages/service/core/workflow/dispatch/index.ts
+++ b/packages/service/core/workflow/dispatch/index.ts
@@ -99,16 +99,6 @@ export async function dispatchWorkFlow({
     apiVersion
   } = data;
 
-  const responseChatItemId = (() => {
-    if (!!lastInteractive) {
-      const lastAiChat = histories.findLast((item) => item.obj === ChatRoleEnum.AI);
-      if (lastAiChat?.dataId) {
-        return lastAiChat.dataId;
-      }
-    }
-    return data.responseChatItemId;
-  })();
-
   // Check url valid
   const invalidInput = query.some((item) => {
     if (item.type === ChatItemValueTypeEnum.file && item.file?.url) {
@@ -197,8 +187,7 @@ export async function dispatchWorkFlow({
       ...data,
       query,
       histories,
-      timezone,
-      responseChatItemId
+      timezone
     }))
   };
   // MCP
@@ -228,7 +217,6 @@ export async function dispatchWorkFlow({
   // Init some props
   return runWorkflow({
     ...data,
-    responseChatItemId,
     checkIsStopping,
     query,
     histories,
diff --git a/projects/app/src/pages/api/core/app/logs/list.ts b/projects/app/src/pages/api/core/app/logs/list.ts
index c0d10a55c1d9..67ec00c49a0a 100644
--- a/projects/app/src/pages/api/core/app/logs/list.ts
+++ b/projects/app/src/pages/api/core/app/logs/list.ts
@@ -141,9 +141,7 @@ async function handler(
                     }
                   },
                   customFeedback: {
-                    $sum: {
-                      $cond: [{ $gt: [{ $size: { $ifNull: ['$customFeedbacks', []] } }, 0] }, 1, 0]
-                    }
+                    $sum: { $size: { $ifNull: ['$customFeedbacks', []] } }
                   },
                   errorCountFromChatItem: {
                     $sum: {

From a1cf82c73bfc8ee12c3c7365efcd5bdf2a5fb153 Mon Sep 17 00:00:00 2001
From: archer <545436317@qq.com>
Date: Fri, 9 Jan 2026 16:45:16 +0800
Subject: [PATCH 9/9] remove invalid function

---
 packages/service/core/chat/controller.ts      |  33 ---
 .../service/core/chat/controller.test.ts      | 267 +-----------------
 2 files changed, 1 insertion(+), 299 deletions(-)

diff --git a/packages/service/core/chat/controller.ts b/packages/service/core/chat/controller.ts
index c4550e9c93f6..3f33cc2ad175 100644
--- a/packages/service/core/chat/controller.ts
+++ b/packages/service/core/chat/controller.ts
@@ -194,39 +194,6 @@ export async function getChatItems({
   return { histories, total, hasMorePrev, hasMoreNext };
 }
 
-export const addCustomFeedbacks = async ({
-  appId,
-  chatId,
-  dataId,
-  feedbacks
-}: {
-  appId: string;
-  chatId?: string;
-  dataId?: string;
-  feedbacks: string[];
-}) => {
-  if (!chatId || !dataId || !feedbacks || feedbacks.length === 0) return;
-
-  try {
-    await mongoSessionRun(async (session) => {
-      await MongoChatItem.updateOne(
-        {
-          appId: new Types.ObjectId(appId),
-          chatId,
-          dataId
-        },
-        { $push: { customFeedbacks: { $each: feedbacks } } },
-        { session }
-      );
-
-      await updateChatFeedbackCount({ appId, chatId, session });
-    });
-  } catch (error) {
-    addLog.error('addCustomFeedbacks error', error);
-    throw error;
-  }
-};
-
 /**
  * Update feedback count statistics for a chat in Chat table
  * This method aggregates feedback data from chatItems and updates the Chat table
diff --git a/test/cases/service/core/chat/controller.test.ts b/test/cases/service/core/chat/controller.test.ts
index 64055cede4cb..3c1802c78744 100644
--- a/test/cases/service/core/chat/controller.test.ts
+++ b/test/cases/service/core/chat/controller.test.ts
@@ -1,9 +1,5 @@
 import { describe, expect, it, beforeEach } from 'vitest';
-import {
-  getChatItems,
-  addCustomFeedbacks,
-  updateChatFeedbackCount
-} from '@fastgpt/service/core/chat/controller';
+import { getChatItems, updateChatFeedbackCount } from '@fastgpt/service/core/chat/controller';
 import { MongoChatItem } from '@fastgpt/service/core/chat/chatItemSchema';
 import { MongoChat } from '@fastgpt/service/core/chat/chatSchema';
 import { ChatRoleEnum, ChatSourceEnum } from '@fastgpt/global/core/chat/constants';
@@ -722,267 +718,6 @@ describe('getChatItems', () => {
   });
 });
 
-describe('addCustomFeedbacks', () => {
-  let testUser: Awaited<ReturnType<typeof getUser>>;
-  let appId: string;
-  let chatId: string;
-  let dataId: string;
-
-  beforeEach(async () => {
-    testUser = await getUser('test-user-feedback');
-
-    const app = await MongoApp.create({
-      name: 'Test App',
-      type: AppTypeEnum.simple,
-      teamId: testUser.teamId,
-      tmbId: testUser.tmbId,
-      modules: []
-    });
-    appId = String(app._id);
-    chatId = getNanoid();
-    dataId = getNanoid();
-
-    // Create chat record
-    await MongoChat.create({
-      chatId,
-      teamId: testUser.teamId,
-      tmbId: testUser.tmbId,
-      appId,
-      source: ChatSourceEnum.online
-    });
-
-    await MongoChatItem.create({
-      teamId: testUser.teamId,
-      tmbId: testUser.tmbId,
-      appId,
-      chatId,
-      dataId,
-      obj: ChatRoleEnum.AI,
-      value: [{ type: 'text', text: { content: 'Test message' } }]
-    });
-  });
-
-  it('should add custom feedbacks to chat item', async () => {
-    await addCustomFeedbacks({
-      appId,
-      chatId,
-      dataId,
-      feedbacks: ['good', 'helpful']
-    });
-
-    const item = await MongoChatItem.findOne({ dataId }).lean();
-    // Cast to any to access customFeedbacks (it's optional on schema)
-    expect((item as any)?.customFeedbacks).toEqual(['good', 'helpful']);
-  });
-
-  it('should append feedbacks to existing ones', async () => {
-    // Add initial feedbacks
-    await addCustomFeedbacks({
-      appId,
-      chatId,
-      dataId,
-      feedbacks: ['good']
-    });
-
-    // Add more feedbacks
-    await addCustomFeedbacks({
-      appId,
-      chatId,
-      dataId,
-      feedbacks: ['helpful', 'clear']
-    });
-
-    const item = await MongoChatItem.findOne({ dataId }).lean();
-    expect((item as any)?.customFeedbacks).toEqual(['good', 'helpful', 'clear']);
-  });
-
-  it('should handle empty feedbacks array', async () => {
-    await addCustomFeedbacks({
-      appId,
-      chatId,
-      dataId,
-      feedbacks: []
-    });
-
-    const item = await MongoChatItem.findOne({ dataId }).lean();
-    expect((item as any)?.customFeedbacks || []).toHaveLength(0);
-  });
-
-  it('should do nothing when chatId is not provided', async () => {
-    await addCustomFeedbacks({
-      appId,
-      chatId: undefined,
-      dataId,
-      feedbacks: ['good']
-    });
-
-    const item = await MongoChatItem.findOne({ dataId }).lean();
-    // When no update occurs, the field may be an empty array due to schema default or undefined
-    const feedbacks = (item as any)?.customFeedbacks;
-    expect(feedbacks === undefined || feedbacks?.length === 0).toBe(true);
-  });
-
-  it('should do nothing when dataId is not provided', async () => {
-    await addCustomFeedbacks({
-      appId,
-      chatId,
-      dataId: undefined,
-      feedbacks: ['good']
-    });
-
-    const item = await MongoChatItem.findOne({ dataId }).lean();
-    const feedbacks = (item as any)?.customFeedbacks;
-    expect(feedbacks === undefined || feedbacks?.length === 0).toBe(true);
-  });
-
-  it('should handle non-existent item gracefully', async () => {
-    // Should not throw error
-    await expect(
-      addCustomFeedbacks({
-        appId,
-        chatId,
-        dataId: 'non-existent-id',
-        feedbacks: ['good']
-      })
-    ).resolves.not.toThrow();
-  });
-
-  describe('updateChatFeedbackCount integration', () => {
-    it('should not set Chat feedback flags when no user feedback exists', async () => {
-      // addCustomFeedbacks always calls updateChatFeedbackCount
-      // When there's no user feedback, flags should remain undefined
-      await addCustomFeedbacks({
-        appId,
-        chatId,
-        dataId,
-        feedbacks: ['good', 'helpful']
-      });
-
-      const chat = await MongoChat.findOne({ appId, chatId }).lean();
-      // Without user feedback, flags should be undefined (not set)
-      expect(chat?.hasGoodFeedback).toBeUndefined();
-      expect(chat?.hasBadFeedback).toBeUndefined();
-      expect(chat?.hasUnreadGoodFeedback).toBeUndefined();
-      expect(chat?.hasUnreadBadFeedback).toBeUndefined();
-    });
-
-    it('should update Chat flags when chat item has user feedback', async () => {
-      // First, add user good feedback to the chat item
-      await MongoChatItem.updateOne({ dataId }, { $set: { userGoodFeedback: 'Great answer!' } });
-
-      // Then add custom feedbacks (which triggers updateChatFeedbackCount)
-      await addCustomFeedbacks({
-        appId,
-        chatId,
-        dataId,
-        feedbacks: ['category1', 'category2']
-      });
-
-      const chat = await MongoChat.findOne({ appId, chatId }).lean();
-      // Should detect the userGoodFeedback and set flag
-      expect(chat?.hasGoodFeedback).toBe(true);
-      expect(chat?.hasBadFeedback).toBeUndefined();
-    });
-
-    it('should aggregate all feedback when adding custom feedbacks', async () => {
-      // Create another AI message with bad feedback
-      const dataId2 = getNanoid();
-      await MongoChatItem.create({
-        teamId: testUser.teamId,
-        tmbId: testUser.tmbId,
-        appId,
-        chatId,
-        dataId: dataId2,
-        obj: ChatRoleEnum.AI,
-        value: [{ type: 'text', text: { content: 'Another message' } }],
-        userBadFeedback: 'Wrong answer',
-        isFeedbackRead: false
-      });
-
-      // Add user good feedback to first message
-      await MongoChatItem.updateOne(
-        { dataId },
-        { $set: { userGoodFeedback: 'Good answer', isFeedbackRead: true } }
-      );
-
-      // Add custom feedbacks to first message
-      await addCustomFeedbacks({
-        appId,
-        chatId,
-        dataId,
-        feedbacks: ['helpful']
-      });
-
-      const chat = await MongoChat.findOne({ appId, chatId }).lean();
-      // Should aggregate both messages
-      expect(chat?.hasGoodFeedback).toBe(true);
-      expect(chat?.hasBadFeedback).toBe(true);
-      expect(chat?.hasUnreadGoodFeedback).toBeUndefined(); // first message is read
-      expect(chat?.hasUnreadBadFeedback).toBe(true); // second message is unread
-    });
-
-    it('should handle transaction rollback correctly', async () => {
-      // Add user feedback first
-      await MongoChatItem.updateOne({ dataId }, { $set: { userGoodFeedback: 'Great!' } });
-
-      // Normal add should succeed and update Chat flags
-      await addCustomFeedbacks({
-        appId,
-        chatId,
-        dataId,
-        feedbacks: ['good']
-      });
-
-      const chat = await MongoChat.findOne({ appId, chatId }).lean();
-      expect(chat?.hasGoodFeedback).toBe(true);
-
-      // Verify custom feedbacks were added
-      const item = await MongoChatItem.findOne({ dataId }).lean();
-      expect((item as any)?.customFeedbacks).toEqual(['good']);
-    });
-
-    it('should maintain Chat flags consistency across multiple operations', async () => {
-      // Start with no feedback flags
-      let chat = await MongoChat.findOne({ appId, chatId }).lean();
-      expect(chat?.hasGoodFeedback).toBeUndefined();
-
-      // Add user feedback and custom feedback together
-      await MongoChatItem.updateOne(
-        { dataId },
-        { $set: { userGoodFeedback: 'Excellent', isFeedbackRead: false } }
-      );
-
-      await addCustomFeedbacks({
-        appId,
-        chatId,
-        dataId,
-        feedbacks: ['category1']
-      });
-
-      // Check flags are set
-      chat = await MongoChat.findOne({ appId, chatId }).lean();
-      expect(chat?.hasGoodFeedback).toBe(true);
-      expect(chat?.hasUnreadGoodFeedback).toBe(true);
-
-      // Mark as read
-      await MongoChatItem.updateOne({ dataId }, { $set: { isFeedbackRead: true } });
-
-      // Add more custom feedbacks
-      await addCustomFeedbacks({
-        appId,
-        chatId,
-        dataId,
-        feedbacks: ['category2']
-      });
-
-      // Unread flag should be undefined now (not false)
-      chat = await MongoChat.findOne({ appId, chatId }).lean();
-      expect(chat?.hasGoodFeedback).toBe(true);
-      expect(chat?.hasUnreadGoodFeedback).toBeUndefined();
-    });
-  });
-});
-
 describe('updateChatFeedbackCount', () => {
   let testUser: Awaited<ReturnType<typeof getUser>>;
   let appId: string;