feat: Support reasoning content(WIP)

Author: shaohuzhang1

apps/application/flow/i_step_node.py

@@ -62,7 +62,9 @@ def handler(self, chat_id,
         answer_tokens = sum([row.get('answer_tokens') for row in details.values() if
                              'answer_tokens' in row and row.get('answer_tokens') is not None])
         answer_text_list = workflow.get_answer_text_list()
-        answer_text = '\n\n'.join(answer['content'] for answer in answer_text_list)
+        answer_text = '\n\n'.join(
+            '\n\n'.join(["\n\n".join([a.get('reasoning_content'), a.get('content')]) for a in answer]) for answer in
+            answer_text_list)
         if workflow.chat_record is not None:
             chat_record = workflow.chat_record
             chat_record.answer_text = answer_text

apps/application/flow/workflow_manage.py

@@ -609,20 +609,19 @@ def get_answer_text_list(self):
             if len(current_answer.content) > 0:
                 if up_node is None or current_answer.view_type == 'single_view' or (
                         current_answer.view_type == 'many_view' and up_node.view_type == 'single_view'):
-                    result.append(current_answer)
+                    result.append([current_answer])
                 else:
                     if len(result) > 0:
                         exec_index = len(result) - 1
-                        content = result[exec_index].content
-                        result[exec_index].content += current_answer.content if len(
-                            content) == 0 else ('\n\n' + current_answer.content)
+                        if isinstance(result[exec_index], list):
+                            result[exec_index].append(current_answer)
                     else:
-                        result.insert(0, current_answer)
+                        result.insert(0, [current_answer])
                 up_node = current_answer
         if len(result) == 0:
             # 如果没有响应 就响应一个空数据
-            return [Answer('', '', '', '', {}).to_dict()]
-        return [r.to_dict() for r in result]
+            return [[]]
+        return [[item.to_dict() for item in r] for r in result]
 
     def get_next_node(self):
         """

ui/src/api/type/application.ts

@@ -290,19 +290,19 @@ export class ChatRecordManage {
             break
           }
           this.append_answer(
-            (node_info.divider_content ? node_info.divider_content.splice(0).join('') : '') +
-              node_info.current_node.buffer.splice(0).join(''),
-            (node_info.divider_reasoning_content
-              ? node_info.divider_reasoning_content.splice(0).join('')
-              : '') + node_info.current_node.reasoning_content_buffer.splice(0).join(''),
+            node_info.current_node.buffer.splice(0).join(''),
+            node_info.current_node.reasoning_content_buffer.splice(0).join(''),
             node_info.answer_text_list_index,
             node_info.current_node.chat_record_id,
             node_info.current_node.runtime_node_id,
             node_info.current_node.child_node,
             node_info.current_node.real_node_id
           )
 
-          if (node_info.current_node.buffer.length == 0) {
+          if (
+            node_info.current_node.buffer.length == 0 &&
+            node_info.current_node.reasoning_content_buffer.length == 0
+          ) {
             node_info.current_node.is_end = true
           }
         }