fix: Fix null pointer exception (#5136)

Author: wangliang181230

apps/application/flow/step_node/ai_chat_step_node/impl/base_chat_node.py

@@ -365,7 +365,7 @@ def handle_variables(self, tool_params):
                 tool_params[k] = self.workflow_manage.generate_prompt(tool_params[k])
             elif type(v) == dict:
                 self.handle_variables(v)
-            elif (type(v) == list) and len(v) > 0 and type(v[0]) == str:
+            elif (type(v) == list) and len(v) > 0 and (type(v[0]) == str):
                 tool_params[k] = self.get_reference_content(v)
         return tool_params
 

apps/application/flow/step_node/mcp_node/impl/base_mcp_node.py

@@ -51,9 +51,9 @@ def handle_variables(self, tool_params):
         for k, v in tool_params.items():
             if type(v) == str:
                 tool_params[k] = self.workflow_manage.generate_prompt(tool_params[k])
-            if type(v) == dict:
+            elif type(v) == dict:
                 self.handle_variables(v)
-            if (type(v) == list) and (type(v[0]) == str):
+            elif (type(v) == list) and len(v) > 0 and (type(v[0]) == str):
                 tool_params[k] = self.get_reference_content(v)
         return tool_params
 

apps/chat/serializers/chat_record.py

@@ -75,8 +75,7 @@ def vote(self, instance: Dict, with_valid=True):
                     chat_record_details_model.vote_status = VoteChoices.STAR
                     chat_record_details_model.vote_reason = vote_reason
                     chat_record_details_model.vote_other_content = vote_other_content
-
-                if vote_status == VoteChoices.TRAMPLE:
+                elif vote_status == VoteChoices.TRAMPLE:
                     # 点踩
                     chat_record_details_model.vote_status = VoteChoices.TRAMPLE
                     chat_record_details_model.vote_reason = vote_reason

apps/common/auth/handle/impl/user_token.py

@@ -258,10 +258,10 @@ def get_role_list(user,
     """
     version = Cache_Version.ROLE_LIST.get_version()
     key = Cache_Version.ROLE_LIST.get_key(user_id=user.id)
-    workspace_list = cache.get(key, version=version)
+    role_list = cache.get(key, version=version)
     # 获取权限列表
     is_query_model = workspace_user_role_mapping_model is not None and workspace_model is not None and role_model is not None and role_permission_mapping_model is not None
-    if workspace_list is None:
+    if role_list is None:
         if is_query_model:
             # 获取工作空间 用户 角色映射数据
             workspace_user_role_mapping_list = QuerySet(workspace_user_role_mapping_model).filter(user_id=user.id)
@@ -274,16 +274,14 @@ def get_role_list(user,
                                                    for
                                                    workspace_user_role_mapping in
                                                    workspace_user_role_mapping_list], [])))
-            cache.set(key, workspace_list, version=version)
-            return role_list
+            cache.set(key, role_list, version=version)
         else:
             if user.role == RoleConstants.ADMIN.value.__str__():
                 role_list = [user.role, get_role_permission(RoleConstants.WORKSPACE_MANAGE, 'default')]
             else:
                 role_list = [user.role, get_role_permission(RoleConstants.USER, 'default')]
             cache.set(key, role_list, version=version)
-            return role_list
-    return workspace_list
+    return role_list
 
 
 def get_auth(user):

apps/common/handle/base_parse_qa_handle.py

@@ -22,7 +22,7 @@ def get_title_row_index_dict(title_row_list):
     title_row_index_dict = {}
     if len(title_row_list) == 1:
         title_row_index_dict['content'] = 0
-    elif len(title_row_list) == 1:
+    elif len(title_row_list) == 2:
         title_row_index_dict['title'] = 0
         title_row_index_dict['content'] = 1
     else:
@@ -33,11 +33,11 @@ def get_title_row_index_dict(title_row_list):
         title_row = title_row_list[index]
         if title_row is None:
             title_row = ''
-        if title_row.startswith('分段标题'):
+        elif title_row.startswith('分段标题'):
             title_row_index_dict['title'] = index
-        if title_row.startswith('分段内容'):
+        elif title_row.startswith('分段内容'):
             title_row_index_dict['content'] = index
-        if title_row.startswith('问题'):
+        elif title_row.startswith('问题'):
             title_row_index_dict['problem_list'] = index
     return title_row_index_dict
 

apps/models_provider/impl/aliyun_bai_lian_model_provider/model/ttv.py

@@ -108,13 +108,12 @@ def generate_video(self, prompt, negative_prompt=None, first_frame_url=None, las
         # --- 等待任务完成 ---
         rsp = self._safe_call(VideoSynthesis.wait, task=rsp, api_key=self.api_key)
         if rsp.status_code == HTTPStatus.OK:
-            maxkb_logger.info("视频生成完成！视频 URL:", rsp.output.video_url)
             if rsp.output.task_status == "SUCCEEDED":
-                maxkb_logger.info("视频生成完成！视频 URL:", rsp.output.video_url)
+                maxkb_logger.info(f'视频生成完成！视频 URL: {rsp.output.video_url}')
                 return rsp.output.video_url
             else:
-                maxkb_logger.error("视频生成失败！")
-                raise RuntimeError(f'生成失败, message: {rsp.output.message}')
+                maxkb_logger.error(f'视频生成失败: {rsp.output.message}')
+                raise RuntimeError(f'视频生成失败, message: {rsp.output.message}')
         else:
             maxkb_logger.error(f'生成失败，status_code: {rsp.status_code}, code: {rsp.code}, message: {rsp.message}')
             raise RuntimeError(f'生成失败，status_code: {rsp.status_code}, code: {rsp.code}, message: {rsp.message}')

ui/src/locales/lang/en-US/workflow.ts

@@ -189,7 +189,7 @@ export default {
       result: 'Search Results',
       searchParam: 'Search Parameters',
       select_variable: 'Select Variable',
-      valueMessage: `Value or name `,
+      valueMessage: 'Value or name',
 
       searchQuestion: {
         label: 'Search Question',