perf: think tag parse (#4102)

packages/service/core/ai/utils.ts

@@ -132,7 +132,7 @@ export const parseReasoningStreamContent = () => {
   let endTagBuffer = '';
 
   /* 
-    parseReasoning - 只控制是否主动解析 <think></think>，如果接口已经解析了，仍然会返回 think 内容。
+    parseThinkTag - 只控制是否主动解析 <think></think>，如果接口已经解析了，则不再解析。
   */
   const parsePart = (
     part: {
@@ -143,13 +143,13 @@ export const parseReasoningStreamContent = () => {
         };
       }[];
     },
-    parseReasoning = false
+    parseThinkTag = false
   ): [string, string] => {
     const content = part.choices?.[0]?.delta?.content || '';
 
     // @ts-ignore
     const reasoningContent = part.choices?.[0]?.delta?.reasoning_content || '';
-    if (reasoningContent || !parseReasoning) {
+    if (reasoningContent || !parseThinkTag) {
       isInThinkTag = false;
       return [reasoningContent, content];
     }

packages/service/core/workflow/dispatch/chat/oneapi.ts

@@ -208,6 +208,7 @@ export const dispatchChatCompletion = async (props: ChatProps): Promise<ChatResp
         res,
         stream: response,
         aiChatReasoning,
+        parseThinkTag: modelConstantsData.reasoning,
         isResponseAnswerText,
         workflowStreamResponse
       });
@@ -513,12 +514,14 @@ async function streamResponse({
   stream,
   workflowStreamResponse,
   aiChatReasoning,
+  parseThinkTag,
   isResponseAnswerText
 }: {
   res: NextApiResponse;
   stream: StreamChatType;
   workflowStreamResponse?: WorkflowResponseType;
   aiChatReasoning?: boolean;
+  parseThinkTag?: boolean;
   isResponseAnswerText?: boolean;
 }) {
   const write = responseWriteController({
@@ -535,7 +538,7 @@ async function streamResponse({
       break;
     }
 
-    const [reasoningContent, content] = parsePart(part, aiChatReasoning);
+    const [reasoningContent, content] = parsePart(part, parseThinkTag);
     answer += content;
     reasoning += reasoningContent;