fix: Support shared knowledge workflow

Author: zhanweizhang7

apps/common/constants/permission_constants.py

@@ -1308,6 +1308,10 @@ class PermissionConstants(Enum):
         group=Group.SYSTEM_KNOWLEDGE_WORKFLOW, operate=Operate.EDIT, role_list=[RoleConstants.ADMIN],
         parent_group=[SystemGroup.SHARED_KNOWLEDGE], is_ee=settings.edition == "EE"
     )
+    SHARED_KNOWLEDGE_WORKFLOW_EXPORT = Permission(
+        group=Group.SYSTEM_KNOWLEDGE_WORKFLOW, operate=Operate.EXPORT, role_list=[RoleConstants.ADMIN],
+        parent_group=[SystemGroup.SHARED_KNOWLEDGE], is_ee=settings.edition == "EE"
+    )
     SHARED_KNOWLEDGE_DOCUMENT_READ = Permission(
         group=Group.SYSTEM_KNOWLEDGE_DOCUMENT, operate=Operate.READ, role_list=[RoleConstants.ADMIN],
         parent_group=[SystemGroup.SHARED_KNOWLEDGE], is_ee=settings.edition == "EE"

apps/knowledge/serializers/knowledge_workflow.py

@@ -283,7 +283,7 @@ def save_workflow(self, instance: Dict):
 
     class Import(serializers.Serializer):
         user_id = serializers.UUIDField(required=True, label=_('user id'))
-        workspace_id = serializers.CharField(required=True, label=_('workspace id'))
+        workspace_id = serializers.CharField(required=False, label=_('workspace id'))
         knowledge_id = serializers.UUIDField(required=True, label=_('knowledge id'))
 
         @transaction.atomic
@@ -364,13 +364,13 @@ def to_tool(tool, workspace_id, user_id):
                         input_field_list=tool.get('input_field_list'),
                         init_field_list=tool.get('init_field_list'),
                         is_active=False if len((tool.get('init_field_list') or [])) > 0 else tool.get('is_active'),
-                        scope=ToolScope.WORKSPACE,
-                        folder_id=workspace_id,
+                        scope=ToolScope.SHARED if workspace_id == 'None' else ToolScope.WORKSPACE,
+                        folder_id='default' if workspace_id == 'None' else workspace_id,
                         workspace_id=workspace_id)
 
     class Export(serializers.Serializer):
         user_id = serializers.UUIDField(required=True, label=_('user id'))
-        workspace_id = serializers.CharField(required=True, label=_('workspace id'))
+        workspace_id = serializers.CharField(required=False, label=_('workspace id'))
         knowledge_id = serializers.UUIDField(required=True, label=_('knowledge id'))
 
         def export(self, with_valid=True):

ui/src/api/system-shared/knowledge.ts

@@ -388,6 +388,39 @@ const putKnowledgeWorkflow: (
   return put(`${prefix}/${knowledge_id}/workflow`, data, undefined, loading)
 }
 
+/** * 导出知识库工作流
+ * @param knowledge_id
+ * @param knowledge_name
+ * @param loading
+ * @returns
+ */
+const exportKnowledgeWorkflow = (
+  knowledge_id: string,
+  knowledge_name: string,
+  loading?: Ref<boolean>,
+) => {
+  return exportFile(
+    knowledge_name + '.kbwf',
+    `${prefix}/${knowledge_id}/workflow/export`,
+    undefined,
+    loading,
+  )
+}
+
+/** * 导入知识库工作流
+ * @param knowledge_id
+ * @param data
+ * @param loading
+ * @returns
+ */
+const importKnowledgeWorkflow: (
+  knowledge_id: string,
+  data: any,
+  loading?: Ref<boolean>,
+) => Promise<Result<any>> = (knowledge_id, data, loading) => {
+  return post(`${prefix}/${knowledge_id}/workflow/import`, data, undefined, loading)
+}
+
 const workflowUpload: (
   knowledge_id: string,
   instance: Dict<any>,
@@ -443,6 +476,8 @@ export default {
   listKnowledgeVersion,
   workflowUpload,
   getWorkflowActionPage,
+  exportKnowledgeWorkflow,
+  importKnowledgeWorkflow,
 } as {
   [key: string]: any
 }

ui/src/views/knowledge-workflow/index.vue

@@ -411,7 +411,6 @@ const importKnowledgeWorkflow = (file: any) => {
   formData.append('file', file.raw)
   const name = file.name.replace('.kbwf', '')
   elUploadRef.value.clearFiles()
-  debugger
   MsgConfirm(
     t('common.tip'),
     `${t('views.application.tip.confirmUse')} ${name} ${t('views.application.tip.overwrite')}?`,